database

type ExecutionDB interface {
	Find(executionHash hash.Hash) (*execution.Execution, error)
	Save(execution *execution.Execution) error
	OpenTransaction() (ExecutionTransaction, error)
	io.Closer
}

type ExecutionTransaction interface {
	Find(executionHash hash.Hash) (*execution.Execution, error)
	Save(execution *execution.Execution) error
	Commit() error
	Discard()
}

type InstanceDB interface {
	// Exist check if instance with given hash exist.
	Exist(hash hash.Hash) (bool, error)

	// Get retrives instance by instance hash.
	Get(hash hash.Hash) (*instance.Instance, error)

	// GetAll retrieves all instances.
	GetAll() ([]*instance.Instance, error)

	// Save saves instance to database.
	Save(i *instance.Instance) error

	// Delete an instance by instance hash.
	Delete(hash hash.Hash) error

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

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

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

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

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

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

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
}

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