Package com.eventstore.dbclient

Class AppendToStream

java.lang.Object

com.eventstore.dbclient.AppendToStream

public class AppendToStream
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
AppendToStream(GrpcClient client, java.lang.String streamName, UserCredentials credentials)

Method Summary

Modifier and Type	Method	Description
AppendToStream	addEvent(EventData event)
AppendToStream	addEvents(EventData... events)
AppendToStream	addEvents(java.util.Iterator<EventData> events)
AppendToStream	authenticated(UserCredentials credentials)
java.util.concurrent.CompletableFuture<WriteResult>	execute()
AppendToStream	expectedRevision(ExpectedRevision revision)
AppendToStream	notRequireLeader()
AppendToStream	requiresLeader()
AppendToStream	requiresLeader(boolean value)
AppendToStream	timeouts(Timeouts timeouts)

Methods inherited from class java.lang.Object

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

Constructor Detail

AppendToStream

public AppendToStream(GrpcClient client,
                      java.lang.String streamName,
                      UserCredentials credentials)

Method Detail

authenticated

public AppendToStream authenticated(UserCredentials credentials)

expectedRevision

public AppendToStream expectedRevision(ExpectedRevision revision)

timeouts

public AppendToStream timeouts(Timeouts timeouts)

requiresLeader

public AppendToStream requiresLeader()

notRequireLeader

public AppendToStream notRequireLeader()

requiresLeader

public AppendToStream requiresLeader(boolean value)

addEvent

public AppendToStream addEvent(EventData event)

addEvents

public AppendToStream addEvents(EventData... events)

addEvents

public AppendToStream addEvents(java.util.Iterator<EventData> events)

execute

public java.util.concurrent.CompletableFuture<WriteResult> execute()