Function RedisGearsPy_ExportRequirement

plugins/python/redisgears_python.c:6580–6633

}

static int RedisGearsPy_ExportRequirement(RedisModuleCtx *ctx, RedisModuleString **argv, int argc){
    if(argc != 2){
        return RedisModule_WrongArity(ctx);
    }

    const char* reqName = RedisModule_StringPtrLen(argv[1], NULL);

    // Notice that this increase the requirement ref count so we must free it as the end.
    PythonRequirementCtx* req = PythonRequirementCtx_Get(reqName);

    if(!req){
        RedisModule_ReplyWithError(ctx, "requirement does not exists");
        return REDISMODULE_OK;
    }

    Gears_Buffer* buff = Gears_BufferCreate();
    Gears_BufferWriter bw;
    Gears_BufferWriterInit(&bw, buff);
    char* err = NULL;
    if(PythonRequirement_Serialize(req, &bw, &err) != REDISMODULE_OK){
        PythonRequirementCtx_Free(req);
        Gears_BufferFree(buff);
        if(!err){
            err = RG_STRDUP("Failed serializing requirement");
        }
        RedisModule_ReplyWithError(ctx, err);
        RG_FREE(err);
        return REDISMODULE_OK;
    }

    RedisModule_ReplyWithArray(ctx, 2);

    RedisGearsPy_SendReqMetaData(ctx, req);

    RedisModule_ReplyWithArray(ctx, REDISMODULE_POSTPONED_ARRAY_LEN);

#define BULK_LEN (1024*1024*10); // 10 MB
    int maxBulKLen = BULK_LEN;

    size_t currPos = 0 ;
    size_t arrayLen = 0;
    while(currPos < buff->size){
        size_t currLen = MIN(maxBulKLen, (buff->size - currPos));
        RedisModule_ReplyWithStringBuffer(ctx, buff->buff + currPos, currLen);
        currPos += currLen;
        ++arrayLen;
    }

    RedisModule_ReplySetArrayLength(ctx, arrayLen);

    Gears_BufferFree(buff);
    PythonRequirementCtx_Free(req);
    return REDISMODULE_OK;
}

static int RedisGearsPy_Stats(RedisModuleCtx *ctx, RedisModuleString **argv, int argc){
	RedisModule_ReplyWithArray(ctx, 6);