ansible-collections/google.cloud
1
0
Fork 0
mirror of https://github.com/ansible-collections/google.cloud.git synced 2025-07-27 15:11:33 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add source snapshot to ansible (#300)

Browse source 
* Make `iap` field computed (#3814) (#272)

Signed-off-by: Modular Magician <magic-modules@google.com>

* add source_image and source_snapshot to google_compute_image (#3799) (#273)

* add source_image to google_compute_image

* add source_snapshot to google_compute_image

* PR comment changes

Signed-off-by: Modular Magician <magic-modules@google.com>

* Collection fixes for release (#3831) (#274)

Signed-off-by: Modular Magician <magic-modules@google.com>

* Add new field filter to pubsub. (#3759) (#275)

* Add new field filter to pubsub.

Fixes: https://github.com/terraform-providers/terraform-provider-google/issues/6727

* Fixed filter name, it was improperly set.

* add filter key to pubsub subscription unit test

* spaces not tabs!

* hardcode filter value in test

* revert remove escaped quotes

Co-authored-by: Tim O'Connell <hi@timoconnell.co.uk>
Signed-off-by: Modular Magician <magic-modules@google.com>

Co-authored-by: Tim O'Connell <hi@timoconnell.co.uk>

* Add archive class to gcs (#3867) (#276)

Signed-off-by: Modular Magician <magic-modules@google.com>

* Add support for gRPC healthchecks (#3825) (#277)

Signed-off-by: Modular Magician <magic-modules@google.com>

* Add enableMessageOrdering to Pub/Sub Subscription (#3872) (#278)

Add enableMessageOrdering to Pub/Sub Subscription

Signed-off-by: Modular Magician <magic-modules@google.com>

* use {product}.googleapis.com endpoints (#3755) (#279)

* use {product}.googleapis.com endpoints

* use actual correct urls

* fix zone data source test

* fix network peering tests

* possibly fix deleting default network

Signed-off-by: Modular Magician <magic-modules@google.com>

* Removed instances where input and output are both true (#3890) (#280)

* [provider-yaml] - Removed instances where input and output are both true

* modified to only supply output. Following pattern from bigquerydatatransfer

Co-authored-by: Scott Suarez <scottsuarez@google.com>
Signed-off-by: Modular Magician <magic-modules@google.com>

Co-authored-by: Scott Suarez <scottsuarez@google.com>

* retrypolicy attribute added (#3843) (#281)

* retrypolicy attribute added

* test case updated

Signed-off-by: Modular Magician <magic-modules@google.com>

* Advanced logging config options in google_compute_subnetwork (#3603) (#282)

Co-authored-by: Dana Hoffman <danahoffman@google.com>
Signed-off-by: Modular Magician <magic-modules@google.com>

Co-authored-by: Dana Hoffman <danahoffman@google.com>

* Add Erase Windows VSS support to compute disk (#3898) (#283)

Co-authored-by: Cameron Thornton <camthornton@google.com>
Signed-off-by: Modular Magician <magic-modules@google.com>

Co-authored-by: Cameron Thornton <camthornton@google.com>

* Add Snapshot location to compute snapshot (#3896) (#286)

* added storage locations

* add storage locations to field

* tweak cmek logic

* fix the decoder logic and cleanup whitespaces

* remove duplicate entry

Signed-off-by: Modular Magician <magic-modules@google.com>

* Added missing 'all' option for protocol firewall rule (#3962) (#287)

Signed-off-by: Modular Magician <magic-modules@google.com>

* Added support GRPC for google_compute_(region)_backend_service.protocol (#3973) (#289)

Co-authored-by: Edward Sun <sunedward@google.com>
Signed-off-by: Modular Magician <magic-modules@google.com>

Co-authored-by: Edward Sun <sunedward@google.com>

* Add schema update support to spanner db 2082 (#3947) (#291)

* eoncders and customdiff added for spanner DB ddl update

* config update test case added

* customdiff modified to handle out-of-index issue

* new lines added

* indent fixed

* indent fixed for tests

* test added for ddl update condition

* mock added Terraformresourcediff, unit tests added

* test fixed

* more unit tests added

* tests fixed

* PR comments implemented

* unit tests converted to table driven tests

* ImportStateVerifyIgnore flag added to tests

* syntax corrected in test

Signed-off-by: Modular Magician <magic-modules@google.com>

* Added properties of options & artifacts on google_cloudbuild_trigger (#3944) (#292)

* added options & artifacts to cloudbuild trigger

* updated with minor changes and added more options in test

* a test adding update behavior for multiple optional fields

Co-authored-by: Edward Sun <sunedward@google.com>
Signed-off-by: Modular Magician <magic-modules@google.com>

Co-authored-by: Edward Sun <sunedward@google.com>

* Enable TPUs to use Shared VPC (#3939) (#293)

* add support for shared vpc

* make cidr_block computable

* add diffsuppression

* tweak diffsupression to ignore when network has a change

* rework diffsupress

* add customizediff

* switch the diff checks

Signed-off-by: Modular Magician <magic-modules@google.com>

* Add SEV_CAPABLE option to google_compute_image (#3994) (#294)

Signed-off-by: Modular Magician <magic-modules@google.com>

* Update docs for pubsub targets in cloud scheduler (#4008) (#295)

Signed-off-by: Modular Magician <magic-modules@google.com>

* Make RegionBackendService health checks optional (#4053) (#297)

Signed-off-by: Modular Magician <magic-modules@google.com>

* Update terminology for IAM roles (#4056) (#299)

Roles like "Owner" and "Editor" are now called "basic roles": https://cloud.google.com/iam/docs/understand

Signed-off-by: Modular Magician <magic-modules@google.com>

* Add source snapshot to ansible (#4060)

Signed-off-by: Modular Magician <magic-modules@google.com>

Co-authored-by: Tim O'Connell <hi@timoconnell.co.uk>
Co-authored-by: Scott Suarez <scottsuarez@google.com>
Co-authored-by: Dana Hoffman <danahoffman@google.com>
Co-authored-by: Cameron Thornton <camthornton@google.com>
Co-authored-by: Edward Sun <sunedward@google.com>
This commit is contained in:
The Magician 2020-10-06 15:39:08 -07:00 • committed by GitHub
commit 7fa00db18c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
169 changed files with 2105 additions and 764 deletions
Download patch file Download diff file Expand all files Collapse all files

121
plugins/modules/gcp_pubsub_subscription.py
View file

@ -34,7 +34,6 @@ description:
- A named resource representing the stream of messages from a single, specific topic,
to be delivered to the subscribing application.
short_description: Creates a GCP Subscription
version_added: '2.6'
author: Google Inc. (@googlecloudplatform)
requirements:
- python >= 2.6
@ -69,7 +68,6 @@ options:
- A set of key/value label pairs to assign to this Subscription.
required: false
type: dict
version_added: '2.8'
push_config:
description:
- If push delivery is used with this subscription, this field is used to configure
@ -84,7 +82,6 @@ options:
header in the HTTP request for every pushed message.
required: false
type: dict
version_added: '2.10'
suboptions:
service_account_email:
description:
@ -160,7 +157,6 @@ options:
required: false
default: 604800s
type: str
version_added: '2.8'
retain_acked_messages:
description:
- Indicates whether to retain acknowledged messages. If `true`, then messages
@ -168,7 +164,6 @@ options:
until they fall out of the messageRetentionDuration window.
required: false
type: bool
version_added: '2.8'
expiration_policy:
description:
- A policy that specifies the conditions for this subscription's expiration.
@ -179,7 +174,6 @@ options:
value for expirationPolicy.ttl is 1 day.
required: false
type: dict
version_added: '2.9'
suboptions:
ttl:
description:
@ -190,6 +184,14 @@ options:
- Example - "3.5s".
required: true
type: str
filter:
description:
- The subscription only delivers the messages that match the filter. Pub/Sub automatically
acknowledges the messages that don't match the filter. You can filter messages
by their attributes. The maximum length of a filter is 256 bytes. After creating
the subscription, you can't modify the filter.
required: false
type: str
dead_letter_policy:
description:
- A policy that specifies the conditions for dead lettering messages in this subscription.
@ -199,13 +201,12 @@ options:
must have permission to Acknowledge() messages on this subscription.
required: false
type: dict
version_added: '2.10'
suboptions:
dead_letter_topic:
description:
- The name of the topic to which dead letter messages should be published.
- Format is `projects/{project}/topics/{topic}`.
- The Cloud Pub/Sub service\naccount associated with the enclosing subscription's
- The Cloud Pub/Sub service account associated with the enclosing subscription's
parent project (i.e., service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com)
must have permission to Publish() to this topic.
- The operation will fail if the topic does not exist.
@ -226,6 +227,39 @@ options:
- If this parameter is 0, a default value of 5 is used.
required: false
type: int
retry_policy:
description:
- A policy that specifies how Pub/Sub retries message delivery for this subscription.
- If not set, the default retry policy is applied. This generally implies that
messages will be retried as soon as possible for healthy subscribers. RetryPolicy
will be triggered on NACKs or acknowledgement deadline exceeded events for a
given message .
required: false
type: dict
suboptions:
minimum_backoff:
description:
- The minimum delay between consecutive deliveries of a given message. Value
should be between 0 and 600 seconds. Defaults to 10 seconds.
- 'A duration in seconds with up to nine fractional digits, terminated by
''s''. Example: "3.5s".'
required: false
type: str
maximum_backoff:
description:
- 'The maximum delay between consecutive deliveries of a given message. Value
should be between 0 and 600 seconds. Defaults to 600 seconds. A duration
in seconds with up to nine fractional digits, terminated by ''s''. Example:
"3.5s".'
required: false
type: str
enable_message_ordering:
description:
- If `true`, messages published with the same orderingKey in PubsubMessage will
be delivered to the subscribers in the order in which they are received by the
Pub/Sub system. Otherwise, they may be delivered in any order.
required: false
type: bool
project:
description:
- The Google Cloud Platform project to use.
@ -257,6 +291,7 @@ options:
description:
- Array of scopes to be used
type: list
elements: str
env_type:
description:
- Specifies which Ansible environment you're running this module within.
@ -429,6 +464,14 @@ expirationPolicy:
- Example - "3.5s".
returned: success
type: str
filter:
description:
- The subscription only delivers the messages that match the filter. Pub/Sub automatically
acknowledges the messages that don't match the filter. You can filter messages
by their attributes. The maximum length of a filter is 256 bytes. After creating
the subscription, you can't modify the filter.
returned: success
type: str
deadLetterPolicy:
description:
- A policy that specifies the conditions for dead lettering messages in this subscription.
@ -443,7 +486,7 @@ deadLetterPolicy:
description:
- The name of the topic to which dead letter messages should be published.
- Format is `projects/{project}/topics/{topic}`.
- The Cloud Pub/Sub service\naccount associated with the enclosing subscription's
- The Cloud Pub/Sub service account associated with the enclosing subscription's
parent project (i.e., service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com)
must have permission to Publish() to this topic.
- The operation will fail if the topic does not exist.
@ -464,6 +507,38 @@ deadLetterPolicy:
- If this parameter is 0, a default value of 5 is used.
returned: success
type: int
retryPolicy:
description:
- A policy that specifies how Pub/Sub retries message delivery for this subscription.
- If not set, the default retry policy is applied. This generally implies that messages
will be retried as soon as possible for healthy subscribers. RetryPolicy will
be triggered on NACKs or acknowledgement deadline exceeded events for a given
message .
returned: success
type: complex
contains:
minimumBackoff:
description:
- The minimum delay between consecutive deliveries of a given message. Value
should be between 0 and 600 seconds. Defaults to 10 seconds.
- 'A duration in seconds with up to nine fractional digits, terminated by ''s''.
Example: "3.5s".'
returned: success
type: str
maximumBackoff:
description:
- 'The maximum delay between consecutive deliveries of a given message. Value
should be between 0 and 600 seconds. Defaults to 600 seconds. A duration in
seconds with up to nine fractional digits, terminated by ''s''. Example: "3.5s".'
returned: success
type: str
enableMessageOrdering:
description:
- If `true`, messages published with the same orderingKey in PubsubMessage will
be delivered to the subscribers in the order in which they are received by the
Pub/Sub system. Otherwise, they may be delivered in any order.
returned: success
type: bool
'''
################################################################################
@ -507,7 +582,10 @@ def main():
message_retention_duration=dict(default='604800s', type='str'),
retain_acked_messages=dict(type='bool'),
expiration_policy=dict(type='dict', options=dict(ttl=dict(required=True, type='str'))),
filter=dict(type='str'),
dead_letter_policy=dict(type='dict', options=dict(dead_letter_topic=dict(type='str'), max_delivery_attempts=dict(type='int'))),
retry_policy=dict(type='dict', options=dict(minimum_backoff=dict(type='str'), maximum_backoff=dict(type='str'))),
enable_message_ordering=dict(type='bool'),
)
)
@ -570,6 +648,10 @@ def updateMask(request, response):
update_mask.append('expirationPolicy')
if request.get('deadLetterPolicy') != response.get('deadLetterPolicy'):
update_mask.append('deadLetterPolicy')
if request.get('retryPolicy') != response.get('retryPolicy'):
update_mask.append('retryPolicy')
if request.get('enableMessageOrdering') != response.get('enableMessageOrdering'):
update_mask.append('enableMessageOrdering')
return ','.join(update_mask)
@ -588,7 +670,10 @@ def resource_to_request(module):
u'messageRetentionDuration': module.params.get('message_retention_duration'),
u'retainAckedMessages': module.params.get('retain_acked_messages'),
u'expirationPolicy': SubscriptionExpirationpolicy(module.params.get('expiration_policy', {}), module).to_request(),
u'filter': module.params.get('filter'),
u'deadLetterPolicy': SubscriptionDeadletterpolicy(module.params.get('dead_letter_policy', {}), module).to_request(),
u'retryPolicy': SubscriptionRetrypolicy(module.params.get('retry_policy', {}), module).to_request(),
u'enableMessageOrdering': module.params.get('enable_message_ordering'),
}
return_vals = {}
for k, v in request.items():
@ -662,7 +747,10 @@ def response_to_hash(module, response):
u'messageRetentionDuration': response.get(u'messageRetentionDuration'),
u'retainAckedMessages': response.get(u'retainAckedMessages'),
u'expirationPolicy': SubscriptionExpirationpolicy(response.get(u'expirationPolicy', {}), module).from_response(),
u'filter': module.params.get('filter'),
u'deadLetterPolicy': SubscriptionDeadletterpolicy(response.get(u'deadLetterPolicy', {}), module).from_response(),
u'retryPolicy': SubscriptionRetrypolicy(response.get(u'retryPolicy', {}), module).from_response(),
u'enableMessageOrdering': response.get(u'enableMessageOrdering'),
}
@ -770,5 +858,20 @@ class SubscriptionDeadletterpolicy(object):
)
class SubscriptionRetrypolicy(object):
def __init__(self, request, module):
self.module = module
if request:
self.request = request
else:
self.request = {}
def to_request(self):
return remove_nones_from_dict({u'minimumBackoff': self.request.get('minimum_backoff'), u'maximumBackoff': self.request.get('maximum_backoff')})
def from_response(self):
return remove_nones_from_dict({u'minimumBackoff': self.request.get(u'minimumBackoff'), u'maximumBackoff': self.request.get(u'maximumBackoff')})
if __name__ == '__main__':
main()