task

Documentation

Index

• type ConstantRetryIntervalTask
  • func WithConstantRetries(maxRetries uint, waitInterval time.Duration, ...) *ConstantRetryIntervalTask
  • func (s *ConstantRetryIntervalTask) Do(ctx context.Context, _ uint) error
  • func (s *ConstantRetryIntervalTask) Interval(_ uint) time.Duration
  • func (s *ConstantRetryIntervalTask) MaxRetries() uint

Types

type ConstantRetryIntervalTask

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

func WithConstantRetries

func WithConstantRetries(maxRetries uint, waitInterval time.Duration, payload func(ctx context.Context) error) *ConstantRetryIntervalTask

func (*ConstantRetryIntervalTask) Do

func (s *ConstantRetryIntervalTask) Do(ctx context.Context, _ uint) error

func (*ConstantRetryIntervalTask) Interval

func (s *ConstantRetryIntervalTask) Interval(_ uint) time.Duration

func (*ConstantRetryIntervalTask) MaxRetries

func (s *ConstantRetryIntervalTask) MaxRetries() uint