ServerConnector.h

Go to the documentation of this file.

 
#pragma once
#include "ConnectionSettings.h"
#include "PeerConnectCode.h"
#include "catapult/functions.h"
#include <memory>
 
namespace catapult {
    namespace crypto { class KeyPair; }
    namespace ionet {
        class Node;
        class PacketSocket;
    }
    namespace thread { class IoThreadPool; }
}
 
namespace catapult { namespace net {
 
    class ServerConnector {
    public:
        using ConnectCallback = consumer<PeerConnectCode, const std::shared_ptr<ionet::PacketSocket>&>;
 
    public:
        virtual ~ServerConnector() = default;
 
    public:
        virtual size_t numActiveConnections() const = 0;
 
    public:
        virtual void connect(const ionet::Node& node, const ConnectCallback& callback) = 0;
 
        virtual void shutdown() = 0;
    };
 
    std::shared_ptr<ServerConnector> CreateServerConnector(
            const std::shared_ptr<thread::IoThreadPool>& pPool,
            const crypto::KeyPair& keyPair,
            const ConnectionSettings& settings);
}}