cmd

Documentation

Index

• Variables
• func CheckResourceExists(ctx context.Context, rc client.Client, name, namespace string, ...) (bool, error)
• func Execute(args []string) int
• func FlagToEnvVarName(f *pflag.Flag) string
• type RunnerReporter
  • func (r *RunnerReporter) Handler(ctx context.Context, events <-chan ctrl.Request) error
  • func (r *RunnerReporter) MatchingObj(obj interface{}) bool
  • func (r *RunnerReporter) Register(c cache.Cache) (cache.Informer, error)
• type WorkspacePodReporter
  • func (r *WorkspacePodReporter) Handler(ctx context.Context, events <-chan ctrl.Request) error
  • func (r *WorkspacePodReporter) MatchingObj(obj interface{}) bool
  • func (r *WorkspacePodReporter) Register(cache runtimecache.Cache) (runtimecache.Informer, error)
• type WorkspaceReporter
  • func (r *WorkspaceReporter) Handler(ctx context.Context, events <-chan ctrl.Request) error
  • func (r *WorkspaceReporter) MatchingObj(obj interface{}) bool
  • func (r *WorkspaceReporter) Register(cache runtimecache.Cache) (runtimecache.Informer, error)

Variables

var ErrPodCompleted = fmt.Errorf("pod ran to completion")

ErrPodCompleted is returned by PodRunning or PodContainerRunning to indicate that the pod has already reached completed state.

var WorkspaceTimeoutErr = fmt.Errorf("timed out waiting for workspace to be in a healthy condition")

Functions

func CheckResourceExists

func CheckResourceExists(ctx context.Context, rc client.Client, name, namespace string, obj runtime.Object) (bool, error)

func Execute

func Execute(args []string) int

func FlagToEnvVarName

func FlagToEnvVarName(f *pflag.Flag) string

Types

type RunnerReporter

type RunnerReporter struct {
	k8s.Client
	// contains filtered or unexported fields
}

func (*RunnerReporter) Handler

func (r *RunnerReporter) Handler(ctx context.Context, events <-chan ctrl.Request) error

func (*RunnerReporter) MatchingObj

func (r *RunnerReporter) MatchingObj(obj interface{}) bool

func (*RunnerReporter) Register

func (r *RunnerReporter) Register(c cache.Cache) (cache.Informer, error)

type WorkspacePodReporter

type WorkspacePodReporter struct {
	k8s.Client
	Id string
}

func (*WorkspacePodReporter) Handler

func (r *WorkspacePodReporter) Handler(ctx context.Context, events <-chan ctrl.Request) error

func (*WorkspacePodReporter) MatchingObj

func (r *WorkspacePodReporter) MatchingObj(obj interface{}) bool

func (*WorkspacePodReporter) Register

func (r *WorkspacePodReporter) Register(cache runtimecache.Cache) (runtimecache.Informer, error)

type WorkspaceReporter

type WorkspaceReporter struct {
	k8s.Client
	Id    string
	CmdId string
}

func (*WorkspaceReporter) Handler

func (r *WorkspaceReporter) Handler(ctx context.Context, events <-chan ctrl.Request) error

func (*WorkspaceReporter) MatchingObj

func (r *WorkspaceReporter) MatchingObj(obj interface{}) bool

func (*WorkspaceReporter) Register

func (r *WorkspaceReporter) Register(cache runtimecache.Cache) (runtimecache.Informer, error)