Uses of Class
io.axoniq.axonserver.grpc.streams.StreamStatus
-
Packages that use StreamStatus Package Description io.axoniq.axonserver.connector.event io.axoniq.axonserver.connector.event.impl io.axoniq.axonserver.grpc.streams -
-
Uses of StreamStatus in io.axoniq.axonserver.connector.event
Methods in io.axoniq.axonserver.connector.event that return types with arguments of type StreamStatus Modifier and Type Method Description CompletableFuture<List<StreamStatus>>EventChannel. persistentStreams()Returns a list of persistent streams with the last confirmed token per segment. -
Uses of StreamStatus in io.axoniq.axonserver.connector.event.impl
Methods in io.axoniq.axonserver.connector.event.impl that return types with arguments of type StreamStatus Modifier and Type Method Description CompletableFuture<List<StreamStatus>>EventChannelImpl. persistentStreams() -
Uses of StreamStatus in io.axoniq.axonserver.grpc.streams
Methods in io.axoniq.axonserver.grpc.streams that return StreamStatus Modifier and Type Method Description StreamStatusStreamStatus.Builder. build()StreamStatusStreamStatus.Builder. buildPartial()static StreamStatusStreamStatus. getDefaultInstance()StreamStatusStreamStatus.Builder. getDefaultInstanceForType()StreamStatusStreamStatus. getDefaultInstanceForType()static StreamStatusStreamStatus. parseDelimitedFrom(InputStream input)static StreamStatusStreamStatus. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamStatusStreamStatus. parseFrom(byte[] data)static StreamStatusStreamStatus. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamStatusStreamStatus. parseFrom(com.google.protobuf.ByteString data)static StreamStatusStreamStatus. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamStatusStreamStatus. parseFrom(com.google.protobuf.CodedInputStream input)static StreamStatusStreamStatus. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamStatusStreamStatus. parseFrom(InputStream input)static StreamStatusStreamStatus. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static StreamStatusStreamStatus. parseFrom(ByteBuffer data)static StreamStatusStreamStatus. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)Methods in io.axoniq.axonserver.grpc.streams that return types with arguments of type StreamStatus Modifier and Type Method Description static io.grpc.MethodDescriptor<ListStreamsRequest,StreamStatus>PersistentStreamServiceGrpc. getListStreamsMethod()com.google.protobuf.Parser<StreamStatus>StreamStatus. getParserForType()Iterator<StreamStatus>PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub. listStreams(ListStreamsRequest request)Returns a list of all persistent event streams defined (for the context).io.grpc.stub.BlockingClientCall<?,StreamStatus>PersistentStreamServiceGrpc.PersistentStreamServiceBlockingV2Stub. listStreams(ListStreamsRequest request)Returns a list of all persistent event streams defined (for the context).static com.google.protobuf.Parser<StreamStatus>StreamStatus. parser()Methods in io.axoniq.axonserver.grpc.streams with parameters of type StreamStatus Modifier and Type Method Description StreamStatus.BuilderStreamStatus.Builder. mergeFrom(StreamStatus other)static StreamStatus.BuilderStreamStatus. newBuilder(StreamStatus prototype)Method parameters in io.axoniq.axonserver.grpc.streams with type arguments of type StreamStatus Modifier and Type Method Description default voidPersistentStreamServiceGrpc.AsyncService. listStreams(ListStreamsRequest request, io.grpc.stub.StreamObserver<StreamStatus> responseObserver)Returns a list of all persistent event streams defined (for the context).voidPersistentStreamServiceGrpc.PersistentStreamServiceStub. listStreams(ListStreamsRequest request, io.grpc.stub.StreamObserver<StreamStatus> responseObserver)Returns a list of all persistent event streams defined (for the context).
-