mirror

package

v1.3.13 Latest Latest Go to latest Published: Nov 9, 2022 License: MIT Imports: 20 Imported by: 1

Details

Package mirror provides local mirroring and replica management

Package mirror provides local mirroring and replica management

Package mirror provides local mirroring and replica management

Package mirror provides local mirroring and replica management

Package mirror provides local mirroring and replica management

View Source

const OpcTxnDone = 27182

This section is empty.

func Init()

type XactPut struct {
	// implements cluster.Xact interface
	xact.DemandBase
	// contains filtered or unexported fields
}

func (r *XactPut) Repl(lom *cluster.LOM)

main method: replicate onto a given (and different) mountpath

func (r *XactPut) Run(*sync.WaitGroup)

control logic: stop and idle timer (LOMs get dispatched directly to workers)

func (r *XactPut) Stats() cluster.XactSnap

type XactTCB struct {
	xact.BckJog
	// contains filtered or unexported fields
}

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

func (r *XactTCB) FromTo() (*cluster.Bck, *cluster.Bck)

func (r *XactTCB) Name() string

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

func (r *XactTCB) String() string

func (r *XactTCB) TxnAbort()

limited pre-run abort

func (r *XactTCB) WaitRunning()