Versions in this module Expand all Collapse all v0 v0.0.2 Oct 13, 2021 v0.0.1 Oct 13, 2021 Changes in this version + const DefaultAddFinalizer + const DefaultCreateProvisionedPVInterval + const DefaultCreateProvisionedPVRetryCount + const DefaultExponentialBackOffOnError + const DefaultFailedDeleteThreshold + const DefaultFailedProvisionThreshold + const DefaultLeaderElection + const DefaultLeaseDuration + const DefaultMetricsAddress + const DefaultMetricsPath + const DefaultMetricsPort + const DefaultRenewDeadline + const DefaultResyncPeriod + const DefaultRetryPeriod + const DefaultThreadiness + func AddFinalizer(addFinalizer bool) func(*ProvisionController) error + func AdditionalProvisionerNames(additionalProvisionerNames []string) func(*ProvisionController) error + func ClaimsInformer(informer cache.SharedIndexInformer) func(*ProvisionController) error + func ClassesInformer(informer cache.SharedInformer) func(*ProvisionController) error + func CreateProvisionedPVBackoff(backoff wait.Backoff) func(*ProvisionController) error + func CreateProvisionedPVInterval(createProvisionedPVInterval time.Duration) func(*ProvisionController) error + func CreateProvisionedPVLimiter(limiter workqueue.RateLimiter) func(*ProvisionController) error + func CreateProvisionedPVRetryCount(createProvisionedPVRetryCount int) func(*ProvisionController) error + func DeletionTimeout(timeout time.Duration) func(*ProvisionController) error + func ExponentialBackOffOnError(exponentialBackOffOnError bool) func(*ProvisionController) error + func FailedDeleteThreshold(failedDeleteThreshold int) func(*ProvisionController) error + func FailedProvisionThreshold(failedProvisionThreshold int) func(*ProvisionController) error + func LeaderElection(leaderElection bool) func(*ProvisionController) error + func LeaderElectionNamespace(leaderElectionNamespace string) func(*ProvisionController) error + func LeaseDuration(leaseDuration time.Duration) func(*ProvisionController) error + func MetricsAddress(metricsAddress string) func(*ProvisionController) error + func MetricsInstance(m metrics.Metrics) func(*ProvisionController) error + func MetricsPath(metricsPath string) func(*ProvisionController) error + func MetricsPort(metricsPort int32) func(*ProvisionController) error + func NodesLister(nodeLister corelistersv1.NodeLister) func(*ProvisionController) error + func ProvisionTimeout(timeout time.Duration) func(*ProvisionController) error + func RateLimiter(rateLimiter workqueue.RateLimiter) func(*ProvisionController) error + func RenewDeadline(renewDeadline time.Duration) func(*ProvisionController) error + func ResyncPeriod(resyncPeriod time.Duration) func(*ProvisionController) error + func RetryPeriod(retryPeriod time.Duration) func(*ProvisionController) error + func Threadiness(threadiness int) func(*ProvisionController) error + func VolumesInformer(informer cache.SharedInformer) func(*ProvisionController) error + type BlockProvisioner interface + SupportsBlock func(context.Context) bool + type DeletionGuard interface + ShouldDelete func(context.Context, *v1.PersistentVolume) bool + type IgnoredError struct + Reason string + func (e *IgnoredError) Error() string + type ProvisionController struct + func NewProvisionController(client kubernetes.Interface, provisionerName string, provisioner Provisioner, ...) *ProvisionController + func (ctrl *ProvisionController) HasRun() bool + func (ctrl *ProvisionController) Run(ctx context.Context) + type ProvisionOptions struct + PVC *v1.PersistentVolumeClaim + PVName string + SelectedNode *v1.Node + StorageClass *storageapis.StorageClass + type Provisioner interface + Delete func(context.Context, *v1.PersistentVolume) error + Provision func(context.Context, ProvisionOptions) (*v1.PersistentVolume, ProvisioningState, error) + type ProvisioningState string + const ProvisioningFinished + const ProvisioningInBackground + const ProvisioningNoChange + const ProvisioningReschedule + type Qualifier interface + ShouldProvision func(context.Context, *v1.PersistentVolumeClaim) bool + type VolumeStore interface + Run func(ctx context.Context, threadiness int) + StoreVolume func(claim *v1.PersistentVolumeClaim, volume *v1.PersistentVolume) error + func NewBackoffStore(client kubernetes.Interface, eventRecorder record.EventRecorder, ...) VolumeStore + func NewVolumeStoreQueue(client kubernetes.Interface, limiter workqueue.RateLimiter, ...) VolumeStore
Go to main page