runner

Documentation

Index

• Constants
• Variables
• func Close() error
• func FlushSendQueue(chainId string, logger log.Logger, metrics prommetrics.Metrics) error
• func Run(cfg *config.Config, home string) error
• func RunGRPCQuery(ctx context.Context, client *lensclient.ChainClient, method string, ...) (abcitypes.ResponseQuery, metadata.MD, error)
• type Clients
  • func (clients Clients) GetForChainId(chainId string) *lensclient.ChainClient
• type Query

Constants

const VERSION = "icq/v0.8.2"

Variables

var (
	WaitInterval       = time.Second * 6
	MaxHistoricQueries = 5
	MaxTxMsgs          = 5
)

Functions

func Close

func Close() error

func FlushSendQueue

func FlushSendQueue(chainId string, logger log.Logger, metrics prommetrics.Metrics) error

func Run

func Run(cfg *config.Config, home string) error

func RunGRPCQuery

func RunGRPCQuery(ctx context.Context, client *lensclient.ChainClient, method string, reqBz []byte, md metadata.MD, metrics prommetrics.Metrics) (abcitypes.ResponseQuery, metadata.MD, error)

Types

type Clients

type Clients []*lensclient.ChainClient

func (Clients) GetForChainId

func (clients Clients) GetForChainId(chainId string) *lensclient.ChainClient

type Query

type Query struct {
	SourceChainId string
	ConnectionId  string
	ChainId       string
	QueryId       string
	Type          string
	Height        int64
	Request       []byte
}