v1

package
v0.3.42 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modeldapi_services_data_v1_data_proto protoreflect.FileDescriptor

Functions

func RegisterDataServiceServer 

func RegisterDataServiceServer(s *grpc.Server, srv DataServiceServer)

Types

type AskModelRequest 

type AskModelRequest struct {
	Product             *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version             *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	StudyName           string                       `protobuf:"bytes,3,opt,name=studyName,proto3" json:"studyName,omitempty"`
	StudyNamespace      string                       `protobuf:"bytes,4,opt,name=studyNamespace,proto3" json:"studyNamespace,omitempty"`
	StudySpec           *v1alpha12.StudySpec         `protobuf:"bytes,5,opt,name=studySpec,proto3" json:"studySpec,omitempty"`
	DatasourceName      string                       `protobuf:"bytes,6,opt,name=datasourceName,proto3" json:"datasourceName,omitempty"`
	DatasourceNamespace string                       `protobuf:"bytes,7,opt,name=datasourceNamespace,proto3" json:"datasourceNamespace,omitempty"`
	DatasourceSpec      *v1alpha1.DataSourceSpec     `protobuf:"bytes,8,opt,name=datasourceSpec,proto3" json:"datasourceSpec,omitempty"`
	DatasetName         string                       `protobuf:"bytes,9,opt,name=datasetName,proto3" json:"datasetName,omitempty"`
	DatasetNamespace    string                       `protobuf:"bytes,10,opt,name=datasetNamespace,proto3" json:"datasetNamespace,omitempty"`
	DatasetSpec         *v1alpha1.DatasetSpec        `protobuf:"bytes,11,opt,name=datasetSpec,proto3" json:"datasetSpec,omitempty"`
	Budget              int32                        `protobuf:"varint,12,opt,name=budget,proto3" json:"budget,omitempty"`
	// contains filtered or unexported fields
}

func (*AskModelRequest) Descriptor deprecated 

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

Deprecated: Use AskModelRequest.ProtoReflect.Descriptor instead.

func (*AskModelRequest) GetBudget 

func (x *AskModelRequest) GetBudget() int32

func (*AskModelRequest) GetDatasetName 

func (x *AskModelRequest) GetDatasetName() string

func (*AskModelRequest) GetDatasetNamespace 

func (x *AskModelRequest) GetDatasetNamespace() string

func (*AskModelRequest) GetDatasetSpec 

func (x *AskModelRequest) GetDatasetSpec() *v1alpha1.DatasetSpec

func (*AskModelRequest) GetDatasourceName 

func (x *AskModelRequest) GetDatasourceName() string

func (*AskModelRequest) GetDatasourceNamespace 

func (x *AskModelRequest) GetDatasourceNamespace() string

func (*AskModelRequest) GetDatasourceSpec 

func (x *AskModelRequest) GetDatasourceSpec() *v1alpha1.DataSourceSpec

func (*AskModelRequest) GetProduct 

func (x *AskModelRequest) GetProduct() *v1alpha1.DataProduct

func (*AskModelRequest) GetStudyName 

func (x *AskModelRequest) GetStudyName() string

func (*AskModelRequest) GetStudyNamespace 

func (x *AskModelRequest) GetStudyNamespace() string

func (*AskModelRequest) GetStudySpec 

func (x *AskModelRequest) GetStudySpec() *v1alpha12.StudySpec

func (*AskModelRequest) GetVersion 

func (x *AskModelRequest) GetVersion() *v1alpha1.DataProductVersion

func (*AskModelRequest) ProtoMessage 

func (*AskModelRequest) ProtoMessage()

func (*AskModelRequest) ProtoReflect 

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

func (*AskModelRequest) Reset 

func (x *AskModelRequest) Reset()

func (*AskModelRequest) String 

func (x *AskModelRequest) String() string

type AskModelResponse 

type AskModelResponse struct {
	Spec *v1alpha12.ModelSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*AskModelResponse) Descriptor deprecated 

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

Deprecated: Use AskModelResponse.ProtoReflect.Descriptor instead.

func (*AskModelResponse) GetSpec 

func (x *AskModelResponse) GetSpec() *v1alpha12.ModelSpec

func (*AskModelResponse) ProtoMessage 

func (*AskModelResponse) ProtoMessage()

func (*AskModelResponse) ProtoReflect 

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

func (*AskModelResponse) Reset 

func (x *AskModelResponse) Reset()

func (*AskModelResponse) String 

func (x *AskModelResponse) String() string

type CreateDatasetReportRequest 

type CreateDatasetReportRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,6,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Report     *v1alpha12.Report            `protobuf:"bytes,8,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatasetReportRequest) Descriptor deprecated 

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

Deprecated: Use CreateDatasetReportRequest.ProtoReflect.Descriptor instead.

func (*CreateDatasetReportRequest) GetBucket 

func (x *CreateDatasetReportRequest) GetBucket() *v1alpha11.VirtualBucket

func (*CreateDatasetReportRequest) GetConnection 

func (x *CreateDatasetReportRequest) GetConnection() *v1alpha11.Connection

func (*CreateDatasetReportRequest) GetDataset 

func (x *CreateDatasetReportRequest) GetDataset() *v1alpha1.Dataset

func (*CreateDatasetReportRequest) GetDatasource 

func (x *CreateDatasetReportRequest) GetDatasource() *v1alpha1.DataSource

func (*CreateDatasetReportRequest) GetProduct 

func (x *CreateDatasetReportRequest) GetProduct() *v1alpha1.DataProduct

func (*CreateDatasetReportRequest) GetReport 

func (x *CreateDatasetReportRequest) GetReport() *v1alpha12.Report

func (*CreateDatasetReportRequest) GetSecret 

func (x *CreateDatasetReportRequest) GetSecret() map[string][]byte

func (*CreateDatasetReportRequest) GetVersion 

func (x *CreateDatasetReportRequest) GetVersion() *v1alpha1.DataProductVersion

func (*CreateDatasetReportRequest) ProtoMessage 

func (*CreateDatasetReportRequest) ProtoMessage()

func (*CreateDatasetReportRequest) ProtoReflect 

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

func (*CreateDatasetReportRequest) Reset 

func (x *CreateDatasetReportRequest) Reset()

func (*CreateDatasetReportRequest) String 

func (x *CreateDatasetReportRequest) String() string

type CreateForecastReportRequest 

type CreateForecastReportRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,3,opt,name=study,proto3" json:"study,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,5,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Forecast   *v1alpha12.Model             `protobuf:"bytes,6,opt,name=forecast,proto3" json:"forecast,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,7,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,9,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Report     *v1alpha12.Report            `protobuf:"bytes,10,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateForecastReportRequest) Descriptor deprecated 

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

Deprecated: Use CreateForecastReportRequest.ProtoReflect.Descriptor instead.

func (*CreateForecastReportRequest) GetBucket 

func (x *CreateForecastReportRequest) GetBucket() *v1alpha11.VirtualBucket

func (*CreateForecastReportRequest) GetConnection 

func (x *CreateForecastReportRequest) GetConnection() *v1alpha11.Connection

func (*CreateForecastReportRequest) GetDataset 

func (x *CreateForecastReportRequest) GetDataset() *v1alpha1.Dataset

func (*CreateForecastReportRequest) GetDatasource 

func (x *CreateForecastReportRequest) GetDatasource() *v1alpha1.DataSource

func (*CreateForecastReportRequest) GetForecast 

func (x *CreateForecastReportRequest) GetForecast() *v1alpha12.Model

func (*CreateForecastReportRequest) GetProduct 

func (x *CreateForecastReportRequest) GetProduct() *v1alpha1.DataProduct

func (*CreateForecastReportRequest) GetReport 

func (x *CreateForecastReportRequest) GetReport() *v1alpha12.Report

func (*CreateForecastReportRequest) GetSecret 

func (x *CreateForecastReportRequest) GetSecret() map[string][]byte

func (*CreateForecastReportRequest) GetStudy 

func (x *CreateForecastReportRequest) GetStudy() *v1alpha12.Study

func (*CreateForecastReportRequest) GetVersion 

func (x *CreateForecastReportRequest) GetVersion() *v1alpha1.DataProductVersion

func (*CreateForecastReportRequest) ProtoMessage 

func (*CreateForecastReportRequest) ProtoMessage()

func (*CreateForecastReportRequest) ProtoReflect 

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

func (*CreateForecastReportRequest) Reset 

func (x *CreateForecastReportRequest) Reset()

func (*CreateForecastReportRequest) String 

func (x *CreateForecastReportRequest) String() string

type CreateModelReportRequest 

type CreateModelReportRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,3,opt,name=study,proto3" json:"study,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,5,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Model      *v1alpha12.Model             `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,7,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,9,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Report     *v1alpha12.Report            `protobuf:"bytes,10,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateModelReportRequest) Descriptor deprecated 

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

Deprecated: Use CreateModelReportRequest.ProtoReflect.Descriptor instead.

func (*CreateModelReportRequest) GetBucket 

func (x *CreateModelReportRequest) GetBucket() *v1alpha11.VirtualBucket

func (*CreateModelReportRequest) GetConnection 

func (x *CreateModelReportRequest) GetConnection() *v1alpha11.Connection

func (*CreateModelReportRequest) GetDataset 

func (x *CreateModelReportRequest) GetDataset() *v1alpha1.Dataset

func (*CreateModelReportRequest) GetDatasource 

func (x *CreateModelReportRequest) GetDatasource() *v1alpha1.DataSource

func (*CreateModelReportRequest) GetModel 

func (x *CreateModelReportRequest) GetModel() *v1alpha12.Model

func (*CreateModelReportRequest) GetProduct 

func (x *CreateModelReportRequest) GetProduct() *v1alpha1.DataProduct

func (*CreateModelReportRequest) GetReport 

func (x *CreateModelReportRequest) GetReport() *v1alpha12.Report

func (*CreateModelReportRequest) GetSecret 

func (x *CreateModelReportRequest) GetSecret() map[string][]byte

func (*CreateModelReportRequest) GetStudy 

func (x *CreateModelReportRequest) GetStudy() *v1alpha12.Study

func (*CreateModelReportRequest) GetVersion 

func (x *CreateModelReportRequest) GetVersion() *v1alpha1.DataProductVersion

func (*CreateModelReportRequest) ProtoMessage 

func (*CreateModelReportRequest) ProtoMessage()

func (*CreateModelReportRequest) ProtoReflect 

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

func (*CreateModelReportRequest) Reset 

func (x *CreateModelReportRequest) Reset()

func (*CreateModelReportRequest) String 

func (x *CreateModelReportRequest) String() string

type CreateReportResponse 

type CreateReportResponse struct {
	Pdf []byte `protobuf:"bytes,1,opt,name=pdf,proto3" json:"pdf,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReportResponse) Descriptor deprecated 

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

Deprecated: Use CreateReportResponse.ProtoReflect.Descriptor instead.

func (*CreateReportResponse) GetPdf 

func (x *CreateReportResponse) GetPdf() []byte

func (*CreateReportResponse) ProtoMessage 

func (*CreateReportResponse) ProtoMessage()

func (*CreateReportResponse) ProtoReflect 

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

func (*CreateReportResponse) Reset 

func (x *CreateReportResponse) Reset()

func (*CreateReportResponse) String 

func (x *CreateReportResponse) String() string

type CreateStudyReportRequest 

type CreateStudyReportRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,3,opt,name=study,proto3" json:"study,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,5,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Models     *v1alpha12.ModelList         `protobuf:"bytes,6,opt,name=models,proto3" json:"models,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,7,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,8,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Report     *v1alpha12.Report            `protobuf:"bytes,10,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStudyReportRequest) Descriptor deprecated 

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

Deprecated: Use CreateStudyReportRequest.ProtoReflect.Descriptor instead.

func (*CreateStudyReportRequest) GetBucket 

func (x *CreateStudyReportRequest) GetBucket() *v1alpha11.VirtualBucket

func (*CreateStudyReportRequest) GetConnection 

func (x *CreateStudyReportRequest) GetConnection() *v1alpha11.Connection

func (*CreateStudyReportRequest) GetDataset 

func (x *CreateStudyReportRequest) GetDataset() *v1alpha1.Dataset

func (*CreateStudyReportRequest) GetDatasource 

func (x *CreateStudyReportRequest) GetDatasource() *v1alpha1.DataSource

func (*CreateStudyReportRequest) GetModels 

func (x *CreateStudyReportRequest) GetModels() *v1alpha12.ModelList

func (*CreateStudyReportRequest) GetProduct 

func (x *CreateStudyReportRequest) GetProduct() *v1alpha1.DataProduct

func (*CreateStudyReportRequest) GetReport 

func (x *CreateStudyReportRequest) GetReport() *v1alpha12.Report

func (*CreateStudyReportRequest) GetSecret 

func (x *CreateStudyReportRequest) GetSecret() map[string][]byte

func (*CreateStudyReportRequest) GetStudy 

func (x *CreateStudyReportRequest) GetStudy() *v1alpha12.Study

func (*CreateStudyReportRequest) GetVersion 

func (x *CreateStudyReportRequest) GetVersion() *v1alpha1.DataProductVersion

func (*CreateStudyReportRequest) ProtoMessage 

func (*CreateStudyReportRequest) ProtoMessage()

func (*CreateStudyReportRequest) ProtoReflect 

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

func (*CreateStudyReportRequest) Reset 

func (x *CreateStudyReportRequest) Reset()

func (*CreateStudyReportRequest) String 

func (x *CreateStudyReportRequest) String() string

type DataServiceClient 

type DataServiceClient interface {
	// Read from a flat file and create a dataset
	ReadFile(ctx context.Context, in *DsReadFileRequest, opts ...grpc.CallOption) (*DsReadFromStoreResponse, error)
	// Read from a feature and create a dataset
	ReadFeature(ctx context.Context, in *DsReadFeatureRequest, opts ...grpc.CallOption) (*DsReadFromStoreResponse, error)
	// Read from audio and create an audio dataset
	ReadAudio(ctx context.Context, in *DsReadAudioRequest, opts ...grpc.CallOption) (*DsReadFromStoreResponse, error)
	// Run the data flow
	RunDataPipeline(ctx context.Context, in *DsRunDataPipelineRequest, opts ...grpc.CallOption) (*DsRunDataPipelineResponse, error)
	// Run recipe
	RunRecipe(ctx context.Context, in *DsRunRecipeRequest, opts ...grpc.CallOption) (*DsRunRecipeResponse, error)
	// Read from a flat file and create a dataset
	WriteFile(ctx context.Context, in *DsWriteFileRequest, opts ...grpc.CallOption) (*DsReadFromStoreResponse, error)
	// Based on the datasource business rules, validate a dataset.
	ValidateDataset(ctx context.Context, in *DsValidateDatasetRequest, opts ...grpc.CallOption) (*DsValidateDatasetResponse, error)
	// Based on the datasource, generate test dataset
	GenerateDataset(ctx context.Context, in *DsGenerateDatasetRequest, opts ...grpc.CallOption) (*DsGenerateDatasetResponse, error)
	// Preform the split. The dataset is assumed to be in the live area after validation
	SplitDataset(ctx context.Context, in *DsSplitDatasetRequest, opts ...grpc.CallOption) (*DsSplitDatasetResponse, error)
	// Visualize a specific column
	CreateColumnProfile(ctx context.Context, in *DsCreateColumnProfileRequest, opts ...grpc.CallOption) (*DsCreateColumnProfileResponse, error)
	// Just infer the datasource, do no plots
	InferSchema(ctx context.Context, in *DsInferSchemaRequest, opts ...grpc.CallOption) (*DsInferSchemaResponse, error)
	// Just infer the datasource, do no plots
	GetTableView(ctx context.Context, in *DsGetTableViewRequest, opts ...grpc.CallOption) (*DsGetTableViewResponse, error)
	// Just infer the datasource, do no plots
	GetMisclassTableView(ctx context.Context, in *DsGetMisclassTableViewRequest, opts ...grpc.CallOption) (*DsGetMisclassTableViewResponse, error)
	// split the dataset to rungs
	SplitDatasetToRungs(ctx context.Context, in *DsSplitDatasetToRungsRequest, opts ...grpc.CallOption) (*DsSplitDatasetToRungsResponse, error)
	// create dataset profile
	CreateDatasetProfile(ctx context.Context, in *DsCreateDatasetProfileRequest, opts ...grpc.CallOption) (*DsCreateDatasetProfileResponse, error)
	// create model profile
	CreateModelProfile(ctx context.Context, in *DsCreateModelProfileRequest, opts ...grpc.CallOption) (*DsCreateModelProfileResponse, error)
	// create study profile
	CreateStudyProfile(ctx context.Context, in *DsCreateStudyProfileRequest, opts ...grpc.CallOption) (*DsCreateStudyProfileResponse, error)
	CreateRecipeProfile(ctx context.Context, in *DsCreateRecipeProfileRequest, opts ...grpc.CallOption) (*DsCreateRecipeProfileResponse, error)
	// report services
	CreateModelReport(ctx context.Context, in *CreateModelReportRequest, opts ...grpc.CallOption) (*CreateReportResponse, error)
	CreateStudyReport(ctx context.Context, in *CreateStudyReportRequest, opts ...grpc.CallOption) (*CreateReportResponse, error)
	CreateDatasetReport(ctx context.Context, in *CreateDatasetReportRequest, opts ...grpc.CallOption) (*CreateReportResponse, error)
	CreateForecastReport(ctx context.Context, in *CreateForecastReportRequest, opts ...grpc.CallOption) (*CreateReportResponse, error)
	// sample model randomly for a given budget
	AskModel(ctx context.Context, in *AskModelRequest, opts ...grpc.CallOption) (*AskModelResponse, error)
	// for bayaisn optimization, we tell the planner the result of the model evaluation
	TellModel(ctx context.Context, in *TellModelRequest, opts ...grpc.CallOption) (*TellModelResponse, error)
	// Partition the class
	PartitionForecastFile(ctx context.Context, in *DsCreateForecastPartitionFilesRequest, opts ...grpc.CallOption) (*DsCreateForecastPartitionFilesResponse, error)
	// Merge the forecast back to one file.
	MergeForecastFile(ctx context.Context, in *DsMergeForecastFileRequest, opts ...grpc.CallOption) (*DsMergeForecastFileResponse, error)
	ShutDown(ctx context.Context, in *DsShutdownRequest, opts ...grpc.CallOption) (*DsShutdownResponse, error)
}

DataServiceClient is the client API for DataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataServiceClient 

func NewDataServiceClient(cc grpc.ClientConnInterface) DataServiceClient

type DataServiceServer 

type DataServiceServer interface {
	// Read from a flat file and create a dataset
	ReadFile(context.Context, *DsReadFileRequest) (*DsReadFromStoreResponse, error)
	// Read from a feature and create a dataset
	ReadFeature(context.Context, *DsReadFeatureRequest) (*DsReadFromStoreResponse, error)
	// Read from audio and create an audio dataset
	ReadAudio(context.Context, *DsReadAudioRequest) (*DsReadFromStoreResponse, error)
	// Run the data flow
	RunDataPipeline(context.Context, *DsRunDataPipelineRequest) (*DsRunDataPipelineResponse, error)
	// Run recipe
	RunRecipe(context.Context, *DsRunRecipeRequest) (*DsRunRecipeResponse, error)
	// Read from a flat file and create a dataset
	WriteFile(context.Context, *DsWriteFileRequest) (*DsReadFromStoreResponse, error)
	// Based on the datasource business rules, validate a dataset.
	ValidateDataset(context.Context, *DsValidateDatasetRequest) (*DsValidateDatasetResponse, error)
	// Based on the datasource, generate test dataset
	GenerateDataset(context.Context, *DsGenerateDatasetRequest) (*DsGenerateDatasetResponse, error)
	// Preform the split. The dataset is assumed to be in the live area after validation
	SplitDataset(context.Context, *DsSplitDatasetRequest) (*DsSplitDatasetResponse, error)
	// Visualize a specific column
	CreateColumnProfile(context.Context, *DsCreateColumnProfileRequest) (*DsCreateColumnProfileResponse, error)
	// Just infer the datasource, do no plots
	InferSchema(context.Context, *DsInferSchemaRequest) (*DsInferSchemaResponse, error)
	// Just infer the datasource, do no plots
	GetTableView(context.Context, *DsGetTableViewRequest) (*DsGetTableViewResponse, error)
	// Just infer the datasource, do no plots
	GetMisclassTableView(context.Context, *DsGetMisclassTableViewRequest) (*DsGetMisclassTableViewResponse, error)
	// split the dataset to rungs
	SplitDatasetToRungs(context.Context, *DsSplitDatasetToRungsRequest) (*DsSplitDatasetToRungsResponse, error)
	// create dataset profile
	CreateDatasetProfile(context.Context, *DsCreateDatasetProfileRequest) (*DsCreateDatasetProfileResponse, error)
	// create model profile
	CreateModelProfile(context.Context, *DsCreateModelProfileRequest) (*DsCreateModelProfileResponse, error)
	// create study profile
	CreateStudyProfile(context.Context, *DsCreateStudyProfileRequest) (*DsCreateStudyProfileResponse, error)
	CreateRecipeProfile(context.Context, *DsCreateRecipeProfileRequest) (*DsCreateRecipeProfileResponse, error)
	// report services
	CreateModelReport(context.Context, *CreateModelReportRequest) (*CreateReportResponse, error)
	CreateStudyReport(context.Context, *CreateStudyReportRequest) (*CreateReportResponse, error)
	CreateDatasetReport(context.Context, *CreateDatasetReportRequest) (*CreateReportResponse, error)
	CreateForecastReport(context.Context, *CreateForecastReportRequest) (*CreateReportResponse, error)
	// sample model randomly for a given budget
	AskModel(context.Context, *AskModelRequest) (*AskModelResponse, error)
	// for bayaisn optimization, we tell the planner the result of the model evaluation
	TellModel(context.Context, *TellModelRequest) (*TellModelResponse, error)
	// Partition the class
	PartitionForecastFile(context.Context, *DsCreateForecastPartitionFilesRequest) (*DsCreateForecastPartitionFilesResponse, error)
	// Merge the forecast back to one file.
	MergeForecastFile(context.Context, *DsMergeForecastFileRequest) (*DsMergeForecastFileResponse, error)
	ShutDown(context.Context, *DsShutdownRequest) (*DsShutdownResponse, error)
}

DataServiceServer is the server API for DataService service.

type DataSourceResponse 

type DataSourceResponse struct {
	// contains filtered or unexported fields
}

func (*DataSourceResponse) Descriptor deprecated 

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

Deprecated: Use DataSourceResponse.ProtoReflect.Descriptor instead.

func (*DataSourceResponse) ProtoMessage 

func (*DataSourceResponse) ProtoMessage()

func (*DataSourceResponse) ProtoReflect 

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

func (*DataSourceResponse) Reset 

func (x *DataSourceResponse) Reset()

func (*DataSourceResponse) String 

func (x *DataSourceResponse) String() string

type DatasetResponse 

type DatasetResponse struct {
	// contains filtered or unexported fields
}

func (*DatasetResponse) Descriptor deprecated 

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

Deprecated: Use DatasetResponse.ProtoReflect.Descriptor instead.

func (*DatasetResponse) ProtoMessage 

func (*DatasetResponse) ProtoMessage()

func (*DatasetResponse) ProtoReflect 

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

func (*DatasetResponse) Reset 

func (x *DatasetResponse) Reset()

func (*DatasetResponse) String 

func (x *DatasetResponse) String() string

type DsCreateColumnProfileRequest 

type DsCreateColumnProfileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,6,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	ColumnType string                       `protobuf:"bytes,8,opt,name=columnType,proto3" json:"columnType,omitempty"`
	ColumnName string                       `protobuf:"bytes,9,opt,name=columnName,proto3" json:"columnName,omitempty"`
	// contains filtered or unexported fields
}

Used to create a profile before the dataset object exist

func (*DsCreateColumnProfileRequest) Descriptor deprecated 

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

Deprecated: Use DsCreateColumnProfileRequest.ProtoReflect.Descriptor instead.

func (*DsCreateColumnProfileRequest) GetBucket 

func (x *DsCreateColumnProfileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsCreateColumnProfileRequest) GetColumnName 

func (x *DsCreateColumnProfileRequest) GetColumnName() string

func (*DsCreateColumnProfileRequest) GetColumnType 

func (x *DsCreateColumnProfileRequest) GetColumnType() string

func (*DsCreateColumnProfileRequest) GetConnection 

func (x *DsCreateColumnProfileRequest) GetConnection() *v1alpha11.Connection

func (*DsCreateColumnProfileRequest) GetDataset 

func (x *DsCreateColumnProfileRequest) GetDataset() *v1alpha1.Dataset

func (*DsCreateColumnProfileRequest) GetDatasource 

func (x *DsCreateColumnProfileRequest) GetDatasource() *v1alpha1.DataSource

func (*DsCreateColumnProfileRequest) GetProduct 

func (x *DsCreateColumnProfileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsCreateColumnProfileRequest) GetSecret 

func (x *DsCreateColumnProfileRequest) GetSecret() map[string][]byte

func (*DsCreateColumnProfileRequest) GetVersion 

func (x *DsCreateColumnProfileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsCreateColumnProfileRequest) ProtoMessage 

func (*DsCreateColumnProfileRequest) ProtoMessage()

func (*DsCreateColumnProfileRequest) ProtoReflect 

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

func (*DsCreateColumnProfileRequest) Reset 

func (x *DsCreateColumnProfileRequest) Reset()

func (*DsCreateColumnProfileRequest) String 

func (x *DsCreateColumnProfileRequest) String() string

type DsCreateColumnProfileResponse 

type DsCreateColumnProfileResponse struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Plot *v1.Plot `protobuf:"bytes,2,opt,name=plot,proto3" json:"plot,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateColumnProfileResponse) Descriptor deprecated 

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

Deprecated: Use DsCreateColumnProfileResponse.ProtoReflect.Descriptor instead.

func (*DsCreateColumnProfileResponse) GetName 

func (x *DsCreateColumnProfileResponse) GetName() string

func (*DsCreateColumnProfileResponse) GetPlot 

func (x *DsCreateColumnProfileResponse) GetPlot() *v1.Plot

func (*DsCreateColumnProfileResponse) ProtoMessage 

func (*DsCreateColumnProfileResponse) ProtoMessage()

func (*DsCreateColumnProfileResponse) ProtoReflect 

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

func (*DsCreateColumnProfileResponse) Reset 

func (x *DsCreateColumnProfileResponse) Reset()

func (*DsCreateColumnProfileResponse) String 

func (x *DsCreateColumnProfileResponse) String() string

type DsCreateDatasetProfileRequest 

type DsCreateDatasetProfileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,6,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Create dataset profile

func (*DsCreateDatasetProfileRequest) Descriptor deprecated 

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

Deprecated: Use DsCreateDatasetProfileRequest.ProtoReflect.Descriptor instead.

func (*DsCreateDatasetProfileRequest) GetBucket 

func (x *DsCreateDatasetProfileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsCreateDatasetProfileRequest) GetConnection 

func (x *DsCreateDatasetProfileRequest) GetConnection() *v1alpha11.Connection

func (*DsCreateDatasetProfileRequest) GetDataset 

func (x *DsCreateDatasetProfileRequest) GetDataset() *v1alpha1.Dataset

func (*DsCreateDatasetProfileRequest) GetDatasource 

func (x *DsCreateDatasetProfileRequest) GetDatasource() *v1alpha1.DataSource

func (*DsCreateDatasetProfileRequest) GetProduct 

func (x *DsCreateDatasetProfileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsCreateDatasetProfileRequest) GetSecret 

func (x *DsCreateDatasetProfileRequest) GetSecret() map[string][]byte

func (*DsCreateDatasetProfileRequest) GetVersion 

func (x *DsCreateDatasetProfileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsCreateDatasetProfileRequest) ProtoMessage 

func (*DsCreateDatasetProfileRequest) ProtoMessage()

func (*DsCreateDatasetProfileRequest) ProtoReflect 

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

func (*DsCreateDatasetProfileRequest) Reset 

func (x *DsCreateDatasetProfileRequest) Reset()

func (*DsCreateDatasetProfileRequest) String 

func (x *DsCreateDatasetProfileRequest) String() string

type DsCreateDatasetProfileResponse 

type DsCreateDatasetProfileResponse struct {
	Uri     string             `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Profile *v1.DatasetProfile `protobuf:"bytes,2,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateDatasetProfileResponse) Descriptor deprecated 

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

Deprecated: Use DsCreateDatasetProfileResponse.ProtoReflect.Descriptor instead.

func (*DsCreateDatasetProfileResponse) GetProfile 

func (x *DsCreateDatasetProfileResponse) GetProfile() *v1.DatasetProfile

func (*DsCreateDatasetProfileResponse) GetUri 

func (x *DsCreateDatasetProfileResponse) GetUri() string

func (*DsCreateDatasetProfileResponse) ProtoMessage 

func (*DsCreateDatasetProfileResponse) ProtoMessage()

func (*DsCreateDatasetProfileResponse) ProtoReflect 

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

func (*DsCreateDatasetProfileResponse) Reset 

func (x *DsCreateDatasetProfileResponse) Reset()

func (*DsCreateDatasetProfileResponse) String 

func (x *DsCreateDatasetProfileResponse) String() string

type DsCreateForecastPartitionFilesRequest 

type DsCreateForecastPartitionFilesRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,5,opt,name=study,proto3" json:"study,omitempty"`
	Model      *v1alpha12.Model             `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,8,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,9,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 154-byte string literal not displayed */
	Forecasts  []*v1alpha12.ForecastObj     `protobuf:"bytes,11,rep,name=forecasts,proto3" json:"forecasts,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateForecastPartitionFilesRequest) Descriptor deprecated 

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

Deprecated: Use DsCreateForecastPartitionFilesRequest.ProtoReflect.Descriptor instead.

func (*DsCreateForecastPartitionFilesRequest) GetBucket 

func (x *DsCreateForecastPartitionFilesRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsCreateForecastPartitionFilesRequest) GetConnection 

func (x *DsCreateForecastPartitionFilesRequest) GetConnection() *v1alpha11.Connection

func (*DsCreateForecastPartitionFilesRequest) GetDataset 

func (x *DsCreateForecastPartitionFilesRequest) GetDataset() *v1alpha1.Dataset

func (*DsCreateForecastPartitionFilesRequest) GetDatasource 

func (x *DsCreateForecastPartitionFilesRequest) GetDatasource() *v1alpha1.DataSource

func (*DsCreateForecastPartitionFilesRequest) GetForecasts 

func (x *DsCreateForecastPartitionFilesRequest) GetForecasts() []*v1alpha12.ForecastObj

func (*DsCreateForecastPartitionFilesRequest) GetModel 

func (x *DsCreateForecastPartitionFilesRequest) GetModel() *v1alpha12.Model

func (*DsCreateForecastPartitionFilesRequest) GetProduct 

func (x *DsCreateForecastPartitionFilesRequest) GetProduct() *v1alpha1.DataProduct

func (*DsCreateForecastPartitionFilesRequest) GetSecret 

func (x *DsCreateForecastPartitionFilesRequest) GetSecret() map[string][]byte

func (*DsCreateForecastPartitionFilesRequest) GetStudy 

func (x *DsCreateForecastPartitionFilesRequest) GetStudy() *v1alpha12.Study

func (*DsCreateForecastPartitionFilesRequest) GetVersion 

func (x *DsCreateForecastPartitionFilesRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsCreateForecastPartitionFilesRequest) ProtoMessage 

func (*DsCreateForecastPartitionFilesRequest) ProtoMessage()

func (*DsCreateForecastPartitionFilesRequest) ProtoReflect 

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

func (*DsCreateForecastPartitionFilesRequest) Reset 

func (x *DsCreateForecastPartitionFilesRequest) Reset()

func (*DsCreateForecastPartitionFilesRequest) String 

func (x *DsCreateForecastPartitionFilesRequest) String() string

type DsCreateForecastPartitionFilesResponse 

type DsCreateForecastPartitionFilesResponse struct {
	Partitions []*PartitionValues `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateForecastPartitionFilesResponse) Descriptor deprecated 

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

Deprecated: Use DsCreateForecastPartitionFilesResponse.ProtoReflect.Descriptor instead.

func (*DsCreateForecastPartitionFilesResponse) GetPartitions 

func (x *DsCreateForecastPartitionFilesResponse) GetPartitions() []*PartitionValues

func (*DsCreateForecastPartitionFilesResponse) ProtoMessage 

func (*DsCreateForecastPartitionFilesResponse) ProtoMessage()

func (*DsCreateForecastPartitionFilesResponse) ProtoReflect 

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

func (*DsCreateForecastPartitionFilesResponse) Reset 

func (x *DsCreateForecastPartitionFilesResponse) Reset()

func (*DsCreateForecastPartitionFilesResponse) String 

func (x *DsCreateForecastPartitionFilesResponse) String() string

type DsCreateModelProfileRequest 

type DsCreateModelProfileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,5,opt,name=study,proto3" json:"study,omitempty"`
	Model      *v1alpha12.Model             `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,8,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,9,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsCreateModelProfileRequest) Descriptor deprecated 

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

Deprecated: Use DsCreateModelProfileRequest.ProtoReflect.Descriptor instead.

func (*DsCreateModelProfileRequest) GetBucket 

func (x *DsCreateModelProfileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsCreateModelProfileRequest) GetConnection 

func (x *DsCreateModelProfileRequest) GetConnection() *v1alpha11.Connection

func (*DsCreateModelProfileRequest) GetDataset 

func (x *DsCreateModelProfileRequest) GetDataset() *v1alpha1.Dataset

func (*DsCreateModelProfileRequest) GetDatasource 

func (x *DsCreateModelProfileRequest) GetDatasource() *v1alpha1.DataSource

func (*DsCreateModelProfileRequest) GetModel 

func (x *DsCreateModelProfileRequest) GetModel() *v1alpha12.Model

func (*DsCreateModelProfileRequest) GetProduct 

func (x *DsCreateModelProfileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsCreateModelProfileRequest) GetSecret 

func (x *DsCreateModelProfileRequest) GetSecret() map[string][]byte

func (*DsCreateModelProfileRequest) GetStudy 

func (x *DsCreateModelProfileRequest) GetStudy() *v1alpha12.Study

func (*DsCreateModelProfileRequest) GetVersion 

func (x *DsCreateModelProfileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsCreateModelProfileRequest) ProtoMessage 

func (*DsCreateModelProfileRequest) ProtoMessage()

func (*DsCreateModelProfileRequest) ProtoReflect 

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

func (*DsCreateModelProfileRequest) Reset 

func (x *DsCreateModelProfileRequest) Reset()

func (*DsCreateModelProfileRequest) String 

func (x *DsCreateModelProfileRequest) String() string

type DsCreateModelProfileResponse 

type DsCreateModelProfileResponse struct {
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateModelProfileResponse) Descriptor deprecated 

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

Deprecated: Use DsCreateModelProfileResponse.ProtoReflect.Descriptor instead.

func (*DsCreateModelProfileResponse) GetUri 

func (x *DsCreateModelProfileResponse) GetUri() string

func (*DsCreateModelProfileResponse) ProtoMessage 

func (*DsCreateModelProfileResponse) ProtoMessage()

func (*DsCreateModelProfileResponse) ProtoReflect 

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

func (*DsCreateModelProfileResponse) Reset 

func (x *DsCreateModelProfileResponse) Reset()

func (*DsCreateModelProfileResponse) String 

func (x *DsCreateModelProfileResponse) String() string

type DsCreateRecipeProfileRequest 

type DsCreateRecipeProfileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,6,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Recipe     *v1alpha1.Recipe             `protobuf:"bytes,8,opt,name=recipe,proto3" json:"recipe,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateRecipeProfileRequest) Descriptor deprecated 

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

Deprecated: Use DsCreateRecipeProfileRequest.ProtoReflect.Descriptor instead.

func (*DsCreateRecipeProfileRequest) GetBucket 

func (x *DsCreateRecipeProfileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsCreateRecipeProfileRequest) GetConnection 

func (x *DsCreateRecipeProfileRequest) GetConnection() *v1alpha11.Connection

func (*DsCreateRecipeProfileRequest) GetDataset 

func (x *DsCreateRecipeProfileRequest) GetDataset() *v1alpha1.Dataset

func (*DsCreateRecipeProfileRequest) GetDatasource 

func (x *DsCreateRecipeProfileRequest) GetDatasource() *v1alpha1.DataSource

func (*DsCreateRecipeProfileRequest) GetProduct 

func (x *DsCreateRecipeProfileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsCreateRecipeProfileRequest) GetRecipe 

func (x *DsCreateRecipeProfileRequest) GetRecipe() *v1alpha1.Recipe

func (*DsCreateRecipeProfileRequest) GetSecret 

func (x *DsCreateRecipeProfileRequest) GetSecret() map[string][]byte

func (*DsCreateRecipeProfileRequest) GetVersion 

func (x *DsCreateRecipeProfileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsCreateRecipeProfileRequest) ProtoMessage 

func (*DsCreateRecipeProfileRequest) ProtoMessage()

func (*DsCreateRecipeProfileRequest) ProtoReflect 

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

func (*DsCreateRecipeProfileRequest) Reset 

func (x *DsCreateRecipeProfileRequest) Reset()

func (*DsCreateRecipeProfileRequest) String 

func (x *DsCreateRecipeProfileRequest) String() string

type DsCreateRecipeProfileResponse 

type DsCreateRecipeProfileResponse struct {
	Result *v1.TableView `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateRecipeProfileResponse) Descriptor deprecated 

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

Deprecated: Use DsCreateRecipeProfileResponse.ProtoReflect.Descriptor instead.

func (*DsCreateRecipeProfileResponse) GetResult 

func (x *DsCreateRecipeProfileResponse) GetResult() *v1.TableView

func (*DsCreateRecipeProfileResponse) ProtoMessage 

func (*DsCreateRecipeProfileResponse) ProtoMessage()

func (*DsCreateRecipeProfileResponse) ProtoReflect 

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

func (*DsCreateRecipeProfileResponse) Reset 

func (x *DsCreateRecipeProfileResponse) Reset()

func (*DsCreateRecipeProfileResponse) String 

func (x *DsCreateRecipeProfileResponse) String() string

type DsCreateStudyProfileRequest 

type DsCreateStudyProfileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,4,opt,name=study,proto3" json:"study,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,5,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,6,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,7,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Models     []*v1alpha12.Model           `protobuf:"bytes,8,rep,name=models,proto3" json:"models,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsCreateStudyProfileRequest) Descriptor deprecated 

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

Deprecated: Use DsCreateStudyProfileRequest.ProtoReflect.Descriptor instead.

func (*DsCreateStudyProfileRequest) GetBucket 

func (x *DsCreateStudyProfileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsCreateStudyProfileRequest) GetConnection 

func (x *DsCreateStudyProfileRequest) GetConnection() *v1alpha11.Connection

func (*DsCreateStudyProfileRequest) GetDataset 

func (x *DsCreateStudyProfileRequest) GetDataset() *v1alpha1.Dataset

func (*DsCreateStudyProfileRequest) GetDatasource 

func (x *DsCreateStudyProfileRequest) GetDatasource() *v1alpha1.DataSource

func (*DsCreateStudyProfileRequest) GetModels 

func (x *DsCreateStudyProfileRequest) GetModels() []*v1alpha12.Model

func (*DsCreateStudyProfileRequest) GetProduct 

func (x *DsCreateStudyProfileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsCreateStudyProfileRequest) GetSecret 

func (x *DsCreateStudyProfileRequest) GetSecret() map[string][]byte

func (*DsCreateStudyProfileRequest) GetStudy 

func (x *DsCreateStudyProfileRequest) GetStudy() *v1alpha12.Study

func (*DsCreateStudyProfileRequest) GetVersion 

func (x *DsCreateStudyProfileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsCreateStudyProfileRequest) ProtoMessage 

func (*DsCreateStudyProfileRequest) ProtoMessage()

func (*DsCreateStudyProfileRequest) ProtoReflect 

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

func (*DsCreateStudyProfileRequest) Reset 

func (x *DsCreateStudyProfileRequest) Reset()

func (*DsCreateStudyProfileRequest) String 

func (x *DsCreateStudyProfileRequest) String() string

type DsCreateStudyProfileResponse 

type DsCreateStudyProfileResponse struct {
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*DsCreateStudyProfileResponse) Descriptor deprecated 

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

Deprecated: Use DsCreateStudyProfileResponse.ProtoReflect.Descriptor instead.

func (*DsCreateStudyProfileResponse) GetUri 

func (x *DsCreateStudyProfileResponse) GetUri() string

func (*DsCreateStudyProfileResponse) ProtoMessage 

func (*DsCreateStudyProfileResponse) ProtoMessage()

func (*DsCreateStudyProfileResponse) ProtoReflect 

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

func (*DsCreateStudyProfileResponse) Reset 

func (x *DsCreateStudyProfileResponse) Reset()

func (*DsCreateStudyProfileResponse) String 

func (x *DsCreateStudyProfileResponse) String() string

type DsDatasetProfileRequest 

type DsDatasetProfileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,6,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Quick      bool                         `protobuf:"varint,8,opt,name=quick,proto3" json:"quick,omitempty"`
	// contains filtered or unexported fields
}

func (*DsDatasetProfileRequest) Descriptor deprecated 

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

Deprecated: Use DsDatasetProfileRequest.ProtoReflect.Descriptor instead.

func (*DsDatasetProfileRequest) GetBucket 

func (x *DsDatasetProfileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsDatasetProfileRequest) GetConnection 

func (x *DsDatasetProfileRequest) GetConnection() *v1alpha11.Connection

func (*DsDatasetProfileRequest) GetDataset 

func (x *DsDatasetProfileRequest) GetDataset() *v1alpha1.Dataset

func (*DsDatasetProfileRequest) GetDatasource 

func (x *DsDatasetProfileRequest) GetDatasource() *v1alpha1.DataSource

func (*DsDatasetProfileRequest) GetProduct 

func (x *DsDatasetProfileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsDatasetProfileRequest) GetQuick 

func (x *DsDatasetProfileRequest) GetQuick() bool

func (*DsDatasetProfileRequest) GetSecret 

func (x *DsDatasetProfileRequest) GetSecret() map[string][]byte

func (*DsDatasetProfileRequest) GetVersion 

func (x *DsDatasetProfileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsDatasetProfileRequest) ProtoMessage 

func (*DsDatasetProfileRequest) ProtoMessage()

func (*DsDatasetProfileRequest) ProtoReflect 

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

func (*DsDatasetProfileRequest) Reset 

func (x *DsDatasetProfileRequest) Reset()

func (*DsDatasetProfileRequest) String 

func (x *DsDatasetProfileRequest) String() string

type DsDatasetProfileResponse 

type DsDatasetProfileResponse struct {
	Profile *v1.DatasetProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*DsDatasetProfileResponse) Descriptor deprecated 

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

Deprecated: Use DsDatasetProfileResponse.ProtoReflect.Descriptor instead.

func (*DsDatasetProfileResponse) GetProfile 

func (x *DsDatasetProfileResponse) GetProfile() *v1.DatasetProfile

func (*DsDatasetProfileResponse) ProtoMessage 

func (*DsDatasetProfileResponse) ProtoMessage()

func (*DsDatasetProfileResponse) ProtoReflect 

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

func (*DsDatasetProfileResponse) Reset 

func (x *DsDatasetProfileResponse) Reset()

func (*DsDatasetProfileResponse) String 

func (x *DsDatasetProfileResponse) String() string

type DsGenerateDatasetRequest 

type DsGenerateDatasetRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Rows       int32                        `protobuf:"varint,7,opt,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*DsGenerateDatasetRequest) Descriptor deprecated 

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

Deprecated: Use DsGenerateDatasetRequest.ProtoReflect.Descriptor instead.

func (*DsGenerateDatasetRequest) GetBucket 

func (x *DsGenerateDatasetRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsGenerateDatasetRequest) GetConnection 

func (x *DsGenerateDatasetRequest) GetConnection() *v1alpha11.Connection

func (*DsGenerateDatasetRequest) GetDatasource 

func (x *DsGenerateDatasetRequest) GetDatasource() *v1alpha1.DataSource

func (*DsGenerateDatasetRequest) GetProduct 

func (x *DsGenerateDatasetRequest) GetProduct() *v1alpha1.DataProduct

func (*DsGenerateDatasetRequest) GetRows 

func (x *DsGenerateDatasetRequest) GetRows() int32

func (*DsGenerateDatasetRequest) GetSecret 

func (x *DsGenerateDatasetRequest) GetSecret() map[string][]byte

func (*DsGenerateDatasetRequest) GetVersion 

func (x *DsGenerateDatasetRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsGenerateDatasetRequest) ProtoMessage 

func (*DsGenerateDatasetRequest) ProtoMessage()

func (*DsGenerateDatasetRequest) ProtoReflect 

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

func (*DsGenerateDatasetRequest) Reset 

func (x *DsGenerateDatasetRequest) Reset()

func (*DsGenerateDatasetRequest) String 

func (x *DsGenerateDatasetRequest) String() string

type DsGenerateDatasetResponse 

type DsGenerateDatasetResponse struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DsGenerateDatasetResponse) Descriptor deprecated 

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

Deprecated: Use DsGenerateDatasetResponse.ProtoReflect.Descriptor instead.

func (*DsGenerateDatasetResponse) GetKey 

func (x *DsGenerateDatasetResponse) GetKey() string

func (*DsGenerateDatasetResponse) ProtoMessage 

func (*DsGenerateDatasetResponse) ProtoMessage()

func (*DsGenerateDatasetResponse) ProtoReflect 

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

func (*DsGenerateDatasetResponse) Reset 

func (x *DsGenerateDatasetResponse) Reset()

func (*DsGenerateDatasetResponse) String 

func (x *DsGenerateDatasetResponse) String() string

type DsGetMisclassTableViewRequest 

type DsGetMisclassTableViewRequest struct {
	Bucket     *v1alpha11.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection    `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte        `` /* 153-byte string literal not displayed */
	Key        string                   `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DsGetMisclassTableViewRequest) Descriptor deprecated 

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

Deprecated: Use DsGetMisclassTableViewRequest.ProtoReflect.Descriptor instead.

func (*DsGetMisclassTableViewRequest) GetBucket 

func (x *DsGetMisclassTableViewRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsGetMisclassTableViewRequest) GetConnection 

func (x *DsGetMisclassTableViewRequest) GetConnection() *v1alpha11.Connection

func (*DsGetMisclassTableViewRequest) GetKey 

func (x *DsGetMisclassTableViewRequest) GetKey() string

func (*DsGetMisclassTableViewRequest) GetSecret 

func (x *DsGetMisclassTableViewRequest) GetSecret() map[string][]byte

func (*DsGetMisclassTableViewRequest) ProtoMessage 

func (*DsGetMisclassTableViewRequest) ProtoMessage()

func (*DsGetMisclassTableViewRequest) ProtoReflect 

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

func (*DsGetMisclassTableViewRequest) Reset 

func (x *DsGetMisclassTableViewRequest) Reset()

func (*DsGetMisclassTableViewRequest) String 

func (x *DsGetMisclassTableViewRequest) String() string

type DsGetMisclassTableViewResponse 

type DsGetMisclassTableViewResponse struct {
	Tableview *v1.TableView `protobuf:"bytes,1,opt,name=tableview,proto3" json:"tableview,omitempty"`
	// contains filtered or unexported fields
}

func (*DsGetMisclassTableViewResponse) Descriptor deprecated 

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

Deprecated: Use DsGetMisclassTableViewResponse.ProtoReflect.Descriptor instead.

func (*DsGetMisclassTableViewResponse) GetTableview 

func (x *DsGetMisclassTableViewResponse) GetTableview() *v1.TableView

func (*DsGetMisclassTableViewResponse) ProtoMessage 

func (*DsGetMisclassTableViewResponse) ProtoMessage()

func (*DsGetMisclassTableViewResponse) ProtoReflect 

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

func (*DsGetMisclassTableViewResponse) Reset 

func (x *DsGetMisclassTableViewResponse) Reset()

func (*DsGetMisclassTableViewResponse) String 

func (x *DsGetMisclassTableViewResponse) String() string

type DsGetTableViewRequest 

type DsGetTableViewRequest struct {
	Bucket     *v1alpha11.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection    `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Datasource *v1alpha1.DataSourceSpec `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Secret     map[string][]byte        `` /* 153-byte string literal not displayed */
	Key        string                   `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DsGetTableViewRequest) Descriptor deprecated 

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

Deprecated: Use DsGetTableViewRequest.ProtoReflect.Descriptor instead.

func (*DsGetTableViewRequest) GetBucket 

func (x *DsGetTableViewRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsGetTableViewRequest) GetConnection 

func (x *DsGetTableViewRequest) GetConnection() *v1alpha11.Connection

func (*DsGetTableViewRequest) GetDatasource 

func (x *DsGetTableViewRequest) GetDatasource() *v1alpha1.DataSourceSpec

func (*DsGetTableViewRequest) GetKey 

func (x *DsGetTableViewRequest) GetKey() string

func (*DsGetTableViewRequest) GetSecret 

func (x *DsGetTableViewRequest) GetSecret() map[string][]byte

func (*DsGetTableViewRequest) ProtoMessage 

func (*DsGetTableViewRequest) ProtoMessage()

func (*DsGetTableViewRequest) ProtoReflect 

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

func (*DsGetTableViewRequest) Reset 

func (x *DsGetTableViewRequest) Reset()

func (*DsGetTableViewRequest) String 

func (x *DsGetTableViewRequest) String() string

type DsGetTableViewResponse 

type DsGetTableViewResponse struct {
	Tableview *v1.TableView `protobuf:"bytes,1,opt,name=tableview,proto3" json:"tableview,omitempty"`
	// contains filtered or unexported fields
}

func (*DsGetTableViewResponse) Descriptor deprecated 

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

Deprecated: Use DsGetTableViewResponse.ProtoReflect.Descriptor instead.

func (*DsGetTableViewResponse) GetTableview 

func (x *DsGetTableViewResponse) GetTableview() *v1.TableView

func (*DsGetTableViewResponse) ProtoMessage 

func (*DsGetTableViewResponse) ProtoMessage()

func (*DsGetTableViewResponse) ProtoReflect 

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

func (*DsGetTableViewResponse) Reset 

func (x *DsGetTableViewResponse) Reset()

func (*DsGetTableViewResponse) String 

func (x *DsGetTableViewResponse) String() string

type DsInferSchemaRequest 

type DsInferSchemaRequest struct {
	Product    *v1alpha1.DataProduct    `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Bucket     *v1alpha11.VirtualBucket `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection    `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte        `` /* 153-byte string literal not displayed */
	Key        string                   `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DsInferSchemaRequest) Descriptor deprecated 

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

Deprecated: Use DsInferSchemaRequest.ProtoReflect.Descriptor instead.

func (*DsInferSchemaRequest) GetBucket 

func (x *DsInferSchemaRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsInferSchemaRequest) GetConnection 

func (x *DsInferSchemaRequest) GetConnection() *v1alpha11.Connection

func (*DsInferSchemaRequest) GetKey 

func (x *DsInferSchemaRequest) GetKey() string

func (*DsInferSchemaRequest) GetProduct 

func (x *DsInferSchemaRequest) GetProduct() *v1alpha1.DataProduct

func (*DsInferSchemaRequest) GetSecret 

func (x *DsInferSchemaRequest) GetSecret() map[string][]byte

func (*DsInferSchemaRequest) ProtoMessage 

func (*DsInferSchemaRequest) ProtoMessage()

func (*DsInferSchemaRequest) ProtoReflect 

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

func (*DsInferSchemaRequest) Reset 

func (x *DsInferSchemaRequest) Reset()

func (*DsInferSchemaRequest) String 

func (x *DsInferSchemaRequest) String() string

type DsInferSchemaResponse 

type DsInferSchemaResponse struct {
	Profile *v1.DatasetProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

func (*DsInferSchemaResponse) Descriptor deprecated 

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

Deprecated: Use DsInferSchemaResponse.ProtoReflect.Descriptor instead.

func (*DsInferSchemaResponse) GetProfile 

func (x *DsInferSchemaResponse) GetProfile() *v1.DatasetProfile

func (*DsInferSchemaResponse) ProtoMessage 

func (*DsInferSchemaResponse) ProtoMessage()

func (*DsInferSchemaResponse) ProtoReflect 

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

func (*DsInferSchemaResponse) Reset 

func (x *DsInferSchemaResponse) Reset()

func (*DsInferSchemaResponse) String 

func (x *DsInferSchemaResponse) String() string

type DsMergeForecastFileRequest 

type DsMergeForecastFileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,5,opt,name=study,proto3" json:"study,omitempty"`
	Model      *v1alpha12.Model             `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,8,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,9,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

Send the forecast

func (*DsMergeForecastFileRequest) Descriptor deprecated 

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

Deprecated: Use DsMergeForecastFileRequest.ProtoReflect.Descriptor instead.

func (*DsMergeForecastFileRequest) GetBucket 

func (x *DsMergeForecastFileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsMergeForecastFileRequest) GetConnection 

func (x *DsMergeForecastFileRequest) GetConnection() *v1alpha11.Connection

func (*DsMergeForecastFileRequest) GetDataset 

func (x *DsMergeForecastFileRequest) GetDataset() *v1alpha1.Dataset

func (*DsMergeForecastFileRequest) GetDatasource 

func (x *DsMergeForecastFileRequest) GetDatasource() *v1alpha1.DataSource

func (*DsMergeForecastFileRequest) GetModel 

func (x *DsMergeForecastFileRequest) GetModel() *v1alpha12.Model

func (*DsMergeForecastFileRequest) GetProduct 

func (x *DsMergeForecastFileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsMergeForecastFileRequest) GetSecret 

func (x *DsMergeForecastFileRequest) GetSecret() map[string][]byte

func (*DsMergeForecastFileRequest) GetStudy 

func (x *DsMergeForecastFileRequest) GetStudy() *v1alpha12.Study

func (*DsMergeForecastFileRequest) GetVersion 

func (x *DsMergeForecastFileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsMergeForecastFileRequest) ProtoMessage 

func (*DsMergeForecastFileRequest) ProtoMessage()

func (*DsMergeForecastFileRequest) ProtoReflect 

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

func (*DsMergeForecastFileRequest) Reset 

func (x *DsMergeForecastFileRequest) Reset()

func (*DsMergeForecastFileRequest) String 

func (x *DsMergeForecastFileRequest) String() string

type DsMergeForecastFileResponse 

type DsMergeForecastFileResponse struct {
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*DsMergeForecastFileResponse) Descriptor deprecated 

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

Deprecated: Use DsMergeForecastFileResponse.ProtoReflect.Descriptor instead.

func (*DsMergeForecastFileResponse) GetUri 

func (x *DsMergeForecastFileResponse) GetUri() string

func (*DsMergeForecastFileResponse) ProtoMessage 

func (*DsMergeForecastFileResponse) ProtoMessage()

func (*DsMergeForecastFileResponse) ProtoReflect 

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

func (*DsMergeForecastFileResponse) Reset 

func (x *DsMergeForecastFileResponse) Reset()

func (*DsMergeForecastFileResponse) String 

func (x *DsMergeForecastFileResponse) String() string

type DsReadAudioRequest 

type DsReadAudioRequest struct {
	Bucket     *v1alpha11.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection    `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte        `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsReadAudioRequest) Descriptor deprecated 

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

Deprecated: Use DsReadAudioRequest.ProtoReflect.Descriptor instead.

func (*DsReadAudioRequest) GetBucket 

func (x *DsReadAudioRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsReadAudioRequest) GetConnection 

func (x *DsReadAudioRequest) GetConnection() *v1alpha11.Connection

func (*DsReadAudioRequest) GetSecret 

func (x *DsReadAudioRequest) GetSecret() map[string][]byte

func (*DsReadAudioRequest) ProtoMessage 

func (*DsReadAudioRequest) ProtoMessage()

func (*DsReadAudioRequest) ProtoReflect 

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

func (*DsReadAudioRequest) Reset 

func (x *DsReadAudioRequest) Reset()

func (*DsReadAudioRequest) String 

func (x *DsReadAudioRequest) String() string

type DsReadFeatureRequest 

type DsReadFeatureRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,4,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsReadFeatureRequest) Descriptor deprecated 

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

Deprecated: Use DsReadFeatureRequest.ProtoReflect.Descriptor instead.

func (*DsReadFeatureRequest) GetBucket 

func (x *DsReadFeatureRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsReadFeatureRequest) GetConnection 

func (x *DsReadFeatureRequest) GetConnection() *v1alpha11.Connection

func (*DsReadFeatureRequest) GetProduct 

func (x *DsReadFeatureRequest) GetProduct() *v1alpha1.DataProduct

func (*DsReadFeatureRequest) GetSecret 

func (x *DsReadFeatureRequest) GetSecret() map[string][]byte

func (*DsReadFeatureRequest) GetVersion 

func (x *DsReadFeatureRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsReadFeatureRequest) ProtoMessage 

func (*DsReadFeatureRequest) ProtoMessage()

func (*DsReadFeatureRequest) ProtoReflect 

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

func (*DsReadFeatureRequest) Reset 

func (x *DsReadFeatureRequest) Reset()

func (*DsReadFeatureRequest) String 

func (x *DsReadFeatureRequest) String() string

type DsReadFileRequest 

type DsReadFileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsReadFileRequest) Descriptor deprecated 

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

Deprecated: Use DsReadFileRequest.ProtoReflect.Descriptor instead.

func (*DsReadFileRequest) GetBucket 

func (x *DsReadFileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsReadFileRequest) GetConnection 

func (x *DsReadFileRequest) GetConnection() *v1alpha11.Connection

func (*DsReadFileRequest) GetProduct 

func (x *DsReadFileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsReadFileRequest) GetSecret 

func (x *DsReadFileRequest) GetSecret() map[string][]byte

func (*DsReadFileRequest) GetVersion 

func (x *DsReadFileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsReadFileRequest) ProtoMessage 

func (*DsReadFileRequest) ProtoMessage()

func (*DsReadFileRequest) ProtoReflect 

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

func (*DsReadFileRequest) Reset 

func (x *DsReadFileRequest) Reset()

func (*DsReadFileRequest) String 

func (x *DsReadFileRequest) String() string

type DsReadFromStoreResponse 

type DsReadFromStoreResponse struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Result     *v1alpha1.Dataset            `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,4,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsReadFromStoreResponse) Descriptor deprecated 

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

Deprecated: Use DsReadFromStoreResponse.ProtoReflect.Descriptor instead.

func (*DsReadFromStoreResponse) GetBucket 

func (x *DsReadFromStoreResponse) GetBucket() *v1alpha11.VirtualBucket

func (*DsReadFromStoreResponse) GetConnection 

func (x *DsReadFromStoreResponse) GetConnection() *v1alpha11.Connection

func (*DsReadFromStoreResponse) GetProduct 

func (x *DsReadFromStoreResponse) GetProduct() *v1alpha1.DataProduct

func (*DsReadFromStoreResponse) GetResult 

func (x *DsReadFromStoreResponse) GetResult() *v1alpha1.Dataset

func (*DsReadFromStoreResponse) GetSecret 

func (x *DsReadFromStoreResponse) GetSecret() map[string][]byte

func (*DsReadFromStoreResponse) GetVersion 

func (x *DsReadFromStoreResponse) GetVersion() *v1alpha1.DataProductVersion

func (*DsReadFromStoreResponse) ProtoMessage 

func (*DsReadFromStoreResponse) ProtoMessage()

func (*DsReadFromStoreResponse) ProtoReflect 

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

func (*DsReadFromStoreResponse) Reset 

func (x *DsReadFromStoreResponse) Reset()

func (*DsReadFromStoreResponse) String 

func (x *DsReadFromStoreResponse) String() string

type DsReadTextCorpusRequest 

type DsReadTextCorpusRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsReadTextCorpusRequest) Descriptor deprecated 

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

Deprecated: Use DsReadTextCorpusRequest.ProtoReflect.Descriptor instead.

func (*DsReadTextCorpusRequest) GetBucket 

func (x *DsReadTextCorpusRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsReadTextCorpusRequest) GetConnection 

func (x *DsReadTextCorpusRequest) GetConnection() *v1alpha11.Connection

func (*DsReadTextCorpusRequest) GetProduct 

func (x *DsReadTextCorpusRequest) GetProduct() *v1alpha1.DataProduct

func (*DsReadTextCorpusRequest) GetSecret 

func (x *DsReadTextCorpusRequest) GetSecret() map[string][]byte

func (*DsReadTextCorpusRequest) GetVersion 

func (x *DsReadTextCorpusRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsReadTextCorpusRequest) ProtoMessage 

func (*DsReadTextCorpusRequest) ProtoMessage()

func (*DsReadTextCorpusRequest) ProtoReflect 

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

func (*DsReadTextCorpusRequest) Reset 

func (x *DsReadTextCorpusRequest) Reset()

func (*DsReadTextCorpusRequest) String 

func (x *DsReadTextCorpusRequest) String() string

type DsRunDataPipelineRequest 

type DsRunDataPipelineRequest struct {
	Pipeline *v1alpha1.DataPipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*DsRunDataPipelineRequest) Descriptor deprecated 

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

Deprecated: Use DsRunDataPipelineRequest.ProtoReflect.Descriptor instead.

func (*DsRunDataPipelineRequest) GetPipeline 

func (x *DsRunDataPipelineRequest) GetPipeline() *v1alpha1.DataPipeline

func (*DsRunDataPipelineRequest) ProtoMessage 

func (*DsRunDataPipelineRequest) ProtoMessage()

func (*DsRunDataPipelineRequest) ProtoReflect 

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

func (*DsRunDataPipelineRequest) Reset 

func (x *DsRunDataPipelineRequest) Reset()

func (*DsRunDataPipelineRequest) String 

func (x *DsRunDataPipelineRequest) String() string

type DsRunDataPipelineResponse 

type DsRunDataPipelineResponse struct {
	Result *v1alpha1.Dataset `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DsRunDataPipelineResponse) Descriptor deprecated 

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

Deprecated: Use DsRunDataPipelineResponse.ProtoReflect.Descriptor instead.

func (*DsRunDataPipelineResponse) GetResult 

func (x *DsRunDataPipelineResponse) GetResult() *v1alpha1.Dataset

func (*DsRunDataPipelineResponse) ProtoMessage 

func (*DsRunDataPipelineResponse) ProtoMessage()

func (*DsRunDataPipelineResponse) ProtoReflect 

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

func (*DsRunDataPipelineResponse) Reset 

func (x *DsRunDataPipelineResponse) Reset()

func (*DsRunDataPipelineResponse) String 

func (x *DsRunDataPipelineResponse) String() string

type DsRunRecipeRequest 

type DsRunRecipeRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,6,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Recipe     *v1alpha1.Recipe             `protobuf:"bytes,8,opt,name=recipe,proto3" json:"recipe,omitempty"`
	Reciperun  *v1alpha1.RecipeRun          `protobuf:"bytes,9,opt,name=reciperun,proto3" json:"reciperun,omitempty"`
	// contains filtered or unexported fields
}

func (*DsRunRecipeRequest) Descriptor deprecated 

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

Deprecated: Use DsRunRecipeRequest.ProtoReflect.Descriptor instead.

func (*DsRunRecipeRequest) GetBucket 

func (x *DsRunRecipeRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsRunRecipeRequest) GetConnection 

func (x *DsRunRecipeRequest) GetConnection() *v1alpha11.Connection

func (*DsRunRecipeRequest) GetDataset 

func (x *DsRunRecipeRequest) GetDataset() *v1alpha1.Dataset

func (*DsRunRecipeRequest) GetDatasource 

func (x *DsRunRecipeRequest) GetDatasource() *v1alpha1.DataSource

func (*DsRunRecipeRequest) GetProduct 

func (x *DsRunRecipeRequest) GetProduct() *v1alpha1.DataProduct

func (*DsRunRecipeRequest) GetRecipe 

func (x *DsRunRecipeRequest) GetRecipe() *v1alpha1.Recipe

func (*DsRunRecipeRequest) GetReciperun 

func (x *DsRunRecipeRequest) GetReciperun() *v1alpha1.RecipeRun

func (*DsRunRecipeRequest) GetSecret 

func (x *DsRunRecipeRequest) GetSecret() map[string][]byte

func (*DsRunRecipeRequest) GetVersion 

func (x *DsRunRecipeRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsRunRecipeRequest) ProtoMessage 

func (*DsRunRecipeRequest) ProtoMessage()

func (*DsRunRecipeRequest) ProtoReflect 

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

func (*DsRunRecipeRequest) Reset 

func (x *DsRunRecipeRequest) Reset()

func (*DsRunRecipeRequest) String 

func (x *DsRunRecipeRequest) String() string

type DsRunRecipeResponse 

type DsRunRecipeResponse struct {
	Result *v1alpha1.Recipe `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DsRunRecipeResponse) Descriptor deprecated 

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

Deprecated: Use DsRunRecipeResponse.ProtoReflect.Descriptor instead.

func (*DsRunRecipeResponse) GetResult 

func (x *DsRunRecipeResponse) GetResult() *v1alpha1.Recipe

func (*DsRunRecipeResponse) ProtoMessage 

func (*DsRunRecipeResponse) ProtoMessage()

func (*DsRunRecipeResponse) ProtoReflect 

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

func (*DsRunRecipeResponse) Reset 

func (x *DsRunRecipeResponse) Reset()

func (*DsRunRecipeResponse) String 

func (x *DsRunRecipeResponse) String() string

type DsShutdownRequest 

type DsShutdownRequest struct {
	// contains filtered or unexported fields
}

func (*DsShutdownRequest) Descriptor deprecated 

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

Deprecated: Use DsShutdownRequest.ProtoReflect.Descriptor instead.

func (*DsShutdownRequest) ProtoMessage 

func (*DsShutdownRequest) ProtoMessage()

func (*DsShutdownRequest) ProtoReflect 

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

func (*DsShutdownRequest) Reset 

func (x *DsShutdownRequest) Reset()

func (*DsShutdownRequest) String 

func (x *DsShutdownRequest) String() string

type DsShutdownResponse 

type DsShutdownResponse struct {
	// contains filtered or unexported fields
}

func (*DsShutdownResponse) Descriptor deprecated 

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

Deprecated: Use DsShutdownResponse.ProtoReflect.Descriptor instead.

func (*DsShutdownResponse) ProtoMessage 

func (*DsShutdownResponse) ProtoMessage()

func (*DsShutdownResponse) ProtoReflect 

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

func (*DsShutdownResponse) Reset 

func (x *DsShutdownResponse) Reset()

func (*DsShutdownResponse) String 

func (x *DsShutdownResponse) String() string

type DsSplitDatasetRequest 

type DsSplitDatasetRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,4,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,5,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,6,opt,name=study,proto3" json:"study,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,7,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsSplitDatasetRequest) Descriptor deprecated 

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

Deprecated: Use DsSplitDatasetRequest.ProtoReflect.Descriptor instead.

func (*DsSplitDatasetRequest) GetBucket 

func (x *DsSplitDatasetRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsSplitDatasetRequest) GetConnection 

func (x *DsSplitDatasetRequest) GetConnection() *v1alpha11.Connection

func (*DsSplitDatasetRequest) GetDataset 

func (x *DsSplitDatasetRequest) GetDataset() *v1alpha1.Dataset

func (*DsSplitDatasetRequest) GetDatasource 

func (x *DsSplitDatasetRequest) GetDatasource() *v1alpha1.DataSource

func (*DsSplitDatasetRequest) GetProduct 

func (x *DsSplitDatasetRequest) GetProduct() *v1alpha1.DataProduct

func (*DsSplitDatasetRequest) GetSecret 

func (x *DsSplitDatasetRequest) GetSecret() map[string][]byte

func (*DsSplitDatasetRequest) GetStudy 

func (x *DsSplitDatasetRequest) GetStudy() *v1alpha12.Study

func (*DsSplitDatasetRequest) GetVersion 

func (x *DsSplitDatasetRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsSplitDatasetRequest) ProtoMessage 

func (*DsSplitDatasetRequest) ProtoMessage()

func (*DsSplitDatasetRequest) ProtoReflect 

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

func (*DsSplitDatasetRequest) Reset 

func (x *DsSplitDatasetRequest) Reset()

func (*DsSplitDatasetRequest) String 

func (x *DsSplitDatasetRequest) String() string

type DsSplitDatasetResponse 

type DsSplitDatasetResponse struct {
	// contains filtered or unexported fields
}

func (*DsSplitDatasetResponse) Descriptor deprecated 

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

Deprecated: Use DsSplitDatasetResponse.ProtoReflect.Descriptor instead.

func (*DsSplitDatasetResponse) ProtoMessage 

func (*DsSplitDatasetResponse) ProtoMessage()

func (*DsSplitDatasetResponse) ProtoReflect 

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

func (*DsSplitDatasetResponse) Reset 

func (x *DsSplitDatasetResponse) Reset()

func (*DsSplitDatasetResponse) String 

func (x *DsSplitDatasetResponse) String() string

type DsSplitDatasetToRungsRequest 

type DsSplitDatasetToRungsRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,4,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,5,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,6,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	Rungs      int32                        `protobuf:"varint,8,opt,name=rungs,proto3" json:"rungs,omitempty"`
	// contains filtered or unexported fields
}

func (*DsSplitDatasetToRungsRequest) Descriptor deprecated 

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

Deprecated: Use DsSplitDatasetToRungsRequest.ProtoReflect.Descriptor instead.

func (*DsSplitDatasetToRungsRequest) GetBucket 

func (x *DsSplitDatasetToRungsRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsSplitDatasetToRungsRequest) GetConnection 

func (x *DsSplitDatasetToRungsRequest) GetConnection() *v1alpha11.Connection

func (*DsSplitDatasetToRungsRequest) GetDataset 

func (x *DsSplitDatasetToRungsRequest) GetDataset() *v1alpha1.Dataset

func (*DsSplitDatasetToRungsRequest) GetDatasource 

func (x *DsSplitDatasetToRungsRequest) GetDatasource() *v1alpha1.DataSource

func (*DsSplitDatasetToRungsRequest) GetProduct 

func (x *DsSplitDatasetToRungsRequest) GetProduct() *v1alpha1.DataProduct

func (*DsSplitDatasetToRungsRequest) GetRungs 

func (x *DsSplitDatasetToRungsRequest) GetRungs() int32

func (*DsSplitDatasetToRungsRequest) GetSecret 

func (x *DsSplitDatasetToRungsRequest) GetSecret() map[string][]byte

func (*DsSplitDatasetToRungsRequest) GetVersion 

func (x *DsSplitDatasetToRungsRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsSplitDatasetToRungsRequest) ProtoMessage 

func (*DsSplitDatasetToRungsRequest) ProtoMessage()

func (*DsSplitDatasetToRungsRequest) ProtoReflect 

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

func (*DsSplitDatasetToRungsRequest) Reset 

func (x *DsSplitDatasetToRungsRequest) Reset()

func (*DsSplitDatasetToRungsRequest) String 

func (x *DsSplitDatasetToRungsRequest) String() string

type DsSplitDatasetToRungsResponse 

type DsSplitDatasetToRungsResponse struct {
	// contains filtered or unexported fields
}

func (*DsSplitDatasetToRungsResponse) Descriptor deprecated 

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

Deprecated: Use DsSplitDatasetToRungsResponse.ProtoReflect.Descriptor instead.

func (*DsSplitDatasetToRungsResponse) ProtoMessage 

func (*DsSplitDatasetToRungsResponse) ProtoMessage()

func (*DsSplitDatasetToRungsResponse) ProtoReflect 

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

func (*DsSplitDatasetToRungsResponse) Reset 

func (x *DsSplitDatasetToRungsResponse) Reset()

func (*DsSplitDatasetToRungsResponse) String 

func (x *DsSplitDatasetToRungsResponse) String() string

type DsValidateDatasetRequest 

type DsValidateDatasetRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,3,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,4,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=connection,proto3" json:"connection,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,6,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Validate a dataset

func (*DsValidateDatasetRequest) Descriptor deprecated 

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

Deprecated: Use DsValidateDatasetRequest.ProtoReflect.Descriptor instead.

func (*DsValidateDatasetRequest) GetBucket 

func (x *DsValidateDatasetRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsValidateDatasetRequest) GetConnection 

func (x *DsValidateDatasetRequest) GetConnection() *v1alpha11.Connection

func (*DsValidateDatasetRequest) GetDataset 

func (x *DsValidateDatasetRequest) GetDataset() *v1alpha1.Dataset

func (*DsValidateDatasetRequest) GetDatasource 

func (x *DsValidateDatasetRequest) GetDatasource() *v1alpha1.DataSource

func (*DsValidateDatasetRequest) GetProduct 

func (x *DsValidateDatasetRequest) GetProduct() *v1alpha1.DataProduct

func (*DsValidateDatasetRequest) GetSecret 

func (x *DsValidateDatasetRequest) GetSecret() map[string][]byte

func (*DsValidateDatasetRequest) GetVersion 

func (x *DsValidateDatasetRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsValidateDatasetRequest) ProtoMessage 

func (*DsValidateDatasetRequest) ProtoMessage()

func (*DsValidateDatasetRequest) ProtoReflect 

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

func (*DsValidateDatasetRequest) Reset 

func (x *DsValidateDatasetRequest) Reset()

func (*DsValidateDatasetRequest) String 

func (x *DsValidateDatasetRequest) String() string

type DsValidateDatasetResponse 

type DsValidateDatasetResponse struct {
	Errors []string `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*DsValidateDatasetResponse) Descriptor deprecated 

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

Deprecated: Use DsValidateDatasetResponse.ProtoReflect.Descriptor instead.

func (*DsValidateDatasetResponse) GetErrors 

func (x *DsValidateDatasetResponse) GetErrors() []string

func (*DsValidateDatasetResponse) ProtoMessage 

func (*DsValidateDatasetResponse) ProtoMessage()

func (*DsValidateDatasetResponse) ProtoReflect 

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

func (*DsValidateDatasetResponse) Reset 

func (x *DsValidateDatasetResponse) Reset()

func (*DsValidateDatasetResponse) String 

func (x *DsValidateDatasetResponse) String() string

type DsWriteFileRequest 

type DsWriteFileRequest struct {
	Product    *v1alpha1.DataProduct        `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Version    *v1alpha1.DataProductVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Content    *v1alpha1.Dataset            `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Bucket     *v1alpha11.VirtualBucket     `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,6,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsWriteFileRequest) Descriptor deprecated 

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

Deprecated: Use DsWriteFileRequest.ProtoReflect.Descriptor instead.

func (*DsWriteFileRequest) GetBucket 

func (x *DsWriteFileRequest) GetBucket() *v1alpha11.VirtualBucket

func (*DsWriteFileRequest) GetConnection 

func (x *DsWriteFileRequest) GetConnection() *v1alpha11.Connection

func (*DsWriteFileRequest) GetContent 

func (x *DsWriteFileRequest) GetContent() *v1alpha1.Dataset

func (*DsWriteFileRequest) GetProduct 

func (x *DsWriteFileRequest) GetProduct() *v1alpha1.DataProduct

func (*DsWriteFileRequest) GetSecret 

func (x *DsWriteFileRequest) GetSecret() map[string][]byte

func (*DsWriteFileRequest) GetVersion 

func (x *DsWriteFileRequest) GetVersion() *v1alpha1.DataProductVersion

func (*DsWriteFileRequest) ProtoMessage 

func (*DsWriteFileRequest) ProtoMessage()

func (*DsWriteFileRequest) ProtoReflect 

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

func (*DsWriteFileRequest) Reset 

func (x *DsWriteFileRequest) Reset()

func (*DsWriteFileRequest) String 

func (x *DsWriteFileRequest) String() string

type PartitionValues 

type PartitionValues struct {
	Name   string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`     // the name of the partition
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` // the partition values.
	// contains filtered or unexported fields
}

a distinct set of the values in the partition

func (*PartitionValues) Descriptor deprecated 

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

Deprecated: Use PartitionValues.ProtoReflect.Descriptor instead.

func (*PartitionValues) GetName 

func (x *PartitionValues) GetName() string

func (*PartitionValues) GetValues 

func (x *PartitionValues) GetValues() []string

func (*PartitionValues) ProtoMessage 

func (*PartitionValues) ProtoMessage()

func (*PartitionValues) ProtoReflect 

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

func (*PartitionValues) Reset 

func (x *PartitionValues) Reset()

func (*PartitionValues) String 

func (x *PartitionValues) String() string

type TellModelRequest 

type TellModelRequest struct {
	Model *v1alpha12.Model `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*TellModelRequest) Descriptor deprecated 

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

Deprecated: Use TellModelRequest.ProtoReflect.Descriptor instead.

func (*TellModelRequest) GetModel 

func (x *TellModelRequest) GetModel() *v1alpha12.Model

func (*TellModelRequest) ProtoMessage 

func (*TellModelRequest) ProtoMessage()

func (*TellModelRequest) ProtoReflect 

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

func (*TellModelRequest) Reset 

func (x *TellModelRequest) Reset()

func (*TellModelRequest) String 

func (x *TellModelRequest) String() string

type TellModelResponse 

type TellModelResponse struct {
	// contains filtered or unexported fields
}

func (*TellModelResponse) Descriptor deprecated 

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

Deprecated: Use TellModelResponse.ProtoReflect.Descriptor instead.

func (*TellModelResponse) ProtoMessage 

func (*TellModelResponse) ProtoMessage()

func (*TellModelResponse) ProtoReflect 

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

func (*TellModelResponse) Reset 

func (x *TellModelResponse) Reset()

func (*TellModelResponse) String 

func (x *TellModelResponse) String() string

type UnimplementedDataServiceServer 

type UnimplementedDataServiceServer struct {
}

UnimplementedDataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataServiceServer) AskModel 

func (*UnimplementedDataServiceServer) AskModel(context.Context, *AskModelRequest) (*AskModelResponse, error)

func (*UnimplementedDataServiceServer) CreateColumnProfile 

func (*UnimplementedDataServiceServer) CreateColumnProfile(context.Context, *DsCreateColumnProfileRequest) (*DsCreateColumnProfileResponse, error)

func (*UnimplementedDataServiceServer) CreateDatasetProfile 

func (*UnimplementedDataServiceServer) CreateDatasetProfile(context.Context, *DsCreateDatasetProfileRequest) (*DsCreateDatasetProfileResponse, error)

func (*UnimplementedDataServiceServer) CreateDatasetReport 

func (*UnimplementedDataServiceServer) CreateDatasetReport(context.Context, *CreateDatasetReportRequest) (*CreateReportResponse, error)

func (*UnimplementedDataServiceServer) CreateForecastReport 

func (*UnimplementedDataServiceServer) CreateForecastReport(context.Context, *CreateForecastReportRequest) (*CreateReportResponse, error)

func (*UnimplementedDataServiceServer) CreateModelProfile 

func (*UnimplementedDataServiceServer) CreateModelProfile(context.Context, *DsCreateModelProfileRequest) (*DsCreateModelProfileResponse, error)

func (*UnimplementedDataServiceServer) CreateModelReport 

func (*UnimplementedDataServiceServer) CreateModelReport(context.Context, *CreateModelReportRequest) (*CreateReportResponse, error)

func (*UnimplementedDataServiceServer) CreateRecipeProfile 

func (*UnimplementedDataServiceServer) CreateRecipeProfile(context.Context, *DsCreateRecipeProfileRequest) (*DsCreateRecipeProfileResponse, error)

func (*UnimplementedDataServiceServer) CreateStudyProfile 

func (*UnimplementedDataServiceServer) CreateStudyProfile(context.Context, *DsCreateStudyProfileRequest) (*DsCreateStudyProfileResponse, error)

func (*UnimplementedDataServiceServer) CreateStudyReport 

func (*UnimplementedDataServiceServer) CreateStudyReport(context.Context, *CreateStudyReportRequest) (*CreateReportResponse, error)

func (*UnimplementedDataServiceServer) GenerateDataset 

func (*UnimplementedDataServiceServer) GenerateDataset(context.Context, *DsGenerateDatasetRequest) (*DsGenerateDatasetResponse, error)

func (*UnimplementedDataServiceServer) GetMisclassTableView 

func (*UnimplementedDataServiceServer) GetMisclassTableView(context.Context, *DsGetMisclassTableViewRequest) (*DsGetMisclassTableViewResponse, error)

func (*UnimplementedDataServiceServer) GetTableView 

func (*UnimplementedDataServiceServer) GetTableView(context.Context, *DsGetTableViewRequest) (*DsGetTableViewResponse, error)

func (*UnimplementedDataServiceServer) InferSchema 

func (*UnimplementedDataServiceServer) InferSchema(context.Context, *DsInferSchemaRequest) (*DsInferSchemaResponse, error)

func (*UnimplementedDataServiceServer) MergeForecastFile 

func (*UnimplementedDataServiceServer) MergeForecastFile(context.Context, *DsMergeForecastFileRequest) (*DsMergeForecastFileResponse, error)

func (*UnimplementedDataServiceServer) PartitionForecastFile 

func (*UnimplementedDataServiceServer) PartitionForecastFile(context.Context, *DsCreateForecastPartitionFilesRequest) (*DsCreateForecastPartitionFilesResponse, error)

func (*UnimplementedDataServiceServer) ReadAudio 

func (*UnimplementedDataServiceServer) ReadAudio(context.Context, *DsReadAudioRequest) (*DsReadFromStoreResponse, error)

func (*UnimplementedDataServiceServer) ReadFeature 

func (*UnimplementedDataServiceServer) ReadFeature(context.Context, *DsReadFeatureRequest) (*DsReadFromStoreResponse, error)

func (*UnimplementedDataServiceServer) ReadFile 

func (*UnimplementedDataServiceServer) ReadFile(context.Context, *DsReadFileRequest) (*DsReadFromStoreResponse, error)

func (*UnimplementedDataServiceServer) RunDataPipeline 

func (*UnimplementedDataServiceServer) RunDataPipeline(context.Context, *DsRunDataPipelineRequest) (*DsRunDataPipelineResponse, error)

func (*UnimplementedDataServiceServer) RunRecipe 

func (*UnimplementedDataServiceServer) RunRecipe(context.Context, *DsRunRecipeRequest) (*DsRunRecipeResponse, error)

func (*UnimplementedDataServiceServer) ShutDown 

func (*UnimplementedDataServiceServer) ShutDown(context.Context, *DsShutdownRequest) (*DsShutdownResponse, error)

func (*UnimplementedDataServiceServer) SplitDataset 

func (*UnimplementedDataServiceServer) SplitDataset(context.Context, *DsSplitDatasetRequest) (*DsSplitDatasetResponse, error)

func (*UnimplementedDataServiceServer) SplitDatasetToRungs 

func (*UnimplementedDataServiceServer) SplitDatasetToRungs(context.Context, *DsSplitDatasetToRungsRequest) (*DsSplitDatasetToRungsResponse, error)

func (*UnimplementedDataServiceServer) TellModel 

func (*UnimplementedDataServiceServer) TellModel(context.Context, *TellModelRequest) (*TellModelResponse, error)

func (*UnimplementedDataServiceServer) ValidateDataset 

func (*UnimplementedDataServiceServer) ValidateDataset(context.Context, *DsValidateDatasetRequest) (*DsValidateDatasetResponse, error)

func (*UnimplementedDataServiceServer) WriteFile 

func (*UnimplementedDataServiceServer) WriteFile(context.Context, *DsWriteFileRequest) (*DsReadFromStoreResponse, error)

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.