container

package
v0.0.0-...-ebe3fe6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 10, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

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

func GetRole

func GetRole() common.Role

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL