Loading...
Searching...
No Matches
Class List
Here are the classes, structs, unions and interfaces with brief descriptions:

caf | Root namespace of libcaf
mixin | Contains mixin classes implementing several actor traits
behavior_changer | A behavior_changer is an actor that supports self->become(...) and self->unbecome()
requester | A requester is an actor that supports self->request(...)
sender | A sender is an actor that supports self->send(...)
subscriber_base | Marker for subscriber
subscriber | A subscriber is an actor that can subscribe to a group via self->join(...)
policy | Contains policies encapsulating characteristics or algorithms
arg | Provides a wrapper to pass policy types as values to functions
categorized | Configures a cached WDRR fixed multiplexed queue for dispatching to four nested queue (one for each message category type)
downstream_messages | Configures a dynamic WDRR queue for holding downstream messages
nested | Configures a nested DRR queue
normal_messages | Configures a cached DRR queue for holding asynchronous messages with default priority
profiled | An enhancement of CAF's scheduling policy which records fine-grained resource utiliziation for worker threads and actors in the parent coordinator of the workers
scheduler_policy | This concept class describes a policy for worker and coordinator of the scheduler
coordinator_data | Policy-specific data fields for the coordinator
worker_data | Policy-specific data fields for the worker
unprofiled | This class is intended to be used as a base class for actual polices
upstream_messages | Configures a DRR queue for holding upstream messages
urgent_messages | Configures a cached DRR queue for holding asynchronous messages with default priority
work_sharing | Implements scheduling of actors via work sharing (central job queue)
work_stealing | Implements scheduling of actors via work stealing
tcp | Policy object for wrapping default TCP operations
udp | Policy object for wrapping default UDP operations
io | Contains all IO-related classes and functions
network | Contains classes and functions used for network abstraction
acceptor | An acceptor is responsible for accepting incoming connections
acceptor_impl | A concrete acceptor with a technology-dependent policy
acceptor_manager | An acceptor manager configures an acceptor and provides callbacks for incoming connections as well as for error handling
datagram_handler_impl | A concrete datagram_handler with a technology-dependent policy
datagram_manager | A datagram manager provides callbacks for outgoing datagrams as well as for error handling
datagram_servant_impl | Default datagram servant implementation
doorman_impl | Default doorman implementation
event_handler | A socket I/O event handler
state | Stores various status flags and user-defined config parameters
interfaces | Utility class bundling access to network interface names and addresses
ip_endpoint | A hashable wrapper for a sockaddr storage
manager | A manager configures an I/O device and provides callbacks for various I/O operations
multiplexer | Low-level backend for IO multiplexing
runnable | Simple wrapper for runnables
supervisor | Makes sure the multipler does not exit its event loop until the destructor of supervisor has been called
pipe_reader | An event handler for the internal event pipe
protocol | Bundles protocol information for network and transport layer communication
receive_buffer | A container that does not call constructors and destructors for its values
scribe_impl | Default scribe implementation
stream | A stream capable of both reading and writing
stream_impl | A concrete stream with a technology-dependent policy for sending and receiving data from a socket
stream_manager | A stream manager configures an IO stream and provides callbacks for incoming data as well as for error handling
basp | Contains all classes and functions for the Binary Actor Sytem Protocol
header | The header of a Binary Actor System Protocol (BASP) message
instance | Describes a protocol instance managing multiple connections
callee | Provides a callback-based interface for certain BASP events
message_queue | Enforces strict order of message delivery, i.e., deliver messages in the same order as if they were deserialized by a single thread
actor_msg | Request for sending a message to an actor at a later time
routing_table | Stores routing information for a single broker participating as BASP peer and provides both direct and indirect paths
route | Describes a routing path to a node
worker | Deserializes payloads for BASP messages asynchronously
abstract_broker | A broker mediates between actor systems and other components in the network
accept_handle | Generic handle type for managing incoming connections
basp_broker | A broker implementation for the Binary Actor System Protocol (BASP)
broker | Describes a dynamically typed broker
broker_servant | Base class for scribe and doorman
connection_handle | Generic handle type for identifying connections
datagram_handle | Generic handle type for identifying datagram endpoints
datagram_servant | Manages writing to a datagram sink
doorman | Manages incoming connections
middleman | Manages brokers and network backends
middleman_actor_impl | Default implementation of the middleman_actor interface
scribe | Manages a stream
new_connection_msg | Signalizes a newly accepted connection from a `broker`
new_data_msg | Signalizes newly arrived data for a `broker`
data_transferred_msg | Signalizes that a certain amount of bytes has been written
connection_closed_msg | Signalizes that a `broker` connection has been closed
acceptor_closed_msg | Signalizes that a `broker` acceptor has been closed
connection_passivated_msg | Signalizes that a connection has entered passive mode
acceptor_passivated_msg | Signalizes that an acceptor has entered passive mode
new_datagram_msg | Signalizes that a datagram with a certain size has been sent
datagram_sent_msg | Signalizes that a datagram with a certain size has been sent
datagram_servant_passivated_msg | Signalizes that a datagram sink has entered passive mode
datagram_servant_closed_msg | Signalizes that a datagram endpoint has entered passive mode
decorator |
sequencer | An actor decorator implementing "dot operator"-like compositions, i.e., f.g(x) = f(g(x))
splitter | An actor decorator implementing "dot operator"-like compositions, i.e., f.g(x) = f(g(x))
detail |
abstract_worker_hub | A central place where workers return to after finishing a task
container_view | Decorates a container of type T to appear as container of type U
single_arg_wrapper | Enables automagical string conversion for CAF_ARG
comparable | Barton–Nackman trick implementation
ini_value_consumer | Consumes a single value from an INI parser
ini_category_consumer | Consumes a config category
ini_consumer | Consumes a series of dictionaries forming a application configuration
init_fun_factory_helper | Wraps a user-defined function and gives it a uniform signature
int_list | A list of integers (wraps a long... template parameter pack)
il_indices | Creates indices for List beginning at Pos
invoke_result_visitor | Inspects the result of message handlers and triggers type-depended actions such as generating result messages
is_complete | Checks whether T is a complete type
is_one_of | Checks wheter T is in the template parameter pack Ts
path_state | Bundles a filter and a buffer
path_state< unit_t, T > | Compress path_state if Filter is unit
scope_guard | A lightweight scope guard implementation
shared_spinlock | A spinlock implementation providing shared and exclusive locking
squashed_int | Squashes integer types into [u]int_[8|16|32|64]_t equivalents
stream_distribution_tree | A stream distribution tree consist of peers forming an acyclic graph
stream_sink_driver_impl | Identifies an unbound sequence of messages
stream_source_driver_impl | Identifies an unbound sequence of messages
stream_stage_driver_impl | Default implementation for a stream_stage_driver that hardwires message as result type and implements process and finalize using user-provided function objects (usually lambdas)
sync_request_bouncer | Drains a mailbox and sends an error message to each unhandled request
tick_emitter | Converts realtime into a series of ticks, whereas each tick represents a preconfigured timespan
type_erased_value_impl | Default implementation for single type-erased values
type_list | A list of types
tl_head | Gets the first element of List
tl_tail | Gets the tail of List
tl_size | Gets the number of template parameters of List
tl_back | Gets the last element in List
tl_empty | Tests whether a list is empty
tl_slice | Creates a new list from range (First, Last]
tl_right | Creates a new list containing the last N elements
tl_zip | Zips two lists of equal size
tl_zip_right | Equal to zip(right(ListA, N), right(ListB, N), Fun)
tl_index_of_impl | Finds the first element of type What beginning at index Pos
tl_index_of | Finds the first element satisfying Pred beginning at index Pos
tl_index_where | Finds the first element satisfying a given predicate
tl_reverse | Creates a new list wih elements in reversed order
tl_find_impl | Finds the first element of type What beginning at index Pos
tl_find | Finds the first element satisfying Pred beginning at index Pos
tl_forall | Tests whether a predicate holds for all elements of a list
tl_binary_forall | Tests whether a binary predicate holds for all corresponding elements of ListA and ListB
tl_exists | Tests whether a predicate holds for some of the elements of a list
tl_count | Counts the number of elements in the list which satisfy a predicate
tl_count_type | Counts the number of elements in the list which are equal to T
tl_count_not | Counts the number of elements in the list which satisfy a predicate
tl_concat_impl< type_list< LhsTs... >, type_list< RhsTs... > > | Concatenates two lists
tl_concat | Concatenates lists
tl_push_back< type_list< ListTs... >, What > | Appends What to given list
tl_push_front< type_list< ListTs... >, What > | Appends What to given list
tl_cons | Alias for tl_push_front<List, What>
tl_map | Creates a new list by applying a "template function" to each element
tl_map_conditional | Creates a new list by applying a Fun to each element which returns TraitResult for Trait
tl_pop_back | Creates a new list wih all but the last element of List
tl_replace_back | Creates a new list with all but the last element of List and append T to the new list
tl_at< type_list< E... >, N > | Gets element at index N of List
tl_prepend< type_list< T... >, What > | Creates a new list with What prepended to List
tl_filter< type_list< T... >, Pred > | Create a new list containing all elements which satisfy Pred
tl_filter_not | Creates a new list containing all elements which do not satisfy Pred
tl_filter_type | Creates a new list containing all elements which are equal to Type
tl_filter_not_type | Creates a new list containing all elements which are not equal to Type
tl_distinct | Creates a new list from List without any duplicate elements
tl_is_distinct | Tests whether a list is distinct
tl_pad_right | Resizes the list to contain NewSize elements and uses FillType to initialize the new elements with
tl_pad_left | Resizes the list to contain NewSize elements and uses FillType to initialize prepended elements with
tl_trim | Removes trailing What elements from the end
tl_apply | Applies the types of the list to VarArgTemplate
tl_equal | Tests whether ListA contains the same elements as ListB and vice versa
tl_from | Construct a type list from types that take a list of variadic template arguments
is_inspectable | Checks whether T is inspectable by Inspector
has_to_string | Checks whether T defines a free function to_string
conjunction | Joins all bool constants using operator &&
disjunction | Joins all bool constants using operator ||
is_duration | Checks whether T is a std::chrono::duration
is_builtin | Checks whether T is considered a builtin type
is_primitive | Checks whether T is primitive, i.e., either an arithmetic type or convertible to one of STL's string types
is_comparable | Checks whether T1 is comparable with T2
is_forward_iterator | Checks wheter T behaves like a forward iterator
is_iterable | Checks whether T has begin() and end() member functions returning forward iterators
is_byte_sequence | Checks whether T is a contiguous sequence of byte
has_serialize | Checks whether T provides either a free function or a member function for serialization
is_serializable | Any inspectable type is considered to be serializable
is_serializable_impl< T, false, false > | Checks whether T is builtin or provides a serialize (free or member) function
is_mutable_ref | Checks wheter T is a non-const reference
callable_trait | Defines result_type, arg_types, and fun_type
get_callable_trait | Gets a callable trait for T, where T is a function object type, i.e., a function, member function, or a class providing the call operator
is_callable | Checks wheter T is a function or member function
is_callable_with | Checks wheter F is callable with arguments of types Ts...
is_manipulator | Checks wheter F takes mutable references
type_at | Gets the Nth element of the template parameter pack Ts
is_handler_for | Checks whether F is convertible to either std::function<void (T&)> or std::function<void (const T&)>
is_specialization | Checks whether Tpl is a specialization of T or not
transfer_const | Transfers const from T to U. U remains unchanged if T is not const
is_same_ish | Compares T to U und evaluates to true_type if either T == U or if T and U are both integral types of the same size and signedness
always_false | Utility for fallbacks calling static_assert
deconst_kvp | Utility trait for removing const inside a map<K, V>::value_type
is_pair | Utility trait for checking whether T is a std::pair
is_pair< std::pair< First, Second > > | Utility trait for checking whether T is a std::pair
is_map_like | Checks whether T behaves like std::map
is_list_like | Checks whether T behaves like std::vector, std::list, or std::set
static_error_printer | Generates an error using static_assert on an interface mismatch
unique_function | A move-only replacement for std::function
unordered_flat_map | A map abstraction with an unsorted std::vector providing O(n) lookup
intrusive |
drr_cached_queue | A Deficit Round Robin queue with an internal cache for allowing skipping consumers
drr_queue | A Deficit Round Robin queue
fifo_inbox | A FIFO inbox that combines an efficient thread-safe LIFO inbox with a FIFO queue for re-ordering incoming messages
lifo_inbox | An intrusive, thread-safe LIFO queue implementation for a single reader with any number of writers
new_round_result | Returns the state of a consumer from new_round
singly_linked | Intrusive base for singly linked types that allows queues to use T with dummy nodes
task_queue | A singly-linked FIFO queue for storing tasks of varying size
wdrr_dynamic_multiplexed_queue | A work queue that internally multiplexes any number of DRR queues
wdrr_fixed_multiplexed_queue | A work queue that internally multiplexes any number of DRR queues
scheduler |
profiled_coordinator | A coordinator which keeps fine-grained profiling state about its workers and their jobs
abstract_coordinator | A coordinator creates the workers, manages delayed sends and the central printer instance for `aout`
coordinator | Policy-based implementation of the abstract coordinator base class
test_coordinator | A schedule coordinator for testing purposes
worker | Policy-based implementation of the abstract worker base class
meta |
annotation | Type tag for all meta annotations in CAF
tag |
boxing_type | Allows the testing DSL to recognize that subtypes are boxing content types
abstract_actor | Base class for all actor implementations
abstract_channel | Interface for all message receivers
abstract_composable_behavior | Marker type that allows CAF to spawn actors from composable states
abstract_group | A multicast group
actor | Identifies an untyped actor
actor_addr | Stores the address of typed as well as untyped actors
actor_clock | A monotonic clock for scheduling timeouts and delayed messages
actor_config | Stores spawn-time flags and groups
actor_control_block | Actors are always allocated with a control block that stores its identity as well as strong and weak reference counts to it
actor_ostream | Provides support for thread-safe output operations on character streams
actor_pool | An actor poool is a lightweight abstraction for a set of workers
actor_profiler | A profiler which provides a set of callbacks for several actor operations in order to collect fine-grained profiling state about the system
actor_proxy | Represents an actor running on a remote machine, or different hardware, or in a separate process
actor_registry | A registry is used to associate actors to IDs or atoms (names)
actor_system | Actor environment including scheduler, registry, and optional components such as a middleman
module | An (optional) component of the actor system
actor_system_config | Configures an actor_system on startup
dynamically_typed_actor_base | Marker type for dynamically typed actors
statically_typed_actor_base | Marker type for statically typed actors
blocking_actor_base | Marker type for blocking actors
non_blocking_actor_base | Marker type for non-blocking actors
default_actor_traits | Default implementation of actor_traits for non-actors (SFINAE-friendly)
default_actor_traits< T, true > | Default implementation of actor_traits for regular actors
actor_traits | Provides uniform access to properties of actor types
allowed_unsafe_message_type | Template specializations can whitelist individual types for unsafe message passing operations
atom_constant | Lifts an atom_value to a compile-time constant
attachable | Callback utility class
token | Represents a pointer to a value with its subtype as type ID number
behavior | Describes the behavior of an actor, i.e., provides a message handler and an optional timeout
binary_deserializer | Implements the deserializer interface with a binary serialization protocol
blocking_actor | A thread-mapped or context-switching actor using a blocking receive rather than a behavior-stack based message processing
mailbox_policy | Configures the FIFO inbox with two nested queues:
receive_cond | Represents pre- and postconditions for receive loops
accept_one_cond | Pseudo receive condition modeling a single receive
receive_while_helper | Implementation helper for blocking_actor::receive_while
receive_for_helper | Implementation helper for blocking_actor::receive_for
do_receive_helper | Implementation helper for blocking_actor::do_receive
buffered_downstream_manager | Mixin for streams with any number of downstreams
byte_address | Base type for addresses based on a byte representation such as IP or Ethernet addresses
callback | Describes a simple callback, usually implemented via lambda expression
callback_impl | Utility class for wrapping a function object of type Base
select_callback | Utility class for selecting a callback_impl
composable_behavior_base | Generates an interface class that provides operator()
composable_behavior | Base type for composable actor states
composable_behavior_based_actor | Implementation class for spawning composable states directly as actors
composed_type | Computes the type for f*g (actor composition)
config_option | Defines a configuration option for the application
meta_state | Custom vtable-like struct for delegating to type-specific functions and storing type-specific information shared by several config options
config_option_adder | Adds config options of the same category to a config_option_set
config_option_set | A set of config_option objects that parses CLI arguments into a settings object
config_value | A type for config parameters with similar interface to a variant
select_config_value_access | Delegates to config_value_access for all specialized versions
select_config_value_access< T, select_config_value_hint::is_integral > | Catches all non-specialized integer types
select_config_value_access< T, select_config_value_hint::is_list > | Catches all non-specialized list types
select_config_value_access< T, select_config_value_hint::is_map > | Catches all non-specialized map types
config_value_access< std::tuple< Ts... > > | Implements automagic unboxing of std::tuple<Ts...> from a heterogeneous config_value::list
config_value_adaptor | Interfaces between a user-defined type and CAF config values by going through intermediate values
config_value_adaptor_access | Enables user-defined types in config files and on the CLI by converting them to and from tuples
config_value_adaptor_field | Describes a field of type T of an adaptor
config_value_field | Describes a field of Object
config_value_object_access | Enables user-defined types in config files and on the CLI by converting them to and from config_value::dictionary
cow_tuple | A copy-on-write tuple implementation
data_processor | A data processor translates an object into a format that can be stored or vice versa
deep_to_string_t | Wrapper to deep_to_string for using the function as an inspector
default_downstream_manager | Selects a downstream manager implementation based on the signature of various handlers
default_sum_type_access | Allows specializing the sum_type_access trait for any type that simply wraps a variant and exposes it with a get_data() member function
delegated | Helper class to indicate that a request has been forwarded
deserializer | Technology-independent deserialization interface
typed_actor | Identifies a statically typed actor
dictionary | Maps strings to values of type V, but unlike std::map<std::string, V> accepts string_view for looking up keys efficiently
downstream | Grants access to an output stream buffer
downstream_manager | Manages downstream communication for a stream_manager
path_visitor | Function object for iterating over all paths
path_predicate | Predicate object for paths
downstream_manager_base | The default downstream manager base stores outbound paths in an unordered map
downstream_msg | Stream messages that travel downstream, i.e., batches and close messages
batch | Transmits stream data
close | Orderly shuts down a stream after receiving an ACK for the last batch
forced_close | Propagates a fatal error from sources to sinks
ratio_to_time_unit_helper | Converts the ratio Num/Denom to a time_unit if the ratio describes seconds, milliseconds, microseconds, or minutes
duration | Time duration consisting of a time_unit and a 64 bit unsigned integer
has_make_error | Evaluates to true if T is an enum with a free function make_error for converting it to an error
error | A serializable type for storing error codes with category and optional, human-readable context information
event_based_actor | A cooperatively scheduled, event-based actor implementation
execution_unit | Identifies an execution unit, e.g., a worker thread of the scheduler
no_error_t | Helper class to construct an expected<T> that represents no error
expected | Represents the result of a computation which can either complete successfully with an instance of type T or fail with an error
expected< void > | The pattern expected<void> shall be used for functions that may generate an error but would otherwise return bool
extend | Allows convenient definition of types using mixins
forwarding_actor_proxy | Implements a simple proxy forwarding all operations to a manager
function_view | A function view for an actor hides any messaging from the caller
fused_downstream_manager | A downstream manager that delegates to any number of sub-managers
non_owning_ptr | State held for each slot
intrusive_cow_ptr | An intrusive, reference counting smart pointer implementation with copy-on-write optimization
intrusive_ptr | An intrusive, reference counting smart pointer implementation
optional | A C++17 compatible optional implementation
param | Represents a message handler parameter of type T and guarantees copy-on-write semantics
serializer_impl | Implements the serializer interface with a binary serialization protocol
span | A C++11/14 drop-in replacement for C++20's std::span without support for static extents
stream | Empty marker type for streaming handshakes
weak_intrusive_ptr | An intrusive, reference counting smart pointer implementation
parser_state | Stores all informations necessary for implementing an FSM-based parser
typed_event_based_actor | A cooperatively scheduled, event-based actor implementation with static type-checking
typed_response_promise | A response promise can be used to deliver a uniquely identifiable response message from the server (i.e
variant | A variant represents always a valid value of one of the types Ts...
stateful_actor | An event-based actor with managed state
group_module | Interface for user-defined multicast implementations
illegal_message_element | Marker class identifying classes in CAF that are not allowed to be used as message element
inbound_path | State for a path to an upstream actor (source)
stats_t | Stores statistics for measuring complexity of incoming batches
measurement | Wraps a time measurement for a single processed batch
calculation_result | Wraps the resulf of stats_t::calculate()
index_mapping | Marker for representing placeholders at runtime
infer_handle_from_fun | Deduces an actor handle type from a function or function object
infer_handle_from_class | Deduces actor for dynamically typed actors, otherwise typed_actor<...> is deduced
ipv4_endpoint | An IP endpoint that contains an ::ipv4_address and a port
ipv6_endpoint | An IP endpoint that contains an ::ipv6_address and a port
is_actor_handle | Checks whether T is an actor or a typed_actor<...>
is_error_code_enum | Customization point for enabling conversion from an enum type to an error or error_code
is_typed_actor | Evaluates to true if T is a typed_actor<...>
logger | Centrally logs events from all actors in an actor system
config | Combines various logging-related flags and parameters into a bitfield
event | Encapsulates a single logging event
field | Represents a single format string field
line_builder | Utility class for building user-defined log messages with CAF_ARG
mailbox_category_corrector | Corrects the message ID for down- and upstream messages to make sure the category for a mailbox_element matches its content
mailbox_element_vals | Encapsulates arbitrary data in a message element
mailbox_element_view | Provides a view for treating arbitrary data as message element
unbox_message_element | Unboxes atom constants, i.e., converts atom_constant<V> to V
make_sink_result | Returns a stream sink with the slot ID of its first inbound path
make_source_result | Returns a stream source with the slot ID of its first outbound path
make_stage_result | Returns a stream stage with the slot IDs of its first in- and outbound paths
type_erased_value_factory | Converts values to type-erased values
memory_managed | This base enables derived classes to enforce a different allocation strategy than new/delete by providing a virtual protected request_deletion() function and non-public destructor
message | Describes a fixed-length, copy-on-write, type-erased tuple with elements of any type
cli_res | Stores the result of message::extract_opts
cli_arg | Stores the name of a command line option ("<long name>[,<short name>]") along with a description and a callback
message_builder | Provides a convenient interface for createing message objects from a series of values using the member function append
message_handler | A partial function implementation used to process a message
message_id | Bundles various flags along with an optional request ID
message_view | Represents an object pointing to a type_erased_tuple that is convertible to a message
monitorable_actor | Base class for all actor implementations
named_actor_config | Stores a flow-control configuration
no_stages_t | Convenience tag type for producing empty forwarding stacks
node_id | A node ID is an opaque value for representing CAF instances in the network
none_t | Represents "nothing", e.g., for clearing an optional by assigning none
optional< T & > | Template specialization to allow optional to hold a reference rather than an actual value with minimal overhead
outbound_path | State for a single path to a sink of a downstream_manager
add_param | Converts T to param<T> unless T is arithmetic, an atom constant, or a stream handshake
remove_param | Unpacks param<T> to T
param_decay | Convenience struct for remove_param<std::decay<T>>
proxy_registry | Groups a (distributed) set of actors and allows actors in the same namespace to exchange messages
backend | Responsible for creating proxy actors
raw_event_based_actor | A cooperatively raw scheduled actor is a dynamically typed actor that does not handle any system messages
ref_counted | Base class for reference counted objects with an atomic reference count
response_handle | This helper class identifies an expected response message and enables request(...).then(...)
response_promise | A response promise can be used to deliver a uniquely identifiable response message from the server (i.e
response_type | Defines:
response_type_unbox | Unboxes Xs and calls response_type
resumable | A cooperatively executed task managed by one or more instances of execution_unit
runtime_settings_map | Thread-safe container for mapping atoms to arbitrary settings
scheduled_actor | A cooperatively scheduled, event-based actor implementation
mailbox_policy | Configures the FIFO inbox with four nested queues:
mailbox_visitor | Consumes messages from the mailbox
scoped_actor | A scoped handle to a blocking actor
scoped_execution_unit | Identifies an execution unit, e.g., a worker thread of the scheduler
serializer | Technology-independent serialization interface
skip_t | Default handler function that leaves messages in the mailbox
spawn_options | Stores options passed to the spawn function family
stream_deserializer | Implements the deserializer interface with a binary serialization protocol
stream_finalize_trait | Dispatches a finalize call to a function taking either one or two arguments
stream_finalize_trait< Fun, State, false > | Specializes the trait for callbacks that only take the state
stream_finalize_trait< Fun, State, true > | Specializes the trait for callbacks that take state and error
stream_manager | Manages a single stream with any number of in- and outbound paths
stream_serializer | Implements the serializer interface with a binary serialization protocol
stream_sink_driver | Identifies an unbound sequence of messages
stream_sink_trait_base | Base type for all sink traits
stream_sink_trait | Defines required type aliases for stream sinks
stream_sink_trait< void(State &, In)> | Specializes the trait for element-wise processing
stream_sink_trait< void(State &, std::vector< In > &)> | Specializes the trait for batch-wise processing
stream_sink_trait< void(State &, const std::vector< In > &)> | Specializes the trait for batch-wise processing with const references
stream_slots | Maps two stream_slot values into a pair for storing sender and receiver slot information
inbound_stream_slot | Wraps a stream slot ID for inbound paths with the full type information of the path creation
outbound_stream_slot | Wraps a stream slot ID for outbound paths with the full type information of the path creation
stream_source_driver | Identifies an unbound sequence of messages
stream_source_trait | Deduces the output type and the state type for a stream source from its pull implementation
stream_stage_driver | Encapsulates user-provided functionality for generating a stream stage
stream_stage_trait< void(State &, downstream< Out > &, In)> | Deduces the input type, output type and the state type for a stream stage from its process implementation
stream_buffer | The base class for all stream buffer implementations
arraybuf | A streambuffer abstraction over a fixed array of bytes
containerbuf | A streambuffer abstraction over a contiguous container
string_view | Drop-in replacement for C++17 std::string_view
sum_type_access | Specializing this trait allows users to enable holds_alternative, get, get_if, and visit for any user-defined sum type
has_sum_type_access | Evaluates to true if T specializes sum_type_access
exit_msg | Sent to all links when an actor is terminated
down_msg | Sent to all actors monitoring an actor when it is terminated
group_down_msg | Sent to all members of a group when it goes offline
timeout_msg | Signalizes a timeout event
open_stream_msg | Demands the receiver to open a new stream from the sender to the receiver
thread_hook | Interface to define thread hooks
infinite_t | Represents an infinite amount of timeout for specifying "invalid" timeouts
type_erased_tuple | Represents a tuple of type-erased values
empty_type_erased_tuple | Dummy objects representing empty tuples
type_erased_value | Represents a single type-erased value
type_id | Maps the type T to a globally unique ID
type_by_id | Maps the globally unique ID V to a type (inverse to ::type_id)
type_name | Convenience type that resolves to type_name_by_id<type_id_v<T>>
type_name< void > | Convenience specialization that enables generic code to not treat void manually
type_name_by_id | Maps the globally unique ID V to a type name
has_type_id | Evaluates to true if any of these statements holds true:
type_nr | Computes the type number for T
typed_actor_view_base | Tag type for typed_actor_view
unit_t | Unit is analogous to void, but can be safely returned, stored, etc
upstream_msg | Stream messages that flow upstream, i.e., acks and drop messages
ack_open | Acknowledges a previous open message and finalizes a stream handshake
ack_batch | Cumulatively acknowledges received batches and signalizes new demand from a sink to its source
drop | Asks the source to discard any remaining credit and close this path after receiving an ACK for the last batch
forced_drop | Propagates a fatal error from sinks to sources
uri | A URI according to RFC 3986
authority_type | Bundles the authority component of the URI, i.e., userinfo, host, and port
sum_type_access< variant< Ts... > > | Enable holds_alternative, get, get_if, and visit for variant
handle | Base class for IO handles such as accept_handle or connection_handle