ml

package
v1.11.1 Latest Latest
Warning

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

Go to latest
Published: Feb 2, 2021 License: Apache-2.0 Imports: 5 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClassificationReport

type ClassificationReport map[string]interface{}

type ClusteringReport

type ClusteringReport map[string]interface{}

type CrossValidation

type CrossValidation struct {
	// Number of folds in the K-fold cross validation.
	KFold *int32 `json:"kFold,omitempty"`
	// Random state to shuffle and partition data.
	RandomSeed *int32 `json:"randomSeed,omitempty"`
	// Determine whether stratification is used in partitioning the data.
	Stratified *bool `json:"stratified,omitempty"`
}

type CrossValidationScore

type CrossValidationScore []map[string]interface{}

type DeploymentSpec

type DeploymentSpec struct {
	// CPU Resource limit for each container in a deployment.
	CpuLimit *string `json:"cpuLimit,omitempty"`
	// CPU Resource limit for serving requests.
	CpuRequest *string `json:"cpuRequest,omitempty"`
	// Memory Resource limit for each container in a deployment.
	MemoryLimit *string `json:"memoryLimit,omitempty"`
	// Memory Resource limit for serving requests.
	MemoryRequest *string `json:"memoryRequest,omitempty"`
	// Create replicated pods in a deployment.
	Replicas *int32 `json:"replicas,omitempty"`
}

type Error

type Error struct {
	Code    string                   `json:"code"`
	Message string                   `json:"message"`
	Details []map[string]interface{} `json:"details,omitempty"`
}

type Events

type Events struct {
	// Specifies a JSON object that contains explicit custom fields to be defined at index time.
	Attributes map[string]interface{} `json:"attributes,omitempty"`
	// Splunk host field.
	Host *string `json:"host,omitempty"`
	// Splunk source field.
	Source *string `json:"source,omitempty"`
	// Splunk sourcetype field.
	Sourcetype *string `json:"sourcetype,omitempty"`
}

Output events to the Ingest /events endpoint.

type ExecutorErrors

type ExecutorErrors struct {
	Message *string `json:"message,omitempty"`
}

Executor errors.

type ExecutorLogs

type ExecutorLogs struct {
	Level   *string `json:"level,omitempty"`
	Message *string `json:"message,omitempty"`
}

Executor logs.

type Fields

type Fields struct {
	// Fields necessary for task.
	Features []string `json:"features"`
	// Fields produced by task.
	Created []string `json:"created,omitempty"`
	// Target field necessary for task.
	Target *string `json:"target,omitempty"`
}

type FitTask

type FitTask struct {
	Algorithm string       `json:"algorithm"`
	Fields    Fields       `json:"fields"`
	Kind      *FitTaskKind `json:"kind,omitempty"`
	// The name has to be unique in the same workflow, it is optional, can be used to identify that task artifact.
	Name              *string                `json:"name,omitempty"`
	OutputTransformer *string                `json:"outputTransformer,omitempty"`
	Parameters        map[string]interface{} `json:"parameters,omitempty"`
}

Fit task does an estimation/training/fitting, fit task outputs a transformer.

type FitTaskKind

type FitTaskKind string
const (
	FitTaskKindFit FitTaskKind = "fit"
)

List of FitTaskKind

type ForecastingReport

type ForecastingReport map[string]interface{}

type InputData

type InputData struct {
	Kind   InputDataKind   `json:"kind"`
	Source InputDataSource `json:"source"`
}

type InputDataKind

type InputDataKind string
const (
	InputDataKindSpl     InputDataKind = "SPL"
	InputDataKindRawData InputDataKind = "RawData"
)

List of InputDataKind

type InputDataSource

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

InputDataSource is RawData, Spl, (or interface{} if no matches are found)

func MakeInputDataSourceFromRawData

func MakeInputDataSourceFromRawData(f RawData) InputDataSource

MakeInputDataSourceFromRawData creates a new InputDataSource from an instance of RawData

func MakeInputDataSourceFromRawInterface

func MakeInputDataSourceFromRawInterface(f interface{}) InputDataSource

MakeInputDataSourceFromRawInterface creates a new InputDataSource from a raw interface{}

func MakeInputDataSourceFromSpl

func MakeInputDataSourceFromSpl(f Spl) InputDataSource

MakeInputDataSourceFromSpl creates a new InputDataSource from an instance of Spl

func (InputDataSource) IsRawData

func (m InputDataSource) IsRawData() bool

IsRawData checks if the InputDataSource is a RawData

func (InputDataSource) IsRawInterface

func (m InputDataSource) IsRawInterface() bool

IsRawInterface checks if the InputDataSource is an interface{} (unknown type)

func (InputDataSource) IsSpl

func (m InputDataSource) IsSpl() bool

IsSpl checks if the InputDataSource is a Spl

func (InputDataSource) MarshalJSON

func (m InputDataSource) MarshalJSON() ([]byte, error)

MarshalJSON marshals InputDataSource using InputDataSource.InputDataSource

func (InputDataSource) RawData

func (m InputDataSource) RawData() *RawData

RawData returns RawData if IsRawData() is true, nil otherwise

func (InputDataSource) RawInterface

func (m InputDataSource) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (InputDataSource) Spl

func (m InputDataSource) Spl() *Spl

Spl returns Spl if IsSpl() is true, nil otherwise

func (*InputDataSource) UnmarshalJSON

func (m *InputDataSource) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals InputDataSource into RawData, Spl, or interface{} if no matches are found

type InputStream

type InputStream struct {
	Kind   InputStreamKind   `json:"kind"`
	Source InputStreamSource `json:"source"`
}

type InputStreamKind

type InputStreamKind string
const (
	InputStreamKindKafka InputStreamKind = "Kafka"
)

List of InputStreamKind

type InputStreamSource

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

InputStreamSource is KafkaInput, (or interface{} if no matches are found)

func MakeInputStreamSourceFromKafkaInput

func MakeInputStreamSourceFromKafkaInput(f KafkaInput) InputStreamSource

MakeInputStreamSourceFromKafkaInput creates a new InputStreamSource from an instance of KafkaInput

func MakeInputStreamSourceFromRawInterface

func MakeInputStreamSourceFromRawInterface(f interface{}) InputStreamSource

MakeInputStreamSourceFromRawInterface creates a new InputStreamSource from a raw interface{}

func (InputStreamSource) IsKafkaInput

func (m InputStreamSource) IsKafkaInput() bool

IsKafkaInput checks if the InputStreamSource is a KafkaInput

func (InputStreamSource) IsRawInterface

func (m InputStreamSource) IsRawInterface() bool

IsRawInterface checks if the InputStreamSource is an interface{} (unknown type)

func (InputStreamSource) KafkaInput

func (m InputStreamSource) KafkaInput() *KafkaInput

KafkaInput returns KafkaInput if IsKafkaInput() is true, nil otherwise

func (InputStreamSource) MarshalJSON

func (m InputStreamSource) MarshalJSON() ([]byte, error)

MarshalJSON marshals InputStreamSource using InputStreamSource.InputStreamSource

func (InputStreamSource) RawInterface

func (m InputStreamSource) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (*InputStreamSource) UnmarshalJSON

func (m *InputStreamSource) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals InputStreamSource into KafkaInput, or interface{} if no matches are found

type InputStreamSourceOffsetReset

type InputStreamSourceOffsetReset string
const (
	InputStreamSourceOffsetResetEarliest InputStreamSourceOffsetReset = "earliest"
	InputStreamSourceOffsetResetLatest   InputStreamSourceOffsetReset = "latest"
)

List of InputStreamSourceOffsetReset

type KafkaInput

type KafkaInput struct {
	Topic       string                 `json:"topic"`
	OffsetReset *KafkaInputOffsetReset `json:"offsetReset,omitempty"`
}

type KafkaInputOffsetReset

type KafkaInputOffsetReset string
const (
	KafkaInputOffsetResetEarliest KafkaInputOffsetReset = "earliest"
	KafkaInputOffsetResetLatest   KafkaInputOffsetReset = "latest"
)

List of KafkaInputOffsetReset

type KafkaOutput

type KafkaOutput struct {
	Topic string `json:"topic"`
}

type OutputData

type OutputData struct {
	Destination *OutputDataDestination `json:"destination,omitempty"`
	Kind        *OutputDataKind        `json:"kind,omitempty"`
}

type OutputDataDestination

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

OutputDataDestination is Events, (or interface{} if no matches are found)

func MakeOutputDataDestinationFromEvents

func MakeOutputDataDestinationFromEvents(f Events) OutputDataDestination

MakeOutputDataDestinationFromEvents creates a new OutputDataDestination from an instance of Events

func MakeOutputDataDestinationFromRawInterface

func MakeOutputDataDestinationFromRawInterface(f interface{}) OutputDataDestination

MakeOutputDataDestinationFromRawInterface creates a new OutputDataDestination from a raw interface{}

func (OutputDataDestination) Events

func (m OutputDataDestination) Events() *Events

Events returns Events if IsEvents() is true, nil otherwise

func (OutputDataDestination) IsEvents

func (m OutputDataDestination) IsEvents() bool

IsEvents checks if the OutputDataDestination is a Events

func (OutputDataDestination) IsRawInterface

func (m OutputDataDestination) IsRawInterface() bool

IsRawInterface checks if the OutputDataDestination is an interface{} (unknown type)

func (OutputDataDestination) MarshalJSON

func (m OutputDataDestination) MarshalJSON() ([]byte, error)

MarshalJSON marshals OutputDataDestination using OutputDataDestination.OutputDataDestination

func (OutputDataDestination) RawInterface

func (m OutputDataDestination) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (*OutputDataDestination) UnmarshalJSON

func (m *OutputDataDestination) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals OutputDataDestination into Events, or interface{} if no matches are found

type OutputDataKind

type OutputDataKind string
const (
	OutputDataKindEvents OutputDataKind = "Events"
)

List of OutputDataKind

type OutputStream

type OutputStream struct {
	Destination OutputStreamDestination `json:"destination"`
	Kind        OutputStreamKind        `json:"kind"`
}

type OutputStreamDestination

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

OutputStreamDestination is KafkaOutput, (or interface{} if no matches are found)

func MakeOutputStreamDestinationFromKafkaOutput

func MakeOutputStreamDestinationFromKafkaOutput(f KafkaOutput) OutputStreamDestination

MakeOutputStreamDestinationFromKafkaOutput creates a new OutputStreamDestination from an instance of KafkaOutput

func MakeOutputStreamDestinationFromRawInterface

func MakeOutputStreamDestinationFromRawInterface(f interface{}) OutputStreamDestination

MakeOutputStreamDestinationFromRawInterface creates a new OutputStreamDestination from a raw interface{}

func (OutputStreamDestination) IsKafkaOutput

func (m OutputStreamDestination) IsKafkaOutput() bool

IsKafkaOutput checks if the OutputStreamDestination is a KafkaOutput

func (OutputStreamDestination) IsRawInterface

func (m OutputStreamDestination) IsRawInterface() bool

IsRawInterface checks if the OutputStreamDestination is an interface{} (unknown type)

func (OutputStreamDestination) KafkaOutput

func (m OutputStreamDestination) KafkaOutput() *KafkaOutput

KafkaOutput returns KafkaOutput if IsKafkaOutput() is true, nil otherwise

func (OutputStreamDestination) MarshalJSON

func (m OutputStreamDestination) MarshalJSON() ([]byte, error)

MarshalJSON marshals OutputStreamDestination using OutputStreamDestination.OutputStreamDestination

func (OutputStreamDestination) RawInterface

func (m OutputStreamDestination) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (*OutputStreamDestination) UnmarshalJSON

func (m *OutputStreamDestination) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals OutputStreamDestination into KafkaOutput, or interface{} if no matches are found

type OutputStreamKind

type OutputStreamKind string
const (
	OutputStreamKindKafka OutputStreamKind = "Kafka"
)

List of OutputStreamKind

type RawData

type RawData struct {
	// A base-64 encoded CSV string.
	Data *string `json:"data,omitempty"`
}

Send data directly via the reqest body as a base-64 encoded CSV string.

type RegressionReport

type RegressionReport map[string]interface{}

type Score

type Score struct {
	Kind   ScoreKind   `json:"kind"`
	Report ScoreReport `json:"report"`
}

type ScoreKind

type ScoreKind string
const (
	ScoreKindRegression     ScoreKind = "regression"
	ScoreKindClassification ScoreKind = "classification"
	ScoreKindClustering     ScoreKind = "clustering"
	ScoreKindForecasting    ScoreKind = "forecasting"
)

List of ScoreKind

type ScoreReport

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

ScoreReport is ClassificationReport, ClusteringReport, ForecastingReport, RegressionReport, (or interface{} if no matches are found)

func MakeScoreReportFromClassificationReport

func MakeScoreReportFromClassificationReport(f ClassificationReport) ScoreReport

MakeScoreReportFromClassificationReport creates a new ScoreReport from an instance of ClassificationReport

func MakeScoreReportFromClusteringReport

func MakeScoreReportFromClusteringReport(f ClusteringReport) ScoreReport

MakeScoreReportFromClusteringReport creates a new ScoreReport from an instance of ClusteringReport

func MakeScoreReportFromForecastingReport

func MakeScoreReportFromForecastingReport(f ForecastingReport) ScoreReport

MakeScoreReportFromForecastingReport creates a new ScoreReport from an instance of ForecastingReport

func MakeScoreReportFromRawInterface

func MakeScoreReportFromRawInterface(f interface{}) ScoreReport

MakeScoreReportFromRawInterface creates a new ScoreReport from a raw interface{}

func MakeScoreReportFromRegressionReport

func MakeScoreReportFromRegressionReport(f RegressionReport) ScoreReport

MakeScoreReportFromRegressionReport creates a new ScoreReport from an instance of RegressionReport

func (ScoreReport) ClassificationReport

func (m ScoreReport) ClassificationReport() *ClassificationReport

ClassificationReport returns ClassificationReport if IsClassificationReport() is true, nil otherwise

func (ScoreReport) ClusteringReport

func (m ScoreReport) ClusteringReport() *ClusteringReport

ClusteringReport returns ClusteringReport if IsClusteringReport() is true, nil otherwise

func (ScoreReport) ForecastingReport

func (m ScoreReport) ForecastingReport() *ForecastingReport

ForecastingReport returns ForecastingReport if IsForecastingReport() is true, nil otherwise

func (ScoreReport) IsClassificationReport

func (m ScoreReport) IsClassificationReport() bool

IsClassificationReport checks if the ScoreReport is a ClassificationReport

func (ScoreReport) IsClusteringReport

func (m ScoreReport) IsClusteringReport() bool

IsClusteringReport checks if the ScoreReport is a ClusteringReport

func (ScoreReport) IsForecastingReport

func (m ScoreReport) IsForecastingReport() bool

IsForecastingReport checks if the ScoreReport is a ForecastingReport

func (ScoreReport) IsRawInterface

func (m ScoreReport) IsRawInterface() bool

IsRawInterface checks if the ScoreReport is an interface{} (unknown type)

func (ScoreReport) IsRegressionReport

func (m ScoreReport) IsRegressionReport() bool

IsRegressionReport checks if the ScoreReport is a RegressionReport

func (ScoreReport) MarshalJSON

func (m ScoreReport) MarshalJSON() ([]byte, error)

MarshalJSON marshals ScoreReport using ScoreReport.ScoreReport

func (ScoreReport) RawInterface

func (m ScoreReport) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (ScoreReport) RegressionReport

func (m ScoreReport) RegressionReport() *RegressionReport

RegressionReport returns RegressionReport if IsRegressionReport() is true, nil otherwise

func (*ScoreReport) UnmarshalJSON

func (m *ScoreReport) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals ScoreReport into ClassificationReport, ClusteringReport, ForecastingReport, RegressionReport, or interface{} if no matches are found

type Service

type Service services.BaseService

func NewService

func NewService(iClient services.IClient) *Service

NewService creates a new ml service client from the given Config

func (*Service) CreateWorkflow

func (s *Service) CreateWorkflow(workflow Workflow, resp ...*http.Response) (*Workflow, error)

CreateWorkflow - Creates a workflow configuration. Parameters:

workflow: Workflow configuration to be created.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) CreateWorkflowBuild

func (s *Service) CreateWorkflowBuild(id string, workflowBuild WorkflowBuild, resp ...*http.Response) (*WorkflowBuild, error)

CreateWorkflowBuild - Creates a workflow build. Parameters:

id: The workflow ID.
workflowBuild: Input data used to build the workflow.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) CreateWorkflowDeployment

func (s *Service) CreateWorkflowDeployment(id string, buildId string, workflowDeployment WorkflowDeployment, resp ...*http.Response) (*WorkflowDeployment, error)

CreateWorkflowDeployment - Creates a workflow deployment. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
workflowDeployment: Input data used to build the workflow deployment.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) CreateWorkflowInference

func (s *Service) CreateWorkflowInference(id string, buildId string, deploymentId string, workflowInference WorkflowInference, resp ...*http.Response) (*WorkflowInference, error)

CreateWorkflowInference - Creates a workflow inference request. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
deploymentId: The workflow deployment ID.
workflowInference: Input data to the inference request.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) CreateWorkflowRun

func (s *Service) CreateWorkflowRun(id string, buildId string, workflowRun WorkflowRun, resp ...*http.Response) (*WorkflowRun, error)

CreateWorkflowRun - Creates a workflow run. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
workflowRun: Input data used to build the workflow.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) CreateWorkflowStreamDeployment

func (s *Service) CreateWorkflowStreamDeployment(id string, buildId string, workflowStreamDeployment WorkflowStreamDeployment, resp ...*http.Response) (*WorkflowStreamDeployment, error)

CreateWorkflowStreamDeployment - Creates a workflow streaming deployment. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
workflowStreamDeployment: Configuration for the workflow streaming deployment.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) DeleteWorkflow

func (s *Service) DeleteWorkflow(id string, resp ...*http.Response) error

DeleteWorkflow - Removes a workflow configuration. Parameters:

id: The workflow ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) DeleteWorkflowBuild

func (s *Service) DeleteWorkflowBuild(id string, buildId string, resp ...*http.Response) error

DeleteWorkflowBuild - Removes a workflow build. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) DeleteWorkflowDeployment

func (s *Service) DeleteWorkflowDeployment(id string, buildId string, deploymentId string, resp ...*http.Response) error

DeleteWorkflowDeployment - Removes a workflow deployment. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
deploymentId: The workflow deployment ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) DeleteWorkflowRun

func (s *Service) DeleteWorkflowRun(id string, buildId string, runId string, resp ...*http.Response) error

DeleteWorkflowRun - Removes a workflow run. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
runId: The workflow run ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) DeleteWorkflowStreamDeployment

func (s *Service) DeleteWorkflowStreamDeployment(id string, buildId string, streamDeploymentId string, resp ...*http.Response) error

DeleteWorkflowStreamDeployment - Removes a workflow streaming deployment. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
streamDeploymentId: The workflow streaming deployment ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflow

func (s *Service) GetWorkflow(id string, resp ...*http.Response) (*Workflow, error)

GetWorkflow - Returns a workflow configuration. Parameters:

id: The workflow ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowBuild

func (s *Service) GetWorkflowBuild(id string, buildId string, resp ...*http.Response) (*WorkflowBuild, error)

GetWorkflowBuild - Returns the status of a workflow build. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowBuildError

func (s *Service) GetWorkflowBuildError(id string, buildId string, resp ...*http.Response) (*WorkflowBuildError, error)

GetWorkflowBuildError - Returns a list of workflow errors. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowBuildLog

func (s *Service) GetWorkflowBuildLog(id string, buildId string, resp ...*http.Response) (*WorkflowBuildLog, error)

GetWorkflowBuildLog - Returns the logs from a workflow build. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowDeployment

func (s *Service) GetWorkflowDeployment(id string, buildId string, deploymentId string, resp ...*http.Response) (*WorkflowDeployment, error)

GetWorkflowDeployment - Returns the status of a workflow deployment. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
deploymentId: The workflow deployment ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowDeploymentError

func (s *Service) GetWorkflowDeploymentError(id string, buildId string, deploymentId string, resp ...*http.Response) (*WorkflowDeploymentError, error)

GetWorkflowDeploymentError - Returns a list of workflow deployment errors. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
deploymentId: The workflow deployment ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowDeploymentLog

func (s *Service) GetWorkflowDeploymentLog(id string, buildId string, deploymentId string, resp ...*http.Response) (*WorkflowDeploymentLog, error)

GetWorkflowDeploymentLog - Returns the logs from a workflow deployment. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
deploymentId: The workflow deployment ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowRun

func (s *Service) GetWorkflowRun(id string, buildId string, runId string, resp ...*http.Response) (*WorkflowRun, error)

GetWorkflowRun - Returns the status of a workflow run. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
runId: The workflow run ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowRunError

func (s *Service) GetWorkflowRunError(id string, buildId string, runId string, resp ...*http.Response) (*WorkflowRunError, error)

GetWorkflowRunError - Returns the errors for a workflow run. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
runId: The workflow run ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowRunLog

func (s *Service) GetWorkflowRunLog(id string, buildId string, runId string, resp ...*http.Response) (*WorkflowRunLog, error)

GetWorkflowRunLog - Returns the logs for a workflow run. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
runId: The workflow run ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) GetWorkflowStreamDeployment

func (s *Service) GetWorkflowStreamDeployment(id string, buildId string, streamDeploymentId string, resp ...*http.Response) (*WorkflowStreamDeployment, error)

GetWorkflowStreamDeployment - Returns the status of a workflow streaming deployment. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
streamDeploymentId: The workflow streaming deployment ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) ListWorkflowBuilds

func (s *Service) ListWorkflowBuilds(id string, resp ...*http.Response) ([]WorkflowBuild, error)

ListWorkflowBuilds - Returns a list of workflow builds. Parameters:

id: The workflow ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) ListWorkflowDeployments

func (s *Service) ListWorkflowDeployments(id string, buildId string, resp ...*http.Response) ([]WorkflowDeployment, error)

ListWorkflowDeployments - Returns a list of workflow deployments. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) ListWorkflowRuns

func (s *Service) ListWorkflowRuns(id string, buildId string, resp ...*http.Response) ([]WorkflowRun, error)

ListWorkflowRuns - Returns a list of workflow runs. Parameters:

id: The workflow ID.
buildId: The workflow build ID.
resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

func (*Service) ListWorkflows

func (s *Service) ListWorkflows(resp ...*http.Response) ([]WorkflowsGetResponse, error)

ListWorkflows - Returns a list of workflow configurations. Parameters:

resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided

type Servicer

type Servicer interface {
	//interfaces that are auto-generated in interface_generated.go
	ServicerGenerated
}

Servicer represents the interface for implementing all endpoints for this service

type ServicerGenerated added in v1.10.0

type ServicerGenerated interface {
	/*
		CreateWorkflow - Creates a workflow configuration.
		Parameters:
			workflow: Workflow configuration to be created.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	CreateWorkflow(workflow Workflow, resp ...*http.Response) (*Workflow, error)
	/*
		CreateWorkflowBuild - Creates a workflow build.
		Parameters:
			id: The workflow ID.
			workflowBuild: Input data used to build the workflow.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	CreateWorkflowBuild(id string, workflowBuild WorkflowBuild, resp ...*http.Response) (*WorkflowBuild, error)
	/*
		CreateWorkflowDeployment - Creates a workflow deployment.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			workflowDeployment: Input data used to build the workflow deployment.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	CreateWorkflowDeployment(id string, buildId string, workflowDeployment WorkflowDeployment, resp ...*http.Response) (*WorkflowDeployment, error)
	/*
		CreateWorkflowInference - Creates a workflow inference request.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			deploymentId: The workflow deployment ID.
			workflowInference: Input data to the inference request.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	CreateWorkflowInference(id string, buildId string, deploymentId string, workflowInference WorkflowInference, resp ...*http.Response) (*WorkflowInference, error)
	/*
		CreateWorkflowRun - Creates a workflow run.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			workflowRun: Input data used to build the workflow.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	CreateWorkflowRun(id string, buildId string, workflowRun WorkflowRun, resp ...*http.Response) (*WorkflowRun, error)
	/*
		CreateWorkflowStreamDeployment - Creates a workflow streaming deployment.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			workflowStreamDeployment: Configuration for the workflow streaming deployment.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	CreateWorkflowStreamDeployment(id string, buildId string, workflowStreamDeployment WorkflowStreamDeployment, resp ...*http.Response) (*WorkflowStreamDeployment, error)
	/*
		DeleteWorkflow - Removes a workflow configuration.
		Parameters:
			id: The workflow ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	DeleteWorkflow(id string, resp ...*http.Response) error
	/*
		DeleteWorkflowBuild - Removes a workflow build.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	DeleteWorkflowBuild(id string, buildId string, resp ...*http.Response) error
	/*
		DeleteWorkflowDeployment - Removes a workflow deployment.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			deploymentId: The workflow deployment ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	DeleteWorkflowDeployment(id string, buildId string, deploymentId string, resp ...*http.Response) error
	/*
		DeleteWorkflowRun - Removes a workflow run.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			runId: The workflow run ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	DeleteWorkflowRun(id string, buildId string, runId string, resp ...*http.Response) error
	/*
		DeleteWorkflowStreamDeployment - Removes a workflow streaming deployment.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			streamDeploymentId: The workflow streaming deployment ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	DeleteWorkflowStreamDeployment(id string, buildId string, streamDeploymentId string, resp ...*http.Response) error
	/*
		GetWorkflow - Returns a workflow configuration.
		Parameters:
			id: The workflow ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflow(id string, resp ...*http.Response) (*Workflow, error)
	/*
		GetWorkflowBuild - Returns the status of a workflow build.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowBuild(id string, buildId string, resp ...*http.Response) (*WorkflowBuild, error)
	/*
		GetWorkflowBuildError - Returns a list of workflow errors.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowBuildError(id string, buildId string, resp ...*http.Response) (*WorkflowBuildError, error)
	/*
		GetWorkflowBuildLog - Returns the logs from a workflow build.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowBuildLog(id string, buildId string, resp ...*http.Response) (*WorkflowBuildLog, error)
	/*
		GetWorkflowDeployment - Returns the status of a workflow deployment.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			deploymentId: The workflow deployment ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowDeployment(id string, buildId string, deploymentId string, resp ...*http.Response) (*WorkflowDeployment, error)
	/*
		GetWorkflowDeploymentError - Returns a list of workflow deployment errors.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			deploymentId: The workflow deployment ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowDeploymentError(id string, buildId string, deploymentId string, resp ...*http.Response) (*WorkflowDeploymentError, error)
	/*
		GetWorkflowDeploymentLog - Returns the logs from a workflow deployment.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			deploymentId: The workflow deployment ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowDeploymentLog(id string, buildId string, deploymentId string, resp ...*http.Response) (*WorkflowDeploymentLog, error)
	/*
		GetWorkflowRun - Returns the status of a workflow run.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			runId: The workflow run ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowRun(id string, buildId string, runId string, resp ...*http.Response) (*WorkflowRun, error)
	/*
		GetWorkflowRunError - Returns the errors for a workflow run.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			runId: The workflow run ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowRunError(id string, buildId string, runId string, resp ...*http.Response) (*WorkflowRunError, error)
	/*
		GetWorkflowRunLog - Returns the logs for a workflow run.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			runId: The workflow run ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowRunLog(id string, buildId string, runId string, resp ...*http.Response) (*WorkflowRunLog, error)
	/*
		GetWorkflowStreamDeployment - Returns the status of a workflow streaming deployment.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			streamDeploymentId: The workflow streaming deployment ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetWorkflowStreamDeployment(id string, buildId string, streamDeploymentId string, resp ...*http.Response) (*WorkflowStreamDeployment, error)
	/*
		ListWorkflowBuilds - Returns a list of workflow builds.
		Parameters:
			id: The workflow ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	ListWorkflowBuilds(id string, resp ...*http.Response) ([]WorkflowBuild, error)
	/*
		ListWorkflowDeployments - Returns a list of workflow deployments.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	ListWorkflowDeployments(id string, buildId string, resp ...*http.Response) ([]WorkflowDeployment, error)
	/*
		ListWorkflowRuns - Returns a list of workflow runs.
		Parameters:
			id: The workflow ID.
			buildId: The workflow build ID.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	ListWorkflowRuns(id string, buildId string, resp ...*http.Response) ([]WorkflowRun, error)
	/*
		ListWorkflows - Returns a list of workflow configurations.
		Parameters:
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	ListWorkflows(resp ...*http.Response) ([]WorkflowsGetResponse, error)
}

ServicerGenerated represents the interface for implementing all endpoints for this service

type Spl

type Spl struct {
	Query string `json:"query"`
	// Determine whether the Search service extracts all available fields in the data, including fields not mentioned in the SPL for the search job. Set to 'false' for better search performance.
	ExtractAllFields *bool `json:"extractAllFields,omitempty"`
	// The number of seconds to run this search before finalizing.
	MaxTime *int32 `json:"maxTime,omitempty"`
	// The module to run the search in. The default module is used if a module is not specified.
	Module *string `json:"module,omitempty"`
	// Represents parameters on the search job such as 'earliest' and 'latest'.
	QueryParameters map[string]interface{} `json:"queryParameters,omitempty"`
}

type Task

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

func MakeTaskFromFitTask

func MakeTaskFromFitTask(f FitTask) Task

MakeTaskFromFitTask creates a new Task from an instance of FitTask

func MakeTaskFromRawInterface

func MakeTaskFromRawInterface(f interface{}) Task

MakeTaskFromRawInterface creates a new Task from a raw interface{}

func (Task) FitTask

func (m Task) FitTask() *FitTask

FitTask returns FitTask if IsFitTask() is true, nil otherwise

func (Task) IsFitTask

func (m Task) IsFitTask() bool

IsFitTask checks if the Task is a FitTask

func (Task) IsRawInterface

func (m Task) IsRawInterface() bool

IsRawInterface checks if the Task is an interface{} (unknown type)

func (Task) MarshalJSON

func (m Task) MarshalJSON() ([]byte, error)

MarshalJSON marshals Task using the appropriate struct field

func (Task) RawInterface

func (m Task) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (*Task) UnmarshalJSON

func (m *Task) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals Task using the "kind" property

type TaskCommon

type TaskCommon struct {
	Kind *TaskCommonKind `json:"kind,omitempty"`
	// The name has to be unique in the same workflow, it is optional, can be used to identify that task artifact.
	Name *string `json:"name,omitempty"`
}

type TaskCommonKind

type TaskCommonKind string
const (
	TaskCommonKindFit TaskCommonKind = "fit"
)

List of TaskCommonKind

type TaskKind

type TaskKind string
const (
	TaskKindFit TaskKind = "fit"
)

List of TaskKind

type TaskSummary

type TaskSummary struct {
	Algorithm *string `json:"algorithm,omitempty"`
	Name      *string `json:"name,omitempty"`
	// Summary of the task, including but not limited to learned parameters and statistics.
	Summary interface{} `json:"summary,omitempty"`
}

type TrainTestScore

type TrainTestScore struct {
	TestScore     *Score `json:"testScore,omitempty"`
	TrainingScore *Score `json:"trainingScore,omitempty"`
}

type TrainTestSplit

type TrainTestSplit struct {
	// Random state to shuffle and partition data.
	RandomSeed *int32 `json:"randomSeed,omitempty"`
	// Ratio to split out training set and test set. For example, 0.8 means 80% of data for the training set and 20% for the test set.
	Ratio *float32 `json:"ratio,omitempty"`
	// Determine whether stratification is used in partitioning the data.
	Stratified *bool `json:"stratified,omitempty"`
}

type TrainingParameters

type TrainingParameters map[string]interface{}

type Workflow

type Workflow struct {
	Tasks        []Task  `json:"tasks"`
	CreationTime *string `json:"creationTime,omitempty"`
	Id           *string `json:"id,omitempty"`
	Name         *string `json:"name,omitempty"`
}

type WorkflowBuild

type WorkflowBuild struct {
	Input           InputData            `json:"input"`
	CreationTime    *string              `json:"creationTime,omitempty"`
	EndTime         *string              `json:"endTime,omitempty"`
	Id              *string              `json:"id,omitempty"`
	Name            *string              `json:"name,omitempty"`
	Output          *OutputData          `json:"output,omitempty"`
	PipelineSummary []TaskSummary        `json:"pipelineSummary,omitempty"`
	StartTime       *string              `json:"startTime,omitempty"`
	Status          *WorkflowBuildStatus `json:"status,omitempty"`
	// Number of seconds before a workflow build times out.
	TimeoutSecs      *int32                         `json:"timeoutSecs,omitempty"`
	TrainingScore    *Score                         `json:"trainingScore,omitempty"`
	ValidationOption *WorkflowBuildValidationOption `json:"validationOption,omitempty"`
	ValidationScore  *WorkflowBuildValidationScore  `json:"validationScore,omitempty"`
	Workflow         *Workflow                      `json:"workflow,omitempty"`
}

type WorkflowBuildError

type WorkflowBuildError struct {
	Id                    string                  `json:"id"`
	WorkflowId            string                  `json:"workflowId"`
	ExecutorErrors        []ExecutorErrors        `json:"executorErrors,omitempty"`
	RequestId             *string                 `json:"requestId,omitempty"`
	WorkflowManagerErrors []WorkflowManagerErrors `json:"workflowManagerErrors,omitempty"`
}

type WorkflowBuildLog

type WorkflowBuildLog struct {
	Id                  string                `json:"id"`
	WorkflowId          string                `json:"workflowId"`
	ExecutorLogs        []ExecutorLogs        `json:"executorLogs,omitempty"`
	RequestId           *string               `json:"requestId,omitempty"`
	WorkflowManagerLogs []WorkflowManagerLogs `json:"workflowManagerLogs,omitempty"`
}

type WorkflowBuildStatus

type WorkflowBuildStatus string
const (
	WorkflowBuildStatusRunning   WorkflowBuildStatus = "running"
	WorkflowBuildStatusFailed    WorkflowBuildStatus = "failed"
	WorkflowBuildStatusSuccess   WorkflowBuildStatus = "success"
	WorkflowBuildStatusScheduled WorkflowBuildStatus = "scheduled"
)

List of WorkflowBuildStatus

type WorkflowBuildValidationOption

type WorkflowBuildValidationOption struct {
	Kind   WorkflowBuildValidationOptionKind `json:"kind"`
	Option *WorkflowValidationOption         `json:"option,omitempty"`
}

Represents which type of validation to use in the workflow along with any parameters if specified. If this is not included, no validation is done (all data is used for training). Default parameter values are used if no `option` is specified.

type WorkflowBuildValidationOptionKind

type WorkflowBuildValidationOptionKind string
const (
	WorkflowBuildValidationOptionKindTrainTest       WorkflowBuildValidationOptionKind = "TrainTest"
	WorkflowBuildValidationOptionKindCrossValidation WorkflowBuildValidationOptionKind = "CrossValidation"
)

List of WorkflowBuildValidationOptionKind

type WorkflowBuildValidationScore

type WorkflowBuildValidationScore struct {
	Kind  WorkflowBuildValidationScoreKind `json:"kind"`
	Score WorkflowValidationScore          `json:"score"`
}

The validation score whose type is specified by the user in `validationOption`.

type WorkflowBuildValidationScoreKind

type WorkflowBuildValidationScoreKind string
const (
	WorkflowBuildValidationScoreKindTrainTest       WorkflowBuildValidationScoreKind = "TrainTest"
	WorkflowBuildValidationScoreKindCrossValidation WorkflowBuildValidationScoreKind = "CrossValidation"
)

List of WorkflowBuildValidationScoreKind

type WorkflowDeployment

type WorkflowDeployment struct {
	Spec          DeploymentSpec            `json:"spec"`
	CreationTime  *string                   `json:"creationTime,omitempty"`
	EndTime       *string                   `json:"endTime,omitempty"`
	Id            *string                   `json:"id,omitempty"`
	Name          *string                   `json:"name,omitempty"`
	StartTime     *string                   `json:"startTime,omitempty"`
	Status        *WorkflowDeploymentStatus `json:"status,omitempty"`
	WorkflowBuild *WorkflowBuild            `json:"workflowBuild,omitempty"`
}

type WorkflowDeploymentError

type WorkflowDeploymentError struct {
	BuildId               string                  `json:"buildId"`
	Id                    string                  `json:"id"`
	WorkflowId            string                  `json:"workflowId"`
	ExecutorErrors        []ExecutorErrors        `json:"executorErrors,omitempty"`
	RequestId             *string                 `json:"requestId,omitempty"`
	WorkflowManagerErrors []WorkflowManagerErrors `json:"workflowManagerErrors,omitempty"`
}

type WorkflowDeploymentLog

type WorkflowDeploymentLog struct {
	BuildId             string                `json:"buildId"`
	Id                  string                `json:"id"`
	WorkflowId          string                `json:"workflowId"`
	ExecutorLogs        []ExecutorLogs        `json:"executorLogs,omitempty"`
	RequestId           *string               `json:"requestId,omitempty"`
	WorkflowManagerLogs []WorkflowManagerLogs `json:"workflowManagerLogs,omitempty"`
}

type WorkflowDeploymentStatus

type WorkflowDeploymentStatus string
const (
	WorkflowDeploymentStatusRunning      WorkflowDeploymentStatus = "running"
	WorkflowDeploymentStatusFailed       WorkflowDeploymentStatus = "failed"
	WorkflowDeploymentStatusSuccess      WorkflowDeploymentStatus = "success"
	WorkflowDeploymentStatusScheduled    WorkflowDeploymentStatus = "scheduled"
	WorkflowDeploymentStatusInitializing WorkflowDeploymentStatus = "initializing"
)

List of WorkflowDeploymentStatus

type WorkflowInference

type WorkflowInference struct {
	Input  string  `json:"input"`
	Output *string `json:"output,omitempty"`
}

type WorkflowManagerErrors

type WorkflowManagerErrors struct {
	Message *string `json:"message,omitempty"`
}

Workflow manager errors.

type WorkflowManagerLogs

type WorkflowManagerLogs struct {
	Level   *string `json:"level,omitempty"`
	Message *string `json:"message,omitempty"`
}

Workflow manager logs.

type WorkflowRun

type WorkflowRun struct {
	Input        InputData  `json:"input"`
	Output       OutputData `json:"output"`
	CreationTime *string    `json:"creationTime,omitempty"`
	EndTime      *string    `json:"endTime,omitempty"`
	// Determine whether to evaluate the prediction.
	Evaluate        *bool              `json:"evaluate,omitempty"`
	Id              *string            `json:"id,omitempty"`
	Name            *string            `json:"name,omitempty"`
	PredictionScore *Score             `json:"predictionScore,omitempty"`
	StartTime       *string            `json:"startTime,omitempty"`
	Status          *WorkflowRunStatus `json:"status,omitempty"`
	// Number of seconds before a workflow run times out.
	TimeoutSecs   *int32         `json:"timeoutSecs,omitempty"`
	WorkflowBuild *WorkflowBuild `json:"workflowBuild,omitempty"`
}

type WorkflowRunError

type WorkflowRunError struct {
	BuildId               string                  `json:"buildId"`
	Id                    string                  `json:"id"`
	WorkflowId            string                  `json:"workflowId"`
	ExecutorErrors        []ExecutorErrors        `json:"executorErrors,omitempty"`
	RequestId             *string                 `json:"requestId,omitempty"`
	WorkflowManagerErrors []WorkflowManagerErrors `json:"workflowManagerErrors,omitempty"`
}

type WorkflowRunLog

type WorkflowRunLog struct {
	BuildId             string                `json:"buildId"`
	Id                  string                `json:"id"`
	WorkflowId          string                `json:"workflowId"`
	ExecutorLogs        []ExecutorLogs        `json:"executorLogs,omitempty"`
	RequestId           *string               `json:"requestId,omitempty"`
	WorkflowManagerLogs []WorkflowManagerLogs `json:"workflowManagerLogs,omitempty"`
}

type WorkflowRunStatus

type WorkflowRunStatus string
const (
	WorkflowRunStatusRunning   WorkflowRunStatus = "running"
	WorkflowRunStatusFailed    WorkflowRunStatus = "failed"
	WorkflowRunStatusSuccess   WorkflowRunStatus = "success"
	WorkflowRunStatusScheduled WorkflowRunStatus = "scheduled"
)

List of WorkflowRunStatus

type WorkflowStreamDeployment

type WorkflowStreamDeployment struct {
	Input         InputStream                     `json:"input"`
	Output        OutputStream                    `json:"output"`
	CreationTime  *string                         `json:"creationTime,omitempty"`
	EndTime       *string                         `json:"endTime,omitempty"`
	Id            *string                         `json:"id,omitempty"`
	Name          *string                         `json:"name,omitempty"`
	Spec          *DeploymentSpec                 `json:"spec,omitempty"`
	StartTime     *string                         `json:"startTime,omitempty"`
	Status        *WorkflowStreamDeploymentStatus `json:"status,omitempty"`
	WorkflowBuild *WorkflowBuild                  `json:"workflowBuild,omitempty"`
}

type WorkflowStreamDeploymentStatus

type WorkflowStreamDeploymentStatus string
const (
	WorkflowStreamDeploymentStatusRunning      WorkflowStreamDeploymentStatus = "running"
	WorkflowStreamDeploymentStatusFailed       WorkflowStreamDeploymentStatus = "failed"
	WorkflowStreamDeploymentStatusSuccess      WorkflowStreamDeploymentStatus = "success"
	WorkflowStreamDeploymentStatusScheduled    WorkflowStreamDeploymentStatus = "scheduled"
	WorkflowStreamDeploymentStatusInitializing WorkflowStreamDeploymentStatus = "initializing"
)

List of WorkflowStreamDeploymentStatus

type WorkflowValidationOption

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

WorkflowValidationOption is CrossValidation, TrainTestSplit, (or interface{} if no matches are found)

func MakeWorkflowValidationOptionFromCrossValidation

func MakeWorkflowValidationOptionFromCrossValidation(f CrossValidation) WorkflowValidationOption

MakeWorkflowValidationOptionFromCrossValidation creates a new WorkflowValidationOption from an instance of CrossValidation

func MakeWorkflowValidationOptionFromRawInterface

func MakeWorkflowValidationOptionFromRawInterface(f interface{}) WorkflowValidationOption

MakeWorkflowValidationOptionFromRawInterface creates a new WorkflowValidationOption from a raw interface{}

func MakeWorkflowValidationOptionFromTrainTestSplit

func MakeWorkflowValidationOptionFromTrainTestSplit(f TrainTestSplit) WorkflowValidationOption

MakeWorkflowValidationOptionFromTrainTestSplit creates a new WorkflowValidationOption from an instance of TrainTestSplit

func (WorkflowValidationOption) CrossValidation

func (m WorkflowValidationOption) CrossValidation() *CrossValidation

CrossValidation returns CrossValidation if IsCrossValidation() is true, nil otherwise

func (WorkflowValidationOption) IsCrossValidation

func (m WorkflowValidationOption) IsCrossValidation() bool

IsCrossValidation checks if the WorkflowValidationOption is a CrossValidation

func (WorkflowValidationOption) IsRawInterface

func (m WorkflowValidationOption) IsRawInterface() bool

IsRawInterface checks if the WorkflowValidationOption is an interface{} (unknown type)

func (WorkflowValidationOption) IsTrainTestSplit

func (m WorkflowValidationOption) IsTrainTestSplit() bool

IsTrainTestSplit checks if the WorkflowValidationOption is a TrainTestSplit

func (WorkflowValidationOption) MarshalJSON

func (m WorkflowValidationOption) MarshalJSON() ([]byte, error)

MarshalJSON marshals WorkflowValidationOption using WorkflowValidationOption.WorkflowValidationOption

func (WorkflowValidationOption) RawInterface

func (m WorkflowValidationOption) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (WorkflowValidationOption) TrainTestSplit

func (m WorkflowValidationOption) TrainTestSplit() *TrainTestSplit

TrainTestSplit returns TrainTestSplit if IsTrainTestSplit() is true, nil otherwise

func (*WorkflowValidationOption) UnmarshalJSON

func (m *WorkflowValidationOption) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals WorkflowValidationOption into CrossValidation, TrainTestSplit, or interface{} if no matches are found

type WorkflowValidationScore

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

WorkflowValidationScore is CrossValidationScore, TrainTestScore, (or interface{} if no matches are found)

func MakeWorkflowValidationScoreFromCrossValidationScore

func MakeWorkflowValidationScoreFromCrossValidationScore(f CrossValidationScore) WorkflowValidationScore

MakeWorkflowValidationScoreFromCrossValidationScore creates a new WorkflowValidationScore from an instance of CrossValidationScore

func MakeWorkflowValidationScoreFromRawInterface

func MakeWorkflowValidationScoreFromRawInterface(f interface{}) WorkflowValidationScore

MakeWorkflowValidationScoreFromRawInterface creates a new WorkflowValidationScore from a raw interface{}

func MakeWorkflowValidationScoreFromTrainTestScore

func MakeWorkflowValidationScoreFromTrainTestScore(f TrainTestScore) WorkflowValidationScore

MakeWorkflowValidationScoreFromTrainTestScore creates a new WorkflowValidationScore from an instance of TrainTestScore

func (WorkflowValidationScore) CrossValidationScore

func (m WorkflowValidationScore) CrossValidationScore() *CrossValidationScore

CrossValidationScore returns CrossValidationScore if IsCrossValidationScore() is true, nil otherwise

func (WorkflowValidationScore) IsCrossValidationScore

func (m WorkflowValidationScore) IsCrossValidationScore() bool

IsCrossValidationScore checks if the WorkflowValidationScore is a CrossValidationScore

func (WorkflowValidationScore) IsRawInterface

func (m WorkflowValidationScore) IsRawInterface() bool

IsRawInterface checks if the WorkflowValidationScore is an interface{} (unknown type)

func (WorkflowValidationScore) IsTrainTestScore

func (m WorkflowValidationScore) IsTrainTestScore() bool

IsTrainTestScore checks if the WorkflowValidationScore is a TrainTestScore

func (WorkflowValidationScore) MarshalJSON

func (m WorkflowValidationScore) MarshalJSON() ([]byte, error)

MarshalJSON marshals WorkflowValidationScore using WorkflowValidationScore.WorkflowValidationScore

func (WorkflowValidationScore) RawInterface

func (m WorkflowValidationScore) RawInterface() interface{}

RawInterface returns interface{} if IsRawInterface() is true (unknown type), nil otherwise

func (WorkflowValidationScore) TrainTestScore

func (m WorkflowValidationScore) TrainTestScore() *TrainTestScore

TrainTestScore returns TrainTestScore if IsTrainTestScore() is true, nil otherwise

func (*WorkflowValidationScore) UnmarshalJSON

func (m *WorkflowValidationScore) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON unmarshals WorkflowValidationScore into CrossValidationScore, TrainTestScore, or interface{} if no matches are found

type WorkflowsGetResponse

type WorkflowsGetResponse struct {
	CreationTime *string `json:"creationTime,omitempty"`
	Id           *string `json:"id,omitempty"`
	Name         *string `json:"name,omitempty"`
}

Jump to

Keyboard shortcuts

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