clickhouse_segment

Documentation

Overview

Dumps all incoming flow messages to a clickhouse database. The schema used is selected according to the preset parameter.

Index

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

Types

type Clickhouse

type Clickhouse struct {
	segments.BaseSegment

	DSN       string // required
	Preset    string // optional, what schema to use, currently only the option and default is "flowhouse"
	BatchSize int    // optional how many flows to hold in memory between INSERTs, default is 1000
	// contains filtered or unexported fields
}

func (Clickhouse) New

func (segment Clickhouse) 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 (*Clickhouse) Run

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