Modifier and Type | Method and Description |
---|---|
Event |
Event.Builder.build() |
Event |
Event.Builder.buildPartial() |
static Event |
Event.getDefaultInstance() |
Event |
Event.getDefaultInstanceForType() |
Event |
Event.Builder.getDefaultInstanceForType() |
Event |
EventWithToken.getEvent()
The actual Event Message
|
Event |
EventWithToken.Builder.getEvent()
The actual Event Message
|
Event |
EventWithTokenOrBuilder.getEvent()
The actual Event Message
|
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(ByteBuffer data) |
static Event |
Event.parseFrom(ByteBuffer 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) |
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<Event> |
EventStoreGrpc.EventStoreImplBase.appendEvent(io.grpc.stub.StreamObserver<Confirmation> responseObserver)
Accepts a stream of Events returning a Confirmation when completed.
|
io.grpc.stub.StreamObserver<Event> |
EventStoreGrpc.EventStoreStub.appendEvent(io.grpc.stub.StreamObserver<Confirmation> responseObserver)
Accepts a stream of Events returning a Confirmation when completed.
|
static io.grpc.MethodDescriptor<Event,Confirmation> |
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.
|
Iterator<Event> |
EventStoreGrpc.EventStoreBlockingStub.listAggregateSnapshots(GetAggregateSnapshotsRequest request)
Retrieves the Snapshots for a given aggregate.
|
static com.google.protobuf.Parser<Event> |
Event.parser() |
Modifier and Type | Method and Description |
---|---|
Confirmation |
EventStoreGrpc.EventStoreBlockingStub.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.EventStoreImplBase.appendSnapshot(Event request,
io.grpc.stub.StreamObserver<Confirmation> responseObserver)
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
|
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
|
Modifier and Type | Method and Description |
---|---|
void |
EventStoreGrpc.EventStoreImplBase.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.
|
void |
EventStoreGrpc.EventStoreImplBase.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.
|
Modifier and Type | Method and Description |
---|---|
Stream<Event> |
AxonServerEventStoreClient.listAggregateEvents(GetAggregateEventsRequest request)
Deprecated.
in favor of
AxonServerEventStoreClient.listAggregateEvents(String, GetAggregateEventsRequest) , as the context
should always be specified when dealing with an Event Store |
Stream<Event> |
AxonServerEventStoreClient.listAggregateEvents(String context,
GetAggregateEventsRequest request)
Retrieves the events for an aggregate described in given
request . |
Stream<Event> |
AxonServerEventStoreClient.listAggregateSnapshots(GetAggregateSnapshotsRequest request)
Deprecated.
in favor of
AxonServerEventStoreClient.listAggregateSnapshots(String, GetAggregateSnapshotsRequest) , as the
context should always be specified when dealing with an Event Store |
Stream<Event> |
AxonServerEventStoreClient.listAggregateSnapshots(String context,
GetAggregateSnapshotsRequest request)
Retrieve a stream of all the snapshot events utilizing the given
GetAggregateSnapshotsRequest |
Modifier and Type | Method and Description |
---|---|
void |
AppendEventTransaction.append(Event event) |
CompletableFuture<Confirmation> |
AxonServerEventStoreClient.appendSnapshot(Event snapshot)
Deprecated.
in favor of
AxonServerEventStoreClient.appendSnapshot(String, Event) , as the context should always be
specified when dealing with an Event Store |
CompletableFuture<Confirmation> |
AxonServerEventStoreClient.appendSnapshot(String context,
Event snapshot)
Add a snapshot event to the Event Store.
|
Constructor and Description |
---|
AppendEventTransaction(int timeout,
io.grpc.stub.StreamObserver<Event> eventStreamObserver,
CompletableFuture<Confirmation> observer,
EventCipher eventCipher) |
Constructor and Description |
---|
GrpcBackedDomainEventData(Event event)
Initialize using the given
event as the source of raw data. |
Modifier and Type | Method and Description |
---|---|
Event |
EventCipher.decrypt(Event cryptoEvent) |
Event |
EventCipher.encrypt(Event clearEvent) |
Modifier and Type | Method and Description |
---|---|
Event |
EventCipher.decrypt(Event cryptoEvent) |
Event |
EventCipher.encrypt(Event clearEvent) |
Constructor and Description |
---|
EventCipher(Function<Event,Integer> keySelector,
List<byte[]> secretKeys) |
Copyright © 2010–2020. All rights reserved.