controller

package

Go to main page

Versions in this module

v1

v1.11.0

Nov 14, 2019

Changes in this version

+ const AnnUploadClientName

+ func ParseCloneRequestAnnotation(pvc *v1.PersistentVolumeClaim) (exists bool, namespace, name string)

+ type UploadPodArgs struct

+ Client kubernetes.Interface

+ ClientName string

+ Image string

+ Name string

+ PVC *v1.PersistentVolumeClaim

+ PullPolicy string

+ ScratchPVCName string

+ Verbose string

v1.10.6

Sep 19, 2019

v1.10.5

Sep 19, 2019

v1.10.3

Aug 29, 2019

v1.10.2

Aug 20, 2019

Changes in this version

+ const AnnOwnerRef

+ const AnnPodReady

+ func GetUploadServerURL(namespace, pvc string) string

v1.10.0

Jul 26, 2019

Changes in this version

+ const AnnSmartCloneRequest

+ const ErrImportFailedPVC

+ const MessageSmartCloneInProgress

+ const MessageSmartClonePVCInProgress

+ const SmartClonePVCInProgress

+ const SnapshotForSmartCloneCreated

+ const SnapshotForSmartCloneInProgress

+ func IsCsiCrdsDeployed(c extclientset.Interface) bool

+ type SmartCloneController struct

+ func NewSmartCloneController(client kubernetes.Interface, cdiClientSet clientset.Interface, ...) *SmartCloneController

+ func (c *SmartCloneController) ProcessNextItem() bool

+ func (c *SmartCloneController) Run(threadiness int, stopCh <-chan struct{}) error

v1.9.4

Jul 11, 2019

Changes in this version

+ const APIServerPublicKeyDir

+ const APIServerPublicKeyPath

+ const AnnCloneToken

+ func DecodePublicKey(keyBytes []byte) (*rsa.PublicKey, error)

v1.9.1

May 16, 2019

Changes in this version

+ const ErrIncompatiblePVC

+ func ValidateCanCloneSourceAndTargetSpec(sourceSpec, targetSpec *v1.PersistentVolumeClaimSpec) error

v1.8.0

Apr 10, 2019

v1.7.0

Mar 22, 2019

Changes in this version

+ const AnnDefaultStorageClass

+ const AnnRequiresScratch

+ const ScratchVolName

+ func CreateScratchPersistentVolumeClaim(client kubernetes.Interface, pvc *v1.PersistentVolumeClaim, pod *v1.Pod, ...) (*v1.PersistentVolumeClaim, error)

+ func EnsureCDIConfigExists(client kubernetes.Interface, cdiClient clientset.Interface, name string) error

+ func GetScratchPvcStorageClass(client kubernetes.Interface, cdiclient clientset.Interface, ...) (string, error)

+ func MakeEmptyCDIConfigSpec(name string) *cdiv1.CDIConfig

type ConfigController

+ func (c *ConfigController) Init() error

type UploadController

+ func (c *UploadController) Init() error

v1.6.0

Feb 28, 2019

Changes in this version

+ const AnnCertConfigMap

+ const CertVolName

+ func CreateCDIConfig(client kubernetes.Interface, cdiClient clientset.Interface, name string) (*cdiv1.CDIConfig, error)

+ func IsOpenshift(client kubernetes.Interface) bool

+ func MakeCDIConfigSpec(name string) *cdiv1.CDIConfig

+ func MakePVCOwnerReference(pvc *v1.PersistentVolumeClaim) metav1.OwnerReference

+ func MakePodOwnerReference(pod *v1.Pod) metav1.OwnerReference

+ type ConfigController struct

+ func NewConfigController(client kubernetes.Interface, cdiClientSet cdiclientset.Interface, ...) *ConfigController

+ func (c *ConfigController) Run(threadiness int, stopCh <-chan struct{}) error

v1.4.2

Jan 16, 2019

v1.4.1

Dec 6, 2018

Changes in this version

+ const AnnAPIGroup

+ const AnnContentType

+ const AnnSource

+ const ContentTypeArchive

+ const ContentTypeKubevirt

+ const SourceGlance

+ const SourceHTTP

+ const SourceNone

+ const SourceRegistry

+ const SourceS3

v1.3.0

Oct 17, 2018

Changes in this version

+ const AnnCloneOf

+ const AnnCloneRequest

+ const AnnCreatedBy

+ const AnnEndpoint

+ const AnnImportPod

+ const AnnPodPhase

+ const AnnSecret

+ const AnnTargetPodNamespace

+ const AnnUploadRequest

+ const CloneFailed

+ const CloneInProgress

+ const CloneScheduled

+ const CloneSucceeded

+ const CloneUniqueID

+ const DataVolName

+ const DataVolumeFailed

+ const ErrClaimLost

+ const ErrResourceDoesntExist

+ const ErrResourceExists

+ const ImagePathName

+ const ImportFailed

+ const ImportInProgress

+ const ImportScheduled

+ const ImportSucceeded

+ const LabelImportPvc

+ const MessageCloneFailed

+ const MessageCloneInProgress

+ const MessageCloneScheduled

+ const MessageCloneSucceeded

+ const MessageErrClaimLost

+ const MessageImportFailed

+ const MessageImportInProgress

+ const MessageImportScheduled

+ const MessageImportSucceeded

+ const MessageResourceDoesntExist

+ const MessageResourceExists

+ const MessageResourceSynced

+ const MessageUploadFailed

+ const MessageUploadReady

+ const MessageUploadScheduled

+ const MessageUploadSucceeded

+ const SuccessSynced

+ const UploadFailed

+ const UploadReady

+ const UploadScheduled

+ const UploadSucceeded

+ func CreateCloneSourcePod(client kubernetes.Interface, image string, pullPolicy string, cr string, ...) (*v1.Pod, error)

+ func CreateCloneTargetPod(client kubernetes.Interface, image string, pullPolicy string, ...) (*v1.Pod, error)

+ func CreateImporterPod(client kubernetes.Interface, image, verbose, pullPolicy, ep, secretName string, ...) (*v1.Pod, error)

+ func CreateUploadPod(client kubernetes.Interface, caKeyPair *triple.KeyPair, ...) (*v1.Pod, error)

+ func CreateUploadService(client kubernetes.Interface, name string, pvc *v1.PersistentVolumeClaim) (*v1.Service, error)

+ func GetUploadResourceName(pvcName string) string

+ func MakeCloneSourcePodSpec(image, pullPolicy, sourcePvcName string, pvc *v1.PersistentVolumeClaim) *v1.Pod

+ func MakeCloneTargetPodSpec(image, pullPolicy, podAffinityNamespace string, pvc *v1.PersistentVolumeClaim) *v1.Pod

+ func MakeImporterPodSpec(image, verbose, pullPolicy, ep, secret string, pvc *v1.PersistentVolumeClaim) *v1.Pod

+ func MakeOwnerReference(pvc *v1.PersistentVolumeClaim) metav1.OwnerReference

+ func MakeUploadPodSpec(image, verbose, pullPolicy, name string, pvc *v1.PersistentVolumeClaim, ...) *v1.Pod

+ func MakeUploadServiceSpec(name string, pvc *v1.PersistentVolumeClaim) *v1.Service

+ func ParseSourcePvcAnnotation(sourcePvcAnno, del string) (namespace, name string)

+ func UploadPossibleForPVC(pvc *v1.PersistentVolumeClaim) error

+ type CloneController struct

+ func NewCloneController(client kubernetes.Interface, ...) *CloneController

+ func (cc *CloneController) ProcessNextPvcItem() bool

+ func (cc *CloneController) Run(threadiness int, stopCh <-chan struct{}) error

+ type Controller struct

+ func NewController(client kubernetes.Interface, ...) *Controller

+ type DataVolumeController struct

+ func NewDataVolumeController(kubeclientset kubernetes.Interface, cdiClientSet clientset.Interface, ...) *DataVolumeController

+ func (c *DataVolumeController) Run(threadiness int, stopCh <-chan struct{}) error

+ type DataVolumeEvent struct

+ type ImportController struct

+ func NewImportController(client kubernetes.Interface, ...) *ImportController

+ func (ic *ImportController) ProcessNextPvcItem() bool

+ func (ic *ImportController) Run(threadiness int, stopCh <-chan struct{}) error

+ type UploadController struct

+ func NewUploadController(client kubernetes.Interface, ...) *UploadController

+ func (c *UploadController) Run(threadiness int, stopCh <-chan struct{}) error

v1.2.0-alpha.2

Sep 24, 2018

v1.2.0-alpha.1

Sep 12, 2018

v1.1.1

Aug 14, 2018

v1.1.0

Jul 25, 2018

v0

v0.6.0-alpha.0

Jun 13, 2018

v0.5.0-alpha.0

Jun 13, 2018

v0.4.0-alpha.0

Apr 30, 2018

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL