Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + const BatchSize + const BatchWait + const ClientLabel + const HostLabel + const LatencyLabel + const MaxBackoff + const MaxRetries + const MinBackoff + const ReasonGeneric + const ReasonLabel + const ReasonLineTooLong + const ReasonRateLimited + const ReasonStreamLimited + const ReservedLabelTenantID + const TenantLabel + const Timeout + var Reasons = []string + var UserAgent = fmt.Sprintf("promtail/%s", build.Version) + type Client interface + Name func() string + StopNow func() + func New(metrics *Metrics, cfg Config, maxStreams, maxLineSize int, ...) (Client, error) + func NewLogger(metrics *Metrics, log log.Logger, cfgs ...Config) (Client, error) + func NewMulti(metrics *Metrics, logger log.Logger, maxStreams, maxLineSize int, ...) (Client, error) + func NewWithTripperware(metrics *Metrics, cfg Config, maxStreams, maxLineSize int, ...) (Client, error) + type Config struct + BackoffConfig backoff.Config + BatchSize int + BatchWait time.Duration + Client config.HTTPClientConfig + DropRateLimitedBatches bool + ExternalLabels lokiflag.LabelSet + Headers map[string]string + Name string + StreamLagLabels flagext.StringSliceCSV + TenantID string + Timeout time.Duration + URL flagext.URLValue + func (c *Config) RegisterFlags(flags *flag.FlagSet) + func (c *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error + type Manager struct + func NewManager(metrics *Metrics, logger log.Logger, maxStreams, maxLineSize int, ...) (*Manager, error) + func (m *Manager) Chan() chan<- api.Entry + func (m *Manager) Name() string + func (m *Manager) Stop() + func (m *Manager) StopNow() + type Metrics struct + func NewMetrics(reg prometheus.Registerer) *Metrics + type MultiClient struct + func (m *MultiClient) Chan() chan<- api.Entry + func (m *MultiClient) Name() string + func (m *MultiClient) Stop() + func (m *MultiClient) StopNow() + type Stoppable interface + Stop func() + type Tripperware func(http.RoundTripper) http.RoundTripper + type WriterEventsNotifier interface + SubscribeCleanup func(subscriber wal.CleanupEventSubscriber) + SubscribeWrite func(subscriber wal.WriteEventSubscriber)