proc

Documentation

Index

• Constants
• func New() *process
• func NewWithContext(wg *sync.WaitGroup, ctx context.Context, ctxCancel context.CancelFunc) *process
• type Worker
  • func NewWorker(name string, ctx context.Context, wg *sync.WaitGroup, fns ...func(w *Worker)) *Worker
  • func (w *Worker) DefaultEvent() *Worker
  • func (w *Worker) Off(e event) *Worker
  • func (w *Worker) On(e event, fn func(w *Worker, others ...interface{})) *Worker
  • func (w *Worker) Run()
  • func (w *Worker) RunInterval()
  • func (w *Worker) SetFunc(fn func(g *Worker)) *Worker
  • func (w *Worker) SetInterval(interval time.Duration)

Constants

const (
	Signal = "signal"
	Exit   = "exit"
	Error  = "error"
)

Functions

func New

func New() *process

func NewWithContext

func NewWithContext(wg *sync.WaitGroup, ctx context.Context, ctxCancel context.CancelFunc) *process

Types

type Worker

type Worker struct {
	Name     string
	StopCtx  context.Context
	WG       *sync.WaitGroup
	Fn       func(w *Worker)
	Interval time.Duration
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(name string, ctx context.Context, wg *sync.WaitGroup, fns ...func(w *Worker)) *Worker

func (*Worker) DefaultEvent

func (w *Worker) DefaultEvent() *Worker

func (*Worker) Off

func (w *Worker) Off(e event) *Worker

func (*Worker) On

func (w *Worker) On(e event, fn func(w *Worker, others ...interface{})) *Worker

-----------------------------------------------------------------------------

func (*Worker) Run

func (w *Worker) Run()

func (*Worker) RunInterval

func (w *Worker) RunInterval()

func (*Worker) SetFunc

func (w *Worker) SetFunc(fn func(g *Worker)) *Worker

func (*Worker) SetInterval

func (w *Worker) SetInterval(interval time.Duration)