quaiclient

Documentation

Overview

Package ethclient provides a client for the Quai RPC API.

Index

• type Client
  • func Dial(rawurl string, logger *log.Logger) (*Client, error)
  • func DialContext(ctx context.Context, rawurl string, logger *log.Logger) (*Client, error)
  • func NewClient(c *rpc.Client) *Client
  • func (ec *Client) BaseFee(ctx context.Context, txType bool) (*big.Int, error)
  • func (ec *Client) CalcOrder(ctx context.Context, header *types.WorkObject) (int, error)
  • func (ec *Client) Close()
  • func (ec *Client) EstimateGas(ctx context.Context, msg quai.CallMsg) (uint64, error)
  • func (ec *Client) FilterLogs(ctx context.Context, q quai.FilterQuery) ([]types.Log, error)
  • func (ec *Client) GetPendingHeader(ctx context.Context) (*types.WorkObject, error)
  • func (ec *Client) GetWorkShareThreshold(ctx context.Context) (int, error)
  • func (ec *Client) HeaderByHash(ctx context.Context, hash common.Hash) *types.Header
  • func (ec *Client) HeaderByNumber(ctx context.Context, number string) *types.Header
  • func (ec *Client) QiRateAtBlock(ctx context.Context, block interface{}) (*big.Int, error)
  • func (ec *Client) QuaiRateAtBlock(ctx context.Context, block interface{}) (*big.Int, error)
  • func (ec *Client) ReceiveMinedHeader(ctx context.Context, header *types.WorkObject) error
  • func (ec *Client) ReceiveWorkShare(ctx context.Context, header *types.WorkObjectHeader) error
  • func (ec *Client) SubmitSubWorkshare(ctx context.Context, wo *types.WorkObject) error
  • func (ec *Client) SubscribeFilterLogs(ctx context.Context, q quai.FilterQuery, ch chan<- types.Log) (quai.Subscription, error)
  • func (ec *Client) SubscribePendingHeader(ctx context.Context, ch chan<- []byte) (quai.Subscription, error)
  • func (ec *Client) TxPoolStatus(ctx context.Context) (map[string]hexutil.Uint, error)

Types

type Client

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

Client defines typed wrappers for the Quai RPC API.

func Dial

func Dial(rawurl string, logger *log.Logger) (*Client, error)

Dial connects a client to the given URL.

func DialContext

func DialContext(ctx context.Context, rawurl string, logger *log.Logger) (*Client, error)

func NewClient

func NewClient(c *rpc.Client) *Client

NewClient creates a client that uses the given RPC client.

func (*Client) BaseFee

func (ec *Client) BaseFee(ctx context.Context, txType bool) (*big.Int, error)

BaseFee returns the base fee for a tx to be included in the next block. If txType is set to "true" returns the Quai base fee in units of Wei. If txType is set to "false" returns the Qi base fee in units of Qit.

func (*Client) CalcOrder

func (ec *Client) CalcOrder(ctx context.Context, header *types.WorkObject) (int, error)

func (*Client) Close

func (ec *Client) Close()

func (*Client) EstimateGas

func (ec *Client) EstimateGas(ctx context.Context, msg quai.CallMsg) (uint64, error)

EstimateGas tries to estimate the gas needed to execute a specific transaction based on the current pending state of the backend blockchain. There is no guarantee that this is the true gas limit requirement as other transactions may be added or removed by miners, but it should provide a basis for setting a reasonable default.

func (*Client) FilterLogs

func (ec *Client) FilterLogs(ctx context.Context, q quai.FilterQuery) ([]types.Log, error)

FilterLogs executes a filter query.

func (*Client) GetPendingHeader

func (ec *Client) GetPendingHeader(ctx context.Context) (*types.WorkObject, error)

GetPendingHeader gets the latest pending header from the chain.

func (*Client) GetWorkShareThreshold

func (ec *Client) GetWorkShareThreshold(ctx context.Context) (int, error)

func (*Client) HeaderByHash

func (ec *Client) HeaderByHash(ctx context.Context, hash common.Hash) *types.Header

func (*Client) HeaderByNumber

func (ec *Client) HeaderByNumber(ctx context.Context, number string) *types.Header

func (*Client) QiRateAtBlock

func (ec *Client) QiRateAtBlock(ctx context.Context, block interface{}) (*big.Int, error)

QiRateAtBlock returns the number of Quai needed for a Qi at a given block number or hash.

func (*Client) QuaiRateAtBlock

func (ec *Client) QuaiRateAtBlock(ctx context.Context, block interface{}) (*big.Int, error)

QuaiRateAtBlock returns the number of Qi needed for a Quai at a given block number or hash.

func (*Client) ReceiveMinedHeader

func (ec *Client) ReceiveMinedHeader(ctx context.Context, header *types.WorkObject) error

ReceiveMinedHeader sends a mined block back to the node

func (*Client) ReceiveWorkShare

func (ec *Client) ReceiveWorkShare(ctx context.Context, header *types.WorkObjectHeader) error

func (*Client) SubmitSubWorkshare

func (ec *Client) SubmitSubWorkshare(ctx context.Context, wo *types.WorkObject) error

Submits a minimally worked workshare to the client node

func (*Client) SubscribeFilterLogs

func (ec *Client) SubscribeFilterLogs(ctx context.Context, q quai.FilterQuery, ch chan<- types.Log) (quai.Subscription, error)

SubscribeFilterLogs subscribes to the results of a streaming filter query.

func (*Client) SubscribePendingHeader

func (ec *Client) SubscribePendingHeader(ctx context.Context, ch chan<- []byte) (quai.Subscription, error)

SubscribePendingHeader subscribes to notifications about the current pending block on the node.

func (*Client) TxPoolStatus

func (ec *Client) TxPoolStatus(ctx context.Context) (map[string]hexutil.Uint, error)