File Coverage

blib/lib/Sys/Async/Virt/StorageVol.pm

Criterion	Covered	Total	%
statement	26	103	25.2
branch			n/a
condition	0	14	0.0
subroutine	9	25	36.0
pod	14	16	87.5
total	49	158	31.0

####################################################################
#
#     This file was generated using XDR::Parse version v1.0.1
#                   and LibVirt version v12.1.0
#
#      Don't edit this file, use the source template instead
#
#                 ANY CHANGES HERE WILL BE LOST !
#
####################################################################


use v5.26;
use warnings;
use experimental 'signatures';
use Future::AsyncAwait;
use Object::Pad;

class Sys::Async::Virt::StorageVol v0.6.1;

use Carp qw(croak);
use Log::Any qw($log);

use Protocol::Sys::Virt::Remote::XDR v12.1.0;
my $remote = 'Protocol::Sys::Virt::Remote::XDR';

use constant {
    FILE                   => 0,
    BLOCK                  => 1,
    DIR                    => 2,
    NETWORK                => 3,
    NETDIR                 => 4,
    PLOOP                  => 5,
    DELETE_NORMAL          => 0,
    DELETE_ZEROED          => 1 << 0,
    DELETE_WITH_SNAPSHOTS  => 1 << 1,
    WIPE_ALG_ZERO          => 0,
    WIPE_ALG_NNSA          => 1,
    WIPE_ALG_DOD           => 2,
    WIPE_ALG_BSI           => 3,
    WIPE_ALG_GUTMANN       => 4,
    WIPE_ALG_SCHNEIER      => 5,
    WIPE_ALG_PFITZNER7     => 6,
    WIPE_ALG_PFITZNER33    => 7,
    WIPE_ALG_RANDOM        => 8,
    WIPE_ALG_TRIM          => 9,
    USE_ALLOCATION         => 0,
    GET_PHYSICAL           => 1 << 0,
    DOWNLOAD_SPARSE_STREAM => 1 << 0,
    UPLOAD_SPARSE_STREAM   => 1 << 0,
    RESIZE_ALLOCATE        => 1 << 0,
    RESIZE_DELTA           => 1 << 1,
    RESIZE_SHRINK          => 1 << 2,
};


field $_rpc_id :param :reader;
field $_client :param :reader;

method key() {
    return $_rpc_id->{key};
}

method name() {
    return $_rpc_id->{name};
}

method pool() {
    return $_client->_storage_pool_instance( $_rpc_id->{pool} );
}

method delete($flags = 0) {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_DELETE,
        { vol => $_rpc_id, flags => $flags // 0 }, empty => 1 );
}

method download($offset, $length, $flags = 0) {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_DOWNLOAD,
        { vol => $_rpc_id, offset => $offset, length => $length, flags => $flags // 0 }, stream => 'read', empty => 1 );
}

method get_info() {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_GET_INFO,
        { vol => $_rpc_id } );
}

method get_info_flags($flags = 0) {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_GET_INFO_FLAGS,
        { vol => $_rpc_id, flags => $flags // 0 } );
}

async method get_path() {
    return await $_client->_call(
        $remote->PROC_STORAGE_VOL_GET_PATH,
        { vol => $_rpc_id }, unwrap => 'name' );
}

async method get_xml_desc($flags = 0) {
    return await $_client->_call(
        $remote->PROC_STORAGE_VOL_GET_XML_DESC,
        { vol => $_rpc_id, flags => $flags // 0 }, unwrap => 'xml' );
}

async method pool_lookup_by_volume() {
    return await $_client->_call(
        $remote->PROC_STORAGE_POOL_LOOKUP_BY_VOLUME,
        { vol => $_rpc_id }, unwrap => 'pool' );
}

method resize($capacity, $flags = 0) {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_RESIZE,
        { vol => $_rpc_id, capacity => $capacity, flags => $flags // 0 }, empty => 1 );
}

method upload($offset, $length, $flags = 0) {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_UPLOAD,
        { vol => $_rpc_id, offset => $offset, length => $length, flags => $flags // 0 }, stream => 'write', empty => 1 );
}

method wipe($flags = 0) {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_WIPE,
        { vol => $_rpc_id, flags => $flags // 0 }, empty => 1 );
}

method wipe_pattern($algorithm, $flags = 0) {
    return $_client->_call(
        $remote->PROC_STORAGE_VOL_WIPE_PATTERN,
        { vol => $_rpc_id, algorithm => $algorithm, flags => $flags // 0 }, empty => 1 );
}



1;


__END__