code: func NewKvBytesPluginWrapper(cbw keyval.KvBytesPlugin, decrypter ArbitraryDecrypter, decryptFunc DecryptFunc) *KvBytesPluginWrapper {
  	return &KvBytesPluginWrapper{
  		KvBytesPlugin: cbw,
  		decryptData: decryptData{
  			decryptFunc: decryptFunc,
  			decrypter:   decrypter,
  		},
  	}
  }
docs: // NewKvBytesPluginWrapper creates wrapper for provided CoreBrokerWatcher, adding support for decrypting encrypted
  // data