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) IsGone(ctx context.Context)
• 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       = "/v1alpha2.Node/NodePrepareResource"
	NodePrepareResourcesMethod      = "/v1alpha3.Node/NodePrepareResources"
	NodeUnprepareResourceMethod     = "/v1alpha2.Node/NodeUnprepareResource"
	NodeUnprepareResourcesMethod    = "/v1alpha3.Node/NodeUnprepareResources"
	NodeListAndWatchResourcesMethod = "/v1alpha3.Node/NodeListAndWatchResources"
)

Types ¶

type Driver ¶

type Driver struct {
	NameSuffix string
	Controller *app.ExampleController
	Name       string
	Nodes      map[string]*app.ExamplePlugin

	NodeV1alpha2, NodeV1alpha3 bool
	// 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) 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)

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 ¶