github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-12 12:48:51 +00:00
Code Issues Projects Releases Wiki Activity

Add filter to watch

Browse Source
This commit is contained in:
Daniel Smith
2014-08-14 13:23:07 -07:00
parent ca55bfb29c
commit d900134a60
3 changed files with 153 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/watch/mux.go
View File

@@ -20,7 +20,8 @@ import (
"sync"
)
// Mux distributes event notifications among any number of watchers.
// Mux distributes event notifications among any number of watchers. Every event
// is delivered to every watcher.
type Mux struct {
lock sync.Mutex
@@ -33,7 +34,7 @@ type Mux struct {
// NewMux creates a new Mux. queueLength is the maximum number of events to queue.
// When queueLength is 0, Action will block until any prior event has been
// completely distributed. It is guaranteed that events will be distibuted in the
// order in which they occurr, but the order in which a single event is distributed
// order in which they ocurr, but the order in which a single event is distributed
// among all of the watchers is unspecified.
func NewMux(queueLength int) *Mux {
m := &Mux{