utils

package

v0.0.0-...-c0f8dde Latest Latest Go to latest Published: Aug 21, 2020 License: GPL-3.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/polynetwork/btc-relayer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GetCurrHeightFromPoly(poly *poly_go_sdk.PolySdk) (uint32, string, error)
func GetHeaderHashFromPoly(poly *poly_go_sdk.PolySdk, height uint32) (string, error)
func NeedRetry(msg string) bool
func SetUpPoly(poly *poly_go_sdk.PolySdk, rpcAddr string) error
func Wait(dura time.Duration)
type CrossChainItem
- func (cci *CrossChainItem) Deserialize(buf []byte) error
- func (cci *CrossChainItem) Serialize() ([]byte, error)
type CrossChainItemArr
- func (arr *CrossChainItemArr) Deserialize(buf []byte) error
- func (arr CrossChainItemArr) Serialize() ([]byte, error)
type FromPolyItem
type Header
type Headers
- func (h Headers) GetSortedRawHeaders() [][]byte
- func (h Headers) Len() int
- func (h Headers) Less(i, j int) bool
- func (h Headers) Swap(i, j int)
type NeedToRetryErr
- func (err NeedToRetryErr) Error() string
- func (err *NeedToRetryErr) String() string
type NetErr
- func (err NetErr) Error() string
type Request
type Response
type RestCli
- func NewRestCli(addr, user, pwd string) *RestCli
- func (cli *RestCli) BroadcastTx(tx string) (string, error)
- func (cli *RestCli) GetCurrentHeightAndHash() (uint32, string, error)
- func (cli *RestCli) GetHeader(hash string) (*wire.BlockHeader, error)
- func (cli *RestCli) GetProof(txids []string) (string, error)
- func (cli *RestCli) GetScriptPubKey(txid string, index uint32) (string, error)
- func (cli *RestCli) GetTxsAndHeader(height, after uint32) ([]*wire.MsgTx, *wire.BlockHeader, string, error)
- func (cli *RestCli) GetTxsInBlock(hash string) (*wire.MsgBlock, error)
- func (cli *RestCli) IsHeaderReady(height uint32) error

Constants ¶

View Source

const (
	BTC_ID              uint64 = 1
	HDR_LIMIT_PER_BATCH        = 1000
)

Variables ¶

View Source

var (
	SleepTime time.Duration = 10
)

Functions ¶

func GetCurrHeightFromPoly ¶

func GetCurrHeightFromPoly(poly *poly_go_sdk.PolySdk) (uint32, string, error)

func GetHeaderHashFromPoly ¶

func GetHeaderHashFromPoly(poly *poly_go_sdk.PolySdk, height uint32) (string, error)

func NeedRetry ¶

func NeedRetry(msg string) bool

func SetUpPoly ¶

func SetUpPoly(poly *poly_go_sdk.PolySdk, rpcAddr string) error

func Wait ¶

func Wait(dura time.Duration)

Types ¶

type CrossChainItem ¶

type CrossChainItem struct {
	Tx     []byte
	Proof  []byte
	Height uint32
	Txid   chainhash.Hash
}

func (*CrossChainItem) Deserialize ¶

func (cci *CrossChainItem) Deserialize(buf []byte) error

func (*CrossChainItem) Serialize ¶

func (cci *CrossChainItem) Serialize() ([]byte, error)

type CrossChainItemArr ¶

type CrossChainItemArr []*CrossChainItem

func (*CrossChainItemArr) Deserialize ¶

func (arr *CrossChainItemArr) Deserialize(buf []byte) error

func (CrossChainItemArr) Serialize ¶

func (arr CrossChainItemArr) Serialize() ([]byte, error)

type FromPolyItem ¶

type FromPolyItem struct {
	Tx string
}

type Header ¶

type Header struct {
	Raw    []byte
	Height uint32
	Hash   string
}

type Headers ¶

type Headers []*Header

func (Headers) GetSortedRawHeaders ¶

func (h Headers) GetSortedRawHeaders() [][]byte

func (Headers) Len ¶

func (h Headers) Len() int

func (Headers) Less ¶

func (h Headers) Less(i, j int) bool

func (Headers) Swap ¶

func (h Headers) Swap(i, j int)

type NeedToRetryErr ¶

type NeedToRetryErr struct {
	Err error
}

func (NeedToRetryErr) Error ¶

func (err NeedToRetryErr) Error() string

func (*NeedToRetryErr) String ¶

func (err *NeedToRetryErr) String() string

type NetErr ¶

type NetErr struct {
	Err error
}

func (NetErr) Error ¶

func (err NetErr) Error() string

type Request ¶

type Request struct {
	Jsonrpc string        `json:"jsonrpc"`
	Method  string        `json:"method"`
	Params  []interface{} `json:"params"`
	Id      int           `json:"id"`
}

type Response ¶

type Response struct {
	Result interface{}       `json:"result"`
	Error  *btcjson.RPCError `json:"error"`
	Id     int               `json:"id"`
}

type RestCli ¶

type RestCli struct {
	Addr string
	Cli  *http.Client
}

Get tx in block; Get proof;

func NewRestCli ¶

func NewRestCli(addr, user, pwd string) *RestCli

func (*RestCli) BroadcastTx ¶

func (cli *RestCli) BroadcastTx(tx string) (string, error)

func (*RestCli) GetCurrentHeightAndHash ¶

func (cli *RestCli) GetCurrentHeightAndHash() (uint32, string, error)

func (*RestCli) GetHeader ¶

func (cli *RestCli) GetHeader(hash string) (*wire.BlockHeader, error)

func (*RestCli) GetProof ¶

func (cli *RestCli) GetProof(txids []string) (string, error)

func (*RestCli) GetScriptPubKey ¶

func (cli *RestCli) GetScriptPubKey(txid string, index uint32) (string, error)

func (*RestCli) GetTxsAndHeader ¶

func (cli *RestCli) GetTxsAndHeader(height, after uint32) ([]*wire.MsgTx, *wire.BlockHeader, string, error)

func (*RestCli) GetTxsInBlock ¶

func (cli *RestCli) GetTxsInBlock(hash string) (*wire.MsgBlock, error)

func (*RestCli) IsHeaderReady ¶

func (cli *RestCli) IsHeaderReady(height uint32) error

Source Files ¶

View all Source files

utils.go

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