RpcLoadBalancer (rpc_load_balancer v0.3.4)

Distributed RPC load balancer built on :pg.

Acts as a per-instance Supervisor that starts the caches and GenServer needed for a single load balancer. Also provides the public API for node selection, RPC calls/casts, and low-level :erpc wrappers.

Starting a load balancer

RpcLoadBalancer.start_link(
  name: :my_lb,
  selection_algorithm: RpcLoadBalancer.LoadBalancer.SelectionAlgorithm.RoundRobin,
  algorithm_opts: [weights: %{node() => 1}]
)

Summary

Types

name()

Functions

__using__(opts)

Defines a named load balancer module exposing the full RpcLoadBalancer interface bound to a fixed configuration.

call(node, module, fun, args, opts \\ [])

call_on_random_node(node_filter, module, fun, args, opts \\ [])

cast(node, module, fun, args, opts \\ [])

cast_on_random_node(node_filter, module, fun, args, opts \\ [])

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

get_members(load_balancer_name)

select_node(load_balancer_name, opts \\ [])

start_link(opts)

Types

name()

@type name() :: atom()

Functions

using(opts)

(macro)

Defines a named load balancer module exposing the full RpcLoadBalancer interface bound to a fixed configuration.

defmodule MyApp.LoadBalancer do
  use RpcLoadBalancer,
    selection_algorithm: RpcLoadBalancer.LoadBalancer.SelectionAlgorithm.HashRing,
    node_match_list: ["my_app"]
end

Supervise it directly (children = [MyApp.LoadBalancer]) and call the same functions as RpcLoadBalancer, with :load_balancer set to the using module automatically:

MyApp.LoadBalancer.call(node(), Mod, :fun, args, key: id)
MyApp.LoadBalancer.select_node(key: id)
MyApp.LoadBalancer.get_members()

The use options are forwarded to RpcLoadBalancer.start_link/1 with :name set to the using module. start_link/1 and child_spec/1 accept a keyword list of runtime overrides.

call(node, module, fun, args, opts \\ [])

@spec call(node(), module(), atom(), [any()], keyword()) :: ErrorMessage.t_res(any())

call_on_random_node(node_filter, module, fun, args, opts \\ [])

@spec call_on_random_node(String.t(), module(), atom(), [any()], keyword()) ::
  ErrorMessage.t_res(any())

cast(node, module, fun, args, opts \\ [])

@spec cast(node(), module(), atom(), [term()], keyword()) ::
  :ok | {:error, ErrorMessage.t()}

cast_on_random_node(node_filter, module, fun, args, opts \\ [])

@spec cast_on_random_node(String.t(), module(), atom(), [any()], keyword()) ::
  :ok | {:error, ErrorMessage.t()}

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

get_members(load_balancer_name)

@spec get_members(name()) :: {:ok, [node()]} | {:error, ErrorMessage.t()}

select_node(load_balancer_name, opts \\ [])

@spec select_node(
  name(),
  keyword()
) :: {:ok, node()} | {:error, ErrorMessage.t()}

start_link(opts)

@spec start_link(keyword()) :: Supervisor.on_start()