-
Notifications
You must be signed in to change notification settings - Fork 24
/
Copy pathdafka_classes.h
125 lines (106 loc) · 3.9 KB
/
dafka_classes.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
/* =========================================================================
dafka_classes - private header file
Copyright (c) the Contributors as noted in the AUTHORS file. This
file is part of DAFKA, a decentralized distributed streaming
platform: http://zeromq.org.
This Source Code Form is subject to the terms of the Mozilla Public
License, v. 2.0. If a copy of the MPL was not distributed with this
file, You can obtain one at http://mozilla.org/MPL/2.0/.
################################################################################
# THIS FILE IS 100% GENERATED BY ZPROJECT; DO NOT EDIT EXCEPT EXPERIMENTALLY #
# Read the zproject/README.md for information about making permanent changes. #
################################################################################
=========================================================================
*/
#ifndef DAFKA_CLASSES_H_INCLUDED
#define DAFKA_CLASSES_H_INCLUDED
// Platform definitions, must come first
#include "platform.h"
// Asserts check the invariants of methods. If they're not
// fulfilled the program should fail fast. Therefore enforce them!
#ifdef NDEBUG
#undef NDEBUG
#include <assert.h>
#define NDEBUG
#else
#include <assert.h>
#endif
// External API
#include "../include/dafka.h"
// Private external dependencies
// Opaque class structures to allow forward references
#ifndef DAFKA_UNACKED_LIST_T_DEFINED
typedef struct _dafka_unacked_list_t dafka_unacked_list_t;
#define DAFKA_UNACKED_LIST_T_DEFINED
#endif
#ifndef DAFKA_FETCH_FILTER_T_DEFINED
typedef struct _dafka_fetch_filter_t dafka_fetch_filter_t;
#define DAFKA_FETCH_FILTER_T_DEFINED
#endif
#ifndef DAFKA_MSG_KEY_T_DEFINED
typedef struct _dafka_msg_key_t dafka_msg_key_t;
#define DAFKA_MSG_KEY_T_DEFINED
#endif
#ifndef DAFKA_HEAD_KEY_T_DEFINED
typedef struct _dafka_head_key_t dafka_head_key_t;
#define DAFKA_HEAD_KEY_T_DEFINED
#endif
#ifndef DAFKA_UTIL_T_DEFINED
typedef struct _dafka_util_t dafka_util_t;
#define DAFKA_UTIL_T_DEFINED
#endif
#ifndef DAFKA_CONSUMER_STEP_DEFS_T_DEFINED
typedef struct _dafka_consumer_step_defs_t dafka_consumer_step_defs_t;
#define DAFKA_CONSUMER_STEP_DEFS_T_DEFINED
#endif
#ifndef DAFKA_PRODUCER_STEP_DEFS_T_DEFINED
typedef struct _dafka_producer_step_defs_t dafka_producer_step_defs_t;
#define DAFKA_PRODUCER_STEP_DEFS_T_DEFINED
#endif
#ifndef DAFKA_STORE_READER_T_DEFINED
typedef struct _dafka_store_reader_t dafka_store_reader_t;
#define DAFKA_STORE_READER_T_DEFINED
#endif
#ifndef DAFKA_STORE_WRITER_T_DEFINED
typedef struct _dafka_store_writer_t dafka_store_writer_t;
#define DAFKA_STORE_WRITER_T_DEFINED
#endif
#ifndef DAFKA_TEST_PEER_T_DEFINED
typedef struct _dafka_test_peer_t dafka_test_peer_t;
#define DAFKA_TEST_PEER_T_DEFINED
#endif
// Extra headers
// Internal API
#include "dafka_unacked_list.h"
#include "dafka_fetch_filter.h"
#include "dafka_msg_key.h"
#include "dafka_head_key.h"
#include "dafka_util.h"
#include "dafka_consumer_step_defs.h"
#include "dafka_producer_step_defs.h"
#include "dafka_store_reader.h"
#include "dafka_store_writer.h"
#include "dafka_test_peer.h"
// *** To avoid double-definitions, only define if building without draft ***
#ifndef DAFKA_BUILD_DRAFT_API
// *** Draft method, defined for internal use only ***
// Self test of this class.
DAFKA_PRIVATE void
dafka_unacked_list_test (bool verbose);
// *** Draft method, defined for internal use only ***
// Self test of this class.
DAFKA_PRIVATE void
dafka_util_test (bool verbose);
// *** Draft method, defined for internal use only ***
// Self test of this class.
DAFKA_PRIVATE void
dafka_consumer_step_defs_test (bool verbose);
// *** Draft method, defined for internal use only ***
// Self test of this class.
DAFKA_PRIVATE void
dafka_producer_step_defs_test (bool verbose);
// Self test for private classes
DAFKA_PRIVATE void
dafka_private_selftest (bool verbose, const char *subtest);
#endif // DAFKA_BUILD_DRAFT_API
#endif