Skip to content

Commit

Permalink
feat(pubsub): complete AckResult for exactly once (#6387)
Browse files Browse the repository at this point in the history
* refactor sendAck to pipe errors to AckResult map

* rewrite sendAck/sendModAck for exactly once

* add AckResult to list of uncompared methods

* use ackResultWithID in all locations
  • Loading branch information
hongalex authored Aug 1, 2022
1 parent aa6da2e commit c2de57c
Show file tree
Hide file tree
Showing 7 changed files with 294 additions and 204 deletions.
2 changes: 1 addition & 1 deletion pubsub/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ module cloud.google.com/go/pubsub
go 1.15

require (
cloud.google.com/go v0.102.1-0.20220615234935-19a5d218ec4d
cloud.google.com/go v0.102.1-0.20220708235547-f3d2cc2c987e
cloud.google.com/go/iam v0.3.0
cloud.google.com/go/kms v1.4.0
github.com/golang/protobuf v1.5.2
Expand Down
2 changes: 2 additions & 0 deletions pubsub/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,8 @@ cloud.google.com/go v0.100.1/go.mod h1:fs4QogzfH5n2pBXBP9vRiU+eCny7lD2vmFZy79Iuw
cloud.google.com/go v0.100.2/go.mod h1:4Xra9TjzAeYHrl5+oeLlzbM2k3mjVhZh4UqTZ//w99A=
cloud.google.com/go v0.102.1-0.20220615234935-19a5d218ec4d h1:29ZuPdUkhuJw9mwHi6zVYkJRHq956wJ5G9OQUbWl5Ew=
cloud.google.com/go v0.102.1-0.20220615234935-19a5d218ec4d/go.mod h1:mqs3bFXrt/gPc6aOZpchX8DEdQhuJluA/7LZNutd2Nc=
cloud.google.com/go v0.102.1-0.20220708235547-f3d2cc2c987e h1:GZ9rHNbN2TY+p6/dTeU0EADYrOc3BCqy/KwGPZHLsdA=
cloud.google.com/go v0.102.1-0.20220708235547-f3d2cc2c987e/go.mod h1:mqs3bFXrt/gPc6aOZpchX8DEdQhuJluA/7LZNutd2Nc=
cloud.google.com/go/bigquery v1.0.1/go.mod h1:i/xbL2UlR5RvWAURpBYZTtm/cXjCha9lbfbpx4poX+o=
cloud.google.com/go/bigquery v1.3.0/go.mod h1:PjpwJnslEMmckchkHFfq+HTD2DmtT67aNFKH1/VBDHE=
cloud.google.com/go/bigquery v1.4.0/go.mod h1:S8dzgnTigyfTmLBfrtrhyYhwRxG72rYxvftPBK2Dvzc=
Expand Down
Loading

0 comments on commit c2de57c

Please sign in to comment.