Documentation ¶
Index ¶
- Variables
- type Addr
- func (*Addr) Descriptor() ([]byte, []int)
- func (m *Addr) GetNid() []byte
- func (m *Addr) Marshal() (dAtA []byte, err error)
- func (m *Addr) MarshalTo(dAtA []byte) (int, error)
- func (m *Addr) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Addr) ProtoMessage()
- func (m *Addr) Reset()
- func (m *Addr) Size() (n int)
- func (m *Addr) String() string
- func (m *Addr) Unmarshal(dAtA []byte) error
- func (m *Addr) XXX_DiscardUnknown()
- func (m *Addr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Addr) XXX_Merge(src proto.Message)
- func (m *Addr) XXX_Size() int
- func (m *Addr) XXX_Unmarshal(b []byte) error
- type FindVnodeVO
- func (*FindVnodeVO) Descriptor() ([]byte, []int)
- func (m *FindVnodeVO) GetSelf() *Vnodeinfo
- func (m *FindVnodeVO) GetTarget() *Vnodeinfo
- func (m *FindVnodeVO) Marshal() (dAtA []byte, err error)
- func (m *FindVnodeVO) MarshalTo(dAtA []byte) (int, error)
- func (m *FindVnodeVO) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FindVnodeVO) ProtoMessage()
- func (m *FindVnodeVO) Reset()
- func (m *FindVnodeVO) Size() (n int)
- func (m *FindVnodeVO) String() string
- func (m *FindVnodeVO) Unmarshal(dAtA []byte) error
- func (m *FindVnodeVO) XXX_DiscardUnknown()
- func (m *FindVnodeVO) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FindVnodeVO) XXX_Merge(src proto.Message)
- func (m *FindVnodeVO) XXX_Size() int
- func (m *FindVnodeVO) XXX_Unmarshal(b []byte) error
- type IdInfo
- func (*IdInfo) Descriptor() ([]byte, []int)
- func (m *IdInfo) GetCPuk() []byte
- func (m *IdInfo) GetEPuk() []byte
- func (m *IdInfo) GetId() []byte
- func (m *IdInfo) GetSign() []byte
- func (m *IdInfo) GetV() uint32
- func (m *IdInfo) Marshal() (dAtA []byte, err error)
- func (m *IdInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *IdInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdInfo) ProtoMessage()
- func (m *IdInfo) Reset()
- func (m *IdInfo) Size() (n int)
- func (m *IdInfo) String() string
- func (m *IdInfo) Unmarshal(dAtA []byte) error
- func (m *IdInfo) XXX_DiscardUnknown()
- func (m *IdInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdInfo) XXX_Merge(src proto.Message)
- func (m *IdInfo) XXX_Size() int
- func (m *IdInfo) XXX_Unmarshal(b []byte) error
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetBody() *MessageBody
- func (m *Message) GetDataPlus() []byte
- func (m *Message) GetHead() *MessageHead
- func (m *Message) Marshal() (dAtA []byte, err error)
- func (m *Message) MarshalTo(dAtA []byte) (int, error)
- func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) error
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type MessageBody
- func (*MessageBody) Descriptor() ([]byte, []int)
- func (m *MessageBody) GetContent() []byte
- func (m *MessageBody) GetCreateTime() uint64
- func (m *MessageBody) GetHash() []byte
- func (m *MessageBody) GetMessageId() uint64
- func (m *MessageBody) GetRecvRand() uint64
- func (m *MessageBody) GetReplyHash() []byte
- func (m *MessageBody) GetReplyTime() uint64
- func (m *MessageBody) GetSendRand() uint64
- func (m *MessageBody) Marshal() (dAtA []byte, err error)
- func (m *MessageBody) MarshalTo(dAtA []byte) (int, error)
- func (m *MessageBody) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessageBody) ProtoMessage()
- func (m *MessageBody) Reset()
- func (m *MessageBody) Size() (n int)
- func (m *MessageBody) String() string
- func (m *MessageBody) Unmarshal(dAtA []byte) error
- func (m *MessageBody) XXX_DiscardUnknown()
- func (m *MessageBody) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageBody) XXX_Merge(src proto.Message)
- func (m *MessageBody) XXX_Size() int
- func (m *MessageBody) XXX_Unmarshal(b []byte) error
- type MessageHead
- func (*MessageHead) Descriptor() ([]byte, []int)
- func (m *MessageHead) GetAccurate() bool
- func (m *MessageHead) GetOneByOne() bool
- func (m *MessageHead) GetRecvId() []byte
- func (m *MessageHead) GetRecvMachineID() string
- func (m *MessageHead) GetRecvProxyId() []byte
- func (m *MessageHead) GetRecvSuperId() []byte
- func (m *MessageHead) GetRecvVnode() []byte
- func (m *MessageHead) GetSearchVnodeEndId() []byte
- func (m *MessageHead) GetSender() []byte
- func (m *MessageHead) GetSenderMachineID() string
- func (m *MessageHead) GetSenderProxyId() []byte
- func (m *MessageHead) GetSenderSuperId() []byte
- func (m *MessageHead) GetSenderVnode() []byte
- func (m *MessageHead) Marshal() (dAtA []byte, err error)
- func (m *MessageHead) MarshalTo(dAtA []byte) (int, error)
- func (m *MessageHead) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessageHead) ProtoMessage()
- func (m *MessageHead) Reset()
- func (m *MessageHead) Size() (n int)
- func (m *MessageHead) String() string
- func (m *MessageHead) Unmarshal(dAtA []byte) error
- func (m *MessageHead) XXX_DiscardUnknown()
- func (m *MessageHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageHead) XXX_Merge(src proto.Message)
- func (m *MessageHead) XXX_Size() int
- func (m *MessageHead) XXX_Unmarshal(b []byte) error
- type MessageMulticast
- func (*MessageMulticast) Descriptor() ([]byte, []int)
- func (m *MessageMulticast) GetBody() []byte
- func (m *MessageMulticast) GetHead() []byte
- func (m *MessageMulticast) Marshal() (dAtA []byte, err error)
- func (m *MessageMulticast) MarshalTo(dAtA []byte) (int, error)
- func (m *MessageMulticast) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MessageMulticast) ProtoMessage()
- func (m *MessageMulticast) Reset()
- func (m *MessageMulticast) Size() (n int)
- func (m *MessageMulticast) String() string
- func (m *MessageMulticast) Unmarshal(dAtA []byte) error
- func (m *MessageMulticast) XXX_DiscardUnknown()
- func (m *MessageMulticast) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageMulticast) XXX_Merge(src proto.Message)
- func (m *MessageMulticast) XXX_Size() int
- func (m *MessageMulticast) XXX_Unmarshal(b []byte) error
- type MulticastMsg
- func (*MulticastMsg) Descriptor() ([]byte, []int)
- func (m *MulticastMsg) GetContent() string
- func (m *MulticastMsg) GetMsgID() uint64
- func (m *MulticastMsg) GetNodes() []*NodeInfo
- func (m *MulticastMsg) Marshal() (dAtA []byte, err error)
- func (m *MulticastMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *MulticastMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MulticastMsg) ProtoMessage()
- func (m *MulticastMsg) Reset()
- func (m *MulticastMsg) Size() (n int)
- func (m *MulticastMsg) String() string
- func (m *MulticastMsg) Unmarshal(dAtA []byte) error
- func (m *MulticastMsg) XXX_DiscardUnknown()
- func (m *MulticastMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MulticastMsg) XXX_Merge(src proto.Message)
- func (m *MulticastMsg) XXX_Size() int
- func (m *MulticastMsg) XXX_Unmarshal(b []byte) error
- type Node
- func (*Node) Descriptor() ([]byte, []int)
- func (m *Node) GetAddr() string
- func (m *Node) GetIdInfo() *IdInfo
- func (m *Node) GetIsApp() bool
- func (m *Node) GetIsSuper() bool
- func (m *Node) GetMachineID() int64
- func (m *Node) GetMachineIDStr() string
- func (m *Node) GetQuicPort() uint32
- func (m *Node) GetSetGod() bool
- func (m *Node) GetSetGodTime() int64
- func (m *Node) GetTcpPort() uint32
- func (m *Node) GetVersion() uint64
- func (m *Node) Marshal() (dAtA []byte, err error)
- func (m *Node) MarshalTo(dAtA []byte) (int, error)
- func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Node) ProtoMessage()
- func (m *Node) Reset()
- func (m *Node) Size() (n int)
- func (m *Node) String() string
- func (m *Node) Unmarshal(dAtA []byte) error
- func (m *Node) XXX_DiscardUnknown()
- func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Node) XXX_Merge(src proto.Message)
- func (m *Node) XXX_Size() int
- func (m *Node) XXX_Unmarshal(b []byte) error
- type NodeAddrRepeated
- func (*NodeAddrRepeated) Descriptor() ([]byte, []int)
- func (m *NodeAddrRepeated) GetNodes() []*Addr
- func (m *NodeAddrRepeated) Marshal() (dAtA []byte, err error)
- func (m *NodeAddrRepeated) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeAddrRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeAddrRepeated) ProtoMessage()
- func (m *NodeAddrRepeated) Reset()
- func (m *NodeAddrRepeated) Size() (n int)
- func (m *NodeAddrRepeated) String() string
- func (m *NodeAddrRepeated) Unmarshal(dAtA []byte) error
- func (m *NodeAddrRepeated) XXX_DiscardUnknown()
- func (m *NodeAddrRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeAddrRepeated) XXX_Merge(src proto.Message)
- func (m *NodeAddrRepeated) XXX_Size() int
- func (m *NodeAddrRepeated) XXX_Unmarshal(b []byte) error
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)
- func (m *NodeInfo) GetId() []byte
- func (m *NodeInfo) GetMachineID() string
- func (m *NodeInfo) Marshal() (dAtA []byte, err error)
- func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeInfo) ProtoMessage()
- func (m *NodeInfo) Reset()
- func (m *NodeInfo) Size() (n int)
- func (m *NodeInfo) String() string
- func (m *NodeInfo) Unmarshal(dAtA []byte) error
- func (m *NodeInfo) XXX_DiscardUnknown()
- func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeInfo) XXX_Merge(src proto.Message)
- func (m *NodeInfo) XXX_Size() int
- func (m *NodeInfo) XXX_Unmarshal(b []byte) error
- type NodeRepeated
- func (*NodeRepeated) Descriptor() ([]byte, []int)
- func (m *NodeRepeated) GetNodes() []*Node
- func (m *NodeRepeated) Marshal() (dAtA []byte, err error)
- func (m *NodeRepeated) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeRepeated) ProtoMessage()
- func (m *NodeRepeated) Reset()
- func (m *NodeRepeated) Size() (n int)
- func (m *NodeRepeated) String() string
- func (m *NodeRepeated) Unmarshal(dAtA []byte) error
- func (m *NodeRepeated) XXX_DiscardUnknown()
- func (m *NodeRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeRepeated) XXX_Merge(src proto.Message)
- func (m *NodeRepeated) XXX_Size() int
- func (m *NodeRepeated) XXX_Unmarshal(b []byte) error
- type ProxyInfo
- func (*ProxyInfo) Descriptor() ([]byte, []int)
- func (m *ProxyInfo) GetId() []byte
- func (m *ProxyInfo) GetMachineID() string
- func (m *ProxyInfo) GetProxyId() []byte
- func (m *ProxyInfo) GetVersion() int64
- func (m *ProxyInfo) Marshal() (dAtA []byte, err error)
- func (m *ProxyInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *ProxyInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProxyInfo) ProtoMessage()
- func (m *ProxyInfo) Reset()
- func (m *ProxyInfo) Size() (n int)
- func (m *ProxyInfo) String() string
- func (m *ProxyInfo) Unmarshal(dAtA []byte) error
- func (m *ProxyInfo) XXX_DiscardUnknown()
- func (m *ProxyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyInfo) XXX_Merge(src proto.Message)
- func (m *ProxyInfo) XXX_Size() int
- func (m *ProxyInfo) XXX_Unmarshal(b []byte) error
- type ProxyRepeated
- func (*ProxyRepeated) Descriptor() ([]byte, []int)
- func (m *ProxyRepeated) GetProxys() []*ProxyInfo
- func (m *ProxyRepeated) Marshal() (dAtA []byte, err error)
- func (m *ProxyRepeated) MarshalTo(dAtA []byte) (int, error)
- func (m *ProxyRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProxyRepeated) ProtoMessage()
- func (m *ProxyRepeated) Reset()
- func (m *ProxyRepeated) Size() (n int)
- func (m *ProxyRepeated) String() string
- func (m *ProxyRepeated) Unmarshal(dAtA []byte) error
- func (m *ProxyRepeated) XXX_DiscardUnknown()
- func (m *ProxyRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyRepeated) XXX_Merge(src proto.Message)
- func (m *ProxyRepeated) XXX_Size() int
- func (m *ProxyRepeated) XXX_Unmarshal(b []byte) error
- type SearchNodeInfo
- func (*SearchNodeInfo) Descriptor() ([]byte, []int)
- func (m *SearchNodeInfo) GetCPuk() []byte
- func (m *SearchNodeInfo) GetId() []byte
- func (m *SearchNodeInfo) GetSuperId() []byte
- func (m *SearchNodeInfo) Marshal() (dAtA []byte, err error)
- func (m *SearchNodeInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *SearchNodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SearchNodeInfo) ProtoMessage()
- func (m *SearchNodeInfo) Reset()
- func (m *SearchNodeInfo) Size() (n int)
- func (m *SearchNodeInfo) String() string
- func (m *SearchNodeInfo) Unmarshal(dAtA []byte) error
- func (m *SearchNodeInfo) XXX_DiscardUnknown()
- func (m *SearchNodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchNodeInfo) XXX_Merge(src proto.Message)
- func (m *SearchNodeInfo) XXX_Size() int
- func (m *SearchNodeInfo) XXX_Unmarshal(b []byte) error
- type ShareKey
- func (*ShareKey) Descriptor() ([]byte, []int)
- func (m *ShareKey) GetA_DH_PUK() []byte
- func (m *ShareKey) GetB_DH_PUK() []byte
- func (m *ShareKey) GetIdinfo() *IdInfo
- func (m *ShareKey) Marshal() (dAtA []byte, err error)
- func (m *ShareKey) MarshalTo(dAtA []byte) (int, error)
- func (m *ShareKey) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShareKey) ProtoMessage()
- func (m *ShareKey) Reset()
- func (m *ShareKey) Size() (n int)
- func (m *ShareKey) String() string
- func (m *ShareKey) Unmarshal(dAtA []byte) error
- func (m *ShareKey) XXX_DiscardUnknown()
- func (m *ShareKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShareKey) XXX_Merge(src proto.Message)
- func (m *ShareKey) XXX_Size() int
- func (m *ShareKey) XXX_Unmarshal(b []byte) error
- type Vnodeinfo
- func (*Vnodeinfo) Descriptor() ([]byte, []int)
- func (m *Vnodeinfo) GetIndex() uint64
- func (m *Vnodeinfo) GetNid() []byte
- func (m *Vnodeinfo) GetVid() []byte
- func (m *Vnodeinfo) Marshal() (dAtA []byte, err error)
- func (m *Vnodeinfo) MarshalTo(dAtA []byte) (int, error)
- func (m *Vnodeinfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Vnodeinfo) ProtoMessage()
- func (m *Vnodeinfo) Reset()
- func (m *Vnodeinfo) Size() (n int)
- func (m *Vnodeinfo) String() string
- func (m *Vnodeinfo) Unmarshal(dAtA []byte) error
- func (m *Vnodeinfo) XXX_DiscardUnknown()
- func (m *Vnodeinfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Vnodeinfo) XXX_Merge(src proto.Message)
- func (m *Vnodeinfo) XXX_Size() int
- func (m *Vnodeinfo) XXX_Unmarshal(b []byte) error
- type VnodeinfoRepeated
- func (*VnodeinfoRepeated) Descriptor() ([]byte, []int)
- func (m *VnodeinfoRepeated) GetVnodes() []*Vnodeinfo
- func (m *VnodeinfoRepeated) Marshal() (dAtA []byte, err error)
- func (m *VnodeinfoRepeated) MarshalTo(dAtA []byte) (int, error)
- func (m *VnodeinfoRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VnodeinfoRepeated) ProtoMessage()
- func (m *VnodeinfoRepeated) Reset()
- func (m *VnodeinfoRepeated) Size() (n int)
- func (m *VnodeinfoRepeated) String() string
- func (m *VnodeinfoRepeated) Unmarshal(dAtA []byte) error
- func (m *VnodeinfoRepeated) XXX_DiscardUnknown()
- func (m *VnodeinfoRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VnodeinfoRepeated) XXX_Merge(src proto.Message)
- func (m *VnodeinfoRepeated) XXX_Size() int
- func (m *VnodeinfoRepeated) XXX_Unmarshal(b []byte) error
- type VnodeinfoS
- func (*VnodeinfoS) Descriptor() ([]byte, []int)
- func (m *VnodeinfoS) GetAddr() string
- func (m *VnodeinfoS) GetIndex() uint64
- func (m *VnodeinfoS) GetNid() []byte
- func (m *VnodeinfoS) GetQuicPort() uint64
- func (m *VnodeinfoS) GetTcpPort() uint64
- func (m *VnodeinfoS) GetVid() []byte
- func (m *VnodeinfoS) Marshal() (dAtA []byte, err error)
- func (m *VnodeinfoS) MarshalTo(dAtA []byte) (int, error)
- func (m *VnodeinfoS) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VnodeinfoS) ProtoMessage()
- func (m *VnodeinfoS) Reset()
- func (m *VnodeinfoS) Size() (n int)
- func (m *VnodeinfoS) String() string
- func (m *VnodeinfoS) Unmarshal(dAtA []byte) error
- func (m *VnodeinfoS) XXX_DiscardUnknown()
- func (m *VnodeinfoS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VnodeinfoS) XXX_Merge(src proto.Message)
- func (m *VnodeinfoS) XXX_Size() int
- func (m *VnodeinfoS) XXX_Unmarshal(b []byte) error
- type VnodeinfoSRepeated
- func (*VnodeinfoSRepeated) Descriptor() ([]byte, []int)
- func (m *VnodeinfoSRepeated) GetVnodes() []*VnodeinfoS
- func (m *VnodeinfoSRepeated) Marshal() (dAtA []byte, err error)
- func (m *VnodeinfoSRepeated) MarshalTo(dAtA []byte) (int, error)
- func (m *VnodeinfoSRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VnodeinfoSRepeated) ProtoMessage()
- func (m *VnodeinfoSRepeated) Reset()
- func (m *VnodeinfoSRepeated) Size() (n int)
- func (m *VnodeinfoSRepeated) String() string
- func (m *VnodeinfoSRepeated) Unmarshal(dAtA []byte) error
- func (m *VnodeinfoSRepeated) XXX_DiscardUnknown()
- func (m *VnodeinfoSRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VnodeinfoSRepeated) XXX_Merge(src proto.Message)
- func (m *VnodeinfoSRepeated) XXX_Size() int
- func (m *VnodeinfoSRepeated) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthMessageMulticast = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMessageMulticast = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMessageMulticast = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthMulticastmsg = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMulticastmsg = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMulticastmsg = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthNode = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNode = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupNode = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthProxyinfo = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowProxyinfo = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupProxyinfo = fmt.Errorf("proto: unexpected end of group") )
Functions ¶
This section is empty.
Types ¶
type Addr ¶
type Addr struct { Nid []byte `protobuf:"bytes,1,opt,name=Nid,proto3" json:"Nid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Addr) Descriptor ¶
func (*Addr) ProtoMessage ¶
func (*Addr) ProtoMessage()
func (*Addr) XXX_DiscardUnknown ¶
func (m *Addr) XXX_DiscardUnknown()
func (*Addr) XXX_Unmarshal ¶
type FindVnodeVO ¶
type FindVnodeVO struct { Self *Vnodeinfo `protobuf:"bytes,1,opt,name=Self,proto3" json:"Self,omitempty"` Target *Vnodeinfo `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FindVnodeVO) Descriptor ¶
func (*FindVnodeVO) Descriptor() ([]byte, []int)
func (*FindVnodeVO) GetSelf ¶
func (m *FindVnodeVO) GetSelf() *Vnodeinfo
func (*FindVnodeVO) GetTarget ¶
func (m *FindVnodeVO) GetTarget() *Vnodeinfo
func (*FindVnodeVO) Marshal ¶
func (m *FindVnodeVO) Marshal() (dAtA []byte, err error)
func (*FindVnodeVO) MarshalToSizedBuffer ¶
func (m *FindVnodeVO) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FindVnodeVO) ProtoMessage ¶
func (*FindVnodeVO) ProtoMessage()
func (*FindVnodeVO) Reset ¶
func (m *FindVnodeVO) Reset()
func (*FindVnodeVO) Size ¶
func (m *FindVnodeVO) Size() (n int)
func (*FindVnodeVO) String ¶
func (m *FindVnodeVO) String() string
func (*FindVnodeVO) Unmarshal ¶
func (m *FindVnodeVO) Unmarshal(dAtA []byte) error
func (*FindVnodeVO) XXX_DiscardUnknown ¶
func (m *FindVnodeVO) XXX_DiscardUnknown()
func (*FindVnodeVO) XXX_Marshal ¶
func (m *FindVnodeVO) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FindVnodeVO) XXX_Merge ¶
func (m *FindVnodeVO) XXX_Merge(src proto.Message)
func (*FindVnodeVO) XXX_Size ¶
func (m *FindVnodeVO) XXX_Size() int
func (*FindVnodeVO) XXX_Unmarshal ¶
func (m *FindVnodeVO) XXX_Unmarshal(b []byte) error
type IdInfo ¶
type IdInfo struct { Id []byte `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` EPuk []byte `protobuf:"bytes,2,opt,name=EPuk,proto3" json:"EPuk,omitempty"` CPuk []byte `protobuf:"bytes,3,opt,name=CPuk,proto3" json:"CPuk,omitempty"` V uint32 `protobuf:"varint,4,opt,name=V,proto3" json:"V,omitempty"` Sign []byte `protobuf:"bytes,5,opt,name=Sign,proto3" json:"Sign,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IdInfo) Descriptor ¶
func (*IdInfo) MarshalToSizedBuffer ¶
func (*IdInfo) ProtoMessage ¶
func (*IdInfo) ProtoMessage()
func (*IdInfo) XXX_DiscardUnknown ¶
func (m *IdInfo) XXX_DiscardUnknown()
func (*IdInfo) XXX_Marshal ¶
func (*IdInfo) XXX_Unmarshal ¶
type Message ¶
type Message struct { Head *MessageHead `protobuf:"bytes,1,opt,name=Head,proto3" json:"Head,omitempty"` Body *MessageBody `protobuf:"bytes,2,opt,name=Body,proto3" json:"Body,omitempty"` DataPlus []byte `protobuf:"bytes,3,opt,name=DataPlus,proto3" json:"DataPlus,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Message) Descriptor ¶
func (*Message) GetBody ¶
func (m *Message) GetBody() *MessageBody
func (*Message) GetDataPlus ¶
func (*Message) GetHead ¶
func (m *Message) GetHead() *MessageHead
func (*Message) MarshalToSizedBuffer ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type MessageBody ¶
type MessageBody struct { MessageId uint64 `protobuf:"varint,1,opt,name=MessageId,proto3" json:"MessageId,omitempty"` CreateTime uint64 `protobuf:"varint,2,opt,name=CreateTime,proto3" json:"CreateTime,omitempty"` ReplyTime uint64 `protobuf:"varint,3,opt,name=ReplyTime,proto3" json:"ReplyTime,omitempty"` Hash []byte `protobuf:"bytes,4,opt,name=Hash,proto3" json:"Hash,omitempty"` ReplyHash []byte `protobuf:"bytes,5,opt,name=ReplyHash,proto3" json:"ReplyHash,omitempty"` SendRand uint64 `protobuf:"varint,6,opt,name=SendRand,proto3" json:"SendRand,omitempty"` RecvRand uint64 `protobuf:"varint,7,opt,name=RecvRand,proto3" json:"RecvRand,omitempty"` Content []byte `protobuf:"bytes,8,opt,name=Content,proto3" json:"Content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MessageBody) Descriptor ¶
func (*MessageBody) Descriptor() ([]byte, []int)
func (*MessageBody) GetContent ¶
func (m *MessageBody) GetContent() []byte
func (*MessageBody) GetCreateTime ¶
func (m *MessageBody) GetCreateTime() uint64
func (*MessageBody) GetHash ¶
func (m *MessageBody) GetHash() []byte
func (*MessageBody) GetMessageId ¶
func (m *MessageBody) GetMessageId() uint64
func (*MessageBody) GetRecvRand ¶
func (m *MessageBody) GetRecvRand() uint64
func (*MessageBody) GetReplyHash ¶
func (m *MessageBody) GetReplyHash() []byte
func (*MessageBody) GetReplyTime ¶
func (m *MessageBody) GetReplyTime() uint64
func (*MessageBody) GetSendRand ¶
func (m *MessageBody) GetSendRand() uint64
func (*MessageBody) Marshal ¶
func (m *MessageBody) Marshal() (dAtA []byte, err error)
func (*MessageBody) MarshalToSizedBuffer ¶
func (m *MessageBody) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessageBody) ProtoMessage ¶
func (*MessageBody) ProtoMessage()
func (*MessageBody) Reset ¶
func (m *MessageBody) Reset()
func (*MessageBody) Size ¶
func (m *MessageBody) Size() (n int)
func (*MessageBody) String ¶
func (m *MessageBody) String() string
func (*MessageBody) Unmarshal ¶
func (m *MessageBody) Unmarshal(dAtA []byte) error
func (*MessageBody) XXX_DiscardUnknown ¶
func (m *MessageBody) XXX_DiscardUnknown()
func (*MessageBody) XXX_Marshal ¶
func (m *MessageBody) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageBody) XXX_Merge ¶
func (m *MessageBody) XXX_Merge(src proto.Message)
func (*MessageBody) XXX_Size ¶
func (m *MessageBody) XXX_Size() int
func (*MessageBody) XXX_Unmarshal ¶
func (m *MessageBody) XXX_Unmarshal(b []byte) error
type MessageHead ¶
type MessageHead struct { RecvId []byte `protobuf:"bytes,1,opt,name=RecvId,proto3" json:"RecvId,omitempty"` RecvSuperId []byte `protobuf:"bytes,2,opt,name=RecvSuperId,proto3" json:"RecvSuperId,omitempty"` RecvVnode []byte `protobuf:"bytes,3,opt,name=RecvVnode,proto3" json:"RecvVnode,omitempty"` Sender []byte `protobuf:"bytes,4,opt,name=Sender,proto3" json:"Sender,omitempty"` SenderSuperId []byte `protobuf:"bytes,5,opt,name=SenderSuperId,proto3" json:"SenderSuperId,omitempty"` SenderVnode []byte `protobuf:"bytes,6,opt,name=SenderVnode,proto3" json:"SenderVnode,omitempty"` Accurate bool `protobuf:"varint,7,opt,name=Accurate,proto3" json:"Accurate,omitempty"` RecvProxyId []byte `protobuf:"bytes,8,opt,name=RecvProxyId,proto3" json:"RecvProxyId,omitempty"` SenderProxyId []byte `protobuf:"bytes,9,opt,name=SenderProxyId,proto3" json:"SenderProxyId,omitempty"` SearchVnodeEndId []byte `protobuf:"bytes,10,opt,name=SearchVnodeEndId,proto3" json:"SearchVnodeEndId,omitempty"` OneByOne bool `protobuf:"varint,11,opt,name=OneByOne,proto3" json:"OneByOne,omitempty"` SenderMachineID string `protobuf:"bytes,12,opt,name=SenderMachineID,proto3" json:"SenderMachineID,omitempty"` RecvMachineID string `protobuf:"bytes,13,opt,name=RecvMachineID,proto3" json:"RecvMachineID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MessageHead) Descriptor ¶
func (*MessageHead) Descriptor() ([]byte, []int)
func (*MessageHead) GetAccurate ¶
func (m *MessageHead) GetAccurate() bool
func (*MessageHead) GetOneByOne ¶
func (m *MessageHead) GetOneByOne() bool
func (*MessageHead) GetRecvId ¶
func (m *MessageHead) GetRecvId() []byte
func (*MessageHead) GetRecvMachineID ¶
func (m *MessageHead) GetRecvMachineID() string
func (*MessageHead) GetRecvProxyId ¶
func (m *MessageHead) GetRecvProxyId() []byte
func (*MessageHead) GetRecvSuperId ¶
func (m *MessageHead) GetRecvSuperId() []byte
func (*MessageHead) GetRecvVnode ¶
func (m *MessageHead) GetRecvVnode() []byte
func (*MessageHead) GetSearchVnodeEndId ¶
func (m *MessageHead) GetSearchVnodeEndId() []byte
func (*MessageHead) GetSender ¶
func (m *MessageHead) GetSender() []byte
func (*MessageHead) GetSenderMachineID ¶
func (m *MessageHead) GetSenderMachineID() string
func (*MessageHead) GetSenderProxyId ¶
func (m *MessageHead) GetSenderProxyId() []byte
func (*MessageHead) GetSenderSuperId ¶
func (m *MessageHead) GetSenderSuperId() []byte
func (*MessageHead) GetSenderVnode ¶
func (m *MessageHead) GetSenderVnode() []byte
func (*MessageHead) Marshal ¶
func (m *MessageHead) Marshal() (dAtA []byte, err error)
func (*MessageHead) MarshalToSizedBuffer ¶
func (m *MessageHead) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessageHead) ProtoMessage ¶
func (*MessageHead) ProtoMessage()
func (*MessageHead) Reset ¶
func (m *MessageHead) Reset()
func (*MessageHead) Size ¶
func (m *MessageHead) Size() (n int)
func (*MessageHead) String ¶
func (m *MessageHead) String() string
func (*MessageHead) Unmarshal ¶
func (m *MessageHead) Unmarshal(dAtA []byte) error
func (*MessageHead) XXX_DiscardUnknown ¶
func (m *MessageHead) XXX_DiscardUnknown()
func (*MessageHead) XXX_Marshal ¶
func (m *MessageHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageHead) XXX_Merge ¶
func (m *MessageHead) XXX_Merge(src proto.Message)
func (*MessageHead) XXX_Size ¶
func (m *MessageHead) XXX_Size() int
func (*MessageHead) XXX_Unmarshal ¶
func (m *MessageHead) XXX_Unmarshal(b []byte) error
type MessageMulticast ¶
type MessageMulticast struct { Head []byte `protobuf:"bytes,1,opt,name=Head,proto3" json:"Head,omitempty"` Body []byte `protobuf:"bytes,2,opt,name=Body,proto3" json:"Body,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MessageMulticast) Descriptor ¶
func (*MessageMulticast) Descriptor() ([]byte, []int)
func (*MessageMulticast) GetBody ¶
func (m *MessageMulticast) GetBody() []byte
func (*MessageMulticast) GetHead ¶
func (m *MessageMulticast) GetHead() []byte
func (*MessageMulticast) Marshal ¶
func (m *MessageMulticast) Marshal() (dAtA []byte, err error)
func (*MessageMulticast) MarshalToSizedBuffer ¶
func (m *MessageMulticast) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MessageMulticast) ProtoMessage ¶
func (*MessageMulticast) ProtoMessage()
func (*MessageMulticast) Reset ¶
func (m *MessageMulticast) Reset()
func (*MessageMulticast) Size ¶
func (m *MessageMulticast) Size() (n int)
func (*MessageMulticast) String ¶
func (m *MessageMulticast) String() string
func (*MessageMulticast) Unmarshal ¶
func (m *MessageMulticast) Unmarshal(dAtA []byte) error
func (*MessageMulticast) XXX_DiscardUnknown ¶
func (m *MessageMulticast) XXX_DiscardUnknown()
func (*MessageMulticast) XXX_Marshal ¶
func (m *MessageMulticast) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageMulticast) XXX_Merge ¶
func (m *MessageMulticast) XXX_Merge(src proto.Message)
func (*MessageMulticast) XXX_Size ¶
func (m *MessageMulticast) XXX_Size() int
func (*MessageMulticast) XXX_Unmarshal ¶
func (m *MessageMulticast) XXX_Unmarshal(b []byte) error
type MulticastMsg ¶
type MulticastMsg struct { Nodes []*NodeInfo `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` MsgID uint64 `protobuf:"varint,2,opt,name=MsgID,proto3" json:"MsgID,omitempty"` Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MulticastMsg) Descriptor ¶
func (*MulticastMsg) Descriptor() ([]byte, []int)
func (*MulticastMsg) GetContent ¶
func (m *MulticastMsg) GetContent() string
func (*MulticastMsg) GetMsgID ¶
func (m *MulticastMsg) GetMsgID() uint64
func (*MulticastMsg) GetNodes ¶
func (m *MulticastMsg) GetNodes() []*NodeInfo
func (*MulticastMsg) Marshal ¶
func (m *MulticastMsg) Marshal() (dAtA []byte, err error)
func (*MulticastMsg) MarshalToSizedBuffer ¶
func (m *MulticastMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MulticastMsg) ProtoMessage ¶
func (*MulticastMsg) ProtoMessage()
func (*MulticastMsg) Reset ¶
func (m *MulticastMsg) Reset()
func (*MulticastMsg) Size ¶
func (m *MulticastMsg) Size() (n int)
func (*MulticastMsg) String ¶
func (m *MulticastMsg) String() string
func (*MulticastMsg) Unmarshal ¶
func (m *MulticastMsg) Unmarshal(dAtA []byte) error
func (*MulticastMsg) XXX_DiscardUnknown ¶
func (m *MulticastMsg) XXX_DiscardUnknown()
func (*MulticastMsg) XXX_Marshal ¶
func (m *MulticastMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MulticastMsg) XXX_Merge ¶
func (m *MulticastMsg) XXX_Merge(src proto.Message)
func (*MulticastMsg) XXX_Size ¶
func (m *MulticastMsg) XXX_Size() int
func (*MulticastMsg) XXX_Unmarshal ¶
func (m *MulticastMsg) XXX_Unmarshal(b []byte) error
type Node ¶
type Node struct { IdInfo *IdInfo `protobuf:"bytes,1,opt,name=IdInfo,proto3" json:"IdInfo,omitempty"` IsSuper bool `protobuf:"varint,2,opt,name=IsSuper,proto3" json:"IsSuper,omitempty"` Addr string `protobuf:"bytes,3,opt,name=Addr,proto3" json:"Addr,omitempty"` TcpPort uint32 `protobuf:"varint,4,opt,name=TcpPort,proto3" json:"TcpPort,omitempty"` IsApp bool `protobuf:"varint,5,opt,name=IsApp,proto3" json:"IsApp,omitempty"` MachineID int64 `protobuf:"varint,6,opt,name=MachineID,proto3" json:"MachineID,omitempty"` Version uint64 `protobuf:"varint,7,opt,name=Version,proto3" json:"Version,omitempty"` SetGod bool `protobuf:"varint,8,opt,name=SetGod,proto3" json:"SetGod,omitempty"` MachineIDStr string `protobuf:"bytes,9,opt,name=MachineIDStr,proto3" json:"MachineIDStr,omitempty"` SetGodTime int64 `protobuf:"varint,10,opt,name=SetGodTime,proto3" json:"SetGodTime,omitempty"` QuicPort uint32 `protobuf:"varint,11,opt,name=QuicPort,proto3" json:"QuicPort,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Node) Descriptor ¶
func (*Node) GetIsSuper ¶
func (*Node) GetMachineID ¶
func (*Node) GetMachineIDStr ¶
func (*Node) GetQuicPort ¶
func (*Node) GetSetGodTime ¶
func (*Node) GetTcpPort ¶
func (*Node) GetVersion ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) XXX_DiscardUnknown ¶
func (m *Node) XXX_DiscardUnknown()
func (*Node) XXX_Unmarshal ¶
type NodeAddrRepeated ¶
type NodeAddrRepeated struct { Nodes []*Addr `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeAddrRepeated) Descriptor ¶
func (*NodeAddrRepeated) Descriptor() ([]byte, []int)
func (*NodeAddrRepeated) GetNodes ¶
func (m *NodeAddrRepeated) GetNodes() []*Addr
func (*NodeAddrRepeated) Marshal ¶
func (m *NodeAddrRepeated) Marshal() (dAtA []byte, err error)
func (*NodeAddrRepeated) MarshalToSizedBuffer ¶
func (m *NodeAddrRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodeAddrRepeated) ProtoMessage ¶
func (*NodeAddrRepeated) ProtoMessage()
func (*NodeAddrRepeated) Reset ¶
func (m *NodeAddrRepeated) Reset()
func (*NodeAddrRepeated) Size ¶
func (m *NodeAddrRepeated) Size() (n int)
func (*NodeAddrRepeated) String ¶
func (m *NodeAddrRepeated) String() string
func (*NodeAddrRepeated) Unmarshal ¶
func (m *NodeAddrRepeated) Unmarshal(dAtA []byte) error
func (*NodeAddrRepeated) XXX_DiscardUnknown ¶
func (m *NodeAddrRepeated) XXX_DiscardUnknown()
func (*NodeAddrRepeated) XXX_Marshal ¶
func (m *NodeAddrRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeAddrRepeated) XXX_Merge ¶
func (m *NodeAddrRepeated) XXX_Merge(src proto.Message)
func (*NodeAddrRepeated) XXX_Size ¶
func (m *NodeAddrRepeated) XXX_Size() int
func (*NodeAddrRepeated) XXX_Unmarshal ¶
func (m *NodeAddrRepeated) XXX_Unmarshal(b []byte) error
type NodeInfo ¶
type NodeInfo struct { Id []byte `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` MachineID string `protobuf:"bytes,2,opt,name=MachineID,proto3" json:"MachineID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeInfo) Descriptor ¶
func (*NodeInfo) GetMachineID ¶
func (*NodeInfo) MarshalToSizedBuffer ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) XXX_DiscardUnknown ¶
func (m *NodeInfo) XXX_DiscardUnknown()
func (*NodeInfo) XXX_Marshal ¶
func (*NodeInfo) XXX_Unmarshal ¶
type NodeRepeated ¶
type NodeRepeated struct { Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeRepeated) Descriptor ¶
func (*NodeRepeated) Descriptor() ([]byte, []int)
func (*NodeRepeated) GetNodes ¶
func (m *NodeRepeated) GetNodes() []*Node
func (*NodeRepeated) Marshal ¶
func (m *NodeRepeated) Marshal() (dAtA []byte, err error)
func (*NodeRepeated) MarshalToSizedBuffer ¶
func (m *NodeRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodeRepeated) ProtoMessage ¶
func (*NodeRepeated) ProtoMessage()
func (*NodeRepeated) Reset ¶
func (m *NodeRepeated) Reset()
func (*NodeRepeated) Size ¶
func (m *NodeRepeated) Size() (n int)
func (*NodeRepeated) String ¶
func (m *NodeRepeated) String() string
func (*NodeRepeated) Unmarshal ¶
func (m *NodeRepeated) Unmarshal(dAtA []byte) error
func (*NodeRepeated) XXX_DiscardUnknown ¶
func (m *NodeRepeated) XXX_DiscardUnknown()
func (*NodeRepeated) XXX_Marshal ¶
func (m *NodeRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeRepeated) XXX_Merge ¶
func (m *NodeRepeated) XXX_Merge(src proto.Message)
func (*NodeRepeated) XXX_Size ¶
func (m *NodeRepeated) XXX_Size() int
func (*NodeRepeated) XXX_Unmarshal ¶
func (m *NodeRepeated) XXX_Unmarshal(b []byte) error
type ProxyInfo ¶
type ProxyInfo struct { Id []byte `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` ProxyId []byte `protobuf:"bytes,2,opt,name=ProxyId,proto3" json:"ProxyId,omitempty"` MachineID string `protobuf:"bytes,3,opt,name=MachineID,proto3" json:"MachineID,omitempty"` Version int64 `protobuf:"varint,4,opt,name=Version,proto3" json:"Version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyInfo) Descriptor ¶
func (*ProxyInfo) GetMachineID ¶
func (*ProxyInfo) GetProxyId ¶
func (*ProxyInfo) GetVersion ¶
func (*ProxyInfo) MarshalToSizedBuffer ¶
func (*ProxyInfo) ProtoMessage ¶
func (*ProxyInfo) ProtoMessage()
func (*ProxyInfo) XXX_DiscardUnknown ¶
func (m *ProxyInfo) XXX_DiscardUnknown()
func (*ProxyInfo) XXX_Marshal ¶
func (*ProxyInfo) XXX_Unmarshal ¶
type ProxyRepeated ¶
type ProxyRepeated struct { Proxys []*ProxyInfo `protobuf:"bytes,1,rep,name=proxys,proto3" json:"proxys,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyRepeated) Descriptor ¶
func (*ProxyRepeated) Descriptor() ([]byte, []int)
func (*ProxyRepeated) GetProxys ¶
func (m *ProxyRepeated) GetProxys() []*ProxyInfo
func (*ProxyRepeated) Marshal ¶
func (m *ProxyRepeated) Marshal() (dAtA []byte, err error)
func (*ProxyRepeated) MarshalToSizedBuffer ¶
func (m *ProxyRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProxyRepeated) ProtoMessage ¶
func (*ProxyRepeated) ProtoMessage()
func (*ProxyRepeated) Reset ¶
func (m *ProxyRepeated) Reset()
func (*ProxyRepeated) Size ¶
func (m *ProxyRepeated) Size() (n int)
func (*ProxyRepeated) String ¶
func (m *ProxyRepeated) String() string
func (*ProxyRepeated) Unmarshal ¶
func (m *ProxyRepeated) Unmarshal(dAtA []byte) error
func (*ProxyRepeated) XXX_DiscardUnknown ¶
func (m *ProxyRepeated) XXX_DiscardUnknown()
func (*ProxyRepeated) XXX_Marshal ¶
func (m *ProxyRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyRepeated) XXX_Merge ¶
func (m *ProxyRepeated) XXX_Merge(src proto.Message)
func (*ProxyRepeated) XXX_Size ¶
func (m *ProxyRepeated) XXX_Size() int
func (*ProxyRepeated) XXX_Unmarshal ¶
func (m *ProxyRepeated) XXX_Unmarshal(b []byte) error
type SearchNodeInfo ¶
type SearchNodeInfo struct { Id []byte `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` SuperId []byte `protobuf:"bytes,2,opt,name=SuperId,proto3" json:"SuperId,omitempty"` CPuk []byte `protobuf:"bytes,3,opt,name=CPuk,proto3" json:"CPuk,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SearchNodeInfo) Descriptor ¶
func (*SearchNodeInfo) Descriptor() ([]byte, []int)
func (*SearchNodeInfo) GetCPuk ¶
func (m *SearchNodeInfo) GetCPuk() []byte
func (*SearchNodeInfo) GetId ¶
func (m *SearchNodeInfo) GetId() []byte
func (*SearchNodeInfo) GetSuperId ¶
func (m *SearchNodeInfo) GetSuperId() []byte
func (*SearchNodeInfo) Marshal ¶
func (m *SearchNodeInfo) Marshal() (dAtA []byte, err error)
func (*SearchNodeInfo) MarshalToSizedBuffer ¶
func (m *SearchNodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SearchNodeInfo) ProtoMessage ¶
func (*SearchNodeInfo) ProtoMessage()
func (*SearchNodeInfo) Reset ¶
func (m *SearchNodeInfo) Reset()
func (*SearchNodeInfo) Size ¶
func (m *SearchNodeInfo) Size() (n int)
func (*SearchNodeInfo) String ¶
func (m *SearchNodeInfo) String() string
func (*SearchNodeInfo) Unmarshal ¶
func (m *SearchNodeInfo) Unmarshal(dAtA []byte) error
func (*SearchNodeInfo) XXX_DiscardUnknown ¶
func (m *SearchNodeInfo) XXX_DiscardUnknown()
func (*SearchNodeInfo) XXX_Marshal ¶
func (m *SearchNodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchNodeInfo) XXX_Merge ¶
func (m *SearchNodeInfo) XXX_Merge(src proto.Message)
func (*SearchNodeInfo) XXX_Size ¶
func (m *SearchNodeInfo) XXX_Size() int
func (*SearchNodeInfo) XXX_Unmarshal ¶
func (m *SearchNodeInfo) XXX_Unmarshal(b []byte) error
type ShareKey ¶
type ShareKey struct {}
func (*ShareKey) Descriptor ¶
func (*ShareKey) GetA_DH_PUK ¶
func (*ShareKey) GetB_DH_PUK ¶
func (*ShareKey) MarshalToSizedBuffer ¶
func (*ShareKey) ProtoMessage ¶
func (*ShareKey) ProtoMessage()
func (*ShareKey) XXX_DiscardUnknown ¶
func (m *ShareKey) XXX_DiscardUnknown()
func (*ShareKey) XXX_Marshal ¶
func (*ShareKey) XXX_Unmarshal ¶
type Vnodeinfo ¶
type Vnodeinfo struct { Nid []byte `protobuf:"bytes,1,opt,name=Nid,proto3" json:"Nid,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"` Vid []byte `protobuf:"bytes,3,opt,name=Vid,proto3" json:"Vid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Vnodeinfo) Descriptor ¶
func (*Vnodeinfo) MarshalToSizedBuffer ¶
func (*Vnodeinfo) ProtoMessage ¶
func (*Vnodeinfo) ProtoMessage()
func (*Vnodeinfo) XXX_DiscardUnknown ¶
func (m *Vnodeinfo) XXX_DiscardUnknown()
func (*Vnodeinfo) XXX_Marshal ¶
func (*Vnodeinfo) XXX_Unmarshal ¶
type VnodeinfoRepeated ¶
type VnodeinfoRepeated struct { Vnodes []*Vnodeinfo `protobuf:"bytes,1,rep,name=vnodes,proto3" json:"vnodes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VnodeinfoRepeated) Descriptor ¶
func (*VnodeinfoRepeated) Descriptor() ([]byte, []int)
func (*VnodeinfoRepeated) GetVnodes ¶
func (m *VnodeinfoRepeated) GetVnodes() []*Vnodeinfo
func (*VnodeinfoRepeated) Marshal ¶
func (m *VnodeinfoRepeated) Marshal() (dAtA []byte, err error)
func (*VnodeinfoRepeated) MarshalTo ¶
func (m *VnodeinfoRepeated) MarshalTo(dAtA []byte) (int, error)
func (*VnodeinfoRepeated) MarshalToSizedBuffer ¶
func (m *VnodeinfoRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VnodeinfoRepeated) ProtoMessage ¶
func (*VnodeinfoRepeated) ProtoMessage()
func (*VnodeinfoRepeated) Reset ¶
func (m *VnodeinfoRepeated) Reset()
func (*VnodeinfoRepeated) Size ¶
func (m *VnodeinfoRepeated) Size() (n int)
func (*VnodeinfoRepeated) String ¶
func (m *VnodeinfoRepeated) String() string
func (*VnodeinfoRepeated) Unmarshal ¶
func (m *VnodeinfoRepeated) Unmarshal(dAtA []byte) error
func (*VnodeinfoRepeated) XXX_DiscardUnknown ¶
func (m *VnodeinfoRepeated) XXX_DiscardUnknown()
func (*VnodeinfoRepeated) XXX_Marshal ¶
func (m *VnodeinfoRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VnodeinfoRepeated) XXX_Merge ¶
func (m *VnodeinfoRepeated) XXX_Merge(src proto.Message)
func (*VnodeinfoRepeated) XXX_Size ¶
func (m *VnodeinfoRepeated) XXX_Size() int
func (*VnodeinfoRepeated) XXX_Unmarshal ¶
func (m *VnodeinfoRepeated) XXX_Unmarshal(b []byte) error
type VnodeinfoS ¶
type VnodeinfoS struct { Nid []byte `protobuf:"bytes,1,opt,name=Nid,proto3" json:"Nid,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"` Vid []byte `protobuf:"bytes,3,opt,name=Vid,proto3" json:"Vid,omitempty"` Addr string `protobuf:"bytes,4,opt,name=Addr,proto3" json:"Addr,omitempty"` TcpPort uint64 `protobuf:"varint,5,opt,name=TcpPort,proto3" json:"TcpPort,omitempty"` QuicPort uint64 `protobuf:"varint,6,opt,name=QuicPort,proto3" json:"QuicPort,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VnodeinfoS) Descriptor ¶
func (*VnodeinfoS) Descriptor() ([]byte, []int)
func (*VnodeinfoS) GetAddr ¶
func (m *VnodeinfoS) GetAddr() string
func (*VnodeinfoS) GetIndex ¶
func (m *VnodeinfoS) GetIndex() uint64
func (*VnodeinfoS) GetNid ¶
func (m *VnodeinfoS) GetNid() []byte
func (*VnodeinfoS) GetQuicPort ¶
func (m *VnodeinfoS) GetQuicPort() uint64
func (*VnodeinfoS) GetTcpPort ¶
func (m *VnodeinfoS) GetTcpPort() uint64
func (*VnodeinfoS) GetVid ¶
func (m *VnodeinfoS) GetVid() []byte
func (*VnodeinfoS) Marshal ¶
func (m *VnodeinfoS) Marshal() (dAtA []byte, err error)
func (*VnodeinfoS) MarshalToSizedBuffer ¶
func (m *VnodeinfoS) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VnodeinfoS) ProtoMessage ¶
func (*VnodeinfoS) ProtoMessage()
func (*VnodeinfoS) Reset ¶
func (m *VnodeinfoS) Reset()
func (*VnodeinfoS) Size ¶
func (m *VnodeinfoS) Size() (n int)
func (*VnodeinfoS) String ¶
func (m *VnodeinfoS) String() string
func (*VnodeinfoS) Unmarshal ¶
func (m *VnodeinfoS) Unmarshal(dAtA []byte) error
func (*VnodeinfoS) XXX_DiscardUnknown ¶
func (m *VnodeinfoS) XXX_DiscardUnknown()
func (*VnodeinfoS) XXX_Marshal ¶
func (m *VnodeinfoS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VnodeinfoS) XXX_Merge ¶
func (m *VnodeinfoS) XXX_Merge(src proto.Message)
func (*VnodeinfoS) XXX_Size ¶
func (m *VnodeinfoS) XXX_Size() int
func (*VnodeinfoS) XXX_Unmarshal ¶
func (m *VnodeinfoS) XXX_Unmarshal(b []byte) error
type VnodeinfoSRepeated ¶
type VnodeinfoSRepeated struct { Vnodes []*VnodeinfoS `protobuf:"bytes,1,rep,name=vnodes,proto3" json:"vnodes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VnodeinfoSRepeated) Descriptor ¶
func (*VnodeinfoSRepeated) Descriptor() ([]byte, []int)
func (*VnodeinfoSRepeated) GetVnodes ¶
func (m *VnodeinfoSRepeated) GetVnodes() []*VnodeinfoS
func (*VnodeinfoSRepeated) Marshal ¶
func (m *VnodeinfoSRepeated) Marshal() (dAtA []byte, err error)
func (*VnodeinfoSRepeated) MarshalTo ¶
func (m *VnodeinfoSRepeated) MarshalTo(dAtA []byte) (int, error)
func (*VnodeinfoSRepeated) MarshalToSizedBuffer ¶
func (m *VnodeinfoSRepeated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VnodeinfoSRepeated) ProtoMessage ¶
func (*VnodeinfoSRepeated) ProtoMessage()
func (*VnodeinfoSRepeated) Reset ¶
func (m *VnodeinfoSRepeated) Reset()
func (*VnodeinfoSRepeated) Size ¶
func (m *VnodeinfoSRepeated) Size() (n int)
func (*VnodeinfoSRepeated) String ¶
func (m *VnodeinfoSRepeated) String() string
func (*VnodeinfoSRepeated) Unmarshal ¶
func (m *VnodeinfoSRepeated) Unmarshal(dAtA []byte) error
func (*VnodeinfoSRepeated) XXX_DiscardUnknown ¶
func (m *VnodeinfoSRepeated) XXX_DiscardUnknown()
func (*VnodeinfoSRepeated) XXX_Marshal ¶
func (m *VnodeinfoSRepeated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VnodeinfoSRepeated) XXX_Merge ¶
func (m *VnodeinfoSRepeated) XXX_Merge(src proto.Message)
func (*VnodeinfoSRepeated) XXX_Size ¶
func (m *VnodeinfoSRepeated) XXX_Size() int
func (*VnodeinfoSRepeated) XXX_Unmarshal ¶
func (m *VnodeinfoSRepeated) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.