resources

func CompareResourceVersion ¶

func CompareResourceVersion(rv1, rv2 string) bool

CompareResourceVersion is used to compare resource version.

func ExtractConfigMap ¶

func ExtractConfigMap(p *corev1.ConfigMap) *corev1.ConfigMap

ExtractConfigMap is used to extract configmap.

func ExtractDomainDataAnnotations ¶

func ExtractDomainDataAnnotations(p *kusciaapisv1alpha1.DomainData) *kusciaapisv1alpha1.DomainData

ExtractDomainDataAnnotations is used to extract domaindata annotations.

func ExtractDomainDataGrantAnnotations ¶

func ExtractDomainDataGrantAnnotations(p *kusciaapisv1alpha1.DomainDataGrant) *kusciaapisv1alpha1.DomainDataGrant

ExtractDomainDataGrantAnnotations is used to extract domaindatagrant annotations.

func ExtractDomainDataGrantLabels ¶

func ExtractDomainDataGrantLabels(p *kusciaapisv1alpha1.DomainDataGrant) *kusciaapisv1alpha1.DomainDataGrant

ExtractDomainDataGrantLabels is used to extract domainadatagrant labels.

func ExtractDomainDataGrantSpec ¶

func ExtractDomainDataGrantSpec(p *kusciaapisv1alpha1.DomainDataGrant) *kusciaapisv1alpha1.DomainDataGrant

ExtractDomainDataGrantSpec is used to extract domaindatagrant spec.

func ExtractDomainDataGrantStatus ¶

func ExtractDomainDataGrantStatus(p *kusciaapisv1alpha1.DomainDataGrant) *kusciaapisv1alpha1.DomainDataGrant

ExtractDomainDataGrantStatus is used to extract domaindatagrant status.

func ExtractDomainDataLabels ¶

func ExtractDomainDataLabels(p *kusciaapisv1alpha1.DomainData) *kusciaapisv1alpha1.DomainData

ExtractDomainDataLabels is used to extract domainadata labels.

func ExtractDomainDataSpec ¶

func ExtractDomainDataSpec(p *kusciaapisv1alpha1.DomainData) *kusciaapisv1alpha1.DomainData

ExtractDomainDataSpec is used to extract domainData spec.

func ExtractPodAnnotations ¶

func ExtractPodAnnotations(p *corev1.Pod) *corev1.Pod

ExtractPodAnnotations is used to extract pod annotations.

func ExtractPodAnnotationsAndLabels ¶

func ExtractPodAnnotationsAndLabels(p *corev1.Pod) *corev1.Pod

ExtractPodAnnotationsAndLabels is used to extract pod annotations and labels.

func ExtractPodLabels ¶

func ExtractPodLabels(p *corev1.Pod) *corev1.Pod

ExtractPodLabels is used to extract pod labels.

func ExtractPodSpec ¶

func ExtractPodSpec(p *corev1.Pod) *corev1.Pod

ExtractPodSpec is used to extract pod spec.

func ExtractPodStatus ¶

func ExtractPodStatus(p *corev1.Pod) *corev1.Pod

ExtractPodStatus is used to extract pod status.

func ExtractService ¶

func ExtractService(p *corev1.Service) *corev1.Service

ExtractService is used to extract service.

func ExtractServiceLabels ¶

func ExtractServiceLabels(p *corev1.Service) *corev1.Service

ExtractServiceLabels is used to extract service labels.

func ExtractTaskResource ¶

func ExtractTaskResource(p *kusciaapisv1alpha1.TaskResource) *kusciaapisv1alpha1.TaskResource

ExtractTaskResource is used to extract task resource.

func ExtractTaskResourceStatus ¶

func ExtractTaskResourceStatus(p *kusciaapisv1alpha1.TaskResource) *kusciaapisv1alpha1.TaskResource

ExtractTaskResourceStatus is used to extract task resource status.

func GenerateServiceName ¶

func GenerateServiceName(prefix, portName string) string

func GetInterConnParties ¶

func GetInterConnParties(annotations map[string]string) map[string]string

func GetInterConnProtocolTypeByPartyAnnotation ¶

func GetInterConnProtocolTypeByPartyAnnotation(key string) kusciaapisv1alpha1.InterConnProtocolType

func GetKusciaJobCondition ¶

func GetKusciaJobCondition(status *kusciaapisv1alpha1.KusciaJobStatus,
	condType kusciaapisv1alpha1.KusciaJobConditionType,
	generateCond bool) (*kusciaapisv1alpha1.KusciaJobCondition, bool)

GetKusciaJobCondition gets kuscia job condition.

func GetKusciaTaskCondition ¶

func GetKusciaTaskCondition(status *kusciaapisv1alpha1.KusciaTaskStatus, condType kusciaapisv1alpha1.KusciaTaskConditionType, generateCond bool) (*kusciaapisv1alpha1.KusciaTaskCondition, bool)

GetKusciaTaskCondition gets kuscia task condition.

func GetMasterDomain ¶

func GetMasterDomain(domainLister kuscialistersv1alpha1.DomainLister, domainID string) (string, error)

GetMasterDomain is used to get master domain id.

func GetTaskResourceCondition ¶

func GetTaskResourceCondition(trStatus *kusciaapisv1alpha1.TaskResourceStatus, condType kusciaapisv1alpha1.TaskResourceConditionType) *kusciaapisv1alpha1.TaskResourceCondition

GetTaskResourceCondition gets task resource condition.

func GetTaskResourceGroupCondition ¶

func GetTaskResourceGroupCondition(trgStatus *kusciaapisv1alpha1.TaskResourceGroupStatus, condType kusciaapisv1alpha1.TaskResourceGroupConditionType) (*kusciaapisv1alpha1.TaskResourceGroupCondition, bool)

GetTaskResourceGroupCondition is used to get task resource group condition.

func HashString ¶

func HashString(input string) (string, error)

func IsExistingTaskResourceGroupCondition ¶

func IsExistingTaskResourceGroupCondition(status *kusciaapisv1alpha1.TaskResourceGroupStatus, condType kusciaapisv1alpha1.TaskResourceGroupConditionType, condStatus corev1.ConditionStatus) bool

IsExistingTaskResourceGroupCondition checks if TaskResourceGroupCondition exists.

func IsOuterBFIAInterConnDomain ¶

func IsOuterBFIAInterConnDomain(nsLister corelisters.NamespaceLister, domainID string) bool

IsOuterBFIAInterConnDomain checks if outer domain with BFIA protocol.

func IsPartnerDomain ¶

func IsPartnerDomain(nsLister corelisters.NamespaceLister, domainID string) bool

IsPartnerDomain check if is partner domain.

func MergeKusciaJobConditions ¶

func MergeKusciaJobConditions(kusciaJob *kusciaapisv1alpha1.KusciaJob, conds []kusciaapisv1alpha1.KusciaJobCondition)

MergeKusciaJobConditions merges kuscia job conditions.

func MergeKusciaJobTaskStatus ¶

func MergeKusciaJobTaskStatus(kusciaJob *kusciaapisv1alpha1.KusciaJob, taskPhase map[string]kusciaapisv1alpha1.KusciaTaskPhase) bool

MergeKusciaJobTaskStatus merges task status of kuscia job.

func MergeKusciaTaskConditions ¶

func MergeKusciaTaskConditions(kusciaTask *kusciaapisv1alpha1.KusciaTask, conds []kusciaapisv1alpha1.KusciaTaskCondition)

MergeKusciaTaskConditions merges kuscia task conditions.

func MergeKusciaTaskPartyTaskStatus ¶

func MergeKusciaTaskPartyTaskStatus(kusciaTask *kusciaapisv1alpha1.KusciaTask, partyTaskStatus []kusciaapisv1alpha1.PartyTaskStatus)

MergeKusciaTaskPartyTaskStatus merges party task status of Kuscia task.

func PatchConfigMap ¶

func PatchConfigMap(ctx context.Context, kubeClient kubernetes.Interface, oldCm, newCm *corev1.ConfigMap) error

PatchConfigMap is used to patch configmap.

func PatchDomainData ¶

func PatchDomainData(ctx context.Context, kusciaClient kusciaclientset.Interface, oldDd, newDd *kusciaapisv1alpha1.DomainData) error

PatchDomainData is used to patch domaindata.

func PatchDomainDataGrant ¶

func PatchDomainDataGrant(ctx context.Context, kusciaClient kusciaclientset.Interface, oldDdg, newDdg *kusciaapisv1alpha1.DomainDataGrant) error

PatchDomainDataGrant is used to patch domaindatagrant.

func PatchDomainDataGrantStatus ¶

func PatchDomainDataGrantStatus(ctx context.Context, kusciaClient kusciaclientset.Interface, oldDbg, newDbg *kusciaapisv1alpha1.DomainDataGrant) error

PatchDomainDataGrantStatus is used to patch domaindatagrant status.

func PatchDomainDataStatus ¶

func PatchDomainDataStatus(ctx context.Context, kusciaClient kusciaclientset.Interface, oldDb, newDb *kusciaapisv1alpha1.DomainData) error

PatchDomainDataStatus is used to patch domaindata status.

func PatchPod ¶

func PatchPod(ctx context.Context, kubeClient kubernetes.Interface, oldPod, newPod *corev1.Pod) error

PatchPod is used to patch pod.

func PatchPodStatus ¶

func PatchPodStatus(ctx context.Context, kubeClient kubernetes.Interface, oldPod, newPod *corev1.Pod) error

PatchPodStatus is used to patch pod status.

func PatchService ¶

func PatchService(ctx context.Context, kubeClient kubernetes.Interface, oldSvc, newSvc *corev1.Service) error

PatchService is used to patch service.

func PatchTaskResource ¶

func PatchTaskResource(ctx context.Context, kusciaClient kusciaclientset.Interface, oldTr, newTr *kusciaapisv1alpha1.TaskResource) error

PatchTaskResource is used to patch task resource.

func PatchTaskResourceGroupStatus ¶

func PatchTaskResourceGroupStatus(ctx context.Context, kusciaClient kusciaclientset.Interface, oldTrg, newTrg *kusciaapisv1alpha1.TaskResourceGroup) error

PatchTaskResourceGroupStatus is used to patch task resource group status.

func SelectDeployTemplate ¶

func SelectDeployTemplate(templates []kusciaapisv1alpha1.DeployTemplate, role string) (*kusciaapisv1alpha1.DeployTemplate, error)

SelectDeployTemplate selects a matching template according to the role. value of templates[i].Role may have the following values: 'client', 'server', 'client,server', ... Matching process:

1. if role [in] template role list, matched.
2. if template role list is empty，template is universal.
3. if role is empty，select the first template.

func SelfClusterAsInitiator ¶

func SelfClusterAsInitiator(nsLister corelisters.NamespaceLister, domainID string, annotations map[string]string) bool

SelfClusterAsInitiator checks if self cluster domain is scheduling party.

func SetKusciaJobCondition ¶

func SetKusciaJobCondition(now metav1.Time, cond *kusciaapisv1alpha1.KusciaJobCondition, status corev1.ConditionStatus, reason, message string)

SetKusciaJobCondition sets kuscia job condition.

func SetKusciaTaskCondition ¶

func SetKusciaTaskCondition(now metav1.Time, cond *kusciaapisv1alpha1.KusciaTaskCondition, condStatus corev1.ConditionStatus, condReason, condMessage string) bool

SetKusciaTaskCondition sets kuscia task condition.

func SetTaskResourceGroupCondition ¶

func SetTaskResourceGroupCondition(now *metav1.Time, cond *kusciaapisv1alpha1.TaskResourceGroupCondition, condStatus corev1.ConditionStatus, condReason string) bool

SetTaskResourceGroupCondition sets task resource group condition.

func UpdateKusciaJob ¶

func UpdateKusciaJob(kusciaClient kusciaclientset.Interface,
	kj *kusciaapisv1alpha1.KusciaJob,
	hasUpdated func(kusciaJob *kusciaapisv1alpha1.KusciaJob) bool,
	update func(kusciaJob *kusciaapisv1alpha1.KusciaJob),
	retries int) (err error)

UpdateKusciaJob updates kuscia job.

func UpdateKusciaJobStage ¶

func UpdateKusciaJobStage(kusciaClient kusciaclientset.Interface,
	kj *kusciaapisv1alpha1.KusciaJob,
	jobStage kusciaapisv1alpha1.JobStage,
	retries int) error

UpdateKusciaJobStage updates kuscia job stage.

func UpdateKusciaJobStatus ¶

func UpdateKusciaJobStatus(kusciaClient kusciaclientset.Interface, rawKj, curKj *kusciaapisv1alpha1.KusciaJob) (err error)

UpdateKusciaJobStatus will update kuscia job status. The function will retry updating if failed.

func UpdateKusciaTaskStatus ¶

func UpdateKusciaTaskStatus(kusciaClient kusciaclientset.Interface, rawKt, curKt *kusciaapisv1alpha1.KusciaTask) (err error)

UpdateKusciaTaskStatus updates kuscia task status.

func UpdateKusciaTaskStatusWithRetry ¶

func UpdateKusciaTaskStatusWithRetry(kusciaClient kusciaclientset.Interface, rawKt, curKt *kusciaapisv1alpha1.KusciaTask, retryCount int) (err error)

UpdateKusciaTaskStatusWithRetry updates kuscia task status with retry.

func UpdateServiceAnnotations ¶

func UpdateServiceAnnotations(kubeClient kubernetes.Interface, service *corev1.Service, at map[string]string) (err error)

UpdateServiceAnnotations updates service annotations.

func ValidateK8sName ¶

func ValidateK8sName(val string, feildName string) error

ValidateK8sName checks dns subdomain names