Module: Fluent::KinesisHelper::Credentials

Defined in:
lib/fluent/plugin/kinesis_helper/credentials.rb

Instance Method Summary collapse

Instance Method Details

#credentials ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/fluent/plugin/kinesis_helper/credentials.rb', line 18

def credentials
  @provider ||= case
    when @assume_role_credentials
      Aws::AssumeRoleCredentials.new(
        client:            Aws::STS::Client.new(region: @region),
        role_arn:          @assume_role_credentials.role_arn,
        external_id:       @assume_role_credentials.external_id,
        role_session_name: 'aws-fluent-plugin-kinesis',
        duration_seconds:  60 * 60,
    )
    when @shared_credentials
      Aws::SharedCredentials.new(
        profile_name: @shared_credentials.profile_name,
        path:         @shared_credentials.path,
      )
    else
      default_credentials_provider
    end
end