sqlite

Documentation

Overview

Dumps all incoming flow messages to a local sqlite database. The schema used for this is preset.

Index

• type Sqlite
  • func (segment Sqlite) New(config map[string]string) segments.Segment
  • func (segment *Sqlite) Run(wg *sync.WaitGroup)

Types

type Sqlite

type Sqlite struct {
	segments.BaseSegment

	FileName  string // required
	Fields    string // optional comma-separated list of fields to export, default is "", meaning all fields
	BatchSize int    // optional how many flows to hold in memory between INSERTs, default is 1000
	// contains filtered or unexported fields
}

func (Sqlite) New

func (segment Sqlite) New(config map[string]string) segments.Segment

Every Segment must implement a New method, even if there isn't any config it is interested in.

func (*Sqlite) Run

func (segment *Sqlite) Run(wg *sync.WaitGroup)