Skip to main content

​
K8sleaderelector Extension

Status Available in: contrib, k8s Maintainers: @dmitryax, @rakesh-garimella Source: opentelemetry-collector-contrib

​
Overview

​
How It Works

The extension uses k8s.io/client-go/tools/leaderelection to perform leader election. The component that owns the lease becomes the leader and runs the function defined in onStartedLeading. If the leader loses the lease, it runs the function defined in onStoppedLeading, stops its operation, and waits to acquire the lease again.

​
Configuration

receivers:
  my_awesome_receiver:
    k8s_leader_elector: k8s_leader_elector
extensions:
  k8s_leader_elector:
    auth_type: kubeConfig
    lease_name: foo
    lease_namespace: default

service:
  extensions: [k8s_leader_elector]
  pipelines:
    metrics:
      receivers: [my_awesome_receiver]

​
Leader Election Configuration

configurationdescriptiondefault value
auth_typeAuthorization type to be used (serviceAccount, kubeConfig).none (required)
lease_nameThe name of the lease object.none (required)
lease_namespaceThe namespace of the lease object.none (required)
lease_durationThe duration of the lease.15s
renew_deadlineThe deadline for renewing the lease. It must be less than the lease duration.10s
retry_periodThe period for retrying the leader election.2s

​
Delete the lease object

kubectl delete leases.coordination.k8s.io -n <namespace> <lease_name>

​
Suggested RBAC

apiVersion: rbac.authorization.k8s.io/v1
kind: Role
metadata:
  name: my-lease
  namespace: default
rules:
- apiGroups:
  - coordination.k8s.io
  resources:
  - leases
  verbs:
  - get
  - list
  - watch
  - create
  - update
  - patch
  - delete

​
Configuration

​
Example Configuration

k8s_leader_elector/defaults:
  auth_type: kubeConfig
  lease_name: foo
  lease_namespace: default
k8s_leader_elector/with_lease_duration:
  auth_type: kubeConfig
  lease_name: bar
  lease_namespace: default
  lease_duration: 20s
Last generated: 2026-04-13