Method Run

test/brpc_redis_cluster_unittest.cpp:185–195

class AskingHandler : public brpc::RedisCommandHandler {
public:
    brpc::RedisCommandHandlerResult Run(brpc::RedisConnContext* ctx,
                                        const std::vector<butil::StringPiece>& /*args*/,
                                        brpc::RedisReply* output,
                                        bool /*flush_batched*/) override {
        Session* s = GetOrCreateSession(ctx);
        if (s != NULL) {
            s->asking = true;
        }
        output->SetStatus("OK");
        return brpc::REDIS_CMD_HANDLED;
    }
};

class ClusterCommandHandler : public brpc::RedisCommandHandler {