mirror of https://github.com/docker/cli.git
cli/command: remove deprecated EventHandler, InitEventHandler
These were deprecated in 46afd26c45
in v26.0, and have no known users.
Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
This commit is contained in:
parent
ed2d365653
commit
f80d7182ca
|
@ -1,51 +0,0 @@
|
||||||
package command
|
|
||||||
|
|
||||||
import (
|
|
||||||
"sync"
|
|
||||||
|
|
||||||
"github.com/docker/docker/api/types/events"
|
|
||||||
"github.com/sirupsen/logrus"
|
|
||||||
)
|
|
||||||
|
|
||||||
// EventHandler is abstract interface for user to customize
|
|
||||||
// own handle functions of each type of events
|
|
||||||
//
|
|
||||||
// Deprecated: EventHandler is no longer used, and will be removed in the next release.
|
|
||||||
type EventHandler interface {
|
|
||||||
Handle(action events.Action, h func(events.Message))
|
|
||||||
Watch(c <-chan events.Message)
|
|
||||||
}
|
|
||||||
|
|
||||||
// InitEventHandler initializes and returns an EventHandler
|
|
||||||
//
|
|
||||||
// Deprecated: InitEventHandler is no longer used, and will be removed in the next release.
|
|
||||||
func InitEventHandler() EventHandler {
|
|
||||||
return &eventHandler{handlers: make(map[events.Action]func(events.Message))}
|
|
||||||
}
|
|
||||||
|
|
||||||
type eventHandler struct {
|
|
||||||
handlers map[events.Action]func(events.Message)
|
|
||||||
mu sync.Mutex
|
|
||||||
}
|
|
||||||
|
|
||||||
func (w *eventHandler) Handle(action events.Action, h func(events.Message)) {
|
|
||||||
w.mu.Lock()
|
|
||||||
w.handlers[action] = h
|
|
||||||
w.mu.Unlock()
|
|
||||||
}
|
|
||||||
|
|
||||||
// Watch ranges over the passed in event chan and processes the events based on the
|
|
||||||
// handlers created for a given action.
|
|
||||||
// To stop watching, close the event chan.
|
|
||||||
func (w *eventHandler) Watch(c <-chan events.Message) {
|
|
||||||
for e := range c {
|
|
||||||
w.mu.Lock()
|
|
||||||
h, exists := w.handlers[e.Action]
|
|
||||||
w.mu.Unlock()
|
|
||||||
if !exists {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
logrus.Debugf("event handler: received event: %v", e)
|
|
||||||
go h(e)
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in New Issue