servicemonitor

Documentation

Index

• func HasProm(kc client.Client, svcmon *monitoringv1.ServiceMonitor, ...) (*monitoringv1.Prometheus, error)
• func IsDefaultPrometheus(prom *monitoringv1.Prometheus) bool
• func ServiceMonitorsForPrometheus(kc client.Client, labels map[string]string) func(_ context.Context, _ client.Object) []reconcile.Request
• func ServicePortForName(svc *core.Service, portName string) int32
• func UpsertEndpointPort(ports []core.EndpointPort, x core.EndpointPort) []core.EndpointPort
• func UpsertServicePort(ports []core.ServicePort, x core.ServicePort) []core.ServicePort
• type AutoReconciler
  • func NewAutoReconciler(cfg *rest.Config, kc client.Client) *AutoReconciler
  • func (r *AutoReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AutoReconciler) SetupWithManager(mgr ctrl.Manager) error
• type FederationReconciler
  • func NewFederationReconciler(cfg *rest.Config, kc client.Client) *FederationReconciler
  • func (r *FederationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FederationReconciler) ServiceMonitorsForService(ctx context.Context, obj client.Object) []reconcile.Request
  • func (r *FederationReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func HasProm

func HasProm(kc client.Client, svcmon *monitoringv1.ServiceMonitor, prometheuses []*monitoringv1.Prometheus) (*monitoringv1.Prometheus, error)

func IsDefaultPrometheus

func IsDefaultPrometheus(prom *monitoringv1.Prometheus) bool

func ServiceMonitorsForPrometheus

func ServiceMonitorsForPrometheus(kc client.Client, labels map[string]string) func(_ context.Context, _ client.Object) []reconcile.Request

Prometheus -> serviceMonitor

func ServicePortForName

func ServicePortForName(svc *core.Service, portName string) int32

func UpsertEndpointPort

func UpsertEndpointPort(ports []core.EndpointPort, x core.EndpointPort) []core.EndpointPort

func UpsertServicePort

func UpsertServicePort(ports []core.ServicePort, x core.ServicePort) []core.ServicePort

Types

type AutoReconciler

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

AutoReconciler reconciles a ServiceMonitor object

func NewAutoReconciler

func NewAutoReconciler(cfg *rest.Config, kc client.Client) *AutoReconciler

func (*AutoReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ServiceMonitor object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.0/pkg/reconcile

func (*AutoReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type FederationReconciler

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

FederationReconciler reconciles a ServiceMonitor object

func NewFederationReconciler

func NewFederationReconciler(cfg *rest.Config, kc client.Client) *FederationReconciler

func (*FederationReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ServiceMonitor object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.16.0/pkg/reconcile

func (*FederationReconciler) ServiceMonitorsForService

func (r *FederationReconciler) ServiceMonitorsForService(ctx context.Context, obj client.Object) []reconcile.Request

service -> []serviceMonitors

func (*FederationReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.