ccip

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2024 License: MIT Imports: 20 Imported by: 0

README

The code herein is the gRPC wrapper for the CCIP Reporting Plugin Providers

Developing the CCIP Providers requires the follow workflow

  1. Update the golang interfaces in chainlink-common/pkg/types, and/or chainlink-common/pkg/types/ccip

  2. Mirror those changes as protobuf changes in chainlink-common/pkg/loop/internal/pb/ccip note: golang interface <-> gRPC service and struct <-> message remember to run make generate at the top of the repo to generate your changes see docs in internal/pb for more details

  3. If you are adding a new interface, create a file here and implement the gRPC server and client. Follow the testing pattern in the test subdir to ensure roundtrip de/serialization of each and every rpc

  4. If you are updating an interface, then update both the <Interface>GRPCClient and <Interface>GRPCServer in the relevant file.

    • The client code will not compile if you change the interface in chainlink-common/pkg/types/ccip and so these are obvious
    • However the server code will compile and you will receive runtime Unimplemented errors (this is a consequence of golang gRPC best practices that embed a UnimplementedServer. the curious reader can go here)
    • Add support for your new method in the static test implementation found in test and add a test case to the roundTrip test for that interface. This roundtrip test is the key to prevent runtime Unimplemented errors

  5. Update the ccip repo with your commit: go get github.com/smartcontractkit/chainlink-common@<commit_hash>

    • A useful technique to co-develop changes in chainlink-common with ccip (or any other dependent repo) is to use go workspace. A go workspace effectively short circuits the go.mod to use local repos configured by the workspace definition. Ex:
    sh
make ccip-common-workspace
cd ccip-common-workspace
git clone https://github.com/smartcontractkit/ccip.git
git clone https://github.com/smartcontractkit/chainlink-common.git
go work init
go work use ccip
go work use chainlink-common
    • NOTE: the chainlink-common will be a sore spot for the ccip repo. It is in active develop for Keystone. This means that non-CCIP related changes are happening frequently in chainlink-common and core. When these changes necessitate changes in core, it will not be possible to update chainlink-common without reconciling the changes between ccip and core. Recent example changes 7992ed8, e9e903b

Example: you add method to OnRampReader

When adding interface methods, maintain alphabetical order of there declaration and implementations. You will thank yourself later! You will find yourself reading multiple files that define or implement the interfaces and this simply organizational principle makes that much easier when there are more than two or three funcs. It really pays off in the tests, when you can easily compare the test cases and the interface definitions.

Example commit: https://github.com/smartcontractkit/chainlink-common/commit/c15097958cbdd27943c474052b4bf89c845c2673

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCommitProviderServices 

func RegisterCommitProviderServices(s *grpc.Server, provider types.CCIPCommitProvider, brokerExt *net.BrokerExt)

func RegisterExecutionProviderServices 

func RegisterExecutionProviderServices(s *grpc.Server, provider types.CCIPExecProvider, brokerExt *net.BrokerExt)

Types

type CommitGasEstimatorGRPCClient 

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

CommitGasEstimatorGRPCClient implements cciptypes.GasEstimatorCommit by wrapping a ccippb.CommitGasEstimatorReaderGRPCClient grpc client. It is used by a ReportingPlugin to call the CommitGasEstimatorReader service, which is hosted by the relayer

func NewCommitGasEstimatorGRPCClient 

func NewCommitGasEstimatorGRPCClient(cc grpc.ClientConnInterface) *CommitGasEstimatorGRPCClient

func (*CommitGasEstimatorGRPCClient) ClientConn 

func (c *CommitGasEstimatorGRPCClient) ClientConn() grpc.ClientConnInterface

func (*CommitGasEstimatorGRPCClient) Close 

func (c *CommitGasEstimatorGRPCClient) Close() error

func (*CommitGasEstimatorGRPCClient) DenoteInUSD 

func (c *CommitGasEstimatorGRPCClient) DenoteInUSD(p *big.Int, wrappedNativePrice *big.Int) (*big.Int, error)

DenoteInUSD implements ccip.GasPriceEstimatorCommit.

func (*CommitGasEstimatorGRPCClient) Deviates 

func (c *CommitGasEstimatorGRPCClient) Deviates(p1 *big.Int, p2 *big.Int) (bool, error)

Deviates implements ccip.GasPriceEstimatorCommit.

func (*CommitGasEstimatorGRPCClient) GetGasPrice 

func (c *CommitGasEstimatorGRPCClient) GetGasPrice(ctx context.Context) (*big.Int, error)

GetGasPrice implements ccip.GasPriceEstimatorCommit.

func (*CommitGasEstimatorGRPCClient) Median 

func (c *CommitGasEstimatorGRPCClient) Median(gasPrices []*big.Int) (*big.Int, error)

Median implements ccip.GasPriceEstimatorCommit.

type CommitGasEstimatorGRPCServer 

type CommitGasEstimatorGRPCServer struct {
	ccippb.UnimplementedGasPriceEstimatorCommitServer
	// contains filtered or unexported fields
}

CommitGasEstimatorGRPCServer implements ccippb.CommitGasEstimatorReaderServer by wrapping a cciptypes.GasEstimatorCommit implementation. This server is hosted by the relayer and is called ReportingPlugin via the CommitGasEstimatorGRPCClient

func NewCommitGasEstimatorGRPCServer 

func NewCommitGasEstimatorGRPCServer(impl cciptypes.GasPriceEstimatorCommit) *CommitGasEstimatorGRPCServer

func (*CommitGasEstimatorGRPCServer) DenoteInUSD 

func (c *CommitGasEstimatorGRPCServer) DenoteInUSD(ctx context.Context, req *ccippb.DenoteInUSDRequest) (*ccippb.DenoteInUSDResponse, error)

DenoteInUSD implements ccippb.GasPriceEstimatorCommitServer.

func (*CommitGasEstimatorGRPCServer) Deviates 

func (c *CommitGasEstimatorGRPCServer) Deviates(ctx context.Context, req *ccippb.DeviatesRequest) (*ccippb.DeviatesResponse, error)

Deviates implements ccippb.GasPriceEstimatorCommitServer.

func (*CommitGasEstimatorGRPCServer) GetGasPrice 

func (c *CommitGasEstimatorGRPCServer) GetGasPrice(ctx context.Context, req *emptypb.Empty) (*ccippb.GetGasPriceResponse, error)

GetGasPrice implements ccippb.GasPriceEstimatorCommitServer.

func (*CommitGasEstimatorGRPCServer) Median 

func (c *CommitGasEstimatorGRPCServer) Median(ctx context.Context, req *ccippb.MedianRequest) (*ccippb.MedianResponse, error)

Median implements ccippb.GasPriceEstimatorCommitServer.

type CommitProviderClient 

type CommitProviderClient struct {
	*ocr2.PluginProviderClient

	// must be shared with the server
	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewCommitProviderClient 

func NewCommitProviderClient(b *net.BrokerExt, conn grpc.ClientConnInterface) *CommitProviderClient

func (*CommitProviderClient) Close 

func (e *CommitProviderClient) Close() error

func (*CommitProviderClient) NewCommitStoreReader 

func (e *CommitProviderClient) NewCommitStoreReader(ctx context.Context, addr cciptypes.Address) (cciptypes.CommitStoreReader, error)

NewCommitStoreReader implements types.CCIPCommitProvider.

func (*CommitProviderClient) NewOffRampReader 

func (e *CommitProviderClient) NewOffRampReader(ctx context.Context, addr cciptypes.Address) (cciptypes.OffRampReader, error)

NewOffRampReader implements types.CCIPCommitProvider.

func (*CommitProviderClient) NewOnRampReader 

func (e *CommitProviderClient) NewOnRampReader(ctx context.Context, addr cciptypes.Address, sourceChainSelector uint64, destChainSelector uint64) (cciptypes.OnRampReader, error)

NewOnRampReader implements types.CCIPCommitProvider.

func (*CommitProviderClient) NewPriceGetter 

func (e *CommitProviderClient) NewPriceGetter(ctx context.Context) (cciptypes.PriceGetter, error)

NewPriceGetter implements types.CCIPCommitProvider.

func (*CommitProviderClient) NewPriceRegistryReader 

func (e *CommitProviderClient) NewPriceRegistryReader(ctx context.Context, addr cciptypes.Address) (cciptypes.PriceRegistryReader, error)

NewPriceRegistryReader implements types.CCIPCommitProvider.

func (*CommitProviderClient) SourceNativeToken 

func (e *CommitProviderClient) SourceNativeToken(ctx context.Context, addr cciptypes.Address) (cciptypes.Address, error)

SourceNativeToken implements types.CCIPCommitProvider.

type CommitProviderServer 

type CommitProviderServer struct {
	ccippb.UnimplementedCommitCustomHandlersServer
	// BCF-3061 this has to be a shared pointer to the same impl as the execProviderClient
	*net.BrokerExt
	// contains filtered or unexported fields
}

CommitProviderServer is a server that wraps the custom methods of the types.CCIPCommitProvider this is necessary because those method create new resources that need to be served by the broker when we are running in legacy mode.

func NewCommitProviderServer 

func NewCommitProviderServer(impl types.CCIPCommitProvider, brokerExt *net.BrokerExt) *CommitProviderServer

func (*CommitProviderServer) Close 

func (e *CommitProviderServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

Close implements ccippb.CommitCustomHandlersServer.

func (*CommitProviderServer) NewCommitStoreReader 

func (e *CommitProviderServer) NewCommitStoreReader(ctx context.Context, req *ccippb.NewCommitStoreReaderRequest) (*ccippb.NewCommitStoreReaderResponse, error)

NewCommitStoreReader implements ccippb.CommitCustomHandlersServer.

func (*CommitProviderServer) NewOffRampReader 

func (e *CommitProviderServer) NewOffRampReader(ctx context.Context, req *ccippb.NewOffRampReaderRequest) (*ccippb.NewOffRampReaderResponse, error)

func (*CommitProviderServer) NewOnRampReader 

func (e *CommitProviderServer) NewOnRampReader(ctx context.Context, req *ccippb.NewOnRampReaderRequest) (*ccippb.NewOnRampReaderResponse, error)

func (*CommitProviderServer) NewPriceGetter 

func (e *CommitProviderServer) NewPriceGetter(ctx context.Context, _ *emptypb.Empty) (*ccippb.NewPriceGetterResponse, error)

func (*CommitProviderServer) NewPriceRegistryReader 

func (e *CommitProviderServer) NewPriceRegistryReader(ctx context.Context, req *ccippb.NewPriceRegistryReaderRequest) (*ccippb.NewPriceRegistryReaderResponse, error)

func (*CommitProviderServer) SourceNativeToken 

func (e *CommitProviderServer) SourceNativeToken(ctx context.Context, req *ccippb.SourceNativeTokenRequest) (*ccippb.SourceNativeTokenResponse, error)

type CommitStoreGRPCClient 

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

CommitStoreGRPCClient implements cciptypes.CommitStoreReader by wrapping a ccippb.CommitStoreReaderGRPCClient grpc client. It is used by a ReportingPlugin to call the CommitStoreReader service, which is hosted by the relayer

func NewCommitStoreReaderGRPCClient 

func NewCommitStoreReaderGRPCClient(brokerExt *net.BrokerExt, cc grpc.ClientConnInterface) *CommitStoreGRPCClient

func (*CommitStoreGRPCClient) ChangeConfig 

func (c *CommitStoreGRPCClient) ChangeConfig(ctx context.Context, onchainConfig []byte, offchainConfig []byte) (ccip.Address, error)

ChangeConfig implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) ClientConn 

func (c *CommitStoreGRPCClient) ClientConn() grpc.ClientConnInterface

ClientConn implements goplugin.GRPCClientConn.

func (*CommitStoreGRPCClient) Close 

func (c *CommitStoreGRPCClient) Close() error

func (*CommitStoreGRPCClient) DecodeCommitReport 

func (c *CommitStoreGRPCClient) DecodeCommitReport(ctx context.Context, report []byte) (ccip.CommitStoreReport, error)

DecodeCommitReport implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) EncodeCommitReport 

func (c *CommitStoreGRPCClient) EncodeCommitReport(ctx context.Context, report ccip.CommitStoreReport) ([]byte, error)

EncodeCommitReport implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) GasPriceEstimator 

func (c *CommitStoreGRPCClient) GasPriceEstimator(ctx context.Context) (ccip.GasPriceEstimatorCommit, error)

GasPriceEstimator implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) GetAcceptedCommitReportsGteTimestamp 

func (c *CommitStoreGRPCClient) GetAcceptedCommitReportsGteTimestamp(ctx context.Context, ts time.Time, confirmations int) ([]ccip.CommitStoreReportWithTxMeta, error)

GetAcceptedCommitReportsGteTimestamp implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) GetCommitReportMatchingSeqNum 

func (c *CommitStoreGRPCClient) GetCommitReportMatchingSeqNum(ctx context.Context, seqNum uint64, confirmations int) ([]ccip.CommitStoreReportWithTxMeta, error)

GetCommitReportMatchingSeqNum implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) GetCommitStoreStaticConfig 

func (c *CommitStoreGRPCClient) GetCommitStoreStaticConfig(ctx context.Context) (ccip.CommitStoreStaticConfig, error)

GetCommitStoreStaticConfig implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) GetExpectedNextSequenceNumber 

func (c *CommitStoreGRPCClient) GetExpectedNextSequenceNumber(ctx context.Context) (uint64, error)

GetExpectedNextSequenceNumber implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) GetLatestPriceEpochAndRound 

func (c *CommitStoreGRPCClient) GetLatestPriceEpochAndRound(ctx context.Context) (uint64, error)

GetLatestPriceEpochAndRound implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) IsBlessed 

func (c *CommitStoreGRPCClient) IsBlessed(ctx context.Context, root [32]byte) (bool, error)

IsBlessed implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) IsDestChainHealthy 

func (c *CommitStoreGRPCClient) IsDestChainHealthy(ctx context.Context) (bool, error)

IsDestChainHealthy implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) IsDown 

func (c *CommitStoreGRPCClient) IsDown(ctx context.Context) (bool, error)

IsDown implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) OffchainConfig 

func (c *CommitStoreGRPCClient) OffchainConfig(ctx context.Context) (ccip.CommitOffchainConfig, error)

OffchainConfig implements ccip.CommitStoreReader.

func (*CommitStoreGRPCClient) VerifyExecutionReport 

func (c *CommitStoreGRPCClient) VerifyExecutionReport(ctx context.Context, report ccip.ExecReport) (bool, error)

VerifyExecutionReport implements ccip.CommitStoreReader.

type CommitStoreGRPCServer 

type CommitStoreGRPCServer struct {
	ccippb.UnimplementedCommitStoreReaderServer
	// contains filtered or unexported fields
}

CommitStoreGRPCServer implements ccippb.CommitStoreReaderServer by wrapping a cciptypes.CommitStoreReader implementation. This server is hosted by the relayer and is called ReportingPlugin via the CommitStoreGRPCClient

func NewCommitStoreReaderGRPCServer 

func NewCommitStoreReaderGRPCServer(impl ccip.CommitStoreReader, brokerExt *net.BrokerExt) (*CommitStoreGRPCServer, error)

func (*CommitStoreGRPCServer) AddDep 

func (c *CommitStoreGRPCServer) AddDep(dep io.Closer) *CommitStoreGRPCServer

AddDep adds a closer to the list of dependencies that will be closed when the server is closed.

func (*CommitStoreGRPCServer) ChangeConfig 

func (c *CommitStoreGRPCServer) ChangeConfig(ctx context.Context, req *ccippb.CommitStoreChangeConfigRequest) (*ccippb.CommitStoreChangeConfigResponse, error)

ChangeConfig implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) Close 

func (c *CommitStoreGRPCServer) Close(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)

func (*CommitStoreGRPCServer) DecodeCommitReport 

func (c *CommitStoreGRPCServer) DecodeCommitReport(ctx context.Context, req *ccippb.DecodeCommitReportRequest) (*ccippb.DecodeCommitReportResponse, error)

DecodeCommitReport implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) EncodeCommitReport 

func (c *CommitStoreGRPCServer) EncodeCommitReport(ctx context.Context, req *ccippb.EncodeCommitReportRequest) (*ccippb.EncodeCommitReportResponse, error)

EncodeCommitReport implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) GetAcceptedCommitReportsGteTimestamp 

func (c *CommitStoreGRPCServer) GetAcceptedCommitReportsGteTimestamp(ctx context.Context, req *ccippb.GetAcceptedCommitReportsGteTimestampRequest) (*ccippb.GetAcceptedCommitReportsGteTimestampResponse, error)

GetAcceptedCommitReportsGteTimestamp implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) GetCommitGasPriceEstimator 

func (c *CommitStoreGRPCServer) GetCommitGasPriceEstimator(ctx context.Context, req *emptypb.Empty) (*ccippb.GetCommitGasPriceEstimatorResponse, error)

GetCommitGasPriceEstimator implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) GetCommitReportMatchingSequenceNumber 

func (c *CommitStoreGRPCServer) GetCommitReportMatchingSequenceNumber(ctx context.Context, req *ccippb.GetCommitReportMatchingSequenceNumberRequest) (*ccippb.GetCommitReportMatchingSequenceNumberResponse, error)

GeteCommitReportMatchingSequenceNumber implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) GetCommitStoreStaticConfig 

func (c *CommitStoreGRPCServer) GetCommitStoreStaticConfig(ctx context.Context, req *emptypb.Empty) (*ccippb.GetCommitStoreStaticConfigResponse, error)

GetCommitStoreStaticConfig implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) GetExpectedNextSequenceNumber 

func (c *CommitStoreGRPCServer) GetExpectedNextSequenceNumber(ctx context.Context, req *emptypb.Empty) (*ccippb.GetExpectedNextSequenceNumberResponse, error)

GetExpectedNextSequenceNumber implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) GetLatestPriceEpochAndRound 

func (c *CommitStoreGRPCServer) GetLatestPriceEpochAndRound(ctx context.Context, req *emptypb.Empty) (*ccippb.GetLatestPriceEpochAndRoundResponse, error)

GetLatestPriceEpochAndRound implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) GetOffchainConfig 

func (c *CommitStoreGRPCServer) GetOffchainConfig(ctx context.Context, req *emptypb.Empty) (*ccippb.GetOffchainConfigResponse, error)

GetOffchainConfig implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) IsBlessed 

func (c *CommitStoreGRPCServer) IsBlessed(ctx context.Context, req *ccippb.IsBlessedRequest) (*ccippb.IsBlessedResponse, error)

IsBlessed implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) IsDestChainHealthy 

func (c *CommitStoreGRPCServer) IsDestChainHealthy(ctx context.Context, req *emptypb.Empty) (*ccippb.IsDestChainHealthyResponse, error)

IsDestChainHealthy implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) IsDown 

func (c *CommitStoreGRPCServer) IsDown(ctx context.Context, req *emptypb.Empty) (*ccippb.IsDownResponse, error)

IsDown implements ccippb.CommitStoreReaderServer.

func (*CommitStoreGRPCServer) VerifyExecutionReport 

func (c *CommitStoreGRPCServer) VerifyExecutionReport(ctx context.Context, req *ccippb.VerifyExecutionReportRequest) (*ccippb.VerifyExecutionReportResponse, error)

VerifyExecutionReport implements ccippb.CommitStoreReaderServer.

type ExecGasEstimatorGRPCClient 

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

ExecGasEstimatorGRPCClient implements cciptypes.GasEstimatorExec by wrapping a ccippb.ExecGasEstimatorReaderGRPCClient grpc client. It is used by a ReportingPlugin to call the ExecGasEstimatorReader service, which is hosted by the relayer

func NewExecGasEstimatorGRPCClient 

func NewExecGasEstimatorGRPCClient(cc grpc.ClientConnInterface) *ExecGasEstimatorGRPCClient

func (*ExecGasEstimatorGRPCClient) ClientConn 

func (e *ExecGasEstimatorGRPCClient) ClientConn() grpc.ClientConnInterface

func (*ExecGasEstimatorGRPCClient) Close 

func (e *ExecGasEstimatorGRPCClient) Close() error

func (*ExecGasEstimatorGRPCClient) DenoteInUSD 

func (e *ExecGasEstimatorGRPCClient) DenoteInUSD(p *big.Int, wrappedNativePrice *big.Int) (*big.Int, error)

DenoteInUSD implements ccip.GasPriceEstimatorExec.

func (*ExecGasEstimatorGRPCClient) EstimateMsgCostUSD 

func (e *ExecGasEstimatorGRPCClient) EstimateMsgCostUSD(p *big.Int, wrappedNativePrice *big.Int, msg cciptypes.EVM2EVMOnRampCCIPSendRequestedWithMeta) (*big.Int, error)

EstimateMsgCostUSD implements ccip.GasPriceEstimatorExec.

func (*ExecGasEstimatorGRPCClient) GetGasPrice 

func (e *ExecGasEstimatorGRPCClient) GetGasPrice(ctx context.Context) (*big.Int, error)

GetGasPrice implements ccip.GasPriceEstimatorExec.

func (*ExecGasEstimatorGRPCClient) Median 

func (e *ExecGasEstimatorGRPCClient) Median(gasPrices []*big.Int) (*big.Int, error)

Median implements ccip.GasPriceEstimatorExec.

type ExecGasEstimatorGRPCServer 

type ExecGasEstimatorGRPCServer struct {
	ccippb.UnimplementedGasPriceEstimatorExecServer
	// contains filtered or unexported fields
}

ExecGasEstimatorGRPCServer implements ccippb.ExecGasEstimatorReaderServer by wrapping a cciptypes.GasEstimatorExec implementation. This server is hosted by the relayer and is called ReportingPlugin via the ExecGasEstimatorGRPCClient

func NewExecGasEstimatorGRPCServer 

func NewExecGasEstimatorGRPCServer(impl cciptypes.GasPriceEstimatorExec) *ExecGasEstimatorGRPCServer

func (*ExecGasEstimatorGRPCServer) DenoteInUSD 

func (e *ExecGasEstimatorGRPCServer) DenoteInUSD(ctx context.Context, req *ccippb.DenoteInUSDRequest) (*ccippb.DenoteInUSDResponse, error)

DenoteInUSD implements ccippb.GasPriceEstimatorExecServer.

func (*ExecGasEstimatorGRPCServer) EstimateMsgCostUSD 

func (e *ExecGasEstimatorGRPCServer) EstimateMsgCostUSD(ctx context.Context, req *ccippb.EstimateMsgCostUSDRequest) (*ccippb.EstimateMsgCostUSDResponse, error)

EstimateMsgCostUSD implements ccippb.GasPriceEstimatorExecServer.

func (*ExecGasEstimatorGRPCServer) GetGasPrice 

func (e *ExecGasEstimatorGRPCServer) GetGasPrice(ctx context.Context, req *emptypb.Empty) (*ccippb.GetGasPriceResponse, error)

GetGasPrice implements ccippb.GasPriceEstimatorExecServer.

func (*ExecGasEstimatorGRPCServer) Median 

func (e *ExecGasEstimatorGRPCServer) Median(ctx context.Context, req *ccippb.MedianRequest) (*ccippb.MedianResponse, error)

Median implements ccippb.GasPriceEstimatorExecServer.

type ExecProviderClient 

type ExecProviderClient struct {
	*ocr2.PluginProviderClient

	// must be shared with the server
	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewExecProviderClient 

func NewExecProviderClient(b *net.BrokerExt, conn grpc.ClientConnInterface) *ExecProviderClient

func (*ExecProviderClient) Close 

func (e *ExecProviderClient) Close() error

Close implements types.CCIPExecProvider.

func (*ExecProviderClient) NewCommitStoreReader 

func (e *ExecProviderClient) NewCommitStoreReader(ctx context.Context, addr cciptypes.Address) (cciptypes.CommitStoreReader, error)

NewCommitStoreReader implements types.CCIPExecProvider.

func (*ExecProviderClient) NewOffRampReader 

func (e *ExecProviderClient) NewOffRampReader(ctx context.Context, addr cciptypes.Address) (cciptypes.OffRampReader, error)

NewOffRampReader implements types.CCIPExecProvider.

func (*ExecProviderClient) NewOnRampReader 

func (e *ExecProviderClient) NewOnRampReader(ctx context.Context, addr cciptypes.Address, srcChainSelector uint64, dstChainSelector uint64) (cciptypes.OnRampReader, error)

NewOnRampReader implements types.CCIPExecProvider.

func (*ExecProviderClient) NewPriceRegistryReader 

func (e *ExecProviderClient) NewPriceRegistryReader(ctx context.Context, addr cciptypes.Address) (cciptypes.PriceRegistryReader, error)

NewPriceRegistryReader implements types.CCIPExecProvider.

func (*ExecProviderClient) NewTokenDataReader 

func (e *ExecProviderClient) NewTokenDataReader(ctx context.Context, tokenAddress cciptypes.Address) (cciptypes.TokenDataReader, error)

NewTokenDataReader implements types.CCIPExecProvider.

func (*ExecProviderClient) NewTokenPoolBatchedReader 

func (e *ExecProviderClient) NewTokenPoolBatchedReader(ctx context.Context, offRampAddress cciptypes.Address, srcChainSelector uint64) (cciptypes.TokenPoolBatchedReader, error)

NewTokenPoolBatchedReader implements types.CCIPExecProvider.

func (*ExecProviderClient) SourceNativeToken 

func (e *ExecProviderClient) SourceNativeToken(ctx context.Context, addr cciptypes.Address) (cciptypes.Address, error)

SourceNativeToken implements types.CCIPExecProvider.

type ExecProviderServer 

type ExecProviderServer struct {
	ccippb.UnimplementedExecutionCustomHandlersServer
	// BCF-3061 this has to be a shared pointer to the same impl as the execProviderClient
	*net.BrokerExt
	// contains filtered or unexported fields
}

ExecProviderServer is a server that wraps the custom methods of the types.CCIPExecProvider this is necessary because those method create new resources that need to be served by the broker when we are running in legacy mode.

func NewExecProviderServer 

func NewExecProviderServer(impl types.CCIPExecProvider, brokerExt *net.BrokerExt) *ExecProviderServer

func (*ExecProviderServer) Close 

func (e *ExecProviderServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

Close implements ccippb.ExecutionCustomHandlersServer.

func (*ExecProviderServer) NewCommitStoreReader 

func (e *ExecProviderServer) NewCommitStoreReader(ctx context.Context, req *ccippb.NewCommitStoreReaderRequest) (*ccippb.NewCommitStoreReaderResponse, error)

NewCommitStoreReader implements ccippb.ExecutionCustomHandlersServer.

func (*ExecProviderServer) NewOffRampReader 

func (e *ExecProviderServer) NewOffRampReader(ctx context.Context, req *ccippb.NewOffRampReaderRequest) (*ccippb.NewOffRampReaderResponse, error)

func (*ExecProviderServer) NewOnRampReader 

func (e *ExecProviderServer) NewOnRampReader(ctx context.Context, req *ccippb.NewOnRampReaderRequest) (*ccippb.NewOnRampReaderResponse, error)

func (*ExecProviderServer) NewPriceRegistryReader 

func (e *ExecProviderServer) NewPriceRegistryReader(ctx context.Context, req *ccippb.NewPriceRegistryReaderRequest) (*ccippb.NewPriceRegistryReaderResponse, error)

func (*ExecProviderServer) NewTokenDataReader 

func (e *ExecProviderServer) NewTokenDataReader(ctx context.Context, req *ccippb.NewTokenDataRequest) (*ccippb.NewTokenDataResponse, error)

func (*ExecProviderServer) NewTokenPoolBatchedReader 

func (e *ExecProviderServer) NewTokenPoolBatchedReader(ctx context.Context, req *ccippb.NewTokenPoolBatchedReaderRequest) (*ccippb.NewTokenPoolBatchedReaderResponse, error)

func (*ExecProviderServer) SourceNativeToken 

func (e *ExecProviderServer) SourceNativeToken(ctx context.Context, req *ccippb.SourceNativeTokenRequest) (*ccippb.SourceNativeTokenResponse, error)

type GRPCResourceCloser 

type GRPCResourceCloser interface {
	Close(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type OffRampReaderGRPCClient 

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

OffRampReaderGRPCClient implement cciptypes.OffRampReader by wrapping a grpc client connection this client will be used by the CCIP loop service to communicate with the offramp reader

func NewOffRampReaderGRPCClient 

func NewOffRampReaderGRPCClient(brokerExt *net.BrokerExt, cc grpc.ClientConnInterface) *OffRampReaderGRPCClient

NewOffRampReaderGRPCClient creates a new OffRampReaderGRPCClient. It is used by the reporting plugin to call the offramp reader service. The client is created by wrapping a grpc client connection. It requires a brokerExt to allocate and serve the gas estimator server. *must* be the same broker used by the server BCF-3061

func (*OffRampReaderGRPCClient) Address 

func (o *OffRampReaderGRPCClient) Address(ctx context.Context) (cciptypes.Address, error)

Address i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) ChangeConfig 

func (o *OffRampReaderGRPCClient) ChangeConfig(ctx context.Context, onchainConfig []byte, offchainConfig []byte) (cciptypes.Address, cciptypes.Address, error)

ChangeConfig implements github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader

func (*OffRampReaderGRPCClient) ClientConn 

func (o *OffRampReaderGRPCClient) ClientConn() grpc.ClientConnInterface

func (*OffRampReaderGRPCClient) Close 

func (o *OffRampReaderGRPCClient) Close() error

func (*OffRampReaderGRPCClient) CurrentRateLimiterState 

func (o *OffRampReaderGRPCClient) CurrentRateLimiterState(ctx context.Context) (cciptypes.TokenBucketRateLimit, error)

CurrentRateLimiterState i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) DecodeExecutionReport 

func (o *OffRampReaderGRPCClient) DecodeExecutionReport(ctx context.Context, report []byte) (cciptypes.ExecReport, error)

DecodeExecutionReport github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader

func (*OffRampReaderGRPCClient) EncodeExecutionReport 

func (o *OffRampReaderGRPCClient) EncodeExecutionReport(ctx context.Context, report cciptypes.ExecReport) ([]byte, error)

EncodeExecutionReport github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader

func (*OffRampReaderGRPCClient) GasPriceEstimator 

func (o *OffRampReaderGRPCClient) GasPriceEstimator(ctx context.Context) (cciptypes.GasPriceEstimatorExec, error)

GasPriceEstimator github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader

func (*OffRampReaderGRPCClient) GetExecutionState 

func (o *OffRampReaderGRPCClient) GetExecutionState(ctx context.Context, sequenceNumber uint64) (uint8, error)

GetExecutionState i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) GetExecutionStateChangesBetweenSeqNums 

func (o *OffRampReaderGRPCClient) GetExecutionStateChangesBetweenSeqNums(ctx context.Context, seqNumMin uint64, seqNumMax uint64, confirmations int) ([]cciptypes.ExecutionStateChangedWithTxMeta, error)

GetExecutionStateChangesBetweenSeqNums i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) GetRouter 

func (o *OffRampReaderGRPCClient) GetRouter(ctx context.Context) (cciptypes.Address, error)

GetRouter i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) GetSourceToDestTokensMapping 

func (o *OffRampReaderGRPCClient) GetSourceToDestTokensMapping(ctx context.Context) (map[cciptypes.Address]cciptypes.Address, error)

GetSourceToDestTokensMapping i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) GetStaticConfig 

func (o *OffRampReaderGRPCClient) GetStaticConfig(ctx context.Context) (cciptypes.OffRampStaticConfig, error)

GetStaticConfig i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) GetTokens 

func (o *OffRampReaderGRPCClient) GetTokens(ctx context.Context) (cciptypes.OffRampTokens, error)

GetTokens i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) ListSenderNonces 

func (o *OffRampReaderGRPCClient) ListSenderNonces(ctx context.Context, senders []cciptypes.Address) (map[cciptypes.Address]uint64, error)

GetSendersNonce i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) OffchainConfig 

func (o *OffRampReaderGRPCClient) OffchainConfig(ctx context.Context) (cciptypes.ExecOffchainConfig, error)

OffchainConfig i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

func (*OffRampReaderGRPCClient) OnchainConfig 

func (o *OffRampReaderGRPCClient) OnchainConfig(ctx context.Context) (cciptypes.ExecOnchainConfig, error)

OnchainConfig i[github.com/smartcontractkit/chainlink-common/pkg/types/ccip.OffRampReader]

type OffRampReaderGRPCServer 

type OffRampReaderGRPCServer struct {
	ccippb.UnimplementedOffRampReaderServer
	// contains filtered or unexported fields
}

OffRampReaderGRPCServer implements ccippb.OffRampReaderServer by wrapping a cciptypes.OffRampReader implementation.

func NewOffRampReaderGRPCServer 

func NewOffRampReaderGRPCServer(impl cciptypes.OffRampReader, brokerExt *net.BrokerExt) (*OffRampReaderGRPCServer, error)

NewOffRampReaderGRPCServer creates a new OffRampReaderGRPCServer. It is used by the relayer to serve the offramp reader service. The server is created by wrapping a cciptypes.OffRampReader implementation. It requires a brokerExt to allocate and serve the gas estimator server. *must* be the same broker used by the client. BCF-3061

func (*OffRampReaderGRPCServer) AddDep 

func (o *OffRampReaderGRPCServer) AddDep(dep io.Closer) *OffRampReaderGRPCServer

AddDep adds a closer to the list of dependencies that will be closed when the server is closed.

func (*OffRampReaderGRPCServer) Address 

func (o *OffRampReaderGRPCServer) Address(ctx context.Context, req *emptypb.Empty) (*ccippb.OffRampAddressResponse, error)

Address implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) ChangeConfig 

func (o *OffRampReaderGRPCServer) ChangeConfig(ctx context.Context, req *ccippb.ChangeConfigRequest) (*ccippb.ChangeConfigResponse, error)

ChangeConfig implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) Close 

func (o *OffRampReaderGRPCServer) Close(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)

Close implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) CurrentRateLimiterState 

func (o *OffRampReaderGRPCServer) CurrentRateLimiterState(ctx context.Context, req *emptypb.Empty) (*ccippb.CurrentRateLimiterStateResponse, error)

CurrentRateLimiterState implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) DecodeExecutionReport 

func (o *OffRampReaderGRPCServer) DecodeExecutionReport(ctx context.Context, req *ccippb.DecodeExecutionReportRequest) (*ccippb.DecodeExecutionReportResponse, error)

DecodeExecutionReport implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) EncodeExecutionReport 

func (o *OffRampReaderGRPCServer) EncodeExecutionReport(ctx context.Context, req *ccippb.EncodeExecutionReportRequest) (*ccippb.EncodeExecutionReportResponse, error)

EncodeExecutionReport implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) GasPriceEstimator 

func (o *OffRampReaderGRPCServer) GasPriceEstimator(ctx context.Context, req *emptypb.Empty) (*ccippb.GasPriceEstimatorResponse, error)

GasPriceEstimator implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) GetExecutionState 

func (o *OffRampReaderGRPCServer) GetExecutionState(ctx context.Context, req *ccippb.GetExecutionStateRequest) (*ccippb.GetExecutionStateResponse, error)

GetExecutionState implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) GetExecutionStateChanges 

func (o *OffRampReaderGRPCServer) GetExecutionStateChanges(ctx context.Context, req *ccippb.GetExecutionStateChangesRequest) (*ccippb.GetExecutionStateChangesResponse, error)

GetExecutionStateChanges implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) GetRouter 

func (o *OffRampReaderGRPCServer) GetRouter(ctx context.Context, req *emptypb.Empty) (*ccippb.GetRouterResponse, error)

GetRouter implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) GetSourceToDestTokensMapping 

func (o *OffRampReaderGRPCServer) GetSourceToDestTokensMapping(ctx context.Context, req *emptypb.Empty) (*ccippb.GetSourceToDestTokensMappingResponse, error)

GetSourceToDestTokensMapping implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) GetStaticConfig 

func (o *OffRampReaderGRPCServer) GetStaticConfig(ctx context.Context, req *emptypb.Empty) (*ccippb.GetStaticConfigResponse, error)

GetStaticConfig implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) GetTokens 

func (o *OffRampReaderGRPCServer) GetTokens(ctx context.Context, req *emptypb.Empty) (*ccippb.GetTokensResponse, error)

GetTokens implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) ListSenderNonces 

func (o *OffRampReaderGRPCServer) ListSenderNonces(ctx context.Context, req *ccippb.ListSenderNoncesRequest) (*ccippb.ListSenderNoncesResponse, error)

GetSendersNonce implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) OffchainConfig 

func (o *OffRampReaderGRPCServer) OffchainConfig(ctx context.Context, req *emptypb.Empty) (*ccippb.OffchainConfigResponse, error)

OffchainConfig implements ccippb.OffRampReaderServer.

func (*OffRampReaderGRPCServer) OnchainConfig 

func (o *OffRampReaderGRPCServer) OnchainConfig(ctx context.Context, req *emptypb.Empty) (*ccippb.OnchainConfigResponse, error)

OnchainConfig implements ccippb.OffRampReaderServer.

type OnRampReaderGRPCClient 

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

func NewOnRampReaderGRPCClient 

func NewOnRampReaderGRPCClient(cc grpc.ClientConnInterface) *OnRampReaderGRPCClient

func (*OnRampReaderGRPCClient) Address 

func (o *OnRampReaderGRPCClient) Address(ctx context.Context) (cciptypes.Address, error)

Address implements ccip.OnRampReader.

func (*OnRampReaderGRPCClient) ClientConn 

func (o *OnRampReaderGRPCClient) ClientConn() grpc.ClientConnInterface

func (*OnRampReaderGRPCClient) Close 

func (o *OnRampReaderGRPCClient) Close() error

func (*OnRampReaderGRPCClient) GetDynamicConfig 

func (o *OnRampReaderGRPCClient) GetDynamicConfig(ctx context.Context) (cciptypes.OnRampDynamicConfig, error)

GetDynamicConfig implements ccip.OnRampReader.

func (*OnRampReaderGRPCClient) GetSendRequestsBetweenSeqNums 

func (o *OnRampReaderGRPCClient) GetSendRequestsBetweenSeqNums(ctx context.Context, seqNumMin uint64, seqNumMax uint64, finalized bool) ([]cciptypes.EVM2EVMMessageWithTxMeta, error)

GetSendRequestsBetweenSeqNums implements ccip.OnRampReader.

func (*OnRampReaderGRPCClient) IsSourceChainHealthy 

func (o *OnRampReaderGRPCClient) IsSourceChainHealthy(ctx context.Context) (bool, error)

IsSourceChainHealthy returns true if the source chain is healthy.

func (*OnRampReaderGRPCClient) IsSourceCursed 

func (o *OnRampReaderGRPCClient) IsSourceCursed(ctx context.Context) (bool, error)

IsSourceCursed returns true if the source chain is cursed. OnRamp communicates with the underlying RMN to verify if source chain was cursed or not.

func (*OnRampReaderGRPCClient) RouterAddress 

func (o *OnRampReaderGRPCClient) RouterAddress(ctx context.Context) (cciptypes.Address, error)

RouterAddress implements ccip.OnRampReader.

func (*OnRampReaderGRPCClient) SourcePriceRegistryAddress 

func (o *OnRampReaderGRPCClient) SourcePriceRegistryAddress(ctx context.Context) (cciptypes.Address, error)

SourcePriceRegistryAddress returns the address of the current price registry configured on the onRamp.

type OnRampReaderGRPCServer 

type OnRampReaderGRPCServer struct {
	ccippb.UnimplementedOnRampReaderServer
	// contains filtered or unexported fields
}

func NewOnRampReaderGRPCServer 

func NewOnRampReaderGRPCServer(impl cciptypes.OnRampReader) *OnRampReaderGRPCServer

func (*OnRampReaderGRPCServer) AddDep 

func (o *OnRampReaderGRPCServer) AddDep(dep io.Closer) *OnRampReaderGRPCServer

AddDep adds a dependency to the server that will be closed when the server is closed.

func (*OnRampReaderGRPCServer) Address 

func (o *OnRampReaderGRPCServer) Address(ctx context.Context, _ *emptypb.Empty) (*ccippb.OnrampAddressResponse, error)

Address implements ccippb.OnRampReaderServer.

func (*OnRampReaderGRPCServer) Close 

func (o *OnRampReaderGRPCServer) Close(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)

func (*OnRampReaderGRPCServer) GetDynamicConfig 

func (o *OnRampReaderGRPCServer) GetDynamicConfig(ctx context.Context, _ *emptypb.Empty) (*ccippb.GetDynamicConfigResponse, error)

GetDynamicConfig implements ccippb.OnRampReaderServer.

func (*OnRampReaderGRPCServer) GetSendRequestsBetweenSeqNums 

func (o *OnRampReaderGRPCServer) GetSendRequestsBetweenSeqNums(ctx context.Context, req *ccippb.GetSendRequestsBetweenSeqNumsRequest) (*ccippb.GetSendRequestsBetweenSeqNumsResponse, error)

GetSendRequestsBetweenSeqNums implements ccippb.OnRampReaderServer.

func (*OnRampReaderGRPCServer) IsSourceChainHealthy 

func (o *OnRampReaderGRPCServer) IsSourceChainHealthy(ctx context.Context, _ *emptypb.Empty) (*ccippb.IsSourceChainHealthyResponse, error)

IsSourceChainHealthy implements ccippb.OnRampReaderServer.

func (*OnRampReaderGRPCServer) IsSourceCursed 

func (o *OnRampReaderGRPCServer) IsSourceCursed(ctx context.Context, _ *emptypb.Empty) (*ccippb.IsSourceCursedResponse, error)

IsSourceCursed implements ccippb.OnRampReaderServer.

func (*OnRampReaderGRPCServer) RouterAddress 

func (o *OnRampReaderGRPCServer) RouterAddress(ctx context.Context, _ *emptypb.Empty) (*ccippb.RouterAddressResponse, error)

RouterAddress implements ccippb.OnRampReaderServer.

func (*OnRampReaderGRPCServer) SourcePriceRegistryAddress 

func (o *OnRampReaderGRPCServer) SourcePriceRegistryAddress(ctx context.Context, _ *emptypb.Empty) (*ccippb.SourcePriceRegistryAddressResponse, error)

SourcePriceRegistryAddress implements ccippb.OnRampReaderServer.

type PriceGetterGRPCClient 

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

PriceGetterGRPCClient implements cciptypes.PriceGetter by wrapping a ccippb.PriceGetterGRPCClient grpc client. This client is used by a ReportingPlugin to call the PriceGetter service, which is hosted by the relayer

func NewPriceGetterGRPCClient 

func NewPriceGetterGRPCClient(cc grpc.ClientConnInterface) *PriceGetterGRPCClient

func (*PriceGetterGRPCClient) ClientConn 

func (p *PriceGetterGRPCClient) ClientConn() grpc.ClientConnInterface

func (*PriceGetterGRPCClient) Close 

func (p *PriceGetterGRPCClient) Close() error

func (*PriceGetterGRPCClient) FilterConfiguredTokens 

func (p *PriceGetterGRPCClient) FilterConfiguredTokens(ctx context.Context, tokens []cciptypes.Address) (configured []cciptypes.Address, unconfigured []cciptypes.Address, err error)

FilterConfiguredTokens implements ccip.PriceGetter.

func (*PriceGetterGRPCClient) TokenPricesUSD 

func (p *PriceGetterGRPCClient) TokenPricesUSD(ctx context.Context, tokens []cciptypes.Address) (map[cciptypes.Address]*big.Int, error)

TokenPricesUSD implements ccip.PriceGetter.

type PriceGetterGRPCServer 

type PriceGetterGRPCServer struct {
	ccippb.UnimplementedPriceGetterServer
	// contains filtered or unexported fields
}

PriceGetterGRPCServer implements ccippb.PriceGetterServer by wrapping a cciptypes.PriceGetter implementation. This server is hosted by the relayer and is called ReportingPlugin via the PriceGetterGRPCClient

func NewPriceGetterGRPCServer 

func NewPriceGetterGRPCServer(impl cciptypes.PriceGetter) *PriceGetterGRPCServer

func (*PriceGetterGRPCServer) AddDep 

func (p *PriceGetterGRPCServer) AddDep(closer io.Closer) *PriceGetterGRPCServer

func (*PriceGetterGRPCServer) Close 

func (p *PriceGetterGRPCServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*PriceGetterGRPCServer) FilterConfiguredTokens 

func (p *PriceGetterGRPCServer) FilterConfiguredTokens(ctx context.Context, req *ccippb.FilterConfiguredTokensRequest) (*ccippb.FilterConfiguredTokensResponse, error)

FilterConfiguredTokens implements ccippb.PriceGetterServer.

func (*PriceGetterGRPCServer) TokenPricesUSD 

func (p *PriceGetterGRPCServer) TokenPricesUSD(ctx context.Context, req *ccippb.TokenPricesRequest) (*ccippb.TokenPricesResponse, error)

TokenPricesUSD implements ccippb.PriceGetterServer.

type PriceRegistryGRPCClient 

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

PriceRegistryGRPCClient implements cciptypes.PriceRegistryReader by wrapping a ccippb.PriceRegistryReaderGRPCClient grpc client. It is used by a ReportingPlugin to call the PriceRegistryReader service, which is hosted by the relayer

func NewPriceRegistryGRPCClient 

func NewPriceRegistryGRPCClient(cc grpc.ClientConnInterface) *PriceRegistryGRPCClient

func (*PriceRegistryGRPCClient) Address 

func (p *PriceRegistryGRPCClient) Address(ctx context.Context) (cciptypes.Address, error)

Address implements ccip.PriceRegistryReader.

func (*PriceRegistryGRPCClient) ClientConn 

func (p *PriceRegistryGRPCClient) ClientConn() grpc.ClientConnInterface

func (*PriceRegistryGRPCClient) Close 

func (p *PriceRegistryGRPCClient) Close() error

Close implements ccip.PriceRegistryReader.

func (*PriceRegistryGRPCClient) GetAllGasPriceUpdatesCreatedAfter 

func (p *PriceRegistryGRPCClient) GetAllGasPriceUpdatesCreatedAfter(ctx context.Context, ts time.Time, confirmations int) ([]cciptypes.GasPriceUpdateWithTxMeta, error)

GetAllGasPriceUpdatesCreatedAfter implements ccip.PriceRegistryReader.

func (*PriceRegistryGRPCClient) GetFeeTokens 

func (p *PriceRegistryGRPCClient) GetFeeTokens(ctx context.Context) ([]cciptypes.Address, error)

GetFeeTokens implements ccip.PriceRegistryReader.

func (*PriceRegistryGRPCClient) GetGasPriceUpdatesCreatedAfter 

func (p *PriceRegistryGRPCClient) GetGasPriceUpdatesCreatedAfter(ctx context.Context, chainSelector uint64, ts time.Time, confirmations int) ([]cciptypes.GasPriceUpdateWithTxMeta, error)

GetGasPriceUpdatesCreatedAfter implements ccip.PriceRegistryReader.

func (*PriceRegistryGRPCClient) GetTokenPriceUpdatesCreatedAfter 

func (p *PriceRegistryGRPCClient) GetTokenPriceUpdatesCreatedAfter(ctx context.Context, ts time.Time, confirmations int) ([]cciptypes.TokenPriceUpdateWithTxMeta, error)

GetTokenPriceUpdatesCreatedAfter implements ccip.PriceRegistryReader.

func (*PriceRegistryGRPCClient) GetTokenPrices 

func (p *PriceRegistryGRPCClient) GetTokenPrices(ctx context.Context, wantedTokens []cciptypes.Address) ([]cciptypes.TokenPriceUpdate, error)

GetTokenPrices implements ccip.PriceRegistryReader.

func (*PriceRegistryGRPCClient) GetTokensDecimals 

func (p *PriceRegistryGRPCClient) GetTokensDecimals(ctx context.Context, tokenAddresses []cciptypes.Address) ([]uint8, error)

GetTokensDecimals implements ccip.PriceRegistryReader.

type PriceRegistryGRPCServer 

type PriceRegistryGRPCServer struct {
	ccippb.UnimplementedPriceRegistryReaderServer
	// contains filtered or unexported fields
}

PriceRegistryGRPCServer implements ccippb.PriceRegistryReaderServer by wrapping a cciptypes.PriceRegistryReader implementation. This server is hosted by the relayer and is called ReportingPlugin via the PriceRegistryGRPCClient

func NewPriceRegistryGRPCServer 

func NewPriceRegistryGRPCServer(impl cciptypes.PriceRegistryReader) *PriceRegistryGRPCServer

func (*PriceRegistryGRPCServer) AddDep 

func (p *PriceRegistryGRPCServer) AddDep(dep io.Closer) *PriceRegistryGRPCServer

AddDep adds a dependency to the server that will be closed when the server is closed

func (*PriceRegistryGRPCServer) Close 

func (p *PriceRegistryGRPCServer) Close(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)

Close implements ccippb.PriceRegistryReaderServer.

func (*PriceRegistryGRPCServer) GetAddress 

func (p *PriceRegistryGRPCServer) GetAddress(ctx context.Context, req *emptypb.Empty) (*ccippb.GetPriceRegistryAddressResponse, error)

GetAddress implements ccippb.PriceRegistryReaderServer.

func (*PriceRegistryGRPCServer) GetAllGasPriceUpdatesCreatedAfter 

func (p *PriceRegistryGRPCServer) GetAllGasPriceUpdatesCreatedAfter(ctx context.Context, req *ccippb.GetAllGasPriceUpdatesCreatedAfterRequest) (*ccippb.GetAllGasPriceUpdatesCreatedAfterResponse, error)

GetAllGasPriceUpdatesCreatedAfter implements ccippb.PriceRegistryReaderServer.

func (*PriceRegistryGRPCServer) GetFeeTokens 

func (p *PriceRegistryGRPCServer) GetFeeTokens(ctx context.Context, req *emptypb.Empty) (*ccippb.GetFeeTokensResponse, error)

GetFeeTokens implements ccippb.PriceRegistryReaderServer.

func (*PriceRegistryGRPCServer) GetGasPriceUpdatesCreatedAfter 

func (p *PriceRegistryGRPCServer) GetGasPriceUpdatesCreatedAfter(ctx context.Context, req *ccippb.GetGasPriceUpdatesCreatedAfterRequest) (*ccippb.GetGasPriceUpdatesCreatedAfterResponse, error)

GetGasPriceUpdatesCreatedAfter implements ccippb.PriceRegistryReaderServer.

func (*PriceRegistryGRPCServer) GetTokenPriceUpdatesCreatedAfter 

func (p *PriceRegistryGRPCServer) GetTokenPriceUpdatesCreatedAfter(ctx context.Context, req *ccippb.GetTokenPriceUpdatesCreatedAfterRequest) (*ccippb.GetTokenPriceUpdatesCreatedAfterResponse, error)

GetTokenPriceUpdatesCreatedAfter implements ccippb.PriceRegistryReaderServer.

func (*PriceRegistryGRPCServer) GetTokenPrices 

func (p *PriceRegistryGRPCServer) GetTokenPrices(ctx context.Context, req *ccippb.GetTokenPricesRequest) (*ccippb.GetTokenPricesResponse, error)

GetTokenPrices implements ccippb.PriceRegistryReaderServer.

func (*PriceRegistryGRPCServer) GetTokensDecimals 

func (p *PriceRegistryGRPCServer) GetTokensDecimals(ctx context.Context, req *ccippb.GetTokensDecimalsRequest) (*ccippb.GetTokensDecimalsResponse, error)

GetTokensDecimals implements ccippb.PriceRegistryReaderServer.

type TokenDataReaderGRPCClient 

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

TokenDataReaderGRPCClient implements cciptypes.TokenDataReaderReader by wrapping a ccippb.TokenDataReaderReaderGRPCClient grpc client. It is used by a ReportingPlugin to call theTokenDataReaderReader service, which is hosted by the relayer

func NewTokenDataReaderGRPCClient 

func NewTokenDataReaderGRPCClient(cc grpc.ClientConnInterface) *TokenDataReaderGRPCClient

func (*TokenDataReaderGRPCClient) ClientConn 

func (t *TokenDataReaderGRPCClient) ClientConn() grpc.ClientConnInterface

func (*TokenDataReaderGRPCClient) Close 

func (t *TokenDataReaderGRPCClient) Close() error

Close implements ccip.TokenDataReader.

func (*TokenDataReaderGRPCClient) ReadTokenData 

func (t *TokenDataReaderGRPCClient) ReadTokenData(ctx context.Context, msg cciptypes.EVM2EVMOnRampCCIPSendRequestedWithMeta, tokenIndex int) (tokenData []byte, err error)

ReadTokenData implements ccip.TokenDataReader.

type TokenDataReaderGRPCServer 

type TokenDataReaderGRPCServer struct {
	ccippb.UnimplementedTokenDataReaderServer
	// contains filtered or unexported fields
}

TokenDataReaderGRPCServer implements ccippb.TokenDataReaderReaderServer by wrapping a cciptypes.TokenDataReaderReader implementation. This server is hosted by the relayer and is called ReportingPlugin via the TokenDataReaderGRPCClient

func NewTokenDataReaderGRPCServer 

func NewTokenDataReaderGRPCServer(impl cciptypes.TokenDataReader) *TokenDataReaderGRPCServer

func (*TokenDataReaderGRPCServer) AddDep 

func (t *TokenDataReaderGRPCServer) AddDep(dep io.Closer) *TokenDataReaderGRPCServer

AddDep adds a dependency to the server that will be closed when the server is closed.

func (*TokenDataReaderGRPCServer) Close 

func (t *TokenDataReaderGRPCServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

Close implements ccippb.TokenDataReaderServer.

func (*TokenDataReaderGRPCServer) ReadTokenData 

func (t *TokenDataReaderGRPCServer) ReadTokenData(ctx context.Context, req *ccippb.TokenDataRequest) (*ccippb.TokenDataResponse, error)

ReadTokenData implements ccippb.TokenDataReaderServer.

type TokenPoolBatchedReaderGRPCClient 

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

func NewTokenPoolBatchedReaderGRPCClient 

func NewTokenPoolBatchedReaderGRPCClient(cc grpc.ClientConnInterface) *TokenPoolBatchedReaderGRPCClient

func (*TokenPoolBatchedReaderGRPCClient) ClientConn 

func (t *TokenPoolBatchedReaderGRPCClient) ClientConn() grpc.ClientConnInterface

func (*TokenPoolBatchedReaderGRPCClient) Close 

func (t *TokenPoolBatchedReaderGRPCClient) Close() error

Close implements ccip.TokenPoolBatchedReader.

func (*TokenPoolBatchedReaderGRPCClient) GetInboundTokenPoolRateLimits 

func (t *TokenPoolBatchedReaderGRPCClient) GetInboundTokenPoolRateLimits(ctx context.Context, tokenPoolReaders []cciptypes.Address) ([]cciptypes.TokenBucketRateLimit, error)

GetInboundTokenPoolRateLimits implements ccip.TokenPoolBatchedReader.

type TokenPoolBatchedReaderGRPCServer 

type TokenPoolBatchedReaderGRPCServer struct {
	ccippb.UnimplementedTokenPoolBatcherReaderServer
	// contains filtered or unexported fields
}

TokenPoolBatchedReaderGRPCServer implements ccippb.TokenPoolBatchedReaderServer by wrapping a cciptypes.TokenPoolBatchedReader implementation. This server is hosted by the relayer and is called ReportingPlugin via the TokenPoolBatchedReaderGRPCClient

func NewTokenPoolBatchedReaderGRPCServer 

func NewTokenPoolBatchedReaderGRPCServer(impl cciptypes.TokenPoolBatchedReader) *TokenPoolBatchedReaderGRPCServer

func (*TokenPoolBatchedReaderGRPCServer) AddDep 

func (t *TokenPoolBatchedReaderGRPCServer) AddDep(dep io.Closer) *TokenPoolBatchedReaderGRPCServer

func (*TokenPoolBatchedReaderGRPCServer) Close 

func (t *TokenPoolBatchedReaderGRPCServer) Close(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)

func (*TokenPoolBatchedReaderGRPCServer) GetInboundTokenPoolRateLimits 

func (t *TokenPoolBatchedReaderGRPCServer) GetInboundTokenPoolRateLimits(ctx context.Context, req *ccippb.GetInboundTokenPoolRateLimitsRequest) (*ccippb.GetInboundTokenPoolRateLimitsResponse, error)

GetInboundTokenPoolRateLimits implements ccippb.TokenPoolBatcherReaderServer.

Source Files

View all Source files

Directories

Path Synopsis

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.