grpc

Documentation

Index

• func GetHeightRequestHeader(height int64) grpc.CallOption
• type Client
  • func New(cfg Config, l zerolog.Logger, st storage) *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, height int64, 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
	AuthQueryClient         authtypes.QueryClient
	GovQueryClient          govtypes.QueryClient
	MintQueryClient         minttypes.QueryClient
	StakingQueryClient      stakingtypes.QueryClient
	DistributionQueryClient distributiontypes.QueryClient
	AuthzQueryClient        authztypes.QueryClient
	FeegrantQueryClient     feegranttypes.QueryClient
	IbcTransferQueryClient  ibctransfertypes.QueryClient
	LiquidityQueryClient    liquiditytypes.QueryClient
	GraphQueryClient        graphtypes.QueryClient
	BandwidthQueryClient    bandwidthtypes.QueryClient
	DMNQueryClient          dmntypes.QueryClient
	GridQueryClient         gridtypes.QueryClient
	RankQueryClient         ranktypes.QueryClient
	ResourcesQueryClient    resourcestypes.QueryClient
	// contains filtered or unexported fields
}

func New

func New(cfg Config, l zerolog.Logger, st storage) *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, height int64, 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"`
	Timeout          time.Duration `env:"GRPC_TIMEOUT" envDefault:"15s"`
}