instance

Sep 14, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Sep 8, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Aug 12, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Aug 6, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Jul 30, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Jul 15, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Jun 22, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Jun 17, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Jun 3, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Changes in this version

type HostFilter

+ func (f *HostFilter) PatchSD(scrapes []*config.ScrapeConfig)

+ func (f *HostFilter) SetRelabels(relabels []*relabel.Config)

May 24, 2021 GO-2022-0305

  GO-2022-0305: Instance config inline secret exposure in Grafana in github.com/grafana/agent

Changes in this version

+ var DefaultGlobalConfig = GlobalConfig

type BasicManager

+ func (m *BasicManager) GetInstance(name string) (ManagedInstance, error)

+ func (m *BasicManager) UpdateManagerConfig(c BasicManagerConfig)

type Config

+ func (c *Config) Clone() (Config, error)

+ type GlobalConfig struct

+ Prometheus config.GlobalConfig

+ RemoteWrite []*config.RemoteWriteConfig

+ func (c *GlobalConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

type GroupManager

+ func (m *GroupManager) GetInstance(name string) (ManagedInstance, error)

type Instance

+ func (i *Instance) Appender(ctx context.Context) storage.Appender

type ManagedInstance

+ Appender func(ctx context.Context) storage.Appender

type Manager

+ GetInstance func(name string) (ManagedInstance, error)

type MockManager

+ GetInstanceFunc func(name string) (ManagedInstance, error)

+ func (m MockManager) GetInstance(name string) (ManagedInstance, error)

+ type ModalManager struct

+ func NewModalManager(reg prometheus.Registerer, l log.Logger, next Manager, mode Mode) (*ModalManager, error)

+ func (m *ModalManager) ApplyConfig(c Config) error

+ func (m *ModalManager) DeleteConfig(name string) error

+ func (m *ModalManager) GetInstance(name string) (ManagedInstance, error)

+ func (m *ModalManager) ListConfigs() map[string]Config

+ func (m *ModalManager) ListInstances() map[string]ManagedInstance

+ func (m *ModalManager) SetMode(newMode Mode) error

+ func (m *ModalManager) Stop()

+ type Mode string

+ var DefaultMode = ModeShared

+ var ModeDistinct Mode = "distinct"

+ var ModeShared Mode = "shared"

+ func (m *Mode) UnmarshalYAML(unmarshal func(interface{}) error) error

type NoOpInstance

+ func (NoOpInstance) Appender(_ context.Context) storage.Appender

Feb 25, 2021

Changes in this version

+ var ErrNotReady = errors.New("Scrape manager not ready")

Jan 13, 2021

Changes in this version

+ func NewSigV4RoundTripper(cfg SigV4Config, next http.RoundTripper) (http.RoundTripper, error)

type Config

+ func (c *Config) BaseRemoteWrite() []*config.RemoteWriteConfig

type Instance

+ func (i *Instance) StorageDirectory() string

type ManagedInstance

+ StorageDirectory func() string

type NoOpInstance

+ func (NoOpInstance) StorageDirectory() string

+ type RemoteWriteConfig struct

+ Base config.RemoteWriteConfig

+ SigV4 SigV4Config

+ func (c *RemoteWriteConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (c *RemoteWriteConfig) Validate() error

+ type SigV4Config struct

+ Enabled bool

+ Region string

Dec 10, 2020

Changes in this version

type Config

+ MaxWALTime time.Duration

+ MinWALTime time.Duration

Oct 29, 2020

Changes in this version

+ var HostFilterLabelMatchers = []string

type Config

+ HostFilterRelabelConfigs []*relabel.Config

Sep 4, 2020

Changes in this version

+ type CountingManager struct

+ func NewCountingManager(reg prometheus.Registerer, inner Manager) *CountingManager

+ func (cm *CountingManager) ApplyConfig(c Config) error

+ func (cm *CountingManager) DeleteConfig(name string) error

+ func (cm *CountingManager) ListConfigs() map[string]Config

+ func (cm *CountingManager) ListInstances() map[string]ManagedInstance

+ func (cm *CountingManager) Stop()

Aug 12, 2020

Changes in this version

+ var DefaultBasicManagerConfig = BasicManagerConfig

+ type BasicManager struct

+ func NewBasicManager(cfg BasicManagerConfig, logger log.Logger, launch Factory, ...) *BasicManager

+ func (m *BasicManager) ApplyConfig(c Config) error

+ func (m *BasicManager) DeleteConfig(name string) error

+ func (m *BasicManager) ListConfigs() map[string]Config

+ func (m *BasicManager) ListInstances() map[string]ManagedInstance

+ func (m *BasicManager) Stop()

+ type BasicManagerConfig struct

+ InstanceRestartBackoff time.Duration

+ type ConfigValidator func(c *Config) error

+ type ErrInvalidUpdate struct

+ Inner error

+ func (e ErrInvalidUpdate) As(err interface{}) bool

+ func (e ErrInvalidUpdate) Error() string

+ func (e ErrInvalidUpdate) Is(err error) bool

+ type Factory func(c Config) (ManagedInstance, error)

+ type GroupManager struct

+ func NewGroupManager(inner Manager) *GroupManager

+ func (m *GroupManager) ApplyConfig(c Config) error

+ func (m *GroupManager) DeleteConfig(name string) error

+ func (m *GroupManager) ListConfigs() map[string]Config

+ func (m *GroupManager) ListInstances() map[string]ManagedInstance

+ func (m *GroupManager) Stop()

type Instance

+ func (i *Instance) TargetsActive() map[string][]*scrape.Target

+ func (i *Instance) Update(c Config) error

+ type ManagedInstance interface

+ Run func(ctx context.Context) error

+ TargetsActive func() map[string][]*scrape.Target

+ Update func(c Config) error

+ type Manager interface

+ ApplyConfig func(Config) error

+ DeleteConfig func(name string) error

+ ListConfigs func() map[string]Config

+ ListInstances func() map[string]ManagedInstance

+ Stop func()

+ type MockManager struct

+ ApplyConfigFunc func(Config) error

+ DeleteConfigFunc func(name string) error

+ ListConfigsFunc func() map[string]Config

+ ListInstancesFunc func() map[string]ManagedInstance

+ StopFunc func()

+ func (m MockManager) ApplyConfig(c Config) error

+ func (m MockManager) DeleteConfig(name string) error

+ func (m MockManager) ListConfigs() map[string]Config

+ func (m MockManager) ListInstances() map[string]ManagedInstance

+ func (m MockManager) Stop()

+ type NoOpInstance struct

+ func (NoOpInstance) Run(ctx context.Context) error

+ func (NoOpInstance) TargetsActive() map[string][]*scrape.Target

+ func (NoOpInstance) Update(_ Config) error

Jun 18, 2020

Changes in this version

+ func Hostname() (string, error)

May 29, 2020

Changes in this version

+ var DefaultConfig = Config

+ var DefaultRelabelConfigs = []*relabel.Config

+ func MarshalConfig(c *Config, scrubSecrets bool) ([]byte, error)

+ func MarshalConfigToWriter(c *Config, w io.Writer, scrubSecrets bool) error

+ type Config struct

+ HostFilter bool

+ Name string

+ RemoteFlushDeadline time.Duration

+ RemoteWrite []*config.RemoteWriteConfig

+ ScrapeConfigs []*config.ScrapeConfig

+ WALTruncateFrequency time.Duration

+ WriteStaleOnShutdown bool

+ func UnmarshalConfig(r io.Reader) (*Config, error)

+ func (c *Config) ApplyDefaults(global *config.GlobalConfig) error

+ func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (c Config) MarshalYAML() (interface{}, error)

+ type DiscoveredGroups = map[string][]*targetgroup.Group

+ func FilterGroups(in DiscoveredGroups, host string) DiscoveredGroups

+ type GroupChannel = <-chan DiscoveredGroups

+ type HostFilter struct

+ func NewHostFilter(host string) *HostFilter

+ func (f *HostFilter) Run(syncCh GroupChannel)

+ func (f *HostFilter) Stop()

+ func (f *HostFilter) SyncCh() GroupChannel

+ type Instance struct

+ func New(globalCfg config.GlobalConfig, cfg Config, walDir string, logger log.Logger) (*Instance, error)

+ func (i *Instance) Run(ctx context.Context) error

+ type MetricValueCollector struct

+ func NewMetricValueCollector(g prometheus.Gatherer, match string) *MetricValueCollector

+ func (vc *MetricValueCollector) GetValues(label string, labelValues ...string) ([]float64, error)