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 (*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 (*GetFitSolutionResultsRequest) XXX_DiscardUnknown

func (m *GetFitSolutionResultsRequest) XXX_DiscardUnknown()

func (*GetFitSolutionResultsRequest) XXX_Marshal

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

func (*GetFitSolutionResultsRequest) XXX_Merge

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

func (*GetFitSolutionResultsRequest) XXX_Size

func (m *GetFitSolutionResultsRequest) XXX_Size() int

func (*GetFitSolutionResultsRequest) XXX_Unmarshal

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

type GetFitSolutionResultsResponse

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

func (*GetFitSolutionResultsResponse) Descriptor

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

func (*GetFitSolutionResultsResponse) GetExposedOutputs

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

func (*GetFitSolutionResultsResponse) GetFittedSolutionId

func (m *GetFitSolutionResultsResponse) GetFittedSolutionId() string

func (*GetFitSolutionResultsResponse) GetProgress

func (m *GetFitSolutionResultsResponse) GetProgress() *Progress

func (*GetFitSolutionResultsResponse) GetSteps

func (*GetFitSolutionResultsResponse) ProtoMessage

func (*GetFitSolutionResultsResponse) ProtoMessage()

func (*GetFitSolutionResultsResponse) Reset

func (m *GetFitSolutionResultsResponse) Reset()

func (*GetFitSolutionResultsResponse) String

func (*GetFitSolutionResultsResponse) XXX_DiscardUnknown

func (m *GetFitSolutionResultsResponse) XXX_DiscardUnknown()

func (*GetFitSolutionResultsResponse) XXX_Marshal

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

func (*GetFitSolutionResultsResponse) XXX_Merge

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

func (*GetFitSolutionResultsResponse) XXX_Size

func (m *GetFitSolutionResultsResponse) XXX_Size() int

func (*GetFitSolutionResultsResponse) XXX_Unmarshal

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

type GetProduceSolutionResultsRequest

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

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

func (*GetProduceSolutionResultsRequest) Descriptor

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

func (*GetProduceSolutionResultsRequest) GetRequestId

func (m *GetProduceSolutionResultsRequest) GetRequestId() string

func (*GetProduceSolutionResultsRequest) ProtoMessage

func (*GetProduceSolutionResultsRequest) ProtoMessage()

func (*GetProduceSolutionResultsRequest) Reset

func (*GetProduceSolutionResultsRequest) String

func (*GetProduceSolutionResultsRequest) XXX_DiscardUnknown

func (m *GetProduceSolutionResultsRequest) XXX_DiscardUnknown()

func (*GetProduceSolutionResultsRequest) XXX_Marshal

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

func (*GetProduceSolutionResultsRequest) XXX_Merge

func (*GetProduceSolutionResultsRequest) XXX_Size

func (m *GetProduceSolutionResultsRequest) XXX_Size() int

func (*GetProduceSolutionResultsRequest) XXX_Unmarshal

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

type GetProduceSolutionResultsResponse

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

func (*GetProduceSolutionResultsResponse) Descriptor

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

func (*GetProduceSolutionResultsResponse) GetExposedOutputs

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

func (*GetProduceSolutionResultsResponse) GetProgress

func (m *GetProduceSolutionResultsResponse) GetProgress() *Progress

func (*GetProduceSolutionResultsResponse) GetSteps

func (*GetProduceSolutionResultsResponse) ProtoMessage

func (*GetProduceSolutionResultsResponse) ProtoMessage()

func (*GetProduceSolutionResultsResponse) Reset

func (*GetProduceSolutionResultsResponse) String

func (*GetProduceSolutionResultsResponse) XXX_DiscardUnknown

func (m *GetProduceSolutionResultsResponse) XXX_DiscardUnknown()

func (*GetProduceSolutionResultsResponse) XXX_Marshal

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

func (*GetProduceSolutionResultsResponse) XXX_Merge

func (*GetProduceSolutionResultsResponse) XXX_Size

func (m *GetProduceSolutionResultsResponse) XXX_Size() int

func (*GetProduceSolutionResultsResponse) XXX_Unmarshal

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

type GetScoreSolutionResultsRequest

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

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

func (*GetScoreSolutionResultsRequest) Descriptor

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

func (*GetScoreSolutionResultsRequest) GetRequestId

func (m *GetScoreSolutionResultsRequest) GetRequestId() string

func (*GetScoreSolutionResultsRequest) ProtoMessage

func (*GetScoreSolutionResultsRequest) ProtoMessage()

func (*GetScoreSolutionResultsRequest) Reset

func (m *GetScoreSolutionResultsRequest) Reset()

func (*GetScoreSolutionResultsRequest) String

func (*GetScoreSolutionResultsRequest) XXX_DiscardUnknown

func (m *GetScoreSolutionResultsRequest) XXX_DiscardUnknown()

func (*GetScoreSolutionResultsRequest) XXX_Marshal

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

func (*GetScoreSolutionResultsRequest) XXX_Merge

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

func (*GetScoreSolutionResultsRequest) XXX_Size

func (m *GetScoreSolutionResultsRequest) XXX_Size() int

func (*GetScoreSolutionResultsRequest) XXX_Unmarshal

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

type GetScoreSolutionResultsResponse

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

func (*GetScoreSolutionResultsResponse) Descriptor

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

func (*GetScoreSolutionResultsResponse) GetProgress

func (m *GetScoreSolutionResultsResponse) GetProgress() *Progress

func (*GetScoreSolutionResultsResponse) GetScores

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

func (*GetScoreSolutionResultsResponse) ProtoMessage

func (*GetScoreSolutionResultsResponse) ProtoMessage()

func (*GetScoreSolutionResultsResponse) Reset

func (*GetScoreSolutionResultsResponse) String

func (*GetScoreSolutionResultsResponse) XXX_DiscardUnknown

func (m *GetScoreSolutionResultsResponse) XXX_DiscardUnknown()

func (*GetScoreSolutionResultsResponse) XXX_Marshal

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

func (*GetScoreSolutionResultsResponse) XXX_Merge

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

func (*GetScoreSolutionResultsResponse) XXX_Size

func (m *GetScoreSolutionResultsResponse) XXX_Size() int

func (*GetScoreSolutionResultsResponse) XXX_Unmarshal

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

type GetSearchSolutionsResultsRequest

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

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

func (*GetSearchSolutionsResultsRequest) Descriptor

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

func (*GetSearchSolutionsResultsRequest) GetSearchId

func (m *GetSearchSolutionsResultsRequest) GetSearchId() string

func (*GetSearchSolutionsResultsRequest) ProtoMessage

func (*GetSearchSolutionsResultsRequest) ProtoMessage()

func (*GetSearchSolutionsResultsRequest) Reset

func (*GetSearchSolutionsResultsRequest) String

func (*GetSearchSolutionsResultsRequest) XXX_DiscardUnknown

func (m *GetSearchSolutionsResultsRequest) XXX_DiscardUnknown()

func (*GetSearchSolutionsResultsRequest) XXX_Marshal

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

func (*GetSearchSolutionsResultsRequest) XXX_Merge

func (*GetSearchSolutionsResultsRequest) XXX_Size

func (m *GetSearchSolutionsResultsRequest) XXX_Size() int

func (*GetSearchSolutionsResultsRequest) XXX_Unmarshal

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

type GetSearchSolutionsResultsResponse

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

func (*GetSearchSolutionsResultsResponse) Descriptor

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

func (*GetSearchSolutionsResultsResponse) GetAllTicks

func (m *GetSearchSolutionsResultsResponse) GetAllTicks() float64

func (*GetSearchSolutionsResultsResponse) GetDoneTicks

func (m *GetSearchSolutionsResultsResponse) GetDoneTicks() float64

func (*GetSearchSolutionsResultsResponse) GetInternalScore

func (m *GetSearchSolutionsResultsResponse) GetInternalScore() float64

func (*GetSearchSolutionsResultsResponse) GetProgress

func (m *GetSearchSolutionsResultsResponse) GetProgress() *Progress

func (*GetSearchSolutionsResultsResponse) GetScores

func (*GetSearchSolutionsResultsResponse) GetSolutionId

func (m *GetSearchSolutionsResultsResponse) GetSolutionId() string

func (*GetSearchSolutionsResultsResponse) ProtoMessage

func (*GetSearchSolutionsResultsResponse) ProtoMessage()

func (*GetSearchSolutionsResultsResponse) Reset

func (*GetSearchSolutionsResultsResponse) String

func (*GetSearchSolutionsResultsResponse) XXX_DiscardUnknown

func (m *GetSearchSolutionsResultsResponse) XXX_DiscardUnknown()

func (*GetSearchSolutionsResultsResponse) XXX_Marshal

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

func (*GetSearchSolutionsResultsResponse) XXX_Merge

func (*GetSearchSolutionsResultsResponse) XXX_Size

func (m *GetSearchSolutionsResultsResponse) XXX_Size() int

func (*GetSearchSolutionsResultsResponse) XXX_Unmarshal

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

type HelloRequest

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

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

func (*HelloRequest) Descriptor

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

func (*HelloRequest) ProtoMessage

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset

func (m *HelloRequest) Reset()

func (*HelloRequest) String

func (m *HelloRequest) String() string

func (*HelloRequest) XXX_DiscardUnknown

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal

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

func (*HelloRequest) XXX_Merge

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

func (*HelloRequest) XXX_Size

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal

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

type HelloResponse

type HelloResponse struct {
	// Some string identifying the name and version of the TA2 system.
	UserAgent string `protobuf:"bytes,1,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"`
	// Shall be set to "protocol_version" above.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// List of value types that a TA3 system can use to communicate values to a TA2 system.
	// The order is important as a TA3 system should try value types in order until one works
	// out, or an error will be returned instead of the value.
	AllowedValueTypes []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 (*PipelineDescription) GetName

func (m *PipelineDescription) GetName() string

func (*PipelineDescription) GetOutputs

func (*PipelineDescription) GetSource

func (m *PipelineDescription) GetSource() *PipelineSource

func (*PipelineDescription) GetSteps

func (*PipelineDescription) GetUsers

func (*PipelineDescription) ProtoMessage

func (*PipelineDescription) ProtoMessage()

func (*PipelineDescription) Reset

func (m *PipelineDescription) Reset()

func (*PipelineDescription) String

func (m *PipelineDescription) String() string

func (*PipelineDescription) XXX_DiscardUnknown

func (m *PipelineDescription) XXX_DiscardUnknown()

func (*PipelineDescription) XXX_Marshal

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

func (*PipelineDescription) XXX_Merge

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

func (*PipelineDescription) XXX_Size

func (m *PipelineDescription) XXX_Size() int

func (*PipelineDescription) XXX_Unmarshal

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

type PipelineDescriptionInput

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

Possible input to the pipeline or template.

func (*PipelineDescriptionInput) Descriptor

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

func (*PipelineDescriptionInput) GetName

func (m *PipelineDescriptionInput) GetName() string

func (*PipelineDescriptionInput) ProtoMessage

func (*PipelineDescriptionInput) ProtoMessage()

func (*PipelineDescriptionInput) Reset

func (m *PipelineDescriptionInput) Reset()

func (*PipelineDescriptionInput) String

func (m *PipelineDescriptionInput) String() string

func (*PipelineDescriptionInput) XXX_DiscardUnknown

func (m *PipelineDescriptionInput) XXX_DiscardUnknown()

func (*PipelineDescriptionInput) XXX_Marshal

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

func (*PipelineDescriptionInput) XXX_Merge

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

func (*PipelineDescriptionInput) XXX_Size

func (m *PipelineDescriptionInput) XXX_Size() int

func (*PipelineDescriptionInput) XXX_Unmarshal

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

type PipelineDescriptionOutput

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

Available output of the pipeline or template.

func (*PipelineDescriptionOutput) Descriptor

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

func (*PipelineDescriptionOutput) GetData

func (m *PipelineDescriptionOutput) GetData() string

func (*PipelineDescriptionOutput) GetName

func (m *PipelineDescriptionOutput) GetName() string

func (*PipelineDescriptionOutput) ProtoMessage

func (*PipelineDescriptionOutput) ProtoMessage()

func (*PipelineDescriptionOutput) Reset

func (m *PipelineDescriptionOutput) Reset()

func (*PipelineDescriptionOutput) String

func (m *PipelineDescriptionOutput) String() string

func (*PipelineDescriptionOutput) XXX_DiscardUnknown

func (m *PipelineDescriptionOutput) XXX_DiscardUnknown()

func (*PipelineDescriptionOutput) XXX_Marshal

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

func (*PipelineDescriptionOutput) XXX_Merge

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

func (*PipelineDescriptionOutput) XXX_Size

func (m *PipelineDescriptionOutput) XXX_Size() int

func (*PipelineDescriptionOutput) XXX_Unmarshal

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

type PipelineDescriptionStep

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

func (*PipelineDescriptionStep) Descriptor

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

func (*PipelineDescriptionStep) GetPipeline

func (*PipelineDescriptionStep) GetPlaceholder

func (*PipelineDescriptionStep) GetPrimitive

func (*PipelineDescriptionStep) GetStep

func (m *PipelineDescriptionStep) GetStep() isPipelineDescriptionStep_Step

func (*PipelineDescriptionStep) ProtoMessage

func (*PipelineDescriptionStep) ProtoMessage()

func (*PipelineDescriptionStep) Reset

func (m *PipelineDescriptionStep) Reset()

func (*PipelineDescriptionStep) String

func (m *PipelineDescriptionStep) String() string

func (*PipelineDescriptionStep) XXX_DiscardUnknown

func (m *PipelineDescriptionStep) XXX_DiscardUnknown()

func (*PipelineDescriptionStep) XXX_Marshal

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

func (*PipelineDescriptionStep) XXX_Merge

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

func (*PipelineDescriptionStep) XXX_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 (*PlaceholderPipelineDescriptionStep) GetOutputs

func (*PlaceholderPipelineDescriptionStep) ProtoMessage

func (*PlaceholderPipelineDescriptionStep) ProtoMessage()

func (*PlaceholderPipelineDescriptionStep) Reset

func (*PlaceholderPipelineDescriptionStep) String

func (*PlaceholderPipelineDescriptionStep) XXX_DiscardUnknown

func (m *PlaceholderPipelineDescriptionStep) XXX_DiscardUnknown()

func (*PlaceholderPipelineDescriptionStep) XXX_Marshal

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

func (*PlaceholderPipelineDescriptionStep) XXX_Merge

func (*PlaceholderPipelineDescriptionStep) XXX_Size

func (*PlaceholderPipelineDescriptionStep) XXX_Unmarshal

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

type Primitive

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

Description of the primitive.

func (*Primitive) Descriptor

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

func (*Primitive) GetDigest

func (m *Primitive) GetDigest() string

func (*Primitive) GetId

func (m *Primitive) GetId() string

func (*Primitive) GetName

func (m *Primitive) GetName() string

func (*Primitive) GetPythonPath

func (m *Primitive) GetPythonPath() string

func (*Primitive) GetVersion

func (m *Primitive) GetVersion() string

func (*Primitive) ProtoMessage

func (*Primitive) ProtoMessage()

func (*Primitive) Reset

func (m *Primitive) Reset()

func (*Primitive) String

func (m *Primitive) String() string

func (*Primitive) XXX_DiscardUnknown

func (m *Primitive) XXX_DiscardUnknown()

func (*Primitive) XXX_Marshal

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

func (*Primitive) XXX_Merge

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

func (*Primitive) XXX_Size

func (m *Primitive) XXX_Size() int

func (*Primitive) XXX_Unmarshal

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

type PrimitiveArgument

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

func (*PrimitiveArgument) Descriptor

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

func (*PrimitiveArgument) GetData

func (m *PrimitiveArgument) GetData() int32

func (*PrimitiveArgument) ProtoMessage

func (*PrimitiveArgument) ProtoMessage()

func (*PrimitiveArgument) Reset

func (m *PrimitiveArgument) Reset()

func (*PrimitiveArgument) String

func (m *PrimitiveArgument) String() string

func (*PrimitiveArgument) XXX_DiscardUnknown

func (m *PrimitiveArgument) XXX_DiscardUnknown()

func (*PrimitiveArgument) XXX_Marshal

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

func (*PrimitiveArgument) XXX_Merge

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

func (*PrimitiveArgument) XXX_Size

func (m *PrimitiveArgument) XXX_Size() int

func (*PrimitiveArgument) XXX_Unmarshal

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

type PrimitiveArguments

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

func (*PrimitiveArguments) Descriptor

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

func (*PrimitiveArguments) GetData

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

func (*PrimitiveArguments) ProtoMessage

func (*PrimitiveArguments) ProtoMessage()

func (*PrimitiveArguments) Reset

func (m *PrimitiveArguments) Reset()

func (*PrimitiveArguments) String

func (m *PrimitiveArguments) String() string

func (*PrimitiveArguments) XXX_DiscardUnknown

func (m *PrimitiveArguments) XXX_DiscardUnknown()

func (*PrimitiveArguments) XXX_Marshal

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

func (*PrimitiveArguments) XXX_Merge

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

func (*PrimitiveArguments) XXX_Size

func (m *PrimitiveArguments) XXX_Size() int

func (*PrimitiveArguments) XXX_Unmarshal

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

type PrimitivePipelineDescriptionStep

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

func (*PrimitivePipelineDescriptionStep) Descriptor

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

func (*PrimitivePipelineDescriptionStep) GetArguments

func (*PrimitivePipelineDescriptionStep) GetHyperparams

func (*PrimitivePipelineDescriptionStep) GetOutputs

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

func (*PrimitivePipelineDescriptionStep) GetPrimitive

func (m *PrimitivePipelineDescriptionStep) GetPrimitive() *Primitive

func (*PrimitivePipelineDescriptionStep) GetUsers

func (*PrimitivePipelineDescriptionStep) ProtoMessage

func (*PrimitivePipelineDescriptionStep) ProtoMessage()

func (*PrimitivePipelineDescriptionStep) Reset

func (*PrimitivePipelineDescriptionStep) String

func (*PrimitivePipelineDescriptionStep) XXX_DiscardUnknown

func (m *PrimitivePipelineDescriptionStep) XXX_DiscardUnknown()

func (*PrimitivePipelineDescriptionStep) XXX_Marshal

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

func (*PrimitivePipelineDescriptionStep) XXX_Merge

func (*PrimitivePipelineDescriptionStep) XXX_Size

func (m *PrimitivePipelineDescriptionStep) XXX_Size() int

func (*PrimitivePipelineDescriptionStep) XXX_Unmarshal

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

type PrimitiveStepArgument

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

func (*PrimitiveStepArgument) Descriptor

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

func (*PrimitiveStepArgument) GetArgument

func (m *PrimitiveStepArgument) GetArgument() isPrimitiveStepArgument_Argument

func (*PrimitiveStepArgument) GetContainer

func (m *PrimitiveStepArgument) GetContainer() *ContainerArgument

func (*PrimitiveStepArgument) GetContainerList

func (m *PrimitiveStepArgument) GetContainerList() *ContainerArguments

func (*PrimitiveStepArgument) GetData

func (m *PrimitiveStepArgument) GetData() *DataArgument

func (*PrimitiveStepArgument) ProtoMessage

func (*PrimitiveStepArgument) ProtoMessage()

func (*PrimitiveStepArgument) Reset

func (m *PrimitiveStepArgument) Reset()

func (*PrimitiveStepArgument) String

func (m *PrimitiveStepArgument) String() string

func (*PrimitiveStepArgument) XXX_DiscardUnknown

func (m *PrimitiveStepArgument) XXX_DiscardUnknown()

func (*PrimitiveStepArgument) XXX_Marshal

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

func (*PrimitiveStepArgument) XXX_Merge

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

func (*PrimitiveStepArgument) XXX_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 (*PrimitiveStepHyperparameter) GetData

func (*PrimitiveStepHyperparameter) GetDataSet

func (m *PrimitiveStepHyperparameter) GetDataSet() *DataArguments

func (*PrimitiveStepHyperparameter) GetPrimitive

func (*PrimitiveStepHyperparameter) GetPrimitivesSet

func (m *PrimitiveStepHyperparameter) GetPrimitivesSet() *PrimitiveArguments

func (*PrimitiveStepHyperparameter) GetValue

func (*PrimitiveStepHyperparameter) ProtoMessage

func (*PrimitiveStepHyperparameter) ProtoMessage()

func (*PrimitiveStepHyperparameter) Reset

func (m *PrimitiveStepHyperparameter) Reset()

func (*PrimitiveStepHyperparameter) String

func (m *PrimitiveStepHyperparameter) String() string

func (*PrimitiveStepHyperparameter) XXX_DiscardUnknown

func (m *PrimitiveStepHyperparameter) XXX_DiscardUnknown()

func (*PrimitiveStepHyperparameter) XXX_Marshal

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

func (*PrimitiveStepHyperparameter) XXX_Merge

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

func (*PrimitiveStepHyperparameter) XXX_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 (*ScorePredictionsRequest) GetPredictions

func (m *ScorePredictionsRequest) GetPredictions() *Value

func (*ScorePredictionsRequest) GetProblem

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 (*SubpipelinePipelineDescriptionStep) GetOutputs

func (*SubpipelinePipelineDescriptionStep) GetPipeline

func (*SubpipelinePipelineDescriptionStep) ProtoMessage

func (*SubpipelinePipelineDescriptionStep) ProtoMessage()

func (*SubpipelinePipelineDescriptionStep) Reset

func (*SubpipelinePipelineDescriptionStep) String

func (*SubpipelinePipelineDescriptionStep) XXX_DiscardUnknown

func (m *SubpipelinePipelineDescriptionStep) XXX_DiscardUnknown()

func (*SubpipelinePipelineDescriptionStep) XXX_Marshal

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

func (*SubpipelinePipelineDescriptionStep) XXX_Merge

func (*SubpipelinePipelineDescriptionStep) XXX_Size

func (*SubpipelinePipelineDescriptionStep) XXX_Unmarshal

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

type SubpipelineStepDescription

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

func (*SubpipelineStepDescription) Descriptor

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

func (*SubpipelineStepDescription) GetSteps

func (*SubpipelineStepDescription) ProtoMessage

func (*SubpipelineStepDescription) ProtoMessage()

func (*SubpipelineStepDescription) Reset

func (m *SubpipelineStepDescription) Reset()

func (*SubpipelineStepDescription) String

func (m *SubpipelineStepDescription) String() string

func (*SubpipelineStepDescription) XXX_DiscardUnknown

func (m *SubpipelineStepDescription) XXX_DiscardUnknown()

func (*SubpipelineStepDescription) XXX_Marshal

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

func (*SubpipelineStepDescription) XXX_Merge

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

func (*SubpipelineStepDescription) XXX_Size

func (m *SubpipelineStepDescription) XXX_Size() int

func (*SubpipelineStepDescription) XXX_Unmarshal

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

type UnimplementedCoreServer

type UnimplementedCoreServer struct {
}

UnimplementedCoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedCoreServer) DataAvailable

func (*UnimplementedCoreServer) DescribeSolution

func (*UnimplementedCoreServer) EndSearchSolutions

func (*UnimplementedCoreServer) FitSolution

func (*UnimplementedCoreServer) GetFitSolutionResults

func (*UnimplementedCoreServer) GetProduceSolutionResults

func (*UnimplementedCoreServer) GetScoreSolutionResults

func (*UnimplementedCoreServer) GetSearchSolutionsResults

func (*UnimplementedCoreServer) Hello

func (*UnimplementedCoreServer) ListPrimitives

func (*UnimplementedCoreServer) LoadFittedSolution

func (*UnimplementedCoreServer) LoadSolution

func (*UnimplementedCoreServer) ProduceSolution

func (*UnimplementedCoreServer) SaveFittedSolution

func (*UnimplementedCoreServer) SaveSolution

func (*UnimplementedCoreServer) ScorePredictions

func (*UnimplementedCoreServer) ScoreSolution

func (*UnimplementedCoreServer) SearchSolutions

func (*UnimplementedCoreServer) SolutionExport

func (*UnimplementedCoreServer) SplitData

func (*UnimplementedCoreServer) StopSearchSolutions

type UnimplementedExecutorServer

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutorServer) ExecutePipeline

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"`
}

Jump to

Keyboard shortcuts

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