Henrik Feldt

Pipe.scan is not single-threaded...

4

...as such it cannot reliably be used for counting/buffering, etc. Try outputting two events and using the scan implementation I posted in an earlier issue; the initial state is created...

Consider exception handling in Pipe/Processing

1

It should not be possible to crash the pipeline with an exception.

Pipe.combineLatest: need a way to delay emitting values until some condition is true

1

For example: ```fsharp Events.events |> Pipe.filter Message.isGauge |> Pipe.scan (Dictionary()) (fun state message -> fun m -> let k = gaugeKey message match state.TryGetValue k with | false, _ ->...

This improves things when we wish to log crashes happening which also crash Hopac threads.

- Before: 10k messages in 27s = 370 m/s - After: in 4ad22579, 10k messages in 9.98s = 1000 m/s. Method: 5 HTTP requests in flight. - After: in 21e5736a,...

- Message.isGauge - Message.isEvent Allows you to filter messages based on their types.

```fsharp let logary = Config.create "EndToEndTests" (Dns.GetHostName()) |> Config.targets [ LiterateConsole.create LiterateConsole.empty "console" ] |> Config.ilogger (ILogger.LiterateConsole Verbose) |> Config.loggerLevels [ ".*", LogLevel.Debug ] |> Config.processing (Events.events |> Events.sink [...

`KubeCluster` Client –> Scheduler: missing port number in address 'kubernetes'

4

**What happened**: When spawning a new k8s cluster, I get these errors: ``` run-mmm-dask-27408369-swmpw run-mmm CRITICAL:our_package.main:Running of program failed: missing port number in address 'kubernetes' run-mmm-dask-27408369-swmpw run-mmm Traceback (most recent...

Hi, I'm getting an error outside the file: ``` Module build failed: Error: Please check the validity of the CSS block starting from the line #414 ``` This is after...