grpc

package
v1.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 28, 2026 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertInternalHTTPConfig added in v0.2.0 

func ConvertInternalHTTPConfig(config *webhooks.WebhookHTTPConfig) *pb.WebhookHTTPConfig

ConvertInternalHTTPConfig converts internal WebhookHTTPConfig to protobuf WebhookHTTPConfig

func ConvertProtoHTTPConfig added in v0.2.0 

func ConvertProtoHTTPConfig(protoConfig *pb.WebhookHTTPConfig) *webhooks.WebhookHTTPConfig

ConvertProtoHTTPConfig converts protobuf WebhookHTTPConfig to internal WebhookHTTPConfig

func ConvertWebhookRegistrationToProto added in v0.2.0 

func ConvertWebhookRegistrationToProto(webhook *webhooks.WebhookRegistration) *pb.RegisteredWebhook

ConvertWebhookRegistrationToProto converts internal WebhookRegistration to protobuf RegisteredWebhook

func CreateWebhookRegistrationRequest added in v0.2.0 

func CreateWebhookRegistrationRequest(req *pb.RegisterWebhookRequest) webhooks.WebhookRegistrationRequest

CreateWebhookRegistrationRequest creates a WebhookRegistrationRequest from protobuf

Types

type WebhookServer 

type WebhookServer struct {
	pb.UnimplementedWebhookServiceServer
	pb.UnimplementedEventServiceServer
	pb.UnimplementedSubscriptionServiceServer
	pb.UnimplementedDeliveryServiceServer
	pb.UnimplementedHealthServiceServer
	// contains filtered or unexported fields
}

WebhookServer implements all gRPC services

func NewWebhookServer 

func NewWebhookServer(service webhooks.WebhookServiceInterface) *WebhookServer

NewWebhookServer creates a new WebhookServer instance

func (*WebhookServer) CancelRepush added in v0.8.0 

func (s *WebhookServer) CancelRepush(ctx context.Context, req *pb.CancelRepushRequest) (*pb.CancelRepushResponse, error)

CancelRepush aborts a pending or in-progress batch re-push.

func (*WebhookServer) CancelRetry added in v0.8.0 

func (s *WebhookServer) CancelRetry(ctx context.Context, req *pb.CancelRetryRequest) (*pb.CancelRetryResponse, error)

CancelRetry aborts a pending or in-progress batch delivery retry.

func (*WebhookServer) CreateSubscription added in v0.2.0 

func (s *WebhookServer) CreateSubscription(ctx context.Context, req *pb.CreateSubscriptionRequest) (*pb.CreateSubscriptionResponse, error)

CreateSubscription creates a new event subscription for a webhook

func (*WebhookServer) DeleteEvent 

func (s *WebhookServer) DeleteEvent(ctx context.Context, req *pb.DeleteEventRequest) (*pb.DeleteEventResponse, error)

DeleteEvent deletes an event registration

func (*WebhookServer) DeleteSubscription added in v0.2.0 

func (s *WebhookServer) DeleteSubscription(ctx context.Context, req *pb.DeleteSubscriptionRequest) (*pb.DeleteSubscriptionResponse, error)

DeleteSubscription deletes a subscription

func (*WebhookServer) GetDeliveryAttempts added in v0.2.0 

func (s *WebhookServer) GetDeliveryAttempts(ctx context.Context, req *pb.GetDeliveryAttemptsRequest) (*pb.GetDeliveryAttemptsResponse, error)

GetDeliveryAttempts retrieves individual attempt history for a delivery

func (*WebhookServer) GetDeliveryStatus added in v0.2.0 

func (s *WebhookServer) GetDeliveryStatus(ctx context.Context, req *pb.GetDeliveryStatusRequest) (*pb.GetDeliveryStatusResponse, error)

GetDeliveryStatus retrieves delivery status for specific delivery

func (*WebhookServer) GetEvent added in v0.2.0 

func (s *WebhookServer) GetEvent(ctx context.Context, req *pb.GetEventRequest) (*pb.GetEventResponse, error)

GetEvent retrieves an event type by name

func (*WebhookServer) GetEventRecord added in v1.1.0 

func (s *WebhookServer) GetEventRecord(ctx context.Context, req *pb.GetEventRecordRequest) (*pb.GetEventRecordResponse, error)

GetEventRecord retrieves a single pushed event instance by UUID with delivery statistics.

func (*WebhookServer) GetHealthSummary 

func (s *WebhookServer) GetHealthSummary(ctx context.Context, req *pb.GetHealthSummaryRequest) (*pb.GetHealthSummaryResponse, error)

GetHealthSummary gets a summary of webhook health

func (*WebhookServer) GetNamespaceStats 

func (s *WebhookServer) GetNamespaceStats(ctx context.Context, req *pb.GetNamespaceStatsRequest) (*pb.GetNamespaceStatsResponse, error)

GetNamespaceStats retrieves statistics for a namespace

func (*WebhookServer) GetRepushStatus added in v0.8.0 

func (s *WebhookServer) GetRepushStatus(ctx context.Context, req *pb.GetRepushStatusRequest) (*pb.GetRepushStatusResponse, error)

GetRepushStatus returns the current progress of a batch re-push operation.

func (*WebhookServer) GetRetryStatus added in v0.8.0 

func (s *WebhookServer) GetRetryStatus(ctx context.Context, req *pb.GetRetryStatusRequest) (*pb.GetRetryStatusResponse, error)

GetRetryStatus returns the current progress of a batch delivery retry.

func (*WebhookServer) GetSubscription added in v0.2.0 

func (s *WebhookServer) GetSubscription(ctx context.Context, req *pb.GetSubscriptionRequest) (*pb.GetSubscriptionResponse, error)

GetSubscription retrieves a specific subscription by ID

func (*WebhookServer) GetTemplateFunctions added in v0.2.0 

func (s *WebhookServer) GetTemplateFunctions(ctx context.Context, req *pb.GetTemplateFunctionsRequest) (*pb.GetTemplateFunctionsResponse, error)

GetTemplateFunctions returns all available template functions with their descriptions

func (*WebhookServer) GetWebhookHealth 

func (s *WebhookServer) GetWebhookHealth(ctx context.Context, req *pb.GetWebhookHealthRequest) (*pb.GetWebhookHealthResponse, error)

GetWebhookHealth gets health metrics for a webhook

func (*WebhookServer) ListDeliveries added in v0.2.0 

func (s *WebhookServer) ListDeliveries(ctx context.Context, req *pb.ListDeliveriesRequest) (*pb.ListDeliveriesResponse, error)

ListDeliveries retrieves delivery history with filters

func (*WebhookServer) ListEventReports 

func (s *WebhookServer) ListEventReports(ctx context.Context, req *pb.ListEventReportsRequest) (*pb.ListEventReportsResponse, error)

ListEventReports lists all events in descending order, with optional filters

func (*WebhookServer) ListEvents 

func (s *WebhookServer) ListEvents(ctx context.Context, req *pb.ListEventsRequest) (*pb.ListEventsResponse, error)

ListEvents lists all registered events

func (*WebhookServer) ListSubscriptions added in v0.2.0 

func (s *WebhookServer) ListSubscriptions(ctx context.Context, req *pb.ListSubscriptionsRequest) (*pb.ListSubscriptionsResponse, error)

ListSubscriptions lists all subscriptions for a webhook

func (*WebhookServer) ListWebhooks 

func (s *WebhookServer) ListWebhooks(ctx context.Context, req *pb.ListWebhooksRequest) (*pb.ListWebhooksResponse, error)

ListWebhooks lists all registered webhooks for a namespace

func (*WebhookServer) ListWebhooksByHealth 

func (s *WebhookServer) ListWebhooksByHealth(ctx context.Context, req *pb.ListWebhooksByHealthRequest) (*pb.ListWebhooksByHealthResponse, error)

ListWebhooksByHealth lists webhooks filtered by health status

func (*WebhookServer) PauseWebhook 

func (s *WebhookServer) PauseWebhook(ctx context.Context, req *pb.PauseWebhookRequest) (*pb.PauseWebhookResponse, error)

PauseWebhook temporarily disables a webhook

func (*WebhookServer) PushEvent 

func (s *WebhookServer) PushEvent(ctx context.Context, req *pb.PushEventRequest) (*pb.PushEventResponse, error)

PushEvent pushes an event that triggers registered webhooks. Schema validation is soft: events are always accepted and stored. If the payload does not match the registered schema, warnings are returned in the response but the event is still processed.

func (*WebhookServer) RePushEvent added in v0.9.3 

func (s *WebhookServer) RePushEvent(ctx context.Context, req *pb.RePushEventRequest) (*pb.RePushEventResponse, 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.

func (*WebhookServer) RePushEvents added in v0.8.0 

func (s *WebhookServer) RePushEvents(ctx context.Context, req *pb.RePushEventsRequest) (*pb.RePushEventsResponse, error)

RePushEvents starts a batch re-push of events previously snapshotted via ListEventReports.

func (*WebhookServer) RegisterEvent 

func (s *WebhookServer) RegisterEvent(ctx context.Context, req *pb.RegisterEventRequest) (*pb.RegisterEventResponse, error)

RegisterEvent registers a new event type

func (*WebhookServer) RegisterWebhook 

func (s *WebhookServer) RegisterWebhook(ctx context.Context, req *pb.RegisterWebhookRequest) (*pb.RegisterWebhookResponse, error)

RegisterWebhook registers a URL for specific events in a namespace

func (*WebhookServer) ResumeWebhook 

func (s *WebhookServer) ResumeWebhook(ctx context.Context, req *pb.ResumeWebhookRequest) (*pb.ResumeWebhookResponse, error)

ResumeWebhook re-enables a paused webhook

func (*WebhookServer) RetryDeliveries added in v0.8.0 

func (s *WebhookServer) RetryDeliveries(ctx context.Context, req *pb.RetryDeliveriesRequest) (*pb.RetryDeliveriesResponse, error)

RetryDeliveries starts a batch retry of deliveries previously snapshotted via ListDeliveries.

func (*WebhookServer) RetryDelivery added in v0.2.0 

func (s *WebhookServer) RetryDelivery(ctx context.Context, req *pb.RetryDeliveryRequest) (*pb.RetryDeliveryResponse, error)

RetryDelivery manually retries failed or pending webhook deliveries

func (*WebhookServer) TestSubscriptionTemplate added in v0.2.0 

func (s *WebhookServer) TestSubscriptionTemplate(ctx context.Context, req *pb.TestSubscriptionTemplateRequest) (*pb.TestSubscriptionTemplateResponse, error)

TestSubscriptionTemplate dry-runs a transformation template with sample data

func (*WebhookServer) UnregisterWebhook 

func (s *WebhookServer) UnregisterWebhook(ctx context.Context, req *pb.UnregisterWebhookRequest) (*pb.UnregisterWebhookResponse, error)

UnregisterWebhook removes a webhook registration

func (*WebhookServer) UpdateEvent 

func (s *WebhookServer) UpdateEvent(ctx context.Context, req *pb.UpdateEventRequest) (*pb.UpdateEventResponse, error)

UpdateEvent updates an event registration

func (*WebhookServer) UpdateSubscription added in v0.2.0 

func (s *WebhookServer) UpdateSubscription(ctx context.Context, req *pb.UpdateSubscriptionRequest) (*pb.UpdateSubscriptionResponse, error)

UpdateSubscription updates an existing subscription

func (*WebhookServer) UpdateWebhookConfig 

func (s *WebhookServer) UpdateWebhookConfig(ctx context.Context, req *pb.UpdateWebhookConfigRequest) (*pb.UpdateWebhookConfigResponse, error)

UpdateWebhookConfig updates webhook configuration

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.