Module io.axoniq.connector.axonserver
Package io.axoniq.axonserver.grpc.event

Interface GetEventsRequestOrBuilder

  • All Superinterfaces:
    com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
    All Known Implementing Classes:
    GetEventsRequest, GetEventsRequest.Builder
    @Generated
public interface GetEventsRequestOrBuilder
extends com.google.protobuf.MessageOrBuilder

    • Method Detail

      • getTrackingToken

        long getTrackingToken()
         The token to start streaming from
        int64 tracking_token = 1;
        Returns:
        The trackingToken.

      • getNumberOfPermits

        long getNumberOfPermits()
         The number of messages the server may send before it needs to wait for more permits
        int64 number_of_permits = 2;
        Returns:
        The numberOfPermits.

      • getClientId

        String getClientId()
         The unique identifier of this client instance. Used for monitoring.
        string client_id = 3;
        Returns:
        The clientId.

      • getClientIdBytes

        com.google.protobuf.ByteString getClientIdBytes()
         The unique identifier of this client instance. Used for monitoring.
        string client_id = 3;
        Returns:
        The bytes for clientId.

      • getComponentName

        String getComponentName()
         The component name of this client instance. Used for monitoring.
        string component_name = 4;
        Returns:
        The componentName.

      • getComponentNameBytes

        com.google.protobuf.ByteString getComponentNameBytes()
         The component name of this client instance. Used for monitoring.
        string component_name = 4;
        Returns:
        The bytes for componentName.

      • getProcessor

        String getProcessor()
         The name of the processor requesting this stream. Used for monitoring.
        string processor = 5;
        Returns:
        The processor.

      • getProcessorBytes

        com.google.protobuf.ByteString getProcessorBytes()
         The name of the processor requesting this stream. Used for monitoring.
        string processor = 5;
        Returns:
        The bytes for processor.

      • getBlacklistList

        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;

      • getBlacklist

        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;

      • getBlacklistCount

        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;

      • getBlacklistOrBuilderList

        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;

      • getBlacklistOrBuilder

        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;

      • getForceReadFromLeader

        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;
        Returns:
        The forceReadFromLeader.