modules

Documentation

Index

• func ExecuteCommand(L *lua.LState) int
• func GenHash(pass string) string
• func GenerateHash(L *lua.LState) int
• func IndexMessage(L *lua.LState) int
• func InitRedisPool()
• func MQTTClientModuleLoader(L *lua.LState) int
• func PasswordModuleLoader(L *lua.LState) int
• func PersistenceModuleLoader(L *lua.LState) int
• func QueryMessages(L *lua.LState) int
• func RedisModuleLoader(L *lua.LState) int
• func SendMessage(L *lua.LState) int
• type Message

Functions

func ExecuteCommand

func ExecuteCommand(L *lua.LState) int

ExecuteCommand executes the command given by the Lua script

func GenHash

func GenHash(pass string) string

GenHash generates the hash according to the expected by mosquitto auth plugin, it is not the normal implementation Reference: https://github.com/jpmens/mosquitto-auth-plug/issues/44

func GenerateHash

func GenerateHash(L *lua.LState) int

GenerateHash generates pbkdf2 hash for the password

func IndexMessage

func IndexMessage(L *lua.LState) int

func InitRedisPool

func InitRedisPool()

InitRedisPool starts the redis pool

func MQTTClientModuleLoader

func MQTTClientModuleLoader(L *lua.LState) int

MQTTClientModuleLoader loads the module and prepares it

func PasswordModuleLoader

func PasswordModuleLoader(L *lua.LState) int

PasswordModuleLoader loads the password plugin

func PersistenceModuleLoader

func PersistenceModuleLoader(L *lua.LState) int

func QueryMessages

func QueryMessages(L *lua.LState) int

func RedisModuleLoader

func RedisModuleLoader(L *lua.LState) int

RedisModuleLoader loads the Redis module

func SendMessage

func SendMessage(L *lua.LState) int

SendMessage sends message to mqtt

Types

type Message

type Message struct {
	Timestamp time.Time `json:"timestamp"`
	Payload   string    `json:"payload"`
	Topic     string    `json:"topic"`
}