mqtt

type MessageDirection int

type MessageState int

type MqttFactory struct{}

type SessionTopic struct {
	Launcher  string `json:"launcher"`
	SessionId string `json:"sessionId"`
	Action    string `json:"action"`
	State     uint8  `json:"oldState"`
	// contains filtered or unexported fields
}

type Storage interface {
	Open() error
	Close()
	Backup(shutdown bool) error
	Restore() error

	// Session
	FindSession(id string) (*mqttSession, error)
	DeleteSession(id string) error
	UpdateSession(s *mqttSession) error
	RegisterSession(s *mqttSession) error

	// Subscription
	AddSubscription(sessionid string, topic string, qos uint8) error
	RetainSubscription(sessionid string, topic string, qos uint8) error
	RemoveSubscription(sessionid string, topic string) error

	// Message Management
	FindMessage(clientid string, mid uint16) (bool, error)
	StoreMessage(clientid string, msg StorageMessage) error
	DeleteMessageWithValidator(clientid string, validator func(StorageMessage) bool)
	DeleteMessage(clientid string, mid uint16, direction MessageDirection) error

	QueueMessage(clientid string, msg StorageMessage) error
	GetMessageTotalCount(clientid string) int
	InsertMessage(clientid string, mid uint16, direction MessageDirection, msg StorageMessage) error
	ReleaseMessage(clientid string, mid uint16, direction MessageDirection) error
	UpdateMessage(clientid string, mid uint16, direction MessageDirection, state MessageState)
}

type StorageDevice struct{}

type StorageMessage struct {
	ID        uint
	SourceID  string
	Topic     string
	Direction MessageDirection
	State     MessageState
	Qos       uint8
	Retain    bool
	Payload   []uint8
}

type StorageSession struct {
	Id                 string
	Username           string
	Password           string
	Keepalive          uint16
	LastMid            uint16
	State              uint8
	LastMessageInTime  time.Time
	LastMessageOutTime time.Time
	Ping               time.Time
	CleanSession       uint8
	SubscribeCount     uint32
	Protocol           uint8
	RefCount           uint8
}

type StorageTopic struct {
	Name string
}

type TenantTopic struct{}