doublewrite

Documentation

Index

• Constants
• Variables
• type Config
  • func (def Config) Flags(flags *pflag.FlagSet)
• type DoubleWriteMetricReporter
  • func (g *DoubleWriteMetricReporter) Start(ctx cell.HookContext) error
  • func (g *DoubleWriteMetricReporter) Stop(ctx cell.HookContext) error
• type Metrics
  • func NewMetrics() *Metrics
• type NoOpHandlerWithListDone
  • func (h NoOpHandlerWithListDone) OnListDone()

Constants

const (
	// Interval is the refresh interval for the Double Write Metric Reporter
	Interval = "double-write-metric-reporter-interval"
)

Variables

var Cell = cell.Module(
	"double-write-metric-reporter",
	"The Double-Write Metric Reporter compares identities in KVStore and CRD",

	cell.Config(defaultConfig),

	cell.Invoke(registerDoubleWriteMetricReporter),

	metrics.Metric(NewMetrics),
)

Types

type Config

type Config struct {
	Interval time.Duration `mapstructure:"double-write-metric-reporter-interval"`
}

func (Config) Flags

func (def Config) Flags(flags *pflag.FlagSet)

type DoubleWriteMetricReporter

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

func (*DoubleWriteMetricReporter) Start

func (g *DoubleWriteMetricReporter) Start(ctx cell.HookContext) error

func (*DoubleWriteMetricReporter) Stop

func (g *DoubleWriteMetricReporter) Stop(ctx cell.HookContext) error

type Metrics

type Metrics struct {
	// IdentityCRDTotalCount records the total number of CRD identities
	// Requires the Double-Write Identity allocation mode to be enabled
	IdentityCRDTotalCount metric.Gauge

	// IdentityKVStoreTotalCount records the total number of identities in the KVStore
	// Requires the Double-Write Identity allocation mode to be enabled
	IdentityKVStoreTotalCount metric.Gauge

	// IdentityCRDOnlyCount records the number of CRD identities not present in the KVStore
	// Requires the Double-Write Identity allocation mode to be enabled
	IdentityCRDOnlyCount metric.Gauge

	// IdentityKVStoreOnlyCount records the number of identities in the KVStore not present as a CRD
	// Requires the Double-Write Identity allocation mode to be enabled
	IdentityKVStoreOnlyCount metric.Gauge
}

func NewMetrics

func NewMetrics() *Metrics

type NoOpHandlerWithListDone

type NoOpHandlerWithListDone struct {
	doublewrite.NoOpHandler
	// contains filtered or unexported fields
}

func (NoOpHandlerWithListDone) OnListDone

func (h NoOpHandlerWithListDone) OnListDone()