@@ -392,6 +392,13 @@ protected CloudFunctionsServiceStubSettings(Builder settingsBuilder) throws IOEx
static {
ImmutableMap .Builder <String , ImmutableSet <StatusCode .Code >> definitions =
ImmutableMap .builder ();
definitions .put (
"retry_policy_0_codes" ,
ImmutableSet .copyOf (
Lists .<StatusCode .Code >newArrayList (
StatusCode .Code .UNAVAILABLE , StatusCode .Code .DEADLINE_EXCEEDED )));
definitions .put (
"no_retry_1_codes" , ImmutableSet .copyOf (Lists .<StatusCode .Code >newArrayList ()));
definitions .put ("no_retry_codes" , ImmutableSet .copyOf (Lists .<StatusCode .Code >newArrayList ()));
RETRYABLE_CODE_DEFINITIONS = definitions .build ();
}
@@ -401,6 +408,25 @@ protected CloudFunctionsServiceStubSettings(Builder settingsBuilder) throws IOEx
static {
ImmutableMap .Builder <String , RetrySettings > definitions = ImmutableMap .builder ();
RetrySettings settings = null ;
settings =
RetrySettings .newBuilder ()
.setInitialRetryDelay (Duration .ofMillis (100L ))
.setRetryDelayMultiplier (1.3 )
.setMaxRetryDelay (Duration .ofMillis (60000L ))
.setInitialRpcTimeout (Duration .ofMillis (600000L ))
.setRpcTimeoutMultiplier (1.0 )
.setMaxRpcTimeout (Duration .ofMillis (600000L ))
.setTotalTimeout (Duration .ofMillis (600000L ))
.build ();
definitions .put ("retry_policy_0_params" , settings );
settings =
RetrySettings .newBuilder ()
.setInitialRpcTimeout (Duration .ofMillis (600000L ))
.setRpcTimeoutMultiplier (1.0 )
.setMaxRpcTimeout (Duration .ofMillis (600000L ))
.setTotalTimeout (Duration .ofMillis (600000L ))
.build ();
definitions .put ("no_retry_1_params" , settings );
settings = RetrySettings .newBuilder ().setRpcTimeoutMultiplier (1.0 ).build ();
definitions .put ("no_retry_params" , settings );
RETRY_PARAM_DEFINITIONS = definitions .build ();
@@ -491,33 +517,33 @@ private static Builder createDefault() {
private static Builder initDefaults (Builder builder ) {
builder
.listFunctionsSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_0_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_0_params " ));
builder
.getFunctionSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_0_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_0_params " ));
builder
.createFunctionSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_1_params " ));
builder
.updateFunctionSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_0_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_0_params " ));
builder
.deleteFunctionSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_0_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_0_params " ));
builder
.callFunctionSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_1_params " ));
builder
.generateUploadUrlSettings ()
@@ -549,8 +575,8 @@ private static Builder initDefaults(Builder builder) {
.setInitialCallSettings (
UnaryCallSettings
.<CreateFunctionRequest , OperationSnapshot >newUnaryCallSettingsBuilder ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ))
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_1_params " ))
.build ())
.setResponseTransformer (
ProtoOperationTransformers .ResponseTransformer .create (CloudFunction .class ))
@@ -573,8 +599,8 @@ private static Builder initDefaults(Builder builder) {
.setInitialCallSettings (
UnaryCallSettings
.<UpdateFunctionRequest , OperationSnapshot >newUnaryCallSettingsBuilder ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ))
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_0_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_0_params " ))
.build ())
.setResponseTransformer (
ProtoOperationTransformers .ResponseTransformer .create (CloudFunction .class ))
@@ -597,8 +623,8 @@ private static Builder initDefaults(Builder builder) {
.setInitialCallSettings (
UnaryCallSettings
.<DeleteFunctionRequest , OperationSnapshot >newUnaryCallSettingsBuilder ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("no_retry_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("no_retry_params " ))
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_0_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_0_params " ))
.build ())
.setResponseTransformer (
ProtoOperationTransformers .ResponseTransformer .create (Empty .class ))