listener

Documentation

Index

• type DirectCSIController
  • func NewDefaultDirectCSIController(identity string, leaderLockName string, threads int) (*DirectCSIController, error)
  • func NewDirectCSIController(identity string, leaderLockName string, threads int, ...) (*DirectCSIController, error)
  • func (c *DirectCSIController) AddDirectCSIDriveListener(b DirectCSIDriveListener)
  • func (c *DirectCSIController) AddDirectCSIVolumeListener(b DirectCSIVolumeListener)
  • func (c *DirectCSIController) GetOpLock(op interface{}) *sync.Mutex
  • func (c *DirectCSIController) OpLock(op interface{})
  • func (c *DirectCSIController) OpUnlock(op interface{})
  • func (c *DirectCSIController) Run(ctx context.Context) error
• type DirectCSIDriveListener
• type DirectCSIVolumeListener
• type GenericListener

Types

type DirectCSIController

type DirectCSIController struct {
	LeaseDuration time.Duration
	RenewDeadline time.Duration
	RetryPeriod   time.Duration

	// Controller
	ResyncPeriod time.Duration

	// Listeners
	DirectCSIVolumeListener DirectCSIVolumeListener
	DirectCSIDriveListener  DirectCSIDriveListener
	// contains filtered or unexported fields
}

func NewDefaultDirectCSIController

func NewDefaultDirectCSIController(identity string, leaderLockName string, threads int) (*DirectCSIController, error)

func NewDirectCSIController

func NewDirectCSIController(identity string, leaderLockName string, threads int, limiter workqueue.RateLimiter) (*DirectCSIController, error)

func (*DirectCSIController) AddDirectCSIDriveListener

func (c *DirectCSIController) AddDirectCSIDriveListener(b DirectCSIDriveListener)

func (*DirectCSIController) AddDirectCSIVolumeListener

func (c *DirectCSIController) AddDirectCSIVolumeListener(b DirectCSIVolumeListener)

func (*DirectCSIController) GetOpLock

func (c *DirectCSIController) GetOpLock(op interface{}) *sync.Mutex

func (*DirectCSIController) OpLock

func (c *DirectCSIController) OpLock(op interface{})

func (*DirectCSIController) OpUnlock

func (c *DirectCSIController) OpUnlock(op interface{})

func (*DirectCSIController) Run

func (c *DirectCSIController) Run(ctx context.Context) error

Run - runs the controller. Note that ctx must be cancellable i.e. ctx.Done() should not return nil

type DirectCSIDriveListener

type DirectCSIDriveListener interface {
	GenericListener

	Add(ctx context.Context, b *v1alpha1.DirectCSIDrive) error
	Update(ctx context.Context, old *v1alpha1.DirectCSIDrive, new *v1alpha1.DirectCSIDrive) error
	Delete(ctx context.Context, b *v1alpha1.DirectCSIDrive) error
}

type DirectCSIVolumeListener

type DirectCSIVolumeListener interface {
	GenericListener

	Add(ctx context.Context, b *v1alpha1.DirectCSIVolume) error
	Update(ctx context.Context, old *v1alpha1.DirectCSIVolume, new *v1alpha1.DirectCSIVolume) error
	Delete(ctx context.Context, b *v1alpha1.DirectCSIVolume) error
}

type GenericListener

type GenericListener interface {
	InitializeKubeClient(kubeclientset.Interface)
	InitializeDirectCSIClient(clientset.Interface)
}

Set the clients for each of the listeners