Package com.eventstore.dbclient

Class CreatePersistentSubscriptionToAllOptions

java.lang.Object

com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder<CreatePersistentSubscriptionToAllOptions,PersistentSubscriptionToAllSettings>

com.eventstore.dbclient.CreatePersistentSubscriptionToAllOptions

public class CreatePersistentSubscriptionToAllOptions
extends AbstractPersistentSubscriptionSettingsBuilder<CreatePersistentSubscriptionToAllOptions,PersistentSubscriptionToAllSettings>

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.Long	deadline
protected com.eventstore.dbclient.OperationKind	kind
protected ConnectionMetadata	metadata

Fields inherited from class com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder

settings

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CreatePersistentSubscriptionToAllOptions()

Method Summary

Modifier and Type	Method	Description
T	authenticated(UserCredentials credentials)
T	deadline(long durationInMs)
CreatePersistentSubscriptionToAllOptions	filter(SubscriptionFilter filter)
CreatePersistentSubscriptionToAllOptions	fromEnd()
CreatePersistentSubscriptionToAllOptions	fromStart()
static CreatePersistentSubscriptionToAllOptions	get()
UserCredentials	getCredentials()
java.lang.Long	getDeadline()
SubscriptionFilter	getFilter()
com.eventstore.dbclient.OperationKind	getKind()
io.grpc.Metadata	getMetadata()
java.lang.String	getUserCredentials()
boolean	hasUserCredentials()
boolean	isLeaderRequired()
T	notRequireLeader()
T	requiresLeader()
T	requiresLeader(boolean value)
CreatePersistentSubscriptionToAllOptions	startFrom(long unsignedPrepare, long unsignedCommit)
CreatePersistentSubscriptionToAllOptions	startFrom(Position position)

Methods inherited from class com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder

checkpointAfter, checkpointAfterInMs, checkpointLowerBound, checkpointUpperBound, consumerStrategy, disableExtraStatistics, disableLinkResolution, enableExtraStatistics, enableLinkResolution, extraStatistics, getSettings, historyBufferSize, liveBufferSize, maxCheckpointCount, maxRetryCount, maxSubscriberCount, messageTimeout, messageTimeoutInMs, minCheckpointCount, namedConsumerStrategy, notResolveLinkTos, readBatchSize, resolveLinks, resolveLinkTos, resolveLinkTos

Methods inherited from class java.lang.Object

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

Field Detail

metadata

protected final ConnectionMetadata metadata

deadline

protected java.lang.Long deadline

kind

protected com.eventstore.dbclient.OperationKind kind

Constructor Detail

CreatePersistentSubscriptionToAllOptions

protected CreatePersistentSubscriptionToAllOptions()

Method Detail

get

public static CreatePersistentSubscriptionToAllOptions get()

getFilter

public SubscriptionFilter getFilter()

filter

public CreatePersistentSubscriptionToAllOptions filter(SubscriptionFilter filter)

fromStart

public CreatePersistentSubscriptionToAllOptions fromStart()

fromEnd

public CreatePersistentSubscriptionToAllOptions fromEnd()

startFrom

public CreatePersistentSubscriptionToAllOptions startFrom(Position position)

startFrom

public CreatePersistentSubscriptionToAllOptions startFrom(long unsignedPrepare,
                                                          long unsignedCommit)

getMetadata

public io.grpc.Metadata getMetadata()

hasUserCredentials

public boolean hasUserCredentials()

getUserCredentials

public java.lang.String getUserCredentials()

authenticated

public T authenticated(UserCredentials credentials)

requiresLeader

public T requiresLeader()

notRequireLeader

public T notRequireLeader()

requiresLeader

public T requiresLeader(boolean value)

deadline

public T deadline(long durationInMs)

getDeadline

public java.lang.Long getDeadline()

getKind

public com.eventstore.dbclient.OperationKind getKind()

isLeaderRequired

public boolean isLeaderRequired()

getCredentials

public UserCredentials getCredentials()