/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/ |
H A D | RetryPolicy.java | 35 public static class RetryAction { class 38 public static final RetryAction FAIL = 39 new RetryAction(RetryDecision.FAIL); 40 public static final RetryAction RETRY = 41 new RetryAction(RetryDecision.RETRY); 42 public static final RetryAction FAILOVER_AND_RETRY = 43 new RetryAction(RetryDecision.FAILOVER_AND_RETRY); 49 public RetryAction(RetryDecision action) { in RetryAction() method in RetryPolicy.RetryAction 53 public RetryAction(RetryDecision action, long delayTime) { in RetryAction() method in RetryPolicy.RetryAction 57 public RetryAction(RetryDecision action, long delayTime, String reason) { in RetryAction() method in RetryPolicy.RetryAction [all …]
|
H A D | RetryPolicies.java | 165 return RetryAction.FAIL; in shouldRetry() 173 return RetryAction.RETRY; in shouldRetry() 209 return RetryAction.FAIL; in shouldRetry() 211 return new RetryAction(RetryAction.RetryDecision.RETRY, in shouldRetry() 320 return RetryAction.FAIL; in shouldRetry() 326 return new RetryAction(RetryAction.RetryDecision.RETRY, sleepTime); in shouldRetry() 562 return new RetryAction(RetryAction.RetryDecision.FAIL, 0, in shouldRetry() 567 return new RetryAction(RetryAction.RetryDecision.FAIL, 0, "retries (" in shouldRetry() 577 return new RetryAction(RetryAction.RetryDecision.FAILOVER_AND_RETRY, in shouldRetry() 582 return new RetryAction(RetryAction.RetryDecision.RETRY, in shouldRetry() [all …]
|
H A D | RetryInvocationHandler.java | 33 import org.apache.hadoop.io.retry.RetryPolicy.RetryAction; 118 RetryAction action = policy.shouldRetry(e, retries++, in invoke() 120 if (action.action == RetryAction.RetryDecision.FAIL) { in invoke() 134 if (action.action == RetryAction.RetryDecision.FAILOVER_AND_RETRY && in invoke() 158 if (action.action == RetryAction.RetryDecision.FAILOVER_AND_RETRY) { in invoke()
|
/dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-batch/source/model/ |
H A D | RetryAction.cpp | 27 RetryAction GetRetryActionForName(const Aws::String& name) in GetRetryActionForName() 32 return RetryAction::RETRY; in GetRetryActionForName() 36 return RetryAction::EXIT; in GetRetryActionForName() 42 return static_cast<RetryAction>(hashCode); in GetRetryActionForName() 45 return RetryAction::NOT_SET; in GetRetryActionForName() 48 Aws::String GetNameForRetryAction(RetryAction enumValue) in GetNameForRetryAction() 52 case RetryAction::RETRY: in GetNameForRetryAction() 54 case RetryAction::EXIT: in GetNameForRetryAction()
|
H A D | EvaluateOnExit.cpp | 25 m_action(RetryAction::NOT_SET), in EvaluateOnExit() 34 m_action(RetryAction::NOT_SET), in EvaluateOnExit()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/retry/ |
H A D | TestDefaultRetryPolicy.java | 54 RetryPolicy.RetryAction action = policy.shouldRetry( in testWithRetriable() 57 is(RetryPolicy.RetryAction.RetryDecision.RETRY)); in testWithRetriable() 75 RetryPolicy.RetryAction action = policy.shouldRetry( in testWithWrappedRetriable() 79 is(RetryPolicy.RetryAction.RetryDecision.RETRY)); in testWithWrappedRetriable() 96 RetryPolicy.RetryAction action = policy.shouldRetry( in testWithRetriableAndRetryDisabled() 99 is(RetryPolicy.RetryAction.RetryDecision.FAIL)); in testWithRetriableAndRetryDisabled()
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/aws/aws-sdk-go-v2/service/batch/types/ |
H A D | enums.go | 321 type RetryAction string 325 RetryActionRetry RetryAction = "RETRY" 326 RetryActionExit RetryAction = "EXIT" 332 func (RetryAction) Values() []RetryAction { 333 return []RetryAction{
|
/dports/net-p2p/go-ethereum/aws-sdk-go-v2-be1c89938486/service/batch/types/ |
H A D | enums.go | 321 type RetryAction string type 325 RetryActionRetry RetryAction = "RETRY" 326 RetryActionExit RetryAction = "EXIT" 332 func (RetryAction) Values() []RetryAction { 333 return []RetryAction{
|
/dports/net-p2p/go-ethereum/aws-sdk-go-v2-credentials-v1.1.1/service/batch/types/ |
H A D | enums.go | 321 type RetryAction string type 325 RetryActionRetry RetryAction = "RETRY" 326 RetryActionExit RetryAction = "EXIT" 332 func (RetryAction) Values() []RetryAction { 333 return []RetryAction{
|
/dports/security/vault/aws-sdk-go-v2-fdbaadbce5fd/service/batch/types/ |
H A D | enums.go | 357 type RetryAction string type 361 RetryActionRetry RetryAction = "RETRY" 362 RetryActionExit RetryAction = "EXIT" 368 func (RetryAction) Values() []RetryAction { 369 return []RetryAction{
|
/dports/net-p2p/go-ethereum/aws-sdk-go-v2-a930583ec379/service/batch/types/ |
H A D | enums.go | 357 type RetryAction string type 361 RetryActionRetry RetryAction = "RETRY" 362 RetryActionExit RetryAction = "EXIT" 368 func (RetryAction) Values() []RetryAction { 369 return []RetryAction{
|
/dports/security/vault/vault-1.8.2/vendor/github.com/aws/aws-sdk-go-v2/service/batch/types/ |
H A D | enums.go | 357 type RetryAction string type 361 RetryActionRetry RetryAction = "RETRY" 362 RetryActionExit RetryAction = "EXIT" 368 func (RetryAction) Values() []RetryAction { 369 return []RetryAction{
|
/dports/security/vault/aws-sdk-go-v2-1.5.0/service/batch/types/ |
H A D | enums.go | 357 type RetryAction string type 361 RetryActionRetry RetryAction = "RETRY" 362 RetryActionExit RetryAction = "EXIT" 368 func (RetryAction) Values() []RetryAction { 369 return []RetryAction{
|
/dports/security/vault/aws-sdk-go-v2-credentials-v1.1.5/service/batch/types/ |
H A D | enums.go | 357 type RetryAction string type 361 RetryActionRetry RetryAction = "RETRY" 362 RetryActionExit RetryAction = "EXIT" 368 func (RetryAction) Values() []RetryAction { 369 return []RetryAction{
|
/dports/sysutils/vector/vector-0.10.0/src/sinks/util/ |
H A D | retries.rs | 11 pub enum RetryAction { enum 26 fn should_retry_response(&self, _response: &Self::Response) -> RetryAction { in should_retry_response() argument 28 RetryAction::Successful in should_retry_response() 104 RetryAction::Retry(reason) => { in retry() 109 RetryAction::DontRetry(reason) => { in retry() 114 RetryAction::Successful => None, in retry() 160 impl RetryAction { impl 162 if let RetryAction::Retry(_) = &self { in is_retryable() 170 if let RetryAction::DontRetry(_) = &self { in is_not_retryable() 178 if let RetryAction::Successful = &self { in is_successful()
|
H A D | retries2.rs | 13 pub enum RetryAction { enum 28 fn should_retry_response(&self, _response: &Self::Response) -> RetryAction { in should_retry_response() argument 30 RetryAction::Successful in should_retry_response() 105 RetryAction::Retry(reason) => { in retry() 110 RetryAction::DontRetry(reason) => { in retry() 115 RetryAction::Successful => None, in retry() 161 impl RetryAction { impl 163 if let RetryAction::Retry(_) = &self { in is_retryable() 171 if let RetryAction::DontRetry(_) = &self { in is_not_retryable() 179 if let RetryAction::Successful = &self { in is_successful()
|
H A D | http.rs | 2 retries2::{RetryAction, RetryLogic}, 357 fn should_retry_response(&self, response: &Self::Response) -> RetryAction { in should_retry_response() argument 361 StatusCode::TOO_MANY_REQUESTS => RetryAction::Retry("Too many requests".into()), in should_retry_response() 363 RetryAction::DontRetry("endpoint not implemented".into()) in should_retry_response() 365 _ if status.is_server_error() => RetryAction::Retry(format!( in should_retry_response() 370 _ if status.is_success() => RetryAction::Successful, in should_retry_response() 371 _ => RetryAction::DontRetry(format!("response status: {}", status)), in should_retry_response()
|
/dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-batch/include/aws/batch/model/ |
H A D | EvaluateOnExit.h | 267 inline const RetryAction& GetAction() const{ return m_action; } in GetAction() 281 inline void SetAction(const RetryAction& value) { m_actionHasBeenSet = true; m_action = value; } in SetAction() 288 …inline void SetAction(RetryAction&& value) { m_actionHasBeenSet = true; m_action = std::move(value… in SetAction() 295 inline EvaluateOnExit& WithAction(const RetryAction& value) { SetAction(value); return *this;} in WithAction() 302 …inline EvaluateOnExit& WithAction(RetryAction&& value) { SetAction(std::move(value)); return *this… in WithAction() 315 RetryAction m_action;
|
H A D | RetryAction.h | 16 enum class RetryAction enum 25 AWS_BATCH_API RetryAction GetRetryActionForName(const Aws::String& name); 27 AWS_BATCH_API Aws::String GetNameForRetryAction(RetryAction value);
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-couchbase/vendor/github.com/couchbase/gocb/v2/ |
H A D | retry.go | 121 type RetryAction interface { interface 146 RetryAfter(req RetryRequest, reason RetryReason) RetryAction 160 …yWrapper) RetryAfter(req gocbcore.RetryRequest, reason gocbcore.RetryReason) gocbcore.RetryAction { 165 return gocbcore.RetryAction(wrappedAction) 188 func (rs *BestEffortRetryStrategy) RetryAfter(req RetryRequest, reason RetryReason) RetryAction {
|
/dports/security/vault/vault-1.8.2/vendor/github.com/couchbase/gocb/v2/ |
H A D | retry.go | 121 type RetryAction interface { interface 146 RetryAfter(req RetryRequest, reason RetryReason) RetryAction 160 …yWrapper) RetryAfter(req gocbcore.RetryRequest, reason gocbcore.RetryReason) gocbcore.RetryAction { 165 return gocbcore.RetryAction(wrappedAction) 188 func (rs *BestEffortRetryStrategy) RetryAfter(req RetryRequest, reason RetryReason) RetryAction {
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/util/ |
H A D | RetriableCommand.java | 25 import org.apache.hadoop.io.retry.RetryPolicy.RetryAction; 93 RetryAction action = retryPolicy.shouldRetry(latestException, counter, 0, true); in execute() 94 if (action.action == RetryPolicy.RetryAction.RetryDecision.RETRY) { in execute()
|
/dports/sysutils/vector/vector-0.10.0/src/sinks/ |
H A D | elasticsearch.rs | 9 retries2::{RetryAction, RetryLogic}, 296 fn should_retry_response(&self, response: &Self::Response) -> RetryAction { in should_retry_response() argument 302 RetryAction::DontRetry("endpoint not implemented".into()) in should_retry_response() 304 _ if status.is_server_error() => RetryAction::Retry(format!( in should_retry_response() 316 RetryAction::DontRetry("client error".into()) in should_retry_response() 328 RetryAction::DontRetry( in should_retry_response() 347 RetryAction::DontRetry("some messages failed".into()) in should_retry_response() 350 None => RetryAction::Successful, in should_retry_response() 353 _ => RetryAction::DontRetry(format!("response status: {}", status)), in should_retry_response() 511 use crate::{sinks::util::retries2::RetryAction, Event}; [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-couchbase/vendor/github.com/couchbase/gocbcore/v9/ |
H A D | retry.go | 137 type RetryAction interface { interface 162 RetryAfter(req RetryRequest, reason RetryReason) RetryAction 210 func (rs *failFastRetryStrategy) RetryAfter(req RetryRequest, reason RetryReason) RetryAction { 234 func (rs *BestEffortRetryStrategy) RetryAfter(req RetryRequest, reason RetryReason) RetryAction {
|
/dports/security/vault/vault-1.8.2/vendor/github.com/couchbase/gocbcore/v9/ |
H A D | retry.go | 137 type RetryAction interface { interface 162 RetryAfter(req RetryRequest, reason RetryReason) RetryAction 210 func (rs *failFastRetryStrategy) RetryAfter(req RetryRequest, reason RetryReason) RetryAction { 234 func (rs *BestEffortRetryStrategy) RetryAfter(req RetryRequest, reason RetryReason) RetryAction {
|