queue

Documentation

Index

• Variables
• func ToPayload(m any) []byte
• type BillingCreateCustomerOptions
• type Message
• type QueueHandler
• type QueueTopic
  • func ParseQueueTopic(name string) (QueueTopic, error)
  • func (x QueueTopic) IsValid() bool
  • func (x QueueTopic) String() string

Variables

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

Functions

func ToPayload

func ToPayload(m any) []byte

Types

type BillingCreateCustomerOptions

type BillingCreateCustomerOptions struct {
	Workspace *malak.Workspace
	Email     malak.Email
}

type Message

type Message struct {
	ID       string
	Metadata map[string]string
	Data     []byte
}

type QueueHandler

type QueueHandler interface {
	io.Closer
	Add(context.Context, QueueTopic, any) error
	Start(context.Context)
}

type QueueTopic

type QueueTopic string

ENUM(billing_trial_ending,billing_create_customer, invite_team_member)

const (
	// QueueTopicBillingTrialEnding is a QueueTopic of type billing_trial_ending.
	QueueTopicBillingTrialEnding QueueTopic = "billing_trial_ending"
	// QueueTopicBillingCreateCustomer is a QueueTopic of type billing_create_customer.
	QueueTopicBillingCreateCustomer QueueTopic = "billing_create_customer"
	// QueueTopicInviteTeamMember is a QueueTopic of type invite_team_member.
	QueueTopicInviteTeamMember QueueTopic = "invite_team_member"
)

func ParseQueueTopic

func ParseQueueTopic(name string) (QueueTopic, error)

ParseQueueTopic attempts to convert a string to a QueueTopic.

func (QueueTopic) IsValid

func (x QueueTopic) IsValid() bool

IsValid provides a quick way to determine if the typed value is part of the allowed enumerated values

func (QueueTopic) String

func (x QueueTopic) String() string

String implements the Stringer interface.