kubernetes/test/e2e/dra/test-driver/app/kubeletplugin.go

type ExamplePlugin …

type GRPCCall …

type ClaimID …

type Device …

var _ …

// getJSONFilePath returns the absolute path where CDI file is/should be.
func (ex *ExamplePlugin) getJSONFilePath(claimUID string, requestName string) string { … }

type FileOperations …

// StartPlugin sets up the servers that are necessary for a DRA kubelet plugin.
func StartPlugin(ctx context.Context, cdiDir, driverName string, kubeClient kubernetes.Interface, nodeName string, fileOps FileOperations, opts ...kubeletplugin.Option) (*ExamplePlugin, error) { … }

// Stop ensures that all servers are stopped and resources freed.
func (ex *ExamplePlugin) Stop() { … }

func (ex *ExamplePlugin) IsRegistered() bool { … }

// BlockNodePrepareResources locks blockPrepareResourcesMutex and returns unlocking function for it
func (ex *ExamplePlugin) BlockNodePrepareResources() func() { … }

// BlockNodeUnprepareResources locks blockUnprepareResourcesMutex and returns unlocking function for it
func (ex *ExamplePlugin) BlockNodeUnprepareResources() func() { … }

// SetNodePrepareResourcesFailureMode sets the failure mode for NodePrepareResources call
// and returns a function to unset the failure mode
func (ex *ExamplePlugin) SetNodePrepareResourcesFailureMode() func() { … }

func (ex *ExamplePlugin) getPrepareResourcesFailure() error { … }

// SetNodeUnprepareResourcesFailureMode sets the failure mode for NodeUnprepareResources call
// and returns a function to unset the failure mode
func (ex *ExamplePlugin) SetNodeUnprepareResourcesFailureMode() func() { … }

func (ex *ExamplePlugin) getUnprepareResourcesFailure() error { … }

// NodePrepareResource ensures that the CDI file(s) (one per request) for the claim exists. It uses
// a deterministic name to simplify NodeUnprepareResource (no need to remember
// or discover the name) and idempotency (when called again, the file simply
// gets written again).
func (ex *ExamplePlugin) nodePrepareResource(ctx context.Context, claimReq *drapb.Claim) ([]Device, error) { … }

func extractParameters(parameters runtime.RawExtension, env *map[string]string, admin bool) error { … }

func (ex *ExamplePlugin) NodePrepareResources(ctx context.Context, req *drapb.NodePrepareResourcesRequest) (*drapb.NodePrepareResourcesResponse, error) { … }

// NodeUnprepareResource removes the CDI file created by
// NodePrepareResource. It's idempotent, therefore it is not an error when that
// file is already gone.
func (ex *ExamplePlugin) nodeUnprepareResource(ctx context.Context, claimReq *drapb.Claim) error { … }

func (ex *ExamplePlugin) NodeUnprepareResources(ctx context.Context, req *drapb.NodeUnprepareResourcesRequest) (*drapb.NodeUnprepareResourcesResponse, error) { … }

func (ex *ExamplePlugin) GetPreparedResources() []ClaimID { … }

func (ex *ExamplePlugin) recordGRPCCall(ctx context.Context, req interface{ … }

func (ex *ExamplePlugin) recordGRPCStream(srv interface{ … }

func (ex *ExamplePlugin) GetGRPCCalls() []GRPCCall { … }

// CountCalls counts GRPC calls with the given method suffix.
func (ex *ExamplePlugin) CountCalls(methodSuffix string) int { … }