v1

package
v0.5.530 Latest Latest
Warning

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

Go to latest
Published: Dec 26, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_github_com_metaprov_modelaapi_services_trainerd_v1_trainerd_proto protoreflect.FileDescriptor
View Source
var TrainerdService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.trainerd.v1.TrainerdService",
	HandlerType: (*TrainerdServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Train",
			Handler:    _TrainerdService_Train_Handler,
		},
		{
			MethodName: "Explain",
			Handler:    _TrainerdService_Explain_Handler,
		},
		{
			MethodName: "Forecast",
			Handler:    _TrainerdService_Forecast_Handler,
		},
		{
			MethodName: "Test",
			Handler:    _TrainerdService_Test_Handler,
		},
		{
			MethodName: "TrainEnsemble",
			Handler:    _TrainerdService_TrainEnsemble_Handler,
		},
		{
			MethodName: "TrainDriftDetector",
			Handler:    _TrainerdService_TrainDriftDetector_Handler,
		},
		{
			MethodName: "TestEnsemble",
			Handler:    _TrainerdService_TestEnsemble_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _TrainerdService_Shutdown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/trainerd/v1/trainerd.proto",
}

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

Functions

func RegisterTrainerdServiceServer

func RegisterTrainerdServiceServer(s grpc.ServiceRegistrar, srv TrainerdServiceServer)

Types

type CompileRequest

type CompileRequest 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"`
	Model      *v1alpha12.Model             `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,6,opt,name=study,proto3" json:"study,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,7,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,8,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,9,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CompileRequest) Descriptor deprecated

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

Deprecated: Use CompileRequest.ProtoReflect.Descriptor instead.

func (*CompileRequest) GetBucket

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

func (*CompileRequest) GetConnection

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

func (*CompileRequest) GetDataset

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

func (*CompileRequest) GetDatasource

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

func (*CompileRequest) GetModel

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

func (*CompileRequest) GetProduct

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

func (*CompileRequest) GetSecret

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

func (*CompileRequest) GetStudy

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

func (*CompileRequest) GetVersion

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

func (*CompileRequest) ProtoMessage

func (*CompileRequest) ProtoMessage()

func (*CompileRequest) ProtoReflect

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

func (*CompileRequest) Reset

func (x *CompileRequest) Reset()

func (*CompileRequest) String

func (x *CompileRequest) String() string

type CompileResponse

type CompileResponse struct {

	// The location in the bucket of the trained bin model
	CompiledModelUri string `protobuf:"bytes,1,opt,name=compiledModelUri,proto3" json:"compiledModelUri,omitempty"`
	// contains filtered or unexported fields
}

func (*CompileResponse) Descriptor deprecated

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

Deprecated: Use CompileResponse.ProtoReflect.Descriptor instead.

func (*CompileResponse) GetCompiledModelUri

func (x *CompileResponse) GetCompiledModelUri() string

func (*CompileResponse) ProtoMessage

func (*CompileResponse) ProtoMessage()

func (*CompileResponse) ProtoReflect

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

func (*CompileResponse) Reset

func (x *CompileResponse) Reset()

func (*CompileResponse) String

func (x *CompileResponse) String() string

type ExplainRequest

type ExplainRequest 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"`
	Model      *v1alpha12.Model             `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,6,opt,name=study,proto3" json:"study,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,7,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,8,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,9,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 154-byte string literal not displayed */
	Group      bool                         `protobuf:"varint,11,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainRequest) Descriptor deprecated

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

Deprecated: Use ExplainRequest.ProtoReflect.Descriptor instead.

func (*ExplainRequest) GetBucket

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

func (*ExplainRequest) GetConnection

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

func (*ExplainRequest) GetDataset

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

func (*ExplainRequest) GetDatasource

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

func (*ExplainRequest) GetGroup added in v0.5.198

func (x *ExplainRequest) GetGroup() bool

func (*ExplainRequest) GetModel

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

func (*ExplainRequest) GetProduct

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

func (*ExplainRequest) GetSecret

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

func (*ExplainRequest) GetStudy

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

func (*ExplainRequest) GetVersion

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

func (*ExplainRequest) ProtoMessage

func (*ExplainRequest) ProtoMessage()

func (*ExplainRequest) ProtoReflect

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

func (*ExplainRequest) Reset

func (x *ExplainRequest) Reset()

func (*ExplainRequest) String

func (x *ExplainRequest) String() string

type ExplainResponse

type ExplainResponse struct {

	// The location in the bucket of the trained bin model
	ExplainerUri string `protobuf:"bytes,1,opt,name=explainerUri,proto3" json:"explainerUri,omitempty"`
	// The location in the bucket of the cloud manifest.
	TrainShapValuesUri string `protobuf:"bytes,2,opt,name=trainShapValuesUri,proto3" json:"trainShapValuesUri,omitempty"`
	// The location in the bucket of the logs.
	TestShapValuesUri string `protobuf:"bytes,3,opt,name=testShapValuesUri,proto3" json:"testShapValuesUri,omitempty"`
	// feature importance
	ShapFeaturesImportance map[string]float32 `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExplainResponse) Descriptor deprecated

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

Deprecated: Use ExplainResponse.ProtoReflect.Descriptor instead.

func (*ExplainResponse) GetExplainerUri added in v0.4.397

func (x *ExplainResponse) GetExplainerUri() string

func (*ExplainResponse) GetShapFeaturesImportance added in v0.4.397

func (x *ExplainResponse) GetShapFeaturesImportance() map[string]float32

func (*ExplainResponse) GetTestShapValuesUri added in v0.4.397

func (x *ExplainResponse) GetTestShapValuesUri() string

func (*ExplainResponse) GetTrainShapValuesUri added in v0.4.397

func (x *ExplainResponse) GetTrainShapValuesUri() string

func (*ExplainResponse) ProtoMessage

func (*ExplainResponse) ProtoMessage()

func (*ExplainResponse) ProtoReflect

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

func (*ExplainResponse) Reset

func (x *ExplainResponse) Reset()

func (*ExplainResponse) String

func (x *ExplainResponse) String() string

type ForecastRequest

type ForecastRequest 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"`
	Model      *v1alpha12.Model             `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,6,opt,name=study,proto3" json:"study,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,7,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,8,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,9,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 154-byte string literal not displayed */
	Group      bool                         `protobuf:"varint,11,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*ForecastRequest) Descriptor deprecated

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

Deprecated: Use ForecastRequest.ProtoReflect.Descriptor instead.

func (*ForecastRequest) GetBucket

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

func (*ForecastRequest) GetConnection

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

func (*ForecastRequest) GetDataset

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

func (*ForecastRequest) GetDatasource

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

func (*ForecastRequest) GetGroup added in v0.5.168

func (x *ForecastRequest) GetGroup() bool

func (*ForecastRequest) GetModel

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

func (*ForecastRequest) GetProduct

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

func (*ForecastRequest) GetSecret

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

func (*ForecastRequest) GetStudy

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

func (*ForecastRequest) GetVersion

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

func (*ForecastRequest) ProtoMessage

func (*ForecastRequest) ProtoMessage()

func (*ForecastRequest) ProtoReflect

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

func (*ForecastRequest) Reset

func (x *ForecastRequest) Reset()

func (*ForecastRequest) String

func (x *ForecastRequest) String() string

type ForecastResponse

type ForecastResponse struct {

	// The location in the bucket of the forecast
	ForecastCloudUri string `protobuf:"bytes,2,opt,name=forecastCloudUri,proto3" json:"forecastCloudUri,omitempty"`
	// contains filtered or unexported fields
}

func (*ForecastResponse) Descriptor deprecated

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

Deprecated: Use ForecastResponse.ProtoReflect.Descriptor instead.

func (*ForecastResponse) GetForecastCloudUri

func (x *ForecastResponse) GetForecastCloudUri() string

func (*ForecastResponse) ProtoMessage

func (*ForecastResponse) ProtoMessage()

func (*ForecastResponse) ProtoReflect

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

func (*ForecastResponse) Reset

func (x *ForecastResponse) Reset()

func (*ForecastResponse) String

func (x *ForecastResponse) String() string

type ShutdownRequest

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

func (*ShutdownRequest) Descriptor deprecated

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect

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

func (*ShutdownRequest) Reset

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String

func (x *ShutdownRequest) String() string

type ShutdownResponse

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

func (*ShutdownResponse) Descriptor deprecated

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect

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

func (*ShutdownResponse) Reset

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String

func (x *ShutdownResponse) String() string

type TestEnsembleRequest

type TestEnsembleRequest 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"`
	// the spec for the base models
	Base       []*v1alpha12.Model    `protobuf:"bytes,5,rep,name=base,proto3" json:"base,omitempty"`
	Model      *v1alpha12.Model      `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Study      *v1alpha12.Study      `protobuf:"bytes,7,opt,name=study,proto3" json:"study,omitempty"`
	Datasource *v1alpha1.DataSource  `protobuf:"bytes,8,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset     `protobuf:"bytes,9,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection `protobuf:"bytes,10,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte     `` /* 154-byte string literal not displayed */
	Group      bool                  `protobuf:"varint,12,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*TestEnsembleRequest) Descriptor deprecated

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

Deprecated: Use TestEnsembleRequest.ProtoReflect.Descriptor instead.

func (*TestEnsembleRequest) GetBase

func (x *TestEnsembleRequest) GetBase() []*v1alpha12.Model

func (*TestEnsembleRequest) GetBucket

func (*TestEnsembleRequest) GetConnection

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

func (*TestEnsembleRequest) GetDataset

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

func (*TestEnsembleRequest) GetDatasource

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

func (*TestEnsembleRequest) GetGroup added in v0.5.198

func (x *TestEnsembleRequest) GetGroup() bool

func (*TestEnsembleRequest) GetModel

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

func (*TestEnsembleRequest) GetProduct

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

func (*TestEnsembleRequest) GetSecret

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

func (*TestEnsembleRequest) GetStudy

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

func (*TestEnsembleRequest) GetVersion

func (*TestEnsembleRequest) ProtoMessage

func (*TestEnsembleRequest) ProtoMessage()

func (*TestEnsembleRequest) ProtoReflect

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

func (*TestEnsembleRequest) Reset

func (x *TestEnsembleRequest) Reset()

func (*TestEnsembleRequest) String

func (x *TestEnsembleRequest) String() string

type TestRequest

type TestRequest 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"`
	Model      *v1alpha12.Model             `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
	Study      *v1alpha12.Study             `protobuf:"bytes,6,opt,name=study,proto3" json:"study,omitempty"`
	Datasource *v1alpha1.DataSource         `protobuf:"bytes,7,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset            `protobuf:"bytes,8,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection        `protobuf:"bytes,9,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte            `` /* 154-byte string literal not displayed */
	Group      bool                         `protobuf:"varint,11,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*TestRequest) Descriptor deprecated

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

Deprecated: Use TestRequest.ProtoReflect.Descriptor instead.

func (*TestRequest) GetBucket

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

func (*TestRequest) GetConnection

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

func (*TestRequest) GetDataset

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

func (*TestRequest) GetDatasource

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

func (*TestRequest) GetGroup added in v0.5.198

func (x *TestRequest) GetGroup() bool

func (*TestRequest) GetModel

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

func (*TestRequest) GetProduct

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

func (*TestRequest) GetSecret

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

func (*TestRequest) GetStudy

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

func (*TestRequest) GetVersion

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

func (*TestRequest) ProtoMessage

func (*TestRequest) ProtoMessage()

func (*TestRequest) ProtoReflect

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

func (*TestRequest) Reset

func (x *TestRequest) Reset()

func (*TestRequest) String

func (x *TestRequest) String() string

type TestResponse

type TestResponse struct {

	// measurements on the training set
	TrainResult []*v1alpha13.Measurement `protobuf:"bytes,1,rep,name=train_result,json=trainResult,proto3" json:"train_result,omitempty"`
	// measurements on the testing set
	TestResult []*v1alpha13.Measurement `protobuf:"bytes,2,rep,name=test_result,json=testResult,proto3" json:"test_result,omitempty"`
	// The benchmark measurments
	BenchmarkResult []*v1alpha13.Measurement `protobuf:"bytes,3,rep,name=benchmark_result,json=benchmarkResult,proto3" json:"benchmark_result,omitempty"`
	// The location in the bucket of the model binary trained on the testing data
	TestingModelWeightsCloudUri string `protobuf:"bytes,4,opt,name=testingModelWeightsCloudUri,proto3" json:"testingModelWeightsCloudUri,omitempty"`
	// The location in the bucket of the model binary trained on the testing label encoder
	TestingLabelEncoder string `protobuf:"bytes,5,opt,name=testingLabelEncoder,proto3" json:"testingLabelEncoder,omitempty"`
	// The location in the bucket of the model binary trained on the full data
	FullModelWeightsCloudUri string `protobuf:"bytes,6,opt,name=fullModelWeightsCloudUri,proto3" json:"fullModelWeightsCloudUri,omitempty"`
	// The location in the bucket of the model binary trained on the full data
	FullLabelEncoder string `protobuf:"bytes,7,opt,name=fullLabelEncoder,proto3" json:"fullLabelEncoder,omitempty"`
	// The location in the bucket of the cloud manifest.
	ModelManifestCloudUri string `protobuf:"bytes,8,opt,name=modelManifestCloudUri,proto3" json:"modelManifestCloudUri,omitempty"`
	// The location in the bucket of the logs.
	ModelLogsCloudUri string `protobuf:"bytes,9,opt,name=modelLogsCloudUri,proto3" json:"modelLogsCloudUri,omitempty"`
	// The location in the bucket of the trained bin model
	PreWeightsCloudUri string `protobuf:"bytes,10,opt,name=preWeightsCloudUri,proto3" json:"preWeightsCloudUri,omitempty"`
	// The location in the bucket of the cloud manifest.
	PreManifestCloudUri string `protobuf:"bytes,11,opt,name=preManifestCloudUri,proto3" json:"preManifestCloudUri,omitempty"`
	// The location in the bucket of the logs.
	PreLogsCloudUri string `protobuf:"bytes,12,opt,name=preLogsCloudUri,proto3" json:"preLogsCloudUri,omitempty"`
	// python command line
	PythonCMD string `protobuf:"bytes,13,opt,name=pythonCMD,proto3" json:"pythonCMD,omitempty"`
	// The operating system
	OS string `protobuf:"bytes,14,opt,name=OS,proto3" json:"OS,omitempty"`
	// python version info
	PythonVersionInfo string `protobuf:"bytes,15,opt,name=pythonVersionInfo,proto3" json:"pythonVersionInfo,omitempty"`
	// pip freeze string
	PipFreeze map[string]string `` /* 160-byte string literal not displayed */
	// Misclassfied uri
	MisclassUri string `protobuf:"bytes,17,opt,name=misclassUri,proto3" json:"misclassUri,omitempty"`
	// feature importance
	ImpurityFeatureImportance map[string]float32 `` /* 194-byte string literal not displayed */
	// permutation feature importance
	PermutationFeatureImportance map[string]float32 `` /* 200-byte string literal not displayed */
	// train confusion matrix
	TrainCM *v1alpha13.ConfusionMatrix `protobuf:"bytes,20,opt,name=trainCM,proto3" json:"trainCM,omitempty"`
	// test confusion matrix
	TestCM *v1alpha13.ConfusionMatrix `protobuf:"bytes,21,opt,name=testCM,proto3" json:"testCM,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResponse) Descriptor deprecated

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

Deprecated: Use TestResponse.ProtoReflect.Descriptor instead.

func (*TestResponse) GetBenchmarkResult

func (x *TestResponse) GetBenchmarkResult() []*v1alpha13.Measurement

func (*TestResponse) GetFullLabelEncoder added in v0.5.522

func (x *TestResponse) GetFullLabelEncoder() string

func (*TestResponse) GetFullModelWeightsCloudUri added in v0.5.522

func (x *TestResponse) GetFullModelWeightsCloudUri() string

func (*TestResponse) GetImpurityFeatureImportance added in v0.4.814

func (x *TestResponse) GetImpurityFeatureImportance() map[string]float32

func (*TestResponse) GetMisclassUri

func (x *TestResponse) GetMisclassUri() string

func (*TestResponse) GetModelLogsCloudUri

func (x *TestResponse) GetModelLogsCloudUri() string

func (*TestResponse) GetModelManifestCloudUri

func (x *TestResponse) GetModelManifestCloudUri() string

func (*TestResponse) GetOS added in v0.4.811

func (x *TestResponse) GetOS() string

func (*TestResponse) GetPermutationFeatureImportance added in v0.4.814

func (x *TestResponse) GetPermutationFeatureImportance() map[string]float32

func (*TestResponse) GetPipFreeze

func (x *TestResponse) GetPipFreeze() map[string]string

func (*TestResponse) GetPreLogsCloudUri

func (x *TestResponse) GetPreLogsCloudUri() string

func (*TestResponse) GetPreManifestCloudUri

func (x *TestResponse) GetPreManifestCloudUri() string

func (*TestResponse) GetPreWeightsCloudUri

func (x *TestResponse) GetPreWeightsCloudUri() string

func (*TestResponse) GetPythonCMD added in v0.4.811

func (x *TestResponse) GetPythonCMD() string

func (*TestResponse) GetPythonVersionInfo

func (x *TestResponse) GetPythonVersionInfo() string

func (*TestResponse) GetTestCM added in v0.4.813

func (x *TestResponse) GetTestCM() *v1alpha13.ConfusionMatrix

func (*TestResponse) GetTestResult

func (x *TestResponse) GetTestResult() []*v1alpha13.Measurement

func (*TestResponse) GetTestingLabelEncoder added in v0.5.522

func (x *TestResponse) GetTestingLabelEncoder() string

func (*TestResponse) GetTestingModelWeightsCloudUri added in v0.5.522

func (x *TestResponse) GetTestingModelWeightsCloudUri() string

func (*TestResponse) GetTrainCM added in v0.4.813

func (x *TestResponse) GetTrainCM() *v1alpha13.ConfusionMatrix

func (*TestResponse) GetTrainResult

func (x *TestResponse) GetTrainResult() []*v1alpha13.Measurement

func (*TestResponse) ProtoMessage

func (*TestResponse) ProtoMessage()

func (*TestResponse) ProtoReflect

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

func (*TestResponse) Reset

func (x *TestResponse) Reset()

func (*TestResponse) String

func (x *TestResponse) String() string

type TrainDriftDetectorRequest added in v0.4.730

type TrainDriftDetectorRequest 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"`
	// the spec for the base models
	Base       []*v1alpha12.Model    `protobuf:"bytes,5,rep,name=base,proto3" json:"base,omitempty"`
	Model      *v1alpha12.Model      `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Study      *v1alpha12.Study      `protobuf:"bytes,7,opt,name=study,proto3" json:"study,omitempty"`
	Datasource *v1alpha1.DataSource  `protobuf:"bytes,8,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset     `protobuf:"bytes,9,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection `protobuf:"bytes,10,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte     `` /* 154-byte string literal not displayed */
	Group      bool                  `protobuf:"varint,12,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*TrainDriftDetectorRequest) Descriptor deprecated added in v0.4.730

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

Deprecated: Use TrainDriftDetectorRequest.ProtoReflect.Descriptor instead.

func (*TrainDriftDetectorRequest) GetBase added in v0.4.730

func (x *TrainDriftDetectorRequest) GetBase() []*v1alpha12.Model

func (*TrainDriftDetectorRequest) GetBucket added in v0.4.730

func (*TrainDriftDetectorRequest) GetConnection added in v0.4.730

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

func (*TrainDriftDetectorRequest) GetDataset added in v0.4.730

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

func (*TrainDriftDetectorRequest) GetDatasource added in v0.4.730

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

func (*TrainDriftDetectorRequest) GetGroup added in v0.5.198

func (x *TrainDriftDetectorRequest) GetGroup() bool

func (*TrainDriftDetectorRequest) GetModel added in v0.4.730

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

func (*TrainDriftDetectorRequest) GetProduct added in v0.4.730

func (*TrainDriftDetectorRequest) GetSecret added in v0.4.730

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

func (*TrainDriftDetectorRequest) GetStudy added in v0.4.730

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

func (*TrainDriftDetectorRequest) GetVersion added in v0.4.730

func (*TrainDriftDetectorRequest) ProtoMessage added in v0.4.730

func (*TrainDriftDetectorRequest) ProtoMessage()

func (*TrainDriftDetectorRequest) ProtoReflect added in v0.4.730

func (*TrainDriftDetectorRequest) Reset added in v0.4.730

func (x *TrainDriftDetectorRequest) Reset()

func (*TrainDriftDetectorRequest) String added in v0.4.730

func (x *TrainDriftDetectorRequest) String() string

type TrainEnsembleRequest

type TrainEnsembleRequest 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"`
	// the spec for the base models
	Base       []*v1alpha12.Model    `protobuf:"bytes,5,rep,name=base,proto3" json:"base,omitempty"`
	Model      *v1alpha12.Model      `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Study      *v1alpha12.Study      `protobuf:"bytes,7,opt,name=study,proto3" json:"study,omitempty"`
	Datasource *v1alpha1.DataSource  `protobuf:"bytes,8,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset    *v1alpha1.Dataset     `protobuf:"bytes,9,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection *v1alpha11.Connection `protobuf:"bytes,10,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte     `` /* 154-byte string literal not displayed */
	Group      bool                  `protobuf:"varint,12,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

used for ensable training

func (*TrainEnsembleRequest) Descriptor deprecated

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

Deprecated: Use TrainEnsembleRequest.ProtoReflect.Descriptor instead.

func (*TrainEnsembleRequest) GetBase

func (x *TrainEnsembleRequest) GetBase() []*v1alpha12.Model

func (*TrainEnsembleRequest) GetBucket

func (*TrainEnsembleRequest) GetConnection

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

func (*TrainEnsembleRequest) GetDataset

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

func (*TrainEnsembleRequest) GetDatasource

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

func (*TrainEnsembleRequest) GetGroup added in v0.5.198

func (x *TrainEnsembleRequest) GetGroup() bool

func (*TrainEnsembleRequest) GetModel

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

func (*TrainEnsembleRequest) GetProduct

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

func (*TrainEnsembleRequest) GetSecret

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

func (*TrainEnsembleRequest) GetStudy

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

func (*TrainEnsembleRequest) GetVersion

func (*TrainEnsembleRequest) ProtoMessage

func (*TrainEnsembleRequest) ProtoMessage()

func (*TrainEnsembleRequest) ProtoReflect

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

func (*TrainEnsembleRequest) Reset

func (x *TrainEnsembleRequest) Reset()

func (*TrainEnsembleRequest) String

func (x *TrainEnsembleRequest) String() string

type TrainRequest

type TrainRequest 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"`
	Model        *v1alpha12.Model             `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`
	Study        *v1alpha12.Study             `protobuf:"bytes,6,opt,name=study,proto3" json:"study,omitempty"`
	Datasource   *v1alpha1.DataSource         `protobuf:"bytes,7,opt,name=datasource,proto3" json:"datasource,omitempty"`
	Dataset      *v1alpha1.Dataset            `protobuf:"bytes,8,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Connection   *v1alpha11.Connection        `protobuf:"bytes,9,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret       map[string][]byte            `` /* 154-byte string literal not displayed */
	TestDataset  *v1alpha1.Dataset            `protobuf:"bytes,11,opt,name=testDataset,proto3" json:"testDataset,omitempty"`
	TrainDataset *v1alpha1.Dataset            `protobuf:"bytes,12,opt,name=trainDataset,proto3" json:"trainDataset,omitempty"`
	Group        bool                         `protobuf:"varint,13,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*TrainRequest) Descriptor deprecated

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

Deprecated: Use TrainRequest.ProtoReflect.Descriptor instead.

func (*TrainRequest) GetBucket

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

func (*TrainRequest) GetConnection

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

func (*TrainRequest) GetDataset

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

func (*TrainRequest) GetDatasource

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

func (*TrainRequest) GetGroup added in v0.5.168

func (x *TrainRequest) GetGroup() bool

func (*TrainRequest) GetModel

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

func (*TrainRequest) GetProduct

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

func (*TrainRequest) GetSecret

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

func (*TrainRequest) GetStudy

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

func (*TrainRequest) GetTestDataset added in v0.4.586

func (x *TrainRequest) GetTestDataset() *v1alpha1.Dataset

func (*TrainRequest) GetTrainDataset added in v0.4.586

func (x *TrainRequest) GetTrainDataset() *v1alpha1.Dataset

func (*TrainRequest) GetVersion

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

func (*TrainRequest) ProtoMessage

func (*TrainRequest) ProtoMessage()

func (*TrainRequest) ProtoReflect

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

func (*TrainRequest) Reset

func (x *TrainRequest) Reset()

func (*TrainRequest) String

func (x *TrainRequest) String() string

type TrainResponse

type TrainResponse struct {
	Result []*v1alpha13.Measurement `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// The location in the bucket of the trained bin model
	WeightsCloudUri string `protobuf:"bytes,2,opt,name=weightsCloudUri,proto3" json:"weightsCloudUri,omitempty"`
	// The location in the bucket of the cloud manifest.
	ManifestCloudUri string `protobuf:"bytes,3,opt,name=manifestCloudUri,proto3" json:"manifestCloudUri,omitempty"`
	// The location in the bucket of the logs.
	LogsCloudUri string `protobuf:"bytes,4,opt,name=logsCloudUri,proto3" json:"logsCloudUri,omitempty"`
	// The uri for the label encoder, in case of a categorical class.
	LabelEncoder string `protobuf:"bytes,5,opt,name=labelEncoder,proto3" json:"labelEncoder,omitempty"`
	// python version info
	PythonVersionInfo string `protobuf:"bytes,6,opt,name=pythonVersionInfo,proto3" json:"pythonVersionInfo,omitempty"`
	// python command line
	PythonCMD string `protobuf:"bytes,7,opt,name=pythonCMD,proto3" json:"pythonCMD,omitempty"`
	// The operating system
	OS string `protobuf:"bytes,8,opt,name=OS,proto3" json:"OS,omitempty"`
	// pip freeze string
	PipFreeze map[string]string `` /* 159-byte string literal not displayed */
	// feature importance
	ImpurityFeatureImportance map[string]float32 `` /* 194-byte string literal not displayed */
	// permutation feature importance
	PermutationFeatureImportance map[string]float32 `` /* 200-byte string literal not displayed */
	// confusion matrix
	Cm *v1alpha13.ConfusionMatrix `protobuf:"bytes,12,opt,name=cm,proto3" json:"cm,omitempty"`
	// this is the model uri
	ModelIndexURI string `protobuf:"bytes,13,opt,name=modelIndexURI,proto3" json:"modelIndexURI,omitempty"`
	// This is used in cases where the training is also performing the forecast
	ForecastURI string `protobuf:"bytes,14,opt,name=forecastURI,proto3" json:"forecastURI,omitempty"`
	// Compute the features on the time series.
	Features []*v1alpha13.Measurement `protobuf:"bytes,15,rep,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

func (*TrainResponse) Descriptor deprecated

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

Deprecated: Use TrainResponse.ProtoReflect.Descriptor instead.

func (*TrainResponse) GetCm added in v0.4.808

func (*TrainResponse) GetFeatures added in v0.5.238

func (x *TrainResponse) GetFeatures() []*v1alpha13.Measurement

func (*TrainResponse) GetForecastURI added in v0.5.235

func (x *TrainResponse) GetForecastURI() string

func (*TrainResponse) GetImpurityFeatureImportance added in v0.4.816

func (x *TrainResponse) GetImpurityFeatureImportance() map[string]float32

func (*TrainResponse) GetLabelEncoder

func (x *TrainResponse) GetLabelEncoder() string

func (*TrainResponse) GetLogsCloudUri

func (x *TrainResponse) GetLogsCloudUri() string

func (*TrainResponse) GetManifestCloudUri

func (x *TrainResponse) GetManifestCloudUri() string

func (*TrainResponse) GetModelIndexURI added in v0.5.168

func (x *TrainResponse) GetModelIndexURI() string

func (*TrainResponse) GetOS added in v0.4.807

func (x *TrainResponse) GetOS() string

func (*TrainResponse) GetPermutationFeatureImportance added in v0.4.816

func (x *TrainResponse) GetPermutationFeatureImportance() map[string]float32

func (*TrainResponse) GetPipFreeze

func (x *TrainResponse) GetPipFreeze() map[string]string

func (*TrainResponse) GetPythonCMD added in v0.4.807

func (x *TrainResponse) GetPythonCMD() string

func (*TrainResponse) GetPythonVersionInfo

func (x *TrainResponse) GetPythonVersionInfo() string

func (*TrainResponse) GetResult

func (x *TrainResponse) GetResult() []*v1alpha13.Measurement

func (*TrainResponse) GetWeightsCloudUri

func (x *TrainResponse) GetWeightsCloudUri() string

func (*TrainResponse) ProtoMessage

func (*TrainResponse) ProtoMessage()

func (*TrainResponse) ProtoReflect

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

func (*TrainResponse) Reset

func (x *TrainResponse) Reset()

func (*TrainResponse) String

func (x *TrainResponse) String() string

type TrainerdServiceClient

type TrainerdServiceClient interface {
	Train(ctx context.Context, in *TrainRequest, opts ...grpc.CallOption) (*TrainResponse, error)
	Explain(ctx context.Context, in *ExplainRequest, opts ...grpc.CallOption) (*ExplainResponse, error)
	Forecast(ctx context.Context, in *ForecastRequest, opts ...grpc.CallOption) (*ForecastResponse, error)
	Test(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error)
	TrainEnsemble(ctx context.Context, in *TrainEnsembleRequest, opts ...grpc.CallOption) (*TrainResponse, error)
	TrainDriftDetector(ctx context.Context, in *TrainDriftDetectorRequest, opts ...grpc.CallOption) (*TrainResponse, error)
	TestEnsemble(ctx context.Context, in *TestEnsembleRequest, opts ...grpc.CallOption) (*TestResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

TrainerdServiceClient is the client API for TrainerdService 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.

type TrainerdServiceServer

type TrainerdServiceServer interface {
	Train(context.Context, *TrainRequest) (*TrainResponse, error)
	Explain(context.Context, *ExplainRequest) (*ExplainResponse, error)
	Forecast(context.Context, *ForecastRequest) (*ForecastResponse, error)
	Test(context.Context, *TestRequest) (*TestResponse, error)
	TrainEnsemble(context.Context, *TrainEnsembleRequest) (*TrainResponse, error)
	TrainDriftDetector(context.Context, *TrainDriftDetectorRequest) (*TrainResponse, error)
	TestEnsemble(context.Context, *TestEnsembleRequest) (*TestResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	// contains filtered or unexported methods
}

TrainerdServiceServer is the server API for TrainerdService service. All implementations must embed UnimplementedTrainerdServiceServer for forward compatibility

type UnimplementedTrainerdServiceServer

type UnimplementedTrainerdServiceServer struct {
}

UnimplementedTrainerdServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTrainerdServiceServer) Explain

func (UnimplementedTrainerdServiceServer) Forecast

func (UnimplementedTrainerdServiceServer) Shutdown

func (UnimplementedTrainerdServiceServer) Test

func (UnimplementedTrainerdServiceServer) TestEnsemble

func (UnimplementedTrainerdServiceServer) Train

func (UnimplementedTrainerdServiceServer) TrainDriftDetector added in v0.4.730

func (UnimplementedTrainerdServiceServer) TrainEnsemble

type UnsafeTrainerdServiceServer added in v0.4.687

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL