Skip navigation links
A B C D E F G H I J K L M N O P R S T U V W 

A

AbstractRead - Class in com.eventstore.dbclient
 
AbstractRead(GrpcClient, Metadata) - Constructor for class com.eventstore.dbclient.AbstractRead
 
AbstractRegularSubscription - Class in com.eventstore.dbclient
 
AbstractRegularSubscription(GrpcClient, Metadata) - Constructor for class com.eventstore.dbclient.AbstractRegularSubscription
 
ack(ResolvedEvent...) - Method in class com.eventstore.dbclient.PersistentSubscription
 
ack(Iterator<ResolvedEvent>) - Method in class com.eventstore.dbclient.PersistentSubscription
 
addHost(Endpoint) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
ANY - Static variable in class com.eventstore.dbclient.ExpectedRevision
 
AppendToStream - Class in com.eventstore.dbclient
 
AppendToStream(GrpcClient, String, Iterator<EventData>, AppendToStreamOptions) - Constructor for class com.eventstore.dbclient.AppendToStream
 
appendToStream(String, EventData...) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
appendToStream(String, Iterator<EventData>) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
appendToStream(String, AppendToStreamOptions, EventData...) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
appendToStream(String, AppendToStreamOptions, Iterator<EventData>) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
AppendToStreamOptions - Class in com.eventstore.dbclient
 
applyOnWire(StreamsOuterClass.AppendReq.Options.Builder) - Method in class com.eventstore.dbclient.ExpectedRevision
 
applyOnWire(StreamsOuterClass.DeleteReq.Options.Builder) - Method in class com.eventstore.dbclient.ExpectedRevision
 
applyOnWire(StreamsOuterClass.TombstoneReq.Options.Builder) - Method in class com.eventstore.dbclient.ExpectedRevision
 
authenticated(UserCredentials) - Method in class com.eventstore.dbclient.ConnectionMetadata
 
authenticated(UserCredentials) - Method in class com.eventstore.dbclient.GetProjectionResult
 

B

backwards() - Method in class com.eventstore.dbclient.ReadAllOptions
 
backwards() - Method in class com.eventstore.dbclient.ReadStreamOptions
 
binary(String, byte[]) - Static method in class com.eventstore.dbclient.EventDataBuilder
 
binary(UUID, String, byte[]) - Static method in class com.eventstore.dbclient.EventDataBuilder
 
build() - Method in class com.eventstore.dbclient.ConnectionMetadata
 
build() - Method in class com.eventstore.dbclient.EventDataBuilder
 
build() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
build() - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
build() - Method in class com.eventstore.dbclient.TimeoutsBuilder
 
buildConnectionSettings() - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
builder() - Static method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
builder() - Static method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
builderAsBinary(String, byte[]) - Static method in class com.eventstore.dbclient.EventData
 
builderAsBinary(UUID, String, byte[]) - Static method in class com.eventstore.dbclient.EventData
 
builderAsJson(String, A) - Static method in class com.eventstore.dbclient.EventData
 
builderAsJson(UUID, String, A) - Static method in class com.eventstore.dbclient.EventData
 

C

checkpointAfterInMs(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
checkpointer - Variable in class com.eventstore.dbclient.AbstractRegularSubscription
 
Checkpointer - Interface in com.eventstore.dbclient
 
client - Variable in class com.eventstore.dbclient.EventStoreDBClientBase
 
ClusterInfo - Class in com.eventstore.dbclient
 
ClusterInfo(List<ClusterInfo.Member>) - Constructor for class com.eventstore.dbclient.ClusterInfo
 
ClusterInfo.Endpoint - Class in com.eventstore.dbclient
 
ClusterInfo.Member - Class in com.eventstore.dbclient
 
ClusterInfo.MemberState - Enum in com.eventstore.dbclient
 
com.eventstore.dbclient - package com.eventstore.dbclient
 
compareTo(Position) - Method in class com.eventstore.dbclient.Position
 
compareTo(PrefixFilterExpression) - Method in class com.eventstore.dbclient.PrefixFilterExpression
 
compareTo(RegularFilterExpression) - Method in class com.eventstore.dbclient.RegularFilterExpression
 
compareTo(StreamRevision) - Method in class com.eventstore.dbclient.StreamRevision
 
ConnectionBuilder - Class in com.eventstore.dbclient
 
ConnectionBuilder() - Constructor for class com.eventstore.dbclient.ConnectionBuilder
 
ConnectionMetadata - Class in com.eventstore.dbclient
 
ConnectionMetadata() - Constructor for class com.eventstore.dbclient.ConnectionMetadata
 
ConnectionSettingsBuilder - Class in com.eventstore.dbclient
 
ConnectionSettingsBuilder() - Constructor for class com.eventstore.dbclient.ConnectionSettingsBuilder
 
ConnectionShutdownException - Exception in com.eventstore.dbclient
 
ConnectionShutdownException() - Constructor for exception com.eventstore.dbclient.ConnectionShutdownException
 
connectionTimeouts(Timeouts) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
Consts - Class in com.eventstore.dbclient
 
Consts() - Constructor for class com.eventstore.dbclient.Consts
 
ConsumerStrategy - Enum in com.eventstore.dbclient
 
consumerStrategy(ConsumerStrategy) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
convertSingleResponse(CompletableFuture<RespT>) - Static method in class com.eventstore.dbclient.GrpcUtils
 
convertSingleResponse(CompletableFuture<TargetT>, ThrowingFunction<RespT, TargetT, ExceptionT>) - Static method in class com.eventstore.dbclient.GrpcUtils
 
copy(PersistentSubscriptionSettings) - Static method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
create(EventStoreDBClientSettings) - Static method in class com.eventstore.dbclient.EventStoreDBClient
 
create(EventStoreDBClientSettings) - Static method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
create(String, String) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
create(String, String, PersistentSubscriptionSettings) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
create(String, String, CreatePersistentSubscriptionOptions) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
create(EventStoreDBClientSettings) - Static method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
 
createClusterConnectionUsingDns(Endpoint) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
createClusterConnectionUsingDns(Endpoint, NodePreference) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
createClusterConnectionUsingSeeds(Endpoint[]) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
createClusterConnectionUsingSeeds(Endpoint[], NodePreference) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
createConnectionFromConnectionSettings(EventStoreDBClientSettings) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
createContinuous(String, String) - Method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
 
createContinuous(String, String, CreateContinuousProjectionOptions) - Method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
 
CreateContinuousProjectionOptions - Class in com.eventstore.dbclient
 
createOneTime(String, String) - Method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
 
createOneTime(String, String, CreateOneTimeProjectionOptions) - Method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
 
CreateOneTimeProjectionOptions - Class in com.eventstore.dbclient
 
createOptions() - Method in class com.eventstore.dbclient.AbstractRead
 
createOptions() - Method in class com.eventstore.dbclient.AbstractRegularSubscription
 
createOptions() - Method in class com.eventstore.dbclient.ReadAll
 
createOptions() - Method in class com.eventstore.dbclient.ReadStream
 
createOptions() - Method in class com.eventstore.dbclient.SubscribeToAll
 
createOptions() - Method in class com.eventstore.dbclient.SubscribeToStream
 
CreatePersistentSubscription - Class in com.eventstore.dbclient
 
CreatePersistentSubscription(GrpcClient, String, String, CreatePersistentSubscriptionOptions) - Constructor for class com.eventstore.dbclient.CreatePersistentSubscription
 
CreatePersistentSubscriptionOptions - Class in com.eventstore.dbclient
 
CreateProjection - Class in com.eventstore.dbclient
 
createSingleNodeConnection(Endpoint) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
createSingleNodeConnection(String, int) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
credentials - Variable in class com.eventstore.dbclient.EventStoreDBClientBase
 
Credentials(String, String) - Constructor for class com.eventstore.dbclient.EventStoreDBClientSettings.Credentials
 

D

DEFAULT - Static variable in class com.eventstore.dbclient.Timeouts
 
DEFAULT_KEEP_ALIVE_INTERVAL_IN_MS - Static variable in class com.eventstore.dbclient.Consts
 
DEFAULT_KEEP_ALIVE_TIMEOUT_IN_MS - Static variable in class com.eventstore.dbclient.Consts
 
defaultCredentials(String, String) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
defaultReadOptions - Static variable in class com.eventstore.dbclient.AbstractRead
 
defaultReadOptions - Static variable in class com.eventstore.dbclient.AbstractRegularSubscription
 
defaultSubscribeOptions - Static variable in class com.eventstore.dbclient.AbstractRegularSubscription
 
delete(String, String) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
delete(String, String, DeletePersistentSubscriptionOptions) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
DeletePersistentSubscription - Class in com.eventstore.dbclient
 
DeletePersistentSubscription(GrpcClient, String, String, DeletePersistentSubscriptionOptions) - Constructor for class com.eventstore.dbclient.DeletePersistentSubscription
 
DeletePersistentSubscriptionOptions - Class in com.eventstore.dbclient
 
DeleteResult - Class in com.eventstore.dbclient
 
DeleteResult(Position) - Constructor for class com.eventstore.dbclient.DeleteResult
 
DeleteStream - Class in com.eventstore.dbclient
 
DeleteStream(GrpcClient, String, DeleteStreamOptions) - Constructor for class com.eventstore.dbclient.DeleteStream
 
deleteStream(String) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
deleteStream(String, DeleteStreamOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
DeleteStreamOptions - Class in com.eventstore.dbclient
 
Direction - Enum in com.eventstore.dbclient
Specifies the direction of a read operation.
direction(Direction) - Method in class com.eventstore.dbclient.ReadAllOptions
 
disableExtraStatistics() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
disableLinkResolution() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
discoveryInterval(int) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
dnsDiscover(boolean) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 

E

enableExtraStatistics() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
enableLinkResolution() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
END - Static variable in class com.eventstore.dbclient.Position
 
END - Static variable in class com.eventstore.dbclient.StreamRevision
 
Endpoint - Class in com.eventstore.dbclient
 
Endpoint(String, int) - Constructor for class com.eventstore.dbclient.Endpoint
 
equals(Object) - Method in class com.eventstore.dbclient.DeleteResult
 
equals(Object) - Method in class com.eventstore.dbclient.EventTypeFilter
 
equals(Object) - Method in class com.eventstore.dbclient.Position
 
equals(Object) - Method in class com.eventstore.dbclient.PrefixFilterExpression
 
equals(Object) - Method in class com.eventstore.dbclient.RegularFilterExpression
 
equals(Object) - Method in class com.eventstore.dbclient.StreamFilter
 
equals(Object) - Method in class com.eventstore.dbclient.StreamRevision
 
equals(Object) - Method in class com.eventstore.dbclient.WriteResult
 
EventData - Class in com.eventstore.dbclient
 
EventData(UUID, String, String, byte[], byte[]) - Constructor for class com.eventstore.dbclient.EventData
 
EventDataBuilder - Class in com.eventstore.dbclient
 
EventDataBuilder() - Constructor for class com.eventstore.dbclient.EventDataBuilder
 
EventFilter - Interface in com.eventstore.dbclient
 
eventId(UUID) - Method in class com.eventstore.dbclient.EventDataBuilder
 
EventStoreDBClient - Class in com.eventstore.dbclient
 
EventStoreDBClientBase - Class in com.eventstore.dbclient
 
EventStoreDBClientBase(EventStoreDBClientSettings) - Constructor for class com.eventstore.dbclient.EventStoreDBClientBase
 
EventStoreDBClientSettings - Class in com.eventstore.dbclient
 
EventStoreDBClientSettings(boolean, int, int, int, NodePreference, boolean, boolean, boolean, EventStoreDBClientSettings.Credentials, Endpoint[], long, long) - Constructor for class com.eventstore.dbclient.EventStoreDBClientSettings
 
EventStoreDBClientSettings.Credentials - Class in com.eventstore.dbclient
 
EventStoreDBClusterClient - Class in com.eventstore.dbclient
 
EventStoreDBClusterClient(List<InetSocketAddress>, Endpoint, NodePreference, Timeouts, SslContext, long, long) - Constructor for class com.eventstore.dbclient.EventStoreDBClusterClient
 
EventStoreDBConnectionString - Class in com.eventstore.dbclient
 
EventStoreDBConnectionString() - Constructor for class com.eventstore.dbclient.EventStoreDBConnectionString
 
EventStoreDBPersistentSubscriptionsClient - Class in com.eventstore.dbclient
 
EventStoreDBProjectionManagementClient - Class in com.eventstore.dbclient
 
EventTypeFilter - Class in com.eventstore.dbclient
 
EventTypeFilter(Optional<Integer>, RegularFilterExpression) - Constructor for class com.eventstore.dbclient.EventTypeFilter
 
EventTypeFilter(Optional<Integer>, PrefixFilterExpression...) - Constructor for class com.eventstore.dbclient.EventTypeFilter
 
execute() - Method in class com.eventstore.dbclient.AbstractRead
 
execute() - Method in class com.eventstore.dbclient.AbstractRegularSubscription
 
execute() - Method in class com.eventstore.dbclient.AppendToStream
 
execute() - Method in class com.eventstore.dbclient.CreatePersistentSubscription
 
execute() - Method in class com.eventstore.dbclient.CreateProjection
 
execute() - Method in class com.eventstore.dbclient.DeletePersistentSubscription
 
execute() - Method in class com.eventstore.dbclient.DeleteStream
 
execute() - Method in class com.eventstore.dbclient.GetProjectionResult
 
execute() - Method in class com.eventstore.dbclient.SubscribePersistentSubscription
 
execute() - Method in class com.eventstore.dbclient.UpdatePersistentSubscription
 
ExpectedRevision - Class in com.eventstore.dbclient
 
ExpectedRevision() - Constructor for class com.eventstore.dbclient.ExpectedRevision
 
expectedRevision(long) - Static method in class com.eventstore.dbclient.ExpectedRevision
 
extraStatistics(boolean) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 

F

filter - Variable in class com.eventstore.dbclient.SubscribeToAllOptions
 
filter(SubscriptionFilter) - Method in class com.eventstore.dbclient.SubscribeToAllOptions
 
forwards() - Method in class com.eventstore.dbclient.ReadAllOptions
 
forwards() - Method in class com.eventstore.dbclient.ReadStreamOptions
 
fromStreamStart() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 

G

get() - Static method in class com.eventstore.dbclient.AppendToStreamOptions
 
get() - Static method in class com.eventstore.dbclient.CreateContinuousProjectionOptions
 
get() - Static method in class com.eventstore.dbclient.CreateOneTimeProjectionOptions
 
get() - Static method in class com.eventstore.dbclient.CreatePersistentSubscriptionOptions
 
get() - Static method in class com.eventstore.dbclient.DeletePersistentSubscriptionOptions
 
get() - Static method in class com.eventstore.dbclient.DeleteStreamOptions
 
get() - Static method in class com.eventstore.dbclient.ReadAllOptions
 
get() - Static method in class com.eventstore.dbclient.ReadStreamOptions
 
get() - Static method in class com.eventstore.dbclient.SubscribePersistentSubscriptionOptions
 
get() - Static method in class com.eventstore.dbclient.SubscribeToAllOptions
 
get() - Static method in class com.eventstore.dbclient.SubscribeToStreamOptions
 
get() - Static method in class com.eventstore.dbclient.UpdatePersistentSubscriptionOptions
 
get_1() - Method in class com.eventstore.dbclient.Tuple
 
get_2() - Method in class com.eventstore.dbclient.Tuple
 
getActualVersion() - Method in exception com.eventstore.dbclient.WrongExpectedVersionException
 
getAddress() - Method in class com.eventstore.dbclient.ClusterInfo.Endpoint
 
getBufferSize() - Method in class com.eventstore.dbclient.SubscribePersistentSubscriptionOptions
 
getCheckpointAfterMs() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getCommitUnsigned() - Method in class com.eventstore.dbclient.Position
 
getContentType() - Method in class com.eventstore.dbclient.EventData
 
getContentType() - Method in class com.eventstore.dbclient.RecordedEvent
 
getCreated() - Method in class com.eventstore.dbclient.RecordedEvent
 
getDefaultCredentials() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getDirection() - Method in class com.eventstore.dbclient.ReadAllOptions
 
getDirection() - Method in class com.eventstore.dbclient.ReadStreamOptions
 
getDiscoveryInterval() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getEvent() - Method in class com.eventstore.dbclient.ResolvedEvent
 
getEventData() - Method in class com.eventstore.dbclient.EventData
 
getEventData() - Method in class com.eventstore.dbclient.RecordedEvent
 
getEventDataAs(Class<A>) - Method in class com.eventstore.dbclient.RecordedEvent
 
getEventId() - Method in class com.eventstore.dbclient.EventData
 
getEventId() - Method in class com.eventstore.dbclient.RecordedEvent
 
getEvents() - Method in class com.eventstore.dbclient.ReadResult
 
getEventType() - Method in class com.eventstore.dbclient.EventData
 
getEventType() - Method in class com.eventstore.dbclient.RecordedEvent
 
getFilter() - Method in class com.eventstore.dbclient.SubscribeToAllOptions
 
getGossipTimeout() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getHistoryBufferSize() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getHostname() - Method in class com.eventstore.dbclient.Endpoint
 
getHosts() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getHttpEndpoint() - Method in class com.eventstore.dbclient.ClusterInfo.Member
 
getInstanceId() - Method in class com.eventstore.dbclient.ClusterInfo.Member
 
getKeepAliveInterval() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getKeepAliveTimeout() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getLeaderEndpoint() - Method in exception com.eventstore.dbclient.NotLeaderException
 
getLink() - Method in class com.eventstore.dbclient.ResolvedEvent
 
getLiveBufferSize() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getLogPosition() - Method in class com.eventstore.dbclient.DeleteResult
 
getLogPosition() - Method in class com.eventstore.dbclient.WriteResult
 
getMaxCheckpointCount() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getMaxDiscoverAttempts() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getMaxRetryCount() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getMaxSearchWindow() - Method in interface com.eventstore.dbclient.EventFilter
 
getMaxSearchWindow() - Method in class com.eventstore.dbclient.EventTypeFilter
 
getMaxSearchWindow() - Method in class com.eventstore.dbclient.StreamFilter
 
getMaxSubscriberCount() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getMembers() - Method in class com.eventstore.dbclient.ClusterInfo
 
getMessageTimeoutMs() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getMinCheckpointCount() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getNextExpectedRevision() - Method in class com.eventstore.dbclient.WriteResult
 
getNextExpectedRevision() - Method in exception com.eventstore.dbclient.WrongExpectedVersionException
 
getNodePreference() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
getOriginalEvent() - Method in class com.eventstore.dbclient.ResolvedEvent
 
getPort() - Method in class com.eventstore.dbclient.ClusterInfo.Endpoint
 
getPort() - Method in class com.eventstore.dbclient.Endpoint
 
getPosition() - Method in class com.eventstore.dbclient.RecordedEvent
 
getPrefixFilterExpressions() - Method in interface com.eventstore.dbclient.EventFilter
 
getPrefixFilterExpressions() - Method in class com.eventstore.dbclient.EventTypeFilter
 
getPrefixFilterExpressions() - Method in class com.eventstore.dbclient.StreamFilter
 
getPrepareUnsigned() - Method in class com.eventstore.dbclient.Position
 
GetProjectionResult<TResult> - Class in com.eventstore.dbclient
 
getReadBatchSize() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getRegularFilterExpression() - Method in interface com.eventstore.dbclient.EventFilter
 
getRegularFilterExpression() - Method in class com.eventstore.dbclient.EventTypeFilter
 
getRegularFilterExpression() - Method in class com.eventstore.dbclient.StreamFilter
 
getResult(String, Class<TResult>) - Method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
 
getResult(String, Function<TypeFactory, JavaType>) - Method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
 
getRevision() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getState() - Method in class com.eventstore.dbclient.ClusterInfo.Member
 
getStrategy() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
getStreamId() - Method in class com.eventstore.dbclient.RecordedEvent
 
getStreamName() - Method in exception com.eventstore.dbclient.WrongExpectedVersionException
 
getStreamRevision() - Method in class com.eventstore.dbclient.RecordedEvent
 
getSubscriptionId() - Method in class com.eventstore.dbclient.PersistentSubscription
 
getSubscriptionId() - Method in class com.eventstore.dbclient.Subscription
 
getUserMetadata() - Method in class com.eventstore.dbclient.EventData
 
getUserMetadata() - Method in class com.eventstore.dbclient.RecordedEvent
 
getValueUnsigned() - Method in class com.eventstore.dbclient.StreamRevision
 
GossipClient - Class in com.eventstore.dbclient
 
GossipClient(String, int, Timeouts, SslContext) - Constructor for class com.eventstore.dbclient.GossipClient
 
GossipClient(ManagedChannel, Timeouts) - Constructor for class com.eventstore.dbclient.GossipClient
 
gossipTimeout(int) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
GrpcClient - Interface in com.eventstore.dbclient
 
GrpcUtils - Class in com.eventstore.dbclient
 
GrpcUtils() - Constructor for class com.eventstore.dbclient.GrpcUtils
 

H

hardDelete() - Method in class com.eventstore.dbclient.DeleteStreamOptions
 
hashCode() - Method in class com.eventstore.dbclient.DeleteResult
 
hashCode() - Method in class com.eventstore.dbclient.EventTypeFilter
 
hashCode() - Method in class com.eventstore.dbclient.Position
 
hashCode() - Method in class com.eventstore.dbclient.PrefixFilterExpression
 
hashCode() - Method in class com.eventstore.dbclient.RegularFilterExpression
 
hashCode() - Method in class com.eventstore.dbclient.StreamFilter
 
hashCode() - Method in class com.eventstore.dbclient.StreamRevision
 
hashCode() - Method in class com.eventstore.dbclient.WriteResult
 
hasUserCredentials() - Method in class com.eventstore.dbclient.ConnectionMetadata
 
historyBufferSize(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 

I

isAlive() - Method in class com.eventstore.dbclient.ClusterInfo.Member
 
isDnsDiscover() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
isExtraStatistics() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
isResolveLinks() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings
 
isSoftDelete() - Method in class com.eventstore.dbclient.DeleteStreamOptions
 
isThrowOnAppendFailure() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
isTls() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
isTlsVerifyCert() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings
 
isTrackingEmittedStreams() - Method in class com.eventstore.dbclient.CreateContinuousProjectionOptions
 

J

json(String, A) - Static method in class com.eventstore.dbclient.EventDataBuilder
 
json(UUID, String, A) - Static method in class com.eventstore.dbclient.EventDataBuilder
 

K

keepAliveInterval(long) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
keepAliveInterval(long) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
keepAliveTimeout(long) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
keepAliveTimeout(long) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 

L

listener - Variable in class com.eventstore.dbclient.AbstractRegularSubscription
 
liveBufferSize(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
login - Variable in class com.eventstore.dbclient.EventStoreDBClientSettings.Credentials
 

M

Main - Class in com.eventstore.dbclient
 
Main() - Constructor for class com.eventstore.dbclient.Main
 
main(String[]) - Static method in class com.eventstore.dbclient.Main
 
maxCheckpointCount(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
maxDiscoverAttempts(int) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
maxRetryCount(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
maxSubscriberCount(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
messageTimeoutInMs(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
metadata - Variable in class com.eventstore.dbclient.AbstractRead
 
metadata - Variable in class com.eventstore.dbclient.AbstractRegularSubscription
 
metadataAsBytes(byte[]) - Method in class com.eventstore.dbclient.EventDataBuilder
 
metadataAsJson(A) - Method in class com.eventstore.dbclient.EventDataBuilder
 
minCheckpointCount(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 

N

nack(NackAction, String, ResolvedEvent...) - Method in class com.eventstore.dbclient.PersistentSubscription
 
nack(NackAction, String, Iterator<ResolvedEvent>) - Method in class com.eventstore.dbclient.PersistentSubscription
 
NackAction - Enum in com.eventstore.dbclient
 
newBuilder() - Static method in class com.eventstore.dbclient.SubscriptionFilter
 
newBuilder() - Static method in class com.eventstore.dbclient.TimeoutsBuilder
 
NO_STREAM - Static variable in class com.eventstore.dbclient.ExpectedRevision
 
NoClusterNodeFound - Exception in com.eventstore.dbclient
 
NoClusterNodeFound() - Constructor for exception com.eventstore.dbclient.NoClusterNodeFound
 
nodePreference(NodePreference) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
NodePreference - Enum in com.eventstore.dbclient
 
NONE - Static variable in class com.eventstore.dbclient.PrefixFilterExpression
 
NotLeaderException - Exception in com.eventstore.dbclient
 
NotLeaderException(String, int) - Constructor for exception com.eventstore.dbclient.NotLeaderException
 

O

onCancelled(PersistentSubscription) - Method in class com.eventstore.dbclient.PersistentSubscriptionListener
 
onCancelled(Subscription) - Method in class com.eventstore.dbclient.SubscriptionListener
 
onCheckpoint(Subscription, Position) - Method in interface com.eventstore.dbclient.Checkpointer
 
onError(PersistentSubscription, Throwable) - Method in class com.eventstore.dbclient.PersistentSubscriptionListener
 
onError(Subscription, Throwable) - Method in class com.eventstore.dbclient.SubscriptionListener
 
onEvent(PersistentSubscription, ResolvedEvent) - Method in class com.eventstore.dbclient.PersistentSubscriptionListener
 
onEvent(Subscription, ResolvedEvent) - Method in class com.eventstore.dbclient.SubscriptionListener
 

P

parse(String) - Static method in class com.eventstore.dbclient.EventStoreDBConnectionString
 
ParseError - Class in com.eventstore.dbclient
 
ParseError(String, int, int, String) - Constructor for class com.eventstore.dbclient.ParseError
 
parseOrThrow(String) - Static method in class com.eventstore.dbclient.EventStoreDBConnectionString
 
password - Variable in class com.eventstore.dbclient.EventStoreDBClientSettings.Credentials
 
PersistentSubscription - Class in com.eventstore.dbclient
 
PersistentSubscription(ClientCallStreamObserver<Persistent.ReadReq>, String, String, String, int, Persistent.ReadReq.Options.Builder) - Constructor for class com.eventstore.dbclient.PersistentSubscription
 
PersistentSubscriptionListener - Class in com.eventstore.dbclient
 
PersistentSubscriptionListener() - Constructor for class com.eventstore.dbclient.PersistentSubscriptionListener
 
PersistentSubscriptions - Class in com.eventstore.dbclient
 
PersistentSubscriptions(GrpcClient, UserCredentials) - Constructor for class com.eventstore.dbclient.PersistentSubscriptions
 
PersistentSubscriptionSettings - Class in com.eventstore.dbclient
 
PersistentSubscriptionSettings(int, boolean, boolean, int, int, int, int, int, int, int, int, long, ConsumerStrategy) - Constructor for class com.eventstore.dbclient.PersistentSubscriptionSettings
 
PersistentSubscriptionSettingsBuilder - Class in com.eventstore.dbclient
 
PersistentSubscriptionSettingsBuilder() - Constructor for class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
PersistentSubscriptionSettingsBuilder(PersistentSubscriptionSettings) - Constructor for class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
Position - Class in com.eventstore.dbclient
 
Position(long, long) - Constructor for class com.eventstore.dbclient.Position
 
Position(String, String) - Constructor for class com.eventstore.dbclient.Position
 
PrefixFilterExpression - Class in com.eventstore.dbclient
 
PrefixFilterExpression(String) - Constructor for class com.eventstore.dbclient.PrefixFilterExpression
 

R

read() - Method in class com.eventstore.dbclient.GossipClient
 
readAll() - Method in class com.eventstore.dbclient.EventStoreDBClient
 
readAll(long) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
readAll(ReadAllOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
readAll(long, ReadAllOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
ReadAll - Class in com.eventstore.dbclient
 
ReadAll(GrpcClient, long, ReadAllOptions) - Constructor for class com.eventstore.dbclient.ReadAll
 
ReadAllOptions - Class in com.eventstore.dbclient
 
readBatchSize(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
ReadResult - Class in com.eventstore.dbclient
 
ReadResult(List<ResolvedEvent>) - Constructor for class com.eventstore.dbclient.ReadResult
 
readStream(String) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
readStream(String, long) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
readStream(String, ReadStreamOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
readStream(String, long, ReadStreamOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
ReadStream - Class in com.eventstore.dbclient
TODO - Implement a better way to handle very long stream to not end if OOM
ReadStream(GrpcClient, String, long, ReadStreamOptions) - Constructor for class com.eventstore.dbclient.ReadStream
 
ReadStreamOptions - Class in com.eventstore.dbclient
 
RecordedEvent - Class in com.eventstore.dbclient
 
RecordedEvent(String, StreamRevision, UUID, Position, Map<String, String>, byte[], byte[]) - Constructor for class com.eventstore.dbclient.RecordedEvent
 
RegularFilterExpression - Class in com.eventstore.dbclient
 
RegularFilterExpression(Pattern) - Constructor for class com.eventstore.dbclient.RegularFilterExpression
 
requiresLeader() - Method in class com.eventstore.dbclient.ConnectionMetadata
 
ResolvedEvent - Class in com.eventstore.dbclient
 
ResolvedEvent(RecordedEvent, RecordedEvent) - Constructor for class com.eventstore.dbclient.ResolvedEvent
 
resolveLinks(boolean) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
revision(long) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
 
run(Function<ManagedChannel, CompletableFuture<A>>) - Method in class com.eventstore.dbclient.EventStoreDBClusterClient
 
run(Function<ManagedChannel, CompletableFuture<A>>) - Method in interface com.eventstore.dbclient.GrpcClient
 
run(Function<ManagedChannel, CompletableFuture<A>>) - Method in class com.eventstore.dbclient.SingleNodeClient
 

S

setBufferSize(int) - Method in class com.eventstore.dbclient.SubscribePersistentSubscriptionOptions
 
shutdown() - Method in class com.eventstore.dbclient.EventStoreDBClientBase
 
shutdown() - Method in class com.eventstore.dbclient.EventStoreDBClusterClient
 
shutdown() - Method in class com.eventstore.dbclient.GossipClient
 
shutdown() - Method in interface com.eventstore.dbclient.GrpcClient
 
shutdown() - Method in class com.eventstore.dbclient.SingleNodeClient
 
SingleNodeClient - Class in com.eventstore.dbclient
 
SingleNodeClient(String, int, Timeouts, SslContext, long, long) - Constructor for class com.eventstore.dbclient.SingleNodeClient
 
softDelete() - Method in class com.eventstore.dbclient.DeleteStreamOptions
 
SpecialStreamRevision - Enum in com.eventstore.dbclient
 
sslContext(SslContext) - Method in class com.eventstore.dbclient.ConnectionBuilder
 
START - Static variable in class com.eventstore.dbclient.Position
 
START - Static variable in class com.eventstore.dbclient.StreamRevision
 
stop() - Method in class com.eventstore.dbclient.PersistentSubscription
 
stop() - Method in class com.eventstore.dbclient.Subscription
 
STREAM_EXISTS - Static variable in class com.eventstore.dbclient.ExpectedRevision
 
StreamFilter - Class in com.eventstore.dbclient
 
StreamFilter(Optional<Integer>, RegularFilterExpression) - Constructor for class com.eventstore.dbclient.StreamFilter
 
StreamFilter(Optional<Integer>, PrefixFilterExpression...) - Constructor for class com.eventstore.dbclient.StreamFilter
 
StreamNotFoundException - Class in com.eventstore.dbclient
 
StreamNotFoundException() - Constructor for class com.eventstore.dbclient.StreamNotFoundException
 
StreamRevision - Class in com.eventstore.dbclient
 
StreamRevision(long) - Constructor for class com.eventstore.dbclient.StreamRevision
 
StreamRevision(String) - Constructor for class com.eventstore.dbclient.StreamRevision
 
subscribe(String, String, PersistentSubscriptionListener) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
subscribe(String, String, SubscribePersistentSubscriptionOptions, PersistentSubscriptionListener) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
SubscribePersistentSubscription - Class in com.eventstore.dbclient
 
SubscribePersistentSubscription(GrpcClient, String, String, SubscribePersistentSubscriptionOptions, PersistentSubscriptionListener) - Constructor for class com.eventstore.dbclient.SubscribePersistentSubscription
 
SubscribePersistentSubscriptionOptions - Class in com.eventstore.dbclient
 
subscribeToAll(SubscriptionListener) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
subscribeToAll(SubscriptionListener, SubscribeToAllOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
SubscribeToAll - Class in com.eventstore.dbclient
 
SubscribeToAll(GrpcClient, SubscriptionListener, SubscribeToAllOptions) - Constructor for class com.eventstore.dbclient.SubscribeToAll
 
SubscribeToAllOptions - Class in com.eventstore.dbclient
 
subscribeToStream(String, SubscriptionListener) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
subscribeToStream(String, SubscriptionListener, SubscribeToStreamOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
 
SubscribeToStream - Class in com.eventstore.dbclient
 
SubscribeToStream(GrpcClient, String, SubscriptionListener, SubscribeToStreamOptions) - Constructor for class com.eventstore.dbclient.SubscribeToStream
 
SubscribeToStreamOptions - Class in com.eventstore.dbclient
 
Subscription - Class in com.eventstore.dbclient
 
SubscriptionFilter - Class in com.eventstore.dbclient
 
SubscriptionFilter(EventFilter) - Constructor for class com.eventstore.dbclient.SubscriptionFilter
 
SubscriptionFilter(EventFilter, int, Checkpointer) - Constructor for class com.eventstore.dbclient.SubscriptionFilter
 
SubscriptionFilterBuilder - Class in com.eventstore.dbclient
 
SubscriptionFilterBuilder() - Constructor for class com.eventstore.dbclient.SubscriptionFilterBuilder
 
SubscriptionListener - Class in com.eventstore.dbclient
 
SubscriptionListener() - Constructor for class com.eventstore.dbclient.SubscriptionListener
 

T

throwOnAppendFailure(boolean) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
Timeouts - Class in com.eventstore.dbclient
 
TimeoutsBuilder - Class in com.eventstore.dbclient
 
tls(boolean) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
tlsVerifyCert(boolean) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder
 
toStreamOptions(String, StreamRevision) - Static method in class com.eventstore.dbclient.GrpcUtils
 
toString() - Method in class com.eventstore.dbclient.Position
 
toString() - Method in class com.eventstore.dbclient.PrefixFilterExpression
 
toString() - Method in class com.eventstore.dbclient.RegularFilterExpression
 
toString() - Method in enum com.eventstore.dbclient.SpecialStreamRevision
 
toString() - Method in class com.eventstore.dbclient.StreamRevision
 
toUserCredentials() - Method in class com.eventstore.dbclient.EventStoreDBClientSettings.Credentials
 
trackEmittedStreams(boolean) - Method in class com.eventstore.dbclient.CreateContinuousProjectionOptions
 
Tuple<A,B> - Class in com.eventstore.dbclient
 
Tuple(A, B) - Constructor for class com.eventstore.dbclient.Tuple
 

U

update(String, String) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
update(String, String, PersistentSubscriptionSettings) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
update(String, String, UpdatePersistentSubscriptionOptions) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
 
UpdatePersistentSubscription - Class in com.eventstore.dbclient
 
UpdatePersistentSubscription(GrpcClient, String, String, UpdatePersistentSubscriptionOptions) - Constructor for class com.eventstore.dbclient.UpdatePersistentSubscription
 
UpdatePersistentSubscriptionOptions - Class in com.eventstore.dbclient
 
UserCredentials - Class in com.eventstore.dbclient
 
UserCredentials(String, String) - Constructor for class com.eventstore.dbclient.UserCredentials
 

V

valueOf(String) - Static method in enum com.eventstore.dbclient.ClusterInfo.MemberState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.eventstore.dbclient.ConsumerStrategy
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.eventstore.dbclient.Direction
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.eventstore.dbclient.NackAction
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.eventstore.dbclient.NodePreference
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.eventstore.dbclient.SpecialStreamRevision
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.eventstore.dbclient.ClusterInfo.MemberState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.eventstore.dbclient.ConsumerStrategy
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.eventstore.dbclient.Direction
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.eventstore.dbclient.NackAction
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.eventstore.dbclient.NodePreference
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.eventstore.dbclient.SpecialStreamRevision
Returns an array containing the constants of this enum type, in the order they are declared.

W

withCheckpointer(Checkpointer, int) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
withCheckpointer(Checkpointer) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
withEventTypePrefix(String) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
withEventTypeRegularExpression(String) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
withMaxWindow(int) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
withShutdownTimeout(long, TimeUnit) - Method in class com.eventstore.dbclient.TimeoutsBuilder
 
withStreamNamePrefix(String) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
withStreamNameRegularExpression(String) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder
 
withSubscriptionTimeout(long, TimeUnit) - Method in class com.eventstore.dbclient.TimeoutsBuilder
 
WriteResult - Class in com.eventstore.dbclient
 
WriteResult(StreamRevision, Position) - Constructor for class com.eventstore.dbclient.WriteResult
 
WrongExpectedVersionException - Exception in com.eventstore.dbclient
 
WrongExpectedVersionException(String, StreamRevision, StreamRevision) - Constructor for exception com.eventstore.dbclient.WrongExpectedVersionException
 
A B C D E F G H I J K L M N O P R S T U V W 
Skip navigation links