Struct tvix_store::pathinfoservice::bigtable::BigtablePathInfoService

pub struct BigtablePathInfoService {
    instance_name: String,
    client: BigTable,
    params: BigtableParameters,
}

Provides a PathInfoService implementation using Bigtable as an underlying K/V store.

Data format

We use Bigtable as a plain K/V store. The row key is the digest of the store path, in hexlower. Inside the row, we currently have a single column/cell, again using the hexlower store path digest. Its value is the PathInfo message, serialized in canonical protobuf. We currently only populate this column.

Listing is ranging over all rows, and calculate_nar is returning a “unimplemented” error.

Fields

instance_name: String

client: BigTable

params: BigtableParameters

Implementations

impl BigtablePathInfoService

pub async fn connect( instance_name: String, params: BigtableParameters, ) -> Result<Self, Error>

Trait Implementations

impl Clone for BigtablePathInfoService

fn clone(&self) -> BigtablePathInfoService

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl PathInfoService for BigtablePathInfoService

fn get<'life0, 'async_trait>( &'life0 self, digest: [u8; 20], ) -> Pin<Box<dyn Future<Output = Result<Option<PathInfo>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieve a PathInfo message by the output digest.

fn put<'life0, 'async_trait>( &'life0 self, path_info: PathInfo, ) -> Pin<Box<dyn Future<Output = Result<PathInfo, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store a PathInfo message. Implementations MUST call validate and reject invalid messages.

fn list(&self) -> BoxStream<'static, Result<PathInfo, Error>>

Iterate over all PathInfo objects in the store. Implementations can decide to disallow listing.

fn nar_calculation_service(&self) -> Option<Box<dyn NarCalculationService>>

Returns a (more) suitable NarCalculationService. This can be used to offload NAR calculation to the remote side.