🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

Author: gcf-owl-bot[bot]

google/cloud/bigtable_v2/__init__.py

@@ -50,6 +50,7 @@
 from .types.data import ColumnMetadata
 from .types.data import ColumnRange
 from .types.data import Family
+from .types.data import Idempotency
 from .types.data import Mutation
 from .types.data import PartialResultSet
 from .types.data import ProtoFormat
@@ -93,6 +94,7 @@
     "FullReadStatsView",
     "GenerateInitialChangeStreamPartitionsRequest",
     "GenerateInitialChangeStreamPartitionsResponse",
+    "Idempotency",
     "MutateRowRequest",
     "MutateRowResponse",
     "MutateRowsRequest",

google/cloud/bigtable_v2/types/__init__.py

@@ -45,6 +45,7 @@
     ColumnMetadata,
     ColumnRange,
     Family,
+    Idempotency,
     Mutation,
     PartialResultSet,
     ProtoFormat,
@@ -110,6 +111,7 @@
     "ColumnMetadata",
     "ColumnRange",
     "Family",
+    "Idempotency",
     "Mutation",
     "PartialResultSet",
     "ProtoFormat",

google/cloud/bigtable_v2/types/bigtable.py

@@ -457,6 +457,10 @@ class MutateRowRequest(proto.Message):
             meaning that earlier mutations can be masked by
             later ones. Must contain at least one entry and
             at most 100000.
+        idempotency (google.cloud.bigtable_v2.types.Idempotency):
+            Optional parameter for ensuring a MutateRow
+            request is only applied once. Currently
+            applicable only for certain aggregate types.
     """
 
     table_name: str = proto.Field(
@@ -480,6 +484,11 @@ class MutateRowRequest(proto.Message):
         number=3,
         message=data.Mutation,
     )
+    idempotency: data.Idempotency = proto.Field(
+        proto.MESSAGE,
+        number=8,
+        message=data.Idempotency,
+    )
 
 
 class MutateRowResponse(proto.Message):

google/cloud/bigtable_v2/types/data.py

@@ -51,6 +51,7 @@
         "ProtoRows",
         "ProtoRowsBatch",
         "PartialResultSet",
+        "Idempotency",
     },
 )
 
@@ -1609,4 +1610,36 @@ class PartialResultSet(proto.Message):
     )
 
 
+class Idempotency(proto.Message):
+    r"""Parameters on mutations where clients want to ensure
+    idempotency (i.e. at-most-once semantics). This is currently
+    only needed for certain aggregate types.
+
+    Attributes:
+        token (bytes):
+            Unique token used to identify replays of this
+            mutation. Must be at least 8 bytes long.
+        start_time (google.protobuf.timestamp_pb2.Timestamp):
+            Client-assigned timestamp when the mutation's
+            first attempt was sent. Used to reject mutations
+            that arrive after idempotency protection may
+            have expired. May cause spurious rejections if
+            clock skew is too high.
+
+            Leave unset or zero to always accept the
+            mutation, at the risk of double counting if the
+            protection for previous attempts has expired.
+    """
+
+    token: bytes = proto.Field(
+        proto.BYTES,
+        number=1,
+    )
+    start_time: timestamp_pb2.Timestamp = proto.Field(
+        proto.MESSAGE,
+        number=2,
+        message=timestamp_pb2.Timestamp,
+    )
+
+
 __all__ = tuple(sorted(__protobuf__.manifest))