1 files changed, 99 insertions, 0 deletions
diff --git a/fluent-bit/src/record_accessor/ra.y b/fluent-bit/src/record_accessor/ra.y
new file mode 100644
index 000000000..9c4e25b87
--- /dev/null
+++ b/fluent-bit/src/record_accessor/ra.y
@@ -0,0 +1,99 @@
+%define api.pure full
+%name-prefix "flb_ra_"
+
+%parse-param { struct flb_ra_parser *rp };
+%parse-param { const char *str };
+%lex-param   { void *scanner }
+%parse-param { void *scanner }
+
+%{
+#include <stdio.h>
+#include <stdlib.h>
+
+#include <fluent-bit/flb_info.h>
+#include <fluent-bit/flb_mem.h>
+#include <fluent-bit/flb_log.h>
+#include <fluent-bit/flb_slist.h>
+#include <fluent-bit/record_accessor/flb_ra_parser.h>
+
+#include "ra_parser.h"
+#include "ra_lex.h"
+
+extern int flb_ra_lex();
+
+void flb_ra_error(struct flb_ra_parser *rp, const char *query, void *scanner,
+                  const char *str)
+{
+    flb_error("[record accessor] %s at '%s'", str, query);
+}
+
+%} /* EOF C code */
+
+
+/* Known Tokens (refer to sql.l) */
+
+/* Keywords */
+%token IDENTIFIER STRING INTEGER
+
+%define parse.error verbose
+
+/* Union and field types */
+%union
+{
+    int integer;
+    float fval;
+    char *string;
+    struct flb_sp_cmd *cmd;
+    struct flb_exp *expression;
+}
+
+%type <string>     IDENTIFIER
+%type <integer>    INTEGER
+%type <string>     STRING
+%type <string>     record_key
+
+%destructor { flb_free ($$); } IDENTIFIER
+%destructor { flb_free ($$); } STRING
+
+%% /* rules section */
+
+statements: record_accessor
+
+/* Parse record accessor string: $key, $key['x'], $key['x'][...] */
+record_accessor: record_key
+      record_key:
+                  '$' IDENTIFIER
+                  {
+                    void *key;
+
+                    rp->type = FLB_RA_PARSER_KEYMAP;
+                    key = flb_ra_parser_key_add(rp, $2);
+                    if (key) {
+                      rp->key = key;
+                    }
+                    flb_free($2);
+                  }
+                  |
+                  '$' IDENTIFIER record_subkey
+                  {
+                    void *key;
+                    rp->type = FLB_RA_PARSER_KEYMAP;
+                    key = flb_ra_parser_key_add(rp, $2);
+                    if (key) {
+                      rp->key = key;
+                    }
+                    flb_free($2);
+                  }
+      record_subkey: record_subkey record_subkey_index | record_subkey_index
+      record_subkey_index:
+                  '[' STRING ']'
+                  {
+                    flb_ra_parser_subentry_add_string(rp, $2);
+                    flb_free($2);
+                  }
+                  |
+                  '[' INTEGER ']'
+                  {
+                    flb_ra_parser_subentry_add_array_id(rp, $2);
+                  }
+                  ;