code: func (p *LogsPump) RoutingFrom(id string) bool {
  	p.mu.Lock()
  	defer p.mu.Unlock()
  	_, monitoring := p.pumps[normalID(id)]
  	return monitoring
  }
docs: // RoutingFrom returns whether a container id is routing from this pump