relayer

Documentation

Index

• Variables
• func SetPriceFeeder(pf *coingecko.PriceFeed) func(GravityRelayer)
• type BridgeValidators
  • func (b BridgeValidators) GetPowers() []uint64
  • func (b BridgeValidators) HasDuplicates() bool
  • func (b BridgeValidators) Sort()
• type GravityRelayer
  • func NewGravityRelayer(logger zerolog.Logger, gravityQueryClient gravitytypes.QueryClient, ...) GravityRelayer
• type GravityValsetUpdatedEvents
  • func (a GravityValsetUpdatedEvents) Len() int
  • func (a GravityValsetUpdatedEvents) Less(i, j int) bool
  • func (a GravityValsetUpdatedEvents) Swap(i, j int)
• type SubmittableBatch
• type ValsetRelayMode
  • func (d ValsetRelayMode) String() string

Variables

var ErrNotFound = errors.New("not found")

Functions

func SetPriceFeeder

func SetPriceFeeder(pf *coingecko.PriceFeed) func(GravityRelayer)

Types

type BridgeValidators

type BridgeValidators []types.BridgeValidator

func (BridgeValidators) GetPowers

func (b BridgeValidators) GetPowers() []uint64

GetPowers returns only the power values for all members

func (BridgeValidators) HasDuplicates

func (b BridgeValidators) HasDuplicates() bool

HasDuplicates returns true if there are duplicates in the set

func (BridgeValidators) Sort

func (b BridgeValidators) Sort()

Sort sorts the validators by power

type GravityRelayer

type GravityRelayer interface {
	Start(ctx context.Context) error

	FindLatestValset(ctx context.Context) (*gravitytypes.Valset, error)

	RelayBatches(
		ctx context.Context,
		currentValset gravitytypes.Valset,
		possibleBatches map[ethcmn.Address][]SubmittableBatch,
	) error

	RelayValsets(ctx context.Context, currentValset gravitytypes.Valset) error

	// SetPriceFeeder sets the (optional) price feeder used when performing profitable
	// batch calculations.
	SetPriceFeeder(*coingecko.PriceFeed)
}

func NewGravityRelayer

func NewGravityRelayer(
	logger zerolog.Logger,
	gravityQueryClient gravitytypes.QueryClient,
	gravityContract gravity.Contract,
	valsetRelayMode ValsetRelayMode,
	batchRelayEnabled bool,
	loopDuration time.Duration,
	pendingTxWait time.Duration,
	profitMultiplier float64,
	options ...func(GravityRelayer),
) GravityRelayer

type GravityValsetUpdatedEvents

type GravityValsetUpdatedEvents []*wrappers.GravityValsetUpdatedEvent

func (GravityValsetUpdatedEvents) Len

func (a GravityValsetUpdatedEvents) Len() int

func (GravityValsetUpdatedEvents) Less

func (a GravityValsetUpdatedEvents) Less(i, j int) bool

func (GravityValsetUpdatedEvents) Swap

func (a GravityValsetUpdatedEvents) Swap(i, j int)

type SubmittableBatch

type SubmittableBatch struct {
	Batch      types.OutgoingTxBatch
	Signatures []types.MsgConfirmBatch
}

type ValsetRelayMode

type ValsetRelayMode int64

ValsetRelayMode defines an enumerated validator set relay mode.

const (
	ValsetRelayModeNone ValsetRelayMode = iota
	ValsetRelayModeMinimum
	ValsetRelayModeAll
)

Allowed validator set relay modes

func (ValsetRelayMode) String

func (d ValsetRelayMode) String() string

String gets the string representation of the validator set relay mode.