app

Documentation

Index

• Constants
• func CSICommand() cli.Command
• func DaemonCmd() cli.Command
• func DeployDriverCmd() cli.Command
• func MigrateForPre070VolumesCmd() cli.Command
• func PostUpgradeCmd() cli.Command
• func PreUpgradeCmd() cli.Command
• func RecurringJobCmd() cli.Command
• func SystemRolloutCmd() cli.Command
• func UninstallCmd() cli.Command
• type Job
  • func (job *Job) GetEngineImage(name string) (*longhorn.EngineImage, error)
  • func (job *Job) GetSettingAsBool(name types.SettingName) (bool, 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"
	FlagSupportBundleManagerImage = "support-bundle-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"
	FlagCSILivenessProbeImage       = "csi-liveness-probe-image"
	EnvCSIAttacherImage             = "CSI_ATTACHER_IMAGE"
	EnvCSIProvisionerImage          = "CSI_PROVISIONER_IMAGE"
	EnvCSIResizerImage              = "CSI_RESIZER_IMAGE"
	EnvCSISnapshotterImage          = "CSI_SNAPSHOTTER_IMAGE"
	EnvCSINodeDriverRegistrarImage  = "CSI_NODE_DRIVER_REGISTRAR_IMAGE"
	EnvCSILivenessProbeImage        = "CSI_LIVENESS_PROBE_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 = `` /* 761-byte string literal not displayed */

)

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

const (
	HTTPClientTimout = 1 * time.Minute

	SnapshotPurgeStatusInterval = 5 * time.Second
	// SnapshotPurgeStatusTimeout is set to 24 hours because we don't know the appropriate value.
	SnapshotPurgeStatusTimeout = 24 * time.Hour

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

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

	EnvLonghornNamespace = "LONGHORN_NAMESPACE"
)

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

const (
	FlagAll = "all"
)

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 PreUpgradeCmd

func PreUpgradeCmd() cli.Command

func RecurringJobCmd

func RecurringJobCmd() cli.Command

func SystemRolloutCmd

func SystemRolloutCmd() cli.Command

func UninstallCmd

func UninstallCmd() cli.Command

Types

type Job

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

func (*Job) GetEngineImage

func (job *Job) GetEngineImage(name string) (*longhorn.EngineImage, error)

func (*Job) GetSettingAsBool

func (job *Job) GetSettingAsBool(name types.SettingName) (bool, error)

GetSettingAsBool returns boolean of the setting value searching by name.

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
}