k8sutils

Documentation

Index

• Constants
• func DeepHashObject(hasher hash.Hash, objectToWrite interface{})
• func DefaultCreateOptions() *client.CreateOptions
• func DefaultPatchOptions() *client.PatchOptions
• func DefaultSubResourceUpdateOptions() *client.UpdateOptions
• func DefaultUpdateOptions() *client.UpdateOptions
• func GetAnnotation(obj client.Object, key string) string
• func GetLabel(obj client.Object, key string) string
• func IsJobCompleted(job *batchv1.Job) bool
• func ObjectToGroupKind(s *runtime.Scheme, o client.Object) (schema.GroupKind, error)
• func ObjectToGroupVersionKind(s *runtime.Scheme, o client.Object) (schema.GroupVersionKind, error)
• func PodHash(podSpec corev1.PodSpec) string
• func PodIsReady(pod *corev1.Pod) bool
• func PodIsScheduled(pod *corev1.Pod) bool
• func ServerSideApply(ctx context.Context, cl client.Client, obj client.Object, ...) error
• func SetAnnotation(obj client.Object, key, value string)
• func SetLabel(obj client.Object, key, value string)

Constants

const ManagerName = "kubeai-manager"

Functions

func DeepHashObject

func DeepHashObject(hasher hash.Hash, objectToWrite interface{})

DeepHashObject writes specified object to hash using the spew library which follows pointers and prints actual values of the nested objects ensuring the hash does not change when a pointer changes. Copied from k8s.io/kubernetes/pkg/util/hash to avoid dependency on k8s.io/kubernetes.

func DefaultCreateOptions

func DefaultCreateOptions() *client.CreateOptions

func DefaultPatchOptions

func DefaultPatchOptions() *client.PatchOptions

func DefaultSubResourceUpdateOptions

func DefaultSubResourceUpdateOptions() *client.UpdateOptions

func DefaultUpdateOptions

func DefaultUpdateOptions() *client.UpdateOptions

func GetAnnotation

func GetAnnotation(obj client.Object, key string) string

func GetLabel

func GetLabel(obj client.Object, key string) string

func IsJobCompleted

func IsJobCompleted(job *batchv1.Job) bool

func ObjectToGroupKind

func ObjectToGroupKind(s *runtime.Scheme, o client.Object) (schema.GroupKind, error)

func ObjectToGroupVersionKind

func ObjectToGroupVersionKind(s *runtime.Scheme, o client.Object) (schema.GroupVersionKind, error)

func PodHash

func PodHash(podSpec corev1.PodSpec) string

PodHash returns a hash value calculated from Pod spec. Inspired by k8s.io/kubernetes/pkg/controller.ComputeHash()

func PodIsReady

func PodIsReady(pod *corev1.Pod) bool

func PodIsScheduled

func PodIsScheduled(pod *corev1.Pod) bool

func ServerSideApply

func ServerSideApply(ctx context.Context, cl client.Client, obj client.Object, controllerName string) error

func SetAnnotation

func SetAnnotation(obj client.Object, key, value string)

func SetLabel

func SetLabel(obj client.Object, key, value string)