b.v.StreamSink(object) : class documentation

Part of bzrlib.vf_repository View In Hierarchy

Known subclasses: bzrlib.remote.RemoteStreamSink

An object that can insert a stream into a repository.

This interface handles the complexity of reserialising inventories and revisions from different formats, and allows unidirectional insertion into stacked repositories without looking for the missing basis parents beforehand.

Method	__init__	Undocumented
Method	insert_stream	Insert a stream's content into the target repository.
Method	insert_stream_without_locking	Insert a stream's content into the target repository.
Method	finished	Undocumented
Method	_extract_and_insert_inventory_deltas	Undocumented
Method	_extract_and_insert_inventories	Generate a new inventory versionedfile in target, converting data.
Method	_extract_and_insert_revisions	Undocumented

def __init__(self, target_repo):

Undocumented

def insert_stream(self, stream, src_format, resume_tokens):

overridden in bzrlib.remote.RemoteStreamSink

Insert a stream's content into the target repository.

Parameters	src_format	a bzr repository format.
Returns	a list of resume tokens and an iterable of keys additional items required before the insertion can be completed.

def insert_stream_without_locking(self, stream, src_format, is_resume=False):

Insert a stream's content into the target repository.

This assumes that you already have a locked repository and an active write group.

Parameters	src_format	a bzr repository format.
	is_resume	Passed down to get_missing_parent_inventories to indicate if we should be checking for missing texts at the same time.
Returns	A set of keys that are missing.

def _extract_and_insert_inventory_deltas(self, substream, serializer):

Undocumented

def _extract_and_insert_inventories(self, substream, serializer, parse_delta=None):

Generate a new inventory versionedfile in target, converting data.

The inventory is retrieved from the source, (deserializing it), and stored in the target (reserializing it in a different format).

def _extract_and_insert_revisions(self, substream, serializer):

Undocumented

def finished(self):

Undocumented

API Documentation for Bazaar, generated by pydoctor at 2022-06-16 00:25:16.