influxdb

package

v1.5.0 Latest Latest Go to latest Published: Jan 30, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Factory struct {
	// contains filtered or unexported fields
}

func NewFactory() *Factory

func (f *Factory) AddFlags(flagSet *flag.FlagSet)

AddFlags implements plugin.Configurable

func (f *Factory) CreateWriter() (metricstore.Writer, error)

func (f *Factory) InitFromOptions(o Options)

InitFromOptions initializes factory from options.

func (f *Factory) InitFromViper(v *viper.Viper)

InitFromViper implements plugin.Configurable

func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger) error

type MetricWriter struct {
	// contains filtered or unexported fields
}

func NewMetricWriter(l *zap.Logger, client influxdb2.Client, org string, bucket string) *MetricWriter

func (m *MetricWriter) WriteMetric(metrics []prompb.TimeSeries) error

WriteMetric is Asynchronous writer, and it is bulk insert

type Options struct {
	influxdb2.Options
	TLS tlscfg.Options
	// contains filtered or unexported fields
}

func (o *Options) AddFlags(flagSet *flag.FlagSet)

func (o *Options) InitFromViper(v *viper.Viper)

Path	Synopsis
metricstore
dbmodel