adapter

Documentation

Index

• type DeployingEthereumConnection
• type EthereumCaller
• type EthereumConnection
• type EthereumRpcConnection
  • func NewEthereumRpcConnection(config ethereumAdapterConfig, logger log.BasicLogger) *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)
• type EthereumSimulator
  • func NewEthereumSimulatorConnection(logger log.BasicLogger) *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)
• type TransactionLog
  • func (l *TransactionLog) PackedDataArgumentAt(index int) ([]byte, error)

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 {
	// contains filtered or unexported fields
}

func NewEthereumRpcConnection

func NewEthereumRpcConnection(config ethereumAdapterConfig, logger log.BasicLogger) *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)

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)

type EthereumSimulator

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

func NewEthereumSimulatorConnection

func NewEthereumSimulatorConnection(logger log.BasicLogger) *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)

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)

type TransactionLog

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

func (*TransactionLog) PackedDataArgumentAt

func (l *TransactionLog) PackedDataArgumentAt(index int) ([]byte, error)

TODO(v1): this assumes that in events Data every input is 32 bytes (eg. no tuples), is this always the case? [OdedW]