core

Documentation

Index

• Constants
• func Run(logger *zap.SugaredLogger, kubeconfig string, master string, ...) error
• type OCIProvisioner
  • func NewOCIProvisioner(logger *zap.SugaredLogger, kubeClient kubernetes.Interface, ...) (*OCIProvisioner, error)
  • func (p *OCIProvisioner) Delete(ctx context.Context, volume *v1.PersistentVolume) error
  • func (p *OCIProvisioner) Provision(ctx context.Context, options controller.ProvisionOptions) (*v1.PersistentVolume, controller.ProvisioningState, error)
  • func (p *OCIProvisioner) Ready(stopCh <-chan struct{}) error

Constants

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"
)

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

func (p *OCIProvisioner) Provision(ctx context.Context, options controller.ProvisionOptions) (*v1.PersistentVolume, controller.ProvisioningState, error)

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.