container

Documentation

Index

• Constants
• func GetRole() common.Role
• type DataNodeContainerBuilder
  • func NewDataNodeContainerBuilder(instance *hdfsv1alpha1.HdfsCluster, resource corev1.ResourceRequirements) *DataNodeContainerBuilder
  • func (d *DataNodeContainerBuilder) Command() []string
  • func (d *DataNodeContainerBuilder) CommandArgs() []string
  • func (d *DataNodeContainerBuilder) ContainerEnv() []corev1.EnvVar
  • func (d *DataNodeContainerBuilder) ContainerName() string
  • func (d *DataNodeContainerBuilder) ContainerPorts() []corev1.ContainerPort
  • func (d *DataNodeContainerBuilder) LivenessProbe() *corev1.Probe
  • func (d *DataNodeContainerBuilder) ReadinessProbe() *corev1.Probe
  • func (d *DataNodeContainerBuilder) VolumeMount() []corev1.VolumeMount
• type WaitNameNodeContainerBuilder
  • func NewWaitNameNodeContainerBuilder(instance *hdfsv1alpha1.HdfsCluster, resource corev1.ResourceRequirements, ...) *WaitNameNodeContainerBuilder
  • func (w *WaitNameNodeContainerBuilder) Command() []string
  • func (w *WaitNameNodeContainerBuilder) CommandArgs() []string
  • func (w *WaitNameNodeContainerBuilder) ContainerEnv() []corev1.EnvVar
  • func (w *WaitNameNodeContainerBuilder) ContainerName() string
  • func (w *WaitNameNodeContainerBuilder) VolumeMount() []corev1.VolumeMount

Constants

const (
	DataNode     common.ContainerComponent = common.ContainerComponent(common.DataNode)
	WaitNameNode common.ContainerComponent = "wait-for-namenodes"
)

Functions

func GetRole

func GetRole() common.Role

Types

type DataNodeContainerBuilder

type DataNodeContainerBuilder struct {
	common.ContainerBuilder
	// contains filtered or unexported fields
}

func NewDataNodeContainerBuilder

func NewDataNodeContainerBuilder(
	instance *hdfsv1alpha1.HdfsCluster,
	resource corev1.ResourceRequirements,
) *DataNodeContainerBuilder

func (*DataNodeContainerBuilder) Command

func (d *DataNodeContainerBuilder) Command() []string

func (*DataNodeContainerBuilder) CommandArgs

func (d *DataNodeContainerBuilder) CommandArgs() []string

func (*DataNodeContainerBuilder) ContainerEnv

func (d *DataNodeContainerBuilder) ContainerEnv() []corev1.EnvVar

func (*DataNodeContainerBuilder) ContainerName

func (d *DataNodeContainerBuilder) ContainerName() string

func (*DataNodeContainerBuilder) ContainerPorts

func (d *DataNodeContainerBuilder) ContainerPorts() []corev1.ContainerPort

ContainerPorts make container ports of data node

func (*DataNodeContainerBuilder) LivenessProbe

func (d *DataNodeContainerBuilder) LivenessProbe() *corev1.Probe

func (*DataNodeContainerBuilder) ReadinessProbe

func (d *DataNodeContainerBuilder) ReadinessProbe() *corev1.Probe

func (*DataNodeContainerBuilder) VolumeMount

func (d *DataNodeContainerBuilder) VolumeMount() []corev1.VolumeMount

type WaitNameNodeContainerBuilder

type WaitNameNodeContainerBuilder struct {
	common.ContainerBuilder
	// contains filtered or unexported fields
}

func NewWaitNameNodeContainerBuilder

func NewWaitNameNodeContainerBuilder(
	instance *hdfsv1alpha1.HdfsCluster,
	resource corev1.ResourceRequirements,
	groupName string,
) *WaitNameNodeContainerBuilder

func (*WaitNameNodeContainerBuilder) Command

func (w *WaitNameNodeContainerBuilder) Command() []string

func (*WaitNameNodeContainerBuilder) CommandArgs

func (w *WaitNameNodeContainerBuilder) CommandArgs() []string

func (*WaitNameNodeContainerBuilder) ContainerEnv

func (w *WaitNameNodeContainerBuilder) ContainerEnv() []corev1.EnvVar

func (*WaitNameNodeContainerBuilder) ContainerName

func (w *WaitNameNodeContainerBuilder) ContainerName() string

func (*WaitNameNodeContainerBuilder) VolumeMount

func (w *WaitNameNodeContainerBuilder) VolumeMount() []corev1.VolumeMount