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
All Classes All Packages
All Classes All Packages
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 - com.eventstore.dbclient.SpecialStreamRevision
- ANY - Static variable in class com.eventstore.dbclient.ExpectedRevision
- appendToStream(String, AppendToStreamOptions, EventData...) - Method in class com.eventstore.dbclient.EventStoreDBClient
- appendToStream(String, AppendToStreamOptions, Iterator<EventData>) - Method in class com.eventstore.dbclient.EventStoreDBClient
- appendToStream(String, EventData...) - Method in class com.eventstore.dbclient.EventStoreDBClient
- appendToStream(String, Iterator<EventData>) - Method in class com.eventstore.dbclient.EventStoreDBClient
- AppendToStream - Class in com.eventstore.dbclient
- AppendToStream(GrpcClient, String, Iterator<EventData>, AppendToStreamOptions) - Constructor for class com.eventstore.dbclient.AppendToStream
- 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
- Backwards - 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.EventStoreDBClientSettings
- 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 - Variable in class com.eventstore.dbclient.EventStoreDBClientBase
- 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
- 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
- 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
- consumerStrategy(ConsumerStrategy) - Method in class com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder
- ConsumerStrategy - Enum in com.eventstore.dbclient
- 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(EventStoreDBClientSettings) - Static method in class com.eventstore.dbclient.EventStoreDBProjectionManagementClient
- create(String, String) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
- create(String, String, CreatePersistentSubscriptionOptions) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
- create(String, String, PersistentSubscriptionSettings) - Method in class com.eventstore.dbclient.EventStoreDBPersistentSubscriptionsClient
- 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
- 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(String) - Method in class com.eventstore.dbclient.EventStoreDBClient
- deleteStream(String, DeleteStreamOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
- DeleteStream - Class in com.eventstore.dbclient
- DeleteStream(GrpcClient, String, DeleteStreamOptions) - Constructor for class com.eventstore.dbclient.DeleteStream
- DeleteStreamOptions - Class in com.eventstore.dbclient
- direction(Direction) - Method in class com.eventstore.dbclient.ReadAllOptions
- 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
- 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[]) - 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) - 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>, 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.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(long) - Static method in class com.eventstore.dbclient.ExpectedRevision
- 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.SubscribeToAllOptions
- filter(SubscriptionFilter) - Method in class com.eventstore.dbclient.SubscribeToAllOptions
- FOLLOWER - com.eventstore.dbclient.ClusterInfo.MemberState
- FOLLOWER - com.eventstore.dbclient.NodePreference
- forwards() - Method in class com.eventstore.dbclient.ReadAllOptions
- forwards() - Method in class com.eventstore.dbclient.ReadStreamOptions
- Forwards - com.eventstore.dbclient.Direction
-
Read in the forward direction.
- 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
- 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(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.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
- INITIALIZING - com.eventstore.dbclient.ClusterInfo.MemberState
- 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
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.EventStoreDBClientSettings.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
- 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
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.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
- 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
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.EventStoreDBClient
- readAll(long) - Method in class com.eventstore.dbclient.EventStoreDBClient
- readAll(long, ReadAllOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
- readAll(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, long, ReadStreamOptions) - Method in class com.eventstore.dbclient.EventStoreDBClient
- readStream(String, 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>, @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.ConnectionMetadata
- RESIGNING_LEADER - com.eventstore.dbclient.ClusterInfo.MemberState
- 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
- 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
- setBufferSize(int) - Method in class com.eventstore.dbclient.SubscribePersistentSubscriptionOptions
- SHUT_DOWN - com.eventstore.dbclient.ClusterInfo.MemberState
- 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
- 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.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
- 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
- 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
- UNKNOWN - com.eventstore.dbclient.ClusterInfo.MemberState
- 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) - 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
All Classes All Packages