run

Documentation

Index

• Constants
• Variables
• func ValidateDeleteRunRequest(req *request.DeleteRunRequest) error
• func ValidateDeleteRunTagRequest(req *request.DeleteRunTagRequest) error
• func ValidateGetRunRequest(req *request.GetRunRequest) error
• func ValidateLogBatchRequest(req *request.LogBatchRequest) error
• func ValidateLogMetricRequest(req *request.LogMetricRequest) error
• func ValidateLogParamRequest(req *request.LogParamRequest) error
• func ValidateRestoreRunRequest(req *request.RestoreRunRequest) error
• func ValidateSearchRunsRequest(req *request.SearchRunsRequest) error
• func ValidateSetRunTagRequest(req *request.SetRunTagRequest) error
• func ValidateUpdateRunRequest(req *request.UpdateRunRequest) error
• type Service
  • func NewService(tagRepository repositories.TagRepositoryProvider, ...) *Service
  • func (s Service) CreateRun(ctx context.Context, ns *models.Namespace, req *request.CreateRunRequest) (*models.Run, error)
  • func (s Service) DeleteRun(ctx context.Context, namespace *models.Namespace, ...) error
  • func (s Service) DeleteRunTag(ctx context.Context, namespace *models.Namespace, ...) error
  • func (s Service) GetRun(ctx context.Context, namespace *models.Namespace, req *request.GetRunRequest) (*models.Run, error)
  • func (s Service) LogBatch(ctx context.Context, namespace *models.Namespace, req *request.LogBatchRequest) error
  • func (s Service) LogMetric(ctx context.Context, namespace *models.Namespace, ...) error
  • func (s Service) LogParam(ctx context.Context, namespace *models.Namespace, req *request.LogParamRequest) error
  • func (s Service) RestoreRun(ctx context.Context, namespace *models.Namespace, ...) error
  • func (s Service) SearchRuns(ctx context.Context, namespace *models.Namespace, ...) ([]models.Run, int, int, error)
  • func (s Service) SetRunTag(ctx context.Context, namespace *models.Namespace, ...) error
  • func (s Service) UpdateRun(ctx context.Context, namespace *models.Namespace, ...) (*models.Run, error)

Constants

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

supported expression list.

const (
	MaxResultsPerPage = 1000000
)

Variables

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

func NewService(
	tagRepository repositories.TagRepositoryProvider,
	runRepository repositories.RunRepositoryProvider,
	paramRepository repositories.ParamRepositoryProvider,
	metricRepository repositories.MetricRepositoryProvider,
	experimentRepository repositories.ExperimentRepositoryProvider,
) *Service

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)