code: func New(requests chan *choria.ConnectorMessage, fw *choria.Framework, conn choria.ConnectorInfo, srv ServerInfoSource, log *logrus.Entry) *Manager {
  	return &Manager{
  		agents:     make(map[string]Agent),
  		subs:       make(map[string][]string),
  		fw:         fw,
  		log:        log.WithFields(logrus.Fields{"subsystem": "agents"}),
  		mu:         &sync.Mutex{},
  		requests:   requests,
  		conn:       conn,
  		serverInfo: srv,
  	}
  }
docs: // New creates a new Agent Manager