grpc

Documentation

Index

• func GetHeightRequestHeader(height int64) grpc.CallOption
• type Client
  • func New(cfg Config) *Client
  • func (c *Client) Block(ctx context.Context, height int64) (*cometbftcoretypes.ResultBlock, error)
  • func (c *Client) GetTotalSupply(ctx context.Context, height int64) (basetypes.Coins, error)
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) Stop(_ context.Context) error
  • func (c *Client) Txs(ctx context.Context, txs cometbfttypes.Txs) ([]*tx.GetTxResponse, error)
  • func (c *Client) Validators(ctx context.Context, height int64) (*cometbftcoretypes.ResultValidators, error)
• type Config

Functions

func GetHeightRequestHeader

func GetHeightRequestHeader(height int64) grpc.CallOption

GetHeightRequestHeader returns the grpc.CallOption to query the state at a given height

Types

type Client

type Client struct {
	SlashingQueryClient     slashingtypes.QueryClient
	TmsService              tmservice.ServiceClient
	TxService               tx.ServiceClient
	BankQueryClient         banktypes.QueryClient
	GovQueryClient          govtypes.QueryClient
	MintQueryClient         minttypes.QueryClient
	StakingQueryClient      stakingtypes.QueryClient
	DistributionQueryClient distributiontypes.QueryClient
	AuthzQueryClient        authztypes.QueryClient
	FeegrantQueryClient     feegranttypes.QueryClient
	// contains filtered or unexported fields
}

func New

func New(cfg Config) *Client

func (*Client) Block

func (c *Client) Block(ctx context.Context, height int64) (*cometbftcoretypes.ResultBlock, error)

func (*Client) GetTotalSupply

func (c *Client) GetTotalSupply(ctx context.Context, height int64) (basetypes.Coins, error)

func (*Client) Start

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

func (*Client) Stop

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

func (*Client) Txs

func (c *Client) Txs(ctx context.Context, txs cometbfttypes.Txs) ([]*tx.GetTxResponse, error)

Txs queries for all the transactions in a block. Transactions are returned in sdk.TxResponse format which internally contains a sdk.Tx. An error is returned if any query fails.

func (*Client) Validators

func (c *Client) Validators(ctx context.Context, height int64) (*cometbftcoretypes.ResultValidators, error)

type Config

type Config struct {
	Host             string `env:"GRPC_URL" envDefault:"http://localhost:9090"`
	SecureConnection bool   `env:"GRPC_SECURE_CONNECTION" envDefault:"false"`
	MetricsEnabled   bool   `env:"METRICS_ENABLED" envDefault:"false"`
}