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
	// 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)