store

Documentation

Overview

Package store is used to keep application events in sync between the database on the node and the blockchain.

Config

Config contains the local configuration options that the application will adhere to.

CallerSubscriberClient

This makes use of Go-Ethereum's functions to interact with the blockchain. The underlying functions can be viewed here:

go-ethereum/rpc/client.go

KeyStore

KeyStore also utilizes Go-Ethereum's functions to store encrypted keys on the local file system. The underlying functions can be viewed here:

go-ethereum/accounts/keystore/keystore.go

Store

The Store is the persistence layer for the application. It saves the the application state and most interaction with the node needs to occur through the store.

Tx Manager

The transaction manager is used to syncronize interactions on the Ethereum blockchain with the application and database.

Index

• Constants
• func CheckSquashUpgrade(db *gorm.DB) error
• func PromUpdateEthBalance(balance *assets.Eth, from common.Address)
• type Store
  • func NewInsecureStore(config *orm.Config, ethClient eth.Client, ...) (*Store, error)
  • func NewStore(config *orm.Config, ethClient eth.Client, advisoryLock postgres.AdvisoryLocker, ...) (*Store, error)
  • func (s *Store) AuthorizedUserWithSession(sessionID string) (models.User, error)
  • func (s *Store) Close() error
  • func (s *Store) Healthy() error
  • func (s *Store) Ready() error
  • func (s *Store) Start() error
  • func (s *Store) Unscoped() *Store

Constants

const (
	// AutoMigrate is a flag that automatically migrates the DB when passed to initializeORM
	AutoMigrate = "auto_migrate"
)

Functions

func CheckSquashUpgrade

func CheckSquashUpgrade(db *gorm.DB) error

func PromUpdateEthBalance

func PromUpdateEthBalance(balance *assets.Eth, from common.Address)

Types

type Store

type Store struct {
	*orm.ORM
	Config         *orm.Config
	Clock          utils.AfterNower
	EthClient      eth.Client
	AdvisoryLocker postgres.AdvisoryLocker
	// contains filtered or unexported fields
}

Store contains fields for the database, Config for keeping the application state in sync with the database.

func NewInsecureStore

func NewInsecureStore(config *orm.Config, ethClient eth.Client, advisoryLocker postgres.AdvisoryLocker, shutdownSignal gracefulpanic.Signal) (*Store, error)

NewInsecureStore creates a new store with the given config using an insecure keystore. NOTE: Should only be used for testing!

func NewStore

func NewStore(config *orm.Config, ethClient eth.Client, advisoryLock postgres.AdvisoryLocker, shutdownSignal gracefulpanic.Signal) (*Store, error)

NewStore will create a new store func NewStore(config *orm.Config, ethClient eth.Client, advisoryLock postgres.AdvisoryLocker, shutdownSignal gracefulpanic.Signal, keyStoreGenerator KeyStoreGenerator) (*Store, error) {

func (*Store) AuthorizedUserWithSession

func (s *Store) AuthorizedUserWithSession(sessionID string) (models.User, error)

AuthorizedUserWithSession will return the one API user if the Session ID exists and hasn't expired, and update session's LastUsed field.

func (*Store) Close

func (s *Store) Close() error

Close shuts down all of the working parts of the store.

func (*Store) Healthy

func (s *Store) Healthy() error

func (*Store) Ready

func (s *Store) Ready() error

func (*Store) Start

func (s *Store) Start() error

Start initiates all of Store's dependencies

func (*Store) Unscoped

func (s *Store) Unscoped() *Store

Unscoped returns a shallow copy of the store, with an unscoped ORM allowing one to work with soft deleted records.