Version: v0.0.0-...-c527c4f Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Feb 21, 2021 License: MIT Imports: 7 Imported by: 0




This section is empty.


This section is empty.


func Write

func Write(pts []lineprotocol.Point, c write.Client, cfg WriteConfig) (uint64, time.Duration)

Write takes in a slice of lineprotocol.Points, a write.Client, and a WriteConfig. It will attempt to write data to the target until one of the following conditions is met. 1. We reach that MaxPoints specified in the WriteConfig. 2. We've passed the Deadline specified in the WriteConfig.


type WriteConfig

type WriteConfig struct {
	BatchSize uint64
	MaxPoints uint64

	// If 0 (NoCompression), do not gzip at all.
	// Otherwise, pass this value to the gzip writer.
	GzipLevel int

	Deadline time.Time
	Tick     <-chan time.Time
	Results  chan<- WriteResult

WriteConfig specifies the configuration for the Write function.

type WriteResult

type WriteResult struct {
	LatNs      int64
	StatusCode int
	Body       string // Only populated when unusual status code encountered.
	Err        error
	Timestamp  int64

WriteResult contains the latency, status code, and error type each time a write happens.

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL