pub fn source(self, cluster: &MiniCluster) -> Self {
        let org_id = cluster.org_id();
        let bucket_id = cluster.bucket_id();
        let org_id = u64::from_str_radix(org_id, 16).unwrap();
        let bucket_id = u64::from_str_radix(bucket_id, 16).unwrap();

        let partition_id = u64::from(u32::MAX);
        let read_source = ReadSource {
            org_id,
            bucket_id,
            partition_id,
        };

        // Do the magic to-any conversion
        let mut d = bytes::BytesMut::new();
        read_source.encode(&mut d).unwrap();
        let read_source = generated_types::google::protobuf::Any {
            type_url: "/TODO".to_string(),
            value: d.freeze(),
        };

        Self {
            read_source: Some(read_source),
            ..self
        }
    }
/// Creates the appropriate `Any` protobuf magic for a read source with the cluster's org and
/// bucket name
Creates the appropriate `Any` protobuf magic for a read source with the cluster's org and
bucket name
Creates the appropriate ` Any ` protobuf magic for a read source with the cluster ' s org and bucket name
pub fn source(self, cluster: &MiniCluster) -> Self {
        let org_id = cluster.org_id();
        let bucket_id = cluster.bucket_id();
        let org_id = u64::from_str_radix(org_id, 16).unwrap();
        let bucket_id = u64::from_str_radix(bucket_id, 16).unwrap();
        let partition_id = u64::from(u32::MAX);
        let read_source = ReadSource {
            org_id,
            bucket_id,
            partition_id,
        };
        // Do the magic to-any conversion
        let mut d = bytes::BytesMut::new();
        read_source.encode(&mut d).unwrap();
        let read_source = generated_types::google::protobuf::Any {
            type_url: "/TODO".to_string(),
            value: d.freeze(),
        };
        Self {
            read_source: Some(read_source),
            ..self
        }
    }
pub fn source ( self , cluster : & MiniCluster ) -> Self { let org_id = cluster . org_id ( ) ; let bucket_id = cluster . bucket_id ( ) ; let org_id = u64 :: from_str_radix ( org_id , 16 ) . unwrap ( ) ; let bucket_id = u64 :: from_str_radix ( bucket_id , 16 ) . unwrap ( ) ; let partition_id = u64 :: from ( u32 :: MAX ) ; let read_source = ReadSource { org_id , bucket_id , partition_id , } ; // Do the magic to-any conversion let mut d = bytes :: BytesMut :: new ( ) ; read_source . encode ( & mut d ) . unwrap ( ) ; let read_source = generated_types :: google :: protobuf :: Any { type_url : " " . to_string ( ) , value : d . freeze ( ) , } ; Self { read_source : Some ( read_source ) , .. self } }
Creates the appropriate `Any` protobuf magic for a read source with the cluster's org and
bucket name
Creates the appropriate ` Any ` protobuf magic for a read source with the cluster ' s org and bucket name
self
cluster
&MiniCluster
self
cluster
&MiniCluster