rules

Documentation

Index

• func Allocation(rule interface{}, taskName string, ruleType string) (*kubeeyev1alpha2.JobRule, error)
• func AllocationRule(rule interface{}, taskName string, allNode []corev1.Node, ctlOrTem string) ([]kubeeyev1alpha2.JobRule, error)
• func GetRules(ctx context.Context, task types.NamespacedName, client versioned.Interface) map[string][]byte
• func MergeRule(rules ...kubeeyev1alpha2.InspectRule) (*kubeeyev1alpha2.InspectRuleSpec, error)
• func ParseRules(ctx context.Context, clients *kube.KubernetesClient, taskName string, ...) ([]kubeeyev1alpha2.JobRule, map[string]int, error)
• func RuleArrayDeduplication[T any](obj interface{}) ([]T, error)
• func TotalServiceNum(ctx context.Context, clients *kube.KubernetesClient, component *string) int

Functions

func Allocation

func Allocation(rule interface{}, taskName string, ruleType string) (*kubeeyev1alpha2.JobRule, error)

func AllocationRule

func AllocationRule(rule interface{}, taskName string, allNode []corev1.Node, ctlOrTem string) ([]kubeeyev1alpha2.JobRule, error)

func GetRules

func GetRules(ctx context.Context, task types.NamespacedName, client versioned.Interface) map[string][]byte

func MergeRule

func MergeRule(rules ...kubeeyev1alpha2.InspectRule) (*kubeeyev1alpha2.InspectRuleSpec, error)

func ParseRules

func ParseRules(ctx context.Context, clients *kube.KubernetesClient, taskName string, ruleGroup []kubeeyev1alpha2.InspectRule) ([]kubeeyev1alpha2.JobRule, map[string]int, error)

func RuleArrayDeduplication

func RuleArrayDeduplication[T any](obj interface{}) ([]T, error)

func TotalServiceNum

func TotalServiceNum(ctx context.Context, clients *kube.KubernetesClient, component *string) int