paStash NG Commands

paStash Commands

This WIP outlines the nature of paStash commands and their general usage.

What?

Command filters are pluggable pipeline functions users can inject in their logic using npm modules. Example:

  .filter('method', 'INVITE')
  .groupBy('response')
  .divide('timestamp',1000,data)
  .data(data)

Usage

In order to understand the potential usage of command filters we'll create a simple custom plugin providing a divide and multiply set of commands to our pipeline.

Requirements

The following modules are required to run this example:

sudo npm install -g @pastash/pastash @pastash/filter_command @pastash/command_math

Proceed to create a pipeline using your preferred in/out combination. Our custom plugin (and any other) will be loaded at runtime via the plugins property of the command filter:

input {
  stdin{}
}

filter {
  json_fields {}
  command {
    debug => false
    cmd => ".divide('age',2,data).multiply('eyes',2,data).data(data)"
    plugins => ['@pastash/command_chain','@pastash/command_math']
  }
}

output {
  stdout {}
}

Feed it!

The following input should transverse the command pipeline and return all changes to the output:

[{ "sex": "male", "age": 35, "eyes": 2 },{ "sex": "female", "age": 38, "eyes": 2 },{ "sex": "male", "age": 29, "eyes": 2 }]

TO BE CONTINUED