Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var LogLineDesc = baker.InputDesc{ Name: "LogLine", New: NewLogLine, Config: &LogLineConfig{}, }
LogLineDesc describes the LogLine input. This input is made for testing.
var RandomDesc = baker.InputDesc{ Name: "Random", New: NewRandom, Config: &RandomConfig{}, }
RandomDesc describes the Random input.
var RecordsDesc = baker.InputDesc{ Name: "Records", New: NewRecords, Config: &RecordsConfig{}, }
RecordsDesc describes the Records input. This input is made for testing.
Functions ¶
func NewLogLine ¶
func NewLogLine(cfg baker.InputParams) (baker.Input, error)
NewLogLine creates a LogLine baker input.
func NewRandom ¶
func NewRandom(cfg baker.InputParams) (baker.Input, error)
NewRandom creates a Random baker input.
func NewRecords ¶
func NewRecords(cfg baker.InputParams) (baker.Input, error)
NewRecords creates a Records baker input.
Types ¶
type Base ¶
type Base struct{}
Base is a nop implementation of baker.Input useful to be embedded in tests and to redeclare one or more methods.
func (Base) Stats ¶
func (Base) Stats() baker.InputStats
type LogLine ¶
type LogLine struct {
LogLineConfig
}
A LogLine input is a Baker input used for testing.
func (*LogLine) Stats ¶
func (in *LogLine) Stats() (stats baker.InputStats)
type LogLineConfig ¶
type LogLineConfig struct {
Lines []*baker.LogLine // Lines to pipe into the filter chain.
Metadata baker.Metadata // Metadata to assign to every log line.
}
LogLineConfig holds the log lines to be fed to the Baker topology.
type Random ¶
type Random struct {
Cfg *RandomConfig
}
A Random input is baker input used for testing. It generates a specified number of random, but valid, records.
func (*Random) Stats ¶
func (r *Random) Stats() (stats baker.InputStats)
type RandomConfig ¶
RandomConfig specifies the number of random records to generate as well as the seed for the PRNG.
type Records ¶
type Records struct {
RecordsConfig
}
A Records input is a Baker input used for testing.
func (Records) Stats ¶
func (Records) Stats() (stats baker.InputStats)
type RecordsConfig ¶
RecordsConfig holds the log lines to be fed to the Baker topology.
Source Files