database

Documentation

Index

• type CommandContentFactory
  • func (c CommandContentFactory) InsertToSet(set page.CandleSetWithoutYear, candles common.CandleList) []command.CommandContent
• type Database
  • func NewDatabase(config util.Config) (*Database, error)
  • func (d *Database) Execute(commands []command.CommandContent) ([]interface{}, error)
  • func (d *Database) Write(set page.CandleSetWithoutYear, candles common.CandleList) ([]interface{}, error)
• type TransactionContext
  • func NewTransactionContext(accessor *storage.StorageAccessor, dbLock *concurrency.DatabaseLock) TransactionContext
  • func (t *TransactionContext) Commit() error
  • func (t *TransactionContext) Execute(cmd command.CommandContent) (interface{}, error)
  • func (t *TransactionContext) Rollback() error
  • func (t *TransactionContext) RollbackIfActive()
  • func (t *TransactionContext) Start() error

Types

type CommandContentFactory

type CommandContentFactory struct {
}

func (CommandContentFactory) InsertToSet

func (c CommandContentFactory) InsertToSet(set page.CandleSetWithoutYear, candles common.CandleList) []command.CommandContent

type Database

type Database struct {
	Storage *storage.Storage
	Lock    *concurrency.DatabaseLock
	// contains filtered or unexported fields
}

func NewDatabase

func NewDatabase(config util.Config) (*Database, error)

func (*Database) Execute

func (d *Database) Execute(commands []command.CommandContent) ([]interface{}, error)

func (*Database) Write

func (d *Database) Write(set page.CandleSetWithoutYear, candles common.CandleList) ([]interface{}, error)

High level commands

type TransactionContext

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

func NewTransactionContext

func NewTransactionContext(accessor *storage.StorageAccessor, dbLock *concurrency.DatabaseLock) TransactionContext

func (*TransactionContext) Commit

func (t *TransactionContext) Commit() error

func (*TransactionContext) Execute

func (t *TransactionContext) Execute(cmd command.CommandContent) (interface{}, error)

func (*TransactionContext) Rollback

func (t *TransactionContext) Rollback() error

func (*TransactionContext) RollbackIfActive

func (t *TransactionContext) RollbackIfActive()

func (*TransactionContext) Start

func (t *TransactionContext) Start() error