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
|
/*
* Copyright 2013-2018 Fabian Groffen
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef _CONFFILE_H
#define _CONFFILE_H 1
#include "server.h"
#include "aggregator.h"
#include "consistent-hash.h"
#include "allocator.h"
#include "receptor.h"
#define GRAPHITE_PORT 2003
enum clusttype {
BLACKHOLE, /* /dev/null-like destination */
GROUP, /* pseudo type to create a matching tree */
AGGRSTUB, /* pseudo type to have stub matches for aggregation returns */
STATSTUB, /* pseudo type to have stub matches for collector returns */
VALIDATION, /* pseudo type to perform additional data validation */
FORWARD,
FILELOG, /* like forward, write metric to file */
FILELOGIP, /* like forward, write ip metric to file */
CARBON_CH, /* original carbon-relay.py consistent-hash */
FNV1A_CH, /* FNV1a-based consistent-hash */
JUMP_CH, /* jump consistent hash with fnv1a input */
ANYOF, /* FNV1a-based hash, but with backup by others */
FAILOVER, /* ordered attempt delivery list */
AGGREGATION,
REWRITE
};
typedef struct _servers {
server *server;
int refcnt;
struct _servers *next;
} servers;
typedef struct {
unsigned char repl_factor;
ch_ring *ring;
servers *servers;
} chashring;
typedef struct {
unsigned short count;
server **servers;
servers *list;
} serverlist;
typedef struct _validate {
struct _route *rule;
enum { VAL_LOG, VAL_DROP } action;
} validate;
typedef struct _cluster {
char *name;
enum clusttype type;
union {
chashring *ch;
servers *forward;
serverlist *anyof;
aggregator *aggregation;
struct _route *routes;
char *replacement;
struct _validate *validation;
} members;
struct _cluster *next;
} cluster;
typedef struct _destinations {
cluster *cl;
struct _destinations *next;
} destinations;
typedef struct _route {
char *pattern; /* original regex input, used for printing only */
regex_t *rule; /* regex per worker on metric, only if type == REGEX */
size_t nmatch; /* number of match groups */
char *strmatch; /* string to search for if type not REGEX or MATCHALL */
destinations *dests; /* where matches should go */
char *masq; /* when set, what to feed to the hashfunc when routing */
char stop:1; /* whether to continue matching rules after this one */
enum {
MATCHALL, /* the '*', don't do anything, just match everything */
REGEX, /* a regex match */
CONTAINS, /* find string occurrence */
STARTS_WITH, /* metric must start with string */
ENDS_WITH, /* metric must end with string */
MATCHES /* metric matches string exactly */
} matchtype; /* how to interpret the pattern */
struct _route *next;
} route;
void router_yyerror(void *locp, void *, router *r, allocator *ra, allocator *pa, const char *msg);
char *router_validate_address(router *rtr, char **retip, int *retport, void **retsaddr, void **rethint, char *ip, con_proto proto);
char *router_validate_path(router *rtr, char *path);
char *router_validate_expression(router *rtr, route **retr, char *pat);
char *router_validate_cluster(router *rtr, cluster **retcl, char *cluster);
char *router_add_server(router *ret, char *ip, int port, char *inst, con_type type, con_trnsp transport, con_proto proto, struct addrinfo *saddrs, struct addrinfo *hint, char useall, cluster *cl);
char *router_add_cluster(router *r, cluster *cl);
char *router_add_route(router *r, route *rte);
char *router_add_aggregator(router *rtr, aggregator *a);
char *router_add_stubroute(router *rtr, enum clusttype type, cluster *w, destinations *dw);
char *router_add_listener(router *rtr, con_type ltype, con_trnsp trnsp, char *pemcert, con_proto ctype, char *ip, int port, struct addrinfo *saddrs);
char *router_set_statistics(router *rtr, destinations *dsts);
char *router_set_collectorvals(router *rtr, int val, char *prefix, col_mode m);
#endif
|
