update leakybucket readme (#2298)
This commit is contained in:
parent
fddf597040
commit
62caffb102
|
@ -12,9 +12,7 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
func runPour(input chan types.Event, holders []leaky.BucketFactory, buckets *leaky.Buckets, cConfig *csconfig.Config) error {
|
func runPour(input chan types.Event, holders []leaky.BucketFactory, buckets *leaky.Buckets, cConfig *csconfig.Config) error {
|
||||||
var (
|
count := 0
|
||||||
count int
|
|
||||||
)
|
|
||||||
for {
|
for {
|
||||||
//bucket is now ready
|
//bucket is now ready
|
||||||
select {
|
select {
|
||||||
|
|
|
@ -158,7 +158,7 @@ Bayesian Conditions are built from:
|
||||||
|
|
||||||
[This is not dry enough to have many details here, but:]
|
[This is not dry enough to have many details here, but:]
|
||||||
|
|
||||||
The bucket code is triggered by `InfiniBucketify` in `main.go`.
|
The bucket code is triggered by runPour in pour.go, by calling the `leaky.PourItemToHolders` function.
|
||||||
There is one struct called buckets which is for now a
|
There is one struct called buckets which is for now a
|
||||||
`map[string]interface{}` that holds all buckets. The key of this map
|
`map[string]interface{}` that holds all buckets. The key of this map
|
||||||
is derived from the filter configured for the bucket and its
|
is derived from the filter configured for the bucket and its
|
||||||
|
|
Loading…
Reference in a new issue