List of all items
Structs
- api::types::AttrKey
- api::types::BigInt
- api::types::EncodeHexWithoutLeadingZeroes
- api::types::EventCoordinate
- api::types::LogicalTime
- api::types::Nanoseconds
- api::types::TimelineId
- api::types::Uuid
- api::types::WrongAttrTypeError
- auth_token::AuthToken
- auth_token::AuthTokenHexString
- auth_token::token_user_file::UserAuthTokenFileContents
- ingest_client::BoundTimelineState
- ingest_client::IngestClient
- ingest_client::IngestStatus
- ingest_client::ReadyState
- ingest_client::UnauthenticatedState
- ingest_client::dynamic::DynamicIngestClient
- ingest_protocol::InternedAttrKey
- ingest_protocol::PackedAttrKvs
- mutation_plane::types::AttrKv
- mutation_plane::types::AttrKvs
- mutation_plane::types::MutationId
- mutation_plane::types::MutatorId
- mutation_plane::types::ParticipantId
- mutation_plane::types::TriggerCRDT
- mutation_plane_client::child_connection::AuthReq
- mutation_plane_client::child_connection::ChildConnectionId
- mutator_protocol::descriptor::owned::OrganizationCustomMetadata
- mutator_protocol::descriptor::owned::OwnedMutatorDescriptor
- mutator_protocol::descriptor::owned::OwnedMutatorParamDescriptor
- mutator_protocol::mutator::CombinedMutator
- mutator_server::Mutation
- mutator_server::Mutator
- mutator_server::server::ValidApiKeyHeader
- plugin_utils::config::Config
- plugin_utils::ingest::Client
- plugin_utils::mutation::MutatorHost
- plugin_utils::serde::StringifiedOptionAnyVisitor
- reflector_config::AttrKeyEqValuePair
- reflector_config::AvailablePorts
- reflector_config::Config
- reflector_config::InclusivePortRange
- reflector_config::IngestRolloverTracker
- reflector_config::MutatorAttributes
- reflector_config::PluginShutdown
- reflector_config::PluginsIngest
- reflector_config::PluginsIngestMember
- reflector_config::PluginsMutation
- reflector_config::PluginsMutationMember
- reflector_config::RolloverTrackerParticipant
- reflector_config::SemanticErrorExplanation
- reflector_config::TimelineAttributes
- reflector_config::TopLevelIngest
- reflector_config::TopLevelMutation
- reflector_config::TopLevelPlugins
- reflector_config::resolve::ConfigContext
- tracing::ModalityIngestTaskHandle
- tracing::ModalityLayer
- tracing::Options
- tracing::TracingModality
- tracing::blocking::ModalityIngestThreadHandle
- tracing::blocking::ModalityLayer
- tracing::blocking::TracingModality
- tracing::serde_modality_ingest::TracingModality
- tracing::serde_modality_ingest::options::Options
- tracing::serde_subscriber::Packet
- tracing::serde_subscriber::TSHandler
- tracing::serde_subscriber::TSLayer
- tracing::serde_subscriber::TSSubscriber
Enums
- api::types::AttrType
- api::types::AttrVal
- auth_token::AuthTokenStringDeserializationError
- auth_token::LoadAuthTokenError
- auth_token::token_user_file::TokenUserFileReadError
- ingest_client::IngestClientInitializationError
- ingest_client::IngestConnection
- ingest_client::IngestError
- ingest_client::ParseIngestEndpointError
- ingest_client::TlsMode
- ingest_client::dynamic::DynamicIngestError
- ingest_protocol::IngestMessage
- ingest_protocol::IngestResponse
- mutation_plane::protocol::LeafwardsMessage
- mutation_plane::protocol::RootwardsMessage
- mutation_plane_client::child_connection::AuthResponse
- mutation_plane_client::child_connection::Rootwards
- mutation_plane_client::parent_connection::CommsError
- mutation_plane_client::parent_connection::MutationParentClientInitializationError
- mutation_plane_client::parent_connection::MutationParentConnection
- mutation_plane_client::parent_connection::ParseRootwardsEndpointError
- mutation_plane_client::parent_connection::TlsMode
- mutator_protocol::descriptor::owned::MutatorLayer
- mutator_protocol::descriptor::owned::MutatorOperation
- mutator_protocol::descriptor::owned::MutatorStatefulness
- mutator_protocol::descriptor::owned::ParamDescriptorFromAttrsError
- mutator_protocol::descriptor::owned::ValueDistributionKind
- mutator_protocol::descriptor::owned::ValueDistributionScaling
- plugin_utils::ProtocolParentError
- plugin_utils::mutation::MutationProtocolUrlError
- reflector_config::AttrKeyValuePairParseError
- reflector_config::ConfigLoadError
- reflector_config::ConfigWriteError
- reflector_config::EnvSubError
- reflector_config::MergeMutatorAttributesError
- reflector_config::TomlValue
- reflector_config::resolve::ExpandedConfigLoadError
- reflector_config::resolve::ReflectorAuthTokenLoadError
- tracing::InitError
- tracing::serde_modality_ingest::ConnectError
- tracing::serde_modality_ingest::IngestError
Traits
- mutator_protocol::actuator::MutatorActuator
- mutator_protocol::actuator::SyncMutatorActuator
- mutator_protocol::descriptor::MutatorDescriptor
- mutator_protocol::mutator::ActuatorDescriptor
- plugin_utils::BearingConfigFilePath
- plugin_utils::mutation::Mutator
Macros
Functions
- api::proptest_strategies::attr_val
- api::proptest_strategies::cow_string
- api::proptest_strategies::event_coordinate
- api::proptest_strategies::logical_time
- api::proptest_strategies::nanoseconds
- api::proptest_strategies::opaque_event_id
- api::proptest_strategies::timeline_id
- auth_token::decode_auth_token_hex
- auth_token::token_user_file::read_user_auth_token_file
- auth_token::token_user_file::write_user_auth_token_file
- mutation_plane_client::child_connection::mutation_protocol_child_connection
- mutation_plane_client::child_connection::mutation_protocol_child_tcp_connection
- mutation_plane_client::child_connection::mutation_protocol_child_uds_connection
- mutator_protocol::params_attributes::is_valid_param_key
- mutator_protocol::params_attributes::is_valid_single_key_segment_contents
- mutator_server::server::serve_mutators
- mutator_server::server::serve_mutators_on_listener
- plugin_utils::merge_ingest_protocol_parent_url
- plugin_utils::merge_timeline_attrs
- plugin_utils::mutation::mutator_id_to_attr_val
- plugin_utils::serde::from_str
- plugin_utils::server_main
- reflector_config::envsub
- reflector_config::resolve::load_config
- reflector_config::resolve::load_config_and_auth_token
- reflector_config::resolve::resolve_reflector_auth_token
- reflector_config::try_from_file
- reflector_config::try_from_str
- reflector_config::try_to_file
- reflector_config::try_to_string
- tracing::serde_subscriber::timeline_id
- tracing::timeline_id
Type Aliases
Constants
- api::protocol::TAG_EVENT_COORDINATE
- api::protocol::TAG_LOGICAL_TIME
- api::protocol::TAG_NS
- api::protocol::TAG_TIMELINE_ID
- api::types::TIMELINE_ID_SIGIL
- auth_token::MODALITY_AUTH_TOKEN_ENV_VAR
- auth_token::token_user_file::REFLECTOR_AUTH_TOKEN_DEFAULT_FILE_NAME
- auth_token::token_user_file::USER_AUTH_TOKEN_FILE_NAME
- ingest_client::MODALITY_INGEST_TLS_URL_SCHEME
- ingest_client::MODALITY_INGEST_URL_SCHEME
- ingest_client::MODALITY_STORAGE_SERVICE_PORT_DEFAULT
- ingest_client::MODALITY_STORAGE_SERVICE_TLS_PORT_DEFAULT
- mutation_plane::protocol::MUTATION_PROTOCOL_VERSION
- mutation_plane_client::parent_connection::MODALITY_MUTATION_CONNECT_PORT_DEFAULT
- mutation_plane_client::parent_connection::MODALITY_MUTATION_CONNECT_TLS_PORT_DEFAULT
- mutation_plane_client::parent_connection::MODALITY_MUTATION_TLS_URL_SCHEME
- mutation_plane_client::parent_connection::MODALITY_MUTATION_URL_SCHEME
- mutator_protocol::attrs::mutator::DESCRIPTION
- mutator_protocol::attrs::mutator::GROUP
- mutator_protocol::attrs::mutator::ID
- mutator_protocol::attrs::mutator::LAYER
- mutator_protocol::attrs::mutator::MUTATION_EDGE_ID
- mutator_protocol::attrs::mutator::NAME
- mutator_protocol::attrs::mutator::OPERATION
- mutator_protocol::attrs::mutator::RECEIVE_TIME
- mutator_protocol::attrs::mutator::SAFETY
- mutator_protocol::attrs::mutator::SOURCE_FILE
- mutator_protocol::attrs::mutator::SOURCE_LINE
- mutator_protocol::attrs::mutator::STATEFULNESS
- mutator_protocol::params_attributes::MUTATOR_PARAMS_DEFAULT_VALUE_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_DESCRIPTION_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_LEAST_EFFECT_VALUE_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_NAME_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_PREFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_UNITS_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_DISTRIBUTION_INTERFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_DISTRIBUTION_KIND_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_DISTRIBUTION_OPTION_SET_INTERFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_DISTRIBUTION_OPTION_SET_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_DISTRIBUTION_SCALING_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_MAX_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_MIN_SUFFIX
- mutator_protocol::params_attributes::MUTATOR_PARAMS_VALUE_TYPE_SUFFIX
- mutator_server::MUTATOR_API_CONTROL_HEADER
- mutator_server::MUTATOR_API_KEY_HEADER
- plugin_utils::CLI_TEMPLATE
- plugin_utils::MODALITY_STORAGE_SERVICE_PORT_DEFAULT
- reflector_config::CONFIG_ENV_VAR
- reflector_config::MODALITY_MUTATION_CONNECT_PORT_DEFAULT
- reflector_config::MODALITY_MUTATION_CONNECT_TLS_PORT_DEFAULT
- reflector_config::MODALITY_REFLECTOR_INGEST_CONNECT_PORT_DEFAULT
- reflector_config::MODALITY_REFLECTOR_INGEST_CONNECT_TLS_PORT_DEFAULT
- reflector_config::MODALITY_REFLECTOR_MUTATION_CONNECT_PORT_DEFAULT
- reflector_config::MODALITY_REFLECTOR_MUTATION_CONNECT_TLS_PORT_DEFAULT
- reflector_config::MODALITY_STORAGE_SERVICE_PORT_DEFAULT
- reflector_config::MODALITY_STORAGE_SERVICE_TLS_PORT_DEFAULT
- reflector_config::resolve::MODALITY_HOST_ENV_VAR
- reflector_config::resolve::MODALITY_REFLECTOR_PLUGINS_DIR_ENV_VAR