package text

import "github.com/influxdata/influxdb/cmd/influx_tools/internal/format/text"

Index ¶

• type Mode
• type Writer
• func NewWriter(w io.Writer, mode Mode) *Writer
• func (w *Writer) BeginSeries(name, field []byte, typ influxql.DataType, tags models.Tags)
• func (w *Writer) Close() error
• func (w *Writer) EndSeries()
• func (w *Writer) Err() error
• func (w *Writer) NewBucket(start, end int64) (format.BucketWriter, error)
• func (w *Writer) WriteBooleanCursor(cur tsdb.BooleanArrayCursor)
• func (w *Writer) WriteFloatCursor(cur tsdb.FloatArrayCursor)
• func (w *Writer) WriteIntegerCursor(cur tsdb.IntegerArrayCursor)
• func (w *Writer) WriteStringCursor(cur tsdb.StringArrayCursor)
• func (w *Writer) WriteUnsignedCursor(cur tsdb.UnsignedArrayCursor)

Types ¶

type Mode ¶

type Mode bool

const (
	Series Mode = false
	Values Mode = true
)

type Writer ¶

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

func NewWriter ¶

func NewWriter(w io.Writer, mode Mode) *Writer

func (*Writer) BeginSeries ¶

func (w *Writer) BeginSeries(name, field []byte, typ influxql.DataType, tags models.Tags)

func (*Writer) Close ¶

func (w *Writer) Close() error

func (*Writer) EndSeries ¶

func (w *Writer) EndSeries()

func (*Writer) Err ¶

func (w *Writer) Err() error

func (*Writer) NewBucket ¶

func (w *Writer) NewBucket(start, end int64) (format.BucketWriter, error)

func (*Writer) WriteBooleanCursor ¶

func (w *Writer) WriteBooleanCursor(cur tsdb.BooleanArrayCursor)

func (*Writer) WriteFloatCursor ¶

func (w *Writer) WriteFloatCursor(cur tsdb.FloatArrayCursor)

func (*Writer) WriteIntegerCursor ¶

func (w *Writer) WriteIntegerCursor(cur tsdb.IntegerArrayCursor)

func (*Writer) WriteStringCursor ¶

func (w *Writer) WriteStringCursor(cur tsdb.StringArrayCursor)

func (*Writer) WriteUnsignedCursor ¶

func (w *Writer) WriteUnsignedCursor(cur tsdb.UnsignedArrayCursor)

Source Files ¶

writer.go