container

Documentation

Index

• type DataNodeComponent
  • func (c *DataNodeComponent) GetArgs() []string
  • func (c *DataNodeComponent) GetCommand() []string
  • func (c *DataNodeComponent) GetContainerName() string
  • func (c *DataNodeComponent) GetEnvVars() []corev1.EnvVar
  • func (c *DataNodeComponent) GetLivenessProbe() *corev1.Probe
  • func (c *DataNodeComponent) GetPorts() []corev1.ContainerPort
  • func (c *DataNodeComponent) GetReadinessProbe() *corev1.Probe
  • func (c *DataNodeComponent) GetStartupProbe() *corev1.Probe
  • func (c *DataNodeComponent) GetVolumeMounts() []corev1.VolumeMount
• type DataNodeContainerBuilder
  • func NewDataNodeContainerBuilder(instance *hdfsv1alpha1.HdfsCluster, roleGroupInfo *reconciler.RoleGroupInfo, ...) *DataNodeContainerBuilder
  • func (b *DataNodeContainerBuilder) Build() *corev1.Container
• type WaitForNameNodesComponent
  • func (c *WaitForNameNodesComponent) GetArgs() []string
  • func (c *WaitForNameNodesComponent) GetCommand() []string
  • func (c *WaitForNameNodesComponent) GetContainerName() string
  • func (c *WaitForNameNodesComponent) GetEnvVars() []corev1.EnvVar
  • func (c *WaitForNameNodesComponent) GetVolumeMounts() []corev1.VolumeMount
• type WaitForNameNodesContainerBuilder
  • func NewWaitForNameNodesContainerBuilder(instance *hdfsv1alpha1.HdfsCluster, roleGroupInfo *reconciler.RoleGroupInfo, ...) *WaitForNameNodesContainerBuilder
  • func (b *WaitForNameNodesContainerBuilder) Build() *corev1.Container

Types

type DataNodeComponent

type DataNodeComponent struct {
	// contains filtered or unexported fields
}

DataNodeComponent implements the component interface for DataNode

func (*DataNodeComponent) GetArgs

func (c *DataNodeComponent) GetArgs() []string

func (*DataNodeComponent) GetCommand

func (c *DataNodeComponent) GetCommand() []string

func (*DataNodeComponent) GetContainerName

func (c *DataNodeComponent) GetContainerName() string

func (*DataNodeComponent) GetEnvVars

func (c *DataNodeComponent) GetEnvVars() []corev1.EnvVar

func (*DataNodeComponent) GetLivenessProbe

func (c *DataNodeComponent) GetLivenessProbe() *corev1.Probe

func (*DataNodeComponent) GetPorts

func (c *DataNodeComponent) GetPorts() []corev1.ContainerPort

func (*DataNodeComponent) GetReadinessProbe

func (c *DataNodeComponent) GetReadinessProbe() *corev1.Probe

func (*DataNodeComponent) GetStartupProbe

func (c *DataNodeComponent) GetStartupProbe() *corev1.Probe

func (*DataNodeComponent) GetVolumeMounts

func (c *DataNodeComponent) GetVolumeMounts() []corev1.VolumeMount

type DataNodeContainerBuilder

type DataNodeContainerBuilder struct {
	// contains filtered or unexported fields
}

DataNodeContainerBuilder builds datanode containers

func NewDataNodeContainerBuilder

func NewDataNodeContainerBuilder(
	instance *hdfsv1alpha1.HdfsCluster,
	roleGroupInfo *reconciler.RoleGroupInfo,
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
	image *oputil.Image,
) *DataNodeContainerBuilder

NewDataNodeContainerBuilder creates a new datanode container builder

func (*DataNodeContainerBuilder) Build

func (b *DataNodeContainerBuilder) Build() *corev1.Container

Build builds the datanode container

type WaitForNameNodesComponent

type WaitForNameNodesComponent struct {
	// contains filtered or unexported fields
}

WaitForNameNodesComponent implements the component interface for wait-for-namenodes

func (*WaitForNameNodesComponent) GetArgs

func (c *WaitForNameNodesComponent) GetArgs() []string

func (*WaitForNameNodesComponent) GetCommand

func (c *WaitForNameNodesComponent) GetCommand() []string

func (*WaitForNameNodesComponent) GetContainerName

func (c *WaitForNameNodesComponent) GetContainerName() string

func (*WaitForNameNodesComponent) GetEnvVars

func (c *WaitForNameNodesComponent) GetEnvVars() []corev1.EnvVar

func (*WaitForNameNodesComponent) GetVolumeMounts

func (c *WaitForNameNodesComponent) GetVolumeMounts() []corev1.VolumeMount

type WaitForNameNodesContainerBuilder

type WaitForNameNodesContainerBuilder struct {
	// contains filtered or unexported fields
}

WaitForNameNodesContainerBuilder builds wait-for-namenodes init containers

func NewWaitForNameNodesContainerBuilder

func NewWaitForNameNodesContainerBuilder(
	instance *hdfsv1alpha1.HdfsCluster,
	roleGroupInfo *reconciler.RoleGroupInfo,
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
	image *oputil.Image,
) *WaitForNameNodesContainerBuilder

NewWaitForNameNodesContainerBuilder creates a new wait-for-namenodes container builder

func (*WaitForNameNodesContainerBuilder) Build

func (b *WaitForNameNodesContainerBuilder) Build() *corev1.Container

Build builds the wait-for-namenodes container