hive

Documentation

Index

• Constants
• Variables
• func AddConfigOverride[Cfg cell.Flagger](h *Hive, override func(*Cfg))
• type Hive
  • func New(cells ...cell.Cell) *Hive
• type Options
• type ReconcilerMetrics
  • func NewStateDBReconcilerMetrics() (ReconcilerMetrics, reconciler.Metrics)
• type Shutdowner
• type StateDBMetrics
  • func NewStateDBMetrics() (StateDBMetrics, statedb.Metrics)

Constants

const (
	LabelModuleId  = "module_id"
	LabelOperation = "op"
)

Variables

var (
	ShutdownWithError = upstream.ShutdownWithError
)

Functions

func AddConfigOverride

func AddConfigOverride[Cfg cell.Flagger](h *Hive, override func(*Cfg))

Types

type Hive

type Hive = upstream.Hive

func New

func New(cells ...cell.Cell) *Hive

New wraps the hive.New to create a hive with defaults used by cilium-agent. pkg/hive should eventually go away and this code should live in e.g. daemon/cmd or operator/cmd.

type Options

type Options = upstream.Options

type ReconcilerMetrics

type ReconcilerMetrics struct {
	IncrementalReconciliationCount         metric.Vec[metric.Counter]
	IncrementalReconciliationDuration      metric.Vec[metric.Observer]
	IncrementalReconciliationTotalErrors   metric.Vec[metric.Counter]
	IncrementalReconciliationCurrentErrors metric.Vec[metric.Gauge]

	FullReconciliationCount          metric.Vec[metric.Counter]
	FullReconciliationOutOfSyncCount metric.Vec[metric.Counter]
	FullReconciliationTotalErrors    metric.Vec[metric.Counter]
	FullReconciliationDuration       metric.Vec[metric.Observer]
}

func NewStateDBReconcilerMetrics

func NewStateDBReconcilerMetrics() (ReconcilerMetrics, reconciler.Metrics)

type Shutdowner

type Shutdowner = upstream.Shutdowner

type StateDBMetrics

type StateDBMetrics struct {
	// How long a read transaction was held.
	WriteTxnDuration metric.Vec[metric.Observer]
	// How long it took to acquire a write transaction for all tables.
	WriteTxnAcquisition metric.Vec[metric.Observer]
	// How long writers were blocked while waiting to acquire a write transaction for a specific table.
	TableContention metric.Vec[metric.Gauge]
	// The amount of objects in a given table.
	TableObjectCount metric.Vec[metric.Gauge]
	// The current revision of a given table.
	TableRevision metric.Vec[metric.Gauge]
	// The amount of delete trackers for a given table.
	TableDeleteTrackerCount metric.Vec[metric.Gauge]
	// The amount of objects in the graveyard for a given table.
	TableGraveyardObjectCount metric.Vec[metric.Gauge]
	// The lowest revision of a given table that has been processed by the graveyard garbage collector.
	TableGraveyardLowWatermark metric.Vec[metric.Gauge]
	// The time it took to clean the graveyard for a given table.
	TableGraveyardCleaningDuration metric.Vec[metric.Observer]
}

func NewStateDBMetrics

func NewStateDBMetrics() (StateDBMetrics, statedb.Metrics)