| /*** |
| * Copyright 2020 HAProxy Technologies |
| * |
| * This file is part of the HAProxy OpenTracing filter. |
| * |
| * This program is free software; you can redistribute it and/or |
| * modify it under the terms of the GNU General Public License |
| * as published by the Free Software Foundation; either version 2 |
| * of the License, or (at your option) any later version. |
| * |
| * This program is distributed in the hope that it will be useful, |
| * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| * GNU General Public License for more details. |
| * |
| * You should have received a copy of the GNU General Public License |
| * along with this program; if not, write to the Free Software |
| * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. |
| */ |
| #ifndef _OPENTRACING_EVENT_H_ |
| #define _OPENTRACING_EVENT_H_ |
| |
| /* |
| * This must be defined in order for macro FLT_OT_EVENT_DEFINES |
| * and structure flt_ot_event_data to have the correct contents. |
| */ |
| #define AN_REQ_NONE 0 |
| #define AN_REQ_CLIENT_SESS_START 0 |
| #define AN_REQ_SERVER_UNAVAILABLE 0 |
| #define AN_REQ_CLIENT_SESS_END 0 |
| #define AN_RES_SERVER_SESS_START 0 |
| #define AN_RES_SERVER_SESS_END 0 |
| #define SMP_VAL_FE_ 0 |
| #define SMP_VAL_BE_ 0 |
| |
| /* |
| * Event names are selected to be somewhat compatible with the SPOE filter, |
| * from which the following names are taken: |
| * - on-client-session -> on-client-session-start |
| * - on-frontend-tcp-request |
| * - on-frontend-http-request |
| * - on-backend-tcp-request |
| * - on-backend-http-request |
| * - on-server-session -> on-server-session-start |
| * - on-tcp-response |
| * - on-http-response |
| * |
| * FLT_OT_EVENT_NONE is used as an index for 'ot-scope' sections that do not |
| * have an event defined. The 'ot-scope' sections thus defined can be used |
| * within the 'ot-group' section. |
| * |
| * A description of the macro arguments can be found in the structure |
| * flt_ot_event_data definition |
| */ |
| #define FLT_OT_EVENT_DEFINES \ |
| FLT_OT_EVENT_DEF( NONE, REQ, , , 0, "") \ |
| FLT_OT_EVENT_DEF( CLIENT_SESS_START, REQ, CON_ACC, , 1, "on-client-session-start") \ |
| FLT_OT_EVENT_DEF( INSPECT_FE, REQ, REQ_CNT, , 1, "on-frontend-tcp-request") \ |
| FLT_OT_EVENT_DEF( WAIT_HTTP, REQ, , , 1, "on-http-wait-request") \ |
| FLT_OT_EVENT_DEF( HTTP_BODY, REQ, , , 1, "on-http-body-request") \ |
| FLT_OT_EVENT_DEF( HTTP_PROCESS_FE, REQ, HRQ_HDR, , 1, "on-frontend-http-request") \ |
| FLT_OT_EVENT_DEF( SWITCHING_RULES, REQ, , , 1, "on-switching-rules-request") \ |
| FLT_OT_EVENT_DEF( INSPECT_BE, REQ, REQ_CNT, REQ_CNT, 1, "on-backend-tcp-request") \ |
| FLT_OT_EVENT_DEF( HTTP_PROCESS_BE, REQ, HRQ_HDR, HRQ_HDR, 1, "on-backend-http-request") \ |
| /* FLT_OT_EVENT_DEF( HTTP_TARPIT, REQ, , , 1, "on-http-tarpit-request") */ \ |
| FLT_OT_EVENT_DEF( SRV_RULES, REQ, , , 1, "on-process-server-rules-request") \ |
| FLT_OT_EVENT_DEF( HTTP_INNER, REQ, , , 1, "on-http-process-request") \ |
| FLT_OT_EVENT_DEF( PRST_RDP_COOKIE, REQ, , , 1, "on-tcp-rdp-cookie-request") \ |
| FLT_OT_EVENT_DEF( STICKING_RULES, REQ, , , 1, "on-process-sticking-rules-request") \ |
| FLT_OT_EVENT_DEF( CLIENT_SESS_END, REQ, , , 0, "on-client-session-end") \ |
| FLT_OT_EVENT_DEF(SERVER_UNAVAILABLE, REQ, , , 0, "on-server-unavailable") \ |
| \ |
| FLT_OT_EVENT_DEF( SERVER_SESS_START, RES, , SRV_CON, 0, "on-server-session-start") \ |
| FLT_OT_EVENT_DEF( INSPECT, RES, RES_CNT, RES_CNT, 0, "on-tcp-response") \ |
| FLT_OT_EVENT_DEF( WAIT_HTTP, RES, , , 1, "on-http-wait-response") \ |
| FLT_OT_EVENT_DEF( STORE_RULES, RES, , , 1, "on-process-store-rules-response") \ |
| FLT_OT_EVENT_DEF( HTTP_PROCESS_BE, RES, HRS_HDR, HRS_HDR, 1, "on-http-response") \ |
| FLT_OT_EVENT_DEF( SERVER_SESS_END, RES, , , 0, "on-server-session-end") |
| |
| enum FLT_OT_EVENT_enum { |
| #define FLT_OT_EVENT_DEF(a,b,c,d,e,f) FLT_OT_EVENT_##b##_##a, |
| FLT_OT_EVENT_DEFINES |
| FLT_OT_EVENT_MAX |
| #undef FLT_OT_EVENT_DEF |
| }; |
| |
| enum FLT_OT_EVENT_SAMPLE_enum { |
| FLT_OT_EVENT_SAMPLE_TAG = 0, |
| FLT_OT_EVENT_SAMPLE_LOG, |
| FLT_OT_EVENT_SAMPLE_BAGGAGE, |
| }; |
| |
| struct flt_ot_event_data { |
| uint an_bit; /* Used channel analyser. */ |
| uint smp_opt_dir; /* Fetch direction (request/response). */ |
| uint smp_val_fe; /* Valid FE fetch location. */ |
| uint smp_val_be; /* Valid BE fetch location. */ |
| bool flag_http_inject; /* Span context injection allowed. */ |
| const char *name; /* Filter event name. */ |
| }; |
| |
| struct flt_ot_conf_scope; |
| |
| |
| extern const struct flt_ot_event_data flt_ot_event_data[FLT_OT_EVENT_MAX]; |
| |
| |
| int flt_ot_scope_run(struct stream *s, struct filter *f, struct channel *chn, struct flt_ot_conf_scope *conf_scope, const struct timespec *ts, uint dir, char **err); |
| int flt_ot_event_run(struct stream *s, struct filter *f, struct channel *chn, int event, char **err); |
| |
| #endif /* _OPENTRACING_EVENT_H_ */ |
| |
| /* |
| * Local variables: |
| * c-indent-level: 8 |
| * c-basic-offset: 8 |
| * End: |
| * |
| * vi: noexpandtab shiftwidth=8 tabstop=8 |
| */ |