utils

Documentation

Index

• func Chunks[T any](in []T, size int) [][]T
• func FindPodStatusCondition(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) *corev1.PodCondition
• func GetNewConditions(conditions []v1.Condition, newCond v1.Condition) []v1.Condition
• func LatticeServiceName(k8sSourceRouteName string, k8sSourceRouteNamespace string) string
• func PodHasReadinessGate(pod *corev1.Pod, conditionType corev1.PodConditionType) bool
• func RandomAlphaString(length int) string
• func SetPodStatusCondition(conditions *[]corev1.PodCondition, newCondition corev1.PodCondition)
• func SliceFilter[T any](in []T, f FilterFunc[T]) []T
• func SliceMap[T any, U any](in []T, f MapFunc[T, U]) []U
• func SliceMapToPtr[T any](in []T) []*T
• func TargetRefToLatticeResourceName(targetRef *gwv1alpha2.NamespacedPolicyTargetReference, parentNamespace string) (string, error)
• func Truncate(name string, length int) string
• type FilterFunc
• type Item
• type MapFunc
• type PriorityQueue
  • func (pq PriorityQueue) Len() int
  • func (pq PriorityQueue) Less(i, j int) bool
  • func (pq *PriorityQueue) Peek() (*Item, error)
  • func (pq *PriorityQueue) Pop() any
  • func (pq *PriorityQueue) Push(x any)
  • func (pq PriorityQueue) Swap(i, j int)
• type Set
  • func NewSet[T comparable](objs ...T) Set[T]
  • func (s *Set[T]) Contains(t T) bool
  • func (s *Set[T]) Delete(t T)
  • func (s *Set[T]) Items() []T
  • func (s *Set[T]) Put(t T)

Functions

func Chunks

func Chunks[T any](in []T, size int) [][]T

func FindPodStatusCondition

func FindPodStatusCondition(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) *corev1.PodCondition

Copied from: k8s.io/apimachinery/pkg/apis/meta

func GetNewConditions

func GetNewConditions(conditions []v1.Condition, newCond v1.Condition) []v1.Condition

func LatticeServiceName

func LatticeServiceName(k8sSourceRouteName string, k8sSourceRouteNamespace string) string

func PodHasReadinessGate

func PodHasReadinessGate(pod *corev1.Pod, conditionType corev1.PodConditionType) bool

func RandomAlphaString

func RandomAlphaString(length int) string

func SetPodStatusCondition

func SetPodStatusCondition(conditions *[]corev1.PodCondition, newCondition corev1.PodCondition)

Copied from: k8s.io/apimachinery/pkg/apis/meta

func SliceFilter

func SliceFilter[T any](in []T, f FilterFunc[T]) []T

func SliceMap

func SliceMap[T any, U any](in []T, f MapFunc[T, U]) []U

func SliceMapToPtr

func SliceMapToPtr[T any](in []T) []*T

func TargetRefToLatticeResourceName

func TargetRefToLatticeResourceName(
	targetRef *gwv1alpha2.NamespacedPolicyTargetReference,
	parentNamespace string,
) (string, error)

func Truncate

func Truncate(name string, length int) string

Types

type FilterFunc

type FilterFunc[T any] func(T) bool

type Item

type Item struct {
	Value    any
	Priority int32 // The priority of the item in the queue.
	// The Index is needed by update and is maintained by the heap.Interface methods.
	Index int // The Index of the item in the heap.
}

An Item is something we manage in a priority queue.

type MapFunc

type MapFunc[T any, U any] func(T) U

type PriorityQueue

type PriorityQueue []*Item

A PriorityQueue implements heap.Interface and holds Items.

func (PriorityQueue) Len

func (pq PriorityQueue) Len() int

func (PriorityQueue) Less

func (pq PriorityQueue) Less(i, j int) bool

func (*PriorityQueue) Peek

func (pq *PriorityQueue) Peek() (*Item, error)

Peek returns the highest priority item without removing it from the queue. Returns nil and an error if the queue is empty.

func (*PriorityQueue) Pop

func (pq *PriorityQueue) Pop() any

func (*PriorityQueue) Push

func (pq *PriorityQueue) Push(x any)

func (PriorityQueue) Swap

func (pq PriorityQueue) Swap(i, j int)

type Set

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

func NewSet

func NewSet[T comparable](objs ...T) Set[T]

func (*Set[T]) Contains

func (s *Set[T]) Contains(t T) bool

func (*Set[T]) Delete

func (s *Set[T]) Delete(t T)

func (*Set[T]) Items

func (s *Set[T]) Items() []T

func (*Set[T]) Put

func (s *Set[T]) Put(t T)