Documentation
¶
Index ¶
- type Client
- func (c *Client) Block(ctx context.Context, height int64) (*cometbftcoretypes.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 cometbfttypes.Txs) ([]*tx.GetTxResponse, error)
- func (c *Client) Validators(ctx context.Context, height int64) (*cometbftcoretypes.ResultValidators, error)
- type Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct { TmsService tmservice.ServiceClient TxService tx.ServiceClient // contains filtered or unexported fields }
func (*Client) Block ¶
func (c *Client) Block(ctx context.Context, height int64) (*cometbftcoretypes.ResultBlock, error)
func (*Client) Conn ¶
func (c *Client) Conn() *grpc.ClientConn
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"` MaxReceiveMessageSize int `env:"GRPC_MAX_RECEIVE_MESSAGE_SIZE_BYTES" envDefault:"5242880"` // 5MB Timeout time.Duration `env:"GRPC_TIMEOUT" envDefault:"15s"` }
Click to show internal directories.
Click to hide internal directories.