database

Documentation

Index

• func IsErrNotFound(err error) bool
• type DecodeError
  • func (e *DecodeError) Error() string
• type ErrNotFound
  • func (e *ErrNotFound) Error() string
• type ExecutionDB
• type LevelDBExecutionDB
  • func NewExecutionDB(path string) (*LevelDBExecutionDB, error)
  • func (db *LevelDBExecutionDB) Close() error
  • func (db *LevelDBExecutionDB) Find(executionID string) (*execution.Execution, error)
  • func (db *LevelDBExecutionDB) Save(execution *execution.Execution) error
• type LevelDBServiceDB
  • func NewServiceDB(path string) (*LevelDBServiceDB, error)
  • func (d *LevelDBServiceDB) All() ([]*service.Service, error)
  • func (d *LevelDBServiceDB) Close() error
  • func (d *LevelDBServiceDB) Delete(hashOrSID string) error
  • func (d *LevelDBServiceDB) Get(hashOrSID string) (*service.Service, error)
  • func (d *LevelDBServiceDB) Save(s *service.Service) error
• type ServiceDB

Functions

func IsErrNotFound

func IsErrNotFound(err error) bool

IsErrNotFound returns 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

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

ExecutionDB exposes all the functionalities

type LevelDBExecutionDB

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

LevelDBExecutionDB is a concrete implementation of the DB interface

func NewExecutionDB

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

NewExecutionDB creates a new DB instance

func (*LevelDBExecutionDB) Close

func (db *LevelDBExecutionDB) Close() error

Close closes database.

func (*LevelDBExecutionDB) Find

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

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

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

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

All returns every service in database.

func (*LevelDBServiceDB) Close

func (d *LevelDBServiceDB) Close() error

Close closes database.

func (*LevelDBServiceDB) Delete

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

Delete deletes service from database.

func (*LevelDBServiceDB) Get

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

Get retrives service from database.

func (*LevelDBServiceDB) Save

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

Save stores service in database. If there is an another service that uses the same sid, it'll be deleted.

type ServiceDB

type ServiceDB interface {
	// Save saves a service to database.
	Save(s *service.Service) error

	// Get gets a service from database by its unique id
	// or unique sid.
	Get(hashOrSID string) (*service.Service, error)

	// Delete deletes a service from database by its unique id
	// or unique sid.
	Delete(hashOrSID string) error

	// All returns all services from database.
	All() ([]*service.Service, error)

	// Close closes underlying database connection.
	Close() error
}

ServiceDB describes the API of database package.