workutils

package

v0.0.0-...-303e327 Latest Latest Go to latest Published: May 22, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cubefs/cubefs

Documentation ¶

Index ¶

func GetEncoder(mode codemode.CodeMode) (ec.Encoder, error)
func IdxSplitByLocalStripe(idxs []uint8, mode codemode.CodeMode) [][]uint8
type BidExistStatus
- func NewBidExistStatus(mode codemode.CodeMode) BidExistStatus
type BufConfig
type BufPool
- func NewBufPool(cfg *BufConfig) *BufPool
type DroppedBidRecorder
- func DroppedBidRecorderInst() *DroppedBidRecorder
type EncoderPool

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetEncoder ¶

func GetEncoder(mode codemode.CodeMode) (ec.Encoder, error)

func IdxSplitByLocalStripe ¶

func IdxSplitByLocalStripe(idxs []uint8, mode codemode.CodeMode) [][]uint8

IdxSplitByLocalStripe returns local stripe idx

Types ¶

type BidExistStatus ¶

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

BidExistStatus blob id exist status

func NewBidExistStatus ¶

func NewBidExistStatus(mode codemode.CodeMode) BidExistStatus

NewBidExistStatus returns bid exist status

func (*BidExistStatus) CanRecover ¶

func (s *BidExistStatus) CanRecover() bool

CanRecover returns if data can be recover

func (*BidExistStatus) Exist ¶

func (s *BidExistStatus) Exist(vuidIdx uint8)

Exist returns true if vuid is exist

func (*BidExistStatus) ExistCnt ¶

func (s *BidExistStatus) ExistCnt() int

ExistCnt returns exist count

type BufConfig ¶

type BufConfig struct {
	MigrateBufSize     int `json:"migrate_buf_size"`
	MigrateBufCapacity int `json:"migrate_buf_capacity"`
	RepairBufSize      int `json:"repair_buf_size"`
	RepairBufCapacity  int `json:"repair_buf_capacity"`
}

type BufPool ¶

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

var TaskBufPool *BufPool

func NewBufPool ¶

func NewBufPool(cfg *BufConfig) *BufPool

func (*BufPool) GetMigrateBuf ¶

func (b *BufPool) GetMigrateBuf() ([]byte, error)

func (*BufPool) GetMigrateBufSize ¶

func (b *BufPool) GetMigrateBufSize() int

func (*BufPool) GetRepairBuf ¶

func (b *BufPool) GetRepairBuf() ([]byte, error)

func (*BufPool) Put ¶

func (b *BufPool) Put(buf []byte) error

type DroppedBidRecorder ¶

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

DroppedBidRecorder dropped bid recorder

func DroppedBidRecorderInst ¶

func DroppedBidRecorderInst() *DroppedBidRecorder

DroppedBidRecorderInst make sure only one instance in global

func (*DroppedBidRecorder) Close ¶

func (r *DroppedBidRecorder) Close()

Close close safe

func (*DroppedBidRecorder) Init ¶

func (r *DroppedBidRecorder) Init(cfg *recordlog.Config, clusterID proto.ClusterID) error

Init init DroppedBidRecorder

func (*DroppedBidRecorder) Write ¶

func (r *DroppedBidRecorder) Write(ctx context.Context, vid proto.Vid, bid proto.BlobID, reason string)

Write write dropped bid record

type EncoderPool ¶

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

EncoderPool used for ec

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL