container

Documentation

Index

• type FetchNodePortContainerBuilder
  • func NewFetchNodePortContainerBuilder(tlsSecurity *security.KafkaTlsSecurity) *FetchNodePortContainerBuilder
  • func (d *FetchNodePortContainerBuilder) Command() []string
  • func (d *FetchNodePortContainerBuilder) ContainerEnv() []corev1.EnvVar
  • func (d *FetchNodePortContainerBuilder) ContainerName() string
  • func (d *FetchNodePortContainerBuilder) VolumeMount() []corev1.VolumeMount
• type KafkaContainerBuilder
  • func NewKafkaContainerBuilder(image string, imagePullPolicy corev1.PullPolicy, ...) *KafkaContainerBuilder
  • func (d *KafkaContainerBuilder) Command() []string
  • func (d *KafkaContainerBuilder) CommandArgs() []string
  • func (d *KafkaContainerBuilder) ContainerEnv() []corev1.EnvVar
  • func (d *KafkaContainerBuilder) ContainerName() string
  • func (d *KafkaContainerBuilder) ContainerPorts() []corev1.ContainerPort
  • func (d *KafkaContainerBuilder) LaunchCommand(listeners, advertisedListers, lisenerSecurityProtocolMap string) string
  • func (d *KafkaContainerBuilder) LivenessProbe() *corev1.Probe
  • func (d *KafkaContainerBuilder) ReadinessProbe() *corev1.Probe
  • func (d *KafkaContainerBuilder) ResourceRequirements() corev1.ResourceRequirements
  • func (d *KafkaContainerBuilder) VolumeMount() []corev1.VolumeMount

Types

type FetchNodePortContainerBuilder

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

func NewFetchNodePortContainerBuilder

func NewFetchNodePortContainerBuilder(tlsSecurity *security.KafkaTlsSecurity) *FetchNodePortContainerBuilder

func (*FetchNodePortContainerBuilder) Command

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

func (*FetchNodePortContainerBuilder) ContainerEnv

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

func (*FetchNodePortContainerBuilder) ContainerName

func (d *FetchNodePortContainerBuilder) ContainerName() string

func (*FetchNodePortContainerBuilder) VolumeMount

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

type KafkaContainerBuilder

type KafkaContainerBuilder struct {
	common.ContainerBuilder

	*security.KafkaTlsSecurity
	// contains filtered or unexported fields
}

func NewKafkaContainerBuilder

func NewKafkaContainerBuilder(
	image string,
	imagePullPolicy corev1.PullPolicy,
	zookeeperDiscoveryZNode string,
	resourceSpec *kafkav1alpha1.ResourcesSpec,
	tlsSecurity *security.KafkaTlsSecurity,
	namespace string,
	groupSvcName string,
) *KafkaContainerBuilder

func (*KafkaContainerBuilder) Command

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

func (*KafkaContainerBuilder) CommandArgs

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

CommandArgs command args ex: export NODE_PORT=$(cat /kubedoop/tmp/kafka_nodepor

func (*KafkaContainerBuilder) ContainerEnv

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

func (*KafkaContainerBuilder) ContainerName

func (d *KafkaContainerBuilder) ContainerName() string

func (*KafkaContainerBuilder) ContainerPorts

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

ContainerPorts make container ports of data node

func (*KafkaContainerBuilder) LaunchCommand

func (d *KafkaContainerBuilder) LaunchCommand(listeners, advertisedListers, lisenerSecurityProtocolMap string) string

kafka launch command

func (*KafkaContainerBuilder) LivenessProbe

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

func (*KafkaContainerBuilder) ReadinessProbe

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

func (*KafkaContainerBuilder) ResourceRequirements

func (d *KafkaContainerBuilder) ResourceRequirements() corev1.ResourceRequirements

func (*KafkaContainerBuilder) VolumeMount

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