models

Documentation

Index

• Variables
• func FromMessage(m Message) messages.Message
• func Reply(msg Message, sendTo string) (err error)
• func SendMsg(msg Message, sendTo string) (err error)
• func SendText(text, sendTo string) (err error)
• type InformMessage
• type Message
  • func CreateMessage(m messages.Message, properties MessageProperties) (Message, error)
  • func ReciveMsg(queue string) (message Message)
• type MessageProperties
• type RabbitMQ
  • func (r *RabbitMQ) Close() (err error)
  • func (r *RabbitMQ) Connect() (err error)
• type Receive

Variables

var ChangeChan chan messages.Message

ChangeChan is a change msg queue

var InformChan chan Receive

InformChan is a inform msg queue,used for device log

Functions

func FromMessage

func FromMessage(m Message) messages.Message

FromMessage tr069 msg decode

func Reply

func Reply(msg Message, sendTo string) (err error)

Reply rpc reply

func SendMsg

func SendMsg(msg Message, sendTo string) (err error)

SendMsg send msg

func SendText

func SendText(text, sendTo string) (err error)

SendText send text

Types

type InformMessage

type InformMessage struct {
	Inform    *messages.Inform
	Timestamp string
}

InformMessage used to store device inform

type Message

type Message struct {
	MessageProperties
	Body []byte
}

Message amqp msg

func CreateMessage

func CreateMessage(m messages.Message, properties MessageProperties) (Message, error)

CreateMessage tr069 msg encode

func ReciveMsg

func ReciveMsg(queue string) (message Message)

ReciveMsg query msg

type MessageProperties

type MessageProperties struct {
	Headers         amqp.Table
	CorrelationID   string
	ReplyTo         string
	ContentEncoding string
	ContentType     string
	Expiration      string
}

MessageProperties amqp msg property

type RabbitMQ

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

RabbitMQ conn info

func (*RabbitMQ) Close

func (r *RabbitMQ) Close() (err error)

Close close conn

func (*RabbitMQ) Connect

func (r *RabbitMQ) Connect() (err error)

Connect create a new amqp conn

type Receive

type Receive struct {
	Sn            string
	BytesReceived string
}

Receive device log