def source.error

mylsm-lsm-store@0.6.0.1 · src/transfer/BackupOwnerPolicy.bend:21

import Base
import mylsm-lsm-store@0.6.0.1/src/transfer/Backup.bend as Backup

21# Maps every remote cursor failure into the backup source error domain.
22def source.error(error: OwnerError) -> Backup.Error:
23  match error:
24    case ConnectHost{code, message}:
25      Backup.SourceFailure{code, message}
26    case ConnectUnsupported{}:
27      Backup.UnsupportedPlatform{}
28    case ReadHost{code, message}:
29      Backup.SourceFailure{code, message}
30    case ReadUnsupported{}:
31      Backup.UnsupportedPlatform{}
32    case ReadFailure{}:
33      Backup.SourceFailure{5, "owner snapshot cursor read failed"}
34    case CommitHost{code, message}:
35      Backup.SourceFailure{code, message}
36    case CommitFailure{}:
37      Backup.SourceFailure{5, "owner snapshot cursor state is uncertain"}
38    case FrameTooLarge{}:
39      Backup.SourceFailure{75, "owner cursor frame exceeded limit"}
40    case StaleOwner{}:
41      Backup.SourceFailure{116, "owner cursor generation is stale"}
42    case CorrelationMismatch{}:
43      Backup.SourceFailure{71, "owner cursor correlation mismatch"}
44    case MalformedResponse{}:
45      Backup.SourceFailure{71, "owner cursor response is malformed"}
46    case RequestIdsExhausted{}:
47      Backup.SourceFailure{75, "owner cursor request ids exhausted"}
48    case OwnerRejected{}:
49      Backup.SourceFailure{5, "owner rejected snapshot cursor read"}
50    case UnsupportedPlatform{}: Backup.UnsupportedPlatform{}