net

Documentation

Index

• Variables
• type Msg
  • func (*Msg) Descriptor() ([]byte, []int)
  • func (m *Msg) GetChainId() string
  • func (m *Msg) GetFlag() string
  • func (m *Msg) GetMsg() *NetMsg
  • func (m *Msg) Marshal() (dAtA []byte, err error)
  • func (m *Msg) MarshalTo(dAtA []byte) (int, error)
  • func (m *Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Msg) ProtoMessage()
  • func (m *Msg) Reset()
  • func (m *Msg) Size() (n int)
  • func (m *Msg) String() string
  • func (m *Msg) Unmarshal(dAtA []byte) error
  • func (m *Msg) XXX_DiscardUnknown()
  • func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Msg) XXX_Merge(src proto.Message)
  • func (m *Msg) XXX_Size() int
  • func (m *Msg) XXX_Unmarshal(b []byte) error
• type NetMsg
  • func (*NetMsg) Descriptor() ([]byte, []int)
  • func (m *NetMsg) GetPayload() []byte
  • func (m *NetMsg) GetTo() string
  • func (m *NetMsg) GetType() NetMsg_MsgType
  • func (m *NetMsg) Marshal() (dAtA []byte, err error)
  • func (m *NetMsg) MarshalTo(dAtA []byte) (int, error)
  • func (m *NetMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*NetMsg) ProtoMessage()
  • func (m *NetMsg) Reset()
  • func (m *NetMsg) Size() (n int)
  • func (m *NetMsg) String() string
  • func (m *NetMsg) Unmarshal(dAtA []byte) error
  • func (m *NetMsg) XXX_DiscardUnknown()
  • func (m *NetMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *NetMsg) XXX_Merge(src proto.Message)
  • func (m *NetMsg) XXX_Size() int
  • func (m *NetMsg) XXX_Unmarshal(b []byte) error
• type NetMsg_MsgType
  • func (NetMsg_MsgType) EnumDescriptor() ([]byte, []int)
  • func (x NetMsg_MsgType) String() string

Variables

var (
	ErrInvalidLengthNet        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNet          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNet = fmt.Errorf("proto: unexpected end of group")
)

var NetMsg_MsgType_name = map[int32]string{
	0: "INVALID_MSG",
	1: "TX",
	2: "TXS",
	3: "BLOCK",
	4: "BLOCKS",
	5: "CONSENSUS_MSG",
	6: "SYNC_BLOCK_MSG",
	7: "CONSISTENT_MSG",
}

var NetMsg_MsgType_value = map[string]int32{
	"INVALID_MSG":    0,
	"TX":             1,
	"TXS":            2,
	"BLOCK":          3,
	"BLOCKS":         4,
	"CONSENSUS_MSG":  5,
	"SYNC_BLOCK_MSG": 6,
	"CONSISTENT_MSG": 7,
}

Types

type Msg

type Msg struct {
	Msg     *NetMsg `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	ChainId string  `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// 属于那个模块，判断消息类型
	Flag string `protobuf:"bytes,3,opt,name=flag,proto3" json:"flag,omitempty"`
}

wrapped network message

func (*Msg) Descriptor

func (*Msg) Descriptor() ([]byte, []int)

func (*Msg) GetChainId

func (m *Msg) GetChainId() string

func (*Msg) GetFlag

func (m *Msg) GetFlag() string

func (*Msg) GetMsg

func (m *Msg) GetMsg() *NetMsg

func (*Msg) Marshal

func (m *Msg) Marshal() (dAtA []byte, err error)

func (*Msg) MarshalTo

func (m *Msg) MarshalTo(dAtA []byte) (int, error)

func (*Msg) MarshalToSizedBuffer

func (m *Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) Reset

func (m *Msg) Reset()

func (*Msg) Size

func (m *Msg) Size() (n int)

func (*Msg) String

func (m *Msg) String() string

func (*Msg) Unmarshal

func (m *Msg) Unmarshal(dAtA []byte) error

func (*Msg) XXX_DiscardUnknown

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal

func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Msg) XXX_Merge

func (m *Msg) XXX_Merge(src proto.Message)

func (*Msg) XXX_Size

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal

func (m *Msg) XXX_Unmarshal(b []byte) error

type NetMsg

type NetMsg struct {
	// payload of the message
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// message type
	Type NetMsg_MsgType `protobuf:"varint,2,opt,name=type,proto3,enum=net.NetMsg_MsgType" json:"type,omitempty"`
	// nodeId
	To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
}

net message

func (*NetMsg) Descriptor

func (*NetMsg) Descriptor() ([]byte, []int)

func (*NetMsg) GetPayload

func (m *NetMsg) GetPayload() []byte

func (*NetMsg) GetTo

func (m *NetMsg) GetTo() string

func (*NetMsg) GetType

func (m *NetMsg) GetType() NetMsg_MsgType

func (*NetMsg) Marshal

func (m *NetMsg) Marshal() (dAtA []byte, err error)

func (*NetMsg) MarshalTo

func (m *NetMsg) MarshalTo(dAtA []byte) (int, error)

func (*NetMsg) MarshalToSizedBuffer

func (m *NetMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NetMsg) ProtoMessage

func (*NetMsg) ProtoMessage()

func (*NetMsg) Reset

func (m *NetMsg) Reset()

func (*NetMsg) Size

func (m *NetMsg) Size() (n int)

func (*NetMsg) String

func (m *NetMsg) String() string

func (*NetMsg) Unmarshal

func (m *NetMsg) Unmarshal(dAtA []byte) error

func (*NetMsg) XXX_DiscardUnknown

func (m *NetMsg) XXX_DiscardUnknown()

func (*NetMsg) XXX_Marshal

func (m *NetMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetMsg) XXX_Merge

func (m *NetMsg) XXX_Merge(src proto.Message)

func (*NetMsg) XXX_Size

func (m *NetMsg) XXX_Size() int

func (*NetMsg) XXX_Unmarshal

func (m *NetMsg) XXX_Unmarshal(b []byte) error

type NetMsg_MsgType

type NetMsg_MsgType int32

specific net message types

const (
	NetMsg_INVALID_MSG    NetMsg_MsgType = 0
	NetMsg_TX             NetMsg_MsgType = 1
	NetMsg_TXS            NetMsg_MsgType = 2
	NetMsg_BLOCK          NetMsg_MsgType = 3
	NetMsg_BLOCKS         NetMsg_MsgType = 4
	NetMsg_CONSENSUS_MSG  NetMsg_MsgType = 5
	NetMsg_SYNC_BLOCK_MSG NetMsg_MsgType = 6
	NetMsg_CONSISTENT_MSG NetMsg_MsgType = 7
)

func (NetMsg_MsgType) EnumDescriptor

func (NetMsg_MsgType) EnumDescriptor() ([]byte, []int)

func (NetMsg_MsgType) String

func (x NetMsg_MsgType) String() string