triggers

type Action struct {
	// Method is the upper-cased HTTP method.
	Method string
	// URL is the webhook endpoint.
	URL string
	// StaticHeaders are the action's extra request headers.
	StaticHeaders map[string]string
	// IgnoreSSLErrors disables server-certificate verification for this
	// action's requests (upstream "ignore_ssl_errors").
	IgnoreSSLErrors bool
	// Custom is the raw action object of a non-HTTP action, delivered
	// through the Forwarder extension point; nil for HTTP actions.
	Custom json.RawMessage
	// Template is the Mustache body template (upstream "template"), set
	// only when TemplateType == "mustache".
	Template string
	// TemplateType is the upstream "template_type" field. Only "mustache"
	// is rendered; any other non-empty value is accepted but ignored (the
	// default JSON envelope is sent), same as before this field existed.
	TemplateType string
}

type DataEvent struct {
	// DeviceID is the encoded publishing device ID.
	DeviceID string
	// On is the condition name being evaluated.
	On string
	// Interface and Major identify the interface the publish validated
	// against.
	Interface string
	Major     int
	// Path is the concrete data path.
	Path string
	// Value is the decoded payload value (payload.Value closed set; nil for
	// unset).
	Value any
}

type Decision struct {
	Strategy Strategy
	Reason   string
}

type Delivery struct {
	// Realm is the tenant (rides in the Astarte-Realm header).
	Realm string
	// Trigger is the matched trigger.
	Trigger *Trigger
	// Event is the rendered envelope.
	Event SimpleEvent
	// contains filtered or unexported fields
}

type DeviceConnectedEvent struct {
	// Type is always "device_connected".
	Type string `json:"type"`
	// DeviceIPAddress is the peer address of the new connection.
	DeviceIPAddress string `json:"device_ip_address"`
}

type DeviceDeletionFinishedEvent struct {
	// Type is always "device_deletion_finished".
	Type string `json:"type"`
}

type DeviceDeletionStartedEvent struct {
	// Type is always "device_deletion_started".
	Type string `json:"type"`
}

type DeviceDisconnectedEvent struct {
	// Type is always "device_disconnected".
	Type string `json:"type"`
}

type DeviceErrorEvent struct {
	// Type is always "device_error".
	Type string `json:"type"`
	// ErrorName is the rejection reason (Astrate's §2.6 reject-reason
	// labels feed it).
	ErrorName string `json:"error_name"`
	// Metadata carries free-form diagnostic strings.
	Metadata map[string]string `json:"metadata"`
}

type DeviceEvent struct {
	// DeviceID is the encoded device ID.
	DeviceID string
	// On is the condition name (OnDeviceConnected, ...).
	On string
	// Interface and Major carry the interface filter input for
	// interface_added / interface_removed events; empty otherwise.
	Interface string
	Major     int
}

type DeviceRegisteredEvent struct {
	// Type is always "device_registered".
	Type string `json:"type"`
}

type Executor struct {
	// contains filtered or unexported fields
}

type ExecutorConfig struct {
	// Workers is the number of delivery goroutines.
	Workers int
	// QueueSize is the bounded delivery queue capacity; a full queue drops
	// the event with a metric (triggers must never backpressure ingestion,
	// docs/DESIGN.md §1.4).
	QueueSize int
	// MaxAttempts bounds attempts per delivery (1 = no retries).
	MaxAttempts int
	// BackoffStart and BackoffCap shape the exponential retry delay.
	BackoffStart time.Duration
	BackoffCap   time.Duration
	// RequestTimeout bounds each webhook request.
	RequestTimeout time.Duration
	// Forwarder handles non-HTTP actions; nil logs and skips them.
	Forwarder Forwarder
	// Registerer receives the executor's collectors; nil leaves them
	// unregistered (they still work, which tests rely on).
	Registerer prometheus.Registerer
	// Logger receives delivery logs (default slog.Default()).
	Logger *slog.Logger
}

type FieldErrors struct {
	Part   string // e.g. "action"
	Fields map[string][]string
}

type Forwarder interface {
	// Forward delivers one rendered event for a custom action.
	Forward(ctx context.Context, realm, trigger string, action json.RawMessage, event []byte) error
}

type IncomingDataEvent struct {
	// Type is always "incoming_data".
	Type string `json:"type"`
	// Interface is the interface name.
	Interface string `json:"interface"`
	// Path is the concrete data path.
	Path string `json:"path"`
	// Value is the published value (null for property unset).
	Value any `json:"value"`
}

type IncomingIntrospectionEvent struct {
	// Type is always "incoming_introspection".
	Type string `json:"type"`
	// Introspection is the raw `;`-separated introspection payload.
	Introspection string `json:"introspection"`
}

type InterfaceAddedEvent struct {
	// Type is always "interface_added".
	Type string `json:"type"`
	// Interface is the added interface name.
	Interface string `json:"interface"`
	// MajorVersion and MinorVersion are the declared version.
	MajorVersion int `json:"major_version"`
	MinorVersion int `json:"minor_version"`
}

type InterfaceRemovedEvent struct {
	// Type is always "interface_removed".
	Type string `json:"type"`
	// Interface is the removed interface name.
	Interface string `json:"interface"`
	// MajorVersion is the removed major.
	MajorVersion int `json:"major_version"`
}

type PathCreatedEvent struct {
	// Type is always "path_created".
	Type string `json:"type"`
	// Interface is the interface name.
	Interface string `json:"interface"`
	// Path is the concrete data path.
	Path string `json:"path"`
	// Value is the first published value.
	Value any `json:"value"`
}

type PathRemovedEvent struct {
	// Type is always "path_removed".
	Type string `json:"type"`
	// Interface is the interface name.
	Interface string `json:"interface"`
	// Path is the concrete data path.
	Path string `json:"path"`
}

type Policy struct {
	Name            string
	MaximumCapacity int
	PrefetchCount   int
	RetryTimes      int           // 0 when no handler retries
	EventTTL        time.Duration // 0 when unset
	// contains filtered or unexported fields
}

type SimpleEvent struct {
	// Timestamp is the event instant.
	Timestamp time.Time
	// DeviceID is the encoded device ID.
	DeviceID string
	// TriggerName is the matched trigger's name (the envelope carries it).
	TriggerName string
	// Event is the typed event body: one of the *Event structs below.
	Event any
}

type Strategy int

type Trigger struct {
	// Name is the trigger's installed name.
	Name string
	// Action is the parsed delivery action.
	Action *Action
	// Unsupported lists upstream-valid features this version accepts but
	// does not evaluate (logged by the engine's trigger cache).
	Unsupported []string
	// PolicyName is the delivery policy named by the trigger definition.
	// An empty value means the implicit @default behaviour.
	PolicyName string
	// contains filtered or unexported fields
}

type TriggerErrors struct {
	Action         map[string][]string
	SimpleTriggers []map[string][]string // nil entries = no errors at that index
}

type ValueChangeAppliedEvent struct {
	// Type is always "value_change_applied".
	Type string `json:"type"`
	// Interface is the interface name.
	Interface string `json:"interface"`
	// Path is the concrete data path.
	Path string `json:"path"`
	// OldValue is the previous value (null when the path had none).
	OldValue any `json:"old_value"`
	// NewValue is the persisted value.
	NewValue any `json:"new_value"`
}

type ValueChangeEvent struct {
	// Type is always "value_change".
	Type string `json:"type"`
	// Interface is the interface name.
	Interface string `json:"interface"`
	// Path is the concrete data path.
	Path string `json:"path"`
	// OldValue is the previous value (null when the path had none).
	OldValue any `json:"old_value"`
	// NewValue is the published value.
	NewValue any `json:"new_value"`
}

type ValueStoredEvent struct {
	// Type is always "value_stored".
	Type string `json:"type"`
	// Interface is the interface name.
	Interface string `json:"interface"`
	// Path is the concrete data path.
	Path string `json:"path"`
	// Value is the stored value.
	Value any `json:"value"`
}