SundayT1998/milvus-client/errors

README
U
Client
U
ClientError
U
Code
U
CollectionDescription
U
CollectionLoadState
U
Config
U
ConsistencyLevel
U
CreateCollectionOption
U
CreatePartitionOption
U
DeleteOption
U
DescribeCollectionOption
U
DropCollectionOption
U
DropPartitionOption
U
FlushOption
U
FlushTask
U
GetFlushStateOption
U
GetLoadStateOption
U
HasPartitionOption
U
ListCollectionsOption
U
ListPartitionsOption
U
LoadCollectionOption
U
LoadPartitionsOption
U
LoadState
U
LoadTask
U
MutationResult
U
QueryOption
U
QueryResult
U
ReleaseCollectionOption
U
ReleasePartitionsOption
U
RpcError
U
SearchHit
U
SearchOption
U
SearchResult
U
Unary
U
WriteColumn
U
WriteOption
V
client_config
V
client_error_code
V
default_consistency_level
V
default_port
V
default_timeout_millis
V
is_client_error_deadline_exceeded
V
is_client_error_retryable
V
is_deadline_exceeded
V
is_retryable
V
is_transport_failure
V
new_client
V
with_address
V
with_db_name
V
with_gzip
V
with_timeout_millis
V
with_token

SundayT1998/milvus-client/errors does not have a README file

MerError

pub suberror MerError {
  RpcError(code~ : Int, legacy_code~ : @SundayT1998/milvus-client/proto/milvus/proto/common.ErrorCode
ErrorCode, message~ : String, detail~ : String, retriable~ : Bool, input~ : Bool)
}

Milvus RPC 错误的客户端模型。

与上游 merr.RPCError 一一对应：同一个 Milvus code 视为同一个错误，双轨错误码（modern code + legacy ErrorCode）整体保留，不简化。

构造用带标签的语法；典型路径是 from_status，需要手工造错时用预定义值加 wrap_*：

let err = @errors.wrap_err_collection_not_found("demo")
raise err

也可以直接构造：

raise RpcError(
  code=100,
  legacy_code=@common.ErrorCode::CollectionNotExists,
  message="collection not found",
  detail="collection not found",
  retriable=false,
  input=false,
)

impl Show for MerError

MerError::code

source

fn MerError::code(self : MerError?) -> Int

取错误码。与上游 merr.Code 一致；None 等价于上游的 err == nil。

MerError::detail

source

fn MerError::detail(self : MerError?) -> String

取服务端下发的详细错误信息。

MerError::is_input_error

source

fn MerError::is_input_error(self : MerError?) -> Bool

服务端是否把该错误归类为输入错误。

MerError::is_retryable

source

fn MerError::is_retryable(self : MerError?) -> Bool

服务端是否标记该错误可重试。这正是上游 IsRetryableErr 的语义：只看 Status.retriable，不做本地猜测。

MerError::legacy_code

source

fn MerError::legacy_code(self : MerError?) -> @SundayT1998/milvus-client/proto/milvus/proto/common.ErrorCode
ErrorCode

取 legacy 错误码。None 视为 Success。

MerError::same_code

source

fn MerError::same_code(self : MerError, other : MerError) -> Bool

依据 Milvus code 判断两个错误是否同类，对应上游 RPCError.Is （errors.Is 靠 code 匹配，而不是靠错误文本）。

canceled_code

source

let canceled_code : Int

Milvus 客户端错误码常量。

code 是 modern 数值码（Status.code），canceled / timeout 是上游 merr 为 Go context 错误保留的本地码，不属于 Milvus 服务端。

err_collection_not_found

source

fn err_collection_not_found() -> MerError

err_collection_schema_mismatch

source

fn err_collection_schema_mismatch() -> MerError

err_index_not_found

source

fn err_index_not_found() -> MerError

err_parameter_invalid

source

fn err_parameter_invalid() -> MerError

err_parameter_missing

source

fn err_parameter_missing() -> MerError

err_service_internal

source

fn err_service_internal() -> MerError

err_service_not_ready

source

fn err_service_not_ready() -> MerError

预定义错误值，与上游 merr 的命名变量一一对应。

这些值用于 same_code 比对与包装（wrap_*），语义与 Go 版的 ErrCollectionNotFound 等完全一致。

err_service_unimplemented

source

fn err_service_unimplemented() -> MerError

err_unexpected

source

fn err_unexpected() -> MerError

未知错误的兜底值，对应上游 errUnexpected（码 65535）。

error_code

source

fn error_code(err : MerError?) -> Int

取错误码。与上游 merr.Code 一致；None 等价于上游的 err == nil。

error_detail

source

fn error_detail(err : MerError?) -> String

取服务端下发的详细错误信息。

error_legacy_code

source

fn error_legacy_code(err : MerError?) -> @SundayT1998/milvus-client/proto/milvus/proto/common.ErrorCode
ErrorCode

取 legacy 错误码。None 视为 Success。

from_status

source

fn from_status(status : @SundayT1998/milvus-client/proto/milvus/proto/common.Status
Status) -> MerError?

Milvus Status → MerError，对应上游 merr.Error。

双轨码的补齐规则与上游完全一致：

code == 0 时用 legacy 推导 modern 码
legacy 为 Success 时用 modern 码反推 legacy

成功状态返回 None（上游返回 nil）。reason 与 detail 都过一遍脱敏。

input_error_flag_key

source

let input_error_flag_key : String

Status.extra_info 中标记「输入错误」的键，与上游 inputErrorFlagKey 一致。

is_input_error

source

fn is_input_error(err : MerError?) -> Bool

服务端是否把该错误归类为输入错误。

is_ok

source

fn is_ok(status : @SundayT1998/milvus-client/proto/milvus/proto/common.Status
Status?) -> Bool

Status 是否代表成功，对应上游 merr.Ok。

两个字段都要满足：error_code == Success 且 code == 0。 None 视为成功（上游对 nil Status 返回 true）。

is_retryable_err

source

fn is_retryable_err(err : MerError?) -> Bool

服务端是否标记该错误可重试。这正是上游 IsRetryableErr 的语义：只看 Status.retriable，不做本地猜测。

这是给 retry 中间件看的唯一判据，等价于上游 merr.IsRetryableErr。

legacy_code_from_modern

source

fn legacy_code_from_modern(code : Int) -> @SundayT1998/milvus-client/proto/milvus/proto/common.ErrorCode
ErrorCode

modern 数值码 → legacy ErrorCode，逐条照搬上游 legacyCodeFromModern。

未命中的数值码落到 UnexpectedError。

modern_code_from_legacy

source

fn modern_code_from_legacy(legacy : @SundayT1998/milvus-client/proto/milvus/proto/common.ErrorCode
ErrorCode) -> Int

legacy ErrorCode → modern 数值码，逐条照搬上游 modernCodeFromLegacy。

未命中的 legacy 码落到 unexpected_code。

redact

source

fn redact(input : String) -> String

错误信息脱敏。

验收要求「错误信息中不泄露 token 等敏感 metadata」。Milvus 的 Status.detail 与 reason 由服务端拼装，可能回显请求侧的认证头或连接串。上游 Go 版没有这层，这里补上，且是纯函数，不影响任何判定语义。

规则：

Authorization: Bearer xxx / 裸 Bearer xxx → Bearer ***
token=xxx / password=xxx / api_key=xxx 等 key<分隔符>value → 值打码
URL userinfo（scheme://user:pass@host）里的口令段 → ***

非敏感内容（主机名、端口、库名、字段名）原样保留，保证可调试。

success

source

fn success(reason? : String) -> @SundayT1998/milvus-client/proto/milvus/proto/common.Status
Status

成功状态，对应上游 merr.Success。

timeout_code

source

let timeout_code : Int

to_status

source

fn to_status(err : MerError?) -> @SundayT1998/milvus-client/proto/milvus/proto/common.Status
Status

把 MerError? 还原成 Status，对应上游 merr.Status。

主要给 mock 与测试用；None 返回成功 Status。

unexpected_code

source

let unexpected_code : Int

上游 unexpectedCode：(1 << 16) - 1，未知错误统一落到这里。

wrap_err_collection_not_found

source

fn wrap_err_collection_not_found(collection : String, messages? : Array[String]) -> MerError

wrap_err_collection_schema_mismatch

source

fn wrap_err_collection_schema_mismatch(collection : String, messages? : Array[String]) -> MerError

wrap_err_index_not_found

source

fn wrap_err_index_not_found(index_name : String, messages? : Array[String]) -> MerError

wrap_err_parameter_invalid

source

fn wrap_err_parameter_invalid(expected : String, actual : String, messages? : Array[String]) -> MerError

ErrParameterInvalid 带 expected / actual 的包装。

wrap_err_parameter_invalid_err

source

fn wrap_err_parameter_invalid_err(err : String, message : String) -> MerError

把任意错误文本重新归为 ErrParameterInvalid，只保留文本、不保留原 code （上游 WrapErrParameterInvalidErr）。

wrap_err_parameter_invalid_msg

source

fn wrap_err_parameter_invalid_msg(message : String) -> MerError

ErrParameterInvalid 的自由文本包装（上游 WrapErrParameterInvalidMsg）。

wrap_err_parameter_missing_msg

source

fn wrap_err_parameter_missing_msg(message : String) -> MerError

wrap_err_service_internal

source

fn wrap_err_service_internal(reason : String, messages? : Array[String]) -> MerError

ErrServiceInternal 带 reason 的包装。

wrap_err_service_not_ready

source

fn wrap_err_service_not_ready(role : String, session_id : Int64, state : String, messages? : Array[String]) -> MerError

ErrServiceNotReady 带 role / sessionID / state 的包装。

Source Files

Site source Report issue Packages Build queue Skills Statistics

#MerError

#MerError::code

#MerError::detail

#MerError::is_input_error

#MerError::is_retryable

#MerError::legacy_code

#MerError::same_code

#canceled_code

#err_collection_not_found

#err_collection_schema_mismatch

#err_index_not_found

#err_parameter_invalid

#err_parameter_missing

#err_service_internal

#err_service_not_ready

#err_service_unimplemented

#err_unexpected

#error_code

#error_detail

#error_legacy_code

#from_status

#input_error_flag_key

#is_input_error

#is_ok

#is_retryable_err

#legacy_code_from_modern

#modern_code_from_legacy

#redact

#success

#timeout_code

#to_status

#unexpected_code

#wrap_err_collection_not_found

#wrap_err_collection_schema_mismatch

#wrap_err_index_not_found

#wrap_err_parameter_invalid

#wrap_err_parameter_invalid_err

#wrap_err_parameter_invalid_msg

#wrap_err_parameter_missing_msg

#wrap_err_service_internal

#wrap_err_service_not_ready

Source Files

MerError

MerError::code

MerError::detail

MerError::is_input_error

MerError::is_retryable

MerError::legacy_code

MerError::same_code

canceled_code

err_collection_not_found

err_collection_schema_mismatch

err_index_not_found

err_parameter_invalid

err_parameter_missing

err_service_internal

err_service_not_ready

err_service_unimplemented

err_unexpected

error_code

error_detail

error_legacy_code

from_status

input_error_flag_key

is_input_error

is_ok

is_retryable_err

legacy_code_from_modern

modern_code_from_legacy

redact

success

timeout_code

to_status

unexpected_code

wrap_err_collection_not_found

wrap_err_collection_schema_mismatch

wrap_err_index_not_found

wrap_err_parameter_invalid

wrap_err_parameter_invalid_err

wrap_err_parameter_invalid_msg

wrap_err_parameter_missing_msg

wrap_err_service_internal

wrap_err_service_not_ready