Schema.h

 
#pragma once
 
#include <map>
 
#include <iosfwd>
#include <memory>
 
#pragma GCC visibility push(default)
 
namespace pulsar {
 
enum SchemaType
{
    NONE = 0,
 
    STRING = 1,
 
    INT8 = 2,
 
    INT16 = 3,
 
    INT32 = 4,
 
    INT64 = 5,
 
    FLOAT = 6,
 
    DOUBLE = 7,
 
    BYTES = 8,
 
    JSON = 9,
 
    PROTOBUF = 10,
 
    AVRO = 11,
 
    AUTO_CONSUME = 13,
 
    AUTO_PUBLISH = 14,
 
    KEY_VALUE = 15,
};
 
// Return string representation of result code
const char *strSchemaType(SchemaType schemaType);
 
class SchemaInfoImpl;
 
typedef std::map<std::string, std::string> StringMap;
 
class SchemaInfo {
   public:
    SchemaInfo();
 
    SchemaInfo(SchemaType schemaType, const std::string &name, const std::string &schema,
               const StringMap &properties = StringMap());
 
    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_;
};
 
}  // namespace pulsar
 
std::ostream &operator<<(std::ostream &s, pulsar::SchemaType schemaType);
 
#pragma GCC visibility pop