Documentation
¶
Index ¶
- func RenderMessage(message *goflowpb.FlowMessage) (map[string]interface{}, error)
- type GRPCProtobuf
- type InProcess
- type IngestFake
- type IngestFile
- type IngestSynthetic
- type Ingester
- func NewIngestCollector(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
- func NewIngestFake(params config.StageParam) (Ingester, error)
- func NewIngestFile(params config.StageParam) (Ingester, error)
- func NewIngestKafka(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
- func NewIngestStdin(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
- func NewIngestSynthetic(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
- type IngesterNone
- type TransportWrapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RenderMessage ¶
func RenderMessage(message *goflowpb.FlowMessage) (map[string]interface{}, error)
Types ¶
type GRPCProtobuf ¶
type GRPCProtobuf struct {
// contains filtered or unexported fields
}
GRPCProtobuf ingests data from the NetObserv eBPF Agent, using Protocol Buffers over gRPC
func NewGRPCProtobuf ¶
func NewGRPCProtobuf(opMetrics *operational.Metrics, params config.StageParam) (*GRPCProtobuf, error)
func (*GRPCProtobuf) Close ¶
func (no *GRPCProtobuf) Close() error
func (*GRPCProtobuf) Ingest ¶
func (no *GRPCProtobuf) Ingest(out chan<- config.GenericMap)
type InProcess ¶ added in v0.1.11
type InProcess struct {
// contains filtered or unexported fields
}
InProcess ingester is meant to be imported and used from another program via pipeline.StartFLPInProcess
func NewInProcess ¶ added in v0.1.11
func NewInProcess(in chan config.GenericMap) *InProcess
func (*InProcess) Ingest ¶ added in v0.1.11
func (d *InProcess) Ingest(out chan<- config.GenericMap)
type IngestFake ¶ added in v0.1.3
type IngestFake struct {
Count int64
In chan config.GenericMap
// contains filtered or unexported fields
}
func (*IngestFake) Ingest ¶ added in v0.1.3
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 ¶
type IngestFile struct {
PrevRecords []config.GenericMap
TotalRecords int
// contains filtered or unexported fields
}
func (*IngestFile) Ingest ¶
func (ingestF *IngestFile) Ingest(out chan<- config.GenericMap)
Ingest ingests entries from a file and resends the same data every delaySeconds seconds
type IngestSynthetic ¶ added in v0.1.9
type IngestSynthetic struct {
// contains filtered or unexported fields
}
func (*IngestSynthetic) Ingest ¶ added in v0.1.9
func (ingestS *IngestSynthetic) Ingest(out chan<- config.GenericMap)
Ingest generates flow logs according to provided parameters
type Ingester ¶
type Ingester interface {
Ingest(out chan<- config.GenericMap)
}
func NewIngestCollector ¶
func NewIngestCollector(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
NewIngestCollector create a new ingester
func NewIngestFake ¶ added in v0.1.3
func NewIngestFake(params config.StageParam) (Ingester, error)
NewIngestFake creates a new ingester
func NewIngestFile ¶
func NewIngestFile(params config.StageParam) (Ingester, error)
NewIngestFile create a new ingester
func NewIngestKafka ¶
func NewIngestKafka(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
NewIngestKafka create a new ingester
func NewIngestStdin ¶ added in v0.1.11
func NewIngestStdin(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
NewIngestStdin create a new ingester
func NewIngestSynthetic ¶ added in v0.1.9
func NewIngestSynthetic(opMetrics *operational.Metrics, params config.StageParam) (Ingester, error)
NewIngestSynthetic create a new ingester
type IngesterNone ¶
type IngesterNone struct {
}
type TransportWrapper ¶
type TransportWrapper struct {
// contains filtered or unexported fields
}
TransportWrapper is an implementation of the goflow2 transport interface
func NewWrapper ¶
func NewWrapper(c chan map[string]interface{}) *TransportWrapper
func (*TransportWrapper) Send ¶
func (w *TransportWrapper) Send(_, data []byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.