app

Documentation

Index

• Constants
• func AdmissionWebhookServerCommand() cli.Command
• func CSICommand() cli.Command
• func ConversionWebhookServerCommand() cli.Command
• func DaemonCmd() cli.Command
• func DeployDriverCmd() cli.Command
• func MigrateForPre070VolumesCmd() cli.Command
• func PostUpgradeCmd() cli.Command
• func RecurringJobCmd() cli.Command
• func UninstallCmd() cli.Command
• type Job
  • func NewJob(logger logrus.FieldLogger, managerURL, volumeName, snapshotName string, ...) (*Job, error)
  • func (job *Job) GetEngineImage(name string) (*longhorn.EngineImage, 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"
	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 = `` /* 762-byte string literal not displayed */

)

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

const (
	HTTPClientTimout = 1 * time.Minute

	SnapshotPurgeStatusInterval = 5 * time.Second

	WaitInterval              = 5 * time.Second
	DetachingWaitInterval     = 10 * time.Second
	VolumeAttachTimeout       = 300 // 5 minutes
	BackupProcessStartTimeout = 90  // 1.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 AdmissionWebhookServerCommand

func AdmissionWebhookServerCommand() cli.Command

func CSICommand

func CSICommand() cli.Command

func ConversionWebhookServerCommand

func ConversionWebhookServerCommand() 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 RecurringJobCmd

func RecurringJobCmd() cli.Command

func UninstallCmd

func UninstallCmd() cli.Command

Types

type Job

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

func NewJob

func NewJob(logger logrus.FieldLogger, managerURL, volumeName, snapshotName string, labels map[string]string, retain int, task longhorn.RecurringJobType) (*Job, error)

func (*Job) GetEngineImage

func (job *Job) GetEngineImage(name string) (*longhorn.EngineImage, 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
}