execution.hpp

Go to the documentation of this file.

#ifndef CORAL_PROTOCOL_EXECUTION_HPP
#define CORAL_PROTOCOL_EXECUTION_HPP

#include <cstdint>
#include <vector>
#include "google/protobuf/message_lite.h"
#include "zmq.hpp"
#include "execution.pb.h"


namespace coral
{
namespace protocol
{

namespace execution
{


void CreateHelloMessage(
    std::vector<zmq::message_t>& message,
    uint16_t protocolVersion);


void CreateHelloMessage(
    std::vector<zmq::message_t>& message,
    uint16_t protocolVersion,
    const google::protobuf::MessageLite& body);

void CreateDeniedMessage(
    std::vector<zmq::message_t>& message,
    const std::string& reason = std::string());


void CreateMessage(
    std::vector<zmq::message_t>& message,
    coralproto::execution::MessageType type);


void CreateMessage(
    std::vector<zmq::message_t>& message,
    coralproto::execution::MessageType type,
    const google::protobuf::MessageLite& body);


void CreateErrorMessage(
    std::vector<zmq::message_t>& message,
    coralproto::execution::ErrorInfo::Code code,
    const std::string& details = std::string());


void CreateFatalErrorMessage(
    std::vector<zmq::message_t>& message,
    coralproto::execution::ErrorInfo::Code code,
    const std::string& details = std::string());


uint16_t ParseMessageType(const zmq::message_t& header);


uint16_t NonErrorMessageType(const std::vector<zmq::message_t>& message);


class RemoteErrorException : public std::runtime_error
{
public:
    // Constructor for DENIED messages.
    explicit RemoteErrorException(const std::string& deniedReason);

    // Constructor for ERROR messages.
    explicit RemoteErrorException(const coralproto::execution::ErrorInfo& errorInfo);
};


uint16_t ParseHelloMessage(const std::vector<zmq::message_t>& message);


}}}     // namespace
#endif  // header guard