service

package

v1.1.0 Latest Latest Go to latest Published: Dec 14, 2021 License: MIT Imports: 40 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/neo3-relayer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func DeserializeArgs(source []byte) ([]byte, []byte, *big.Int, error)
func HashChildren(v, hash []byte) []byte
func HashLeaf(value []byte) []byte
func MerkleProve(path, root []byte) ([]byte, error)
func ReadBytes(buffer []byte, offset int, count int) ([]byte, int, error)
func ReadUInt255(buffer []byte, offset int) (*big.Int, int, error)
func ReadVarBytes(buffer []byte, offset int) ([]byte, int, error)
func ReadVarUInt(buffer []byte, offset int) (uint64, int, error)
func ReadVarUInt16(buffer []byte, offset int) (uint64, int, error)
func ReadVarUInt32(buffer []byte, offset int) (uint64, int, error)
func ReadVarUInt64(buffer []byte, offset int) (uint64, int, error)
func ReadVarUInt8(buffer []byte, offset int) (uint64, int, error)
type CrossChainTxParameter
- func DeserializeCrossChainTxParameter(source []byte, offset int) (*CrossChainTxParameter, error)
type SyncService
- func NewSyncService(acct *rsdk.Account, relaySdk *rsdk.PolySdk, neoAccount *wallet.WalletHelper, ...) *SyncService
- func (this *SyncService) GetCurrentNeoChainSyncHeight() (uint64, error)
- func (this *SyncService) GetCurrentRelayChainSyncHeight(neoChainID uint64) (uint32, error)
- func (this *SyncService) GetStateRootMsg(sr mpt.StateRoot) []byte
- func (this *SyncService) NeoToRelay()
- func (this *SyncService) NeoToRelayCheckAndRetry()
- func (this *SyncService) RelayToNeo()
- func (this *SyncService) RelayToNeoCheckAndRetry()
- func (this *SyncService) Run()
type ToMerkleValue
- func DeserializeMerkleValue(source []byte) (*ToMerkleValue, error)

Constants ¶

View Source

const (
	VERIFY_AND_EXECUTE_TX = "verifyAndExecuteTx"
	CHANGE_BOOK_KEEPER    = "changeBookKeeper"
	GET_BOOK_KEEPERS      = "getBookKeepers"
)

View Source

const PolyPublicKeyLength int = 67

Variables ¶

View Source

var Log = log.Log

Functions ¶

func DeserializeArgs ¶

func DeserializeArgs(source []byte) ([]byte, []byte, *big.Int, error)

func HashChildren ¶

func HashChildren(v, hash []byte) []byte

func HashLeaf ¶

func HashLeaf(value []byte) []byte

func MerkleProve ¶

func MerkleProve(path, root []byte) ([]byte, error)

func ReadBytes ¶

func ReadBytes(buffer []byte, offset int, count int) ([]byte, int, error)

func ReadUInt255 ¶

func ReadUInt255(buffer []byte, offset int) (*big.Int, int, error)

func ReadVarBytes ¶

func ReadVarBytes(buffer []byte, offset int) ([]byte, int, error)

func ReadVarUInt ¶

func ReadVarUInt(buffer []byte, offset int) (uint64, int, error)

func ReadVarUInt16 ¶

func ReadVarUInt16(buffer []byte, offset int) (uint64, int, error)

func ReadVarUInt32 ¶

func ReadVarUInt32(buffer []byte, offset int) (uint64, int, error)

func ReadVarUInt64 ¶

func ReadVarUInt64(buffer []byte, offset int) (uint64, int, error)

func ReadVarUInt8 ¶

func ReadVarUInt8(buffer []byte, offset int) (uint64, int, error)

Types ¶

type CrossChainTxParameter ¶

type CrossChainTxParameter struct {
	TxHash       []byte // source chain tx hash, when FromChainID = 2 (eth), it's a key
	CrossChainID []byte
	FromContract []byte

	ToChainID  uint64
	ToContract []byte
	Method     []byte
	Args       []byte
}

func DeserializeCrossChainTxParameter ¶

func DeserializeCrossChainTxParameter(source []byte, offset int) (*CrossChainTxParameter, error)

type SyncService ¶

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

SyncService ...

func NewSyncService ¶

func NewSyncService(acct *rsdk.Account, relaySdk *rsdk.PolySdk, neoAccount *wallet.WalletHelper, client *rpc.RpcClient) *SyncService

NewSyncService ...

func (*SyncService) GetCurrentNeoChainSyncHeight ¶

func (this *SyncService) GetCurrentNeoChainSyncHeight() (uint64, error)

GetCurrentNeoChainSyncHeight

func (*SyncService) GetCurrentRelayChainSyncHeight ¶

func (this *SyncService) GetCurrentRelayChainSyncHeight(neoChainID uint64) (uint32, error)

GetCurrentRelayChainSyncHeight :get the synced NEO blockHeight from Relay Chain

func (*SyncService) GetStateRootMsg ¶

func (this *SyncService) GetStateRootMsg(sr mpt.StateRoot) []byte

func (*SyncService) NeoToRelay ¶

func (this *SyncService) NeoToRelay()

NeoToRelay ...

func (*SyncService) NeoToRelayCheckAndRetry ¶

func (this *SyncService) NeoToRelayCheckAndRetry()

func (*SyncService) RelayToNeo ¶

func (this *SyncService) RelayToNeo()

RelayToNeo sync headers from relay chain to neo

func (*SyncService) RelayToNeoCheckAndRetry ¶ added in v1.0.0

func (this *SyncService) RelayToNeoCheckAndRetry()

func (*SyncService) Run ¶

func (this *SyncService) Run()

Run ...

type ToMerkleValue ¶

type ToMerkleValue struct {
	TxHash      []byte // poly chain tx hash
	FromChainID uint64
	TxParam     *CrossChainTxParameter
}

func DeserializeMerkleValue ¶

func DeserializeMerkleValue(source []byte) (*ToMerkleValue, error)

Source Files ¶

View all Source files

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