database

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsErrNotFound 

func IsErrNotFound(err error) bool

IsErrNotFound returs true if err is type of ErrNotFound, false otherwise.

Types

type DecodeError 

type DecodeError struct {
	ID string
}

DecodeError represents a service impossible to decode.

func (*DecodeError) Error 

func (e *DecodeError) Error() string

type ErrNotFound 

type ErrNotFound struct {
	ID string
}

ErrNotFound is an not found error.

func (*ErrNotFound) Error 

func (e *ErrNotFound) Error() string

type ExecutionDB added in v0.4.0 

type ExecutionDB interface {
	Find(executionID string) (*execution.Execution, error)
	Save(execution *execution.Execution) error
	Close() error
}

ExecutionDB exposes all the functionalities

type LevelDBExecutionDB added in v0.4.0 

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

LevelDBExecutionDB is a concrete implementation of the DB interface

func NewExecutionDB added in v0.4.0 

func NewExecutionDB(path string) (*LevelDBExecutionDB, error)

NewExecutionDB creates a new DB instance

func (*LevelDBExecutionDB) Close added in v0.4.0 

func (db *LevelDBExecutionDB) Close() error

Close closes database.

func (*LevelDBExecutionDB) Find added in v0.4.0 

func (db *LevelDBExecutionDB) Find(executionID string) (*execution.Execution, error)

Find the execution based on an executionID, returns an error if not found

func (*LevelDBExecutionDB) Save added in v0.4.0 

func (db *LevelDBExecutionDB) Save(execution *execution.Execution) error

Save an instance of executable in the database Returns an error if anything from marshaling to database saving goes wrong

type LevelDBServiceDB added in v0.4.0 

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

LevelDBServiceDB is a database for storing service definition.

func NewServiceDB 

func NewServiceDB(path string) (*LevelDBServiceDB, error)

NewServiceDB returns the database which is located under given path.

func (*LevelDBServiceDB) All added in v0.4.0 

func (d *LevelDBServiceDB) All() ([]*service.Service, error)

All returns every service in database.

func (*LevelDBServiceDB) Close added in v0.4.0 

func (d *LevelDBServiceDB) Close() error

Close closes database.

func (*LevelDBServiceDB) Delete added in v0.4.0 

func (d *LevelDBServiceDB) Delete(id string) error

Delete deletes service from database.

func (*LevelDBServiceDB) Get added in v0.4.0 

func (d *LevelDBServiceDB) Get(id string) (*service.Service, error)

Get retrives service from database.

func (*LevelDBServiceDB) Save added in v0.4.0 

func (d *LevelDBServiceDB) Save(s *service.Service) error

Save stores service in database.

type ServiceDB 

type ServiceDB interface {
	All() ([]*service.Service, error)
	Close() error
	Delete(id string) error
	Get(id string) (*service.Service, error)
	Save(s *service.Service) error
}

ServiceDB describes the API of database package.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.