Documentation
¶
Index ¶
- Constants
- Variables
- func NewGRPCRunner(srv *grpc.Server, sockFile string, leaderElection bool) manager.Runnable
- func NewHealthServer(c HealthCheck) grpc_health_v1.HealthServer
- type CheckableRegistrationServer
- type HealthCheck
- type Provisioner
- type ProvisionerOptions
- type Resizer
- type ResizerOptions
- type Snapshotter
- type SnapshotterOptions
Constants ¶
View Source
const (
ResyncPeriodOfCsiNodeInformer = 1 * time.Hour
)
View Source
const (
ResyncPeriodOfSnapshotInformer = 15 * time.Minute
)
Variables ¶
View Source
var ErrPluginRegistrationFailed = fmt.Errorf("plugin registration failed")
Functions ¶
func NewGRPCRunner ¶
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 NewHealthServer ¶
func NewHealthServer(c HealthCheck) grpc_health_v1.HealthServer
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 HealthCheck ¶
var AlwaysHealthy HealthCheck = func(ctx context.Context) error { return nil }
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
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 ¶
type ResizerOptions ¶
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
Click to show internal directories.
Click to hide internal directories.