type ExamplePlugin …
type GRPCCall …
type ClaimID …
type Device …
var _ …
func (ex *ExamplePlugin) getJSONFilePath(claimUID string, requestName string) string { … }
type FileOperations …
func StartPlugin(ctx context.Context, cdiDir, driverName string, kubeClient kubernetes.Interface, nodeName string, fileOps FileOperations, opts ...kubeletplugin.Option) (*ExamplePlugin, error) { … }
func (ex *ExamplePlugin) Stop() { … }
func (ex *ExamplePlugin) IsRegistered() bool { … }
func (ex *ExamplePlugin) BlockNodePrepareResources() func() { … }
func (ex *ExamplePlugin) BlockNodeUnprepareResources() func() { … }
func (ex *ExamplePlugin) SetNodePrepareResourcesFailureMode() func() { … }
func (ex *ExamplePlugin) getPrepareResourcesFailure() error { … }
func (ex *ExamplePlugin) SetNodeUnprepareResourcesFailureMode() func() { … }
func (ex *ExamplePlugin) getUnprepareResourcesFailure() error { … }
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) { … }
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 { … }
func (ex *ExamplePlugin) CountCalls(methodSuffix string) int { … }