pack: add 'epoch_ms' format

Signed-off-by: Jeongki Kim <[email protected]>

Author: jeongki-kim

include/fluent-bit/flb_pack.h

@@ -36,9 +36,10 @@
 #define FLB_PACK_JSON_PRIMITIVE     JSMN_PRIMITIVE
 
 /* Date formats */
-#define FLB_PACK_JSON_DATE_DOUBLE   0
-#define FLB_PACK_JSON_DATE_ISO8601  1
-#define FLB_PACK_JSON_DATE_EPOCH    2
+#define FLB_PACK_JSON_DATE_DOUBLE       0
+#define FLB_PACK_JSON_DATE_ISO8601      1
+#define FLB_PACK_JSON_DATE_EPOCH        2
+#define FLB_PACK_JSON_DATE_EPOCH_MS     3
 
 /* Specific ISO8601 format */
 #define FLB_PACK_JSON_DATE_ISO8601_FMT "%Y-%m-%dT%H:%M:%S"

src/flb_pack.c

@@ -772,6 +772,11 @@ int flb_pack_to_json_date_type(const char *str)
     else if (strcasecmp(str, "epoch") == 0) {
         return FLB_PACK_JSON_DATE_EPOCH;
     }
+    else if (strcasecmp(str, "epoch_ms") == 0 ||
+             strcasecmp(str, "epoch_millis") == 0 ||
+             strcasecmp(str, "epoch_milliseconds") == 0) {
+        return FLB_PACK_JSON_DATE_EPOCH_MS;
+    }
 
     return -1;
 }
@@ -892,6 +897,11 @@ flb_sds_t flb_pack_msgpack_to_json_format(const char *data, uint64_t bytes,
             case FLB_PACK_JSON_DATE_EPOCH:
                 msgpack_pack_uint64(&tmp_pck, (long long unsigned)(tms.tm.tv_sec));
                 break;
+            case FLB_PACK_JSON_DATE_EPOCH_MS:
+                msgpack_pack_uint64(&tmp_pck,
+                                    (long long unsigned)(tms.tm.tv_sec) * 1000 +
+                                    tms.tm.tv_nsec / 1000000);
+                break;
             }
         }