retry

Documentation

Index

• type DefaultEligibilityStrategy
  • func (s DefaultEligibilityStrategy) IsEligibleForRetry(props StrategyProps) bool
• type EligibilityStrategy
• type Strategy
  • func NewFixedCountRetryStrategy(logFactory logger.MomentoLoggerFactory) Strategy
  • func NewNeverRetryStrategy() Strategy
• type StrategyProps

Types

type DefaultEligibilityStrategy

type DefaultEligibilityStrategy struct{}

func (DefaultEligibilityStrategy) IsEligibleForRetry

func (s DefaultEligibilityStrategy) IsEligibleForRetry(props StrategyProps) bool

type EligibilityStrategy

type EligibilityStrategy interface {
	// IsEligibleForRetry Determines whether a grpc call is able to be retried. The determination is based on the result
	// of the last invocation of the call and whether the call is idempotent.
	IsEligibleForRetry(props StrategyProps) bool
}

type Strategy

type Strategy interface {
	// DetermineWhenToRetry Determines whether a grpc call can be retried and how long to wait before that retry.
	//
	// RetryableProps - Information about the grpc call, its last invocation, and how many times the call
	//            has been made.
	//
	// Returns The time in seconds before the next retry should occur or nil if no retry should be attempted.
	DetermineWhenToRetry(props StrategyProps) *int
}

func NewFixedCountRetryStrategy

func NewFixedCountRetryStrategy(logFactory logger.MomentoLoggerFactory) Strategy

func NewNeverRetryStrategy

func NewNeverRetryStrategy() Strategy

NewNeverRetryStrategy is a retry strategy that never retries any request

type StrategyProps

type StrategyProps struct {
	GrpcStatusCode codes.Code
	GrpcMethod     string
	AttemptNumber  int
}