Class: Google::Apis::PubsubV1::AwsMsk

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
lib/google/apis/pubsub_v1/classes.rb,
lib/google/apis/pubsub_v1/representations.rb,
lib/google/apis/pubsub_v1/representations.rb

Overview

Ingestion settings for Amazon MSK.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ AwsMsk

Returns a new instance of AwsMsk.



207
208
209
 
# File 'lib/google/apis/pubsub_v1/classes.rb', line 207

def initialize(**args)
   update!(**args)
end

Instance Attribute Details

#aws_role_arn ⇒ String

Required. AWS role ARN to be used for Federated Identity authentication with Amazon MSK. Check the Pub/Sub docs for how to set up this role and the required permissions that need to be attached to it. Corresponds to the JSON property awsRoleArn

Returns:

  • (String) 


180
181
182
 
# File 'lib/google/apis/pubsub_v1/classes.rb', line 180

def aws_role_arn
  @aws_role_arn
end

#cluster_arn ⇒ String

Required. The Amazon Resource Name (ARN) that uniquely identifies the cluster. Corresponds to the JSON property clusterArn

Returns:

  • (String) 


185
186
187
 
# File 'lib/google/apis/pubsub_v1/classes.rb', line 185

def cluster_arn
  @cluster_arn
end

#gcp_service_account ⇒ String

Required. The GCP service account to be used for Federated Identity authentication with Amazon MSK (via a AssumeRoleWithWebIdentity call for the provided role). The aws_role_arn must be set up with accounts.google.com: sub equals to this service account number. Corresponds to the JSON property gcpServiceAccount

Returns:

  • (String) 


193
194
195
 
# File 'lib/google/apis/pubsub_v1/classes.rb', line 193

def 
  @gcp_service_account
end

#state ⇒ String

Output only. An output-only field that indicates the state of the Amazon MSK ingestion source. Corresponds to the JSON property state

Returns:

  • (String) 


199
200
201
 
# File 'lib/google/apis/pubsub_v1/classes.rb', line 199

def state
  @state
end

#topic ⇒ String

Required. The name of the topic in the Amazon MSK cluster that Pub/Sub will import from. Corresponds to the JSON property topic

Returns:

  • (String) 


205
206
207
 
# File 'lib/google/apis/pubsub_v1/classes.rb', line 205

def topic
  @topic
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



212
213
214
215
216
217
218
 
# File 'lib/google/apis/pubsub_v1/classes.rb', line 212

def update!(**args)
  @aws_role_arn = args[:aws_role_arn] if args.key?(:aws_role_arn)
  @cluster_arn = args[:cluster_arn] if args.key?(:cluster_arn)
  @gcp_service_account = args[:gcp_service_account] if args.key?(:gcp_service_account)
  @state = args[:state] if args.key?(:state)
  @topic = args[:topic] if args.key?(:topic)
end