relayer

Documentation

Index

• Variables
• type Relayer
  • func NewRelayer(tmQuerier *rpc.TmQuerier, appQuerier *rpc.AppQuerier, p2pQuerier *p2p.Querier, ...) *Relayer
  • func (r *Relayer) ProcessAttestation(ctx context.Context, opts *bind.TransactOpts, ...) (*coregethtypes.Transaction, error)
  • func (r *Relayer) QueryValsetFromP2PNetworkAndValidateIt(ctx context.Context) (*celestiatypes.Valset, error)
  • func (r *Relayer) SaveDataCommitmentSignaturesToStore(ctx context.Context, att celestiatypes.DataCommitment, ...) error
  • func (r *Relayer) SaveValsetSignaturesToStore(ctx context.Context, att celestiatypes.Valset, confirms []types.ValsetConfirm) error
  • func (r *Relayer) Start(ctx context.Context) error
  • func (r *Relayer) SubmitDataRootTupleRoot(opts *bind.TransactOpts, dataCommitment celestiatypes.DataCommitment, ...) (*coregethtypes.Transaction, error)
  • func (r *Relayer) UpdateValidatorSet(ctx context.Context, opts *bind.TransactOpts, valset celestiatypes.Valset, ...) (*coregethtypes.Transaction, error)

Variables

var (
	ErrAttestationNotValsetRequest         = errors.New("attestation is not a valset request")
	ErrAttestationNotDataCommitmentRequest = errors.New("attestation is not a data commitment request")
	ErrAttestationNotFound                 = errors.New("attestation not found")
	ErrValidatorSetMismatch                = errors.New("p2p validator set is different from the trusted contract one")
	ErrTransactionStillPending             = errors.New("evm transaction still pending")
)

Types

type Relayer

type Relayer struct {
	TmQuerier  *rpc.TmQuerier
	AppQuerier *rpc.AppQuerier
	P2PQuerier *p2p.Querier
	EVMClient  *evm.Client

	Retrier               *helpers.Retrier
	SignatureStore        *badger.Datastore
	RetryTimeout          time.Duration
	IsBackupRelayer       bool
	BackupRelayerWaitTime time.Duration
	Meters                *telemetry.RelayerMeters
	// contains filtered or unexported fields
}

func NewRelayer

func NewRelayer(
	tmQuerier *rpc.TmQuerier,
	appQuerier *rpc.AppQuerier,
	p2pQuerier *p2p.Querier,
	evmClient *evm.Client,
	logger tmlog.Logger,
	retrier *helpers.Retrier,
	sigStore *badger.Datastore,
	retryTimeout time.Duration,
	isBackupRelayer bool,
	backupRelayerWaitTime time.Duration,
	meters *telemetry.RelayerMeters,
) *Relayer

func (*Relayer) ProcessAttestation

func (r *Relayer) ProcessAttestation(ctx context.Context, opts *bind.TransactOpts, attI celestiatypes.AttestationRequestI) (*coregethtypes.Transaction, error)

func (*Relayer) QueryValsetFromP2PNetworkAndValidateIt

func (r *Relayer) QueryValsetFromP2PNetworkAndValidateIt(ctx context.Context) (*celestiatypes.Valset, error)

QueryValsetFromP2PNetworkAndValidateIt Queries the latest valset from the P2P network and validates it against the validator set hash used in the contract.

func (*Relayer) SaveDataCommitmentSignaturesToStore

func (r *Relayer) SaveDataCommitmentSignaturesToStore(ctx context.Context, att celestiatypes.DataCommitment, dataRootTupleRoot string, confirms []types.DataCommitmentConfirm) error

func (*Relayer) SaveValsetSignaturesToStore

func (r *Relayer) SaveValsetSignaturesToStore(ctx context.Context, att celestiatypes.Valset, confirms []types.ValsetConfirm) error

func (*Relayer) Start

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

func (*Relayer) SubmitDataRootTupleRoot

func (r *Relayer) SubmitDataRootTupleRoot(
	opts *bind.TransactOpts,
	dataCommitment celestiatypes.DataCommitment,
	currentValset celestiatypes.Valset,
	commitment string,
	confirms []types.DataCommitmentConfirm,
) (*coregethtypes.Transaction, error)

func (*Relayer) UpdateValidatorSet

func (r *Relayer) UpdateValidatorSet(
	ctx context.Context,
	opts *bind.TransactOpts,
	valset celestiatypes.Valset,
	newThreshold uint64,
	confirms []types.ValsetConfirm,
) (*coregethtypes.Transaction, error)