b.r.RemoteStreamSource(vf_repository.StreamSource) : class documentation

Part of bzrlib.remote View In Hierarchy

Stream data from a remote server.
Method get_stream Undocumented
Method get_stream_for_missing_keys Undocumented
Method missing_parents_chain Chain multiple streams together to handle stacking.
Method missing_parents_rev_handler Undocumented
Method _real_stream Get a stream for search from repo.
Method _get_stream Core worker to get a stream from repo for search.

Inherited from StreamSource:

Method __init__ Create a StreamSource streaming from from_repository.
Method delta_on_metadata Return True if delta's are permitted on metadata streams.
Method inventory_fetch_order Undocumented
Method _fetch_revision_texts Undocumented
Method _generate_root_texts This will be called by get_stream between fetching weave texts and
Method _rich_root_upgrade Undocumented
Method _get_inventory_stream Undocumented
Method _get_simple_inventory_stream Undocumented
Method _get_convertable_inventory_stream Undocumented
Method _stream_invs_as_deltas Return a stream of inventory-deltas for the given rev ids.
def get_stream(self, search):
Undocumented
def get_stream_for_missing_keys(self, missing_keys):
Undocumented
def _real_stream(self, repo, search):
Get a stream for search from repo.

This never called RemoteStreamSource.get_stream, and is a heler for RemoteStreamSource._get_stream to allow getting a stream reliably whether fallback back because of old servers or trying to stream from a non-RemoteRepository (which the stacked support code will do).

def _get_stream(self, repo, search):
Core worker to get a stream from repo for search.

This is used by both get_stream and the stacking support logic. It deliberately gets a stream for repo which does not need to be self.from_repository. In the event that repo is not Remote, or cannot do a smart stream, a fallback is made to the generic repository._get_stream() interface, via self._real_stream.

In the event of stacking, streams from _get_stream will not contain all the data for search - this is normal (see get_stream).

ParametersrepoA repository.
searchA search.
def missing_parents_chain(self, search, sources):
Chain multiple streams together to handle stacking.
ParameterssearchThe overall search to satisfy with streams.
sourcesA list of Repository objects to query.
def missing_parents_rev_handler(self, substream):
Undocumented
API Documentation for Bazaar, generated by pydoctor at 2022-06-16 00:25:16.