Packages

kflow

1.1.0
1.1.0 1.0.0

Fault-tolerant dataflow DSL

HexDocs

Current section

Files

Jump to
Readme
2 Versions
9 Dependencies
0 Dependants
Files
Activity
kflow src testbed kflow_test_macros.hrl
Raw

src/testbed/kflow_test_macros.hrl 

-ifndef(KFLOW_TEST_MACROS_HRL).

-define(KFLOW_TEST_MACROS_HRL, true).



-ifndef(SNK_COLLECTOR).

-define(SNK_COLLECTOR, true). % enable snabbkaffe test macros

-endif.

-include_lib("kflow/include/kflow.hrl").

-include_lib("kafka_protocol/include/kpro.hrl").

-include_lib("hut/include/hut.hrl").

-include_lib("snabbkaffe/include/snabbkaffe.hrl").

-include_lib("stdlib/include/assert.hrl").



%%====================================================================

%% Macros

%%====================================================================



-define(test_client, kflow_test_client).

-define(KAFKA_HOST, "localhost").

-define(KAFKA_PORT, 9092).



-define(topic(TestCase), list_to_binary(atom_to_list(TestCase))).

-define(topic, ?topic(?FUNCTION_NAME)).



-define(group_id(TestCase), list_to_binary(atom_to_list(TestCase) ++ "_grp")).

-define(group_id, ?group_id(?FUNCTION_NAME)).



-endif.