tenant

package
v0.0.0-...-7d163e4 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2025 License: Apache-2.0, MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IngressBasePath = `^/v3/%d/(?P<projectID>[0-9]+)/ingest`
	// our original paths /ingest/<type> remain for consistency
	IngressPathTracesTmpl  = IngressBasePath + "/traces"
	IngressPathMetricsTmpl = IngressBasePath + "/metrics"
	IngressPathLogsTmpl    = IngressBasePath + "/logs"
	// OTEL compatible paths that are ingest/v1/<type> compatible
	IngressPathTracesOTELTmpl  = IngressBasePath + "/v1/traces"
	IngressPathMetricsOTELTmpl = IngressBasePath + "/v1/metrics"
	IngressPathLogsOTELTmpl    = IngressBasePath + "/v1/logs"
)

Variables

This section is empty.

Functions

func ClickHouseUsersProvision 

func ClickHouseUsersProvision(
	username string,
	password string,
	grants []string,
	databaseNames []string,
	chEndpoint url.URL,
) []common.Action

func ClickHouseUsersProvisionOnCloud 

func ClickHouseUsersProvisionOnCloud(
	username string,
	password string,
	grants []string,
	databaseNames []string,
	chEndpoint url.URL) []common.Action

Types

type BaseReconciler 

type BaseReconciler struct {
	// contains filtered or unexported fields
}

type ClickHouseEndpoints 

type ClickHouseEndpoints struct {
	Http   url.URL
	Native url.URL
}

type ClickHouseReconciler 

type ClickHouseReconciler struct {
	BaseReconciler

	Teardown bool
	Log      logr.Logger
	State    *GitLabObservabilityTenantState
}

func NewClickHouseReconciler 

func NewClickHouseReconciler(
	t trace.Tracer,
	teardown bool,
	state *GitLabObservabilityTenantState,
	tenantID int64,
) *ClickHouseReconciler

func (*ClickHouseReconciler) Reconcile 

func (i *ClickHouseReconciler) Reconcile(
	ctx context.Context,
	cr *opstracev1alpha1.GitLabObservabilityTenant,
) common.DesiredState

Note: Function length can be reduced after simplifying dual writing.

type GitLabObservabilityTenantState 

type GitLabObservabilityTenantState struct {
	Cluster                *opstracev1alpha1.Cluster
	SchedulerCHCredentials *corev1.Secret
	TenantNamespace        *corev1.Namespace
	TenantCHCredentials    *corev1.Secret
	TenantCollectorConfig  *corev1.ConfigMap

	CloudCHCredentials *corev1.Secret

	TenantCHCloudCredentials *corev1.Secret
	// contains filtered or unexported fields
}

func NewGitLabObservabilityTenantState 

func NewGitLabObservabilityTenantState() *GitLabObservabilityTenantState

func (*GitLabObservabilityTenantState) Read 

func (g *GitLabObservabilityTenantState) Read(
	ctx context.Context,
	cr *opstracev1alpha1.GitLabObservabilityTenant,
	client client.Client,
) error

type NamespaceReconciler 

type NamespaceReconciler struct {
	BaseReconciler

	Teardown bool
	Log      logr.Logger
	// contains filtered or unexported fields
}

func NewNamespaceReconciler 

func NewNamespaceReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
	tenantID int64,
) *NamespaceReconciler

func (*NamespaceReconciler) ApplyConfiguration 

func (i *NamespaceReconciler) ApplyConfiguration(
	cr *v1alpha1.GitLabObservabilityTenant,
) (*kustomize.Kustomization, error)

func (*NamespaceReconciler) ApplyOverrides 

func (i *NamespaceReconciler) ApplyOverrides(k *kustomize.Kustomization, cr *v1alpha1.GitLabObservabilityTenant)

func (*NamespaceReconciler) Reconcile 

func (i *NamespaceReconciler) Reconcile(
	ctx context.Context,
	cr *v1alpha1.GitLabObservabilityTenant,
) common.DesiredState

type OTELCollectorReconciler 

type OTELCollectorReconciler struct {
	BaseReconciler

	Teardown bool
	Log      logr.Logger

	State *GitLabObservabilityTenantState
	// contains filtered or unexported fields
}

func NewOTELCollectorReconciler 

func NewOTELCollectorReconciler(
	t trace.Tracer,
	initialManifests map[string][]byte,
	teardown bool,
	tenantID int64,
	state *GitLabObservabilityTenantState,
) *OTELCollectorReconciler

func (*OTELCollectorReconciler) ApplyConfiguration 

func (i *OTELCollectorReconciler) ApplyConfiguration(
	cr *v1alpha1.GitLabObservabilityTenant,
) (*kustomize.Kustomization, error)

func (*OTELCollectorReconciler) ApplyOverrides 

func (i *OTELCollectorReconciler) ApplyOverrides(k *kustomize.Kustomization, cr *v1alpha1.GitLabObservabilityTenant)

func (*OTELCollectorReconciler) Reconcile 

func (i *OTELCollectorReconciler) Reconcile(
	ctx context.Context,
	cr *v1alpha1.GitLabObservabilityTenant,
) common.DesiredState

type ReconcileTenant 

type ReconcileTenant struct {
	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
}

func (*ReconcileTenant) Reconcile 

func (r *ReconcileTenant) Reconcile(
	ctx context.Context,
	request reconcile.Request,
) (result ctrl.Result, err error)

func (*ReconcileTenant) SetupWithManager 

func (r *ReconcileTenant) SetupWithManager(mgr ctrl.Manager) error

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.