util

Documentation

Index

• Constants
• func BytesToMiB(bytes uint64) uint64
• func CombineErrors(errorList ...error) (retErr error)
• func GetFileChunkChecksum(filePath string, start, size int64) (string, error)
• func GetVolumeNameFromEngineName(engineName string) string
• func IsSPDKTargetProcessRunning() (bool, error)
• func Min(x, y uint64) uint64
• func Now() string
• func ParseLabels(labels []string) (map[string]string, error)
• func RemovePrefix(path, prefix string) string
• func RoundUp(num, base uint64) uint64
• func StartSPDKTgtDaemon() error
• func StopSPDKTgtDaemon(timeout time.Duration) error
• func UUID() string
• func UnescapeURL(url string) string
• type Bitmap
  • func NewBitmap(start, end int32) *Bitmap
  • func (b *Bitmap) AllocateRange(count int32) (int32, int32, error)
  • func (b *Bitmap) ReleaseRange(start, end int32) error
• type ReplicaError
  • func NewReplicaError(address string, err error) ReplicaError
  • func (e ReplicaError) Error() string
• type TaskError
  • func NewTaskError(res ...ReplicaError) *TaskError
  • func (t *TaskError) Append(re ReplicaError)
  • func (t *TaskError) Error() string
  • func (t *TaskError) HasError() bool

Constants

const (
	EngineRandomIDLenth = 8
	EngineSuffix        = "-e"
)

Functions

func BytesToMiB

func BytesToMiB(bytes uint64) uint64

func CombineErrors

func CombineErrors(errorList ...error) (retErr error)

func GetFileChunkChecksum

func GetFileChunkChecksum(filePath string, start, size int64) (string, error)

func GetVolumeNameFromEngineName

func GetVolumeNameFromEngineName(engineName string) string

func IsSPDKTargetProcessRunning

func IsSPDKTargetProcessRunning() (bool, error)

func Min

func Min(x, y uint64) uint64

func Now

func Now() string

func ParseLabels

func ParseLabels(labels []string) (map[string]string, error)

func RemovePrefix

func RemovePrefix(path, prefix string) string

func RoundUp

func RoundUp(num, base uint64) uint64

func StartSPDKTgtDaemon

func StartSPDKTgtDaemon() error

func StopSPDKTgtDaemon

func StopSPDKTgtDaemon(timeout time.Duration) error

func UUID

func UUID() string

func UnescapeURL

func UnescapeURL(url string) string

Types

type Bitmap

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

func NewBitmap

func NewBitmap(start, end int32) *Bitmap

NewBitmap allocate a bitmap range from [start, end], notice the end is included

func (*Bitmap) AllocateRange

func (b *Bitmap) AllocateRange(count int32) (int32, int32, error)

func (*Bitmap) ReleaseRange

func (b *Bitmap) ReleaseRange(start, end int32) error

type ReplicaError

type ReplicaError struct {
	Address string
	Message string
}

func NewReplicaError

func NewReplicaError(address string, err error) ReplicaError

func (ReplicaError) Error

func (e ReplicaError) Error() string

type TaskError

type TaskError struct {
	ReplicaErrors []ReplicaError
}

func NewTaskError

func NewTaskError(res ...ReplicaError) *TaskError

func (*TaskError) Append

func (t *TaskError) Append(re ReplicaError)

func (*TaskError) Error

func (t *TaskError) Error() string

func (*TaskError) HasError

func (t *TaskError) HasError() bool