msg

Documentation

Index

• Constants
• type MessageSign
  • func (s *MessageSign) Decode(sign []byte) int
  • func (s *MessageSign) Encode(sign []byte) int
  • func (s *MessageSign) Sign(hb []byte) error
  • func (s *MessageSign) Verify(hb []byte, remoteP2pAddr string) error
• type RelayMsgBuf
  • func (r *RelayMsgBuf) GetBytesAfterHeader() []byte
  • func (r *RelayMsgBuf) GetHeader() []byte
  • func (r *RelayMsgBuf) PutIntoBuffer(msg *RelayMsgBuf) int
  • func (r *RelayMsgBuf) ReleaseAlloc()
• type Signer

Constants

const (
	MsgSignLen                = types.P2pSignatureLength + types.P2pAddressBech32Length + types.P2pPublicKeyLength
	ThresholdToHashBeforeSign = 128
)

Types

type MessageSign

type MessageSign struct {
	Signature  []byte
	P2pAddress string
	P2pPubKey  []byte
	Signer     Signer
}

MessageSign

func (*MessageSign) Decode

func (s *MessageSign) Decode(sign []byte) int

func (*MessageSign) Encode

func (s *MessageSign) Encode(sign []byte) int

func (*MessageSign) Sign

func (s *MessageSign) Sign(hb []byte) error

func (*MessageSign) Verify

func (s *MessageSign) Verify(hb []byte, remoteP2pAddr string) error

type RelayMsgBuf

type RelayMsgBuf struct {
	PacketId int64
	MSGHead  header.MessageHead
	MSGSign  MessageSign
	MSGBody  []byte
	MSGData  []byte

	Alloc *[]byte
}

RelayMsgBuf application layer internal buffer for msg，

func (*RelayMsgBuf) GetBytesAfterHeader

func (r *RelayMsgBuf) GetBytesAfterHeader() []byte

func (*RelayMsgBuf) GetHeader

func (r *RelayMsgBuf) GetHeader() []byte

func (*RelayMsgBuf) PutIntoBuffer

func (r *RelayMsgBuf) PutIntoBuffer(msg *RelayMsgBuf) int

func (*RelayMsgBuf) ReleaseAlloc

func (r *RelayMsgBuf) ReleaseAlloc()

type Signer

type Signer func([]byte) []byte