messengers

type EmailMessenger ¶

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

EmailMessenger sends emails using an SMTP connection pool

func NewEmailMessenger(cfg config.SMTPConfig, groupResolver GroupResolver, logger *slog.Logger, rootURL string) (*EmailMessenger, error)

func (e *EmailMessenger) Close()

func (e *EmailMessenger) Send(ctx context.Context, msg Message) error

type EmailNotifyConfig ¶ added in v0.8.0

type EmailNotifyConfig struct {
	Receivers []string `json:"receivers" jsonschema:"title=Recipients,description=Users or groups to notify" jsonschema_extras:"widget=userselector"`
}

EmailNotifyConfig defines the messenger-specific configuration schema for email notifications.

type EventType ¶ added in v0.8.0

type EventType string

EventType identifies the kind of event a Message carries.

const (
	EventFlowExecution EventType = "flow.execution"
)

type FlowExecutionEvent ¶ added in v0.8.0

type FlowExecutionEvent struct {
	FlowID    string `json:"flow_id"`
	FlowName  string `json:"flow_name"`
	ExecID    string `json:"exec_id"`
	Status    string `json:"status"`
	Error     string `json:"error"`
	Namespace string `json:"namespace"`
	RootURL   string `json:"-"`
}

FlowExecutionEvent carries structured data about a flow execution state change.

type GroupResolver ¶ added in v0.8.0

type GroupResolver interface {
	ResolveGroupEmails(ctx context.Context, groupName string) ([]string, error)
}

GroupResolver resolves a group name to a list of member email addresses.

type Message ¶

type Message struct {
	Event  EventType
	Data   any
	Config map[string]any
}

Message is the generic struct passed to messengers.

type Messenger ¶

type Messenger interface {
	Send(ctx context.Context, message Message) error
	Close()
}

type WebhookMessenger ¶ added in v0.8.0

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

WebhookMessenger sends HTTP POST requests using the Standard Webhooks format.

func NewWebhookMessenger(cfg config.WebhookConfig, logger *slog.Logger) (*WebhookMessenger, error)

func (w *WebhookMessenger) Close()

func (w *WebhookMessenger) Send(_ context.Context, msg Message) error

type WebhookNotifyConfig ¶ added in v0.8.0

type WebhookNotifyConfig struct {
	URL string `json:"url" jsonschema:"title=Webhook URL,description=URL to POST webhook notifications to"`
}

WebhookNotifyConfig defines the per-flow webhook configuration rendered in the UI.