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

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 EventStoreDBClient	create(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

Methods inherited from class java.lang.Object

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

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)