ingester

Documentation

Index

• type Ingester
  • func New(hostTagStorage htstorage.Storage, metricsRecorder Recorder, ...) Ingester
  • func NewDisabled() Ingester
• type Recorder
  • func NewRecorder(reg prometheus.Registerer) Recorder

Types

type Ingester

type Ingester interface {
	StoreMetrics(ctx context.Context, series ddstructs.Series) error
	StoreHostTags(ctx context.Context, hostname string, systemTags []string) error
	StoreCheckRun(ctx context.Context, checks ddstructs.ServiceChecks) error
}

func New

func New(
	hostTagStorage htstorage.Storage,
	metricsRecorder Recorder,
	client remotewrite.Client,
) Ingester

func NewDisabled

func NewDisabled() Ingester

type Recorder

type Recorder interface {
	// contains filtered or unexported methods
}

func NewRecorder

func NewRecorder(reg prometheus.Registerer) Recorder

NewRecorder returns a new Prometheus metrics Recorder. It ensures that the ingester metrics are properly registered.