status

Documentation

Index

• func HandleRequest(w http.ResponseWriter, r *http.Request)
• type Connection
• type Connections
  • func NewConnections(proto string) *Connections
  • func (c *Connections) Connected(conn net.Conn)
  • func (c *Connections) Disconnected(conn net.Conn)
  • func (c *Connections) MarshalJSON() ([]byte, error)
  • func (c *Connections) Packet(conn net.Conn, packet mqtt.Identifier)

Functions

func HandleRequest

func HandleRequest(w http.ResponseWriter, r *http.Request)

Types

type Connection

type Connection struct {
	LastTimestamp time.Time
	LastPacket    mqtt.Identifier
}

type Connections

type Connections struct {
	// contains filtered or unexported fields
}

func NewConnections

func NewConnections(proto string) *Connections

func (*Connections) Connected

func (c *Connections) Connected(conn net.Conn)

func (*Connections) Disconnected

func (c *Connections) Disconnected(conn net.Conn)

func (*Connections) MarshalJSON

func (c *Connections) MarshalJSON() ([]byte, error)

func (*Connections) Packet

func (c *Connections) Packet(conn net.Conn, packet mqtt.Identifier)