errhandler

Documentation

Index

• type DataWriter
• type Handler
  • func New(statsCh chan<- base.Stats) *Handler
  • func (w *Handler) Init(file *config.File, concurrency int, cleanup bool) (chan base.ErrData, error)

Types

type DataWriter

type DataWriter interface {
	Init(*os.File)
	Write([]base.Data)
	Flush()
	Error() error
}

type Handler

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

func New

func New(statsCh chan<- base.Stats) *Handler

func (*Handler) Init

func (w *Handler) Init(file *config.File, concurrency int, cleanup bool) (chan base.ErrData, error)