herokutarget

Documentation

Index

• Constants
• type HerokuDrainTargetConfig
• type HerokuTarget
  • func NewHerokuTarget(metrics *Metrics, logger log.Logger, handler loki.EntryHandler, ...) (*HerokuTarget, error)
  • func (h *HerokuTarget) Details() interface{}
  • func (h *HerokuTarget) DrainEndpoint() string
  • func (h *HerokuTarget) HTTPListenAddress() string
  • func (h *HerokuTarget) HealthyEndpoint() string
  • func (h *HerokuTarget) Labels() model.LabelSet
  • func (h *HerokuTarget) Ready() bool
  • func (h *HerokuTarget) Stop() error
• type Metrics
  • func NewMetrics(reg prometheus.Registerer) *Metrics

Constants

const ReservedLabelTenantID = "__tenant_id__"

Types

type HerokuDrainTargetConfig

type HerokuDrainTargetConfig struct {
	Server *fnet.ServerConfig

	// Labels optionally holds labels to associate with each record received on the push api.
	Labels model.LabelSet

	// UseIncomingTimestamp sets the timestamp to the incoming heroku log entry timestamp. If false,
	// promtail will assign the current timestamp to the log entry when it was processed.
	UseIncomingTimestamp bool
}

HerokuDrainTargetConfig describes a scrape config to listen and consume heroku logs, in the HTTPS drain manner.

type HerokuTarget

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

func NewHerokuTarget

func NewHerokuTarget(metrics *Metrics, logger log.Logger, handler loki.EntryHandler, relabel []*relabel.Config, config *HerokuDrainTargetConfig, reg prometheus.Registerer) (*HerokuTarget, error)

NewHerokuTarget creates a brand new Heroku Drain target, capable of receiving logs from a Heroku application through an HTTP drain.

func (*HerokuTarget) Details

func (h *HerokuTarget) Details() interface{}

func (*HerokuTarget) DrainEndpoint

func (h *HerokuTarget) DrainEndpoint() string

func (*HerokuTarget) HTTPListenAddress

func (h *HerokuTarget) HTTPListenAddress() string

func (*HerokuTarget) HealthyEndpoint

func (h *HerokuTarget) HealthyEndpoint() string

func (*HerokuTarget) Labels

func (h *HerokuTarget) Labels() model.LabelSet

func (*HerokuTarget) Ready

func (h *HerokuTarget) Ready() bool

func (*HerokuTarget) Stop

func (h *HerokuTarget) Stop() error

type Metrics

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

func NewMetrics

func NewMetrics(reg prometheus.Registerer) *Metrics