All tasks stats

[yosiat]

Hi,

I am currently building UI for Kapacitor (that I hope to release in a month) and I am showing a list of all tasks.
I want to add to each task the number of points he processed and how much he outputed (points written or alerts triggered).

In the current api it will be slow, because I will need to fetch all tasks (using "/tasks") and fetch each task and parse it's dot file. and I want to do this every 10 seconds or something.

So I thoought about adding to "/tasks" something like this:

{
    Name: "cpu_alert",
    Type: 0,
    DBRPs: [{
        db: "kapacitor_example",
        rp: "default"
    }],
    Enabled: true,
    Executing: true,
    ExecutionStats: {
        Inputs: {
            stream1: 234
        },
        Outputs: {
            alert1: 298,
            influxdbout: 12
        }
    }
}

Where the Inputs and Outputs are key value of how much they emitted.
I digged to the source code and found a way to do so, but I am not sure about this, and I want OK before I code it out.

1. I need node to export how much they emitted - and this can be calculated by the summing the "emitted" in Edge statsMap.
2. Add to ExecutingTask function that will return "ExecutionStats" struct that will:
   • Input nodes:
     1. Find them all by checking their type StreamNode/ BatchNode
     2. Get their value - by summing the edge outs emitted
   • Output nodes:
     1. Find the output nodes by the next predicate: node that have parents and doesn't have child nodes.
     2. Expose function on "Node" (is this the right place) - that will return how much their outputed

@nathanielc What do you think? am I in the right direction?

[yosiat]

Moving discussion to the pull request #323