client

Documentation

Index

• Constants
• type IMessageHandler
• type Message
• type TransportMessageToCC
  • func (t2CC *TransportMessageToCC) Exec(message *Message) error
• type WebSocket
  • func NewWebSocket(uri string) (ws *WebSocket, err error)
  • func (ws *WebSocket) Close() (err error)
  • func (ws *WebSocket) OnMessage(handler IMessageHandler)
  • func (ws *WebSocket) Receive() string
  • func (ws *WebSocket) ReceiveJson(ref interface{})
  • func (ws *WebSocket) Send(message string) (err error)
  • func (ws *WebSocket) SendJson(ref interface{}) (err error)

Constants

const DEFAULT_ORIGIN = "http://127.0.0.1"

Types

type IMessageHandler

type IMessageHandler interface {
	Exec(message *Message) error
}

type Message

type Message struct {
	Org     int    `json:"org"`     // 归属组织
	Topic   int    `json:"topic"`   // 主题
	Content string `json:"content"` // 内容
}

type TransportMessageToCC

type TransportMessageToCC struct {
}

func (*TransportMessageToCC) Exec

func (t2CC *TransportMessageToCC) Exec(message *Message) error

type WebSocket

type WebSocket struct {
	Stop chan bool
	// contains filtered or unexported fields
}

func NewWebSocket

func NewWebSocket(uri string) (ws *WebSocket, err error)

func (*WebSocket) Close

func (ws *WebSocket) Close() (err error)

func (*WebSocket) OnMessage

func (ws *WebSocket) OnMessage(handler IMessageHandler)

func (*WebSocket) Receive

func (ws *WebSocket) Receive() string

func (*WebSocket) ReceiveJson

func (ws *WebSocket) ReceiveJson(ref interface{})

func (*WebSocket) Send

func (ws *WebSocket) Send(message string) (err error)

func (*WebSocket) SendJson

func (ws *WebSocket) SendJson(ref interface{}) (err error)