writer

Documentation

Index

• func Cleanup(filename string, tables []string) (bool, error)
• func Link(filename string, tables []string) error
• type Writer
  • func New(in chan *RowBinary.WriteBuffer, path string, ...) *Writer
  • func (w *Writer) Cleanup() error
  • func (w *Writer) IsInProgress(filename string) bool
  • func (w *Writer) LinkAll() error
  • func (w *Writer) Start() error
  • func (w *Writer) Stat(send func(metric string, value float64))

Functions

func Cleanup

func Cleanup(filename string, tables []string) (bool, error)

func Link

func Link(filename string, tables []string) error

Write symlink to file to all table subfolders

Types

type Writer

type Writer struct {
	stop.Struct
	sync.RWMutex
	// contains filtered or unexported fields
}

Writer dumps all received data in prepared for clickhouse format

func New

func New(in chan *RowBinary.WriteBuffer, path string, autoInterval *config.ChunkAutoInterval, uploaders []string, onFinish func(string) error) *Writer

func (*Writer) Cleanup

func (w *Writer) Cleanup() error

func (*Writer) IsInProgress

func (w *Writer) IsInProgress(filename string) bool

func (*Writer) LinkAll

func (w *Writer) LinkAll() error

func (*Writer) Start

func (w *Writer) Start() error

func (*Writer) Stat

func (w *Writer) Stat(send func(metric string, value float64))