query

Feb 9, 2026

Changes in this version

+ var RequiredParquetDirs = []string

+ func HasCompleteParquetData(analyticsDir string) bool

type AggregateOptions

+ HideDeletedFromSource bool

type MessageDetail

+ SourceConversationID string

type MessageFilter

+ HideDeletedFromSource bool

type MessageSummary

+ SourceConversationID string

type StatsOptions

+ HideDeletedFromSource bool

Feb 7, 2026

Changes in this version

+ func HintRepairEncoding(err error) error

+ func IsEncodingError(err error) bool

Feb 5, 2026

Changes in this version

type DuckDBEngine

+ func (e *DuckDBEngine) SearchFastWithStats(ctx context.Context, q *search.Query, queryStr string, filter MessageFilter, ...) (*SearchFastResult, error)

+ type DuckDBOptions struct

+ DisableSQLiteScanner bool

type Engine

+ SearchFastWithStats func(ctx context.Context, query *search.Query, queryStr string, ...) (*SearchFastResult, error)

type SQLiteEngine

+ func (e *SQLiteEngine) SearchFastWithStats(ctx context.Context, q *search.Query, queryStr string, filter MessageFilter, ...) (*SearchFastResult, error)

+ type SearchFastResult struct

+ Messages []MessageSummary

+ Stats *TotalStats

+ TotalCount int64

Feb 3, 2026

Changes in this version

type DuckDBEngine

+ func (e *DuckDBEngine) Aggregate(ctx context.Context, groupBy ViewType, opts AggregateOptions) ([]AggregateRow, error)

type Engine

+ Aggregate func(ctx context.Context, groupBy ViewType, opts AggregateOptions) ([]AggregateRow, error)

type MessageFilter

+ EmptyValueTargets map[ViewType]bool

+ Pagination Pagination

+ Sorting MessageSorting

+ TimeRange TimeRange

+ func (f *MessageFilter) HasEmptyTargets() bool

+ func (f *MessageFilter) MatchesEmpty(v ViewType) bool

+ func (f *MessageFilter) SetEmptyTarget(v ViewType)

+ func (f MessageFilter) Clone() MessageFilter

+ type MessageSorting struct

+ Direction SortDirection

+ Field MessageSortField

+ type Pagination struct

+ Limit int

+ Offset int

type SQLiteEngine

+ func (e *SQLiteEngine) Aggregate(ctx context.Context, groupBy ViewType, opts AggregateOptions) ([]AggregateRow, error)

type TimeGranularity

+ const TimeGranularityCount

+ type TimeRange struct

+ Granularity TimeGranularity

+ Period string

type ViewType

+ const ViewTypeCount

Feb 2, 2026

Changes in this version

+ func HasParquetData(analyticsDir string) bool

+ func MergeFilterIntoQuery(q *search.Query, filter MessageFilter) *search.Query

+ type AccountInfo struct

+ DisplayName string

+ ID int64

+ Identifier string

+ SourceType string

+ type Address struct

+ Email string

+ Name string

+ type AggregateFunc func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ type AggregateOptions struct

+ After *time.Time

+ Before *time.Time

+ Limit int

+ SearchQuery string

+ SortDirection SortDirection

+ SortField SortField

+ SourceID *int64

+ TimeGranularity TimeGranularity

+ WithAttachmentsOnly bool

+ func DefaultAggregateOptions() AggregateOptions

+ type AggregateRow struct

+ AttachmentCount int64

+ AttachmentSize int64

+ Count int64

+ Key string

+ TotalSize int64

+ TotalUnique int64

+ type AttachmentInfo struct

+ ContentHash string

+ Filename string

+ ID int64

+ MimeType string

+ Size int64

+ type DuckDBEngine struct

+ func NewDuckDBEngine(analyticsDir string, sqlitePath string, sqliteDB *sql.DB) (*DuckDBEngine, error)

+ func (e *DuckDBEngine) AggregateByDomain(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *DuckDBEngine) AggregateByLabel(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *DuckDBEngine) AggregateByRecipient(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *DuckDBEngine) AggregateByRecipientName(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *DuckDBEngine) AggregateBySender(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *DuckDBEngine) AggregateBySenderName(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *DuckDBEngine) AggregateByTime(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *DuckDBEngine) Close() error

+ func (e *DuckDBEngine) GetAttachment(ctx context.Context, id int64) (*AttachmentInfo, error)

+ func (e *DuckDBEngine) GetGmailIDsByFilter(ctx context.Context, filter MessageFilter) ([]string, error)

+ func (e *DuckDBEngine) GetMessage(ctx context.Context, id int64) (*MessageDetail, error)

+ func (e *DuckDBEngine) GetMessageBySourceID(ctx context.Context, sourceMessageID string) (*MessageDetail, error)

+ func (e *DuckDBEngine) GetTotalStats(ctx context.Context, opts StatsOptions) (*TotalStats, error)

+ func (e *DuckDBEngine) ListAccounts(ctx context.Context) ([]AccountInfo, error)

+ func (e *DuckDBEngine) ListMessages(ctx context.Context, filter MessageFilter) ([]MessageSummary, error)

+ func (e *DuckDBEngine) Search(ctx context.Context, q *search.Query, limit, offset int) ([]MessageSummary, error)

+ func (e *DuckDBEngine) SearchFast(ctx context.Context, q *search.Query, filter MessageFilter, limit, offset int) ([]MessageSummary, error)

+ func (e *DuckDBEngine) SearchFastCount(ctx context.Context, q *search.Query, filter MessageFilter) (int64, error)

+ func (e *DuckDBEngine) SubAggregate(ctx context.Context, filter MessageFilter, groupBy ViewType, ...) ([]AggregateRow, error)

+ type Engine interface

+ AggregateByDomain func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ AggregateByLabel func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ AggregateByRecipient func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ AggregateByRecipientName func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ AggregateBySender func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ AggregateBySenderName func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ AggregateByTime func(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ Close func() error

+ GetAttachment func(ctx context.Context, id int64) (*AttachmentInfo, error)

+ GetGmailIDsByFilter func(ctx context.Context, filter MessageFilter) ([]string, error)

+ GetMessage func(ctx context.Context, id int64) (*MessageDetail, error)

+ GetMessageBySourceID func(ctx context.Context, sourceMessageID string) (*MessageDetail, error)

+ GetTotalStats func(ctx context.Context, opts StatsOptions) (*TotalStats, error)

+ ListAccounts func(ctx context.Context) ([]AccountInfo, error)

+ ListMessages func(ctx context.Context, filter MessageFilter) ([]MessageSummary, error)

+ Search func(ctx context.Context, query *search.Query, limit, offset int) ([]MessageSummary, error)

+ SearchFast func(ctx context.Context, query *search.Query, filter MessageFilter, ...) ([]MessageSummary, error)

+ SearchFastCount func(ctx context.Context, query *search.Query, filter MessageFilter) (int64, error)

+ SubAggregate func(ctx context.Context, filter MessageFilter, groupBy ViewType, ...) ([]AggregateRow, error)

+ type MessageDetail struct

+ Attachments []AttachmentInfo

+ Bcc []Address

+ BodyHTML string

+ BodyText string

+ Cc []Address

+ ConversationID int64

+ From []Address

+ HasAttachments bool

+ ID int64

+ Labels []string

+ ReceivedAt *time.Time

+ SentAt time.Time

+ SizeEstimate int64

+ Snippet string

+ SourceMessageID string

+ Subject string

+ To []Address

+ type MessageFilter struct

+ After *time.Time

+ Before *time.Time

+ ConversationID *int64

+ Domain string

+ Label string

+ Limit int

+ MatchEmptyDomain bool

+ MatchEmptyLabel bool

+ MatchEmptyRecipient bool

+ MatchEmptyRecipientName bool

+ MatchEmptySender bool

+ MatchEmptySenderName bool

+ Offset int

+ Recipient string

+ RecipientName string

+ Sender string

+ SenderName string

+ SortDirection SortDirection

+ SortField MessageSortField

+ SourceID *int64

+ TimeGranularity TimeGranularity

+ TimePeriod string

+ WithAttachmentsOnly bool

+ type MessageSortField int

+ const MessageSortByDate

+ const MessageSortBySize

+ const MessageSortBySubject

+ type MessageSummary struct

+ AttachmentCount int

+ ConversationID int64

+ DeletedAt *time.Time

+ FromEmail string

+ FromName string

+ HasAttachments bool

+ ID int64

+ Labels []string

+ SentAt time.Time

+ SizeEstimate int64

+ Snippet string

+ SourceMessageID string

+ Subject string

+ type ParquetSyncState struct

+ LastMessageID int64

+ LastSyncAt time.Time

+ type SQLiteEngine struct

+ func NewSQLiteEngine(db *sql.DB) *SQLiteEngine

+ func (e *SQLiteEngine) AggregateByDomain(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *SQLiteEngine) AggregateByLabel(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *SQLiteEngine) AggregateByRecipient(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *SQLiteEngine) AggregateByRecipientName(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *SQLiteEngine) AggregateBySender(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *SQLiteEngine) AggregateBySenderName(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *SQLiteEngine) AggregateByTime(ctx context.Context, opts AggregateOptions) ([]AggregateRow, error)

+ func (e *SQLiteEngine) Close() error

+ func (e *SQLiteEngine) GetAggregateFunc(viewType ViewType) AggregateFunc

+ func (e *SQLiteEngine) GetAttachment(ctx context.Context, id int64) (*AttachmentInfo, error)

+ func (e *SQLiteEngine) GetGmailIDsByFilter(ctx context.Context, filter MessageFilter) ([]string, error)

+ func (e *SQLiteEngine) GetMessage(ctx context.Context, id int64) (*MessageDetail, error)

+ func (e *SQLiteEngine) GetMessageBySourceID(ctx context.Context, sourceMessageID string) (*MessageDetail, error)

+ func (e *SQLiteEngine) GetTotalStats(ctx context.Context, opts StatsOptions) (*TotalStats, error)

+ func (e *SQLiteEngine) ListAccounts(ctx context.Context) ([]AccountInfo, error)

+ func (e *SQLiteEngine) ListMessages(ctx context.Context, filter MessageFilter) ([]MessageSummary, error)

+ func (e *SQLiteEngine) Search(ctx context.Context, q *search.Query, limit, offset int) ([]MessageSummary, error)

+ func (e *SQLiteEngine) SearchFast(ctx context.Context, q *search.Query, filter MessageFilter, limit, offset int) ([]MessageSummary, error)

+ func (e *SQLiteEngine) SearchFastCount(ctx context.Context, q *search.Query, filter MessageFilter) (int64, error)

+ func (e *SQLiteEngine) SubAggregate(ctx context.Context, filter MessageFilter, groupBy ViewType, ...) ([]AggregateRow, error)

+ type SortDirection int

+ const SortAsc

+ const SortDesc

+ type SortField int

+ const SortByAttachmentSize

+ const SortByCount

+ const SortByName

+ const SortBySize

+ func (f SortField) String() string

+ type StatsOptions struct

+ GroupBy ViewType

+ SearchQuery string

+ SourceID *int64

+ WithAttachmentsOnly bool

+ type TimeGranularity int

+ const TimeDay

+ const TimeMonth

+ const TimeYear

+ func (g TimeGranularity) String() string

+ type TotalStats struct

+ AccountCount int64

+ AttachmentCount int64

+ AttachmentSize int64

+ LabelCount int64

+ MessageCount int64

+ TotalSize int64

+ type ViewType int

+ const ViewDomains

+ const ViewLabels

+ const ViewRecipientNames

+ const ViewRecipients

+ const ViewSenderNames

+ const ViewSenders

+ const ViewTime

+ func (v ViewType) String() string