package dra

import "k8s.io/kubernetes/test/e2e/dra"

Index ¶

• Constants
• type Driver
• func NewDriver(f *framework.Framework, nodes *Nodes, configureResources func() app.Resources, devicesPerNode ...map[string]map[resourceapi.QualifiedName]resourceapi.DeviceAttribute) *Driver
• func (d *Driver) CallCount(m MethodInstance) int64
• func (d *Driver) Fail(m MethodInstance, injectError bool)
• func (d *Driver) IsGone(ctx context.Context)
• func (d *Driver) Nodenames() (nodenames []string)
• func (d *Driver) SetUp(nodes *Nodes, resources app.Resources, devicesPerNode ...map[string]map[resourceapi.QualifiedName]resourceapi.DeviceAttribute)
• func (d *Driver) TearDown()
• type KubeletPlugin
• type MethodInstance
• type Nodes
• func NewNodes(f *framework.Framework, minNodes, maxNodes int) *Nodes

Constants ¶

const (
	NodePrepareResourcesMethod   = "/v1alpha3.Node/NodePrepareResources"
	NodeUnprepareResourcesMethod = "/v1alpha3.Node/NodeUnprepareResources"
)

Types ¶

type Driver ¶

type Driver struct {
	NameSuffix string
	Controller *app.ExampleController
	Name       string

	// Nodes contains entries for each node selected for a test when the test runs.
	// In addition, there is one entry for a fictional node.
	Nodes map[string]KubeletPlugin

	NodeV1alpha3 bool
	// contains filtered or unexported fields
}

func NewDriver ¶

func NewDriver(f *framework.Framework, nodes *Nodes, configureResources func() app.Resources, devicesPerNode ...map[string]map[resourceapi.QualifiedName]resourceapi.DeviceAttribute) *Driver

NewDriver sets up controller (as client of the cluster) and kubelet plugin (via proxy) before the test runs. It cleans up after the test.

func (*Driver) CallCount ¶

func (d *Driver) CallCount(m MethodInstance) int64

func (*Driver) Fail ¶

func (d *Driver) Fail(m MethodInstance, injectError bool)

func (*Driver) IsGone ¶

func (d *Driver) IsGone(ctx context.Context)

func (*Driver) Nodenames ¶

func (d *Driver) Nodenames() (nodenames []string)

func (*Driver) SetUp ¶

func (d *Driver) SetUp(nodes *Nodes, resources app.Resources, devicesPerNode ...map[string]map[resourceapi.QualifiedName]resourceapi.DeviceAttribute)

func (*Driver) TearDown ¶

func (d *Driver) TearDown()

type KubeletPlugin ¶

type KubeletPlugin struct {
	*app.ExamplePlugin
	ClientSet kubernetes.Interface
}

type MethodInstance ¶

type MethodInstance struct {
	Nodename   string
	FullMethod string
}

type Nodes ¶

type Nodes struct {
	NodeNames []string
}

func NewNodes ¶

func NewNodes(f *framework.Framework, minNodes, maxNodes int) *Nodes

NewNodes selects nodes to run the test on.

Source Files ¶

deploy.go dra.go

Directories ¶