influxdb

package

v3.0.33 Latest Latest Go to latest Published: Mar 12, 2021 License: BSD-2-Clause Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/djthorpe/gopi

Links

Open Source Insights

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

Constants ¶

View Source

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

	EnvUsername = "INFLUX_USERNAME"
	EnvPassword = "INFLUX_PASSWORD"
)

Variables ¶

This section is empty.

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 ¶ added in v3.0.3

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

func (*Writer) Credentials ¶ added in v3.0.3

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

func (*Writer) Database ¶ added in v3.0.3

func (this *Writer) Database() string

func (*Writer) Define ¶ added in v3.0.3

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

func (*Writer) Dispose ¶ added in v3.0.3

func (this *Writer) Dispose() error

func (*Writer) Endpoint ¶ added in v3.0.3

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

func (*Writer) New ¶ added in v3.0.3

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

func (*Writer) Ping ¶ added in v3.0.3

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

func (*Writer) Run ¶ added in v3.0.3

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

func (*Writer) String ¶ added in v3.0.3

func (this *Writer) String() string

func (*Writer) Write ¶ added in v3.0.3

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

Write measurements to the endpoint

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL