Skip to content

Commit ddb8925

Browse files
committed
chunker relocate and rename
1 parent 238a7b0 commit ddb8925

4 files changed

Lines changed: 13 additions & 13 deletions

File tree

prime_backup/action/helpers/blob_pre_calc_result.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@
33
from typing import List, IO
44

55
from prime_backup.types.chunk_method import ChunkMethod
6+
from prime_backup.types.chunker import PrettyChunk
67
from prime_backup.utils import misc_utils, hash_utils
7-
from prime_backup.utils.chunker import PrettyChunk
88
from prime_backup.utils.hash_utils import SizeAndHash
99

1010

prime_backup/types/chunk_method.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -2,24 +2,24 @@
22
from pathlib import Path
33
from typing import Optional, IO, TYPE_CHECKING
44

5-
from prime_backup.types.chunker_factory import ChunkerFactory, CDCChunkerFactory, FixedSizeChunkerFactory
6-
from prime_backup.utils.chunker import Chunker
5+
from prime_backup.types.chunker import Chunker
6+
from prime_backup.types.chunker_definition import ChunkerDefinition, CDCChunkerDefinition, FixedSizeChunkerDefinition
77
from prime_backup.utils.path_like import PathLike
88

99

1010
class ChunkMethod(enum.Enum):
1111
# Content-Defined Chunking (CDC)
12-
cdc_32k = CDCChunkerFactory(avg_size=32 * 1024, min_size=8 * 1024, max_size=256 * 1024)
13-
cdc_128k = CDCChunkerFactory(avg_size=128 * 1024, min_size=64 * 1024, max_size=1024 * 1024)
12+
cdc_32k = CDCChunkerDefinition(avg_size=32 * 1024, min_size=8 * 1024, max_size=256 * 1024)
13+
cdc_128k = CDCChunkerDefinition(avg_size=128 * 1024, min_size=64 * 1024, max_size=1024 * 1024)
1414
cdc = cdc_32k
1515

1616
# Fixed-Size Chunking
17-
fixed_4k = FixedSizeChunkerFactory(4 * 1024)
18-
fixed_32k = FixedSizeChunkerFactory(32 * 1024)
19-
fixed_128k = FixedSizeChunkerFactory(128 * 1024)
17+
fixed_4k = FixedSizeChunkerDefinition(4 * 1024)
18+
fixed_32k = FixedSizeChunkerDefinition(32 * 1024)
19+
fixed_128k = FixedSizeChunkerDefinition(128 * 1024)
2020

2121
if TYPE_CHECKING:
22-
value: ChunkerFactory
22+
value: ChunkerDefinition
2323

2424
@classmethod
2525
def get_for_file(cls, file_path: PathLike, file_size: int) -> Optional['ChunkMethod']:
Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,10 @@
55

66
from typing_extensions import override
77

8-
from prime_backup.utils.chunker import Chunker, CDCFileChunker, CDCStreamChunker, FixedSizeFileChunker, FixedSizeStreamChunker, CDCChunkerConfig
8+
from prime_backup.types.chunker import Chunker, CDCFileChunker, CDCStreamChunker, FixedSizeFileChunker, FixedSizeStreamChunker, CDCChunkerConfig
99

1010

11-
class ChunkerFactory(ABC):
11+
class ChunkerDefinition(ABC):
1212
@abstractmethod
1313
def create_file_chunker(self, file_path: Path, need_entire_file_hash: bool) -> Chunker:
1414
...
@@ -19,7 +19,7 @@ def create_stream_chunker(self, stream, need_entire_file_hash: bool) -> Chunker:
1919

2020

2121
@dataclasses.dataclass(frozen=True)
22-
class CDCChunkerFactory(ChunkerFactory):
22+
class CDCChunkerDefinition(ChunkerDefinition):
2323
avg_size: int
2424
min_size: int
2525
max_size: int
@@ -38,7 +38,7 @@ def create_stream_chunker(self, stream: IO[bytes], need_entire_file_hash: bool)
3838

3939

4040
@dataclasses.dataclass(frozen=True)
41-
class FixedSizeChunkerFactory(ChunkerFactory):
41+
class FixedSizeChunkerDefinition(ChunkerDefinition):
4242
chunk_size: int
4343

4444
@override

0 commit comments

Comments
 (0)