event.go RawHistoryFolder

1package domain
2
3import (
4	"context"
5	"time"
6)
7
8// EventType defines the type of event that occurred.
9type EventType string
10
11const (
12	EventImagePushed          EventType = "image.pushed"
13	EventImageDeleted         EventType = "image.deleted"
14	EventConfigReload         EventType = "config.reload"
15	EventManualReload         EventType = "manual.reload"
16	EventContainerStop        EventType = "container.stop"
17	EventContainerStart       EventType = "container.start"
18	EventContainerHealthCheck EventType = "container.health_check"
19	EventContainerDeployed    EventType = "container.deployed"
20)
21
22// Event represents a domain event that occurred in the system.
23type Event struct {
24	ID          string
25	Type        EventType
26	Timestamp   time.Time
27	ImageName   string
28	Tag         string
29	Route       string
30	ContainerID string
31	Data        any
32}
33
34// ImagePushedPayload contains data for image.pushed events.
35type ImagePushedPayload struct {
36	Name        string
37	Reference   string
38	Manifest    []byte
39	Annotations map[string]string
40}
41
42// ContainerEventPayload contains data for container events.
43type ContainerEventPayload struct {
44	ContainerID string
45	Domain      string
46	Image       string
47	Action      string
48}
49
50// ConfigReloadPayload contains data for config.reload events.
51type ConfigReloadPayload struct {
52	Source        string // "file" or "manual"
53	AddedRoutes   []string
54	RemovedRoutes []string
55	UpdatedRoutes []string
56}
57
58// Context keys for domain-level concerns.
59type contextKey string
60
61const (
62	// ContextKeyInternalDeploy indicates the deployment is triggered internally
63	// (e.g., from our own registry's image.pushed event) and should use
64	// internal registry authentication for image pulls.
65	ContextKeyInternalDeploy contextKey = "internal_deploy"
66)
67
68// IsInternalDeploy checks if the context indicates an internal deployment.
69func IsInternalDeploy(ctx context.Context) bool {
70	v, ok := ctx.Value(ContextKeyInternalDeploy).(bool)
71	return ok && v
72}
73
74// WithInternalDeploy returns a context marked as an internal deployment.
75func WithInternalDeploy(ctx context.Context) context.Context {
76	return context.WithValue(ctx, ContextKeyInternalDeploy, true)
77}