kubeapis

Documentation

Index

• type DeviceLocator
  • func NewKubeletDeviceLocator(resource string) DeviceLocator
• type KubeletDeviceLocator
  • func (k *KubeletDeviceLocator) Close() error
  • func (k *KubeletDeviceLocator) List() ([]*types.PodInfo, error)
  • func (k *KubeletDeviceLocator) Locate(devices *types.Device) (*types.PodContainer, error)
• type PodSitter
  • func (p *PodSitter) GetNodeFromApiServer(name string) (*v1.Node, error)
  • func (p *PodSitter) GetPod(namespace, name string) (*v1.Pod, error)
  • func (p *PodSitter) GetPodFromApiServer(namespace, name string) (*v1.Pod, error)
  • func (p *PodSitter) HasSynced() bool
  • func (p *PodSitter) Start()
• type Sitter
  • func NewSitter(client *kubernetes.Clientset, nodeName string) Sitter

Types

type DeviceLocator

type DeviceLocator interface {
	Locate(devices *types.Device) (*types.PodContainer, error)
	List() ([]*types.PodInfo, error)
	Close() error
}

func NewKubeletDeviceLocator

func NewKubeletDeviceLocator(resource string) DeviceLocator

type KubeletDeviceLocator

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

func (*KubeletDeviceLocator) Close

func (k *KubeletDeviceLocator) Close() error

func (*KubeletDeviceLocator) List

func (k *KubeletDeviceLocator) List() ([]*types.PodInfo, error)

func (*KubeletDeviceLocator) Locate

func (k *KubeletDeviceLocator) Locate(devices *types.Device) (*types.PodContainer, error)

type PodSitter

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

func (*PodSitter) GetNodeFromApiServer

func (p *PodSitter) GetNodeFromApiServer(name string) (*v1.Node, error)

func (*PodSitter) GetPod

func (p *PodSitter) GetPod(namespace, name string) (*v1.Pod, error)

func (*PodSitter) GetPodFromApiServer

func (p *PodSitter) GetPodFromApiServer(namespace, name string) (*v1.Pod, error)

func (*PodSitter) HasSynced

func (p *PodSitter) HasSynced() bool

func (*PodSitter) Start

func (p *PodSitter) Start()

type Sitter

type Sitter interface {
	Start()
	GetPod(namespace, name string) (*v1.Pod, error)
	GetPodFromApiServer(namespace, name string) (*v1.Pod, error)
	GetNodeFromApiServer(name string) (*v1.Node, error)
	HasSynced() bool
}

func NewSitter

func NewSitter(client *kubernetes.Clientset, nodeName string) Sitter