storage

Documentation

Index

• Constants
• type StorageManager
  • func NewStorageManager(r *registry.Container) *StorageManager
  • func RestoreStorageManager(r *registry.Container) *StorageManager
  • func (self *StorageManager) Close() error
  • func (self *StorageManager) Exec(query string, params []interface{}, f func(result sql.Result, err error) error) error
  • func (self *StorageManager) GetConnection() *sql.DB
  • func (self *StorageManager) Open() error
  • func (self *StorageManager) Query(query string, params []interface{}, f func(rows *sql.Rows) error) error

Constants

const STORAGE_MANAGER_ID = "StorageManager"

Types

type StorageManager

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

func NewStorageManager

func NewStorageManager(r *registry.Container) *StorageManager

/ Initialize storage

func RestoreStorageManager

func RestoreStorageManager(r *registry.Container) *StorageManager

func (*StorageManager) Close

func (self *StorageManager) Close() error

func (*StorageManager) Exec

func (self *StorageManager) Exec(query string, params []interface{}, f func(result sql.Result, err error) error) error

func (*StorageManager) GetConnection

func (self *StorageManager) GetConnection() *sql.DB

func (*StorageManager) Open

func (self *StorageManager) Open() error

func (*StorageManager) Query

func (self *StorageManager) Query(query string, params []interface{}, f func(rows *sql.Rows) error) error