database

Documentation

Index

• type LevelDBProcessDB
  • func NewProcessDB(path string) (*LevelDBProcessDB, error)
  • func (d *LevelDBProcessDB) All() ([]*process.Process, error)
  • func (d *LevelDBProcessDB) Close() error
  • func (d *LevelDBProcessDB) Delete(hash hash.Hash) error
  • func (d *LevelDBProcessDB) Get(hash hash.Hash) (*process.Process, error)
  • func (d *LevelDBProcessDB) Save(s *process.Process) error
• type ProcessDB

Types

type LevelDBProcessDB

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

LevelDBProcessDB is a database for storing processes definition.

func NewProcessDB

func NewProcessDB(path string) (*LevelDBProcessDB, error)

NewProcessDB returns the database which is located under given path.

func (*LevelDBProcessDB) All

func (d *LevelDBProcessDB) All() ([]*process.Process, error)

All returns every process in database.

func (*LevelDBProcessDB) Close

func (d *LevelDBProcessDB) Close() error

Close closes database.

func (*LevelDBProcessDB) Delete

func (d *LevelDBProcessDB) Delete(hash hash.Hash) error

Delete deletes process from database.

func (*LevelDBProcessDB) Get

func (d *LevelDBProcessDB) Get(hash hash.Hash) (*process.Process, error)

Get retrives process from database.

func (*LevelDBProcessDB) Save

func (d *LevelDBProcessDB) Save(s *process.Process) error

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

type ProcessDB

type ProcessDB interface {
	// Save saves a process to database.
	Save(s *process.Process) error

	// Get gets a process from database by its unique hash.
	Get(hash hash.Hash) (*process.Process, error)

	// Delete deletes a process from database by its unique hash.
	Delete(hash hash.Hash) error

	// All returns all processes from database.
	All() ([]*process.Process, error)

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

ProcessDB describes the API of database package.