xs

package
v1.3.25 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2024 License: MIT Imports: 40 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-2024, 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) 2024, 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-2024, 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-2024, 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-2024, 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-2024, 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-2024, 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-2024, 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-2024, 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-2024, 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-2024, 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) 2024, 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-2024, 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-2024, 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-2024, 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-2024, 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-2024, 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-2024, NVIDIA CORPORATION. All rights reserved.

Index

Constants

View Source 
const OpcTxnDone = 27182
View Source 
const PrefixTcoID = "tco-"

Variables

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

Functions

func PrmObjName added in v1.3.22 

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

func RenewBlobDl added in v1.3.22 

func RenewBlobDl(xid string, params *core.BlobParams, oa *cmn.ObjAttrs) xreg.RenewRes

NOTE: to optimize-out additional HEAD request (below), the caller must pass `oa` attrs (just lom is not enough)

func Xreg 

func Xreg(xeleOnly bool)

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 added in v1.3.16 

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

type LsoRsp 

type LsoRsp struct {
	Err    error
	Lst    *cmn.LsoRes
	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(wg *sync.WaitGroup)

func (*LsoXact) Snap 

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

func (*LsoXact) String 

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

func (*LsoXact) TxnAbort 

func (r *LsoXact) TxnAbort(err error)

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 *core.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 *core.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() core.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() (err 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 *core.LOM) (err error)

func (*XactArch) Do 

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

func (*XactArch) FromTo added in v1.3.16 

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

func (*XactArch) Name added in v1.3.16 

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

func (*XactArch) Run 

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

func (*XactArch) Snap 

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

func (*XactArch) String 

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

func (*XactArch) TxnAbort 

func (r *XactArch) TxnAbort(err error)

limited pre-run abort

type XactBlobDl added in v1.3.22 

type XactBlobDl struct {
	xact.Base
	// contains filtered or unexported fields
}

func (*XactBlobDl) Name added in v1.3.22 

func (r *XactBlobDl) Name() string

func (*XactBlobDl) Run added in v1.3.22 

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

func (*XactBlobDl) Snap added in v1.3.22 

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

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 added in v1.3.16 

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

type XactNsumm added in v1.3.21 

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

func (*XactNsumm) Name added in v1.3.21 

func (r *XactNsumm) Name() string

func (*XactNsumm) Result added in v1.3.21 

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

func (*XactNsumm) Run added in v1.3.21 

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

func (*XactNsumm) Snap added in v1.3.21 

func (r *XactNsumm) Snap() (snap *core.Snap)

func (*XactNsumm) String added in v1.3.21 

func (r *XactNsumm) String() string

type XactTCB added in v1.3.22 

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

func (*XactTCB) Args added in v1.3.22 

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

func (*XactTCB) FromTo added in v1.3.22 

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

func (*XactTCB) Name added in v1.3.22 

func (r *XactTCB) Name() string

func (*XactTCB) Run added in v1.3.22 

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

func (*XactTCB) Snap added in v1.3.22 

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

func (*XactTCB) String added in v1.3.22 

func (r *XactTCB) String() string

func (*XactTCB) TxnAbort added in v1.3.22 

func (r *XactTCB) TxnAbort(err error)

limited pre-run abort

func (*XactTCB) WaitRunning added in v1.3.22 

func (r *XactTCB) WaitRunning()

type XactTCObjs 

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

func (*XactTCObjs) Begin 

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

func (*XactTCObjs) Do 

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

more work

func (*XactTCObjs) FromTo added in v1.3.16 

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

func (*XactTCObjs) Name added in v1.3.16 

func (r *XactTCObjs) Name() string

func (*XactTCObjs) Run 

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

func (*XactTCObjs) Snap 

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

func (*XactTCObjs) String 

func (r *XactTCObjs) String() string

func (*XactTCObjs) TxnAbort 

func (r *XactTCObjs) TxnAbort(err error)

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.