Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controller

package

Go to main page

Versions in this module

v5

v5.3.0

May 30, 2025

v5.2.0

Jan 17, 2025

v5.1.0

Aug 22, 2024

Changes in this version

+ const ResyncPeriodOfCsiNodeInformer

+ const ResyncPeriodOfReferenceGrantInformer

+ func Connect(ctx context.Context, address string, metricsManager metrics.CSIMetricsManager) (*grpc.ClientConn, error)

+ func GenerateAccessibilityRequirements(kubeClient kubernetes.Interface, driverName string, pvcName string, ...) (*csi.TopologyRequirement, error)

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

+ func GetDriverCapabilities(conn *grpc.ClientConn, timeout time.Duration) (rpc.PluginCapabilitySet, rpc.ControllerCapabilitySet, error)

+ func GetDriverName(conn *grpc.ClientConn, timeout time.Duration) (string, error)

+ func GetNodeInfo(conn *grpc.ClientConn, timeout time.Duration) (*csi.NodeGetInfoResponse, error)

+ func IsGranted(ctx context.Context, claim *v1.PersistentVolumeClaim, ...) (bool, error)

+ func NewCSIProvisioner(client kubernetes.Interface, connectionTimeout time.Duration, identity string, ...) controller.Provisioner

+ func Probe(ctx context.Context, conn *grpc.ClientConn, singleCallTimeout time.Duration) error

+ func SupportsTopology(pluginCapabilities rpc.PluginCapabilitySet) bool

+ func VolumeIsAccessible(affinity *v1.VolumeNodeAffinity, nodeTopology *csi.Topology) (bool, error)

+ type CloningProtectionController struct

+ func NewCloningProtectionController(client kubernetes.Interface, ...) *CloningProtectionController

+ func (p *CloningProtectionController) Run(ctx context.Context, threadiness int)

+ type NodeDeployment struct

+ BaseDelay time.Duration

+ ClaimInformer coreinformers.PersistentVolumeClaimInformer

+ ImmediateBinding bool

+ MaxDelay time.Duration

+ NodeInfo csi.NodeGetInfoResponse

+ NodeName string

+ type ProvisionerCSITranslator interface

+ GetInTreeNameFromCSIName func(pluginName string) (string, error)

+ IsMigratedCSIDriverByName func(csiPluginName string) bool

+ IsPVMigratable func(pv *v1.PersistentVolume) bool

+ TranslateCSIPVToInTree func(pv *v1.PersistentVolume) (*v1.PersistentVolume, error)

+ TranslateInTreePVToCSI func(pv *v1.PersistentVolume) (*v1.PersistentVolume, error)

+ TranslateInTreeStorageClassToCSI func(inTreePluginName string, sc *storagev1.StorageClass) (*storagev1.StorageClass, error)

Other modules containing this package

github.com/kubernetes-csi/external-provisioner