dataflow

Documentation

Index

• Constants
• func Enabled(f featuregate.Feature) bool
• func GenerateNodeAffinity(job *batchv1.Job) (*corev1.NodeAffinity, error)
• func InjectAffinityAnnotation(opAnnotation map[string]string, podAnnotation map[string]string) map[string]string
• func InjectAffinityByRunAfterOp(c client.Client, runAfter *datav1alpha1.OperationRef, opNamespace string, ...) (*v1.Affinity, error)

Constants

const (
	// DataflowAffinity Enable affinity inheritance for dataflow operations.
	DataflowAffinity featuregate.Feature = "DataflowAffinity"
)

Functions

func Enabled

func Enabled(f featuregate.Feature) bool

Enabled is helper for `utilfeature.DefaultFeatureGate.Enabled()`

func GenerateNodeAffinity

func GenerateNodeAffinity(job *batchv1.Job) (*corev1.NodeAffinity, error)

func InjectAffinityAnnotation

func InjectAffinityAnnotation(opAnnotation map[string]string, podAnnotation map[string]string) map[string]string

InjectAffinityAnnotation inject the affinity annotation for the pod.

func InjectAffinityByRunAfterOp

func InjectAffinityByRunAfterOp(c client.Client, runAfter *datav1alpha1.OperationRef, opNamespace string, currentAffinity *v1.Affinity) (*v1.Affinity, error)

InjectAffinityByRunAfterOp inject the affinity based on preceding operation