Trait DataSinkProxyInterface

pub trait DataSinkProxyInterface: Send + Sync {
    type ReadAssetResponseFut: Future<Output = Result<DataSinkReadAssetResult, Error>> + Send;
    type WriteAssetResponseFut: Future<Output = Result<i32, Error>> + Send;
    type WriteFirmwareResponseFut: Future<Output = Result<WriteFirmwareResult, Error>> + Send;
    type ReadFirmwareResponseFut: Future<Output = Result<DataSinkReadFirmwareResult, Error>> + Send;
    type WriteVolumesResponseFut: Future<Output = Result<i32, Error>> + Send;
    type WriteOpaqueVolumeResponseFut: Future<Output = Result<DataSinkWriteOpaqueVolumeResult, Error>> + Send;
    type WriteSparseVolumeResponseFut: Future<Output = Result<DataSinkWriteSparseVolumeResult, Error>> + Send;
    type FlushResponseFut: Future<Output = Result<i32, Error>> + Send;

    // Required methods
    fn read_asset(
        &self,
        configuration: Configuration,
        asset: Asset,
    ) -> Self::ReadAssetResponseFut;
    fn write_asset(
        &self,
        configuration: Configuration,
        asset: Asset,
        payload: Buffer,
    ) -> Self::WriteAssetResponseFut;
    fn write_firmware(
        &self,
        configuration: Configuration,
        type_: &str,
        payload: Buffer,
    ) -> Self::WriteFirmwareResponseFut;
    fn read_firmware(
        &self,
        configuration: Configuration,
        type_: &str,
    ) -> Self::ReadFirmwareResponseFut;
    fn write_volumes(
        &self,
        payload: ClientEnd<PayloadStreamMarker>,
    ) -> Self::WriteVolumesResponseFut;
    fn write_opaque_volume(
        &self,
        payload: Buffer,
    ) -> Self::WriteOpaqueVolumeResponseFut;
    fn write_sparse_volume(
        &self,
        payload: Buffer,
    ) -> Self::WriteSparseVolumeResponseFut;
    fn flush(&self) -> Self::FlushResponseFut;
}

Required Associated Types

type ReadAssetResponseFut: Future<Output = Result<DataSinkReadAssetResult, Error>> + Send

type WriteAssetResponseFut: Future<Output = Result<i32, Error>> + Send

type WriteFirmwareResponseFut: Future<Output = Result<WriteFirmwareResult, Error>> + Send

type ReadFirmwareResponseFut: Future<Output = Result<DataSinkReadFirmwareResult, Error>> + Send

type WriteVolumesResponseFut: Future<Output = Result<i32, Error>> + Send

type WriteOpaqueVolumeResponseFut: Future<Output = Result<DataSinkWriteOpaqueVolumeResult, Error>> + Send

type WriteSparseVolumeResponseFut: Future<Output = Result<DataSinkWriteSparseVolumeResult, Error>> + Send

type FlushResponseFut: Future<Output = Result<i32, Error>> + Send

Required Methods

fn read_asset( &self, configuration: Configuration, asset: Asset, ) -> Self::ReadAssetResponseFut

fn write_asset( &self, configuration: Configuration, asset: Asset, payload: Buffer, ) -> Self::WriteAssetResponseFut

fn write_firmware( &self, configuration: Configuration, type_: &str, payload: Buffer, ) -> Self::WriteFirmwareResponseFut

fn read_firmware( &self, configuration: Configuration, type_: &str, ) -> Self::ReadFirmwareResponseFut

fn write_volumes( &self, payload: ClientEnd<PayloadStreamMarker>, ) -> Self::WriteVolumesResponseFut

fn write_opaque_volume( &self, payload: Buffer, ) -> Self::WriteOpaqueVolumeResponseFut

fn write_sparse_volume( &self, payload: Buffer, ) -> Self::WriteSparseVolumeResponseFut

fn flush(&self) -> Self::FlushResponseFut

Implementors

impl DataSinkProxyInterface for DataSinkProxy

type ReadAssetResponseFut = QueryResponseFut<Result<Buffer, i32>>

type WriteAssetResponseFut = QueryResponseFut<i32>

type WriteFirmwareResponseFut = QueryResponseFut<WriteFirmwareResult>

type ReadFirmwareResponseFut = QueryResponseFut<Result<Buffer, i32>>

type WriteVolumesResponseFut = QueryResponseFut<i32>

type WriteOpaqueVolumeResponseFut = QueryResponseFut<Result<(), i32>>

type WriteSparseVolumeResponseFut = QueryResponseFut<Result<(), i32>>

type FlushResponseFut = QueryResponseFut<i32>