keeper

Documentation

Index

• type HasValidateBasic
• type Keeper
  • func NewKeeper(cdc codec.Codec, key storetypes.StoreKey, msgRouter types.MsgRouter, ...) Keeper
  • func (k Keeper) AllocateAddress(cctx context.Context) sdk.AccAddress
  • func (k Keeper) DeserializeRequests(bz []byte) ([]types.QueryRequest, error)
  • func (k Keeper) DeserializeTxMessages(bz []byte) ([]sdk.Msg, error)
  • func (k Keeper) ExecuteTx(origCtx sdk.Context, addr string, msgs []sdk.Msg) ([]interface{}, error)
  • func (k Keeper) Query(cctx context.Context, qm types.QueryRequest) (*types.QueryResponse, error)
  • func (k Keeper) ResolveProtoMessage(typeUrl string) (proto.Message, error)

Types

type HasValidateBasic

type HasValidateBasic interface {
	ValidateBasic() error
}

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.Codec,
	key storetypes.StoreKey,
	msgRouter types.MsgRouter,
	queryRouter types.GRPCQueryRouter,
	acctKeeper types.AccountKeeper,
) Keeper

NewKeeper creates a new dIBC Keeper instance

func (Keeper) AllocateAddress

func (k Keeper) AllocateAddress(cctx context.Context) sdk.AccAddress

AllocateAddress returns an sdk.AccAddress derived using a host module account address, sequence number, the current block app hash, and the current block data hash. The sdk.AccAddress returned is a sub-address of the host module account.

func (Keeper) DeserializeRequests

func (k Keeper) DeserializeRequests(bz []byte) ([]types.QueryRequest, error)

DeserializeRequests uses the global proto codec's proto3 JSON unmarshaller and then unpacks the Any types into actual objects.

func (Keeper) DeserializeTxMessages

func (k Keeper) DeserializeTxMessages(bz []byte) ([]sdk.Msg, error)

func (Keeper) ExecuteTx

func (k Keeper) ExecuteTx(origCtx sdk.Context, addr string, msgs []sdk.Msg) ([]interface{}, error)

func (Keeper) Query

func (k Keeper) Query(cctx context.Context, qm types.QueryRequest) (*types.QueryResponse, error)

func (Keeper) ResolveProtoMessage

func (k Keeper) ResolveProtoMessage(typeUrl string) (proto.Message, error)