package dra

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

Index ¶

• Constants
• type Driver
• func NewDriver(f *framework.Framework, nodes *Nodes, configureResources func() app.Resources) *Driver
• func (d *Driver) CallCount(m MethodInstance) int64
• func (d *Driver) Fail(m MethodInstance, injectError bool)
• func (d *Driver) Nodenames() (nodenames []string)
• func (d *Driver) SetUp(nodes *Nodes, resources app.Resources)
• func (d *Driver) TearDown()
• type MethodInstance
• type Nodes
• func NewNodes(f *framework.Framework, minNodes, maxNodes int) *Nodes

Constants ¶

const (
	NodePrepareResourceMethod   = "/v1alpha1.Node/NodePrepareResource"
	NodeUnprepareResourceMethod = "/v1alpha1.Node/NodeUnprepareResource"
)

Types ¶

type Driver ¶

type Driver struct {
	NameSuffix string
	Controller *app.ExampleController
	Name       string
	Nodes      map[string]*app.ExamplePlugin
	// contains filtered or unexported fields
}

func NewDriver ¶

func NewDriver(f *framework.Framework, nodes *Nodes, configureResources func() app.Resources) *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) Nodenames ¶

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

func (*Driver) SetUp ¶

func (d *Driver) SetUp(nodes *Nodes, resources app.Resources)

func (*Driver) TearDown ¶

func (d *Driver) TearDown()

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 ¶