Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.streams

Interface PersistentStreamServiceGrpc.AsyncService

All Known Implementing Classes:

PersistentStreamServiceGrpc.PersistentStreamServiceImplBase

Enclosing class:

PersistentStreamServiceGrpc

public static interface PersistentStreamServiceGrpc.AsyncService

 Service providing operations for persistent event streams, event streams where Axon Server keeps
track of the progress. All operations require a header (AxonIQ-Context) to be passed with each request to define
the context.
 

Method Summary

Modifier and Type	Method	Description
default void	createStream(CreateStreamRequest request, io.grpc.stub.StreamObserver<CreateStreamResponse> responseObserver)	Creates a persistent stream if it does not exist.
default void	deleteStream(DeleteStreamRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Deletes a persistent event stream.
default void	listStreams(ListStreamsRequest request, io.grpc.stub.StreamObserver<StreamStatus> responseObserver)	Returns a list of all persistent event streams defined (for the context).
default io.grpc.stub.StreamObserver<StreamRequest>	openStream(io.grpc.stub.StreamObserver<StreamSignal> responseObserver)	Open a persistent event stream connection from a client.
default void	resetStream(ResetStreamRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Resets the position of a persistent stream.
default void	updateStream(UpdateStreamRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)	Change properties of a persistent event stream.

Method Detail

createStream

default void createStream(CreateStreamRequest request,
                          io.grpc.stub.StreamObserver<CreateStreamResponse> responseObserver)

 Creates a persistent stream if it does not exist. 
 

openStream

default io.grpc.stub.StreamObserver<StreamRequest> openStream(io.grpc.stub.StreamObserver<StreamSignal> responseObserver)

 Open a persistent event stream connection from a client. Creates the stream if it does not exist. 
 

deleteStream

default void deleteStream(DeleteStreamRequest request,
                          io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Deletes a persistent event stream. All existing connections to the stream are closed. 
 

updateStream

default void updateStream(UpdateStreamRequest request,
                          io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Change properties of a persistent event stream. 
 

listStreams

default void listStreams(ListStreamsRequest request,
                         io.grpc.stub.StreamObserver<StreamStatus> responseObserver)

 Returns a list of all persistent event streams defined (for the context). For each event stream it returns
the progress per segment.  
 

resetStream

default void resetStream(ResetStreamRequest request,
                         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

 Resets the position of a persistent stream.