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
}