distro

Documentation

Index

• func InitLogger(l *zap.Logger)
• func Loop(config Config, errChan chan error, eventCh chan *models.Event)
• func RefreshRegistrations(update export.NotifyUpdate)
• func ZeroMQReceiver(eventCh chan *models.Event)
• type Config
  • func GetDefaultConfig() Config
• type Filterer
• type Formater
• type Sender
  • func NewHTTPSender(addr models.Addressable) Sender
  • func NewMqttSender(addr models.Addressable) Sender
• type Transformer
  • func NewAESEncryption(encData export.EncryptionDetails) Transformer

Functions

func InitLogger

func InitLogger(l *zap.Logger)

InitLogger - Init zap Logger

func Loop

func Loop(config Config, errChan chan error, eventCh chan *models.Event)

Loop - registration loop

func RefreshRegistrations

func RefreshRegistrations(update export.NotifyUpdate)

func ZeroMQReceiver

func ZeroMQReceiver(eventCh chan *models.Event)

Types

type Config

type Config struct {
	Port       int
	ClientHost string
	DataHost   string
	MQTTSCert  string
	MQTTSKey   string
}

func GetDefaultConfig

func GetDefaultConfig() Config

type Filterer

type Filterer interface {
	Filter(event *models.Event) (bool, *models.Event)
}

Filter - Filter interface

type Formater

type Formater interface {
	Format(event *models.Event) []byte
}

Formater - Format interface

type Sender

type Sender interface {
	Send(data []byte)
}

Sender - Send interface

func NewHTTPSender

func NewHTTPSender(addr models.Addressable) Sender

NewHTTPSender - create http sender

func NewMqttSender

func NewMqttSender(addr models.Addressable) Sender

NewMqttSender - create new mqtt sender

type Transformer

type Transformer interface {
	Transform(data []byte) []byte
}

Transformer - Transform interface

func NewAESEncryption

func NewAESEncryption(encData export.EncryptionDetails) Transformer