in lib/kinesis_producer/daemon.rb [182:192]
def make_set_credential_message(credentials, for_metrics = false)
return nil if credentials.nil?
cred = KinesisProducer::Protobuf::Credentials.new(
akid: credentials.credentials.access_key_id,
secret_key: credentials.credentials.secret_access_key,
token: credentials.credentials.session_token
)
set_credentials = KinesisProducer::Protobuf::SetCredentials.new(credentials: cred, for_metrics: for_metrics)
make_message(FixnumMax, :set_credentials, set_credentials)
end