receiver

package

Go to main page

Versions in this module

v0

v0.27.2

Mar 18, 2024

v0.27.1

Dec 1, 2023

v0.27.0

Nov 22, 2023

v0.26.0

Oct 12, 2023

v0.25.1

Sep 25, 2023

v0.25.0

Aug 21, 2023

v0.24.0

Aug 8, 2023

Changes in this version

+ type Rabbitmq struct

+ Handler *skogul.HandlerRef

+ Host string

+ Password skogul.Secret

+ Port string

+ Queue string

+ Username skogul.Secret

+ func (r *Rabbitmq) Start() error

+ func (r *Rabbitmq) Verify() error

v0.23.0

Jul 6, 2023

v0.22.0

May 9, 2023

Changes in this version

type SQL

+ UnmarshalJson []string

v0.21.1

Feb 27, 2023

v0.21.0

Feb 10, 2023

Changes in this version

+ type Nats struct

+ Handler skogul.HandlerRef

+ Insecure bool

+ NKeyFile string

+ Name string

+ Password string

+ Queue string

+ Servers string

+ Subject string

+ TLSCACert string

+ TLSClientCert string

+ TLSClientKey string

+ UserCreds string

+ Username string

+ func (n *Nats) Start() error

+ func (n *Nats) Verify() error

v0.20.11

Jan 5, 2023

v0.20.10

Jan 5, 2023

v0.20.9

Jan 5, 2023

v0.20.8

Jan 5, 2023

v0.20.7

Jan 5, 2023

v0.20.6

Jan 5, 2023

v0.20.5

Jan 5, 2023

v0.20.4

Jan 5, 2023

v0.20.3

Jan 5, 2023

v0.20.2

Jan 5, 2023

v0.20.1

Jan 5, 2023

v0.20.0

Jan 5, 2023

Changes in this version

+ type LineFileAdvanced struct

+ Delay skogul.Duration

+ File string

+ Handler skogul.HandlerRef

+ NewFile string

+ Post string

+ Pre string

+ Shell string

+ func (lf *LineFileAdvanced) Start() error

v0.19.1

Nov 15, 2022

v0.19.0

Nov 14, 2022

v0.18.0

Sep 20, 2022

v0.17.0

Aug 24, 2022

Changes in this version

+ type SQL struct

+ ConnStr string

+ Driver string

+ Handler skogul.HandlerRef

+ Interval skogul.Duration

+ Metadata []string

+ Query string

+ func (s *SQL) Start() error

v0.16.0

May 28, 2022

Changes in this version

+ type Kafka struct

+ Brokers []string

+ ClientID string

+ Handler skogul.HandlerRef

+ Password string

+ TLS bool

+ Topic string

+ Username string

+ func (k *Kafka) Start() error

+ type WholeFile struct

+ File string

+ Frequency skogul.Duration

+ Handler skogul.HandlerRef

+ func (wf *WholeFile) Start() error

v0.15.2

May 9, 2022

v0.15.1

May 9, 2022

v0.15.0

Apr 10, 2022

v0.14.3

Apr 1, 2022

Changes in this version

type HTTP

+ Log204OK bool

v0.14.2

Mar 23, 2022

v0.14.1

Mar 22, 2022

v0.14.0

Mar 22, 2022

v0.13.2

Mar 22, 2022

v0.13.1

Mar 22, 2022

v0.13.0

Mar 22, 2022

Changes in this version

type HTTP

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

v0.12.1

Dec 10, 2021

v0.12.0

Dec 10, 2021

Changes in this version

+ type Stats struct

+ ChanSize int

+ Handler *skogul.HandlerRef

+ func (s *Stats) Start() error

+ func (s *Stats) StartC(ctx context.Context) error

+ func (s *Stats) Verify() error

type UDP

+ EmitStats skogul.Duration

+ func (ud *UDP) GetStats() *skogul.Metric

v0.11.0

Dec 2, 2021

Changes in this version

type UDP

+ Buffer int

v0.10.9

Dec 1, 2021

v0.10.8

Nov 15, 2021

v0.10.7

May 7, 2021

v0.10.6

Apr 27, 2021

v0.10.5

Apr 27, 2021

v0.10.4

Nov 12, 2020

Changes in this version

type UDP

+ FailureLevel string

v0.10.3

Nov 6, 2020

Changes in this version

type MQTT

+ DisplayMQTTLogs bool

+ RenewClientID bool

v0.10.2

Oct 26, 2020

Changes in this version

+ const UDP_MAX_READ_SIZE

type UDP

+ PacketSize int

+ func (ud *UDP) Verify() error

v0.10.1

Oct 16, 2020

v0.10.0

Oct 14, 2020

Changes in this version

type HTTP

+ ClientCertificateCAs []string

type HTTPAuth

+ SANDNSName string

+ SkipCertificateVerify bool

type UDP

+ Backlog int

+ Threads int

v0.9.0

Sep 25, 2020

v0.8.1

Sep 22, 2020

v0.8.0

Sep 4, 2020

v0.7.2

Jul 30, 2020

v0.7.1

Jul 3, 2020

v0.7.0

Jun 18, 2020

v0.6.2

Apr 3, 2020

v0.6.1

Apr 3, 2020

v0.6.0

Apr 2, 2020

v0.5.5

Mar 3, 2020

v0.5.4

Mar 3, 2020

v0.5.3

Mar 3, 2020

v0.5.2

Mar 2, 2020

v0.5.2-pre2

Feb 25, 2020

v0.5.2-pre1

Jan 30, 2020

v0.5.1

Jan 30, 2020

v0.5.0

Jan 22, 2020

v0.4.1

Jan 6, 2020

v0.4.0

Dec 4, 2019

Changes in this version

type MQTT

+ Broker string

+ ClientID string

+ Topics []string

+ func (handler *MQTT) Verify() error

v0.3.0

Nov 18, 2019

Changes in this version

type HTTP

+ Auth map[string]*HTTPAuth

+ type HTTPAuth struct

+ Password string

+ Username string

+ type LogrusLog struct

+ Handler skogul.HandlerRef

+ Loglevel string

+ func (lg *LogrusLog) Start() error

+ func (lg *LogrusLog) Write(bytes []byte) (int, error)

+ type LogrusSkogulHook struct

+ A string

+ Writer *LogrusLog

+ func (hook *LogrusSkogulHook) Fire(entry *logrus.Entry) error

+ func (hook *LogrusSkogulHook) Levels() []logrus.Level

v0.2.0

Nov 8, 2019

v0.2.0-pre.2

Nov 6, 2019

v0.1.0

Oct 23, 2019

Changes in this version

+ var Auto map[string]*Receiver

+ func Add(r Receiver) error

+ type File struct

+ File string

+ Handler skogul.HandlerRef

+ func (s *File) Start() error

+ type HTTP struct

+ Address string

+ Certfile string

+ Handlers map[string]*skogul.HandlerRef

+ Keyfile string

+ Password string

+ Username string

+ func (htt *HTTP) Start() error

+ func (htt *HTTP) Verify() error

+ type LineFile struct

+ Delay skogul.Duration

+ File string

+ Handler skogul.HandlerRef

+ func (lf *LineFile) Start() error

+ type Log struct

+ Echo bool

+ Handler skogul.HandlerRef

+ func (lg *Log) Parse(b []byte) (*skogul.Container, error)

+ func (lg *Log) Start() error

+ func (lg *Log) Write(p []byte) (n int, err error)

+ type MQTT struct

+ Address string

+ Handler *skogul.HandlerRef

+ Password string

+ Username string

+ func (handler *MQTT) Start() error

+ type Receiver struct

+ Aliases []string

+ Alloc func() skogul.Receiver

+ Help string

+ Name string

+ type Stdin struct

+ Handler skogul.HandlerRef

+ func (s *Stdin) Start() error

+ type TCPLine struct

+ Address string

+ Handler skogul.HandlerRef

+ func (tl *TCPLine) Start() error

+ type Tester struct

+ Delay skogul.Duration

+ Handler skogul.HandlerRef

+ Metrics int64

+ Threads int

+ Values int64

+ func (tst *Tester) Start() error

+ type UDP struct

+ Address string

+ Handler skogul.HandlerRef

+ func (ud *UDP) Start() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL