dhtmsg_pb

package
v0.5.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDhtmsg = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDhtmsg   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DhtMessage_ConnectionType_name = map[int32]string{
	0: "CONT_NO",
	1: "CONT_YES",
	2: "CONT_MAY",
	3: "CONT_FAILED",
}
View Source 
var DhtMessage_ConnectionType_value = map[string]int32{
	"CONT_NO":     0,
	"CONT_YES":    1,
	"CONT_MAY":    2,
	"CONT_FAILED": 3,
}
View Source 
var DhtMessage_MessageType_name = map[int32]string{
	0:  "MID_HANDSHAKE",
	1:  "MID_FINDNODE",
	2:  "MID_NEIGHBORS",
	3:  "MID_PUTVALUE",
	4:  "MID_GETVALUE_REQ",
	5:  "MID_GETVALUE_RSP",
	6:  "MID_PUTPROVIDER",
	7:  "MID_GETPROVIDER_REQ",
	8:  "MID_GETPROVIDER_RSP",
	9:  "MID_PING",
	10: "MID_PONG",
}
View Source 
var DhtMessage_MessageType_value = map[string]int32{
	"MID_HANDSHAKE":       0,
	"MID_FINDNODE":        1,
	"MID_NEIGHBORS":       2,
	"MID_PUTVALUE":        3,
	"MID_GETVALUE_REQ":    4,
	"MID_GETVALUE_RSP":    5,
	"MID_PUTPROVIDER":     6,
	"MID_GETPROVIDER_REQ": 7,
	"MID_GETPROVIDER_RSP": 8,
	"MID_PING":            9,
	"MID_PONG":            10,
}
View Source 
var ProtocolId_name = map[int32]string{
	0:   "PID_DHT",
	255: "PID_EXT",
}
View Source 
var ProtocolId_value = map[string]int32{
	"PID_DHT": 0,
	"PID_EXT": 255,
}

Functions

This section is empty.

Types

type DhtMessage 

type DhtMessage struct {
	MsgType              *DhtMessage_MessageType    `protobuf:"varint,1,req,name=msgType,enum=dhtmsg.pb.DhtMessage_MessageType" json:"msgType,omitempty"`
	Handshake            *DhtMessage_Handshake      `protobuf:"bytes,2,opt,name=handshake" json:"handshake,omitempty"`
	FindNode             *DhtMessage_FindNode       `protobuf:"bytes,3,opt,name=findNode" json:"findNode,omitempty"`
	Neighbors            *DhtMessage_Neighbors      `protobuf:"bytes,4,opt,name=neighbors" json:"neighbors,omitempty"`
	PutValue             *DhtMessage_PutValue       `protobuf:"bytes,5,opt,name=putValue" json:"putValue,omitempty"`
	GetValueReq          *DhtMessage_GetValueReq    `protobuf:"bytes,6,opt,name=getValueReq" json:"getValueReq,omitempty"`
	GetValueRsp          *DhtMessage_GetValueRsp    `protobuf:"bytes,7,opt,name=getValueRsp" json:"getValueRsp,omitempty"`
	PutProvider          *DhtMessage_PutProvider    `protobuf:"bytes,8,opt,name=putProvider" json:"putProvider,omitempty"`
	GetProviderReq       *DhtMessage_GetProviderReq `protobuf:"bytes,9,opt,name=getProviderReq" json:"getProviderReq,omitempty"`
	GetProviderRsp       *DhtMessage_GetProviderRsp `protobuf:"bytes,10,opt,name=getProviderRsp" json:"getProviderRsp,omitempty"`
	Ping                 *DhtMessage_Ping           `protobuf:"bytes,11,opt,name=ping" json:"ping,omitempty"`
	Pong                 *DhtMessage_Pong           `protobuf:"bytes,12,opt,name=pong" json:"pong,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*DhtMessage) Descriptor 

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

func (*DhtMessage) GetFindNode 

func (m *DhtMessage) GetFindNode() *DhtMessage_FindNode

func (*DhtMessage) GetGetProviderReq 

func (m *DhtMessage) GetGetProviderReq() *DhtMessage_GetProviderReq

func (*DhtMessage) GetGetProviderRsp 

func (m *DhtMessage) GetGetProviderRsp() *DhtMessage_GetProviderRsp

func (*DhtMessage) GetGetValueReq 

func (m *DhtMessage) GetGetValueReq() *DhtMessage_GetValueReq

func (*DhtMessage) GetGetValueRsp 

func (m *DhtMessage) GetGetValueRsp() *DhtMessage_GetValueRsp

func (*DhtMessage) GetHandshake 

func (m *DhtMessage) GetHandshake() *DhtMessage_Handshake

func (*DhtMessage) GetMsgType 

func (m *DhtMessage) GetMsgType() DhtMessage_MessageType

func (*DhtMessage) GetNeighbors 

func (m *DhtMessage) GetNeighbors() *DhtMessage_Neighbors

func (*DhtMessage) GetPing 

func (m *DhtMessage) GetPing() *DhtMessage_Ping

func (*DhtMessage) GetPong 

func (m *DhtMessage) GetPong() *DhtMessage_Pong

func (*DhtMessage) GetPutProvider 

func (m *DhtMessage) GetPutProvider() *DhtMessage_PutProvider

func (*DhtMessage) GetPutValue 

func (m *DhtMessage) GetPutValue() *DhtMessage_PutValue

func (*DhtMessage) Marshal 

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

func (*DhtMessage) MarshalTo 

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

func (*DhtMessage) ProtoMessage 

func (*DhtMessage) ProtoMessage()

func (*DhtMessage) Reset 

func (m *DhtMessage) Reset()

func (*DhtMessage) Size 

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

func (*DhtMessage) String 

func (m *DhtMessage) String() string

func (*DhtMessage) Unmarshal 

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

func (*DhtMessage) XXX_DiscardUnknown 

func (m *DhtMessage) XXX_DiscardUnknown()

func (*DhtMessage) XXX_Marshal 

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

func (*DhtMessage) XXX_Merge 

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

func (*DhtMessage) XXX_Size 

func (m *DhtMessage) XXX_Size() int

func (*DhtMessage) XXX_Unmarshal 

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

type DhtMessage_ConnectionType 

type DhtMessage_ConnectionType int32
const (
	DhtMessage_CONT_NO     DhtMessage_ConnectionType = 0
	DhtMessage_CONT_YES    DhtMessage_ConnectionType = 1
	DhtMessage_CONT_MAY    DhtMessage_ConnectionType = 2
	DhtMessage_CONT_FAILED DhtMessage_ConnectionType = 3
)

func (DhtMessage_ConnectionType) Enum 

func (x DhtMessage_ConnectionType) Enum() *DhtMessage_ConnectionType

func (DhtMessage_ConnectionType) EnumDescriptor 

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

func (DhtMessage_ConnectionType) String 

func (x DhtMessage_ConnectionType) String() string

func (*DhtMessage_ConnectionType) UnmarshalJSON 

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

type DhtMessage_FindNode 

type DhtMessage_FindNode struct {
	From                 *DhtMessage_Node `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Target               []byte           `protobuf:"bytes,3,req,name=Target" json:"Target,omitempty"`
	Id                   *uint64          `protobuf:"varint,4,req,name=Id" json:"Id,omitempty"`
	Extra                []byte           `protobuf:"bytes,5,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DhtMessage_FindNode) Descriptor 

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

func (*DhtMessage_FindNode) GetExtra 

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

func (*DhtMessage_FindNode) GetFrom 

func (m *DhtMessage_FindNode) GetFrom() *DhtMessage_Node

func (*DhtMessage_FindNode) GetId 

func (m *DhtMessage_FindNode) GetId() uint64

func (*DhtMessage_FindNode) GetTarget 

func (m *DhtMessage_FindNode) GetTarget() []byte

func (*DhtMessage_FindNode) GetTo 

func (m *DhtMessage_FindNode) GetTo() *DhtMessage_Node

func (*DhtMessage_FindNode) Marshal 

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

func (*DhtMessage_FindNode) MarshalTo 

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

func (*DhtMessage_FindNode) ProtoMessage 

func (*DhtMessage_FindNode) ProtoMessage()

func (*DhtMessage_FindNode) Reset 

func (m *DhtMessage_FindNode) Reset()

func (*DhtMessage_FindNode) Size 

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

func (*DhtMessage_FindNode) String 

func (m *DhtMessage_FindNode) String() string

func (*DhtMessage_FindNode) Unmarshal 

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

func (*DhtMessage_FindNode) XXX_DiscardUnknown 

func (m *DhtMessage_FindNode) XXX_DiscardUnknown()

func (*DhtMessage_FindNode) XXX_Marshal 

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

func (*DhtMessage_FindNode) XXX_Merge 

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

func (*DhtMessage_FindNode) XXX_Size 

func (m *DhtMessage_FindNode) XXX_Size() int

func (*DhtMessage_FindNode) XXX_Unmarshal 

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

type DhtMessage_GetProviderReq 

type DhtMessage_GetProviderReq struct {
	From                 *DhtMessage_Node `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Key                  []byte           `protobuf:"bytes,3,req,name=Key" json:"Key,omitempty"`
	Id                   *uint64          `protobuf:"varint,4,req,name=Id" json:"Id,omitempty"`
	Extra                []byte           `protobuf:"bytes,5,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DhtMessage_GetProviderReq) Descriptor 

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

func (*DhtMessage_GetProviderReq) GetExtra 

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

func (*DhtMessage_GetProviderReq) GetFrom 

func (m *DhtMessage_GetProviderReq) GetFrom() *DhtMessage_Node

func (*DhtMessage_GetProviderReq) GetId 

func (m *DhtMessage_GetProviderReq) GetId() uint64

func (*DhtMessage_GetProviderReq) GetKey 

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

func (*DhtMessage_GetProviderReq) GetTo 

func (m *DhtMessage_GetProviderReq) GetTo() *DhtMessage_Node

func (*DhtMessage_GetProviderReq) Marshal 

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

func (*DhtMessage_GetProviderReq) MarshalTo 

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

func (*DhtMessage_GetProviderReq) ProtoMessage 

func (*DhtMessage_GetProviderReq) ProtoMessage()

func (*DhtMessage_GetProviderReq) Reset 

func (m *DhtMessage_GetProviderReq) Reset()

func (*DhtMessage_GetProviderReq) Size 

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

func (*DhtMessage_GetProviderReq) String 

func (m *DhtMessage_GetProviderReq) String() string

func (*DhtMessage_GetProviderReq) Unmarshal 

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

func (*DhtMessage_GetProviderReq) XXX_DiscardUnknown 

func (m *DhtMessage_GetProviderReq) XXX_DiscardUnknown()

func (*DhtMessage_GetProviderReq) XXX_Marshal 

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

func (*DhtMessage_GetProviderReq) XXX_Merge 

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

func (*DhtMessage_GetProviderReq) XXX_Size 

func (m *DhtMessage_GetProviderReq) XXX_Size() int

func (*DhtMessage_GetProviderReq) XXX_Unmarshal 

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

type DhtMessage_GetProviderRsp 

type DhtMessage_GetProviderRsp struct {
	From                 *DhtMessage_Node     `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node     `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Provider             *DhtMessage_Provider `protobuf:"bytes,3,req,name=Provider" json:"Provider,omitempty"`
	Key                  []byte               `protobuf:"bytes,4,req,name=Key" json:"Key,omitempty"`
	Nodes                []*DhtMessage_Node   `protobuf:"bytes,5,rep,name=Nodes" json:"Nodes,omitempty"`
	Id                   *uint64              `protobuf:"varint,6,req,name=Id" json:"Id,omitempty"`
	Extra                []byte               `protobuf:"bytes,7,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DhtMessage_GetProviderRsp) Descriptor 

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

func (*DhtMessage_GetProviderRsp) GetExtra 

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

func (*DhtMessage_GetProviderRsp) GetFrom 

func (m *DhtMessage_GetProviderRsp) GetFrom() *DhtMessage_Node

func (*DhtMessage_GetProviderRsp) GetId 

func (m *DhtMessage_GetProviderRsp) GetId() uint64

func (*DhtMessage_GetProviderRsp) GetKey 

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

func (*DhtMessage_GetProviderRsp) GetNodes 

func (m *DhtMessage_GetProviderRsp) GetNodes() []*DhtMessage_Node

func (*DhtMessage_GetProviderRsp) GetProvider 

func (m *DhtMessage_GetProviderRsp) GetProvider() *DhtMessage_Provider

func (*DhtMessage_GetProviderRsp) GetTo 

func (m *DhtMessage_GetProviderRsp) GetTo() *DhtMessage_Node

func (*DhtMessage_GetProviderRsp) Marshal 

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

func (*DhtMessage_GetProviderRsp) MarshalTo 

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

func (*DhtMessage_GetProviderRsp) ProtoMessage 

func (*DhtMessage_GetProviderRsp) ProtoMessage()

func (*DhtMessage_GetProviderRsp) Reset 

func (m *DhtMessage_GetProviderRsp) Reset()

func (*DhtMessage_GetProviderRsp) Size 

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

func (*DhtMessage_GetProviderRsp) String 

func (m *DhtMessage_GetProviderRsp) String() string

func (*DhtMessage_GetProviderRsp) Unmarshal 

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

func (*DhtMessage_GetProviderRsp) XXX_DiscardUnknown 

func (m *DhtMessage_GetProviderRsp) XXX_DiscardUnknown()

func (*DhtMessage_GetProviderRsp) XXX_Marshal 

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

func (*DhtMessage_GetProviderRsp) XXX_Merge 

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

func (*DhtMessage_GetProviderRsp) XXX_Size 

func (m *DhtMessage_GetProviderRsp) XXX_Size() int

func (*DhtMessage_GetProviderRsp) XXX_Unmarshal 

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

type DhtMessage_GetValueReq 

type DhtMessage_GetValueReq struct {
	From                 *DhtMessage_Node `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Key                  []byte           `protobuf:"bytes,3,req,name=Key" json:"Key,omitempty"`
	Id                   *uint64          `protobuf:"varint,4,req,name=Id" json:"Id,omitempty"`
	Extra                []byte           `protobuf:"bytes,5,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DhtMessage_GetValueReq) Descriptor 

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

func (*DhtMessage_GetValueReq) GetExtra 

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

func (*DhtMessage_GetValueReq) GetFrom 

func (m *DhtMessage_GetValueReq) GetFrom() *DhtMessage_Node

func (*DhtMessage_GetValueReq) GetId 

func (m *DhtMessage_GetValueReq) GetId() uint64

func (*DhtMessage_GetValueReq) GetKey 

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

func (*DhtMessage_GetValueReq) GetTo 

func (m *DhtMessage_GetValueReq) GetTo() *DhtMessage_Node

func (*DhtMessage_GetValueReq) Marshal 

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

func (*DhtMessage_GetValueReq) MarshalTo 

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

func (*DhtMessage_GetValueReq) ProtoMessage 

func (*DhtMessage_GetValueReq) ProtoMessage()

func (*DhtMessage_GetValueReq) Reset 

func (m *DhtMessage_GetValueReq) Reset()

func (*DhtMessage_GetValueReq) Size 

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

func (*DhtMessage_GetValueReq) String 

func (m *DhtMessage_GetValueReq) String() string

func (*DhtMessage_GetValueReq) Unmarshal 

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

func (*DhtMessage_GetValueReq) XXX_DiscardUnknown 

func (m *DhtMessage_GetValueReq) XXX_DiscardUnknown()

func (*DhtMessage_GetValueReq) XXX_Marshal 

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

func (*DhtMessage_GetValueReq) XXX_Merge 

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

func (*DhtMessage_GetValueReq) XXX_Size 

func (m *DhtMessage_GetValueReq) XXX_Size() int

func (*DhtMessage_GetValueReq) XXX_Unmarshal 

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

type DhtMessage_GetValueRsp 

type DhtMessage_GetValueRsp struct {
	From                 *DhtMessage_Node  `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node  `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Value                *DhtMessage_Value `protobuf:"bytes,3,opt,name=Value" json:"Value,omitempty"`
	Nodes                *DhtMessage_Node  `protobuf:"bytes,4,opt,name=Nodes" json:"Nodes,omitempty"`
	Id                   *uint64           `protobuf:"varint,5,req,name=Id" json:"Id,omitempty"`
	Extra                []byte            `protobuf:"bytes,6,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DhtMessage_GetValueRsp) Descriptor 

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

func (*DhtMessage_GetValueRsp) GetExtra 

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

func (*DhtMessage_GetValueRsp) GetFrom 

func (m *DhtMessage_GetValueRsp) GetFrom() *DhtMessage_Node

func (*DhtMessage_GetValueRsp) GetId 

func (m *DhtMessage_GetValueRsp) GetId() uint64

func (*DhtMessage_GetValueRsp) GetNodes 

func (m *DhtMessage_GetValueRsp) GetNodes() *DhtMessage_Node

func (*DhtMessage_GetValueRsp) GetTo 

func (m *DhtMessage_GetValueRsp) GetTo() *DhtMessage_Node

func (*DhtMessage_GetValueRsp) GetValue 

func (m *DhtMessage_GetValueRsp) GetValue() *DhtMessage_Value

func (*DhtMessage_GetValueRsp) Marshal 

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

func (*DhtMessage_GetValueRsp) MarshalTo 

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

func (*DhtMessage_GetValueRsp) ProtoMessage 

func (*DhtMessage_GetValueRsp) ProtoMessage()

func (*DhtMessage_GetValueRsp) Reset 

func (m *DhtMessage_GetValueRsp) Reset()

func (*DhtMessage_GetValueRsp) Size 

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

func (*DhtMessage_GetValueRsp) String 

func (m *DhtMessage_GetValueRsp) String() string

func (*DhtMessage_GetValueRsp) Unmarshal 

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

func (*DhtMessage_GetValueRsp) XXX_DiscardUnknown 

func (m *DhtMessage_GetValueRsp) XXX_DiscardUnknown()

func (*DhtMessage_GetValueRsp) XXX_Marshal 

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

func (*DhtMessage_GetValueRsp) XXX_Merge 

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

func (*DhtMessage_GetValueRsp) XXX_Size 

func (m *DhtMessage_GetValueRsp) XXX_Size() int

func (*DhtMessage_GetValueRsp) XXX_Unmarshal 

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

type DhtMessage_Handshake 

type DhtMessage_Handshake struct {
	ChainId              *uint32                `protobuf:"varint,1,req,name=ChainId" json:"ChainId,omitempty"`
	Dir                  *int32                 `protobuf:"varint,2,req,name=Dir" json:"Dir,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            []*DhtMessage_Protocol `protobuf:"bytes,8,rep,name=Protocols" json:"Protocols,omitempty"`
	Id                   *uint64                `protobuf:"varint,9,req,name=Id" json:"Id,omitempty"`
	Extra                []byte                 `protobuf:"bytes,10,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DhtMessage_Handshake) Descriptor 

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

func (*DhtMessage_Handshake) GetChainId 

func (m *DhtMessage_Handshake) GetChainId() uint32

func (*DhtMessage_Handshake) GetDir 

func (m *DhtMessage_Handshake) GetDir() int32

func (*DhtMessage_Handshake) GetExtra 

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

func (*DhtMessage_Handshake) GetIP 

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

func (*DhtMessage_Handshake) GetId 

func (m *DhtMessage_Handshake) GetId() uint64

func (*DhtMessage_Handshake) GetNodeId 

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

func (*DhtMessage_Handshake) GetProtoNum 

func (m *DhtMessage_Handshake) GetProtoNum() uint32

func (*DhtMessage_Handshake) GetProtocols 

func (m *DhtMessage_Handshake) GetProtocols() []*DhtMessage_Protocol

func (*DhtMessage_Handshake) GetTCP 

func (m *DhtMessage_Handshake) GetTCP() uint32

func (*DhtMessage_Handshake) GetUDP 

func (m *DhtMessage_Handshake) GetUDP() uint32

func (*DhtMessage_Handshake) Marshal 

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

func (*DhtMessage_Handshake) MarshalTo 

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

func (*DhtMessage_Handshake) ProtoMessage 

func (*DhtMessage_Handshake) ProtoMessage()

func (*DhtMessage_Handshake) Reset 

func (m *DhtMessage_Handshake) Reset()

func (*DhtMessage_Handshake) Size 

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

func (*DhtMessage_Handshake) String 

func (m *DhtMessage_Handshake) String() string

func (*DhtMessage_Handshake) Unmarshal 

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

func (*DhtMessage_Handshake) XXX_DiscardUnknown 

func (m *DhtMessage_Handshake) XXX_DiscardUnknown()

func (*DhtMessage_Handshake) XXX_Marshal 

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

func (*DhtMessage_Handshake) XXX_Merge 

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

func (*DhtMessage_Handshake) XXX_Size 

func (m *DhtMessage_Handshake) XXX_Size() int

func (*DhtMessage_Handshake) XXX_Unmarshal 

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

type DhtMessage_MessageType 

type DhtMessage_MessageType int32
const (
	DhtMessage_MID_HANDSHAKE       DhtMessage_MessageType = 0
	DhtMessage_MID_FINDNODE        DhtMessage_MessageType = 1
	DhtMessage_MID_NEIGHBORS       DhtMessage_MessageType = 2
	DhtMessage_MID_PUTVALUE        DhtMessage_MessageType = 3
	DhtMessage_MID_GETVALUE_REQ    DhtMessage_MessageType = 4
	DhtMessage_MID_GETVALUE_RSP    DhtMessage_MessageType = 5
	DhtMessage_MID_PUTPROVIDER     DhtMessage_MessageType = 6
	DhtMessage_MID_GETPROVIDER_REQ DhtMessage_MessageType = 7
	DhtMessage_MID_GETPROVIDER_RSP DhtMessage_MessageType = 8
	DhtMessage_MID_PING            DhtMessage_MessageType = 9
	DhtMessage_MID_PONG            DhtMessage_MessageType = 10
)

func (DhtMessage_MessageType) Enum 

func (x DhtMessage_MessageType) Enum() *DhtMessage_MessageType

func (DhtMessage_MessageType) EnumDescriptor 

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

func (DhtMessage_MessageType) String 

func (x DhtMessage_MessageType) String() string

func (*DhtMessage_MessageType) UnmarshalJSON 

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

type DhtMessage_Neighbors 

type DhtMessage_Neighbors struct {
	From                 *DhtMessage_Node   `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node   `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Nodes                []*DhtMessage_Node `protobuf:"bytes,3,rep,name=Nodes" json:"Nodes,omitempty"`
	Id                   *uint64            `protobuf:"varint,4,req,name=Id" json:"Id,omitempty"`
	Extra                []byte             `protobuf:"bytes,5,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DhtMessage_Neighbors) Descriptor 

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

func (*DhtMessage_Neighbors) GetExtra 

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

func (*DhtMessage_Neighbors) GetFrom 

func (m *DhtMessage_Neighbors) GetFrom() *DhtMessage_Node

func (*DhtMessage_Neighbors) GetId 

func (m *DhtMessage_Neighbors) GetId() uint64

func (*DhtMessage_Neighbors) GetNodes 

func (m *DhtMessage_Neighbors) GetNodes() []*DhtMessage_Node

func (*DhtMessage_Neighbors) GetTo 

func (m *DhtMessage_Neighbors) GetTo() *DhtMessage_Node

func (*DhtMessage_Neighbors) Marshal 

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

func (*DhtMessage_Neighbors) MarshalTo 

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

func (*DhtMessage_Neighbors) ProtoMessage 

func (*DhtMessage_Neighbors) ProtoMessage()

func (*DhtMessage_Neighbors) Reset 

func (m *DhtMessage_Neighbors) Reset()

func (*DhtMessage_Neighbors) Size 

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

func (*DhtMessage_Neighbors) String 

func (m *DhtMessage_Neighbors) String() string

func (*DhtMessage_Neighbors) Unmarshal 

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

func (*DhtMessage_Neighbors) XXX_DiscardUnknown 

func (m *DhtMessage_Neighbors) XXX_DiscardUnknown()

func (*DhtMessage_Neighbors) XXX_Marshal 

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

func (*DhtMessage_Neighbors) XXX_Merge 

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

func (*DhtMessage_Neighbors) XXX_Size 

func (m *DhtMessage_Neighbors) XXX_Size() int

func (*DhtMessage_Neighbors) XXX_Unmarshal 

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

type DhtMessage_Node 

type DhtMessage_Node struct {
	IP                   []byte                     `protobuf:"bytes,1,req,name=IP" json:"IP,omitempty"`
	UDP                  *uint32                    `protobuf:"varint,2,req,name=UDP" json:"UDP,omitempty"`
	TCP                  *uint32                    `protobuf:"varint,3,req,name=TCP" json:"TCP,omitempty"`
	NodeId               []byte                     `protobuf:"bytes,4,req,name=NodeId" json:"NodeId,omitempty"`
	ConnType             *DhtMessage_ConnectionType `protobuf:"varint,5,req,name=ConnType,enum=dhtmsg.pb.DhtMessage_ConnectionType" json:"ConnType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*DhtMessage_Node) Descriptor 

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

func (*DhtMessage_Node) GetConnType 

func (m *DhtMessage_Node) GetConnType() DhtMessage_ConnectionType

func (*DhtMessage_Node) GetIP 

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

func (*DhtMessage_Node) GetNodeId 

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

func (*DhtMessage_Node) GetTCP 

func (m *DhtMessage_Node) GetTCP() uint32

func (*DhtMessage_Node) GetUDP 

func (m *DhtMessage_Node) GetUDP() uint32

func (*DhtMessage_Node) Marshal 

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

func (*DhtMessage_Node) MarshalTo 

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

func (*DhtMessage_Node) ProtoMessage 

func (*DhtMessage_Node) ProtoMessage()

func (*DhtMessage_Node) Reset 

func (m *DhtMessage_Node) Reset()

func (*DhtMessage_Node) Size 

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

func (*DhtMessage_Node) String 

func (m *DhtMessage_Node) String() string

func (*DhtMessage_Node) Unmarshal 

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

func (*DhtMessage_Node) XXX_DiscardUnknown 

func (m *DhtMessage_Node) XXX_DiscardUnknown()

func (*DhtMessage_Node) XXX_Marshal 

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

func (*DhtMessage_Node) XXX_Merge 

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

func (*DhtMessage_Node) XXX_Size 

func (m *DhtMessage_Node) XXX_Size() int

func (*DhtMessage_Node) XXX_Unmarshal 

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

type DhtMessage_Ping 

type DhtMessage_Ping struct {
	From                 *DhtMessage_Node `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Seq                  *uint64          `protobuf:"varint,3,req,name=Seq" json:"Seq,omitempty"`
	Extra                []byte           `protobuf:"bytes,4,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DhtMessage_Ping) Descriptor 

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

func (*DhtMessage_Ping) GetExtra 

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

func (*DhtMessage_Ping) GetFrom 

func (m *DhtMessage_Ping) GetFrom() *DhtMessage_Node

func (*DhtMessage_Ping) GetSeq 

func (m *DhtMessage_Ping) GetSeq() uint64

func (*DhtMessage_Ping) GetTo 

func (m *DhtMessage_Ping) GetTo() *DhtMessage_Node

func (*DhtMessage_Ping) Marshal 

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

func (*DhtMessage_Ping) MarshalTo 

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

func (*DhtMessage_Ping) ProtoMessage 

func (*DhtMessage_Ping) ProtoMessage()

func (*DhtMessage_Ping) Reset 

func (m *DhtMessage_Ping) Reset()

func (*DhtMessage_Ping) Size 

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

func (*DhtMessage_Ping) String 

func (m *DhtMessage_Ping) String() string

func (*DhtMessage_Ping) Unmarshal 

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

func (*DhtMessage_Ping) XXX_DiscardUnknown 

func (m *DhtMessage_Ping) XXX_DiscardUnknown()

func (*DhtMessage_Ping) XXX_Marshal 

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

func (*DhtMessage_Ping) XXX_Merge 

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

func (*DhtMessage_Ping) XXX_Size 

func (m *DhtMessage_Ping) XXX_Size() int

func (*DhtMessage_Ping) XXX_Unmarshal 

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

type DhtMessage_Pong 

type DhtMessage_Pong struct {
	From                 *DhtMessage_Node `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Seq                  *uint64          `protobuf:"varint,3,req,name=Seq" json:"Seq,omitempty"`
	Extra                []byte           `protobuf:"bytes,4,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DhtMessage_Pong) Descriptor 

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

func (*DhtMessage_Pong) GetExtra 

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

func (*DhtMessage_Pong) GetFrom 

func (m *DhtMessage_Pong) GetFrom() *DhtMessage_Node

func (*DhtMessage_Pong) GetSeq 

func (m *DhtMessage_Pong) GetSeq() uint64

func (*DhtMessage_Pong) GetTo 

func (m *DhtMessage_Pong) GetTo() *DhtMessage_Node

func (*DhtMessage_Pong) Marshal 

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

func (*DhtMessage_Pong) MarshalTo 

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

func (*DhtMessage_Pong) ProtoMessage 

func (*DhtMessage_Pong) ProtoMessage()

func (*DhtMessage_Pong) Reset 

func (m *DhtMessage_Pong) Reset()

func (*DhtMessage_Pong) Size 

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

func (*DhtMessage_Pong) String 

func (m *DhtMessage_Pong) String() string

func (*DhtMessage_Pong) Unmarshal 

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

func (*DhtMessage_Pong) XXX_DiscardUnknown 

func (m *DhtMessage_Pong) XXX_DiscardUnknown()

func (*DhtMessage_Pong) XXX_Marshal 

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

func (*DhtMessage_Pong) XXX_Merge 

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

func (*DhtMessage_Pong) XXX_Size 

func (m *DhtMessage_Pong) XXX_Size() int

func (*DhtMessage_Pong) XXX_Unmarshal 

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

type DhtMessage_Protocol 

type DhtMessage_Protocol struct {
	Pid                  *ProtocolId `protobuf:"varint,1,req,name=Pid,enum=dhtmsg.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 (*DhtMessage_Protocol) Descriptor 

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

func (*DhtMessage_Protocol) GetPid 

func (m *DhtMessage_Protocol) GetPid() ProtocolId

func (*DhtMessage_Protocol) GetVer 

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

func (*DhtMessage_Protocol) Marshal 

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

func (*DhtMessage_Protocol) MarshalTo 

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

func (*DhtMessage_Protocol) ProtoMessage 

func (*DhtMessage_Protocol) ProtoMessage()

func (*DhtMessage_Protocol) Reset 

func (m *DhtMessage_Protocol) Reset()

func (*DhtMessage_Protocol) Size 

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

func (*DhtMessage_Protocol) String 

func (m *DhtMessage_Protocol) String() string

func (*DhtMessage_Protocol) Unmarshal 

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

func (*DhtMessage_Protocol) XXX_DiscardUnknown 

func (m *DhtMessage_Protocol) XXX_DiscardUnknown()

func (*DhtMessage_Protocol) XXX_Marshal 

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

func (*DhtMessage_Protocol) XXX_Merge 

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

func (*DhtMessage_Protocol) XXX_Size 

func (m *DhtMessage_Protocol) XXX_Size() int

func (*DhtMessage_Protocol) XXX_Unmarshal 

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

type DhtMessage_Provider 

type DhtMessage_Provider struct {
	Key                  []byte             `protobuf:"bytes,1,req,name=Key" json:"Key,omitempty"`
	Nodes                []*DhtMessage_Node `protobuf:"bytes,2,rep,name=Nodes" json:"Nodes,omitempty"`
	Extra                []byte             `protobuf:"bytes,3,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DhtMessage_Provider) Descriptor 

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

func (*DhtMessage_Provider) GetExtra 

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

func (*DhtMessage_Provider) GetKey 

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

func (*DhtMessage_Provider) GetNodes 

func (m *DhtMessage_Provider) GetNodes() []*DhtMessage_Node

func (*DhtMessage_Provider) Marshal 

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

func (*DhtMessage_Provider) MarshalTo 

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

func (*DhtMessage_Provider) ProtoMessage 

func (*DhtMessage_Provider) ProtoMessage()

func (*DhtMessage_Provider) Reset 

func (m *DhtMessage_Provider) Reset()

func (*DhtMessage_Provider) Size 

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

func (*DhtMessage_Provider) String 

func (m *DhtMessage_Provider) String() string

func (*DhtMessage_Provider) Unmarshal 

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

func (*DhtMessage_Provider) XXX_DiscardUnknown 

func (m *DhtMessage_Provider) XXX_DiscardUnknown()

func (*DhtMessage_Provider) XXX_Marshal 

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

func (*DhtMessage_Provider) XXX_Merge 

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

func (*DhtMessage_Provider) XXX_Size 

func (m *DhtMessage_Provider) XXX_Size() int

func (*DhtMessage_Provider) XXX_Unmarshal 

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

type DhtMessage_PutProvider 

type DhtMessage_PutProvider struct {
	From                 *DhtMessage_Node     `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node     `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Provider             *DhtMessage_Provider `protobuf:"bytes,3,req,name=Provider" json:"Provider,omitempty"`
	Id                   *uint64              `protobuf:"varint,4,req,name=Id" json:"Id,omitempty"`
	Extra                []byte               `protobuf:"bytes,5,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DhtMessage_PutProvider) Descriptor 

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

func (*DhtMessage_PutProvider) GetExtra 

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

func (*DhtMessage_PutProvider) GetFrom 

func (m *DhtMessage_PutProvider) GetFrom() *DhtMessage_Node

func (*DhtMessage_PutProvider) GetId 

func (m *DhtMessage_PutProvider) GetId() uint64

func (*DhtMessage_PutProvider) GetProvider 

func (m *DhtMessage_PutProvider) GetProvider() *DhtMessage_Provider

func (*DhtMessage_PutProvider) GetTo 

func (m *DhtMessage_PutProvider) GetTo() *DhtMessage_Node

func (*DhtMessage_PutProvider) Marshal 

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

func (*DhtMessage_PutProvider) MarshalTo 

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

func (*DhtMessage_PutProvider) ProtoMessage 

func (*DhtMessage_PutProvider) ProtoMessage()

func (*DhtMessage_PutProvider) Reset 

func (m *DhtMessage_PutProvider) Reset()

func (*DhtMessage_PutProvider) Size 

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

func (*DhtMessage_PutProvider) String 

func (m *DhtMessage_PutProvider) String() string

func (*DhtMessage_PutProvider) Unmarshal 

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

func (*DhtMessage_PutProvider) XXX_DiscardUnknown 

func (m *DhtMessage_PutProvider) XXX_DiscardUnknown()

func (*DhtMessage_PutProvider) XXX_Marshal 

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

func (*DhtMessage_PutProvider) XXX_Merge 

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

func (*DhtMessage_PutProvider) XXX_Size 

func (m *DhtMessage_PutProvider) XXX_Size() int

func (*DhtMessage_PutProvider) XXX_Unmarshal 

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

type DhtMessage_PutValue 

type DhtMessage_PutValue struct {
	From                 *DhtMessage_Node    `protobuf:"bytes,1,req,name=From" json:"From,omitempty"`
	To                   *DhtMessage_Node    `protobuf:"bytes,2,req,name=To" json:"To,omitempty"`
	Values               []*DhtMessage_Value `protobuf:"bytes,3,rep,name=Values" json:"Values,omitempty"`
	Id                   *uint64             `protobuf:"varint,4,req,name=Id" json:"Id,omitempty"`
	Extra                []byte              `protobuf:"bytes,5,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DhtMessage_PutValue) Descriptor 

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

func (*DhtMessage_PutValue) GetExtra 

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

func (*DhtMessage_PutValue) GetFrom 

func (m *DhtMessage_PutValue) GetFrom() *DhtMessage_Node

func (*DhtMessage_PutValue) GetId 

func (m *DhtMessage_PutValue) GetId() uint64

func (*DhtMessage_PutValue) GetTo 

func (m *DhtMessage_PutValue) GetTo() *DhtMessage_Node

func (*DhtMessage_PutValue) GetValues 

func (m *DhtMessage_PutValue) GetValues() []*DhtMessage_Value

func (*DhtMessage_PutValue) Marshal 

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

func (*DhtMessage_PutValue) MarshalTo 

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

func (*DhtMessage_PutValue) ProtoMessage 

func (*DhtMessage_PutValue) ProtoMessage()

func (*DhtMessage_PutValue) Reset 

func (m *DhtMessage_PutValue) Reset()

func (*DhtMessage_PutValue) Size 

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

func (*DhtMessage_PutValue) String 

func (m *DhtMessage_PutValue) String() string

func (*DhtMessage_PutValue) Unmarshal 

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

func (*DhtMessage_PutValue) XXX_DiscardUnknown 

func (m *DhtMessage_PutValue) XXX_DiscardUnknown()

func (*DhtMessage_PutValue) XXX_Marshal 

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

func (*DhtMessage_PutValue) XXX_Merge 

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

func (*DhtMessage_PutValue) XXX_Size 

func (m *DhtMessage_PutValue) XXX_Size() int

func (*DhtMessage_PutValue) XXX_Unmarshal 

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

type DhtMessage_Value 

type DhtMessage_Value struct {
	Key                  []byte   `protobuf:"bytes,1,req,name=Key" json:"Key,omitempty"`
	Val                  []byte   `protobuf:"bytes,2,req,name=Val" json:"Val,omitempty"`
	Extra                []byte   `protobuf:"bytes,3,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DhtMessage_Value) Descriptor 

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

func (*DhtMessage_Value) GetExtra 

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

func (*DhtMessage_Value) GetKey 

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

func (*DhtMessage_Value) GetVal 

func (m *DhtMessage_Value) GetVal() []byte

func (*DhtMessage_Value) Marshal 

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

func (*DhtMessage_Value) MarshalTo 

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

func (*DhtMessage_Value) ProtoMessage 

func (*DhtMessage_Value) ProtoMessage()

func (*DhtMessage_Value) Reset 

func (m *DhtMessage_Value) Reset()

func (*DhtMessage_Value) Size 

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

func (*DhtMessage_Value) String 

func (m *DhtMessage_Value) String() string

func (*DhtMessage_Value) Unmarshal 

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

func (*DhtMessage_Value) XXX_DiscardUnknown 

func (m *DhtMessage_Value) XXX_DiscardUnknown()

func (*DhtMessage_Value) XXX_Marshal 

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

func (*DhtMessage_Value) XXX_Merge 

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

func (*DhtMessage_Value) XXX_Size 

func (m *DhtMessage_Value) XXX_Size() int

func (*DhtMessage_Value) XXX_Unmarshal 

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

type DhtPackage 

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

func (*DhtPackage) Descriptor 

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

func (*DhtPackage) GetPayload 

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

func (*DhtPackage) GetPayloadLength 

func (m *DhtPackage) GetPayloadLength() uint32

func (*DhtPackage) GetPid 

func (m *DhtPackage) GetPid() ProtocolId

func (*DhtPackage) Marshal 

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

func (*DhtPackage) MarshalTo 

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

func (*DhtPackage) ProtoMessage 

func (*DhtPackage) ProtoMessage()

func (*DhtPackage) Reset 

func (m *DhtPackage) Reset()

func (*DhtPackage) Size 

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

func (*DhtPackage) String 

func (m *DhtPackage) String() string

func (*DhtPackage) Unmarshal 

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

func (*DhtPackage) XXX_DiscardUnknown 

func (m *DhtPackage) XXX_DiscardUnknown()

func (*DhtPackage) XXX_Marshal 

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

func (*DhtPackage) XXX_Merge 

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

func (*DhtPackage) XXX_Size 

func (m *DhtPackage) XXX_Size() int

func (*DhtPackage) XXX_Unmarshal 

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

type DhtProviderRecord 

type DhtProviderRecord struct {
	Key                  []byte                        `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Providers            []*DhtProviderRecord_Provider `protobuf:"bytes,2,rep,name=providers" json:"providers,omitempty"`
	Extra                []byte                        `protobuf:"bytes,3,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*DhtProviderRecord) Descriptor 

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

func (*DhtProviderRecord) GetExtra 

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

func (*DhtProviderRecord) GetKey 

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

func (*DhtProviderRecord) GetProviders 

func (m *DhtProviderRecord) GetProviders() []*DhtProviderRecord_Provider

func (*DhtProviderRecord) Marshal 

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

func (*DhtProviderRecord) MarshalTo 

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

func (*DhtProviderRecord) ProtoMessage 

func (*DhtProviderRecord) ProtoMessage()

func (*DhtProviderRecord) Reset 

func (m *DhtProviderRecord) Reset()

func (*DhtProviderRecord) Size 

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

func (*DhtProviderRecord) String 

func (m *DhtProviderRecord) String() string

func (*DhtProviderRecord) Unmarshal 

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

func (*DhtProviderRecord) XXX_DiscardUnknown 

func (m *DhtProviderRecord) XXX_DiscardUnknown()

func (*DhtProviderRecord) XXX_Marshal 

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

func (*DhtProviderRecord) XXX_Merge 

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

func (*DhtProviderRecord) XXX_Size 

func (m *DhtProviderRecord) XXX_Size() int

func (*DhtProviderRecord) XXX_Unmarshal 

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

type DhtProviderRecord_Node 

type DhtProviderRecord_Node struct {
	IP                   []byte   `protobuf:"bytes,1,req,name=IP" json:"IP,omitempty"`
	UDP                  *uint32  `protobuf:"varint,2,req,name=UDP" json:"UDP,omitempty"`
	TCP                  *uint32  `protobuf:"varint,3,req,name=TCP" json:"TCP,omitempty"`
	NodeId               []byte   `protobuf:"bytes,4,req,name=NodeId" json:"NodeId,omitempty"`
	Extra                []byte   `protobuf:"bytes,5,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DhtProviderRecord_Node) Descriptor 

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

func (*DhtProviderRecord_Node) GetExtra 

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

func (*DhtProviderRecord_Node) GetIP 

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

func (*DhtProviderRecord_Node) GetNodeId 

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

func (*DhtProviderRecord_Node) GetTCP 

func (m *DhtProviderRecord_Node) GetTCP() uint32

func (*DhtProviderRecord_Node) GetUDP 

func (m *DhtProviderRecord_Node) GetUDP() uint32

func (*DhtProviderRecord_Node) Marshal 

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

func (*DhtProviderRecord_Node) MarshalTo 

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

func (*DhtProviderRecord_Node) ProtoMessage 

func (*DhtProviderRecord_Node) ProtoMessage()

func (*DhtProviderRecord_Node) Reset 

func (m *DhtProviderRecord_Node) Reset()

func (*DhtProviderRecord_Node) Size 

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

func (*DhtProviderRecord_Node) String 

func (m *DhtProviderRecord_Node) String() string

func (*DhtProviderRecord_Node) Unmarshal 

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

func (*DhtProviderRecord_Node) XXX_DiscardUnknown 

func (m *DhtProviderRecord_Node) XXX_DiscardUnknown()

func (*DhtProviderRecord_Node) XXX_Marshal 

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

func (*DhtProviderRecord_Node) XXX_Merge 

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

func (*DhtProviderRecord_Node) XXX_Size 

func (m *DhtProviderRecord_Node) XXX_Size() int

func (*DhtProviderRecord_Node) XXX_Unmarshal 

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

type DhtProviderRecord_Provider 

type DhtProviderRecord_Provider struct {
	Node                 *DhtProviderRecord_Node `protobuf:"bytes,1,req,name=Node" json:"Node,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 (*DhtProviderRecord_Provider) Descriptor 

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

func (*DhtProviderRecord_Provider) GetExtra 

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

func (*DhtProviderRecord_Provider) GetNode 

func (m *DhtProviderRecord_Provider) GetNode() *DhtProviderRecord_Node

func (*DhtProviderRecord_Provider) Marshal 

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

func (*DhtProviderRecord_Provider) MarshalTo 

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

func (*DhtProviderRecord_Provider) ProtoMessage 

func (*DhtProviderRecord_Provider) ProtoMessage()

func (*DhtProviderRecord_Provider) Reset 

func (m *DhtProviderRecord_Provider) Reset()

func (*DhtProviderRecord_Provider) Size 

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

func (*DhtProviderRecord_Provider) String 

func (m *DhtProviderRecord_Provider) String() string

func (*DhtProviderRecord_Provider) Unmarshal 

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

func (*DhtProviderRecord_Provider) XXX_DiscardUnknown 

func (m *DhtProviderRecord_Provider) XXX_DiscardUnknown()

func (*DhtProviderRecord_Provider) XXX_Marshal 

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

func (*DhtProviderRecord_Provider) XXX_Merge 

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

func (*DhtProviderRecord_Provider) XXX_Size 

func (m *DhtProviderRecord_Provider) XXX_Size() int

func (*DhtProviderRecord_Provider) XXX_Unmarshal 

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

type DhtRecord 

type DhtRecord struct {
	Key                  []byte   `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	Extra                []byte   `protobuf:"bytes,3,opt,name=Extra" json:"Extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DhtRecord) Descriptor 

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

func (*DhtRecord) GetExtra 

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

func (*DhtRecord) GetKey 

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

func (*DhtRecord) GetValue 

func (m *DhtRecord) GetValue() []byte

func (*DhtRecord) Marshal 

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

func (*DhtRecord) MarshalTo 

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

func (*DhtRecord) ProtoMessage 

func (*DhtRecord) ProtoMessage()

func (*DhtRecord) Reset 

func (m *DhtRecord) Reset()

func (*DhtRecord) Size 

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

func (*DhtRecord) String 

func (m *DhtRecord) String() string

func (*DhtRecord) Unmarshal 

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

func (*DhtRecord) XXX_DiscardUnknown 

func (m *DhtRecord) XXX_DiscardUnknown()

func (*DhtRecord) XXX_Marshal 

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

func (*DhtRecord) XXX_Merge 

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

func (*DhtRecord) XXX_Size 

func (m *DhtRecord) XXX_Size() int

func (*DhtRecord) XXX_Unmarshal 

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

type ProtocolId 

type ProtocolId int32
const (
	ProtocolId_PID_DHT 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.