core

Documentation

Index

• type Agent
  • func NewAgent(params *param.Agent) *Agent
  • func (a *Agent) Add(schedule kernel.Schedule, schedules ...kernel.Schedule) error
  • func (a *Agent) Remove(schedule kernel.Schedule) error
  • func (a *Agent) Start(ctx context.Context, tasker kernel.Tasker, selector kernel.Selector) (err error)
  • func (a *Agent) Stop(ctx context.Context) error

Types

type Agent

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

func NewAgent

func NewAgent(params *param.Agent) *Agent

func (*Agent) Add

func (a *Agent) Add(schedule kernel.Schedule, schedules ...kernel.Schedule) error

func (*Agent) Remove

func (a *Agent) Remove(schedule kernel.Schedule) error

func (*Agent) Start

func (a *Agent) Start(ctx context.Context, tasker kernel.Tasker, selector kernel.Selector) (err error)

func (*Agent) Stop

func (a *Agent) Stop(ctx context.Context) error