Package com.eventstore.dbclient
Class EventStoreDBClient
- java.lang.Object
-
- com.eventstore.dbclient.EventStoreDBClientBase
-
- com.eventstore.dbclient.EventStoreDBClient
-
public class EventStoreDBClient extends EventStoreDBClientBase
-
-
Field Summary
-
Fields inherited from class com.eventstore.dbclient.EventStoreDBClientBase
client, credentials
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.concurrent.CompletableFuture<WriteResult>appendToStream(java.lang.String streamName, AppendToStreamOptions options, EventData... events)java.util.concurrent.CompletableFuture<WriteResult>appendToStream(java.lang.String streamName, AppendToStreamOptions options, java.util.Iterator<EventData> events)java.util.concurrent.CompletableFuture<WriteResult>appendToStream(java.lang.String streamName, EventData... events)java.util.concurrent.CompletableFuture<WriteResult>appendToStream(java.lang.String streamName, java.util.Iterator<EventData> events)static EventStoreDBClientcreate(EventStoreDBClientSettings settings)java.util.concurrent.CompletableFuture<DeleteResult>deleteStream(java.lang.String streamName)java.util.concurrent.CompletableFuture<DeleteResult>deleteStream(java.lang.String streamName, DeleteStreamOptions options)java.util.concurrent.CompletableFuture<ReadResult>readAll()java.util.concurrent.CompletableFuture<ReadResult>readAll(long maxCount)java.util.concurrent.CompletableFuture<ReadResult>readAll(long maxCount, ReadAllOptions options)java.util.concurrent.CompletableFuture<ReadResult>readAll(ReadAllOptions options)java.util.concurrent.CompletableFuture<ReadResult>readStream(java.lang.String streamName)java.util.concurrent.CompletableFuture<ReadResult>readStream(java.lang.String streamName, long maxCount)java.util.concurrent.CompletableFuture<ReadResult>readStream(java.lang.String streamName, long maxCount, ReadStreamOptions options)java.util.concurrent.CompletableFuture<ReadResult>readStream(java.lang.String streamName, ReadStreamOptions options)java.util.concurrent.CompletableFuture<Subscription>subscribeToAll(SubscriptionListener listener)java.util.concurrent.CompletableFuture<Subscription>subscribeToAll(SubscriptionListener listener, SubscribeToAllOptions options)java.util.concurrent.CompletableFuture<Subscription>subscribeToStream(java.lang.String streamName, SubscriptionListener listener)java.util.concurrent.CompletableFuture<Subscription>subscribeToStream(java.lang.String streamName, SubscriptionListener listener, SubscribeToStreamOptions options)-
Methods inherited from class com.eventstore.dbclient.EventStoreDBClientBase
shutdown
-
-
-
-
Method Detail
-
create
public static EventStoreDBClient create(EventStoreDBClientSettings settings)
-
appendToStream
public java.util.concurrent.CompletableFuture<WriteResult> appendToStream(java.lang.String streamName, EventData... events)
-
appendToStream
public java.util.concurrent.CompletableFuture<WriteResult> appendToStream(java.lang.String streamName, java.util.Iterator<EventData> events)
-
appendToStream
public java.util.concurrent.CompletableFuture<WriteResult> appendToStream(java.lang.String streamName, AppendToStreamOptions options, EventData... events)
-
appendToStream
public java.util.concurrent.CompletableFuture<WriteResult> appendToStream(java.lang.String streamName, AppendToStreamOptions options, java.util.Iterator<EventData> events)
-
readStream
public java.util.concurrent.CompletableFuture<ReadResult> readStream(java.lang.String streamName)
-
readStream
public java.util.concurrent.CompletableFuture<ReadResult> readStream(java.lang.String streamName, long maxCount)
-
readStream
public java.util.concurrent.CompletableFuture<ReadResult> readStream(java.lang.String streamName, ReadStreamOptions options)
-
readStream
public java.util.concurrent.CompletableFuture<ReadResult> readStream(java.lang.String streamName, long maxCount, ReadStreamOptions options)
-
readAll
public java.util.concurrent.CompletableFuture<ReadResult> readAll()
-
readAll
public java.util.concurrent.CompletableFuture<ReadResult> readAll(long maxCount)
-
readAll
public java.util.concurrent.CompletableFuture<ReadResult> readAll(ReadAllOptions options)
-
readAll
public java.util.concurrent.CompletableFuture<ReadResult> readAll(long maxCount, ReadAllOptions options)
-
subscribeToStream
public java.util.concurrent.CompletableFuture<Subscription> subscribeToStream(java.lang.String streamName, SubscriptionListener listener)
-
subscribeToStream
public java.util.concurrent.CompletableFuture<Subscription> subscribeToStream(java.lang.String streamName, SubscriptionListener listener, SubscribeToStreamOptions options)
-
subscribeToAll
public java.util.concurrent.CompletableFuture<Subscription> subscribeToAll(SubscriptionListener listener)
-
subscribeToAll
public java.util.concurrent.CompletableFuture<Subscription> subscribeToAll(SubscriptionListener listener, SubscribeToAllOptions options)
-
deleteStream
public java.util.concurrent.CompletableFuture<DeleteResult> deleteStream(java.lang.String streamName)
-
deleteStream
public java.util.concurrent.CompletableFuture<DeleteResult> deleteStream(java.lang.String streamName, DeleteStreamOptions options)
-
-