Module: Aws::Kinesis::Endpoints Private

Defined in:
lib/aws-sdk-kinesis/endpoints.rb

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

Defined Under Namespace

Classes: AddTagsToStream, DecreaseStreamRetentionPeriod, DeleteResourcePolicy, DeleteStream, DeregisterStreamConsumer, DescribeStream, DescribeStreamConsumer, DescribeStreamSummary, DisableEnhancedMonitoring, EnableEnhancedMonitoring, GetRecords, GetResourcePolicy, GetShardIterator, IncreaseStreamRetentionPeriod, ListShards, ListStreamConsumers, ListTagsForResource, ListTagsForStream, MergeShards, PutRecord, PutRecords, PutResourcePolicy, RegisterStreamConsumer, RemoveTagsFromStream, SplitShard, StartStreamEncryption, StopStreamEncryption, SubscribeToShard, TagResource, UntagResource, UpdateShardCount, UpdateStreamMode

Class Method Summary collapse

Class Method Details

.parameters_for_operation(context) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.



338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
# File 'lib/aws-sdk-kinesis/endpoints.rb', line 338

def self.parameters_for_operation(context)
  case context.operation_name
  when :add_tags_to_stream
    AddTagsToStream.build(context)
  when :decrease_stream_retention_period
    DecreaseStreamRetentionPeriod.build(context)
  when :delete_resource_policy
    DeleteResourcePolicy.build(context)
  when :delete_stream
    DeleteStream.build(context)
  when :deregister_stream_consumer
    DeregisterStreamConsumer.build(context)
  when :describe_stream
    DescribeStream.build(context)
  when :describe_stream_consumer
    DescribeStreamConsumer.build(context)
  when :describe_stream_summary
    DescribeStreamSummary.build(context)
  when :disable_enhanced_monitoring
    DisableEnhancedMonitoring.build(context)
  when :enable_enhanced_monitoring
    EnableEnhancedMonitoring.build(context)
  when :get_records
    GetRecords.build(context)
  when :get_resource_policy
    GetResourcePolicy.build(context)
  when :get_shard_iterator
    GetShardIterator.build(context)
  when :increase_stream_retention_period
    IncreaseStreamRetentionPeriod.build(context)
  when :list_shards
    ListShards.build(context)
  when :list_stream_consumers
    ListStreamConsumers.build(context)
  when :list_tags_for_resource
    ListTagsForResource.build(context)
  when :list_tags_for_stream
    ListTagsForStream.build(context)
  when :merge_shards
    MergeShards.build(context)
  when :put_record
    PutRecord.build(context)
  when :put_records
    PutRecords.build(context)
  when :put_resource_policy
    PutResourcePolicy.build(context)
  when :register_stream_consumer
    RegisterStreamConsumer.build(context)
  when :remove_tags_from_stream
    RemoveTagsFromStream.build(context)
  when :split_shard
    SplitShard.build(context)
  when :start_stream_encryption
    StartStreamEncryption.build(context)
  when :stop_stream_encryption
    StopStreamEncryption.build(context)
  when :subscribe_to_shard
    SubscribeToShard.build(context)
  when :tag_resource
    TagResource.build(context)
  when :untag_resource
    UntagResource.build(context)
  when :update_shard_count
    UpdateShardCount.build(context)
  when :update_stream_mode
    UpdateStreamMode.build(context)
  else
    Aws::Kinesis::EndpointParameters.create(context.config)
  end
end