Packages

erlkaf

2.1.2
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_nif.h
Raw

c_src/erlkaf_nif.h 

#ifndef C_SRC_ERLKAF_NIF_H_

#define C_SRC_ERLKAF_NIF_H_



#include "erl_nif.h"



class QueueCallbacksDispatcher;



struct atoms

{

    ERL_NIF_TERM atomOk;

    ERL_NIF_TERM atomUndefined;

    ERL_NIF_TERM atomError;

    ERL_NIF_TERM atomTrue;

    ERL_NIF_TERM atomFalse;

    ERL_NIF_TERM atomBadArg;

    ERL_NIF_TERM atomOptions;

    ERL_NIF_TERM atomMessage;

    ERL_NIF_TERM atomBrokers;

    ERL_NIF_TERM atomTopics;

    ERL_NIF_TERM atomPartitions;

    ERL_NIF_TERM atomId;

    ERL_NIF_TERM atomHost;

    ERL_NIF_TERM atomPort;

    ERL_NIF_TERM atomName;

    ERL_NIF_TERM atomLeader;

    ERL_NIF_TERM atomReplicas;

    ERL_NIF_TERM atomIsrs;

    ERL_NIF_TERM atomDeliveryReport;

    ERL_NIF_TERM atomLogEvent;

    ERL_NIF_TERM atomAssignPartition;

    ERL_NIF_TERM atomRevokePartition;

    ERL_NIF_TERM atomStats;

    ERL_NIF_TERM atomClientStopped;

    ERL_NIF_TERM atomNotAvailable;

    ERL_NIF_TERM atomCreateTime;

    ERL_NIF_TERM atomLogAppendTime;

};



struct erlkaf_data

{

    ErlNifResourceType* res_producer;

    ErlNifResourceType* res_consumer;

    ErlNifResourceType* res_queue;

    QueueCallbacksDispatcher* notifier_;

};



extern atoms ATOMS;



#endif  // C_SRC_ERLKAF_NIF_H_