adapters

package
v0.0.0-...-b096497 Latest Latest
Warning

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

 Go to latest Published: May 26, 2026 License: MIT Imports: 63 Imported by: 0

Documentation

Index

Constants

View Source 
const ConfigureLanesDataStoreFamilyExtraKey = "canton.dataStore"

ConfigureLanesDataStoreFamilyExtraKey passes e.DataStore into Canton lane configure when the pinned chainlink-ccip ConfigureChainForLanesInput type does not yet expose DataStore.

Variables

View Source 
var CantonFamilySelector = [4]byte{0xdf, 0xaf, 0xaf, 0x4b}

Functions

func DefaultCantonFeeQuoterDestChainConfig 

func DefaultCantonFeeQuoterDestChainConfig() lanes.FeeQuoterDestChainConfig

func DeployCantonChainContracts 

func DeployCantonChainContracts(ctx context.Context, bundle cldf_ops.Bundle, chains cldf_chain.BlockChains, input ccipadapters.DeployChainContractsInput) (ccipadapters.DeployChainContractsOutput, error)

Types

type CantonAggregatorConfigAdapter 

type CantonAggregatorConfigAdapter struct{}

func (*CantonAggregatorConfigAdapter) GetDeployedChains 

func (a *CantonAggregatorConfigAdapter) GetDeployedChains(ds datastore.DataStore, qualifier string) []uint64

GetDeployedChains implements adapters.AggregatorConfigAdapter.

func (*CantonAggregatorConfigAdapter) ResolveDestinationVerifierAddress 

func (a *CantonAggregatorConfigAdapter) ResolveDestinationVerifierAddress(ds datastore.DataStore, chainSelector uint64, qualifier string) (string, error)

ResolveDestinationVerifierAddress implements adapters.AggregatorConfigAdapter.

For Canton we want to resolve the aggregator destination verifier address to the raw instance address of the committee verifier so that users see the raw address in the indexer's verifier results for a specific message. This appears when users send a message from X -> Canton.

func (*CantonAggregatorConfigAdapter) ResolveSourceVerifierAddress 

func (a *CantonAggregatorConfigAdapter) ResolveSourceVerifierAddress(ds datastore.DataStore, chainSelector uint64, qualifier string) (string, error)

ResolveSourceVerifierAddress implements adapters.AggregatorConfigAdapter.

For Canton we want to resolve the aggregator source verifier address to the hashed instance address of the committee verifier. This is because the CCIPMessageSentEvent onchain emits the hashed instance address, and the aggregator checks that the source verifier address it is configured with is present inside the message's CCV addresses. https://github.com/smartcontractkit/chainlink-ccv/blob/33b00afa3061efc6faca53e5cfb9658e4ad9d6e1/aggregator/pkg/quorum/evm_quorum_validator.go#L49-L51.

type CantonChainFamilyAdapter 

type CantonChainFamilyAdapter struct{}

func (*CantonChainFamilyAdapter) AddressRefToBytes 

func (a *CantonChainFamilyAdapter) AddressRefToBytes(ref datastore.AddressRef) ([]byte, error)

func (*CantonChainFamilyAdapter) ConfigureChainForLanes 

func (a *CantonChainFamilyAdapter) ConfigureChainForLanes() *cldfops.Sequence[ccipadapters.ConfigureChainForLanesInput, ccipseq.OnChainOutput, cldfchain.BlockChains]

func (*CantonChainFamilyAdapter) ConfigureCommitteeVerifierForLanes 

func (a *CantonChainFamilyAdapter) ConfigureCommitteeVerifierForLanes() *cldfops.Sequence[ccipadapters.ConfigureChainForLanesInput, ccipseq.OnChainOutput, cldfchain.BlockChains]

ConfigureCommitteeVerifierForLanes configures CommitteeVerifier lane settings only. Used by ConfigureCantonCommitteeVerifierForLanesFromTopology (Run 2).

func (*CantonChainFamilyAdapter) GetAddressBytesLength 

func (a *CantonChainFamilyAdapter) GetAddressBytesLength() uint8

GetAddressBytesLength implements adapters.ChainFamily.

func (*CantonChainFamilyAdapter) GetChainFamilySelector 

func (a *CantonChainFamilyAdapter) GetChainFamilySelector() [4]byte

GetChainFamilySelector implements adapters.ChainFamily.

func (*CantonChainFamilyAdapter) GetDefaultCommitteeVerifierRemoteChainConfig 

func (a *CantonChainFamilyAdapter) GetDefaultCommitteeVerifierRemoteChainConfig() ccipadapters.CommitteeVerifierRemoteChainDefaults

GetDefaultCommitteeVerifierRemoteChainConfig implements adapters.ChainFamily.

func (*CantonChainFamilyAdapter) GetDefaultFeeQuoterDestChainConfig 

func (a *CantonChainFamilyAdapter) GetDefaultFeeQuoterDestChainConfig() ccipadapters.FeeQuoterDestChainConfig

GetDefaultFeeQuoterDestChainConfig implements adapters.ChainFamily.

func (*CantonChainFamilyAdapter) GetDefaultFinalityConfig 

func (a *CantonChainFamilyAdapter) GetDefaultFinalityConfig() finality.Config

GetDefaultFinalityConfig implements adapters.ChainFamily.

func (*CantonChainFamilyAdapter) GetDefaultRemoteChainConfig 

func (a *CantonChainFamilyAdapter) GetDefaultRemoteChainConfig() ccipadapters.RemoteChainDefaults

GetDefaultRemoteChainConfig implements adapters.ChainFamily.

func (*CantonChainFamilyAdapter) GetFQAddress 

func (a *CantonChainFamilyAdapter) GetFQAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (*CantonChainFamilyAdapter) GetOffRampAddress 

func (a *CantonChainFamilyAdapter) GetOffRampAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (*CantonChainFamilyAdapter) GetOnRampAddress 

func (a *CantonChainFamilyAdapter) GetOnRampAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (*CantonChainFamilyAdapter) GetRouterAddress 

func (a *CantonChainFamilyAdapter) GetRouterAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (*CantonChainFamilyAdapter) GetTestRouter 

func (a *CantonChainFamilyAdapter) GetTestRouter(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (*CantonChainFamilyAdapter) ResolveExecutor 

func (a *CantonChainFamilyAdapter) ResolveExecutor(ds datastore.DataStore, chainSelector uint64, qualifier string) (string, error)

type CantonCommitteeVerifierContractAdapter 

type CantonCommitteeVerifierContractAdapter struct{}

func (CantonCommitteeVerifierContractAdapter) GetCommitteeVerifierResolver 

func (c CantonCommitteeVerifierContractAdapter) GetCommitteeVerifierResolver(ds datastore.DataStore, chainSelector uint64, qualifier string) ([]datastore.AddressRef, error)

GetCommitteeVerifierResolver implements adapters.CommitteeVerifierContractAdapter.

func (CantonCommitteeVerifierContractAdapter) ResolveCommitteeVerifierContracts 

func (c CantonCommitteeVerifierContractAdapter) ResolveCommitteeVerifierContracts(ds datastore.DataStore, chainSelector uint64, qualifier string) ([]datastore.AddressRef, error)

type CantonCommitteeVerifierOnchain 

type CantonCommitteeVerifierOnchain struct{}

func (*CantonCommitteeVerifierOnchain) ApplySignatureConfigs 

func (a *CantonCommitteeVerifierOnchain) ApplySignatureConfigs(ctx context.Context, env deployment.Environment, destChainSelector uint64, qualifier string, change adapters.SignatureConfigChange) error

ApplySignatureConfigs implements adapters.CommitteeVerifierOnchainAdapter.

func (*CantonCommitteeVerifierOnchain) ScanCommitteeStates 

func (a *CantonCommitteeVerifierOnchain) ScanCommitteeStates(ctx context.Context, env deployment.Environment, chainSelector uint64) ([]*adapters.CommitteeState, error)

ScanCommitteeStates implements adapters.CommitteeVerifierOnchainAdapter.

type CantonCurseAdapter 

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

func NewCantonCurseAdapter 

func NewCantonCurseAdapter() *CantonCurseAdapter

func (*CantonCurseAdapter) Curse 

func (c *CantonCurseAdapter) Curse() *cldf_ops.Sequence[fastcurse.CurseInput, sequences.OnChainOutput, chain.BlockChains]

Curse implements fastcurse.CurseAdapter.

func (*CantonCurseAdapter) Initialize 

func (c *CantonCurseAdapter) Initialize(e deployment.Environment, selector uint64) error

Initialize implements fastcurse.CurseAdapter.

func (*CantonCurseAdapter) IsChainConnectedToTargetChain 

func (c *CantonCurseAdapter) IsChainConnectedToTargetChain(e deployment.Environment, selector uint64, targetSel uint64) (bool, error)

IsChainConnectedToTargetChain implements fastcurse.CurseAdapter.

func (*CantonCurseAdapter) IsCurseEnabledForChain 

func (c *CantonCurseAdapter) IsCurseEnabledForChain(e deployment.Environment, selector uint64) (bool, error)

IsCurseEnabledForChain implements fastcurse.CurseAdapter.

func (*CantonCurseAdapter) IsSubjectCursedOnChain 

func (c *CantonCurseAdapter) IsSubjectCursedOnChain(e deployment.Environment, selector uint64, subject fastcurse.Subject) (bool, error)

IsSubjectCursedOnChain implements fastcurse.CurseAdapter.

func (*CantonCurseAdapter) ListConnectedChains 

func (c *CantonCurseAdapter) ListConnectedChains(e deployment.Environment, selector uint64) ([]uint64, error)

ListConnectedChains implements fastcurse.CurseAdapter. TODO: go doc comment on the interface for this method is pretty confusing. It seems to want all configured source chains for the given chain selector.

func (*CantonCurseAdapter) SubjectToSelector 

func (c *CantonCurseAdapter) SubjectToSelector(subject fastcurse.Subject) (uint64, error)

SubjectToSelector implements fastcurse.CurseAdapter.

func (*CantonCurseAdapter) Uncurse 

func (c *CantonCurseAdapter) Uncurse() *cldf_ops.Sequence[fastcurse.CurseInput, sequences.OnChainOutput, chain.BlockChains]

Uncurse implements fastcurse.CurseAdapter.

type CantonCurseSubjectAdapter 

type CantonCurseSubjectAdapter struct {
}

func NewCantonCurseSubjectAdapter 

func NewCantonCurseSubjectAdapter() *CantonCurseSubjectAdapter

func (*CantonCurseSubjectAdapter) DeriveCurseAdapterVersion 

func (c *CantonCurseSubjectAdapter) DeriveCurseAdapterVersion(e deployment.Environment, selector uint64) (*semver.Version, error)

DeriveCurseAdapterVersion implements fastcurse.CurseSubjectAdapter.

func (*CantonCurseSubjectAdapter) SelectorToSubject 

func (c *CantonCurseSubjectAdapter) SelectorToSubject(selector uint64) fastcurse.Subject

SelectorToSubject implements fastcurse.CurseSubjectAdapter.

type CantonDeployChainContractsAdapter 

type CantonDeployChainContractsAdapter struct{}

func (*CantonDeployChainContractsAdapter) DeployChainContracts 

func (c *CantonDeployChainContractsAdapter) DeployChainContracts() *cldf_ops.Sequence[ccipadapters.DeployChainContractsInput, ccipadapters.DeployChainContractsOutput, cldf_chain.BlockChains]

func (*CantonDeployChainContractsAdapter) SetContractParamsFromImportedConfig 

func (c *CantonDeployChainContractsAdapter) SetContractParamsFromImportedConfig() *cldf_ops.Sequence[ccipadapters.DeployChainConfigCreatorInput, ccipadapters.DeployContractParams, cldf_chain.BlockChains]

type CantonExecutorConfigAdapter 

type CantonExecutorConfigAdapter struct{}

func (*CantonExecutorConfigAdapter) BuildChainConfig 

func (a *CantonExecutorConfigAdapter) BuildChainConfig(ds datastore.DataStore, chainSelector uint64, qualifier string) (ccvexecutor.ChainConfiguration, error)

func (*CantonExecutorConfigAdapter) GetDeployedChains 

func (a *CantonExecutorConfigAdapter) GetDeployedChains(ds datastore.DataStore, qualifier string) []uint64

type CantonIndexerConfigAdapter 

type CantonIndexerConfigAdapter struct{}

func (*CantonIndexerConfigAdapter) ResolveVerifierAddresses 

func (a *CantonIndexerConfigAdapter) ResolveVerifierAddresses(
	ds datastore.DataStore, chainSelector uint64, qualifier string, kind ccvadapters.VerifierKind,
) ([]string, error)

type CantonLaneAdapter 

type CantonLaneAdapter struct{}

func (CantonLaneAdapter) ConfigureLaneLegAsDest 

func (c CantonLaneAdapter) ConfigureLaneLegAsDest() *cldfops.Sequence[lanes.UpdateLanesInput, seqcore.OnChainOutput, cldfchain.BlockChains]

func (CantonLaneAdapter) ConfigureLaneLegAsSource 

func (c CantonLaneAdapter) ConfigureLaneLegAsSource() *cldfops.Sequence[lanes.UpdateLanesInput, seqcore.OnChainOutput, cldfchain.BlockChains]

func (CantonLaneAdapter) DisableRemoteChain 

func (c CantonLaneAdapter) DisableRemoteChain() *cldfops.Sequence[lanes.DisableRemoteChainInput, seqcore.OnChainOutput, cldfchain.BlockChains]

func (CantonLaneAdapter) GetDefaultGasPrice 

func (c CantonLaneAdapter) GetDefaultGasPrice() *big.Int

func (CantonLaneAdapter) GetFQAddress 

func (c CantonLaneAdapter) GetFQAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (CantonLaneAdapter) GetFeeQuoterDestChainConfig 

func (c CantonLaneAdapter) GetFeeQuoterDestChainConfig() lanes.FeeQuoterDestChainConfig

func (CantonLaneAdapter) GetOffRampAddress 

func (c CantonLaneAdapter) GetOffRampAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (CantonLaneAdapter) GetOnRampAddress 

func (c CantonLaneAdapter) GetOnRampAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

func (CantonLaneAdapter) GetRouterAddress 

func (c CantonLaneAdapter) GetRouterAddress(ds datastore.DataStore, chainSelector uint64) ([]byte, error)

type CantonMCMSReader 

type CantonMCMSReader struct{}

func (*CantonMCMSReader) GetChainMetadata 

func (r *CantonMCMSReader) GetChainMetadata(
	e cldf.Environment,
	chainSelector uint64,
	input ccipmcms.Input,
) (mcms_types.ChainMetadata, error)

func (*CantonMCMSReader) GetMCMSRef 

func (r *CantonMCMSReader) GetMCMSRef(
	e cldf.Environment,
	chainSelector uint64,
	input ccipmcms.Input,
) (datastore.AddressRef, error)

func (*CantonMCMSReader) GetTimelockRef 

func (r *CantonMCMSReader) GetTimelockRef(
	e cldf.Environment,
	chainSelector uint64,
	input ccipmcms.Input,
) (datastore.AddressRef, error)

type CantonTokenAdapter 

type CantonTokenAdapter struct{}

func (CantonTokenAdapter) AddressRefToBytes 

func (c CantonTokenAdapter) AddressRefToBytes(ref datastore.AddressRef) ([]byte, error)

func (CantonTokenAdapter) ConfigureTokenForTransfersSequence 

func (c CantonTokenAdapter) ConfigureTokenForTransfersSequence() *operations.Sequence[tokenadapters.ConfigureTokenForTransfersInput, sequences.OnChainOutput, chain.BlockChains]

func (CantonTokenAdapter) DeployToken 

func (c CantonTokenAdapter) DeployToken() *operations.Sequence[tokenadapters.DeployTokenInput, sequences.OnChainOutput, chain.BlockChains]

func (CantonTokenAdapter) DeployTokenPoolForToken 

func (c CantonTokenAdapter) DeployTokenPoolForToken() *operations.Sequence[tokenadapters.DeployTokenPoolInput, sequences.OnChainOutput, chain.BlockChains]

func (CantonTokenAdapter) DeployTokenVerify 

func (c CantonTokenAdapter) DeployTokenVerify(e deployment.Environment, in tokenadapters.DeployTokenInput) error

func (CantonTokenAdapter) DeriveTokenAddress 

func (c CantonTokenAdapter) DeriveTokenAddress(e deployment.Environment, chainSelector uint64, poolRef datastore.AddressRef) ([]byte, error)

func (CantonTokenAdapter) DeriveTokenDecimals 

func (c CantonTokenAdapter) DeriveTokenDecimals(e deployment.Environment, chainSelector uint64, poolRef datastore.AddressRef, token []byte) (uint8, error)

func (CantonTokenAdapter) DeriveTokenPoolCounterpart 

func (c CantonTokenAdapter) DeriveTokenPoolCounterpart(e deployment.Environment, chainSelector uint64, tokenPool []byte, token []byte) ([]byte, error)

func (CantonTokenAdapter) ManualRegistration 

func (c CantonTokenAdapter) ManualRegistration() *operations.Sequence[tokenadapters.ManualRegistrationSequenceInput, sequences.OnChainOutput, chain.BlockChains]

func (CantonTokenAdapter) MigrateLockReleasePoolLiquiditySequence 

func (c CantonTokenAdapter) MigrateLockReleasePoolLiquiditySequence() *operations.Sequence[tokenadapters.MigrateLockReleasePoolLiquidityInput, sequences.OnChainOutput, chain.BlockChains]

func (CantonTokenAdapter) SetTokenPoolRateLimits 

func (c CantonTokenAdapter) SetTokenPoolRateLimits() *operations.Sequence[tokenadapters.TPRLRemotes, sequences.OnChainOutput, chain.BlockChains]

func (CantonTokenAdapter) UpdateAuthorities 

func (c CantonTokenAdapter) UpdateAuthorities() *operations.Sequence[tokenadapters.UpdateAuthoritiesInput, sequences.OnChainOutput, *deployment.Environment]

type CantonTransferOwnershipAdapter 

type CantonTransferOwnershipAdapter struct{}

CantonTransferOwnershipAdapter satisfies the cross-family deploy-chain-contracts timelock transfer hook. Canton CCIP contracts record mcms/ccipOwner on-ledger at deploy time (factory choices / proposal-driven deploy); they do not use the EVM Ownable2Step + timelock accept path.

func (*CantonTransferOwnershipAdapter) InitializeTimelockAddress 

func (a *CantonTransferOwnershipAdapter) InitializeTimelockAddress(_ cldf.Environment, _ mcms.Input) error

func (*CantonTransferOwnershipAdapter) SequenceAcceptOwnership 

func (a *CantonTransferOwnershipAdapter) SequenceAcceptOwnership() *cldf_ops.Sequence[ccipdeploy.TransferOwnershipPerChainInput, sequences.OnChainOutput, cldf_chain.BlockChains]

func (*CantonTransferOwnershipAdapter) SequenceTransferOwnershipViaMCMS 

func (a *CantonTransferOwnershipAdapter) SequenceTransferOwnershipViaMCMS() *cldf_ops.Sequence[ccipdeploy.TransferOwnershipPerChainInput, sequences.OnChainOutput, cldf_chain.BlockChains]

func (*CantonTransferOwnershipAdapter) ShouldAcceptOwnershipWithTransferOwnership 

func (a *CantonTransferOwnershipAdapter) ShouldAcceptOwnershipWithTransferOwnership(_ cldf.Environment, _ ccipdeploy.TransferOwnershipPerChainInput) (bool, error)

type CantonVerifierJobConfigAdapter 

type CantonVerifierJobConfigAdapter struct{}

func (*CantonVerifierJobConfigAdapter) GetSignerAddressFamily 

func (a *CantonVerifierJobConfigAdapter) GetSignerAddressFamily() string

GetSignerAddressFamily implements adapters.VerifierConfigAdapter.

func (*CantonVerifierJobConfigAdapter) ResolveVerifierContractAddresses 

func (a *CantonVerifierJobConfigAdapter) ResolveVerifierContractAddresses(
	ds datastore.DataStore,
	chainSelector uint64,
	committeeQualifier string,
	executorQualifier string,
) (*ccvadapters.VerifierContractAddresses, error)

ResolveVerifierContractAddresses implements adapters.VerifierConfigAdapter.

Source Files

View all Source files

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.