A B C D E F G H I J L M N O P R S T U V W
All Classes All Packages

A

AbstractRead - Class in com.eventstore.dbclient

AbstractRead(GrpcClient) - Constructor for class com.eventstore.dbclient.AbstractRead

AbstractRegularSubscription - Class in com.eventstore.dbclient

AbstractRegularSubscription(GrpcClient) - 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

addEvent(EventData) - Method in class com.eventstore.dbclient.AppendToStream

addEvents(EventData...) - Method in class com.eventstore.dbclient.AppendToStream

addEvents(Iterator<EventData>) - Method in class com.eventstore.dbclient.AppendToStream

addHost(Endpoint) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder

ANY - com.eventstore.dbclient.SpecialStreamRevision

ANY - Static variable in class com.eventstore.dbclient.ExpectedRevision

appendStream(String) - Method in class com.eventstore.dbclient.Streams

AppendToStream - Class in com.eventstore.dbclient

AppendToStream(GrpcClient, String, UserCredentials) - Constructor for class com.eventstore.dbclient.AppendToStream

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.AppendToStream

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.ConnectionMetadata

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.ConnectPersistentSubscription

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.CreatePersistentSubscription

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.DeletePersistentSubscription

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.DeleteStream

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.ReadAll

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.ReadStream

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.SubscribeToAll

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.SubscribeToStream

authenticated(UserCredentials) - Method in class com.eventstore.dbclient.UpdatePersistentSubscription

B

backward() - Method in class com.eventstore.dbclient.ReadAll

backward() - Method in class com.eventstore.dbclient.ReadStream

Backward - com.eventstore.dbclient.Direction

Read in the backward direction.

binary(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.ClientSettings

builder() - Static method in class com.eventstore.dbclient.PersistentSubscriptionSettings

builderAsBinary(String, byte[]) - Static method in class com.eventstore.dbclient.EventData

builderAsJson(String, A) - Static method in class com.eventstore.dbclient.EventData

C

CATCHING_UP - com.eventstore.dbclient.ClusterInfo.MemberState

checkpointAfterInMs(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

checkpointer - Variable in class com.eventstore.dbclient.AbstractRegularSubscription

Checkpointer - Interface in com.eventstore.dbclient

Client - Class in com.eventstore.dbclient

ClientSettings - Class in com.eventstore.dbclient

ClientSettings(boolean, int, int, int, NodePreference, boolean, boolean, boolean, ClientSettings.Credentials, Endpoint[]) - Constructor for class com.eventstore.dbclient.ClientSettings

ClientSettings.Credentials - Class in com.eventstore.dbclient

CLONE - com.eventstore.dbclient.ClusterInfo.MemberState

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

ClusterResolverFactory - Class in com.eventstore.dbclient

ClusterResolverFactory(List<InetSocketAddress>, NodePreference, Timeouts, SslContext) - Constructor for class com.eventstore.dbclient.ClusterResolverFactory

com.eventstore.dbclient - package com.eventstore.dbclient

compareTo(Position) - Method in class com.eventstore.dbclient.Position

compareTo(StreamRevision) - Method in class com.eventstore.dbclient.StreamRevision

compareTo(PrefixFilterExpression) - Method in class com.eventstore.dbclient.PrefixFilterExpression

compareTo(RegularFilterExpression) - Method in class com.eventstore.dbclient.RegularFilterExpression

connect(String, String, PersistentSubscriptionListener) - Method in class com.eventstore.dbclient.PersistentSubscriptions

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

ConnectionString - Class in com.eventstore.dbclient

ConnectionString() - Constructor for class com.eventstore.dbclient.ConnectionString

connectionTimeouts(Timeouts) - Method in class com.eventstore.dbclient.ConnectionBuilder

ConnectPersistentSubscription - Class in com.eventstore.dbclient

ConnectPersistentSubscription(GrpcClient, String, String, UserCredentials, PersistentSubscriptionListener) - Constructor for class com.eventstore.dbclient.ConnectPersistentSubscription

consumerStrategy(ConsumerStrategy) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

ConsumerStrategy - Enum in com.eventstore.dbclient

convertSingleResponse(CompletableFuture<TargetT>, Function<RespT, TargetT>) - Static method in class com.eventstore.dbclient.GrpcUtils

copy(PersistentSubscriptionSettings) - Static method in class com.eventstore.dbclient.PersistentSubscriptionSettings

create(ClientSettings) - Static method in class com.eventstore.dbclient.Client

create(String, String) - Method in class com.eventstore.dbclient.PersistentSubscriptions

createClusterConnectionUsingDns(String) - Method in class com.eventstore.dbclient.ConnectionBuilder

createClusterConnectionUsingDns(String, 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(ClientSettings) - Method in class com.eventstore.dbclient.ConnectionBuilder

createOptions() - Method in class com.eventstore.dbclient.AbstractRegularSubscription

createOptions() - Method in class com.eventstore.dbclient.SubscribeToAll

createOptions() - Method in class com.eventstore.dbclient.SubscribeToStream

createOptions(long) - Method in class com.eventstore.dbclient.AbstractRead

createOptions(long) - Method in class com.eventstore.dbclient.ReadAll

createOptions(long) - Method in class com.eventstore.dbclient.ReadStream

CreatePersistentSubscription - Class in com.eventstore.dbclient

CreatePersistentSubscription(GrpcClient, String, String, UserCredentials) - Constructor for class com.eventstore.dbclient.CreatePersistentSubscription

createSingleNodeConnection(Endpoint) - Method in class com.eventstore.dbclient.ConnectionBuilder

createSingleNodeConnection(String, int) - Method in class com.eventstore.dbclient.ConnectionBuilder

Credentials(String, String) - Constructor for class com.eventstore.dbclient.ClientSettings.Credentials

D

DEFAULT - Static variable in class com.eventstore.dbclient.Timeouts

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.PersistentSubscriptions

DeletePersistentSubscription - Class in com.eventstore.dbclient

DeletePersistentSubscription(GrpcClient, String, String, UserCredentials) - Constructor for class com.eventstore.dbclient.DeletePersistentSubscription

DeleteResult - Class in com.eventstore.dbclient

DeleteResult(Position) - Constructor for class com.eventstore.dbclient.DeleteResult

deleteStream(String) - Method in class com.eventstore.dbclient.Streams

DeleteStream - Class in com.eventstore.dbclient

DeleteStream(GrpcClient, String, UserCredentials) - Constructor for class com.eventstore.dbclient.DeleteStream

Direction - Enum in com.eventstore.dbclient

Specifies the direction of a read operation.

disableExtraStatistics() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

disableLinkResolution() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

DISCOVER_LEADER - com.eventstore.dbclient.ClusterInfo.MemberState

discoveryInterval(int) - Method in class com.eventstore.dbclient.ConnectionSettingsBuilder

DispatchToSingle - com.eventstore.dbclient.ConsumerStrategy

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

EventStoreDBClusterClient - Class in com.eventstore.dbclient

EventStoreDBClusterClient(List<InetSocketAddress>, String, NodePreference, Timeouts, SslContext) - Constructor for class com.eventstore.dbclient.EventStoreDBClusterClient

EventTypeFilter - Class in com.eventstore.dbclient

EventTypeFilter(Optional<Integer>, PrefixFilterExpression...) - Constructor for class com.eventstore.dbclient.EventTypeFilter

EventTypeFilter(Optional<Integer>, RegularFilterExpression) - Constructor for class com.eventstore.dbclient.EventTypeFilter

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.DeletePersistentSubscription

execute() - Method in class com.eventstore.dbclient.DeleteStream

execute() - Method in class com.eventstore.dbclient.UpdatePersistentSubscription

execute(int) - Method in class com.eventstore.dbclient.ConnectPersistentSubscription

execute(long) - Method in class com.eventstore.dbclient.AbstractRead

expectedRevision(long) - Static method in class com.eventstore.dbclient.ExpectedRevision

expectedRevision(ExpectedRevision) - Method in class com.eventstore.dbclient.AppendToStream

expectedRevision(ExpectedRevision) - Method in class com.eventstore.dbclient.DeleteStream

ExpectedRevision - Class in com.eventstore.dbclient

ExpectedRevision() - Constructor for class com.eventstore.dbclient.ExpectedRevision

extraStatistics(boolean) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

F

filter - Variable in class com.eventstore.dbclient.SubscribeToAll

filter(SubscriptionFilter) - Method in class com.eventstore.dbclient.SubscribeToAll

FOLLOWER - com.eventstore.dbclient.ClusterInfo.MemberState

FOLLOWER - com.eventstore.dbclient.NodePreference

forward() - Method in class com.eventstore.dbclient.ReadAll

forward() - Method in class com.eventstore.dbclient.ReadStream

Forward - com.eventstore.dbclient.Direction

Read in the forward direction.

fromEnd() - Method in class com.eventstore.dbclient.ReadAll

fromEnd() - Method in class com.eventstore.dbclient.ReadStream

fromEnd() - Method in class com.eventstore.dbclient.SubscribeToAll

fromEnd() - Method in class com.eventstore.dbclient.SubscribeToStream

fromPosition(Position) - Method in class com.eventstore.dbclient.ReadAll

fromPosition(Position) - Method in class com.eventstore.dbclient.SubscribeToAll

fromRevision(long) - Method in class com.eventstore.dbclient.ReadStream

fromRevision(long) - Method in class com.eventstore.dbclient.SubscribeToStream

fromStart() - Method in class com.eventstore.dbclient.ReadAll

fromStart() - Method in class com.eventstore.dbclient.ReadStream

fromStart() - Method in class com.eventstore.dbclient.SubscribeToAll

fromStart() - Method in class com.eventstore.dbclient.SubscribeToStream

fromStreamStart() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

G

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

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.ClientSettings

getDefaultScheme() - Method in class com.eventstore.dbclient.ClusterResolverFactory

getDiscoveryInterval() - Method in class com.eventstore.dbclient.ClientSettings

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

getGossipTimeout() - Method in class com.eventstore.dbclient.ClientSettings

getHistoryBufferSize() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings

getHostname() - Method in class com.eventstore.dbclient.Endpoint

getHosts() - Method in class com.eventstore.dbclient.ClientSettings

getHttpEndpoint() - Method in class com.eventstore.dbclient.ClusterInfo.Member

getInstanceId() - Method in class com.eventstore.dbclient.ClusterInfo.Member

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.ClientSettings

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.ClientSettings

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

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

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(ManagedChannel, Timeouts) - Constructor for class com.eventstore.dbclient.GossipClient

GossipClient(String, int, Timeouts, SslContext) - 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.DeleteStream

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

historyBufferSize(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

I

INITIALIZING - com.eventstore.dbclient.ClusterInfo.MemberState

isAlive() - Method in class com.eventstore.dbclient.ClusterInfo.Member

isAvailable() - Method in class com.eventstore.dbclient.ClusterResolverFactory

isDnsDiscover() - Method in class com.eventstore.dbclient.ClientSettings

isExtraStatistics() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings

isResolveLinks() - Method in class com.eventstore.dbclient.PersistentSubscriptionSettings

isThrowOnAppendFailure() - Method in class com.eventstore.dbclient.ClientSettings

isTls() - Method in class com.eventstore.dbclient.ClientSettings

isTlsVerifyCert() - Method in class com.eventstore.dbclient.ClientSettings

J

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

L

LEADER - com.eventstore.dbclient.ClusterInfo.MemberState

LEADER - com.eventstore.dbclient.NodePreference

listener - Variable in class com.eventstore.dbclient.AbstractRegularSubscription

liveBufferSize(int) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

login - Variable in class com.eventstore.dbclient.ClientSettings.Credentials

M

main(String[]) - Static method in class com.eventstore.dbclient.Main

Main - Class in com.eventstore.dbclient

Main() - Constructor for class com.eventstore.dbclient.Main

MANAGER - com.eventstore.dbclient.ClusterInfo.MemberState

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

newNameResolver(URI, NameResolver.Args) - Method in class com.eventstore.dbclient.ClusterResolverFactory

NO_STREAM - com.eventstore.dbclient.SpecialStreamRevision

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

notRequireLeader() - Method in class com.eventstore.dbclient.AppendToStream

notRequireLeader() - Method in class com.eventstore.dbclient.DeleteStream

notRequireLeader() - Method in class com.eventstore.dbclient.ReadAll

notRequireLeader() - Method in class com.eventstore.dbclient.ReadStream

notRequireLeader() - Method in class com.eventstore.dbclient.SubscribeToAll

notRequireLeader() - Method in class com.eventstore.dbclient.SubscribeToStream

notResolveLinks() - Method in class com.eventstore.dbclient.ReadAll

notResolveLinks() - Method in class com.eventstore.dbclient.ReadStream

notResolveLinks() - Method in class com.eventstore.dbclient.SubscribeToAll

notResolveLinks() - Method in class com.eventstore.dbclient.SubscribeToStream

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

Park - com.eventstore.dbclient.NackAction

parse(String) - Static method in class com.eventstore.dbclient.ConnectionString

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.ConnectionString

password - Variable in class com.eventstore.dbclient.ClientSettings.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() - Method in class com.eventstore.dbclient.Client

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

Pinned - com.eventstore.dbclient.ConsumerStrategy

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

PRE_LEADER - com.eventstore.dbclient.ClusterInfo.MemberState

PRE_READ_ONLY_REPLICA - com.eventstore.dbclient.ClusterInfo.MemberState

PRE_REPLICA - com.eventstore.dbclient.ClusterInfo.MemberState

PrefixFilterExpression - Class in com.eventstore.dbclient

PrefixFilterExpression(String) - Constructor for class com.eventstore.dbclient.PrefixFilterExpression

priority() - Method in class com.eventstore.dbclient.ClusterResolverFactory

R

RANDOM - com.eventstore.dbclient.NodePreference

read() - Method in class com.eventstore.dbclient.GossipClient

READ_ONLY_LEADERLESS - com.eventstore.dbclient.ClusterInfo.MemberState

READ_ONLY_REPLICA - com.eventstore.dbclient.ClusterInfo.MemberState

READ_ONLY_REPLICA - com.eventstore.dbclient.NodePreference

readAll() - Method in class com.eventstore.dbclient.Streams

ReadAll - Class in com.eventstore.dbclient

ReadAll(GrpcClient, UserCredentials) - Constructor for class com.eventstore.dbclient.ReadAll

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.Streams

ReadStream - Class in com.eventstore.dbclient

TODO - Implement a better way to handle very long stream to not end if OOM

ReadStream(GrpcClient, String, UserCredentials) - Constructor for class com.eventstore.dbclient.ReadStream

readThrough() - Method in class com.eventstore.dbclient.AbstractRead

RecordedEvent - Class in com.eventstore.dbclient

RecordedEvent(String, StreamRevision, UUID, Position, Map<String, String>, @javax.validation.constraints.NotNull byte[], @javax.validation.constraints.NotNull 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.AppendToStream

requiresLeader() - Method in class com.eventstore.dbclient.ConnectionMetadata

requiresLeader() - Method in class com.eventstore.dbclient.DeleteStream

requiresLeader() - Method in class com.eventstore.dbclient.ReadAll

requiresLeader() - Method in class com.eventstore.dbclient.ReadStream

requiresLeader() - Method in class com.eventstore.dbclient.SubscribeToAll

requiresLeader() - Method in class com.eventstore.dbclient.SubscribeToStream

requiresLeader(boolean) - Method in class com.eventstore.dbclient.AppendToStream

requiresLeader(boolean) - Method in class com.eventstore.dbclient.DeleteStream

requiresLeader(boolean) - Method in class com.eventstore.dbclient.ReadAll

requiresLeader(boolean) - Method in class com.eventstore.dbclient.ReadStream

requiresLeader(boolean) - Method in class com.eventstore.dbclient.SubscribeToAll

requiresLeader(boolean) - Method in class com.eventstore.dbclient.SubscribeToStream

RESIGNING_LEADER - com.eventstore.dbclient.ClusterInfo.MemberState

ResolvedEvent - Class in com.eventstore.dbclient

ResolvedEvent(RecordedEvent, RecordedEvent) - Constructor for class com.eventstore.dbclient.ResolvedEvent

resolveLinks - Variable in class com.eventstore.dbclient.AbstractRegularSubscription

resolveLinks() - Method in class com.eventstore.dbclient.ReadAll

resolveLinks() - Method in class com.eventstore.dbclient.ReadStream

resolveLinks() - Method in class com.eventstore.dbclient.SubscribeToAll

resolveLinks() - Method in class com.eventstore.dbclient.SubscribeToStream

resolveLinks(boolean) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

resolveLinks(boolean) - Method in class com.eventstore.dbclient.ReadAll

resolveLinks(boolean) - Method in class com.eventstore.dbclient.ReadStream

resolveLinks(boolean) - Method in class com.eventstore.dbclient.SubscribeToAll

resolveLinks(boolean) - Method in class com.eventstore.dbclient.SubscribeToStream

Retry - com.eventstore.dbclient.NackAction

revision(long) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

RoundRobin - com.eventstore.dbclient.ConsumerStrategy

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

settings(PersistentSubscriptionSettings) - Method in class com.eventstore.dbclient.CreatePersistentSubscription

settings(PersistentSubscriptionSettings) - Method in class com.eventstore.dbclient.UpdatePersistentSubscription

SHUT_DOWN - com.eventstore.dbclient.ClusterInfo.MemberState

shutdown() - Method in class com.eventstore.dbclient.Client

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

SHUTTING_DOWN - com.eventstore.dbclient.ClusterInfo.MemberState

SingleNodeClient - Class in com.eventstore.dbclient

SingleNodeClient(String, int, Timeouts, SslContext) - Constructor for class com.eventstore.dbclient.SingleNodeClient

Skip - com.eventstore.dbclient.NackAction

softDelete() - Method in class com.eventstore.dbclient.DeleteStream

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

startingPosition(StreamRevision) - Method in class com.eventstore.dbclient.ReadStream

startingPosition(StreamRevision) - Method in class com.eventstore.dbclient.SubscribeToStream

stop() - Method in class com.eventstore.dbclient.PersistentSubscription

stop() - Method in class com.eventstore.dbclient.Subscription

Stop - com.eventstore.dbclient.NackAction

STREAM_EXISTS - com.eventstore.dbclient.SpecialStreamRevision

STREAM_EXISTS - Static variable in class com.eventstore.dbclient.ExpectedRevision

StreamFilter - Class in com.eventstore.dbclient

StreamFilter(Optional<Integer>, PrefixFilterExpression...) - Constructor for class com.eventstore.dbclient.StreamFilter

StreamFilter(Optional<Integer>, RegularFilterExpression) - 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

streams() - Method in class com.eventstore.dbclient.Client

Streams - Class in com.eventstore.dbclient

Streams(GrpcClient, UserCredentials) - Constructor for class com.eventstore.dbclient.Streams

subscribeToAll(SubscriptionListener) - Method in class com.eventstore.dbclient.Streams

SubscribeToAll - Class in com.eventstore.dbclient

SubscribeToAll(GrpcClient, SubscriptionListener, UserCredentials) - Constructor for class com.eventstore.dbclient.SubscribeToAll

subscribeToStream(String, SubscriptionListener) - Method in class com.eventstore.dbclient.Streams

SubscribeToStream - Class in com.eventstore.dbclient

SubscribeToStream(GrpcClient, String, SubscriptionListener, UserCredentials) - Constructor for class com.eventstore.dbclient.SubscribeToStream

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 - Variable in class com.eventstore.dbclient.AbstractRegularSubscription

timeouts(Timeouts) - Method in class com.eventstore.dbclient.AppendToStream

timeouts(Timeouts) - Method in class com.eventstore.dbclient.DeleteStream

timeouts(Timeouts) - Method in class com.eventstore.dbclient.ReadAll

timeouts(Timeouts) - Method in class com.eventstore.dbclient.ReadStream

timeouts(Timeouts) - Method in class com.eventstore.dbclient.SubscribeToAll

timeouts(Timeouts) - Method in class com.eventstore.dbclient.SubscribeToStream

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.ClientSettings.Credentials

Tuple<A,B> - Class in com.eventstore.dbclient

Tuple(A, B) - Constructor for class com.eventstore.dbclient.Tuple

U

UNKNOWN - com.eventstore.dbclient.ClusterInfo.MemberState

update(String, String) - Method in class com.eventstore.dbclient.PersistentSubscriptions

UpdatePersistentSubscription - Class in com.eventstore.dbclient

UpdatePersistentSubscription(GrpcClient, String, String, UserCredentials) - Constructor for class com.eventstore.dbclient.UpdatePersistentSubscription

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) - Method in class com.eventstore.dbclient.SubscriptionFilterBuilder

withCheckpointer(Checkpointer, int) - 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 L M N O P R S T U V W
All Classes All Packages