updater

Documentation

Index

• func RegisterUpdater(name string, isDefaultEnabled bool, ...)
• type UnitUpdater
  • func NewUnitUpdater(logger log.Logger) (*UnitUpdater, error)
  • func (u UnitUpdater) Update(queryTime time.Time, units []types.Unit) []types.Unit
• type Updater
  • func NewTSDBUpdater(logger log.Logger) (Updater, error)

Functions

func RegisterUpdater

func RegisterUpdater(name string, isDefaultEnabled bool, factory func(logger log.Logger) (Updater, error))

Register updater

Types

type UnitUpdater

type UnitUpdater struct {
	Names    []string
	Updaters []Updater
	Logger   log.Logger
}

UnitUpdater implements the interface to update compute units from different updaters.

func NewUnitUpdater

func NewUnitUpdater(logger log.Logger) (*UnitUpdater, error)

NewUnitUpdater creates a new UnitUpdater

func (UnitUpdater) Update

func (u UnitUpdater) Update(queryTime time.Time, units []types.Unit) []types.Unit

Update implements updating units using registered updaters

type Updater

type Updater interface {
	Update(queryTime time.Time, units []types.Unit) []types.Unit
}

Unit updater interface

func NewTSDBUpdater

func NewTSDBUpdater(logger log.Logger) (Updater, error)

Factory to create a new updater interface