influx3

package

v0.0.0-...-e105d0e Latest Latest Go to latest Published: Apr 8, 2024 License: Apache-2.0 Imports: 6 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

This section is empty.

This section is empty.

This section is empty.

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

func NewInfluxIngester(opts ...Option) *InfluxDBIngester

NewOptions creates a new Options instance with provided functional options

func (in *InfluxDBIngester) Close() error

func (in *InfluxDBIngester) Get() ([]map[string]any, error)

func (in *InfluxDBIngester) Ingest(data map[string]any)

type Option func(*Options)

func WithClient(client *influxdb3.Client) Option

WithClient sets the InfluxDB client in Options

func WithDatabase(database string) Option

WithDatabase sets the database in Options

func WithLogger(logger *slog.Logger) Option

WithLogger sets the logger in Options

func WithMeasurement(measurement string) Option

WithMeasurement sets the measurement in Options

func WithOrganization(organization string) Option

WithOrganization sets the organization in Options

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