runner

Documentation

Index

• Variables
• type Option
  • func WitDuration(duration time.Duration) Option
  • func WithMaxTimes(maxTimes int) Option
  • func WithTimeInterval(timeInterval int) Option
• type Options
• type Runner
  • func New(coordinator *coordinator.Coordinator, dao dao.TransactionDao, opts ...Option) *Runner
  • func (r *Runner) Run(ctx context.Context) (_ error)
  • func (r *Runner) Stop(ctx context.Context) error

Variables

var Default = &Options{
	duration:     time.Second * 2,
	timeInterval: time.Minute,
	MaxTimes:     3,
}

Types

type Option

type Option func(options *Options)

func WitDuration

func WitDuration(duration time.Duration) Option

func WithMaxTimes

func WithMaxTimes(maxTimes int) Option

func WithTimeInterval

func WithTimeInterval(timeInterval int) Option

type Options

type Options struct {
	MaxTimes int
	// contains filtered or unexported fields
}

type Runner

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

func New

func New(coordinator *coordinator.Coordinator, dao dao.TransactionDao, opts ...Option) *Runner

func (*Runner) Run

func (r *Runner) Run(ctx context.Context) (_ error)

func (*Runner) Stop

func (r *Runner) Stop(ctx context.Context) error