Class: Google::Apis::RunV1alpha1::CloudPubSubSourceSpec

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

Overview

The desired state of the CloudPubSubSource.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Core::JsonObjectSupport

#to_json

Methods included from Core::Hashable

process_value, #to_h

Constructor Details

#initialize(**args) ⇒ CloudPubSubSourceSpec

Returns a new instance of CloudPubSubSourceSpec.



585
586
587
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 585

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

Instance Attribute Details

#ack_deadline ⇒ String

AckDeadline is the default maximum time after a subscriber receives a message before the subscriber should acknowledge the message. Defaults to 30 seconds ('30s'). +optional Corresponds to the JSON property ackDeadline

Returns:

  • (String) 


525
526
527
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 525

def ack_deadline
  @ack_deadline
end

#ce_overrides ⇒ Google::Apis::RunV1alpha1::CloudEventOverrides

CloudEventOverrides defines arguments for a Source that control the output format of the CloudEvents produced by the Source. Corresponds to the JSON property ceOverrides

Returns:



531
532
533
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 531

def ce_overrides
  @ce_overrides
end

#project ⇒ String

Project is the ID of the Google Cloud Project that the CloudPubSubSource Topic exists in. If omitted, defaults to same as the cluster. +optional Corresponds to the JSON property project

Returns:

  • (String) 


537
538
539
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 537

def project
  @project
end

#pubsub_secret ⇒ Google::Apis::RunV1alpha1::SecretKeySelector

Cloud Run fully managed: not supported Cloud Run on GKE: supported SecretKeySelector selects a key of a Secret. Corresponds to the JSON property pubsubSecret

Returns:



544
545
546
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 544

def pubsub_secret
  @pubsub_secret
end

#retain_acked_messages ⇒ Boolean Also known as: retain_acked_messages?

RetainAckedMessages defines whether to retain acknowledged messages. If true, acknowledged messages will not be expunged until they fall out of the RetentionDuration window. Corresponds to the JSON property retainAckedMessages

Returns:

  • (Boolean) 


551
552
553
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 551

def retain_acked_messages
  @retain_acked_messages
end

#retention_duration ⇒ String

RetentionDuration defines how long to retain messages in backlog, from the time of publish. If RetainAckedMessages is true, this duration affects the retention of acknowledged messages, otherwise only unacknowledged messages are retained. Cannot be longer than 7 days or shorter than 10 minutes. Defaults to 7 days ('7d'). +optional Corresponds to the JSON property retentionDuration

Returns:

  • (String) 


562
563
564
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 562

def retention_duration
  @retention_duration
end

#secret ⇒ Google::Apis::RunV1alpha1::SecretKeySelector

Cloud Run fully managed: not supported Cloud Run on GKE: supported SecretKeySelector selects a key of a Secret. Corresponds to the JSON property secret

Returns:



569
570
571
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 569

def secret
  @secret
end

#sink ⇒ Google::Apis::RunV1alpha1::Destination

Sink is a reference to an object that will resolve to a domain name or a URI directly to use as the sink. Corresponds to the JSON property sink

Returns:



575
576
577
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 575

def sink
  @sink
end

#topic ⇒ String

Topic is the ID of the CloudPubSubSource Topic to Subscribe to. It must be in the form of the unique identifier within the project, not the entire name. E.g. it must be 'laconia', not 'projects/my-proj/topics/laconia'. Corresponds to the JSON property topic

Returns:

  • (String) 


583
584
585
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 583

def topic
  @topic
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



590
591
592
593
594
595
596
597
598
599
600
 
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 590

def update!(**args)
  @ack_deadline = args[:ack_deadline] if args.key?(:ack_deadline)
  @ce_overrides = args[:ce_overrides] if args.key?(:ce_overrides)
  @project = args[:project] if args.key?(:project)
  @pubsub_secret = args[:pubsub_secret] if args.key?(:pubsub_secret)
  @retain_acked_messages = args[:retain_acked_messages] if args.key?(:retain_acked_messages)
  @retention_duration = args[:retention_duration] if args.key?(:retention_duration)
  @secret = args[:secret] if args.key?(:secret)
  @sink = args[:sink] if args.key?(:sink)
  @topic = args[:topic] if args.key?(:topic)
end