Documentation ¶
Overview ¶
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
Index ¶
- Constants
- Variables
- func RegisterMetaServiceServer(s *grpc.Server, srv MetaServiceServer)
- type AddBindReq
- func (*AddBindReq) Descriptor() ([]byte, []int)
- func (m *AddBindReq) GetCluster() uint64
- func (m *AddBindReq) GetHeader() RpcHeader
- func (m *AddBindReq) GetServer() uint64
- func (m *AddBindReq) Marshal() (dAtA []byte, err error)
- func (m *AddBindReq) MarshalTo(dAtA []byte) (int, error)
- func (*AddBindReq) ProtoMessage()
- func (m *AddBindReq) Reset()
- func (m *AddBindReq) Size() (n int)
- func (m *AddBindReq) String() string
- func (m *AddBindReq) Unmarshal(dAtA []byte) error
- type AddBindRsp
- func (*AddBindRsp) Descriptor() ([]byte, []int)
- func (m *AddBindRsp) GetHeader() RpcHeader
- func (m *AddBindRsp) Marshal() (dAtA []byte, err error)
- func (m *AddBindRsp) MarshalTo(dAtA []byte) (int, error)
- func (*AddBindRsp) ProtoMessage()
- func (m *AddBindRsp) Reset()
- func (m *AddBindRsp) Size() (n int)
- func (m *AddBindRsp) String() string
- func (m *AddBindRsp) Unmarshal(dAtA []byte) error
- type GetAPIListReq
- func (*GetAPIListReq) Descriptor() ([]byte, []int)
- func (m *GetAPIListReq) GetHeader() RpcHeader
- func (m *GetAPIListReq) Marshal() (dAtA []byte, err error)
- func (m *GetAPIListReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetAPIListReq) ProtoMessage()
- func (m *GetAPIListReq) Reset()
- func (m *GetAPIListReq) Size() (n int)
- func (m *GetAPIListReq) String() string
- func (m *GetAPIListReq) Unmarshal(dAtA []byte) error
- type GetAPIReq
- func (*GetAPIReq) Descriptor() ([]byte, []int)
- func (m *GetAPIReq) GetHeader() RpcHeader
- func (m *GetAPIReq) GetID() uint64
- func (m *GetAPIReq) Marshal() (dAtA []byte, err error)
- func (m *GetAPIReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetAPIReq) ProtoMessage()
- func (m *GetAPIReq) Reset()
- func (m *GetAPIReq) Size() (n int)
- func (m *GetAPIReq) String() string
- func (m *GetAPIReq) Unmarshal(dAtA []byte) error
- type GetAPIRsp
- func (*GetAPIRsp) Descriptor() ([]byte, []int)
- func (m *GetAPIRsp) GetAPI() *metapb.API
- func (m *GetAPIRsp) GetHeader() RpcHeader
- func (m *GetAPIRsp) Marshal() (dAtA []byte, err error)
- func (m *GetAPIRsp) MarshalTo(dAtA []byte) (int, error)
- func (*GetAPIRsp) ProtoMessage()
- func (m *GetAPIRsp) Reset()
- func (m *GetAPIRsp) Size() (n int)
- func (m *GetAPIRsp) String() string
- func (m *GetAPIRsp) Unmarshal(dAtA []byte) error
- type GetBindServersReq
- func (*GetBindServersReq) Descriptor() ([]byte, []int)
- func (m *GetBindServersReq) GetCluster() uint64
- func (m *GetBindServersReq) GetHeader() RpcHeader
- func (m *GetBindServersReq) Marshal() (dAtA []byte, err error)
- func (m *GetBindServersReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetBindServersReq) ProtoMessage()
- func (m *GetBindServersReq) Reset()
- func (m *GetBindServersReq) Size() (n int)
- func (m *GetBindServersReq) String() string
- func (m *GetBindServersReq) Unmarshal(dAtA []byte) error
- type GetBindServersRsp
- func (*GetBindServersRsp) Descriptor() ([]byte, []int)
- func (m *GetBindServersRsp) GetHeader() RpcHeader
- func (m *GetBindServersRsp) GetServers() []uint64
- func (m *GetBindServersRsp) Marshal() (dAtA []byte, err error)
- func (m *GetBindServersRsp) MarshalTo(dAtA []byte) (int, error)
- func (*GetBindServersRsp) ProtoMessage()
- func (m *GetBindServersRsp) Reset()
- func (m *GetBindServersRsp) Size() (n int)
- func (m *GetBindServersRsp) String() string
- func (m *GetBindServersRsp) Unmarshal(dAtA []byte) error
- type GetClusterListReq
- func (*GetClusterListReq) Descriptor() ([]byte, []int)
- func (m *GetClusterListReq) GetHeader() RpcHeader
- func (m *GetClusterListReq) Marshal() (dAtA []byte, err error)
- func (m *GetClusterListReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetClusterListReq) ProtoMessage()
- func (m *GetClusterListReq) Reset()
- func (m *GetClusterListReq) Size() (n int)
- func (m *GetClusterListReq) String() string
- func (m *GetClusterListReq) Unmarshal(dAtA []byte) error
- type GetClusterReq
- func (*GetClusterReq) Descriptor() ([]byte, []int)
- func (m *GetClusterReq) GetHeader() RpcHeader
- func (m *GetClusterReq) GetID() uint64
- func (m *GetClusterReq) Marshal() (dAtA []byte, err error)
- func (m *GetClusterReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetClusterReq) ProtoMessage()
- func (m *GetClusterReq) Reset()
- func (m *GetClusterReq) Size() (n int)
- func (m *GetClusterReq) String() string
- func (m *GetClusterReq) Unmarshal(dAtA []byte) error
- type GetClusterRsp
- func (*GetClusterRsp) Descriptor() ([]byte, []int)
- func (m *GetClusterRsp) GetCluster() *metapb.Cluster
- func (m *GetClusterRsp) GetHeader() RpcHeader
- func (m *GetClusterRsp) Marshal() (dAtA []byte, err error)
- func (m *GetClusterRsp) MarshalTo(dAtA []byte) (int, error)
- func (*GetClusterRsp) ProtoMessage()
- func (m *GetClusterRsp) Reset()
- func (m *GetClusterRsp) Size() (n int)
- func (m *GetClusterRsp) String() string
- func (m *GetClusterRsp) Unmarshal(dAtA []byte) error
- type GetRoutingListReq
- func (*GetRoutingListReq) Descriptor() ([]byte, []int)
- func (m *GetRoutingListReq) GetHeader() RpcHeader
- func (m *GetRoutingListReq) Marshal() (dAtA []byte, err error)
- func (m *GetRoutingListReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetRoutingListReq) ProtoMessage()
- func (m *GetRoutingListReq) Reset()
- func (m *GetRoutingListReq) Size() (n int)
- func (m *GetRoutingListReq) String() string
- func (m *GetRoutingListReq) Unmarshal(dAtA []byte) error
- type GetRoutingReq
- func (*GetRoutingReq) Descriptor() ([]byte, []int)
- func (m *GetRoutingReq) GetHeader() RpcHeader
- func (m *GetRoutingReq) GetID() uint64
- func (m *GetRoutingReq) Marshal() (dAtA []byte, err error)
- func (m *GetRoutingReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetRoutingReq) ProtoMessage()
- func (m *GetRoutingReq) Reset()
- func (m *GetRoutingReq) Size() (n int)
- func (m *GetRoutingReq) String() string
- func (m *GetRoutingReq) Unmarshal(dAtA []byte) error
- type GetRoutingRsp
- func (*GetRoutingRsp) Descriptor() ([]byte, []int)
- func (m *GetRoutingRsp) GetHeader() RpcHeader
- func (m *GetRoutingRsp) GetRouting() *metapb.Routing
- func (m *GetRoutingRsp) Marshal() (dAtA []byte, err error)
- func (m *GetRoutingRsp) MarshalTo(dAtA []byte) (int, error)
- func (*GetRoutingRsp) ProtoMessage()
- func (m *GetRoutingRsp) Reset()
- func (m *GetRoutingRsp) Size() (n int)
- func (m *GetRoutingRsp) String() string
- func (m *GetRoutingRsp) Unmarshal(dAtA []byte) error
- type GetServerListReq
- func (*GetServerListReq) Descriptor() ([]byte, []int)
- func (m *GetServerListReq) GetHeader() RpcHeader
- func (m *GetServerListReq) Marshal() (dAtA []byte, err error)
- func (m *GetServerListReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetServerListReq) ProtoMessage()
- func (m *GetServerListReq) Reset()
- func (m *GetServerListReq) Size() (n int)
- func (m *GetServerListReq) String() string
- func (m *GetServerListReq) Unmarshal(dAtA []byte) error
- type GetServerReq
- func (*GetServerReq) Descriptor() ([]byte, []int)
- func (m *GetServerReq) GetHeader() RpcHeader
- func (m *GetServerReq) GetID() uint64
- func (m *GetServerReq) Marshal() (dAtA []byte, err error)
- func (m *GetServerReq) MarshalTo(dAtA []byte) (int, error)
- func (*GetServerReq) ProtoMessage()
- func (m *GetServerReq) Reset()
- func (m *GetServerReq) Size() (n int)
- func (m *GetServerReq) String() string
- func (m *GetServerReq) Unmarshal(dAtA []byte) error
- type GetServerRsp
- func (*GetServerRsp) Descriptor() ([]byte, []int)
- func (m *GetServerRsp) GetHeader() RpcHeader
- func (m *GetServerRsp) GetServer() *metapb.Server
- func (m *GetServerRsp) Marshal() (dAtA []byte, err error)
- func (m *GetServerRsp) MarshalTo(dAtA []byte) (int, error)
- func (*GetServerRsp) ProtoMessage()
- func (m *GetServerRsp) Reset()
- func (m *GetServerRsp) Size() (n int)
- func (m *GetServerRsp) String() string
- func (m *GetServerRsp) Unmarshal(dAtA []byte) error
- type MetaServiceClient
- type MetaServiceServer
- type MetaService_GetAPIListClient
- type MetaService_GetAPIListServer
- type MetaService_GetClusterListClient
- type MetaService_GetClusterListServer
- type MetaService_GetRoutingListClient
- type MetaService_GetRoutingListServer
- type MetaService_GetServerListClient
- type MetaService_GetServerListServer
- type PutAPIReq
- func (*PutAPIReq) Descriptor() ([]byte, []int)
- func (m *PutAPIReq) GetAPI() metapb.API
- func (m *PutAPIReq) GetHeader() RpcHeader
- func (m *PutAPIReq) Marshal() (dAtA []byte, err error)
- func (m *PutAPIReq) MarshalTo(dAtA []byte) (int, error)
- func (*PutAPIReq) ProtoMessage()
- func (m *PutAPIReq) Reset()
- func (m *PutAPIReq) Size() (n int)
- func (m *PutAPIReq) String() string
- func (m *PutAPIReq) Unmarshal(dAtA []byte) error
- type PutAPIRsp
- func (*PutAPIRsp) Descriptor() ([]byte, []int)
- func (m *PutAPIRsp) GetHeader() RpcHeader
- func (m *PutAPIRsp) GetID() uint64
- func (m *PutAPIRsp) Marshal() (dAtA []byte, err error)
- func (m *PutAPIRsp) MarshalTo(dAtA []byte) (int, error)
- func (*PutAPIRsp) ProtoMessage()
- func (m *PutAPIRsp) Reset()
- func (m *PutAPIRsp) Size() (n int)
- func (m *PutAPIRsp) String() string
- func (m *PutAPIRsp) Unmarshal(dAtA []byte) error
- type PutClusterReq
- func (*PutClusterReq) Descriptor() ([]byte, []int)
- func (m *PutClusterReq) GetCluster() metapb.Cluster
- func (m *PutClusterReq) GetHeader() RpcHeader
- func (m *PutClusterReq) Marshal() (dAtA []byte, err error)
- func (m *PutClusterReq) MarshalTo(dAtA []byte) (int, error)
- func (*PutClusterReq) ProtoMessage()
- func (m *PutClusterReq) Reset()
- func (m *PutClusterReq) Size() (n int)
- func (m *PutClusterReq) String() string
- func (m *PutClusterReq) Unmarshal(dAtA []byte) error
- type PutClusterRsp
- func (*PutClusterRsp) Descriptor() ([]byte, []int)
- func (m *PutClusterRsp) GetHeader() RpcHeader
- func (m *PutClusterRsp) GetID() uint64
- func (m *PutClusterRsp) Marshal() (dAtA []byte, err error)
- func (m *PutClusterRsp) MarshalTo(dAtA []byte) (int, error)
- func (*PutClusterRsp) ProtoMessage()
- func (m *PutClusterRsp) Reset()
- func (m *PutClusterRsp) Size() (n int)
- func (m *PutClusterRsp) String() string
- func (m *PutClusterRsp) Unmarshal(dAtA []byte) error
- type PutRoutingReq
- func (*PutRoutingReq) Descriptor() ([]byte, []int)
- func (m *PutRoutingReq) GetHeader() RpcHeader
- func (m *PutRoutingReq) GetRouting() metapb.Routing
- func (m *PutRoutingReq) Marshal() (dAtA []byte, err error)
- func (m *PutRoutingReq) MarshalTo(dAtA []byte) (int, error)
- func (*PutRoutingReq) ProtoMessage()
- func (m *PutRoutingReq) Reset()
- func (m *PutRoutingReq) Size() (n int)
- func (m *PutRoutingReq) String() string
- func (m *PutRoutingReq) Unmarshal(dAtA []byte) error
- type PutRoutingRsp
- func (*PutRoutingRsp) Descriptor() ([]byte, []int)
- func (m *PutRoutingRsp) GetHeader() RpcHeader
- func (m *PutRoutingRsp) GetID() uint64
- func (m *PutRoutingRsp) Marshal() (dAtA []byte, err error)
- func (m *PutRoutingRsp) MarshalTo(dAtA []byte) (int, error)
- func (*PutRoutingRsp) ProtoMessage()
- func (m *PutRoutingRsp) Reset()
- func (m *PutRoutingRsp) Size() (n int)
- func (m *PutRoutingRsp) String() string
- func (m *PutRoutingRsp) Unmarshal(dAtA []byte) error
- type PutServerReq
- func (*PutServerReq) Descriptor() ([]byte, []int)
- func (m *PutServerReq) GetHeader() RpcHeader
- func (m *PutServerReq) GetServer() metapb.Server
- func (m *PutServerReq) Marshal() (dAtA []byte, err error)
- func (m *PutServerReq) MarshalTo(dAtA []byte) (int, error)
- func (*PutServerReq) ProtoMessage()
- func (m *PutServerReq) Reset()
- func (m *PutServerReq) Size() (n int)
- func (m *PutServerReq) String() string
- func (m *PutServerReq) Unmarshal(dAtA []byte) error
- type PutServerRsp
- func (*PutServerRsp) Descriptor() ([]byte, []int)
- func (m *PutServerRsp) GetHeader() RpcHeader
- func (m *PutServerRsp) GetID() uint64
- func (m *PutServerRsp) Marshal() (dAtA []byte, err error)
- func (m *PutServerRsp) MarshalTo(dAtA []byte) (int, error)
- func (*PutServerRsp) ProtoMessage()
- func (m *PutServerRsp) Reset()
- func (m *PutServerRsp) Size() (n int)
- func (m *PutServerRsp) String() string
- func (m *PutServerRsp) Unmarshal(dAtA []byte) error
- type RemoveAPIReq
- func (*RemoveAPIReq) Descriptor() ([]byte, []int)
- func (m *RemoveAPIReq) GetHeader() RpcHeader
- func (m *RemoveAPIReq) GetID() uint64
- func (m *RemoveAPIReq) Marshal() (dAtA []byte, err error)
- func (m *RemoveAPIReq) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveAPIReq) ProtoMessage()
- func (m *RemoveAPIReq) Reset()
- func (m *RemoveAPIReq) Size() (n int)
- func (m *RemoveAPIReq) String() string
- func (m *RemoveAPIReq) Unmarshal(dAtA []byte) error
- type RemoveAPIRsp
- func (*RemoveAPIRsp) Descriptor() ([]byte, []int)
- func (m *RemoveAPIRsp) GetHeader() RpcHeader
- func (m *RemoveAPIRsp) Marshal() (dAtA []byte, err error)
- func (m *RemoveAPIRsp) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveAPIRsp) ProtoMessage()
- func (m *RemoveAPIRsp) Reset()
- func (m *RemoveAPIRsp) Size() (n int)
- func (m *RemoveAPIRsp) String() string
- func (m *RemoveAPIRsp) Unmarshal(dAtA []byte) error
- type RemoveBindReq
- func (*RemoveBindReq) Descriptor() ([]byte, []int)
- func (m *RemoveBindReq) GetCluster() uint64
- func (m *RemoveBindReq) GetHeader() RpcHeader
- func (m *RemoveBindReq) GetServer() uint64
- func (m *RemoveBindReq) Marshal() (dAtA []byte, err error)
- func (m *RemoveBindReq) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveBindReq) ProtoMessage()
- func (m *RemoveBindReq) Reset()
- func (m *RemoveBindReq) Size() (n int)
- func (m *RemoveBindReq) String() string
- func (m *RemoveBindReq) Unmarshal(dAtA []byte) error
- type RemoveBindRsp
- func (*RemoveBindRsp) Descriptor() ([]byte, []int)
- func (m *RemoveBindRsp) GetHeader() RpcHeader
- func (m *RemoveBindRsp) Marshal() (dAtA []byte, err error)
- func (m *RemoveBindRsp) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveBindRsp) ProtoMessage()
- func (m *RemoveBindRsp) Reset()
- func (m *RemoveBindRsp) Size() (n int)
- func (m *RemoveBindRsp) String() string
- func (m *RemoveBindRsp) Unmarshal(dAtA []byte) error
- type RemoveClusterBindReq
- func (*RemoveClusterBindReq) Descriptor() ([]byte, []int)
- func (m *RemoveClusterBindReq) GetCluster() uint64
- func (m *RemoveClusterBindReq) GetHeader() RpcHeader
- func (m *RemoveClusterBindReq) Marshal() (dAtA []byte, err error)
- func (m *RemoveClusterBindReq) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveClusterBindReq) ProtoMessage()
- func (m *RemoveClusterBindReq) Reset()
- func (m *RemoveClusterBindReq) Size() (n int)
- func (m *RemoveClusterBindReq) String() string
- func (m *RemoveClusterBindReq) Unmarshal(dAtA []byte) error
- type RemoveClusterBindRsp
- func (*RemoveClusterBindRsp) Descriptor() ([]byte, []int)
- func (m *RemoveClusterBindRsp) GetHeader() RpcHeader
- func (m *RemoveClusterBindRsp) Marshal() (dAtA []byte, err error)
- func (m *RemoveClusterBindRsp) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveClusterBindRsp) ProtoMessage()
- func (m *RemoveClusterBindRsp) Reset()
- func (m *RemoveClusterBindRsp) Size() (n int)
- func (m *RemoveClusterBindRsp) String() string
- func (m *RemoveClusterBindRsp) Unmarshal(dAtA []byte) error
- type RemoveClusterReq
- func (*RemoveClusterReq) Descriptor() ([]byte, []int)
- func (m *RemoveClusterReq) GetHeader() RpcHeader
- func (m *RemoveClusterReq) GetID() uint64
- func (m *RemoveClusterReq) Marshal() (dAtA []byte, err error)
- func (m *RemoveClusterReq) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveClusterReq) ProtoMessage()
- func (m *RemoveClusterReq) Reset()
- func (m *RemoveClusterReq) Size() (n int)
- func (m *RemoveClusterReq) String() string
- func (m *RemoveClusterReq) Unmarshal(dAtA []byte) error
- type RemoveClusterRsp
- func (*RemoveClusterRsp) Descriptor() ([]byte, []int)
- func (m *RemoveClusterRsp) GetHeader() RpcHeader
- func (m *RemoveClusterRsp) Marshal() (dAtA []byte, err error)
- func (m *RemoveClusterRsp) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveClusterRsp) ProtoMessage()
- func (m *RemoveClusterRsp) Reset()
- func (m *RemoveClusterRsp) Size() (n int)
- func (m *RemoveClusterRsp) String() string
- func (m *RemoveClusterRsp) Unmarshal(dAtA []byte) error
- type RemoveRoutingReq
- func (*RemoveRoutingReq) Descriptor() ([]byte, []int)
- func (m *RemoveRoutingReq) GetHeader() RpcHeader
- func (m *RemoveRoutingReq) GetID() uint64
- func (m *RemoveRoutingReq) Marshal() (dAtA []byte, err error)
- func (m *RemoveRoutingReq) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveRoutingReq) ProtoMessage()
- func (m *RemoveRoutingReq) Reset()
- func (m *RemoveRoutingReq) Size() (n int)
- func (m *RemoveRoutingReq) String() string
- func (m *RemoveRoutingReq) Unmarshal(dAtA []byte) error
- type RemoveRoutingRsp
- func (*RemoveRoutingRsp) Descriptor() ([]byte, []int)
- func (m *RemoveRoutingRsp) GetHeader() RpcHeader
- func (m *RemoveRoutingRsp) Marshal() (dAtA []byte, err error)
- func (m *RemoveRoutingRsp) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveRoutingRsp) ProtoMessage()
- func (m *RemoveRoutingRsp) Reset()
- func (m *RemoveRoutingRsp) Size() (n int)
- func (m *RemoveRoutingRsp) String() string
- func (m *RemoveRoutingRsp) Unmarshal(dAtA []byte) error
- type RemoveServerReq
- func (*RemoveServerReq) Descriptor() ([]byte, []int)
- func (m *RemoveServerReq) GetHeader() RpcHeader
- func (m *RemoveServerReq) GetID() uint64
- func (m *RemoveServerReq) Marshal() (dAtA []byte, err error)
- func (m *RemoveServerReq) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveServerReq) ProtoMessage()
- func (m *RemoveServerReq) Reset()
- func (m *RemoveServerReq) Size() (n int)
- func (m *RemoveServerReq) String() string
- func (m *RemoveServerReq) Unmarshal(dAtA []byte) error
- type RemoveServerRsp
- func (*RemoveServerRsp) Descriptor() ([]byte, []int)
- func (m *RemoveServerRsp) GetHeader() RpcHeader
- func (m *RemoveServerRsp) Marshal() (dAtA []byte, err error)
- func (m *RemoveServerRsp) MarshalTo(dAtA []byte) (int, error)
- func (*RemoveServerRsp) ProtoMessage()
- func (m *RemoveServerRsp) Reset()
- func (m *RemoveServerRsp) Size() (n int)
- func (m *RemoveServerRsp) String() string
- func (m *RemoveServerRsp) Unmarshal(dAtA []byte) error
- type RpcHeader
- func (*RpcHeader) Descriptor() ([]byte, []int)
- func (m *RpcHeader) GetUuid() string
- func (m *RpcHeader) Marshal() (dAtA []byte, err error)
- func (m *RpcHeader) MarshalTo(dAtA []byte) (int, error)
- func (*RpcHeader) ProtoMessage()
- func (m *RpcHeader) Reset()
- func (m *RpcHeader) Size() (n int)
- func (m *RpcHeader) String() string
- func (m *RpcHeader) Unmarshal(dAtA []byte) error
Constants ¶
View Source
const (
// ServiceMeta meta service name
ServiceMeta = "gateway-service-meta"
)
Variables ¶
View Source
var ( ErrInvalidLengthRpcpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRpcpb = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterMetaServiceServer ¶
func RegisterMetaServiceServer(s *grpc.Server, srv MetaServiceServer)
Types ¶
type AddBindReq ¶
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 (*AddBindReq) Descriptor ¶
func (*AddBindReq) Descriptor() ([]byte, []int)
func (*AddBindReq) GetCluster ¶
func (m *AddBindReq) GetCluster() uint64
func (*AddBindReq) GetHeader ¶
func (m *AddBindReq) GetHeader() RpcHeader
func (*AddBindReq) GetServer ¶
func (m *AddBindReq) GetServer() uint64
func (*AddBindReq) Marshal ¶
func (m *AddBindReq) Marshal() (dAtA []byte, err error)
func (*AddBindReq) ProtoMessage ¶
func (*AddBindReq) ProtoMessage()
func (*AddBindReq) Reset ¶
func (m *AddBindReq) Reset()
func (*AddBindReq) Size ¶
func (m *AddBindReq) Size() (n int)
func (*AddBindReq) String ¶
func (m *AddBindReq) String() string
func (*AddBindReq) Unmarshal ¶
func (m *AddBindReq) Unmarshal(dAtA []byte) error
type AddBindRsp ¶
type AddBindRsp struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*AddBindRsp) Descriptor ¶
func (*AddBindRsp) Descriptor() ([]byte, []int)
func (*AddBindRsp) GetHeader ¶
func (m *AddBindRsp) GetHeader() RpcHeader
func (*AddBindRsp) Marshal ¶
func (m *AddBindRsp) Marshal() (dAtA []byte, err error)
func (*AddBindRsp) ProtoMessage ¶
func (*AddBindRsp) ProtoMessage()
func (*AddBindRsp) Reset ¶
func (m *AddBindRsp) Reset()
func (*AddBindRsp) Size ¶
func (m *AddBindRsp) Size() (n int)
func (*AddBindRsp) String ¶
func (m *AddBindRsp) String() string
func (*AddBindRsp) Unmarshal ¶
func (m *AddBindRsp) Unmarshal(dAtA []byte) error
type GetAPIListReq ¶
type GetAPIListReq struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*GetAPIListReq) Descriptor ¶
func (*GetAPIListReq) Descriptor() ([]byte, []int)
func (*GetAPIListReq) GetHeader ¶
func (m *GetAPIListReq) GetHeader() RpcHeader
func (*GetAPIListReq) Marshal ¶
func (m *GetAPIListReq) Marshal() (dAtA []byte, err error)
func (*GetAPIListReq) ProtoMessage ¶
func (*GetAPIListReq) ProtoMessage()
func (*GetAPIListReq) Reset ¶
func (m *GetAPIListReq) Reset()
func (*GetAPIListReq) Size ¶
func (m *GetAPIListReq) Size() (n int)
func (*GetAPIListReq) String ¶
func (m *GetAPIListReq) String() string
func (*GetAPIListReq) Unmarshal ¶
func (m *GetAPIListReq) Unmarshal(dAtA []byte) error
type GetAPIReq ¶
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 (*GetAPIReq) Descriptor ¶
func (*GetAPIReq) ProtoMessage ¶
func (*GetAPIReq) ProtoMessage()
type GetAPIRsp ¶
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 (*GetAPIRsp) Descriptor ¶
func (*GetAPIRsp) ProtoMessage ¶
func (*GetAPIRsp) ProtoMessage()
type GetBindServersReq ¶
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 (*GetBindServersReq) Descriptor ¶
func (*GetBindServersReq) Descriptor() ([]byte, []int)
func (*GetBindServersReq) GetCluster ¶
func (m *GetBindServersReq) GetCluster() uint64
func (*GetBindServersReq) GetHeader ¶
func (m *GetBindServersReq) GetHeader() RpcHeader
func (*GetBindServersReq) Marshal ¶
func (m *GetBindServersReq) Marshal() (dAtA []byte, err error)
func (*GetBindServersReq) MarshalTo ¶
func (m *GetBindServersReq) MarshalTo(dAtA []byte) (int, error)
func (*GetBindServersReq) ProtoMessage ¶
func (*GetBindServersReq) ProtoMessage()
func (*GetBindServersReq) Reset ¶
func (m *GetBindServersReq) Reset()
func (*GetBindServersReq) Size ¶
func (m *GetBindServersReq) Size() (n int)
func (*GetBindServersReq) String ¶
func (m *GetBindServersReq) String() string
func (*GetBindServersReq) Unmarshal ¶
func (m *GetBindServersReq) Unmarshal(dAtA []byte) error
type GetBindServersRsp ¶
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 (*GetBindServersRsp) Descriptor ¶
func (*GetBindServersRsp) Descriptor() ([]byte, []int)
func (*GetBindServersRsp) GetHeader ¶
func (m *GetBindServersRsp) GetHeader() RpcHeader
func (*GetBindServersRsp) GetServers ¶
func (m *GetBindServersRsp) GetServers() []uint64
func (*GetBindServersRsp) Marshal ¶
func (m *GetBindServersRsp) Marshal() (dAtA []byte, err error)
func (*GetBindServersRsp) MarshalTo ¶
func (m *GetBindServersRsp) MarshalTo(dAtA []byte) (int, error)
func (*GetBindServersRsp) ProtoMessage ¶
func (*GetBindServersRsp) ProtoMessage()
func (*GetBindServersRsp) Reset ¶
func (m *GetBindServersRsp) Reset()
func (*GetBindServersRsp) Size ¶
func (m *GetBindServersRsp) Size() (n int)
func (*GetBindServersRsp) String ¶
func (m *GetBindServersRsp) String() string
func (*GetBindServersRsp) Unmarshal ¶
func (m *GetBindServersRsp) Unmarshal(dAtA []byte) error
type GetClusterListReq ¶
type GetClusterListReq struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*GetClusterListReq) Descriptor ¶
func (*GetClusterListReq) Descriptor() ([]byte, []int)
func (*GetClusterListReq) GetHeader ¶
func (m *GetClusterListReq) GetHeader() RpcHeader
func (*GetClusterListReq) Marshal ¶
func (m *GetClusterListReq) Marshal() (dAtA []byte, err error)
func (*GetClusterListReq) MarshalTo ¶
func (m *GetClusterListReq) MarshalTo(dAtA []byte) (int, error)
func (*GetClusterListReq) ProtoMessage ¶
func (*GetClusterListReq) ProtoMessage()
func (*GetClusterListReq) Reset ¶
func (m *GetClusterListReq) Reset()
func (*GetClusterListReq) Size ¶
func (m *GetClusterListReq) Size() (n int)
func (*GetClusterListReq) String ¶
func (m *GetClusterListReq) String() string
func (*GetClusterListReq) Unmarshal ¶
func (m *GetClusterListReq) Unmarshal(dAtA []byte) error
type GetClusterReq ¶
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 (*GetClusterReq) Descriptor ¶
func (*GetClusterReq) Descriptor() ([]byte, []int)
func (*GetClusterReq) GetHeader ¶
func (m *GetClusterReq) GetHeader() RpcHeader
func (*GetClusterReq) GetID ¶
func (m *GetClusterReq) GetID() uint64
func (*GetClusterReq) Marshal ¶
func (m *GetClusterReq) Marshal() (dAtA []byte, err error)
func (*GetClusterReq) ProtoMessage ¶
func (*GetClusterReq) ProtoMessage()
func (*GetClusterReq) Reset ¶
func (m *GetClusterReq) Reset()
func (*GetClusterReq) Size ¶
func (m *GetClusterReq) Size() (n int)
func (*GetClusterReq) String ¶
func (m *GetClusterReq) String() string
func (*GetClusterReq) Unmarshal ¶
func (m *GetClusterReq) Unmarshal(dAtA []byte) error
type GetClusterRsp ¶
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 (*GetClusterRsp) Descriptor ¶
func (*GetClusterRsp) Descriptor() ([]byte, []int)
func (*GetClusterRsp) GetCluster ¶
func (m *GetClusterRsp) GetCluster() *metapb.Cluster
func (*GetClusterRsp) GetHeader ¶
func (m *GetClusterRsp) GetHeader() RpcHeader
func (*GetClusterRsp) Marshal ¶
func (m *GetClusterRsp) Marshal() (dAtA []byte, err error)
func (*GetClusterRsp) ProtoMessage ¶
func (*GetClusterRsp) ProtoMessage()
func (*GetClusterRsp) Reset ¶
func (m *GetClusterRsp) Reset()
func (*GetClusterRsp) Size ¶
func (m *GetClusterRsp) Size() (n int)
func (*GetClusterRsp) String ¶
func (m *GetClusterRsp) String() string
func (*GetClusterRsp) Unmarshal ¶
func (m *GetClusterRsp) Unmarshal(dAtA []byte) error
type GetRoutingListReq ¶
type GetRoutingListReq struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*GetRoutingListReq) Descriptor ¶
func (*GetRoutingListReq) Descriptor() ([]byte, []int)
func (*GetRoutingListReq) GetHeader ¶
func (m *GetRoutingListReq) GetHeader() RpcHeader
func (*GetRoutingListReq) Marshal ¶
func (m *GetRoutingListReq) Marshal() (dAtA []byte, err error)
func (*GetRoutingListReq) MarshalTo ¶
func (m *GetRoutingListReq) MarshalTo(dAtA []byte) (int, error)
func (*GetRoutingListReq) ProtoMessage ¶
func (*GetRoutingListReq) ProtoMessage()
func (*GetRoutingListReq) Reset ¶
func (m *GetRoutingListReq) Reset()
func (*GetRoutingListReq) Size ¶
func (m *GetRoutingListReq) Size() (n int)
func (*GetRoutingListReq) String ¶
func (m *GetRoutingListReq) String() string
func (*GetRoutingListReq) Unmarshal ¶
func (m *GetRoutingListReq) Unmarshal(dAtA []byte) error
type GetRoutingReq ¶
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 (*GetRoutingReq) Descriptor ¶
func (*GetRoutingReq) Descriptor() ([]byte, []int)
func (*GetRoutingReq) GetHeader ¶
func (m *GetRoutingReq) GetHeader() RpcHeader
func (*GetRoutingReq) GetID ¶
func (m *GetRoutingReq) GetID() uint64
func (*GetRoutingReq) Marshal ¶
func (m *GetRoutingReq) Marshal() (dAtA []byte, err error)
func (*GetRoutingReq) ProtoMessage ¶
func (*GetRoutingReq) ProtoMessage()
func (*GetRoutingReq) Reset ¶
func (m *GetRoutingReq) Reset()
func (*GetRoutingReq) Size ¶
func (m *GetRoutingReq) Size() (n int)
func (*GetRoutingReq) String ¶
func (m *GetRoutingReq) String() string
func (*GetRoutingReq) Unmarshal ¶
func (m *GetRoutingReq) Unmarshal(dAtA []byte) error
type GetRoutingRsp ¶
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 (*GetRoutingRsp) Descriptor ¶
func (*GetRoutingRsp) Descriptor() ([]byte, []int)
func (*GetRoutingRsp) GetHeader ¶
func (m *GetRoutingRsp) GetHeader() RpcHeader
func (*GetRoutingRsp) GetRouting ¶
func (m *GetRoutingRsp) GetRouting() *metapb.Routing
func (*GetRoutingRsp) Marshal ¶
func (m *GetRoutingRsp) Marshal() (dAtA []byte, err error)
func (*GetRoutingRsp) ProtoMessage ¶
func (*GetRoutingRsp) ProtoMessage()
func (*GetRoutingRsp) Reset ¶
func (m *GetRoutingRsp) Reset()
func (*GetRoutingRsp) Size ¶
func (m *GetRoutingRsp) Size() (n int)
func (*GetRoutingRsp) String ¶
func (m *GetRoutingRsp) String() string
func (*GetRoutingRsp) Unmarshal ¶
func (m *GetRoutingRsp) Unmarshal(dAtA []byte) error
type GetServerListReq ¶
type GetServerListReq struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*GetServerListReq) Descriptor ¶
func (*GetServerListReq) Descriptor() ([]byte, []int)
func (*GetServerListReq) GetHeader ¶
func (m *GetServerListReq) GetHeader() RpcHeader
func (*GetServerListReq) Marshal ¶
func (m *GetServerListReq) Marshal() (dAtA []byte, err error)
func (*GetServerListReq) ProtoMessage ¶
func (*GetServerListReq) ProtoMessage()
func (*GetServerListReq) Reset ¶
func (m *GetServerListReq) Reset()
func (*GetServerListReq) Size ¶
func (m *GetServerListReq) Size() (n int)
func (*GetServerListReq) String ¶
func (m *GetServerListReq) String() string
func (*GetServerListReq) Unmarshal ¶
func (m *GetServerListReq) Unmarshal(dAtA []byte) error
type GetServerReq ¶
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 (*GetServerReq) Descriptor ¶
func (*GetServerReq) Descriptor() ([]byte, []int)
func (*GetServerReq) GetHeader ¶
func (m *GetServerReq) GetHeader() RpcHeader
func (*GetServerReq) GetID ¶
func (m *GetServerReq) GetID() uint64
func (*GetServerReq) Marshal ¶
func (m *GetServerReq) Marshal() (dAtA []byte, err error)
func (*GetServerReq) ProtoMessage ¶
func (*GetServerReq) ProtoMessage()
func (*GetServerReq) Reset ¶
func (m *GetServerReq) Reset()
func (*GetServerReq) Size ¶
func (m *GetServerReq) Size() (n int)
func (*GetServerReq) String ¶
func (m *GetServerReq) String() string
func (*GetServerReq) Unmarshal ¶
func (m *GetServerReq) Unmarshal(dAtA []byte) error
type GetServerRsp ¶
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 (*GetServerRsp) Descriptor ¶
func (*GetServerRsp) Descriptor() ([]byte, []int)
func (*GetServerRsp) GetHeader ¶
func (m *GetServerRsp) GetHeader() RpcHeader
func (*GetServerRsp) GetServer ¶
func (m *GetServerRsp) GetServer() *metapb.Server
func (*GetServerRsp) Marshal ¶
func (m *GetServerRsp) Marshal() (dAtA []byte, err error)
func (*GetServerRsp) ProtoMessage ¶
func (*GetServerRsp) ProtoMessage()
func (*GetServerRsp) Reset ¶
func (m *GetServerRsp) Reset()
func (*GetServerRsp) Size ¶
func (m *GetServerRsp) Size() (n int)
func (*GetServerRsp) String ¶
func (m *GetServerRsp) String() string
func (*GetServerRsp) Unmarshal ¶
func (m *GetServerRsp) Unmarshal(dAtA []byte) error
type MetaServiceClient ¶
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) }
func NewMetaServiceClient ¶
func NewMetaServiceClient(cc *grpc.ClientConn) MetaServiceClient
type MetaServiceServer ¶
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) }
type MetaService_GetAPIListClient ¶
type MetaService_GetAPIListClient interface { Recv() (*metapb.API, error) grpc.ClientStream }
type MetaService_GetAPIListServer ¶
type MetaService_GetAPIListServer interface { Send(*metapb.API) error grpc.ServerStream }
type MetaService_GetClusterListClient ¶
type MetaService_GetClusterListClient interface { Recv() (*metapb.Cluster, error) grpc.ClientStream }
type MetaService_GetClusterListServer ¶
type MetaService_GetClusterListServer interface { Send(*metapb.Cluster) error grpc.ServerStream }
type MetaService_GetRoutingListClient ¶
type MetaService_GetRoutingListClient interface { Recv() (*metapb.Routing, error) grpc.ClientStream }
type MetaService_GetRoutingListServer ¶
type MetaService_GetRoutingListServer interface { Send(*metapb.Routing) error grpc.ServerStream }
type MetaService_GetServerListClient ¶
type MetaService_GetServerListClient interface { Recv() (*metapb.Server, error) grpc.ClientStream }
type MetaService_GetServerListServer ¶
type MetaService_GetServerListServer interface { Send(*metapb.Server) error grpc.ServerStream }
type PutAPIReq ¶
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 (*PutAPIReq) Descriptor ¶
func (*PutAPIReq) ProtoMessage ¶
func (*PutAPIReq) ProtoMessage()
type PutAPIRsp ¶
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 (*PutAPIRsp) Descriptor ¶
func (*PutAPIRsp) ProtoMessage ¶
func (*PutAPIRsp) ProtoMessage()
type PutClusterReq ¶
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 (*PutClusterReq) Descriptor ¶
func (*PutClusterReq) Descriptor() ([]byte, []int)
func (*PutClusterReq) GetCluster ¶
func (m *PutClusterReq) GetCluster() metapb.Cluster
func (*PutClusterReq) GetHeader ¶
func (m *PutClusterReq) GetHeader() RpcHeader
func (*PutClusterReq) Marshal ¶
func (m *PutClusterReq) Marshal() (dAtA []byte, err error)
func (*PutClusterReq) ProtoMessage ¶
func (*PutClusterReq) ProtoMessage()
func (*PutClusterReq) Reset ¶
func (m *PutClusterReq) Reset()
func (*PutClusterReq) Size ¶
func (m *PutClusterReq) Size() (n int)
func (*PutClusterReq) String ¶
func (m *PutClusterReq) String() string
func (*PutClusterReq) Unmarshal ¶
func (m *PutClusterReq) Unmarshal(dAtA []byte) error
type PutClusterRsp ¶
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 (*PutClusterRsp) Descriptor ¶
func (*PutClusterRsp) Descriptor() ([]byte, []int)
func (*PutClusterRsp) GetHeader ¶
func (m *PutClusterRsp) GetHeader() RpcHeader
func (*PutClusterRsp) GetID ¶
func (m *PutClusterRsp) GetID() uint64
func (*PutClusterRsp) Marshal ¶
func (m *PutClusterRsp) Marshal() (dAtA []byte, err error)
func (*PutClusterRsp) ProtoMessage ¶
func (*PutClusterRsp) ProtoMessage()
func (*PutClusterRsp) Reset ¶
func (m *PutClusterRsp) Reset()
func (*PutClusterRsp) Size ¶
func (m *PutClusterRsp) Size() (n int)
func (*PutClusterRsp) String ¶
func (m *PutClusterRsp) String() string
func (*PutClusterRsp) Unmarshal ¶
func (m *PutClusterRsp) Unmarshal(dAtA []byte) error
type PutRoutingReq ¶
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 (*PutRoutingReq) Descriptor ¶
func (*PutRoutingReq) Descriptor() ([]byte, []int)
func (*PutRoutingReq) GetHeader ¶
func (m *PutRoutingReq) GetHeader() RpcHeader
func (*PutRoutingReq) GetRouting ¶
func (m *PutRoutingReq) GetRouting() metapb.Routing
func (*PutRoutingReq) Marshal ¶
func (m *PutRoutingReq) Marshal() (dAtA []byte, err error)
func (*PutRoutingReq) ProtoMessage ¶
func (*PutRoutingReq) ProtoMessage()
func (*PutRoutingReq) Reset ¶
func (m *PutRoutingReq) Reset()
func (*PutRoutingReq) Size ¶
func (m *PutRoutingReq) Size() (n int)
func (*PutRoutingReq) String ¶
func (m *PutRoutingReq) String() string
func (*PutRoutingReq) Unmarshal ¶
func (m *PutRoutingReq) Unmarshal(dAtA []byte) error
type PutRoutingRsp ¶
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 (*PutRoutingRsp) Descriptor ¶
func (*PutRoutingRsp) Descriptor() ([]byte, []int)
func (*PutRoutingRsp) GetHeader ¶
func (m *PutRoutingRsp) GetHeader() RpcHeader
func (*PutRoutingRsp) GetID ¶
func (m *PutRoutingRsp) GetID() uint64
func (*PutRoutingRsp) Marshal ¶
func (m *PutRoutingRsp) Marshal() (dAtA []byte, err error)
func (*PutRoutingRsp) ProtoMessage ¶
func (*PutRoutingRsp) ProtoMessage()
func (*PutRoutingRsp) Reset ¶
func (m *PutRoutingRsp) Reset()
func (*PutRoutingRsp) Size ¶
func (m *PutRoutingRsp) Size() (n int)
func (*PutRoutingRsp) String ¶
func (m *PutRoutingRsp) String() string
func (*PutRoutingRsp) Unmarshal ¶
func (m *PutRoutingRsp) Unmarshal(dAtA []byte) error
type PutServerReq ¶
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 (*PutServerReq) Descriptor ¶
func (*PutServerReq) Descriptor() ([]byte, []int)
func (*PutServerReq) GetHeader ¶
func (m *PutServerReq) GetHeader() RpcHeader
func (*PutServerReq) GetServer ¶
func (m *PutServerReq) GetServer() metapb.Server
func (*PutServerReq) Marshal ¶
func (m *PutServerReq) Marshal() (dAtA []byte, err error)
func (*PutServerReq) ProtoMessage ¶
func (*PutServerReq) ProtoMessage()
func (*PutServerReq) Reset ¶
func (m *PutServerReq) Reset()
func (*PutServerReq) Size ¶
func (m *PutServerReq) Size() (n int)
func (*PutServerReq) String ¶
func (m *PutServerReq) String() string
func (*PutServerReq) Unmarshal ¶
func (m *PutServerReq) Unmarshal(dAtA []byte) error
type PutServerRsp ¶
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 (*PutServerRsp) Descriptor ¶
func (*PutServerRsp) Descriptor() ([]byte, []int)
func (*PutServerRsp) GetHeader ¶
func (m *PutServerRsp) GetHeader() RpcHeader
func (*PutServerRsp) GetID ¶
func (m *PutServerRsp) GetID() uint64
func (*PutServerRsp) Marshal ¶
func (m *PutServerRsp) Marshal() (dAtA []byte, err error)
func (*PutServerRsp) ProtoMessage ¶
func (*PutServerRsp) ProtoMessage()
func (*PutServerRsp) Reset ¶
func (m *PutServerRsp) Reset()
func (*PutServerRsp) Size ¶
func (m *PutServerRsp) Size() (n int)
func (*PutServerRsp) String ¶
func (m *PutServerRsp) String() string
func (*PutServerRsp) Unmarshal ¶
func (m *PutServerRsp) Unmarshal(dAtA []byte) error
type RemoveAPIReq ¶
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 (*RemoveAPIReq) Descriptor ¶
func (*RemoveAPIReq) Descriptor() ([]byte, []int)
func (*RemoveAPIReq) GetHeader ¶
func (m *RemoveAPIReq) GetHeader() RpcHeader
func (*RemoveAPIReq) GetID ¶
func (m *RemoveAPIReq) GetID() uint64
func (*RemoveAPIReq) Marshal ¶
func (m *RemoveAPIReq) Marshal() (dAtA []byte, err error)
func (*RemoveAPIReq) ProtoMessage ¶
func (*RemoveAPIReq) ProtoMessage()
func (*RemoveAPIReq) Reset ¶
func (m *RemoveAPIReq) Reset()
func (*RemoveAPIReq) Size ¶
func (m *RemoveAPIReq) Size() (n int)
func (*RemoveAPIReq) String ¶
func (m *RemoveAPIReq) String() string
func (*RemoveAPIReq) Unmarshal ¶
func (m *RemoveAPIReq) Unmarshal(dAtA []byte) error
type RemoveAPIRsp ¶
type RemoveAPIRsp struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*RemoveAPIRsp) Descriptor ¶
func (*RemoveAPIRsp) Descriptor() ([]byte, []int)
func (*RemoveAPIRsp) GetHeader ¶
func (m *RemoveAPIRsp) GetHeader() RpcHeader
func (*RemoveAPIRsp) Marshal ¶
func (m *RemoveAPIRsp) Marshal() (dAtA []byte, err error)
func (*RemoveAPIRsp) ProtoMessage ¶
func (*RemoveAPIRsp) ProtoMessage()
func (*RemoveAPIRsp) Reset ¶
func (m *RemoveAPIRsp) Reset()
func (*RemoveAPIRsp) Size ¶
func (m *RemoveAPIRsp) Size() (n int)
func (*RemoveAPIRsp) String ¶
func (m *RemoveAPIRsp) String() string
func (*RemoveAPIRsp) Unmarshal ¶
func (m *RemoveAPIRsp) Unmarshal(dAtA []byte) error
type RemoveBindReq ¶
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 (*RemoveBindReq) Descriptor ¶
func (*RemoveBindReq) Descriptor() ([]byte, []int)
func (*RemoveBindReq) GetCluster ¶
func (m *RemoveBindReq) GetCluster() uint64
func (*RemoveBindReq) GetHeader ¶
func (m *RemoveBindReq) GetHeader() RpcHeader
func (*RemoveBindReq) GetServer ¶
func (m *RemoveBindReq) GetServer() uint64
func (*RemoveBindReq) Marshal ¶
func (m *RemoveBindReq) Marshal() (dAtA []byte, err error)
func (*RemoveBindReq) ProtoMessage ¶
func (*RemoveBindReq) ProtoMessage()
func (*RemoveBindReq) Reset ¶
func (m *RemoveBindReq) Reset()
func (*RemoveBindReq) Size ¶
func (m *RemoveBindReq) Size() (n int)
func (*RemoveBindReq) String ¶
func (m *RemoveBindReq) String() string
func (*RemoveBindReq) Unmarshal ¶
func (m *RemoveBindReq) Unmarshal(dAtA []byte) error
type RemoveBindRsp ¶
type RemoveBindRsp struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*RemoveBindRsp) Descriptor ¶
func (*RemoveBindRsp) Descriptor() ([]byte, []int)
func (*RemoveBindRsp) GetHeader ¶
func (m *RemoveBindRsp) GetHeader() RpcHeader
func (*RemoveBindRsp) Marshal ¶
func (m *RemoveBindRsp) Marshal() (dAtA []byte, err error)
func (*RemoveBindRsp) ProtoMessage ¶
func (*RemoveBindRsp) ProtoMessage()
func (*RemoveBindRsp) Reset ¶
func (m *RemoveBindRsp) Reset()
func (*RemoveBindRsp) Size ¶
func (m *RemoveBindRsp) Size() (n int)
func (*RemoveBindRsp) String ¶
func (m *RemoveBindRsp) String() string
func (*RemoveBindRsp) Unmarshal ¶
func (m *RemoveBindRsp) Unmarshal(dAtA []byte) error
type RemoveClusterBindReq ¶
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 (*RemoveClusterBindReq) Descriptor ¶
func (*RemoveClusterBindReq) Descriptor() ([]byte, []int)
func (*RemoveClusterBindReq) GetCluster ¶
func (m *RemoveClusterBindReq) GetCluster() uint64
func (*RemoveClusterBindReq) GetHeader ¶
func (m *RemoveClusterBindReq) GetHeader() RpcHeader
func (*RemoveClusterBindReq) Marshal ¶
func (m *RemoveClusterBindReq) Marshal() (dAtA []byte, err error)
func (*RemoveClusterBindReq) MarshalTo ¶
func (m *RemoveClusterBindReq) MarshalTo(dAtA []byte) (int, error)
func (*RemoveClusterBindReq) ProtoMessage ¶
func (*RemoveClusterBindReq) ProtoMessage()
func (*RemoveClusterBindReq) Reset ¶
func (m *RemoveClusterBindReq) Reset()
func (*RemoveClusterBindReq) Size ¶
func (m *RemoveClusterBindReq) Size() (n int)
func (*RemoveClusterBindReq) String ¶
func (m *RemoveClusterBindReq) String() string
func (*RemoveClusterBindReq) Unmarshal ¶
func (m *RemoveClusterBindReq) Unmarshal(dAtA []byte) error
type RemoveClusterBindRsp ¶
type RemoveClusterBindRsp struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*RemoveClusterBindRsp) Descriptor ¶
func (*RemoveClusterBindRsp) Descriptor() ([]byte, []int)
func (*RemoveClusterBindRsp) GetHeader ¶
func (m *RemoveClusterBindRsp) GetHeader() RpcHeader
func (*RemoveClusterBindRsp) Marshal ¶
func (m *RemoveClusterBindRsp) Marshal() (dAtA []byte, err error)
func (*RemoveClusterBindRsp) MarshalTo ¶
func (m *RemoveClusterBindRsp) MarshalTo(dAtA []byte) (int, error)
func (*RemoveClusterBindRsp) ProtoMessage ¶
func (*RemoveClusterBindRsp) ProtoMessage()
func (*RemoveClusterBindRsp) Reset ¶
func (m *RemoveClusterBindRsp) Reset()
func (*RemoveClusterBindRsp) Size ¶
func (m *RemoveClusterBindRsp) Size() (n int)
func (*RemoveClusterBindRsp) String ¶
func (m *RemoveClusterBindRsp) String() string
func (*RemoveClusterBindRsp) Unmarshal ¶
func (m *RemoveClusterBindRsp) Unmarshal(dAtA []byte) error
type RemoveClusterReq ¶
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 (*RemoveClusterReq) Descriptor ¶
func (*RemoveClusterReq) Descriptor() ([]byte, []int)
func (*RemoveClusterReq) GetHeader ¶
func (m *RemoveClusterReq) GetHeader() RpcHeader
func (*RemoveClusterReq) GetID ¶
func (m *RemoveClusterReq) GetID() uint64
func (*RemoveClusterReq) Marshal ¶
func (m *RemoveClusterReq) Marshal() (dAtA []byte, err error)
func (*RemoveClusterReq) ProtoMessage ¶
func (*RemoveClusterReq) ProtoMessage()
func (*RemoveClusterReq) Reset ¶
func (m *RemoveClusterReq) Reset()
func (*RemoveClusterReq) Size ¶
func (m *RemoveClusterReq) Size() (n int)
func (*RemoveClusterReq) String ¶
func (m *RemoveClusterReq) String() string
func (*RemoveClusterReq) Unmarshal ¶
func (m *RemoveClusterReq) Unmarshal(dAtA []byte) error
type RemoveClusterRsp ¶
type RemoveClusterRsp struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*RemoveClusterRsp) Descriptor ¶
func (*RemoveClusterRsp) Descriptor() ([]byte, []int)
func (*RemoveClusterRsp) GetHeader ¶
func (m *RemoveClusterRsp) GetHeader() RpcHeader
func (*RemoveClusterRsp) Marshal ¶
func (m *RemoveClusterRsp) Marshal() (dAtA []byte, err error)
func (*RemoveClusterRsp) ProtoMessage ¶
func (*RemoveClusterRsp) ProtoMessage()
func (*RemoveClusterRsp) Reset ¶
func (m *RemoveClusterRsp) Reset()
func (*RemoveClusterRsp) Size ¶
func (m *RemoveClusterRsp) Size() (n int)
func (*RemoveClusterRsp) String ¶
func (m *RemoveClusterRsp) String() string
func (*RemoveClusterRsp) Unmarshal ¶
func (m *RemoveClusterRsp) Unmarshal(dAtA []byte) error
type RemoveRoutingReq ¶
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 (*RemoveRoutingReq) Descriptor ¶
func (*RemoveRoutingReq) Descriptor() ([]byte, []int)
func (*RemoveRoutingReq) GetHeader ¶
func (m *RemoveRoutingReq) GetHeader() RpcHeader
func (*RemoveRoutingReq) GetID ¶
func (m *RemoveRoutingReq) GetID() uint64
func (*RemoveRoutingReq) Marshal ¶
func (m *RemoveRoutingReq) Marshal() (dAtA []byte, err error)
func (*RemoveRoutingReq) ProtoMessage ¶
func (*RemoveRoutingReq) ProtoMessage()
func (*RemoveRoutingReq) Reset ¶
func (m *RemoveRoutingReq) Reset()
func (*RemoveRoutingReq) Size ¶
func (m *RemoveRoutingReq) Size() (n int)
func (*RemoveRoutingReq) String ¶
func (m *RemoveRoutingReq) String() string
func (*RemoveRoutingReq) Unmarshal ¶
func (m *RemoveRoutingReq) Unmarshal(dAtA []byte) error
type RemoveRoutingRsp ¶
type RemoveRoutingRsp struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*RemoveRoutingRsp) Descriptor ¶
func (*RemoveRoutingRsp) Descriptor() ([]byte, []int)
func (*RemoveRoutingRsp) GetHeader ¶
func (m *RemoveRoutingRsp) GetHeader() RpcHeader
func (*RemoveRoutingRsp) Marshal ¶
func (m *RemoveRoutingRsp) Marshal() (dAtA []byte, err error)
func (*RemoveRoutingRsp) ProtoMessage ¶
func (*RemoveRoutingRsp) ProtoMessage()
func (*RemoveRoutingRsp) Reset ¶
func (m *RemoveRoutingRsp) Reset()
func (*RemoveRoutingRsp) Size ¶
func (m *RemoveRoutingRsp) Size() (n int)
func (*RemoveRoutingRsp) String ¶
func (m *RemoveRoutingRsp) String() string
func (*RemoveRoutingRsp) Unmarshal ¶
func (m *RemoveRoutingRsp) Unmarshal(dAtA []byte) error
type RemoveServerReq ¶
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 (*RemoveServerReq) Descriptor ¶
func (*RemoveServerReq) Descriptor() ([]byte, []int)
func (*RemoveServerReq) GetHeader ¶
func (m *RemoveServerReq) GetHeader() RpcHeader
func (*RemoveServerReq) GetID ¶
func (m *RemoveServerReq) GetID() uint64
func (*RemoveServerReq) Marshal ¶
func (m *RemoveServerReq) Marshal() (dAtA []byte, err error)
func (*RemoveServerReq) ProtoMessage ¶
func (*RemoveServerReq) ProtoMessage()
func (*RemoveServerReq) Reset ¶
func (m *RemoveServerReq) Reset()
func (*RemoveServerReq) Size ¶
func (m *RemoveServerReq) Size() (n int)
func (*RemoveServerReq) String ¶
func (m *RemoveServerReq) String() string
func (*RemoveServerReq) Unmarshal ¶
func (m *RemoveServerReq) Unmarshal(dAtA []byte) error
type RemoveServerRsp ¶
type RemoveServerRsp struct { Header RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header"` XXX_unrecognized []byte `json:"-"` }
func (*RemoveServerRsp) Descriptor ¶
func (*RemoveServerRsp) Descriptor() ([]byte, []int)
func (*RemoveServerRsp) GetHeader ¶
func (m *RemoveServerRsp) GetHeader() RpcHeader
func (*RemoveServerRsp) Marshal ¶
func (m *RemoveServerRsp) Marshal() (dAtA []byte, err error)
func (*RemoveServerRsp) ProtoMessage ¶
func (*RemoveServerRsp) ProtoMessage()
func (*RemoveServerRsp) Reset ¶
func (m *RemoveServerRsp) Reset()
func (*RemoveServerRsp) Size ¶
func (m *RemoveServerRsp) Size() (n int)
func (*RemoveServerRsp) String ¶
func (m *RemoveServerRsp) String() string
func (*RemoveServerRsp) Unmarshal ¶
func (m *RemoveServerRsp) Unmarshal(dAtA []byte) error
type RpcHeader ¶
type RpcHeader struct { Uuid string `protobuf:"bytes,1,opt,name=uuid" json:"uuid"` XXX_unrecognized []byte `json:"-"` }
RpcHeader is the header for all rpc request and response
func (*RpcHeader) Descriptor ¶
func (*RpcHeader) ProtoMessage ¶
func (*RpcHeader) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.