mlflow

Documentation

Index

• func ResourceMlflowExperiment() *schema.Resource
• func ResourceMlflowModel() *schema.Resource
• func ResourceMlflowWebhook() *schema.Resource
• type Experiment
• type ExperimentsAPI
  • func NewExperimentsAPI(ctx context.Context, m any) ExperimentsAPI
  • func (a ExperimentsAPI) Create(d *Experiment) error
  • func (a ExperimentsAPI) Delete(id string) error
  • func (a ExperimentsAPI) Read(experimentId string) (*Experiment, error)
  • func (a ExperimentsAPI) Update(e *experimentUpdate) error
• type HttpUrlSpec
• type JobSpec
• type Model
• type ModelVersion
• type ModelsAPI
  • func NewModelsAPI(ctx context.Context, m any) ModelsAPI
  • func (a ModelsAPI) Create(m *Model) error
  • func (a ModelsAPI) Delete(name string) error
  • func (a ModelsAPI) Read(name string) (*Model, error)
  • func (a ModelsAPI) Update(m *Model) error
• type Tag
• type Webhook
• type WebhooksAPI
  • func NewWebhooksAPI(ctx context.Context, m any) WebhooksAPI
  • func (a WebhooksAPI) Create(m Webhook) (string, error)
  • func (a WebhooksAPI) Delete(ID string) error
  • func (a WebhooksAPI) Read(ID string) (Webhook, error)
  • func (a WebhooksAPI) Update(id string, m Webhook) error

Functions

func ResourceMlflowExperiment

func ResourceMlflowExperiment() *schema.Resource

func ResourceMlflowModel

func ResourceMlflowModel() *schema.Resource

func ResourceMlflowWebhook

func ResourceMlflowWebhook() *schema.Resource

Types

type Experiment

type Experiment struct {
	Name             string `json:"name"`
	Description      string `json:"description,omitempty"`
	ExperimentId     string `json:"experiment_id,omitempty" tf:"computed"`
	ArtifactLocation string `json:"artifact_location,omitempty" tf:"force_new,suppress_diff"`
	LifecycleStage   string `json:"lifecycle_stage,omitempty" tf:"computed"`
	LastUpdateTime   int64  `json:"last_update_time,omitempty" tf:"computed"`
	CreationTime     int64  `json:"creation_time,omitempty" tf:"computed"`
}

Experiment defines the response object from the API

type ExperimentsAPI

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

ExperimentsAPI ...

func NewExperimentsAPI

func NewExperimentsAPI(ctx context.Context, m any) ExperimentsAPI

NewExperimentsAPI ...

func (ExperimentsAPI) Create

func (a ExperimentsAPI) Create(d *Experiment) error

Create ...

func (ExperimentsAPI) Delete

func (a ExperimentsAPI) Delete(id string) error

Delete ...

func (ExperimentsAPI) Read

func (a ExperimentsAPI) Read(experimentId string) (*Experiment, error)

Read ...

func (ExperimentsAPI) Update

func (a ExperimentsAPI) Update(e *experimentUpdate) error

Update ...

type HttpUrlSpec

type HttpUrlSpec struct {
	URL                   string `json:"url"`
	EnableSslVerification bool   `json:"enable_ssl_verification" tf:"optional,default:true"`
	Secret                string `json:"secret,omitempty"`
	Authorization         string `json:"authorization,omitempty" tf:"sensitive"`
}

type JobSpec

type JobSpec struct {
	JobID        string `json:"job_id"`
	AccessToken  string `json:"access_token" tf:"sensitive"`
	WorkspaceURL string `json:"workspace_url,omitempty"`
}

type Model

type Model struct {
	Name                 string         `json:"name" tf:"force_new"`
	CreationTimestamp    int64          `json:"creation_timestamp,omitempty" tf:"computed"`
	LastUpdatedTimestamp int64          `json:"last_updated_timestamp,omitempty" tf:"computed"`
	UserID               string         `json:"user_id,omitempty" tf:"computed"`
	LatestVersions       []ModelVersion `json:"latest_versions,omitempty" tf:"computed"`
	Description          string         `json:"description,omitempty"`
	Tags                 []Tag          `json:"tags,omitempty"`
	RegisteredModelID    string         `json:"id,omitempty" tf:"computed,alias:registered_model_id"`
}

Model defines the response object from the API

type ModelVersion

type ModelVersion struct {
	Name                 string `json:"name"`
	Version              string `json:"version"`
	CreationTimestamp    int64  `json:"creation_timestamp,omitempty"`
	LastUpdatedTimestamp int64  `json:"last_updated_timestamp,omitempty"`
	UserID               string `json:"user_id,omitempty"`
	CurrentStage         string `json:"current_stage,omitempty"`
	Source               string `json:"source,omitempty"`
	Status               string `json:"status,omitempty"`
}

ModelVersion defines a MLFlow model version as returned by the API

type ModelsAPI

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

func NewModelsAPI

func NewModelsAPI(ctx context.Context, m any) ModelsAPI

func (ModelsAPI) Create

func (a ModelsAPI) Create(m *Model) error

func (ModelsAPI) Delete

func (a ModelsAPI) Delete(name string) error

Delete removes the model by its name

func (ModelsAPI) Read

func (a ModelsAPI) Read(name string) (*Model, error)

func (ModelsAPI) Update

func (a ModelsAPI) Update(m *Model) error

Update the model entity

type Tag

type Tag struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type Webhook

type Webhook struct {
	ID          string       `json:"id" tf:"computed"`
	Events      []string     `json:"events"`
	Status      string       `json:"status,omitempty" tf:"default:ACTIVE"`
	Description string       `json:"description,omitempty"`
	ModelName   string       `json:"model_name,omitempty" tf:"force_new"`
	HttpUrlSpec *HttpUrlSpec `json:"http_url_spec,omitempty"` // TODO: add diff suppressor?
	JobSpec     *JobSpec     `json:"job_spec,omitempty"`      // TODO: add diff suppressor?
}

type WebhooksAPI

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

func NewWebhooksAPI

func NewWebhooksAPI(ctx context.Context, m any) WebhooksAPI

func (WebhooksAPI) Create

func (a WebhooksAPI) Create(m Webhook) (string, error)

func (WebhooksAPI) Delete

func (a WebhooksAPI) Delete(ID string) error

Delete removes the webhook by its ID

func (WebhooksAPI) Read

func (a WebhooksAPI) Read(ID string) (Webhook, error)

func (WebhooksAPI) Update

func (a WebhooksAPI) Update(id string, m Webhook) error

Update the webhook entity