sqlite

package

v0.4.0-beta Latest Latest Go to latest Published: Dec 16, 2021 License: GPL-3.0 Imports: 7 Imported by: 0

Details

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

This section is empty.

This section is empty.

This section is empty.

type Sqlite struct {
	segments.BaseSegment

	FileName string // required
	// contains filtered or unexported fields
}

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 (segment *Sqlite) Run(wg *sync.WaitGroup)