rpc

Documentation

Index

• type Client
  • func New(cfg Config) *Client
  • func (c *Client) Genesis(ctx context.Context) (*cometbfttypes.GenesisDoc, error)
  • func (c *Client) GetBlockEvents(ctx context.Context, height int64) (begin, end types.BlockerEvents, err error)
  • func (c *Client) GetBlockResults(ctx context.Context, height int64) (*coretypes.ResultBlockResults, error)
  • func (c *Client) GetLastBlockHeight(ctx context.Context) (int64, error)
  • func (c *Client) GetTxResults(ctx context.Context, height int64) ([]*abci.ResponseDeliverTx, error)
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) Stop(_ context.Context) error
  • func (c *Client) SubscribeNewBlocks(ctx context.Context) (<-chan cometbftcoretypes.ResultEvent, error)
  • func (c *Client) WsEnabled() bool
• type Config

Types

type Client

type Client struct {
	*jsonrpcclient.WSClient
	*cometbftHttp.WSEvents

	RPCClient *cometbftHttp.HTTP
	// contains filtered or unexported fields
}

func New

func New(cfg Config) *Client

func (*Client) Genesis

func (c *Client) Genesis(ctx context.Context) (*cometbfttypes.GenesisDoc, error)

func (*Client) GetBlockEvents

func (c *Client) GetBlockEvents(ctx context.Context, height int64) (begin, end types.BlockerEvents, err error)

GetBlockEvents returns begin block and end block events.

func (*Client) GetBlockResults

func (c *Client) GetBlockResults(ctx context.Context, height int64) (*coretypes.ResultBlockResults, error)

func (*Client) GetLastBlockHeight

func (c *Client) GetLastBlockHeight(ctx context.Context) (int64, error)

func (*Client) GetTxResults

func (c *Client) GetTxResults(ctx context.Context, height int64) ([]*abci.ResponseDeliverTx, error)

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

func (*Client) Stop

func (c *Client) Stop(_ context.Context) error

func (*Client) SubscribeNewBlocks

func (c *Client) SubscribeNewBlocks(ctx context.Context) (<-chan cometbftcoretypes.ResultEvent, error)

func (*Client) WsEnabled

func (c *Client) WsEnabled() bool

type Config

type Config struct {
	Host      string        `env:"RPC_URL" envDefault:"http://localhost:26657"`
	WSEnabled bool          `env:"WS_ENABLED" envDefault:"true"`
	Timeout   time.Duration `env:"RPC_TIMEOUT" envDefault:"15s"`
}