write

type BatchWriter interface {
	WriteBatches(ctx context.Context, r io.Reader, writeFn func(batch []byte) error) error
}

type BufferBatcher 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
	MaxLineLength    int           // MaxLineLength specifies the maximum length of a single line
}

type BytesPerSec float64

type Client struct {
	clients.CLI
	api.WriteApi
	LineReader
	RateLimiter
	BatchWriter
}

type DryRunClient struct {
	clients.CLI
	LineReader
}

type HttpClient interface {
	Do(*http.Request) (*http.Response, error)
}

type InputCompression int

type InputFormat int

type LineReader interface {
	Open(ctx context.Context) (io.Reader, io.Closer, error)
}

type MultiInputLineReader struct {
	StdIn      io.Reader
	HttpClient HttpClient
	ErrorOut   io.Writer

	Args        []string
	Files       []string
	URLs        []string
	Format      InputFormat
	Compression InputCompression
	Encoding    string

	// CSV-specific options.
	Headers                    []string
	SkipRowOnError             bool
	SkipHeader                 int
	IgnoreDataTypeInColumnName bool
	Debug                      bool
}

type Params struct {
	clients.OrgBucketParams
	Precision api.WritePrecision
}

type RateLimiter interface {
	Throttle(ctx context.Context, in io.Reader) io.Reader
}

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