run

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: May 6, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	InExpression            = "IN"
	NotInExpression         = "NOT IN"
	LikeExpression          = "LIKE"
	ILikeExpression         = "ILIKE"
	EqualExpression         = "="
	NotEqualExpression      = "!="
	LessExpression          = "<"
	LessOrEqualExpression   = "<="
	GraterExpression        = ">"
	GraterOrEqualExpression = ">="
)

supported expression list.

View Source
const (
	MaxResultsPerPage = 1000000
)

Variables

View Source
var (
	AllowedViewTypeList = map[request.ViewType]struct{}{
		"":                          {},
		request.ViewTypeAll:         {},
		request.ViewTypeActiveOnly:  {},
		request.ViewTypeDeletedOnly: {},
	}
)

AllowedViewTypeList supported list of ViewType.

Functions

func ValidateDeleteRunRequest

func ValidateDeleteRunRequest(req *request.DeleteRunRequest) error

ValidateDeleteRunRequest validates `POST /mlflow/runs/delete` request.

func ValidateDeleteRunTagRequest

func ValidateDeleteRunTagRequest(req *request.DeleteRunTagRequest) error

ValidateDeleteRunTagRequest validates `POST /mlflow/runs/delete-tag` request.

func ValidateGetRunRequest

func ValidateGetRunRequest(req *request.GetRunRequest) error

ValidateGetRunRequest validates `GET /mlflow/runs/get` request.

func ValidateLogBatchRequest

func ValidateLogBatchRequest(req *request.LogBatchRequest) error

ValidateLogBatchRequest validates `POST /mlflow/runs/log-batch` request.

func ValidateLogMetricRequest

func ValidateLogMetricRequest(req *request.LogMetricRequest) error

ValidateLogMetricRequest validates `POST /mlflow/runs/log-metric` request.

func ValidateLogParamRequest

func ValidateLogParamRequest(req *request.LogParamRequest) error

ValidateLogParamRequest validates `POST /mlflow/runs/log-parameter` request.

func ValidateRestoreRunRequest

func ValidateRestoreRunRequest(req *request.RestoreRunRequest) error

ValidateRestoreRunRequest validates `POST /mlflow/runs/restore` request.

func ValidateSearchRunsRequest

func ValidateSearchRunsRequest(req *request.SearchRunsRequest) error

ValidateSearchRunsRequest validates `POST /mlflow/runs/search` request.

func ValidateSetRunTagRequest

func ValidateSetRunTagRequest(req *request.SetRunTagRequest) error

ValidateSetRunTagRequest validates `POST /mlflow/runs/set-tag` request.

func ValidateUpdateRunRequest

func ValidateUpdateRunRequest(req *request.UpdateRunRequest) error

ValidateUpdateRunRequest validates `POST /mlflow/runs/update` request.

Types

type Service

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

Service provides service layer to work with `run` business logic.

func NewService

NewService creates new Service instance.

func (Service) CreateRun

func (s Service) CreateRun(
	ctx context.Context, ns *models.Namespace, req *request.CreateRunRequest,
) (*models.Run, error)

func (Service) DeleteRun

func (s Service) DeleteRun(
	ctx context.Context, namespace *models.Namespace, req *request.DeleteRunRequest,
) error

DeleteRun handles delete models.Run entity business logic.

func (Service) DeleteRunTag

func (s Service) DeleteRunTag(
	ctx context.Context,
	namespace *models.Namespace,
	req *request.DeleteRunTagRequest,
) error

func (Service) GetRun

func (s Service) GetRun(
	ctx context.Context,
	namespace *models.Namespace,
	req *request.GetRunRequest,
) (*models.Run, error)

func (Service) LogBatch

func (s Service) LogBatch(
	ctx context.Context,
	namespace *models.Namespace,
	req *request.LogBatchRequest,
) error

func (Service) LogMetric

func (s Service) LogMetric(
	ctx context.Context,
	namespace *models.Namespace,
	req *request.LogMetricRequest,
) error

func (Service) LogParam

func (s Service) LogParam(
	ctx context.Context,
	namespace *models.Namespace,
	req *request.LogParamRequest,
) error

func (Service) RestoreRun

func (s Service) RestoreRun(
	ctx context.Context,
	namespace *models.Namespace,
	req *request.RestoreRunRequest,
) error

func (Service) SearchRuns

func (s Service) SearchRuns(
	ctx context.Context, namespace *models.Namespace, req *request.SearchRunsRequest,
) ([]models.Run, int, int, error)

nolint:gocyclo TODO:get back and fix `gocyclo` problem.

func (Service) SetRunTag

func (s Service) SetRunTag(
	ctx context.Context,
	namespace *models.Namespace,
	req *request.SetRunTagRequest,
) error

func (Service) UpdateRun

func (s Service) UpdateRun(
	ctx context.Context, namespace *models.Namespace, req *request.UpdateRunRequest,
) (*models.Run, error)

Jump to

Keyboard shortcuts

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