xact

Jan 15, 2026

Changes in this version

type ArgsMsg

+ func (args *ArgsMsg) Finished() SnapsCond

+ func (args *ArgsMsg) Idle() SnapsCond

+ func (args *ArgsMsg) NotRunning() SnapsCond

+ func (args *ArgsMsg) Started() SnapsCond

type MultiSnap

+ func (xs MultiSnap) AggregateState(xid string) (aborted, running, notstarted bool)

+ func (xs MultiSnap) ToJSON(tid string, indent bool) ([]byte, error)

+ type SnapsCond func(MultiSnap) (done, reset bool, err error)

Dec 5, 2025

Changes in this version

type Base

+ func (xctn *Base) IsDone() bool

+ func (xctn *Base) IsRunning() (yes bool)

+ func (xctn *Base) NewSnap(self core.Xact) (snap *core.Snap)

+ func (xctn *Base) SetStopping()

type Descriptor

+ QuietBrief bool

Oct 7, 2025

Changes in this version

+ const FlagKeepMisplaced

+ const FlagLatestVer

+ const FlagSync

+ const FlagZeroSize

type Descriptor

+ LogLess bool

Jul 25, 2025

Changes in this version

+ const XrbLatestVer

+ const XrbSync

May 9, 2025

Changes in this version

+ func GetCtxVlabs(ctx context.Context) map[string]string

+ func NewCtxVlabs(vlabs map[string]string) context.Context

type BckJog

+ func (r *BckJog) NumJoggers() int

+ func (r *BckJog) NumVisits() int64

Feb 7, 2025

Changes in this version

+ const XrmZeroSize

+ func CheckValidKind(kind string) (err error)

+ func CheckValidUUID(id string) (err error)

+ func GetSimilar(kindOrName string) (simKind, simName string)

type ArgsMsg

+ Flags uint32

type Base

+ func (xctn *Base) SetCtlMsg(s string)

Feb 25, 2024

Changes in this version

+ const SepaID

+ func Cname(kind, uuid string) string

+ func ParseCname(cname string) (xactKind, xactID string, _ error)

type Base

+ func (xctn *Base) Cname() string

type DemandBase

+ func (r *DemandBase) Reset(idleTime time.Duration)

Nov 5, 2023

Changes in this version

type Descriptor

+ AbortRebRes bool

+ ConflictRebRes bool

type NotifXactListener

+ func (nxb *NotifXactListener) WithCause(cause string) *NotifXactListener

Aug 29, 2023

Changes in this version

+ const IdleDefault

type Descriptor

+ ExtendedStats bool

Jul 9, 2023

Changes in this version

type Base

+ func (xctn *Base) AddErr(err error)

+ func (xctn *Base) Err() error

+ func (xctn *Base) ErrCnt() int

+ func (xctn *Base) InMaintOrDecomm(smap *meta.Smap, tsi *meta.Snode) (err error)

+ func (xctn *Base) JoinErr() (int, error)

type BckJog

+ Config *cmn.Config

+ T cluster.Target

type Marked

+ Restarted bool

Mar 31, 2023

Changes in this version

+ const DefWaitTimeLong

+ const DefWaitTimeShort

+ const LeftID

+ const MaxPollTime

+ const MaxProbingFreq

+ const MinPollTime

+ const NumConsecutiveIdle

+ const RightID

+ const ScopeB

+ const ScopeGB

+ const UUIDSepa

+ func GetKindName(kindOrName string) (kind, name string)

+ func IdlesBeforeFinishing(kindOrName string) bool

+ func IsSameScope(kindOrName string, scs ...int) bool

+ func IsValidUUID(id string) bool

+ func ListDisplayNames(onlyStartable bool) (names []string)

+ 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

+ func (xctn *Base) IsIdle() bool

+ func (xctn *Base) LomAdd(lom *cluster.LOM)

type DemandBase

+ func (r *DemandBase) IsIdle() bool

type Descriptor

+ DisplayName string

+ Idles bool

+ func GetDescriptor(kindOrName string) (string, Descriptor, error)

+ 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)

Nov 7, 2022

Changes in this version

+ const ScopeBck

+ const ScopeG

+ const ScopeO

+ const ScopeT

+ var IncFinished func()

+ var Table = map[string]Descriptor

+ func CompareRebIDs(someID, fltID string) int

+ func GoRunW(xctn cluster.Xact)

+ func IsBckScope(kind string) bool

+ func IsMountpath(kind string) bool

+ func IsValidKind(kind string) bool

+ func IsValidRebID(id string) bool

+ func RebID2S(id int64) string

+ func RefcntQuiCB(refc *atomic.Int32, maxTimeout, totalSoFar time.Duration) cluster.QuiRes

+ func S2RebID(id string) (int64, error)

+ type Base struct

+ func (*Base) FromTo() (*cluster.Bck, *cluster.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() *cluster.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) GetStats() (stats *Stats)

+ func (xctn *Base) ID() string

+ func (xctn *Base) InBytes() int64

+ func (xctn *Base) InObjs() int64

+ func (xctn *Base) InObjsAdd(cnt int, size int64)

+ func (xctn *Base) InitBase(id, kind string, bck *cluster.Bck)

+ func (xctn *Base) IsAborted() bool

+ func (xctn *Base) Kind() string

+ func (xctn *Base) Name() (s string)

+ func (xctn *Base) Notif() (n cluster.Notif)

+ 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) Snap() cluster.XactSnap

+ func (xctn *Base) StartTime() time.Time

+ func (xctn *Base) String() string

+ func (xctn *Base) ToSnap(snap *Snap)

+ func (xctn *Base) ToStats(stats *Stats)

+ type BaseDemandStatsExt struct

+ IsIdle bool

+ type BckJog struct

+ func (r *BckJog) Init(id, kind string, bck *cluster.Bck, opts *mpather.JoggerGroupOpts)

+ 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) ExtSnap() *SnapExt

+ func (r *DemandBase) IdleTimer() <-chan struct{}

+ func (r *DemandBase) IncPending()

+ func (r *DemandBase) Init(uuid, kind string, bck *cluster.Bck, idle time.Duration) (xdb *DemandBase)

+ func (r *DemandBase) Pending() (cnt int64)

+ func (r *DemandBase) Snap() cluster.XactSnap

+ func (r *DemandBase) Stop()

+ func (r *DemandBase) SubPending(n int)

+ type Descriptor struct

+ Access apc.AccessAttrs

+ MassiveBck bool

+ Metasync bool

+ Mountpath bool

+ Owned bool

+ Rebalance bool

+ RefreshCap bool

+ Resilver bool

+ Scope string

+ Startable bool

+ type Marked struct

+ Interrupted bool

+ Xact cluster.Xact

+ type NotifXact struct

+ Xact cluster.Xact

+ func (nx *NotifXact) ToNotifMsg() cluster.NotifMsg

+ type NotifXactListener struct

+ func NewXactNL(uuid, action string, smap *cluster.Smap, srcs cluster.NodeMap, bck ...*cmn.Bck) *NotifXactListener

+ func (*NotifXactListener) UnmarshalStats(rawMsg []byte) (stats any, finished, aborted bool, err error)

+ func (nxb *NotifXactListener) AbortArgs() cmn.HreqArgs

+ func (nxb *NotifXactListener) QueryArgs() cmn.HreqArgs

+ type QueryMsg struct

+ Bck cmn.Bck

+ Buckets []cmn.Bck

+ DaemonID string

+ Ext any

+ ID string

+ Kind string

+ OnlyRunning *bool

+ func (msg *QueryMsg) String() (s string)

+ type QueryMsgLRU struct

+ Force bool

+ type Snap struct

+ AbortedX bool

+ Bck cmn.Bck

+ EndTime time.Time

+ ID string

+ Kind string

+ StartTime time.Time

+ Stats Stats

+ func (b *Snap) Finished() bool

+ func (b *Snap) IsAborted() bool

+ func (b *Snap) Running() bool

+ type SnapExt struct

+ Ext any

+ func (b *SnapExt) Idle() bool

+ type Stats struct

+ Bytes int64

+ InBytes int64

+ InObjs int64

+ Objs int64

+ OutBytes int64

+ OutObjs int64