Versions in this module Expand all Collapse all v0 v0.0.2 Sep 13, 2021 Changes in this version + var ErrBufferInsufficientData error = errors.New("service: buffer has insufficient data.") + var ErrBufferNotReady error = errors.New("service: buffer is not ready") + var ErrInvalidConnectionType error = errors.New("service: Invalid connection type") + var ErrInvalidSubscriber error = errors.New("service: Invalid subscriber") + var SVC *service + func GetServerName() string + func InitServiceTaskPool(poolSize int) (close io.Closer) + type Client struct + AckTimeout int + AuthPlus authplus.AuthPlus + ConnectTimeout int + KeepAlive int + TimeoutRetries int + func (this *Client) Connect(uri string, msg *messagev5.ConnectMessage) (err error) + func (this *Client) Disconnect() + func (this *Client) Ping(onComplete OnCompleteFunc) error + func (this *Client) Publish(msg *messagev5.PublishMessage, onComplete OnCompleteFunc) error + func (this *Client) Subscribe(msg *messagev5.SubscribeMessage, onComplete OnCompleteFunc, ...) error + func (this *Client) Unsubscribe(msg *messagev5.UnsubscribeMessage, onComplete OnCompleteFunc) error + type OnCompleteFunc func(msg, ack messagev5.Message, err error) error + type OnPublishFunc func(msg *messagev5.PublishMessage) error + type SafeMap struct + func NewSafeMap() *SafeMap + func (sm *SafeMap) Get(k uint16) (v interface{}, exist bool) + func (sm *SafeMap) Set(k uint16, v interface{}) (interface{}, bool) + type Server struct + AckTimeout int + AuthPlusProvider []string + Authenticator string + ClusterClient *sync.Map + ClusterDiscover cluster.NodeDiscover + ClusterServer *server.Server + ConFig *config.SIConfig + ConnectTimeout int + EventStore store.EventStore + KeepAlive int + MessageStore store.MessageStore + SessionStore store.SessionStore + SessionsProvider string + ShareTopicMapNode cluster.ShareTopicMapNode + TimeoutRetries int + TopicsProvider string + Version string + WriteTimeout int + func (s *Server) TopicProvider() *topicsv5.Manager + func (this *Server) AddCloser(close io.Closer) + func (this *Server) Close() error + func (this *Server) InitStore() + func (this *Server) ListenAndServe(uri string) error + func (this *Server) NewService() *service + func (this *Server) RunClusterComp()