pipeline

package
v0.0.0-...-d6f8ab3 Latest Latest
Warning

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

Go to latest
Published: Aug 9, 2019 License: Apache-2.0 Imports: 29 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var E_ProtocolVersion = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.FileOptions)(nil),
	ExtensionType: (*string)(nil),
	Field:         54100,
	Name:          "protocol_version",
	Tag:           "bytes,54100,opt,name=protocol_version",
	Filename:      "core.proto",
}
View Source
var EvaluationMethod_name = map[int32]string{
	0:   "EVALUATION_METHOD_UNDEFINED",
	1:   "HOLDOUT",
	2:   "K_FOLD",
	99:  "RANKING",
	100: "LEAVE_ONE_OUT",
	101: "PREDICTION",
	102: "TRAINING_DATA",
}
View Source
var EvaluationMethod_value = map[string]int32{
	"EVALUATION_METHOD_UNDEFINED": 0,
	"HOLDOUT":                     1,
	"K_FOLD":                      2,
	"RANKING":                     99,
	"LEAVE_ONE_OUT":               100,
	"PREDICTION":                  101,
	"TRAINING_DATA":               102,
}
View Source
var NullValue_name = map[int32]string{
	0: "NULL_VALUE",
}
View Source
var NullValue_value = map[string]int32{
	"NULL_VALUE": 0,
}
View Source
var PerformanceMetric_name = map[int32]string{
	0:   "METRIC_UNDEFINED",
	1:   "ACCURACY",
	2:   "PRECISION",
	3:   "RECALL",
	4:   "F1",
	5:   "F1_MICRO",
	6:   "F1_MACRO",
	7:   "ROC_AUC",
	8:   "ROC_AUC_MICRO",
	9:   "ROC_AUC_MACRO",
	10:  "MEAN_SQUARED_ERROR",
	11:  "ROOT_MEAN_SQUARED_ERROR",
	12:  "MEAN_ABSOLUTE_ERROR",
	13:  "R_SQUARED",
	14:  "NORMALIZED_MUTUAL_INFORMATION",
	15:  "JACCARD_SIMILARITY_SCORE",
	17:  "PRECISION_AT_TOP_K",
	18:  "OBJECT_DETECTION_AVERAGE_PRECISION",
	19:  "HAMMING_LOSS",
	99:  "RANK",
	100: "LOSS",
}
View Source
var PerformanceMetric_value = map[string]int32{
	"METRIC_UNDEFINED":                   0,
	"ACCURACY":                           1,
	"PRECISION":                          2,
	"RECALL":                             3,
	"F1":                                 4,
	"F1_MICRO":                           5,
	"F1_MACRO":                           6,
	"ROC_AUC":                            7,
	"ROC_AUC_MICRO":                      8,
	"ROC_AUC_MACRO":                      9,
	"MEAN_SQUARED_ERROR":                 10,
	"ROOT_MEAN_SQUARED_ERROR":            11,
	"MEAN_ABSOLUTE_ERROR":                12,
	"R_SQUARED":                          13,
	"NORMALIZED_MUTUAL_INFORMATION":      14,
	"JACCARD_SIMILARITY_SCORE":           15,
	"PRECISION_AT_TOP_K":                 17,
	"OBJECT_DETECTION_AVERAGE_PRECISION": 18,
	"HAMMING_LOSS":                       19,
	"RANK":                               99,
	"LOSS":                               100,
}
View Source
var PipelineContext_name = map[int32]string{
	0: "PIPELINE_CONTEXT_UNKNOWN",
	1: "PRETRAINING",
	2: "TESTING",
	3: "EVALUATION",
	4: "PRODUCTION",
}
View Source
var PipelineContext_value = map[string]int32{
	"PIPELINE_CONTEXT_UNKNOWN": 0,
	"PRETRAINING":              1,
	"TESTING":                  2,
	"EVALUATION":               3,
	"PRODUCTION":               4,
}
View Source
var ProgressState_name = map[int32]string{
	0: "PROGRESS_UNKNOWN",
	1: "PENDING",
	2: "RUNNING",
	3: "COMPLETED",
	4: "ERRORED",
}
View Source
var ProgressState_value = map[string]int32{
	"PROGRESS_UNKNOWN": 0,
	"PENDING":          1,
	"RUNNING":          2,
	"COMPLETED":        3,
	"ERRORED":          4,
}
View Source
var TaskSubtype_name = map[int32]string{
	0: "TASK_SUBTYPE_UNDEFINED",
	1: "NONE",
	2: "BINARY",
	3: "MULTICLASS",
	4: "MULTILABEL",
	5: "UNIVARIATE",
	6: "MULTIVARIATE",
	7: "OVERLAPPING",
	8: "NONOVERLAPPING",
}
View Source
var TaskSubtype_value = map[string]int32{
	"TASK_SUBTYPE_UNDEFINED": 0,
	"NONE":                   1,
	"BINARY":                 2,
	"MULTICLASS":             3,
	"MULTILABEL":             4,
	"UNIVARIATE":             5,
	"MULTIVARIATE":           6,
	"OVERLAPPING":            7,
	"NONOVERLAPPING":         8,
}
View Source
var TaskType_name = map[int32]string{
	0:  "TASK_TYPE_UNDEFINED",
	1:  "CLASSIFICATION",
	2:  "REGRESSION",
	3:  "CLUSTERING",
	4:  "LINK_PREDICTION",
	5:  "VERTEX_NOMINATION",
	6:  "VERTEX_CLASSIFICATION",
	7:  "COMMUNITY_DETECTION",
	8:  "GRAPH_MATCHING",
	9:  "TIME_SERIES_FORECASTING",
	10: "COLLABORATIVE_FILTERING",
	11: "OBJECT_DETECTION",
	12: "SEMISUPERVISED_CLASSIFICATION",
	13: "SEMISUPERVISED_REGRESSION",
}
View Source
var TaskType_value = map[string]int32{
	"TASK_TYPE_UNDEFINED":           0,
	"CLASSIFICATION":                1,
	"REGRESSION":                    2,
	"CLUSTERING":                    3,
	"LINK_PREDICTION":               4,
	"VERTEX_NOMINATION":             5,
	"VERTEX_CLASSIFICATION":         6,
	"COMMUNITY_DETECTION":           7,
	"GRAPH_MATCHING":                8,
	"TIME_SERIES_FORECASTING":       9,
	"COLLABORATIVE_FILTERING":       10,
	"OBJECT_DETECTION":              11,
	"SEMISUPERVISED_CLASSIFICATION": 12,
	"SEMISUPERVISED_REGRESSION":     13,
}
View Source
var ValueType_name = map[int32]string{
	0: "VALUE_TYPE_UNDEFINED",
	1: "RAW",
	2: "DATASET_URI",
	3: "CSV_URI",
	4: "PICKLE_URI",
	5: "PICKLE_BLOB",
	6: "PLASMA_ID",
	7: "LARGE_RAW",
	8: "LARGE_PICKLE_BLOB",
}
View Source
var ValueType_value = map[string]int32{
	"VALUE_TYPE_UNDEFINED": 0,
	"RAW":                  1,
	"DATASET_URI":          2,
	"CSV_URI":              3,
	"PICKLE_URI":           4,
	"PICKLE_BLOB":          5,
	"PLASMA_ID":            6,
	"LARGE_RAW":            7,
	"LARGE_PICKLE_BLOB":    8,
}

Functions

func APIVersion

func APIVersion() string

APIVersion is the version of the TA3-TA2 API extracted from the protobuf definition. Lazily evaluated since the protobuf init has to be complete before it can be used. Doesn't change after initialization.

func RegisterCoreServer

func RegisterCoreServer(s *grpc.Server, srv CoreServer)

Types

type ContainerArgument

type ContainerArgument struct {
	// Data reference.
	Data                 string   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerArgument) Descriptor

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

func (*ContainerArgument) GetData

func (m *ContainerArgument) GetData() string

func (*ContainerArgument) ProtoMessage

func (*ContainerArgument) ProtoMessage()

func (*ContainerArgument) Reset

func (m *ContainerArgument) Reset()

func (*ContainerArgument) String

func (m *ContainerArgument) String() string

func (*ContainerArgument) XXX_DiscardUnknown

func (m *ContainerArgument) XXX_DiscardUnknown()

func (*ContainerArgument) XXX_Marshal

func (m *ContainerArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerArgument) XXX_Merge

func (m *ContainerArgument) XXX_Merge(src proto.Message)

func (*ContainerArgument) XXX_Size

func (m *ContainerArgument) XXX_Size() int

func (*ContainerArgument) XXX_Unmarshal

func (m *ContainerArgument) XXX_Unmarshal(b []byte) error

type ContainerArguments

type ContainerArguments struct {
	Data                 []string `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerArguments) Descriptor

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

func (*ContainerArguments) GetData

func (m *ContainerArguments) GetData() []string

func (*ContainerArguments) ProtoMessage

func (*ContainerArguments) ProtoMessage()

func (*ContainerArguments) Reset

func (m *ContainerArguments) Reset()

func (*ContainerArguments) String

func (m *ContainerArguments) String() string

func (*ContainerArguments) XXX_DiscardUnknown

func (m *ContainerArguments) XXX_DiscardUnknown()

func (*ContainerArguments) XXX_Marshal

func (m *ContainerArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerArguments) XXX_Merge

func (m *ContainerArguments) XXX_Merge(src proto.Message)

func (*ContainerArguments) XXX_Size

func (m *ContainerArguments) XXX_Size() int

func (*ContainerArguments) XXX_Unmarshal

func (m *ContainerArguments) XXX_Unmarshal(b []byte) error

type CoreClient

type CoreClient interface {
	SearchSolutions(ctx context.Context, in *SearchSolutionsRequest, opts ...grpc.CallOption) (*SearchSolutionsResponse, error)
	GetSearchSolutionsResults(ctx context.Context, in *GetSearchSolutionsResultsRequest, opts ...grpc.CallOption) (Core_GetSearchSolutionsResultsClient, error)
	EndSearchSolutions(ctx context.Context, in *EndSearchSolutionsRequest, opts ...grpc.CallOption) (*EndSearchSolutionsResponse, error)
	StopSearchSolutions(ctx context.Context, in *StopSearchSolutionsRequest, opts ...grpc.CallOption) (*StopSearchSolutionsResponse, error)
	DescribeSolution(ctx context.Context, in *DescribeSolutionRequest, opts ...grpc.CallOption) (*DescribeSolutionResponse, error)
	ScoreSolution(ctx context.Context, in *ScoreSolutionRequest, opts ...grpc.CallOption) (*ScoreSolutionResponse, error)
	GetScoreSolutionResults(ctx context.Context, in *GetScoreSolutionResultsRequest, opts ...grpc.CallOption) (Core_GetScoreSolutionResultsClient, error)
	FitSolution(ctx context.Context, in *FitSolutionRequest, opts ...grpc.CallOption) (*FitSolutionResponse, error)
	GetFitSolutionResults(ctx context.Context, in *GetFitSolutionResultsRequest, opts ...grpc.CallOption) (Core_GetFitSolutionResultsClient, error)
	ProduceSolution(ctx context.Context, in *ProduceSolutionRequest, opts ...grpc.CallOption) (*ProduceSolutionResponse, error)
	GetProduceSolutionResults(ctx context.Context, in *GetProduceSolutionResultsRequest, opts ...grpc.CallOption) (Core_GetProduceSolutionResultsClient, error)
	SolutionExport(ctx context.Context, in *SolutionExportRequest, opts ...grpc.CallOption) (*SolutionExportResponse, error)
	UpdateProblem(ctx context.Context, in *UpdateProblemRequest, opts ...grpc.CallOption) (*UpdateProblemResponse, error)
	DataAvailable(ctx context.Context, in *DataAvailableRequest, opts ...grpc.CallOption) (*DataAvailableResponse, error)
	ListPrimitives(ctx context.Context, in *ListPrimitivesRequest, opts ...grpc.CallOption) (*ListPrimitivesResponse, error)
	Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
	// Optional.
	SaveSolution(ctx context.Context, in *SaveSolutionRequest, opts ...grpc.CallOption) (*SaveSolutionResponse, error)
	LoadSolution(ctx context.Context, in *LoadSolutionRequest, opts ...grpc.CallOption) (*LoadSolutionResponse, error)
	SaveFittedSolution(ctx context.Context, in *SaveFittedSolutionRequest, opts ...grpc.CallOption) (*SaveFittedSolutionResponse, error)
	LoadFittedSolution(ctx context.Context, in *LoadFittedSolutionRequest, opts ...grpc.CallOption) (*LoadFittedSolutionResponse, error)
}

CoreClient is the client API for Core service.

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

func NewCoreClient

func NewCoreClient(cc *grpc.ClientConn) CoreClient

type CoreServer

type CoreServer interface {
	SearchSolutions(context.Context, *SearchSolutionsRequest) (*SearchSolutionsResponse, error)
	GetSearchSolutionsResults(*GetSearchSolutionsResultsRequest, Core_GetSearchSolutionsResultsServer) error
	EndSearchSolutions(context.Context, *EndSearchSolutionsRequest) (*EndSearchSolutionsResponse, error)
	StopSearchSolutions(context.Context, *StopSearchSolutionsRequest) (*StopSearchSolutionsResponse, error)
	DescribeSolution(context.Context, *DescribeSolutionRequest) (*DescribeSolutionResponse, error)
	ScoreSolution(context.Context, *ScoreSolutionRequest) (*ScoreSolutionResponse, error)
	GetScoreSolutionResults(*GetScoreSolutionResultsRequest, Core_GetScoreSolutionResultsServer) error
	FitSolution(context.Context, *FitSolutionRequest) (*FitSolutionResponse, error)
	GetFitSolutionResults(*GetFitSolutionResultsRequest, Core_GetFitSolutionResultsServer) error
	ProduceSolution(context.Context, *ProduceSolutionRequest) (*ProduceSolutionResponse, error)
	GetProduceSolutionResults(*GetProduceSolutionResultsRequest, Core_GetProduceSolutionResultsServer) error
	SolutionExport(context.Context, *SolutionExportRequest) (*SolutionExportResponse, error)
	UpdateProblem(context.Context, *UpdateProblemRequest) (*UpdateProblemResponse, error)
	DataAvailable(context.Context, *DataAvailableRequest) (*DataAvailableResponse, error)
	ListPrimitives(context.Context, *ListPrimitivesRequest) (*ListPrimitivesResponse, error)
	Hello(context.Context, *HelloRequest) (*HelloResponse, error)
	// Optional.
	SaveSolution(context.Context, *SaveSolutionRequest) (*SaveSolutionResponse, error)
	LoadSolution(context.Context, *LoadSolutionRequest) (*LoadSolutionResponse, error)
	SaveFittedSolution(context.Context, *SaveFittedSolutionRequest) (*SaveFittedSolutionResponse, error)
	LoadFittedSolution(context.Context, *LoadFittedSolutionRequest) (*LoadFittedSolutionResponse, error)
}

CoreServer is the server API for Core service.

type Core_GetFitSolutionResultsClient

type Core_GetFitSolutionResultsClient interface {
	Recv() (*GetFitSolutionResultsResponse, error)
	grpc.ClientStream
}

type Core_GetFitSolutionResultsServer

type Core_GetFitSolutionResultsServer interface {
	Send(*GetFitSolutionResultsResponse) error
	grpc.ServerStream
}

type Core_GetProduceSolutionResultsClient

type Core_GetProduceSolutionResultsClient interface {
	Recv() (*GetProduceSolutionResultsResponse, error)
	grpc.ClientStream
}

type Core_GetProduceSolutionResultsServer

type Core_GetProduceSolutionResultsServer interface {
	Send(*GetProduceSolutionResultsResponse) error
	grpc.ServerStream
}

type Core_GetScoreSolutionResultsClient

type Core_GetScoreSolutionResultsClient interface {
	Recv() (*GetScoreSolutionResultsResponse, error)
	grpc.ClientStream
}

type Core_GetScoreSolutionResultsServer

type Core_GetScoreSolutionResultsServer interface {
	Send(*GetScoreSolutionResultsResponse) error
	grpc.ServerStream
}

type Core_GetSearchSolutionsResultsClient

type Core_GetSearchSolutionsResultsClient interface {
	Recv() (*GetSearchSolutionsResultsResponse, error)
	grpc.ClientStream
}

type Core_GetSearchSolutionsResultsServer

type Core_GetSearchSolutionsResultsServer interface {
	Send(*GetSearchSolutionsResultsResponse) error
	grpc.ServerStream
}

type DataArgument

type DataArgument struct {
	// Data reference.
	Data                 string   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataArgument) Descriptor

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

func (*DataArgument) GetData

func (m *DataArgument) GetData() string

func (*DataArgument) ProtoMessage

func (*DataArgument) ProtoMessage()

func (*DataArgument) Reset

func (m *DataArgument) Reset()

func (*DataArgument) String

func (m *DataArgument) String() string

func (*DataArgument) XXX_DiscardUnknown

func (m *DataArgument) XXX_DiscardUnknown()

func (*DataArgument) XXX_Marshal

func (m *DataArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataArgument) XXX_Merge

func (m *DataArgument) XXX_Merge(src proto.Message)

func (*DataArgument) XXX_Size

func (m *DataArgument) XXX_Size() int

func (*DataArgument) XXX_Unmarshal

func (m *DataArgument) XXX_Unmarshal(b []byte) error

type DataArguments

type DataArguments struct {
	Data                 []string `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataArguments) Descriptor

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

func (*DataArguments) GetData

func (m *DataArguments) GetData() []string

func (*DataArguments) ProtoMessage

func (*DataArguments) ProtoMessage()

func (*DataArguments) Reset

func (m *DataArguments) Reset()

func (*DataArguments) String

func (m *DataArguments) String() string

func (*DataArguments) XXX_DiscardUnknown

func (m *DataArguments) XXX_DiscardUnknown()

func (*DataArguments) XXX_Marshal

func (m *DataArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataArguments) XXX_Merge

func (m *DataArguments) XXX_Merge(src proto.Message)

func (*DataArguments) XXX_Size

func (m *DataArguments) XXX_Size() int

func (*DataArguments) XXX_Unmarshal

func (m *DataArguments) XXX_Unmarshal(b []byte) error

type DataAugmentation

type DataAugmentation struct {
	Domain               []string `protobuf:"bytes,1,rep,name=domain,proto3" json:"domain,omitempty"`
	Keywords             []string `protobuf:"bytes,2,rep,name=keywords,proto3" json:"keywords,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataAugmentation) Descriptor

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

func (*DataAugmentation) GetDomain

func (m *DataAugmentation) GetDomain() []string

func (*DataAugmentation) GetKeywords

func (m *DataAugmentation) GetKeywords() []string

func (*DataAugmentation) ProtoMessage

func (*DataAugmentation) ProtoMessage()

func (*DataAugmentation) Reset

func (m *DataAugmentation) Reset()

func (*DataAugmentation) String

func (m *DataAugmentation) String() string

func (*DataAugmentation) XXX_DiscardUnknown

func (m *DataAugmentation) XXX_DiscardUnknown()

func (*DataAugmentation) XXX_Marshal

func (m *DataAugmentation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataAugmentation) XXX_Merge

func (m *DataAugmentation) XXX_Merge(src proto.Message)

func (*DataAugmentation) XXX_Size

func (m *DataAugmentation) XXX_Size() int

func (*DataAugmentation) XXX_Unmarshal

func (m *DataAugmentation) XXX_Unmarshal(b []byte) error

type DataAvailableRequest

type DataAvailableRequest struct {
	// Some string identifying the name and version of the TA3 system.
	UserAgent string `protobuf:"bytes,1,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"`
	// Shall be set to "protocol_version" above.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Desired upper limit of time spend processing this data, expressed in minutes.
	// Is suggestion, and TA2's should attempt to obey, but TA3's should realize may be
	// violated. Default value of 0 (and any negative number) signifies no time bound.
	TimeBound float64 `protobuf:"fixed64,3,opt,name=time_bound,json=timeBound,proto3" json:"time_bound,omitempty"`
	// Value stating the priority for processing of this data. Larger number is higher
	// priority. If unspecified, by default priority is 0. Negative numbers have
	// still lower priority.
	Priority             float64  `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"`
	Data                 []*Value `protobuf:"bytes,5,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Inform TA2 about data being available, triggering any potential internal data processing by TA2.

func (*DataAvailableRequest) Descriptor

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

func (*DataAvailableRequest) GetData

func (m *DataAvailableRequest) GetData() []*Value

func (*DataAvailableRequest) GetPriority

func (m *DataAvailableRequest) GetPriority() float64

func (*DataAvailableRequest) GetTimeBound

func (m *DataAvailableRequest) GetTimeBound() float64

func (*DataAvailableRequest) GetUserAgent

func (m *DataAvailableRequest) GetUserAgent() string

func (*DataAvailableRequest) GetVersion

func (m *DataAvailableRequest) GetVersion() string

func (*DataAvailableRequest) ProtoMessage

func (*DataAvailableRequest) ProtoMessage()

func (*DataAvailableRequest) Reset

func (m *DataAvailableRequest) Reset()

func (*DataAvailableRequest) String

func (m *DataAvailableRequest) String() string

func (*DataAvailableRequest) XXX_DiscardUnknown

func (m *DataAvailableRequest) XXX_DiscardUnknown()

func (*DataAvailableRequest) XXX_Marshal

func (m *DataAvailableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataAvailableRequest) XXX_Merge

func (m *DataAvailableRequest) XXX_Merge(src proto.Message)

func (*DataAvailableRequest) XXX_Size

func (m *DataAvailableRequest) XXX_Size() int

func (*DataAvailableRequest) XXX_Unmarshal

func (m *DataAvailableRequest) XXX_Unmarshal(b []byte) error

type DataAvailableResponse

type DataAvailableResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataAvailableResponse) Descriptor

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

func (*DataAvailableResponse) ProtoMessage

func (*DataAvailableResponse) ProtoMessage()

func (*DataAvailableResponse) Reset

func (m *DataAvailableResponse) Reset()

func (*DataAvailableResponse) String

func (m *DataAvailableResponse) String() string

func (*DataAvailableResponse) XXX_DiscardUnknown

func (m *DataAvailableResponse) XXX_DiscardUnknown()

func (*DataAvailableResponse) XXX_Marshal

func (m *DataAvailableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataAvailableResponse) XXX_Merge

func (m *DataAvailableResponse) XXX_Merge(src proto.Message)

func (*DataAvailableResponse) XXX_Size

func (m *DataAvailableResponse) XXX_Size() int

func (*DataAvailableResponse) XXX_Unmarshal

func (m *DataAvailableResponse) XXX_Unmarshal(b []byte) error

type DataResource

type DataResource struct {
	ResID        string          `json:"resID"`
	ResPath      string          `json:"resPath"`
	ResType      string          `json:"resType"`
	ResFormat    []string        `json:"resFormat"`
	IsCollection bool            `json:"isCollection"`
	Variables    []*DataVariable `json:"columns"`
}

DataResource represents a set of variables.

type DataSchema

type DataSchema struct {
	Properties    *DataSchemaProperties `json:"about"`
	DataResources []*DataResource       `json:"dataResources"`
}

DataSchema encapsulates the data schema json structure.

type DataSchemaProperties

type DataSchemaProperties struct {
	DatasetID       string `json:"datasetID"`
	DatasetName     string `json:"datasetName"`
	Description     string `json:"description"`
	Citation        string `json:"citation"`
	License         string `json:"license"`
	Source          string `json:"source"`
	SourceURI       string `json:"sourceURI"`
	ApproximateSize string `json:"approximateSize"`
	Redacted        bool   `json:"redacted"`
	SchemaVersion   string `json:"datasetSchemaVersion"`
}

DataSchemaProperties contains the basic properties of a dataset.

type DataVariable

type DataVariable struct {
	ColName  string   `json:"colName"`
	Role     []string `json:"role"`
	ColType  string   `json:"colType"`
	ColIndex int      `json:"colIndex"`
}

DataVariable captures the data schema representation of a variable.

type DescribeSolutionRequest

type DescribeSolutionRequest struct {
	SolutionId           string   `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request a detailed description of the found solution.

func (*DescribeSolutionRequest) Descriptor

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

func (*DescribeSolutionRequest) GetSolutionId

func (m *DescribeSolutionRequest) GetSolutionId() string

func (*DescribeSolutionRequest) ProtoMessage

func (*DescribeSolutionRequest) ProtoMessage()

func (*DescribeSolutionRequest) Reset

func (m *DescribeSolutionRequest) Reset()

func (*DescribeSolutionRequest) String

func (m *DescribeSolutionRequest) String() string

func (*DescribeSolutionRequest) XXX_DiscardUnknown

func (m *DescribeSolutionRequest) XXX_DiscardUnknown()

func (*DescribeSolutionRequest) XXX_Marshal

func (m *DescribeSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeSolutionRequest) XXX_Merge

func (m *DescribeSolutionRequest) XXX_Merge(src proto.Message)

func (*DescribeSolutionRequest) XXX_Size

func (m *DescribeSolutionRequest) XXX_Size() int

func (*DescribeSolutionRequest) XXX_Unmarshal

func (m *DescribeSolutionRequest) XXX_Unmarshal(b []byte) error

type DescribeSolutionResponse

type DescribeSolutionResponse struct {
	// A pipeline description. Nested pipelines should be fully described as well.
	Pipeline *PipelineDescription `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// Each step in a pipeline has description. These are reported in the order of steps in
	// the pipeline.
	Steps                []*StepDescription `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DescribeSolutionResponse) Descriptor

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

func (*DescribeSolutionResponse) GetPipeline

func (*DescribeSolutionResponse) GetSteps

func (m *DescribeSolutionResponse) GetSteps() []*StepDescription

func (*DescribeSolutionResponse) ProtoMessage

func (*DescribeSolutionResponse) ProtoMessage()

func (*DescribeSolutionResponse) Reset

func (m *DescribeSolutionResponse) Reset()

func (*DescribeSolutionResponse) String

func (m *DescribeSolutionResponse) String() string

func (*DescribeSolutionResponse) XXX_DiscardUnknown

func (m *DescribeSolutionResponse) XXX_DiscardUnknown()

func (*DescribeSolutionResponse) XXX_Marshal

func (m *DescribeSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeSolutionResponse) XXX_Merge

func (m *DescribeSolutionResponse) XXX_Merge(src proto.Message)

func (*DescribeSolutionResponse) XXX_Size

func (m *DescribeSolutionResponse) XXX_Size() int

func (*DescribeSolutionResponse) XXX_Unmarshal

func (m *DescribeSolutionResponse) XXX_Unmarshal(b []byte) error

type EndSearchSolutionsRequest

type EndSearchSolutionsRequest struct {
	SearchId             string   `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Ends the search and releases all resources associated with the solution search. If the call is made in parallel with a running search and results are being streamed, the search is stopped and the "GetSearchSolutionsResults" stream is closed by TA2 (as happens when the search is concluded on its own, or when a search is stopped by "StopSearchSolutions"). Found solution IDs during the search are no longer valid after this call.

func (*EndSearchSolutionsRequest) Descriptor

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

func (*EndSearchSolutionsRequest) GetSearchId

func (m *EndSearchSolutionsRequest) GetSearchId() string

func (*EndSearchSolutionsRequest) ProtoMessage

func (*EndSearchSolutionsRequest) ProtoMessage()

func (*EndSearchSolutionsRequest) Reset

func (m *EndSearchSolutionsRequest) Reset()

func (*EndSearchSolutionsRequest) String

func (m *EndSearchSolutionsRequest) String() string

func (*EndSearchSolutionsRequest) XXX_DiscardUnknown

func (m *EndSearchSolutionsRequest) XXX_DiscardUnknown()

func (*EndSearchSolutionsRequest) XXX_Marshal

func (m *EndSearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndSearchSolutionsRequest) XXX_Merge

func (m *EndSearchSolutionsRequest) XXX_Merge(src proto.Message)

func (*EndSearchSolutionsRequest) XXX_Size

func (m *EndSearchSolutionsRequest) XXX_Size() int

func (*EndSearchSolutionsRequest) XXX_Unmarshal

func (m *EndSearchSolutionsRequest) XXX_Unmarshal(b []byte) error

type EndSearchSolutionsResponse

type EndSearchSolutionsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EndSearchSolutionsResponse) Descriptor

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

func (*EndSearchSolutionsResponse) ProtoMessage

func (*EndSearchSolutionsResponse) ProtoMessage()

func (*EndSearchSolutionsResponse) Reset

func (m *EndSearchSolutionsResponse) Reset()

func (*EndSearchSolutionsResponse) String

func (m *EndSearchSolutionsResponse) String() string

func (*EndSearchSolutionsResponse) XXX_DiscardUnknown

func (m *EndSearchSolutionsResponse) XXX_DiscardUnknown()

func (*EndSearchSolutionsResponse) XXX_Marshal

func (m *EndSearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndSearchSolutionsResponse) XXX_Merge

func (m *EndSearchSolutionsResponse) XXX_Merge(src proto.Message)

func (*EndSearchSolutionsResponse) XXX_Size

func (m *EndSearchSolutionsResponse) XXX_Size() int

func (*EndSearchSolutionsResponse) XXX_Unmarshal

func (m *EndSearchSolutionsResponse) XXX_Unmarshal(b []byte) error

type EvaluationMethod

type EvaluationMethod int32
const (
	// Default value. Not to be used.
	EvaluationMethod_EVALUATION_METHOD_UNDEFINED EvaluationMethod = 0
	// The following are the only evaluation methods required
	// to be supported for the "ScoreSolution" call.
	EvaluationMethod_HOLDOUT EvaluationMethod = 1
	EvaluationMethod_K_FOLD  EvaluationMethod = 2
	// This evaluation method can be used to ask TA2 to rank a
	// solution as part of all found solutions of a given
	// "SearchSolutions" call. Invalid to use before the
	// "SearchSolutions" call, of which the solution is part of,
	// has successfully completed or has been stopped.
	// Only possible with "RANK" performance metric.
	EvaluationMethod_RANKING EvaluationMethod = 99
	// The rest are defined to allow expressing internal evaluation
	// methods used by TA2 during solution search. If any method being used
	// is missing, feel free to request it to be added.
	EvaluationMethod_LEAVE_ONE_OUT EvaluationMethod = 100
	// Instead of really scoring, a TA2 might predict the score only.
	EvaluationMethod_PREDICTION EvaluationMethod = 101
	// Training data is reused to test as well.
	EvaluationMethod_TRAINING_DATA EvaluationMethod = 102
)

func (EvaluationMethod) EnumDescriptor

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

func (EvaluationMethod) String

func (x EvaluationMethod) String() string

type FitSolutionRequest

type FitSolutionRequest struct {
	SolutionId string   `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"`
	Inputs     []*Value `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// List of data references of step outputs which should be exposed to the TA3 system.
	// If you want to expose outputs of the whole pipeline (e.g., predictions themselves),
	// list them here as well. These can be recursive data references like
	// "steps.1.steps.4.produce" to point to an output inside a sub-pipeline.
	// Systems only have to support exposing final outputs and can return "ValueError" for
	// intermediate values.
	ExposeOutputs []string `protobuf:"bytes,3,rep,name=expose_outputs,json=exposeOutputs,proto3" json:"expose_outputs,omitempty"`
	// Which value types should be used for exposing outputs. If not provided, the allowed
	// value types list from the search solutions call is used instead.
	// The order is important as TA2 system will try value types in order until one works out,
	// or an error will be returned instead of the value. An error exposing a value does not
	// stop the overall process.
	ExposeValueTypes []ValueType `` /* 134-byte string literal not displayed */
	// Any users associated with this call itself. Optional.
	Users                []*SolutionRunUser `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Fit the solution on given inputs. If a solution is already fitted on inputs this is a NOOP (if no additional outputs should be exposed). This can happen when a TA2 simultaneously fits the solution as part of the solution search phase.

func (*FitSolutionRequest) Descriptor

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

func (*FitSolutionRequest) GetExposeOutputs

func (m *FitSolutionRequest) GetExposeOutputs() []string

func (*FitSolutionRequest) GetExposeValueTypes

func (m *FitSolutionRequest) GetExposeValueTypes() []ValueType

func (*FitSolutionRequest) GetInputs

func (m *FitSolutionRequest) GetInputs() []*Value

func (*FitSolutionRequest) GetSolutionId

func (m *FitSolutionRequest) GetSolutionId() string

func (*FitSolutionRequest) GetUsers

func (m *FitSolutionRequest) GetUsers() []*SolutionRunUser

func (*FitSolutionRequest) ProtoMessage

func (*FitSolutionRequest) ProtoMessage()

func (*FitSolutionRequest) Reset

func (m *FitSolutionRequest) Reset()

func (*FitSolutionRequest) String

func (m *FitSolutionRequest) String() string

func (*FitSolutionRequest) XXX_DiscardUnknown

func (m *FitSolutionRequest) XXX_DiscardUnknown()

func (*FitSolutionRequest) XXX_Marshal

func (m *FitSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FitSolutionRequest) XXX_Merge

func (m *FitSolutionRequest) XXX_Merge(src proto.Message)

func (*FitSolutionRequest) XXX_Size

func (m *FitSolutionRequest) XXX_Size() int

func (*FitSolutionRequest) XXX_Unmarshal

func (m *FitSolutionRequest) XXX_Unmarshal(b []byte) error

type FitSolutionResponse

type FitSolutionResponse struct {
	RequestId            string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FitSolutionResponse) Descriptor

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

func (*FitSolutionResponse) GetRequestId

func (m *FitSolutionResponse) GetRequestId() string

func (*FitSolutionResponse) ProtoMessage

func (*FitSolutionResponse) ProtoMessage()

func (*FitSolutionResponse) Reset

func (m *FitSolutionResponse) Reset()

func (*FitSolutionResponse) String

func (m *FitSolutionResponse) String() string

func (*FitSolutionResponse) XXX_DiscardUnknown

func (m *FitSolutionResponse) XXX_DiscardUnknown()

func (*FitSolutionResponse) XXX_Marshal

func (m *FitSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FitSolutionResponse) XXX_Merge

func (m *FitSolutionResponse) XXX_Merge(src proto.Message)

func (*FitSolutionResponse) XXX_Size

func (m *FitSolutionResponse) XXX_Size() int

func (*FitSolutionResponse) XXX_Unmarshal

func (m *FitSolutionResponse) XXX_Unmarshal(b []byte) error

type GetFitSolutionResultsRequest

type GetFitSolutionResultsRequest struct {
	RequestId            string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Get the latest state of fitting the solution and start receiving any further new updates to the state as well.

func (*GetFitSolutionResultsRequest) Descriptor

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

func (*GetFitSolutionResultsRequest) GetRequestId

func (m *GetFitSolutionResultsRequest) GetRequestId() string

func (*GetFitSolutionResultsRequest) ProtoMessage

func (*GetFitSolutionResultsRequest) ProtoMessage()

func (*GetFitSolutionResultsRequest) Reset

func (m *GetFitSolutionResultsRequest) Reset()

func (*GetFitSolutionResultsRequest) String

func (*GetFitSolutionResultsRequest) XXX_DiscardUnknown

func (m *GetFitSolutionResultsRequest) XXX_DiscardUnknown()

func (*GetFitSolutionResultsRequest) XXX_Marshal

func (m *GetFitSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFitSolutionResultsRequest) XXX_Merge

func (m *GetFitSolutionResultsRequest) XXX_Merge(src proto.Message)

func (*GetFitSolutionResultsRequest) XXX_Size

func (m *GetFitSolutionResultsRequest) XXX_Size() int

func (*GetFitSolutionResultsRequest) XXX_Unmarshal

func (m *GetFitSolutionResultsRequest) XXX_Unmarshal(b []byte) error

type GetFitSolutionResultsResponse

type GetFitSolutionResultsResponse struct {
	// Overall process progress.
	Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"`
	// The list contains progress for each step in the pipeline, in order.
	// List can be incomplete while the process is in progress. Systems can provide
	// steps only at the end (when "progress" equals COMPLETED) and not during running.
	Steps []*StepProgress `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"`
	// A mapping between data references of step outputs and values.
	ExposedOutputs map[string]*Value `` /* 191-byte string literal not displayed */
	// The fitted solution ID, once progress = COMPLETED.
	FittedSolutionId     string   `protobuf:"bytes,4,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFitSolutionResultsResponse) Descriptor

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

func (*GetFitSolutionResultsResponse) GetExposedOutputs

func (m *GetFitSolutionResultsResponse) GetExposedOutputs() map[string]*Value

func (*GetFitSolutionResultsResponse) GetFittedSolutionId

func (m *GetFitSolutionResultsResponse) GetFittedSolutionId() string

func (*GetFitSolutionResultsResponse) GetProgress

func (m *GetFitSolutionResultsResponse) GetProgress() *Progress

func (*GetFitSolutionResultsResponse) GetSteps

func (*GetFitSolutionResultsResponse) ProtoMessage

func (*GetFitSolutionResultsResponse) ProtoMessage()

func (*GetFitSolutionResultsResponse) Reset

func (m *GetFitSolutionResultsResponse) Reset()

func (*GetFitSolutionResultsResponse) String

func (*GetFitSolutionResultsResponse) XXX_DiscardUnknown

func (m *GetFitSolutionResultsResponse) XXX_DiscardUnknown()

func (*GetFitSolutionResultsResponse) XXX_Marshal

func (m *GetFitSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFitSolutionResultsResponse) XXX_Merge

func (m *GetFitSolutionResultsResponse) XXX_Merge(src proto.Message)

func (*GetFitSolutionResultsResponse) XXX_Size

func (m *GetFitSolutionResultsResponse) XXX_Size() int

func (*GetFitSolutionResultsResponse) XXX_Unmarshal

func (m *GetFitSolutionResultsResponse) XXX_Unmarshal(b []byte) error

type GetProduceSolutionResultsRequest

type GetProduceSolutionResultsRequest struct {
	RequestId            string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Get the latest state of producing the fitted solution and start receiving any further new updates to the state as well.

func (*GetProduceSolutionResultsRequest) Descriptor

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

func (*GetProduceSolutionResultsRequest) GetRequestId

func (m *GetProduceSolutionResultsRequest) GetRequestId() string

func (*GetProduceSolutionResultsRequest) ProtoMessage

func (*GetProduceSolutionResultsRequest) ProtoMessage()

func (*GetProduceSolutionResultsRequest) Reset

func (*GetProduceSolutionResultsRequest) String

func (*GetProduceSolutionResultsRequest) XXX_DiscardUnknown

func (m *GetProduceSolutionResultsRequest) XXX_DiscardUnknown()

func (*GetProduceSolutionResultsRequest) XXX_Marshal

func (m *GetProduceSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetProduceSolutionResultsRequest) XXX_Merge

func (*GetProduceSolutionResultsRequest) XXX_Size

func (m *GetProduceSolutionResultsRequest) XXX_Size() int

func (*GetProduceSolutionResultsRequest) XXX_Unmarshal

func (m *GetProduceSolutionResultsRequest) XXX_Unmarshal(b []byte) error

type GetProduceSolutionResultsResponse

type GetProduceSolutionResultsResponse struct {
	// Overall process progress.
	Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"`
	// The list contains progress for each step in the pipeline, in order.
	// List can be incomplete while the process is in progress. Systems can provide
	// steps only at the end (when "progress" equals COMPLETED) and not during running.
	Steps []*StepProgress `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"`
	// A mapping between data references of step outputs and values.
	ExposedOutputs       map[string]*Value `` /* 191-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetProduceSolutionResultsResponse) Descriptor

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

func (*GetProduceSolutionResultsResponse) GetExposedOutputs

func (m *GetProduceSolutionResultsResponse) GetExposedOutputs() map[string]*Value

func (*GetProduceSolutionResultsResponse) GetProgress

func (m *GetProduceSolutionResultsResponse) GetProgress() *Progress

func (*GetProduceSolutionResultsResponse) GetSteps

func (*GetProduceSolutionResultsResponse) ProtoMessage

func (*GetProduceSolutionResultsResponse) ProtoMessage()

func (*GetProduceSolutionResultsResponse) Reset

func (*GetProduceSolutionResultsResponse) String

func (*GetProduceSolutionResultsResponse) XXX_DiscardUnknown

func (m *GetProduceSolutionResultsResponse) XXX_DiscardUnknown()

func (*GetProduceSolutionResultsResponse) XXX_Marshal

func (m *GetProduceSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetProduceSolutionResultsResponse) XXX_Merge

func (*GetProduceSolutionResultsResponse) XXX_Size

func (m *GetProduceSolutionResultsResponse) XXX_Size() int

func (*GetProduceSolutionResultsResponse) XXX_Unmarshal

func (m *GetProduceSolutionResultsResponse) XXX_Unmarshal(b []byte) error

type GetScoreSolutionResultsRequest

type GetScoreSolutionResultsRequest struct {
	RequestId            string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Get all score results computed until now and start receiving any new score results computed as well.

func (*GetScoreSolutionResultsRequest) Descriptor

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

func (*GetScoreSolutionResultsRequest) GetRequestId

func (m *GetScoreSolutionResultsRequest) GetRequestId() string

func (*GetScoreSolutionResultsRequest) ProtoMessage

func (*GetScoreSolutionResultsRequest) ProtoMessage()

func (*GetScoreSolutionResultsRequest) Reset

func (m *GetScoreSolutionResultsRequest) Reset()

func (*GetScoreSolutionResultsRequest) String

func (*GetScoreSolutionResultsRequest) XXX_DiscardUnknown

func (m *GetScoreSolutionResultsRequest) XXX_DiscardUnknown()

func (*GetScoreSolutionResultsRequest) XXX_Marshal

func (m *GetScoreSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetScoreSolutionResultsRequest) XXX_Merge

func (m *GetScoreSolutionResultsRequest) XXX_Merge(src proto.Message)

func (*GetScoreSolutionResultsRequest) XXX_Size

func (m *GetScoreSolutionResultsRequest) XXX_Size() int

func (*GetScoreSolutionResultsRequest) XXX_Unmarshal

func (m *GetScoreSolutionResultsRequest) XXX_Unmarshal(b []byte) error

type GetScoreSolutionResultsResponse

type GetScoreSolutionResultsResponse struct {
	// Overall process progress.
	Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"`
	// List of score results. List can be incomplete while the process is in progress.
	Scores               []*Score `protobuf:"bytes,2,rep,name=scores,proto3" json:"scores,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetScoreSolutionResultsResponse) Descriptor

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

func (*GetScoreSolutionResultsResponse) GetProgress

func (m *GetScoreSolutionResultsResponse) GetProgress() *Progress

func (*GetScoreSolutionResultsResponse) GetScores

func (m *GetScoreSolutionResultsResponse) GetScores() []*Score

func (*GetScoreSolutionResultsResponse) ProtoMessage

func (*GetScoreSolutionResultsResponse) ProtoMessage()

func (*GetScoreSolutionResultsResponse) Reset

func (*GetScoreSolutionResultsResponse) String

func (*GetScoreSolutionResultsResponse) XXX_DiscardUnknown

func (m *GetScoreSolutionResultsResponse) XXX_DiscardUnknown()

func (*GetScoreSolutionResultsResponse) XXX_Marshal

func (m *GetScoreSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetScoreSolutionResultsResponse) XXX_Merge

func (m *GetScoreSolutionResultsResponse) XXX_Merge(src proto.Message)

func (*GetScoreSolutionResultsResponse) XXX_Size

func (m *GetScoreSolutionResultsResponse) XXX_Size() int

func (*GetScoreSolutionResultsResponse) XXX_Unmarshal

func (m *GetScoreSolutionResultsResponse) XXX_Unmarshal(b []byte) error

type GetSearchSolutionsResultsRequest

type GetSearchSolutionsResultsRequest struct {
	SearchId             string   `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Get all solutions presently identified by the search and start receiving any further solutions also found as well.

func (*GetSearchSolutionsResultsRequest) Descriptor

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

func (*GetSearchSolutionsResultsRequest) GetSearchId

func (m *GetSearchSolutionsResultsRequest) GetSearchId() string

func (*GetSearchSolutionsResultsRequest) ProtoMessage

func (*GetSearchSolutionsResultsRequest) ProtoMessage()

func (*GetSearchSolutionsResultsRequest) Reset

func (*GetSearchSolutionsResultsRequest) String

func (*GetSearchSolutionsResultsRequest) XXX_DiscardUnknown

func (m *GetSearchSolutionsResultsRequest) XXX_DiscardUnknown()

func (*GetSearchSolutionsResultsRequest) XXX_Marshal

func (m *GetSearchSolutionsResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSearchSolutionsResultsRequest) XXX_Merge

func (*GetSearchSolutionsResultsRequest) XXX_Size

func (m *GetSearchSolutionsResultsRequest) XXX_Size() int

func (*GetSearchSolutionsResultsRequest) XXX_Unmarshal

func (m *GetSearchSolutionsResultsRequest) XXX_Unmarshal(b []byte) error

type GetSearchSolutionsResultsResponse

type GetSearchSolutionsResultsResponse struct {
	// Overall process progress, not progress per solution. While solutions are being found and
	// returned, or scores computed and updated, progress state should be kept at "RUNNING".
	Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"`
	// A measure of progress during search. It can be any number of internal steps or
	// actions a TA2 is doing during search. It can be even number of how many candidate
	// solutions were already examined. It does not even have to be an integer.
	// How regularly a change to this number is reported to TA3 is left to TA2's discretion,
	// but a rule of thumb is at least once a minute if the number changes.
	DoneTicks float64 `protobuf:"fixed64,2,opt,name=done_ticks,json=doneTicks,proto3" json:"done_ticks,omitempty"`
	// If TA2 knows how many internal steps or actions are there, it can set this field.
	// This can also be updated through time if more (or even less) internal steps or
	// actions are determined to be necessary. If this value is non-zero, then it should
	// always hold that "done_ticks" <= "all_ticks".
	AllTicks   float64 `protobuf:"fixed64,3,opt,name=all_ticks,json=allTicks,proto3" json:"all_ticks,omitempty"`
	SolutionId string  `protobuf:"bytes,4,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"`
	// Internal score for this solution between 0.0 and 1.0 where 1.0 is the highest score.
	// There is no other meaning to this score and it does not necessary depend on scores
	// listed in the problem description. Optional.
	// Because this field is optional, if omitted the default value will be 0. But 0 is a
	// valid value for this field. Because of that you should never omit the field.
	// If you do not have internal score to provide, use NaN for the value of this field
	// to signal that. When solution cannot be scored (i.e., the fully specified pipeline
	// used as a template is not a standard pipeline) internal score does not have to be
	// provided.
	InternalScore float64 `protobuf:"fixed64,5,opt,name=internal_score,json=internalScore,proto3" json:"internal_score,omitempty"`
	// TA2 might be able to provide more meaningful scores as well, depending on its
	// approach to solution search. Moreover, even the same TA2 might not use the same scoring
	// approach for all of its solutions. Optional. When solution cannot be scored (i.e., the
	// fully specified pipeline used as a template is not a standard pipeline) score does
	// not have to be provided.
	Scores               []*SolutionSearchScore `protobuf:"bytes,6,rep,name=scores,proto3" json:"scores,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetSearchSolutionsResultsResponse) Descriptor

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

func (*GetSearchSolutionsResultsResponse) GetAllTicks

func (m *GetSearchSolutionsResultsResponse) GetAllTicks() float64

func (*GetSearchSolutionsResultsResponse) GetDoneTicks

func (m *GetSearchSolutionsResultsResponse) GetDoneTicks() float64

func (*GetSearchSolutionsResultsResponse) GetInternalScore

func (m *GetSearchSolutionsResultsResponse) GetInternalScore() float64

func (*GetSearchSolutionsResultsResponse) GetProgress

func (m *GetSearchSolutionsResultsResponse) GetProgress() *Progress

func (*GetSearchSolutionsResultsResponse) GetScores

func (*GetSearchSolutionsResultsResponse) GetSolutionId

func (m *GetSearchSolutionsResultsResponse) GetSolutionId() string

func (*GetSearchSolutionsResultsResponse) ProtoMessage

func (*GetSearchSolutionsResultsResponse) ProtoMessage()

func (*GetSearchSolutionsResultsResponse) Reset

func (*GetSearchSolutionsResultsResponse) String

func (*GetSearchSolutionsResultsResponse) XXX_DiscardUnknown

func (m *GetSearchSolutionsResultsResponse) XXX_DiscardUnknown()

func (*GetSearchSolutionsResultsResponse) XXX_Marshal

func (m *GetSearchSolutionsResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSearchSolutionsResultsResponse) XXX_Merge

func (*GetSearchSolutionsResultsResponse) XXX_Size

func (m *GetSearchSolutionsResultsResponse) XXX_Size() int

func (*GetSearchSolutionsResultsResponse) XXX_Unmarshal

func (m *GetSearchSolutionsResultsResponse) XXX_Unmarshal(b []byte) error

type HelloRequest

type HelloRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identify a TA2 and get supported features. This call is also suitable for a ping/pong call to check that the gRPC connection to the TA2 is ready.

func (*HelloRequest) Descriptor

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

func (*HelloRequest) ProtoMessage

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset

func (m *HelloRequest) Reset()

func (*HelloRequest) String

func (m *HelloRequest) String() string

func (*HelloRequest) XXX_DiscardUnknown

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal

func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HelloRequest) XXX_Merge

func (m *HelloRequest) XXX_Merge(src proto.Message)

func (*HelloRequest) XXX_Size

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal

func (m *HelloRequest) XXX_Unmarshal(b []byte) error

type HelloResponse

type HelloResponse struct {
	// Some string identifying the name and version of the TA2 system.
	UserAgent string `protobuf:"bytes,1,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"`
	// Shall be set to "protocol_version" above.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// List of value types that a TA3 system can use to communicate values to a TA2 system.
	// The order is important as a TA3 system should try value types in order until one works
	// out, or an error will be returned instead of the value.
	AllowedValueTypes []ValueType `` /* 137-byte string literal not displayed */
	// List of API extensions that a TA2 supports.
	SupportedExtensions  []string `protobuf:"bytes,4,rep,name=supported_extensions,json=supportedExtensions,proto3" json:"supported_extensions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HelloResponse) Descriptor

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

func (*HelloResponse) GetAllowedValueTypes

func (m *HelloResponse) GetAllowedValueTypes() []ValueType

func (*HelloResponse) GetSupportedExtensions

func (m *HelloResponse) GetSupportedExtensions() []string

func (*HelloResponse) GetUserAgent

func (m *HelloResponse) GetUserAgent() string

func (*HelloResponse) GetVersion

func (m *HelloResponse) GetVersion() string

func (*HelloResponse) ProtoMessage

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset

func (m *HelloResponse) Reset()

func (*HelloResponse) String

func (m *HelloResponse) String() string

func (*HelloResponse) XXX_DiscardUnknown

func (m *HelloResponse) XXX_DiscardUnknown()

func (*HelloResponse) XXX_Marshal

func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HelloResponse) XXX_Merge

func (m *HelloResponse) XXX_Merge(src proto.Message)

func (*HelloResponse) XXX_Size

func (m *HelloResponse) XXX_Size() int

func (*HelloResponse) XXX_Unmarshal

func (m *HelloResponse) XXX_Unmarshal(b []byte) error

type ListPrimitivesRequest

type ListPrimitivesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

List all primitives known to TA2, their IDs, versions, names, and digests. Using this information a TA3 should know which primitives may be put into a pipeline template. To narrow down potential primitives to use a TA3 can also ask a TA2 to do a solution search and then observe which primitives the TA2 is using. If more metadata about primitives is needed, then a TA3 can use the results of this call to map primitives to metadata (from Python code or primitive annotations) on its own.

func (*ListPrimitivesRequest) Descriptor

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

func (*ListPrimitivesRequest) ProtoMessage

func (*ListPrimitivesRequest) ProtoMessage()

func (*ListPrimitivesRequest) Reset

func (m *ListPrimitivesRequest) Reset()

func (*ListPrimitivesRequest) String

func (m *ListPrimitivesRequest) String() string

func (*ListPrimitivesRequest) XXX_DiscardUnknown

func (m *ListPrimitivesRequest) XXX_DiscardUnknown()

func (*ListPrimitivesRequest) XXX_Marshal

func (m *ListPrimitivesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPrimitivesRequest) XXX_Merge

func (m *ListPrimitivesRequest) XXX_Merge(src proto.Message)

func (*ListPrimitivesRequest) XXX_Size

func (m *ListPrimitivesRequest) XXX_Size() int

func (*ListPrimitivesRequest) XXX_Unmarshal

func (m *ListPrimitivesRequest) XXX_Unmarshal(b []byte) error

type ListPrimitivesResponse

type ListPrimitivesResponse struct {
	Primitives           []*Primitive `protobuf:"bytes,1,rep,name=primitives,proto3" json:"primitives,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListPrimitivesResponse) Descriptor

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

func (*ListPrimitivesResponse) GetPrimitives

func (m *ListPrimitivesResponse) GetPrimitives() []*Primitive

func (*ListPrimitivesResponse) ProtoMessage

func (*ListPrimitivesResponse) ProtoMessage()

func (*ListPrimitivesResponse) Reset

func (m *ListPrimitivesResponse) Reset()

func (*ListPrimitivesResponse) String

func (m *ListPrimitivesResponse) String() string

func (*ListPrimitivesResponse) XXX_DiscardUnknown

func (m *ListPrimitivesResponse) XXX_DiscardUnknown()

func (*ListPrimitivesResponse) XXX_Marshal

func (m *ListPrimitivesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPrimitivesResponse) XXX_Merge

func (m *ListPrimitivesResponse) XXX_Merge(src proto.Message)

func (*ListPrimitivesResponse) XXX_Size

func (m *ListPrimitivesResponse) XXX_Size() int

func (*ListPrimitivesResponse) XXX_Unmarshal

func (m *ListPrimitivesResponse) XXX_Unmarshal(b []byte) error

type LoadFittedSolutionRequest

type LoadFittedSolutionRequest struct {
	// An URI pointing to a directory containing a fitted solution.
	FittedSolutionUri    string   `protobuf:"bytes,1,opt,name=fitted_solution_uri,json=fittedSolutionUri,proto3" json:"fitted_solution_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Load a fitted solution that was saved before.

func (*LoadFittedSolutionRequest) Descriptor

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

func (*LoadFittedSolutionRequest) GetFittedSolutionUri

func (m *LoadFittedSolutionRequest) GetFittedSolutionUri() string

func (*LoadFittedSolutionRequest) ProtoMessage

func (*LoadFittedSolutionRequest) ProtoMessage()

func (*LoadFittedSolutionRequest) Reset

func (m *LoadFittedSolutionRequest) Reset()

func (*LoadFittedSolutionRequest) String

func (m *LoadFittedSolutionRequest) String() string

func (*LoadFittedSolutionRequest) XXX_DiscardUnknown

func (m *LoadFittedSolutionRequest) XXX_DiscardUnknown()

func (*LoadFittedSolutionRequest) XXX_Marshal

func (m *LoadFittedSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadFittedSolutionRequest) XXX_Merge

func (m *LoadFittedSolutionRequest) XXX_Merge(src proto.Message)

func (*LoadFittedSolutionRequest) XXX_Size

func (m *LoadFittedSolutionRequest) XXX_Size() int

func (*LoadFittedSolutionRequest) XXX_Unmarshal

func (m *LoadFittedSolutionRequest) XXX_Unmarshal(b []byte) error

type LoadFittedSolutionResponse

type LoadFittedSolutionResponse struct {
	// Fitted solution id loaded.
	FittedSolutionId     string   `protobuf:"bytes,1,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadFittedSolutionResponse) Descriptor

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

func (*LoadFittedSolutionResponse) GetFittedSolutionId

func (m *LoadFittedSolutionResponse) GetFittedSolutionId() string

func (*LoadFittedSolutionResponse) ProtoMessage

func (*LoadFittedSolutionResponse) ProtoMessage()

func (*LoadFittedSolutionResponse) Reset

func (m *LoadFittedSolutionResponse) Reset()

func (*LoadFittedSolutionResponse) String

func (m *LoadFittedSolutionResponse) String() string

func (*LoadFittedSolutionResponse) XXX_DiscardUnknown

func (m *LoadFittedSolutionResponse) XXX_DiscardUnknown()

func (*LoadFittedSolutionResponse) XXX_Marshal

func (m *LoadFittedSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadFittedSolutionResponse) XXX_Merge

func (m *LoadFittedSolutionResponse) XXX_Merge(src proto.Message)

func (*LoadFittedSolutionResponse) XXX_Size

func (m *LoadFittedSolutionResponse) XXX_Size() int

func (*LoadFittedSolutionResponse) XXX_Unmarshal

func (m *LoadFittedSolutionResponse) XXX_Unmarshal(b []byte) error

type LoadSolutionRequest

type LoadSolutionRequest struct {
	// An URI pointing to a directory containing a solution saved.
	SolutionUri          string   `protobuf:"bytes,1,opt,name=solution_uri,json=solutionUri,proto3" json:"solution_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Load a solution that was saved before.

func (*LoadSolutionRequest) Descriptor

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

func (*LoadSolutionRequest) GetSolutionUri

func (m *LoadSolutionRequest) GetSolutionUri() string

func (*LoadSolutionRequest) ProtoMessage

func (*LoadSolutionRequest) ProtoMessage()

func (*LoadSolutionRequest) Reset

func (m *LoadSolutionRequest) Reset()

func (*LoadSolutionRequest) String

func (m *LoadSolutionRequest) String() string

func (*LoadSolutionRequest) XXX_DiscardUnknown

func (m *LoadSolutionRequest) XXX_DiscardUnknown()

func (*LoadSolutionRequest) XXX_Marshal

func (m *LoadSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadSolutionRequest) XXX_Merge

func (m *LoadSolutionRequest) XXX_Merge(src proto.Message)

func (*LoadSolutionRequest) XXX_Size

func (m *LoadSolutionRequest) XXX_Size() int

func (*LoadSolutionRequest) XXX_Unmarshal

func (m *LoadSolutionRequest) XXX_Unmarshal(b []byte) error

type LoadSolutionResponse

type LoadSolutionResponse struct {
	// Id of solution which was loaded.
	SolutionId           string   `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadSolutionResponse) Descriptor

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

func (*LoadSolutionResponse) GetSolutionId

func (m *LoadSolutionResponse) GetSolutionId() string

func (*LoadSolutionResponse) ProtoMessage

func (*LoadSolutionResponse) ProtoMessage()

func (*LoadSolutionResponse) Reset

func (m *LoadSolutionResponse) Reset()

func (*LoadSolutionResponse) String

func (m *LoadSolutionResponse) String() string

func (*LoadSolutionResponse) XXX_DiscardUnknown

func (m *LoadSolutionResponse) XXX_DiscardUnknown()

func (*LoadSolutionResponse) XXX_Marshal

func (m *LoadSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadSolutionResponse) XXX_Merge

func (m *LoadSolutionResponse) XXX_Merge(src proto.Message)

func (*LoadSolutionResponse) XXX_Size

func (m *LoadSolutionResponse) XXX_Size() int

func (*LoadSolutionResponse) XXX_Unmarshal

func (m *LoadSolutionResponse) XXX_Unmarshal(b []byte) error

type NullValue

type NullValue int32
const (
	NullValue_NULL_VALUE NullValue = 0
)

func (NullValue) EnumDescriptor

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

func (NullValue) String

func (x NullValue) String() string

type PerformanceMetric

type PerformanceMetric int32

The evaluation metric for any potential solution.

const (
	// Default value. Not to be used.
	PerformanceMetric_METRIC_UNDEFINED PerformanceMetric = 0
	// The following are the only evaluation methods required
	// to be supported for the ScoreSolution call.
	PerformanceMetric_ACCURACY                           PerformanceMetric = 1
	PerformanceMetric_PRECISION                          PerformanceMetric = 2
	PerformanceMetric_RECALL                             PerformanceMetric = 3
	PerformanceMetric_F1                                 PerformanceMetric = 4
	PerformanceMetric_F1_MICRO                           PerformanceMetric = 5
	PerformanceMetric_F1_MACRO                           PerformanceMetric = 6
	PerformanceMetric_ROC_AUC                            PerformanceMetric = 7
	PerformanceMetric_ROC_AUC_MICRO                      PerformanceMetric = 8
	PerformanceMetric_ROC_AUC_MACRO                      PerformanceMetric = 9
	PerformanceMetric_MEAN_SQUARED_ERROR                 PerformanceMetric = 10
	PerformanceMetric_ROOT_MEAN_SQUARED_ERROR            PerformanceMetric = 11
	PerformanceMetric_MEAN_ABSOLUTE_ERROR                PerformanceMetric = 12
	PerformanceMetric_R_SQUARED                          PerformanceMetric = 13
	PerformanceMetric_NORMALIZED_MUTUAL_INFORMATION      PerformanceMetric = 14
	PerformanceMetric_JACCARD_SIMILARITY_SCORE           PerformanceMetric = 15
	PerformanceMetric_PRECISION_AT_TOP_K                 PerformanceMetric = 17
	PerformanceMetric_OBJECT_DETECTION_AVERAGE_PRECISION PerformanceMetric = 18
	PerformanceMetric_HAMMING_LOSS                       PerformanceMetric = 19
	// This metric can be used to ask TA2 to rank a solution as part of
	// all found solutions of a given "SearchSolutions" call. Rank is a
	// floating-point number. Lower numbers represent better solutions.
	// Presently evaluation requirements are that ranks should be non-negative
	// and that each ranked pipeline have a different rank (for all
	// solutions of a given SearchSolutions call). Only possible with
	// "RANKING" evaluation method.
	PerformanceMetric_RANK PerformanceMetric = 99
	// The rest are defined to allow expressing internal evaluation
	// scores used by TA2 during pipeline search. If any you are using
	// is missing, feel free to request it to be added.
	// Average loss of an unspecified loss function.
	PerformanceMetric_LOSS PerformanceMetric = 100
)

func (PerformanceMetric) EnumDescriptor

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

func (PerformanceMetric) String

func (x PerformanceMetric) String() string

type PipelineContext

type PipelineContext int32

TODO: Deprecated. Remove.

const (
	PipelineContext_PIPELINE_CONTEXT_UNKNOWN PipelineContext = 0
	PipelineContext_PRETRAINING              PipelineContext = 1
	PipelineContext_TESTING                  PipelineContext = 2
	PipelineContext_EVALUATION               PipelineContext = 3
	PipelineContext_PRODUCTION               PipelineContext = 4
)

func (PipelineContext) EnumDescriptor

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

func (PipelineContext) String

func (x PipelineContext) String() string

type PipelineDescription

type PipelineDescription struct {
	// TA2: UUID of the pipeline. Templates do not have IDs. But TA3 might provide it for a fully
	// specified pipeline. It does not necessary have to match "solution_id" from
	// "ListSolutionsResponse" and other related messages. Those IDs are about whole solutions
	// (pipeline, potentially fitted, with set hyper-parameters). This here ID is about this
	// particular ID description.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// "schema" field is not needed because it is fixed by the TA2-TA3 protocol version.
	// System which generated a pipeline or a template. Optional.
	Source *PipelineSource `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// TA2: Timestamp when created. Templates do not have this timestamp. TA3 might provide it for
	// a fully specified pipeline.
	Created *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"`
	// TODO: Deprecated. Remove.
	Context PipelineContext `protobuf:"varint,4,opt,name=context,proto3,enum=PipelineContext" json:"context,omitempty"` // Deprecated: Do not use.
	// Human friendly name of the pipeline. For templates it can be a hint to
	// TA2 how to name found pipelines. Optional.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// Human friendly description of the pipeline. Optional.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// List of users associated with the creation of the template and consequently of the pipeline.
	// TA2 can store this information into metalearning database. TA2 is not really expected to use
	// this information during pipeline search. TA2 should not have to understand TA3 users, mapping
	// between users and pipeline search IDs is something TA3 should handle. Optional.
	Users []*PipelineDescriptionUser `protobuf:"bytes,7,rep,name=users,proto3" json:"users,omitempty"`
	// In most cases inputs are datasets. But if TA3 wants to jut run a primitive, it can send a
	// template with only that primitive in the template, and then pass anything to its inputs during
	// execution. Here, we are describing possible inputs to the pipeline or template. Order matters.
	Inputs []*PipelineDescriptionInput `protobuf:"bytes,8,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Available outputs of the pipeline or template.
	Outputs []*PipelineDescriptionOutput `protobuf:"bytes,9,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Steps defining the pipeline.
	Steps                []*PipelineDescriptionStep `protobuf:"bytes,10,rep,name=steps,proto3" json:"steps,omitempty"`
	Digest               string                     `protobuf:"bytes,11,opt,name=digest,proto3" json:"digest,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Pipeline description matches the D3M pipeline description. It serves two purposes: describing found pipelines by TA2 to TA3, and communicating pipeline templates by TA3 to TA2. Because of this some fields are reasonable only in one of those uses. They are marked with "TA2" or "TA3" in the comment, for fields which are primarily to be set only by TA2 or only by TA3, respectively.

func (*PipelineDescription) Descriptor

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

func (*PipelineDescription) GetContext deprecated

func (m *PipelineDescription) GetContext() PipelineContext

Deprecated: Do not use.

func (*PipelineDescription) GetCreated

func (m *PipelineDescription) GetCreated() *timestamp.Timestamp

func (*PipelineDescription) GetDescription

func (m *PipelineDescription) GetDescription() string

func (*PipelineDescription) GetDigest

func (m *PipelineDescription) GetDigest() string

func (*PipelineDescription) GetId

func (m *PipelineDescription) GetId() string

func (*PipelineDescription) GetInputs

func (*PipelineDescription) GetName

func (m *PipelineDescription) GetName() string

func (*PipelineDescription) GetOutputs

func (*PipelineDescription) GetSource

func (m *PipelineDescription) GetSource() *PipelineSource

func (*PipelineDescription) GetSteps

func (*PipelineDescription) GetUsers

func (*PipelineDescription) ProtoMessage

func (*PipelineDescription) ProtoMessage()

func (*PipelineDescription) Reset

func (m *PipelineDescription) Reset()

func (*PipelineDescription) String

func (m *PipelineDescription) String() string

func (*PipelineDescription) XXX_DiscardUnknown

func (m *PipelineDescription) XXX_DiscardUnknown()

func (*PipelineDescription) XXX_Marshal

func (m *PipelineDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineDescription) XXX_Merge

func (m *PipelineDescription) XXX_Merge(src proto.Message)

func (*PipelineDescription) XXX_Size

func (m *PipelineDescription) XXX_Size() int

func (*PipelineDescription) XXX_Unmarshal

func (m *PipelineDescription) XXX_Unmarshal(b []byte) error

type PipelineDescriptionInput

type PipelineDescriptionInput struct {
	// Human friendly name of the input.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Possible input to the pipeline or template.

func (*PipelineDescriptionInput) Descriptor

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

func (*PipelineDescriptionInput) GetName

func (m *PipelineDescriptionInput) GetName() string

func (*PipelineDescriptionInput) ProtoMessage

func (*PipelineDescriptionInput) ProtoMessage()

func (*PipelineDescriptionInput) Reset

func (m *PipelineDescriptionInput) Reset()

func (*PipelineDescriptionInput) String

func (m *PipelineDescriptionInput) String() string

func (*PipelineDescriptionInput) XXX_DiscardUnknown

func (m *PipelineDescriptionInput) XXX_DiscardUnknown()

func (*PipelineDescriptionInput) XXX_Marshal

func (m *PipelineDescriptionInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineDescriptionInput) XXX_Merge

func (m *PipelineDescriptionInput) XXX_Merge(src proto.Message)

func (*PipelineDescriptionInput) XXX_Size

func (m *PipelineDescriptionInput) XXX_Size() int

func (*PipelineDescriptionInput) XXX_Unmarshal

func (m *PipelineDescriptionInput) XXX_Unmarshal(b []byte) error

type PipelineDescriptionOutput

type PipelineDescriptionOutput struct {
	// Human friendly name of the output.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Data reference, probably of an output of a step.
	Data                 string   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Available output of the pipeline or template.

func (*PipelineDescriptionOutput) Descriptor

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

func (*PipelineDescriptionOutput) GetData

func (m *PipelineDescriptionOutput) GetData() string

func (*PipelineDescriptionOutput) GetName

func (m *PipelineDescriptionOutput) GetName() string

func (*PipelineDescriptionOutput) ProtoMessage

func (*PipelineDescriptionOutput) ProtoMessage()

func (*PipelineDescriptionOutput) Reset

func (m *PipelineDescriptionOutput) Reset()

func (*PipelineDescriptionOutput) String

func (m *PipelineDescriptionOutput) String() string

func (*PipelineDescriptionOutput) XXX_DiscardUnknown

func (m *PipelineDescriptionOutput) XXX_DiscardUnknown()

func (*PipelineDescriptionOutput) XXX_Marshal

func (m *PipelineDescriptionOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineDescriptionOutput) XXX_Merge

func (m *PipelineDescriptionOutput) XXX_Merge(src proto.Message)

func (*PipelineDescriptionOutput) XXX_Size

func (m *PipelineDescriptionOutput) XXX_Size() int

func (*PipelineDescriptionOutput) XXX_Unmarshal

func (m *PipelineDescriptionOutput) XXX_Unmarshal(b []byte) error

type PipelineDescriptionStep

type PipelineDescriptionStep struct {
	// Types that are valid to be assigned to Step:
	//	*PipelineDescriptionStep_Primitive
	//	*PipelineDescriptionStep_Pipeline
	//	*PipelineDescriptionStep_Placeholder
	Step                 isPipelineDescriptionStep_Step `protobuf_oneof:"step"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*PipelineDescriptionStep) Descriptor

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

func (*PipelineDescriptionStep) GetPipeline

func (*PipelineDescriptionStep) GetPlaceholder

func (*PipelineDescriptionStep) GetPrimitive

func (*PipelineDescriptionStep) GetStep

func (m *PipelineDescriptionStep) GetStep() isPipelineDescriptionStep_Step

func (*PipelineDescriptionStep) ProtoMessage

func (*PipelineDescriptionStep) ProtoMessage()

func (*PipelineDescriptionStep) Reset

func (m *PipelineDescriptionStep) Reset()

func (*PipelineDescriptionStep) String

func (m *PipelineDescriptionStep) String() string

func (*PipelineDescriptionStep) XXX_DiscardUnknown

func (m *PipelineDescriptionStep) XXX_DiscardUnknown()

func (*PipelineDescriptionStep) XXX_Marshal

func (m *PipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineDescriptionStep) XXX_Merge

func (m *PipelineDescriptionStep) XXX_Merge(src proto.Message)

func (*PipelineDescriptionStep) XXX_OneofFuncs

func (*PipelineDescriptionStep) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*PipelineDescriptionStep) XXX_Size

func (m *PipelineDescriptionStep) XXX_Size() int

func (*PipelineDescriptionStep) XXX_Unmarshal

func (m *PipelineDescriptionStep) XXX_Unmarshal(b []byte) error

type PipelineDescriptionStep_Pipeline

type PipelineDescriptionStep_Pipeline struct {
	Pipeline *SubpipelinePipelineDescriptionStep `protobuf:"bytes,2,opt,name=pipeline,proto3,oneof"`
}

type PipelineDescriptionStep_Placeholder

type PipelineDescriptionStep_Placeholder struct {
	Placeholder *PlaceholderPipelineDescriptionStep `protobuf:"bytes,3,opt,name=placeholder,proto3,oneof"`
}

type PipelineDescriptionStep_Primitive

type PipelineDescriptionStep_Primitive struct {
	Primitive *PrimitivePipelineDescriptionStep `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}

type PipelineDescriptionUser

type PipelineDescriptionUser struct {
	// Globally unique ID for this user. It can be opaque, but it should identify the same user
	// across sessions. Consider using UUID variant 5 with namespace set to the name of your system
	// and name to an ID in your system's database. It does not have to map to any real ID, just
	// that it is possible to connect multiple pipelines/templates by the same user together,
	// if necessary.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A natural language description of what the user did to be on the list, e.g., "Picked
	// a pipeline from a list of pipelines.".
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// A natural language description by the user of what the user did,
	// e.g., "I picked a pipeline because it looks short in comparison with others.".
	Rationale            string   `protobuf:"bytes,3,opt,name=rationale,proto3" json:"rationale,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

User associated with the creation of the template/pipeline, or selection of a primitive.

func (*PipelineDescriptionUser) Descriptor

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

func (*PipelineDescriptionUser) GetId

func (m *PipelineDescriptionUser) GetId() string

func (*PipelineDescriptionUser) GetRationale

func (m *PipelineDescriptionUser) GetRationale() string

func (*PipelineDescriptionUser) GetReason

func (m *PipelineDescriptionUser) GetReason() string

func (*PipelineDescriptionUser) ProtoMessage

func (*PipelineDescriptionUser) ProtoMessage()

func (*PipelineDescriptionUser) Reset

func (m *PipelineDescriptionUser) Reset()

func (*PipelineDescriptionUser) String

func (m *PipelineDescriptionUser) String() string

func (*PipelineDescriptionUser) XXX_DiscardUnknown

func (m *PipelineDescriptionUser) XXX_DiscardUnknown()

func (*PipelineDescriptionUser) XXX_Marshal

func (m *PipelineDescriptionUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineDescriptionUser) XXX_Merge

func (m *PipelineDescriptionUser) XXX_Merge(src proto.Message)

func (*PipelineDescriptionUser) XXX_Size

func (m *PipelineDescriptionUser) XXX_Size() int

func (*PipelineDescriptionUser) XXX_Unmarshal

func (m *PipelineDescriptionUser) XXX_Unmarshal(b []byte) error

type PipelineSource

type PipelineSource struct {
	// String representing name of the author, team.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// An URI to contact the source.
	Contact string `protobuf:"bytes,2,opt,name=contact,proto3" json:"contact,omitempty"`
	// A list of pipelines used to derive the pipeline.
	Pipelines            []*PipelineDescription `protobuf:"bytes,3,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*PipelineSource) Descriptor

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

func (*PipelineSource) GetContact

func (m *PipelineSource) GetContact() string

func (*PipelineSource) GetName

func (m *PipelineSource) GetName() string

func (*PipelineSource) GetPipelines

func (m *PipelineSource) GetPipelines() []*PipelineDescription

func (*PipelineSource) ProtoMessage

func (*PipelineSource) ProtoMessage()

func (*PipelineSource) Reset

func (m *PipelineSource) Reset()

func (*PipelineSource) String

func (m *PipelineSource) String() string

func (*PipelineSource) XXX_DiscardUnknown

func (m *PipelineSource) XXX_DiscardUnknown()

func (*PipelineSource) XXX_Marshal

func (m *PipelineSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineSource) XXX_Merge

func (m *PipelineSource) XXX_Merge(src proto.Message)

func (*PipelineSource) XXX_Size

func (m *PipelineSource) XXX_Size() int

func (*PipelineSource) XXX_Unmarshal

func (m *PipelineSource) XXX_Unmarshal(b []byte) error

type PlaceholderPipelineDescriptionStep

type PlaceholderPipelineDescriptionStep struct {
	// List of inputs which can be used as inputs to resulting sub-pipeline. Resulting
	// sub-pipeline does not have to use all the inputs, but it cannot use any other inputs.
	Inputs []*StepInput `protobuf:"bytes,1,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// A list of outputs of the resulting sub-pipeline.
	Outputs              []*StepOutput `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Used to represent a pipeline template which can be used to generate full pipelines. A placeholder is replaced with a pipeline step to form a pipeline. See README.md for restrictions on the number of them, their position, allowed inputs and outputs, etc.

func (*PlaceholderPipelineDescriptionStep) Descriptor

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

func (*PlaceholderPipelineDescriptionStep) GetInputs

func (*PlaceholderPipelineDescriptionStep) GetOutputs

func (*PlaceholderPipelineDescriptionStep) ProtoMessage

func (*PlaceholderPipelineDescriptionStep) ProtoMessage()

func (*PlaceholderPipelineDescriptionStep) Reset

func (*PlaceholderPipelineDescriptionStep) String

func (*PlaceholderPipelineDescriptionStep) XXX_DiscardUnknown

func (m *PlaceholderPipelineDescriptionStep) XXX_DiscardUnknown()

func (*PlaceholderPipelineDescriptionStep) XXX_Marshal

func (m *PlaceholderPipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlaceholderPipelineDescriptionStep) XXX_Merge

func (*PlaceholderPipelineDescriptionStep) XXX_Size

func (*PlaceholderPipelineDescriptionStep) XXX_Unmarshal

func (m *PlaceholderPipelineDescriptionStep) XXX_Unmarshal(b []byte) error

type Primitive

type Primitive struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Version    string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	PythonPath string `protobuf:"bytes,3,opt,name=python_path,json=pythonPath,proto3" json:"python_path,omitempty"`
	Name       string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Digest is optional, because some locally registered primitives might not have it.
	// But for all primitives published it is available and it should be provided here as well.
	Digest               string   `protobuf:"bytes,5,opt,name=digest,proto3" json:"digest,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Description of the primitive.

func (*Primitive) Descriptor

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

func (*Primitive) GetDigest

func (m *Primitive) GetDigest() string

func (*Primitive) GetId

func (m *Primitive) GetId() string

func (*Primitive) GetName

func (m *Primitive) GetName() string

func (*Primitive) GetPythonPath

func (m *Primitive) GetPythonPath() string

func (*Primitive) GetVersion

func (m *Primitive) GetVersion() string

func (*Primitive) ProtoMessage

func (*Primitive) ProtoMessage()

func (*Primitive) Reset

func (m *Primitive) Reset()

func (*Primitive) String

func (m *Primitive) String() string

func (*Primitive) XXX_DiscardUnknown

func (m *Primitive) XXX_DiscardUnknown()

func (*Primitive) XXX_Marshal

func (m *Primitive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Primitive) XXX_Merge

func (m *Primitive) XXX_Merge(src proto.Message)

func (*Primitive) XXX_Size

func (m *Primitive) XXX_Size() int

func (*Primitive) XXX_Unmarshal

func (m *Primitive) XXX_Unmarshal(b []byte) error

type PrimitiveArgument

type PrimitiveArgument struct {
	// 0-based index identifying a step of which primitive is used as a value.
	Data                 int32    `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrimitiveArgument) Descriptor

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

func (*PrimitiveArgument) GetData

func (m *PrimitiveArgument) GetData() int32

func (*PrimitiveArgument) ProtoMessage

func (*PrimitiveArgument) ProtoMessage()

func (*PrimitiveArgument) Reset

func (m *PrimitiveArgument) Reset()

func (*PrimitiveArgument) String

func (m *PrimitiveArgument) String() string

func (*PrimitiveArgument) XXX_DiscardUnknown

func (m *PrimitiveArgument) XXX_DiscardUnknown()

func (*PrimitiveArgument) XXX_Marshal

func (m *PrimitiveArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrimitiveArgument) XXX_Merge

func (m *PrimitiveArgument) XXX_Merge(src proto.Message)

func (*PrimitiveArgument) XXX_Size

func (m *PrimitiveArgument) XXX_Size() int

func (*PrimitiveArgument) XXX_Unmarshal

func (m *PrimitiveArgument) XXX_Unmarshal(b []byte) error

type PrimitiveArguments

type PrimitiveArguments struct {
	// 0-based index identifying a step of which primitive is used as a value.
	Data                 []int32  `protobuf:"varint,1,rep,packed,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrimitiveArguments) Descriptor

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

func (*PrimitiveArguments) GetData

func (m *PrimitiveArguments) GetData() []int32

func (*PrimitiveArguments) ProtoMessage

func (*PrimitiveArguments) ProtoMessage()

func (*PrimitiveArguments) Reset

func (m *PrimitiveArguments) Reset()

func (*PrimitiveArguments) String

func (m *PrimitiveArguments) String() string

func (*PrimitiveArguments) XXX_DiscardUnknown

func (m *PrimitiveArguments) XXX_DiscardUnknown()

func (*PrimitiveArguments) XXX_Marshal

func (m *PrimitiveArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrimitiveArguments) XXX_Merge

func (m *PrimitiveArguments) XXX_Merge(src proto.Message)

func (*PrimitiveArguments) XXX_Size

func (m *PrimitiveArguments) XXX_Size() int

func (*PrimitiveArguments) XXX_Unmarshal

func (m *PrimitiveArguments) XXX_Unmarshal(b []byte) error

type PrimitivePipelineDescriptionStep

type PrimitivePipelineDescriptionStep struct {
	Primitive *Primitive `protobuf:"bytes,1,opt,name=primitive,proto3" json:"primitive,omitempty"`
	// Arguments to the primitive. Constructor arguments should not be listed here, because they
	// can be automatically created from other information. All these arguments are listed as kind
	// "PIPELINE" in primitive's metadata.
	Arguments map[string]*PrimitiveStepArgument `` /* 159-byte string literal not displayed */
	// List of produce methods providing data. One can reference using data reference these outputs
	// then in arguments (inputs) in other steps or pipeline outputs.
	Outputs []*StepOutput `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Some hyper-parameters are not really tunable and should be fixed as part of template/pipeline.
	// This can be done here. Hyper-parameters listed here cannot be tuned or overridden. Author of a
	// template/pipeline decides which hyper-parameter are which, probably based on their semantic type.
	// TA3 can specify a list of hyper-parameters to fix, and TA2 can add to the list additional
	// hyper-parameters in found pipelines.
	Hyperparams map[string]*PrimitiveStepHyperparameter `` /* 163-byte string literal not displayed */
	// List of users associated with selection of this primitive/arguments/hyper-parameters. Optional.
	Users                []*PipelineDescriptionUser `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*PrimitivePipelineDescriptionStep) Descriptor

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

func (*PrimitivePipelineDescriptionStep) GetArguments

func (*PrimitivePipelineDescriptionStep) GetHyperparams

func (*PrimitivePipelineDescriptionStep) GetOutputs

func (m *PrimitivePipelineDescriptionStep) GetOutputs() []*StepOutput

func (*PrimitivePipelineDescriptionStep) GetPrimitive

func (m *PrimitivePipelineDescriptionStep) GetPrimitive() *Primitive

func (*PrimitivePipelineDescriptionStep) GetUsers

func (*PrimitivePipelineDescriptionStep) ProtoMessage

func (*PrimitivePipelineDescriptionStep) ProtoMessage()

func (*PrimitivePipelineDescriptionStep) Reset

func (*PrimitivePipelineDescriptionStep) String

func (*PrimitivePipelineDescriptionStep) XXX_DiscardUnknown

func (m *PrimitivePipelineDescriptionStep) XXX_DiscardUnknown()

func (*PrimitivePipelineDescriptionStep) XXX_Marshal

func (m *PrimitivePipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrimitivePipelineDescriptionStep) XXX_Merge

func (*PrimitivePipelineDescriptionStep) XXX_Size

func (m *PrimitivePipelineDescriptionStep) XXX_Size() int

func (*PrimitivePipelineDescriptionStep) XXX_Unmarshal

func (m *PrimitivePipelineDescriptionStep) XXX_Unmarshal(b []byte) error

type PrimitiveStepArgument

type PrimitiveStepArgument struct {
	// Types that are valid to be assigned to Argument:
	//	*PrimitiveStepArgument_Container
	//	*PrimitiveStepArgument_Data
	//	*PrimitiveStepArgument_ContainerList
	Argument             isPrimitiveStepArgument_Argument `protobuf_oneof:"argument"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*PrimitiveStepArgument) Descriptor

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

func (*PrimitiveStepArgument) GetArgument

func (m *PrimitiveStepArgument) GetArgument() isPrimitiveStepArgument_Argument

func (*PrimitiveStepArgument) GetContainer

func (m *PrimitiveStepArgument) GetContainer() *ContainerArgument

func (*PrimitiveStepArgument) GetContainerList

func (m *PrimitiveStepArgument) GetContainerList() *ContainerArguments

func (*PrimitiveStepArgument) GetData

func (m *PrimitiveStepArgument) GetData() *DataArgument

func (*PrimitiveStepArgument) ProtoMessage

func (*PrimitiveStepArgument) ProtoMessage()

func (*PrimitiveStepArgument) Reset

func (m *PrimitiveStepArgument) Reset()

func (*PrimitiveStepArgument) String

func (m *PrimitiveStepArgument) String() string

func (*PrimitiveStepArgument) XXX_DiscardUnknown

func (m *PrimitiveStepArgument) XXX_DiscardUnknown()

func (*PrimitiveStepArgument) XXX_Marshal

func (m *PrimitiveStepArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrimitiveStepArgument) XXX_Merge

func (m *PrimitiveStepArgument) XXX_Merge(src proto.Message)

func (*PrimitiveStepArgument) XXX_OneofFuncs

func (*PrimitiveStepArgument) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*PrimitiveStepArgument) XXX_Size

func (m *PrimitiveStepArgument) XXX_Size() int

func (*PrimitiveStepArgument) XXX_Unmarshal

func (m *PrimitiveStepArgument) XXX_Unmarshal(b []byte) error

type PrimitiveStepArgument_Container

type PrimitiveStepArgument_Container struct {
	Container *ContainerArgument `protobuf:"bytes,1,opt,name=container,proto3,oneof"`
}

type PrimitiveStepArgument_ContainerList

type PrimitiveStepArgument_ContainerList struct {
	ContainerList *ContainerArguments `protobuf:"bytes,3,opt,name=container_list,json=containerList,proto3,oneof"`
}

type PrimitiveStepArgument_Data

type PrimitiveStepArgument_Data struct {
	Data *DataArgument `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type PrimitiveStepDescription

type PrimitiveStepDescription struct {
	// Selected value for free pipeline hyper-parameters.
	Hyperparams          map[string]*Value `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PrimitiveStepDescription) Descriptor

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

func (*PrimitiveStepDescription) GetHyperparams

func (m *PrimitiveStepDescription) GetHyperparams() map[string]*Value

func (*PrimitiveStepDescription) ProtoMessage

func (*PrimitiveStepDescription) ProtoMessage()

func (*PrimitiveStepDescription) Reset

func (m *PrimitiveStepDescription) Reset()

func (*PrimitiveStepDescription) String

func (m *PrimitiveStepDescription) String() string

func (*PrimitiveStepDescription) XXX_DiscardUnknown

func (m *PrimitiveStepDescription) XXX_DiscardUnknown()

func (*PrimitiveStepDescription) XXX_Marshal

func (m *PrimitiveStepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrimitiveStepDescription) XXX_Merge

func (m *PrimitiveStepDescription) XXX_Merge(src proto.Message)

func (*PrimitiveStepDescription) XXX_Size

func (m *PrimitiveStepDescription) XXX_Size() int

func (*PrimitiveStepDescription) XXX_Unmarshal

func (m *PrimitiveStepDescription) XXX_Unmarshal(b []byte) error

type PrimitiveStepHyperparameter

type PrimitiveStepHyperparameter struct {
	// Types that are valid to be assigned to Argument:
	//	*PrimitiveStepHyperparameter_Container
	//	*PrimitiveStepHyperparameter_Data
	//	*PrimitiveStepHyperparameter_Primitive
	//	*PrimitiveStepHyperparameter_Value
	//	*PrimitiveStepHyperparameter_DataSet
	//	*PrimitiveStepHyperparameter_PrimitivesSet
	Argument             isPrimitiveStepHyperparameter_Argument `protobuf_oneof:"argument"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*PrimitiveStepHyperparameter) Descriptor

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

func (*PrimitiveStepHyperparameter) GetArgument

func (m *PrimitiveStepHyperparameter) GetArgument() isPrimitiveStepHyperparameter_Argument

func (*PrimitiveStepHyperparameter) GetContainer

func (*PrimitiveStepHyperparameter) GetData

func (*PrimitiveStepHyperparameter) GetDataSet

func (m *PrimitiveStepHyperparameter) GetDataSet() *DataArguments

func (*PrimitiveStepHyperparameter) GetPrimitive

func (*PrimitiveStepHyperparameter) GetPrimitivesSet

func (m *PrimitiveStepHyperparameter) GetPrimitivesSet() *PrimitiveArguments

func (*PrimitiveStepHyperparameter) GetValue

func (*PrimitiveStepHyperparameter) ProtoMessage

func (*PrimitiveStepHyperparameter) ProtoMessage()

func (*PrimitiveStepHyperparameter) Reset

func (m *PrimitiveStepHyperparameter) Reset()

func (*PrimitiveStepHyperparameter) String

func (m *PrimitiveStepHyperparameter) String() string

func (*PrimitiveStepHyperparameter) XXX_DiscardUnknown

func (m *PrimitiveStepHyperparameter) XXX_DiscardUnknown()

func (*PrimitiveStepHyperparameter) XXX_Marshal

func (m *PrimitiveStepHyperparameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrimitiveStepHyperparameter) XXX_Merge

func (m *PrimitiveStepHyperparameter) XXX_Merge(src proto.Message)

func (*PrimitiveStepHyperparameter) XXX_OneofFuncs

func (*PrimitiveStepHyperparameter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*PrimitiveStepHyperparameter) XXX_Size

func (m *PrimitiveStepHyperparameter) XXX_Size() int

func (*PrimitiveStepHyperparameter) XXX_Unmarshal

func (m *PrimitiveStepHyperparameter) XXX_Unmarshal(b []byte) error

type PrimitiveStepHyperparameter_Container

type PrimitiveStepHyperparameter_Container struct {
	Container *ContainerArgument `protobuf:"bytes,1,opt,name=container,proto3,oneof"`
}

type PrimitiveStepHyperparameter_Data

type PrimitiveStepHyperparameter_Data struct {
	Data *DataArgument `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type PrimitiveStepHyperparameter_DataSet

type PrimitiveStepHyperparameter_DataSet struct {
	DataSet *DataArguments `protobuf:"bytes,5,opt,name=data_set,json=dataSet,proto3,oneof"`
}

type PrimitiveStepHyperparameter_Primitive

type PrimitiveStepHyperparameter_Primitive struct {
	Primitive *PrimitiveArgument `protobuf:"bytes,3,opt,name=primitive,proto3,oneof"`
}

type PrimitiveStepHyperparameter_PrimitivesSet

type PrimitiveStepHyperparameter_PrimitivesSet struct {
	PrimitivesSet *PrimitiveArguments `protobuf:"bytes,6,opt,name=primitives_set,json=primitivesSet,proto3,oneof"`
}

type PrimitiveStepHyperparameter_Value

type PrimitiveStepHyperparameter_Value struct {
	Value *ValueArgument `protobuf:"bytes,4,opt,name=value,proto3,oneof"`
}

type Problem

type Problem struct {
	TaskType             TaskType                    `protobuf:"varint,5,opt,name=task_type,json=taskType,proto3,enum=TaskType" json:"task_type,omitempty"`
	TaskSubtype          TaskSubtype                 `protobuf:"varint,6,opt,name=task_subtype,json=taskSubtype,proto3,enum=TaskSubtype" json:"task_subtype,omitempty"`
	PerformanceMetrics   []*ProblemPerformanceMetric `protobuf:"bytes,7,rep,name=performance_metrics,json=performanceMetrics,proto3" json:"performance_metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*Problem) Descriptor

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

func (*Problem) GetPerformanceMetrics

func (m *Problem) GetPerformanceMetrics() []*ProblemPerformanceMetric

func (*Problem) GetTaskSubtype

func (m *Problem) GetTaskSubtype() TaskSubtype

func (*Problem) GetTaskType

func (m *Problem) GetTaskType() TaskType

func (*Problem) ProtoMessage

func (*Problem) ProtoMessage()

func (*Problem) Reset

func (m *Problem) Reset()

func (*Problem) String

func (m *Problem) String() string

func (*Problem) XXX_DiscardUnknown

func (m *Problem) XXX_DiscardUnknown()

func (*Problem) XXX_Marshal

func (m *Problem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Problem) XXX_Merge

func (m *Problem) XXX_Merge(src proto.Message)

func (*Problem) XXX_Size

func (m *Problem) XXX_Size() int

func (*Problem) XXX_Unmarshal

func (m *Problem) XXX_Unmarshal(b []byte) error

type ProblemDescription

type ProblemDescription struct {
	Problem *Problem        `protobuf:"bytes,1,opt,name=problem,proto3" json:"problem,omitempty"`
	Inputs  []*ProblemInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// ID of this problem. Required.
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Version of this problem.
	Version              string              `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Name                 string              `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Description          string              `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Digest               string              `protobuf:"bytes,7,opt,name=digest,proto3" json:"digest,omitempty"`
	DataAugmentation     []*DataAugmentation `protobuf:"bytes,8,rep,name=data_augmentation,json=dataAugmentation,proto3" json:"data_augmentation,omitempty"`
	OtherNames           []string            `protobuf:"bytes,9,rep,name=other_names,json=otherNames,proto3" json:"other_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Problem description matches the parsed problem description by the d3m_metadata.problem.parse_problem_description Python method. Problem outputs are not necessary for the purpose of this API and are needed only when executing an exported pipeline, but then TA2 gets full problem description anyway directly.

func (*ProblemDescription) Descriptor

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

func (*ProblemDescription) GetDataAugmentation

func (m *ProblemDescription) GetDataAugmentation() []*DataAugmentation

func (*ProblemDescription) GetDescription

func (m *ProblemDescription) GetDescription() string

func (*ProblemDescription) GetDigest

func (m *ProblemDescription) GetDigest() string

func (*ProblemDescription) GetId

func (m *ProblemDescription) GetId() string

func (*ProblemDescription) GetInputs

func (m *ProblemDescription) GetInputs() []*ProblemInput

func (*ProblemDescription) GetName

func (m *ProblemDescription) GetName() string

func (*ProblemDescription) GetOtherNames

func (m *ProblemDescription) GetOtherNames() []string

func (*ProblemDescription) GetProblem

func (m *ProblemDescription) GetProblem() *Problem

func (*ProblemDescription) GetVersion

func (m *ProblemDescription) GetVersion() string

func (*ProblemDescription) ProtoMessage

func (*ProblemDescription) ProtoMessage()

func (*ProblemDescription) Reset

func (m *ProblemDescription) Reset()

func (*ProblemDescription) String

func (m *ProblemDescription) String() string

func (*ProblemDescription) XXX_DiscardUnknown

func (m *ProblemDescription) XXX_DiscardUnknown()

func (*ProblemDescription) XXX_Marshal

func (m *ProblemDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProblemDescription) XXX_Merge

func (m *ProblemDescription) XXX_Merge(src proto.Message)

func (*ProblemDescription) XXX_Size

func (m *ProblemDescription) XXX_Size() int

func (*ProblemDescription) XXX_Unmarshal

func (m *ProblemDescription) XXX_Unmarshal(b []byte) error

type ProblemInput

type ProblemInput struct {
	// Should match one of input datasets given to the pipeline search.
	// Every "Dataset" object has an "id" associated with it and is available
	// in its metadata. That ID is then used here to reference those inputs.
	DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// Targets should resolve to columns in a given dataset.
	Targets []*ProblemTarget `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"`
	// A list of privileged data columns related to unavailable attributes during testing.
	// These columns do not have data available in the test split of a dataset.
	PrivilegedData       []*ProblemPrivilegedData `protobuf:"bytes,3,rep,name=privileged_data,json=privilegedData,proto3" json:"privileged_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ProblemInput) Descriptor

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

func (*ProblemInput) GetDatasetId

func (m *ProblemInput) GetDatasetId() string

func (*ProblemInput) GetPrivilegedData

func (m *ProblemInput) GetPrivilegedData() []*ProblemPrivilegedData

func (*ProblemInput) GetTargets

func (m *ProblemInput) GetTargets() []*ProblemTarget

func (*ProblemInput) ProtoMessage

func (*ProblemInput) ProtoMessage()

func (*ProblemInput) Reset

func (m *ProblemInput) Reset()

func (*ProblemInput) String

func (m *ProblemInput) String() string

func (*ProblemInput) XXX_DiscardUnknown

func (m *ProblemInput) XXX_DiscardUnknown()

func (*ProblemInput) XXX_Marshal

func (m *ProblemInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProblemInput) XXX_Merge

func (m *ProblemInput) XXX_Merge(src proto.Message)

func (*ProblemInput) XXX_Size

func (m *ProblemInput) XXX_Size() int

func (*ProblemInput) XXX_Unmarshal

func (m *ProblemInput) XXX_Unmarshal(b []byte) error

type ProblemPerformanceMetric

type ProblemPerformanceMetric struct {
	Metric PerformanceMetric `protobuf:"varint,1,opt,name=metric,proto3,enum=PerformanceMetric" json:"metric,omitempty"`
	// Additional params used by some metrics.
	K                    int32    `protobuf:"varint,2,opt,name=k,proto3" json:"k,omitempty"`
	PosLabel             string   `protobuf:"bytes,3,opt,name=pos_label,json=posLabel,proto3" json:"pos_label,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProblemPerformanceMetric) Descriptor

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

func (*ProblemPerformanceMetric) GetK

func (m *ProblemPerformanceMetric) GetK() int32

func (*ProblemPerformanceMetric) GetMetric

func (*ProblemPerformanceMetric) GetPosLabel

func (m *ProblemPerformanceMetric) GetPosLabel() string

func (*ProblemPerformanceMetric) ProtoMessage

func (*ProblemPerformanceMetric) ProtoMessage()

func (*ProblemPerformanceMetric) Reset

func (m *ProblemPerformanceMetric) Reset()

func (*ProblemPerformanceMetric) String

func (m *ProblemPerformanceMetric) String() string

func (*ProblemPerformanceMetric) XXX_DiscardUnknown

func (m *ProblemPerformanceMetric) XXX_DiscardUnknown()

func (*ProblemPerformanceMetric) XXX_Marshal

func (m *ProblemPerformanceMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProblemPerformanceMetric) XXX_Merge

func (m *ProblemPerformanceMetric) XXX_Merge(src proto.Message)

func (*ProblemPerformanceMetric) XXX_Size

func (m *ProblemPerformanceMetric) XXX_Size() int

func (*ProblemPerformanceMetric) XXX_Unmarshal

func (m *ProblemPerformanceMetric) XXX_Unmarshal(b []byte) error

type ProblemPrivilegedData

type ProblemPrivilegedData struct {
	PrivilegedDataIndex  int32    `protobuf:"varint,1,opt,name=privileged_data_index,json=privilegedDataIndex,proto3" json:"privileged_data_index,omitempty"`
	ResourceId           string   `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ColumnIndex          int32    `protobuf:"varint,3,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"`
	ColumnName           string   `protobuf:"bytes,4,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProblemPrivilegedData) Descriptor

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

func (*ProblemPrivilegedData) GetColumnIndex

func (m *ProblemPrivilegedData) GetColumnIndex() int32

func (*ProblemPrivilegedData) GetColumnName

func (m *ProblemPrivilegedData) GetColumnName() string

func (*ProblemPrivilegedData) GetPrivilegedDataIndex

func (m *ProblemPrivilegedData) GetPrivilegedDataIndex() int32

func (*ProblemPrivilegedData) GetResourceId

func (m *ProblemPrivilegedData) GetResourceId() string

func (*ProblemPrivilegedData) ProtoMessage

func (*ProblemPrivilegedData) ProtoMessage()

func (*ProblemPrivilegedData) Reset

func (m *ProblemPrivilegedData) Reset()

func (*ProblemPrivilegedData) String

func (m *ProblemPrivilegedData) String() string

func (*ProblemPrivilegedData) XXX_DiscardUnknown

func (m *ProblemPrivilegedData) XXX_DiscardUnknown()

func (*ProblemPrivilegedData) XXX_Marshal

func (m *ProblemPrivilegedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProblemPrivilegedData) XXX_Merge

func (m *ProblemPrivilegedData) XXX_Merge(src proto.Message)

func (*ProblemPrivilegedData) XXX_Size

func (m *ProblemPrivilegedData) XXX_Size() int

func (*ProblemPrivilegedData) XXX_Unmarshal

func (m *ProblemPrivilegedData) XXX_Unmarshal(b []byte) error

type ProblemTarget

type ProblemTarget struct {
	TargetIndex          int32    `protobuf:"varint,1,opt,name=target_index,json=targetIndex,proto3" json:"target_index,omitempty"`
	ResourceId           string   `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ColumnIndex          int32    `protobuf:"varint,3,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"`
	ColumnName           string   `protobuf:"bytes,4,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	ClustersNumber       int32    `protobuf:"varint,5,opt,name=clusters_number,json=clustersNumber,proto3" json:"clusters_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProblemTarget) Descriptor

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

func (*ProblemTarget) GetClustersNumber

func (m *ProblemTarget) GetClustersNumber() int32

func (*ProblemTarget) GetColumnIndex

func (m *ProblemTarget) GetColumnIndex() int32

func (*ProblemTarget) GetColumnName

func (m *ProblemTarget) GetColumnName() string

func (*ProblemTarget) GetResourceId

func (m *ProblemTarget) GetResourceId() string

func (*ProblemTarget) GetTargetIndex

func (m *ProblemTarget) GetTargetIndex() int32

func (*ProblemTarget) ProtoMessage

func (*ProblemTarget) ProtoMessage()

func (*ProblemTarget) Reset

func (m *ProblemTarget) Reset()

func (*ProblemTarget) String

func (m *ProblemTarget) String() string

func (*ProblemTarget) XXX_DiscardUnknown

func (m *ProblemTarget) XXX_DiscardUnknown()

func (*ProblemTarget) XXX_Marshal

func (m *ProblemTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProblemTarget) XXX_Merge

func (m *ProblemTarget) XXX_Merge(src proto.Message)

func (*ProblemTarget) XXX_Size

func (m *ProblemTarget) XXX_Size() int

func (*ProblemTarget) XXX_Unmarshal

func (m *ProblemTarget) XXX_Unmarshal(b []byte) error

type ProduceSolutionRequest

type ProduceSolutionRequest struct {
	FittedSolutionId string   `protobuf:"bytes,1,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"`
	Inputs           []*Value `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// List of data references of step outputs which should be exposed to the TA3 system.
	// If you want to expose outputs of the whole pipeline (e.g., predictions themselves),
	// list them here as well. These can be recursive data references like
	// "steps.1.steps.4.produce" to point to an output inside a sub-pipeline.
	// Systems only have to support exposing final outputs and can return "ValueError" for
	// intermediate values.
	ExposeOutputs []string `protobuf:"bytes,3,rep,name=expose_outputs,json=exposeOutputs,proto3" json:"expose_outputs,omitempty"`
	// Which value types should be used for exposing outputs. If not provided, the allowed
	// value types list from the search solutions call is used instead.
	// The order is important as the TA2 system will try value types in order until one works
	// out, or an error will be returned instead of the value. An error exposing a value does
	// not stop the overall process.
	ExposeValueTypes []ValueType `` /* 134-byte string literal not displayed */
	// Any users associated with this call itself. Optional.
	Users                []*SolutionRunUser `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Produce (execute) the solution on given inputs. A solution has to have been fitted for this to be possible (even if in cases where this is just created by transformations).

func (*ProduceSolutionRequest) Descriptor

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

func (*ProduceSolutionRequest) GetExposeOutputs

func (m *ProduceSolutionRequest) GetExposeOutputs() []string

func (*ProduceSolutionRequest) GetExposeValueTypes

func (m *ProduceSolutionRequest) GetExposeValueTypes() []ValueType

func (*ProduceSolutionRequest) GetFittedSolutionId

func (m *ProduceSolutionRequest) GetFittedSolutionId() string

func (*ProduceSolutionRequest) GetInputs

func (m *ProduceSolutionRequest) GetInputs() []*Value

func (*ProduceSolutionRequest) GetUsers

func (m *ProduceSolutionRequest) GetUsers() []*SolutionRunUser

func (*ProduceSolutionRequest) ProtoMessage

func (*ProduceSolutionRequest) ProtoMessage()

func (*ProduceSolutionRequest) Reset

func (m *ProduceSolutionRequest) Reset()

func (*ProduceSolutionRequest) String

func (m *ProduceSolutionRequest) String() string

func (*ProduceSolutionRequest) XXX_DiscardUnknown

func (m *ProduceSolutionRequest) XXX_DiscardUnknown()

func (*ProduceSolutionRequest) XXX_Marshal

func (m *ProduceSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProduceSolutionRequest) XXX_Merge

func (m *ProduceSolutionRequest) XXX_Merge(src proto.Message)

func (*ProduceSolutionRequest) XXX_Size

func (m *ProduceSolutionRequest) XXX_Size() int

func (*ProduceSolutionRequest) XXX_Unmarshal

func (m *ProduceSolutionRequest) XXX_Unmarshal(b []byte) error

type ProduceSolutionResponse

type ProduceSolutionResponse struct {
	RequestId            string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProduceSolutionResponse) Descriptor

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

func (*ProduceSolutionResponse) GetRequestId

func (m *ProduceSolutionResponse) GetRequestId() string

func (*ProduceSolutionResponse) ProtoMessage

func (*ProduceSolutionResponse) ProtoMessage()

func (*ProduceSolutionResponse) Reset

func (m *ProduceSolutionResponse) Reset()

func (*ProduceSolutionResponse) String

func (m *ProduceSolutionResponse) String() string

func (*ProduceSolutionResponse) XXX_DiscardUnknown

func (m *ProduceSolutionResponse) XXX_DiscardUnknown()

func (*ProduceSolutionResponse) XXX_Marshal

func (m *ProduceSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProduceSolutionResponse) XXX_Merge

func (m *ProduceSolutionResponse) XXX_Merge(src proto.Message)

func (*ProduceSolutionResponse) XXX_Size

func (m *ProduceSolutionResponse) XXX_Size() int

func (*ProduceSolutionResponse) XXX_Unmarshal

func (m *ProduceSolutionResponse) XXX_Unmarshal(b []byte) error

type Progress

type Progress struct {
	State  ProgressState `protobuf:"varint,1,opt,name=state,proto3,enum=ProgressState" json:"state,omitempty"`
	Status string        `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Set only after state becomes "RUNNING". If it never really properly runs, but errors
	// when attempted to run, then it should be the timestamp of the error.
	Start *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"`
	// Set only when state is "COMPLETED" or "ERRORED".
	End                  *timestamp.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

After "state" becomes "COMPLETED" or "ERRORED" stream closes. The granularity of progress updates is not specified by the API at this time. Some systems might be updating frequently and provide many updates of the progress of a whole process as well as individual pipeline steps. Some systems might just report these high-level progress states once, not doing any progress updates in the meantime. The "status" field should contain information to supplement the progress state, such as specific failure details in the case of an "ERRORED" state being returned.

func (*Progress) Descriptor

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

func (*Progress) GetEnd

func (m *Progress) GetEnd() *timestamp.Timestamp

func (*Progress) GetStart

func (m *Progress) GetStart() *timestamp.Timestamp

func (*Progress) GetState

func (m *Progress) GetState() ProgressState

func (*Progress) GetStatus

func (m *Progress) GetStatus() string

func (*Progress) ProtoMessage

func (*Progress) ProtoMessage()

func (*Progress) Reset

func (m *Progress) Reset()

func (*Progress) String

func (m *Progress) String() string

func (*Progress) XXX_DiscardUnknown

func (m *Progress) XXX_DiscardUnknown()

func (*Progress) XXX_Marshal

func (m *Progress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Progress) XXX_Merge

func (m *Progress) XXX_Merge(src proto.Message)

func (*Progress) XXX_Size

func (m *Progress) XXX_Size() int

func (*Progress) XXX_Unmarshal

func (m *Progress) XXX_Unmarshal(b []byte) error

type ProgressState

type ProgressState int32
const (
	// Default value. Not to be used.
	ProgressState_PROGRESS_UNKNOWN ProgressState = 0
	// The process has been scheduled but is pending execution.
	ProgressState_PENDING ProgressState = 1
	// The process is currently running. There can be multiple messages with this state
	// (while the process is running).
	ProgressState_RUNNING ProgressState = 2
	// The process completed and final results are available.
	ProgressState_COMPLETED ProgressState = 3
	// The process failed.
	ProgressState_ERRORED ProgressState = 4
)

func (ProgressState) EnumDescriptor

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

func (ProgressState) String

func (x ProgressState) String() string

type RequestNode

type RequestNode interface {
	GetRequestID() string
	GetParent() string
	GetChildren() []string
	GetRequestMsg() interface{}
}

RequestNode stores data for a hierarchical server API request.

type SaveFittedSolutionRequest

type SaveFittedSolutionRequest struct {
	// Fitted solution id to saved.
	FittedSolutionId     string   `protobuf:"bytes,1,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Save a fitted solution that can be loaded later. Optional.

func (*SaveFittedSolutionRequest) Descriptor

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

func (*SaveFittedSolutionRequest) GetFittedSolutionId

func (m *SaveFittedSolutionRequest) GetFittedSolutionId() string

func (*SaveFittedSolutionRequest) ProtoMessage

func (*SaveFittedSolutionRequest) ProtoMessage()

func (*SaveFittedSolutionRequest) Reset

func (m *SaveFittedSolutionRequest) Reset()

func (*SaveFittedSolutionRequest) String

func (m *SaveFittedSolutionRequest) String() string

func (*SaveFittedSolutionRequest) XXX_DiscardUnknown

func (m *SaveFittedSolutionRequest) XXX_DiscardUnknown()

func (*SaveFittedSolutionRequest) XXX_Marshal

func (m *SaveFittedSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SaveFittedSolutionRequest) XXX_Merge

func (m *SaveFittedSolutionRequest) XXX_Merge(src proto.Message)

func (*SaveFittedSolutionRequest) XXX_Size

func (m *SaveFittedSolutionRequest) XXX_Size() int

func (*SaveFittedSolutionRequest) XXX_Unmarshal

func (m *SaveFittedSolutionRequest) XXX_Unmarshal(b []byte) error

type SaveFittedSolutionResponse

type SaveFittedSolutionResponse struct {
	// An URI pointing to a directory containing a fitted solution.
	FittedSolutionUri    string   `protobuf:"bytes,1,opt,name=fitted_solution_uri,json=fittedSolutionUri,proto3" json:"fitted_solution_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SaveFittedSolutionResponse) Descriptor

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

func (*SaveFittedSolutionResponse) GetFittedSolutionUri

func (m *SaveFittedSolutionResponse) GetFittedSolutionUri() string

func (*SaveFittedSolutionResponse) ProtoMessage

func (*SaveFittedSolutionResponse) ProtoMessage()

func (*SaveFittedSolutionResponse) Reset

func (m *SaveFittedSolutionResponse) Reset()

func (*SaveFittedSolutionResponse) String

func (m *SaveFittedSolutionResponse) String() string

func (*SaveFittedSolutionResponse) XXX_DiscardUnknown

func (m *SaveFittedSolutionResponse) XXX_DiscardUnknown()

func (*SaveFittedSolutionResponse) XXX_Marshal

func (m *SaveFittedSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SaveFittedSolutionResponse) XXX_Merge

func (m *SaveFittedSolutionResponse) XXX_Merge(src proto.Message)

func (*SaveFittedSolutionResponse) XXX_Size

func (m *SaveFittedSolutionResponse) XXX_Size() int

func (*SaveFittedSolutionResponse) XXX_Unmarshal

func (m *SaveFittedSolutionResponse) XXX_Unmarshal(b []byte) error

type SaveSolutionRequest

type SaveSolutionRequest struct {
	// Id of solution to saved
	SolutionId           string   `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Save a solution that can be loaded later. (Pipeline description/ Pipeline run) Optional.

func (*SaveSolutionRequest) Descriptor

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

func (*SaveSolutionRequest) GetSolutionId

func (m *SaveSolutionRequest) GetSolutionId() string

func (*SaveSolutionRequest) ProtoMessage

func (*SaveSolutionRequest) ProtoMessage()

func (*SaveSolutionRequest) Reset

func (m *SaveSolutionRequest) Reset()

func (*SaveSolutionRequest) String

func (m *SaveSolutionRequest) String() string

func (*SaveSolutionRequest) XXX_DiscardUnknown

func (m *SaveSolutionRequest) XXX_DiscardUnknown()

func (*SaveSolutionRequest) XXX_Marshal

func (m *SaveSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SaveSolutionRequest) XXX_Merge

func (m *SaveSolutionRequest) XXX_Merge(src proto.Message)

func (*SaveSolutionRequest) XXX_Size

func (m *SaveSolutionRequest) XXX_Size() int

func (*SaveSolutionRequest) XXX_Unmarshal

func (m *SaveSolutionRequest) XXX_Unmarshal(b []byte) error

type SaveSolutionResponse

type SaveSolutionResponse struct {
	// An URI pointing to a directory containing a solution saved.
	SolutionUri          string   `protobuf:"bytes,1,opt,name=solution_uri,json=solutionUri,proto3" json:"solution_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SaveSolutionResponse) Descriptor

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

func (*SaveSolutionResponse) GetSolutionUri

func (m *SaveSolutionResponse) GetSolutionUri() string

func (*SaveSolutionResponse) ProtoMessage

func (*SaveSolutionResponse) ProtoMessage()

func (*SaveSolutionResponse) Reset

func (m *SaveSolutionResponse) Reset()

func (*SaveSolutionResponse) String

func (m *SaveSolutionResponse) String() string

func (*SaveSolutionResponse) XXX_DiscardUnknown

func (m *SaveSolutionResponse) XXX_DiscardUnknown()

func (*SaveSolutionResponse) XXX_Marshal

func (m *SaveSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SaveSolutionResponse) XXX_Merge

func (m *SaveSolutionResponse) XXX_Merge(src proto.Message)

func (*SaveSolutionResponse) XXX_Size

func (m *SaveSolutionResponse) XXX_Size() int

func (*SaveSolutionResponse) XXX_Unmarshal

func (m *SaveSolutionResponse) XXX_Unmarshal(b []byte) error

type Score

type Score struct {
	Metric *ProblemPerformanceMetric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// When doing multiple folds, which fold is this score associated with, 0-based.
	// We do not aggregate scores across folds on the TA2 side, but expose everything to the TA3.
	// If scoring was not done as part of the cross-validation, then it can be returned
	// as the first and only fold, in which case the value of this field should be 0.
	Fold  int32  `protobuf:"varint,2,opt,name=fold,proto3" json:"fold,omitempty"`
	Value *Value `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// Random seed used to run a pipeline for this score to be obtained.
	RandomSeed int32 `protobuf:"varint,5,opt,name=random_seed,json=randomSeed,proto3" json:"random_seed,omitempty"`
	// The normalized value of the scoring metric. Value is from the [0, 1] interval, where higher is better. Optional.
	Normalized           *Value   `protobuf:"bytes,6,opt,name=normalized,proto3" json:"normalized,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Score) Descriptor

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

func (*Score) GetFold

func (m *Score) GetFold() int32

func (*Score) GetMetric

func (m *Score) GetMetric() *ProblemPerformanceMetric

func (*Score) GetNormalized

func (m *Score) GetNormalized() *Value

func (*Score) GetRandomSeed

func (m *Score) GetRandomSeed() int32

func (*Score) GetValue

func (m *Score) GetValue() *Value

func (*Score) ProtoMessage

func (*Score) ProtoMessage()

func (*Score) Reset

func (m *Score) Reset()

func (*Score) String

func (m *Score) String() string

func (*Score) XXX_DiscardUnknown

func (m *Score) XXX_DiscardUnknown()

func (*Score) XXX_Marshal

func (m *Score) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Score) XXX_Merge

func (m *Score) XXX_Merge(src proto.Message)

func (*Score) XXX_Size

func (m *Score) XXX_Size() int

func (*Score) XXX_Unmarshal

func (m *Score) XXX_Unmarshal(b []byte) error

type ScoreSolutionRequest

type ScoreSolutionRequest struct {
	SolutionId         string                      `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"`
	Inputs             []*Value                    `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	PerformanceMetrics []*ProblemPerformanceMetric `protobuf:"bytes,3,rep,name=performance_metrics,json=performanceMetrics,proto3" json:"performance_metrics,omitempty"`
	// Any users associated with this call itself. Optional.
	Users                []*SolutionRunUser    `protobuf:"bytes,4,rep,name=users,proto3" json:"users,omitempty"`
	Configuration        *ScoringConfiguration `protobuf:"bytes,5,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Request solution to be scored given inputs. Inputs have to be Dataset container values and pipeline outputs have to be predictions. It can internally run multiple fit + produce runs of the pipeline on permutations of inputs data (e.g., for cross-validation). This is also why we cannot expose outputs here. When solution cannot be scored (i.e., the fully specified pipeline used as a template is not a standard pipeline), this call does not have to be supported.

func (*ScoreSolutionRequest) Descriptor

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

func (*ScoreSolutionRequest) GetConfiguration

func (m *ScoreSolutionRequest) GetConfiguration() *ScoringConfiguration

func (*ScoreSolutionRequest) GetInputs

func (m *ScoreSolutionRequest) GetInputs() []*Value

func (*ScoreSolutionRequest) GetPerformanceMetrics

func (m *ScoreSolutionRequest) GetPerformanceMetrics() []*ProblemPerformanceMetric

func (*ScoreSolutionRequest) GetSolutionId

func (m *ScoreSolutionRequest) GetSolutionId() string

func (*ScoreSolutionRequest) GetUsers

func (m *ScoreSolutionRequest) GetUsers() []*SolutionRunUser

func (*ScoreSolutionRequest) ProtoMessage

func (*ScoreSolutionRequest) ProtoMessage()

func (*ScoreSolutionRequest) Reset

func (m *ScoreSolutionRequest) Reset()

func (*ScoreSolutionRequest) String

func (m *ScoreSolutionRequest) String() string

func (*ScoreSolutionRequest) XXX_DiscardUnknown

func (m *ScoreSolutionRequest) XXX_DiscardUnknown()

func (*ScoreSolutionRequest) XXX_Marshal

func (m *ScoreSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScoreSolutionRequest) XXX_Merge

func (m *ScoreSolutionRequest) XXX_Merge(src proto.Message)

func (*ScoreSolutionRequest) XXX_Size

func (m *ScoreSolutionRequest) XXX_Size() int

func (*ScoreSolutionRequest) XXX_Unmarshal

func (m *ScoreSolutionRequest) XXX_Unmarshal(b []byte) error

type ScoreSolutionResponse

type ScoreSolutionResponse struct {
	RequestId            string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScoreSolutionResponse) Descriptor

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

func (*ScoreSolutionResponse) GetRequestId

func (m *ScoreSolutionResponse) GetRequestId() string

func (*ScoreSolutionResponse) ProtoMessage

func (*ScoreSolutionResponse) ProtoMessage()

func (*ScoreSolutionResponse) Reset

func (m *ScoreSolutionResponse) Reset()

func (*ScoreSolutionResponse) String

func (m *ScoreSolutionResponse) String() string

func (*ScoreSolutionResponse) XXX_DiscardUnknown

func (m *ScoreSolutionResponse) XXX_DiscardUnknown()

func (*ScoreSolutionResponse) XXX_Marshal

func (m *ScoreSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScoreSolutionResponse) XXX_Merge

func (m *ScoreSolutionResponse) XXX_Merge(src proto.Message)

func (*ScoreSolutionResponse) XXX_Size

func (m *ScoreSolutionResponse) XXX_Size() int

func (*ScoreSolutionResponse) XXX_Unmarshal

func (m *ScoreSolutionResponse) XXX_Unmarshal(b []byte) error

type ScoringConfiguration

type ScoringConfiguration struct {
	// The evaluation method to use.
	Method EvaluationMethod `protobuf:"varint,1,opt,name=method,proto3,enum=EvaluationMethod" json:"method,omitempty"`
	// Number of folds made, if applicable.
	Folds int32 `protobuf:"varint,2,opt,name=folds,proto3" json:"folds,omitempty"`
	// If applicable, the ratio between the train and test data and represents the proportion of
	// the input data to include in the train split. The rest is included in the test split.
	// E.g., "train_test_ratio == 0.8" would mean that 80% of the whole data becomes the train split
	// and 20% of the whole data becomes the test split.
	TrainTestRatio float64 `protobuf:"fixed64,3,opt,name=train_test_ratio,json=trainTestRatio,proto3" json:"train_test_ratio,omitempty"`
	// Shuffle data? Set to true if employed.
	Shuffle bool `protobuf:"varint,4,opt,name=shuffle,proto3" json:"shuffle,omitempty"`
	// Value for random seed to use for shuffling. Optional.
	RandomSeed int32 `protobuf:"varint,5,opt,name=random_seed,json=randomSeed,proto3" json:"random_seed,omitempty"`
	// Do stratified k-fold? Set to true if employed.
	Stratified           bool     `protobuf:"varint,6,opt,name=stratified,proto3" json:"stratified,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScoringConfiguration) Descriptor

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

func (*ScoringConfiguration) GetFolds

func (m *ScoringConfiguration) GetFolds() int32

func (*ScoringConfiguration) GetMethod

func (m *ScoringConfiguration) GetMethod() EvaluationMethod

func (*ScoringConfiguration) GetRandomSeed

func (m *ScoringConfiguration) GetRandomSeed() int32

func (*ScoringConfiguration) GetShuffle

func (m *ScoringConfiguration) GetShuffle() bool

func (*ScoringConfiguration) GetStratified

func (m *ScoringConfiguration) GetStratified() bool

func (*ScoringConfiguration) GetTrainTestRatio

func (m *ScoringConfiguration) GetTrainTestRatio() float64

func (*ScoringConfiguration) ProtoMessage

func (*ScoringConfiguration) ProtoMessage()

func (*ScoringConfiguration) Reset

func (m *ScoringConfiguration) Reset()

func (*ScoringConfiguration) String

func (m *ScoringConfiguration) String() string

func (*ScoringConfiguration) XXX_DiscardUnknown

func (m *ScoringConfiguration) XXX_DiscardUnknown()

func (*ScoringConfiguration) XXX_Marshal

func (m *ScoringConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScoringConfiguration) XXX_Merge

func (m *ScoringConfiguration) XXX_Merge(src proto.Message)

func (*ScoringConfiguration) XXX_Size

func (m *ScoringConfiguration) XXX_Size() int

func (*ScoringConfiguration) XXX_Unmarshal

func (m *ScoringConfiguration) XXX_Unmarshal(b []byte) error

type SearchSolutionsRequest

type SearchSolutionsRequest struct {
	// Some string identifying the name and version of the TA3 system.
	UserAgent string `protobuf:"bytes,1,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"`
	// Shall be set to "protocol_version" above.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Desired upper limit of time for solution search, expressed in minutes.
	// Is suggestion, and TA2's should attempt to obey, but TA3's should realize may be
	// violated. Default value of 0 (and any negative number) signifies no time bound.
	// See also time_bound_run.
	TimeBoundSearch float64 `protobuf:"fixed64,3,opt,name=time_bound_search,json=timeBoundSearch,proto3" json:"time_bound_search,omitempty"`
	// Value stating the priority of the search. If multiple searches are queued then highest
	// priority (largest number) should be started next by TA2. Primarily used to sort any
	// queue, but no further guarantee that TA2 can give more resources to high priority
	// searches. If unspecified, by default search will have priority 0. Negative numbers have
	// still lower priority.
	Priority float64 `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// Which value types can a TA2 system use to communicate values to a TA3 system?
	// The order is important as a TA2 system will try value types in order until one works out,
	// or an error will be returned instead of the value.
	AllowedValueTypes []ValueType `` /* 137-byte string literal not displayed */
	// Problem description to use for the solution search. Problem description is optional
	// with fully specified pipelines which TA3 provides. If still provided, TA2 should use
	// it to set semantic types on target columns and any other use of a problem description
	// for the needs of running a pipeline.
	Problem *ProblemDescription `protobuf:"bytes,6,opt,name=problem,proto3" json:"problem,omitempty"`
	// A pipeline template to use for search or to execute. If template is omitted, then a
	// regular solution search is done. If template consists only of one placeholder step,
	// then a regular solution search is done to replace that step. If there is no placeholder
	// step, but template describes a full pipeline with free hyper-parameters, then this
	// call becomes a hyper-paramater tuning call over free hyper-paramaters and found solutions
	// share the same pipeline, but different hyper-parameter configurations. If there is no
	// placeholder step and all hyper-parameters are fixed as part of the pipeline, then this
	// call only checks the given template and returns the solution with same pipeline back, to
	// be executed. This allows fixed computations to be done on data, for example, pipeline can
	// consist of only one primitive with fixed hyper-parameters to execute that one primitive.
	// Moreover, such fully specified pipelines with fixed hyper-parametres can have any
	// inputs and any outputs. Otherwise pipelines have to be from a Dataset container value
	// to predictions Pandas dataframe. While there are all these options possible, only a
	// subset has to be supported by all systems. See README for more details.
	Template *PipelineDescription `protobuf:"bytes,7,opt,name=template,proto3" json:"template,omitempty"`
	// Pipeline inputs used during solution search. They have to point to Dataset container
	// values. Order matters as each input is mapped to a template's input in order. Optional
	// for templates without a placeholder and with all hyper-parameters fixed.
	Inputs []*Value `protobuf:"bytes,8,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Desire upper limit of time for one pass of the pipeline run expressed in minutes.
	// Expressed at time of search, TA2's should limit the search to solutions
	// that would not take longer than this for one pass of the pipeline run.
	// Is suggestion, and TA2's should attempt to obey, but TA3's should realize may be
	// violated. Default value of 0 (and any negative number) signifies no time bound.
	// This can also functionally be used as the time bound for scoring also.
	TimeBoundRun float64 `protobuf:"fixed64,9,opt,name=time_bound_run,json=timeBoundRun,proto3" json:"time_bound_run,omitempty"`
	// Suggested maximum number of solutions to rank. Default is 0. If it is 0, it means
	// no ranking of found solutions is done and no limit on number of found solutions is set.
	// TA2 can still provide "RANK" score as part of "scores" field if ranking approach
	// TA2 uses still allows to stream found solutions as they are found.
	// If value of this field is not 0, the behavior of this call changes:
	//  - "time_bound_search" becomes a time bound for both search and ranking.
	//    TA2 decides how to divide the time between searching and ranking.
	//  - TA2 is required to provide "RANK" score as part of "scores" field in
	//    messages "GetSearchSolutionsResultsResponse".
	//  - TA2 can make all found solutions available only at the end of the call.
	//    If ranking approach used by TA2 allows for that, TA2 can still stream
	//    found solutions (and their ranks) during whole call.
	//  - Calling "StopSearchSolutions" stops both search and ranking processes,
	//    but TA2 can quickly return ranked solutions up to that point, if possible,
	//    before closing the "GetSearchSolutionsResults" stream. Similarly
	//    for "EndSearchSolutions", but that is less useful.
	//  - TA2 can still return more solutions than the limit. The limit only signals
	//    that TA2 does not have to rank and return more solutions than the limit,
	//    which is useful when ranking is an expensive operation.
	RankSolutionsLimit   int32    `protobuf:"varint,10,opt,name=rank_solutions_limit,json=rankSolutionsLimit,proto3" json:"rank_solutions_limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Starts a new solution search. Found solutions have not necessary been fitted on the provided inputs. Problem description and inputs are used only to help guide the search process. Consider any found solutions to be just a static description of solutions at this stage. Multiple parallel solution searches can happen at the same time.

func (*SearchSolutionsRequest) Descriptor

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

func (*SearchSolutionsRequest) GetAllowedValueTypes

func (m *SearchSolutionsRequest) GetAllowedValueTypes() []ValueType

func (*SearchSolutionsRequest) GetInputs

func (m *SearchSolutionsRequest) GetInputs() []*Value

func (*SearchSolutionsRequest) GetPriority

func (m *SearchSolutionsRequest) GetPriority() float64

func (*SearchSolutionsRequest) GetProblem

func (m *SearchSolutionsRequest) GetProblem() *ProblemDescription

func (*SearchSolutionsRequest) GetRankSolutionsLimit

func (m *SearchSolutionsRequest) GetRankSolutionsLimit() int32

func (*SearchSolutionsRequest) GetTemplate

func (m *SearchSolutionsRequest) GetTemplate() *PipelineDescription

func (*SearchSolutionsRequest) GetTimeBoundRun

func (m *SearchSolutionsRequest) GetTimeBoundRun() float64

func (*SearchSolutionsRequest) GetTimeBoundSearch

func (m *SearchSolutionsRequest) GetTimeBoundSearch() float64

func (*SearchSolutionsRequest) GetUserAgent

func (m *SearchSolutionsRequest) GetUserAgent() string

func (*SearchSolutionsRequest) GetVersion

func (m *SearchSolutionsRequest) GetVersion() string

func (*SearchSolutionsRequest) ProtoMessage

func (*SearchSolutionsRequest) ProtoMessage()

func (*SearchSolutionsRequest) Reset

func (m *SearchSolutionsRequest) Reset()

func (*SearchSolutionsRequest) String

func (m *SearchSolutionsRequest) String() string

func (*SearchSolutionsRequest) XXX_DiscardUnknown

func (m *SearchSolutionsRequest) XXX_DiscardUnknown()

func (*SearchSolutionsRequest) XXX_Marshal

func (m *SearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchSolutionsRequest) XXX_Merge

func (m *SearchSolutionsRequest) XXX_Merge(src proto.Message)

func (*SearchSolutionsRequest) XXX_Size

func (m *SearchSolutionsRequest) XXX_Size() int

func (*SearchSolutionsRequest) XXX_Unmarshal

func (m *SearchSolutionsRequest) XXX_Unmarshal(b []byte) error

type SearchSolutionsResponse

type SearchSolutionsResponse struct {
	// An ID identifying this solution search. This string should be at least 22 characters
	// long to ensure enough entropy to not be guessable.
	SearchId             string   `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Call returns immediately with the ID. Use "GetFoundSolutions" call to get results.

func (*SearchSolutionsResponse) Descriptor

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

func (*SearchSolutionsResponse) GetSearchId

func (m *SearchSolutionsResponse) GetSearchId() string

func (*SearchSolutionsResponse) ProtoMessage

func (*SearchSolutionsResponse) ProtoMessage()

func (*SearchSolutionsResponse) Reset

func (m *SearchSolutionsResponse) Reset()

func (*SearchSolutionsResponse) String

func (m *SearchSolutionsResponse) String() string

func (*SearchSolutionsResponse) XXX_DiscardUnknown

func (m *SearchSolutionsResponse) XXX_DiscardUnknown()

func (*SearchSolutionsResponse) XXX_Marshal

func (m *SearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchSolutionsResponse) XXX_Merge

func (m *SearchSolutionsResponse) XXX_Merge(src proto.Message)

func (*SearchSolutionsResponse) XXX_Size

func (m *SearchSolutionsResponse) XXX_Size() int

func (*SearchSolutionsResponse) XXX_Unmarshal

func (m *SearchSolutionsResponse) XXX_Unmarshal(b []byte) error

type Server

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

Server represents a basic distil solution server.

func NewServer

func NewServer(userAgent string, resultDir string, sendDelay int,
	numUpdates int, errPercentage float64, maxSolutions int) *Server

NewServer creates a new solution server instance. ID maps are initialized with place holder values to support tests without explicit calls to session management.

func (*Server) DataAvailable

func (s *Server) DataAvailable(ctx context.Context, in *DataAvailableRequest) (*DataAvailableResponse, error)

DataAvailable does something

func (*Server) DescribeSolution

func (s *Server) DescribeSolution(ctx context.Context, req *DescribeSolutionRequest) (*DescribeSolutionResponse, error)

DescribeSolution generates a solution description struct for a given solution.

func (*Server) EndSearchSolutions

func (s *Server) EndSearchSolutions(ctx context.Context, req *EndSearchSolutionsRequest) (*EndSearchSolutionsResponse, error)

EndSearchSolutions Releases resources associated with a previusly issued search request. NOTE(cbethune): Does this require that a Stop request has been issued?

func (*Server) FitSolution

func (s *Server) FitSolution(ctx context.Context, req *FitSolutionRequest) (*FitSolutionResponse, error)

FitSolution fits a solution to training data.

func (*Server) GetFitSolutionResults

func (s *Server) GetFitSolutionResults(req *GetFitSolutionResultsRequest, stream Core_GetFitSolutionResultsServer) error

GetFitSolutionResults returns a stream of solution fit result for a previously issued fit request.

func (*Server) GetProduceSolutionResults

func (s *Server) GetProduceSolutionResults(req *GetProduceSolutionResultsRequest, stream Core_GetProduceSolutionResultsServer) error

GetProduceSolutionResults returns a stream of solution results for a previously issued produce request.

func (*Server) GetScoreSolutionResults

func (s *Server) GetScoreSolutionResults(req *GetScoreSolutionResultsRequest, stream Core_GetScoreSolutionResultsServer) error

GetScoreSolutionResults returns a stream of solution score results for a previously issued scoring request.

func (*Server) GetSearchSolutionsResults

func (s *Server) GetSearchSolutionsResults(req *GetSearchSolutionsResultsRequest, stream Core_GetSearchSolutionsResultsServer) error

GetSearchSolutionsResults returns a stream of solution results associated with a previously issued request

func (*Server) Hello

func (s *Server) Hello(ctx context.Context, req *HelloRequest) (*HelloResponse, error)

Hello returns information on what the server supports.

func (*Server) ListPrimitives

func (s *Server) ListPrimitives(ctx context.Context, req *ListPrimitivesRequest) (*ListPrimitivesResponse, error)

ListPrimitives returns a list of TA1 primitives that TA3 is allowed to use in pre-processing solution specifications.

func (*Server) LoadFittedSolution

LoadFittedSolution does something

func (*Server) LoadSolution

func (s *Server) LoadSolution(ctx context.Context, in *LoadSolutionRequest) (*LoadSolutionResponse, error)

LoadSolution does something

func (*Server) ProduceSolution

func (s *Server) ProduceSolution(ctx context.Context, req *ProduceSolutionRequest) (*ProduceSolutionResponse, error)

ProduceSolution executes a solution on supplied data. Solution needs to have previously executed a fit.

func (*Server) SaveFittedSolution

SaveFittedSolution does something

func (*Server) SaveSolution

func (s *Server) SaveSolution(ctx context.Context, in *SaveSolutionRequest) (*SaveSolutionResponse, error)

SaveSolution does something

func (*Server) ScoreSolution

func (s *Server) ScoreSolution(ctx context.Context, req *ScoreSolutionRequest) (*ScoreSolutionResponse, error)

ScoreSolution generates a score for a given solution.

func (*Server) SearchSolutions

func (s *Server) SearchSolutions(ctx context.Context, req *SearchSolutionsRequest) (*SearchSolutionsResponse, error)

SearchSolutions generates a searchID and returns a SearchResponse immediately

func (*Server) SolutionExport

func (s *Server) SolutionExport(ctx context.Context, req *SolutionExportRequest) (*SolutionExportResponse, error)

SolutionExport exports a previously generated solution. The solution needs to have had a fit step executed on it to be valid for export.

func (*Server) StopSearchSolutions

func (s *Server) StopSearchSolutions(ctx context.Context, req *StopSearchSolutionsRequest) (*StopSearchSolutionsResponse, error)

StopSearchSolutions Stops a running solution search request. NOTE(cbethune): Does this allow for a search to be restarted via a search request that uses the same ID?

func (*Server) UpdateProblem

func (s *Server) UpdateProblem(ctx context.Context, req *UpdateProblemRequest) (*UpdateProblemResponse, error)

UpdateProblem updates the problem defintion associated with a search

type ServerRequests

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

ServerRequests provides thread safe access to API request information

func NewServerRequests

func NewServerRequests() *ServerRequests

NewServerRequests creates a new instance of a server request manager

func (*ServerRequests) AddRequest

func (s *ServerRequests) AddRequest(parentID string, requestMsg interface{}) (RequestNode, error)

AddRequest adds a new server API request

func (*ServerRequests) GetRequest

func (s *ServerRequests) GetRequest(requestID string) (RequestNode, error)

GetRequest returns a previously added server API request

func (*ServerRequests) IsComplete

func (s *ServerRequests) IsComplete(requestID string) bool

IsComplete indicates whether or not a server request is in a complete state.

func (*ServerRequests) RemoveRequest

func (s *ServerRequests) RemoveRequest(requestID string) error

RemoveRequest request removes a request node and all of its descendants.

func (*ServerRequests) SetComplete

func (s *ServerRequests) SetComplete(requestID string)

SetComplete marks a server API request as having completed processing

type SolutionExportRequest

type SolutionExportRequest struct {
	// Found solution to export.
	SolutionId string `protobuf:"bytes,3,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"`
	// Solution rank to be used for the exported solution. Lower numbers represent
	// better solutions. Presently evaluation requirements are that ranks should be non-negative
	// and that each exported pipeline have a different rank. TA3 should make sure not to repeat ranks.
	// Filenames of exported files are left to be chosen by the TA2 system.
	Rank                 float64  `protobuf:"fixed64,2,opt,name=rank,proto3" json:"rank,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Exports a solution for evaluation purposes based on evaluation specifications.

func (*SolutionExportRequest) Descriptor

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

func (*SolutionExportRequest) GetRank

func (m *SolutionExportRequest) GetRank() float64

func (*SolutionExportRequest) GetSolutionId

func (m *SolutionExportRequest) GetSolutionId() string

func (*SolutionExportRequest) ProtoMessage

func (*SolutionExportRequest) ProtoMessage()

func (*SolutionExportRequest) Reset

func (m *SolutionExportRequest) Reset()

func (*SolutionExportRequest) String

func (m *SolutionExportRequest) String() string

func (*SolutionExportRequest) XXX_DiscardUnknown

func (m *SolutionExportRequest) XXX_DiscardUnknown()

func (*SolutionExportRequest) XXX_Marshal

func (m *SolutionExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SolutionExportRequest) XXX_Merge

func (m *SolutionExportRequest) XXX_Merge(src proto.Message)

func (*SolutionExportRequest) XXX_Size

func (m *SolutionExportRequest) XXX_Size() int

func (*SolutionExportRequest) XXX_Unmarshal

func (m *SolutionExportRequest) XXX_Unmarshal(b []byte) error

type SolutionExportResponse

type SolutionExportResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SolutionExportResponse) Descriptor

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

func (*SolutionExportResponse) ProtoMessage

func (*SolutionExportResponse) ProtoMessage()

func (*SolutionExportResponse) Reset

func (m *SolutionExportResponse) Reset()

func (*SolutionExportResponse) String

func (m *SolutionExportResponse) String() string

func (*SolutionExportResponse) XXX_DiscardUnknown

func (m *SolutionExportResponse) XXX_DiscardUnknown()

func (*SolutionExportResponse) XXX_Marshal

func (m *SolutionExportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SolutionExportResponse) XXX_Merge

func (m *SolutionExportResponse) XXX_Merge(src proto.Message)

func (*SolutionExportResponse) XXX_Size

func (m *SolutionExportResponse) XXX_Size() int

func (*SolutionExportResponse) XXX_Unmarshal

func (m *SolutionExportResponse) XXX_Unmarshal(b []byte) error

type SolutionRunUser

type SolutionRunUser struct {
	// A UUID of the user. It does not have to map to any real ID, just that it is possible
	// to connect multiple solution actions by the same user together, if necessary.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Was this run because solution was chosen by this user.
	Chosen bool `protobuf:"varint,2,opt,name=chosen,proto3" json:"chosen,omitempty"`
	// Textual reason provided by the user why the run was chosen by this user.
	Reason               string   `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

User associated with the run of the solution.

func (*SolutionRunUser) Descriptor

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

func (*SolutionRunUser) GetChosen

func (m *SolutionRunUser) GetChosen() bool

func (*SolutionRunUser) GetId

func (m *SolutionRunUser) GetId() string

func (*SolutionRunUser) GetReason

func (m *SolutionRunUser) GetReason() string

func (*SolutionRunUser) ProtoMessage

func (*SolutionRunUser) ProtoMessage()

func (*SolutionRunUser) Reset

func (m *SolutionRunUser) Reset()

func (*SolutionRunUser) String

func (m *SolutionRunUser) String() string

func (*SolutionRunUser) XXX_DiscardUnknown

func (m *SolutionRunUser) XXX_DiscardUnknown()

func (*SolutionRunUser) XXX_Marshal

func (m *SolutionRunUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SolutionRunUser) XXX_Merge

func (m *SolutionRunUser) XXX_Merge(src proto.Message)

func (*SolutionRunUser) XXX_Size

func (m *SolutionRunUser) XXX_Size() int

func (*SolutionRunUser) XXX_Unmarshal

func (m *SolutionRunUser) XXX_Unmarshal(b []byte) error

type SolutionSearchScore

type SolutionSearchScore struct {
	ScoringConfiguration *ScoringConfiguration `protobuf:"bytes,1,opt,name=scoring_configuration,json=scoringConfiguration,proto3" json:"scoring_configuration,omitempty"`
	Scores               []*Score              `protobuf:"bytes,2,rep,name=scores,proto3" json:"scores,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Description of a TA2 score done during solution search. Because there is a wide range of potential approaches a TA2 can use to score candidate solutions this might not capture what

your TA2 is doing. Feel free to request additions to be able to describe your approach.

func (*SolutionSearchScore) Descriptor

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

func (*SolutionSearchScore) GetScores

func (m *SolutionSearchScore) GetScores() []*Score

func (*SolutionSearchScore) GetScoringConfiguration

func (m *SolutionSearchScore) GetScoringConfiguration() *ScoringConfiguration

func (*SolutionSearchScore) ProtoMessage

func (*SolutionSearchScore) ProtoMessage()

func (*SolutionSearchScore) Reset

func (m *SolutionSearchScore) Reset()

func (*SolutionSearchScore) String

func (m *SolutionSearchScore) String() string

func (*SolutionSearchScore) XXX_DiscardUnknown

func (m *SolutionSearchScore) XXX_DiscardUnknown()

func (*SolutionSearchScore) XXX_Marshal

func (m *SolutionSearchScore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SolutionSearchScore) XXX_Merge

func (m *SolutionSearchScore) XXX_Merge(src proto.Message)

func (*SolutionSearchScore) XXX_Size

func (m *SolutionSearchScore) XXX_Size() int

func (*SolutionSearchScore) XXX_Unmarshal

func (m *SolutionSearchScore) XXX_Unmarshal(b []byte) error

type StepDescription

type StepDescription struct {
	// Types that are valid to be assigned to Step:
	//	*StepDescription_Primitive
	//	*StepDescription_Pipeline
	Step                 isStepDescription_Step `protobuf_oneof:"step"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StepDescription) Descriptor

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

func (*StepDescription) GetPipeline

func (m *StepDescription) GetPipeline() *SubpipelineStepDescription

func (*StepDescription) GetPrimitive

func (m *StepDescription) GetPrimitive() *PrimitiveStepDescription

func (*StepDescription) GetStep

func (m *StepDescription) GetStep() isStepDescription_Step

func (*StepDescription) ProtoMessage

func (*StepDescription) ProtoMessage()

func (*StepDescription) Reset

func (m *StepDescription) Reset()

func (*StepDescription) String

func (m *StepDescription) String() string

func (*StepDescription) XXX_DiscardUnknown

func (m *StepDescription) XXX_DiscardUnknown()

func (*StepDescription) XXX_Marshal

func (m *StepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepDescription) XXX_Merge

func (m *StepDescription) XXX_Merge(src proto.Message)

func (*StepDescription) XXX_OneofFuncs

func (*StepDescription) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*StepDescription) XXX_Size

func (m *StepDescription) XXX_Size() int

func (*StepDescription) XXX_Unmarshal

func (m *StepDescription) XXX_Unmarshal(b []byte) error

type StepDescription_Pipeline

type StepDescription_Pipeline struct {
	Pipeline *SubpipelineStepDescription `protobuf:"bytes,2,opt,name=pipeline,proto3,oneof"`
}

type StepDescription_Primitive

type StepDescription_Primitive struct {
	Primitive *PrimitiveStepDescription `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}

type StepInput

type StepInput struct {
	// Data reference.
	Data                 string   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StepInput) Descriptor

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

func (*StepInput) GetData

func (m *StepInput) GetData() string

func (*StepInput) ProtoMessage

func (*StepInput) ProtoMessage()

func (*StepInput) Reset

func (m *StepInput) Reset()

func (*StepInput) String

func (m *StepInput) String() string

func (*StepInput) XXX_DiscardUnknown

func (m *StepInput) XXX_DiscardUnknown()

func (*StepInput) XXX_Marshal

func (m *StepInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepInput) XXX_Merge

func (m *StepInput) XXX_Merge(src proto.Message)

func (*StepInput) XXX_Size

func (m *StepInput) XXX_Size() int

func (*StepInput) XXX_Unmarshal

func (m *StepInput) XXX_Unmarshal(b []byte) error

type StepOutput

type StepOutput struct {
	// Name which becomes part of the data reference.
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StepOutput) Descriptor

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

func (*StepOutput) GetId

func (m *StepOutput) GetId() string

func (*StepOutput) ProtoMessage

func (*StepOutput) ProtoMessage()

func (*StepOutput) Reset

func (m *StepOutput) Reset()

func (*StepOutput) String

func (m *StepOutput) String() string

func (*StepOutput) XXX_DiscardUnknown

func (m *StepOutput) XXX_DiscardUnknown()

func (*StepOutput) XXX_Marshal

func (m *StepOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepOutput) XXX_Merge

func (m *StepOutput) XXX_Merge(src proto.Message)

func (*StepOutput) XXX_Size

func (m *StepOutput) XXX_Size() int

func (*StepOutput) XXX_Unmarshal

func (m *StepOutput) XXX_Unmarshal(b []byte) error

type StepProgress

type StepProgress struct {
	Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"`
	// If step is a sub-pipeline, then this list contains progress for each step in the
	// sub-pipeline, in order.
	// List can be incomplete while the process is in progress. Systems can provide
	// steps only at the end (when "progress" equals COMPLETED) and not during running.
	Steps                []*StepProgress `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*StepProgress) Descriptor

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

func (*StepProgress) GetProgress

func (m *StepProgress) GetProgress() *Progress

func (*StepProgress) GetSteps

func (m *StepProgress) GetSteps() []*StepProgress

func (*StepProgress) ProtoMessage

func (*StepProgress) ProtoMessage()

func (*StepProgress) Reset

func (m *StepProgress) Reset()

func (*StepProgress) String

func (m *StepProgress) String() string

func (*StepProgress) XXX_DiscardUnknown

func (m *StepProgress) XXX_DiscardUnknown()

func (*StepProgress) XXX_Marshal

func (m *StepProgress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepProgress) XXX_Merge

func (m *StepProgress) XXX_Merge(src proto.Message)

func (*StepProgress) XXX_Size

func (m *StepProgress) XXX_Size() int

func (*StepProgress) XXX_Unmarshal

func (m *StepProgress) XXX_Unmarshal(b []byte) error

type StopSearchSolutionsRequest

type StopSearchSolutionsRequest struct {
	SearchId             string   `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Stops the search but leaves all currently found solutions available. If the call is made in parallel with a running search and results are being streamed, the "GetSearchSolutionsResults" stream is closed by the TA2 (as happens when the search is concluded on its own). Search cannot be re-started after it has been stopped.

func (*StopSearchSolutionsRequest) Descriptor

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

func (*StopSearchSolutionsRequest) GetSearchId

func (m *StopSearchSolutionsRequest) GetSearchId() string

func (*StopSearchSolutionsRequest) ProtoMessage

func (*StopSearchSolutionsRequest) ProtoMessage()

func (*StopSearchSolutionsRequest) Reset

func (m *StopSearchSolutionsRequest) Reset()

func (*StopSearchSolutionsRequest) String

func (m *StopSearchSolutionsRequest) String() string

func (*StopSearchSolutionsRequest) XXX_DiscardUnknown

func (m *StopSearchSolutionsRequest) XXX_DiscardUnknown()

func (*StopSearchSolutionsRequest) XXX_Marshal

func (m *StopSearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopSearchSolutionsRequest) XXX_Merge

func (m *StopSearchSolutionsRequest) XXX_Merge(src proto.Message)

func (*StopSearchSolutionsRequest) XXX_Size

func (m *StopSearchSolutionsRequest) XXX_Size() int

func (*StopSearchSolutionsRequest) XXX_Unmarshal

func (m *StopSearchSolutionsRequest) XXX_Unmarshal(b []byte) error

type StopSearchSolutionsResponse

type StopSearchSolutionsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopSearchSolutionsResponse) Descriptor

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

func (*StopSearchSolutionsResponse) ProtoMessage

func (*StopSearchSolutionsResponse) ProtoMessage()

func (*StopSearchSolutionsResponse) Reset

func (m *StopSearchSolutionsResponse) Reset()

func (*StopSearchSolutionsResponse) String

func (m *StopSearchSolutionsResponse) String() string

func (*StopSearchSolutionsResponse) XXX_DiscardUnknown

func (m *StopSearchSolutionsResponse) XXX_DiscardUnknown()

func (*StopSearchSolutionsResponse) XXX_Marshal

func (m *StopSearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopSearchSolutionsResponse) XXX_Merge

func (m *StopSearchSolutionsResponse) XXX_Merge(src proto.Message)

func (*StopSearchSolutionsResponse) XXX_Size

func (m *StopSearchSolutionsResponse) XXX_Size() int

func (*StopSearchSolutionsResponse) XXX_Unmarshal

func (m *StopSearchSolutionsResponse) XXX_Unmarshal(b []byte) error

type SubpipelinePipelineDescriptionStep

type SubpipelinePipelineDescriptionStep struct {
	// Only "id" field is required in this case to reference another pipeline in the template.
	Pipeline *PipelineDescription `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// List of data references, probably of an output of a step or pipeline input,
	// mapped to sub-pipeline's inputs in order.
	Inputs []*StepInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// List of IDs to be used in data references, mapping sub-pipeline's outputs in order.
	Outputs              []*StepOutput `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SubpipelinePipelineDescriptionStep) Descriptor

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

func (*SubpipelinePipelineDescriptionStep) GetInputs

func (*SubpipelinePipelineDescriptionStep) GetOutputs

func (*SubpipelinePipelineDescriptionStep) GetPipeline

func (*SubpipelinePipelineDescriptionStep) ProtoMessage

func (*SubpipelinePipelineDescriptionStep) ProtoMessage()

func (*SubpipelinePipelineDescriptionStep) Reset

func (*SubpipelinePipelineDescriptionStep) String

func (*SubpipelinePipelineDescriptionStep) XXX_DiscardUnknown

func (m *SubpipelinePipelineDescriptionStep) XXX_DiscardUnknown()

func (*SubpipelinePipelineDescriptionStep) XXX_Marshal

func (m *SubpipelinePipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubpipelinePipelineDescriptionStep) XXX_Merge

func (*SubpipelinePipelineDescriptionStep) XXX_Size

func (*SubpipelinePipelineDescriptionStep) XXX_Unmarshal

func (m *SubpipelinePipelineDescriptionStep) XXX_Unmarshal(b []byte) error

type SubpipelineStepDescription

type SubpipelineStepDescription struct {
	// Each step in a sub-pipeline has a description. These are reported in the order of steps
	// in the sub-pipeline.
	Steps                []*StepDescription `protobuf:"bytes,1,rep,name=steps,proto3" json:"steps,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SubpipelineStepDescription) Descriptor

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

func (*SubpipelineStepDescription) GetSteps

func (*SubpipelineStepDescription) ProtoMessage

func (*SubpipelineStepDescription) ProtoMessage()

func (*SubpipelineStepDescription) Reset

func (m *SubpipelineStepDescription) Reset()

func (*SubpipelineStepDescription) String

func (m *SubpipelineStepDescription) String() string

func (*SubpipelineStepDescription) XXX_DiscardUnknown

func (m *SubpipelineStepDescription) XXX_DiscardUnknown()

func (*SubpipelineStepDescription) XXX_Marshal

func (m *SubpipelineStepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubpipelineStepDescription) XXX_Merge

func (m *SubpipelineStepDescription) XXX_Merge(src proto.Message)

func (*SubpipelineStepDescription) XXX_Size

func (m *SubpipelineStepDescription) XXX_Size() int

func (*SubpipelineStepDescription) XXX_Unmarshal

func (m *SubpipelineStepDescription) XXX_Unmarshal(b []byte) error

type TaskSubtype

type TaskSubtype int32

Secondary classification of the problem.

const (
	// Default value. Not to be used.
	TaskSubtype_TASK_SUBTYPE_UNDEFINED TaskSubtype = 0
	// No secondary task is applicable for this problem.
	TaskSubtype_NONE           TaskSubtype = 1
	TaskSubtype_BINARY         TaskSubtype = 2
	TaskSubtype_MULTICLASS     TaskSubtype = 3
	TaskSubtype_MULTILABEL     TaskSubtype = 4
	TaskSubtype_UNIVARIATE     TaskSubtype = 5
	TaskSubtype_MULTIVARIATE   TaskSubtype = 6
	TaskSubtype_OVERLAPPING    TaskSubtype = 7
	TaskSubtype_NONOVERLAPPING TaskSubtype = 8
)

func (TaskSubtype) EnumDescriptor

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

func (TaskSubtype) String

func (x TaskSubtype) String() string

type TaskType

type TaskType int32

Top level classification of the problem.

const (
	// Default value. Not to be used.
	TaskType_TASK_TYPE_UNDEFINED           TaskType = 0
	TaskType_CLASSIFICATION                TaskType = 1
	TaskType_REGRESSION                    TaskType = 2
	TaskType_CLUSTERING                    TaskType = 3
	TaskType_LINK_PREDICTION               TaskType = 4
	TaskType_VERTEX_NOMINATION             TaskType = 5
	TaskType_VERTEX_CLASSIFICATION         TaskType = 6
	TaskType_COMMUNITY_DETECTION           TaskType = 7
	TaskType_GRAPH_MATCHING                TaskType = 8
	TaskType_TIME_SERIES_FORECASTING       TaskType = 9
	TaskType_COLLABORATIVE_FILTERING       TaskType = 10
	TaskType_OBJECT_DETECTION              TaskType = 11
	TaskType_SEMISUPERVISED_CLASSIFICATION TaskType = 12
	TaskType_SEMISUPERVISED_REGRESSION     TaskType = 13
)

func (TaskType) EnumDescriptor

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

func (TaskType) String

func (x TaskType) String() string

type UpdateProblemRequest

type UpdateProblemRequest struct {
	SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	// New problem description. It has to be provided in full and it replaces existing
	// problem description.
	Problem              *ProblemDescription `protobuf:"bytes,2,opt,name=problem,proto3" json:"problem,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Updates problem with new description. This also updates the problem description for all ongoing solution searches associated with this problem. Internal behavior of TA2 is unspecified: it can simply start a new search using new problem description, or it can start modifying solutions it has already found to new problem description, or it can use it to further help narrow down ongoing solution searches. In any case, after this call returns, all reported solutions for searches associated with this problem should be for the updated problem description.

func (*UpdateProblemRequest) Descriptor

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

func (*UpdateProblemRequest) GetProblem

func (m *UpdateProblemRequest) GetProblem() *ProblemDescription

func (*UpdateProblemRequest) GetSearchId

func (m *UpdateProblemRequest) GetSearchId() string

func (*UpdateProblemRequest) ProtoMessage

func (*UpdateProblemRequest) ProtoMessage()

func (*UpdateProblemRequest) Reset

func (m *UpdateProblemRequest) Reset()

func (*UpdateProblemRequest) String

func (m *UpdateProblemRequest) String() string

func (*UpdateProblemRequest) XXX_DiscardUnknown

func (m *UpdateProblemRequest) XXX_DiscardUnknown()

func (*UpdateProblemRequest) XXX_Marshal

func (m *UpdateProblemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateProblemRequest) XXX_Merge

func (m *UpdateProblemRequest) XXX_Merge(src proto.Message)

func (*UpdateProblemRequest) XXX_Size

func (m *UpdateProblemRequest) XXX_Size() int

func (*UpdateProblemRequest) XXX_Unmarshal

func (m *UpdateProblemRequest) XXX_Unmarshal(b []byte) error

type UpdateProblemResponse

type UpdateProblemResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateProblemResponse) Descriptor

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

func (*UpdateProblemResponse) ProtoMessage

func (*UpdateProblemResponse) ProtoMessage()

func (*UpdateProblemResponse) Reset

func (m *UpdateProblemResponse) Reset()

func (*UpdateProblemResponse) String

func (m *UpdateProblemResponse) String() string

func (*UpdateProblemResponse) XXX_DiscardUnknown

func (m *UpdateProblemResponse) XXX_DiscardUnknown()

func (*UpdateProblemResponse) XXX_Marshal

func (m *UpdateProblemResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateProblemResponse) XXX_Merge

func (m *UpdateProblemResponse) XXX_Merge(src proto.Message)

func (*UpdateProblemResponse) XXX_Size

func (m *UpdateProblemResponse) XXX_Size() int

func (*UpdateProblemResponse) XXX_Unmarshal

func (m *UpdateProblemResponse) XXX_Unmarshal(b []byte) error

type Value

type Value struct {
	// Types that are valid to be assigned to Value:
	//	*Value_Error
	//	*Value_Raw
	//	*Value_DatasetUri
	//	*Value_CsvUri
	//	*Value_PickleUri
	//	*Value_PickleBlob
	//	*Value_PlasmaId
	Value                isValue_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Value) Descriptor

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

func (*Value) GetCsvUri

func (m *Value) GetCsvUri() string

func (*Value) GetDatasetUri

func (m *Value) GetDatasetUri() string

func (*Value) GetError

func (m *Value) GetError() *ValueError

func (*Value) GetPickleBlob

func (m *Value) GetPickleBlob() []byte

func (*Value) GetPickleUri

func (m *Value) GetPickleUri() string

func (*Value) GetPlasmaId

func (m *Value) GetPlasmaId() []byte

func (*Value) GetRaw

func (m *Value) GetRaw() *ValueRaw

func (*Value) GetValue

func (m *Value) GetValue() isValue_Value

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) String

func (m *Value) String() string

func (*Value) XXX_DiscardUnknown

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal

func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Value) XXX_Merge

func (m *Value) XXX_Merge(src proto.Message)

func (*Value) XXX_OneofFuncs

func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Value) XXX_Size

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal

func (m *Value) XXX_Unmarshal(b []byte) error

type ValueArgument

type ValueArgument struct {
	Data                 *Value   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValueArgument) Descriptor

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

func (*ValueArgument) GetData

func (m *ValueArgument) GetData() *Value

func (*ValueArgument) ProtoMessage

func (*ValueArgument) ProtoMessage()

func (*ValueArgument) Reset

func (m *ValueArgument) Reset()

func (*ValueArgument) String

func (m *ValueArgument) String() string

func (*ValueArgument) XXX_DiscardUnknown

func (m *ValueArgument) XXX_DiscardUnknown()

func (*ValueArgument) XXX_Marshal

func (m *ValueArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueArgument) XXX_Merge

func (m *ValueArgument) XXX_Merge(src proto.Message)

func (*ValueArgument) XXX_Size

func (m *ValueArgument) XXX_Size() int

func (*ValueArgument) XXX_Unmarshal

func (m *ValueArgument) XXX_Unmarshal(b []byte) error

type ValueDict

type ValueDict struct {
	Items                map[string]*ValueRaw `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ValueDict) Descriptor

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

func (*ValueDict) GetItems

func (m *ValueDict) GetItems() map[string]*ValueRaw

func (*ValueDict) ProtoMessage

func (*ValueDict) ProtoMessage()

func (*ValueDict) Reset

func (m *ValueDict) Reset()

func (*ValueDict) String

func (m *ValueDict) String() string

func (*ValueDict) XXX_DiscardUnknown

func (m *ValueDict) XXX_DiscardUnknown()

func (*ValueDict) XXX_Marshal

func (m *ValueDict) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueDict) XXX_Merge

func (m *ValueDict) XXX_Merge(src proto.Message)

func (*ValueDict) XXX_Size

func (m *ValueDict) XXX_Size() int

func (*ValueDict) XXX_Unmarshal

func (m *ValueDict) XXX_Unmarshal(b []byte) error

type ValueError

type ValueError struct {
	// A error message useful for debugging or logging. Not meant to be very end-user friendly.
	// If a list of supported/allowed value types could not support a given value, then message
	// should say so. On the other hand, if there was really an error using a value type which
	// would otherwise support a given value, then the error message should communicate this error.
	// If there was such an error but some later value type allowed for recovery, then there
	// should be no error.
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValueError) Descriptor

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

func (*ValueError) GetMessage

func (m *ValueError) GetMessage() string

func (*ValueError) ProtoMessage

func (*ValueError) ProtoMessage()

func (*ValueError) Reset

func (m *ValueError) Reset()

func (*ValueError) String

func (m *ValueError) String() string

func (*ValueError) XXX_DiscardUnknown

func (m *ValueError) XXX_DiscardUnknown()

func (*ValueError) XXX_Marshal

func (m *ValueError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueError) XXX_Merge

func (m *ValueError) XXX_Merge(src proto.Message)

func (*ValueError) XXX_Size

func (m *ValueError) XXX_Size() int

func (*ValueError) XXX_Unmarshal

func (m *ValueError) XXX_Unmarshal(b []byte) error

type ValueList

type ValueList struct {
	Items                []*ValueRaw `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ValueList) Descriptor

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

func (*ValueList) GetItems

func (m *ValueList) GetItems() []*ValueRaw

func (*ValueList) ProtoMessage

func (*ValueList) ProtoMessage()

func (*ValueList) Reset

func (m *ValueList) Reset()

func (*ValueList) String

func (m *ValueList) String() string

func (*ValueList) XXX_DiscardUnknown

func (m *ValueList) XXX_DiscardUnknown()

func (*ValueList) XXX_Marshal

func (m *ValueList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueList) XXX_Merge

func (m *ValueList) XXX_Merge(src proto.Message)

func (*ValueList) XXX_Size

func (m *ValueList) XXX_Size() int

func (*ValueList) XXX_Unmarshal

func (m *ValueList) XXX_Unmarshal(b []byte) error

type ValueRaw

type ValueRaw struct {
	// Types that are valid to be assigned to Raw:
	//	*ValueRaw_Null
	//	*ValueRaw_Double
	//	*ValueRaw_Int64
	//	*ValueRaw_Bool
	//	*ValueRaw_String_
	//	*ValueRaw_Bytes
	//	*ValueRaw_List
	//	*ValueRaw_Dict
	Raw                  isValueRaw_Raw `protobuf_oneof:"raw"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ValueRaw) Descriptor

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

func (*ValueRaw) GetBool

func (m *ValueRaw) GetBool() bool

func (*ValueRaw) GetBytes

func (m *ValueRaw) GetBytes() []byte

func (*ValueRaw) GetDict

func (m *ValueRaw) GetDict() *ValueDict

func (*ValueRaw) GetDouble

func (m *ValueRaw) GetDouble() float64

func (*ValueRaw) GetInt64

func (m *ValueRaw) GetInt64() int64

func (*ValueRaw) GetList

func (m *ValueRaw) GetList() *ValueList

func (*ValueRaw) GetNull

func (m *ValueRaw) GetNull() NullValue

func (*ValueRaw) GetRaw

func (m *ValueRaw) GetRaw() isValueRaw_Raw

func (*ValueRaw) GetString_

func (m *ValueRaw) GetString_() string

func (*ValueRaw) ProtoMessage

func (*ValueRaw) ProtoMessage()

func (*ValueRaw) Reset

func (m *ValueRaw) Reset()

func (*ValueRaw) String

func (m *ValueRaw) String() string

func (*ValueRaw) XXX_DiscardUnknown

func (m *ValueRaw) XXX_DiscardUnknown()

func (*ValueRaw) XXX_Marshal

func (m *ValueRaw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueRaw) XXX_Merge

func (m *ValueRaw) XXX_Merge(src proto.Message)

func (*ValueRaw) XXX_OneofFuncs

func (*ValueRaw) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ValueRaw) XXX_Size

func (m *ValueRaw) XXX_Size() int

func (*ValueRaw) XXX_Unmarshal

func (m *ValueRaw) XXX_Unmarshal(b []byte) error

type ValueRaw_Bool

type ValueRaw_Bool struct {
	Bool bool `protobuf:"varint,4,opt,name=bool,proto3,oneof"`
}

type ValueRaw_Bytes

type ValueRaw_Bytes struct {
	Bytes []byte `protobuf:"bytes,6,opt,name=bytes,proto3,oneof"`
}

type ValueRaw_Dict

type ValueRaw_Dict struct {
	Dict *ValueDict `protobuf:"bytes,8,opt,name=dict,proto3,oneof"`
}

type ValueRaw_Double

type ValueRaw_Double struct {
	Double float64 `protobuf:"fixed64,2,opt,name=double,proto3,oneof"`
}

type ValueRaw_Int64

type ValueRaw_Int64 struct {
	Int64 int64 `protobuf:"varint,3,opt,name=int64,proto3,oneof"`
}

type ValueRaw_List

type ValueRaw_List struct {
	List *ValueList `protobuf:"bytes,7,opt,name=list,proto3,oneof"`
}

type ValueRaw_Null

type ValueRaw_Null struct {
	Null NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=NullValue,oneof"`
}

type ValueRaw_String_

type ValueRaw_String_ struct {
	String_ string `protobuf:"bytes,5,opt,name=string,proto3,oneof"`
}

type ValueType

type ValueType int32
const (
	// Default value. Not to be used.
	ValueType_VALUE_TYPE_UNDEFINED ValueType = 0
	// Raw value. Not all values can be represented as a raw value.
	// The value before encoding should be at most 64 KB.
	ValueType_RAW ValueType = 1
	// Represent the value as a D3M dataset. Only "file://" schema is supported using a
	// shared file system. Dataset URI should point to the "datasetDoc.json" file of the dataset.
	// Only Dataset container values can be represented this way.
	ValueType_DATASET_URI ValueType = 2
	// Represent the value as a CSV file. Only "file://" schema is supported using a
	// shared file system. CSV URI should point to the file with ".csv" file extension.
	// Only tabular container values with numeric and string cell values can be represented
	// this way.
	ValueType_CSV_URI ValueType = 3
	// Represent values by Python-pickling them. Only "file://" schema is supported using a
	// shared file system. Pickle URI should point to the file with ".pickle" file extension.
	ValueType_PICKLE_URI ValueType = 4
	// Represent values by Python-pickling them but sending them through the API.
	// The value before encoding should be at most 64 KB.
	ValueType_PICKLE_BLOB ValueType = 5
	// Represent values with arrow and storing them into shared instance of Plasma.
	ValueType_PLASMA_ID ValueType = 6
	// Same as "RAW", but without any size limit.
	ValueType_LARGE_RAW ValueType = 7
	// Same as "PICKLE_BLOB", but without any size limit.
	ValueType_LARGE_PICKLE_BLOB ValueType = 8
)

func (ValueType) EnumDescriptor

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

func (ValueType) String

func (x ValueType) String() string

type Value_CsvUri

type Value_CsvUri struct {
	CsvUri string `protobuf:"bytes,4,opt,name=csv_uri,json=csvUri,proto3,oneof"`
}

type Value_DatasetUri

type Value_DatasetUri struct {
	DatasetUri string `protobuf:"bytes,3,opt,name=dataset_uri,json=datasetUri,proto3,oneof"`
}

type Value_Error

type Value_Error struct {
	Error *ValueError `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type Value_PickleBlob

type Value_PickleBlob struct {
	PickleBlob []byte `protobuf:"bytes,6,opt,name=pickle_blob,json=pickleBlob,proto3,oneof"`
}

type Value_PickleUri

type Value_PickleUri struct {
	PickleUri string `protobuf:"bytes,5,opt,name=pickle_uri,json=pickleUri,proto3,oneof"`
}

type Value_PlasmaId

type Value_PlasmaId struct {
	PlasmaId []byte `protobuf:"bytes,7,opt,name=plasma_id,json=plasmaId,proto3,oneof"`
}

type Value_Raw

type Value_Raw struct {
	Raw *ValueRaw `protobuf:"bytes,2,opt,name=raw,proto3,oneof"`
}

Jump to

Keyboard shortcuts

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