README.md 3.4 KB

Introduction

The parser will be used to process streaming and plugins input as well as metadata

Usage

  1. Define a structure that will be used to share user state across calls
  2. Initialize the parser using parser_init
  3. Register keywords and associated callback function using parser_add_keyword
  4. Register actions on the keywords
  5. Start a loop until EOF
    1. Fetch the next line using parser_next
    2. Process the line using parser_action
      1. The registered callbacks are executed to parse the input
      2. The registered action for the callback is called for processing
  6. Release the parser using parser_destroy
  7. Release the user structure

Functions


parse_init(RRDHOST *host, void *user, void *input, int flags)

Initialize an internal parser with the specified user defined data structure that will be shared across calls.

Input

  • Host
    • The host this parser will be dealing with. For streaming with SSL enabled for this host
  • user
    • User defined structure that is passed in all the calls
  • input
    • Where the parser will get the input from
  • flags
    • flags to define processing on the input

Output

  • A parser structure

parse_push(PARSER *parser, char *line)

Push a new line for processing

Input

  • parser
    • The parser object as returned by the parser_init
  • line
    • The new line to process

Output

  • The line will be injected into the stream and will be the next one to be processed

Returns

  • 0 line added
  • 1 error detected

parse_add_keyword(PARSER *parser, char *keyword, keyword_function callback_function)

The function will add callbacks for keywords. The callback function is defined as

typedef PARSER_RC (*keyword_function)(char **, void *);

Input

  • parser
    • The parser object as returned by the parser_init
  • keyword
    • The keyword to register
  • keyword_function
    • The callback that will handle the keyword processing
    • The callback function should return one of the following
      • PARSER_RC_OK -- Callback was successful (continue with other callbacks)
      • PARSER_RC_STOP -- Stop processing callbacks (return OK)
      • PARSER_RC_ERROR -- Callback failed, exit

Output

  • The corresponding keyword and callback will be registered

Returns

  • 0 maximum callbacks already registered for this keyword
  • > 0 which is the number of callbacks associated with this keyword.

parser_next(PARSER *parser)

Return the next item to parse

Input

  • parser
    • The parser object as returned by the parser_init

Output

  • The parser will store internally the next item to parse

Returns

  • 0 Next item fetched successfully
  • 1 No more items to parse

parser_action(PARSER *parser, char *input)

Return the next item to parse

Input

  • parser
    • The parser object as returned by the parser_init
  • input
    • Process the input specified instead of using the internal buffer

Output

  • The current keyword will be processed by calling all the registered callbacks

Returns

  • 0 Callbacks called successfully
  • 1 Failed

parser_destroy(PARSER *parser)

Cleanup a previously allocated parser

Input

  • parser
    • The parser object as returned by the parser_init

Output

  • The parser is deallocated

Returns

  • none

parser_recover_input(PARSER *parser)

Cleanup a previously allocated parser

Input

  • parser
    • The parser object as returned by the parser_init

Output

  • The parser is deallocated

Returns

  • none