proto

type BatchJobStatus struct {

	// Current status of the batch job.
	// @example "processing"
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Total number of items in the batch.
	Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// Number of items successfully processed so far.
	Processed int32 `protobuf:"varint,3,opt,name=processed,proto3" json:"processed,omitempty"`
	// Number of items that failed processing.
	Failed int32 `protobuf:"varint,4,opt,name=failed,proto3" json:"failed,omitempty"`
	// When the batch job was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// When the batch job expires (created_at + ttl_seconds).
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

type CancelRepushRequest struct {

	// Batch ID to cancel.
	// @required
	RepushId string `protobuf:"bytes,1,opt,name=repush_id,json=repushId,proto3" json:"repush_id,omitempty"`
	// contains filtered or unexported fields
}

type CancelRepushResponse struct {

	// Current status after cancellation (will be "cancelled").
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type CancelRetryRequest struct {

	// Batch ID to cancel.
	// @required
	RetryId string `protobuf:"bytes,1,opt,name=retry_id,json=retryId,proto3" json:"retry_id,omitempty"`
	// contains filtered or unexported fields
}

type CancelRetryResponse struct {

	// Current status after cancellation (will be "cancelled").
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type CreateSubscriptionRequest struct {

	// UUID of the webhook to subscribe. Required.
	// The webhook must exist in the specified namespace.
	// @example "550e8400-e29b-41d4-a716-446655440000"
	WebhookId string `protobuf:"bytes,1,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	// Event type name to subscribe to. Required.
	// @example "order.created"
	EventName string `protobuf:"bytes,2,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	// Namespace for the subscription. Required.
	// Must match the webhook's namespace.
	// @example "production"
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Per-subscription HTTP headers. Optional.
	// Merged with (and overrides) webhook-level headers on delivery.
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// HTTP method override. Optional. Default: "POST".
	Method string `protobuf:"bytes,5,opt,name=method,proto3" json:"method,omitempty"`
	// Timeout override in seconds. Optional. Default: use webhook's timeout.
	Timeout int32 `protobuf:"varint,6,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Enable Go template payload transformation. Default: false.
	TransformEnabled bool `protobuf:"varint,7,opt,name=transform_enabled,json=transformEnabled,proto3" json:"transform_enabled,omitempty"`
	// Go template for payload transformation. Only used when transform_enabled is true.
	// Use TestSubscriptionTemplate to validate before saving.
	TransformTemplate string `protobuf:"bytes,8,opt,name=transform_template,json=transformTemplate,proto3" json:"transform_template,omitempty"`
	// Label filters for selective event matching. Optional.
	// Only events with labels matching all key-value pairs will trigger this subscription.
	// @example {"region": "us-east"}
	LabelFilters map[string]string `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateSubscriptionResponse struct {

	// Server-generated UUID of the new subscription.
	// @example "7c9e6679-7425-40de-944b-e07fc1f90ae7"
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// When the subscription was created.
	// @example "2025-01-15T10:30:00Z"
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type DeleteEventRequest struct {

	// Event name to delete. Required.
	// @example "order.created"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteSubscriptionRequest struct {

	// UUID of the subscription to delete. Required.
	// @example "7c9e6679-7425-40de-944b-e07fc1f90ae7"
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// Namespace the subscription belongs to. Required.
	// @example "production"
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

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

type DeliveryAttempt struct {

	// Server-generated UUID for this attempt.
	// @example "a-110e8400-e29b-41d4-a716-446655440000"
	AttemptId string `protobuf:"bytes,1,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	// UUID of the parent delivery this attempt belongs to.
	DeliveryId string `protobuf:"bytes,2,opt,name=delivery_id,json=deliveryId,proto3" json:"delivery_id,omitempty"`
	// UUID of the target webhook.
	WebhookId string `protobuf:"bytes,3,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	// Whether this attempt resulted in a successful delivery
	// (response code matched expected_status_codes).
	// @example true
	Success bool `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	// Round-trip time in milliseconds from sending the request to receiving
	// the full response (or timeout/error). 0 if no connection was established.
	// @example 245
	ResponseTime int32 `protobuf:"varint,5,opt,name=response_time,json=responseTime,proto3" json:"response_time,omitempty"`
	// HTTP response status code. 0 if no response was received
	// (timeout, connection refused, DNS error, etc.).
	// @example 200
	ResponseCode int32 `protobuf:"varint,6,opt,name=response_code,json=responseCode,proto3" json:"response_code,omitempty"`
	// Error message describing the failure. Empty string on success.
	// Contains the raw error from the HTTP client (e.g., "context deadline exceeded",
	// "connection refused", "no such host").
	ErrorMessage string `protobuf:"bytes,7,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Classified error category for this attempt.
	// Values: "success", "client_error", "server_error", "timeout",
	// "connection_refused", "network_error", "dns_error", "tls_error",
	// "unexpected_status", "unknown".
	// @example "success"
	ErrorCategory string `protobuf:"bytes,8,opt,name=error_category,json=errorCategory,proto3" json:"error_category,omitempty"`
	// When this attempt was made.
	// @example "2025-01-15T10:30:05Z"
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

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(ctx context.Context, in *GetDeliveryStatusRequest, opts ...grpc.CallOption) (*GetDeliveryStatusResponse, error)
	// ListDeliveries returns delivery records for a namespace, optionally filtered
	// by webhook_id or event_id. Ordered by created_at descending. Paginated.
	ListDeliveries(ctx context.Context, in *ListDeliveriesRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *RetryDeliveryRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *GetDeliveryAttemptsRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *RetryDeliveriesRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *GetRetryStatusRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *CancelRetryRequest, opts ...grpc.CallOption) (*CancelRetryResponse, error)
}

type DeliveryServiceServer 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, *GetDeliveryStatusRequest) (*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, *ListDeliveriesRequest) (*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, *RetryDeliveryRequest) (*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, *GetDeliveryAttemptsRequest) (*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, *RetryDeliveriesRequest) (*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, *GetRetryStatusRequest) (*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, *CancelRetryRequest) (*CancelRetryResponse, error)
	// contains filtered or unexported methods
}

type EventReport struct {

	// Server-generated UUID of the event instance.
	EventId string `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// Namespace the event was pushed into.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Event type name.
	EventName string `protobuf:"bytes,3,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	// The original payload that was pushed.
	Payload *structpb.Struct `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// Metadata attached when the event was pushed.
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// When the event was pushed.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// TTL in seconds that was specified when pushing. 0 if no TTL was set.
	TtlSeconds int64 `protobuf:"varint,7,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`
	// Number of webhooks that received (or will receive) a delivery for this event.
	WebhookCount int32 `protobuf:"varint,8,opt,name=webhook_count,json=webhookCount,proto3" json:"webhook_count,omitempty"`
	// Number of deliveries that completed successfully (terminal SUCCESS status).
	SuccessfulDeliveries int32 `protobuf:"varint,9,opt,name=successful_deliveries,json=successfulDeliveries,proto3" json:"successful_deliveries,omitempty"`
	// Number of deliveries that failed permanently (terminal FAILED or EXPIRED status).
	FailedDeliveries int32 `protobuf:"varint,10,opt,name=failed_deliveries,json=failedDeliveries,proto3" json:"failed_deliveries,omitempty"`
	// Number of deliveries still in progress (PENDING, SENDING, or RETRYING status).
	PendingDeliveries int32 `protobuf:"varint,11,opt,name=pending_deliveries,json=pendingDeliveries,proto3" json:"pending_deliveries,omitempty"`
	// Whether the event payload matched the registered JSON schema at push time.
	// Always true when no schema is registered for the event type.
	// When false, the event was still accepted and delivered, but the payload
	// did not conform to the schema. Check PushEventResponse.warnings for details.
	SchemaValid bool `protobuf:"varint,12,opt,name=schema_valid,json=schemaValid,proto3" json:"schema_valid,omitempty"`
	// contains filtered or unexported fields
}

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(ctx context.Context, in *RegisterEventRequest, opts ...grpc.CallOption) (*RegisterEventResponse, error)
	// ListEvents returns all registered event types, optionally filtered to active-only.
	// Results are paginated.
	ListEvents(ctx context.Context, in *ListEventsRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *UpdateEventRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *DeleteEventRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *GetEventRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *PushEventRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *ListEventReportsRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *GetEventRecordRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *RePushEventRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *RePushEventsRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *GetRepushStatusRequest, opts ...grpc.CallOption) (*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(ctx context.Context, in *CancelRepushRequest, opts ...grpc.CallOption) (*CancelRepushResponse, error)
}

type EventServiceServer 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, *RegisterEventRequest) (*RegisterEventResponse, error)
	// ListEvents returns all registered event types, optionally filtered to active-only.
	// Results are paginated.
	ListEvents(context.Context, *ListEventsRequest) (*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, *UpdateEventRequest) (*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, *DeleteEventRequest) (*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, *GetEventRequest) (*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, *PushEventRequest) (*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, *ListEventReportsRequest) (*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, *GetEventRecordRequest) (*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, *RePushEventRequest) (*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, *RePushEventsRequest) (*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, *GetRepushStatusRequest) (*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, *CancelRepushRequest) (*CancelRepushResponse, error)
	// contains filtered or unexported methods
}

type EventSubscription struct {

	// Server-generated UUID for this subscription.
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// UUID of the webhook that receives deliveries through this subscription.
	WebhookId string `protobuf:"bytes,2,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	// Event type name this subscription listens for.
	EventName string `protobuf:"bytes,3,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	// Namespace this subscription belongs to.
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Per-subscription HTTP headers added to delivery requests.
	// These are merged with (and override) the webhook's headers.
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// HTTP method override for deliveries through this subscription.
	// Default: "POST". Allows using PUT, PATCH, etc. per subscription.
	Method string `protobuf:"bytes,6,opt,name=method,proto3" json:"method,omitempty"`
	// Per-subscription timeout override in seconds.
	// When set (> 0), overrides the webhook's request_timeout_seconds for this subscription.
	Timeout int32 `protobuf:"varint,7,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Whether Go template payload transformation is enabled for this subscription.
	TransformEnabled bool `protobuf:"varint,8,opt,name=transform_enabled,json=transformEnabled,proto3" json:"transform_enabled,omitempty"`
	// Go template string for payload transformation. Only used when transform_enabled is true.
	// The template receives the event payload as its data context. Available functions
	// can be listed via WebhookService.GetTemplateFunctions.
	TransformTemplate string `protobuf:"bytes,9,opt,name=transform_template,json=transformTemplate,proto3" json:"transform_template,omitempty"`
	// When this subscription was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// When this subscription was last modified.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Label filters for selective event matching. When set, only events whose labels
	// contain all key-value pairs in this map will trigger deliveries through this subscription.
	// Uses AND logic: every filter must match. Empty map matches all events.
	LabelFilters map[string]string `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetDeliveryAttemptsRequest struct {

	// UUID of the delivery to get attempts for. Required.
	// @example "d-550e8400-e29b-41d4-a716-446655440000"
	DeliveryId string `protobuf:"bytes,1,opt,name=delivery_id,json=deliveryId,proto3" json:"delivery_id,omitempty"`
	// contains filtered or unexported fields
}

type GetDeliveryAttemptsResponse struct {

	// Delivery attempts ordered by timestamp ascending (oldest first).
	// The last element reflects the most recent attempt.
	Attempts []*DeliveryAttempt `protobuf:"bytes,1,rep,name=attempts,proto3" json:"attempts,omitempty"`
	// contains filtered or unexported fields
}

type GetDeliveryStatusRequest struct {

	// UUID of the delivery to retrieve. Required.
	// @example "d-550e8400-e29b-41d4-a716-446655440000"
	DeliveryId string `protobuf:"bytes,1,opt,name=delivery_id,json=deliveryId,proto3" json:"delivery_id,omitempty"`
	// Namespace the delivery belongs to. Required.
	// @example "production"
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type GetDeliveryStatusResponse struct {

	// Full delivery details including request/response bodies and error info.
	Delivery *WebhookDelivery `protobuf:"bytes,1,opt,name=delivery,proto3" json:"delivery,omitempty"`
	// contains filtered or unexported fields
}

type GetEventRecordRequest struct {

	// UUID of the event instance. Required.
	// @example "e-550e8400-e29b-41d4-a716-446655440000"
	EventId string `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

type GetEventRecordResponse struct {

	// The event instance with aggregated delivery statistics.
	Event *EventReport `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// Labels attached when the event was pushed.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// When the event expires (based on TTL). Zero value if no TTL was set.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

type GetEventRequest struct {

	// Event name to look up. Required.
	// @example "order.created"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetEventResponse struct {

	// The event type definition, including schema and sample_payload.
	Event *RegisteredEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

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

type GetHealthSummaryResponse struct {

	// Aggregate health counts across all namespaces.
	Summary *HealthSummary `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

type GetNamespaceStatsRequest struct {

	// Namespace to get statistics for. Required.
	// @example "production"
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type GetNamespaceStatsResponse struct {

	// The namespace these stats apply to.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Aggregate statistics for the namespace.
	Stats *NamespaceStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

type GetRepushStatusRequest struct {

	// Batch ID returned by RePushEvents or ListEventReports.
	// @required
	RepushId string `protobuf:"bytes,1,opt,name=repush_id,json=repushId,proto3" json:"repush_id,omitempty"`
	// contains filtered or unexported fields
}

type GetRepushStatusResponse struct {

	// Full batch job status.
	Batch *BatchJobStatus `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

type GetRetryStatusRequest struct {

	// Batch ID returned by RetryDeliveries or ListDeliveries.
	// @required
	RetryId string `protobuf:"bytes,1,opt,name=retry_id,json=retryId,proto3" json:"retry_id,omitempty"`
	// contains filtered or unexported fields
}

type GetRetryStatusResponse struct {

	// Full batch job status.
	Batch *BatchJobStatus `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

type GetSubscriptionRequest struct {

	// UUID of the subscription to retrieve. Required.
	// @example "7c9e6679-7425-40de-944b-e07fc1f90ae7"
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// Namespace the subscription belongs to. Required.
	// @example "production"
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type GetSubscriptionResponse struct {

	// Full subscription details.
	Subscription *EventSubscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

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

type GetTemplateFunctionsResponse struct {

	// Available template functions with names and descriptions.
	Functions []*TemplateFunction `protobuf:"bytes,1,rep,name=functions,proto3" json:"functions,omitempty"`
	// Total number of available functions.
	// @example 42
	TotalCount int32 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

type GetWebhookHealthRequest struct {

	// UUID of the webhook. Required.
	// @example "550e8400-e29b-41d4-a716-446655440000"
	WebhookId string `protobuf:"bytes,1,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	// Namespace the webhook belongs to. Required.
	// @example "production"
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type GetWebhookHealthResponse struct {

	// UUID of the webhook.
	WebhookId string `protobuf:"bytes,3,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	// Computed health status based on success_rate and consecutive_failures.
	// Returns HEALTH_UNSPECIFIED if the webhook has no delivery history.
	// @example "HEALTHY"
	Health WebhookHealth `protobuf:"varint,4,opt,name=health,proto3,enum=webhook.WebhookHealth" json:"health,omitempty"`
	// Detailed health metrics. Null if the webhook has no delivery history.
	Metrics *WebhookHealthMetrics `protobuf:"bytes,5,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

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(ctx context.Context, in *GetWebhookHealthRequest, opts ...grpc.CallOption) (*GetWebhookHealthResponse, error)
	// ListWebhooksByHealth returns all webhooks matching a given health status.
	// Useful for finding degraded or unhealthy endpoints. Paginated.
	ListWebhooksByHealth(ctx context.Context, in *ListWebhooksByHealthRequest, opts ...grpc.CallOption) (*ListWebhooksByHealthResponse, error)
	// GetHealthSummary returns aggregate counts of webhooks by health status
	// (healthy, degraded, unhealthy, unknown) across all namespaces.
	GetHealthSummary(ctx context.Context, in *GetHealthSummaryRequest, opts ...grpc.CallOption) (*GetHealthSummaryResponse, error)
}

type HealthServiceServer 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, *GetWebhookHealthRequest) (*GetWebhookHealthResponse, error)
	// ListWebhooksByHealth returns all webhooks matching a given health status.
	// Useful for finding degraded or unhealthy endpoints. Paginated.
	ListWebhooksByHealth(context.Context, *ListWebhooksByHealthRequest) (*ListWebhooksByHealthResponse, error)
	// GetHealthSummary returns aggregate counts of webhooks by health status
	// (healthy, degraded, unhealthy, unknown) across all namespaces.
	GetHealthSummary(context.Context, *GetHealthSummaryRequest) (*GetHealthSummaryResponse, error)
	// contains filtered or unexported methods
}

type HealthSummary struct {

	// Number of webhooks in HEALTHY state (>90% success rate, <3 consecutive failures).
	// @example 45
	HealthyCount int32 `protobuf:"varint,1,opt,name=healthy_count,json=healthyCount,proto3" json:"healthy_count,omitempty"`
	// Number of webhooks in DEGRADED state (50-90% success rate or 3-9 consecutive failures).
	// @example 3
	DegradedCount int32 `protobuf:"varint,2,opt,name=degraded_count,json=degradedCount,proto3" json:"degraded_count,omitempty"`
	// Number of webhooks in UNHEALTHY state (<50% success rate or 10+ consecutive failures).
	// @example 1
	UnhealthyCount int32 `protobuf:"varint,3,opt,name=unhealthy_count,json=unhealthyCount,proto3" json:"unhealthy_count,omitempty"`
	// Number of webhooks with no delivery history (HEALTH_UNSPECIFIED).
	// @example 2
	UnknownCount int32 `protobuf:"varint,4,opt,name=unknown_count,json=unknownCount,proto3" json:"unknown_count,omitempty"`
	// Total number of webhooks (sum of all categories above).
	// @example 51
	TotalCount int32 `protobuf:"varint,5,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

type ListDeliveriesRequest struct {

	// Namespace to list deliveries from. Required.
	// @example "production"
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Filter by webhook UUID. Optional.
	// @example "550e8400-e29b-41d4-a716-446655440000"
	WebhookId string `protobuf:"bytes,2,opt,name=webhook_id,json=webhookId,proto3" json:"webhook_id,omitempty"`
	// Filter by event UUID. Optional.
	EventId string `protobuf:"bytes,3,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// Pagination parameters. Default: limit=50, offset=0.
	// @example {"limit": 20}
	Pagination *PaginationRequest `protobuf:"bytes,4,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// Filter by delivery status. Optional.
	// @example "failed"
	Status *string `protobuf:"bytes,5,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// Filter by error classification. Optional.
	// @example "server_error"
	ErrorCategory *string `protobuf:"bytes,6,opt,name=error_category,json=errorCategory,proto3,oneof" json:"error_category,omitempty"`
	// Filter by subscription UUID. Optional.
	SubscriptionId *string `protobuf:"bytes,7,opt,name=subscription_id,json=subscriptionId,proto3,oneof" json:"subscription_id,omitempty"`
	// Filter to deliveries created at or after this timestamp.
	CreatedAfter *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_after,json=createdAfter,proto3" json:"created_after,omitempty"`
	// Filter to deliveries created at or before this timestamp.
	CreatedBefore *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_before,json=createdBefore,proto3" json:"created_before,omitempty"`
	// When true, snapshot all matching delivery IDs (up to 10,000) into a
	// batch job and return a retry_id in the response. Pass that ID to
	// RetryDeliveries to retry the exact set that matched this query.
	PrepareRetry bool `protobuf:"varint,10,opt,name=prepare_retry,json=prepareRetry,proto3" json:"prepare_retry,omitempty"`
	// contains filtered or unexported fields
}

type ListDeliveriesResponse struct {

	// Deliveries matching the filter criteria, newest first.
	Deliveries []*WebhookDelivery `protobuf:"bytes,1,rep,name=deliveries,proto3" json:"deliveries,omitempty"`
	// Pagination metadata.
	Pagination *PaginationResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// Batch ID for deterministic retry. Only populated when
	// prepare_retry=true was set in the request. Pass to RetryDeliveries.
	RetryId string `protobuf:"bytes,5,opt,name=retry_id,json=retryId,proto3" json:"retry_id,omitempty"`
	// contains filtered or unexported fields
}

type ListEventReportsRequest struct {

	// Namespace to list events from. Required.
	// @example "production"
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Filter to events of this type name. Optional.
	// @example "order.created"
	EventName *string `protobuf:"bytes,2,opt,name=event_name,json=eventName,proto3,oneof" json:"event_name,omitempty"`
	// Pagination parameters. Default: limit=50, offset=0. Max limit: 1000.
	// @example {"limit": 25}
	Pagination *PaginationRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// Filter by schema validation status. When set, only events matching
	// the specified schema_valid value are returned.
	SchemaValid *bool `protobuf:"varint,6,opt,name=schema_valid,json=schemaValid,proto3,oneof" json:"schema_valid,omitempty"`
	// Filter by labels using JSONB containment. Only events whose labels
	// contain all specified key-value pairs are returned.
	// @example {"region": "us-east"}
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Filter to events created at or after this timestamp.
	CreatedAfter *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_after,json=createdAfter,proto3" json:"created_after,omitempty"`
	// Filter to events created at or before this timestamp.
	CreatedBefore *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_before,json=createdBefore,proto3" json:"created_before,omitempty"`
	// When true, snapshot all matching event IDs (up to 10,000) into a
	// batch job and return a repush_id in the response. Pass that ID to
	// RePushEvents to re-push the exact set of events that matched this query.
	PrepareRepush bool `protobuf:"varint,10,opt,name=prepare_repush,json=prepareRepush,proto3" json:"prepare_repush,omitempty"`
	// contains filtered or unexported fields
}

type ListEventReportsResponse struct {

	// Event instances ordered by created_at descending (newest first).
	Events []*EventReport `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// Pagination metadata.
	Pagination *PaginationResponse `protobuf:"bytes,5,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// Batch ID for deterministic re-push. Only populated when
	// prepare_repush=true was set in the request. Pass to RePushEvents.
	RepushId string `protobuf:"bytes,6,opt,name=repush_id,json=repushId,proto3" json:"repush_id,omitempty"`
	// contains filtered or unexported fields
}

type ListEventsRequest struct {

	// When true, only return active event types. Default: false (return all).
	// @example true
	ActiveOnly bool `protobuf:"varint,1,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	// Pagination parameters. Default: limit=50, offset=0.
	Pagination *PaginationRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

type ListEventsResponse struct {

	// Event type definitions matching the filter criteria.
	Events []*RegisteredEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// Pagination metadata.
	Pagination *PaginationResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}