Manifold (manifold v1.7.0)

Copy Markdown

Summary

Types

option()
pack_mode()
pack_mode_option()
send_mode_option()

Functions

current_partitioner()
current_sender()
partitioner_for(pid)
send(pid, message, options \\ [])
sender_for(pid)
set_partitioner_key(key)
set_sender_key(key)
start(type, args)

Callback implementation for Application.start/2.

valid_send_options?(options)

Types

option()

@type option() :: pack_mode_option() | send_mode_option()

pack_mode()

@type pack_mode() :: :binary | :etf | nil

pack_mode_option()

@type pack_mode_option() :: {:pack_mode, pack_mode()}

send_mode_option()

@type send_mode_option() :: {:send_mode, :offload}

Functions

current_partitioner()

current_sender()

partitioner_for(pid)

send(pid, message, options \\ [])

@spec send([pid() | nil] | pid() | nil, message :: term(), options :: [option()]) ::
  :ok

sender_for(pid)

set_partitioner_key(key)

set_sender_key(key)

start(type, args)

Callback implementation for Application.start/2.

valid_send_options?(options)

@spec valid_send_options?(Keyword.t()) :: boolean()