pipeline

package
v0.0.0-...-39ca940 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2021 License: Apache-2.0 Imports: 9 Imported by: 2

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 NullValue_name = map[int32]string{
	0: "NULL_VALUE",
}
View Source 
var NullValue_value = map[string]int32{
	"NULL_VALUE": 0,
}
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,
}

Functions

func RegisterCoreServer 

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

func RegisterExecutorServer 

func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)

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)
	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)
	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)
	SplitData(ctx context.Context, in *SplitDataRequest, opts ...grpc.CallOption) (Core_SplitDataClient, error)
	ScorePredictions(ctx context.Context, in *ScorePredictionsRequest, opts ...grpc.CallOption) (*ScorePredictionsResponse, 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)
	DataAvailable(context.Context, *DataAvailableRequest) (*DataAvailableResponse, error)
	ListPrimitives(context.Context, *ListPrimitivesRequest) (*ListPrimitivesResponse, error)
	Hello(context.Context, *HelloRequest) (*HelloResponse, error)
	SaveSolution(context.Context, *SaveSolutionRequest) (*SaveSolutionResponse, error)
	LoadSolution(context.Context, *LoadSolutionRequest) (*LoadSolutionResponse, error)
	SaveFittedSolution(context.Context, *SaveFittedSolutionRequest) (*SaveFittedSolutionResponse, error)
	LoadFittedSolution(context.Context, *LoadFittedSolutionRequest) (*LoadFittedSolutionResponse, error)
	SplitData(*SplitDataRequest, Core_SplitDataServer) error
	ScorePredictions(context.Context, *ScorePredictionsRequest) (*ScorePredictionsResponse, 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 Core_SplitDataClient 

type Core_SplitDataClient interface {
	Recv() (*SplitDataResponse, error)
	grpc.ClientStream
}

type Core_SplitDataServer 

type Core_SplitDataServer interface {
	Send(*SplitDataResponse) 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.
	// 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 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 (m *DescribeSolutionResponse) GetPipeline() *PipelineDescription

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 ExecutorClient 

type ExecutorClient interface {
	ExecutePipeline(ctx context.Context, in *PipelineExecuteRequest, opts ...grpc.CallOption) (*PipelineExecuteResponse, error)
}

ExecutorClient is the client API for Executor service.

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

func NewExecutorClient 

func NewExecutorClient(cc *grpc.ClientConn) ExecutorClient

type ExecutorServer 

type ExecutorServer interface {
	ExecutePipeline(context.Context, *PipelineExecuteRequest) (*PipelineExecuteResponse, error)
}

ExecutorServer is the server API for Executor service.

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.
	// Data references for step outputs which otherwise would not be computed during
	// pipeline execution can also be provided to force them to be computed and exposed.
	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 []string `protobuf:"bytes,4,rep,name=expose_value_types,json=exposeValueTypes,proto3" json:"expose_value_types,omitempty"`
	// Any users associated with this call itself. Optional.
	Users []*SolutionRunUser `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"`
	// Seed for pseudorandom number generator. Note, not setting this value
	// means always using seed of 0.
	RandomSeed           int32    `protobuf:"varint,6,opt,name=random_seed,json=randomSeed,proto3" json:"random_seed,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() []string

func (*FitSolutionRequest) GetInputs 

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

func (*FitSolutionRequest) GetRandomSeed 

func (m *FitSolutionRequest) GetRandomSeed() int32

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 ForecastingHorizon 

type ForecastingHorizon struct {
	ResourceId           string   `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ColumnIndex          int32    `protobuf:"varint,2,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"`
	ColumnName           string   `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	HorizonValue         float64  `protobuf:"fixed64,4,opt,name=horizon_value,json=horizonValue,proto3" json:"horizon_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ForecastingHorizon) Descriptor 

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

func (*ForecastingHorizon) GetColumnIndex 

func (m *ForecastingHorizon) GetColumnIndex() int32

func (*ForecastingHorizon) GetColumnName 

func (m *ForecastingHorizon) GetColumnName() string

func (*ForecastingHorizon) GetHorizonValue 

func (m *ForecastingHorizon) GetHorizonValue() float64

func (*ForecastingHorizon) GetResourceId 

func (m *ForecastingHorizon) GetResourceId() string

func (*ForecastingHorizon) ProtoMessage 

func (*ForecastingHorizon) ProtoMessage()

func (*ForecastingHorizon) Reset 

func (m *ForecastingHorizon) Reset()

func (*ForecastingHorizon) String 

func (m *ForecastingHorizon) String() string

func (*ForecastingHorizon) XXX_DiscardUnknown 

func (m *ForecastingHorizon) XXX_DiscardUnknown()

func (*ForecastingHorizon) XXX_Marshal 

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

func (*ForecastingHorizon) XXX_Merge 

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

func (*ForecastingHorizon) XXX_Size 

func (m *ForecastingHorizon) XXX_Size() int

func (*ForecastingHorizon) XXX_Unmarshal 

func (m *ForecastingHorizon) 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 (m *GetFitSolutionResultsRequest) String() 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 (m *GetFitSolutionResultsResponse) GetSteps() []*StepProgress

func (*GetFitSolutionResultsResponse) ProtoMessage 

func (*GetFitSolutionResultsResponse) ProtoMessage()

func (*GetFitSolutionResultsResponse) Reset 

func (m *GetFitSolutionResultsResponse) Reset()

func (*GetFitSolutionResultsResponse) String 

func (m *GetFitSolutionResultsResponse) String() 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 (m *GetProduceSolutionResultsRequest) Reset()

func (*GetProduceSolutionResultsRequest) String 

func (m *GetProduceSolutionResultsRequest) String() 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 (m *GetProduceSolutionResultsRequest) XXX_Merge(src proto.Message)

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 (m *GetProduceSolutionResultsResponse) GetSteps() []*StepProgress

func (*GetProduceSolutionResultsResponse) ProtoMessage 

func (*GetProduceSolutionResultsResponse) ProtoMessage()

func (*GetProduceSolutionResultsResponse) Reset 

func (m *GetProduceSolutionResultsResponse) Reset()

func (*GetProduceSolutionResultsResponse) String 

func (m *GetProduceSolutionResultsResponse) String() 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 (m *GetProduceSolutionResultsResponse) XXX_Merge(src proto.Message)

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 (m *GetScoreSolutionResultsRequest) String() 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 (m *GetScoreSolutionResultsResponse) Reset()

func (*GetScoreSolutionResultsResponse) String 

func (m *GetScoreSolutionResultsResponse) String() 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 (m *GetSearchSolutionsResultsRequest) Reset()

func (*GetSearchSolutionsResultsRequest) String 

func (m *GetSearchSolutionsResultsRequest) String() 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 (m *GetSearchSolutionsResultsRequest) XXX_Merge(src proto.Message)

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 (m *GetSearchSolutionsResultsResponse) GetScores() []*SolutionSearchScore

func (*GetSearchSolutionsResultsResponse) GetSolutionId 

func (m *GetSearchSolutionsResultsResponse) GetSolutionId() string

func (*GetSearchSolutionsResultsResponse) ProtoMessage 

func (*GetSearchSolutionsResultsResponse) ProtoMessage()

func (*GetSearchSolutionsResultsResponse) Reset 

func (m *GetSearchSolutionsResultsResponse) Reset()

func (*GetSearchSolutionsResultsResponse) String 

func (m *GetSearchSolutionsResultsResponse) String() 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 (m *GetSearchSolutionsResultsResponse) XXX_Merge(src proto.Message)

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 []string `protobuf:"bytes,3,rep,name=allowed_value_types,json=allowedValueTypes,proto3" json:"allowed_value_types,omitempty"`
	// List of API extensions that a TA2 supports.
	SupportedExtensions         []string `protobuf:"bytes,4,rep,name=supported_extensions,json=supportedExtensions,proto3" json:"supported_extensions,omitempty"`
	SupportedTaskKeywords       []string `` /* 126-byte string literal not displayed */
	SupportedPerformanceMetrics []string `` /* 144-byte string literal not displayed */
	SupportedEvaluationMethods  []string `` /* 141-byte string literal not displayed */
	// Supported search features by TA2. Can be an empty list if TA2 does not respect suggested
	// search features for any search request, or does not support any search features.
	// (TA2 can always ignore a suggested search feature for a particular search request,
	// even if a search feature is listed here.)
	SupportedSearchFeatures []string `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

This response signifies that the TA2 is ready to begin a search. For evaluation purposes, it is advisable that TA2's not respond positively until they have the primitives library loaded and are ready for to begin a search, otherwise the time required to load the library will count against them by the dummy TA3. Starting to listen on gRPC port signals that system is running.

func (*HelloResponse) Descriptor 

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

func (*HelloResponse) GetAllowedValueTypes 

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

func (*HelloResponse) GetSupportedEvaluationMethods 

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

func (*HelloResponse) GetSupportedExtensions 

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

func (*HelloResponse) GetSupportedPerformanceMetrics 

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

func (*HelloResponse) GetSupportedSearchFeatures 

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

func (*HelloResponse) GetSupportedTaskKeywords 

func (m *HelloResponse) GetSupportedTaskKeywords() []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 saved 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 {
	// ID of a fitted solution which was 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 saved solution.
	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 a 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 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"`
	// 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) 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 (m *PipelineDescription) GetInputs() []*PipelineDescriptionInput

func (*PipelineDescription) GetName 

func (m *PipelineDescription) GetName() string

func (*PipelineDescription) GetOutputs 

func (m *PipelineDescription) GetOutputs() []*PipelineDescriptionOutput

func (*PipelineDescription) GetSource 

func (m *PipelineDescription) GetSource() *PipelineSource

func (*PipelineDescription) GetSteps 

func (m *PipelineDescription) GetSteps() []*PipelineDescriptionStep

func (*PipelineDescription) GetUsers 

func (m *PipelineDescription) GetUsers() []*PipelineDescriptionUser

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 (m *PipelineDescriptionStep) GetPipeline() *SubpipelinePipelineDescriptionStep

func (*PipelineDescriptionStep) GetPlaceholder 

func (m *PipelineDescriptionStep) GetPlaceholder() *PlaceholderPipelineDescriptionStep

func (*PipelineDescriptionStep) GetPrimitive 

func (m *PipelineDescriptionStep) GetPrimitive() *PrimitivePipelineDescriptionStep

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_OneofWrappers 

func (*PipelineDescriptionStep) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 PipelineExecuteRequest 

type PipelineExecuteRequest struct {
	PipelineDescription  *PipelineDescription `protobuf:"bytes,1,opt,name=pipelineDescription,proto3" json:"pipelineDescription,omitempty"`
	Inputs               []*Value             `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PipelineExecuteRequest) Descriptor 

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

func (*PipelineExecuteRequest) GetInputs 

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

func (*PipelineExecuteRequest) GetPipelineDescription 

func (m *PipelineExecuteRequest) GetPipelineDescription() *PipelineDescription

func (*PipelineExecuteRequest) ProtoMessage 

func (*PipelineExecuteRequest) ProtoMessage()

func (*PipelineExecuteRequest) Reset 

func (m *PipelineExecuteRequest) Reset()

func (*PipelineExecuteRequest) String 

func (m *PipelineExecuteRequest) String() string

func (*PipelineExecuteRequest) XXX_DiscardUnknown 

func (m *PipelineExecuteRequest) XXX_DiscardUnknown()

func (*PipelineExecuteRequest) XXX_Marshal 

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

func (*PipelineExecuteRequest) XXX_Merge 

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

func (*PipelineExecuteRequest) XXX_Size 

func (m *PipelineExecuteRequest) XXX_Size() int

func (*PipelineExecuteRequest) XXX_Unmarshal 

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

type PipelineExecuteResponse 

type PipelineExecuteResponse struct {
	ResultURI            string   `protobuf:"bytes,1,opt,name=resultURI,proto3" json:"resultURI,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PipelineExecuteResponse) Descriptor 

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

func (*PipelineExecuteResponse) GetResultURI 

func (m *PipelineExecuteResponse) GetResultURI() string

func (*PipelineExecuteResponse) ProtoMessage 

func (*PipelineExecuteResponse) ProtoMessage()

func (*PipelineExecuteResponse) Reset 

func (m *PipelineExecuteResponse) Reset()

func (*PipelineExecuteResponse) String 

func (m *PipelineExecuteResponse) String() string

func (*PipelineExecuteResponse) XXX_DiscardUnknown 

func (m *PipelineExecuteResponse) XXX_DiscardUnknown()

func (*PipelineExecuteResponse) XXX_Marshal 

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

func (*PipelineExecuteResponse) XXX_Merge 

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

func (*PipelineExecuteResponse) XXX_Size 

func (m *PipelineExecuteResponse) XXX_Size() int

func (*PipelineExecuteResponse) XXX_Unmarshal 

func (m *PipelineExecuteResponse) 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 (m *PlaceholderPipelineDescriptionStep) GetInputs() []*StepInput

func (*PlaceholderPipelineDescriptionStep) GetOutputs 

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

func (*PlaceholderPipelineDescriptionStep) ProtoMessage 

func (*PlaceholderPipelineDescriptionStep) ProtoMessage()

func (*PlaceholderPipelineDescriptionStep) Reset 

func (m *PlaceholderPipelineDescriptionStep) Reset()

func (*PlaceholderPipelineDescriptionStep) String 

func (m *PlaceholderPipelineDescriptionStep) String() 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 (m *PlaceholderPipelineDescriptionStep) XXX_Merge(src proto.Message)

func (*PlaceholderPipelineDescriptionStep) XXX_Size 

func (m *PlaceholderPipelineDescriptionStep) XXX_Size() int

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 (m *PrimitivePipelineDescriptionStep) GetArguments() map[string]*PrimitiveStepArgument

func (*PrimitivePipelineDescriptionStep) GetHyperparams 

func (m *PrimitivePipelineDescriptionStep) GetHyperparams() map[string]*PrimitiveStepHyperparameter

func (*PrimitivePipelineDescriptionStep) GetOutputs 

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

func (*PrimitivePipelineDescriptionStep) GetPrimitive 

func (m *PrimitivePipelineDescriptionStep) GetPrimitive() *Primitive

func (*PrimitivePipelineDescriptionStep) GetUsers 

func (m *PrimitivePipelineDescriptionStep) GetUsers() []*PipelineDescriptionUser

func (*PrimitivePipelineDescriptionStep) ProtoMessage 

func (*PrimitivePipelineDescriptionStep) ProtoMessage()

func (*PrimitivePipelineDescriptionStep) Reset 

func (m *PrimitivePipelineDescriptionStep) Reset()

func (*PrimitivePipelineDescriptionStep) String 

func (m *PrimitivePipelineDescriptionStep) String() 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 (m *PrimitivePipelineDescriptionStep) XXX_Merge(src proto.Message)

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_OneofWrappers 

func (*PrimitiveStepArgument) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 (m *PrimitiveStepHyperparameter) GetContainer() *ContainerArgument

func (*PrimitiveStepHyperparameter) GetData 

func (m *PrimitiveStepHyperparameter) GetData() *DataArgument

func (*PrimitiveStepHyperparameter) GetDataSet 

func (m *PrimitiveStepHyperparameter) GetDataSet() *DataArguments

func (*PrimitiveStepHyperparameter) GetPrimitive 

func (m *PrimitiveStepHyperparameter) GetPrimitive() *PrimitiveArgument

func (*PrimitiveStepHyperparameter) GetPrimitivesSet 

func (m *PrimitiveStepHyperparameter) GetPrimitivesSet() *PrimitiveArguments

func (*PrimitiveStepHyperparameter) GetValue 

func (m *PrimitiveStepHyperparameter) GetValue() *ValueArgument

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_OneofWrappers 

func (*PrimitiveStepHyperparameter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 {
	// Task keywords of the problem. Standard values are required
	// to be supported and are available here:
	// https://metadata.datadrivendiscovery.org/devel/?definitions#definitions.problem.task_keywords
	//
	// No standard value will ever start with "_", so if you worry about
	// potential conflicts with future standard values, consider starting
	// your non-standard values with "_'.
	TaskKeywords         []string                    `protobuf:"bytes,8,rep,name=task_keywords,json=taskKeywords,proto3" json:"task_keywords,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) GetTaskKeywords 

func (m *Problem) GetTaskKeywords() []string

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"`
	ForecastingHorizon   *ForecastingHorizon      `protobuf:"bytes,4,opt,name=forecasting_horizon,json=forecastingHorizon,proto3" json:"forecasting_horizon,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) GetForecastingHorizon 

func (m *ProblemInput) GetForecastingHorizon() *ForecastingHorizon

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 {
	// The evaluation metric. Standard values are required to be supported
	// and are available here:
	// https://metadata.datadrivendiscovery.org/devel/?definitions#definitions.performance_metric
	//
	// In addition, "RANK" metric should be also supported. "RANK" metric
	// can be used for a rank of a solution among all found solutions of
	// a given "SearchSolutions" call. Rank is a non-negative floating-point number.
	// Lower numbers represent better solutions. Each ranked solution should have
	// a different rank (for all solutions of a given "SearchSolutions" call).
	// Only possible with "RANKING" evaluation method.
	//
	// The following additional metrics are defined to allow expressing
	// internal evaluation scores used by TA2 during solution search.
	// If any you are using is missing, feel free to request it to be added.
	// * "LOSS"
	//   Average loss of an unspecified loss function.
	//
	// No standard value will ever start with "_", so if you worry about
	// potential conflicts with future standard values, consider starting
	// your non-standard values with "_'.
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" 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 (m *ProblemPerformanceMetric) GetMetric() string

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.
	// Data references for step outputs which otherwise would not be computed during
	// pipeline execution can also be provided to force them to be computed and exposed.
	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 []string `protobuf:"bytes,4,rep,name=expose_value_types,json=exposeValueTypes,proto3" json:"expose_value_types,omitempty"`
	// 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() []string

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 SaveFittedSolutionRequest 

type SaveFittedSolutionRequest struct {
	// ID of a fitted solution to save.
	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.

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 saved 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 a solution to save.
	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.

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 saved solution.
	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.
	// Note, not setting this value means always using seed of 0.
	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 ScorePredictionsRequest 

type ScorePredictionsRequest struct {
	// Predictions computed on the data.
	Predictions *Value `protobuf:"bytes,1,opt,name=predictions,proto3" json:"predictions,omitempty"`
	// Score data containing the true labels on the same split for comparison.
	ScoreInput *Value `protobuf:"bytes,4,opt,name=score_input,json=scoreInput,proto3" json:"score_input,omitempty"`
	// Problem definition.
	Problem *ProblemDescription `protobuf:"bytes,2,opt,name=problem,proto3" json:"problem,omitempty"`
	// List of metrics. If not empty, those metrics will be computed by the TA2 instead of the ones
	// listed in the problem.
	Metric               []*ProblemPerformanceMetric `protobuf:"bytes,3,rep,name=metric,proto3" json:"metric,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ScorePredictionsRequest) Descriptor 

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

func (*ScorePredictionsRequest) GetMetric 

func (m *ScorePredictionsRequest) GetMetric() []*ProblemPerformanceMetric

func (*ScorePredictionsRequest) GetPredictions 

func (m *ScorePredictionsRequest) GetPredictions() *Value

func (*ScorePredictionsRequest) GetProblem 

func (m *ScorePredictionsRequest) GetProblem() *ProblemDescription

func (*ScorePredictionsRequest) GetScoreInput 

func (m *ScorePredictionsRequest) GetScoreInput() *Value

func (*ScorePredictionsRequest) ProtoMessage 

func (*ScorePredictionsRequest) ProtoMessage()

func (*ScorePredictionsRequest) Reset 

func (m *ScorePredictionsRequest) Reset()

func (*ScorePredictionsRequest) String 

func (m *ScorePredictionsRequest) String() string

func (*ScorePredictionsRequest) XXX_DiscardUnknown 

func (m *ScorePredictionsRequest) XXX_DiscardUnknown()

func (*ScorePredictionsRequest) XXX_Marshal 

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

func (*ScorePredictionsRequest) XXX_Merge 

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

func (*ScorePredictionsRequest) XXX_Size 

func (m *ScorePredictionsRequest) XXX_Size() int

func (*ScorePredictionsRequest) XXX_Unmarshal 

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

type ScorePredictionsResponse 

type ScorePredictionsResponse struct {
	// Scores for the predictions.
	Scores               []*Score `protobuf:"bytes,1,rep,name=scores,proto3" json:"scores,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScorePredictionsResponse) Descriptor 

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

func (*ScorePredictionsResponse) GetScores 

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

func (*ScorePredictionsResponse) ProtoMessage 

func (*ScorePredictionsResponse) ProtoMessage()

func (*ScorePredictionsResponse) Reset 

func (m *ScorePredictionsResponse) Reset()

func (*ScorePredictionsResponse) String 

func (m *ScorePredictionsResponse) String() string

func (*ScorePredictionsResponse) XXX_DiscardUnknown 

func (m *ScorePredictionsResponse) XXX_DiscardUnknown()

func (*ScorePredictionsResponse) XXX_Marshal 

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

func (*ScorePredictionsResponse) XXX_Merge 

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

func (*ScorePredictionsResponse) XXX_Size 

func (m *ScorePredictionsResponse) XXX_Size() int

func (*ScorePredictionsResponse) XXX_Unmarshal 

func (m *ScorePredictionsResponse) 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. Standard values are required to
	// be supported and are:
	// * "HOLDOUT"
	// * "K_FOLD"
	//
	// In addition, "RANKING" evaluation method should be also supported.
	// "RANKING" evaluation method can be used for a rank of a solution
	// among 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.
	//
	// The following additional evaluation methods 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.
	// * "LEAVE_ONE_OUT"
	// * "PREDICTION"
	//   Instead of really scoring, a TA2 might predict the score only.
	// * "TRAINING_DATA"
	//   Training data is reused to test as well.
	//
	// No standard value will ever start with "_", so if you worry about
	// potential conflicts with future standard values, consider starting
	// your non-standard values with "_'.
	Method string `protobuf:"bytes,1,opt,name=method,proto3" 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. Note, not setting this value
	// means always using seed of 0.
	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() string

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.
	// 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 []string `protobuf:"bytes,5,rep,name=allowed_value_types,json=allowedValueTypes,proto3" json:"allowed_value_types,omitempty"`
	// 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-parameter tuning call over free hyper-parameters and found solutions
	// share the same pipeline, but different hyper-parameter configurations (unless
	// "use_default_values_for_free_hyperparams" is set to true). 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:
	//  - Omitted templates,
	//  - Partial pipelines with one placeholder step, at the last step in the pipeline template,
	//  - Fully specified pipelines without free hyper-parameters, or with free hyper-parameters
	//    and "use_default_values_for_free_hyperparams" set to true.
	// See the Pipeline section of the 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.
	// 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"`
	// Random seed used to initiate search.  Note, not setting this value means
	// always using seed of 0.
	RandomSeed int32 `protobuf:"varint,11,opt,name=random_seed,json=randomSeed,proto3" json:"random_seed,omitempty"`
	// If set to true, during search TA2 is suggested to not do hyper-parameter tuning
	// of free hyper-parameters but use their default values. It might be that TA2
	// operates searches for both the pipeline and hyper-parameter values at the same
	// time and flag cannot be easily respected, in that case this flag can be ignored by TA2.
	// When template is provided and contains free hyper-parameters but no placeholders,
	// then setting this flag to true means that for all free hyper-parameters in the
	// template default values should be used. This allows TA3 to not have to fix
	// values for all free hyper-parameters in the template itself, to obtain a
	// fully specified pipelines without free hyper-parameters.
	// Generally applies only to tuning hyper-parameters.
	UseDefaultValuesForFreeHyperparams bool `` /* 173-byte string literal not displayed */
	// Suggested TA2 search features to use, from ones supported by TA2 as
	// provided in "supported_search_features" of the "HelloResponse".
	// TA2 can ignore any suggestion. When not provided or when ignored, TA2
	// can use any search features, or even search features not
	// listed in "supported_search_feature".
	SearchFeatures       []string `protobuf:"bytes,13,rep,name=search_features,json=searchFeatures,proto3" json:"search_features,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() []string

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

func (m *SearchSolutionsRequest) GetRandomSeed() int32

func (*SearchSolutionsRequest) GetRankSolutionsLimit 

func (m *SearchSolutionsRequest) GetRankSolutionsLimit() int32

func (*SearchSolutionsRequest) GetSearchFeatures 

func (m *SearchSolutionsRequest) GetSearchFeatures() []string

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

func (m *SearchSolutionsRequest) GetUseDefaultValuesForFreeHyperparams() bool

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 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. Rank is a non-negative floating-point number.
	// Lower numbers represent better solutions. Each exported solution should 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, but all exported files should be inside a directory
	// with a name equal to the search ID of the search the exported solution belongs to.
	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 SplitDataRequest 

type SplitDataRequest struct {
	// The input dataset to be split.
	Input *Value `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// How to perform the split. Note that only "HOLDOUT" and "K_FOLD" make sense for the
	// EvaluationMethod.
	ScoringConfiguration *ScoringConfiguration `protobuf:"bytes,2,opt,name=scoring_configuration,json=scoringConfiguration,proto3" json:"scoring_configuration,omitempty"`
	// Which value types should be used for outputs.
	// 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.
	AllowedValueTypes []string `protobuf:"bytes,3,rep,name=allowed_value_types,json=allowedValueTypes,proto3" json:"allowed_value_types,omitempty"`
	// The problem, which is necessary for some splitting methods like stratified splits.
	Problem              *ProblemDescription `protobuf:"bytes,4,opt,name=problem,proto3" json:"problem,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SplitDataRequest) Descriptor 

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

func (*SplitDataRequest) GetAllowedValueTypes 

func (m *SplitDataRequest) GetAllowedValueTypes() []string

func (*SplitDataRequest) GetInput 

func (m *SplitDataRequest) GetInput() *Value

func (*SplitDataRequest) GetProblem 

func (m *SplitDataRequest) GetProblem() *ProblemDescription

func (*SplitDataRequest) GetScoringConfiguration 

func (m *SplitDataRequest) GetScoringConfiguration() *ScoringConfiguration

func (*SplitDataRequest) ProtoMessage 

func (*SplitDataRequest) ProtoMessage()

func (*SplitDataRequest) Reset 

func (m *SplitDataRequest) Reset()

func (*SplitDataRequest) String 

func (m *SplitDataRequest) String() string

func (*SplitDataRequest) XXX_DiscardUnknown 

func (m *SplitDataRequest) XXX_DiscardUnknown()

func (*SplitDataRequest) XXX_Marshal 

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

func (*SplitDataRequest) XXX_Merge 

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

func (*SplitDataRequest) XXX_Size 

func (m *SplitDataRequest) XXX_Size() int

func (*SplitDataRequest) XXX_Unmarshal 

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

type SplitDataResponse 

type SplitDataResponse struct {
	TrainOutput          *Value   `protobuf:"bytes,1,opt,name=train_output,json=trainOutput,proto3" json:"train_output,omitempty"`
	TestOutput           *Value   `protobuf:"bytes,2,opt,name=test_output,json=testOutput,proto3" json:"test_output,omitempty"`
	ScoreOutput          *Value   `protobuf:"bytes,3,opt,name=score_output,json=scoreOutput,proto3" json:"score_output,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SplitDataResponse) Descriptor 

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

func (*SplitDataResponse) GetScoreOutput 

func (m *SplitDataResponse) GetScoreOutput() *Value

func (*SplitDataResponse) GetTestOutput 

func (m *SplitDataResponse) GetTestOutput() *Value

func (*SplitDataResponse) GetTrainOutput 

func (m *SplitDataResponse) GetTrainOutput() *Value

func (*SplitDataResponse) ProtoMessage 

func (*SplitDataResponse) ProtoMessage()

func (*SplitDataResponse) Reset 

func (m *SplitDataResponse) Reset()

func (*SplitDataResponse) String 

func (m *SplitDataResponse) String() string

func (*SplitDataResponse) XXX_DiscardUnknown 

func (m *SplitDataResponse) XXX_DiscardUnknown()

func (*SplitDataResponse) XXX_Marshal 

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

func (*SplitDataResponse) XXX_Merge 

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

func (*SplitDataResponse) XXX_Size 

func (m *SplitDataResponse) XXX_Size() int

func (*SplitDataResponse) XXX_Unmarshal 

func (m *SplitDataResponse) 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_OneofWrappers 

func (*StepDescription) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 (m *SubpipelinePipelineDescriptionStep) GetInputs() []*StepInput

func (*SubpipelinePipelineDescriptionStep) GetOutputs 

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

func (*SubpipelinePipelineDescriptionStep) GetPipeline 

func (m *SubpipelinePipelineDescriptionStep) GetPipeline() *PipelineDescription

func (*SubpipelinePipelineDescriptionStep) ProtoMessage 

func (*SubpipelinePipelineDescriptionStep) ProtoMessage()

func (*SubpipelinePipelineDescriptionStep) Reset 

func (m *SubpipelinePipelineDescriptionStep) Reset()

func (*SubpipelinePipelineDescriptionStep) String 

func (m *SubpipelinePipelineDescriptionStep) String() 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 (m *SubpipelinePipelineDescriptionStep) XXX_Merge(src proto.Message)

func (*SubpipelinePipelineDescriptionStep) XXX_Size 

func (m *SubpipelinePipelineDescriptionStep) XXX_Size() int

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 (m *SubpipelineStepDescription) GetSteps() []*StepDescription

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 UnimplementedCoreServer 

type UnimplementedCoreServer struct {
}

UnimplementedCoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedCoreServer) DataAvailable 

func (*UnimplementedCoreServer) DataAvailable(ctx context.Context, req *DataAvailableRequest) (*DataAvailableResponse, error)

func (*UnimplementedCoreServer) DescribeSolution 

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

func (*UnimplementedCoreServer) EndSearchSolutions 

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

func (*UnimplementedCoreServer) FitSolution 

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

func (*UnimplementedCoreServer) GetFitSolutionResults 

func (*UnimplementedCoreServer) GetFitSolutionResults(req *GetFitSolutionResultsRequest, srv Core_GetFitSolutionResultsServer) error

func (*UnimplementedCoreServer) GetProduceSolutionResults 

func (*UnimplementedCoreServer) GetProduceSolutionResults(req *GetProduceSolutionResultsRequest, srv Core_GetProduceSolutionResultsServer) error

func (*UnimplementedCoreServer) GetScoreSolutionResults 

func (*UnimplementedCoreServer) GetScoreSolutionResults(req *GetScoreSolutionResultsRequest, srv Core_GetScoreSolutionResultsServer) error

func (*UnimplementedCoreServer) GetSearchSolutionsResults 

func (*UnimplementedCoreServer) GetSearchSolutionsResults(req *GetSearchSolutionsResultsRequest, srv Core_GetSearchSolutionsResultsServer) error

func (*UnimplementedCoreServer) Hello 

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

func (*UnimplementedCoreServer) ListPrimitives 

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

func (*UnimplementedCoreServer) LoadFittedSolution 

func (*UnimplementedCoreServer) LoadFittedSolution(ctx context.Context, req *LoadFittedSolutionRequest) (*LoadFittedSolutionResponse, error)

func (*UnimplementedCoreServer) LoadSolution 

func (*UnimplementedCoreServer) LoadSolution(ctx context.Context, req *LoadSolutionRequest) (*LoadSolutionResponse, error)

func (*UnimplementedCoreServer) ProduceSolution 

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

func (*UnimplementedCoreServer) SaveFittedSolution 

func (*UnimplementedCoreServer) SaveFittedSolution(ctx context.Context, req *SaveFittedSolutionRequest) (*SaveFittedSolutionResponse, error)

func (*UnimplementedCoreServer) SaveSolution 

func (*UnimplementedCoreServer) SaveSolution(ctx context.Context, req *SaveSolutionRequest) (*SaveSolutionResponse, error)

func (*UnimplementedCoreServer) ScorePredictions 

func (*UnimplementedCoreServer) ScorePredictions(ctx context.Context, req *ScorePredictionsRequest) (*ScorePredictionsResponse, error)

func (*UnimplementedCoreServer) ScoreSolution 

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

func (*UnimplementedCoreServer) SearchSolutions 

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

func (*UnimplementedCoreServer) SolutionExport 

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

func (*UnimplementedCoreServer) SplitData 

func (*UnimplementedCoreServer) SplitData(req *SplitDataRequest, srv Core_SplitDataServer) error

func (*UnimplementedCoreServer) StopSearchSolutions 

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

type UnimplementedExecutorServer 

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutorServer) ExecutePipeline 

func (*UnimplementedExecutorServer) ExecutePipeline(ctx context.Context, req *PipelineExecuteRequest) (*PipelineExecuteResponse, 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_ParquetUri
	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) GetParquetUri 

func (m *Value) GetParquetUri() string

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_OneofWrappers 

func (*Value) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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_OneofWrappers 

func (*ValueRaw) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 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_ParquetUri 

type Value_ParquetUri struct {
	ParquetUri string `protobuf:"bytes,8,opt,name=parquet_uri,json=parquetUri,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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

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