Hi there! Are you looking for the official Deno documentation? Try docs.deno.com for all your Deno learning needs.

Kinesis

import { Kinesis } from "https://aws-api-16vtt531a2w0.deno.dev/v0.2/services/kinesis.ts";
class Kinesis {
constructor(apiFactory: client.ApiFactory);
async addTagsToStream(params: AddTagsToStreamInput, opts?: client.RequestOptions): Promise<void>;
async createStream(params: CreateStreamInput, opts?: client.RequestOptions): Promise<void>;
async decreaseStreamRetentionPeriod(params: DecreaseStreamRetentionPeriodInput, opts?: client.RequestOptions): Promise<void>;
async deleteStream(params: DeleteStreamInput, opts?: client.RequestOptions): Promise<void>;
async deregisterStreamConsumer(params?: DeregisterStreamConsumerInput, opts?: client.RequestOptions): Promise<void>;
async describeLimits(opts?: client.RequestOptions): Promise<DescribeLimitsOutput>;
async describeStream(params: DescribeStreamInput, opts?: client.RequestOptions): Promise<DescribeStreamOutput>;
async describeStreamConsumer(params?: DescribeStreamConsumerInput, opts?: client.RequestOptions): Promise<DescribeStreamConsumerOutput>;
async describeStreamSummary(params: DescribeStreamSummaryInput, opts?: client.RequestOptions): Promise<DescribeStreamSummaryOutput>;
async disableEnhancedMonitoring(params: DisableEnhancedMonitoringInput, opts?: client.RequestOptions): Promise<EnhancedMonitoringOutput>;
async enableEnhancedMonitoring(params: EnableEnhancedMonitoringInput, opts?: client.RequestOptions): Promise<EnhancedMonitoringOutput>;
async getRecords(params: GetRecordsInput, opts?: client.RequestOptions): Promise<GetRecordsOutput>;
async getShardIterator(params: GetShardIteratorInput, opts?: client.RequestOptions): Promise<GetShardIteratorOutput>;
async increaseStreamRetentionPeriod(params: IncreaseStreamRetentionPeriodInput, opts?: client.RequestOptions): Promise<void>;
async listShards(params?: ListShardsInput, opts?: client.RequestOptions): Promise<ListShardsOutput>;
async listStreamConsumers(params: ListStreamConsumersInput, opts?: client.RequestOptions): Promise<ListStreamConsumersOutput>;
async listStreams(params?: ListStreamsInput, opts?: client.RequestOptions): Promise<ListStreamsOutput>;
async listTagsForStream(params: ListTagsForStreamInput, opts?: client.RequestOptions): Promise<ListTagsForStreamOutput>;
async mergeShards(params: MergeShardsInput, opts?: client.RequestOptions): Promise<void>;
async putRecord(params: PutRecordInput, opts?: client.RequestOptions): Promise<PutRecordOutput>;
async putRecords(params: PutRecordsInput, opts?: client.RequestOptions): Promise<PutRecordsOutput>;
async registerStreamConsumer(params: RegisterStreamConsumerInput, opts?: client.RequestOptions): Promise<RegisterStreamConsumerOutput>;
async removeTagsFromStream(params: RemoveTagsFromStreamInput, opts?: client.RequestOptions): Promise<void>;
async splitShard(params: SplitShardInput, opts?: client.RequestOptions): Promise<void>;
async startStreamEncryption(params: StartStreamEncryptionInput, opts?: client.RequestOptions): Promise<void>;
async stopStreamEncryption(params: StopStreamEncryptionInput, opts?: client.RequestOptions): Promise<void>;
async updateShardCount(params: UpdateShardCountInput, opts?: client.RequestOptions): Promise<UpdateShardCountOutput>;
async waitForStreamExists(params: DescribeStreamInput, opts?: client.RequestOptions): Promise<DescribeStreamOutput>;
async waitForStreamNotExists(params: DescribeStreamInput, opts?: client.RequestOptions): Promise<Error | DescribeStreamOutput>;
 
static ApiMetadata: client.ApiMetadata;
}

§Constructors

§
new Kinesis(apiFactory: client.ApiFactory)
[src]

§Methods

§
addTagsToStream(params: AddTagsToStreamInput, opts?: client.RequestOptions): Promise<void>
[src]
§
createStream(params: CreateStreamInput, opts?: client.RequestOptions): Promise<void>
[src]
§
decreaseStreamRetentionPeriod(params: DecreaseStreamRetentionPeriodInput, opts?: client.RequestOptions): Promise<void>
[src]
§
deleteStream(params: DeleteStreamInput, opts?: client.RequestOptions): Promise<void>
[src]
§
deregisterStreamConsumer(params?: DeregisterStreamConsumerInput, opts?: client.RequestOptions): Promise<void>
[src]
§
describeLimits(opts?: client.RequestOptions): Promise<DescribeLimitsOutput>
[src]
§
disableEnhancedMonitoring(params: DisableEnhancedMonitoringInput, opts?: client.RequestOptions): Promise<EnhancedMonitoringOutput>
[src]
§
enableEnhancedMonitoring(params: EnableEnhancedMonitoringInput, opts?: client.RequestOptions): Promise<EnhancedMonitoringOutput>
[src]
§
getRecords(params: GetRecordsInput, opts?: client.RequestOptions): Promise<GetRecordsOutput>
[src]
§
increaseStreamRetentionPeriod(params: IncreaseStreamRetentionPeriodInput, opts?: client.RequestOptions): Promise<void>
[src]
§
listShards(params?: ListShardsInput, opts?: client.RequestOptions): Promise<ListShardsOutput>
[src]
§
listStreams(params?: ListStreamsInput, opts?: client.RequestOptions): Promise<ListStreamsOutput>
[src]
§
mergeShards(params: MergeShardsInput, opts?: client.RequestOptions): Promise<void>
[src]
§
putRecord(params: PutRecordInput, opts?: client.RequestOptions): Promise<PutRecordOutput>
[src]
§
putRecords(params: PutRecordsInput, opts?: client.RequestOptions): Promise<PutRecordsOutput>
[src]
§
removeTagsFromStream(params: RemoveTagsFromStreamInput, opts?: client.RequestOptions): Promise<void>
[src]
§
splitShard(params: SplitShardInput, opts?: client.RequestOptions): Promise<void>
[src]
§
startStreamEncryption(params: StartStreamEncryptionInput, opts?: client.RequestOptions): Promise<void>
[src]
§
stopStreamEncryption(params: StopStreamEncryptionInput, opts?: client.RequestOptions): Promise<void>
[src]
§
waitForStreamExists(params: DescribeStreamInput, opts?: client.RequestOptions): Promise<DescribeStreamOutput>
[src]

Checks state up to 18 times, 10 seconds apart (about 3 minutes max wait time).

§
waitForStreamNotExists(params: DescribeStreamInput, opts?: client.RequestOptions): Promise<Error | DescribeStreamOutput>
[src]

Checks state up to 18 times, 10 seconds apart (about 3 minutes max wait time).

§Static Properties