ingester

Documentation

Index

• type Ingester
  • func NewIngester(framesChannel <-chan reader.Frame, stagingTable StagingTable) *Ingester
  • func (i *Ingester) Run(ctx context.Context)
• type StagingTable

Types

type Ingester

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

Ingester is responsible for receiving frames and storing it in the staging table. Ingester decodes received message and implements field iterator which is responsible for splitting message in multiple fields.

func NewIngester

func NewIngester(framesChannel <-chan reader.Frame, stagingTable StagingTable) *Ingester

func (*Ingester) Run

func (i *Ingester) Run(ctx context.Context)

type StagingTable

type StagingTable interface {
	Add(tables.FieldIterator) error
}