Method SetUp

src/apiserver/api_server_test.cc:36–82

        return instance;
    }
    virtual void SetUp() {
        std::cout << "Environment SetUp!" << std::endl;
        ::hybridse::vm::Engine::InitializeGlobalLLVM();
        FLAGS_zk_session_timeout = 100000;

        mc.reset(new sdk::MiniCluster(6181));
        ASSERT_TRUE(mc->SetUp()) << "Fail to set up mini cluster";

        queue_svc.reset(new APIServerImpl);
        sdk::ClusterOptions cluster_options;
        cluster_options.zk_cluster = mc->GetZkCluster();
        cluster_options.zk_path = mc->GetZkPath();
        ASSERT_TRUE(queue_svc->Init(cluster_options));

        // Http server set up
        ASSERT_TRUE(server.AddService(queue_svc.get(), brpc::SERVER_DOESNT_OWN_SERVICE, "/* => Process") == 0)
            << "Fail to add queue_svc";

        // Start the server.
        int api_server_port = 8010;
        brpc::ServerOptions server_options;
        // options.idle_timeout_sec = FLAGS_idle_timeout_s;
        ASSERT_TRUE(server.Start(api_server_port, &server_options) == 0) << "Fail to start HttpServer";

        sdk::SQLRouterOptions sql_opt;
        sql_opt.session_timeout = 30000;
        sql_opt.zk_cluster = mc->GetZkCluster();
        sql_opt.zk_path = mc->GetZkPath();
        //        sql_opt.enable_debug = true;
        cluster_remote = sdk::NewClusterSQLRouter(sql_opt);
        hybridse::sdk::Status status;
        ASSERT_TRUE(cluster_remote != nullptr);

        db = "api_server_test";
        cluster_remote->DropDB(db, &status);
        cluster_remote->CreateDB(db, &status);
        std::vector<std::string> dbs;
        ASSERT_TRUE(cluster_remote->ShowDB(&dbs, &status));
        ASSERT_TRUE(std::find(dbs.begin(), dbs.end(), db) != dbs.end());

        brpc::ChannelOptions options;
        options.protocol = "http";
        options.timeout_ms = 2000 /*milliseconds*/;
        options.max_retry = 3;
        ASSERT_TRUE(http_channel.Init("http://127.0.0.1:", api_server_port, &options) == 0)
            << "Fail to initialize http channel";
    }

    virtual void TearDown() {
        std::cout << "Environment TearDown!" << std::endl;