types

package
v0.23.0 Latest Latest
Warning

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

 Go to latest Published: May 4, 2023 License: Apache-2.0 Imports: 45 Imported by: 13

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCreateAtomicSwap = "create_atomic_swap"
	EventTypeClaimAtomicSwap  = "claim_atomic_swap"
	EventTypeRefundAtomicSwap = "refund_atomic_swap"
	EventTypeSwapsExpired     = "swaps_expired"

	AttributeValueCategory       = ModuleName
	AttributeKeySender           = "sender"
	AttributeKeyRecipient        = "recipient"
	AttributeKeyAtomicSwapID     = "atomic_swap_id"
	AttributeKeyRandomNumberHash = "random_number_hash"
	AttributeKeyTimestamp        = "timestamp"
	AttributeKeySenderOtherChain = "sender_other_chain"
	AttributeKeyExpireHeight     = "expire_height"
	AttributeKeyAmount           = "amount"
	AttributeKeyDirection        = "direction"
	AttributeKeyClaimSender      = "claim_sender"
	AttributeKeyRandomNumber     = "random_number"
	AttributeKeyRefundSender     = "refund_sender"
	AttributeKeyAtomicSwapIDs    = "atomic_swap_ids"
	AttributeExpirationBlock     = "expiration_block"
)

Events for bep3 module

View Source 
const (
	// ModuleName is the name of the module
	ModuleName = "bep3"

	// StoreKey to be used when creating the KVStore
	StoreKey = ModuleName

	// RouterKey to be used for routing msgs
	RouterKey = ModuleName

	// QuerierRoute is the querier route for bep3
	QuerierRoute = ModuleName

	// DefaultParamspace default namestore
	DefaultParamspace = ModuleName

	// DefaultLongtermStorageDuration is 1 week (assuming a block time of 7 seconds)
	DefaultLongtermStorageDuration uint64 = 86400
)
View Source 
const (
	CreateAtomicSwap = "createAtomicSwap"
	ClaimAtomicSwap  = "claimAtomicSwap"
	RefundAtomicSwap = "refundAtomicSwap"
	CalcSwapID       = "calcSwapID"

	Int64Size               = 8
	RandomNumberHashLength  = 32
	RandomNumberLength      = 32
	MaxOtherChainAddrLength = 64
	SwapIDLength            = 32
	MaxExpectedIncomeLength = 64
)
View Source 
const (
	// QueryGetAssetSupply command for getting info about an asset's supply
	QueryGetAssetSupply = "supply"
	// QueryGetAssetSupplies command for getting a list of asset supplies
	QueryGetAssetSupplies = "supplies"
	// QueryGetAtomicSwap command for getting info about an atomic swap
	QueryGetAtomicSwap = "swap"
	// QueryGetAtomicSwaps command for getting a list of atomic swaps
	QueryGetAtomicSwaps = "swaps"
	// QueryGetParams command for getting module params
	QueryGetParams = "parameters"
)

Variables

View Source 
var (
	ErrInvalidLengthBep3        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBep3          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBep3 = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// ErrInvalidTimestamp error for when an timestamp is outside of bounds. Assumes block time of 10 seconds.
	ErrInvalidTimestamp = errorsmod.Register(ModuleName, 2, "timestamp can neither be 15 minutes ahead of the current time, nor 30 minutes later")
	// ErrInvalidHeightSpan error for when a proposed height span is outside of lock time range
	ErrInvalidHeightSpan = errorsmod.Register(ModuleName, 3, "height span is outside acceptable range")
	// ErrInsufficientAmount error for when a swap's amount cannot cover the deputy's fixed fee
	ErrInsufficientAmount = errorsmod.Register(ModuleName, 4, "amount cannot cover the deputy fixed fee")
	// ErrAssetNotSupported error for when an asset is not supported
	ErrAssetNotSupported = errorsmod.Register(ModuleName, 5, "asset not found")
	// ErrAssetNotActive error for when an asset is currently inactive
	ErrAssetNotActive = errorsmod.Register(ModuleName, 6, "asset is currently inactive")
	// ErrAssetSupplyNotFound error for when an asset's supply is not found in the store
	ErrAssetSupplyNotFound = errorsmod.Register(ModuleName, 7, "asset supply not found in store")
	// ErrExceedsSupplyLimit error for when the proposed supply increase would put the supply above limit
	ErrExceedsSupplyLimit = errorsmod.Register(ModuleName, 8, "asset supply over limit")
	// ErrExceedsAvailableSupply error for when the proposed outgoing amount exceeds the total available supply
	ErrExceedsAvailableSupply = errorsmod.Register(ModuleName, 9, "outgoing swap exceeds total available supply")
	// ErrInvalidCurrentSupply error for when the proposed decrease would result in a negative current supplyx
	ErrInvalidCurrentSupply = errorsmod.Register(ModuleName, 10, "supply decrease puts current asset supply below 0")
	// ErrInvalidIncomingSupply error for when the proposed decrease would result in a negative incoming supply
	ErrInvalidIncomingSupply = errorsmod.Register(ModuleName, 11, "supply decrease puts incoming asset supply below 0")
	// ErrInvalidOutgoingSupply error for when the proposed decrease would result in a negative outgoing supply
	ErrInvalidOutgoingSupply = errorsmod.Register(ModuleName, 12, "supply decrease puts outgoing asset supply below 0")
	// ErrInvalidClaimSecret error when a submitted secret doesn't match an AtomicSwap's swapID
	ErrInvalidClaimSecret = errorsmod.Register(ModuleName, 13, "hashed claim attempt does not match")
	// ErrAtomicSwapAlreadyExists error for when an AtomicSwap with this swapID already exists
	ErrAtomicSwapAlreadyExists = errorsmod.Register(ModuleName, 14, "atomic swap already exists")
	// ErrAtomicSwapNotFound error for when an atomic swap is not found
	ErrAtomicSwapNotFound = errorsmod.Register(ModuleName, 15, "atomic swap not found")
	// ErrSwapNotRefundable error for when an AtomicSwap has not expired and cannot be refunded
	ErrSwapNotRefundable = errorsmod.Register(ModuleName, 16, "atomic swap is still active and cannot be refunded")
	// ErrSwapNotClaimable error for when an atomic swap is not open and cannot be claimed
	ErrSwapNotClaimable = errorsmod.Register(ModuleName, 17, "atomic swap is not claimable")
	// ErrInvalidAmount error for when a swap's amount is outside acceptable range
	ErrInvalidAmount = errorsmod.Register(ModuleName, 18, "amount is outside acceptable range")
	// ErrInvalidSwapAccount error for when a swap involves an invalid account
	ErrInvalidSwapAccount = errorsmod.Register(ModuleName, 19, "atomic swap has invalid account")
	// ErrExceedsTimeBasedSupplyLimit error for when the proposed supply increase would put the supply above limit for the current time period
	ErrExceedsTimeBasedSupplyLimit = errorsmod.Register(ModuleName, 20, "asset supply over limit for current time period")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	AtomicSwapKeyPrefix             = []byte{0x00} // prefix for keys that store AtomicSwaps
	AtomicSwapByBlockPrefix         = []byte{0x01} // prefix for keys of the AtomicSwapsByBlock index
	AtomicSwapLongtermStoragePrefix = []byte{0x02} // prefix for keys of the AtomicSwapLongtermStorage index
	AssetSupplyPrefix               = []byte{0x03}
	PreviousBlockTimeKey            = []byte{0x04}
)

Key prefixes

View Source 
var (
	KeyAssetParams = []byte("AssetParams")

	DefaultBnbDeputyFixedFee sdkmath.Int = sdkmath.NewInt(1000) // 0.00001 BNB
	DefaultMinAmount         sdkmath.Int = sdk.ZeroInt()
	DefaultMaxAmount         sdkmath.Int = sdkmath.NewInt(1000000000000) // 10,000 BNB
	DefaultMinBlockLock      uint64      = 220
	DefaultMaxBlockLock      uint64      = 270
	DefaultPreviousBlockTime             = tmtime.Canonical(time.Unix(1, 0))
)

Parameter keys

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	AtomicSwapCoinsAccAddr = sdk.AccAddress(crypto.AddressHash([]byte("KavaAtomicSwapCoins")))
)

ensure Msg interface compliance at compile time

View Source 
var (

	// ModuleCdc references the global x/bep3 module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/bep3 and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var SwapDirection_name = map[int32]string{
	0: "SWAP_DIRECTION_UNSPECIFIED",
	1: "SWAP_DIRECTION_INCOMING",
	2: "SWAP_DIRECTION_OUTGOING",
}
View Source 
var SwapDirection_value = map[string]int32{
	"SWAP_DIRECTION_UNSPECIFIED": 0,
	"SWAP_DIRECTION_INCOMING":    1,
	"SWAP_DIRECTION_OUTGOING":    2,
}
View Source 
var SwapStatus_name = map[int32]string{
	0: "SWAP_STATUS_UNSPECIFIED",
	1: "SWAP_STATUS_OPEN",
	2: "SWAP_STATUS_COMPLETED",
	3: "SWAP_STATUS_EXPIRED",
}
View Source 
var SwapStatus_value = map[string]int32{
	"SWAP_STATUS_UNSPECIFIED": 0,
	"SWAP_STATUS_OPEN":        1,
	"SWAP_STATUS_COMPLETED":   2,
	"SWAP_STATUS_EXPIRED":     3,
}

Functions

func CalculateRandomHash 

func CalculateRandomHash(randomNumber []byte, timestamp int64) []byte

CalculateRandomHash calculates the hash of a number and timestamp

func CalculateSwapID 

func CalculateSwapID(randomNumberHash []byte, sender sdk.AccAddress, senderOtherChain string) []byte

CalculateSwapID calculates the hash of a RandomNumberHash, sdk.AccAddress, and string

func GenerateSecureRandomNumber 

func GenerateSecureRandomNumber() ([]byte, error)

GenerateSecureRandomNumber generates cryptographically strong pseudo-random number

func GetAtomicSwapByHeightKey 

func GetAtomicSwapByHeightKey(height uint64, swapID []byte) []byte

GetAtomicSwapByHeightKey is used by the AtomicSwapByBlock index and AtomicSwapLongtermStorage index

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable Key declaration for parameters

func RegisterInterfaces added in v0.16.0 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec added in v0.16.0 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers all the necessary types and interfaces for the bep3 module.

func RegisterMsgServer added in v0.16.0 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler added in v0.16.0 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient added in v0.16.0 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint added in v0.16.0 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer added in v0.16.0 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer added in v0.16.0 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper added in v0.8.0 

type AccountKeeper interface {
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI
	GetModuleAddressAndPermissions(moduleName string) (sdk.AccAddress, []string)
	SetModuleAccount(ctx sdk.Context, macc authtypes.ModuleAccountI)

	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	NewAccountWithAddress(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	SetAccount(ctx sdk.Context, acc authtypes.AccountI)
}

AccountKeeper defines the expected account keeper

type AssetParam 

type AssetParam struct {
	// denom represents the denominatin for this asset
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// coin_id represents the registered coin type to use (https://github.com/satoshilabs/slips/blob/master/slip-0044.md)
	CoinID int64 `protobuf:"varint,2,opt,name=coin_id,json=coinId,proto3" json:"coin_id,omitempty"`
	// supply_limit defines the maximum supply allowed for the asset - a total or time based rate limit
	SupplyLimit SupplyLimit `protobuf:"bytes,3,opt,name=supply_limit,json=supplyLimit,proto3" json:"supply_limit"`
	// active specifies if the asset is live or paused
	Active bool `protobuf:"varint,4,opt,name=active,proto3" json:"active,omitempty"`
	// deputy_address the kava address of the deputy
	DeputyAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 155-byte string literal not displayed */
	// fixed_fee defines the fee for incoming swaps
	FixedFee github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,6,opt,name=fixed_fee,json=fixedFee,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"fixed_fee"`
	// min_swap_amount defines the minimum amount able to be swapped in a single message
	MinSwapAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 142-byte string literal not displayed */
	// max_swap_amount defines the maximum amount able to be swapped in a single message
	MaxSwapAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 142-byte string literal not displayed */
	// min_block_lock defined the minimum blocks to lock
	MinBlockLock uint64 `protobuf:"varint,9,opt,name=min_block_lock,json=minBlockLock,proto3" json:"min_block_lock,omitempty"`
	// min_block_lock defined the maximum blocks to lock
	MaxBlockLock uint64 `protobuf:"varint,10,opt,name=max_block_lock,json=maxBlockLock,proto3" json:"max_block_lock,omitempty"`
}

AssetParam defines parameters for each bep3 asset.

func NewAssetParam added in v0.11.0 

func NewAssetParam(
	denom string, coinID int64, limit SupplyLimit, active bool,
	deputyAddr sdk.AccAddress, fixedFee sdkmath.Int, minSwapAmount sdkmath.Int,
	maxSwapAmount sdkmath.Int, minBlockLock uint64, maxBlockLock uint64,
) AssetParam

NewAssetParam returns a new AssetParam

func (*AssetParam) Descriptor added in v0.16.0 

func (*AssetParam) Descriptor() ([]byte, []int)

func (*AssetParam) GetActive added in v0.16.0 

func (m *AssetParam) GetActive() bool

func (*AssetParam) GetCoinID added in v0.16.0 

func (m *AssetParam) GetCoinID() int64

func (*AssetParam) GetDenom added in v0.16.0 

func (m *AssetParam) GetDenom() string

func (*AssetParam) GetDeputyAddress added in v0.16.0 

func (m *AssetParam) GetDeputyAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*AssetParam) GetMaxBlockLock added in v0.16.0 

func (m *AssetParam) GetMaxBlockLock() uint64

func (*AssetParam) GetMinBlockLock added in v0.16.0 

func (m *AssetParam) GetMinBlockLock() uint64

func (*AssetParam) GetSupplyLimit added in v0.16.0 

func (m *AssetParam) GetSupplyLimit() SupplyLimit

func (*AssetParam) Marshal added in v0.16.0 

func (m *AssetParam) Marshal() (dAtA []byte, err error)

func (*AssetParam) MarshalTo added in v0.16.0 

func (m *AssetParam) MarshalTo(dAtA []byte) (int, error)

func (*AssetParam) MarshalToSizedBuffer added in v0.16.0 

func (m *AssetParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AssetParam) ProtoMessage added in v0.16.0 

func (*AssetParam) ProtoMessage()

func (*AssetParam) Reset added in v0.16.0 

func (m *AssetParam) Reset()

func (*AssetParam) Size added in v0.16.0 

func (m *AssetParam) Size() (n int)

func (*AssetParam) String 

func (m *AssetParam) String() string

func (*AssetParam) Unmarshal added in v0.16.0 

func (m *AssetParam) Unmarshal(dAtA []byte) error

func (*AssetParam) XXX_DiscardUnknown added in v0.16.0 

func (m *AssetParam) XXX_DiscardUnknown()

func (*AssetParam) XXX_Marshal added in v0.16.0 

func (m *AssetParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssetParam) XXX_Merge added in v0.16.0 

func (m *AssetParam) XXX_Merge(src proto.Message)

func (*AssetParam) XXX_Size added in v0.16.0 

func (m *AssetParam) XXX_Size() int

func (*AssetParam) XXX_Unmarshal added in v0.16.0 

func (m *AssetParam) XXX_Unmarshal(b []byte) error

type AssetParams 

type AssetParams []AssetParam

AssetParams array of AssetParam

type AssetSupplies 

type AssetSupplies []AssetSupply

AssetSupplies is a slice of AssetSupply

type AssetSupply 

type AssetSupply struct {
	// incoming_supply represents the incoming supply of an asset
	IncomingSupply types.Coin `protobuf:"bytes,1,opt,name=incoming_supply,json=incomingSupply,proto3" json:"incoming_supply"`
	// outgoing_supply represents the outgoing supply of an asset
	OutgoingSupply types.Coin `protobuf:"bytes,2,opt,name=outgoing_supply,json=outgoingSupply,proto3" json:"outgoing_supply"`
	// current_supply represents the current on-chain supply of an asset
	CurrentSupply types.Coin `protobuf:"bytes,3,opt,name=current_supply,json=currentSupply,proto3" json:"current_supply"`
	// time_limited_current_supply represents the time limited current supply of an asset
	TimeLimitedCurrentSupply types.Coin `` /* 127-byte string literal not displayed */
	// time_elapsed represents the time elapsed
	TimeElapsed time.Duration `protobuf:"bytes,5,opt,name=time_elapsed,json=timeElapsed,proto3,stdduration" json:"time_elapsed"`
}

AssetSupply defines information about an asset's supply.

func NewAssetSupply 

func NewAssetSupply(incomingSupply, outgoingSupply, currentSupply, timeLimitedSupply sdk.Coin, timeElapsed time.Duration) AssetSupply

NewAssetSupply initializes a new AssetSupply

func (*AssetSupply) Descriptor added in v0.16.0 

func (*AssetSupply) Descriptor() ([]byte, []int)

func (AssetSupply) Equal added in v0.11.0 

func (a AssetSupply) Equal(b AssetSupply) bool

Equal returns if two asset supplies are equal

func (*AssetSupply) GetCurrentSupply added in v0.16.0 

func (m *AssetSupply) GetCurrentSupply() types.Coin

func (AssetSupply) GetDenom added in v0.11.0 

func (a AssetSupply) GetDenom() string

GetDenom getter method for the denom of the asset supply

func (*AssetSupply) GetIncomingSupply added in v0.16.0 

func (m *AssetSupply) GetIncomingSupply() types.Coin

func (*AssetSupply) GetOutgoingSupply added in v0.16.0 

func (m *AssetSupply) GetOutgoingSupply() types.Coin

func (*AssetSupply) GetTimeElapsed added in v0.16.0 

func (m *AssetSupply) GetTimeElapsed() time.Duration

func (*AssetSupply) GetTimeLimitedCurrentSupply added in v0.16.0 

func (m *AssetSupply) GetTimeLimitedCurrentSupply() types.Coin

func (*AssetSupply) Marshal added in v0.16.0 

func (m *AssetSupply) Marshal() (dAtA []byte, err error)

func (*AssetSupply) MarshalTo added in v0.16.0 

func (m *AssetSupply) MarshalTo(dAtA []byte) (int, error)

func (*AssetSupply) MarshalToSizedBuffer added in v0.16.0 

func (m *AssetSupply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AssetSupply) ProtoMessage added in v0.16.0 

func (*AssetSupply) ProtoMessage()

func (*AssetSupply) Reset added in v0.16.0 

func (m *AssetSupply) Reset()

func (*AssetSupply) Size added in v0.16.0 

func (m *AssetSupply) Size() (n int)

func (*AssetSupply) String 

func (m *AssetSupply) String() string

func (*AssetSupply) Unmarshal added in v0.16.0 

func (m *AssetSupply) Unmarshal(dAtA []byte) error

func (AssetSupply) Validate added in v0.8.0 

func (a AssetSupply) Validate() error

Validate performs a basic validation of an asset supply fields.

func (*AssetSupply) XXX_DiscardUnknown added in v0.16.0 

func (m *AssetSupply) XXX_DiscardUnknown()

func (*AssetSupply) XXX_Marshal added in v0.16.0 

func (m *AssetSupply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssetSupply) XXX_Merge added in v0.16.0 

func (m *AssetSupply) XXX_Merge(src proto.Message)

func (*AssetSupply) XXX_Size added in v0.16.0 

func (m *AssetSupply) XXX_Size() int

func (*AssetSupply) XXX_Unmarshal added in v0.16.0 

func (m *AssetSupply) XXX_Unmarshal(b []byte) error

type AssetSupplyResponse added in v0.16.0 

type AssetSupplyResponse struct {
	// incoming_supply represents the incoming supply of an asset
	IncomingSupply types.Coin `protobuf:"bytes,1,opt,name=incoming_supply,json=incomingSupply,proto3" json:"incoming_supply"`
	// outgoing_supply represents the outgoing supply of an asset
	OutgoingSupply types.Coin `protobuf:"bytes,2,opt,name=outgoing_supply,json=outgoingSupply,proto3" json:"outgoing_supply"`
	// current_supply represents the current on-chain supply of an asset
	CurrentSupply types.Coin `protobuf:"bytes,3,opt,name=current_supply,json=currentSupply,proto3" json:"current_supply"`
	// time_limited_current_supply represents the time limited current supply of an asset
	TimeLimitedCurrentSupply types.Coin `` /* 127-byte string literal not displayed */
	// time_elapsed represents the time elapsed
	TimeElapsed time.Duration `protobuf:"bytes,5,opt,name=time_elapsed,json=timeElapsed,proto3,stdduration" json:"time_elapsed"`
}

AssetSupplyResponse defines information about an asset's supply.

func (*AssetSupplyResponse) Descriptor added in v0.16.0 

func (*AssetSupplyResponse) Descriptor() ([]byte, []int)

func (*AssetSupplyResponse) GetCurrentSupply added in v0.16.0 

func (m *AssetSupplyResponse) GetCurrentSupply() types.Coin

func (*AssetSupplyResponse) GetIncomingSupply added in v0.16.0 

func (m *AssetSupplyResponse) GetIncomingSupply() types.Coin

func (*AssetSupplyResponse) GetOutgoingSupply added in v0.16.0 

func (m *AssetSupplyResponse) GetOutgoingSupply() types.Coin

func (*AssetSupplyResponse) GetTimeElapsed added in v0.16.0 

func (m *AssetSupplyResponse) GetTimeElapsed() time.Duration

func (*AssetSupplyResponse) GetTimeLimitedCurrentSupply added in v0.16.0 

func (m *AssetSupplyResponse) GetTimeLimitedCurrentSupply() types.Coin

func (*AssetSupplyResponse) Marshal added in v0.16.0 

func (m *AssetSupplyResponse) Marshal() (dAtA []byte, err error)

func (*AssetSupplyResponse) MarshalTo added in v0.16.0 

func (m *AssetSupplyResponse) MarshalTo(dAtA []byte) (int, error)

func (*AssetSupplyResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *AssetSupplyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AssetSupplyResponse) ProtoMessage added in v0.16.0 

func (*AssetSupplyResponse) ProtoMessage()

func (*AssetSupplyResponse) Reset added in v0.16.0 

func (m *AssetSupplyResponse) Reset()

func (*AssetSupplyResponse) Size added in v0.16.0 

func (m *AssetSupplyResponse) Size() (n int)

func (*AssetSupplyResponse) String added in v0.16.0 

func (m *AssetSupplyResponse) String() string

func (*AssetSupplyResponse) Unmarshal added in v0.16.0 

func (m *AssetSupplyResponse) Unmarshal(dAtA []byte) error

func (*AssetSupplyResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *AssetSupplyResponse) XXX_DiscardUnknown()

func (*AssetSupplyResponse) XXX_Marshal added in v0.16.0 

func (m *AssetSupplyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssetSupplyResponse) XXX_Merge added in v0.16.0 

func (m *AssetSupplyResponse) XXX_Merge(src proto.Message)

func (*AssetSupplyResponse) XXX_Size added in v0.16.0 

func (m *AssetSupplyResponse) XXX_Size() int

func (*AssetSupplyResponse) XXX_Unmarshal added in v0.16.0 

func (m *AssetSupplyResponse) XXX_Unmarshal(b []byte) error

type AtomicSwap 

type AtomicSwap struct {
	// amount represents the amount being swapped
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	// random_number_hash represents the hash of the random number
	RandomNumberHash github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 173-byte string literal not displayed */
	// expire_height represents the height when the swap expires
	ExpireHeight uint64 `protobuf:"varint,3,opt,name=expire_height,json=expireHeight,proto3" json:"expire_height,omitempty"`
	// timestamp represents the timestamp of the swap
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// sender is the kava chain sender of the swap
	Sender github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,5,opt,name=sender,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"sender,omitempty"`
	// recipient is the kava chain recipient of the swap
	Recipient github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 126-byte string literal not displayed */
	// sender_other_chain is the sender on the other chain
	SenderOtherChain string `protobuf:"bytes,7,opt,name=sender_other_chain,json=senderOtherChain,proto3" json:"sender_other_chain,omitempty"`
	// recipient_other_chain is the recipient on the other chain
	RecipientOtherChain string `protobuf:"bytes,8,opt,name=recipient_other_chain,json=recipientOtherChain,proto3" json:"recipient_other_chain,omitempty"`
	// closed_block is the block when the swap is closed
	ClosedBlock int64 `protobuf:"varint,9,opt,name=closed_block,json=closedBlock,proto3" json:"closed_block,omitempty"`
	// status represents the current status of the swap
	Status SwapStatus `protobuf:"varint,10,opt,name=status,proto3,enum=kava.bep3.v1beta1.SwapStatus" json:"status,omitempty"`
	// cross_chain identifies whether the atomic swap is cross chain
	CrossChain bool `protobuf:"varint,11,opt,name=cross_chain,json=crossChain,proto3" json:"cross_chain,omitempty"`
	// direction identifies if the swap is incoming or outgoing
	Direction SwapDirection `protobuf:"varint,12,opt,name=direction,proto3,enum=kava.bep3.v1beta1.SwapDirection" json:"direction,omitempty"`
}

AtomicSwap defines an atomic swap between chains for the pricefeed module.

func NewAtomicSwap 

func NewAtomicSwap(amount sdk.Coins, randomNumberHash tmbytes.HexBytes, expireHeight uint64, timestamp int64,
	sender, recipient sdk.AccAddress, senderOtherChain, recipientOtherChain string, closedBlock int64,
	status SwapStatus, crossChain bool, direction SwapDirection,
) AtomicSwap

NewAtomicSwap returns a new AtomicSwap

func (*AtomicSwap) Descriptor added in v0.16.0 

func (*AtomicSwap) Descriptor() ([]byte, []int)

func (*AtomicSwap) GetAmount added in v0.16.0 

func (m *AtomicSwap) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*AtomicSwap) GetClosedBlock added in v0.16.0 

func (m *AtomicSwap) GetClosedBlock() int64

func (AtomicSwap) GetCoins added in v0.8.0 

func (a AtomicSwap) GetCoins() sdk.Coins

GetCoins returns the swap's amount as sdk.Coins

func (*AtomicSwap) GetCrossChain added in v0.16.0 

func (m *AtomicSwap) GetCrossChain() bool

func (*AtomicSwap) GetDirection added in v0.16.0 

func (m *AtomicSwap) GetDirection() SwapDirection

func (*AtomicSwap) GetExpireHeight added in v0.16.0 

func (m *AtomicSwap) GetExpireHeight() uint64

func (*AtomicSwap) GetRandomNumberHash added in v0.16.0 

func (m *AtomicSwap) GetRandomNumberHash() github_com_tendermint_tendermint_libs_bytes.HexBytes

func (*AtomicSwap) GetRecipient added in v0.16.0 

func (m *AtomicSwap) GetRecipient() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*AtomicSwap) GetRecipientOtherChain added in v0.16.0 

func (m *AtomicSwap) GetRecipientOtherChain() string

func (*AtomicSwap) GetSender added in v0.16.0 

func (m *AtomicSwap) GetSender() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*AtomicSwap) GetSenderOtherChain added in v0.16.0 

func (m *AtomicSwap) GetSenderOtherChain() string

func (*AtomicSwap) GetStatus added in v0.16.0 

func (m *AtomicSwap) GetStatus() SwapStatus

func (AtomicSwap) GetSwapID 

func (a AtomicSwap) GetSwapID() tmbytes.HexBytes

GetSwapID calculates the ID of an atomic swap

func (*AtomicSwap) GetTimestamp added in v0.16.0 

func (m *AtomicSwap) GetTimestamp() int64

func (*AtomicSwap) Marshal added in v0.16.0 

func (m *AtomicSwap) Marshal() (dAtA []byte, err error)

func (*AtomicSwap) MarshalTo added in v0.16.0 

func (m *AtomicSwap) MarshalTo(dAtA []byte) (int, error)

func (*AtomicSwap) MarshalToSizedBuffer added in v0.16.0 

func (m *AtomicSwap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AtomicSwap) ProtoMessage added in v0.16.0 

func (*AtomicSwap) ProtoMessage()

func (*AtomicSwap) Reset added in v0.16.0 

func (m *AtomicSwap) Reset()

func (*AtomicSwap) Size added in v0.16.0 

func (m *AtomicSwap) Size() (n int)

func (*AtomicSwap) String 

func (m *AtomicSwap) String() string

func (*AtomicSwap) Unmarshal added in v0.16.0 

func (m *AtomicSwap) Unmarshal(dAtA []byte) error

func (AtomicSwap) Validate 

func (a AtomicSwap) Validate() error

Validate performs a basic validation of an atomic swap fields.

func (*AtomicSwap) XXX_DiscardUnknown added in v0.16.0 

func (m *AtomicSwap) XXX_DiscardUnknown()

func (*AtomicSwap) XXX_Marshal added in v0.16.0 

func (m *AtomicSwap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AtomicSwap) XXX_Merge added in v0.16.0 

func (m *AtomicSwap) XXX_Merge(src proto.Message)

func (*AtomicSwap) XXX_Size added in v0.16.0 

func (m *AtomicSwap) XXX_Size() int

func (*AtomicSwap) XXX_Unmarshal added in v0.16.0 

func (m *AtomicSwap) XXX_Unmarshal(b []byte) error

type AtomicSwapResponse added in v0.16.0 

type AtomicSwapResponse struct {
	// id represents the id of the atomic swap
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// amount represents the amount being swapped
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	// random_number_hash represents the hash of the random number
	RandomNumberHash string `protobuf:"bytes,3,opt,name=random_number_hash,json=randomNumberHash,proto3" json:"random_number_hash,omitempty"`
	// expire_height represents the height when the swap expires
	ExpireHeight uint64 `protobuf:"varint,4,opt,name=expire_height,json=expireHeight,proto3" json:"expire_height,omitempty"`
	// timestamp represents the timestamp of the swap
	Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// sender is the kava chain sender of the swap
	Sender string `protobuf:"bytes,6,opt,name=sender,proto3" json:"sender,omitempty"`
	// recipient is the kava chain recipient of the swap
	Recipient string `protobuf:"bytes,7,opt,name=recipient,proto3" json:"recipient,omitempty"`
	// sender_other_chain is the sender on the other chain
	SenderOtherChain string `protobuf:"bytes,8,opt,name=sender_other_chain,json=senderOtherChain,proto3" json:"sender_other_chain,omitempty"`
	// recipient_other_chain is the recipient on the other chain
	RecipientOtherChain string `protobuf:"bytes,9,opt,name=recipient_other_chain,json=recipientOtherChain,proto3" json:"recipient_other_chain,omitempty"`
	// closed_block is the block when the swap is closed
	ClosedBlock int64 `protobuf:"varint,10,opt,name=closed_block,json=closedBlock,proto3" json:"closed_block,omitempty"`
	// status represents the current status of the swap
	Status SwapStatus `protobuf:"varint,11,opt,name=status,proto3,enum=kava.bep3.v1beta1.SwapStatus" json:"status,omitempty"`
	// cross_chain identifies whether the atomic swap is cross chain
	CrossChain bool `protobuf:"varint,12,opt,name=cross_chain,json=crossChain,proto3" json:"cross_chain,omitempty"`
	// direction identifies if the swap is incoming or outgoing
	Direction SwapDirection `protobuf:"varint,13,opt,name=direction,proto3,enum=kava.bep3.v1beta1.SwapDirection" json:"direction,omitempty"`
}

AtomicSwapResponse represents the returned atomic swap properties

func (*AtomicSwapResponse) Descriptor added in v0.16.0 

func (*AtomicSwapResponse) Descriptor() ([]byte, []int)

func (*AtomicSwapResponse) GetAmount added in v0.16.0 

func (m *AtomicSwapResponse) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*AtomicSwapResponse) GetClosedBlock added in v0.16.0 

func (m *AtomicSwapResponse) GetClosedBlock() int64

func (*AtomicSwapResponse) GetCrossChain added in v0.16.0 

func (m *AtomicSwapResponse) GetCrossChain() bool

func (*AtomicSwapResponse) GetDirection added in v0.16.0 

func (m *AtomicSwapResponse) GetDirection() SwapDirection

func (*AtomicSwapResponse) GetExpireHeight added in v0.16.0 

func (m *AtomicSwapResponse) GetExpireHeight() uint64

func (*AtomicSwapResponse) GetId added in v0.16.0 

func (m *AtomicSwapResponse) GetId() string

func (*AtomicSwapResponse) GetRandomNumberHash added in v0.16.0 

func (m *AtomicSwapResponse) GetRandomNumberHash() string

func (*AtomicSwapResponse) GetRecipient added in v0.16.0 

func (m *AtomicSwapResponse) GetRecipient() string

func (*AtomicSwapResponse) GetRecipientOtherChain added in v0.16.0 

func (m *AtomicSwapResponse) GetRecipientOtherChain() string

func (*AtomicSwapResponse) GetSender added in v0.16.0 

func (m *AtomicSwapResponse) GetSender() string

func (*AtomicSwapResponse) GetSenderOtherChain added in v0.16.0 

func (m *AtomicSwapResponse) GetSenderOtherChain() string

func (*AtomicSwapResponse) GetStatus added in v0.16.0 

func (m *AtomicSwapResponse) GetStatus() SwapStatus

func (*AtomicSwapResponse) GetTimestamp added in v0.16.0 

func (m *AtomicSwapResponse) GetTimestamp() int64

func (*AtomicSwapResponse) Marshal added in v0.16.0 

func (m *AtomicSwapResponse) Marshal() (dAtA []byte, err error)

func (*AtomicSwapResponse) MarshalTo added in v0.16.0 

func (m *AtomicSwapResponse) MarshalTo(dAtA []byte) (int, error)

func (*AtomicSwapResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *AtomicSwapResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AtomicSwapResponse) ProtoMessage added in v0.16.0 

func (*AtomicSwapResponse) ProtoMessage()

func (*AtomicSwapResponse) Reset added in v0.16.0 

func (m *AtomicSwapResponse) Reset()

func (*AtomicSwapResponse) Size added in v0.16.0 

func (m *AtomicSwapResponse) Size() (n int)

func (*AtomicSwapResponse) String added in v0.16.0 

func (m *AtomicSwapResponse) String() string

func (*AtomicSwapResponse) Unmarshal added in v0.16.0 

func (m *AtomicSwapResponse) Unmarshal(dAtA []byte) error

func (*AtomicSwapResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *AtomicSwapResponse) XXX_DiscardUnknown()

func (*AtomicSwapResponse) XXX_Marshal added in v0.16.0 

func (m *AtomicSwapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AtomicSwapResponse) XXX_Merge added in v0.16.0 

func (m *AtomicSwapResponse) XXX_Merge(src proto.Message)

func (*AtomicSwapResponse) XXX_Size added in v0.16.0 

func (m *AtomicSwapResponse) XXX_Size() int

func (*AtomicSwapResponse) XXX_Unmarshal added in v0.16.0 

func (m *AtomicSwapResponse) XXX_Unmarshal(b []byte) error

type AtomicSwaps 

type AtomicSwaps []AtomicSwap

AtomicSwaps is a slice of AtomicSwap

type BankKeeper added in v0.16.0 

type BankKeeper interface {
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, name string, amt sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type GenesisState 

type GenesisState struct {
	// params defines all the paramaters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// atomic_swaps represents the state of stored atomic swaps
	AtomicSwaps AtomicSwaps `protobuf:"bytes,2,rep,name=atomic_swaps,json=atomicSwaps,proto3,castrepeated=AtomicSwaps" json:"atomic_swaps"`
	// supplies represents the supply information of each atomic swap
	Supplies AssetSupplies `protobuf:"bytes,3,rep,name=supplies,proto3,castrepeated=AssetSupplies" json:"supplies"`
	// previous_block_time represents the time of the previous block
	PreviousBlockTime time.Time `protobuf:"bytes,4,opt,name=previous_block_time,json=previousBlockTime,proto3,stdtime" json:"previous_block_time"`
}

GenesisState defines the pricefeed module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() GenesisState

DefaultGenesisState - default GenesisState used by Cosmos Hub

func NewGenesisState 

func NewGenesisState(params Params, swaps AtomicSwaps, supplies AssetSupplies, previousBlockTime time.Time) GenesisState

NewGenesisState creates a new GenesisState object

func (*GenesisState) Descriptor added in v0.16.0 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetAtomicSwaps added in v0.16.0 

func (m *GenesisState) GetAtomicSwaps() AtomicSwaps

func (*GenesisState) GetParams added in v0.16.0 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPreviousBlockTime added in v0.16.0 

func (m *GenesisState) GetPreviousBlockTime() time.Time

func (*GenesisState) GetSupplies added in v0.16.0 

func (m *GenesisState) GetSupplies() AssetSupplies

func (*GenesisState) Marshal added in v0.16.0 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo added in v0.16.0 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer added in v0.16.0 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage added in v0.16.0 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset added in v0.16.0 

func (m *GenesisState) Reset()

func (*GenesisState) Size added in v0.16.0 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String added in v0.16.0 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal added in v0.16.0 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate validates genesis inputs. It returns error if validation of any input fails.

func (*GenesisState) XXX_DiscardUnknown added in v0.16.0 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal added in v0.16.0 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge added in v0.16.0 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size added in v0.16.0 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal added in v0.16.0 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type LegacyAugmentedAtomicSwap added in v0.16.0 

type LegacyAugmentedAtomicSwap struct {
	ID string `json:"id" yaml:"id"`

	// Embed AtomicSwap fields explicity in order to output as top level JSON fields
	// This prevents breaking changes for clients using REST API
	Amount              sdk.Coins        `json:"amount"  yaml:"amount"`
	RandomNumberHash    tmbytes.HexBytes `json:"random_number_hash"  yaml:"random_number_hash"`
	ExpireHeight        uint64           `json:"expire_height"  yaml:"expire_height"`
	Timestamp           int64            `json:"timestamp"  yaml:"timestamp"`
	Sender              sdk.AccAddress   `json:"sender"  yaml:"sender"`
	Recipient           sdk.AccAddress   `json:"recipient"  yaml:"recipient"`
	SenderOtherChain    string           `json:"sender_other_chain"  yaml:"sender_other_chain"`
	RecipientOtherChain string           `json:"recipient_other_chain"  yaml:"recipient_other_chain"`
	ClosedBlock         int64            `json:"closed_block"  yaml:"closed_block"`
	Status              SwapStatus       `json:"status"  yaml:"status"`
	CrossChain          bool             `json:"cross_chain"  yaml:"cross_chain"`
	Direction           SwapDirection    `json:"direction"  yaml:"direction"`
}

LegacyAugmentedAtomicSwap defines an ID and AtomicSwap fields on the top level. This should be removed when legacy REST endpoints are removed.

func NewLegacyAugmentedAtomicSwap added in v0.16.0 

func NewLegacyAugmentedAtomicSwap(swap AtomicSwap) LegacyAugmentedAtomicSwap

type LegacyAugmentedAtomicSwaps added in v0.16.0 

type LegacyAugmentedAtomicSwaps []LegacyAugmentedAtomicSwap

type MsgClaimAtomicSwap 

type MsgClaimAtomicSwap struct {
	From         string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	SwapID       string `protobuf:"bytes,2,opt,name=swap_id,json=swapId,proto3" json:"swap_id,omitempty"`
	RandomNumber string `protobuf:"bytes,3,opt,name=random_number,json=randomNumber,proto3" json:"random_number,omitempty"`
}

MsgClaimAtomicSwap defines the Msg/ClaimAtomicSwap request type.

func NewMsgClaimAtomicSwap 

func NewMsgClaimAtomicSwap(from string, swapID, randomNumber tmbytes.HexBytes) MsgClaimAtomicSwap

NewMsgClaimAtomicSwap initializes a new MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Descriptor added in v0.16.0 

func (*MsgClaimAtomicSwap) Descriptor() ([]byte, []int)

func (MsgClaimAtomicSwap) GetInvolvedAddresses 

func (msg MsgClaimAtomicSwap) GetInvolvedAddresses() []sdk.AccAddress

GetInvolvedAddresses gets the addresses involved in a MsgClaimAtomicSwap

func (MsgClaimAtomicSwap) GetSignBytes 

func (msg MsgClaimAtomicSwap) GetSignBytes() []byte

GetSignBytes gets the sign bytes of a MsgClaimAtomicSwap

func (MsgClaimAtomicSwap) GetSigners 

func (msg MsgClaimAtomicSwap) GetSigners() []sdk.AccAddress

GetSigners gets the signers of a MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Marshal added in v0.16.0 

func (m *MsgClaimAtomicSwap) Marshal() (dAtA []byte, err error)

func (*MsgClaimAtomicSwap) MarshalTo added in v0.16.0 

func (m *MsgClaimAtomicSwap) MarshalTo(dAtA []byte) (int, error)

func (*MsgClaimAtomicSwap) MarshalToSizedBuffer added in v0.16.0 

func (m *MsgClaimAtomicSwap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgClaimAtomicSwap) ProtoMessage added in v0.16.0 

func (*MsgClaimAtomicSwap) ProtoMessage()

func (*MsgClaimAtomicSwap) Reset added in v0.16.0 

func (m *MsgClaimAtomicSwap) Reset()

func (MsgClaimAtomicSwap) Route 

func (msg MsgClaimAtomicSwap) Route() string

Route establishes the route for the MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Size added in v0.16.0 

func (m *MsgClaimAtomicSwap) Size() (n int)

func (MsgClaimAtomicSwap) String 

func (msg MsgClaimAtomicSwap) String() string

String prints the MsgClaimAtomicSwap

func (MsgClaimAtomicSwap) Type 

func (msg MsgClaimAtomicSwap) Type() string

Type is the name of MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Unmarshal added in v0.16.0 

func (m *MsgClaimAtomicSwap) Unmarshal(dAtA []byte) error

func (MsgClaimAtomicSwap) ValidateBasic 

func (msg MsgClaimAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) XXX_DiscardUnknown added in v0.16.0 

func (m *MsgClaimAtomicSwap) XXX_DiscardUnknown()

func (*MsgClaimAtomicSwap) XXX_Marshal added in v0.16.0 

func (m *MsgClaimAtomicSwap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgClaimAtomicSwap) XXX_Merge added in v0.16.0 

func (m *MsgClaimAtomicSwap) XXX_Merge(src proto.Message)

func (*MsgClaimAtomicSwap) XXX_Size added in v0.16.0 

func (m *MsgClaimAtomicSwap) XXX_Size() int

func (*MsgClaimAtomicSwap) XXX_Unmarshal added in v0.16.0 

func (m *MsgClaimAtomicSwap) XXX_Unmarshal(b []byte) error

type MsgClaimAtomicSwapResponse added in v0.16.0 

type MsgClaimAtomicSwapResponse struct {
}

MsgClaimAtomicSwapResponse defines the Msg/ClaimAtomicSwap response type.

func (*MsgClaimAtomicSwapResponse) Descriptor added in v0.16.0 

func (*MsgClaimAtomicSwapResponse) Descriptor() ([]byte, []int)

func (*MsgClaimAtomicSwapResponse) Marshal added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) Marshal() (dAtA []byte, err error)

func (*MsgClaimAtomicSwapResponse) MarshalTo added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgClaimAtomicSwapResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgClaimAtomicSwapResponse) ProtoMessage added in v0.16.0 

func (*MsgClaimAtomicSwapResponse) ProtoMessage()

func (*MsgClaimAtomicSwapResponse) Reset added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) Reset()

func (*MsgClaimAtomicSwapResponse) Size added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) Size() (n int)

func (*MsgClaimAtomicSwapResponse) String added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) String() string

func (*MsgClaimAtomicSwapResponse) Unmarshal added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) Unmarshal(dAtA []byte) error

func (*MsgClaimAtomicSwapResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgClaimAtomicSwapResponse) XXX_Marshal added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgClaimAtomicSwapResponse) XXX_Merge added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) XXX_Merge(src proto.Message)

func (*MsgClaimAtomicSwapResponse) XXX_Size added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) XXX_Size() int

func (*MsgClaimAtomicSwapResponse) XXX_Unmarshal added in v0.16.0 

func (m *MsgClaimAtomicSwapResponse) XXX_Unmarshal(b []byte) error

type MsgClient added in v0.16.0 

type MsgClient interface {
	// CreateAtomicSwap defines a method for creating an atomic swap
	CreateAtomicSwap(ctx context.Context, in *MsgCreateAtomicSwap, opts ...grpc.CallOption) (*MsgCreateAtomicSwapResponse, error)
	// ClaimAtomicSwap defines a method for claiming an atomic swap
	ClaimAtomicSwap(ctx context.Context, in *MsgClaimAtomicSwap, opts ...grpc.CallOption) (*MsgClaimAtomicSwapResponse, error)
	// RefundAtomicSwap defines a method for refunding an atomic swap
	RefundAtomicSwap(ctx context.Context, in *MsgRefundAtomicSwap, opts ...grpc.CallOption) (*MsgRefundAtomicSwapResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient added in v0.16.0 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateAtomicSwap 

type MsgCreateAtomicSwap struct {
	From                string                                   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To                  string                                   `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	RecipientOtherChain string                                   `protobuf:"bytes,3,opt,name=recipient_other_chain,json=recipientOtherChain,proto3" json:"recipient_other_chain,omitempty"`
	SenderOtherChain    string                                   `protobuf:"bytes,4,opt,name=sender_other_chain,json=senderOtherChain,proto3" json:"sender_other_chain,omitempty"`
	RandomNumberHash    string                                   `protobuf:"bytes,5,opt,name=random_number_hash,json=randomNumberHash,proto3" json:"random_number_hash,omitempty"`
	Timestamp           int64                                    `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Amount              github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,7,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	HeightSpan          uint64                                   `protobuf:"varint,8,opt,name=height_span,json=heightSpan,proto3" json:"height_span,omitempty"`
}

MsgCreateAtomicSwap defines the Msg/CreateAtomicSwap request type.

func NewMsgCreateAtomicSwap 

func NewMsgCreateAtomicSwap(from, to string, recipientOtherChain,
	senderOtherChain string, randomNumberHash tmbytes.HexBytes, timestamp int64,
	amount sdk.Coins, heightSpan uint64,
) MsgCreateAtomicSwap

NewMsgCreateAtomicSwap initializes a new MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Descriptor added in v0.16.0 

func (*MsgCreateAtomicSwap) Descriptor() ([]byte, []int)

func (MsgCreateAtomicSwap) GetInvolvedAddresses 

func (msg MsgCreateAtomicSwap) GetInvolvedAddresses() []sdk.AccAddress

GetInvolvedAddresses gets the addresses involved in a MsgCreateAtomicSwap

func (MsgCreateAtomicSwap) GetSignBytes 

func (msg MsgCreateAtomicSwap) GetSignBytes() []byte

GetSignBytes gets the sign bytes of a MsgCreateAtomicSwap

func (MsgCreateAtomicSwap) GetSigners 

func (msg MsgCreateAtomicSwap) GetSigners() []sdk.AccAddress

GetSigners gets the signers of a MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Marshal added in v0.16.0 

func (m *MsgCreateAtomicSwap) Marshal() (dAtA []byte, err error)

func (*MsgCreateAtomicSwap) MarshalTo added in v0.16.0 

func (m *MsgCreateAtomicSwap) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateAtomicSwap) MarshalToSizedBuffer added in v0.16.0 

func (m *MsgCreateAtomicSwap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateAtomicSwap) ProtoMessage added in v0.16.0 

func (*MsgCreateAtomicSwap) ProtoMessage()

func (*MsgCreateAtomicSwap) Reset added in v0.16.0 

func (m *MsgCreateAtomicSwap) Reset()

func (MsgCreateAtomicSwap) Route 

func (msg MsgCreateAtomicSwap) Route() string

Route establishes the route for the MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Size added in v0.16.0 

func (m *MsgCreateAtomicSwap) Size() (n int)

func (MsgCreateAtomicSwap) String 

func (msg MsgCreateAtomicSwap) String() string

String prints the MsgCreateAtomicSwap

func (MsgCreateAtomicSwap) Type 

func (msg MsgCreateAtomicSwap) Type() string

Type is the name of MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Unmarshal added in v0.16.0 

func (m *MsgCreateAtomicSwap) Unmarshal(dAtA []byte) error

func (MsgCreateAtomicSwap) ValidateBasic 

func (msg MsgCreateAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) XXX_DiscardUnknown added in v0.16.0 

func (m *MsgCreateAtomicSwap) XXX_DiscardUnknown()

func (*MsgCreateAtomicSwap) XXX_Marshal added in v0.16.0 

func (m *MsgCreateAtomicSwap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateAtomicSwap) XXX_Merge added in v0.16.0 

func (m *MsgCreateAtomicSwap) XXX_Merge(src proto.Message)

func (*MsgCreateAtomicSwap) XXX_Size added in v0.16.0 

func (m *MsgCreateAtomicSwap) XXX_Size() int

func (*MsgCreateAtomicSwap) XXX_Unmarshal added in v0.16.0 

func (m *MsgCreateAtomicSwap) XXX_Unmarshal(b []byte) error

type MsgCreateAtomicSwapResponse added in v0.16.0 

type MsgCreateAtomicSwapResponse struct {
}

MsgCreateAtomicSwapResponse defines the Msg/CreateAtomicSwap response type.

func (*MsgCreateAtomicSwapResponse) Descriptor added in v0.16.0 

func (*MsgCreateAtomicSwapResponse) Descriptor() ([]byte, []int)

func (*MsgCreateAtomicSwapResponse) Marshal added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) Marshal() (dAtA []byte, err error)

func (*MsgCreateAtomicSwapResponse) MarshalTo added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateAtomicSwapResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateAtomicSwapResponse) ProtoMessage added in v0.16.0 

func (*MsgCreateAtomicSwapResponse) ProtoMessage()

func (*MsgCreateAtomicSwapResponse) Reset added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) Reset()

func (*MsgCreateAtomicSwapResponse) Size added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) Size() (n int)

func (*MsgCreateAtomicSwapResponse) String added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) String() string

func (*MsgCreateAtomicSwapResponse) Unmarshal added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) Unmarshal(dAtA []byte) error

func (*MsgCreateAtomicSwapResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgCreateAtomicSwapResponse) XXX_Marshal added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateAtomicSwapResponse) XXX_Merge added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) XXX_Merge(src proto.Message)

func (*MsgCreateAtomicSwapResponse) XXX_Size added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) XXX_Size() int

func (*MsgCreateAtomicSwapResponse) XXX_Unmarshal added in v0.16.0 

func (m *MsgCreateAtomicSwapResponse) XXX_Unmarshal(b []byte) error

type MsgRefundAtomicSwap 

type MsgRefundAtomicSwap struct {
	From   string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	SwapID string `protobuf:"bytes,2,opt,name=swap_id,json=swapId,proto3" json:"swap_id,omitempty"`
}

MsgRefundAtomicSwap defines the Msg/RefundAtomicSwap request type.

func NewMsgRefundAtomicSwap 

func NewMsgRefundAtomicSwap(from string, swapID tmbytes.HexBytes) MsgRefundAtomicSwap

NewMsgRefundAtomicSwap initializes a new MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Descriptor added in v0.16.0 

func (*MsgRefundAtomicSwap) Descriptor() ([]byte, []int)

func (MsgRefundAtomicSwap) GetInvolvedAddresses 

func (msg MsgRefundAtomicSwap) GetInvolvedAddresses() []sdk.AccAddress

GetInvolvedAddresses gets the addresses involved in a MsgRefundAtomicSwap

func (MsgRefundAtomicSwap) GetSignBytes 

func (msg MsgRefundAtomicSwap) GetSignBytes() []byte

GetSignBytes gets the sign bytes of a MsgRefundAtomicSwap

func (MsgRefundAtomicSwap) GetSigners 

func (msg MsgRefundAtomicSwap) GetSigners() []sdk.AccAddress

GetSigners gets the signers of a MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Marshal added in v0.16.0 

func (m *MsgRefundAtomicSwap) Marshal() (dAtA []byte, err error)

func (*MsgRefundAtomicSwap) MarshalTo added in v0.16.0 

func (m *MsgRefundAtomicSwap) MarshalTo(dAtA []byte) (int, error)

func (*MsgRefundAtomicSwap) MarshalToSizedBuffer added in v0.16.0 

func (m *MsgRefundAtomicSwap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRefundAtomicSwap) ProtoMessage added in v0.16.0 

func (*MsgRefundAtomicSwap) ProtoMessage()

func (*MsgRefundAtomicSwap) Reset added in v0.16.0 

func (m *MsgRefundAtomicSwap) Reset()

func (MsgRefundAtomicSwap) Route 

func (msg MsgRefundAtomicSwap) Route() string

Route establishes the route for the MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Size added in v0.16.0 

func (m *MsgRefundAtomicSwap) Size() (n int)

func (MsgRefundAtomicSwap) String 

func (msg MsgRefundAtomicSwap) String() string

String prints the MsgRefundAtomicSwap

func (MsgRefundAtomicSwap) Type 

func (msg MsgRefundAtomicSwap) Type() string

Type is the name of MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Unmarshal added in v0.16.0 

func (m *MsgRefundAtomicSwap) Unmarshal(dAtA []byte) error

func (MsgRefundAtomicSwap) ValidateBasic 

func (msg MsgRefundAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) XXX_DiscardUnknown added in v0.16.0 

func (m *MsgRefundAtomicSwap) XXX_DiscardUnknown()

func (*MsgRefundAtomicSwap) XXX_Marshal added in v0.16.0 

func (m *MsgRefundAtomicSwap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRefundAtomicSwap) XXX_Merge added in v0.16.0 

func (m *MsgRefundAtomicSwap) XXX_Merge(src proto.Message)

func (*MsgRefundAtomicSwap) XXX_Size added in v0.16.0 

func (m *MsgRefundAtomicSwap) XXX_Size() int

func (*MsgRefundAtomicSwap) XXX_Unmarshal added in v0.16.0 

func (m *MsgRefundAtomicSwap) XXX_Unmarshal(b []byte) error

type MsgRefundAtomicSwapResponse added in v0.16.0 

type MsgRefundAtomicSwapResponse struct {
}

MsgRefundAtomicSwapResponse defines the Msg/RefundAtomicSwap response type.

func (*MsgRefundAtomicSwapResponse) Descriptor added in v0.16.0 

func (*MsgRefundAtomicSwapResponse) Descriptor() ([]byte, []int)

func (*MsgRefundAtomicSwapResponse) Marshal added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) Marshal() (dAtA []byte, err error)

func (*MsgRefundAtomicSwapResponse) MarshalTo added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgRefundAtomicSwapResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRefundAtomicSwapResponse) ProtoMessage added in v0.16.0 

func (*MsgRefundAtomicSwapResponse) ProtoMessage()

func (*MsgRefundAtomicSwapResponse) Reset added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) Reset()

func (*MsgRefundAtomicSwapResponse) Size added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) Size() (n int)

func (*MsgRefundAtomicSwapResponse) String added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) String() string

func (*MsgRefundAtomicSwapResponse) Unmarshal added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) Unmarshal(dAtA []byte) error

func (*MsgRefundAtomicSwapResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgRefundAtomicSwapResponse) XXX_Marshal added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRefundAtomicSwapResponse) XXX_Merge added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) XXX_Merge(src proto.Message)

func (*MsgRefundAtomicSwapResponse) XXX_Size added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) XXX_Size() int

func (*MsgRefundAtomicSwapResponse) XXX_Unmarshal added in v0.16.0 

func (m *MsgRefundAtomicSwapResponse) XXX_Unmarshal(b []byte) error

type MsgServer added in v0.16.0 

type MsgServer interface {
	// CreateAtomicSwap defines a method for creating an atomic swap
	CreateAtomicSwap(context.Context, *MsgCreateAtomicSwap) (*MsgCreateAtomicSwapResponse, error)
	// ClaimAtomicSwap defines a method for claiming an atomic swap
	ClaimAtomicSwap(context.Context, *MsgClaimAtomicSwap) (*MsgClaimAtomicSwapResponse, error)
	// RefundAtomicSwap defines a method for refunding an atomic swap
	RefundAtomicSwap(context.Context, *MsgRefundAtomicSwap) (*MsgRefundAtomicSwapResponse, error)
}

MsgServer is the server API for Msg service.

type Params 

type Params struct {
	// asset_params define the parameters for each bep3 asset
	AssetParams AssetParams `protobuf:"bytes,1,rep,name=asset_params,json=assetParams,proto3,castrepeated=AssetParams" json:"asset_params"`
}

Params defines the parameters for the bep3 module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default params for bep3 module

func NewParams 

func NewParams(ap []AssetParam) Params

NewParams returns a new params object

func (*Params) Descriptor added in v0.16.0 

func (*Params) Descriptor() ([]byte, []int)

func (*Params) GetAssetParams added in v0.16.0 

func (m *Params) GetAssetParams() AssetParams

func (*Params) Marshal added in v0.16.0 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo added in v0.16.0 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer added in v0.16.0 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs implements the ParamSet interface and returns all the key/value pairs pairs of bep3 module's parameters. nolint

func (*Params) ProtoMessage added in v0.16.0 

func (*Params) ProtoMessage()

func (*Params) Reset added in v0.16.0 

func (m *Params) Reset()

func (*Params) Size added in v0.16.0 

func (m *Params) Size() (n int)

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal added in v0.16.0 

func (m *Params) Unmarshal(dAtA []byte) error

func (Params) Validate 

func (p Params) Validate() error

Validate ensure that params have valid values

func (*Params) XXX_DiscardUnknown added in v0.16.0 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal added in v0.16.0 

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge added in v0.16.0 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size added in v0.16.0 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal added in v0.16.0 

func (m *Params) XXX_Unmarshal(b []byte) error

type QueryAssetSupplies added in v0.8.0 

type QueryAssetSupplies struct {
	Page  int `json:"page" yaml:"page"`
	Limit int `json:"limit" yaml:"limit"`
}

QueryAssetSupplies contains the params for an AssetSupplies query

func NewQueryAssetSupplies added in v0.8.0 

func NewQueryAssetSupplies(page int, limit int) QueryAssetSupplies

NewQueryAssetSupplies creates a new QueryAssetSupplies

type QueryAssetSuppliesRequest added in v0.16.0 

type QueryAssetSuppliesRequest struct {
}

QueryAssetSuppliesRequest is the request type for the Query/AssetSupplies RPC method.

func (*QueryAssetSuppliesRequest) Descriptor added in v0.16.0 

func (*QueryAssetSuppliesRequest) Descriptor() ([]byte, []int)

func (*QueryAssetSuppliesRequest) Marshal added in v0.16.0 

func (m *QueryAssetSuppliesRequest) Marshal() (dAtA []byte, err error)

func (*QueryAssetSuppliesRequest) MarshalTo added in v0.16.0 

func (m *QueryAssetSuppliesRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryAssetSuppliesRequest) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAssetSuppliesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAssetSuppliesRequest) ProtoMessage added in v0.16.0 

func (*QueryAssetSuppliesRequest) ProtoMessage()

func (*QueryAssetSuppliesRequest) Reset added in v0.16.0 

func (m *QueryAssetSuppliesRequest) Reset()

func (*QueryAssetSuppliesRequest) Size added in v0.16.0 

func (m *QueryAssetSuppliesRequest) Size() (n int)

func (*QueryAssetSuppliesRequest) String added in v0.16.0 

func (m *QueryAssetSuppliesRequest) String() string

func (*QueryAssetSuppliesRequest) Unmarshal added in v0.16.0 

func (m *QueryAssetSuppliesRequest) Unmarshal(dAtA []byte) error

func (*QueryAssetSuppliesRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAssetSuppliesRequest) XXX_DiscardUnknown()

func (*QueryAssetSuppliesRequest) XXX_Marshal added in v0.16.0 

func (m *QueryAssetSuppliesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAssetSuppliesRequest) XXX_Merge added in v0.16.0 

func (m *QueryAssetSuppliesRequest) XXX_Merge(src proto.Message)

func (*QueryAssetSuppliesRequest) XXX_Size added in v0.16.0 

func (m *QueryAssetSuppliesRequest) XXX_Size() int

func (*QueryAssetSuppliesRequest) XXX_Unmarshal added in v0.16.0 

func (m *QueryAssetSuppliesRequest) XXX_Unmarshal(b []byte) error

type QueryAssetSuppliesResponse added in v0.16.0 

type QueryAssetSuppliesResponse struct {
	// asset_supplies represents the supplies of returned assets
	AssetSupplies []AssetSupplyResponse `protobuf:"bytes,1,rep,name=asset_supplies,json=assetSupplies,proto3" json:"asset_supplies"`
}

QueryAssetSuppliesResponse is the response type for the Query/AssetSupplies RPC method.

func (*QueryAssetSuppliesResponse) Descriptor added in v0.16.0 

func (*QueryAssetSuppliesResponse) Descriptor() ([]byte, []int)

func (*QueryAssetSuppliesResponse) GetAssetSupplies added in v0.16.0 

func (m *QueryAssetSuppliesResponse) GetAssetSupplies() []AssetSupplyResponse

func (*QueryAssetSuppliesResponse) Marshal added in v0.16.0 

func (m *QueryAssetSuppliesResponse) Marshal() (dAtA []byte, err error)

func (*QueryAssetSuppliesResponse) MarshalTo added in v0.16.0 

func (m *QueryAssetSuppliesResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryAssetSuppliesResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAssetSuppliesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAssetSuppliesResponse) ProtoMessage added in v0.16.0 

func (*QueryAssetSuppliesResponse) ProtoMessage()

func (*QueryAssetSuppliesResponse) Reset added in v0.16.0 

func (m *QueryAssetSuppliesResponse) Reset()

func (*QueryAssetSuppliesResponse) Size added in v0.16.0 

func (m *QueryAssetSuppliesResponse) Size() (n int)

func (*QueryAssetSuppliesResponse) String added in v0.16.0 

func (m *QueryAssetSuppliesResponse) String() string

func (*QueryAssetSuppliesResponse) Unmarshal added in v0.16.0 

func (m *QueryAssetSuppliesResponse) Unmarshal(dAtA []byte) error

func (*QueryAssetSuppliesResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAssetSuppliesResponse) XXX_DiscardUnknown()

func (*QueryAssetSuppliesResponse) XXX_Marshal added in v0.16.0 

func (m *QueryAssetSuppliesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAssetSuppliesResponse) XXX_Merge added in v0.16.0 

func (m *QueryAssetSuppliesResponse) XXX_Merge(src proto.Message)

func (*QueryAssetSuppliesResponse) XXX_Size added in v0.16.0 

func (m *QueryAssetSuppliesResponse) XXX_Size() int

func (*QueryAssetSuppliesResponse) XXX_Unmarshal added in v0.16.0 

func (m *QueryAssetSuppliesResponse) XXX_Unmarshal(b []byte) error

type QueryAssetSupply 

type QueryAssetSupply struct {
	Denom string `json:"denom" yaml:"denom"`
}

QueryAssetSupply contains the params for query 'custom/bep3/supply'

func NewQueryAssetSupply 

func NewQueryAssetSupply(denom string) QueryAssetSupply

NewQueryAssetSupply creates a new QueryAssetSupply

type QueryAssetSupplyRequest added in v0.16.0 

type QueryAssetSupplyRequest struct {
	// denom filters the asset response for the specified denom
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryAssetSupplyRequest is the request type for the Query/AssetSupply RPC method.

func (*QueryAssetSupplyRequest) Descriptor added in v0.16.0 

func (*QueryAssetSupplyRequest) Descriptor() ([]byte, []int)

func (*QueryAssetSupplyRequest) Marshal added in v0.16.0 

func (m *QueryAssetSupplyRequest) Marshal() (dAtA []byte, err error)

func (*QueryAssetSupplyRequest) MarshalTo added in v0.16.0 

func (m *QueryAssetSupplyRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryAssetSupplyRequest) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAssetSupplyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAssetSupplyRequest) ProtoMessage added in v0.16.0 

func (*QueryAssetSupplyRequest) ProtoMessage()

func (*QueryAssetSupplyRequest) Reset added in v0.16.0 

func (m *QueryAssetSupplyRequest) Reset()

func (*QueryAssetSupplyRequest) Size added in v0.16.0 

func (m *QueryAssetSupplyRequest) Size() (n int)

func (*QueryAssetSupplyRequest) String added in v0.16.0 

func (m *QueryAssetSupplyRequest) String() string

func (*QueryAssetSupplyRequest) Unmarshal added in v0.16.0 

func (m *QueryAssetSupplyRequest) Unmarshal(dAtA []byte) error

func (*QueryAssetSupplyRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAssetSupplyRequest) XXX_DiscardUnknown()

func (*QueryAssetSupplyRequest) XXX_Marshal added in v0.16.0 

func (m *QueryAssetSupplyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAssetSupplyRequest) XXX_Merge added in v0.16.0 

func (m *QueryAssetSupplyRequest) XXX_Merge(src proto.Message)

func (*QueryAssetSupplyRequest) XXX_Size added in v0.16.0 

func (m *QueryAssetSupplyRequest) XXX_Size() int

func (*QueryAssetSupplyRequest) XXX_Unmarshal added in v0.16.0 

func (m *QueryAssetSupplyRequest) XXX_Unmarshal(b []byte) error

type QueryAssetSupplyResponse added in v0.16.0 

type QueryAssetSupplyResponse struct {
	// asset_supply represents the supply of the asset
	AssetSupply AssetSupplyResponse `protobuf:"bytes,1,opt,name=asset_supply,json=assetSupply,proto3" json:"asset_supply"`
}

QueryAssetSupplyResponse is the response type for the Query/AssetSupply RPC method.

func (*QueryAssetSupplyResponse) Descriptor added in v0.16.0 

func (*QueryAssetSupplyResponse) Descriptor() ([]byte, []int)

func (*QueryAssetSupplyResponse) GetAssetSupply added in v0.16.0 

func (m *QueryAssetSupplyResponse) GetAssetSupply() AssetSupplyResponse

func (*QueryAssetSupplyResponse) Marshal added in v0.16.0 

func (m *QueryAssetSupplyResponse) Marshal() (dAtA []byte, err error)

func (*QueryAssetSupplyResponse) MarshalTo added in v0.16.0 

func (m *QueryAssetSupplyResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryAssetSupplyResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAssetSupplyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAssetSupplyResponse) ProtoMessage added in v0.16.0 

func (*QueryAssetSupplyResponse) ProtoMessage()

func (*QueryAssetSupplyResponse) Reset added in v0.16.0 

func (m *QueryAssetSupplyResponse) Reset()

func (*QueryAssetSupplyResponse) Size added in v0.16.0 

func (m *QueryAssetSupplyResponse) Size() (n int)

func (*QueryAssetSupplyResponse) String added in v0.16.0 

func (m *QueryAssetSupplyResponse) String() string

func (*QueryAssetSupplyResponse) Unmarshal added in v0.16.0 

func (m *QueryAssetSupplyResponse) Unmarshal(dAtA []byte) error

func (*QueryAssetSupplyResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAssetSupplyResponse) XXX_DiscardUnknown()

func (*QueryAssetSupplyResponse) XXX_Marshal added in v0.16.0 

func (m *QueryAssetSupplyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAssetSupplyResponse) XXX_Merge added in v0.16.0 

func (m *QueryAssetSupplyResponse) XXX_Merge(src proto.Message)

func (*QueryAssetSupplyResponse) XXX_Size added in v0.16.0 

func (m *QueryAssetSupplyResponse) XXX_Size() int

func (*QueryAssetSupplyResponse) XXX_Unmarshal added in v0.16.0 

func (m *QueryAssetSupplyResponse) XXX_Unmarshal(b []byte) error

type QueryAtomicSwapByID 

type QueryAtomicSwapByID struct {
	SwapID tmbytes.HexBytes `json:"swap_id" yaml:"swap_id"`
}

QueryAtomicSwapByID contains the params for query 'custom/bep3/swap'

func NewQueryAtomicSwapByID 

func NewQueryAtomicSwapByID(swapBytes tmbytes.HexBytes) QueryAtomicSwapByID

NewQueryAtomicSwapByID creates a new QueryAtomicSwapByID

type QueryAtomicSwapRequest added in v0.16.0 

type QueryAtomicSwapRequest struct {
	// swap_id represents the id of the swap to query
	SwapId string `protobuf:"bytes,1,opt,name=swap_id,json=swapId,proto3" json:"swap_id,omitempty"`
}

QueryAtomicSwapRequest is the request type for the Query/AtomicSwap RPC method.

func (*QueryAtomicSwapRequest) Descriptor added in v0.16.0 

func (*QueryAtomicSwapRequest) Descriptor() ([]byte, []int)

func (*QueryAtomicSwapRequest) Marshal added in v0.16.0 

func (m *QueryAtomicSwapRequest) Marshal() (dAtA []byte, err error)

func (*QueryAtomicSwapRequest) MarshalTo added in v0.16.0 

func (m *QueryAtomicSwapRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryAtomicSwapRequest) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAtomicSwapRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAtomicSwapRequest) ProtoMessage added in v0.16.0 

func (*QueryAtomicSwapRequest) ProtoMessage()

func (*QueryAtomicSwapRequest) Reset added in v0.16.0 

func (m *QueryAtomicSwapRequest) Reset()

func (*QueryAtomicSwapRequest) Size added in v0.16.0 

func (m *QueryAtomicSwapRequest) Size() (n int)

func (*QueryAtomicSwapRequest) String added in v0.16.0 

func (m *QueryAtomicSwapRequest) String() string

func (*QueryAtomicSwapRequest) Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapRequest) Unmarshal(dAtA []byte) error

func (*QueryAtomicSwapRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAtomicSwapRequest) XXX_DiscardUnknown()

func (*QueryAtomicSwapRequest) XXX_Marshal added in v0.16.0 

func (m *QueryAtomicSwapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAtomicSwapRequest) XXX_Merge added in v0.16.0 

func (m *QueryAtomicSwapRequest) XXX_Merge(src proto.Message)

func (*QueryAtomicSwapRequest) XXX_Size added in v0.16.0 

func (m *QueryAtomicSwapRequest) XXX_Size() int

func (*QueryAtomicSwapRequest) XXX_Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapRequest) XXX_Unmarshal(b []byte) error

type QueryAtomicSwapResponse added in v0.16.0 

type QueryAtomicSwapResponse struct {
	AtomicSwap AtomicSwapResponse `protobuf:"bytes,2,opt,name=atomic_swap,json=atomicSwap,proto3" json:"atomic_swap"`
}

QueryAtomicSwapResponse is the response type for the Query/AtomicSwap RPC method.

func (*QueryAtomicSwapResponse) Descriptor added in v0.16.0 

func (*QueryAtomicSwapResponse) Descriptor() ([]byte, []int)

func (*QueryAtomicSwapResponse) GetAtomicSwap added in v0.16.0 

func (m *QueryAtomicSwapResponse) GetAtomicSwap() AtomicSwapResponse

func (*QueryAtomicSwapResponse) Marshal added in v0.16.0 

func (m *QueryAtomicSwapResponse) Marshal() (dAtA []byte, err error)

func (*QueryAtomicSwapResponse) MarshalTo added in v0.16.0 

func (m *QueryAtomicSwapResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryAtomicSwapResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAtomicSwapResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAtomicSwapResponse) ProtoMessage added in v0.16.0 

func (*QueryAtomicSwapResponse) ProtoMessage()

func (*QueryAtomicSwapResponse) Reset added in v0.16.0 

func (m *QueryAtomicSwapResponse) Reset()

func (*QueryAtomicSwapResponse) Size added in v0.16.0 

func (m *QueryAtomicSwapResponse) Size() (n int)

func (*QueryAtomicSwapResponse) String added in v0.16.0 

func (m *QueryAtomicSwapResponse) String() string

func (*QueryAtomicSwapResponse) Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapResponse) Unmarshal(dAtA []byte) error

func (*QueryAtomicSwapResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAtomicSwapResponse) XXX_DiscardUnknown()

func (*QueryAtomicSwapResponse) XXX_Marshal added in v0.16.0 

func (m *QueryAtomicSwapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAtomicSwapResponse) XXX_Merge added in v0.16.0 

func (m *QueryAtomicSwapResponse) XXX_Merge(src proto.Message)

func (*QueryAtomicSwapResponse) XXX_Size added in v0.16.0 

func (m *QueryAtomicSwapResponse) XXX_Size() int

func (*QueryAtomicSwapResponse) XXX_Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapResponse) XXX_Unmarshal(b []byte) error

type QueryAtomicSwaps 

type QueryAtomicSwaps struct {
	Page       int            `json:"page" yaml:"page"`
	Limit      int            `json:"limit" yaml:"limit"`
	Involve    sdk.AccAddress `json:"involve" yaml:"involve"`
	Expiration uint64         `json:"expiration" yaml:"expiration"`
	Status     SwapStatus     `json:"status" yaml:"status"`
	Direction  SwapDirection  `json:"direction" yaml:"direction"`
}

QueryAtomicSwaps contains the params for an AtomicSwaps query

func NewQueryAtomicSwaps 

func NewQueryAtomicSwaps(page, limit int, involve sdk.AccAddress, expiration uint64,
	status SwapStatus, direction SwapDirection,
) QueryAtomicSwaps

NewQueryAtomicSwaps creates a new instance of QueryAtomicSwaps

type QueryAtomicSwapsRequest added in v0.16.0 

type QueryAtomicSwapsRequest struct {
	// involve filters by address
	Involve string `protobuf:"bytes,1,opt,name=involve,proto3" json:"involve,omitempty"`
	// expiration filters by expiration block height
	Expiration uint64 `protobuf:"varint,2,opt,name=expiration,proto3" json:"expiration,omitempty"`
	// status filters by swap status
	Status SwapStatus `protobuf:"varint,3,opt,name=status,proto3,enum=kava.bep3.v1beta1.SwapStatus" json:"status,omitempty"`
	// direction fitlers by swap direction
	Direction  SwapDirection      `protobuf:"varint,4,opt,name=direction,proto3,enum=kava.bep3.v1beta1.SwapDirection" json:"direction,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,5,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAtomicSwapsRequest is the request type for the Query/AtomicSwaps RPC method.

func (*QueryAtomicSwapsRequest) Descriptor added in v0.16.0 

func (*QueryAtomicSwapsRequest) Descriptor() ([]byte, []int)

func (*QueryAtomicSwapsRequest) Marshal added in v0.16.0 

func (m *QueryAtomicSwapsRequest) Marshal() (dAtA []byte, err error)

func (*QueryAtomicSwapsRequest) MarshalTo added in v0.16.0 

func (m *QueryAtomicSwapsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryAtomicSwapsRequest) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAtomicSwapsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAtomicSwapsRequest) ProtoMessage added in v0.16.0 

func (*QueryAtomicSwapsRequest) ProtoMessage()

func (*QueryAtomicSwapsRequest) Reset added in v0.16.0 

func (m *QueryAtomicSwapsRequest) Reset()

func (*QueryAtomicSwapsRequest) Size added in v0.16.0 

func (m *QueryAtomicSwapsRequest) Size() (n int)

func (*QueryAtomicSwapsRequest) String added in v0.16.0 

func (m *QueryAtomicSwapsRequest) String() string

func (*QueryAtomicSwapsRequest) Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapsRequest) Unmarshal(dAtA []byte) error

func (*QueryAtomicSwapsRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAtomicSwapsRequest) XXX_DiscardUnknown()

func (*QueryAtomicSwapsRequest) XXX_Marshal added in v0.16.0 

func (m *QueryAtomicSwapsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAtomicSwapsRequest) XXX_Merge added in v0.16.0 

func (m *QueryAtomicSwapsRequest) XXX_Merge(src proto.Message)

func (*QueryAtomicSwapsRequest) XXX_Size added in v0.16.0 

func (m *QueryAtomicSwapsRequest) XXX_Size() int

func (*QueryAtomicSwapsRequest) XXX_Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapsRequest) XXX_Unmarshal(b []byte) error

type QueryAtomicSwapsResponse added in v0.16.0 

type QueryAtomicSwapsResponse struct {
	// atomic_swap represents the returned atomic swaps for the request
	AtomicSwaps []AtomicSwapResponse `protobuf:"bytes,1,rep,name=atomic_swaps,json=atomicSwaps,proto3" json:"atomic_swaps"`
	Pagination  *query.PageResponse  `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAtomicSwapsResponse is the response type for the Query/AtomicSwaps RPC method.

func (*QueryAtomicSwapsResponse) Descriptor added in v0.16.0 

func (*QueryAtomicSwapsResponse) Descriptor() ([]byte, []int)

func (*QueryAtomicSwapsResponse) GetAtomicSwaps added in v0.16.0 

func (m *QueryAtomicSwapsResponse) GetAtomicSwaps() []AtomicSwapResponse

func (*QueryAtomicSwapsResponse) GetPagination added in v0.16.0 

func (m *QueryAtomicSwapsResponse) GetPagination() *query.PageResponse

func (*QueryAtomicSwapsResponse) Marshal added in v0.16.0 

func (m *QueryAtomicSwapsResponse) Marshal() (dAtA []byte, err error)

func (*QueryAtomicSwapsResponse) MarshalTo added in v0.16.0 

func (m *QueryAtomicSwapsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryAtomicSwapsResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryAtomicSwapsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAtomicSwapsResponse) ProtoMessage added in v0.16.0 

func (*QueryAtomicSwapsResponse) ProtoMessage()

func (*QueryAtomicSwapsResponse) Reset added in v0.16.0 

func (m *QueryAtomicSwapsResponse) Reset()

func (*QueryAtomicSwapsResponse) Size added in v0.16.0 

func (m *QueryAtomicSwapsResponse) Size() (n int)

func (*QueryAtomicSwapsResponse) String added in v0.16.0 

func (m *QueryAtomicSwapsResponse) String() string

func (*QueryAtomicSwapsResponse) Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapsResponse) Unmarshal(dAtA []byte) error

func (*QueryAtomicSwapsResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryAtomicSwapsResponse) XXX_DiscardUnknown()

func (*QueryAtomicSwapsResponse) XXX_Marshal added in v0.16.0 

func (m *QueryAtomicSwapsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAtomicSwapsResponse) XXX_Merge added in v0.16.0 

func (m *QueryAtomicSwapsResponse) XXX_Merge(src proto.Message)

func (*QueryAtomicSwapsResponse) XXX_Size added in v0.16.0 

func (m *QueryAtomicSwapsResponse) XXX_Size() int

func (*QueryAtomicSwapsResponse) XXX_Unmarshal added in v0.16.0 

func (m *QueryAtomicSwapsResponse) XXX_Unmarshal(b []byte) error

type QueryClient added in v0.16.0 

type QueryClient interface {
	// Params queries module params
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// AssetSupply queries info about an asset's supply
	AssetSupply(ctx context.Context, in *QueryAssetSupplyRequest, opts ...grpc.CallOption) (*QueryAssetSupplyResponse, error)
	// AssetSupplies queries a list of asset supplies
	AssetSupplies(ctx context.Context, in *QueryAssetSuppliesRequest, opts ...grpc.CallOption) (*QueryAssetSuppliesResponse, error)
	// AtomicSwap queries info about an atomic swap
	AtomicSwap(ctx context.Context, in *QueryAtomicSwapRequest, opts ...grpc.CallOption) (*QueryAtomicSwapResponse, error)
	// AtomicSwaps queries a list of atomic swaps
	AtomicSwaps(ctx context.Context, in *QueryAtomicSwapsRequest, opts ...grpc.CallOption) (*QueryAtomicSwapsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient added in v0.16.0 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryParamsRequest added in v0.16.0 

type QueryParamsRequest struct {
}

QueryParamsRequest defines the request type for querying x/bep3 parameters.

func (*QueryParamsRequest) Descriptor added in v0.16.0 

func (*QueryParamsRequest) Descriptor() ([]byte, []int)

func (*QueryParamsRequest) Marshal added in v0.16.0 

func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)

func (*QueryParamsRequest) MarshalTo added in v0.16.0 

func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryParamsRequest) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsRequest) ProtoMessage added in v0.16.0 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset added in v0.16.0 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size added in v0.16.0 

func (m *QueryParamsRequest) Size() (n int)

func (*QueryParamsRequest) String added in v0.16.0 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal added in v0.16.0 

func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error

func (*QueryParamsRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal added in v0.16.0 

func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryParamsRequest) XXX_Merge added in v0.16.0 

func (m *QueryParamsRequest) XXX_Merge(src proto.Message)

func (*QueryParamsRequest) XXX_Size added in v0.16.0 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal added in v0.16.0 

func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error

type QueryParamsResponse added in v0.16.0 

type QueryParamsResponse struct {
	// params represents the parameters of the module
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse defines the response type for querying x/bep3 parameters.

func (*QueryParamsResponse) Descriptor added in v0.16.0 

func (*QueryParamsResponse) Descriptor() ([]byte, []int)

func (*QueryParamsResponse) GetParams added in v0.16.0 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal added in v0.16.0 

func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)

func (*QueryParamsResponse) MarshalTo added in v0.16.0 

func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryParamsResponse) MarshalToSizedBuffer added in v0.16.0 

func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsResponse) ProtoMessage added in v0.16.0 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset added in v0.16.0 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size added in v0.16.0 

func (m *QueryParamsResponse) Size() (n int)

func (*QueryParamsResponse) String added in v0.16.0 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal added in v0.16.0 

func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error

func (*QueryParamsResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal added in v0.16.0 

func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryParamsResponse) XXX_Merge added in v0.16.0 

func (m *QueryParamsResponse) XXX_Merge(src proto.Message)

func (*QueryParamsResponse) XXX_Size added in v0.16.0 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal added in v0.16.0 

func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error

type QueryServer added in v0.16.0 

type QueryServer interface {
	// Params queries module params
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// AssetSupply queries info about an asset's supply
	AssetSupply(context.Context, *QueryAssetSupplyRequest) (*QueryAssetSupplyResponse, error)
	// AssetSupplies queries a list of asset supplies
	AssetSupplies(context.Context, *QueryAssetSuppliesRequest) (*QueryAssetSuppliesResponse, error)
	// AtomicSwap queries info about an atomic swap
	AtomicSwap(context.Context, *QueryAtomicSwapRequest) (*QueryAtomicSwapResponse, error)
	// AtomicSwaps queries a list of atomic swaps
	AtomicSwaps(context.Context, *QueryAtomicSwapsRequest) (*QueryAtomicSwapsResponse, error)
}

QueryServer is the server API for Query service.

type SupplyLimit added in v0.11.0 

type SupplyLimit struct {
	// limit defines the total supply allowed
	Limit github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=limit,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"limit"`
	// time_limited enables or disables time based supply limiting
	TimeLimited bool `protobuf:"varint,2,opt,name=time_limited,json=timeLimited,proto3" json:"time_limited,omitempty"`
	// time_period specifies the duration that time_based_limit is evalulated
	TimePeriod time.Duration `protobuf:"bytes,3,opt,name=time_period,json=timePeriod,proto3,stdduration" json:"time_period"`
	// time_based_limit defines the maximum supply that can be swapped within time_period
	TimeBasedLimit github_com_cosmos_cosmos_sdk_types.Int `` /* 145-byte string literal not displayed */
}

SupplyLimit define the absolute and time-based limits for an assets's supply.

func (*SupplyLimit) Descriptor added in v0.16.0 

func (*SupplyLimit) Descriptor() ([]byte, []int)

func (SupplyLimit) Equals added in v0.11.0 

func (sl SupplyLimit) Equals(sl2 SupplyLimit) bool

Equals returns true if two supply limits are equal

func (*SupplyLimit) GetTimeLimited added in v0.16.0 

func (m *SupplyLimit) GetTimeLimited() bool

func (*SupplyLimit) GetTimePeriod added in v0.16.0 

func (m *SupplyLimit) GetTimePeriod() time.Duration

func (*SupplyLimit) Marshal added in v0.16.0 

func (m *SupplyLimit) Marshal() (dAtA []byte, err error)

func (*SupplyLimit) MarshalTo added in v0.16.0 

func (m *SupplyLimit) MarshalTo(dAtA []byte) (int, error)

func (*SupplyLimit) MarshalToSizedBuffer added in v0.16.0 

func (m *SupplyLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SupplyLimit) ProtoMessage added in v0.16.0 

func (*SupplyLimit) ProtoMessage()

func (*SupplyLimit) Reset added in v0.16.0 

func (m *SupplyLimit) Reset()

func (*SupplyLimit) Size added in v0.16.0 

func (m *SupplyLimit) Size() (n int)

func (*SupplyLimit) String added in v0.11.0 

func (m *SupplyLimit) String() string

func (*SupplyLimit) Unmarshal added in v0.16.0 

func (m *SupplyLimit) Unmarshal(dAtA []byte) error

func (*SupplyLimit) XXX_DiscardUnknown added in v0.16.0 

func (m *SupplyLimit) XXX_DiscardUnknown()

func (*SupplyLimit) XXX_Marshal added in v0.16.0 

func (m *SupplyLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SupplyLimit) XXX_Merge added in v0.16.0 

func (m *SupplyLimit) XXX_Merge(src proto.Message)

func (*SupplyLimit) XXX_Size added in v0.16.0 

func (m *SupplyLimit) XXX_Size() int

func (*SupplyLimit) XXX_Unmarshal added in v0.16.0 

func (m *SupplyLimit) XXX_Unmarshal(b []byte) error

type SwapDirection 

type SwapDirection int32

SwapDirection is the direction of an AtomicSwap 

const (
	// SWAP_DIRECTION_UNSPECIFIED represents unspecified or invalid swap direcation
	SWAP_DIRECTION_UNSPECIFIED SwapDirection = 0
	// SWAP_DIRECTION_INCOMING represents is incoming swap (to the kava chain)
	SWAP_DIRECTION_INCOMING SwapDirection = 1
	// SWAP_DIRECTION_OUTGOING represents an outgoing swap (from the kava chain)
	SWAP_DIRECTION_OUTGOING SwapDirection = 2
)

func NewSwapDirectionFromString 

func NewSwapDirectionFromString(str string) SwapDirection

NewSwapDirectionFromString converts string to SwapDirection type

func (SwapDirection) EnumDescriptor added in v0.16.0 

func (SwapDirection) EnumDescriptor() ([]byte, []int)

func (SwapDirection) IsValid added in v0.8.0 

func (direction SwapDirection) IsValid() bool

IsValid returns true if the swap direction is valid and false otherwise.

func (SwapDirection) String 

func (x SwapDirection) String() string

type SwapStatus 

type SwapStatus int32

SwapStatus is the status of an AtomicSwap 

const (
	// SWAP_STATUS_UNSPECIFIED represents an unspecified status
	SWAP_STATUS_UNSPECIFIED SwapStatus = 0
	// SWAP_STATUS_OPEN represents an open swap
	SWAP_STATUS_OPEN SwapStatus = 1
	// SWAP_STATUS_COMPLETED represents a completed swap
	SWAP_STATUS_COMPLETED SwapStatus = 2
	// SWAP_STATUS_EXPIRED represents an expired swap
	SWAP_STATUS_EXPIRED SwapStatus = 3
)

func NewSwapStatusFromString 

func NewSwapStatusFromString(str string) SwapStatus

NewSwapStatusFromString converts string to SwapStatus type

func (SwapStatus) EnumDescriptor added in v0.16.0 

func (SwapStatus) EnumDescriptor() ([]byte, []int)

func (SwapStatus) IsValid added in v0.8.0 

func (status SwapStatus) IsValid() bool

IsValid returns true if the swap status is valid and false otherwise.

func (SwapStatus) String 

func (x SwapStatus) String() string

type UnimplementedMsgServer added in v0.16.0 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ClaimAtomicSwap added in v0.16.0 

func (*UnimplementedMsgServer) ClaimAtomicSwap(ctx context.Context, req *MsgClaimAtomicSwap) (*MsgClaimAtomicSwapResponse, error)

func (*UnimplementedMsgServer) CreateAtomicSwap added in v0.16.0 

func (*UnimplementedMsgServer) CreateAtomicSwap(ctx context.Context, req *MsgCreateAtomicSwap) (*MsgCreateAtomicSwapResponse, error)

func (*UnimplementedMsgServer) RefundAtomicSwap added in v0.16.0 

func (*UnimplementedMsgServer) RefundAtomicSwap(ctx context.Context, req *MsgRefundAtomicSwap) (*MsgRefundAtomicSwapResponse, error)

type UnimplementedQueryServer added in v0.16.0 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AssetSupplies added in v0.16.0 

func (*UnimplementedQueryServer) AssetSupplies(ctx context.Context, req *QueryAssetSuppliesRequest) (*QueryAssetSuppliesResponse, error)

func (*UnimplementedQueryServer) AssetSupply added in v0.16.0 

func (*UnimplementedQueryServer) AssetSupply(ctx context.Context, req *QueryAssetSupplyRequest) (*QueryAssetSupplyResponse, error)

func (*UnimplementedQueryServer) AtomicSwap added in v0.16.0 

func (*UnimplementedQueryServer) AtomicSwap(ctx context.Context, req *QueryAtomicSwapRequest) (*QueryAtomicSwapResponse, error)

func (*UnimplementedQueryServer) AtomicSwaps added in v0.16.0 

func (*UnimplementedQueryServer) AtomicSwaps(ctx context.Context, req *QueryAtomicSwapsRequest) (*QueryAtomicSwapsResponse, error)

func (*UnimplementedQueryServer) Params added in v0.16.0 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

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.