csi

package
v0.0.0-...-7a7d364 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	ResyncPeriodOfCsiNodeInformer = 1 * time.Hour
)
View Source
const (
	ResyncPeriodOfSnapshotInformer = 15 * time.Minute
)

Variables

This section is empty.

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.

func NewRegistrationServer

func NewRegistrationServer(driverName string, endpoint string, versions []string) registerapi.RegistrationServer

NewRegistrationServer returns an initialized registrationServer instance

Types

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
}

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
}

Jump to

Keyboard shortcuts

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