eventing

type HandlerInvoker func(event MdaiEvent) error

type MdaiEvent struct {
	ID             string    `json:"id,omitempty"`
	Name           string    `json:"name"`    // e.g. "alert_firing"
	Version        int       `json:"version"` // schema version
	Timestamp      time.Time `json:"timestamp,omitempty"`
	Payload        string    `json:"payload"`
	Source         string    `json:"source"`    // used in subject, could not be empty
	SourceID       string    `json:"source_id"` // ex alert fingerprint
	CorrelationID  string    `json:"correlation_id,omitempty"`
	HubName        string    `json:"hub_name"`
	RecursionDepth int       `json:"recursion_depth,omitempty"` // recursion depth limit for events
}

type MdaiEventConsumerGroup string

type MdaiEventSubject struct {
	// The specific MDAI Event stream this event belongs. Joined to Path with "."
	Type MdaiEventType
	// The path after the stream. Joined to preceding Type with "."
	Path string
}

type MdaiEventType string

type VariablesActionPayload struct {
	VariableRef string `json:"variableRef"`
	DataType    string `json:"dataType"`
	Operation   string `json:"operation"`
	Data        any    `json:"data"`
}