A B C D E F G H I L M N P R S T U V W
All Classes All Packages
All Classes All Packages
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
All Classes All Packages