adapter

Documentation

Index

• Constants
• type BlockNumberAndTime
  • func (b *BlockNumberAndTime) String() string
• 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) (*BlockNumberAndTime, 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 NopEthereumAdapter
  • func (n *NopEthereumAdapter) CallContract(ctx context.Context, contractAddress []byte, packedInput []byte, ...) (packedOutput []byte, err error)
  • func (n *NopEthereumAdapter) GetTransactionLogs(ctx context.Context, txHash primitives.Uint256, eventSignature []byte) ([]*TransactionLog, error)
  • func (n *NopEthereumAdapter) HeaderByNumber(ctx context.Context, number *big.Int) (*BlockNumberAndTime, error)
• type TransactionLog

Constants

const ARBITRARY_TXHASH = "0xb41e0591756bd1331de35eac3e3da460c9b3503d10e7bf08b84f057f489cd189"

const STATUS_FAILED = "failed"

const STATUS_IN_PROGRESS = "in-progress"

const STATUS_SUCCESS = "success"

Types

type BlockNumberAndTime

type BlockNumberAndTime struct {
	TimeInSeconds uint64
	BlockNumber   int64
}

func (*BlockNumberAndTime) String

func (b *BlockNumberAndTime) String() string

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) (*BlockNumberAndTime, 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) (*BlockNumberAndTime, 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 NopEthereumAdapter

type NopEthereumAdapter struct {
}

func (*NopEthereumAdapter) CallContract

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

func (*NopEthereumAdapter) GetTransactionLogs

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

func (*NopEthereumAdapter) HeaderByNumber

func (n *NopEthereumAdapter) HeaderByNumber(ctx context.Context, number *big.Int) (*BlockNumberAndTime, error)

type TransactionLog

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