influxdb

Documentation

Index

• Constants
• func IsReservedName(name string) bool
• func QuoteField(f gopi.Field) (string, error)
• func QuoteFieldName(f gopi.Field) string
• func QuoteFieldValue(f gopi.Field) string
• func QuoteFields(fields []gopi.Field) (string, error)
• func QuoteMeasurement(m gopi.Measurement) (string, error)
• type Writer
  • func (this *Writer) Credentials() (string, string)
  • func (this *Writer) Database() string
  • func (this *Writer) Define(cfg gopi.Config) error
  • func (this *Writer) Dispose() error
  • func (this *Writer) Endpoint() *url.URL
  • func (this *Writer) New(cfg gopi.Config) error
  • func (this *Writer) Ping() (time.Duration, error)
  • func (this *Writer) Run(ctx context.Context) error
  • func (this *Writer) String() string
  • func (this *Writer) Write(metrics ...gopi.Measurement) error

Constants

const (
	DefaultScheme   = "http"
	DefaultEndpoint = DefaultScheme + "://localhost/metrics"
	DefaultPort     = 8086

	EnvUsername = "INFLUX_USERNAME"
	EnvPassword = "INFLUX_PASSWORD"
)

Functions

func IsReservedName

func IsReservedName(name string) bool

func QuoteField

func QuoteField(f gopi.Field) (string, error)

func QuoteFieldName

func QuoteFieldName(f gopi.Field) string

QuoteFieldName returns quoted version of the name, returning empty string if invalid

func QuoteFieldValue

func QuoteFieldValue(f gopi.Field) string

QuoteFieldName returns quoted version of the value, returning empty string if invalid or nil

func QuoteFields

func QuoteFields(fields []gopi.Field) (string, error)

func QuoteMeasurement

func QuoteMeasurement(m gopi.Measurement) (string, error)

QuoteMeasurement returns a line for a measurement

Types

type Writer

type Writer struct {
	sync.Mutex
	gopi.Unit
	gopi.Logger
	gopi.Publisher
	*http.Client
	// contains filtered or unexported fields
}

func (*Writer) Credentials

func (this *Writer) Credentials() (string, string)

func (*Writer) Database

func (this *Writer) Database() string

func (*Writer) Define

func (this *Writer) Define(cfg gopi.Config) error

func (*Writer) Dispose

func (this *Writer) Dispose() error

func (*Writer) Endpoint

func (this *Writer) Endpoint() *url.URL

func (*Writer) New

func (this *Writer) New(cfg gopi.Config) error

func (*Writer) Ping

func (this *Writer) Ping() (time.Duration, error)

func (*Writer) Run

func (this *Writer) Run(ctx context.Context) error

func (*Writer) String

func (this *Writer) String() string

func (*Writer) Write

func (this *Writer) Write(metrics ...gopi.Measurement) error

Write measurements to the endpoint