writer

Documentation

Index

• type Writer
  • func New(in chan *RowBinary.WriteBuffer, path string, fileInterval time.Duration, ...) *Writer
  • func (w *Writer) IsInProgress(filename string) bool
  • func (w *Writer) Start() error
  • func (w *Writer) Stat(send func(metric string, value float64))

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, fileInterval time.Duration, logger zap.Logger) *Writer

func (*Writer) IsInProgress

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

func (*Writer) Start

func (w *Writer) Start() error

func (*Writer) Stat

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