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

Sep 5, 2024

v0.5.0

Aug 19, 2024

v0.4.0

Aug 14, 2024

v0.3.1

Jul 30, 2024

v0.3.0

Jul 30, 2024

v0.2.0

Jul 23, 2024

v0.1.10

Jun 19, 2024

Changes in this version

type Keeper

+ func (k Keeper) EmitMsg(ctx sdk.Context, typ types.MsgType, msgTypeID uint64, destChainID uint64, ...) (uint64, error)

v0.1.9

Jun 14, 2024

Changes in this version

+ var File_halo_portal_keeper_portal_proto protoreflect.FileDescriptor

+ type Block struct

+ CreatedHeight uint64

+ Id uint64

+ func (*Block) Descriptor() ([]byte, []int)

+ func (*Block) ProtoMessage()

+ func (x *Block) GetCreatedHeight() uint64

+ func (x *Block) GetId() uint64

+ func (x *Block) ProtoReflect() protoreflect.Message

+ func (x *Block) Reset()

+ func (x *Block) String() string

+ type BlockCreatedHeightIndexKey struct

+ func (this BlockCreatedHeightIndexKey) WithCreatedHeight(created_height uint64) BlockCreatedHeightIndexKey

+ type BlockIdIndexKey struct

+ func (this BlockIdIndexKey) WithId(id uint64) BlockIdIndexKey

+ type BlockIndexKey interface

+ type BlockIterator struct

+ func (i BlockIterator) Value() (*Block, error)

+ type BlockPrimaryKey = BlockIdIndexKey

+ type BlockTable interface

+ Delete func(ctx context.Context, block *Block) error

+ DeleteBy func(ctx context.Context, prefixKey BlockIndexKey) error

+ DeleteRange func(ctx context.Context, from, to BlockIndexKey) error

+ Get func(ctx context.Context, id uint64) (*Block, error)

+ GetByCreatedHeight func(ctx context.Context, created_height uint64) (*Block, error)

+ Has func(ctx context.Context, id uint64) (found bool, err error)

+ HasByCreatedHeight func(ctx context.Context, created_height uint64) (found bool, err error)

+ Insert func(ctx context.Context, block *Block) error

+ InsertReturningId func(ctx context.Context, block *Block) (uint64, error)

+ LastInsertedSequence func(ctx context.Context) (uint64, error)

+ List func(ctx context.Context, prefixKey BlockIndexKey, opts ...ormlist.Option) (BlockIterator, error)

+ ListRange func(ctx context.Context, from, to BlockIndexKey, opts ...ormlist.Option) (BlockIterator, error)

+ Save func(ctx context.Context, block *Block) error

+ Update func(ctx context.Context, block *Block) error

+ func NewBlockTable(db ormtable.Schema) (BlockTable, error)

+ type Keeper struct

+ func NewKeeper(storeService store.KVStoreService) (Keeper, error)

+ func (k Keeper) Block(ctx context.Context, req *types.BlockRequest) (*types.BlockResponse, error)

+ func (k Keeper) CreateMsg(ctx sdk.Context, typ types.MsgType, msgTypeID uint64, destChainID uint64, ...) error

+ type Msg struct

+ BlockId uint64

+ DestChainId uint64

+ Id uint64

+ MsgType uint32

+ MsgTypeId uint64

+ ShardId uint64

+ StreamOffset uint64

+ func (*Msg) Descriptor() ([]byte, []int)

+ func (*Msg) ProtoMessage()

+ func (x *Msg) GetBlockId() uint64

+ func (x *Msg) GetDestChainId() uint64

+ func (x *Msg) GetId() uint64

+ func (x *Msg) GetMsgType() uint32

+ func (x *Msg) GetMsgTypeId() uint64

+ func (x *Msg) GetShardId() uint64

+ func (x *Msg) GetStreamOffset() uint64

+ func (x *Msg) ProtoReflect() protoreflect.Message

+ func (x *Msg) Reset()

+ func (x *Msg) String() string

+ type MsgBlockIdIndexKey struct

+ func (this MsgBlockIdIndexKey) WithBlockId(block_id uint64) MsgBlockIdIndexKey

+ type MsgIdIndexKey struct

+ func (this MsgIdIndexKey) WithId(id uint64) MsgIdIndexKey

+ type MsgIndexKey interface

+ type MsgIterator struct

+ func (i MsgIterator) Value() (*Msg, error)

+ type MsgPrimaryKey = MsgIdIndexKey

+ type MsgTable interface

+ Delete func(ctx context.Context, msg *Msg) error

+ DeleteBy func(ctx context.Context, prefixKey MsgIndexKey) error

+ DeleteRange func(ctx context.Context, from, to MsgIndexKey) error

+ Get func(ctx context.Context, id uint64) (*Msg, error)

+ Has func(ctx context.Context, id uint64) (found bool, err error)

+ Insert func(ctx context.Context, msg *Msg) error

+ InsertReturningId func(ctx context.Context, msg *Msg) (uint64, error)

+ LastInsertedSequence func(ctx context.Context) (uint64, error)

+ List func(ctx context.Context, prefixKey MsgIndexKey, opts ...ormlist.Option) (MsgIterator, error)

+ ListRange func(ctx context.Context, from, to MsgIndexKey, opts ...ormlist.Option) (MsgIterator, error)

+ Save func(ctx context.Context, msg *Msg) error

+ Update func(ctx context.Context, msg *Msg) error

+ func NewMsgTable(db ormtable.Schema) (MsgTable, error)

+ type Offset struct

+ DestChainId uint64

+ Id uint64

+ Offset uint64

+ ShardId uint64

+ func (*Offset) Descriptor() ([]byte, []int)

+ func (*Offset) ProtoMessage()

+ func (x *Offset) GetDestChainId() uint64

+ func (x *Offset) GetId() uint64

+ func (x *Offset) GetOffset() uint64

+ func (x *Offset) GetShardId() uint64

+ func (x *Offset) ProtoReflect() protoreflect.Message

+ func (x *Offset) Reset()

+ func (x *Offset) String() string

+ type OffsetDestChainIdShardIdIndexKey struct

+ func (this OffsetDestChainIdShardIdIndexKey) WithDestChainId(dest_chain_id uint64) OffsetDestChainIdShardIdIndexKey

+ func (this OffsetDestChainIdShardIdIndexKey) WithDestChainIdShardId(dest_chain_id uint64, shard_id uint64) OffsetDestChainIdShardIdIndexKey

+ type OffsetIdIndexKey struct

+ func (this OffsetIdIndexKey) WithId(id uint64) OffsetIdIndexKey

+ type OffsetIndexKey interface

+ type OffsetIterator struct

+ func (i OffsetIterator) Value() (*Offset, error)

+ type OffsetPrimaryKey = OffsetIdIndexKey

+ type OffsetTable interface

+ Delete func(ctx context.Context, offset *Offset) error

+ DeleteBy func(ctx context.Context, prefixKey OffsetIndexKey) error

+ DeleteRange func(ctx context.Context, from, to OffsetIndexKey) error

+ Get func(ctx context.Context, id uint64) (*Offset, error)

+ GetByDestChainIdShardId func(ctx context.Context, dest_chain_id uint64, shard_id uint64) (*Offset, error)

+ Has func(ctx context.Context, id uint64) (found bool, err error)

+ HasByDestChainIdShardId func(ctx context.Context, dest_chain_id uint64, shard_id uint64) (found bool, err error)

+ Insert func(ctx context.Context, offset *Offset) error

+ InsertReturningId func(ctx context.Context, offset *Offset) (uint64, error)

+ LastInsertedSequence func(ctx context.Context) (uint64, error)

+ List func(ctx context.Context, prefixKey OffsetIndexKey, opts ...ormlist.Option) (OffsetIterator, error)

+ ListRange func(ctx context.Context, from, to OffsetIndexKey, opts ...ormlist.Option) (OffsetIterator, error)

+ Save func(ctx context.Context, offset *Offset) error

+ Update func(ctx context.Context, offset *Offset) error

+ func NewOffsetTable(db ormtable.Schema) (OffsetTable, error)

+ type PortalStore interface

+ BlockTable func() BlockTable

+ MsgTable func() MsgTable

+ OffsetTable func() OffsetTable

+ func NewPortalStore(db ormtable.Schema) (PortalStore, error)