xs

package
v1.3.13 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2022 License: MIT Imports: 37 Imported by: 0

Documentation

Overview

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) 2021-2022, 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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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, 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.

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) 2021-2022, 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) 2021-2022, 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, 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)

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

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

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

TODO: check "resilver-marked" and unify with rebalance

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 *cluster.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.ArchiveMsg) (err error)

func (*XactArch) Do 

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

func (*XactArch) Run 

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

func (*XactArch) Snap 

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

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)

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)

func (*XactTCObjs) Run 

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

func (*XactTCObjs) Snap 

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

func (*XactTCObjs) String 

func (r *XactTCObjs) String() (s 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.