core

package
v1.28.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 16, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ProvisionerNameDefault is the name of the default OCI volume provisioner (block)
	ProvisionerNameDefault = "oracle.com/oci"
	// ProvisionerNameBlock is the name of the OCI block volume provisioner
	ProvisionerNameBlock = "oracle.com/oci-block"
	// ProvisionerNameFss is the name of the OCI FSS dedicated storage provisioner
	ProvisionerNameFss = "oracle.com/oci-fss"
)

Variables

This section is empty.

Functions

func Run

func Run(logger *zap.SugaredLogger, kubeconfig string, master string, minVolumeSize string, volumeRoundingEnabled bool, stopCh <-chan struct{}) error

Run runs the volume provisoner control loop

Types

type OCIProvisioner

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

OCIProvisioner is a dynamic volume provisioner that satisfies the Kubernetes external storage Provisioner controller interface

func NewOCIProvisioner

func NewOCIProvisioner(logger *zap.SugaredLogger, kubeClient kubernetes.Interface, nodeInformer informersv1.NodeInformer, provisionerType string, volumeRoundingEnabled bool, minVolumeSize resource.Quantity) (*OCIProvisioner, error)

NewOCIProvisioner creates a new OCI provisioner.

func (*OCIProvisioner) Delete

func (p *OCIProvisioner) Delete(ctx context.Context, volume *v1.PersistentVolume) error

Delete removes the storage asset that was created by Provision represented by the given PV.

func (*OCIProvisioner) Provision

Provision creates a storage asset and returns a PV object representing it.

func (*OCIProvisioner) Ready

func (p *OCIProvisioner) Ready(stopCh <-chan struct{}) error

Ready waits unitl the the nodeLister has been synced.

Jump to

Keyboard shortcuts

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