mirror of
https://github.com/yusing/godoxy.git
synced 2025-05-20 12:42:34 +02:00
96 lines
2.2 KiB
Go
96 lines
2.2 KiB
Go
package events
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
dockerEvents "github.com/docker/docker/api/types/events"
|
|
)
|
|
|
|
type (
|
|
Event struct {
|
|
Type EventType
|
|
ActorName string // docker: container name, file: relative file path
|
|
ActorID string // docker: container id, file: empty
|
|
ActorAttributes map[string]string // docker: container labels, file: empty
|
|
Action Action
|
|
}
|
|
Action uint16
|
|
EventType string
|
|
)
|
|
|
|
const (
|
|
ActionFileWritten Action = (1 << iota)
|
|
ActionFileCreated
|
|
ActionFileDeleted
|
|
ActionFileRenamed
|
|
|
|
ActionContainerCreate
|
|
ActionContainerStart
|
|
ActionContainerUnpause
|
|
|
|
ActionContainerKill
|
|
ActionContainerStop
|
|
ActionContainerPause
|
|
ActionContainerDie
|
|
ActionContainerDestroy
|
|
|
|
ActionForceReload
|
|
|
|
actionContainerStartMask = ActionContainerCreate | ActionContainerStart | ActionContainerUnpause
|
|
actionContainerStopMask = ActionContainerKill | ActionContainerStop | ActionContainerDie
|
|
)
|
|
|
|
const (
|
|
EventTypeDocker EventType = "docker"
|
|
EventTypeFile EventType = "file"
|
|
)
|
|
|
|
var DockerEventMap = map[dockerEvents.Action]Action{
|
|
dockerEvents.ActionCreate: ActionContainerCreate,
|
|
dockerEvents.ActionStart: ActionContainerStart,
|
|
dockerEvents.ActionUnPause: ActionContainerUnpause,
|
|
|
|
dockerEvents.ActionKill: ActionContainerKill,
|
|
dockerEvents.ActionStop: ActionContainerStop,
|
|
dockerEvents.ActionPause: ActionContainerPause,
|
|
dockerEvents.ActionDie: ActionContainerDie,
|
|
dockerEvents.ActionDestroy: ActionContainerDestroy,
|
|
}
|
|
|
|
var fileActionNameMap = map[Action]string{
|
|
ActionFileWritten: "written",
|
|
ActionFileCreated: "created",
|
|
ActionFileDeleted: "deleted",
|
|
ActionFileRenamed: "renamed",
|
|
}
|
|
|
|
var actionNameMap = func() (m map[Action]string) {
|
|
m = make(map[Action]string, len(DockerEventMap))
|
|
for k, v := range DockerEventMap {
|
|
m[v] = string(k)
|
|
}
|
|
for k, v := range fileActionNameMap {
|
|
m[k] = v
|
|
}
|
|
return
|
|
}()
|
|
|
|
func (e Event) String() string {
|
|
return fmt.Sprintf("%s %s", e.Action, e.ActorName)
|
|
}
|
|
|
|
func (a Action) String() string {
|
|
return actionNameMap[a]
|
|
}
|
|
|
|
func (a Action) IsContainerStart() bool {
|
|
return a&actionContainerStartMask != 0
|
|
}
|
|
|
|
func (a Action) IsContainerStop() bool {
|
|
return a&actionContainerStopMask != 0
|
|
}
|
|
|
|
func (a Action) IsContainerPause() bool {
|
|
return a == ActionContainerPause
|
|
}
|