Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: add support for exactly once delivery #578

Merged
merged 3 commits into from
Feb 5, 2022
Merged

feat: add support for exactly once delivery #578

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
16e0e6e
feat: add exactly once delivery flag
gcf-owl-bot[bot] Feb 5, 2022
7b6d660
🦉 Updates from OwlBot
gcf-owl-bot[bot] Feb 5, 2022
3428cf6
Merge branch 'main' into owl-bot-30aacf93-2df3-47a1-8d1b-4b1a100d60ce
parthea Feb 5, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
52 changes: 52 additions & 0 deletions google/pubsub_v1/types/pubsub.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1123,24 +1123,76 @@ class StreamingPullResponse(proto.Message):
received_messages (Sequence[google.pubsub_v1.types.ReceivedMessage]):
Received Pub/Sub messages. This will not be
empty.
acknowlege_confirmation (google.pubsub_v1.types.StreamingPullResponse.AcknowledgeConfirmation):
This field will only be set if
``enable_exactly_once_delivery`` is set to ``true``.
modify_ack_deadline_confirmation (google.pubsub_v1.types.StreamingPullResponse.ModifyAckDeadlineConfirmation):
This field will only be set if
``enable_exactly_once_delivery`` is set to ``true``.
subscription_properties (google.pubsub_v1.types.StreamingPullResponse.SubscriptionProperties):
Properties associated with this subscription.
"""

class AcknowledgeConfirmation(proto.Message):
r"""Acknowledgement IDs sent in one or more previous requests to
acknowledge a previously received message.

Attributes:
ack_ids (Sequence[str]):
Successfully processed acknowledgement IDs.
invalid_ack_ids (Sequence[str]):
List of acknowledgement IDs that were
malformed or whose acknowledgement deadline has
expired.
unordered_ack_ids (Sequence[str]):
List of acknowledgement IDs that were out of
order.
"""

ack_ids = proto.RepeatedField(proto.STRING, number=1,)
invalid_ack_ids = proto.RepeatedField(proto.STRING, number=2,)
unordered_ack_ids = proto.RepeatedField(proto.STRING, number=3,)

class ModifyAckDeadlineConfirmation(proto.Message):
r"""Acknowledgement IDs sent in one or more previous requests to
modify the deadline for a specific message.

Attributes:
ack_ids (Sequence[str]):
Successfully processed acknowledgement IDs.
invalid_ack_ids (Sequence[str]):
List of acknowledgement IDs that were
malformed or whose acknowledgement deadline has
expired.
"""

ack_ids = proto.RepeatedField(proto.STRING, number=1,)
invalid_ack_ids = proto.RepeatedField(proto.STRING, number=2,)

class SubscriptionProperties(proto.Message):
r"""Subscription properties sent as part of the response.

Attributes:
exactly_once_delivery_enabled (bool):
True iff exactly once delivery is enabled for
this subscription.
message_ordering_enabled (bool):
True iff message ordering is enabled for this
subscription.
"""

exactly_once_delivery_enabled = proto.Field(proto.BOOL, number=1,)
message_ordering_enabled = proto.Field(proto.BOOL, number=2,)

received_messages = proto.RepeatedField(
proto.MESSAGE, number=1, message="ReceivedMessage",
)
acknowlege_confirmation = proto.Field(
proto.MESSAGE, number=2, message=AcknowledgeConfirmation,
)
modify_ack_deadline_confirmation = proto.Field(
proto.MESSAGE, number=3, message=ModifyAckDeadlineConfirmation,
)
subscription_properties = proto.Field(
proto.MESSAGE, number=4, message=SubscriptionProperties,
)
Expand Down