runner

Documentation

Index

• type Option
  • func WithBackoffJitter(backoffJitter suture.Jitter) Option
  • func WithDontPropagateTermination(dontPropagateTermination bool) Option
  • func WithEventHook(eventHook suture.EventHook) Option
  • func WithFailureBackoff(failureBackoff time.Duration) Option
  • func WithFailureDecay(failureDecay float64) Option
  • func WithFailureThreshold(failureThreshold float64) Option
  • func WithPassThroughPanics(passThroughPanics bool) Option
  • func WithTimeout(timeout time.Duration) Option
• type Runner
  • func New(name string, opts ...Option) *Runner
  • func (r *Runner) Run(ctx context.Context, services ...suture.Service) error

Types

type Option

type Option func(*suture.Spec)

func WithBackoffJitter

func WithBackoffJitter(backoffJitter suture.Jitter) Option

func WithDontPropagateTermination

func WithDontPropagateTermination(dontPropagateTermination bool) Option

func WithEventHook

func WithEventHook(eventHook suture.EventHook) Option

func WithFailureBackoff

func WithFailureBackoff(failureBackoff time.Duration) Option

func WithFailureDecay

func WithFailureDecay(failureDecay float64) Option

func WithFailureThreshold

func WithFailureThreshold(failureThreshold float64) Option

func WithPassThroughPanics

func WithPassThroughPanics(passThroughPanics bool) Option

func WithTimeout

func WithTimeout(timeout time.Duration) Option

type Runner

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

func New

func New(name string, opts ...Option) *Runner

func (*Runner) Run

func (r *Runner) Run(ctx context.Context, services ...suture.Service) error