relayer

package
v0.9.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 21, 2025 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPluginRelayerServer 

func RegisterPluginRelayerServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, impl looptypes.PluginRelayer) error

func RegisterStandAloneMedianProvider 

func RegisterStandAloneMedianProvider(s *grpc.Server, p types.MedianProvider)

RegisterStandAloneMedianProvider register the servers needed for a median plugin provider, this is a workaround to test the Node API on EVM until the EVM relayer is loopifyed.

func RegisterStandAloneOCR3CapabilityProvider 

func RegisterStandAloneOCR3CapabilityProvider(s *grpc.Server, p types.OCR3CapabilityProvider)

RegisterStandAloneOCR3CapabilityProvider register the servers needed for a generic plugin provider, this is a workaround to test the Node API on EVM until the EVM relayer is loopifyed.

func RegisterStandAlonePluginProvider 

func RegisterStandAlonePluginProvider(s *grpc.Server, p types.PluginProvider)

RegisterStandAlonePluginProvider register the servers needed for a generic plugin provider, this is a workaround to test the Node API on EVM until the EVM relayer is loopifyed.

Types

type EVMClient added in v0.7.1 

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

func NewEVMCClient added in v0.7.1 

func NewEVMCClient(grpcClient evmpb.EVMClient) *EVMClient

func (*EVMClient) BalanceAt added in v0.7.1 

func (e *EVMClient) BalanceAt(ctx context.Context, request evmtypes.BalanceAtRequest) (*evmtypes.BalanceAtReply, error)

func (*EVMClient) CalculateTransactionFee added in v0.7.1 

func (e *EVMClient) CalculateTransactionFee(ctx context.Context, receiptGasInfo evmtypes.ReceiptGasInfo) (*evmtypes.TransactionFee, error)

CalculateTransactionFee implements types.EVMService.

func (*EVMClient) CallContract added in v0.7.1 

func (e *EVMClient) CallContract(ctx context.Context, request evmtypes.CallContractRequest) (*evmtypes.CallContractReply, error)

func (*EVMClient) EstimateGas added in v0.7.1 

func (e *EVMClient) EstimateGas(ctx context.Context, msg *evmtypes.CallMsg) (uint64, error)

func (*EVMClient) FilterLogs added in v0.7.1 

func (e *EVMClient) FilterLogs(ctx context.Context, request evmtypes.FilterLogsRequest) (*evmtypes.FilterLogsReply, error)

func (*EVMClient) GetFiltersNames added in v0.9.0 

func (e *EVMClient) GetFiltersNames(ctx context.Context) ([]string, error)

func (*EVMClient) GetForwarderForEOA added in v0.7.1 

func (e *EVMClient) GetForwarderForEOA(ctx context.Context, eoa, ocr2AggregatorID evmtypes.Address, pluginType string) (forwarder evmtypes.Address, err error)

func (*EVMClient) GetTransactionByHash added in v0.7.1 

func (e *EVMClient) GetTransactionByHash(ctx context.Context, request evmtypes.GetTransactionByHashRequest) (*evmtypes.Transaction, error)

func (*EVMClient) GetTransactionFee added in v0.7.1 

func (e *EVMClient) GetTransactionFee(ctx context.Context, transactionID string) (*evmtypes.TransactionFee, error)

func (*EVMClient) GetTransactionReceipt added in v0.7.1 

func (e *EVMClient) GetTransactionReceipt(ctx context.Context, request evmtypes.GeTransactionReceiptRequest) (*evmtypes.Receipt, error)

func (*EVMClient) GetTransactionStatus added in v0.7.1 

func (e *EVMClient) GetTransactionStatus(ctx context.Context, transactionID string) (types.TransactionStatus, error)

func (*EVMClient) HeaderByNumber added in v0.9.0 

func (e *EVMClient) HeaderByNumber(ctx context.Context, request evmtypes.HeaderByNumberRequest) (*evmtypes.HeaderByNumberReply, error)

func (*EVMClient) QueryTrackedLogs added in v0.7.1 

func (e *EVMClient) QueryTrackedLogs(ctx context.Context, filterQuery []query.Expression,
	limitAndSort query.LimitAndSort, confidenceLevel primitives.ConfidenceLevel) ([]*evmtypes.Log, error)

func (*EVMClient) RegisterLogTracking added in v0.7.1 

func (e *EVMClient) RegisterLogTracking(ctx context.Context, filter evmtypes.LPFilterQuery) error

func (*EVMClient) SubmitTransaction added in v0.7.1 

func (e *EVMClient) SubmitTransaction(ctx context.Context, txRequest evmtypes.SubmitTransactionRequest) (*evmtypes.TransactionResult, error)

SubmitTransaction implements types.EVMService.

func (*EVMClient) UnregisterLogTracking added in v0.7.1 

func (e *EVMClient) UnregisterLogTracking(ctx context.Context, filterName string) error

type PluginProviderClient 

type PluginProviderClient interface {
	types.PluginProvider
	goplugin.GRPCClientConn
}

func WrapProviderClientConnection 

func WrapProviderClientConnection(ctx context.Context, providerType string, cc grpc.ClientConnInterface, broker *net.BrokerExt) (PluginProviderClient, error)

type PluginRelayerClient 

type PluginRelayerClient struct {
	*goplugin.PluginClient
	*goplugin.ServiceClient
	// contains filtered or unexported fields
}

func NewPluginRelayerClient 

func NewPluginRelayerClient(brokerCfg net.BrokerConfig) *PluginRelayerClient

func (*PluginRelayerClient) NewRelayer 

func (p *PluginRelayerClient) NewRelayer(ctx context.Context, config string, keystore, csaKeystore core.Keystore, capabilityRegistry core.CapabilitiesRegistry) (looptypes.Relayer, error)

type TONClient added in v0.8.0 

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

func NewTONClient added in v0.8.0 

func NewTONClient(grpcClient tonpb.TONClient) *TONClient

func (*TONClient) GetAccountBalance added in v0.8.0 

func (c *TONClient) GetAccountBalance(ctx context.Context, addr string, block *tontypes.BlockIDExt) (*tontypes.Balance, error)

func (*TONClient) GetBlockData added in v0.8.0 

func (c *TONClient) GetBlockData(ctx context.Context, block *tontypes.BlockIDExt) (*tontypes.Block, error)

func (*TONClient) GetMasterchainInfo added in v0.8.0 

func (c *TONClient) GetMasterchainInfo(ctx context.Context) (*tontypes.BlockIDExt, error)

func (*TONClient) GetTxExecutionFees added in v0.8.0 

func (c *TONClient) GetTxExecutionFees(ctx context.Context, lt uint64) (*tontypes.TransactionFee, error)

func (*TONClient) GetTxStatus added in v0.8.0 

func (c *TONClient) GetTxStatus(ctx context.Context, lt uint64) (types.TransactionStatus, tontypes.ExitCode, error)

func (*TONClient) HasFilter added in v0.8.0 

func (c *TONClient) HasFilter(ctx context.Context, name string) bool

func (*TONClient) RegisterFilter added in v0.8.0 

func (c *TONClient) RegisterFilter(ctx context.Context, filter tontypes.LPFilterQuery) error

func (*TONClient) SendTx added in v0.8.0 

func (c *TONClient) SendTx(ctx context.Context, msg tontypes.Message) error

func (*TONClient) UnregisterFilter added in v0.8.0 

func (c *TONClient) UnregisterFilter(ctx context.Context, name string) error

Source Files

View all Source files

Directories

Path Synopsis
pluginprovider
contractreader
contractreader/test
contractwriter
ext/ccip
ext/ccip/test
ext/ccipocr3
ext/ccipocr3/test
ext/median
ext/median/test
ext/mercury
ext/mercury/test
ext/mercury/v1
ext/mercury/v1/test
ext/mercury/v2
ext/mercury/v2/test
ext/mercury/v3
ext/mercury/v3/test
ext/mercury/v4
ext/mercury/v4/test
ext/ocr3capability
ext/ocr3capability/test
ocr2
ocr2/test
ocr3
ocr3/test

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.