69db6279aa
Although having a request ID available throughout the codebase is very valuable, the impact of requiring a Context as an argument to every function in the codepath of an API request, is too significant and was not properly understood at the time of the review. Furthermore, mixing API-layer code with non-API-layer code makes the latter usable only by API-layer code (one that has a notion of Context). This reverts commit de4164043546d2b9ee3bf323dbc41f4979c84480, reversing changes made to 7daeecd42d7bb112bfe01532c8c9a962bb0c7967. Signed-off-by: Tibor Vass <tibor@docker.com> Conflicts: api/server/container.go builder/internals.go daemon/container_unix.go daemon/create.go Upstream-commit: b08f071e18043abe8ce15f56826d38dd26bedb78 Component: engine
66 lines
1.6 KiB
Go
66 lines
1.6 KiB
Go
package events
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/docker/docker/pkg/jsonmessage"
|
|
"github.com/docker/docker/pkg/pubsub"
|
|
)
|
|
|
|
const eventsLimit = 64
|
|
|
|
// Events is pubsub channel for *jsonmessage.JSONMessage
|
|
type Events struct {
|
|
mu sync.Mutex
|
|
events []*jsonmessage.JSONMessage
|
|
pub *pubsub.Publisher
|
|
}
|
|
|
|
// New returns new *Events instance
|
|
func New() *Events {
|
|
return &Events{
|
|
events: make([]*jsonmessage.JSONMessage, 0, eventsLimit),
|
|
pub: pubsub.NewPublisher(100*time.Millisecond, 1024),
|
|
}
|
|
}
|
|
|
|
// Subscribe adds new listener to events, returns slice of 64 stored last events
|
|
// channel in which you can expect new events in form of interface{}, so you
|
|
// need type assertion.
|
|
func (e *Events) Subscribe() ([]*jsonmessage.JSONMessage, chan interface{}) {
|
|
e.mu.Lock()
|
|
current := make([]*jsonmessage.JSONMessage, len(e.events))
|
|
copy(current, e.events)
|
|
l := e.pub.Subscribe()
|
|
e.mu.Unlock()
|
|
return current, l
|
|
}
|
|
|
|
// Evict evicts listener from pubsub
|
|
func (e *Events) Evict(l chan interface{}) {
|
|
e.pub.Evict(l)
|
|
}
|
|
|
|
// Log broadcasts event to listeners. Each listener has 100 millisecond for
|
|
// receiving event or it will be skipped.
|
|
func (e *Events) Log(action, id, from string) {
|
|
now := time.Now().UTC()
|
|
jm := &jsonmessage.JSONMessage{Status: action, ID: id, From: from, Time: now.Unix(), TimeNano: now.UnixNano()}
|
|
e.mu.Lock()
|
|
if len(e.events) == cap(e.events) {
|
|
// discard oldest event
|
|
copy(e.events, e.events[1:])
|
|
e.events[len(e.events)-1] = jm
|
|
} else {
|
|
e.events = append(e.events, jm)
|
|
}
|
|
e.mu.Unlock()
|
|
e.pub.Publish(jm)
|
|
}
|
|
|
|
// SubscribersCount returns number of event listeners
|
|
func (e *Events) SubscribersCount() int {
|
|
return e.pub.Len()
|
|
}
|