utils

package

v0.7.4 Latest Latest Go to latest Published: Jun 30, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/KusionStack/kuperator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func BeginOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, ...) (bool, error)
func CancelOpsLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, ...) error
func ConvertErrMapToList(errMap map[string]error) []error
func ConvertSyncErrMap(errMap *sync.Map) map[string]error
func EnqueueOperationJobFromPod(c client.Client, pod *corev1.Pod, q *workqueue.RateLimitingInterface, ...)
func FinishOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, ...) error
func IsJobFinished(instance *appsv1alpha1.OperationJob) bool
func MapOpsStatusByPod(instance *appsv1alpha1.OperationJob) map[string]*appsv1alpha1.OpsStatus
func SetOpsStatusError(candidate *opscore.OpsCandidate, reason, message string)
func UpdatePodWithRetry(ctx context.Context, c client.Client, obj client.Object, ...) error

Constants ¶

View Source

const (
	ReasonUpdateObjectFailed = "UpdateObjectFailed"
	ReasonGetObjectFailed    = "GetObjectFailed"
)

Variables ¶

View Source

var StatusUpToDateExpectation = expectations.NewResourceVersionExpectation()

Functions ¶

func BeginOperateLifecycle ¶

func BeginOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, pod *corev1.Pod) (bool, error)

func CancelOpsLifecycle ¶

func CancelOpsLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, pod *corev1.Pod) error

func ConvertErrMapToList ¶ added in v0.6.1

func ConvertErrMapToList(errMap map[string]error) []error

func ConvertSyncErrMap ¶ added in v0.6.1

func ConvertSyncErrMap(errMap *sync.Map) map[string]error

func EnqueueOperationJobFromPod ¶

func EnqueueOperationJobFromPod(c client.Client, pod *corev1.Pod, q *workqueue.RateLimitingInterface, fn func(client.Client, *corev1.Pod) (sets.String, bool))

func FinishOperateLifecycle ¶

func FinishOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, pod *corev1.Pod) error

func IsJobFinished ¶

func IsJobFinished(instance *appsv1alpha1.OperationJob) bool

func MapOpsStatusByPod ¶

func MapOpsStatusByPod(instance *appsv1alpha1.OperationJob) map[string]*appsv1alpha1.OpsStatus

func SetOpsStatusError ¶ added in v0.6.0

func SetOpsStatusError(candidate *opscore.OpsCandidate, reason, message string)

func UpdatePodWithRetry ¶ added in v0.6.1

func UpdatePodWithRetry(ctx context.Context, c client.Client, obj client.Object, updateFn func(*corev1.Pod)) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL