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) GetLastBlockHeight(ctx context.Context) (int64, error)
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) Stop(ctx 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
	HTTPClient *http.Client
	// 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) GetLastBlockHeight

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

func (*Client) Start

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

func (*Client) Stop

func (c *Client) Stop(ctx 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"`
}