otlptest

Documentation

Index

• type Exporter
  • func NewExporterWithWriter(w io.Writer) Exporter
• type ExporterFunc
  • func (f ExporterFunc) Export(ctx context.Context, req *collectormetrics.ExportMetricsServiceRequest) (*collectormetrics.ExportMetricsServiceResponse, error)
• type MetricsCollector
  • func NewMetricsCollector(exporter Exporter) *MetricsCollector
  • func NewUnstartedMetricsCollector(exporter Exporter) *MetricsCollector
  • func (mc *MetricsCollector) Close()
  • func (mc *MetricsCollector) Start()

Types

type Exporter

type Exporter interface {
	Export(context.Context, *collectormetrics.ExportMetricsServiceRequest) (*collectormetrics.ExportMetricsServiceResponse, error)
}

func NewExporterWithWriter

func NewExporterWithWriter(w io.Writer) Exporter

type ExporterFunc

type ExporterFunc func(context.Context, *collectormetrics.ExportMetricsServiceRequest) (*collectormetrics.ExportMetricsServiceResponse, error)

func (ExporterFunc) Export

func (f ExporterFunc) Export(ctx context.Context, req *collectormetrics.ExportMetricsServiceRequest) (*collectormetrics.ExportMetricsServiceResponse, error)

type MetricsCollector

type MetricsCollector struct {
	URL      string
	Listener net.Listener
	// contains filtered or unexported fields
}

func NewMetricsCollector

func NewMetricsCollector(exporter Exporter) *MetricsCollector

func NewUnstartedMetricsCollector

func NewUnstartedMetricsCollector(exporter Exporter) *MetricsCollector

func (*MetricsCollector) Close

func (mc *MetricsCollector) Close()

func (*MetricsCollector) Start

func (mc *MetricsCollector) Start()