components

Documentation

Overview

Package components defines the common interfaces for the components.

Index

• Constants
• func GetAllComponents() map[string]Component
• func IsComponentRegistered(name string) bool
• func RegisterComponent(name string, comp Component) error
• type Component
  • func GetComponent(name string) (Component, error)
• type Event
• type Info
• type Metric
• type OutputProvider
• type PromRegisterer
• type SettableComponent
• type State
• type WatchableComponent

Constants

const (
	StateHealthy      = "Healthy"
	StateUnhealthy    = "Unhealthy"
	StateInitializing = "Initializing"
	StateDegraded     = "Degraded"
)

Functions

func GetAllComponents

func GetAllComponents() map[string]Component

func IsComponentRegistered

func IsComponentRegistered(name string) bool

func RegisterComponent

func RegisterComponent(name string, comp Component) error

Types

type Component

type Component interface {
	// Defines the component name,
	// and used for the HTTP handler registration path.
	// Must be globally unique.
	Name() string

	// Start called upon server start.
	// Implements component-specific poller start logic.
	Start() error

	// Returns the current states of the component.
	States(ctx context.Context) ([]State, error)

	// Returns all the events from "since".
	Events(ctx context.Context, since time.Time) ([]Event, error)

	// Returns all the metrics from the component.
	Metrics(ctx context.Context, since time.Time) ([]Metric, error)

	// Called upon server close.
	// Implements copmonent-specific poller cleanup logic.
	Close() error
}

Component represents an individual component of the system.

Each component check is independent of each other. But the underlying implementation may share the same data sources in order to minimize the querying overhead (e.g., nvidia-smi calls).

Each component implements its own output format inside the State struct. And recommended to have a consistent name for its HTTP handler. And recommended to define const keys for the State extra information field.

func GetComponent

func GetComponent(name string) (Component, error)

type Event

type Event struct {
	Time             metav1.Time              `json:"time"`
	Name             string                   `json:"name,omitempty"`
	Type             common.EventType         `json:"type,omitempty"`
	Message          string                   `json:"message,omitempty"`    // detailed message of the event
	ExtraInfo        map[string]string        `json:"extra_info,omitempty"` // any extra information the component may want to expose
	SuggestedActions *common.SuggestedActions `json:"suggested_actions,omitempty"`
}

type Info

type Info struct {
	States  []State  `json:"states"`
	Events  []Event  `json:"events"`
	Metrics []Metric `json:"metrics"`
}

type Metric

type Metric struct {
	components_metrics_state.Metric
	ExtraInfo map[string]string `json:"extra_info,omitempty"` // any extra information the component may want to expose
}

type OutputProvider

type OutputProvider interface {
	Output() (any, error)
}

Defines an optional component interface that returns the underlying output data.

type PromRegisterer

type PromRegisterer interface {
	RegisterCollectors(reg *prometheus.Registry, dbRW *sql.DB, dbRO *sql.DB, tableName string) error
}

Defines an optional component interface that supports Prometheus metrics.

type SettableComponent

type SettableComponent interface {
	SetStates(ctx context.Context, states ...State) error
	SetEvents(ctx context.Context, events ...Event) error
}

type State

type State struct {
	Name      string            `json:"name,omitempty"`
	Healthy   bool              `json:"healthy,omitempty"`
	Health    string            `json:"health,omitempty"`     // Healthy, Degraded, Unhealthy
	Reason    string            `json:"reason,omitempty"`     // a detailed and processed reason on why the component is not healthy
	Error     string            `json:"error,omitempty"`      // the unprocessed error returned from the component
	ExtraInfo map[string]string `json:"extra_info,omitempty"` // any extra information the component may want to expose

	SuggestedActions *common.SuggestedActions `json:"suggested_actions,omitempty"`
}

type WatchableComponent

type WatchableComponent interface {
	Component
}

WatchableComponent wraps the component with a watchable interface. Useful to intercept the component states method calls to track metrics.