mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-06 17:18:35 +08:00
668 lines
28 KiB
Go
668 lines
28 KiB
Go
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|
// versions:
|
|
// - protoc-gen-go-grpc v1.3.0
|
|
// - protoc v3.21.4
|
|
// source: proxy.proto
|
|
|
|
package proxypb
|
|
|
|
import (
|
|
context "context"
|
|
commonpb "github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
|
|
milvuspb "github.com/milvus-io/milvus-proto/go-api/v2/milvuspb"
|
|
internalpb "github.com/milvus-io/milvus/pkg/v2/proto/internalpb"
|
|
grpc "google.golang.org/grpc"
|
|
codes "google.golang.org/grpc/codes"
|
|
status "google.golang.org/grpc/status"
|
|
)
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the grpc package it is being compiled against.
|
|
// Requires gRPC-Go v1.32.0 or later.
|
|
const _ = grpc.SupportPackageIsVersion7
|
|
|
|
const (
|
|
Proxy_GetComponentStates_FullMethodName = "/milvus.proto.proxy.Proxy/GetComponentStates"
|
|
Proxy_GetStatisticsChannel_FullMethodName = "/milvus.proto.proxy.Proxy/GetStatisticsChannel"
|
|
Proxy_InvalidateCollectionMetaCache_FullMethodName = "/milvus.proto.proxy.Proxy/InvalidateCollectionMetaCache"
|
|
Proxy_GetDdChannel_FullMethodName = "/milvus.proto.proxy.Proxy/GetDdChannel"
|
|
Proxy_InvalidateCredentialCache_FullMethodName = "/milvus.proto.proxy.Proxy/InvalidateCredentialCache"
|
|
Proxy_UpdateCredentialCache_FullMethodName = "/milvus.proto.proxy.Proxy/UpdateCredentialCache"
|
|
Proxy_RefreshPolicyInfoCache_FullMethodName = "/milvus.proto.proxy.Proxy/RefreshPolicyInfoCache"
|
|
Proxy_GetProxyMetrics_FullMethodName = "/milvus.proto.proxy.Proxy/GetProxyMetrics"
|
|
Proxy_SetRates_FullMethodName = "/milvus.proto.proxy.Proxy/SetRates"
|
|
Proxy_ListClientInfos_FullMethodName = "/milvus.proto.proxy.Proxy/ListClientInfos"
|
|
Proxy_ImportV2_FullMethodName = "/milvus.proto.proxy.Proxy/ImportV2"
|
|
Proxy_GetImportProgress_FullMethodName = "/milvus.proto.proxy.Proxy/GetImportProgress"
|
|
Proxy_ListImports_FullMethodName = "/milvus.proto.proxy.Proxy/ListImports"
|
|
Proxy_InvalidateShardLeaderCache_FullMethodName = "/milvus.proto.proxy.Proxy/InvalidateShardLeaderCache"
|
|
Proxy_GetSegmentsInfo_FullMethodName = "/milvus.proto.proxy.Proxy/GetSegmentsInfo"
|
|
Proxy_GetQuotaMetrics_FullMethodName = "/milvus.proto.proxy.Proxy/GetQuotaMetrics"
|
|
)
|
|
|
|
// ProxyClient is the client API for Proxy service.
|
|
//
|
|
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
|
type ProxyClient interface {
|
|
GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)
|
|
GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
|
|
InvalidateCollectionMetaCache(ctx context.Context, in *InvalidateCollMetaCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
|
|
GetDdChannel(ctx context.Context, in *internalpb.GetDdChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
|
|
InvalidateCredentialCache(ctx context.Context, in *InvalidateCredCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
|
|
UpdateCredentialCache(ctx context.Context, in *UpdateCredCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
|
|
RefreshPolicyInfoCache(ctx context.Context, in *RefreshPolicyInfoCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
|
|
GetProxyMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)
|
|
SetRates(ctx context.Context, in *SetRatesRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
|
|
ListClientInfos(ctx context.Context, in *ListClientInfosRequest, opts ...grpc.CallOption) (*ListClientInfosResponse, error)
|
|
// importV2
|
|
ImportV2(ctx context.Context, in *internalpb.ImportRequest, opts ...grpc.CallOption) (*internalpb.ImportResponse, error)
|
|
GetImportProgress(ctx context.Context, in *internalpb.GetImportProgressRequest, opts ...grpc.CallOption) (*internalpb.GetImportProgressResponse, error)
|
|
ListImports(ctx context.Context, in *internalpb.ListImportsRequest, opts ...grpc.CallOption) (*internalpb.ListImportsResponse, error)
|
|
InvalidateShardLeaderCache(ctx context.Context, in *InvalidateShardLeaderCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
|
|
GetSegmentsInfo(ctx context.Context, in *internalpb.GetSegmentsInfoRequest, opts ...grpc.CallOption) (*internalpb.GetSegmentsInfoResponse, error)
|
|
GetQuotaMetrics(ctx context.Context, in *internalpb.GetQuotaMetricsRequest, opts ...grpc.CallOption) (*internalpb.GetQuotaMetricsResponse, error)
|
|
}
|
|
|
|
type proxyClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewProxyClient(cc grpc.ClientConnInterface) ProxyClient {
|
|
return &proxyClient{cc}
|
|
}
|
|
|
|
func (c *proxyClient) GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error) {
|
|
out := new(milvuspb.ComponentStates)
|
|
err := c.cc.Invoke(ctx, Proxy_GetComponentStates_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error) {
|
|
out := new(milvuspb.StringResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_GetStatisticsChannel_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) InvalidateCollectionMetaCache(ctx context.Context, in *InvalidateCollMetaCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
|
|
out := new(commonpb.Status)
|
|
err := c.cc.Invoke(ctx, Proxy_InvalidateCollectionMetaCache_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) GetDdChannel(ctx context.Context, in *internalpb.GetDdChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error) {
|
|
out := new(milvuspb.StringResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_GetDdChannel_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) InvalidateCredentialCache(ctx context.Context, in *InvalidateCredCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
|
|
out := new(commonpb.Status)
|
|
err := c.cc.Invoke(ctx, Proxy_InvalidateCredentialCache_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) UpdateCredentialCache(ctx context.Context, in *UpdateCredCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
|
|
out := new(commonpb.Status)
|
|
err := c.cc.Invoke(ctx, Proxy_UpdateCredentialCache_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) RefreshPolicyInfoCache(ctx context.Context, in *RefreshPolicyInfoCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
|
|
out := new(commonpb.Status)
|
|
err := c.cc.Invoke(ctx, Proxy_RefreshPolicyInfoCache_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) GetProxyMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error) {
|
|
out := new(milvuspb.GetMetricsResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_GetProxyMetrics_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) SetRates(ctx context.Context, in *SetRatesRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
|
|
out := new(commonpb.Status)
|
|
err := c.cc.Invoke(ctx, Proxy_SetRates_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) ListClientInfos(ctx context.Context, in *ListClientInfosRequest, opts ...grpc.CallOption) (*ListClientInfosResponse, error) {
|
|
out := new(ListClientInfosResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_ListClientInfos_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) ImportV2(ctx context.Context, in *internalpb.ImportRequest, opts ...grpc.CallOption) (*internalpb.ImportResponse, error) {
|
|
out := new(internalpb.ImportResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_ImportV2_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) GetImportProgress(ctx context.Context, in *internalpb.GetImportProgressRequest, opts ...grpc.CallOption) (*internalpb.GetImportProgressResponse, error) {
|
|
out := new(internalpb.GetImportProgressResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_GetImportProgress_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) ListImports(ctx context.Context, in *internalpb.ListImportsRequest, opts ...grpc.CallOption) (*internalpb.ListImportsResponse, error) {
|
|
out := new(internalpb.ListImportsResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_ListImports_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) InvalidateShardLeaderCache(ctx context.Context, in *InvalidateShardLeaderCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
|
|
out := new(commonpb.Status)
|
|
err := c.cc.Invoke(ctx, Proxy_InvalidateShardLeaderCache_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) GetSegmentsInfo(ctx context.Context, in *internalpb.GetSegmentsInfoRequest, opts ...grpc.CallOption) (*internalpb.GetSegmentsInfoResponse, error) {
|
|
out := new(internalpb.GetSegmentsInfoResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_GetSegmentsInfo_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *proxyClient) GetQuotaMetrics(ctx context.Context, in *internalpb.GetQuotaMetricsRequest, opts ...grpc.CallOption) (*internalpb.GetQuotaMetricsResponse, error) {
|
|
out := new(internalpb.GetQuotaMetricsResponse)
|
|
err := c.cc.Invoke(ctx, Proxy_GetQuotaMetrics_FullMethodName, in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// ProxyServer is the server API for Proxy service.
|
|
// All implementations should embed UnimplementedProxyServer
|
|
// for forward compatibility
|
|
type ProxyServer interface {
|
|
GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
|
|
GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
|
|
InvalidateCollectionMetaCache(context.Context, *InvalidateCollMetaCacheRequest) (*commonpb.Status, error)
|
|
GetDdChannel(context.Context, *internalpb.GetDdChannelRequest) (*milvuspb.StringResponse, error)
|
|
InvalidateCredentialCache(context.Context, *InvalidateCredCacheRequest) (*commonpb.Status, error)
|
|
UpdateCredentialCache(context.Context, *UpdateCredCacheRequest) (*commonpb.Status, error)
|
|
RefreshPolicyInfoCache(context.Context, *RefreshPolicyInfoCacheRequest) (*commonpb.Status, error)
|
|
GetProxyMetrics(context.Context, *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)
|
|
SetRates(context.Context, *SetRatesRequest) (*commonpb.Status, error)
|
|
ListClientInfos(context.Context, *ListClientInfosRequest) (*ListClientInfosResponse, error)
|
|
// importV2
|
|
ImportV2(context.Context, *internalpb.ImportRequest) (*internalpb.ImportResponse, error)
|
|
GetImportProgress(context.Context, *internalpb.GetImportProgressRequest) (*internalpb.GetImportProgressResponse, error)
|
|
ListImports(context.Context, *internalpb.ListImportsRequest) (*internalpb.ListImportsResponse, error)
|
|
InvalidateShardLeaderCache(context.Context, *InvalidateShardLeaderCacheRequest) (*commonpb.Status, error)
|
|
GetSegmentsInfo(context.Context, *internalpb.GetSegmentsInfoRequest) (*internalpb.GetSegmentsInfoResponse, error)
|
|
GetQuotaMetrics(context.Context, *internalpb.GetQuotaMetricsRequest) (*internalpb.GetQuotaMetricsResponse, error)
|
|
}
|
|
|
|
// UnimplementedProxyServer should be embedded to have forward compatible implementations.
|
|
type UnimplementedProxyServer struct {
|
|
}
|
|
|
|
func (UnimplementedProxyServer) GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetComponentStates not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetStatisticsChannel not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) InvalidateCollectionMetaCache(context.Context, *InvalidateCollMetaCacheRequest) (*commonpb.Status, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method InvalidateCollectionMetaCache not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) GetDdChannel(context.Context, *internalpb.GetDdChannelRequest) (*milvuspb.StringResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetDdChannel not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) InvalidateCredentialCache(context.Context, *InvalidateCredCacheRequest) (*commonpb.Status, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method InvalidateCredentialCache not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) UpdateCredentialCache(context.Context, *UpdateCredCacheRequest) (*commonpb.Status, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateCredentialCache not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) RefreshPolicyInfoCache(context.Context, *RefreshPolicyInfoCacheRequest) (*commonpb.Status, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method RefreshPolicyInfoCache not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) GetProxyMetrics(context.Context, *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetProxyMetrics not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) SetRates(context.Context, *SetRatesRequest) (*commonpb.Status, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method SetRates not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) ListClientInfos(context.Context, *ListClientInfosRequest) (*ListClientInfosResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListClientInfos not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) ImportV2(context.Context, *internalpb.ImportRequest) (*internalpb.ImportResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ImportV2 not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) GetImportProgress(context.Context, *internalpb.GetImportProgressRequest) (*internalpb.GetImportProgressResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetImportProgress not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) ListImports(context.Context, *internalpb.ListImportsRequest) (*internalpb.ListImportsResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListImports not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) InvalidateShardLeaderCache(context.Context, *InvalidateShardLeaderCacheRequest) (*commonpb.Status, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method InvalidateShardLeaderCache not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) GetSegmentsInfo(context.Context, *internalpb.GetSegmentsInfoRequest) (*internalpb.GetSegmentsInfoResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetSegmentsInfo not implemented")
|
|
}
|
|
func (UnimplementedProxyServer) GetQuotaMetrics(context.Context, *internalpb.GetQuotaMetricsRequest) (*internalpb.GetQuotaMetricsResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetQuotaMetrics not implemented")
|
|
}
|
|
|
|
// UnsafeProxyServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to ProxyServer will
|
|
// result in compilation errors.
|
|
type UnsafeProxyServer interface {
|
|
mustEmbedUnimplementedProxyServer()
|
|
}
|
|
|
|
func RegisterProxyServer(s grpc.ServiceRegistrar, srv ProxyServer) {
|
|
s.RegisterService(&Proxy_ServiceDesc, srv)
|
|
}
|
|
|
|
func _Proxy_GetComponentStates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(milvuspb.GetComponentStatesRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).GetComponentStates(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_GetComponentStates_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).GetComponentStates(ctx, req.(*milvuspb.GetComponentStatesRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_GetStatisticsChannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(internalpb.GetStatisticsChannelRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).GetStatisticsChannel(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_GetStatisticsChannel_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).GetStatisticsChannel(ctx, req.(*internalpb.GetStatisticsChannelRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_InvalidateCollectionMetaCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(InvalidateCollMetaCacheRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).InvalidateCollectionMetaCache(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_InvalidateCollectionMetaCache_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).InvalidateCollectionMetaCache(ctx, req.(*InvalidateCollMetaCacheRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_GetDdChannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(internalpb.GetDdChannelRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).GetDdChannel(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_GetDdChannel_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).GetDdChannel(ctx, req.(*internalpb.GetDdChannelRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_InvalidateCredentialCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(InvalidateCredCacheRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).InvalidateCredentialCache(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_InvalidateCredentialCache_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).InvalidateCredentialCache(ctx, req.(*InvalidateCredCacheRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_UpdateCredentialCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(UpdateCredCacheRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).UpdateCredentialCache(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_UpdateCredentialCache_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).UpdateCredentialCache(ctx, req.(*UpdateCredCacheRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_RefreshPolicyInfoCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RefreshPolicyInfoCacheRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).RefreshPolicyInfoCache(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_RefreshPolicyInfoCache_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).RefreshPolicyInfoCache(ctx, req.(*RefreshPolicyInfoCacheRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_GetProxyMetrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(milvuspb.GetMetricsRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).GetProxyMetrics(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_GetProxyMetrics_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).GetProxyMetrics(ctx, req.(*milvuspb.GetMetricsRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_SetRates_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(SetRatesRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).SetRates(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_SetRates_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).SetRates(ctx, req.(*SetRatesRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_ListClientInfos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(ListClientInfosRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).ListClientInfos(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_ListClientInfos_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).ListClientInfos(ctx, req.(*ListClientInfosRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_ImportV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(internalpb.ImportRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).ImportV2(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_ImportV2_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).ImportV2(ctx, req.(*internalpb.ImportRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_GetImportProgress_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(internalpb.GetImportProgressRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).GetImportProgress(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_GetImportProgress_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).GetImportProgress(ctx, req.(*internalpb.GetImportProgressRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_ListImports_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(internalpb.ListImportsRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).ListImports(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_ListImports_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).ListImports(ctx, req.(*internalpb.ListImportsRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_InvalidateShardLeaderCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(InvalidateShardLeaderCacheRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).InvalidateShardLeaderCache(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_InvalidateShardLeaderCache_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).InvalidateShardLeaderCache(ctx, req.(*InvalidateShardLeaderCacheRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_GetSegmentsInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(internalpb.GetSegmentsInfoRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).GetSegmentsInfo(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_GetSegmentsInfo_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).GetSegmentsInfo(ctx, req.(*internalpb.GetSegmentsInfoRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Proxy_GetQuotaMetrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(internalpb.GetQuotaMetricsRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(ProxyServer).GetQuotaMetrics(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: Proxy_GetQuotaMetrics_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(ProxyServer).GetQuotaMetrics(ctx, req.(*internalpb.GetQuotaMetricsRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
// Proxy_ServiceDesc is the grpc.ServiceDesc for Proxy service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var Proxy_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "milvus.proto.proxy.Proxy",
|
|
HandlerType: (*ProxyServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "GetComponentStates",
|
|
Handler: _Proxy_GetComponentStates_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetStatisticsChannel",
|
|
Handler: _Proxy_GetStatisticsChannel_Handler,
|
|
},
|
|
{
|
|
MethodName: "InvalidateCollectionMetaCache",
|
|
Handler: _Proxy_InvalidateCollectionMetaCache_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetDdChannel",
|
|
Handler: _Proxy_GetDdChannel_Handler,
|
|
},
|
|
{
|
|
MethodName: "InvalidateCredentialCache",
|
|
Handler: _Proxy_InvalidateCredentialCache_Handler,
|
|
},
|
|
{
|
|
MethodName: "UpdateCredentialCache",
|
|
Handler: _Proxy_UpdateCredentialCache_Handler,
|
|
},
|
|
{
|
|
MethodName: "RefreshPolicyInfoCache",
|
|
Handler: _Proxy_RefreshPolicyInfoCache_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetProxyMetrics",
|
|
Handler: _Proxy_GetProxyMetrics_Handler,
|
|
},
|
|
{
|
|
MethodName: "SetRates",
|
|
Handler: _Proxy_SetRates_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListClientInfos",
|
|
Handler: _Proxy_ListClientInfos_Handler,
|
|
},
|
|
{
|
|
MethodName: "ImportV2",
|
|
Handler: _Proxy_ImportV2_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetImportProgress",
|
|
Handler: _Proxy_GetImportProgress_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListImports",
|
|
Handler: _Proxy_ListImports_Handler,
|
|
},
|
|
{
|
|
MethodName: "InvalidateShardLeaderCache",
|
|
Handler: _Proxy_InvalidateShardLeaderCache_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetSegmentsInfo",
|
|
Handler: _Proxy_GetSegmentsInfo_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetQuotaMetrics",
|
|
Handler: _Proxy_GetQuotaMetrics_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "proxy.proto",
|
|
}
|