db

Documentation

Index

• Variables
• func CheckAuth(login string, pass string) error
• func Close()
• func DeleteRetain(topic string, qos int) error
• func DeleteSubscription(id string, topic string) error
• func FetchRetain() (map[string]*packet.WillMessage, error)
• func FetchSubcription(id string) (map[string]int, error)
• func Open(dbName string) error
• func SaveRetain(topic string, payload string, qos int) error
• func SaveSubscription(id string, topic string, qos int) error

Variables

var (
	ErrNotFound = errors.New("empty result set")
)

Functions

func CheckAuth

func CheckAuth(login string, pass string) error

TODO use bcrypt to store passwords

func Close

func Close()

func DeleteRetain

func DeleteRetain(topic string, qos int) error

func DeleteSubscription

func DeleteSubscription(id string, topic string) error

func FetchRetain

func FetchRetain() (map[string]*packet.WillMessage, error)

func FetchSubcription

func FetchSubcription(id string) (map[string]int, error)

func Open

func Open(dbName string) error

func SaveRetain

func SaveRetain(topic string, payload string, qos int) error

func SaveSubscription

func SaveSubscription(id string, topic string, qos int) error