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, hasCert bool, ...) error
- func ConvertSize(size interface{}) (int64, error)
- func CopyHostDirectoryContent(src, dest string) (err error)
- func CopyReq(req *http.Request) *http.Request
- func CreateDiskPathReplicaSubdirectory(path string) error
- func DeleteDiskPathReplicaSubdirectoryAndDiskCfgFile(nsExec *iscsi_util.NamespaceExecutor, path string) error
- func DetectFileSystem(volumeName string) (string, error)
- func Execute(binary string, args ...string) (string, error)
- func ExecuteWithTimeout(timeout time.Duration, binary string, args ...string) (string, error)
- func ExecuteWithoutTimeout(binary string, args ...string) (string, error)
- func ExpandFileSystem(volumeName string) (err error)
- func FilteredLoggingHandler(filteredPaths map[string]struct{}, writer io.Writer, router http.Handler) http.Handler
- 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 GetAnnotation(obj runtime.Object, annotationKey string) (string, error)
- func GetBackupID(backupURL string) (string, error)
- func GetChecksumSHA512(data []byte) string
- func GetDistinctTolerations(tolerationList []v1.Toleration) []v1.Toleration
- func GetLocalIPs() ([]string, error)
- func GetRequiredEnv(key string) (string, error)
- func GetStringChecksum(data string) string
- func GetTolerationChecksum(t v1.Toleration) string
- func IsKubernetesDefaultToleration(toleration v1.Toleration) bool
- func IsKubernetesVersionAtLeast(kubeClient clientset.Interface, vers string) (bool, error)
- func IsSupportedFileSystem(fsType string) bool
- 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 RetryOnConflictCause(fn func() (interface{}, error)) (obj interface{}, err error)
- func RoundUpSize(size int64) int64
- func RunAsync(wg *sync.WaitGroup, f func())
- func SetAnnotation(obj runtime.Object, annotationKey, annotationValue string) error
- func SplitStringToMap(str, separator string) map[string]struct{}
- func TimestampAfterTimeout(ts string, timeout time.Duration) bool
- func TimestampWithinLimit(latest time.Time, ts string, limit time.Duration) bool
- func TolerationListToMap(tolerationList []v1.Toleration) map[string]v1.Toleration
- func UUID() string
- func ValidateName(name string) bool
- func ValidateSnapshotLabels(labels map[string]string) (map[string]string, error)
- func ValidateTags(inputTags []string) ([]string, error)
- func WaitForAPI(url string, timeout int) error
- func WaitForDevice(dev string, timeout int) error
- type DiskConfig
- type DiskInfo
- type MetadataConfig
Constants ¶
View Source
const ( VolumeStackPrefix = "volume-" ControllerServiceName = "controller" ReplicaServiceName = "replica" BackupStoreTypeS3 = "s3" AWSAccessKey = "AWS_ACCESS_KEY_ID" AWSSecretKey = "AWS_SECRET_ACCESS_KEY" AWSEndPoint = "AWS_ENDPOINTS" AWSCert = "AWS_CERT" HTTPSProxy = "HTTPS_PROXY" HTTPProxy = "HTTP_PROXY" NOProxy = "NO_PROXY" VirtualHostedStyle = "VIRTUAL_HOSTED_STYLE" HostProcPath = "/host/proc" ReplicaDirectory = "/replicas/" DeviceDirectory = "/dev/longhorn/" TemporaryMountPointDirectory = "/tmp/mnt/" DefaultKubernetesTolerationKey = "kubernetes.io" DiskConfigFile = "longhorn-disk.cfg" SizeAlignment = 2 * 1024 * 1024 MinimalVolumeSize = 10 * 1024 * 1024 )
Variables ¶
View Source
var ( ConflictRetryInterval = 20 * time.Millisecond ConflictRetryCounts = 100 )
Functions ¶
func CheckBackupType ¶
func CmdOutLines ¶
func ConfigBackupCredential ¶
func ConfigEnvWithCredential ¶
func ConvertSize ¶
func CopyHostDirectoryContent ¶ added in v0.8.0
func CreateDiskPathReplicaSubdirectory ¶ added in v0.8.1
func DeleteDiskPathReplicaSubdirectoryAndDiskCfgFile ¶ added in v1.0.0
func DeleteDiskPathReplicaSubdirectoryAndDiskCfgFile( nsExec *iscsi_util.NamespaceExecutor, path string) error
func DetectFileSystem ¶ added in v0.8.0
func ExecuteWithTimeout ¶
func ExecuteWithoutTimeout ¶ added in v0.6.0
func ExpandFileSystem ¶ added in v0.8.0
func FilteredLoggingHandler ¶ added in v0.4.1
func FormatTimeZ ¶
func FromMillis ¶
func GetAnnotation ¶ added in v1.1.0
func GetBackupID ¶
func GetChecksumSHA512 ¶
func GetDistinctTolerations ¶ added in v1.1.0
func GetDistinctTolerations(tolerationList []v1.Toleration) []v1.Toleration
func GetLocalIPs ¶
func GetRequiredEnv ¶
func GetStringChecksum ¶
func GetTolerationChecksum ¶ added in v1.1.0
func GetTolerationChecksum(t v1.Toleration) string
func IsKubernetesDefaultToleration ¶ added in v0.6.0
func IsKubernetesDefaultToleration(toleration v1.Toleration) bool
func IsKubernetesVersionAtLeast ¶ added in v0.8.0
func IsSupportedFileSystem ¶ added in v0.8.0
func ParseLabels ¶
ParseLabels parses the provided Labels based on longhorn-engine's implementation: https://github.com/longhorn/longhorn-engine/blob/master/util/util.go
func RegisterShutdownChannel ¶
func RegisterShutdownChannel(done chan struct{})
func RemoveHostDirectoryContent ¶ added in v0.3.3
func RetryOnConflictCause ¶
func RoundUpSize ¶
func SetAnnotation ¶ added in v1.1.0
func SplitStringToMap ¶
func TimestampWithinLimit ¶ added in v0.8.0
func TolerationListToMap ¶ added in v0.6.0
func TolerationListToMap(tolerationList []v1.Toleration) map[string]v1.Toleration
func ValidateName ¶
func ValidateSnapshotLabels ¶ added in v0.6.0
func ValidateTags ¶ added in v0.6.0
func WaitForDevice ¶
WaitForDevice timeout in second
Types ¶
type DiskConfig ¶ added in v0.8.1
type DiskConfig struct {
DiskUUID string `json:"diskUUID"`
}
func GenerateDiskConfig ¶ added in v0.8.1
func GenerateDiskConfig(path string) (*DiskConfig, error)
func GetDiskConfig ¶ added in v0.8.1
func GetDiskConfig(path string) (*DiskConfig, error)
Click to show internal directories.
Click to hide internal directories.