sqlitestore

Documentation

Index

• Variables
• type SqliteStore
  • func NewSqliteStore(db string) (*SqliteStore, error)
  • func (m *SqliteStore) Add(op ...*v1.Operation) error
  • func (m *SqliteStore) Close() error
  • func (m *SqliteStore) Delete(opID ...int64) ([]*v1.Operation, error)
  • func (m *SqliteStore) Get(opID int64) (*v1.Operation, error)
  • func (m *SqliteStore) Query(q oplog.Query, f func(*v1.Operation) error) error
  • func (m *SqliteStore) SetVersion(version int64) error
  • func (m *SqliteStore) Transform(q oplog.Query, f func(*v1.Operation) (*v1.Operation, error)) error
  • func (m *SqliteStore) Update(op ...*v1.Operation) error
  • func (m *SqliteStore) Version() (int64, error)

Variables

var ErrLocked = errors.New("sqlite db is locked")

Types

type SqliteStore

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

func NewSqliteStore

func NewSqliteStore(db string) (*SqliteStore, error)

func (*SqliteStore) Add

func (m *SqliteStore) Add(op ...*v1.Operation) error

func (*SqliteStore) Close

func (m *SqliteStore) Close() error

func (*SqliteStore) Delete

func (m *SqliteStore) Delete(opID ...int64) ([]*v1.Operation, error)

func (*SqliteStore) Get

func (m *SqliteStore) Get(opID int64) (*v1.Operation, error)

func (*SqliteStore) Query

func (m *SqliteStore) Query(q oplog.Query, f func(*v1.Operation) error) error

func (*SqliteStore) SetVersion

func (m *SqliteStore) SetVersion(version int64) error

func (*SqliteStore) Transform

func (m *SqliteStore) Transform(q oplog.Query, f func(*v1.Operation) (*v1.Operation, error)) error

func (*SqliteStore) Update

func (m *SqliteStore) Update(op ...*v1.Operation) error

func (*SqliteStore) Version

func (m *SqliteStore) Version() (int64, error)