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 QUICBuffConfigInit(bufferSize, readBlockSize, writeBlockSize uint64) + type OnCompleteFunc func(msg, ack message.Message, err error) error + type OnPublishFunc func(msg *message.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 + Authenticator string + ConnectTimeout int + KeepAlive int + SessionsProvider string + TimeoutRetries int + TopicsProvider string + Version string + func (this *Server) Close() error + func (this *Server) ListenAndServe(uri string) error v0.0.2-temp Aug 19, 2021
Go to main page