Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientsBySubscription ¶
type ClientsBySubscription map[string][]*ServerClient
type IncomingMessage ¶
type IncomingMessage struct {
// contains filtered or unexported fields
}
type PubSubServer ¶
type PubSubServer struct {
// contains filtered or unexported fields
}
func New ¶
func New(confCtx *config.Context) *PubSubServer
func (*PubSubServer) Close ¶
func (e *PubSubServer) Close()
type ServerClient ¶
type ServerClient struct {
// contains filtered or unexported fields
}
client from the server's perspective
func (*ServerClient) DisconnectNonBlocking ¶
func (c *ServerClient) DisconnectNonBlocking()
Source Files
Click to show internal directories.
Click to hide internal directories.