README
¶
starlarkgroup
Go errgroup.Group for starlark. Allows a starlark thread to spawn go routines.
Each go routine can be optionally pooled and rate limited.
Arguments to go are frozen. Wait returns a tuple of sorted values in order of
calling. Calls are lazy evaluated and only executed when wait() is called.
def square(x):
return x*x
def square_all(vs):
# Create a group of 10 go routines, limited every 10ms with a burst of 10.
g = group(n = 10, every = "10ms", burst = 10)
for i in vs:
g.go(square, i) # args[1:] and kwargs passed to arg[0]
return g.wait()
print(square_all(range(10))) # prints: [0, 1, 4, 9, 16, 25, 36, 49, 64, 81]
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Make ¶
func Make(thread *starlark.Thread, _ *starlark.Builtin, args starlark.Tuple, kwargs []starlark.Tuple) (starlark.Value, error)
Make creates a new group instance. Accepts the following optional kwargs: "n", "every", "burst".
An application can add 'group' to the Starlark envrionment like so:
globals := starlark.StringDict{
"group": starlark.NewBuiltin("group", starlarkgroup.Make),
}
Types ¶
type Group ¶
type Group struct {
// contains filtered or unexported fields
}
Group implements errgroup.Group in starlark with additional rate limiting. Arguments to go call are frozen. Wait returns a sorted tuple in order of calling. Calls are lazy evaluated and only executed when waiting.
Source Files
Click to show internal directories.
Click to hide internal directories.