pipederive 0.2.1

Proc macros for data integration app using pipebase framework
Documentation 
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

pub const PROJECT: &str = "project";
pub const PROJECT_INPUT: &str = "project.input";
pub const PROJECT_FROM: &str = "project.from";
pub const PROJECT_EXPR: &str = "project.expr";
pub const PROJECT_ALIAS: &str = "project.alias";
pub const PROJECT_ALIAS_DEFAULT: &str = "a";

pub const FILTER: &str = "filter";
pub const FILTER_PREDICATE: &str = "filter.predicate";
pub const FILTER_ALIAS: &str = "filter.alias";
pub const FILTER_ALIAS_DEFAULT: &str = "a";

pub const FIELD_VISIT: &str = "visit";

pub const HASH: &str = "hash";

pub const ORDER: &str = "order";

pub const CHANNEL_SENDER_SUFFIX: &str = "_tx";
pub const CHANNEL_RECEIVER_SUFFIX: &str = "_rx";

pub const CONFIG_SUFFIX: &str = "_cfg";

pub const CONTEXT_STORE: &str = "cstore";
pub const CONTEXT_STORE_NAME: &str = "cstore.name";
pub const CONTEXT_STORE_CONFIG_TYPE: &str = "cstore.config.ty";
pub const CONTEXT_STORE_CONFIG_PATH: &str = "cstore.config.path";
pub const CONTEXT_STORE_CONFIG_EMPTY_PATH: &str = "";
pub const CONTEXT_STORE_IDENT_SUFFIX: &str = "_c";
pub const CONTEXT_COLLECTOR_IDENT_SUFFIX: &str = "_ctxs";

pub const ERROR_HANDLER: &str = "error";
pub const ERROR_HANDLER_CONFIG_TYPE: &str = "error.config.ty";
pub const ERROR_HANDLER_CONFIG_PATH: &str = "error.config.path";
pub const ERROR_HANDLER_DEFAULT_IDENT: &str = "_error_handler";
pub const ERROR_HANDLER_DEFAULT_RX: &str = "_erx";
pub const ERROR_HANDLER_DEFAULT_TX: &str = "_etx";
pub const ERROR_HANDLER_CHANNEL_BUFFER: &str = "error.buffer";
pub const ERROR_HANDLER_CHANNEL_DEFAULT_BUFFER: usize = 1024;
pub const ERROR_HANDLER_CHANNEL_DEFAULT_TYPE: &str = "PipeError";

pub const BOOTSTRAP_PIPE: &str = "pipe";
pub const BOOTSTRAP_PIPE_NAME: &str = "pipe.name";
pub const BOOTSTRAP_PIPE_TYPE: &str = "pipe.ty";
pub const BOOTSTRAP_PIPE_UPSTREAM: &str = "pipe.upstream";
pub const BOOTSTRAP_PIPE_UPSTREAM_NAME_SEP: &str = ",";
pub const BOOTSTRAP_PIPE_CONFIG_TYPE: &str = "pipe.config.ty";
pub const BOOTSTRAP_PIPE_CONFIG_PATH: &str = "pipe.config.path";
pub const BOOTSTRAP_PIPE_CONFIG_EMPTY_PATH: &str = "";
pub const BOOTSTRAP_PIPE_OUTPUT: &str = "pipe.output";
pub const BOOTSTRAP_PIPE_CHANNEL_BUFFER: &str = "pipe.buffer";
pub const BOOTSTRAP_PIPE_CHANNEL_DEFAULT_BUFFER: usize = 1024;
pub const BOOTSTRAP_MODULE: &str = "bootstrap";
pub const BOOTSTRAP_FUNCTION: &str = "bootstrap";
pub const BOOTSTRAP_PIPE_IDENT_SUFFIX: &str = "_p";
pub const BOOTSTRAP_PIPE_CHANNELS_SUFFIX: &str = "_chs";

pub const MACRO_CHANNEL: &str = "channel!";
pub const MACRO_RUN_PIPE: &str = "run_pipe!";
pub const MACRO_JOIN_PIPES: &str = "join_pipes!";
pub const MACRO_PIPE_CHANNELS: &str = "pipe_channels!";
pub const MACRO_ERROR_HANDLER: &str = "error_handler!";
pub const MACRO_SUBSCRIBE_ERROR_HANDLER: &str = "subscribe_error_handler!";
pub const MACRO_RUN_ERROR_HANDLER: &str = "run_error_handler!";
pub const MACRO_CONTEXT_STORE: &str = "cstore!";
pub const MACRO_RUN_CONTEXT_STORE: &str = "run_cstore!";
pub const MACRO_CONFIG: &str = "config!";
pub const MACRO_COLLECT_CONTEXT: &str = "collect_context!";

pub const AGGREGATE_SUM: &str = "agg.sum";
pub const AGGREGATE_TOP: &str = "agg.top";
pub const AGGREGATE_AVG_F32: &str = "agg.avgf32";
pub const AGGREGATE_AVG_F32_DEFAULT_TYPE: &str = "Averagef32";
pub const AGGREGATE_COUNT32: &str = "agg.count32";
pub const AGGREGATE_COUNT32_DEFAULT_TYPE: &str = "Count32";

pub const GROUP: &str = "group";

pub const EQUAL: &str = "equal";

pub const LEFT: &str = "left";
pub const RIGHT: &str = "right";

pub const RENDER_TEMPLATE: &str = "render.template";
pub const RENDER_POSITION: &str = "render.pos";
pub const RENDER_EXPR: &str = "render.expr";

pub const CONVERT_INPUT: &str = "convert.input";
pub const CONVERT_FROM: &str = "convert.from";

pub const ATTRIBUTE_ALIAS: &str = "attribute.alias";