database

Oct 25, 2019

Changes in this version

+ type OwnershipDB struct

+ func NewOwnershipDB(s store.Store, cdc *codec.Codec) *OwnershipDB

+ func (d *OwnershipDB) All() ([]*ownership.Ownership, error)

+ func (d *OwnershipDB) Close() error

+ func (d *OwnershipDB) Save(o *ownership.Ownership) error

Sep 6, 2019

Changes in this version

type InstanceDB

+ Exist func(hash hash.Hash) (bool, error)

type LevelDBInstanceDB

+ func (d *LevelDBInstanceDB) Exist(hash hash.Hash) (bool, error)

+ type LevelDBProcessDB struct

+ 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 interface

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

+ Close func() error

+ Delete func(hash hash.Hash) error

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

+ Save func(s *process.Process) error

type ServiceDB

+ func (d *ServiceDB) Exist(hash hash.Hash) (bool, error)

Aug 16, 2019

Changes in this version

+ type LevelDBWorkflowDB struct

+ func NewWorkflowDB(path string) (*LevelDBWorkflowDB, error)

+ func (d *LevelDBWorkflowDB) All() ([]*workflow.Workflow, error)

+ func (d *LevelDBWorkflowDB) Close() error

+ func (d *LevelDBWorkflowDB) Delete(hash hash.Hash) error

+ func (d *LevelDBWorkflowDB) Get(hash hash.Hash) (*workflow.Workflow, error)

+ func (d *LevelDBWorkflowDB) Save(s *workflow.Workflow) error

+ type WorkflowDB interface

+ All func() ([]*workflow.Workflow, error)

+ Close func() error

+ Delete func(hash hash.Hash) error

+ Get func(hash hash.Hash) (*workflow.Workflow, error)

+ Save func(s *workflow.Workflow) error

Jul 5, 2019

Changes in this version

type ExecutionDB

+ OpenTransaction func() (ExecutionTransaction, error)

+ type ExecutionTransaction interface

+ Commit func() error

+ Discard func()

+ Find func(executionHash hash.Hash) (*execution.Execution, error)

+ Save func(execution *execution.Execution) error

+ type InstanceDB interface

+ Close func() error

+ Delete func(hash hash.Hash) error

+ Get func(hash hash.Hash) (*instance.Instance, error)

+ GetAll func() ([]*instance.Instance, error)

+ Save func(i *instance.Instance) error

type LevelDBExecutionDB

+ func (db *LevelDBExecutionDB) OpenTransaction() (ExecutionTransaction, error)

+ type LevelDBExecutionTransaction struct

+ func (tx *LevelDBExecutionTransaction) Commit() error

+ func (tx *LevelDBExecutionTransaction) Discard()

+ func (tx *LevelDBExecutionTransaction) Find(executionHash hash.Hash) (*execution.Execution, error)

+ func (tx *LevelDBExecutionTransaction) Save(execution *execution.Execution) error

+ type LevelDBInstanceDB struct

+ func NewInstanceDB(path string) (*LevelDBInstanceDB, error)

+ func (d *LevelDBInstanceDB) Close() error

+ func (d *LevelDBInstanceDB) Delete(hash hash.Hash) error

+ func (d *LevelDBInstanceDB) Get(hash hash.Hash) (*instance.Instance, error)

+ func (d *LevelDBInstanceDB) GetAll() ([]*instance.Instance, error)

+ func (d *LevelDBInstanceDB) Save(i *instance.Instance) error

Nov 2, 2018

Changes in this version

+ type ExecutionDB interface

+ Close func() error

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

+ Save func(execution *execution.Execution) error

+ type LevelDBExecutionDB struct

+ 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 struct

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

+ func (d *LevelDBServiceDB) Close() error

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

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

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

Oct 5, 2018

Changes in this version

+ func IsErrNotFound(err error) bool

+ type DecodeError struct

+ ID string

+ func (e *DecodeError) Error() string

+ type ErrNotFound struct

+ ID string

+ func (e *ErrNotFound) Error() string

+ type ServiceDB struct

+ func NewServiceDB(path string) (*ServiceDB, error)

+ func (db *ServiceDB) All() ([]*service.Service, error)

+ func (db *ServiceDB) Close() error

+ func (db *ServiceDB) Delete(id string) error

+ func (db *ServiceDB) Get(id string) (*service.Service, error)

+ func (db *ServiceDB) Save(s *service.Service) error