controllers

Apr 23, 2023

Changes in this version

+ type ConsumerHandler struct

+ func (h *ConsumerHandler) Cleanup(_ kafka.ConsumerGroupSession) error

+ func (h *ConsumerHandler) ConsumeClaim(sess kafka.ConsumerGroupSession, claim kafka.ConsumerGroupClaim) error

+ func (h *ConsumerHandler) Setup(_ kafka.ConsumerGroupSession) error

type Controller

+ func (c *Controller) ResourceReconcile(ctx context.Context, resource *u.Unstructured) (reconcile.Result, error)

+ type ResourceDetails struct

+ Group string

+ Kind string

+ MessageID uuid.UUID

+ Name string

+ Namespace string

+ Resource string

+ Version string

Apr 5, 2023

Changes in this version

+ var WatchingResourcesCount = prometheus.NewGauge(prometheus.GaugeOpts{ ... })

+ func NewMetrics()

type Controller

+ func (c *Controller) DeleteResource(key string, m *sync.Map)

+ func (c *Controller) RetrieveOrStoreResource(key string, resource u.Unstructured, m *sync.Map) (u.Unstructured, bool)

+ func (c *Controller) RetrieveResource(key string, m *sync.Map) (u.Unstructured, bool)

Mar 21, 2023

Changes in this version

type Controller

+ func (c *Controller) ReconcileNotificationCadence(request reconcile.Request, resource *u.Unstructured, url string, ...) error

+ func (c *Controller) UpdateMapWithResource(resource u.Unstructured, m *sync.Map)

Feb 16, 2023

Changes in this version

+ func DiscoverClusterGRVs(ctx context.Context, dc *discovery.DiscoveryClient, di dynamic.Interface, ...) ([]u.Unstructured, error)

+ func GVRFromUnstructured(o u.Unstructured) schema.GroupVersionResource

+ func GetResourcesByJq(dynamic dynamic.Interface, ctx context.Context, group string, version string, ...) ([]u.Unstructured, error)

+ func GetUnstructuredResourceList(dynamic dynamic.Interface, ctx context.Context, group string, version string, ...) ([]u.Unstructured, error)

+ type Controller struct

+ Client client.Client

+ DynamicClient dynamic.Interface

+ Scheme *runtime.Scheme

+ func (c *Controller) InitializeController(mgr manager.Manager, requiredLabel string) error

+ func (c *Controller) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

+ func (c *Controller) ReconcileConfigMap(ctx context.Context) (v1.ConfigMap, error)

+ func (c *Controller) ReconcileSecret(ctx context.Context) (v1.Secret, error)

+ func (c *Controller) RetrieveResourceFromMap(key string) (u.Unstructured, bool)

+ func (c *Controller) WatchResources(controller controller.Controller, discoveryClient *discovery.DiscoveryClient, ...) error