xs

package
v1.3.18 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 6, 2023 License: MIT Imports: 34 Imported by: 0

Documentation

Overview

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs is a collection of eXtended actions (xactions), including multi-object operations, list-objects, (cluster) rebalance and (target) resilver, ETL, and more.

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

Package xs contains most of the supported eXtended actions (xactions) with some exceptions that include certain storage services (mirror, EC) and extensions (downloader, lru).

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

Package xs contains most of the supported eXtended actions (xactions) with some exceptions that include certain storage services (mirror, EC) and extensions (downloader, lru).

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

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrGone = errors.New("gone")
)

Functions

func Xreg 

func Xreg()

for additional startup-time reg-s see lru, downloader, ec

Types

type Election 

type Election struct {
	xact.Base
}

func (*Election) Run 

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

func (*Election) Snap 

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

type LsoRsp 

type LsoRsp struct {
	Err    error
	Lst    *cmn.LsoResult
	Status int
}

`on-demand` per list-objects request

type LsoXact 

type LsoXact struct {
	// contains filtered or unexported fields
}

`on-demand` per list-objects request

func (*LsoXact) Abort 

func (r *LsoXact) Abort(err error) (ok bool)

skip on-demand idleness check

func (*LsoXact) Do 

func (r *LsoXact) Do(msg *apc.LsoMsg) *LsoRsp

func (*LsoXact) Run 

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

func (*LsoXact) Snap 

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

func (*LsoXact) String 

func (r *LsoXact) String() (s string)

func (*LsoXact) TxnAbort 

func (r *LsoXact) TxnAbort()

limited pre-run abort

type Rebalance 

type Rebalance struct {
	xact.Base
}

func NewRebalance 

func NewRebalance(id, kind string) (xreb *Rebalance)

func (*Rebalance) RebID 

func (xreb *Rebalance) RebID() int64

func (*Rebalance) Run 

func (*Rebalance) Run(*sync.WaitGroup)

func (*Rebalance) Snap 

func (xreb *Rebalance) Snap() (snap *cluster.Snap)

type Resilver 

type Resilver struct {
	xact.Base
}

func NewResilver 

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

func (*Resilver) Run 

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

func (*Resilver) Snap 

func (xres *Resilver) Snap() (snap *cluster.Snap)

func (*Resilver) String 

func (xres *Resilver) String() string

type TestBmvFactory 

type TestBmvFactory = bmvFactory

type TestXFactory 

type TestXFactory struct {
	// contains filtered or unexported fields

} // tests only

concrete list-range type xactions (see also: archive.go)

func (*TestXFactory) Get 

func (p *TestXFactory) Get() cluster.Xact

func (*TestXFactory) Kind 

func (*TestXFactory) Kind() string

func (*TestXFactory) New 

func (*TestXFactory) New(args xreg.Args, bck *meta.Bck) xreg.Renewable

func (*TestXFactory) Start 

func (p *TestXFactory) Start() error

func (*TestXFactory) WhenPrevIsRunning 

func (*TestXFactory) WhenPrevIsRunning(xreg.Renewable) (xreg.WPR, error)

type XactArch 

type XactArch struct {
	// contains filtered or unexported fields
}

func (*XactArch) Begin 

func (r *XactArch) Begin(msg *cmn.ArchiveBckMsg, archlom *cluster.LOM) (err error)

func (*XactArch) Do 

func (r *XactArch) Do(msg *cmn.ArchiveBckMsg)

func (*XactArch) FromTo 

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

func (*XactArch) Name 

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

func (*XactArch) Run 

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

func (*XactArch) Snap 

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

func (*XactArch) String 

func (r *XactArch) String() (s string)

func (*XactArch) TxnAbort 

func (r *XactArch) TxnAbort()

limited pre-run abort

type XactDirPromote 

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

func (*XactDirPromote) Run 

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

func (*XactDirPromote) SetFshare 

func (r *XactDirPromote) SetFshare(v bool)

func (*XactDirPromote) Snap 

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

type XactTCObjs 

type XactTCObjs struct {
	// contains filtered or unexported fields
}

func (*XactTCObjs) Begin 

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

func (*XactTCObjs) Do 

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

more work

func (*XactTCObjs) FromTo 

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

func (*XactTCObjs) Name 

func (r *XactTCObjs) Name() string

func (*XactTCObjs) Run 

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

func (*XactTCObjs) Snap 

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

func (*XactTCObjs) String 

func (r *XactTCObjs) String() string

func (*XactTCObjs) TxnAbort 

func (r *XactTCObjs) TxnAbort()

limited pre-run abort

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.