connect

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type WebhookConnectServer 

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

func NewWebhookConnectServer 

func NewWebhookConnectServer(
	webhookService pb.WebhookServiceServer,
	eventService pb.EventServiceServer,
	subscriptionService pb.SubscriptionServiceServer,
	deliveryService pb.DeliveryServiceServer,
	healthService pb.HealthServiceServer,
) *WebhookConnectServer

NewWebhookConnectServer creates a new Connect-RPC server

func (*WebhookConnectServer) CreateSubscription added in v0.2.0 

func (s *WebhookConnectServer) CreateSubscription(ctx context.Context, req *connect.Request[pb.CreateSubscriptionRequest]) (*connect.Response[pb.CreateSubscriptionResponse], error)

SubscriptionService Implementation

func (*WebhookConnectServer) DeleteEvent 

func (s *WebhookConnectServer) DeleteEvent(ctx context.Context, req *connect.Request[pb.DeleteEventRequest]) (*connect.Response[pb.DeleteEventResponse], error)

func (*WebhookConnectServer) DeleteSubscription added in v0.2.0 

func (s *WebhookConnectServer) DeleteSubscription(ctx context.Context, req *connect.Request[pb.DeleteSubscriptionRequest]) (*connect.Response[pb.DeleteSubscriptionResponse], error)

func (*WebhookConnectServer) GetDeliveryAttempts added in v0.2.0 

func (s *WebhookConnectServer) GetDeliveryAttempts(ctx context.Context, req *connect.Request[pb.GetDeliveryAttemptsRequest]) (*connect.Response[pb.GetDeliveryAttemptsResponse], error)

func (*WebhookConnectServer) GetDeliveryStatus added in v0.2.0 

func (s *WebhookConnectServer) GetDeliveryStatus(ctx context.Context, req *connect.Request[pb.GetDeliveryStatusRequest]) (*connect.Response[pb.GetDeliveryStatusResponse], error)

DeliveryService Implementation

func (*WebhookConnectServer) GetEvent added in v0.2.0 

func (s *WebhookConnectServer) GetEvent(ctx context.Context, req *connect.Request[pb.GetEventRequest]) (*connect.Response[pb.GetEventResponse], error)

func (*WebhookConnectServer) GetHealthSummary 

func (s *WebhookConnectServer) GetHealthSummary(ctx context.Context, req *connect.Request[pb.GetHealthSummaryRequest]) (*connect.Response[pb.GetHealthSummaryResponse], error)

func (*WebhookConnectServer) GetNamespaceStats 

func (s *WebhookConnectServer) GetNamespaceStats(ctx context.Context, req *connect.Request[pb.GetNamespaceStatsRequest]) (*connect.Response[pb.GetNamespaceStatsResponse], error)

func (*WebhookConnectServer) GetSubscription added in v0.2.0 

func (s *WebhookConnectServer) GetSubscription(ctx context.Context, req *connect.Request[pb.GetSubscriptionRequest]) (*connect.Response[pb.GetSubscriptionResponse], error)

func (*WebhookConnectServer) GetTemplateFunctions added in v0.2.0 

func (s *WebhookConnectServer) GetTemplateFunctions(ctx context.Context, req *connect.Request[pb.GetTemplateFunctionsRequest]) (*connect.Response[pb.GetTemplateFunctionsResponse], error)

func (*WebhookConnectServer) GetWebhookHealth 

func (s *WebhookConnectServer) GetWebhookHealth(ctx context.Context, req *connect.Request[pb.GetWebhookHealthRequest]) (*connect.Response[pb.GetWebhookHealthResponse], error)

HealthService Implementation

func (*WebhookConnectServer) ListDeliveries added in v0.2.0 

func (s *WebhookConnectServer) ListDeliveries(ctx context.Context, req *connect.Request[pb.ListDeliveriesRequest]) (*connect.Response[pb.ListDeliveriesResponse], error)

func (*WebhookConnectServer) ListEventReports 

func (s *WebhookConnectServer) ListEventReports(ctx context.Context, req *connect.Request[pb.ListEventReportsRequest]) (*connect.Response[pb.ListEventReportsResponse], error)

func (*WebhookConnectServer) ListEvents 

func (s *WebhookConnectServer) ListEvents(ctx context.Context, req *connect.Request[pb.ListEventsRequest]) (*connect.Response[pb.ListEventsResponse], error)

func (*WebhookConnectServer) ListSubscriptions added in v0.2.0 

func (s *WebhookConnectServer) ListSubscriptions(ctx context.Context, req *connect.Request[pb.ListSubscriptionsRequest]) (*connect.Response[pb.ListSubscriptionsResponse], error)

func (*WebhookConnectServer) ListWebhooks 

func (s *WebhookConnectServer) ListWebhooks(ctx context.Context, req *connect.Request[pb.ListWebhooksRequest]) (*connect.Response[pb.ListWebhooksResponse], error)

func (*WebhookConnectServer) ListWebhooksByHealth 

func (s *WebhookConnectServer) ListWebhooksByHealth(ctx context.Context, req *connect.Request[pb.ListWebhooksByHealthRequest]) (*connect.Response[pb.ListWebhooksByHealthResponse], error)

func (*WebhookConnectServer) PauseWebhook 

func (s *WebhookConnectServer) PauseWebhook(ctx context.Context, req *connect.Request[pb.PauseWebhookRequest]) (*connect.Response[pb.PauseWebhookResponse], error)

func (*WebhookConnectServer) PushEvent 

func (s *WebhookConnectServer) PushEvent(ctx context.Context, req *connect.Request[pb.PushEventRequest]) (*connect.Response[pb.PushEventResponse], error)

func (*WebhookConnectServer) RegisterEvent 

func (s *WebhookConnectServer) RegisterEvent(ctx context.Context, req *connect.Request[pb.RegisterEventRequest]) (*connect.Response[pb.RegisterEventResponse], error)

EventService Implementation

func (*WebhookConnectServer) RegisterWebhook 

func (s *WebhookConnectServer) RegisterWebhook(ctx context.Context, req *connect.Request[pb.RegisterWebhookRequest]) (*connect.Response[pb.RegisterWebhookResponse], error)

WebhookService Implementation

func (*WebhookConnectServer) ResumeWebhook 

func (s *WebhookConnectServer) ResumeWebhook(ctx context.Context, req *connect.Request[pb.ResumeWebhookRequest]) (*connect.Response[pb.ResumeWebhookResponse], error)

func (*WebhookConnectServer) RetryDelivery added in v0.2.0 

func (s *WebhookConnectServer) RetryDelivery(ctx context.Context, req *connect.Request[pb.RetryDeliveryRequest]) (*connect.Response[pb.RetryDeliveryResponse], error)

func (*WebhookConnectServer) TestSubscriptionTemplate added in v0.2.0 

func (s *WebhookConnectServer) TestSubscriptionTemplate(ctx context.Context, req *connect.Request[pb.TestSubscriptionTemplateRequest]) (*connect.Response[pb.TestSubscriptionTemplateResponse], error)

func (*WebhookConnectServer) UnregisterWebhook 

func (s *WebhookConnectServer) UnregisterWebhook(ctx context.Context, req *connect.Request[pb.UnregisterWebhookRequest]) (*connect.Response[pb.UnregisterWebhookResponse], error)

func (*WebhookConnectServer) UpdateEvent 

func (s *WebhookConnectServer) UpdateEvent(ctx context.Context, req *connect.Request[pb.UpdateEventRequest]) (*connect.Response[pb.UpdateEventResponse], error)

func (*WebhookConnectServer) UpdateSubscription added in v0.2.0 

func (s *WebhookConnectServer) UpdateSubscription(ctx context.Context, req *connect.Request[pb.UpdateSubscriptionRequest]) (*connect.Response[pb.UpdateSubscriptionResponse], error)

func (*WebhookConnectServer) UpdateWebhookConfig 

func (s *WebhookConnectServer) UpdateWebhookConfig(ctx context.Context, req *connect.Request[pb.UpdateWebhookConfigRequest]) (*connect.Response[pb.UpdateWebhookConfigResponse], error)

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.