grpc

Documentation

Index

• type Client
  • func New(cfg Config, l zerolog.Logger, st storage) *Client
  • func (c *Client) Block(ctx context.Context, height int64) (*tmcoretypes.ResultBlock, error)
  • func (c *Client) Conn() *grpc.ClientConn
  • 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 tmtypes.Txs) ([]*tx.GetTxResponse, error)
• type Config

Types

type Client

type Client struct {
	TmsService tmservice.ServiceClient
	TxService  tx.ServiceClient
	// 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) (*tmcoretypes.ResultBlock, error)

func (*Client) Conn

func (c *Client) Conn() *grpc.ClientConn

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 tmtypes.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.

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"`
	MaxReceiveMessageSize int           `env:"GRPC_MAX_RECEIVE_MESSAGE_SIZE_BYTES" envDefault:"5242880"` // 5MB
	Timeout               time.Duration `env:"GRPC_TIMEOUT" envDefault:"15s"`
}