CryptoKeyReader.h

 
#ifndef CRYPTOKEYREADER_H_
#define CRYPTOKEYREADER_H_
 
#include <pulsar/Result.h>
#include <pulsar/EncryptionKeyInfo.h>
 
#pragma GCC visibility push(default)
 
namespace pulsar {
 
class CryptoKeyReader {
   public:
    virtual ~CryptoKeyReader() {}
 
    /*
     * Return the encryption key corresponding to the key name in the argument
     * <p>
     * This method should be implemented to return the EncryptionKeyInfo. This method will be
     * called at the time of producer creation as well as consumer receiving messages.
     * Hence, application should not make any blocking calls within the implementation.
     * <p>
     *
     * @param keyName
     *            Unique name to identify the key
     * @param metadata
     *            Additional information needed to identify the key
     * @param encKeyInfo updated with details about the public key
     * @return Result ResultOk is returned for success
     *
     */
    virtual Result getPublicKey(const std::string& keyName, std::map<std::string, std::string>& metadata,
                                EncryptionKeyInfo& encKeyInfo) const = 0;
 
    /*
     * @param keyName
     *            Unique name to identify the key
     * @param metadata
     *            Additional information needed to identify the key
     * @param encKeyInfo updated with details about the private key
     * @return Result ResultOk is returned for success
     */
    virtual Result getPrivateKey(const std::string& keyName, std::map<std::string, std::string>& metadata,
                                 EncryptionKeyInfo& encKeyInfo) const = 0;
 
}; /* namespace pulsar */
 
typedef std::shared_ptr<CryptoKeyReader> CryptoKeyReaderPtr;
}  // namespace pulsar
 
#pragma GCC visibility pop
 
#endif /* CRYPTOKEYREADER_H_ */