GoDoxy/internal/watcher/events/events.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

	actionContainerWakeMask  = ActionContainerCreate | ActionContainerStart | ActionContainerUnpause
	actionContainerSleepMask = ActionContainerKill | ActionContainerStop | ActionContainerPause | 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,
}

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.ActorName, e.Action)
}

func (a Action) String() string {
	return actionNameMap[a]
}

func (a Action) IsContainerWake() bool {
	return a&actionContainerWakeMask != 0
}

func (a Action) IsContainerSleep() bool {
	return a&actionContainerSleepMask != 0
}