Documentation
¶
Index ¶
- Variables
- func RegisterClusterManagerServer(s *grpc.Server, srv ClusterManagerServer)
- func RegisterClusterNodeServer(s *grpc.Server, srv ClusterNodeServer)
- type AddNodeReq
- func (*AddNodeReq) Descriptor() ([]byte, []int)
- func (m *AddNodeReq) GetNodeId() uint32
- func (m *AddNodeReq) Marshal() (dAtA []byte, err error)
- func (m *AddNodeReq) MarshalTo(dAtA []byte) (int, error)
- func (*AddNodeReq) ProtoMessage()
- func (m *AddNodeReq) Reset()
- func (m *AddNodeReq) Size() (n int)
- func (m *AddNodeReq) String() string
- func (m *AddNodeReq) Unmarshal(dAtA []byte) error
- func (m *AddNodeReq) XXX_DiscardUnknown()
- func (m *AddNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddNodeReq) XXX_Merge(src proto.Message)
- func (m *AddNodeReq) XXX_Size() int
- func (m *AddNodeReq) XXX_Unmarshal(b []byte) error
- type AddNodeRes
- func (*AddNodeRes) Descriptor() ([]byte, []int)
- func (m *AddNodeRes) GetRaftAddress() string
- func (m *AddNodeRes) GetServerAddress() string
- func (m *AddNodeRes) GetSuccess() bool
- func (m *AddNodeRes) Marshal() (dAtA []byte, err error)
- func (m *AddNodeRes) MarshalTo(dAtA []byte) (int, error)
- func (*AddNodeRes) ProtoMessage()
- func (m *AddNodeRes) Reset()
- func (m *AddNodeRes) Size() (n int)
- func (m *AddNodeRes) String() string
- func (m *AddNodeRes) Unmarshal(dAtA []byte) error
- func (m *AddNodeRes) XXX_DiscardUnknown()
- func (m *AddNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddNodeRes) XXX_Merge(src proto.Message)
- func (m *AddNodeRes) XXX_Size() int
- func (m *AddNodeRes) XXX_Unmarshal(b []byte) error
- type ClusterManagerClient
- type ClusterManagerServer
- type ClusterNodeClient
- type ClusterNodeServer
- type DeRegisterNodeReq
- func (*DeRegisterNodeReq) Descriptor() ([]byte, []int)
- func (m *DeRegisterNodeReq) GetNodeId() uint32
- func (m *DeRegisterNodeReq) Marshal() (dAtA []byte, err error)
- func (m *DeRegisterNodeReq) MarshalTo(dAtA []byte) (int, error)
- func (*DeRegisterNodeReq) ProtoMessage()
- func (m *DeRegisterNodeReq) Reset()
- func (m *DeRegisterNodeReq) Size() (n int)
- func (m *DeRegisterNodeReq) String() string
- func (m *DeRegisterNodeReq) Unmarshal(dAtA []byte) error
- func (m *DeRegisterNodeReq) XXX_DiscardUnknown()
- func (m *DeRegisterNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeRegisterNodeReq) XXX_Merge(src proto.Message)
- func (m *DeRegisterNodeReq) XXX_Size() int
- func (m *DeRegisterNodeReq) XXX_Unmarshal(b []byte) error
- type DeRegisterNodeRes
- func (*DeRegisterNodeRes) Descriptor() ([]byte, []int)
- func (m *DeRegisterNodeRes) Marshal() (dAtA []byte, err error)
- func (m *DeRegisterNodeRes) MarshalTo(dAtA []byte) (int, error)
- func (*DeRegisterNodeRes) ProtoMessage()
- func (m *DeRegisterNodeRes) Reset()
- func (m *DeRegisterNodeRes) Size() (n int)
- func (m *DeRegisterNodeRes) String() string
- func (m *DeRegisterNodeRes) Unmarshal(dAtA []byte) error
- func (m *DeRegisterNodeRes) XXX_DiscardUnknown()
- func (m *DeRegisterNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeRegisterNodeRes) XXX_Merge(src proto.Message)
- func (m *DeRegisterNodeRes) XXX_Size() int
- func (m *DeRegisterNodeRes) XXX_Unmarshal(b []byte) error
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)
- func (m *Peer) GetId() uint32
- func (m *Peer) GetRaftAddress() string
- func (m *Peer) GetServerAddress() string
- func (m *Peer) Marshal() (dAtA []byte, err error)
- func (m *Peer) MarshalTo(dAtA []byte) (int, error)
- func (*Peer) ProtoMessage()
- func (m *Peer) Reset()
- func (m *Peer) Size() (n int)
- func (m *Peer) String() string
- func (m *Peer) Unmarshal(dAtA []byte) error
- func (m *Peer) XXX_DiscardUnknown()
- func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Peer) XXX_Merge(src proto.Message)
- func (m *Peer) XXX_Size() int
- func (m *Peer) XXX_Unmarshal(b []byte) error
- type PeerListRes
- func (*PeerListRes) Descriptor() ([]byte, []int)
- func (m *PeerListRes) GetPeers() map[uint32]*Peer
- func (m *PeerListRes) Marshal() (dAtA []byte, err error)
- func (m *PeerListRes) MarshalTo(dAtA []byte) (int, error)
- func (*PeerListRes) ProtoMessage()
- func (m *PeerListRes) Reset()
- func (m *PeerListRes) Size() (n int)
- func (m *PeerListRes) String() string
- func (m *PeerListRes) Unmarshal(dAtA []byte) error
- func (m *PeerListRes) XXX_DiscardUnknown()
- func (m *PeerListRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerListRes) XXX_Merge(src proto.Message)
- func (m *PeerListRes) XXX_Size() int
- func (m *PeerListRes) XXX_Unmarshal(b []byte) error
- type RegisterNodeReq
- func (*RegisterNodeReq) Descriptor() ([]byte, []int)
- func (m *RegisterNodeReq) GetNetworkAddress() string
- func (m *RegisterNodeReq) GetNodeId() uint32
- func (m *RegisterNodeReq) Marshal() (dAtA []byte, err error)
- func (m *RegisterNodeReq) MarshalTo(dAtA []byte) (int, error)
- func (*RegisterNodeReq) ProtoMessage()
- func (m *RegisterNodeReq) Reset()
- func (m *RegisterNodeReq) Size() (n int)
- func (m *RegisterNodeReq) String() string
- func (m *RegisterNodeReq) Unmarshal(dAtA []byte) error
- func (m *RegisterNodeReq) XXX_DiscardUnknown()
- func (m *RegisterNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterNodeReq) XXX_Merge(src proto.Message)
- func (m *RegisterNodeReq) XXX_Size() int
- func (m *RegisterNodeReq) XXX_Unmarshal(b []byte) error
- type RegisterNodeRes
- func (*RegisterNodeRes) Descriptor() ([]byte, []int)
- func (m *RegisterNodeRes) GetOk() bool
- func (m *RegisterNodeRes) Marshal() (dAtA []byte, err error)
- func (m *RegisterNodeRes) MarshalTo(dAtA []byte) (int, error)
- func (*RegisterNodeRes) ProtoMessage()
- func (m *RegisterNodeRes) Reset()
- func (m *RegisterNodeRes) Size() (n int)
- func (m *RegisterNodeRes) String() string
- func (m *RegisterNodeRes) Unmarshal(dAtA []byte) error
- func (m *RegisterNodeRes) XXX_DiscardUnknown()
- func (m *RegisterNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterNodeRes) XXX_Merge(src proto.Message)
- func (m *RegisterNodeRes) XXX_Size() int
- func (m *RegisterNodeRes) XXX_Unmarshal(b []byte) error
- type RemoveNodeReq
- func (*RemoveNodeReq) Descriptor() ([]byte, []int)
- func (m *RemoveNodeReq) GetNodeId() uint32
- func (m *RemoveNodeReq) Marshal() (dAtA []byte, err error)
- func (m *RemoveNodeReq) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveNodeReq) ProtoMessage()
- func (m *RemoveNodeReq) Reset()
- func (m *RemoveNodeReq) Size() (n int)
- func (m *RemoveNodeReq) String() string
- func (m *RemoveNodeReq) Unmarshal(dAtA []byte) error
- func (m *RemoveNodeReq) XXX_DiscardUnknown()
- func (m *RemoveNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveNodeReq) XXX_Merge(src proto.Message)
- func (m *RemoveNodeReq) XXX_Size() int
- func (m *RemoveNodeReq) XXX_Unmarshal(b []byte) error
- type RemoveNodeRes
- func (*RemoveNodeRes) Descriptor() ([]byte, []int)
- func (m *RemoveNodeRes) GetSuccess() bool
- func (m *RemoveNodeRes) Marshal() (dAtA []byte, err error)
- func (m *RemoveNodeRes) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveNodeRes) ProtoMessage()
- func (m *RemoveNodeRes) Reset()
- func (m *RemoveNodeRes) Size() (n int)
- func (m *RemoveNodeRes) String() string
- func (m *RemoveNodeRes) Unmarshal(dAtA []byte) error
- func (m *RemoveNodeRes) XXX_DiscardUnknown()
- func (m *RemoveNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveNodeRes) XXX_Merge(src proto.Message)
- func (m *RemoveNodeRes) XXX_Size() int
- func (m *RemoveNodeRes) XXX_Unmarshal(b []byte) error
- type UpdateNodeReq
- func (*UpdateNodeReq) Descriptor() ([]byte, []int)
- func (m *UpdateNodeReq) GetNodeId() uint32
- func (m *UpdateNodeReq) Marshal() (dAtA []byte, err error)
- func (m *UpdateNodeReq) MarshalTo(dAtA []byte) (int, error)
- func (*UpdateNodeReq) ProtoMessage()
- func (m *UpdateNodeReq) Reset()
- func (m *UpdateNodeReq) Size() (n int)
- func (m *UpdateNodeReq) String() string
- func (m *UpdateNodeReq) Unmarshal(dAtA []byte) error
- func (m *UpdateNodeReq) XXX_DiscardUnknown()
- func (m *UpdateNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateNodeReq) XXX_Merge(src proto.Message)
- func (m *UpdateNodeReq) XXX_Size() int
- func (m *UpdateNodeReq) XXX_Unmarshal(b []byte) error
- type UpdateNodeRes
- func (*UpdateNodeRes) Descriptor() ([]byte, []int)
- func (m *UpdateNodeRes) GetSuccess() bool
- func (m *UpdateNodeRes) Marshal() (dAtA []byte, err error)
- func (m *UpdateNodeRes) MarshalTo(dAtA []byte) (int, error)
- func (*UpdateNodeRes) ProtoMessage()
- func (m *UpdateNodeRes) Reset()
- func (m *UpdateNodeRes) Size() (n int)
- func (m *UpdateNodeRes) String() string
- func (m *UpdateNodeRes) Unmarshal(dAtA []byte) error
- func (m *UpdateNodeRes) XXX_DiscardUnknown()
- func (m *UpdateNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateNodeRes) XXX_Merge(src proto.Message)
- func (m *UpdateNodeRes) XXX_Size() int
- func (m *UpdateNodeRes) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthClusterServices = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowClusterServices = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterClusterManagerServer ¶
func RegisterClusterManagerServer(s *grpc.Server, srv ClusterManagerServer)
func RegisterClusterNodeServer ¶
func RegisterClusterNodeServer(s *grpc.Server, srv ClusterNodeServer)
Types ¶
type AddNodeReq ¶
type AddNodeReq struct { NodeId uint32 `protobuf:"varint,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AddNodeReq) Descriptor ¶
func (*AddNodeReq) Descriptor() ([]byte, []int)
func (*AddNodeReq) GetNodeId ¶
func (m *AddNodeReq) GetNodeId() uint32
func (*AddNodeReq) Marshal ¶
func (m *AddNodeReq) Marshal() (dAtA []byte, err error)
func (*AddNodeReq) ProtoMessage ¶
func (*AddNodeReq) ProtoMessage()
func (*AddNodeReq) Reset ¶
func (m *AddNodeReq) Reset()
func (*AddNodeReq) Size ¶
func (m *AddNodeReq) Size() (n int)
func (*AddNodeReq) String ¶
func (m *AddNodeReq) String() string
func (*AddNodeReq) Unmarshal ¶
func (m *AddNodeReq) Unmarshal(dAtA []byte) error
func (*AddNodeReq) XXX_DiscardUnknown ¶
func (m *AddNodeReq) XXX_DiscardUnknown()
func (*AddNodeReq) XXX_Marshal ¶
func (m *AddNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddNodeReq) XXX_Merge ¶
func (m *AddNodeReq) XXX_Merge(src proto.Message)
func (*AddNodeReq) XXX_Size ¶
func (m *AddNodeReq) XXX_Size() int
func (*AddNodeReq) XXX_Unmarshal ¶
func (m *AddNodeReq) XXX_Unmarshal(b []byte) error
type AddNodeRes ¶
type AddNodeRes struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` ServerAddress string `protobuf:"bytes,2,opt,name=ServerAddress,proto3" json:"ServerAddress,omitempty"` RaftAddress string `protobuf:"bytes,3,opt,name=RaftAddress,proto3" json:"RaftAddress,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AddNodeRes) Descriptor ¶
func (*AddNodeRes) Descriptor() ([]byte, []int)
func (*AddNodeRes) GetRaftAddress ¶
func (m *AddNodeRes) GetRaftAddress() string
func (*AddNodeRes) GetServerAddress ¶
func (m *AddNodeRes) GetServerAddress() string
func (*AddNodeRes) GetSuccess ¶
func (m *AddNodeRes) GetSuccess() bool
func (*AddNodeRes) Marshal ¶
func (m *AddNodeRes) Marshal() (dAtA []byte, err error)
func (*AddNodeRes) ProtoMessage ¶
func (*AddNodeRes) ProtoMessage()
func (*AddNodeRes) Reset ¶
func (m *AddNodeRes) Reset()
func (*AddNodeRes) Size ¶
func (m *AddNodeRes) Size() (n int)
func (*AddNodeRes) String ¶
func (m *AddNodeRes) String() string
func (*AddNodeRes) Unmarshal ¶
func (m *AddNodeRes) Unmarshal(dAtA []byte) error
func (*AddNodeRes) XXX_DiscardUnknown ¶
func (m *AddNodeRes) XXX_DiscardUnknown()
func (*AddNodeRes) XXX_Marshal ¶
func (m *AddNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddNodeRes) XXX_Merge ¶
func (m *AddNodeRes) XXX_Merge(src proto.Message)
func (*AddNodeRes) XXX_Size ¶
func (m *AddNodeRes) XXX_Size() int
func (*AddNodeRes) XXX_Unmarshal ¶
func (m *AddNodeRes) XXX_Unmarshal(b []byte) error
type ClusterManagerClient ¶
type ClusterManagerClient interface { RegisterNode(ctx context.Context, in *RegisterNodeReq, opts ...grpc.CallOption) (*RegisterNodeRes, error) DeRegisterNode(ctx context.Context, in *DeRegisterNodeReq, opts ...grpc.CallOption) (*DeRegisterNodeRes, error) }
ClusterManagerClient is the client API for ClusterManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewClusterManagerClient ¶
func NewClusterManagerClient(cc *grpc.ClientConn) ClusterManagerClient
type ClusterManagerServer ¶
type ClusterManagerServer interface { RegisterNode(context.Context, *RegisterNodeReq) (*RegisterNodeRes, error) DeRegisterNode(context.Context, *DeRegisterNodeReq) (*DeRegisterNodeRes, error) }
ClusterManagerServer is the server API for ClusterManager service.
type ClusterNodeClient ¶
type ClusterNodeClient interface { AddNode(ctx context.Context, in *AddNodeReq, opts ...grpc.CallOption) (*AddNodeRes, error) RemoveNode(ctx context.Context, in *RemoveNodeReq, opts ...grpc.CallOption) (*RemoveNodeRes, error) GetNodeList(ctx context.Context, in *protobuf.Empty, opts ...grpc.CallOption) (*PeerListRes, error) }
ClusterNodeClient is the client API for ClusterNode service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewClusterNodeClient ¶
func NewClusterNodeClient(cc *grpc.ClientConn) ClusterNodeClient
type ClusterNodeServer ¶
type ClusterNodeServer interface { AddNode(context.Context, *AddNodeReq) (*AddNodeRes, error) RemoveNode(context.Context, *RemoveNodeReq) (*RemoveNodeRes, error) GetNodeList(context.Context, *protobuf.Empty) (*PeerListRes, error) }
ClusterNodeServer is the server API for ClusterNode service.
type DeRegisterNodeReq ¶
type DeRegisterNodeReq struct { NodeId uint32 `protobuf:"varint,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeRegisterNodeReq) Descriptor ¶
func (*DeRegisterNodeReq) Descriptor() ([]byte, []int)
func (*DeRegisterNodeReq) GetNodeId ¶
func (m *DeRegisterNodeReq) GetNodeId() uint32
func (*DeRegisterNodeReq) Marshal ¶
func (m *DeRegisterNodeReq) Marshal() (dAtA []byte, err error)
func (*DeRegisterNodeReq) MarshalTo ¶
func (m *DeRegisterNodeReq) MarshalTo(dAtA []byte) (int, error)
func (*DeRegisterNodeReq) ProtoMessage ¶
func (*DeRegisterNodeReq) ProtoMessage()
func (*DeRegisterNodeReq) Reset ¶
func (m *DeRegisterNodeReq) Reset()
func (*DeRegisterNodeReq) Size ¶
func (m *DeRegisterNodeReq) Size() (n int)
func (*DeRegisterNodeReq) String ¶
func (m *DeRegisterNodeReq) String() string
func (*DeRegisterNodeReq) Unmarshal ¶
func (m *DeRegisterNodeReq) Unmarshal(dAtA []byte) error
func (*DeRegisterNodeReq) XXX_DiscardUnknown ¶
func (m *DeRegisterNodeReq) XXX_DiscardUnknown()
func (*DeRegisterNodeReq) XXX_Marshal ¶
func (m *DeRegisterNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeRegisterNodeReq) XXX_Merge ¶
func (m *DeRegisterNodeReq) XXX_Merge(src proto.Message)
func (*DeRegisterNodeReq) XXX_Size ¶
func (m *DeRegisterNodeReq) XXX_Size() int
func (*DeRegisterNodeReq) XXX_Unmarshal ¶
func (m *DeRegisterNodeReq) XXX_Unmarshal(b []byte) error
type DeRegisterNodeRes ¶
type DeRegisterNodeRes struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeRegisterNodeRes) Descriptor ¶
func (*DeRegisterNodeRes) Descriptor() ([]byte, []int)
func (*DeRegisterNodeRes) Marshal ¶
func (m *DeRegisterNodeRes) Marshal() (dAtA []byte, err error)
func (*DeRegisterNodeRes) MarshalTo ¶
func (m *DeRegisterNodeRes) MarshalTo(dAtA []byte) (int, error)
func (*DeRegisterNodeRes) ProtoMessage ¶
func (*DeRegisterNodeRes) ProtoMessage()
func (*DeRegisterNodeRes) Reset ¶
func (m *DeRegisterNodeRes) Reset()
func (*DeRegisterNodeRes) Size ¶
func (m *DeRegisterNodeRes) Size() (n int)
func (*DeRegisterNodeRes) String ¶
func (m *DeRegisterNodeRes) String() string
func (*DeRegisterNodeRes) Unmarshal ¶
func (m *DeRegisterNodeRes) Unmarshal(dAtA []byte) error
func (*DeRegisterNodeRes) XXX_DiscardUnknown ¶
func (m *DeRegisterNodeRes) XXX_DiscardUnknown()
func (*DeRegisterNodeRes) XXX_Marshal ¶
func (m *DeRegisterNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeRegisterNodeRes) XXX_Merge ¶
func (m *DeRegisterNodeRes) XXX_Merge(src proto.Message)
func (*DeRegisterNodeRes) XXX_Size ¶
func (m *DeRegisterNodeRes) XXX_Size() int
func (*DeRegisterNodeRes) XXX_Unmarshal ¶
func (m *DeRegisterNodeRes) XXX_Unmarshal(b []byte) error
type Peer ¶
type Peer struct { Id uint32 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"` ServerAddress string `protobuf:"bytes,2,opt,name=ServerAddress,proto3" json:"ServerAddress,omitempty"` RaftAddress string `protobuf:"bytes,3,opt,name=RaftAddress,proto3" json:"RaftAddress,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Peer) Descriptor ¶
func (*Peer) GetRaftAddress ¶
func (*Peer) GetServerAddress ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) XXX_DiscardUnknown ¶
func (m *Peer) XXX_DiscardUnknown()
func (*Peer) XXX_Unmarshal ¶
type PeerListRes ¶
type PeerListRes struct { Peers map[uint32]*Peer `` /* 152-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeerListRes) Descriptor ¶
func (*PeerListRes) Descriptor() ([]byte, []int)
func (*PeerListRes) GetPeers ¶
func (m *PeerListRes) GetPeers() map[uint32]*Peer
func (*PeerListRes) Marshal ¶
func (m *PeerListRes) Marshal() (dAtA []byte, err error)
func (*PeerListRes) ProtoMessage ¶
func (*PeerListRes) ProtoMessage()
func (*PeerListRes) Reset ¶
func (m *PeerListRes) Reset()
func (*PeerListRes) Size ¶
func (m *PeerListRes) Size() (n int)
func (*PeerListRes) String ¶
func (m *PeerListRes) String() string
func (*PeerListRes) Unmarshal ¶
func (m *PeerListRes) Unmarshal(dAtA []byte) error
func (*PeerListRes) XXX_DiscardUnknown ¶
func (m *PeerListRes) XXX_DiscardUnknown()
func (*PeerListRes) XXX_Marshal ¶
func (m *PeerListRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeerListRes) XXX_Merge ¶
func (m *PeerListRes) XXX_Merge(src proto.Message)
func (*PeerListRes) XXX_Size ¶
func (m *PeerListRes) XXX_Size() int
func (*PeerListRes) XXX_Unmarshal ¶
func (m *PeerListRes) XXX_Unmarshal(b []byte) error
type RegisterNodeReq ¶
type RegisterNodeReq struct { NodeId uint32 `protobuf:"varint,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"` NetworkAddress string `protobuf:"bytes,2,opt,name=NetworkAddress,proto3" json:"NetworkAddress,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterNodeReq) Descriptor ¶
func (*RegisterNodeReq) Descriptor() ([]byte, []int)
func (*RegisterNodeReq) GetNetworkAddress ¶
func (m *RegisterNodeReq) GetNetworkAddress() string
func (*RegisterNodeReq) GetNodeId ¶
func (m *RegisterNodeReq) GetNodeId() uint32
func (*RegisterNodeReq) Marshal ¶
func (m *RegisterNodeReq) Marshal() (dAtA []byte, err error)
func (*RegisterNodeReq) ProtoMessage ¶
func (*RegisterNodeReq) ProtoMessage()
func (*RegisterNodeReq) Reset ¶
func (m *RegisterNodeReq) Reset()
func (*RegisterNodeReq) Size ¶
func (m *RegisterNodeReq) Size() (n int)
func (*RegisterNodeReq) String ¶
func (m *RegisterNodeReq) String() string
func (*RegisterNodeReq) Unmarshal ¶
func (m *RegisterNodeReq) Unmarshal(dAtA []byte) error
func (*RegisterNodeReq) XXX_DiscardUnknown ¶
func (m *RegisterNodeReq) XXX_DiscardUnknown()
func (*RegisterNodeReq) XXX_Marshal ¶
func (m *RegisterNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterNodeReq) XXX_Merge ¶
func (m *RegisterNodeReq) XXX_Merge(src proto.Message)
func (*RegisterNodeReq) XXX_Size ¶
func (m *RegisterNodeReq) XXX_Size() int
func (*RegisterNodeReq) XXX_Unmarshal ¶
func (m *RegisterNodeReq) XXX_Unmarshal(b []byte) error
type RegisterNodeRes ¶
type RegisterNodeRes struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterNodeRes) Descriptor ¶
func (*RegisterNodeRes) Descriptor() ([]byte, []int)
func (*RegisterNodeRes) GetOk ¶
func (m *RegisterNodeRes) GetOk() bool
func (*RegisterNodeRes) Marshal ¶
func (m *RegisterNodeRes) Marshal() (dAtA []byte, err error)
func (*RegisterNodeRes) ProtoMessage ¶
func (*RegisterNodeRes) ProtoMessage()
func (*RegisterNodeRes) Reset ¶
func (m *RegisterNodeRes) Reset()
func (*RegisterNodeRes) Size ¶
func (m *RegisterNodeRes) Size() (n int)
func (*RegisterNodeRes) String ¶
func (m *RegisterNodeRes) String() string
func (*RegisterNodeRes) Unmarshal ¶
func (m *RegisterNodeRes) Unmarshal(dAtA []byte) error
func (*RegisterNodeRes) XXX_DiscardUnknown ¶
func (m *RegisterNodeRes) XXX_DiscardUnknown()
func (*RegisterNodeRes) XXX_Marshal ¶
func (m *RegisterNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterNodeRes) XXX_Merge ¶
func (m *RegisterNodeRes) XXX_Merge(src proto.Message)
func (*RegisterNodeRes) XXX_Size ¶
func (m *RegisterNodeRes) XXX_Size() int
func (*RegisterNodeRes) XXX_Unmarshal ¶
func (m *RegisterNodeRes) XXX_Unmarshal(b []byte) error
type RemoveNodeReq ¶
type RemoveNodeReq struct { NodeId uint32 `protobuf:"varint,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoveNodeReq) Descriptor ¶
func (*RemoveNodeReq) Descriptor() ([]byte, []int)
func (*RemoveNodeReq) GetNodeId ¶
func (m *RemoveNodeReq) GetNodeId() uint32
func (*RemoveNodeReq) Marshal ¶
func (m *RemoveNodeReq) Marshal() (dAtA []byte, err error)
func (*RemoveNodeReq) ProtoMessage ¶
func (*RemoveNodeReq) ProtoMessage()
func (*RemoveNodeReq) Reset ¶
func (m *RemoveNodeReq) Reset()
func (*RemoveNodeReq) Size ¶
func (m *RemoveNodeReq) Size() (n int)
func (*RemoveNodeReq) String ¶
func (m *RemoveNodeReq) String() string
func (*RemoveNodeReq) Unmarshal ¶
func (m *RemoveNodeReq) Unmarshal(dAtA []byte) error
func (*RemoveNodeReq) XXX_DiscardUnknown ¶
func (m *RemoveNodeReq) XXX_DiscardUnknown()
func (*RemoveNodeReq) XXX_Marshal ¶
func (m *RemoveNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveNodeReq) XXX_Merge ¶
func (m *RemoveNodeReq) XXX_Merge(src proto.Message)
func (*RemoveNodeReq) XXX_Size ¶
func (m *RemoveNodeReq) XXX_Size() int
func (*RemoveNodeReq) XXX_Unmarshal ¶
func (m *RemoveNodeReq) XXX_Unmarshal(b []byte) error
type RemoveNodeRes ¶
type RemoveNodeRes struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoveNodeRes) Descriptor ¶
func (*RemoveNodeRes) Descriptor() ([]byte, []int)
func (*RemoveNodeRes) GetSuccess ¶
func (m *RemoveNodeRes) GetSuccess() bool
func (*RemoveNodeRes) Marshal ¶
func (m *RemoveNodeRes) Marshal() (dAtA []byte, err error)
func (*RemoveNodeRes) ProtoMessage ¶
func (*RemoveNodeRes) ProtoMessage()
func (*RemoveNodeRes) Reset ¶
func (m *RemoveNodeRes) Reset()
func (*RemoveNodeRes) Size ¶
func (m *RemoveNodeRes) Size() (n int)
func (*RemoveNodeRes) String ¶
func (m *RemoveNodeRes) String() string
func (*RemoveNodeRes) Unmarshal ¶
func (m *RemoveNodeRes) Unmarshal(dAtA []byte) error
func (*RemoveNodeRes) XXX_DiscardUnknown ¶
func (m *RemoveNodeRes) XXX_DiscardUnknown()
func (*RemoveNodeRes) XXX_Marshal ¶
func (m *RemoveNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveNodeRes) XXX_Merge ¶
func (m *RemoveNodeRes) XXX_Merge(src proto.Message)
func (*RemoveNodeRes) XXX_Size ¶
func (m *RemoveNodeRes) XXX_Size() int
func (*RemoveNodeRes) XXX_Unmarshal ¶
func (m *RemoveNodeRes) XXX_Unmarshal(b []byte) error
type UpdateNodeReq ¶
type UpdateNodeReq struct { NodeId uint32 `protobuf:"varint,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateNodeReq) Descriptor ¶
func (*UpdateNodeReq) Descriptor() ([]byte, []int)
func (*UpdateNodeReq) GetNodeId ¶
func (m *UpdateNodeReq) GetNodeId() uint32
func (*UpdateNodeReq) Marshal ¶
func (m *UpdateNodeReq) Marshal() (dAtA []byte, err error)
func (*UpdateNodeReq) ProtoMessage ¶
func (*UpdateNodeReq) ProtoMessage()
func (*UpdateNodeReq) Reset ¶
func (m *UpdateNodeReq) Reset()
func (*UpdateNodeReq) Size ¶
func (m *UpdateNodeReq) Size() (n int)
func (*UpdateNodeReq) String ¶
func (m *UpdateNodeReq) String() string
func (*UpdateNodeReq) Unmarshal ¶
func (m *UpdateNodeReq) Unmarshal(dAtA []byte) error
func (*UpdateNodeReq) XXX_DiscardUnknown ¶
func (m *UpdateNodeReq) XXX_DiscardUnknown()
func (*UpdateNodeReq) XXX_Marshal ¶
func (m *UpdateNodeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateNodeReq) XXX_Merge ¶
func (m *UpdateNodeReq) XXX_Merge(src proto.Message)
func (*UpdateNodeReq) XXX_Size ¶
func (m *UpdateNodeReq) XXX_Size() int
func (*UpdateNodeReq) XXX_Unmarshal ¶
func (m *UpdateNodeReq) XXX_Unmarshal(b []byte) error
type UpdateNodeRes ¶
type UpdateNodeRes struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateNodeRes) Descriptor ¶
func (*UpdateNodeRes) Descriptor() ([]byte, []int)
func (*UpdateNodeRes) GetSuccess ¶
func (m *UpdateNodeRes) GetSuccess() bool
func (*UpdateNodeRes) Marshal ¶
func (m *UpdateNodeRes) Marshal() (dAtA []byte, err error)
func (*UpdateNodeRes) ProtoMessage ¶
func (*UpdateNodeRes) ProtoMessage()
func (*UpdateNodeRes) Reset ¶
func (m *UpdateNodeRes) Reset()
func (*UpdateNodeRes) Size ¶
func (m *UpdateNodeRes) Size() (n int)
func (*UpdateNodeRes) String ¶
func (m *UpdateNodeRes) String() string
func (*UpdateNodeRes) Unmarshal ¶
func (m *UpdateNodeRes) Unmarshal(dAtA []byte) error
func (*UpdateNodeRes) XXX_DiscardUnknown ¶
func (m *UpdateNodeRes) XXX_DiscardUnknown()
func (*UpdateNodeRes) XXX_Marshal ¶
func (m *UpdateNodeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateNodeRes) XXX_Merge ¶
func (m *UpdateNodeRes) XXX_Merge(src proto.Message)
func (*UpdateNodeRes) XXX_Size ¶
func (m *UpdateNodeRes) XXX_Size() int
func (*UpdateNodeRes) XXX_Unmarshal ¶
func (m *UpdateNodeRes) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.