Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ccipocr3

package

Go to main page

Versions in this module

v0

v0.9.6

Sep 26, 2025

v0.9.5

Sep 19, 2025

Changes in this version

type CCIPProviderClient

+ func (p *CCIPProviderClient) GetSyncRequests() map[string][]byte

+ type ChainAccessorClient struct

+ 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

v0.9.4

Sep 2, 2025

v0.9.3

Aug 21, 2025

v0.9.2

Aug 21, 2025

v0.9.1

Aug 20, 2025

Changes in this version

+ func NewCCIPProviderClient(b *net.BrokerExt, cc grpc.ClientConnInterface) types.CCIPProvider

+ func NewChainAccessorClient(broker *net.BrokerExt, cc grpc.ClientConnInterface) ccipocr3.ChainAccessor

+ 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 struct

+ func (p *CCIPProviderClient) ChainAccessor() ccipocr3.ChainAccessor

+ func (p *CCIPProviderClient) Codec() ccipocr3.Codec

+ func (p *CCIPProviderClient) ContractTransmitter() ocr3types.ContractTransmitter[[]byte]

+ type CCIPProviderServer struct

+ func (s CCIPProviderServer) ConnToProvider(conn grpc.ClientConnInterface, broker net.Broker, brokerCfg net.BrokerConfig) types.CCIPProvider