Versions in this module Expand all Collapse all v0 v0.0.1 Aug 29, 2022 Changes in this version + type ConfigStore interface + Bool func(name string) (bool, bool) + Duration func(name string) (time.Duration, bool) + Int func(name string) (int, bool) + String func(name string) (string, bool) + Strings func(name string) ([]string, bool) + type FLBConfigStore struct + func NewFLBConfigStore(ctx unsafe.Pointer, l *zerolog.Logger) FLBConfigStore + func (f *FLBConfigStore) Bool(name string) (bool, bool) + func (f *FLBConfigStore) Duration(name string) (time.Duration, bool) + func (f *FLBConfigStore) Int(name string) (int, bool) + func (f *FLBConfigStore) String(name string) (string, bool) + func (f *FLBConfigStore) Strings(name string) ([]string, bool) + type FLBRecordReader struct + func NewFLBRecordReader() (*FLBRecordReader, error) + func (r *FLBRecordReader) ReadRecord() (time.Time, map[string]interface{}, error) + func (r *FLBRecordReader) ResetReader(data unsafe.Pointer, length int) + type FLBTime struct + func (t FLBTime) ReadExt(i interface{}, b []byte) + func (t FLBTime) WriteExt(interface{}) []byte + type OutputPlugin struct + As []string + D bool + ID int + KA bool + R *FLBRecordReader + TSField string + func NewPluginFromConfig(ctx context.Context, config *OutputPluginConfig, opts ...option.ClientOption) (*OutputPlugin, error) + func (p *OutputPlugin) CreateMessage(ts time.Time, tag string, record map[string]interface{}) (*pubsub.Message, error) + type OutputPluginConfig struct + As []string + Crds string + D bool + ID int + KA bool + PID string + PS pubsub.PublishSettings + TID string + TSField string + func BuildPluginConfig(id int, cs ConfigStore) *OutputPluginConfig + func (c *OutputPluginConfig) Validate() error