// Code generated by protoc-gen-go. DO NOT EDIT. // source: adm_management.proto // package声明符，用来防止不同的消息类型有命名冲突 package pb import ( v1 "adm-gateway/pb/v1" context "context" fmt "fmt" proto "github.com/golang/protobuf/proto" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" math "math" ) // 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.ProtoPackageIsVersion3 // please upgrade the proto package func init() { proto.RegisterFile("adm_management.proto", fileDescriptor_dcebd7d01e3b1b1a) } var fileDescriptor_dcebd7d01e3b1b1a = []byte{ // 695 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x96, 0x51, 0x4f, 0x14, 0x31, 0x10, 0xc7, 0x7d, 0x50, 0xc4, 0xaa, 0x70, 0x96, 0x43, 0x14, 0xe3, 0x8b, 0x4f, 0x26, 0xc6, 0x23, 0x28, 0x89, 0x89, 0x89, 0x89, 0x27, 0x07, 0x09, 0x01, 0x12, 0xc2, 0xc1, 0x8b, 0x2f, 0xa6, 0xb7, 0x3b, 0x81, 0x0d, 0xbd, 0xdd, 0x75, 0xaf, 0x77, 0xb8, 0xdf, 0xcf, 0x0f, 0x66, 0xda, 0x69, 0xa7, 0x9d, 0xbd, 0xf3, 0xad, 0xf3, 0x9b, 0xf9, 0x4f, 0xa7, 0xb3, 0xd3, 0xde, 0x89, 0xbe, 0xca, 0xa7, 0xbf, 0xa6, 0xaa, 0x54, 0x37, 0x30, 0x85, 0xd2, 0x0c, 0xea, 0xa6, 0x32, 0x95, 0x14, 0xf5, 0x64, 0x30, 0x83, 0x66, 0x51, 0x64, 0xb0, 0xfb, 0x6a, 0xb1, 0xbf, 0x97, 0x2b, 0xa3, 0x96, 0xa2, 0x3e, 0xfd, 0xed, 0x09, 0x71, 0x4e, 0x50, 0x1e, 0x88, 0xf5, 0x91, 0x32, 0xea, 0xac, 0x98, 0x19, 0xb9, 0x35, 0x58, 0xec, 0x0f, 0x82, 0x75, 0x09, 0xbf, 0xe7, 0x30, 0x33, 0xbb, 0x2f, 0x38, 0xac, 0x75, 0xfb, 0xee, 0x81, 0xfc, 0x2a, 0xc4, 0x18, 0x54, 0x93, 0xdd, 0x5a, 0x87, 0xdc, 0xb6, 0x21, 0xd1, 0x0e, 0xca, 0xad, 0x2e, 0x46, 0xed, 0x37, 0xf1, 0x14, 0xe1, 0x19, 0x2c, 0x40, 0xcb, 0x97, 0x31, 0xca, 0x81, 0xa0, 0xee, 0x2f, 0x71, 0x94, 0x1f, 0x88, 0xf5, 0x4b, 0xd0, 0xca, 0x14, 0x55, 0x89, 0x05, 0x07, 0x8b, 0x15, 0x1c, 0x21, 0xaa, 0x06, 0x62, 0x6d, 0x7c, 0x5f, 0x98, 0xec, 0x56, 0x3a, 0x37, 0xae, 0x83, 0x62, 0x33, 0x45, 0xb4, 0xcb, 0x95, 0x9a, 0xdd, 0xc5, 0xb6, 0x04, 0x8b, 0xed, 0x12, 0x61, 0xa7, 0x2d, 0xd6, 0x91, 0xb6, 0xc5, 0xda, 0x2b, 0xda, 0x82, 0x98, 0xb4, 0x23, 0xa8, 0xa1, 0xcc, 0xa1, 0xcc, 0x5a, 0xd4, 0x46, 0x9b, 0x69, 0x53, 0x8c, 0xda, 0x4b, 0x21, 0x6d, 0x87, 0xc7, 0xd5, 0xbc, 0xc9, 0x80, 0xba, 0xf3, 0x36, 0x7c, 0x39, 0xce, 0x43, 0xae, 0x37, 0xff, 0x73, 0x53, 0x3d, 0xe7, 0xaa, 0x9c, 0x2b, 0x1d, 0xcf, 0x12, 0x6d, 0x56, 0x4f, 0x8a, 0x63, 0xb7, 0x5d, 0x52, 0xdf, 0x6d, 0xbf, 0x41, 0xda, 0x6d, 0x8f, 0x30, 0xfe, 0xbd, 0x78, 0xe8, 0x76, 0xd9, 0x0c, 0x4d, 0x0d, 0xb1, 0xcf, 0x23, 0xa0, 0xcc, 0x87, 0x0d, 0x28, 0xe3, 0x33, 0xe3, 0x9a, 0x65, 0x0e, 0x88, 0x4e, 0x71, 0x5d, 0xeb, 0x4a, 0xe5, 0xc7, 0x85, 0x06, 0x3c, 0x45, 0xb4, 0xd9, 0x29, 0x52, 0x8c, 0xda, 0x0f, 0xe2, 0xd1, 0x71, 0x01, 0x3a, 0x97, 0x3d, 0xeb, 0x77, 0xcb, 0xa0, 0xd8, 0x48, 0x08, 0x05, 0x1f, 0xfd, 0xc9, 0x40, 0x63, 0xb0, 0x5b, 0xb2, 0x60, 0x4f, 0x30, 0x78, 0x5f, 0x3c, 0x1e, 0x5e, 0x9c, 0xb8, 0xe1, 0x92, 0xd6, 0xe9, 0x8d, 0x20, 0xe8, 0x31, 0x46, 0x03, 0x79, 0x78, 0x0b, 0xd9, 0xdd, 0xf0, 0xe2, 0x04, 0x07, 0x32, 0x58, 0x6c, 0x20, 0x23, 0x44, 0xd5, 0x17, 0xf1, 0x64, 0x04, 0x1a, 0x0c, 0x58, 0x59, 0x1f, 0x87, 0xc7, 0x9b, 0x41, 0x27, 0x3b, 0x94, 0x2a, 0x3c, 0x85, 0x36, 0x56, 0xe8, 0x0d, 0x56, 0x21, 0x31, 0xda, 0x0b, 0x7b, 0x7f, 0x0a, 0x2d, 0xee, 0x45, 0x26, 0xdb, 0x2b, 0xa1, 0x9d, 0x22, 0x49, 0x48, 0xe6, 0x8a, 0x22, 0x13, 0xe1, 0x40, 0xac, 0x0d, 0xb5, 0xb6, 0x47, 0x73, 0x87, 0xc7, 0x35, 0x1b, 0x86, 0x80, 0xd2, 0x78, 0xbb, 0x4b, 0x88, 0x4f, 0xb6, 0xd8, 0x4c, 0x11, 0xc5, 0x5f, 0xcf, 0x80, 0xf2, 0xe3, 0x9a, 0xc5, 0x07, 0x44, 0x2f, 0xdb, 0x95, 0x9a, 0x68, 0x18, 0x9b, 0x66, 0x9e, 0x19, 0x7c, 0xd9, 0x12, 0xc0, 0x5e, 0x36, 0xc6, 0xe9, 0x13, 0x8f, 0x4d, 0xab, 0xe1, 0x5c, 0xd5, 0xf8, 0x89, 0x83, 0xc5, 0x3e, 0x71, 0x84, 0xf4, 0xa5, 0x8e, 0xf2, 0xc2, 0x58, 0x91, 0xeb, 0x92, 0x37, 0xd8, 0x97, 0x22, 0x46, 0x0d, 0x1f, 0x6a, 0xed, 0x6f, 0x68, 0xdf, 0x9f, 0x9b, 0x5f, 0x52, 0xd9, 0xa1, 0x28, 0x1c, 0x89, 0xde, 0xb0, 0x2c, 0xab, 0x79, 0x99, 0xb9, 0x1f, 0x0f, 0x37, 0x1e, 0x3b, 0x2e, 0x32, 0xa1, 0x21, 0xc5, 0xf6, 0xb2, 0x83, 0x6e, 0xbb, 0x2d, 0x08, 0x6f, 0xbb, 0x5d, 0xb1, 0xdb, 0x8e, 0x80, 0xbd, 0x6b, 0x27, 0xd3, 0xba, 0x6a, 0xcc, 0x15, 0x4c, 0x6b, 0x6d, 0x6f, 0x3e, 0xbd, 0x6b, 0x9c, 0x2f, 0xbd, 0x6b, 0x5d, 0x37, 0xe6, 0x3c, 0x16, 0x1b, 0x38, 0x81, 0x94, 0xef, 0x75, 0x9c, 0xca, 0x6e, 0xae, 0x9d, 0x55, 0x2e, 0xcc, 0xf3, 0x5d, 0x3c, 0xb3, 0xa5, 0x52, 0x96, 0x9d, 0x50, 0x7c, 0x37, 0xc7, 0xf6, 0xb2, 0x83, 0x2a, 0xc1, 0x91, 0xe6, 0x95, 0x70, 0xc6, 0x2a, 0xe9, 0xba, 0xe2, 0x2f, 0x07, 0x1d, 0xd7, 0xff, 0x72, 0x90, 0xcd, 0x7f, 0x39, 0x12, 0x4c, 0xa3, 0x70, 0x5d, 0xe7, 0x2a, 0x79, 0x20, 0xc8, 0x64, 0xa3, 0x90, 0x50, 0x27, 0xfc, 0xd1, 0xfb, 0xb9, 0xa1, 0xf2, 0xe9, 0xc7, 0x1b, 0x65, 0xe0, 0x5e, 0xb5, 0x7b, 0xf5, 0x64, 0xb2, 0xe6, 0xfe, 0x5f, 0x7c, 0xfe, 0x17, 0x00, 0x00, 0xff, 0xff, 0x7f, 0x8c, 0xd4, 0xd9, 0x9d, 0x08, 0x00, 0x00, } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context var _ grpc.ClientConnInterface // 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.SupportPackageIsVersion6 // ManagementClient is the client API for Management service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type ManagementClient interface { // 数据列表 DataList(ctx context.Context, in *v1.DataListRequest, opts ...grpc.CallOption) (*v1.DataListReply, error) // 数据搜索列表 SearchData(ctx context.Context, in *v1.SearchDataRequest, opts ...grpc.CallOption) (*v1.SearchDataReply, error) // 所属层搜索列表 SearchLevel(ctx context.Context, in *v1.SearchLevelRequest, opts ...grpc.CallOption) (*v1.SearchLevelReply, error) // 关系列表 Relation(ctx context.Context, in *v1.RelationRequest, opts ...grpc.CallOption) (*v1.RelationReply, error) // 开关 Switch(ctx context.Context, in *v1.SwitchRequest, opts ...grpc.CallOption) (*v1.SwitchReply, error) // 任务列表 TaskList(ctx context.Context, in *v1.TaskListRequest, opts ...grpc.CallOption) (*v1.TaskListReply, error) // 任务搜索列表 SearchTask(ctx context.Context, in *v1.SearchTaskRequest, opts ...grpc.CallOption) (*v1.SearchTaskReply, error) // 依赖表 Dependency(ctx context.Context, in *v1.DependencyRequest, opts ...grpc.CallOption) (*v1.DependencyReply, error) // 血缘关系 DataSourceRelation(ctx context.Context, in *v1.DataSourceRelationRequest, opts ...grpc.CallOption) (*v1.DataSourceRelationReply, error) // 手动任务列表 ManualTask(ctx context.Context, in *v1.ManualTaskRequest, opts ...grpc.CallOption) (*v1.ManualTaskReply, error) // 源表搜索列表 Source(ctx context.Context, in *v1.SourceRequest, opts ...grpc.CallOption) (*v1.SourceReply, error) // 任务列表 Task(ctx context.Context, in *v1.TaskRequest, opts ...grpc.CallOption) (*v1.TaskReply, error) // 源表创建 Create(ctx context.Context, in *v1.CreateRequest, opts ...grpc.CallOption) (*v1.CreateReply, error) // 上传创建 UploadFile(ctx context.Context, in *v1.UploadFileRequest, opts ...grpc.CallOption) (*v1.UploadFileReply, error) // 字段管理 Field(ctx context.Context, in *v1.FieldRequest, opts ...grpc.CallOption) (*v1.FieldReply, error) // 导出EXCEL Excel(ctx context.Context, in *v1.ExcelRequest, opts ...grpc.CallOption) (*v1.ExcelReply, error) // API管理 APIList(ctx context.Context, in *v1.APIListRequest, opts ...grpc.CallOption) (*v1.APIListReply, error) // 查看API CheckAPI(ctx context.Context, in *v1.CheckAPIRequest, opts ...grpc.CallOption) (*v1.CheckAPIReply, error) // 删除API DeleteAPI(ctx context.Context, in *v1.DeleteAPIRequest, opts ...grpc.CallOption) (*v1.DeleteAPIReply, error) // 密钥管理 KeyList(ctx context.Context, in *v1.KeyListRequest, opts ...grpc.CallOption) (*v1.KeyListReply, error) // 新增密钥 CreateKey(ctx context.Context, in *v1.CreateKeyRequest, opts ...grpc.CallOption) (*v1.CreateKeyReply, error) // 删除密钥 DeleteKey(ctx context.Context, in *v1.DeleteKeyRequest, opts ...grpc.CallOption) (*v1.DeleteKeyReply, error) // API列表 AllAPI(ctx context.Context, in *v1.AllAPIRequest, opts ...grpc.CallOption) (*v1.AllAPIReply, error) // 密钥列表 AllKey(ctx context.Context, in *v1.AllKeyRequest, opts ...grpc.CallOption) (*v1.AllKeyReply, error) // API查询 UseAPI(ctx context.Context, in *v1.UseAPIRequest, opts ...grpc.CallOption) (*v1.UseAPIReply, error) // 查看表结构 TableStruct(ctx context.Context, in *v1.TableStructRequest, opts ...grpc.CallOption) (*v1.TableStructReply, error) // 车型映射管理 StyleMap(ctx context.Context, in *v1.StyleMapRequest, opts ...grpc.CallOption) (*v1.StyleMapReply, error) // 编辑 EditMap(ctx context.Context, in *v1.EditMapRequest, opts ...grpc.CallOption) (*v1.EditMapReply, error) // 映射源列表 AllSource(ctx context.Context, in *v1.AllSourceRequest, opts ...grpc.CallOption) (*v1.AllSourceReply, error) // 信息公告 AnnouncementList(ctx context.Context, in *v1.AnnouncementRequest, opts ...grpc.CallOption) (*v1.AnnouncementReply, error) // 编辑 Edit(ctx context.Context, in *v1.EditRequest, opts ...grpc.CallOption) (*v1.EditReply, error) // 数据导入模板 DataImportTemplate(ctx context.Context, in *v1.DataImportTemplateRequest, opts ...grpc.CallOption) (*v1.DataImportTemplateReply, error) // 新建模板 CreateTemplate(ctx context.Context, in *v1.CreateTemplateRequest, opts ...grpc.CallOption) (*v1.CreateTemplateReply, error) // 修改模板 EditTemplate(ctx context.Context, in *v1.EditTemplateRequest, opts ...grpc.CallOption) (*v1.EditTemplateReply, error) // 删除模板 DeleteTemplate(ctx context.Context, in *v1.DeleteTemplateRequest, opts ...grpc.CallOption) (*v1.DeleteTemplateReply, error) // 数据导入 DataImport(ctx context.Context, in *v1.DataImportRequest, opts ...grpc.CallOption) (*v1.DataImportReply, error) // 更新API表 UpdateAPI(ctx context.Context, in *v1.UpdateAPIRequest, opts ...grpc.CallOption) (*v1.UpdateAPIReply, error) } type managementClient struct { cc grpc.ClientConnInterface } func NewManagementClient(cc grpc.ClientConnInterface) ManagementClient { return &managementClient{cc} } func (c *managementClient) DataList(ctx context.Context, in *v1.DataListRequest, opts ...grpc.CallOption) (*v1.DataListReply, error) { out := new(v1.DataListReply) err := c.cc.Invoke(ctx, "/pb.service.Management/DataList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) SearchData(ctx context.Context, in *v1.SearchDataRequest, opts ...grpc.CallOption) (*v1.SearchDataReply, error) { out := new(v1.SearchDataReply) err := c.cc.Invoke(ctx, "/pb.service.Management/SearchData", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) SearchLevel(ctx context.Context, in *v1.SearchLevelRequest, opts ...grpc.CallOption) (*v1.SearchLevelReply, error) { out := new(v1.SearchLevelReply) err := c.cc.Invoke(ctx, "/pb.service.Management/SearchLevel", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Relation(ctx context.Context, in *v1.RelationRequest, opts ...grpc.CallOption) (*v1.RelationReply, error) { out := new(v1.RelationReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Relation", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Switch(ctx context.Context, in *v1.SwitchRequest, opts ...grpc.CallOption) (*v1.SwitchReply, error) { out := new(v1.SwitchReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Switch", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) TaskList(ctx context.Context, in *v1.TaskListRequest, opts ...grpc.CallOption) (*v1.TaskListReply, error) { out := new(v1.TaskListReply) err := c.cc.Invoke(ctx, "/pb.service.Management/TaskList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) SearchTask(ctx context.Context, in *v1.SearchTaskRequest, opts ...grpc.CallOption) (*v1.SearchTaskReply, error) { out := new(v1.SearchTaskReply) err := c.cc.Invoke(ctx, "/pb.service.Management/SearchTask", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Dependency(ctx context.Context, in *v1.DependencyRequest, opts ...grpc.CallOption) (*v1.DependencyReply, error) { out := new(v1.DependencyReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Dependency", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) DataSourceRelation(ctx context.Context, in *v1.DataSourceRelationRequest, opts ...grpc.CallOption) (*v1.DataSourceRelationReply, error) { out := new(v1.DataSourceRelationReply) err := c.cc.Invoke(ctx, "/pb.service.Management/DataSourceRelation", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) ManualTask(ctx context.Context, in *v1.ManualTaskRequest, opts ...grpc.CallOption) (*v1.ManualTaskReply, error) { out := new(v1.ManualTaskReply) err := c.cc.Invoke(ctx, "/pb.service.Management/ManualTask", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Source(ctx context.Context, in *v1.SourceRequest, opts ...grpc.CallOption) (*v1.SourceReply, error) { out := new(v1.SourceReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Source", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Task(ctx context.Context, in *v1.TaskRequest, opts ...grpc.CallOption) (*v1.TaskReply, error) { out := new(v1.TaskReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Task", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Create(ctx context.Context, in *v1.CreateRequest, opts ...grpc.CallOption) (*v1.CreateReply, error) { out := new(v1.CreateReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Create", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) UploadFile(ctx context.Context, in *v1.UploadFileRequest, opts ...grpc.CallOption) (*v1.UploadFileReply, error) { out := new(v1.UploadFileReply) err := c.cc.Invoke(ctx, "/pb.service.Management/UploadFile", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Field(ctx context.Context, in *v1.FieldRequest, opts ...grpc.CallOption) (*v1.FieldReply, error) { out := new(v1.FieldReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Field", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Excel(ctx context.Context, in *v1.ExcelRequest, opts ...grpc.CallOption) (*v1.ExcelReply, error) { out := new(v1.ExcelReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Excel", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) APIList(ctx context.Context, in *v1.APIListRequest, opts ...grpc.CallOption) (*v1.APIListReply, error) { out := new(v1.APIListReply) err := c.cc.Invoke(ctx, "/pb.service.Management/APIList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) CheckAPI(ctx context.Context, in *v1.CheckAPIRequest, opts ...grpc.CallOption) (*v1.CheckAPIReply, error) { out := new(v1.CheckAPIReply) err := c.cc.Invoke(ctx, "/pb.service.Management/CheckAPI", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) DeleteAPI(ctx context.Context, in *v1.DeleteAPIRequest, opts ...grpc.CallOption) (*v1.DeleteAPIReply, error) { out := new(v1.DeleteAPIReply) err := c.cc.Invoke(ctx, "/pb.service.Management/DeleteAPI", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) KeyList(ctx context.Context, in *v1.KeyListRequest, opts ...grpc.CallOption) (*v1.KeyListReply, error) { out := new(v1.KeyListReply) err := c.cc.Invoke(ctx, "/pb.service.Management/KeyList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) CreateKey(ctx context.Context, in *v1.CreateKeyRequest, opts ...grpc.CallOption) (*v1.CreateKeyReply, error) { out := new(v1.CreateKeyReply) err := c.cc.Invoke(ctx, "/pb.service.Management/CreateKey", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) DeleteKey(ctx context.Context, in *v1.DeleteKeyRequest, opts ...grpc.CallOption) (*v1.DeleteKeyReply, error) { out := new(v1.DeleteKeyReply) err := c.cc.Invoke(ctx, "/pb.service.Management/DeleteKey", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) AllAPI(ctx context.Context, in *v1.AllAPIRequest, opts ...grpc.CallOption) (*v1.AllAPIReply, error) { out := new(v1.AllAPIReply) err := c.cc.Invoke(ctx, "/pb.service.Management/AllAPI", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) AllKey(ctx context.Context, in *v1.AllKeyRequest, opts ...grpc.CallOption) (*v1.AllKeyReply, error) { out := new(v1.AllKeyReply) err := c.cc.Invoke(ctx, "/pb.service.Management/AllKey", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) UseAPI(ctx context.Context, in *v1.UseAPIRequest, opts ...grpc.CallOption) (*v1.UseAPIReply, error) { out := new(v1.UseAPIReply) err := c.cc.Invoke(ctx, "/pb.service.Management/UseAPI", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) TableStruct(ctx context.Context, in *v1.TableStructRequest, opts ...grpc.CallOption) (*v1.TableStructReply, error) { out := new(v1.TableStructReply) err := c.cc.Invoke(ctx, "/pb.service.Management/TableStruct", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) StyleMap(ctx context.Context, in *v1.StyleMapRequest, opts ...grpc.CallOption) (*v1.StyleMapReply, error) { out := new(v1.StyleMapReply) err := c.cc.Invoke(ctx, "/pb.service.Management/StyleMap", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) EditMap(ctx context.Context, in *v1.EditMapRequest, opts ...grpc.CallOption) (*v1.EditMapReply, error) { out := new(v1.EditMapReply) err := c.cc.Invoke(ctx, "/pb.service.Management/EditMap", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) AllSource(ctx context.Context, in *v1.AllSourceRequest, opts ...grpc.CallOption) (*v1.AllSourceReply, error) { out := new(v1.AllSourceReply) err := c.cc.Invoke(ctx, "/pb.service.Management/AllSource", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) AnnouncementList(ctx context.Context, in *v1.AnnouncementRequest, opts ...grpc.CallOption) (*v1.AnnouncementReply, error) { out := new(v1.AnnouncementReply) err := c.cc.Invoke(ctx, "/pb.service.Management/AnnouncementList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) Edit(ctx context.Context, in *v1.EditRequest, opts ...grpc.CallOption) (*v1.EditReply, error) { out := new(v1.EditReply) err := c.cc.Invoke(ctx, "/pb.service.Management/Edit", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) DataImportTemplate(ctx context.Context, in *v1.DataImportTemplateRequest, opts ...grpc.CallOption) (*v1.DataImportTemplateReply, error) { out := new(v1.DataImportTemplateReply) err := c.cc.Invoke(ctx, "/pb.service.Management/DataImportTemplate", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) CreateTemplate(ctx context.Context, in *v1.CreateTemplateRequest, opts ...grpc.CallOption) (*v1.CreateTemplateReply, error) { out := new(v1.CreateTemplateReply) err := c.cc.Invoke(ctx, "/pb.service.Management/CreateTemplate", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) EditTemplate(ctx context.Context, in *v1.EditTemplateRequest, opts ...grpc.CallOption) (*v1.EditTemplateReply, error) { out := new(v1.EditTemplateReply) err := c.cc.Invoke(ctx, "/pb.service.Management/EditTemplate", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) DeleteTemplate(ctx context.Context, in *v1.DeleteTemplateRequest, opts ...grpc.CallOption) (*v1.DeleteTemplateReply, error) { out := new(v1.DeleteTemplateReply) err := c.cc.Invoke(ctx, "/pb.service.Management/DeleteTemplate", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) DataImport(ctx context.Context, in *v1.DataImportRequest, opts ...grpc.CallOption) (*v1.DataImportReply, error) { out := new(v1.DataImportReply) err := c.cc.Invoke(ctx, "/pb.service.Management/DataImport", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *managementClient) UpdateAPI(ctx context.Context, in *v1.UpdateAPIRequest, opts ...grpc.CallOption) (*v1.UpdateAPIReply, error) { out := new(v1.UpdateAPIReply) err := c.cc.Invoke(ctx, "/pb.service.Management/UpdateAPI", in, out, opts...) if err != nil { return nil, err } return out, nil } // ManagementServer is the server API for Management service. type ManagementServer interface { // 数据列表 DataList(context.Context, *v1.DataListRequest) (*v1.DataListReply, error) // 数据搜索列表 SearchData(context.Context, *v1.SearchDataRequest) (*v1.SearchDataReply, error) // 所属层搜索列表 SearchLevel(context.Context, *v1.SearchLevelRequest) (*v1.SearchLevelReply, error) // 关系列表 Relation(context.Context, *v1.RelationRequest) (*v1.RelationReply, error) // 开关 Switch(context.Context, *v1.SwitchRequest) (*v1.SwitchReply, error) // 任务列表 TaskList(context.Context, *v1.TaskListRequest) (*v1.TaskListReply, error) // 任务搜索列表 SearchTask(context.Context, *v1.SearchTaskRequest) (*v1.SearchTaskReply, error) // 依赖表 Dependency(context.Context, *v1.DependencyRequest) (*v1.DependencyReply, error) // 血缘关系 DataSourceRelation(context.Context, *v1.DataSourceRelationRequest) (*v1.DataSourceRelationReply, error) // 手动任务列表 ManualTask(context.Context, *v1.ManualTaskRequest) (*v1.ManualTaskReply, error) // 源表搜索列表 Source(context.Context, *v1.SourceRequest) (*v1.SourceReply, error) // 任务列表 Task(context.Context, *v1.TaskRequest) (*v1.TaskReply, error) // 源表创建 Create(context.Context, *v1.CreateRequest) (*v1.CreateReply, error) // 上传创建 UploadFile(context.Context, *v1.UploadFileRequest) (*v1.UploadFileReply, error) // 字段管理 Field(context.Context, *v1.FieldRequest) (*v1.FieldReply, error) // 导出EXCEL Excel(context.Context, *v1.ExcelRequest) (*v1.ExcelReply, error) // API管理 APIList(context.Context, *v1.APIListRequest) (*v1.APIListReply, error) // 查看API CheckAPI(context.Context, *v1.CheckAPIRequest) (*v1.CheckAPIReply, error) // 删除API DeleteAPI(context.Context, *v1.DeleteAPIRequest) (*v1.DeleteAPIReply, error) // 密钥管理 KeyList(context.Context, *v1.KeyListRequest) (*v1.KeyListReply, error) // 新增密钥 CreateKey(context.Context, *v1.CreateKeyRequest) (*v1.CreateKeyReply, error) // 删除密钥 DeleteKey(context.Context, *v1.DeleteKeyRequest) (*v1.DeleteKeyReply, error) // API列表 AllAPI(context.Context, *v1.AllAPIRequest) (*v1.AllAPIReply, error) // 密钥列表 AllKey(context.Context, *v1.AllKeyRequest) (*v1.AllKeyReply, error) // API查询 UseAPI(context.Context, *v1.UseAPIRequest) (*v1.UseAPIReply, error) // 查看表结构 TableStruct(context.Context, *v1.TableStructRequest) (*v1.TableStructReply, error) // 车型映射管理 StyleMap(context.Context, *v1.StyleMapRequest) (*v1.StyleMapReply, error) // 编辑 EditMap(context.Context, *v1.EditMapRequest) (*v1.EditMapReply, error) // 映射源列表 AllSource(context.Context, *v1.AllSourceRequest) (*v1.AllSourceReply, error) // 信息公告 AnnouncementList(context.Context, *v1.AnnouncementRequest) (*v1.AnnouncementReply, error) // 编辑 Edit(context.Context, *v1.EditRequest) (*v1.EditReply, error) // 数据导入模板 DataImportTemplate(context.Context, *v1.DataImportTemplateRequest) (*v1.DataImportTemplateReply, error) // 新建模板 CreateTemplate(context.Context, *v1.CreateTemplateRequest) (*v1.CreateTemplateReply, error) // 修改模板 EditTemplate(context.Context, *v1.EditTemplateRequest) (*v1.EditTemplateReply, error) // 删除模板 DeleteTemplate(context.Context, *v1.DeleteTemplateRequest) (*v1.DeleteTemplateReply, error) // 数据导入 DataImport(context.Context, *v1.DataImportRequest) (*v1.DataImportReply, error) // 更新API表 UpdateAPI(context.Context, *v1.UpdateAPIRequest) (*v1.UpdateAPIReply, error) } // UnimplementedManagementServer can be embedded to have forward compatible implementations. type UnimplementedManagementServer struct { } func (*UnimplementedManagementServer) DataList(ctx context.Context, req *v1.DataListRequest) (*v1.DataListReply, error) { return nil, status.Errorf(codes.Unimplemented, "method DataList not implemented") } func (*UnimplementedManagementServer) SearchData(ctx context.Context, req *v1.SearchDataRequest) (*v1.SearchDataReply, error) { return nil, status.Errorf(codes.Unimplemented, "method SearchData not implemented") } func (*UnimplementedManagementServer) SearchLevel(ctx context.Context, req *v1.SearchLevelRequest) (*v1.SearchLevelReply, error) { return nil, status.Errorf(codes.Unimplemented, "method SearchLevel not implemented") } func (*UnimplementedManagementServer) Relation(ctx context.Context, req *v1.RelationRequest) (*v1.RelationReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Relation not implemented") } func (*UnimplementedManagementServer) Switch(ctx context.Context, req *v1.SwitchRequest) (*v1.SwitchReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Switch not implemented") } func (*UnimplementedManagementServer) TaskList(ctx context.Context, req *v1.TaskListRequest) (*v1.TaskListReply, error) { return nil, status.Errorf(codes.Unimplemented, "method TaskList not implemented") } func (*UnimplementedManagementServer) SearchTask(ctx context.Context, req *v1.SearchTaskRequest) (*v1.SearchTaskReply, error) { return nil, status.Errorf(codes.Unimplemented, "method SearchTask not implemented") } func (*UnimplementedManagementServer) Dependency(ctx context.Context, req *v1.DependencyRequest) (*v1.DependencyReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Dependency not implemented") } func (*UnimplementedManagementServer) DataSourceRelation(ctx context.Context, req *v1.DataSourceRelationRequest) (*v1.DataSourceRelationReply, error) { return nil, status.Errorf(codes.Unimplemented, "method DataSourceRelation not implemented") } func (*UnimplementedManagementServer) ManualTask(ctx context.Context, req *v1.ManualTaskRequest) (*v1.ManualTaskReply, error) { return nil, status.Errorf(codes.Unimplemented, "method ManualTask not implemented") } func (*UnimplementedManagementServer) Source(ctx context.Context, req *v1.SourceRequest) (*v1.SourceReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Source not implemented") } func (*UnimplementedManagementServer) Task(ctx context.Context, req *v1.TaskRequest) (*v1.TaskReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Task not implemented") } func (*UnimplementedManagementServer) Create(ctx context.Context, req *v1.CreateRequest) (*v1.CreateReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") } func (*UnimplementedManagementServer) UploadFile(ctx context.Context, req *v1.UploadFileRequest) (*v1.UploadFileReply, error) { return nil, status.Errorf(codes.Unimplemented, "method UploadFile not implemented") } func (*UnimplementedManagementServer) Field(ctx context.Context, req *v1.FieldRequest) (*v1.FieldReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Field not implemented") } func (*UnimplementedManagementServer) Excel(ctx context.Context, req *v1.ExcelRequest) (*v1.ExcelReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Excel not implemented") } func (*UnimplementedManagementServer) APIList(ctx context.Context, req *v1.APIListRequest) (*v1.APIListReply, error) { return nil, status.Errorf(codes.Unimplemented, "method APIList not implemented") } func (*UnimplementedManagementServer) CheckAPI(ctx context.Context, req *v1.CheckAPIRequest) (*v1.CheckAPIReply, error) { return nil, status.Errorf(codes.Unimplemented, "method CheckAPI not implemented") } func (*UnimplementedManagementServer) DeleteAPI(ctx context.Context, req *v1.DeleteAPIRequest) (*v1.DeleteAPIReply, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteAPI not implemented") } func (*UnimplementedManagementServer) KeyList(ctx context.Context, req *v1.KeyListRequest) (*v1.KeyListReply, error) { return nil, status.Errorf(codes.Unimplemented, "method KeyList not implemented") } func (*UnimplementedManagementServer) CreateKey(ctx context.Context, req *v1.CreateKeyRequest) (*v1.CreateKeyReply, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateKey not implemented") } func (*UnimplementedManagementServer) DeleteKey(ctx context.Context, req *v1.DeleteKeyRequest) (*v1.DeleteKeyReply, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteKey not implemented") } func (*UnimplementedManagementServer) AllAPI(ctx context.Context, req *v1.AllAPIRequest) (*v1.AllAPIReply, error) { return nil, status.Errorf(codes.Unimplemented, "method AllAPI not implemented") } func (*UnimplementedManagementServer) AllKey(ctx context.Context, req *v1.AllKeyRequest) (*v1.AllKeyReply, error) { return nil, status.Errorf(codes.Unimplemented, "method AllKey not implemented") } func (*UnimplementedManagementServer) UseAPI(ctx context.Context, req *v1.UseAPIRequest) (*v1.UseAPIReply, error) { return nil, status.Errorf(codes.Unimplemented, "method UseAPI not implemented") } func (*UnimplementedManagementServer) TableStruct(ctx context.Context, req *v1.TableStructRequest) (*v1.TableStructReply, error) { return nil, status.Errorf(codes.Unimplemented, "method TableStruct not implemented") } func (*UnimplementedManagementServer) StyleMap(ctx context.Context, req *v1.StyleMapRequest) (*v1.StyleMapReply, error) { return nil, status.Errorf(codes.Unimplemented, "method StyleMap not implemented") } func (*UnimplementedManagementServer) EditMap(ctx context.Context, req *v1.EditMapRequest) (*v1.EditMapReply, error) { return nil, status.Errorf(codes.Unimplemented, "method EditMap not implemented") } func (*UnimplementedManagementServer) AllSource(ctx context.Context, req *v1.AllSourceRequest) (*v1.AllSourceReply, error) { return nil, status.Errorf(codes.Unimplemented, "method AllSource not implemented") } func (*UnimplementedManagementServer) AnnouncementList(ctx context.Context, req *v1.AnnouncementRequest) (*v1.AnnouncementReply, error) { return nil, status.Errorf(codes.Unimplemented, "method AnnouncementList not implemented") } func (*UnimplementedManagementServer) Edit(ctx context.Context, req *v1.EditRequest) (*v1.EditReply, error) { return nil, status.Errorf(codes.Unimplemented, "method Edit not implemented") } func (*UnimplementedManagementServer) DataImportTemplate(ctx context.Context, req *v1.DataImportTemplateRequest) (*v1.DataImportTemplateReply, error) { return nil, status.Errorf(codes.Unimplemented, "method DataImportTemplate not implemented") } func (*UnimplementedManagementServer) CreateTemplate(ctx context.Context, req *v1.CreateTemplateRequest) (*v1.CreateTemplateReply, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateTemplate not implemented") } func (*UnimplementedManagementServer) EditTemplate(ctx context.Context, req *v1.EditTemplateRequest) (*v1.EditTemplateReply, error) { return nil, status.Errorf(codes.Unimplemented, "method EditTemplate not implemented") } func (*UnimplementedManagementServer) DeleteTemplate(ctx context.Context, req *v1.DeleteTemplateRequest) (*v1.DeleteTemplateReply, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteTemplate not implemented") } func (*UnimplementedManagementServer) DataImport(ctx context.Context, req *v1.DataImportRequest) (*v1.DataImportReply, error) { return nil, status.Errorf(codes.Unimplemented, "method DataImport not implemented") } func (*UnimplementedManagementServer) UpdateAPI(ctx context.Context, req *v1.UpdateAPIRequest) (*v1.UpdateAPIReply, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateAPI not implemented") } func RegisterManagementServer(s *grpc.Server, srv ManagementServer) { s.RegisterService(&_Management_serviceDesc, srv) } func _Management_DataList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DataListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).DataList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/DataList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).DataList(ctx, req.(*v1.DataListRequest)) } return interceptor(ctx, in, info, handler) } func _Management_SearchData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.SearchDataRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).SearchData(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/SearchData", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).SearchData(ctx, req.(*v1.SearchDataRequest)) } return interceptor(ctx, in, info, handler) } func _Management_SearchLevel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.SearchLevelRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).SearchLevel(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/SearchLevel", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).SearchLevel(ctx, req.(*v1.SearchLevelRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Relation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.RelationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Relation(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Relation", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Relation(ctx, req.(*v1.RelationRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Switch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.SwitchRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Switch(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Switch", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Switch(ctx, req.(*v1.SwitchRequest)) } return interceptor(ctx, in, info, handler) } func _Management_TaskList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.TaskListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).TaskList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/TaskList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).TaskList(ctx, req.(*v1.TaskListRequest)) } return interceptor(ctx, in, info, handler) } func _Management_SearchTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.SearchTaskRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).SearchTask(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/SearchTask", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).SearchTask(ctx, req.(*v1.SearchTaskRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Dependency_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DependencyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Dependency(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Dependency", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Dependency(ctx, req.(*v1.DependencyRequest)) } return interceptor(ctx, in, info, handler) } func _Management_DataSourceRelation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DataSourceRelationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).DataSourceRelation(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/DataSourceRelation", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).DataSourceRelation(ctx, req.(*v1.DataSourceRelationRequest)) } return interceptor(ctx, in, info, handler) } func _Management_ManualTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.ManualTaskRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).ManualTask(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/ManualTask", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).ManualTask(ctx, req.(*v1.ManualTaskRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Source_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.SourceRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Source(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Source", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Source(ctx, req.(*v1.SourceRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Task_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.TaskRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Task(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Task", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Task(ctx, req.(*v1.TaskRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.CreateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Create(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Create", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Create(ctx, req.(*v1.CreateRequest)) } return interceptor(ctx, in, info, handler) } func _Management_UploadFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.UploadFileRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).UploadFile(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/UploadFile", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).UploadFile(ctx, req.(*v1.UploadFileRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Field_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.FieldRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Field(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Field", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Field(ctx, req.(*v1.FieldRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Excel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.ExcelRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Excel(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Excel", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Excel(ctx, req.(*v1.ExcelRequest)) } return interceptor(ctx, in, info, handler) } func _Management_APIList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.APIListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).APIList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/APIList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).APIList(ctx, req.(*v1.APIListRequest)) } return interceptor(ctx, in, info, handler) } func _Management_CheckAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.CheckAPIRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).CheckAPI(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/CheckAPI", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).CheckAPI(ctx, req.(*v1.CheckAPIRequest)) } return interceptor(ctx, in, info, handler) } func _Management_DeleteAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DeleteAPIRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).DeleteAPI(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/DeleteAPI", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).DeleteAPI(ctx, req.(*v1.DeleteAPIRequest)) } return interceptor(ctx, in, info, handler) } func _Management_KeyList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.KeyListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).KeyList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/KeyList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).KeyList(ctx, req.(*v1.KeyListRequest)) } return interceptor(ctx, in, info, handler) } func _Management_CreateKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.CreateKeyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).CreateKey(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/CreateKey", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).CreateKey(ctx, req.(*v1.CreateKeyRequest)) } return interceptor(ctx, in, info, handler) } func _Management_DeleteKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DeleteKeyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).DeleteKey(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/DeleteKey", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).DeleteKey(ctx, req.(*v1.DeleteKeyRequest)) } return interceptor(ctx, in, info, handler) } func _Management_AllAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.AllAPIRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).AllAPI(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/AllAPI", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).AllAPI(ctx, req.(*v1.AllAPIRequest)) } return interceptor(ctx, in, info, handler) } func _Management_AllKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.AllKeyRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).AllKey(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/AllKey", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).AllKey(ctx, req.(*v1.AllKeyRequest)) } return interceptor(ctx, in, info, handler) } func _Management_UseAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.UseAPIRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).UseAPI(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/UseAPI", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).UseAPI(ctx, req.(*v1.UseAPIRequest)) } return interceptor(ctx, in, info, handler) } func _Management_TableStruct_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.TableStructRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).TableStruct(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/TableStruct", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).TableStruct(ctx, req.(*v1.TableStructRequest)) } return interceptor(ctx, in, info, handler) } func _Management_StyleMap_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.StyleMapRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).StyleMap(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/StyleMap", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).StyleMap(ctx, req.(*v1.StyleMapRequest)) } return interceptor(ctx, in, info, handler) } func _Management_EditMap_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.EditMapRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).EditMap(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/EditMap", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).EditMap(ctx, req.(*v1.EditMapRequest)) } return interceptor(ctx, in, info, handler) } func _Management_AllSource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.AllSourceRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).AllSource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/AllSource", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).AllSource(ctx, req.(*v1.AllSourceRequest)) } return interceptor(ctx, in, info, handler) } func _Management_AnnouncementList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.AnnouncementRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).AnnouncementList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/AnnouncementList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).AnnouncementList(ctx, req.(*v1.AnnouncementRequest)) } return interceptor(ctx, in, info, handler) } func _Management_Edit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.EditRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).Edit(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/Edit", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).Edit(ctx, req.(*v1.EditRequest)) } return interceptor(ctx, in, info, handler) } func _Management_DataImportTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DataImportTemplateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).DataImportTemplate(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/DataImportTemplate", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).DataImportTemplate(ctx, req.(*v1.DataImportTemplateRequest)) } return interceptor(ctx, in, info, handler) } func _Management_CreateTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.CreateTemplateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).CreateTemplate(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/CreateTemplate", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).CreateTemplate(ctx, req.(*v1.CreateTemplateRequest)) } return interceptor(ctx, in, info, handler) } func _Management_EditTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.EditTemplateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).EditTemplate(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/EditTemplate", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).EditTemplate(ctx, req.(*v1.EditTemplateRequest)) } return interceptor(ctx, in, info, handler) } func _Management_DeleteTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DeleteTemplateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).DeleteTemplate(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/DeleteTemplate", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).DeleteTemplate(ctx, req.(*v1.DeleteTemplateRequest)) } return interceptor(ctx, in, info, handler) } func _Management_DataImport_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.DataImportRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).DataImport(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/DataImport", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).DataImport(ctx, req.(*v1.DataImportRequest)) } return interceptor(ctx, in, info, handler) } func _Management_UpdateAPI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(v1.UpdateAPIRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ManagementServer).UpdateAPI(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.service.Management/UpdateAPI", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ManagementServer).UpdateAPI(ctx, req.(*v1.UpdateAPIRequest)) } return interceptor(ctx, in, info, handler) } var _Management_serviceDesc = grpc.ServiceDesc{ ServiceName: "pb.service.Management", HandlerType: (*ManagementServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "DataList", Handler: _Management_DataList_Handler, }, { MethodName: "SearchData", Handler: _Management_SearchData_Handler, }, { MethodName: "SearchLevel", Handler: _Management_SearchLevel_Handler, }, { MethodName: "Relation", Handler: _Management_Relation_Handler, }, { MethodName: "Switch", Handler: _Management_Switch_Handler, }, { MethodName: "TaskList", Handler: _Management_TaskList_Handler, }, { MethodName: "SearchTask", Handler: _Management_SearchTask_Handler, }, { MethodName: "Dependency", Handler: _Management_Dependency_Handler, }, { MethodName: "DataSourceRelation", Handler: _Management_DataSourceRelation_Handler, }, { MethodName: "ManualTask", Handler: _Management_ManualTask_Handler, }, { MethodName: "Source", Handler: _Management_Source_Handler, }, { MethodName: "Task", Handler: _Management_Task_Handler, }, { MethodName: "Create", Handler: _Management_Create_Handler, }, { MethodName: "UploadFile", Handler: _Management_UploadFile_Handler, }, { MethodName: "Field", Handler: _Management_Field_Handler, }, { MethodName: "Excel", Handler: _Management_Excel_Handler, }, { MethodName: "APIList", Handler: _Management_APIList_Handler, }, { MethodName: "CheckAPI", Handler: _Management_CheckAPI_Handler, }, { MethodName: "DeleteAPI", Handler: _Management_DeleteAPI_Handler, }, { MethodName: "KeyList", Handler: _Management_KeyList_Handler, }, { MethodName: "CreateKey", Handler: _Management_CreateKey_Handler, }, { MethodName: "DeleteKey", Handler: _Management_DeleteKey_Handler, }, { MethodName: "AllAPI", Handler: _Management_AllAPI_Handler, }, { MethodName: "AllKey", Handler: _Management_AllKey_Handler, }, { MethodName: "UseAPI", Handler: _Management_UseAPI_Handler, }, { MethodName: "TableStruct", Handler: _Management_TableStruct_Handler, }, { MethodName: "StyleMap", Handler: _Management_StyleMap_Handler, }, { MethodName: "EditMap", Handler: _Management_EditMap_Handler, }, { MethodName: "AllSource", Handler: _Management_AllSource_Handler, }, { MethodName: "AnnouncementList", Handler: _Management_AnnouncementList_Handler, }, { MethodName: "Edit", Handler: _Management_Edit_Handler, }, { MethodName: "DataImportTemplate", Handler: _Management_DataImportTemplate_Handler, }, { MethodName: "CreateTemplate", Handler: _Management_CreateTemplate_Handler, }, { MethodName: "EditTemplate", Handler: _Management_EditTemplate_Handler, }, { MethodName: "DeleteTemplate", Handler: _Management_DeleteTemplate_Handler, }, { MethodName: "DataImport", Handler: _Management_DataImport_Handler, }, { MethodName: "UpdateAPI", Handler: _Management_UpdateAPI_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "adm_management.proto", }