| CreateStreamRequest |
Request to create a persistent stream
|
| CreateStreamRequest.Builder |
Request to create a persistent stream
|
| CreateStreamResponse |
Response for a create stream request
|
| CreateStreamResponse.Builder |
Response for a create stream request
|
| DeleteStreamRequest |
Request to delete a persistent stream
|
| DeleteStreamRequest.Builder |
Request to delete a persistent stream
|
| InitializationProperties |
Properties to create the stream if it does not exist
|
| InitializationProperties.Builder |
Properties to create the stream if it does not exist
|
| ListStreamsRequest |
request to list the persistent streams for a context
|
| ListStreamsRequest.Builder |
request to list the persistent streams for a context
|
| Open |
Request to open a connection to a persistent stream
|
| Open.Builder |
Request to open a connection to a persistent stream
|
| OpenSegment |
Message to prepare client for events on a specific segment
|
| OpenSegment.Builder |
Message to prepare client for events on a specific segment
|
| PersistentStreamEvent |
Event sent on a persistent stream segment
|
| PersistentStreamEvent.Builder |
Event sent on a persistent stream segment
|
| PersistentStreams |
|
| PersistentStreamServiceGrpc |
Service providing operations for persistent event streams, event streams where Axon Server keeps
track of the progress.
|
| PersistentStreamServiceGrpc.PersistentStreamServiceBlockingStub |
A stub to allow clients to do limited synchronous rpc calls to service PersistentStreamService.
|
| PersistentStreamServiceGrpc.PersistentStreamServiceBlockingV2Stub |
A stub to allow clients to do synchronous rpc calls to service PersistentStreamService.
|
| PersistentStreamServiceGrpc.PersistentStreamServiceFutureStub |
A stub to allow clients to do ListenableFuture-style rpc calls to service PersistentStreamService.
|
| PersistentStreamServiceGrpc.PersistentStreamServiceImplBase |
Base class for the server implementation of the service PersistentStreamService.
|
| PersistentStreamServiceGrpc.PersistentStreamServiceStub |
A stub to allow clients to do asynchronous rpc calls to service PersistentStreamService.
|
| ProgressAcknowledgement |
Message to report progress of event processing for a specific segment in a stream
|
| ProgressAcknowledgement.Builder |
Message to report progress of event processing for a specific segment in a stream
|
| Requests |
Protobuf type io.axoniq.axonserver.grpc.streams.Requests
|
| Requests.Builder |
Protobuf type io.axoniq.axonserver.grpc.streams.Requests
|
| ResetStreamConfiguration |
Message to provide parameters for resetting a persistent stream
|
| ResetStreamConfiguration.Builder |
Message to provide parameters for resetting a persistent stream
|
| ResetStreamRequest |
Protobuf type io.axoniq.axonserver.grpc.streams.ResetStreamRequest
|
| ResetStreamRequest.Builder |
Protobuf type io.axoniq.axonserver.grpc.streams.ResetStreamRequest
|
| SegmentError |
Request to notify Axon Server of an error on a persistent stream segment
|
| SegmentError.Builder |
Request to notify Axon Server of an error on a persistent stream segment
|
| SegmentPosition |
Contains the position per segment
|
| SegmentPosition.Builder |
Contains the position per segment
|
| SequencingPolicy |
Defines the policy used to distribute events across segments.
|
| SequencingPolicy.Builder |
Defines the policy used to distribute events across segments.
|
| StreamRequest |
Request to set up a connection to a stream.
|
| StreamRequest.Builder |
Request to set up a connection to a stream.
|
| StreamSignal |
Message sent by Axon Server to the client stream connection
|
| StreamSignal.Builder |
Message sent by Axon Server to the client stream connection
|
| StreamStatus |
Contains the current status of a persistent stream
|
| StreamStatus.Builder |
Contains the current status of a persistent stream
|
| UpdateStreamRequest |
Request to update the properties of a persistent stream
|
| UpdateStreamRequest.Builder |
Request to update the properties of a persistent stream
|