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

Interface StreamStatusOrBuilder

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

    • Method Detail

      • getStreamId

        String getStreamId()
         the unique identification of the persistent stream
        string stream_id = 1;
        Returns:
        The streamId.

      • getStreamIdBytes

        com.google.protobuf.ByteString getStreamIdBytes()
         the unique identification of the persistent stream
        string stream_id = 1;
        Returns:
        The bytes for streamId.

      • getStreamName

        String getStreamName()
         a name for the persistent stream
        string stream_name = 2;
        Returns:
        The streamName.

      • getStreamNameBytes

        com.google.protobuf.ByteString getStreamNameBytes()
         a name for the persistent stream
        string stream_name = 2;
        Returns:
        The bytes for streamName.

      • hasSequencingPolicy

        boolean hasSequencingPolicy()
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;
        Returns:
        Whether the sequencingPolicy field is set.

      • getSequencingPolicy

        SequencingPolicy getSequencingPolicy()
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;
        Returns:
        The sequencingPolicy.

      • getSequencingPolicyOrBuilder

        SequencingPolicyOrBuilder getSequencingPolicyOrBuilder()
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;

      • getFilter

        String getFilter()
         an expression to filter events, same syntax as used for ad-hoc queries on the event store
        string filter = 4;
        Returns:
        The filter.

      • getFilterBytes

        com.google.protobuf.ByteString getFilterBytes()
         an expression to filter events, same syntax as used for ad-hoc queries on the event store
        string filter = 4;
        Returns:
        The bytes for filter.

      • getSegmentsList

        List<SegmentPosition> getSegmentsList()
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • getSegments

        SegmentPosition getSegments​(int index)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • getSegmentsCount

        int getSegmentsCount()
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • getSegmentsOrBuilderList

        List<? extends SegmentPositionOrBuilder> getSegmentsOrBuilderList()
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • getSegmentsOrBuilder

        SegmentPositionOrBuilder getSegmentsOrBuilder​(int index)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;