Mozilla Ingestion Utility Module

1. Functions

1.1. new_message

Returns a new message table based on a moz_ingest uri/message.

Arguments

  • hsr (userdata) Heka stream reader
  • uri (string/nil) URI to parse into message fields, if not provided it is extracted from Fields[uri]

Return

  • msg (table/error) - base message table before the namespace specific transformation

1.2. load_json_schemas

Returns a table of rjson schemas key by namespace and version.

Arguments

  • schema_path (string) - Directory containing the JSON schemas

Return

  • schemas (table)

source code: util.lua

results matching ""

    No results matching ""