prometheus_output

Documentation

Index

• type Config
• type PrometheusOutput
  • func (p *PrometheusOutput) Close() error
  • func (p *PrometheusOutput) Collect(ch chan<- prometheus.Metric)
  • func (p *PrometheusOutput) Describe(ch chan<- *prometheus.Desc)
  • func (p *PrometheusOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, ...) error
  • func (p *PrometheusOutput) RegisterMetrics(reg *prometheus.Registry)
  • func (p *PrometheusOutput) SetEventProcessors(ps map[string]map[string]interface{}, log *log.Logger)
  • func (p *PrometheusOutput) SetLogger(logger *log.Logger)
  • func (p *PrometheusOutput) SetName(name string)
  • func (p *PrometheusOutput) String() string
  • func (p *PrometheusOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)
  • func (p *PrometheusOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)

Types

type Config

type Config struct {
	Listen                 string        `mapstructure:"listen,omitempty"`
	Path                   string        `mapstructure:"path,omitempty"`
	Expiration             time.Duration `mapstructure:"expiration,omitempty"`
	MetricPrefix           string        `mapstructure:"metric-prefix,omitempty"`
	AppendSubscriptionName bool          `mapstructure:"append-subscription-name,omitempty"`
	ExportTimestamps       bool          `mapstructure:"export-timestamps,omitempty"`
	StringsAsLabels        bool          `mapstructure:"strings-as-labels,omitempty"`
	Debug                  bool          `mapstructure:"debug,omitempty"`
	EventProcessors        []string      `mapstructure:"event-processors,omitempty"`
}

type PrometheusOutput

type PrometheusOutput struct {
	Cfg *Config

	sync.Mutex
	// contains filtered or unexported fields
}

func (*PrometheusOutput) Close

func (p *PrometheusOutput) Close() error

func (*PrometheusOutput) Collect

func (p *PrometheusOutput) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector

func (*PrometheusOutput) Describe

func (p *PrometheusOutput) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector

func (*PrometheusOutput) Init

func (p *PrometheusOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, opts ...outputs.Option) error

func (*PrometheusOutput) RegisterMetrics

func (p *PrometheusOutput) RegisterMetrics(reg *prometheus.Registry)

func (*PrometheusOutput) SetEventProcessors

func (p *PrometheusOutput) SetEventProcessors(ps map[string]map[string]interface{}, log *log.Logger)

func (*PrometheusOutput) SetLogger

func (p *PrometheusOutput) SetLogger(logger *log.Logger)

func (*PrometheusOutput) SetName

func (p *PrometheusOutput) SetName(name string)

func (*PrometheusOutput) String

func (p *PrometheusOutput) String() string

func (*PrometheusOutput) Write

func (p *PrometheusOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)

Write implements the outputs.Output interface

func (*PrometheusOutput) WriteEvent

func (p *PrometheusOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)