Method TestConsumerConfig

phxqueue/test/test_config.cpp:304–326

void TestConfig::TestConsumerConfig(const config::ConsumerConfig *consumer_config) {
    comm::proto::Addr expected_addr;
    expected_addr.set_ip("127.0.0.1");
    expected_addr.set_port(8001);
    expected_addr.set_paxos_port(0);

    // GetAllConsumer
    {
        vector<shared_ptr<const config::proto::Consumer> > consumers;
        const int expected_nr_consumer{3};

        assert(comm::RetCode::RET_OK == consumer_config->GetAllConsumer(consumers));
        assert(expected_nr_consumer == consumers.size());
    }

    // GetConsumerByAddr
    {
        shared_ptr<const config::proto::Consumer> consumer;
        assert(comm::RetCode::RET_OK ==
               consumer_config->GetConsumerByAddr(expected_addr, consumer));
        assert(consumer);
    }
}

void TestConfig::TestSchedulerConfig(const config::SchedulerConfig *scheduler_config) {
    comm::proto::Addr expected_addr;