client

Documentation

Index

• func New(cfg client.Config, numberOfBatchIds uint64, logger log.Logger) (types.LokiClient, error)
• func NewClient(cfg *config.Config, logger log.Logger) (types.LokiClient, error)
• func NewPromtailClient(cfg client.Config, logger log.Logger) (types.LokiClient, error)
• func NewRemoveTenantIdClient(clientToWrap types.LokiClient) types.LokiClient
• type LokiClient

Functions

func New

func New(cfg client.Config, numberOfBatchIds uint64, logger log.Logger) (types.LokiClient, error)

New makes a new Client.

func NewClient

func NewClient(cfg *config.Config, logger log.Logger) (types.LokiClient, error)

NewClient creates a new client based on the fluentbit configuration.

func NewPromtailClient

func NewPromtailClient(cfg client.Config, logger log.Logger) (types.LokiClient, error)

NewPromtailClient return promtail client which increments the ForwardedLogs counter on successful call of the Handle function

func NewRemoveTenantIdClient

func NewRemoveTenantIdClient(clientToWrap types.LokiClient) types.LokiClient

NewRemoveTenantIdClient return loki client wich removes the __tenant_id__ value fro the label set

Types

type LokiClient

type LokiClient interface {
	Handle(labels model.LabelSet, time time.Time, entry string) error
	// Stop shut down the client immediately without waiting to send the saved logs
	Stop()
	// StopWait stops the client of receiving new logs and waits all saved logs to be sent until shuting down
	StopWait()
}