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 + var ErrGone = errors.New("gone") + func Xreg() + type Election struct + func (*Election) Run(*sync.WaitGroup) + func (r *Election) Snap() (snap *cluster.Snap) + type LsoRsp struct + Err error + Lst *cmn.LsoResult + Status int + type LsoXact struct + func (r *LsoXact) Abort(err error) (ok bool) + func (r *LsoXact) Do(msg *apc.LsoMsg) *LsoRsp + func (r *LsoXact) Run(*sync.WaitGroup) + func (r *LsoXact) Snap() (snap *cluster.Snap) + func (r *LsoXact) String() (s string) + func (r *LsoXact) TxnAbort() + type Rebalance struct + func NewRebalance(id, kind string) (xreb *Rebalance) + func (*Rebalance) Run(*sync.WaitGroup) + func (xreb *Rebalance) RebID() int64 + func (xreb *Rebalance) Snap() (snap *cluster.Snap) + type Resilver struct + func NewResilver(id, kind string) (xres *Resilver) + func (*Resilver) Run(*sync.WaitGroup) + func (xres *Resilver) Snap() (snap *cluster.Snap) + func (xres *Resilver) String() string + type TestBmvFactory = bmvFactory + type TestXFactory struct + func (*TestXFactory) Kind() string + func (*TestXFactory) New(args xreg.Args, bck *meta.Bck) xreg.Renewable + func (*TestXFactory) WhenPrevIsRunning(xreg.Renewable) (xreg.WPR, error) + func (p *TestXFactory) Get() cluster.Xact + func (p *TestXFactory) Start() error + type XactArch struct + func (r *XactArch) Begin(msg *cmn.ArchiveBckMsg, archlom *cluster.LOM) (err error) + func (r *XactArch) Do(msg *cmn.ArchiveBckMsg) + func (r *XactArch) FromTo() (src, dst *meta.Bck) + func (r *XactArch) Name() (s string) + func (r *XactArch) Run(wg *sync.WaitGroup) + func (r *XactArch) Snap() (snap *cluster.Snap) + func (r *XactArch) String() (s string) + func (r *XactArch) TxnAbort() + type XactDirPromote struct + func (r *XactDirPromote) Run(wg *sync.WaitGroup) + func (r *XactDirPromote) SetFshare(v bool) + func (r *XactDirPromote) Snap() (snap *cluster.Snap) + type XactTCObjs struct + func (r *XactTCObjs) Begin(msg *cmn.TCObjsMsg) + func (r *XactTCObjs) Do(msg *cmn.TCObjsMsg) + func (r *XactTCObjs) FromTo() (*meta.Bck, *meta.Bck) + func (r *XactTCObjs) Name() string + func (r *XactTCObjs) Run(wg *sync.WaitGroup) + func (r *XactTCObjs) Snap() (snap *cluster.Snap) + func (r *XactTCObjs) String() string + func (r *XactTCObjs) TxnAbort()
Go to main page