listener

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
}

type DirectCSIDriveListener interface {
	GenericListener

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

type DirectCSIVolumeListener interface {
	GenericListener

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

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