mqti

Documentation

Index

• Constants
• Variables
• func CreateWorkers(influxDB *InfluxDBConnection, jobs <-chan *MQTTMessage)
• func DebugLog(line ...interface{})
• func DebugLogMQTTMessage(m *MQTTMessage)
• func EnableDebugging(yes bool)
• func LogMQTTMessage(m *MQTTMessage)
• func MQTTSubscribe(incoming chan *MQTTMessage)
• func NewTLSConfig(certFile, keyFile string) *tls.Config
• func ParseEpoch(in string) time.Time
• func ParseTime(in string) time.Time
• type Config
  • func GetConfig() (*Config, error)
• type FilterJSONMungerConfiguration
• type FilterMungerConfiguration
• type GeohashMungerConfiguration
• type InfluxDBConnection
  • func NewInfluxDBConnection() (*InfluxDBConnection, error)
  • func (i InfluxDBConnection) Forward(m *MQTTMessage) error
• type MQTTMessage
  • func (m MQTTMessage) PayloadAsJSON() (map[string]interface{}, error)
  • func (m MQTTMessage) PayloadAsString() string
• type MappingConfiguration
• type TagsMungerConfiguration

Constants

const DEBUGDISKFILE string = "/tmp/mqti-debug.log"

DEBUGDISKFILE ...

const EndOfTime string = "9999-12-31T23:59:59"

EndOfTime ...

Variables

var DiskLog *logrus.Logger

DiskLog ...

var DiskLogFile *os.File

DiskLogFile ...

var Log = logrus.New()

Log ...

var Version = "v0.1.2"

Version ...

Functions

func CreateWorkers

func CreateWorkers(influxDB *InfluxDBConnection, jobs <-chan *MQTTMessage)

CreateWorkers ...

func DebugLog

func DebugLog(line ...interface{})

DebugLog ...

func DebugLogMQTTMessage

func DebugLogMQTTMessage(m *MQTTMessage)

DebugLogMQTTMessage ...

func EnableDebugging

func EnableDebugging(yes bool)

EnableDebugging ...

func LogMQTTMessage

func LogMQTTMessage(m *MQTTMessage)

LogMQTTMessage ...

func MQTTSubscribe

func MQTTSubscribe(incoming chan *MQTTMessage)

MQTTSubscribe ...

func NewTLSConfig

func NewTLSConfig(certFile, keyFile string) *tls.Config

NewTLSConfig ...

func ParseEpoch

func ParseEpoch(in string) time.Time

ParseEpoch ...

func ParseTime

func ParseTime(in string) time.Time

ParseTime ...

Types

type Config

type Config struct {
	MQti     mQtiConfiguration
	MQTT     mQTTConfiguration
	InfluxDB influxDBConfiguration
	Mappings []MappingConfiguration
}

Config ...

func GetConfig

func GetConfig() (*Config, error)

GetConfig ...

type FilterJSONMungerConfiguration

type FilterJSONMungerConfiguration struct {
	And []map[string]string
	Or  []map[string]string
}

FilterJSONMungerConfiguration ...

type FilterMungerConfiguration

type FilterMungerConfiguration struct {
	JSON FilterJSONMungerConfiguration
}

FilterMungerConfiguration ...

type GeohashMungerConfiguration

type GeohashMungerConfiguration struct {
	LatitudeField  string `mapstructure:"lat_field"`
	LongitudeField string `mapstructure:"lng_field"`
	ResultField    string `mapstructure:"result_field"`
}

GeohashMungerConfiguration ...

type InfluxDBConnection

type InfluxDBConnection struct {
	*InfluxDBClient.Client
}

InfluxDBConnection ...

func NewInfluxDBConnection

func NewInfluxDBConnection() (*InfluxDBConnection, error)

NewInfluxDBConnection ...

func (InfluxDBConnection) Forward

func (i InfluxDBConnection) Forward(m *MQTTMessage) error

Forward ...

type MQTTMessage

type MQTTMessage struct {
	MQTT.Message
	MappingConfiguration
}

MQTTMessage ...

func (MQTTMessage) PayloadAsJSON

func (m MQTTMessage) PayloadAsJSON() (map[string]interface{}, error)

PayloadAsJSON ...

func (MQTTMessage) PayloadAsString

func (m MQTTMessage) PayloadAsString() string

PayloadAsString ...

type MappingConfiguration

type MappingConfiguration struct {
	Name     string
	MQTT     mQTTMappingConfiguration
	InfluxDB influxDBMappingConfiguration
}

MappingConfiguration ...

type TagsMungerConfiguration

type TagsMungerConfiguration struct {
	From []map[string]string
}

TagsMungerConfiguration ...