controller

Documentation

Index

• Constants
• func Connect(address string, timeout time.Duration) (*grpc.ClientConn, error)
• func GenerateAccessibilityRequirements(kubeClient kubernetes.Interface, csiAPIClient csiclientset.Interface, ...) (*csi.TopologyRequirement, error)
• func GenerateVolumeNodeAffinity(accessibleTopology []*csi.Topology) *v1.VolumeNodeAffinity
• func NewCSIProvisioner(client kubernetes.Interface, csiAPIClient csiclientset.Interface, ...) controller.Provisioner

Constants

const (
	PluginCapability_CONTROLLER_SERVICE = iota
	PluginCapability_ACCESSIBILITY_CONSTRAINTS
	ControllerCapability_CREATE_DELETE_VOLUME
	ControllerCapability_CREATE_DELETE_SNAPSHOT
)

Functions

func Connect

func Connect(address string, timeout time.Duration) (*grpc.ClientConn, error)

func GenerateAccessibilityRequirements

func GenerateAccessibilityRequirements(
	kubeClient kubernetes.Interface,
	csiAPIClient csiclientset.Interface,
	driverName string,
	allowedTopologies []v1.TopologySelectorTerm,
	selectedNode *v1.Node) (*csi.TopologyRequirement, error)

func GenerateVolumeNodeAffinity

func GenerateVolumeNodeAffinity(accessibleTopology []*csi.Topology) *v1.VolumeNodeAffinity

func NewCSIProvisioner

func NewCSIProvisioner(client kubernetes.Interface,
	csiAPIClient csiclientset.Interface,
	csiEndpoint string,
	connectionTimeout time.Duration,
	identity string,
	volumeNamePrefix string,
	volumeNameUUIDLength int,
	grpcClient *grpc.ClientConn,
	snapshotClient snapclientset.Interface) controller.Provisioner

NewCSIProvisioner creates new CSI provisioner