Versions in this module Expand all Collapse all v1 v1.1.0 Dec 26, 2025 v1.0.0 Dec 26, 2025 Changes in this version + const SeverityCritical + const SeverityError + const SeverityInfo + const SeverityWarning + func WithNotifier(ctx context.Context, n Notifier) context.Context + type Event struct + FlowID string + Message string + Metadata map[string]any + NodeID string + RunID string + Severity string + Timestamp time.Time + Type EventType + type EventType string + const EventNodeCompleted + const EventNodeFailed + const EventNodeStarted + const EventPRCreated + const EventReviewNeeded + const EventRunCompleted + const EventRunFailed + const EventRunStarted + type LogNotifier struct + Logger *slog.Logger + func NewLogNotifier(logger *slog.Logger) *LogNotifier + func (n *LogNotifier) Notify(ctx context.Context, event Event) error + type MultiNotifier struct + Logger *slog.Logger + Notifiers []Notifier + func NewMultiNotifier(notifiers ...Notifier) *MultiNotifier + func (n *MultiNotifier) Notify(ctx context.Context, event Event) error + type NopNotifier struct + func (NopNotifier) Notify(ctx context.Context, event Event) error + type Notifier interface + Notify func(ctx context.Context, event Event) error + func MustNotifierFromContext(ctx context.Context) Notifier + func NotifierFromContext(ctx context.Context) Notifier + type SlackNotifier struct + Channel string + Client *http.Client + Username string + WebhookURL string + func NewSlackNotifier(webhookURL string, opts ...SlackOption) *SlackNotifier + func (n *SlackNotifier) Notify(ctx context.Context, event Event) error + type SlackOption func(*SlackNotifier) + func WithSlackChannel(channel string) SlackOption + func WithSlackUsername(username string) SlackOption + type WebhookNotifier struct + Client *http.Client + Headers map[string]string + URL string + func NewWebhookNotifier(url string, headers map[string]string) *WebhookNotifier + func (n *WebhookNotifier) Notify(ctx context.Context, event Event) error
Go to main page