k8s

Documentation

Index

• Variables
• func AttachFallbackToLogs(pod *corev1.Pod, logstream io.ReadCloser) error
• func DeleteWaitAnnotationKey(obj metav1.Object)
• func GetNamespacedName(obj metav1.Object) types.NamespacedName
• func PodConnect(ctx context.Context, kc kubernetes.Interface, namespace, name string, ...) error
• type PodListWatcher
  • func (plw *PodListWatcher) List(options metav1.ListOptions) (runtime.Object, error)
  • func (plw *PodListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)
• type RunListWatcher
  • func (lw *RunListWatcher) List(options metav1.ListOptions) (runtime.Object, error)
  • func (lw *RunListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)
• type WorkspaceListWatcher
  • func (lw *WorkspaceListWatcher) List(options metav1.ListOptions) (runtime.Object, error)
  • func (lw *WorkspaceListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)

Variables

var (
	KubeClient = getKubeClient
	StokClient = getStokClient
)

For testing purposes

var (
	Attach = attachToPod
)

var (
	GetLogs = getLogs
)

Functions

func AttachFallbackToLogs

func AttachFallbackToLogs(pod *corev1.Pod, logstream io.ReadCloser) error

Attach to pod, falling back to streaming logs on error

func DeleteWaitAnnotationKey

func DeleteWaitAnnotationKey(obj metav1.Object)

Delete annotation WaitAnnotationKey, giving the runner the signal to start

func GetNamespacedName

func GetNamespacedName(obj metav1.Object) types.NamespacedName

func PodConnect

func PodConnect(ctx context.Context, kc kubernetes.Interface, namespace, name string, release func() error) error

PodConnect does the following: 1. Gets log stream of stdout of pod 2. Attaches to TTY of pod, failing that it falls back to copying log stream to user stdout 3. Releases the 'hold' on the pod, i.e. deletes an annotation, informing the pod runner that it can invoke the terraform process, safe in the knowledge that the user is at the very least streaming logs

Types

type PodListWatcher

type PodListWatcher struct {
	Client    kubernetes.Interface
	Namespace string
	Name      string
}

func (*PodListWatcher) List

func (plw *PodListWatcher) List(options metav1.ListOptions) (runtime.Object, error)

func (*PodListWatcher) Watch

func (plw *PodListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)

type RunListWatcher

type RunListWatcher struct {
	Client    stokclient.Interface
	Namespace string
	Name      string
}

func (*RunListWatcher) List

func (lw *RunListWatcher) List(options metav1.ListOptions) (runtime.Object, error)

func (*RunListWatcher) Watch

func (lw *RunListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)

type WorkspaceListWatcher

type WorkspaceListWatcher struct {
	Client    stokclient.Interface
	Namespace string
	Name      string
}

func (*WorkspaceListWatcher) List

func (lw *WorkspaceListWatcher) List(options metav1.ListOptions) (runtime.Object, error)

func (*WorkspaceListWatcher) Watch

func (lw *WorkspaceListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)