Documentation ¶
Index ¶
- func NewMsgServerImpl(keeper *Keeper) types.MsgServer
- func VerifyAttestationSignatures(message []byte, attestation []byte, publicKeys []types.Attester, ...) error
- type Keeper
- func (k Keeper) Attester(c context.Context, req *types.QueryGetAttesterRequest) (*types.QueryGetAttesterResponse, error)
- func (k Keeper) Attesters(c context.Context, req *types.QueryAllAttestersRequest) (*types.QueryAllAttestersResponse, error)
- func (k Keeper) BurnMessageVersion(_ context.Context, _ *types.QueryBurnMessageVersionRequest) (*types.QueryBurnMessageVersionResponse, error)
- func (k Keeper) BurningAndMintingPaused(c context.Context, req *types.QueryGetBurningAndMintingPausedRequest) (*types.QueryGetBurningAndMintingPausedResponse, error)
- func (k Keeper) DeleteAttester(ctx context.Context, key string)
- func (k Keeper) DeletePendingOwner(ctx context.Context)
- func (k Keeper) DeleteRemoteTokenMessenger(ctx context.Context, remoteDomain uint32)
- func (k Keeper) DeleteTokenPair(ctx context.Context, remoteDomain uint32, remoteToken []byte)
- func (k Keeper) GetAllAttesters(ctx context.Context) (list []types.Attester)
- func (k Keeper) GetAllPerMessageBurnLimits(ctx context.Context) (list []types.PerMessageBurnLimit)
- func (k Keeper) GetAllTokenPairs(ctx context.Context) (list []types.TokenPair)
- func (k Keeper) GetAllUsedNonces(ctx context.Context) (list []types.Nonce)
- func (k Keeper) GetAttester(ctx context.Context, key string) (val types.Attester, found bool)
- func (k Keeper) GetAttesterManager(ctx context.Context) (attesterManager string)
- func (k Keeper) GetBurningAndMintingPaused(ctx context.Context) (val types.BurningAndMintingPaused, found bool)
- func (k Keeper) GetMaxMessageBodySize(ctx context.Context) (val types.MaxMessageBodySize, found bool)
- func (k Keeper) GetNextAvailableNonce(ctx context.Context) (val types.Nonce, found bool)
- func (k Keeper) GetOwner(ctx context.Context) (owner string)
- func (k Keeper) GetPauser(ctx context.Context) (pauser string)
- func (k Keeper) GetPendingOwner(ctx context.Context) (pendingOwner string, found bool)
- func (k Keeper) GetPerMessageBurnLimit(ctx context.Context, denom string) (val types.PerMessageBurnLimit, found bool)
- func (k Keeper) GetRemoteTokenMessenger(ctx context.Context, remoteDomain uint32) (val types.RemoteTokenMessenger, found bool)
- func (k Keeper) GetRemoteTokenMessengers(ctx context.Context) (list []types.RemoteTokenMessenger)
- func (k Keeper) GetSendingAndReceivingMessagesPaused(ctx context.Context) (val types.SendingAndReceivingMessagesPaused, found bool)
- func (k Keeper) GetSignatureThreshold(ctx context.Context) (val types.SignatureThreshold, found bool)
- func (k Keeper) GetTokenController(ctx context.Context) (tokenController string)
- func (k Keeper) GetTokenPair(ctx context.Context, remoteDomain uint32, remoteToken []byte) (val types.TokenPair, found bool)
- func (k Keeper) GetTokenPairHex(ctx context.Context, remoteDomain uint32, remoteTokenHex string) (val types.TokenPair, found bool)
- func (k Keeper) GetUsedNonce(ctx context.Context, nonce types.Nonce) (found bool)
- func (k Keeper) LocalDomain(_ context.Context, _ *types.QueryLocalDomainRequest) (*types.QueryLocalDomainResponse, error)
- func (k Keeper) LocalMessageVersion(_ context.Context, _ *types.QueryLocalMessageVersionRequest) (*types.QueryLocalMessageVersionResponse, error)
- func (k Keeper) Logger() log.Logger
- func (k Keeper) MaxMessageBodySize(c context.Context, req *types.QueryGetMaxMessageBodySizeRequest) (*types.QueryGetMaxMessageBodySizeResponse, error)
- func (k Keeper) NextAvailableNonce(c context.Context, req *types.QueryGetNextAvailableNonceRequest) (*types.QueryGetNextAvailableNonceResponse, error)
- func (k Keeper) PerMessageBurnLimit(c context.Context, req *types.QueryGetPerMessageBurnLimitRequest) (*types.QueryGetPerMessageBurnLimitResponse, error)
- func (k Keeper) PerMessageBurnLimits(c context.Context, req *types.QueryAllPerMessageBurnLimitsRequest) (*types.QueryAllPerMessageBurnLimitsResponse, error)
- func (k Keeper) RemoteTokenMessenger(c context.Context, req *types.QueryRemoteTokenMessengerRequest) (*types.QueryRemoteTokenMessengerResponse, error)
- func (k Keeper) RemoteTokenMessengers(c context.Context, req *types.QueryRemoteTokenMessengersRequest) (*types.QueryRemoteTokenMessengersResponse, error)
- func (k Keeper) ReserveAndIncrementNonce(ctx context.Context) (val types.Nonce)
- func (k Keeper) Roles(goCtx context.Context, req *types.QueryRolesRequest) (*types.QueryRolesResponse, error)
- func (k Keeper) SendingAndReceivingMessagesPaused(c context.Context, req *types.QueryGetSendingAndReceivingMessagesPausedRequest) (*types.QueryGetSendingAndReceivingMessagesPausedResponse, error)
- func (k Keeper) SetAttester(ctx context.Context, key types.Attester)
- func (k Keeper) SetAttesterManager(ctx context.Context, attesterManager string)
- func (k Keeper) SetBurningAndMintingPaused(ctx context.Context, paused types.BurningAndMintingPaused)
- func (k Keeper) SetMaxMessageBodySize(ctx context.Context, amount types.MaxMessageBodySize)
- func (k Keeper) SetNextAvailableNonce(ctx context.Context, key types.Nonce)
- func (k Keeper) SetOwner(ctx context.Context, owner string)
- func (k Keeper) SetPauser(ctx context.Context, pauser string)
- func (k Keeper) SetPendingOwner(ctx context.Context, pendingOwner string)
- func (k Keeper) SetPerMessageBurnLimit(ctx context.Context, limit types.PerMessageBurnLimit)
- func (k Keeper) SetRemoteTokenMessenger(ctx context.Context, remoteTokenMessenger types.RemoteTokenMessenger)
- func (k Keeper) SetSendingAndReceivingMessagesPaused(ctx context.Context, paused types.SendingAndReceivingMessagesPaused)
- func (k Keeper) SetSignatureThreshold(ctx context.Context, key types.SignatureThreshold)
- func (k Keeper) SetTokenController(ctx context.Context, tokenController string)
- func (k Keeper) SetTokenPair(ctx context.Context, tokenPair types.TokenPair)
- func (k Keeper) SetUsedNonce(ctx context.Context, nonce types.Nonce)
- func (k Keeper) SignatureThreshold(c context.Context, req *types.QueryGetSignatureThresholdRequest) (*types.QueryGetSignatureThresholdResponse, error)
- func (k Keeper) TokenPair(c context.Context, req *types.QueryGetTokenPairRequest) (*types.QueryGetTokenPairResponse, error)
- func (k Keeper) TokenPairs(c context.Context, req *types.QueryAllTokenPairsRequest) (*types.QueryAllTokenPairsResponse, error)
- func (k Keeper) UsedNonce(c context.Context, req *types.QueryGetUsedNonceRequest) (*types.QueryGetUsedNonceResponse, error)
- func (k Keeper) UsedNonces(c context.Context, req *types.QueryAllUsedNoncesRequest) (*types.QueryAllUsedNoncesResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMsgServerImpl ¶
NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.
func VerifyAttestationSignatures ¶
func VerifyAttestationSignatures( message []byte, attestation []byte, publicKeys []types.Attester, signatureThreshold uint32, ) error
* Rules for valid attestation: * 1. length of `_attestation` == 65 (signature length) * signatureThreshold * 2. addresses recovered from attestation must be in increasing order. * For example, if signature A is signed by address 0x1..., and signature B * is signed by address 0x2..., attestation must be passed as AB. * 3. no duplicate signers * 4. all signers must be enabled attesters
Types ¶
type Keeper ¶
type Keeper struct {
// contains filtered or unexported fields
}
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, logger log.Logger, storeService store.KVStoreService, bank types.BankKeeper, fiattokenfactory types.FiatTokenfactoryKeeper, ) *Keeper
func (Keeper) Attester ¶
func (k Keeper) Attester(c context.Context, req *types.QueryGetAttesterRequest) (*types.QueryGetAttesterResponse, error)
func (Keeper) Attesters ¶
func (k Keeper) Attesters(c context.Context, req *types.QueryAllAttestersRequest) (*types.QueryAllAttestersResponse, error)
func (Keeper) BurnMessageVersion ¶
func (k Keeper) BurnMessageVersion(_ context.Context, _ *types.QueryBurnMessageVersionRequest) (*types.QueryBurnMessageVersionResponse, error)
func (Keeper) BurningAndMintingPaused ¶
func (k Keeper) BurningAndMintingPaused(c context.Context, req *types.QueryGetBurningAndMintingPausedRequest) (*types.QueryGetBurningAndMintingPausedResponse, error)
func (Keeper) DeleteAttester ¶
DeleteAttester removes an attester
func (Keeper) DeletePendingOwner ¶
DeletePendingOwner deletes the pending owner of the CCTP module from state.
func (Keeper) DeleteRemoteTokenMessenger ¶
DeleteRemoteTokenMessenger removes a remote token messenger
func (Keeper) DeleteTokenPair ¶
DeleteTokenPair removes a token pair
func (Keeper) GetAllAttesters ¶
GetAllAttesters returns all attesters
func (Keeper) GetAllPerMessageBurnLimits ¶
func (k Keeper) GetAllPerMessageBurnLimits(ctx context.Context) (list []types.PerMessageBurnLimit)
GetAllMessageBurnLimit gets all PerMessageBurnLimits from the store
func (Keeper) GetAllTokenPairs ¶
GetAllTokenPairs returns all token pairs
func (Keeper) GetAllUsedNonces ¶
GetAllUsedNonces returns all UsedNonces
func (Keeper) GetAttester ¶
GetAttester returns an attester
func (Keeper) GetAttesterManager ¶
GetAttesterManager returns the attester manager of the CCTP module from state.
func (Keeper) GetBurningAndMintingPaused ¶
func (k Keeper) GetBurningAndMintingPaused(ctx context.Context) (val types.BurningAndMintingPaused, found bool)
GetBurningAndMintingPaused returns BurningAndMintingPaused
func (Keeper) GetMaxMessageBodySize ¶
func (k Keeper) GetMaxMessageBodySize(ctx context.Context) (val types.MaxMessageBodySize, found bool)
GetMaxMessageBodySize returns the MaxMessageBodySize
func (Keeper) GetNextAvailableNonce ¶
GetNextAvailableNonce returns the next available nonce
func (Keeper) GetPendingOwner ¶
GetPendingOwner returns the pending owner of the CCTP module from state.
func (Keeper) GetPerMessageBurnLimit ¶
func (k Keeper) GetPerMessageBurnLimit(ctx context.Context, denom string) (val types.PerMessageBurnLimit, found bool)
GetPerMessageBurnLimit returns a PerMessageBurnLimit
func (Keeper) GetRemoteTokenMessenger ¶
func (k Keeper) GetRemoteTokenMessenger(ctx context.Context, remoteDomain uint32) (val types.RemoteTokenMessenger, found bool)
GetRemoteTokenMessenger returns a remote token messenger
func (Keeper) GetRemoteTokenMessengers ¶
func (k Keeper) GetRemoteTokenMessengers(ctx context.Context) (list []types.RemoteTokenMessenger)
GetRemoteTokenMessengers returns all remote token messengers
func (Keeper) GetSendingAndReceivingMessagesPaused ¶
func (k Keeper) GetSendingAndReceivingMessagesPaused(ctx context.Context) (val types.SendingAndReceivingMessagesPaused, found bool)
GetSendingAndReceivingMessagesPaused returns SendingAndReceivingMessagesPaused
func (Keeper) GetSignatureThreshold ¶
func (k Keeper) GetSignatureThreshold(ctx context.Context) (val types.SignatureThreshold, found bool)
GetSignatureThreshold returns the SignatureThreshold
func (Keeper) GetTokenController ¶
GetTokenController returns the token controller of the CCTP module from state.
func (Keeper) GetTokenPair ¶
func (k Keeper) GetTokenPair(ctx context.Context, remoteDomain uint32, remoteToken []byte) (val types.TokenPair, found bool)
GetTokenPair returns a token pair
func (Keeper) GetTokenPairHex ¶
func (k Keeper) GetTokenPairHex(ctx context.Context, remoteDomain uint32, remoteTokenHex string) (val types.TokenPair, found bool)
GetTokenPair returns a token pair
func (Keeper) GetUsedNonce ¶
GetUsedNonce returns a nonce
func (Keeper) LocalDomain ¶
func (k Keeper) LocalDomain(_ context.Context, _ *types.QueryLocalDomainRequest) (*types.QueryLocalDomainResponse, error)
func (Keeper) LocalMessageVersion ¶
func (k Keeper) LocalMessageVersion(_ context.Context, _ *types.QueryLocalMessageVersionRequest) (*types.QueryLocalMessageVersionResponse, error)
func (Keeper) MaxMessageBodySize ¶
func (k Keeper) MaxMessageBodySize(c context.Context, req *types.QueryGetMaxMessageBodySizeRequest) (*types.QueryGetMaxMessageBodySizeResponse, error)
func (Keeper) NextAvailableNonce ¶
func (k Keeper) NextAvailableNonce(c context.Context, req *types.QueryGetNextAvailableNonceRequest) (*types.QueryGetNextAvailableNonceResponse, error)
func (Keeper) PerMessageBurnLimit ¶
func (k Keeper) PerMessageBurnLimit(c context.Context, req *types.QueryGetPerMessageBurnLimitRequest) (*types.QueryGetPerMessageBurnLimitResponse, error)
func (Keeper) PerMessageBurnLimits ¶
func (k Keeper) PerMessageBurnLimits(c context.Context, req *types.QueryAllPerMessageBurnLimitsRequest) (*types.QueryAllPerMessageBurnLimitsResponse, error)
func (Keeper) RemoteTokenMessenger ¶
func (k Keeper) RemoteTokenMessenger(c context.Context, req *types.QueryRemoteTokenMessengerRequest) (*types.QueryRemoteTokenMessengerResponse, error)
func (Keeper) RemoteTokenMessengers ¶
func (k Keeper) RemoteTokenMessengers(c context.Context, req *types.QueryRemoteTokenMessengersRequest) (*types.QueryRemoteTokenMessengersResponse, error)
func (Keeper) ReserveAndIncrementNonce ¶
func (Keeper) Roles ¶
func (k Keeper) Roles(goCtx context.Context, req *types.QueryRolesRequest) (*types.QueryRolesResponse, error)
func (Keeper) SendingAndReceivingMessagesPaused ¶
func (k Keeper) SendingAndReceivingMessagesPaused(c context.Context, req *types.QueryGetSendingAndReceivingMessagesPausedRequest) (*types.QueryGetSendingAndReceivingMessagesPausedResponse, error)
func (Keeper) SetAttester ¶
SetAttester sets an attester in the store
func (Keeper) SetAttesterManager ¶
SetAttesterManager stores the attester manager of the CCTP module in state.
func (Keeper) SetBurningAndMintingPaused ¶
func (k Keeper) SetBurningAndMintingPaused(ctx context.Context, paused types.BurningAndMintingPaused)
SetBurningAndMintingPaused set BurningAndMintingPaused in the store
func (Keeper) SetMaxMessageBodySize ¶
func (k Keeper) SetMaxMessageBodySize(ctx context.Context, amount types.MaxMessageBodySize)
SetMaxMessageBodySize sets MaxMessageBodySize in the store
func (Keeper) SetNextAvailableNonce ¶
SetNextAvailableNonce sets the next available nonce in the store
func (Keeper) SetPendingOwner ¶
SetPendingOwner stores the pending owner of the CCTP module in state.
func (Keeper) SetPerMessageBurnLimit ¶
func (k Keeper) SetPerMessageBurnLimit(ctx context.Context, limit types.PerMessageBurnLimit)
SetPerMessageBurnLimit sets a PerMessageBurnLimit in the store
func (Keeper) SetRemoteTokenMessenger ¶
func (k Keeper) SetRemoteTokenMessenger(ctx context.Context, remoteTokenMessenger types.RemoteTokenMessenger)
SetRemoteTokenMessenger sets a remote token messenger in the store
func (Keeper) SetSendingAndReceivingMessagesPaused ¶
func (k Keeper) SetSendingAndReceivingMessagesPaused(ctx context.Context, paused types.SendingAndReceivingMessagesPaused)
SetSendingAndReceivingMessagesPaused sets SendingAndReceivingMessagesPaused in the store
func (Keeper) SetSignatureThreshold ¶
func (k Keeper) SetSignatureThreshold(ctx context.Context, key types.SignatureThreshold)
SetSignatureThreshold sets a SignatureThreshold in the store
func (Keeper) SetTokenController ¶
SetTokenController stores the token controller of the CCTP module in state.
func (Keeper) SetTokenPair ¶
SetTokenPair sets a token pair in the store
func (Keeper) SetUsedNonce ¶
SetUsedNonce sets a nonce in the store
func (Keeper) SignatureThreshold ¶
func (k Keeper) SignatureThreshold(c context.Context, req *types.QueryGetSignatureThresholdRequest) (*types.QueryGetSignatureThresholdResponse, error)
func (Keeper) TokenPair ¶
func (k Keeper) TokenPair(c context.Context, req *types.QueryGetTokenPairRequest) (*types.QueryGetTokenPairResponse, error)
func (Keeper) TokenPairs ¶
func (k Keeper) TokenPairs(c context.Context, req *types.QueryAllTokenPairsRequest) (*types.QueryAllTokenPairsResponse, error)
func (Keeper) UsedNonce ¶
func (k Keeper) UsedNonce(c context.Context, req *types.QueryGetUsedNonceRequest) (*types.QueryGetUsedNonceResponse, error)
func (Keeper) UsedNonces ¶
func (k Keeper) UsedNonces(c context.Context, req *types.QueryAllUsedNoncesRequest) (*types.QueryAllUsedNoncesResponse, error)
Source Files ¶
- attestation.go
- attesters.go
- burning_and_minting_paused.go
- grpc_query.go
- grpc_query_attesters.go
- grpc_query_burn_message_version.go
- grpc_query_burning_and_minting_paused.go
- grpc_query_local_domain.go
- grpc_query_local_message_version.go
- grpc_query_max_message_body_size.go
- grpc_query_next_available_nonce.go
- grpc_query_per_message_burn_limits.go
- grpc_query_remote_token_messengers.go
- grpc_query_roles.go
- grpc_query_sending_and_receiving_messages_paused.go
- grpc_query_signature_threshold.go
- grpc_query_token_pairs.go
- grpc_query_used_nonces.go
- keeper.go
- max_message_body_size.go
- msg_server.go
- msg_server_accept_owner.go
- msg_server_add_remote_token_messenger.go
- msg_server_deposit_for_burn.go
- msg_server_deposit_for_burn_with_caller.go
- msg_server_disable_attester.go
- msg_server_enable_attester.go
- msg_server_link_token_pair.go
- msg_server_pause_burning_and_minting.go
- msg_server_pause_sending_and_receiving_messages.go
- msg_server_receive_message.go
- msg_server_remove_remote_token_messenger.go
- msg_server_replace_deposit_for_burn.go
- msg_server_replace_message.go
- msg_server_send_message.go
- msg_server_send_message_with_caller.go
- msg_server_set_max_burn_amount_per_message.go
- msg_server_unlink_token_pair.go
- msg_server_unpause_burning_and_minting.go
- msg_server_unpause_sending_and_receiving_messages.go
- msg_server_update_attester_manager.go
- msg_server_update_max_message_body_size.go
- msg_server_update_owner.go
- msg_server_update_pauser.go
- msg_server_update_signature_threshold.go
- msg_server_update_token_controller.go
- next_available_nonce.go
- per_message_burn_limits.go
- remote_token_messengers.go
- roles.go
- sending_and_receiving_messages_paused.go
- signature_threshold.go
- token_pairs.go
- used_nonces.go