storage

Documentation

Index

• Constants
• Variables
• type Client
  • func (d Client) MarshalBinary() (data []byte, err error)
  • func (d *Client) UnmarshalBinary(data []byte) error
• type ClientProperties
• type ClientWill
• type Message
  • func (d Message) MarshalBinary() (data []byte, err error)
  • func (d *Message) ToPacket() packets.Packet
  • func (d *Message) UnmarshalBinary(data []byte) error
• type MessageProperties
• type Serializable
• type Subscription
  • func (d Subscription) MarshalBinary() (data []byte, err error)
  • func (d *Subscription) UnmarshalBinary(data []byte) error
• type SystemInfo
  • func (d SystemInfo) MarshalBinary() (data []byte, err error)
  • func (d *SystemInfo) UnmarshalBinary(data []byte) error

Constants

const (
	SubscriptionKey = "SUB" // unique key to denote Subscriptions in a store
	SysInfoKey      = "SYS" // unique key to denote server system information in a store
	RetainedKey     = "RET" // unique key to denote retained messages in a store
	InflightKey     = "IFM" // unique key to denote inflight messages in a store
	ClientKey       = "CL"  // unique key to denote clients in a store
)

Variables

var (
	// ErrDBFileNotOpen indicates that the file database (e.g. bolt/badger) wasn't open for reading.
	ErrDBFileNotOpen = errors.New("db file not open")
)

Types

type Client

type Client struct {
	Will            ClientWill       `json:"will"`            // will topic and payload data if applicable
	Properties      ClientProperties `json:"properties"`      // the connect properties for the client
	Username        []byte           `json:"username"`        // the username of the client
	ID              string           `json:"id" storm:"id"`   // the client id / storage key
	T               string           `json:"t"`               // the data type (client)
	Remote          string           `json:"remote"`          // the remote address of the client
	Listener        string           `json:"listener"`        // the listener the client connected on
	ProtocolVersion byte             `json:"protocolVersion"` // mqtt protocol version of the client
	Clean           bool             `json:"clean"`           // if the client requested a clean start/session
}

Client is a storable representation of an MQTT client.

func (Client) MarshalBinary

func (d Client) MarshalBinary() (data []byte, err error)

MarshalBinary encodes the values into a json string.

func (*Client) UnmarshalBinary

func (d *Client) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes a json string into a struct.

type ClientProperties

type ClientProperties struct {
	AuthenticationData        []byte                 `json:"authenticationData"`
	User                      []packets.UserProperty `json:"user"`
	AuthenticationMethod      string                 `json:"authenticationMethod"`
	SessionExpiryInterval     uint32                 `json:"sessionExpiryInterval"`
	MaximumPacketSize         uint32                 `json:"maximumPacketSize"`
	ReceiveMaximum            uint16                 `json:"receiveMaximum"`
	TopicAliasMaximum         uint16                 `json:"topicAliasMaximum"`
	SessionExpiryIntervalFlag bool                   `json:"sessionExpiryIntervalFlag"`
	RequestProblemInfo        byte                   `json:"requestProblemInfo"`
	RequestProblemInfoFlag    bool                   `json:"requestProblemInfoFlag"`
	RequestResponseInfo       byte                   `json:"requestResponseInfo"`
}

ClientProperties contains a limited set of the mqtt v5 properties specific to a client connection.

type ClientWill

type ClientWill struct {
	Payload           []byte                 `json:"payload"`
	User              []packets.UserProperty `json:"user"`
	TopicName         string                 `json:"topicName"`
	Flag              uint32                 `json:"flag"`
	WillDelayInterval uint32                 `json:"willDelayInterval"`
	Qos               byte                   `json:"qos"`
	Retain            bool                   `json:"retain"`
}

ClientWill contains a will message for a client, and limited mqtt v5 properties.

type Message

type Message struct {
	Properties  MessageProperties   `json:"properties"`    // -
	Payload     []byte              `json:"payload"`       // the message payload (if retained)
	T           string              `json:"t"`             // the data type
	ID          string              `json:"id" storm:"id"` // the storage key
	Origin      string              `json:"origin"`        // the id of the client who sent the message
	TopicName   string              `json:"topic_name"`    // the topic the message was sent to (if retained)
	FixedHeader packets.FixedHeader `json:"fixedheader"`   // the header properties of the message
	Created     int64               `json:"created"`       // the time the message was created in unixtime
	Sent        int64               `json:"sent"`          // the last time the message was sent (for retries) in unixtime (if inflight)
	PacketID    uint16              `json:"packet_id"`     // the unique id of the packet (if inflight)
}

Message is a storable representation of an MQTT message (specifically publish).

func (Message) MarshalBinary

func (d Message) MarshalBinary() (data []byte, err error)

MarshalBinary encodes the values into a json string.

func (*Message) ToPacket

func (d *Message) ToPacket() packets.Packet

ToPacket converts a storage.Message to a standard packet.

func (*Message) UnmarshalBinary

func (d *Message) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes a json string into a struct.

type MessageProperties

type MessageProperties struct {
	CorrelationData        []byte                 `json:"correlationData"`
	SubscriptionIdentifier []int                  `json:"subscriptionIdentifier"`
	User                   []packets.UserProperty `json:"user"`
	ContentType            string                 `json:"contentType"`
	ResponseTopic          string                 `json:"responseTopic"`
	MessageExpiryInterval  uint32                 `json:"messageExpiry"`
	TopicAlias             uint16                 `json:"topicAlias"`
	PayloadFormat          byte                   `json:"payloadFormat"`
	PayloadFormatFlag      bool                   `json:"payloadFormatFlag"`
}

MessageProperties contains a limited subset of mqtt v5 properties specific to publish messages.

type Serializable

type Serializable interface {
	UnmarshalBinary([]byte) error
	MarshalBinary() (data []byte, err error)
}

Serializable is an interface for objects that can be serialized and deserialized.

type Subscription

type Subscription struct {
	T                 string `json:"t"`
	ID                string `json:"id" storm:"id"`
	Client            string `json:"client"`
	Filter            string `json:"filter"`
	Identifier        int    `json:"identifier"`
	RetainHandling    byte   `json:"retain_handling"`
	Qos               byte   `json:"qos"`
	RetainAsPublished bool   `json:"retain_as_pub"`
	NoLocal           bool   `json:"no_local"`
}

Subscription is a storable representation of an MQTT subscription.

func (Subscription) MarshalBinary

func (d Subscription) MarshalBinary() (data []byte, err error)

MarshalBinary encodes the values into a json string.

func (*Subscription) UnmarshalBinary

func (d *Subscription) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes a json string into a struct.

type SystemInfo

type SystemInfo struct {
	system.Info        // embed the system info struct
	T           string `json:"t"`             // the data type
	ID          string `json:"id" storm:"id"` // the storage key
}

SystemInfo is a storable representation of the system information values.

func (SystemInfo) MarshalBinary

func (d SystemInfo) MarshalBinary() (data []byte, err error)

MarshalBinary encodes the values into a json string.

func (*SystemInfo) UnmarshalBinary

func (d *SystemInfo) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes a json string into a struct.