Versions in this module Expand all Collapse all v0 v0.2.0 Mar 31, 2017 v0.1.0 Mar 29, 2017 Changes in this version + type ClientsBySubscription map[string][]*ServerClient + type IncomingMessage struct + type PubSubServer struct + func New(confCtx *config.Context) *PubSubServer + func (e *PubSubServer) Close() + type ServerClient struct + func (c *ServerClient) DisconnectNonBlocking()