k8s

Documentation

Index

• func CreateWorkspace(ctx context.Context, k8sClient client.Client, req models.WorkspaceSettings, ...) error
• func DeleteWorkspace(ctx context.Context, k8sClient client.Client, payload models.WorkspaceSettings) error
• func GenerateStorageConfig(workspaceName string, c *utils.Config) workspacev1alpha1.StorageSpec
• func InitializeManager() (manager.Manager, error)
• func ListenForWorkspaceStatusUpdates(ctx context.Context, mgr manager.Manager, ...) error
• func MapBlockStoresToEFSAccessPoints(workspaceName string, c *utils.Config, blockStores []models.BlockStore) []workspacev1alpha1.EFSAccess
• func MapObjectStoresToS3Buckets(workspaceName string, c *utils.Config, objectStores []models.ObjectStore) []workspacev1alpha1.S3Bucket
• func ProcessWorkspace(ctx context.Context, client client.Client, c *utils.Config, ...) error
• func UpdateWorkspace(ctx context.Context, k8sClient client.Client, req models.WorkspaceSettings, ...) error

Functions

func CreateWorkspace

func CreateWorkspace(ctx context.Context, k8sClient client.Client, req models.WorkspaceSettings, c *utils.Config) error

CreateWorkspace creates a new Workspace in the cluster

func DeleteWorkspace

func DeleteWorkspace(ctx context.Context, k8sClient client.Client, payload models.WorkspaceSettings) error

DeleteWorkspace deletes an existing Workspace in the cluster

func GenerateStorageConfig

func GenerateStorageConfig(workspaceName string, c *utils.Config) workspacev1alpha1.StorageSpec

GenerateStorageConfig generates a StorageSpec for a Workspace based on the workspace name

func InitializeManager

func InitializeManager() (manager.Manager, error)

InitializeManager initializes and returns a Kubernetes manager

func ListenForWorkspaceStatusUpdates

func ListenForWorkspaceStatusUpdates(ctx context.Context, mgr manager.Manager, statusUpdates chan models.WorkspaceStatus) error

ListenForWorkspaceStatusUpdates listens for updates to the Workspace CRD

func MapBlockStoresToEFSAccessPoints

func MapBlockStoresToEFSAccessPoints(workspaceName string, c *utils.Config, blockStores []models.BlockStore) []workspacev1alpha1.EFSAccess

MapBlockStoresToEFSAccessPoints maps BlockStores to EFSAccessPoints

func MapObjectStoresToS3Buckets

func MapObjectStoresToS3Buckets(workspaceName string, c *utils.Config, objectStores []models.ObjectStore) []workspacev1alpha1.S3Bucket

MapObjectStoresToS3Buckets maps ObjectStores to S3Buckets

func ProcessWorkspace

func ProcessWorkspace(ctx context.Context, client client.Client, c *utils.Config, payload models.WorkspaceSettings) error

ProcessWorkspace processes a WorkspaceSettings pulsar message payload

func UpdateWorkspace

func UpdateWorkspace(ctx context.Context, k8sClient client.Client, req models.WorkspaceSettings, c *utils.Config) error

UpdateWorkspace updates an existing Workspace in the cluster