core

Oct 30, 2024

Changes in this version

type Agent

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

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

Oct 28, 2024

Changes in this version

+ type Agent struct

+ func NewAgent(params *param.Agent) *Agent

+ func (a *Agent) Add(scheduling core2.Scheduling) error

+ func (a *Agent) Process(tasking core2.Tasking, processor core2.Processor) (err error)

+ func (a *Agent) Remove(scheduling core2.Scheduling) error

+ type Tasker = kernel.Tasker

Sep 27, 2024

Changes in this version

type Scheduling

+ Type func() Type

+ type Type uint16

Aug 17, 2024

Changes in this version

+ type Executor interface

+ Error func() error

+ Execute func() error

+ Next func() time.Time

+ Recyclable func() bool

Aug 16, 2024

Changes in this version

+ type Tasking interface

+ Times func() int

Aug 16, 2024

Changes in this version

+ type Scheduling struct

+ func NewScheduling(params *param.Scheduling) *Scheduling

+ func (s *Scheduling) Data() any

+ func (s *Scheduling) Id() uint64

+ func (s *Scheduling) Target() uint64