v1

package
v0.4.861 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.data.v1.DataService",
	HandlerType: (*DataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReadFile",
			Handler:    _DataService_ReadFile_Handler,
		},
		{
			MethodName: "ReadFeature",
			Handler:    _DataService_ReadFeature_Handler,
		},
		{
			MethodName: "ReadAudio",
			Handler:    _DataService_ReadAudio_Handler,
		},
		{
			MethodName: "RunDataPipeline",
			Handler:    _DataService_RunDataPipeline_Handler,
		},
		{
			MethodName: "RunRecipe",
			Handler:    _DataService_RunRecipe_Handler,
		},
		{
			MethodName: "WriteFile",
			Handler:    _DataService_WriteFile_Handler,
		},
		{
			MethodName: "ValidateDataset",
			Handler:    _DataService_ValidateDataset_Handler,
		},
		{
			MethodName: "GenerateDataset",
			Handler:    _DataService_GenerateDataset_Handler,
		},
		{
			MethodName: "SplitDataset",
			Handler:    _DataService_SplitDataset_Handler,
		},
		{
			MethodName: "CreateColumnProfile",
			Handler:    _DataService_CreateColumnProfile_Handler,
		},
		{
			MethodName: "InferSchema",
			Handler:    _DataService_InferSchema_Handler,
		},
		{
			MethodName: "GetTableView",
			Handler:    _DataService_GetTableView_Handler,
		},
		{
			MethodName: "SplitDatasetToRungs",
			Handler:    _DataService_SplitDatasetToRungs_Handler,
		},
		{
			MethodName: "CreateDatasetProfile",
			Handler:    _DataService_CreateDatasetProfile_Handler,
		},
		{
			MethodName: "CreateModelProfile",
			Handler:    _DataService_CreateModelProfile_Handler,
		},
		{
			MethodName: "CreateStudyProfile",
			Handler:    _DataService_CreateStudyProfile_Handler,
		},
		{
			MethodName: "CreateRecipeProfile",
			Handler:    _DataService_CreateRecipeProfile_Handler,
		},
		{
			MethodName: "CreateModelReport",
			Handler:    _DataService_CreateModelReport_Handler,
		},
		{
			MethodName: "CreateStudyReport",
			Handler:    _DataService_CreateStudyReport_Handler,
		},
		{
			MethodName: "CreateDatasetReport",
			Handler:    _DataService_CreateDatasetReport_Handler,
		},
		{
			MethodName: "CreateForecastReport",
			Handler:    _DataService_CreateForecastReport_Handler,
		},
		{
			MethodName: "CreateSummaryReport",
			Handler:    _DataService_CreateSummaryReport_Handler,
		},
		{
			MethodName: "AskFE",
			Handler:    _DataService_AskFE_Handler,
		},
		{
			MethodName: "AskBaseline",
			Handler:    _DataService_AskBaseline_Handler,
		},
		{
			MethodName: "AskEnsemble",
			Handler:    _DataService_AskEnsemble_Handler,
		},
		{
			MethodName: "AskModel",
			Handler:    _DataService_AskModel_Handler,
		},
		{
			MethodName: "AskAllModelsForTask",
			Handler:    _DataService_AskAllModelsForTask_Handler,
		},
		{
			MethodName: "TellPartialModel",
			Handler:    _DataService_TellPartialModel_Handler,
		},
		{
			MethodName: "TellModel",
			Handler:    _DataService_TellModel_Handler,
		},
		{
			MethodName: "PartitionForecastFile",
			Handler:    _DataService_PartitionForecastFile_Handler,
		},
		{
			MethodName: "MergeForecastFile",
			Handler:    _DataService_MergeForecastFile_Handler,
		},
		{
			MethodName: "ValidateModel",
			Handler:    _DataService_ValidateModel_Handler,
		},
		{
			MethodName: "DsTestConnection",
			Handler:    _DataService_DsTestConnection_Handler,
		},
		{
			MethodName: "ShutDown",
			Handler:    _DataService_ShutDown_Handler,
		},
		{
			MethodName: "StudyEnded",
			Handler:    _DataService_StudyEnded_Handler,
		},
		{
			MethodName: "SaveOptimizerDB",
			Handler:    _DataService_SaveOptimizerDB_Handler,
		},
		{
			MethodName: "GetDatabases",
			Handler:    _DataService_GetDatabases_Handler,
		},
		{
			MethodName: "GetTables",
			Handler:    _DataService_GetTables_Handler,
		},
		{
			MethodName: "ExecuteSql",
			Handler:    _DataService_ExecuteSql_Handler,
		},
		{
			MethodName: "Snapshot",
			Handler:    _DataService_Snapshot_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/data/v1/data.proto",
}

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

View Source 
var File_github_com_metaprov_modelaapi_services_data_v1_data_proto protoreflect.FileDescriptor

Functions

func RegisterDataServiceServer 

func RegisterDataServiceServer(s grpc.ServiceRegistrar, srv DataServiceServer)

Types

type AskAllModelsForTaskRequest 

type AskAllModelsForTaskRequest 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"`
	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"`
	Budget     int32                        `protobuf:"varint,6,opt,name=budget,proto3" json:"budget,omitempty"`
	Task       string                       `protobuf:"bytes,7,opt,name=task,proto3" json:"task,omitempty"` // use default HP
	// contains filtered or unexported fields
}

func (*AskAllModelsForTaskRequest) Descriptor deprecated 

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

Deprecated: Use AskAllModelsForTaskRequest.ProtoReflect.Descriptor instead.

func (*AskAllModelsForTaskRequest) GetBudget 

func (x *AskAllModelsForTaskRequest) GetBudget() int32

func (*AskAllModelsForTaskRequest) GetDataset 

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

func (*AskAllModelsForTaskRequest) GetDatasource 

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

func (*AskAllModelsForTaskRequest) GetProduct 

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

func (*AskAllModelsForTaskRequest) GetStudy 

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

func (*AskAllModelsForTaskRequest) GetTask 

func (x *AskAllModelsForTaskRequest) GetTask() string

func (*AskAllModelsForTaskRequest) GetVersion 

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

func (*AskAllModelsForTaskRequest) ProtoMessage 

func (*AskAllModelsForTaskRequest) ProtoMessage()

func (*AskAllModelsForTaskRequest) ProtoReflect 

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

func (*AskAllModelsForTaskRequest) Reset 

func (x *AskAllModelsForTaskRequest) Reset()

func (*AskAllModelsForTaskRequest) String 

func (x *AskAllModelsForTaskRequest) String() string

type AskAllModelsForTaskResponse 

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

func (*AskAllModelsForTaskResponse) Descriptor deprecated 

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

Deprecated: Use AskAllModelsForTaskResponse.ProtoReflect.Descriptor instead.

func (*AskAllModelsForTaskResponse) GetModel 

func (x *AskAllModelsForTaskResponse) GetModel() []*v1alpha12.Model

func (*AskAllModelsForTaskResponse) ProtoMessage 

func (*AskAllModelsForTaskResponse) ProtoMessage()

func (*AskAllModelsForTaskResponse) ProtoReflect 

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

func (*AskAllModelsForTaskResponse) Reset 

func (x *AskAllModelsForTaskResponse) Reset()

func (*AskAllModelsForTaskResponse) String 

func (x *AskAllModelsForTaskResponse) String() string

type AskBaselineRequest 

type AskBaselineRequest 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"`
	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"`
	Algnames   []string                     `protobuf:"bytes,6,rep,name=algnames,proto3" json:"algnames,omitempty"` // ask for a list of algorithms
	All        bool                         `protobuf:"varint,7,opt,name=all,proto3" json:"all,omitempty"`          // ask for all algorithms
	// contains filtered or unexported fields
}

func (*AskBaselineRequest) Descriptor deprecated 

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

Deprecated: Use AskBaselineRequest.ProtoReflect.Descriptor instead.

func (*AskBaselineRequest) GetAlgnames 

func (x *AskBaselineRequest) GetAlgnames() []string

func (*AskBaselineRequest) GetAll 

func (x *AskBaselineRequest) GetAll() bool

func (*AskBaselineRequest) GetDataset 

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

func (*AskBaselineRequest) GetDatasource 

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

func (*AskBaselineRequest) GetProduct 

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

func (*AskBaselineRequest) GetStudy 

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

func (*AskBaselineRequest) GetVersion 

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

func (*AskBaselineRequest) ProtoMessage 

func (*AskBaselineRequest) ProtoMessage()

func (*AskBaselineRequest) ProtoReflect 

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

func (*AskBaselineRequest) Reset 

func (x *AskBaselineRequest) Reset()

func (*AskBaselineRequest) String 

func (x *AskBaselineRequest) String() string

type AskBaselineResponse 

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

func (*AskBaselineResponse) Descriptor deprecated 

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

Deprecated: Use AskBaselineResponse.ProtoReflect.Descriptor instead.

func (*AskBaselineResponse) GetModel 

func (x *AskBaselineResponse) GetModel() []*v1alpha12.Model

func (*AskBaselineResponse) ProtoMessage 

func (*AskBaselineResponse) ProtoMessage()

func (*AskBaselineResponse) ProtoReflect 

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

func (*AskBaselineResponse) Reset 

func (x *AskBaselineResponse) Reset()

func (*AskBaselineResponse) String 

func (x *AskBaselineResponse) String() string

type AskEnsembleRequest 

type AskEnsembleRequest 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"`
	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"`
	Models     []*v1alpha12.Model           `protobuf:"bytes,6,rep,name=models,proto3" json:"models,omitempty"`
	// contains filtered or unexported fields
}

func (*AskEnsembleRequest) Descriptor deprecated 

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

Deprecated: Use AskEnsembleRequest.ProtoReflect.Descriptor instead.

func (*AskEnsembleRequest) GetDataset 

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

func (*AskEnsembleRequest) GetDatasource 

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

func (*AskEnsembleRequest) GetModels 

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

func (*AskEnsembleRequest) GetProduct 

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

func (*AskEnsembleRequest) GetStudy 

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

func (*AskEnsembleRequest) GetVersion 

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

func (*AskEnsembleRequest) ProtoMessage 

func (*AskEnsembleRequest) ProtoMessage()

func (*AskEnsembleRequest) ProtoReflect 

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

func (*AskEnsembleRequest) Reset 

func (x *AskEnsembleRequest) Reset()

func (*AskEnsembleRequest) String 

func (x *AskEnsembleRequest) String() string

type AskEnsembleResponse 

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

Return one or more ensembles

func (*AskEnsembleResponse) Descriptor deprecated 

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

Deprecated: Use AskEnsembleResponse.ProtoReflect.Descriptor instead.

func (*AskEnsembleResponse) GetModel 

func (x *AskEnsembleResponse) GetModel() []*v1alpha12.Model

func (*AskEnsembleResponse) ProtoMessage 

func (*AskEnsembleResponse) ProtoMessage()

func (*AskEnsembleResponse) ProtoReflect 

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

func (*AskEnsembleResponse) Reset 

func (x *AskEnsembleResponse) Reset()

func (*AskEnsembleResponse) String 

func (x *AskEnsembleResponse) String() string

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"`
	Study      *v1alpha12.Study             `protobuf:"bytes,3,opt,name=study,proto3" json:"study,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"`
	Budget     int32                        `protobuf:"varint,6,opt,name=budget,proto3" json:"budget,omitempty"`
	DefaultHP  bool                         `protobuf:"varint,7,opt,name=defaultHP,proto3" json:"defaultHP,omitempty"` // use default HP
	Algorithm  string                       `protobuf:"bytes,8,opt,name=algorithm,proto3" json:"algorithm,omitempty"`  // ask for a specific algorithm.
	// contains filtered or unexported fields
}

func (*AskModelRequest) Descriptor deprecated 

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

Deprecated: Use AskModelRequest.ProtoReflect.Descriptor instead.

func (*AskModelRequest) GetAlgorithm 

func (x *AskModelRequest) GetAlgorithm() string

func (*AskModelRequest) GetBudget 

func (x *AskModelRequest) GetBudget() int32

func (*AskModelRequest) GetDataset 

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

func (*AskModelRequest) GetDatasource 

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

func (*AskModelRequest) GetDefaultHP 

func (x *AskModelRequest) GetDefaultHP() bool

func (*AskModelRequest) GetProduct 

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

func (*AskModelRequest) GetStudy 

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

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 {
	Model *v1alpha12.Model `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*AskModelResponse) Descriptor deprecated 

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

Deprecated: Use AskModelResponse.ProtoReflect.Descriptor instead.

func (*AskModelResponse) GetModel 

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

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 CreateSummaryReportRequest 

type CreateSummaryReportRequest 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,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 (*CreateSummaryReportRequest) Descriptor deprecated 

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

Deprecated: Use CreateSummaryReportRequest.ProtoReflect.Descriptor instead.

func (*CreateSummaryReportRequest) GetBucket 

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

func (*CreateSummaryReportRequest) GetConnection 

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

func (*CreateSummaryReportRequest) GetProduct 

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

func (*CreateSummaryReportRequest) GetReport 

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

func (*CreateSummaryReportRequest) GetSecret 

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

func (*CreateSummaryReportRequest) GetVersion 

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

func (*CreateSummaryReportRequest) ProtoMessage 

func (*CreateSummaryReportRequest) ProtoMessage()

func (*CreateSummaryReportRequest) ProtoReflect 

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

func (*CreateSummaryReportRequest) Reset 

func (x *CreateSummaryReportRequest) Reset()

func (*CreateSummaryReportRequest) String 

func (x *CreateSummaryReportRequest) 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)
	// 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)
	CreateSummaryReport(ctx context.Context, in *CreateSummaryReportRequest, opts ...grpc.CallOption) (*CreateReportResponse, error)
	// sample feature engineering pipeline
	AskFE(ctx context.Context, in *AskModelRequest, opts ...grpc.CallOption) (*AskModelResponse, error)
	AskBaseline(ctx context.Context, in *AskBaselineRequest, opts ...grpc.CallOption) (*AskBaselineResponse, error)
	AskEnsemble(ctx context.Context, in *AskEnsembleRequest, opts ...grpc.CallOption) (*AskEnsembleResponse, error)
	// sample model randomly for a given budget
	AskModel(ctx context.Context, in *AskModelRequest, opts ...grpc.CallOption) (*AskModelResponse, error)
	// sample model randomly for a given budget
	AskAllModelsForTask(ctx context.Context, in *AskAllModelsForTaskRequest, opts ...grpc.CallOption) (*AskAllModelsForTaskResponse, error)
	// If a model is a partial model (sample < 100%)
	TellPartialModel(ctx context.Context, in *TellModelRequest, opts ...grpc.CallOption) (*TellModelResponse, 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)
	// Check for data drift
	ValidateModel(ctx context.Context, in *ValidateModelRequest, opts ...grpc.CallOption) (*ValidateModelResponse, error)
	// test connection from python presepective
	DsTestConnection(ctx context.Context, in *DsTestConnectionRequest, opts ...grpc.CallOption) (*DsTestConnectionResponse, error)
	ShutDown(ctx context.Context, in *DsShutdownRequest, opts ...grpc.CallOption) (*DsShutdownResponse, error)
	StudyEnded(ctx context.Context, in *DsStudyEndedRequest, opts ...grpc.CallOption) (*DsStudyEndedResponse, error)
	SaveOptimizerDB(ctx context.Context, in *SaveOptimizerDBRequest, opts ...grpc.CallOption) (*SaveOptimizerDBResponse, error)
	GetDatabases(ctx context.Context, in *DsGetDatabasesRequest, opts ...grpc.CallOption) (*DsGetDatabasesResponse, error)
	GetTables(ctx context.Context, in *DsGetTablesRequest, opts ...grpc.CallOption) (*DsGetTablesResponse, error)
	ExecuteSql(ctx context.Context, in *DsExecuteSqlRequest, opts ...grpc.CallOption) (*DsExecuteSqlResponse, error)
	Snapshot(ctx context.Context, in *DsSnapshotRequest, opts ...grpc.CallOption) (*DsSnapshotResponse, error)
}

DataServiceClient is the client API for DataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func 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)
	// 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)
	CreateSummaryReport(context.Context, *CreateSummaryReportRequest) (*CreateReportResponse, error)
	// sample feature engineering pipeline
	AskFE(context.Context, *AskModelRequest) (*AskModelResponse, error)
	AskBaseline(context.Context, *AskBaselineRequest) (*AskBaselineResponse, error)
	AskEnsemble(context.Context, *AskEnsembleRequest) (*AskEnsembleResponse, error)
	// sample model randomly for a given budget
	AskModel(context.Context, *AskModelRequest) (*AskModelResponse, error)
	// sample model randomly for a given budget
	AskAllModelsForTask(context.Context, *AskAllModelsForTaskRequest) (*AskAllModelsForTaskResponse, error)
	// If a model is a partial model (sample < 100%)
	TellPartialModel(context.Context, *TellModelRequest) (*TellModelResponse, 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)
	// Check for data drift
	ValidateModel(context.Context, *ValidateModelRequest) (*ValidateModelResponse, error)
	// test connection from python presepective
	DsTestConnection(context.Context, *DsTestConnectionRequest) (*DsTestConnectionResponse, error)
	ShutDown(context.Context, *DsShutdownRequest) (*DsShutdownResponse, error)
	StudyEnded(context.Context, *DsStudyEndedRequest) (*DsStudyEndedResponse, error)
	SaveOptimizerDB(context.Context, *SaveOptimizerDBRequest) (*SaveOptimizerDBResponse, error)
	GetDatabases(context.Context, *DsGetDatabasesRequest) (*DsGetDatabasesResponse, error)
	GetTables(context.Context, *DsGetTablesRequest) (*DsGetTablesResponse, error)
	ExecuteSql(context.Context, *DsExecuteSqlRequest) (*DsExecuteSqlResponse, error)
	Snapshot(context.Context, *DsSnapshotRequest) (*DsSnapshotResponse, error)
	// contains filtered or unexported methods
}

DataServiceServer is the server API for DataService service. All implementations must embed UnimplementedDataServiceServer for forward compatibility

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 DsExecuteSqlRequest 

type DsExecuteSqlRequest struct {
	Connection   *v1alpha11.Connection `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret       map[string][]byte     `` /* 153-byte string literal not displayed */
	DatabaseName string                `protobuf:"bytes,3,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	Sql          string                `protobuf:"bytes,4,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*DsExecuteSqlRequest) Descriptor deprecated 

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

Deprecated: Use DsExecuteSqlRequest.ProtoReflect.Descriptor instead.

func (*DsExecuteSqlRequest) GetConnection 

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

func (*DsExecuteSqlRequest) GetDatabaseName 

func (x *DsExecuteSqlRequest) GetDatabaseName() string

func (*DsExecuteSqlRequest) GetSecret 

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

func (*DsExecuteSqlRequest) GetSql 

func (x *DsExecuteSqlRequest) GetSql() string

func (*DsExecuteSqlRequest) ProtoMessage 

func (*DsExecuteSqlRequest) ProtoMessage()

func (*DsExecuteSqlRequest) ProtoReflect 

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

func (*DsExecuteSqlRequest) Reset 

func (x *DsExecuteSqlRequest) Reset()

func (*DsExecuteSqlRequest) String 

func (x *DsExecuteSqlRequest) String() string

type DsExecuteSqlResponse 

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

func (*DsExecuteSqlResponse) Descriptor deprecated 

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

Deprecated: Use DsExecuteSqlResponse.ProtoReflect.Descriptor instead.

func (*DsExecuteSqlResponse) GetTableview 

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

func (*DsExecuteSqlResponse) ProtoMessage 

func (*DsExecuteSqlResponse) ProtoMessage()

func (*DsExecuteSqlResponse) ProtoReflect 

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

func (*DsExecuteSqlResponse) Reset 

func (x *DsExecuteSqlResponse) Reset()

func (*DsExecuteSqlResponse) String 

func (x *DsExecuteSqlResponse) 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 DsGetDatabasesRequest 

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

func (*DsGetDatabasesRequest) Descriptor deprecated 

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

Deprecated: Use DsGetDatabasesRequest.ProtoReflect.Descriptor instead.

func (*DsGetDatabasesRequest) GetConnection 

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

func (*DsGetDatabasesRequest) GetSecret 

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

func (*DsGetDatabasesRequest) ProtoMessage 

func (*DsGetDatabasesRequest) ProtoMessage()

func (*DsGetDatabasesRequest) ProtoReflect 

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

func (*DsGetDatabasesRequest) Reset 

func (x *DsGetDatabasesRequest) Reset()

func (*DsGetDatabasesRequest) String 

func (x *DsGetDatabasesRequest) String() string

type DsGetDatabasesResponse 

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

func (*DsGetDatabasesResponse) Descriptor deprecated 

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

Deprecated: Use DsGetDatabasesResponse.ProtoReflect.Descriptor instead.

func (*DsGetDatabasesResponse) GetDatabases 

func (x *DsGetDatabasesResponse) GetDatabases() []string

func (*DsGetDatabasesResponse) ProtoMessage 

func (*DsGetDatabasesResponse) ProtoMessage()

func (*DsGetDatabasesResponse) ProtoReflect 

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

func (*DsGetDatabasesResponse) Reset 

func (x *DsGetDatabasesResponse) Reset()

func (*DsGetDatabasesResponse) String 

func (x *DsGetDatabasesResponse) String() string

type DsGetTableViewRequest 

type DsGetTableViewRequest struct {
	Bucket     *v1alpha11.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Flatfile   *v1alpha1.CsvFileSpec    `protobuf:"bytes,2,opt,name=flatfile,proto3" json:"flatfile,omitempty"`
	Location   *v1alpha1.DataLocation   `protobuf:"bytes,3,opt,name=location,proto3" json:"location,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 (*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) GetFlatfile 

func (x *DsGetTableViewRequest) GetFlatfile() *v1alpha1.CsvFileSpec

func (*DsGetTableViewRequest) GetLocation 

func (x *DsGetTableViewRequest) GetLocation() *v1alpha1.DataLocation

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 DsGetTablesRequest 

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

func (*DsGetTablesRequest) Descriptor deprecated 

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

Deprecated: Use DsGetTablesRequest.ProtoReflect.Descriptor instead.

func (*DsGetTablesRequest) GetConnection 

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

func (*DsGetTablesRequest) GetDatabaseName 

func (x *DsGetTablesRequest) GetDatabaseName() string

func (*DsGetTablesRequest) GetSecret 

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

func (*DsGetTablesRequest) ProtoMessage 

func (*DsGetTablesRequest) ProtoMessage()

func (*DsGetTablesRequest) ProtoReflect 

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

func (*DsGetTablesRequest) Reset 

func (x *DsGetTablesRequest) Reset()

func (*DsGetTablesRequest) String 

func (x *DsGetTablesRequest) String() string

type DsGetTablesResponse 

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

func (*DsGetTablesResponse) Descriptor deprecated 

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

Deprecated: Use DsGetTablesResponse.ProtoReflect.Descriptor instead.

func (*DsGetTablesResponse) GetTables 

func (x *DsGetTablesResponse) GetTables() []string

func (*DsGetTablesResponse) ProtoMessage 

func (*DsGetTablesResponse) ProtoMessage()

func (*DsGetTablesResponse) ProtoReflect 

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

func (*DsGetTablesResponse) Reset 

func (x *DsGetTablesResponse) Reset()

func (*DsGetTablesResponse) String 

func (x *DsGetTablesResponse) String() string

type DsInferSchemaRequest 

type DsInferSchemaRequest struct {
	Bucket     *v1alpha11.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Location   *v1alpha1.DataLocation   `protobuf:"bytes,2,opt,name=location,proto3" json:"location,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"`
	Secret     map[string][]byte        `` /* 153-byte string literal not displayed */
	// 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) GetDatasource 

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

func (*DsInferSchemaRequest) GetLocation 

func (x *DsInferSchemaRequest) GetLocation() *v1alpha1.DataLocation

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 DsSnapshotRequest 

type DsSnapshotRequest 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"`
	Dbconnection      *v1alpha11.Connection        `protobuf:"bytes,5,opt,name=dbconnection,proto3" json:"dbconnection,omitempty"`
	Dbsecret          map[string][]byte            `` /* 157-byte string literal not displayed */
	Storageconnection *v1alpha11.Connection        `protobuf:"bytes,7,opt,name=storageconnection,proto3" json:"storageconnection,omitempty"`
	Storagesecret     map[string][]byte            `` /* 167-byte string literal not displayed */
	Bucket            *v1alpha11.VirtualBucket     `protobuf:"bytes,9,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key               string                       `protobuf:"bytes,10,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DsSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use DsSnapshotRequest.ProtoReflect.Descriptor instead.

func (*DsSnapshotRequest) GetBucket 

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

func (*DsSnapshotRequest) GetDataset 

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

func (*DsSnapshotRequest) GetDatasource 

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

func (*DsSnapshotRequest) GetDbconnection 

func (x *DsSnapshotRequest) GetDbconnection() *v1alpha11.Connection

func (*DsSnapshotRequest) GetDbsecret 

func (x *DsSnapshotRequest) GetDbsecret() map[string][]byte

func (*DsSnapshotRequest) GetKey 

func (x *DsSnapshotRequest) GetKey() string

func (*DsSnapshotRequest) GetProduct 

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

func (*DsSnapshotRequest) GetStorageconnection 

func (x *DsSnapshotRequest) GetStorageconnection() *v1alpha11.Connection

func (*DsSnapshotRequest) GetStoragesecret 

func (x *DsSnapshotRequest) GetStoragesecret() map[string][]byte

func (*DsSnapshotRequest) GetVersion 

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

func (*DsSnapshotRequest) ProtoMessage 

func (*DsSnapshotRequest) ProtoMessage()

func (*DsSnapshotRequest) ProtoReflect 

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

func (*DsSnapshotRequest) Reset 

func (x *DsSnapshotRequest) Reset()

func (*DsSnapshotRequest) String 

func (x *DsSnapshotRequest) String() string

type DsSnapshotResponse 

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

func (*DsSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use DsSnapshotResponse.ProtoReflect.Descriptor instead.

func (*DsSnapshotResponse) ProtoMessage 

func (*DsSnapshotResponse) ProtoMessage()

func (*DsSnapshotResponse) ProtoReflect 

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

func (*DsSnapshotResponse) Reset 

func (x *DsSnapshotResponse) Reset()

func (*DsSnapshotResponse) String 

func (x *DsSnapshotResponse) 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 */
	TrainingDataset *v1alpha1.Dataset            `protobuf:"bytes,9,opt,name=trainingDataset,proto3" json:"trainingDataset,omitempty"`
	TestingDataset  *v1alpha1.Dataset            `protobuf:"bytes,10,opt,name=testingDataset,proto3" json:"testingDataset,omitempty"`
	// 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) GetTestingDataset added in v0.4.587 

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

func (*DsSplitDatasetRequest) GetTrainingDataset added in v0.4.587 

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

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 {
	Training       int32  `protobuf:"varint,1,opt,name=training,proto3" json:"training,omitempty"`
	Testing        int32  `protobuf:"varint,2,opt,name=testing,proto3" json:"testing,omitempty"`
	Validation     int32  `protobuf:"varint,3,opt,name=validation,proto3" json:"validation,omitempty"`
	TrainingHash   string `protobuf:"bytes,4,opt,name=training_hash,json=trainingHash,proto3" json:"training_hash,omitempty"`
	TestingHash    string `protobuf:"bytes,5,opt,name=testing_hash,json=testingHash,proto3" json:"testing_hash,omitempty"`
	ValidationHash string `protobuf:"bytes,6,opt,name=validation_hash,json=validationHash,proto3" json:"validation_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*DsSplitDatasetResponse) Descriptor deprecated 

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

Deprecated: Use DsSplitDatasetResponse.ProtoReflect.Descriptor instead.

func (*DsSplitDatasetResponse) GetTesting 

func (x *DsSplitDatasetResponse) GetTesting() int32

func (*DsSplitDatasetResponse) GetTestingHash 

func (x *DsSplitDatasetResponse) GetTestingHash() string

func (*DsSplitDatasetResponse) GetTraining 

func (x *DsSplitDatasetResponse) GetTraining() int32

func (*DsSplitDatasetResponse) GetTrainingHash 

func (x *DsSplitDatasetResponse) GetTrainingHash() string

func (*DsSplitDatasetResponse) GetValidation 

func (x *DsSplitDatasetResponse) GetValidation() int32

func (*DsSplitDatasetResponse) GetValidationHash 

func (x *DsSplitDatasetResponse) GetValidationHash() string

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 DsStudyEndedRequest 

type DsStudyEndedRequest 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"`
	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"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DsStudyEndedRequest) Descriptor deprecated 

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

Deprecated: Use DsStudyEndedRequest.ProtoReflect.Descriptor instead.

func (*DsStudyEndedRequest) GetBucket 

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

func (*DsStudyEndedRequest) GetConnection 

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

func (*DsStudyEndedRequest) GetDataset 

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

func (*DsStudyEndedRequest) GetDatasource 

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

func (*DsStudyEndedRequest) GetProduct 

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

func (*DsStudyEndedRequest) GetSecret 

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

func (*DsStudyEndedRequest) GetStudy 

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

func (*DsStudyEndedRequest) GetVersion 

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

func (*DsStudyEndedRequest) ProtoMessage 

func (*DsStudyEndedRequest) ProtoMessage()

func (*DsStudyEndedRequest) ProtoReflect 

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

func (*DsStudyEndedRequest) Reset 

func (x *DsStudyEndedRequest) Reset()

func (*DsStudyEndedRequest) String 

func (x *DsStudyEndedRequest) String() string

type DsStudyEndedResponse 

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

func (*DsStudyEndedResponse) Descriptor deprecated 

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

Deprecated: Use DsStudyEndedResponse.ProtoReflect.Descriptor instead.

func (*DsStudyEndedResponse) ProtoMessage 

func (*DsStudyEndedResponse) ProtoMessage()

func (*DsStudyEndedResponse) ProtoReflect 

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

func (*DsStudyEndedResponse) Reset 

func (x *DsStudyEndedResponse) Reset()

func (*DsStudyEndedResponse) String 

func (x *DsStudyEndedResponse) String() string

type DsTestConnectionRequest 

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

func (*DsTestConnectionRequest) Descriptor deprecated 

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

Deprecated: Use DsTestConnectionRequest.ProtoReflect.Descriptor instead.

func (*DsTestConnectionRequest) GetBucket 

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

func (*DsTestConnectionRequest) GetConnection 

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

func (*DsTestConnectionRequest) GetSecret 

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

func (*DsTestConnectionRequest) ProtoMessage 

func (*DsTestConnectionRequest) ProtoMessage()

func (*DsTestConnectionRequest) ProtoReflect 

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

func (*DsTestConnectionRequest) Reset 

func (x *DsTestConnectionRequest) Reset()

func (*DsTestConnectionRequest) String 

func (x *DsTestConnectionRequest) String() string

type DsTestConnectionResponse 

type DsTestConnectionResponse struct {
	Status bool   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*DsTestConnectionResponse) Descriptor deprecated 

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

Deprecated: Use DsTestConnectionResponse.ProtoReflect.Descriptor instead.

func (*DsTestConnectionResponse) GetMsg 

func (x *DsTestConnectionResponse) GetMsg() string

func (*DsTestConnectionResponse) GetStatus 

func (x *DsTestConnectionResponse) GetStatus() bool

func (*DsTestConnectionResponse) ProtoMessage 

func (*DsTestConnectionResponse) ProtoMessage()

func (*DsTestConnectionResponse) ProtoReflect 

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

func (*DsTestConnectionResponse) Reset 

func (x *DsTestConnectionResponse) Reset()

func (*DsTestConnectionResponse) String 

func (x *DsTestConnectionResponse) 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 {
	Result []*v1alpha1.DataValidationResult `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DsValidateDatasetResponse) Descriptor deprecated 

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

Deprecated: Use DsValidateDatasetResponse.ProtoReflect.Descriptor instead.

func (*DsValidateDatasetResponse) GetResult 

func (x *DsValidateDatasetResponse) GetResult() []*v1alpha1.DataValidationResult

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 SaveOptimizerDBRequest 

type SaveOptimizerDBRequest 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"`
	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"`
	Secret     map[string][]byte            `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SaveOptimizerDBRequest) Descriptor deprecated 

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

Deprecated: Use SaveOptimizerDBRequest.ProtoReflect.Descriptor instead.

func (*SaveOptimizerDBRequest) GetBucket 

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

func (*SaveOptimizerDBRequest) GetConnection 

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

func (*SaveOptimizerDBRequest) GetDataset 

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

func (*SaveOptimizerDBRequest) GetDatasource 

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

func (*SaveOptimizerDBRequest) GetProduct 

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

func (*SaveOptimizerDBRequest) GetSecret 

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

func (*SaveOptimizerDBRequest) GetStudy 

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

func (*SaveOptimizerDBRequest) GetVersion 

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

func (*SaveOptimizerDBRequest) ProtoMessage 

func (*SaveOptimizerDBRequest) ProtoMessage()

func (*SaveOptimizerDBRequest) ProtoReflect 

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

func (*SaveOptimizerDBRequest) Reset 

func (x *SaveOptimizerDBRequest) Reset()

func (*SaveOptimizerDBRequest) String 

func (x *SaveOptimizerDBRequest) String() string

type SaveOptimizerDBResponse 

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

func (*SaveOptimizerDBResponse) Descriptor deprecated 

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

Deprecated: Use SaveOptimizerDBResponse.ProtoReflect.Descriptor instead.

func (*SaveOptimizerDBResponse) ProtoMessage 

func (*SaveOptimizerDBResponse) ProtoMessage()

func (*SaveOptimizerDBResponse) ProtoReflect 

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

func (*SaveOptimizerDBResponse) Reset 

func (x *SaveOptimizerDBResponse) Reset()

func (*SaveOptimizerDBResponse) String 

func (x *SaveOptimizerDBResponse) String() string

type TellModelRequest 

type TellModelRequest 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"`
	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"`
	Model      *v1alpha12.Model             `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Failed     bool                         `protobuf:"varint,7,opt,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

func (*TellModelRequest) Descriptor deprecated 

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

Deprecated: Use TellModelRequest.ProtoReflect.Descriptor instead.

func (*TellModelRequest) GetDataset 

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

func (*TellModelRequest) GetDatasource 

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

func (*TellModelRequest) GetFailed added in v0.4.764 

func (x *TellModelRequest) GetFailed() bool

func (*TellModelRequest) GetModel 

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

func (*TellModelRequest) GetProduct 

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

func (*TellModelRequest) GetStudy 

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

func (*TellModelRequest) GetVersion 

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

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 {
	Pruned bool `protobuf:"varint,1,opt,name=pruned,proto3" json:"pruned,omitempty"`
	// contains filtered or unexported fields
}

func (*TellModelResponse) Descriptor deprecated 

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

Deprecated: Use TellModelResponse.ProtoReflect.Descriptor instead.

func (*TellModelResponse) GetPruned added in v0.4.764 

func (x *TellModelResponse) GetPruned() bool

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 must be embedded to have forward compatible implementations.

func (UnimplementedDataServiceServer) AskAllModelsForTask 

func (UnimplementedDataServiceServer) AskAllModelsForTask(context.Context, *AskAllModelsForTaskRequest) (*AskAllModelsForTaskResponse, error)

func (UnimplementedDataServiceServer) AskBaseline 

func (UnimplementedDataServiceServer) AskBaseline(context.Context, *AskBaselineRequest) (*AskBaselineResponse, error)

func (UnimplementedDataServiceServer) AskEnsemble 

func (UnimplementedDataServiceServer) AskEnsemble(context.Context, *AskEnsembleRequest) (*AskEnsembleResponse, error)

func (UnimplementedDataServiceServer) AskFE 

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

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) CreateSummaryReport 

func (UnimplementedDataServiceServer) CreateSummaryReport(context.Context, *CreateSummaryReportRequest) (*CreateReportResponse, error)

func (UnimplementedDataServiceServer) DsTestConnection 

func (UnimplementedDataServiceServer) DsTestConnection(context.Context, *DsTestConnectionRequest) (*DsTestConnectionResponse, error)

func (UnimplementedDataServiceServer) ExecuteSql 

func (UnimplementedDataServiceServer) ExecuteSql(context.Context, *DsExecuteSqlRequest) (*DsExecuteSqlResponse, error)

func (UnimplementedDataServiceServer) GenerateDataset 

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

func (UnimplementedDataServiceServer) GetDatabases 

func (UnimplementedDataServiceServer) GetDatabases(context.Context, *DsGetDatabasesRequest) (*DsGetDatabasesResponse, error)

func (UnimplementedDataServiceServer) GetTableView 

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

func (UnimplementedDataServiceServer) GetTables 

func (UnimplementedDataServiceServer) GetTables(context.Context, *DsGetTablesRequest) (*DsGetTablesResponse, 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) SaveOptimizerDB 

func (UnimplementedDataServiceServer) SaveOptimizerDB(context.Context, *SaveOptimizerDBRequest) (*SaveOptimizerDBResponse, error)

func (UnimplementedDataServiceServer) ShutDown 

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

func (UnimplementedDataServiceServer) Snapshot 

func (UnimplementedDataServiceServer) Snapshot(context.Context, *DsSnapshotRequest) (*DsSnapshotResponse, 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) StudyEnded 

func (UnimplementedDataServiceServer) StudyEnded(context.Context, *DsStudyEndedRequest) (*DsStudyEndedResponse, error)

func (UnimplementedDataServiceServer) TellModel 

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

func (UnimplementedDataServiceServer) TellPartialModel added in v0.4.766 

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

func (UnimplementedDataServiceServer) ValidateDataset 

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

func (UnimplementedDataServiceServer) ValidateModel 

func (UnimplementedDataServiceServer) ValidateModel(context.Context, *ValidateModelRequest) (*ValidateModelResponse, error)

func (UnimplementedDataServiceServer) WriteFile 

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

type UnsafeDataServiceServer added in v0.4.687 

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

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

type ValidateModelRequest 

type ValidateModelRequest 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"`
	Predictor  *v1alpha13.Predictor         `protobuf:"bytes,7,opt,name=predictor,proto3" json:"predictor,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 (*ValidateModelRequest) Descriptor deprecated 

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

Deprecated: Use ValidateModelRequest.ProtoReflect.Descriptor instead.

func (*ValidateModelRequest) GetBucket 

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

func (*ValidateModelRequest) GetConnection 

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

func (*ValidateModelRequest) GetDataset 

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

func (*ValidateModelRequest) GetDatasource 

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

func (*ValidateModelRequest) GetModel 

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

func (*ValidateModelRequest) GetPredictor 

func (x *ValidateModelRequest) GetPredictor() *v1alpha13.Predictor

func (*ValidateModelRequest) GetProduct 

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

func (*ValidateModelRequest) GetSecret 

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

func (*ValidateModelRequest) GetStudy 

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

func (*ValidateModelRequest) GetVersion 

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

func (*ValidateModelRequest) ProtoMessage 

func (*ValidateModelRequest) ProtoMessage()

func (*ValidateModelRequest) ProtoReflect 

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

func (*ValidateModelRequest) Reset 

func (x *ValidateModelRequest) Reset()

func (*ValidateModelRequest) String 

func (x *ValidateModelRequest) String() string

type ValidateModelResponse 

type ValidateModelResponse struct {
	Result []*v1alpha12.ModelValidationResult `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateModelResponse) Descriptor deprecated 

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

Deprecated: Use ValidateModelResponse.ProtoReflect.Descriptor instead.

func (*ValidateModelResponse) GetResult 

func (x *ValidateModelResponse) GetResult() []*v1alpha12.ModelValidationResult

func (*ValidateModelResponse) ProtoMessage 

func (*ValidateModelResponse) ProtoMessage()

func (*ValidateModelResponse) ProtoReflect 

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

func (*ValidateModelResponse) Reset 

func (x *ValidateModelResponse) Reset()

func (*ValidateModelResponse) String 

func (x *ValidateModelResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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