app

Documentation

Index

• Constants
• Variables
• func CSICommand() cli.Command
• func DaemonCmd() cli.Command
• func DeployDriverCmd() cli.Command
• func MigrateForPre070VolumesCmd() cli.Command
• func PostUpgradeCmd() cli.Command
• func SnapshotCmd() cli.Command
• func UninstallCmd() cli.Command
• type DaemonSetOps
  • func (ops *DaemonSetOps) Create(name string, d *appsv1.DaemonSet) (*appsv1.DaemonSet, error)
  • func (ops *DaemonSetOps) Delete(name string) error
  • func (ops *DaemonSetOps) Get(name string) (*appsv1.DaemonSet, error)
• type Job
  • func NewJob(managerURL, volumeName, snapshotName string, labels map[string]string, ...) (*Job, error)
  • func (job *Job) GetVolume(name string) (*longhorn.Volume, error)
  • func (job *Job) UpdateVolumeStatus(v *longhorn.Volume) (*longhorn.Volume, error)
• type NameWithTimestamp

Constants

const (
	FlagEngineImage              = "engine-image"
	FlagInstanceManagerImage     = "instance-manager-image"
	FlagShareManagerImage        = "share-manager-image"
	FlagBackingImageManagerImage = "backing-image-manager-image"
	FlagManagerImage             = "manager-image"
	FlagServiceAccount           = "service-account"
	FlagKubeConfig               = "kube-config"
)

const (
	EnvKubeletRootDir = "KUBELET_ROOT_DIR"

	FlagManagerURL = "manager-url"

	FlagKubeletRootDir = "kubelet-root-dir"

	FlagCSIAttacherImage            = "csi-attacher-image"
	FlagCSIProvisionerImage         = "csi-provisioner-image"
	FlagCSIResizerImage             = "csi-resizer-image"
	FlagCSISnapshotterImage         = "csi-snapshotter-image"
	FlagCSINodeDriverRegistrarImage = "csi-node-driver-registrar-image"
	EnvCSIAttacherImage             = "CSI_ATTACHER_IMAGE"
	EnvCSIProvisionerImage          = "CSI_PROVISIONER_IMAGE"
	EnvCSIResizerImage              = "CSI_RESIZER_IMAGE"
	EnvCSISnapshotterImage          = "CSI_SNAPSHOTTER_IMAGE"
	EnvCSINodeDriverRegistrarImage  = "CSI_NODE_DRIVER_REGISTRAR_IMAGE"

	FlagCSIAttacherReplicaCount    = "csi-attacher-replica-count"
	FlagCSIProvisionerReplicaCount = "csi-provisioner-replica-count"
	FlagCSIResizerReplicaCount     = "csi-resizer-replica-count"
	FlagCSISnapshotterReplicaCount = "csi-snapshotter-replica-count"
	EnvCSIAttacherReplicaCount     = "CSI_ATTACHER_REPLICA_COUNT"
	EnvCSIProvisionerReplicaCount  = "CSI_PROVISIONER_REPLICA_COUNT"
	EnvCSIResizerReplicaCount      = "CSI_RESIZER_REPLICA_COUNT"
	EnvCSISnapshotterReplicaCount  = "CSI_SNAPSHOTTER_REPLICA_COUNT"
)

const (
	DetectPodMaxPolls = 120

	ArgKubeletRootDir = "root-dir"

	ArgNameKubeletRootDir = "--root-dir"

	DefaultKubeletRootDir = "/var/lib/kubelet"

	KubeletDetectionPodName = "discover-proc-kubelet-cmdline"
	K3SDetectionPodName     = "discover-proc-k3s-cmdline"

	GetKubeletCmdlineScript = `` /* 453-byte string literal not displayed */

	GetK3SCmdlineScript = `` /* 762-byte string literal not displayed */

)

const (
	RetryCounts   = 360
	RetryInterval = 5 * time.Second
)

const (
	FlagForce     = "force"
	FlagNamespace = "namespace"

	EnvLonghornNamespace = "LONGHORN_NAMESPACE"
)

const (
	PVCAnnotationCSIProvisioner = "volume.beta.kubernetes.io/storage-provisioner"
	PVAnnotationCSIProvisioner  = "pv.kubernetes.io/provisioned-by"
)

const (
	FlagSnapshotName = "snapshot-name"
	FlagLabels       = "labels"
	FlagRetain       = "retain"
	FlagBackup       = "backup"

	SnapshotPurgeStatusInterval = 5 * time.Second

	WaitInterval              = 5 * time.Second
	DetachingWaitInterval     = 10 * time.Second
	VolumeAttachTimeout       = 300 // 5 minutes
	BackupProcessStartTimeout = 90  // 1.5 minutes

)

const (
	FlagAll = "all"
)

Variables

var VERSION = "VERSION_PLACEHOLDER"

Functions

func CSICommand

func CSICommand() cli.Command

func DaemonCmd

func DaemonCmd() cli.Command

func DeployDriverCmd

func DeployDriverCmd() cli.Command

func MigrateForPre070VolumesCmd

func MigrateForPre070VolumesCmd() cli.Command

func PostUpgradeCmd

func PostUpgradeCmd() cli.Command

func SnapshotCmd

func SnapshotCmd() cli.Command

func UninstallCmd

func UninstallCmd() cli.Command

Types

type DaemonSetOps

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

func (*DaemonSetOps) Create

func (ops *DaemonSetOps) Create(name string, d *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

func (*DaemonSetOps) Delete

func (ops *DaemonSetOps) Delete(name string) error

func (*DaemonSetOps) Get

func (ops *DaemonSetOps) Get(name string) (*appsv1.DaemonSet, error)

type Job

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

func NewJob

func NewJob(managerURL, volumeName, snapshotName string, labels map[string]string, retain int, backup bool) (*Job, error)

func (*Job) GetVolume

func (job *Job) GetVolume(name string) (*longhorn.Volume, error)

func (*Job) UpdateVolumeStatus

func (job *Job) UpdateVolumeStatus(v *longhorn.Volume) (*longhorn.Volume, error)

type NameWithTimestamp

type NameWithTimestamp struct {
	Name      string
	Timestamp time.Time
}