component

Documentation

Index

• type Component
• type ComponentAccessor
  • func BuildExecutorSpec(tc *v1alpha1.TiflowCluster) ComponentAccessor
  • func BuildMasterSpec(tc *v1alpha1.TiflowCluster) ComponentAccessor

Types

type Component

type Component int

Component defines component identity of all components

const (
	ComponentTiflowMaster Component = iota
	ComponentTiflowExecutor
)

type ComponentAccessor

type ComponentAccessor interface {
	ImagePullPolicy() corev1.PullPolicy
	ImagePullSecrets() []corev1.LocalObjectReference
	HostNetwork() bool
	Affinity() *corev1.Affinity
	PriorityClassName() *string
	NodeSelector() map[string]string
	Labels() map[string]string
	Annotations() map[string]string
	Tolerations() []corev1.Toleration
	PodSecurityContext() *corev1.PodSecurityContext
	DnsPolicy() corev1.DNSPolicy
	ConfigUpdateStrategy() v1alpha1.ConfigUpdateStrategy
	BuildPodSpec() corev1.PodSpec
	Env() []corev1.EnvVar
	EnvFrom() []corev1.EnvFromSource
	AdditionalContainers() []corev1.Container
	InitContainers() []corev1.Container
	AdditionalVolumes() []corev1.Volume
	AdditionalVolumeMounts() []corev1.VolumeMount
	TerminationGracePeriodSeconds() *int64
	StatefulSetUpdateStrategy() apps.StatefulSetUpdateStrategyType
	PodManagementPolicy() apps.PodManagementPolicyType
	TopologySpreadConstraints() []corev1.TopologySpreadConstraint
}

ComponentAccessor is the interface to access component details, which respects the cluster-level properties and component-level overrides +output:none

func BuildExecutorSpec

func BuildExecutorSpec(tc *v1alpha1.TiflowCluster) ComponentAccessor

func BuildMasterSpec

func BuildMasterSpec(tc *v1alpha1.TiflowCluster) ComponentAccessor