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

A

account - Variable in class s2.config.Endpoints
 
AccountChannel - Class in s2.channel
 
AccountCompatibleChannel - Interface in s2.channel
 
ACTIVE - s2.types.BasinState
 
address - Variable in class s2.config.BasinEndpoint
 
Address - Class in s2.config
 
Address(String, int) - Constructor for class s2.config.Address
 
age - Variable in class s2.types.Age
 
Age - Class in s2.types
 
Age(Duration) - Constructor for class s2.types.Age
 
ALL - 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 - Class in s2.types
 
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 in s2.config
 
appendSession(Consumer<AppendOutput>, Consumer<Throwable>, Runnable) - Method in class s2.client.StreamClient
Start an unmanaged streaming append session.
applyRequestMetadata(CallCredentials.RequestInfo, Executor, CallCredentials.MetadataApplier) - Method in class s2.auth.BearerTokenCallCredentials
Applies the bearer token to the request metadata.
assignment - Variable in class s2.types.CreateBasinRequest
 
AutoClosableManagedChannel - Class in s2.channel
 
AutoClosableManagedChannel(ManagedChannel) - Constructor for class s2.channel.AutoClosableManagedChannel
 
awaitCompletion() - Method in class s2.client.ReadSession
 
AWS - s2.config.Cloud
 

B

BaseClient - Class in s2.client
 
basin - Variable in class s2.config.Endpoints
 
basin - Variable in class s2.types.CreateBasinRequest
 
basin - Variable in class s2.types.ReconfigureBasinRequest
 
BasinChannel - Class in s2.channel
 
BasinClient - Class in s2.client
Client for basin-level operations.
BasinClient.BasinClientBuilder - Class in s2.client
 
BasinCompatibleChannel - Interface in s2.channel
 
basinConfig - Variable in class s2.types.ReconfigureBasinRequest
 
BasinConfig - Class in s2.types
 
BasinConfig(StreamConfig) - Constructor for class s2.types.BasinConfig
 
BasinEndpoint - Class in s2.config
 
BasinInfo - Class in s2.types
 
basinState - Variable in class s2.types.BasinInfo
 
BasinState - Enum in s2.types
 
BasinUtils - Class in s2.utils
 
BasinUtils() - Constructor for class s2.utils.BasinUtils
 
Batch - Class in s2.types
 
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 - Variable in class s2.types.AppendRecord
 
body - Variable in class s2.types.SequencedRecord
 
build() - Method in class s2.client.BasinClient.BasinClientBuilder
 
build() - Method in class s2.client.Client.ClientBuilder
 
build() - Method in class s2.client.StreamClient.StreamClientBuilder
 
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 - Variable in class s2.types.BasinInfo
 
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.ClientBuilder - Class in s2.client
 
ClientBuilder(Config) - Constructor for class s2.client.Client.ClientBuilder
 
close() - Method in class s2.channel.AutoClosableManagedChannel
 
close() - Method in class s2.client.BaseClient
 
close() - Method in class s2.client.ManagedAppendSession
 
close() - Method in class s2.client.ManagedReadSession
 
close() - Method in class s2.client.ReadSession
 
closeGracefully() - Method in class s2.client.ManagedAppendSession
 
closeImmediately() - Method in class s2.client.ManagedAppendSession
 
Cloud - Enum in s2.config
 
CombinedChannel - Class in s2.channel
 
compression - Variable in class s2.config.Config
 
config - Variable in class s2.types.CreateBasinRequest
 
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 - Variable in class s2.types.StreamInfo
 
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 - s2.types.BasinState
 

D

defaultStreamConfig - Variable in class s2.types.BasinConfig
 
deleteBasin(String) - Method in class s2.client.Client
Delete a basin.
deletedAt - Variable in class s2.types.StreamInfo
 
deleteStream(String) - Method in class s2.client.BasinClient
Delete a stream.
DELETING - s2.types.BasinState
 
Direct - Class in s2.config
 
Direct(Address) - Constructor for class s2.config.Direct
 

E

elems - Variable in class s2.types.Paginated
 
endpoints - Variable in class s2.config.Config
 
Endpoints - Class in s2.config
 
endSeqNum - Variable in class s2.types.AppendOutput
 
equals(Object) - Method in class s2.auth.BearerTokenCallCredentials
Returns whether this credentials implementation is equal to another object.
equals(Object) - Method in class s2.config.Address
 
equals(Object) - Method in class s2.config.BasinEndpoint
 
EXPRESS - s2.types.StorageClass
 

F

fencingToken - Variable in class s2.types.AppendInput
 
fieldMask - Variable in class s2.types.ReconfigureBasinRequest
 
fieldMask - Variable in class s2.types.ReconfigureStreamRequest
 
firstSeqNum() - Method in class s2.types.Batch
 
FirstSeqNum - Class in s2.types
 
FirstSeqNum(long) - Constructor for class s2.types.FirstSeqNum
 
forAccountService(Config) - Static method in class s2.channel.ManagedChannelFactory
 
forBasinOrStreamService(Config, String) - Static method in class s2.channel.ManagedChannelFactory
 
forCell(Cloud, String) - Static method in class s2.config.Endpoints
 
forCloud(Cloud) - Static method in class s2.config.Endpoints
 
forCombinedChannel(Config) - Static method in class s2.channel.ManagedChannelFactory
 
fromEnvironment() - Static method in class s2.config.Endpoints
 
fromProto(AppendOutput) - Static method in class s2.types.AppendOutput
 
fromProto(BasinInfo) - Static method in class s2.types.BasinInfo
 
fromProto(Header) - Static method in class s2.types.Header
 
fromProto(ReadOutput) - Static method in interface s2.types.ReadOutput
 
fromProto(SequencedRecord) - Static method in class s2.types.SequencedRecord
 
fromProto(SequencedRecordBatch) - Static method in class s2.types.SequencedRecordBatch
 
fromProto(StreamConfig) - Static method in class s2.types.StreamConfig
 
fromProto(StreamInfo) - Static method in class s2.types.StreamInfo
 
fromString(String) - Static method in class s2.config.Address
 
fromString(String) - Static method in enum 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.
getChannel() - Method in class s2.channel.AccountChannel
 
getChannel() - Method in interface s2.channel.AccountCompatibleChannel
 
getChannel() - Method in class s2.channel.BasinChannel
 
getChannel() - Method in interface s2.channel.BasinCompatibleChannel
 
getChannel() - Method in class s2.channel.CombinedChannel
 
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 class s2.config.Address
 
hashCode() - Method in class s2.config.BasinEndpoint
 
hasMore - Variable in class s2.types.Paginated
 
hasNext() - Method in class s2.client.ManagedReadSession
 
Header - Class in s2.types
 
Header(ByteString, ByteString) - Constructor for class s2.types.Header
 
headers - Variable in class s2.types.AppendRecord
 
headers - Variable in class s2.types.SequencedRecord
 
host - Variable in class s2.config.Address
 

I

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

L

lastSeqNum() - Method in class s2.types.Batch
 
limit - Variable in class s2.types.ListBasinsRequest
 
limit - Variable in class s2.types.ListStreamsRequest
 
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
 
managedChannel - Variable in class s2.channel.AutoClosableManagedChannel
 
ManagedChannelFactory - Class in s2.channel
 
ManagedChannelFactory() - Constructor for class s2.channel.ManagedChannelFactory
 
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 class s2.types.Batch
 
meteredBytes() - Method in interface s2.types.MeteredBytes
 
meteredBytes() - Method in class s2.types.SequencedRecord
 
meteredBytes() - Method in class s2.types.SequencedRecordBatch
 
MeteredBytes - Interface in s2.types
 

N

name - Variable in class s2.types.BasinInfo
 
name - Variable in class s2.types.Header
 
name - Variable in class s2.types.StreamInfo
 
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
 
newBuilder(Config) - Static method in class s2.client.Client
 
newBuilder(Config, String) - Static method in class s2.client.BasinClient
 
newBuilder(Config, String, String) - Static method in class s2.client.StreamClient
 
nextSeqNum - Variable in class s2.types.AppendOutput
 
NextSeqNum - Class in s2.types
 
NextSeqNum(long) - Constructor for class s2.types.NextSeqNum
 
NO_SIDE_EFFECTS - s2.config.AppendRetryPolicy
 
NONE - Static variable in class s2.types.ReadLimit
 

P

Paginated<T> - Class in s2.types
 
Paginated(boolean, List<T>) - Constructor for class s2.types.Paginated
 
ParentZone - Class in s2.config
 
ParentZone(Address) - Constructor for class s2.config.ParentZone
 
port - Variable in class s2.config.Address
 
prefix - Variable in class s2.types.ListBasinsRequest
 
prefix - Variable in class s2.types.ListStreamsRequest
 

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 - Variable in class s2.types.SequencedRecordBatch
 
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.channel - package s2.channel
Utilities and classes for constructing gRPC channels for communicating with S2 services.
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 - Variable in class s2.types.BasinInfo
 
seqNum - Variable in class s2.types.SequencedRecord
 
SequencedRecord - Class in s2.types
 
sequencedRecordBatch - Variable in class s2.types.Batch
 
SequencedRecordBatch - Class in s2.types
 
singleEndpoint() - Method in class s2.config.Endpoints
 
STANDARD - s2.types.StorageClass
 
startAfter - Variable in class s2.types.ListBasinsRequest
 
startAfter - Variable in class s2.types.ListStreamsRequest
 
startSeqNum - Variable in class s2.types.AppendOutput
 
startSeqNum - Variable in class s2.types.ReadRequest
 
startSeqNum - Variable in class s2.types.ReadSessionRequest
 
storageClass - Variable in class s2.types.StreamConfig
 
StorageClass - Enum in s2.types
 
stream - Variable in class s2.types.ReconfigureStreamRequest
 
StreamClient - Class in s2.client
Client for stream-level operations.
StreamClient.AppendSessionRequestStream - Class in s2.client
 
StreamClient.StreamClientBuilder - Class in s2.client
 
StreamClientBuilder(Config, String, String) - Constructor for class s2.client.StreamClient.StreamClientBuilder
 
streamConfig - Variable in class s2.types.CreateStreamRequest
 
streamConfig - Variable in class s2.types.ReconfigureStreamRequest
 
StreamConfig - Class in s2.types
 
StreamConfig.StreamConfigBuilder - Class in s2.types
 
StreamConfigBuilder() - Constructor for class s2.types.StreamConfig.StreamConfigBuilder
 
StreamInfo - Class in s2.types
 
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 class s2.types.BasinConfig
 
toProto() - Method in class s2.types.CreateBasinRequest
 
toProto() - Method in class s2.types.CreateStreamRequest
 
toProto() - Method in 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 enum s2.config.Cloud
 
toString() - Method in class s2.types.AppendOutput
 
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 - s2.types.BasinState
 
UNKNOWN - s2.types.StorageClass
 
UNSPECIFIED - s2.types.BasinState
 
UNSPECIFIED - 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 - Variable in class s2.types.FirstSeqNum
 
value - Variable in class s2.types.Header
 
value - Variable in class s2.types.NextSeqNum
 
valueOf(String) - Static method in enum s2.config.AppendRetryPolicy
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum s2.config.Cloud
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum s2.types.BasinState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum s2.types.StorageClass
Returns the enum constant of this type with the specified name.
values() - Static method in enum s2.config.AppendRetryPolicy
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum s2.config.Cloud
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum s2.types.BasinState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum s2.types.StorageClass
Returns an array containing the constants of this enum type, 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
 
withBody(byte[]) - Method in class s2.types.AppendRecord.AppendRecordBuilder
 
withBody(ByteString) - Method in class s2.types.AppendRecord.AppendRecordBuilder
 
withChannel(AccountCompatibleChannel) - Method in class s2.client.Client.ClientBuilder
 
withChannel(BasinCompatibleChannel) - Method in class s2.client.BasinClient.BasinClientBuilder
 
withChannel(BasinCompatibleChannel) - Method in class s2.client.StreamClient.StreamClientBuilder
 
withCompression(Boolean) - Method in class s2.config.Config.ConfigBuilder
 
withDefaultStreamConfig(StreamConfig) - Method in class s2.types.CreateBasinRequest.CreateBasinRequestBuilder
 
withEndpoints(Endpoints) - Method in class s2.config.Config.ConfigBuilder
 
withExecutor(ScheduledExecutorService) - Method in class s2.client.BasinClient.BasinClientBuilder
 
withExecutor(ScheduledExecutorService) - Method in class s2.client.Client.ClientBuilder
 
withExecutor(ScheduledExecutorService) - Method in class s2.client.StreamClient.StreamClientBuilder
 
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 P R S T U V W 
All Classes All Packages