Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.streams

Class PersistentStreamServiceGrpc.PersistentStreamServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<PersistentStreamServiceGrpc.PersistentStreamServiceStub>

io.axoniq.axonserver.grpc.streams.PersistentStreamServiceGrpc.PersistentStreamServiceStub

Enclosing class:

PersistentStreamServiceGrpc

public static final class PersistentStreamServiceGrpc.PersistentStreamServiceStub
extends io.grpc.stub.AbstractAsyncStub<PersistentStreamServiceGrpc.PersistentStreamServiceStub>

A stub to allow clients to do asynchronous rpc calls to service PersistentStreamService.

 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.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

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

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected PersistentStreamServiceGrpc.PersistentStreamServiceStub build(io.grpc.Channel channel,
                                                                        io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<PersistentStreamServiceGrpc.PersistentStreamServiceStub>

createStream

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

 Creates a persistent stream if it does not exist. 
 

openStream

public 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

public 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

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

 Change properties of a persistent event stream. 
 

listStreams

public 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

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

 Resets the position of a persistent stream.