exporter

Documentation

Index

• type GRPCProto
  • func StartGRPCProto(hostPort string) (*GRPCProto, error)
  • func (g *GRPCProto) ExportFlows(input <-chan []*flow.Record)

Types

type GRPCProto

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

GRPCProto flow exporter. Its ExportFlows method accepts slices of *flow.Record by its input channel, converts them to *pbflow.Records instances, and submits them to the collector.

func StartGRPCProto

func StartGRPCProto(hostPort string) (*GRPCProto, error)

func (*GRPCProto) ExportFlows

func (g *GRPCProto) ExportFlows(input <-chan []*flow.Record)

ExportFlows accepts slices of *flow.Record by its input channel, converts them to *pbflow.Records instances, and submits them to the collector.