sidecar

Jun 23, 2022

Changes in this version

type InjectConfigOptions

+ ShardMonitorEnable bool

Feb 22, 2021

Changes in this version

type InjectConfigOptions

+ PrometheusURL string

type Injector

+ func (i *Injector) ApplyConfig(cfg *prom.ConfigInfo) error

+ type TargetsInfo struct

+ IdleAt *time.Time

+ Status map[uint64]*target.ScrapeStatus

+ Targets map[string][]*target.Target

+ type TargetsManager struct

+ func NewTargetsManager(storeDir string, log logrus.FieldLogger) *TargetsManager

+ func (t *TargetsManager) AddUpdateCallbacks(f ...func(targets map[string][]*target.Target) error)

+ func (t *TargetsManager) Load() error

+ func (t *TargetsManager) TargetsInfo() TargetsInfo

+ func (t *TargetsManager) UpdateTargets(req *shard.UpdateTargetsRequest) error

Dec 18, 2020

Changes in this version

+ type Service struct

+ func NewService(promURL string, configFile string, storeDir string, ...) *Service

+ func (s *Service) Init() error

+ func (s *Service) Run(address string) error

+ func (s *Service) ServeHTTP(wt http.ResponseWriter, r *http.Request)

Dec 11, 2020

Changes in this version

type Proxy

+ func (p *Proxy) TargetStatus() map[uint64]*target.ScrapeStatus

Nov 20, 2020

Changes in this version

+ type API struct

+ ConfigReload chan *config.Config

+ TargetReload chan map[string][]*target.Target

+ func NewAPI(promURL string, proxy *Proxy, readConfig func() ([]byte, error), ...) *API

+ func (w *API) Run(address string) error

+ func (w *API) ServeHTTP(wt http.ResponseWriter, r *http.Request)

+ type InjectConfigOptions struct

+ ProxyURL string

+ type Injector struct

+ func NewInjector(originFile, outFile string, option InjectConfigOptions, log logrus.FieldLogger) *Injector

+ func (i *Injector) UpdateConfig() error

+ func (i *Injector) UpdateTargets(ts map[string][]*target.Target) error

+ type Proxy struct

+ func NewProxy(spManager *scrape.Manager, log logrus.FieldLogger) *Proxy

+ func (p *Proxy) Run(address string) error

+ func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (p *Proxy) UpdateTargets(groups map[string][]*target.Target) error