ethereum

Documentation

Index

• type EthAdaptor
  • func (a *EthAdaptor) Count() (totalNumber int, consensusNumber int)
  • func (a *EthAdaptor) GetChainName() string
  • func (a *EthAdaptor) GetIP() string
  • func (a *EthAdaptor) GetPort() int
  • func (a *EthAdaptor) GetSequence() int64
  • func (a *EthAdaptor) ObtainTx(chainID string, sequence int64) (*txs.TxQcp, error)
  • func (a *EthAdaptor) QuerySequence(chainID string, inout string) (int64, error)
  • func (a *EthAdaptor) Start() error
  • func (a *EthAdaptor) Stop() error
  • func (a *EthAdaptor) SubmitTx(chainID string, tx *txs.TxQcp) error
  • func (a *EthAdaptor) Subscribe(listener ports.EventsListener)
  • func (a *EthAdaptor) Sync() error

Types

type EthAdaptor

type EthAdaptor struct {
	Addrs storage.AddressBook
	// contains filtered or unexported fields
}

EthAdaptor provides adapter for ethereum

func (*EthAdaptor) Count

func (a *EthAdaptor) Count() (totalNumber int, consensusNumber int)

Count Calculate the total and consensus number for chain

func (*EthAdaptor) GetChainName

func (a *EthAdaptor) GetChainName() string

GetChainName returns chain name

func (*EthAdaptor) GetIP

func (a *EthAdaptor) GetIP() string

GetIP returns chain node ip

func (*EthAdaptor) GetPort

func (a *EthAdaptor) GetPort() int

GetPort returns chain node port

func (*EthAdaptor) GetSequence

func (a *EthAdaptor) GetSequence() int64

GetSequence returns sequence of tx in cache

func (*EthAdaptor) ObtainTx

func (a *EthAdaptor) ObtainTx(chainID string, sequence int64) (*txs.TxQcp, error)

ObtainTx obtain Tx from ethereum chain recharge:

send transaction data back to fabric

withdraw:

send transaction data back to fabric

func (*EthAdaptor) QuerySequence

func (a *EthAdaptor) QuerySequence(chainID string, inout string) (int64, error)

QuerySequence query sequence of Tx in ethereum

func (*EthAdaptor) Start

func (a *EthAdaptor) Start() error

Start fabric adapter service

func (*EthAdaptor) Stop

func (a *EthAdaptor) Stop() error

Stop fabric adapter service

func (*EthAdaptor) SubmitTx

func (a *EthAdaptor) SubmitTx(chainID string, tx *txs.TxQcp) error

SubmitTx submit Tx to ethereum chain

func (*EthAdaptor) Subscribe

func (a *EthAdaptor) Subscribe(listener ports.EventsListener)

Subscribe events from ethereum chain

func (*EthAdaptor) Sync

func (a *EthAdaptor) Sync() error

Sync status for fabric adapter service