lokihttp

Documentation

Index

• Constants
• Variables
• type Client
  • func New(reg prometheus.Registerer, cfg Config, logger log.Logger) (Client, error)
  • func NewWithTripperware(reg prometheus.Registerer, cfg Config, logger log.Logger, tp Tripperware) (Client, error)
• type Config
• type Entry
• type Fake
  • func NewFake() *Fake
  • func (c *Fake) Chan() chan<- Entry
  • func (c *Fake) Stop()
  • func (c *Fake) StopNow()
• type Tripperware

Constants

const (

	// Label reserved to override the tenant ID while processing
	// pipeline stages
	ReservedLabelTenantID = "__tenant_id__"

	LatencyLabel = "filename"
	HostLabel    = "host"
)

Variables

var UserAgent = fmt.Sprintf("grafana/%s", setting.BuildVersion)

Types

type Client

type Client interface {
	Chan() chan<- Entry

	Stop()
	StopNow()
}

Client pushes entries to Loki and can be stopped

func New

func New(reg prometheus.Registerer, cfg Config, logger log.Logger) (Client, error)

New makes a new Client.

func NewWithTripperware

func NewWithTripperware(reg prometheus.Registerer, cfg Config, logger log.Logger, tp Tripperware) (Client, error)

NewWithTripperware creates a new Loki client with a custom tripperware.

type Config

type Config struct {
	URL       flagext.URLValue
	BatchWait time.Duration
	BatchSize int

	Client config.HTTPClientConfig

	BackoffConfig backoff.Config
	Timeout       time.Duration

	TenantID string
}

Config describes configuration for a HTTP pusher client.

type Entry

type Entry struct {
	Labels model.LabelSet
	logproto.Entry
}

Entry is a log entry with labels.

type Fake

type Fake struct {
	Labels model.LabelSet
	Entry  string
	// contains filtered or unexported fields
}

func NewFake

func NewFake() *Fake

func (*Fake) Chan

func (c *Fake) Chan() chan<- Entry

func (*Fake) Stop

func (c *Fake) Stop()

func (*Fake) StopNow

func (c *Fake) StopNow()

type Tripperware

type Tripperware func(http.RoundTripper) http.RoundTripper

Tripperware can wrap a roundtripper.