bigdata
/
dsMin
6
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'd920dc0dd5'
${ noResults }
dsMin/dsBaseWeb/Tools/proto/DataexDataaccess/DataexDataaccessProto/DataexDataaccess.pb.go

809 lines
30 KiB
Raw Blame History Escape

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.21.0
// protoc v3.11.4
// source: DataexDataaccess.proto
//在web层重新生成pb.go的方法
//
//protoc -I Business/DataexDataaccess/DataexDataaccessProto/ Business/DataexDataaccess/DataexDataaccessProto/DataexDataaccess.proto --go_out=plugins=grpc:Business/DataexDataaccess/DataexDataaccessProto
package DataexDataaccessProto
import (
context "context"
proto "github.com/golang/protobuf/proto"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
// This is a compile-time assertion that a sufficiently up-to-date version
// of the legacy proto package is being used.
const _ = proto.ProtoPackageIsVersion4
type ModelArg struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
//ID
Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
//数据源ID
DatasourceId string `protobuf:"bytes,2,opt,name=DatasourceId,proto3" json:"DatasourceId,omitempty"`
//
DatasourceCode string `protobuf:"bytes,3,opt,name=DatasourceCode,proto3" json:"DatasourceCode,omitempty"`
//数据使用系统ID
ConsumeSystemid string `protobuf:"bytes,4,opt,name=ConsumeSystemid,proto3" json:"ConsumeSystemid,omitempty"`
//可查【1：是，-1：否】
QueryFlag int32 `protobuf:"varint,5,opt,name=QueryFlag,proto3" json:"QueryFlag,omitempty"`
//可修改【1：是，-1：否】
SetFlag int32 `protobuf:"varint,6,opt,name=SetFlag,proto3" json:"SetFlag,omitempty"`
//使用数据范围【1：本机构，2：本机构以及下属机构，-1：不限制】
ConsumeType int32 `protobuf:"varint,7,opt,name=ConsumeType,proto3" json:"ConsumeType,omitempty"`
//使用数据机构ID【-1：不限制】
ConsumeOrgid string `protobuf:"bytes,8,opt,name=ConsumeOrgid,proto3" json:"ConsumeOrgid,omitempty"`
//建立时间
CreateTime string `protobuf:"bytes,9,opt,name=CreateTime,proto3" json:"CreateTime,omitempty"`
//最近修改时间
ChangeTime string `protobuf:"bytes,10,opt,name=ChangeTime,proto3" json:"ChangeTime,omitempty"`
//删除时间
DeleteTime string `protobuf:"bytes,11,opt,name=DeleteTime,proto3" json:"DeleteTime,omitempty"`
//删除标志【默认-1，1：删除，-1：正常】
DeleteFlag int32 `protobuf:"varint,12,opt,name=DeleteFlag,proto3" json:"DeleteFlag,omitempty"`
//启用标志【默认1，1：启用，-1：禁用】
EnableFlag int32 `protobuf:"varint,13,opt,name=EnableFlag,proto3" json:"EnableFlag,omitempty"`
//需要强制更新的列
ForceUpdateFields []string `protobuf:"bytes,14,rep,name=ForceUpdateFields,proto3" json:"ForceUpdateFields,omitempty"`
}
func (x *ModelArg) Reset() {
*x = ModelArg{}
if protoimpl.UnsafeEnabled {
mi := &file_DataexDataaccess_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ModelArg) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ModelArg) ProtoMessage() {}
func (x *ModelArg) ProtoReflect() protoreflect.Message {
mi := &file_DataexDataaccess_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ModelArg.ProtoReflect.Descriptor instead.
func (*ModelArg) Descriptor() ([]byte, []int) {
return file_DataexDataaccess_proto_rawDescGZIP(), []int{0}
}
func (x *ModelArg) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *ModelArg) GetDatasourceId() string {
if x != nil {
return x.DatasourceId
}
return ""
}
func (x *ModelArg) GetDatasourceCode() string {
if x != nil {
return x.DatasourceCode
}
return ""
}
func (x *ModelArg) GetConsumeSystemid() string {
if x != nil {
return x.ConsumeSystemid
}
return ""
}
func (x *ModelArg) GetQueryFlag() int32 {
if x != nil {
return x.QueryFlag
}
return 0
}
func (x *ModelArg) GetSetFlag() int32 {
if x != nil {
return x.SetFlag
}
return 0
}
func (x *ModelArg) GetConsumeType() int32 {
if x != nil {
return x.ConsumeType
}
return 0
}
func (x *ModelArg) GetConsumeOrgid() string {
if x != nil {
return x.ConsumeOrgid
}
return ""
}
func (x *ModelArg) GetCreateTime() string {
if x != nil {
return x.CreateTime
}
return ""
}
func (x *ModelArg) GetChangeTime() string {
if x != nil {
return x.ChangeTime
}
return ""
}
func (x *ModelArg) GetDeleteTime() string {
if x != nil {
return x.DeleteTime
}
return ""
}
func (x *ModelArg) GetDeleteFlag() int32 {
if x != nil {
return x.DeleteFlag
}
return 0
}
func (x *ModelArg) GetEnableFlag() int32 {
if x != nil {
return x.EnableFlag
}
return 0
}
func (x *ModelArg) GetForceUpdateFields() []string {
if x != nil {
return x.ForceUpdateFields
}
return nil
}
// 查询参数
type QueryArg struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Page int32 `protobuf:"varint,1,opt,name=Page,proto3" json:"Page,omitempty"`
Limit int32 `protobuf:"varint,2,opt,name=Limit,proto3" json:"Limit,omitempty"`
}
func (x *QueryArg) Reset() {
*x = QueryArg{}
if protoimpl.UnsafeEnabled {
mi := &file_DataexDataaccess_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *QueryArg) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueryArg) ProtoMessage() {}
func (x *QueryArg) ProtoReflect() protoreflect.Message {
mi := &file_DataexDataaccess_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use QueryArg.ProtoReflect.Descriptor instead.
func (*QueryArg) Descriptor() ([]byte, []int) {
return file_DataexDataaccess_proto_rawDescGZIP(), []int{1}
}
func (x *QueryArg) GetPage() int32 {
if x != nil {
return x.Page
}
return 0
}
func (x *QueryArg) GetLimit() int32 {
if x != nil {
return x.Limit
}
return 0
}
// 查询请求响应
type Reply struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
Count int32 `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"`
List string `protobuf:"bytes,4,opt,name=List,proto3" json:"List,omitempty"`
}
func (x *Reply) Reset() {
*x = Reply{}
if protoimpl.UnsafeEnabled {
mi := &file_DataexDataaccess_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Reply) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Reply) ProtoMessage() {}
func (x *Reply) ProtoReflect() protoreflect.Message {
mi := &file_DataexDataaccess_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Reply.ProtoReflect.Descriptor instead.
func (*Reply) Descriptor() ([]byte, []int) {
return file_DataexDataaccess_proto_rawDescGZIP(), []int{2}
}
func (x *Reply) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *Reply) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *Reply) GetCount() int32 {
if x != nil {
return x.Count
}
return 0
}
func (x *Reply) GetList() string {
if x != nil {
return x.List
}
return ""
}
//删除参数
type DeleteIdsArg struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
//一个或多个ID
Ids []string `protobuf:"bytes,1,rep,name=Ids,proto3" json:"Ids,omitempty"`
}
func (x *DeleteIdsArg) Reset() {
*x = DeleteIdsArg{}
if protoimpl.UnsafeEnabled {
mi := &file_DataexDataaccess_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *DeleteIdsArg) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DeleteIdsArg) ProtoMessage() {}
func (x *DeleteIdsArg) ProtoReflect() protoreflect.Message {
mi := &file_DataexDataaccess_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DeleteIdsArg.ProtoReflect.Descriptor instead.
func (*DeleteIdsArg) Descriptor() ([]byte, []int) {
return file_DataexDataaccess_proto_rawDescGZIP(), []int{3}
}
func (x *DeleteIdsArg) GetIds() []string {
if x != nil {
return x.Ids
}
return nil
}
var File_DataexDataaccess_proto protoreflect.FileDescriptor
var file_DataexDataaccess_proto_rawDesc = []byte{
0x0a, 0x16, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65,
0x73, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x15, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78,
0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x22,
0xdc, 0x03, 0x0a, 0x08, 0x4d, 0x6f, 0x64, 0x65, 0x6c, 0x41, 0x72, 0x67, 0x12, 0x0e, 0x0a, 0x02,
0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x49, 0x64, 0x12, 0x22, 0x0a, 0x0c,
0x44, 0x61, 0x74, 0x61, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01,
0x28, 0x09, 0x52, 0x0c, 0x44, 0x61, 0x74, 0x61, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x49, 0x64,
0x12, 0x26, 0x0a, 0x0e, 0x44, 0x61, 0x74, 0x61, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x43, 0x6f,
0x64, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x44, 0x61, 0x74, 0x61, 0x73, 0x6f,
0x75, 0x72, 0x63, 0x65, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x28, 0x0a, 0x0f, 0x43, 0x6f, 0x6e, 0x73,
0x75, 0x6d, 0x65, 0x53, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28,
0x09, 0x52, 0x0f, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x53, 0x79, 0x73, 0x74, 0x65, 0x6d,
0x69, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x51, 0x75, 0x65, 0x72, 0x79, 0x46, 0x6c, 0x61, 0x67, 0x18,
0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x51, 0x75, 0x65, 0x72, 0x79, 0x46, 0x6c, 0x61, 0x67,
0x12, 0x18, 0x0a, 0x07, 0x53, 0x65, 0x74, 0x46, 0x6c, 0x61, 0x67, 0x18, 0x06, 0x20, 0x01, 0x28,
0x05, 0x52, 0x07, 0x53, 0x65, 0x74, 0x46, 0x6c, 0x61, 0x67, 0x12, 0x20, 0x0a, 0x0b, 0x43, 0x6f,
0x6e, 0x73, 0x75, 0x6d, 0x65, 0x54, 0x79, 0x70, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52,
0x0b, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x54, 0x79, 0x70, 0x65, 0x12, 0x22, 0x0a, 0x0c,
0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x4f, 0x72, 0x67, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01,
0x28, 0x09, 0x52, 0x0c, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x4f, 0x72, 0x67, 0x69, 0x64,
0x12, 0x1e, 0x0a, 0x0a, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x09,
0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65,
0x12, 0x1e, 0x0a, 0x0a, 0x43, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x0a,
0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x43, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x54, 0x69, 0x6d, 0x65,
0x12, 0x1e, 0x0a, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x0b,
0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65,
0x12, 0x1e, 0x0a, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x46, 0x6c, 0x61, 0x67, 0x18, 0x0c,
0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x46, 0x6c, 0x61, 0x67,
0x12, 0x1e, 0x0a, 0x0a, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x46, 0x6c, 0x61, 0x67, 0x18, 0x0d,
0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x45, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x46, 0x6c, 0x61, 0x67,
0x12, 0x2c, 0x0a, 0x11, 0x46, 0x6f, 0x72, 0x63, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x46,
0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x0e, 0x20, 0x03, 0x28, 0x09, 0x52, 0x11, 0x46, 0x6f, 0x72,
0x63, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x22, 0x34,
0x0a, 0x08, 0x51, 0x75, 0x65, 0x72, 0x79, 0x41, 0x72, 0x67, 0x12, 0x12, 0x0a, 0x04, 0x50, 0x61,
0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x50, 0x61, 0x67, 0x65, 0x12, 0x14,
0x0a, 0x05, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x4c,
0x69, 0x6d, 0x69, 0x74, 0x22, 0x65, 0x0a, 0x05, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x12, 0x18, 0x0a,
0x07, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07,
0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61,
0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
0x65, 0x12, 0x14, 0x0a, 0x05, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05,
0x52, 0x05, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x18,
0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x4c, 0x69, 0x73, 0x74, 0x22, 0x20, 0x0a, 0x0c, 0x44,
0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x64, 0x73, 0x41, 0x72, 0x67, 0x12, 0x10, 0x0a, 0x03, 0x49,
0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x03, 0x49, 0x64, 0x73, 0x32, 0xdb, 0x03,
0x0a, 0x16, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65,
0x73, 0x73, 0x4d, 0x61, 0x6e, 0x61, 0x67, 0x65, 0x12, 0x56, 0x0a, 0x13, 0x47, 0x65, 0x74, 0x44,
0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12,
0x1f, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65,
0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x4d, 0x6f, 0x64, 0x65, 0x6c, 0x41, 0x72, 0x67,
0x1a, 0x1c, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63,
0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00,
0x12, 0x56, 0x0a, 0x13, 0x41, 0x64, 0x64, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74,
0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x1f, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78,
0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e,
0x4d, 0x6f, 0x64, 0x65, 0x6c, 0x41, 0x72, 0x67, 0x1a, 0x1c, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65,
0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f,
0x2e, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x5d, 0x0a, 0x16, 0x44, 0x65, 0x6c, 0x65,
0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65,
0x73, 0x73, 0x12, 0x23, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61,
0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74,
0x65, 0x49, 0x64, 0x73, 0x41, 0x72, 0x67, 0x1a, 0x1c, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78,
0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e,
0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x12, 0x59, 0x0a, 0x16, 0x55, 0x70, 0x64, 0x61, 0x74,
0x65, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73,
0x73, 0x12, 0x1f, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63,
0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x4d, 0x6f, 0x64, 0x65, 0x6c, 0x41,
0x72, 0x67, 0x1a, 0x1c, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61,
0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x79,
0x22, 0x00, 0x12, 0x57, 0x0a, 0x14, 0x50, 0x61, 0x67, 0x65, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78,
0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x1f, 0x2e, 0x44, 0x61, 0x74,
0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f,
0x74, 0x6f, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x41, 0x72, 0x67, 0x1a, 0x1c, 0x2e, 0x44, 0x61,
0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72,
0x6f, 0x74, 0x6f, 0x2e, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x22, 0x00, 0x42, 0x48, 0x0a, 0x16, 0x63,
0x6f, 0x6d, 0x2e, 0x64, 0x73, 0x69, 0x64, 0x65, 0x61, 0x6c, 0x2e, 0x64, 0x73, 0x6d, 0x69, 0x6e,
0x2e, 0x62, 0x61, 0x73, 0x65, 0x42, 0x10, 0x44, 0x61, 0x74, 0x61, 0x65, 0x78, 0x44, 0x61, 0x74,
0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x01, 0x5a, 0x17, 0x2e, 0x3b, 0x44, 0x61, 0x74,
0x61, 0x65, 0x78, 0x44, 0x61, 0x74, 0x61, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x72, 0x6f,
0x74, 0x6f, 0xa2, 0x02, 0x00, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_DataexDataaccess_proto_rawDescOnce sync.Once
file_DataexDataaccess_proto_rawDescData = file_DataexDataaccess_proto_rawDesc
)
func file_DataexDataaccess_proto_rawDescGZIP() []byte {
file_DataexDataaccess_proto_rawDescOnce.Do(func() {
file_DataexDataaccess_proto_rawDescData = protoimpl.X.CompressGZIP(file_DataexDataaccess_proto_rawDescData)
})
return file_DataexDataaccess_proto_rawDescData
}
var file_DataexDataaccess_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
var file_DataexDataaccess_proto_goTypes = []interface{}{
(*ModelArg)(nil), // 0: DataexDataaccessProto.ModelArg
(*QueryArg)(nil), // 1: DataexDataaccessProto.QueryArg
(*Reply)(nil), // 2: DataexDataaccessProto.Reply
(*DeleteIdsArg)(nil), // 3: DataexDataaccessProto.DeleteIdsArg
}
var file_DataexDataaccess_proto_depIdxs = []int32{
0, // 0: DataexDataaccessProto.DataexDataaccessManage.GetDataexDataaccess:input_type -> DataexDataaccessProto.ModelArg
0, // 1: DataexDataaccessProto.DataexDataaccessManage.AddDataexDataaccess:input_type -> DataexDataaccessProto.ModelArg
3, // 2: DataexDataaccessProto.DataexDataaccessManage.DeleteDataexDataaccess:input_type -> DataexDataaccessProto.DeleteIdsArg
0, // 3: DataexDataaccessProto.DataexDataaccessManage.UpdateDataexDataaccess:input_type -> DataexDataaccessProto.ModelArg
1, // 4: DataexDataaccessProto.DataexDataaccessManage.PageDataexDataaccess:input_type -> DataexDataaccessProto.QueryArg
2, // 5: DataexDataaccessProto.DataexDataaccessManage.GetDataexDataaccess:output_type -> DataexDataaccessProto.Reply
2, // 6: DataexDataaccessProto.DataexDataaccessManage.AddDataexDataaccess:output_type -> DataexDataaccessProto.Reply
2, // 7: DataexDataaccessProto.DataexDataaccessManage.DeleteDataexDataaccess:output_type -> DataexDataaccessProto.Reply
2, // 8: DataexDataaccessProto.DataexDataaccessManage.UpdateDataexDataaccess:output_type -> DataexDataaccessProto.Reply
2, // 9: DataexDataaccessProto.DataexDataaccessManage.PageDataexDataaccess:output_type -> DataexDataaccessProto.Reply
5, // [5:10] is the sub-list for method output_type
0, // [0:5] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name
}
func init() { file_DataexDataaccess_proto_init() }
func file_DataexDataaccess_proto_init() {
if File_DataexDataaccess_proto != nil {
return
}
if !protoimpl.UnsafeEnabled {
file_DataexDataaccess_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ModelArg); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_DataexDataaccess_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*QueryArg); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_DataexDataaccess_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Reply); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_DataexDataaccess_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*DeleteIdsArg); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_DataexDataaccess_proto_rawDesc,
NumEnums: 0,
NumMessages: 4,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_DataexDataaccess_proto_goTypes,
DependencyIndexes: file_DataexDataaccess_proto_depIdxs,
MessageInfos: file_DataexDataaccess_proto_msgTypes,
}.Build()
File_DataexDataaccess_proto = out.File
file_DataexDataaccess_proto_rawDesc = nil
file_DataexDataaccess_proto_goTypes = nil
file_DataexDataaccess_proto_depIdxs = nil
}
// 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
// DataexDataaccessManageClient is the client API for DataexDataaccessManage service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type DataexDataaccessManageClient interface {
//获取单条
GetDataexDataaccess(ctx context.Context, in *ModelArg, opts ...grpc.CallOption) (*Reply, error)
//增加
AddDataexDataaccess(ctx context.Context, in *ModelArg, opts ...grpc.CallOption) (*Reply, error)
//批量删除
DeleteDataexDataaccess(ctx context.Context, in *DeleteIdsArg, opts ...grpc.CallOption) (*Reply, error)
//修改
UpdateDataexDataaccess(ctx context.Context, in *ModelArg, opts ...grpc.CallOption) (*Reply, error)
//查询(分页)
PageDataexDataaccess(ctx context.Context, in *QueryArg, opts ...grpc.CallOption) (*Reply, error)
}
type dataexDataaccessManageClient struct {
cc grpc.ClientConnInterface
}
func NewDataexDataaccessManageClient(cc grpc.ClientConnInterface) DataexDataaccessManageClient {
return &dataexDataaccessManageClient{cc}
}
func (c *dataexDataaccessManageClient) GetDataexDataaccess(ctx context.Context, in *ModelArg, opts ...grpc.CallOption) (*Reply, error) {
out := new(Reply)
err := c.cc.Invoke(ctx, "/DataexDataaccessProto.DataexDataaccessManage/GetDataexDataaccess", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *dataexDataaccessManageClient) AddDataexDataaccess(ctx context.Context, in *ModelArg, opts ...grpc.CallOption) (*Reply, error) {
out := new(Reply)
err := c.cc.Invoke(ctx, "/DataexDataaccessProto.DataexDataaccessManage/AddDataexDataaccess", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *dataexDataaccessManageClient) DeleteDataexDataaccess(ctx context.Context, in *DeleteIdsArg, opts ...grpc.CallOption) (*Reply, error) {
out := new(Reply)
err := c.cc.Invoke(ctx, "/DataexDataaccessProto.DataexDataaccessManage/DeleteDataexDataaccess", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *dataexDataaccessManageClient) UpdateDataexDataaccess(ctx context.Context, in *ModelArg, opts ...grpc.CallOption) (*Reply, error) {
out := new(Reply)
err := c.cc.Invoke(ctx, "/DataexDataaccessProto.DataexDataaccessManage/UpdateDataexDataaccess", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *dataexDataaccessManageClient) PageDataexDataaccess(ctx context.Context, in *QueryArg, opts ...grpc.CallOption) (*Reply, error) {
out := new(Reply)
err := c.cc.Invoke(ctx, "/DataexDataaccessProto.DataexDataaccessManage/PageDataexDataaccess", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// DataexDataaccessManageServer is the server API for DataexDataaccessManage service.
type DataexDataaccessManageServer interface {
//获取单条
GetDataexDataaccess(context.Context, *ModelArg) (*Reply, error)
//增加
AddDataexDataaccess(context.Context, *ModelArg) (*Reply, error)
//批量删除
DeleteDataexDataaccess(context.Context, *DeleteIdsArg) (*Reply, error)
//修改
UpdateDataexDataaccess(context.Context, *ModelArg) (*Reply, error)
//查询(分页)
PageDataexDataaccess(context.Context, *QueryArg) (*Reply, error)
}
// UnimplementedDataexDataaccessManageServer can be embedded to have forward compatible implementations.
type UnimplementedDataexDataaccessManageServer struct {
}
func (*UnimplementedDataexDataaccessManageServer) GetDataexDataaccess(context.Context, *ModelArg) (*Reply, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetDataexDataaccess not implemented")
}
func (*UnimplementedDataexDataaccessManageServer) AddDataexDataaccess(context.Context, *ModelArg) (*Reply, error) {
return nil, status.Errorf(codes.Unimplemented, "method AddDataexDataaccess not implemented")
}
func (*UnimplementedDataexDataaccessManageServer) DeleteDataexDataaccess(context.Context, *DeleteIdsArg) (*Reply, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteDataexDataaccess not implemented")
}
func (*UnimplementedDataexDataaccessManageServer) UpdateDataexDataaccess(context.Context, *ModelArg) (*Reply, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateDataexDataaccess not implemented")
}
func (*UnimplementedDataexDataaccessManageServer) PageDataexDataaccess(context.Context, *QueryArg) (*Reply, error) {
return nil, status.Errorf(codes.Unimplemented, "method PageDataexDataaccess not implemented")
}
func RegisterDataexDataaccessManageServer(s *grpc.Server, srv DataexDataaccessManageServer) {
s.RegisterService(&_DataexDataaccessManage_serviceDesc, srv)
}
func _DataexDataaccessManage_GetDataexDataaccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ModelArg)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DataexDataaccessManageServer).GetDataexDataaccess(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/DataexDataaccessProto.DataexDataaccessManage/GetDataexDataaccess",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DataexDataaccessManageServer).GetDataexDataaccess(ctx, req.(*ModelArg))
}
return interceptor(ctx, in, info, handler)
}
func _DataexDataaccessManage_AddDataexDataaccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ModelArg)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DataexDataaccessManageServer).AddDataexDataaccess(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/DataexDataaccessProto.DataexDataaccessManage/AddDataexDataaccess",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DataexDataaccessManageServer).AddDataexDataaccess(ctx, req.(*ModelArg))
}
return interceptor(ctx, in, info, handler)
}
func _DataexDataaccessManage_DeleteDataexDataaccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteIdsArg)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DataexDataaccessManageServer).DeleteDataexDataaccess(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/DataexDataaccessProto.DataexDataaccessManage/DeleteDataexDataaccess",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DataexDataaccessManageServer).DeleteDataexDataaccess(ctx, req.(*DeleteIdsArg))
}
return interceptor(ctx, in, info, handler)
}
func _DataexDataaccessManage_UpdateDataexDataaccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ModelArg)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DataexDataaccessManageServer).UpdateDataexDataaccess(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/DataexDataaccessProto.DataexDataaccessManage/UpdateDataexDataaccess",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DataexDataaccessManageServer).UpdateDataexDataaccess(ctx, req.(*ModelArg))
}
return interceptor(ctx, in, info, handler)
}
func _DataexDataaccessManage_PageDataexDataaccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryArg)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DataexDataaccessManageServer).PageDataexDataaccess(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/DataexDataaccessProto.DataexDataaccessManage/PageDataexDataaccess",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DataexDataaccessManageServer).PageDataexDataaccess(ctx, req.(*QueryArg))
}
return interceptor(ctx, in, info, handler)
}
var _DataexDataaccessManage_serviceDesc = grpc.ServiceDesc{
ServiceName: "DataexDataaccessProto.DataexDataaccessManage",
HandlerType: (*DataexDataaccessManageServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetDataexDataaccess",
Handler: _DataexDataaccessManage_GetDataexDataaccess_Handler,
},
{
MethodName: "AddDataexDataaccess",
Handler: _DataexDataaccessManage_AddDataexDataaccess_Handler,
},
{
MethodName: "DeleteDataexDataaccess",
Handler: _DataexDataaccessManage_DeleteDataexDataaccess_Handler,
},
{
MethodName: "UpdateDataexDataaccess",
Handler: _DataexDataaccessManage_UpdateDataexDataaccess_Handler,
},
{
MethodName: "PageDataexDataaccess",
Handler: _DataexDataaccessManage_PageDataexDataaccess_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "DataexDataaccess.proto",
}
Reference in new issue View Git Blame Copy Permalink