prometheus

Documentation

Index

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

Functions

func ListOptions

func ListOptions(name string) metav1.ListOptions

Types

type ControllerOption

type ControllerOption func(*Operator)

func WithEndpointSlice

func WithEndpointSlice() ControllerOption

WithEndpointSlice tells that the Kubernetes API supports the Endpointslice resource.

func WithScrapeConfig

func WithScrapeConfig() ControllerOption

WithScrapeConfig tells that the controller manages ScrapeConfig objects.

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 Prometheus deployments and monitoring configurations.

func New

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

New creates a new controller.

func (*Operator) Iterate

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

Iterate implements the operator.StatusReconciler interface.

func (*Operator) RefreshStatusFor

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

RefreshStatus implements the operator.StatusReconciler interface.

func (*Operator) Run

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

Run the controller.

func (*Operator) Sync

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

Sync implements the operator.Syncer interface.

func (*Operator) UpdateStatus

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

UpdateStatus updates the status subresource of the object identified by the given key. UpdateStatus implements the operator.Syncer interface.