Documentation ¶
Index ¶
- Constants
- func ErrorIsNotFound(err error) bool
- type DataStore
- func (s *DataStore) CreateDefaultNode(name string) (*longhorn.Node, error)
- func (s *DataStore) CreateEngine(e *longhorn.Engine) (*longhorn.Engine, error)
- func (s *DataStore) CreateEngineImage(img *longhorn.EngineImage) (*longhorn.EngineImage, error)
- func (s *DataStore) CreateEngineImageDaemonSet(ds *appsv1beta2.DaemonSet) error
- func (s *DataStore) CreateNode(node *longhorn.Node) (*longhorn.Node, error)
- func (s *DataStore) CreateReplica(r *longhorn.Replica) (*longhorn.Replica, error)
- func (s *DataStore) CreateSetting(setting *longhorn.Setting) (*longhorn.Setting, error)
- func (s *DataStore) CreateVolume(v *longhorn.Volume) (*longhorn.Volume, error)
- func (s *DataStore) CreateVolumeCronJob(volumeName string, cronJob *batchv1beta1.CronJob) (*batchv1beta1.CronJob, error)
- func (s *DataStore) DeleteCronJob(cronJobName string) error
- func (s *DataStore) DeleteDaemonSet(name string) error
- func (s *DataStore) DeleteEngine(name string) error
- func (s *DataStore) DeleteEngineImage(name string) error
- func (s *DataStore) DeleteManagerDaemonSet() error
- func (s *DataStore) DeleteNode(name string) error
- func (s *DataStore) DeleteReplica(name string) error
- func (s *DataStore) DeleteVolume(name string) error
- func (s *DataStore) GetCredentialFromSecret(secretName string) (map[string]string, error)
- func (s *DataStore) GetDaemonSet(name string) (*appsv1beta2.DaemonSet, error)
- func (s *DataStore) GetEngine(name string) (*longhorn.Engine, error)
- func (s *DataStore) GetEngineImage(name string) (*longhorn.EngineImage, error)
- func (s *DataStore) GetEngineImageDaemonSet(name string) (*appsv1beta2.DaemonSet, error)
- func (s *DataStore) GetKubernetesNode(name string) (*corev1.Node, error)
- func (s *DataStore) GetManagerDaemonSet() (*appsv1beta2.DaemonSet, error)
- func (s *DataStore) GetManagerNodeIPMap() (map[string]string, error)
- func (s *DataStore) GetNode(name string) (*longhorn.Node, error)
- func (s *DataStore) GetNodeRO(name string) (*longhorn.Node, error)
- func (s *DataStore) GetReplica(name string) (*longhorn.Replica, error)
- func (s *DataStore) GetSetting(sName types.SettingName) (*longhorn.Setting, error)
- func (s *DataStore) GetSettingAsBool(settingName types.SettingName) (bool, error)
- func (s *DataStore) GetSettingAsInt(settingName types.SettingName) (int64, error)
- func (s *DataStore) GetVolume(name string) (*longhorn.Volume, error)
- func (s *DataStore) InitSettings() error
- func (s *DataStore) IsNodeDownOrDeleted(name string) (bool, error)
- func (s *DataStore) ListEngineImages() (map[string]*longhorn.EngineImage, error)
- func (s *DataStore) ListEngines() (map[string]*longhorn.Engine, error)
- func (s *DataStore) ListEnginesByNode(name string) ([]*longhorn.Engine, error)
- func (s *DataStore) ListEvents() ([]*corev1.Event, error)
- func (s *DataStore) ListManagerPods() ([]*corev1.Pod, error)
- func (s *DataStore) ListNodes() (map[string]*longhorn.Node, error)
- func (s *DataStore) ListReplicas() (map[string]*longhorn.Replica, error)
- func (s *DataStore) ListReplicasByNode(name string) (map[string][]*longhorn.Replica, error)
- func (s *DataStore) ListSettings() (map[types.SettingName]*longhorn.Setting, error)
- func (s *DataStore) ListVolumeCronJobROs(volumeName string) (map[string]*batchv1beta1.CronJob, error)
- func (s *DataStore) ListVolumeEngines(volumeName string) (map[string]*longhorn.Engine, error)
- func (s *DataStore) ListVolumeReplicas(volumeName string) (map[string]*longhorn.Replica, error)
- func (s *DataStore) ListVolumes() (map[string]*longhorn.Volume, error)
- func (s *DataStore) ListVolumesRO() ([]*longhorn.Volume, error)
- func (s *DataStore) RemoveFinalizerForEngine(obj *longhorn.Engine) error
- func (s *DataStore) RemoveFinalizerForEngineImage(obj *longhorn.EngineImage) error
- func (s *DataStore) RemoveFinalizerForNode(obj *longhorn.Node) error
- func (s *DataStore) RemoveFinalizerForReplica(obj *longhorn.Replica) error
- func (s *DataStore) RemoveFinalizerForVolume(obj *longhorn.Volume) error
- func (s *DataStore) ResetEngineMonitoringStatus(e *longhorn.Engine) (*longhorn.Engine, error)
- func (s *DataStore) Sync(stopCh <-chan struct{}) bool
- func (s *DataStore) UpdateEngine(e *longhorn.Engine) (*longhorn.Engine, error)
- func (s *DataStore) UpdateEngineImage(img *longhorn.EngineImage) (*longhorn.EngineImage, error)
- func (s *DataStore) UpdateNode(node *longhorn.Node) (*longhorn.Node, error)
- func (s *DataStore) UpdateReplica(r *longhorn.Replica) (*longhorn.Replica, error)
- func (s *DataStore) UpdateSetting(setting *longhorn.Setting) (*longhorn.Setting, error)
- func (s *DataStore) UpdateVolume(v *longhorn.Volume) (*longhorn.Volume, error)
- func (s *DataStore) UpdateVolumeAndOwner(v *longhorn.Volume) (*longhorn.Volume, error)
- func (s *DataStore) UpdateVolumeCronJob(volumeName string, cronJob *batchv1beta1.CronJob) (*batchv1beta1.CronJob, error)
Constants ¶
const ( LonghornVolumeKey = "longhornvolume" // NameMaximumLength restricted the length due to Kubernetes name limitation NameMaximumLength = 40 )
const (
LonghornManagerDaemonSetName = "longhorn-manager"
)
Variables ¶
This section is empty.
Functions ¶
func ErrorIsNotFound ¶ added in v0.3.1
Types ¶
type DataStore ¶
type DataStore struct {
// contains filtered or unexported fields
}
func NewDataStore ¶
func NewDataStore( volumeInformer lhinformers.VolumeInformer, engineInformer lhinformers.EngineInformer, replicaInformer lhinformers.ReplicaInformer, engineImageInformer lhinformers.EngineImageInformer, nodeInformer lhinformers.NodeInformer, settingInformer lhinformers.SettingInformer, lhClient lhclientset.Interface, podInformer coreinformers.PodInformer, cronJobInformer batchinformers_v1beta1.CronJobInformer, daemonSetInformer appsinformers_v1beta2.DaemonSetInformer, kubeClient clientset.Interface, namespace string) *DataStore
func (*DataStore) CreateDefaultNode ¶
CreateDefaultNode will set default directory to node replica mount path
func (*DataStore) CreateEngine ¶
func (*DataStore) CreateEngineImage ¶
func (s *DataStore) CreateEngineImage(img *longhorn.EngineImage) (*longhorn.EngineImage, error)
func (*DataStore) CreateEngineImageDaemonSet ¶
func (s *DataStore) CreateEngineImageDaemonSet(ds *appsv1beta2.DaemonSet) error
func (*DataStore) CreateNode ¶
func (*DataStore) CreateReplica ¶
func (*DataStore) CreateSetting ¶
func (*DataStore) CreateVolume ¶
func (*DataStore) CreateVolumeCronJob ¶
func (s *DataStore) CreateVolumeCronJob(volumeName string, cronJob *batchv1beta1.CronJob) (*batchv1beta1.CronJob, error)
func (*DataStore) DeleteCronJob ¶
func (*DataStore) DeleteDaemonSet ¶ added in v0.3.2
func (*DataStore) DeleteEngine ¶
DeleteEngine won't result in immediately deletion since finalizer was set by default
func (*DataStore) DeleteEngineImage ¶
DeleteEngineImage won't result in immediately deletion since finalizer was set by default
func (*DataStore) DeleteManagerDaemonSet ¶ added in v0.3.2
func (*DataStore) DeleteNode ¶ added in v0.3.1
func (*DataStore) DeleteReplica ¶
DeleteReplica won't result in immediately deletion since finalizer was set by default
func (*DataStore) DeleteVolume ¶
DeleteVolume won't result in immediately deletion since finalizer was set by default
func (*DataStore) GetCredentialFromSecret ¶
func (*DataStore) GetDaemonSet ¶ added in v0.3.2
func (s *DataStore) GetDaemonSet(name string) (*appsv1beta2.DaemonSet, error)
func (*DataStore) GetEngineImage ¶
func (s *DataStore) GetEngineImage(name string) (*longhorn.EngineImage, error)
func (*DataStore) GetEngineImageDaemonSet ¶
func (s *DataStore) GetEngineImageDaemonSet(name string) (*appsv1beta2.DaemonSet, error)
func (*DataStore) GetKubernetesNode ¶ added in v0.3.1
func (*DataStore) GetManagerDaemonSet ¶ added in v0.3.2
func (s *DataStore) GetManagerDaemonSet() (*appsv1beta2.DaemonSet, error)
func (*DataStore) GetManagerNodeIPMap ¶
func (*DataStore) GetReplica ¶
func (*DataStore) GetSetting ¶
GetSetting will automatically fill the non-existing setting if it's a valid setting name. The function will not return nil for *longhorn.Setting when error is nil
func (*DataStore) GetSettingAsBool ¶ added in v0.3.2
func (s *DataStore) GetSettingAsBool(settingName types.SettingName) (bool, error)
func (*DataStore) GetSettingAsInt ¶
func (s *DataStore) GetSettingAsInt(settingName types.SettingName) (int64, error)
func (*DataStore) InitSettings ¶ added in v0.3.2
func (*DataStore) IsNodeDownOrDeleted ¶ added in v0.3.2
func (*DataStore) ListEngineImages ¶
func (s *DataStore) ListEngineImages() (map[string]*longhorn.EngineImage, error)
func (*DataStore) ListEngines ¶ added in v0.3.2
func (*DataStore) ListEnginesByNode ¶ added in v0.3.1
func (*DataStore) ListReplicas ¶ added in v0.3.2
func (*DataStore) ListReplicasByNode ¶
func (*DataStore) ListSettings ¶
func (*DataStore) ListVolumeCronJobROs ¶
func (s *DataStore) ListVolumeCronJobROs(volumeName string) (map[string]*batchv1beta1.CronJob, error)
ListVolumeCronJobROs returns a map of read-only CronJobs for the volume
func (*DataStore) ListVolumeEngines ¶
func (*DataStore) ListVolumeReplicas ¶
func (*DataStore) ListVolumes ¶
func (*DataStore) ListVolumesRO ¶ added in v0.3.2
func (*DataStore) RemoveFinalizerForEngine ¶
RemoveFinalizerForEngine will result in deletion if DeletionTimestamp was set
func (*DataStore) RemoveFinalizerForEngineImage ¶
func (s *DataStore) RemoveFinalizerForEngineImage(obj *longhorn.EngineImage) error
RemoveFinalizerForEngineImage will result in deletion if DeletionTimestamp was set
func (*DataStore) RemoveFinalizerForNode ¶
RemoveFinalizerForNode will result in deletion if DeletionTimestamp was set
func (*DataStore) RemoveFinalizerForReplica ¶
RemoveFinalizerForReplica will result in deletion if DeletionTimestamp was set
func (*DataStore) RemoveFinalizerForVolume ¶
RemoveFinalizerForVolume will result in deletion if DeletionTimestamp was set
func (*DataStore) ResetEngineMonitoringStatus ¶
func (*DataStore) UpdateEngine ¶
func (*DataStore) UpdateEngineImage ¶
func (s *DataStore) UpdateEngineImage(img *longhorn.EngineImage) (*longhorn.EngineImage, error)
func (*DataStore) UpdateNode ¶
func (*DataStore) UpdateReplica ¶
func (*DataStore) UpdateSetting ¶
func (*DataStore) UpdateVolume ¶
func (*DataStore) UpdateVolumeAndOwner ¶
func (*DataStore) UpdateVolumeCronJob ¶
func (s *DataStore) UpdateVolumeCronJob(volumeName string, cronJob *batchv1beta1.CronJob) (*batchv1beta1.CronJob, error)