xs

Feb 25, 2024

Changes in this version

+ const OpcTxnDone

+ const PrefixTcoID

+ func PrmObjName(objfqn, dirfqn, prefix string) (_ string, err error)

+ func RenewBlobDl(xid string, lom *core.LOM, oa *cmn.ObjAttrs, wfqn string, lmfh *os.File, ...) xreg.RenewRes

+ type XactBlobDl struct

+ func (r *XactBlobDl) Name() string

+ func (r *XactBlobDl) Run(*sync.WaitGroup)

+ func (r *XactBlobDl) Snap() (snap *core.Snap)

+ type XactTCB struct

+ func (r *XactTCB) Args() *xreg.TCBArgs

+ func (r *XactTCB) FromTo() (*meta.Bck, *meta.Bck)

+ func (r *XactTCB) Name() string

+ func (r *XactTCB) Run(wg *sync.WaitGroup)

+ func (r *XactTCB) Snap() (snap *core.Snap)

+ func (r *XactTCB) String() string

+ func (r *XactTCB) TxnAbort(err error)

+ func (r *XactTCB) WaitRunning()

Nov 5, 2023

Changes in this version

+ type XactNsumm struct

+ func (r *XactNsumm) Name() string

+ func (r *XactNsumm) Result() (cmn.AllBsummResults, error)

+ func (r *XactNsumm) Run(started *sync.WaitGroup)

+ func (r *XactNsumm) Snap() (snap *cluster.Snap)

+ func (r *XactNsumm) String() string

Mar 31, 2023

Changes in this version

type Election

+ func (r *Election) Snap() (snap *cluster.Snap)

type XactArch

+ func (r *XactArch) FromTo() (src, dst *cluster.Bck)

+ func (r *XactArch) Name() (s string)

type XactDirPromote

+ func (r *XactDirPromote) Snap() (snap *cluster.Snap)

type XactTCObjs

+ func (r *XactTCObjs) FromTo() (*cluster.Bck, *cluster.Bck)

+ func (r *XactTCObjs) Name() string

Nov 7, 2022

Changes in this version

+ var ErrGone = errors.New("gone")

+ func Xreg()

+ type Election struct

+ func (*Election) Run(*sync.WaitGroup)

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

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

+ type Resilver struct

+ func NewResilver(id, kind string) (xres *Resilver)

+ func (*Resilver) Run(*sync.WaitGroup)

+ func (xres *Resilver) Snap() cluster.XactSnap

+ func (xres *Resilver) String() string

+ type TestBmvFactory = bmvFactory

+ type TestXFactory struct

+ func (*TestXFactory) Kind() string

+ func (*TestXFactory) New(args xreg.Args, bck *cluster.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.ArchiveMsg) (err error)

+ func (r *XactArch) Do(msg *cmn.ArchiveMsg)

+ func (r *XactArch) Run(wg *sync.WaitGroup)

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

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

+ type XactTCObjs struct

+ func (r *XactTCObjs) Begin(msg *cmn.TCObjsMsg)

+ func (r *XactTCObjs) Do(msg *cmn.TCObjsMsg)

+ func (r *XactTCObjs) Run(wg *sync.WaitGroup)

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

+ func (r *XactTCObjs) String() (s string)

+ func (r *XactTCObjs) TxnAbort()