subpub

package

Go to main page

Versions in this module

v1

v1.2.24053

May 17, 2024

v1.2.24052

May 13, 2024

Changes in this version

+ type ISubA interface

v1.2.24051

Apr 30, 2024

Changes in this version

+ const ACTION_SUCCESSFUL

v1.2.24041

Apr 1, 2024

Changes in this version

+ const ACTION_SERVER_BASE

+ const ACTION_SERVER_CONN_CONNECTED

+ const ACTION_SERVER_CONN_DISCONNECTED

+ const ACTION_SERVER_CONN_RECV_BUF

+ const ACTION_SERVER_CONN_SEND_BUF

+ const ACTION_START

v1.2.24013

Jan 18, 2024

Changes in this version

+ const ACTION_MESSAGE

+ const ACTION_RECVBUF

+ var DefaultPub = NewPubHub()

+ var DefaultSub = NewSubHub()

+ var DefaultSubchannel = NewSubchannel()

+ var DefaultSubscribe = NewSubscribe()

+ type IPub interface

+ Pub func(topic string, max int, args ...interface{}) int

+ type IStatus interface

+ Status func() string

+ type ISub interface

+ Sub func(id, topic string, cb func(id, topic string, args ...interface{}) (ok bool))

+ type ISubPub interface

+ type IUnsub interface

+ Unsub func(id, topic string) bool

+ type SubFunc = func(id, topic string, args ...interface{}) (ok bool)

type SubHub

+ func (this *SubHub) ConfigDefaultConnType(s string)

+ func (this *SubHub) Status() string

+ type Subchannel struct

+ func NewSubchannel() *Subchannel

+ func (this *Subchannel) CleanChannels() (cnt int)

+ func (this *Subchannel) Close() error

+ func (this *Subchannel) ClosePubChannel(channel string) (closed bool)

+ func (this *Subchannel) GetChannelCount() int

+ func (this *Subchannel) GetChannelSessionCount(channel string) int

+ func (this *Subchannel) Pub(channel string, max int, args ...interface{}) int

+ func (this *Subchannel) Status() string

+ func (this *Subchannel) Sub(id, channel string, cb SubFunc)

+ func (this *Subchannel) Unsub(id, channel string) bool

+ type Subscribe struct

+ func NewSubscribe() *Subscribe

+ func NewSubscribeEx(routeParseFunc func(topic string) interface{}, ...) *Subscribe

+ func (this *Subscribe) CleanChannels() (cnt int)

+ func (this *Subscribe) Close() error

+ func (this *Subscribe) ClosePubChannel(channel string) (closed bool)

+ func (this *Subscribe) Count() int

+ func (this *Subscribe) GetTopicSubCount(topic string) int

+ func (this *Subscribe) Pub(channel string, max int, args ...interface{}) int

+ func (this *Subscribe) Status() string

+ func (this *Subscribe) StatusDetail() string

+ func (this *Subscribe) Sub(id, topic string, cb SubFunc)

+ func (this *Subscribe) TopicCount() int

+ func (this *Subscribe) Unsub(id, topic string) bool

v1.2.24012

Jan 7, 2024

Changes in this version

+ const ACTION_BEFORE_CONNECT

+ const ACTION_CLOSE

+ const ACTION_CONNECTED

+ const ACTION_CONNECTFAIL

+ const ACTION_CUSTOM

+ const ACTION_DISCONNECTED

+ const ACTION_ERROR

+ const ACTION_RECV_TOPIC_DATA

+ const ACTION_SEND_BUF

+ type PubHub struct

+ func NewPubHub() *PubHub

+ func (this *PubHub) AddSession(sessionid string, conf gobase.StrMap, notifyFn gobase.SubFunc) error

+ func (this *PubHub) DelSession(sessionid string) bool

+ func (this *PubHub) Pub(sessionid string, topic string, max int, args ...interface{}) int

+ type PubSessionIntf interface

+ Close func() error

+ Pub func(topic string, max int, args ...interface{}) int

+ Start func()

+ type SubHub struct

+ func NewSubHub() *SubHub

+ func (this *SubHub) AddSession(sessionid string, conf gobase.StrMap, fn gobase.SubFunc) error

+ func (this *SubHub) DelSession(sessionid string) bool

+ func (this *SubHub) PostData(sessionid string, args ...interface{}) error

+ type SubSessionIntf interface

+ Close func() error

+ PostData func(args ...interface{}) error

+ Start func()

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