mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
80d694d205
* rendering: headless chrome progress * renderer: minor change * grpc: version hell * updated grpc libs * wip: minor progess * rendering: new image rendering plugin is starting to work * feat: now phantomjs works as well and updated alerting to use new rendering service * refactor: renamed renderer package and service to rendering to make renderer name less confusing (rendering is internal service that handles the renderer plugin now) * rendering: now render key is passed and render auth is working in plugin mode * removed unneeded lines from gitignore * rendering: now plugin mode supports waiting for all panels to complete rendering * fix: LastSeenAt fix for render calls, was not set which causes a lot of updates to Last Seen at during rendering, this should fix sqlite db locked issues in seen in previous releases * change: changed render tz url parameter to use proper timezone name as chrome does not handle UTC offset TZ values * fix: another update to tz param generation * renderer: added http mode to renderer service, new ini setting [rendering] server_url
63 lines
1.8 KiB
Go
63 lines
1.8 KiB
Go
// Package run implements an actor-runner with deterministic teardown. It is
|
|
// somewhat similar to package errgroup, except it does not require actor
|
|
// goroutines to understand context semantics. This makes it suitable for use in
|
|
// more circumstances; for example, goroutines which are handling connections
|
|
// from net.Listeners, or scanning input from a closable io.Reader.
|
|
package run
|
|
|
|
// Group collects actors (functions) and runs them concurrently.
|
|
// When one actor (function) returns, all actors are interrupted.
|
|
// The zero value of a Group is useful.
|
|
type Group struct {
|
|
actors []actor
|
|
}
|
|
|
|
// Add an actor (function) to the group. Each actor must be pre-emptable by an
|
|
// interrupt function. That is, if interrupt is invoked, execute should return.
|
|
// Also, it must be safe to call interrupt even after execute has returned.
|
|
//
|
|
// The first actor (function) to return interrupts all running actors.
|
|
// The error is passed to the interrupt functions, and is returned by Run.
|
|
func (g *Group) Add(execute func() error, interrupt func(error)) {
|
|
g.actors = append(g.actors, actor{execute, interrupt})
|
|
}
|
|
|
|
// Run all actors (functions) concurrently.
|
|
// When the first actor returns, all others are interrupted.
|
|
// Run only returns when all actors have exited.
|
|
// Run returns the error returned by the first exiting actor.
|
|
func (g *Group) Run() error {
|
|
if len(g.actors) == 0 {
|
|
return nil
|
|
}
|
|
|
|
// Run each actor.
|
|
errors := make(chan error, len(g.actors))
|
|
for _, a := range g.actors {
|
|
go func(a actor) {
|
|
errors <- a.execute()
|
|
}(a)
|
|
}
|
|
|
|
// Wait for the first actor to stop.
|
|
err := <-errors
|
|
|
|
// Signal all actors to stop.
|
|
for _, a := range g.actors {
|
|
a.interrupt(err)
|
|
}
|
|
|
|
// Wait for all actors to stop.
|
|
for i := 1; i < cap(errors); i++ {
|
|
<-errors
|
|
}
|
|
|
|
// Return the original error.
|
|
return err
|
|
}
|
|
|
|
type actor struct {
|
|
execute func() error
|
|
interrupt func(error)
|
|
}
|