volume

type MockVolumePlugin ¶

type MockVolumePlugin struct{}

MockVolumePlugin is a simple implementation of VolumePluginControlPlane and VolumePluginWorkerPlane for testing purposes.

It creates a subdirectory on the host for each actor. This only persists data if the actor is scheduled to the same host.

This plugin also does not cleanup the subdirectories, so that has to be done by the test infrastructure.

The control-plane methods (Create/Delete/Attach/DetachVolume) are intentionally stateless no-ops: they log and succeed, with no bookkeeping of which volumes exist or which node they're attached to. Nothing reads that state - the e2e test that exercises this plugin verifies the volume actually worked by checking the real file MountVolume writes on the node, not by querying the plugin. A stateful mock used to track this in an in-process map, which broke once ate-api-server ran multiple replicas (whichever replica handled a given RPC had no idea what a different replica's map contained); going stateless removes the bug class instead of syncing the state, since nothing actually needs it.

func NewMockVolumePlugin() *MockVolumePlugin

func (p *MockVolumePlugin) AttachVolume(ctx context.Context, volumeID string, node string) error

func (p *MockVolumePlugin) CreateVolume(ctx context.Context, name string, capacity string, storageClass string, parameters map[string]string) (string, map[string]string, error)

func (p *MockVolumePlugin) DeleteVolume(ctx context.Context, volumeID string) error

func (p *MockVolumePlugin) DetachVolume(ctx context.Context, volumeID string, node string) error

func (p *MockVolumePlugin) DriverName(ctx context.Context) (string, error)

func (p *MockVolumePlugin) MountVolume(ctx context.Context, volumeID string, targetPath string, volumeContext map[string]string) error

func (p *MockVolumePlugin) UnmountVolume(ctx context.Context, volumeID string, targetPath string) error

type VolumePluginControlPlane ¶

type VolumePluginControlPlane interface {
	DriverName(ctx context.Context) (string, error)
	CreateVolume(ctx context.Context, name string, capacity string, driverName string, parameters map[string]string) (volumeID string, volumeContext map[string]string, err error)
	DeleteVolume(ctx context.Context, volumeID string) error
	AttachVolume(ctx context.Context, volumeID string, node string) error
	DetachVolume(ctx context.Context, volumeID string, node string) error
}

VolumePluginControlPlane abstracts storage operations performed on the control plane.

type VolumePluginWorkerPlane ¶

type VolumePluginWorkerPlane interface {
	MountVolume(ctx context.Context, volumeID string, targetPath string, volumeContext map[string]string) error
	UnmountVolume(ctx context.Context, volumeID string, targetPath string) error
}

VolumePluginWorkerPlane abstracts storage operations performed on worker nodes.