adapter

Documentation

Index

• Constants
• type DeployingEthereumConnection
• type EthereumCaller
• type EthereumConnection
• type EthereumRpcConnection
  • func NewEthereumRpcConnection(config ethereumAdapterConfig, logger log.Logger, registry metric.Registry) *EthereumRpcConnection
  • func (c *EthereumRpcConnection) CallContract(ctx context.Context, contractAddress []byte, packedInput []byte, ...) (packedOutput []byte, err error)
  • func (c *EthereumRpcConnection) DeployEthereumContract(auth *bind.TransactOpts, abijson string, bytecode string, ...) (*common.Address, *bind.BoundContract, error)
  • func (c *EthereumRpcConnection) DeployEthereumContractManually(ctx context.Context, auth *bind.TransactOpts, abijson string, bytecode string, ...) (*common.Address, error)
  • func (c *EthereumRpcConnection) DeploySimpleStorageContract(auth *bind.TransactOpts, stringValue string) ([]byte, error)
  • func (c *EthereumRpcConnection) GetTransactionLogs(ctx context.Context, txHash primitives.Uint256, eventSignature []byte) ([]*TransactionLog, error)
  • func (rpc *EthereumRpcConnection) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
  • func (c *EthereumRpcConnection) Receipt(txHash common.Hash) (*types.Receipt, error)
  • func (c *EthereumRpcConnection) ReportConnectionStatus(ctx context.Context)
  • func (c *EthereumRpcConnection) SyncProgress() (*ethereum.SyncProgress, error)
• type EthereumSimulator
  • func NewEthereumSimulatorConnection(logger log.Logger) *EthereumSimulator
  • func (c *EthereumSimulator) CallContract(ctx context.Context, contractAddress []byte, packedInput []byte, ...) (packedOutput []byte, err error)
  • func (es *EthereumSimulator) Commit()
  • func (c *EthereumSimulator) DeployEthereumContract(auth *bind.TransactOpts, abijson string, bytecode string, ...) (*common.Address, *bind.BoundContract, error)
  • func (c *EthereumSimulator) DeployEthereumContractManually(ctx context.Context, auth *bind.TransactOpts, abijson string, bytecode string, ...) (*common.Address, error)
  • func (c *EthereumSimulator) DeploySimpleStorageContract(auth *bind.TransactOpts, stringValue string) ([]byte, error)
  • func (es *EthereumSimulator) GetAuth() *bind.TransactOpts
  • func (c *EthereumSimulator) GetTransactionLogs(ctx context.Context, txHash primitives.Uint256, eventSignature []byte) ([]*TransactionLog, error)
  • func (es *EthereumSimulator) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
  • func (c *EthereumSimulator) Receipt(txHash common.Hash) (*types.Receipt, error)
  • func (c *EthereumSimulator) SyncProgress() (*ethereum.SyncProgress, error)
• type TransactionLog

Constants

const ARBITRARY_TXHASH = "0xb41e0591756bd1331de35eac3e3da460c9b3503d10e7bf08b84f057f489cd189"

const STATUS_FAILED = "failed"

const STATUS_IN_PROGRESS = "in-progress"

const STATUS_SUCCESS = "success"

Types

type DeployingEthereumConnection

type DeployingEthereumConnection interface {
	EthereumConnection
	DeploySimpleStorageContract(auth *bind.TransactOpts, stringValue string) ([]byte, error)
	DeployEthereumContract(auth *bind.TransactOpts, abijson string, bytecode string, params ...interface{}) (*common.Address, *bind.BoundContract, error)
}

type EthereumCaller

type EthereumCaller interface {
	bind.ContractBackend
	TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
}

type EthereumConnection

type EthereumConnection interface {
	CallContract(ctx context.Context, contractAddress []byte, packedInput []byte, blockNumber *big.Int) (packedOutput []byte, err error)
	GetTransactionLogs(ctx context.Context, txHash primitives.Uint256, eventSignature []byte) ([]*TransactionLog, error)
	HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
}

type EthereumRpcConnection

type EthereumRpcConnection struct {
	govnr.TreeSupervisor
	// contains filtered or unexported fields
}

func NewEthereumRpcConnection

func NewEthereumRpcConnection(config ethereumAdapterConfig, logger log.Logger, registry metric.Registry) *EthereumRpcConnection

func (*EthereumRpcConnection) CallContract

func (c *EthereumRpcConnection) CallContract(ctx context.Context, contractAddress []byte, packedInput []byte, blockNumber *big.Int) (packedOutput []byte, err error)

func (*EthereumRpcConnection) DeployEthereumContract

func (c *EthereumRpcConnection) DeployEthereumContract(auth *bind.TransactOpts, abijson string, bytecode string, params ...interface{}) (*common.Address, *bind.BoundContract, error)

this is a helper for integration test, not used in production code

func (*EthereumRpcConnection) DeployEthereumContractManually

func (c *EthereumRpcConnection) DeployEthereumContractManually(ctx context.Context, auth *bind.TransactOpts, abijson string, bytecode string, params ...interface{}) (*common.Address, error)

func (*EthereumRpcConnection) DeploySimpleStorageContract

func (c *EthereumRpcConnection) DeploySimpleStorageContract(auth *bind.TransactOpts, stringValue string) ([]byte, error)

this is a helper for integration test, not used in production code

func (*EthereumRpcConnection) GetTransactionLogs

func (c *EthereumRpcConnection) GetTransactionLogs(ctx context.Context, txHash primitives.Uint256, eventSignature []byte) ([]*TransactionLog, error)

func (*EthereumRpcConnection) HeaderByNumber

func (rpc *EthereumRpcConnection) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

func (*EthereumRpcConnection) Receipt

func (c *EthereumRpcConnection) Receipt(txHash common.Hash) (*types.Receipt, error)

func (*EthereumRpcConnection) ReportConnectionStatus

func (c *EthereumRpcConnection) ReportConnectionStatus(ctx context.Context)

func (*EthereumRpcConnection) SyncProgress

func (c *EthereumRpcConnection) SyncProgress() (*ethereum.SyncProgress, error)

type EthereumSimulator

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

func NewEthereumSimulatorConnection

func NewEthereumSimulatorConnection(logger log.Logger) *EthereumSimulator

func (*EthereumSimulator) CallContract

func (c *EthereumSimulator) CallContract(ctx context.Context, contractAddress []byte, packedInput []byte, blockNumber *big.Int) (packedOutput []byte, err error)

func (*EthereumSimulator) Commit

func (es *EthereumSimulator) Commit()

func (*EthereumSimulator) DeployEthereumContract

func (c *EthereumSimulator) DeployEthereumContract(auth *bind.TransactOpts, abijson string, bytecode string, params ...interface{}) (*common.Address, *bind.BoundContract, error)

this is a helper for integration test, not used in production code

func (*EthereumSimulator) DeployEthereumContractManually

func (c *EthereumSimulator) DeployEthereumContractManually(ctx context.Context, auth *bind.TransactOpts, abijson string, bytecode string, params ...interface{}) (*common.Address, error)

func (*EthereumSimulator) DeploySimpleStorageContract

func (c *EthereumSimulator) DeploySimpleStorageContract(auth *bind.TransactOpts, stringValue string) ([]byte, error)

this is a helper for integration test, not used in production code

func (*EthereumSimulator) GetAuth

func (es *EthereumSimulator) GetAuth() *bind.TransactOpts

func (*EthereumSimulator) GetTransactionLogs

func (c *EthereumSimulator) GetTransactionLogs(ctx context.Context, txHash primitives.Uint256, eventSignature []byte) ([]*TransactionLog, error)

func (*EthereumSimulator) HeaderByNumber

func (es *EthereumSimulator) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

func (*EthereumSimulator) Receipt

func (c *EthereumSimulator) Receipt(txHash common.Hash) (*types.Receipt, error)

func (*EthereumSimulator) SyncProgress

func (c *EthereumSimulator) SyncProgress() (*ethereum.SyncProgress, error)

type TransactionLog

type TransactionLog struct {
	ContractAddress []byte
	PackedTopics    [][]byte // indexed fields
	Data            []byte   // non-indexed fields
	RepackedData    []byte
	BlockNumber     uint64
	TxIndex         uint32
}