BackupOwnerCursorIo.source.error: def of mylsm-lsm-store@0.6.0.1
Import: import mylsm-lsm-store@0.6.0.1/src/transfer/BackupOwnerCursorIo.bend as BackupOwnerCursorIo
Lines 56-88 of mylsm-lsm-store@0.6.0.1/src/transfer/BackupOwnerCursorIo.bend: https://jend.leeeet.dev/read.txt?path=mylsm-lsm-store@0.6.0.1/src/transfer/BackupOwnerCursorIo.bend&start_line=56&end_line=88

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend as Client
import mylsm-lsm-store@0.6.0.1/src/coordinator/Io.bend as ClientIo
import mylsm-lsm-store@0.6.0.1/src/coordinator/UnixSocketIo.bend as ClientSocket
import mylsm-lsm-store@0.6.0.1/src/transfer/BackupOwnerPolicy.bend as Policy
import mylsm-lsm-store@0.6.0.1/src/transfer/Backup.bend as Backup

# Converts socket and protocol errors into the pure owner-error policy.
def source.error(error: Client.Error) -> Backup.Error:
  match error:
    case Client.ConnectFailure{ClientSocket.Host{code, message}}:
      Policy.source.error(Policy.ConnectHost{code, message})
    case Client.ConnectFailure{ClientSocket.UnsupportedPlatform{}}:
      Policy.source.error(Policy.ConnectUnsupported{})
    case Client.ConnectFailure{ClientSocket.Transient{code}}:
      Policy.source.error(Policy.ConnectHost{code,
        "owner socket connection was interrupted"})
    case Client.RetryRead{ClientIo.Host{code, message}}:
      Policy.source.error(Policy.ReadHost{code, message})
    case Client.RetryRead{ClientIo.UnsupportedPlatform{}}:
      Policy.source.error(Policy.ReadUnsupported{})
    case Client.RetryRead{ClientIo.Transient{code}}:
      Policy.source.error(Policy.ReadHost{code,
        "owner socket read was interrupted"})
    case Client.RetryRead{_}: Policy.source.error(Policy.ReadFailure{})
    case Client.CommitUnknown{ClientIo.Host{code, message}}:
      Policy.source.error(Policy.CommitHost{code, message})
    case Client.CommitUnknown{ClientIo.Transient{code}}:
      Policy.source.error(Policy.CommitHost{code,
        "owner mutation response was interrupted"})
    case Client.CommitUnknown{_}: Policy.source.error(Policy.CommitFailure{})
    case Client.FrameTooLarge{}: Policy.source.error(Policy.FrameTooLarge{})
    case Client.StaleOwner{}: Policy.source.error(Policy.StaleOwner{})
    case Client.CorrelationMismatch{}:
      Policy.source.error(Policy.CorrelationMismatch{})
    case Client.MalformedResponse{}:
      Policy.source.error(Policy.MalformedResponse{})
    case Client.RequestIdsExhausted{}:
      Policy.source.error(Policy.RequestIdsExhausted{})
    case Client.OwnerRejected{_}: Policy.source.error(Policy.OwnerRejected{})

Uses (6):
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend&name=Error
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/Io.bend&name=Error
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/coordinator/UnixSocketIo.bend&name=Error
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/transfer/Backup.bend&name=Error
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/transfer/BackupOwnerPolicy.bend&name=OwnerError
  https://jend.leeeet.dev/definition.txt?path=mylsm-lsm-store@0.6.0.1/src/transfer/BackupOwnerPolicy.bend&name=source.error