Documentation ¶
Index ¶
- func GetAlluxioConfigMapName(nameOverride, clusterName string) string
- func GetClusterFullName(nameOverride, helmReleaseName string) string
- func GetConfYamlPath(namespacedName types.NamespacedName) string
- func GetFuseDaemonSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
- func GetFuseStatus(ctx ComponentStatusReqCtx) (*v1.DaemonSet, error)
- func GetK8sClient() (*kubernetes.Clientset, error)
- func GetLoadConfigmapName(nameOverride, clusterName string) string
- func GetLoadJobName(loadName string) string
- func GetMasterStatefulSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
- func GetMasterStatus(ctx ComponentStatusReqCtx) (*v1.StatefulSet, error)
- func GetProxyDaemonSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
- func GetProxyStatus(ctx ComponentStatusReqCtx) (*v1.DaemonSet, error)
- func GetUpdateConfigmapName(nameOverride, clusterName string) string
- func GetUpdateJobName(updateName string) string
- func GetWorkerDeploymentNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
- func GetWorkerStatus(ctx ComponentStatusReqCtx) (*v1.Deployment, error)
- func HelmDeleteIfExist(ctx HelmContext) error
- func HelmInstall(ctx HelmContext) error
- func IfHelmReleaseExists(ctx HelmContext) (bool, error)
- type ComponentStatusReqCtx
- type HelmContext
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAlluxioConfigMapName ¶
func GetClusterFullName ¶ added in v1.0.1
GetClusterFullName The same function that constructs alluxio.fullName in helm chart
func GetConfYamlPath ¶
func GetConfYamlPath(namespacedName types.NamespacedName) string
func GetFuseDaemonSetNamespacedName ¶
func GetFuseDaemonSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
func GetFuseStatus ¶ added in v1.0.1
func GetFuseStatus(ctx ComponentStatusReqCtx) (*v1.DaemonSet, error)
func GetK8sClient ¶ added in v1.0.1
func GetK8sClient() (*kubernetes.Clientset, error)
func GetLoadConfigmapName ¶
func GetLoadJobName ¶
func GetMasterStatefulSetNamespacedName ¶
func GetMasterStatefulSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
func GetMasterStatus ¶ added in v1.0.1
func GetMasterStatus(ctx ComponentStatusReqCtx) (*v1.StatefulSet, error)
func GetProxyDaemonSetNamespacedName ¶
func GetProxyDaemonSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
func GetProxyStatus ¶ added in v1.0.1
func GetProxyStatus(ctx ComponentStatusReqCtx) (*v1.DaemonSet, error)
func GetUpdateConfigmapName ¶ added in v1.0.1
func GetUpdateJobName ¶ added in v1.0.1
func GetWorkerDeploymentNamespacedName ¶
func GetWorkerDeploymentNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName
func GetWorkerStatus ¶ added in v1.0.1
func GetWorkerStatus(ctx ComponentStatusReqCtx) (*v1.Deployment, error)
func HelmDeleteIfExist ¶
func HelmDeleteIfExist(ctx HelmContext) error
func HelmInstall ¶
func HelmInstall(ctx HelmContext) error
func IfHelmReleaseExists ¶
func IfHelmReleaseExists(ctx HelmContext) (bool, error)
Types ¶
type ComponentStatusReqCtx ¶ added in v1.0.1
type ComponentStatusReqCtx struct { client.Client context.Context *alluxiov1alpha1.AlluxioCluster types.NamespacedName }
Click to show internal directories.
Click to hide internal directories.