Merge pull request #4688 from alltilla/loki-timestamp-option-string-param

loki: enable setting the timestamp() option with quoted strings

Author: OverOrion

modules/grpc/loki/loki-dest.cpp

@@ -196,11 +196,11 @@ loki_dd_add_label(LogDriver *d, const gchar *name, LogTemplate *value)
   self->cpp->add_label(name, value);
 }
 
-void
-loki_dd_set_timestamp(LogDriver *d, LogMessageTimeStamp t)
+gboolean
+loki_dd_set_timestamp(LogDriver *d, const gchar *t)
 {
   LokiDestDriver *self = (LokiDestDriver *) d;
-  self->cpp->set_timestamp(t);
+  return self->cpp->set_timestamp(t);
 }
 
 void

modules/grpc/loki/loki-dest.h

@@ -38,7 +38,7 @@ LogDriver *loki_dd_new(GlobalConfig *cfg);
 void loki_dd_set_url(LogDriver *d, const gchar *url);
 void loki_dd_set_message_template_ref(LogDriver *d, LogTemplate *message);
 void loki_dd_add_label(LogDriver *d, const gchar *name, LogTemplate *value);
-void loki_dd_set_timestamp(LogDriver *d, LogMessageTimeStamp t);
+gboolean loki_dd_set_timestamp(LogDriver *d, const gchar *t);
 
 GrpcClientCredentialsBuilderW *loki_dd_get_credentials_builder(LogDriver *s);
 

modules/grpc/loki/loki-dest.hpp

@@ -98,9 +98,17 @@ class DestinationDriver final
     this->message = msg;
   }
 
-  void set_timestamp(LogMessageTimeStamp t)
+  bool set_timestamp(const char *t)
   {
-    this->timestamp = t;
+    if (strcasecmp(t, "current") == 0)
+      this->timestamp = LM_TS_PROCESSED;
+    else if (strcasecmp(t, "received") == 0)
+      this->timestamp = LM_TS_RECVD;
+    else if (strcasecmp(t, "msg") == 0)
+      this->timestamp = LM_TS_STAMP;
+    else
+      return false;
+    return true;
   }
 
   void set_keepalive_time(int t)

modules/grpc/loki/loki-grammar.ym

@@ -53,9 +53,6 @@ GrpcClientCredentialsBuilderW *last_grpc_client_credentials_builder;
 %token KW_URL
 %token KW_LABELS
 %token KW_TIMESTAMP
-%token KW_CURRENT
-%token KW_RECEIVED
-%token KW_MSG
 
 %token KW_AUTH
 %token KW_INSECURE
@@ -97,7 +94,11 @@ loki_dest_option
   : KW_URL '(' string ')' { loki_dd_set_url(last_driver, $3); free($3); }
   | KW_KEEP_ALIVE '(' loki_keepalive_options ')'
   | KW_LABELS '(' loki_labels ')'
-  | KW_TIMESTAMP '(' loki_timestamp_enum ')'
+  | KW_TIMESTAMP '(' string ')'
+    {
+      CHECK_ERROR(loki_dd_set_timestamp(last_driver, $3), @1, "Failed to set timestamp(). Valid values are: \"current\", \"received\", \"msg\"");
+      free($3);
+    }
   | KW_TEMPLATE '(' template_name_or_content ')' { loki_dd_set_message_template_ref(last_driver, $3); }
   | KW_AUTH { last_grpc_client_credentials_builder = loki_dd_get_credentials_builder(last_driver); } '(' grpc_client_credentials_option ')'
   | threaded_dest_driver_general_option
@@ -120,12 +121,6 @@ loki_label
     }
   ;
 
-loki_timestamp_enum
-  : KW_CURRENT { loki_dd_set_timestamp(last_driver, LM_TS_PROCESSED); }
-  | KW_RECEIVED { loki_dd_set_timestamp(last_driver, LM_TS_RECVD); }
-  | KW_MSG { loki_dd_set_timestamp(last_driver, LM_TS_STAMP); }
-  ;
-
 loki_keepalive_options
   : loki_keepalive_option loki_keepalive_options
   |

modules/grpc/loki/loki-parser.c

@@ -34,9 +34,6 @@ static CfgLexerKeyword loki_keywords[] =
   { "url", KW_URL },
   { "labels", KW_LABELS },
   { "timestamp", KW_TIMESTAMP },
-  { "current", KW_CURRENT },
-  { "received", KW_RECEIVED },
-  { "msg", KW_MSG },
   { "keep_alive", KW_KEEP_ALIVE },
   { "time", KW_TIME },
   { "timeout", KW_TIMEOUT },

news/other-4688.md

@@ -0,0 +1,6 @@
+`loki()`: The `timestamp()` option now supports quoted strings.
+
+The valid values are the following, with or without quotes, case insensitive:
+  * "current"
+  * "received"
+  * "msg"