Versions in this module Expand all Collapse all v0 v0.27.1 Jul 30, 2020 Changes in this version + type Collector struct + Config Config + Producer sarama.SyncProducer + Samples []stats.Sample + func New(conf Config) (*Collector, error) + func (c *Collector) Collect(scs []stats.SampleContainer) + func (c *Collector) GetRequiredSystemTags() stats.SystemTagSet + func (c *Collector) Init() error + func (c *Collector) Link() string + func (c *Collector) Run(ctx context.Context) + func (c *Collector) SetRunStatus(status lib.RunStatus) + type Config struct + Brokers []string + Format null.String + InfluxDBConfig influxdb.Config + PushInterval types.NullDuration + Topic null.String + func NewConfig() Config + func ParseArg(arg string) (Config, error) + func (c Config) Apply(cfg Config) Config
Go to main page