apis

type ControllerManager interface {
	Run(stopCh <-chan struct{})

	VolumeScheduler() apisv1alpha1.VolumeScheduler

	VolumeGroupManager() apisv1alpha1.VolumeGroupManager

	ReconcileNode(node *apisv1alpha1.LocalStorageNode)

	ReconcileVolume(vol *apisv1alpha1.LocalVolume)

	ReconcileVolumeGroup(volGroup *apisv1alpha1.LocalVolumeGroup)

	ReconcileVolumeExpand(expand *apisv1alpha1.LocalVolumeExpand)

	ReconcileVolumeMigrate(migrate *apisv1alpha1.LocalVolumeMigrate)

	ReconcileVolumeGroupMigrate(lvgmigrate *apisv1alpha1.LocalVolumeGroupMigrate)

	ReconcileVolumeConvert(convert *apisv1alpha1.LocalVolumeConvert)

	ReconcileVolumeGroupConvert(lvgconvert *apisv1alpha1.LocalVolumeGroupConvert)
}

type LocalStorageMember interface {
	Run(stopCh <-chan struct{})

	// ******  configuration ******* //
	ConfigureBase(name string, namespace string, haSystemConfig apisv1alpha1.SystemConfig, cli client.Client, informersCache cache.Cache) LocalStorageMember

	ConfigureNode() LocalStorageMember

	ConfigureController(scheme *runtime.Scheme) LocalStorageMember

	ConfigureCSIDriver(driverName string, sockAddr string) LocalStorageMember

	ConfigureRESTServer(httpPort int) LocalStorageMember

	// access the modules
	Controller() ControllerManager

	Node() NodeManager

	Name() string

	Version() string

	DriverName() string
}

type NodeManager interface {
	Run(stopCh <-chan struct{})

	Storage() *nodestorage.LocalManager

	TakeVolumeReplicaTaskAssignment(vol *apisv1alpha1.LocalVolume)

	ReconcileVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica)
}