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, CreateStream, DecreaseStreamRetentionPeriod, DeleteResourcePolicy, DeleteStream, DeregisterStreamConsumer, DescribeAccountSettings, DescribeLimits, DescribeStream, DescribeStreamConsumer, DescribeStreamSummary, DisableEnhancedMonitoring, EnableEnhancedMonitoring, GetRecords, GetResourcePolicy, GetShardIterator, IncreaseStreamRetentionPeriod, ListShards, ListStreamConsumers, ListStreams, ListTagsForResource, ListTagsForStream, MergeShards, PutRecord, PutRecords, PutResourcePolicy, RegisterStreamConsumer, RemoveTagsFromStream, SplitShard, StartStreamEncryption, StopStreamEncryption, SubscribeToShard, TagResource, UntagResource, UpdateAccountSettings, UpdateMaxRecordSize, UpdateShardCount, UpdateStreamMode, UpdateStreamWarmThroughput

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.



437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
# File 'lib/aws-sdk-kinesis/endpoints.rb', line 437

def self.parameters_for_operation(context)
  case context.operation_name
  when :add_tags_to_stream
    AddTagsToStream.build(context)
  when :create_stream
    CreateStream.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_account_settings
    DescribeAccountSettings.build(context)
  when :describe_limits
    DescribeLimits.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_streams
    ListStreams.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_account_settings
    UpdateAccountSettings.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