writer

Documentation

Index

• type Config
• type Metrics
• type Writer
  • func Open(cfg Config) (w *Writer, err error)
  • func (w *Writer) Close() (err error)
  • func (w *Writer) Metrics() (m Metrics)
  • func (w *Writer) Write(ss []*analyzer.FlowStats) (err error)

Types

type Config

type Config struct {
	Dir              string
	File             string
	CompressionLevel int
	Flush            bool
	RotateInterval   time.Duration
	RotateSize       uint64
	Partial          bool
	Log              bool
}

type Metrics

type Metrics struct {
	WriteTimes metrics.DurationStats
	sync.RWMutex
}

type Writer

type Writer struct {
	Config

	sync.Mutex
	// contains filtered or unexported fields
}

func Open

func Open(cfg Config) (w *Writer, err error)

func (*Writer) Close

func (w *Writer) Close() (err error)

func (*Writer) Metrics

func (w *Writer) Metrics() (m Metrics)

func (*Writer) Write

func (w *Writer) Write(ss []*analyzer.FlowStats) (err error)