pubsub: regenerate apiv1
This includes the generated formalization of
@@ -73,6 +73,18 @@ func defaultSubscriberCallOptions() *SubscriberCallOptions {
})
}),
},
+ {"messaging", "idempotent"}: {
+ gax.WithRetry(func() gax.Retryer {
+ return gax.OnCodes([]codes.Code{
+ codes.DeadlineExceeded,
+ codes.Unavailable,
+ }, gax.Backoff{
+ Initial: 100 * time.Millisecond,
+ Max: 60000 * time.Millisecond,
+ Multiplier: 1.3,
+ })
+ }),
+ },
{"messaging", "pull"}: {
gax.WithRetry(func() gax.Retryer {
return gax.OnCodes([]codes.Code{
@@ -109,7 +121,7 @@ func defaultSubscriberCallOptions() *SubscriberCallOptions {
ListSubscriptions: retry[[2]string{"default", "idempotent"}],
DeleteSubscription: retry[[2]string{"default", "idempotent"}],
ModifyAckDeadline: retry[[2]string{"default", "non_idempotent"}],
- Acknowledge: retry[[2]string{"default", "idempotent"}],
+ Acknowledge: retry[[2]string{"messaging", "idempotent"}],
Pull: retry[[2]string{"messaging", "pull"}],
StreamingPull: retry[[2]string{"streaming_messaging", "pull"}],
ModifyPushConfig: retry[[2]string{"default", "non_idempotent"}],
