Decoder.hh

Go to the documentation of this file.

#ifndef avro_Decoder_hh__
#define avro_Decoder_hh__

#include <stdint.h>
#include <string>
#include <vector>

#include "ValidSchema.hh"
#include "Stream.hh"

#include <boost/shared_ptr.hpp>


namespace avro {

class Decoder {
public:
    virtual void init(InputStream& is) = 0;

    virtual void decodeNull() = 0;

    virtual bool decodeBool() = 0;

    virtual int32_t decodeInt() = 0;

    virtual int64_t decodeLong() = 0;

    virtual float decodeFloat() = 0;

    virtual double decodeDouble() = 0;

    std::string decodeString() {
        std::string result;
        decodeString(result);
        return result;
    }

    virtual void decodeString(std::string& value) = 0;

    virtual void skipString() = 0;

    std::vector<uint8_t> decodeBytes() {
        std::vector<uint8_t> result;
        decodeBytes(result);
        return result;
    }

    virtual void decodeBytes(std::vector<uint8_t>& value) = 0;

    virtual void skipBytes() = 0;

    std::vector<uint8_t> decodeFixed(size_t n) {
        std::vector<uint8_t> result;
        decodeFixed(n, result);
        return result;
    }

    virtual void decodeFixed(size_t n, std::vector<uint8_t>& value) = 0;

    virtual void skipFixed(size_t n) = 0;

    virtual size_t decodeEnum() = 0;

    virtual size_t arrayStart() = 0;

    virtual size_t arrayNext() = 0;

    virtual size_t skipArray() = 0;

    virtual size_t mapStart() = 0;

    virtual size_t mapNext() = 0;

    virtual size_t skipMap() = 0;

    virtual size_t decodeUnionIndex() = 0;
};

typedef boost::shared_ptr<Decoder> DecoderPtr;

class ResolvingDecoder : public Decoder {
public:
    virtual const std::vector<size_t>& fieldOrder() = 0;
};

typedef boost::shared_ptr<ResolvingDecoder> ResolvingDecoderPtr;
DecoderPtr binaryDecoder();

DecoderPtr validatingDecoder(const ValidSchema& schema,
    const DecoderPtr& base);

DecoderPtr jsonDecoder(const ValidSchema& schema);

ResolvingDecoderPtr resolvingDecoder(const ValidSchema& writer,
    const ValidSchema& reader, const DecoderPtr& base);


}   // namespace avro

#endif