relation

Documentation

Index

• type Relation
  • func NewRelation(cfgFile string) (*Relation, error)
  • func (r *Relation) Add(obj []types.Schema)
  • func (r *Relation) BatchUpdate(fn func(txn *sqlx.Tx) error) error
  • func (r *Relation) Blocks(limit int, offset int) ([]types.Hash, error)
  • func (r *Relation) BlocksByAccount(address types.Address, limit int, offset int) ([]types.Hash, error)
  • func (r *Relation) BlocksCount() (uint64, error)
  • func (r *Relation) BlocksCountByType() (map[string]uint64, error)
  • func (r *Relation) Close() error
  • func (r *Relation) DB() *sqlx.DB
  • func (r *Relation) Delete(obj types.Schema)
  • func (r *Relation) EmptyStore() error
  • func (r *Relation) Get(dest interface{}, query string) error
  • func (r *Relation) Queryx(query string) (*sqlx.Rows, error)
  • func (r *Relation) Register(t types.Schema) error
  • func (r *Relation) Select(dest interface{}, query string) error
• type Store

Types

type Relation

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

func NewRelation

func NewRelation(cfgFile string) (*Relation, error)

func (*Relation) Add

func (r *Relation) Add(obj []types.Schema)

func (*Relation) BatchUpdate

func (r *Relation) BatchUpdate(fn func(txn *sqlx.Tx) error) error

func (*Relation) Blocks

func (r *Relation) Blocks(limit int, offset int) ([]types.Hash, error)

func (*Relation) BlocksByAccount

func (r *Relation) BlocksByAccount(address types.Address, limit int, offset int) ([]types.Hash, error)

func (*Relation) BlocksCount

func (r *Relation) BlocksCount() (uint64, error)

func (*Relation) BlocksCountByType

func (r *Relation) BlocksCountByType() (map[string]uint64, error)

func (*Relation) Close

func (r *Relation) Close() error

func (*Relation) DB

func (r *Relation) DB() *sqlx.DB

func (*Relation) Delete

func (r *Relation) Delete(obj types.Schema)

func (*Relation) EmptyStore

func (r *Relation) EmptyStore() error

func (*Relation) Get

func (r *Relation) Get(dest interface{}, query string) error

func (*Relation) Queryx

func (r *Relation) Queryx(query string) (*sqlx.Rows, error)

func (*Relation) Register

func (r *Relation) Register(t types.Schema) error

func (*Relation) Select

func (r *Relation) Select(dest interface{}, query string) error

type Store

type Store interface {
	Blocks(limit int, offset int) ([]types.Hash, error)
	BlocksByAccount(address types.Address, limit int, offset int) ([]types.Hash, error)
	BlocksCount() (uint64, error)
	BlocksCountByType() (map[string]uint64, error)

	Select(dest interface{}, query string) error
	Get(dest interface{}, query string) error
	Queryx(query string) (*sqlx.Rows, error)
	DB() *sqlx.DB
	Close() error
	EmptyStore() error
}