driver

Documentation

Index

• Constants
• type Environment
• type KubeletPlugin
• type MemoryDriver
  • func Start(ctx context.Context, env Environment) (*MemoryDriver, error)
  • func (mdrv *MemoryDriver) CreateContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container) (*api.ContainerAdjustment, []*api.ContainerUpdate, error)
  • func (mdrv *MemoryDriver) HandleError(ctx context.Context, err error, msg string)
  • func (mdrv *MemoryDriver) PrepareResourceClaims(ctx context.Context, claims []*resourceapi.ResourceClaim) (map[k8stypes.UID]kubeletplugin.PrepareResult, error)
  • func (mdrv *MemoryDriver) PublishResources(ctx context.Context)
  • func (mdrv *MemoryDriver) RemoveContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container) error
  • func (mdrv *MemoryDriver) RemovePodSandbox(ctx context.Context, pod *api.PodSandbox) error
  • func (mdrv *MemoryDriver) RunPodSandbox(ctx context.Context, pod *api.PodSandbox) error
  • func (mdrv *MemoryDriver) Shutdown(ctx context.Context)
  • func (mdrv *MemoryDriver) Stop()
  • func (mdrv *MemoryDriver) StopContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container) ([]*api.ContainerUpdate, error)
  • func (mdrv *MemoryDriver) StopPodSandbox(ctx context.Context, pod *api.PodSandbox) error
  • func (mdrv *MemoryDriver) Synchronize(ctx context.Context, pods []*api.PodSandbox, containers []*api.Container) ([]*api.ContainerUpdate, error)
  • func (mdrv *MemoryDriver) UnprepareResourceClaims(ctx context.Context, claims []kubeletplugin.NamespacedObject) (map[k8stypes.UID]error, error)
  • func (mdrv *MemoryDriver) UpdateContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container, ...) ([]*api.ContainerUpdate, error)
  • func (mdrv *MemoryDriver) UpdatePodSandbox(ctx context.Context, pod *api.PodSandbox, over *api.LinuxResources, ...) error
• type SysinfoDiscoverer
• type SysinfoVerifier

Constants

const (
	Name = "dra.memory"
)

Types

type Environment

type Environment struct {
	Logger      logr.Logger
	DriverName  string
	NodeName    string
	Clientset   kubernetes.Interface
	SysVerifier SysinfoVerifier
	SysRoot     string
	CgroupMount string
}

type KubeletPlugin

type KubeletPlugin interface {
	PublishResources(context.Context, resourceslice.DriverResources) error
	Stop()
}

KubeletPlugin is an interface that describes the methods used from kubeletplugin.Helper.

type MemoryDriver

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

func Start

func Start(ctx context.Context, env Environment) (*MemoryDriver, error)

Start creates and starts a new MemoryDriver.

func (*MemoryDriver) CreateContainer

func (mdrv *MemoryDriver) CreateContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container) (*api.ContainerAdjustment, []*api.ContainerUpdate, error)

func (*MemoryDriver) HandleError

func (mdrv *MemoryDriver) HandleError(ctx context.Context, err error, msg string)

func (*MemoryDriver) PrepareResourceClaims

func (mdrv *MemoryDriver) PrepareResourceClaims(ctx context.Context, claims []*resourceapi.ResourceClaim) (map[k8stypes.UID]kubeletplugin.PrepareResult, error)

func (*MemoryDriver) PublishResources

func (mdrv *MemoryDriver) PublishResources(ctx context.Context)

func (*MemoryDriver) RemoveContainer

func (mdrv *MemoryDriver) RemoveContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container) error

func (*MemoryDriver) RemovePodSandbox

func (mdrv *MemoryDriver) RemovePodSandbox(ctx context.Context, pod *api.PodSandbox) error

func (*MemoryDriver) RunPodSandbox

func (mdrv *MemoryDriver) RunPodSandbox(ctx context.Context, pod *api.PodSandbox) error

func (*MemoryDriver) Shutdown

func (mdrv *MemoryDriver) Shutdown(ctx context.Context)

Shutdown is called when the runtime is shutting down.

func (*MemoryDriver) Stop

func (mdrv *MemoryDriver) Stop()

func (*MemoryDriver) StopContainer

func (mdrv *MemoryDriver) StopContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container) ([]*api.ContainerUpdate, error)

func (*MemoryDriver) StopPodSandbox

func (mdrv *MemoryDriver) StopPodSandbox(ctx context.Context, pod *api.PodSandbox) error

func (*MemoryDriver) Synchronize

func (mdrv *MemoryDriver) Synchronize(ctx context.Context, pods []*api.PodSandbox, containers []*api.Container) ([]*api.ContainerUpdate, error)

func (*MemoryDriver) UnprepareResourceClaims

func (mdrv *MemoryDriver) UnprepareResourceClaims(ctx context.Context, claims []kubeletplugin.NamespacedObject) (map[k8stypes.UID]error, error)

UnprepareResourceClaims is called by the kubelet to unprepare the resources for a claim.

func (*MemoryDriver) UpdateContainer

func (mdrv *MemoryDriver) UpdateContainer(ctx context.Context, pod *api.PodSandbox, ctr *api.Container, res *api.LinuxResources) ([]*api.ContainerUpdate, error)

func (*MemoryDriver) UpdatePodSandbox

func (mdrv *MemoryDriver) UpdatePodSandbox(ctx context.Context, pod *api.PodSandbox, over *api.LinuxResources, res *api.LinuxResources) error

type SysinfoDiscoverer

type SysinfoDiscoverer interface {
	Discover() (sysinfo.MachineData, error)
}

type SysinfoVerifier

type SysinfoVerifier interface {
	Validate() error
}