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) 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")
)

Types

type Relayer

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

	Retrier        *helpers.Retrier
	SignatureStore *badger.Datastore
	// 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,
) *Relayer

func (*Relayer) ProcessAttestation

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

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)