worker

Documentation

Index

• Constants
• Variables
• func CreateEvent(dp *depot.Depot, payload *CreateEventPayload) error
• func EndTrials(dp *depot.Depot) error
• func NotifyAboutEndingTrials(dp *depot.Depot) error
• func NotifyAboutTrialMidways(dp *depot.Depot) error
• func Run(dp *depot.Depot, queues []string) error
• func SendEmail(dp *depot.Depot, payload *SendEmailPayload) error
• func SendWebhook(dp *depot.Depot, payload *SendWebhookPayload)
• type CreateEventPayload
• type Event
• type SendEmailPayload
• type SendWebhookPayload

Constants

const CreateEventQueue rabbitmq.QueueName = "createEvent"

const EndTrialsQueue rabbitmq.QueueName = "endTrials"

const NotifyAboutEndingTrialsQueue rabbitmq.QueueName = "notifyAboutEndingTrials"

const NotifyAboutTrialMidwaysQueue rabbitmq.QueueName = "notifyAboutTrialMidways"

const SendEmailQueue rabbitmq.QueueName = "sendEmail"

const SendWebhookQueue rabbitmq.QueueName = "sendWebhook"

Variables

var Queues = []*rabbitmq.Queue{
	{Name: CreateEventQueue},
	{Name: EndTrialsQueue},
	{Name: NotifyAboutEndingTrialsQueue, Ttl: 24 * time.Hour},
	{Name: NotifyAboutTrialMidwaysQueue, Ttl: 15 * 24 * time.Hour},
	{Name: SendEmailQueue},
	{Name: SendWebhookQueue},
}

Functions

func CreateEvent

func CreateEvent(dp *depot.Depot, payload *CreateEventPayload) error

func EndTrials

func EndTrials(dp *depot.Depot) error

func NotifyAboutEndingTrials

func NotifyAboutEndingTrials(dp *depot.Depot) error

func NotifyAboutTrialMidways

func NotifyAboutTrialMidways(dp *depot.Depot) error

func Run

func Run(dp *depot.Depot, queues []string) error

func SendEmail

func SendEmail(dp *depot.Depot, payload *SendEmailPayload) error

func SendWebhook

func SendWebhook(dp *depot.Depot, payload *SendWebhookPayload)

Types

type CreateEventPayload

type CreateEventPayload = event.CreatePayload

type Event

type Event string

const (
	SendWebhookEventOrganizationDeleted Event = "organization.deleted"
	SendWebhookEventUserSignedUp        Event = "user.signed_up"
)

type SendEmailPayload

type SendEmailPayload = email.SendInput

type SendWebhookPayload

type SendWebhookPayload struct {
	Data  map[string]any
	Event Event
}