Home
last modified time | relevance | path

Searched refs:RetryAction (Results 1 – 25 of 60) sorted by relevance

123

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/
H A DRetryPolicy.java35 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 DRetryPolicies.java165 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 DRetryInvocationHandler.java33 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 DRetryAction.cpp27 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 DEvaluateOnExit.cpp25 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 DTestDefaultRetryPolicy.java54 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 Denums.go321 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 Denums.go321 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 Denums.go321 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 Denums.go357 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 Denums.go357 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 Denums.go357 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 Denums.go357 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 Denums.go357 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 Dretries.rs11 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 Dretries2.rs13 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 Dhttp.rs2 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 DEvaluateOnExit.h267 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 DRetryAction.h16 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 Dretry.go121 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 Dretry.go121 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 DRetriableCommand.java25 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 Delasticsearch.rs9 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 Dretry.go137 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 Dretry.go137 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 {

123