Documentation ¶
Index ¶
- func SetupErrorTrackingMigrations(selfHostedVersion bool) func() ([]*goose.Migration, error)
- func SetupLoggingMigrations(selfHostedVersion bool) func() ([]*goose.Migration, error)
- func SetupMetricsMigrations(selfHostedVersion bool) func() ([]*goose.Migration, error)
- func SetupTracingMigrationsForCloud() ([]*goose.Migration, error)
- func SetupTracingMigrationsForSelfhosted() ([]*goose.Migration, error)
- type BaseReconciler
- type CertManagerReconciler
- type ClickHouseOperatorReconciler
- type ClickHouseReconciler
- type ClickHouseState
- func (i *ClickHouseState) GetCloudEndpoints() (*config.ClickHouseEndpoints, error)
- func (i *ClickHouseState) GetSchedulerCredentials() (*url.Userinfo, error)
- func (i *ClickHouseState) GetSelfhostedEndpoints() (*config.ClickHouseEndpoints, error)
- func (i *ClickHouseState) Read(ctx context.Context, cr *v1alpha1.Cluster, client client.Client) error
- func (i *ClickHouseState) ReadCredentials(ctx context.Context, cr *v1alpha1.Cluster, client client.Client) error
- type ClusterState
- type ErrortrackingAPIReconciler
- type ExternalDNSReconciler
- type GatekeeperReconciler
- type IngressControllerReconciler
- type JaegerOperatorReconciler
- type MonitoringReconciler
- type OpenTelemetryOperatorReconciler
- type PrometheusOperatorReconciler
- type PrometheusReconciler
- type ProvisioningAPIReconciler
- type QueryAPIReconciler
- type ReconcileCluster
- type RedisOperatorReconciler
- type ReloaderReconciler
- type StorageReconciler
- type SwaggerUIReconciler
- type TraceQueryAPIReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetupLoggingMigrations ¶
func SetupMetricsMigrations ¶
func SetupTracingMigrationsForCloud ¶
func SetupTracingMigrationsForCloud() ([]*goose.Migration, error)
func SetupTracingMigrationsForSelfhosted ¶
func SetupTracingMigrationsForSelfhosted() ([]*goose.Migration, error)
Types ¶
type BaseReconciler ¶
type BaseReconciler struct { Teardown bool Log logr.Logger // contains filtered or unexported fields }
func (*BaseReconciler) Reconcile ¶
func (i *BaseReconciler) Reconcile(ctx context.Context, cr *v1alpha1.Cluster) common.DesiredState
type CertManagerReconciler ¶
type CertManagerReconciler struct {
BaseReconciler
}
type ClickHouseOperatorReconciler ¶
type ClickHouseOperatorReconciler struct {
BaseReconciler
}
type ClickHouseReconciler ¶
type ClickHouseReconciler struct { Teardown bool Log logr.Logger // contains filtered or unexported fields }
func NewClickHouseReconciler ¶
func (*ClickHouseReconciler) Reconcile ¶
func (i *ClickHouseReconciler) Reconcile( ctx context.Context, state *ClusterState, cr *v1alpha1.Cluster, ) common.DesiredState
type ClickHouseState ¶
type ClickHouseState struct { // Keep track of Credentials so we can pass them to our ClickHouse client Credentials *v1.Secret // Track Clickhouse Cluster CR status: Cluster *clickhousev1alpha1.ClickHouse // ClickHouse Cloud credentials CloudCredentials *v1.Secret // contains filtered or unexported fields }
func NewClickHouseState ¶
func NewClickHouseState() *ClickHouseState
func (*ClickHouseState) GetCloudEndpoints ¶
func (i *ClickHouseState) GetCloudEndpoints() (*config.ClickHouseEndpoints, error)
func (*ClickHouseState) GetSchedulerCredentials ¶
func (i *ClickHouseState) GetSchedulerCredentials() (*url.Userinfo, error)
Get ClickHouse username/password for the scheduler
func (*ClickHouseState) GetSelfhostedEndpoints ¶
func (i *ClickHouseState) GetSelfhostedEndpoints() (*config.ClickHouseEndpoints, error)
Get ClickHouse endpoints for the scheduler user
func (*ClickHouseState) ReadCredentials ¶
type ClusterState ¶
type ClusterState struct { ClickHouse ClickHouseState // All Opstrace tenants Tenants *v1.NamespaceList LogLevel string }
func NewClusterState ¶
func NewClusterState(logLevel string) *ClusterState
type ErrortrackingAPIReconciler ¶
type ErrortrackingAPIReconciler struct { BaseReconciler // contains filtered or unexported fields }
func NewErrorTrackingAPIReconciler ¶
func NewErrorTrackingAPIReconciler( t trace.Tracer, initialManifests map[string][]byte, teardown bool, clusterState *ClusterState, ) *ErrortrackingAPIReconciler
type ExternalDNSReconciler ¶
type ExternalDNSReconciler struct {
BaseReconciler
}
func (*ExternalDNSReconciler) Reconcile ¶
func (i *ExternalDNSReconciler) Reconcile(ctx context.Context, cr *v1alpha1.Cluster) common.DesiredState
type GatekeeperReconciler ¶
type GatekeeperReconciler struct { BaseReconciler // contains filtered or unexported fields }
func NewGatekeeperReconciler ¶
func NewGatekeeperReconciler( t trace.Tracer, initialManifests map[string][]byte, teardown bool, clusterState *ClusterState, ) *GatekeeperReconciler
func (*GatekeeperReconciler) Reconcile ¶
func (i *GatekeeperReconciler) Reconcile(ctx context.Context, cr *v1alpha1.Cluster) common.DesiredState
type IngressControllerReconciler ¶
type IngressControllerReconciler struct {
BaseReconciler
}
type JaegerOperatorReconciler ¶
type JaegerOperatorReconciler struct {
BaseReconciler
}
type MonitoringReconciler ¶
type MonitoringReconciler struct { BaseReconciler // contains filtered or unexported fields }
func NewMonitoringReconciler ¶
func NewMonitoringReconciler( t trace.Tracer, initialManifests map[string][]byte, teardown bool, chState *ClickHouseState, ) *MonitoringReconciler
type OpenTelemetryOperatorReconciler ¶
type OpenTelemetryOperatorReconciler struct {
BaseReconciler
}
type PrometheusOperatorReconciler ¶
type PrometheusOperatorReconciler struct {
BaseReconciler
}
type PrometheusReconciler ¶
type PrometheusReconciler struct {
BaseReconciler
}
func NewPrometheusReconciler ¶
type ProvisioningAPIReconciler ¶
type ProvisioningAPIReconciler struct { BaseReconciler LogLevel string }
type QueryAPIReconciler ¶
type QueryAPIReconciler struct { BaseReconciler // contains filtered or unexported fields }
func NewQueryAPIReconciler ¶
func NewQueryAPIReconciler( t trace.Tracer, initialManifests map[string][]byte, teardown bool, clusterState *ClusterState, ) *QueryAPIReconciler
type ReconcileCluster ¶
type ReconcileCluster struct { // This client, initialized using mgr.Client() above, is a split client // that reads objects from the cache and writes to the apiserver Client client.Client Scheme *runtime.Scheme Transport *http.Transport Recorder record.EventRecorder Log logr.Logger InitialManifests map[string]map[string][]byte StatusPoller *polling.StatusPoller DriftPreventionInterval time.Duration LogLevel string Tracer trace.Tracer }
ReconcileCluster reconciles a Cluster object
func (*ReconcileCluster) Reconcile ¶
func (r *ReconcileCluster) Reconcile( ctx context.Context, request reconcile.Request, ) (result ctrl.Result, err error)
Reconcile , The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
func (*ReconcileCluster) SetupWithManager ¶
func (r *ReconcileCluster) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type RedisOperatorReconciler ¶
type RedisOperatorReconciler struct {
BaseReconciler
}
func (*RedisOperatorReconciler) Reconcile ¶
func (i *RedisOperatorReconciler) Reconcile(ctx context.Context, cr *v1alpha1.Cluster) common.DesiredState
type ReloaderReconciler ¶
type ReloaderReconciler struct {
BaseReconciler
}
func NewReloaderReconciler ¶
type StorageReconciler ¶
type StorageReconciler struct {
BaseReconciler
}
func NewStorageReconciler ¶
type SwaggerUIReconciler ¶
type SwaggerUIReconciler struct {
BaseReconciler
}
func NewSwaggerUIReconciler ¶
type TraceQueryAPIReconciler ¶
type TraceQueryAPIReconciler struct { BaseReconciler // contains filtered or unexported fields }
func NewTraceQueryAPIReconciler ¶
func NewTraceQueryAPIReconciler( t trace.Tracer, initialManifests map[string][]byte, teardown bool, clusterState *ClusterState) *TraceQueryAPIReconciler
Source Files ¶
- base_reconciler.go
- certmanager_reconciler.go
- clickhouse_operator_reconciler.go
- clickhouse_reconciler.go
- clickhouse_state.go
- cluster_controller.go
- cluster_state.go
- errortrackingapi_reconciler.go
- externaldns_reconciler.go
- gatekeeper_reconciler.go
- ingress_controller_reconciler.go
- jaeger_operator_reconciler.go
- monitoring_reconciler.go
- otel_operator_reconciler.go
- prometheus_operator_reconciler.go
- prometheus_reconciler.go
- provisioning_api_reconciler.go
- query_api_reconciler.go
- redis_reconciler.go
- reloader_reconciler.go
- storage_reconciler.go
- swagger_ui_reconciler.go
- trace_query_api_reconciler.go
Click to show internal directories.
Click to hide internal directories.