http_server/health: Implement throughput health check

Signed-off-by: Thiago Padilha <[email protected]>

Author: tchrono

include/fluent-bit/flb_config.h

@@ -171,6 +171,11 @@ struct flb_config {
     int hc_errors_count;               /* health check error counts as unhealthy*/
     int hc_retry_failure_count;        /* health check retry failures count as unhealthy*/
     int health_check_period;           /* period by second for health status check */
+    int hc_throughput;                 /* if throughput check is enabled */
+    char *hc_throughput_input_plugins; /* which input plugins should be considered for checking throughput */
+    char *hc_throughput_output_plugins;/* which output plugins should be considered for checking throughput */
+    double hc_throughput_ratio_threshold; /* output/input ratio threshold to consider a failure */
+    int hc_throughput_min_failures; /* minimum amount of failures to cause error condition */
 #endif
 
     /*
@@ -298,6 +303,11 @@ enum conf_type {
 #define FLB_CONF_STR_HC_ERRORS_COUNT                        "HC_Errors_Count"
 #define FLB_CONF_STR_HC_RETRIES_FAILURE_COUNT               "HC_Retry_Failure_Count"
 #define FLB_CONF_STR_HC_PERIOD                              "HC_Period"
+#define FLB_CONF_STR_HC_THROUGHPUT                          "HC_Throughput"
+#define FLB_CONF_STR_HC_THROUGHPUT_IN_PLUGINS               "HC_Throughput_Input_Plugins"
+#define FLB_CONF_STR_HC_THROUGHPUT_OUT_PLUGINS              "HC_Throughput_Output_Plugins"
+#define FLB_CONF_STR_HC_THROUGHPUT_RATIO_THRESHOLD          "HC_Throughput_Ratio_Threshold"
+#define FLB_CONF_STR_HC_THROUGHPUT_MIN_FAILURES             "HC_Throughput_Min_Failures"
 #endif /* !FLB_HAVE_HTTP_SERVER */
 
 /* DNS */

src/flb_config.c

@@ -106,6 +106,25 @@ struct flb_service_config service_configs[] = {
      FLB_CONF_TYPE_INT,
      offsetof(struct flb_config, health_check_period)},
 
+    {FLB_CONF_STR_HC_THROUGHPUT,
+     FLB_CONF_TYPE_BOOL,
+     offsetof(struct flb_config, hc_throughput)},
+
+    {FLB_CONF_STR_HC_THROUGHPUT_IN_PLUGINS,
+     FLB_CONF_TYPE_STR,
+     offsetof(struct flb_config, hc_throughput_input_plugins)},
+
+    {FLB_CONF_STR_HC_THROUGHPUT_OUT_PLUGINS,
+     FLB_CONF_TYPE_STR,
+     offsetof(struct flb_config, hc_throughput_output_plugins)},
+
+    {FLB_CONF_STR_HC_THROUGHPUT_RATIO_THRESHOLD,
+     FLB_CONF_TYPE_DOUBLE,
+     offsetof(struct flb_config, hc_throughput_ratio_threshold)},
+
+    {FLB_CONF_STR_HC_THROUGHPUT_MIN_FAILURES,
+     FLB_CONF_TYPE_INT,
+     offsetof(struct flb_config, hc_throughput_min_failures)},
 #endif
     /* DNS*/
     {FLB_CONF_DNS_MODE,