message

package

Go to main page

Versions in this module

v0

v0.2.5

May 16, 2020

Changes in this version

+ var DefaultMsgPrefix = []byte("ws")

+ var TopicBase = SysTopic.Child("base")

+ var TopicCluster = SysTopic.Child("cluster")

+ var TopicClusterInfo = TopicCluster.Child("info")

+ var TopicClusterLateral = TopicCluster.Child("lateral")

+ var TopicClusterRedirect = TopicCluster.Child("redirect")

+ var TopicClusterSuperior = TopicCluster.Child("superior")

+ var TopicTopic = SysTopic.Child("topic")

type Serializer

+ func (ms *Serializer) Prefix() []byte

type Topic

+ Child func(string) Topic

+ IsChildOf func(p Topic) bool

v0.2.4

May 10, 2020

Changes in this version

+ var TopicClusterIps = NewTopic("/sys/cluster/ips")

+ var TopicLateral = NewTopic("/sys/cluster/lateral")

+ var TopicLateralRedirect = NewTopic("/sys/cluster/lateral/redirect")

+ var TopicSuperior = NewTopic("/sys/cluster/Superior")

+ var TopicSuperiorIps = NewTopic("/sys/cluster/Superior/ips")

+ type FuncError = func(error)

+ type Publisher interface

+ Pub func(interface{})

type Serializer

+ func (ms *Serializer) GetMsgType(msg []byte) MsgType

+ func (ms *Serializer) GetRandomID(msg []byte) uint32

+ func (ms *Serializer) GetSourceID(msg []byte) uint32

+ func (ms *Serializer) ResetRandomTag(msg []byte, randomTag int)

+ func (ms *Serializer) ResetSourceID(msg []byte, sourceId int)

+ func (ms *Serializer) ReturnBackBytes(p []byte)

+ type Subscriber interface

+ Cancel func()

+ Do func(data interface{})

+ SetMax func(uint)

+ SetOnce func()

+ Valid func() bool

+ type SubscriberList interface

+ Add func(callback Func) Subscriber

+ Len func() int

+ Range func(func(s Subscriber))

+ func NewSubscriberList() SubscriberList

type Topic

+ Bytes func() []byte

v0.2.3

Apr 8, 2020

Changes in this version

+ var InvalidPrefix = errors.New("invalid prefix")

+ var InvalidTopic = errors.New("invalid topic")

+ var TopicSubscribeAll = NewTopic("/sys/admin/subscribe_all")

+ func MsgTypeName(m MsgType) string

+ type FuncTransfer = func([]byte, string, string)

type Serializer

+ func (ms *Serializer) AddSourceTopicItem(msg []byte, source_id string)

+ func (ms *Serializer) GetSourceTopic(msg []byte) Topic

+ func (ms *Serializer) SeparateMessage(msg []byte) (target Topic, source Topic, tag string, typ MsgType, data []byte)

v0.2.2

Apr 7, 2020

Changes in this version

+ type Func interface

+ type FuncBlank = func()

+ type FuncBool = func(bool)

+ type FuncBytes = func([]byte)

+ type FuncDefault = func(interface{})

+ type FuncInt = func(int)

+ type FuncString = func(string)

+ type MsgType string

+ const MsgTypeBool

+ const MsgTypeBytes

+ const MsgTypeInt

+ const MsgTypeJSON

+ const MsgTypeString

+ func (m MsgType) Name() string

+ func (m MsgType) String() string

v0.2.1

Feb 12, 2020

Changes in this version

+ var ErrUnformedMsg = errors.New("unformed Msg")

+ var TopicAuth = NewTopic("/sys/auth")

+ var TopicGetAllNodes = NewTopic("/sys/admin/get_all_nodes")

+ var TopicStopNode = NewTopic("/sys/admin/stop_node")

+ var TopicSysLog = NewTopic("/sys/log")

v0.2.0

Feb 11, 2020

Changes in this version

+ const InnerTopic

+ const PublicTopic

+ const SysTopic

+ var ErrNotAllowedTopic = errors.New("this topic is not allowed to subscribe or publish")

+ var InvalidMessage = errors.New("invalid message")

+ var TopicCancel = NewTopic("/sys/cancel")

+ var TopicCancelAll = NewTopic("/sys/cancel_all")

+ var TopicGetAllTopics = NewTopic("/sys/admin/GetAllTopics")

+ var TopicSubscribe = NewTopic("/sys/subscribe")

+ func IsInnerTopic(t Topic) bool

+ func IsPublicTopic(t Topic) bool

+ func IsSysTopic(t Topic) bool

+ func TypeofTopic(t Topic) string

+ type Serializer struct

+ func NewSerializer(messagePrefix []byte) *Serializer

+ func (ms *Serializer) Deserialize(t Topic, websocketMessage []byte) (interface{}, error)

+ func (ms *Serializer) GetMsgTopic(websocketMessage []byte) Topic

+ func (ms *Serializer) Serialize(t Topic, data interface{}) ([]byte, error)

+ type Topic interface

+ FirstFragment func() string

+ Fragment func(int) string

+ Len func() int

+ Since func(int) string

+ String func() string

+ func NewTopic(t string) Topic

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL