Versions in this module Expand all Collapse all v1 v1.0.1 Nov 21, 2024 v1.0.0 Oct 19, 2024 Changes in this version + func NewKubeClientFromGlobalInformer(gi GlobalInformer, clusterID ClusterID) (client kube.Client, err error) + func WithNonTerminatedPods[T runtime.Object](config *ListConfig[T]) + type Cluster interface + ID func() ClusterID + KubeClient func() kube.Client + type ClusterID string + func (cid ClusterID) String() string + type ClusterResourceEventHandler interface + OnAdd func(cluster Cluster, obj any) + OnDelete func(cluster Cluster, obj any) + OnUpdate func(cluster Cluster, oldObj, newObj any) + type ClusterWatchErrorHandler func(cluster Cluster, r *cache.Reflector, err error) + type FilterFunction func(obj T) bool + type GlobalInformer interface + AddCluster func(clusterID ClusterID, client kube.Client, defaultResync time.Duration, ...) + AllSynced func() bool + ClusterHasSynced func(clusterID ClusterID) bool + ClusterSyncMap func(clusterID ClusterID) map[ResourceUnit]bool + GetCluster func(id ClusterID) Cluster + HasSynced func(clusterID ClusterID, resource schema.GroupVersionResource) bool + ListClusters func() (clusters []Cluster) + RemoveCluster func(clusterID ClusterID) + func NewGlobalInformer(scheme *runtime.Scheme) GlobalInformer + type KubeClient struct + type ListConfig struct + type ListOption func(config *ListConfig[T]) + func FromMetaListOptions[T runtime.Object](opts metav1.ListOptions) (res []ListOption[T]) + func InNamespaces[T runtime.Object](namespaces ...string) ListOption[T] + func WithCustomFilter[T runtime.Object](fn FilterFunction[T]) ListOption[T] + func WithCustomPreFilter[T runtime.Object](fn PreFilterFunction) ListOption[T] + func WithLabelSelectorStr[T runtime.Object](selector string) (opt ListOption[T], err error) + func WithLabelSelector[T runtime.Object](selector labels.Selector) ListOption[T] + func WithLabelsMap[T runtime.Object](m map[string]string) ListOption[T] + func WithMetaLabelSelector[T runtime.Object](selector *metav1.LabelSelector) (opt ListOption[T], err error) + func WithNames[T runtime.Object](names ...string) ListOption[T] + func WithOwnerReference[T runtime.Object](gvk schema.GroupVersionKind, name string) ListOption[T] + func WithPagination[T runtime.Object](less func(a, b *unstructured.Unstructured) bool, offset, limit int, ...) ListOption[T] + type PreFilterFunction func(obj *unstructured.Unstructured) bool + type ResourceBuilder interface + AllClusters func() ResourceBuilder[T] + Clusters func(clusters ...ClusterID) ResourceBuilder[T] + ForKind func(gvk schema.GroupVersionKind) ResourceBuilder[T] + ForResource func(gvr schema.GroupVersionResource) ResourceBuilder[T] + Get func(namespace, name string) (obj T, err error) + List func(opts ...ListOption[T]) (list []T, err error) + func NewResourceBuilder[T runtime.Object](gi GlobalInformer) ResourceBuilder[T] + type ResourceUnit struct + Namespace string + Resource schema.GroupVersionResource + type ResourceUnitWithHandlers struct + ResourceEventHandlers []ClusterResourceEventHandler + WatchErrorHandlers []ClusterWatchErrorHandler + func BuildResourceUnitWithHandlersSlice(units []ResourceUnit) (res []ResourceUnitWithHandlers)
Go to main page