Versions in this module Expand all Collapse all v1 v1.0.0 Apr 10, 2023 Changes in this version + const DefaultQueueBacklog + const OLS_INVALID_SLOT + const OLS_MAX_SLOT + const QueueType_Chan + const QueueType_List + func OlsAlloc() uint + func OlsFree(slot uint) + func OlsInstallSlotCleanHandler(slot uint, handler OlsSlotCleanHandler) + func SendOwn(p *Object, c *Object) bool + func SendTerm(o *Object) bool + func SendTermAck(p *Object) bool + func SendTermReq(p *Object, c *Object) bool + type Command interface + Done func(*Object) error + type CommandWrapper func(*Object) error + func (cw CommandWrapper) Done(o *Object) error + type Object struct + Id int + Name string + UserData interface{} + func NewObject(id int, name string, opt Options, sinker Sinker) *Object + func (o *Object) Active() + func (o *Object) IsTermiated() bool + func (o *Object) LaunchChild(c *Object) + func (o *Object) OlsClrValue() + func (o *Object) OlsGetValue(slot uint) interface{} + func (o *Object) OlsSetValue(slot uint, val interface{}) + func (o *Object) ProcessCommand() + func (o *Object) ProcessSeqnum() + func (o *Object) SendCommand(c Command, incseq bool) bool + func (o *Object) Terminate(s *Object) + type OlsSlotCleanHandler func(interface{}) + type Options struct + Interval time.Duration + MaxDone int + QueueBacklog int + type Sinker interface + OnStart func() + OnStop func() + OnTick func()
Go to main page