net

package

v3.0.1 Latest Latest Go to latest Published: Dec 25, 2023 License: Apache-2.0 Imports: 5 Imported by: 14

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

git.chainmaker.org.cn/chainmaker/pb-go

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Msg
type NetMsg
type NetMsg_MsgType
- func (NetMsg_MsgType) EnumDescriptor() ([]byte, []int)
- func (x NetMsg_MsgType) String() string

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

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",
}

View Source

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,
}

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

net.pb.go

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