k8s

package

v0.0.1 Latest Latest Go to latest Published: May 23, 2023 License: MIT Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/salberternst/workspace

Links

Open Source Insights

Documentation ¶

Index ¶

func ExecuteInPod(namespace string, name string, container string, command []string, ...) error
func GetNotebookPod(namespace string, notebookName string) (*v1.Pod, error)
func GetPodLogs(pod v1.Pod, container string, follow bool) error
func GetWorkspacePod(namespace string, workspacName string) (*v1.Pod, error)
func GetWorkspaceVolumes(namespace string, notebookName string) ([]v1.PersistentVolumeClaim, error)
func ReadSecret(name string, namespace string) (*v1.Secret, error)
func WaitForDeployment(name, namespace string, waitTimeout uint) error
func WaitUntilPodIsReady(name, namespace string) error
type Client
- func GetClient() *Client
- func InitClient(kubeConfigPath string) (*Client, error)
- func (o *Client) CreateDialer(name string, namespace string) (*httpstream.Dialer, error)
- func (o *Client) ForwardPorts(name string, namespace string, ports []string) (PortForward, error)
type ConfigMapper
- func NewConfigMapper(files []FileMap) ConfigMapper
- func (o *ConfigMapper) BuildConfigMap(namespace, name string) error
type FileMap
type PortForward

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ExecuteInPod ¶

func ExecuteInPod(namespace string, name string, container string, command []string, terminal bool) error

func GetNotebookPod ¶

func GetNotebookPod(namespace string, notebookName string) (*v1.Pod, error)

func GetPodLogs ¶

func GetPodLogs(pod v1.Pod, container string, follow bool) error

func GetWorkspacePod ¶

func GetWorkspacePod(namespace string, workspacName string) (*v1.Pod, error)

func GetWorkspaceVolumes ¶

func GetWorkspaceVolumes(namespace string, notebookName string) ([]v1.PersistentVolumeClaim, error)

func ReadSecret ¶

func ReadSecret(name string, namespace string) (*v1.Secret, error)

func WaitForDeployment ¶

func WaitForDeployment(name, namespace string, waitTimeout uint) error

func WaitUntilPodIsReady ¶

func WaitUntilPodIsReady(name, namespace string) error

Types ¶

type Client ¶

type Client struct {
	CoreV1    *kubernetes.Clientset
	Config    *rest.Config
	Namespace string
}

func GetClient ¶

func GetClient() *Client

func InitClient ¶

func InitClient(kubeConfigPath string) (*Client, error)

func (*Client) CreateDialer ¶

func (o *Client) CreateDialer(name string, namespace string) (*httpstream.Dialer, error)

func (*Client) ForwardPorts ¶

func (o *Client) ForwardPorts(name string, namespace string, ports []string) (PortForward, error)

type ConfigMapper ¶

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

func NewConfigMapper ¶

func NewConfigMapper(files []FileMap) ConfigMapper

func (*ConfigMapper) BuildConfigMap ¶

func (o *ConfigMapper) BuildConfigMap(namespace, name string) error

type FileMap ¶

type FileMap struct {
	LocalFilename string
	Id            string
	MountPath     string
}

type PortForward ¶

type PortForward struct {
	ReadyChannel   chan struct{}
	StopChannel    chan struct{}
	Name           string
	Namespace      string
	ForwardedPorts []portforward.ForwardedPort
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL