Uses of Class
io.axoniq.axonserver.grpc.event.Event

Packages that use Event

Package	Description
io.axoniq.axonserver.connector.event
io.axoniq.axonserver.connector.event.impl
io.axoniq.axonserver.connector.event.transformation
io.axoniq.axonserver.connector.event.transformation.impl
io.axoniq.axonserver.connector.event.transformation.impl.grpc
io.axoniq.axonserver.grpc.event

Uses of Event in io.axoniq.axonserver.connector.event

Methods in io.axoniq.axonserver.connector.event that return Event

Modifier and Type	Method	Description
Event	AggregateEventStream.next()	Returns the next available event, possibly blocking until one becomes available for reading.

Methods in io.axoniq.axonserver.connector.event that return types with arguments of type Event

Modifier and Type	Method	Description
default Stream<Event>	AggregateEventStream.asStream()	Returns a Stream that consumes the Events from this instance.

Methods in io.axoniq.axonserver.connector.event with parameters of type Event

Modifier and Type	Method	Description
AppendEventsTransaction	AppendEventsTransaction.appendEvent(Event event)	Append the given event to be committed as part of this transaction.
default CompletableFuture<ConfirmationWithConsistencyMarker>	EventChannel.appendEvents(Event... events)	Append the given events to the Event Store.
CompletableFuture<Confirmation>	EventChannel.appendSnapshot(Event snapshotEvent)	Store the given snapshotEvent.
default CompletableFuture<String>	EventChannel.reschedule(String scheduleToken, Duration triggerDuration, Event event)	Convenience method to cancel the scheduled event with given scheduleToken and reschedule the given event to be published after given triggerDuration.
CompletableFuture<String>	EventChannel.reschedule(String scheduleToken, Instant scheduleTime, Event event)	Convenience method to cancel the scheduled event with given scheduleToken and reschedule the given event to be published at given scheduleTime.
default CompletableFuture<String>	EventChannel.scheduleEvent(Duration triggerDuration, Event event)	Schedule the given event to be published after given triggerDuration.
CompletableFuture<String>	EventChannel.scheduleEvent(Instant scheduleTime, Event event)	Schedule the given event to be published at given scheduleTime.

Uses of Event in io.axoniq.axonserver.connector.event.impl

Methods in io.axoniq.axonserver.connector.event.impl that return Event

Modifier and Type	Method	Description
Event	BufferedAggregateEventStream.next()
protected Event	BufferedAggregateEventStream.terminalMessage()

Methods in io.axoniq.axonserver.connector.event.impl with parameters of type Event

Modifier and Type	Method	Description
AppendEventsTransaction	AppendEventsTransactionImpl.appendEvent(Event event)
CompletableFuture<Confirmation>	EventChannelImpl.appendSnapshot(Event snapshotEvent)
CompletableFuture<String>	EventChannelImpl.reschedule(String scheduleToken, Instant scheduleTime, Event event)
CompletableFuture<String>	EventChannelImpl.scheduleEvent(Instant scheduleTime, Event event)

Constructor parameters in io.axoniq.axonserver.connector.event.impl with type arguments of type Event

Constructor	Description
AppendEventsTransactionImpl(io.grpc.stub.StreamObserver<Event> stream, CompletableFuture<ConfirmationWithConsistencyMarker> result)	Constructs a AppendEventsTransactionImpl used to append events to the Event Store.

Uses of Event in io.axoniq.axonserver.connector.event.transformation

Methods in io.axoniq.axonserver.connector.event.transformation with parameters of type Event

Modifier and Type	Method	Description
CompletableFuture<Appender>	Appender.replaceEvent(long token, Event replacement)	Appends to the transformation the request to replace the event with the given token.

Uses of Event in io.axoniq.axonserver.connector.event.transformation.impl

Methods in io.axoniq.axonserver.connector.event.transformation.impl with parameters of type Event

Modifier and Type	Method	Description
CompletableFuture<Void>	EventTransformationService.TransformationStream.replaceEvent(long token, Event event, long sequence)	Registers the request to replace the event with the specified token.
CompletableFuture<Appender>	TransformationStreamAppender.replaceEvent(long token, Event replacement)

Uses of Event in io.axoniq.axonserver.connector.event.transformation.impl.grpc

Methods in io.axoniq.axonserver.connector.event.transformation.impl.grpc with parameters of type Event

Modifier and Type	Method	Description
CompletableFuture<Void>	GrpcTransformationStream.replaceEvent(long token, Event event, long sequence)

Uses of Event in io.axoniq.axonserver.grpc.event

Methods in io.axoniq.axonserver.grpc.event that return Event

Modifier and Type	Method	Description
Event	Event.Builder.build()
Event	Event.Builder.buildPartial()
static Event	Event.getDefaultInstance()
Event	Event.Builder.getDefaultInstanceForType()
Event	Event.getDefaultInstanceForType()
Event	EventWithToken.Builder.getEvent()	The actual Event Message
Event	EventWithToken.getEvent()	The actual Event Message
Event	EventWithTokenOrBuilder.getEvent()	The actual Event Message
Event	RescheduleEventRequest.Builder.getEvent()	the event to publish
Event	RescheduleEventRequest.getEvent()	the event to publish
Event	RescheduleEventRequestOrBuilder.getEvent()	the event to publish
Event	ScheduleEventRequest.Builder.getEvent()	the event to publish
Event	ScheduleEventRequest.getEvent()	the event to publish
Event	ScheduleEventRequestOrBuilder.getEvent()	the event to publish
Event	TransformedEvent.Builder.getEvent()	The new content of the event
Event	TransformedEvent.getEvent()	The new content of the event
Event	TransformedEventOrBuilder.getEvent()	The new content of the event
static Event	Event.parseDelimitedFrom(InputStream input)
static Event	Event.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Event	Event.parseFrom(byte[] data)
static Event	Event.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Event	Event.parseFrom(com.google.protobuf.ByteString data)
static Event	Event.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Event	Event.parseFrom(com.google.protobuf.CodedInputStream input)
static Event	Event.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Event	Event.parseFrom(InputStream input)
static Event	Event.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Event	Event.parseFrom(ByteBuffer data)
static Event	Event.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in io.axoniq.axonserver.grpc.event that return types with arguments of type Event

Modifier and Type	Method	Description
default io.grpc.stub.StreamObserver<Event>	EventStoreGrpc.AsyncService.appendEvent(io.grpc.stub.StreamObserver<ConfirmationWithConsistencyMarker> responseObserver)	Accepts a stream of Events returning a Confirmation when completed.
io.grpc.stub.BlockingClientCall<Event,ConfirmationWithConsistencyMarker>	EventStoreGrpc.EventStoreBlockingV2Stub.appendEvent()	Accepts a stream of Events returning a Confirmation when completed.
io.grpc.stub.StreamObserver<Event>	EventStoreGrpc.EventStoreStub.appendEvent(io.grpc.stub.StreamObserver<ConfirmationWithConsistencyMarker> responseObserver)	Accepts a stream of Events returning a Confirmation when completed.
static io.grpc.MethodDescriptor<Event,ConfirmationWithConsistencyMarker>	EventStoreGrpc.getAppendEventMethod()
static io.grpc.MethodDescriptor<Event,Confirmation>	EventStoreGrpc.getAppendSnapshotMethod()
static io.grpc.MethodDescriptor<GetAggregateEventsRequest,Event>	EventStoreGrpc.getListAggregateEventsMethod()
static io.grpc.MethodDescriptor<GetAggregateSnapshotsRequest,Event>	EventStoreGrpc.getListAggregateSnapshotsMethod()
com.google.protobuf.Parser<Event>	Event.getParserForType()
Iterator<Event>	EventStoreGrpc.EventStoreBlockingStub.listAggregateEvents(GetAggregateEventsRequest request)	Retrieves the Events for a given aggregate.
io.grpc.stub.BlockingClientCall<?,Event>	EventStoreGrpc.EventStoreBlockingV2Stub.listAggregateEvents(GetAggregateEventsRequest request)	Retrieves the Events for a given aggregate.
Iterator<Event>	EventStoreGrpc.EventStoreBlockingStub.listAggregateSnapshots(GetAggregateSnapshotsRequest request)	Retrieves the Snapshots for a given aggregate.
io.grpc.stub.BlockingClientCall<?,Event>	EventStoreGrpc.EventStoreBlockingV2Stub.listAggregateSnapshots(GetAggregateSnapshotsRequest request)	Retrieves the Snapshots for a given aggregate.
static com.google.protobuf.Parser<Event>	Event.parser()

Methods in io.axoniq.axonserver.grpc.event with parameters of type Event

Modifier and Type	Method	Description
default void	EventStoreGrpc.AsyncService.appendSnapshot(Event request, io.grpc.stub.StreamObserver<Confirmation> responseObserver)	Accepts a Snapshot event returning a Confirmation when completed.
Confirmation	EventStoreGrpc.EventStoreBlockingStub.appendSnapshot(Event request)	Accepts a Snapshot event returning a Confirmation when completed.
Confirmation	EventStoreGrpc.EventStoreBlockingV2Stub.appendSnapshot(Event request)	Accepts a Snapshot event returning a Confirmation when completed.
com.google.common.util.concurrent.ListenableFuture<Confirmation>	EventStoreGrpc.EventStoreFutureStub.appendSnapshot(Event request)	Accepts a Snapshot event returning a Confirmation when completed.
void	EventStoreGrpc.EventStoreStub.appendSnapshot(Event request, io.grpc.stub.StreamObserver<Confirmation> responseObserver)	Accepts a Snapshot event returning a Confirmation when completed.
EventWithToken.Builder	EventWithToken.Builder.mergeEvent(Event value)	The actual Event Message
RescheduleEventRequest.Builder	RescheduleEventRequest.Builder.mergeEvent(Event value)	the event to publish
ScheduleEventRequest.Builder	ScheduleEventRequest.Builder.mergeEvent(Event value)	the event to publish
TransformedEvent.Builder	TransformedEvent.Builder.mergeEvent(Event value)	The new content of the event
Event.Builder	Event.Builder.mergeFrom(Event other)
static Event.Builder	Event.newBuilder(Event prototype)
EventWithToken.Builder	EventWithToken.Builder.setEvent(Event value)	The actual Event Message
RescheduleEventRequest.Builder	RescheduleEventRequest.Builder.setEvent(Event value)	the event to publish
ScheduleEventRequest.Builder	ScheduleEventRequest.Builder.setEvent(Event value)	the event to publish
TransformedEvent.Builder	TransformedEvent.Builder.setEvent(Event value)	The new content of the event

Method parameters in io.axoniq.axonserver.grpc.event with type arguments of type Event

Modifier and Type	Method	Description
default void	EventStoreGrpc.AsyncService.listAggregateEvents(GetAggregateEventsRequest request, io.grpc.stub.StreamObserver<Event> responseObserver)	Retrieves the Events for a given aggregate.
void	EventStoreGrpc.EventStoreStub.listAggregateEvents(GetAggregateEventsRequest request, io.grpc.stub.StreamObserver<Event> responseObserver)	Retrieves the Events for a given aggregate.
default void	EventStoreGrpc.AsyncService.listAggregateSnapshots(GetAggregateSnapshotsRequest request, io.grpc.stub.StreamObserver<Event> responseObserver)	Retrieves the Snapshots for a given aggregate.
void	EventStoreGrpc.EventStoreStub.listAggregateSnapshots(GetAggregateSnapshotsRequest request, io.grpc.stub.StreamObserver<Event> responseObserver)	Retrieves the Snapshots for a given aggregate.