persist

Documentation

Index

• type DB
  • func Open(ctx context.Context, path string) (*DB, error)
  • func (db *DB) Begin(ctx context.Context) (*Tx, error)
  • func (db *DB) Close() error
• type Tx
  • func (tx *Tx) Commit() error
  • func (tx *Tx) InsertMessageID(ctx context.Context, account string, msg message.ID) error
  • func (tx *Tx) LatestHistoryID(ctx context.Context) (uint64, error)
  • func (tx *Tx) ListUpdated(ctx context.Context, account string, limit int, handler func(message.ID) error) error
  • func (tx *Tx) Rollback() error
  • func (tx *Tx) UpdateHeader(ctx context.Context, account string, hdr *message.Header) error
  • func (tx *Tx) WriteHistoryID(ctx context.Context, account string, history_id uint64) error

Types

type DB

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

func Open

func Open(ctx context.Context, path string) (*DB, error)

func (*DB) Begin

func (db *DB) Begin(ctx context.Context) (*Tx, error)

func (*DB) Close

func (db *DB) Close() error

type Tx

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

func (*Tx) Commit

func (tx *Tx) Commit() error

func (*Tx) InsertMessageID

func (tx *Tx) InsertMessageID(ctx context.Context, account string, msg message.ID) error

func (*Tx) LatestHistoryID

func (tx *Tx) LatestHistoryID(ctx context.Context) (uint64, error)

func (*Tx) ListUpdated

func (tx *Tx) ListUpdated(ctx context.Context, account string, limit int, handler func(message.ID) error) error

func (*Tx) Rollback

func (tx *Tx) Rollback() error

func (*Tx) UpdateHeader

func (tx *Tx) UpdateHeader(ctx context.Context, account string, hdr *message.Header) error

func (*Tx) WriteHistoryID

func (tx *Tx) WriteHistoryID(ctx context.Context, account string, history_id uint64) error