server

type DebugService struct {
	// contains filtered or unexported fields
}

type LSVDDisk interface {
	// Close closes the disk
	Close(ctx context.Context) error

	// Size returns the disk size in bytes
	Size() int64

	// HandleNBD handles NBD protocol on the given connection
	HandleNBD(ctx context.Context, conn net.Conn, clientFile *os.File) error
}

type MountController struct {
	// contains filtered or unexported fields
}

type MountOps interface {
	// CreateDir creates a directory with the specified permissions
	CreateDir(path string, perm os.FileMode) error

	// RemoveFile removes a file
	RemoveFile(path string) error

	// NBDLoopback sets up an NBD loopback device
	// Returns: index, conn, clientFile, cleanup function, error
	NBDLoopback(ctx context.Context, sizeBytes uint64) (uint32, net.Conn, *os.File, func() error, error)

	// NBDStatus checks the status of an NBD device
	NBDStatus(idx uint32) error

	// NBDDisconnect disconnects an NBD device
	NBDDisconnect(idx uint32) error

	// CreateDeviceNode creates a block device node
	CreateDeviceNode(path string, nbdIndex uint32) error

	// Mount mounts a device at the specified path
	Mount(device, mountPath, filesystem string, readOnly bool) error

	// Unmount unmounts a path
	Unmount(path string) error

	// IsMounted checks if a path is a mount point
	IsMounted(path string) bool

	// IsFormatted checks if a device has a filesystem
	IsFormatted(device, filesystem string) (bool, error)

	// FormatDevice formats a device with the specified filesystem
	FormatDevice(ctx context.Context, device, filesystem string) error

	// OpenLSVDDisk opens an LSVD disk for the given volume.
	// If remoteOnly is true, the disk uses only remote cloud storage (no local).
	// The leaseNonce is passed to the segment access for write operations.
	OpenLSVDDisk(ctx context.Context, diskPath, volumeId string, remoteOnly bool, leaseNonce string) (LSVDDisk, error)

	// AcquireVolumeLease acquires a lease from the cloud for exclusive access.
	// Returns the lease nonce, or empty string if cloud auth is not configured.
	AcquireVolumeLease(ctx context.Context, volumeId string, metadata map[string]any) (string, error)

	// ReleaseVolumeLease releases a lease from the cloud.
	// Does nothing if cloud auth is not configured or nonce is empty.
	ReleaseVolumeLease(ctx context.Context, volumeId, nonce string) error
}

type MountState struct {
	// EntityId is the ID of the lsvd_mount entity
	EntityId string `json:"entity_id"`

	// VolumeId is the ID of the lsvd_volume entity
	VolumeId string `json:"volume_id"`

	// NbdIndex is the NBD device index
	NbdIndex uint32 `json:"nbd_index"`

	// DevicePath is the path to the NBD device node
	DevicePath string `json:"device_path"`

	// MountPath is where the volume is mounted
	MountPath string `json:"mount_path"`

	// Mounted indicates if the volume is currently mounted
	Mounted bool `json:"mounted"`

	// ReadOnly indicates if the mount is read-only
	ReadOnly bool `json:"read_only"`

	// LeaseNonce is the volume lease nonce from remote Disk API
	LeaseNonce string `json:"lease_nonce,omitempty"`
}

type Server struct {
	// contains filtered or unexported fields
}

type ServerOption func(*serverOptions)

type ServiceConfig struct {
	// ClientCert is the PEM-encoded client certificate
	ClientCert []byte `json:"client_cert,omitempty"`
	// ClientKey is the PEM-encoded client private key
	ClientKey []byte `json:"client_key,omitempty"`
	// CloudURL is the miren.cloud API URL for disk replication
	CloudURL string `json:"cloud_url,omitempty"`
	// PrivateKey is the PEM-encoded private key for cloud authentication
	PrivateKey string `json:"private_key,omitempty"`
}

type State struct {
	Volumes map[string]*VolumeState `json:"volumes"`
	Mounts  map[string]*MountState  `json:"mounts"`
	// contains filtered or unexported fields
}

type VolumeController struct {
	// contains filtered or unexported fields
}

type VolumeOps interface {
	// CreateVolumeDir creates the directory for a volume
	CreateVolumeDir(path string) error

	// RemoveVolumeDir removes a volume directory and all its contents
	RemoveVolumeDir(path string) error

	// VolumePathExists checks if a volume path exists
	VolumePathExists(path string) bool

	// InitLSVDVolume initializes an LSVD volume at the given path.
	// Returns the actual volume ID used (which may differ from the input when
	// cloud auth is configured and the server generates the ID).
	// If remoteOnly is true, the volume is only initialized on the remote cloud
	// (no local storage).
	InitLSVDVolume(ctx context.Context, path, volumeId string, size units.Bytes, metadata map[string]any, remoteOnly bool) (string, error)
}

type VolumeState struct {
	// EntityId is the ID of the lsvd_volume entity
	EntityId string `json:"entity_id"`

	// VolumeId is the LSVD volume identifier
	VolumeId string `json:"volume_id"`

	// Name is the human-readable name (from parent disk)
	Name string `json:"name,omitempty"`

	// DiskPath is the path to the volume data directory
	DiskPath string `json:"disk_path"`

	// SizeBytes is the volume size
	SizeBytes int64 `json:"size_bytes"`

	// Filesystem type (ext4, xfs, btrfs)
	Filesystem string `json:"filesystem"`

	// RemoteOnly indicates if this uses only remote storage
	RemoteOnly bool `json:"remote_only"`
}