Documentation
¶
Index ¶
- Variables
- type SQLite
- func (db *SQLite) Delete(key string) error
- func (db *SQLite) Get(key string) (record.Record, error)
- func (db *SQLite) GetMeta(key string) (*record.Meta, error)
- func (db *SQLite) Injected() bool
- func (db *SQLite) Maintain(ctx context.Context) error
- func (db *SQLite) MaintainRecordStates(ctx context.Context, purgeDeletedBefore time.Time, shadowDelete bool) error
- func (db *SQLite) MaintainThorough(ctx context.Context) error
- func (db *SQLite) Purge(ctx context.Context, q *query.Query, local, internal, shadowDelete bool) (int, error)
- func (db *SQLite) Put(r record.Record) (record.Record, error)
- func (db *SQLite) PutMany(shadowDelete bool) (chan<- record.Record, <-chan error)
- func (db *SQLite) Query(q *query.Query, local, internal bool) (*iterator.Iterator, error)
- func (db *SQLite) ReadOnly() bool
- func (db *SQLite) Shutdown() error
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrQueryTimeout = errors.New("query timeout")
)
Errors.
Functions ¶
This section is empty.
Types ¶
type SQLite ¶
type SQLite struct {
// contains filtered or unexported fields
}
SQLite storage.
func (*SQLite) MaintainRecordStates ¶
func (db *SQLite) MaintainRecordStates(ctx context.Context, purgeDeletedBefore time.Time, shadowDelete bool) error
MaintainRecordStates maintains records states in the database.
func (*SQLite) Purge ¶
func (db *SQLite) Purge(ctx context.Context, q *query.Query, local, internal, shadowDelete bool) (int, error)
Purge deletes all records that match the given query. It returns the number of successful deletes and an error.
Click to show internal directories.
Click to hide internal directories.