mlplatform

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: MPL-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewJupyterHubResource 

func NewJupyterHubResource() resource.Resource

func NewK8SRegistryResource added in v0.7.0 

func NewK8SRegistryResource() resource.Resource

func NewMLFlowDeployResource 

func NewMLFlowDeployResource() resource.Resource

func NewMLFlowResource 

func NewMLFlowResource() resource.Resource

func NewSparkK8SResource added in v0.7.0 

func NewSparkK8SResource() resource.Resource

Types

type JupyterHubResource 

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

func (*JupyterHubResource) Configure 

func (r *JupyterHubResource) Configure(ctx context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

func (*JupyterHubResource) Create 

func (r *JupyterHubResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

func (*JupyterHubResource) Delete 

func (r *JupyterHubResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

func (*JupyterHubResource) ImportState 

func (r *JupyterHubResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*JupyterHubResource) Metadata 

func (r *JupyterHubResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

func (*JupyterHubResource) Read 

func (r *JupyterHubResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

func (*JupyterHubResource) Schema 

func (r *JupyterHubResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse)

func (*JupyterHubResource) Update 

func (r *JupyterHubResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

type JupyterHubResourceModel 

type JupyterHubResourceModel struct {
	ID               types.String              `tfsdk:"id"`
	Name             types.String              `tfsdk:"name"`
	DomainName       types.String              `tfsdk:"domain_name"`
	AdminName        types.String              `tfsdk:"admin_name"`
	AdminPassword    types.String              `tfsdk:"admin_password"`
	FlavorID         types.String              `tfsdk:"flavor_id"`
	AvailabilityZone types.String              `tfsdk:"availability_zone"`
	BootVolume       *MLPlatformVolumeModel    `tfsdk:"boot_volume"`
	DataVolumes      []*MLPlatformVolumeModel  `tfsdk:"data_volumes"`
	Networks         []*MLPlatformNetworkModel `tfsdk:"networks"`
	S3FSBucket       types.String              `tfsdk:"s3fs_bucket"`
	CreatedAt        types.String              `tfsdk:"created_at"`
	PrivateIP        types.String              `tfsdk:"private_ip"`
	DNSName          types.String              `tfsdk:"dns_name"`
	Region           types.String              `tfsdk:"region"`
	Timeouts         timeouts.Value            `tfsdk:"timeouts"`
}

type K8SRegistryResource added in v0.7.0 

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

func (*K8SRegistryResource) Configure added in v0.7.0 

func (r *K8SRegistryResource) Configure(ctx context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

func (*K8SRegistryResource) Create added in v0.7.0 

func (r *K8SRegistryResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

func (*K8SRegistryResource) Delete added in v0.7.0 

func (r *K8SRegistryResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

func (*K8SRegistryResource) ImportState added in v0.7.0 

func (r *K8SRegistryResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*K8SRegistryResource) Metadata added in v0.7.0 

func (r *K8SRegistryResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

func (*K8SRegistryResource) Read added in v0.7.0 

func (r *K8SRegistryResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

func (*K8SRegistryResource) Schema added in v0.7.0 

func (r *K8SRegistryResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse)

func (*K8SRegistryResource) Update added in v0.7.0 

func (r *K8SRegistryResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

type K8SRegistryResourceModel added in v0.7.0 

type K8SRegistryResourceModel struct {
	ID               types.String              `tfsdk:"id"`
	Name             types.String              `tfsdk:"name"`
	DomainName       types.String              `tfsdk:"domain_name"`
	AdminName        types.String              `tfsdk:"admin_name"`
	AdminPassword    types.String              `tfsdk:"admin_password"`
	FlavorID         types.String              `tfsdk:"flavor_id"`
	AvailabilityZone types.String              `tfsdk:"availability_zone"`
	BootVolume       *MLPlatformVolumeModel    `tfsdk:"boot_volume"`
	DataVolumes      []*MLPlatformVolumeModel  `tfsdk:"data_volumes"`
	Networks         []*MLPlatformNetworkModel `tfsdk:"networks"`
	CreatedAt        types.String              `tfsdk:"created_at"`
	PrivateIP        types.String              `tfsdk:"private_ip"`
	DNSName          types.String              `tfsdk:"dns_name"`
	Region           types.String              `tfsdk:"region"`
	Timeouts         timeouts.Value            `tfsdk:"timeouts"`
}

type MLFlowDeployResource 

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

func (*MLFlowDeployResource) Configure 

func (r *MLFlowDeployResource) Configure(ctx context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

func (*MLFlowDeployResource) Create 

func (r *MLFlowDeployResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

func (*MLFlowDeployResource) Delete 

func (r *MLFlowDeployResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

func (*MLFlowDeployResource) ImportState 

func (r *MLFlowDeployResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*MLFlowDeployResource) Metadata 

func (r *MLFlowDeployResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

func (*MLFlowDeployResource) Read 

func (r *MLFlowDeployResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

func (*MLFlowDeployResource) Schema 

func (r *MLFlowDeployResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse)

func (*MLFlowDeployResource) Update 

func (r *MLFlowDeployResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

type MLFlowDeployResourceModel 

type MLFlowDeployResourceModel struct {
	ID               types.String              `tfsdk:"id"`
	Name             types.String              `tfsdk:"name"`
	FlavorID         types.String              `tfsdk:"flavor_id"`
	MLFlowInstanceID types.String              `tfsdk:"mlflow_instance_id"`
	AvailabilityZone types.String              `tfsdk:"availability_zone"`
	BootVolume       *MLPlatformVolumeModel    `tfsdk:"boot_volume"`
	DataVolumes      []*MLPlatformVolumeModel  `tfsdk:"data_volumes"`
	Networks         []*MLPlatformNetworkModel `tfsdk:"networks"`
	CreatedAt        types.String              `tfsdk:"created_at"`
	PrivateIP        types.String              `tfsdk:"private_ip"`
	DNSName          types.String              `tfsdk:"dns_name"`
	Region           types.String              `tfsdk:"region"`
	Timeouts         timeouts.Value            `tfsdk:"timeouts"`
}

type MLFlowResource 

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

func (*MLFlowResource) Configure 

func (r *MLFlowResource) Configure(ctx context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

func (*MLFlowResource) Create 

func (r *MLFlowResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

func (*MLFlowResource) Delete 

func (r *MLFlowResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

func (*MLFlowResource) ImportState 

func (r *MLFlowResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*MLFlowResource) Metadata 

func (r *MLFlowResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

func (*MLFlowResource) Read 

func (r *MLFlowResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

func (*MLFlowResource) Schema 

func (r *MLFlowResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse)

func (*MLFlowResource) Update 

func (r *MLFlowResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

type MLFlowResourceModel 

type MLFlowResourceModel struct {
	ID               types.String              `tfsdk:"id"`
	Name             types.String              `tfsdk:"name"`
	FlavorID         types.String              `tfsdk:"flavor_id"`
	JHInstanceID     types.String              `tfsdk:"jh_instance_id"`
	AvailabilityZone types.String              `tfsdk:"availability_zone"`
	BootVolume       *MLPlatformVolumeModel    `tfsdk:"boot_volume"`
	DataVolumes      []*MLPlatformVolumeModel  `tfsdk:"data_volumes"`
	Networks         []*MLPlatformNetworkModel `tfsdk:"networks"`
	DemoMode         types.Bool                `tfsdk:"demo_mode"`
	CreatedAt        types.String              `tfsdk:"created_at"`
	PrivateIP        types.String              `tfsdk:"private_ip"`
	DNSName          types.String              `tfsdk:"dns_name"`
	Region           types.String              `tfsdk:"region"`
	Timeouts         timeouts.Value            `tfsdk:"timeouts"`
}

type MLPlatformNetworkModel 

type MLPlatformNetworkModel struct {
	IPPool    types.String `tfsdk:"ip_pool"`
	NetworkID types.String `tfsdk:"network_id"`
}

type MLPlatformVolumeModel 

type MLPlatformVolumeModel struct {
	Name       types.String `tfsdk:"name"`
	Size       types.Int64  `tfsdk:"size"`
	VolumeType types.String `tfsdk:"volume_type"`
	VolumeID   types.String `tfsdk:"volume_id"`
}

type SparkK8SNodeGroupModel added in v0.7.0 

type SparkK8SNodeGroupModel struct {
	NodeCount          types.Int64  `tfsdk:"node_count"`
	FlavorID           types.String `tfsdk:"flavor_id"`
	AutoscalingEnabled types.Bool   `tfsdk:"autoscaling_enabled"`
	MinNodes           types.Int64  `tfsdk:"min_nodes"`
	MaxNodes           types.Int64  `tfsdk:"max_nodes"`
}

type SparkK8SResource added in v0.7.0 

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

func (*SparkK8SResource) Configure added in v0.7.0 

func (r *SparkK8SResource) Configure(ctx context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

func (*SparkK8SResource) Create added in v0.7.0 

func (r *SparkK8SResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

func (*SparkK8SResource) Delete added in v0.7.0 

func (r *SparkK8SResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

func (*SparkK8SResource) ImportState added in v0.7.0 

func (r *SparkK8SResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*SparkK8SResource) Metadata added in v0.7.0 

func (r *SparkK8SResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

func (*SparkK8SResource) Read added in v0.7.0 

func (r *SparkK8SResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

func (*SparkK8SResource) Schema added in v0.7.0 

func (r *SparkK8SResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse)

func (*SparkK8SResource) Update added in v0.7.0 

func (r *SparkK8SResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

type SparkK8SResourceModel added in v0.7.0 

type SparkK8SResourceModel struct {
	ID                   types.String              `tfsdk:"id"`
	Name                 types.String              `tfsdk:"name"`
	AvailabilityZone     types.String              `tfsdk:"availability_zone"`
	NetworkID            types.String              `tfsdk:"network_id"`
	SubnetID             types.String              `tfsdk:"subnet_id"`
	NodeGroups           []*SparkK8SNodeGroupModel `tfsdk:"node_groups"`
	ClusterMode          types.String              `tfsdk:"cluster_mode"`
	RegistryID           types.String              `tfsdk:"registry_id"`
	IPPool               types.String              `tfsdk:"ip_pool"`
	SparkConfiguration   types.String              `tfsdk:"spark_configuration"`
	EnvironmentVariables types.String              `tfsdk:"environment_variables"`

	S3BucketName            types.String `tfsdk:"s3_bucket_name"`
	HistoryServerURL        types.String `tfsdk:"history_server_url"`
	ControlInstanceID       types.String `tfsdk:"control_instance_id"`
	InactiveMin             types.Int64  `tfsdk:"inactive_min"`
	SuspendAfterInactiveMin types.Int64  `tfsdk:"suspend_after_inactive_min"`
	DeleteAfterInactiveMin  types.Int64  `tfsdk:"delete_after_inactive_min"`

	Region   types.String   `tfsdk:"region"`
	Timeouts timeouts.Value `tfsdk:"timeouts"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.