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<StreamMetadata>	getStreamMetadata(java.lang.String streamName)
java.util.concurrent.CompletableFuture<StreamMetadata>	getStreamMetadata(java.lang.String streamName, ReadStreamOptions 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)
org.reactivestreams.Publisher<ResolvedEvent>	readAllReactive()
org.reactivestreams.Publisher<ResolvedEvent>	readAllReactive(long maxCount)
org.reactivestreams.Publisher<ResolvedEvent>	readAllReactive(long maxCount, ReadAllOptions options)
org.reactivestreams.Publisher<ResolvedEvent>	readAllReactive(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)
org.reactivestreams.Publisher<ResolvedEvent>	readStreamReactive(java.lang.String streamName)
org.reactivestreams.Publisher<ResolvedEvent>	readStreamReactive(java.lang.String streamName, long maxCount)
org.reactivestreams.Publisher<ResolvedEvent>	readStreamReactive(java.lang.String streamName, long maxCount, ReadStreamOptions options)
org.reactivestreams.Publisher<ResolvedEvent>	readStreamReactive(java.lang.String streamName, ReadStreamOptions options)
java.util.concurrent.CompletableFuture<WriteResult>	setStreamMetadata(java.lang.String streamName, AppendToStreamOptions options, StreamMetadata metadata)
java.util.concurrent.CompletableFuture<WriteResult>	setStreamMetadata(java.lang.String streamName, StreamMetadata metadata)
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)

setStreamMetadata

public java.util.concurrent.CompletableFuture<WriteResult> setStreamMetadata(java.lang.String streamName,
                                                                             StreamMetadata metadata)

setStreamMetadata

public java.util.concurrent.CompletableFuture<WriteResult> setStreamMetadata(java.lang.String streamName,
                                                                             AppendToStreamOptions options,
                                                                             StreamMetadata metadata)

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)

readStreamReactive

public org.reactivestreams.Publisher<ResolvedEvent> readStreamReactive(java.lang.String streamName)

readStreamReactive

public org.reactivestreams.Publisher<ResolvedEvent> readStreamReactive(java.lang.String streamName,
                                                                       long maxCount)

readStreamReactive

public org.reactivestreams.Publisher<ResolvedEvent> readStreamReactive(java.lang.String streamName,
                                                                       ReadStreamOptions options)

readStreamReactive

public org.reactivestreams.Publisher<ResolvedEvent> readStreamReactive(java.lang.String streamName,
                                                                       long maxCount,
                                                                       ReadStreamOptions options)

getStreamMetadata

public java.util.concurrent.CompletableFuture<StreamMetadata> getStreamMetadata(java.lang.String streamName)

getStreamMetadata

public java.util.concurrent.CompletableFuture<StreamMetadata> getStreamMetadata(java.lang.String streamName,
                                                                                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)

readAllReactive

public org.reactivestreams.Publisher<ResolvedEvent> readAllReactive()

readAllReactive

public org.reactivestreams.Publisher<ResolvedEvent> readAllReactive(long maxCount)

readAllReactive

public org.reactivestreams.Publisher<ResolvedEvent> readAllReactive(ReadAllOptions options)

readAllReactive

public org.reactivestreams.Publisher<ResolvedEvent> readAllReactive(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)