dulwich.fastexport.GitImportProcessor

class documentation

class GitImportProcessor(processor.ImportProcessor):

An import processor that imports into a Git repository using Dulwich.

Method	`__init__`	Initialize GitImportProcessor.
Method	`blob_handler`	Process a BlobCommand.
Method	`checkpoint_handler`	Process a CheckpointCommand.
Method	`commit_handler`	Process a CommitCommand.
Method	`feature_handler`	Process a FeatureCommand.
Method	`import_stream`	Import from a fast-import stream.
Method	`lookup_object`	Look up an object by reference or marker.
Method	`progress_handler`	Process a ProgressCommand.
Method	`reset_handler`	Process a ResetCommand.
Method	`tag_handler`	Process a TagCommand.
Instance Variable	`last_commit`	Undocumented
Instance Variable	`markers`	Undocumented
Instance Variable	`repo`	Undocumented
Method	`_reset_base`	Undocumented
Instance Variable	`_contents`	Undocumented

def __init__(self, repo: BaseRepo, params: Any | None = None, verbose: bool = False, outf: BinaryIO | None = None): ¶

Initialize GitImportProcessor.

Parameters
repo:`BaseRepo`	Repository to import into
params:`Any \| None`	Import parameters
verbose:`bool`	Whether to enable verbose output
outf:`BinaryIO \| None`	Output file for verbose messages

def blob_handler(self, cmd: commands.BlobCommand): ¶

Process a BlobCommand.

def checkpoint_handler(self, cmd: commands.CheckpointCommand): ¶

Process a CheckpointCommand.

def commit_handler(self, cmd: commands.CommitCommand): ¶

Process a CommitCommand.

def feature_handler(self, cmd: commands.FeatureCommand): ¶

Process a FeatureCommand.

def import_stream(self, stream: BinaryIO) -> dict[bytes, ObjectID]: ¶

Import from a fast-import stream.

Parameters
stream:`BinaryIO`	Stream to import from

Returns
`dict[bytes, ObjectID]`	Dictionary of markers to object IDs

def lookup_object(self, objectish: bytes) -> ObjectID: ¶

Look up an object by reference or marker.

Parameters
objectish:`bytes`	Object reference or marker

Returns
`ObjectID`	Object ID

def progress_handler(self, cmd: commands.ProgressCommand): ¶

Process a ProgressCommand.

def reset_handler(self, cmd: commands.ResetCommand): ¶

Process a ResetCommand.

def tag_handler(self, cmd: commands.TagCommand): ¶

Process a TagCommand.

last_commit = ¶

Undocumented

markers: dict[bytes, ObjectID] = ¶

Undocumented

repo = ¶

Undocumented

def _reset_base(self, commit_id: ObjectID): ¶

Undocumented

_contents: dict[bytes, tuple[int, bytes]] = ¶

Undocumented