email

type AttachmentCache struct {
	// contains filtered or unexported fields
}

type AttachmentProcessor struct {
	// contains filtered or unexported fields
}

type DispatchOptions struct {
	Context context.Context
	Monitor monitor.Monitor
	Tracker OffsetTracker
	// StartOffset is retained for API compatibility but is no longer consulted
	// for offset arithmetic — Task.Index is treated as an absolute position
	// and Tracker.MarkComplete handles concurrency-safe advancement.
	StartOffset int
	// AttachmentCache is reused across all sends in this dispatch. When nil,
	// the dispatcher creates one with DefaultAttachmentCacheLimit. Pass a
	// pre-populated cache to share across multiple dispatches.
	AttachmentCache *AttachmentCache
	// OffsetSaveInterval controls how often the tracker is flushed to disk.
	// Zero falls back to 200ms. Negative disables periodic flushing (only the
	// final save at dispatch end is performed).
	OffsetSaveInterval time.Duration
	// PendingEmails seeds the monitor dashboard with all expected recipients
	// before any worker runs. StartDispatcher populates this from the task
	// slice automatically; streaming callers should supply it from their
	// recipient list so the dashboard shows everyone in Pending state.
	PendingEmails []string
}

type DispatchResult struct {
	Sent   int
	Failed int
}

type OffsetTracker interface {
	UpdateOffset(offset int)
	MarkComplete(idx int)
	Save() error
}

type Task struct {
	Recipient   parser.Recipient
	Subject     string
	Body        string // HTML body (from --template)
	PlainText   string // Plain-text body (from --text, for multipart/alternative)
	Retries     int
	Attachments []string
	CC          []string
	BCC         []string
	Index       int // Position in original task list for offset tracking
}

type TemplateCache struct {
	// contains filtered or unexported fields
}