import { Kinesis } from "https://deno.land/x/aws_api@v0.8.1/services/kinesis/mod.ts";
Methods
addTagsToStream(params: s.AddTagsToStreamInput, opts?: client.RequestOptions): Promise<void>
createStream(params: s.CreateStreamInput, opts?: client.RequestOptions): Promise<void>
decreaseStreamRetentionPeriod(params: s.DecreaseStreamRetentionPeriodInput, opts?: client.RequestOptions): Promise<void>
deleteStream(params: s.DeleteStreamInput, opts?: client.RequestOptions): Promise<void>
deregisterStreamConsumer(params?: s.DeregisterStreamConsumerInput, opts?: client.RequestOptions): Promise<void>
describeLimits(opts?: client.RequestOptions): Promise<s.DescribeLimitsOutput>
describeStream(params: s.DescribeStreamInput, opts?: client.RequestOptions): Promise<s.DescribeStreamOutput>
describeStreamConsumer(params?: s.DescribeStreamConsumerInput, opts?: client.RequestOptions): Promise<s.DescribeStreamConsumerOutput>
describeStreamSummary(params: s.DescribeStreamSummaryInput, opts?: client.RequestOptions): Promise<s.DescribeStreamSummaryOutput>
disableEnhancedMonitoring(params: s.DisableEnhancedMonitoringInput, opts?: client.RequestOptions): Promise<s.EnhancedMonitoringOutput>
enableEnhancedMonitoring(params: s.EnableEnhancedMonitoringInput, opts?: client.RequestOptions): Promise<s.EnhancedMonitoringOutput>
getRecords(params: s.GetRecordsInput, opts?: client.RequestOptions): Promise<s.GetRecordsOutput>
getShardIterator(params: s.GetShardIteratorInput, opts?: client.RequestOptions): Promise<s.GetShardIteratorOutput>
increaseStreamRetentionPeriod(params: s.IncreaseStreamRetentionPeriodInput, opts?: client.RequestOptions): Promise<void>
listShards(params?: s.ListShardsInput, opts?: client.RequestOptions): Promise<s.ListShardsOutput>
listStreamConsumers(params: s.ListStreamConsumersInput, opts?: client.RequestOptions): Promise<s.ListStreamConsumersOutput>
listStreams(params?: s.ListStreamsInput, opts?: client.RequestOptions): Promise<s.ListStreamsOutput>
listTagsForStream(params: s.ListTagsForStreamInput, opts?: client.RequestOptions): Promise<s.ListTagsForStreamOutput>
mergeShards(params: s.MergeShardsInput, opts?: client.RequestOptions): Promise<void>
putRecord(params: s.PutRecordInput, opts?: client.RequestOptions): Promise<s.PutRecordOutput>
putRecords(params: s.PutRecordsInput, opts?: client.RequestOptions): Promise<s.PutRecordsOutput>
registerStreamConsumer(params: s.RegisterStreamConsumerInput, opts?: client.RequestOptions): Promise<s.RegisterStreamConsumerOutput>
removeTagsFromStream(params: s.RemoveTagsFromStreamInput, opts?: client.RequestOptions): Promise<void>
splitShard(params: s.SplitShardInput, opts?: client.RequestOptions): Promise<void>
startStreamEncryption(params: s.StartStreamEncryptionInput, opts?: client.RequestOptions): Promise<void>
stopStreamEncryption(params: s.StopStreamEncryptionInput, opts?: client.RequestOptions): Promise<void>
updateShardCount(params: s.UpdateShardCountInput, opts?: client.RequestOptions): Promise<s.UpdateShardCountOutput>
updateStreamMode(params: s.UpdateStreamModeInput, opts?: client.RequestOptions): Promise<void>
waitForStreamExists(params: s.DescribeStreamInput, opts?: client.RequestOptions): Promise<s.DescribeStreamOutput>
Checks state up to 18 times, 10 seconds apart (about 3 minutes max wait time).
waitForStreamNotExists(params: s.DescribeStreamInput, opts?: client.RequestOptions): Promise<Error | s.DescribeStreamOutput>
Checks state up to 18 times, 10 seconds apart (about 3 minutes max wait time).