common

Documentation

Index

• Constants
• func GetCurrentTime() *metav1.Time
• func GetInterConnKusciaPartyDomainIDs(obj metav1.Object) []string
• func GetJobStage(stage string) v1alpha1.JobStage
• func GetObjectAnnotation(obj metav1.Object, key string) string
• func GetObjectLabel(obj metav1.Object, key string) string
• func GetObjectNamespaceName(obj metav1.Object) string
• func GetPartyMasterDomains(domainLister kuscialistersv1alpha1.DomainLister, obj metav1.Object) (map[string][]string, error)
• func GetSelfClusterPartyDomainIDs(obj metav1.Object) []string
• func IsOriginalResourceDeleteEvent(key string) (string, bool)
• func SelfClusterIsInitiator(domainLister kuscialistersv1alpha1.DomainLister, obj metav1.Object) (bool, error)
• func UpdateJobStage(job *v1alpha1.KusciaJob, jobSummary *v1alpha1.KusciaJobSummary) bool

Constants

const (
	DeleteEventKeyPrefix = "delete_event:"
)

Functions

func GetCurrentTime

func GetCurrentTime() *metav1.Time

func GetInterConnKusciaPartyDomainIDs

func GetInterConnKusciaPartyDomainIDs(obj metav1.Object) []string

func GetJobStage

func GetJobStage(stage string) v1alpha1.JobStage

func GetObjectAnnotation

func GetObjectAnnotation(obj metav1.Object, key string) string

func GetObjectLabel

func GetObjectLabel(obj metav1.Object, key string) string

func GetObjectNamespaceName

func GetObjectNamespaceName(obj metav1.Object) string

func GetPartyMasterDomains

func GetPartyMasterDomains(domainLister kuscialistersv1alpha1.DomainLister, obj metav1.Object) (map[string][]string, error)

func GetSelfClusterPartyDomainIDs

func GetSelfClusterPartyDomainIDs(obj metav1.Object) []string

func IsOriginalResourceDeleteEvent

func IsOriginalResourceDeleteEvent(key string) (string, bool)

func SelfClusterIsInitiator

func SelfClusterIsInitiator(domainLister kuscialistersv1alpha1.DomainLister, obj metav1.Object) (bool, error)

func UpdateJobStage

func UpdateJobStage(job *v1alpha1.KusciaJob, jobSummary *v1alpha1.KusciaJobSummary) bool