streamfleet_mail

Sep 3, 2025

Changes in this version

+ const QueueKeyPrefix

+ type Client struct

+ func NewClient(ctx context.Context, sfClientOpt streamfleet.ClientOpt, queueKey string) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) EnqueueAndForget(email *mail.Msg, opt streamfleet.TaskOpt) error

+ func (c *Client) EnqueueAndTrack(email *mail.Msg, opt streamfleet.TaskOpt) (*streamfleet.TaskHandle, error)

+ type Worker struct

+ func NewWorker(ctx context.Context, mailClient *mail.Client, ...) (*Worker, error)

+ func (w *Worker) Close() error

+ func (w *Worker) Run() error