public class AppendEventTransaction extends Object
Constructor and Description |
---|
AppendEventTransaction(int timeout,
io.grpc.stub.StreamObserver<Event> eventStreamObserver,
CompletableFuture<Confirmation> observer,
EventCipher eventCipher) |
Modifier and Type | Method and Description |
---|---|
void |
append(Event event) |
void |
commit() |
void |
rollback(Throwable reason) |
public AppendEventTransaction(int timeout, io.grpc.stub.StreamObserver<Event> eventStreamObserver, CompletableFuture<Confirmation> observer, EventCipher eventCipher)
public void append(Event event)
public void commit() throws InterruptedException, ExecutionException, TimeoutException
public void rollback(Throwable reason)
Copyright © 2010–2019. All rights reserved.