common

package
v0.0.0-...-b7b35bc Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2026 License: MIT Imports: 49 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NoAddress       = Address("")
	NoopAddress     = Address("noop")
	EVMNullAddress  = Address("0x0000000000000000000000000000000000000000")
	GaiaZeroAddress = Address("cosmos100000000000000000000000000000000708mjz")
)
View Source 
const (
	EmptyChain = Chain("")
	BSCChain   = Chain("Bsc")
	ETHChain   = Chain("Eth")
	BTCChain   = Chain("Btc")
	LTCChain   = Chain("Ltc")
	BCHChain   = Chain("Bch")
	DOGEChain  = Chain("Doge")
	THORChain  = Chain("Thor")
	GAIAChain  = Chain("Gaia")
	AVAXChain  = Chain("Avax")
	BASEChain  = Chain("Base")
	XRPChain   = Chain("Xrp")
	MAPChain   = Chain("Map")
	ARBChain   = Chain("Arb")
	TRONChain  = Chain("Tron")
	SOLChain   = Chain("Sol")

	SigningAlgoSecp256k1 = SigningAlgo("secp256k1")
	SigningAlgoEd25519   = SigningAlgo("ed25519")
)
View Source 
const CurrentChainNetwork = MainNet // todo switch network
View Source 
const One = 100000000

One is useful type so THORNode doesn't need to manage 8 zeroes all the time

View Source 
const THORChainDecimals = 8

THORChainDecimals indicate the number of decimal points used in THORChain

Variables

View Source 
var (
	// EmptyAsset empty asset, not valid
	EmptyAsset = Asset{Chain: EmptyChain, Symbol: "", Ticker: "", Synth: false}
	// ATOMAsset ATOM
	ATOMAsset = Asset{Chain: GAIAChain, Symbol: "ATOM", Ticker: "ATOM", Synth: false}
	// BNBBEP20Asset BNB
	BNBBEP20Asset = Asset{Chain: BSCChain, Symbol: "BNB", Ticker: "BNB", Synth: false}
	// BTCAsset BTC
	BTCAsset = Asset{Chain: BTCChain, Symbol: "BTC", Ticker: "BTC", Synth: false}
	// LTCAsset BTC
	LTCAsset = Asset{Chain: LTCChain, Symbol: "LTC", Ticker: "LTC", Synth: false}
	// BCHAsset BCH
	BCHAsset = Asset{Chain: BCHChain, Symbol: "BCH", Ticker: "BCH", Synth: false}
	// DOGEAsset DOGE
	DOGEAsset = Asset{Chain: DOGEChain, Symbol: "DOGE", Ticker: "DOGE", Synth: false}
	// ETHAsset ETH
	ETHAsset = Asset{Chain: ETHChain, Symbol: "ETH", Ticker: "ETH", Synth: false}
	// BaseAsset ETH
	BaseETHAsset = Asset{Chain: BASEChain, Symbol: "ETH", Ticker: "ETH", Synth: false}
	// AVAXAsset AVAX
	AVAXAsset = Asset{Chain: AVAXChain, Symbol: "AVAX", Ticker: "AVAX", Synth: false}
	// XRPAsset XRP
	XRPAsset = Asset{Chain: XRPChain, Symbol: "XRP", Ticker: "XRP", Synth: false}
	// RuneNative RUNE on thorchain
	RuneNative = Asset{Chain: THORChain, Symbol: "RUNE", Ticker: "RUNE", Synth: false}
	TCY        = Asset{Chain: THORChain, Symbol: "TCY", Ticker: "TCY", Synth: false}
	TOR        = Asset{Chain: THORChain, Symbol: "TOR", Ticker: "TOR", Synth: false}
	THORBTC    = Asset{Chain: THORChain, Symbol: "BTC", Ticker: "BTC", Synth: false}
	// MAPAsset MAPO
	MAPAsset = Asset{Chain: MAPChain, Symbol: "MAPO", Ticker: "MAPO", Synth: false}
)
View Source 
var (
	ErrInvalidLengthCommon        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCommon          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCommon = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	EmptyPubKey    PubKey
	EmptyPubKeySet PubKeySet
)
View Source 
var AllChains = [...]Chain{
	BSCChain,
	ETHChain,
	BTCChain,
	LTCChain,
	BCHChain,
	DOGEChain,
	GAIAChain,
	AVAXChain,
	BASEChain,
	XRPChain,
	MAPChain,
	ARBChain,
}
View Source 
var BlankTxID = TxID("0000000000000000000000000000000000000000000000000000000000000000")

BlankTxID represent blank

View Source 
var LatestVersion semver.Version = semver.MustParse("999.0.0")
View Source 
var NoCoin = Coin{
	Asset:  EmptyAsset,
	Amount: cosmos.ZeroUint(),
}

NoCoin is empty Coin

View Source 
var Status_name = map[int32]string{
	0: "incomplete",
	1: "done",
	2: "reverted",
}
View Source 
var Status_value = map[string]int32{
	"incomplete": 0,
	"done":       1,
	"reverted":   2,
}
View Source 
var UnsupportedChain = errors.New("unsupported chain")

Functions

func Abs 

func Abs[T int | int64](a T) T

func Completion 

func Completion(bytes []byte, number int) []byte

func CompressPubKey 

func CompressPubKey(pks []byte) (string, error)

func ConvertAndEncode 

func ConvertAndEncode(hrp string, data []byte) (string, error)

ConvertAndEncode converts from a base64 encoded byte string to hex or base32 encoded byte string and then to bech32

func CosmosPrivateKeyToTMPrivateKey 

func CosmosPrivateKeyToTMPrivateKey(privateKey cryptotypes.PrivKey) crypto.PrivKey

CosmosPrivateKeyToTMPrivateKey convert cosmos implementation of private key to tendermint private key

func Entropy 

func Entropy(b []byte) float64

func GetMedianInt64 

func GetMedianInt64(vals []int64) int64

func GetMedianUint 

func GetMedianUint(vals []cosmos.Uint) cosmos.Uint

func GetSafeShare 

func GetSafeShare(part, total, allocation cosmos.Uint) cosmos.Uint

GetSafeShare does the same as GetUncappedShare , but GetSafeShare will guarantee the result will not more than total. The first two arguments should always have the same units (cancelling out to represent a unitless ratio applied to the allocation).

func GetUncappedShare 

func GetUncappedShare(part, total, allocation cosmos.Uint) (share cosmos.Uint)

GetUncappedShare this method will panic if any of the input parameter can't be convert to cosmos.Dec which shouldn't happen. The first two arguments should always have the same units (cancelling out to represent a unitless ratio applied to the allocation).

func HasHexPrefix 

func HasHexPrefix(s string) bool

func IsValidXRPAddress 

func IsValidXRPAddress(address string) bool

func JSON 

func JSON(v interface{}) string

func Max 

func Max[T int | uint | int64 | uint64](a, b T) T

func Min 

func Min[T int | uint | int64 | uint64](a, b T) T

func RandHexString 

func RandHexString(n int) string

RandHexString generates random hex string used for test purpose

func RoundSignificantFigures 

func RoundSignificantFigures(number uint64, significantDigits int64) uint64

RoundSignificantFigures rounds an unsigned 64-bit integer to the specified number of significant digits. It takes the number and significant digits as arguments.

func SafeSub 

func SafeSub(input1, input2 cosmos.Uint) cosmos.Uint

SafeSub subtract input2 from input1, given cosmos.Uint can't be negative , otherwise it will panic thus in this method,when input2 is larger than input 1, it will just return cosmos.ZeroUint

func Sign 

func Sign(buf []byte) ([]byte, []byte, error)

Sign an array of bytes. Returns (signature, pubkey, error)

func SignBase64 

func SignBase64(buf []byte) (string, string, error)

func TrimHexPrefix 

func TrimHexPrefix(s string) string

func WeightedMean 

func WeightedMean(vals, weights []cosmos.Uint) (cosmos.Uint, error)

WeightedMean calculates the weighted mean of a set of values and their weights.

Types

type Account 

type Account struct {
	Sequence      int64
	AccountNumber int64
	Coins         Coins
	HasMemoFlag   bool
}

Account define a struct to hold account information across all chain

func NewAccount 

func NewAccount(sequence, accountNumber int64, coins Coins, hasMemoFlag bool) Account

NewAccount create a new instance of Account

type Address 

type Address string

func ConvertToNewBCHAddressFormat 

func ConvertToNewBCHAddressFormat(addr Address) (Address, error)

ConvertToNewBCHAddressFormat convert the given BCH to new address format

func NewAddress 

func NewAddress(address string) (Address, error)

NewAddress create a new Address. Supports ETH/bech2/BTC/LTC/BCH/DOGE/XRP.

func (Address) AccAddress 

func (addr Address) AccAddress() (cosmos.AccAddress, error)

func (Address) Equals 

func (addr Address) Equals(addr2 Address) bool

func (Address) GetChain 

func (addr Address) GetChain() Chain

Note that this will always return ETHChain for an AVAXChain address, so perhaps only use it when determining a network (e.g. mainnet/testnet).

func (Address) GetNetwork 

func (addr Address) GetNetwork(chain Chain) ChainNetwork

func (Address) IsChain 

func (addr Address) IsChain(chain Chain) bool

Note that this can have false positives, such as being unable to distinguish between ETH and AVAX.

func (Address) IsEmpty 

func (addr Address) IsEmpty() bool

func (Address) IsNoop 

func (addr Address) IsNoop() bool

func (Address) IsValidBCHAddress 

func (addr Address) IsValidBCHAddress() bool

IsValidBCHAddress determinate whether the address is a valid new BCH address format

func (Address) MappedAccAddress 

func (addr Address) MappedAccAddress() (cosmos.AccAddress, error)

func (Address) String 

func (addr Address) String() string

type Asset 

type Asset struct {
	Chain   Chain  `protobuf:"bytes,1,opt,name=chain,proto3,casttype=Chain" json:"chain,omitempty"`
	Symbol  Symbol `protobuf:"bytes,2,opt,name=symbol,proto3,casttype=Symbol" json:"symbol,omitempty"`
	Ticker  Ticker `protobuf:"bytes,3,opt,name=ticker,proto3,casttype=Ticker" json:"ticker,omitempty"`
	Synth   bool   `protobuf:"varint,4,opt,name=synth,proto3" json:"synth,omitempty"`
	Trade   bool   `protobuf:"varint,5,opt,name=trade,proto3" json:"trade,omitempty"`
	Secured bool   `protobuf:"varint,6,opt,name=secured,proto3" json:"secured,omitempty"`
}

func NewAsset 

func NewAsset(input string) (Asset, error)

NewAsset parse the given input into Asset object

func NewAssetWithShortCodes 

func NewAssetWithShortCodes(version semver.Version, input string) (Asset, error)

func NewAssetWithShortCodesV3_1_0 

func NewAssetWithShortCodesV3_1_0(input string) (Asset, error)

func RuneAsset 

func RuneAsset() Asset

RuneAsset return RUNE Asset depends on different environment

func (*Asset) Descriptor 

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

func (Asset) Equals 

func (a Asset) Equals(a2 Asset) bool

Equals determinate whether two assets are equivalent

func (Asset) GetChain 

func (a Asset) GetChain() Chain

func (Asset) GetDerivedAsset 

func (a Asset) GetDerivedAsset() Asset

Get derived asset of asset

func (Asset) GetLayer1Asset 

func (a Asset) GetLayer1Asset() Asset

Get layer1 asset version

func (Asset) GetSecuredAsset 

func (a Asset) GetSecuredAsset() Asset

Get secured asset of asset

func (Asset) GetSyntheticAsset 

func (a Asset) GetSyntheticAsset() Asset

Get synthetic asset of asset

func (Asset) GetTradeAsset 

func (a Asset) GetTradeAsset() Asset

Get trade asset of asset

func (Asset) IsDerivedAsset 

func (a Asset) IsDerivedAsset() bool

Check if asset is a derived asset

func (Asset) IsEmpty 

func (a Asset) IsEmpty() bool

IsEmpty will be true when any of the field is empty, chain,symbol or ticker

func (Asset) IsGasAsset 

func (a Asset) IsGasAsset() bool

IsGasAsset check whether asset is base asset used to pay for gas

func (Asset) IsNative 

func (a Asset) IsNative() bool

IsNative is a helper function, returns true when the asset is a native asset to MAPChain (ie rune, a synth, etc)

func (Asset) IsRune 

func (a Asset) IsRune() bool

IsRune is a helper function ,return true only when the asset represent RUNE

func (Asset) IsSecuredAsset 

func (a Asset) IsSecuredAsset() bool

func (Asset) IsSyntheticAsset 

func (a Asset) IsSyntheticAsset() bool

Check if asset is a pegged asset

func (Asset) IsTCY 

func (a Asset) IsTCY() bool

IsTCY is a helper function ,return true only when the asset represent RUNE

func (Asset) IsTradeAsset 

func (a Asset) IsTradeAsset() bool

func (Asset) IsVaultAsset 

func (a Asset) IsVaultAsset() bool

func (*Asset) Marshal 

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

func (Asset) MarshalJSON 

func (a Asset) MarshalJSON() ([]byte, error)

MarshalJSON implement Marshaler interface

func (Asset) MarshalJSONPB 

func (a Asset) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)

MarshalJSONPB implement jsonpb.Marshaler

func (*Asset) MarshalTo 

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

func (*Asset) MarshalToSizedBuffer 

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

func (Asset) MimirString 

func (a Asset) MimirString() string

Replace pool name "." with a "-" for Mimir key checking.

func (Asset) Native 

func (a Asset) Native() string

Native return native asset, only relevant on MAPChain

func (*Asset) ProtoMessage 

func (*Asset) ProtoMessage()

func (*Asset) Reset 

func (m *Asset) Reset()

func (Asset) ShortCode 

func (a Asset) ShortCode() string

ShortCode returns the short code for the asset.

func (*Asset) Size 

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

func (Asset) String 

func (a Asset) String() string

String implement fmt.Stringer , return the string representation of Asset

func (*Asset) Unmarshal 

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

func (*Asset) UnmarshalJSON 

func (a *Asset) UnmarshalJSON(data []byte) error

UnmarshalJSON implement Unmarshaler interface

func (*Asset) UnmarshalJSONPB 

func (a *Asset) UnmarshalJSONPB(unmarshal *jsonpb.Unmarshaler, content []byte) error

UnmarshalJSONPB implement jsonpb.Unmarshaler

func (Asset) Valid 

func (a Asset) Valid() error

func (*Asset) XXX_DiscardUnknown 

func (m *Asset) XXX_DiscardUnknown()

func (*Asset) XXX_Marshal 

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

func (*Asset) XXX_Merge 

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

func (*Asset) XXX_Size 

func (m *Asset) XXX_Size() int

func (*Asset) XXX_Unmarshal 

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

type AttestErrataTx 

type AttestErrataTx struct {
	ErrataTx    *ErrataTx    `protobuf:"bytes,1,opt,name=errata_tx,json=errataTx,proto3" json:"errata_tx,omitempty"`
	Attestation *Attestation `protobuf:"bytes,2,opt,name=attestation,proto3" json:"attestation,omitempty"`
}

func (*AttestErrataTx) Descriptor 

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

func (*AttestErrataTx) GetAttestation 

func (a *AttestErrataTx) GetAttestation() *Attestation

Implement AttestMessage for AttestErrataTx

func (*AttestErrataTx) GetSignablePayload 

func (a *AttestErrataTx) GetSignablePayload() ([]byte, error)

func (*AttestErrataTx) Marshal 

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

func (*AttestErrataTx) MarshalTo 

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

func (*AttestErrataTx) MarshalToSizedBuffer 

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

func (*AttestErrataTx) ProtoMessage 

func (*AttestErrataTx) ProtoMessage()

func (*AttestErrataTx) Reset 

func (m *AttestErrataTx) Reset()

func (*AttestErrataTx) Size 

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

func (*AttestErrataTx) String 

func (this *AttestErrataTx) String() string

func (*AttestErrataTx) Unmarshal 

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

func (*AttestErrataTx) XXX_DiscardUnknown 

func (m *AttestErrataTx) XXX_DiscardUnknown()

func (*AttestErrataTx) XXX_Marshal 

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

func (*AttestErrataTx) XXX_Merge 

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

func (*AttestErrataTx) XXX_Size 

func (m *AttestErrataTx) XXX_Size() int

func (*AttestErrataTx) XXX_Unmarshal 

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

type AttestNetworkFee 

type AttestNetworkFee struct {
	NetworkFee  *NetworkFee  `protobuf:"bytes,1,opt,name=network_fee,json=networkFee,proto3" json:"network_fee,omitempty"`
	Attestation *Attestation `protobuf:"bytes,2,opt,name=attestation,proto3" json:"attestation,omitempty"`
}

func (*AttestNetworkFee) Descriptor 

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

func (*AttestNetworkFee) GetAttestation 

func (a *AttestNetworkFee) GetAttestation() *Attestation

Implement AttestMessage for AttestNetworkFee

func (*AttestNetworkFee) GetSignablePayload 

func (a *AttestNetworkFee) GetSignablePayload() ([]byte, error)

func (*AttestNetworkFee) Marshal 

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

func (*AttestNetworkFee) MarshalTo 

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

func (*AttestNetworkFee) MarshalToSizedBuffer 

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

func (*AttestNetworkFee) ProtoMessage 

func (*AttestNetworkFee) ProtoMessage()

func (*AttestNetworkFee) Reset 

func (m *AttestNetworkFee) Reset()

func (*AttestNetworkFee) Size 

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

func (*AttestNetworkFee) String 

func (this *AttestNetworkFee) String() string

func (*AttestNetworkFee) Unmarshal 

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

func (*AttestNetworkFee) XXX_DiscardUnknown 

func (m *AttestNetworkFee) XXX_DiscardUnknown()

func (*AttestNetworkFee) XXX_Marshal 

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

func (*AttestNetworkFee) XXX_Merge 

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

func (*AttestNetworkFee) XXX_Size 

func (m *AttestNetworkFee) XXX_Size() int

func (*AttestNetworkFee) XXX_Unmarshal 

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

type AttestSolvency 

type AttestSolvency struct {
	Solvency    *Solvency    `protobuf:"bytes,1,opt,name=solvency,proto3" json:"solvency,omitempty"`
	Attestation *Attestation `protobuf:"bytes,2,opt,name=attestation,proto3" json:"attestation,omitempty"`
}

func (*AttestSolvency) Descriptor 

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

func (*AttestSolvency) GetAttestation 

func (a *AttestSolvency) GetAttestation() *Attestation

Implement AttestMessage for AttestSolvency

func (*AttestSolvency) GetSignablePayload 

func (a *AttestSolvency) GetSignablePayload() ([]byte, error)

func (*AttestSolvency) Marshal 

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

func (*AttestSolvency) MarshalTo 

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

func (*AttestSolvency) MarshalToSizedBuffer 

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

func (*AttestSolvency) ProtoMessage 

func (*AttestSolvency) ProtoMessage()

func (*AttestSolvency) Reset 

func (m *AttestSolvency) Reset()

func (*AttestSolvency) Size 

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

func (*AttestSolvency) String 

func (this *AttestSolvency) String() string

func (*AttestSolvency) Unmarshal 

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

func (*AttestSolvency) XXX_DiscardUnknown 

func (m *AttestSolvency) XXX_DiscardUnknown()

func (*AttestSolvency) XXX_Marshal 

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

func (*AttestSolvency) XXX_Merge 

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

func (*AttestSolvency) XXX_Size 

func (m *AttestSolvency) XXX_Size() int

func (*AttestSolvency) XXX_Unmarshal 

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

type AttestTx 

type AttestTx struct {
	ObsTx                  ObservedTx   `protobuf:"bytes,1,opt,name=obsTx,proto3" json:"obsTx"`
	Attestation            *Attestation `protobuf:"bytes,2,opt,name=attestation,proto3" json:"attestation,omitempty"`
	Inbound                bool         `protobuf:"varint,3,opt,name=inbound,proto3" json:"inbound,omitempty"`
	AllowFutureObservation bool         `` /* 130-byte string literal not displayed */
}

func (*AttestTx) Descriptor 

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

func (*AttestTx) GetAttestation 

func (a *AttestTx) GetAttestation() *Attestation

Implement AttestMessage for AttestTx

func (*AttestTx) GetSignablePayload 

func (a *AttestTx) GetSignablePayload() ([]byte, error)

func (*AttestTx) Marshal 

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

func (*AttestTx) MarshalTo 

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

func (*AttestTx) MarshalToSizedBuffer 

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

func (*AttestTx) ProtoMessage 

func (*AttestTx) ProtoMessage()

func (*AttestTx) Reset 

func (m *AttestTx) Reset()

func (*AttestTx) Size 

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

func (*AttestTx) String 

func (this *AttestTx) String() string

func (*AttestTx) Unmarshal 

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

func (*AttestTx) XXX_DiscardUnknown 

func (m *AttestTx) XXX_DiscardUnknown()

func (*AttestTx) XXX_Marshal 

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

func (*AttestTx) XXX_Merge 

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

func (*AttestTx) XXX_Size 

func (m *AttestTx) XXX_Size() int

func (*AttestTx) XXX_Unmarshal 

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

type Attestation 

type Attestation struct {
	PubKey    []byte `protobuf:"bytes,1,opt,name=PubKey,proto3" json:"PubKey,omitempty"`
	Signature []byte `protobuf:"bytes,2,opt,name=Signature,proto3" json:"Signature,omitempty"`
}

func (*Attestation) Descriptor 

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

func (*Attestation) Equals 

func (a *Attestation) Equals(att *Attestation) bool

Equals compares two Attestation and returns true iff they are equal

func (*Attestation) Marshal 

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

func (*Attestation) MarshalTo 

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

func (*Attestation) MarshalToSizedBuffer 

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

func (*Attestation) ProtoMessage 

func (*Attestation) ProtoMessage()

func (*Attestation) Reset 

func (m *Attestation) Reset()

func (*Attestation) Size 

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

func (*Attestation) String 

func (this *Attestation) String() string

func (*Attestation) Unmarshal 

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

func (*Attestation) XXX_DiscardUnknown 

func (m *Attestation) XXX_DiscardUnknown()

func (*Attestation) XXX_Marshal 

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

func (*Attestation) XXX_Merge 

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

func (*Attestation) XXX_Size 

func (m *Attestation) XXX_Size() int

func (*Attestation) XXX_Unmarshal 

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

type AttestationBatch 

type AttestationBatch struct {
	AttestTxs         []*AttestTx         `protobuf:"bytes,1,rep,name=attest_txs,json=attestTxs,proto3" json:"attest_txs,omitempty"`
	AttestNetworkFees []*AttestNetworkFee `protobuf:"bytes,2,rep,name=attest_network_fees,json=attestNetworkFees,proto3" json:"attest_network_fees,omitempty"`
	AttestSolvencies  []*AttestSolvency   `protobuf:"bytes,3,rep,name=attest_solvencies,json=attestSolvencies,proto3" json:"attest_solvencies,omitempty"`
	AttestErrataTxs   []*AttestErrataTx   `protobuf:"bytes,4,rep,name=attest_errata_txs,json=attestErrataTxs,proto3" json:"attest_errata_txs,omitempty"`
}

func (*AttestationBatch) Descriptor 

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

func (*AttestationBatch) Marshal 

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

func (*AttestationBatch) MarshalTo 

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

func (*AttestationBatch) MarshalToSizedBuffer 

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

func (*AttestationBatch) ProtoMessage 

func (*AttestationBatch) ProtoMessage()

func (*AttestationBatch) Reset 

func (m *AttestationBatch) Reset()

func (*AttestationBatch) Size 

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

func (*AttestationBatch) String 

func (this *AttestationBatch) String() string

func (*AttestationBatch) Unmarshal 

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

func (*AttestationBatch) XXX_DiscardUnknown 

func (m *AttestationBatch) XXX_DiscardUnknown()

func (*AttestationBatch) XXX_Marshal 

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

func (*AttestationBatch) XXX_Merge 

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

func (*AttestationBatch) XXX_Size 

func (m *AttestationBatch) XXX_Size() int

func (*AttestationBatch) XXX_Unmarshal 

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

type Chain 

type Chain string

func GetChainName 

func GetChainName(key *big.Int) (Chain, bool)

func GetEVMChains 

func GetEVMChains() []Chain

GetEVMChains returns all "EVM" chains connected to THORChain "EVM" is defined, in thornode's context, as a chain that: - uses 0x as an address prefix - has a "Router" Smart Contract

func GetUTXOChains 

func GetUTXOChains() []Chain

GetUTXOChains returns all "UTXO" chains connected to THORChain.

func NewChain 

func NewChain(chainID string) (Chain, error)

NewChain create a new Chain and default the siging_algo to Secp256k1

func (Chain) AddressPrefix 

func (c Chain) AddressPrefix(cn ChainNetwork) string

AddressPrefix return the address prefix used by the given network (mocknet/mainnet)

func (Chain) ApproximateBlockMilliseconds 

func (c Chain) ApproximateBlockMilliseconds() int64

func (Chain) ChainID 

func (c Chain) ChainID() (*big.Int, error)

func (Chain) DecodeAddress 

func (c Chain) DecodeAddress(address string) ([]byte, error)

func (Chain) DefaultCoinbase 

func (c Chain) DefaultCoinbase() float64

DefaultCoinbase returns the default coinbase address for each chain, returns 0 if no coinbase emission is used. This is used used at the time of writing as a fallback value in Bifrost, and for inbound confirmation count estimates in the quote APIs.

func (Chain) DustThreshold 

func (c Chain) DustThreshold() cosmos.Uint

DustThreshold returns the min dust threshold for each chain The min dust threshold defines the lower end of the withdraw range of memoless savers txs The native coin value provided in a memoless tx defines a basis points amount of Withdraw or Add to a savers position as follows: Withdraw range: (dust_threshold + 1) -> (dust_threshold + 10_000) Add range: dust_threshold -> Inf NOTE: these should all be in 8 decimal places

func (Chain) Equals 

func (c Chain) Equals(c2 Chain) bool

Equals compare two chain to see whether they represent the same chain

func (Chain) GetGasAsset 

func (c Chain) GetGasAsset() Asset

GetGasAsset chain's base asset

func (Chain) GetSigningAlgo 

func (c Chain) GetSigningAlgo() SigningAlgo

GetSigningAlgo get the signing algorithm for the given chain

func (Chain) InboundNotes 

func (c Chain) InboundNotes() string

func (Chain) IsBSCChain 

func (c Chain) IsBSCChain() bool

func (Chain) IsEVM 

func (c Chain) IsEVM() bool

IsEVM returns true if given chain is an EVM chain. See working definition of an "EVM" chain in the `GetEVMChains` function description

func (Chain) IsEmpty 

func (c Chain) IsEmpty() bool

IsEmpty is to determinate whether the chain is empty

func (Chain) IsMAPChain 

func (c Chain) IsMAPChain() bool

func (Chain) IsUTXO 

func (c Chain) IsUTXO() bool

IsUTXO returns true if given chain is a UTXO chain.

func (Chain) IsValidAddress 

func (c Chain) IsValidAddress(addr Address) bool

IsValidAddress make sure the address is correct for the chain And this also make sure mocknet doesn't use mainnet address vice versa

func (Chain) MaxMemoLength 

func (c Chain) MaxMemoLength() int

MaxMemoLength returns the max memo length for each chain.

func (Chain) NativeToken 

func (c Chain) NativeToken() (string, bool)

func (Chain) String 

func (c Chain) String() string

String implement fmt.Stringer

func (Chain) Valid 

func (c Chain) Valid() error

Valid validates chain format, should consist only of uppercase letters

type ChainNetwork 

type ChainNetwork uint8

ChainNetwork is to indicate which chain environment THORNode are working with 

const (
	// MainNet network for mainnet
	MainNet ChainNetwork = iota + 1
	// TestNet network for mocknet
	TestNet
)

func (ChainNetwork) SoftEquals 

func (net ChainNetwork) SoftEquals(net2 ChainNetwork) bool

Soft Equals check is mainnet == mainet, or mocknet == mocknet

type ChainPoolInfo 

type ChainPoolInfo struct {
	Chain       Chain   `json:"chain"`
	PubKey      PubKey  `json:"pub_key"`
	PoolAddress Address `json:"pool_address"`
}

ChainPoolInfo represent the pool address specific for a chain 

var EmptyChainPoolInfo ChainPoolInfo

EmptyChainPoolInfo everything is empty

func NewChainPoolInfo 

func NewChainPoolInfo(chain Chain, pubKey PubKey) (ChainPoolInfo, error)

NewChainPoolInfo create a new instance of ChainPoolInfo

func (ChainPoolInfo) IsEmpty 

func (cpi ChainPoolInfo) IsEmpty() bool

IsEmpty whether the struct is empty

type Chains 

type Chains []Chain

Chains represent a slice of Chain

func NewChains 

func NewChains(raw []string) (Chains, error)

func (Chains) Distinct 

func (chains Chains) Distinct() Chains

Distinct return a distinct set of chains, no duplicates

func (Chains) Has 

func (chains Chains) Has(c Chain) bool

Has check whether chain c is in the list

func (Chains) Strings 

func (chains Chains) Strings() []string

type Coin 

type Coin struct {
	Asset    Asset                  `protobuf:"bytes,1,opt,name=asset,proto3,customtype=Asset" json:"asset"`
	Amount   cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=amount,proto3,customtype=cosmossdk.io/math.Uint" json:"amount"`
	Decimals int64                  `protobuf:"varint,3,opt,name=decimals,proto3" json:"decimals,omitempty"`
}

func NewCoin 

func NewCoin(asset Asset, amount cosmos.Uint) Coin

NewCoin return a new instance of Coin

func ParseCoin 

func ParseCoin(coinStr string) (Coin, error)

ParseCoin parses a coin string and panics if it is invalid.

func (*Coin) Descriptor 

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

func (Coin) Equals 

func (c Coin) Equals(cc Coin) bool

Equals compare two coins to see whether they represent the same information

func (Coin) IsEmpty 

func (c Coin) IsEmpty() bool

IsEmpty check whether asset is empty or amount is zero

func (Coin) IsNative 

func (c Coin) IsNative() bool

IsNative check whether the coin is native on THORChain

func (Coin) IsRune 

func (c Coin) IsRune() bool

IsRune checks whether the coin's Asset is RUNE.

func (Coin) IsTCY 

func (c Coin) IsTCY() bool

IsTCY checks whether the coin's Asset is TCY.

func (*Coin) Marshal 

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

func (*Coin) MarshalTo 

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

func (*Coin) MarshalToSizedBuffer 

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

func (Coin) Native 

func (c Coin) Native() (cosmos.Coin, error)

Native create a new instance of cosmos.Coin

func (*Coin) ProtoMessage 

func (*Coin) ProtoMessage()

func (*Coin) Reset 

func (m *Coin) Reset()

func (*Coin) Size 

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

func (Coin) String 

func (c Coin) String() string

String implement fmt.Stringer

func (*Coin) Unmarshal 

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

func (Coin) Valid 

func (c Coin) Valid() error

Valid return an error if the coin is not correct

func (Coin) WithDecimals 

func (c Coin) WithDecimals(decimal int64) Coin

WithDecimals update coin with a decimal

func (*Coin) XXX_DiscardUnknown 

func (m *Coin) XXX_DiscardUnknown()

func (*Coin) XXX_Marshal 

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

func (*Coin) XXX_Merge 

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

func (*Coin) XXX_Size 

func (m *Coin) XXX_Size() int

func (*Coin) XXX_Unmarshal 

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

type Coins 

type Coins []Coin

Coins represent a slice of Coin

func NewCoins 

func NewCoins(coins ...Coin) Coins

NewCoins create a new Coins structure

func (Coins) Add 

func (oldCoins Coins) Add(addCoins ...Coin) Coins

func (Coins) Contains 

func (cs Coins) Contains(c Coin) bool

Contains check whether the given coin is in the list

func (Coins) Copy 

func (cs Coins) Copy() Coins

Copy returns a new copy of Coins.

func (Coins) Distinct 

func (cs Coins) Distinct() Coins

Distinct return a new Coins ,which duplicated coins had been removed

func (Coins) EqualsEx 

func (cs Coins) EqualsEx(cs2 Coins) bool

EqualsEx Check if two lists of coins are equal to each other. This method will make a copy of cs1 & cs2 , thus the original coins order will not be changed

func (Coins) GetCoin 

func (cs Coins) GetCoin(asset Asset) Coin

GetCoin gets a specific coin by asset. Assumes there is only one of this coin in the list.

func (Coins) HasSynthetic 

func (cs Coins) HasSynthetic() bool

HasSynthetic check whether the coins contains synth coin

func (Coins) IsEmpty 

func (cs Coins) IsEmpty() bool

func (Coins) Native 

func (cs Coins) Native() (cosmos.Coins, error)

func (Coins) NoneEmpty 

func (cs Coins) NoneEmpty() Coins

NoneEmpty return a new Coins , which ignore the coin that is empty either Coin asset is empty or amount is empty

func (Coins) SafeSub 

func (oldCoins Coins) SafeSub(subCoins ...Coin) Coins

func (Coins) String 

func (cs Coins) String() string

String implement fmt.Stringer

func (Coins) Valid 

func (cs Coins) Valid() error

Valid check whether all the coins are valid , if not , then return an error

type ErrataTx 

type ErrataTx struct {
	Id    TxID  `protobuf:"bytes,1,opt,name=id,proto3,casttype=TxID" json:"id,omitempty"`
	Chain Chain `protobuf:"bytes,2,opt,name=chain,proto3,casttype=Chain" json:"chain,omitempty"`
}

func (*ErrataTx) Descriptor 

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

func (*ErrataTx) Equals 

func (e *ErrataTx) Equals(other *ErrataTx) bool

func (*ErrataTx) GetSignablePayload 

func (e *ErrataTx) GetSignablePayload() ([]byte, error)

GetSignablePayload returns the data that is signed for verification

func (*ErrataTx) Marshal 

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

func (*ErrataTx) MarshalTo 

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

func (*ErrataTx) MarshalToSizedBuffer 

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

func (*ErrataTx) ProtoMessage 

func (*ErrataTx) ProtoMessage()

func (*ErrataTx) Reset 

func (m *ErrataTx) Reset()

func (*ErrataTx) Size 

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

func (*ErrataTx) String 

func (this *ErrataTx) String() string

func (*ErrataTx) Unmarshal 

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

func (*ErrataTx) XXX_DiscardUnknown 

func (m *ErrataTx) XXX_DiscardUnknown()

func (*ErrataTx) XXX_Marshal 

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

func (*ErrataTx) XXX_Merge 

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

func (*ErrataTx) XXX_Size 

func (m *ErrataTx) XXX_Size() int

func (*ErrataTx) XXX_Unmarshal 

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

type Fee 

type Fee struct {
	Coins      Coins                  `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=Coins" json:"coins"`
	PoolDeduct cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=pool_deduct,json=poolDeduct,proto3,customtype=cosmossdk.io/math.Uint" json:"pool_deduct"`
}

func NewFee 

func NewFee(coins Coins, poolDeduct cosmos.Uint) Fee

NewFee return a new instance of Fee

func (*Fee) Descriptor 

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

func (*Fee) Marshal 

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

func (*Fee) MarshalTo 

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

func (*Fee) MarshalToSizedBuffer 

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

func (*Fee) ProtoMessage 

func (*Fee) ProtoMessage()

func (*Fee) Reset 

func (m *Fee) Reset()

func (*Fee) Size 

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

func (Fee) String 

func (f Fee) String() string

func (*Fee) Unmarshal 

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

func (*Fee) XXX_DiscardUnknown 

func (m *Fee) XXX_DiscardUnknown()

func (*Fee) XXX_Marshal 

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

func (*Fee) XXX_Merge 

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

func (*Fee) XXX_Size 

func (m *Fee) XXX_Size() int

func (*Fee) XXX_Unmarshal 

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

type Gas 

type Gas Coins

Gas coins

func GetEVMGasFee 

func GetEVMGasFee(chain Chain, gasPrice *big.Int, msgLen uint64) Gas

func MakeEVMGas 

func MakeEVMGas(chain Chain, gasPrice *big.Int, gas uint64, layer1Fee *big.Int) Gas

func (Gas) Add 

func (gas Gas) Add(addCoins ...Coin) Gas

Coins Add for Gas.

func (Gas) Adds_deprecated 

func (g Gas) Adds_deprecated(g2 Gas) Gas

Add combines two gas objects into one, adding amounts where needed or appending new coins. **WARNING**: dangerous, returns self-reference and also self-modifies

func (Gas) Equals 

func (g Gas) Equals(gas2 Gas) bool

Equals Check if two lists of coins are equal to each other. Order does not matter

func (Gas) IsEmpty 

func (g Gas) IsEmpty() bool

IsEmpty return true as long as there is one coin in it that is not empty

func (Gas) NoneEmpty 

func (g Gas) NoneEmpty() Gas

NoneEmpty returns a new Gas which ignores any coin which is empty either Coin asset is empty or amount is empty

func (Gas) SafeSub 

func (gas Gas) SafeSub(subCoins ...Coin) Gas

Coins SafeSub for Gas.

func (Gas) ToCoins 

func (g Gas) ToCoins() Coins

ToCoins convert the gas to Coins

func (Gas) Valid 

func (g Gas) Valid() error

Valid return nil when it is valid, otherwise return an error

type Invariant 

type Invariant func(ctx cosmos.Context) (msg []string, broken bool)

An Invariant is a function which tests a particular invariant. The invariant returns a descriptive message about what happened and a boolean indicating whether the invariant has been broken.

type InvariantRoute 

type InvariantRoute struct {
	Route     string
	Invariant Invariant
}

invariant route

func NewInvariantRoute 

func NewInvariantRoute(route string, invariant Invariant) InvariantRoute

NewInvariantRoute - create an InvariantRoute object

type NetworkFee 

type NetworkFee struct {
	Height          int64  `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Chain           Chain  `protobuf:"bytes,2,opt,name=chain,proto3,casttype=Chain" json:"chain,omitempty"`
	TransactionSize uint64 `protobuf:"varint,3,opt,name=transaction_size,json=transactionSize,proto3" json:"transaction_size,omitempty"`
	TransactionRate uint64 `protobuf:"varint,4,opt,name=transaction_rate,json=transactionRate,proto3" json:"transaction_rate,omitempty"`
}

func (*NetworkFee) Descriptor 

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

func (*NetworkFee) Equals 

func (nf *NetworkFee) Equals(other *NetworkFee) bool

func (*NetworkFee) GetSignablePayload 

func (nf *NetworkFee) GetSignablePayload() ([]byte, error)

GetSignablePayload returns the data that is signed for verification

func (*NetworkFee) Marshal 

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

func (*NetworkFee) MarshalTo 

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

func (*NetworkFee) MarshalToSizedBuffer 

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

func (*NetworkFee) ProtoMessage 

func (*NetworkFee) ProtoMessage()

func (*NetworkFee) Reset 

func (m *NetworkFee) Reset()

func (*NetworkFee) Size 

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

func (*NetworkFee) String 

func (this *NetworkFee) String() string

func (*NetworkFee) Unmarshal 

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

func (*NetworkFee) Valid 

func (m *NetworkFee) Valid() error

Valid - check whether NetworkFee struct represent valid information

func (*NetworkFee) XXX_DiscardUnknown 

func (m *NetworkFee) XXX_DiscardUnknown()

func (*NetworkFee) XXX_Marshal 

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

func (*NetworkFee) XXX_Merge 

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

func (*NetworkFee) XXX_Size 

func (m *NetworkFee) XXX_Size() int

func (*NetworkFee) XXX_Unmarshal 

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

type ObservedTx 

type ObservedTx struct {
	Tx                    Tx                      `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx"`
	Status                Status                  `protobuf:"varint,2,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`
	OutHashes             []string                `protobuf:"bytes,3,rep,name=out_hashes,json=outHashes,proto3" json:"out_hashes,omitempty"`
	BlockHeight           int64                   `protobuf:"varint,4,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	Signers               []string                `protobuf:"bytes,5,rep,name=signers,proto3" json:"signers,omitempty"`
	ObservedPubKey        PubKey                  `protobuf:"bytes,6,opt,name=observed_pub_key,json=observedPubKey,proto3,casttype=PubKey" json:"observed_pub_key,omitempty"`
	KeysignMs             int64                   `protobuf:"varint,7,opt,name=keysign_ms,json=keysignMs,proto3" json:"keysign_ms,omitempty"`
	FinaliseHeight        int64                   `protobuf:"varint,8,opt,name=finalise_height,json=finaliseHeight,proto3" json:"finalise_height,omitempty"`
	Aggregator            string                  `protobuf:"bytes,9,opt,name=aggregator,proto3" json:"aggregator,omitempty"`
	AggregatorTarget      string                  `protobuf:"bytes,10,opt,name=aggregator_target,json=aggregatorTarget,proto3" json:"aggregator_target,omitempty"`
	AggregatorTargetLimit *cosmossdk_io_math.Uint `` /* 161-byte string literal not displayed */
}

func NewObservedTx 

func NewObservedTx(tx Tx, height int64, pk PubKey, finalisedHeight int64) ObservedTx

NewObservedTx create a new instance of ObservedTx

func (*ObservedTx) Descriptor 

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

func (ObservedTx) Equals 

func (m ObservedTx) Equals(tx2 ObservedTx) bool

Equals compare two ObservedTx

func (*ObservedTx) GetOutHashes 

func (m *ObservedTx) GetOutHashes() TxIDs

func (*ObservedTx) GetSignablePayload 

func (o *ObservedTx) GetSignablePayload() ([]byte, error)

GetSignablePayload returns the data that is signed for verification

func (*ObservedTx) GetSigners 

func (m *ObservedTx) GetSigners() []cosmos.AccAddress

GetSigners return all the node address that had sign the tx

func (*ObservedTx) HasSigned 

func (m *ObservedTx) HasSigned(signer cosmos.AccAddress) bool

HasSigned - check if given address has signed

func (*ObservedTx) IsDone 

func (m *ObservedTx) IsDone(numOuts int) bool

IsDone will only return true when the number of out hashes is larger or equals the input number

func (*ObservedTx) IsEmpty 

func (m *ObservedTx) IsEmpty() bool

IsEmpty check whether the Tx is empty

func (*ObservedTx) IsFinal 

func (m *ObservedTx) IsFinal() bool

IsFinal indicates whether ObserveTx is final.

func (*ObservedTx) Marshal 

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

func (*ObservedTx) MarshalTo 

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

func (*ObservedTx) MarshalToSizedBuffer 

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

func (*ObservedTx) ProtoMessage 

func (*ObservedTx) ProtoMessage()

func (*ObservedTx) Reset 

func (m *ObservedTx) Reset()

func (*ObservedTx) SetDone 

func (m *ObservedTx) SetDone(hash TxID, numOuts int)

SetDone check the ObservedTx status, update it's status to done if the outbound tx had been processed

func (*ObservedTx) Sign 

func (m *ObservedTx) Sign(signer cosmos.AccAddress) bool

Sign add the given node account to signers list if the given signer is already in the list, it will return false, otherwise true

func (*ObservedTx) Size 

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

func (*ObservedTx) String 

func (m *ObservedTx) String() string

String implement fmt.Stringer

func (*ObservedTx) Unmarshal 

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

func (*ObservedTx) Valid 

func (m *ObservedTx) Valid() error

Valid check whether the observed tx represent valid information

func (*ObservedTx) XXX_DiscardUnknown 

func (m *ObservedTx) XXX_DiscardUnknown()

func (*ObservedTx) XXX_Marshal 

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

func (*ObservedTx) XXX_Merge 

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

func (*ObservedTx) XXX_Size 

func (m *ObservedTx) XXX_Size() int

func (*ObservedTx) XXX_Unmarshal 

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

type ObservedTxs 

type ObservedTxs []ObservedTx

ObservedTxs a list of ObservedTx

func (ObservedTxs) Contains 

func (txs ObservedTxs) Contains(tx ObservedTx) bool

type ProtoUint 

type ProtoUint struct {
	Value cosmossdk_io_math.Uint `protobuf:"bytes,1,opt,name=value,proto3,customtype=cosmossdk.io/math.Uint" json:"value"`
}

func (*ProtoUint) Descriptor 

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

func (*ProtoUint) Marshal 

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

func (*ProtoUint) MarshalTo 

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

func (*ProtoUint) MarshalToSizedBuffer 

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

func (*ProtoUint) ProtoMessage 

func (*ProtoUint) ProtoMessage()

func (*ProtoUint) Reset 

func (m *ProtoUint) Reset()

func (*ProtoUint) Size 

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

func (*ProtoUint) String 

func (this *ProtoUint) String() string

func (*ProtoUint) Unmarshal 

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

func (*ProtoUint) XXX_DiscardUnknown 

func (m *ProtoUint) XXX_DiscardUnknown()

func (*ProtoUint) XXX_Marshal 

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

func (*ProtoUint) XXX_Merge 

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

func (*ProtoUint) XXX_Size 

func (m *ProtoUint) XXX_Size() int

func (*ProtoUint) XXX_Unmarshal 

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

type PubKey 

type PubKey string

PubKey used in thorchain, it should be bech32 encoded string thus it will be something like tthorpub1addwnpepqt7qug8vk9r3saw8n4r803ydj2g3dqwx0mvq5akhnze86fc536xcycgtrnv tthorpub1addwnpepqdqvd4r84lq9m54m5kk9sf4k6kdgavvch723pcgadulxd6ey9u70k6zq8qe

func NewPubKey 

func NewPubKey(key string) (PubKey, error)

NewPubKey create a new instance of PubKey key is bech32 encoded string

func NewPubKeyByEth 

func NewPubKeyByEth(key string) (PubKey, error)

NewPubKeyByEth create a new instance of PubKey key is bech32 encoded string

func NewPubKeyFromCrypto 

func NewPubKeyFromCrypto(pk crypto.PubKey) (PubKey, error)

func (PubKey) EVMPubkeyToAddress 

func (p PubKey) EVMPubkeyToAddress() (Address, error)

EVMPubkeyToAddress converts a pubkey of an EVM chain to the corresponding address

func (PubKey) Equals 

func (p PubKey) Equals(pubKey1 PubKey) bool

Equals check whether two are the same

func (PubKey) GetAddress 

func (p PubKey) GetAddress(chain Chain) (Address, error)

GetAddress will return an address for the given chain

func (PubKey) GetThorAddress 

func (p PubKey) GetThorAddress() (cosmos.AccAddress, error)

func (PubKey) IsEmpty 

func (p PubKey) IsEmpty() bool

IsEmpty to check whether it is empty

func (PubKey) MarshalJSON 

func (p PubKey) MarshalJSON() ([]byte, error)

MarshalJSON to Marshals to JSON using Bech32

func (PubKey) Secp256K1 

func (p PubKey) Secp256K1() (*btcec.PublicKey, error)

func (PubKey) String 

func (p PubKey) String() string

String stringer implementation

func (*PubKey) UnmarshalJSON 

func (p *PubKey) UnmarshalJSON(data []byte) error

UnmarshalJSON to Unmarshal from JSON assuming Bech32 encoding

type PubKeySet 

type PubKeySet struct {
	Secp256k1 PubKey `protobuf:"bytes,1,opt,name=secp256k1,proto3,casttype=PubKey" json:"secp256k1,omitempty"`
	Ed25519   PubKey `protobuf:"bytes,2,opt,name=ed25519,proto3,casttype=PubKey" json:"ed25519,omitempty"`
}

PubKeySet contains two pub keys , secp256k1 and ed25519

func NewPubKeySet 

func NewPubKeySet(secp256k1, ed25519 PubKey) PubKeySet

NewPubKeySet create a new instance of PubKeySet , which contains two keys

func (PubKeySet) Contains 

func (p PubKeySet) Contains(pk PubKey) bool

func (*PubKeySet) Descriptor 

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

func (PubKeySet) Equals 

func (p PubKeySet) Equals(pks1 PubKeySet) bool

Equals check whether two PubKeySet are the same

func (PubKeySet) GetAddress 

func (p PubKeySet) GetAddress(chain Chain) (Address, error)

GetAddress

func (PubKeySet) IsEmpty 

func (p PubKeySet) IsEmpty() bool

IsEmpty will determinate whether PubKeySet is an empty

func (*PubKeySet) Marshal 

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

func (*PubKeySet) MarshalTo 

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

func (*PubKeySet) MarshalToSizedBuffer 

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

func (*PubKeySet) ProtoMessage 

func (*PubKeySet) ProtoMessage()

func (*PubKeySet) Reset 

func (m *PubKeySet) Reset()

func (*PubKeySet) Size 

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

func (PubKeySet) String 

func (p PubKeySet) String() string

String implements fmt.Stringer

func (*PubKeySet) Unmarshal 

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

func (*PubKeySet) XXX_DiscardUnknown 

func (m *PubKeySet) XXX_DiscardUnknown()

func (*PubKeySet) XXX_Marshal 

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

func (*PubKeySet) XXX_Merge 

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

func (*PubKeySet) XXX_Size 

func (m *PubKeySet) XXX_Size() int

func (*PubKeySet) XXX_Unmarshal 

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

type PubKeys 

type PubKeys []PubKey

PubKey used in thorchain, it should be bech32 encoded string thus it will be something like tthorpub1addwnpepqt7qug8vk9r3saw8n4r803ydj2g3dqwx0mvq5akhnze86fc536xcycgtrnv tthorpub1addwnpepqdqvd4r84lq9m54m5kk9sf4k6kdgavvch723pcgadulxd6ey9u70k6zq8qe

func (PubKeys) Addresses 

func (p PubKeys) Addresses() ([]cosmos.AccAddress, error)

func (PubKeys) Contains 

func (p PubKeys) Contains(pk PubKey) bool

func (PubKeys) Equals 

func (p PubKeys) Equals(newPks PubKeys) bool

Equals check whether two pub keys are identical

func (PubKeys) String 

func (p PubKeys) String() string

String implement stringer interface

func (PubKeys) Strings 

func (p PubKeys) Strings() []string

func (PubKeys) Valid 

func (p PubKeys) Valid() error

type QuorumErrataTx 

type QuorumErrataTx struct {
	ErrataTx     *ErrataTx      `protobuf:"bytes,1,opt,name=errata_tx,json=errataTx,proto3" json:"errata_tx,omitempty"`
	Attestations []*Attestation `protobuf:"bytes,2,rep,name=attestations,proto3" json:"attestations,omitempty"`
}

func (*QuorumErrataTx) Descriptor 

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

func (*QuorumErrataTx) Equals 

func (qe *QuorumErrataTx) Equals(other *QuorumErrataTx) bool

func (*QuorumErrataTx) GetAttestations 

func (qe *QuorumErrataTx) GetAttestations() []*Attestation

func (*QuorumErrataTx) Marshal 

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

func (*QuorumErrataTx) MarshalTo 

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

func (*QuorumErrataTx) MarshalToSizedBuffer 

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

func (*QuorumErrataTx) ProtoMessage 

func (*QuorumErrataTx) ProtoMessage()

func (*QuorumErrataTx) RemoveAttestations 

func (qe *QuorumErrataTx) RemoveAttestations(atts []*Attestation) bool

func (*QuorumErrataTx) Reset 

func (m *QuorumErrataTx) Reset()

func (*QuorumErrataTx) SetAttestations 

func (qe *QuorumErrataTx) SetAttestations(atts []*Attestation) *QuorumErrataTx

func (*QuorumErrataTx) Size 

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

func (*QuorumErrataTx) String 

func (this *QuorumErrataTx) String() string

func (*QuorumErrataTx) Unmarshal 

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

func (*QuorumErrataTx) XXX_DiscardUnknown 

func (m *QuorumErrataTx) XXX_DiscardUnknown()

func (*QuorumErrataTx) XXX_Marshal 

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

func (*QuorumErrataTx) XXX_Merge 

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

func (*QuorumErrataTx) XXX_Size 

func (m *QuorumErrataTx) XXX_Size() int

func (*QuorumErrataTx) XXX_Unmarshal 

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

type QuorumNetworkFee 

type QuorumNetworkFee struct {
	NetworkFee   *NetworkFee    `protobuf:"bytes,1,opt,name=network_fee,json=networkFee,proto3" json:"network_fee,omitempty"`
	Attestations []*Attestation `protobuf:"bytes,2,rep,name=attestations,proto3" json:"attestations,omitempty"`
}

func (*QuorumNetworkFee) Descriptor 

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

func (*QuorumNetworkFee) Equals 

func (qnf *QuorumNetworkFee) Equals(other *QuorumNetworkFee) bool

func (*QuorumNetworkFee) GetAttestations 

func (qnf *QuorumNetworkFee) GetAttestations() []*Attestation

func (*QuorumNetworkFee) Marshal 

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

func (*QuorumNetworkFee) MarshalTo 

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

func (*QuorumNetworkFee) MarshalToSizedBuffer 

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

func (*QuorumNetworkFee) ProtoMessage 

func (*QuorumNetworkFee) ProtoMessage()

func (*QuorumNetworkFee) RemoveAttestations 

func (qnf *QuorumNetworkFee) RemoveAttestations(atts []*Attestation) bool

RemoveAttestations removes matching attestations from a quorum network fee, and returns true if there are no more attestations.

func (*QuorumNetworkFee) Reset 

func (m *QuorumNetworkFee) Reset()

func (*QuorumNetworkFee) SetAttestations 

func (qnf *QuorumNetworkFee) SetAttestations(atts []*Attestation) *QuorumNetworkFee

func (*QuorumNetworkFee) Size 

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

func (*QuorumNetworkFee) String 

func (this *QuorumNetworkFee) String() string

func (*QuorumNetworkFee) Unmarshal 

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

func (*QuorumNetworkFee) XXX_DiscardUnknown 

func (m *QuorumNetworkFee) XXX_DiscardUnknown()

func (*QuorumNetworkFee) XXX_Marshal 

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

func (*QuorumNetworkFee) XXX_Merge 

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

func (*QuorumNetworkFee) XXX_Size 

func (m *QuorumNetworkFee) XXX_Size() int

func (*QuorumNetworkFee) XXX_Unmarshal 

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

type QuorumSolvency 

type QuorumSolvency struct {
	Solvency     *Solvency      `protobuf:"bytes,1,opt,name=solvency,proto3" json:"solvency,omitempty"`
	Attestations []*Attestation `protobuf:"bytes,2,rep,name=attestations,proto3" json:"attestations,omitempty"`
}

func (*QuorumSolvency) Descriptor 

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

func (*QuorumSolvency) Equals 

func (qs *QuorumSolvency) Equals(other *QuorumSolvency) bool

func (*QuorumSolvency) GetAttestations 

func (qs *QuorumSolvency) GetAttestations() []*Attestation

func (*QuorumSolvency) Marshal 

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

func (*QuorumSolvency) MarshalTo 

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

func (*QuorumSolvency) MarshalToSizedBuffer 

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

func (*QuorumSolvency) ProtoMessage 

func (*QuorumSolvency) ProtoMessage()

func (*QuorumSolvency) RemoveAttestations 

func (qs *QuorumSolvency) RemoveAttestations(atts []*Attestation) bool

func (*QuorumSolvency) Reset 

func (m *QuorumSolvency) Reset()

func (*QuorumSolvency) SetAttestations 

func (qs *QuorumSolvency) SetAttestations(atts []*Attestation) *QuorumSolvency

func (*QuorumSolvency) Size 

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

func (*QuorumSolvency) String 

func (this *QuorumSolvency) String() string

func (*QuorumSolvency) Unmarshal 

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

func (*QuorumSolvency) XXX_DiscardUnknown 

func (m *QuorumSolvency) XXX_DiscardUnknown()

func (*QuorumSolvency) XXX_Marshal 

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

func (*QuorumSolvency) XXX_Merge 

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

func (*QuorumSolvency) XXX_Size 

func (m *QuorumSolvency) XXX_Size() int

func (*QuorumSolvency) XXX_Unmarshal 

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

type QuorumState 

type QuorumState struct {
	QuoTxs         []*QuorumTx         `protobuf:"bytes,1,rep,name=quoTxs,proto3" json:"quoTxs,omitempty"`
	QuoNetworkFees []*QuorumNetworkFee `protobuf:"bytes,2,rep,name=quoNetworkFees,proto3" json:"quoNetworkFees,omitempty"`
	QuoSolvencies  []*QuorumSolvency   `protobuf:"bytes,3,rep,name=quoSolvencies,proto3" json:"quoSolvencies,omitempty"`
	QuoErrataTxs   []*QuorumErrataTx   `protobuf:"bytes,4,rep,name=quoErrataTxs,proto3" json:"quoErrataTxs,omitempty"`
}

func (*QuorumState) Descriptor 

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

func (*QuorumState) Marshal 

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

func (*QuorumState) MarshalTo 

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

func (*QuorumState) MarshalToSizedBuffer 

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

func (*QuorumState) ProtoMessage 

func (*QuorumState) ProtoMessage()

func (*QuorumState) Reset 

func (m *QuorumState) Reset()

func (*QuorumState) Size 

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

func (*QuorumState) String 

func (this *QuorumState) String() string

func (*QuorumState) Unmarshal 

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

func (*QuorumState) XXX_DiscardUnknown 

func (m *QuorumState) XXX_DiscardUnknown()

func (*QuorumState) XXX_Marshal 

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

func (*QuorumState) XXX_Merge 

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

func (*QuorumState) XXX_Size 

func (m *QuorumState) XXX_Size() int

func (*QuorumState) XXX_Unmarshal 

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

type QuorumTx 

type QuorumTx struct {
	ObsTx                  ObservedTx     `protobuf:"bytes,1,opt,name=obsTx,proto3" json:"obsTx"`
	Attestations           []*Attestation `protobuf:"bytes,2,rep,name=attestations,proto3" json:"attestations,omitempty"`
	Inbound                bool           `protobuf:"varint,3,opt,name=inbound,proto3" json:"inbound,omitempty"`
	AllowFutureObservation bool           `` /* 130-byte string literal not displayed */
}

func (*QuorumTx) Descriptor 

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

func (*QuorumTx) Equals 

func (qtx *QuorumTx) Equals(other *QuorumTx) bool

func (*QuorumTx) GetAttestations 

func (qtx *QuorumTx) GetAttestations() []*Attestation

func (*QuorumTx) Marshal 

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

func (*QuorumTx) MarshalTo 

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

func (*QuorumTx) MarshalToSizedBuffer 

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

func (*QuorumTx) ProtoMessage 

func (*QuorumTx) ProtoMessage()

func (*QuorumTx) RemoveAttestations 

func (qtx *QuorumTx) RemoveAttestations(atts []*Attestation) bool

RemoveAttestations removes matching attestations from a quorum tx, and returns true if there are no more attestations.

func (*QuorumTx) Reset 

func (m *QuorumTx) Reset()

func (*QuorumTx) SetAttestations 

func (qtx *QuorumTx) SetAttestations(atts []*Attestation) *QuorumTx

func (*QuorumTx) Size 

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

func (*QuorumTx) String 

func (this *QuorumTx) String() string

func (*QuorumTx) Unmarshal 

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

func (*QuorumTx) XXX_DiscardUnknown 

func (m *QuorumTx) XXX_DiscardUnknown()

func (*QuorumTx) XXX_Marshal 

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

func (*QuorumTx) XXX_Merge 

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

func (*QuorumTx) XXX_Size 

func (m *QuorumTx) XXX_Size() int

func (*QuorumTx) XXX_Unmarshal 

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

type SigningAlgo 

type SigningAlgo string

type Solvency 

type Solvency struct {
	Id     TxID   `protobuf:"bytes,1,opt,name=id,proto3,casttype=TxID" json:"id,omitempty"`
	Chain  Chain  `protobuf:"bytes,2,opt,name=chain,proto3,casttype=Chain" json:"chain,omitempty"`
	PubKey PubKey `protobuf:"bytes,3,opt,name=pub_key,json=pubKey,proto3,casttype=PubKey" json:"pub_key,omitempty"`
	Coins  Coins  `protobuf:"bytes,4,rep,name=coins,proto3,castrepeated=Coins" json:"coins"`
	Height int64  `protobuf:"varint,5,opt,name=height,proto3" json:"height,omitempty"`
}

func (*Solvency) Descriptor 

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

func (*Solvency) Equals 

func (s *Solvency) Equals(other *Solvency) bool

func (*Solvency) GetSignablePayload 

func (s *Solvency) GetSignablePayload() ([]byte, error)

GetSignablePayload returns the data that is signed for verification

func (*Solvency) Hash 

func (s *Solvency) Hash() (TxID, error)

func (*Solvency) Marshal 

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

func (*Solvency) MarshalTo 

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

func (*Solvency) MarshalToSizedBuffer 

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

func (*Solvency) ProtoMessage 

func (*Solvency) ProtoMessage()

func (*Solvency) Reset 

func (m *Solvency) Reset()

func (*Solvency) Size 

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

func (*Solvency) String 

func (this *Solvency) String() string

func (*Solvency) Unmarshal 

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

func (*Solvency) XXX_DiscardUnknown 

func (m *Solvency) XXX_DiscardUnknown()

func (*Solvency) XXX_Marshal 

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

func (*Solvency) XXX_Merge 

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

func (*Solvency) XXX_Size 

func (m *Solvency) XXX_Size() int

func (*Solvency) XXX_Unmarshal 

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

type Status 

type Status int32
const (
	Status_incomplete Status = 0
	Status_done       Status = 1
	Status_reverted   Status = 2
)

func (Status) EnumDescriptor 

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

func (Status) MarshalJSON 

func (x Status) MarshalJSON() ([]byte, error)

MarshalJSON marshal Status to JSON in string form

func (Status) String 

func (x Status) String() string

func (*Status) UnmarshalJSON 

func (x *Status) UnmarshalJSON(b []byte) error

UnmarshalJSON convert string form back to Status

type Symbol 

type Symbol string

Symbol represent an asset

func NewSymbol 

func NewSymbol(input string) (Symbol, error)

NewSymbol parse the input as symbol

func (Symbol) Equals 

func (s Symbol) Equals(s2 Symbol) bool

Equals check whether two symbol are the same

func (Symbol) IsEmpty 

func (s Symbol) IsEmpty() bool

IsEmpty return true when symbol is just empty string

func (Symbol) IsMiniToken 

func (s Symbol) IsMiniToken() bool

IsMiniToken is to determine whether it is a mini token on binance chain

func (Symbol) String 

func (s Symbol) String() string

String implement fmt.Stringer

func (Symbol) Ticker 

func (s Symbol) Ticker() Ticker

Ticker return the ticker part of symbol

func (Symbol) Valid 

func (s Symbol) Valid() error

type Ticker 

type Ticker string

Ticker The trading 'symbol' or shortened name (typically in capital letters) that refer to a coin on a trading platform. For example: ETH

func NewTicker 

func NewTicker(ticker string) (Ticker, error)

NewTicker parse the given string as ticker, return error if it is not legitimate ticker

func (Ticker) Equals 

func (t Ticker) Equals(t2 Ticker) bool

Equals compare whether two ticker is the same

func (Ticker) IsEmpty 

func (t Ticker) IsEmpty() bool

IsEmpty return true when the ticker is an empty string

func (Ticker) String 

func (t Ticker) String() string

String implement fmt.Stringer

type Tickers 

type Tickers []Ticker

Tickers a list of ticker

type Tx 

type Tx struct {
	ID          TxID    `protobuf:"bytes,1,opt,name=id,proto3,casttype=TxID" json:"id,omitempty"`
	Chain       Chain   `protobuf:"bytes,2,opt,name=chain,proto3,casttype=Chain" json:"chain,omitempty"`
	FromAddress Address `protobuf:"bytes,3,opt,name=from_address,json=fromAddress,proto3,casttype=Address" json:"from_address,omitempty"`
	ToAddress   Address `protobuf:"bytes,4,opt,name=to_address,json=toAddress,proto3,casttype=Address" json:"to_address,omitempty"`
	Coins       Coins   `protobuf:"bytes,5,rep,name=coins,proto3,castrepeated=Coins" json:"coins"`
	Gas         Gas     `protobuf:"bytes,6,rep,name=gas,proto3,castrepeated=Gas" json:"gas"`
	Memo        string  `protobuf:"bytes,7,opt,name=memo,proto3" json:"memo,omitempty"`
}

func GetRagnarokTx 

func GetRagnarokTx(chain Chain, fromAddr, toAddr Address) Tx

GetRagnarokTx return a tx used for ragnarok

func NewTx 

func NewTx(txID TxID, from, to Address, coins Coins, gas Gas, memo string) Tx

NewTx create a new instance of Tx based on the input information

func (*Tx) Descriptor 

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

func (Tx) EqualsEx 

func (tx Tx) EqualsEx(tx2 Tx) bool

EqualsEx compare two Tx to see whether they represent the same Tx This method will not change the original tx & tx2

func (Tx) Hash 

func (tx Tx) Hash(blockHeight int64) string

Hash calculates an internal hash based on chain, from address, coins, to address and block height.

func (Tx) IsEmpty 

func (tx Tx) IsEmpty() bool

IsEmpty check whether the ID field is empty or not

func (*Tx) Marshal 

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

func (*Tx) MarshalTo 

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

func (*Tx) MarshalToSizedBuffer 

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

func (*Tx) ProtoMessage 

func (*Tx) ProtoMessage()

func (*Tx) Reset 

func (m *Tx) Reset()

func (*Tx) Size 

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

func (Tx) String 

func (tx Tx) String() string

String implement fmt.Stringer return a string representation of the tx

func (Tx) ToAttributes 

func (tx Tx) ToAttributes() []cosmos.Attribute

ToAttributes push all the tx fields into a slice of cosmos Attribute(key value pairs)

func (*Tx) Unmarshal 

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

func (Tx) Valid 

func (tx Tx) Valid() error

Valid do some data sanity check , if the tx contains invalid information it will return an none nil error

func (*Tx) XXX_DiscardUnknown 

func (m *Tx) XXX_DiscardUnknown()

func (*Tx) XXX_Marshal 

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

func (*Tx) XXX_Merge 

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

func (*Tx) XXX_Size 

func (m *Tx) XXX_Size() int

func (*Tx) XXX_Unmarshal 

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

type TxID 

type TxID string

TxID is a string that can uniquely represent a transaction on different block chain

func NewTxID 

func NewTxID(hash string) (TxID, error)

NewTxID parse the input hash as TxID

func (TxID) Equals 

func (tx TxID) Equals(tx2 TxID) bool

Equals check whether two TxID are the same

func (TxID) Int64 

func (tx TxID) Int64() int64

func (TxID) IsBlank 

func (tx TxID) IsBlank() bool

func (TxID) IsEmpty 

func (tx TxID) IsEmpty() bool

IsEmpty return true when the tx represent empty string

func (TxID) Reverse 

func (tx TxID) Reverse() TxID

Reverse returns a reversed version of the TxID

func (TxID) String 

func (tx TxID) String() string

String implement fmt.Stringer

type TxIDs 

type TxIDs []TxID

TxIDs is a slice of TxID

type Txs 

type Txs []Tx

Txs a list of Tx

Source Files

View all Source files

Directories

Path Synopsis
avaxtokens
basetokens
bsctokens
ethtokens

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.