workstations

package
v1.127.0 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplyWorkstationConfigGCPDefaults added in v1.126.0 

func ApplyWorkstationConfigGCPDefaults(mapCtx *direct.MapContext, in *krm.WorkstationConfigSpec, out *pb.WorkstationConfig, actual *pb.WorkstationConfig)

func NewWorkstationClusterModel added in v1.126.0 

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

func NewWorkstationConfigModel added in v1.126.0 

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

func NewWorkstationModel added in v1.127.0 

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

func NormalizeWorkstationCluster 

func NormalizeWorkstationCluster(ctx context.Context, kube client.Reader, obj *krm.WorkstationCluster) error

func ResolveWorkstationConfigRefs added in v1.126.0 

func ResolveWorkstationConfigRefs(ctx context.Context, kube client.Reader, obj *krm.WorkstationConfig) error

func WorkstationAnnotations_FromProto added in v1.126.0 

func WorkstationAnnotations_FromProto(mapCtx *direct.MapContext, in map[string]string) []krm.WorkstationAnnotation

func WorkstationAnnotations_ToProto added in v1.126.0 

func WorkstationAnnotations_ToProto(mapCtx *direct.MapContext, in []krm.WorkstationAnnotation) map[string]string

func WorkstationClusterAllowedProjects_FromProto 

func WorkstationClusterAllowedProjects_FromProto(mapCtx *direct.MapContext, in []string) []refs.ProjectRef

func WorkstationClusterAllowedProjects_ToProto 

func WorkstationClusterAllowedProjects_ToProto(mapCtx *direct.MapContext, in []refs.ProjectRef) []string

func WorkstationClusterClusterHostname_FromProto 

func WorkstationClusterClusterHostname_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationCluster_PrivateClusterConfig) *string

func WorkstationClusterObservedState_FromProto 

func WorkstationClusterObservedState_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationCluster) *krm.WorkstationClusterObservedState

func WorkstationClusterObservedState_ToProto added in v1.125.0 

func WorkstationClusterObservedState_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationClusterObservedState) *pb.WorkstationCluster

func WorkstationClusterServiceAttachmentUri_FromProto 

func WorkstationClusterServiceAttachmentUri_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationCluster_PrivateClusterConfig) *string

func WorkstationClusterSpec_FromProto 

func WorkstationClusterSpec_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationCluster) *krm.WorkstationClusterSpec

func WorkstationClusterSpec_ToProto 

func WorkstationClusterSpec_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationClusterSpec) *pb.WorkstationCluster

func WorkstationCluster_PrivateClusterConfig_FromProto 

func WorkstationCluster_PrivateClusterConfig_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationCluster_PrivateClusterConfig) *krm.WorkstationCluster_PrivateClusterConfig

func WorkstationCluster_PrivateClusterConfig_ToProto 

func WorkstationCluster_PrivateClusterConfig_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationCluster_PrivateClusterConfig) *pb.WorkstationCluster_PrivateClusterConfig

func WorkstationConfigObservedState_FromProto added in v1.126.0 

func WorkstationConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig) *krm.WorkstationConfigObservedState

func WorkstationConfigObservedState_ToProto added in v1.126.0 

func WorkstationConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfigObservedState) *pb.WorkstationConfig

func WorkstationConfigSpec_FromProto added in v1.126.0 

func WorkstationConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig) *krm.WorkstationConfigSpec

func WorkstationConfigSpec_ToProto added in v1.126.0 

func WorkstationConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfigSpec) *pb.WorkstationConfig

func WorkstationConfig_Container_EnvVar_FromProto added in v1.126.0 

func WorkstationConfig_Container_EnvVar_FromProto(mapCtx *direct.MapContext, in map[string]string) []krm.WorkstationConfig_Container_EnvVar

func WorkstationConfig_Container_EnvVar_ToProto added in v1.126.0 

func WorkstationConfig_Container_EnvVar_ToProto(mapCtx *direct.MapContext, in []krm.WorkstationConfig_Container_EnvVar) map[string]string

func WorkstationConfig_Container_FromProto added in v1.126.0 

func WorkstationConfig_Container_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_Container) *krm.WorkstationConfig_Container

func WorkstationConfig_Container_ToProto added in v1.126.0 

func WorkstationConfig_Container_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_Container) *pb.WorkstationConfig_Container

func WorkstationConfig_CustomerEncryptionKey_FromProto added in v1.126.0 

func WorkstationConfig_CustomerEncryptionKey_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_CustomerEncryptionKey) *krm.WorkstationConfig_CustomerEncryptionKey

func WorkstationConfig_CustomerEncryptionKey_ToProto added in v1.126.0 

func WorkstationConfig_CustomerEncryptionKey_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_CustomerEncryptionKey) *pb.WorkstationConfig_CustomerEncryptionKey

func WorkstationConfig_HostObservedState_FromProto added in v1.126.0 

func WorkstationConfig_HostObservedState_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_Host) *krm.WorkstationConfig_HostObservedState

func WorkstationConfig_HostObservedState_ToProto added in v1.126.0 

func WorkstationConfig_HostObservedState_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_HostObservedState) *pb.WorkstationConfig_Host

func WorkstationConfig_Host_FromProto added in v1.126.0 

func WorkstationConfig_Host_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_Host) *krm.WorkstationConfig_Host

func WorkstationConfig_Host_GceInstanceObservedState_FromProto added in v1.126.0 

func WorkstationConfig_Host_GceInstanceObservedState_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_Host_GceInstance) *krm.WorkstationConfig_Host_GceInstanceObservedState

func WorkstationConfig_Host_GceInstanceObservedState_ToProto added in v1.126.0 

func WorkstationConfig_Host_GceInstanceObservedState_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_Host_GceInstanceObservedState) *pb.WorkstationConfig_Host_GceInstance

func WorkstationConfig_Host_GceInstance_FromProto added in v1.126.0 

func WorkstationConfig_Host_GceInstance_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_Host_GceInstance) *krm.WorkstationConfig_Host_GceInstance

func WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig_FromProto added in v1.126.0 

func WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig) *krm.WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig

func WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig_ToProto added in v1.126.0 

func WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig) *pb.WorkstationConfig_Host_GceInstance_GceConfidentialInstanceConfig

func WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig_FromProto added in v1.126.0 

func WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig) *krm.WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig

func WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig_ToProto added in v1.126.0 

func WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig) *pb.WorkstationConfig_Host_GceInstance_GceShieldedInstanceConfig

func WorkstationConfig_Host_GceInstance_ToProto added in v1.126.0 

func WorkstationConfig_Host_GceInstance_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_Host_GceInstance) *pb.WorkstationConfig_Host_GceInstance

func WorkstationConfig_Host_ToProto added in v1.126.0 

func WorkstationConfig_Host_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_Host) *pb.WorkstationConfig_Host

func WorkstationConfig_PersistentDirectory_FromProto added in v1.126.0 

func WorkstationConfig_PersistentDirectory_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_PersistentDirectory) *krm.WorkstationConfig_PersistentDirectory

func WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk_FromProto added in v1.126.0 

func WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk) *krm.WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk

func WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk_ToProto added in v1.126.0 

func WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk) *pb.WorkstationConfig_PersistentDirectory_GceRegionalPersistentDisk

func WorkstationConfig_PersistentDirectory_ToProto added in v1.126.0 

func WorkstationConfig_PersistentDirectory_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_PersistentDirectory) *pb.WorkstationConfig_PersistentDirectory

func WorkstationConfig_ReadinessCheck_FromProto added in v1.126.0 

func WorkstationConfig_ReadinessCheck_FromProto(mapCtx *direct.MapContext, in *pb.WorkstationConfig_ReadinessCheck) *krm.WorkstationConfig_ReadinessCheck

func WorkstationConfig_ReadinessCheck_ToProto added in v1.126.0 

func WorkstationConfig_ReadinessCheck_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationConfig_ReadinessCheck) *pb.WorkstationConfig_ReadinessCheck

func WorkstationGCPConditions_FromProto added in v1.126.0 

func WorkstationGCPConditions_FromProto(mapCtx *direct.MapContext, in []*status.Status) []krm.WorkstationServiceGCPCondition

func WorkstationGCPConditions_ToProto added in v1.126.0 

func WorkstationGCPConditions_ToProto(mapCtx *direct.MapContext, in []krm.WorkstationServiceGCPCondition) []*status.Status

func WorkstationLabels_FromProto added in v1.126.0 

func WorkstationLabels_FromProto(mapCtx *direct.MapContext, in map[string]string) []krm.WorkstationLabel

func WorkstationLabels_ToProto added in v1.126.0 

func WorkstationLabels_ToProto(mapCtx *direct.MapContext, in []krm.WorkstationLabel) map[string]string

func WorkstationObservedState_FromProto added in v1.127.0 

func WorkstationObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Workstation) *krm.WorkstationObservedState

func WorkstationObservedState_ToProto added in v1.127.0 

func WorkstationObservedState_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationObservedState) *pb.Workstation

func WorkstationSpec_FromProto added in v1.127.0 

func WorkstationSpec_FromProto(mapCtx *direct.MapContext, in *pb.Workstation) *krm.WorkstationSpec

func WorkstationSpec_ToProto added in v1.127.0 

func WorkstationSpec_ToProto(mapCtx *direct.MapContext, in *krm.WorkstationSpec) *pb.Workstation

Types

type Adapter 

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

func (*Adapter) Create 

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

func (*Adapter) Delete 

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

func (*Adapter) Export 

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

func (*Adapter) Find 

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

func (*Adapter) Update 

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

type WorkstationAdapter added in v1.127.0 

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

func (*WorkstationAdapter) Create added in v1.127.0 

func (a *WorkstationAdapter) 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 (*WorkstationAdapter) Delete added in v1.127.0 

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

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

func (*WorkstationAdapter) Export added in v1.127.0 

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

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

func (*WorkstationAdapter) Find added in v1.127.0 

func (a *WorkstationAdapter) 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 (*WorkstationAdapter) Update added in v1.127.0 

func (a *WorkstationAdapter) 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 WorkstationClusterIdentity 

type WorkstationClusterIdentity struct {
	Parent             parent
	WorkstationCluster string
}

The Identifier for ConfigConnector to track the WorkstationCluster resource from the GCP service.

func BuildID 

func BuildID(project, location, resourceID string) *WorkstationClusterIdentity

BuildID builds the ID for ConfigConnector to track the WorkstationCluster resource from the GCP service.

func (*WorkstationClusterIdentity) AsExternalRef 

func (c *WorkstationClusterIdentity) AsExternalRef() *string

AsExternalRef builds a externalRef from a WorkstationCluster

func (*WorkstationClusterIdentity) FullyQualifiedName 

func (c *WorkstationClusterIdentity) FullyQualifiedName() string

FullyQualifiedName returns both parent and resource ID in the full url format.

type WorkstationConfigAdapter added in v1.126.0 

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

func (*WorkstationConfigAdapter) Create added in v1.126.0 

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

func (*WorkstationConfigAdapter) Delete added in v1.126.0 

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

Delete implements the Adapter interface.

func (*WorkstationConfigAdapter) Export added in v1.126.0 

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

func (*WorkstationConfigAdapter) Find added in v1.126.0 

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

func (*WorkstationConfigAdapter) Update added in v1.126.0 

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

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.