store

package
v0.0.0-...-31ca664 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 4, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrBadTable = errors.New("invalid table name")
)
View Source
var (
	ErrUnexpectedColumnType = errors.New("unexpected column type")
)

Functions

func Plugin

func Plugin() plugin.Plugin

Types

type SqliteStore

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

SqliteStore is a store for LogEntries using Sqlite3 as a storage engine.

func NewStore

func NewStore(log hclog.Logger, filename string) (*SqliteStore, error)

func (*SqliteStore) Close

func (s *SqliteStore) Close() error

func (*SqliteStore) CtxQueryEntries

func (s *SqliteStore) CtxQueryEntries(ctx context.Context, table string) (iterator.Iterator, error)

func (*SqliteStore) CtxSink

func (s *SqliteStore) CtxSink(ctx context.Context, iter iterator.Iterator, table string) error

func (*SqliteStore) QueryEntries

func (s *SqliteStore) QueryEntries(table string) (iterator.Iterator, error)

func (*SqliteStore) Sink

func (s *SqliteStore) Sink(iter iterator.Iterator, table string) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL