worker

package

Go to main page

Versions in this module

v0

v0.3.0

Oct 19, 2026

Changes in this version

+ const NoticeDays

+ const StatusCertChanged

+ const StatusKeyUnavailable

+ const StatusReconnectNeeded

type Check

+ RouteOnly []int64

type CheckState

+ RouteOnly []int64

type Cleanup

+ RouteOnly []int64

+ type PlanEnd struct

+ Every time.Duration

+ Hub *events.Hub

+ Now func() time.Time

+ PublicURL string

+ Sender mailer.Sender

+ Start func(store.Account)

+ Stop func(accountID int64)

+ Store *store.Store

+ func (j PlanEnd) Once(ctx context.Context) (steps int, err error)

+ func (j PlanEnd) Run(ctx context.Context)

+ type Removal struct

+ Every time.Duration

+ Hub *events.Hub

+ Now func() time.Time

+ Start func(store.Account)

+ Stop func(accountID int64)

+ Store *store.Store

+ func (r Removal) Once(ctx context.Context) (removed int, err error)

+ func (r Removal) Run(ctx context.Context)

type Supervisor

+ Moves func(ctx context.Context, mb mail.Mailbox, acct store.Account) error

+ MovesEvery time.Duration

v0.2.0

Oct 9, 2026

v0.1.4

Oct 8, 2026

v0.1.3

Oct 8, 2026

Changes in this version

type Check

+ func (c *Check) Started() CheckState

v0.1.2

Oct 8, 2026

Changes in this version

type Check

+ RuleIDs []int64

type CheckState

+ RuleIDs []int64

type CheckStore

+ func (s *CheckStore) All() []*Check

type Cleanup

+ RuleIDs []int64

type Manager

+ func (m *Manager) SortAll(ctx context.Context, runs []SortRun) ([]store.Batch, error)

v0.1.1

Oct 8, 2026

v0.1.0

Oct 8, 2026

Changes in this version

+ const CheckFailed

+ const CheckReady

+ const CheckRunning

+ const CheckStale

+ const QueueSize

+ const StatusAuthFailed

+ const StatusError

+ const StatusLive

+ const StatusPaused

+ const StatusReconnecting

+ var ErrCleanupRunning = errors.New("a cleanup is already running for this account")

+ var ErrNotConnected = errors.New("account is not connected")

+ type Check struct

+ AccountID int64

+ Fingerprint string

+ Folder string

+ ID string

+ Limit int

+ Since int64

+ StartedAt int64

+ func (c *Check) MarkStale()

+ func (c *Check) SetExclude(ids []int) bool

+ func (c *Check) State() CheckState

+ type CheckFunc func(ctx context.Context, report func(composer.CheckProgress)) ([]composer.CheckRow, error)

+ type CheckState struct

+ AccountID int64

+ CostUSD float64

+ Done int

+ Error string

+ Exclude []int

+ Fingerprint string

+ Folder string

+ ID string

+ Limit int

+ Matched int

+ ModelCalls int

+ Rows []composer.CheckRow

+ Since int64

+ Status string

+ Tokens int

+ Total int

+ type CheckStore struct

+ func NewCheckStore() *CheckStore

+ func (s *CheckStore) Discard(accountID int64) *Check

+ func (s *CheckStore) Get(accountID int64) *Check

+ func (s *CheckStore) Take(accountID int64, id string) *Check

+ type Cleanup struct

+ AccountID int64

+ Folder string

+ Limit int

+ Since time.Time

+ type Manager struct

+ func (m *Manager) Checks() *CheckStore

+ func (m *Manager) Lock(accountID int64) (unlock func())

+ func (m *Manager) Mailbox(accountID int64) (mail.Mailbox, error)

+ func (m *Manager) Sort(ctx context.Context, sr SortRun) (store.Batch, error)

+ func (m *Manager) Start(ctx context.Context, s *Supervisor)

+ func (m *Manager) StartCheck(c Cleanup, fingerprint string, run CheckFunc) (*Check, error)

+ func (m *Manager) Stop(accountID int64)

+ func (m *Manager) Wait()

+ type Retention struct

+ Days func(ctx context.Context) int

+ Every time.Duration

+ Now func() time.Time

+ Store *store.Store

+ func (r Retention) Once(ctx context.Context) (blanked, deleted int64, err error)

+ func (r Retention) Run(ctx context.Context)

+ type SortRun struct

+ AccountID int64

+ Folder string

+ Limit int

+ Matched int

+ Rows []composer.CheckRow

+ Since int64

+ type Supervisor struct

+ Account store.Account

+ BackoffMax time.Duration

+ BackoffMin time.Duration

+ ContactsEvery time.Duration

+ DrainTimeout time.Duration

+ Hub *events.Hub

+ Open func(ctx context.Context) (mail.Mailbox, error)

+ Pipeline pipeline.Pipeline

+ RetryEvery time.Duration

+ Store *store.Store

+ func (s *Supervisor) Mailbox() mail.Mailbox

+ func (s *Supervisor) Run(ctx context.Context)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL