Documentation
¶
Index ¶
- func NewChainAccessorServer(impl ccipocr3.ChainAccessor) *chainAccessorServer
- func NewChainSpecificAddressCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.ChainSpecificAddressCodec
- func NewChainSpecificAddressCodecServer(impl ccipocr3.ChainSpecificAddressCodec) *chainSpecificAddressCodecServer
- func NewCommitPluginCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.CommitPluginCodec
- func NewCommitPluginCodecServer(impl ccipocr3.CommitPluginCodec) ccipocr3pb.CommitPluginCodecServer
- func NewExecutePluginCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.ExecutePluginCodec
- func NewExecutePluginCodecServer(impl ccipocr3.ExecutePluginCodec) ccipocr3pb.ExecutePluginCodecServer
- func NewSourceChainExtraDataCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.SourceChainExtraDataCodec
- func NewSourceChainExtraDataCodecServer(impl ccipocr3.SourceChainExtraDataCodec) ccipocr3pb.SourceChainExtraDataCodecServer
- func NewTokenDataEncoderClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.TokenDataEncoder
- func NewTokenDataEncoderServer(impl ccipocr3.TokenDataEncoder) ccipocr3pb.TokenDataEncoderServer
- func RegisterProviderServices(s *grpc.Server, provider types.CCIPProvider)
- type CCIPProviderClient
- type CCIPProviderServer
- type ChainAccessorClient
- func (c *ChainAccessorClient) CommitReportsGTETimestamp(ctx context.Context, ts time.Time, confidence primitives.ConfidenceLevel, ...) ([]ccipocr3.CommitPluginReportWithMeta, error)
- func (c *ChainAccessorClient) ExecutedMessages(ctx context.Context, ranges map[ccipocr3.ChainSelector][]ccipocr3.SeqNumRange, ...) (map[ccipocr3.ChainSelector][]ccipocr3.SeqNum, error)
- func (c *ChainAccessorClient) GetAllConfigsLegacy(ctx context.Context, destChainSelector ccipocr3.ChainSelector, ...) (ccipocr3.ChainConfigSnapshot, ...)
- func (c *ChainAccessorClient) GetChainFeeComponents(ctx context.Context) (ccipocr3.ChainFeeComponents, error)
- func (c *ChainAccessorClient) GetChainFeePriceUpdate(ctx context.Context, selectors []ccipocr3.ChainSelector) (map[ccipocr3.ChainSelector]ccipocr3.TimestampedUnixBig, error)
- func (c *ChainAccessorClient) GetContractAddress(contractName string) ([]byte, error)
- func (c *ChainAccessorClient) GetExpectedNextSequenceNumber(ctx context.Context, dest ccipocr3.ChainSelector) (ccipocr3.SeqNum, error)
- func (c *ChainAccessorClient) GetFeeQuoterDestChainConfig(ctx context.Context, dest ccipocr3.ChainSelector) (ccipocr3.FeeQuoterDestChainConfig, error)
- func (c *ChainAccessorClient) GetFeeQuoterTokenUpdates(ctx context.Context, tokens []ccipocr3.UnknownEncodedAddress, ...) (map[ccipocr3.UnknownEncodedAddress]ccipocr3.TimestampedUnixBig, error)
- func (c *ChainAccessorClient) GetFeedPricesUSD(ctx context.Context, tokens []ccipocr3.UnknownEncodedAddress, ...) (ccipocr3.TokenPriceMap, error)
- func (c *ChainAccessorClient) GetLatestPriceSeqNr(ctx context.Context) (ccipocr3.SeqNum, error)
- func (c *ChainAccessorClient) GetSyncRequests() map[string]ccipocr3.UnknownAddress
- func (c *ChainAccessorClient) GetTokenPriceUSD(ctx context.Context, address ccipocr3.UnknownAddress) (ccipocr3.TimestampedUnixBig, error)
- func (c *ChainAccessorClient) LatestMessageTo(ctx context.Context, dest ccipocr3.ChainSelector) (ccipocr3.SeqNum, error)
- func (c *ChainAccessorClient) MessagesByTokenID(ctx context.Context, source, dest ccipocr3.ChainSelector, ...) (map[ccipocr3.MessageTokenID]ccipocr3.Bytes, error)
- func (c *ChainAccessorClient) MsgsBetweenSeqNums(ctx context.Context, dest ccipocr3.ChainSelector, ...) ([]ccipocr3.Message, error)
- func (c *ChainAccessorClient) NextSeqNum(ctx context.Context, sources []ccipocr3.ChainSelector) (map[ccipocr3.ChainSelector]ccipocr3.SeqNum, error)
- func (c *ChainAccessorClient) Nonces(ctx context.Context, ...) (map[ccipocr3.ChainSelector]map[string]uint64, error)
- func (c *ChainAccessorClient) Sync(ctx context.Context, contractName string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewChainAccessorServer ¶
func NewChainAccessorServer(impl ccipocr3.ChainAccessor) *chainAccessorServer
func NewChainSpecificAddressCodecClient ¶
func NewChainSpecificAddressCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.ChainSpecificAddressCodec
func NewChainSpecificAddressCodecServer ¶
func NewChainSpecificAddressCodecServer(impl ccipocr3.ChainSpecificAddressCodec) *chainSpecificAddressCodecServer
func NewCommitPluginCodecClient ¶
func NewCommitPluginCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.CommitPluginCodec
func NewCommitPluginCodecServer ¶
func NewCommitPluginCodecServer(impl ccipocr3.CommitPluginCodec) ccipocr3pb.CommitPluginCodecServer
func NewExecutePluginCodecClient ¶
func NewExecutePluginCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.ExecutePluginCodec
func NewExecutePluginCodecServer ¶
func NewExecutePluginCodecServer(impl ccipocr3.ExecutePluginCodec) ccipocr3pb.ExecutePluginCodecServer
func NewSourceChainExtraDataCodecClient ¶
func NewSourceChainExtraDataCodecClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.SourceChainExtraDataCodec
func NewSourceChainExtraDataCodecServer ¶
func NewSourceChainExtraDataCodecServer(impl ccipocr3.SourceChainExtraDataCodec) ccipocr3pb.SourceChainExtraDataCodecServer
func NewTokenDataEncoderClient ¶
func NewTokenDataEncoderClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.TokenDataEncoder
func NewTokenDataEncoderServer ¶
func NewTokenDataEncoderServer(impl ccipocr3.TokenDataEncoder) ccipocr3pb.TokenDataEncoderServer
func RegisterProviderServices ¶
func RegisterProviderServices(s *grpc.Server, provider types.CCIPProvider)
Types ¶
type CCIPProviderClient ¶
type CCIPProviderClient struct {
*goplugin.ServiceClient
// contains filtered or unexported fields
}
func NewCCIPProviderClient ¶
func NewCCIPProviderClient(b *net.BrokerExt, cc grpc.ClientConnInterface) *CCIPProviderClient
func (*CCIPProviderClient) ChainAccessor ¶
func (p *CCIPProviderClient) ChainAccessor() ccipocr3.ChainAccessor
func (*CCIPProviderClient) Codec ¶
func (p *CCIPProviderClient) Codec() ccipocr3.Codec
func (*CCIPProviderClient) ContractTransmitter ¶
func (p *CCIPProviderClient) ContractTransmitter() ocr3types.ContractTransmitter[[]byte]
func (*CCIPProviderClient) GetSyncRequests ¶ added in v0.9.5
func (p *CCIPProviderClient) GetSyncRequests() map[string][]byte
type CCIPProviderServer ¶
type CCIPProviderServer struct{}
Server implementation
func (CCIPProviderServer) ConnToProvider ¶
func (s CCIPProviderServer) ConnToProvider(conn grpc.ClientConnInterface, broker net.Broker, brokerCfg net.BrokerConfig) types.CCIPProvider
type ChainAccessorClient ¶ added in v0.9.5
func NewChainAccessorClient ¶
func NewChainAccessorClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) *ChainAccessorClient
func (*ChainAccessorClient) CommitReportsGTETimestamp ¶ added in v0.9.5
func (c *ChainAccessorClient) CommitReportsGTETimestamp( ctx context.Context, ts time.Time, confidence primitives.ConfidenceLevel, limit int, ) ([]ccipocr3.CommitPluginReportWithMeta, error)
DestinationAccessor methods
func (*ChainAccessorClient) ExecutedMessages ¶ added in v0.9.5
func (c *ChainAccessorClient) ExecutedMessages( ctx context.Context, ranges map[ccipocr3.ChainSelector][]ccipocr3.SeqNumRange, confidence primitives.ConfidenceLevel, ) (map[ccipocr3.ChainSelector][]ccipocr3.SeqNum, error)
func (*ChainAccessorClient) GetAllConfigsLegacy ¶ added in v0.9.5
func (c *ChainAccessorClient) GetAllConfigsLegacy( ctx context.Context, destChainSelector ccipocr3.ChainSelector, sourceChainSelectors []ccipocr3.ChainSelector, ) (ccipocr3.ChainConfigSnapshot, map[ccipocr3.ChainSelector]ccipocr3.SourceChainConfig, error)
func (*ChainAccessorClient) GetChainFeeComponents ¶ added in v0.9.5
func (c *ChainAccessorClient) GetChainFeeComponents(ctx context.Context) (ccipocr3.ChainFeeComponents, error)
func (*ChainAccessorClient) GetChainFeePriceUpdate ¶ added in v0.9.5
func (c *ChainAccessorClient) GetChainFeePriceUpdate(ctx context.Context, selectors []ccipocr3.ChainSelector) (map[ccipocr3.ChainSelector]ccipocr3.TimestampedUnixBig, error)
func (*ChainAccessorClient) GetContractAddress ¶ added in v0.9.5
func (c *ChainAccessorClient) GetContractAddress(contractName string) ([]byte, error)
AllAccessors methods
func (*ChainAccessorClient) GetExpectedNextSequenceNumber ¶ added in v0.9.5
func (c *ChainAccessorClient) GetExpectedNextSequenceNumber(ctx context.Context, dest ccipocr3.ChainSelector) (ccipocr3.SeqNum, error)
func (*ChainAccessorClient) GetFeeQuoterDestChainConfig ¶ added in v0.9.5
func (c *ChainAccessorClient) GetFeeQuoterDestChainConfig(ctx context.Context, dest ccipocr3.ChainSelector) (ccipocr3.FeeQuoterDestChainConfig, error)
func (*ChainAccessorClient) GetFeeQuoterTokenUpdates ¶ added in v0.9.5
func (c *ChainAccessorClient) GetFeeQuoterTokenUpdates(ctx context.Context, tokens []ccipocr3.UnknownEncodedAddress, chain ccipocr3.ChainSelector) (map[ccipocr3.UnknownEncodedAddress]ccipocr3.TimestampedUnixBig, error)
func (*ChainAccessorClient) GetFeedPricesUSD ¶ added in v0.9.5
func (c *ChainAccessorClient) GetFeedPricesUSD(ctx context.Context, tokens []ccipocr3.UnknownEncodedAddress, tokenInfo map[ccipocr3.UnknownEncodedAddress]ccipocr3.TokenInfo) (ccipocr3.TokenPriceMap, error)
PriceReader methods
func (*ChainAccessorClient) GetLatestPriceSeqNr ¶ added in v0.9.5
func (*ChainAccessorClient) GetSyncRequests ¶ added in v0.9.5
func (c *ChainAccessorClient) GetSyncRequests() map[string]ccipocr3.UnknownAddress
func (*ChainAccessorClient) GetTokenPriceUSD ¶ added in v0.9.5
func (c *ChainAccessorClient) GetTokenPriceUSD(ctx context.Context, address ccipocr3.UnknownAddress) (ccipocr3.TimestampedUnixBig, error)
func (*ChainAccessorClient) LatestMessageTo ¶ added in v0.9.5
func (c *ChainAccessorClient) LatestMessageTo(ctx context.Context, dest ccipocr3.ChainSelector) (ccipocr3.SeqNum, error)
func (*ChainAccessorClient) MessagesByTokenID ¶ added in v0.9.5
func (c *ChainAccessorClient) MessagesByTokenID(ctx context.Context, source, dest ccipocr3.ChainSelector, tokens map[ccipocr3.MessageTokenID]ccipocr3.RampTokenAmount) (map[ccipocr3.MessageTokenID]ccipocr3.Bytes, error)
USDCMessageReader methods
func (*ChainAccessorClient) MsgsBetweenSeqNums ¶ added in v0.9.5
func (c *ChainAccessorClient) MsgsBetweenSeqNums(ctx context.Context, dest ccipocr3.ChainSelector, seqNumRange ccipocr3.SeqNumRange) ([]ccipocr3.Message, error)
SourceAccessor methods
func (*ChainAccessorClient) NextSeqNum ¶ added in v0.9.5
func (c *ChainAccessorClient) NextSeqNum(ctx context.Context, sources []ccipocr3.ChainSelector) (map[ccipocr3.ChainSelector]ccipocr3.SeqNum, error)
func (*ChainAccessorClient) Nonces ¶ added in v0.9.5
func (c *ChainAccessorClient) Nonces(ctx context.Context, addresses map[ccipocr3.ChainSelector][]ccipocr3.UnknownEncodedAddress) (map[ccipocr3.ChainSelector]map[string]uint64, error)
func (*ChainAccessorClient) Sync ¶ added in v0.9.5
func (c *ChainAccessorClient) Sync(ctx context.Context, contractName string, contractAddress ccipocr3.UnknownAddress) error
Click to show internal directories.
Click to hide internal directories.