btc

package
v1.3.0 Latest Latest
Warning

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

Go to latest
Published: Mar 19, 2025 License: LGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Chain

type Chain struct {
	// contains filtered or unexported fields
}

func New

func New() *Chain

func (*Chain) Conn

func (c *Chain) Conn() core.Connection

Conn return Connection interface for relayer register

func (*Chain) Id

func (c *Chain) Id() msg.ChainId

func (*Chain) Name

func (c *Chain) Name() string

func (*Chain) New

func (c *Chain) New(chainCfg *core.ChainConfig, logger log15.Logger, sysErr chan<- error, role mapprotocol.Role) (core.Chain, error)

func (*Chain) SetRouter

func (c *Chain) SetRouter(r core.Router)

func (*Chain) Start

func (c *Chain) Start() error

func (*Chain) Stop

func (c *Chain) Stop()

Stop signals to any running routines to exit

type Config

type Config struct {
	chain.Config
	Addr string
}

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(endpoint string, log log15.Logger) *Connection

func (*Connection) CallOpts

func (c *Connection) CallOpts() *bind.CallOpts

func (*Connection) Client

func (c *Connection) Client() *ethclient.Client

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) Connect

func (c *Connection) Connect() error

Connect starts the ethereum WS connection

func (*Connection) EnsureHasBytecode

func (c *Connection) EnsureHasBytecode(addr ethcommon.Address) error

EnsureHasBytecode asserts if contract code exists at the specified address

func (*Connection) Keypair

func (c *Connection) Keypair() *keystore.Key

func (*Connection) LatestBlock

func (c *Connection) LatestBlock() (*big.Int, error)

LatestBlock returns the latest block from the current chain

func (*Connection) LockAndUpdateOpts

func (c *Connection) LockAndUpdateOpts(needNewNonce bool) error

func (*Connection) Opts

func (c *Connection) Opts() *bind.TransactOpts

func (*Connection) UnlockOpts

func (c *Connection) UnlockOpts()

func (*Connection) WaitForBlock

func (c *Connection) WaitForBlock(targetBlock *big.Int, delay *big.Int) error

type Handler

type Handler func(*sync) (int64, error)

type LogHandler

type LogHandler func(*sync, *MessageOut) error

type MessageOut

type MessageOut struct {
	Id           int64  `json:"id"`
	Topic        string `json:"topic"`
	BlockNumber  int64  `json:"block_number"`
	TxHash       string `json:"tx_hash"`
	Addr         string `json:"addr"`
	OrderID      string `json:"order_id"`  // orderId
	From         string `json:"from"`      // relay
	To           string `json:"to"`        //
	SrcChain     string `json:"src_chain"` // fromChain
	SrcToken     string `json:"src_token"` // token
	Sender       string `json:"sender"`    // initiator
	InAmount     string `json:"in_amount"` // amount
	InTxHash     string `json:"in_tx_hash"`
	BridgeFee    string `json:"bridge_fee"`
	DstChain     string `json:"dst_chain"`      // toChain
	DstToken     string `json:"dst_token"`      //
	Receiver     string `json:"receiver"`       //
	MOS          string `json:"mos"`            // map mos address
	Relay        bool   `json:"relay"`          //   (from butter)
	MessageType  uint8  `json:"message_type"`   // default 3
	GasLimit     string `json:"gas_limit"`      // default 0
	MinOutAmount string `json:"min_out_amount"` //  minOutAmount
	SwapData     string `json:"swap_data"`      // (from butter)
}

type T

type T struct {
	OrderId      string `json:"order_id"`
	From         string `json:"from"`
	To           string `json:"to"`
	SrcChain     string `json:"src_chain"`
	SrcToken     string `json:"src_token"`
	Sender       string `json:"sender"`
	InAmount     string `json:"in_amount"`
	InTxHash     string `json:"in_tx_hash"`
	BridgeFee    string `json:"bridge_fee"`
	DstChain     string `json:"dst_chain"`
	DstToken     string `json:"dst_token"`
	Receiver     string `json:"receiver"`
	Mos          string `json:"mos"`
	Relay        bool   `json:"relay"`
	MessageType  int    `json:"message_type"`
	GasLimit     string `json:"gas_limit"`
	MinOutAmount string `json:"min_out_amount"`
	SwapData     string `json:"swap_data"`
}

type Writer

type Writer struct {
	// contains filtered or unexported fields
}

func (*Writer) ResolveMessage

func (w *Writer) ResolveMessage(m msg.Message) bool

Jump to

Keyboard shortcuts

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