hub / github.com/datainfrahq/druid-operator
github.com/datainfrahq/druid-operator @v1.3.1
Chat with this repo
292 symbols
838 edges
44 files
136 documented · 47%
● updated 4mo agov1.3.1 · 2025-10-08★ 13248 open issues
What it actually does AI analysis from the code graph — generated when you open this
loading…
README
Kubernetes Operator For Apache Druid
- Druid Operator provisions and manages Apache Druid cluster on kubernetes.
- Druid Operator is designed to provision and manage Apache Druid in distributed mode only.
- It is built in Golang using kubebuilder.
- Refer to Documentation for getting started.
- Feel free to join Kubernetes slack and join druid-operator
Newsletter - Monthly updates on running druid on kubernetes.
Talks and Blogs on Druid Operator
- Druid Summit 2023
- Dok Community
- Druid Summit
- Druid Operator Blog
- Druid On K8s Without ZK
- Building Apache Druid on Kubernetes: How Dailymotion Serves Partner Data
Supported CR's
- The operator supports CR's of type
DruidandDruidIngestion. DruidandDruidIngestionCR belongs to api Groupdruid.apache.organd versionv1alpha1
Druid Operator Architecture
Notifications
- The project moved to Kubebuilder v3 which requires a manual change in the operator.
- Users are encourage to use operator version 0.0.9+.
- The operator has moved from HPA apiVersion autoscaling/v2beta1 to autoscaling/v2 API users will need to update there HPA Specs according v2 api in order to work with the latest druid-operator release.
- druid-operator has moved Ingress apiVersion networking/v1beta1 to networking/v1. Users will need to update there Ingress Spec in the druid CR according networking/v1 syntax. In case users are using schema validated CRD, the CRD will also be needed to be updated.
- The v1.0.0 release for druid-operator is compatible with k8s version 1.25. HPA API is kept to version v2beta2.
- Release v1.2.2 had a bug for namespace scoped operator deployments, this is fixed in 1.2.3.
- Release v1.2.3 had a bug in updating finalizers, this is fixed in 1.2.4.
Kubernetes version compatibility
| druid-operator | 0.0.9 | v1.0.0 | v1.1.0 | v1.2.2 | v1.2.3 | v1.2.4 |
|---|---|---|---|---|---|---|
| kubernetes <= 1.20 | :x: | :x: | :x: | :x: | :x: | :x: |
| kubernetes == 1.21 | :white_check_mark: | :x: | :x: | :x: | :x: | :x: |
| kubernetes >= 1.22 and <= 1.25 | :white_check_mark: | :white_check_mark: | :white_check_mark: | :white_check_mark: | :white_check_mark: | :white_check_mark: |
| kubernetes > 1.25 and <= 1.29.1 | :x: | :x: | :white_check_mark: | :white_check_mark: | :white_check_mark: | :white_check_mark: |
Contributors
Note
Apache®, Apache Druid, Druid® are either registered trademarks or trademarks of the Apache Software Foundation in the United States and/or other countries. This project, druid-operator, is not an Apache Software Foundation project.
Extension points exported contracts — how you extend this code
GenericEventEmitter (Interface)GenericEventEmitter can be used for any case where the state change isn't handled by reader,writer or any custom event. [2 …
controllers/druid/interface.go
DruidHTTP (Interface)
DruidHTTP interface [1 implementers]
pkg/http/http.go
TransformStatusFunc (FuncType)
(no doc)
controllers/ingestion/reconciler.go
K8sEventEmitter (Interface)
Methods include an obj and k8s obj, obj is druid CR (runtime.Object) and k8s obj ( object interface ) K8sEventEmitter wi [2 …
controllers/druid/interface.go
Reader (Interface)
Reader Interface [1 implementers]
controllers/druid/interface.go
Writer (Interface)
Writer Interface [1 implementers]
controllers/druid/interface.go
EventEmitter (Interface)
EventEmitter Interface is a wrapper interface for all the emitter interface druid operator shall support. EventEmitter i
controllers/druid/interface.go
Core symbols most depended-on inside this repo
Getcalled by 41
controllers/druid/interface.go
EmitEventGeneric
called by 19
controllers/druid/interface.go
firstNonNilValue
called by 17
controllers/druid/util.go
List
called by 14
controllers/druid/interface.go
firstNonEmptyStr
called by 13
controllers/druid/util.go
Delete
called by 12
controllers/druid/interface.go
detectType
called by 12
controllers/druid/interface.go
MakePath
called by 12
pkg/druidapi/druidapi.go
Shape
Languages
Go100%
Modules by API surface
controllers/druid/handler.go55 symbols
controllers/druid/interface.go41 symbols
apis/druid/v1alpha1/zz_generated.deepcopy.go34 symbols
controllers/ingestion/reconciler.go18 symbols
controllers/druid/volume_claim_template_update_test.go13 symbols
controllers/druid/util.go12 symbols
apis/druid/v1alpha1/druid_types.go12 symbols
controllers/ingestion/reconciler_test.go9 symbols
pkg/http/http.go8 symbols
controllers/druid/volume_claim_template_update.go7 symbols
apis/druid/v1alpha1/druidingestion_types.go7 symbols
controllers/druid/druid_controller.go6 symbols
Datastores touched
druiddbDatabase · 1 repos
For agents
$ claude mcp add druid-operator \
-- python -m otcore.mcp_server <graph>