datamesh

package
v0.0.0-...-a1208dc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 30, 2024 License: Apache-2.0 Imports: 9 Imported by: 9

Documentation

Index

Constants

View Source 
const (
	DomainDataService_CreateDomainData_FullMethodName = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataService/CreateDomainData"
	DomainDataService_QueryDomainData_FullMethodName  = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataService/QueryDomainData"
	DomainDataService_UpdateDomainData_FullMethodName = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataService/UpdateDomainData"
	DomainDataService_DeleteDomainData_FullMethodName = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataService/DeleteDomainData"
)
View Source 
const (
	DomainDataGrantService_CreateDomainDataGrant_FullMethodName = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataGrantService/CreateDomainDataGrant"
	DomainDataGrantService_QueryDomainDataGrant_FullMethodName  = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataGrantService/QueryDomainDataGrant"
	DomainDataGrantService_UpdateDomainDataGrant_FullMethodName = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataGrantService/UpdateDomainDataGrant"
	DomainDataGrantService_DeleteDomainDataGrant_FullMethodName = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataGrantService/DeleteDomainDataGrant"
)
View Source 
const (
	DomainDataSourceService_QueryDomainDataSource_FullMethodName = "/kuscia.proto.api.v1alpha1.datamesh.DomainDataSourceService/QueryDomainDataSource"
)

Variables

View Source 
var (
	ContentType_name = map[int32]string{
		0: "Table",
		1: "RAW",
		2: "CSV",
	}
	ContentType_value = map[string]int32{
		"Table": 0,
		"RAW":   1,
		"CSV":   2,
	}
)

Enum value maps for ContentType.

View Source 
var DomainDataGrantService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kuscia.proto.api.v1alpha1.datamesh.DomainDataGrantService",
	HandlerType: (*DomainDataGrantServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateDomainDataGrant",
			Handler:    _DomainDataGrantService_CreateDomainDataGrant_Handler,
		},
		{
			MethodName: "QueryDomainDataGrant",
			Handler:    _DomainDataGrantService_QueryDomainDataGrant_Handler,
		},
		{
			MethodName: "UpdateDomainDataGrant",
			Handler:    _DomainDataGrantService_UpdateDomainDataGrant_Handler,
		},
		{
			MethodName: "DeleteDomainDataGrant",
			Handler:    _DomainDataGrantService_DeleteDomainDataGrant_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kuscia/proto/api/v1alpha1/datamesh/domaindatagrant.proto",
}

DomainDataGrantService_ServiceDesc is the grpc.ServiceDesc for DomainDataGrantService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DomainDataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kuscia.proto.api.v1alpha1.datamesh.DomainDataService",
	HandlerType: (*DomainDataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateDomainData",
			Handler:    _DomainDataService_CreateDomainData_Handler,
		},
		{
			MethodName: "QueryDomainData",
			Handler:    _DomainDataService_QueryDomainData_Handler,
		},
		{
			MethodName: "UpdateDomainData",
			Handler:    _DomainDataService_UpdateDomainData_Handler,
		},
		{
			MethodName: "DeleteDomainData",
			Handler:    _DomainDataService_DeleteDomainData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kuscia/proto/api/v1alpha1/datamesh/domaindata.proto",
}

DomainDataService_ServiceDesc is the grpc.ServiceDesc for DomainDataService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DomainDataSourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kuscia.proto.api.v1alpha1.datamesh.DomainDataSourceService",
	HandlerType: (*DomainDataSourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryDomainDataSource",
			Handler:    _DomainDataSourceService_QueryDomainDataSource_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kuscia/proto/api/v1alpha1/datamesh/domaindatasource.proto",
}

DomainDataSourceService_ServiceDesc is the grpc.ServiceDesc for DomainDataSourceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_kuscia_proto_api_v1alpha1_datamesh_domaindata_proto protoreflect.FileDescriptor
View Source 
var File_kuscia_proto_api_v1alpha1_datamesh_domaindatagrant_proto protoreflect.FileDescriptor
View Source 
var File_kuscia_proto_api_v1alpha1_datamesh_domaindatasource_proto protoreflect.FileDescriptor
View Source 
var File_kuscia_proto_api_v1alpha1_datamesh_flightdm_proto protoreflect.FileDescriptor
View Source 
var File_kuscia_proto_api_v1alpha1_datamesh_flightinner_proto protoreflect.FileDescriptor

Functions

func RegisterDomainDataGrantServiceServer 

func RegisterDomainDataGrantServiceServer(s grpc.ServiceRegistrar, srv DomainDataGrantServiceServer)

func RegisterDomainDataServiceServer 

func RegisterDomainDataServiceServer(s grpc.ServiceRegistrar, srv DomainDataServiceServer)

func RegisterDomainDataSourceServiceServer 

func RegisterDomainDataSourceServiceServer(s grpc.ServiceRegistrar, srv DomainDataSourceServiceServer)

Types

type CSVWriteOptions 

type CSVWriteOptions struct {

	// field delimiter of csv file, default is comma
	FieldDelimiter string `protobuf:"bytes,1,opt,name=field_delimiter,json=fieldDelimiter,proto3" json:"field_delimiter,omitempty"`
	// contains filtered or unexported fields
}

write options of csv file

func (*CSVWriteOptions) Descriptor deprecated 

func (*CSVWriteOptions) Descriptor() ([]byte, []int)

Deprecated: Use CSVWriteOptions.ProtoReflect.Descriptor instead.

func (*CSVWriteOptions) GetFieldDelimiter 

func (x *CSVWriteOptions) GetFieldDelimiter() string

func (*CSVWriteOptions) ProtoMessage 

func (*CSVWriteOptions) ProtoMessage()

func (*CSVWriteOptions) ProtoReflect 

func (x *CSVWriteOptions) ProtoReflect() protoreflect.Message

func (*CSVWriteOptions) Reset 

func (x *CSVWriteOptions) Reset()

func (*CSVWriteOptions) String 

func (x *CSVWriteOptions) String() string

type CommandDataMeshQuery 

type CommandDataMeshQuery struct {
	Query      *CommandDomainDataQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Domaindata *DomainData             `protobuf:"bytes,2,opt,name=domaindata,proto3" json:"domaindata,omitempty"`
	Datasource *DomainDataSource       `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDataMeshQuery) Descriptor deprecated 

func (*CommandDataMeshQuery) Descriptor() ([]byte, []int)

Deprecated: Use CommandDataMeshQuery.ProtoReflect.Descriptor instead.

func (*CommandDataMeshQuery) GetDatasource 

func (x *CommandDataMeshQuery) GetDatasource() *DomainDataSource

func (*CommandDataMeshQuery) GetDomaindata 

func (x *CommandDataMeshQuery) GetDomaindata() *DomainData

func (*CommandDataMeshQuery) GetQuery 

func (x *CommandDataMeshQuery) GetQuery() *CommandDomainDataQuery

func (*CommandDataMeshQuery) ProtoMessage 

func (*CommandDataMeshQuery) ProtoMessage()

func (*CommandDataMeshQuery) ProtoReflect 

func (x *CommandDataMeshQuery) ProtoReflect() protoreflect.Message

func (*CommandDataMeshQuery) Reset 

func (x *CommandDataMeshQuery) Reset()

func (*CommandDataMeshQuery) String 

func (x *CommandDataMeshQuery) String() string

type CommandDataMeshSqlQuery 

type CommandDataMeshSqlQuery struct {
	Query      *CommandDataSourceSqlQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Datasource *DomainDataSource          `protobuf:"bytes,2,opt,name=datasource,proto3" json:"datasource,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDataMeshSqlQuery) Descriptor deprecated 

func (*CommandDataMeshSqlQuery) Descriptor() ([]byte, []int)

Deprecated: Use CommandDataMeshSqlQuery.ProtoReflect.Descriptor instead.

func (*CommandDataMeshSqlQuery) GetDatasource 

func (x *CommandDataMeshSqlQuery) GetDatasource() *DomainDataSource

func (*CommandDataMeshSqlQuery) GetQuery 

func (x *CommandDataMeshSqlQuery) GetQuery() *CommandDataSourceSqlQuery

func (*CommandDataMeshSqlQuery) ProtoMessage 

func (*CommandDataMeshSqlQuery) ProtoMessage()

func (*CommandDataMeshSqlQuery) ProtoReflect 

func (x *CommandDataMeshSqlQuery) ProtoReflect() protoreflect.Message

func (*CommandDataMeshSqlQuery) Reset 

func (x *CommandDataMeshSqlQuery) Reset()

func (*CommandDataMeshSqlQuery) String 

func (x *CommandDataMeshSqlQuery) String() string

type CommandDataMeshUpdate 

type CommandDataMeshUpdate struct {
	Update     *CommandDomainDataUpdate `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
	Domaindata *DomainData              `protobuf:"bytes,2,opt,name=domaindata,proto3" json:"domaindata,omitempty"`
	Datasource *DomainDataSource        `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDataMeshUpdate) Descriptor deprecated 

func (*CommandDataMeshUpdate) Descriptor() ([]byte, []int)

Deprecated: Use CommandDataMeshUpdate.ProtoReflect.Descriptor instead.

func (*CommandDataMeshUpdate) GetDatasource 

func (x *CommandDataMeshUpdate) GetDatasource() *DomainDataSource

func (*CommandDataMeshUpdate) GetDomaindata 

func (x *CommandDataMeshUpdate) GetDomaindata() *DomainData

func (*CommandDataMeshUpdate) GetUpdate 

func (x *CommandDataMeshUpdate) GetUpdate() *CommandDomainDataUpdate

func (*CommandDataMeshUpdate) ProtoMessage 

func (*CommandDataMeshUpdate) ProtoMessage()

func (*CommandDataMeshUpdate) ProtoReflect 

func (x *CommandDataMeshUpdate) ProtoReflect() protoreflect.Message

func (*CommandDataMeshUpdate) Reset 

func (x *CommandDataMeshUpdate) Reset()

func (*CommandDataMeshUpdate) String 

func (x *CommandDataMeshUpdate) String() string

type CommandDataSourceSqlQuery 

type CommandDataSourceSqlQuery struct {
	DatasourceId string `protobuf:"bytes,1,opt,name=datasource_id,json=datasourceId,proto3" json:"datasource_id,omitempty"`
	// only support select sql
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDataSourceSqlQuery) Descriptor deprecated 

func (*CommandDataSourceSqlQuery) Descriptor() ([]byte, []int)

Deprecated: Use CommandDataSourceSqlQuery.ProtoReflect.Descriptor instead.

func (*CommandDataSourceSqlQuery) GetDatasourceId 

func (x *CommandDataSourceSqlQuery) GetDatasourceId() string

func (*CommandDataSourceSqlQuery) GetSql 

func (x *CommandDataSourceSqlQuery) GetSql() string

func (*CommandDataSourceSqlQuery) ProtoMessage 

func (*CommandDataSourceSqlQuery) ProtoMessage()

func (*CommandDataSourceSqlQuery) ProtoReflect 

func (x *CommandDataSourceSqlQuery) ProtoReflect() protoreflect.Message

func (*CommandDataSourceSqlQuery) Reset 

func (x *CommandDataSourceSqlQuery) Reset()

func (*CommandDataSourceSqlQuery) String 

func (x *CommandDataSourceSqlQuery) String() string

type CommandDomainDataQuery 

type CommandDomainDataQuery struct {
	DomaindataId string `protobuf:"bytes,1,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// column name of DomainData's columns
	Columns []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// transfer content-type(expected content type of flight data from data proxy response)
	// for domaindata with type != table, the content_type can only be RAW, other types will not take effect
	ContentType ContentType `` /* 147-byte string literal not displayed */
	// if content_type is CSV, you can set file_write_options
	FileWriteOptions *FileWriteOptions `protobuf:"bytes,4,opt,name=file_write_options,json=fileWriteOptions,proto3" json:"file_write_options,omitempty"`
	// specific the partition column and value, such as "dmdt=20240520"
	PartitionSpec string `protobuf:"bytes,5,opt,name=partition_spec,json=partitionSpec,proto3" json:"partition_spec,omitempty"`
	// contains filtered or unexported fields
}

call GetFlightInfo with CommandDomainDataQuery, return TicketDomainDataQuery and then call DoGet with TicketDomainDataQuery

func (*CommandDomainDataQuery) Descriptor deprecated 

func (*CommandDomainDataQuery) Descriptor() ([]byte, []int)

Deprecated: Use CommandDomainDataQuery.ProtoReflect.Descriptor instead.

func (*CommandDomainDataQuery) GetColumns 

func (x *CommandDomainDataQuery) GetColumns() []string

func (*CommandDomainDataQuery) GetContentType 

func (x *CommandDomainDataQuery) GetContentType() ContentType

func (*CommandDomainDataQuery) GetDomaindataId 

func (x *CommandDomainDataQuery) GetDomaindataId() string

func (*CommandDomainDataQuery) GetFileWriteOptions 

func (x *CommandDomainDataQuery) GetFileWriteOptions() *FileWriteOptions

func (*CommandDomainDataQuery) GetPartitionSpec 

func (x *CommandDomainDataQuery) GetPartitionSpec() string

func (*CommandDomainDataQuery) ProtoMessage 

func (*CommandDomainDataQuery) ProtoMessage()

func (*CommandDomainDataQuery) ProtoReflect 

func (x *CommandDomainDataQuery) ProtoReflect() protoreflect.Message

func (*CommandDomainDataQuery) Reset 

func (x *CommandDomainDataQuery) Reset()

func (*CommandDomainDataQuery) String 

func (x *CommandDomainDataQuery) String() string

type CommandDomainDataUpdate 

type CommandDomainDataUpdate struct {
	DomaindataId string `protobuf:"bytes,1,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// create an nonexistent domaindata and get a update ticket
	DomaindataRequest *CreateDomainDataRequest `protobuf:"bytes,2,opt,name=domaindata_request,json=domaindataRequest,proto3" json:"domaindata_request,omitempty"`
	// transfer content-type(content type of flight data from client request)
	// for domaindata with type != table, the content_type can only be RAW, other types will not take effect
	ContentType ContentType `` /* 147-byte string literal not displayed */
	// for domaindata stored with file format in datasource , you can specify file_write_options
	FileWriteOptions *FileWriteOptions `protobuf:"bytes,4,opt,name=file_write_options,json=fileWriteOptions,proto3" json:"file_write_options,omitempty"`
	// extra options varies by datasource type
	ExtraOptions map[string]string `` /* 185-byte string literal not displayed */
	// specific the partition column and value, such as "dmdt=20240520"
	PartitionSpec string `protobuf:"bytes,6,opt,name=partition_spec,json=partitionSpec,proto3" json:"partition_spec,omitempty"`
	// contains filtered or unexported fields
}

call GetFlightInfo with CommandDomainDataUpdate, return TicketDomainDataQuery which is an update query and then call DoPut with TicketDomainDataQuery

func (*CommandDomainDataUpdate) Descriptor deprecated 

func (*CommandDomainDataUpdate) Descriptor() ([]byte, []int)

Deprecated: Use CommandDomainDataUpdate.ProtoReflect.Descriptor instead.

func (*CommandDomainDataUpdate) GetContentType 

func (x *CommandDomainDataUpdate) GetContentType() ContentType

func (*CommandDomainDataUpdate) GetDomaindataId 

func (x *CommandDomainDataUpdate) GetDomaindataId() string

func (*CommandDomainDataUpdate) GetDomaindataRequest 

func (x *CommandDomainDataUpdate) GetDomaindataRequest() *CreateDomainDataRequest

func (*CommandDomainDataUpdate) GetExtraOptions 

func (x *CommandDomainDataUpdate) GetExtraOptions() map[string]string

func (*CommandDomainDataUpdate) GetFileWriteOptions 

func (x *CommandDomainDataUpdate) GetFileWriteOptions() *FileWriteOptions

func (*CommandDomainDataUpdate) GetPartitionSpec 

func (x *CommandDomainDataUpdate) GetPartitionSpec() string

func (*CommandDomainDataUpdate) ProtoMessage 

func (*CommandDomainDataUpdate) ProtoMessage()

func (*CommandDomainDataUpdate) ProtoReflect 

func (x *CommandDomainDataUpdate) ProtoReflect() protoreflect.Message

func (*CommandDomainDataUpdate) Reset 

func (x *CommandDomainDataUpdate) Reset()

func (*CommandDomainDataUpdate) String 

func (x *CommandDomainDataUpdate) String() string

type CommandGetDomainDataSchema 

type CommandGetDomainDataSchema struct {
	DomaindataId string `protobuf:"bytes,1,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// contains filtered or unexported fields
}

call with GetSchema, return SchemaResult, extension attributes are set with metadata

func (*CommandGetDomainDataSchema) Descriptor deprecated 

func (*CommandGetDomainDataSchema) Descriptor() ([]byte, []int)

Deprecated: Use CommandGetDomainDataSchema.ProtoReflect.Descriptor instead.

func (*CommandGetDomainDataSchema) GetDomaindataId 

func (x *CommandGetDomainDataSchema) GetDomaindataId() string

func (*CommandGetDomainDataSchema) ProtoMessage 

func (*CommandGetDomainDataSchema) ProtoMessage()

func (*CommandGetDomainDataSchema) ProtoReflect 

func (x *CommandGetDomainDataSchema) ProtoReflect() protoreflect.Message

func (*CommandGetDomainDataSchema) Reset 

func (x *CommandGetDomainDataSchema) Reset()

func (*CommandGetDomainDataSchema) String 

func (x *CommandGetDomainDataSchema) String() string

type ContentType 

type ContentType int32

ContentType define ArrowSchema for flight data in DoGet Response and DoPut Request for ContentType = Table, ArrowSchema is defined by DomainData's columns for rest types, ArrowSchema is a dummy schema with one column of Binary Type 

const (
	ContentType_Table ContentType = 0
	// read raw data from datasource
	ContentType_RAW ContentType = 1
	// the expected DoGet response content or the DoPut request content is  csv byte stream, currently not support
	ContentType_CSV ContentType = 2
)

func (ContentType) Descriptor 

func (ContentType) Descriptor() protoreflect.EnumDescriptor

func (ContentType) Enum 

func (x ContentType) Enum() *ContentType

func (ContentType) EnumDescriptor deprecated 

func (ContentType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContentType.Descriptor instead.

func (ContentType) Number 

func (x ContentType) Number() protoreflect.EnumNumber

func (ContentType) String 

func (x ContentType) String() string

func (ContentType) Type 

func (ContentType) Type() protoreflect.EnumType

type CreateDomainDataGrantRequest 

type CreateDomainDataGrantRequest struct {
	Header            *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DomaindatagrantId string                  `protobuf:"bytes,2,opt,name=domaindatagrant_id,json=domaindatagrantId,proto3" json:"domaindatagrant_id,omitempty"`
	DomaindataId      string                  `protobuf:"bytes,3,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	GrantDomain       string                  `protobuf:"bytes,4,opt,name=grant_domain,json=grantDomain,proto3" json:"grant_domain,omitempty"`
	Limit             *GrantLimit             `protobuf:"bytes,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Description       map[string]string       `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateDomainDataGrantRequest) Descriptor deprecated 

func (*CreateDomainDataGrantRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateDomainDataGrantRequest.ProtoReflect.Descriptor instead.

func (*CreateDomainDataGrantRequest) GetDescription 

func (x *CreateDomainDataGrantRequest) GetDescription() map[string]string

func (*CreateDomainDataGrantRequest) GetDomaindataId 

func (x *CreateDomainDataGrantRequest) GetDomaindataId() string

func (*CreateDomainDataGrantRequest) GetDomaindatagrantId 

func (x *CreateDomainDataGrantRequest) GetDomaindatagrantId() string

func (*CreateDomainDataGrantRequest) GetGrantDomain 

func (x *CreateDomainDataGrantRequest) GetGrantDomain() string

func (*CreateDomainDataGrantRequest) GetHeader 

func (x *CreateDomainDataGrantRequest) GetHeader() *v1alpha1.RequestHeader

func (*CreateDomainDataGrantRequest) GetLimit 

func (x *CreateDomainDataGrantRequest) GetLimit() *GrantLimit

func (*CreateDomainDataGrantRequest) ProtoMessage 

func (*CreateDomainDataGrantRequest) ProtoMessage()

func (*CreateDomainDataGrantRequest) ProtoReflect 

func (x *CreateDomainDataGrantRequest) ProtoReflect() protoreflect.Message

func (*CreateDomainDataGrantRequest) Reset 

func (x *CreateDomainDataGrantRequest) Reset()

func (*CreateDomainDataGrantRequest) String 

func (x *CreateDomainDataGrantRequest) String() string

type CreateDomainDataGrantResponse 

type CreateDomainDataGrantResponse struct {
	Status *v1alpha1.Status                   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Data   *CreateDomainDataGrantResponseData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDomainDataGrantResponse) Descriptor deprecated 

func (*CreateDomainDataGrantResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateDomainDataGrantResponse.ProtoReflect.Descriptor instead.

func (*CreateDomainDataGrantResponse) GetData 

func (x *CreateDomainDataGrantResponse) GetData() *CreateDomainDataGrantResponseData

func (*CreateDomainDataGrantResponse) GetStatus 

func (x *CreateDomainDataGrantResponse) GetStatus() *v1alpha1.Status

func (*CreateDomainDataGrantResponse) ProtoMessage 

func (*CreateDomainDataGrantResponse) ProtoMessage()

func (*CreateDomainDataGrantResponse) ProtoReflect 

func (x *CreateDomainDataGrantResponse) ProtoReflect() protoreflect.Message

func (*CreateDomainDataGrantResponse) Reset 

func (x *CreateDomainDataGrantResponse) Reset()

func (*CreateDomainDataGrantResponse) String 

func (x *CreateDomainDataGrantResponse) String() string

type CreateDomainDataGrantResponseData 

type CreateDomainDataGrantResponseData struct {

	// id of created domaindatagrant
	DomaindatagrantId string `protobuf:"bytes,1,opt,name=domaindatagrant_id,json=domaindatagrantId,proto3" json:"domaindatagrant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDomainDataGrantResponseData) Descriptor deprecated 

func (*CreateDomainDataGrantResponseData) Descriptor() ([]byte, []int)

Deprecated: Use CreateDomainDataGrantResponseData.ProtoReflect.Descriptor instead.

func (*CreateDomainDataGrantResponseData) GetDomaindatagrantId 

func (x *CreateDomainDataGrantResponseData) GetDomaindatagrantId() string

func (*CreateDomainDataGrantResponseData) ProtoMessage 

func (*CreateDomainDataGrantResponseData) ProtoMessage()

func (*CreateDomainDataGrantResponseData) ProtoReflect 

func (x *CreateDomainDataGrantResponseData) ProtoReflect() protoreflect.Message

func (*CreateDomainDataGrantResponseData) Reset 

func (x *CreateDomainDataGrantResponseData) Reset()

func (*CreateDomainDataGrantResponseData) String 

func (x *CreateDomainDataGrantResponseData) String() string

type CreateDomainDataRequest 

type CreateDomainDataRequest struct {
	Header *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Optional, The domaindata_id would be generated by server if the domaindata_id is empty.
	// The unique identity of domaindata, it couldn't duplicate in the same domain.
	DomaindataId string `protobuf:"bytes,2,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// The human readable, it could duplicate in the domain.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Enum: table,model,rule,report,unknown
	Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// The relative_uri is relative to the datasource URI, The datasourceURI appends relative_uri is the domaindataURI.
	// e.g. the relative_uri is "train/table.csv"
	//
	//	the URI of datasource is "/home/data"
	//	the URI of domaindata is "/home/data/train/table.csv"
	RelativeUri string `protobuf:"bytes,5,opt,name=relative_uri,json=relativeUri,proto3" json:"relative_uri,omitempty"`
	// Optional, server would use default datasource if datasource_id is empty.
	// The datasource is where the domain is stored.
	DatasourceId string `protobuf:"bytes,6,opt,name=datasource_id,json=datasourceId,proto3" json:"datasource_id,omitempty"`
	// Optional, The attributes of the domaindata, this field use as a extra field, User could set
	// this field to any data what they need.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// Optional, Partition not support now
	Partition *v1alpha1.Partition `protobuf:"bytes,8,opt,name=partition,proto3" json:"partition,omitempty"`
	// This field must be set if the type is 'table',
	// the columns describe the table's schema information.
	Columns []*v1alpha1.DataColumn `protobuf:"bytes,9,rep,name=columns,proto3" json:"columns,omitempty"`
	// Optional , The vendor is the one who outputs the domain data, it may be the SecretFlow engine,
	// another vendor's engine, or manually registered. it's could be manual, secretflow or other vendor string.
	Vendor string `protobuf:"bytes,10,opt,name=vendor,proto3" json:"vendor,omitempty"`
	// file-format only takes effect when the data source type is  localfs or oss. default value is csv
	FileFormat v1alpha1.FileFormat `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateDomainDataRequest) Descriptor deprecated 

func (*CreateDomainDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateDomainDataRequest.ProtoReflect.Descriptor instead.

func (*CreateDomainDataRequest) GetAttributes 

func (x *CreateDomainDataRequest) GetAttributes() map[string]string

func (*CreateDomainDataRequest) GetColumns 

func (x *CreateDomainDataRequest) GetColumns() []*v1alpha1.DataColumn

func (*CreateDomainDataRequest) GetDatasourceId 

func (x *CreateDomainDataRequest) GetDatasourceId() string

func (*CreateDomainDataRequest) GetDomaindataId 

func (x *CreateDomainDataRequest) GetDomaindataId() string

func (*CreateDomainDataRequest) GetFileFormat 

func (x *CreateDomainDataRequest) GetFileFormat() v1alpha1.FileFormat

func (*CreateDomainDataRequest) GetHeader 

func (x *CreateDomainDataRequest) GetHeader() *v1alpha1.RequestHeader

func (*CreateDomainDataRequest) GetName 

func (x *CreateDomainDataRequest) GetName() string

func (*CreateDomainDataRequest) GetPartition 

func (x *CreateDomainDataRequest) GetPartition() *v1alpha1.Partition

func (*CreateDomainDataRequest) GetRelativeUri 

func (x *CreateDomainDataRequest) GetRelativeUri() string

func (*CreateDomainDataRequest) GetType 

func (x *CreateDomainDataRequest) GetType() string

func (*CreateDomainDataRequest) GetVendor 

func (x *CreateDomainDataRequest) GetVendor() string

func (*CreateDomainDataRequest) ProtoMessage 

func (*CreateDomainDataRequest) ProtoMessage()

func (*CreateDomainDataRequest) ProtoReflect 

func (x *CreateDomainDataRequest) ProtoReflect() protoreflect.Message

func (*CreateDomainDataRequest) Reset 

func (x *CreateDomainDataRequest) Reset()

func (*CreateDomainDataRequest) String 

func (x *CreateDomainDataRequest) String() string

type CreateDomainDataResponse 

type CreateDomainDataResponse struct {
	Status *v1alpha1.Status              `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Data   *CreateDomainDataResponseData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDomainDataResponse) Descriptor deprecated 

func (*CreateDomainDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateDomainDataResponse.ProtoReflect.Descriptor instead.

func (*CreateDomainDataResponse) GetData 

func (x *CreateDomainDataResponse) GetData() *CreateDomainDataResponseData

func (*CreateDomainDataResponse) GetStatus 

func (x *CreateDomainDataResponse) GetStatus() *v1alpha1.Status

func (*CreateDomainDataResponse) ProtoMessage 

func (*CreateDomainDataResponse) ProtoMessage()

func (*CreateDomainDataResponse) ProtoReflect 

func (x *CreateDomainDataResponse) ProtoReflect() protoreflect.Message

func (*CreateDomainDataResponse) Reset 

func (x *CreateDomainDataResponse) Reset()

func (*CreateDomainDataResponse) String 

func (x *CreateDomainDataResponse) String() string

type CreateDomainDataResponseData 

type CreateDomainDataResponseData struct {

	// ID of created domaindata
	DomaindataId string `protobuf:"bytes,1,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDomainDataResponseData) Descriptor deprecated 

func (*CreateDomainDataResponseData) Descriptor() ([]byte, []int)

Deprecated: Use CreateDomainDataResponseData.ProtoReflect.Descriptor instead.

func (*CreateDomainDataResponseData) GetDomaindataId 

func (x *CreateDomainDataResponseData) GetDomaindataId() string

func (*CreateDomainDataResponseData) ProtoMessage 

func (*CreateDomainDataResponseData) ProtoMessage()

func (*CreateDomainDataResponseData) ProtoReflect 

func (x *CreateDomainDataResponseData) ProtoReflect() protoreflect.Message

func (*CreateDomainDataResponseData) Reset 

func (x *CreateDomainDataResponseData) Reset()

func (*CreateDomainDataResponseData) String 

func (x *CreateDomainDataResponseData) String() string

type DataSourceInfo 

type DataSourceInfo struct {

	// there is only one of the localfs or the oss in the DataSourceInfo
	// LocalDataSourceInfo is exist only if the type of datasource is localfs
	// OssDataSourceInfo is exist only if the type of datasource is oss
	Localfs *LocalDataSourceInfo `protobuf:"bytes,1,opt,name=localfs,proto3" json:"localfs,omitempty"`
	Oss     *OssDataSourceInfo   `protobuf:"bytes,2,opt,name=oss,proto3" json:"oss,omitempty"`
	// Relational database info, such as Mysql/oracle/postgres
	Database *DatabaseDataSourceInfo `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	// aliyun odps(MaxCompute)
	Odps *OdpsDataSourceInfo `protobuf:"bytes,4,opt,name=odps,proto3" json:"odps,omitempty"`
	// contains filtered or unexported fields
}

func (*DataSourceInfo) Descriptor deprecated 

func (*DataSourceInfo) Descriptor() ([]byte, []int)

Deprecated: Use DataSourceInfo.ProtoReflect.Descriptor instead.

func (*DataSourceInfo) GetDatabase 

func (x *DataSourceInfo) GetDatabase() *DatabaseDataSourceInfo

func (*DataSourceInfo) GetLocalfs 

func (x *DataSourceInfo) GetLocalfs() *LocalDataSourceInfo

func (*DataSourceInfo) GetOdps 

func (x *DataSourceInfo) GetOdps() *OdpsDataSourceInfo

func (*DataSourceInfo) GetOss 

func (x *DataSourceInfo) GetOss() *OssDataSourceInfo

func (*DataSourceInfo) ProtoMessage 

func (*DataSourceInfo) ProtoMessage()

func (*DataSourceInfo) ProtoReflect 

func (x *DataSourceInfo) ProtoReflect() protoreflect.Message

func (*DataSourceInfo) Reset 

func (x *DataSourceInfo) Reset()

func (*DataSourceInfo) String 

func (x *DataSourceInfo) String() string

type DatabaseDataSourceInfo 

type DatabaseDataSourceInfo struct {

	// endpoint for database, such as localhost:3306
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// user name of account to access database
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// password of account to access database
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// database name
	Database string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

datasource info for mysql/oracle/postgres

func (*DatabaseDataSourceInfo) Descriptor deprecated 

func (*DatabaseDataSourceInfo) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseDataSourceInfo.ProtoReflect.Descriptor instead.

func (*DatabaseDataSourceInfo) GetDatabase 

func (x *DatabaseDataSourceInfo) GetDatabase() string

func (*DatabaseDataSourceInfo) GetEndpoint 

func (x *DatabaseDataSourceInfo) GetEndpoint() string

func (*DatabaseDataSourceInfo) GetPassword 

func (x *DatabaseDataSourceInfo) GetPassword() string

func (*DatabaseDataSourceInfo) GetUser 

func (x *DatabaseDataSourceInfo) GetUser() string

func (*DatabaseDataSourceInfo) ProtoMessage 

func (*DatabaseDataSourceInfo) ProtoMessage()

func (*DatabaseDataSourceInfo) ProtoReflect 

func (x *DatabaseDataSourceInfo) ProtoReflect() protoreflect.Message

func (*DatabaseDataSourceInfo) Reset 

func (x *DatabaseDataSourceInfo) Reset()

func (*DatabaseDataSourceInfo) String 

func (x *DatabaseDataSourceInfo) String() string

type DeleteDomainDataGrantRequest 

type DeleteDomainDataGrantRequest struct {
	Header            *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DomaindatagrantId string                  `protobuf:"bytes,2,opt,name=domaindatagrant_id,json=domaindatagrantId,proto3" json:"domaindatagrant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDomainDataGrantRequest) Descriptor deprecated 

func (*DeleteDomainDataGrantRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDomainDataGrantRequest.ProtoReflect.Descriptor instead.

func (*DeleteDomainDataGrantRequest) GetDomaindatagrantId 

func (x *DeleteDomainDataGrantRequest) GetDomaindatagrantId() string

func (*DeleteDomainDataGrantRequest) GetHeader 

func (x *DeleteDomainDataGrantRequest) GetHeader() *v1alpha1.RequestHeader

func (*DeleteDomainDataGrantRequest) ProtoMessage 

func (*DeleteDomainDataGrantRequest) ProtoMessage()

func (*DeleteDomainDataGrantRequest) ProtoReflect 

func (x *DeleteDomainDataGrantRequest) ProtoReflect() protoreflect.Message

func (*DeleteDomainDataGrantRequest) Reset 

func (x *DeleteDomainDataGrantRequest) Reset()

func (*DeleteDomainDataGrantRequest) String 

func (x *DeleteDomainDataGrantRequest) String() string

type DeleteDomainDataGrantResponse 

type DeleteDomainDataGrantResponse struct {
	Status *v1alpha1.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDomainDataGrantResponse) Descriptor deprecated 

func (*DeleteDomainDataGrantResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDomainDataGrantResponse.ProtoReflect.Descriptor instead.

func (*DeleteDomainDataGrantResponse) GetStatus 

func (x *DeleteDomainDataGrantResponse) GetStatus() *v1alpha1.Status

func (*DeleteDomainDataGrantResponse) ProtoMessage 

func (*DeleteDomainDataGrantResponse) ProtoMessage()

func (*DeleteDomainDataGrantResponse) ProtoReflect 

func (x *DeleteDomainDataGrantResponse) ProtoReflect() protoreflect.Message

func (*DeleteDomainDataGrantResponse) Reset 

func (x *DeleteDomainDataGrantResponse) Reset()

func (*DeleteDomainDataGrantResponse) String 

func (x *DeleteDomainDataGrantResponse) String() string

type DeleteDomainDataRequest 

type DeleteDomainDataRequest struct {
	Header *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// domaindata id
	DomaindataId string `protobuf:"bytes,2,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDomainDataRequest) Descriptor deprecated 

func (*DeleteDomainDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDomainDataRequest.ProtoReflect.Descriptor instead.

func (*DeleteDomainDataRequest) GetDomaindataId 

func (x *DeleteDomainDataRequest) GetDomaindataId() string

func (*DeleteDomainDataRequest) GetHeader 

func (x *DeleteDomainDataRequest) GetHeader() *v1alpha1.RequestHeader

func (*DeleteDomainDataRequest) ProtoMessage 

func (*DeleteDomainDataRequest) ProtoMessage()

func (*DeleteDomainDataRequest) ProtoReflect 

func (x *DeleteDomainDataRequest) ProtoReflect() protoreflect.Message

func (*DeleteDomainDataRequest) Reset 

func (x *DeleteDomainDataRequest) Reset()

func (*DeleteDomainDataRequest) String 

func (x *DeleteDomainDataRequest) String() string

type DeleteDomainDataResponse 

type DeleteDomainDataResponse struct {
	Status *v1alpha1.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDomainDataResponse) Descriptor deprecated 

func (*DeleteDomainDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDomainDataResponse.ProtoReflect.Descriptor instead.

func (*DeleteDomainDataResponse) GetStatus 

func (x *DeleteDomainDataResponse) GetStatus() *v1alpha1.Status

func (*DeleteDomainDataResponse) ProtoMessage 

func (*DeleteDomainDataResponse) ProtoMessage()

func (*DeleteDomainDataResponse) ProtoReflect 

func (x *DeleteDomainDataResponse) ProtoReflect() protoreflect.Message

func (*DeleteDomainDataResponse) Reset 

func (x *DeleteDomainDataResponse) Reset()

func (*DeleteDomainDataResponse) String 

func (x *DeleteDomainDataResponse) String() string

type DomainData 

type DomainData struct {

	// domaindata_id is the identification of domaindata, it couldn't duplicate in the domain.
	DomaindataId string `protobuf:"bytes,1,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// The human readable, it could duplicate in the domain.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// domaindata type , Enum: table,model,rule,report,unknown
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// The relative_uri is relative to the datasource URI, The datasourceURI appends relative_uri is the domaindataURI.
	// e.g. the relative_uri is "train/table.csv"
	//
	//	the URI of datasource is "/home/data"
	//	the URI of domaindata is "/home/data/train/table.csv"
	RelativeUri string `protobuf:"bytes,4,opt,name=relative_uri,json=relativeUri,proto3" json:"relative_uri,omitempty"`
	// datasource_id is the identity of the domaindatasource, the domaindatasource that storage the domaindata file.
	DatasourceId string `protobuf:"bytes,5,opt,name=datasource_id,json=datasourceId,proto3" json:"datasource_id,omitempty"`
	// attributes : the attributes of the domaindata, this field use as a extra field, User could set
	// this field to any data what they need.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// Partition not support now,
	Partition *v1alpha1.Partition `protobuf:"bytes,7,opt,name=partition,proto3" json:"partition,omitempty"`
	// This field must be set if the type is 'table',
	// The columns describe the table's schema information.
	Columns []*v1alpha1.DataColumn `protobuf:"bytes,8,rep,name=columns,proto3" json:"columns,omitempty"`
	// The vendor is the one who outputs the domain data, it may be the SecretFlow engine,
	// another vendor's engine, or manually registered. it's could be manual, secretflow or other vendor string.
	Vendor string `protobuf:"bytes,9,opt,name=vendor,proto3" json:"vendor,omitempty"`
	// if the data is stored with file format, file_format describe file format
	FileFormat v1alpha1.FileFormat `` /* 135-byte string literal not displayed */
	Author     string              `protobuf:"bytes,11,opt,name=author,proto3" json:"author,omitempty"`
	// contains filtered or unexported fields
}

func (*DomainData) Descriptor deprecated 

func (*DomainData) Descriptor() ([]byte, []int)

Deprecated: Use DomainData.ProtoReflect.Descriptor instead.

func (*DomainData) GetAttributes 

func (x *DomainData) GetAttributes() map[string]string

func (*DomainData) GetAuthor 

func (x *DomainData) GetAuthor() string

func (*DomainData) GetColumns 

func (x *DomainData) GetColumns() []*v1alpha1.DataColumn

func (*DomainData) GetDatasourceId 

func (x *DomainData) GetDatasourceId() string

func (*DomainData) GetDomaindataId 

func (x *DomainData) GetDomaindataId() string

func (*DomainData) GetFileFormat 

func (x *DomainData) GetFileFormat() v1alpha1.FileFormat

func (*DomainData) GetName 

func (x *DomainData) GetName() string

func (*DomainData) GetPartition 

func (x *DomainData) GetPartition() *v1alpha1.Partition

func (*DomainData) GetRelativeUri 

func (x *DomainData) GetRelativeUri() string

func (*DomainData) GetType 

func (x *DomainData) GetType() string

func (*DomainData) GetVendor 

func (x *DomainData) GetVendor() string

func (*DomainData) ProtoMessage 

func (*DomainData) ProtoMessage()

func (*DomainData) ProtoReflect 

func (x *DomainData) ProtoReflect() protoreflect.Message

func (*DomainData) Reset 

func (x *DomainData) Reset()

func (*DomainData) String 

func (x *DomainData) String() string

type DomainDataGrantData 

type DomainDataGrantData struct {
	DomaindatagrantId string            `protobuf:"bytes,1,opt,name=domaindatagrant_id,json=domaindatagrantId,proto3" json:"domaindatagrant_id,omitempty"`
	Author            string            `protobuf:"bytes,2,opt,name=author,proto3" json:"author,omitempty"`
	DomaindataId      string            `protobuf:"bytes,3,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	GrantDomain       string            `protobuf:"bytes,4,opt,name=grant_domain,json=grantDomain,proto3" json:"grant_domain,omitempty"`
	Limit             *GrantLimit       `protobuf:"bytes,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Description       map[string]string `` /* 163-byte string literal not displayed */
	Signature         string            `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*DomainDataGrantData) Descriptor deprecated 

func (*DomainDataGrantData) Descriptor() ([]byte, []int)

Deprecated: Use DomainDataGrantData.ProtoReflect.Descriptor instead.

func (*DomainDataGrantData) GetAuthor 

func (x *DomainDataGrantData) GetAuthor() string

func (*DomainDataGrantData) GetDescription 

func (x *DomainDataGrantData) GetDescription() map[string]string

func (*DomainDataGrantData) GetDomaindataId 

func (x *DomainDataGrantData) GetDomaindataId() string

func (*DomainDataGrantData) GetDomaindatagrantId 

func (x *DomainDataGrantData) GetDomaindatagrantId() string

func (*DomainDataGrantData) GetGrantDomain 

func (x *DomainDataGrantData) GetGrantDomain() string

func (*DomainDataGrantData) GetLimit 

func (x *DomainDataGrantData) GetLimit() *GrantLimit

func (*DomainDataGrantData) GetSignature 

func (x *DomainDataGrantData) GetSignature() string

func (*DomainDataGrantData) ProtoMessage 

func (*DomainDataGrantData) ProtoMessage()

func (*DomainDataGrantData) ProtoReflect 

func (x *DomainDataGrantData) ProtoReflect() protoreflect.Message

func (*DomainDataGrantData) Reset 

func (x *DomainDataGrantData) Reset()

func (*DomainDataGrantData) String 

func (x *DomainDataGrantData) String() string

type DomainDataGrantServiceClient 

type DomainDataGrantServiceClient interface {
	CreateDomainDataGrant(ctx context.Context, in *CreateDomainDataGrantRequest, opts ...grpc.CallOption) (*CreateDomainDataGrantResponse, error)
	QueryDomainDataGrant(ctx context.Context, in *QueryDomainDataGrantRequest, opts ...grpc.CallOption) (*QueryDomainDataGrantResponse, error)
	UpdateDomainDataGrant(ctx context.Context, in *UpdateDomainDataGrantRequest, opts ...grpc.CallOption) (*UpdateDomainDataGrantResponse, error)
	DeleteDomainDataGrant(ctx context.Context, in *DeleteDomainDataGrantRequest, opts ...grpc.CallOption) (*DeleteDomainDataGrantResponse, error)
}

DomainDataGrantServiceClient is the client API for DomainDataGrantService 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.

func NewDomainDataGrantServiceClient 

func NewDomainDataGrantServiceClient(cc grpc.ClientConnInterface) DomainDataGrantServiceClient

type DomainDataGrantServiceServer 

type DomainDataGrantServiceServer interface {
	CreateDomainDataGrant(context.Context, *CreateDomainDataGrantRequest) (*CreateDomainDataGrantResponse, error)
	QueryDomainDataGrant(context.Context, *QueryDomainDataGrantRequest) (*QueryDomainDataGrantResponse, error)
	UpdateDomainDataGrant(context.Context, *UpdateDomainDataGrantRequest) (*UpdateDomainDataGrantResponse, error)
	DeleteDomainDataGrant(context.Context, *DeleteDomainDataGrantRequest) (*DeleteDomainDataGrantResponse, error)
	// contains filtered or unexported methods
}

DomainDataGrantServiceServer is the server API for DomainDataGrantService service. All implementations must embed UnimplementedDomainDataGrantServiceServer for forward compatibility

type DomainDataServiceClient 

type DomainDataServiceClient interface {
	CreateDomainData(ctx context.Context, in *CreateDomainDataRequest, opts ...grpc.CallOption) (*CreateDomainDataResponse, error)
	QueryDomainData(ctx context.Context, in *QueryDomainDataRequest, opts ...grpc.CallOption) (*QueryDomainDataResponse, error)
	UpdateDomainData(ctx context.Context, in *UpdateDomainDataRequest, opts ...grpc.CallOption) (*UpdateDomainDataResponse, error)
	DeleteDomainData(ctx context.Context, in *DeleteDomainDataRequest, opts ...grpc.CallOption) (*DeleteDomainDataResponse, error)
}

DomainDataServiceClient is the client API for DomainDataService 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.

func NewDomainDataServiceClient 

func NewDomainDataServiceClient(cc grpc.ClientConnInterface) DomainDataServiceClient

type DomainDataServiceServer 

type DomainDataServiceServer interface {
	CreateDomainData(context.Context, *CreateDomainDataRequest) (*CreateDomainDataResponse, error)
	QueryDomainData(context.Context, *QueryDomainDataRequest) (*QueryDomainDataResponse, error)
	UpdateDomainData(context.Context, *UpdateDomainDataRequest) (*UpdateDomainDataResponse, error)
	DeleteDomainData(context.Context, *DeleteDomainDataRequest) (*DeleteDomainDataResponse, error)
	// contains filtered or unexported methods
}

DomainDataServiceServer is the server API for DomainDataService service. All implementations must embed UnimplementedDomainDataServiceServer for forward compatibility

type DomainDataSource 

type DomainDataSource struct {

	// datasource id
	DatasourceId string `protobuf:"bytes,1,opt,name=datasource_id,json=datasourceId,proto3" json:"datasource_id,omitempty"`
	// datasource name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// datasource type, enum [localfs, oss, mysql]
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// datasource status, enum [Available,Unavailable]
	Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// datasource info, for domain secretBackend which support set interface in clientSDK, you can set info directly when
	// create or update domainDataSource, you can also set an info_key already existed in secretBackend instead.
	// if you set info and info_key simultaneously, only info_key will take effect.
	Info *DataSourceInfo `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
	// datasource info key, for domain secretBackend which nonsupport set interface in clientSDK, use an secret key
	// instead of info when create or update DomainDataSource, the value refers to info_key is a json format string of
	// DataSourceInfo varies by datasource type
	InfoKey string `protobuf:"bytes,6,opt,name=info_key,json=infoKey,proto3" json:"info_key,omitempty"`
	// access directly to datasource or proxy_pass to DataProxy, default is false
	AccessDirectly bool `protobuf:"varint,7,opt,name=access_directly,json=accessDirectly,proto3" json:"access_directly,omitempty"`
	// contains filtered or unexported fields
}

func (*DomainDataSource) Descriptor deprecated 

func (*DomainDataSource) Descriptor() ([]byte, []int)

Deprecated: Use DomainDataSource.ProtoReflect.Descriptor instead.

func (*DomainDataSource) GetAccessDirectly 

func (x *DomainDataSource) GetAccessDirectly() bool

func (*DomainDataSource) GetDatasourceId 

func (x *DomainDataSource) GetDatasourceId() string

func (*DomainDataSource) GetInfo 

func (x *DomainDataSource) GetInfo() *DataSourceInfo

func (*DomainDataSource) GetInfoKey 

func (x *DomainDataSource) GetInfoKey() string

func (*DomainDataSource) GetName 

func (x *DomainDataSource) GetName() string

func (*DomainDataSource) GetStatus 

func (x *DomainDataSource) GetStatus() string

func (*DomainDataSource) GetType 

func (x *DomainDataSource) GetType() string

func (*DomainDataSource) ProtoMessage 

func (*DomainDataSource) ProtoMessage()

func (*DomainDataSource) ProtoReflect 

func (x *DomainDataSource) ProtoReflect() protoreflect.Message

func (*DomainDataSource) Reset 

func (x *DomainDataSource) Reset()

func (*DomainDataSource) String 

func (x *DomainDataSource) String() string

type DomainDataSourceServiceClient 

type DomainDataSourceServiceClient interface {
	QueryDomainDataSource(ctx context.Context, in *QueryDomainDataSourceRequest, opts ...grpc.CallOption) (*QueryDomainDataSourceResponse, error)
}

DomainDataSourceServiceClient is the client API for DomainDataSourceService 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.

func NewDomainDataSourceServiceClient 

func NewDomainDataSourceServiceClient(cc grpc.ClientConnInterface) DomainDataSourceServiceClient

type DomainDataSourceServiceServer 

type DomainDataSourceServiceServer interface {
	QueryDomainDataSource(context.Context, *QueryDomainDataSourceRequest) (*QueryDomainDataSourceResponse, error)
	// contains filtered or unexported methods
}

DomainDataSourceServiceServer is the server API for DomainDataSourceService service. All implementations must embed UnimplementedDomainDataSourceServiceServer for forward compatibility

type FileWriteOptions 

type FileWriteOptions struct {

	// Types that are assignable to Options:
	//
	//	*FileWriteOptions_CsvOptions
	Options isFileWriteOptions_Options `protobuf_oneof:"Options"`
	// contains filtered or unexported fields
}

write options varies by file format

func (*FileWriteOptions) Descriptor deprecated 

func (*FileWriteOptions) Descriptor() ([]byte, []int)

Deprecated: Use FileWriteOptions.ProtoReflect.Descriptor instead.

func (*FileWriteOptions) GetCsvOptions 

func (x *FileWriteOptions) GetCsvOptions() *CSVWriteOptions

func (*FileWriteOptions) GetOptions 

func (m *FileWriteOptions) GetOptions() isFileWriteOptions_Options

func (*FileWriteOptions) ProtoMessage 

func (*FileWriteOptions) ProtoMessage()

func (*FileWriteOptions) ProtoReflect 

func (x *FileWriteOptions) ProtoReflect() protoreflect.Message

func (*FileWriteOptions) Reset 

func (x *FileWriteOptions) Reset()

func (*FileWriteOptions) String 

func (x *FileWriteOptions) String() string

type FileWriteOptions_CsvOptions 

type FileWriteOptions_CsvOptions struct {
	CsvOptions *CSVWriteOptions `protobuf:"bytes,2,opt,name=csv_options,json=csvOptions,proto3,oneof"`
}

type GrantLimit 

type GrantLimit struct {
	ExpirationTime int64    `protobuf:"varint,1,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	UseCount       int32    `protobuf:"varint,2,opt,name=use_count,json=useCount,proto3" json:"use_count,omitempty"`
	FlowId         string   `protobuf:"bytes,3,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Components     []string `protobuf:"bytes,4,rep,name=components,proto3" json:"components,omitempty"`
	Initiator      string   `protobuf:"bytes,5,opt,name=initiator,proto3" json:"initiator,omitempty"`
	InputConfig    string   `protobuf:"bytes,6,opt,name=input_config,json=inputConfig,proto3" json:"input_config,omitempty"`
	// contains filtered or unexported fields
}

func (*GrantLimit) Descriptor deprecated 

func (*GrantLimit) Descriptor() ([]byte, []int)

Deprecated: Use GrantLimit.ProtoReflect.Descriptor instead.

func (*GrantLimit) GetComponents 

func (x *GrantLimit) GetComponents() []string

func (*GrantLimit) GetExpirationTime 

func (x *GrantLimit) GetExpirationTime() int64

func (*GrantLimit) GetFlowId 

func (x *GrantLimit) GetFlowId() string

func (*GrantLimit) GetInitiator 

func (x *GrantLimit) GetInitiator() string

func (*GrantLimit) GetInputConfig 

func (x *GrantLimit) GetInputConfig() string

func (*GrantLimit) GetUseCount 

func (x *GrantLimit) GetUseCount() int32

func (*GrantLimit) ProtoMessage 

func (*GrantLimit) ProtoMessage()

func (*GrantLimit) ProtoReflect 

func (x *GrantLimit) ProtoReflect() protoreflect.Message

func (*GrantLimit) Reset 

func (x *GrantLimit) Reset()

func (*GrantLimit) String 

func (x *GrantLimit) String() string

type LocalDataSourceInfo 

type LocalDataSourceInfo struct {

	// the local path of datasource
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

datasource info for local path

func (*LocalDataSourceInfo) Descriptor deprecated 

func (*LocalDataSourceInfo) Descriptor() ([]byte, []int)

Deprecated: Use LocalDataSourceInfo.ProtoReflect.Descriptor instead.

func (*LocalDataSourceInfo) GetPath 

func (x *LocalDataSourceInfo) GetPath() string

func (*LocalDataSourceInfo) ProtoMessage 

func (*LocalDataSourceInfo) ProtoMessage()

func (*LocalDataSourceInfo) ProtoReflect 

func (x *LocalDataSourceInfo) ProtoReflect() protoreflect.Message

func (*LocalDataSourceInfo) Reset 

func (x *LocalDataSourceInfo) Reset()

func (*LocalDataSourceInfo) String 

func (x *LocalDataSourceInfo) String() string

type OdpsDataSourceInfo 

type OdpsDataSourceInfo struct {

	// ODPS address such as "https://odps.xxx.cn-xxx.com"
	Endpoint        string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Project         string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	AccessKeyId     string `protobuf:"bytes,3,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	AccessKeySecret string `protobuf:"bytes,4,opt,name=access_key_secret,json=accessKeySecret,proto3" json:"access_key_secret,omitempty"`
	// contains filtered or unexported fields
}

func (*OdpsDataSourceInfo) Descriptor deprecated 

func (*OdpsDataSourceInfo) Descriptor() ([]byte, []int)

Deprecated: Use OdpsDataSourceInfo.ProtoReflect.Descriptor instead.

func (*OdpsDataSourceInfo) GetAccessKeyId 

func (x *OdpsDataSourceInfo) GetAccessKeyId() string

func (*OdpsDataSourceInfo) GetAccessKeySecret 

func (x *OdpsDataSourceInfo) GetAccessKeySecret() string

func (*OdpsDataSourceInfo) GetEndpoint 

func (x *OdpsDataSourceInfo) GetEndpoint() string

func (*OdpsDataSourceInfo) GetProject 

func (x *OdpsDataSourceInfo) GetProject() string

func (*OdpsDataSourceInfo) ProtoMessage 

func (*OdpsDataSourceInfo) ProtoMessage()

func (*OdpsDataSourceInfo) ProtoReflect 

func (x *OdpsDataSourceInfo) ProtoReflect() protoreflect.Message

func (*OdpsDataSourceInfo) Reset 

func (x *OdpsDataSourceInfo) Reset()

func (*OdpsDataSourceInfo) String 

func (x *OdpsDataSourceInfo) String() string

type OssDataSourceInfo 

type OssDataSourceInfo struct {

	// endpoint oss.xxx.cn-xxx.com or 127.0.0.1:9000
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// the bucket name of the oss datasource
	Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// the prefix of the oss datasource. e.g.  data/traindata/
	Prefix string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// access key
	AccessKeyId string `protobuf:"bytes,4,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	// access secret
	AccessKeySecret string `protobuf:"bytes,5,opt,name=access_key_secret,json=accessKeySecret,proto3" json:"access_key_secret,omitempty"`
	// virtualhost is the same as AliyunOSS's virtualhost , default true
	Virtualhost bool `protobuf:"varint,6,opt,name=virtualhost,proto3" json:"virtualhost,omitempty"`
	// optional enum[s3v2,s3v4]
	Version string `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	// optional enum[oss,minio] , default oss
	StorageType string `protobuf:"bytes,8,opt,name=storage_type,json=storageType,proto3" json:"storage_type,omitempty"`
	// contains filtered or unexported fields
}

datasource info for oss oss not support now

func (*OssDataSourceInfo) Descriptor deprecated 

func (*OssDataSourceInfo) Descriptor() ([]byte, []int)

Deprecated: Use OssDataSourceInfo.ProtoReflect.Descriptor instead.

func (*OssDataSourceInfo) GetAccessKeyId 

func (x *OssDataSourceInfo) GetAccessKeyId() string

func (*OssDataSourceInfo) GetAccessKeySecret 

func (x *OssDataSourceInfo) GetAccessKeySecret() string

func (*OssDataSourceInfo) GetBucket 

func (x *OssDataSourceInfo) GetBucket() string

func (*OssDataSourceInfo) GetEndpoint 

func (x *OssDataSourceInfo) GetEndpoint() string

func (*OssDataSourceInfo) GetPrefix 

func (x *OssDataSourceInfo) GetPrefix() string

func (*OssDataSourceInfo) GetStorageType 

func (x *OssDataSourceInfo) GetStorageType() string

func (*OssDataSourceInfo) GetVersion 

func (x *OssDataSourceInfo) GetVersion() string

func (*OssDataSourceInfo) GetVirtualhost 

func (x *OssDataSourceInfo) GetVirtualhost() bool

func (*OssDataSourceInfo) ProtoMessage 

func (*OssDataSourceInfo) ProtoMessage()

func (*OssDataSourceInfo) ProtoReflect 

func (x *OssDataSourceInfo) ProtoReflect() protoreflect.Message

func (*OssDataSourceInfo) Reset 

func (x *OssDataSourceInfo) Reset()

func (*OssDataSourceInfo) String 

func (x *OssDataSourceInfo) String() string

type QueryDomainDataGrantRequest 

type QueryDomainDataGrantRequest struct {
	Header            *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DomaindatagrantId string                  `protobuf:"bytes,2,opt,name=domaindatagrant_id,json=domaindatagrantId,proto3" json:"domaindatagrant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDomainDataGrantRequest) Descriptor deprecated 

func (*QueryDomainDataGrantRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryDomainDataGrantRequest.ProtoReflect.Descriptor instead.

func (*QueryDomainDataGrantRequest) GetDomaindatagrantId 

func (x *QueryDomainDataGrantRequest) GetDomaindatagrantId() string

func (*QueryDomainDataGrantRequest) GetHeader 

func (x *QueryDomainDataGrantRequest) GetHeader() *v1alpha1.RequestHeader

func (*QueryDomainDataGrantRequest) ProtoMessage 

func (*QueryDomainDataGrantRequest) ProtoMessage()

func (*QueryDomainDataGrantRequest) ProtoReflect 

func (x *QueryDomainDataGrantRequest) ProtoReflect() protoreflect.Message

func (*QueryDomainDataGrantRequest) Reset 

func (x *QueryDomainDataGrantRequest) Reset()

func (*QueryDomainDataGrantRequest) String 

func (x *QueryDomainDataGrantRequest) String() string

type QueryDomainDataGrantResponse 

type QueryDomainDataGrantResponse struct {
	Status *v1alpha1.Status     `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Data   *DomainDataGrantData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDomainDataGrantResponse) Descriptor deprecated 

func (*QueryDomainDataGrantResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryDomainDataGrantResponse.ProtoReflect.Descriptor instead.

func (*QueryDomainDataGrantResponse) GetData 

func (x *QueryDomainDataGrantResponse) GetData() *DomainDataGrantData

func (*QueryDomainDataGrantResponse) GetStatus 

func (x *QueryDomainDataGrantResponse) GetStatus() *v1alpha1.Status

func (*QueryDomainDataGrantResponse) ProtoMessage 

func (*QueryDomainDataGrantResponse) ProtoMessage()

func (*QueryDomainDataGrantResponse) ProtoReflect 

func (x *QueryDomainDataGrantResponse) ProtoReflect() protoreflect.Message

func (*QueryDomainDataGrantResponse) Reset 

func (x *QueryDomainDataGrantResponse) Reset()

func (*QueryDomainDataGrantResponse) String 

func (x *QueryDomainDataGrantResponse) String() string

type QueryDomainDataRequest 

type QueryDomainDataRequest struct {
	Header       *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DomaindataId string                  `protobuf:"bytes,2,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDomainDataRequest) Descriptor deprecated 

func (*QueryDomainDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryDomainDataRequest.ProtoReflect.Descriptor instead.

func (*QueryDomainDataRequest) GetDomaindataId 

func (x *QueryDomainDataRequest) GetDomaindataId() string

func (*QueryDomainDataRequest) GetHeader 

func (x *QueryDomainDataRequest) GetHeader() *v1alpha1.RequestHeader

func (*QueryDomainDataRequest) ProtoMessage 

func (*QueryDomainDataRequest) ProtoMessage()

func (*QueryDomainDataRequest) ProtoReflect 

func (x *QueryDomainDataRequest) ProtoReflect() protoreflect.Message

func (*QueryDomainDataRequest) Reset 

func (x *QueryDomainDataRequest) Reset()

func (*QueryDomainDataRequest) String 

func (x *QueryDomainDataRequest) String() string

type QueryDomainDataResponse 

type QueryDomainDataResponse struct {
	Status *v1alpha1.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Data   *DomainData      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDomainDataResponse) Descriptor deprecated 

func (*QueryDomainDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryDomainDataResponse.ProtoReflect.Descriptor instead.

func (*QueryDomainDataResponse) GetData 

func (x *QueryDomainDataResponse) GetData() *DomainData

func (*QueryDomainDataResponse) GetStatus 

func (x *QueryDomainDataResponse) GetStatus() *v1alpha1.Status

func (*QueryDomainDataResponse) ProtoMessage 

func (*QueryDomainDataResponse) ProtoMessage()

func (*QueryDomainDataResponse) ProtoReflect 

func (x *QueryDomainDataResponse) ProtoReflect() protoreflect.Message

func (*QueryDomainDataResponse) Reset 

func (x *QueryDomainDataResponse) Reset()

func (*QueryDomainDataResponse) String 

func (x *QueryDomainDataResponse) String() string

type QueryDomainDataSourceRequest 

type QueryDomainDataSourceRequest struct {
	Header       *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DatasourceId string                  `protobuf:"bytes,2,opt,name=datasource_id,json=datasourceId,proto3" json:"datasource_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDomainDataSourceRequest) Descriptor deprecated 

func (*QueryDomainDataSourceRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryDomainDataSourceRequest.ProtoReflect.Descriptor instead.

func (*QueryDomainDataSourceRequest) GetDatasourceId 

func (x *QueryDomainDataSourceRequest) GetDatasourceId() string

func (*QueryDomainDataSourceRequest) GetHeader 

func (x *QueryDomainDataSourceRequest) GetHeader() *v1alpha1.RequestHeader

func (*QueryDomainDataSourceRequest) ProtoMessage 

func (*QueryDomainDataSourceRequest) ProtoMessage()

func (*QueryDomainDataSourceRequest) ProtoReflect 

func (x *QueryDomainDataSourceRequest) ProtoReflect() protoreflect.Message

func (*QueryDomainDataSourceRequest) Reset 

func (x *QueryDomainDataSourceRequest) Reset()

func (*QueryDomainDataSourceRequest) String 

func (x *QueryDomainDataSourceRequest) String() string

type QueryDomainDataSourceResponse 

type QueryDomainDataSourceResponse struct {
	Status *v1alpha1.Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Data   *DomainDataSource `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDomainDataSourceResponse) Descriptor deprecated 

func (*QueryDomainDataSourceResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryDomainDataSourceResponse.ProtoReflect.Descriptor instead.

func (*QueryDomainDataSourceResponse) GetData 

func (x *QueryDomainDataSourceResponse) GetData() *DomainDataSource

func (*QueryDomainDataSourceResponse) GetStatus 

func (x *QueryDomainDataSourceResponse) GetStatus() *v1alpha1.Status

func (*QueryDomainDataSourceResponse) ProtoMessage 

func (*QueryDomainDataSourceResponse) ProtoMessage()

func (*QueryDomainDataSourceResponse) ProtoReflect 

func (x *QueryDomainDataSourceResponse) ProtoReflect() protoreflect.Message

func (*QueryDomainDataSourceResponse) Reset 

func (x *QueryDomainDataSourceResponse) Reset()

func (*QueryDomainDataSourceResponse) String 

func (x *QueryDomainDataSourceResponse) String() string

type UnimplementedDomainDataGrantServiceServer 

type UnimplementedDomainDataGrantServiceServer struct {
}

UnimplementedDomainDataGrantServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainDataGrantServiceServer) CreateDomainDataGrant 

func (UnimplementedDomainDataGrantServiceServer) CreateDomainDataGrant(context.Context, *CreateDomainDataGrantRequest) (*CreateDomainDataGrantResponse, error)

func (UnimplementedDomainDataGrantServiceServer) DeleteDomainDataGrant 

func (UnimplementedDomainDataGrantServiceServer) DeleteDomainDataGrant(context.Context, *DeleteDomainDataGrantRequest) (*DeleteDomainDataGrantResponse, error)

func (UnimplementedDomainDataGrantServiceServer) QueryDomainDataGrant 

func (UnimplementedDomainDataGrantServiceServer) QueryDomainDataGrant(context.Context, *QueryDomainDataGrantRequest) (*QueryDomainDataGrantResponse, error)

func (UnimplementedDomainDataGrantServiceServer) UpdateDomainDataGrant 

func (UnimplementedDomainDataGrantServiceServer) UpdateDomainDataGrant(context.Context, *UpdateDomainDataGrantRequest) (*UpdateDomainDataGrantResponse, error)

type UnimplementedDomainDataServiceServer 

type UnimplementedDomainDataServiceServer struct {
}

UnimplementedDomainDataServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainDataServiceServer) CreateDomainData 

func (UnimplementedDomainDataServiceServer) CreateDomainData(context.Context, *CreateDomainDataRequest) (*CreateDomainDataResponse, error)

func (UnimplementedDomainDataServiceServer) DeleteDomainData 

func (UnimplementedDomainDataServiceServer) DeleteDomainData(context.Context, *DeleteDomainDataRequest) (*DeleteDomainDataResponse, error)

func (UnimplementedDomainDataServiceServer) QueryDomainData 

func (UnimplementedDomainDataServiceServer) QueryDomainData(context.Context, *QueryDomainDataRequest) (*QueryDomainDataResponse, error)

func (UnimplementedDomainDataServiceServer) UpdateDomainData 

func (UnimplementedDomainDataServiceServer) UpdateDomainData(context.Context, *UpdateDomainDataRequest) (*UpdateDomainDataResponse, error)

type UnimplementedDomainDataSourceServiceServer 

type UnimplementedDomainDataSourceServiceServer struct {
}

UnimplementedDomainDataSourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainDataSourceServiceServer) QueryDomainDataSource 

func (UnimplementedDomainDataSourceServiceServer) QueryDomainDataSource(context.Context, *QueryDomainDataSourceRequest) (*QueryDomainDataSourceResponse, error)

type UnsafeDomainDataGrantServiceServer 

type UnsafeDomainDataGrantServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDomainDataGrantServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DomainDataGrantServiceServer will result in compilation errors.

type UnsafeDomainDataServiceServer 

type UnsafeDomainDataServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDomainDataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DomainDataServiceServer will result in compilation errors.

type UnsafeDomainDataSourceServiceServer 

type UnsafeDomainDataSourceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDomainDataSourceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DomainDataSourceServiceServer will result in compilation errors.

type UpdateDomainDataGrantRequest 

type UpdateDomainDataGrantRequest struct {
	Header            *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DomaindatagrantId string                  `protobuf:"bytes,2,opt,name=domaindatagrant_id,json=domaindatagrantId,proto3" json:"domaindatagrant_id,omitempty"`
	DomaindataId      string                  `protobuf:"bytes,3,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	GrantDomain       string                  `protobuf:"bytes,4,opt,name=grant_domain,json=grantDomain,proto3" json:"grant_domain,omitempty"`
	Limit             *GrantLimit             `protobuf:"bytes,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Description       map[string]string       `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateDomainDataGrantRequest) Descriptor deprecated 

func (*UpdateDomainDataGrantRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDomainDataGrantRequest.ProtoReflect.Descriptor instead.

func (*UpdateDomainDataGrantRequest) GetDescription 

func (x *UpdateDomainDataGrantRequest) GetDescription() map[string]string

func (*UpdateDomainDataGrantRequest) GetDomaindataId 

func (x *UpdateDomainDataGrantRequest) GetDomaindataId() string

func (*UpdateDomainDataGrantRequest) GetDomaindatagrantId 

func (x *UpdateDomainDataGrantRequest) GetDomaindatagrantId() string

func (*UpdateDomainDataGrantRequest) GetGrantDomain 

func (x *UpdateDomainDataGrantRequest) GetGrantDomain() string

func (*UpdateDomainDataGrantRequest) GetHeader 

func (x *UpdateDomainDataGrantRequest) GetHeader() *v1alpha1.RequestHeader

func (*UpdateDomainDataGrantRequest) GetLimit 

func (x *UpdateDomainDataGrantRequest) GetLimit() *GrantLimit

func (*UpdateDomainDataGrantRequest) ProtoMessage 

func (*UpdateDomainDataGrantRequest) ProtoMessage()

func (*UpdateDomainDataGrantRequest) ProtoReflect 

func (x *UpdateDomainDataGrantRequest) ProtoReflect() protoreflect.Message

func (*UpdateDomainDataGrantRequest) Reset 

func (x *UpdateDomainDataGrantRequest) Reset()

func (*UpdateDomainDataGrantRequest) String 

func (x *UpdateDomainDataGrantRequest) String() string

type UpdateDomainDataGrantResponse 

type UpdateDomainDataGrantResponse struct {
	Status *v1alpha1.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDomainDataGrantResponse) Descriptor deprecated 

func (*UpdateDomainDataGrantResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDomainDataGrantResponse.ProtoReflect.Descriptor instead.

func (*UpdateDomainDataGrantResponse) GetStatus 

func (x *UpdateDomainDataGrantResponse) GetStatus() *v1alpha1.Status

func (*UpdateDomainDataGrantResponse) ProtoMessage 

func (*UpdateDomainDataGrantResponse) ProtoMessage()

func (*UpdateDomainDataGrantResponse) ProtoReflect 

func (x *UpdateDomainDataGrantResponse) ProtoReflect() protoreflect.Message

func (*UpdateDomainDataGrantResponse) Reset 

func (x *UpdateDomainDataGrantResponse) Reset()

func (*UpdateDomainDataGrantResponse) String 

func (x *UpdateDomainDataGrantResponse) String() string

type UpdateDomainDataRequest 

type UpdateDomainDataRequest struct {
	Header *v1alpha1.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Mandatory, The domaindata_id indicate which domaindata would be updated.
	DomaindataId string `protobuf:"bytes,2,opt,name=domaindata_id,json=domaindataId,proto3" json:"domaindata_id,omitempty"`
	// the human-readable name
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Enum: table,model,rule,report,unknown
	Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// The relative_uri is relative to the datasource URI, The datasourceURI appends relative_uri is the domaindataURI.
	// e.g. the relative_uri is "train/table.csv"
	//
	//	the URI of datasource is "/home/data"
	//	the URI of domaindata is "/home/data/train/table.csv"
	RelativeUri string `protobuf:"bytes,5,opt,name=relative_uri,json=relativeUri,proto3" json:"relative_uri,omitempty"`
	// The datasource is where the domain is stored.
	DatasourceId string `protobuf:"bytes,6,opt,name=datasource_id,json=datasourceId,proto3" json:"datasource_id,omitempty"`
	// The attributes of the domaindata, this field use as a extra field, User could set
	// this field to any data that they need.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// Partition not support now
	Partition *v1alpha1.Partition `protobuf:"bytes,8,opt,name=partition,proto3" json:"partition,omitempty"`
	// columns: the columns' information of the table data.
	// this field must be set if the type is 'table'
	Columns []*v1alpha1.DataColumn `protobuf:"bytes,9,rep,name=columns,proto3" json:"columns,omitempty"`
	// The vendor is the one who outputs the domain data, it may be the secretFlow engine,
	// another vendor's engine, or manually registered.  enum manual,secretflow.
	Vendor     string              `protobuf:"bytes,10,opt,name=vendor,proto3" json:"vendor,omitempty"`
	FileFormat v1alpha1.FileFormat `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateDomainDataRequest) Descriptor deprecated 

func (*UpdateDomainDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDomainDataRequest.ProtoReflect.Descriptor instead.

func (*UpdateDomainDataRequest) GetAttributes 

func (x *UpdateDomainDataRequest) GetAttributes() map[string]string

func (*UpdateDomainDataRequest) GetColumns 

func (x *UpdateDomainDataRequest) GetColumns() []*v1alpha1.DataColumn

func (*UpdateDomainDataRequest) GetDatasourceId 

func (x *UpdateDomainDataRequest) GetDatasourceId() string

func (*UpdateDomainDataRequest) GetDomaindataId 

func (x *UpdateDomainDataRequest) GetDomaindataId() string

func (*UpdateDomainDataRequest) GetFileFormat 

func (x *UpdateDomainDataRequest) GetFileFormat() v1alpha1.FileFormat

func (*UpdateDomainDataRequest) GetHeader 

func (x *UpdateDomainDataRequest) GetHeader() *v1alpha1.RequestHeader

func (*UpdateDomainDataRequest) GetName 

func (x *UpdateDomainDataRequest) GetName() string

func (*UpdateDomainDataRequest) GetPartition 

func (x *UpdateDomainDataRequest) GetPartition() *v1alpha1.Partition

func (*UpdateDomainDataRequest) GetRelativeUri 

func (x *UpdateDomainDataRequest) GetRelativeUri() string

func (*UpdateDomainDataRequest) GetType 

func (x *UpdateDomainDataRequest) GetType() string

func (*UpdateDomainDataRequest) GetVendor 

func (x *UpdateDomainDataRequest) GetVendor() string

func (*UpdateDomainDataRequest) ProtoMessage 

func (*UpdateDomainDataRequest) ProtoMessage()

func (*UpdateDomainDataRequest) ProtoReflect 

func (x *UpdateDomainDataRequest) ProtoReflect() protoreflect.Message

func (*UpdateDomainDataRequest) Reset 

func (x *UpdateDomainDataRequest) Reset()

func (*UpdateDomainDataRequest) String 

func (x *UpdateDomainDataRequest) String() string

type UpdateDomainDataResponse 

type UpdateDomainDataResponse struct {
	Status *v1alpha1.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDomainDataResponse) Descriptor deprecated 

func (*UpdateDomainDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDomainDataResponse.ProtoReflect.Descriptor instead.

func (*UpdateDomainDataResponse) GetStatus 

func (x *UpdateDomainDataResponse) GetStatus() *v1alpha1.Status

func (*UpdateDomainDataResponse) ProtoMessage 

func (*UpdateDomainDataResponse) ProtoMessage()

func (*UpdateDomainDataResponse) ProtoReflect 

func (x *UpdateDomainDataResponse) ProtoReflect() protoreflect.Message

func (*UpdateDomainDataResponse) Reset 

func (x *UpdateDomainDataResponse) Reset()

func (*UpdateDomainDataResponse) String 

func (x *UpdateDomainDataResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.