common

Documentation

Index

• Variables
• func DefaultControllerRateLimiter[T comparable]() workqueue.TypedRateLimiter[T]
• func GetElasticsearchFromRef(ctx context.Context, c client.Client, o client.Object, ...) (es *elasticsearchcrd.Elasticsearch, err error)
• func GetKibanaFromRef(ctx context.Context, c client.Client, o client.Object, kbRef shared.KibanaRef) (kb *kibanacrd.Kibana, err error)
• type KubernetesCapability

Variables

var (
	TotalErrors = prometheus.NewCounter(
		prometheus.CounterOpts{
			Name: "elasticsearch_operator_errors_total",
			Help: "Number of errors from all controllers",
		},
	)
	ControllerErrors = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "elasticsearch_operator_errors_controller",
		Help: "Number of errors per controllers",
	}, []string{"controller", "namespace", "name"})
	ControllerInstances = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "elasticsearch_operator_instances_controller",
		Help: "Number of instance per controllers",
	}, []string{"controller", "namespace", "name"})
)

Functions

func DefaultControllerRateLimiter

func DefaultControllerRateLimiter[T comparable]() workqueue.TypedRateLimiter[T]

func GetElasticsearchFromRef

func GetElasticsearchFromRef(ctx context.Context, c client.Client, o client.Object, esRef shared.ElasticsearchRef) (es *elasticsearchcrd.Elasticsearch, err error)

GetElasticsearchRef permit to get Elasticsearch

func GetKibanaFromRef

func GetKibanaFromRef(ctx context.Context, c client.Client, o client.Object, kbRef shared.KibanaRef) (kb *kibanacrd.Kibana, err error)

GetKibanaRef permit to get Kibana

Types

type KubernetesCapability

type KubernetesCapability struct {
	HasRoute      bool
	HasPrometheus bool
}

KubernetesCapability descripte the capability of the current Kubernetes cluster