ingest

package

v0.1.3-rc4 Latest Latest Go to latest Published: Aug 4, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Details

This section is empty.

This section is empty.

func RenderMessage(message *goflowpb.FlowMessage) (map[string]interface{}, error)

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

GRPCProtobuf ingests data from the NetObserv eBPF Agent, using Protocol Buffers over gRPC

func NewGRPCProtobuf(params config.StageParam) (*GRPCProtobuf, error)

func (no *GRPCProtobuf) Close() error

func (no *GRPCProtobuf) Ingest(out chan<- []config.GenericMap)

type IngestFake struct {
	In chan []config.GenericMap
	// contains filtered or unexported fields
}

func (inf *IngestFake) Ingest(out chan<- []config.GenericMap)

Ingest reads records from an input channel and writes them as-is to the output channel

type IngestFile struct {
	PrevRecords  []config.GenericMap
	TotalRecords int
	// contains filtered or unexported fields
}

func (ingestF *IngestFile) Ingest(out chan<- []config.GenericMap)

Ingest ingests entries from a file and resends the same data every delaySeconds seconds

type Ingester interface {
	Ingest(out chan<- []config.GenericMap)
}

func NewIngestCollector(params config.StageParam) (Ingester, error)

NewIngestCollector create a new ingester

func NewIngestFake(params config.StageParam) (Ingester, error)

NewIngestFake creates a new ingester

func NewIngestFile(params config.StageParam) (Ingester, error)

NewIngestFile create a new ingester

func NewIngestKafka(params config.StageParam) (Ingester, error)

NewIngestKafka create a new ingester

type IngesterNone struct {
}

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

TransportWrapper is an implementation of the goflow2 transport interface

func NewWrapper(c chan map[string]interface{}) *TransportWrapper

func (w *TransportWrapper) Send(_, data []byte) error