filter

Documentation

Index

• Constants
• type ContainerFilter
• type KubernetesContainerFilter
  • func NewKubernetesContainerFilter(namespace string, podGetterApi corev1.PodsGetter) *KubernetesContainerFilter
  • func (filter *KubernetesContainerFilter) FindContainerInfo(identifier *model.MachineIdentifier) (containerInfo *model.ContainerInfo, err error)
  • func (filter *KubernetesContainerFilter) GetContainer(name string) (containerInfo *model.ContainerInfo, err error)
  • func (filter *KubernetesContainerFilter) GetContainerList() (containersInfo []*model.ContainerInfo, err error)

Constants

const (
	MachineNameEnvVar = "CHE_MACHINE_NAME"
)

Types

type ContainerFilter

type ContainerFilter interface {
	// Return list Che workspace containers.
	GetContainerList() (containersInfo []*model.ContainerInfo, err error)

	// Find container information by Che specific container identifier.
	// Return error in case fail filter operation.
	FindContainerInfo(identifier *model.MachineIdentifier) (containerInfo *model.ContainerInfo, err error)
}

Container filter to find container information if it's possible by unique Che specific container name.

type KubernetesContainerFilter

type KubernetesContainerFilter struct {
	ContainerFilter
	// contains filtered or unexported fields
}

Kubernetes specific implementation of the container information filter. Eclipse CHE workspace pod could be located in the same namespace like Eclipse CHE master or in the separated namespace. Kubernetes container filter search workspace pod by workspaceId and then search container information inside pod by machine name.

func NewKubernetesContainerFilter

func NewKubernetesContainerFilter(namespace string, podGetterApi corev1.PodsGetter) *KubernetesContainerFilter

Create new kubernetes container filter.

func (*KubernetesContainerFilter) FindContainerInfo

func (filter *KubernetesContainerFilter) FindContainerInfo(identifier *model.MachineIdentifier) (containerInfo *model.ContainerInfo, err error)

Find container information by pod label: "wsId" and container environment variables "machineName".

func (*KubernetesContainerFilter) GetContainer

func (filter *KubernetesContainerFilter) GetContainer(name string) (containerInfo *model.ContainerInfo, err error)

func (*KubernetesContainerFilter) GetContainerList

func (filter *KubernetesContainerFilter) GetContainerList() (containersInfo []*model.ContainerInfo, err error)