Versions in this module Expand all Collapse all v1 v1.6.1 Nov 21, 2023 Changes in this version + func GetKubernetesClient() (*kubernetes.Clientset, error) + func GetKubernetesConfig(kubeconfig string) (*rest.Config, error) + func NewLeaderElector(leaderElectionID string, config *rest.Config, startFunc func(context.Context), ...) (*leaderelection.LeaderElector, error) + type EnhancedEvent struct + ClusterName string + InvolvedObject EnhancedObjectReference + func (e *EnhancedEvent) GetTimestampISO8601() string + func (e *EnhancedEvent) GetTimestampMs() int64 + func (e *EnhancedEvent) ToJSON() []byte + func (e EnhancedEvent) DeDot() EnhancedEvent + type EnhancedObjectReference struct + Annotations map[string]string + Deleted bool + Labels map[string]string + OwnerReferences []metav1.OwnerReference + type EventHandler func(event *EnhancedEvent) + type EventWatcher struct + func NewEventWatcher(config *rest.Config, namespace string, MaxEventAgeSeconds int64, ...) *EventWatcher + func (e *EventWatcher) OnAdd(obj interface{}) + func (e *EventWatcher) OnDelete(obj interface{}) + func (e *EventWatcher) OnUpdate(oldObj, newObj interface{}) + func (e *EventWatcher) Start() + func (e *EventWatcher) Stop() + type LeaderElectionConfig struct + Enabled bool + LeaderElectionID string + type ObjectMetadata struct + Annotations map[string]string + Deleted bool + Labels map[string]string + OwnerReferences []metav1.OwnerReference + type ObjectMetadataCache struct + func (o *ObjectMetadataCache) GetObjectMetadata(reference *v1.ObjectReference, clientset *kubernetes.Clientset, ...) (ObjectMetadata, error) + type ObjectMetadataProvider interface + GetObjectMetadata func(reference *v1.ObjectReference, clientset *kubernetes.Clientset, ...) (ObjectMetadata, error) + func NewObjectMetadataProvider(size int) ObjectMetadataProvider