utils

package

v0.0.259 Latest Latest Go to latest Published: Mar 22, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

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

Repository

github.com/kubescape/storage

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CanonicalHash(in []byte) (string, error)
func MergeMaps[Map ~map[K]V, K comparable, V any](m1, m2 Map, skips ...K) Map
func RemoveManagedFields(d metav1.Object)
func RemoveSpecificFields(d *unstructured.Unstructured, fields [][]string) error
func ValidateCompletionAnnotation(annotations map[string]string) *field.Error
func ValidateStatusAnnotation(annotations map[string]string) *field.Error
type MapMutex
- func NewMapMutex[T comparable]() MapMutex[T]

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ContextNilError            = errors.New("context is nil")
	ContextNotCancellableError = errors.New("context is not cancellable")
	ContextNoTimeoutError      = errors.New("context has no timeout")
	TimeOutError               = errors.New("lock acquisition timed out")
)

Functions ¶

func CanonicalHash ¶ added in v0.0.135

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

func MergeMaps ¶ added in v0.0.199

func MergeMaps[Map ~map[K]V, K comparable, V any](m1, m2 Map, skips ...K) Map

MergeMaps merges m2 key/values into m1 without overriding existing keys

func RemoveManagedFields ¶ added in v0.0.135

func RemoveManagedFields(d metav1.Object)

func RemoveSpecificFields ¶ added in v0.0.135

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

func ValidateCompletionAnnotation ¶ added in v0.0.75

func ValidateCompletionAnnotation(annotations map[string]string) *field.Error

func ValidateStatusAnnotation ¶ added in v0.0.75

func ValidateStatusAnnotation(annotations map[string]string) *field.Error

Types ¶

type MapMutex ¶ added in v0.0.67

type MapMutex[T comparable] struct {
	// contains filtered or unexported fields
}

func NewMapMutex ¶

func NewMapMutex[T comparable]() MapMutex[T]

func (*MapMutex[T]) Lock ¶ added in v0.0.67

func (m *MapMutex[T]) Lock(ctx context.Context, key T) error

func (*MapMutex[T]) RLock ¶ added in v0.0.67

func (m *MapMutex[T]) RLock(ctx context.Context, key T) error

func (*MapMutex[T]) RUnlock ¶ added in v0.0.67

func (m *MapMutex[T]) RUnlock(key T)

func (*MapMutex[T]) Unlock ¶ added in v0.0.67

func (m *MapMutex[T]) Unlock(key T)

release before unlock: release decrements refcount and may delete the map entry under the global lock. The per-key unlock happens after, on the returned pointer. Do NOT reorder — unlocking first would allow a concurrent acquire to find and reuse the entry before the refcount is decremented, preventing eviction.

Source Files ¶

View all Source files

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