sender

Oct 12, 2023

Changes in this version

type SNMP

+ SnmpTrapOID string

Aug 21, 2023

Changes in this version

+ type TCP struct

+ Address string

+ Delimiter []byte

+ DialTimeout skogul.Duration

+ Encoder skogul.EncoderRef

+ KeepAlive skogul.Duration

+ MaxRetries int

+ Threads int

+ WriteTimeout skogul.Duration

+ func (t *TCP) Send(c *skogul.Container) error

+ func (t *TCP) Verify() error

Aug 8, 2023

Changes in this version

+ type Rabbitmq struct

+ Encoder skogul.EncoderRef

+ Host string

+ Password skogul.Secret

+ Port string

+ Queue string

+ Timeout int

+ Username skogul.Secret

+ func (r *Rabbitmq) Send(c *skogul.Container) error

+ func (r *Rabbitmq) Verify() error

+ type SNMP struct

+ Community string

+ Oidmap map[string]interface{}

+ Port uint16

+ Target string

+ Timeout uint

+ Version string

+ func (x *SNMP) Send(c *skogul.Container) error

Feb 10, 2023

Changes in this version

+ type Nats struct

+ Encoder skogul.EncoderRef

+ Insecure bool

+ NKeyFile string

+ Name string

+ Password string

+ Servers string

+ Subject string

+ SubjectAppend []string

+ TLSCACert string

+ TLSClientCert string

+ TLSClientKey string

+ UserCreds string

+ Username string

+ func (n *Nats) Send(c *skogul.Container) error

+ func (n *Nats) Verify() error

Nov 14, 2022

Changes in this version

type Batch

+ func (bat *Batch) Verify() error

type File

+ File string

+ func (f *File) Deprecated() error

Aug 24, 2022

Changes in this version

type File

+ Encoder skogul.EncoderRef

May 28, 2022

Changes in this version

type Debug

+ Encoder skogul.EncoderRef

+ type Kafka struct

+ Address string

+ ClientID string

+ Encoder skogul.EncoderRef

+ Password string

+ Sync bool

+ TLS bool

+ Topic string

+ Username string

+ func (k *Kafka) Send(c *skogul.Container) error

May 9, 2022

Changes in this version

+ type EnrichmentUpdater struct

+ Enricher skogul.TransformerRef

+ func (e *EnrichmentUpdater) Send(c *skogul.Container) error

+ func (e *EnrichmentUpdater) Verify() error

type HTTP

+ Encoder skogul.EncoderRef

Apr 10, 2022

Changes in this version

+ type Match struct

+ Conditions []map[string]interface{}

+ Next *skogul.SenderRef

+ type Switch struct

+ Default *skogul.SenderRef

+ Map []Match

+ Next []*skogul.SenderRef

+ func (sw *Switch) Send(c *skogul.Container) error

Dec 10, 2021

Changes in this version

type HTTP

+ func (ht *HTTP) GetStats() *skogul.Metric

Dec 2, 2021

Changes in this version

type Batch

+ Burner skogul.SenderRef

type Counter

+ func (co *Counter) Verify() error

Dec 1, 2021

Changes in this version

type Net

+ func (n *Net) Verify() error

Nov 15, 2021

Changes in this version

type Batch

+ Threads int

type InfluxDB

+ Token skogul.Secret

Nov 12, 2020

Changes in this version

type Splunk

+ Source string

+ SourceField string

Oct 14, 2020

Changes in this version

type HTTP

+ Certfile string

+ Headers map[string]string

+ Keyfile string

+ type Splunk struct

+ HTTP *HTTP

+ HostnameField string

+ Index string

+ Token string

+ URL string

+ func (s *Splunk) Send(c *skogul.Container) error

+ func (s *Splunk) Verify() error

Sep 4, 2020

Changes in this version

+ type File struct

+ Append bool

+ Path string

+ func (f *File) Send(c *skogul.Container) error

+ func (f *File) Verify() error

Apr 3, 2020

Changes in this version

type InfluxDB

+ ConvertIntToFloat bool

Dec 4, 2019

Changes in this version

type MQTT

+ Broker string

+ ClientID string

+ Password string

+ Topics []string

+ Username string

+ func (handler *MQTT) Verify() error

Oct 23, 2019

Changes in this version

+ var Auto map[string]*Sender

+ func Add(s Sender) error

+ type Backoff struct

+ Base skogul.Duration

+ Next skogul.SenderRef

+ Retries uint64

+ func (bo *Backoff) Send(c *skogul.Container) error

+ type Batch struct

+ Interval skogul.Duration

+ Next skogul.SenderRef

+ Threshold int

+ func (bat *Batch) Send(c *skogul.Container) error

+ type Counter struct

+ Next skogul.SenderRef

+ Period skogul.Duration

+ Stats skogul.HandlerRef

+ func (co *Counter) Send(c *skogul.Container) error

+ type Debug struct

+ Prefix string

+ func (db *Debug) Send(c *skogul.Container) error

+ type Detacher struct

+ Depth int

+ Next skogul.SenderRef

+ func (de *Detacher) Send(c *skogul.Container) error

+ type Dupe struct

+ Next []skogul.SenderRef

+ func (dp *Dupe) Send(c *skogul.Container) error

+ type ErrDiverter struct

+ Err skogul.HandlerRef

+ Next skogul.SenderRef

+ RetErr bool

+ func (ed *ErrDiverter) Send(c *skogul.Container) error

+ type Fallback struct

+ Next []skogul.SenderRef

+ func (fb *Fallback) Send(c *skogul.Container) error

+ type Fanout struct

+ Next skogul.SenderRef

+ Workers int

+ func (fo *Fanout) Send(c *skogul.Container) error

+ type ForwardAndFail struct

+ Next skogul.SenderRef

+ func (faf *ForwardAndFail) Send(c *skogul.Container) error

+ type HTTP struct

+ ConnsPerHost int

+ IdleConnsPerHost int

+ Insecure bool

+ RootCA string

+ Timeout skogul.Duration

+ URL string

+ func (ht *HTTP) Send(c *skogul.Container) error

+ func (ht *HTTP) Verify() error

+ type InfluxDB struct

+ Measurement string

+ MeasurementFromMetadata string

+ Timeout skogul.Duration

+ URL string

+ func (idb *InfluxDB) Send(c *skogul.Container) error

+ func (idb *InfluxDB) Verify() error

+ type Log struct

+ Message string

+ func (lg Log) Send(c *skogul.Container) error

+ type MQTT struct

+ Address string

+ func (handler *MQTT) Send(c *skogul.Container) error

+ type MnR struct

+ Address string

+ DefaultGroup string

+ func (mnr *MnR) Send(c *skogul.Container) error

+ type Net struct

+ Address string

+ Network string

+ func (n *Net) Send(c *skogul.Container) error

+ type Null struct

+ func (n *Null) Send(c *skogul.Container) error

+ type SQL struct

+ ConnStr string

+ Driver string

+ Query string

+ func (sq *SQL) Send(c *skogul.Container) error

+ func (sq *SQL) Verify() error

+ type Sender struct

+ Aliases []string

+ Alloc func() skogul.Sender

+ Help string

+ Name string

+ type Sleeper struct

+ Base skogul.Duration

+ MaxDelay skogul.Duration

+ Next skogul.SenderRef

+ Verbose bool

+ func (sl *Sleeper) Send(c *skogul.Container) error

+ type Test struct

+ func (rcv *Test) Received() uint64

+ func (rcv *Test) Send(c *skogul.Container) error

+ func (rcv *Test) Set(v uint64)

+ func (rcv *Test) SetSync(v bool)

+ func (rcv *Test) TestNegative(t failer, s skogul.Sender, c *skogul.Container)

+ func (rcv *Test) TestQuick(t failer, sender skogul.Sender, c *skogul.Container, received uint64)

+ func (rcv *Test) TestSync(t failer, s skogul.Sender, c *skogul.Container, send int, received int)

+ func (rcv *Test) TestTime(t failer, s skogul.Sender, c *skogul.Container, received uint64, ...)