db

Documentation

Index

• type Driver
  • func (o *Driver) New(sp view.ServiceProvider, dataSourceName string, config driver.Config) (driver.Persistence, error)
  • func (o *Driver) NewTransactionalVersionedPersistence(sp view.ServiceProvider, dataSourceName string, config driver.Config) (driver.TransactionalVersionedPersistence, error)
  • func (o *Driver) NewVersioned(sp view.ServiceProvider, dataSourceName string, config driver.Config) (driver.VersionedPersistence, error)
  • func (o *Driver) OpenDB(sp view.ServiceProvider, onsName, dbName, creator string) (*Orion, error)
• type ItemList
  • func (i *ItemList) Get(index int) (*driver.VersionedRead, bool)
  • func (i *ItemList) GetLast() []byte
  • func (i *ItemList) Set(index int, v *driver.VersionedRead, k []byte)
• type Opts
• type Orion
  • func (db *Orion) BeginUpdate() error
  • func (db *Orion) Close() error
  • func (db *Orion) Commit() error
  • func (db *Orion) DeleteState(namespace, key string) error
  • func (db *Orion) Discard() error
  • func (db *Orion) GetCachedStateRangeScanIterator(namespace string, startKey string, endKey string) (driver.VersionedResultsIterator, error)
  • func (db *Orion) GetState(namespace, key string) ([]byte, uint64, uint64, error)
  • func (db *Orion) GetStateMetadata(namespace, key string) (map[string][]byte, uint64, uint64, error)
  • func (db *Orion) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (driver.VersionedResultsIterator, error)
  • func (db *Orion) SetState(namespace, key string, value []byte, block, txnum uint64) error
  • func (db *Orion) SetStateMetadata(namespace, key string, metadata map[string][]byte, block, txnum uint64) error
• type OrionBackend
• type VersionedResultsIterator
  • func (v *VersionedResultsIterator) Close()
  • func (v *VersionedResultsIterator) Next() (*driver.VersionedRead, error)

Types

type Driver

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

func (*Driver) New

func (o *Driver) New(sp view.ServiceProvider, dataSourceName string, config driver.Config) (driver.Persistence, error)

func (*Driver) NewTransactionalVersionedPersistence

func (o *Driver) NewTransactionalVersionedPersistence(sp view.ServiceProvider, dataSourceName string, config driver.Config) (driver.TransactionalVersionedPersistence, error)

NewTransactionalVersionedPersistence returns a new TransactionalVersionedPersistence for the passed data source and config

func (*Driver) NewVersioned

func (o *Driver) NewVersioned(sp view.ServiceProvider, dataSourceName string, config driver.Config) (driver.VersionedPersistence, error)

func (*Driver) OpenDB

func (o *Driver) OpenDB(sp view.ServiceProvider, onsName, dbName, creator string) (*Orion, error)

type ItemList

type ItemList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*ItemList) Get

func (i *ItemList) Get(index int) (*driver.VersionedRead, bool)

func (*ItemList) GetLast

func (i *ItemList) GetLast() []byte

func (*ItemList) Set

func (i *ItemList) Set(index int, v *driver.VersionedRead, k []byte)

type Opts

type Opts struct {
	Network  string
	Database string
	Creator  string
}

type Orion

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

func (*Orion) BeginUpdate

func (db *Orion) BeginUpdate() error

func (*Orion) Close

func (db *Orion) Close() error

func (*Orion) Commit

func (db *Orion) Commit() error

func (*Orion) DeleteState

func (db *Orion) DeleteState(namespace, key string) error

func (*Orion) Discard

func (db *Orion) Discard() error

func (*Orion) GetCachedStateRangeScanIterator

func (db *Orion) GetCachedStateRangeScanIterator(namespace string, startKey string, endKey string) (driver.VersionedResultsIterator, error)

func (*Orion) GetState

func (db *Orion) GetState(namespace, key string) ([]byte, uint64, uint64, error)

func (*Orion) GetStateMetadata

func (db *Orion) GetStateMetadata(namespace, key string) (map[string][]byte, uint64, uint64, error)

func (*Orion) GetStateRangeScanIterator

func (db *Orion) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (driver.VersionedResultsIterator, error)

func (*Orion) SetState

func (db *Orion) SetState(namespace, key string, value []byte, block, txnum uint64) error

func (*Orion) SetStateMetadata

func (db *Orion) SetStateMetadata(namespace, key string, metadata map[string][]byte, block, txnum uint64) error

type OrionBackend

type OrionBackend interface {
	SessionManager() *orion.SessionManager
	TransactionManager() *orion.TransactionManager
}

type VersionedResultsIterator

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

func (*VersionedResultsIterator) Close

func (v *VersionedResultsIterator) Close()

func (*VersionedResultsIterator) Next

func (v *VersionedResultsIterator) Next() (*driver.VersionedRead, error)