Versions in this module Expand all Collapse all v0 v0.34.0 Sep 26, 2022 Changes in this version + func RunClientTests(f ClientFactory) func(*testing.T) + type ClientFactory func() (otlpmetric.Client, Collector) + type Collector interface + Collect func() *Storage + type GRPCCollector struct + func NewGRPCCollector(endpoint string, errCh <-chan error) (*GRPCCollector, error) + func (c *GRPCCollector) Addr() net.Addr + func (c *GRPCCollector) Collect() *Storage + func (c *GRPCCollector) Export(ctx context.Context, req *collpb.ExportMetricsServiceRequest) (*collpb.ExportMetricsServiceResponse, error) + func (c *GRPCCollector) Headers() map[string][]string + func (c *GRPCCollector) Shutdown() + type HTTPCollector struct + func NewHTTPCollector(endpoint string, errCh <-chan error) (*HTTPCollector, error) + func (c *HTTPCollector) Addr() net.Addr + func (c *HTTPCollector) Collect() *Storage + func (c *HTTPCollector) Headers() map[string][]string + func (c *HTTPCollector) Shutdown(ctx context.Context) error + type HTTPResponseError struct + Err error + Header http.Header + Status int + func (e *HTTPResponseError) Error() string + func (e *HTTPResponseError) Unwrap() error + type Storage struct + func NewStorage() *Storage + func (s *Storage) Add(request *collpb.ExportMetricsServiceRequest) + func (s *Storage) Dump() []*mpb.ResourceMetrics