KEYSPACESSTREAMS
GetRecords
valid {
input.Body.shardIterator == STRING
input.Body.maxResults == INTEGER
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
GetShardIterator
enum_ShardIteratorType := [ "TRIM_HORIZON", "LATEST", "AT_SEQUENCE_NUMBER", "AFTER_SEQUENCE_NUMBER" ]
valid {
input.Body.streamArn == STRING
input.Body.shardId == STRING
input.Body.shardIteratorType == enum_ShardIteratorType[_]
input.Body.sequenceNumber == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
GetStream
enum_ShardFilterType := [ "CHILD_SHARDS" ]
valid {
input.Body.streamArn == STRING
input.Body.maxResults == INTEGER
input.Body.shardFilter.type == enum_ShardFilterType[_]
input.Body.shardFilter.shardId == STRING
input.Body.nextToken == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
ListStreams
valid {
input.Body.keyspaceName == STRING
input.Body.tableName == STRING
input.Body.maxResults == INTEGER
input.Body.nextToken == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
Updated 4 days ago