Versions in this module Expand all Collapse all v1 v1.0.1 Sep 7, 2023 Changes in this version + func GetClusterFullName(nameOverride, helmReleaseName string) string + func GetFuseStatus(ctx ComponentStatusReqCtx) (*v1.DaemonSet, error) + func GetK8sClient() (*kubernetes.Clientset, error) + func GetMasterStatus(ctx ComponentStatusReqCtx) (*v1.StatefulSet, error) + func GetProxyStatus(ctx ComponentStatusReqCtx) (*v1.DaemonSet, error) + func GetUpdateConfigmapName(nameOverride, clusterName string) string + func GetUpdateJobName(updateName string) string + func GetWorkerStatus(ctx ComponentStatusReqCtx) (*v1.Deployment, error) + type ComponentStatusReqCtx struct v1.0.0 Jun 14, 2023 Changes in this version + func GetAlluxioConfigMapName(nameOverride, clusterName string) string + func GetConfYamlPath(namespacedName types.NamespacedName) string + func GetFuseDaemonSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName + func GetLoadConfigmapName(nameOverride, clusterName string) string + func GetLoadJobName(loadName string) string + func GetMasterStatefulSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName + func GetProxyDaemonSetNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName + func GetWorkerDeploymentNamespacedName(nameOverride string, clusterNamespacedName types.NamespacedName) types.NamespacedName + func HelmDeleteIfExist(ctx HelmContext) error + func HelmInstall(ctx HelmContext) error + func IfHelmReleaseExists(ctx HelmContext) (bool, error) + type HelmContext struct + ConfigFilePath string + HelmChartPath string + Namespace string + ReleaseName string