runner

Documentation

Index

• Variables
• func Close(cfg *types.Config) error
• func FlushSendQueue(cfg *types.Config, logger log.Logger, metrics prommetrics.Metrics) error
• func Run(ctx context.Context, cfg *types.Config, errHandler func(error)) error
• type ClientUpdateRequirement
• type Message
• type Query

Variables

var (
	VERSION             = "icq-relayer"
	QUICKSILVER_VERSION = ""
	COMMIT              = ""
)

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 * 800)
	RtyErr    = retry.LastErrorOnly(true)
)

Functions

func Close

func Close(cfg *types.Config) error

func FlushSendQueue

func FlushSendQueue(cfg *types.Config, logger log.Logger, metrics prommetrics.Metrics) error

func Run

func Run(ctx context.Context, cfg *types.Config, errHandler func(error)) error

Types

type ClientUpdateRequirement

type ClientUpdateRequirement struct {
	ConnectionId string
	ChainId      string
	Height       int64
}

type Message

type Message struct {
	Msg          sdk.Msg
	ClientUpdate *ClientUpdateRequirement
}

type Query

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