RpcLoadBalancer.LoadBalancer.Pg (rpc_load_balancer v0.3.0)

Encapsulates the shared :pg group name and the patterns for reading membership and fanning out RPC calls to remote members.

Summary

child_spec(opts)

Runs :erpc.multicall/5 against every remote member of the group and returns [{remote_node, result}] pairs in membership order.

pg_group_name()

Returns remote node names (non-local, deduplicated) registered for the given load balancer.

@spec child_spec(any()) :: map()

@spec multicall(atom() | module(), module(), atom(), [any()], timeout()) :: [
  {node(), any()}
]

Runs :erpc.multicall/5 against every remote member of the group and returns [{remote_node, result}] pairs in membership order.

Empty-membership shortcut: returns [] without invoking :erpc.

@spec pg_group_name() :: atom()

@spec remote_members(atom() | module()) :: [node()]

Returns remote node names (non-local, deduplicated) registered for the given load balancer.

@spec start_link(any()) :: {:ok, pid()} | {:error, any()}