influxdb

package

v2.16.13 Latest Latest Go to latest Published: Jul 28, 2026 License: Apache-2.0, Apache-2.0 Imports: 11 Imported by: 0

Details

View Source

const Namespace = "github_com/letgoapp/krakend-influx"

View Source

var ErrNoConfig = errors.New("unable to load custom config")

func New(ctx context.Context, extraConfig config.ExtraConfig, metricsCollector *ginmetrics.Metrics, logger logging.Logger) error

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

func NewBuffer(size int) *Buffer

func (b *Buffer) Add(ps ...client.BatchPoints)

func (b *Buffer) Elements() []client.BatchPoints