message

package

v0.0.0-...-67b0b38 Latest Latest Go to latest Published: Oct 5, 2018 License: Apache-2.0 Imports: 23 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/icloudland/starchain

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetHeadersFromHash(startHash common.Uint256, stopHash common.Uint256) ([]ledger.Header, uint32, error)
func HandleNodeMsg(node Noder, buf []byte, len int) error
func LocateMsgHdr(buf []byte) []byte
func MsgType(buf []byte) (string, error)
func NewAddrs(nodeaddrs []NodeAddr, count uint64) ([]byte, error)
func NewBlock(bk *ledger.Block) ([]byte, error)
func NewBlockFromHash(hash common.Uint256) (*ledger.Block, error)
func NewBlocksReq(n protocol.Noder) ([]byte, error)
func NewConsensus(cp *ConsensusPayload) ([]byte, error)
func NewHeaders(headers []ledger.Header, count uint32) ([]byte, error)
func NewHeadersReq() ([]byte, error)
func NewInv(inv *InvPayload) ([]byte, error)
func NewMsg(t string, n Noder) ([]byte, error)
func NewNotFound(hash common.Uint256) ([]byte, error)
func NewPingMsg() ([]byte, error)
func NewPongMsg() ([]byte, error)
func NewTxn(txn *transaction.Transaction) ([]byte, error)
func NewTxnFromHash(hash common.Uint256) (*transaction.Transaction, error)
func NewVerack() ([]byte, error)
func NewVersion(node protocol.Noder) ([]byte, error)
func PayloadLen(buf []byte) int
func ReqBlkData(node Noder, hash common.Uint256) error
func ReqTxnPool(node protocol.Noder) error
func SendMsgSyncHeaders(node protocol.Noder)
func ValidMsgHdr(buf []byte) bool
type ConsensusPayload
- func (cp *ConsensusPayload) Deserialize(r io.Reader) error
- func (cp *ConsensusPayload) DeserializeUnsigned(r io.Reader) error
- func (cp *ConsensusPayload) GetMessage() []byte
- func (cp *ConsensusPayload) GetProgramHashes() ([]common.Uint160, error)
- func (cp *ConsensusPayload) GetPrograms() []*program.Program
- func (cp *ConsensusPayload) Hash() common.Uint256
- func (cp *ConsensusPayload) InvertoryType() common.InventoryType
- func (cp *ConsensusPayload) Serialize(w io.Writer) error
- func (cp *ConsensusPayload) SerializeUnsigned(w io.Writer) error
- func (cp *ConsensusPayload) SetPrograms(programs []*program.Program)
- func (cp *ConsensusPayload) ToArray() []byte
- func (cp *ConsensusPayload) Type() common.InventoryType
- func (cp *ConsensusPayload) Verify() error
type Inv
- func (msg *Inv) Deserialization(p []byte) error
- func (msg Inv) Handle(node protocol.Noder) error
- func (msg Inv) Serialization() ([]byte, error)
- func (msg Inv) Verify(buf []byte) error
type InvPayload
- func GetInvFromBlockHash(starthash Uint256, stophash Uint256) (*InvPayload, error)
- func NewInvPayload(invType InventoryType, count uint32, msg []byte) *InvPayload
- func (msg *InvPayload) Serialization(w io.Writer)
type Messager
- func AllocMsg(t string, length int) Messager

Constants ¶

View Source

const (
	HTTPINFOFLAG = 0
)

View Source

const (
	NODEADDRSIZE = 30
)

Variables ¶

This section is empty.

Functions ¶

func GetHeadersFromHash ¶

func GetHeadersFromHash(startHash common.Uint256, stopHash common.Uint256) ([]ledger.Header, uint32, error)

func HandleNodeMsg ¶

func HandleNodeMsg(node Noder, buf []byte, len int) error

func LocateMsgHdr ¶

func LocateMsgHdr(buf []byte) []byte

func MsgType ¶

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

func NewAddrs ¶

func NewAddrs(nodeaddrs []NodeAddr, count uint64) ([]byte, error)

func NewBlock ¶

func NewBlock(bk *ledger.Block) ([]byte, error)

func NewBlockFromHash ¶

func NewBlockFromHash(hash common.Uint256) (*ledger.Block, error)

func NewBlocksReq ¶

func NewBlocksReq(n protocol.Noder) ([]byte, error)

func NewConsensus ¶

func NewConsensus(cp *ConsensusPayload) ([]byte, error)

func NewHeaders ¶

func NewHeaders(headers []ledger.Header, count uint32) ([]byte, error)

func NewHeadersReq ¶

func NewHeadersReq() ([]byte, error)

func NewInv ¶

func NewInv(inv *InvPayload) ([]byte, error)

func NewMsg ¶

func NewMsg(t string, n Noder) ([]byte, error)

func NewNotFound ¶

func NewNotFound(hash common.Uint256) ([]byte, error)

func NewPingMsg ¶

func NewPingMsg() ([]byte, error)

func NewPongMsg ¶

func NewPongMsg() ([]byte, error)

func NewTxn ¶

func NewTxn(txn *transaction.Transaction) ([]byte, error)

func NewTxnFromHash ¶

func NewTxnFromHash(hash common.Uint256) (*transaction.Transaction, error)

func NewVerack ¶

func NewVerack() ([]byte, error)

func NewVersion ¶

func NewVersion(node protocol.Noder) ([]byte, error)

func PayloadLen ¶

func PayloadLen(buf []byte) int

func ReqBlkData ¶

func ReqBlkData(node Noder, hash common.Uint256) error

func ReqTxnPool ¶

func ReqTxnPool(node protocol.Noder) error

func SendMsgSyncHeaders ¶

func SendMsgSyncHeaders(node protocol.Noder)

func ValidMsgHdr ¶

func ValidMsgHdr(buf []byte) bool

Types ¶

type ConsensusPayload ¶

type ConsensusPayload struct {
	Version         uint32
	PrevHash        common.Uint256
	Height          uint32
	BookKeeperIndex uint16
	Timestamp       uint32
	Data            []byte
	Owner           *crypto.PubKey
	Program         *program.Program
	// contains filtered or unexported fields
}

func (*ConsensusPayload) Deserialize ¶

func (cp *ConsensusPayload) Deserialize(r io.Reader) error

func (*ConsensusPayload) DeserializeUnsigned ¶

func (cp *ConsensusPayload) DeserializeUnsigned(r io.Reader) error

func (*ConsensusPayload) GetMessage ¶

func (cp *ConsensusPayload) GetMessage() []byte

func (*ConsensusPayload) GetProgramHashes ¶

func (cp *ConsensusPayload) GetProgramHashes() ([]common.Uint160, error)

func (*ConsensusPayload) GetPrograms ¶

func (cp *ConsensusPayload) GetPrograms() []*program.Program

func (*ConsensusPayload) Hash ¶

func (cp *ConsensusPayload) Hash() common.Uint256

func (*ConsensusPayload) InvertoryType ¶

func (cp *ConsensusPayload) InvertoryType() common.InventoryType

func (*ConsensusPayload) Serialize ¶

func (cp *ConsensusPayload) Serialize(w io.Writer) error

func (*ConsensusPayload) SerializeUnsigned ¶

func (cp *ConsensusPayload) SerializeUnsigned(w io.Writer) error

func (*ConsensusPayload) SetPrograms ¶

func (cp *ConsensusPayload) SetPrograms(programs []*program.Program)

func (*ConsensusPayload) ToArray ¶

func (cp *ConsensusPayload) ToArray() []byte

func (*ConsensusPayload) Type ¶

func (cp *ConsensusPayload) Type() common.InventoryType

func (*ConsensusPayload) Verify ¶

func (cp *ConsensusPayload) Verify() error

type Inv ¶

type Inv struct {
	Hdr msgHdr
	P   InvPayload
}

func (*Inv) Deserialization ¶

func (msg *Inv) Deserialization(p []byte) error

func (Inv) Handle ¶

func (msg Inv) Handle(node protocol.Noder) error

func (Inv) Serialization ¶

func (msg Inv) Serialization() ([]byte, error)

func (Inv) Verify ¶

func (msg Inv) Verify(buf []byte) error

type InvPayload ¶

type InvPayload struct {
	InvType InventoryType
	Cnt     uint32
	Blk     []byte
}

func GetInvFromBlockHash ¶

func GetInvFromBlockHash(starthash Uint256, stophash Uint256) (*InvPayload, error)

func NewInvPayload ¶

func NewInvPayload(invType InventoryType, count uint32, msg []byte) *InvPayload

func (*InvPayload) Serialization ¶

func (msg *InvPayload) Serialization(w io.Writer)

type Messager ¶

type Messager interface {
	Verify([]byte) error
	Serialization() ([]byte, error)
	Deserialization([]byte) error
	Handle(Noder) error
}

func AllocMsg ¶

func AllocMsg(t string, length int) Messager

Source Files ¶

View all Source files

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