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.
Source Files
Click to show internal directories.
Click to hide internal directories.