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 CmdStats struct + PendingCnt int64 + RecvCmdCnt int64 + SendCmdCnt int64 + type Command interface + Done func(*Object) error + type CommandWrapper func(*Object) error + func (cw CommandWrapper) Done(o *Object) error + type Cond struct + func NewCond(waitor int) *Cond + func (c *Cond) Broadcast() + func (c *Cond) Drain() + func (c *Cond) Signal() + func (c *Cond) Wait() + func (c *Cond) WaitForTick(ticker *time.Ticker) bool + func (c *Cond) WaitForTimeout(dura time.Duration) bool + type IStatsWatch interface + Stop func() + type IStatsWatchMgr interface + WatchStart func(name string, elementype int) IStatsWatch + var StatsWatchMgr IStatsWatchMgr + 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) GetChildById(id int) *Object + func (o *Object) GetPendingCommandCnt() int + func (o *Object) GetStats() map[string]CmdStats + func (o *Object) GetTreeName() string + 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) StatsSelf() (stats CmdStats) + func (o *Object) Terminate(s *Object) + type ObjectMonitor struct + func (om *ObjectMonitor) OnStart(o *Object) + func (om *ObjectMonitor) OnStop(o *Object) + func (om *ObjectMonitor) OnTick(o *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