Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AvroDatum ¶
type AvroDatum struct { // *goavro.Record Record interface{} // the topic that the Record requested Topic string // the approximate byte size of the original Record, if known ApproxBytes int64 }
AvroDatum conveys the avro data coming in on our TCP listening channel.
type Collector ¶
type Collector struct { ListenEndpointFlag string RecordInputLogFlag bool InputLimitAmountKBytesFlag int InputLimitPeriodFlag int // contains filtered or unexported fields }
Collector defines the structure of the framework collector and facilitates mocking the various configuration options during testing.
func New ¶
func New(cfg Collector, nodeInfo collectors.NodeInfo) (Collector, chan producers.MetricsMessage)
New returns a new instance of the framework collector.
func (*Collector) RunFrameworkTCPListener ¶
func (c *Collector) RunFrameworkTCPListener()
RunFrameworkTCPListener runs a TCP socket listener which produces Avro records sent to that socket. Expects input which has been formatted in the Avro ODF standard. This function should be run as a gofunc.
Click to show internal directories.
Click to hide internal directories.