localdb

package

v0.0.0-...-4c91ef0 Latest Latest Go to latest Published: Oct 28, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package localdb implements a diviner database on the local file system using boltdb.

This section is empty.

This section is empty.

This section is empty.

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

DB implements diviner.Database using Bolt.

func Open(filename string) (db *DB, err error)

Open opens and returns a new database with the provided filename. The file is created if it does not already exist.

func (d *DB) AppendRunMetrics(ctx context.Context, study string, seq uint64, metrics diviner.Metrics) error

func (d *DB) CreateStudyIfNotExist(ctx context.Context, study diviner.Study) (created bool, err error)

func (*DB) CreateTable(_ context.Context) error

CreateTable is a no-op.

func (d *DB) InsertRun(ctx context.Context, run diviner.Run) (diviner.Run, error)

New implements diviner.Database.

func (d *DB) ListRuns(ctx context.Context, study string, states diviner.RunState, since time.Time) (runs []diviner.Run, err error)

Runs implements diviner.Database.

func (d *DB) ListStudies(ctx context.Context, prefix string, since time.Time) (studies []diviner.Study, err error)

Studies implements diviner.Database.

func (d *DB) Log(study string, seq uint64, since time.Time, follow bool) io.Reader

Log implements diviner.Run.

func (d *DB) Logger(study string, seq uint64) io.WriteCloser

func (d *DB) LookupRun(ctx context.Context, study string, seq uint64) (run diviner.Run, err error)

Run implements diviner.Database.

func (d *DB) LookupStudy(ctx context.Context, name string) (study diviner.Study, err error)

Study implements diviner.Database.

func (d *DB) NextSeq(ctx context.Context, study string) (seq uint64, err error)

NextSeq reserves and returns the next sequence number for the provided study.

func (d *DB) UpdateRun(ctx context.Context, study string, seq uint64, state diviner.RunState, message string, runtime time.Duration, retry int) error