code: func (p *Plugin) NewWatcher(keyPrefix string) keyval.ProtoWatcher {
  	return p.protoWrapper.NewWatcher(keyPrefix)
  }
docs: // NewWatcher creates new instance of prefixed broker that provides API with arguments of type proto.Message.