thread

Documentation

Index

• type Thread
  • func New(ctx context.Context, log logrus.FieldLogger, name string, ...) *Thread
  • func (t *Thread) LastRunStartedAt() time.Time
  • func (t *Thread) Name() string
  • func (t *Thread) Start()
  • func (t *Thread) Stop()

Types

type Thread

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

Thread provides a background, periodic thread, which invokes the given function every supplied interval.

Sample usage:

monitorFunc := func() {
    //do monitoring logic
}
monitor := thread.New(log, "Health Monitor", time.Minute*2, monitorFunc)
monitor.Start()
defer monitor.Stop()
....

func New

func New(ctx context.Context, log logrus.FieldLogger, name string, interval time.Duration, exec func(context.Context)) *Thread

func (*Thread) LastRunStartedAt

func (t *Thread) LastRunStartedAt() time.Time

func (*Thread) Name

func (t *Thread) Name() string

func (*Thread) Start

func (t *Thread) Start()

Start thread

func (*Thread) Stop

func (t *Thread) Stop()

Stop thread