model

Documentation

Index

• Constants
• func SessionExpired(lastSeen int64, expiryInterval int64) bool
• type Client
• type Message
• type Retain
• type Retry
  • func (r Retry) Expired() bool
• type RunningSession
  • func (s *RunningSession) ApplyAcl(pubAcl string, subAcl string)
  • func (s *RunningSession) ApplySessionId(sessionID int64)
  • func (s *RunningSession) CleanStart() bool
  • func (s *RunningSession) Expired() bool
  • func (s *RunningSession) FromLocalhost() bool
  • func (s *RunningSession) GetClientId() string
  • func (s *RunningSession) GetConn() TagyouConn
  • func (s *RunningSession) GetConnected() bool
  • func (s *RunningSession) GetExpiryInterval() int64
  • func (s *RunningSession) GetId() int64
  • func (s *RunningSession) GetKeepAlive() int
  • func (s *RunningSession) GetLastConnect() int64
  • func (s *RunningSession) GetLastSeen() int64
  • func (s *RunningSession) GetProtocolVersion() uint8
  • func (s *RunningSession) HavePass() bool
  • func (s *RunningSession) HaveUser() bool
  • func (s *RunningSession) ReservedBit() bool
  • func (s *RunningSession) SetConnected(connected bool)
  • func (s *RunningSession) WillFlag() bool
  • func (s *RunningSession) WillQoS() uint8
  • func (s *RunningSession) WillRetain() bool
• type Session
• type Subscription
• type SubscriptionGroup
• type TagyouConn
• type User
• type WebsocketConnection
  • func (c WebsocketConnection) Close() error
  • func (c WebsocketConnection) RemoteAddr() net.Addr
  • func (c WebsocketConnection) Write(b []byte) (n int, e error)

Constants

const WAIT_FOR_PUB_ACK = 10

qos 1

const WAIT_FOR_PUB_COMP = 21

const WAIT_FOR_PUB_REC = 20

qos 2

const WAIT_FOR_PUB_REL = 20

Functions

func SessionExpired

func SessionExpired(lastSeen int64, expiryInterval int64) bool

Types

type Client

type Client struct {
	ID           int64
	ClientId     string
	Username     string
	Password     []byte
	SubscribeAcl string
	PublishAcl   string
	CreatedAt    int64
}

type Message

type Message struct {
	Topic       string
	Qos         byte
	Retained    bool
	Payload     string
	PayloadType byte
}

type Retain

type Retain struct {
	ClientID           string
	Topic              string
	ApplicationMessage []byte
	CreatedAt          int64
}

type Retry

type Retry struct {
	ID                 int64
	ClientId           string
	ApplicationMessage []byte
	PacketIdentifier   int
	Qos                uint8
	Dup                bool
	Retries            uint8
	AckStatus          uint8
	CreatedAt          int64
	SessionID          int64
	ReasonCode         uint8
}

func (Retry) Expired

func (r Retry) Expired() bool

type RunningSession

type RunningSession struct {
	ID              int64
	SessionID       int64
	ClientId        string
	ProtocolVersion uint8
	LastSeen        int64
	LastConnect     int64
	Connected       bool
	ExpiryInterval  int64
	ConnectFlags    uint8
	KeepAlive       int
	WillTopic       string
	WillDelay       int64
	WillMessage     []byte
	Username        string
	Password        string
	SubscribeAcl    string
	PublishAcl      string
	Conn            TagyouConn
	Mu              sync.RWMutex
}

func (*RunningSession) ApplyAcl

func (s *RunningSession) ApplyAcl(pubAcl string, subAcl string)

func (*RunningSession) ApplySessionId

func (s *RunningSession) ApplySessionId(sessionID int64)

func (*RunningSession) CleanStart

func (s *RunningSession) CleanStart() bool

func (*RunningSession) Expired

func (s *RunningSession) Expired() bool

func (*RunningSession) FromLocalhost

func (s *RunningSession) FromLocalhost() bool

func (*RunningSession) GetClientId

func (s *RunningSession) GetClientId() string

func (*RunningSession) GetConn

func (s *RunningSession) GetConn() TagyouConn

func (*RunningSession) GetConnected

func (s *RunningSession) GetConnected() bool

func (*RunningSession) GetExpiryInterval

func (s *RunningSession) GetExpiryInterval() int64

func (*RunningSession) GetId

func (s *RunningSession) GetId() int64

func (*RunningSession) GetKeepAlive

func (s *RunningSession) GetKeepAlive() int

func (*RunningSession) GetLastConnect

func (s *RunningSession) GetLastConnect() int64

func (*RunningSession) GetLastSeen

func (s *RunningSession) GetLastSeen() int64

func (*RunningSession) GetProtocolVersion

func (s *RunningSession) GetProtocolVersion() uint8

func (*RunningSession) HavePass

func (s *RunningSession) HavePass() bool

func (*RunningSession) HaveUser

func (s *RunningSession) HaveUser() bool

func (*RunningSession) ReservedBit

func (s *RunningSession) ReservedBit() bool

func (*RunningSession) SetConnected

func (s *RunningSession) SetConnected(connected bool)

func (*RunningSession) WillFlag

func (s *RunningSession) WillFlag() bool

func (*RunningSession) WillQoS

func (s *RunningSession) WillQoS() uint8

func (*RunningSession) WillRetain

func (s *RunningSession) WillRetain() bool

type Session

type Session interface {
	GetId() int64
	GetClientId() string
	GetProtocolVersion() uint8
	Expired() bool
	GetLastSeen() int64
	GetLastConnect() int64
	GetExpiryInterval() int64
	GetConnected() bool
}

type Subscription

type Subscription struct {
	ClientId          string
	Topic             string
	RetainHandling    uint8
	RetainAsPublished uint8
	NoLocal           uint8
	Qos               uint8
	ProtocolVersion   uint8
	Enabled           bool
	CreatedAt         int64
	SessionID         int64
	Shared            bool
	ShareName         string
}

type SubscriptionGroup

type SubscriptionGroup map[string][]Subscription

type TagyouConn

type TagyouConn interface {
	Write(b []byte) (n int, err error)
	Close() error
	RemoteAddr() net.Addr
}

type User

type User struct {
	ID        int64
	Username  string
	Password  []byte
	CreatedAt int64
}

* Users enabled to connect to http apis

type WebsocketConnection

type WebsocketConnection struct {
	Conn *websocket.Conn
}

func (WebsocketConnection) Close

func (c WebsocketConnection) Close() error

func (WebsocketConnection) RemoteAddr

func (c WebsocketConnection) RemoteAddr() net.Addr

func (WebsocketConnection) Write

func (c WebsocketConnection) Write(b []byte) (n int, e error)