Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

keeper

package

Go to main page

Versions in this module

v0

v0.6.0

May 6, 2024

Changes in this version

type Keeper

+ func (k Keeper) AppendTxToEntry(ctx sdk.Context, reqID string, encTx types.GeneralEncryptedTx) uint64

+ func (k Keeper) GetAllGenEncTxEntry(ctx sdk.Context) (list []types.GenEncTxExecutionQueue)

+ func (k Keeper) GetAllGenEncTxExecutionQueueEntry(ctx sdk.Context) (list []types.GenEncTxExecutionQueue)

+ func (k Keeper) GetAllGenEncTxReqQueueEntry(ctx sdk.Context) (list []commontypes.RequestAggrKeyshare)

+ func (k Keeper) GetAllGenEncTxSignalQueueEntry(ctx sdk.Context) (list []commontypes.GetAggrKeyshare)

+ func (k Keeper) GetEntry(ctx sdk.Context, reqID string) (val types.GenEncTxExecutionQueue, found bool)

+ func (k Keeper) GetExecutionQueueEntry(ctx sdk.Context, reqID string) (val types.GenEncTxExecutionQueue, found bool)

+ func (k Keeper) GetRequestCount(ctx sdk.Context) string

+ func (k Keeper) GetRequestQueueEntry(ctx sdk.Context, reqID string) (val commontypes.RequestAggrKeyshare, found bool)

+ func (k Keeper) GetSignalQueueEntry(ctx sdk.Context, reqID string) (val commontypes.GetAggrKeyshare, found bool)

+ func (k Keeper) IsSourceChain(ctx sdk.Context) (res bool)

+ func (k Keeper) KeyshareReq(c context.Context, req *types.QueryKeyshareRequest) (*types.QueryKeyshareResponse, error)

+ func (k Keeper) KeyshareReqAll(c context.Context, req *types.QueryAllKeyshareRequest) (*types.QueryAllKeyshareResponse, error)

+ func (k Keeper) OnAcknowledgementGetAggrKeysharePacket(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) OnAcknowledgementRequestAggrKeysharePacket(ctx sdk.Context, packet channeltypes.Packet, ...) error

+ func (k Keeper) OnRecvAggrKeyshareDataPacket(ctx sdk.Context, packet channeltypes.Packet, ...) (packetAck kstypes.AggrKeyshareDataPacketAck, err error)

+ func (k Keeper) RemoveEntry(ctx sdk.Context, reqID string)

+ func (k Keeper) RemoveExecutionQueueEntry(ctx sdk.Context, reqID string)

+ func (k Keeper) RemoveReqQueueEntry(ctx sdk.Context, reqID string)

+ func (k Keeper) RemoveSignalQueueEntry(ctx sdk.Context, reqID string)

+ func (k Keeper) SetEntry(ctx sdk.Context, val types.GenEncTxExecutionQueue)

+ func (k Keeper) SetExecutionQueueEntry(ctx sdk.Context, val types.GenEncTxExecutionQueue)

+ func (k Keeper) SetReqQueueEntry(ctx sdk.Context, val commontypes.RequestAggrKeyshare)

+ func (k Keeper) SetRequestCount(ctx sdk.Context, requestNumber uint64)

+ func (k Keeper) SetSignalQueueEntry(ctx sdk.Context, val commontypes.GetAggrKeyshare)

+ func (k Keeper) TransmitGetAggrKeysharePacket(ctx sdk.Context, packetData kstypes.GetAggrKeysharePacketData, ...) (uint64, error)

v0.5.0

Mar 26, 2024

v0.4.0

Mar 5, 2024

Changes in this version

type Keeper

+ func (k Keeper) KeyshareChannelID(ctx sdk.Context) (res string)

+ func (k Keeper) PepChannelID(ctx sdk.Context) (res string)

+ func (k Keeper) SetAllEncryptedTxExpired(ctx sdk.Context, height uint64)

+ func (k Keeper) SetEncryptedTxProcessedHeight(ctx sdk.Context, height uint64, index uint64, processedHeight uint64)

+ func (k Keeper) TransmitRequestAggrKeysharePacket(ctx sdk.Context, packetData kstypes.RequestAggrKeysharePacketData, ...) (uint64, error)

v0.3.2

Feb 9, 2024

Changes in this version

+ func NewMsgServerImpl(keeper Keeper) types.MsgServer

+ type Keeper struct

+ func NewKeeper(cdc codec.BinaryCodec, storeKey, memKey storetypes.StoreKey, ...) *Keeper

+ func (k Keeper) AppendEncryptedTx(ctx sdk.Context, encryptedTx types.EncryptedTx) uint64

+ func (k Keeper) ChannelID(ctx sdk.Context) (res string)

+ func (k Keeper) DeleteActivePubKey(ctx sdk.Context)

+ func (k Keeper) DeleteQueuedPubKey(ctx sdk.Context)

+ func (k Keeper) EncryptedTx(c context.Context, req *types.QueryGetEncryptedTxRequest) (*types.QueryGetEncryptedTxResponse, error)

+ func (k Keeper) EncryptedTxAll(c context.Context, req *types.QueryAllEncryptedTxRequest) (*types.QueryAllEncryptedTxResponse, error)

+ func (k Keeper) EncryptedTxAllFromHeight(c context.Context, req *types.QueryAllEncryptedTxFromHeightRequest) (*types.QueryAllEncryptedTxFromHeightResponse, error)

+ func (k Keeper) GetActivePubKey(ctx sdk.Context) (val types.ActivePubKey, found bool)

+ func (k Keeper) GetAggregatedKeyShare(ctx sdk.Context, height uint64) (val types.AggregatedKeyShare, found bool)

+ func (k Keeper) GetAllAggregatedKeyShare(ctx sdk.Context) (list []types.AggregatedKeyShare)

+ func (k Keeper) GetAllEncryptedArray(ctx sdk.Context) (arr []types.EncryptedTxArray)

+ func (k Keeper) GetAllPepNonce(ctx sdk.Context) (list []types.PepNonce)

+ func (k Keeper) GetEncryptedTx(ctx sdk.Context, targetHeight uint64, index uint64) (val types.EncryptedTx, found bool)

+ func (k Keeper) GetEncryptedTxAllFromHeight(ctx sdk.Context, targetHeight uint64) types.EncryptedTxArray

+ func (k Keeper) GetLastExecutedHeight(ctx sdk.Context) string

+ func (k Keeper) GetLatestHeight(ctx sdk.Context) string

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

+ func (k Keeper) GetPepNonce(ctx sdk.Context, address string) (val types.PepNonce, found bool)

+ func (k Keeper) GetQueuedPubKey(ctx sdk.Context) (val types.QueuedPubKey, found bool)

+ func (k Keeper) IncreasePepNonce(ctx sdk.Context, address string) uint64

+ func (k Keeper) LatestHeight(goCtx context.Context, req *types.QueryLatestHeightRequest) (*types.QueryLatestHeightResponse, error)

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

+ func (k Keeper) MinGasPrice(ctx sdk.Context) (res sdk.Coin)

+ func (k Keeper) OnAcknowledgementCurrentKeysPacket(ctx sdk.Context, packet channeltypes.Packet, data types.CurrentKeysPacketData, ...) error

+ func (k Keeper) OnRecvCurrentKeysPacket(ctx sdk.Context, packet channeltypes.Packet, data types.CurrentKeysPacketData) (packetAck types.CurrentKeysPacketAck, err error)

+ func (k Keeper) OnTimeoutCurrentKeysPacket(ctx sdk.Context, packet channeltypes.Packet, data types.CurrentKeysPacketData) error

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

+ func (k Keeper) PepNonce(c context.Context, req *types.QueryGetPepNonceRequest) (*types.QueryGetPepNonceResponse, error)

+ func (k Keeper) PepNonceAll(c context.Context, req *types.QueryAllPepNonceRequest) (*types.QueryAllPepNonceResponse, error)

+ func (k Keeper) PubKey(goCtx context.Context, req *types.QueryPubKeyRequest) (*types.QueryPubKeyResponse, error)

+ func (k Keeper) QueryFairyringCurrentKeys(ctx sdk.Context) error

+ func (k Keeper) RemoveAggregatedKeyShare(ctx sdk.Context, height uint64)

+ func (k Keeper) RemoveAllEncryptedTxFromHeight(ctx sdk.Context, targetHeight uint64)

+ func (k Keeper) RemoveEncryptedTx(ctx sdk.Context, targetHeight uint64, index uint64)

+ func (k Keeper) RemovePepNonce(ctx sdk.Context, address string)

+ func (k Keeper) SetActivePubKey(ctx sdk.Context, activePubKey types.ActivePubKey)

+ func (k Keeper) SetAggregatedKeyShare(ctx sdk.Context, aggregatedKeyShare types.AggregatedKeyShare)

+ func (k Keeper) SetEncryptedTx(ctx sdk.Context, height uint64, encryptedTxArr types.EncryptedTxArray)

+ func (k Keeper) SetLastExecutedHeight(ctx sdk.Context, height string)

+ func (k Keeper) SetLatestHeight(ctx sdk.Context, height string)

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

+ func (k Keeper) SetPepNonce(ctx sdk.Context, pepNonce types.PepNonce)

+ func (k Keeper) SetQueuedPubKey(ctx sdk.Context, queuedPubKey types.QueuedPubKey)

+ func (k Keeper) TransmitCurrentKeysPacket(ctx sdk.Context, packetData types.CurrentKeysPacketData, ...) error

+ func (k Keeper) TrustedAddresses(ctx sdk.Context) (res []string)

+ func (k Keeper) TrustedCounterParties(ctx sdk.Context) (res []*types.TrustedCounterParty)