queue

Jan 31, 2025

Changes in this version

+ var ErrInvalidQueueTopic = errors.New("not a valid QueueTopic")

+ type BillingCreateCustomerOptions struct

+ Email malak.Email

+ Workspace *malak.Workspace

+ type QueueTopic string

+ const QueueTopicBillingCreateCustomer

+ const QueueTopicBillingTrialEnding

+ const QueueTopicInviteTeamMember

+ func ParseQueueTopic(name string) (QueueTopic, error)

+ func (x QueueTopic) IsValid() bool

+ func (x QueueTopic) String() string

Jan 23, 2025

Changes in this version

+ func ToPayload(m any) []byte

+ type Message struct

+ Data []byte

+ ID string

+ Metadata map[string]string

+ type QueueHandler interface

+ Add func(context.Context, string, *Message) error

+ Start func(context.Context)