loaders

Documentation

Index

• Variables
• func DecodeConfig(src, dst interface{}) error
• func Register(name string, initFn Initializer)
• type Initializer
• type Option
  • func WithRegistry(reg *prometheus.Registry) Option
• type TargetLoader
• type TargetOperation
  • func Diff(m1, m2 map[string]*types.TargetConfig) *TargetOperation

Variables

var Loaders = map[string]Initializer{}

var LoadersTypes = []string{
	"file",
	"consul",
	"docker",
	"http",
}

Functions

func DecodeConfig

func DecodeConfig(src, dst interface{}) error

func Register

func Register(name string, initFn Initializer)

Types

type Initializer

type Initializer func() TargetLoader

type Option

type Option func(TargetLoader)

func WithRegistry

func WithRegistry(reg *prometheus.Registry) Option

type TargetLoader

type TargetLoader interface {
	Init(context.Context, map[string]interface{}, *log.Logger, ...Option) error
	Start(context.Context) chan *TargetOperation
	RegisterMetrics(*prometheus.Registry)
}

type TargetOperation

type TargetOperation struct {
	Add []*types.TargetConfig
	Del []string
}

func Diff

func Diff(m1, m2 map[string]*types.TargetConfig) *TargetOperation