Packages

erlkaf

2.1.1
2.2.1 2.2.0 2.1.9 2.1.8 2.1.7 2.1.6 2.1.5 2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.0.9 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3

erlkaf - Erlang Kafka library based on librdkafka

HexDocs

Current section

Files

Jump to
Readme
30 Versions
3 Dependencies
Dependants
Files
Activity
erlkaf c_src erlkaf_consumer.h
Raw

c_src/erlkaf_consumer.h 

#ifndef C_SRC_ERLKAF_CONSUMER_H_

#define C_SRC_ERLKAF_CONSUMER_H_



#include "erl_nif.h"



void enif_queue_free(ErlNifEnv* env, void* obj);

void enif_consumer_free(ErlNifEnv* env, void* obj);

ERL_NIF_TERM enif_consumer_new(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]);

ERL_NIF_TERM enif_consumer_partition_revoke_completed(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]);

ERL_NIF_TERM enif_consumer_queue_poll(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]);

ERL_NIF_TERM enif_consumer_queue_cleanup(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]);

ERL_NIF_TERM enif_consumer_offset_store(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]);

ERL_NIF_TERM enif_consumer_cleanup(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv[]);



#endif  // C_SRC_ERLKAF_CONSUMER_H_