keeper

Documentation

Index

• func NewLegacyQuerier(keeper Keeper, cdc *codec.LegacyAmino) sdk.Querier
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• func NewQueryServer(keeper Keeper) types.QueryServer
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, bankKeeper types.BankKeeper, ...) Keeper
  • func (k Keeper) AddPeggyToken(ctx sdk.Context, token string)
  • func (k Keeper) Exists(ctx sdk.Context, key []byte) bool
  • func (k Keeper) ExistsPeggyToken(ctx sdk.Context, token string) bool
  • func (k Keeper) GetBlacklist(ctx sdk.Context) []string
  • func (k Keeper) GetCethReceiverAccount(ctx sdk.Context) sdk.AccAddress
  • func (k Keeper) GetPeggyToken(ctx sdk.Context) types.PeggyTokens
  • func (k Keeper) IsBlacklisted(ctx sdk.Context, address string) bool
  • func (k Keeper) IsCethReceiverAccount(ctx sdk.Context, cethReceiverAccount sdk.AccAddress) bool
  • func (k Keeper) IsCethReceiverAccountSet(ctx sdk.Context) bool
  • func (k Keeper) IsPaused(ctx sdk.Context) bool
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) ProcessBurn(ctx sdk.Context, cosmosSender sdk.AccAddress, msg *types.MsgBurn) error
  • func (k Keeper) ProcessClaim(ctx sdk.Context, claim *types.EthBridgeClaim) (oracletypes.Status, error)
  • func (k Keeper) ProcessLock(ctx sdk.Context, cosmosSender sdk.AccAddress, msg *types.MsgLock) error
  • func (k Keeper) ProcessRescueCeth(ctx sdk.Context, msg *types.MsgRescueCeth) error
  • func (k Keeper) ProcessSuccessfulClaim(ctx sdk.Context, claim string) error
  • func (k Keeper) ProcessUpdateCethReceiverAccount(ctx sdk.Context, cosmosSender sdk.AccAddress, ...) error
  • func (k Keeper) ProcessUpdateWhiteListValidator(ctx sdk.Context, cosmosSender sdk.AccAddress, validator sdk.ValAddress, ...) error
  • func (k Keeper) SetBlacklist(ctx sdk.Context, msg *types.MsgSetBlacklist) error
  • func (k Keeper) SetCethReceiverAccount(ctx sdk.Context, cethReceiverAccount sdk.AccAddress)
  • func (k Keeper) SetPause(ctx sdk.Context, pause *types.Pause)

Functions

func NewLegacyQuerier

func NewLegacyQuerier(keeper Keeper, cdc *codec.LegacyAmino) sdk.Querier

NewLegacyQuerier is the module level router for state queries

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func NewQueryServer

func NewQueryServer(keeper Keeper) types.QueryServer

NewQueryServer returns an implementation of the ethbridge QueryServer interface, for the provided Keeper.

Types

type Keeper

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

Keeper maintains the link to data storage and exposes getter/setter methods for the various parts of the state machine

func NewKeeper

func NewKeeper(cdc codec.BinaryCodec, bankKeeper types.BankKeeper, oracleKeeper types.OracleKeeper, accountKeeper types.AccountKeeper, adminKeeper types.AdminKeeper, storeKey sdk.StoreKey) Keeper

NewKeeper creates new instances of the oracle Keeper

func (Keeper) AddPeggyToken

func (k Keeper) AddPeggyToken(ctx sdk.Context, token string)

AddPeggyToken add a token into peggy token list

func (Keeper) Exists

func (k Keeper) Exists(ctx sdk.Context, key []byte) bool

Exists chec if the key existed in db.

func (Keeper) ExistsPeggyToken

func (k Keeper) ExistsPeggyToken(ctx sdk.Context, token string) bool

ExistsPeggyToken return if token in peggy token list

func (Keeper) GetBlacklist

func (k Keeper) GetBlacklist(ctx sdk.Context) []string

func (Keeper) GetCethReceiverAccount

func (k Keeper) GetCethReceiverAccount(ctx sdk.Context) sdk.AccAddress

func (Keeper) GetPeggyToken

func (k Keeper) GetPeggyToken(ctx sdk.Context) types.PeggyTokens

GetPeggyToken get peggy token list

func (Keeper) IsBlacklisted

func (k Keeper) IsBlacklisted(ctx sdk.Context, address string) bool

func (Keeper) IsCethReceiverAccount

func (k Keeper) IsCethReceiverAccount(ctx sdk.Context, cethReceiverAccount sdk.AccAddress) bool

func (Keeper) IsCethReceiverAccountSet

func (k Keeper) IsCethReceiverAccountSet(ctx sdk.Context) bool

func (Keeper) IsPaused

func (k Keeper) IsPaused(ctx sdk.Context) bool

func (Keeper) Logger

func (k Keeper) Logger(ctx sdk.Context) log.Logger

Logger returns a module-specific logger.

func (Keeper) ProcessBurn

func (k Keeper) ProcessBurn(ctx sdk.Context, cosmosSender sdk.AccAddress, msg *types.MsgBurn) error

ProcessBurn processes the burn of bridged coins from the given sender

func (Keeper) ProcessClaim

func (k Keeper) ProcessClaim(ctx sdk.Context, claim *types.EthBridgeClaim) (oracletypes.Status, error)

ProcessClaim processes a new claim coming in from a validator

func (Keeper) ProcessLock

func (k Keeper) ProcessLock(ctx sdk.Context, cosmosSender sdk.AccAddress, msg *types.MsgLock) error

ProcessLock processes the lockup of cosmos coins from the given sender

func (Keeper) ProcessRescueCeth

func (k Keeper) ProcessRescueCeth(ctx sdk.Context, msg *types.MsgRescueCeth) error

ProcessRescueCeth transfer ceth from ethbridge module to an account

func (Keeper) ProcessSuccessfulClaim

func (k Keeper) ProcessSuccessfulClaim(ctx sdk.Context, claim string) error

ProcessSuccessfulClaim processes a claim that has just completed successfully with consensus

func (Keeper) ProcessUpdateCethReceiverAccount

func (k Keeper) ProcessUpdateCethReceiverAccount(ctx sdk.Context, cosmosSender sdk.AccAddress, cethReceiverAccount sdk.AccAddress) error

ProcessUpdateCethReceiverAccount processes the update whitelist validator from admin

func (Keeper) ProcessUpdateWhiteListValidator

func (k Keeper) ProcessUpdateWhiteListValidator(ctx sdk.Context, cosmosSender sdk.AccAddress, validator sdk.ValAddress, operationtype string) error

ProcessUpdateWhiteListValidator processes the update whitelist validator from admin

func (Keeper) SetBlacklist

func (k Keeper) SetBlacklist(ctx sdk.Context, msg *types.MsgSetBlacklist) error

func (Keeper) SetCethReceiverAccount

func (k Keeper) SetCethReceiverAccount(ctx sdk.Context, cethReceiverAccount sdk.AccAddress)

func (Keeper) SetPause

func (k Keeper) SetPause(ctx sdk.Context, pause *types.Pause)