types

package
v0.3.4 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2021 License: Apache-2.0 Imports: 43 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"
	AttributeKeyExpireTimestamp  = "expire_timestamp"
	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
	DefaultLongtermStorageDuration uint64 = 7 * 24 * 60 * 60
)
View Source 
const (
	CreateAtomicSwap = "createAtomicSwap"
	ClaimAtomicSwap  = "claimAtomicSwap"
	RefundAtomicSwap = "refundAtomicSwap"
	CalcSwapID       = "calcSwapID"

	Int64Size               = 8
	RandomNumberHashLength  = 32
	RandomNumberLength      = 32
	AddrByteCount           = 20
	MaxOtherChainAddrLength = 64
	SwapIDLength            = 32
	MaxExpectedIncomeLength = 64
)
View Source 
const (
	ThreeDayMinutes = 60 * 24 * 3

	// Todo set this to a meaningful value
	DeputyFee = 5000
)
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 (
	// 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")
	// ErrInvalidTimeSpan error for when a proposed time span is outside of lock time range
	ErrInvalidTimeSpan = sdkerrors.Register(ModuleName, 3, "time 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 (
	// ModulePermissionsUpgradeTime is the block time after which the bep3 module account's permissions are synced with the supply module.
	ModulePermissionsUpgradeTime time.Time = time.Date(2020, 11, 3, 10, 0, 0, 0, time.UTC)

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

	DefaultMinAmount           sdk.Int = sdk.ZeroInt()
	DefaultMaxAmount           sdk.Int = sdk.NewInt(1000000000000) // 10,000 BNB
	DefaultPreviousBlockTime           = tmtime.Canonical(time.Unix(0, 0))
	DefaultSwapBlockTimestamp  int64   = 10 // At 10th second.
	DefaultSwapTimeSpanMinutes int64   = 5  // 5 minutes
)

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 (
	ErrInvalidLengthSwap        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSwap          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSwap = 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("emoneyAtomicSwapCoins")))
)

ensure Msg interface compliance at compile time

View Source 
var (

	// ModuleCdc references the 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.
	ModuleCdc = codec.NewAminoCodec(amino)
)

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 GetAtomicSwapByTimestampKey added in v0.2.0 

func GetAtomicSwapByTimestampKey(timestamp int64, swapID []byte) []byte

GetAtomicSwapByTimestampKey is used by the AtomicSwapByTimestamp and AtomicSwapLongTermStorage index to generate sortable timestamp keys.

func GetHeightSortableKey added in v0.3.0 

func GetHeightSortableKey(height uint64) []byte

func GetTimestampSortableKey added in v0.2.0 

func GetTimestampSortableKey(timestamp int64) []byte

func PackAccounts added in v0.3.0 

func PackAccounts(accounts authtypes.GenesisAccounts) ([]*codectypes.Any, error)

PackAccounts converts GenesisAccounts to Any slice

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable Key declaration for parameters

func RegisterInterfaces added in v0.3.0 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec added in v0.3.0 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterCodec registers concrete types on amino

func RegisterMsgServer added in v0.3.0 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler added in v0.3.0 

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

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

func RegisterQueryHandlerClient added in v0.3.0 

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

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

func RegisterQueryHandlerFromEndpoint added in v0.3.0 

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

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

func RegisterQueryHandlerServer added in v0.3.0 

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

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

func RegisterQueryServer added in v0.3.0 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func UnpackAccounts added in v0.3.0 

func UnpackAccounts(accountsAny []*codectypes.Any) (authtypes.GenesisAccounts, error)

UnpackAccounts converts Any slice to GenesisAccounts

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	NewAccountWithAddress(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	SetAccount(sdk.Context, authtypes.AccountI)

	GetModuleAddress(moduleName string) sdk.AccAddress
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI
	GetModuleAddressAndPermissions(moduleName string) (addr sdk.AccAddress, permissions []string)
	SetModuleAccount(ctx sdk.Context, mAcc authtypes.ModuleAccountI)
}

AccountKeeper defines the expected account keeper (noalias)

type AssetParam 

type AssetParam struct {
	// name of the asset
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty" yaml:"denom"`
	// SLIP-0044 registered coin type - see 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" yaml:"coin_id"`
	// asset supply limit
	SupplyLimit SupplyLimit `protobuf:"bytes,3,opt,name=supply_limit,json=supplyLimit,proto3" json:"supply_limit" yaml:"supply_limit"`
	// denotes if asset is available or paused
	Active bool `protobuf:"varint,4,opt,name=active,proto3" json:"active,omitempty" yaml:"active"`
	// the address of the relayer process
	DeputyAddress string `protobuf:"bytes,5,opt,name=deputy_address,json=deputyAddress,proto3" json:"deputy_address,omitempty" yaml:"deputy_address"`
	// It should match the deputy config chain values. The fixed fee charged by the relayer process for outgoing swaps
	FixedFee github_com_cosmos_cosmos_sdk_types.Int `` /* 142-byte string literal not displayed */
	// Minimum swap amount
	MinSwapAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 165-byte string literal not displayed */
	// Maximum swap amount
	MaxSwapAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 165-byte string literal not displayed */
	// Unix seconds of swap creation block timestamp
	// Original	SwapTimestamp int64 `json:"swap_time" yaml:"swap_time"`
	SwapTimestamp int64 `protobuf:"varint,9,opt,name=swap_time,json=swapTime,proto3" json:"swap_time,omitempty" yaml:"swap_time"`
	// minutes span before time expiration
	// Original SwapTimeSpan int64 `json:"time_span" yaml:"time_span"`
	SwapTimeSpanMin int64 `` /* 138-byte string literal not displayed */
}

AssetParam parameters that must be specified 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,
	swapTimestamp int64, swapTimeSpanMin int64) AssetParam

NewAssetParam returns a new AssetParam

func (*AssetParam) Descriptor added in v0.3.0 

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

func (*AssetParam) GetActive added in v0.3.0 

func (m *AssetParam) GetActive() bool

func (*AssetParam) GetCoinID added in v0.3.0 

func (m *AssetParam) GetCoinID() int64

func (*AssetParam) GetDenom added in v0.3.0 

func (m *AssetParam) GetDenom() string

func (*AssetParam) GetDeputyAddress added in v0.3.0 

func (m *AssetParam) GetDeputyAddress() string

func (*AssetParam) GetSupplyLimit added in v0.3.0 

func (m *AssetParam) GetSupplyLimit() SupplyLimit

func (*AssetParam) GetSwapTimeSpanMin added in v0.3.0 

func (m *AssetParam) GetSwapTimeSpanMin() int64

func (*AssetParam) GetSwapTimestamp added in v0.3.0 

func (m *AssetParam) GetSwapTimestamp() int64

func (*AssetParam) Marshal added in v0.3.0 

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

func (*AssetParam) MarshalTo added in v0.3.0 

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

func (*AssetParam) MarshalToSizedBuffer added in v0.3.0 

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

func (*AssetParam) ProtoMessage added in v0.3.0 

func (*AssetParam) ProtoMessage()

func (*AssetParam) Reset added in v0.3.0 

func (m *AssetParam) Reset()

func (*AssetParam) Size added in v0.3.0 

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

func (AssetParam) String 

func (ap AssetParam) String() string

String implements fmt.Stringer

func (*AssetParam) Unmarshal added in v0.3.0 

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

func (*AssetParam) XXX_DiscardUnknown added in v0.3.0 

func (m *AssetParam) XXX_DiscardUnknown()

func (*AssetParam) XXX_Marshal added in v0.3.0 

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

func (*AssetParam) XXX_Merge added in v0.3.0 

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

func (*AssetParam) XXX_Size added in v0.3.0 

func (m *AssetParam) XXX_Size() int

func (*AssetParam) XXX_Unmarshal added in v0.3.0 

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

type AssetParams 

type AssetParams []AssetParam

AssetParams array of AssetParam

func (AssetParams) String 

func (aps AssetParams) String() string

String implements fmt.Stringer

type AssetSupplies 

type AssetSupplies struct {
	AssetSupplies []AssetSupply `protobuf:"bytes,1,rep,name=asset_supplies,json=assetSupplies,proto3" json:"asset_supplies" yaml:"asset_supplies"`
}

slice of AssetSupply

func (*AssetSupplies) Descriptor added in v0.3.0 

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

func (*AssetSupplies) GetAssetSupplies added in v0.3.0 

func (m *AssetSupplies) GetAssetSupplies() []AssetSupply

func (*AssetSupplies) Marshal added in v0.3.0 

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

func (*AssetSupplies) MarshalTo added in v0.3.0 

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

func (*AssetSupplies) MarshalToSizedBuffer added in v0.3.0 

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

func (*AssetSupplies) ProtoMessage added in v0.3.0 

func (*AssetSupplies) ProtoMessage()

func (*AssetSupplies) Reset added in v0.3.0 

func (m *AssetSupplies) Reset()

func (*AssetSupplies) Size added in v0.3.0 

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

func (*AssetSupplies) String added in v0.3.0 

func (m *AssetSupplies) String() string

func (*AssetSupplies) Unmarshal added in v0.3.0 

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

func (*AssetSupplies) XXX_DiscardUnknown added in v0.3.0 

func (m *AssetSupplies) XXX_DiscardUnknown()

func (*AssetSupplies) XXX_Marshal added in v0.3.0 

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

func (*AssetSupplies) XXX_Merge added in v0.3.0 

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

func (*AssetSupplies) XXX_Size added in v0.3.0 

func (m *AssetSupplies) XXX_Size() int

func (*AssetSupplies) XXX_Unmarshal added in v0.3.0 

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

type AssetSupply 

type AssetSupply struct {
	IncomingSupply           types.Coin `protobuf:"bytes,1,opt,name=incoming_supply,json=incomingSupply,proto3" json:"incoming_supply" yaml:"incoming_supply"`
	OutgoingSupply           types.Coin `protobuf:"bytes,2,opt,name=outgoing_supply,json=outgoingSupply,proto3" json:"outgoing_supply" yaml:"outgoing_supply"`
	CurrentSupply            types.Coin `protobuf:"bytes,3,opt,name=current_supply,json=currentSupply,proto3" json:"current_supply" yaml:"current_supply"`
	TimeLimitedCurrentSupply types.Coin `` /* 162-byte string literal not displayed */
	// the time.duration int64 units of times elapsed
	TimeElapsed int64 `protobuf:"varint,5,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty" yaml:"time_elapsed"`
}

AssetSupply contains information about an asset's supply

func NewAssetSupply 

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

NewAssetSupply initializes a new AssetSupply

func (*AssetSupply) Descriptor added in v0.3.0 

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 added in v0.3.0 

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 added in v0.3.0 

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

func (*AssetSupply) GetOutgoingSupply added in v0.3.0 

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

func (*AssetSupply) GetTimeElapsed added in v0.3.0 

func (m *AssetSupply) GetTimeElapsed() int64

func (*AssetSupply) GetTimeLimitedCurrentSupply added in v0.3.0 

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

func (*AssetSupply) Marshal added in v0.3.0 

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

func (*AssetSupply) MarshalTo added in v0.3.0 

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

func (*AssetSupply) MarshalToSizedBuffer added in v0.3.0 

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

func (*AssetSupply) ProtoMessage added in v0.3.0 

func (*AssetSupply) ProtoMessage()

func (*AssetSupply) Reset added in v0.3.0 

func (m *AssetSupply) Reset()

func (*AssetSupply) Size added in v0.3.0 

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

func (AssetSupply) String 

func (a AssetSupply) String() string

String implements stringer

func (*AssetSupply) Unmarshal added in v0.3.0 

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 added in v0.3.0 

func (m *AssetSupply) XXX_DiscardUnknown()

func (*AssetSupply) XXX_Marshal added in v0.3.0 

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

func (*AssetSupply) XXX_Merge added in v0.3.0 

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

func (*AssetSupply) XXX_Size added in v0.3.0 

func (m *AssetSupply) XXX_Size() int

func (*AssetSupply) XXX_Unmarshal added in v0.3.0 

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

type AtomicSwap 

type AtomicSwap struct {
	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" yaml:"amount"`
	RandomNumberHash    github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 199-byte string literal not displayed */
	ExpireTimestamp     int64                                                `` /* 131-byte string literal not displayed */
	Timestamp           int64                                                `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty" yaml:"timestamp"`
	Sender              string                                               `protobuf:"bytes,5,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Recipient           string                                               `protobuf:"bytes,6,opt,name=recipient,proto3" json:"recipient,omitempty" yaml:"recipient"`
	SenderOtherChain    string                                               `` /* 137-byte string literal not displayed */
	RecipientOtherChain string                                               `` /* 149-byte string literal not displayed */
	ClosedBlock         int64                                                `protobuf:"varint,9,opt,name=closed_block,json=closedBlock,proto3" json:"closed_block,omitempty" yaml:"closed_block"`
	Status              SwapStatus                                           `protobuf:"varint,10,opt,name=status,proto3,casttype=SwapStatus" json:"status,omitempty" yaml:"status"`
	CrossChain          bool                                                 `protobuf:"varint,11,opt,name=cross_chain,json=crossChain,proto3" json:"cross_chain,omitempty" yaml:"cross_chain"`
	Direction           SwapDirection                                        `protobuf:"varint,12,opt,name=direction,proto3,casttype=SwapDirection" json:"direction,omitempty" yaml:"direction"`
}

AtomicSwap contains the information for an atomic swap

func NewAtomicSwap 

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

NewAtomicSwap returns a new AtomicSwap

func (*AtomicSwap) Descriptor added in v0.3.0 

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

func (*AtomicSwap) GetAmount added in v0.3.0 

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

func (*AtomicSwap) GetClosedBlock added in v0.3.0 

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 added in v0.3.0 

func (m *AtomicSwap) GetCrossChain() bool

func (*AtomicSwap) GetDirection added in v0.3.0 

func (m *AtomicSwap) GetDirection() SwapDirection

func (*AtomicSwap) GetExpireTimestamp added in v0.3.0 

func (m *AtomicSwap) GetExpireTimestamp() int64

func (*AtomicSwap) GetRandomNumberHash added in v0.3.0 

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

func (*AtomicSwap) GetRecipient added in v0.3.0 

func (m *AtomicSwap) GetRecipient() string

func (*AtomicSwap) GetRecipientOtherChain added in v0.3.0 

func (m *AtomicSwap) GetRecipientOtherChain() string

func (*AtomicSwap) GetSender added in v0.3.0 

func (m *AtomicSwap) GetSender() string

func (*AtomicSwap) GetSenderOtherChain added in v0.3.0 

func (m *AtomicSwap) GetSenderOtherChain() string

func (*AtomicSwap) GetStatus added in v0.3.0 

func (m *AtomicSwap) GetStatus() SwapStatus

func (AtomicSwap) GetSwapID 

func (a AtomicSwap) GetSwapID() tmbytes.HexBytes

GetSwapID calculates the ID of an atomic swap

func (*AtomicSwap) GetTimestamp added in v0.3.0 

func (m *AtomicSwap) GetTimestamp() int64

func (*AtomicSwap) Marshal added in v0.3.0 

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

func (*AtomicSwap) MarshalTo added in v0.3.0 

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

func (*AtomicSwap) MarshalToSizedBuffer added in v0.3.0 

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

func (*AtomicSwap) ProtoMessage added in v0.3.0 

func (*AtomicSwap) ProtoMessage()

func (*AtomicSwap) Reset added in v0.3.0 

func (m *AtomicSwap) Reset()

func (*AtomicSwap) Size added in v0.3.0 

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

func (AtomicSwap) String 

func (a AtomicSwap) String() string

String implements stringer

func (*AtomicSwap) Unmarshal added in v0.3.0 

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

func (AtomicSwap) Validate 

func (a AtomicSwap) Validate() error

Validate performs a basic validation of an atomic swap fields.

func (*AtomicSwap) XXX_DiscardUnknown added in v0.3.0 

func (m *AtomicSwap) XXX_DiscardUnknown()

func (*AtomicSwap) XXX_Marshal added in v0.3.0 

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

func (*AtomicSwap) XXX_Merge added in v0.3.0 

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

func (*AtomicSwap) XXX_Size added in v0.3.0 

func (m *AtomicSwap) XXX_Size() int

func (*AtomicSwap) XXX_Unmarshal added in v0.3.0 

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

type AtomicSwaps 

type AtomicSwaps []AtomicSwap

AtomicSwaps is a slice of AtomicSwap

func (AtomicSwaps) String 

func (swaps AtomicSwaps) String() string

String implements stringer

type AugmentedAtomicSwap 

type AugmentedAtomicSwap struct {
	ID                  string                                               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	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" yaml:"amount"`
	RandomNumberHash    github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 199-byte string literal not displayed */
	ExpireTimestamp     int64                                                `` /* 131-byte string literal not displayed */
	Timestamp           int64                                                `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty" yaml:"timestamp"`
	Sender              string                                               `protobuf:"bytes,6,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Recipient           string                                               `protobuf:"bytes,7,opt,name=recipient,proto3" json:"recipient,omitempty" yaml:"recipient"`
	SenderOtherChain    string                                               `` /* 137-byte string literal not displayed */
	RecipientOtherChain string                                               `` /* 149-byte string literal not displayed */
	ClosedBlock         int64                                                `protobuf:"varint,10,opt,name=closed_block,json=closedBlock,proto3" json:"closed_block,omitempty" yaml:"closed_block"`
	Status              SwapStatus                                           `protobuf:"varint,11,opt,name=status,proto3,casttype=SwapStatus" json:"status,omitempty" yaml:"status"`
	CrossChain          bool                                                 `protobuf:"varint,12,opt,name=cross_chain,json=crossChain,proto3" json:"cross_chain,omitempty" yaml:"cross_chain"`
	Direction           SwapDirection                                        `protobuf:"varint,13,opt,name=direction,proto3,casttype=SwapDirection" json:"direction,omitempty" yaml:"direction"`
}

AtomicSwap with an ID

func NewAugmentedAtomicSwap 

func NewAugmentedAtomicSwap(swap AtomicSwap) AugmentedAtomicSwap

func (*AugmentedAtomicSwap) Descriptor added in v0.3.0 

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

func (*AugmentedAtomicSwap) GetAmount added in v0.3.0 

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

func (*AugmentedAtomicSwap) GetClosedBlock added in v0.3.0 

func (m *AugmentedAtomicSwap) GetClosedBlock() int64

func (*AugmentedAtomicSwap) GetCrossChain added in v0.3.0 

func (m *AugmentedAtomicSwap) GetCrossChain() bool

func (*AugmentedAtomicSwap) GetDirection added in v0.3.0 

func (m *AugmentedAtomicSwap) GetDirection() SwapDirection

func (*AugmentedAtomicSwap) GetExpireTimestamp added in v0.3.0 

func (m *AugmentedAtomicSwap) GetExpireTimestamp() int64

func (*AugmentedAtomicSwap) GetID added in v0.3.0 

func (m *AugmentedAtomicSwap) GetID() string

func (*AugmentedAtomicSwap) GetRandomNumberHash added in v0.3.0 

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

func (*AugmentedAtomicSwap) GetRecipient added in v0.3.0 

func (m *AugmentedAtomicSwap) GetRecipient() string

func (*AugmentedAtomicSwap) GetRecipientOtherChain added in v0.3.0 

func (m *AugmentedAtomicSwap) GetRecipientOtherChain() string

func (*AugmentedAtomicSwap) GetSender added in v0.3.0 

func (m *AugmentedAtomicSwap) GetSender() string

func (*AugmentedAtomicSwap) GetSenderOtherChain added in v0.3.0 

func (m *AugmentedAtomicSwap) GetSenderOtherChain() string

func (*AugmentedAtomicSwap) GetStatus added in v0.3.0 

func (m *AugmentedAtomicSwap) GetStatus() SwapStatus

func (*AugmentedAtomicSwap) GetTimestamp added in v0.3.0 

func (m *AugmentedAtomicSwap) GetTimestamp() int64

func (*AugmentedAtomicSwap) Marshal added in v0.3.0 

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

func (*AugmentedAtomicSwap) MarshalTo added in v0.3.0 

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

func (*AugmentedAtomicSwap) MarshalToSizedBuffer added in v0.3.0 

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

func (*AugmentedAtomicSwap) ProtoMessage added in v0.3.0 

func (*AugmentedAtomicSwap) ProtoMessage()

func (*AugmentedAtomicSwap) Reset added in v0.3.0 

func (m *AugmentedAtomicSwap) Reset()

func (*AugmentedAtomicSwap) Size added in v0.3.0 

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

func (*AugmentedAtomicSwap) String added in v0.3.0 

func (m *AugmentedAtomicSwap) String() string

func (*AugmentedAtomicSwap) Unmarshal added in v0.3.0 

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

func (*AugmentedAtomicSwap) XXX_DiscardUnknown added in v0.3.0 

func (m *AugmentedAtomicSwap) XXX_DiscardUnknown()

func (*AugmentedAtomicSwap) XXX_Marshal added in v0.3.0 

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

func (*AugmentedAtomicSwap) XXX_Merge added in v0.3.0 

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

func (*AugmentedAtomicSwap) XXX_Size added in v0.3.0 

func (m *AugmentedAtomicSwap) XXX_Size() int

func (*AugmentedAtomicSwap) XXX_Unmarshal added in v0.3.0 

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

type AugmentedAtomicSwaps 

type AugmentedAtomicSwaps struct {
	AugmentedAtomicSwaps []AugmentedAtomicSwap `` /* 143-byte string literal not displayed */
}

Slice of Augmented Atomic Swaps

func (*AugmentedAtomicSwaps) Descriptor added in v0.3.0 

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

func (*AugmentedAtomicSwaps) GetAugmentedAtomicSwaps added in v0.3.0 

func (m *AugmentedAtomicSwaps) GetAugmentedAtomicSwaps() []AugmentedAtomicSwap

func (*AugmentedAtomicSwaps) Marshal added in v0.3.0 

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

func (*AugmentedAtomicSwaps) MarshalTo added in v0.3.0 

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

func (*AugmentedAtomicSwaps) MarshalToSizedBuffer added in v0.3.0 

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

func (*AugmentedAtomicSwaps) ProtoMessage added in v0.3.0 

func (*AugmentedAtomicSwaps) ProtoMessage()

func (*AugmentedAtomicSwaps) Reset added in v0.3.0 

func (m *AugmentedAtomicSwaps) Reset()

func (*AugmentedAtomicSwaps) Size added in v0.3.0 

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

func (*AugmentedAtomicSwaps) String added in v0.3.0 

func (m *AugmentedAtomicSwaps) String() string

func (*AugmentedAtomicSwaps) Unmarshal added in v0.3.0 

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

func (*AugmentedAtomicSwaps) XXX_DiscardUnknown added in v0.3.0 

func (m *AugmentedAtomicSwaps) XXX_DiscardUnknown()

func (*AugmentedAtomicSwaps) XXX_Marshal added in v0.3.0 

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

func (*AugmentedAtomicSwaps) XXX_Merge added in v0.3.0 

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

func (*AugmentedAtomicSwaps) XXX_Size added in v0.3.0 

func (m *AugmentedAtomicSwaps) XXX_Size() int

func (*AugmentedAtomicSwaps) XXX_Unmarshal added in v0.3.0 

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

type BankKeeper added in v0.3.0 

type BankKeeper interface {
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	LockedCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SetBalances(ctx sdk.Context, addr sdk.AccAddress, balances sdk.Coins) error
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetSupply(ctx sdk.Context) bankexported.SupplyI
}

BankKeeper or Bank Keeper in SDK 0.40+ defines the expected supply keeper (noalias)

type GenesisState 

type GenesisState struct {
	Params            Params        `protobuf:"bytes,1,opt,name=params,proto3" json:"params" yaml:"params"`
	AtomicSwaps       []AtomicSwap  `protobuf:"bytes,2,rep,name=atomic_swaps,json=atomicSwaps,proto3" json:"atomic_swaps" yaml:"atomic_swaps"`
	Supplies          AssetSupplies `protobuf:"bytes,3,opt,name=supplies,proto3" json:"supplies" yaml:"supplies"`
	PreviousBlockTime time.Time     `` /* 139-byte string literal not displayed */
}

type GenesisState struct {

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState - default GenesisState used by Cosmos Hub

func NewGenesisState 

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

NewGenesisState creates a new GenesisState object

func (*GenesisState) Descriptor added in v0.3.0 

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

func (GenesisState) Equal 

func (gs GenesisState) Equal(gs2 GenesisState) bool

Equal checks whether two GenesisState structs are equivalent.

func (*GenesisState) GetAtomicSwaps added in v0.3.0 

func (m *GenesisState) GetAtomicSwaps() []AtomicSwap

func (*GenesisState) GetParams added in v0.3.0 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPreviousBlockTime added in v0.3.0 

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

func (*GenesisState) GetSupplies added in v0.3.0 

func (m *GenesisState) GetSupplies() AssetSupplies

func (GenesisState) IsEmpty 

func (gs GenesisState) IsEmpty() bool

IsEmpty returns true if a GenesisState is empty.

func (*GenesisState) Marshal added in v0.3.0 

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

func (*GenesisState) MarshalTo added in v0.3.0 

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

func (*GenesisState) MarshalToSizedBuffer added in v0.3.0 

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

func (*GenesisState) ProtoMessage added in v0.3.0 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset added in v0.3.0 

func (m *GenesisState) Reset()

func (*GenesisState) Size added in v0.3.0 

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

func (*GenesisState) String added in v0.3.0 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal added in v0.3.0 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

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

func (*GenesisState) XXX_DiscardUnknown added in v0.3.0 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal added in v0.3.0 

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

func (*GenesisState) XXX_Merge added in v0.3.0 

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

func (*GenesisState) XXX_Size added in v0.3.0 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal added in v0.3.0 

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

type MsgClaimAtomicSwap 

type MsgClaimAtomicSwap struct {
	From         string                                               `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	SwapID       github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 156-byte string literal not displayed */
	RandomNumber github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 180-byte string literal not displayed */
}

MsgClaimAtomicSwap defines a AtomicSwap claim

func NewMsgClaimAtomicSwap 

func NewMsgClaimAtomicSwap(from sdk.AccAddress, swapID, randomNumber []byte) *MsgClaimAtomicSwap

NewMsgClaimAtomicSwap initializes a new MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Descriptor added in v0.3.0 

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

func (*MsgClaimAtomicSwap) GetFrom added in v0.3.0 

func (m *MsgClaimAtomicSwap) GetFrom() string

func (MsgClaimAtomicSwap) GetInvolvedAddresses 

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

GetInvolvedAddresses gets the addresses involved in a MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) GetRandomNumber added in v0.3.0 

func (m *MsgClaimAtomicSwap) GetRandomNumber() github_com_tendermint_tendermint_libs_bytes.HexBytes

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) GetSwapID added in v0.3.0 

func (m *MsgClaimAtomicSwap) GetSwapID() github_com_tendermint_tendermint_libs_bytes.HexBytes

func (*MsgClaimAtomicSwap) Marshal added in v0.3.0 

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

func (*MsgClaimAtomicSwap) MarshalTo added in v0.3.0 

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

func (*MsgClaimAtomicSwap) MarshalToSizedBuffer added in v0.3.0 

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

func (*MsgClaimAtomicSwap) ProtoMessage added in v0.3.0 

func (*MsgClaimAtomicSwap) ProtoMessage()

func (*MsgClaimAtomicSwap) Reset added in v0.3.0 

func (m *MsgClaimAtomicSwap) Reset()

func (MsgClaimAtomicSwap) Route 

func (msg MsgClaimAtomicSwap) Route() string

Route establishes the route for the MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Size added in v0.3.0 

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

func (MsgClaimAtomicSwap) String 

func (msg MsgClaimAtomicSwap) String() string

String prints the MsgClaimAtomicSwap

func (MsgClaimAtomicSwap) Type 

func (msg MsgClaimAtomicSwap) Type() string

Type is the name of MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) Unmarshal added in v0.3.0 

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

func (MsgClaimAtomicSwap) ValidateBasic 

func (msg MsgClaimAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgClaimAtomicSwap

func (*MsgClaimAtomicSwap) XXX_DiscardUnknown added in v0.3.0 

func (m *MsgClaimAtomicSwap) XXX_DiscardUnknown()

func (*MsgClaimAtomicSwap) XXX_Marshal added in v0.3.0 

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

func (*MsgClaimAtomicSwap) XXX_Merge added in v0.3.0 

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

func (*MsgClaimAtomicSwap) XXX_Size added in v0.3.0 

func (m *MsgClaimAtomicSwap) XXX_Size() int

func (*MsgClaimAtomicSwap) XXX_Unmarshal added in v0.3.0 

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

type MsgClaimAtomicSwapResponse added in v0.3.0 

type MsgClaimAtomicSwapResponse struct {
	RandomNumberHash string `` /* 137-byte string literal not displayed */
	Timestamp        int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty" yaml:"timestamp"`
}

func (*MsgClaimAtomicSwapResponse) Descriptor added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) GetRandomNumberHash added in v0.3.0 

func (m *MsgClaimAtomicSwapResponse) GetRandomNumberHash() string

func (*MsgClaimAtomicSwapResponse) GetTimestamp added in v0.3.0 

func (m *MsgClaimAtomicSwapResponse) GetTimestamp() int64

func (*MsgClaimAtomicSwapResponse) Marshal added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) MarshalTo added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) ProtoMessage added in v0.3.0 

func (*MsgClaimAtomicSwapResponse) ProtoMessage()

func (*MsgClaimAtomicSwapResponse) Reset added in v0.3.0 

func (m *MsgClaimAtomicSwapResponse) Reset()

func (*MsgClaimAtomicSwapResponse) Size added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) String added in v0.3.0 

func (m *MsgClaimAtomicSwapResponse) String() string

func (*MsgClaimAtomicSwapResponse) Unmarshal added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *MsgClaimAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgClaimAtomicSwapResponse) XXX_Marshal added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) XXX_Merge added in v0.3.0 

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

func (*MsgClaimAtomicSwapResponse) XXX_Size added in v0.3.0 

func (m *MsgClaimAtomicSwapResponse) XXX_Size() int

func (*MsgClaimAtomicSwapResponse) XXX_Unmarshal added in v0.3.0 

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

type MsgClient added in v0.3.0 

type MsgClient interface {
	CreateAtomicSwap(ctx context.Context, in *MsgCreateAtomicSwap, opts ...grpc.CallOption) (*MsgCreateAtomicSwapResponse, error)
	ClaimAtomicSwap(ctx context.Context, in *MsgClaimAtomicSwap, opts ...grpc.CallOption) (*MsgClaimAtomicSwapResponse, error)
	RefundAtomicSwap(ctx context.Context, in *MsgRefundAtomicSwap, opts ...grpc.CallOption) (*MsgRefundAtomicSwapResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient added in v0.3.0 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateAtomicSwap 

type MsgCreateAtomicSwap struct {
	From                string                                               `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	To                  string                                               `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty" yaml:"to"`
	RecipientOtherChain string                                               `` /* 149-byte string literal not displayed */
	SenderOtherChain    string                                               `` /* 137-byte string literal not displayed */
	RandomNumberHash    github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 199-byte string literal not displayed */
	Timestamp           int64                                                `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty" yaml:"timestamp"`
	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" yaml:"amount"`
	// minutes span before time expiration
	TimeSpanMin int64 `protobuf:"varint,8,opt,name=time_span_min,json=timeSpanMin,proto3" json:"time_span_min,omitempty" yaml:"time_span_min"`
}

MsgCreateAtomicSwap contains an AtomicSwap struct

func NewMsgCreateAtomicSwap 

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

NewMsgCreateAtomicSwap initializes a new MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Descriptor added in v0.3.0 

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

func (*MsgCreateAtomicSwap) GetAmount added in v0.3.0 

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

func (*MsgCreateAtomicSwap) GetFrom added in v0.3.0 

func (m *MsgCreateAtomicSwap) GetFrom() string

func (MsgCreateAtomicSwap) GetInvolvedAddresses 

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

GetInvolvedAddresses gets the addresses involved in a MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) GetRandomNumberHash added in v0.3.0 

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

func (*MsgCreateAtomicSwap) GetRecipientOtherChain added in v0.3.0 

func (m *MsgCreateAtomicSwap) GetRecipientOtherChain() string

func (*MsgCreateAtomicSwap) GetSenderOtherChain added in v0.3.0 

func (m *MsgCreateAtomicSwap) GetSenderOtherChain() string

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) GetTimeSpanMin added in v0.3.0 

func (m *MsgCreateAtomicSwap) GetTimeSpanMin() int64

func (*MsgCreateAtomicSwap) GetTimestamp added in v0.3.0 

func (m *MsgCreateAtomicSwap) GetTimestamp() int64

func (*MsgCreateAtomicSwap) GetTo added in v0.3.0 

func (m *MsgCreateAtomicSwap) GetTo() string

func (*MsgCreateAtomicSwap) Marshal added in v0.3.0 

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

func (*MsgCreateAtomicSwap) MarshalTo added in v0.3.0 

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

func (*MsgCreateAtomicSwap) MarshalToSizedBuffer added in v0.3.0 

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

func (*MsgCreateAtomicSwap) ProtoMessage added in v0.3.0 

func (*MsgCreateAtomicSwap) ProtoMessage()

func (*MsgCreateAtomicSwap) Reset added in v0.3.0 

func (m *MsgCreateAtomicSwap) Reset()

func (MsgCreateAtomicSwap) Route 

func (msg MsgCreateAtomicSwap) Route() string

Route establishes the route for the MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Size added in v0.3.0 

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

func (MsgCreateAtomicSwap) String 

func (msg MsgCreateAtomicSwap) String() string

String prints the MsgCreateAtomicSwap

func (MsgCreateAtomicSwap) Type 

func (msg MsgCreateAtomicSwap) Type() string

Type is the name of MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) Unmarshal added in v0.3.0 

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

func (MsgCreateAtomicSwap) ValidateBasic 

func (msg MsgCreateAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgCreateAtomicSwap

func (*MsgCreateAtomicSwap) XXX_DiscardUnknown added in v0.3.0 

func (m *MsgCreateAtomicSwap) XXX_DiscardUnknown()

func (*MsgCreateAtomicSwap) XXX_Marshal added in v0.3.0 

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

func (*MsgCreateAtomicSwap) XXX_Merge added in v0.3.0 

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

func (*MsgCreateAtomicSwap) XXX_Size added in v0.3.0 

func (m *MsgCreateAtomicSwap) XXX_Size() int

func (*MsgCreateAtomicSwap) XXX_Unmarshal added in v0.3.0 

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

type MsgCreateAtomicSwapResponse added in v0.3.0 

type MsgCreateAtomicSwapResponse struct {
	RandomNumberHash string `` /* 137-byte string literal not displayed */
	SwapID           string `protobuf:"bytes,2,opt,name=swap_id,json=swapId,proto3" json:"swap_id,omitempty" yaml:"swap_id"`
}

func (*MsgCreateAtomicSwapResponse) Descriptor added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) GetRandomNumberHash added in v0.3.0 

func (m *MsgCreateAtomicSwapResponse) GetRandomNumberHash() string

func (*MsgCreateAtomicSwapResponse) GetSwapID added in v0.3.0 

func (m *MsgCreateAtomicSwapResponse) GetSwapID() string

func (*MsgCreateAtomicSwapResponse) Marshal added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) MarshalTo added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) ProtoMessage added in v0.3.0 

func (*MsgCreateAtomicSwapResponse) ProtoMessage()

func (*MsgCreateAtomicSwapResponse) Reset added in v0.3.0 

func (m *MsgCreateAtomicSwapResponse) Reset()

func (*MsgCreateAtomicSwapResponse) Size added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) String added in v0.3.0 

func (m *MsgCreateAtomicSwapResponse) String() string

func (*MsgCreateAtomicSwapResponse) Unmarshal added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *MsgCreateAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgCreateAtomicSwapResponse) XXX_Marshal added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) XXX_Merge added in v0.3.0 

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

func (*MsgCreateAtomicSwapResponse) XXX_Size added in v0.3.0 

func (m *MsgCreateAtomicSwapResponse) XXX_Size() int

func (*MsgCreateAtomicSwapResponse) XXX_Unmarshal added in v0.3.0 

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

type MsgRefundAtomicSwap 

type MsgRefundAtomicSwap struct {
	From   string                                               `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	SwapID github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 156-byte string literal not displayed */
}

MsgRefundAtomicSwap defines a refund msg

func NewMsgRefundAtomicSwap 

func NewMsgRefundAtomicSwap(from sdk.AccAddress, swapID []byte) *MsgRefundAtomicSwap

NewMsgRefundAtomicSwap initializes a new MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Descriptor added in v0.3.0 

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

func (*MsgRefundAtomicSwap) GetFrom added in v0.3.0 

func (m *MsgRefundAtomicSwap) GetFrom() string

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) GetSwapID added in v0.3.0 

func (m *MsgRefundAtomicSwap) GetSwapID() github_com_tendermint_tendermint_libs_bytes.HexBytes

func (*MsgRefundAtomicSwap) Marshal added in v0.3.0 

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

func (*MsgRefundAtomicSwap) MarshalTo added in v0.3.0 

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

func (*MsgRefundAtomicSwap) MarshalToSizedBuffer added in v0.3.0 

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

func (*MsgRefundAtomicSwap) ProtoMessage added in v0.3.0 

func (*MsgRefundAtomicSwap) ProtoMessage()

func (*MsgRefundAtomicSwap) Reset added in v0.3.0 

func (m *MsgRefundAtomicSwap) Reset()

func (MsgRefundAtomicSwap) Route 

func (msg MsgRefundAtomicSwap) Route() string

Route establishes the route for the MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Size added in v0.3.0 

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

func (MsgRefundAtomicSwap) String 

func (msg MsgRefundAtomicSwap) String() string

String prints the MsgRefundAtomicSwap

func (MsgRefundAtomicSwap) Type 

func (msg MsgRefundAtomicSwap) Type() string

Type is the name of MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) Unmarshal added in v0.3.0 

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

func (MsgRefundAtomicSwap) ValidateBasic 

func (msg MsgRefundAtomicSwap) ValidateBasic() error

ValidateBasic validates the MsgRefundAtomicSwap

func (*MsgRefundAtomicSwap) XXX_DiscardUnknown added in v0.3.0 

func (m *MsgRefundAtomicSwap) XXX_DiscardUnknown()

func (*MsgRefundAtomicSwap) XXX_Marshal added in v0.3.0 

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

func (*MsgRefundAtomicSwap) XXX_Merge added in v0.3.0 

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

func (*MsgRefundAtomicSwap) XXX_Size added in v0.3.0 

func (m *MsgRefundAtomicSwap) XXX_Size() int

func (*MsgRefundAtomicSwap) XXX_Unmarshal added in v0.3.0 

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

type MsgRefundAtomicSwapResponse added in v0.3.0 

type MsgRefundAtomicSwapResponse struct {
	RandomNumberHash string `` /* 137-byte string literal not displayed */
	Timestamp        int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty" yaml:"timestamp"`
}

func (*MsgRefundAtomicSwapResponse) Descriptor added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) GetRandomNumberHash added in v0.3.0 

func (m *MsgRefundAtomicSwapResponse) GetRandomNumberHash() string

func (*MsgRefundAtomicSwapResponse) GetTimestamp added in v0.3.0 

func (m *MsgRefundAtomicSwapResponse) GetTimestamp() int64

func (*MsgRefundAtomicSwapResponse) Marshal added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) MarshalTo added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) ProtoMessage added in v0.3.0 

func (*MsgRefundAtomicSwapResponse) ProtoMessage()

func (*MsgRefundAtomicSwapResponse) Reset added in v0.3.0 

func (m *MsgRefundAtomicSwapResponse) Reset()

func (*MsgRefundAtomicSwapResponse) Size added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) String added in v0.3.0 

func (m *MsgRefundAtomicSwapResponse) String() string

func (*MsgRefundAtomicSwapResponse) Unmarshal added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *MsgRefundAtomicSwapResponse) XXX_DiscardUnknown()

func (*MsgRefundAtomicSwapResponse) XXX_Marshal added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) XXX_Merge added in v0.3.0 

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

func (*MsgRefundAtomicSwapResponse) XXX_Size added in v0.3.0 

func (m *MsgRefundAtomicSwapResponse) XXX_Size() int

func (*MsgRefundAtomicSwapResponse) XXX_Unmarshal added in v0.3.0 

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

type MsgServer added in v0.3.0 

type MsgServer interface {
	CreateAtomicSwap(context.Context, *MsgCreateAtomicSwap) (*MsgCreateAtomicSwapResponse, error)
	ClaimAtomicSwap(context.Context, *MsgClaimAtomicSwap) (*MsgClaimAtomicSwapResponse, error)
	RefundAtomicSwap(context.Context, *MsgRefundAtomicSwap) (*MsgRefundAtomicSwapResponse, error)
}

MsgServer is the server API for Msg service.

type Params 

type Params struct {
	AssetParams []AssetParam `protobuf:"bytes,1,rep,name=asset_params,json=assetParams,proto3" json:"asset_params" yaml:"asset_params"`
}

Params governance parameters for bep3 module

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default params for bep3 module

func NewParams 

func NewParams(ap AssetParams,
) Params

NewParams returns a new params object

func (*Params) Descriptor added in v0.3.0 

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

func (*Params) GetAssetParams added in v0.3.0 

func (m *Params) GetAssetParams() []AssetParam

func (*Params) Marshal added in v0.3.0 

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

func (*Params) MarshalTo added in v0.3.0 

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

func (*Params) MarshalToSizedBuffer added in v0.3.0 

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

func (*Params) ParamSetPairs 

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

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

func (*Params) ProtoMessage added in v0.3.0 

func (*Params) ProtoMessage()

func (*Params) Reset added in v0.3.0 

func (m *Params) Reset()

func (*Params) Size added in v0.3.0 

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

func (Params) String 

func (p Params) String() string

String implements fmt.Stringer

func (*Params) Unmarshal added in v0.3.0 

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

func (Params) Validate 

func (p Params) Validate() error

Validate ensure that params have valid values

func (*Params) XXX_DiscardUnknown added in v0.3.0 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal added in v0.3.0 

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

func (*Params) XXX_Merge added in v0.3.0 

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

func (*Params) XXX_Size added in v0.3.0 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal added in v0.3.0 

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

type PrevBlockTime added in v0.3.0 

type PrevBlockTime struct {
	Val time.Time `protobuf:"bytes,1,opt,name=val,proto3,stdtime" json:"val"`
}

Proto type required for serializing the previous block time to manage supply expirations.

func (*PrevBlockTime) Descriptor added in v0.3.0 

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

func (*PrevBlockTime) GetVal added in v0.3.0 

func (m *PrevBlockTime) GetVal() time.Time

func (*PrevBlockTime) Marshal added in v0.3.0 

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

func (*PrevBlockTime) MarshalTo added in v0.3.0 

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

func (*PrevBlockTime) MarshalToSizedBuffer added in v0.3.0 

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

func (*PrevBlockTime) ProtoMessage added in v0.3.0 

func (*PrevBlockTime) ProtoMessage()

func (*PrevBlockTime) Reset added in v0.3.0 

func (m *PrevBlockTime) Reset()

func (*PrevBlockTime) Size added in v0.3.0 

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

func (*PrevBlockTime) String added in v0.3.0 

func (m *PrevBlockTime) String() string

func (*PrevBlockTime) Unmarshal added in v0.3.0 

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

func (*PrevBlockTime) XXX_DiscardUnknown added in v0.3.0 

func (m *PrevBlockTime) XXX_DiscardUnknown()

func (*PrevBlockTime) XXX_Marshal added in v0.3.0 

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

func (*PrevBlockTime) XXX_Merge added in v0.3.0 

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

func (*PrevBlockTime) XXX_Size added in v0.3.0 

func (m *PrevBlockTime) XXX_Size() int

func (*PrevBlockTime) XXX_Unmarshal added in v0.3.0 

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

type QueryAssetSupplies 

type QueryAssetSupplies struct {
	Page  int `protobuf:"varint,1,opt,name=page,proto3,casttype=int" json:"page,omitempty" yaml:"page"`
	Limit int `protobuf:"varint,2,opt,name=limit,proto3,casttype=int" json:"limit,omitempty" yaml:"limit"`
}

// QueryAssetSupplies contains the params for an AssetSupplies query type QueryAssetSupplies struct { Page int `json:"page" yaml:"page"` Limit int `json:"limit" yaml:"limit"` }

func NewQueryAssetSupplies 

func NewQueryAssetSupplies(page int, limit int) QueryAssetSupplies

NewQueryAssetSupplies creates a new QueryAssetSupplies

func (*QueryAssetSupplies) Descriptor added in v0.3.0 

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

func (*QueryAssetSupplies) GetLimit added in v0.3.0 

func (m *QueryAssetSupplies) GetLimit() int

func (*QueryAssetSupplies) GetPage added in v0.3.0 

func (m *QueryAssetSupplies) GetPage() int

func (*QueryAssetSupplies) Marshal added in v0.3.0 

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

func (*QueryAssetSupplies) MarshalTo added in v0.3.0 

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

func (*QueryAssetSupplies) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAssetSupplies) ProtoMessage added in v0.3.0 

func (*QueryAssetSupplies) ProtoMessage()

func (*QueryAssetSupplies) Reset added in v0.3.0 

func (m *QueryAssetSupplies) Reset()

func (*QueryAssetSupplies) Size added in v0.3.0 

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

func (*QueryAssetSupplies) String added in v0.3.0 

func (m *QueryAssetSupplies) String() string

func (*QueryAssetSupplies) Unmarshal added in v0.3.0 

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

func (*QueryAssetSupplies) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAssetSupplies) XXX_DiscardUnknown()

func (*QueryAssetSupplies) XXX_Marshal added in v0.3.0 

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

func (*QueryAssetSupplies) XXX_Merge added in v0.3.0 

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

func (*QueryAssetSupplies) XXX_Size added in v0.3.0 

func (m *QueryAssetSupplies) XXX_Size() int

func (*QueryAssetSupplies) XXX_Unmarshal added in v0.3.0 

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

type QueryAssetSuppliesRequest added in v0.3.0 

type QueryAssetSuppliesRequest struct {
}

gRPC assets req

func (*QueryAssetSuppliesRequest) Descriptor added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) Marshal added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) MarshalTo added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) ProtoMessage added in v0.3.0 

func (*QueryAssetSuppliesRequest) ProtoMessage()

func (*QueryAssetSuppliesRequest) Reset added in v0.3.0 

func (m *QueryAssetSuppliesRequest) Reset()

func (*QueryAssetSuppliesRequest) Size added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) String added in v0.3.0 

func (m *QueryAssetSuppliesRequest) String() string

func (*QueryAssetSuppliesRequest) Unmarshal added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAssetSuppliesRequest) XXX_DiscardUnknown()

func (*QueryAssetSuppliesRequest) XXX_Marshal added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) XXX_Merge added in v0.3.0 

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

func (*QueryAssetSuppliesRequest) XXX_Size added in v0.3.0 

func (m *QueryAssetSuppliesRequest) XXX_Size() int

func (*QueryAssetSuppliesRequest) XXX_Unmarshal added in v0.3.0 

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

type QueryAssetSuppliesResponse added in v0.3.0 

type QueryAssetSuppliesResponse struct {
	Supplies AssetSupplies `protobuf:"bytes,1,opt,name=supplies,proto3" json:"supplies" yaml:"supplies"`
}

gRPC asset supplies response

func (*QueryAssetSuppliesResponse) Descriptor added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) GetSupplies added in v0.3.0 

func (m *QueryAssetSuppliesResponse) GetSupplies() AssetSupplies

func (*QueryAssetSuppliesResponse) Marshal added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) MarshalTo added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) ProtoMessage added in v0.3.0 

func (*QueryAssetSuppliesResponse) ProtoMessage()

func (*QueryAssetSuppliesResponse) Reset added in v0.3.0 

func (m *QueryAssetSuppliesResponse) Reset()

func (*QueryAssetSuppliesResponse) Size added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) String added in v0.3.0 

func (m *QueryAssetSuppliesResponse) String() string

func (*QueryAssetSuppliesResponse) Unmarshal added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAssetSuppliesResponse) XXX_DiscardUnknown()

func (*QueryAssetSuppliesResponse) XXX_Marshal added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) XXX_Merge added in v0.3.0 

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

func (*QueryAssetSuppliesResponse) XXX_Size added in v0.3.0 

func (m *QueryAssetSuppliesResponse) XXX_Size() int

func (*QueryAssetSuppliesResponse) XXX_Unmarshal added in v0.3.0 

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

type QueryAssetSupply 

type QueryAssetSupply struct {
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty" yaml:"denom"`
}

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

func NewQueryAssetSupply 

func NewQueryAssetSupply(denom string) QueryAssetSupply

NewQueryAssetSupply creates a new QueryAssetSupply

func (*QueryAssetSupply) Descriptor added in v0.3.0 

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

func (*QueryAssetSupply) GetDenom added in v0.3.0 

func (m *QueryAssetSupply) GetDenom() string

func (*QueryAssetSupply) Marshal added in v0.3.0 

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

func (*QueryAssetSupply) MarshalTo added in v0.3.0 

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

func (*QueryAssetSupply) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAssetSupply) ProtoMessage added in v0.3.0 

func (*QueryAssetSupply) ProtoMessage()

func (*QueryAssetSupply) Reset added in v0.3.0 

func (m *QueryAssetSupply) Reset()

func (*QueryAssetSupply) Size added in v0.3.0 

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

func (*QueryAssetSupply) String added in v0.3.0 

func (m *QueryAssetSupply) String() string

func (*QueryAssetSupply) Unmarshal added in v0.3.0 

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

func (*QueryAssetSupply) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAssetSupply) XXX_DiscardUnknown()

func (*QueryAssetSupply) XXX_Marshal added in v0.3.0 

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

func (*QueryAssetSupply) XXX_Merge added in v0.3.0 

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

func (*QueryAssetSupply) XXX_Size added in v0.3.0 

func (m *QueryAssetSupply) XXX_Size() int

func (*QueryAssetSupply) XXX_Unmarshal added in v0.3.0 

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

type QueryAssetSupplyRequest added in v0.3.0 

type QueryAssetSupplyRequest struct {
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty" yaml:"denom"`
}

gRPC asset req

func (*QueryAssetSupplyRequest) Descriptor added in v0.3.0 

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

func (*QueryAssetSupplyRequest) GetDenom added in v0.3.0 

func (m *QueryAssetSupplyRequest) GetDenom() string

func (*QueryAssetSupplyRequest) Marshal added in v0.3.0 

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

func (*QueryAssetSupplyRequest) MarshalTo added in v0.3.0 

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

func (*QueryAssetSupplyRequest) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAssetSupplyRequest) ProtoMessage added in v0.3.0 

func (*QueryAssetSupplyRequest) ProtoMessage()

func (*QueryAssetSupplyRequest) Reset added in v0.3.0 

func (m *QueryAssetSupplyRequest) Reset()

func (*QueryAssetSupplyRequest) Size added in v0.3.0 

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

func (*QueryAssetSupplyRequest) String added in v0.3.0 

func (m *QueryAssetSupplyRequest) String() string

func (*QueryAssetSupplyRequest) Unmarshal added in v0.3.0 

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

func (*QueryAssetSupplyRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAssetSupplyRequest) XXX_DiscardUnknown()

func (*QueryAssetSupplyRequest) XXX_Marshal added in v0.3.0 

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

func (*QueryAssetSupplyRequest) XXX_Merge added in v0.3.0 

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

func (*QueryAssetSupplyRequest) XXX_Size added in v0.3.0 

func (m *QueryAssetSupplyRequest) XXX_Size() int

func (*QueryAssetSupplyRequest) XXX_Unmarshal added in v0.3.0 

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

type QueryAssetSupplyResponse added in v0.3.0 

type QueryAssetSupplyResponse struct {
	Supply AssetSupply `protobuf:"bytes,1,opt,name=supply,proto3" json:"supply" yaml:"supply"`
}

gRPC asset supply response

func (*QueryAssetSupplyResponse) Descriptor added in v0.3.0 

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

func (*QueryAssetSupplyResponse) GetSupply added in v0.3.0 

func (m *QueryAssetSupplyResponse) GetSupply() AssetSupply

func (*QueryAssetSupplyResponse) Marshal added in v0.3.0 

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

func (*QueryAssetSupplyResponse) MarshalTo added in v0.3.0 

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

func (*QueryAssetSupplyResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAssetSupplyResponse) ProtoMessage added in v0.3.0 

func (*QueryAssetSupplyResponse) ProtoMessage()

func (*QueryAssetSupplyResponse) Reset added in v0.3.0 

func (m *QueryAssetSupplyResponse) Reset()

func (*QueryAssetSupplyResponse) Size added in v0.3.0 

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

func (*QueryAssetSupplyResponse) String added in v0.3.0 

func (m *QueryAssetSupplyResponse) String() string

func (*QueryAssetSupplyResponse) Unmarshal added in v0.3.0 

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

func (*QueryAssetSupplyResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAssetSupplyResponse) XXX_DiscardUnknown()

func (*QueryAssetSupplyResponse) XXX_Marshal added in v0.3.0 

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

func (*QueryAssetSupplyResponse) XXX_Merge added in v0.3.0 

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

func (*QueryAssetSupplyResponse) XXX_Size added in v0.3.0 

func (m *QueryAssetSupplyResponse) XXX_Size() int

func (*QueryAssetSupplyResponse) XXX_Unmarshal added in v0.3.0 

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

type QueryAtomicSwapByID 

type QueryAtomicSwapByID struct {
	SwapID github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 156-byte string literal not displayed */
}

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

func NewQueryAtomicSwapByID 

func NewQueryAtomicSwapByID(swapBytes tmbytes.HexBytes) QueryAtomicSwapByID

NewQueryAtomicSwapByID creates a new QueryAtomicSwapByID

func (*QueryAtomicSwapByID) Descriptor added in v0.3.0 

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

func (*QueryAtomicSwapByID) GetSwapID added in v0.3.0 

func (m *QueryAtomicSwapByID) GetSwapID() github_com_tendermint_tendermint_libs_bytes.HexBytes

func (*QueryAtomicSwapByID) Marshal added in v0.3.0 

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

func (*QueryAtomicSwapByID) MarshalTo added in v0.3.0 

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

func (*QueryAtomicSwapByID) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAtomicSwapByID) ProtoMessage added in v0.3.0 

func (*QueryAtomicSwapByID) ProtoMessage()

func (*QueryAtomicSwapByID) Reset added in v0.3.0 

func (m *QueryAtomicSwapByID) Reset()

func (*QueryAtomicSwapByID) Size added in v0.3.0 

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

func (*QueryAtomicSwapByID) String added in v0.3.0 

func (m *QueryAtomicSwapByID) String() string

func (*QueryAtomicSwapByID) Unmarshal added in v0.3.0 

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

func (*QueryAtomicSwapByID) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAtomicSwapByID) XXX_DiscardUnknown()

func (*QueryAtomicSwapByID) XXX_Marshal added in v0.3.0 

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

func (*QueryAtomicSwapByID) XXX_Merge added in v0.3.0 

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

func (*QueryAtomicSwapByID) XXX_Size added in v0.3.0 

func (m *QueryAtomicSwapByID) XXX_Size() int

func (*QueryAtomicSwapByID) XXX_Unmarshal added in v0.3.0 

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

type QueryAtomicSwaps 

type QueryAtomicSwaps struct {
	Page       int           `protobuf:"varint,1,opt,name=page,proto3,casttype=int" json:"page,omitempty" yaml:"page"`
	Limit      int           `protobuf:"varint,2,opt,name=limit,proto3,casttype=int" json:"limit,omitempty" yaml:"limit"`
	Involve    string        `protobuf:"bytes,3,opt,name=involve,proto3" json:"involve,omitempty" yaml:"involve"`
	Expiration int64         `protobuf:"varint,4,opt,name=expiration,proto3" json:"expiration,omitempty" yaml:"involve"`
	Status     SwapStatus    `protobuf:"varint,5,opt,name=status,proto3,casttype=SwapStatus" json:"status,omitempty" yaml:"status"`
	Direction  SwapDirection `protobuf:"varint,6,opt,name=direction,proto3,casttype=SwapDirection" json:"direction,omitempty" yaml:"direction"`
}

QueryAtomicSwaps contains the params for an AtomicSwaps query

func NewQueryAtomicSwaps 

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

NewQueryAtomicSwaps creates a new instance of QueryAtomicSwaps

func (*QueryAtomicSwaps) Descriptor added in v0.3.0 

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

func (*QueryAtomicSwaps) GetDirection added in v0.3.0 

func (m *QueryAtomicSwaps) GetDirection() SwapDirection

func (*QueryAtomicSwaps) GetExpiration added in v0.3.0 

func (m *QueryAtomicSwaps) GetExpiration() int64

func (*QueryAtomicSwaps) GetInvolve added in v0.3.0 

func (m *QueryAtomicSwaps) GetInvolve() string

func (*QueryAtomicSwaps) GetLimit added in v0.3.0 

func (m *QueryAtomicSwaps) GetLimit() int

func (*QueryAtomicSwaps) GetPage added in v0.3.0 

func (m *QueryAtomicSwaps) GetPage() int

func (*QueryAtomicSwaps) GetStatus added in v0.3.0 

func (m *QueryAtomicSwaps) GetStatus() SwapStatus

func (*QueryAtomicSwaps) Marshal added in v0.3.0 

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

func (*QueryAtomicSwaps) MarshalTo added in v0.3.0 

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

func (*QueryAtomicSwaps) MarshalToSizedBuffer added in v0.3.0 

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

func (*QueryAtomicSwaps) ProtoMessage added in v0.3.0 

func (*QueryAtomicSwaps) ProtoMessage()

func (*QueryAtomicSwaps) Reset added in v0.3.0 

func (m *QueryAtomicSwaps) Reset()

func (*QueryAtomicSwaps) Size added in v0.3.0 

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

func (*QueryAtomicSwaps) String added in v0.3.0 

func (m *QueryAtomicSwaps) String() string

func (*QueryAtomicSwaps) Unmarshal added in v0.3.0 

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

func (*QueryAtomicSwaps) XXX_DiscardUnknown added in v0.3.0 

func (m *QueryAtomicSwaps) XXX_DiscardUnknown()

func (*QueryAtomicSwaps) XXX_Marshal added in v0.3.0 

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

func (*QueryAtomicSwaps) XXX_Merge added in v0.3.0 

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

func (*QueryAtomicSwaps) XXX_Size added in v0.3.0 

func (m *QueryAtomicSwaps) XXX_Size() int

func (*QueryAtomicSwaps) XXX_Unmarshal added in v0.3.0 

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

type QueryClient added in v0.3.0 

type QueryClient interface {
	AssetSupply(ctx context.Context, in *QueryAssetSupplyRequest, opts ...grpc.CallOption) (*QueryAssetSupplyResponse, error)
	AssetSupplies(ctx context.Context, in *QueryAssetSuppliesRequest, opts ...grpc.CallOption) (*QueryAssetSuppliesResponse, error)
	Swap(ctx context.Context, in *QuerySwapRequest, opts ...grpc.CallOption) (*QuerySwapResponse, error)
	Swaps(ctx context.Context, in *QuerySwapsRequest, opts ...grpc.CallOption) (*QuerySwapsResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient added in v0.3.0 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryServer added in v0.3.0 

type QueryServer interface {
	AssetSupply(context.Context, *QueryAssetSupplyRequest) (*QueryAssetSupplyResponse, error)
	AssetSupplies(context.Context, *QueryAssetSuppliesRequest) (*QueryAssetSuppliesResponse, error)
	Swap(context.Context, *QuerySwapRequest) (*QuerySwapResponse, error)
	Swaps(context.Context, *QuerySwapsRequest) (*QuerySwapsResponse, error)
}

QueryServer is the server API for Query service.

type QuerySwapRequest added in v0.3.0 

type QuerySwapRequest struct {
	SwapID github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 156-byte string literal not displayed */
}

gRPC swap req

func (*QuerySwapRequest) Descriptor added in v0.3.0 

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

func (*QuerySwapRequest) GetSwapID added in v0.3.0 

func (m *QuerySwapRequest) GetSwapID() github_com_tendermint_tendermint_libs_bytes.HexBytes

func (*QuerySwapRequest) Marshal added in v0.3.0 

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

func (*QuerySwapRequest) MarshalTo added in v0.3.0 

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

func (*QuerySwapRequest) MarshalToSizedBuffer added in v0.3.0 

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

func (*QuerySwapRequest) ProtoMessage added in v0.3.0 

func (*QuerySwapRequest) ProtoMessage()

func (*QuerySwapRequest) Reset added in v0.3.0 

func (m *QuerySwapRequest) Reset()

func (*QuerySwapRequest) Size added in v0.3.0 

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

func (*QuerySwapRequest) String added in v0.3.0 

func (m *QuerySwapRequest) String() string

func (*QuerySwapRequest) Unmarshal added in v0.3.0 

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

func (*QuerySwapRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *QuerySwapRequest) XXX_DiscardUnknown()

func (*QuerySwapRequest) XXX_Marshal added in v0.3.0 

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

func (*QuerySwapRequest) XXX_Merge added in v0.3.0 

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

func (*QuerySwapRequest) XXX_Size added in v0.3.0 

func (m *QuerySwapRequest) XXX_Size() int

func (*QuerySwapRequest) XXX_Unmarshal added in v0.3.0 

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

type QuerySwapResponse added in v0.3.0 

type QuerySwapResponse struct {
	Swap AtomicSwap `protobuf:"bytes,1,opt,name=swap,proto3" json:"swap" yaml:"swap"`
}

gRPC swap response

func (*QuerySwapResponse) Descriptor added in v0.3.0 

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

func (*QuerySwapResponse) GetSwap added in v0.3.0 

func (m *QuerySwapResponse) GetSwap() AtomicSwap

func (*QuerySwapResponse) Marshal added in v0.3.0 

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

func (*QuerySwapResponse) MarshalTo added in v0.3.0 

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

func (*QuerySwapResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*QuerySwapResponse) ProtoMessage added in v0.3.0 

func (*QuerySwapResponse) ProtoMessage()

func (*QuerySwapResponse) Reset added in v0.3.0 

func (m *QuerySwapResponse) Reset()

func (*QuerySwapResponse) Size added in v0.3.0 

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

func (*QuerySwapResponse) String added in v0.3.0 

func (m *QuerySwapResponse) String() string

func (*QuerySwapResponse) Unmarshal added in v0.3.0 

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

func (*QuerySwapResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *QuerySwapResponse) XXX_DiscardUnknown()

func (*QuerySwapResponse) XXX_Marshal added in v0.3.0 

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

func (*QuerySwapResponse) XXX_Merge added in v0.3.0 

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

func (*QuerySwapResponse) XXX_Size added in v0.3.0 

func (m *QuerySwapResponse) XXX_Size() int

func (*QuerySwapResponse) XXX_Unmarshal added in v0.3.0 

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

type QuerySwapsRequest added in v0.3.0 

type QuerySwapsRequest struct {
	Params *QueryAtomicSwaps `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty" yaml:"params"`
}

gRPC swaps req

func (*QuerySwapsRequest) Descriptor added in v0.3.0 

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

func (*QuerySwapsRequest) GetParams added in v0.3.0 

func (m *QuerySwapsRequest) GetParams() *QueryAtomicSwaps

func (*QuerySwapsRequest) Marshal added in v0.3.0 

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

func (*QuerySwapsRequest) MarshalTo added in v0.3.0 

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

func (*QuerySwapsRequest) MarshalToSizedBuffer added in v0.3.0 

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

func (*QuerySwapsRequest) ProtoMessage added in v0.3.0 

func (*QuerySwapsRequest) ProtoMessage()

func (*QuerySwapsRequest) Reset added in v0.3.0 

func (m *QuerySwapsRequest) Reset()

func (*QuerySwapsRequest) Size added in v0.3.0 

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

func (*QuerySwapsRequest) String added in v0.3.0 

func (m *QuerySwapsRequest) String() string

func (*QuerySwapsRequest) Unmarshal added in v0.3.0 

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

func (*QuerySwapsRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *QuerySwapsRequest) XXX_DiscardUnknown()

func (*QuerySwapsRequest) XXX_Marshal added in v0.3.0 

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

func (*QuerySwapsRequest) XXX_Merge added in v0.3.0 

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

func (*QuerySwapsRequest) XXX_Size added in v0.3.0 

func (m *QuerySwapsRequest) XXX_Size() int

func (*QuerySwapsRequest) XXX_Unmarshal added in v0.3.0 

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

type QuerySwapsResponse added in v0.3.0 

type QuerySwapsResponse struct {
	Swaps AugmentedAtomicSwaps `protobuf:"bytes,1,opt,name=swaps,proto3" json:"swaps" yaml:"swaps"`
}

gRPC swap response

func (*QuerySwapsResponse) Descriptor added in v0.3.0 

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

func (*QuerySwapsResponse) GetSwaps added in v0.3.0 

func (m *QuerySwapsResponse) GetSwaps() AugmentedAtomicSwaps

func (*QuerySwapsResponse) Marshal added in v0.3.0 

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

func (*QuerySwapsResponse) MarshalTo added in v0.3.0 

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

func (*QuerySwapsResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*QuerySwapsResponse) ProtoMessage added in v0.3.0 

func (*QuerySwapsResponse) ProtoMessage()

func (*QuerySwapsResponse) Reset added in v0.3.0 

func (m *QuerySwapsResponse) Reset()

func (*QuerySwapsResponse) Size added in v0.3.0 

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

func (*QuerySwapsResponse) String added in v0.3.0 

func (m *QuerySwapsResponse) String() string

func (*QuerySwapsResponse) Unmarshal added in v0.3.0 

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

func (*QuerySwapsResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *QuerySwapsResponse) XXX_DiscardUnknown()

func (*QuerySwapsResponse) XXX_Marshal added in v0.3.0 

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

func (*QuerySwapsResponse) XXX_Merge added in v0.3.0 

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

func (*QuerySwapsResponse) XXX_Size added in v0.3.0 

func (m *QuerySwapsResponse) XXX_Size() int

func (*QuerySwapsResponse) XXX_Unmarshal added in v0.3.0 

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

type SupplyLimit 

type SupplyLimit struct {
	// the absolute supply limit for an asset
	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" yaml:"limit"`
	// boolean for whether the supply is limited by time
	TimeLimited bool `protobuf:"varint,2,opt,name=time_limited,json=timeLimited,proto3" json:"time_limited,omitempty" yaml:"time_limited"`
	// the time.duration int64 units for which the supply time limit applies
	TimePeriod int64 `protobuf:"varint,3,opt,name=time_period,json=timePeriod,proto3" json:"time_period,omitempty" yaml:"time_period"`
	// the supply limit for an asset for each time period
	TimeBasedLimit github_com_cosmos_cosmos_sdk_types.Int `` /* 169-byte string literal not displayed */
}

SupplyLimit parameters that control the absolute and time-based limits for an assets's supply

func (*SupplyLimit) Descriptor added in v0.3.0 

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 added in v0.3.0 

func (m *SupplyLimit) GetTimeLimited() bool

func (*SupplyLimit) GetTimePeriod added in v0.3.0 

func (m *SupplyLimit) GetTimePeriod() int64

func (*SupplyLimit) Marshal added in v0.3.0 

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

func (*SupplyLimit) MarshalTo added in v0.3.0 

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

func (*SupplyLimit) MarshalToSizedBuffer added in v0.3.0 

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

func (*SupplyLimit) ProtoMessage added in v0.3.0 

func (*SupplyLimit) ProtoMessage()

func (*SupplyLimit) Reset added in v0.3.0 

func (m *SupplyLimit) Reset()

func (*SupplyLimit) Size added in v0.3.0 

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

func (SupplyLimit) String 

func (sl SupplyLimit) String() string

String implements fmt.Stringer

func (*SupplyLimit) Unmarshal added in v0.3.0 

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

func (*SupplyLimit) XXX_DiscardUnknown added in v0.3.0 

func (m *SupplyLimit) XXX_DiscardUnknown()

func (*SupplyLimit) XXX_Marshal added in v0.3.0 

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

func (*SupplyLimit) XXX_Merge added in v0.3.0 

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

func (*SupplyLimit) XXX_Size added in v0.3.0 

func (m *SupplyLimit) XXX_Size() int

func (*SupplyLimit) XXX_Unmarshal added in v0.3.0 

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

type SwapDirection 

type SwapDirection byte

SwapDirection is the direction of an AtomicSwap 

const (
	INVALID  SwapDirection = 0x00
	Incoming SwapDirection = 0x01
	Outgoing SwapDirection = 0x02
)

func NewSwapDirectionFromString 

func NewSwapDirectionFromString(str string) SwapDirection

NewSwapDirectionFromString converts string to SwapDirection type

func (SwapDirection) IsValid 

func (direction SwapDirection) IsValid() bool

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

func (SwapDirection) MarshalJSON 

func (direction SwapDirection) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SwapDirection

func (SwapDirection) String 

func (direction SwapDirection) String() string

String returns the string representation of a SwapDirection

func (*SwapDirection) UnmarshalJSON 

func (direction *SwapDirection) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals the SwapDirection

type SwapStatus 

type SwapStatus byte

SwapStatus is the status of an AtomicSwap 

const (
	NULL      SwapStatus = 0x00
	Open      SwapStatus = 0x01
	Completed SwapStatus = 0x02
	Expired   SwapStatus = 0x03
)

swap statuses

func NewSwapStatusFromString 

func NewSwapStatusFromString(str string) SwapStatus

NewSwapStatusFromString converts string to SwapStatus type

func (SwapStatus) IsValid 

func (status SwapStatus) IsValid() bool

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

func (SwapStatus) MarshalJSON 

func (status SwapStatus) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SwapStatus

func (SwapStatus) String 

func (status SwapStatus) String() string

String returns the string representation of a SwapStatus

func (*SwapStatus) UnmarshalJSON 

func (status *SwapStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals the SwapStatus

type UnimplementedMsgServer added in v0.3.0 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ClaimAtomicSwap added in v0.3.0 

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

func (*UnimplementedMsgServer) CreateAtomicSwap added in v0.3.0 

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

func (*UnimplementedMsgServer) RefundAtomicSwap added in v0.3.0 

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

type UnimplementedQueryServer added in v0.3.0 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AssetSupplies added in v0.3.0 

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

func (*UnimplementedQueryServer) AssetSupply added in v0.3.0 

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

func (*UnimplementedQueryServer) Swap added in v0.3.0 

func (*UnimplementedQueryServer) Swap(ctx context.Context, req *QuerySwapRequest) (*QuerySwapResponse, error)

func (*UnimplementedQueryServer) Swaps added in v0.3.0 

func (*UnimplementedQueryServer) Swaps(ctx context.Context, req *QuerySwapsRequest) (*QuerySwapsResponse, 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.