sqlite3

Documentation

Index

• func NewBuilder(options ...Option) db.ClientInterface
• func RunMigrations(ctx context.Context, tx utils.QueryWrapper, ...) error
• func ScanMailbox(scanner utils.RowScanner) (*db.Mailbox, error)
• func ScanMailboxWithAttr(scanner utils.RowScanner) (*db.MailboxWithAttr, error)
• func ScanMessage(scanner utils.RowScanner) (*db.Message, error)
• func ScanMessageWithFlags(scanner utils.RowScanner) (*db.MessageWithFlags, error)
• func TestUpdateDBVersion(ctx context.Context, dbPath, userID string, version int) error
• type Builder
  • func (Builder) Delete(dir string, userID string) error
  • func (b Builder) New(dir string, userID string) (db.Client, bool, error)
• type Client
  • func NewClient(dir string, userID string, debug, trace bool) (*Client, bool, error)
  • func (c *Client) Close() error
  • func (c *Client) Init(ctx context.Context, generator imap.UIDValidityGenerator) error
  • func (c *Client) Read(ctx context.Context, op func(context.Context, db.ReadOnly) error) error
  • func (c *Client) Write(ctx context.Context, op func(context.Context, db.Transaction) error) error
• type Migration
• type Option
  • func Debug() Option
  • func Trace() Option

Functions

func NewBuilder

func NewBuilder(options ...Option) db.ClientInterface

func RunMigrations

func RunMigrations(ctx context.Context, tx utils.QueryWrapper, generator imap.UIDValidityGenerator) error

func ScanMailbox

func ScanMailbox(scanner utils.RowScanner) (*db.Mailbox, error)

func ScanMailboxWithAttr

func ScanMailboxWithAttr(scanner utils.RowScanner) (*db.MailboxWithAttr, error)

func ScanMessage

func ScanMessage(scanner utils.RowScanner) (*db.Message, error)

func ScanMessageWithFlags

func ScanMessageWithFlags(scanner utils.RowScanner) (*db.MessageWithFlags, error)

func TestUpdateDBVersion

func TestUpdateDBVersion(ctx context.Context, dbPath, userID string, version int) error

Types

type Builder

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

func (Builder) Delete

func (Builder) Delete(dir string, userID string) error

func (Builder) New

func (b Builder) New(dir string, userID string) (db.Client, bool, error)

type Client

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

func NewClient

func NewClient(dir string, userID string, debug, trace bool) (*Client, bool, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Init

func (c *Client) Init(ctx context.Context, generator imap.UIDValidityGenerator) error

func (*Client) Read

func (c *Client) Read(ctx context.Context, op func(context.Context, db.ReadOnly) error) error

func (*Client) Write

func (c *Client) Write(ctx context.Context, op func(context.Context, db.Transaction) error) error

type Migration

type Migration interface {
	Run(ctx context.Context, tx utils.QueryWrapper, generator imap.UIDValidityGenerator) error
}

type Option

type Option interface {
	// contains filtered or unexported methods
}

func Debug

func Debug() Option

Debug enables logging of the SQL queries and their values. Written to debug log.

func Trace

func Trace() Option

Trace enables db interface call tracing. Name of the called functions will be written to trace log.