runner

package

v0.0.0-...-89b98da Latest Latest Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/quicksilver-zone/quicksilver

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)
func Tx(client *lensclient.ChainClient, hash []byte) (tmtypes.TxProof, int64, error)
type Clients
- func (clients Clients) GetForChainId(chainId string) *lensclient.ChainClient
type Query
type TxResultMinimal

Constants ¶

View Source

const (
	VERSION = "icq/v0.11.0"
)

Variables ¶

View Source

var (
	MaxTxMsgs             int
	WaitInterval          = time.Second * 6
	HistoricQueryInterval = time.Second * 15
	TxMsgs                = MaxTxMsgs

	LastReduced time.Time

	// Variables used for retries
	RtyAttNum = uint(5)
	RtyAtt    = retry.Attempts(RtyAttNum)
	RtyDel    = retry.Delay(time.Millisecond * 400)
	RtyErr    = retry.LastErrorOnly(true)
)

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)

func Tx ¶

func Tx(client *lensclient.ChainClient, hash []byte) (tmtypes.TxProof, int64, error)

tm0.37 has a breaking change whereby tx events are no longer base64 encoded, so are represented as string and not bytes. As a result, we cannot use the RPCClient.Tx() method which attempts to unmarshal the Result, including the underlying Tx object. As such, we want to query the result directly, and unmarshal the json ourselves, to a representation of the result that conveniently does not contain the Tx object (that we don't use, because the TxProof already contains a byte representation of tx anyway!) Note: this function is compatible with 0.34 and 0.37 representations of transactions.

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
}

type TxResultMinimal ¶

type TxResultMinimal struct {
	Height string          `json:"height"`
	Proof  tmtypes.TxProof `json:"proof"`
}

a minimised representation of the Tx emitted by a Tx query, only containing Height and Proof and thus compatbiel with tm0.34 and tm0.37.

Source Files ¶

View all Source files

run.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL