informer

Documentation

Index

• type Informer
• type K8sInformer
  • func NewK8sInformer(log *zap.Logger, informer cache.SharedIndexInformer) (*K8sInformer, error)
  • func (i *K8sInformer) List() []*ParsedWorkspace
  • func (i *K8sInformer) Start(ctx context.Context) error
• type MockInformer
  • func NewMockInformer() *MockInformer
  • func (i *MockInformer) List() []*ParsedWorkspace
  • func (i *MockInformer) Start(ctx context.Context) error
• type ParsedWorkspace

Types

type Informer

type Informer interface {
	Start(ctx context.Context) error
	List() []*ParsedWorkspace
}

type K8sInformer

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

func NewK8sInformer

func NewK8sInformer(log *zap.Logger, informer cache.SharedIndexInformer) (*K8sInformer, error)

func (*K8sInformer) List

func (i *K8sInformer) List() []*ParsedWorkspace

func (*K8sInformer) Start

func (i *K8sInformer) Start(ctx context.Context) error

type MockInformer

type MockInformer struct {
	Resources map[string]*ParsedWorkspace
}

func NewMockInformer

func NewMockInformer() *MockInformer

func (*MockInformer) List

func (i *MockInformer) List() []*ParsedWorkspace

func (*MockInformer) Start

func (i *MockInformer) Start(ctx context.Context) error

type ParsedWorkspace

type ParsedWorkspace struct {
	Name              string
	Namespace         string
	ResourceVersion   string
	K8sDeploymentInfo map[string]interface{}
}

ParsedWorkspace is our internal view on the full unstructured.Unstructured k8s resource. We use ParsedWorkspace for logic like checking if the latest change has been persisted or whether we terminated the workspace