Documentation ¶
Index ¶
- Constants
- func Consume(client EthClient, filter *chain.Filter, blockRange *rpcevents.BlockRange, ...) error
- type Block
- type Chain
- func (c *Chain) Close() error
- func (c *Chain) Connectivity() connectivity.State
- func (c *Chain) ConsumeBlocks(ctx context.Context, in *rpcevents.BlockRange, ...) error
- func (c *Chain) GetABI(ctx context.Context, address crypto.Address) (string, error)
- func (c *Chain) GetChainID() string
- func (c *Chain) GetVersion() string
- func (c *Chain) StatusMessage(ctx context.Context, lastProcessedHeight uint64) []interface{}
- type EthClient
- type Event
- type Transaction
- func (tx *Transaction) GetEvents() []chain.Event
- func (tx *Transaction) GetException() *errors.Exception
- func (tx *Transaction) GetHash() binary.HexBytes
- func (tx *Transaction) GetIndex() uint64
- func (tx *Transaction) GetMetadata(columns types.SQLColumnNames) (map[string]interface{}, error)
- func (tx *Transaction) GetOrigin() *chain.Origin
Constants ¶
View Source
const ConsumerScope = "EthereumConsumer"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Block ¶
type Block struct { Height uint64 Transactions []chain.Transaction // contains filtered or unexported fields }
func (*Block) GetMetadata ¶
func (b *Block) GetMetadata(columns types.SQLColumnNames) (map[string]interface{}, error)
func (*Block) GetTxs ¶
func (b *Block) GetTxs() []chain.Transaction
type Chain ¶
type Chain struct {
// contains filtered or unexported fields
}
func New ¶
func New(client EthClient, filter *chain.Filter, consumerConfig *chain.BlockConsumerConfig, logger *logging.Logger) (*Chain, error)
We rely on this failing if the chain is not an Ethereum Chain
func (*Chain) Connectivity ¶
func (c *Chain) Connectivity() connectivity.State
func (*Chain) ConsumeBlocks ¶
func (*Chain) GetChainID ¶
func (*Chain) GetVersion ¶
type Event ¶
type Event struct { exec.LogEvent Height uint64 // Index of event in entire block (what ethereum provides us with IndexInBlock uint64 // Index of event in transaction Index uint64 TransactionHash binary.HexBytes }
func (*Event) GetAddress ¶
func (*Event) GetTransactionHash ¶
type Transaction ¶
func NewEthereumTransaction ¶
func NewEthereumTransaction(log *Event) *Transaction
func (*Transaction) GetEvents ¶
func (tx *Transaction) GetEvents() []chain.Event
func (*Transaction) GetException ¶
func (tx *Transaction) GetException() *errors.Exception
func (*Transaction) GetHash ¶
func (tx *Transaction) GetHash() binary.HexBytes
func (*Transaction) GetIndex ¶
func (tx *Transaction) GetIndex() uint64
func (*Transaction) GetMetadata ¶
func (tx *Transaction) GetMetadata(columns types.SQLColumnNames) (map[string]interface{}, error)
func (*Transaction) GetOrigin ¶
func (tx *Transaction) GetOrigin() *chain.Origin
Click to show internal directories.
Click to hide internal directories.