Schema.h

 
#pragma once
 
#include <pulsar/defines.h>
 
#include <iosfwd>
#include <map>
#include <memory>
#include <string>
 
namespace pulsar {
 
enum class KeyValueEncodingType
{
    SEPARATED,
 
    INLINE
};
 
// Return string representation of result code
PULSAR_PUBLIC const char *strEncodingType(pulsar::KeyValueEncodingType encodingType);
 
PULSAR_PUBLIC KeyValueEncodingType enumEncodingType(std::string encodingTypeStr);
 
enum SchemaType
{
    NONE = 0,
 
    STRING = 1,
 
    JSON = 2,
 
    PROTOBUF = 3,
 
    AVRO = 4,
 
    INT8 = 6,
 
    INT16 = 7,
 
    INT32 = 8,
 
    INT64 = 9,
 
    FLOAT = 10,
 
    DOUBLE = 11,
 
    KEY_VALUE = 15,
 
    PROTOBUF_NATIVE = 20,
 
    BYTES = -1,
 
    AUTO_CONSUME = -3,
 
    AUTO_PUBLISH = -4,
};
 
// Return string representation of result code
PULSAR_PUBLIC const char *strSchemaType(SchemaType schemaType);
 
class SchemaInfoImpl;
 
typedef std::map<std::string, std::string> StringMap;
 
class PULSAR_PUBLIC SchemaInfo {
   public:
    SchemaInfo();
 
    SchemaInfo(SchemaType schemaType, const std::string &name, const std::string &schema,
               const StringMap &properties = StringMap());
 
    SchemaInfo(const SchemaInfo &keySchema, const SchemaInfo &valueSchema,
               const KeyValueEncodingType &keyValueEncodingType = KeyValueEncodingType::INLINE);
 
    SchemaType getSchemaType() const;
 
    const std::string &getName() const;
 
    const std::string &getSchema() const;
 
    const StringMap &getProperties() const;
 
   private:
    typedef std::shared_ptr<SchemaInfoImpl> SchemaInfoImplPtr;
    SchemaInfoImplPtr impl_;
    static constexpr uint32_t INVALID_SIZE = 0xFFFFFFFF;
};
 
}  // namespace pulsar
 
PULSAR_PUBLIC std::ostream &operator<<(std::ostream &s, pulsar::SchemaType schemaType);
 
PULSAR_PUBLIC std::ostream &operator<<(std::ostream &s, pulsar::KeyValueEncodingType encodingType);