write

package

v2.0.0-beta.5 Latest Latest Go to latest Published: Feb 13, 2020 License: MIT Imports: 7 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/mildebrandt/influxdb

Documentation ¶

Index ¶

Constants
func ScanLines(data []byte, atEOF bool) (advance int, token []byte, err error)
type Batcher
- func (b *Batcher) Write(ctx context.Context, org, bucket platform.ID, r io.Reader) error

Constants ¶

View Source

const (
	// DefaultMaxBytes is 500KB; this is typically 250 to 500 lines.
	DefaultMaxBytes = 500000
	// DefaultInterval will flush every 10 seconds.
	DefaultInterval = 10 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

func ScanLines ¶

func ScanLines(data []byte, atEOF bool) (advance int, token []byte, err error)

ScanLines is used in bufio.Scanner.Split to split lines of line protocol.

Types ¶

type Batcher ¶

type Batcher struct {
	MaxFlushBytes    int                   // MaxFlushBytes is the maximum number of bytes to buffer before flushing
	MaxFlushInterval time.Duration         // MaxFlushInterval is the maximum amount of time to wait before flushing
	Service          platform.WriteService // Service receives batches flushed from Batcher.
}

Batcher batches line protocol for sends to output.

func (*Batcher) Write ¶

func (b *Batcher) Write(ctx context.Context, org, bucket platform.ID, r io.Reader) error

Write reads r in batches and sends to the output.

Source Files ¶

View all Source files

batcher.go

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