controller

package
v0.0.0-...-092aeb9 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2025 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CompactNameFromParent 

func CompactNameFromParent(resourceName string) string

CompactNameFromParent returns the name of the Thanos Compact component.

func QueryFrontendNameFromParent 

func QueryFrontendNameFromParent(resourceName string) string

QueryFrontendNameFromParent returns the name of the Thanos Query Frontend component.

func QueryNameFromParent 

func QueryNameFromParent(resourceName string) string

QueryNameFromParent returns the name of the Thanos Query component.

func ReceiveIngesterNameFromParent 

func ReceiveIngesterNameFromParent(resourceName, hashringName string) string

ReceiveIngesterNameFromParent returns the name of the Thanos Receive Ingester component.

func ReceiveRouterNameFromParent 

func ReceiveRouterNameFromParent(resourceName string) string

ReceiveRouterNameFromParent returns the name of the Thanos Receive Router component.

func RulerNameFromParent 

func RulerNameFromParent(resourceName string) string

RulerNameFromParent returns the name of the Thanos Ruler component.

func StoreNameFromParent 

func StoreNameFromParent(resourceName string, index *int32) string

StoreNameFromParent returns the name of the Thanos Store component.

Types

type Config 

type Config struct {
	// FeatureGate holds information about enabled features.
	FeatureGate FeatureGate
	// InstrumentationConfig contains the common instrumentation configuration for all controllers.
	InstrumentationConfig InstrumentationConfig
}

Config holds the configuration for all controllers.

type FeatureGate 

type FeatureGate struct {
	// EnableServiceMonitor enables the management of ServiceMonitor objects.
	// See https://prometheus-operator.dev/docs/api-reference/api/#monitoring.coreos.com/v1.ServiceMonitor
	EnableServiceMonitor bool
	// EnablePrometheusRuleDiscovery enables the discovery of PrometheusRule objects to set on Thanos Ruler.
	// See https://prometheus-operator.dev/docs/api-reference/api/#monitoring.coreos.com/v1.PrometheusRule
	EnablePrometheusRuleDiscovery bool
}

FeatureGate holds information about enabled features.

func (FeatureGate) ToGVK 

func (fg FeatureGate) ToGVK() []schema.GroupVersionKind

ToGVK returns the GroupVersionKind for all enabled features.

type InstrumentationConfig 

type InstrumentationConfig struct {
	Logger        logr.Logger
	EventRecorder record.EventRecorder

	MetricsRegistry prometheus.Registerer
}

InstrumentationConfig contains the common instrumentation configuration for all controllers.

type ThanosCompactReconciler 

type ThanosCompactReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ThanosCompactReconciler reconciles a ThanosCompact object

func NewThanosCompactReconciler 

func NewThanosCompactReconciler(conf Config, client client.Client, scheme *runtime.Scheme) *ThanosCompactReconciler

NewThanosCompactReconciler returns a reconciler for ThanosCompact resources.

func (*ThanosCompactReconciler) Reconcile 

func (r *ThanosCompactReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ThanosCompact object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.3/pkg/reconcile

func (*ThanosCompactReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ThanosQueryReconciler 

type ThanosQueryReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ThanosQueryReconciler reconciles a ThanosQuery object

func NewThanosQueryReconciler 

func NewThanosQueryReconciler(conf Config, client client.Client, scheme *runtime.Scheme) *ThanosQueryReconciler

NewThanosQueryReconciler returns a reconciler for ThanosQuery resources.

func (*ThanosQueryReconciler) Reconcile 

func (r *ThanosQueryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.0/pkg/reconcile

func (*ThanosQueryReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ThanosReceiveReconciler 

type ThanosReceiveReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ThanosReceiveReconciler reconciles a ThanosReceive object

func NewThanosReceiveReconciler 

func NewThanosReceiveReconciler(conf Config, client client.Client, scheme *runtime.Scheme) *ThanosReceiveReconciler

NewThanosReceiveReconciler returns a reconciler for ThanosReceive resources.

func (*ThanosReceiveReconciler) Reconcile 

func (r *ThanosReceiveReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.3/pkg/reconcile

func (*ThanosReceiveReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ThanosRulerReconciler 

type ThanosRulerReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ThanosRulerReconciler reconciles a ThanosRuler object

func NewThanosRulerReconciler 

func NewThanosRulerReconciler(conf Config, client client.Client, scheme *runtime.Scheme) *ThanosRulerReconciler

NewThanosRulerReconciler returns a reconciler for ThanosRuler resources.

func (*ThanosRulerReconciler) Reconcile 

func (r *ThanosRulerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.0/pkg/reconcile

func (*ThanosRulerReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ThanosStoreReconciler 

type ThanosStoreReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ThanosStoreReconciler reconciles a ThanosStore object

func NewThanosStoreReconciler 

func NewThanosStoreReconciler(conf Config, client client.Client, scheme *runtime.Scheme) *ThanosStoreReconciler

NewThanosStoreReconciler returns a reconciler for ThanosStore resources.

func (*ThanosStoreReconciler) Reconcile 

func (r *ThanosStoreReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.0/pkg/reconcile

func (*ThanosStoreReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

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.