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
- type FilterJSONMungerConfiguration
- type FilterMungerConfiguration
- type GeohashMungerConfiguration
- type InfluxDBConnection
- type MQTTMessage
- type MappingConfiguration
- type TagsMungerConfiguration
Constants ¶
View Source
const DEBUGDISKFILE string = "/tmp/mqti-debug.log"
DEBUGDISKFILE ...
View Source
const EndOfTime string = "9999-12-31T23:59:59"
EndOfTime ...
Variables ¶
View Source
var DiskLog *logrus.Logger
DiskLog ...
View Source
var DiskLogFile *os.File
DiskLogFile ...
View Source
var Log = logrus.New()
Log ...
View Source
var Version = "v0.1.2"
Version ...
Functions ¶
func CreateWorkers ¶
func CreateWorkers(influxDB *InfluxDBConnection, jobs <-chan *MQTTMessage)
CreateWorkers ...
Types ¶
type Config ¶
type Config struct { MQti mQtiConfiguration MQTT mQTTConfiguration InfluxDB influxDBConfiguration Mappings []MappingConfiguration }
Config ...
type FilterJSONMungerConfiguration ¶
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 ¶
TagsMungerConfiguration ...
Source Files ¶
Click to show internal directories.
Click to hide internal directories.