Versions in this module Expand all Collapse all v0 v0.1.1 Jun 5, 2024 v0.1.0 Jan 22, 2024 Changes in this version + var EndpointsliceTransformer = func(logger logr.Logger) toolscache.TransformFunc + var PartialObjectTransformer = func(logger logr.Logger) toolscache.TransformFunc + var PodTransformer = func(logger logr.Logger) toolscache.TransformFunc + var ServiceTransformer = func(logger logr.Logger) toolscache.TransformFunc + func IndexPodByNode(ctx context.Context, fi client.FieldIndexer) error + func IndexPodByPrefixName(ctx context.Context, fi client.FieldIndexer) error + func NewPartialObjectMetadata(kind string, name *types.NamespacedName) *metav1.PartialObjectMetadata + type CollectorOption func(opt *collectorOptions) + func WithExternalSource(src source.Source) CollectorOption + func WithOwnerSources(sources map[string]chan<- event.GenericEvent) CollectorOption + func WithPodMatchingFields(podMatchingFields func(metadata *metav1.ObjectMeta) client.ListOption) CollectorOption + func WithSubscribersChan(sChan subscriber.SubsChan) CollectorOption + type EndpointsDispatcher struct + Name string + PodCollectorSource chan<- event.GenericEvent + Pods map[string]map[string]struct{} + ServiceCollectorSource chan<- event.GenericEvent + func (r *EndpointsDispatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *EndpointsDispatcher) SetupWithManager(mgr ctrl.Manager) error + type EndpointslicesDispatcher struct + Name string + PodCollectorSource chan<- event.GenericEvent + Pods map[string]map[string]struct{} + ServiceCollectorSource chan<- event.GenericEvent + ServicesName map[string]string + func (r *EndpointslicesDispatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *EndpointslicesDispatcher) SetupWithManager(mgr ctrl.Manager) error + type ObjectMetaCollector struct + func NewObjectMetaCollector(cl client.Client, queue broker.Queue, cache *events.Cache, ...) *ObjectMetaCollector + func (r *ObjectMetaCollector) GetName() string + func (r *ObjectMetaCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *ObjectMetaCollector) SetupWithManager(mgr ctrl.Manager) error + func (r *ObjectMetaCollector) Start(ctx context.Context) error + type PodCollector struct + func NewPodCollector(cl client.Client, queue broker.Queue, cache *events.Cache, name string, ...) *PodCollector + func (pc *PodCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (pc *PodCollector) SetupWithManager(mgr ctrl.Manager) error + func (pc *PodCollector) Start(ctx context.Context) error + type ServiceCollector struct + func NewServiceCollector(cl client.Client, queue broker.Queue, cache *events.Cache, name string, ...) *ServiceCollector + func (r *ServiceCollector) GetName() string + func (r *ServiceCollector) ObjFieldsHandler(logger logr.Logger, evt *events.Resource, svc *corev1.Service) error + func (r *ServiceCollector) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *ServiceCollector) SetupWithManager(mgr ctrl.Manager) error + func (r *ServiceCollector) Start(ctx context.Context) error
Go to main page