controllers

Documentation

Index

• type CloseChannel
• type MetricReconciler
  • func (r *MetricReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MetricReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MetricsDefinition
• type MetricsMemory
• type Resource

Types

type CloseChannel

type CloseChannel struct {
	Channel chan struct{}
	Closed  bool
}

type MetricReconciler

type MetricReconciler struct {
	client.Client
	Kind      string
	Scheme    *runtime.Scheme
	MmHandler xmetrics.IManagedMetricsHandler
}

MetricReconciler reconciles a Metric object

func (*MetricReconciler) Reconcile

func (r *MetricReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=metrics.crossplane.io,resources=metrics,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=metrics.crossplane.io,resources=metrics/status,verbs=get;update;patch +kubebuilder:rbac:groups=metrics.crossplane.io,resources=metrics/finalizers,verbs=update +kubebuilder:rbac:groups=apiextensions.k8s.io,resources=customresourcedefinitions,verbs=get;list

func (*MetricReconciler) SetupWithManager

func (r *MetricReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type MetricsDefinition

type MetricsDefinition struct {
	Channels map[string]*CloseChannel
}

type MetricsMemory

type MetricsMemory struct {
	Channel  *CloseChannel
	Consumer map[string]struct{}
}

type Resource

type Resource struct {
	Group      string  `json:"group"`
	Version    string  `json:"version"`
	Kind       string  `json:"kind"`
	Resource   string  `json:"resource"`
	MetricName string  `json:"metricName"`
	Namespace  *string `json:"namespace,omitempty"`
}