Versions in this module Expand all Collapse all v5 v5.3.0 Jul 17, 2023 Changes in this version + var HTTPProtocols = regexp.MustCompile("https?://") + func CreateGrpcConnection(cfg *GRPCConfig) (*grpc.ClientConn, error) + func GetHeightRequestContext(context context.Context, height int64) context.Context + func MustCreateGrpcConnection(cfg *GRPCConfig) *grpc.ClientConn + type Details struct + GRPC *GRPCConfig + RPC *RPCConfig + func DefaultDetails() *Details + func NewDetails(rpc *RPCConfig, grpc *GRPCConfig) *Details + func (d *Details) Validate() error + type GRPCConfig struct + Address string + Insecure bool + func DefaultGrpcConfig() *GRPCConfig + func NewGrpcConfig(address string, insecure bool) *GRPCConfig + type Node struct + func NewNode(cfg *Details, codec codec.Codec) (*Node, error) + func (cp *Node) Block(height int64) (*tmctypes.ResultBlock, error) + func (cp *Node) BlockResults(height int64) (*tmctypes.ResultBlockResults, error) + func (cp *Node) ChainID() (string, error) + func (cp *Node) ConsensusState() (*constypes.RoundStateSimple, error) + func (cp *Node) Genesis() (*tmctypes.ResultGenesis, error) + func (cp *Node) LatestHeight() (int64, error) + func (cp *Node) Stop() + func (cp *Node) SubscribeEvents(subscriber, query string) (<-chan tmctypes.ResultEvent, context.CancelFunc, error) + func (cp *Node) SubscribeNewBlocks(subscriber string) (<-chan tmctypes.ResultEvent, context.CancelFunc, error) + func (cp *Node) Tx(hash string) (*types.Tx, error) + func (cp *Node) TxSearch(query string, page *int, perPage *int, orderBy string) (*tmctypes.ResultTxSearch, error) + func (cp *Node) Txs(block *tmctypes.ResultBlock) ([]*types.Tx, error) + func (cp *Node) Validators(height int64) (*tmctypes.ResultValidators, error) + type RPCConfig struct + Address string + ClientName string + MaxConnections int + func DefaultRPCConfig() *RPCConfig + func NewRPCConfig(clientName, address string, maxConnections int) *RPCConfig + type Source struct + Ctx context.Context + GrpcConn *grpc.ClientConn + func NewSource(config *GRPCConfig) (*Source, error) + func (k Source) Type() string