keeper

package
v1.9.2 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2023 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ErrChainNotFound                               = whoops.Errorf("chain with chainReferenceID '%s' was not found")
	ErrChainNotActive                              = whoops.Errorf("chain with chainReferenceID '%s' is not active")
	ErrNotEnoughValidatorsForGivenChainReferenceID = whoops.String("not enough validators in the current snapshot to form a proper valset")
	ErrUnexpectedError                             = whoops.String("unexpected error")
	ErrConsensusNotAchieved                        = whoops.String("evm: consensus not achieved")
	ErrCannotAddSupportForChainThatExists          = whoops.Errorf("chain info already exists: %s")
	ErrCannotActiveSmartContractThatIsNotDeploying = whoops.String("trying to activate a smart contract that is not currently deploying")
)
View Source 
const (
	ConsensusTurnstoneMessage     = "evm-turnstone-message"
	ConsensusGetValidatorBalances = "validators-balances"
	ConsensusCollectFundEvents    = "collect-fund-events"
	SignaturePrefix               = "\x19Ethereum Signed Message:\n32"
)

Variables

View Source 
var SupportedConsensusQueues = []supportedChainInfo{
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
	{
		// contains filtered or unexported fields
	},
}

Functions

func NewMsgServerImpl 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.

Types

type Keeper 

type Keeper struct {
	ConsensusKeeper types.ConsensusKeeper
	SchedulerKeeper types.SchedulerKeeper
	Valset          types.ValsetKeeper
	// contains filtered or unexported fields
}

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey,
	memKey storetypes.StoreKey,
	ps paramtypes.Subspace,
	consensusKeeper types.ConsensusKeeper,
	valsetKeeper types.ValsetKeeper,
) *Keeper

func (Keeper) ActivateChainReferenceID 

func (k Keeper) ActivateChainReferenceID(
	ctx sdk.Context,
	chainReferenceID string,
	smartContract *types.SmartContract,
	smartContractAddr string,
	smartContractUniqueID []byte,
) (retErr error)

func (Keeper) AddSmartContractExecutionToConsensus 

func (k Keeper) AddSmartContractExecutionToConsensus(
	ctx sdk.Context,
	chainReferenceID,
	turnstoneID string,
	logicCall *types.SubmitLogicCall,
) (uint64, error)

func (Keeper) AddSupportForNewChain 

func (k Keeper) AddSupportForNewChain(
	ctx sdk.Context,
	chainReferenceID string,
	chainID uint64,
	blockHeight uint64,
	blockHashAtHeight string,
	minimumOnChainBalance *big.Int,
) error

func (Keeper) AllSmartContractsDeployments added in v0.6.0 

func (k Keeper) AllSmartContractsDeployments(ctx sdk.Context) ([]*types.SmartContractDeployment, error)

func (Keeper) ChainsInfos 

func (k Keeper) ChainsInfos(goCtx context.Context, req *types.QueryChainsInfosRequest) (*types.QueryChainsInfosResponse, error)

func (Keeper) ChangeMinOnChainBalance added in v0.8.0 

func (k Keeper) ChangeMinOnChainBalance(ctx sdk.Context, chainReferenceID string, balance *big.Int) error

func (Keeper) CheckExternalBalancesForChain added in v0.6.0 

func (k Keeper) CheckExternalBalancesForChain(ctx sdk.Context, chainReferenceID string) error

func (Keeper) CollectJobFundEvents added in v0.10.2 

func (k Keeper) CollectJobFundEvents(ctx sdk.Context) error

func (Keeper) DeleteSmartContractDeploymentByContractID added in v1.9.1 

func (k Keeper) DeleteSmartContractDeploymentByContractID(ctx sdk.Context, smartContractID uint64, chainReferenceID string)

func (Keeper) DeployNewSmartContract added in v1.7.0 

func (k Keeper) DeployNewSmartContract(goCtx context.Context, msg *types.MsgDeployNewSmartContractRequest) (*types.DeployNewSmartContractResponse, error)

func (Keeper) ExecuteJob added in v0.10.0 

func (k Keeper) ExecuteJob(ctx sdk.Context, jcfg *xchain.JobConfiguration) (uint64, error)

ExecuteJob schedules the definition and payload for execution via consensus queue

func (Keeper) GetAllChainInfos 

func (k Keeper) GetAllChainInfos(ctx sdk.Context) ([]*types.ChainInfo, error)

func (Keeper) GetChainInfo 

func (k Keeper) GetChainInfo(ctx sdk.Context, targetChainReferenceID string) (*types.ChainInfo, error)

func (Keeper) GetEthAddressByValidator added in v1.8.0 

func (k Keeper) GetEthAddressByValidator(ctx sdk.Context, validator sdk.ValAddress, chainReferenceId string) (ethAddress *gravitymoduletypes.EthAddress, found bool, err error)

func (Keeper) GetLastCompassContract added in v1.7.0 

func (k Keeper) GetLastCompassContract(ctx sdk.Context) (*types.SmartContract, error)

func (Keeper) GetParams 

func (k Keeper) GetParams(ctx sdk.Context) types.Params

GetParams get all parameters as types.Params

func (Keeper) GetRelayWeights added in v1.4.0 

func (k Keeper) GetRelayWeights(ctx sdk.Context, chainReferenceID string) (*types.RelayWeights, error)

func (Keeper) GetValidatorAddressByEthAddress added in v1.8.0 

func (k Keeper) GetValidatorAddressByEthAddress(ctx sdk.Context, ethAddr gravitymoduletypes.EthAddress, chainReferenceId string) (valAddr sdk.ValAddress, found bool, err error)

func (Keeper) GetValsetByID 

func (k Keeper) GetValsetByID(goCtx context.Context, req *types.QueryGetValsetByIDRequest) (*types.QueryGetValsetByIDResponse, error)

GetValsetByID returns the valset given chain id and valset id. if the valset id is non-pozitive then it returns the latest valset existing.

func (Keeper) HasAnySmartContractDeployment 

func (k Keeper) HasAnySmartContractDeployment(ctx sdk.Context, chainReferenceID string) (found bool)

func (Keeper) Logger 

func (k Keeper) Logger(ctx sdk.Context) liblog.Logr

func (Keeper) MissingChains added in v1.7.0 

func (k Keeper) MissingChains(ctx sdk.Context, inputChainReferenceIDs []string) ([]string, error)

MissingChains returns the chains in this keeper that aren't in the input slice

func (Keeper) ModuleName added in v0.6.0 

func (k Keeper) ModuleName() string

func (Keeper) OnSnapshotBuilt 

func (k Keeper) OnSnapshotBuilt(ctx sdk.Context, snapshot *valsettypes.Snapshot)

func (Keeper) Params 

func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) PickValidatorForMessage added in v1.4.0 

func (k Keeper) PickValidatorForMessage(ctx sdk.Context, chainReferenceID string, requirements *xchain.JobRequirements) (string, error)

func (Keeper) PreJobExecution added in v1.2.0 

func (k Keeper) PreJobExecution(ctx sdk.Context, job *schedulertypes.Job) error

func (Keeper) PublishSnapshotToAllChains added in v1.7.0 

func (k Keeper) PublishSnapshotToAllChains(ctx sdk.Context, snapshot *valsettypes.Snapshot, forcePublish bool) error

func (Keeper) PublishValsetToChain added in v1.7.0 

func (k Keeper) PublishValsetToChain(ctx sdk.Context, valset types.Valset, chain *types.ChainInfo) error

func (Keeper) QueryGetSmartContract added in v0.6.0 

func (k Keeper) QueryGetSmartContract(goCtx context.Context, req *types.QueryGetSmartContractRequest) (*types.QueryGetSmartContractResponse, error)

func (Keeper) QueryGetSmartContractDeployments added in v0.6.0 

func (k Keeper) QueryGetSmartContractDeployments(goCtx context.Context, req *types.QueryGetSmartContractDeploymentsRequest) (*types.QueryGetSmartContractDeploymentsResponse, error)

func (Keeper) RemoveSmartContractDeployment added in v0.6.0 

func (k Keeper) RemoveSmartContractDeployment(ctx context.Context, req *types.MsgRemoveSmartContractDeploymentRequest) (*types.RemoveSmartContractDeploymentResponse, error)

func (Keeper) RemoveSupportForChain 

func (k Keeper) RemoveSupportForChain(ctx sdk.Context, proposal *types.RemoveChainProposal) error

func (Keeper) SaveNewSmartContract 

func (k Keeper) SaveNewSmartContract(ctx sdk.Context, abiJSON string, bytecode []byte) (*types.SmartContract, error)

func (Keeper) SetAsCompassContract added in v1.7.0 

func (k Keeper) SetAsCompassContract(ctx sdk.Context, smartContract *types.SmartContract) error

func (Keeper) SetParams 

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams set the params

func (Keeper) SetRelayWeights added in v1.4.0 

func (k Keeper) SetRelayWeights(ctx sdk.Context, chainReferenceID string, weights *types.RelayWeights) error

func (Keeper) SetSmartContractDeploymentStatusByContractID added in v1.9.1 

func (k Keeper) SetSmartContractDeploymentStatusByContractID(ctx sdk.Context, smartContractID uint64, chainReferenceID string, status types.SmartContractDeployment_Status) error

func (Keeper) SupportedQueues 

func (k Keeper) SupportedQueues(ctx sdk.Context) ([]consensus.SupportsConsensusQueueAction, error)

func (Keeper) TryDeployingLastCompassContractToAllChains added in v1.7.0 

func (k Keeper) TryDeployingLastCompassContractToAllChains(ctx sdk.Context)

func (Keeper) VerifyJob added in v0.10.0 

func (k Keeper) VerifyJob(ctx sdk.Context, definition, payload []byte, chainReferenceID xchain.ReferenceID) error

func (Keeper) XChainReferenceIDs added in v0.10.0 

func (k Keeper) XChainReferenceIDs(ctx sdk.Context) []xchain.ReferenceID

func (Keeper) XChainType added in v0.10.0 

func (k Keeper) XChainType() xchain.Type

type MsgAssigner added in v1.4.0 

type MsgAssigner struct {
	ValsetKeeper types.ValsetKeeper
}

func (MsgAssigner) PickValidatorForMessage added in v1.4.0 

func (ma MsgAssigner) PickValidatorForMessage(ctx sdk.Context, weights *types.RelayWeights, chainID string, req *xchain.JobRequirements) (string, error)

type ValidatorInfo added in v1.4.0 

type ValidatorInfo struct {
	Fee           float64
	Uptime        float64
	SuccessRate   float64
	ExecutionTime float64
	FeatureSet    float64
}

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.