controllers

Documentation

Index

• Variables
• func NewMetrics()
• type ConsumerHandler
  • 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) InitializeController(mgr manager.Manager, requiredLabel string) error
  • func (c *Controller) Reconcile(_ context.Context, _ reconcile.Request) (reconcile.Result, error)
  • func (c *Controller) ReconcileNotificationCadence(resource *u.Unstructured, url string, priority string, settings v1.ConfigMap, ...) error
  • func (c *Controller) ResourceReconcile(ctx context.Context, resource *u.Unstructured) (reconcile.Result, error)
  • func (c *Controller) WatchResources(discoveryClient *discovery.DiscoveryClient, dynamicClient dynamic.Interface, ...) error
• type ResourceDetails

Variables

var WatchingResourcesCount = prometheus.NewGauge(prometheus.GaugeOpts{
	Name: "heimdall_watching_resource_count",
	Help: "Number of resources being watched by Heimdall",
})

Functions

func NewMetrics

func NewMetrics()

Types

type ConsumerHandler

type ConsumerHandler struct {
	// contains filtered or unexported fields
}

func (*ConsumerHandler) Cleanup

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

Cleanup Necessary for Consumer Groups

func (*ConsumerHandler) ConsumeClaim

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

func (*ConsumerHandler) Setup

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

Setup Necessary for Consumer Groups

type Controller

type Controller struct {
	Client client.Client
	Scheme *runtime.Scheme
}

func (*Controller) InitializeController

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

InitializeController Add +kubebuilder:rbac:groups=*,resources=*,verbs=get;list;watch

func (*Controller) Reconcile

func (c *Controller) Reconcile(_ context.Context, _ reconcile.Request) (reconcile.Result, error)

Reconcile Placeholder for now as we don't need a traditional reconcile loop

func (*Controller) ReconcileNotificationCadence

func (c *Controller) ReconcileNotificationCadence(resource *u.Unstructured, url string, priority string, settings v1.ConfigMap, resources v1.ConfigMap, secret v1.Secret) error

func (*Controller) ResourceReconcile

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

func (*Controller) WatchResources

func (c *Controller) WatchResources(discoveryClient *discovery.DiscoveryClient, dynamicClient dynamic.Interface, requiredLabel string) error

type ResourceDetails

type ResourceDetails struct {
	MessageID uuid.UUID
	Name      string
	Namespace string
	Kind      string
	Group     string
	Version   string
	Resource  string
}