Documentation ¶
Index ¶
- Constants
- func GetRole() common.Role
- type FormatNameNodeContainerBuilder
- func (f *FormatNameNodeContainerBuilder) Command() []string
- func (f *FormatNameNodeContainerBuilder) CommandArgs() []string
- func (f *FormatNameNodeContainerBuilder) ContainerEnv() []corev1.EnvVar
- func (f *FormatNameNodeContainerBuilder) ContainerName() string
- func (f *FormatNameNodeContainerBuilder) PodNames() []string
- func (f *FormatNameNodeContainerBuilder) VolumeMount() []corev1.VolumeMount
- type FormatZookeeperContainerBuilder
- func (z *FormatZookeeperContainerBuilder) Command() []string
- func (z *FormatZookeeperContainerBuilder) CommandArgs() []string
- func (z *FormatZookeeperContainerBuilder) ContainerEnv() []corev1.EnvVar
- func (z *FormatZookeeperContainerBuilder) ContainerName() string
- func (z *FormatZookeeperContainerBuilder) VolumeMount() []corev1.VolumeMount
- type NameNodeContainerBuilder
- func (n *NameNodeContainerBuilder) Command() []string
- func (n *NameNodeContainerBuilder) CommandArgs() []string
- func (n *NameNodeContainerBuilder) ContainerEnv() []corev1.EnvVar
- func (n *NameNodeContainerBuilder) ContainerName() string
- func (n *NameNodeContainerBuilder) ContainerPorts() []corev1.ContainerPort
- func (n *NameNodeContainerBuilder) LivenessProbe() *corev1.Probe
- func (n *NameNodeContainerBuilder) ReadinessProbe() *corev1.Probe
- func (n *NameNodeContainerBuilder) VolumeMount() []corev1.VolumeMount
- type ZkfcContainerBuilder
Constants ¶
View Source
const ( Zkfc common.ContainerComponent = "zkfc" NameNode common.ContainerComponent = common.ContainerComponent(common.NameNode) FormatNameNode common.ContainerComponent = "format-namenodes" FormatZookeeper common.ContainerComponent = "format-zookeeper" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type FormatNameNodeContainerBuilder ¶
type FormatNameNodeContainerBuilder struct { common.ContainerBuilder // contains filtered or unexported fields }
FormatNameNodeContainerBuilder container builder
func NewFormatNameNodeContainerBuilder ¶
func NewFormatNameNodeContainerBuilder( instance *hdfsv1alpha1.HdfsCluster, resource corev1.ResourceRequirements, nameNodeReplicates int32, statefulSetName string, ) *FormatNameNodeContainerBuilder
func (*FormatNameNodeContainerBuilder) Command ¶
func (f *FormatNameNodeContainerBuilder) Command() []string
func (*FormatNameNodeContainerBuilder) CommandArgs ¶
func (f *FormatNameNodeContainerBuilder) CommandArgs() []string
func (*FormatNameNodeContainerBuilder) ContainerEnv ¶
func (f *FormatNameNodeContainerBuilder) ContainerEnv() []corev1.EnvVar
func (*FormatNameNodeContainerBuilder) ContainerName ¶
func (f *FormatNameNodeContainerBuilder) ContainerName() string
func (*FormatNameNodeContainerBuilder) PodNames ¶
func (f *FormatNameNodeContainerBuilder) PodNames() []string
func (*FormatNameNodeContainerBuilder) VolumeMount ¶
func (f *FormatNameNodeContainerBuilder) VolumeMount() []corev1.VolumeMount
type FormatZookeeperContainerBuilder ¶
type FormatZookeeperContainerBuilder struct { common.ContainerBuilder // contains filtered or unexported fields }
FormatZookeeperContainerBuilder container builder
func NewFormatZookeeperContainerBuilder ¶
func NewFormatZookeeperContainerBuilder( instance *hdfsv1alpha1.HdfsCluster, resource corev1.ResourceRequirements, zookeeperConfigMapName string, ) *FormatZookeeperContainerBuilder
func (*FormatZookeeperContainerBuilder) Command ¶
func (z *FormatZookeeperContainerBuilder) Command() []string
func (*FormatZookeeperContainerBuilder) CommandArgs ¶
func (z *FormatZookeeperContainerBuilder) CommandArgs() []string
func (*FormatZookeeperContainerBuilder) ContainerEnv ¶
func (z *FormatZookeeperContainerBuilder) ContainerEnv() []corev1.EnvVar
func (*FormatZookeeperContainerBuilder) ContainerName ¶
func (z *FormatZookeeperContainerBuilder) ContainerName() string
func (*FormatZookeeperContainerBuilder) VolumeMount ¶
func (z *FormatZookeeperContainerBuilder) VolumeMount() []corev1.VolumeMount
type NameNodeContainerBuilder ¶
type NameNodeContainerBuilder struct { common.ContainerBuilder // contains filtered or unexported fields }
func NewNameNodeContainerBuilder ¶
func NewNameNodeContainerBuilder( instance *hdfsv1alpha1.HdfsCluster, resource corev1.ResourceRequirements) *NameNodeContainerBuilder
func (*NameNodeContainerBuilder) Command ¶
func (n *NameNodeContainerBuilder) Command() []string
func (*NameNodeContainerBuilder) CommandArgs ¶
func (n *NameNodeContainerBuilder) CommandArgs() []string
func (*NameNodeContainerBuilder) ContainerEnv ¶
func (n *NameNodeContainerBuilder) ContainerEnv() []corev1.EnvVar
func (*NameNodeContainerBuilder) ContainerName ¶
func (n *NameNodeContainerBuilder) ContainerName() string
func (*NameNodeContainerBuilder) ContainerPorts ¶
func (n *NameNodeContainerBuilder) ContainerPorts() []corev1.ContainerPort
ContainerPorts make container ports of name node
func (*NameNodeContainerBuilder) LivenessProbe ¶
func (n *NameNodeContainerBuilder) LivenessProbe() *corev1.Probe
func (*NameNodeContainerBuilder) ReadinessProbe ¶
func (n *NameNodeContainerBuilder) ReadinessProbe() *corev1.Probe
func (*NameNodeContainerBuilder) VolumeMount ¶
func (n *NameNodeContainerBuilder) VolumeMount() []corev1.VolumeMount
type ZkfcContainerBuilder ¶
type ZkfcContainerBuilder struct { common.ContainerBuilder // contains filtered or unexported fields }
zkfc container builder
func NewZkfcContainerBuilder ¶
func NewZkfcContainerBuilder( instance *hdfsv1alpha1.HdfsCluster, resource corev1.ResourceRequirements, ) *ZkfcContainerBuilder
func (*ZkfcContainerBuilder) Command ¶
func (z *ZkfcContainerBuilder) Command() []string
func (*ZkfcContainerBuilder) CommandArgs ¶
func (z *ZkfcContainerBuilder) CommandArgs() []string
CommandArgs zookeeper fail-over controller command args
func (*ZkfcContainerBuilder) ContainerEnv ¶
func (z *ZkfcContainerBuilder) ContainerEnv() []corev1.EnvVar
func (*ZkfcContainerBuilder) ContainerName ¶
func (z *ZkfcContainerBuilder) ContainerName() string
func (*ZkfcContainerBuilder) VolumeMount ¶
func (z *ZkfcContainerBuilder) VolumeMount() []corev1.VolumeMount
Click to show internal directories.
Click to hide internal directories.