Documentation
¶
Index ¶
Constants ¶
View Source
const ( PublicTopic = "" InnerTopic = "inner" SysTopic = "sys" )
Variables ¶
View Source
var ( TopicSubscribe = NewTopic("/sys/subscribe") TopicCancel = NewTopic("/sys/cancel") TopicCancelAll = NewTopic("/sys/cancel_all") TopicGetAllTopics = NewTopic("/sys/admin/GetAllTopics") )
View Source
var (
ErrNotAllowedTopic = errors.New("this topic is not allowed to subscribe or publish")
)
View Source
var InvalidMessage = errors.New("invalid message")
Functions ¶
func IsInnerTopic ¶
func IsPublicTopic ¶
func IsSysTopic ¶
func TypeofTopic ¶
Types ¶
type Serializer ¶
type Serializer struct {
// contains filtered or unexported fields
}
func NewSerializer ¶
func NewSerializer(messagePrefix []byte) *Serializer
func (*Serializer) Deserialize ¶
func (ms *Serializer) Deserialize(t Topic, websocketMessage []byte) (interface{}, error)
deserialize deserializes a custom websocket message from the client such as prefix:topic;0:abc_msg Supported data types are: string, int, bool, bytes and JSON.
func (*Serializer) GetMsgTopic ¶
func (ms *Serializer) GetMsgTopic(websocketMessage []byte) Topic
getWebsocketCustomEvent return empty string when the websocketMessage is native message
func (*Serializer) Serialize ¶
func (ms *Serializer) Serialize(t Topic, data interface{}) ([]byte, error)
websocketMessageSerialize serializes a custom websocket message from websocketServer to be delivered to the client returns the string form of the message Supported data types are: string, int, bool, bytes and JSON.
Source Files
Click to show internal directories.
Click to hide internal directories.