sidecar

Documentation

Index

• type InjectConfigOptions
• type Injector
  • func NewInjector(outFile string, option InjectConfigOptions, log logrus.FieldLogger) *Injector
  • func (i *Injector) ApplyConfig(cfg *prom.ConfigInfo) error
  • func (i *Injector) UpdateTargets(ts map[string][]*target.Target) error
• type Proxy
  • func NewProxy(getJob func(jobName string) *scrape.JobInfo, ...) *Proxy
  • func (p *Proxy) Run(address string) error
  • func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Service
  • func NewService(promURL string, getPromRuntimeInfo func() (*prom.RuntimeInfo, error), ...) *Service
  • func (s *Service) Run(address string) error
  • func (s *Service) ServeHTTP(wt http.ResponseWriter, r *http.Request)
• type TargetsInfo
• type TargetsManager
  • 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

Types

type InjectConfigOptions

type InjectConfigOptions struct {
	// ProxyURL will be injected to all job if it is not empty
	ProxyURL string
	// PrometheusURL will be injected
	PrometheusURL string
}

InjectConfigOptions indicate what to inject to config file

type Injector

type Injector struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Injector gen injected config file

func NewInjector

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

NewInjector create new injector with InjectConfigOptions

func (*Injector) ApplyConfig

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

ApplyConfig gen new config

func (*Injector) UpdateTargets

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

UpdateTargets set new targets

type Proxy

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

Proxy is a Proxy server for prometheus tManager Proxy will return an empty metrics if this target if not allowed to scrape for this prometheus client otherwise, Proxy do real tManager, statistic metrics samples and return metrics to prometheus

func NewProxy

func NewProxy(
	getJob func(jobName string) *scrape.JobInfo,
	getStatus func() map[uint64]*target.ScrapeStatus,
	log logrus.FieldLogger) *Proxy

NewProxy create a new proxy server

func (*Proxy) Run

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

Run start Proxy server and block

func (*Proxy) ServeHTTP

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

ServeHTTP handle one Proxy request

type Service

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

Service is the api server of shard

func NewService

func NewService(
	promURL string,
	getPromRuntimeInfo func() (*prom.RuntimeInfo, error),
	cfgManager *prom.ConfigManager,
	targetManager *TargetsManager,
	lg logrus.FieldLogger) *Service

NewService create new api server of shard

func (*Service) Run

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

Run start Service at "address"

func (*Service) ServeHTTP

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

type TargetsInfo

type TargetsInfo struct {
	// Targets is all targets this shard scraping
	Targets map[string][]*target.Target
	// IdleAt is the time this shard has no scraping targets
	// IdleAt is nil if at lease one target is scraping
	IdleAt *time.Time
	// Status is the runtime status of all targets
	Status map[uint64]*target.ScrapeStatus `json:"-"`
}

TargetsInfo contains all current targets

type TargetsManager

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

TargetsManager manager local targets of this shard

func NewTargetsManager

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

NewTargetsManager return a new target manager

func (*TargetsManager) AddUpdateCallbacks

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

AddUpdateCallbacks add a call back for targets updating event

func (*TargetsManager) Load

func (t *TargetsManager) Load() error

Load load local targets information from storeDir

func (*TargetsManager) TargetsInfo

func (t *TargetsManager) TargetsInfo() TargetsInfo

TargetsInfo return current targets of this shard

func (*TargetsManager) UpdateTargets

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

UpdateTargets update local targets