mirror

Documentation

Overview

Package mirror provides local mirroring and replica management

• Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.

Package mirror provides local mirroring and replica management

• Copyright (c) 2018-2023, NVIDIA CORPORATION. All rights reserved.

Package mirror provides local mirroring and replica management

• Copyright (c) 2018-2021, NVIDIA CORPORATION. All rights reserved.

Package mirror provides local mirroring and replica management

• Copyright (c) 2018-2023, NVIDIA CORPORATION. All rights reserved.

Package mirror provides local mirroring and replica management

• Copyright (c) 2018-2023, NVIDIA CORPORATION. All rights reserved.

Index

• Constants
• func Init()
• type XactPut
  • func (r *XactPut) Repl(lom *cluster.LOM)
  • func (r *XactPut) Run(*sync.WaitGroup)
  • func (r *XactPut) Snap() (snap *cluster.Snap)
• type XactTCB
  • 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 *cluster.Snap)
  • func (r *XactTCB) String() string
  • func (r *XactTCB) TxnAbort()
  • func (r *XactTCB) WaitRunning()

Constants

const OpcTxnDone = 27182

Functions

func Init

func Init()

Types

type XactPut

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

func (*XactPut) Repl

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

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

func (*XactPut) Run

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

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

func (*XactPut) Snap

func (r *XactPut) Snap() (snap *cluster.Snap)

type XactTCB

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

func (*XactTCB) Args

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

func (*XactTCB) FromTo

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

func (*XactTCB) Name

func (r *XactTCB) Name() string

func (*XactTCB) Run

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

func (*XactTCB) Snap

func (r *XactTCB) Snap() (snap *cluster.Snap)

func (*XactTCB) String

func (r *XactTCB) String() string

func (*XactTCB) TxnAbort

func (r *XactTCB) TxnAbort()

limited pre-run abort

func (*XactTCB) WaitRunning

func (r *XactTCB) WaitRunning()