types

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Jul 19, 2023 License: Apache-2.0 Imports: 45 Imported by: 0

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("FuryAtomicSwapCoins")))
)

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 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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 

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 

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 

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 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

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 fury 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 

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 

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

func (*AssetParam) GetActive 

func (m *AssetParam) GetActive() bool

func (*AssetParam) GetCoinID 

func (m *AssetParam) GetCoinID() int64

func (*AssetParam) GetDenom 

func (m *AssetParam) GetDenom() string

func (*AssetParam) GetDeputyAddress 

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

func (*AssetParam) GetMaxBlockLock 

func (m *AssetParam) GetMaxBlockLock() uint64

func (*AssetParam) GetMinBlockLock 

func (m *AssetParam) GetMinBlockLock() uint64

func (*AssetParam) GetSupplyLimit 

func (m *AssetParam) GetSupplyLimit() SupplyLimit

func (*AssetParam) Marshal 

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

func (*AssetParam) MarshalTo 

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

func (*AssetParam) MarshalToSizedBuffer 

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

func (*AssetParam) ProtoMessage 

func (*AssetParam) ProtoMessage()

func (*AssetParam) Reset 

func (m *AssetParam) Reset()

func (*AssetParam) Size 

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

func (*AssetParam) String 

func (m *AssetParam) String() string

func (*AssetParam) Unmarshal 

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

func (*AssetParam) XXX_DiscardUnknown 

func (m *AssetParam) XXX_DiscardUnknown()

func (*AssetParam) XXX_Marshal 

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

func (*AssetParam) XXX_Merge 

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

func (*AssetParam) XXX_Size 

func (m *AssetParam) XXX_Size() int

func (*AssetParam) XXX_Unmarshal 

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 

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

func (AssetSupply) Equal 

func (a AssetSupply) Equal(b AssetSupply) bool

Equal returns if two asset supplies are equal

func (*AssetSupply) GetCurrentSupply 

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

func (AssetSupply) GetDenom 

func (a AssetSupply) GetDenom() string

GetDenom getter method for the denom of the asset supply

func (*AssetSupply) GetIncomingSupply 

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

func (*AssetSupply) GetOutgoingSupply 

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

func (*AssetSupply) GetTimeElapsed 

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

func (*AssetSupply) GetTimeLimitedCurrentSupply 

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

func (*AssetSupply) Marshal 

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

func (*AssetSupply) MarshalTo 

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

func (*AssetSupply) MarshalToSizedBuffer 

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

func (*AssetSupply) ProtoMessage 

func (*AssetSupply) ProtoMessage()

func (*AssetSupply) Reset 

func (m *AssetSupply) Reset()

func (*AssetSupply) Size 

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

func (*AssetSupply) String 

func (m *AssetSupply) String() string

func (*AssetSupply) Unmarshal 

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

func (AssetSupply) Validate 

func (a AssetSupply) Validate() error

Validate performs a basic validation of an asset supply fields.

func (*AssetSupply) XXX_DiscardUnknown 

func (m *AssetSupply) XXX_DiscardUnknown()

func (*AssetSupply) XXX_Marshal 

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

func (*AssetSupply) XXX_Merge 

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

func (*AssetSupply) XXX_Size 

func (m *AssetSupply) XXX_Size() int

func (*AssetSupply) XXX_Unmarshal 

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

type AssetSupplyResponse 

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 

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

func (*AssetSupplyResponse) GetCurrentSupply 

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

func (*AssetSupplyResponse) GetIncomingSupply 

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

func (*AssetSupplyResponse) GetOutgoingSupply 

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

func (*AssetSupplyResponse) GetTimeElapsed 

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

func (*AssetSupplyResponse) GetTimeLimitedCurrentSupply 

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

func (*AssetSupplyResponse) Marshal 

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

func (*AssetSupplyResponse) MarshalTo 

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

func (*AssetSupplyResponse) MarshalToSizedBuffer 

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

func (*AssetSupplyResponse) ProtoMessage 

func (*AssetSupplyResponse) ProtoMessage()

func (*AssetSupplyResponse) Reset 

func (m *AssetSupplyResponse) Reset()

func (*AssetSupplyResponse) Size 

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

func (*AssetSupplyResponse) String 

func (m *AssetSupplyResponse) String() string

func (*AssetSupplyResponse) Unmarshal 

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

func (*AssetSupplyResponse) XXX_DiscardUnknown 

func (m *AssetSupplyResponse) XXX_DiscardUnknown()

func (*AssetSupplyResponse) XXX_Marshal 

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

func (*AssetSupplyResponse) XXX_Merge 

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

func (*AssetSupplyResponse) XXX_Size 

func (m *AssetSupplyResponse) XXX_Size() int

func (*AssetSupplyResponse) XXX_Unmarshal 

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 fury 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 fury 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=fury.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=fury.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 

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

func (*AtomicSwap) GetAmount 

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

func (*AtomicSwap) GetClosedBlock 

func (m *AtomicSwap) GetClosedBlock() int64

func (AtomicSwap) GetCoins 

func (a AtomicSwap) GetCoins() sdk.Coins

GetCoins returns the swap's amount as sdk.Coins

func (*AtomicSwap) GetCrossChain 

func (m *AtomicSwap) GetCrossChain() bool

func (*AtomicSwap) GetDirection 

func (m *AtomicSwap) GetDirection() SwapDirection

func (*AtomicSwap) GetExpireHeight 

func (m *AtomicSwap) GetExpireHeight() uint64

func (*AtomicSwap) GetRandomNumberHash 

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

func (*AtomicSwap) GetRecipient 

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

func (*AtomicSwap) GetRecipientOtherChain 

func (m *AtomicSwap) GetRecipientOtherChain() string

func (*AtomicSwap) GetSender 

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

func (*AtomicSwap) GetSenderOtherChain 

func (m *AtomicSwap) GetSenderOtherChain() string

func (*AtomicSwap) GetStatus 

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 

func (m *AtomicSwap) GetTimestamp() int64

func (*AtomicSwap) Marshal 

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

func (*AtomicSwap) MarshalTo 

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

func (*AtomicSwap) MarshalToSizedBuffer 

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

func (*AtomicSwap) ProtoMessage 

func (*AtomicSwap) ProtoMessage()

func (*AtomicSwap) Reset 

func (m *AtomicSwap) Reset()

func (*AtomicSwap) Size 

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

func (*AtomicSwap) String 

func (m *AtomicSwap) String() string

func (*AtomicSwap) Unmarshal 

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 

func (m *AtomicSwap) XXX_DiscardUnknown()

func (*AtomicSwap) XXX_Marshal 

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

func (*AtomicSwap) XXX_Merge 

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

func (*AtomicSwap) XXX_Size 

func (m *AtomicSwap) XXX_Size() int

func (*AtomicSwap) XXX_Unmarshal 

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

type AtomicSwapResponse 

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 fury chain sender of the swap
	Sender string `protobuf:"bytes,6,opt,name=sender,proto3" json:"sender,omitempty"`
	// recipient is the fury 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=fury.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=fury.bep3.v1beta1.SwapDirection" json:"direction,omitempty"`
}

AtomicSwapResponse represents the returned atomic swap properties

func (*AtomicSwapResponse) Descriptor 

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

func (*AtomicSwapResponse) GetAmount 

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

func (*AtomicSwapResponse) GetClosedBlock 

func (m *AtomicSwapResponse) GetClosedBlock() int64

func (*AtomicSwapResponse) GetCrossChain 

func (m *AtomicSwapResponse) GetCrossChain() bool

func (*AtomicSwapResponse) GetDirection 

func (m *AtomicSwapResponse) GetDirection() SwapDirection

func (*AtomicSwapResponse) GetExpireHeight 

func (m *AtomicSwapResponse) GetExpireHeight() uint64

func (*AtomicSwapResponse) GetId 

func (m *AtomicSwapResponse) GetId() string

func (*AtomicSwapResponse) GetRandomNumberHash 

func (m *AtomicSwapResponse) GetRandomNumberHash() string

func (*AtomicSwapResponse) GetRecipient 

func (m *AtomicSwapResponse) GetRecipient() string

func (*AtomicSwapResponse) GetRecipientOtherChain 

func (m *AtomicSwapResponse) GetRecipientOtherChain() string

func (*AtomicSwapResponse) GetSender 

func (m *AtomicSwapResponse) GetSender() string

func (*AtomicSwapResponse) GetSenderOtherChain 

func (m *AtomicSwapResponse) GetSenderOtherChain() string

func (*AtomicSwapResponse) GetStatus 

func (m *AtomicSwapResponse) GetStatus() SwapStatus

func (*AtomicSwapResponse) GetTimestamp 

func (m *AtomicSwapResponse) GetTimestamp() int64

func (*AtomicSwapResponse) Marshal 

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

func (*AtomicSwapResponse) MarshalTo 

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

func (*AtomicSwapResponse) MarshalToSizedBuffer 

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

func (*AtomicSwapResponse) ProtoMessage 

func (*AtomicSwapResponse) ProtoMessage()

func (*AtomicSwapResponse) Reset 

func (m *AtomicSwapResponse) Reset()

func (*AtomicSwapResponse) Size 

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

func (*AtomicSwapResponse) String 

func (m *AtomicSwapResponse) String() string

func (*AtomicSwapResponse) Unmarshal 

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

func (*AtomicSwapResponse) XXX_DiscardUnknown 

func (m *AtomicSwapResponse) XXX_DiscardUnknown()

func (*AtomicSwapResponse) XXX_Marshal 

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

func (*AtomicSwapResponse) XXX_Merge 

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

func (*AtomicSwapResponse) XXX_Size 

func (m *AtomicSwapResponse) XXX_Size() int

func (*AtomicSwapResponse) XXX_Unmarshal 

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

type AtomicSwaps 

type AtomicSwaps []AtomicSwap

AtomicSwaps is a slice of AtomicSwap

type BankKeeper 

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 

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

func (*GenesisState) GetAtomicSwaps 

func (m *GenesisState) GetAtomicSwaps() AtomicSwaps

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPreviousBlockTime 

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

func (*GenesisState) GetSupplies 

func (m *GenesisState) GetSupplies() AssetSupplies

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type LegacyAugmentedAtomicSwap 

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 

func NewLegacyAugmentedAtomicSwap(swap AtomicSwap) LegacyAugmentedAtomicSwap

type LegacyAugmentedAtomicSwaps 

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 

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 

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

func (*MsgClaimAtomicSwap) MarshalTo 

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

func (*MsgClaimAtomicSwap) MarshalToSizedBuffer 

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

func (*MsgClaimAtomicSwap) ProtoMessage 

func (*MsgClaimAtomicSwap) ProtoMessage()

func (*MsgClaimAtomicSwap) Reset 

func (m *MsgClaimAtomicSwap) Reset()

func (MsgClaimAtomicSwap) Route 

func (msg MsgClaimAtomicSwap) Route() string

Route establishes the route for the MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Size 

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 

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

func (MsgClaimAtomicSwap) ValidateBasic 

func (msg MsgClaimAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) XXX_DiscardUnknown 

func (m *MsgClaimAtomicSwap) XXX_DiscardUnknown()

func (*MsgClaimAtomicSwap) XXX_Marshal 

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

func (*MsgClaimAtomicSwap) XXX_Merge 

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

func (*MsgClaimAtomicSwap) XXX_Size 

func (m *MsgClaimAtomicSwap) XXX_Size() int

func (*MsgClaimAtomicSwap) XXX_Unmarshal 

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

type MsgClaimAtomicSwapResponse 

type MsgClaimAtomicSwapResponse struct {
}

MsgClaimAtomicSwapResponse defines the Msg/ClaimAtomicSwap response type.

func (*MsgClaimAtomicSwapResponse) Descriptor 

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

func (*MsgClaimAtomicSwapResponse) Marshal 

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

func (*MsgClaimAtomicSwapResponse) MarshalTo 

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

func (*MsgClaimAtomicSwapResponse) MarshalToSizedBuffer 

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

func (*MsgClaimAtomicSwapResponse) ProtoMessage 

func (*MsgClaimAtomicSwapResponse) ProtoMessage()

func (*MsgClaimAtomicSwapResponse) Reset 

func (m *MsgClaimAtomicSwapResponse) Reset()

func (*MsgClaimAtomicSwapResponse) Size 

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

func (*MsgClaimAtomicSwapResponse) String 

func (m *MsgClaimAtomicSwapResponse) String() string

func (*MsgClaimAtomicSwapResponse) Unmarshal 

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

func (*MsgClaimAtomicSwapResponse) XXX_DiscardUnknown 

func (m *MsgClaimAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgClaimAtomicSwapResponse) XXX_Marshal 

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

func (*MsgClaimAtomicSwapResponse) XXX_Merge 

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

func (*MsgClaimAtomicSwapResponse) XXX_Size 

func (m *MsgClaimAtomicSwapResponse) XXX_Size() int

func (*MsgClaimAtomicSwapResponse) XXX_Unmarshal 

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

type MsgClient 

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 

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 

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 

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

func (*MsgCreateAtomicSwap) MarshalTo 

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

func (*MsgCreateAtomicSwap) MarshalToSizedBuffer 

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

func (*MsgCreateAtomicSwap) ProtoMessage 

func (*MsgCreateAtomicSwap) ProtoMessage()

func (*MsgCreateAtomicSwap) Reset 

func (m *MsgCreateAtomicSwap) Reset()

func (MsgCreateAtomicSwap) Route 

func (msg MsgCreateAtomicSwap) Route() string

Route establishes the route for the MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Size 

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 

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

func (MsgCreateAtomicSwap) ValidateBasic 

func (msg MsgCreateAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) XXX_DiscardUnknown 

func (m *MsgCreateAtomicSwap) XXX_DiscardUnknown()

func (*MsgCreateAtomicSwap) XXX_Marshal 

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

func (*MsgCreateAtomicSwap) XXX_Merge 

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

func (*MsgCreateAtomicSwap) XXX_Size 

func (m *MsgCreateAtomicSwap) XXX_Size() int

func (*MsgCreateAtomicSwap) XXX_Unmarshal 

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

type MsgCreateAtomicSwapResponse 

type MsgCreateAtomicSwapResponse struct {
}

MsgCreateAtomicSwapResponse defines the Msg/CreateAtomicSwap response type.

func (*MsgCreateAtomicSwapResponse) Descriptor 

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

func (*MsgCreateAtomicSwapResponse) Marshal 

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

func (*MsgCreateAtomicSwapResponse) MarshalTo 

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

func (*MsgCreateAtomicSwapResponse) MarshalToSizedBuffer 

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

func (*MsgCreateAtomicSwapResponse) ProtoMessage 

func (*MsgCreateAtomicSwapResponse) ProtoMessage()

func (*MsgCreateAtomicSwapResponse) Reset 

func (m *MsgCreateAtomicSwapResponse) Reset()

func (*MsgCreateAtomicSwapResponse) Size 

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

func (*MsgCreateAtomicSwapResponse) String 

func (m *MsgCreateAtomicSwapResponse) String() string

func (*MsgCreateAtomicSwapResponse) Unmarshal 

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

func (*MsgCreateAtomicSwapResponse) XXX_DiscardUnknown 

func (m *MsgCreateAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgCreateAtomicSwapResponse) XXX_Marshal 

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

func (*MsgCreateAtomicSwapResponse) XXX_Merge 

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

func (*MsgCreateAtomicSwapResponse) XXX_Size 

func (m *MsgCreateAtomicSwapResponse) XXX_Size() int

func (*MsgCreateAtomicSwapResponse) XXX_Unmarshal 

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 

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 

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

func (*MsgRefundAtomicSwap) MarshalTo 

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

func (*MsgRefundAtomicSwap) MarshalToSizedBuffer 

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

func (*MsgRefundAtomicSwap) ProtoMessage 

func (*MsgRefundAtomicSwap) ProtoMessage()

func (*MsgRefundAtomicSwap) Reset 

func (m *MsgRefundAtomicSwap) Reset()

func (MsgRefundAtomicSwap) Route 

func (msg MsgRefundAtomicSwap) Route() string

Route establishes the route for the MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Size 

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 

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

func (MsgRefundAtomicSwap) ValidateBasic 

func (msg MsgRefundAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) XXX_DiscardUnknown 

func (m *MsgRefundAtomicSwap) XXX_DiscardUnknown()

func (*MsgRefundAtomicSwap) XXX_Marshal 

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

func (*MsgRefundAtomicSwap) XXX_Merge 

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

func (*MsgRefundAtomicSwap) XXX_Size 

func (m *MsgRefundAtomicSwap) XXX_Size() int

func (*MsgRefundAtomicSwap) XXX_Unmarshal 

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

type MsgRefundAtomicSwapResponse 

type MsgRefundAtomicSwapResponse struct {
}

MsgRefundAtomicSwapResponse defines the Msg/RefundAtomicSwap response type.

func (*MsgRefundAtomicSwapResponse) Descriptor 

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

func (*MsgRefundAtomicSwapResponse) Marshal 

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

func (*MsgRefundAtomicSwapResponse) MarshalTo 

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

func (*MsgRefundAtomicSwapResponse) MarshalToSizedBuffer 

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

func (*MsgRefundAtomicSwapResponse) ProtoMessage 

func (*MsgRefundAtomicSwapResponse) ProtoMessage()

func (*MsgRefundAtomicSwapResponse) Reset 

func (m *MsgRefundAtomicSwapResponse) Reset()

func (*MsgRefundAtomicSwapResponse) Size 

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

func (*MsgRefundAtomicSwapResponse) String 

func (m *MsgRefundAtomicSwapResponse) String() string

func (*MsgRefundAtomicSwapResponse) Unmarshal 

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

func (*MsgRefundAtomicSwapResponse) XXX_DiscardUnknown 

func (m *MsgRefundAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgRefundAtomicSwapResponse) XXX_Marshal 

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

func (*MsgRefundAtomicSwapResponse) XXX_Merge 

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

func (*MsgRefundAtomicSwapResponse) XXX_Size 

func (m *MsgRefundAtomicSwapResponse) XXX_Size() int

func (*MsgRefundAtomicSwapResponse) XXX_Unmarshal 

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

type MsgServer 

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 

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

func (*Params) GetAssetParams 

func (m *Params) GetAssetParams() AssetParams

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryAssetSupplies 

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 

func NewQueryAssetSupplies(page int, limit int) QueryAssetSupplies

NewQueryAssetSupplies creates a new QueryAssetSupplies

type QueryAssetSuppliesRequest 

type QueryAssetSuppliesRequest struct {
}

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

func (*QueryAssetSuppliesRequest) Descriptor 

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

func (*QueryAssetSuppliesRequest) Marshal 

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

func (*QueryAssetSuppliesRequest) MarshalTo 

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

func (*QueryAssetSuppliesRequest) MarshalToSizedBuffer 

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

func (*QueryAssetSuppliesRequest) ProtoMessage 

func (*QueryAssetSuppliesRequest) ProtoMessage()

func (*QueryAssetSuppliesRequest) Reset 

func (m *QueryAssetSuppliesRequest) Reset()

func (*QueryAssetSuppliesRequest) Size 

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

func (*QueryAssetSuppliesRequest) String 

func (m *QueryAssetSuppliesRequest) String() string

func (*QueryAssetSuppliesRequest) Unmarshal 

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

func (*QueryAssetSuppliesRequest) XXX_DiscardUnknown 

func (m *QueryAssetSuppliesRequest) XXX_DiscardUnknown()

func (*QueryAssetSuppliesRequest) XXX_Marshal 

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

func (*QueryAssetSuppliesRequest) XXX_Merge 

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

func (*QueryAssetSuppliesRequest) XXX_Size 

func (m *QueryAssetSuppliesRequest) XXX_Size() int

func (*QueryAssetSuppliesRequest) XXX_Unmarshal 

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

type QueryAssetSuppliesResponse 

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 

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

func (*QueryAssetSuppliesResponse) GetAssetSupplies 

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

func (*QueryAssetSuppliesResponse) Marshal 

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

func (*QueryAssetSuppliesResponse) MarshalTo 

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

func (*QueryAssetSuppliesResponse) MarshalToSizedBuffer 

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

func (*QueryAssetSuppliesResponse) ProtoMessage 

func (*QueryAssetSuppliesResponse) ProtoMessage()

func (*QueryAssetSuppliesResponse) Reset 

func (m *QueryAssetSuppliesResponse) Reset()

func (*QueryAssetSuppliesResponse) Size 

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

func (*QueryAssetSuppliesResponse) String 

func (m *QueryAssetSuppliesResponse) String() string

func (*QueryAssetSuppliesResponse) Unmarshal 

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

func (*QueryAssetSuppliesResponse) XXX_DiscardUnknown 

func (m *QueryAssetSuppliesResponse) XXX_DiscardUnknown()

func (*QueryAssetSuppliesResponse) XXX_Marshal 

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

func (*QueryAssetSuppliesResponse) XXX_Merge 

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

func (*QueryAssetSuppliesResponse) XXX_Size 

func (m *QueryAssetSuppliesResponse) XXX_Size() int

func (*QueryAssetSuppliesResponse) XXX_Unmarshal 

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 

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 

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

func (*QueryAssetSupplyRequest) Marshal 

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

func (*QueryAssetSupplyRequest) MarshalTo 

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

func (*QueryAssetSupplyRequest) MarshalToSizedBuffer 

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

func (*QueryAssetSupplyRequest) ProtoMessage 

func (*QueryAssetSupplyRequest) ProtoMessage()

func (*QueryAssetSupplyRequest) Reset 

func (m *QueryAssetSupplyRequest) Reset()

func (*QueryAssetSupplyRequest) Size 

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

func (*QueryAssetSupplyRequest) String 

func (m *QueryAssetSupplyRequest) String() string

func (*QueryAssetSupplyRequest) Unmarshal 

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

func (*QueryAssetSupplyRequest) XXX_DiscardUnknown 

func (m *QueryAssetSupplyRequest) XXX_DiscardUnknown()

func (*QueryAssetSupplyRequest) XXX_Marshal 

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

func (*QueryAssetSupplyRequest) XXX_Merge 

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

func (*QueryAssetSupplyRequest) XXX_Size 

func (m *QueryAssetSupplyRequest) XXX_Size() int

func (*QueryAssetSupplyRequest) XXX_Unmarshal 

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

type QueryAssetSupplyResponse 

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 

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

func (*QueryAssetSupplyResponse) GetAssetSupply 

func (m *QueryAssetSupplyResponse) GetAssetSupply() AssetSupplyResponse

func (*QueryAssetSupplyResponse) Marshal 

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

func (*QueryAssetSupplyResponse) MarshalTo 

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

func (*QueryAssetSupplyResponse) MarshalToSizedBuffer 

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

func (*QueryAssetSupplyResponse) ProtoMessage 

func (*QueryAssetSupplyResponse) ProtoMessage()

func (*QueryAssetSupplyResponse) Reset 

func (m *QueryAssetSupplyResponse) Reset()

func (*QueryAssetSupplyResponse) Size 

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

func (*QueryAssetSupplyResponse) String 

func (m *QueryAssetSupplyResponse) String() string

func (*QueryAssetSupplyResponse) Unmarshal 

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

func (*QueryAssetSupplyResponse) XXX_DiscardUnknown 

func (m *QueryAssetSupplyResponse) XXX_DiscardUnknown()

func (*QueryAssetSupplyResponse) XXX_Marshal 

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

func (*QueryAssetSupplyResponse) XXX_Merge 

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

func (*QueryAssetSupplyResponse) XXX_Size 

func (m *QueryAssetSupplyResponse) XXX_Size() int

func (*QueryAssetSupplyResponse) XXX_Unmarshal 

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 

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 

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

func (*QueryAtomicSwapRequest) Marshal 

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

func (*QueryAtomicSwapRequest) MarshalTo 

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

func (*QueryAtomicSwapRequest) MarshalToSizedBuffer 

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

func (*QueryAtomicSwapRequest) ProtoMessage 

func (*QueryAtomicSwapRequest) ProtoMessage()

func (*QueryAtomicSwapRequest) Reset 

func (m *QueryAtomicSwapRequest) Reset()

func (*QueryAtomicSwapRequest) Size 

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

func (*QueryAtomicSwapRequest) String 

func (m *QueryAtomicSwapRequest) String() string

func (*QueryAtomicSwapRequest) Unmarshal 

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

func (*QueryAtomicSwapRequest) XXX_DiscardUnknown 

func (m *QueryAtomicSwapRequest) XXX_DiscardUnknown()

func (*QueryAtomicSwapRequest) XXX_Marshal 

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

func (*QueryAtomicSwapRequest) XXX_Merge 

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

func (*QueryAtomicSwapRequest) XXX_Size 

func (m *QueryAtomicSwapRequest) XXX_Size() int

func (*QueryAtomicSwapRequest) XXX_Unmarshal 

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

type QueryAtomicSwapResponse 

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 

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

func (*QueryAtomicSwapResponse) GetAtomicSwap 

func (m *QueryAtomicSwapResponse) GetAtomicSwap() AtomicSwapResponse

func (*QueryAtomicSwapResponse) Marshal 

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

func (*QueryAtomicSwapResponse) MarshalTo 

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

func (*QueryAtomicSwapResponse) MarshalToSizedBuffer 

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

func (*QueryAtomicSwapResponse) ProtoMessage 

func (*QueryAtomicSwapResponse) ProtoMessage()

func (*QueryAtomicSwapResponse) Reset 

func (m *QueryAtomicSwapResponse) Reset()

func (*QueryAtomicSwapResponse) Size 

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

func (*QueryAtomicSwapResponse) String 

func (m *QueryAtomicSwapResponse) String() string

func (*QueryAtomicSwapResponse) Unmarshal 

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

func (*QueryAtomicSwapResponse) XXX_DiscardUnknown 

func (m *QueryAtomicSwapResponse) XXX_DiscardUnknown()

func (*QueryAtomicSwapResponse) XXX_Marshal 

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

func (*QueryAtomicSwapResponse) XXX_Merge 

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

func (*QueryAtomicSwapResponse) XXX_Size 

func (m *QueryAtomicSwapResponse) XXX_Size() int

func (*QueryAtomicSwapResponse) XXX_Unmarshal 

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 

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=fury.bep3.v1beta1.SwapStatus" json:"status,omitempty"`
	// direction fitlers by swap direction
	Direction  SwapDirection      `protobuf:"varint,4,opt,name=direction,proto3,enum=fury.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 

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

func (*QueryAtomicSwapsRequest) Marshal 

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

func (*QueryAtomicSwapsRequest) MarshalTo 

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

func (*QueryAtomicSwapsRequest) MarshalToSizedBuffer 

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

func (*QueryAtomicSwapsRequest) ProtoMessage 

func (*QueryAtomicSwapsRequest) ProtoMessage()

func (*QueryAtomicSwapsRequest) Reset 

func (m *QueryAtomicSwapsRequest) Reset()

func (*QueryAtomicSwapsRequest) Size 

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

func (*QueryAtomicSwapsRequest) String 

func (m *QueryAtomicSwapsRequest) String() string

func (*QueryAtomicSwapsRequest) Unmarshal 

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

func (*QueryAtomicSwapsRequest) XXX_DiscardUnknown 

func (m *QueryAtomicSwapsRequest) XXX_DiscardUnknown()

func (*QueryAtomicSwapsRequest) XXX_Marshal 

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

func (*QueryAtomicSwapsRequest) XXX_Merge 

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

func (*QueryAtomicSwapsRequest) XXX_Size 

func (m *QueryAtomicSwapsRequest) XXX_Size() int

func (*QueryAtomicSwapsRequest) XXX_Unmarshal 

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

type QueryAtomicSwapsResponse 

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 

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

func (*QueryAtomicSwapsResponse) GetAtomicSwaps 

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

func (*QueryAtomicSwapsResponse) GetPagination 

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

func (*QueryAtomicSwapsResponse) Marshal 

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

func (*QueryAtomicSwapsResponse) MarshalTo 

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

func (*QueryAtomicSwapsResponse) MarshalToSizedBuffer 

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

func (*QueryAtomicSwapsResponse) ProtoMessage 

func (*QueryAtomicSwapsResponse) ProtoMessage()

func (*QueryAtomicSwapsResponse) Reset 

func (m *QueryAtomicSwapsResponse) Reset()

func (*QueryAtomicSwapsResponse) Size 

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

func (*QueryAtomicSwapsResponse) String 

func (m *QueryAtomicSwapsResponse) String() string

func (*QueryAtomicSwapsResponse) Unmarshal 

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

func (*QueryAtomicSwapsResponse) XXX_DiscardUnknown 

func (m *QueryAtomicSwapsResponse) XXX_DiscardUnknown()

func (*QueryAtomicSwapsResponse) XXX_Marshal 

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

func (*QueryAtomicSwapsResponse) XXX_Merge 

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

func (*QueryAtomicSwapsResponse) XXX_Size 

func (m *QueryAtomicSwapsResponse) XXX_Size() int

func (*QueryAtomicSwapsResponse) XXX_Unmarshal 

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

type QueryClient 

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 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

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 

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 

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

func (SupplyLimit) Equals 

func (sl SupplyLimit) Equals(sl2 SupplyLimit) bool

Equals returns true if two supply limits are equal

func (*SupplyLimit) GetTimeLimited 

func (m *SupplyLimit) GetTimeLimited() bool

func (*SupplyLimit) GetTimePeriod 

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

func (*SupplyLimit) Marshal 

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

func (*SupplyLimit) MarshalTo 

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

func (*SupplyLimit) MarshalToSizedBuffer 

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

func (*SupplyLimit) ProtoMessage 

func (*SupplyLimit) ProtoMessage()

func (*SupplyLimit) Reset 

func (m *SupplyLimit) Reset()

func (*SupplyLimit) Size 

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

func (*SupplyLimit) String 

func (m *SupplyLimit) String() string

func (*SupplyLimit) Unmarshal 

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

func (*SupplyLimit) XXX_DiscardUnknown 

func (m *SupplyLimit) XXX_DiscardUnknown()

func (*SupplyLimit) XXX_Marshal 

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

func (*SupplyLimit) XXX_Merge 

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

func (*SupplyLimit) XXX_Size 

func (m *SupplyLimit) XXX_Size() int

func (*SupplyLimit) XXX_Unmarshal 

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 fury chain)
	SWAP_DIRECTION_INCOMING SwapDirection = 1
	// SWAP_DIRECTION_OUTGOING represents an outgoing swap (from the fury chain)
	SWAP_DIRECTION_OUTGOING SwapDirection = 2
)

func NewSwapDirectionFromString 

func NewSwapDirectionFromString(str string) SwapDirection

NewSwapDirectionFromString converts string to SwapDirection type

func (SwapDirection) EnumDescriptor 

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

func (SwapDirection) IsValid 

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 

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

func (SwapStatus) IsValid 

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 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ClaimAtomicSwap 

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

func (*UnimplementedMsgServer) CreateAtomicSwap 

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

func (*UnimplementedMsgServer) RefundAtomicSwap 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AssetSupplies 

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

func (*UnimplementedQueryServer) AssetSupply 

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

func (*UnimplementedQueryServer) AtomicSwap 

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

func (*UnimplementedQueryServer) AtomicSwaps 

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

func (*UnimplementedQueryServer) Params 

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.