tcpmsg_pb

package
v0.5.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 14, 2019 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTcpmsg = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTcpmsg   = fmt.Errorf("proto: integer overflow")
)
View Source 
var KeyStatus_name = map[int32]string{
	0: "KS_NOTEXIST",
	1: "KS_EXIST",
}
View Source 
var KeyStatus_value = map[string]int32{
	"KS_NOTEXIST": 0,
	"KS_EXIST":    1,
}
View Source 
var MessageId_name = map[int32]string{
	0:  "MID_HANDSHAKE",
	1:  "MID_PING",
	2:  "MID_PONG",
	3:  "MID_TX",
	4:  "MID_EVENT",
	5:  "MID_BLOCKHEADER",
	6:  "MID_BLOCK",
	7:  "MID_CHKK",
	8:  "MID_RPTK",
	9:  "MID_GCD",
	10: "MID_PCD",
	-1: "MID_INVALID",
}
View Source 
var MessageId_value = map[string]int32{
	"MID_HANDSHAKE":   0,
	"MID_PING":        1,
	"MID_PONG":        2,
	"MID_TX":          3,
	"MID_EVENT":       4,
	"MID_BLOCKHEADER": 5,
	"MID_BLOCK":       6,
	"MID_CHKK":        7,
	"MID_RPTK":        8,
	"MID_GCD":         9,
	"MID_PCD":         10,
	"MID_INVALID":     -1,
}
View Source 
var ProtocolId_name = map[int32]string{
	0:   "PID_P2P",
	255: "PID_EXT",
}
View Source 
var ProtocolId_value = map[string]int32{
	"PID_P2P": 0,
	"PID_EXT": 255,
}

Functions

This section is empty.

Types

type ExtMessage 

type ExtMessage struct {
	Mid                  *MessageId               `protobuf:"varint,1,req,name=mid,enum=tcpmsg.pb.MessageId" json:"mid,omitempty"`
	CheckKey             *ExtMessage_CheckKey     `protobuf:"bytes,2,opt,name=checkKey" json:"checkKey,omitempty"`
	ReportKey            *ExtMessage_ReportKey    `protobuf:"bytes,3,opt,name=reportKey" json:"reportKey,omitempty"`
	GetChainData         *ExtMessage_GetChainData `protobuf:"bytes,4,opt,name=getChainData" json:"getChainData,omitempty"`
	PutChainData         *ExtMessage_PutChainData `protobuf:"bytes,5,opt,name=putChainData" json:"putChainData,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

External application message

func (*ExtMessage) Descriptor 

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

func (*ExtMessage) GetCheckKey 

func (m *ExtMessage) GetCheckKey() *ExtMessage_CheckKey

func (*ExtMessage) GetGetChainData 

func (m *ExtMessage) GetGetChainData() *ExtMessage_GetChainData

func (*ExtMessage) GetMid 

func (m *ExtMessage) GetMid() MessageId

func (*ExtMessage) GetPutChainData 

func (m *ExtMessage) GetPutChainData() *ExtMessage_PutChainData

func (*ExtMessage) GetReportKey 

func (m *ExtMessage) GetReportKey() *ExtMessage_ReportKey

func (*ExtMessage) Marshal 

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

func (*ExtMessage) MarshalTo 

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

func (*ExtMessage) ProtoMessage 

func (*ExtMessage) ProtoMessage()

func (*ExtMessage) Reset 

func (m *ExtMessage) Reset()

func (*ExtMessage) Size 

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

func (*ExtMessage) String 

func (m *ExtMessage) String() string

func (*ExtMessage) Unmarshal 

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

func (*ExtMessage) XXX_DiscardUnknown 

func (m *ExtMessage) XXX_DiscardUnknown()

func (*ExtMessage) XXX_Marshal 

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

func (*ExtMessage) XXX_Merge 

func (dst *ExtMessage) XXX_Merge(src proto.Message)

func (*ExtMessage) XXX_Size 

func (m *ExtMessage) XXX_Size() int

func (*ExtMessage) XXX_Unmarshal 

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

type ExtMessage_CheckKey 

type ExtMessage_CheckKey struct {
	Extra                []byte   `protobuf:"bytes,1,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExtMessage_CheckKey) Descriptor 

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

func (*ExtMessage_CheckKey) GetExtra 

func (m *ExtMessage_CheckKey) GetExtra() []byte

func (*ExtMessage_CheckKey) Marshal 

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

func (*ExtMessage_CheckKey) MarshalTo 

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

func (*ExtMessage_CheckKey) ProtoMessage 

func (*ExtMessage_CheckKey) ProtoMessage()

func (*ExtMessage_CheckKey) Reset 

func (m *ExtMessage_CheckKey) Reset()

func (*ExtMessage_CheckKey) Size 

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

func (*ExtMessage_CheckKey) String 

func (m *ExtMessage_CheckKey) String() string

func (*ExtMessage_CheckKey) Unmarshal 

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

func (*ExtMessage_CheckKey) XXX_DiscardUnknown 

func (m *ExtMessage_CheckKey) XXX_DiscardUnknown()

func (*ExtMessage_CheckKey) XXX_Marshal 

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

func (*ExtMessage_CheckKey) XXX_Merge 

func (dst *ExtMessage_CheckKey) XXX_Merge(src proto.Message)

func (*ExtMessage_CheckKey) XXX_Size 

func (m *ExtMessage_CheckKey) XXX_Size() int

func (*ExtMessage_CheckKey) XXX_Unmarshal 

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

type ExtMessage_GetChainData 

type ExtMessage_GetChainData struct {
	Seq                  *uint64  `protobuf:"varint,1,req,name=Seq" json:"Seq,omitempty"`
	Kind                 []byte   `protobuf:"bytes,2,req,name=Kind" json:"Kind,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,req,name=Key" json:"Key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExtMessage_GetChainData) Descriptor 

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

func (*ExtMessage_GetChainData) GetKey 

func (m *ExtMessage_GetChainData) GetKey() []byte

func (*ExtMessage_GetChainData) GetKind 

func (m *ExtMessage_GetChainData) GetKind() []byte

func (*ExtMessage_GetChainData) GetSeq 

func (m *ExtMessage_GetChainData) GetSeq() uint64

func (*ExtMessage_GetChainData) Marshal 

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

func (*ExtMessage_GetChainData) MarshalTo 

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

func (*ExtMessage_GetChainData) ProtoMessage 

func (*ExtMessage_GetChainData) ProtoMessage()

func (*ExtMessage_GetChainData) Reset 

func (m *ExtMessage_GetChainData) Reset()

func (*ExtMessage_GetChainData) Size 

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

func (*ExtMessage_GetChainData) String 

func (m *ExtMessage_GetChainData) String() string

func (*ExtMessage_GetChainData) Unmarshal 

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

func (*ExtMessage_GetChainData) XXX_DiscardUnknown 

func (m *ExtMessage_GetChainData) XXX_DiscardUnknown()

func (*ExtMessage_GetChainData) XXX_Marshal 

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

func (*ExtMessage_GetChainData) XXX_Merge 

func (dst *ExtMessage_GetChainData) XXX_Merge(src proto.Message)

func (*ExtMessage_GetChainData) XXX_Size 

func (m *ExtMessage_GetChainData) XXX_Size() int

func (*ExtMessage_GetChainData) XXX_Unmarshal 

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

type ExtMessage_PutChainData 

type ExtMessage_PutChainData struct {
	Seq                  *uint64  `protobuf:"varint,1,req,name=Seq" json:"Seq,omitempty"`
	Kind                 []byte   `protobuf:"bytes,2,req,name=Kind" json:"Kind,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,req,name=Key" json:"Key,omitempty"`
	Data                 []byte   `protobuf:"bytes,4,req,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExtMessage_PutChainData) Descriptor 

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

func (*ExtMessage_PutChainData) GetData 

func (m *ExtMessage_PutChainData) GetData() []byte

func (*ExtMessage_PutChainData) GetKey 

func (m *ExtMessage_PutChainData) GetKey() []byte

func (*ExtMessage_PutChainData) GetKind 

func (m *ExtMessage_PutChainData) GetKind() []byte

func (*ExtMessage_PutChainData) GetSeq 

func (m *ExtMessage_PutChainData) GetSeq() uint64

func (*ExtMessage_PutChainData) Marshal 

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

func (*ExtMessage_PutChainData) MarshalTo 

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

func (*ExtMessage_PutChainData) ProtoMessage 

func (*ExtMessage_PutChainData) ProtoMessage()

func (*ExtMessage_PutChainData) Reset 

func (m *ExtMessage_PutChainData) Reset()

func (*ExtMessage_PutChainData) Size 

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

func (*ExtMessage_PutChainData) String 

func (m *ExtMessage_PutChainData) String() string

func (*ExtMessage_PutChainData) Unmarshal 

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

func (*ExtMessage_PutChainData) XXX_DiscardUnknown 

func (m *ExtMessage_PutChainData) XXX_DiscardUnknown()

func (*ExtMessage_PutChainData) XXX_Marshal 

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

func (*ExtMessage_PutChainData) XXX_Merge 

func (dst *ExtMessage_PutChainData) XXX_Merge(src proto.Message)

func (*ExtMessage_PutChainData) XXX_Size 

func (m *ExtMessage_PutChainData) XXX_Size() int

func (*ExtMessage_PutChainData) XXX_Unmarshal 

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

type ExtMessage_ReportKey 

type ExtMessage_ReportKey struct {
	Status               *KeyStatus `protobuf:"varint,1,req,name=Status,enum=tcpmsg.pb.KeyStatus" json:"Status,omitempty"`
	Extra                []byte     `protobuf:"bytes,2,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ExtMessage_ReportKey) Descriptor 

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

func (*ExtMessage_ReportKey) GetExtra 

func (m *ExtMessage_ReportKey) GetExtra() []byte

func (*ExtMessage_ReportKey) GetStatus 

func (m *ExtMessage_ReportKey) GetStatus() KeyStatus

func (*ExtMessage_ReportKey) Marshal 

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

func (*ExtMessage_ReportKey) MarshalTo 

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

func (*ExtMessage_ReportKey) ProtoMessage 

func (*ExtMessage_ReportKey) ProtoMessage()

func (*ExtMessage_ReportKey) Reset 

func (m *ExtMessage_ReportKey) Reset()

func (*ExtMessage_ReportKey) Size 

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

func (*ExtMessage_ReportKey) String 

func (m *ExtMessage_ReportKey) String() string

func (*ExtMessage_ReportKey) Unmarshal 

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

func (*ExtMessage_ReportKey) XXX_DiscardUnknown 

func (m *ExtMessage_ReportKey) XXX_DiscardUnknown()

func (*ExtMessage_ReportKey) XXX_Marshal 

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

func (*ExtMessage_ReportKey) XXX_Merge 

func (dst *ExtMessage_ReportKey) XXX_Merge(src proto.Message)

func (*ExtMessage_ReportKey) XXX_Size 

func (m *ExtMessage_ReportKey) XXX_Size() int

func (*ExtMessage_ReportKey) XXX_Unmarshal 

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

type KeyStatus 

type KeyStatus int32
const (
	KeyStatus_KS_NOTEXIST KeyStatus = 0
	KeyStatus_KS_EXIST    KeyStatus = 1
)

func (KeyStatus) Enum 

func (x KeyStatus) Enum() *KeyStatus

func (KeyStatus) EnumDescriptor 

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

func (KeyStatus) String 

func (x KeyStatus) String() string

func (*KeyStatus) UnmarshalJSON 

func (x *KeyStatus) UnmarshalJSON(data []byte) error

type MessageId 

type MessageId int32
const (
	MessageId_MID_HANDSHAKE   MessageId = 0
	MessageId_MID_PING        MessageId = 1
	MessageId_MID_PONG        MessageId = 2
	MessageId_MID_TX          MessageId = 3
	MessageId_MID_EVENT       MessageId = 4
	MessageId_MID_BLOCKHEADER MessageId = 5
	MessageId_MID_BLOCK       MessageId = 6
	MessageId_MID_CHKK        MessageId = 7
	MessageId_MID_RPTK        MessageId = 8
	MessageId_MID_GCD         MessageId = 9
	MessageId_MID_PCD         MessageId = 10
	MessageId_MID_INVALID     MessageId = -1
)

func (MessageId) Enum 

func (x MessageId) Enum() *MessageId

func (MessageId) EnumDescriptor 

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

func (MessageId) String 

func (x MessageId) String() string

func (*MessageId) UnmarshalJSON 

func (x *MessageId) UnmarshalJSON(data []byte) error

type P2PMessage 

type P2PMessage struct {
	Mid                  *MessageId            `protobuf:"varint,1,req,name=mid,enum=tcpmsg.pb.MessageId" json:"mid,omitempty"`
	Handshake            *P2PMessage_Handshake `protobuf:"bytes,2,opt,name=handshake" json:"handshake,omitempty"`
	Ping                 *P2PMessage_Ping      `protobuf:"bytes,3,opt,name=ping" json:"ping,omitempty"`
	Pong                 *P2PMessage_Pong      `protobuf:"bytes,4,opt,name=pong" json:"pong,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*P2PMessage) Descriptor 

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

func (*P2PMessage) GetHandshake 

func (m *P2PMessage) GetHandshake() *P2PMessage_Handshake

func (*P2PMessage) GetMid 

func (m *P2PMessage) GetMid() MessageId

func (*P2PMessage) GetPing 

func (m *P2PMessage) GetPing() *P2PMessage_Ping

func (*P2PMessage) GetPong 

func (m *P2PMessage) GetPong() *P2PMessage_Pong

func (*P2PMessage) Marshal 

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

func (*P2PMessage) MarshalTo 

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

func (*P2PMessage) ProtoMessage 

func (*P2PMessage) ProtoMessage()

func (*P2PMessage) Reset 

func (m *P2PMessage) Reset()

func (*P2PMessage) Size 

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

func (*P2PMessage) String 

func (m *P2PMessage) String() string

func (*P2PMessage) Unmarshal 

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

func (*P2PMessage) XXX_DiscardUnknown 

func (m *P2PMessage) XXX_DiscardUnknown()

func (*P2PMessage) XXX_Marshal 

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

func (*P2PMessage) XXX_Merge 

func (dst *P2PMessage) XXX_Merge(src proto.Message)

func (*P2PMessage) XXX_Size 

func (m *P2PMessage) XXX_Size() int

func (*P2PMessage) XXX_Unmarshal 

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

type P2PMessage_Handshake 

type P2PMessage_Handshake struct {
	ChainId              *uint32                `protobuf:"varint,1,req,name=ChainId" json:"ChainId,omitempty"`
	SubNetId             []byte                 `protobuf:"bytes,2,req,name=SubNetId" json:"SubNetId,omitempty"`
	NodeId               []byte                 `protobuf:"bytes,3,req,name=NodeId" json:"NodeId,omitempty"`
	IP                   []byte                 `protobuf:"bytes,4,req,name=IP" json:"IP,omitempty"`
	UDP                  *uint32                `protobuf:"varint,5,req,name=UDP" json:"UDP,omitempty"`
	TCP                  *uint32                `protobuf:"varint,6,req,name=TCP" json:"TCP,omitempty"`
	ProtoNum             *uint32                `protobuf:"varint,7,req,name=ProtoNum" json:"ProtoNum,omitempty"`
	Protocols            []*P2PMessage_Protocol `protobuf:"bytes,8,rep,name=Protocols" json:"Protocols,omitempty"`
	SignR                *int32                 `protobuf:"varint,9,req,name=SignR" json:"SignR,omitempty"`
	R                    []byte                 `protobuf:"bytes,10,req,name=R" json:"R,omitempty"`
	SignS                *int32                 `protobuf:"varint,11,req,name=SignS" json:"SignS,omitempty"`
	S                    []byte                 `protobuf:"bytes,12,req,name=S" json:"S,omitempty"`
	Extra                []byte                 `protobuf:"bytes,13,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*P2PMessage_Handshake) Descriptor 

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

func (*P2PMessage_Handshake) GetChainId 

func (m *P2PMessage_Handshake) GetChainId() uint32

func (*P2PMessage_Handshake) GetExtra 

func (m *P2PMessage_Handshake) GetExtra() []byte

func (*P2PMessage_Handshake) GetIP 

func (m *P2PMessage_Handshake) GetIP() []byte

func (*P2PMessage_Handshake) GetNodeId 

func (m *P2PMessage_Handshake) GetNodeId() []byte

func (*P2PMessage_Handshake) GetProtoNum 

func (m *P2PMessage_Handshake) GetProtoNum() uint32

func (*P2PMessage_Handshake) GetProtocols 

func (m *P2PMessage_Handshake) GetProtocols() []*P2PMessage_Protocol

func (*P2PMessage_Handshake) GetR 

func (m *P2PMessage_Handshake) GetR() []byte

func (*P2PMessage_Handshake) GetS 

func (m *P2PMessage_Handshake) GetS() []byte

func (*P2PMessage_Handshake) GetSignR 

func (m *P2PMessage_Handshake) GetSignR() int32

func (*P2PMessage_Handshake) GetSignS 

func (m *P2PMessage_Handshake) GetSignS() int32

func (*P2PMessage_Handshake) GetSubNetId 

func (m *P2PMessage_Handshake) GetSubNetId() []byte

func (*P2PMessage_Handshake) GetTCP 

func (m *P2PMessage_Handshake) GetTCP() uint32

func (*P2PMessage_Handshake) GetUDP 

func (m *P2PMessage_Handshake) GetUDP() uint32

func (*P2PMessage_Handshake) Marshal 

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

func (*P2PMessage_Handshake) MarshalTo 

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

func (*P2PMessage_Handshake) ProtoMessage 

func (*P2PMessage_Handshake) ProtoMessage()

func (*P2PMessage_Handshake) Reset 

func (m *P2PMessage_Handshake) Reset()

func (*P2PMessage_Handshake) Size 

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

func (*P2PMessage_Handshake) String 

func (m *P2PMessage_Handshake) String() string

func (*P2PMessage_Handshake) Unmarshal 

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

func (*P2PMessage_Handshake) XXX_DiscardUnknown 

func (m *P2PMessage_Handshake) XXX_DiscardUnknown()

func (*P2PMessage_Handshake) XXX_Marshal 

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

func (*P2PMessage_Handshake) XXX_Merge 

func (dst *P2PMessage_Handshake) XXX_Merge(src proto.Message)

func (*P2PMessage_Handshake) XXX_Size 

func (m *P2PMessage_Handshake) XXX_Size() int

func (*P2PMessage_Handshake) XXX_Unmarshal 

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

type P2PMessage_Ping 

type P2PMessage_Ping struct {
	Seq                  *uint64  `protobuf:"varint,1,req,name=seq" json:"seq,omitempty"`
	Extra                []byte   `protobuf:"bytes,2,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*P2PMessage_Ping) Descriptor 

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

func (*P2PMessage_Ping) GetExtra 

func (m *P2PMessage_Ping) GetExtra() []byte

func (*P2PMessage_Ping) GetSeq 

func (m *P2PMessage_Ping) GetSeq() uint64

func (*P2PMessage_Ping) Marshal 

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

func (*P2PMessage_Ping) MarshalTo 

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

func (*P2PMessage_Ping) ProtoMessage 

func (*P2PMessage_Ping) ProtoMessage()

func (*P2PMessage_Ping) Reset 

func (m *P2PMessage_Ping) Reset()

func (*P2PMessage_Ping) Size 

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

func (*P2PMessage_Ping) String 

func (m *P2PMessage_Ping) String() string

func (*P2PMessage_Ping) Unmarshal 

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

func (*P2PMessage_Ping) XXX_DiscardUnknown 

func (m *P2PMessage_Ping) XXX_DiscardUnknown()

func (*P2PMessage_Ping) XXX_Marshal 

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

func (*P2PMessage_Ping) XXX_Merge 

func (dst *P2PMessage_Ping) XXX_Merge(src proto.Message)

func (*P2PMessage_Ping) XXX_Size 

func (m *P2PMessage_Ping) XXX_Size() int

func (*P2PMessage_Ping) XXX_Unmarshal 

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

type P2PMessage_Pong 

type P2PMessage_Pong struct {
	Seq                  *uint64  `protobuf:"varint,1,req,name=seq" json:"seq,omitempty"`
	Extra                []byte   `protobuf:"bytes,2,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*P2PMessage_Pong) Descriptor 

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

func (*P2PMessage_Pong) GetExtra 

func (m *P2PMessage_Pong) GetExtra() []byte

func (*P2PMessage_Pong) GetSeq 

func (m *P2PMessage_Pong) GetSeq() uint64

func (*P2PMessage_Pong) Marshal 

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

func (*P2PMessage_Pong) MarshalTo 

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

func (*P2PMessage_Pong) ProtoMessage 

func (*P2PMessage_Pong) ProtoMessage()

func (*P2PMessage_Pong) Reset 

func (m *P2PMessage_Pong) Reset()

func (*P2PMessage_Pong) Size 

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

func (*P2PMessage_Pong) String 

func (m *P2PMessage_Pong) String() string

func (*P2PMessage_Pong) Unmarshal 

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

func (*P2PMessage_Pong) XXX_DiscardUnknown 

func (m *P2PMessage_Pong) XXX_DiscardUnknown()

func (*P2PMessage_Pong) XXX_Marshal 

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

func (*P2PMessage_Pong) XXX_Merge 

func (dst *P2PMessage_Pong) XXX_Merge(src proto.Message)

func (*P2PMessage_Pong) XXX_Size 

func (m *P2PMessage_Pong) XXX_Size() int

func (*P2PMessage_Pong) XXX_Unmarshal 

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

type P2PMessage_Protocol 

type P2PMessage_Protocol struct {
	Pid                  *ProtocolId `protobuf:"varint,1,req,name=Pid,enum=tcpmsg.pb.ProtocolId" json:"Pid,omitempty"`
	Ver                  []byte      `protobuf:"bytes,2,req,name=Ver" json:"Ver,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*P2PMessage_Protocol) Descriptor 

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

func (*P2PMessage_Protocol) GetPid 

func (m *P2PMessage_Protocol) GetPid() ProtocolId

func (*P2PMessage_Protocol) GetVer 

func (m *P2PMessage_Protocol) GetVer() []byte

func (*P2PMessage_Protocol) Marshal 

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

func (*P2PMessage_Protocol) MarshalTo 

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

func (*P2PMessage_Protocol) ProtoMessage 

func (*P2PMessage_Protocol) ProtoMessage()

func (*P2PMessage_Protocol) Reset 

func (m *P2PMessage_Protocol) Reset()

func (*P2PMessage_Protocol) Size 

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

func (*P2PMessage_Protocol) String 

func (m *P2PMessage_Protocol) String() string

func (*P2PMessage_Protocol) Unmarshal 

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

func (*P2PMessage_Protocol) XXX_DiscardUnknown 

func (m *P2PMessage_Protocol) XXX_DiscardUnknown()

func (*P2PMessage_Protocol) XXX_Marshal 

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

func (*P2PMessage_Protocol) XXX_Merge 

func (dst *P2PMessage_Protocol) XXX_Merge(src proto.Message)

func (*P2PMessage_Protocol) XXX_Size 

func (m *P2PMessage_Protocol) XXX_Size() int

func (*P2PMessage_Protocol) XXX_Unmarshal 

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

type P2PPackage 

type P2PPackage struct {
	Pid                  *ProtocolId `protobuf:"varint,1,req,name=Pid,enum=tcpmsg.pb.ProtocolId" json:"Pid,omitempty"`
	ExtMid               *MessageId  `protobuf:"varint,2,opt,name=ExtMid,enum=tcpmsg.pb.MessageId" json:"ExtMid,omitempty"`
	ExtKey               []byte      `protobuf:"bytes,3,opt,name=ExtKey" json:"ExtKey,omitempty"`
	PayloadLength        *uint32     `protobuf:"varint,4,req,name=PayloadLength" json:"PayloadLength,omitempty"`
	Payload              []byte      `protobuf:"bytes,5,opt,name=Payload" json:"Payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*P2PPackage) Descriptor 

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

func (*P2PPackage) GetExtKey 

func (m *P2PPackage) GetExtKey() []byte

func (*P2PPackage) GetExtMid 

func (m *P2PPackage) GetExtMid() MessageId

func (*P2PPackage) GetPayload 

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

func (*P2PPackage) GetPayloadLength 

func (m *P2PPackage) GetPayloadLength() uint32

func (*P2PPackage) GetPid 

func (m *P2PPackage) GetPid() ProtocolId

func (*P2PPackage) Marshal 

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

func (*P2PPackage) MarshalTo 

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

func (*P2PPackage) ProtoMessage 

func (*P2PPackage) ProtoMessage()

func (*P2PPackage) Reset 

func (m *P2PPackage) Reset()

func (*P2PPackage) Size 

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

func (*P2PPackage) String 

func (m *P2PPackage) String() string

func (*P2PPackage) Unmarshal 

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

func (*P2PPackage) XXX_DiscardUnknown 

func (m *P2PPackage) XXX_DiscardUnknown()

func (*P2PPackage) XXX_Marshal 

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

func (*P2PPackage) XXX_Merge 

func (dst *P2PPackage) XXX_Merge(src proto.Message)

func (*P2PPackage) XXX_Size 

func (m *P2PPackage) XXX_Size() int

func (*P2PPackage) XXX_Unmarshal 

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

type ProtocolId 

type ProtocolId int32
const (
	ProtocolId_PID_P2P ProtocolId = 0
	ProtocolId_PID_EXT ProtocolId = 255
)

func (ProtocolId) Enum 

func (x ProtocolId) Enum() *ProtocolId

func (ProtocolId) EnumDescriptor 

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

func (ProtocolId) String 

func (x ProtocolId) String() string

func (*ProtocolId) UnmarshalJSON 

func (x *ProtocolId) UnmarshalJSON(data []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.