Documentation
¶
Index ¶
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(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 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 Ingester ¶
type Ingester interface {
Ingest(out chan<- []config.GenericMap)
}
func NewIngestCollector ¶
func NewIngestCollector(params config.StageParam) (Ingester, error)
NewIngestCollector create a new ingester
func NewIngestFile ¶
func NewIngestFile(params config.StageParam) (Ingester, error)
NewIngestFile create a new ingester
func NewIngestKafka ¶
func NewIngestKafka(params config.StageParam) (Ingester, error)
NewIngestKafka 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.