relayer

Documentation

Index

• Variables
• type Config
• type EvmFactorier
• type PalomaClienter
• type Relayer
  • func New(config *config.Config, palomaClient PalomaClienter, evmFactory EvmFactorier, ...) *Relayer
  • func (r *Relayer) AttestMessages(ctx context.Context, _ sync.Locker) error
  • func (r *Relayer) BootHealthCheck(ctx context.Context) error
  • func (r *Relayer) GravityHandleBatchSendEvent(ctx context.Context, locker sync.Locker) error
  • func (r *Relayer) GravityHandleSendToPalomaEvent(ctx context.Context, locker sync.Locker) error
  • func (r *Relayer) GravityRelayBatches(ctx context.Context, locker sync.Locker) error
  • func (r *Relayer) GravitySignBatches(ctx context.Context, locker sync.Locker) error
  • func (r *Relayer) HealthCheck(ctx context.Context) error
  • func (r *Relayer) RelayMessages(ctx context.Context, _ sync.Locker) error
  • func (r *Relayer) SetAppVersion(appVersion string)
  • func (r *Relayer) SetMevClient(c mev.Client)
  • func (r *Relayer) SignMessages(ctx context.Context, _ sync.Locker) error
  • func (r *Relayer) Start(ctx context.Context) error
  • func (r *Relayer) UpdateExternalChainInfos(ctx context.Context, _ sync.Locker) error

Variables

var (
	ErrMissingChainConfig = errors.Unrecoverable(whoops.String("missing chain config"))
	ErrUnknown            = errors.Unrecoverable(whoops.String("unknown errror"))

	ErrInvalidMinOnChainBalance = whoops.Errorf("invalid minOnChainBalance: %s")

	ErrNotAValidatorAccount = whoops.String("not a validator account")

	ErrValidatorIsNotStaking = whoops.String("validator is not staking")
)

Types

type Config

type Config struct {
	KeepAliveLoopTimeout    time.Duration
	KeepAliveBlockThreshold int64
}

type EvmFactorier

type EvmFactorier interface {
	Build(
		cfg config.EVM,
		chainReferenceID,
		smartContractID,
		smartContractABIJson,
		smartContractAddress string,
		chainID *big.Int,
		blockHeight int64,
		blockHeightHash common.Hash,
		minOnChainBalance *big.Int,
		mevClient mev.Client,
	) (chain.Processor, error)
}

type PalomaClienter

type PalomaClienter interface {
	NewStatus() paloma.StatusUpdater
	AddExternalChainInfo(ctx context.Context, chainInfos ...paloma.ChainInfoIn) error
	QueryValidatorInfo(ctx context.Context) ([]*valset.ExternalChainInfo, error)
	BroadcastMessageSignatures(ctx context.Context, signatures ...paloma.BroadcastMessageSignatureIn) error
	QueryMessagesForAttesting(ctx context.Context, queueTypeName string) ([]chain.MessageWithSignatures, error)
	QueryMessagesForRelaying(ctx context.Context, queueTypeName string) ([]chain.MessageWithSignatures, error)
	QueryMessagesForSigning(ctx context.Context, queueTypeName string) ([]chain.QueuedMessage, error)
	QueryGetEVMChainInfos(ctx context.Context) ([]*evmtypes.ChainInfo, error)
	AddMessageEvidence(ctx context.Context, queueTypeName string, messageID uint64, proof proto.Message) error
	SetPublicAccessData(ctx context.Context, queueTypeName string, messageID uint64, data []byte) error
	SetErrorData(ctx context.Context, queueTypeName string, messageID uint64, data []byte) error
	QueryGetEVMValsetByID(ctx context.Context, id uint64, chainID string) (*evmtypes.Valset, error)
	GetValidatorAddress() sdk.ValAddress
	GetValidator(ctx context.Context) (*stakingtypes.Validator, error)
	GetCreator() string
	BlockHeight(context.Context) (int64, error)
	QueryGetSnapshotByID(ctx context.Context, id uint64) (*valset.Snapshot, error)

	QueryGetValidatorAliveUntilBlockHeight(ctx context.Context) (int64, error)
	KeepValidatorAlive(ctx context.Context, appVersion string) error

	GravityQueryLastUnsignedBatch(ctx context.Context, chainReferenceID string) ([]gravity.OutgoingTxBatch, error)
	GravityConfirmBatches(ctx context.Context, signatures ...chain.SignedGravityOutgoingTxBatch) error
	GravityQueryBatchesForRelaying(ctx context.Context, chainReferenceID string) ([]chain.GravityBatchWithSignatures, error)
}

type Relayer

type Relayer struct {
	// contains filtered or unexported fields
}

func New

func New(config *config.Config, palomaClient PalomaClienter, evmFactory EvmFactorier, customTime utiltime.Time, cfg Config) *Relayer

func (*Relayer) AttestMessages

func (r *Relayer) AttestMessages(ctx context.Context, _ sync.Locker) error

func (*Relayer) BootHealthCheck

func (r *Relayer) BootHealthCheck(ctx context.Context) error

func (*Relayer) GravityHandleBatchSendEvent

func (r *Relayer) GravityHandleBatchSendEvent(ctx context.Context, locker sync.Locker) error

func (*Relayer) GravityHandleSendToPalomaEvent

func (r *Relayer) GravityHandleSendToPalomaEvent(ctx context.Context, locker sync.Locker) error

func (*Relayer) GravityRelayBatches

func (r *Relayer) GravityRelayBatches(ctx context.Context, locker sync.Locker) error

func (*Relayer) GravitySignBatches

func (r *Relayer) GravitySignBatches(ctx context.Context, locker sync.Locker) error

func (*Relayer) HealthCheck

func (r *Relayer) HealthCheck(ctx context.Context) error

func (*Relayer) RelayMessages

func (r *Relayer) RelayMessages(ctx context.Context, _ sync.Locker) error

func (*Relayer) SetAppVersion

func (r *Relayer) SetAppVersion(appVersion string)

func (*Relayer) SetMevClient

func (r *Relayer) SetMevClient(c mev.Client)

func (*Relayer) SignMessages

func (r *Relayer) SignMessages(ctx context.Context, _ sync.Locker) error

func (*Relayer) Start

func (r *Relayer) Start(ctx context.Context) error

Start starts the relayer. It's responsible for handling the communication with Paloma and other chains.

func (*Relayer) UpdateExternalChainInfos

func (r *Relayer) UpdateExternalChainInfos(ctx context.Context, _ sync.Locker) error