| Mode | Name | Size | |
|---|---|---|---|
| -rw-r--r-- | hash.go | 315 | logplain |
| -rw-r--r-- | namespace.go | 45 | logplain |
| d--------- | operator | 310 | logplain |
| -rw-r--r-- | record.go | 804 | logplain |
| -rw-r--r-- | state.go | 247 | logplain |
| -rw-r--r-- | state_backend.go | 1440 | logplain |
| -rw-r--r-- | timer.go | 2525 | logplain |
| -rw-r--r-- | window.go | 1073 | logplain |
 |
index : flux.git | |
| Event-driven stream processing engine in Go with stateful computation & windowing | sangtran |
| aboutsummaryrefslogtreecommitdiff |