EasyRpc.RpcCall (EasyRpc v1.0.0)

Core module for executing remote procedure calls.

Handles RPC execution with:

Internally uses the plug pipeline system for safe/retry mode, and direct :erpc.call for bare mode (backward compatible).

See EasyRpc.Pipeline and EasyRpc.Plug for extending behaviour.

Summary

args()

config_ref()

function_name()

raw_result()

result()

Executes an RPC call using the given WrapperConfig.

Executes with a dynamically resolved NodeSelector.

Executes an RPC call with automatic retry. Always uses error handling.

Backward-compatible alias for execute/3.

Backward-compatible alias for execute_dynamic/4.

@type args() :: list()

@type config_ref() :: {app :: atom(), config_name :: atom()}

@type function_name() :: atom()

@type raw_result() :: term()

@type result() :: {:ok, term()} | {:error, EasyRpc.Error.t()}

@spec execute(EasyRpc.WrapperConfig.t(), function_name(), args()) ::
  result() | raw_result()

Executes an RPC call using the given WrapperConfig.

In bare mode (no error_handling, no retry), uses direct :erpc.call for backward-compatible exception propagation.

In safe/retry mode, uses the plug pipeline.

@spec execute_dynamic(
  EasyRpc.WrapperConfig.t(),
  config_ref(),
  function_name(),
  args()
) ::
  result() | raw_result()

Executes with a dynamically resolved NodeSelector.

Loads the node selector at call-time from {app, config_name}. Useful when cluster topology changes at runtime.

@spec execute_with_retry(EasyRpc.WrapperConfig.t(), function_name(), args()) ::
  result()

Executes an RPC call with automatic retry. Always uses error handling.

Returns {:ok, result} | {:error, Error.t()}.

@spec rpc_call(
  EasyRpc.WrapperConfig.t(),
  {function_name(), args()}
) :: result() | raw_result()

Backward-compatible alias for execute/3.

@spec rpc_call_dynamic(
  EasyRpc.WrapperConfig.t(),
  config_ref(),
  {function_name(), args()}
) ::
  result() | raw_result()

Backward-compatible alias for execute_dynamic/4.