Versions in this module Expand all Collapse all v0 v0.8.0 Mar 10, 2024 Changes in this version + const DefaultHiveUser + const DefaultKyuubiUser + var DefaultHdfsUserList = []string v0.7.0 Feb 4, 2024 Changes in this version + const CoreSiteDefaultConfFile + const CurrentHdfsVersion + const DefaultClusterDomain + const DefaultClusterDomainName + const DefaultClusterSign + const DefaultConfigNameSuffix + const DefaultCoreSiteFile + const DefaultDiskNum + const DefaultHaReplicas + const DefaultHdfsLogVolumeSize + const DefaultHdfsParentZnodePrefix + const DefaultHdfsSiteFile + const DefaultHdfsVolumeSize + const DefaultHeadlessSvcNameSuffix + const DefaultHttpFSSiteFile + const DefaultIOBufferSize + const DefaultLivenessProbeFailureThreshold + const DefaultLivenessProbeInitialDelaySeconds + const DefaultLivenessProbePeriodSeconds + const DefaultLivenessProbeSuccessThreshold + const DefaultLivenessProbeTimeoutSeconds + const DefaultLogVolumeName + const DefaultMaxWaitSeconds + const DefaultNameService + const DefaultNameSuffix + const DefaultQuorumReplicas + const DefaultReadinessProbeFailureThreshold + const DefaultReadinessProbeInitialDelaySeconds + const DefaultReadinessProbePeriodSeconds + const DefaultReadinessProbeSuccessThreshold + const DefaultReadinessProbeTimeoutSeconds + const DefaultReplicas + const DefaultStorageClass + const DefaultTerminationGracePeriod + const DefaultWebUIUser + const HdfsConfDir + const HdfsDataPath + const HdfsDiskPathPrefix + const HdfsHomeDir + const HdfsLogsDir + const HdfsProbeTypeLiveness + const HdfsProbeTypeReadiness + const HdfsRoleAll + const HdfsRoleDataNode + const HdfsRoleHttpFS + const HdfsRoleJournalNode + const HdfsRoleNameNode + const HdfsSiteDefaultConfFile + const HttpFSSiteDefaultConfFile + const HttpFSTempDir + var CustomizableCoreSiteConfKeyPrefixs = []string + var CustomizableHdfsSiteConfKeyPrefixs = []string + var DefaultNamedPort = map[string]int32 + var DefaultNamedPortConfKey = map[string]string + var HDFSRole2Prefix = map[string]string + var HDFS_HA = "false" + var JN_NODES = "" + var JN_RPC_PORT = "8485" + var NN0_NODE = "" + var NN1_NODE = "" + var NN_RPC_PORT = "8020" + var ZK_CLIENT_PORT = "2181" + var ZK_NODES = "" + func CheckHdfsHA(cluster *hdfsv1.HdfsCluster) bool + func ClusterResourceLabels(cluster *hdfsv1.HdfsCluster, role string) map[string]string + func ClusterResourceName(cluster *hdfsv1.HdfsCluster, suffixs ...string) string + func DefaultEnvVars(role string) []corev1.EnvVar + func DefaultXml2Map() (map[string]string, map[string]string, map[string]string, error) + func FillJNEnvs(qjournal string) + func FillNNEnvs(hdfsSite map[string]string) + func FillZKEnvs(zkEndpoints string, zkReplicas int) + func GetClusterDomain(cluster *hdfsv1.HdfsCluster) string + func GetRefZookeeperInfo(cluster *hdfsv1.HdfsCluster) (int, string, error) + func GetReplicas(cluster *hdfsv1.HdfsCluster, role string) int32 + func GetStorageClassName(cluster *hdfsv1.HdfsCluster) string + func LogInfoInterval(ctx context.Context, interval int, msg string) + type HdfsClusterReconciler struct + Scheme *runtime.Scheme + func (r *HdfsClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HdfsClusterReconciler) SetupWithManager(mgr ctrl.Manager) error + type XmlConfiguration struct + Properties []XmlProperty + XmlName xml.Name + type XmlProperty struct + Name string + Value string
Go to main page