csi

Documentation

Index

• Constants
• Variables
• func NewGRPCRunner(srv *grpc.Server, sockFile string, leaderElection bool) manager.Runnable
• type CheckableRegistrationServer
  • func NewRegistrationServer(onFail context.CancelCauseFunc, driverName string, endpoint string, ...) CheckableRegistrationServer
• type Provisioner
  • func NewProvisioner(mgr manager.Manager, options ProvisionerOptions) *Provisioner
  • func (p *Provisioner) NeedLeaderElection() bool
  • func (p *Provisioner) Start(ctx context.Context) error
• type ProvisionerOptions
• type Resizer
  • func NewResizer(mgr manager.Manager, options ProvisionerOptions) *Resizer
  • func (r *Resizer) NeedLeaderElection() bool
  • func (r *Resizer) Start(ctx context.Context) error
• type ResizerOptions
• type Snapshotter
  • func NewSnapshotter(mgr manager.Manager, options SnapshotterOptions) *Snapshotter
  • func (s *Snapshotter) NeedLeaderElection() bool
  • func (s *Snapshotter) Start(ctx context.Context) error
• type SnapshotterOptions

Constants

const (
	ResyncPeriodOfCsiNodeInformer = 1 * time.Hour
)

const (
	ResyncPeriodOfSnapshotInformer = 15 * time.Minute
)

Variables

var ErrPluginRegistrationFailed = fmt.Errorf("plugin registration failed")

Functions

func NewGRPCRunner

func NewGRPCRunner(srv *grpc.Server, sockFile string, leaderElection bool) manager.Runnable

NewGRPCRunner creates controller-runtime's manager.Runnable for a gRPC server. The server will listen on UNIX domain socket at sockFile. If leaderElection is true, the server will run only when it is elected as leader.

Types

type CheckableRegistrationServer

type CheckableRegistrationServer interface {
	registerapi.RegistrationServer
	Registered() bool
}

func NewRegistrationServer

func NewRegistrationServer(onFail context.CancelCauseFunc, driverName string, endpoint string, versions []string) CheckableRegistrationServer

NewRegistrationServer returns an initialized registrationServer instance

type Provisioner

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

func NewProvisioner

func NewProvisioner(mgr manager.Manager, options ProvisionerOptions) *Provisioner

func (*Provisioner) NeedLeaderElection

func (p *Provisioner) NeedLeaderElection() bool

func (*Provisioner) Start

func (p *Provisioner) Start(ctx context.Context) error

type ProvisionerOptions

type ProvisionerOptions struct {
	DriverName          string
	CSIEndpoint         string
	CSIOperationTimeout time.Duration
	Metrics             *connection.ExtendedCSIMetricsManager
}

type Resizer

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

func NewResizer

func NewResizer(mgr manager.Manager, options ProvisionerOptions) *Resizer

func (*Resizer) NeedLeaderElection

func (r *Resizer) NeedLeaderElection() bool

func (*Resizer) Start

func (r *Resizer) Start(ctx context.Context) error

type ResizerOptions

type ResizerOptions struct {
	DriverName          string
	CSIEndpoint         string
	CSIOperationTimeout time.Duration // 10*time.Second
}

type Snapshotter

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

func NewSnapshotter

func NewSnapshotter(mgr manager.Manager, options SnapshotterOptions) *Snapshotter

func (*Snapshotter) NeedLeaderElection

func (s *Snapshotter) NeedLeaderElection() bool

func (*Snapshotter) Start

func (s *Snapshotter) Start(ctx context.Context) error

type SnapshotterOptions

type SnapshotterOptions struct {
	DriverName          string
	CSIEndpoint         string
	CSIOperationTimeout time.Duration
}