util

Documentation

Index

• Constants
• Variables
• func AddFinalizer(name string, obj runtime.Object) error
• func Backoff(maxDuration time.Duration, timeoutMessage string, f func() (bool, error)) error
• func CheckBackupType(backupTarget string) (string, error)
• func CmdOutLines(cmd *exec.Cmd, cancel <-chan interface{}) (<-chan string, <-chan error)
• func ConfigBackupCredential(backupTarget string, credential map[string]string) error
• func ConfigEnvWithCredential(backupTarget string, credentialSecret string, hasEndpoint bool, ...) error
• func ControllerAddress(volumeName string) string
• func ConvertSize(size interface{}) (int64, error)
• func CopyReq(req *http.Request) *http.Request
• func Execute(binary string, args ...string) (string, error)
• func ExecuteWithTimeout(timeout time.Duration, binary string, args ...string) (string, error)
• func FinalizerExists(name string, obj runtime.Object) bool
• func FormatLocalTime(t time.Time, loc *time.Location) string
• func FormatTimeZ(t time.Time) string
• func FromMillis(t int64) time.Time
• func GetBackupID(backupURL string) (string, error)
• func GetChecksumSHA512(data []byte) string
• func GetInitiatorNSPath() string
• func GetLocalIPs() ([]string, error)
• func GetRequiredEnv(key string) (string, error)
• func GetStringChecksum(data string) string
• func LimitToPeriod(p, t [2]time.Time) [2]time.Time
• func Now() string
• func ParseLabels(labels []string) (map[string]string, error)
• func ParseLocalTime(ts string, loc *time.Location) (time.Time, error)
• func ParsePeriod(s string, loc *time.Location) ([2]time.Time, error)
• func ParseTime(t string) (time.Time, error)
• func ParseTimeZ(s string) (time.Time, error)
• func RandomID() string
• func RegisterShutdownChannel(done chan struct{})
• func RemoveFinalizer(name string, obj runtime.Object) error
• func RemoveHostDirectoryContent(directory string) (err error)
• func ReplicaAddress(name, volumeName string) string
• func ReplicaName(address, volumeName string) string
• func RetryOnConflictCause(fn func() (interface{}, error)) (obj interface{}, err error)
• func RoundUpSize(size int64) int64
• func RunAsync(wg *sync.WaitGroup, f func())
• func SplitStringToMap(str, separator string) map[string]struct{}
• func TimestampAfterTimeout(ts string, timeout time.Duration) bool
• func UUID() string
• func ValidateName(name string) bool
• func VolumeStackName(volumeName string) string
• func WaitForAPI(url string, timeout int) error
• func WaitForDevice(dev string, timeout int) error
• type DiskInfo
  • func GetDiskInfo(directory string) (info *DiskInfo, err error)
• type MetadataConfig

Constants

const (
	VolumeStackPrefix     = "volume-"
	ControllerServiceName = "controller"
	ReplicaServiceName    = "replica"

	BackupStoreTypeS3 = "s3"
	AWSAccessKey      = "AWS_ACCESS_KEY_ID"
	AWSSecretKey      = "AWS_SECRET_ACCESS_KEY"
	AWSEndPoint       = "AWS_ENDPOINTS"
)

Variables

var (
	ConflictRetryInterval = 20 * time.Millisecond
	ConflictRetryCounts   = 100
)

Functions

func AddFinalizer

func AddFinalizer(name string, obj runtime.Object) error

func Backoff

func Backoff(maxDuration time.Duration, timeoutMessage string, f func() (bool, error)) error

func CheckBackupType

func CheckBackupType(backupTarget string) (string, error)

func CmdOutLines

func CmdOutLines(cmd *exec.Cmd, cancel <-chan interface{}) (<-chan string, <-chan error)

func ConfigBackupCredential

func ConfigBackupCredential(backupTarget string, credential map[string]string) error

func ConfigEnvWithCredential

func ConfigEnvWithCredential(backupTarget string, credentialSecret string, hasEndpoint bool, container *v1.Container) error

func ControllerAddress

func ControllerAddress(volumeName string) string

func ConvertSize

func ConvertSize(size interface{}) (int64, error)

func CopyReq

func CopyReq(req *http.Request) *http.Request

func Execute

func Execute(binary string, args ...string) (string, error)

func ExecuteWithTimeout

func ExecuteWithTimeout(timeout time.Duration, binary string, args ...string) (string, error)

func FinalizerExists

func FinalizerExists(name string, obj runtime.Object) bool

func FormatLocalTime

func FormatLocalTime(t time.Time, loc *time.Location) string

func FormatTimeZ

func FormatTimeZ(t time.Time) string

func FromMillis

func FromMillis(t int64) time.Time

func GetBackupID

func GetBackupID(backupURL string) (string, error)

func GetChecksumSHA512

func GetChecksumSHA512(data []byte) string

func GetInitiatorNSPath

func GetInitiatorNSPath() string

func GetLocalIPs

func GetLocalIPs() ([]string, error)

func GetRequiredEnv

func GetRequiredEnv(key string) (string, error)

func GetStringChecksum

func GetStringChecksum(data string) string

func LimitToPeriod

func LimitToPeriod(p, t [2]time.Time) [2]time.Time

func Now

func Now() string

func ParseLabels

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

func ParseLocalTime

func ParseLocalTime(ts string, loc *time.Location) (time.Time, error)

func ParsePeriod

func ParsePeriod(s string, loc *time.Location) ([2]time.Time, error)

func ParseTime

func ParseTime(t string) (time.Time, error)

func ParseTimeZ

func ParseTimeZ(s string) (time.Time, error)

func RandomID

func RandomID() string

func RegisterShutdownChannel

func RegisterShutdownChannel(done chan struct{})

func RemoveFinalizer

func RemoveFinalizer(name string, obj runtime.Object) error

func RemoveHostDirectoryContent

func RemoveHostDirectoryContent(directory string) (err error)

func ReplicaAddress

func ReplicaAddress(name, volumeName string) string

func ReplicaName

func ReplicaName(address, volumeName string) string

func RetryOnConflictCause

func RetryOnConflictCause(fn func() (interface{}, error)) (obj interface{}, err error)

func RoundUpSize

func RoundUpSize(size int64) int64

func RunAsync

func RunAsync(wg *sync.WaitGroup, f func())

func SplitStringToMap

func SplitStringToMap(str, separator string) map[string]struct{}

func TimestampAfterTimeout

func TimestampAfterTimeout(ts string, timeout time.Duration) bool

func UUID

func UUID() string

func ValidateName

func ValidateName(name string) bool

func VolumeStackName

func VolumeStackName(volumeName string) string

func WaitForAPI

func WaitForAPI(url string, timeout int) error

WaitForAPI timeout in second

func WaitForDevice

func WaitForDevice(dev string, timeout int) error

WaitForDevice timeout in second

Types

type DiskInfo

type DiskInfo struct {
	Fsid             string
	Path             string
	Type             string
	FreeBlock        int64
	TotalBlock       int64
	BlockSize        int64
	StorageMaximum   int64
	StorageAvailable int64
}

func GetDiskInfo

func GetDiskInfo(directory string) (info *DiskInfo, err error)

type MetadataConfig

type MetadataConfig struct {
	DriverName          string
	Image               string
	OrcImage            string
	DriverContainerName string
}