Struct aws_sdk_kinesis::model::shard_filter::Builder
source · pub struct Builder { /* private fields */ }
Expand description
A builder for ShardFilter
.
Implementations§
source§impl Builder
impl Builder
sourcepub fn type(self, input: ShardFilterType) -> Self
pub fn type(self, input: ShardFilterType) -> Self
The shard type specified in the ShardFilter
parameter. This is a required property of the ShardFilter
parameter.
You can specify the following valid values:
-
AFTER_SHARD_ID
- the response includes all the shards, starting with the shard whose ID immediately follows theShardId
that you provided. -
AT_TRIM_HORIZON
- the response includes all the shards that were open atTRIM_HORIZON
. -
FROM_TRIM_HORIZON
- (default), the response includes all the shards within the retention period of the data stream (trim to tip). -
AT_LATEST
- the response includes only the currently open shards of the data stream. -
AT_TIMESTAMP
- the response includes all shards whose start timestamp is less than or equal to the given timestamp and end timestamp is greater than or equal to the given timestamp or still open. -
FROM_TIMESTAMP
- the response incldues all closed shards whose end timestamp is greater than or equal to the given timestamp and also all open shards. Corrected toTRIM_HORIZON
of the data stream ifFROM_TIMESTAMP
is less than theTRIM_HORIZON
value.
sourcepub fn set_type(self, input: Option<ShardFilterType>) -> Self
pub fn set_type(self, input: Option<ShardFilterType>) -> Self
The shard type specified in the ShardFilter
parameter. This is a required property of the ShardFilter
parameter.
You can specify the following valid values:
-
AFTER_SHARD_ID
- the response includes all the shards, starting with the shard whose ID immediately follows theShardId
that you provided. -
AT_TRIM_HORIZON
- the response includes all the shards that were open atTRIM_HORIZON
. -
FROM_TRIM_HORIZON
- (default), the response includes all the shards within the retention period of the data stream (trim to tip). -
AT_LATEST
- the response includes only the currently open shards of the data stream. -
AT_TIMESTAMP
- the response includes all shards whose start timestamp is less than or equal to the given timestamp and end timestamp is greater than or equal to the given timestamp or still open. -
FROM_TIMESTAMP
- the response incldues all closed shards whose end timestamp is greater than or equal to the given timestamp and also all open shards. Corrected toTRIM_HORIZON
of the data stream ifFROM_TIMESTAMP
is less than theTRIM_HORIZON
value.
sourcepub fn shard_id(self, input: impl Into<String>) -> Self
pub fn shard_id(self, input: impl Into<String>) -> Self
The exclusive start shardID
speified in the ShardFilter
parameter. This property can only be used if the AFTER_SHARD_ID
shard type is specified.
sourcepub fn set_shard_id(self, input: Option<String>) -> Self
pub fn set_shard_id(self, input: Option<String>) -> Self
The exclusive start shardID
speified in the ShardFilter
parameter. This property can only be used if the AFTER_SHARD_ID
shard type is specified.
sourcepub fn timestamp(self, input: DateTime) -> Self
pub fn timestamp(self, input: DateTime) -> Self
The timestamps specified in the ShardFilter
parameter. A timestamp is a Unix epoch date with precision in milliseconds. For example, 2016-04-04T19:58:46.480-00:00 or 1459799926.480. This property can only be used if FROM_TIMESTAMP
or AT_TIMESTAMP
shard types are specified.
sourcepub fn set_timestamp(self, input: Option<DateTime>) -> Self
pub fn set_timestamp(self, input: Option<DateTime>) -> Self
The timestamps specified in the ShardFilter
parameter. A timestamp is a Unix epoch date with precision in milliseconds. For example, 2016-04-04T19:58:46.480-00:00 or 1459799926.480. This property can only be used if FROM_TIMESTAMP
or AT_TIMESTAMP
shard types are specified.
sourcepub fn build(self) -> ShardFilter
pub fn build(self) -> ShardFilter
Consumes the builder and constructs a ShardFilter
.