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, UpdateMaxRecordSize, UpdateShardCount, UpdateStreamMode, UpdateStreamWarmThroughput

Class Method Summary

• .parameters_for_operation(context) ⇒ Object private

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.

# File 'lib/aws-sdk-kinesis/endpoints.rb', line 392

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_max_record_size
    UpdateMaxRecordSize.build(context)
  when :update_shard_count
    UpdateShardCount.build(context)
  when :update_stream_mode
    UpdateStreamMode.build(context)
  when :update_stream_warm_throughput
    UpdateStreamWarmThroughput.build(context)
  else
    Aws::Kinesis::EndpointParameters.create(context.config)
  end
end