Index

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form

A

account - Variable in class s2.config.Endpoints

ACTIVE - Enum constant in enum class s2.types.BasinState

Address - Class in s2.config

Address(String, int) - Constructor for class s2.config.Address

Age - Class in s2.types

Age(Duration) - Constructor for class s2.types.Age

ALL - Enum constant in enum class s2.config.AppendRetryPolicy

append(AppendInput) - Method in class s2.client.StreamClient

Append a batch of records to a stream, using the unary append RPC.

AppendInput - Class in s2.types

AppendInput.AppendInputBuilder - Class in s2.types

AppendInputBuilder() - Constructor for class s2.types.AppendInput.AppendInputBuilder

AppendOutput - Record Class in s2.types

AppendOutput(long, long, long) - Constructor for record class s2.types.AppendOutput

Creates an instance of a AppendOutput record class.

AppendRecord - Class in s2.types

AppendRecord.AppendRecordBuilder - Class in s2.types

AppendRecordBuilder() - Constructor for class s2.types.AppendRecord.AppendRecordBuilder

appendRetryPolicy - Variable in class s2.config.Config

AppendRetryPolicy - Enum Class in s2.config

appendSession(Consumer<AppendOutput>, Consumer<Throwable>, Runnable) - Method in class s2.client.StreamClient

Start an unmanaged streaming append session.

AppendSessionRequestStream(Consumer<AppendInput>, Consumer<Throwable>, Runnable) - Constructor for record class s2.client.StreamClient.AppendSessionRequestStream

Creates an instance of a AppendSessionRequestStream record class.

applyRequestMetadata(CallCredentials.RequestInfo, Executor, CallCredentials.MetadataApplier) - Method in class s2.auth.BearerTokenCallCredentials

Applies the bearer token to the request metadata.

awaitCompletion() - Method in class s2.client.ReadSession

AWS - Enum constant in enum class s2.config.Cloud

B

BaseClient - Class in s2.client

basin - Variable in class s2.config.Endpoints

basinClient(String) - Method in class s2.client.Client

Create a BasinClient for interacting with basin-level RPCs.

BasinClient - Class in s2.client

Client for basin-level operations.

BasinClient(String, Config, ManagedChannel, ScheduledExecutorService) - Constructor for class s2.client.BasinClient

Instantiates a new Basin client.

BasinClient(String, Config, ScheduledExecutorService) - Constructor for class s2.client.BasinClient

Instantiates a new Basin client.

BasinConfig - Record Class in s2.types

BasinConfig(StreamConfig) - Constructor for record class s2.types.BasinConfig

Creates an instance of a BasinConfig record class.

BasinEndpoint - Class in s2.config

BasinInfo - Record Class in s2.types

BasinInfo(String, String, String, BasinState) - Constructor for record class s2.types.BasinInfo

Creates an instance of a BasinInfo record class.

BasinState - Enum Class in s2.types

BasinUtils - Class in s2.utils

BasinUtils() - Constructor for class s2.utils.BasinUtils

Batch - Record Class in s2.types

Batch(SequencedRecordBatch) - Constructor for record class s2.types.Batch

Creates an instance of a Batch record class.

BearerTokenCallCredentials - Class in s2.auth

Implementation of CallCredentials that adds a bearer token to request metadata.

BearerTokenCallCredentials(String) - Constructor for class s2.auth.BearerTokenCallCredentials

Creates new bearer token credentials.

body() - Method in record class s2.types.SequencedRecord

Returns the value of the body record component.

build() - Method in class s2.config.Config.ConfigBuilder

build() - Method in class s2.types.AppendInput.AppendInputBuilder

build() - Method in class s2.types.AppendRecord.AppendRecordBuilder

build() - Method in class s2.types.CreateBasinRequest.CreateBasinRequestBuilder

build() - Method in class s2.types.CreateStreamRequest.CreateStreamRequestBuilder

build() - Method in class s2.types.ListBasinsRequest.ListBasinsRequestBuilder

build() - Method in class s2.types.ListStreamsRequest.ListStreamsRequestBuilder

build() - Method in class s2.types.ReadRequest.ReadRequestBuilder

build() - Method in class s2.types.ReadSessionRequest.ReadSessionRequestBuilder

build() - Method in class s2.types.ReconfigureBasinRequest.ReconfigureBasinRequestBuilder

build() - Method in class s2.types.ReconfigureStreamRequest.ReconfigureStreamRequestBuilder

build() - Method in class s2.types.StreamConfig.StreamConfigBuilder

bytes - Variable in class s2.types.ReadLimit

bytes(long) - Static method in class s2.types.ReadLimit

C

cell() - Method in record class s2.types.BasinInfo

Returns the value of the cell record component.

checkTail() - Method in class s2.client.StreamClient

Check the sequence number that will be assigned to the next record on a stream.

Client - Class in s2.client

Client for account-level operations.

Client(Config) - Constructor for class s2.client.Client

Instantiates a new Client, using default settings for creating a channel, as well as an executor service.

Client(Config, ManagedChannel, ScheduledExecutorService) - Constructor for class s2.client.Client

Instantiates a new Client.

close() - Method in class s2.client.BaseClient

closeGracefully() - Method in class s2.client.ManagedAppendSession

closeImmediately() - Method in class s2.client.ManagedAppendSession

Cloud - Enum Class in s2.config

Config - Class in s2.config

Config.ConfigBuilder - Class in s2.config

count - Variable in class s2.types.ReadLimit

count(long) - Static method in class s2.types.ReadLimit

countOrBytes(long, long) - Static method in class s2.types.ReadLimit

createBasin(CreateBasinRequest) - Method in class s2.client.Client

Create a new basin.

CreateBasinRequest - Class in s2.types

CreateBasinRequest.CreateBasinRequestBuilder - Class in s2.types

CreateBasinRequestBuilder() - Constructor for class s2.types.CreateBasinRequest.CreateBasinRequestBuilder

createdAt() - Method in record class s2.types.StreamInfo

Returns the value of the createdAt record component.

createStream(CreateStreamRequest) - Method in class s2.client.BasinClient

Create a new stream within this basin.

CreateStreamRequest - Class in s2.types

CreateStreamRequest.CreateStreamRequestBuilder - Class in s2.types

CreateStreamRequestBuilder() - Constructor for class s2.types.CreateStreamRequest.CreateStreamRequestBuilder

CREATING - Enum constant in enum class s2.types.BasinState

D

DEFAULT - Static variable in class s2.types.ReadRequest

defaultStreamConfig() - Method in record class s2.types.BasinConfig

Returns the value of the defaultStreamConfig record component.

deleteBasin(String) - Method in class s2.client.Client

Delete a basin.

deletedAt() - Method in record class s2.types.StreamInfo

Returns the value of the deletedAt record component.

deleteStream(String) - Method in class s2.client.BasinClient

Delete a stream.

DELETING - Enum constant in enum class s2.types.BasinState

Direct - Class in s2.config

Direct(Address) - Constructor for class s2.config.Direct

E

elems() - Method in record class s2.types.Paginated

Returns the value of the elems record component.

endpoints - Variable in class s2.config.Config

Endpoints - Class in s2.config

endSeqNum() - Method in record class s2.types.AppendOutput

Returns the value of the endSeqNum record component.

equals(Object) - Method in class s2.auth.BearerTokenCallCredentials

Returns whether this credentials implementation is equal to another object.

equals(Object) - Method in record class s2.client.StreamClient.AppendSessionRequestStream

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in class s2.config.Address

equals(Object) - Method in class s2.config.BasinEndpoint

equals(Object) - Method in record class s2.types.AppendOutput

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.BasinConfig

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.BasinInfo

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.Batch

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.FirstSeqNum

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.Header

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.NextSeqNum

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.Paginated

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.SequencedRecord

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.SequencedRecordBatch

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class s2.types.StreamInfo

Indicates whether some other object is "equal to" this one.

EXPRESS - Enum constant in enum class s2.types.StorageClass

F

fencingToken - Variable in class s2.types.AppendInput

firstSeqNum() - Method in record class s2.types.Batch

FirstSeqNum - Record Class in s2.types

FirstSeqNum(long) - Constructor for record class s2.types.FirstSeqNum

Creates an instance of a FirstSeqNum record class.

forCell(Cloud, String) - Static method in class s2.config.Endpoints

forCloud(Cloud) - Static method in class s2.config.Endpoints

fromEnvironment() - Static method in class s2.config.Endpoints

fromProto(AppendOutput) - Static method in record class s2.types.AppendOutput

fromProto(BasinInfo) - Static method in record class s2.types.BasinInfo

fromProto(Header) - Static method in record class s2.types.Header

fromProto(ReadOutput) - Static method in interface s2.types.ReadOutput

fromProto(SequencedRecord) - Static method in record class s2.types.SequencedRecord

fromProto(SequencedRecordBatch) - Static method in record class s2.types.SequencedRecordBatch

fromProto(StreamConfig) - Static method in class s2.types.StreamConfig

fromProto(StreamInfo) - Static method in record class s2.types.StreamInfo

fromString(String) - Static method in class s2.config.Address

fromString(String) - Static method in enum class s2.config.Cloud

G

get() - Method in class s2.client.ManagedReadSession

get(Duration) - Method in class s2.client.ManagedReadSession

getBasinConfig(String) - Method in class s2.client.Client

Get a basin's config.

getBytes() - Method in class s2.types.AppendRecord

getHeaders() - Method in class s2.types.AppendRecord

getStreamConfig(String) - Method in class s2.client.BasinClient

Get current config of a stream.

H

hashCode() - Method in class s2.auth.BearerTokenCallCredentials

Returns a hash code value for this credentials implementation.

hashCode() - Method in record class s2.client.StreamClient.AppendSessionRequestStream

Returns a hash code value for this object.

hashCode() - Method in class s2.config.Address

hashCode() - Method in class s2.config.BasinEndpoint

hashCode() - Method in record class s2.types.AppendOutput

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.BasinConfig

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.BasinInfo

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.Batch

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.FirstSeqNum

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.Header

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.NextSeqNum

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.Paginated

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.SequencedRecord

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.SequencedRecordBatch

Returns a hash code value for this object.

hashCode() - Method in record class s2.types.StreamInfo

Returns a hash code value for this object.

hasMore() - Method in record class s2.types.Paginated

Returns the value of the hasMore record component.

hasNext() - Method in class s2.client.ManagedReadSession

Header - Record Class in s2.types

Header(ByteString, ByteString) - Constructor for record class s2.types.Header

Creates an instance of a Header record class.

headers() - Method in record class s2.types.SequencedRecord

Returns the value of the headers record component.

host - Variable in class s2.config.Address

I

isClosed() - Method in class s2.client.ManagedReadSession

L

lastSeqNum() - Method in record class s2.types.Batch

listBasins(ListBasinsRequest) - Method in class s2.client.Client

List basins.

ListBasinsRequest - Class in s2.types

ListBasinsRequest.ListBasinsRequestBuilder - Class in s2.types

ListBasinsRequestBuilder() - Constructor for class s2.types.ListBasinsRequest.ListBasinsRequestBuilder

listStreams(ListStreamsRequest) - Method in class s2.client.BasinClient

List streams within the basin.

ListStreamsRequest - Class in s2.types

ListStreamsRequest.ListStreamsRequestBuilder - Class in s2.types

ListStreamsRequestBuilder() - Constructor for class s2.types.ListStreamsRequest.ListStreamsRequestBuilder

M

managedAppendSession() - Method in class s2.client.StreamClient

Start a managed append session.

ManagedAppendSession - Class in s2.client

managedReadSession(ReadSessionRequest, Integer) - Method in class s2.client.StreamClient

Retrieve batches of records from a stream continuously, using a buffered queue-backed iterator.

ManagedReadSession - Class in s2.client

manual(Optional<String>, Optional<String>, Optional<String>) - Static method in class s2.config.Endpoints

matchSeqNum - Variable in class s2.types.AppendInput

maxAppendInflightBytes - Variable in class s2.config.Config

maxRetries - Variable in class s2.config.Config

meteredBytes() - Method in class s2.types.AppendInput

meteredBytes() - Method in class s2.types.AppendRecord

meteredBytes() - Method in record class s2.types.Batch

meteredBytes() - Method in interface s2.types.MeteredBytes

meteredBytes() - Method in record class s2.types.SequencedRecord

meteredBytes() - Method in record class s2.types.SequencedRecordBatch

MeteredBytes - Interface in s2.types

N

name() - Method in record class s2.types.BasinInfo

Returns the value of the name record component.

name() - Method in record class s2.types.Header

Returns the value of the name record component.

name() - Method in record class s2.types.StreamInfo

Returns the value of the name record component.

newBuilder() - Static method in class s2.types.AppendInput

newBuilder() - Static method in class s2.types.AppendRecord

newBuilder() - Static method in class s2.types.CreateBasinRequest

newBuilder() - Static method in class s2.types.CreateStreamRequest

newBuilder() - Static method in class s2.types.ListBasinsRequest

newBuilder() - Static method in class s2.types.ListStreamsRequest

newBuilder() - Static method in class s2.types.ReadRequest

newBuilder() - Static method in class s2.types.ReadSessionRequest

newBuilder() - Method in class s2.types.ReconfigureBasinRequest

newBuilder() - Method in class s2.types.ReconfigureStreamRequest

newBuilder() - Static method in class s2.types.StreamConfig

newBuilder(String) - Static method in class s2.config.Config

nextSeqNum() - Method in record class s2.types.AppendOutput

Returns the value of the nextSeqNum record component.

NextSeqNum - Record Class in s2.types

NextSeqNum(long) - Constructor for record class s2.types.NextSeqNum

Creates an instance of a NextSeqNum record class.

NO_SIDE_EFFECTS - Enum constant in enum class s2.config.AppendRetryPolicy

NONE - Static variable in class s2.types.ReadLimit

O

onComplete() - Method in record class s2.client.StreamClient.AppendSessionRequestStream

Returns the value of the onComplete record component.

onError() - Method in record class s2.client.StreamClient.AppendSessionRequestStream

Returns the value of the onError record component.

onNext() - Method in record class s2.client.StreamClient.AppendSessionRequestStream

Returns the value of the onNext record component.

P

Paginated<T> - Record Class in s2.types

Paginated(boolean, List<T>) - Constructor for record class s2.types.Paginated

Creates an instance of a Paginated record class.

ParentZone - Class in s2.config

ParentZone(Address) - Constructor for class s2.config.ParentZone

port - Variable in class s2.config.Address

R

read(ReadRequest) - Method in class s2.client.StreamClient

Retrieve a batch of records from a stream, using the unary read RPC.

readLimit - Variable in class s2.types.ReadRequest

readLimit - Variable in class s2.types.ReadSessionRequest

ReadLimit - Class in s2.types

ReadOutput - Interface in s2.types

ReadRequest - Class in s2.types

ReadRequest(long, ReadLimit) - Constructor for class s2.types.ReadRequest

ReadRequest.ReadRequestBuilder - Class in s2.types

ReadRequestBuilder() - Constructor for class s2.types.ReadRequest.ReadRequestBuilder

readSession(ReadSessionRequest, Consumer<ReadOutput>, Consumer<Throwable>) - Method in class s2.client.StreamClient

Retrieve batches of records from a stream continuously.

ReadSession - Class in s2.client

ReadSessionRequest - Class in s2.types

ReadSessionRequest(long, ReadLimit) - Constructor for class s2.types.ReadSessionRequest

ReadSessionRequest.ReadSessionRequestBuilder - Class in s2.types

ReadSessionRequestBuilder() - Constructor for class s2.types.ReadSessionRequest.ReadSessionRequestBuilder

reconfigureBasin(ReconfigureBasinRequest) - Method in class s2.client.Client

Update configuration of an existing basin.

ReconfigureBasinRequest - Class in s2.types

ReconfigureBasinRequest.ReconfigureBasinRequestBuilder - Class in s2.types

ReconfigureBasinRequestBuilder() - Constructor for class s2.types.ReconfigureBasinRequest.ReconfigureBasinRequestBuilder

reconfigureStream(ReconfigureStreamRequest) - Method in class s2.client.BasinClient

Reconfigure an existing stream.

ReconfigureStreamRequest - Class in s2.types

ReconfigureStreamRequest.ReconfigureStreamRequestBuilder - Class in s2.types

ReconfigureStreamRequestBuilder() - Constructor for class s2.types.ReconfigureStreamRequest.ReconfigureStreamRequestBuilder

records - Variable in class s2.types.AppendInput

records() - Method in record class s2.types.SequencedRecordBatch

Returns the value of the records record component.

remaining(long, long) - Method in class s2.types.ReadLimit

requestTimeout - Variable in class s2.config.Config

retentionPolicy - Variable in class s2.types.StreamConfig

RetentionPolicy - Class in s2.types

RetentionPolicy() - Constructor for class s2.types.RetentionPolicy

retryDelay - Variable in class s2.config.Config

S

s2.auth - package s2.auth

Authentication related utilities.

s2.client - package s2.client

Set of clients, and associated classes, for interacting with S2's service RPCs.

s2.config - package s2.config

Configuration classes used by clients.

s2.types - package s2.types

Types used by clients.

s2.utils - package s2.utils

Validation and miscellaneous utility functions.

scope() - Method in record class s2.types.BasinInfo

Returns the value of the scope record component.

seqNum() - Method in record class s2.types.SequencedRecord

Returns the value of the seqNum record component.

SequencedRecord - Record Class in s2.types

SequencedRecord(Long, List<Header>, ByteString) - Constructor for record class s2.types.SequencedRecord

Creates an instance of a SequencedRecord record class.

sequencedRecordBatch() - Method in record class s2.types.Batch

Returns the value of the sequencedRecordBatch record component.

SequencedRecordBatch - Record Class in s2.types

SequencedRecordBatch(List<SequencedRecord>) - Constructor for record class s2.types.SequencedRecordBatch

Creates an instance of a SequencedRecordBatch record class.

singleEndpoint() - Method in class s2.config.Endpoints

STANDARD - Enum constant in enum class s2.types.StorageClass

startSeqNum - Variable in class s2.types.ReadRequest

startSeqNum - Variable in class s2.types.ReadSessionRequest

startSeqNum() - Method in record class s2.types.AppendOutput

Returns the value of the startSeqNum record component.

state() - Method in record class s2.types.BasinInfo

Returns the value of the state record component.

storageClass - Variable in class s2.types.StreamConfig

StorageClass - Enum Class in s2.types

streamClient(String) - Method in class s2.client.BasinClient

Create a StreamClient for interacting with stream-level RPCs.

StreamClient - Class in s2.client

Client for stream-level operations.

StreamClient(String, String, Config, ManagedChannel, ScheduledExecutorService) - Constructor for class s2.client.StreamClient

Instantiates a new Stream client.

StreamClient.AppendSessionRequestStream - Record Class in s2.client

streamConfig - Variable in class s2.types.CreateStreamRequest

StreamConfig - Class in s2.types

StreamConfig.StreamConfigBuilder - Class in s2.types

StreamConfigBuilder() - Constructor for class s2.types.StreamConfig.StreamConfigBuilder

StreamInfo - Record Class in s2.types

StreamInfo(String, Instant, Optional<Instant>) - Constructor for record class s2.types.StreamInfo

Creates an instance of a StreamInfo record class.

streamName - Variable in class s2.types.CreateStreamRequest

StreamUtils - Class in s2.utils

StreamUtils() - Constructor for class s2.utils.StreamUtils

submit(AppendInput, Duration) - Method in class s2.client.ManagedAppendSession

T

token - Variable in class s2.config.Config

toProto() - Method in class s2.types.AppendRecord

toProto() - Method in record class s2.types.BasinConfig

toProto() - Method in class s2.types.CreateBasinRequest

toProto() - Method in class s2.types.CreateStreamRequest

toProto() - Method in record class s2.types.Header

toProto() - Method in class s2.types.ListBasinsRequest

toProto() - Method in class s2.types.ListStreamsRequest

toProto() - Method in class s2.types.ReadLimit

toProto() - Method in class s2.types.ReadSessionRequest

toProto() - Method in class s2.types.ReconfigureBasinRequest

toProto() - Method in class s2.types.ReconfigureStreamRequest

toProto() - Method in class s2.types.StreamConfig

toProto(String) - Method in class s2.types.AppendInput

toProto(String) - Method in class s2.types.ReadRequest

toProto(String) - Method in class s2.types.ReadSessionRequest

toString() - Method in record class s2.client.StreamClient.AppendSessionRequestStream

Returns a string representation of this record class.

toString() - Method in enum class s2.config.Cloud

toString() - Method in record class s2.types.AppendOutput

Returns a string representation of this record class.

toString() - Method in record class s2.types.BasinConfig

Returns a string representation of this record class.

toString() - Method in record class s2.types.BasinInfo

Returns a string representation of this record class.

toString() - Method in record class s2.types.Batch

Returns a string representation of this record class.

toString() - Method in record class s2.types.FirstSeqNum

Returns a string representation of this record class.

toString() - Method in record class s2.types.Header

Returns a string representation of this record class.

toString() - Method in record class s2.types.NextSeqNum

Returns a string representation of this record class.

toString() - Method in record class s2.types.Paginated

Returns a string representation of this record class.

toString() - Method in record class s2.types.SequencedRecord

Returns a string representation of this record class.

toString() - Method in record class s2.types.SequencedRecordBatch

Returns a string representation of this record class.

toString() - Method in record class s2.types.StreamInfo

Returns a string representation of this record class.

toTarget(String) - Method in class s2.config.BasinEndpoint

toTarget(String) - Method in class s2.config.Direct

toTarget(String) - Method in class s2.config.ParentZone

U

UNKNOWN - Enum constant in enum class s2.types.BasinState

UNKNOWN - Enum constant in enum class s2.types.StorageClass

UNSPECIFIED - Enum constant in enum class s2.types.BasinState

UNSPECIFIED - Enum constant in enum class s2.types.StorageClass

update(long, long, long) - Method in class s2.types.ReadSessionRequest

userAgent - Variable in class s2.config.Config

V

validateBasinName(String) - Static method in class s2.utils.BasinUtils

validateStreamName(String) - Static method in class s2.utils.StreamUtils

validateUnary() - Method in class s2.types.ReadLimit

value() - Method in record class s2.types.FirstSeqNum

Returns the value of the value record component.

value() - Method in record class s2.types.Header

Returns the value of the value record component.

value() - Method in record class s2.types.NextSeqNum

Returns the value of the value record component.

valueOf(String) - Static method in enum class s2.config.AppendRetryPolicy

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class s2.config.Cloud

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class s2.types.BasinState

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class s2.types.StorageClass

Returns the enum constant of this class with the specified name.

values() - Static method in enum class s2.config.AppendRetryPolicy

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class s2.config.Cloud

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class s2.types.BasinState

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class s2.types.StorageClass

Returns an array containing the constants of this enum class, in the order they are declared.

W

withAppendRetryPolicy(AppendRetryPolicy) - Method in class s2.config.Config.ConfigBuilder

withAssignmentCell(String) - Method in class s2.types.CreateBasinRequest.CreateBasinRequestBuilder

withAssignmentScope(String) - Method in class s2.types.CreateBasinRequest.CreateBasinRequestBuilder

withBasin(String) - Method in class s2.types.CreateBasinRequest.CreateBasinRequestBuilder

withBasin(String) - Method in class s2.types.ReconfigureBasinRequest.ReconfigureBasinRequestBuilder

withBasinConfig(BasinConfig) - Method in class s2.types.ReconfigureBasinRequest.ReconfigureBasinRequestBuilder

withBytes(byte[]) - Method in class s2.types.AppendRecord.AppendRecordBuilder

withDefaultStreamConfig(StreamConfig) - Method in class s2.types.CreateBasinRequest.CreateBasinRequestBuilder

withEndpoints(Endpoints) - Method in class s2.config.Config.ConfigBuilder

withFencingToken(ByteString) - Method in class s2.types.AppendInput.AppendInputBuilder

withFieldMask(List<String>) - Method in class s2.types.ReconfigureBasinRequest.ReconfigureBasinRequestBuilder

withFieldMask(List<String>) - Method in class s2.types.ReconfigureStreamRequest.ReconfigureStreamRequestBuilder

withHeaders(List<Header>) - Method in class s2.types.AppendRecord.AppendRecordBuilder

withLimit(Integer) - Method in class s2.types.ListBasinsRequest.ListBasinsRequestBuilder

withLimit(Integer) - Method in class s2.types.ListStreamsRequest.ListStreamsRequestBuilder

withMatchSeqNum(Long) - Method in class s2.types.AppendInput.AppendInputBuilder

withMaxAppendInflightBytes(int) - Method in class s2.config.Config.ConfigBuilder

withMaxRetries(int) - Method in class s2.config.Config.ConfigBuilder

withPrefix(String) - Method in class s2.types.ListBasinsRequest.ListBasinsRequestBuilder

withPrefix(String) - Method in class s2.types.ListStreamsRequest.ListStreamsRequestBuilder

withReadLimit(ReadLimit) - Method in class s2.types.ReadRequest.ReadRequestBuilder

withReadLimit(ReadLimit) - Method in class s2.types.ReadSessionRequest.ReadSessionRequestBuilder

withRecords(List<AppendRecord>) - Method in class s2.types.AppendInput.AppendInputBuilder

withRequestTimeout(long, TemporalUnit) - Method in class s2.config.Config.ConfigBuilder

withRetentionPolicy(RetentionPolicy) - Method in class s2.types.StreamConfig.StreamConfigBuilder

withRetryDelay(Duration) - Method in class s2.config.Config.ConfigBuilder

withStartAfter(String) - Method in class s2.types.ListBasinsRequest.ListBasinsRequestBuilder

withStartAfter(String) - Method in class s2.types.ListStreamsRequest.ListStreamsRequestBuilder

withStartSeqNum(long) - Method in class s2.types.ReadRequest.ReadRequestBuilder

withStartSeqNum(long) - Method in class s2.types.ReadSessionRequest.ReadSessionRequestBuilder

withStorageClass(StorageClass) - Method in class s2.types.StreamConfig.StreamConfigBuilder

withStream(String) - Method in class s2.types.ReconfigureStreamRequest.ReconfigureStreamRequestBuilder

withStreamConfig(StreamConfig) - Method in class s2.types.CreateStreamRequest.CreateStreamRequestBuilder

withStreamConfig(StreamConfig) - Method in class s2.types.ReconfigureStreamRequest.ReconfigureStreamRequestBuilder

withStreamName(String) - Method in class s2.types.CreateStreamRequest.CreateStreamRequestBuilder

withUserAgent(String) - Method in class s2.config.Config.ConfigBuilder

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form