Versions in this module Expand all Collapse all v1 v1.3.19 Jun 6, 2023 v1.3.18 Jun 6, 2023 Changes in this version + func OnFinished(n cluster.Notif, err error) + func OnProgress(n cluster.Notif) + type Base struct + Dsts []string + F func(n cluster.Notif, err error) + Interval time.Duration + P func(n cluster.Notif) + When cluster.Upon + func (base *Base) LastNotifTime() int64 + func (base *Base) NotifyInterval() time.Duration + func (base *Base) OnFinishedCB() func(cluster.Notif, error) + func (base *Base) OnProgressCB() func(cluster.Notif) + func (base *Base) SetLastNotified(now int64) + func (base *Base) Subscribers() []string + func (base *Base) Upon(u cluster.Upon) bool + type Callback func(n Listener) + type Listener interface + Aborted func() bool + ActiveCount func() int + ActiveNotifiers func() meta.NodeMap + AddedTime func() int64 + Bcks func() []*cmn.Bck + Callback func(nl Listener, ts int64) + EndTime func() int64 + Err func() error + FinCount func() int + Finished func() bool + GetOwner func() string + HasFinished func(node *meta.Snode) bool + Kind func() string + LastUpdated func(si *meta.Snode) int64 + Lock func() + MarkFinished func(node *meta.Snode) + NodeStats func() *NodeStats + NodesTardy func(periodicNotifTime time.Duration) (nodes meta.NodeMap, tardy bool) + Notifiers func() meta.NodeMap + ProgressInterval func() time.Duration + QueryArgs func() cmn.HreqArgs + RLock func() + RUnlock func() + SetAborted func() + SetAddedTime func() + SetErr func(error) + SetOwner func(string) + SetStats func(daeID string, stats any) + Status func() *Status + String func() string + UUID func() string + Unlock func() + UnmarshalStats func(rawMsg []byte) (any, bool, bool, error) + type ListenerBase struct + AbortedX atomic.Bool + ActiveSrcs meta.NodeMap + Common struct{ ... } + EndTimeX atomic.Int64 + ErrValue cos.ErrValue + F Callback + Srcs meta.NodeMap + Stats *NodeStats + func NewNLB(uuid, action string, smap *meta.Smap, srcs meta.NodeMap, ...) *ListenerBase + func (nlb *ListenerBase) Aborted() bool + func (nlb *ListenerBase) ActiveCount() int + func (nlb *ListenerBase) ActiveNotifiers() meta.NodeMap + func (nlb *ListenerBase) AddedTime() int64 + func (nlb *ListenerBase) Bcks() []*cmn.Bck + func (nlb *ListenerBase) Callback(nl Listener, ts int64) + func (nlb *ListenerBase) EndTime() int64 + func (nlb *ListenerBase) Err() error + func (nlb *ListenerBase) FinCount() int + func (nlb *ListenerBase) Finished() bool + func (nlb *ListenerBase) GetOwner() string + func (nlb *ListenerBase) HasFinished(node *meta.Snode) bool + func (nlb *ListenerBase) Kind() string + func (nlb *ListenerBase) LastUpdated(si *meta.Snode) int64 + func (nlb *ListenerBase) Lock() + func (nlb *ListenerBase) MarkFinished(node *meta.Snode) + func (nlb *ListenerBase) NodeStats() *NodeStats + func (nlb *ListenerBase) NodesTardy(periodicNotifTime time.Duration) (nodes meta.NodeMap, tardy bool) + func (nlb *ListenerBase) Notifiers() meta.NodeMap + func (nlb *ListenerBase) ProgressInterval() time.Duration + func (nlb *ListenerBase) RLock() + func (nlb *ListenerBase) RUnlock() + func (nlb *ListenerBase) SetAborted() + func (nlb *ListenerBase) SetAddedTime() + func (nlb *ListenerBase) SetErr(err error) + func (nlb *ListenerBase) SetOwner(o string) + func (nlb *ListenerBase) SetStats(daeID string, stats any) + func (nlb *ListenerBase) Status() *Status + func (nlb *ListenerBase) String() string + func (nlb *ListenerBase) UUID() string + func (nlb *ListenerBase) Unlock() + type NodeStats struct + func NewNodeStats(sizes ...int) *NodeStats + func (ns *NodeStats) Len() (l int) + func (ns *NodeStats) Load(key string) (val any, ok bool) + func (ns *NodeStats) MarshalJSON() (data []byte, err error) + func (ns *NodeStats) Range(f func(string, any) bool) + func (ns *NodeStats) Store(key string, stats any) + func (ns *NodeStats) UnmarshalJSON(data []byte) (err error) + type Status struct + AbortedX bool + EndTimeX int64 + ErrMsg string + Kind string + UUID string + func (ns *Status) Aborted() bool + func (ns *Status) Finished() bool + func (ns *Status) String() (s string) + type StatusVec []Status + func (nsv StatusVec) String() (s string)
Go to main page