cluster

package
v0.0.0-...-b4e7bf2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2024 License: Apache-2.0, MIT Imports: 46 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetupErrorTrackingMigrations 

func SetupErrorTrackingMigrations(selfHostedVersion bool) func() ([]*goose.Migration, error)

func SetupLoggingMigrations 

func SetupLoggingMigrations(selfHostedVersion bool) func() ([]*goose.Migration, error)

func SetupMetricsMigrations 

func SetupMetricsMigrations(selfHostedVersion bool) func() ([]*goose.Migration, error)

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
}

func NewCertManagerReconciler 

func NewCertManagerReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *CertManagerReconciler

type ClickHouseOperatorReconciler 

type ClickHouseOperatorReconciler struct {
	BaseReconciler
}

func NewClickHouseOperatorReconciler 

func NewClickHouseOperatorReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *ClickHouseOperatorReconciler

type ClickHouseReconciler 

type ClickHouseReconciler struct {
	Teardown bool
	Log      logr.Logger
	// contains filtered or unexported fields
}

func NewClickHouseReconciler 

func NewClickHouseReconciler(t trace.Tracer, teardown bool, logger logr.Logger) *ClickHouseReconciler

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) Read 

func (i *ClickHouseState) Read(ctx context.Context, cr *v1alpha1.Cluster, client client.Client) error

func (*ClickHouseState) ReadCredentials 

func (i *ClickHouseState) ReadCredentials(ctx context.Context, cr *v1alpha1.Cluster, client client.Client) error

type ClusterState 

type ClusterState struct {
	ClickHouse ClickHouseState
	// All Opstrace tenants
	Tenants *v1.NamespaceList

	LogLevel string
}

func NewClusterState 

func NewClusterState(logLevel string) *ClusterState

func (*ClusterState) Read 

func (i *ClusterState) Read(ctx context.Context, cr *v1alpha1.Cluster, client client.Client) error

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 NewExternalDNSReconciler 

func NewExternalDNSReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *ExternalDNSReconciler

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
}

func NewIngressControllerReconciler 

func NewIngressControllerReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *IngressControllerReconciler

type JaegerOperatorReconciler 

type JaegerOperatorReconciler struct {
	BaseReconciler
}

func NewJaegerOperatorReconciler 

func NewJaegerOperatorReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *JaegerOperatorReconciler

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
}

func NewOpenTelemetryOperatorReconciler 

func NewOpenTelemetryOperatorReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *OpenTelemetryOperatorReconciler

type PrometheusOperatorReconciler 

type PrometheusOperatorReconciler struct {
	BaseReconciler
}

func NewPrometheusOperatorReconciler 

func NewPrometheusOperatorReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *PrometheusOperatorReconciler

type PrometheusReconciler 

type PrometheusReconciler struct {
	BaseReconciler
}

func NewPrometheusReconciler 

func NewPrometheusReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *PrometheusReconciler

type ProvisioningAPIReconciler 

type ProvisioningAPIReconciler struct {
	BaseReconciler

	LogLevel string
}

func NewProvisioningAPIReconciler 

func NewProvisioningAPIReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
	logLevel string,
) *ProvisioningAPIReconciler

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 NewRedisOperatorReconciler 

func NewRedisOperatorReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *RedisOperatorReconciler

func (*RedisOperatorReconciler) Reconcile 

func (i *RedisOperatorReconciler) Reconcile(ctx context.Context, cr *v1alpha1.Cluster) common.DesiredState

type ReloaderReconciler 

type ReloaderReconciler struct {
	BaseReconciler
}

func NewReloaderReconciler 

func NewReloaderReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *ReloaderReconciler

type StorageReconciler 

type StorageReconciler struct {
	BaseReconciler
}

func NewStorageReconciler 

func NewStorageReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *StorageReconciler

type SwaggerUIReconciler 

type SwaggerUIReconciler struct {
	BaseReconciler
}

func NewSwaggerUIReconciler 

func NewSwaggerUIReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
) *SwaggerUIReconciler

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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.