Documentation
¶
Overview ¶
These APIs allow you to manage Experiments, Feature Store, Forecasting, Model Registry, etc.
Index ¶
- type Activity
- type ActivityAction
- type ActivityType
- type ApproveTransitionRequest
- type ApproveTransitionRequestResponse
- type CommentActivityAction
- type CommentObject
- type CreateComment
- type CreateCommentResponse
- type CreateExperiment
- type CreateExperimentResponse
- type CreateForecastingExperimentRequest
- type CreateForecastingExperimentResponse
- type CreateLoggedModelRequest
- type CreateLoggedModelResponse
- type CreateModelRequest
- type CreateModelResponse
- type CreateModelVersionRequest
- type CreateModelVersionResponse
- type CreateOnlineStoreRequest
- type CreateRegistryWebhook
- type CreateRun
- type CreateRunResponse
- type CreateTransitionRequest
- type CreateTransitionRequestResponse
- type CreateWebhookResponse
- type Dataset
- type DatasetInput
- type DeleteCommentRequest
- type DeleteCommentResponse
- type DeleteExperiment
- type DeleteExperimentResponse
- type DeleteLoggedModelRequest
- type DeleteLoggedModelResponse
- type DeleteLoggedModelTagRequest
- type DeleteLoggedModelTagResponse
- type DeleteModelRequest
- type DeleteModelResponse
- type DeleteModelTagRequest
- type DeleteModelTagResponse
- type DeleteModelVersionRequest
- type DeleteModelVersionResponse
- type DeleteModelVersionTagRequest
- type DeleteModelVersionTagResponse
- type DeleteOnlineStoreRequest
- type DeleteOnlineStoreResponse
- type DeleteRun
- type DeleteRunResponse
- type DeleteRuns
- type DeleteRunsResponse
- type DeleteTag
- type DeleteTagResponse
- type DeleteTransitionRequestRequest
- type DeleteTransitionRequestResponse
- type DeleteTransitionRequestStage
- type DeleteWebhookRequest
- type DeleteWebhookResponse
- type Experiment
- type ExperimentAccessControlRequest
- type ExperimentAccessControlResponse
- type ExperimentPermission
- type ExperimentPermissionLevel
- type ExperimentPermissions
- type ExperimentPermissionsDescription
- type ExperimentPermissionsRequest
- type ExperimentTag
- type ExperimentsAPI
- func (a *ExperimentsAPI) CreateExperiment(ctx context.Context, request CreateExperiment) (*CreateExperimentResponse, error)
- func (a *ExperimentsAPI) CreateLoggedModel(ctx context.Context, request CreateLoggedModelRequest) (*CreateLoggedModelResponse, error)
- func (a *ExperimentsAPI) CreateRun(ctx context.Context, request CreateRun) (*CreateRunResponse, error)
- func (a *ExperimentsAPI) DeleteExperiment(ctx context.Context, request DeleteExperiment) error
- func (a *ExperimentsAPI) DeleteLoggedModel(ctx context.Context, request DeleteLoggedModelRequest) error
- func (a *ExperimentsAPI) DeleteLoggedModelByModelId(ctx context.Context, modelId string) error
- func (a *ExperimentsAPI) DeleteLoggedModelTag(ctx context.Context, request DeleteLoggedModelTagRequest) error
- func (a *ExperimentsAPI) DeleteLoggedModelTagByModelIdAndTagKey(ctx context.Context, modelId string, tagKey string) error
- func (a *ExperimentsAPI) DeleteRun(ctx context.Context, request DeleteRun) error
- func (a *ExperimentsAPI) DeleteRuns(ctx context.Context, request DeleteRuns) (*DeleteRunsResponse, error)
- func (a *ExperimentsAPI) DeleteTag(ctx context.Context, request DeleteTag) error
- func (a *ExperimentsAPI) FinalizeLoggedModel(ctx context.Context, request FinalizeLoggedModelRequest) (*FinalizeLoggedModelResponse, error)
- func (a *ExperimentsAPI) GetByName(ctx context.Context, request GetByNameRequest) (*GetExperimentByNameResponse, error)
- func (a *ExperimentsAPI) GetExperiment(ctx context.Context, request GetExperimentRequest) (*GetExperimentResponse, error)
- func (a *ExperimentsAPI) GetHistory(ctx context.Context, request GetHistoryRequest) listing.Iterator[Metric]
- func (a *ExperimentsAPI) GetHistoryAll(ctx context.Context, request GetHistoryRequest) ([]Metric, error)
- func (a *ExperimentsAPI) GetLoggedModel(ctx context.Context, request GetLoggedModelRequest) (*GetLoggedModelResponse, error)
- func (a *ExperimentsAPI) GetLoggedModelByModelId(ctx context.Context, modelId string) (*GetLoggedModelResponse, error)
- func (a *ExperimentsAPI) GetPermissionLevels(ctx context.Context, request GetExperimentPermissionLevelsRequest) (*GetExperimentPermissionLevelsResponse, error)
- func (a *ExperimentsAPI) GetPermissionLevelsByExperimentId(ctx context.Context, experimentId string) (*GetExperimentPermissionLevelsResponse, error)
- func (a *ExperimentsAPI) GetPermissions(ctx context.Context, request GetExperimentPermissionsRequest) (*ExperimentPermissions, error)
- func (a *ExperimentsAPI) GetPermissionsByExperimentId(ctx context.Context, experimentId string) (*ExperimentPermissions, error)
- func (a *ExperimentsAPI) GetRun(ctx context.Context, request GetRunRequest) (*GetRunResponse, error)
- func (a *ExperimentsAPI) ListArtifacts(ctx context.Context, request ListArtifactsRequest) listing.Iterator[FileInfo]
- func (a *ExperimentsAPI) ListArtifactsAll(ctx context.Context, request ListArtifactsRequest) ([]FileInfo, error)
- func (a *ExperimentsAPI) ListExperiments(ctx context.Context, request ListExperimentsRequest) listing.Iterator[Experiment]
- func (a *ExperimentsAPI) ListExperimentsAll(ctx context.Context, request ListExperimentsRequest) ([]Experiment, error)
- func (a *ExperimentsAPI) LogBatch(ctx context.Context, request LogBatch) error
- func (a *ExperimentsAPI) LogInputs(ctx context.Context, request LogInputs) error
- func (a *ExperimentsAPI) LogLoggedModelParams(ctx context.Context, request LogLoggedModelParamsRequest) error
- func (a *ExperimentsAPI) LogMetric(ctx context.Context, request LogMetric) error
- func (a *ExperimentsAPI) LogModel(ctx context.Context, request LogModel) error
- func (a *ExperimentsAPI) LogOutputs(ctx context.Context, request LogOutputsRequest) error
- func (a *ExperimentsAPI) LogParam(ctx context.Context, request LogParam) error
- func (a *ExperimentsAPI) RestoreExperiment(ctx context.Context, request RestoreExperiment) error
- func (a *ExperimentsAPI) RestoreRun(ctx context.Context, request RestoreRun) error
- func (a *ExperimentsAPI) RestoreRuns(ctx context.Context, request RestoreRuns) (*RestoreRunsResponse, error)
- func (a *ExperimentsAPI) SearchExperiments(ctx context.Context, request SearchExperiments) listing.Iterator[Experiment]
- func (a *ExperimentsAPI) SearchExperimentsAll(ctx context.Context, request SearchExperiments) ([]Experiment, error)
- func (a *ExperimentsAPI) SearchLoggedModels(ctx context.Context, request SearchLoggedModelsRequest) (*SearchLoggedModelsResponse, error)
- func (a *ExperimentsAPI) SearchRuns(ctx context.Context, request SearchRuns) listing.Iterator[Run]
- func (a *ExperimentsAPI) SearchRunsAll(ctx context.Context, request SearchRuns) ([]Run, error)
- func (a *ExperimentsAPI) SetExperimentTag(ctx context.Context, request SetExperimentTag) error
- func (a *ExperimentsAPI) SetLoggedModelTags(ctx context.Context, request SetLoggedModelTagsRequest) error
- func (a *ExperimentsAPI) SetPermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
- func (a *ExperimentsAPI) SetTag(ctx context.Context, request SetTag) error
- func (a *ExperimentsAPI) UpdateExperiment(ctx context.Context, request UpdateExperiment) error
- func (a *ExperimentsAPI) UpdatePermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
- func (a *ExperimentsAPI) UpdateRun(ctx context.Context, request UpdateRun) (*UpdateRunResponse, error)
- type ExperimentsInterface
- type ExperimentsServicedeprecated
- type FeatureStoreAPI
- func (a *FeatureStoreAPI) CreateOnlineStore(ctx context.Context, request CreateOnlineStoreRequest) (*OnlineStore, error)
- func (a *FeatureStoreAPI) DeleteOnlineStore(ctx context.Context, request DeleteOnlineStoreRequest) error
- func (a *FeatureStoreAPI) DeleteOnlineStoreByName(ctx context.Context, name string) error
- func (a *FeatureStoreAPI) GetOnlineStore(ctx context.Context, request GetOnlineStoreRequest) (*OnlineStore, error)
- func (a *FeatureStoreAPI) GetOnlineStoreByName(ctx context.Context, name string) (*OnlineStore, error)
- func (a *FeatureStoreAPI) ListOnlineStores(ctx context.Context, request ListOnlineStoresRequest) listing.Iterator[OnlineStore]
- func (a *FeatureStoreAPI) ListOnlineStoresAll(ctx context.Context, request ListOnlineStoresRequest) ([]OnlineStore, error)
- func (a *FeatureStoreAPI) PublishTable(ctx context.Context, request PublishTableRequest) (*PublishTableResponse, error)
- func (a *FeatureStoreAPI) UpdateOnlineStore(ctx context.Context, request UpdateOnlineStoreRequest) (*OnlineStore, error)
- type FeatureStoreInterface
- type FeatureStoreServicedeprecated
- type FileInfo
- type FinalizeLoggedModelRequest
- type FinalizeLoggedModelResponse
- type ForecastingAPI
- func (a *ForecastingAPI) CreateExperiment(ctx context.Context, ...) (*WaitGetExperimentForecastingSucceeded[CreateForecastingExperimentResponse], ...)
- func (a *ForecastingAPI) CreateExperimentAndWait(ctx context.Context, ...) (*ForecastingExperiment, error)deprecated
- func (a *ForecastingAPI) GetExperiment(ctx context.Context, request GetForecastingExperimentRequest) (*ForecastingExperiment, error)
- func (a *ForecastingAPI) GetExperimentByExperimentId(ctx context.Context, experimentId string) (*ForecastingExperiment, error)
- func (a *ForecastingAPI) WaitGetExperimentForecastingSucceeded(ctx context.Context, experimentId string, timeout time.Duration, ...) (*ForecastingExperiment, error)
- type ForecastingExperiment
- type ForecastingExperimentState
- type ForecastingInterface
- type ForecastingServicedeprecated
- type GetByNameRequest
- type GetExperimentByNameResponse
- type GetExperimentPermissionLevelsRequest
- type GetExperimentPermissionLevelsResponse
- type GetExperimentPermissionsRequest
- type GetExperimentRequest
- type GetExperimentResponse
- type GetForecastingExperimentRequest
- type GetHistoryRequest
- type GetLatestVersionsRequest
- type GetLatestVersionsResponse
- type GetLoggedModelRequest
- type GetLoggedModelResponse
- type GetMetricHistoryResponse
- type GetModelRequest
- type GetModelResponse
- type GetModelVersionDownloadUriRequest
- type GetModelVersionDownloadUriResponse
- type GetModelVersionRequest
- type GetModelVersionResponse
- type GetOnlineStoreRequest
- type GetRegisteredModelPermissionLevelsRequest
- type GetRegisteredModelPermissionLevelsResponse
- type GetRegisteredModelPermissionsRequest
- type GetRunRequest
- type GetRunResponse
- type HttpUrlSpec
- type HttpUrlSpecWithoutSecret
- type InputTag
- type JobSpec
- type JobSpecWithoutSecret
- type ListArtifactsRequest
- type ListArtifactsResponse
- type ListExperimentsRequest
- type ListExperimentsResponse
- type ListModelsRequest
- type ListModelsResponse
- type ListOnlineStoresRequest
- type ListOnlineStoresResponse
- type ListRegistryWebhooks
- type ListTransitionRequestsRequest
- type ListTransitionRequestsResponse
- type ListWebhooksRequest
- type LogBatch
- type LogBatchResponse
- type LogInputs
- type LogInputsResponse
- type LogLoggedModelParamsRequest
- type LogLoggedModelParamsRequestResponse
- type LogMetric
- type LogMetricResponse
- type LogModel
- type LogModelResponse
- type LogOutputsRequest
- type LogOutputsResponse
- type LogParam
- type LogParamResponse
- type LoggedModel
- type LoggedModelData
- type LoggedModelInfo
- type LoggedModelParameter
- type LoggedModelStatus
- type LoggedModelTag
- type Metric
- type Model
- type ModelDatabricks
- type ModelInput
- type ModelOutput
- type ModelRegistryAPI
- func (a *ModelRegistryAPI) ApproveTransitionRequest(ctx context.Context, request ApproveTransitionRequest) (*ApproveTransitionRequestResponse, error)
- func (a *ModelRegistryAPI) CreateComment(ctx context.Context, request CreateComment) (*CreateCommentResponse, error)
- func (a *ModelRegistryAPI) CreateModel(ctx context.Context, request CreateModelRequest) (*CreateModelResponse, error)
- func (a *ModelRegistryAPI) CreateModelVersion(ctx context.Context, request CreateModelVersionRequest) (*CreateModelVersionResponse, error)
- func (a *ModelRegistryAPI) CreateTransitionRequest(ctx context.Context, request CreateTransitionRequest) (*CreateTransitionRequestResponse, error)
- func (a *ModelRegistryAPI) CreateWebhook(ctx context.Context, request CreateRegistryWebhook) (*CreateWebhookResponse, error)
- func (a *ModelRegistryAPI) DeleteComment(ctx context.Context, request DeleteCommentRequest) error
- func (a *ModelRegistryAPI) DeleteModel(ctx context.Context, request DeleteModelRequest) error
- func (a *ModelRegistryAPI) DeleteModelTag(ctx context.Context, request DeleteModelTagRequest) error
- func (a *ModelRegistryAPI) DeleteModelVersion(ctx context.Context, request DeleteModelVersionRequest) error
- func (a *ModelRegistryAPI) DeleteModelVersionTag(ctx context.Context, request DeleteModelVersionTagRequest) error
- func (a *ModelRegistryAPI) DeleteTransitionRequest(ctx context.Context, request DeleteTransitionRequestRequest) error
- func (a *ModelRegistryAPI) DeleteWebhook(ctx context.Context, request DeleteWebhookRequest) error
- func (a *ModelRegistryAPI) GetLatestVersions(ctx context.Context, request GetLatestVersionsRequest) listing.Iterator[ModelVersion]
- func (a *ModelRegistryAPI) GetLatestVersionsAll(ctx context.Context, request GetLatestVersionsRequest) ([]ModelVersion, error)
- func (a *ModelRegistryAPI) GetModel(ctx context.Context, request GetModelRequest) (*GetModelResponse, error)
- func (a *ModelRegistryAPI) GetModelVersion(ctx context.Context, request GetModelVersionRequest) (*GetModelVersionResponse, error)
- func (a *ModelRegistryAPI) GetModelVersionDownloadUri(ctx context.Context, request GetModelVersionDownloadUriRequest) (*GetModelVersionDownloadUriResponse, error)
- func (a *ModelRegistryAPI) GetPermissionLevels(ctx context.Context, request GetRegisteredModelPermissionLevelsRequest) (*GetRegisteredModelPermissionLevelsResponse, error)
- func (a *ModelRegistryAPI) GetPermissionLevelsByRegisteredModelId(ctx context.Context, registeredModelId string) (*GetRegisteredModelPermissionLevelsResponse, error)
- func (a *ModelRegistryAPI) GetPermissions(ctx context.Context, request GetRegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
- func (a *ModelRegistryAPI) GetPermissionsByRegisteredModelId(ctx context.Context, registeredModelId string) (*RegisteredModelPermissions, error)
- func (a *ModelRegistryAPI) ListModels(ctx context.Context, request ListModelsRequest) listing.Iterator[Model]
- func (a *ModelRegistryAPI) ListModelsAll(ctx context.Context, request ListModelsRequest) ([]Model, error)
- func (a *ModelRegistryAPI) ListTransitionRequests(ctx context.Context, request ListTransitionRequestsRequest) listing.Iterator[Activity]
- func (a *ModelRegistryAPI) ListTransitionRequestsAll(ctx context.Context, request ListTransitionRequestsRequest) ([]Activity, error)
- func (a *ModelRegistryAPI) ListWebhooks(ctx context.Context, request ListWebhooksRequest) listing.Iterator[RegistryWebhook]
- func (a *ModelRegistryAPI) ListWebhooksAll(ctx context.Context, request ListWebhooksRequest) ([]RegistryWebhook, error)
- func (a *ModelRegistryAPI) RejectTransitionRequest(ctx context.Context, request RejectTransitionRequest) (*RejectTransitionRequestResponse, error)
- func (a *ModelRegistryAPI) RenameModel(ctx context.Context, request RenameModelRequest) (*RenameModelResponse, error)
- func (a *ModelRegistryAPI) SearchModelVersions(ctx context.Context, request SearchModelVersionsRequest) listing.Iterator[ModelVersion]
- func (a *ModelRegistryAPI) SearchModelVersionsAll(ctx context.Context, request SearchModelVersionsRequest) ([]ModelVersion, error)
- func (a *ModelRegistryAPI) SearchModels(ctx context.Context, request SearchModelsRequest) listing.Iterator[Model]
- func (a *ModelRegistryAPI) SearchModelsAll(ctx context.Context, request SearchModelsRequest) ([]Model, error)
- func (a *ModelRegistryAPI) SetModelTag(ctx context.Context, request SetModelTagRequest) error
- func (a *ModelRegistryAPI) SetModelVersionTag(ctx context.Context, request SetModelVersionTagRequest) error
- func (a *ModelRegistryAPI) SetPermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
- func (a *ModelRegistryAPI) TestRegistryWebhook(ctx context.Context, request TestRegistryWebhookRequest) (*TestRegistryWebhookResponse, error)
- func (a *ModelRegistryAPI) TransitionStage(ctx context.Context, request TransitionModelVersionStageDatabricks) (*TransitionStageResponse, error)
- func (a *ModelRegistryAPI) UpdateComment(ctx context.Context, request UpdateComment) (*UpdateCommentResponse, error)
- func (a *ModelRegistryAPI) UpdateModel(ctx context.Context, request UpdateModelRequest) error
- func (a *ModelRegistryAPI) UpdateModelVersion(ctx context.Context, request UpdateModelVersionRequest) error
- func (a *ModelRegistryAPI) UpdatePermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
- func (a *ModelRegistryAPI) UpdateWebhook(ctx context.Context, request UpdateRegistryWebhook) error
- type ModelRegistryInterface
- type ModelRegistryServicedeprecated
- type ModelTag
- type ModelVersion
- type ModelVersionDatabricks
- type ModelVersionStatus
- type ModelVersionTag
- type OnlineStore
- type OnlineStoreState
- type Param
- type PermissionLevel
- type PublishSpec
- type PublishSpecPublishMode
- type PublishTableRequest
- type PublishTableResponse
- type RegisteredModelAccessControlRequest
- type RegisteredModelAccessControlResponse
- type RegisteredModelPermission
- type RegisteredModelPermissionLevel
- type RegisteredModelPermissions
- type RegisteredModelPermissionsDescription
- type RegisteredModelPermissionsRequest
- type RegistryWebhook
- type RegistryWebhookEvent
- type RegistryWebhookStatus
- type RejectTransitionRequest
- type RejectTransitionRequestResponse
- type RenameModelRequest
- type RenameModelResponse
- type RestoreExperiment
- type RestoreExperimentResponse
- type RestoreRun
- type RestoreRunResponse
- type RestoreRuns
- type RestoreRunsResponse
- type Run
- type RunData
- type RunInfo
- type RunInfoStatus
- type RunInputs
- type RunTag
- type SearchExperiments
- type SearchExperimentsResponse
- type SearchLoggedModelsDataset
- type SearchLoggedModelsOrderBy
- type SearchLoggedModelsRequest
- type SearchLoggedModelsResponse
- type SearchModelVersionsRequest
- type SearchModelVersionsResponse
- type SearchModelsRequest
- type SearchModelsResponse
- type SearchRuns
- type SearchRunsResponse
- type SetExperimentTag
- type SetExperimentTagResponse
- type SetLoggedModelTagsRequest
- type SetLoggedModelTagsResponse
- type SetModelTagRequest
- type SetModelTagResponse
- type SetModelVersionTagRequest
- type SetModelVersionTagResponse
- type SetTag
- type SetTagResponse
- type Stage
- type Status
- type TestRegistryWebhook
- type TestRegistryWebhookRequest
- type TestRegistryWebhookResponse
- type TransitionModelVersionStageDatabricks
- type TransitionRequest
- type TransitionStageResponse
- type UpdateComment
- type UpdateCommentResponse
- type UpdateExperiment
- type UpdateExperimentResponse
- type UpdateModelRequest
- type UpdateModelResponse
- type UpdateModelVersionRequest
- type UpdateModelVersionResponse
- type UpdateOnlineStoreRequest
- type UpdateRegistryWebhook
- type UpdateRun
- type UpdateRunResponse
- type UpdateRunStatus
- type UpdateWebhookResponse
- type ViewType
- type WaitGetExperimentForecastingSucceeded
- func (w *WaitGetExperimentForecastingSucceeded[R]) Get() (*ForecastingExperiment, error)
- func (w *WaitGetExperimentForecastingSucceeded[R]) GetWithTimeout(timeout time.Duration) (*ForecastingExperiment, error)
- func (w *WaitGetExperimentForecastingSucceeded[R]) OnProgress(callback func(*ForecastingExperiment)) *WaitGetExperimentForecastingSucceeded[R]
Examples ¶
- ExperimentsAPI.CreateExperiment (Experiments)
- ExperimentsAPI.CreateExperiment (MLflowRuns)
- ExperimentsAPI.CreateRun (MLflowRuns)
- ExperimentsAPI.GetExperiment (Experiments)
- ExperimentsAPI.ListExperiments (Experiments)
- ExperimentsAPI.UpdateExperiment (Experiments)
- ExperimentsAPI.UpdateRun (MLflowRuns)
- ModelRegistryAPI.CreateComment (ModelVersionComments)
- ModelRegistryAPI.CreateModel (ModelVersionComments)
- ModelRegistryAPI.CreateModel (ModelVersions)
- ModelRegistryAPI.CreateModel (Models)
- ModelRegistryAPI.CreateModelVersion (ModelVersionComments)
- ModelRegistryAPI.CreateModelVersion (ModelVersions)
- ModelRegistryAPI.CreateWebhook (RegistryWebhooks)
- ModelRegistryAPI.GetModel (Models)
- ModelRegistryAPI.ListModels (Models)
- ModelRegistryAPI.ListWebhooks (RegistryWebhooks)
- ModelRegistryAPI.UpdateComment (ModelVersionComments)
- ModelRegistryAPI.UpdateModel (Models)
- ModelRegistryAPI.UpdateModelVersion (ModelVersions)
- ModelRegistryAPI.UpdateWebhook (RegistryWebhooks)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Activity ¶
type Activity struct {
// Type of activity. Valid values are: * `APPLIED_TRANSITION`: User applied
// the corresponding stage transition.
//
// * `REQUESTED_TRANSITION`: User requested the corresponding stage
// transition.
//
// * `CANCELLED_REQUEST`: User cancelled an existing transition request.
//
// * `APPROVED_REQUEST`: User approved the corresponding stage transition.
//
// * `REJECTED_REQUEST`: User rejected the coressponding stage transition.
//
// * `SYSTEM_TRANSITION`: For events performed as a side effect, such as
// archiving existing model versions in a stage.
// Wire name: 'activity_type'
ActivityType ActivityType `json:"activity_type,omitempty"`
// User-provided comment associated with the activity.
// Wire name: 'comment'
Comment string `json:"comment,omitempty"`
// Creation time of the object, as a Unix timestamp in milliseconds.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// Source stage of the transition (if the activity is stage transition
// related). Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'from_stage'
FromStage Stage `json:"from_stage,omitempty"`
// Unique identifier for the object.
// Wire name: 'id'
Id string `json:"id,omitempty"`
// Time of the object at last update, as a Unix timestamp in milliseconds.
// Wire name: 'last_updated_timestamp'
LastUpdatedTimestamp int64 `json:"last_updated_timestamp,omitempty"`
// Comment made by system, for example explaining an activity of type
// `SYSTEM_TRANSITION`. It usually describes a side effect, such as a
// version being archived as part of another version's stage transition, and
// may not be returned for some activity types.
// Wire name: 'system_comment'
SystemComment string `json:"system_comment,omitempty"`
// Target stage of the transition (if the activity is stage transition
// related). Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'to_stage'
ToStage Stage `json:"to_stage,omitempty"`
// The username of the user that created the object.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Activity recorded for the action.
func (Activity) MarshalJSON ¶ added in v0.23.0
func (*Activity) UnmarshalJSON ¶ added in v0.23.0
type ActivityAction ¶
type ActivityAction string
An action that a user (with sufficient permissions) could take on an activity. Valid values are: * `APPROVE_TRANSITION_REQUEST`: Approve a transition request
* `REJECT_TRANSITION_REQUEST`: Reject a transition request
* `CANCEL_TRANSITION_REQUEST`: Cancel (delete) a transition request
const ActivityActionApproveTransitionRequest ActivityAction = `APPROVE_TRANSITION_REQUEST`
Approve a transition request
const ActivityActionCancelTransitionRequest ActivityAction = `CANCEL_TRANSITION_REQUEST`
Cancel (delete) a transition request
const ActivityActionRejectTransitionRequest ActivityAction = `REJECT_TRANSITION_REQUEST`
Reject a transition request
func (*ActivityAction) Set ¶
func (f *ActivityAction) Set(v string) error
Set raw string value and validate it against allowed values
func (*ActivityAction) String ¶
func (f *ActivityAction) String() string
String representation for fmt.Print
func (*ActivityAction) Type ¶
func (f *ActivityAction) Type() string
Type always returns ActivityAction to satisfy [pflag.Value] interface
func (*ActivityAction) Values ¶ added in v0.72.0
func (f *ActivityAction) Values() []ActivityAction
Values returns all possible values for ActivityAction.
There is no guarantee on the order of the values in the slice.
type ActivityType ¶
type ActivityType string
Type of activity. Valid values are: * `APPLIED_TRANSITION`: User applied the corresponding stage transition.
* `REQUESTED_TRANSITION`: User requested the corresponding stage transition.
* `CANCELLED_REQUEST`: User cancelled an existing transition request.
* `APPROVED_REQUEST`: User approved the corresponding stage transition.
* `REJECTED_REQUEST`: User rejected the coressponding stage transition.
* `SYSTEM_TRANSITION`: For events performed as a side effect, such as archiving existing model versions in a stage.
const ActivityTypeAppliedTransition ActivityType = `APPLIED_TRANSITION`
User applied the corresponding stage transition.
const ActivityTypeApprovedRequest ActivityType = `APPROVED_REQUEST`
User approved the corresponding stage transition.
const ActivityTypeCancelledRequest ActivityType = `CANCELLED_REQUEST`
User cancelled an existing transition request.
const ActivityTypeNewComment ActivityType = `NEW_COMMENT`
const ActivityTypeRejectedRequest ActivityType = `REJECTED_REQUEST`
User rejected the coressponding stage transition.
const ActivityTypeRequestedTransition ActivityType = `REQUESTED_TRANSITION`
User requested the corresponding stage transition.
const ActivityTypeSystemTransition ActivityType = `SYSTEM_TRANSITION`
For events performed as a side effect, such as archiving existing model versions in a stage.
func (*ActivityType) Set ¶
func (f *ActivityType) Set(v string) error
Set raw string value and validate it against allowed values
func (*ActivityType) String ¶
func (f *ActivityType) String() string
String representation for fmt.Print
func (*ActivityType) Type ¶
func (f *ActivityType) Type() string
Type always returns ActivityType to satisfy [pflag.Value] interface
func (*ActivityType) Values ¶ added in v0.72.0
func (f *ActivityType) Values() []ActivityType
Values returns all possible values for ActivityType.
There is no guarantee on the order of the values in the slice.
type ApproveTransitionRequest ¶
type ApproveTransitionRequest struct {
// Specifies whether to archive all current model versions in the target
// stage.
// Wire name: 'archive_existing_versions'
ArchiveExistingVersions bool `json:"archive_existing_versions"`
// User-provided comment on the action.
// Wire name: 'comment'
Comment string `json:"comment,omitempty"`
// Name of the model.
// Wire name: 'name'
Name string `json:"name"`
// Target stage of the transition. Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'stage'
Stage Stage `json:"stage"`
// Version of the model.
// Wire name: 'version'
Version string `json:"version"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ApproveTransitionRequest) MarshalJSON ¶ added in v0.23.0
func (st ApproveTransitionRequest) MarshalJSON() ([]byte, error)
func (*ApproveTransitionRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *ApproveTransitionRequest) UnmarshalJSON(b []byte) error
type ApproveTransitionRequestResponse ¶
type ApproveTransitionRequestResponse struct {
// Activity recorded for the action.
// Wire name: 'activity'
Activity *Activity `json:"activity,omitempty"`
}
func (ApproveTransitionRequestResponse) MarshalJSON ¶ added in v0.73.0
func (st ApproveTransitionRequestResponse) MarshalJSON() ([]byte, error)
func (*ApproveTransitionRequestResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *ApproveTransitionRequestResponse) UnmarshalJSON(b []byte) error
type CommentActivityAction ¶
type CommentActivityAction string
An action that a user (with sufficient permissions) could take on a comment. Valid values are: * `EDIT_COMMENT`: Edit the comment
* `DELETE_COMMENT`: Delete the comment
const CommentActivityActionDeleteComment CommentActivityAction = `DELETE_COMMENT`
Delete the comment
const CommentActivityActionEditComment CommentActivityAction = `EDIT_COMMENT`
Edit the comment
func (*CommentActivityAction) Set ¶
func (f *CommentActivityAction) Set(v string) error
Set raw string value and validate it against allowed values
func (*CommentActivityAction) String ¶
func (f *CommentActivityAction) String() string
String representation for fmt.Print
func (*CommentActivityAction) Type ¶
func (f *CommentActivityAction) Type() string
Type always returns CommentActivityAction to satisfy [pflag.Value] interface
func (*CommentActivityAction) Values ¶ added in v0.72.0
func (f *CommentActivityAction) Values() []CommentActivityAction
Values returns all possible values for CommentActivityAction.
There is no guarantee on the order of the values in the slice.
type CommentObject ¶
type CommentObject struct {
// Array of actions on the activity allowed for the current viewer.
// Wire name: 'available_actions'
AvailableActions []CommentActivityAction `json:"available_actions,omitempty"`
// User-provided comment on the action.
// Wire name: 'comment'
Comment string `json:"comment,omitempty"`
// Creation time of the object, as a Unix timestamp in milliseconds.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// Comment ID
// Wire name: 'id'
Id string `json:"id,omitempty"`
// Time of the object at last update, as a Unix timestamp in milliseconds.
// Wire name: 'last_updated_timestamp'
LastUpdatedTimestamp int64 `json:"last_updated_timestamp,omitempty"`
// The username of the user that created the object.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Comment details.
func (CommentObject) MarshalJSON ¶ added in v0.23.0
func (st CommentObject) MarshalJSON() ([]byte, error)
func (*CommentObject) UnmarshalJSON ¶ added in v0.23.0
func (st *CommentObject) UnmarshalJSON(b []byte) error
type CreateComment ¶
type CreateComment struct {
// User-provided comment on the action.
// Wire name: 'comment'
Comment string `json:"comment"`
// Name of the model.
// Wire name: 'name'
Name string `json:"name"`
// Version of the model.
// Wire name: 'version'
Version string `json:"version"`
}
func (CreateComment) MarshalJSON ¶ added in v0.73.0
func (st CreateComment) MarshalJSON() ([]byte, error)
func (*CreateComment) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateComment) UnmarshalJSON(b []byte) error
type CreateCommentResponse ¶
type CreateCommentResponse struct {
// Comment details.
// Wire name: 'comment'
Comment *CommentObject `json:"comment,omitempty"`
}
func (CreateCommentResponse) MarshalJSON ¶ added in v0.73.0
func (st CreateCommentResponse) MarshalJSON() ([]byte, error)
func (*CreateCommentResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateCommentResponse) UnmarshalJSON(b []byte) error
type CreateExperiment ¶
type CreateExperiment struct {
// Location where all artifacts for the experiment are stored. If not
// provided, the remote server will select an appropriate default.
// Wire name: 'artifact_location'
ArtifactLocation string `json:"artifact_location,omitempty"`
// Experiment name.
// Wire name: 'name'
Name string `json:"name"`
// A collection of tags to set on the experiment. Maximum tag size and
// number of tags per request depends on the storage backend. All storage
// backends are guaranteed to support tag keys up to 250 bytes in size and
// tag values up to 5000 bytes in size. All storage backends are also
// guaranteed to support up to 20 tags per request.
// Wire name: 'tags'
Tags []ExperimentTag `json:"tags,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateExperiment) MarshalJSON ¶ added in v0.23.0
func (st CreateExperiment) MarshalJSON() ([]byte, error)
func (*CreateExperiment) UnmarshalJSON ¶ added in v0.23.0
func (st *CreateExperiment) UnmarshalJSON(b []byte) error
type CreateExperimentResponse ¶
type CreateExperimentResponse struct {
// Unique identifier for the experiment.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateExperimentResponse) MarshalJSON ¶ added in v0.23.0
func (st CreateExperimentResponse) MarshalJSON() ([]byte, error)
func (*CreateExperimentResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *CreateExperimentResponse) UnmarshalJSON(b []byte) error
type CreateForecastingExperimentRequest ¶ added in v0.60.0
type CreateForecastingExperimentRequest struct {
// The column in the training table used to customize weights for each time
// series.
// Wire name: 'custom_weights_column'
CustomWeightsColumn string `json:"custom_weights_column,omitempty"`
// The path in the workspace to store the created experiment.
// Wire name: 'experiment_path'
ExperimentPath string `json:"experiment_path,omitempty"`
// The time interval between consecutive rows in the time series data.
// Possible values include: '1 second', '1 minute', '5 minutes', '10
// minutes', '15 minutes', '30 minutes', 'Hourly', 'Daily', 'Weekly',
// 'Monthly', 'Quarterly', 'Yearly'.
// Wire name: 'forecast_granularity'
ForecastGranularity string `json:"forecast_granularity"`
// The number of time steps into the future to make predictions, calculated
// as a multiple of forecast_granularity. This value represents how far
// ahead the model should forecast.
// Wire name: 'forecast_horizon'
ForecastHorizon int64 `json:"forecast_horizon"`
// The fully qualified path of a Unity Catalog table, formatted as
// catalog_name.schema_name.table_name, used to store future feature data
// for predictions.
// Wire name: 'future_feature_data_path'
FutureFeatureDataPath string `json:"future_feature_data_path,omitempty"`
// The region code(s) to automatically add holiday features. Currently
// supports only one region.
// Wire name: 'holiday_regions'
HolidayRegions []string `json:"holiday_regions,omitempty"`
// Specifies the list of feature columns to include in model training. These
// columns must exist in the training data and be of type string, numerical,
// or boolean. If not specified, no additional features will be included.
// Note: Certain columns are automatically handled: - Automatically
// excluded: split_column, target_column, custom_weights_column. -
// Automatically included: time_column.
// Wire name: 'include_features'
IncludeFeatures []string `json:"include_features,omitempty"`
// The maximum duration for the experiment in minutes. The experiment stops
// automatically if it exceeds this limit.
// Wire name: 'max_runtime'
MaxRuntime int64 `json:"max_runtime,omitempty"`
// The fully qualified path of a Unity Catalog table, formatted as
// catalog_name.schema_name.table_name, used to store predictions.
// Wire name: 'prediction_data_path'
PredictionDataPath string `json:"prediction_data_path,omitempty"`
// The evaluation metric used to optimize the forecasting model.
// Wire name: 'primary_metric'
PrimaryMetric string `json:"primary_metric,omitempty"`
// The fully qualified path of a Unity Catalog model, formatted as
// catalog_name.schema_name.model_name, used to store the best model.
// Wire name: 'register_to'
RegisterTo string `json:"register_to,omitempty"`
// // The column in the training table used for custom data splits. Values
// must be 'train', 'validate', or 'test'.
// Wire name: 'split_column'
SplitColumn string `json:"split_column,omitempty"`
// The column in the input training table used as the prediction target for
// model training. The values in this column are used as the ground truth
// for model training.
// Wire name: 'target_column'
TargetColumn string `json:"target_column"`
// The column in the input training table that represents each row's
// timestamp.
// Wire name: 'time_column'
TimeColumn string `json:"time_column"`
// The column in the training table used to group the dataset for predicting
// individual time series.
// Wire name: 'timeseries_identifier_columns'
TimeseriesIdentifierColumns []string `json:"timeseries_identifier_columns,omitempty"`
// The fully qualified path of a Unity Catalog table, formatted as
// catalog_name.schema_name.table_name, used as training data for the
// forecasting model.
// Wire name: 'train_data_path'
TrainDataPath string `json:"train_data_path"`
// List of frameworks to include for model tuning. Possible values are
// 'Prophet', 'ARIMA', 'DeepAR'. An empty list includes all supported
// frameworks.
// Wire name: 'training_frameworks'
TrainingFrameworks []string `json:"training_frameworks,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateForecastingExperimentRequest) MarshalJSON ¶ added in v0.60.0
func (st CreateForecastingExperimentRequest) MarshalJSON() ([]byte, error)
func (*CreateForecastingExperimentRequest) UnmarshalJSON ¶ added in v0.60.0
func (st *CreateForecastingExperimentRequest) UnmarshalJSON(b []byte) error
type CreateForecastingExperimentResponse ¶ added in v0.60.0
type CreateForecastingExperimentResponse struct {
// The unique ID of the created forecasting experiment
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateForecastingExperimentResponse) MarshalJSON ¶ added in v0.60.0
func (st CreateForecastingExperimentResponse) MarshalJSON() ([]byte, error)
func (*CreateForecastingExperimentResponse) UnmarshalJSON ¶ added in v0.60.0
func (st *CreateForecastingExperimentResponse) UnmarshalJSON(b []byte) error
type CreateLoggedModelRequest ¶ added in v0.70.0
type CreateLoggedModelRequest struct {
// The ID of the experiment that owns the model.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id"`
// The type of the model, such as “"Agent"“, “"Classifier"“, “"LLM"“.
// Wire name: 'model_type'
ModelType string `json:"model_type,omitempty"`
// The name of the model (optional). If not specified one will be generated.
// Wire name: 'name'
Name string `json:"name,omitempty"`
// Parameters attached to the model.
// Wire name: 'params'
Params []LoggedModelParameter `json:"params,omitempty"`
// The ID of the run that created the model.
// Wire name: 'source_run_id'
SourceRunId string `json:"source_run_id,omitempty"`
// Tags attached to the model.
// Wire name: 'tags'
Tags []LoggedModelTag `json:"tags,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateLoggedModelRequest) MarshalJSON ¶ added in v0.70.0
func (st CreateLoggedModelRequest) MarshalJSON() ([]byte, error)
func (*CreateLoggedModelRequest) UnmarshalJSON ¶ added in v0.70.0
func (st *CreateLoggedModelRequest) UnmarshalJSON(b []byte) error
type CreateLoggedModelResponse ¶ added in v0.70.0
type CreateLoggedModelResponse struct {
// The newly created logged model.
// Wire name: 'model'
Model *LoggedModel `json:"model,omitempty"`
}
func (CreateLoggedModelResponse) MarshalJSON ¶ added in v0.73.0
func (st CreateLoggedModelResponse) MarshalJSON() ([]byte, error)
func (*CreateLoggedModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateLoggedModelResponse) UnmarshalJSON(b []byte) error
type CreateModelRequest ¶
type CreateModelRequest struct {
// Optional description for registered model.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Register models under this name
// Wire name: 'name'
Name string `json:"name"`
// Additional metadata for registered model.
// Wire name: 'tags'
Tags []ModelTag `json:"tags,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateModelRequest) MarshalJSON ¶ added in v0.23.0
func (st CreateModelRequest) MarshalJSON() ([]byte, error)
func (*CreateModelRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *CreateModelRequest) UnmarshalJSON(b []byte) error
type CreateModelResponse ¶
type CreateModelResponse struct {
// Wire name: 'registered_model'
RegisteredModel *Model `json:"registered_model,omitempty"`
}
func (CreateModelResponse) MarshalJSON ¶ added in v0.73.0
func (st CreateModelResponse) MarshalJSON() ([]byte, error)
func (*CreateModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateModelResponse) UnmarshalJSON(b []byte) error
type CreateModelVersionRequest ¶
type CreateModelVersionRequest struct {
// Optional description for model version.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Register model under this name
// Wire name: 'name'
Name string `json:"name"`
// MLflow run ID for correlation, if `source` was generated by an experiment
// run in MLflow tracking server
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// MLflow run link - this is the exact link of the run that generated this
// model version, potentially hosted at another instance of MLflow.
// Wire name: 'run_link'
RunLink string `json:"run_link,omitempty"`
// URI indicating the location of the model artifacts.
// Wire name: 'source'
Source string `json:"source"`
// Additional metadata for model version.
// Wire name: 'tags'
Tags []ModelVersionTag `json:"tags,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateModelVersionRequest) MarshalJSON ¶ added in v0.23.0
func (st CreateModelVersionRequest) MarshalJSON() ([]byte, error)
func (*CreateModelVersionRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *CreateModelVersionRequest) UnmarshalJSON(b []byte) error
type CreateModelVersionResponse ¶
type CreateModelVersionResponse struct {
// Return new version number generated for this model in registry.
// Wire name: 'model_version'
ModelVersion *ModelVersion `json:"model_version,omitempty"`
}
func (CreateModelVersionResponse) MarshalJSON ¶ added in v0.73.0
func (st CreateModelVersionResponse) MarshalJSON() ([]byte, error)
func (*CreateModelVersionResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateModelVersionResponse) UnmarshalJSON(b []byte) error
type CreateOnlineStoreRequest ¶ added in v0.73.0
type CreateOnlineStoreRequest struct {
// An OnlineStore is a logical database instance that stores and serves
// features online.
// Wire name: 'online_store'
OnlineStore OnlineStore `json:"online_store"`
}
Create an Online Feature Store
func (CreateOnlineStoreRequest) MarshalJSON ¶ added in v0.73.0
func (st CreateOnlineStoreRequest) MarshalJSON() ([]byte, error)
func (*CreateOnlineStoreRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateOnlineStoreRequest) UnmarshalJSON(b []byte) error
type CreateRegistryWebhook ¶
type CreateRegistryWebhook struct {
// User-specified description for the webhook.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Events that can trigger a registry webhook: * `MODEL_VERSION_CREATED`: A
// new model version was created for the associated model.
//
// * `MODEL_VERSION_TRANSITIONED_STAGE`: A model version’s stage was
// changed.
//
// * `TRANSITION_REQUEST_CREATED`: A user requested a model version’s
// stage be transitioned.
//
// * `COMMENT_CREATED`: A user wrote a comment on a registered model.
//
// * `REGISTERED_MODEL_CREATED`: A new registered model was created. This
// event type can only be specified for a registry-wide webhook, which can
// be created by not specifying a model name in the create request.
//
// * `MODEL_VERSION_TAG_SET`: A user set a tag on the model version.
//
// * `MODEL_VERSION_TRANSITIONED_TO_STAGING`: A model version was
// transitioned to staging.
//
// * `MODEL_VERSION_TRANSITIONED_TO_PRODUCTION`: A model version was
// transitioned to production.
//
// * `MODEL_VERSION_TRANSITIONED_TO_ARCHIVED`: A model version was archived.
//
// * `TRANSITION_REQUEST_TO_STAGING_CREATED`: A user requested a model
// version be transitioned to staging.
//
// * `TRANSITION_REQUEST_TO_PRODUCTION_CREATED`: A user requested a model
// version be transitioned to production.
//
// * `TRANSITION_REQUEST_TO_ARCHIVED_CREATED`: A user requested a model
// version be archived.
// Wire name: 'events'
Events []RegistryWebhookEvent `json:"events"`
// Wire name: 'http_url_spec'
HttpUrlSpec *HttpUrlSpec `json:"http_url_spec,omitempty"`
// Wire name: 'job_spec'
JobSpec *JobSpec `json:"job_spec,omitempty"`
// If model name is not specified, a registry-wide webhook is created that
// listens for the specified events across all versions of all registered
// models.
// Wire name: 'model_name'
ModelName string `json:"model_name,omitempty"`
// Enable or disable triggering the webhook, or put the webhook into test
// mode. The default is `ACTIVE`: * `ACTIVE`: Webhook is triggered when an
// associated event happens.
//
// * `DISABLED`: Webhook is not triggered.
//
// * `TEST_MODE`: Webhook can be triggered through the test endpoint, but is
// not triggered on a real event.
// Wire name: 'status'
Status RegistryWebhookStatus `json:"status,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateRegistryWebhook) MarshalJSON ¶ added in v0.23.0
func (st CreateRegistryWebhook) MarshalJSON() ([]byte, error)
func (*CreateRegistryWebhook) UnmarshalJSON ¶ added in v0.23.0
func (st *CreateRegistryWebhook) UnmarshalJSON(b []byte) error
type CreateRun ¶
type CreateRun struct {
// ID of the associated experiment.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id,omitempty"`
// The name of the run.
// Wire name: 'run_name'
RunName string `json:"run_name,omitempty"`
// Unix timestamp in milliseconds of when the run started.
// Wire name: 'start_time'
StartTime int64 `json:"start_time,omitempty"`
// Additional metadata for run.
// Wire name: 'tags'
Tags []RunTag `json:"tags,omitempty"`
// ID of the user executing the run. This field is deprecated as of MLflow
// 1.0, and will be removed in a future MLflow release. Use 'mlflow.user'
// tag instead.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateRun) MarshalJSON ¶ added in v0.23.0
func (*CreateRun) UnmarshalJSON ¶ added in v0.23.0
type CreateRunResponse ¶
type CreateRunResponse struct {
// The newly created run.
// Wire name: 'run'
Run *Run `json:"run,omitempty"`
}
func (CreateRunResponse) MarshalJSON ¶ added in v0.73.0
func (st CreateRunResponse) MarshalJSON() ([]byte, error)
func (*CreateRunResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateRunResponse) UnmarshalJSON(b []byte) error
type CreateTransitionRequest ¶
type CreateTransitionRequest struct {
// User-provided comment on the action.
// Wire name: 'comment'
Comment string `json:"comment,omitempty"`
// Name of the model.
// Wire name: 'name'
Name string `json:"name"`
// Target stage of the transition. Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'stage'
Stage Stage `json:"stage"`
// Version of the model.
// Wire name: 'version'
Version string `json:"version"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (CreateTransitionRequest) MarshalJSON ¶ added in v0.23.0
func (st CreateTransitionRequest) MarshalJSON() ([]byte, error)
func (*CreateTransitionRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *CreateTransitionRequest) UnmarshalJSON(b []byte) error
type CreateTransitionRequestResponse ¶
type CreateTransitionRequestResponse struct {
// Transition request details.
// Wire name: 'request'
Request *TransitionRequest `json:"request,omitempty"`
}
func (CreateTransitionRequestResponse) MarshalJSON ¶ added in v0.73.0
func (st CreateTransitionRequestResponse) MarshalJSON() ([]byte, error)
func (*CreateTransitionRequestResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateTransitionRequestResponse) UnmarshalJSON(b []byte) error
type CreateWebhookResponse ¶
type CreateWebhookResponse struct {
// Wire name: 'webhook'
Webhook *RegistryWebhook `json:"webhook,omitempty"`
}
func (CreateWebhookResponse) MarshalJSON ¶ added in v0.73.0
func (st CreateWebhookResponse) MarshalJSON() ([]byte, error)
func (*CreateWebhookResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *CreateWebhookResponse) UnmarshalJSON(b []byte) error
type Dataset ¶ added in v0.9.0
type Dataset struct {
// Dataset digest, e.g. an md5 hash of the dataset that uniquely identifies
// it within datasets of the same name.
// Wire name: 'digest'
Digest string `json:"digest"`
// The name of the dataset. E.g. “my.uc.table@2” “nyc-taxi-dataset”,
// “fantastic-elk-3”
// Wire name: 'name'
Name string `json:"name"`
// The profile of the dataset. Summary statistics for the dataset, such as
// the number of rows in a table, the mean / std / mode of each column in a
// table, or the number of elements in an array.
// Wire name: 'profile'
Profile string `json:"profile,omitempty"`
// The schema of the dataset. E.g., MLflow ColSpec JSON for a dataframe,
// MLflow TensorSpec JSON for an ndarray, or another schema format.
// Wire name: 'schema'
Schema string `json:"schema,omitempty"`
// Source information for the dataset. Note that the source may not exactly
// reproduce the dataset if it was transformed / modified before use with
// MLflow.
// Wire name: 'source'
Source string `json:"source"`
// The type of the dataset source, e.g. ‘databricks-uc-table’,
// ‘DBFS’, ‘S3’, ...
// Wire name: 'source_type'
SourceType string `json:"source_type"`
ForceSendFields []string `json:"-" tf:"-"`
}
Dataset. Represents a reference to data used for training, testing, or evaluation during the model development process.
func (Dataset) MarshalJSON ¶ added in v0.23.0
func (*Dataset) UnmarshalJSON ¶ added in v0.23.0
type DatasetInput ¶ added in v0.9.0
type DatasetInput struct {
// The dataset being used as a Run input.
// Wire name: 'dataset'
Dataset Dataset `json:"dataset"`
// A list of tags for the dataset input, e.g. a “context” tag with value
// “training”
// Wire name: 'tags'
Tags []InputTag `json:"tags,omitempty"`
}
DatasetInput. Represents a dataset and input tags.
func (DatasetInput) MarshalJSON ¶ added in v0.73.0
func (st DatasetInput) MarshalJSON() ([]byte, error)
func (*DatasetInput) UnmarshalJSON ¶ added in v0.73.0
func (st *DatasetInput) UnmarshalJSON(b []byte) error
type DeleteCommentRequest ¶
type DeleteCommentRequest struct {
// Unique identifier of an activity
Id string `json:"-" tf:"-"`
}
Delete a comment
func (DeleteCommentRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteCommentRequest) MarshalJSON() ([]byte, error)
func (*DeleteCommentRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteCommentRequest) UnmarshalJSON(b []byte) error
type DeleteCommentResponse ¶ added in v0.34.0
type DeleteCommentResponse struct {
}
func (DeleteCommentResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteCommentResponse) MarshalJSON() ([]byte, error)
func (*DeleteCommentResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteCommentResponse) UnmarshalJSON(b []byte) error
type DeleteExperiment ¶
type DeleteExperiment struct {
// ID of the associated experiment.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id"`
}
func (DeleteExperiment) MarshalJSON ¶ added in v0.73.0
func (st DeleteExperiment) MarshalJSON() ([]byte, error)
func (*DeleteExperiment) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteExperiment) UnmarshalJSON(b []byte) error
type DeleteExperimentResponse ¶ added in v0.34.0
type DeleteExperimentResponse struct {
}
func (DeleteExperimentResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteExperimentResponse) MarshalJSON() ([]byte, error)
func (*DeleteExperimentResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteExperimentResponse) UnmarshalJSON(b []byte) error
type DeleteLoggedModelRequest ¶ added in v0.70.0
type DeleteLoggedModelRequest struct {
// The ID of the logged model to delete.
ModelId string `json:"-" tf:"-"`
}
Delete a logged model
func (DeleteLoggedModelRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteLoggedModelRequest) MarshalJSON() ([]byte, error)
func (*DeleteLoggedModelRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteLoggedModelRequest) UnmarshalJSON(b []byte) error
type DeleteLoggedModelResponse ¶ added in v0.70.0
type DeleteLoggedModelResponse struct {
}
func (DeleteLoggedModelResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteLoggedModelResponse) MarshalJSON() ([]byte, error)
func (*DeleteLoggedModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteLoggedModelResponse) UnmarshalJSON(b []byte) error
type DeleteLoggedModelTagRequest ¶ added in v0.70.0
type DeleteLoggedModelTagRequest struct {
// The ID of the logged model to delete the tag from.
ModelId string `json:"-" tf:"-"`
// The tag key.
TagKey string `json:"-" tf:"-"`
}
Delete a tag on a logged model
func (DeleteLoggedModelTagRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteLoggedModelTagRequest) MarshalJSON() ([]byte, error)
func (*DeleteLoggedModelTagRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteLoggedModelTagRequest) UnmarshalJSON(b []byte) error
type DeleteLoggedModelTagResponse ¶ added in v0.70.0
type DeleteLoggedModelTagResponse struct {
}
func (DeleteLoggedModelTagResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteLoggedModelTagResponse) MarshalJSON() ([]byte, error)
func (*DeleteLoggedModelTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteLoggedModelTagResponse) UnmarshalJSON(b []byte) error
type DeleteModelRequest ¶
type DeleteModelRequest struct {
// Registered model unique name identifier.
Name string `json:"-" tf:"-"`
}
Delete a model
func (DeleteModelRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelRequest) MarshalJSON() ([]byte, error)
func (*DeleteModelRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelRequest) UnmarshalJSON(b []byte) error
type DeleteModelResponse ¶ added in v0.34.0
type DeleteModelResponse struct {
}
func (DeleteModelResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelResponse) MarshalJSON() ([]byte, error)
func (*DeleteModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelResponse) UnmarshalJSON(b []byte) error
type DeleteModelTagRequest ¶
type DeleteModelTagRequest struct {
// Name of the tag. The name must be an exact match; wild-card deletion is
// not supported. Maximum size is 250 bytes.
Key string `json:"-" tf:"-"`
// Name of the registered model that the tag was logged under.
Name string `json:"-" tf:"-"`
}
Delete a model tag
func (DeleteModelTagRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelTagRequest) MarshalJSON() ([]byte, error)
func (*DeleteModelTagRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelTagRequest) UnmarshalJSON(b []byte) error
type DeleteModelTagResponse ¶ added in v0.34.0
type DeleteModelTagResponse struct {
}
func (DeleteModelTagResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelTagResponse) MarshalJSON() ([]byte, error)
func (*DeleteModelTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelTagResponse) UnmarshalJSON(b []byte) error
type DeleteModelVersionRequest ¶
type DeleteModelVersionRequest struct {
// Name of the registered model
Name string `json:"-" tf:"-"`
// Model version number
Version string `json:"-" tf:"-"`
}
Delete a model version.
func (DeleteModelVersionRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelVersionRequest) MarshalJSON() ([]byte, error)
func (*DeleteModelVersionRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelVersionRequest) UnmarshalJSON(b []byte) error
type DeleteModelVersionResponse ¶ added in v0.34.0
type DeleteModelVersionResponse struct {
}
func (DeleteModelVersionResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelVersionResponse) MarshalJSON() ([]byte, error)
func (*DeleteModelVersionResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelVersionResponse) UnmarshalJSON(b []byte) error
type DeleteModelVersionTagRequest ¶
type DeleteModelVersionTagRequest struct {
// Name of the tag. The name must be an exact match; wild-card deletion is
// not supported. Maximum size is 250 bytes.
Key string `json:"-" tf:"-"`
// Name of the registered model that the tag was logged under.
Name string `json:"-" tf:"-"`
// Model version number that the tag was logged under.
Version string `json:"-" tf:"-"`
}
Delete a model version tag
func (DeleteModelVersionTagRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelVersionTagRequest) MarshalJSON() ([]byte, error)
func (*DeleteModelVersionTagRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelVersionTagRequest) UnmarshalJSON(b []byte) error
type DeleteModelVersionTagResponse ¶ added in v0.34.0
type DeleteModelVersionTagResponse struct {
}
func (DeleteModelVersionTagResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteModelVersionTagResponse) MarshalJSON() ([]byte, error)
func (*DeleteModelVersionTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteModelVersionTagResponse) UnmarshalJSON(b []byte) error
type DeleteOnlineStoreRequest ¶ added in v0.73.0
type DeleteOnlineStoreRequest struct {
// Name of the online store to delete.
Name string `json:"-" tf:"-"`
}
Delete an Online Feature Store
func (DeleteOnlineStoreRequest) MarshalJSON ¶ added in v0.73.0
func (st DeleteOnlineStoreRequest) MarshalJSON() ([]byte, error)
func (*DeleteOnlineStoreRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteOnlineStoreRequest) UnmarshalJSON(b []byte) error
type DeleteOnlineStoreResponse ¶ added in v0.73.0
type DeleteOnlineStoreResponse struct {
}
func (DeleteOnlineStoreResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteOnlineStoreResponse) MarshalJSON() ([]byte, error)
func (*DeleteOnlineStoreResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteOnlineStoreResponse) UnmarshalJSON(b []byte) error
type DeleteRun ¶
type DeleteRun struct {
// ID of the run to delete.
// Wire name: 'run_id'
RunId string `json:"run_id"`
}
func (DeleteRun) MarshalJSON ¶ added in v0.73.0
func (*DeleteRun) UnmarshalJSON ¶ added in v0.73.0
type DeleteRunResponse ¶ added in v0.34.0
type DeleteRunResponse struct {
}
func (DeleteRunResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteRunResponse) MarshalJSON() ([]byte, error)
func (*DeleteRunResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteRunResponse) UnmarshalJSON(b []byte) error
type DeleteRuns ¶ added in v0.17.0
type DeleteRuns struct {
// The ID of the experiment containing the runs to delete.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id"`
// An optional positive integer indicating the maximum number of runs to
// delete. The maximum allowed value for max_runs is 10000.
// Wire name: 'max_runs'
MaxRuns int `json:"max_runs,omitempty"`
// The maximum creation timestamp in milliseconds since the UNIX epoch for
// deleting runs. Only runs created prior to or at this timestamp are
// deleted.
// Wire name: 'max_timestamp_millis'
MaxTimestampMillis int64 `json:"max_timestamp_millis"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (DeleteRuns) MarshalJSON ¶ added in v0.23.0
func (st DeleteRuns) MarshalJSON() ([]byte, error)
func (*DeleteRuns) UnmarshalJSON ¶ added in v0.23.0
func (st *DeleteRuns) UnmarshalJSON(b []byte) error
type DeleteRunsResponse ¶ added in v0.17.0
type DeleteRunsResponse struct {
// The number of runs deleted.
// Wire name: 'runs_deleted'
RunsDeleted int `json:"runs_deleted,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (DeleteRunsResponse) MarshalJSON ¶ added in v0.23.0
func (st DeleteRunsResponse) MarshalJSON() ([]byte, error)
func (*DeleteRunsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *DeleteRunsResponse) UnmarshalJSON(b []byte) error
type DeleteTag ¶
type DeleteTag struct {
// Name of the tag. Maximum size is 255 bytes. Must be provided.
// Wire name: 'key'
Key string `json:"key"`
// ID of the run that the tag was logged under. Must be provided.
// Wire name: 'run_id'
RunId string `json:"run_id"`
}
func (DeleteTag) MarshalJSON ¶ added in v0.73.0
func (*DeleteTag) UnmarshalJSON ¶ added in v0.73.0
type DeleteTagResponse ¶ added in v0.34.0
type DeleteTagResponse struct {
}
func (DeleteTagResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteTagResponse) MarshalJSON() ([]byte, error)
func (*DeleteTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteTagResponse) UnmarshalJSON(b []byte) error
type DeleteTransitionRequestRequest ¶
type DeleteTransitionRequestRequest struct {
// User-provided comment on the action.
Comment string `json:"-" tf:"-"`
// Username of the user who created this request. Of the transition requests
// matching the specified details, only the one transition created by this
// user will be deleted.
Creator string `json:"-" tf:"-"`
// Name of the model.
Name string `json:"-" tf:"-"`
// Target stage of the transition request. Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
Stage DeleteTransitionRequestStage `json:"-" tf:"-"`
// Version of the model.
Version string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
Delete a transition request
func (DeleteTransitionRequestRequest) MarshalJSON ¶ added in v0.23.0
func (st DeleteTransitionRequestRequest) MarshalJSON() ([]byte, error)
func (*DeleteTransitionRequestRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *DeleteTransitionRequestRequest) UnmarshalJSON(b []byte) error
type DeleteTransitionRequestResponse ¶ added in v0.34.0
type DeleteTransitionRequestResponse struct {
}
func (DeleteTransitionRequestResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteTransitionRequestResponse) MarshalJSON() ([]byte, error)
func (*DeleteTransitionRequestResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteTransitionRequestResponse) UnmarshalJSON(b []byte) error
type DeleteTransitionRequestStage ¶ added in v0.9.0
type DeleteTransitionRequestStage string
const DeleteTransitionRequestStageArchived DeleteTransitionRequestStage = `Archived`
const DeleteTransitionRequestStageNone DeleteTransitionRequestStage = `None`
const DeleteTransitionRequestStageProduction DeleteTransitionRequestStage = `Production`
const DeleteTransitionRequestStageStaging DeleteTransitionRequestStage = `Staging`
func (*DeleteTransitionRequestStage) Set ¶ added in v0.9.0
func (f *DeleteTransitionRequestStage) Set(v string) error
Set raw string value and validate it against allowed values
func (*DeleteTransitionRequestStage) String ¶ added in v0.9.0
func (f *DeleteTransitionRequestStage) String() string
String representation for fmt.Print
func (*DeleteTransitionRequestStage) Type ¶ added in v0.9.0
func (f *DeleteTransitionRequestStage) Type() string
Type always returns DeleteTransitionRequestStage to satisfy [pflag.Value] interface
func (*DeleteTransitionRequestStage) Values ¶ added in v0.72.0
func (f *DeleteTransitionRequestStage) Values() []DeleteTransitionRequestStage
Values returns all possible values for DeleteTransitionRequestStage.
There is no guarantee on the order of the values in the slice.
type DeleteWebhookRequest ¶
type DeleteWebhookRequest struct {
// Webhook ID required to delete a registry webhook.
Id string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
Delete a webhook
func (DeleteWebhookRequest) MarshalJSON ¶ added in v0.23.0
func (st DeleteWebhookRequest) MarshalJSON() ([]byte, error)
func (*DeleteWebhookRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *DeleteWebhookRequest) UnmarshalJSON(b []byte) error
type DeleteWebhookResponse ¶ added in v0.34.0
type DeleteWebhookResponse struct {
}
func (DeleteWebhookResponse) MarshalJSON ¶ added in v0.73.0
func (st DeleteWebhookResponse) MarshalJSON() ([]byte, error)
func (*DeleteWebhookResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *DeleteWebhookResponse) UnmarshalJSON(b []byte) error
type Experiment ¶
type Experiment struct {
// Location where artifacts for the experiment are stored.
// Wire name: 'artifact_location'
ArtifactLocation string `json:"artifact_location,omitempty"`
// Creation time
// Wire name: 'creation_time'
CreationTime int64 `json:"creation_time,omitempty"`
// Unique identifier for the experiment.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id,omitempty"`
// Last update time
// Wire name: 'last_update_time'
LastUpdateTime int64 `json:"last_update_time,omitempty"`
// Current life cycle stage of the experiment: "active" or "deleted".
// Deleted experiments are not returned by APIs.
// Wire name: 'lifecycle_stage'
LifecycleStage string `json:"lifecycle_stage,omitempty"`
// Human readable name that identifies the experiment.
// Wire name: 'name'
Name string `json:"name,omitempty"`
// Tags: Additional metadata key-value pairs.
// Wire name: 'tags'
Tags []ExperimentTag `json:"tags,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
An experiment and its metadata.
func (Experiment) MarshalJSON ¶ added in v0.23.0
func (st Experiment) MarshalJSON() ([]byte, error)
func (*Experiment) UnmarshalJSON ¶ added in v0.23.0
func (st *Experiment) UnmarshalJSON(b []byte) error
type ExperimentAccessControlRequest ¶ added in v0.15.0
type ExperimentAccessControlRequest struct {
// name of the group
// Wire name: 'group_name'
GroupName string `json:"group_name,omitempty"`
// Permission level
// Wire name: 'permission_level'
PermissionLevel ExperimentPermissionLevel `json:"permission_level,omitempty"`
// application ID of a service principal
// Wire name: 'service_principal_name'
ServicePrincipalName string `json:"service_principal_name,omitempty"`
// name of the user
// Wire name: 'user_name'
UserName string `json:"user_name,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ExperimentAccessControlRequest) MarshalJSON ¶ added in v0.23.0
func (st ExperimentAccessControlRequest) MarshalJSON() ([]byte, error)
func (*ExperimentAccessControlRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *ExperimentAccessControlRequest) UnmarshalJSON(b []byte) error
type ExperimentAccessControlResponse ¶ added in v0.15.0
type ExperimentAccessControlResponse struct {
// All permissions.
// Wire name: 'all_permissions'
AllPermissions []ExperimentPermission `json:"all_permissions,omitempty"`
// Display name of the user or service principal.
// Wire name: 'display_name'
DisplayName string `json:"display_name,omitempty"`
// name of the group
// Wire name: 'group_name'
GroupName string `json:"group_name,omitempty"`
// Name of the service principal.
// Wire name: 'service_principal_name'
ServicePrincipalName string `json:"service_principal_name,omitempty"`
// name of the user
// Wire name: 'user_name'
UserName string `json:"user_name,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ExperimentAccessControlResponse) MarshalJSON ¶ added in v0.23.0
func (st ExperimentAccessControlResponse) MarshalJSON() ([]byte, error)
func (*ExperimentAccessControlResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *ExperimentAccessControlResponse) UnmarshalJSON(b []byte) error
type ExperimentPermission ¶ added in v0.15.0
type ExperimentPermission struct {
// Wire name: 'inherited'
Inherited bool `json:"inherited,omitempty"`
// Wire name: 'inherited_from_object'
InheritedFromObject []string `json:"inherited_from_object,omitempty"`
// Permission level
// Wire name: 'permission_level'
PermissionLevel ExperimentPermissionLevel `json:"permission_level,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ExperimentPermission) MarshalJSON ¶ added in v0.23.0
func (st ExperimentPermission) MarshalJSON() ([]byte, error)
func (*ExperimentPermission) UnmarshalJSON ¶ added in v0.23.0
func (st *ExperimentPermission) UnmarshalJSON(b []byte) error
type ExperimentPermissionLevel ¶ added in v0.15.0
type ExperimentPermissionLevel string
Permission level
const ExperimentPermissionLevelCanEdit ExperimentPermissionLevel = `CAN_EDIT`
const ExperimentPermissionLevelCanManage ExperimentPermissionLevel = `CAN_MANAGE`
const ExperimentPermissionLevelCanRead ExperimentPermissionLevel = `CAN_READ`
func (*ExperimentPermissionLevel) Set ¶ added in v0.15.0
func (f *ExperimentPermissionLevel) Set(v string) error
Set raw string value and validate it against allowed values
func (*ExperimentPermissionLevel) String ¶ added in v0.15.0
func (f *ExperimentPermissionLevel) String() string
String representation for fmt.Print
func (*ExperimentPermissionLevel) Type ¶ added in v0.15.0
func (f *ExperimentPermissionLevel) Type() string
Type always returns ExperimentPermissionLevel to satisfy [pflag.Value] interface
func (*ExperimentPermissionLevel) Values ¶ added in v0.72.0
func (f *ExperimentPermissionLevel) Values() []ExperimentPermissionLevel
Values returns all possible values for ExperimentPermissionLevel.
There is no guarantee on the order of the values in the slice.
type ExperimentPermissions ¶ added in v0.15.0
type ExperimentPermissions struct {
// Wire name: 'access_control_list'
AccessControlList []ExperimentAccessControlResponse `json:"access_control_list,omitempty"`
// Wire name: 'object_id'
ObjectId string `json:"object_id,omitempty"`
// Wire name: 'object_type'
ObjectType string `json:"object_type,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ExperimentPermissions) MarshalJSON ¶ added in v0.23.0
func (st ExperimentPermissions) MarshalJSON() ([]byte, error)
func (*ExperimentPermissions) UnmarshalJSON ¶ added in v0.23.0
func (st *ExperimentPermissions) UnmarshalJSON(b []byte) error
type ExperimentPermissionsDescription ¶ added in v0.15.0
type ExperimentPermissionsDescription struct {
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Permission level
// Wire name: 'permission_level'
PermissionLevel ExperimentPermissionLevel `json:"permission_level,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ExperimentPermissionsDescription) MarshalJSON ¶ added in v0.23.0
func (st ExperimentPermissionsDescription) MarshalJSON() ([]byte, error)
func (*ExperimentPermissionsDescription) UnmarshalJSON ¶ added in v0.23.0
func (st *ExperimentPermissionsDescription) UnmarshalJSON(b []byte) error
type ExperimentPermissionsRequest ¶ added in v0.15.0
type ExperimentPermissionsRequest struct {
// Wire name: 'access_control_list'
AccessControlList []ExperimentAccessControlRequest `json:"access_control_list,omitempty"`
// The experiment for which to get or manage permissions.
ExperimentId string `json:"-" tf:"-"`
}
func (ExperimentPermissionsRequest) MarshalJSON ¶ added in v0.73.0
func (st ExperimentPermissionsRequest) MarshalJSON() ([]byte, error)
func (*ExperimentPermissionsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *ExperimentPermissionsRequest) UnmarshalJSON(b []byte) error
type ExperimentTag ¶
type ExperimentTag struct {
// The tag key.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// The tag value.
// Wire name: 'value'
Value string `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
A tag for an experiment.
func (ExperimentTag) MarshalJSON ¶ added in v0.23.0
func (st ExperimentTag) MarshalJSON() ([]byte, error)
func (*ExperimentTag) UnmarshalJSON ¶ added in v0.23.0
func (st *ExperimentTag) UnmarshalJSON(b []byte) error
type ExperimentsAPI ¶
type ExperimentsAPI struct {
// contains filtered or unexported fields
}
Experiments are the primary unit of organization in MLflow; all MLflow runs belong to an experiment. Each experiment lets you visualize, search, and compare runs, as well as download run artifacts or metadata for analysis in other tools. Experiments are maintained in a Databricks hosted MLflow tracking server.
Experiments are located in the workspace file tree. You manage experiments using the same tools you use to manage other workspace objects such as folders, notebooks, and libraries.
func NewExperiments ¶
func NewExperiments(client *client.DatabricksClient) *ExperimentsAPI
func (*ExperimentsAPI) CreateExperiment ¶
func (a *ExperimentsAPI) CreateExperiment(ctx context.Context, request CreateExperiment) (*CreateExperimentResponse, error)
Example (Experiments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
experiment, err := w.Experiments.CreateExperiment(ctx, ml.CreateExperiment{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", experiment)
// cleanup
err = w.Experiments.DeleteExperiment(ctx, ml.DeleteExperiment{
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
Example (MLflowRuns) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
experiment, err := w.Experiments.CreateExperiment(ctx, ml.CreateExperiment{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", experiment)
// cleanup
err = w.Experiments.DeleteExperiment(ctx, ml.DeleteExperiment{
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
func (*ExperimentsAPI) CreateLoggedModel ¶ added in v0.70.0
func (a *ExperimentsAPI) CreateLoggedModel(ctx context.Context, request CreateLoggedModelRequest) (*CreateLoggedModelResponse, error)
func (*ExperimentsAPI) CreateRun ¶
func (a *ExperimentsAPI) CreateRun(ctx context.Context, request CreateRun) (*CreateRunResponse, error)
Example (MLflowRuns) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
experiment, err := w.Experiments.CreateExperiment(ctx, ml.CreateExperiment{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", experiment)
created, err := w.Experiments.CreateRun(ctx, ml.CreateRun{
ExperimentId: experiment.ExperimentId,
Tags: []ml.RunTag{ml.RunTag{
Key: "foo",
Value: "bar",
}},
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
// cleanup
err = w.Experiments.DeleteExperiment(ctx, ml.DeleteExperiment{
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
err = w.Experiments.DeleteRun(ctx, ml.DeleteRun{
RunId: created.Run.Info.RunId,
})
if err != nil {
panic(err)
}
func (*ExperimentsAPI) DeleteExperiment ¶
func (a *ExperimentsAPI) DeleteExperiment(ctx context.Context, request DeleteExperiment) error
func (*ExperimentsAPI) DeleteLoggedModel ¶ added in v0.70.0
func (a *ExperimentsAPI) DeleteLoggedModel(ctx context.Context, request DeleteLoggedModelRequest) error
func (*ExperimentsAPI) DeleteLoggedModelByModelId ¶ added in v0.70.0
func (a *ExperimentsAPI) DeleteLoggedModelByModelId(ctx context.Context, modelId string) error
Delete a logged model.
func (*ExperimentsAPI) DeleteLoggedModelTag ¶ added in v0.70.0
func (a *ExperimentsAPI) DeleteLoggedModelTag(ctx context.Context, request DeleteLoggedModelTagRequest) error
func (*ExperimentsAPI) DeleteLoggedModelTagByModelIdAndTagKey ¶ added in v0.70.0
func (a *ExperimentsAPI) DeleteLoggedModelTagByModelIdAndTagKey(ctx context.Context, modelId string, tagKey string) error
Delete a tag on a logged model.
func (*ExperimentsAPI) DeleteRuns ¶ added in v0.17.0
func (a *ExperimentsAPI) DeleteRuns(ctx context.Context, request DeleteRuns) (*DeleteRunsResponse, error)
func (*ExperimentsAPI) FinalizeLoggedModel ¶ added in v0.70.0
func (a *ExperimentsAPI) FinalizeLoggedModel(ctx context.Context, request FinalizeLoggedModelRequest) (*FinalizeLoggedModelResponse, error)
func (*ExperimentsAPI) GetByName ¶
func (a *ExperimentsAPI) GetByName(ctx context.Context, request GetByNameRequest) (*GetExperimentByNameResponse, error)
func (*ExperimentsAPI) GetExperiment ¶
func (a *ExperimentsAPI) GetExperiment(ctx context.Context, request GetExperimentRequest) (*GetExperimentResponse, error)
Example (Experiments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
experiment, err := w.Experiments.CreateExperiment(ctx, ml.CreateExperiment{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", experiment)
_, err = w.Experiments.GetExperiment(ctx, ml.GetExperimentRequest{
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
// cleanup
err = w.Experiments.DeleteExperiment(ctx, ml.DeleteExperiment{
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
func (*ExperimentsAPI) GetHistory ¶
func (a *ExperimentsAPI) GetHistory(ctx context.Context, request GetHistoryRequest) listing.Iterator[Metric]
Gets a list of all values for the specified metric for a given run.
func (*ExperimentsAPI) GetHistoryAll ¶ added in v0.18.0
func (a *ExperimentsAPI) GetHistoryAll(ctx context.Context, request GetHistoryRequest) ([]Metric, error)
Gets a list of all values for the specified metric for a given run.
func (*ExperimentsAPI) GetLoggedModel ¶ added in v0.70.0
func (a *ExperimentsAPI) GetLoggedModel(ctx context.Context, request GetLoggedModelRequest) (*GetLoggedModelResponse, error)
func (*ExperimentsAPI) GetLoggedModelByModelId ¶ added in v0.70.0
func (a *ExperimentsAPI) GetLoggedModelByModelId(ctx context.Context, modelId string) (*GetLoggedModelResponse, error)
Get a logged model.
func (*ExperimentsAPI) GetPermissionLevels ¶ added in v0.19.0
func (a *ExperimentsAPI) GetPermissionLevels(ctx context.Context, request GetExperimentPermissionLevelsRequest) (*GetExperimentPermissionLevelsResponse, error)
func (*ExperimentsAPI) GetPermissionLevelsByExperimentId ¶ added in v0.19.0
func (a *ExperimentsAPI) GetPermissionLevelsByExperimentId(ctx context.Context, experimentId string) (*GetExperimentPermissionLevelsResponse, error)
Gets the permission levels that a user can have on an object.
func (*ExperimentsAPI) GetPermissions ¶ added in v0.19.0
func (a *ExperimentsAPI) GetPermissions(ctx context.Context, request GetExperimentPermissionsRequest) (*ExperimentPermissions, error)
func (*ExperimentsAPI) GetPermissionsByExperimentId ¶ added in v0.19.0
func (a *ExperimentsAPI) GetPermissionsByExperimentId(ctx context.Context, experimentId string) (*ExperimentPermissions, error)
Gets the permissions of an experiment. Experiments can inherit permissions from their root object.
func (*ExperimentsAPI) GetRun ¶
func (a *ExperimentsAPI) GetRun(ctx context.Context, request GetRunRequest) (*GetRunResponse, error)
func (*ExperimentsAPI) ListArtifacts ¶ added in v0.24.0
func (a *ExperimentsAPI) ListArtifacts(ctx context.Context, request ListArtifactsRequest) listing.Iterator[FileInfo]
List artifacts for a run. Takes an optional `artifact_path` prefix which if specified, the response contains only artifacts with the specified prefix. A maximum of 1000 artifacts will be retrieved for UC Volumes. Please call `/api/2.0/fs/directories{directory_path}` for listing artifacts in UC Volumes, which supports pagination. See [List directory contents | Files API](/api/workspace/files/listdirectorycontents).
func (*ExperimentsAPI) ListArtifactsAll ¶
func (a *ExperimentsAPI) ListArtifactsAll(ctx context.Context, request ListArtifactsRequest) ([]FileInfo, error)
List artifacts for a run. Takes an optional `artifact_path` prefix which if specified, the response contains only artifacts with the specified prefix. A maximum of 1000 artifacts will be retrieved for UC Volumes. Please call `/api/2.0/fs/directories{directory_path}` for listing artifacts in UC Volumes, which supports pagination. See [List directory contents | Files API](/api/workspace/files/listdirectorycontents).
func (*ExperimentsAPI) ListExperiments ¶ added in v0.24.0
func (a *ExperimentsAPI) ListExperiments(ctx context.Context, request ListExperimentsRequest) listing.Iterator[Experiment]
Gets a list of all experiments.
Example (Experiments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
all, err := w.Experiments.ListExperimentsAll(ctx, ml.ListExperimentsRequest{})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", all)
func (*ExperimentsAPI) ListExperimentsAll ¶
func (a *ExperimentsAPI) ListExperimentsAll(ctx context.Context, request ListExperimentsRequest) ([]Experiment, error)
Gets a list of all experiments.
func (*ExperimentsAPI) LogLoggedModelParams ¶ added in v0.70.0
func (a *ExperimentsAPI) LogLoggedModelParams(ctx context.Context, request LogLoggedModelParamsRequest) error
func (*ExperimentsAPI) LogOutputs ¶ added in v0.70.0
func (a *ExperimentsAPI) LogOutputs(ctx context.Context, request LogOutputsRequest) error
func (*ExperimentsAPI) RestoreExperiment ¶
func (a *ExperimentsAPI) RestoreExperiment(ctx context.Context, request RestoreExperiment) error
func (*ExperimentsAPI) RestoreRun ¶
func (a *ExperimentsAPI) RestoreRun(ctx context.Context, request RestoreRun) error
func (*ExperimentsAPI) RestoreRuns ¶ added in v0.17.0
func (a *ExperimentsAPI) RestoreRuns(ctx context.Context, request RestoreRuns) (*RestoreRunsResponse, error)
func (*ExperimentsAPI) SearchExperiments ¶ added in v0.24.0
func (a *ExperimentsAPI) SearchExperiments(ctx context.Context, request SearchExperiments) listing.Iterator[Experiment]
Searches for experiments that satisfy specified search criteria.
func (*ExperimentsAPI) SearchExperimentsAll ¶
func (a *ExperimentsAPI) SearchExperimentsAll(ctx context.Context, request SearchExperiments) ([]Experiment, error)
Searches for experiments that satisfy specified search criteria.
func (*ExperimentsAPI) SearchLoggedModels ¶ added in v0.70.0
func (a *ExperimentsAPI) SearchLoggedModels(ctx context.Context, request SearchLoggedModelsRequest) (*SearchLoggedModelsResponse, error)
func (*ExperimentsAPI) SearchRuns ¶ added in v0.24.0
Searches for runs that satisfy expressions.
Search expressions can use `mlflowMetric` and `mlflowParam` keys.
func (*ExperimentsAPI) SearchRunsAll ¶
func (a *ExperimentsAPI) SearchRunsAll(ctx context.Context, request SearchRuns) ([]Run, error)
Searches for runs that satisfy expressions.
Search expressions can use `mlflowMetric` and `mlflowParam` keys.
func (*ExperimentsAPI) SetExperimentTag ¶
func (a *ExperimentsAPI) SetExperimentTag(ctx context.Context, request SetExperimentTag) error
func (*ExperimentsAPI) SetLoggedModelTags ¶ added in v0.70.0
func (a *ExperimentsAPI) SetLoggedModelTags(ctx context.Context, request SetLoggedModelTagsRequest) error
func (*ExperimentsAPI) SetPermissions ¶ added in v0.19.0
func (a *ExperimentsAPI) SetPermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
func (*ExperimentsAPI) UpdateExperiment ¶
func (a *ExperimentsAPI) UpdateExperiment(ctx context.Context, request UpdateExperiment) error
Example (Experiments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
experiment, err := w.Experiments.CreateExperiment(ctx, ml.CreateExperiment{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", experiment)
err = w.Experiments.UpdateExperiment(ctx, ml.UpdateExperiment{
NewName: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
// cleanup
err = w.Experiments.DeleteExperiment(ctx, ml.DeleteExperiment{
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
func (*ExperimentsAPI) UpdatePermissions ¶ added in v0.19.0
func (a *ExperimentsAPI) UpdatePermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
func (*ExperimentsAPI) UpdateRun ¶
func (a *ExperimentsAPI) UpdateRun(ctx context.Context, request UpdateRun) (*UpdateRunResponse, error)
Example (MLflowRuns) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
experiment, err := w.Experiments.CreateExperiment(ctx, ml.CreateExperiment{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", experiment)
created, err := w.Experiments.CreateRun(ctx, ml.CreateRun{
ExperimentId: experiment.ExperimentId,
Tags: []ml.RunTag{ml.RunTag{
Key: "foo",
Value: "bar",
}},
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
_, err = w.Experiments.UpdateRun(ctx, ml.UpdateRun{
RunId: created.Run.Info.RunId,
Status: ml.UpdateRunStatusKilled,
})
if err != nil {
panic(err)
}
// cleanup
err = w.Experiments.DeleteExperiment(ctx, ml.DeleteExperiment{
ExperimentId: experiment.ExperimentId,
})
if err != nil {
panic(err)
}
err = w.Experiments.DeleteRun(ctx, ml.DeleteRun{
RunId: created.Run.Info.RunId,
})
if err != nil {
panic(err)
}
type ExperimentsInterface ¶ added in v0.29.0
type ExperimentsInterface interface {
// Creates an experiment with a name. Returns the ID of the newly created
// experiment. Validates that another experiment with the same name does not
// already exist and fails if another experiment with the same name already
// exists.
//
// Throws `RESOURCE_ALREADY_EXISTS` if an experiment with the given name exists.
CreateExperiment(ctx context.Context, request CreateExperiment) (*CreateExperimentResponse, error)
// Create a logged model.
CreateLoggedModel(ctx context.Context, request CreateLoggedModelRequest) (*CreateLoggedModelResponse, error)
// Creates a new run within an experiment. A run is usually a single execution
// of a machine learning or data ETL pipeline. MLflow uses runs to track the
// `mlflowParam`, `mlflowMetric`, and `mlflowRunTag` associated with a single
// execution.
CreateRun(ctx context.Context, request CreateRun) (*CreateRunResponse, error)
// Marks an experiment and associated metadata, runs, metrics, params, and tags
// for deletion. If the experiment uses FileStore, artifacts associated with the
// experiment are also deleted.
DeleteExperiment(ctx context.Context, request DeleteExperiment) error
// Delete a logged model.
DeleteLoggedModel(ctx context.Context, request DeleteLoggedModelRequest) error
// Delete a logged model.
DeleteLoggedModelByModelId(ctx context.Context, modelId string) error
// Delete a tag on a logged model.
DeleteLoggedModelTag(ctx context.Context, request DeleteLoggedModelTagRequest) error
// Delete a tag on a logged model.
DeleteLoggedModelTagByModelIdAndTagKey(ctx context.Context, modelId string, tagKey string) error
// Marks a run for deletion.
DeleteRun(ctx context.Context, request DeleteRun) error
// Bulk delete runs in an experiment that were created prior to or at the
// specified timestamp. Deletes at most max_runs per request. To call this API
// from a Databricks Notebook in Python, you can use the client code snippet on
DeleteRuns(ctx context.Context, request DeleteRuns) (*DeleteRunsResponse, error)
// Deletes a tag on a run. Tags are run metadata that can be updated during a
// run and after a run completes.
DeleteTag(ctx context.Context, request DeleteTag) error
// Finalize a logged model.
FinalizeLoggedModel(ctx context.Context, request FinalizeLoggedModelRequest) (*FinalizeLoggedModelResponse, error)
// Gets metadata for an experiment.
//
// This endpoint will return deleted experiments, but prefers the active
// experiment if an active and deleted experiment share the same name. If
// multiple deleted experiments share the same name, the API will return one of
// them.
//
// Throws `RESOURCE_DOES_NOT_EXIST` if no experiment with the specified name
// exists.
GetByName(ctx context.Context, request GetByNameRequest) (*GetExperimentByNameResponse, error)
// Gets metadata for an experiment. This method works on deleted experiments.
GetExperiment(ctx context.Context, request GetExperimentRequest) (*GetExperimentResponse, error)
// Gets a list of all values for the specified metric for a given run.
//
// This method is generated by Databricks SDK Code Generator.
GetHistory(ctx context.Context, request GetHistoryRequest) listing.Iterator[Metric]
// Gets a list of all values for the specified metric for a given run.
//
// This method is generated by Databricks SDK Code Generator.
GetHistoryAll(ctx context.Context, request GetHistoryRequest) ([]Metric, error)
// Get a logged model.
GetLoggedModel(ctx context.Context, request GetLoggedModelRequest) (*GetLoggedModelResponse, error)
// Get a logged model.
GetLoggedModelByModelId(ctx context.Context, modelId string) (*GetLoggedModelResponse, error)
// Gets the permission levels that a user can have on an object.
GetPermissionLevels(ctx context.Context, request GetExperimentPermissionLevelsRequest) (*GetExperimentPermissionLevelsResponse, error)
// Gets the permission levels that a user can have on an object.
GetPermissionLevelsByExperimentId(ctx context.Context, experimentId string) (*GetExperimentPermissionLevelsResponse, error)
// Gets the permissions of an experiment. Experiments can inherit permissions
// from their root object.
GetPermissions(ctx context.Context, request GetExperimentPermissionsRequest) (*ExperimentPermissions, error)
// Gets the permissions of an experiment. Experiments can inherit permissions
// from their root object.
GetPermissionsByExperimentId(ctx context.Context, experimentId string) (*ExperimentPermissions, error)
// Gets the metadata, metrics, params, and tags for a run. In the case where
// multiple metrics with the same key are logged for a run, return only the
// value with the latest timestamp.
//
// If there are multiple values with the latest timestamp, return the maximum of
// these values.
GetRun(ctx context.Context, request GetRunRequest) (*GetRunResponse, error)
// List artifacts for a run. Takes an optional `artifact_path` prefix which if
// specified, the response contains only artifacts with the specified prefix. A
// maximum of 1000 artifacts will be retrieved for UC Volumes. Please call
// `/api/2.0/fs/directories{directory_path}` for listing artifacts in UC
// Volumes, which supports pagination. See [List directory contents | Files
// API](/api/workspace/files/listdirectorycontents).
//
// This method is generated by Databricks SDK Code Generator.
ListArtifacts(ctx context.Context, request ListArtifactsRequest) listing.Iterator[FileInfo]
// List artifacts for a run. Takes an optional `artifact_path` prefix which if
// specified, the response contains only artifacts with the specified prefix. A
// maximum of 1000 artifacts will be retrieved for UC Volumes. Please call
// `/api/2.0/fs/directories{directory_path}` for listing artifacts in UC
// Volumes, which supports pagination. See [List directory contents | Files
// API](/api/workspace/files/listdirectorycontents).
//
// This method is generated by Databricks SDK Code Generator.
ListArtifactsAll(ctx context.Context, request ListArtifactsRequest) ([]FileInfo, error)
// Gets a list of all experiments.
//
// This method is generated by Databricks SDK Code Generator.
ListExperiments(ctx context.Context, request ListExperimentsRequest) listing.Iterator[Experiment]
// Gets a list of all experiments.
//
// This method is generated by Databricks SDK Code Generator.
ListExperimentsAll(ctx context.Context, request ListExperimentsRequest) ([]Experiment, error)
// Logs a batch of metrics, params, and tags for a run. If any data failed to be
// persisted, the server will respond with an error (non-200 status code).
//
// In case of error (due to internal server error or an invalid request),
// partial data may be written.
//
// You can write metrics, params, and tags in interleaving fashion, but within a
// given entity type are guaranteed to follow the order specified in the request
// body.
//
// The overwrite behavior for metrics, params, and tags is as follows:
//
// * Metrics: metric values are never overwritten. Logging a metric (key, value,
// timestamp) appends to the set of values for the metric with the provided key.
//
// * Tags: tag values can be overwritten by successive writes to the same tag
// key. That is, if multiple tag values with the same key are provided in the
// same API request, the last-provided tag value is written. Logging the same
// tag (key, value) is permitted. Specifically, logging a tag is idempotent.
//
// * Parameters: once written, param values cannot be changed (attempting to
// overwrite a param value will result in an error). However, logging the same
// param (key, value) is permitted. Specifically, logging a param is idempotent.
//
// Request Limits ------------------------------- A single JSON-serialized API
// request may be up to 1 MB in size and contain:
//
// * No more than 1000 metrics, params, and tags in total
//
// * Up to 1000 metrics
//
// * Up to 100 params
//
// * Up to 100 tags
//
// For example, a valid request might contain 900 metrics, 50 params, and 50
// tags, but logging 900 metrics, 50 params, and 51 tags is invalid.
//
// The following limits also apply to metric, param, and tag keys and values:
//
// * Metric keys, param keys, and tag keys can be up to 250 characters in length
//
// * Parameter and tag values can be up to 250 characters in length
LogBatch(ctx context.Context, request LogBatch) error
// Logs inputs, such as datasets and models, to an MLflow Run.
LogInputs(ctx context.Context, request LogInputs) error
// Logs params for a logged model. A param is a key-value pair (string key,
// string value). Examples include hyperparameters used for ML model training. A
// param can be logged only once for a logged model, and attempting to overwrite
// an existing param with a different value will result in an error
LogLoggedModelParams(ctx context.Context, request LogLoggedModelParamsRequest) error
// Log a metric for a run. A metric is a key-value pair (string key, float
// value) with an associated timestamp. Examples include the various metrics
// that represent ML model accuracy. A metric can be logged multiple times.
LogMetric(ctx context.Context, request LogMetric) error
// **Note:** the [Create a logged
// model](/api/workspace/experiments/createloggedmodel) API replaces this
// endpoint.
//
// Log a model to an MLflow Run.
LogModel(ctx context.Context, request LogModel) error
// Logs outputs, such as models, from an MLflow Run.
LogOutputs(ctx context.Context, request LogOutputsRequest) error
// Logs a param used for a run. A param is a key-value pair (string key, string
// value). Examples include hyperparameters used for ML model training and
// constant dates and values used in an ETL pipeline. A param can be logged only
// once for a run.
LogParam(ctx context.Context, request LogParam) error
// Restore an experiment marked for deletion. This also restores associated
// metadata, runs, metrics, params, and tags. If experiment uses FileStore,
// underlying artifacts associated with experiment are also restored.
//
// Throws `RESOURCE_DOES_NOT_EXIST` if experiment was never created or was
// permanently deleted.
RestoreExperiment(ctx context.Context, request RestoreExperiment) error
// Restores a deleted run. This also restores associated metadata, runs,
// metrics, params, and tags.
//
// Throws `RESOURCE_DOES_NOT_EXIST` if the run was never created or was
// permanently deleted.
RestoreRun(ctx context.Context, request RestoreRun) error
// Bulk restore runs in an experiment that were deleted no earlier than the
// specified timestamp. Restores at most max_runs per request. To call this API
// from a Databricks Notebook in Python, you can use the client code snippet on
RestoreRuns(ctx context.Context, request RestoreRuns) (*RestoreRunsResponse, error)
// Searches for experiments that satisfy specified search criteria.
//
// This method is generated by Databricks SDK Code Generator.
SearchExperiments(ctx context.Context, request SearchExperiments) listing.Iterator[Experiment]
// Searches for experiments that satisfy specified search criteria.
//
// This method is generated by Databricks SDK Code Generator.
SearchExperimentsAll(ctx context.Context, request SearchExperiments) ([]Experiment, error)
// Search for Logged Models that satisfy specified search criteria.
SearchLoggedModels(ctx context.Context, request SearchLoggedModelsRequest) (*SearchLoggedModelsResponse, error)
// Searches for runs that satisfy expressions.
//
// Search expressions can use `mlflowMetric` and `mlflowParam` keys.
//
// This method is generated by Databricks SDK Code Generator.
SearchRuns(ctx context.Context, request SearchRuns) listing.Iterator[Run]
// Searches for runs that satisfy expressions.
//
// Search expressions can use `mlflowMetric` and `mlflowParam` keys.
//
// This method is generated by Databricks SDK Code Generator.
SearchRunsAll(ctx context.Context, request SearchRuns) ([]Run, error)
// Sets a tag on an experiment. Experiment tags are metadata that can be
// updated.
SetExperimentTag(ctx context.Context, request SetExperimentTag) error
// Set tags for a logged model.
SetLoggedModelTags(ctx context.Context, request SetLoggedModelTagsRequest) error
// Sets permissions on an object, replacing existing permissions if they exist.
// Deletes all direct permissions if none are specified. Objects can inherit
// permissions from their root object.
SetPermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
// Sets a tag on a run. Tags are run metadata that can be updated during a run
// and after a run completes.
SetTag(ctx context.Context, request SetTag) error
// Updates experiment metadata.
UpdateExperiment(ctx context.Context, request UpdateExperiment) error
// Updates the permissions on an experiment. Experiments can inherit permissions
// from their root object.
UpdatePermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
// Updates run metadata.
UpdateRun(ctx context.Context, request UpdateRun) (*UpdateRunResponse, error)
}
type ExperimentsService
deprecated
type ExperimentsService interface {
// Creates an experiment with a name. Returns the ID of the newly created
// experiment. Validates that another experiment with the same name does not
// already exist and fails if another experiment with the same name already
// exists.
//
// Throws `RESOURCE_ALREADY_EXISTS` if an experiment with the given name
// exists.
CreateExperiment(ctx context.Context, request CreateExperiment) (*CreateExperimentResponse, error)
// Create a logged model.
CreateLoggedModel(ctx context.Context, request CreateLoggedModelRequest) (*CreateLoggedModelResponse, error)
// Creates a new run within an experiment. A run is usually a single
// execution of a machine learning or data ETL pipeline. MLflow uses runs to
// track the `mlflowParam`, `mlflowMetric`, and `mlflowRunTag` associated
// with a single execution.
CreateRun(ctx context.Context, request CreateRun) (*CreateRunResponse, error)
// Marks an experiment and associated metadata, runs, metrics, params, and
// tags for deletion. If the experiment uses FileStore, artifacts associated
// with the experiment are also deleted.
DeleteExperiment(ctx context.Context, request DeleteExperiment) error
// Delete a logged model.
DeleteLoggedModel(ctx context.Context, request DeleteLoggedModelRequest) error
// Delete a tag on a logged model.
DeleteLoggedModelTag(ctx context.Context, request DeleteLoggedModelTagRequest) error
// Marks a run for deletion.
DeleteRun(ctx context.Context, request DeleteRun) error
// Bulk delete runs in an experiment that were created prior to or at the
// specified timestamp. Deletes at most max_runs per request. To call this
// API from a Databricks Notebook in Python, you can use the client code
// snippet on
DeleteRuns(ctx context.Context, request DeleteRuns) (*DeleteRunsResponse, error)
// Deletes a tag on a run. Tags are run metadata that can be updated during
// a run and after a run completes.
DeleteTag(ctx context.Context, request DeleteTag) error
// Finalize a logged model.
FinalizeLoggedModel(ctx context.Context, request FinalizeLoggedModelRequest) (*FinalizeLoggedModelResponse, error)
// Gets metadata for an experiment.
//
// This endpoint will return deleted experiments, but prefers the active
// experiment if an active and deleted experiment share the same name. If
// multiple deleted experiments share the same name, the API will return one
// of them.
//
// Throws `RESOURCE_DOES_NOT_EXIST` if no experiment with the specified name
// exists.
GetByName(ctx context.Context, request GetByNameRequest) (*GetExperimentByNameResponse, error)
// Gets metadata for an experiment. This method works on deleted
// experiments.
GetExperiment(ctx context.Context, request GetExperimentRequest) (*GetExperimentResponse, error)
// Gets a list of all values for the specified metric for a given run.
GetHistory(ctx context.Context, request GetHistoryRequest) (*GetMetricHistoryResponse, error)
// Get a logged model.
GetLoggedModel(ctx context.Context, request GetLoggedModelRequest) (*GetLoggedModelResponse, error)
// Gets the permission levels that a user can have on an object.
GetPermissionLevels(ctx context.Context, request GetExperimentPermissionLevelsRequest) (*GetExperimentPermissionLevelsResponse, error)
// Gets the permissions of an experiment. Experiments can inherit
// permissions from their root object.
GetPermissions(ctx context.Context, request GetExperimentPermissionsRequest) (*ExperimentPermissions, error)
// Gets the metadata, metrics, params, and tags for a run. In the case where
// multiple metrics with the same key are logged for a run, return only the
// value with the latest timestamp.
//
// If there are multiple values with the latest timestamp, return the
// maximum of these values.
GetRun(ctx context.Context, request GetRunRequest) (*GetRunResponse, error)
// List artifacts for a run. Takes an optional `artifact_path` prefix which
// if specified, the response contains only artifacts with the specified
// prefix. A maximum of 1000 artifacts will be retrieved for UC Volumes.
// Please call `/api/2.0/fs/directories{directory_path}` for listing
// artifacts in UC Volumes, which supports pagination. See [List directory
// contents | Files API](/api/workspace/files/listdirectorycontents).
ListArtifacts(ctx context.Context, request ListArtifactsRequest) (*ListArtifactsResponse, error)
// Gets a list of all experiments.
ListExperiments(ctx context.Context, request ListExperimentsRequest) (*ListExperimentsResponse, error)
// Logs a batch of metrics, params, and tags for a run. If any data failed
// to be persisted, the server will respond with an error (non-200 status
// code).
//
// In case of error (due to internal server error or an invalid request),
// partial data may be written.
//
// You can write metrics, params, and tags in interleaving fashion, but
// within a given entity type are guaranteed to follow the order specified
// in the request body.
//
// The overwrite behavior for metrics, params, and tags is as follows:
//
// * Metrics: metric values are never overwritten. Logging a metric (key,
// value, timestamp) appends to the set of values for the metric with the
// provided key.
//
// * Tags: tag values can be overwritten by successive writes to the same
// tag key. That is, if multiple tag values with the same key are provided
// in the same API request, the last-provided tag value is written. Logging
// the same tag (key, value) is permitted. Specifically, logging a tag is
// idempotent.
//
// * Parameters: once written, param values cannot be changed (attempting to
// overwrite a param value will result in an error). However, logging the
// same param (key, value) is permitted. Specifically, logging a param is
// idempotent.
//
// Request Limits ------------------------------- A single JSON-serialized
// API request may be up to 1 MB in size and contain:
//
// * No more than 1000 metrics, params, and tags in total
//
// * Up to 1000 metrics
//
// * Up to 100 params
//
// * Up to 100 tags
//
// For example, a valid request might contain 900 metrics, 50 params, and 50
// tags, but logging 900 metrics, 50 params, and 51 tags is invalid.
//
// The following limits also apply to metric, param, and tag keys and
// values:
//
// * Metric keys, param keys, and tag keys can be up to 250 characters in
// length
//
// * Parameter and tag values can be up to 250 characters in length
LogBatch(ctx context.Context, request LogBatch) error
// Logs inputs, such as datasets and models, to an MLflow Run.
LogInputs(ctx context.Context, request LogInputs) error
// Logs params for a logged model. A param is a key-value pair (string key,
// string value). Examples include hyperparameters used for ML model
// training. A param can be logged only once for a logged model, and
// attempting to overwrite an existing param with a different value will
// result in an error
LogLoggedModelParams(ctx context.Context, request LogLoggedModelParamsRequest) error
// Log a metric for a run. A metric is a key-value pair (string key, float
// value) with an associated timestamp. Examples include the various metrics
// that represent ML model accuracy. A metric can be logged multiple times.
LogMetric(ctx context.Context, request LogMetric) error
// **Note:** the [Create a logged
// model](/api/workspace/experiments/createloggedmodel) API replaces this
// endpoint.
//
// Log a model to an MLflow Run.
LogModel(ctx context.Context, request LogModel) error
// Logs outputs, such as models, from an MLflow Run.
LogOutputs(ctx context.Context, request LogOutputsRequest) error
// Logs a param used for a run. A param is a key-value pair (string key,
// string value). Examples include hyperparameters used for ML model
// training and constant dates and values used in an ETL pipeline. A param
// can be logged only once for a run.
LogParam(ctx context.Context, request LogParam) error
// Restore an experiment marked for deletion. This also restores associated
// metadata, runs, metrics, params, and tags. If experiment uses FileStore,
// underlying artifacts associated with experiment are also restored.
//
// Throws `RESOURCE_DOES_NOT_EXIST` if experiment was never created or was
// permanently deleted.
RestoreExperiment(ctx context.Context, request RestoreExperiment) error
// Restores a deleted run. This also restores associated metadata, runs,
// metrics, params, and tags.
//
// Throws `RESOURCE_DOES_NOT_EXIST` if the run was never created or was
// permanently deleted.
RestoreRun(ctx context.Context, request RestoreRun) error
// Bulk restore runs in an experiment that were deleted no earlier than the
// specified timestamp. Restores at most max_runs per request. To call this
// API from a Databricks Notebook in Python, you can use the client code
// snippet on
RestoreRuns(ctx context.Context, request RestoreRuns) (*RestoreRunsResponse, error)
// Searches for experiments that satisfy specified search criteria.
SearchExperiments(ctx context.Context, request SearchExperiments) (*SearchExperimentsResponse, error)
// Search for Logged Models that satisfy specified search criteria.
SearchLoggedModels(ctx context.Context, request SearchLoggedModelsRequest) (*SearchLoggedModelsResponse, error)
// Searches for runs that satisfy expressions.
//
// Search expressions can use `mlflowMetric` and `mlflowParam` keys.
SearchRuns(ctx context.Context, request SearchRuns) (*SearchRunsResponse, error)
// Sets a tag on an experiment. Experiment tags are metadata that can be
// updated.
SetExperimentTag(ctx context.Context, request SetExperimentTag) error
// Set tags for a logged model.
SetLoggedModelTags(ctx context.Context, request SetLoggedModelTagsRequest) error
// Sets permissions on an object, replacing existing permissions if they
// exist. Deletes all direct permissions if none are specified. Objects can
// inherit permissions from their root object.
SetPermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
// Sets a tag on a run. Tags are run metadata that can be updated during a
// run and after a run completes.
SetTag(ctx context.Context, request SetTag) error
// Updates experiment metadata.
UpdateExperiment(ctx context.Context, request UpdateExperiment) error
// Updates the permissions on an experiment. Experiments can inherit
// permissions from their root object.
UpdatePermissions(ctx context.Context, request ExperimentPermissionsRequest) (*ExperimentPermissions, error)
// Updates run metadata.
UpdateRun(ctx context.Context, request UpdateRun) (*UpdateRunResponse, error)
}
Experiments are the primary unit of organization in MLflow; all MLflow runs belong to an experiment. Each experiment lets you visualize, search, and compare runs, as well as download run artifacts or metadata for analysis in other tools. Experiments are maintained in a Databricks hosted MLflow tracking server.
Experiments are located in the workspace file tree. You manage experiments using the same tools you use to manage other workspace objects such as folders, notebooks, and libraries.
Deprecated: Do not use this interface, it will be removed in a future version of the SDK.
type FeatureStoreAPI ¶ added in v0.73.0
type FeatureStoreAPI struct {
// contains filtered or unexported fields
}
A feature store is a centralized repository that enables data scientists to find and share features. Using a feature store also ensures that the code used to compute feature values is the same during model training and when the model is used for inference.
An online store is a low-latency database used for feature lookup during real-time model inference or serve feature for real-time applications.
func NewFeatureStore ¶ added in v0.73.0
func NewFeatureStore(client *client.DatabricksClient) *FeatureStoreAPI
func (*FeatureStoreAPI) CreateOnlineStore ¶ added in v0.73.0
func (a *FeatureStoreAPI) CreateOnlineStore(ctx context.Context, request CreateOnlineStoreRequest) (*OnlineStore, error)
func (*FeatureStoreAPI) DeleteOnlineStore ¶ added in v0.73.0
func (a *FeatureStoreAPI) DeleteOnlineStore(ctx context.Context, request DeleteOnlineStoreRequest) error
func (*FeatureStoreAPI) DeleteOnlineStoreByName ¶ added in v0.73.0
func (a *FeatureStoreAPI) DeleteOnlineStoreByName(ctx context.Context, name string) error
Delete an Online Feature Store.
func (*FeatureStoreAPI) GetOnlineStore ¶ added in v0.73.0
func (a *FeatureStoreAPI) GetOnlineStore(ctx context.Context, request GetOnlineStoreRequest) (*OnlineStore, error)
func (*FeatureStoreAPI) GetOnlineStoreByName ¶ added in v0.73.0
func (a *FeatureStoreAPI) GetOnlineStoreByName(ctx context.Context, name string) (*OnlineStore, error)
Get an Online Feature Store.
func (*FeatureStoreAPI) ListOnlineStores ¶ added in v0.73.0
func (a *FeatureStoreAPI) ListOnlineStores(ctx context.Context, request ListOnlineStoresRequest) listing.Iterator[OnlineStore]
List Online Feature Stores.
func (*FeatureStoreAPI) ListOnlineStoresAll ¶ added in v0.73.0
func (a *FeatureStoreAPI) ListOnlineStoresAll(ctx context.Context, request ListOnlineStoresRequest) ([]OnlineStore, error)
List Online Feature Stores.
func (*FeatureStoreAPI) PublishTable ¶ added in v0.73.0
func (a *FeatureStoreAPI) PublishTable(ctx context.Context, request PublishTableRequest) (*PublishTableResponse, error)
func (*FeatureStoreAPI) UpdateOnlineStore ¶ added in v0.73.0
func (a *FeatureStoreAPI) UpdateOnlineStore(ctx context.Context, request UpdateOnlineStoreRequest) (*OnlineStore, error)
type FeatureStoreInterface ¶ added in v0.73.0
type FeatureStoreInterface interface {
// Create an Online Feature Store.
CreateOnlineStore(ctx context.Context, request CreateOnlineStoreRequest) (*OnlineStore, error)
// Delete an Online Feature Store.
DeleteOnlineStore(ctx context.Context, request DeleteOnlineStoreRequest) error
// Delete an Online Feature Store.
DeleteOnlineStoreByName(ctx context.Context, name string) error
// Get an Online Feature Store.
GetOnlineStore(ctx context.Context, request GetOnlineStoreRequest) (*OnlineStore, error)
// Get an Online Feature Store.
GetOnlineStoreByName(ctx context.Context, name string) (*OnlineStore, error)
// List Online Feature Stores.
//
// This method is generated by Databricks SDK Code Generator.
ListOnlineStores(ctx context.Context, request ListOnlineStoresRequest) listing.Iterator[OnlineStore]
// List Online Feature Stores.
//
// This method is generated by Databricks SDK Code Generator.
ListOnlineStoresAll(ctx context.Context, request ListOnlineStoresRequest) ([]OnlineStore, error)
// Publish features.
PublishTable(ctx context.Context, request PublishTableRequest) (*PublishTableResponse, error)
// Update an Online Feature Store.
UpdateOnlineStore(ctx context.Context, request UpdateOnlineStoreRequest) (*OnlineStore, error)
}
type FeatureStoreService
deprecated
added in
v0.73.0
type FeatureStoreService interface {
// Create an Online Feature Store.
CreateOnlineStore(ctx context.Context, request CreateOnlineStoreRequest) (*OnlineStore, error)
// Delete an Online Feature Store.
DeleteOnlineStore(ctx context.Context, request DeleteOnlineStoreRequest) error
// Get an Online Feature Store.
GetOnlineStore(ctx context.Context, request GetOnlineStoreRequest) (*OnlineStore, error)
// List Online Feature Stores.
ListOnlineStores(ctx context.Context, request ListOnlineStoresRequest) (*ListOnlineStoresResponse, error)
// Publish features.
PublishTable(ctx context.Context, request PublishTableRequest) (*PublishTableResponse, error)
// Update an Online Feature Store.
UpdateOnlineStore(ctx context.Context, request UpdateOnlineStoreRequest) (*OnlineStore, error)
}
A feature store is a centralized repository that enables data scientists to find and share features. Using a feature store also ensures that the code used to compute feature values is the same during model training and when the model is used for inference.
An online store is a low-latency database used for feature lookup during real-time model inference or serve feature for real-time applications.
Deprecated: Do not use this interface, it will be removed in a future version of the SDK.
type FileInfo ¶
type FileInfo struct {
// The size in bytes of the file. Unset for directories.
// Wire name: 'file_size'
FileSize int64 `json:"file_size,omitempty"`
// Whether the path is a directory.
// Wire name: 'is_dir'
IsDir bool `json:"is_dir,omitempty"`
// The path relative to the root artifact directory run.
// Wire name: 'path'
Path string `json:"path,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Metadata of a single artifact file or directory.
func (FileInfo) MarshalJSON ¶ added in v0.23.0
func (*FileInfo) UnmarshalJSON ¶ added in v0.23.0
type FinalizeLoggedModelRequest ¶ added in v0.70.0
type FinalizeLoggedModelRequest struct {
// The ID of the logged model to finalize.
ModelId string `json:"-" tf:"-"`
// Whether or not the model is ready for use.
// “"LOGGED_MODEL_UPLOAD_FAILED"“ indicates that something went wrong when
// logging the model weights / agent code.
// Wire name: 'status'
Status LoggedModelStatus `json:"status"`
}
func (FinalizeLoggedModelRequest) MarshalJSON ¶ added in v0.73.0
func (st FinalizeLoggedModelRequest) MarshalJSON() ([]byte, error)
func (*FinalizeLoggedModelRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *FinalizeLoggedModelRequest) UnmarshalJSON(b []byte) error
type FinalizeLoggedModelResponse ¶ added in v0.70.0
type FinalizeLoggedModelResponse struct {
// The updated logged model.
// Wire name: 'model'
Model *LoggedModel `json:"model,omitempty"`
}
func (FinalizeLoggedModelResponse) MarshalJSON ¶ added in v0.73.0
func (st FinalizeLoggedModelResponse) MarshalJSON() ([]byte, error)
func (*FinalizeLoggedModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *FinalizeLoggedModelResponse) UnmarshalJSON(b []byte) error
type ForecastingAPI ¶ added in v0.60.0
type ForecastingAPI struct {
// contains filtered or unexported fields
}
The Forecasting API allows you to create and get serverless forecasting experiments
func NewForecasting ¶ added in v0.60.0
func NewForecasting(client *client.DatabricksClient) *ForecastingAPI
func (*ForecastingAPI) CreateExperiment ¶ added in v0.60.0
func (a *ForecastingAPI) CreateExperiment(ctx context.Context, createForecastingExperimentRequest CreateForecastingExperimentRequest) (*WaitGetExperimentForecastingSucceeded[CreateForecastingExperimentResponse], error)
Creates a serverless forecasting experiment. Returns the experiment ID.
func (*ForecastingAPI) CreateExperimentAndWait
deprecated
added in
v0.60.0
func (a *ForecastingAPI) CreateExperimentAndWait(ctx context.Context, createForecastingExperimentRequest CreateForecastingExperimentRequest, options ...retries.Option[ForecastingExperiment]) (*ForecastingExperiment, error)
Calls ForecastingAPI.CreateExperiment and waits to reach SUCCEEDED state
You can override the default timeout of 120 minutes by calling adding retries.Timeout[ForecastingExperiment](60*time.Minute) functional option.
Deprecated: use ForecastingAPI.CreateExperiment.Get() or ForecastingAPI.WaitGetExperimentForecastingSucceeded
func (*ForecastingAPI) GetExperiment ¶ added in v0.60.0
func (a *ForecastingAPI) GetExperiment(ctx context.Context, request GetForecastingExperimentRequest) (*ForecastingExperiment, error)
func (*ForecastingAPI) GetExperimentByExperimentId ¶ added in v0.60.0
func (a *ForecastingAPI) GetExperimentByExperimentId(ctx context.Context, experimentId string) (*ForecastingExperiment, error)
Public RPC to get forecasting experiment
func (*ForecastingAPI) WaitGetExperimentForecastingSucceeded ¶ added in v0.60.0
func (a *ForecastingAPI) WaitGetExperimentForecastingSucceeded(ctx context.Context, experimentId string, timeout time.Duration, callback func(*ForecastingExperiment)) (*ForecastingExperiment, error)
WaitGetExperimentForecastingSucceeded repeatedly calls ForecastingAPI.GetExperiment and waits to reach SUCCEEDED state
type ForecastingExperiment ¶ added in v0.60.0
type ForecastingExperiment struct {
// The unique ID for the forecasting experiment.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id,omitempty"`
// The URL to the forecasting experiment page.
// Wire name: 'experiment_page_url'
ExperimentPageUrl string `json:"experiment_page_url,omitempty"`
// The current state of the forecasting experiment.
// Wire name: 'state'
State ForecastingExperimentState `json:"state,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Represents a forecasting experiment with its unique identifier, URL, and state.
func (ForecastingExperiment) MarshalJSON ¶ added in v0.60.0
func (st ForecastingExperiment) MarshalJSON() ([]byte, error)
func (*ForecastingExperiment) UnmarshalJSON ¶ added in v0.60.0
func (st *ForecastingExperiment) UnmarshalJSON(b []byte) error
type ForecastingExperimentState ¶ added in v0.60.0
type ForecastingExperimentState string
const ForecastingExperimentStateCancelled ForecastingExperimentState = `CANCELLED`
const ForecastingExperimentStateFailed ForecastingExperimentState = `FAILED`
const ForecastingExperimentStatePending ForecastingExperimentState = `PENDING`
const ForecastingExperimentStateRunning ForecastingExperimentState = `RUNNING`
const ForecastingExperimentStateSucceeded ForecastingExperimentState = `SUCCEEDED`
func (*ForecastingExperimentState) Set ¶ added in v0.60.0
func (f *ForecastingExperimentState) Set(v string) error
Set raw string value and validate it against allowed values
func (*ForecastingExperimentState) String ¶ added in v0.60.0
func (f *ForecastingExperimentState) String() string
String representation for fmt.Print
func (*ForecastingExperimentState) Type ¶ added in v0.60.0
func (f *ForecastingExperimentState) Type() string
Type always returns ForecastingExperimentState to satisfy [pflag.Value] interface
func (*ForecastingExperimentState) Values ¶ added in v0.72.0
func (f *ForecastingExperimentState) Values() []ForecastingExperimentState
Values returns all possible values for ForecastingExperimentState.
There is no guarantee on the order of the values in the slice.
type ForecastingInterface ¶ added in v0.60.0
type ForecastingInterface interface {
// WaitGetExperimentForecastingSucceeded repeatedly calls [ForecastingAPI.GetExperiment] and waits to reach SUCCEEDED state
WaitGetExperimentForecastingSucceeded(ctx context.Context, experimentId string,
timeout time.Duration, callback func(*ForecastingExperiment)) (*ForecastingExperiment, error)
// Creates a serverless forecasting experiment. Returns the experiment ID.
CreateExperiment(ctx context.Context, createForecastingExperimentRequest CreateForecastingExperimentRequest) (*WaitGetExperimentForecastingSucceeded[CreateForecastingExperimentResponse], error)
// Calls [ForecastingAPIInterface.CreateExperiment] and waits to reach SUCCEEDED state
//
// You can override the default timeout of 120 minutes by calling adding
// retries.Timeout[ForecastingExperiment](60*time.Minute) functional option.
//
// Deprecated: use [ForecastingAPIInterface.CreateExperiment].Get() or [ForecastingAPIInterface.WaitGetExperimentForecastingSucceeded]
CreateExperimentAndWait(ctx context.Context, createForecastingExperimentRequest CreateForecastingExperimentRequest, options ...retries.Option[ForecastingExperiment]) (*ForecastingExperiment, error)
// Public RPC to get forecasting experiment
GetExperiment(ctx context.Context, request GetForecastingExperimentRequest) (*ForecastingExperiment, error)
// Public RPC to get forecasting experiment
GetExperimentByExperimentId(ctx context.Context, experimentId string) (*ForecastingExperiment, error)
}
type ForecastingService
deprecated
added in
v0.60.0
type ForecastingService interface {
// Creates a serverless forecasting experiment. Returns the experiment ID.
CreateExperiment(ctx context.Context, request CreateForecastingExperimentRequest) (*CreateForecastingExperimentResponse, error)
// Public RPC to get forecasting experiment
GetExperiment(ctx context.Context, request GetForecastingExperimentRequest) (*ForecastingExperiment, error)
}
The Forecasting API allows you to create and get serverless forecasting experiments
Deprecated: Do not use this interface, it will be removed in a future version of the SDK.
type GetByNameRequest ¶
type GetByNameRequest struct {
// Name of the associated experiment.
ExperimentName string `json:"-" tf:"-"`
}
Get an experiment by name
func (GetByNameRequest) MarshalJSON ¶ added in v0.73.0
func (st GetByNameRequest) MarshalJSON() ([]byte, error)
func (*GetByNameRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetByNameRequest) UnmarshalJSON(b []byte) error
type GetExperimentByNameResponse ¶
type GetExperimentByNameResponse struct {
// Experiment details.
// Wire name: 'experiment'
Experiment *Experiment `json:"experiment,omitempty"`
}
func (GetExperimentByNameResponse) MarshalJSON ¶ added in v0.73.0
func (st GetExperimentByNameResponse) MarshalJSON() ([]byte, error)
func (*GetExperimentByNameResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetExperimentByNameResponse) UnmarshalJSON(b []byte) error
type GetExperimentPermissionLevelsRequest ¶ added in v0.15.0
type GetExperimentPermissionLevelsRequest struct {
// The experiment for which to get or manage permissions.
ExperimentId string `json:"-" tf:"-"`
}
Get experiment permission levels
func (GetExperimentPermissionLevelsRequest) MarshalJSON ¶ added in v0.73.0
func (st GetExperimentPermissionLevelsRequest) MarshalJSON() ([]byte, error)
func (*GetExperimentPermissionLevelsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetExperimentPermissionLevelsRequest) UnmarshalJSON(b []byte) error
type GetExperimentPermissionLevelsResponse ¶ added in v0.15.0
type GetExperimentPermissionLevelsResponse struct {
// Specific permission levels
// Wire name: 'permission_levels'
PermissionLevels []ExperimentPermissionsDescription `json:"permission_levels,omitempty"`
}
func (GetExperimentPermissionLevelsResponse) MarshalJSON ¶ added in v0.73.0
func (st GetExperimentPermissionLevelsResponse) MarshalJSON() ([]byte, error)
func (*GetExperimentPermissionLevelsResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetExperimentPermissionLevelsResponse) UnmarshalJSON(b []byte) error
type GetExperimentPermissionsRequest ¶ added in v0.15.0
type GetExperimentPermissionsRequest struct {
// The experiment for which to get or manage permissions.
ExperimentId string `json:"-" tf:"-"`
}
Get experiment permissions
func (GetExperimentPermissionsRequest) MarshalJSON ¶ added in v0.73.0
func (st GetExperimentPermissionsRequest) MarshalJSON() ([]byte, error)
func (*GetExperimentPermissionsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetExperimentPermissionsRequest) UnmarshalJSON(b []byte) error
type GetExperimentRequest ¶
type GetExperimentRequest struct {
// ID of the associated experiment.
ExperimentId string `json:"-" tf:"-"`
}
Get an experiment
func (GetExperimentRequest) MarshalJSON ¶ added in v0.73.0
func (st GetExperimentRequest) MarshalJSON() ([]byte, error)
func (*GetExperimentRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetExperimentRequest) UnmarshalJSON(b []byte) error
type GetExperimentResponse ¶ added in v0.18.0
type GetExperimentResponse struct {
// Experiment details.
// Wire name: 'experiment'
Experiment *Experiment `json:"experiment,omitempty"`
}
func (GetExperimentResponse) MarshalJSON ¶ added in v0.73.0
func (st GetExperimentResponse) MarshalJSON() ([]byte, error)
func (*GetExperimentResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetExperimentResponse) UnmarshalJSON(b []byte) error
type GetForecastingExperimentRequest ¶ added in v0.60.0
type GetForecastingExperimentRequest struct {
// The unique ID of a forecasting experiment
ExperimentId string `json:"-" tf:"-"`
}
Get a forecasting experiment
func (GetForecastingExperimentRequest) MarshalJSON ¶ added in v0.73.0
func (st GetForecastingExperimentRequest) MarshalJSON() ([]byte, error)
func (*GetForecastingExperimentRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetForecastingExperimentRequest) UnmarshalJSON(b []byte) error
type GetHistoryRequest ¶
type GetHistoryRequest struct {
// Maximum number of Metric records to return per paginated request. Default
// is set to 25,000. If set higher than 25,000, a request Exception will be
// raised.
MaxResults int `json:"-" tf:"-"`
// Name of the metric.
MetricKey string `json:"-" tf:"-"`
// Token indicating the page of metric histories to fetch.
PageToken string `json:"-" tf:"-"`
// ID of the run from which to fetch metric values. Must be provided.
RunId string `json:"-" tf:"-"`
// [Deprecated, use `run_id` instead] ID of the run from which to fetch
// metric values. This field will be removed in a future MLflow version.
RunUuid string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
Get metric history for a run
func (GetHistoryRequest) MarshalJSON ¶ added in v0.23.0
func (st GetHistoryRequest) MarshalJSON() ([]byte, error)
func (*GetHistoryRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *GetHistoryRequest) UnmarshalJSON(b []byte) error
type GetLatestVersionsRequest ¶
type GetLatestVersionsRequest struct {
// Registered model unique name identifier.
// Wire name: 'name'
Name string `json:"name"`
// List of stages.
// Wire name: 'stages'
Stages []string `json:"stages,omitempty"`
}
func (GetLatestVersionsRequest) MarshalJSON ¶ added in v0.73.0
func (st GetLatestVersionsRequest) MarshalJSON() ([]byte, error)
func (*GetLatestVersionsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetLatestVersionsRequest) UnmarshalJSON(b []byte) error
type GetLatestVersionsResponse ¶
type GetLatestVersionsResponse struct {
// Latest version models for each requests stage. Only return models with
// current `READY` status. If no `stages` provided, returns the latest
// version for each stage, including `"None"`.
// Wire name: 'model_versions'
ModelVersions []ModelVersion `json:"model_versions,omitempty"`
}
func (GetLatestVersionsResponse) MarshalJSON ¶ added in v0.73.0
func (st GetLatestVersionsResponse) MarshalJSON() ([]byte, error)
func (*GetLatestVersionsResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetLatestVersionsResponse) UnmarshalJSON(b []byte) error
type GetLoggedModelRequest ¶ added in v0.70.0
type GetLoggedModelRequest struct {
// The ID of the logged model to retrieve.
ModelId string `json:"-" tf:"-"`
}
Get a logged model
func (GetLoggedModelRequest) MarshalJSON ¶ added in v0.73.0
func (st GetLoggedModelRequest) MarshalJSON() ([]byte, error)
func (*GetLoggedModelRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetLoggedModelRequest) UnmarshalJSON(b []byte) error
type GetLoggedModelResponse ¶ added in v0.70.0
type GetLoggedModelResponse struct {
// The retrieved logged model.
// Wire name: 'model'
Model *LoggedModel `json:"model,omitempty"`
}
func (GetLoggedModelResponse) MarshalJSON ¶ added in v0.73.0
func (st GetLoggedModelResponse) MarshalJSON() ([]byte, error)
func (*GetLoggedModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetLoggedModelResponse) UnmarshalJSON(b []byte) error
type GetMetricHistoryResponse ¶
type GetMetricHistoryResponse struct {
// All logged values for this metric if `max_results` is not specified in
// the request or if the total count of metrics returned is less than the
// service level pagination threshold. Otherwise, this is one page of
// results.
// Wire name: 'metrics'
Metrics []Metric `json:"metrics,omitempty"`
// A token that can be used to issue a query for the next page of metric
// history values. A missing token indicates that no additional metrics are
// available to fetch.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (GetMetricHistoryResponse) MarshalJSON ¶ added in v0.23.0
func (st GetMetricHistoryResponse) MarshalJSON() ([]byte, error)
func (*GetMetricHistoryResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *GetMetricHistoryResponse) UnmarshalJSON(b []byte) error
type GetModelRequest ¶
type GetModelRequest struct {
// Registered model unique name identifier.
Name string `json:"-" tf:"-"`
}
Get model
func (GetModelRequest) MarshalJSON ¶ added in v0.73.0
func (st GetModelRequest) MarshalJSON() ([]byte, error)
func (*GetModelRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetModelRequest) UnmarshalJSON(b []byte) error
type GetModelResponse ¶
type GetModelResponse struct {
// Wire name: 'registered_model_databricks'
RegisteredModelDatabricks *ModelDatabricks `json:"registered_model_databricks,omitempty"`
}
func (GetModelResponse) MarshalJSON ¶ added in v0.73.0
func (st GetModelResponse) MarshalJSON() ([]byte, error)
func (*GetModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetModelResponse) UnmarshalJSON(b []byte) error
type GetModelVersionDownloadUriRequest ¶
type GetModelVersionDownloadUriRequest struct {
// Name of the registered model
Name string `json:"-" tf:"-"`
// Model version number
Version string `json:"-" tf:"-"`
}
Get a model version URI
func (GetModelVersionDownloadUriRequest) MarshalJSON ¶ added in v0.73.0
func (st GetModelVersionDownloadUriRequest) MarshalJSON() ([]byte, error)
func (*GetModelVersionDownloadUriRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetModelVersionDownloadUriRequest) UnmarshalJSON(b []byte) error
type GetModelVersionDownloadUriResponse ¶
type GetModelVersionDownloadUriResponse struct {
// URI corresponding to where artifacts for this model version are stored.
// Wire name: 'artifact_uri'
ArtifactUri string `json:"artifact_uri,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (GetModelVersionDownloadUriResponse) MarshalJSON ¶ added in v0.23.0
func (st GetModelVersionDownloadUriResponse) MarshalJSON() ([]byte, error)
func (*GetModelVersionDownloadUriResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *GetModelVersionDownloadUriResponse) UnmarshalJSON(b []byte) error
type GetModelVersionRequest ¶
type GetModelVersionRequest struct {
// Name of the registered model
Name string `json:"-" tf:"-"`
// Model version number
Version string `json:"-" tf:"-"`
}
Get a model version
func (GetModelVersionRequest) MarshalJSON ¶ added in v0.73.0
func (st GetModelVersionRequest) MarshalJSON() ([]byte, error)
func (*GetModelVersionRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetModelVersionRequest) UnmarshalJSON(b []byte) error
type GetModelVersionResponse ¶
type GetModelVersionResponse struct {
// Wire name: 'model_version'
ModelVersion *ModelVersion `json:"model_version,omitempty"`
}
func (GetModelVersionResponse) MarshalJSON ¶ added in v0.73.0
func (st GetModelVersionResponse) MarshalJSON() ([]byte, error)
func (*GetModelVersionResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetModelVersionResponse) UnmarshalJSON(b []byte) error
type GetOnlineStoreRequest ¶ added in v0.73.0
type GetOnlineStoreRequest struct {
// Name of the online store to get.
Name string `json:"-" tf:"-"`
}
Get an Online Feature Store
func (GetOnlineStoreRequest) MarshalJSON ¶ added in v0.73.0
func (st GetOnlineStoreRequest) MarshalJSON() ([]byte, error)
func (*GetOnlineStoreRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetOnlineStoreRequest) UnmarshalJSON(b []byte) error
type GetRegisteredModelPermissionLevelsRequest ¶ added in v0.15.0
type GetRegisteredModelPermissionLevelsRequest struct {
// The registered model for which to get or manage permissions.
RegisteredModelId string `json:"-" tf:"-"`
}
Get registered model permission levels
func (GetRegisteredModelPermissionLevelsRequest) MarshalJSON ¶ added in v0.73.0
func (st GetRegisteredModelPermissionLevelsRequest) MarshalJSON() ([]byte, error)
func (*GetRegisteredModelPermissionLevelsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetRegisteredModelPermissionLevelsRequest) UnmarshalJSON(b []byte) error
type GetRegisteredModelPermissionLevelsResponse ¶ added in v0.15.0
type GetRegisteredModelPermissionLevelsResponse struct {
// Specific permission levels
// Wire name: 'permission_levels'
PermissionLevels []RegisteredModelPermissionsDescription `json:"permission_levels,omitempty"`
}
func (GetRegisteredModelPermissionLevelsResponse) MarshalJSON ¶ added in v0.73.0
func (st GetRegisteredModelPermissionLevelsResponse) MarshalJSON() ([]byte, error)
func (*GetRegisteredModelPermissionLevelsResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetRegisteredModelPermissionLevelsResponse) UnmarshalJSON(b []byte) error
type GetRegisteredModelPermissionsRequest ¶ added in v0.15.0
type GetRegisteredModelPermissionsRequest struct {
// The registered model for which to get or manage permissions.
RegisteredModelId string `json:"-" tf:"-"`
}
Get registered model permissions
func (GetRegisteredModelPermissionsRequest) MarshalJSON ¶ added in v0.73.0
func (st GetRegisteredModelPermissionsRequest) MarshalJSON() ([]byte, error)
func (*GetRegisteredModelPermissionsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *GetRegisteredModelPermissionsRequest) UnmarshalJSON(b []byte) error
type GetRunRequest ¶
type GetRunRequest struct {
// ID of the run to fetch. Must be provided.
RunId string `json:"-" tf:"-"`
// [Deprecated, use `run_id` instead] ID of the run to fetch. This field
// will be removed in a future MLflow version.
RunUuid string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
Get a run
func (GetRunRequest) MarshalJSON ¶ added in v0.23.0
func (st GetRunRequest) MarshalJSON() ([]byte, error)
func (*GetRunRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *GetRunRequest) UnmarshalJSON(b []byte) error
type GetRunResponse ¶
type GetRunResponse struct {
// Run metadata (name, start time, etc) and data (metrics, params, and
// tags).
// Wire name: 'run'
Run *Run `json:"run,omitempty"`
}
func (GetRunResponse) MarshalJSON ¶ added in v0.73.0
func (st GetRunResponse) MarshalJSON() ([]byte, error)
func (*GetRunResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *GetRunResponse) UnmarshalJSON(b []byte) error
type HttpUrlSpec ¶
type HttpUrlSpec struct {
// Value of the authorization header that should be sent in the request sent
// by the wehbook. It should be of the form `"<auth type> <credentials>"`.
// If set to an empty string, no authorization header will be included in
// the request.
// Wire name: 'authorization'
Authorization string `json:"authorization,omitempty"`
// Enable/disable SSL certificate validation. Default is true. For
// self-signed certificates, this field must be false AND the destination
// server must disable certificate validation as well. For security
// purposes, it is encouraged to perform secret validation with the
// HMAC-encoded portion of the payload and acknowledge the risk associated
// with disabling hostname validation whereby it becomes more likely that
// requests can be maliciously routed to an unintended host.
// Wire name: 'enable_ssl_verification'
EnableSslVerification bool `json:"enable_ssl_verification,omitempty"`
// Shared secret required for HMAC encoding payload. The HMAC-encoded
// payload will be sent in the header as: { "X-Databricks-Signature":
// $encoded_payload }.
// Wire name: 'secret'
Secret string `json:"secret,omitempty"`
// External HTTPS URL called on event trigger (by using a POST request).
// Wire name: 'url'
Url string `json:"url"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (HttpUrlSpec) MarshalJSON ¶ added in v0.23.0
func (st HttpUrlSpec) MarshalJSON() ([]byte, error)
func (*HttpUrlSpec) UnmarshalJSON ¶ added in v0.23.0
func (st *HttpUrlSpec) UnmarshalJSON(b []byte) error
type HttpUrlSpecWithoutSecret ¶
type HttpUrlSpecWithoutSecret struct {
// Enable/disable SSL certificate validation. Default is true. For
// self-signed certificates, this field must be false AND the destination
// server must disable certificate validation as well. For security
// purposes, it is encouraged to perform secret validation with the
// HMAC-encoded portion of the payload and acknowledge the risk associated
// with disabling hostname validation whereby it becomes more likely that
// requests can be maliciously routed to an unintended host.
// Wire name: 'enable_ssl_verification'
EnableSslVerification bool `json:"enable_ssl_verification,omitempty"`
// External HTTPS URL called on event trigger (by using a POST request).
// Wire name: 'url'
Url string `json:"url,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (HttpUrlSpecWithoutSecret) MarshalJSON ¶ added in v0.23.0
func (st HttpUrlSpecWithoutSecret) MarshalJSON() ([]byte, error)
func (*HttpUrlSpecWithoutSecret) UnmarshalJSON ¶ added in v0.23.0
func (st *HttpUrlSpecWithoutSecret) UnmarshalJSON(b []byte) error
type InputTag ¶ added in v0.9.0
type InputTag struct {
// The tag key.
// Wire name: 'key'
Key string `json:"key"`
// The tag value.
// Wire name: 'value'
Value string `json:"value"`
}
Tag for a dataset input.
func (InputTag) MarshalJSON ¶ added in v0.23.0
func (*InputTag) UnmarshalJSON ¶ added in v0.23.0
type JobSpec ¶
type JobSpec struct {
// The personal access token used to authorize webhook's job runs.
// Wire name: 'access_token'
AccessToken string `json:"access_token"`
// ID of the job that the webhook runs.
// Wire name: 'job_id'
JobId string `json:"job_id"`
// URL of the workspace containing the job that this webhook runs. If not
// specified, the job’s workspace URL is assumed to be the same as the
// workspace where the webhook is created.
// Wire name: 'workspace_url'
WorkspaceUrl string `json:"workspace_url,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (JobSpec) MarshalJSON ¶ added in v0.23.0
func (*JobSpec) UnmarshalJSON ¶ added in v0.23.0
type JobSpecWithoutSecret ¶
type JobSpecWithoutSecret struct {
// ID of the job that the webhook runs.
// Wire name: 'job_id'
JobId string `json:"job_id,omitempty"`
// URL of the workspace containing the job that this webhook runs. Defaults
// to the workspace URL in which the webhook is created. If not specified,
// the job’s workspace is assumed to be the same as the webhook’s.
// Wire name: 'workspace_url'
WorkspaceUrl string `json:"workspace_url,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (JobSpecWithoutSecret) MarshalJSON ¶ added in v0.23.0
func (st JobSpecWithoutSecret) MarshalJSON() ([]byte, error)
func (*JobSpecWithoutSecret) UnmarshalJSON ¶ added in v0.23.0
func (st *JobSpecWithoutSecret) UnmarshalJSON(b []byte) error
type ListArtifactsRequest ¶
type ListArtifactsRequest struct {
// The token indicating the page of artifact results to fetch. `page_token`
// is not supported when listing artifacts in UC Volumes. A maximum of 1000
// artifacts will be retrieved for UC Volumes. Please call
// `/api/2.0/fs/directories{directory_path}` for listing artifacts in UC
// Volumes, which supports pagination. See [List directory contents | Files
// API](/api/workspace/files/listdirectorycontents).
PageToken string `json:"-" tf:"-"`
// Filter artifacts matching this path (a relative path from the root
// artifact directory).
Path string `json:"-" tf:"-"`
// ID of the run whose artifacts to list. Must be provided.
RunId string `json:"-" tf:"-"`
// [Deprecated, use `run_id` instead] ID of the run whose artifacts to list.
// This field will be removed in a future MLflow version.
RunUuid string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
List artifacts
func (ListArtifactsRequest) MarshalJSON ¶ added in v0.23.0
func (st ListArtifactsRequest) MarshalJSON() ([]byte, error)
func (*ListArtifactsRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *ListArtifactsRequest) UnmarshalJSON(b []byte) error
type ListArtifactsResponse ¶
type ListArtifactsResponse struct {
// The file location and metadata for artifacts.
// Wire name: 'files'
Files []FileInfo `json:"files,omitempty"`
// The token that can be used to retrieve the next page of artifact results.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
// The root artifact directory for the run.
// Wire name: 'root_uri'
RootUri string `json:"root_uri,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ListArtifactsResponse) MarshalJSON ¶ added in v0.23.0
func (st ListArtifactsResponse) MarshalJSON() ([]byte, error)
func (*ListArtifactsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *ListArtifactsResponse) UnmarshalJSON(b []byte) error
type ListExperimentsRequest ¶
type ListExperimentsRequest struct {
// Maximum number of experiments desired. If `max_results` is unspecified,
// return all experiments. If `max_results` is too large, it'll be
// automatically capped at 1000. Callers of this endpoint are encouraged to
// pass max_results explicitly and leverage page_token to iterate through
// experiments.
MaxResults int64 `json:"-" tf:"-"`
// Token indicating the page of experiments to fetch
PageToken string `json:"-" tf:"-"`
// Qualifier for type of experiments to be returned. If unspecified, return
// only active experiments.
ViewType ViewType `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
List experiments
func (ListExperimentsRequest) MarshalJSON ¶ added in v0.23.0
func (st ListExperimentsRequest) MarshalJSON() ([]byte, error)
func (*ListExperimentsRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *ListExperimentsRequest) UnmarshalJSON(b []byte) error
type ListExperimentsResponse ¶
type ListExperimentsResponse struct {
// Paginated Experiments beginning with the first item on the requested
// page.
// Wire name: 'experiments'
Experiments []Experiment `json:"experiments,omitempty"`
// Token that can be used to retrieve the next page of experiments. Empty
// token means no more experiment is available for retrieval.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ListExperimentsResponse) MarshalJSON ¶ added in v0.23.0
func (st ListExperimentsResponse) MarshalJSON() ([]byte, error)
func (*ListExperimentsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *ListExperimentsResponse) UnmarshalJSON(b []byte) error
type ListModelsRequest ¶
type ListModelsRequest struct {
// Maximum number of registered models desired. Max threshold is 1000.
MaxResults int `json:"-" tf:"-"`
// Pagination token to go to the next page based on a previous query.
PageToken string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
List models
func (ListModelsRequest) MarshalJSON ¶ added in v0.23.0
func (st ListModelsRequest) MarshalJSON() ([]byte, error)
func (*ListModelsRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *ListModelsRequest) UnmarshalJSON(b []byte) error
type ListModelsResponse ¶
type ListModelsResponse struct {
// Pagination token to request next page of models for the same query.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
// Wire name: 'registered_models'
RegisteredModels []Model `json:"registered_models,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ListModelsResponse) MarshalJSON ¶ added in v0.23.0
func (st ListModelsResponse) MarshalJSON() ([]byte, error)
func (*ListModelsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *ListModelsResponse) UnmarshalJSON(b []byte) error
type ListOnlineStoresRequest ¶ added in v0.73.0
type ListOnlineStoresRequest struct {
// The maximum number of results to return. Defaults to 100 if not
// specified.
PageSize int `json:"-" tf:"-"`
// Pagination token to go to the next page based on a previous query.
PageToken string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
List Online Feature Stores
func (ListOnlineStoresRequest) MarshalJSON ¶ added in v0.73.0
func (st ListOnlineStoresRequest) MarshalJSON() ([]byte, error)
func (*ListOnlineStoresRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *ListOnlineStoresRequest) UnmarshalJSON(b []byte) error
type ListOnlineStoresResponse ¶ added in v0.73.0
type ListOnlineStoresResponse struct {
// Pagination token to request the next page of results for this query.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
// List of online stores.
// Wire name: 'online_stores'
OnlineStores []OnlineStore `json:"online_stores,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ListOnlineStoresResponse) MarshalJSON ¶ added in v0.73.0
func (st ListOnlineStoresResponse) MarshalJSON() ([]byte, error)
func (*ListOnlineStoresResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *ListOnlineStoresResponse) UnmarshalJSON(b []byte) error
type ListRegistryWebhooks ¶
type ListRegistryWebhooks struct {
// Token that can be used to retrieve the next page of artifact results
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
// Array of registry webhooks.
// Wire name: 'webhooks'
Webhooks []RegistryWebhook `json:"webhooks,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ListRegistryWebhooks) MarshalJSON ¶ added in v0.23.0
func (st ListRegistryWebhooks) MarshalJSON() ([]byte, error)
func (*ListRegistryWebhooks) UnmarshalJSON ¶ added in v0.23.0
func (st *ListRegistryWebhooks) UnmarshalJSON(b []byte) error
type ListTransitionRequestsRequest ¶
type ListTransitionRequestsRequest struct {
// Name of the model.
Name string `json:"-" tf:"-"`
// Version of the model.
Version string `json:"-" tf:"-"`
}
List transition requests
func (ListTransitionRequestsRequest) MarshalJSON ¶ added in v0.73.0
func (st ListTransitionRequestsRequest) MarshalJSON() ([]byte, error)
func (*ListTransitionRequestsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *ListTransitionRequestsRequest) UnmarshalJSON(b []byte) error
type ListTransitionRequestsResponse ¶
type ListTransitionRequestsResponse struct {
// Array of open transition requests.
// Wire name: 'requests'
Requests []Activity `json:"requests,omitempty"`
}
func (ListTransitionRequestsResponse) MarshalJSON ¶ added in v0.73.0
func (st ListTransitionRequestsResponse) MarshalJSON() ([]byte, error)
func (*ListTransitionRequestsResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *ListTransitionRequestsResponse) UnmarshalJSON(b []byte) error
type ListWebhooksRequest ¶
type ListWebhooksRequest struct {
// If `events` is specified, any webhook with one or more of the specified
// trigger events is included in the output. If `events` is not specified,
// webhooks of all event types are included in the output.
Events []RegistryWebhookEvent `json:"-" tf:"-"`
// If not specified, all webhooks associated with the specified events are
// listed, regardless of their associated model.
ModelName string `json:"-" tf:"-"`
// Token indicating the page of artifact results to fetch
PageToken string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
List registry webhooks
func (ListWebhooksRequest) MarshalJSON ¶ added in v0.23.0
func (st ListWebhooksRequest) MarshalJSON() ([]byte, error)
func (*ListWebhooksRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *ListWebhooksRequest) UnmarshalJSON(b []byte) error
type LogBatch ¶
type LogBatch struct {
// Metrics to log. A single request can contain up to 1000 metrics, and up
// to 1000 metrics, params, and tags in total.
// Wire name: 'metrics'
Metrics []Metric `json:"metrics,omitempty"`
// Params to log. A single request can contain up to 100 params, and up to
// 1000 metrics, params, and tags in total.
// Wire name: 'params'
Params []Param `json:"params,omitempty"`
// ID of the run to log under
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// Tags to log. A single request can contain up to 100 tags, and up to 1000
// metrics, params, and tags in total.
// Wire name: 'tags'
Tags []RunTag `json:"tags,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (LogBatch) MarshalJSON ¶ added in v0.23.0
func (*LogBatch) UnmarshalJSON ¶ added in v0.23.0
type LogBatchResponse ¶ added in v0.34.0
type LogBatchResponse struct {
}
func (LogBatchResponse) MarshalJSON ¶ added in v0.73.0
func (st LogBatchResponse) MarshalJSON() ([]byte, error)
func (*LogBatchResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *LogBatchResponse) UnmarshalJSON(b []byte) error
type LogInputs ¶ added in v0.9.0
type LogInputs struct {
// Dataset inputs
// Wire name: 'datasets'
Datasets []DatasetInput `json:"datasets,omitempty"`
// Model inputs
// Wire name: 'models'
Models []ModelInput `json:"models,omitempty"`
// ID of the run to log under
// Wire name: 'run_id'
RunId string `json:"run_id"`
}
func (LogInputs) MarshalJSON ¶ added in v0.23.0
func (*LogInputs) UnmarshalJSON ¶ added in v0.23.0
type LogInputsResponse ¶ added in v0.34.0
type LogInputsResponse struct {
}
func (LogInputsResponse) MarshalJSON ¶ added in v0.73.0
func (st LogInputsResponse) MarshalJSON() ([]byte, error)
func (*LogInputsResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *LogInputsResponse) UnmarshalJSON(b []byte) error
type LogLoggedModelParamsRequest ¶ added in v0.70.0
type LogLoggedModelParamsRequest struct {
// The ID of the logged model to log params for.
ModelId string `json:"-" tf:"-"`
// Parameters to attach to the model.
// Wire name: 'params'
Params []LoggedModelParameter `json:"params,omitempty"`
}
func (LogLoggedModelParamsRequest) MarshalJSON ¶ added in v0.73.0
func (st LogLoggedModelParamsRequest) MarshalJSON() ([]byte, error)
func (*LogLoggedModelParamsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *LogLoggedModelParamsRequest) UnmarshalJSON(b []byte) error
type LogLoggedModelParamsRequestResponse ¶ added in v0.70.0
type LogLoggedModelParamsRequestResponse struct {
}
func (LogLoggedModelParamsRequestResponse) MarshalJSON ¶ added in v0.73.0
func (st LogLoggedModelParamsRequestResponse) MarshalJSON() ([]byte, error)
func (*LogLoggedModelParamsRequestResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *LogLoggedModelParamsRequestResponse) UnmarshalJSON(b []byte) error
type LogMetric ¶
type LogMetric struct {
// Dataset digest of the dataset associated with the metric, e.g. an md5
// hash of the dataset that uniquely identifies it within datasets of the
// same name.
// Wire name: 'dataset_digest'
DatasetDigest string `json:"dataset_digest,omitempty"`
// The name of the dataset associated with the metric. E.g.
// “my.uc.table@2” “nyc-taxi-dataset”, “fantastic-elk-3”
// Wire name: 'dataset_name'
DatasetName string `json:"dataset_name,omitempty"`
// Name of the metric.
// Wire name: 'key'
Key string `json:"key"`
// ID of the logged model associated with the metric, if applicable
// Wire name: 'model_id'
ModelId string `json:"model_id,omitempty"`
// ID of the run under which to log the metric. Must be provided.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// [Deprecated, use `run_id` instead] ID of the run under which to log the
// metric. This field will be removed in a future MLflow version.
// Wire name: 'run_uuid'
RunUuid string `json:"run_uuid,omitempty"`
// Step at which to log the metric
// Wire name: 'step'
Step int64 `json:"step,omitempty"`
// Unix timestamp in milliseconds at the time metric was logged.
// Wire name: 'timestamp'
Timestamp int64 `json:"timestamp"`
// Double value of the metric being logged.
// Wire name: 'value'
Value float64 `json:"value"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (LogMetric) MarshalJSON ¶ added in v0.23.0
func (*LogMetric) UnmarshalJSON ¶ added in v0.23.0
type LogMetricResponse ¶ added in v0.34.0
type LogMetricResponse struct {
}
func (LogMetricResponse) MarshalJSON ¶ added in v0.73.0
func (st LogMetricResponse) MarshalJSON() ([]byte, error)
func (*LogMetricResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *LogMetricResponse) UnmarshalJSON(b []byte) error
type LogModel ¶
type LogModel struct {
// MLmodel file in json format.
// Wire name: 'model_json'
ModelJson string `json:"model_json,omitempty"`
// ID of the run to log under
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (LogModel) MarshalJSON ¶ added in v0.23.0
func (*LogModel) UnmarshalJSON ¶ added in v0.23.0
type LogModelResponse ¶ added in v0.34.0
type LogModelResponse struct {
}
func (LogModelResponse) MarshalJSON ¶ added in v0.73.0
func (st LogModelResponse) MarshalJSON() ([]byte, error)
func (*LogModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *LogModelResponse) UnmarshalJSON(b []byte) error
type LogOutputsRequest ¶ added in v0.70.0
type LogOutputsRequest struct {
// The model outputs from the Run.
// Wire name: 'models'
Models []ModelOutput `json:"models,omitempty"`
// The ID of the Run from which to log outputs.
// Wire name: 'run_id'
RunId string `json:"run_id"`
}
func (LogOutputsRequest) MarshalJSON ¶ added in v0.73.0
func (st LogOutputsRequest) MarshalJSON() ([]byte, error)
func (*LogOutputsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *LogOutputsRequest) UnmarshalJSON(b []byte) error
type LogOutputsResponse ¶ added in v0.70.0
type LogOutputsResponse struct {
}
func (LogOutputsResponse) MarshalJSON ¶ added in v0.73.0
func (st LogOutputsResponse) MarshalJSON() ([]byte, error)
func (*LogOutputsResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *LogOutputsResponse) UnmarshalJSON(b []byte) error
type LogParam ¶
type LogParam struct {
// Name of the param. Maximum size is 255 bytes.
// Wire name: 'key'
Key string `json:"key"`
// ID of the run under which to log the param. Must be provided.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// [Deprecated, use `run_id` instead] ID of the run under which to log the
// param. This field will be removed in a future MLflow version.
// Wire name: 'run_uuid'
RunUuid string `json:"run_uuid,omitempty"`
// String value of the param being logged. Maximum size is 500 bytes.
// Wire name: 'value'
Value string `json:"value"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (LogParam) MarshalJSON ¶ added in v0.23.0
func (*LogParam) UnmarshalJSON ¶ added in v0.23.0
type LogParamResponse ¶ added in v0.34.0
type LogParamResponse struct {
}
func (LogParamResponse) MarshalJSON ¶ added in v0.73.0
func (st LogParamResponse) MarshalJSON() ([]byte, error)
func (*LogParamResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *LogParamResponse) UnmarshalJSON(b []byte) error
type LoggedModel ¶ added in v0.70.0
type LoggedModel struct {
// The params and metrics attached to the logged model.
// Wire name: 'data'
Data *LoggedModelData `json:"data,omitempty"`
// The logged model attributes such as model ID, status, tags, etc.
// Wire name: 'info'
Info *LoggedModelInfo `json:"info,omitempty"`
}
A logged model message includes logged model attributes, tags, registration info, params, and linked run metrics.
func (LoggedModel) MarshalJSON ¶ added in v0.73.0
func (st LoggedModel) MarshalJSON() ([]byte, error)
func (*LoggedModel) UnmarshalJSON ¶ added in v0.73.0
func (st *LoggedModel) UnmarshalJSON(b []byte) error
type LoggedModelData ¶ added in v0.70.0
type LoggedModelData struct {
// Performance metrics linked to the model.
// Wire name: 'metrics'
Metrics []Metric `json:"metrics,omitempty"`
// Immutable string key-value pairs of the model.
// Wire name: 'params'
Params []LoggedModelParameter `json:"params,omitempty"`
}
A LoggedModelData message includes logged model params and linked metrics.
func (LoggedModelData) MarshalJSON ¶ added in v0.73.0
func (st LoggedModelData) MarshalJSON() ([]byte, error)
func (*LoggedModelData) UnmarshalJSON ¶ added in v0.73.0
func (st *LoggedModelData) UnmarshalJSON(b []byte) error
type LoggedModelInfo ¶ added in v0.70.0
type LoggedModelInfo struct {
// The URI of the directory where model artifacts are stored.
// Wire name: 'artifact_uri'
ArtifactUri string `json:"artifact_uri,omitempty"`
// The timestamp when the model was created in milliseconds since the UNIX
// epoch.
// Wire name: 'creation_timestamp_ms'
CreationTimestampMs int64 `json:"creation_timestamp_ms,omitempty"`
// The ID of the user or principal that created the model.
// Wire name: 'creator_id'
CreatorId int64 `json:"creator_id,omitempty"`
// The ID of the experiment that owns the model.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id,omitempty"`
// The timestamp when the model was last updated in milliseconds since the
// UNIX epoch.
// Wire name: 'last_updated_timestamp_ms'
LastUpdatedTimestampMs int64 `json:"last_updated_timestamp_ms,omitempty"`
// The unique identifier for the logged model.
// Wire name: 'model_id'
ModelId string `json:"model_id,omitempty"`
// The type of model, such as “"Agent"“, “"Classifier"“, “"LLM"“.
// Wire name: 'model_type'
ModelType string `json:"model_type,omitempty"`
// The name of the model.
// Wire name: 'name'
Name string `json:"name,omitempty"`
// The ID of the run that created the model.
// Wire name: 'source_run_id'
SourceRunId string `json:"source_run_id,omitempty"`
// The status of whether or not the model is ready for use.
// Wire name: 'status'
Status LoggedModelStatus `json:"status,omitempty"`
// Details on the current model status.
// Wire name: 'status_message'
StatusMessage string `json:"status_message,omitempty"`
// Mutable string key-value pairs set on the model.
// Wire name: 'tags'
Tags []LoggedModelTag `json:"tags,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
A LoggedModelInfo includes logged model attributes, tags, and registration info.
func (LoggedModelInfo) MarshalJSON ¶ added in v0.70.0
func (st LoggedModelInfo) MarshalJSON() ([]byte, error)
func (*LoggedModelInfo) UnmarshalJSON ¶ added in v0.70.0
func (st *LoggedModelInfo) UnmarshalJSON(b []byte) error
type LoggedModelParameter ¶ added in v0.70.0
type LoggedModelParameter struct {
// The key identifying this param.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// The value of this param.
// Wire name: 'value'
Value string `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Parameter associated with a LoggedModel.
func (LoggedModelParameter) MarshalJSON ¶ added in v0.70.0
func (st LoggedModelParameter) MarshalJSON() ([]byte, error)
func (*LoggedModelParameter) UnmarshalJSON ¶ added in v0.70.0
func (st *LoggedModelParameter) UnmarshalJSON(b []byte) error
type LoggedModelStatus ¶ added in v0.70.0
type LoggedModelStatus string
A LoggedModelStatus enum value represents the status of a logged model.
const LoggedModelStatusLoggedModelPending LoggedModelStatus = `LOGGED_MODEL_PENDING`
const LoggedModelStatusLoggedModelReady LoggedModelStatus = `LOGGED_MODEL_READY`
const LoggedModelStatusLoggedModelUploadFailed LoggedModelStatus = `LOGGED_MODEL_UPLOAD_FAILED`
func (*LoggedModelStatus) Set ¶ added in v0.70.0
func (f *LoggedModelStatus) Set(v string) error
Set raw string value and validate it against allowed values
func (*LoggedModelStatus) String ¶ added in v0.70.0
func (f *LoggedModelStatus) String() string
String representation for fmt.Print
func (*LoggedModelStatus) Type ¶ added in v0.70.0
func (f *LoggedModelStatus) Type() string
Type always returns LoggedModelStatus to satisfy [pflag.Value] interface
func (*LoggedModelStatus) Values ¶ added in v0.72.0
func (f *LoggedModelStatus) Values() []LoggedModelStatus
Values returns all possible values for LoggedModelStatus.
There is no guarantee on the order of the values in the slice.
type LoggedModelTag ¶ added in v0.70.0
type LoggedModelTag struct {
// The tag key.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// The tag value.
// Wire name: 'value'
Value string `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Tag for a LoggedModel.
func (LoggedModelTag) MarshalJSON ¶ added in v0.70.0
func (st LoggedModelTag) MarshalJSON() ([]byte, error)
func (*LoggedModelTag) UnmarshalJSON ¶ added in v0.70.0
func (st *LoggedModelTag) UnmarshalJSON(b []byte) error
type Metric ¶
type Metric struct {
// The dataset digest of the dataset associated with the metric, e.g. an md5
// hash of the dataset that uniquely identifies it within datasets of the
// same name.
// Wire name: 'dataset_digest'
DatasetDigest string `json:"dataset_digest,omitempty"`
// The name of the dataset associated with the metric. E.g.
// “my.uc.table@2” “nyc-taxi-dataset”, “fantastic-elk-3”
// Wire name: 'dataset_name'
DatasetName string `json:"dataset_name,omitempty"`
// The key identifying the metric.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// The ID of the logged model or registered model version associated with
// the metric, if applicable.
// Wire name: 'model_id'
ModelId string `json:"model_id,omitempty"`
// The ID of the run containing the metric.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// The step at which the metric was logged.
// Wire name: 'step'
Step int64 `json:"step,omitempty"`
// The timestamp at which the metric was recorded.
// Wire name: 'timestamp'
Timestamp int64 `json:"timestamp,omitempty"`
// The value of the metric.
// Wire name: 'value'
Value float64 `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Metric associated with a run, represented as a key-value pair.
func (Metric) MarshalJSON ¶ added in v0.23.0
func (*Metric) UnmarshalJSON ¶ added in v0.23.0
type Model ¶
type Model struct {
// Timestamp recorded when this `registered_model` was created.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// Description of this `registered_model`.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Timestamp recorded when metadata for this `registered_model` was last
// updated.
// Wire name: 'last_updated_timestamp'
LastUpdatedTimestamp int64 `json:"last_updated_timestamp,omitempty"`
// Collection of latest model versions for each stage. Only contains models
// with current `READY` status.
// Wire name: 'latest_versions'
LatestVersions []ModelVersion `json:"latest_versions,omitempty"`
// Unique name for the model.
// Wire name: 'name'
Name string `json:"name,omitempty"`
// Tags: Additional metadata key-value pairs for this `registered_model`.
// Wire name: 'tags'
Tags []ModelTag `json:"tags,omitempty"`
// User that created this `registered_model`
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (Model) MarshalJSON ¶ added in v0.23.0
func (*Model) UnmarshalJSON ¶ added in v0.23.0
type ModelDatabricks ¶
type ModelDatabricks struct {
// Creation time of the object, as a Unix timestamp in milliseconds.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// User-specified description for the object.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Unique identifier for the object.
// Wire name: 'id'
Id string `json:"id,omitempty"`
// Time of the object at last update, as a Unix timestamp in milliseconds.
// Wire name: 'last_updated_timestamp'
LastUpdatedTimestamp int64 `json:"last_updated_timestamp,omitempty"`
// Array of model versions, each the latest version for its stage.
// Wire name: 'latest_versions'
LatestVersions []ModelVersion `json:"latest_versions,omitempty"`
// Name of the model.
// Wire name: 'name'
Name string `json:"name,omitempty"`
// Permission level of the requesting user on the object. For what is
// allowed at each level, see [MLflow Model permissions](..).
// Wire name: 'permission_level'
PermissionLevel PermissionLevel `json:"permission_level,omitempty"`
// Array of tags associated with the model.
// Wire name: 'tags'
Tags []ModelTag `json:"tags,omitempty"`
// The username of the user that created the object.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ModelDatabricks) MarshalJSON ¶ added in v0.23.0
func (st ModelDatabricks) MarshalJSON() ([]byte, error)
func (*ModelDatabricks) UnmarshalJSON ¶ added in v0.23.0
func (st *ModelDatabricks) UnmarshalJSON(b []byte) error
type ModelInput ¶ added in v0.63.0
type ModelInput struct {
// The unique identifier of the model.
// Wire name: 'model_id'
ModelId string `json:"model_id"`
}
Represents a LoggedModel or Registered Model Version input to a Run.
func (ModelInput) MarshalJSON ¶ added in v0.73.0
func (st ModelInput) MarshalJSON() ([]byte, error)
func (*ModelInput) UnmarshalJSON ¶ added in v0.73.0
func (st *ModelInput) UnmarshalJSON(b []byte) error
type ModelOutput ¶ added in v0.70.0
type ModelOutput struct {
// The unique identifier of the model.
// Wire name: 'model_id'
ModelId string `json:"model_id"`
// The step at which the model was produced.
// Wire name: 'step'
Step int64 `json:"step"`
}
Represents a LoggedModel output of a Run.
func (ModelOutput) MarshalJSON ¶ added in v0.73.0
func (st ModelOutput) MarshalJSON() ([]byte, error)
func (*ModelOutput) UnmarshalJSON ¶ added in v0.73.0
func (st *ModelOutput) UnmarshalJSON(b []byte) error
type ModelRegistryAPI ¶
type ModelRegistryAPI struct {
// contains filtered or unexported fields
}
Note: This API reference documents APIs for the Workspace Model Registry. Databricks recommends using [Models in Unity Catalog](/api/workspace/registeredmodels) instead. Models in Unity Catalog provides centralized model governance, cross-workspace access, lineage, and deployment. Workspace Model Registry will be deprecated in the future.
The Workspace Model Registry is a centralized model repository and a UI and set of APIs that enable you to manage the full lifecycle of MLflow Models.
func NewModelRegistry ¶
func NewModelRegistry(client *client.DatabricksClient) *ModelRegistryAPI
func (*ModelRegistryAPI) ApproveTransitionRequest ¶
func (a *ModelRegistryAPI) ApproveTransitionRequest(ctx context.Context, request ApproveTransitionRequest) (*ApproveTransitionRequestResponse, error)
func (*ModelRegistryAPI) CreateComment ¶
func (a *ModelRegistryAPI) CreateComment(ctx context.Context, request CreateComment) (*CreateCommentResponse, error)
Example (ModelVersionComments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
model, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
mv, err := w.ModelRegistry.CreateModelVersion(ctx, ml.CreateModelVersionRequest{
Name: model.RegisteredModel.Name,
Source: "dbfs:/tmp",
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", mv)
created, err := w.ModelRegistry.CreateComment(ctx, ml.CreateComment{
Comment: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
Name: mv.ModelVersion.Name,
Version: mv.ModelVersion.Version,
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
// cleanup
err = w.ModelRegistry.DeleteComment(ctx, ml.DeleteCommentRequest{
Id: created.Comment.Id,
})
if err != nil {
panic(err)
}
func (*ModelRegistryAPI) CreateModel ¶
func (a *ModelRegistryAPI) CreateModel(ctx context.Context, request CreateModelRequest) (*CreateModelResponse, error)
Example (ModelVersionComments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
model, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
Example (ModelVersions) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
model, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
Example (Models) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
created, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
func (*ModelRegistryAPI) CreateModelVersion ¶
func (a *ModelRegistryAPI) CreateModelVersion(ctx context.Context, request CreateModelVersionRequest) (*CreateModelVersionResponse, error)
Example (ModelVersionComments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
model, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
mv, err := w.ModelRegistry.CreateModelVersion(ctx, ml.CreateModelVersionRequest{
Name: model.RegisteredModel.Name,
Source: "dbfs:/tmp",
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", mv)
Example (ModelVersions) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
model, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
created, err := w.ModelRegistry.CreateModelVersion(ctx, ml.CreateModelVersionRequest{
Name: model.RegisteredModel.Name,
Source: "dbfs:/tmp",
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
func (*ModelRegistryAPI) CreateTransitionRequest ¶
func (a *ModelRegistryAPI) CreateTransitionRequest(ctx context.Context, request CreateTransitionRequest) (*CreateTransitionRequestResponse, error)
func (*ModelRegistryAPI) CreateWebhook ¶
func (a *ModelRegistryAPI) CreateWebhook(ctx context.Context, request CreateRegistryWebhook) (*CreateWebhookResponse, error)
Example (RegistryWebhooks) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
created, err := w.ModelRegistry.CreateWebhook(ctx, ml.CreateRegistryWebhook{
Description: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
Events: []ml.RegistryWebhookEvent{ml.RegistryWebhookEventModelVersionCreated},
HttpUrlSpec: &ml.HttpUrlSpec{
Url: w.Config.CanonicalHostName(),
},
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
// cleanup
err = w.ModelRegistry.DeleteWebhook(ctx, ml.DeleteWebhookRequest{
Id: created.Webhook.Id,
})
if err != nil {
panic(err)
}
func (*ModelRegistryAPI) DeleteComment ¶
func (a *ModelRegistryAPI) DeleteComment(ctx context.Context, request DeleteCommentRequest) error
func (*ModelRegistryAPI) DeleteModel ¶
func (a *ModelRegistryAPI) DeleteModel(ctx context.Context, request DeleteModelRequest) error
func (*ModelRegistryAPI) DeleteModelTag ¶
func (a *ModelRegistryAPI) DeleteModelTag(ctx context.Context, request DeleteModelTagRequest) error
func (*ModelRegistryAPI) DeleteModelVersion ¶
func (a *ModelRegistryAPI) DeleteModelVersion(ctx context.Context, request DeleteModelVersionRequest) error
func (*ModelRegistryAPI) DeleteModelVersionTag ¶
func (a *ModelRegistryAPI) DeleteModelVersionTag(ctx context.Context, request DeleteModelVersionTagRequest) error
func (*ModelRegistryAPI) DeleteTransitionRequest ¶
func (a *ModelRegistryAPI) DeleteTransitionRequest(ctx context.Context, request DeleteTransitionRequestRequest) error
func (*ModelRegistryAPI) DeleteWebhook ¶
func (a *ModelRegistryAPI) DeleteWebhook(ctx context.Context, request DeleteWebhookRequest) error
func (*ModelRegistryAPI) GetLatestVersions ¶ added in v0.24.0
func (a *ModelRegistryAPI) GetLatestVersions(ctx context.Context, request GetLatestVersionsRequest) listing.Iterator[ModelVersion]
Gets the latest version of a registered model.
func (*ModelRegistryAPI) GetLatestVersionsAll ¶
func (a *ModelRegistryAPI) GetLatestVersionsAll(ctx context.Context, request GetLatestVersionsRequest) ([]ModelVersion, error)
Gets the latest version of a registered model.
func (*ModelRegistryAPI) GetModel ¶
func (a *ModelRegistryAPI) GetModel(ctx context.Context, request GetModelRequest) (*GetModelResponse, error)
Example (Models) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
created, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
model, err := w.ModelRegistry.GetModel(ctx, ml.GetModelRequest{
Name: created.RegisteredModel.Name,
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
func (*ModelRegistryAPI) GetModelVersion ¶
func (a *ModelRegistryAPI) GetModelVersion(ctx context.Context, request GetModelVersionRequest) (*GetModelVersionResponse, error)
func (*ModelRegistryAPI) GetModelVersionDownloadUri ¶
func (a *ModelRegistryAPI) GetModelVersionDownloadUri(ctx context.Context, request GetModelVersionDownloadUriRequest) (*GetModelVersionDownloadUriResponse, error)
func (*ModelRegistryAPI) GetPermissionLevels ¶ added in v0.19.0
func (a *ModelRegistryAPI) GetPermissionLevels(ctx context.Context, request GetRegisteredModelPermissionLevelsRequest) (*GetRegisteredModelPermissionLevelsResponse, error)
func (*ModelRegistryAPI) GetPermissionLevelsByRegisteredModelId ¶ added in v0.19.0
func (a *ModelRegistryAPI) GetPermissionLevelsByRegisteredModelId(ctx context.Context, registeredModelId string) (*GetRegisteredModelPermissionLevelsResponse, error)
Gets the permission levels that a user can have on an object.
func (*ModelRegistryAPI) GetPermissions ¶ added in v0.19.0
func (a *ModelRegistryAPI) GetPermissions(ctx context.Context, request GetRegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
func (*ModelRegistryAPI) GetPermissionsByRegisteredModelId ¶ added in v0.19.0
func (a *ModelRegistryAPI) GetPermissionsByRegisteredModelId(ctx context.Context, registeredModelId string) (*RegisteredModelPermissions, error)
Gets the permissions of a registered model. Registered models can inherit permissions from their root object.
func (*ModelRegistryAPI) ListModels ¶ added in v0.24.0
func (a *ModelRegistryAPI) ListModels(ctx context.Context, request ListModelsRequest) listing.Iterator[Model]
Lists all available registered models, up to the limit specified in __max_results__.
Example (Models) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
all, err := w.ModelRegistry.ListModelsAll(ctx, ml.ListModelsRequest{})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", all)
func (*ModelRegistryAPI) ListModelsAll ¶
func (a *ModelRegistryAPI) ListModelsAll(ctx context.Context, request ListModelsRequest) ([]Model, error)
Lists all available registered models, up to the limit specified in __max_results__.
func (*ModelRegistryAPI) ListTransitionRequests ¶ added in v0.24.0
func (a *ModelRegistryAPI) ListTransitionRequests(ctx context.Context, request ListTransitionRequestsRequest) listing.Iterator[Activity]
Gets a list of all open stage transition requests for the model version.
func (*ModelRegistryAPI) ListTransitionRequestsAll ¶
func (a *ModelRegistryAPI) ListTransitionRequestsAll(ctx context.Context, request ListTransitionRequestsRequest) ([]Activity, error)
Gets a list of all open stage transition requests for the model version.
func (*ModelRegistryAPI) ListWebhooks ¶ added in v0.24.0
func (a *ModelRegistryAPI) ListWebhooks(ctx context.Context, request ListWebhooksRequest) listing.Iterator[RegistryWebhook]
**NOTE:** This endpoint is in Public Preview.
Lists all registry webhooks.
Example (RegistryWebhooks) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
all, err := w.ModelRegistry.ListWebhooksAll(ctx, ml.ListWebhooksRequest{})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", all)
func (*ModelRegistryAPI) ListWebhooksAll ¶
func (a *ModelRegistryAPI) ListWebhooksAll(ctx context.Context, request ListWebhooksRequest) ([]RegistryWebhook, error)
**NOTE:** This endpoint is in Public Preview.
Lists all registry webhooks.
func (*ModelRegistryAPI) RejectTransitionRequest ¶
func (a *ModelRegistryAPI) RejectTransitionRequest(ctx context.Context, request RejectTransitionRequest) (*RejectTransitionRequestResponse, error)
func (*ModelRegistryAPI) RenameModel ¶
func (a *ModelRegistryAPI) RenameModel(ctx context.Context, request RenameModelRequest) (*RenameModelResponse, error)
func (*ModelRegistryAPI) SearchModelVersions ¶ added in v0.24.0
func (a *ModelRegistryAPI) SearchModelVersions(ctx context.Context, request SearchModelVersionsRequest) listing.Iterator[ModelVersion]
Searches for specific model versions based on the supplied __filter__.
func (*ModelRegistryAPI) SearchModelVersionsAll ¶
func (a *ModelRegistryAPI) SearchModelVersionsAll(ctx context.Context, request SearchModelVersionsRequest) ([]ModelVersion, error)
Searches for specific model versions based on the supplied __filter__.
func (*ModelRegistryAPI) SearchModels ¶ added in v0.24.0
func (a *ModelRegistryAPI) SearchModels(ctx context.Context, request SearchModelsRequest) listing.Iterator[Model]
Search for registered models based on the specified __filter__.
func (*ModelRegistryAPI) SearchModelsAll ¶
func (a *ModelRegistryAPI) SearchModelsAll(ctx context.Context, request SearchModelsRequest) ([]Model, error)
Search for registered models based on the specified __filter__.
func (*ModelRegistryAPI) SetModelTag ¶
func (a *ModelRegistryAPI) SetModelTag(ctx context.Context, request SetModelTagRequest) error
func (*ModelRegistryAPI) SetModelVersionTag ¶
func (a *ModelRegistryAPI) SetModelVersionTag(ctx context.Context, request SetModelVersionTagRequest) error
func (*ModelRegistryAPI) SetPermissions ¶ added in v0.19.0
func (a *ModelRegistryAPI) SetPermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
func (*ModelRegistryAPI) TestRegistryWebhook ¶
func (a *ModelRegistryAPI) TestRegistryWebhook(ctx context.Context, request TestRegistryWebhookRequest) (*TestRegistryWebhookResponse, error)
func (*ModelRegistryAPI) TransitionStage ¶
func (a *ModelRegistryAPI) TransitionStage(ctx context.Context, request TransitionModelVersionStageDatabricks) (*TransitionStageResponse, error)
func (*ModelRegistryAPI) UpdateComment ¶
func (a *ModelRegistryAPI) UpdateComment(ctx context.Context, request UpdateComment) (*UpdateCommentResponse, error)
Example (ModelVersionComments) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
model, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
mv, err := w.ModelRegistry.CreateModelVersion(ctx, ml.CreateModelVersionRequest{
Name: model.RegisteredModel.Name,
Source: "dbfs:/tmp",
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", mv)
created, err := w.ModelRegistry.CreateComment(ctx, ml.CreateComment{
Comment: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
Name: mv.ModelVersion.Name,
Version: mv.ModelVersion.Version,
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
_, err = w.ModelRegistry.UpdateComment(ctx, ml.UpdateComment{
Comment: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
Id: created.Comment.Id,
})
if err != nil {
panic(err)
}
// cleanup
err = w.ModelRegistry.DeleteComment(ctx, ml.DeleteCommentRequest{
Id: created.Comment.Id,
})
if err != nil {
panic(err)
}
func (*ModelRegistryAPI) UpdateModel ¶
func (a *ModelRegistryAPI) UpdateModel(ctx context.Context, request UpdateModelRequest) error
Example (Models) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
created, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
model, err := w.ModelRegistry.GetModel(ctx, ml.GetModelRequest{
Name: created.RegisteredModel.Name,
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
err = w.ModelRegistry.UpdateModel(ctx, ml.UpdateModelRequest{
Name: model.RegisteredModelDatabricks.Name,
Description: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
func (*ModelRegistryAPI) UpdateModelVersion ¶
func (a *ModelRegistryAPI) UpdateModelVersion(ctx context.Context, request UpdateModelVersionRequest) error
Example (ModelVersions) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
model, err := w.ModelRegistry.CreateModel(ctx, ml.CreateModelRequest{
Name: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", model)
created, err := w.ModelRegistry.CreateModelVersion(ctx, ml.CreateModelVersionRequest{
Name: model.RegisteredModel.Name,
Source: "dbfs:/tmp",
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
err = w.ModelRegistry.UpdateModelVersion(ctx, ml.UpdateModelVersionRequest{
Description: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
Name: created.ModelVersion.Name,
Version: created.ModelVersion.Version,
})
if err != nil {
panic(err)
}
func (*ModelRegistryAPI) UpdatePermissions ¶ added in v0.19.0
func (a *ModelRegistryAPI) UpdatePermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
func (*ModelRegistryAPI) UpdateWebhook ¶
func (a *ModelRegistryAPI) UpdateWebhook(ctx context.Context, request UpdateRegistryWebhook) error
Example (RegistryWebhooks) ¶
ctx := context.Background()
w, err := databricks.NewWorkspaceClient()
if err != nil {
panic(err)
}
created, err := w.ModelRegistry.CreateWebhook(ctx, ml.CreateRegistryWebhook{
Description: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
Events: []ml.RegistryWebhookEvent{ml.RegistryWebhookEventModelVersionCreated},
HttpUrlSpec: &ml.HttpUrlSpec{
Url: w.Config.CanonicalHostName(),
},
})
if err != nil {
panic(err)
}
logger.Infof(ctx, "found %v", created)
err = w.ModelRegistry.UpdateWebhook(ctx, ml.UpdateRegistryWebhook{
Id: created.Webhook.Id,
Description: fmt.Sprintf("sdk-%x", time.Now().UnixNano()),
})
if err != nil {
panic(err)
}
// cleanup
err = w.ModelRegistry.DeleteWebhook(ctx, ml.DeleteWebhookRequest{
Id: created.Webhook.Id,
})
if err != nil {
panic(err)
}
type ModelRegistryInterface ¶ added in v0.29.0
type ModelRegistryInterface interface {
// Approves a model version stage transition request.
ApproveTransitionRequest(ctx context.Context, request ApproveTransitionRequest) (*ApproveTransitionRequestResponse, error)
// Posts a comment on a model version. A comment can be submitted either by a
// user or programmatically to display relevant information about the model. For
// example, test results or deployment errors.
CreateComment(ctx context.Context, request CreateComment) (*CreateCommentResponse, error)
// Creates a new registered model with the name specified in the request body.
//
// Throws `RESOURCE_ALREADY_EXISTS` if a registered model with the given name
// exists.
CreateModel(ctx context.Context, request CreateModelRequest) (*CreateModelResponse, error)
// Creates a model version.
CreateModelVersion(ctx context.Context, request CreateModelVersionRequest) (*CreateModelVersionResponse, error)
// Creates a model version stage transition request.
CreateTransitionRequest(ctx context.Context, request CreateTransitionRequest) (*CreateTransitionRequestResponse, error)
// **NOTE**: This endpoint is in Public Preview.
//
// Creates a registry webhook.
CreateWebhook(ctx context.Context, request CreateRegistryWebhook) (*CreateWebhookResponse, error)
// Deletes a comment on a model version.
DeleteComment(ctx context.Context, request DeleteCommentRequest) error
// Deletes a registered model.
DeleteModel(ctx context.Context, request DeleteModelRequest) error
// Deletes the tag for a registered model.
DeleteModelTag(ctx context.Context, request DeleteModelTagRequest) error
// Deletes a model version.
DeleteModelVersion(ctx context.Context, request DeleteModelVersionRequest) error
// Deletes a model version tag.
DeleteModelVersionTag(ctx context.Context, request DeleteModelVersionTagRequest) error
// Cancels a model version stage transition request.
DeleteTransitionRequest(ctx context.Context, request DeleteTransitionRequestRequest) error
// **NOTE:** This endpoint is in Public Preview.
//
// Deletes a registry webhook.
DeleteWebhook(ctx context.Context, request DeleteWebhookRequest) error
// Gets the latest version of a registered model.
//
// This method is generated by Databricks SDK Code Generator.
GetLatestVersions(ctx context.Context, request GetLatestVersionsRequest) listing.Iterator[ModelVersion]
// Gets the latest version of a registered model.
//
// This method is generated by Databricks SDK Code Generator.
GetLatestVersionsAll(ctx context.Context, request GetLatestVersionsRequest) ([]ModelVersion, error)
// Get the details of a model. This is a Databricks workspace version of the
// [MLflow endpoint] that also returns the model's Databricks workspace ID and
// the permission level of the requesting user on the model.
//
// [MLflow endpoint]: https://www.mlflow.org/docs/latest/rest-api.html#get-registeredmodel
GetModel(ctx context.Context, request GetModelRequest) (*GetModelResponse, error)
// Get a model version.
GetModelVersion(ctx context.Context, request GetModelVersionRequest) (*GetModelVersionResponse, error)
// Gets a URI to download the model version.
GetModelVersionDownloadUri(ctx context.Context, request GetModelVersionDownloadUriRequest) (*GetModelVersionDownloadUriResponse, error)
// Gets the permission levels that a user can have on an object.
GetPermissionLevels(ctx context.Context, request GetRegisteredModelPermissionLevelsRequest) (*GetRegisteredModelPermissionLevelsResponse, error)
// Gets the permission levels that a user can have on an object.
GetPermissionLevelsByRegisteredModelId(ctx context.Context, registeredModelId string) (*GetRegisteredModelPermissionLevelsResponse, error)
// Gets the permissions of a registered model. Registered models can inherit
// permissions from their root object.
GetPermissions(ctx context.Context, request GetRegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
// Gets the permissions of a registered model. Registered models can inherit
// permissions from their root object.
GetPermissionsByRegisteredModelId(ctx context.Context, registeredModelId string) (*RegisteredModelPermissions, error)
// Lists all available registered models, up to the limit specified in
// __max_results__.
//
// This method is generated by Databricks SDK Code Generator.
ListModels(ctx context.Context, request ListModelsRequest) listing.Iterator[Model]
// Lists all available registered models, up to the limit specified in
// __max_results__.
//
// This method is generated by Databricks SDK Code Generator.
ListModelsAll(ctx context.Context, request ListModelsRequest) ([]Model, error)
// Gets a list of all open stage transition requests for the model version.
//
// This method is generated by Databricks SDK Code Generator.
ListTransitionRequests(ctx context.Context, request ListTransitionRequestsRequest) listing.Iterator[Activity]
// Gets a list of all open stage transition requests for the model version.
//
// This method is generated by Databricks SDK Code Generator.
ListTransitionRequestsAll(ctx context.Context, request ListTransitionRequestsRequest) ([]Activity, error)
// **NOTE:** This endpoint is in Public Preview.
//
// Lists all registry webhooks.
//
// This method is generated by Databricks SDK Code Generator.
ListWebhooks(ctx context.Context, request ListWebhooksRequest) listing.Iterator[RegistryWebhook]
// **NOTE:** This endpoint is in Public Preview.
//
// Lists all registry webhooks.
//
// This method is generated by Databricks SDK Code Generator.
ListWebhooksAll(ctx context.Context, request ListWebhooksRequest) ([]RegistryWebhook, error)
// Rejects a model version stage transition request.
RejectTransitionRequest(ctx context.Context, request RejectTransitionRequest) (*RejectTransitionRequestResponse, error)
// Renames a registered model.
RenameModel(ctx context.Context, request RenameModelRequest) (*RenameModelResponse, error)
// Searches for specific model versions based on the supplied __filter__.
//
// This method is generated by Databricks SDK Code Generator.
SearchModelVersions(ctx context.Context, request SearchModelVersionsRequest) listing.Iterator[ModelVersion]
// Searches for specific model versions based on the supplied __filter__.
//
// This method is generated by Databricks SDK Code Generator.
SearchModelVersionsAll(ctx context.Context, request SearchModelVersionsRequest) ([]ModelVersion, error)
// Search for registered models based on the specified __filter__.
//
// This method is generated by Databricks SDK Code Generator.
SearchModels(ctx context.Context, request SearchModelsRequest) listing.Iterator[Model]
// Search for registered models based on the specified __filter__.
//
// This method is generated by Databricks SDK Code Generator.
SearchModelsAll(ctx context.Context, request SearchModelsRequest) ([]Model, error)
// Sets a tag on a registered model.
SetModelTag(ctx context.Context, request SetModelTagRequest) error
// Sets a model version tag.
SetModelVersionTag(ctx context.Context, request SetModelVersionTagRequest) error
// Sets permissions on an object, replacing existing permissions if they exist.
// Deletes all direct permissions if none are specified. Objects can inherit
// permissions from their root object.
SetPermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
// **NOTE:** This endpoint is in Public Preview.
//
// Tests a registry webhook.
TestRegistryWebhook(ctx context.Context, request TestRegistryWebhookRequest) (*TestRegistryWebhookResponse, error)
// Transition a model version's stage. This is a Databricks workspace version of
// the [MLflow endpoint] that also accepts a comment associated with the
// transition to be recorded.",
//
// [MLflow endpoint]: https://www.mlflow.org/docs/latest/rest-api.html#transition-modelversion-stage
TransitionStage(ctx context.Context, request TransitionModelVersionStageDatabricks) (*TransitionStageResponse, error)
// Post an edit to a comment on a model version.
UpdateComment(ctx context.Context, request UpdateComment) (*UpdateCommentResponse, error)
// Updates a registered model.
UpdateModel(ctx context.Context, request UpdateModelRequest) error
// Updates the model version.
UpdateModelVersion(ctx context.Context, request UpdateModelVersionRequest) error
// Updates the permissions on a registered model. Registered models can inherit
// permissions from their root object.
UpdatePermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
// **NOTE:** This endpoint is in Public Preview.
//
// Updates a registry webhook.
UpdateWebhook(ctx context.Context, request UpdateRegistryWebhook) error
}
type ModelRegistryService
deprecated
type ModelRegistryService interface {
// Approves a model version stage transition request.
ApproveTransitionRequest(ctx context.Context, request ApproveTransitionRequest) (*ApproveTransitionRequestResponse, error)
// Posts a comment on a model version. A comment can be submitted either by
// a user or programmatically to display relevant information about the
// model. For example, test results or deployment errors.
CreateComment(ctx context.Context, request CreateComment) (*CreateCommentResponse, error)
// Creates a new registered model with the name specified in the request
// body.
//
// Throws `RESOURCE_ALREADY_EXISTS` if a registered model with the given
// name exists.
CreateModel(ctx context.Context, request CreateModelRequest) (*CreateModelResponse, error)
// Creates a model version.
CreateModelVersion(ctx context.Context, request CreateModelVersionRequest) (*CreateModelVersionResponse, error)
// Creates a model version stage transition request.
CreateTransitionRequest(ctx context.Context, request CreateTransitionRequest) (*CreateTransitionRequestResponse, error)
// **NOTE**: This endpoint is in Public Preview.
//
// Creates a registry webhook.
CreateWebhook(ctx context.Context, request CreateRegistryWebhook) (*CreateWebhookResponse, error)
// Deletes a comment on a model version.
DeleteComment(ctx context.Context, request DeleteCommentRequest) error
// Deletes a registered model.
DeleteModel(ctx context.Context, request DeleteModelRequest) error
// Deletes the tag for a registered model.
DeleteModelTag(ctx context.Context, request DeleteModelTagRequest) error
// Deletes a model version.
DeleteModelVersion(ctx context.Context, request DeleteModelVersionRequest) error
// Deletes a model version tag.
DeleteModelVersionTag(ctx context.Context, request DeleteModelVersionTagRequest) error
// Cancels a model version stage transition request.
DeleteTransitionRequest(ctx context.Context, request DeleteTransitionRequestRequest) error
// **NOTE:** This endpoint is in Public Preview.
//
// Deletes a registry webhook.
DeleteWebhook(ctx context.Context, request DeleteWebhookRequest) error
// Gets the latest version of a registered model.
GetLatestVersions(ctx context.Context, request GetLatestVersionsRequest) (*GetLatestVersionsResponse, error)
// Get the details of a model. This is a Databricks workspace version of the
// [MLflow endpoint] that also returns the model's Databricks workspace ID
// and the permission level of the requesting user on the model.
//
// [MLflow endpoint]: https://www.mlflow.org/docs/latest/rest-api.html#get-registeredmodel
GetModel(ctx context.Context, request GetModelRequest) (*GetModelResponse, error)
// Get a model version.
GetModelVersion(ctx context.Context, request GetModelVersionRequest) (*GetModelVersionResponse, error)
// Gets a URI to download the model version.
GetModelVersionDownloadUri(ctx context.Context, request GetModelVersionDownloadUriRequest) (*GetModelVersionDownloadUriResponse, error)
// Gets the permission levels that a user can have on an object.
GetPermissionLevels(ctx context.Context, request GetRegisteredModelPermissionLevelsRequest) (*GetRegisteredModelPermissionLevelsResponse, error)
// Gets the permissions of a registered model. Registered models can inherit
// permissions from their root object.
GetPermissions(ctx context.Context, request GetRegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
// Lists all available registered models, up to the limit specified in
// __max_results__.
ListModels(ctx context.Context, request ListModelsRequest) (*ListModelsResponse, error)
// Gets a list of all open stage transition requests for the model version.
ListTransitionRequests(ctx context.Context, request ListTransitionRequestsRequest) (*ListTransitionRequestsResponse, error)
// **NOTE:** This endpoint is in Public Preview.
//
// Lists all registry webhooks.
ListWebhooks(ctx context.Context, request ListWebhooksRequest) (*ListRegistryWebhooks, error)
// Rejects a model version stage transition request.
RejectTransitionRequest(ctx context.Context, request RejectTransitionRequest) (*RejectTransitionRequestResponse, error)
// Renames a registered model.
RenameModel(ctx context.Context, request RenameModelRequest) (*RenameModelResponse, error)
// Searches for specific model versions based on the supplied __filter__.
SearchModelVersions(ctx context.Context, request SearchModelVersionsRequest) (*SearchModelVersionsResponse, error)
// Search for registered models based on the specified __filter__.
SearchModels(ctx context.Context, request SearchModelsRequest) (*SearchModelsResponse, error)
// Sets a tag on a registered model.
SetModelTag(ctx context.Context, request SetModelTagRequest) error
// Sets a model version tag.
SetModelVersionTag(ctx context.Context, request SetModelVersionTagRequest) error
// Sets permissions on an object, replacing existing permissions if they
// exist. Deletes all direct permissions if none are specified. Objects can
// inherit permissions from their root object.
SetPermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
// **NOTE:** This endpoint is in Public Preview.
//
// Tests a registry webhook.
TestRegistryWebhook(ctx context.Context, request TestRegistryWebhookRequest) (*TestRegistryWebhookResponse, error)
// Transition a model version's stage. This is a Databricks workspace
// version of the [MLflow endpoint] that also accepts a comment associated
// with the transition to be recorded.",
//
// [MLflow endpoint]: https://www.mlflow.org/docs/latest/rest-api.html#transition-modelversion-stage
TransitionStage(ctx context.Context, request TransitionModelVersionStageDatabricks) (*TransitionStageResponse, error)
// Post an edit to a comment on a model version.
UpdateComment(ctx context.Context, request UpdateComment) (*UpdateCommentResponse, error)
// Updates a registered model.
UpdateModel(ctx context.Context, request UpdateModelRequest) error
// Updates the model version.
UpdateModelVersion(ctx context.Context, request UpdateModelVersionRequest) error
// Updates the permissions on a registered model. Registered models can
// inherit permissions from their root object.
UpdatePermissions(ctx context.Context, request RegisteredModelPermissionsRequest) (*RegisteredModelPermissions, error)
// **NOTE:** This endpoint is in Public Preview.
//
// Updates a registry webhook.
UpdateWebhook(ctx context.Context, request UpdateRegistryWebhook) error
}
Note: This API reference documents APIs for the Workspace Model Registry. Databricks recommends using [Models in Unity Catalog](/api/workspace/registeredmodels) instead. Models in Unity Catalog provides centralized model governance, cross-workspace access, lineage, and deployment. Workspace Model Registry will be deprecated in the future.
The Workspace Model Registry is a centralized model repository and a UI and set of APIs that enable you to manage the full lifecycle of MLflow Models.
Deprecated: Do not use this interface, it will be removed in a future version of the SDK.
type ModelTag ¶
type ModelTag struct {
// The tag key.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// The tag value.
// Wire name: 'value'
Value string `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ModelTag) MarshalJSON ¶ added in v0.23.0
func (*ModelTag) UnmarshalJSON ¶ added in v0.23.0
type ModelVersion ¶
type ModelVersion struct {
// Timestamp recorded when this `model_version` was created.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// Current stage for this `model_version`.
// Wire name: 'current_stage'
CurrentStage string `json:"current_stage,omitempty"`
// Description of this `model_version`.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Timestamp recorded when metadata for this `model_version` was last
// updated.
// Wire name: 'last_updated_timestamp'
LastUpdatedTimestamp int64 `json:"last_updated_timestamp,omitempty"`
// Unique name of the model
// Wire name: 'name'
Name string `json:"name,omitempty"`
// MLflow run ID used when creating `model_version`, if `source` was
// generated by an experiment run stored in MLflow tracking server.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// Run Link: Direct link to the run that generated this version
// Wire name: 'run_link'
RunLink string `json:"run_link,omitempty"`
// URI indicating the location of the source model artifacts, used when
// creating `model_version`
// Wire name: 'source'
Source string `json:"source,omitempty"`
// Current status of `model_version`
// Wire name: 'status'
Status ModelVersionStatus `json:"status,omitempty"`
// Details on current `status`, if it is pending or failed.
// Wire name: 'status_message'
StatusMessage string `json:"status_message,omitempty"`
// Tags: Additional metadata key-value pairs for this `model_version`.
// Wire name: 'tags'
Tags []ModelVersionTag `json:"tags,omitempty"`
// User that created this `model_version`.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
// Model's version number.
// Wire name: 'version'
Version string `json:"version,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ModelVersion) MarshalJSON ¶ added in v0.23.0
func (st ModelVersion) MarshalJSON() ([]byte, error)
func (*ModelVersion) UnmarshalJSON ¶ added in v0.23.0
func (st *ModelVersion) UnmarshalJSON(b []byte) error
type ModelVersionDatabricks ¶
type ModelVersionDatabricks struct {
// Creation time of the object, as a Unix timestamp in milliseconds.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// Stage of the model version. Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'current_stage'
CurrentStage Stage `json:"current_stage,omitempty"`
// User-specified description for the object.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Time of the object at last update, as a Unix timestamp in milliseconds.
// Wire name: 'last_updated_timestamp'
LastUpdatedTimestamp int64 `json:"last_updated_timestamp,omitempty"`
// Name of the model.
// Wire name: 'name'
Name string `json:"name,omitempty"`
// Permission level of the requesting user on the object. For what is
// allowed at each level, see [MLflow Model permissions](..).
// Wire name: 'permission_level'
PermissionLevel PermissionLevel `json:"permission_level,omitempty"`
// Unique identifier for the MLflow tracking run associated with the source
// model artifacts.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// URL of the run associated with the model artifacts. This field is set at
// model version creation time only for model versions whose source run is
// from a tracking server that is different from the registry server.
// Wire name: 'run_link'
RunLink string `json:"run_link,omitempty"`
// URI that indicates the location of the source model artifacts. This is
// used when creating the model version.
// Wire name: 'source'
Source string `json:"source,omitempty"`
// The status of the model version. Valid values are: *
// `PENDING_REGISTRATION`: Request to register a new model version is
// pending as server performs background tasks.
//
// * `FAILED_REGISTRATION`: Request to register a new model version has
// failed.
//
// * `READY`: Model version is ready for use.
// Wire name: 'status'
Status Status `json:"status,omitempty"`
// Details on the current status, for example why registration failed.
// Wire name: 'status_message'
StatusMessage string `json:"status_message,omitempty"`
// Array of tags that are associated with the model version.
// Wire name: 'tags'
Tags []ModelVersionTag `json:"tags,omitempty"`
// The username of the user that created the object.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
// Version of the model.
// Wire name: 'version'
Version string `json:"version,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ModelVersionDatabricks) MarshalJSON ¶ added in v0.23.0
func (st ModelVersionDatabricks) MarshalJSON() ([]byte, error)
func (*ModelVersionDatabricks) UnmarshalJSON ¶ added in v0.23.0
func (st *ModelVersionDatabricks) UnmarshalJSON(b []byte) error
type ModelVersionStatus ¶
type ModelVersionStatus string
Current status of `model_version`
const ModelVersionStatusFailedRegistration ModelVersionStatus = `FAILED_REGISTRATION`
const ModelVersionStatusPendingRegistration ModelVersionStatus = `PENDING_REGISTRATION`
const ModelVersionStatusReady ModelVersionStatus = `READY`
func (*ModelVersionStatus) Set ¶
func (f *ModelVersionStatus) Set(v string) error
Set raw string value and validate it against allowed values
func (*ModelVersionStatus) String ¶
func (f *ModelVersionStatus) String() string
String representation for fmt.Print
func (*ModelVersionStatus) Type ¶
func (f *ModelVersionStatus) Type() string
Type always returns ModelVersionStatus to satisfy [pflag.Value] interface
func (*ModelVersionStatus) Values ¶ added in v0.72.0
func (f *ModelVersionStatus) Values() []ModelVersionStatus
Values returns all possible values for ModelVersionStatus.
There is no guarantee on the order of the values in the slice.
type ModelVersionTag ¶
type ModelVersionTag struct {
// The tag key.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// The tag value.
// Wire name: 'value'
Value string `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (ModelVersionTag) MarshalJSON ¶ added in v0.23.0
func (st ModelVersionTag) MarshalJSON() ([]byte, error)
func (*ModelVersionTag) UnmarshalJSON ¶ added in v0.23.0
func (st *ModelVersionTag) UnmarshalJSON(b []byte) error
type OnlineStore ¶ added in v0.73.0
type OnlineStore struct {
// The capacity of the online store. Valid values are "CU_1", "CU_2",
// "CU_4", "CU_8".
// Wire name: 'capacity'
Capacity string `json:"capacity,omitempty"`
// The timestamp when the online store was created.
// Wire name: 'creation_time'
CreationTime string `json:"creation_time,omitempty"`
// The email of the creator of the online store.
// Wire name: 'creator'
Creator string `json:"creator,omitempty"`
// The name of the online store. This is the unique identifier for the
// online store.
// Wire name: 'name'
Name string `json:"name"`
// The current state of the online store.
// Wire name: 'state'
State OnlineStoreState `json:"state,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
An OnlineStore is a logical database instance that stores and serves features online.
func (OnlineStore) MarshalJSON ¶ added in v0.73.0
func (st OnlineStore) MarshalJSON() ([]byte, error)
func (*OnlineStore) UnmarshalJSON ¶ added in v0.73.0
func (st *OnlineStore) UnmarshalJSON(b []byte) error
type OnlineStoreState ¶ added in v0.73.0
type OnlineStoreState string
const OnlineStoreStateAvailable OnlineStoreState = `AVAILABLE`
const OnlineStoreStateDeleting OnlineStoreState = `DELETING`
const OnlineStoreStateFailingOver OnlineStoreState = `FAILING_OVER`
const OnlineStoreStateStarting OnlineStoreState = `STARTING`
const OnlineStoreStateStopped OnlineStoreState = `STOPPED`
const OnlineStoreStateUpdating OnlineStoreState = `UPDATING`
func (*OnlineStoreState) Set ¶ added in v0.73.0
func (f *OnlineStoreState) Set(v string) error
Set raw string value and validate it against allowed values
func (*OnlineStoreState) String ¶ added in v0.73.0
func (f *OnlineStoreState) String() string
String representation for fmt.Print
func (*OnlineStoreState) Type ¶ added in v0.73.0
func (f *OnlineStoreState) Type() string
Type always returns OnlineStoreState to satisfy [pflag.Value] interface
func (*OnlineStoreState) Values ¶ added in v0.73.0
func (f *OnlineStoreState) Values() []OnlineStoreState
Values returns all possible values for OnlineStoreState.
There is no guarantee on the order of the values in the slice.
type Param ¶
type Param struct {
// Key identifying this param.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// Value associated with this param.
// Wire name: 'value'
Value string `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Param associated with a run.
func (Param) MarshalJSON ¶ added in v0.23.0
func (*Param) UnmarshalJSON ¶ added in v0.23.0
type PermissionLevel ¶
type PermissionLevel string
Permission level of the requesting user on the object. For what is allowed at each level, see [MLflow Model permissions](..).
const PermissionLevelCanEdit PermissionLevel = `CAN_EDIT`
const PermissionLevelCanManage PermissionLevel = `CAN_MANAGE`
const PermissionLevelCanManageProductionVersions PermissionLevel = `CAN_MANAGE_PRODUCTION_VERSIONS`
const PermissionLevelCanManageStagingVersions PermissionLevel = `CAN_MANAGE_STAGING_VERSIONS`
const PermissionLevelCanRead PermissionLevel = `CAN_READ`
func (*PermissionLevel) Set ¶
func (f *PermissionLevel) Set(v string) error
Set raw string value and validate it against allowed values
func (*PermissionLevel) String ¶
func (f *PermissionLevel) String() string
String representation for fmt.Print
func (*PermissionLevel) Type ¶
func (f *PermissionLevel) Type() string
Type always returns PermissionLevel to satisfy [pflag.Value] interface
func (*PermissionLevel) Values ¶ added in v0.72.0
func (f *PermissionLevel) Values() []PermissionLevel
Values returns all possible values for PermissionLevel.
There is no guarantee on the order of the values in the slice.
type PublishSpec ¶ added in v0.73.0
type PublishSpec struct {
// The name of the target online store.
// Wire name: 'online_store'
OnlineStore string `json:"online_store"`
// The full three-part (catalog, schema, table) name of the online table.
// Auto-generated if not specified.
// Wire name: 'online_table_name'
OnlineTableName string `json:"online_table_name,omitempty"`
// The publish mode of the pipeline that syncs the online table with the
// source table. Defaults to TRIGGERED if not specified. All publish modes
// require the source table to have Change Data Feed (CDF) enabled.
// Wire name: 'publish_mode'
PublishMode PublishSpecPublishMode `json:"publish_mode,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (PublishSpec) MarshalJSON ¶ added in v0.73.0
func (st PublishSpec) MarshalJSON() ([]byte, error)
func (*PublishSpec) UnmarshalJSON ¶ added in v0.73.0
func (st *PublishSpec) UnmarshalJSON(b []byte) error
type PublishSpecPublishMode ¶ added in v0.73.0
type PublishSpecPublishMode string
const PublishSpecPublishModeContinuous PublishSpecPublishMode = `CONTINUOUS`
const PublishSpecPublishModeTriggered PublishSpecPublishMode = `TRIGGERED`
func (*PublishSpecPublishMode) Set ¶ added in v0.73.0
func (f *PublishSpecPublishMode) Set(v string) error
Set raw string value and validate it against allowed values
func (*PublishSpecPublishMode) String ¶ added in v0.73.0
func (f *PublishSpecPublishMode) String() string
String representation for fmt.Print
func (*PublishSpecPublishMode) Type ¶ added in v0.73.0
func (f *PublishSpecPublishMode) Type() string
Type always returns PublishSpecPublishMode to satisfy [pflag.Value] interface
func (*PublishSpecPublishMode) Values ¶ added in v0.73.0
func (f *PublishSpecPublishMode) Values() []PublishSpecPublishMode
Values returns all possible values for PublishSpecPublishMode.
There is no guarantee on the order of the values in the slice.
type PublishTableRequest ¶ added in v0.73.0
type PublishTableRequest struct {
// The specification for publishing the online table from the source table.
// Wire name: 'publish_spec'
PublishSpec PublishSpec `json:"publish_spec"`
// The full three-part (catalog, schema, table) name of the source table.
SourceTableName string `json:"-" tf:"-"`
}
func (PublishTableRequest) MarshalJSON ¶ added in v0.73.0
func (st PublishTableRequest) MarshalJSON() ([]byte, error)
func (*PublishTableRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *PublishTableRequest) UnmarshalJSON(b []byte) error
type PublishTableResponse ¶ added in v0.73.0
type PublishTableResponse struct {
// The full three-part (catalog, schema, table) name of the online table.
// Wire name: 'online_table_name'
OnlineTableName string `json:"online_table_name,omitempty"`
// The ID of the pipeline that syncs the online table with the source table.
// Wire name: 'pipeline_id'
PipelineId string `json:"pipeline_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (PublishTableResponse) MarshalJSON ¶ added in v0.73.0
func (st PublishTableResponse) MarshalJSON() ([]byte, error)
func (*PublishTableResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *PublishTableResponse) UnmarshalJSON(b []byte) error
type RegisteredModelAccessControlRequest ¶ added in v0.15.0
type RegisteredModelAccessControlRequest struct {
// name of the group
// Wire name: 'group_name'
GroupName string `json:"group_name,omitempty"`
// Permission level
// Wire name: 'permission_level'
PermissionLevel RegisteredModelPermissionLevel `json:"permission_level,omitempty"`
// application ID of a service principal
// Wire name: 'service_principal_name'
ServicePrincipalName string `json:"service_principal_name,omitempty"`
// name of the user
// Wire name: 'user_name'
UserName string `json:"user_name,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RegisteredModelAccessControlRequest) MarshalJSON ¶ added in v0.23.0
func (st RegisteredModelAccessControlRequest) MarshalJSON() ([]byte, error)
func (*RegisteredModelAccessControlRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *RegisteredModelAccessControlRequest) UnmarshalJSON(b []byte) error
type RegisteredModelAccessControlResponse ¶ added in v0.15.0
type RegisteredModelAccessControlResponse struct {
// All permissions.
// Wire name: 'all_permissions'
AllPermissions []RegisteredModelPermission `json:"all_permissions,omitempty"`
// Display name of the user or service principal.
// Wire name: 'display_name'
DisplayName string `json:"display_name,omitempty"`
// name of the group
// Wire name: 'group_name'
GroupName string `json:"group_name,omitempty"`
// Name of the service principal.
// Wire name: 'service_principal_name'
ServicePrincipalName string `json:"service_principal_name,omitempty"`
// name of the user
// Wire name: 'user_name'
UserName string `json:"user_name,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RegisteredModelAccessControlResponse) MarshalJSON ¶ added in v0.23.0
func (st RegisteredModelAccessControlResponse) MarshalJSON() ([]byte, error)
func (*RegisteredModelAccessControlResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *RegisteredModelAccessControlResponse) UnmarshalJSON(b []byte) error
type RegisteredModelPermission ¶ added in v0.15.0
type RegisteredModelPermission struct {
// Wire name: 'inherited'
Inherited bool `json:"inherited,omitempty"`
// Wire name: 'inherited_from_object'
InheritedFromObject []string `json:"inherited_from_object,omitempty"`
// Permission level
// Wire name: 'permission_level'
PermissionLevel RegisteredModelPermissionLevel `json:"permission_level,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RegisteredModelPermission) MarshalJSON ¶ added in v0.23.0
func (st RegisteredModelPermission) MarshalJSON() ([]byte, error)
func (*RegisteredModelPermission) UnmarshalJSON ¶ added in v0.23.0
func (st *RegisteredModelPermission) UnmarshalJSON(b []byte) error
type RegisteredModelPermissionLevel ¶ added in v0.15.0
type RegisteredModelPermissionLevel string
Permission level
const RegisteredModelPermissionLevelCanEdit RegisteredModelPermissionLevel = `CAN_EDIT`
const RegisteredModelPermissionLevelCanManage RegisteredModelPermissionLevel = `CAN_MANAGE`
const RegisteredModelPermissionLevelCanManageProductionVersions RegisteredModelPermissionLevel = `CAN_MANAGE_PRODUCTION_VERSIONS`
const RegisteredModelPermissionLevelCanManageStagingVersions RegisteredModelPermissionLevel = `CAN_MANAGE_STAGING_VERSIONS`
const RegisteredModelPermissionLevelCanRead RegisteredModelPermissionLevel = `CAN_READ`
func (*RegisteredModelPermissionLevel) Set ¶ added in v0.15.0
func (f *RegisteredModelPermissionLevel) Set(v string) error
Set raw string value and validate it against allowed values
func (*RegisteredModelPermissionLevel) String ¶ added in v0.15.0
func (f *RegisteredModelPermissionLevel) String() string
String representation for fmt.Print
func (*RegisteredModelPermissionLevel) Type ¶ added in v0.15.0
func (f *RegisteredModelPermissionLevel) Type() string
Type always returns RegisteredModelPermissionLevel to satisfy [pflag.Value] interface
func (*RegisteredModelPermissionLevel) Values ¶ added in v0.72.0
func (f *RegisteredModelPermissionLevel) Values() []RegisteredModelPermissionLevel
Values returns all possible values for RegisteredModelPermissionLevel.
There is no guarantee on the order of the values in the slice.
type RegisteredModelPermissions ¶ added in v0.15.0
type RegisteredModelPermissions struct {
// Wire name: 'access_control_list'
AccessControlList []RegisteredModelAccessControlResponse `json:"access_control_list,omitempty"`
// Wire name: 'object_id'
ObjectId string `json:"object_id,omitempty"`
// Wire name: 'object_type'
ObjectType string `json:"object_type,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RegisteredModelPermissions) MarshalJSON ¶ added in v0.23.0
func (st RegisteredModelPermissions) MarshalJSON() ([]byte, error)
func (*RegisteredModelPermissions) UnmarshalJSON ¶ added in v0.23.0
func (st *RegisteredModelPermissions) UnmarshalJSON(b []byte) error
type RegisteredModelPermissionsDescription ¶ added in v0.15.0
type RegisteredModelPermissionsDescription struct {
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Permission level
// Wire name: 'permission_level'
PermissionLevel RegisteredModelPermissionLevel `json:"permission_level,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RegisteredModelPermissionsDescription) MarshalJSON ¶ added in v0.23.0
func (st RegisteredModelPermissionsDescription) MarshalJSON() ([]byte, error)
func (*RegisteredModelPermissionsDescription) UnmarshalJSON ¶ added in v0.23.0
func (st *RegisteredModelPermissionsDescription) UnmarshalJSON(b []byte) error
type RegisteredModelPermissionsRequest ¶ added in v0.15.0
type RegisteredModelPermissionsRequest struct {
// Wire name: 'access_control_list'
AccessControlList []RegisteredModelAccessControlRequest `json:"access_control_list,omitempty"`
// The registered model for which to get or manage permissions.
RegisteredModelId string `json:"-" tf:"-"`
}
func (RegisteredModelPermissionsRequest) MarshalJSON ¶ added in v0.73.0
func (st RegisteredModelPermissionsRequest) MarshalJSON() ([]byte, error)
func (*RegisteredModelPermissionsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *RegisteredModelPermissionsRequest) UnmarshalJSON(b []byte) error
type RegistryWebhook ¶
type RegistryWebhook struct {
// Creation time of the object, as a Unix timestamp in milliseconds.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// User-specified description for the webhook.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Events that can trigger a registry webhook: * `MODEL_VERSION_CREATED`: A
// new model version was created for the associated model.
//
// * `MODEL_VERSION_TRANSITIONED_STAGE`: A model version’s stage was
// changed.
//
// * `TRANSITION_REQUEST_CREATED`: A user requested a model version’s
// stage be transitioned.
//
// * `COMMENT_CREATED`: A user wrote a comment on a registered model.
//
// * `REGISTERED_MODEL_CREATED`: A new registered model was created. This
// event type can only be specified for a registry-wide webhook, which can
// be created by not specifying a model name in the create request.
//
// * `MODEL_VERSION_TAG_SET`: A user set a tag on the model version.
//
// * `MODEL_VERSION_TRANSITIONED_TO_STAGING`: A model version was
// transitioned to staging.
//
// * `MODEL_VERSION_TRANSITIONED_TO_PRODUCTION`: A model version was
// transitioned to production.
//
// * `MODEL_VERSION_TRANSITIONED_TO_ARCHIVED`: A model version was archived.
//
// * `TRANSITION_REQUEST_TO_STAGING_CREATED`: A user requested a model
// version be transitioned to staging.
//
// * `TRANSITION_REQUEST_TO_PRODUCTION_CREATED`: A user requested a model
// version be transitioned to production.
//
// * `TRANSITION_REQUEST_TO_ARCHIVED_CREATED`: A user requested a model
// version be archived.
// Wire name: 'events'
Events []RegistryWebhookEvent `json:"events,omitempty"`
// Wire name: 'http_url_spec'
HttpUrlSpec *HttpUrlSpecWithoutSecret `json:"http_url_spec,omitempty"`
// Webhook ID
// Wire name: 'id'
Id string `json:"id,omitempty"`
// Wire name: 'job_spec'
JobSpec *JobSpecWithoutSecret `json:"job_spec,omitempty"`
// Time of the object at last update, as a Unix timestamp in milliseconds.
// Wire name: 'last_updated_timestamp'
LastUpdatedTimestamp int64 `json:"last_updated_timestamp,omitempty"`
// Name of the model whose events would trigger this webhook.
// Wire name: 'model_name'
ModelName string `json:"model_name,omitempty"`
// Enable or disable triggering the webhook, or put the webhook into test
// mode. The default is `ACTIVE`: * `ACTIVE`: Webhook is triggered when an
// associated event happens.
//
// * `DISABLED`: Webhook is not triggered.
//
// * `TEST_MODE`: Webhook can be triggered through the test endpoint, but is
// not triggered on a real event.
// Wire name: 'status'
Status RegistryWebhookStatus `json:"status,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RegistryWebhook) MarshalJSON ¶ added in v0.23.0
func (st RegistryWebhook) MarshalJSON() ([]byte, error)
func (*RegistryWebhook) UnmarshalJSON ¶ added in v0.23.0
func (st *RegistryWebhook) UnmarshalJSON(b []byte) error
type RegistryWebhookEvent ¶
type RegistryWebhookEvent string
const RegistryWebhookEventCommentCreated RegistryWebhookEvent = `COMMENT_CREATED`
const RegistryWebhookEventModelVersionCreated RegistryWebhookEvent = `MODEL_VERSION_CREATED`
const RegistryWebhookEventModelVersionTagSet RegistryWebhookEvent = `MODEL_VERSION_TAG_SET`
const RegistryWebhookEventModelVersionTransitionedStage RegistryWebhookEvent = `MODEL_VERSION_TRANSITIONED_STAGE`
const RegistryWebhookEventModelVersionTransitionedToArchived RegistryWebhookEvent = `MODEL_VERSION_TRANSITIONED_TO_ARCHIVED`
const RegistryWebhookEventModelVersionTransitionedToProduction RegistryWebhookEvent = `MODEL_VERSION_TRANSITIONED_TO_PRODUCTION`
const RegistryWebhookEventModelVersionTransitionedToStaging RegistryWebhookEvent = `MODEL_VERSION_TRANSITIONED_TO_STAGING`
const RegistryWebhookEventRegisteredModelCreated RegistryWebhookEvent = `REGISTERED_MODEL_CREATED`
const RegistryWebhookEventTransitionRequestCreated RegistryWebhookEvent = `TRANSITION_REQUEST_CREATED`
const RegistryWebhookEventTransitionRequestToArchivedCreated RegistryWebhookEvent = `TRANSITION_REQUEST_TO_ARCHIVED_CREATED`
const RegistryWebhookEventTransitionRequestToProductionCreated RegistryWebhookEvent = `TRANSITION_REQUEST_TO_PRODUCTION_CREATED`
const RegistryWebhookEventTransitionRequestToStagingCreated RegistryWebhookEvent = `TRANSITION_REQUEST_TO_STAGING_CREATED`
func (*RegistryWebhookEvent) Set ¶
func (f *RegistryWebhookEvent) Set(v string) error
Set raw string value and validate it against allowed values
func (*RegistryWebhookEvent) String ¶
func (f *RegistryWebhookEvent) String() string
String representation for fmt.Print
func (*RegistryWebhookEvent) Type ¶
func (f *RegistryWebhookEvent) Type() string
Type always returns RegistryWebhookEvent to satisfy [pflag.Value] interface
func (*RegistryWebhookEvent) Values ¶ added in v0.72.0
func (f *RegistryWebhookEvent) Values() []RegistryWebhookEvent
Values returns all possible values for RegistryWebhookEvent.
There is no guarantee on the order of the values in the slice.
type RegistryWebhookStatus ¶
type RegistryWebhookStatus string
Enable or disable triggering the webhook, or put the webhook into test mode. The default is `ACTIVE`: * `ACTIVE`: Webhook is triggered when an associated event happens.
* `DISABLED`: Webhook is not triggered.
* `TEST_MODE`: Webhook can be triggered through the test endpoint, but is not triggered on a real event.
const RegistryWebhookStatusActive RegistryWebhookStatus = `ACTIVE`
Webhook is triggered when an associated event happens.
const RegistryWebhookStatusDisabled RegistryWebhookStatus = `DISABLED`
Webhook is not triggered.
const RegistryWebhookStatusTestMode RegistryWebhookStatus = `TEST_MODE`
Webhook can be triggered through the test endpoint, but is not triggered on a real event.
func (*RegistryWebhookStatus) Set ¶
func (f *RegistryWebhookStatus) Set(v string) error
Set raw string value and validate it against allowed values
func (*RegistryWebhookStatus) String ¶
func (f *RegistryWebhookStatus) String() string
String representation for fmt.Print
func (*RegistryWebhookStatus) Type ¶
func (f *RegistryWebhookStatus) Type() string
Type always returns RegistryWebhookStatus to satisfy [pflag.Value] interface
func (*RegistryWebhookStatus) Values ¶ added in v0.72.0
func (f *RegistryWebhookStatus) Values() []RegistryWebhookStatus
Values returns all possible values for RegistryWebhookStatus.
There is no guarantee on the order of the values in the slice.
type RejectTransitionRequest ¶
type RejectTransitionRequest struct {
// User-provided comment on the action.
// Wire name: 'comment'
Comment string `json:"comment,omitempty"`
// Name of the model.
// Wire name: 'name'
Name string `json:"name"`
// Target stage of the transition. Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'stage'
Stage Stage `json:"stage"`
// Version of the model.
// Wire name: 'version'
Version string `json:"version"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RejectTransitionRequest) MarshalJSON ¶ added in v0.23.0
func (st RejectTransitionRequest) MarshalJSON() ([]byte, error)
func (*RejectTransitionRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *RejectTransitionRequest) UnmarshalJSON(b []byte) error
type RejectTransitionRequestResponse ¶
type RejectTransitionRequestResponse struct {
// Activity recorded for the action.
// Wire name: 'activity'
Activity *Activity `json:"activity,omitempty"`
}
func (RejectTransitionRequestResponse) MarshalJSON ¶ added in v0.73.0
func (st RejectTransitionRequestResponse) MarshalJSON() ([]byte, error)
func (*RejectTransitionRequestResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *RejectTransitionRequestResponse) UnmarshalJSON(b []byte) error
type RenameModelRequest ¶
type RenameModelRequest struct {
// Registered model unique name identifier.
// Wire name: 'name'
Name string `json:"name"`
// If provided, updates the name for this `registered_model`.
// Wire name: 'new_name'
NewName string `json:"new_name,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RenameModelRequest) MarshalJSON ¶ added in v0.23.0
func (st RenameModelRequest) MarshalJSON() ([]byte, error)
func (*RenameModelRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *RenameModelRequest) UnmarshalJSON(b []byte) error
type RenameModelResponse ¶
type RenameModelResponse struct {
// Wire name: 'registered_model'
RegisteredModel *Model `json:"registered_model,omitempty"`
}
func (RenameModelResponse) MarshalJSON ¶ added in v0.73.0
func (st RenameModelResponse) MarshalJSON() ([]byte, error)
func (*RenameModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *RenameModelResponse) UnmarshalJSON(b []byte) error
type RestoreExperiment ¶
type RestoreExperiment struct {
// ID of the associated experiment.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id"`
}
func (RestoreExperiment) MarshalJSON ¶ added in v0.73.0
func (st RestoreExperiment) MarshalJSON() ([]byte, error)
func (*RestoreExperiment) UnmarshalJSON ¶ added in v0.73.0
func (st *RestoreExperiment) UnmarshalJSON(b []byte) error
type RestoreExperimentResponse ¶ added in v0.34.0
type RestoreExperimentResponse struct {
}
func (RestoreExperimentResponse) MarshalJSON ¶ added in v0.73.0
func (st RestoreExperimentResponse) MarshalJSON() ([]byte, error)
func (*RestoreExperimentResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *RestoreExperimentResponse) UnmarshalJSON(b []byte) error
type RestoreRun ¶
type RestoreRun struct {
// ID of the run to restore.
// Wire name: 'run_id'
RunId string `json:"run_id"`
}
func (RestoreRun) MarshalJSON ¶ added in v0.73.0
func (st RestoreRun) MarshalJSON() ([]byte, error)
func (*RestoreRun) UnmarshalJSON ¶ added in v0.73.0
func (st *RestoreRun) UnmarshalJSON(b []byte) error
type RestoreRunResponse ¶ added in v0.34.0
type RestoreRunResponse struct {
}
func (RestoreRunResponse) MarshalJSON ¶ added in v0.73.0
func (st RestoreRunResponse) MarshalJSON() ([]byte, error)
func (*RestoreRunResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *RestoreRunResponse) UnmarshalJSON(b []byte) error
type RestoreRuns ¶ added in v0.17.0
type RestoreRuns struct {
// The ID of the experiment containing the runs to restore.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id"`
// An optional positive integer indicating the maximum number of runs to
// restore. The maximum allowed value for max_runs is 10000.
// Wire name: 'max_runs'
MaxRuns int `json:"max_runs,omitempty"`
// The minimum deletion timestamp in milliseconds since the UNIX epoch for
// restoring runs. Only runs deleted no earlier than this timestamp are
// restored.
// Wire name: 'min_timestamp_millis'
MinTimestampMillis int64 `json:"min_timestamp_millis"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RestoreRuns) MarshalJSON ¶ added in v0.23.0
func (st RestoreRuns) MarshalJSON() ([]byte, error)
func (*RestoreRuns) UnmarshalJSON ¶ added in v0.23.0
func (st *RestoreRuns) UnmarshalJSON(b []byte) error
type RestoreRunsResponse ¶ added in v0.17.0
type RestoreRunsResponse struct {
// The number of runs restored.
// Wire name: 'runs_restored'
RunsRestored int `json:"runs_restored,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (RestoreRunsResponse) MarshalJSON ¶ added in v0.23.0
func (st RestoreRunsResponse) MarshalJSON() ([]byte, error)
func (*RestoreRunsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *RestoreRunsResponse) UnmarshalJSON(b []byte) error
type Run ¶
type Run struct {
// Run data.
// Wire name: 'data'
Data *RunData `json:"data,omitempty"`
// Run metadata.
// Wire name: 'info'
Info *RunInfo `json:"info,omitempty"`
// Run inputs.
// Wire name: 'inputs'
Inputs *RunInputs `json:"inputs,omitempty"`
}
A single run.
func (Run) MarshalJSON ¶ added in v0.73.0
func (*Run) UnmarshalJSON ¶ added in v0.73.0
type RunData ¶
type RunData struct {
// Run metrics.
// Wire name: 'metrics'
Metrics []Metric `json:"metrics,omitempty"`
// Run parameters.
// Wire name: 'params'
Params []Param `json:"params,omitempty"`
// Additional metadata key-value pairs.
// Wire name: 'tags'
Tags []RunTag `json:"tags,omitempty"`
}
Run data (metrics, params, and tags).
func (RunData) MarshalJSON ¶ added in v0.73.0
func (*RunData) UnmarshalJSON ¶ added in v0.73.0
type RunInfo ¶
type RunInfo struct {
// URI of the directory where artifacts should be uploaded. This can be a
// local path (starting with "/"), or a distributed file system (DFS) path,
// like “s3://bucket/directory“ or “dbfs:/my/directory“. If not set, the
// local “./mlruns“ directory is chosen.
// Wire name: 'artifact_uri'
ArtifactUri string `json:"artifact_uri,omitempty"`
// Unix timestamp of when the run ended in milliseconds.
// Wire name: 'end_time'
EndTime int64 `json:"end_time,omitempty"`
// The experiment ID.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id,omitempty"`
// Current life cycle stage of the experiment : OneOf("active", "deleted")
// Wire name: 'lifecycle_stage'
LifecycleStage string `json:"lifecycle_stage,omitempty"`
// Unique identifier for the run.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// The name of the run.
// Wire name: 'run_name'
RunName string `json:"run_name,omitempty"`
// [Deprecated, use run_id instead] Unique identifier for the run. This
// field will be removed in a future MLflow version.
// Wire name: 'run_uuid'
RunUuid string `json:"run_uuid,omitempty"`
// Unix timestamp of when the run started in milliseconds.
// Wire name: 'start_time'
StartTime int64 `json:"start_time,omitempty"`
// Current status of the run.
// Wire name: 'status'
Status RunInfoStatus `json:"status,omitempty"`
// User who initiated the run. This field is deprecated as of MLflow 1.0,
// and will be removed in a future MLflow release. Use 'mlflow.user' tag
// instead.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Metadata of a single run.
func (RunInfo) MarshalJSON ¶ added in v0.23.0
func (*RunInfo) UnmarshalJSON ¶ added in v0.23.0
type RunInfoStatus ¶
type RunInfoStatus string
Status of a run.
const RunInfoStatusFailed RunInfoStatus = `FAILED`
const RunInfoStatusFinished RunInfoStatus = `FINISHED`
const RunInfoStatusKilled RunInfoStatus = `KILLED`
const RunInfoStatusRunning RunInfoStatus = `RUNNING`
const RunInfoStatusScheduled RunInfoStatus = `SCHEDULED`
func (*RunInfoStatus) Set ¶
func (f *RunInfoStatus) Set(v string) error
Set raw string value and validate it against allowed values
func (*RunInfoStatus) String ¶
func (f *RunInfoStatus) String() string
String representation for fmt.Print
func (*RunInfoStatus) Type ¶
func (f *RunInfoStatus) Type() string
Type always returns RunInfoStatus to satisfy [pflag.Value] interface
func (*RunInfoStatus) Values ¶ added in v0.72.0
func (f *RunInfoStatus) Values() []RunInfoStatus
Values returns all possible values for RunInfoStatus.
There is no guarantee on the order of the values in the slice.
type RunInputs ¶ added in v0.9.0
type RunInputs struct {
// Run metrics.
// Wire name: 'dataset_inputs'
DatasetInputs []DatasetInput `json:"dataset_inputs,omitempty"`
// Model inputs to the Run.
// Wire name: 'model_inputs'
ModelInputs []ModelInput `json:"model_inputs,omitempty"`
}
Run inputs.
func (RunInputs) MarshalJSON ¶ added in v0.73.0
func (*RunInputs) UnmarshalJSON ¶ added in v0.73.0
type RunTag ¶
type RunTag struct {
// The tag key.
// Wire name: 'key'
Key string `json:"key,omitempty"`
// The tag value.
// Wire name: 'value'
Value string `json:"value,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Tag for a run.
func (RunTag) MarshalJSON ¶ added in v0.23.0
func (*RunTag) UnmarshalJSON ¶ added in v0.23.0
type SearchExperiments ¶
type SearchExperiments struct {
// String representing a SQL filter condition (e.g. "name ILIKE
// 'my-experiment%'")
// Wire name: 'filter'
Filter string `json:"filter,omitempty"`
// Maximum number of experiments desired. Max threshold is 3000.
// Wire name: 'max_results'
MaxResults int64 `json:"max_results,omitempty"`
// List of columns for ordering search results, which can include experiment
// name and last updated timestamp with an optional "DESC" or "ASC"
// annotation, where "ASC" is the default. Tiebreaks are done by experiment
// id DESC.
// Wire name: 'order_by'
OrderBy []string `json:"order_by,omitempty"`
// Token indicating the page of experiments to fetch
// Wire name: 'page_token'
PageToken string `json:"page_token,omitempty"`
// Qualifier for type of experiments to be returned. If unspecified, return
// only active experiments.
// Wire name: 'view_type'
ViewType ViewType `json:"view_type,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchExperiments) MarshalJSON ¶ added in v0.23.0
func (st SearchExperiments) MarshalJSON() ([]byte, error)
func (*SearchExperiments) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchExperiments) UnmarshalJSON(b []byte) error
type SearchExperimentsResponse ¶
type SearchExperimentsResponse struct {
// Experiments that match the search criteria
// Wire name: 'experiments'
Experiments []Experiment `json:"experiments,omitempty"`
// Token that can be used to retrieve the next page of experiments. An empty
// token means that no more experiments are available for retrieval.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchExperimentsResponse) MarshalJSON ¶ added in v0.23.0
func (st SearchExperimentsResponse) MarshalJSON() ([]byte, error)
func (*SearchExperimentsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchExperimentsResponse) UnmarshalJSON(b []byte) error
type SearchLoggedModelsDataset ¶ added in v0.70.0
type SearchLoggedModelsDataset struct {
// The digest of the dataset.
// Wire name: 'dataset_digest'
DatasetDigest string `json:"dataset_digest,omitempty"`
// The name of the dataset.
// Wire name: 'dataset_name'
DatasetName string `json:"dataset_name"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchLoggedModelsDataset) MarshalJSON ¶ added in v0.70.0
func (st SearchLoggedModelsDataset) MarshalJSON() ([]byte, error)
func (*SearchLoggedModelsDataset) UnmarshalJSON ¶ added in v0.70.0
func (st *SearchLoggedModelsDataset) UnmarshalJSON(b []byte) error
type SearchLoggedModelsOrderBy ¶ added in v0.70.0
type SearchLoggedModelsOrderBy struct {
// Whether the search results order is ascending or not.
// Wire name: 'ascending'
Ascending bool `json:"ascending,omitempty"`
// If “field_name“ refers to a metric, this field specifies the digest of
// the dataset associated with the metric. Only metrics associated with the
// specified dataset name and digest will be considered for ordering. This
// field may only be set if “dataset_name“ is also set.
// Wire name: 'dataset_digest'
DatasetDigest string `json:"dataset_digest,omitempty"`
// If “field_name“ refers to a metric, this field specifies the name of
// the dataset associated with the metric. Only metrics associated with the
// specified dataset name will be considered for ordering. This field may
// only be set if “field_name“ refers to a metric.
// Wire name: 'dataset_name'
DatasetName string `json:"dataset_name,omitempty"`
// The name of the field to order by, e.g. "metrics.accuracy".
// Wire name: 'field_name'
FieldName string `json:"field_name"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchLoggedModelsOrderBy) MarshalJSON ¶ added in v0.70.0
func (st SearchLoggedModelsOrderBy) MarshalJSON() ([]byte, error)
func (*SearchLoggedModelsOrderBy) UnmarshalJSON ¶ added in v0.70.0
func (st *SearchLoggedModelsOrderBy) UnmarshalJSON(b []byte) error
type SearchLoggedModelsRequest ¶ added in v0.70.0
type SearchLoggedModelsRequest struct {
// List of datasets on which to apply the metrics filter clauses. For
// example, a filter with `metrics.accuracy > 0.9` and dataset info with
// name "test_dataset" means we will return all logged models with accuracy
// > 0.9 on the test_dataset. Metric values from ANY dataset matching the
// criteria are considered. If no datasets are specified, then metrics
// across all datasets are considered in the filter.
// Wire name: 'datasets'
Datasets []SearchLoggedModelsDataset `json:"datasets,omitempty"`
// The IDs of the experiments in which to search for logged models.
// Wire name: 'experiment_ids'
ExperimentIds []string `json:"experiment_ids,omitempty"`
// A filter expression over logged model info and data that allows returning
// a subset of logged models. The syntax is a subset of SQL that supports
// AND'ing together binary operations.
//
// Example: “params.alpha < 0.3 AND metrics.accuracy > 0.9“.
// Wire name: 'filter'
Filter string `json:"filter,omitempty"`
// The maximum number of Logged Models to return. The maximum limit is 50.
// Wire name: 'max_results'
MaxResults int `json:"max_results,omitempty"`
// The list of columns for ordering the results, with additional fields for
// sorting criteria.
// Wire name: 'order_by'
OrderBy []SearchLoggedModelsOrderBy `json:"order_by,omitempty"`
// The token indicating the page of logged models to fetch.
// Wire name: 'page_token'
PageToken string `json:"page_token,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchLoggedModelsRequest) MarshalJSON ¶ added in v0.70.0
func (st SearchLoggedModelsRequest) MarshalJSON() ([]byte, error)
func (*SearchLoggedModelsRequest) UnmarshalJSON ¶ added in v0.70.0
func (st *SearchLoggedModelsRequest) UnmarshalJSON(b []byte) error
type SearchLoggedModelsResponse ¶ added in v0.70.0
type SearchLoggedModelsResponse struct {
// Logged models that match the search criteria.
// Wire name: 'models'
Models []LoggedModel `json:"models,omitempty"`
// The token that can be used to retrieve the next page of logged models.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchLoggedModelsResponse) MarshalJSON ¶ added in v0.70.0
func (st SearchLoggedModelsResponse) MarshalJSON() ([]byte, error)
func (*SearchLoggedModelsResponse) UnmarshalJSON ¶ added in v0.70.0
func (st *SearchLoggedModelsResponse) UnmarshalJSON(b []byte) error
type SearchModelVersionsRequest ¶
type SearchModelVersionsRequest struct {
// String filter condition, like "name='my-model-name'". Must be a single
// boolean condition, with string values wrapped in single quotes.
Filter string `json:"-" tf:"-"`
// Maximum number of models desired. Max threshold is 10K.
MaxResults int `json:"-" tf:"-"`
// List of columns to be ordered by including model name, version, stage
// with an optional "DESC" or "ASC" annotation, where "ASC" is the default.
// Tiebreaks are done by latest stage transition timestamp, followed by name
// ASC, followed by version DESC.
OrderBy []string `json:"-" tf:"-"`
// Pagination token to go to next page based on previous search query.
PageToken string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
Searches model versions
func (SearchModelVersionsRequest) MarshalJSON ¶ added in v0.23.0
func (st SearchModelVersionsRequest) MarshalJSON() ([]byte, error)
func (*SearchModelVersionsRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchModelVersionsRequest) UnmarshalJSON(b []byte) error
type SearchModelVersionsResponse ¶
type SearchModelVersionsResponse struct {
// Models that match the search criteria
// Wire name: 'model_versions'
ModelVersions []ModelVersion `json:"model_versions,omitempty"`
// Pagination token to request next page of models for the same search
// query.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchModelVersionsResponse) MarshalJSON ¶ added in v0.23.0
func (st SearchModelVersionsResponse) MarshalJSON() ([]byte, error)
func (*SearchModelVersionsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchModelVersionsResponse) UnmarshalJSON(b []byte) error
type SearchModelsRequest ¶
type SearchModelsRequest struct {
// String filter condition, like "name LIKE 'my-model-name'". Interpreted in
// the backend automatically as "name LIKE '%my-model-name%'". Single
// boolean condition, with string values wrapped in single quotes.
Filter string `json:"-" tf:"-"`
// Maximum number of models desired. Default is 100. Max threshold is 1000.
MaxResults int `json:"-" tf:"-"`
// List of columns for ordering search results, which can include model name
// and last updated timestamp with an optional "DESC" or "ASC" annotation,
// where "ASC" is the default. Tiebreaks are done by model name ASC.
OrderBy []string `json:"-" tf:"-"`
// Pagination token to go to the next page based on a previous search query.
PageToken string `json:"-" tf:"-"`
ForceSendFields []string `json:"-" tf:"-"`
}
Search models
func (SearchModelsRequest) MarshalJSON ¶ added in v0.23.0
func (st SearchModelsRequest) MarshalJSON() ([]byte, error)
func (*SearchModelsRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchModelsRequest) UnmarshalJSON(b []byte) error
type SearchModelsResponse ¶
type SearchModelsResponse struct {
// Pagination token to request the next page of models.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
// Registered Models that match the search criteria.
// Wire name: 'registered_models'
RegisteredModels []Model `json:"registered_models,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchModelsResponse) MarshalJSON ¶ added in v0.23.0
func (st SearchModelsResponse) MarshalJSON() ([]byte, error)
func (*SearchModelsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchModelsResponse) UnmarshalJSON(b []byte) error
type SearchRuns ¶
type SearchRuns struct {
// List of experiment IDs to search over.
// Wire name: 'experiment_ids'
ExperimentIds []string `json:"experiment_ids,omitempty"`
// A filter expression over params, metrics, and tags, that allows returning
// a subset of runs. The syntax is a subset of SQL that supports ANDing
// together binary operations between a param, metric, or tag and a
// constant.
//
// Example: `metrics.rmse < 1 and params.model_class = 'LogisticRegression'`
//
// You can select columns with special characters (hyphen, space, period,
// etc.) by using double quotes: `metrics."model class" = 'LinearRegression'
// and tags."user-name" = 'Tomas'`
//
// Supported operators are `=`, `!=`, `>`, `>=`, `<`, and `<=`.
// Wire name: 'filter'
Filter string `json:"filter,omitempty"`
// Maximum number of runs desired. Max threshold is 50000
// Wire name: 'max_results'
MaxResults int `json:"max_results,omitempty"`
// List of columns to be ordered by, including attributes, params, metrics,
// and tags with an optional `"DESC"` or `"ASC"` annotation, where `"ASC"`
// is the default. Example: `["params.input DESC", "metrics.alpha ASC",
// "metrics.rmse"]`. Tiebreaks are done by start_time `DESC` followed by
// `run_id` for runs with the same start time (and this is the default
// ordering criterion if order_by is not provided).
// Wire name: 'order_by'
OrderBy []string `json:"order_by,omitempty"`
// Token for the current page of runs.
// Wire name: 'page_token'
PageToken string `json:"page_token,omitempty"`
// Whether to display only active, only deleted, or all runs. Defaults to
// only active runs.
// Wire name: 'run_view_type'
RunViewType ViewType `json:"run_view_type,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchRuns) MarshalJSON ¶ added in v0.23.0
func (st SearchRuns) MarshalJSON() ([]byte, error)
func (*SearchRuns) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchRuns) UnmarshalJSON(b []byte) error
type SearchRunsResponse ¶
type SearchRunsResponse struct {
// Token for the next page of runs.
// Wire name: 'next_page_token'
NextPageToken string `json:"next_page_token,omitempty"`
// Runs that match the search criteria.
// Wire name: 'runs'
Runs []Run `json:"runs,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SearchRunsResponse) MarshalJSON ¶ added in v0.23.0
func (st SearchRunsResponse) MarshalJSON() ([]byte, error)
func (*SearchRunsResponse) UnmarshalJSON ¶ added in v0.23.0
func (st *SearchRunsResponse) UnmarshalJSON(b []byte) error
type SetExperimentTag ¶
type SetExperimentTag struct {
// ID of the experiment under which to log the tag. Must be provided.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id"`
// Name of the tag. Keys up to 250 bytes in size are supported.
// Wire name: 'key'
Key string `json:"key"`
// String value of the tag being logged. Values up to 64KB in size are
// supported.
// Wire name: 'value'
Value string `json:"value"`
}
func (SetExperimentTag) MarshalJSON ¶ added in v0.73.0
func (st SetExperimentTag) MarshalJSON() ([]byte, error)
func (*SetExperimentTag) UnmarshalJSON ¶ added in v0.73.0
func (st *SetExperimentTag) UnmarshalJSON(b []byte) error
type SetExperimentTagResponse ¶ added in v0.34.0
type SetExperimentTagResponse struct {
}
func (SetExperimentTagResponse) MarshalJSON ¶ added in v0.73.0
func (st SetExperimentTagResponse) MarshalJSON() ([]byte, error)
func (*SetExperimentTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *SetExperimentTagResponse) UnmarshalJSON(b []byte) error
type SetLoggedModelTagsRequest ¶ added in v0.70.0
type SetLoggedModelTagsRequest struct {
// The ID of the logged model to set the tags on.
ModelId string `json:"-" tf:"-"`
// The tags to set on the logged model.
// Wire name: 'tags'
Tags []LoggedModelTag `json:"tags,omitempty"`
}
func (SetLoggedModelTagsRequest) MarshalJSON ¶ added in v0.73.0
func (st SetLoggedModelTagsRequest) MarshalJSON() ([]byte, error)
func (*SetLoggedModelTagsRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *SetLoggedModelTagsRequest) UnmarshalJSON(b []byte) error
type SetLoggedModelTagsResponse ¶ added in v0.70.0
type SetLoggedModelTagsResponse struct {
}
func (SetLoggedModelTagsResponse) MarshalJSON ¶ added in v0.73.0
func (st SetLoggedModelTagsResponse) MarshalJSON() ([]byte, error)
func (*SetLoggedModelTagsResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *SetLoggedModelTagsResponse) UnmarshalJSON(b []byte) error
type SetModelTagRequest ¶
type SetModelTagRequest struct {
// Name of the tag. Maximum size depends on storage backend. If a tag with
// this name already exists, its preexisting value will be replaced by the
// specified `value`. All storage backends are guaranteed to support key
// values up to 250 bytes in size.
// Wire name: 'key'
Key string `json:"key"`
// Unique name of the model.
// Wire name: 'name'
Name string `json:"name"`
// String value of the tag being logged. Maximum size depends on storage
// backend. All storage backends are guaranteed to support key values up to
// 5000 bytes in size.
// Wire name: 'value'
Value string `json:"value"`
}
func (SetModelTagRequest) MarshalJSON ¶ added in v0.73.0
func (st SetModelTagRequest) MarshalJSON() ([]byte, error)
func (*SetModelTagRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *SetModelTagRequest) UnmarshalJSON(b []byte) error
type SetModelTagResponse ¶ added in v0.34.0
type SetModelTagResponse struct {
}
func (SetModelTagResponse) MarshalJSON ¶ added in v0.73.0
func (st SetModelTagResponse) MarshalJSON() ([]byte, error)
func (*SetModelTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *SetModelTagResponse) UnmarshalJSON(b []byte) error
type SetModelVersionTagRequest ¶
type SetModelVersionTagRequest struct {
// Name of the tag. Maximum size depends on storage backend. If a tag with
// this name already exists, its preexisting value will be replaced by the
// specified `value`. All storage backends are guaranteed to support key
// values up to 250 bytes in size.
// Wire name: 'key'
Key string `json:"key"`
// Unique name of the model.
// Wire name: 'name'
Name string `json:"name"`
// String value of the tag being logged. Maximum size depends on storage
// backend. All storage backends are guaranteed to support key values up to
// 5000 bytes in size.
// Wire name: 'value'
Value string `json:"value"`
// Model version number.
// Wire name: 'version'
Version string `json:"version"`
}
func (SetModelVersionTagRequest) MarshalJSON ¶ added in v0.73.0
func (st SetModelVersionTagRequest) MarshalJSON() ([]byte, error)
func (*SetModelVersionTagRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *SetModelVersionTagRequest) UnmarshalJSON(b []byte) error
type SetModelVersionTagResponse ¶ added in v0.34.0
type SetModelVersionTagResponse struct {
}
func (SetModelVersionTagResponse) MarshalJSON ¶ added in v0.73.0
func (st SetModelVersionTagResponse) MarshalJSON() ([]byte, error)
func (*SetModelVersionTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *SetModelVersionTagResponse) UnmarshalJSON(b []byte) error
type SetTag ¶
type SetTag struct {
// Name of the tag. Keys up to 250 bytes in size are supported.
// Wire name: 'key'
Key string `json:"key"`
// ID of the run under which to log the tag. Must be provided.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// [Deprecated, use `run_id` instead] ID of the run under which to log the
// tag. This field will be removed in a future MLflow version.
// Wire name: 'run_uuid'
RunUuid string `json:"run_uuid,omitempty"`
// String value of the tag being logged. Values up to 64KB in size are
// supported.
// Wire name: 'value'
Value string `json:"value"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (SetTag) MarshalJSON ¶ added in v0.23.0
func (*SetTag) UnmarshalJSON ¶ added in v0.23.0
type SetTagResponse ¶ added in v0.34.0
type SetTagResponse struct {
}
func (SetTagResponse) MarshalJSON ¶ added in v0.73.0
func (st SetTagResponse) MarshalJSON() ([]byte, error)
func (*SetTagResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *SetTagResponse) UnmarshalJSON(b []byte) error
type Stage ¶
type Stage string
Stage of the model version. Valid values are:
* `None`: The initial stage of a model version.
* `Staging`: Staging or pre-production stage.
* `Production`: Production stage.
* `Archived`: Archived stage.
const StageArchived Stage = `Archived`
Archived stage.
const StageNone Stage = `None`
The initial stage of a model version.
const StageProduction Stage = `Production`
Production stage.
const StageStaging Stage = `Staging`
Staging or pre-production stage.
type Status ¶
type Status string
The status of the model version. Valid values are: * `PENDING_REGISTRATION`: Request to register a new model version is pending as server performs background tasks.
* `FAILED_REGISTRATION`: Request to register a new model version has failed.
* `READY`: Model version is ready for use.
const StatusFailedRegistration Status = `FAILED_REGISTRATION`
Request to register a new model version has failed.
const StatusPendingRegistration Status = `PENDING_REGISTRATION`
Request to register a new model version is pending as server performs background tasks.
const StatusReady Status = `READY`
Model version is ready for use.
type TestRegistryWebhook ¶
type TestRegistryWebhook struct {
// Body of the response from the webhook URL
// Wire name: 'body'
Body string `json:"body,omitempty"`
// Status code returned by the webhook URL
// Wire name: 'status_code'
StatusCode int `json:"status_code,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Test webhook response object.
func (TestRegistryWebhook) MarshalJSON ¶ added in v0.23.0
func (st TestRegistryWebhook) MarshalJSON() ([]byte, error)
func (*TestRegistryWebhook) UnmarshalJSON ¶ added in v0.23.0
func (st *TestRegistryWebhook) UnmarshalJSON(b []byte) error
type TestRegistryWebhookRequest ¶
type TestRegistryWebhookRequest struct {
// If `event` is specified, the test trigger uses the specified event. If
// `event` is not specified, the test trigger uses a randomly chosen event
// associated with the webhook.
// Wire name: 'event'
Event RegistryWebhookEvent `json:"event,omitempty"`
// Webhook ID
// Wire name: 'id'
Id string `json:"id"`
}
func (TestRegistryWebhookRequest) MarshalJSON ¶ added in v0.73.0
func (st TestRegistryWebhookRequest) MarshalJSON() ([]byte, error)
func (*TestRegistryWebhookRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *TestRegistryWebhookRequest) UnmarshalJSON(b []byte) error
type TestRegistryWebhookResponse ¶
type TestRegistryWebhookResponse struct {
// Test webhook response object.
// Wire name: 'webhook'
Webhook *TestRegistryWebhook `json:"webhook,omitempty"`
}
func (TestRegistryWebhookResponse) MarshalJSON ¶ added in v0.73.0
func (st TestRegistryWebhookResponse) MarshalJSON() ([]byte, error)
func (*TestRegistryWebhookResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *TestRegistryWebhookResponse) UnmarshalJSON(b []byte) error
type TransitionModelVersionStageDatabricks ¶
type TransitionModelVersionStageDatabricks struct {
// Specifies whether to archive all current model versions in the target
// stage.
// Wire name: 'archive_existing_versions'
ArchiveExistingVersions bool `json:"archive_existing_versions"`
// User-provided comment on the action.
// Wire name: 'comment'
Comment string `json:"comment,omitempty"`
// Name of the model.
// Wire name: 'name'
Name string `json:"name"`
// Target stage of the transition. Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'stage'
Stage Stage `json:"stage"`
// Version of the model.
// Wire name: 'version'
Version string `json:"version"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (TransitionModelVersionStageDatabricks) MarshalJSON ¶ added in v0.23.0
func (st TransitionModelVersionStageDatabricks) MarshalJSON() ([]byte, error)
func (*TransitionModelVersionStageDatabricks) UnmarshalJSON ¶ added in v0.23.0
func (st *TransitionModelVersionStageDatabricks) UnmarshalJSON(b []byte) error
type TransitionRequest ¶
type TransitionRequest struct {
// Array of actions on the activity allowed for the current viewer.
// Wire name: 'available_actions'
AvailableActions []ActivityAction `json:"available_actions,omitempty"`
// User-provided comment associated with the transition request.
// Wire name: 'comment'
Comment string `json:"comment,omitempty"`
// Creation time of the object, as a Unix timestamp in milliseconds.
// Wire name: 'creation_timestamp'
CreationTimestamp int64 `json:"creation_timestamp,omitempty"`
// Target stage of the transition (if the activity is stage transition
// related). Valid values are:
//
// * `None`: The initial stage of a model version.
//
// * `Staging`: Staging or pre-production stage.
//
// * `Production`: Production stage.
//
// * `Archived`: Archived stage.
// Wire name: 'to_stage'
ToStage Stage `json:"to_stage,omitempty"`
// The username of the user that created the object.
// Wire name: 'user_id'
UserId string `json:"user_id,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
Transition request details.
func (TransitionRequest) MarshalJSON ¶ added in v0.23.0
func (st TransitionRequest) MarshalJSON() ([]byte, error)
func (*TransitionRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *TransitionRequest) UnmarshalJSON(b []byte) error
type TransitionStageResponse ¶
type TransitionStageResponse struct {
// Wire name: 'model_version'
ModelVersion *ModelVersionDatabricks `json:"model_version,omitempty"`
}
func (TransitionStageResponse) MarshalJSON ¶ added in v0.73.0
func (st TransitionStageResponse) MarshalJSON() ([]byte, error)
func (*TransitionStageResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *TransitionStageResponse) UnmarshalJSON(b []byte) error
type UpdateComment ¶
type UpdateComment struct {
// User-provided comment on the action.
// Wire name: 'comment'
Comment string `json:"comment"`
// Unique identifier of an activity
// Wire name: 'id'
Id string `json:"id"`
}
func (UpdateComment) MarshalJSON ¶ added in v0.73.0
func (st UpdateComment) MarshalJSON() ([]byte, error)
func (*UpdateComment) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateComment) UnmarshalJSON(b []byte) error
type UpdateCommentResponse ¶
type UpdateCommentResponse struct {
// Comment details.
// Wire name: 'comment'
Comment *CommentObject `json:"comment,omitempty"`
}
func (UpdateCommentResponse) MarshalJSON ¶ added in v0.73.0
func (st UpdateCommentResponse) MarshalJSON() ([]byte, error)
func (*UpdateCommentResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateCommentResponse) UnmarshalJSON(b []byte) error
type UpdateExperiment ¶
type UpdateExperiment struct {
// ID of the associated experiment.
// Wire name: 'experiment_id'
ExperimentId string `json:"experiment_id"`
// If provided, the experiment's name is changed to the new name. The new
// name must be unique.
// Wire name: 'new_name'
NewName string `json:"new_name,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (UpdateExperiment) MarshalJSON ¶ added in v0.23.0
func (st UpdateExperiment) MarshalJSON() ([]byte, error)
func (*UpdateExperiment) UnmarshalJSON ¶ added in v0.23.0
func (st *UpdateExperiment) UnmarshalJSON(b []byte) error
type UpdateExperimentResponse ¶ added in v0.34.0
type UpdateExperimentResponse struct {
}
func (UpdateExperimentResponse) MarshalJSON ¶ added in v0.73.0
func (st UpdateExperimentResponse) MarshalJSON() ([]byte, error)
func (*UpdateExperimentResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateExperimentResponse) UnmarshalJSON(b []byte) error
type UpdateModelRequest ¶
type UpdateModelRequest struct {
// If provided, updates the description for this `registered_model`.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Registered model unique name identifier.
// Wire name: 'name'
Name string `json:"name"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (UpdateModelRequest) MarshalJSON ¶ added in v0.23.0
func (st UpdateModelRequest) MarshalJSON() ([]byte, error)
func (*UpdateModelRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *UpdateModelRequest) UnmarshalJSON(b []byte) error
type UpdateModelResponse ¶ added in v0.34.0
type UpdateModelResponse struct {
}
func (UpdateModelResponse) MarshalJSON ¶ added in v0.73.0
func (st UpdateModelResponse) MarshalJSON() ([]byte, error)
func (*UpdateModelResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateModelResponse) UnmarshalJSON(b []byte) error
type UpdateModelVersionRequest ¶
type UpdateModelVersionRequest struct {
// If provided, updates the description for this `registered_model`.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Name of the registered model
// Wire name: 'name'
Name string `json:"name"`
// Model version number
// Wire name: 'version'
Version string `json:"version"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (UpdateModelVersionRequest) MarshalJSON ¶ added in v0.23.0
func (st UpdateModelVersionRequest) MarshalJSON() ([]byte, error)
func (*UpdateModelVersionRequest) UnmarshalJSON ¶ added in v0.23.0
func (st *UpdateModelVersionRequest) UnmarshalJSON(b []byte) error
type UpdateModelVersionResponse ¶ added in v0.34.0
type UpdateModelVersionResponse struct {
}
func (UpdateModelVersionResponse) MarshalJSON ¶ added in v0.73.0
func (st UpdateModelVersionResponse) MarshalJSON() ([]byte, error)
func (*UpdateModelVersionResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateModelVersionResponse) UnmarshalJSON(b []byte) error
type UpdateOnlineStoreRequest ¶ added in v0.73.0
type UpdateOnlineStoreRequest struct {
// The name of the online store. This is the unique identifier for the
// online store.
Name string `json:"-" tf:"-"`
// An OnlineStore is a logical database instance that stores and serves
// features online.
// Wire name: 'online_store'
OnlineStore OnlineStore `json:"online_store"`
// The list of fields to update.
UpdateMask string `json:"-" tf:"-"`
}
Update an Online Feature Store
func (UpdateOnlineStoreRequest) MarshalJSON ¶ added in v0.73.0
func (st UpdateOnlineStoreRequest) MarshalJSON() ([]byte, error)
func (*UpdateOnlineStoreRequest) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateOnlineStoreRequest) UnmarshalJSON(b []byte) error
type UpdateRegistryWebhook ¶
type UpdateRegistryWebhook struct {
// User-specified description for the webhook.
// Wire name: 'description'
Description string `json:"description,omitempty"`
// Events that can trigger a registry webhook: * `MODEL_VERSION_CREATED`: A
// new model version was created for the associated model.
//
// * `MODEL_VERSION_TRANSITIONED_STAGE`: A model version’s stage was
// changed.
//
// * `TRANSITION_REQUEST_CREATED`: A user requested a model version’s
// stage be transitioned.
//
// * `COMMENT_CREATED`: A user wrote a comment on a registered model.
//
// * `REGISTERED_MODEL_CREATED`: A new registered model was created. This
// event type can only be specified for a registry-wide webhook, which can
// be created by not specifying a model name in the create request.
//
// * `MODEL_VERSION_TAG_SET`: A user set a tag on the model version.
//
// * `MODEL_VERSION_TRANSITIONED_TO_STAGING`: A model version was
// transitioned to staging.
//
// * `MODEL_VERSION_TRANSITIONED_TO_PRODUCTION`: A model version was
// transitioned to production.
//
// * `MODEL_VERSION_TRANSITIONED_TO_ARCHIVED`: A model version was archived.
//
// * `TRANSITION_REQUEST_TO_STAGING_CREATED`: A user requested a model
// version be transitioned to staging.
//
// * `TRANSITION_REQUEST_TO_PRODUCTION_CREATED`: A user requested a model
// version be transitioned to production.
//
// * `TRANSITION_REQUEST_TO_ARCHIVED_CREATED`: A user requested a model
// version be archived.
// Wire name: 'events'
Events []RegistryWebhookEvent `json:"events,omitempty"`
// Wire name: 'http_url_spec'
HttpUrlSpec *HttpUrlSpec `json:"http_url_spec,omitempty"`
// Webhook ID
// Wire name: 'id'
Id string `json:"id"`
// Wire name: 'job_spec'
JobSpec *JobSpec `json:"job_spec,omitempty"`
// Enable or disable triggering the webhook, or put the webhook into test
// mode. The default is `ACTIVE`: * `ACTIVE`: Webhook is triggered when an
// associated event happens.
//
// * `DISABLED`: Webhook is not triggered.
//
// * `TEST_MODE`: Webhook can be triggered through the test endpoint, but is
// not triggered on a real event.
// Wire name: 'status'
Status RegistryWebhookStatus `json:"status,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (UpdateRegistryWebhook) MarshalJSON ¶ added in v0.23.0
func (st UpdateRegistryWebhook) MarshalJSON() ([]byte, error)
func (*UpdateRegistryWebhook) UnmarshalJSON ¶ added in v0.23.0
func (st *UpdateRegistryWebhook) UnmarshalJSON(b []byte) error
type UpdateRun ¶
type UpdateRun struct {
// Unix timestamp in milliseconds of when the run ended.
// Wire name: 'end_time'
EndTime int64 `json:"end_time,omitempty"`
// ID of the run to update. Must be provided.
// Wire name: 'run_id'
RunId string `json:"run_id,omitempty"`
// Updated name of the run.
// Wire name: 'run_name'
RunName string `json:"run_name,omitempty"`
// [Deprecated, use `run_id` instead] ID of the run to update. This field
// will be removed in a future MLflow version.
// Wire name: 'run_uuid'
RunUuid string `json:"run_uuid,omitempty"`
// Updated status of the run.
// Wire name: 'status'
Status UpdateRunStatus `json:"status,omitempty"`
ForceSendFields []string `json:"-" tf:"-"`
}
func (UpdateRun) MarshalJSON ¶ added in v0.23.0
func (*UpdateRun) UnmarshalJSON ¶ added in v0.23.0
type UpdateRunResponse ¶
type UpdateRunResponse struct {
// Updated metadata of the run.
// Wire name: 'run_info'
RunInfo *RunInfo `json:"run_info,omitempty"`
}
func (UpdateRunResponse) MarshalJSON ¶ added in v0.73.0
func (st UpdateRunResponse) MarshalJSON() ([]byte, error)
func (*UpdateRunResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateRunResponse) UnmarshalJSON(b []byte) error
type UpdateRunStatus ¶
type UpdateRunStatus string
Status of a run.
const UpdateRunStatusFailed UpdateRunStatus = `FAILED`
const UpdateRunStatusFinished UpdateRunStatus = `FINISHED`
const UpdateRunStatusKilled UpdateRunStatus = `KILLED`
const UpdateRunStatusRunning UpdateRunStatus = `RUNNING`
const UpdateRunStatusScheduled UpdateRunStatus = `SCHEDULED`
func (*UpdateRunStatus) Set ¶
func (f *UpdateRunStatus) Set(v string) error
Set raw string value and validate it against allowed values
func (*UpdateRunStatus) String ¶
func (f *UpdateRunStatus) String() string
String representation for fmt.Print
func (*UpdateRunStatus) Type ¶
func (f *UpdateRunStatus) Type() string
Type always returns UpdateRunStatus to satisfy [pflag.Value] interface
func (*UpdateRunStatus) Values ¶ added in v0.72.0
func (f *UpdateRunStatus) Values() []UpdateRunStatus
Values returns all possible values for UpdateRunStatus.
There is no guarantee on the order of the values in the slice.
type UpdateWebhookResponse ¶ added in v0.34.0
type UpdateWebhookResponse struct {
}
func (UpdateWebhookResponse) MarshalJSON ¶ added in v0.73.0
func (st UpdateWebhookResponse) MarshalJSON() ([]byte, error)
func (*UpdateWebhookResponse) UnmarshalJSON ¶ added in v0.73.0
func (st *UpdateWebhookResponse) UnmarshalJSON(b []byte) error
type ViewType ¶ added in v0.59.0
type ViewType string
Qualifier for the view type.
const ViewTypeActiveOnly ViewType = `ACTIVE_ONLY`
const ViewTypeAll ViewType = `ALL`
const ViewTypeDeletedOnly ViewType = `DELETED_ONLY`
type WaitGetExperimentForecastingSucceeded ¶ added in v0.60.0
type WaitGetExperimentForecastingSucceeded[R any] struct { Response *R ExperimentId string `json:"experiment_id"` Poll func(time.Duration, func(*ForecastingExperiment)) (*ForecastingExperiment, error) // contains filtered or unexported fields }
WaitGetExperimentForecastingSucceeded is a wrapper that calls ForecastingAPI.WaitGetExperimentForecastingSucceeded and waits to reach SUCCEEDED state.
func (*WaitGetExperimentForecastingSucceeded[R]) Get ¶ added in v0.60.0
func (w *WaitGetExperimentForecastingSucceeded[R]) Get() (*ForecastingExperiment, error)
Get the ForecastingExperiment with the default timeout of 120 minutes.
func (*WaitGetExperimentForecastingSucceeded[R]) GetWithTimeout ¶ added in v0.60.0
func (w *WaitGetExperimentForecastingSucceeded[R]) GetWithTimeout(timeout time.Duration) (*ForecastingExperiment, error)
Get the ForecastingExperiment with custom timeout.
func (*WaitGetExperimentForecastingSucceeded[R]) OnProgress ¶ added in v0.60.0
func (w *WaitGetExperimentForecastingSucceeded[R]) OnProgress(callback func(*ForecastingExperiment)) *WaitGetExperimentForecastingSucceeded[R]
OnProgress invokes a callback every time it polls for the status update.