monnoroch / golfstream Goto Github PK

Structure errors.Ex contains an error and a stack trace, but when created with errors.AsEx(err) the stack trace has an additional last line inside AsEx() which should be cut off.

Now you can only print list of event's fields and can't print whole events.

Right now sprintf is good enough, but it prints in Go internal format. Would be better to create a separate to_json function to act like sprintf but dump to json.

In addition to http remote implementations we need jsonrpc (+ws as in http).

Basically, the idea is to add new streams.Run(map[string]stream.Stream, ...). Then you can provide multiple inputs and name them. This function will then just create the same initial context as the current one like this: https://github.com/Monnoroch/golfstream/blob/master/stream/build.go#L14, but with multiple entries and custom names.

https://github.com/Monnoroch/golfstream/blob/master/service.go#L116.

If a stream is 1:N, then we have to call it N times here, is a stream is N:1 like RollingMaxBy, then we loop infinitely in it's Next() since self.val.evt is always the same forever in that loop.

Some streams.Stream instances may break if an error occure. They return an error and after that calling Next() method is unsafe. This should be fixed: a stream that returned an error needs to ignore the problem internally and maintein consistent state, so that it's safe to call Next() again until EOI.

Would be very helpful to just write:

{"save": ["tmp", {"lua": [{"load": "events"}, "function(evt) return evt, nil end"]}]}

With any code in lua.

ACHTUNG: need to disable filesystem and shell access.