notebooks

package
v1.154.0 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ContainerImageV1beta1_FromProto added in v1.131.0 

func ContainerImageV1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ContainerImage) *krm.ContainerImage

func ContainerImageV1beta1_ToProto added in v1.131.0 

func ContainerImageV1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ContainerImage) *pb.ContainerImage

func ContainerImage_v1alpha1_FromProto added in v1.151.0 

func ContainerImage_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ContainerImage) *krmnotebooksv1alpha1.ContainerImage

func ContainerImage_v1alpha1_ToProto added in v1.151.0 

func ContainerImage_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.ContainerImage) *pb.ContainerImage

func ContainerImage_v1beta1_FromProto added in v1.151.0 

func ContainerImage_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ContainerImage) *krm.ContainerImage

func ContainerImage_v1beta1_ToProto added in v1.151.0 

func ContainerImage_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ContainerImage) *pb.ContainerImage

func ExecutionTemplate_DataprocParameters_v1alpha1_FromProto added in v1.153.0 

func ExecutionTemplate_DataprocParameters_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionTemplate_DataprocParameters) *krmnotebooksv1alpha1.ExecutionTemplate_DataprocParameters

func ExecutionTemplate_DataprocParameters_v1alpha1_ToProto added in v1.153.0 

func ExecutionTemplate_DataprocParameters_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.ExecutionTemplate_DataprocParameters) *pb.ExecutionTemplate_DataprocParameters

func ExecutionTemplate_SchedulerAcceleratorConfig_v1alpha1_FromProto added in v1.153.0 

func ExecutionTemplate_SchedulerAcceleratorConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionTemplate_SchedulerAcceleratorConfig) *krmnotebooksv1alpha1.ExecutionTemplate_SchedulerAcceleratorConfig

func ExecutionTemplate_SchedulerAcceleratorConfig_v1alpha1_ToProto added in v1.153.0 

func ExecutionTemplate_SchedulerAcceleratorConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.ExecutionTemplate_SchedulerAcceleratorConfig) *pb.ExecutionTemplate_SchedulerAcceleratorConfig

func ExecutionTemplate_VertexAiParameters_v1alpha1_FromProto added in v1.153.0 

func ExecutionTemplate_VertexAiParameters_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionTemplate_VertexAIParameters) *krmnotebooksv1alpha1.ExecutionTemplate_VertexAiParameters

func ExecutionTemplate_VertexAiParameters_v1alpha1_ToProto added in v1.153.0 

func ExecutionTemplate_VertexAiParameters_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.ExecutionTemplate_VertexAiParameters) *pb.ExecutionTemplate_VertexAIParameters

func ExecutionTemplate_v1alpha1_FromProto added in v1.153.0 

func ExecutionTemplate_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ExecutionTemplate) *krmnotebooksv1alpha1.ExecutionTemplate

func ExecutionTemplate_v1alpha1_ToProto added in v1.153.0 

func ExecutionTemplate_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.ExecutionTemplate) *pb.ExecutionTemplate

func Instance_AcceleratorConfig_v1beta1_FromProto added in v1.151.0 

func Instance_AcceleratorConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance_AcceleratorConfig) *krm.Instance_AcceleratorConfig

func Instance_AcceleratorConfig_v1beta1_ToProto added in v1.151.0 

func Instance_AcceleratorConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Instance_AcceleratorConfig) *pb.Instance_AcceleratorConfig

func Instance_Disk_GuestOSFeature_v1beta1_FromProto added in v1.151.0 

func Instance_Disk_GuestOSFeature_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance_Disk_GuestOsFeature) *krm.Instance_Disk_GuestOSFeature

func Instance_Disk_GuestOSFeature_v1beta1_ToProto added in v1.151.0 

func Instance_Disk_GuestOSFeature_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Instance_Disk_GuestOSFeature) *pb.Instance_Disk_GuestOsFeature

func Instance_Disk_v1beta1_FromProto added in v1.151.0 

func Instance_Disk_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance_Disk) *krm.Instance_Disk

func Instance_Disk_v1beta1_ToProto added in v1.151.0 

func Instance_Disk_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Instance_Disk) *pb.Instance_Disk

func Instance_ShieldedInstanceConfig_v1beta1_FromProto added in v1.151.0 

func Instance_ShieldedInstanceConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ShieldedInstanceConfig) *krm.Instance_ShieldedInstanceConfig

func Instance_ShieldedInstanceConfig_v1beta1_ToProto added in v1.151.0 

func Instance_ShieldedInstanceConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Instance_ShieldedInstanceConfig) *pb.Instance_ShieldedInstanceConfig

func Instance_UpgradeHistoryEntry_v1beta1_FromProto added in v1.151.0 

func Instance_UpgradeHistoryEntry_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance_UpgradeHistoryEntry) *krm.Instance_UpgradeHistoryEntry

func Instance_UpgradeHistoryEntry_v1beta1_ToProto added in v1.151.0 

func Instance_UpgradeHistoryEntry_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Instance_UpgradeHistoryEntry) *pb.Instance_UpgradeHistoryEntry

func NewEnvironmentModel 

func NewEnvironmentModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewExecutionModel added in v1.154.0 

func NewExecutionModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewInstanceModel added in v1.132.0 

func NewInstanceModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NotebookInstanceObservedState_v1beta1_FromProto added in v1.151.0 

func NotebookInstanceObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krm.NotebookInstanceObservedState

func NotebookInstanceObservedState_v1beta1_ToProto added in v1.151.0 

func NotebookInstanceObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.NotebookInstanceObservedState) *pb.Instance

func NotebookInstanceSpec_v1beta1_FromProto added in v1.151.0 

func NotebookInstanceSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krm.NotebookInstanceSpec

func NotebookInstanceSpec_v1beta1_ToProto added in v1.151.0 

func NotebookInstanceSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.NotebookInstanceSpec) *pb.Instance

func NotebooksEnvironmentObservedState_v1alpha1_FromProto added in v1.151.0 

func NotebooksEnvironmentObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Environment) *krm.NotebooksEnvironmentObservedState

func NotebooksEnvironmentObservedState_v1alpha1_ToProto added in v1.151.0 

func NotebooksEnvironmentObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.NotebooksEnvironmentObservedState) *pb.Environment

func NotebooksEnvironmentSpec_v1alpha1_FromProto added in v1.151.0 

func NotebooksEnvironmentSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Environment) *krm.NotebooksEnvironmentSpec

func NotebooksEnvironmentSpec_v1alpha1_ToProto added in v1.151.0 

func NotebooksEnvironmentSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.NotebooksEnvironmentSpec) *pb.Environment

func NotebooksExecutionObservedState_v1alpha1_FromProto added in v1.153.0 

func NotebooksExecutionObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Execution) *krmnotebooksv1alpha1.NotebooksExecutionObservedState

found existing non-generated mapping function "NotebooksEnvironmentSpec_v1alpha1_ToProto", skipping 

func NotebooksEnvironmentSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.NotebooksEnvironmentSpec) *pb.Environment {
	if in == nil {
		return nil
	}
	out := &pb.Environment{}
	// MISSING: Name
	out.DisplayName = direct.ValueOf(in.DisplayName)
	out.Description = direct.ValueOf(in.Description)
	// MISSING: VMImage
	// (near miss): "VMImage" vs "VmImage"
	if oneof := ContainerImage_v1alpha1_ToProto(mapCtx, in.ContainerImage); oneof != nil {
		out.ImageType = &pb.Environment_ContainerImage{ContainerImage: oneof}
	}
	out.PostStartupScript = direct.ValueOf(in.PostStartupScript)
	return out
}

func NotebooksExecutionObservedState_v1alpha1_ToProto added in v1.153.0 

func NotebooksExecutionObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.NotebooksExecutionObservedState) *pb.Execution

func NotebooksExecutionSpec_v1alpha1_FromProto added in v1.153.0 

func NotebooksExecutionSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Execution) *krmnotebooksv1alpha1.NotebooksExecutionSpec

func NotebooksExecutionSpec_v1alpha1_ToProto added in v1.153.0 

func NotebooksExecutionSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.NotebooksExecutionSpec) *pb.Execution

func NotebooksScheduleObservedState_v1alpha1_FromProto added in v1.154.0 

func NotebooksScheduleObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Schedule) *krmnotebooksv1alpha1.NotebooksScheduleObservedState

func NotebooksScheduleObservedState_v1alpha1_ToProto added in v1.154.0 

func NotebooksScheduleObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.NotebooksScheduleObservedState) *pb.Schedule

func NotebooksScheduleSpec_v1alpha1_FromProto added in v1.154.0 

func NotebooksScheduleSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Schedule) *krmnotebooksv1alpha1.NotebooksScheduleSpec

func NotebooksScheduleSpec_v1alpha1_ToProto added in v1.154.0 

func NotebooksScheduleSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.NotebooksScheduleSpec) *pb.Schedule

func ReservationAffinity_v1beta1_FromProto added in v1.151.0 

func ReservationAffinity_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ReservationAffinity) *krm.ReservationAffinity

func ReservationAffinity_v1beta1_ToProto added in v1.151.0 

func ReservationAffinity_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ReservationAffinity) *pb.ReservationAffinity

func VMImage_ImageFamily_ToProto added in v1.131.0 

func VMImage_ImageFamily_ToProto(mapCtx *direct.MapContext, in *string) *pb.VmImage_ImageFamily

func VMImage_ImageName_ToProto added in v1.131.0 

func VMImage_ImageName_ToProto(mapCtx *direct.MapContext, in *string) *pb.VmImage_ImageName

func VMImage_v1alpha1_FromProto added in v1.151.0 

func VMImage_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.VmImage) *krmnotebooksv1alpha1.VMImage

func VMImage_v1alpha1_ToProto added in v1.151.0 

func VMImage_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmnotebooksv1alpha1.VMImage) *pb.VmImage

func VMImage_v1beta1_FromProto added in v1.151.0 

func VMImage_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.VmImage) *krm.VMImage

found existing non-generated mapping function "VMImage_ImageFamily_ToProto", skipping 

func VMImage_ImageFamily_ToProto(mapCtx *direct.MapContext, in *string) *pb.VmImage_ImageFamily {
	if in == nil {
		return nil
	}
	return &pb.VmImage_ImageFamily{ImageFamily: *in}
}

func VMImage_v1beta1_ToProto added in v1.151.0 

func VMImage_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.VMImage) *pb.VmImage

func VmImage_FromProto 

func VmImage_FromProto(mapCtx *direct.MapContext, in *pb.VmImage) *krm.VMImage

func VmImage_ImageFamily_ToProto 

func VmImage_ImageFamily_ToProto(mapCtx *direct.MapContext, in *string) *pb.VmImage_ImageFamily

func VmImage_ImageName_ToProto 

func VmImage_ImageName_ToProto(mapCtx *direct.MapContext, in *string) *pb.VmImage_ImageName

func VmImage_ToProto 

func VmImage_ToProto(mapCtx *direct.MapContext, in *krm.VMImage) *pb.VmImage

Types

type EnvironmentAdapter 

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

func (*EnvironmentAdapter) Create 

func (a *EnvironmentAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*EnvironmentAdapter) Delete 

func (a *EnvironmentAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*EnvironmentAdapter) Export 

func (a *EnvironmentAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*EnvironmentAdapter) Find 

func (a *EnvironmentAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*EnvironmentAdapter) Update 

func (a *EnvironmentAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

type ExecutionAdapter added in v1.154.0 

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

func (*ExecutionAdapter) Create added in v1.154.0 

func (a *ExecutionAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

func (*ExecutionAdapter) Delete added in v1.154.0 

func (a *ExecutionAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

func (*ExecutionAdapter) Export added in v1.154.0 

func (a *ExecutionAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

func (*ExecutionAdapter) Find added in v1.154.0 

func (a *ExecutionAdapter) Find(ctx context.Context) (bool, error)

func (*ExecutionAdapter) Update added in v1.154.0 

func (a *ExecutionAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

type InstanceAdapter added in v1.132.0 

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

func (*InstanceAdapter) Create added in v1.132.0 

func (a *InstanceAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*InstanceAdapter) Delete added in v1.132.0 

func (a *InstanceAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*InstanceAdapter) Export added in v1.132.0 

func (a *InstanceAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*InstanceAdapter) Find added in v1.132.0 

func (a *InstanceAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*InstanceAdapter) Update added in v1.132.0 

func (a *InstanceAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

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.