Class: Google::Apis::RunV1alpha1::PubSubSpec
- Inherits:
-
Object
- Object
- Google::Apis::RunV1alpha1::PubSubSpec
- 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 PubSub.
Instance Attribute Summary collapse
-
#ack_deadline ⇒ String
AckDeadline is the default maximum time after a subscriber receives a message before the subscriber should acknowledge the message.
-
#ce_overrides ⇒ Google::Apis::RunV1alpha1::CloudEventOverrides
CloudEventOverrides defines arguments for a Source that control the output format of the CloudEvents produced by the Source.
-
#project ⇒ String
Project is the ID of the Google Cloud Project that the PubSub Topic exists in.
-
#pubsub_secret ⇒ Google::Apis::RunV1alpha1::SecretKeySelector
Cloud Run fully managed: not supported Cloud Run on GKE: supported SecretKeySelector selects a key of a Secret.
-
#retain_acked_messages ⇒ Boolean
(also: #retain_acked_messages?)
RetainAckedMessages defines whether to retain acknowledged messages.
-
#retention_duration ⇒ String
RetentionDuration defines how long to retain messages in backlog, from the time of publish.
-
#secret ⇒ Google::Apis::RunV1alpha1::SecretKeySelector
Cloud Run fully managed: not supported Cloud Run on GKE: supported SecretKeySelector selects a key of a Secret.
-
#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.
-
#topic ⇒ String
Topic is the ID of the PubSub Topic to Subscribe to.
Instance Method Summary collapse
-
#initialize(**args) ⇒ PubSubSpec
constructor
A new instance of PubSubSpec.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ PubSubSpec
Returns a new instance of PubSubSpec
2943 2944 2945 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2943 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
2883 2884 2885 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2883 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
2889 2890 2891 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2889 def ce_overrides @ce_overrides end |
#project ⇒ String
Project is the ID of the Google Cloud Project that the PubSub Topic exists
in. If omitted, defaults to same as the cluster. +optional
Corresponds to the JSON property project
2895 2896 2897 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2895 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
2902 2903 2904 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2902 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
2909 2910 2911 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2909 def @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
2920 2921 2922 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2920 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
2927 2928 2929 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2927 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
2933 2934 2935 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2933 def sink @sink end |
#topic ⇒ String
Topic is the ID of the PubSub 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
2941 2942 2943 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2941 def topic @topic end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
2948 2949 2950 2951 2952 2953 2954 2955 2956 2957 2958 |
# File 'generated/google/apis/run_v1alpha1/classes.rb', line 2948 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 |