protoconnect

type DeliveryServiceClient interface {
	// GetDeliveryStatus returns full details of a single delivery, including
	// request body, response body, response code, error category, and retry state.
	// Errors: NOT_FOUND if the delivery_id does not exist in the given namespace.
	GetDeliveryStatus(context.Context, *connect.Request[proto.GetDeliveryStatusRequest]) (*connect.Response[proto.GetDeliveryStatusResponse], error)
	// ListDeliveries returns delivery records for a namespace, optionally filtered
	// by webhook_id or event_id. Ordered by created_at descending. Paginated.
	ListDeliveries(context.Context, *connect.Request[proto.ListDeliveriesRequest]) (*connect.Response[proto.ListDeliveriesResponse], error)
	// RetryDelivery re-enqueues deliveries for processing.
	// Can target a specific delivery_id, all failed/pending deliveries for a webhook_id,
	// or both. Set force=true to retry even successful deliveries.
	// Returns the count and IDs of deliveries that were re-enqueued.
	RetryDelivery(context.Context, *connect.Request[proto.RetryDeliveryRequest]) (*connect.Response[proto.RetryDeliveryResponse], error)
	// GetDeliveryAttempts returns the per-attempt history for a delivery, ordered by timestamp.
	// Each attempt includes response_time, response_code, error_message, and error_category.
	// Errors: INVALID_ARGUMENT if delivery_id is empty.
	GetDeliveryAttempts(context.Context, *connect.Request[proto.GetDeliveryAttemptsRequest]) (*connect.Response[proto.GetDeliveryAttemptsResponse], error)
	// RetryDeliveries executes a deterministic batch retry of deliveries whose IDs were
	// previously snapshotted via ListDeliveries with prepare_retry=true.
	// Each delivery is reset to pending and re-enqueued for HTTP delivery.
	// The batch is processed asynchronously via a River job; poll GetRetryStatus for progress.
	// Errors: NOT_FOUND if the retry_id does not exist or has expired.
	// Errors: FAILED_PRECONDITION if the batch is not in 'pending' status.
	RetryDeliveries(context.Context, *connect.Request[proto.RetryDeliveriesRequest]) (*connect.Response[proto.RetryDeliveriesResponse], error)
	// GetRetryStatus returns the current progress of a batch retry operation.
	// Errors: NOT_FOUND if the retry_id does not exist or has expired.
	GetRetryStatus(context.Context, *connect.Request[proto.GetRetryStatusRequest]) (*connect.Response[proto.GetRetryStatusResponse], error)
	// CancelRetry aborts a batch retry that is pending or in progress.
	// Items already processed are not rolled back.
	// Errors: NOT_FOUND if the retry_id does not exist.
	// Errors: FAILED_PRECONDITION if the batch is already completed or cancelled.
	CancelRetry(context.Context, *connect.Request[proto.CancelRetryRequest]) (*connect.Response[proto.CancelRetryResponse], error)
}

type DeliveryServiceHandler interface {
	// GetDeliveryStatus returns full details of a single delivery, including
	// request body, response body, response code, error category, and retry state.
	// Errors: NOT_FOUND if the delivery_id does not exist in the given namespace.
	GetDeliveryStatus(context.Context, *connect.Request[proto.GetDeliveryStatusRequest]) (*connect.Response[proto.GetDeliveryStatusResponse], error)
	// ListDeliveries returns delivery records for a namespace, optionally filtered
	// by webhook_id or event_id. Ordered by created_at descending. Paginated.
	ListDeliveries(context.Context, *connect.Request[proto.ListDeliveriesRequest]) (*connect.Response[proto.ListDeliveriesResponse], error)
	// RetryDelivery re-enqueues deliveries for processing.
	// Can target a specific delivery_id, all failed/pending deliveries for a webhook_id,
	// or both. Set force=true to retry even successful deliveries.
	// Returns the count and IDs of deliveries that were re-enqueued.
	RetryDelivery(context.Context, *connect.Request[proto.RetryDeliveryRequest]) (*connect.Response[proto.RetryDeliveryResponse], error)
	// GetDeliveryAttempts returns the per-attempt history for a delivery, ordered by timestamp.
	// Each attempt includes response_time, response_code, error_message, and error_category.
	// Errors: INVALID_ARGUMENT if delivery_id is empty.
	GetDeliveryAttempts(context.Context, *connect.Request[proto.GetDeliveryAttemptsRequest]) (*connect.Response[proto.GetDeliveryAttemptsResponse], error)
	// RetryDeliveries executes a deterministic batch retry of deliveries whose IDs were
	// previously snapshotted via ListDeliveries with prepare_retry=true.
	// Each delivery is reset to pending and re-enqueued for HTTP delivery.
	// The batch is processed asynchronously via a River job; poll GetRetryStatus for progress.
	// Errors: NOT_FOUND if the retry_id does not exist or has expired.
	// Errors: FAILED_PRECONDITION if the batch is not in 'pending' status.
	RetryDeliveries(context.Context, *connect.Request[proto.RetryDeliveriesRequest]) (*connect.Response[proto.RetryDeliveriesResponse], error)
	// GetRetryStatus returns the current progress of a batch retry operation.
	// Errors: NOT_FOUND if the retry_id does not exist or has expired.
	GetRetryStatus(context.Context, *connect.Request[proto.GetRetryStatusRequest]) (*connect.Response[proto.GetRetryStatusResponse], error)
	// CancelRetry aborts a batch retry that is pending or in progress.
	// Items already processed are not rolled back.
	// Errors: NOT_FOUND if the retry_id does not exist.
	// Errors: FAILED_PRECONDITION if the batch is already completed or cancelled.
	CancelRetry(context.Context, *connect.Request[proto.CancelRetryRequest]) (*connect.Response[proto.CancelRetryResponse], error)
}

type EventServiceClient interface {
	// RegisterEvent creates a new event type definition.
	// If a JSON schema is provided, all future PushEvent payloads for this event
	// are validated against it. The event name is the primary identifier (not a UUID).
	// Errors: ALREADY_EXISTS if an event with the same name already exists.
	RegisterEvent(context.Context, *connect.Request[proto.RegisterEventRequest]) (*connect.Response[proto.RegisterEventResponse], error)
	// ListEvents returns all registered event types, optionally filtered to active-only.
	// Results are paginated.
	ListEvents(context.Context, *connect.Request[proto.ListEventsRequest]) (*connect.Response[proto.ListEventsResponse], error)
	// UpdateEvent modifies an existing event type's description, schema, metadata, or active flag.
	// Updating the schema does not retroactively validate previously pushed events.
	// Errors: NOT_FOUND if the event name does not exist.
	UpdateEvent(context.Context, *connect.Request[proto.UpdateEventRequest]) (*connect.Response[proto.UpdateEventResponse], error)
	// DeleteEvent permanently removes an event type definition.
	// Existing subscriptions referencing this event name are not automatically deleted.
	// Errors: NOT_FOUND if the event name does not exist.
	DeleteEvent(context.Context, *connect.Request[proto.DeleteEventRequest]) (*connect.Response[proto.DeleteEventResponse], error)
	// GetEvent returns a single event type by name, including its schema and auto-generated sample payload.
	// Errors: NOT_FOUND if the event name does not exist.
	GetEvent(context.Context, *connect.Request[proto.GetEventRequest]) (*connect.Response[proto.GetEventResponse], error)
	// PushEvent emits an event instance. This is the primary ingestion endpoint.
	// On success, the event is persisted and a background job is enqueued to fan out
	// deliveries to all matching subscriptions (by namespace + event_name + label_filters).
	// The response returns immediately with the event_id; delivery happens asynchronously.
	// If the event type has a JSON schema, the payload is validated before acceptance.
	// Errors: INVALID_ARGUMENT if the payload fails schema validation.
	// Errors: NOT_FOUND if the event name is not registered.
	PushEvent(context.Context, *connect.Request[proto.PushEventRequest]) (*connect.Response[proto.PushEventResponse], error)
	// ListEventReports returns pushed event instances (not type definitions) for a namespace,
	// ordered by created_at descending. Each report includes delivery stats
	// (webhook_count, successful/failed/pending counts). Paginated, max 1000 per page.
	ListEventReports(context.Context, *connect.Request[proto.ListEventReportsRequest]) (*connect.Response[proto.ListEventReportsResponse], error)
	// GetEventRecord retrieves a single pushed event instance by its UUID.
	// Returns the event record with its payload, metadata, labels, and aggregated
	// delivery statistics (webhook_count, successful/failed/pending counts).
	// This is different from GetEvent which returns an event type definition by name.
	// Errors: NOT_FOUND if the event_id does not exist.
	// Errors: INVALID_ARGUMENT if the event_id is not a valid UUID.
	GetEventRecord(context.Context, *connect.Request[proto.GetEventRecordRequest]) (*connect.Response[proto.GetEventRecordResponse], error)
	// RePushEvent replays a single previously pushed event as if it were pushed fresh.
	// Loads the original event record and re-pushes through the standard PushEvent pipeline.
	// Errors: NOT_FOUND if the event_id does not exist.
	// Errors: INVALID_ARGUMENT if the event_id is not a valid UUID.
	RePushEvent(context.Context, *connect.Request[proto.RePushEventRequest]) (*connect.Response[proto.RePushEventResponse], error)
	// RePushEvents executes a deterministic batch re-push of events whose IDs were
	// previously snapshotted via ListEventReports with prepare_repush=true.
	// Each event is re-pushed as if it were pushed fresh: new event_id, current schema validation.
	// The batch is processed asynchronously via a River job; poll GetRepushStatus for progress.
	// Errors: NOT_FOUND if the repush_id does not exist or has expired.
	// Errors: FAILED_PRECONDITION if the batch is not in 'pending' status.
	RePushEvents(context.Context, *connect.Request[proto.RePushEventsRequest]) (*connect.Response[proto.RePushEventsResponse], error)
	// GetRepushStatus returns the current progress of a batch re-push operation.
	// Errors: NOT_FOUND if the repush_id does not exist or has expired.
	GetRepushStatus(context.Context, *connect.Request[proto.GetRepushStatusRequest]) (*connect.Response[proto.GetRepushStatusResponse], error)
	// CancelRepush aborts a batch re-push that is pending or in progress.
	// Items already processed are not rolled back.
	// Errors: NOT_FOUND if the repush_id does not exist.
	// Errors: FAILED_PRECONDITION if the batch is already completed or cancelled.
	CancelRepush(context.Context, *connect.Request[proto.CancelRepushRequest]) (*connect.Response[proto.CancelRepushResponse], error)
}

type EventServiceHandler interface {
	// RegisterEvent creates a new event type definition.
	// If a JSON schema is provided, all future PushEvent payloads for this event
	// are validated against it. The event name is the primary identifier (not a UUID).
	// Errors: ALREADY_EXISTS if an event with the same name already exists.
	RegisterEvent(context.Context, *connect.Request[proto.RegisterEventRequest]) (*connect.Response[proto.RegisterEventResponse], error)
	// ListEvents returns all registered event types, optionally filtered to active-only.
	// Results are paginated.
	ListEvents(context.Context, *connect.Request[proto.ListEventsRequest]) (*connect.Response[proto.ListEventsResponse], error)
	// UpdateEvent modifies an existing event type's description, schema, metadata, or active flag.
	// Updating the schema does not retroactively validate previously pushed events.
	// Errors: NOT_FOUND if the event name does not exist.
	UpdateEvent(context.Context, *connect.Request[proto.UpdateEventRequest]) (*connect.Response[proto.UpdateEventResponse], error)
	// DeleteEvent permanently removes an event type definition.
	// Existing subscriptions referencing this event name are not automatically deleted.
	// Errors: NOT_FOUND if the event name does not exist.
	DeleteEvent(context.Context, *connect.Request[proto.DeleteEventRequest]) (*connect.Response[proto.DeleteEventResponse], error)
	// GetEvent returns a single event type by name, including its schema and auto-generated sample payload.
	// Errors: NOT_FOUND if the event name does not exist.
	GetEvent(context.Context, *connect.Request[proto.GetEventRequest]) (*connect.Response[proto.GetEventResponse], error)
	// PushEvent emits an event instance. This is the primary ingestion endpoint.
	// On success, the event is persisted and a background job is enqueued to fan out
	// deliveries to all matching subscriptions (by namespace + event_name + label_filters).
	// The response returns immediately with the event_id; delivery happens asynchronously.
	// If the event type has a JSON schema, the payload is validated before acceptance.
	// Errors: INVALID_ARGUMENT if the payload fails schema validation.
	// Errors: NOT_FOUND if the event name is not registered.
	PushEvent(context.Context, *connect.Request[proto.PushEventRequest]) (*connect.Response[proto.PushEventResponse], error)
	// ListEventReports returns pushed event instances (not type definitions) for a namespace,
	// ordered by created_at descending. Each report includes delivery stats
	// (webhook_count, successful/failed/pending counts). Paginated, max 1000 per page.
	ListEventReports(context.Context, *connect.Request[proto.ListEventReportsRequest]) (*connect.Response[proto.ListEventReportsResponse], error)
	// GetEventRecord retrieves a single pushed event instance by its UUID.
	// Returns the event record with its payload, metadata, labels, and aggregated
	// delivery statistics (webhook_count, successful/failed/pending counts).
	// This is different from GetEvent which returns an event type definition by name.
	// Errors: NOT_FOUND if the event_id does not exist.
	// Errors: INVALID_ARGUMENT if the event_id is not a valid UUID.
	GetEventRecord(context.Context, *connect.Request[proto.GetEventRecordRequest]) (*connect.Response[proto.GetEventRecordResponse], error)
	// RePushEvent replays a single previously pushed event as if it were pushed fresh.
	// Loads the original event record and re-pushes through the standard PushEvent pipeline.
	// Errors: NOT_FOUND if the event_id does not exist.
	// Errors: INVALID_ARGUMENT if the event_id is not a valid UUID.
	RePushEvent(context.Context, *connect.Request[proto.RePushEventRequest]) (*connect.Response[proto.RePushEventResponse], error)
	// RePushEvents executes a deterministic batch re-push of events whose IDs were
	// previously snapshotted via ListEventReports with prepare_repush=true.
	// Each event is re-pushed as if it were pushed fresh: new event_id, current schema validation.
	// The batch is processed asynchronously via a River job; poll GetRepushStatus for progress.
	// Errors: NOT_FOUND if the repush_id does not exist or has expired.
	// Errors: FAILED_PRECONDITION if the batch is not in 'pending' status.
	RePushEvents(context.Context, *connect.Request[proto.RePushEventsRequest]) (*connect.Response[proto.RePushEventsResponse], error)
	// GetRepushStatus returns the current progress of a batch re-push operation.
	// Errors: NOT_FOUND if the repush_id does not exist or has expired.
	GetRepushStatus(context.Context, *connect.Request[proto.GetRepushStatusRequest]) (*connect.Response[proto.GetRepushStatusResponse], error)
	// CancelRepush aborts a batch re-push that is pending or in progress.
	// Items already processed are not rolled back.
	// Errors: NOT_FOUND if the repush_id does not exist.
	// Errors: FAILED_PRECONDITION if the batch is already completed or cancelled.
	CancelRepush(context.Context, *connect.Request[proto.CancelRepushRequest]) (*connect.Response[proto.CancelRepushResponse], error)
}

type HealthServiceClient interface {
	// GetWebhookHealth returns health status and detailed metrics for a single webhook:
	// total/successful/failed deliveries, consecutive failures, success rate, avg response time,
	// and error category breakdown (client/server/timeout/network errors).
	// Returns HEALTH_UNSPECIFIED with no metrics if the webhook has no delivery history.
	GetWebhookHealth(context.Context, *connect.Request[proto.GetWebhookHealthRequest]) (*connect.Response[proto.GetWebhookHealthResponse], error)
	// ListWebhooksByHealth returns all webhooks matching a given health status.
	// Useful for finding degraded or unhealthy endpoints. Paginated.
	ListWebhooksByHealth(context.Context, *connect.Request[proto.ListWebhooksByHealthRequest]) (*connect.Response[proto.ListWebhooksByHealthResponse], error)
	// GetHealthSummary returns aggregate counts of webhooks by health status
	// (healthy, degraded, unhealthy, unknown) across all namespaces.
	GetHealthSummary(context.Context, *connect.Request[proto.GetHealthSummaryRequest]) (*connect.Response[proto.GetHealthSummaryResponse], error)
}

type HealthServiceHandler interface {
	// GetWebhookHealth returns health status and detailed metrics for a single webhook:
	// total/successful/failed deliveries, consecutive failures, success rate, avg response time,
	// and error category breakdown (client/server/timeout/network errors).
	// Returns HEALTH_UNSPECIFIED with no metrics if the webhook has no delivery history.
	GetWebhookHealth(context.Context, *connect.Request[proto.GetWebhookHealthRequest]) (*connect.Response[proto.GetWebhookHealthResponse], error)
	// ListWebhooksByHealth returns all webhooks matching a given health status.
	// Useful for finding degraded or unhealthy endpoints. Paginated.
	ListWebhooksByHealth(context.Context, *connect.Request[proto.ListWebhooksByHealthRequest]) (*connect.Response[proto.ListWebhooksByHealthResponse], error)
	// GetHealthSummary returns aggregate counts of webhooks by health status
	// (healthy, degraded, unhealthy, unknown) across all namespaces.
	GetHealthSummary(context.Context, *connect.Request[proto.GetHealthSummaryRequest]) (*connect.Response[proto.GetHealthSummaryResponse], error)
}

type SubscriptionServiceClient interface {
	// CreateSubscription links a webhook to an event name in a namespace.
	// Optionally configure per-subscription headers, HTTP method override, timeout override,
	// payload transformation (Go template), and label filters for selective matching.
	// Errors: ALREADY_EXISTS if the webhook is already subscribed to this event in this namespace.
	// Errors: NOT_FOUND if the webhook_id does not exist.
	CreateSubscription(context.Context, *connect.Request[proto.CreateSubscriptionRequest]) (*connect.Response[proto.CreateSubscriptionResponse], error)
	// GetSubscription returns a single subscription by ID.
	// Errors: NOT_FOUND if the subscription_id does not exist in the given namespace.
	GetSubscription(context.Context, *connect.Request[proto.GetSubscriptionRequest]) (*connect.Response[proto.GetSubscriptionResponse], error)
	// ListSubscriptions returns subscriptions in a namespace, optionally filtered
	// by webhook_id or event_name. Results are paginated.
	ListSubscriptions(context.Context, *connect.Request[proto.ListSubscriptionsRequest]) (*connect.Response[proto.ListSubscriptionsResponse], error)
	// UpdateSubscription modifies a subscription's headers, method, timeout,
	// transform settings, or label filters. Only non-zero fields are applied.
	// Errors: NOT_FOUND if the subscription does not exist.
	UpdateSubscription(context.Context, *connect.Request[proto.UpdateSubscriptionRequest]) (*connect.Response[proto.UpdateSubscriptionResponse], error)
	// DeleteSubscription permanently removes a subscription.
	// Existing in-flight deliveries for this subscription are not cancelled.
	// Errors: NOT_FOUND if the subscription does not exist.
	DeleteSubscription(context.Context, *connect.Request[proto.DeleteSubscriptionRequest]) (*connect.Response[proto.DeleteSubscriptionResponse], error)
	// TestSubscriptionTemplate renders a Go template against the sample payload of the
	// given event type. Returns the transformed output string. Use this to validate
	// templates before saving them on a subscription.
	// Errors: INVALID_ARGUMENT if the template fails to parse or execute.
	// Errors: NOT_FOUND if the event_name does not exist.
	TestSubscriptionTemplate(context.Context, *connect.Request[proto.TestSubscriptionTemplateRequest]) (*connect.Response[proto.TestSubscriptionTemplateResponse], error)
}

type SubscriptionServiceHandler interface {
	// CreateSubscription links a webhook to an event name in a namespace.
	// Optionally configure per-subscription headers, HTTP method override, timeout override,
	// payload transformation (Go template), and label filters for selective matching.
	// Errors: ALREADY_EXISTS if the webhook is already subscribed to this event in this namespace.
	// Errors: NOT_FOUND if the webhook_id does not exist.
	CreateSubscription(context.Context, *connect.Request[proto.CreateSubscriptionRequest]) (*connect.Response[proto.CreateSubscriptionResponse], error)
	// GetSubscription returns a single subscription by ID.
	// Errors: NOT_FOUND if the subscription_id does not exist in the given namespace.
	GetSubscription(context.Context, *connect.Request[proto.GetSubscriptionRequest]) (*connect.Response[proto.GetSubscriptionResponse], error)
	// ListSubscriptions returns subscriptions in a namespace, optionally filtered
	// by webhook_id or event_name. Results are paginated.
	ListSubscriptions(context.Context, *connect.Request[proto.ListSubscriptionsRequest]) (*connect.Response[proto.ListSubscriptionsResponse], error)
	// UpdateSubscription modifies a subscription's headers, method, timeout,
	// transform settings, or label filters. Only non-zero fields are applied.
	// Errors: NOT_FOUND if the subscription does not exist.
	UpdateSubscription(context.Context, *connect.Request[proto.UpdateSubscriptionRequest]) (*connect.Response[proto.UpdateSubscriptionResponse], error)
	// DeleteSubscription permanently removes a subscription.
	// Existing in-flight deliveries for this subscription are not cancelled.
	// Errors: NOT_FOUND if the subscription does not exist.
	DeleteSubscription(context.Context, *connect.Request[proto.DeleteSubscriptionRequest]) (*connect.Response[proto.DeleteSubscriptionResponse], error)
	// TestSubscriptionTemplate renders a Go template against the sample payload of the
	// given event type. Returns the transformed output string. Use this to validate
	// templates before saving them on a subscription.
	// Errors: INVALID_ARGUMENT if the template fails to parse or execute.
	// Errors: NOT_FOUND if the event_name does not exist.
	TestSubscriptionTemplate(context.Context, *connect.Request[proto.TestSubscriptionTemplateRequest]) (*connect.Response[proto.TestSubscriptionTemplateResponse], error)
}

type UnimplementedDeliveryServiceHandler struct{}

type UnimplementedEventServiceHandler struct{}

type UnimplementedHealthServiceHandler struct{}

type UnimplementedSubscriptionServiceHandler struct{}

type UnimplementedWebhookServiceHandler struct{}

type WebhookServiceClient interface {
	// RegisterWebhook creates a new webhook registration.
	// Accepts a target URL, a list of event names, and optional HTTP configuration.
	// Subscriptions are created automatically for each event in the events list.
	// Returns the generated webhook_id and created_at timestamp.
	// Errors: ALREADY_EXISTS if the URL is already registered in the same namespace.
	RegisterWebhook(context.Context, *connect.Request[proto.RegisterWebhookRequest]) (*connect.Response[proto.RegisterWebhookResponse], error)
	// UnregisterWebhook permanently deletes a webhook and all its subscriptions.
	// Associated delivery records are also cascade-deleted.
	// Errors: NOT_FOUND if the webhook_id does not exist in the given namespace.
	UnregisterWebhook(context.Context, *connect.Request[proto.UnregisterWebhookRequest]) (*connect.Response[proto.UnregisterWebhookResponse], error)
	// ListWebhooks returns webhooks for a namespace with optional filters.
	// Supports filtering by event name, active status, or specific webhook_id.
	// Results are paginated (default limit: 50). Each webhook includes its current health status.
	ListWebhooks(context.Context, *connect.Request[proto.ListWebhooksRequest]) (*connect.Response[proto.ListWebhooksResponse], error)
	// UpdateWebhookConfig patches one or more fields on an existing webhook.
	// Only non-zero fields in WebhookUpdateFields are applied. Updating events replaces
	// the full subscription set: removed events have their subscriptions deleted,
	// new events get subscriptions created.
	// Errors: NOT_FOUND if the webhook does not exist.
	UpdateWebhookConfig(context.Context, *connect.Request[proto.UpdateWebhookConfigRequest]) (*connect.Response[proto.UpdateWebhookConfigResponse], error)
	// PauseWebhook sets a webhook to inactive. Paused webhooks are skipped during
	// event fan-out -- no new deliveries are created for them. Existing in-flight
	// deliveries are not cancelled.
	// Errors: NOT_FOUND if the webhook does not exist.
	PauseWebhook(context.Context, *connect.Request[proto.PauseWebhookRequest]) (*connect.Response[proto.PauseWebhookResponse], error)
	// ResumeWebhook re-activates a paused webhook. Future events will again create
	// deliveries for this webhook. Events pushed while the webhook was paused are not retroactively delivered.
	// Errors: NOT_FOUND if the webhook does not exist.
	ResumeWebhook(context.Context, *connect.Request[proto.ResumeWebhookRequest]) (*connect.Response[proto.ResumeWebhookResponse], error)
	// GetNamespaceStats returns aggregate delivery statistics for a namespace:
	// total/active webhooks, total/successful/failed/pending deliveries, and success rate.
	GetNamespaceStats(context.Context, *connect.Request[proto.GetNamespaceStatsRequest]) (*connect.Response[proto.GetNamespaceStatsResponse], error)
	// GetTemplateFunctions returns the list of Go template functions available for
	// payload transformation in subscriptions. Each entry includes the function name
	// and a description of its behavior.
	GetTemplateFunctions(context.Context, *connect.Request[proto.GetTemplateFunctionsRequest]) (*connect.Response[proto.GetTemplateFunctionsResponse], error)
}

type WebhookServiceHandler interface {
	// RegisterWebhook creates a new webhook registration.
	// Accepts a target URL, a list of event names, and optional HTTP configuration.
	// Subscriptions are created automatically for each event in the events list.
	// Returns the generated webhook_id and created_at timestamp.
	// Errors: ALREADY_EXISTS if the URL is already registered in the same namespace.
	RegisterWebhook(context.Context, *connect.Request[proto.RegisterWebhookRequest]) (*connect.Response[proto.RegisterWebhookResponse], error)
	// UnregisterWebhook permanently deletes a webhook and all its subscriptions.
	// Associated delivery records are also cascade-deleted.
	// Errors: NOT_FOUND if the webhook_id does not exist in the given namespace.
	UnregisterWebhook(context.Context, *connect.Request[proto.UnregisterWebhookRequest]) (*connect.Response[proto.UnregisterWebhookResponse], error)
	// ListWebhooks returns webhooks for a namespace with optional filters.
	// Supports filtering by event name, active status, or specific webhook_id.
	// Results are paginated (default limit: 50). Each webhook includes its current health status.
	ListWebhooks(context.Context, *connect.Request[proto.ListWebhooksRequest]) (*connect.Response[proto.ListWebhooksResponse], error)
	// UpdateWebhookConfig patches one or more fields on an existing webhook.
	// Only non-zero fields in WebhookUpdateFields are applied. Updating events replaces
	// the full subscription set: removed events have their subscriptions deleted,
	// new events get subscriptions created.
	// Errors: NOT_FOUND if the webhook does not exist.
	UpdateWebhookConfig(context.Context, *connect.Request[proto.UpdateWebhookConfigRequest]) (*connect.Response[proto.UpdateWebhookConfigResponse], error)
	// PauseWebhook sets a webhook to inactive. Paused webhooks are skipped during
	// event fan-out -- no new deliveries are created for them. Existing in-flight
	// deliveries are not cancelled.
	// Errors: NOT_FOUND if the webhook does not exist.
	PauseWebhook(context.Context, *connect.Request[proto.PauseWebhookRequest]) (*connect.Response[proto.PauseWebhookResponse], error)
	// ResumeWebhook re-activates a paused webhook. Future events will again create
	// deliveries for this webhook. Events pushed while the webhook was paused are not retroactively delivered.
	// Errors: NOT_FOUND if the webhook does not exist.
	ResumeWebhook(context.Context, *connect.Request[proto.ResumeWebhookRequest]) (*connect.Response[proto.ResumeWebhookResponse], error)
	// GetNamespaceStats returns aggregate delivery statistics for a namespace:
	// total/active webhooks, total/successful/failed/pending deliveries, and success rate.
	GetNamespaceStats(context.Context, *connect.Request[proto.GetNamespaceStatsRequest]) (*connect.Response[proto.GetNamespaceStatsResponse], error)
	// GetTemplateFunctions returns the list of Go template functions available for
	// payload transformation in subscriptions. Each entry includes the function name
	// and a description of its behavior.
	GetTemplateFunctions(context.Context, *connect.Request[proto.GetTemplateFunctionsRequest]) (*connect.Response[proto.GetTemplateFunctionsResponse], error)
}