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 + const DefWaitTimeLong + const DefWaitTimeShort + const LeftID + const MaxPollTime + const MaxProbingFreq + const MinPollTime + const NumConsecutiveIdle + const RightID + const ScopeB + const ScopeG + const ScopeGB + const ScopeT + const UUIDSepa + var IncFinished func() + var Table = map[string]Descriptor + func CompareRebIDs(someID, fltID string) int + func GetKindName(kindOrName string) (kind, name string) + func GoRunW(xctn cluster.Xact) + func IdlesBeforeFinishing(kindOrName string) bool + func IsMountpath(kind string) bool + func IsSameScope(kindOrName string, scs ...int) bool + func IsValidKind(kind string) bool + func IsValidRebID(id string) (valid bool) + func IsValidUUID(id string) bool + func ListDisplayNames(onlyStartable bool) (names []string) + func RebID2S(id int64) string + func RefcntQuiCB(refc *atomic.Int32, maxTimeout, totalSoFar time.Duration) cluster.QuiRes + func S2RebID(id string) (int64, error) + type ArgsMsg struct + Bck cmn.Bck + Buckets []cmn.Bck + DaemonID string + Force bool + ID string + Kind string + OnlyRunning bool + Timeout time.Duration + func (args *ArgsMsg) String() (s string) + type Base struct + func (*Base) FromTo() (*meta.Bck, *meta.Bck) + func (*Base) Result() (any, error) + func (xctn *Base) Abort(err error) (ok bool) + func (xctn *Base) AbortErr() (err error) + func (xctn *Base) AbortedAfter(d time.Duration) (err error) + func (xctn *Base) AddNotif(n cluster.Notif) + func (xctn *Base) Bck() *meta.Bck + func (xctn *Base) Bytes() int64 + func (xctn *Base) ChanAbort() <-chan error + func (xctn *Base) EndTime() time.Time + func (xctn *Base) Finish(err error) + func (xctn *Base) Finished() bool + func (xctn *Base) ID() string + func (xctn *Base) InBytes() int64 + func (xctn *Base) InMaintOrDecomm(smap *meta.Smap, tsi *meta.Snode) (err error) + func (xctn *Base) InObjs() int64 + func (xctn *Base) InObjsAdd(cnt int, size int64) + func (xctn *Base) InitBase(id, kind string, bck *meta.Bck) + func (xctn *Base) IsAborted() bool + func (xctn *Base) IsIdle() bool + func (xctn *Base) Kind() string + func (xctn *Base) LomAdd(lom *cluster.LOM) + func (xctn *Base) Name() (s string) + func (xctn *Base) Objs() int64 + func (xctn *Base) ObjsAdd(cnt int, size int64) + func (xctn *Base) OutBytes() int64 + func (xctn *Base) OutObjs() int64 + func (xctn *Base) OutObjsAdd(cnt int, size int64) + func (xctn *Base) Quiesce(d time.Duration, cb cluster.QuiCB) cluster.QuiRes + func (xctn *Base) Running() (yes bool) + func (xctn *Base) StartTime() time.Time + func (xctn *Base) String() string + func (xctn *Base) ToSnap(snap *cluster.Snap) + func (xctn *Base) ToStats(stats *cluster.Stats) + type BckJog struct + func (r *BckJog) Init(id, kind string, bck *meta.Bck, opts *mpather.JgroupOpts) + func (r *BckJog) Run() + func (r *BckJog) Target() cluster.Target + func (r *BckJog) Wait() error + type Demand interface + DecPending func() + IdleTimer func() <-chan struct{} + IncPending func() + SubPending func(n int) + type DemandBase struct + func (r *DemandBase) Abort(err error) (ok bool) + func (r *DemandBase) DecPending() + func (r *DemandBase) IdleTimer() <-chan struct{} + func (r *DemandBase) IncPending() + func (r *DemandBase) Init(uuid, kind string, bck *meta.Bck, idle time.Duration) (xdb *DemandBase) + func (r *DemandBase) IsIdle() bool + func (r *DemandBase) Pending() (cnt int64) + func (r *DemandBase) Stop() + func (r *DemandBase) SubPending(n int) + type Descriptor struct + Access apc.AccessAttrs + DisplayName string + Idles bool + MassiveBck bool + Metasync bool + Mountpath bool + Owned bool + Rebalance bool + RefreshCap bool + Resilver bool + Scope int + Startable bool + func GetDescriptor(kindOrName string) (string, Descriptor, error) + type Marked struct + Interrupted bool + Restarted bool + Xact cluster.Xact + type MultiSnap map[string][]*cluster.Snap + func (xs MultiSnap) ByteCounts(xid string) (locBytes, outBytes, inBytes int64) + func (xs MultiSnap) GetUUIDs() []string + func (xs MultiSnap) IsAborted(xid string) (bool, error) + func (xs MultiSnap) IsIdle(xid string) (found, idle bool) + func (xs MultiSnap) ObjCounts(xid string) (locObjs, outObjs, inObjs int64) + func (xs MultiSnap) RunningTarget(xid string) (string, *cluster.Snap, error) + func (xs MultiSnap) TotalRunningTime(xid string) (time.Duration, error) + type NotifXact struct + Xact cluster.Xact + func (nx *NotifXact) ToNotifMsg() cluster.NotifMsg + type NotifXactListener struct + func NewXactNL(uuid, action string, smap *meta.Smap, srcs meta.NodeMap, bck ...*cmn.Bck) *NotifXactListener + func (*NotifXactListener) UnmarshalStats(rawMsg []byte) (stats any, finished, aborted bool, err error) + func (nxb *NotifXactListener) QueryArgs() cmn.HreqArgs + type QueryMsg struct + Bck cmn.Bck + Buckets []cmn.Bck + DaemonID string + ID string + Kind string + OnlyRunning *bool + func (msg *QueryMsg) String() (s string)
Go to main page