store

package

Go to main page

Versions in this module

v0

v0.3.0

Oct 19, 2026

Changes in this version

+ const ActionDraft

+ const ActionInterrupted

+ const AuditCompanySignInAddOn

+ const AuditCompanySignInPortal

+ const AuditDays

+ const AuditDestinationAdded

+ const AuditDestinationRemoved

+ const AuditInvitationAccepted

+ const AuditInvitationCreated

+ const AuditInvitationRevoked

+ const AuditInvitationWithdrawn

+ const AuditMailboxAdded

+ const AuditMailboxChanged

+ const AuditMailboxRemoved

+ const AuditMemberJoined

+ const AuditMemberRemoved

+ const AuditMemberRoleChanged

+ const AuditPlanChanged

+ const AuditRuleChanged

+ const AuditRuleCreated

+ const AuditRuleDeleted

+ const AuditRulesReordered

+ const AuditSenderRuleDeleted

+ const AuditSenderRuleSet

+ const AuditSettingsChanged

+ const DefaultTenantKeyCache

+ const DeliveryFailed

+ const DeliverySent

+ const DestinationSlack

+ const DestinationWebhook

+ const DraftWait

+ const EndedRemovalDays

+ const EndedSecretsDays

+ const ForgetDays

+ const IntervalMonth

+ const IntervalYear

+ const InvitationDays

+ const MoveDays

+ const NoLimit

+ const NoticeDays

+ const PlanEnded

+ const PlanPersonal

+ const PlanPro

+ const PlanTeam

+ const PlanTrial

+ const QuestionNo

+ const QuestionOpen

+ const QuestionYes

+ const RemovedMailboxDays

+ const RoleAdmin

+ const RoleMember

+ const RoleOwner

+ const StatusActive

+ const StatusCancelsAtPeriodEnd

+ const StatusPastDue

+ const TrialDays

+ var ErrAlreadyInvited = errors.New("already invited")

+ var ErrAlreadyMember = errors.New("already a member of the team")

+ var ErrAnswered = errors.New("the person already answered the question about this sender and folder")

+ var ErrBadPlan = errors.New("unknown plan, interval or status")

+ var ErrBadRole = errors.New("unknown role")

+ var ErrHasAccount = errors.New("the address has a MailRules account")

+ var ErrLastOwner = errors.New("the team's last owner")

+ var ErrMailboxLimit = errors.New("the mailbox limit is reached")

+ var ErrNoKeys = errors.New("store: no key provider")

+ var ErrNoSecret = errors.New("the mailbox's password was deleted; enter it again")

+ var ErrPlanNotEnded = errors.New("the tenant's plan has not ended")

+ var ErrRemovedMember = errors.New("removed from the team: a new invitation is needed")

+ var ErrSchema = errors.New("the database schema does not match this build")

+ var ErrSeatLimit = errors.New("seat limit reached")

+ var ErrTenantScope = errors.New("store: a tenant outside the current scope")

+ var Roles = []string

+ func CheckSchema(ctx context.Context, db *sql.DB) error

+ func Month(t time.Time) string

+ func OpenPostgres(ctx context.Context, dsn string) (*sql.DB, error)

+ func OpenSetting(k crypto.TenantKey, name, stored string) (string, error)

+ func RoleName(role string) string

+ func RoleRank(role string) int

+ func SealSetting(k crypto.TenantKey, name, value string) (string, error)

+ func TenantOf(ctx context.Context) int64

+ func URLHint(raw string) string

+ func WithActor(ctx context.Context, a Actor) context.Context

+ func WithTenant(ctx context.Context, tenantID int64) context.Context

+ func WithoutActor(ctx context.Context) context.Context

type Account

+ CertFingerprint string

+ Module bool

+ OAuth bool

+ SecretGone bool

type Action

+ Draft *DraftRef

+ type Actor struct

+ Name string

+ UserID int64

+ func ActorOf(ctx context.Context) (Actor, bool)

+ type AuditEntry struct

+ Action string

+ Actor string

+ ActorID int64

+ At int64

+ Detail string

+ ID int64

+ Target string

type Decision

+ Metered bool

+ SenderSource string

+ type Delivery struct

+ CreatedAt int64

+ DestinationID int64

+ ID int64

+ NoticeID int64

+ Reason string

+ RuleID int64

+ RuleName string

+ Status string

+ type Destination struct

+ AddressDeleted bool

+ CreatedAt int64

+ ID int64

+ Kind string

+ Name string

+ TenantID int64

+ URLHint string

+ func (d Destination) NeedsHTTPS() bool

+ type DestinationSecret struct

+ Secret string

+ URL string

+ type DraftJob struct

+ AccountID int64

+ Attempts int

+ BatchID int64

+ CreatedAt int64

+ DecisionID int64

+ ID int64

+ Instruction string

+ Key string

+ MessageID int64

+ ReadPrevious bool

+ RuleID int64

+ RuleName string

+ TenantID int64

+ type DraftRef struct

+ MessageID string

+ UID uint32

+ UIDValidity uint32

+ type EndedPlan struct

+ WarnedAt int64

+ type Filed struct

+ ActionID int64

+ After Snapshot

+ Before Snapshot

+ FiledAt int64

+ From string

+ MessageID int64

+ MsgID string

+ RuleID int64

+ RuleName string

+ type FollowUps struct

+ Draft bool

+ Notices bool

+ type Forget struct

+ Accounts []int64

+ Keys bool

+ TenantID int64

+ UserID int64

+ type Forgotten struct

+ RemoveAt int64

+ TenantID int64

+ UserID int64

+ type Invitation struct

+ AcceptedAt int64

+ CreatedAt int64

+ Email string

+ ExpiresAt int64

+ ID int64

+ InvitedBy int64

+ InvitedByEmail string

+ Record string

+ Role string

+ TenantID int64

+ type Keyring struct

+ func NewKeyring(p crypto.KeyProvider, ttl time.Duration) *Keyring

+ type MailboxLimitError struct

+ Connected int

+ Limit int

+ func (e *MailboxLimitError) Error() string

+ func (e *MailboxLimitError) Is(target error) bool

+ type MasterKeyUses struct

+ RemovedMailboxes int

+ Secrets int

+ TenantKeys int

+ func (u MasterKeyUses) Total() int

+ type Member struct

+ Email string

+ JoinedAt int64

+ Role string

+ UserID int64

type Message

+ Metered bool

+ UnsubscribeURL string

+ type Move struct

+ AccountID int64

+ ActionID int64

+ Attempts int

+ Chosen string

+ Count int

+ CreatedAt int64

+ Filed string

+ FiledAt int64

+ From string

+ ID int64

+ Inbox bool

+ Mailbox string

+ MessageID int64

+ Person bool

+ RuleID int64

+ RuleName string

+ TenantID int64

+ type Notice struct

+ AccountID int64

+ Attempts int

+ CreatedAt int64

+ DestinationID int64

+ ID int64

+ MessageID int64

+ RuleID int64

+ RuleName string

+ TenantID int64

+ type NoticePayload struct

+ Actions []string

+ Folder string

+ From string

+ FromName string

+ Mailbox string

+ Subject string

+ type Plan struct

+ CompanySignInAddOn bool

+ Interval string

+ PeriodEnd int64

+ Plan string

+ Record string

+ Seats int

+ Status string

+ type PlanState struct

+ EndedAt int64

+ SecretsDeleted bool

+ TrialEnd int64

+ Warned int

+ func (p PlanState) Ended() bool

+ type Question struct

+ AccountID int64

+ AskedAt int64

+ Emails int

+ Folder string

+ From string

+ ID int64

+ Inbox bool

+ Mailbox string

+ Status string

+ TenantID int64

+ type Removal struct

+ Accounts []int64

+ Rules []rules.Rule

+ Tenant bool

+ TenantID int64

+ type RemovedMailbox struct

+ AccountID int64

+ Attempts int

+ CreatedAt int64

+ ID int64

+ OAuth bool

+ Preset string

+ TenantID int64

+ Username string

+ type SeatCheck struct

+ Attempts int

+ CreatedAt int64

+ TenantID int64

+ Version int64

+ type SeatLimit func(p PlanState) int

+ type SeatLimitError struct

+ Limit int

+ Used int

+ func (e *SeatLimitError) Error() string

+ func (e *SeatLimitError) Is(target error) bool

+ type SecretsCheck struct

+ Total int

+ Unreadable int

+ func (c SecretsCheck) Readable() int

type SenderSeen

+ OneClick bool

+ UnsubscribedAt int64

type Store

+ func (s *Store) AIEmails(ctx context.Context, tenantID int64, month string) (int, error)

+ func (s *Store) AcceptInvitation(ctx context.Context, tenantID int64, email string, now int64) error

+ func (s *Store) AddUnsubscribe(ctx context.Context, accountID int64, address, host string, now int64) error

+ func (s *Store) AnswerQuestion(ctx context.Context, v Viewer, id int64, yes bool, now int64) (Question, error)

+ func (s *Store) AskMove(ctx context.Context, moveID, now int64) (Question, bool, error)

+ func (s *Store) Audit(ctx context.Context, tenantID int64, action, target, detail string) error

+ func (s *Store) AuditLog(ctx context.Context, tenantID, since, until int64) ([]AuditEntry, error)

+ func (s *Store) CheckSecrets(ctx context.Context) (SecretsCheck, error)

+ func (s *Store) CreateAccountWithin(ctx context.Context, a Account, secret string, max int) (Account, error)

+ func (s *Store) CreateDestination(ctx context.Context, d Destination, sec DestinationSecret, now int64) (Destination, error)

+ func (s *Store) CreateInvitation(ctx context.Context, tenantID int64, inv Invitation, seats SeatLimit, ...) (Invitation, error)

+ func (s *Store) DecisionDraft(ctx context.Context, tenantID, decisionID int64) (a Action, ok bool, err error)

+ func (s *Store) DeleteDestination(ctx context.Context, tenantID, id, now int64) ([]rules.Rule, error)

+ func (s *Store) DeleteOwnAccount(ctx context.Context, provider, subject string, now int64) (Forget, error)

+ func (s *Store) DeleteTenantSecrets(ctx context.Context, tenantID, endedAt, now int64) ([]int64, error)

+ func (s *Store) Destination(ctx context.Context, id int64) (Destination, error)

+ func (s *Store) DestinationSecret(ctx context.Context, id int64) (DestinationSecret, error)

+ func (s *Store) Destinations(ctx context.Context, tenantID int64) ([]Destination, error)

+ func (s *Store) DraftDone(ctx context.Context, j DraftJob) error

+ func (s *Store) DraftRetry(ctx context.Context, j DraftJob, next int64) error

+ func (s *Store) DueForRemoval(ctx context.Context, now int64) ([]Forgotten, error)

+ func (s *Store) EndTrial(ctx context.Context, tenantID, now int64) (bool, error)

+ func (s *Store) EndedPlan(ctx context.Context, tenantID, now int64) (EndedPlan, error)

+ func (s *Store) ExpireRemovedMailboxes(ctx context.Context, now int64) ([]RemovedMailbox, error)

+ func (s *Store) FiledSince(ctx context.Context, accountID, since, afterID int64, limit int) ([]Filed, error)

+ func (s *Store) FirstCleanupUsed(ctx context.Context, tenantID int64) (int, error)

+ func (s *Store) ForgetIdentity(ctx context.Context, provider, subject string, now int64) (Forget, error)

+ func (s *Store) IdentityMailboxes(ctx context.Context, provider, subject string) ([]int64, error)

+ func (s *Store) Invitations(ctx context.Context, tenantID, now int64) ([]Invitation, error)

+ func (s *Store) LastOwner(ctx context.Context, u User) (bool, error)

+ func (s *Store) LeftByMailRules(ctx context.Context, accountID int64, folder string, uidValidity, uid uint32, ...) (bool, error)

+ func (s *Store) MasterKeyUses(ctx context.Context) (MasterKeyUses, error)

+ func (s *Store) Members(ctx context.Context, tenantID int64) ([]Member, error)

+ func (s *Store) MoveHanded(ctx context.Context, id, now int64) error

+ func (s *Store) MoveRetry(ctx context.Context, id, next int64) error

+ func (s *Store) NoticeHanded(ctx context.Context, id, now int64) error

+ func (s *Store) NoticeRetry(ctx context.Context, id, next int64) error

+ func (s *Store) OpenQuestions(ctx context.Context, v Viewer) ([]Question, error)

+ func (s *Store) PlanEndTenants(ctx context.Context, now int64) ([]int64, error)

+ func (s *Store) PlanWarned(ctx context.Context, tenantID, endedAt int64, n int, now int64) error

+ func (s *Store) QueueSeatCheck(ctx context.Context, tenantID, now int64) error

+ func (s *Store) RecentDeliveries(ctx context.Context, tenantID int64, perDestination int) (map[int64][]Delivery, error)

+ func (s *Store) RecordDelivery(ctx context.Context, noticeID int64, sent bool, reason string, at int64) (tenantID int64, err error)

+ func (s *Store) RecordMove(ctx context.Context, m Move) (int64, error)

+ func (s *Store) RemovalAccounts(ctx context.Context, userID int64) ([]int64, error)

+ func (s *Store) RemoveEndedTenant(ctx context.Context, tenantID, endedAt, now int64) (Removal, error)

+ func (s *Store) RemoveForgotten(ctx context.Context, userID, now int64) (Removal, error)

+ func (s *Store) RemoveMember(ctx context.Context, provider, subject string, now int64) (Forget, error)

+ func (s *Store) RemovedMailboxRetry(ctx context.Context, id, next int64) error

+ func (s *Store) RemovedMailboxSecret(ctx context.Context, id int64) (string, error)

+ func (s *Store) RemovedMailboxTaken(ctx context.Context, id int64) error

+ func (s *Store) ReplaceUnopenableTenantKeys(ctx context.Context) (int, error)

+ func (s *Store) RevokeInvitation(ctx context.Context, tenantID, id int64, why string, now int64) (Invitation, error)

+ func (s *Store) RewrapTenantKeys(ctx context.Context) (int, error)

+ func (s *Store) RunInEffect(ctx context.Context, tenantID, decisionID int64) (bool, error)

+ func (s *Store) SeatCheckDone(ctx context.Context, c SeatCheck) error

+ func (s *Store) SeatCheckRetry(ctx context.Context, c SeatCheck, next int64) error

+ func (s *Store) SeatsUsed(ctx context.Context, tenantID, now int64) (int, error)

+ func (s *Store) SetAccountCert(ctx context.Context, id int64, fingerprint string) error

+ func (s *Store) SetInvitationRecord(ctx context.Context, tenantID, id int64, rec string) error

+ func (s *Store) SetPlan(ctx context.Context, tenantID int64, p Plan, now int64) (before, after PlanState, err error)

+ func (s *Store) SetRole(ctx context.Context, tenantID, userID int64, role string, now int64) error

+ func (s *Store) SpendAIEmails(ctx context.Context, tenantID int64, at time.Time, n int) error

+ func (s *Store) SpendCleanupEmail(ctx context.Context, tenantID int64, at time.Time, grant int) (fromGrant bool, err error)

+ func (s *Store) TenantEmails(ctx context.Context, tenantID int64) ([]string, error)

+ func (s *Store) TenantKey(ctx context.Context, tenantID int64) (crypto.TenantKey, error)

+ func (s *Store) TenantOrganisation(ctx context.Context, tenantID int64) (provider, organisation string, err error)

+ func (s *Store) TenantPlan(ctx context.Context, tenantID, now int64) (PlanState, error)

+ func (s *Store) UnsubscribeLinks(ctx context.Context, v Viewer, address string, since int64) ([]UnsubscribeLink, error)

+ func (s *Store) UpgradeSecrets(ctx context.Context) (int, error)

+ func (s *Store) UserIdentity(ctx context.Context, userID int64) (Identity, error)

+ func (s *Store) WaitingDrafts(ctx context.Context, now int64, limit int) ([]DraftJob, error)

+ func (s *Store) WaitingMoves(ctx context.Context, now int64, limit int) ([]Move, error)

+ func (s *Store) WaitingNotices(ctx context.Context, now int64, limit int) ([]Notice, error)

+ func (s *Store) WaitingRemovedMailboxes(ctx context.Context, now int64, limit int) ([]RemovedMailbox, error)

+ func (s *Store) WaitingSeatChecks(ctx context.Context, now int64, limit int) ([]SeatCheck, error)

+ func (s *Store) WithKeyring(k *Keyring) *Store

+ func (s *Store) WithKeys(p crypto.KeyProvider) *Store

+ type UnsubscribeLink struct

+ AccountID int64

+ URL string

type User

+ Role string

v0.2.0

Oct 9, 2026

Changes in this version

+ const NewAccountShared

+ const SelfHostTenant

+ var ErrEmailInUse = errors.New("email in use by another user")

+ var ErrTenantMismatch = errors.New("identity belongs to another tenant")

type Account

+ Shared bool

+ TenantID int64

+ func (a Account) Owner() Viewer

type Batch

+ TenantID int64

+ type Identity struct

+ Email string

+ Provider string

+ Subject string

+ Tenant string

+ type Ledger struct

+ Operator func(provider string) bool

+ Store *Store

+ TenantID int64

+ func (l Ledger) AddUsage(ctx context.Context, day, provider, model, purpose string, ...) error

type Store

+ func (s *Store) AccountTenant(ctx context.Context, accountID int64) (int64, error)

+ func (s *Store) CanSee(ctx context.Context, v Viewer, accountID int64) (bool, error)

+ func (s *Store) CreateTenant(ctx context.Context, provider, externalID string, now int64) (int64, error)

+ func (s *Store) CreateUser(ctx context.Context, tenantID int64, email, passwordHash string, now int64) (User, error)

+ func (s *Store) EndIdentitySessions(ctx context.Context, provider, subject string) error

+ func (s *Store) MessageActivity(ctx context.Context, messageID int64) (ActivityRow, error)

+ func (s *Store) SetAccountShared(ctx context.Context, id int64, shared bool) error

+ func (s *Store) SettingsLike(ctx context.Context, prefix string) (map[int64]map[string]string, error)

+ func (s *Store) SignInIdentity(ctx context.Context, id Identity, now int64) (User, error)

+ func (s *Store) TenantAccounts(ctx context.Context, tenantID int64) ([]Account, error)

+ func (s *Store) TenantMembers(ctx context.Context, tenantID int64) (int, error)

+ func (s *Store) Tenants(ctx context.Context) ([]int64, error)

+ func (s *Store) User(ctx context.Context, id int64) (User, error)

+ func (s *Store) Users(ctx context.Context) ([]User, error)

+ func (s *Store) VisibleAccount(ctx context.Context, v Viewer, id int64) (Account, error)

+ func (s *Store) VisibleAccounts(ctx context.Context, v Viewer) ([]Account, error)

+ func (s *Store) VisibleAction(ctx context.Context, v Viewer, id int64) (Action, error)

+ func (s *Store) VisibleBatch(ctx context.Context, v Viewer, id int64) (Batch, error)

+ func (s *Store) VisibleBatchActions(ctx context.Context, v Viewer, batchID int64) ([]Action, error)

+ func (s *Store) VisibleMessage(ctx context.Context, v Viewer, id int64) (Message, error)

type UsageRow

+ Operator bool

type User

+ TenantID int64

+ func (u User) Viewer() Viewer

+ type Viewer struct

+ TenantID int64

+ UserID int64

v0.1.4

Oct 8, 2026

v0.1.3

Oct 8, 2026

Changes in this version

type Store

+ func (s *Store) ReconcileRemovedMailboxes(ctx context.Context, now int64) ([]rules.Rule, error)

v0.1.2

Oct 8, 2026

Changes in this version

type Batch

+ RunID int64

+ type CleanupBatch struct

+ AccountID int64

+ Folder string

+ ScanLimit int

+ ScanMatched int

+ Since int64

+ Total int

type Store

+ func (s *Store) CreateCleanupRun(ctx context.Context, cs []CleanupBatch, now int64) ([]Batch, error)

+ func (s *Store) SetPassword(ctx context.Context, userID int64, passwordHash string) error

v0.1.1

Oct 8, 2026

v0.1.0

Oct 8, 2026

Changes in this version

+ const ActionDone

+ const ActionDryRun

+ const ActionFailed

+ const ActionUndone

+ const BatchCleanup

+ const BatchCorrection

+ const BatchDone

+ const BatchFailed

+ const BatchLive

+ const BatchRunning

+ const BatchUndo

+ const BatchUndone

+ const CorrectionFix

+ const CorrectionReview

+ const DefaultLeaveOwnMail

+ const DefaultTrashToFolder

+ const KeepMessagesDays

+ const SettingLeaveOwnMail

+ const SettingSummary

+ const SettingTrashToFolder

+ const StateActed

+ const StateDecided

+ const StateError

+ const StateNew

+ const StateReview

+ const StateSkipped

+ const SummaryFailed

+ const SummarySending

+ const SummarySent

+ const UndoDays

+ var ErrAlreadySetUp = errors.New("already set up")

+ var ErrNotFound = errors.New("not found")

+ var ErrRuleSet = errors.New("the list must name every rule exactly once")

+ var Outcomes = []string

+ func Migrate(ctx context.Context, db *sql.DB) error

+ func Open(ctx context.Context, dataDir string) (*sql.DB, error)

+ type Account struct

+ Capabilities []string

+ CreatedAt int64

+ Host string

+ ID int64

+ Label string

+ LastError string

+ LastEventAt int64

+ Port int

+ Preset string

+ Status string

+ TLSMode string

+ UserID int64

+ Username string

+ WatchFolder string

+ func (a Account) OwnAddresses() []string

+ type Action struct

+ AccountID int64

+ After *Snapshot

+ BatchID int64

+ Before Snapshot

+ CreatedAt int64

+ DecisionID int64

+ Error string

+ Folder string

+ ID int64

+ Kind string

+ MessageID int64

+ Status string

+ UndoneAt int64

+ type ActivityFilter struct

+ AccountID int64

+ Action string

+ After FeedCursor

+ ID int64

+ Limit int

+ Outcome string

+ RuleID int64

+ Stage string

+ State string

+ type ActivityRow struct

+ Actions []Action

+ Decision *Decision

+ Message Message

+ func (r ActivityRow) Cursor() FeedCursor

+ type Batch struct

+ AccountID int64

+ CostUSD float64

+ CreatedAt int64

+ Done int

+ Folder string

+ ID int64

+ Kind string

+ ScanLimit int

+ ScanMatched int

+ Since int64

+ Skipped int

+ Status string

+ Tokens int

+ Total int

+ type Contact struct

+ Address string

+ LastSentAt int64

+ type Correction struct

+ CreatedAt int64

+ Example string

+ ID int64

+ Kind string

+ MessageID int64

+ RightRule string

+ RightRuleID int64

+ WrongRuleID int64

+ type Decision struct

+ Confidence float64

+ CostUSD float64

+ CreatedAt int64

+ ID int64

+ LatencyMS int64

+ MessageID int64

+ Model string

+ Probabilities map[int64]float64

+ Reason string

+ RuleID int64

+ RuleName string

+ RuleVersion int

+ Stage string

+ TokensIn int

+ TokensOut int

+ type FeedCursor struct

+ ActedAt int64

+ ID int64

+ type Folder struct

+ AccountID int64

+ Delimiter string

+ LastUID uint32

+ Name string

+ SpecialUse string

+ UIDValidity uint32

+ type Message struct

+ AccountID int64

+ ActedAt int64

+ Attempts int

+ CreatedAt int64

+ CurFolder string

+ CurUID uint32

+ CurUIDValidity uint32

+ Folder string

+ FromAddr string

+ FromDomain string

+ FromName string

+ HasAttachment bool

+ ID int64

+ ListID string

+ MessageID string

+ NextAttemptAt int64

+ ReceivedAt int64

+ Signals Signals

+ Size int64

+ Snippet string

+ State string

+ Subject string

+ ToAddrs []string

+ UID uint32

+ UIDValidity uint32

+ func (m Message) Location() mail.MsgRef

+ type NewRule struct

+ Position *int

+ Rule rules.Rule

+ type RuleStat struct

+ Hits int

+ LastMatchAt int64

+ type RuleUse struct

+ Calls int

+ CostUSD float64

+ Emails int

+ RuleID int64

+ RuleName string

+ type SenderDecision struct

+ Confidence float64

+ Corrected bool

+ RuleID int64

+ Stage string

+ type SenderSeen struct

+ Address string

+ LastSeenAt int64

+ ListUnsubscribe bool

+ Messages int

+ Name string

+ type Signals struct

+ Bulk bool

+ Contact bool

+ DMARC string

+ ListUnsubscribe bool

+ Noreply bool

+ RepliedBefore bool

+ type Snapshot struct

+ Flags []string

+ Folder string

+ UID uint32

+ UIDValidity uint32

+ func (s Snapshot) Ref(accountID int64) mail.MsgRef

+ type Store struct

+ func New(db *sql.DB) *Store

+ func (s *Store) Account(ctx context.Context, id int64) (Account, error)

+ func (s *Store) AccountSecret(ctx context.Context, master []byte, id int64) (string, error)

+ func (s *Store) Accounts(ctx context.Context) ([]Account, error)

+ func (s *Store) Action(ctx context.Context, id int64) (Action, error)

+ func (s *Store) Activity(ctx context.Context, f ActivityFilter) ([]ActivityRow, error)

+ func (s *Store) ActivityFor(ctx context.Context, messageID int64) (ActivityRow, error)

+ func (s *Store) AddBatchProgress(ctx context.Context, id int64, done, skipped, tokens int, costUSD float64) error

+ func (s *Store) AddCorrection(ctx context.Context, userID int64, c Correction, always string) (int64, error)

+ func (s *Store) AddDecision(ctx context.Context, d Decision, state string) (int64, error)

+ func (s *Store) AddFolder(ctx context.Context, accountID int64, name string) error

+ func (s *Store) AddLearnedSenderRule(ctx context.Context, userID int64, address string, ruleID, now int64) (bool, error)

+ func (s *Store) AddUsage(ctx context.Context, day, provider, model, purpose string, ...) error

+ func (s *Store) AdvanceFolder(ctx context.Context, ref mail.MsgRef) error

+ func (s *Store) Batch(ctx context.Context, id int64) (Batch, error)

+ func (s *Store) BatchActionCounts(ctx context.Context, batchID int64) (map[string]int, error)

+ func (s *Store) BatchActions(ctx context.Context, batchID int64) ([]Action, error)

+ func (s *Store) Batches(ctx context.Context, kind string, before int64, limit int) ([]Batch, error)

+ func (s *Store) ClaimSummary(ctx context.Context, userID, dueAt, now int64, maxAttempts int) (id int64, attempt int, ok bool, err error)

+ func (s *Store) Corrections(ctx context.Context, userID int64, limit int) ([]Correction, error)

+ func (s *Store) CountMessages(ctx context.Context, state string) (int, error)

+ func (s *Store) CreateAccount(ctx context.Context, master []byte, a Account, secret string) (Account, error)

+ func (s *Store) CreateBatch(ctx context.Context, kind, status string, now int64) (int64, error)

+ func (s *Store) CreateCleanupBatch(ctx context.Context, accountID int64, folder string, since int64, ...) (Batch, error)

+ func (s *Store) CreateFirstUser(ctx context.Context, email, passwordHash string, now int64) (User, error)

+ func (s *Store) CreateRule(ctx context.Context, r rules.Rule, now int64) (rules.Rule, error)

+ func (s *Store) CreateRules(ctx context.Context, userID int64, added []NewRule, now int64) ([]rules.Rule, error)

+ func (s *Store) CreateSession(ctx context.Context, tokenHash string, userID, now, expiresAt int64) error

+ func (s *Store) DeleteAccount(ctx context.Context, id int64) error

+ func (s *Store) DeleteRule(ctx context.Context, userID, id int64) error

+ func (s *Store) DeleteSenderRule(ctx context.Context, userID int64, matchType, value string) error

+ func (s *Store) DeleteSession(ctx context.Context, tokenHash string) error

+ func (s *Store) DoneActionsSince(ctx context.Context, ruleID, since int64) ([]Action, error)

+ func (s *Store) DryRun(ctx context.Context, def bool) (bool, error)

+ func (s *Store) DueMessages(ctx context.Context, accountID, now int64) ([]Message, error)

+ func (s *Store) ExtendSession(ctx context.Context, tokenHash string, expiresAt int64) error

+ func (s *Store) FailRunningBatches(ctx context.Context) error

+ func (s *Store) FinishAction(ctx context.Context, a Action) error

+ func (s *Store) FinishSummary(ctx context.Context, id int64, sent bool, periodStart, periodEnd, now int64) error

+ func (s *Store) FirstUser(ctx context.Context) (User, error)

+ func (s *Store) Folder(ctx context.Context, accountID int64, name string) (Folder, error)

+ func (s *Store) Folders(ctx context.Context, accountID int64) ([]Folder, error)

+ func (s *Store) HasUsers(ctx context.Context) (bool, error)

+ func (s *Store) HitSenderRule(ctx context.Context, id int64) error

+ func (s *Store) ImportRules(ctx context.Context, userID int64, imported []rules.Rule, now int64) (created, updated int, err error)

+ func (s *Store) IngestMessage(ctx context.Context, ref mail.MsgRef, now int64) (m Message, fresh bool, err error)

+ func (s *Store) InsertAction(ctx context.Context, a Action) (int64, error)

+ func (s *Store) IsContact(ctx context.Context, accountID int64, address string) (bool, error)

+ func (s *Store) LastMailAt(ctx context.Context, accountID int64) (int64, error)

+ func (s *Store) LastSentSummary(ctx context.Context, userID int64) (Summary, error)

+ func (s *Store) LeaveOwnMail(ctx context.Context) (bool, error)

+ func (s *Store) LiveBatch(ctx context.Context, now time.Time) (int64, error)

+ func (s *Store) MarkActionUndone(ctx context.Context, a Action, restored mail.MsgRef, now int64) error

+ func (s *Store) Message(ctx context.Context, id int64) (Message, error)

+ func (s *Store) MessageActions(ctx context.Context, messageID int64) ([]Action, error)

+ func (s *Store) MessageByMessageID(ctx context.Context, accountID int64, messageID string, except int64) (Message, error)

+ func (s *Store) MessageCorrections(ctx context.Context, messageID int64) ([]Correction, error)

+ func (s *Store) MessageDecisions(ctx context.Context, messageID int64) ([]Decision, error)

+ func (s *Store) Ping(ctx context.Context) error

+ func (s *Store) PutSenderRule(ctx context.Context, sr rules.SenderRule, now int64) (rules.SenderRule, error)

+ func (s *Store) QuietRules(ctx context.Context, userID, since int64) (int, error)

+ func (s *Store) Rebind(ctx context.Context, fresh, known int64, ref mail.MsgRef) (bool, error)

+ func (s *Store) RecentSenderDecisions(ctx context.Context, userID int64, address string, n int) ([]SenderDecision, error)

+ func (s *Store) ReorderRules(ctx context.Context, userID int64, ids []int64) error

+ func (s *Store) Retain(ctx context.Context, now int64, retentionDays int) (blanked, deleted int64, err error)

+ func (s *Store) Rule(ctx context.Context, userID, id int64) (rules.Rule, error)

+ func (s *Store) RuleCosts(ctx context.Context, userID, since int64) ([]RuleUse, error)

+ func (s *Store) RuleStats(ctx context.Context, userID, since int64) (map[int64]RuleStat, error)

+ func (s *Store) Rules(ctx context.Context, userID int64) ([]rules.Rule, error)

+ func (s *Store) SaveFolders(ctx context.Context, accountID int64, folders []Folder) error

+ func (s *Store) SaveMessageSummary(ctx context.Context, m Message) error

+ func (s *Store) SenderRules(ctx context.Context, userID int64) ([]rules.SenderRule, error)

+ func (s *Store) SendersSeen(ctx context.Context, userID, since int64) ([]SenderSeen, error)

+ func (s *Store) SessionUser(ctx context.Context, tokenHash string, now int64) (User, int64, error)

+ func (s *Store) SetAccountCapabilities(ctx context.Context, id int64, capabilities []string) error

+ func (s *Store) SetAccountSecret(ctx context.Context, master []byte, id int64, secret string) error

+ func (s *Store) SetAccountStatus(ctx context.Context, id int64, status, lastError string, now int64) error

+ func (s *Store) SetBatchProgress(ctx context.Context, id int64, total, done int) error

+ func (s *Store) SetBatchStatus(ctx context.Context, id int64, status string) error

+ func (s *Store) SetDryRun(ctx context.Context, on bool) error

+ func (s *Store) SetFolderPosition(ctx context.Context, accountID int64, name string, uidValidity, lastUID uint32) error

+ func (s *Store) SetMessageState(ctx context.Context, id int64, state string, attempts int, nextAttemptAt int64) error

+ func (s *Store) SetSetting(ctx context.Context, key, value string) error

+ func (s *Store) SetSettings(ctx context.Context, values map[string]*string) error

+ func (s *Store) SetTrashToFolder(ctx context.Context, on bool) error

+ func (s *Store) Setting(ctx context.Context, key string) (string, error)

+ func (s *Store) Settings(ctx context.Context) (map[string]string, error)

+ func (s *Store) StatsTotals(ctx context.Context, userID, since int64) (Totals, error)

+ func (s *Store) SummaryCost(ctx context.Context, userID, from, to int64) (costUSD float64, calls int, err error)

+ func (s *Store) SummaryReview(ctx context.Context, userID int64, limit int) ([]SummaryEmail, int, error)

+ func (s *Store) SummaryRules(ctx context.Context, userID, from, to int64) ([]RuleUse, error)

+ func (s *Store) SummaryTrashed(ctx context.Context, userID, from, to int64, limit int) ([]SummaryEmail, int, error)

+ func (s *Store) TopRules(ctx context.Context, userID, since int64, limit int) ([]RuleUse, error)

+ func (s *Store) TrashToFolder(ctx context.Context) (bool, error)

+ func (s *Store) UpdateAccount(ctx context.Context, a Account) error

+ func (s *Store) UpdateRule(ctx context.Context, r rules.Rule, now int64) error

+ func (s *Store) UpsertContacts(ctx context.Context, accountID int64, contacts []Contact) error

+ func (s *Store) Usage(ctx context.Context, sinceDay string) ([]UsageRow, error)

+ func (s *Store) UserByEmail(ctx context.Context, email string) (User, error)

+ type Summary struct

+ Attempts int

+ DueAt int64

+ ID int64

+ LastAttemptAt int64

+ PeriodEnd int64

+ PeriodStart int64

+ SentAt int64

+ Status string

+ UserID int64

+ type SummaryEmail struct

+ DryRun bool

+ Folder string

+ FromAddr string

+ FromName string

+ MessageID int64

+ Subject string

+ type Totals struct

+ Processed int

+ Sorted int

+ Trashed int

+ WentNowhere int

+ WentReview int

+ WentSorted int

+ WentTrash int

+ WithoutModel int

+ type UsageRow struct

+ Calls int

+ CostUSD float64

+ Day string

+ Model string

+ Provider string

+ Purpose string

+ TokensIn int

+ TokensOut int

+ type User struct

+ CreatedAt int64

+ Email string

+ ID int64

+ PasswordHash string

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