flow

package

v0.0.0-...-246ca4d Latest Latest Go to latest Published: Sep 30, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Package flow implements ClickHouse table schema for cilium hubble flow events.

This section is empty.

View Source

var DDL = NewDDL("flows")

DDL for ClickHouse table.

func NewDDL(tableName string) string

type Peer struct {
	Kubernetes RowKubernetes
}

type Row struct {
	Raw     *observer.Flow
	Index   Peer
	Peer    Peer
	Inverse bool
}

type RowKubernetes struct {
	Pod       string
	Namespace string
	Image     string
	Container string
}

type Table struct {
	// contains filtered or unexported fields
}

Table is wrapper for ClickHouse columns that simplifies data ingestion.

func NewTable(name string) *Table

func (t *Table) Append(row Row) error

func (t *Table) Each(fn func(row Row) error) error

func (t *Table) Input() proto.Input

func (t *Table) Insert() string

func (t *Table) Reset()

func (t *Table) Result() proto.Results

func (t *Table) ResultColumns() []string

func (t *Table) Rows() int