@@ -526,11 +526,16 @@ public ApiFuture<ListEndpointsPagedResponse> getFuturePagedResponse(
ImmutableMap .Builder <String , ImmutableSet <StatusCode .Code >> definitions =
ImmutableMap .builder ();
definitions .put (
"idempotent " ,
"retry_policy_1_codes " ,
ImmutableSet .copyOf (
Lists .<StatusCode .Code >newArrayList (
StatusCode .Code .DEADLINE_EXCEEDED , StatusCode .Code .UNAVAILABLE )));
definitions .put ("non_idempotent" , ImmutableSet .copyOf (Lists .<StatusCode .Code >newArrayList ()));
StatusCode .Code .UNAVAILABLE , StatusCode .Code .UNKNOWN )));
definitions .put ("no_retry_codes" , ImmutableSet .copyOf (Lists .<StatusCode .Code >newArrayList ()));
definitions .put (
"retry_policy_2_codes" ,
ImmutableSet .copyOf (
Lists .<StatusCode .Code >newArrayList (
StatusCode .Code .UNAVAILABLE , StatusCode .Code .UNKNOWN )));
RETRYABLE_CODE_DEFINITIONS = definitions .build ();
}
@@ -541,15 +546,28 @@ public ApiFuture<ListEndpointsPagedResponse> getFuturePagedResponse(
RetrySettings settings = null ;
settings =
RetrySettings .newBuilder ()
.setInitialRetryDelay (Duration .ofMillis (100L ))
.setInitialRetryDelay (Duration .ofMillis (1000L ))
.setRetryDelayMultiplier (1.3 )
.setMaxRetryDelay (Duration .ofMillis (60000L ))
.setInitialRpcTimeout (Duration .ofMillis (15000L ))
.setRpcTimeoutMultiplier (1.0 )
.setMaxRpcTimeout (Duration .ofMillis (15000L ))
.setTotalTimeout (Duration .ofMillis (15000L ))
.build ();
definitions .put ("retry_policy_1_params" , settings );
settings =
RetrySettings .newBuilder ()
.setInitialRetryDelay (Duration .ofMillis (1000L ))
.setRetryDelayMultiplier (1.3 )
.setMaxRetryDelay (Duration .ofMillis (60000L ))
.setInitialRpcTimeout (Duration .ofMillis (20000L ))
.setInitialRpcTimeout (Duration .ofMillis (15000L ))
.setRpcTimeoutMultiplier (1.0 )
.setMaxRpcTimeout (Duration .ofMillis (20000L ))
.setTotalTimeout (Duration .ofMillis (600000L ))
.setMaxRpcTimeout (Duration .ofMillis (15000L ))
.setTotalTimeout (Duration .ofMillis (15000L ))
.build ();
definitions .put ("default" , settings );
definitions .put ("retry_policy_2_params" , settings );
settings = RetrySettings .newBuilder ().setRpcTimeoutMultiplier (1.0 ).build ();
definitions .put ("no_retry_params" , settings );
RETRY_PARAM_DEFINITIONS = definitions .build ();
}
@@ -633,93 +651,93 @@ private static Builder initDefaults(Builder builder) {
builder
.createNamespaceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.listNamespacesSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.getNamespaceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.updateNamespaceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.deleteNamespaceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.createServiceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.listServicesSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.getServiceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.updateServiceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.deleteServiceSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.createEndpointSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.listEndpointsSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.getEndpointSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.updateEndpointSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.deleteEndpointSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.getIamPolicySettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.setIamPolicySettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
builder
.testIamPermissionsSettings ()
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("non_idempotent " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("default " ));
.setRetryableCodes (RETRYABLE_CODE_DEFINITIONS .get ("retry_policy_1_codes " ))
.setRetrySettings (RETRY_PARAM_DEFINITIONS .get ("retry_policy_1_params " ));
return builder ;
}