▽

Package dra

Constants

const (
    NodePrepareResourceMethod       = "/v1alpha2.Node/NodePrepareResource"
    NodePrepareResourcesMethod      = "/v1alpha3.Node/NodePrepareResources"
    NodeUnprepareResourceMethod     = "/v1alpha2.Node/NodeUnprepareResource"
    NodeUnprepareResourcesMethod    = "/v1alpha3.Node/NodeUnprepareResources"
    NodeListAndWatchResourcesMethod = "/v1alpha3.Node/NodeListAndWatchResources"
)

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.

Subdirectories