utils

Mar 1, 2024

Changes in this version

+ func FileContent(path string) []byte

+ func FileToUnstructured(path string) *unstructured.Unstructured

+ func RemoveSpecificFields(d *unstructured.Unstructured, fields [][]string) error

Feb 26, 2024

Changes in this version

+ func GreaterOrEqualVersion(a string, b string) bool

+ func IsBatchMessageSupported(version string) bool

Feb 19, 2024

Changes in this version

+ func DeptMsgIdFromContext(ctx context.Context) (int, string)

+ func NewMsgId() string

Jan 18, 2024

Changes in this version

+ func ServePprof()

Jan 9, 2024

Changes in this version

+ var Direct = direct

+ func GetDialer() func(context.Context, string, string) (net.Conn, error)

+ func NewBackOff() backoff.BackOff

Jan 3, 2024

Changes in this version

+ func FilterAndMarshal(d *unstructured.Unstructured) ([]byte, error)

Dec 24, 2023

Changes in this version

+ func RemoveManagedFields(d *unstructured.Unstructured)

Dec 22, 2023

Changes in this version

type CooldownQueue

+ func (q *CooldownQueue) Closed() bool

Dec 11, 2023

Changes in this version

+ func ClientIdentifierFromContext(ctx context.Context) domain.ClientIdentifier

+ func StartLivenessProbe()

+ func StringValueBigger(s1, s2 string) bool

Nov 16, 2023

Changes in this version

+ const DefaultQueueSize

+ const DefaultTTL

+ type CooldownQueue struct

+ ResultChan <-chan watch.Event

+ func NewCooldownQueue(size int, cooldown time.Duration) *CooldownQueue

+ func (q *CooldownQueue) Enqueue(e watch.Event)

+ func (q *CooldownQueue) Stop()

Nov 15, 2023

Changes in this version

+ func ContextFromIdentifiers(parent context.Context, id domain.ClientIdentifier) context.Context

Oct 30, 2023

Changes in this version

+ func CanonicalHash(in []byte) (string, error)

+ func CompareJson(a, b []byte) bool

+ func ContextFromGeneric(generic domain.Generic) context.Context

+ func KeyToNsName(key string) (string, string)

+ func NewClient() (dynamic.Interface, error)

+ func NsNameToKey(ns, name string) string

+ func PulsarMessageIDtoString(msgID pulsar.MessageID) string