Documentation ¶
Index ¶
- Variables
- func APIVersion() string
- func RegisterCoreServer(s *grpc.Server, srv CoreServer)
- type ContainerArgument
- func (*ContainerArgument) Descriptor() ([]byte, []int)
- func (m *ContainerArgument) GetData() string
- func (*ContainerArgument) ProtoMessage()
- func (m *ContainerArgument) Reset()
- func (m *ContainerArgument) String() string
- func (m *ContainerArgument) XXX_DiscardUnknown()
- func (m *ContainerArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainerArgument) XXX_Merge(src proto.Message)
- func (m *ContainerArgument) XXX_Size() int
- func (m *ContainerArgument) XXX_Unmarshal(b []byte) error
- type ContainerArguments
- func (*ContainerArguments) Descriptor() ([]byte, []int)
- func (m *ContainerArguments) GetData() []string
- func (*ContainerArguments) ProtoMessage()
- func (m *ContainerArguments) Reset()
- func (m *ContainerArguments) String() string
- func (m *ContainerArguments) XXX_DiscardUnknown()
- func (m *ContainerArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainerArguments) XXX_Merge(src proto.Message)
- func (m *ContainerArguments) XXX_Size() int
- func (m *ContainerArguments) XXX_Unmarshal(b []byte) error
- type CoreClient
- type CoreServer
- type Core_GetFitSolutionResultsClient
- type Core_GetFitSolutionResultsServer
- type Core_GetProduceSolutionResultsClient
- type Core_GetProduceSolutionResultsServer
- type Core_GetScoreSolutionResultsClient
- type Core_GetScoreSolutionResultsServer
- type Core_GetSearchSolutionsResultsClient
- type Core_GetSearchSolutionsResultsServer
- type DataArgument
- func (*DataArgument) Descriptor() ([]byte, []int)
- func (m *DataArgument) GetData() string
- func (*DataArgument) ProtoMessage()
- func (m *DataArgument) Reset()
- func (m *DataArgument) String() string
- func (m *DataArgument) XXX_DiscardUnknown()
- func (m *DataArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataArgument) XXX_Merge(src proto.Message)
- func (m *DataArgument) XXX_Size() int
- func (m *DataArgument) XXX_Unmarshal(b []byte) error
- type DataArguments
- func (*DataArguments) Descriptor() ([]byte, []int)
- func (m *DataArguments) GetData() []string
- func (*DataArguments) ProtoMessage()
- func (m *DataArguments) Reset()
- func (m *DataArguments) String() string
- func (m *DataArguments) XXX_DiscardUnknown()
- func (m *DataArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataArguments) XXX_Merge(src proto.Message)
- func (m *DataArguments) XXX_Size() int
- func (m *DataArguments) XXX_Unmarshal(b []byte) error
- type DataAugmentation
- func (*DataAugmentation) Descriptor() ([]byte, []int)
- func (m *DataAugmentation) GetDomain() []string
- func (m *DataAugmentation) GetKeywords() []string
- func (*DataAugmentation) ProtoMessage()
- func (m *DataAugmentation) Reset()
- func (m *DataAugmentation) String() string
- func (m *DataAugmentation) XXX_DiscardUnknown()
- func (m *DataAugmentation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataAugmentation) XXX_Merge(src proto.Message)
- func (m *DataAugmentation) XXX_Size() int
- func (m *DataAugmentation) XXX_Unmarshal(b []byte) error
- type DataAvailableRequest
- func (*DataAvailableRequest) Descriptor() ([]byte, []int)
- func (m *DataAvailableRequest) GetData() []*Value
- func (m *DataAvailableRequest) GetPriority() float64
- func (m *DataAvailableRequest) GetTimeBound() float64
- func (m *DataAvailableRequest) GetUserAgent() string
- func (m *DataAvailableRequest) GetVersion() string
- func (*DataAvailableRequest) ProtoMessage()
- func (m *DataAvailableRequest) Reset()
- func (m *DataAvailableRequest) String() string
- func (m *DataAvailableRequest) XXX_DiscardUnknown()
- func (m *DataAvailableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataAvailableRequest) XXX_Merge(src proto.Message)
- func (m *DataAvailableRequest) XXX_Size() int
- func (m *DataAvailableRequest) XXX_Unmarshal(b []byte) error
- type DataAvailableResponse
- func (*DataAvailableResponse) Descriptor() ([]byte, []int)
- func (*DataAvailableResponse) ProtoMessage()
- func (m *DataAvailableResponse) Reset()
- func (m *DataAvailableResponse) String() string
- func (m *DataAvailableResponse) XXX_DiscardUnknown()
- func (m *DataAvailableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataAvailableResponse) XXX_Merge(src proto.Message)
- func (m *DataAvailableResponse) XXX_Size() int
- func (m *DataAvailableResponse) XXX_Unmarshal(b []byte) error
- type DataResource
- type DataSchema
- type DataSchemaProperties
- type DataVariable
- type DescribeSolutionRequest
- func (*DescribeSolutionRequest) Descriptor() ([]byte, []int)
- func (m *DescribeSolutionRequest) GetSolutionId() string
- func (*DescribeSolutionRequest) ProtoMessage()
- func (m *DescribeSolutionRequest) Reset()
- func (m *DescribeSolutionRequest) String() string
- func (m *DescribeSolutionRequest) XXX_DiscardUnknown()
- func (m *DescribeSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DescribeSolutionRequest) XXX_Merge(src proto.Message)
- func (m *DescribeSolutionRequest) XXX_Size() int
- func (m *DescribeSolutionRequest) XXX_Unmarshal(b []byte) error
- type DescribeSolutionResponse
- func (*DescribeSolutionResponse) Descriptor() ([]byte, []int)
- func (m *DescribeSolutionResponse) GetPipeline() *PipelineDescription
- func (m *DescribeSolutionResponse) GetSteps() []*StepDescription
- func (*DescribeSolutionResponse) ProtoMessage()
- func (m *DescribeSolutionResponse) Reset()
- func (m *DescribeSolutionResponse) String() string
- func (m *DescribeSolutionResponse) XXX_DiscardUnknown()
- func (m *DescribeSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DescribeSolutionResponse) XXX_Merge(src proto.Message)
- func (m *DescribeSolutionResponse) XXX_Size() int
- func (m *DescribeSolutionResponse) XXX_Unmarshal(b []byte) error
- type EndSearchSolutionsRequest
- func (*EndSearchSolutionsRequest) Descriptor() ([]byte, []int)
- func (m *EndSearchSolutionsRequest) GetSearchId() string
- func (*EndSearchSolutionsRequest) ProtoMessage()
- func (m *EndSearchSolutionsRequest) Reset()
- func (m *EndSearchSolutionsRequest) String() string
- func (m *EndSearchSolutionsRequest) XXX_DiscardUnknown()
- func (m *EndSearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EndSearchSolutionsRequest) XXX_Merge(src proto.Message)
- func (m *EndSearchSolutionsRequest) XXX_Size() int
- func (m *EndSearchSolutionsRequest) XXX_Unmarshal(b []byte) error
- type EndSearchSolutionsResponse
- func (*EndSearchSolutionsResponse) Descriptor() ([]byte, []int)
- func (*EndSearchSolutionsResponse) ProtoMessage()
- func (m *EndSearchSolutionsResponse) Reset()
- func (m *EndSearchSolutionsResponse) String() string
- func (m *EndSearchSolutionsResponse) XXX_DiscardUnknown()
- func (m *EndSearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EndSearchSolutionsResponse) XXX_Merge(src proto.Message)
- func (m *EndSearchSolutionsResponse) XXX_Size() int
- func (m *EndSearchSolutionsResponse) XXX_Unmarshal(b []byte) error
- type EvaluationMethod
- type FitSolutionRequest
- func (*FitSolutionRequest) Descriptor() ([]byte, []int)
- func (m *FitSolutionRequest) GetExposeOutputs() []string
- func (m *FitSolutionRequest) GetExposeValueTypes() []ValueType
- func (m *FitSolutionRequest) GetInputs() []*Value
- func (m *FitSolutionRequest) GetSolutionId() string
- func (m *FitSolutionRequest) GetUsers() []*SolutionRunUser
- func (*FitSolutionRequest) ProtoMessage()
- func (m *FitSolutionRequest) Reset()
- func (m *FitSolutionRequest) String() string
- func (m *FitSolutionRequest) XXX_DiscardUnknown()
- func (m *FitSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FitSolutionRequest) XXX_Merge(src proto.Message)
- func (m *FitSolutionRequest) XXX_Size() int
- func (m *FitSolutionRequest) XXX_Unmarshal(b []byte) error
- type FitSolutionResponse
- func (*FitSolutionResponse) Descriptor() ([]byte, []int)
- func (m *FitSolutionResponse) GetRequestId() string
- func (*FitSolutionResponse) ProtoMessage()
- func (m *FitSolutionResponse) Reset()
- func (m *FitSolutionResponse) String() string
- func (m *FitSolutionResponse) XXX_DiscardUnknown()
- func (m *FitSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FitSolutionResponse) XXX_Merge(src proto.Message)
- func (m *FitSolutionResponse) XXX_Size() int
- func (m *FitSolutionResponse) XXX_Unmarshal(b []byte) error
- type GetFitSolutionResultsRequest
- func (*GetFitSolutionResultsRequest) Descriptor() ([]byte, []int)
- func (m *GetFitSolutionResultsRequest) GetRequestId() string
- func (*GetFitSolutionResultsRequest) ProtoMessage()
- func (m *GetFitSolutionResultsRequest) Reset()
- func (m *GetFitSolutionResultsRequest) String() string
- func (m *GetFitSolutionResultsRequest) XXX_DiscardUnknown()
- func (m *GetFitSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetFitSolutionResultsRequest) XXX_Merge(src proto.Message)
- func (m *GetFitSolutionResultsRequest) XXX_Size() int
- func (m *GetFitSolutionResultsRequest) XXX_Unmarshal(b []byte) error
- type GetFitSolutionResultsResponse
- func (*GetFitSolutionResultsResponse) Descriptor() ([]byte, []int)
- func (m *GetFitSolutionResultsResponse) GetExposedOutputs() map[string]*Value
- func (m *GetFitSolutionResultsResponse) GetFittedSolutionId() string
- func (m *GetFitSolutionResultsResponse) GetProgress() *Progress
- func (m *GetFitSolutionResultsResponse) GetSteps() []*StepProgress
- func (*GetFitSolutionResultsResponse) ProtoMessage()
- func (m *GetFitSolutionResultsResponse) Reset()
- func (m *GetFitSolutionResultsResponse) String() string
- func (m *GetFitSolutionResultsResponse) XXX_DiscardUnknown()
- func (m *GetFitSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetFitSolutionResultsResponse) XXX_Merge(src proto.Message)
- func (m *GetFitSolutionResultsResponse) XXX_Size() int
- func (m *GetFitSolutionResultsResponse) XXX_Unmarshal(b []byte) error
- type GetProduceSolutionResultsRequest
- func (*GetProduceSolutionResultsRequest) Descriptor() ([]byte, []int)
- func (m *GetProduceSolutionResultsRequest) GetRequestId() string
- func (*GetProduceSolutionResultsRequest) ProtoMessage()
- func (m *GetProduceSolutionResultsRequest) Reset()
- func (m *GetProduceSolutionResultsRequest) String() string
- func (m *GetProduceSolutionResultsRequest) XXX_DiscardUnknown()
- func (m *GetProduceSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetProduceSolutionResultsRequest) XXX_Merge(src proto.Message)
- func (m *GetProduceSolutionResultsRequest) XXX_Size() int
- func (m *GetProduceSolutionResultsRequest) XXX_Unmarshal(b []byte) error
- type GetProduceSolutionResultsResponse
- func (*GetProduceSolutionResultsResponse) Descriptor() ([]byte, []int)
- func (m *GetProduceSolutionResultsResponse) GetExposedOutputs() map[string]*Value
- func (m *GetProduceSolutionResultsResponse) GetProgress() *Progress
- func (m *GetProduceSolutionResultsResponse) GetSteps() []*StepProgress
- func (*GetProduceSolutionResultsResponse) ProtoMessage()
- func (m *GetProduceSolutionResultsResponse) Reset()
- func (m *GetProduceSolutionResultsResponse) String() string
- func (m *GetProduceSolutionResultsResponse) XXX_DiscardUnknown()
- func (m *GetProduceSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetProduceSolutionResultsResponse) XXX_Merge(src proto.Message)
- func (m *GetProduceSolutionResultsResponse) XXX_Size() int
- func (m *GetProduceSolutionResultsResponse) XXX_Unmarshal(b []byte) error
- type GetScoreSolutionResultsRequest
- func (*GetScoreSolutionResultsRequest) Descriptor() ([]byte, []int)
- func (m *GetScoreSolutionResultsRequest) GetRequestId() string
- func (*GetScoreSolutionResultsRequest) ProtoMessage()
- func (m *GetScoreSolutionResultsRequest) Reset()
- func (m *GetScoreSolutionResultsRequest) String() string
- func (m *GetScoreSolutionResultsRequest) XXX_DiscardUnknown()
- func (m *GetScoreSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetScoreSolutionResultsRequest) XXX_Merge(src proto.Message)
- func (m *GetScoreSolutionResultsRequest) XXX_Size() int
- func (m *GetScoreSolutionResultsRequest) XXX_Unmarshal(b []byte) error
- type GetScoreSolutionResultsResponse
- func (*GetScoreSolutionResultsResponse) Descriptor() ([]byte, []int)
- func (m *GetScoreSolutionResultsResponse) GetProgress() *Progress
- func (m *GetScoreSolutionResultsResponse) GetScores() []*Score
- func (*GetScoreSolutionResultsResponse) ProtoMessage()
- func (m *GetScoreSolutionResultsResponse) Reset()
- func (m *GetScoreSolutionResultsResponse) String() string
- func (m *GetScoreSolutionResultsResponse) XXX_DiscardUnknown()
- func (m *GetScoreSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetScoreSolutionResultsResponse) XXX_Merge(src proto.Message)
- func (m *GetScoreSolutionResultsResponse) XXX_Size() int
- func (m *GetScoreSolutionResultsResponse) XXX_Unmarshal(b []byte) error
- type GetSearchSolutionsResultsRequest
- func (*GetSearchSolutionsResultsRequest) Descriptor() ([]byte, []int)
- func (m *GetSearchSolutionsResultsRequest) GetSearchId() string
- func (*GetSearchSolutionsResultsRequest) ProtoMessage()
- func (m *GetSearchSolutionsResultsRequest) Reset()
- func (m *GetSearchSolutionsResultsRequest) String() string
- func (m *GetSearchSolutionsResultsRequest) XXX_DiscardUnknown()
- func (m *GetSearchSolutionsResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetSearchSolutionsResultsRequest) XXX_Merge(src proto.Message)
- func (m *GetSearchSolutionsResultsRequest) XXX_Size() int
- func (m *GetSearchSolutionsResultsRequest) XXX_Unmarshal(b []byte) error
- type GetSearchSolutionsResultsResponse
- func (*GetSearchSolutionsResultsResponse) Descriptor() ([]byte, []int)
- func (m *GetSearchSolutionsResultsResponse) GetAllTicks() float64
- func (m *GetSearchSolutionsResultsResponse) GetDoneTicks() float64
- func (m *GetSearchSolutionsResultsResponse) GetInternalScore() float64
- func (m *GetSearchSolutionsResultsResponse) GetProgress() *Progress
- func (m *GetSearchSolutionsResultsResponse) GetScores() []*SolutionSearchScore
- func (m *GetSearchSolutionsResultsResponse) GetSolutionId() string
- func (*GetSearchSolutionsResultsResponse) ProtoMessage()
- func (m *GetSearchSolutionsResultsResponse) Reset()
- func (m *GetSearchSolutionsResultsResponse) String() string
- func (m *GetSearchSolutionsResultsResponse) XXX_DiscardUnknown()
- func (m *GetSearchSolutionsResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetSearchSolutionsResultsResponse) XXX_Merge(src proto.Message)
- func (m *GetSearchSolutionsResultsResponse) XXX_Size() int
- func (m *GetSearchSolutionsResultsResponse) XXX_Unmarshal(b []byte) error
- type HelloRequest
- func (*HelloRequest) Descriptor() ([]byte, []int)
- func (*HelloRequest) ProtoMessage()
- func (m *HelloRequest) Reset()
- func (m *HelloRequest) String() string
- func (m *HelloRequest) XXX_DiscardUnknown()
- func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HelloRequest) XXX_Merge(src proto.Message)
- func (m *HelloRequest) XXX_Size() int
- func (m *HelloRequest) XXX_Unmarshal(b []byte) error
- type HelloResponse
- func (*HelloResponse) Descriptor() ([]byte, []int)
- func (m *HelloResponse) GetAllowedValueTypes() []ValueType
- func (m *HelloResponse) GetSupportedExtensions() []string
- func (m *HelloResponse) GetUserAgent() string
- func (m *HelloResponse) GetVersion() string
- func (*HelloResponse) ProtoMessage()
- func (m *HelloResponse) Reset()
- func (m *HelloResponse) String() string
- func (m *HelloResponse) XXX_DiscardUnknown()
- func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HelloResponse) XXX_Merge(src proto.Message)
- func (m *HelloResponse) XXX_Size() int
- func (m *HelloResponse) XXX_Unmarshal(b []byte) error
- type ListPrimitivesRequest
- func (*ListPrimitivesRequest) Descriptor() ([]byte, []int)
- func (*ListPrimitivesRequest) ProtoMessage()
- func (m *ListPrimitivesRequest) Reset()
- func (m *ListPrimitivesRequest) String() string
- func (m *ListPrimitivesRequest) XXX_DiscardUnknown()
- func (m *ListPrimitivesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListPrimitivesRequest) XXX_Merge(src proto.Message)
- func (m *ListPrimitivesRequest) XXX_Size() int
- func (m *ListPrimitivesRequest) XXX_Unmarshal(b []byte) error
- type ListPrimitivesResponse
- func (*ListPrimitivesResponse) Descriptor() ([]byte, []int)
- func (m *ListPrimitivesResponse) GetPrimitives() []*Primitive
- func (*ListPrimitivesResponse) ProtoMessage()
- func (m *ListPrimitivesResponse) Reset()
- func (m *ListPrimitivesResponse) String() string
- func (m *ListPrimitivesResponse) XXX_DiscardUnknown()
- func (m *ListPrimitivesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListPrimitivesResponse) XXX_Merge(src proto.Message)
- func (m *ListPrimitivesResponse) XXX_Size() int
- func (m *ListPrimitivesResponse) XXX_Unmarshal(b []byte) error
- type LoadFittedSolutionRequest
- func (*LoadFittedSolutionRequest) Descriptor() ([]byte, []int)
- func (m *LoadFittedSolutionRequest) GetFittedSolutionUri() string
- func (*LoadFittedSolutionRequest) ProtoMessage()
- func (m *LoadFittedSolutionRequest) Reset()
- func (m *LoadFittedSolutionRequest) String() string
- func (m *LoadFittedSolutionRequest) XXX_DiscardUnknown()
- func (m *LoadFittedSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadFittedSolutionRequest) XXX_Merge(src proto.Message)
- func (m *LoadFittedSolutionRequest) XXX_Size() int
- func (m *LoadFittedSolutionRequest) XXX_Unmarshal(b []byte) error
- type LoadFittedSolutionResponse
- func (*LoadFittedSolutionResponse) Descriptor() ([]byte, []int)
- func (m *LoadFittedSolutionResponse) GetFittedSolutionId() string
- func (*LoadFittedSolutionResponse) ProtoMessage()
- func (m *LoadFittedSolutionResponse) Reset()
- func (m *LoadFittedSolutionResponse) String() string
- func (m *LoadFittedSolutionResponse) XXX_DiscardUnknown()
- func (m *LoadFittedSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadFittedSolutionResponse) XXX_Merge(src proto.Message)
- func (m *LoadFittedSolutionResponse) XXX_Size() int
- func (m *LoadFittedSolutionResponse) XXX_Unmarshal(b []byte) error
- type LoadSolutionRequest
- func (*LoadSolutionRequest) Descriptor() ([]byte, []int)
- func (m *LoadSolutionRequest) GetSolutionUri() string
- func (*LoadSolutionRequest) ProtoMessage()
- func (m *LoadSolutionRequest) Reset()
- func (m *LoadSolutionRequest) String() string
- func (m *LoadSolutionRequest) XXX_DiscardUnknown()
- func (m *LoadSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadSolutionRequest) XXX_Merge(src proto.Message)
- func (m *LoadSolutionRequest) XXX_Size() int
- func (m *LoadSolutionRequest) XXX_Unmarshal(b []byte) error
- type LoadSolutionResponse
- func (*LoadSolutionResponse) Descriptor() ([]byte, []int)
- func (m *LoadSolutionResponse) GetSolutionId() string
- func (*LoadSolutionResponse) ProtoMessage()
- func (m *LoadSolutionResponse) Reset()
- func (m *LoadSolutionResponse) String() string
- func (m *LoadSolutionResponse) XXX_DiscardUnknown()
- func (m *LoadSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadSolutionResponse) XXX_Merge(src proto.Message)
- func (m *LoadSolutionResponse) XXX_Size() int
- func (m *LoadSolutionResponse) XXX_Unmarshal(b []byte) error
- type NullValue
- type PerformanceMetric
- type PipelineContext
- type PipelineDescription
- func (*PipelineDescription) Descriptor() ([]byte, []int)
- func (m *PipelineDescription) GetContext() PipelineContextdeprecated
- func (m *PipelineDescription) GetCreated() *timestamp.Timestamp
- func (m *PipelineDescription) GetDescription() string
- func (m *PipelineDescription) GetDigest() string
- func (m *PipelineDescription) GetId() string
- func (m *PipelineDescription) GetInputs() []*PipelineDescriptionInput
- func (m *PipelineDescription) GetName() string
- func (m *PipelineDescription) GetOutputs() []*PipelineDescriptionOutput
- func (m *PipelineDescription) GetSource() *PipelineSource
- func (m *PipelineDescription) GetSteps() []*PipelineDescriptionStep
- func (m *PipelineDescription) GetUsers() []*PipelineDescriptionUser
- func (*PipelineDescription) ProtoMessage()
- func (m *PipelineDescription) Reset()
- func (m *PipelineDescription) String() string
- func (m *PipelineDescription) XXX_DiscardUnknown()
- func (m *PipelineDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineDescription) XXX_Merge(src proto.Message)
- func (m *PipelineDescription) XXX_Size() int
- func (m *PipelineDescription) XXX_Unmarshal(b []byte) error
- type PipelineDescriptionInput
- func (*PipelineDescriptionInput) Descriptor() ([]byte, []int)
- func (m *PipelineDescriptionInput) GetName() string
- func (*PipelineDescriptionInput) ProtoMessage()
- func (m *PipelineDescriptionInput) Reset()
- func (m *PipelineDescriptionInput) String() string
- func (m *PipelineDescriptionInput) XXX_DiscardUnknown()
- func (m *PipelineDescriptionInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineDescriptionInput) XXX_Merge(src proto.Message)
- func (m *PipelineDescriptionInput) XXX_Size() int
- func (m *PipelineDescriptionInput) XXX_Unmarshal(b []byte) error
- type PipelineDescriptionOutput
- func (*PipelineDescriptionOutput) Descriptor() ([]byte, []int)
- func (m *PipelineDescriptionOutput) GetData() string
- func (m *PipelineDescriptionOutput) GetName() string
- func (*PipelineDescriptionOutput) ProtoMessage()
- func (m *PipelineDescriptionOutput) Reset()
- func (m *PipelineDescriptionOutput) String() string
- func (m *PipelineDescriptionOutput) XXX_DiscardUnknown()
- func (m *PipelineDescriptionOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineDescriptionOutput) XXX_Merge(src proto.Message)
- func (m *PipelineDescriptionOutput) XXX_Size() int
- func (m *PipelineDescriptionOutput) XXX_Unmarshal(b []byte) error
- type PipelineDescriptionStep
- func (*PipelineDescriptionStep) Descriptor() ([]byte, []int)
- func (m *PipelineDescriptionStep) GetPipeline() *SubpipelinePipelineDescriptionStep
- func (m *PipelineDescriptionStep) GetPlaceholder() *PlaceholderPipelineDescriptionStep
- func (m *PipelineDescriptionStep) GetPrimitive() *PrimitivePipelineDescriptionStep
- func (m *PipelineDescriptionStep) GetStep() isPipelineDescriptionStep_Step
- func (*PipelineDescriptionStep) ProtoMessage()
- func (m *PipelineDescriptionStep) Reset()
- func (m *PipelineDescriptionStep) String() string
- func (m *PipelineDescriptionStep) XXX_DiscardUnknown()
- func (m *PipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineDescriptionStep) XXX_Merge(src proto.Message)
- func (*PipelineDescriptionStep) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *PipelineDescriptionStep) XXX_Size() int
- func (m *PipelineDescriptionStep) XXX_Unmarshal(b []byte) error
- type PipelineDescriptionStep_Pipeline
- type PipelineDescriptionStep_Placeholder
- type PipelineDescriptionStep_Primitive
- type PipelineDescriptionUser
- func (*PipelineDescriptionUser) Descriptor() ([]byte, []int)
- func (m *PipelineDescriptionUser) GetId() string
- func (m *PipelineDescriptionUser) GetRationale() string
- func (m *PipelineDescriptionUser) GetReason() string
- func (*PipelineDescriptionUser) ProtoMessage()
- func (m *PipelineDescriptionUser) Reset()
- func (m *PipelineDescriptionUser) String() string
- func (m *PipelineDescriptionUser) XXX_DiscardUnknown()
- func (m *PipelineDescriptionUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineDescriptionUser) XXX_Merge(src proto.Message)
- func (m *PipelineDescriptionUser) XXX_Size() int
- func (m *PipelineDescriptionUser) XXX_Unmarshal(b []byte) error
- type PipelineSource
- func (*PipelineSource) Descriptor() ([]byte, []int)
- func (m *PipelineSource) GetContact() string
- func (m *PipelineSource) GetName() string
- func (m *PipelineSource) GetPipelines() []*PipelineDescription
- func (*PipelineSource) ProtoMessage()
- func (m *PipelineSource) Reset()
- func (m *PipelineSource) String() string
- func (m *PipelineSource) XXX_DiscardUnknown()
- func (m *PipelineSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PipelineSource) XXX_Merge(src proto.Message)
- func (m *PipelineSource) XXX_Size() int
- func (m *PipelineSource) XXX_Unmarshal(b []byte) error
- type PlaceholderPipelineDescriptionStep
- func (*PlaceholderPipelineDescriptionStep) Descriptor() ([]byte, []int)
- func (m *PlaceholderPipelineDescriptionStep) GetInputs() []*StepInput
- func (m *PlaceholderPipelineDescriptionStep) GetOutputs() []*StepOutput
- func (*PlaceholderPipelineDescriptionStep) ProtoMessage()
- func (m *PlaceholderPipelineDescriptionStep) Reset()
- func (m *PlaceholderPipelineDescriptionStep) String() string
- func (m *PlaceholderPipelineDescriptionStep) XXX_DiscardUnknown()
- func (m *PlaceholderPipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PlaceholderPipelineDescriptionStep) XXX_Merge(src proto.Message)
- func (m *PlaceholderPipelineDescriptionStep) XXX_Size() int
- func (m *PlaceholderPipelineDescriptionStep) XXX_Unmarshal(b []byte) error
- type Primitive
- func (*Primitive) Descriptor() ([]byte, []int)
- func (m *Primitive) GetDigest() string
- func (m *Primitive) GetId() string
- func (m *Primitive) GetName() string
- func (m *Primitive) GetPythonPath() string
- func (m *Primitive) GetVersion() string
- func (*Primitive) ProtoMessage()
- func (m *Primitive) Reset()
- func (m *Primitive) String() string
- func (m *Primitive) XXX_DiscardUnknown()
- func (m *Primitive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Primitive) XXX_Merge(src proto.Message)
- func (m *Primitive) XXX_Size() int
- func (m *Primitive) XXX_Unmarshal(b []byte) error
- type PrimitiveArgument
- func (*PrimitiveArgument) Descriptor() ([]byte, []int)
- func (m *PrimitiveArgument) GetData() int32
- func (*PrimitiveArgument) ProtoMessage()
- func (m *PrimitiveArgument) Reset()
- func (m *PrimitiveArgument) String() string
- func (m *PrimitiveArgument) XXX_DiscardUnknown()
- func (m *PrimitiveArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveArgument) XXX_Merge(src proto.Message)
- func (m *PrimitiveArgument) XXX_Size() int
- func (m *PrimitiveArgument) XXX_Unmarshal(b []byte) error
- type PrimitiveArguments
- func (*PrimitiveArguments) Descriptor() ([]byte, []int)
- func (m *PrimitiveArguments) GetData() []int32
- func (*PrimitiveArguments) ProtoMessage()
- func (m *PrimitiveArguments) Reset()
- func (m *PrimitiveArguments) String() string
- func (m *PrimitiveArguments) XXX_DiscardUnknown()
- func (m *PrimitiveArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveArguments) XXX_Merge(src proto.Message)
- func (m *PrimitiveArguments) XXX_Size() int
- func (m *PrimitiveArguments) XXX_Unmarshal(b []byte) error
- type PrimitivePipelineDescriptionStep
- func (*PrimitivePipelineDescriptionStep) Descriptor() ([]byte, []int)
- func (m *PrimitivePipelineDescriptionStep) GetArguments() map[string]*PrimitiveStepArgument
- func (m *PrimitivePipelineDescriptionStep) GetHyperparams() map[string]*PrimitiveStepHyperparameter
- func (m *PrimitivePipelineDescriptionStep) GetOutputs() []*StepOutput
- func (m *PrimitivePipelineDescriptionStep) GetPrimitive() *Primitive
- func (m *PrimitivePipelineDescriptionStep) GetUsers() []*PipelineDescriptionUser
- func (*PrimitivePipelineDescriptionStep) ProtoMessage()
- func (m *PrimitivePipelineDescriptionStep) Reset()
- func (m *PrimitivePipelineDescriptionStep) String() string
- func (m *PrimitivePipelineDescriptionStep) XXX_DiscardUnknown()
- func (m *PrimitivePipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitivePipelineDescriptionStep) XXX_Merge(src proto.Message)
- func (m *PrimitivePipelineDescriptionStep) XXX_Size() int
- func (m *PrimitivePipelineDescriptionStep) XXX_Unmarshal(b []byte) error
- type PrimitiveStepArgument
- func (*PrimitiveStepArgument) Descriptor() ([]byte, []int)
- func (m *PrimitiveStepArgument) GetArgument() isPrimitiveStepArgument_Argument
- func (m *PrimitiveStepArgument) GetContainer() *ContainerArgument
- func (m *PrimitiveStepArgument) GetContainerList() *ContainerArguments
- func (m *PrimitiveStepArgument) GetData() *DataArgument
- func (*PrimitiveStepArgument) ProtoMessage()
- func (m *PrimitiveStepArgument) Reset()
- func (m *PrimitiveStepArgument) String() string
- func (m *PrimitiveStepArgument) XXX_DiscardUnknown()
- func (m *PrimitiveStepArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveStepArgument) XXX_Merge(src proto.Message)
- func (*PrimitiveStepArgument) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *PrimitiveStepArgument) XXX_Size() int
- func (m *PrimitiveStepArgument) XXX_Unmarshal(b []byte) error
- type PrimitiveStepArgument_Container
- type PrimitiveStepArgument_ContainerList
- type PrimitiveStepArgument_Data
- type PrimitiveStepDescription
- func (*PrimitiveStepDescription) Descriptor() ([]byte, []int)
- func (m *PrimitiveStepDescription) GetHyperparams() map[string]*Value
- func (*PrimitiveStepDescription) ProtoMessage()
- func (m *PrimitiveStepDescription) Reset()
- func (m *PrimitiveStepDescription) String() string
- func (m *PrimitiveStepDescription) XXX_DiscardUnknown()
- func (m *PrimitiveStepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveStepDescription) XXX_Merge(src proto.Message)
- func (m *PrimitiveStepDescription) XXX_Size() int
- func (m *PrimitiveStepDescription) XXX_Unmarshal(b []byte) error
- type PrimitiveStepHyperparameter
- func (*PrimitiveStepHyperparameter) Descriptor() ([]byte, []int)
- func (m *PrimitiveStepHyperparameter) GetArgument() isPrimitiveStepHyperparameter_Argument
- func (m *PrimitiveStepHyperparameter) GetContainer() *ContainerArgument
- func (m *PrimitiveStepHyperparameter) GetData() *DataArgument
- func (m *PrimitiveStepHyperparameter) GetDataSet() *DataArguments
- func (m *PrimitiveStepHyperparameter) GetPrimitive() *PrimitiveArgument
- func (m *PrimitiveStepHyperparameter) GetPrimitivesSet() *PrimitiveArguments
- func (m *PrimitiveStepHyperparameter) GetValue() *ValueArgument
- func (*PrimitiveStepHyperparameter) ProtoMessage()
- func (m *PrimitiveStepHyperparameter) Reset()
- func (m *PrimitiveStepHyperparameter) String() string
- func (m *PrimitiveStepHyperparameter) XXX_DiscardUnknown()
- func (m *PrimitiveStepHyperparameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveStepHyperparameter) XXX_Merge(src proto.Message)
- func (*PrimitiveStepHyperparameter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *PrimitiveStepHyperparameter) XXX_Size() int
- func (m *PrimitiveStepHyperparameter) XXX_Unmarshal(b []byte) error
- type PrimitiveStepHyperparameter_Container
- type PrimitiveStepHyperparameter_Data
- type PrimitiveStepHyperparameter_DataSet
- type PrimitiveStepHyperparameter_Primitive
- type PrimitiveStepHyperparameter_PrimitivesSet
- type PrimitiveStepHyperparameter_Value
- type Problem
- func (*Problem) Descriptor() ([]byte, []int)
- func (m *Problem) GetPerformanceMetrics() []*ProblemPerformanceMetric
- func (m *Problem) GetTaskSubtype() TaskSubtype
- func (m *Problem) GetTaskType() TaskType
- func (*Problem) ProtoMessage()
- func (m *Problem) Reset()
- func (m *Problem) String() string
- func (m *Problem) XXX_DiscardUnknown()
- func (m *Problem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Problem) XXX_Merge(src proto.Message)
- func (m *Problem) XXX_Size() int
- func (m *Problem) XXX_Unmarshal(b []byte) error
- type ProblemDescription
- func (*ProblemDescription) Descriptor() ([]byte, []int)
- func (m *ProblemDescription) GetDataAugmentation() []*DataAugmentation
- func (m *ProblemDescription) GetDescription() string
- func (m *ProblemDescription) GetDigest() string
- func (m *ProblemDescription) GetId() string
- func (m *ProblemDescription) GetInputs() []*ProblemInput
- func (m *ProblemDescription) GetName() string
- func (m *ProblemDescription) GetOtherNames() []string
- func (m *ProblemDescription) GetProblem() *Problem
- func (m *ProblemDescription) GetVersion() string
- func (*ProblemDescription) ProtoMessage()
- func (m *ProblemDescription) Reset()
- func (m *ProblemDescription) String() string
- func (m *ProblemDescription) XXX_DiscardUnknown()
- func (m *ProblemDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProblemDescription) XXX_Merge(src proto.Message)
- func (m *ProblemDescription) XXX_Size() int
- func (m *ProblemDescription) XXX_Unmarshal(b []byte) error
- type ProblemInput
- func (*ProblemInput) Descriptor() ([]byte, []int)
- func (m *ProblemInput) GetDatasetId() string
- func (m *ProblemInput) GetPrivilegedData() []*ProblemPrivilegedData
- func (m *ProblemInput) GetTargets() []*ProblemTarget
- func (*ProblemInput) ProtoMessage()
- func (m *ProblemInput) Reset()
- func (m *ProblemInput) String() string
- func (m *ProblemInput) XXX_DiscardUnknown()
- func (m *ProblemInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProblemInput) XXX_Merge(src proto.Message)
- func (m *ProblemInput) XXX_Size() int
- func (m *ProblemInput) XXX_Unmarshal(b []byte) error
- type ProblemPerformanceMetric
- func (*ProblemPerformanceMetric) Descriptor() ([]byte, []int)
- func (m *ProblemPerformanceMetric) GetK() int32
- func (m *ProblemPerformanceMetric) GetMetric() PerformanceMetric
- func (m *ProblemPerformanceMetric) GetPosLabel() string
- func (*ProblemPerformanceMetric) ProtoMessage()
- func (m *ProblemPerformanceMetric) Reset()
- func (m *ProblemPerformanceMetric) String() string
- func (m *ProblemPerformanceMetric) XXX_DiscardUnknown()
- func (m *ProblemPerformanceMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProblemPerformanceMetric) XXX_Merge(src proto.Message)
- func (m *ProblemPerformanceMetric) XXX_Size() int
- func (m *ProblemPerformanceMetric) XXX_Unmarshal(b []byte) error
- type ProblemPrivilegedData
- func (*ProblemPrivilegedData) Descriptor() ([]byte, []int)
- func (m *ProblemPrivilegedData) GetColumnIndex() int32
- func (m *ProblemPrivilegedData) GetColumnName() string
- func (m *ProblemPrivilegedData) GetPrivilegedDataIndex() int32
- func (m *ProblemPrivilegedData) GetResourceId() string
- func (*ProblemPrivilegedData) ProtoMessage()
- func (m *ProblemPrivilegedData) Reset()
- func (m *ProblemPrivilegedData) String() string
- func (m *ProblemPrivilegedData) XXX_DiscardUnknown()
- func (m *ProblemPrivilegedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProblemPrivilegedData) XXX_Merge(src proto.Message)
- func (m *ProblemPrivilegedData) XXX_Size() int
- func (m *ProblemPrivilegedData) XXX_Unmarshal(b []byte) error
- type ProblemTarget
- func (*ProblemTarget) Descriptor() ([]byte, []int)
- func (m *ProblemTarget) GetClustersNumber() int32
- func (m *ProblemTarget) GetColumnIndex() int32
- func (m *ProblemTarget) GetColumnName() string
- func (m *ProblemTarget) GetResourceId() string
- func (m *ProblemTarget) GetTargetIndex() int32
- func (*ProblemTarget) ProtoMessage()
- func (m *ProblemTarget) Reset()
- func (m *ProblemTarget) String() string
- func (m *ProblemTarget) XXX_DiscardUnknown()
- func (m *ProblemTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProblemTarget) XXX_Merge(src proto.Message)
- func (m *ProblemTarget) XXX_Size() int
- func (m *ProblemTarget) XXX_Unmarshal(b []byte) error
- type ProduceSolutionRequest
- func (*ProduceSolutionRequest) Descriptor() ([]byte, []int)
- func (m *ProduceSolutionRequest) GetExposeOutputs() []string
- func (m *ProduceSolutionRequest) GetExposeValueTypes() []ValueType
- func (m *ProduceSolutionRequest) GetFittedSolutionId() string
- func (m *ProduceSolutionRequest) GetInputs() []*Value
- func (m *ProduceSolutionRequest) GetUsers() []*SolutionRunUser
- func (*ProduceSolutionRequest) ProtoMessage()
- func (m *ProduceSolutionRequest) Reset()
- func (m *ProduceSolutionRequest) String() string
- func (m *ProduceSolutionRequest) XXX_DiscardUnknown()
- func (m *ProduceSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProduceSolutionRequest) XXX_Merge(src proto.Message)
- func (m *ProduceSolutionRequest) XXX_Size() int
- func (m *ProduceSolutionRequest) XXX_Unmarshal(b []byte) error
- type ProduceSolutionResponse
- func (*ProduceSolutionResponse) Descriptor() ([]byte, []int)
- func (m *ProduceSolutionResponse) GetRequestId() string
- func (*ProduceSolutionResponse) ProtoMessage()
- func (m *ProduceSolutionResponse) Reset()
- func (m *ProduceSolutionResponse) String() string
- func (m *ProduceSolutionResponse) XXX_DiscardUnknown()
- func (m *ProduceSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProduceSolutionResponse) XXX_Merge(src proto.Message)
- func (m *ProduceSolutionResponse) XXX_Size() int
- func (m *ProduceSolutionResponse) XXX_Unmarshal(b []byte) error
- type Progress
- func (*Progress) Descriptor() ([]byte, []int)
- func (m *Progress) GetEnd() *timestamp.Timestamp
- func (m *Progress) GetStart() *timestamp.Timestamp
- func (m *Progress) GetState() ProgressState
- func (m *Progress) GetStatus() string
- func (*Progress) ProtoMessage()
- func (m *Progress) Reset()
- func (m *Progress) String() string
- func (m *Progress) XXX_DiscardUnknown()
- func (m *Progress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Progress) XXX_Merge(src proto.Message)
- func (m *Progress) XXX_Size() int
- func (m *Progress) XXX_Unmarshal(b []byte) error
- type ProgressState
- type RequestNode
- type SaveFittedSolutionRequest
- func (*SaveFittedSolutionRequest) Descriptor() ([]byte, []int)
- func (m *SaveFittedSolutionRequest) GetFittedSolutionId() string
- func (*SaveFittedSolutionRequest) ProtoMessage()
- func (m *SaveFittedSolutionRequest) Reset()
- func (m *SaveFittedSolutionRequest) String() string
- func (m *SaveFittedSolutionRequest) XXX_DiscardUnknown()
- func (m *SaveFittedSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SaveFittedSolutionRequest) XXX_Merge(src proto.Message)
- func (m *SaveFittedSolutionRequest) XXX_Size() int
- func (m *SaveFittedSolutionRequest) XXX_Unmarshal(b []byte) error
- type SaveFittedSolutionResponse
- func (*SaveFittedSolutionResponse) Descriptor() ([]byte, []int)
- func (m *SaveFittedSolutionResponse) GetFittedSolutionUri() string
- func (*SaveFittedSolutionResponse) ProtoMessage()
- func (m *SaveFittedSolutionResponse) Reset()
- func (m *SaveFittedSolutionResponse) String() string
- func (m *SaveFittedSolutionResponse) XXX_DiscardUnknown()
- func (m *SaveFittedSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SaveFittedSolutionResponse) XXX_Merge(src proto.Message)
- func (m *SaveFittedSolutionResponse) XXX_Size() int
- func (m *SaveFittedSolutionResponse) XXX_Unmarshal(b []byte) error
- type SaveSolutionRequest
- func (*SaveSolutionRequest) Descriptor() ([]byte, []int)
- func (m *SaveSolutionRequest) GetSolutionId() string
- func (*SaveSolutionRequest) ProtoMessage()
- func (m *SaveSolutionRequest) Reset()
- func (m *SaveSolutionRequest) String() string
- func (m *SaveSolutionRequest) XXX_DiscardUnknown()
- func (m *SaveSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SaveSolutionRequest) XXX_Merge(src proto.Message)
- func (m *SaveSolutionRequest) XXX_Size() int
- func (m *SaveSolutionRequest) XXX_Unmarshal(b []byte) error
- type SaveSolutionResponse
- func (*SaveSolutionResponse) Descriptor() ([]byte, []int)
- func (m *SaveSolutionResponse) GetSolutionUri() string
- func (*SaveSolutionResponse) ProtoMessage()
- func (m *SaveSolutionResponse) Reset()
- func (m *SaveSolutionResponse) String() string
- func (m *SaveSolutionResponse) XXX_DiscardUnknown()
- func (m *SaveSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SaveSolutionResponse) XXX_Merge(src proto.Message)
- func (m *SaveSolutionResponse) XXX_Size() int
- func (m *SaveSolutionResponse) XXX_Unmarshal(b []byte) error
- type Score
- func (*Score) Descriptor() ([]byte, []int)
- func (m *Score) GetFold() int32
- func (m *Score) GetMetric() *ProblemPerformanceMetric
- func (m *Score) GetNormalized() *Value
- func (m *Score) GetRandomSeed() int32
- func (m *Score) GetValue() *Value
- func (*Score) ProtoMessage()
- func (m *Score) Reset()
- func (m *Score) String() string
- func (m *Score) XXX_DiscardUnknown()
- func (m *Score) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Score) XXX_Merge(src proto.Message)
- func (m *Score) XXX_Size() int
- func (m *Score) XXX_Unmarshal(b []byte) error
- type ScoreSolutionRequest
- func (*ScoreSolutionRequest) Descriptor() ([]byte, []int)
- func (m *ScoreSolutionRequest) GetConfiguration() *ScoringConfiguration
- func (m *ScoreSolutionRequest) GetInputs() []*Value
- func (m *ScoreSolutionRequest) GetPerformanceMetrics() []*ProblemPerformanceMetric
- func (m *ScoreSolutionRequest) GetSolutionId() string
- func (m *ScoreSolutionRequest) GetUsers() []*SolutionRunUser
- func (*ScoreSolutionRequest) ProtoMessage()
- func (m *ScoreSolutionRequest) Reset()
- func (m *ScoreSolutionRequest) String() string
- func (m *ScoreSolutionRequest) XXX_DiscardUnknown()
- func (m *ScoreSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScoreSolutionRequest) XXX_Merge(src proto.Message)
- func (m *ScoreSolutionRequest) XXX_Size() int
- func (m *ScoreSolutionRequest) XXX_Unmarshal(b []byte) error
- type ScoreSolutionResponse
- func (*ScoreSolutionResponse) Descriptor() ([]byte, []int)
- func (m *ScoreSolutionResponse) GetRequestId() string
- func (*ScoreSolutionResponse) ProtoMessage()
- func (m *ScoreSolutionResponse) Reset()
- func (m *ScoreSolutionResponse) String() string
- func (m *ScoreSolutionResponse) XXX_DiscardUnknown()
- func (m *ScoreSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScoreSolutionResponse) XXX_Merge(src proto.Message)
- func (m *ScoreSolutionResponse) XXX_Size() int
- func (m *ScoreSolutionResponse) XXX_Unmarshal(b []byte) error
- type ScoringConfiguration
- func (*ScoringConfiguration) Descriptor() ([]byte, []int)
- func (m *ScoringConfiguration) GetFolds() int32
- func (m *ScoringConfiguration) GetMethod() EvaluationMethod
- func (m *ScoringConfiguration) GetRandomSeed() int32
- func (m *ScoringConfiguration) GetShuffle() bool
- func (m *ScoringConfiguration) GetStratified() bool
- func (m *ScoringConfiguration) GetTrainTestRatio() float64
- func (*ScoringConfiguration) ProtoMessage()
- func (m *ScoringConfiguration) Reset()
- func (m *ScoringConfiguration) String() string
- func (m *ScoringConfiguration) XXX_DiscardUnknown()
- func (m *ScoringConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScoringConfiguration) XXX_Merge(src proto.Message)
- func (m *ScoringConfiguration) XXX_Size() int
- func (m *ScoringConfiguration) XXX_Unmarshal(b []byte) error
- type SearchSolutionsRequest
- func (*SearchSolutionsRequest) Descriptor() ([]byte, []int)
- func (m *SearchSolutionsRequest) GetAllowedValueTypes() []ValueType
- func (m *SearchSolutionsRequest) GetInputs() []*Value
- func (m *SearchSolutionsRequest) GetPriority() float64
- func (m *SearchSolutionsRequest) GetProblem() *ProblemDescription
- func (m *SearchSolutionsRequest) GetRankSolutionsLimit() int32
- func (m *SearchSolutionsRequest) GetTemplate() *PipelineDescription
- func (m *SearchSolutionsRequest) GetTimeBoundRun() float64
- func (m *SearchSolutionsRequest) GetTimeBoundSearch() float64
- func (m *SearchSolutionsRequest) GetUserAgent() string
- func (m *SearchSolutionsRequest) GetVersion() string
- func (*SearchSolutionsRequest) ProtoMessage()
- func (m *SearchSolutionsRequest) Reset()
- func (m *SearchSolutionsRequest) String() string
- func (m *SearchSolutionsRequest) XXX_DiscardUnknown()
- func (m *SearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchSolutionsRequest) XXX_Merge(src proto.Message)
- func (m *SearchSolutionsRequest) XXX_Size() int
- func (m *SearchSolutionsRequest) XXX_Unmarshal(b []byte) error
- type SearchSolutionsResponse
- func (*SearchSolutionsResponse) Descriptor() ([]byte, []int)
- func (m *SearchSolutionsResponse) GetSearchId() string
- func (*SearchSolutionsResponse) ProtoMessage()
- func (m *SearchSolutionsResponse) Reset()
- func (m *SearchSolutionsResponse) String() string
- func (m *SearchSolutionsResponse) XXX_DiscardUnknown()
- func (m *SearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchSolutionsResponse) XXX_Merge(src proto.Message)
- func (m *SearchSolutionsResponse) XXX_Size() int
- func (m *SearchSolutionsResponse) XXX_Unmarshal(b []byte) error
- type Server
- func (s *Server) DataAvailable(ctx context.Context, in *DataAvailableRequest) (*DataAvailableResponse, error)
- func (s *Server) DescribeSolution(ctx context.Context, req *DescribeSolutionRequest) (*DescribeSolutionResponse, error)
- func (s *Server) EndSearchSolutions(ctx context.Context, req *EndSearchSolutionsRequest) (*EndSearchSolutionsResponse, error)
- func (s *Server) FitSolution(ctx context.Context, req *FitSolutionRequest) (*FitSolutionResponse, error)
- func (s *Server) GetFitSolutionResults(req *GetFitSolutionResultsRequest, stream Core_GetFitSolutionResultsServer) error
- func (s *Server) GetProduceSolutionResults(req *GetProduceSolutionResultsRequest, ...) error
- func (s *Server) GetScoreSolutionResults(req *GetScoreSolutionResultsRequest, stream Core_GetScoreSolutionResultsServer) error
- func (s *Server) GetSearchSolutionsResults(req *GetSearchSolutionsResultsRequest, ...) error
- func (s *Server) Hello(ctx context.Context, req *HelloRequest) (*HelloResponse, error)
- func (s *Server) ListPrimitives(ctx context.Context, req *ListPrimitivesRequest) (*ListPrimitivesResponse, error)
- func (s *Server) LoadFittedSolution(ctx context.Context, in *LoadFittedSolutionRequest) (*LoadFittedSolutionResponse, error)
- func (s *Server) LoadSolution(ctx context.Context, in *LoadSolutionRequest) (*LoadSolutionResponse, error)
- func (s *Server) ProduceSolution(ctx context.Context, req *ProduceSolutionRequest) (*ProduceSolutionResponse, error)
- func (s *Server) SaveFittedSolution(ctx context.Context, in *SaveFittedSolutionRequest) (*SaveFittedSolutionResponse, error)
- func (s *Server) SaveSolution(ctx context.Context, in *SaveSolutionRequest) (*SaveSolutionResponse, error)
- func (s *Server) ScoreSolution(ctx context.Context, req *ScoreSolutionRequest) (*ScoreSolutionResponse, error)
- func (s *Server) SearchSolutions(ctx context.Context, req *SearchSolutionsRequest) (*SearchSolutionsResponse, error)
- func (s *Server) SolutionExport(ctx context.Context, req *SolutionExportRequest) (*SolutionExportResponse, error)
- func (s *Server) StopSearchSolutions(ctx context.Context, req *StopSearchSolutionsRequest) (*StopSearchSolutionsResponse, error)
- func (s *Server) UpdateProblem(ctx context.Context, req *UpdateProblemRequest) (*UpdateProblemResponse, error)
- type ServerRequests
- func (s *ServerRequests) AddRequest(parentID string, requestMsg interface{}) (RequestNode, error)
- func (s *ServerRequests) GetRequest(requestID string) (RequestNode, error)
- func (s *ServerRequests) IsComplete(requestID string) bool
- func (s *ServerRequests) RemoveRequest(requestID string) error
- func (s *ServerRequests) SetComplete(requestID string)
- type SolutionExportRequest
- func (*SolutionExportRequest) Descriptor() ([]byte, []int)
- func (m *SolutionExportRequest) GetRank() float64
- func (m *SolutionExportRequest) GetSolutionId() string
- func (*SolutionExportRequest) ProtoMessage()
- func (m *SolutionExportRequest) Reset()
- func (m *SolutionExportRequest) String() string
- func (m *SolutionExportRequest) XXX_DiscardUnknown()
- func (m *SolutionExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SolutionExportRequest) XXX_Merge(src proto.Message)
- func (m *SolutionExportRequest) XXX_Size() int
- func (m *SolutionExportRequest) XXX_Unmarshal(b []byte) error
- type SolutionExportResponse
- func (*SolutionExportResponse) Descriptor() ([]byte, []int)
- func (*SolutionExportResponse) ProtoMessage()
- func (m *SolutionExportResponse) Reset()
- func (m *SolutionExportResponse) String() string
- func (m *SolutionExportResponse) XXX_DiscardUnknown()
- func (m *SolutionExportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SolutionExportResponse) XXX_Merge(src proto.Message)
- func (m *SolutionExportResponse) XXX_Size() int
- func (m *SolutionExportResponse) XXX_Unmarshal(b []byte) error
- type SolutionRunUser
- func (*SolutionRunUser) Descriptor() ([]byte, []int)
- func (m *SolutionRunUser) GetChosen() bool
- func (m *SolutionRunUser) GetId() string
- func (m *SolutionRunUser) GetReason() string
- func (*SolutionRunUser) ProtoMessage()
- func (m *SolutionRunUser) Reset()
- func (m *SolutionRunUser) String() string
- func (m *SolutionRunUser) XXX_DiscardUnknown()
- func (m *SolutionRunUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SolutionRunUser) XXX_Merge(src proto.Message)
- func (m *SolutionRunUser) XXX_Size() int
- func (m *SolutionRunUser) XXX_Unmarshal(b []byte) error
- type SolutionSearchScore
- func (*SolutionSearchScore) Descriptor() ([]byte, []int)
- func (m *SolutionSearchScore) GetScores() []*Score
- func (m *SolutionSearchScore) GetScoringConfiguration() *ScoringConfiguration
- func (*SolutionSearchScore) ProtoMessage()
- func (m *SolutionSearchScore) Reset()
- func (m *SolutionSearchScore) String() string
- func (m *SolutionSearchScore) XXX_DiscardUnknown()
- func (m *SolutionSearchScore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SolutionSearchScore) XXX_Merge(src proto.Message)
- func (m *SolutionSearchScore) XXX_Size() int
- func (m *SolutionSearchScore) XXX_Unmarshal(b []byte) error
- type StepDescription
- func (*StepDescription) Descriptor() ([]byte, []int)
- func (m *StepDescription) GetPipeline() *SubpipelineStepDescription
- func (m *StepDescription) GetPrimitive() *PrimitiveStepDescription
- func (m *StepDescription) GetStep() isStepDescription_Step
- func (*StepDescription) ProtoMessage()
- func (m *StepDescription) Reset()
- func (m *StepDescription) String() string
- func (m *StepDescription) XXX_DiscardUnknown()
- func (m *StepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepDescription) XXX_Merge(src proto.Message)
- func (*StepDescription) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *StepDescription) XXX_Size() int
- func (m *StepDescription) XXX_Unmarshal(b []byte) error
- type StepDescription_Pipeline
- type StepDescription_Primitive
- type StepInput
- func (*StepInput) Descriptor() ([]byte, []int)
- func (m *StepInput) GetData() string
- func (*StepInput) ProtoMessage()
- func (m *StepInput) Reset()
- func (m *StepInput) String() string
- func (m *StepInput) XXX_DiscardUnknown()
- func (m *StepInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepInput) XXX_Merge(src proto.Message)
- func (m *StepInput) XXX_Size() int
- func (m *StepInput) XXX_Unmarshal(b []byte) error
- type StepOutput
- func (*StepOutput) Descriptor() ([]byte, []int)
- func (m *StepOutput) GetId() string
- func (*StepOutput) ProtoMessage()
- func (m *StepOutput) Reset()
- func (m *StepOutput) String() string
- func (m *StepOutput) XXX_DiscardUnknown()
- func (m *StepOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepOutput) XXX_Merge(src proto.Message)
- func (m *StepOutput) XXX_Size() int
- func (m *StepOutput) XXX_Unmarshal(b []byte) error
- type StepProgress
- func (*StepProgress) Descriptor() ([]byte, []int)
- func (m *StepProgress) GetProgress() *Progress
- func (m *StepProgress) GetSteps() []*StepProgress
- func (*StepProgress) ProtoMessage()
- func (m *StepProgress) Reset()
- func (m *StepProgress) String() string
- func (m *StepProgress) XXX_DiscardUnknown()
- func (m *StepProgress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepProgress) XXX_Merge(src proto.Message)
- func (m *StepProgress) XXX_Size() int
- func (m *StepProgress) XXX_Unmarshal(b []byte) error
- type StopSearchSolutionsRequest
- func (*StopSearchSolutionsRequest) Descriptor() ([]byte, []int)
- func (m *StopSearchSolutionsRequest) GetSearchId() string
- func (*StopSearchSolutionsRequest) ProtoMessage()
- func (m *StopSearchSolutionsRequest) Reset()
- func (m *StopSearchSolutionsRequest) String() string
- func (m *StopSearchSolutionsRequest) XXX_DiscardUnknown()
- func (m *StopSearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopSearchSolutionsRequest) XXX_Merge(src proto.Message)
- func (m *StopSearchSolutionsRequest) XXX_Size() int
- func (m *StopSearchSolutionsRequest) XXX_Unmarshal(b []byte) error
- type StopSearchSolutionsResponse
- func (*StopSearchSolutionsResponse) Descriptor() ([]byte, []int)
- func (*StopSearchSolutionsResponse) ProtoMessage()
- func (m *StopSearchSolutionsResponse) Reset()
- func (m *StopSearchSolutionsResponse) String() string
- func (m *StopSearchSolutionsResponse) XXX_DiscardUnknown()
- func (m *StopSearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopSearchSolutionsResponse) XXX_Merge(src proto.Message)
- func (m *StopSearchSolutionsResponse) XXX_Size() int
- func (m *StopSearchSolutionsResponse) XXX_Unmarshal(b []byte) error
- type SubpipelinePipelineDescriptionStep
- func (*SubpipelinePipelineDescriptionStep) Descriptor() ([]byte, []int)
- func (m *SubpipelinePipelineDescriptionStep) GetInputs() []*StepInput
- func (m *SubpipelinePipelineDescriptionStep) GetOutputs() []*StepOutput
- func (m *SubpipelinePipelineDescriptionStep) GetPipeline() *PipelineDescription
- func (*SubpipelinePipelineDescriptionStep) ProtoMessage()
- func (m *SubpipelinePipelineDescriptionStep) Reset()
- func (m *SubpipelinePipelineDescriptionStep) String() string
- func (m *SubpipelinePipelineDescriptionStep) XXX_DiscardUnknown()
- func (m *SubpipelinePipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubpipelinePipelineDescriptionStep) XXX_Merge(src proto.Message)
- func (m *SubpipelinePipelineDescriptionStep) XXX_Size() int
- func (m *SubpipelinePipelineDescriptionStep) XXX_Unmarshal(b []byte) error
- type SubpipelineStepDescription
- func (*SubpipelineStepDescription) Descriptor() ([]byte, []int)
- func (m *SubpipelineStepDescription) GetSteps() []*StepDescription
- func (*SubpipelineStepDescription) ProtoMessage()
- func (m *SubpipelineStepDescription) Reset()
- func (m *SubpipelineStepDescription) String() string
- func (m *SubpipelineStepDescription) XXX_DiscardUnknown()
- func (m *SubpipelineStepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubpipelineStepDescription) XXX_Merge(src proto.Message)
- func (m *SubpipelineStepDescription) XXX_Size() int
- func (m *SubpipelineStepDescription) XXX_Unmarshal(b []byte) error
- type TaskSubtype
- type TaskType
- type UpdateProblemRequest
- func (*UpdateProblemRequest) Descriptor() ([]byte, []int)
- func (m *UpdateProblemRequest) GetProblem() *ProblemDescription
- func (m *UpdateProblemRequest) GetSearchId() string
- func (*UpdateProblemRequest) ProtoMessage()
- func (m *UpdateProblemRequest) Reset()
- func (m *UpdateProblemRequest) String() string
- func (m *UpdateProblemRequest) XXX_DiscardUnknown()
- func (m *UpdateProblemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateProblemRequest) XXX_Merge(src proto.Message)
- func (m *UpdateProblemRequest) XXX_Size() int
- func (m *UpdateProblemRequest) XXX_Unmarshal(b []byte) error
- type UpdateProblemResponse
- func (*UpdateProblemResponse) Descriptor() ([]byte, []int)
- func (*UpdateProblemResponse) ProtoMessage()
- func (m *UpdateProblemResponse) Reset()
- func (m *UpdateProblemResponse) String() string
- func (m *UpdateProblemResponse) XXX_DiscardUnknown()
- func (m *UpdateProblemResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateProblemResponse) XXX_Merge(src proto.Message)
- func (m *UpdateProblemResponse) XXX_Size() int
- func (m *UpdateProblemResponse) XXX_Unmarshal(b []byte) error
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetCsvUri() string
- func (m *Value) GetDatasetUri() string
- func (m *Value) GetError() *ValueError
- func (m *Value) GetPickleBlob() []byte
- func (m *Value) GetPickleUri() string
- func (m *Value) GetPlasmaId() []byte
- func (m *Value) GetRaw() *ValueRaw
- func (m *Value) GetValue() isValue_Value
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) String() string
- func (m *Value) XXX_DiscardUnknown()
- func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Value) XXX_Merge(src proto.Message)
- func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Value) XXX_Size() int
- func (m *Value) XXX_Unmarshal(b []byte) error
- type ValueArgument
- func (*ValueArgument) Descriptor() ([]byte, []int)
- func (m *ValueArgument) GetData() *Value
- func (*ValueArgument) ProtoMessage()
- func (m *ValueArgument) Reset()
- func (m *ValueArgument) String() string
- func (m *ValueArgument) XXX_DiscardUnknown()
- func (m *ValueArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValueArgument) XXX_Merge(src proto.Message)
- func (m *ValueArgument) XXX_Size() int
- func (m *ValueArgument) XXX_Unmarshal(b []byte) error
- type ValueDict
- func (*ValueDict) Descriptor() ([]byte, []int)
- func (m *ValueDict) GetItems() map[string]*ValueRaw
- func (*ValueDict) ProtoMessage()
- func (m *ValueDict) Reset()
- func (m *ValueDict) String() string
- func (m *ValueDict) XXX_DiscardUnknown()
- func (m *ValueDict) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValueDict) XXX_Merge(src proto.Message)
- func (m *ValueDict) XXX_Size() int
- func (m *ValueDict) XXX_Unmarshal(b []byte) error
- type ValueError
- func (*ValueError) Descriptor() ([]byte, []int)
- func (m *ValueError) GetMessage() string
- func (*ValueError) ProtoMessage()
- func (m *ValueError) Reset()
- func (m *ValueError) String() string
- func (m *ValueError) XXX_DiscardUnknown()
- func (m *ValueError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValueError) XXX_Merge(src proto.Message)
- func (m *ValueError) XXX_Size() int
- func (m *ValueError) XXX_Unmarshal(b []byte) error
- type ValueList
- func (*ValueList) Descriptor() ([]byte, []int)
- func (m *ValueList) GetItems() []*ValueRaw
- func (*ValueList) ProtoMessage()
- func (m *ValueList) Reset()
- func (m *ValueList) String() string
- func (m *ValueList) XXX_DiscardUnknown()
- func (m *ValueList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValueList) XXX_Merge(src proto.Message)
- func (m *ValueList) XXX_Size() int
- func (m *ValueList) XXX_Unmarshal(b []byte) error
- type ValueRaw
- func (*ValueRaw) Descriptor() ([]byte, []int)
- func (m *ValueRaw) GetBool() bool
- func (m *ValueRaw) GetBytes() []byte
- func (m *ValueRaw) GetDict() *ValueDict
- func (m *ValueRaw) GetDouble() float64
- func (m *ValueRaw) GetInt64() int64
- func (m *ValueRaw) GetList() *ValueList
- func (m *ValueRaw) GetNull() NullValue
- func (m *ValueRaw) GetRaw() isValueRaw_Raw
- func (m *ValueRaw) GetString_() string
- func (*ValueRaw) ProtoMessage()
- func (m *ValueRaw) Reset()
- func (m *ValueRaw) String() string
- func (m *ValueRaw) XXX_DiscardUnknown()
- func (m *ValueRaw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValueRaw) XXX_Merge(src proto.Message)
- func (*ValueRaw) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ValueRaw) XXX_Size() int
- func (m *ValueRaw) XXX_Unmarshal(b []byte) error
- type ValueRaw_Bool
- type ValueRaw_Bytes
- type ValueRaw_Dict
- type ValueRaw_Double
- type ValueRaw_Int64
- type ValueRaw_List
- type ValueRaw_Null
- type ValueRaw_String_
- type ValueType
- type Value_CsvUri
- type Value_DatasetUri
- type Value_Error
- type Value_PickleBlob
- type Value_PickleUri
- type Value_PlasmaId
- type Value_Raw
Constants ¶
This section is empty.
Variables ¶
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", }
var EvaluationMethod_name = map[int32]string{
0: "EVALUATION_METHOD_UNDEFINED",
1: "HOLDOUT",
2: "K_FOLD",
99: "RANKING",
100: "LEAVE_ONE_OUT",
101: "PREDICTION",
102: "TRAINING_DATA",
}
var EvaluationMethod_value = map[string]int32{
"EVALUATION_METHOD_UNDEFINED": 0,
"HOLDOUT": 1,
"K_FOLD": 2,
"RANKING": 99,
"LEAVE_ONE_OUT": 100,
"PREDICTION": 101,
"TRAINING_DATA": 102,
}
var NullValue_name = map[int32]string{
0: "NULL_VALUE",
}
var NullValue_value = map[string]int32{
"NULL_VALUE": 0,
}
var PerformanceMetric_name = map[int32]string{
0: "METRIC_UNDEFINED",
1: "ACCURACY",
2: "PRECISION",
3: "RECALL",
4: "F1",
5: "F1_MICRO",
6: "F1_MACRO",
7: "ROC_AUC",
8: "ROC_AUC_MICRO",
9: "ROC_AUC_MACRO",
10: "MEAN_SQUARED_ERROR",
11: "ROOT_MEAN_SQUARED_ERROR",
12: "MEAN_ABSOLUTE_ERROR",
13: "R_SQUARED",
14: "NORMALIZED_MUTUAL_INFORMATION",
15: "JACCARD_SIMILARITY_SCORE",
17: "PRECISION_AT_TOP_K",
18: "OBJECT_DETECTION_AVERAGE_PRECISION",
19: "HAMMING_LOSS",
99: "RANK",
100: "LOSS",
}
var PerformanceMetric_value = map[string]int32{
"METRIC_UNDEFINED": 0,
"ACCURACY": 1,
"PRECISION": 2,
"RECALL": 3,
"F1": 4,
"F1_MICRO": 5,
"F1_MACRO": 6,
"ROC_AUC": 7,
"ROC_AUC_MICRO": 8,
"ROC_AUC_MACRO": 9,
"MEAN_SQUARED_ERROR": 10,
"ROOT_MEAN_SQUARED_ERROR": 11,
"MEAN_ABSOLUTE_ERROR": 12,
"R_SQUARED": 13,
"NORMALIZED_MUTUAL_INFORMATION": 14,
"JACCARD_SIMILARITY_SCORE": 15,
"PRECISION_AT_TOP_K": 17,
"OBJECT_DETECTION_AVERAGE_PRECISION": 18,
"HAMMING_LOSS": 19,
"RANK": 99,
"LOSS": 100,
}
var PipelineContext_name = map[int32]string{
0: "PIPELINE_CONTEXT_UNKNOWN",
1: "PRETRAINING",
2: "TESTING",
3: "EVALUATION",
4: "PRODUCTION",
}
var PipelineContext_value = map[string]int32{
"PIPELINE_CONTEXT_UNKNOWN": 0,
"PRETRAINING": 1,
"TESTING": 2,
"EVALUATION": 3,
"PRODUCTION": 4,
}
var ProgressState_name = map[int32]string{
0: "PROGRESS_UNKNOWN",
1: "PENDING",
2: "RUNNING",
3: "COMPLETED",
4: "ERRORED",
}
var ProgressState_value = map[string]int32{
"PROGRESS_UNKNOWN": 0,
"PENDING": 1,
"RUNNING": 2,
"COMPLETED": 3,
"ERRORED": 4,
}
var TaskSubtype_name = map[int32]string{
0: "TASK_SUBTYPE_UNDEFINED",
1: "NONE",
2: "BINARY",
3: "MULTICLASS",
4: "MULTILABEL",
5: "UNIVARIATE",
6: "MULTIVARIATE",
7: "OVERLAPPING",
8: "NONOVERLAPPING",
}
var TaskSubtype_value = map[string]int32{
"TASK_SUBTYPE_UNDEFINED": 0,
"NONE": 1,
"BINARY": 2,
"MULTICLASS": 3,
"MULTILABEL": 4,
"UNIVARIATE": 5,
"MULTIVARIATE": 6,
"OVERLAPPING": 7,
"NONOVERLAPPING": 8,
}
var TaskType_name = map[int32]string{
0: "TASK_TYPE_UNDEFINED",
1: "CLASSIFICATION",
2: "REGRESSION",
3: "CLUSTERING",
4: "LINK_PREDICTION",
5: "VERTEX_NOMINATION",
6: "VERTEX_CLASSIFICATION",
7: "COMMUNITY_DETECTION",
8: "GRAPH_MATCHING",
9: "TIME_SERIES_FORECASTING",
10: "COLLABORATIVE_FILTERING",
11: "OBJECT_DETECTION",
12: "SEMISUPERVISED_CLASSIFICATION",
13: "SEMISUPERVISED_REGRESSION",
}
var TaskType_value = map[string]int32{
"TASK_TYPE_UNDEFINED": 0,
"CLASSIFICATION": 1,
"REGRESSION": 2,
"CLUSTERING": 3,
"LINK_PREDICTION": 4,
"VERTEX_NOMINATION": 5,
"VERTEX_CLASSIFICATION": 6,
"COMMUNITY_DETECTION": 7,
"GRAPH_MATCHING": 8,
"TIME_SERIES_FORECASTING": 9,
"COLLABORATIVE_FILTERING": 10,
"OBJECT_DETECTION": 11,
"SEMISUPERVISED_CLASSIFICATION": 12,
"SEMISUPERVISED_REGRESSION": 13,
}
var ValueType_name = map[int32]string{
0: "VALUE_TYPE_UNDEFINED",
1: "RAW",
2: "DATASET_URI",
3: "CSV_URI",
4: "PICKLE_URI",
5: "PICKLE_BLOB",
6: "PLASMA_ID",
7: "LARGE_RAW",
8: "LARGE_PICKLE_BLOB",
}
var ValueType_value = map[string]int32{
"VALUE_TYPE_UNDEFINED": 0,
"RAW": 1,
"DATASET_URI": 2,
"CSV_URI": 3,
"PICKLE_URI": 4,
"PICKLE_BLOB": 5,
"PLASMA_ID": 6,
"LARGE_RAW": 7,
"LARGE_PICKLE_BLOB": 8,
}
Functions ¶
func APIVersion ¶
func APIVersion() string
APIVersion is the version of the TA3-TA2 API extracted from the protobuf definition. Lazily evaluated since the protobuf init has to be complete before it can be used. Doesn't change after initialization.
func RegisterCoreServer ¶
func RegisterCoreServer(s *grpc.Server, srv CoreServer)
Types ¶
type ContainerArgument ¶
type ContainerArgument struct { // Data reference. Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ContainerArgument) Descriptor ¶
func (*ContainerArgument) Descriptor() ([]byte, []int)
func (*ContainerArgument) GetData ¶
func (m *ContainerArgument) GetData() string
func (*ContainerArgument) ProtoMessage ¶
func (*ContainerArgument) ProtoMessage()
func (*ContainerArgument) Reset ¶
func (m *ContainerArgument) Reset()
func (*ContainerArgument) String ¶
func (m *ContainerArgument) String() string
func (*ContainerArgument) XXX_DiscardUnknown ¶
func (m *ContainerArgument) XXX_DiscardUnknown()
func (*ContainerArgument) XXX_Marshal ¶
func (m *ContainerArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerArgument) XXX_Merge ¶
func (m *ContainerArgument) XXX_Merge(src proto.Message)
func (*ContainerArgument) XXX_Size ¶
func (m *ContainerArgument) XXX_Size() int
func (*ContainerArgument) XXX_Unmarshal ¶
func (m *ContainerArgument) XXX_Unmarshal(b []byte) error
type ContainerArguments ¶
type ContainerArguments struct { Data []string `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ContainerArguments) Descriptor ¶
func (*ContainerArguments) Descriptor() ([]byte, []int)
func (*ContainerArguments) GetData ¶
func (m *ContainerArguments) GetData() []string
func (*ContainerArguments) ProtoMessage ¶
func (*ContainerArguments) ProtoMessage()
func (*ContainerArguments) Reset ¶
func (m *ContainerArguments) Reset()
func (*ContainerArguments) String ¶
func (m *ContainerArguments) String() string
func (*ContainerArguments) XXX_DiscardUnknown ¶
func (m *ContainerArguments) XXX_DiscardUnknown()
func (*ContainerArguments) XXX_Marshal ¶
func (m *ContainerArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerArguments) XXX_Merge ¶
func (m *ContainerArguments) XXX_Merge(src proto.Message)
func (*ContainerArguments) XXX_Size ¶
func (m *ContainerArguments) XXX_Size() int
func (*ContainerArguments) XXX_Unmarshal ¶
func (m *ContainerArguments) XXX_Unmarshal(b []byte) error
type CoreClient ¶
type CoreClient interface { SearchSolutions(ctx context.Context, in *SearchSolutionsRequest, opts ...grpc.CallOption) (*SearchSolutionsResponse, error) GetSearchSolutionsResults(ctx context.Context, in *GetSearchSolutionsResultsRequest, opts ...grpc.CallOption) (Core_GetSearchSolutionsResultsClient, error) EndSearchSolutions(ctx context.Context, in *EndSearchSolutionsRequest, opts ...grpc.CallOption) (*EndSearchSolutionsResponse, error) StopSearchSolutions(ctx context.Context, in *StopSearchSolutionsRequest, opts ...grpc.CallOption) (*StopSearchSolutionsResponse, error) DescribeSolution(ctx context.Context, in *DescribeSolutionRequest, opts ...grpc.CallOption) (*DescribeSolutionResponse, error) ScoreSolution(ctx context.Context, in *ScoreSolutionRequest, opts ...grpc.CallOption) (*ScoreSolutionResponse, error) GetScoreSolutionResults(ctx context.Context, in *GetScoreSolutionResultsRequest, opts ...grpc.CallOption) (Core_GetScoreSolutionResultsClient, error) FitSolution(ctx context.Context, in *FitSolutionRequest, opts ...grpc.CallOption) (*FitSolutionResponse, error) GetFitSolutionResults(ctx context.Context, in *GetFitSolutionResultsRequest, opts ...grpc.CallOption) (Core_GetFitSolutionResultsClient, error) ProduceSolution(ctx context.Context, in *ProduceSolutionRequest, opts ...grpc.CallOption) (*ProduceSolutionResponse, error) GetProduceSolutionResults(ctx context.Context, in *GetProduceSolutionResultsRequest, opts ...grpc.CallOption) (Core_GetProduceSolutionResultsClient, error) SolutionExport(ctx context.Context, in *SolutionExportRequest, opts ...grpc.CallOption) (*SolutionExportResponse, error) UpdateProblem(ctx context.Context, in *UpdateProblemRequest, opts ...grpc.CallOption) (*UpdateProblemResponse, error) DataAvailable(ctx context.Context, in *DataAvailableRequest, opts ...grpc.CallOption) (*DataAvailableResponse, error) ListPrimitives(ctx context.Context, in *ListPrimitivesRequest, opts ...grpc.CallOption) (*ListPrimitivesResponse, error) Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error) // Optional. SaveSolution(ctx context.Context, in *SaveSolutionRequest, opts ...grpc.CallOption) (*SaveSolutionResponse, error) LoadSolution(ctx context.Context, in *LoadSolutionRequest, opts ...grpc.CallOption) (*LoadSolutionResponse, error) SaveFittedSolution(ctx context.Context, in *SaveFittedSolutionRequest, opts ...grpc.CallOption) (*SaveFittedSolutionResponse, error) LoadFittedSolution(ctx context.Context, in *LoadFittedSolutionRequest, opts ...grpc.CallOption) (*LoadFittedSolutionResponse, error) }
CoreClient is the client API for Core service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCoreClient ¶
func NewCoreClient(cc *grpc.ClientConn) CoreClient
type CoreServer ¶
type CoreServer interface { SearchSolutions(context.Context, *SearchSolutionsRequest) (*SearchSolutionsResponse, error) GetSearchSolutionsResults(*GetSearchSolutionsResultsRequest, Core_GetSearchSolutionsResultsServer) error EndSearchSolutions(context.Context, *EndSearchSolutionsRequest) (*EndSearchSolutionsResponse, error) StopSearchSolutions(context.Context, *StopSearchSolutionsRequest) (*StopSearchSolutionsResponse, error) DescribeSolution(context.Context, *DescribeSolutionRequest) (*DescribeSolutionResponse, error) ScoreSolution(context.Context, *ScoreSolutionRequest) (*ScoreSolutionResponse, error) GetScoreSolutionResults(*GetScoreSolutionResultsRequest, Core_GetScoreSolutionResultsServer) error FitSolution(context.Context, *FitSolutionRequest) (*FitSolutionResponse, error) GetFitSolutionResults(*GetFitSolutionResultsRequest, Core_GetFitSolutionResultsServer) error ProduceSolution(context.Context, *ProduceSolutionRequest) (*ProduceSolutionResponse, error) GetProduceSolutionResults(*GetProduceSolutionResultsRequest, Core_GetProduceSolutionResultsServer) error SolutionExport(context.Context, *SolutionExportRequest) (*SolutionExportResponse, error) UpdateProblem(context.Context, *UpdateProblemRequest) (*UpdateProblemResponse, error) DataAvailable(context.Context, *DataAvailableRequest) (*DataAvailableResponse, error) ListPrimitives(context.Context, *ListPrimitivesRequest) (*ListPrimitivesResponse, error) Hello(context.Context, *HelloRequest) (*HelloResponse, error) // Optional. SaveSolution(context.Context, *SaveSolutionRequest) (*SaveSolutionResponse, error) LoadSolution(context.Context, *LoadSolutionRequest) (*LoadSolutionResponse, error) SaveFittedSolution(context.Context, *SaveFittedSolutionRequest) (*SaveFittedSolutionResponse, error) LoadFittedSolution(context.Context, *LoadFittedSolutionRequest) (*LoadFittedSolutionResponse, error) }
CoreServer is the server API for Core service.
type Core_GetFitSolutionResultsClient ¶
type Core_GetFitSolutionResultsClient interface { Recv() (*GetFitSolutionResultsResponse, error) grpc.ClientStream }
type Core_GetFitSolutionResultsServer ¶
type Core_GetFitSolutionResultsServer interface { Send(*GetFitSolutionResultsResponse) error grpc.ServerStream }
type Core_GetProduceSolutionResultsClient ¶
type Core_GetProduceSolutionResultsClient interface { Recv() (*GetProduceSolutionResultsResponse, error) grpc.ClientStream }
type Core_GetProduceSolutionResultsServer ¶
type Core_GetProduceSolutionResultsServer interface { Send(*GetProduceSolutionResultsResponse) error grpc.ServerStream }
type Core_GetScoreSolutionResultsClient ¶
type Core_GetScoreSolutionResultsClient interface { Recv() (*GetScoreSolutionResultsResponse, error) grpc.ClientStream }
type Core_GetScoreSolutionResultsServer ¶
type Core_GetScoreSolutionResultsServer interface { Send(*GetScoreSolutionResultsResponse) error grpc.ServerStream }
type Core_GetSearchSolutionsResultsClient ¶
type Core_GetSearchSolutionsResultsClient interface { Recv() (*GetSearchSolutionsResultsResponse, error) grpc.ClientStream }
type Core_GetSearchSolutionsResultsServer ¶
type Core_GetSearchSolutionsResultsServer interface { Send(*GetSearchSolutionsResultsResponse) error grpc.ServerStream }
type DataArgument ¶
type DataArgument struct { // Data reference. Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataArgument) Descriptor ¶
func (*DataArgument) Descriptor() ([]byte, []int)
func (*DataArgument) GetData ¶
func (m *DataArgument) GetData() string
func (*DataArgument) ProtoMessage ¶
func (*DataArgument) ProtoMessage()
func (*DataArgument) Reset ¶
func (m *DataArgument) Reset()
func (*DataArgument) String ¶
func (m *DataArgument) String() string
func (*DataArgument) XXX_DiscardUnknown ¶
func (m *DataArgument) XXX_DiscardUnknown()
func (*DataArgument) XXX_Marshal ¶
func (m *DataArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataArgument) XXX_Merge ¶
func (m *DataArgument) XXX_Merge(src proto.Message)
func (*DataArgument) XXX_Size ¶
func (m *DataArgument) XXX_Size() int
func (*DataArgument) XXX_Unmarshal ¶
func (m *DataArgument) XXX_Unmarshal(b []byte) error
type DataArguments ¶
type DataArguments struct { Data []string `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataArguments) Descriptor ¶
func (*DataArguments) Descriptor() ([]byte, []int)
func (*DataArguments) GetData ¶
func (m *DataArguments) GetData() []string
func (*DataArguments) ProtoMessage ¶
func (*DataArguments) ProtoMessage()
func (*DataArguments) Reset ¶
func (m *DataArguments) Reset()
func (*DataArguments) String ¶
func (m *DataArguments) String() string
func (*DataArguments) XXX_DiscardUnknown ¶
func (m *DataArguments) XXX_DiscardUnknown()
func (*DataArguments) XXX_Marshal ¶
func (m *DataArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataArguments) XXX_Merge ¶
func (m *DataArguments) XXX_Merge(src proto.Message)
func (*DataArguments) XXX_Size ¶
func (m *DataArguments) XXX_Size() int
func (*DataArguments) XXX_Unmarshal ¶
func (m *DataArguments) XXX_Unmarshal(b []byte) error
type DataAugmentation ¶
type DataAugmentation struct { Domain []string `protobuf:"bytes,1,rep,name=domain,proto3" json:"domain,omitempty"` Keywords []string `protobuf:"bytes,2,rep,name=keywords,proto3" json:"keywords,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataAugmentation) Descriptor ¶
func (*DataAugmentation) Descriptor() ([]byte, []int)
func (*DataAugmentation) GetDomain ¶
func (m *DataAugmentation) GetDomain() []string
func (*DataAugmentation) GetKeywords ¶
func (m *DataAugmentation) GetKeywords() []string
func (*DataAugmentation) ProtoMessage ¶
func (*DataAugmentation) ProtoMessage()
func (*DataAugmentation) Reset ¶
func (m *DataAugmentation) Reset()
func (*DataAugmentation) String ¶
func (m *DataAugmentation) String() string
func (*DataAugmentation) XXX_DiscardUnknown ¶
func (m *DataAugmentation) XXX_DiscardUnknown()
func (*DataAugmentation) XXX_Marshal ¶
func (m *DataAugmentation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataAugmentation) XXX_Merge ¶
func (m *DataAugmentation) XXX_Merge(src proto.Message)
func (*DataAugmentation) XXX_Size ¶
func (m *DataAugmentation) XXX_Size() int
func (*DataAugmentation) XXX_Unmarshal ¶
func (m *DataAugmentation) XXX_Unmarshal(b []byte) error
type DataAvailableRequest ¶
type DataAvailableRequest struct { // Some string identifying the name and version of the TA3 system. UserAgent string `protobuf:"bytes,1,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` // Shall be set to "protocol_version" above. Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Desired upper limit of time spend processing this data, expressed in minutes. // Is suggestion, and TA2's should attempt to obey, but TA3's should realize may be // violated. Default value of 0 (and any negative number) signifies no time bound. TimeBound float64 `protobuf:"fixed64,3,opt,name=time_bound,json=timeBound,proto3" json:"time_bound,omitempty"` // Value stating the priority for processing of this data. Larger number is higher // priority. If unspecified, by default priority is 0. Negative numbers have // still lower priority. Priority float64 `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"` Data []*Value `protobuf:"bytes,5,rep,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Inform TA2 about data being available, triggering any potential internal data processing by TA2.
func (*DataAvailableRequest) Descriptor ¶
func (*DataAvailableRequest) Descriptor() ([]byte, []int)
func (*DataAvailableRequest) GetData ¶
func (m *DataAvailableRequest) GetData() []*Value
func (*DataAvailableRequest) GetPriority ¶
func (m *DataAvailableRequest) GetPriority() float64
func (*DataAvailableRequest) GetTimeBound ¶
func (m *DataAvailableRequest) GetTimeBound() float64
func (*DataAvailableRequest) GetUserAgent ¶
func (m *DataAvailableRequest) GetUserAgent() string
func (*DataAvailableRequest) GetVersion ¶
func (m *DataAvailableRequest) GetVersion() string
func (*DataAvailableRequest) ProtoMessage ¶
func (*DataAvailableRequest) ProtoMessage()
func (*DataAvailableRequest) Reset ¶
func (m *DataAvailableRequest) Reset()
func (*DataAvailableRequest) String ¶
func (m *DataAvailableRequest) String() string
func (*DataAvailableRequest) XXX_DiscardUnknown ¶
func (m *DataAvailableRequest) XXX_DiscardUnknown()
func (*DataAvailableRequest) XXX_Marshal ¶
func (m *DataAvailableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataAvailableRequest) XXX_Merge ¶
func (m *DataAvailableRequest) XXX_Merge(src proto.Message)
func (*DataAvailableRequest) XXX_Size ¶
func (m *DataAvailableRequest) XXX_Size() int
func (*DataAvailableRequest) XXX_Unmarshal ¶
func (m *DataAvailableRequest) XXX_Unmarshal(b []byte) error
type DataAvailableResponse ¶
type DataAvailableResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataAvailableResponse) Descriptor ¶
func (*DataAvailableResponse) Descriptor() ([]byte, []int)
func (*DataAvailableResponse) ProtoMessage ¶
func (*DataAvailableResponse) ProtoMessage()
func (*DataAvailableResponse) Reset ¶
func (m *DataAvailableResponse) Reset()
func (*DataAvailableResponse) String ¶
func (m *DataAvailableResponse) String() string
func (*DataAvailableResponse) XXX_DiscardUnknown ¶
func (m *DataAvailableResponse) XXX_DiscardUnknown()
func (*DataAvailableResponse) XXX_Marshal ¶
func (m *DataAvailableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataAvailableResponse) XXX_Merge ¶
func (m *DataAvailableResponse) XXX_Merge(src proto.Message)
func (*DataAvailableResponse) XXX_Size ¶
func (m *DataAvailableResponse) XXX_Size() int
func (*DataAvailableResponse) XXX_Unmarshal ¶
func (m *DataAvailableResponse) XXX_Unmarshal(b []byte) error
type DataResource ¶
type DataResource struct { ResID string `json:"resID"` ResPath string `json:"resPath"` ResType string `json:"resType"` ResFormat []string `json:"resFormat"` IsCollection bool `json:"isCollection"` Variables []*DataVariable `json:"columns"` }
DataResource represents a set of variables.
type DataSchema ¶
type DataSchema struct { Properties *DataSchemaProperties `json:"about"` DataResources []*DataResource `json:"dataResources"` }
DataSchema encapsulates the data schema json structure.
type DataSchemaProperties ¶
type DataSchemaProperties struct { DatasetID string `json:"datasetID"` DatasetName string `json:"datasetName"` Description string `json:"description"` Citation string `json:"citation"` License string `json:"license"` Source string `json:"source"` SourceURI string `json:"sourceURI"` ApproximateSize string `json:"approximateSize"` Redacted bool `json:"redacted"` SchemaVersion string `json:"datasetSchemaVersion"` }
DataSchemaProperties contains the basic properties of a dataset.
type DataVariable ¶
type DataVariable struct { ColName string `json:"colName"` Role []string `json:"role"` ColType string `json:"colType"` ColIndex int `json:"colIndex"` }
DataVariable captures the data schema representation of a variable.
type DescribeSolutionRequest ¶
type DescribeSolutionRequest struct { SolutionId string `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request a detailed description of the found solution.
func (*DescribeSolutionRequest) Descriptor ¶
func (*DescribeSolutionRequest) Descriptor() ([]byte, []int)
func (*DescribeSolutionRequest) GetSolutionId ¶
func (m *DescribeSolutionRequest) GetSolutionId() string
func (*DescribeSolutionRequest) ProtoMessage ¶
func (*DescribeSolutionRequest) ProtoMessage()
func (*DescribeSolutionRequest) Reset ¶
func (m *DescribeSolutionRequest) Reset()
func (*DescribeSolutionRequest) String ¶
func (m *DescribeSolutionRequest) String() string
func (*DescribeSolutionRequest) XXX_DiscardUnknown ¶
func (m *DescribeSolutionRequest) XXX_DiscardUnknown()
func (*DescribeSolutionRequest) XXX_Marshal ¶
func (m *DescribeSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DescribeSolutionRequest) XXX_Merge ¶
func (m *DescribeSolutionRequest) XXX_Merge(src proto.Message)
func (*DescribeSolutionRequest) XXX_Size ¶
func (m *DescribeSolutionRequest) XXX_Size() int
func (*DescribeSolutionRequest) XXX_Unmarshal ¶
func (m *DescribeSolutionRequest) XXX_Unmarshal(b []byte) error
type DescribeSolutionResponse ¶
type DescribeSolutionResponse struct { // A pipeline description. Nested pipelines should be fully described as well. Pipeline *PipelineDescription `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // Each step in a pipeline has description. These are reported in the order of steps in // the pipeline. Steps []*StepDescription `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DescribeSolutionResponse) Descriptor ¶
func (*DescribeSolutionResponse) Descriptor() ([]byte, []int)
func (*DescribeSolutionResponse) GetPipeline ¶
func (m *DescribeSolutionResponse) GetPipeline() *PipelineDescription
func (*DescribeSolutionResponse) GetSteps ¶
func (m *DescribeSolutionResponse) GetSteps() []*StepDescription
func (*DescribeSolutionResponse) ProtoMessage ¶
func (*DescribeSolutionResponse) ProtoMessage()
func (*DescribeSolutionResponse) Reset ¶
func (m *DescribeSolutionResponse) Reset()
func (*DescribeSolutionResponse) String ¶
func (m *DescribeSolutionResponse) String() string
func (*DescribeSolutionResponse) XXX_DiscardUnknown ¶
func (m *DescribeSolutionResponse) XXX_DiscardUnknown()
func (*DescribeSolutionResponse) XXX_Marshal ¶
func (m *DescribeSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DescribeSolutionResponse) XXX_Merge ¶
func (m *DescribeSolutionResponse) XXX_Merge(src proto.Message)
func (*DescribeSolutionResponse) XXX_Size ¶
func (m *DescribeSolutionResponse) XXX_Size() int
func (*DescribeSolutionResponse) XXX_Unmarshal ¶
func (m *DescribeSolutionResponse) XXX_Unmarshal(b []byte) error
type EndSearchSolutionsRequest ¶
type EndSearchSolutionsRequest struct { SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Ends the search and releases all resources associated with the solution search. If the call is made in parallel with a running search and results are being streamed, the search is stopped and the "GetSearchSolutionsResults" stream is closed by TA2 (as happens when the search is concluded on its own, or when a search is stopped by "StopSearchSolutions"). Found solution IDs during the search are no longer valid after this call.
func (*EndSearchSolutionsRequest) Descriptor ¶
func (*EndSearchSolutionsRequest) Descriptor() ([]byte, []int)
func (*EndSearchSolutionsRequest) GetSearchId ¶
func (m *EndSearchSolutionsRequest) GetSearchId() string
func (*EndSearchSolutionsRequest) ProtoMessage ¶
func (*EndSearchSolutionsRequest) ProtoMessage()
func (*EndSearchSolutionsRequest) Reset ¶
func (m *EndSearchSolutionsRequest) Reset()
func (*EndSearchSolutionsRequest) String ¶
func (m *EndSearchSolutionsRequest) String() string
func (*EndSearchSolutionsRequest) XXX_DiscardUnknown ¶
func (m *EndSearchSolutionsRequest) XXX_DiscardUnknown()
func (*EndSearchSolutionsRequest) XXX_Marshal ¶
func (m *EndSearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EndSearchSolutionsRequest) XXX_Merge ¶
func (m *EndSearchSolutionsRequest) XXX_Merge(src proto.Message)
func (*EndSearchSolutionsRequest) XXX_Size ¶
func (m *EndSearchSolutionsRequest) XXX_Size() int
func (*EndSearchSolutionsRequest) XXX_Unmarshal ¶
func (m *EndSearchSolutionsRequest) XXX_Unmarshal(b []byte) error
type EndSearchSolutionsResponse ¶
type EndSearchSolutionsResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EndSearchSolutionsResponse) Descriptor ¶
func (*EndSearchSolutionsResponse) Descriptor() ([]byte, []int)
func (*EndSearchSolutionsResponse) ProtoMessage ¶
func (*EndSearchSolutionsResponse) ProtoMessage()
func (*EndSearchSolutionsResponse) Reset ¶
func (m *EndSearchSolutionsResponse) Reset()
func (*EndSearchSolutionsResponse) String ¶
func (m *EndSearchSolutionsResponse) String() string
func (*EndSearchSolutionsResponse) XXX_DiscardUnknown ¶
func (m *EndSearchSolutionsResponse) XXX_DiscardUnknown()
func (*EndSearchSolutionsResponse) XXX_Marshal ¶
func (m *EndSearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EndSearchSolutionsResponse) XXX_Merge ¶
func (m *EndSearchSolutionsResponse) XXX_Merge(src proto.Message)
func (*EndSearchSolutionsResponse) XXX_Size ¶
func (m *EndSearchSolutionsResponse) XXX_Size() int
func (*EndSearchSolutionsResponse) XXX_Unmarshal ¶
func (m *EndSearchSolutionsResponse) XXX_Unmarshal(b []byte) error
type EvaluationMethod ¶
type EvaluationMethod int32
const ( // Default value. Not to be used. EvaluationMethod_EVALUATION_METHOD_UNDEFINED EvaluationMethod = 0 // The following are the only evaluation methods required // to be supported for the "ScoreSolution" call. EvaluationMethod_HOLDOUT EvaluationMethod = 1 EvaluationMethod_K_FOLD EvaluationMethod = 2 // This evaluation method can be used to ask TA2 to rank a // solution as part of all found solutions of a given // "SearchSolutions" call. Invalid to use before the // "SearchSolutions" call, of which the solution is part of, // has successfully completed or has been stopped. // Only possible with "RANK" performance metric. EvaluationMethod_RANKING EvaluationMethod = 99 // The rest are defined to allow expressing internal evaluation // methods used by TA2 during solution search. If any method being used // is missing, feel free to request it to be added. EvaluationMethod_LEAVE_ONE_OUT EvaluationMethod = 100 // Instead of really scoring, a TA2 might predict the score only. EvaluationMethod_PREDICTION EvaluationMethod = 101 // Training data is reused to test as well. EvaluationMethod_TRAINING_DATA EvaluationMethod = 102 )
func (EvaluationMethod) EnumDescriptor ¶
func (EvaluationMethod) EnumDescriptor() ([]byte, []int)
func (EvaluationMethod) String ¶
func (x EvaluationMethod) String() string
type FitSolutionRequest ¶
type FitSolutionRequest struct { SolutionId string `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"` Inputs []*Value `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` // List of data references of step outputs which should be exposed to the TA3 system. // If you want to expose outputs of the whole pipeline (e.g., predictions themselves), // list them here as well. These can be recursive data references like // "steps.1.steps.4.produce" to point to an output inside a sub-pipeline. // Systems only have to support exposing final outputs and can return "ValueError" for // intermediate values. ExposeOutputs []string `protobuf:"bytes,3,rep,name=expose_outputs,json=exposeOutputs,proto3" json:"expose_outputs,omitempty"` // Which value types should be used for exposing outputs. If not provided, the allowed // value types list from the search solutions call is used instead. // The order is important as TA2 system will try value types in order until one works out, // or an error will be returned instead of the value. An error exposing a value does not // stop the overall process. ExposeValueTypes []ValueType `` /* 134-byte string literal not displayed */ // Any users associated with this call itself. Optional. Users []*SolutionRunUser `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Fit the solution on given inputs. If a solution is already fitted on inputs this is a NOOP (if no additional outputs should be exposed). This can happen when a TA2 simultaneously fits the solution as part of the solution search phase.
func (*FitSolutionRequest) Descriptor ¶
func (*FitSolutionRequest) Descriptor() ([]byte, []int)
func (*FitSolutionRequest) GetExposeOutputs ¶
func (m *FitSolutionRequest) GetExposeOutputs() []string
func (*FitSolutionRequest) GetExposeValueTypes ¶
func (m *FitSolutionRequest) GetExposeValueTypes() []ValueType
func (*FitSolutionRequest) GetInputs ¶
func (m *FitSolutionRequest) GetInputs() []*Value
func (*FitSolutionRequest) GetSolutionId ¶
func (m *FitSolutionRequest) GetSolutionId() string
func (*FitSolutionRequest) GetUsers ¶
func (m *FitSolutionRequest) GetUsers() []*SolutionRunUser
func (*FitSolutionRequest) ProtoMessage ¶
func (*FitSolutionRequest) ProtoMessage()
func (*FitSolutionRequest) Reset ¶
func (m *FitSolutionRequest) Reset()
func (*FitSolutionRequest) String ¶
func (m *FitSolutionRequest) String() string
func (*FitSolutionRequest) XXX_DiscardUnknown ¶
func (m *FitSolutionRequest) XXX_DiscardUnknown()
func (*FitSolutionRequest) XXX_Marshal ¶
func (m *FitSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FitSolutionRequest) XXX_Merge ¶
func (m *FitSolutionRequest) XXX_Merge(src proto.Message)
func (*FitSolutionRequest) XXX_Size ¶
func (m *FitSolutionRequest) XXX_Size() int
func (*FitSolutionRequest) XXX_Unmarshal ¶
func (m *FitSolutionRequest) XXX_Unmarshal(b []byte) error
type FitSolutionResponse ¶
type FitSolutionResponse struct { RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FitSolutionResponse) Descriptor ¶
func (*FitSolutionResponse) Descriptor() ([]byte, []int)
func (*FitSolutionResponse) GetRequestId ¶
func (m *FitSolutionResponse) GetRequestId() string
func (*FitSolutionResponse) ProtoMessage ¶
func (*FitSolutionResponse) ProtoMessage()
func (*FitSolutionResponse) Reset ¶
func (m *FitSolutionResponse) Reset()
func (*FitSolutionResponse) String ¶
func (m *FitSolutionResponse) String() string
func (*FitSolutionResponse) XXX_DiscardUnknown ¶
func (m *FitSolutionResponse) XXX_DiscardUnknown()
func (*FitSolutionResponse) XXX_Marshal ¶
func (m *FitSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FitSolutionResponse) XXX_Merge ¶
func (m *FitSolutionResponse) XXX_Merge(src proto.Message)
func (*FitSolutionResponse) XXX_Size ¶
func (m *FitSolutionResponse) XXX_Size() int
func (*FitSolutionResponse) XXX_Unmarshal ¶
func (m *FitSolutionResponse) XXX_Unmarshal(b []byte) error
type GetFitSolutionResultsRequest ¶
type GetFitSolutionResultsRequest struct { RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Get the latest state of fitting the solution and start receiving any further new updates to the state as well.
func (*GetFitSolutionResultsRequest) Descriptor ¶
func (*GetFitSolutionResultsRequest) Descriptor() ([]byte, []int)
func (*GetFitSolutionResultsRequest) GetRequestId ¶
func (m *GetFitSolutionResultsRequest) GetRequestId() string
func (*GetFitSolutionResultsRequest) ProtoMessage ¶
func (*GetFitSolutionResultsRequest) ProtoMessage()
func (*GetFitSolutionResultsRequest) Reset ¶
func (m *GetFitSolutionResultsRequest) Reset()
func (*GetFitSolutionResultsRequest) String ¶
func (m *GetFitSolutionResultsRequest) String() string
func (*GetFitSolutionResultsRequest) XXX_DiscardUnknown ¶
func (m *GetFitSolutionResultsRequest) XXX_DiscardUnknown()
func (*GetFitSolutionResultsRequest) XXX_Marshal ¶
func (m *GetFitSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetFitSolutionResultsRequest) XXX_Merge ¶
func (m *GetFitSolutionResultsRequest) XXX_Merge(src proto.Message)
func (*GetFitSolutionResultsRequest) XXX_Size ¶
func (m *GetFitSolutionResultsRequest) XXX_Size() int
func (*GetFitSolutionResultsRequest) XXX_Unmarshal ¶
func (m *GetFitSolutionResultsRequest) XXX_Unmarshal(b []byte) error
type GetFitSolutionResultsResponse ¶
type GetFitSolutionResultsResponse struct { // Overall process progress. Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"` // The list contains progress for each step in the pipeline, in order. // List can be incomplete while the process is in progress. Systems can provide // steps only at the end (when "progress" equals COMPLETED) and not during running. Steps []*StepProgress `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"` // A mapping between data references of step outputs and values. ExposedOutputs map[string]*Value `` /* 191-byte string literal not displayed */ // The fitted solution ID, once progress = COMPLETED. FittedSolutionId string `protobuf:"bytes,4,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetFitSolutionResultsResponse) Descriptor ¶
func (*GetFitSolutionResultsResponse) Descriptor() ([]byte, []int)
func (*GetFitSolutionResultsResponse) GetExposedOutputs ¶
func (m *GetFitSolutionResultsResponse) GetExposedOutputs() map[string]*Value
func (*GetFitSolutionResultsResponse) GetFittedSolutionId ¶
func (m *GetFitSolutionResultsResponse) GetFittedSolutionId() string
func (*GetFitSolutionResultsResponse) GetProgress ¶
func (m *GetFitSolutionResultsResponse) GetProgress() *Progress
func (*GetFitSolutionResultsResponse) GetSteps ¶
func (m *GetFitSolutionResultsResponse) GetSteps() []*StepProgress
func (*GetFitSolutionResultsResponse) ProtoMessage ¶
func (*GetFitSolutionResultsResponse) ProtoMessage()
func (*GetFitSolutionResultsResponse) Reset ¶
func (m *GetFitSolutionResultsResponse) Reset()
func (*GetFitSolutionResultsResponse) String ¶
func (m *GetFitSolutionResultsResponse) String() string
func (*GetFitSolutionResultsResponse) XXX_DiscardUnknown ¶
func (m *GetFitSolutionResultsResponse) XXX_DiscardUnknown()
func (*GetFitSolutionResultsResponse) XXX_Marshal ¶
func (m *GetFitSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetFitSolutionResultsResponse) XXX_Merge ¶
func (m *GetFitSolutionResultsResponse) XXX_Merge(src proto.Message)
func (*GetFitSolutionResultsResponse) XXX_Size ¶
func (m *GetFitSolutionResultsResponse) XXX_Size() int
func (*GetFitSolutionResultsResponse) XXX_Unmarshal ¶
func (m *GetFitSolutionResultsResponse) XXX_Unmarshal(b []byte) error
type GetProduceSolutionResultsRequest ¶
type GetProduceSolutionResultsRequest struct { RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Get the latest state of producing the fitted solution and start receiving any further new updates to the state as well.
func (*GetProduceSolutionResultsRequest) Descriptor ¶
func (*GetProduceSolutionResultsRequest) Descriptor() ([]byte, []int)
func (*GetProduceSolutionResultsRequest) GetRequestId ¶
func (m *GetProduceSolutionResultsRequest) GetRequestId() string
func (*GetProduceSolutionResultsRequest) ProtoMessage ¶
func (*GetProduceSolutionResultsRequest) ProtoMessage()
func (*GetProduceSolutionResultsRequest) Reset ¶
func (m *GetProduceSolutionResultsRequest) Reset()
func (*GetProduceSolutionResultsRequest) String ¶
func (m *GetProduceSolutionResultsRequest) String() string
func (*GetProduceSolutionResultsRequest) XXX_DiscardUnknown ¶
func (m *GetProduceSolutionResultsRequest) XXX_DiscardUnknown()
func (*GetProduceSolutionResultsRequest) XXX_Marshal ¶
func (m *GetProduceSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetProduceSolutionResultsRequest) XXX_Merge ¶
func (m *GetProduceSolutionResultsRequest) XXX_Merge(src proto.Message)
func (*GetProduceSolutionResultsRequest) XXX_Size ¶
func (m *GetProduceSolutionResultsRequest) XXX_Size() int
func (*GetProduceSolutionResultsRequest) XXX_Unmarshal ¶
func (m *GetProduceSolutionResultsRequest) XXX_Unmarshal(b []byte) error
type GetProduceSolutionResultsResponse ¶
type GetProduceSolutionResultsResponse struct { // Overall process progress. Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"` // The list contains progress for each step in the pipeline, in order. // List can be incomplete while the process is in progress. Systems can provide // steps only at the end (when "progress" equals COMPLETED) and not during running. Steps []*StepProgress `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"` // A mapping between data references of step outputs and values. ExposedOutputs map[string]*Value `` /* 191-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetProduceSolutionResultsResponse) Descriptor ¶
func (*GetProduceSolutionResultsResponse) Descriptor() ([]byte, []int)
func (*GetProduceSolutionResultsResponse) GetExposedOutputs ¶
func (m *GetProduceSolutionResultsResponse) GetExposedOutputs() map[string]*Value
func (*GetProduceSolutionResultsResponse) GetProgress ¶
func (m *GetProduceSolutionResultsResponse) GetProgress() *Progress
func (*GetProduceSolutionResultsResponse) GetSteps ¶
func (m *GetProduceSolutionResultsResponse) GetSteps() []*StepProgress
func (*GetProduceSolutionResultsResponse) ProtoMessage ¶
func (*GetProduceSolutionResultsResponse) ProtoMessage()
func (*GetProduceSolutionResultsResponse) Reset ¶
func (m *GetProduceSolutionResultsResponse) Reset()
func (*GetProduceSolutionResultsResponse) String ¶
func (m *GetProduceSolutionResultsResponse) String() string
func (*GetProduceSolutionResultsResponse) XXX_DiscardUnknown ¶
func (m *GetProduceSolutionResultsResponse) XXX_DiscardUnknown()
func (*GetProduceSolutionResultsResponse) XXX_Marshal ¶
func (m *GetProduceSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetProduceSolutionResultsResponse) XXX_Merge ¶
func (m *GetProduceSolutionResultsResponse) XXX_Merge(src proto.Message)
func (*GetProduceSolutionResultsResponse) XXX_Size ¶
func (m *GetProduceSolutionResultsResponse) XXX_Size() int
func (*GetProduceSolutionResultsResponse) XXX_Unmarshal ¶
func (m *GetProduceSolutionResultsResponse) XXX_Unmarshal(b []byte) error
type GetScoreSolutionResultsRequest ¶
type GetScoreSolutionResultsRequest struct { RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Get all score results computed until now and start receiving any new score results computed as well.
func (*GetScoreSolutionResultsRequest) Descriptor ¶
func (*GetScoreSolutionResultsRequest) Descriptor() ([]byte, []int)
func (*GetScoreSolutionResultsRequest) GetRequestId ¶
func (m *GetScoreSolutionResultsRequest) GetRequestId() string
func (*GetScoreSolutionResultsRequest) ProtoMessage ¶
func (*GetScoreSolutionResultsRequest) ProtoMessage()
func (*GetScoreSolutionResultsRequest) Reset ¶
func (m *GetScoreSolutionResultsRequest) Reset()
func (*GetScoreSolutionResultsRequest) String ¶
func (m *GetScoreSolutionResultsRequest) String() string
func (*GetScoreSolutionResultsRequest) XXX_DiscardUnknown ¶
func (m *GetScoreSolutionResultsRequest) XXX_DiscardUnknown()
func (*GetScoreSolutionResultsRequest) XXX_Marshal ¶
func (m *GetScoreSolutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetScoreSolutionResultsRequest) XXX_Merge ¶
func (m *GetScoreSolutionResultsRequest) XXX_Merge(src proto.Message)
func (*GetScoreSolutionResultsRequest) XXX_Size ¶
func (m *GetScoreSolutionResultsRequest) XXX_Size() int
func (*GetScoreSolutionResultsRequest) XXX_Unmarshal ¶
func (m *GetScoreSolutionResultsRequest) XXX_Unmarshal(b []byte) error
type GetScoreSolutionResultsResponse ¶
type GetScoreSolutionResultsResponse struct { // Overall process progress. Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"` // List of score results. List can be incomplete while the process is in progress. Scores []*Score `protobuf:"bytes,2,rep,name=scores,proto3" json:"scores,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetScoreSolutionResultsResponse) Descriptor ¶
func (*GetScoreSolutionResultsResponse) Descriptor() ([]byte, []int)
func (*GetScoreSolutionResultsResponse) GetProgress ¶
func (m *GetScoreSolutionResultsResponse) GetProgress() *Progress
func (*GetScoreSolutionResultsResponse) GetScores ¶
func (m *GetScoreSolutionResultsResponse) GetScores() []*Score
func (*GetScoreSolutionResultsResponse) ProtoMessage ¶
func (*GetScoreSolutionResultsResponse) ProtoMessage()
func (*GetScoreSolutionResultsResponse) Reset ¶
func (m *GetScoreSolutionResultsResponse) Reset()
func (*GetScoreSolutionResultsResponse) String ¶
func (m *GetScoreSolutionResultsResponse) String() string
func (*GetScoreSolutionResultsResponse) XXX_DiscardUnknown ¶
func (m *GetScoreSolutionResultsResponse) XXX_DiscardUnknown()
func (*GetScoreSolutionResultsResponse) XXX_Marshal ¶
func (m *GetScoreSolutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetScoreSolutionResultsResponse) XXX_Merge ¶
func (m *GetScoreSolutionResultsResponse) XXX_Merge(src proto.Message)
func (*GetScoreSolutionResultsResponse) XXX_Size ¶
func (m *GetScoreSolutionResultsResponse) XXX_Size() int
func (*GetScoreSolutionResultsResponse) XXX_Unmarshal ¶
func (m *GetScoreSolutionResultsResponse) XXX_Unmarshal(b []byte) error
type GetSearchSolutionsResultsRequest ¶
type GetSearchSolutionsResultsRequest struct { SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Get all solutions presently identified by the search and start receiving any further solutions also found as well.
func (*GetSearchSolutionsResultsRequest) Descriptor ¶
func (*GetSearchSolutionsResultsRequest) Descriptor() ([]byte, []int)
func (*GetSearchSolutionsResultsRequest) GetSearchId ¶
func (m *GetSearchSolutionsResultsRequest) GetSearchId() string
func (*GetSearchSolutionsResultsRequest) ProtoMessage ¶
func (*GetSearchSolutionsResultsRequest) ProtoMessage()
func (*GetSearchSolutionsResultsRequest) Reset ¶
func (m *GetSearchSolutionsResultsRequest) Reset()
func (*GetSearchSolutionsResultsRequest) String ¶
func (m *GetSearchSolutionsResultsRequest) String() string
func (*GetSearchSolutionsResultsRequest) XXX_DiscardUnknown ¶
func (m *GetSearchSolutionsResultsRequest) XXX_DiscardUnknown()
func (*GetSearchSolutionsResultsRequest) XXX_Marshal ¶
func (m *GetSearchSolutionsResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetSearchSolutionsResultsRequest) XXX_Merge ¶
func (m *GetSearchSolutionsResultsRequest) XXX_Merge(src proto.Message)
func (*GetSearchSolutionsResultsRequest) XXX_Size ¶
func (m *GetSearchSolutionsResultsRequest) XXX_Size() int
func (*GetSearchSolutionsResultsRequest) XXX_Unmarshal ¶
func (m *GetSearchSolutionsResultsRequest) XXX_Unmarshal(b []byte) error
type GetSearchSolutionsResultsResponse ¶
type GetSearchSolutionsResultsResponse struct { // Overall process progress, not progress per solution. While solutions are being found and // returned, or scores computed and updated, progress state should be kept at "RUNNING". Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"` // A measure of progress during search. It can be any number of internal steps or // actions a TA2 is doing during search. It can be even number of how many candidate // solutions were already examined. It does not even have to be an integer. // How regularly a change to this number is reported to TA3 is left to TA2's discretion, // but a rule of thumb is at least once a minute if the number changes. DoneTicks float64 `protobuf:"fixed64,2,opt,name=done_ticks,json=doneTicks,proto3" json:"done_ticks,omitempty"` // If TA2 knows how many internal steps or actions are there, it can set this field. // This can also be updated through time if more (or even less) internal steps or // actions are determined to be necessary. If this value is non-zero, then it should // always hold that "done_ticks" <= "all_ticks". AllTicks float64 `protobuf:"fixed64,3,opt,name=all_ticks,json=allTicks,proto3" json:"all_ticks,omitempty"` SolutionId string `protobuf:"bytes,4,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"` // Internal score for this solution between 0.0 and 1.0 where 1.0 is the highest score. // There is no other meaning to this score and it does not necessary depend on scores // listed in the problem description. Optional. // Because this field is optional, if omitted the default value will be 0. But 0 is a // valid value for this field. Because of that you should never omit the field. // If you do not have internal score to provide, use NaN for the value of this field // to signal that. When solution cannot be scored (i.e., the fully specified pipeline // used as a template is not a standard pipeline) internal score does not have to be // provided. InternalScore float64 `protobuf:"fixed64,5,opt,name=internal_score,json=internalScore,proto3" json:"internal_score,omitempty"` // TA2 might be able to provide more meaningful scores as well, depending on its // approach to solution search. Moreover, even the same TA2 might not use the same scoring // approach for all of its solutions. Optional. When solution cannot be scored (i.e., the // fully specified pipeline used as a template is not a standard pipeline) score does // not have to be provided. Scores []*SolutionSearchScore `protobuf:"bytes,6,rep,name=scores,proto3" json:"scores,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetSearchSolutionsResultsResponse) Descriptor ¶
func (*GetSearchSolutionsResultsResponse) Descriptor() ([]byte, []int)
func (*GetSearchSolutionsResultsResponse) GetAllTicks ¶
func (m *GetSearchSolutionsResultsResponse) GetAllTicks() float64
func (*GetSearchSolutionsResultsResponse) GetDoneTicks ¶
func (m *GetSearchSolutionsResultsResponse) GetDoneTicks() float64
func (*GetSearchSolutionsResultsResponse) GetInternalScore ¶
func (m *GetSearchSolutionsResultsResponse) GetInternalScore() float64
func (*GetSearchSolutionsResultsResponse) GetProgress ¶
func (m *GetSearchSolutionsResultsResponse) GetProgress() *Progress
func (*GetSearchSolutionsResultsResponse) GetScores ¶
func (m *GetSearchSolutionsResultsResponse) GetScores() []*SolutionSearchScore
func (*GetSearchSolutionsResultsResponse) GetSolutionId ¶
func (m *GetSearchSolutionsResultsResponse) GetSolutionId() string
func (*GetSearchSolutionsResultsResponse) ProtoMessage ¶
func (*GetSearchSolutionsResultsResponse) ProtoMessage()
func (*GetSearchSolutionsResultsResponse) Reset ¶
func (m *GetSearchSolutionsResultsResponse) Reset()
func (*GetSearchSolutionsResultsResponse) String ¶
func (m *GetSearchSolutionsResultsResponse) String() string
func (*GetSearchSolutionsResultsResponse) XXX_DiscardUnknown ¶
func (m *GetSearchSolutionsResultsResponse) XXX_DiscardUnknown()
func (*GetSearchSolutionsResultsResponse) XXX_Marshal ¶
func (m *GetSearchSolutionsResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetSearchSolutionsResultsResponse) XXX_Merge ¶
func (m *GetSearchSolutionsResultsResponse) XXX_Merge(src proto.Message)
func (*GetSearchSolutionsResultsResponse) XXX_Size ¶
func (m *GetSearchSolutionsResultsResponse) XXX_Size() int
func (*GetSearchSolutionsResultsResponse) XXX_Unmarshal ¶
func (m *GetSearchSolutionsResultsResponse) XXX_Unmarshal(b []byte) error
type HelloRequest ¶
type HelloRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Identify a TA2 and get supported features. This call is also suitable for a ping/pong call to check that the gRPC connection to the TA2 is ready.
func (*HelloRequest) Descriptor ¶
func (*HelloRequest) Descriptor() ([]byte, []int)
func (*HelloRequest) ProtoMessage ¶
func (*HelloRequest) ProtoMessage()
func (*HelloRequest) Reset ¶
func (m *HelloRequest) Reset()
func (*HelloRequest) String ¶
func (m *HelloRequest) String() string
func (*HelloRequest) XXX_DiscardUnknown ¶
func (m *HelloRequest) XXX_DiscardUnknown()
func (*HelloRequest) XXX_Marshal ¶
func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HelloRequest) XXX_Merge ¶
func (m *HelloRequest) XXX_Merge(src proto.Message)
func (*HelloRequest) XXX_Size ¶
func (m *HelloRequest) XXX_Size() int
func (*HelloRequest) XXX_Unmarshal ¶
func (m *HelloRequest) XXX_Unmarshal(b []byte) error
type HelloResponse ¶
type HelloResponse struct { // Some string identifying the name and version of the TA2 system. UserAgent string `protobuf:"bytes,1,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` // Shall be set to "protocol_version" above. Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // List of value types that a TA3 system can use to communicate values to a TA2 system. // The order is important as a TA3 system should try value types in order until one works // out, or an error will be returned instead of the value. AllowedValueTypes []ValueType `` /* 137-byte string literal not displayed */ // List of API extensions that a TA2 supports. SupportedExtensions []string `protobuf:"bytes,4,rep,name=supported_extensions,json=supportedExtensions,proto3" json:"supported_extensions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HelloResponse) Descriptor ¶
func (*HelloResponse) Descriptor() ([]byte, []int)
func (*HelloResponse) GetAllowedValueTypes ¶
func (m *HelloResponse) GetAllowedValueTypes() []ValueType
func (*HelloResponse) GetSupportedExtensions ¶
func (m *HelloResponse) GetSupportedExtensions() []string
func (*HelloResponse) GetUserAgent ¶
func (m *HelloResponse) GetUserAgent() string
func (*HelloResponse) GetVersion ¶
func (m *HelloResponse) GetVersion() string
func (*HelloResponse) ProtoMessage ¶
func (*HelloResponse) ProtoMessage()
func (*HelloResponse) Reset ¶
func (m *HelloResponse) Reset()
func (*HelloResponse) String ¶
func (m *HelloResponse) String() string
func (*HelloResponse) XXX_DiscardUnknown ¶
func (m *HelloResponse) XXX_DiscardUnknown()
func (*HelloResponse) XXX_Marshal ¶
func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HelloResponse) XXX_Merge ¶
func (m *HelloResponse) XXX_Merge(src proto.Message)
func (*HelloResponse) XXX_Size ¶
func (m *HelloResponse) XXX_Size() int
func (*HelloResponse) XXX_Unmarshal ¶
func (m *HelloResponse) XXX_Unmarshal(b []byte) error
type ListPrimitivesRequest ¶
type ListPrimitivesRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
List all primitives known to TA2, their IDs, versions, names, and digests. Using this information a TA3 should know which primitives may be put into a pipeline template. To narrow down potential primitives to use a TA3 can also ask a TA2 to do a solution search and then observe which primitives the TA2 is using. If more metadata about primitives is needed, then a TA3 can use the results of this call to map primitives to metadata (from Python code or primitive annotations) on its own.
func (*ListPrimitivesRequest) Descriptor ¶
func (*ListPrimitivesRequest) Descriptor() ([]byte, []int)
func (*ListPrimitivesRequest) ProtoMessage ¶
func (*ListPrimitivesRequest) ProtoMessage()
func (*ListPrimitivesRequest) Reset ¶
func (m *ListPrimitivesRequest) Reset()
func (*ListPrimitivesRequest) String ¶
func (m *ListPrimitivesRequest) String() string
func (*ListPrimitivesRequest) XXX_DiscardUnknown ¶
func (m *ListPrimitivesRequest) XXX_DiscardUnknown()
func (*ListPrimitivesRequest) XXX_Marshal ¶
func (m *ListPrimitivesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListPrimitivesRequest) XXX_Merge ¶
func (m *ListPrimitivesRequest) XXX_Merge(src proto.Message)
func (*ListPrimitivesRequest) XXX_Size ¶
func (m *ListPrimitivesRequest) XXX_Size() int
func (*ListPrimitivesRequest) XXX_Unmarshal ¶
func (m *ListPrimitivesRequest) XXX_Unmarshal(b []byte) error
type ListPrimitivesResponse ¶
type ListPrimitivesResponse struct { Primitives []*Primitive `protobuf:"bytes,1,rep,name=primitives,proto3" json:"primitives,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListPrimitivesResponse) Descriptor ¶
func (*ListPrimitivesResponse) Descriptor() ([]byte, []int)
func (*ListPrimitivesResponse) GetPrimitives ¶
func (m *ListPrimitivesResponse) GetPrimitives() []*Primitive
func (*ListPrimitivesResponse) ProtoMessage ¶
func (*ListPrimitivesResponse) ProtoMessage()
func (*ListPrimitivesResponse) Reset ¶
func (m *ListPrimitivesResponse) Reset()
func (*ListPrimitivesResponse) String ¶
func (m *ListPrimitivesResponse) String() string
func (*ListPrimitivesResponse) XXX_DiscardUnknown ¶
func (m *ListPrimitivesResponse) XXX_DiscardUnknown()
func (*ListPrimitivesResponse) XXX_Marshal ¶
func (m *ListPrimitivesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListPrimitivesResponse) XXX_Merge ¶
func (m *ListPrimitivesResponse) XXX_Merge(src proto.Message)
func (*ListPrimitivesResponse) XXX_Size ¶
func (m *ListPrimitivesResponse) XXX_Size() int
func (*ListPrimitivesResponse) XXX_Unmarshal ¶
func (m *ListPrimitivesResponse) XXX_Unmarshal(b []byte) error
type LoadFittedSolutionRequest ¶
type LoadFittedSolutionRequest struct { // An URI pointing to a directory containing a fitted solution. FittedSolutionUri string `protobuf:"bytes,1,opt,name=fitted_solution_uri,json=fittedSolutionUri,proto3" json:"fitted_solution_uri,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Load a fitted solution that was saved before.
func (*LoadFittedSolutionRequest) Descriptor ¶
func (*LoadFittedSolutionRequest) Descriptor() ([]byte, []int)
func (*LoadFittedSolutionRequest) GetFittedSolutionUri ¶
func (m *LoadFittedSolutionRequest) GetFittedSolutionUri() string
func (*LoadFittedSolutionRequest) ProtoMessage ¶
func (*LoadFittedSolutionRequest) ProtoMessage()
func (*LoadFittedSolutionRequest) Reset ¶
func (m *LoadFittedSolutionRequest) Reset()
func (*LoadFittedSolutionRequest) String ¶
func (m *LoadFittedSolutionRequest) String() string
func (*LoadFittedSolutionRequest) XXX_DiscardUnknown ¶
func (m *LoadFittedSolutionRequest) XXX_DiscardUnknown()
func (*LoadFittedSolutionRequest) XXX_Marshal ¶
func (m *LoadFittedSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadFittedSolutionRequest) XXX_Merge ¶
func (m *LoadFittedSolutionRequest) XXX_Merge(src proto.Message)
func (*LoadFittedSolutionRequest) XXX_Size ¶
func (m *LoadFittedSolutionRequest) XXX_Size() int
func (*LoadFittedSolutionRequest) XXX_Unmarshal ¶
func (m *LoadFittedSolutionRequest) XXX_Unmarshal(b []byte) error
type LoadFittedSolutionResponse ¶
type LoadFittedSolutionResponse struct { // Fitted solution id loaded. FittedSolutionId string `protobuf:"bytes,1,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoadFittedSolutionResponse) Descriptor ¶
func (*LoadFittedSolutionResponse) Descriptor() ([]byte, []int)
func (*LoadFittedSolutionResponse) GetFittedSolutionId ¶
func (m *LoadFittedSolutionResponse) GetFittedSolutionId() string
func (*LoadFittedSolutionResponse) ProtoMessage ¶
func (*LoadFittedSolutionResponse) ProtoMessage()
func (*LoadFittedSolutionResponse) Reset ¶
func (m *LoadFittedSolutionResponse) Reset()
func (*LoadFittedSolutionResponse) String ¶
func (m *LoadFittedSolutionResponse) String() string
func (*LoadFittedSolutionResponse) XXX_DiscardUnknown ¶
func (m *LoadFittedSolutionResponse) XXX_DiscardUnknown()
func (*LoadFittedSolutionResponse) XXX_Marshal ¶
func (m *LoadFittedSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadFittedSolutionResponse) XXX_Merge ¶
func (m *LoadFittedSolutionResponse) XXX_Merge(src proto.Message)
func (*LoadFittedSolutionResponse) XXX_Size ¶
func (m *LoadFittedSolutionResponse) XXX_Size() int
func (*LoadFittedSolutionResponse) XXX_Unmarshal ¶
func (m *LoadFittedSolutionResponse) XXX_Unmarshal(b []byte) error
type LoadSolutionRequest ¶
type LoadSolutionRequest struct { // An URI pointing to a directory containing a solution saved. SolutionUri string `protobuf:"bytes,1,opt,name=solution_uri,json=solutionUri,proto3" json:"solution_uri,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Load a solution that was saved before.
func (*LoadSolutionRequest) Descriptor ¶
func (*LoadSolutionRequest) Descriptor() ([]byte, []int)
func (*LoadSolutionRequest) GetSolutionUri ¶
func (m *LoadSolutionRequest) GetSolutionUri() string
func (*LoadSolutionRequest) ProtoMessage ¶
func (*LoadSolutionRequest) ProtoMessage()
func (*LoadSolutionRequest) Reset ¶
func (m *LoadSolutionRequest) Reset()
func (*LoadSolutionRequest) String ¶
func (m *LoadSolutionRequest) String() string
func (*LoadSolutionRequest) XXX_DiscardUnknown ¶
func (m *LoadSolutionRequest) XXX_DiscardUnknown()
func (*LoadSolutionRequest) XXX_Marshal ¶
func (m *LoadSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadSolutionRequest) XXX_Merge ¶
func (m *LoadSolutionRequest) XXX_Merge(src proto.Message)
func (*LoadSolutionRequest) XXX_Size ¶
func (m *LoadSolutionRequest) XXX_Size() int
func (*LoadSolutionRequest) XXX_Unmarshal ¶
func (m *LoadSolutionRequest) XXX_Unmarshal(b []byte) error
type LoadSolutionResponse ¶
type LoadSolutionResponse struct { // Id of solution which was loaded. SolutionId string `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoadSolutionResponse) Descriptor ¶
func (*LoadSolutionResponse) Descriptor() ([]byte, []int)
func (*LoadSolutionResponse) GetSolutionId ¶
func (m *LoadSolutionResponse) GetSolutionId() string
func (*LoadSolutionResponse) ProtoMessage ¶
func (*LoadSolutionResponse) ProtoMessage()
func (*LoadSolutionResponse) Reset ¶
func (m *LoadSolutionResponse) Reset()
func (*LoadSolutionResponse) String ¶
func (m *LoadSolutionResponse) String() string
func (*LoadSolutionResponse) XXX_DiscardUnknown ¶
func (m *LoadSolutionResponse) XXX_DiscardUnknown()
func (*LoadSolutionResponse) XXX_Marshal ¶
func (m *LoadSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadSolutionResponse) XXX_Merge ¶
func (m *LoadSolutionResponse) XXX_Merge(src proto.Message)
func (*LoadSolutionResponse) XXX_Size ¶
func (m *LoadSolutionResponse) XXX_Size() int
func (*LoadSolutionResponse) XXX_Unmarshal ¶
func (m *LoadSolutionResponse) XXX_Unmarshal(b []byte) error
type NullValue ¶
type NullValue int32
const (
NullValue_NULL_VALUE NullValue = 0
)
func (NullValue) EnumDescriptor ¶
type PerformanceMetric ¶
type PerformanceMetric int32
The evaluation metric for any potential solution.
const ( // Default value. Not to be used. PerformanceMetric_METRIC_UNDEFINED PerformanceMetric = 0 // The following are the only evaluation methods required // to be supported for the ScoreSolution call. PerformanceMetric_ACCURACY PerformanceMetric = 1 PerformanceMetric_PRECISION PerformanceMetric = 2 PerformanceMetric_RECALL PerformanceMetric = 3 PerformanceMetric_F1 PerformanceMetric = 4 PerformanceMetric_F1_MICRO PerformanceMetric = 5 PerformanceMetric_F1_MACRO PerformanceMetric = 6 PerformanceMetric_ROC_AUC PerformanceMetric = 7 PerformanceMetric_ROC_AUC_MICRO PerformanceMetric = 8 PerformanceMetric_ROC_AUC_MACRO PerformanceMetric = 9 PerformanceMetric_MEAN_SQUARED_ERROR PerformanceMetric = 10 PerformanceMetric_ROOT_MEAN_SQUARED_ERROR PerformanceMetric = 11 PerformanceMetric_MEAN_ABSOLUTE_ERROR PerformanceMetric = 12 PerformanceMetric_R_SQUARED PerformanceMetric = 13 PerformanceMetric_NORMALIZED_MUTUAL_INFORMATION PerformanceMetric = 14 PerformanceMetric_JACCARD_SIMILARITY_SCORE PerformanceMetric = 15 PerformanceMetric_PRECISION_AT_TOP_K PerformanceMetric = 17 PerformanceMetric_OBJECT_DETECTION_AVERAGE_PRECISION PerformanceMetric = 18 PerformanceMetric_HAMMING_LOSS PerformanceMetric = 19 // This metric can be used to ask TA2 to rank a solution as part of // all found solutions of a given "SearchSolutions" call. Rank is a // floating-point number. Lower numbers represent better solutions. // Presently evaluation requirements are that ranks should be non-negative // and that each ranked pipeline have a different rank (for all // solutions of a given SearchSolutions call). Only possible with // "RANKING" evaluation method. PerformanceMetric_RANK PerformanceMetric = 99 // The rest are defined to allow expressing internal evaluation // scores used by TA2 during pipeline search. If any you are using // is missing, feel free to request it to be added. // Average loss of an unspecified loss function. PerformanceMetric_LOSS PerformanceMetric = 100 )
func (PerformanceMetric) EnumDescriptor ¶
func (PerformanceMetric) EnumDescriptor() ([]byte, []int)
func (PerformanceMetric) String ¶
func (x PerformanceMetric) String() string
type PipelineContext ¶
type PipelineContext int32
TODO: Deprecated. Remove.
const ( PipelineContext_PIPELINE_CONTEXT_UNKNOWN PipelineContext = 0 PipelineContext_PRETRAINING PipelineContext = 1 PipelineContext_TESTING PipelineContext = 2 PipelineContext_EVALUATION PipelineContext = 3 PipelineContext_PRODUCTION PipelineContext = 4 )
func (PipelineContext) EnumDescriptor ¶
func (PipelineContext) EnumDescriptor() ([]byte, []int)
func (PipelineContext) String ¶
func (x PipelineContext) String() string
type PipelineDescription ¶
type PipelineDescription struct { // TA2: UUID of the pipeline. Templates do not have IDs. But TA3 might provide it for a fully // specified pipeline. It does not necessary have to match "solution_id" from // "ListSolutionsResponse" and other related messages. Those IDs are about whole solutions // (pipeline, potentially fitted, with set hyper-parameters). This here ID is about this // particular ID description. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // "schema" field is not needed because it is fixed by the TA2-TA3 protocol version. // System which generated a pipeline or a template. Optional. Source *PipelineSource `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // TA2: Timestamp when created. Templates do not have this timestamp. TA3 might provide it for // a fully specified pipeline. Created *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"` // TODO: Deprecated. Remove. Context PipelineContext `protobuf:"varint,4,opt,name=context,proto3,enum=PipelineContext" json:"context,omitempty"` // Deprecated: Do not use. // Human friendly name of the pipeline. For templates it can be a hint to // TA2 how to name found pipelines. Optional. Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"` // Human friendly description of the pipeline. Optional. Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"` // List of users associated with the creation of the template and consequently of the pipeline. // TA2 can store this information into metalearning database. TA2 is not really expected to use // this information during pipeline search. TA2 should not have to understand TA3 users, mapping // between users and pipeline search IDs is something TA3 should handle. Optional. Users []*PipelineDescriptionUser `protobuf:"bytes,7,rep,name=users,proto3" json:"users,omitempty"` // In most cases inputs are datasets. But if TA3 wants to jut run a primitive, it can send a // template with only that primitive in the template, and then pass anything to its inputs during // execution. Here, we are describing possible inputs to the pipeline or template. Order matters. Inputs []*PipelineDescriptionInput `protobuf:"bytes,8,rep,name=inputs,proto3" json:"inputs,omitempty"` // Available outputs of the pipeline or template. Outputs []*PipelineDescriptionOutput `protobuf:"bytes,9,rep,name=outputs,proto3" json:"outputs,omitempty"` // Steps defining the pipeline. Steps []*PipelineDescriptionStep `protobuf:"bytes,10,rep,name=steps,proto3" json:"steps,omitempty"` Digest string `protobuf:"bytes,11,opt,name=digest,proto3" json:"digest,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Pipeline description matches the D3M pipeline description. It serves two purposes: describing found pipelines by TA2 to TA3, and communicating pipeline templates by TA3 to TA2. Because of this some fields are reasonable only in one of those uses. They are marked with "TA2" or "TA3" in the comment, for fields which are primarily to be set only by TA2 or only by TA3, respectively.
func (*PipelineDescription) Descriptor ¶
func (*PipelineDescription) Descriptor() ([]byte, []int)
func (*PipelineDescription) GetContext
deprecated
func (m *PipelineDescription) GetContext() PipelineContext
Deprecated: Do not use.
func (*PipelineDescription) GetCreated ¶
func (m *PipelineDescription) GetCreated() *timestamp.Timestamp
func (*PipelineDescription) GetDescription ¶
func (m *PipelineDescription) GetDescription() string
func (*PipelineDescription) GetDigest ¶
func (m *PipelineDescription) GetDigest() string
func (*PipelineDescription) GetId ¶
func (m *PipelineDescription) GetId() string
func (*PipelineDescription) GetInputs ¶
func (m *PipelineDescription) GetInputs() []*PipelineDescriptionInput
func (*PipelineDescription) GetName ¶
func (m *PipelineDescription) GetName() string
func (*PipelineDescription) GetOutputs ¶
func (m *PipelineDescription) GetOutputs() []*PipelineDescriptionOutput
func (*PipelineDescription) GetSource ¶
func (m *PipelineDescription) GetSource() *PipelineSource
func (*PipelineDescription) GetSteps ¶
func (m *PipelineDescription) GetSteps() []*PipelineDescriptionStep
func (*PipelineDescription) GetUsers ¶
func (m *PipelineDescription) GetUsers() []*PipelineDescriptionUser
func (*PipelineDescription) ProtoMessage ¶
func (*PipelineDescription) ProtoMessage()
func (*PipelineDescription) Reset ¶
func (m *PipelineDescription) Reset()
func (*PipelineDescription) String ¶
func (m *PipelineDescription) String() string
func (*PipelineDescription) XXX_DiscardUnknown ¶
func (m *PipelineDescription) XXX_DiscardUnknown()
func (*PipelineDescription) XXX_Marshal ¶
func (m *PipelineDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineDescription) XXX_Merge ¶
func (m *PipelineDescription) XXX_Merge(src proto.Message)
func (*PipelineDescription) XXX_Size ¶
func (m *PipelineDescription) XXX_Size() int
func (*PipelineDescription) XXX_Unmarshal ¶
func (m *PipelineDescription) XXX_Unmarshal(b []byte) error
type PipelineDescriptionInput ¶
type PipelineDescriptionInput struct { // Human friendly name of the input. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Possible input to the pipeline or template.
func (*PipelineDescriptionInput) Descriptor ¶
func (*PipelineDescriptionInput) Descriptor() ([]byte, []int)
func (*PipelineDescriptionInput) GetName ¶
func (m *PipelineDescriptionInput) GetName() string
func (*PipelineDescriptionInput) ProtoMessage ¶
func (*PipelineDescriptionInput) ProtoMessage()
func (*PipelineDescriptionInput) Reset ¶
func (m *PipelineDescriptionInput) Reset()
func (*PipelineDescriptionInput) String ¶
func (m *PipelineDescriptionInput) String() string
func (*PipelineDescriptionInput) XXX_DiscardUnknown ¶
func (m *PipelineDescriptionInput) XXX_DiscardUnknown()
func (*PipelineDescriptionInput) XXX_Marshal ¶
func (m *PipelineDescriptionInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineDescriptionInput) XXX_Merge ¶
func (m *PipelineDescriptionInput) XXX_Merge(src proto.Message)
func (*PipelineDescriptionInput) XXX_Size ¶
func (m *PipelineDescriptionInput) XXX_Size() int
func (*PipelineDescriptionInput) XXX_Unmarshal ¶
func (m *PipelineDescriptionInput) XXX_Unmarshal(b []byte) error
type PipelineDescriptionOutput ¶
type PipelineDescriptionOutput struct { // Human friendly name of the output. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Data reference, probably of an output of a step. Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Available output of the pipeline or template.
func (*PipelineDescriptionOutput) Descriptor ¶
func (*PipelineDescriptionOutput) Descriptor() ([]byte, []int)
func (*PipelineDescriptionOutput) GetData ¶
func (m *PipelineDescriptionOutput) GetData() string
func (*PipelineDescriptionOutput) GetName ¶
func (m *PipelineDescriptionOutput) GetName() string
func (*PipelineDescriptionOutput) ProtoMessage ¶
func (*PipelineDescriptionOutput) ProtoMessage()
func (*PipelineDescriptionOutput) Reset ¶
func (m *PipelineDescriptionOutput) Reset()
func (*PipelineDescriptionOutput) String ¶
func (m *PipelineDescriptionOutput) String() string
func (*PipelineDescriptionOutput) XXX_DiscardUnknown ¶
func (m *PipelineDescriptionOutput) XXX_DiscardUnknown()
func (*PipelineDescriptionOutput) XXX_Marshal ¶
func (m *PipelineDescriptionOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineDescriptionOutput) XXX_Merge ¶
func (m *PipelineDescriptionOutput) XXX_Merge(src proto.Message)
func (*PipelineDescriptionOutput) XXX_Size ¶
func (m *PipelineDescriptionOutput) XXX_Size() int
func (*PipelineDescriptionOutput) XXX_Unmarshal ¶
func (m *PipelineDescriptionOutput) XXX_Unmarshal(b []byte) error
type PipelineDescriptionStep ¶
type PipelineDescriptionStep struct { // Types that are valid to be assigned to Step: // *PipelineDescriptionStep_Primitive // *PipelineDescriptionStep_Pipeline // *PipelineDescriptionStep_Placeholder Step isPipelineDescriptionStep_Step `protobuf_oneof:"step"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PipelineDescriptionStep) Descriptor ¶
func (*PipelineDescriptionStep) Descriptor() ([]byte, []int)
func (*PipelineDescriptionStep) GetPipeline ¶
func (m *PipelineDescriptionStep) GetPipeline() *SubpipelinePipelineDescriptionStep
func (*PipelineDescriptionStep) GetPlaceholder ¶
func (m *PipelineDescriptionStep) GetPlaceholder() *PlaceholderPipelineDescriptionStep
func (*PipelineDescriptionStep) GetPrimitive ¶
func (m *PipelineDescriptionStep) GetPrimitive() *PrimitivePipelineDescriptionStep
func (*PipelineDescriptionStep) GetStep ¶
func (m *PipelineDescriptionStep) GetStep() isPipelineDescriptionStep_Step
func (*PipelineDescriptionStep) ProtoMessage ¶
func (*PipelineDescriptionStep) ProtoMessage()
func (*PipelineDescriptionStep) Reset ¶
func (m *PipelineDescriptionStep) Reset()
func (*PipelineDescriptionStep) String ¶
func (m *PipelineDescriptionStep) String() string
func (*PipelineDescriptionStep) XXX_DiscardUnknown ¶
func (m *PipelineDescriptionStep) XXX_DiscardUnknown()
func (*PipelineDescriptionStep) XXX_Marshal ¶
func (m *PipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineDescriptionStep) XXX_Merge ¶
func (m *PipelineDescriptionStep) XXX_Merge(src proto.Message)
func (*PipelineDescriptionStep) XXX_OneofFuncs ¶
func (*PipelineDescriptionStep) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*PipelineDescriptionStep) XXX_Size ¶
func (m *PipelineDescriptionStep) XXX_Size() int
func (*PipelineDescriptionStep) XXX_Unmarshal ¶
func (m *PipelineDescriptionStep) XXX_Unmarshal(b []byte) error
type PipelineDescriptionStep_Pipeline ¶
type PipelineDescriptionStep_Pipeline struct {
Pipeline *SubpipelinePipelineDescriptionStep `protobuf:"bytes,2,opt,name=pipeline,proto3,oneof"`
}
type PipelineDescriptionStep_Placeholder ¶
type PipelineDescriptionStep_Placeholder struct {
Placeholder *PlaceholderPipelineDescriptionStep `protobuf:"bytes,3,opt,name=placeholder,proto3,oneof"`
}
type PipelineDescriptionStep_Primitive ¶
type PipelineDescriptionStep_Primitive struct {
Primitive *PrimitivePipelineDescriptionStep `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}
type PipelineDescriptionUser ¶
type PipelineDescriptionUser struct { // Globally unique ID for this user. It can be opaque, but it should identify the same user // across sessions. Consider using UUID variant 5 with namespace set to the name of your system // and name to an ID in your system's database. It does not have to map to any real ID, just // that it is possible to connect multiple pipelines/templates by the same user together, // if necessary. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // A natural language description of what the user did to be on the list, e.g., "Picked // a pipeline from a list of pipelines.". Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // A natural language description by the user of what the user did, // e.g., "I picked a pipeline because it looks short in comparison with others.". Rationale string `protobuf:"bytes,3,opt,name=rationale,proto3" json:"rationale,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
User associated with the creation of the template/pipeline, or selection of a primitive.
func (*PipelineDescriptionUser) Descriptor ¶
func (*PipelineDescriptionUser) Descriptor() ([]byte, []int)
func (*PipelineDescriptionUser) GetId ¶
func (m *PipelineDescriptionUser) GetId() string
func (*PipelineDescriptionUser) GetRationale ¶
func (m *PipelineDescriptionUser) GetRationale() string
func (*PipelineDescriptionUser) GetReason ¶
func (m *PipelineDescriptionUser) GetReason() string
func (*PipelineDescriptionUser) ProtoMessage ¶
func (*PipelineDescriptionUser) ProtoMessage()
func (*PipelineDescriptionUser) Reset ¶
func (m *PipelineDescriptionUser) Reset()
func (*PipelineDescriptionUser) String ¶
func (m *PipelineDescriptionUser) String() string
func (*PipelineDescriptionUser) XXX_DiscardUnknown ¶
func (m *PipelineDescriptionUser) XXX_DiscardUnknown()
func (*PipelineDescriptionUser) XXX_Marshal ¶
func (m *PipelineDescriptionUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineDescriptionUser) XXX_Merge ¶
func (m *PipelineDescriptionUser) XXX_Merge(src proto.Message)
func (*PipelineDescriptionUser) XXX_Size ¶
func (m *PipelineDescriptionUser) XXX_Size() int
func (*PipelineDescriptionUser) XXX_Unmarshal ¶
func (m *PipelineDescriptionUser) XXX_Unmarshal(b []byte) error
type PipelineSource ¶
type PipelineSource struct { // String representing name of the author, team. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // An URI to contact the source. Contact string `protobuf:"bytes,2,opt,name=contact,proto3" json:"contact,omitempty"` // A list of pipelines used to derive the pipeline. Pipelines []*PipelineDescription `protobuf:"bytes,3,rep,name=pipelines,proto3" json:"pipelines,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PipelineSource) Descriptor ¶
func (*PipelineSource) Descriptor() ([]byte, []int)
func (*PipelineSource) GetContact ¶
func (m *PipelineSource) GetContact() string
func (*PipelineSource) GetName ¶
func (m *PipelineSource) GetName() string
func (*PipelineSource) GetPipelines ¶
func (m *PipelineSource) GetPipelines() []*PipelineDescription
func (*PipelineSource) ProtoMessage ¶
func (*PipelineSource) ProtoMessage()
func (*PipelineSource) Reset ¶
func (m *PipelineSource) Reset()
func (*PipelineSource) String ¶
func (m *PipelineSource) String() string
func (*PipelineSource) XXX_DiscardUnknown ¶
func (m *PipelineSource) XXX_DiscardUnknown()
func (*PipelineSource) XXX_Marshal ¶
func (m *PipelineSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PipelineSource) XXX_Merge ¶
func (m *PipelineSource) XXX_Merge(src proto.Message)
func (*PipelineSource) XXX_Size ¶
func (m *PipelineSource) XXX_Size() int
func (*PipelineSource) XXX_Unmarshal ¶
func (m *PipelineSource) XXX_Unmarshal(b []byte) error
type PlaceholderPipelineDescriptionStep ¶
type PlaceholderPipelineDescriptionStep struct { // List of inputs which can be used as inputs to resulting sub-pipeline. Resulting // sub-pipeline does not have to use all the inputs, but it cannot use any other inputs. Inputs []*StepInput `protobuf:"bytes,1,rep,name=inputs,proto3" json:"inputs,omitempty"` // A list of outputs of the resulting sub-pipeline. Outputs []*StepOutput `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Used to represent a pipeline template which can be used to generate full pipelines. A placeholder is replaced with a pipeline step to form a pipeline. See README.md for restrictions on the number of them, their position, allowed inputs and outputs, etc.
func (*PlaceholderPipelineDescriptionStep) Descriptor ¶
func (*PlaceholderPipelineDescriptionStep) Descriptor() ([]byte, []int)
func (*PlaceholderPipelineDescriptionStep) GetInputs ¶
func (m *PlaceholderPipelineDescriptionStep) GetInputs() []*StepInput
func (*PlaceholderPipelineDescriptionStep) GetOutputs ¶
func (m *PlaceholderPipelineDescriptionStep) GetOutputs() []*StepOutput
func (*PlaceholderPipelineDescriptionStep) ProtoMessage ¶
func (*PlaceholderPipelineDescriptionStep) ProtoMessage()
func (*PlaceholderPipelineDescriptionStep) Reset ¶
func (m *PlaceholderPipelineDescriptionStep) Reset()
func (*PlaceholderPipelineDescriptionStep) String ¶
func (m *PlaceholderPipelineDescriptionStep) String() string
func (*PlaceholderPipelineDescriptionStep) XXX_DiscardUnknown ¶
func (m *PlaceholderPipelineDescriptionStep) XXX_DiscardUnknown()
func (*PlaceholderPipelineDescriptionStep) XXX_Marshal ¶
func (m *PlaceholderPipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PlaceholderPipelineDescriptionStep) XXX_Merge ¶
func (m *PlaceholderPipelineDescriptionStep) XXX_Merge(src proto.Message)
func (*PlaceholderPipelineDescriptionStep) XXX_Size ¶
func (m *PlaceholderPipelineDescriptionStep) XXX_Size() int
func (*PlaceholderPipelineDescriptionStep) XXX_Unmarshal ¶
func (m *PlaceholderPipelineDescriptionStep) XXX_Unmarshal(b []byte) error
type Primitive ¶
type Primitive struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` PythonPath string `protobuf:"bytes,3,opt,name=python_path,json=pythonPath,proto3" json:"python_path,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // Digest is optional, because some locally registered primitives might not have it. // But for all primitives published it is available and it should be provided here as well. Digest string `protobuf:"bytes,5,opt,name=digest,proto3" json:"digest,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Description of the primitive.
func (*Primitive) Descriptor ¶
func (*Primitive) GetPythonPath ¶
func (*Primitive) GetVersion ¶
func (*Primitive) ProtoMessage ¶
func (*Primitive) ProtoMessage()
func (*Primitive) XXX_DiscardUnknown ¶
func (m *Primitive) XXX_DiscardUnknown()
func (*Primitive) XXX_Marshal ¶
func (*Primitive) XXX_Unmarshal ¶
type PrimitiveArgument ¶
type PrimitiveArgument struct { // 0-based index identifying a step of which primitive is used as a value. Data int32 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PrimitiveArgument) Descriptor ¶
func (*PrimitiveArgument) Descriptor() ([]byte, []int)
func (*PrimitiveArgument) GetData ¶
func (m *PrimitiveArgument) GetData() int32
func (*PrimitiveArgument) ProtoMessage ¶
func (*PrimitiveArgument) ProtoMessage()
func (*PrimitiveArgument) Reset ¶
func (m *PrimitiveArgument) Reset()
func (*PrimitiveArgument) String ¶
func (m *PrimitiveArgument) String() string
func (*PrimitiveArgument) XXX_DiscardUnknown ¶
func (m *PrimitiveArgument) XXX_DiscardUnknown()
func (*PrimitiveArgument) XXX_Marshal ¶
func (m *PrimitiveArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveArgument) XXX_Merge ¶
func (m *PrimitiveArgument) XXX_Merge(src proto.Message)
func (*PrimitiveArgument) XXX_Size ¶
func (m *PrimitiveArgument) XXX_Size() int
func (*PrimitiveArgument) XXX_Unmarshal ¶
func (m *PrimitiveArgument) XXX_Unmarshal(b []byte) error
type PrimitiveArguments ¶
type PrimitiveArguments struct { // 0-based index identifying a step of which primitive is used as a value. Data []int32 `protobuf:"varint,1,rep,packed,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PrimitiveArguments) Descriptor ¶
func (*PrimitiveArguments) Descriptor() ([]byte, []int)
func (*PrimitiveArguments) GetData ¶
func (m *PrimitiveArguments) GetData() []int32
func (*PrimitiveArguments) ProtoMessage ¶
func (*PrimitiveArguments) ProtoMessage()
func (*PrimitiveArguments) Reset ¶
func (m *PrimitiveArguments) Reset()
func (*PrimitiveArguments) String ¶
func (m *PrimitiveArguments) String() string
func (*PrimitiveArguments) XXX_DiscardUnknown ¶
func (m *PrimitiveArguments) XXX_DiscardUnknown()
func (*PrimitiveArguments) XXX_Marshal ¶
func (m *PrimitiveArguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveArguments) XXX_Merge ¶
func (m *PrimitiveArguments) XXX_Merge(src proto.Message)
func (*PrimitiveArguments) XXX_Size ¶
func (m *PrimitiveArguments) XXX_Size() int
func (*PrimitiveArguments) XXX_Unmarshal ¶
func (m *PrimitiveArguments) XXX_Unmarshal(b []byte) error
type PrimitivePipelineDescriptionStep ¶
type PrimitivePipelineDescriptionStep struct { Primitive *Primitive `protobuf:"bytes,1,opt,name=primitive,proto3" json:"primitive,omitempty"` // Arguments to the primitive. Constructor arguments should not be listed here, because they // can be automatically created from other information. All these arguments are listed as kind // "PIPELINE" in primitive's metadata. Arguments map[string]*PrimitiveStepArgument `` /* 159-byte string literal not displayed */ // List of produce methods providing data. One can reference using data reference these outputs // then in arguments (inputs) in other steps or pipeline outputs. Outputs []*StepOutput `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"` // Some hyper-parameters are not really tunable and should be fixed as part of template/pipeline. // This can be done here. Hyper-parameters listed here cannot be tuned or overridden. Author of a // template/pipeline decides which hyper-parameter are which, probably based on their semantic type. // TA3 can specify a list of hyper-parameters to fix, and TA2 can add to the list additional // hyper-parameters in found pipelines. Hyperparams map[string]*PrimitiveStepHyperparameter `` /* 163-byte string literal not displayed */ // List of users associated with selection of this primitive/arguments/hyper-parameters. Optional. Users []*PipelineDescriptionUser `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PrimitivePipelineDescriptionStep) Descriptor ¶
func (*PrimitivePipelineDescriptionStep) Descriptor() ([]byte, []int)
func (*PrimitivePipelineDescriptionStep) GetArguments ¶
func (m *PrimitivePipelineDescriptionStep) GetArguments() map[string]*PrimitiveStepArgument
func (*PrimitivePipelineDescriptionStep) GetHyperparams ¶
func (m *PrimitivePipelineDescriptionStep) GetHyperparams() map[string]*PrimitiveStepHyperparameter
func (*PrimitivePipelineDescriptionStep) GetOutputs ¶
func (m *PrimitivePipelineDescriptionStep) GetOutputs() []*StepOutput
func (*PrimitivePipelineDescriptionStep) GetPrimitive ¶
func (m *PrimitivePipelineDescriptionStep) GetPrimitive() *Primitive
func (*PrimitivePipelineDescriptionStep) GetUsers ¶
func (m *PrimitivePipelineDescriptionStep) GetUsers() []*PipelineDescriptionUser
func (*PrimitivePipelineDescriptionStep) ProtoMessage ¶
func (*PrimitivePipelineDescriptionStep) ProtoMessage()
func (*PrimitivePipelineDescriptionStep) Reset ¶
func (m *PrimitivePipelineDescriptionStep) Reset()
func (*PrimitivePipelineDescriptionStep) String ¶
func (m *PrimitivePipelineDescriptionStep) String() string
func (*PrimitivePipelineDescriptionStep) XXX_DiscardUnknown ¶
func (m *PrimitivePipelineDescriptionStep) XXX_DiscardUnknown()
func (*PrimitivePipelineDescriptionStep) XXX_Marshal ¶
func (m *PrimitivePipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitivePipelineDescriptionStep) XXX_Merge ¶
func (m *PrimitivePipelineDescriptionStep) XXX_Merge(src proto.Message)
func (*PrimitivePipelineDescriptionStep) XXX_Size ¶
func (m *PrimitivePipelineDescriptionStep) XXX_Size() int
func (*PrimitivePipelineDescriptionStep) XXX_Unmarshal ¶
func (m *PrimitivePipelineDescriptionStep) XXX_Unmarshal(b []byte) error
type PrimitiveStepArgument ¶
type PrimitiveStepArgument struct { // Types that are valid to be assigned to Argument: // *PrimitiveStepArgument_Container // *PrimitiveStepArgument_Data // *PrimitiveStepArgument_ContainerList Argument isPrimitiveStepArgument_Argument `protobuf_oneof:"argument"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PrimitiveStepArgument) Descriptor ¶
func (*PrimitiveStepArgument) Descriptor() ([]byte, []int)
func (*PrimitiveStepArgument) GetArgument ¶
func (m *PrimitiveStepArgument) GetArgument() isPrimitiveStepArgument_Argument
func (*PrimitiveStepArgument) GetContainer ¶
func (m *PrimitiveStepArgument) GetContainer() *ContainerArgument
func (*PrimitiveStepArgument) GetContainerList ¶
func (m *PrimitiveStepArgument) GetContainerList() *ContainerArguments
func (*PrimitiveStepArgument) GetData ¶
func (m *PrimitiveStepArgument) GetData() *DataArgument
func (*PrimitiveStepArgument) ProtoMessage ¶
func (*PrimitiveStepArgument) ProtoMessage()
func (*PrimitiveStepArgument) Reset ¶
func (m *PrimitiveStepArgument) Reset()
func (*PrimitiveStepArgument) String ¶
func (m *PrimitiveStepArgument) String() string
func (*PrimitiveStepArgument) XXX_DiscardUnknown ¶
func (m *PrimitiveStepArgument) XXX_DiscardUnknown()
func (*PrimitiveStepArgument) XXX_Marshal ¶
func (m *PrimitiveStepArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveStepArgument) XXX_Merge ¶
func (m *PrimitiveStepArgument) XXX_Merge(src proto.Message)
func (*PrimitiveStepArgument) XXX_OneofFuncs ¶
func (*PrimitiveStepArgument) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*PrimitiveStepArgument) XXX_Size ¶
func (m *PrimitiveStepArgument) XXX_Size() int
func (*PrimitiveStepArgument) XXX_Unmarshal ¶
func (m *PrimitiveStepArgument) XXX_Unmarshal(b []byte) error
type PrimitiveStepArgument_Container ¶
type PrimitiveStepArgument_Container struct {
Container *ContainerArgument `protobuf:"bytes,1,opt,name=container,proto3,oneof"`
}
type PrimitiveStepArgument_ContainerList ¶
type PrimitiveStepArgument_ContainerList struct {
ContainerList *ContainerArguments `protobuf:"bytes,3,opt,name=container_list,json=containerList,proto3,oneof"`
}
type PrimitiveStepArgument_Data ¶
type PrimitiveStepArgument_Data struct {
Data *DataArgument `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}
type PrimitiveStepDescription ¶
type PrimitiveStepDescription struct { // Selected value for free pipeline hyper-parameters. Hyperparams map[string]*Value `` /* 163-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PrimitiveStepDescription) Descriptor ¶
func (*PrimitiveStepDescription) Descriptor() ([]byte, []int)
func (*PrimitiveStepDescription) GetHyperparams ¶
func (m *PrimitiveStepDescription) GetHyperparams() map[string]*Value
func (*PrimitiveStepDescription) ProtoMessage ¶
func (*PrimitiveStepDescription) ProtoMessage()
func (*PrimitiveStepDescription) Reset ¶
func (m *PrimitiveStepDescription) Reset()
func (*PrimitiveStepDescription) String ¶
func (m *PrimitiveStepDescription) String() string
func (*PrimitiveStepDescription) XXX_DiscardUnknown ¶
func (m *PrimitiveStepDescription) XXX_DiscardUnknown()
func (*PrimitiveStepDescription) XXX_Marshal ¶
func (m *PrimitiveStepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveStepDescription) XXX_Merge ¶
func (m *PrimitiveStepDescription) XXX_Merge(src proto.Message)
func (*PrimitiveStepDescription) XXX_Size ¶
func (m *PrimitiveStepDescription) XXX_Size() int
func (*PrimitiveStepDescription) XXX_Unmarshal ¶
func (m *PrimitiveStepDescription) XXX_Unmarshal(b []byte) error
type PrimitiveStepHyperparameter ¶
type PrimitiveStepHyperparameter struct { // Types that are valid to be assigned to Argument: // *PrimitiveStepHyperparameter_Container // *PrimitiveStepHyperparameter_Data // *PrimitiveStepHyperparameter_Primitive // *PrimitiveStepHyperparameter_Value // *PrimitiveStepHyperparameter_DataSet // *PrimitiveStepHyperparameter_PrimitivesSet Argument isPrimitiveStepHyperparameter_Argument `protobuf_oneof:"argument"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PrimitiveStepHyperparameter) Descriptor ¶
func (*PrimitiveStepHyperparameter) Descriptor() ([]byte, []int)
func (*PrimitiveStepHyperparameter) GetArgument ¶
func (m *PrimitiveStepHyperparameter) GetArgument() isPrimitiveStepHyperparameter_Argument
func (*PrimitiveStepHyperparameter) GetContainer ¶
func (m *PrimitiveStepHyperparameter) GetContainer() *ContainerArgument
func (*PrimitiveStepHyperparameter) GetData ¶
func (m *PrimitiveStepHyperparameter) GetData() *DataArgument
func (*PrimitiveStepHyperparameter) GetDataSet ¶
func (m *PrimitiveStepHyperparameter) GetDataSet() *DataArguments
func (*PrimitiveStepHyperparameter) GetPrimitive ¶
func (m *PrimitiveStepHyperparameter) GetPrimitive() *PrimitiveArgument
func (*PrimitiveStepHyperparameter) GetPrimitivesSet ¶
func (m *PrimitiveStepHyperparameter) GetPrimitivesSet() *PrimitiveArguments
func (*PrimitiveStepHyperparameter) GetValue ¶
func (m *PrimitiveStepHyperparameter) GetValue() *ValueArgument
func (*PrimitiveStepHyperparameter) ProtoMessage ¶
func (*PrimitiveStepHyperparameter) ProtoMessage()
func (*PrimitiveStepHyperparameter) Reset ¶
func (m *PrimitiveStepHyperparameter) Reset()
func (*PrimitiveStepHyperparameter) String ¶
func (m *PrimitiveStepHyperparameter) String() string
func (*PrimitiveStepHyperparameter) XXX_DiscardUnknown ¶
func (m *PrimitiveStepHyperparameter) XXX_DiscardUnknown()
func (*PrimitiveStepHyperparameter) XXX_Marshal ¶
func (m *PrimitiveStepHyperparameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveStepHyperparameter) XXX_Merge ¶
func (m *PrimitiveStepHyperparameter) XXX_Merge(src proto.Message)
func (*PrimitiveStepHyperparameter) XXX_OneofFuncs ¶
func (*PrimitiveStepHyperparameter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*PrimitiveStepHyperparameter) XXX_Size ¶
func (m *PrimitiveStepHyperparameter) XXX_Size() int
func (*PrimitiveStepHyperparameter) XXX_Unmarshal ¶
func (m *PrimitiveStepHyperparameter) XXX_Unmarshal(b []byte) error
type PrimitiveStepHyperparameter_Container ¶
type PrimitiveStepHyperparameter_Container struct {
Container *ContainerArgument `protobuf:"bytes,1,opt,name=container,proto3,oneof"`
}
type PrimitiveStepHyperparameter_Data ¶
type PrimitiveStepHyperparameter_Data struct {
Data *DataArgument `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}
type PrimitiveStepHyperparameter_DataSet ¶
type PrimitiveStepHyperparameter_DataSet struct {
DataSet *DataArguments `protobuf:"bytes,5,opt,name=data_set,json=dataSet,proto3,oneof"`
}
type PrimitiveStepHyperparameter_Primitive ¶
type PrimitiveStepHyperparameter_Primitive struct {
Primitive *PrimitiveArgument `protobuf:"bytes,3,opt,name=primitive,proto3,oneof"`
}
type PrimitiveStepHyperparameter_PrimitivesSet ¶
type PrimitiveStepHyperparameter_PrimitivesSet struct {
PrimitivesSet *PrimitiveArguments `protobuf:"bytes,6,opt,name=primitives_set,json=primitivesSet,proto3,oneof"`
}
type PrimitiveStepHyperparameter_Value ¶
type PrimitiveStepHyperparameter_Value struct {
Value *ValueArgument `protobuf:"bytes,4,opt,name=value,proto3,oneof"`
}
type Problem ¶
type Problem struct { TaskType TaskType `protobuf:"varint,5,opt,name=task_type,json=taskType,proto3,enum=TaskType" json:"task_type,omitempty"` TaskSubtype TaskSubtype `protobuf:"varint,6,opt,name=task_subtype,json=taskSubtype,proto3,enum=TaskSubtype" json:"task_subtype,omitempty"` PerformanceMetrics []*ProblemPerformanceMetric `protobuf:"bytes,7,rep,name=performance_metrics,json=performanceMetrics,proto3" json:"performance_metrics,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Problem) Descriptor ¶
func (*Problem) GetPerformanceMetrics ¶
func (m *Problem) GetPerformanceMetrics() []*ProblemPerformanceMetric
func (*Problem) GetTaskSubtype ¶
func (m *Problem) GetTaskSubtype() TaskSubtype
func (*Problem) GetTaskType ¶
func (*Problem) ProtoMessage ¶
func (*Problem) ProtoMessage()
func (*Problem) XXX_DiscardUnknown ¶
func (m *Problem) XXX_DiscardUnknown()
func (*Problem) XXX_Marshal ¶
func (*Problem) XXX_Unmarshal ¶
type ProblemDescription ¶
type ProblemDescription struct { Problem *Problem `protobuf:"bytes,1,opt,name=problem,proto3" json:"problem,omitempty"` Inputs []*ProblemInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` // ID of this problem. Required. Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // Version of this problem. Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"` Digest string `protobuf:"bytes,7,opt,name=digest,proto3" json:"digest,omitempty"` DataAugmentation []*DataAugmentation `protobuf:"bytes,8,rep,name=data_augmentation,json=dataAugmentation,proto3" json:"data_augmentation,omitempty"` OtherNames []string `protobuf:"bytes,9,rep,name=other_names,json=otherNames,proto3" json:"other_names,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Problem description matches the parsed problem description by the d3m_metadata.problem.parse_problem_description Python method. Problem outputs are not necessary for the purpose of this API and are needed only when executing an exported pipeline, but then TA2 gets full problem description anyway directly.
func (*ProblemDescription) Descriptor ¶
func (*ProblemDescription) Descriptor() ([]byte, []int)
func (*ProblemDescription) GetDataAugmentation ¶
func (m *ProblemDescription) GetDataAugmentation() []*DataAugmentation
func (*ProblemDescription) GetDescription ¶
func (m *ProblemDescription) GetDescription() string
func (*ProblemDescription) GetDigest ¶
func (m *ProblemDescription) GetDigest() string
func (*ProblemDescription) GetId ¶
func (m *ProblemDescription) GetId() string
func (*ProblemDescription) GetInputs ¶
func (m *ProblemDescription) GetInputs() []*ProblemInput
func (*ProblemDescription) GetName ¶
func (m *ProblemDescription) GetName() string
func (*ProblemDescription) GetOtherNames ¶
func (m *ProblemDescription) GetOtherNames() []string
func (*ProblemDescription) GetProblem ¶
func (m *ProblemDescription) GetProblem() *Problem
func (*ProblemDescription) GetVersion ¶
func (m *ProblemDescription) GetVersion() string
func (*ProblemDescription) ProtoMessage ¶
func (*ProblemDescription) ProtoMessage()
func (*ProblemDescription) Reset ¶
func (m *ProblemDescription) Reset()
func (*ProblemDescription) String ¶
func (m *ProblemDescription) String() string
func (*ProblemDescription) XXX_DiscardUnknown ¶
func (m *ProblemDescription) XXX_DiscardUnknown()
func (*ProblemDescription) XXX_Marshal ¶
func (m *ProblemDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProblemDescription) XXX_Merge ¶
func (m *ProblemDescription) XXX_Merge(src proto.Message)
func (*ProblemDescription) XXX_Size ¶
func (m *ProblemDescription) XXX_Size() int
func (*ProblemDescription) XXX_Unmarshal ¶
func (m *ProblemDescription) XXX_Unmarshal(b []byte) error
type ProblemInput ¶
type ProblemInput struct { // Should match one of input datasets given to the pipeline search. // Every "Dataset" object has an "id" associated with it and is available // in its metadata. That ID is then used here to reference those inputs. DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"` // Targets should resolve to columns in a given dataset. Targets []*ProblemTarget `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"` // A list of privileged data columns related to unavailable attributes during testing. // These columns do not have data available in the test split of a dataset. PrivilegedData []*ProblemPrivilegedData `protobuf:"bytes,3,rep,name=privileged_data,json=privilegedData,proto3" json:"privileged_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProblemInput) Descriptor ¶
func (*ProblemInput) Descriptor() ([]byte, []int)
func (*ProblemInput) GetDatasetId ¶
func (m *ProblemInput) GetDatasetId() string
func (*ProblemInput) GetPrivilegedData ¶
func (m *ProblemInput) GetPrivilegedData() []*ProblemPrivilegedData
func (*ProblemInput) GetTargets ¶
func (m *ProblemInput) GetTargets() []*ProblemTarget
func (*ProblemInput) ProtoMessage ¶
func (*ProblemInput) ProtoMessage()
func (*ProblemInput) Reset ¶
func (m *ProblemInput) Reset()
func (*ProblemInput) String ¶
func (m *ProblemInput) String() string
func (*ProblemInput) XXX_DiscardUnknown ¶
func (m *ProblemInput) XXX_DiscardUnknown()
func (*ProblemInput) XXX_Marshal ¶
func (m *ProblemInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProblemInput) XXX_Merge ¶
func (m *ProblemInput) XXX_Merge(src proto.Message)
func (*ProblemInput) XXX_Size ¶
func (m *ProblemInput) XXX_Size() int
func (*ProblemInput) XXX_Unmarshal ¶
func (m *ProblemInput) XXX_Unmarshal(b []byte) error
type ProblemPerformanceMetric ¶
type ProblemPerformanceMetric struct { Metric PerformanceMetric `protobuf:"varint,1,opt,name=metric,proto3,enum=PerformanceMetric" json:"metric,omitempty"` // Additional params used by some metrics. K int32 `protobuf:"varint,2,opt,name=k,proto3" json:"k,omitempty"` PosLabel string `protobuf:"bytes,3,opt,name=pos_label,json=posLabel,proto3" json:"pos_label,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProblemPerformanceMetric) Descriptor ¶
func (*ProblemPerformanceMetric) Descriptor() ([]byte, []int)
func (*ProblemPerformanceMetric) GetK ¶
func (m *ProblemPerformanceMetric) GetK() int32
func (*ProblemPerformanceMetric) GetMetric ¶
func (m *ProblemPerformanceMetric) GetMetric() PerformanceMetric
func (*ProblemPerformanceMetric) GetPosLabel ¶
func (m *ProblemPerformanceMetric) GetPosLabel() string
func (*ProblemPerformanceMetric) ProtoMessage ¶
func (*ProblemPerformanceMetric) ProtoMessage()
func (*ProblemPerformanceMetric) Reset ¶
func (m *ProblemPerformanceMetric) Reset()
func (*ProblemPerformanceMetric) String ¶
func (m *ProblemPerformanceMetric) String() string
func (*ProblemPerformanceMetric) XXX_DiscardUnknown ¶
func (m *ProblemPerformanceMetric) XXX_DiscardUnknown()
func (*ProblemPerformanceMetric) XXX_Marshal ¶
func (m *ProblemPerformanceMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProblemPerformanceMetric) XXX_Merge ¶
func (m *ProblemPerformanceMetric) XXX_Merge(src proto.Message)
func (*ProblemPerformanceMetric) XXX_Size ¶
func (m *ProblemPerformanceMetric) XXX_Size() int
func (*ProblemPerformanceMetric) XXX_Unmarshal ¶
func (m *ProblemPerformanceMetric) XXX_Unmarshal(b []byte) error
type ProblemPrivilegedData ¶
type ProblemPrivilegedData struct { PrivilegedDataIndex int32 `protobuf:"varint,1,opt,name=privileged_data_index,json=privilegedDataIndex,proto3" json:"privileged_data_index,omitempty"` ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ColumnIndex int32 `protobuf:"varint,3,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"` ColumnName string `protobuf:"bytes,4,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProblemPrivilegedData) Descriptor ¶
func (*ProblemPrivilegedData) Descriptor() ([]byte, []int)
func (*ProblemPrivilegedData) GetColumnIndex ¶
func (m *ProblemPrivilegedData) GetColumnIndex() int32
func (*ProblemPrivilegedData) GetColumnName ¶
func (m *ProblemPrivilegedData) GetColumnName() string
func (*ProblemPrivilegedData) GetPrivilegedDataIndex ¶
func (m *ProblemPrivilegedData) GetPrivilegedDataIndex() int32
func (*ProblemPrivilegedData) GetResourceId ¶
func (m *ProblemPrivilegedData) GetResourceId() string
func (*ProblemPrivilegedData) ProtoMessage ¶
func (*ProblemPrivilegedData) ProtoMessage()
func (*ProblemPrivilegedData) Reset ¶
func (m *ProblemPrivilegedData) Reset()
func (*ProblemPrivilegedData) String ¶
func (m *ProblemPrivilegedData) String() string
func (*ProblemPrivilegedData) XXX_DiscardUnknown ¶
func (m *ProblemPrivilegedData) XXX_DiscardUnknown()
func (*ProblemPrivilegedData) XXX_Marshal ¶
func (m *ProblemPrivilegedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProblemPrivilegedData) XXX_Merge ¶
func (m *ProblemPrivilegedData) XXX_Merge(src proto.Message)
func (*ProblemPrivilegedData) XXX_Size ¶
func (m *ProblemPrivilegedData) XXX_Size() int
func (*ProblemPrivilegedData) XXX_Unmarshal ¶
func (m *ProblemPrivilegedData) XXX_Unmarshal(b []byte) error
type ProblemTarget ¶
type ProblemTarget struct { TargetIndex int32 `protobuf:"varint,1,opt,name=target_index,json=targetIndex,proto3" json:"target_index,omitempty"` ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ColumnIndex int32 `protobuf:"varint,3,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"` ColumnName string `protobuf:"bytes,4,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"` ClustersNumber int32 `protobuf:"varint,5,opt,name=clusters_number,json=clustersNumber,proto3" json:"clusters_number,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProblemTarget) Descriptor ¶
func (*ProblemTarget) Descriptor() ([]byte, []int)
func (*ProblemTarget) GetClustersNumber ¶
func (m *ProblemTarget) GetClustersNumber() int32
func (*ProblemTarget) GetColumnIndex ¶
func (m *ProblemTarget) GetColumnIndex() int32
func (*ProblemTarget) GetColumnName ¶
func (m *ProblemTarget) GetColumnName() string
func (*ProblemTarget) GetResourceId ¶
func (m *ProblemTarget) GetResourceId() string
func (*ProblemTarget) GetTargetIndex ¶
func (m *ProblemTarget) GetTargetIndex() int32
func (*ProblemTarget) ProtoMessage ¶
func (*ProblemTarget) ProtoMessage()
func (*ProblemTarget) Reset ¶
func (m *ProblemTarget) Reset()
func (*ProblemTarget) String ¶
func (m *ProblemTarget) String() string
func (*ProblemTarget) XXX_DiscardUnknown ¶
func (m *ProblemTarget) XXX_DiscardUnknown()
func (*ProblemTarget) XXX_Marshal ¶
func (m *ProblemTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProblemTarget) XXX_Merge ¶
func (m *ProblemTarget) XXX_Merge(src proto.Message)
func (*ProblemTarget) XXX_Size ¶
func (m *ProblemTarget) XXX_Size() int
func (*ProblemTarget) XXX_Unmarshal ¶
func (m *ProblemTarget) XXX_Unmarshal(b []byte) error
type ProduceSolutionRequest ¶
type ProduceSolutionRequest struct { FittedSolutionId string `protobuf:"bytes,1,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"` Inputs []*Value `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` // List of data references of step outputs which should be exposed to the TA3 system. // If you want to expose outputs of the whole pipeline (e.g., predictions themselves), // list them here as well. These can be recursive data references like // "steps.1.steps.4.produce" to point to an output inside a sub-pipeline. // Systems only have to support exposing final outputs and can return "ValueError" for // intermediate values. ExposeOutputs []string `protobuf:"bytes,3,rep,name=expose_outputs,json=exposeOutputs,proto3" json:"expose_outputs,omitempty"` // Which value types should be used for exposing outputs. If not provided, the allowed // value types list from the search solutions call is used instead. // The order is important as the TA2 system will try value types in order until one works // out, or an error will be returned instead of the value. An error exposing a value does // not stop the overall process. ExposeValueTypes []ValueType `` /* 134-byte string literal not displayed */ // Any users associated with this call itself. Optional. Users []*SolutionRunUser `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Produce (execute) the solution on given inputs. A solution has to have been fitted for this to be possible (even if in cases where this is just created by transformations).
func (*ProduceSolutionRequest) Descriptor ¶
func (*ProduceSolutionRequest) Descriptor() ([]byte, []int)
func (*ProduceSolutionRequest) GetExposeOutputs ¶
func (m *ProduceSolutionRequest) GetExposeOutputs() []string
func (*ProduceSolutionRequest) GetExposeValueTypes ¶
func (m *ProduceSolutionRequest) GetExposeValueTypes() []ValueType
func (*ProduceSolutionRequest) GetFittedSolutionId ¶
func (m *ProduceSolutionRequest) GetFittedSolutionId() string
func (*ProduceSolutionRequest) GetInputs ¶
func (m *ProduceSolutionRequest) GetInputs() []*Value
func (*ProduceSolutionRequest) GetUsers ¶
func (m *ProduceSolutionRequest) GetUsers() []*SolutionRunUser
func (*ProduceSolutionRequest) ProtoMessage ¶
func (*ProduceSolutionRequest) ProtoMessage()
func (*ProduceSolutionRequest) Reset ¶
func (m *ProduceSolutionRequest) Reset()
func (*ProduceSolutionRequest) String ¶
func (m *ProduceSolutionRequest) String() string
func (*ProduceSolutionRequest) XXX_DiscardUnknown ¶
func (m *ProduceSolutionRequest) XXX_DiscardUnknown()
func (*ProduceSolutionRequest) XXX_Marshal ¶
func (m *ProduceSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProduceSolutionRequest) XXX_Merge ¶
func (m *ProduceSolutionRequest) XXX_Merge(src proto.Message)
func (*ProduceSolutionRequest) XXX_Size ¶
func (m *ProduceSolutionRequest) XXX_Size() int
func (*ProduceSolutionRequest) XXX_Unmarshal ¶
func (m *ProduceSolutionRequest) XXX_Unmarshal(b []byte) error
type ProduceSolutionResponse ¶
type ProduceSolutionResponse struct { RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProduceSolutionResponse) Descriptor ¶
func (*ProduceSolutionResponse) Descriptor() ([]byte, []int)
func (*ProduceSolutionResponse) GetRequestId ¶
func (m *ProduceSolutionResponse) GetRequestId() string
func (*ProduceSolutionResponse) ProtoMessage ¶
func (*ProduceSolutionResponse) ProtoMessage()
func (*ProduceSolutionResponse) Reset ¶
func (m *ProduceSolutionResponse) Reset()
func (*ProduceSolutionResponse) String ¶
func (m *ProduceSolutionResponse) String() string
func (*ProduceSolutionResponse) XXX_DiscardUnknown ¶
func (m *ProduceSolutionResponse) XXX_DiscardUnknown()
func (*ProduceSolutionResponse) XXX_Marshal ¶
func (m *ProduceSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProduceSolutionResponse) XXX_Merge ¶
func (m *ProduceSolutionResponse) XXX_Merge(src proto.Message)
func (*ProduceSolutionResponse) XXX_Size ¶
func (m *ProduceSolutionResponse) XXX_Size() int
func (*ProduceSolutionResponse) XXX_Unmarshal ¶
func (m *ProduceSolutionResponse) XXX_Unmarshal(b []byte) error
type Progress ¶
type Progress struct { State ProgressState `protobuf:"varint,1,opt,name=state,proto3,enum=ProgressState" json:"state,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // Set only after state becomes "RUNNING". If it never really properly runs, but errors // when attempted to run, then it should be the timestamp of the error. Start *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"` // Set only when state is "COMPLETED" or "ERRORED". End *timestamp.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
After "state" becomes "COMPLETED" or "ERRORED" stream closes. The granularity of progress updates is not specified by the API at this time. Some systems might be updating frequently and provide many updates of the progress of a whole process as well as individual pipeline steps. Some systems might just report these high-level progress states once, not doing any progress updates in the meantime. The "status" field should contain information to supplement the progress state, such as specific failure details in the case of an "ERRORED" state being returned.
func (*Progress) Descriptor ¶
func (*Progress) GetState ¶
func (m *Progress) GetState() ProgressState
func (*Progress) ProtoMessage ¶
func (*Progress) ProtoMessage()
func (*Progress) XXX_DiscardUnknown ¶
func (m *Progress) XXX_DiscardUnknown()
func (*Progress) XXX_Marshal ¶
func (*Progress) XXX_Unmarshal ¶
type ProgressState ¶
type ProgressState int32
const ( // Default value. Not to be used. ProgressState_PROGRESS_UNKNOWN ProgressState = 0 // The process has been scheduled but is pending execution. ProgressState_PENDING ProgressState = 1 // The process is currently running. There can be multiple messages with this state // (while the process is running). ProgressState_RUNNING ProgressState = 2 // The process completed and final results are available. ProgressState_COMPLETED ProgressState = 3 // The process failed. ProgressState_ERRORED ProgressState = 4 )
func (ProgressState) EnumDescriptor ¶
func (ProgressState) EnumDescriptor() ([]byte, []int)
func (ProgressState) String ¶
func (x ProgressState) String() string
type RequestNode ¶
type RequestNode interface { GetRequestID() string GetParent() string GetChildren() []string GetRequestMsg() interface{} }
RequestNode stores data for a hierarchical server API request.
type SaveFittedSolutionRequest ¶
type SaveFittedSolutionRequest struct { // Fitted solution id to saved. FittedSolutionId string `protobuf:"bytes,1,opt,name=fitted_solution_id,json=fittedSolutionId,proto3" json:"fitted_solution_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Save a fitted solution that can be loaded later. Optional.
func (*SaveFittedSolutionRequest) Descriptor ¶
func (*SaveFittedSolutionRequest) Descriptor() ([]byte, []int)
func (*SaveFittedSolutionRequest) GetFittedSolutionId ¶
func (m *SaveFittedSolutionRequest) GetFittedSolutionId() string
func (*SaveFittedSolutionRequest) ProtoMessage ¶
func (*SaveFittedSolutionRequest) ProtoMessage()
func (*SaveFittedSolutionRequest) Reset ¶
func (m *SaveFittedSolutionRequest) Reset()
func (*SaveFittedSolutionRequest) String ¶
func (m *SaveFittedSolutionRequest) String() string
func (*SaveFittedSolutionRequest) XXX_DiscardUnknown ¶
func (m *SaveFittedSolutionRequest) XXX_DiscardUnknown()
func (*SaveFittedSolutionRequest) XXX_Marshal ¶
func (m *SaveFittedSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SaveFittedSolutionRequest) XXX_Merge ¶
func (m *SaveFittedSolutionRequest) XXX_Merge(src proto.Message)
func (*SaveFittedSolutionRequest) XXX_Size ¶
func (m *SaveFittedSolutionRequest) XXX_Size() int
func (*SaveFittedSolutionRequest) XXX_Unmarshal ¶
func (m *SaveFittedSolutionRequest) XXX_Unmarshal(b []byte) error
type SaveFittedSolutionResponse ¶
type SaveFittedSolutionResponse struct { // An URI pointing to a directory containing a fitted solution. FittedSolutionUri string `protobuf:"bytes,1,opt,name=fitted_solution_uri,json=fittedSolutionUri,proto3" json:"fitted_solution_uri,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SaveFittedSolutionResponse) Descriptor ¶
func (*SaveFittedSolutionResponse) Descriptor() ([]byte, []int)
func (*SaveFittedSolutionResponse) GetFittedSolutionUri ¶
func (m *SaveFittedSolutionResponse) GetFittedSolutionUri() string
func (*SaveFittedSolutionResponse) ProtoMessage ¶
func (*SaveFittedSolutionResponse) ProtoMessage()
func (*SaveFittedSolutionResponse) Reset ¶
func (m *SaveFittedSolutionResponse) Reset()
func (*SaveFittedSolutionResponse) String ¶
func (m *SaveFittedSolutionResponse) String() string
func (*SaveFittedSolutionResponse) XXX_DiscardUnknown ¶
func (m *SaveFittedSolutionResponse) XXX_DiscardUnknown()
func (*SaveFittedSolutionResponse) XXX_Marshal ¶
func (m *SaveFittedSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SaveFittedSolutionResponse) XXX_Merge ¶
func (m *SaveFittedSolutionResponse) XXX_Merge(src proto.Message)
func (*SaveFittedSolutionResponse) XXX_Size ¶
func (m *SaveFittedSolutionResponse) XXX_Size() int
func (*SaveFittedSolutionResponse) XXX_Unmarshal ¶
func (m *SaveFittedSolutionResponse) XXX_Unmarshal(b []byte) error
type SaveSolutionRequest ¶
type SaveSolutionRequest struct { // Id of solution to saved SolutionId string `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Save a solution that can be loaded later. (Pipeline description/ Pipeline run) Optional.
func (*SaveSolutionRequest) Descriptor ¶
func (*SaveSolutionRequest) Descriptor() ([]byte, []int)
func (*SaveSolutionRequest) GetSolutionId ¶
func (m *SaveSolutionRequest) GetSolutionId() string
func (*SaveSolutionRequest) ProtoMessage ¶
func (*SaveSolutionRequest) ProtoMessage()
func (*SaveSolutionRequest) Reset ¶
func (m *SaveSolutionRequest) Reset()
func (*SaveSolutionRequest) String ¶
func (m *SaveSolutionRequest) String() string
func (*SaveSolutionRequest) XXX_DiscardUnknown ¶
func (m *SaveSolutionRequest) XXX_DiscardUnknown()
func (*SaveSolutionRequest) XXX_Marshal ¶
func (m *SaveSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SaveSolutionRequest) XXX_Merge ¶
func (m *SaveSolutionRequest) XXX_Merge(src proto.Message)
func (*SaveSolutionRequest) XXX_Size ¶
func (m *SaveSolutionRequest) XXX_Size() int
func (*SaveSolutionRequest) XXX_Unmarshal ¶
func (m *SaveSolutionRequest) XXX_Unmarshal(b []byte) error
type SaveSolutionResponse ¶
type SaveSolutionResponse struct { // An URI pointing to a directory containing a solution saved. SolutionUri string `protobuf:"bytes,1,opt,name=solution_uri,json=solutionUri,proto3" json:"solution_uri,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SaveSolutionResponse) Descriptor ¶
func (*SaveSolutionResponse) Descriptor() ([]byte, []int)
func (*SaveSolutionResponse) GetSolutionUri ¶
func (m *SaveSolutionResponse) GetSolutionUri() string
func (*SaveSolutionResponse) ProtoMessage ¶
func (*SaveSolutionResponse) ProtoMessage()
func (*SaveSolutionResponse) Reset ¶
func (m *SaveSolutionResponse) Reset()
func (*SaveSolutionResponse) String ¶
func (m *SaveSolutionResponse) String() string
func (*SaveSolutionResponse) XXX_DiscardUnknown ¶
func (m *SaveSolutionResponse) XXX_DiscardUnknown()
func (*SaveSolutionResponse) XXX_Marshal ¶
func (m *SaveSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SaveSolutionResponse) XXX_Merge ¶
func (m *SaveSolutionResponse) XXX_Merge(src proto.Message)
func (*SaveSolutionResponse) XXX_Size ¶
func (m *SaveSolutionResponse) XXX_Size() int
func (*SaveSolutionResponse) XXX_Unmarshal ¶
func (m *SaveSolutionResponse) XXX_Unmarshal(b []byte) error
type Score ¶
type Score struct { Metric *ProblemPerformanceMetric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"` // When doing multiple folds, which fold is this score associated with, 0-based. // We do not aggregate scores across folds on the TA2 side, but expose everything to the TA3. // If scoring was not done as part of the cross-validation, then it can be returned // as the first and only fold, in which case the value of this field should be 0. Fold int32 `protobuf:"varint,2,opt,name=fold,proto3" json:"fold,omitempty"` Value *Value `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` // Random seed used to run a pipeline for this score to be obtained. RandomSeed int32 `protobuf:"varint,5,opt,name=random_seed,json=randomSeed,proto3" json:"random_seed,omitempty"` // The normalized value of the scoring metric. Value is from the [0, 1] interval, where higher is better. Optional. Normalized *Value `protobuf:"bytes,6,opt,name=normalized,proto3" json:"normalized,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Score) Descriptor ¶
func (*Score) GetMetric ¶
func (m *Score) GetMetric() *ProblemPerformanceMetric
func (*Score) GetNormalized ¶
func (*Score) GetRandomSeed ¶
func (*Score) ProtoMessage ¶
func (*Score) ProtoMessage()
func (*Score) XXX_DiscardUnknown ¶
func (m *Score) XXX_DiscardUnknown()
func (*Score) XXX_Marshal ¶
func (*Score) XXX_Unmarshal ¶
type ScoreSolutionRequest ¶
type ScoreSolutionRequest struct { SolutionId string `protobuf:"bytes,1,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"` Inputs []*Value `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` PerformanceMetrics []*ProblemPerformanceMetric `protobuf:"bytes,3,rep,name=performance_metrics,json=performanceMetrics,proto3" json:"performance_metrics,omitempty"` // Any users associated with this call itself. Optional. Users []*SolutionRunUser `protobuf:"bytes,4,rep,name=users,proto3" json:"users,omitempty"` Configuration *ScoringConfiguration `protobuf:"bytes,5,opt,name=configuration,proto3" json:"configuration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request solution to be scored given inputs. Inputs have to be Dataset container values and pipeline outputs have to be predictions. It can internally run multiple fit + produce runs of the pipeline on permutations of inputs data (e.g., for cross-validation). This is also why we cannot expose outputs here. When solution cannot be scored (i.e., the fully specified pipeline used as a template is not a standard pipeline), this call does not have to be supported.
func (*ScoreSolutionRequest) Descriptor ¶
func (*ScoreSolutionRequest) Descriptor() ([]byte, []int)
func (*ScoreSolutionRequest) GetConfiguration ¶
func (m *ScoreSolutionRequest) GetConfiguration() *ScoringConfiguration
func (*ScoreSolutionRequest) GetInputs ¶
func (m *ScoreSolutionRequest) GetInputs() []*Value
func (*ScoreSolutionRequest) GetPerformanceMetrics ¶
func (m *ScoreSolutionRequest) GetPerformanceMetrics() []*ProblemPerformanceMetric
func (*ScoreSolutionRequest) GetSolutionId ¶
func (m *ScoreSolutionRequest) GetSolutionId() string
func (*ScoreSolutionRequest) GetUsers ¶
func (m *ScoreSolutionRequest) GetUsers() []*SolutionRunUser
func (*ScoreSolutionRequest) ProtoMessage ¶
func (*ScoreSolutionRequest) ProtoMessage()
func (*ScoreSolutionRequest) Reset ¶
func (m *ScoreSolutionRequest) Reset()
func (*ScoreSolutionRequest) String ¶
func (m *ScoreSolutionRequest) String() string
func (*ScoreSolutionRequest) XXX_DiscardUnknown ¶
func (m *ScoreSolutionRequest) XXX_DiscardUnknown()
func (*ScoreSolutionRequest) XXX_Marshal ¶
func (m *ScoreSolutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScoreSolutionRequest) XXX_Merge ¶
func (m *ScoreSolutionRequest) XXX_Merge(src proto.Message)
func (*ScoreSolutionRequest) XXX_Size ¶
func (m *ScoreSolutionRequest) XXX_Size() int
func (*ScoreSolutionRequest) XXX_Unmarshal ¶
func (m *ScoreSolutionRequest) XXX_Unmarshal(b []byte) error
type ScoreSolutionResponse ¶
type ScoreSolutionResponse struct { RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ScoreSolutionResponse) Descriptor ¶
func (*ScoreSolutionResponse) Descriptor() ([]byte, []int)
func (*ScoreSolutionResponse) GetRequestId ¶
func (m *ScoreSolutionResponse) GetRequestId() string
func (*ScoreSolutionResponse) ProtoMessage ¶
func (*ScoreSolutionResponse) ProtoMessage()
func (*ScoreSolutionResponse) Reset ¶
func (m *ScoreSolutionResponse) Reset()
func (*ScoreSolutionResponse) String ¶
func (m *ScoreSolutionResponse) String() string
func (*ScoreSolutionResponse) XXX_DiscardUnknown ¶
func (m *ScoreSolutionResponse) XXX_DiscardUnknown()
func (*ScoreSolutionResponse) XXX_Marshal ¶
func (m *ScoreSolutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScoreSolutionResponse) XXX_Merge ¶
func (m *ScoreSolutionResponse) XXX_Merge(src proto.Message)
func (*ScoreSolutionResponse) XXX_Size ¶
func (m *ScoreSolutionResponse) XXX_Size() int
func (*ScoreSolutionResponse) XXX_Unmarshal ¶
func (m *ScoreSolutionResponse) XXX_Unmarshal(b []byte) error
type ScoringConfiguration ¶
type ScoringConfiguration struct { // The evaluation method to use. Method EvaluationMethod `protobuf:"varint,1,opt,name=method,proto3,enum=EvaluationMethod" json:"method,omitempty"` // Number of folds made, if applicable. Folds int32 `protobuf:"varint,2,opt,name=folds,proto3" json:"folds,omitempty"` // If applicable, the ratio between the train and test data and represents the proportion of // the input data to include in the train split. The rest is included in the test split. // E.g., "train_test_ratio == 0.8" would mean that 80% of the whole data becomes the train split // and 20% of the whole data becomes the test split. TrainTestRatio float64 `protobuf:"fixed64,3,opt,name=train_test_ratio,json=trainTestRatio,proto3" json:"train_test_ratio,omitempty"` // Shuffle data? Set to true if employed. Shuffle bool `protobuf:"varint,4,opt,name=shuffle,proto3" json:"shuffle,omitempty"` // Value for random seed to use for shuffling. Optional. RandomSeed int32 `protobuf:"varint,5,opt,name=random_seed,json=randomSeed,proto3" json:"random_seed,omitempty"` // Do stratified k-fold? Set to true if employed. Stratified bool `protobuf:"varint,6,opt,name=stratified,proto3" json:"stratified,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ScoringConfiguration) Descriptor ¶
func (*ScoringConfiguration) Descriptor() ([]byte, []int)
func (*ScoringConfiguration) GetFolds ¶
func (m *ScoringConfiguration) GetFolds() int32
func (*ScoringConfiguration) GetMethod ¶
func (m *ScoringConfiguration) GetMethod() EvaluationMethod
func (*ScoringConfiguration) GetRandomSeed ¶
func (m *ScoringConfiguration) GetRandomSeed() int32
func (*ScoringConfiguration) GetShuffle ¶
func (m *ScoringConfiguration) GetShuffle() bool
func (*ScoringConfiguration) GetStratified ¶
func (m *ScoringConfiguration) GetStratified() bool
func (*ScoringConfiguration) GetTrainTestRatio ¶
func (m *ScoringConfiguration) GetTrainTestRatio() float64
func (*ScoringConfiguration) ProtoMessage ¶
func (*ScoringConfiguration) ProtoMessage()
func (*ScoringConfiguration) Reset ¶
func (m *ScoringConfiguration) Reset()
func (*ScoringConfiguration) String ¶
func (m *ScoringConfiguration) String() string
func (*ScoringConfiguration) XXX_DiscardUnknown ¶
func (m *ScoringConfiguration) XXX_DiscardUnknown()
func (*ScoringConfiguration) XXX_Marshal ¶
func (m *ScoringConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScoringConfiguration) XXX_Merge ¶
func (m *ScoringConfiguration) XXX_Merge(src proto.Message)
func (*ScoringConfiguration) XXX_Size ¶
func (m *ScoringConfiguration) XXX_Size() int
func (*ScoringConfiguration) XXX_Unmarshal ¶
func (m *ScoringConfiguration) XXX_Unmarshal(b []byte) error
type SearchSolutionsRequest ¶
type SearchSolutionsRequest struct { // Some string identifying the name and version of the TA3 system. UserAgent string `protobuf:"bytes,1,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` // Shall be set to "protocol_version" above. Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Desired upper limit of time for solution search, expressed in minutes. // Is suggestion, and TA2's should attempt to obey, but TA3's should realize may be // violated. Default value of 0 (and any negative number) signifies no time bound. // See also time_bound_run. TimeBoundSearch float64 `protobuf:"fixed64,3,opt,name=time_bound_search,json=timeBoundSearch,proto3" json:"time_bound_search,omitempty"` // Value stating the priority of the search. If multiple searches are queued then highest // priority (largest number) should be started next by TA2. Primarily used to sort any // queue, but no further guarantee that TA2 can give more resources to high priority // searches. If unspecified, by default search will have priority 0. Negative numbers have // still lower priority. Priority float64 `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"` // Which value types can a TA2 system use to communicate values to a TA3 system? // The order is important as a TA2 system will try value types in order until one works out, // or an error will be returned instead of the value. AllowedValueTypes []ValueType `` /* 137-byte string literal not displayed */ // Problem description to use for the solution search. Problem description is optional // with fully specified pipelines which TA3 provides. If still provided, TA2 should use // it to set semantic types on target columns and any other use of a problem description // for the needs of running a pipeline. Problem *ProblemDescription `protobuf:"bytes,6,opt,name=problem,proto3" json:"problem,omitempty"` // A pipeline template to use for search or to execute. If template is omitted, then a // regular solution search is done. If template consists only of one placeholder step, // then a regular solution search is done to replace that step. If there is no placeholder // step, but template describes a full pipeline with free hyper-parameters, then this // call becomes a hyper-paramater tuning call over free hyper-paramaters and found solutions // share the same pipeline, but different hyper-parameter configurations. If there is no // placeholder step and all hyper-parameters are fixed as part of the pipeline, then this // call only checks the given template and returns the solution with same pipeline back, to // be executed. This allows fixed computations to be done on data, for example, pipeline can // consist of only one primitive with fixed hyper-parameters to execute that one primitive. // Moreover, such fully specified pipelines with fixed hyper-parametres can have any // inputs and any outputs. Otherwise pipelines have to be from a Dataset container value // to predictions Pandas dataframe. While there are all these options possible, only a // subset has to be supported by all systems. See README for more details. Template *PipelineDescription `protobuf:"bytes,7,opt,name=template,proto3" json:"template,omitempty"` // Pipeline inputs used during solution search. They have to point to Dataset container // values. Order matters as each input is mapped to a template's input in order. Optional // for templates without a placeholder and with all hyper-parameters fixed. Inputs []*Value `protobuf:"bytes,8,rep,name=inputs,proto3" json:"inputs,omitempty"` // Desire upper limit of time for one pass of the pipeline run expressed in minutes. // Expressed at time of search, TA2's should limit the search to solutions // that would not take longer than this for one pass of the pipeline run. // Is suggestion, and TA2's should attempt to obey, but TA3's should realize may be // violated. Default value of 0 (and any negative number) signifies no time bound. // This can also functionally be used as the time bound for scoring also. TimeBoundRun float64 `protobuf:"fixed64,9,opt,name=time_bound_run,json=timeBoundRun,proto3" json:"time_bound_run,omitempty"` // Suggested maximum number of solutions to rank. Default is 0. If it is 0, it means // no ranking of found solutions is done and no limit on number of found solutions is set. // TA2 can still provide "RANK" score as part of "scores" field if ranking approach // TA2 uses still allows to stream found solutions as they are found. // If value of this field is not 0, the behavior of this call changes: // - "time_bound_search" becomes a time bound for both search and ranking. // TA2 decides how to divide the time between searching and ranking. // - TA2 is required to provide "RANK" score as part of "scores" field in // messages "GetSearchSolutionsResultsResponse". // - TA2 can make all found solutions available only at the end of the call. // If ranking approach used by TA2 allows for that, TA2 can still stream // found solutions (and their ranks) during whole call. // - Calling "StopSearchSolutions" stops both search and ranking processes, // but TA2 can quickly return ranked solutions up to that point, if possible, // before closing the "GetSearchSolutionsResults" stream. Similarly // for "EndSearchSolutions", but that is less useful. // - TA2 can still return more solutions than the limit. The limit only signals // that TA2 does not have to rank and return more solutions than the limit, // which is useful when ranking is an expensive operation. RankSolutionsLimit int32 `protobuf:"varint,10,opt,name=rank_solutions_limit,json=rankSolutionsLimit,proto3" json:"rank_solutions_limit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Starts a new solution search. Found solutions have not necessary been fitted on the provided inputs. Problem description and inputs are used only to help guide the search process. Consider any found solutions to be just a static description of solutions at this stage. Multiple parallel solution searches can happen at the same time.
func (*SearchSolutionsRequest) Descriptor ¶
func (*SearchSolutionsRequest) Descriptor() ([]byte, []int)
func (*SearchSolutionsRequest) GetAllowedValueTypes ¶
func (m *SearchSolutionsRequest) GetAllowedValueTypes() []ValueType
func (*SearchSolutionsRequest) GetInputs ¶
func (m *SearchSolutionsRequest) GetInputs() []*Value
func (*SearchSolutionsRequest) GetPriority ¶
func (m *SearchSolutionsRequest) GetPriority() float64
func (*SearchSolutionsRequest) GetProblem ¶
func (m *SearchSolutionsRequest) GetProblem() *ProblemDescription
func (*SearchSolutionsRequest) GetRankSolutionsLimit ¶
func (m *SearchSolutionsRequest) GetRankSolutionsLimit() int32
func (*SearchSolutionsRequest) GetTemplate ¶
func (m *SearchSolutionsRequest) GetTemplate() *PipelineDescription
func (*SearchSolutionsRequest) GetTimeBoundRun ¶
func (m *SearchSolutionsRequest) GetTimeBoundRun() float64
func (*SearchSolutionsRequest) GetTimeBoundSearch ¶
func (m *SearchSolutionsRequest) GetTimeBoundSearch() float64
func (*SearchSolutionsRequest) GetUserAgent ¶
func (m *SearchSolutionsRequest) GetUserAgent() string
func (*SearchSolutionsRequest) GetVersion ¶
func (m *SearchSolutionsRequest) GetVersion() string
func (*SearchSolutionsRequest) ProtoMessage ¶
func (*SearchSolutionsRequest) ProtoMessage()
func (*SearchSolutionsRequest) Reset ¶
func (m *SearchSolutionsRequest) Reset()
func (*SearchSolutionsRequest) String ¶
func (m *SearchSolutionsRequest) String() string
func (*SearchSolutionsRequest) XXX_DiscardUnknown ¶
func (m *SearchSolutionsRequest) XXX_DiscardUnknown()
func (*SearchSolutionsRequest) XXX_Marshal ¶
func (m *SearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchSolutionsRequest) XXX_Merge ¶
func (m *SearchSolutionsRequest) XXX_Merge(src proto.Message)
func (*SearchSolutionsRequest) XXX_Size ¶
func (m *SearchSolutionsRequest) XXX_Size() int
func (*SearchSolutionsRequest) XXX_Unmarshal ¶
func (m *SearchSolutionsRequest) XXX_Unmarshal(b []byte) error
type SearchSolutionsResponse ¶
type SearchSolutionsResponse struct { // An ID identifying this solution search. This string should be at least 22 characters // long to ensure enough entropy to not be guessable. SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Call returns immediately with the ID. Use "GetFoundSolutions" call to get results.
func (*SearchSolutionsResponse) Descriptor ¶
func (*SearchSolutionsResponse) Descriptor() ([]byte, []int)
func (*SearchSolutionsResponse) GetSearchId ¶
func (m *SearchSolutionsResponse) GetSearchId() string
func (*SearchSolutionsResponse) ProtoMessage ¶
func (*SearchSolutionsResponse) ProtoMessage()
func (*SearchSolutionsResponse) Reset ¶
func (m *SearchSolutionsResponse) Reset()
func (*SearchSolutionsResponse) String ¶
func (m *SearchSolutionsResponse) String() string
func (*SearchSolutionsResponse) XXX_DiscardUnknown ¶
func (m *SearchSolutionsResponse) XXX_DiscardUnknown()
func (*SearchSolutionsResponse) XXX_Marshal ¶
func (m *SearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchSolutionsResponse) XXX_Merge ¶
func (m *SearchSolutionsResponse) XXX_Merge(src proto.Message)
func (*SearchSolutionsResponse) XXX_Size ¶
func (m *SearchSolutionsResponse) XXX_Size() int
func (*SearchSolutionsResponse) XXX_Unmarshal ¶
func (m *SearchSolutionsResponse) XXX_Unmarshal(b []byte) error
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server represents a basic distil solution server.
func NewServer ¶
func NewServer(userAgent string, resultDir string, sendDelay int, numUpdates int, errPercentage float64, maxSolutions int) *Server
NewServer creates a new solution server instance. ID maps are initialized with place holder values to support tests without explicit calls to session management.
func (*Server) DataAvailable ¶
func (s *Server) DataAvailable(ctx context.Context, in *DataAvailableRequest) (*DataAvailableResponse, error)
DataAvailable does something
func (*Server) DescribeSolution ¶
func (s *Server) DescribeSolution(ctx context.Context, req *DescribeSolutionRequest) (*DescribeSolutionResponse, error)
DescribeSolution generates a solution description struct for a given solution.
func (*Server) EndSearchSolutions ¶
func (s *Server) EndSearchSolutions(ctx context.Context, req *EndSearchSolutionsRequest) (*EndSearchSolutionsResponse, error)
EndSearchSolutions Releases resources associated with a previusly issued search request. NOTE(cbethune): Does this require that a Stop request has been issued?
func (*Server) FitSolution ¶
func (s *Server) FitSolution(ctx context.Context, req *FitSolutionRequest) (*FitSolutionResponse, error)
FitSolution fits a solution to training data.
func (*Server) GetFitSolutionResults ¶
func (s *Server) GetFitSolutionResults(req *GetFitSolutionResultsRequest, stream Core_GetFitSolutionResultsServer) error
GetFitSolutionResults returns a stream of solution fit result for a previously issued fit request.
func (*Server) GetProduceSolutionResults ¶
func (s *Server) GetProduceSolutionResults(req *GetProduceSolutionResultsRequest, stream Core_GetProduceSolutionResultsServer) error
GetProduceSolutionResults returns a stream of solution results for a previously issued produce request.
func (*Server) GetScoreSolutionResults ¶
func (s *Server) GetScoreSolutionResults(req *GetScoreSolutionResultsRequest, stream Core_GetScoreSolutionResultsServer) error
GetScoreSolutionResults returns a stream of solution score results for a previously issued scoring request.
func (*Server) GetSearchSolutionsResults ¶
func (s *Server) GetSearchSolutionsResults(req *GetSearchSolutionsResultsRequest, stream Core_GetSearchSolutionsResultsServer) error
GetSearchSolutionsResults returns a stream of solution results associated with a previously issued request
func (*Server) Hello ¶
func (s *Server) Hello(ctx context.Context, req *HelloRequest) (*HelloResponse, error)
Hello returns information on what the server supports.
func (*Server) ListPrimitives ¶
func (s *Server) ListPrimitives(ctx context.Context, req *ListPrimitivesRequest) (*ListPrimitivesResponse, error)
ListPrimitives returns a list of TA1 primitives that TA3 is allowed to use in pre-processing solution specifications.
func (*Server) LoadFittedSolution ¶
func (s *Server) LoadFittedSolution(ctx context.Context, in *LoadFittedSolutionRequest) (*LoadFittedSolutionResponse, error)
LoadFittedSolution does something
func (*Server) LoadSolution ¶
func (s *Server) LoadSolution(ctx context.Context, in *LoadSolutionRequest) (*LoadSolutionResponse, error)
LoadSolution does something
func (*Server) ProduceSolution ¶
func (s *Server) ProduceSolution(ctx context.Context, req *ProduceSolutionRequest) (*ProduceSolutionResponse, error)
ProduceSolution executes a solution on supplied data. Solution needs to have previously executed a fit.
func (*Server) SaveFittedSolution ¶
func (s *Server) SaveFittedSolution(ctx context.Context, in *SaveFittedSolutionRequest) (*SaveFittedSolutionResponse, error)
SaveFittedSolution does something
func (*Server) SaveSolution ¶
func (s *Server) SaveSolution(ctx context.Context, in *SaveSolutionRequest) (*SaveSolutionResponse, error)
SaveSolution does something
func (*Server) ScoreSolution ¶
func (s *Server) ScoreSolution(ctx context.Context, req *ScoreSolutionRequest) (*ScoreSolutionResponse, error)
ScoreSolution generates a score for a given solution.
func (*Server) SearchSolutions ¶
func (s *Server) SearchSolutions(ctx context.Context, req *SearchSolutionsRequest) (*SearchSolutionsResponse, error)
SearchSolutions generates a searchID and returns a SearchResponse immediately
func (*Server) SolutionExport ¶
func (s *Server) SolutionExport(ctx context.Context, req *SolutionExportRequest) (*SolutionExportResponse, error)
SolutionExport exports a previously generated solution. The solution needs to have had a fit step executed on it to be valid for export.
func (*Server) StopSearchSolutions ¶
func (s *Server) StopSearchSolutions(ctx context.Context, req *StopSearchSolutionsRequest) (*StopSearchSolutionsResponse, error)
StopSearchSolutions Stops a running solution search request. NOTE(cbethune): Does this allow for a search to be restarted via a search request that uses the same ID?
func (*Server) UpdateProblem ¶
func (s *Server) UpdateProblem(ctx context.Context, req *UpdateProblemRequest) (*UpdateProblemResponse, error)
UpdateProblem updates the problem defintion associated with a search
type ServerRequests ¶
type ServerRequests struct {
// contains filtered or unexported fields
}
ServerRequests provides thread safe access to API request information
func NewServerRequests ¶
func NewServerRequests() *ServerRequests
NewServerRequests creates a new instance of a server request manager
func (*ServerRequests) AddRequest ¶
func (s *ServerRequests) AddRequest(parentID string, requestMsg interface{}) (RequestNode, error)
AddRequest adds a new server API request
func (*ServerRequests) GetRequest ¶
func (s *ServerRequests) GetRequest(requestID string) (RequestNode, error)
GetRequest returns a previously added server API request
func (*ServerRequests) IsComplete ¶
func (s *ServerRequests) IsComplete(requestID string) bool
IsComplete indicates whether or not a server request is in a complete state.
func (*ServerRequests) RemoveRequest ¶
func (s *ServerRequests) RemoveRequest(requestID string) error
RemoveRequest request removes a request node and all of its descendants.
func (*ServerRequests) SetComplete ¶
func (s *ServerRequests) SetComplete(requestID string)
SetComplete marks a server API request as having completed processing
type SolutionExportRequest ¶
type SolutionExportRequest struct { // Found solution to export. SolutionId string `protobuf:"bytes,3,opt,name=solution_id,json=solutionId,proto3" json:"solution_id,omitempty"` // Solution rank to be used for the exported solution. Lower numbers represent // better solutions. Presently evaluation requirements are that ranks should be non-negative // and that each exported pipeline have a different rank. TA3 should make sure not to repeat ranks. // Filenames of exported files are left to be chosen by the TA2 system. Rank float64 `protobuf:"fixed64,2,opt,name=rank,proto3" json:"rank,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Exports a solution for evaluation purposes based on evaluation specifications.
func (*SolutionExportRequest) Descriptor ¶
func (*SolutionExportRequest) Descriptor() ([]byte, []int)
func (*SolutionExportRequest) GetRank ¶
func (m *SolutionExportRequest) GetRank() float64
func (*SolutionExportRequest) GetSolutionId ¶
func (m *SolutionExportRequest) GetSolutionId() string
func (*SolutionExportRequest) ProtoMessage ¶
func (*SolutionExportRequest) ProtoMessage()
func (*SolutionExportRequest) Reset ¶
func (m *SolutionExportRequest) Reset()
func (*SolutionExportRequest) String ¶
func (m *SolutionExportRequest) String() string
func (*SolutionExportRequest) XXX_DiscardUnknown ¶
func (m *SolutionExportRequest) XXX_DiscardUnknown()
func (*SolutionExportRequest) XXX_Marshal ¶
func (m *SolutionExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SolutionExportRequest) XXX_Merge ¶
func (m *SolutionExportRequest) XXX_Merge(src proto.Message)
func (*SolutionExportRequest) XXX_Size ¶
func (m *SolutionExportRequest) XXX_Size() int
func (*SolutionExportRequest) XXX_Unmarshal ¶
func (m *SolutionExportRequest) XXX_Unmarshal(b []byte) error
type SolutionExportResponse ¶
type SolutionExportResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SolutionExportResponse) Descriptor ¶
func (*SolutionExportResponse) Descriptor() ([]byte, []int)
func (*SolutionExportResponse) ProtoMessage ¶
func (*SolutionExportResponse) ProtoMessage()
func (*SolutionExportResponse) Reset ¶
func (m *SolutionExportResponse) Reset()
func (*SolutionExportResponse) String ¶
func (m *SolutionExportResponse) String() string
func (*SolutionExportResponse) XXX_DiscardUnknown ¶
func (m *SolutionExportResponse) XXX_DiscardUnknown()
func (*SolutionExportResponse) XXX_Marshal ¶
func (m *SolutionExportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SolutionExportResponse) XXX_Merge ¶
func (m *SolutionExportResponse) XXX_Merge(src proto.Message)
func (*SolutionExportResponse) XXX_Size ¶
func (m *SolutionExportResponse) XXX_Size() int
func (*SolutionExportResponse) XXX_Unmarshal ¶
func (m *SolutionExportResponse) XXX_Unmarshal(b []byte) error
type SolutionRunUser ¶
type SolutionRunUser struct { // A UUID of the user. It does not have to map to any real ID, just that it is possible // to connect multiple solution actions by the same user together, if necessary. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Was this run because solution was chosen by this user. Chosen bool `protobuf:"varint,2,opt,name=chosen,proto3" json:"chosen,omitempty"` // Textual reason provided by the user why the run was chosen by this user. Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
User associated with the run of the solution.
func (*SolutionRunUser) Descriptor ¶
func (*SolutionRunUser) Descriptor() ([]byte, []int)
func (*SolutionRunUser) GetChosen ¶
func (m *SolutionRunUser) GetChosen() bool
func (*SolutionRunUser) GetId ¶
func (m *SolutionRunUser) GetId() string
func (*SolutionRunUser) GetReason ¶
func (m *SolutionRunUser) GetReason() string
func (*SolutionRunUser) ProtoMessage ¶
func (*SolutionRunUser) ProtoMessage()
func (*SolutionRunUser) Reset ¶
func (m *SolutionRunUser) Reset()
func (*SolutionRunUser) String ¶
func (m *SolutionRunUser) String() string
func (*SolutionRunUser) XXX_DiscardUnknown ¶
func (m *SolutionRunUser) XXX_DiscardUnknown()
func (*SolutionRunUser) XXX_Marshal ¶
func (m *SolutionRunUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SolutionRunUser) XXX_Merge ¶
func (m *SolutionRunUser) XXX_Merge(src proto.Message)
func (*SolutionRunUser) XXX_Size ¶
func (m *SolutionRunUser) XXX_Size() int
func (*SolutionRunUser) XXX_Unmarshal ¶
func (m *SolutionRunUser) XXX_Unmarshal(b []byte) error
type SolutionSearchScore ¶
type SolutionSearchScore struct { ScoringConfiguration *ScoringConfiguration `protobuf:"bytes,1,opt,name=scoring_configuration,json=scoringConfiguration,proto3" json:"scoring_configuration,omitempty"` Scores []*Score `protobuf:"bytes,2,rep,name=scores,proto3" json:"scores,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Description of a TA2 score done during solution search. Because there is a wide range of potential approaches a TA2 can use to score candidate solutions this might not capture what
your TA2 is doing. Feel free to request additions to be able to describe your approach.
func (*SolutionSearchScore) Descriptor ¶
func (*SolutionSearchScore) Descriptor() ([]byte, []int)
func (*SolutionSearchScore) GetScores ¶
func (m *SolutionSearchScore) GetScores() []*Score
func (*SolutionSearchScore) GetScoringConfiguration ¶
func (m *SolutionSearchScore) GetScoringConfiguration() *ScoringConfiguration
func (*SolutionSearchScore) ProtoMessage ¶
func (*SolutionSearchScore) ProtoMessage()
func (*SolutionSearchScore) Reset ¶
func (m *SolutionSearchScore) Reset()
func (*SolutionSearchScore) String ¶
func (m *SolutionSearchScore) String() string
func (*SolutionSearchScore) XXX_DiscardUnknown ¶
func (m *SolutionSearchScore) XXX_DiscardUnknown()
func (*SolutionSearchScore) XXX_Marshal ¶
func (m *SolutionSearchScore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SolutionSearchScore) XXX_Merge ¶
func (m *SolutionSearchScore) XXX_Merge(src proto.Message)
func (*SolutionSearchScore) XXX_Size ¶
func (m *SolutionSearchScore) XXX_Size() int
func (*SolutionSearchScore) XXX_Unmarshal ¶
func (m *SolutionSearchScore) XXX_Unmarshal(b []byte) error
type StepDescription ¶
type StepDescription struct { // Types that are valid to be assigned to Step: // *StepDescription_Primitive // *StepDescription_Pipeline Step isStepDescription_Step `protobuf_oneof:"step"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StepDescription) Descriptor ¶
func (*StepDescription) Descriptor() ([]byte, []int)
func (*StepDescription) GetPipeline ¶
func (m *StepDescription) GetPipeline() *SubpipelineStepDescription
func (*StepDescription) GetPrimitive ¶
func (m *StepDescription) GetPrimitive() *PrimitiveStepDescription
func (*StepDescription) GetStep ¶
func (m *StepDescription) GetStep() isStepDescription_Step
func (*StepDescription) ProtoMessage ¶
func (*StepDescription) ProtoMessage()
func (*StepDescription) Reset ¶
func (m *StepDescription) Reset()
func (*StepDescription) String ¶
func (m *StepDescription) String() string
func (*StepDescription) XXX_DiscardUnknown ¶
func (m *StepDescription) XXX_DiscardUnknown()
func (*StepDescription) XXX_Marshal ¶
func (m *StepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StepDescription) XXX_Merge ¶
func (m *StepDescription) XXX_Merge(src proto.Message)
func (*StepDescription) XXX_OneofFuncs ¶
func (*StepDescription) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*StepDescription) XXX_Size ¶
func (m *StepDescription) XXX_Size() int
func (*StepDescription) XXX_Unmarshal ¶
func (m *StepDescription) XXX_Unmarshal(b []byte) error
type StepDescription_Pipeline ¶
type StepDescription_Pipeline struct {
Pipeline *SubpipelineStepDescription `protobuf:"bytes,2,opt,name=pipeline,proto3,oneof"`
}
type StepDescription_Primitive ¶
type StepDescription_Primitive struct {
Primitive *PrimitiveStepDescription `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}
type StepInput ¶
type StepInput struct { // Data reference. Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StepInput) Descriptor ¶
func (*StepInput) ProtoMessage ¶
func (*StepInput) ProtoMessage()
func (*StepInput) XXX_DiscardUnknown ¶
func (m *StepInput) XXX_DiscardUnknown()
func (*StepInput) XXX_Marshal ¶
func (*StepInput) XXX_Unmarshal ¶
type StepOutput ¶
type StepOutput struct { // Name which becomes part of the data reference. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StepOutput) Descriptor ¶
func (*StepOutput) Descriptor() ([]byte, []int)
func (*StepOutput) GetId ¶
func (m *StepOutput) GetId() string
func (*StepOutput) ProtoMessage ¶
func (*StepOutput) ProtoMessage()
func (*StepOutput) Reset ¶
func (m *StepOutput) Reset()
func (*StepOutput) String ¶
func (m *StepOutput) String() string
func (*StepOutput) XXX_DiscardUnknown ¶
func (m *StepOutput) XXX_DiscardUnknown()
func (*StepOutput) XXX_Marshal ¶
func (m *StepOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StepOutput) XXX_Merge ¶
func (m *StepOutput) XXX_Merge(src proto.Message)
func (*StepOutput) XXX_Size ¶
func (m *StepOutput) XXX_Size() int
func (*StepOutput) XXX_Unmarshal ¶
func (m *StepOutput) XXX_Unmarshal(b []byte) error
type StepProgress ¶
type StepProgress struct { Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"` // If step is a sub-pipeline, then this list contains progress for each step in the // sub-pipeline, in order. // List can be incomplete while the process is in progress. Systems can provide // steps only at the end (when "progress" equals COMPLETED) and not during running. Steps []*StepProgress `protobuf:"bytes,2,rep,name=steps,proto3" json:"steps,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StepProgress) Descriptor ¶
func (*StepProgress) Descriptor() ([]byte, []int)
func (*StepProgress) GetProgress ¶
func (m *StepProgress) GetProgress() *Progress
func (*StepProgress) GetSteps ¶
func (m *StepProgress) GetSteps() []*StepProgress
func (*StepProgress) ProtoMessage ¶
func (*StepProgress) ProtoMessage()
func (*StepProgress) Reset ¶
func (m *StepProgress) Reset()
func (*StepProgress) String ¶
func (m *StepProgress) String() string
func (*StepProgress) XXX_DiscardUnknown ¶
func (m *StepProgress) XXX_DiscardUnknown()
func (*StepProgress) XXX_Marshal ¶
func (m *StepProgress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StepProgress) XXX_Merge ¶
func (m *StepProgress) XXX_Merge(src proto.Message)
func (*StepProgress) XXX_Size ¶
func (m *StepProgress) XXX_Size() int
func (*StepProgress) XXX_Unmarshal ¶
func (m *StepProgress) XXX_Unmarshal(b []byte) error
type StopSearchSolutionsRequest ¶
type StopSearchSolutionsRequest struct { SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Stops the search but leaves all currently found solutions available. If the call is made in parallel with a running search and results are being streamed, the "GetSearchSolutionsResults" stream is closed by the TA2 (as happens when the search is concluded on its own). Search cannot be re-started after it has been stopped.
func (*StopSearchSolutionsRequest) Descriptor ¶
func (*StopSearchSolutionsRequest) Descriptor() ([]byte, []int)
func (*StopSearchSolutionsRequest) GetSearchId ¶
func (m *StopSearchSolutionsRequest) GetSearchId() string
func (*StopSearchSolutionsRequest) ProtoMessage ¶
func (*StopSearchSolutionsRequest) ProtoMessage()
func (*StopSearchSolutionsRequest) Reset ¶
func (m *StopSearchSolutionsRequest) Reset()
func (*StopSearchSolutionsRequest) String ¶
func (m *StopSearchSolutionsRequest) String() string
func (*StopSearchSolutionsRequest) XXX_DiscardUnknown ¶
func (m *StopSearchSolutionsRequest) XXX_DiscardUnknown()
func (*StopSearchSolutionsRequest) XXX_Marshal ¶
func (m *StopSearchSolutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopSearchSolutionsRequest) XXX_Merge ¶
func (m *StopSearchSolutionsRequest) XXX_Merge(src proto.Message)
func (*StopSearchSolutionsRequest) XXX_Size ¶
func (m *StopSearchSolutionsRequest) XXX_Size() int
func (*StopSearchSolutionsRequest) XXX_Unmarshal ¶
func (m *StopSearchSolutionsRequest) XXX_Unmarshal(b []byte) error
type StopSearchSolutionsResponse ¶
type StopSearchSolutionsResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopSearchSolutionsResponse) Descriptor ¶
func (*StopSearchSolutionsResponse) Descriptor() ([]byte, []int)
func (*StopSearchSolutionsResponse) ProtoMessage ¶
func (*StopSearchSolutionsResponse) ProtoMessage()
func (*StopSearchSolutionsResponse) Reset ¶
func (m *StopSearchSolutionsResponse) Reset()
func (*StopSearchSolutionsResponse) String ¶
func (m *StopSearchSolutionsResponse) String() string
func (*StopSearchSolutionsResponse) XXX_DiscardUnknown ¶
func (m *StopSearchSolutionsResponse) XXX_DiscardUnknown()
func (*StopSearchSolutionsResponse) XXX_Marshal ¶
func (m *StopSearchSolutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopSearchSolutionsResponse) XXX_Merge ¶
func (m *StopSearchSolutionsResponse) XXX_Merge(src proto.Message)
func (*StopSearchSolutionsResponse) XXX_Size ¶
func (m *StopSearchSolutionsResponse) XXX_Size() int
func (*StopSearchSolutionsResponse) XXX_Unmarshal ¶
func (m *StopSearchSolutionsResponse) XXX_Unmarshal(b []byte) error
type SubpipelinePipelineDescriptionStep ¶
type SubpipelinePipelineDescriptionStep struct { // Only "id" field is required in this case to reference another pipeline in the template. Pipeline *PipelineDescription `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // List of data references, probably of an output of a step or pipeline input, // mapped to sub-pipeline's inputs in order. Inputs []*StepInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` // List of IDs to be used in data references, mapping sub-pipeline's outputs in order. Outputs []*StepOutput `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SubpipelinePipelineDescriptionStep) Descriptor ¶
func (*SubpipelinePipelineDescriptionStep) Descriptor() ([]byte, []int)
func (*SubpipelinePipelineDescriptionStep) GetInputs ¶
func (m *SubpipelinePipelineDescriptionStep) GetInputs() []*StepInput
func (*SubpipelinePipelineDescriptionStep) GetOutputs ¶
func (m *SubpipelinePipelineDescriptionStep) GetOutputs() []*StepOutput
func (*SubpipelinePipelineDescriptionStep) GetPipeline ¶
func (m *SubpipelinePipelineDescriptionStep) GetPipeline() *PipelineDescription
func (*SubpipelinePipelineDescriptionStep) ProtoMessage ¶
func (*SubpipelinePipelineDescriptionStep) ProtoMessage()
func (*SubpipelinePipelineDescriptionStep) Reset ¶
func (m *SubpipelinePipelineDescriptionStep) Reset()
func (*SubpipelinePipelineDescriptionStep) String ¶
func (m *SubpipelinePipelineDescriptionStep) String() string
func (*SubpipelinePipelineDescriptionStep) XXX_DiscardUnknown ¶
func (m *SubpipelinePipelineDescriptionStep) XXX_DiscardUnknown()
func (*SubpipelinePipelineDescriptionStep) XXX_Marshal ¶
func (m *SubpipelinePipelineDescriptionStep) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubpipelinePipelineDescriptionStep) XXX_Merge ¶
func (m *SubpipelinePipelineDescriptionStep) XXX_Merge(src proto.Message)
func (*SubpipelinePipelineDescriptionStep) XXX_Size ¶
func (m *SubpipelinePipelineDescriptionStep) XXX_Size() int
func (*SubpipelinePipelineDescriptionStep) XXX_Unmarshal ¶
func (m *SubpipelinePipelineDescriptionStep) XXX_Unmarshal(b []byte) error
type SubpipelineStepDescription ¶
type SubpipelineStepDescription struct { // Each step in a sub-pipeline has a description. These are reported in the order of steps // in the sub-pipeline. Steps []*StepDescription `protobuf:"bytes,1,rep,name=steps,proto3" json:"steps,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SubpipelineStepDescription) Descriptor ¶
func (*SubpipelineStepDescription) Descriptor() ([]byte, []int)
func (*SubpipelineStepDescription) GetSteps ¶
func (m *SubpipelineStepDescription) GetSteps() []*StepDescription
func (*SubpipelineStepDescription) ProtoMessage ¶
func (*SubpipelineStepDescription) ProtoMessage()
func (*SubpipelineStepDescription) Reset ¶
func (m *SubpipelineStepDescription) Reset()
func (*SubpipelineStepDescription) String ¶
func (m *SubpipelineStepDescription) String() string
func (*SubpipelineStepDescription) XXX_DiscardUnknown ¶
func (m *SubpipelineStepDescription) XXX_DiscardUnknown()
func (*SubpipelineStepDescription) XXX_Marshal ¶
func (m *SubpipelineStepDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubpipelineStepDescription) XXX_Merge ¶
func (m *SubpipelineStepDescription) XXX_Merge(src proto.Message)
func (*SubpipelineStepDescription) XXX_Size ¶
func (m *SubpipelineStepDescription) XXX_Size() int
func (*SubpipelineStepDescription) XXX_Unmarshal ¶
func (m *SubpipelineStepDescription) XXX_Unmarshal(b []byte) error
type TaskSubtype ¶
type TaskSubtype int32
Secondary classification of the problem.
const ( // Default value. Not to be used. TaskSubtype_TASK_SUBTYPE_UNDEFINED TaskSubtype = 0 // No secondary task is applicable for this problem. TaskSubtype_NONE TaskSubtype = 1 TaskSubtype_BINARY TaskSubtype = 2 TaskSubtype_MULTICLASS TaskSubtype = 3 TaskSubtype_MULTILABEL TaskSubtype = 4 TaskSubtype_UNIVARIATE TaskSubtype = 5 TaskSubtype_MULTIVARIATE TaskSubtype = 6 TaskSubtype_OVERLAPPING TaskSubtype = 7 TaskSubtype_NONOVERLAPPING TaskSubtype = 8 )
func (TaskSubtype) EnumDescriptor ¶
func (TaskSubtype) EnumDescriptor() ([]byte, []int)
func (TaskSubtype) String ¶
func (x TaskSubtype) String() string
type TaskType ¶
type TaskType int32
Top level classification of the problem.
const ( // Default value. Not to be used. TaskType_TASK_TYPE_UNDEFINED TaskType = 0 TaskType_CLASSIFICATION TaskType = 1 TaskType_REGRESSION TaskType = 2 TaskType_CLUSTERING TaskType = 3 TaskType_LINK_PREDICTION TaskType = 4 TaskType_VERTEX_NOMINATION TaskType = 5 TaskType_VERTEX_CLASSIFICATION TaskType = 6 TaskType_COMMUNITY_DETECTION TaskType = 7 TaskType_GRAPH_MATCHING TaskType = 8 TaskType_TIME_SERIES_FORECASTING TaskType = 9 TaskType_COLLABORATIVE_FILTERING TaskType = 10 TaskType_OBJECT_DETECTION TaskType = 11 TaskType_SEMISUPERVISED_CLASSIFICATION TaskType = 12 TaskType_SEMISUPERVISED_REGRESSION TaskType = 13 )
func (TaskType) EnumDescriptor ¶
type UpdateProblemRequest ¶
type UpdateProblemRequest struct { SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"` // New problem description. It has to be provided in full and it replaces existing // problem description. Problem *ProblemDescription `protobuf:"bytes,2,opt,name=problem,proto3" json:"problem,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Updates problem with new description. This also updates the problem description for all ongoing solution searches associated with this problem. Internal behavior of TA2 is unspecified: it can simply start a new search using new problem description, or it can start modifying solutions it has already found to new problem description, or it can use it to further help narrow down ongoing solution searches. In any case, after this call returns, all reported solutions for searches associated with this problem should be for the updated problem description.
func (*UpdateProblemRequest) Descriptor ¶
func (*UpdateProblemRequest) Descriptor() ([]byte, []int)
func (*UpdateProblemRequest) GetProblem ¶
func (m *UpdateProblemRequest) GetProblem() *ProblemDescription
func (*UpdateProblemRequest) GetSearchId ¶
func (m *UpdateProblemRequest) GetSearchId() string
func (*UpdateProblemRequest) ProtoMessage ¶
func (*UpdateProblemRequest) ProtoMessage()
func (*UpdateProblemRequest) Reset ¶
func (m *UpdateProblemRequest) Reset()
func (*UpdateProblemRequest) String ¶
func (m *UpdateProblemRequest) String() string
func (*UpdateProblemRequest) XXX_DiscardUnknown ¶
func (m *UpdateProblemRequest) XXX_DiscardUnknown()
func (*UpdateProblemRequest) XXX_Marshal ¶
func (m *UpdateProblemRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateProblemRequest) XXX_Merge ¶
func (m *UpdateProblemRequest) XXX_Merge(src proto.Message)
func (*UpdateProblemRequest) XXX_Size ¶
func (m *UpdateProblemRequest) XXX_Size() int
func (*UpdateProblemRequest) XXX_Unmarshal ¶
func (m *UpdateProblemRequest) XXX_Unmarshal(b []byte) error
type UpdateProblemResponse ¶
type UpdateProblemResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateProblemResponse) Descriptor ¶
func (*UpdateProblemResponse) Descriptor() ([]byte, []int)
func (*UpdateProblemResponse) ProtoMessage ¶
func (*UpdateProblemResponse) ProtoMessage()
func (*UpdateProblemResponse) Reset ¶
func (m *UpdateProblemResponse) Reset()
func (*UpdateProblemResponse) String ¶
func (m *UpdateProblemResponse) String() string
func (*UpdateProblemResponse) XXX_DiscardUnknown ¶
func (m *UpdateProblemResponse) XXX_DiscardUnknown()
func (*UpdateProblemResponse) XXX_Marshal ¶
func (m *UpdateProblemResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateProblemResponse) XXX_Merge ¶
func (m *UpdateProblemResponse) XXX_Merge(src proto.Message)
func (*UpdateProblemResponse) XXX_Size ¶
func (m *UpdateProblemResponse) XXX_Size() int
func (*UpdateProblemResponse) XXX_Unmarshal ¶
func (m *UpdateProblemResponse) XXX_Unmarshal(b []byte) error
type Value ¶
type Value struct { // Types that are valid to be assigned to Value: // *Value_Error // *Value_Raw // *Value_DatasetUri // *Value_CsvUri // *Value_PickleUri // *Value_PickleBlob // *Value_PlasmaId Value isValue_Value `protobuf_oneof:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Value) Descriptor ¶
func (*Value) GetDatasetUri ¶
func (*Value) GetError ¶
func (m *Value) GetError() *ValueError
func (*Value) GetPickleBlob ¶
func (*Value) GetPickleUri ¶
func (*Value) GetPlasmaId ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) XXX_DiscardUnknown ¶
func (m *Value) XXX_DiscardUnknown()
func (*Value) XXX_Marshal ¶
func (*Value) XXX_OneofFuncs ¶
func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Value) XXX_Unmarshal ¶
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) ProtoMessage ¶
func (*ValueDict) ProtoMessage()
func (*ValueDict) XXX_DiscardUnknown ¶
func (m *ValueDict) XXX_DiscardUnknown()
func (*ValueDict) XXX_Marshal ¶
func (*ValueDict) XXX_Unmarshal ¶
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) ProtoMessage ¶
func (*ValueList) ProtoMessage()
func (*ValueList) XXX_DiscardUnknown ¶
func (m *ValueList) XXX_DiscardUnknown()
func (*ValueList) XXX_Marshal ¶
func (*ValueList) XXX_Unmarshal ¶
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) GetString_ ¶
func (*ValueRaw) ProtoMessage ¶
func (*ValueRaw) ProtoMessage()
func (*ValueRaw) XXX_DiscardUnknown ¶
func (m *ValueRaw) XXX_DiscardUnknown()
func (*ValueRaw) XXX_Marshal ¶
func (*ValueRaw) XXX_OneofFuncs ¶
func (*ValueRaw) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*ValueRaw) XXX_Unmarshal ¶
type ValueRaw_Bool ¶
type ValueRaw_Bool struct {
Bool bool `protobuf:"varint,4,opt,name=bool,proto3,oneof"`
}
type ValueRaw_Bytes ¶
type ValueRaw_Bytes struct {
Bytes []byte `protobuf:"bytes,6,opt,name=bytes,proto3,oneof"`
}
type ValueRaw_Dict ¶
type ValueRaw_Dict struct {
Dict *ValueDict `protobuf:"bytes,8,opt,name=dict,proto3,oneof"`
}
type ValueRaw_Double ¶
type ValueRaw_Double struct {
Double float64 `protobuf:"fixed64,2,opt,name=double,proto3,oneof"`
}
type ValueRaw_Int64 ¶
type ValueRaw_Int64 struct {
Int64 int64 `protobuf:"varint,3,opt,name=int64,proto3,oneof"`
}
type ValueRaw_List ¶
type ValueRaw_List struct {
List *ValueList `protobuf:"bytes,7,opt,name=list,proto3,oneof"`
}
type ValueRaw_Null ¶
type ValueRaw_Null struct {
Null NullValue `protobuf:"varint,1,opt,name=null,proto3,enum=NullValue,oneof"`
}
type ValueRaw_String_ ¶
type ValueRaw_String_ struct {
String_ string `protobuf:"bytes,5,opt,name=string,proto3,oneof"`
}
type ValueType ¶
type ValueType int32
const ( // Default value. Not to be used. ValueType_VALUE_TYPE_UNDEFINED ValueType = 0 // Raw value. Not all values can be represented as a raw value. // The value before encoding should be at most 64 KB. ValueType_RAW ValueType = 1 // Represent the value as a D3M dataset. Only "file://" schema is supported using a // shared file system. Dataset URI should point to the "datasetDoc.json" file of the dataset. // Only Dataset container values can be represented this way. ValueType_DATASET_URI ValueType = 2 // Represent the value as a CSV file. Only "file://" schema is supported using a // shared file system. CSV URI should point to the file with ".csv" file extension. // Only tabular container values with numeric and string cell values can be represented // this way. ValueType_CSV_URI ValueType = 3 // Represent values by Python-pickling them. Only "file://" schema is supported using a // shared file system. Pickle URI should point to the file with ".pickle" file extension. ValueType_PICKLE_URI ValueType = 4 // Represent values by Python-pickling them but sending them through the API. // The value before encoding should be at most 64 KB. ValueType_PICKLE_BLOB ValueType = 5 // Represent values with arrow and storing them into shared instance of Plasma. ValueType_PLASMA_ID ValueType = 6 // Same as "RAW", but without any size limit. ValueType_LARGE_RAW ValueType = 7 // Same as "PICKLE_BLOB", but without any size limit. ValueType_LARGE_PICKLE_BLOB ValueType = 8 )
func (ValueType) EnumDescriptor ¶
type Value_CsvUri ¶
type Value_CsvUri struct {
CsvUri string `protobuf:"bytes,4,opt,name=csv_uri,json=csvUri,proto3,oneof"`
}
type Value_DatasetUri ¶
type Value_DatasetUri struct {
DatasetUri string `protobuf:"bytes,3,opt,name=dataset_uri,json=datasetUri,proto3,oneof"`
}
type Value_Error ¶
type Value_Error struct {
Error *ValueError `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}
type Value_PickleBlob ¶
type Value_PickleBlob struct {
PickleBlob []byte `protobuf:"bytes,6,opt,name=pickle_blob,json=pickleBlob,proto3,oneof"`
}
type Value_PickleUri ¶
type Value_PickleUri struct {
PickleUri string `protobuf:"bytes,5,opt,name=pickle_uri,json=pickleUri,proto3,oneof"`
}
type Value_PlasmaId ¶
type Value_PlasmaId struct {
PlasmaId []byte `protobuf:"bytes,7,opt,name=plasma_id,json=plasmaId,proto3,oneof"`
}