Documentation
¶
Index ¶
- Constants
- Variables
- type AppInstallationRequestWorker
- type EventDistributer
- type InstallationCleanupWorker
- type InvitationEmailConsumer
- type NodeRequestWorker
- type NotificationEmailConsumer
- type WebhookCleanupWorker
- type WebhookProvisioner
- type WorkflowCleanupWorker
- type WorkflowEventRouter
- type WorkflowNodeExecutor
- type WorkflowNodeQueueWorker
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 AppInstallationRequestWorker ¶ added in v0.0.21
type AppInstallationRequestWorker struct {
// contains filtered or unexported fields
}
func NewAppInstallationRequestWorker ¶ added in v0.0.21
func (*AppInstallationRequestWorker) LockAndProcessRequest ¶ added in v0.0.21
func (w *AppInstallationRequestWorker) LockAndProcessRequest(request models.AppInstallationRequest) error
func (*AppInstallationRequestWorker) Start ¶ added in v0.0.21
func (w *AppInstallationRequestWorker) 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 InstallationCleanupWorker ¶
type InstallationCleanupWorker struct {
// contains filtered or unexported fields
}
func NewInstallationCleanupWorker ¶
func NewInstallationCleanupWorker() *InstallationCleanupWorker
func (*InstallationCleanupWorker) LockAndProcessInstallation ¶
func (w *InstallationCleanupWorker) LockAndProcessInstallation(installation models.AppInstallation) error
func (*InstallationCleanupWorker) Start ¶
func (w *InstallationCleanupWorker) 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 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.WorkflowNodeRequest) 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 (*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 (*WebhookProvisioner) LockAndProcessWebhook ¶
func (w *WebhookProvisioner) LockAndProcessWebhook(webhook models.Webhook) error
func (*WebhookProvisioner) Start ¶
func (w *WebhookProvisioner) Start(ctx context.Context)
type WorkflowCleanupWorker ¶
type WorkflowCleanupWorker struct {
// contains filtered or unexported fields
}
func NewWorkflowCleanupWorker ¶
func NewWorkflowCleanupWorker() *WorkflowCleanupWorker
func (*WorkflowCleanupWorker) LockAndProcessWorkflow ¶
func (w *WorkflowCleanupWorker) LockAndProcessWorkflow(workflow models.Workflow) error
func (*WorkflowCleanupWorker) Start ¶
func (w *WorkflowCleanupWorker) Start(ctx context.Context)
type WorkflowEventRouter ¶
type WorkflowEventRouter struct {
// contains filtered or unexported fields
}
func NewWorkflowEventRouter ¶
func NewWorkflowEventRouter() *WorkflowEventRouter
func (*WorkflowEventRouter) LockAndProcessEvent ¶
func (w *WorkflowEventRouter) LockAndProcessEvent(logger *log.Entry, event models.WorkflowEvent) error
func (*WorkflowEventRouter) Start ¶
func (w *WorkflowEventRouter) Start(ctx context.Context)
type WorkflowNodeExecutor ¶
type WorkflowNodeExecutor struct {
// contains filtered or unexported fields
}
func NewWorkflowNodeExecutor ¶
func (*WorkflowNodeExecutor) LockAndProcessNodeExecution ¶
func (w *WorkflowNodeExecutor) LockAndProcessNodeExecution(id uuid.UUID) error
func (*WorkflowNodeExecutor) Start ¶
func (w *WorkflowNodeExecutor) Start(ctx context.Context)
type WorkflowNodeQueueWorker ¶
type WorkflowNodeQueueWorker struct {
// contains filtered or unexported fields
}
func NewWorkflowNodeQueueWorker ¶
func NewWorkflowNodeQueueWorker(registry *registry.Registry) *WorkflowNodeQueueWorker
func (*WorkflowNodeQueueWorker) LockAndProcessNode ¶
func (w *WorkflowNodeQueueWorker) LockAndProcessNode(logger *log.Entry, node models.WorkflowNode) error
func (*WorkflowNodeQueueWorker) Start ¶
func (w *WorkflowNodeQueueWorker) Start(ctx context.Context)
Source Files
¶
- app_installation_request_worker.go
- event_distributer.go
- installation_cleanup_worker.go
- invitation_email_consumer.go
- notification_email_consumer.go
- webhook_cleanup_worker.go
- webhook_provisioner.go
- workflow_cleanup_worker.go
- workflow_event_router.go
- workflow_node_executor.go
- workflow_node_queue_worker.go
- workflow_node_request_worker.go
Directories
Click to show internal directories.
Click to hide internal directories.