Package io.axoniq.axonserver.grpc.event
Class GetEventsRequest
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessage
-
- io.axoniq.axonserver.grpc.event.GetEventsRequest
-
- All Implemented Interfaces:
com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,GetEventsRequestOrBuilder,Serializable
@Generated public final class GetEventsRequest extends com.google.protobuf.GeneratedMessage implements GetEventsRequestOrBuilder
Request message to open an Event Stream from the Event Store.
Protobuf typeio.axoniq.axonserver.grpc.event.GetEventsRequest- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classGetEventsRequest.BuilderRequest message to open an Event Stream from the Event Store.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T extends Object>, com.google.protobuf.GeneratedMessage.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intBLACKLIST_FIELD_NUMBERstatic intCLIENT_ID_FIELD_NUMBERstatic intCOMPONENT_NAME_FIELD_NUMBERstatic intFORCE_READ_FROM_LEADER_FIELD_NUMBERstatic intNUMBER_OF_PERMITS_FIELD_NUMBERstatic intPROCESSOR_FIELD_NUMBERstatic intTRACKING_TOKEN_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)PayloadDescriptiongetBlacklist(int index)An enumeration of payload types that need to be blacklisted.intgetBlacklistCount()An enumeration of payload types that need to be blacklisted.List<PayloadDescription>getBlacklistList()An enumeration of payload types that need to be blacklisted.PayloadDescriptionOrBuildergetBlacklistOrBuilder(int index)An enumeration of payload types that need to be blacklisted.List<? extends PayloadDescriptionOrBuilder>getBlacklistOrBuilderList()An enumeration of payload types that need to be blacklisted.StringgetClientId()The unique identifier of this client instance.com.google.protobuf.ByteStringgetClientIdBytes()The unique identifier of this client instance.StringgetComponentName()The component name of this client instance.com.google.protobuf.ByteStringgetComponentNameBytes()The component name of this client instance.static GetEventsRequestgetDefaultInstance()GetEventsRequestgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.Descriptors.DescriptorgetDescriptorForType()booleangetForceReadFromLeader()Indicates whether to force reading events from the leader node of an Axon Server.longgetNumberOfPermits()The number of messages the server may send before it needs to wait for more permitscom.google.protobuf.Parser<GetEventsRequest>getParserForType()StringgetProcessor()The name of the processor requesting this stream.com.google.protobuf.ByteStringgetProcessorBytes()The name of the processor requesting this stream.intgetSerializedSize()longgetTrackingToken()The token to start streaming frominthashCode()protected com.google.protobuf.GeneratedMessage.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static GetEventsRequest.BuildernewBuilder()static GetEventsRequest.BuildernewBuilder(GetEventsRequest prototype)GetEventsRequest.BuildernewBuilderForType()protected GetEventsRequest.BuildernewBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)static GetEventsRequestparseDelimitedFrom(InputStream input)static GetEventsRequestparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static GetEventsRequestparseFrom(byte[] data)static GetEventsRequestparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static GetEventsRequestparseFrom(com.google.protobuf.ByteString data)static GetEventsRequestparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static GetEventsRequestparseFrom(com.google.protobuf.CodedInputStream input)static GetEventsRequestparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static GetEventsRequestparseFrom(InputStream input)static GetEventsRequestparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static GetEventsRequestparseFrom(ByteBuffer data)static GetEventsRequestparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<GetEventsRequest>parser()GetEventsRequest.BuildertoBuilder()voidwriteTo(com.google.protobuf.CodedOutputStream output)-
Methods inherited from class com.google.protobuf.GeneratedMessage
computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, makeMutableCopy, newFileScopedGeneratedExtension, newInstance, newMessageScopedGeneratedExtension, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashFields, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
TRACKING_TOKEN_FIELD_NUMBER
public static final int TRACKING_TOKEN_FIELD_NUMBER
- See Also:
- Constant Field Values
-
NUMBER_OF_PERMITS_FIELD_NUMBER
public static final int NUMBER_OF_PERMITS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
CLIENT_ID_FIELD_NUMBER
public static final int CLIENT_ID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
COMPONENT_NAME_FIELD_NUMBER
public static final int COMPONENT_NAME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PROCESSOR_FIELD_NUMBER
public static final int PROCESSOR_FIELD_NUMBER
- See Also:
- Constant Field Values
-
BLACKLIST_FIELD_NUMBER
public static final int BLACKLIST_FIELD_NUMBER
- See Also:
- Constant Field Values
-
FORCE_READ_FROM_LEADER_FIELD_NUMBER
public static final int FORCE_READ_FROM_LEADER_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessage
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessage
-
getTrackingToken
public long getTrackingToken()
The token to start streaming from
int64 tracking_token = 1;- Specified by:
getTrackingTokenin interfaceGetEventsRequestOrBuilder- Returns:
- The trackingToken.
-
getNumberOfPermits
public long getNumberOfPermits()
The number of messages the server may send before it needs to wait for more permits
int64 number_of_permits = 2;- Specified by:
getNumberOfPermitsin interfaceGetEventsRequestOrBuilder- Returns:
- The numberOfPermits.
-
getClientId
public String getClientId()
The unique identifier of this client instance. Used for monitoring.
string client_id = 3;- Specified by:
getClientIdin interfaceGetEventsRequestOrBuilder- Returns:
- The clientId.
-
getClientIdBytes
public com.google.protobuf.ByteString getClientIdBytes()
The unique identifier of this client instance. Used for monitoring.
string client_id = 3;- Specified by:
getClientIdBytesin interfaceGetEventsRequestOrBuilder- Returns:
- The bytes for clientId.
-
getComponentName
public String getComponentName()
The component name of this client instance. Used for monitoring.
string component_name = 4;- Specified by:
getComponentNamein interfaceGetEventsRequestOrBuilder- Returns:
- The componentName.
-
getComponentNameBytes
public com.google.protobuf.ByteString getComponentNameBytes()
The component name of this client instance. Used for monitoring.
string component_name = 4;- Specified by:
getComponentNameBytesin interfaceGetEventsRequestOrBuilder- Returns:
- The bytes for componentName.
-
getProcessor
public String getProcessor()
The name of the processor requesting this stream. Used for monitoring.
string processor = 5;- Specified by:
getProcessorin interfaceGetEventsRequestOrBuilder- Returns:
- The processor.
-
getProcessorBytes
public com.google.protobuf.ByteString getProcessorBytes()
The name of the processor requesting this stream. Used for monitoring.
string processor = 5;- Specified by:
getProcessorBytesin interfaceGetEventsRequestOrBuilder- Returns:
- The bytes for processor.
-
getBlacklistList
public List<PayloadDescription> getBlacklistList()
An enumeration of payload types that need to be blacklisted. The Server will stop sending messages of these types in order to reduce I/O. Note that the Server may occasionally send a blacklisted message to prevent time-outs and stale tokens on clients.
repeated .io.axoniq.axonserver.grpc.event.PayloadDescription blacklist = 6;- Specified by:
getBlacklistListin interfaceGetEventsRequestOrBuilder
-
getBlacklistOrBuilderList
public List<? extends PayloadDescriptionOrBuilder> getBlacklistOrBuilderList()
An enumeration of payload types that need to be blacklisted. The Server will stop sending messages of these types in order to reduce I/O. Note that the Server may occasionally send a blacklisted message to prevent time-outs and stale tokens on clients.
repeated .io.axoniq.axonserver.grpc.event.PayloadDescription blacklist = 6;- Specified by:
getBlacklistOrBuilderListin interfaceGetEventsRequestOrBuilder
-
getBlacklistCount
public int getBlacklistCount()
An enumeration of payload types that need to be blacklisted. The Server will stop sending messages of these types in order to reduce I/O. Note that the Server may occasionally send a blacklisted message to prevent time-outs and stale tokens on clients.
repeated .io.axoniq.axonserver.grpc.event.PayloadDescription blacklist = 6;- Specified by:
getBlacklistCountin interfaceGetEventsRequestOrBuilder
-
getBlacklist
public PayloadDescription getBlacklist(int index)
An enumeration of payload types that need to be blacklisted. The Server will stop sending messages of these types in order to reduce I/O. Note that the Server may occasionally send a blacklisted message to prevent time-outs and stale tokens on clients.
repeated .io.axoniq.axonserver.grpc.event.PayloadDescription blacklist = 6;- Specified by:
getBlacklistin interfaceGetEventsRequestOrBuilder
-
getBlacklistOrBuilder
public PayloadDescriptionOrBuilder getBlacklistOrBuilder(int index)
An enumeration of payload types that need to be blacklisted. The Server will stop sending messages of these types in order to reduce I/O. Note that the Server may occasionally send a blacklisted message to prevent time-outs and stale tokens on clients.
repeated .io.axoniq.axonserver.grpc.event.PayloadDescription blacklist = 6;- Specified by:
getBlacklistOrBuilderin interfaceGetEventsRequestOrBuilder
-
getForceReadFromLeader
public boolean getForceReadFromLeader()
Indicates whether to force reading events from the leader node of an Axon Server. Forcing reads from leader reduces the staleness of the data read, but also puts extra burden on the leader, reducing overall scalability. <p> This property has no effect on connections to AxonServer SE. </p>
bool force_read_from_leader = 7;- Specified by:
getForceReadFromLeaderin interfaceGetEventsRequestOrBuilder- Returns:
- The forceReadFromLeader.
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessage- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessage
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static GetEventsRequest parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static GetEventsRequest parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static GetEventsRequest parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static GetEventsRequest parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static GetEventsRequest parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static GetEventsRequest parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static GetEventsRequest parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static GetEventsRequest parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static GetEventsRequest parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static GetEventsRequest parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static GetEventsRequest parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static GetEventsRequest parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public GetEventsRequest.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static GetEventsRequest.Builder newBuilder()
-
newBuilder
public static GetEventsRequest.Builder newBuilder(GetEventsRequest prototype)
-
toBuilder
public GetEventsRequest.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected GetEventsRequest.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
- Overrides:
newBuilderForTypein classcom.google.protobuf.AbstractMessage
-
getDefaultInstance
public static GetEventsRequest getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<GetEventsRequest> parser()
-
getParserForType
public com.google.protobuf.Parser<GetEventsRequest> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessage
-
getDefaultInstanceForType
public GetEventsRequest getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-