disk

type DiskController struct {
	Log *slog.Logger
	EAC *entityserver_v1alpha.EntityAccessClient
	// contains filtered or unexported fields
}

type DiskLeaseController struct {
	Log *slog.Logger
	EAC *entityserver_v1alpha.EntityAccessClient
	// contains filtered or unexported fields
}

type DiskWatchController struct {
	Log *slog.Logger
	EAC *entityserver_v1alpha.EntityAccessClient

	// Reference to the disk lease controller to enqueue lease reconciliations
	LeaseController *controller.ReconcileController
}

type LsvdClient interface {
	// CreateVolume creates a new LSVD volume (calls both CreateVolumeInSegmentAccess and InitializeDisk)
	// Returns the volume ID that was actually created.
	CreateVolume(ctx context.Context, sizeGb int64, filesystem string) (string, error)

	// CreateVolumeInSegmentAccess creates a volume only in SegmentAccess (no disk initialization).
	// Returns the volume ID that was created (server-generated for remote, locally-generated for local-only).
	CreateVolumeInSegmentAccess(ctx context.Context, diskName string, sizeGb int64, filesystem string) (string, error)

	// InitializeDisk initializes lsvd.NewDisk for an existing volume in SegmentAccess
	InitializeDisk(ctx context.Context, volumeId string, filesystem string) error

	// UnprovisionVolume unprovisions an LSVD volume (does not delete data)
	UnprovisionVolume(ctx context.Context, volumeId string) error

	// MountVolume mounts an LSVD volume to a mount path (requires InitializeDisk to be called first)
	MountVolume(ctx context.Context, volumeId string, mountPath string, readOnly bool) error

	// UnmountVolume unmounts an LSVD volume
	UnmountVolume(ctx context.Context, volumeId string) error

	// IsVolumeMounted checks if a volume is currently mounted
	IsVolumeMounted(ctx context.Context, volumeId string) (bool, error)

	// GetVolumeInfo returns information about a volume
	GetVolumeInfo(ctx context.Context, volumeId string) (*VolumeInfo, error)

	// ListVolumes lists all volumes
	ListVolumes(ctx context.Context) ([]string, error)

	// AcquireVolumeLease acquires a volume lease from the remote Disk API.
	// Returns the lease nonce if successful, empty string if not using remote storage.
	// nodeId and appId are included as metadata for the lease.
	AcquireVolumeLease(ctx context.Context, volumeId, nodeId, appId string) (string, error)

	// ReleaseVolumeLease releases a volume lease from the remote Disk API.
	ReleaseVolumeLease(ctx context.Context, volumeId string, nonce string) error
}

type LsvdClientOption func(*lsvdClientImpl)

type VolumeInfo struct {
	ID         string
	Name       string
	SizeBytes  int64
	Filesystem string
	MountPath  string
	UUID       string
	Status     VolumeStatus
}

type VolumeStatus string