Documentation
¶
Index ¶
- func GetWorkersAsStatefulset(client client.Client, key types.NamespacedName) (workers *appsv1.StatefulSet, err error)
- type Helper
- func (e *Helper) BuildWorkersAffinity(workers *appsv1.StatefulSet) (workersToUpdate *appsv1.StatefulSet, err error)
- func (e *Helper) CheckAndSyncFuseStatus(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), ...) (ready bool, err error)
- func (e *Helper) CheckAndSyncMasterStatus(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), ...) (ready bool, err error)
- func (e *Helper) CheckAndSyncWorkerStatus(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), ...) (readyOrPartialReady bool, err error)
- func (e *Helper) CleanUpFuse() (count int, err error)
- func (e *Helper) GetFuseNodes() (nodes []corev1.Node, err error)
- func (e *Helper) GetIpAddressesOfFuse() (ipAddresses []string, err error)
- func (e *Helper) GetIpAddressesOfWorker() (ipAddresses []string, err error)
- func (e *Helper) GetWorkerNodes() (nodes []corev1.Node, err error)
- func (e *Helper) SetupWorkers(runtime base.RuntimeInterface, currentStatus datav1alpha1.RuntimeStatus, ...) (err error)
- func (e *Helper) SyncReplicas(ctx cruntime.ReconcileRequestContext, runtime base.RuntimeInterface, ...) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetWorkersAsStatefulset ¶
func GetWorkersAsStatefulset(client client.Client, key types.NamespacedName) (workers *appsv1.StatefulSet, err error)
GetWorkersAsStatefulset gets workers as statefulset object. if it returns deprecated errors, it indicates that not support anymore.
Types ¶
type Helper ¶
type Helper struct {
// contains filtered or unexported fields
}
The common part of the engine which can be reused
func BuildHelper ¶
func (*Helper) BuildWorkersAffinity ¶
func (e *Helper) BuildWorkersAffinity(workers *appsv1.StatefulSet) (workersToUpdate *appsv1.StatefulSet, err error)
BuildWorkersAffinity builds workers affinity if it doesn't have
func (*Helper) CheckAndSyncFuseStatus ¶ added in v1.0.7
func (e *Helper) CheckAndSyncFuseStatus(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), fuseDsNamespacedName types.NamespacedName) (ready bool, err error)
func (*Helper) CheckAndSyncMasterStatus ¶ added in v1.0.7
func (e *Helper) CheckAndSyncMasterStatus(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), masterStsNamespacedName types.NamespacedName) (ready bool, err error)
func (*Helper) CheckAndSyncWorkerStatus ¶ added in v1.0.7
func (e *Helper) CheckAndSyncWorkerStatus(getRuntimeFn func(client.Client) (base.RuntimeInterface, error), workerStsNamespacedName types.NamespacedName) (readyOrPartialReady bool, err error)
CheckAndSyncWorkerStatus checks the worker statefulset's status and update it to runtime's status accordingly. It returns readyOrPartialReady to indicate if the worker statefulset is (partial) ready or not ready.
func (*Helper) CleanUpFuse ¶
CleanUpFuse will cleanup node label for Fuse.
func (*Helper) GetFuseNodes ¶ added in v0.9.0
GetFuseNodes gets the node of fuses
func (*Helper) GetIpAddressesOfFuse ¶ added in v0.9.0
GetIpAddressesOfFuse gets Ipaddresses from the Fuse Node
func (*Helper) GetIpAddressesOfWorker ¶ added in v0.9.0
GetIpAddressesOfWorker gets Ipaddresses from the Worker Node
func (*Helper) GetWorkerNodes ¶ added in v0.9.0
func (*Helper) SetupWorkers ¶
func (e *Helper) SetupWorkers(runtime base.RuntimeInterface, currentStatus datav1alpha1.RuntimeStatus, workers *appsv1.StatefulSet) (err error)
SetupWorkers checks the desired and current replicas of workers and makes an update over the status by setting phases and conditions. The function calls for a status update and finally returns error if anything unexpected happens.
func (*Helper) SyncReplicas ¶
func (e *Helper) SyncReplicas(ctx cruntime.ReconcileRequestContext, runtime base.RuntimeInterface, currentStatus datav1alpha1.RuntimeStatus, workers *appsv1.StatefulSet) (err error)
CheckWorkersReady checks if workers are ready
Source Files
Directories