thanos

Documentation

Index

• func ListOptions(name string) metav1.ListOptions
• type Config
• type ControllerOption
  • func WithStorageClassValidation() ControllerOption
• type Operator
  • func New(ctx context.Context, restConfig *rest.Config, c operator.Config, ...) (*Operator, error)
  • func (o *Operator) Iterate(processFn func(metav1.Object, []monitoringv1.Condition))
  • func (o *Operator) RefreshStatusFor(obj metav1.Object)
  • func (o *Operator) Run(ctx context.Context) error
  • func (o *Operator) Sync(ctx context.Context, key string) error
  • func (o *Operator) UpdateStatus(ctx context.Context, key string) error

Functions

func ListOptions

func ListOptions(name string) metav1.ListOptions

Types

type Config

type Config struct {
	LocalHost              string
	ReloaderConfig         operator.ContainerConfig
	ThanosDefaultBaseImage string
	Annotations            operator.Map
	Labels                 operator.Map
}

Config defines the operator's parameters for the Thanos controller. Whenever the value of one of these parameters is changed, it triggers an update of the managed statefulsets.

type ControllerOption

type ControllerOption func(*Operator)

func WithStorageClassValidation

func WithStorageClassValidation() ControllerOption

WithStorageClassValidation tells that the controller should verify that the Prometheus spec references a valid StorageClass name.

type Operator

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

Operator manages life cycle of Thanos deployments and monitoring configurations.

func New

func New(ctx context.Context, restConfig *rest.Config, c operator.Config, logger *slog.Logger, r prometheus.Registerer, options ...ControllerOption) (*Operator, error)

New creates a new controller.

func (*Operator) Iterate

func (o *Operator) Iterate(processFn func(metav1.Object, []monitoringv1.Condition))

Iterate implements the operator.StatusReconciler interface.

func (*Operator) RefreshStatusFor

func (o *Operator) RefreshStatusFor(obj metav1.Object)

RefreshStatus implements the operator.StatusReconciler interface.

func (*Operator) Run

func (o *Operator) Run(ctx context.Context) error

Run the controller.

func (*Operator) Sync

func (o *Operator) Sync(ctx context.Context, key string) error

Sync implements the operator.Syncer interface.

func (*Operator) UpdateStatus

func (o *Operator) UpdateStatus(ctx context.Context, key string) error

UpdateStatus implements the operator.Syncer interface.