Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

store

package

Go to main page

Versions in this module

v0

v0.6.4

Jul 24, 2019

Changes in this version

type Config

+ func (c Config) TxAttemptLimit() uint16

type ConfigSchema

+ TxAttemptLimit uint16

v0.6.3

Jul 9, 2019

v0.6.2

Jun 27, 2019

v0.6.1

Jun 26, 2019

v0.6.0

Jun 25, 2019

Changes in this version

+ const DefaultGasLimit

+ var ErrPendingConnection = errors.New("Cannot talk to chain, pending connection")

+ var Sha = "unset"

+ var Version = "unset"

+ func ExtractERC20BalanceTargetAddress(args interface{}) (common.Address, bool)

+ type AttemptState int

+ const Confirmed

+ const Safe

+ const Unconfirmed

+ const Unknown

+ func (a AttemptState) String() string

+ type CallerSubscriber interface

+ Call func(result interface{}, method string, args ...interface{}) error

+ EthSubscribe func(context.Context, interface{}, ...interface{}) (models.EthSubscription, error)

+ type Config struct

+ SecretGenerator SecretGenerator

+ func NewConfig() Config

+ func (c Config) AllowOrigins() string

+ func (c Config) BridgeResponseURL() *url.URL

+ func (c Config) CertFile() string

+ func (c Config) ChainID() uint64

+ func (c Config) ClientNodeURL() string

+ func (c Config) CreateProductionLogger() *zap.Logger

+ func (c Config) DatabaseTimeout() time.Duration

+ func (c Config) DatabaseURL() string

+ func (c Config) DefaultHTTPLimit() int64

+ func (c Config) Dev() bool

+ func (c Config) EthGasBumpThreshold() uint64

+ func (c Config) EthGasBumpWei() *big.Int

+ func (c Config) EthGasPriceDefault() *big.Int

+ func (c Config) EthereumURL() string

+ func (c Config) ExplorerAccessKey() string

+ func (c Config) ExplorerSecret() string

+ func (c Config) ExplorerURL() *url.URL

+ func (c Config) JSONConsole() bool

+ func (c Config) KeyFile() string

+ func (c Config) KeysDir() string

+ func (c Config) LinkContractAddress() string

+ func (c Config) LogLevel() LogLevel

+ func (c Config) LogSQLStatements() bool

+ func (c Config) LogToDisk() bool

+ func (c Config) MaximumServiceDuration() time.Duration

+ func (c Config) MinIncomingConfirmations() uint32

+ func (c Config) MinOutgoingConfirmations() uint64

+ func (c Config) MinimumContractPayment() *assets.Link

+ func (c Config) MinimumRequestExpiration() uint64

+ func (c Config) MinimumServiceDuration() time.Duration

+ func (c Config) NormalizedDatabaseURL() string

+ func (c Config) OracleContractAddress() *common.Address

+ func (c Config) Port() uint16

+ func (c Config) ReaperExpiration() time.Duration

+ func (c Config) RootDir() string

+ func (c Config) SecureCookies() bool

+ func (c Config) SessionOptions() sessions.Options

+ func (c Config) SessionSecret() ([]byte, error)

+ func (c Config) SessionTimeout() time.Duration

+ func (c Config) Set(name string, value interface{})

+ func (c Config) TLSCertPath() string

+ func (c Config) TLSHost() string

+ func (c Config) TLSKeyPath() string

+ func (c Config) TLSPort() uint16

+ type ConfigSchema struct

+ AllowOrigins string

+ BridgeResponseURL url.URL

+ ChainID uint64

+ ClientNodeURL string

+ DatabaseTimeout time.Duration

+ DatabaseURL string

+ DefaultHTTPLimit int64

+ Dev bool

+ EthGasBumpThreshold uint64

+ EthGasBumpWei big.Int

+ EthGasPriceDefault big.Int

+ EthereumURL string

+ ExplorerAccessKey string

+ ExplorerSecret string

+ ExplorerURL *url.URL

+ JSONConsole bool

+ LinkContractAddress string

+ LogLevel LogLevel

+ LogSQLStatements bool

+ LogToDisk bool

+ MaximumServiceDuration time.Duration

+ MinIncomingConfirmations uint32

+ MinOutgoingConfirmations uint64

+ MinimumContractPayment assets.Link

+ MinimumRequestExpiration uint64

+ MinimumServiceDuration time.Duration

+ OracleContractAddress common.Address

+ Port uint16

+ ReaperExpiration time.Duration

+ RootDir string

+ SecureCookies bool

+ SessionTimeout time.Duration

+ TLSCertPath string

+ TLSHost string

+ TLSKeyPath string

+ TLSPort uint16

+ type Contract struct

+ ABI abi.ABI

+ func GetContract(name string) (*Contract, error)

+ func (contract *Contract) EncodeMessageCall(method string, args ...interface{}) ([]byte, error)

+ type Dialer interface

+ Dial func(string) (CallerSubscriber, error)

+ type EthClient struct

+ func (eth *EthClient) GetBlockByNumber(hex string) (models.BlockHeader, error)

+ func (eth *EthClient) GetBlockNumber() (uint64, error)

+ func (eth *EthClient) GetChainID() (uint64, error)

+ func (eth *EthClient) GetERC20Balance(address common.Address, contractAddress common.Address) (*big.Int, error)

+ func (eth *EthClient) GetEthBalance(address common.Address) (*assets.Eth, error)

+ func (eth *EthClient) GetLogs(q ethereum.FilterQuery) ([]models.Log, error)

+ func (eth *EthClient) GetNonce(address common.Address) (uint64, error)

+ func (eth *EthClient) GetTxReceipt(hash common.Hash) (*models.TxReceipt, error)

+ func (eth *EthClient) GetWeiBalance(address common.Address) (*big.Int, error)

+ func (eth *EthClient) SendRawTx(hex string) (common.Hash, error)

+ func (eth *EthClient) SubscribeToLogs(channel chan<- models.Log, q ethereum.FilterQuery) (models.EthSubscription, error)

+ func (eth *EthClient) SubscribeToNewHeads(channel chan<- models.BlockHeader) (models.EthSubscription, error)

+ type EthDialer struct

+ func (ed *EthDialer) Dial(urlString string) (CallerSubscriber, error)

+ type EthTxManager struct

+ func NewEthTxManager(ethClient *EthClient, config Config, keyStore *KeyStore, orm *orm.ORM) *EthTxManager

+ func (txm *EthTxManager) BumpGasUntilSafe(hash common.Hash) (*models.TxReceipt, AttemptState, error)

+ func (txm *EthTxManager) CheckAttempt(txAttempt *models.TxAttempt, blockHeight uint64) (*models.TxReceipt, AttemptState, error)

+ func (txm *EthTxManager) Connect(bn *models.Head) error

+ func (txm *EthTxManager) Connected() bool

+ func (txm *EthTxManager) ContractLINKBalance(wr models.WithdrawalRequest) (assets.Link, error)

+ func (txm *EthTxManager) CreateTx(to common.Address, data []byte) (*models.Tx, error)

+ func (txm *EthTxManager) CreateTxWithEth(from, to common.Address, value *assets.Eth) (*models.Tx, error)

+ func (txm *EthTxManager) CreateTxWithGas(surrogateID null.String, to common.Address, data []byte, gasPriceWei *big.Int, ...) (*models.Tx, error)

+ func (txm *EthTxManager) Disconnect()

+ func (txm *EthTxManager) GetETHAndLINKBalances(address common.Address) (*big.Int, *assets.Link, error)

+ func (txm *EthTxManager) GetLINKBalance(address common.Address) (*assets.Link, error)

+ func (txm *EthTxManager) NextActiveAccount() *ManagedAccount

+ func (txm *EthTxManager) OnNewHead(*models.Head)

+ func (txm *EthTxManager) Register(accts []accounts.Account)

+ func (txm *EthTxManager) WithdrawLINK(wr models.WithdrawalRequest) (common.Hash, error)

+ type HeadTrackable interface

+ Connect func(*models.Head) error

+ Disconnect func()

+ OnNewHead func(*models.Head)

+ type KeyStore struct

+ func NewKeyStore(keyDir string) *KeyStore

+ func (ks *KeyStore) GetAccounts() []accounts.Account

+ func (ks *KeyStore) GetFirstAccount() (accounts.Account, error)

+ func (ks *KeyStore) HasAccounts() bool

+ func (ks *KeyStore) NewAccount(passphrase string) (accounts.Account, error)

+ func (ks *KeyStore) Sign(input []byte) (models.Signature, error)

+ func (ks *KeyStore) SignTx(account accounts.Account, tx *types.Transaction, chainID uint64) (*types.Transaction, error)

+ func (ks *KeyStore) Unlock(phrase string) error

+ type LogLevel struct

+ func (ll LogLevel) ForGin() string

+ type ManagedAccount struct

+ func NewManagedAccount(a accounts.Account, nonce uint64) *ManagedAccount

+ func (a *ManagedAccount) GetAndIncrementNonce(callback func(uint64) error) error

+ func (a *ManagedAccount) Nonce() uint64

+ func (a *ManagedAccount) ReloadNonce(txm *EthTxManager) error

+ type QueuedRunChannel struct

+ func (rq *QueuedRunChannel) Close()

+ func (rq *QueuedRunChannel) Receive() <-chan RunRequest

+ func (rq *QueuedRunChannel) Send(jobRunID string) error

+ type RunChannel interface

+ Close func()

+ Receive func() <-chan RunRequest

+ Send func(jobRunID string) error

+ func NewQueuedRunChannel() RunChannel

+ type RunRequest struct

+ ID string

+ type SecretGenerator interface

+ Generate func(Config) ([]byte, error)

+ type Store struct

+ Clock utils.AfterNower

+ Config Config

+ KeyStore *KeyStore

+ RunChannel RunChannel

+ StatsPusher *synchronization.StatsPusher

+ TxManager TxManager

+ func NewStore(config Config) *Store

+ func NewStoreWithDialer(config Config, dialer Dialer) *Store

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

+ func (s *Store) Close() error

+ func (s *Store) Start() error

+ func (s *Store) SyncDiskKeyStoreToDB() error

+ func (s *Store) Unscoped() *Store

+ type TxManager interface

+ BumpGasUntilSafe func(hash common.Hash) (*models.TxReceipt, AttemptState, error)

+ CheckAttempt func(txAttempt *models.TxAttempt, blockHeight uint64) (*models.TxReceipt, AttemptState, error)

+ Connected func() bool

+ ContractLINKBalance func(wr models.WithdrawalRequest) (assets.Link, error)

+ CreateTx func(to common.Address, data []byte) (*models.Tx, error)

+ CreateTxWithEth func(from, to common.Address, value *assets.Eth) (*models.Tx, error)

+ CreateTxWithGas func(surrogateID null.String, to common.Address, data []byte, gasPriceWei *big.Int, ...) (*models.Tx, error)

+ GetBlockByNumber func(hex string) (models.BlockHeader, error)

+ GetChainID func() (uint64, error)

+ GetEthBalance func(address common.Address) (*assets.Eth, error)

+ GetLINKBalance func(address common.Address) (*assets.Link, error)

+ GetLogs func(q ethereum.FilterQuery) ([]models.Log, error)

+ GetTxReceipt func(common.Hash) (*models.TxReceipt, error)

+ NextActiveAccount func() *ManagedAccount

+ Register func(accounts []accounts.Account)

+ SubscribeToLogs func(channel chan<- models.Log, q ethereum.FilterQuery) (models.EthSubscription, error)

+ SubscribeToNewHeads func(channel chan<- models.BlockHeader) (models.EthSubscription, error)

+ WithdrawLINK func(wr models.WithdrawalRequest) (common.Hash, error)