controller

Documentation

Index

• type Interface
  • func NewDownloadController(logger logrus.FieldLogger, downloadInformer informers.DownloadInformer, ...) Interface
  • func NewUploadController(logger logrus.FieldLogger, uploadInformer informers.UploadInformer, ...) Interface

Types

type Interface

type Interface interface {
	// Run runs the component.
	Run(ctx context.Context, workers int) error
}

Interface represents a runnable component.

func NewDownloadController

func NewDownloadController(
	logger logrus.FieldLogger,
	downloadInformer informers.DownloadInformer,
	downloadClient pluginv1client.DownloadsGetter,
	kubeClient kubernetes.Interface,
	dataMover *dataMover.DataMover,
	nodeName string,
) Interface

func NewUploadController

func NewUploadController(
	logger logrus.FieldLogger,
	uploadInformer informers.UploadInformer,
	uploadClient pluginv1client.UploadsGetter,
	kubeClient kubernetes.Interface,
	pvcInformer corev1informers.PersistentVolumeClaimInformer,
	pvInformer corev1informers.PersistentVolumeInformer,
	dataMover *dataMover.DataMover,
	snapMgr *snapshotmgr.SnapshotManager,
	nodeName string,
) Interface