Versions in this module Expand all Collapse all v1 v1.0.4 Jul 25, 2025 v1.0.3 Jul 11, 2025 v1.0.2 Jul 1, 2025 v1.0.1 Jul 1, 2025 v1.0.0 Jun 26, 2025 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