workers

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const InvitationEmailConnectionName = "superplane"
View Source 
const InvitationEmailServiceName = "superplane" + "." + messages.WorkflowExchange + "." + messages.InvitationCreatedRoutingKey + ".worker-consumer"
View Source 
const NotificationEmailConnectionName = "superplane"
View Source 
const NotificationEmailServiceName = "superplane" + "." + messages.WorkflowExchange + "." + messages.NotificationEmailRequestedRoutingKey + ".worker-consumer"

Variables

View Source 
var ErrRecordLocked = errors.New("record locked")

Functions

This section is empty.

Types

type CanvasCleanupWorker added in v0.6.0 

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

func NewCanvasCleanupWorker added in v0.6.0 

func NewCanvasCleanupWorker() *CanvasCleanupWorker

func (*CanvasCleanupWorker) LockAndProcessCanvas added in v0.6.0 

func (w *CanvasCleanupWorker) LockAndProcessCanvas(canvas models.Canvas) error

func (*CanvasCleanupWorker) Start added in v0.6.0 

func (w *CanvasCleanupWorker) Start(ctx context.Context)

type EventDistributer 

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

EventDistributer coordinates message consumption from RabbitMQ and distributes events to websocket clients

func NewEventDistributer 

func NewEventDistributer(wsHub *ws.Hub) *EventDistributer

NewEventDistributer creates a new event distributer coordinator

func (*EventDistributer) Shutdown 

func (e *EventDistributer) Shutdown(ctx context.Context) error

Shutdown gracefully stops the worker

func (*EventDistributer) Start 

func (e *EventDistributer) Start() error

Start begins consuming messages from RabbitMQ for all relevant routing keys

type EventRouter added in v0.6.0 

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

func NewEventRouter added in v0.6.0 

func NewEventRouter() *EventRouter

func (*EventRouter) LockAndProcessEvent added in v0.6.0 

func (w *EventRouter) LockAndProcessEvent(logger *log.Entry, event models.CanvasEvent) error

func (*EventRouter) Start added in v0.6.0 

func (w *EventRouter) Start(ctx context.Context)

type IntegrationCleanupWorker added in v0.6.0 

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

func NewIntegrationCleanupWorker added in v0.6.0 

func NewIntegrationCleanupWorker(registry *registry.Registry, encryptor crypto.Encryptor, baseURL string) *IntegrationCleanupWorker

func (*IntegrationCleanupWorker) LockAndProcessIntegration added in v0.6.0 

func (w *IntegrationCleanupWorker) LockAndProcessIntegration(integration models.Integration) error

func (*IntegrationCleanupWorker) Start added in v0.6.0 

func (w *IntegrationCleanupWorker) Start(ctx context.Context)

type IntegrationRequestWorker added in v0.6.0 

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

func NewIntegrationRequestWorker added in v0.6.0 

func NewIntegrationRequestWorker(encryptor crypto.Encryptor, registry *registry.Registry, oidcProvider oidc.Provider, baseURL string, webhooksBaseURL string) *IntegrationRequestWorker

func (*IntegrationRequestWorker) LockAndProcessRequest added in v0.6.0 

func (w *IntegrationRequestWorker) LockAndProcessRequest(request models.IntegrationRequest) error

func (*IntegrationRequestWorker) Start added in v0.6.0 

func (w *IntegrationRequestWorker) Start(ctx context.Context)

type InvitationEmailConsumer 

type InvitationEmailConsumer struct {
	Consumer     *tackle.Consumer
	RabbitMQURL  string
	EmailService services.EmailService
	BaseURL      string
}

func NewInvitationEmailConsumer 

func NewInvitationEmailConsumer(rabbitMQURL string, emailService services.EmailService, baseURL string) *InvitationEmailConsumer

func (*InvitationEmailConsumer) Consume 

func (c *InvitationEmailConsumer) Consume(delivery tackle.Delivery) error

func (*InvitationEmailConsumer) Start 

func (c *InvitationEmailConsumer) Start() error

func (*InvitationEmailConsumer) Stop 

func (c *InvitationEmailConsumer) Stop()

type NodeExecutor added in v0.6.0 

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

func NewNodeExecutor added in v0.6.0 

func NewNodeExecutor(encryptor crypto.Encryptor, registry *registry.Registry, baseURL string, webhookBaseURL string) *NodeExecutor

func (*NodeExecutor) LockAndProcessNodeExecution added in v0.6.0 

func (w *NodeExecutor) LockAndProcessNodeExecution(id uuid.UUID) error

func (*NodeExecutor) Start added in v0.6.0 

func (w *NodeExecutor) Start(ctx context.Context)

type NodeQueueWorker added in v0.6.0 

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

func NewNodeQueueWorker added in v0.6.0 

func NewNodeQueueWorker(registry *registry.Registry) *NodeQueueWorker

func (*NodeQueueWorker) LockAndProcessNode added in v0.6.0 

func (w *NodeQueueWorker) LockAndProcessNode(logger *log.Entry, node models.CanvasNode) error

func (*NodeQueueWorker) Start added in v0.6.0 

func (w *NodeQueueWorker) Start(ctx context.Context)

type NodeRequestWorker 

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

func NewNodeRequestWorker 

func NewNodeRequestWorker(encryptor crypto.Encryptor, registry *registry.Registry) *NodeRequestWorker

func (*NodeRequestWorker) LockAndProcessRequest 

func (w *NodeRequestWorker) LockAndProcessRequest(request models.CanvasNodeRequest) error

func (*NodeRequestWorker) Start 

func (w *NodeRequestWorker) Start(ctx context.Context)

type NotificationEmailConsumer added in v0.0.43 

type NotificationEmailConsumer struct {
	Consumer     *tackle.Consumer
	RabbitMQURL  string
	EmailService services.EmailService
	AuthService  authorization.Authorization
}

func NewNotificationEmailConsumer added in v0.0.43 

func NewNotificationEmailConsumer(
	rabbitMQURL string,
	emailService services.EmailService,
	authService authorization.Authorization,
) *NotificationEmailConsumer

func (*NotificationEmailConsumer) Consume added in v0.0.43 

func (c *NotificationEmailConsumer) Consume(delivery tackle.Delivery) error

func (*NotificationEmailConsumer) Start added in v0.0.43 

func (c *NotificationEmailConsumer) Start() error

func (*NotificationEmailConsumer) Stop added in v0.0.43 

func (c *NotificationEmailConsumer) Stop()

type WebhookCleanupWorker 

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

func NewWebhookCleanupWorker 

func NewWebhookCleanupWorker(encryptor crypto.Encryptor, registry *registry.Registry, baseURL string) *WebhookCleanupWorker

func (*WebhookCleanupWorker) LockAndProcessWebhook 

func (w *WebhookCleanupWorker) LockAndProcessWebhook(webhook models.Webhook) error

func (*WebhookCleanupWorker) Start 

func (w *WebhookCleanupWorker) Start(ctx context.Context)

type WebhookProvisioner 

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

func NewWebhookProvisioner 

func NewWebhookProvisioner(baseURL string, encryptor crypto.Encryptor, registry *registry.Registry) *WebhookProvisioner

func (*WebhookProvisioner) LockAndProcessWebhook 

func (w *WebhookProvisioner) LockAndProcessWebhook(webhook models.Webhook) error

func (*WebhookProvisioner) Start 

func (w *WebhookProvisioner) Start(ctx context.Context)

Source Files

View all Source files

Directories

Path Synopsis

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.