open-cluster-management/pkg/work/spoke/statusfeedback/rules/rule.go

package rules

import (
	"k8s.io/apimachinery/pkg/runtime/schema"

	workapiv1 "open-cluster-management.io/api/work/v1"
)

type WellKnownStatusRuleResolver interface {
	GetPathsByKind(schema.GroupVersionKind) []workapiv1.JsonPath
}

type DefaultWellKnownStatusResolver struct {
	rules map[schema.GroupVersionKind][]workapiv1.JsonPath
}

var deploymentRule = []workapiv1.JsonPath{
	{
		Name: "ReadyReplicas",
		Path: ".status.readyReplicas",
	},
	{
		Name: "Replicas",
		Path: ".status.replicas",
	},
	{
		Name: "AvailableReplicas",
		Path: ".status.availableReplicas",
	},
}

var daemonsetRule = []workapiv1.JsonPath{
	{
		Name: "NumberReady",
		Path: ".status.numberReady",
	},
	{
		Name: "DesiredNumberScheduled",
		Path: ".status.desiredNumberScheduled",
	},
	{
		Name: "NumberAvailable",
		Path: ".status.numberAvailable",
	},
}

var jobRule = []workapiv1.JsonPath{
	{
		Name: "JobComplete",
		Path: `.status.conditions[?(@.type=="Complete")].status`,
	},
	{
		Name: "JobSucceeded",
		Path: `.status.succeeded`,
	},
}

var podRule = []workapiv1.JsonPath{
	{
		Name: "PodReady",
		Path: `.status.conditions[?(@.type=="Ready")].status`,
	},
	{
		Name: "PodPhase",
		Path: `.status.phase`,
	},
}

func DefaultWellKnownStatusRule() WellKnownStatusRuleResolver {
	return &DefaultWellKnownStatusResolver{
		rules: map[schema.GroupVersionKind][]workapiv1.JsonPath{
			{Group: "apps", Version: "v1", Kind: "Deployment"}: deploymentRule,
			{Group: "batch", Version: "v1", Kind: "Job"}:       jobRule,
			{Group: "", Version: "v1", Kind: "Pod"}:            podRule,
			{Group: "apps", Version: "v1", Kind: "DaemonSet"}:  daemonsetRule,
		},
	}
}

func (w *DefaultWellKnownStatusResolver) GetPathsByKind(gvk schema.GroupVersionKind) []workapiv1.JsonPath {
	return w.rules[gvk]
}