Class: Aws::MediaConnect::Waiters::SourceEndpointConnected

Inherits:
Object
  • Object
show all
Defined in:
gems/aws-sdk-mediaconnect/lib/aws-sdk-mediaconnect/waiters.rb

Overview

Wait until the Source Endpoint is CONNECTED

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ SourceEndpointConnected

Returns a new instance of SourceEndpointConnected.

Parameters:

  • options (Hash)

Options Hash (options):

  • :client (required, Client)
  • :max_attempts (Integer) — default: 40
  • :delay (Integer) — default: 3
  • :before_attempt (Proc)
  • :before_wait (Proc) 


1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
1053
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
 
# File 'gems/aws-sdk-mediaconnect/lib/aws-sdk-mediaconnect/waiters.rb', line 1042

def initialize(options)
  @client = options.fetch(:client)
  @waiter = Aws::Waiters::Waiter.new({
    max_attempts: 40,
    delay: 3,
    poller: Aws::Waiters::Poller.new(
      operation_name: :get_source_endpoint,
      acceptors: [
        {
          "matcher" => "path",
          "argument" => "source_endpoint.connection_state",
          "state" => "success",
          "expected" => "CONNECTED"
        },
        {
          "matcher" => "error",
          "state" => "retry",
          "expected" => "InternalServerErrorException"
        },
        {
          "matcher" => "error",
          "state" => "retry",
          "expected" => "ServiceUnavailableException"
        },
        {
          "matcher" => "error",
          "state" => "retry",
          "expected" => "TooManyRequestsException"
        }
      ]
    )
  }.merge(options))
end

Instance Method Details

#wait(params = {}) ⇒ Types::GetSourceEndpointResponse

Returns a response object which responds to the following methods:

Parameters:

  • params (Hash) (defaults to: {}) —

    a customizable set of options

Options Hash (params):

  • :arn (required, String) —

    The Amazon Resource Name (ARN) of the source endpoint to retrieve.

Returns:



1078
1079
1080
 
# File 'gems/aws-sdk-mediaconnect/lib/aws-sdk-mediaconnect/waiters.rb', line 1078

def wait(params = {})
  @waiter.wait(client: @client, params: params)
end