types

package
v0.0.0-...-a749886 Latest Latest
Warning

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

Go to latest
Published: Nov 27, 2022 License: Apache-2.0 Imports: 42 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 = sdkerrors.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 = sdkerrors.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 = sdkerrors.Register(ModuleName, 4, "amount cannot cover the deputy fixed fee")
	// ErrAssetNotSupported error for when an asset is not supported
	ErrAssetNotSupported = sdkerrors.Register(ModuleName, 5, "asset not found")
	// ErrAssetNotActive error for when an asset is currently inactive
	ErrAssetNotActive = sdkerrors.Register(ModuleName, 6, "asset is currently inactive")
	// ErrAssetSupplyNotFound error for when an asset's supply is not found in the store
	ErrAssetSupplyNotFound = sdkerrors.Register(ModuleName, 7, "asset supply not found in store")
	// ErrExceedsSupplyLimit error for when the proposed supply increase would put the supply above limit
	ErrExceedsSupplyLimit = sdkerrors.Register(ModuleName, 8, "asset supply over limit")
	// ErrExceedsAvailableSupply error for when the proposed outgoing amount exceeds the total available supply
	ErrExceedsAvailableSupply = sdkerrors.Register(ModuleName, 9, "outgoing swap exceeds total available supply")
	// ErrInvalidCurrentSupply error for when the proposed decrease would result in a negative current supplyx
	ErrInvalidCurrentSupply = sdkerrors.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 = sdkerrors.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 = sdkerrors.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 = sdkerrors.Register(ModuleName, 13, "hashed claim attempt does not match")
	// ErrAtomicSwapAlreadyExists error for when an AtomicSwap with this swapID already exists
	ErrAtomicSwapAlreadyExists = sdkerrors.Register(ModuleName, 14, "atomic swap already exists")
	// ErrAtomicSwapNotFound error for when an atomic swap is not found
	ErrAtomicSwapNotFound = sdkerrors.Register(ModuleName, 15, "atomic swap not found")
	// ErrSwapNotRefundable error for when an AtomicSwap has not expired and cannot be refunded
	ErrSwapNotRefundable = sdkerrors.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 = sdkerrors.Register(ModuleName, 17, "atomic swap is not claimable")
	// ErrInvalidAmount error for when a swap's amount is outside acceptable range
	ErrInvalidAmount = sdkerrors.Register(ModuleName, 18, "amount is outside acceptable range")
	// ErrInvalidSwapAccount error for when a swap involves an invalid account
	ErrInvalidSwapAccount = sdkerrors.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 = sdkerrors.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 sdk.Int = sdk.NewInt(1000) // 0.00001 BNB
	DefaultMinAmount         sdk.Int = sdk.ZeroInt()
	DefaultMaxAmount         sdk.Int = sdk.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("CogitoAtomicSwapCoins")))
)

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 cogito 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 sdk.Int, minSwapAmount sdk.Int,
	maxSwapAmount sdk.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 (*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 cogito 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 cogito 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=cogito.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=cogito.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 (*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 (*AtomicSwap) GetRecipient

func (*AtomicSwap) GetRecipientOtherChain

func (m *AtomicSwap) GetRecipientOtherChain() string

func (*AtomicSwap) GetSender

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 cogito chain sender of the swap
	Sender string `protobuf:"bytes,6,opt,name=sender,proto3" json:"sender,omitempty"`
	// recipient is the cogito 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=cogito.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=cogito.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 (*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=cogito.bep3.v1beta1.SwapStatus" json:"status,omitempty"`
	// direction fitlers by swap direction
	Direction  SwapDirection      `protobuf:"varint,4,opt,name=direction,proto3,enum=cogito.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 cogito chain)
	SWAP_DIRECTION_INCOMING SwapDirection = 1
	// SWAP_DIRECTION_OUTGOING represents an outgoing swap (from the cogito 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) CreateAtomicSwap

func (*UnimplementedMsgServer) RefundAtomicSwap

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AssetSupplies

func (*UnimplementedQueryServer) AssetSupply

func (*UnimplementedQueryServer) AtomicSwap

func (*UnimplementedQueryServer) AtomicSwaps

func (*UnimplementedQueryServer) Params

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL