retry

Documentation

Index

• type Chain
  • func NewChain() *Chain
  • func (c *Chain) Add(strategies ...orchestrator.RetryStrategy)
  • func (c *Chain) ShouldRetry(ctx context.Context, request orchestrator.RetryRequest) bool
• type FixedStrategy
  • func NewFixedStrategy(params FixedStrategyParams) *FixedStrategy
  • func (s *FixedStrategy) ShouldRetry(ctx context.Context, request orchestrator.RetryRequest) bool
• type FixedStrategyParams

Types

type Chain

type Chain struct {
	// contains filtered or unexported fields
}

func NewChain

func NewChain() *Chain

func (*Chain) Add

func (c *Chain) Add(strategies ...orchestrator.RetryStrategy)

func (*Chain) ShouldRetry

func (c *Chain) ShouldRetry(ctx context.Context, request orchestrator.RetryRequest) bool

type FixedStrategy

type FixedStrategy struct {
	// contains filtered or unexported fields
}

func NewFixedStrategy

func NewFixedStrategy(params FixedStrategyParams) *FixedStrategy

func (*FixedStrategy) ShouldRetry

func (s *FixedStrategy) ShouldRetry(ctx context.Context, request orchestrator.RetryRequest) bool

type FixedStrategyParams

type FixedStrategyParams struct {
	ShouldRetry bool
}