internal

Documentation

Index

• func NewLogger(cfg config.MainConfig, isSupervisor bool) log.Logger
• func NewOTLPClientFactory(cc otlp.ClientConfig) otlp.StorageClientFactory
• func NewTailer(ctx context.Context, scfg SidecarConfig) (*tail.Tailer, error)
• func StartComponents(ctx context.Context, scfg SidecarConfig, tailer tail.WalTailer, ...) error
• func StartTelemetry(scfg SidecarConfig, defaultSvcName string, isSuper bool) *telemetry.Telemetry
• type ShutdownFunc
• type SidecarConfig

Functions

func NewLogger

func NewLogger(cfg config.MainConfig, isSupervisor bool) log.Logger

func NewOTLPClientFactory

func NewOTLPClientFactory(cc otlp.ClientConfig) otlp.StorageClientFactory

func NewTailer

func NewTailer(ctx context.Context, scfg SidecarConfig) (*tail.Tailer, error)

func StartComponents

func StartComponents(ctx context.Context, scfg SidecarConfig, tailer tail.WalTailer, startOffset int) error

func StartTelemetry

func StartTelemetry(scfg SidecarConfig, defaultSvcName string, isSuper bool) *telemetry.Telemetry

Types

type ShutdownFunc

type ShutdownFunc func(context.Context)

type SidecarConfig

type SidecarConfig struct {
	ClientFactory otlp.StorageClientFactory
	Monitor       *prometheus.Monitor
	Logger        log.Logger

	// InstanceId is a unique identifer for this process.
	InstanceId    string
	Matchers      [][]*labels.Matcher
	MetricRenames map[string]string
	MetadataCache *metadata.Cache

	FailingReporter common.FailingReporter

	config.MainConfig
}