influxdb

Nov 1, 2023

Changes in this version

+ type Exporter struct

+ func NewExporter(opts ...Option) *Exporter

+ func (e *Exporter) ExportView(viewData *view.Data)

+ type MetricPoint struct

+ Fields map[string]interface{}

+ Measurement string

+ Tags map[string]string

+ Timestamp time.Time

+ type Option func(*Exporter)

+ func WithErrorHandler(h func(error)) Option

+ func WithStore(s Store) Option

+ func WithTags(tags map[string]string) Option

+ type Store interface

+ Database func() string

+ GetClient func() influxdb.Client

+ Ping func(context.Context, time.Duration) error

+ ReadMetrics func(context.Context, string) (*influxdb.Response, error)

+ WriteBatch func(context.Context, []MetricPoint) error

+ WriteMetrics func(context.Context, string, map[string]string, map[string]interface{}) error

+ func NewStore(opts ...StoreOption) (Store, error)

+ type StoreOption func(*influxDB)

+ func WithAddr(addr string) StoreOption

+ func WithDatabase(db string) StoreOption

+ func WithInsecureSkipVerify(skip bool) StoreOption

+ func WithMapper(mapper func(string, map[string]string) (string, map[string]string)) StoreOption

+ func WithNameAsTag(timeseries string) StoreOption

+ func WithPassword(pwd string) StoreOption

+ func WithProxy(proxy func(*http.Request) (*url.URL, error)) StoreOption

+ func WithTLSConfig(config *tls.Config) StoreOption

+ func WithTimeout(d time.Duration) StoreOption

+ func WithURL(r string) StoreOption

+ func WithUser(user string) StoreOption