public class SubscribeToAllOptions
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected SubscriptionFilter |
filter |
protected ConnectionMetadata |
metadata |
protected Timeouts |
timeouts |
| Modifier and Type | Method and Description |
|---|---|
T |
authenticated(UserCredentials credentials) |
SubscribeToAllOptions |
filter(SubscriptionFilter filter) |
T |
fromEnd() |
T |
fromPosition(Position position) |
T |
fromStart() |
static SubscribeToAllOptions |
get() |
SubscriptionFilter |
getFilter() |
io.grpc.Metadata |
getMetadata() |
Position |
getPosition() |
Timeouts |
getTimeouts() |
boolean |
hasUserCredentials() |
T |
notRequireLeader() |
T |
notResolveLinkTos() |
T |
requiresLeader() |
T |
requiresLeader(boolean value) |
T |
resolveLinkTos() |
T |
resolveLinkTos(boolean value) |
boolean |
shouldResolveLinkTos() |
T |
timeouts(Timeouts timeouts) |
protected SubscriptionFilter filter
protected Timeouts timeouts
protected final ConnectionMetadata metadata
public static SubscribeToAllOptions get()
public SubscriptionFilter getFilter()
public SubscribeToAllOptions filter(SubscriptionFilter filter)
public Position getPosition()
public T fromStart()
public T fromEnd()
public T fromPosition(Position position)
public boolean shouldResolveLinkTos()
public T resolveLinkTos(boolean value)
public T resolveLinkTos()
public T notResolveLinkTos()
public Timeouts getTimeouts()
public T timeouts(Timeouts timeouts)
public io.grpc.Metadata getMetadata()
public boolean hasUserCredentials()
public T authenticated(UserCredentials credentials)
public T requiresLeader()
public T notRequireLeader()
public T requiresLeader(boolean value)