client

Documentation

Index

• type EthClient
  • func NewEthClient(client *ethclient.Client) EthClient
  • func (client EthClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
  • func (client EthClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
  • func (client EthClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)
  • func (client EthClient) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
  • func (client EthClient) SubscribeNewStateChanges(ctx context.Context, q ethereum.FilterQuery, ch chan<- filters.Payload) (ethereum.Subscription, error)
  • func (client EthClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
  • func (client EthClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)
• type RpcClient
  • func NewRpcClient(client *rpc.Client, ipcPath string) RpcClient
  • func (client RpcClient) BatchCall(batch []core.BatchElem) error
  • func (client RpcClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
  • func (client RpcClient) IpcPath() string
  • func (client RpcClient) Subscribe(namespace string, payloadChan interface{}, args ...interface{}) (core.Subscription, error)
• type Subscription
  • func (sub Subscription) Err() <-chan error
  • func (sub Subscription) Unsubscribe()

Types

type EthClient

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

func NewEthClient

func NewEthClient(client *ethclient.Client) EthClient

func (EthClient) BlockByNumber

func (client EthClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

func (EthClient) CallContract

func (client EthClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

func (EthClient) FilterLogs

func (client EthClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

func (EthClient) HeaderByNumber

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

func (EthClient) SubscribeNewStateChanges

func (client EthClient) SubscribeNewStateChanges(ctx context.Context, q ethereum.FilterQuery, ch chan<- filters.Payload) (ethereum.Subscription, error)

func (EthClient) TransactionReceipt

func (client EthClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

func (EthClient) TransactionSender

func (client EthClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)

type RpcClient

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

func NewRpcClient

func NewRpcClient(client *rpc.Client, ipcPath string) RpcClient

func (RpcClient) BatchCall

func (client RpcClient) BatchCall(batch []core.BatchElem) error

func (RpcClient) CallContext

func (client RpcClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error

func (RpcClient) IpcPath

func (client RpcClient) IpcPath() string

func (RpcClient) Subscribe

func (client RpcClient) Subscribe(namespace string, payloadChan interface{}, args ...interface{}) (core.Subscription, error)

Subscribe subscribes to an rpc "namespace_subscribe" subscription with the given channel The first argument needs to be the method we wish to invoke

type Subscription

type Subscription struct {
	RpcSubscription *rpc.ClientSubscription
}

func (Subscription) Err

func (sub Subscription) Err() <-chan error

func (Subscription) Unsubscribe

func (sub Subscription) Unsubscribe()