view release on metacpan or  search on metacpan

src/EV__Kafka.xs  view on Meta::CPAN

        /* allow_auto_topic_creation (v4+) */
        if (ver >= 4)
            kf_buf_append_i8(&body, 1);

        conn_send_request(aTHX_ self, API_METADATA, ver, &body, cb, 0, 0);
        kf_buf_free(&body);
    }

void
api_versions(EV::Kafka::Conn self)
    PPCODE:
    {
        if (!self->api_versions_known)
            XSRETURN_UNDEF;

        HV *hv = newHV();
        int i;
        for (i = 0; i < API_VERSIONS_MAX_KEY; i++) {
            if (self->api_versions[i] >= 0) {
                char key[8];
                int klen = snprintf(key, sizeof(key), "%d", i);

src/EV__Kafka.xs  view on Meta::CPAN

    {
        STRLEN len;
        const char *data = SvPV(data_sv, len);
        RETVAL = crc32c(data, len);
    }
    OUTPUT:
        RETVAL

void
_error_name(int code)
    PPCODE:
    {
        const char *name = NULL;
        switch (code) {
            case  0: name = "NONE"; break;
            case  1: name = "OFFSET_OUT_OF_RANGE"; break;
            case  2: name = "CORRUPT_MESSAGE"; break;
            case  3: name = "UNKNOWN_TOPIC_OR_PARTITION"; break;
            case  5: name = "LEADER_NOT_AVAILABLE"; break;
            case  6: name = "NOT_LEADER_OR_FOLLOWER"; break;
            case  7: name = "REQUEST_TIMED_OUT"; break;