代码拉取完成，页面将自动刷新
// Code generated by protoc-gen-gogo.
// source: rpcpb.proto
// DO NOT EDIT!
/*
Package rpcpb is a generated protocol buffer package.
It is generated from these files:
rpcpb.proto
It has these top-level messages:
RpcHeader
PutClusterReq
PutClusterRsp
RemoveClusterReq
RemoveClusterRsp
GetClusterReq
GetClusterRsp
GetClusterListReq
PutServerReq
PutServerRsp
RemoveServerReq
RemoveServerRsp
GetServerReq
GetServerRsp
GetServerListReq
PutAPIReq
PutAPIRsp
RemoveAPIReq
RemoveAPIRsp
GetAPIReq
GetAPIRsp
GetAPIListReq
PutRoutingReq
PutRoutingRsp
RemoveRoutingReq
RemoveRoutingRsp
GetRoutingReq
GetRoutingRsp
GetRoutingListReq
AddBindReq
AddBindRsp
RemoveBindReq
RemoveBindRsp
RemoveClusterBindReq
RemoveClusterBindRsp
GetBindServersReq
GetBindServersRsp
*/
package rpcpb
import (
"fmt"
proto "github.com/golang/protobuf/proto"
math "math"
metapb "github.com/fagongzi/gateway/pkg/pb/metapb"
context "golang.org/x/net/context"
grpc "google.golang.org/grpc"
io "io"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
// RpcHeader is the header for all rpc request and response
type RpcHeader struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid" json:"uuid"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RpcHeader) Reset() { *m = RpcHeader{} }
func (m *RpcHeader) String() string { return proto.CompactTextString(m) }
func (*RpcHeader) ProtoMessage() {}
func (*RpcHeader) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{0} }
func (m *RpcHeader) GetUuid() string {
if m != nil {
return m.Uuid
}
return ""
}
type PutClusterReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Cluster metapb.Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutClusterReq) Reset() { *m = PutClusterReq{} }
func (m *PutClusterReq) String() string { return proto.CompactTextString(m) }
func (*PutClusterReq) ProtoMessage() {}
func (*PutClusterReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{1} }
func (m *PutClusterReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutClusterReq) GetCluster() metapb.Cluster {
if m != nil {
return m.Cluster
}
return metapb.Cluster{}
}
type PutClusterRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutClusterRsp) Reset() { *m = PutClusterRsp{} }
func (m *PutClusterRsp) String() string { return proto.CompactTextString(m) }
func (*PutClusterRsp) ProtoMessage() {}
func (*PutClusterRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{2} }
func (m *PutClusterRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutClusterRsp) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveClusterReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveClusterReq) Reset() { *m = RemoveClusterReq{} }
func (m *RemoveClusterReq) String() string { return proto.CompactTextString(m) }
func (*RemoveClusterReq) ProtoMessage() {}
func (*RemoveClusterReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{3} }
func (m *RemoveClusterReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *RemoveClusterReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveClusterRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveClusterRsp) Reset() { *m = RemoveClusterRsp{} }
func (m *RemoveClusterRsp) String() string { return proto.CompactTextString(m) }
func (*RemoveClusterRsp) ProtoMessage() {}
func (*RemoveClusterRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{4} }
func (m *RemoveClusterRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type GetClusterReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetClusterReq) Reset() { *m = GetClusterReq{} }
func (m *GetClusterReq) String() string { return proto.CompactTextString(m) }
func (*GetClusterReq) ProtoMessage() {}
func (*GetClusterReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{5} }
func (m *GetClusterReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetClusterReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type GetClusterRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Cluster *metapb.Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetClusterRsp) Reset() { *m = GetClusterRsp{} }
func (m *GetClusterRsp) String() string { return proto.CompactTextString(m) }
func (*GetClusterRsp) ProtoMessage() {}
func (*GetClusterRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{6} }
func (m *GetClusterRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetClusterRsp) GetCluster() *metapb.Cluster {
if m != nil {
return m.Cluster
}
return nil
}
type GetClusterListReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetClusterListReq) Reset() { *m = GetClusterListReq{} }
func (m *GetClusterListReq) String() string { return proto.CompactTextString(m) }
func (*GetClusterListReq) ProtoMessage() {}
func (*GetClusterListReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{7} }
func (m *GetClusterListReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type PutServerReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Server metapb.Server `protobuf:"bytes,2,opt,name=server" json:"server"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutServerReq) Reset() { *m = PutServerReq{} }
func (m *PutServerReq) String() string { return proto.CompactTextString(m) }
func (*PutServerReq) ProtoMessage() {}
func (*PutServerReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{8} }
func (m *PutServerReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutServerReq) GetServer() metapb.Server {
if m != nil {
return m.Server
}
return metapb.Server{}
}
type PutServerRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutServerRsp) Reset() { *m = PutServerRsp{} }
func (m *PutServerRsp) String() string { return proto.CompactTextString(m) }
func (*PutServerRsp) ProtoMessage() {}
func (*PutServerRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{9} }
func (m *PutServerRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutServerRsp) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveServerReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveServerReq) Reset() { *m = RemoveServerReq{} }
func (m *RemoveServerReq) String() string { return proto.CompactTextString(m) }
func (*RemoveServerReq) ProtoMessage() {}
func (*RemoveServerReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{10} }
func (m *RemoveServerReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *RemoveServerReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveServerRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveServerRsp) Reset() { *m = RemoveServerRsp{} }
func (m *RemoveServerRsp) String() string { return proto.CompactTextString(m) }
func (*RemoveServerRsp) ProtoMessage() {}
func (*RemoveServerRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{11} }
func (m *RemoveServerRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type GetServerReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetServerReq) Reset() { *m = GetServerReq{} }
func (m *GetServerReq) String() string { return proto.CompactTextString(m) }
func (*GetServerReq) ProtoMessage() {}
func (*GetServerReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{12} }
func (m *GetServerReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetServerReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type GetServerRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Server *metapb.Server `protobuf:"bytes,2,opt,name=server" json:"server,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetServerRsp) Reset() { *m = GetServerRsp{} }
func (m *GetServerRsp) String() string { return proto.CompactTextString(m) }
func (*GetServerRsp) ProtoMessage() {}
func (*GetServerRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{13} }
func (m *GetServerRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetServerRsp) GetServer() *metapb.Server {
if m != nil {
return m.Server
}
return nil
}
type GetServerListReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetServerListReq) Reset() { *m = GetServerListReq{} }
func (m *GetServerListReq) String() string { return proto.CompactTextString(m) }
func (*GetServerListReq) ProtoMessage() {}
func (*GetServerListReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{14} }
func (m *GetServerListReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type PutAPIReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
API metapb.API `protobuf:"bytes,2,opt,name=api" json:"api"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutAPIReq) Reset() { *m = PutAPIReq{} }
func (m *PutAPIReq) String() string { return proto.CompactTextString(m) }
func (*PutAPIReq) ProtoMessage() {}
func (*PutAPIReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{15} }
func (m *PutAPIReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutAPIReq) GetAPI() metapb.API {
if m != nil {
return m.API
}
return metapb.API{}
}
type PutAPIRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutAPIRsp) Reset() { *m = PutAPIRsp{} }
func (m *PutAPIRsp) String() string { return proto.CompactTextString(m) }
func (*PutAPIRsp) ProtoMessage() {}
func (*PutAPIRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{16} }
func (m *PutAPIRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutAPIRsp) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveAPIReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveAPIReq) Reset() { *m = RemoveAPIReq{} }
func (m *RemoveAPIReq) String() string { return proto.CompactTextString(m) }
func (*RemoveAPIReq) ProtoMessage() {}
func (*RemoveAPIReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{17} }
func (m *RemoveAPIReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *RemoveAPIReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveAPIRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveAPIRsp) Reset() { *m = RemoveAPIRsp{} }
func (m *RemoveAPIRsp) String() string { return proto.CompactTextString(m) }
func (*RemoveAPIRsp) ProtoMessage() {}
func (*RemoveAPIRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{18} }
func (m *RemoveAPIRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type GetAPIReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetAPIReq) Reset() { *m = GetAPIReq{} }
func (m *GetAPIReq) String() string { return proto.CompactTextString(m) }
func (*GetAPIReq) ProtoMessage() {}
func (*GetAPIReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{19} }
func (m *GetAPIReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetAPIReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type GetAPIRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
API *metapb.API `protobuf:"bytes,2,opt,name=api" json:"api,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetAPIRsp) Reset() { *m = GetAPIRsp{} }
func (m *GetAPIRsp) String() string { return proto.CompactTextString(m) }
func (*GetAPIRsp) ProtoMessage() {}
func (*GetAPIRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{20} }
func (m *GetAPIRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetAPIRsp) GetAPI() *metapb.API {
if m != nil {
return m.API
}
return nil
}
type GetAPIListReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetAPIListReq) Reset() { *m = GetAPIListReq{} }
func (m *GetAPIListReq) String() string { return proto.CompactTextString(m) }
func (*GetAPIListReq) ProtoMessage() {}
func (*GetAPIListReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{21} }
func (m *GetAPIListReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type PutRoutingReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Routing metapb.Routing `protobuf:"bytes,2,opt,name=routing" json:"routing"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutRoutingReq) Reset() { *m = PutRoutingReq{} }
func (m *PutRoutingReq) String() string { return proto.CompactTextString(m) }
func (*PutRoutingReq) ProtoMessage() {}
func (*PutRoutingReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{22} }
func (m *PutRoutingReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutRoutingReq) GetRouting() metapb.Routing {
if m != nil {
return m.Routing
}
return metapb.Routing{}
}
type PutRoutingRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *PutRoutingRsp) Reset() { *m = PutRoutingRsp{} }
func (m *PutRoutingRsp) String() string { return proto.CompactTextString(m) }
func (*PutRoutingRsp) ProtoMessage() {}
func (*PutRoutingRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{23} }
func (m *PutRoutingRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *PutRoutingRsp) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveRoutingReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveRoutingReq) Reset() { *m = RemoveRoutingReq{} }
func (m *RemoveRoutingReq) String() string { return proto.CompactTextString(m) }
func (*RemoveRoutingReq) ProtoMessage() {}
func (*RemoveRoutingReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{24} }
func (m *RemoveRoutingReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *RemoveRoutingReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type RemoveRoutingRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveRoutingRsp) Reset() { *m = RemoveRoutingRsp{} }
func (m *RemoveRoutingRsp) String() string { return proto.CompactTextString(m) }
func (*RemoveRoutingRsp) ProtoMessage() {}
func (*RemoveRoutingRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{25} }
func (m *RemoveRoutingRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type GetRoutingReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
ID uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetRoutingReq) Reset() { *m = GetRoutingReq{} }
func (m *GetRoutingReq) String() string { return proto.CompactTextString(m) }
func (*GetRoutingReq) ProtoMessage() {}
func (*GetRoutingReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{26} }
func (m *GetRoutingReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetRoutingReq) GetID() uint64 {
if m != nil {
return m.ID
}
return 0
}
type GetRoutingRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Routing *metapb.Routing `protobuf:"bytes,2,opt,name=routing" json:"routing,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetRoutingRsp) Reset() { *m = GetRoutingRsp{} }
func (m *GetRoutingRsp) String() string { return proto.CompactTextString(m) }
func (*GetRoutingRsp) ProtoMessage() {}
func (*GetRoutingRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{27} }
func (m *GetRoutingRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetRoutingRsp) GetRouting() *metapb.Routing {
if m != nil {
return m.Routing
}
return nil
}
type GetRoutingListReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetRoutingListReq) Reset() { *m = GetRoutingListReq{} }
func (m *GetRoutingListReq) String() string { return proto.CompactTextString(m) }
func (*GetRoutingListReq) ProtoMessage() {}
func (*GetRoutingListReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{28} }
func (m *GetRoutingListReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type AddBindReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Cluster uint64 `protobuf:"varint,2,opt,name=cluster" json:"cluster"`
Server uint64 `protobuf:"varint,3,opt,name=server" json:"server"`
XXX_unrecognized []byte `json:"-"`
}
func (m *AddBindReq) Reset() { *m = AddBindReq{} }
func (m *AddBindReq) String() string { return proto.CompactTextString(m) }
func (*AddBindReq) ProtoMessage() {}
func (*AddBindReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{29} }
func (m *AddBindReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *AddBindReq) GetCluster() uint64 {
if m != nil {
return m.Cluster
}
return 0
}
func (m *AddBindReq) GetServer() uint64 {
if m != nil {
return m.Server
}
return 0
}
type AddBindRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *AddBindRsp) Reset() { *m = AddBindRsp{} }
func (m *AddBindRsp) String() string { return proto.CompactTextString(m) }
func (*AddBindRsp) ProtoMessage() {}
func (*AddBindRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{30} }
func (m *AddBindRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type RemoveBindReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Cluster uint64 `protobuf:"varint,2,opt,name=cluster" json:"cluster"`
Server uint64 `protobuf:"varint,3,opt,name=server" json:"server"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveBindReq) Reset() { *m = RemoveBindReq{} }
func (m *RemoveBindReq) String() string { return proto.CompactTextString(m) }
func (*RemoveBindReq) ProtoMessage() {}
func (*RemoveBindReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{31} }
func (m *RemoveBindReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *RemoveBindReq) GetCluster() uint64 {
if m != nil {
return m.Cluster
}
return 0
}
func (m *RemoveBindReq) GetServer() uint64 {
if m != nil {
return m.Server
}
return 0
}
type RemoveBindRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveBindRsp) Reset() { *m = RemoveBindRsp{} }
func (m *RemoveBindRsp) String() string { return proto.CompactTextString(m) }
func (*RemoveBindRsp) ProtoMessage() {}
func (*RemoveBindRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{32} }
func (m *RemoveBindRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type RemoveClusterBindReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Cluster uint64 `protobuf:"varint,2,opt,name=cluster" json:"cluster"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveClusterBindReq) Reset() { *m = RemoveClusterBindReq{} }
func (m *RemoveClusterBindReq) String() string { return proto.CompactTextString(m) }
func (*RemoveClusterBindReq) ProtoMessage() {}
func (*RemoveClusterBindReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{33} }
func (m *RemoveClusterBindReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *RemoveClusterBindReq) GetCluster() uint64 {
if m != nil {
return m.Cluster
}
return 0
}
type RemoveClusterBindRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
XXX_unrecognized []byte `json:"-"`
}
func (m *RemoveClusterBindRsp) Reset() { *m = RemoveClusterBindRsp{} }
func (m *RemoveClusterBindRsp) String() string { return proto.CompactTextString(m) }
func (*RemoveClusterBindRsp) ProtoMessage() {}
func (*RemoveClusterBindRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{34} }
func (m *RemoveClusterBindRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
type GetBindServersReq struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Cluster uint64 `protobuf:"varint,2,opt,name=cluster" json:"cluster"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetBindServersReq) Reset() { *m = GetBindServersReq{} }
func (m *GetBindServersReq) String() string { return proto.CompactTextString(m) }
func (*GetBindServersReq) ProtoMessage() {}
func (*GetBindServersReq) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{35} }
func (m *GetBindServersReq) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetBindServersReq) GetCluster() uint64 {
if m != nil {
return m.Cluster
}
return 0
}
type GetBindServersRsp struct {
Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
Servers []uint64 `protobuf:"varint,2,rep,name=servers" json:"servers,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *GetBindServersRsp) Reset() { *m = GetBindServersRsp{} }
func (m *GetBindServersRsp) String() string { return proto.CompactTextString(m) }
func (*GetBindServersRsp) ProtoMessage() {}
func (*GetBindServersRsp) Descriptor() ([]byte, []int) { return fileDescriptorRpcpb, []int{36} }
func (m *GetBindServersRsp) GetHeader() RpcHeader {
if m != nil {
return m.Header
}
return RpcHeader{}
}
func (m *GetBindServersRsp) GetServers() []uint64 {
if m != nil {
return m.Servers
}
return nil
}
func init() {
proto.RegisterType((*RpcHeader)(nil), "rpcpb.RpcHeader")
proto.RegisterType((*PutClusterReq)(nil), "rpcpb.PutClusterReq")
proto.RegisterType((*PutClusterRsp)(nil), "rpcpb.PutClusterRsp")
proto.RegisterType((*RemoveClusterReq)(nil), "rpcpb.RemoveClusterReq")
proto.RegisterType((*RemoveClusterRsp)(nil), "rpcpb.RemoveClusterRsp")
proto.RegisterType((*GetClusterReq)(nil), "rpcpb.GetClusterReq")
proto.RegisterType((*GetClusterRsp)(nil), "rpcpb.GetClusterRsp")
proto.RegisterType((*GetClusterListReq)(nil), "rpcpb.GetClusterListReq")
proto.RegisterType((*PutServerReq)(nil), "rpcpb.PutServerReq")
proto.RegisterType((*PutServerRsp)(nil), "rpcpb.PutServerRsp")
proto.RegisterType((*RemoveServerReq)(nil), "rpcpb.RemoveServerReq")
proto.RegisterType((*RemoveServerRsp)(nil), "rpcpb.RemoveServerRsp")
proto.RegisterType((*GetServerReq)(nil), "rpcpb.GetServerReq")
proto.RegisterType((*GetServerRsp)(nil), "rpcpb.GetServerRsp")
proto.RegisterType((*GetServerListReq)(nil), "rpcpb.GetServerListReq")
proto.RegisterType((*PutAPIReq)(nil), "rpcpb.PutAPIReq")
proto.RegisterType((*PutAPIRsp)(nil), "rpcpb.PutAPIRsp")
proto.RegisterType((*RemoveAPIReq)(nil), "rpcpb.RemoveAPIReq")
proto.RegisterType((*RemoveAPIRsp)(nil), "rpcpb.RemoveAPIRsp")
proto.RegisterType((*GetAPIReq)(nil), "rpcpb.GetAPIReq")
proto.RegisterType((*GetAPIRsp)(nil), "rpcpb.GetAPIRsp")
proto.RegisterType((*GetAPIListReq)(nil), "rpcpb.GetAPIListReq")
proto.RegisterType((*PutRoutingReq)(nil), "rpcpb.PutRoutingReq")
proto.RegisterType((*PutRoutingRsp)(nil), "rpcpb.PutRoutingRsp")
proto.RegisterType((*RemoveRoutingReq)(nil), "rpcpb.RemoveRoutingReq")
proto.RegisterType((*RemoveRoutingRsp)(nil), "rpcpb.RemoveRoutingRsp")
proto.RegisterType((*GetRoutingReq)(nil), "rpcpb.GetRoutingReq")
proto.RegisterType((*GetRoutingRsp)(nil), "rpcpb.GetRoutingRsp")
proto.RegisterType((*GetRoutingListReq)(nil), "rpcpb.GetRoutingListReq")
proto.RegisterType((*AddBindReq)(nil), "rpcpb.AddBindReq")
proto.RegisterType((*AddBindRsp)(nil), "rpcpb.AddBindRsp")
proto.RegisterType((*RemoveBindReq)(nil), "rpcpb.RemoveBindReq")
proto.RegisterType((*RemoveBindRsp)(nil), "rpcpb.RemoveBindRsp")
proto.RegisterType((*RemoveClusterBindReq)(nil), "rpcpb.RemoveClusterBindReq")
proto.RegisterType((*RemoveClusterBindRsp)(nil), "rpcpb.RemoveClusterBindRsp")
proto.RegisterType((*GetBindServersReq)(nil), "rpcpb.GetBindServersReq")
proto.RegisterType((*GetBindServersRsp)(nil), "rpcpb.GetBindServersRsp")
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// Client API for MetaService service
type MetaServiceClient interface {
PutCluster(ctx context.Context, in *PutClusterReq, opts ...grpc.CallOption) (*PutClusterRsp, error)
RemoveCluster(ctx context.Context, in *RemoveClusterReq, opts ...grpc.CallOption) (*RemoveClusterRsp, error)
GetCluster(ctx context.Context, in *GetClusterReq, opts ...grpc.CallOption) (*GetClusterRsp, error)
GetClusterList(ctx context.Context, in *GetClusterListReq, opts ...grpc.CallOption) (MetaService_GetClusterListClient, error)
PutServer(ctx context.Context, in *PutServerReq, opts ...grpc.CallOption) (*PutServerRsp, error)
RemoveServer(ctx context.Context, in *RemoveServerReq, opts ...grpc.CallOption) (*RemoveServerRsp, error)
GetServer(ctx context.Context, in *GetServerReq, opts ...grpc.CallOption) (*GetServerRsp, error)
GetServerList(ctx context.Context, in *GetServerListReq, opts ...grpc.CallOption) (MetaService_GetServerListClient, error)
PutAPI(ctx context.Context, in *PutAPIReq, opts ...grpc.CallOption) (*PutAPIRsp, error)
RemoveAPI(ctx context.Context, in *RemoveAPIReq, opts ...grpc.CallOption) (*RemoveAPIRsp, error)
GetAPI(ctx context.Context, in *GetAPIReq, opts ...grpc.CallOption) (*GetAPIRsp, error)
GetAPIList(ctx context.Context, in *GetAPIListReq, opts ...grpc.CallOption) (MetaService_GetAPIListClient, error)
PutRouting(ctx context.Context, in *PutRoutingReq, opts ...grpc.CallOption) (*PutRoutingRsp, error)
RemoveRouting(ctx context.Context, in *RemoveRoutingReq, opts ...grpc.CallOption) (*RemoveRoutingRsp, error)
GetRouting(ctx context.Context, in *GetRoutingReq, opts ...grpc.CallOption) (*GetRoutingRsp, error)
GetRoutingList(ctx context.Context, in *GetRoutingListReq, opts ...grpc.CallOption) (MetaService_GetRoutingListClient, error)
AddBind(ctx context.Context, in *AddBindReq, opts ...grpc.CallOption) (*AddBindRsp, error)
RemoveBind(ctx context.Context, in *RemoveBindReq, opts ...grpc.CallOption) (*RemoveBindRsp, error)
RemoveClusterBind(ctx context.Context, in *RemoveClusterBindReq, opts ...grpc.CallOption) (*RemoveClusterBindRsp, error)
GetBindServers(ctx context.Context, in *GetBindServersReq, opts ...grpc.CallOption) (*GetBindServersRsp, error)
}
type metaServiceClient struct {
cc *grpc.ClientConn
}
func NewMetaServiceClient(cc *grpc.ClientConn) MetaServiceClient {
return &metaServiceClient{cc}
}
func (c *metaServiceClient) PutCluster(ctx context.Context, in *PutClusterReq, opts ...grpc.CallOption) (*PutClusterRsp, error) {
out := new(PutClusterRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/PutCluster", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) RemoveCluster(ctx context.Context, in *RemoveClusterReq, opts ...grpc.CallOption) (*RemoveClusterRsp, error) {
out := new(RemoveClusterRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/RemoveCluster", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetCluster(ctx context.Context, in *GetClusterReq, opts ...grpc.CallOption) (*GetClusterRsp, error) {
out := new(GetClusterRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/GetCluster", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetClusterList(ctx context.Context, in *GetClusterListReq, opts ...grpc.CallOption) (MetaService_GetClusterListClient, error) {
stream, err := grpc.NewClientStream(ctx, &_MetaService_serviceDesc.Streams[0], c.cc, "/rpcpb.MetaService/GetClusterList", opts...)
if err != nil {
return nil, err
}
x := &metaServiceGetClusterListClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type MetaService_GetClusterListClient interface {
Recv() (*metapb.Cluster, error)
grpc.ClientStream
}
type metaServiceGetClusterListClient struct {
grpc.ClientStream
}
func (x *metaServiceGetClusterListClient) Recv() (*metapb.Cluster, error) {
m := new(metapb.Cluster)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *metaServiceClient) PutServer(ctx context.Context, in *PutServerReq, opts ...grpc.CallOption) (*PutServerRsp, error) {
out := new(PutServerRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/PutServer", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) RemoveServer(ctx context.Context, in *RemoveServerReq, opts ...grpc.CallOption) (*RemoveServerRsp, error) {
out := new(RemoveServerRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/RemoveServer", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetServer(ctx context.Context, in *GetServerReq, opts ...grpc.CallOption) (*GetServerRsp, error) {
out := new(GetServerRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/GetServer", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetServerList(ctx context.Context, in *GetServerListReq, opts ...grpc.CallOption) (MetaService_GetServerListClient, error) {
stream, err := grpc.NewClientStream(ctx, &_MetaService_serviceDesc.Streams[1], c.cc, "/rpcpb.MetaService/GetServerList", opts...)
if err != nil {
return nil, err
}
x := &metaServiceGetServerListClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type MetaService_GetServerListClient interface {
Recv() (*metapb.Server, error)
grpc.ClientStream
}
type metaServiceGetServerListClient struct {
grpc.ClientStream
}
func (x *metaServiceGetServerListClient) Recv() (*metapb.Server, error) {
m := new(metapb.Server)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *metaServiceClient) PutAPI(ctx context.Context, in *PutAPIReq, opts ...grpc.CallOption) (*PutAPIRsp, error) {
out := new(PutAPIRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/PutAPI", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) RemoveAPI(ctx context.Context, in *RemoveAPIReq, opts ...grpc.CallOption) (*RemoveAPIRsp, error) {
out := new(RemoveAPIRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/RemoveAPI", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetAPI(ctx context.Context, in *GetAPIReq, opts ...grpc.CallOption) (*GetAPIRsp, error) {
out := new(GetAPIRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/GetAPI", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetAPIList(ctx context.Context, in *GetAPIListReq, opts ...grpc.CallOption) (MetaService_GetAPIListClient, error) {
stream, err := grpc.NewClientStream(ctx, &_MetaService_serviceDesc.Streams[2], c.cc, "/rpcpb.MetaService/GetAPIList", opts...)
if err != nil {
return nil, err
}
x := &metaServiceGetAPIListClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type MetaService_GetAPIListClient interface {
Recv() (*metapb.API, error)
grpc.ClientStream
}
type metaServiceGetAPIListClient struct {
grpc.ClientStream
}
func (x *metaServiceGetAPIListClient) Recv() (*metapb.API, error) {
m := new(metapb.API)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *metaServiceClient) PutRouting(ctx context.Context, in *PutRoutingReq, opts ...grpc.CallOption) (*PutRoutingRsp, error) {
out := new(PutRoutingRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/PutRouting", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) RemoveRouting(ctx context.Context, in *RemoveRoutingReq, opts ...grpc.CallOption) (*RemoveRoutingRsp, error) {
out := new(RemoveRoutingRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/RemoveRouting", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetRouting(ctx context.Context, in *GetRoutingReq, opts ...grpc.CallOption) (*GetRoutingRsp, error) {
out := new(GetRoutingRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/GetRouting", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetRoutingList(ctx context.Context, in *GetRoutingListReq, opts ...grpc.CallOption) (MetaService_GetRoutingListClient, error) {
stream, err := grpc.NewClientStream(ctx, &_MetaService_serviceDesc.Streams[3], c.cc, "/rpcpb.MetaService/GetRoutingList", opts...)
if err != nil {
return nil, err
}
x := &metaServiceGetRoutingListClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type MetaService_GetRoutingListClient interface {
Recv() (*metapb.Routing, error)
grpc.ClientStream
}
type metaServiceGetRoutingListClient struct {
grpc.ClientStream
}
func (x *metaServiceGetRoutingListClient) Recv() (*metapb.Routing, error) {
m := new(metapb.Routing)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *metaServiceClient) AddBind(ctx context.Context, in *AddBindReq, opts ...grpc.CallOption) (*AddBindRsp, error) {
out := new(AddBindRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/AddBind", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) RemoveBind(ctx context.Context, in *RemoveBindReq, opts ...grpc.CallOption) (*RemoveBindRsp, error) {
out := new(RemoveBindRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/RemoveBind", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) RemoveClusterBind(ctx context.Context, in *RemoveClusterBindReq, opts ...grpc.CallOption) (*RemoveClusterBindRsp, error) {
out := new(RemoveClusterBindRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/RemoveClusterBind", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metaServiceClient) GetBindServers(ctx context.Context, in *GetBindServersReq, opts ...grpc.CallOption) (*GetBindServersRsp, error) {
out := new(GetBindServersRsp)
err := grpc.Invoke(ctx, "/rpcpb.MetaService/GetBindServers", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Server API for MetaService service
type MetaServiceServer interface {
PutCluster(context.Context, *PutClusterReq) (*PutClusterRsp, error)
RemoveCluster(context.Context, *RemoveClusterReq) (*RemoveClusterRsp, error)
GetCluster(context.Context, *GetClusterReq) (*GetClusterRsp, error)
GetClusterList(*GetClusterListReq, MetaService_GetClusterListServer) error
PutServer(context.Context, *PutServerReq) (*PutServerRsp, error)
RemoveServer(context.Context, *RemoveServerReq) (*RemoveServerRsp, error)
GetServer(context.Context, *GetServerReq) (*GetServerRsp, error)
GetServerList(*GetServerListReq, MetaService_GetServerListServer) error
PutAPI(context.Context, *PutAPIReq) (*PutAPIRsp, error)
RemoveAPI(context.Context, *RemoveAPIReq) (*RemoveAPIRsp, error)
GetAPI(context.Context, *GetAPIReq) (*GetAPIRsp, error)
GetAPIList(*GetAPIListReq, MetaService_GetAPIListServer) error
PutRouting(context.Context, *PutRoutingReq) (*PutRoutingRsp, error)
RemoveRouting(context.Context, *RemoveRoutingReq) (*RemoveRoutingRsp, error)
GetRouting(context.Context, *GetRoutingReq) (*GetRoutingRsp, error)
GetRoutingList(*GetRoutingListReq, MetaService_GetRoutingListServer) error
AddBind(context.Context, *AddBindReq) (*AddBindRsp, error)
RemoveBind(context.Context, *RemoveBindReq) (*RemoveBindRsp, error)
RemoveClusterBind(context.Context, *RemoveClusterBindReq) (*RemoveClusterBindRsp, error)
GetBindServers(context.Context, *GetBindServersReq) (*GetBindServersRsp, error)
}
func RegisterMetaServiceServer(s *grpc.Server, srv MetaServiceServer) {
s.RegisterService(&_MetaService_serviceDesc, srv)
}
func _MetaService_PutCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PutClusterReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).PutCluster(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/PutCluster",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).PutCluster(ctx, req.(*PutClusterReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_RemoveCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveClusterReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).RemoveCluster(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/RemoveCluster",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).RemoveCluster(ctx, req.(*RemoveClusterReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetClusterReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).GetCluster(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/GetCluster",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).GetCluster(ctx, req.(*GetClusterReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetClusterList_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(GetClusterListReq)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(MetaServiceServer).GetClusterList(m, &metaServiceGetClusterListServer{stream})
}
type MetaService_GetClusterListServer interface {
Send(*metapb.Cluster) error
grpc.ServerStream
}
type metaServiceGetClusterListServer struct {
grpc.ServerStream
}
func (x *metaServiceGetClusterListServer) Send(m *metapb.Cluster) error {
return x.ServerStream.SendMsg(m)
}
func _MetaService_PutServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PutServerReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).PutServer(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/PutServer",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).PutServer(ctx, req.(*PutServerReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_RemoveServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveServerReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).RemoveServer(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/RemoveServer",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).RemoveServer(ctx, req.(*RemoveServerReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetServer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetServerReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).GetServer(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/GetServer",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).GetServer(ctx, req.(*GetServerReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetServerList_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(GetServerListReq)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(MetaServiceServer).GetServerList(m, &metaServiceGetServerListServer{stream})
}
type MetaService_GetServerListServer interface {
Send(*metapb.Server) error
grpc.ServerStream
}
type metaServiceGetServerListServer struct {
grpc.ServerStream
}
func (x *metaServiceGetServerListServer) Send(m *metapb.Server) error {
return x.ServerStream.SendMsg(m)
}
func _MetaService_PutAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PutAPIReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).PutAPI(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/PutAPI",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).PutAPI(ctx, req.(*PutAPIReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_RemoveAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveAPIReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).RemoveAPI(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/RemoveAPI",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).RemoveAPI(ctx, req.(*RemoveAPIReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetAPIReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).GetAPI(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/GetAPI",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).GetAPI(ctx, req.(*GetAPIReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetAPIList_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(GetAPIListReq)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(MetaServiceServer).GetAPIList(m, &metaServiceGetAPIListServer{stream})
}
type MetaService_GetAPIListServer interface {
Send(*metapb.API) error
grpc.ServerStream
}
type metaServiceGetAPIListServer struct {
grpc.ServerStream
}
func (x *metaServiceGetAPIListServer) Send(m *metapb.API) error {
return x.ServerStream.SendMsg(m)
}
func _MetaService_PutRouting_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PutRoutingReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).PutRouting(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/PutRouting",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).PutRouting(ctx, req.(*PutRoutingReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_RemoveRouting_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveRoutingReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).RemoveRouting(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/RemoveRouting",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).RemoveRouting(ctx, req.(*RemoveRoutingReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetRouting_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRoutingReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).GetRouting(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/GetRouting",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).GetRouting(ctx, req.(*GetRoutingReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetRoutingList_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(GetRoutingListReq)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(MetaServiceServer).GetRoutingList(m, &metaServiceGetRoutingListServer{stream})
}
type MetaService_GetRoutingListServer interface {
Send(*metapb.Routing) error
grpc.ServerStream
}
type metaServiceGetRoutingListServer struct {
grpc.ServerStream
}
func (x *metaServiceGetRoutingListServer) Send(m *metapb.Routing) error {
return x.ServerStream.SendMsg(m)
}
func _MetaService_AddBind_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AddBindReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).AddBind(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/AddBind",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).AddBind(ctx, req.(*AddBindReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_RemoveBind_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveBindReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).RemoveBind(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/RemoveBind",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).RemoveBind(ctx, req.(*RemoveBindReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_RemoveClusterBind_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveClusterBindReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).RemoveClusterBind(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/RemoveClusterBind",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).RemoveClusterBind(ctx, req.(*RemoveClusterBindReq))
}
return interceptor(ctx, in, info, handler)
}
func _MetaService_GetBindServers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetBindServersReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetaServiceServer).GetBindServers(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/rpcpb.MetaService/GetBindServers",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetaServiceServer).GetBindServers(ctx, req.(*GetBindServersReq))
}
return interceptor(ctx, in, info, handler)
}
var _MetaService_serviceDesc = grpc.ServiceDesc{
ServiceName: "rpcpb.MetaService",
HandlerType: (*MetaServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "PutCluster",
Handler: _MetaService_PutCluster_Handler,
},
{
MethodName: "RemoveCluster",
Handler: _MetaService_RemoveCluster_Handler,
},
{
MethodName: "GetCluster",
Handler: _MetaService_GetCluster_Handler,
},
{
MethodName: "PutServer",
Handler: _MetaService_PutServer_Handler,
},
{
MethodName: "RemoveServer",
Handler: _MetaService_RemoveServer_Handler,
},
{
MethodName: "GetServer",
Handler: _MetaService_GetServer_Handler,
},
{
MethodName: "PutAPI",
Handler: _MetaService_PutAPI_Handler,
},
{
MethodName: "RemoveAPI",
Handler: _MetaService_RemoveAPI_Handler,
},
{
MethodName: "GetAPI",
Handler: _MetaService_GetAPI_Handler,
},
{
MethodName: "PutRouting",
Handler: _MetaService_PutRouting_Handler,
},
{
MethodName: "RemoveRouting",
Handler: _MetaService_RemoveRouting_Handler,
},
{
MethodName: "GetRouting",
Handler: _MetaService_GetRouting_Handler,
},
{
MethodName: "AddBind",
Handler: _MetaService_AddBind_Handler,
},
{
MethodName: "RemoveBind",
Handler: _MetaService_RemoveBind_Handler,
},
{
MethodName: "RemoveClusterBind",
Handler: _MetaService_RemoveClusterBind_Handler,
},
{
MethodName: "GetBindServers",
Handler: _MetaService_GetBindServers_Handler,
},
},
Streams: []grpc.StreamDesc{
{
StreamName: "GetClusterList",
Handler: _MetaService_GetClusterList_Handler,
ServerStreams: true,
},
{
StreamName: "GetServerList",
Handler: _MetaService_GetServerList_Handler,
ServerStreams: true,
},
{
StreamName: "GetAPIList",
Handler: _MetaService_GetAPIList_Handler,
ServerStreams: true,
},
{
StreamName: "GetRoutingList",
Handler: _MetaService_GetRoutingList_Handler,
ServerStreams: true,
},
},
Metadata: "rpcpb.proto",
}
func (m *RpcHeader) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RpcHeader) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(len(m.Uuid)))
i += copy(dAtA[i:], m.Uuid)
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutClusterReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutClusterReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n1, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Cluster.Size()))
n2, err := m.Cluster.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n2
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutClusterRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutClusterRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n3, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n3
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveClusterReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveClusterReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n4, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n4
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveClusterRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveClusterRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n5, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n5
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetClusterReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetClusterReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n6, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n6
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetClusterRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetClusterRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n7, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n7
if m.Cluster != nil {
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Cluster.Size()))
n8, err := m.Cluster.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n8
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetClusterListReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetClusterListReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n9, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n9
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutServerReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutServerReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n10, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n10
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Server.Size()))
n11, err := m.Server.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n11
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutServerRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutServerRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n12, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n12
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveServerReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveServerReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n13, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n13
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveServerRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveServerRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n14, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n14
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetServerReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetServerReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n15, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n15
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetServerRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetServerRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n16, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n16
if m.Server != nil {
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Server.Size()))
n17, err := m.Server.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n17
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetServerListReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetServerListReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n18, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n18
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutAPIReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutAPIReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n19, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n19
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.API.Size()))
n20, err := m.API.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n20
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutAPIRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutAPIRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n21, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n21
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveAPIReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveAPIReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n22, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n22
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveAPIRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveAPIRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n23, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n23
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetAPIReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetAPIReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n24, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n24
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetAPIRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetAPIRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n25, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n25
if m.API != nil {
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.API.Size()))
n26, err := m.API.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n26
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetAPIListReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetAPIListReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n27, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n27
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutRoutingReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutRoutingReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n28, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n28
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Routing.Size()))
n29, err := m.Routing.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n29
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *PutRoutingRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PutRoutingRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n30, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n30
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveRoutingReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveRoutingReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n31, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n31
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveRoutingRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveRoutingRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n32, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n32
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetRoutingReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetRoutingReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n33, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n33
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.ID))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetRoutingRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetRoutingRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n34, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n34
if m.Routing != nil {
dAtA[i] = 0x12
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Routing.Size()))
n35, err := m.Routing.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n35
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetRoutingListReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetRoutingListReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n36, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n36
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *AddBindReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *AddBindReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n37, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n37
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Cluster))
dAtA[i] = 0x18
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Server))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *AddBindRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *AddBindRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n38, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n38
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveBindReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveBindReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n39, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n39
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Cluster))
dAtA[i] = 0x18
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Server))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveBindRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveBindRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n40, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n40
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveClusterBindReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveClusterBindReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n41, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n41
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Cluster))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *RemoveClusterBindRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *RemoveClusterBindRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n42, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n42
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetBindServersReq) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetBindServersReq) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n43, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n43
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Cluster))
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *GetBindServersRsp) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetBindServersRsp) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
dAtA[i] = 0xa
i++
i = encodeVarintRpcpb(dAtA, i, uint64(m.Header.Size()))
n44, err := m.Header.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n44
if len(m.Servers) > 0 {
for _, num := range m.Servers {
dAtA[i] = 0x10
i++
i = encodeVarintRpcpb(dAtA, i, uint64(num))
}
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func encodeFixed64Rpcpb(dAtA []byte, offset int, v uint64) int {
dAtA[offset] = uint8(v)
dAtA[offset+1] = uint8(v >> 8)
dAtA[offset+2] = uint8(v >> 16)
dAtA[offset+3] = uint8(v >> 24)
dAtA[offset+4] = uint8(v >> 32)
dAtA[offset+5] = uint8(v >> 40)
dAtA[offset+6] = uint8(v >> 48)
dAtA[offset+7] = uint8(v >> 56)
return offset + 8
}
func encodeFixed32Rpcpb(dAtA []byte, offset int, v uint32) int {
dAtA[offset] = uint8(v)
dAtA[offset+1] = uint8(v >> 8)
dAtA[offset+2] = uint8(v >> 16)
dAtA[offset+3] = uint8(v >> 24)
return offset + 4
}
func encodeVarintRpcpb(dAtA []byte, offset int, v uint64) int {
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
offset++
}
dAtA[offset] = uint8(v)
return offset + 1
}
func (m *RpcHeader) Size() (n int) {
var l int
_ = l
l = len(m.Uuid)
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutClusterReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
l = m.Cluster.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutClusterRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveClusterReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveClusterRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetClusterReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetClusterRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.Cluster != nil {
l = m.Cluster.Size()
n += 1 + l + sovRpcpb(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetClusterListReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutServerReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
l = m.Server.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutServerRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveServerReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveServerRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetServerReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetServerRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.Server != nil {
l = m.Server.Size()
n += 1 + l + sovRpcpb(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetServerListReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutAPIReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
l = m.API.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutAPIRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveAPIReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveAPIRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetAPIReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetAPIRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.API != nil {
l = m.API.Size()
n += 1 + l + sovRpcpb(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetAPIListReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutRoutingReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
l = m.Routing.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *PutRoutingRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveRoutingReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveRoutingRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetRoutingReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.ID))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetRoutingRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.Routing != nil {
l = m.Routing.Size()
n += 1 + l + sovRpcpb(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetRoutingListReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *AddBindReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.Cluster))
n += 1 + sovRpcpb(uint64(m.Server))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *AddBindRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveBindReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.Cluster))
n += 1 + sovRpcpb(uint64(m.Server))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveBindRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveClusterBindReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.Cluster))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *RemoveClusterBindRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetBindServersReq) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
n += 1 + sovRpcpb(uint64(m.Cluster))
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *GetBindServersRsp) Size() (n int) {
var l int
_ = l
l = m.Header.Size()
n += 1 + l + sovRpcpb(uint64(l))
if len(m.Servers) > 0 {
for _, e := range m.Servers {
n += 1 + sovRpcpb(uint64(e))
}
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func sovRpcpb(x uint64) (n int) {
for {
n++
x >>= 7
if x == 0 {
break
}
}
return n
}
func sozRpcpb(x uint64) (n int) {
return sovRpcpb(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (m *RpcHeader) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RpcHeader: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RpcHeader: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Uuid", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Uuid = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutClusterReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutClusterReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutClusterReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Cluster.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutClusterRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutClusterRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutClusterRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveClusterReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveClusterReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveClusterReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveClusterRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveClusterRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveClusterRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetClusterReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetClusterReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetClusterReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetClusterRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetClusterRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetClusterRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Cluster == nil {
m.Cluster = &metapb.Cluster{}
}
if err := m.Cluster.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetClusterListReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetClusterListReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetClusterListReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutServerReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutServerReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutServerReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Server.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutServerRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutServerRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutServerRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveServerReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveServerReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveServerReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveServerRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveServerRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveServerRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetServerReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetServerReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetServerReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetServerRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetServerRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetServerRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Server == nil {
m.Server = &metapb.Server{}
}
if err := m.Server.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetServerListReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetServerListReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetServerListReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutAPIReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutAPIReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutAPIReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field API", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.API.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutAPIRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutAPIRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutAPIRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveAPIReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveAPIReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveAPIReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveAPIRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveAPIRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveAPIRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetAPIReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetAPIReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetAPIReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetAPIRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetAPIRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetAPIRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field API", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.API == nil {
m.API = &metapb.API{}
}
if err := m.API.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetAPIListReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetAPIListReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetAPIListReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutRoutingReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutRoutingReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutRoutingReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Routing", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Routing.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PutRoutingRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PutRoutingRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PutRoutingRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveRoutingReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveRoutingReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveRoutingReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveRoutingRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveRoutingRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveRoutingRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetRoutingReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetRoutingReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetRoutingReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetRoutingRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetRoutingRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetRoutingRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Routing", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Routing == nil {
m.Routing = &metapb.Routing{}
}
if err := m.Routing.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetRoutingListReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetRoutingListReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetRoutingListReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *AddBindReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: AddBindReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: AddBindReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType)
}
m.Cluster = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Cluster |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
}
m.Server = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Server |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *AddBindRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: AddBindRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: AddBindRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveBindReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveBindReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveBindReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType)
}
m.Cluster = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Cluster |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Server", wireType)
}
m.Server = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Server |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveBindRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveBindRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveBindRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveClusterBindReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveClusterBindReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveClusterBindReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType)
}
m.Cluster = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Cluster |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *RemoveClusterBindRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: RemoveClusterBindRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: RemoveClusterBindRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetBindServersReq) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetBindServersReq: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetBindServersReq: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Cluster", wireType)
}
m.Cluster = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Cluster |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetBindServersRsp) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetBindServersRsp: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetBindServersRsp: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Header", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.Header.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType == 0 {
var v uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Servers = append(m.Servers, v)
} else if wireType == 2 {
var packedLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
packedLen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if packedLen < 0 {
return ErrInvalidLengthRpcpb
}
postIndex := iNdEx + packedLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
for iNdEx < postIndex {
var v uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpcpb
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Servers = append(m.Servers, v)
}
} else {
return fmt.Errorf("proto: wrong wireType = %d for field Servers", wireType)
}
default:
iNdEx = preIndex
skippy, err := skipRpcpb(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpcpb
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func skipRpcpb(dAtA []byte) (n int, err error) {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpcpb
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
wireType := int(wire & 0x7)
switch wireType {
case 0:
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpcpb
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
iNdEx++
if dAtA[iNdEx-1] < 0x80 {
break
}
}
return iNdEx, nil
case 1:
iNdEx += 8
return iNdEx, nil
case 2:
var length int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpcpb
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
length |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
iNdEx += length
if length < 0 {
return 0, ErrInvalidLengthRpcpb
}
return iNdEx, nil
case 3:
for {
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpcpb
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipRpcpb(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
}
return iNdEx, nil
case 4:
return iNdEx, nil
case 5:
iNdEx += 4
return iNdEx, nil
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
}
panic("unreachable")
}
var (
ErrInvalidLengthRpcpb = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowRpcpb = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("rpcpb.proto", fileDescriptorRpcpb) }
var fileDescriptorRpcpb = []byte{
// 889 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x57, 0x5f, 0x6b, 0x13, 0x4b,
0x14, 0xcf, 0x26, 0xb9, 0x29, 0x39, 0xe9, 0x9f, 0x74, 0x1a, 0xee, 0x0d, 0x73, 0x2f, 0x69, 0x59,
0xb8, 0x20, 0x22, 0xa9, 0xd6, 0x87, 0x42, 0x29, 0xd6, 0xa4, 0xd2, 0x1a, 0x50, 0x0c, 0xf1, 0xa1,
0x50, 0x51, 0x48, 0x93, 0x35, 0x2e, 0xb4, 0xcd, 0x9a, 0xec, 0xf6, 0x41, 0xf0, 0x7b, 0xf8, 0x91,
0xfa, 0x58, 0xbf, 0x40, 0xd1, 0xf8, 0x45, 0x64, 0xe7, 0xff, 0x4c, 0xb6, 0x21, 0x9d, 0x76, 0xf1,
0xc9, 0x7a, 0x66, 0xce, 0xef, 0xfc, 0xce, 0x99, 0x93, 0x73, 0x7e, 0x0b, 0xa5, 0x51, 0xd0, 0x0b,
0x4e, 0xea, 0xc1, 0x68, 0x18, 0x0e, 0xd1, 0x5f, 0xe4, 0x3f, 0x78, 0xed, 0xcc, 0x0b, 0xbb, 0xc1,
0xc9, 0x26, 0xfd, 0x87, 0x9e, 0xe1, 0xca, 0x60, 0x38, 0x18, 0x92, 0x3f, 0x37, 0xe3, 0xbf, 0xa8,
0xd5, 0xfd, 0x1f, 0x8a, 0x9d, 0xa0, 0xf7, 0xd2, 0xeb, 0xf6, 0xbd, 0x11, 0xaa, 0x42, 0x3e, 0x8a,
0xfc, 0x7e, 0xd5, 0xd9, 0x70, 0x1e, 0x14, 0x9b, 0xf9, 0xcb, 0xeb, 0xf5, 0x4c, 0x87, 0x58, 0xdc,
0x00, 0x96, 0xda, 0x51, 0xb8, 0x7f, 0x1a, 0x8d, 0x43, 0x6f, 0xd4, 0xf1, 0x3e, 0xa3, 0x3a, 0x14,
0x3e, 0x11, 0x27, 0x72, 0xb9, 0xb4, 0x55, 0xae, 0x53, 0x1e, 0x02, 0x8c, 0xb9, 0xb3, 0x5b, 0x68,
0x13, 0x16, 0x7a, 0xd4, 0xbb, 0x9a, 0x25, 0x0e, 0x2b, 0x75, 0xc6, 0x8e, 0x81, 0xb2, 0xfb, 0xfc,
0x96, 0xfb, 0x4e, 0x8b, 0x38, 0x0e, 0x6e, 0x1d, 0x11, 0x43, 0xd6, 0xef, 0x93, 0x60, 0xf9, 0x26,
0xc4, 0x27, 0x93, 0xeb, 0xf5, 0x6c, 0xeb, 0x45, 0x27, 0xeb, 0xf7, 0xdd, 0x0f, 0x50, 0xee, 0x78,
0x67, 0xc3, 0x0b, 0xef, 0x0e, 0x19, 0xcd, 0xc2, 0x6f, 0x9a, 0xf8, 0xb7, 0xe7, 0x1f, 0x17, 0xe0,
0xd0, 0x0b, 0x53, 0x22, 0x18, 0x68, 0xe0, 0x16, 0xd5, 0x9d, 0xef, 0x3d, 0x1d, 0xf9, 0x9e, 0xfb,
0xb0, 0x2a, 0x23, 0xbe, 0xf2, 0xc7, 0xa1, 0x45, 0x4a, 0xee, 0x29, 0x2c, 0xb6, 0xa3, 0xf0, 0xad,
0x37, 0xba, 0xb0, 0x2b, 0xc9, 0x23, 0x28, 0x8c, 0x89, 0x33, 0x23, 0xbd, 0xcc, 0x49, 0x53, 0x48,
0x7e, 0x9b, 0xde, 0x71, 0x8f, 0xd5, 0x68, 0xf7, 0xdc, 0x81, 0xef, 0x61, 0x85, 0x76, 0x88, 0x7d,
0x32, 0xb3, 0xe0, 0x1b, 0x06, 0xbc, 0x45, 0xff, 0x1d, 0xc3, 0xe2, 0xa1, 0x17, 0xa6, 0x43, 0xef,
0x54, 0xc5, 0xb6, 0xa8, 0xec, 0x3c, 0xef, 0xe8, 0x88, 0x77, 0x6c, 0x42, 0x59, 0x44, 0xb3, 0xed,
0xbc, 0x01, 0x14, 0xdb, 0x51, 0xd8, 0x68, 0xb7, 0x6c, 0x4a, 0xf1, 0x10, 0x72, 0xdd, 0xc0, 0x67,
0x5c, 0x4b, 0x9c, 0x6b, 0xa3, 0xdd, 0x6a, 0x96, 0x58, 0x61, 0x72, 0x31, 0x72, 0x7c, 0xc9, 0x3d,
0x12, 0x81, 0xee, 0xb9, 0xe3, 0x8e, 0x61, 0x91, 0xb6, 0x84, 0x65, 0x12, 0xb3, 0xb0, 0x9f, 0xa9,
0xd8, 0x16, 0xbd, 0x76, 0x04, 0xc5, 0x43, 0x2f, 0x4c, 0x81, 0xd8, 0x40, 0x00, 0x5b, 0x54, 0x73,
0xf6, 0xb3, 0x39, 0xda, 0xb3, 0xed, 0x91, 0x81, 0xda, 0x68, 0xb7, 0x6c, 0x1b, 0x8c, 0x6e, 0xd8,
0xce, 0x30, 0x0a, 0xfd, 0xf3, 0x81, 0xe5, 0x86, 0x1d, 0x51, 0x6f, 0x73, 0x22, 0x33, 0x50, 0xbe,
0x61, 0xd9, 0x2d, 0xb6, 0x61, 0x79, 0xc4, 0xb4, 0x36, 0xec, 0x1d, 0x32, 0x9a, 0x6b, 0xc3, 0xda,
0xf3, 0x67, 0x1b, 0x36, 0x25, 0x82, 0x81, 0x06, 0x6e, 0xb7, 0x61, 0xe7, 0x78, 0x4f, 0x47, 0xbe,
0x27, 0xdd, 0xb0, 0xec, 0xd0, 0xb6, 0x0d, 0xbf, 0x00, 0x34, 0xfa, 0xfd, 0xa6, 0x7f, 0xde, 0xb7,
0x29, 0x48, 0x4d, 0x57, 0x05, 0x79, 0x43, 0xd4, 0xa1, 0xff, 0xc4, 0xdc, 0xce, 0x29, 0xc7, 0x7c,
0x4e, 0xef, 0xca, 0xd8, 0x16, 0xaf, 0xf9, 0x15, 0x96, 0x68, 0x47, 0xfc, 0x19, 0xf2, 0x7b, 0x5a,
0x78, 0x0b, 0xfe, 0x1f, 0xa1, 0xa2, 0x69, 0xc6, 0x94, 0xd2, 0x70, 0x0f, 0x92, 0xe2, 0x58, 0xf0,
0xed, 0x91, 0x76, 0x8b, 0xbd, 0xe9, 0x66, 0x1d, 0xa7, 0x41, 0x76, 0x3a, 0x88, 0xc5, 0x2f, 0xa9,
0x06, 0x0b, 0xf4, 0x91, 0xc6, 0xd5, 0xec, 0x46, 0x8e, 0x05, 0x71, 0x3a, 0xdc, 0xb8, 0xf5, 0xbd,
0x08, 0xa5, 0xd7, 0x5e, 0xd8, 0x8d, 0x43, 0xf8, 0x3d, 0x0f, 0xed, 0x00, 0xc8, 0x4f, 0x0f, 0x54,
0x61, 0xe8, 0xda, 0xf7, 0x0f, 0x4e, 0xb0, 0x8e, 0x03, 0x37, 0x83, 0xf6, 0x79, 0x1b, 0x70, 0xf7,
0x7f, 0x38, 0x39, 0xe3, 0x7b, 0x03, 0x27, 0x1f, 0x10, 0x90, 0x1d, 0x00, 0xa9, 0x95, 0x05, 0x01,
0xed, 0x6b, 0x00, 0x27, 0x58, 0x89, 0xef, 0x1e, 0x2c, 0xeb, 0x3a, 0x1b, 0x55, 0xa7, 0x6e, 0xb2,
0xe1, 0x80, 0x4d, 0xcd, 0xee, 0x66, 0x1e, 0x3b, 0x68, 0x9b, 0x08, 0x10, 0x5a, 0x6e, 0xb4, 0x26,
0xd3, 0x14, 0x4a, 0x10, 0x4f, 0x1b, 0x49, 0xe4, 0xe7, 0x5c, 0x04, 0x30, 0xdf, 0xbf, 0xb5, 0x04,
0xa5, 0x7b, 0xa2, 0x9d, 0x20, 0x6c, 0x93, 0x6d, 0x6d, 0x84, 0x56, 0x45, 0x28, 0x9e, 0x36, 0x12,
0xc7, 0x5d, 0x32, 0x6c, 0xa5, 0xc2, 0x13, 0x55, 0x37, 0x75, 0x1f, 0x36, 0x94, 0x22, 0xc9, 0xb8,
0x0e, 0x05, 0x2a, 0xb9, 0x50, 0x59, 0x66, 0x46, 0xc5, 0x08, 0x36, 0x2c, 0x9c, 0xa6, 0x50, 0x3b,
0x82, 0xa6, 0xaa, 0xad, 0xf0, 0xb4, 0x91, 0x38, 0xd6, 0xa1, 0x40, 0x45, 0x82, 0x08, 0x24, 0x54,
0x0f, 0x36, 0x2c, 0xe4, 0xfe, 0x53, 0xd2, 0x07, 0x4c, 0x54, 0xa8, 0x7d, 0x20, 0x75, 0x06, 0x56,
0x75, 0x09, 0xc9, 0x86, 0x76, 0x2f, 0x5b, 0x03, 0x6a, 0xf7, 0xca, 0x45, 0x87, 0x13, 0xac, 0x7a,
0xf7, 0x72, 0x77, 0xbd, 0x49, 0x15, 0x84, 0xe4, 0x03, 0xa5, 0x7b, 0x4d, 0x02, 0xda, 0xa6, 0xc5,
0x09, 0x56, 0xa5, 0x7b, 0x95, 0x1d, 0xa6, 0x76, 0xaf, 0xbe, 0xda, 0xb0, 0xb9, 0x0f, 0x49, 0xf6,
0x4f, 0x60, 0x81, 0xed, 0x10, 0xb4, 0xca, 0x3c, 0xe5, 0x3e, 0xc3, 0xa6, 0x89, 0xf3, 0x95, 0x93,
0x5b, 0xf0, 0xd5, 0x76, 0x09, 0x4e, 0xb0, 0x12, 0xdf, 0x37, 0xb0, 0x3a, 0x35, 0x4c, 0xd1, 0xbf,
0x49, 0xbf, 0x6c, 0x8e, 0x74, 0xf3, 0x21, 0x01, 0x3c, 0x20, 0x05, 0x50, 0x06, 0x9e, 0x5a, 0x00,
0x7d, 0xd8, 0xe2, 0x1b, 0x4e, 0x62, 0x9c, 0x66, 0xe5, 0xea, 0x67, 0x2d, 0x73, 0x39, 0xa9, 0x39,
0x57, 0x93, 0x9a, 0xf3, 0x63, 0x52, 0x73, 0xbe, 0xfd, 0xaa, 0x65, 0x7e, 0x07, 0x00, 0x00, 0xff,
0xff, 0x6a, 0xd3, 0x0c, 0xff, 0x2d, 0x12, 0x00, 0x00,
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手