package shard

import "github.com/influxdata/influxdb/internal/shard"

Index ¶

• func AutoNumber() option
• func Generation(gen int) option
• func Sequence(seq int) option
• func Temporary() option
• type Writer
• func NewWriter(id uint64, path string, opts ...option) *Writer
• func (w *Writer) Close()
• func (w *Writer) Err() error
• func (w *Writer) Files() []string
• func (w *Writer) ShardID() uint64
• func (w *Writer) Write(key []byte, values tsm1.Values)
• func (w *Writer) WriteV(key []byte, values gen.Values)

Functions ¶

func AutoNumber ¶

func AutoNumber() option

AutoNumber will read the existing TSM file names and use generation + 1

func Generation ¶

func Generation(gen int) option

Generation specifies the generation number of the tsm files.

func Sequence ¶

func Sequence(seq int) option

Sequence specifies the starting sequence number of the tsm files.

func Temporary ¶

func Temporary() option

Temporary configures the writer to create tsm.tmp files.

Types ¶

type Writer ¶

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

func NewWriter ¶

func NewWriter(id uint64, path string, opts ...option) *Writer

func (*Writer) Close ¶

func (w *Writer) Close()

Close closes the writer.

func (*Writer) Err ¶

func (w *Writer) Err() error

func (*Writer) Files ¶

func (w *Writer) Files() []string

Files returns the full paths of all the files written by the Writer.

func (*Writer) ShardID ¶

func (w *Writer) ShardID() uint64

ShardID returns the shard number of the writer.

func (*Writer) Write ¶

func (w *Writer) Write(key []byte, values tsm1.Values)

func (*Writer) WriteV ¶

func (w *Writer) WriteV(key []byte, values gen.Values)

Source Files ¶

writer.go