Skip to content

KumoMTA Docs

module: kumo.mpsc

Initializing search

KumoCorp/kumomta

Tutorial
User Guide
Reference Manual
FAQ
Changelog

KumoMTA Docs

KumoCorp/kumomta

Tutorial
Tutorial
User Guide
User Guide
- General
  General
- Installation
  Installation
- Configuration
  Configuration
- Operation
  Operation
- Policy
  Policy
- Clustering
  Clustering
- Performance
  Performance
- Integrations
  Integrations
Reference Manual
Reference Manual
- Predefined Metadata
- Queues
- Configuration Lifecycle
- Memory Management
- Template Syntax
  Template Syntax
  - cycler
  - dateformat
  - datetimeformat
  - filesizeformat
  - joiner
  - now
  - pluralize
  - timeformat
- Log Record
- kcli
  kcli
- module: kumo
  module: kumo
  - available_parallelism
  - bump_config_epoch
  - configure_accounting_db_path
  - configure_bounce_classifier
  - configure_local_logs
    
    configure_local_logs
    
    back_pressure
    
    compression_level
    
    filter_event
    
    headers
    
    log_dir
    
    max_file_size
    
    max_segment_duration
    
    meta
    
    min_free_inodes
    
    min_free_space
    
    per_record
  - configure_log_hook
  - configure_redis_throttles
  - define_spool
    
    define_spool
    
    flush
    
    kind
    
    min_free_inodes
    
    min_free_space
    
    name
    
    path
    
    rocks_params
  - disconnect
  - eval_config_monitor_globs
  - glob
  - json_encode
  - json_encode_pretty
  - json_load
  - json_parse
  - log_debug
  - log_error
  - log_info
  - log_warn
  - make_egress_path
    
    make_egress_path
    
    additional_connection_limits
    
    additional_message_rate_throttles
    
    additional_source_selection_rates
    
    allow_smtp_auth_plain_without_tls
    
    banner_timeout
    
    connect_timeout
    
    connection_limit
    
    consecutive_connection_failures_before_delay
    
    data_dot_timeout
    
    data_timeout
    
    dispatcher_wakeup_strategy
    
    ehlo_domain
    
    ehlo_timeout
    
    enable_dane
    
    enable_mta_sts
    
    enable_pipelining
    
    enable_rset
    
    enable_tls
    
    idle_timeout
    
    low_memory_reduction_policy
    
    mail_from_timeout
    
    maintainer_wakeup_strategy
    
    max_connection_rate
    
    max_deliveries_per_connection
    
    max_message_rate
    
    max_ready
    
    no_memory_reduction_policy
    
    openssl_cipher_list
    
    openssl_cipher_suites
    
    openssl_options
    
    opportunistic_tls_reconnect_on_failed_handshake
    
    prohibited_hosts
    
    rcpt_to_timeout
    
    reconnect_strategy
    
    refresh_interval
    
    refresh_strategy
    
    remember_broken_tls
    
    rset_timeout
    
    rustls_cipher_suites
    
    skip_hosts
    
    smtp_auth_plain_password
    
    smtp_auth_plain_username
    
    smtp_port
    
    source_selection_rate
    
    starttls_timeout
    
    suspended
    
    system_shutdown_timeout
    
    tls_certificate
    
    tls_prefer_openssl
    
    tls_private_key
    
    try_next_host_on_transport_error
    
    use_lmtp
  - make_egress_pool
    
    make_egress_pool
    
    entries
    
    name
    
    ttl
  - make_egress_source
    
    make_egress_source
    
    ehlo_domain
    
    ha_proxy_server
    
    ha_proxy_source_address
    
    name
    
    remote_port
    
    socks5_proxy_server
    
    socks5_proxy_source_address
    
    source_address
    
    ttl
  - make_listener_domain
    
    make_listener_domain
    
    log_arf
    
    log_oob
    
    relay_from
    
    relay_to
  - make_queue_config
    
    make_queue_config
    
    egress_pool
    
    max_age
    
    max_message_rate
    
    max_retry_interval
    
    protocol
    
    reap_interval
    
    refresh_interval
    
    refresh_strategy
    
    retry_interval
    
    shrink_policy
    
    strategy
    
    timerwheel_tick_interval
  - make_throttle
  - memoize
  - on
  - read_dir
  - reject
  - set_config_monitor_globs
  - set_diagnostic_log_filter
  - set_httpinject_recipient_rate_limit
  - set_httpinject_threads
  - set_logging_threads
  - set_lruttl_cache_capacity
  - set_max_lua_context_age
  - set_max_lua_context_use_count
  - set_max_spare_lua_contexts
  - set_memory_hard_limit
  - set_memory_low_thresh
  - set_memory_soft_limit
  - set_qmaint_threads
  - set_ready_qmaint_threads
  - set_readyq_threads
  - set_smtpsrv_threads
  - set_spoolin_threads
  - sleep
  - spawn_task
  - start_esmtp_listener
    
    start_esmtp_listener
    
    banner
    
    client_timeout
    
    data_buffer_size
    
    data_processing_timeout
    
    deferred_queue
    
    deferred_spool
    
    hostname
    
    invalid_line_endings
    
    line_length_hard_limit
    
    listen
    
    max_connections
    
    max_message_size
    
    max_messages_per_connection
    
    max_recipients_per_message
    
    meta
    
    peer
    
    relay_hosts
    
    tls_certificate
    
    tls_private_key
    
    tls_required_client_ca
    
    trace_headers
    
    via
  - start_http_listener
    
    start_http_listener
    
    hostname
    
    listen
    
    request_body_limit
    
    tls_certificate
    
    tls_private_key
    
    trusted_hosts
    
    use_tls
  - toml_encode
  - toml_encode_pretty
  - toml_load
  - toml_parse
  - uncached_glob
- module: kumo.amqp
  module: kumo.amqp
  - basic_publish
  - build_client
- module: kumo.api.inject
  module: kumo.api.inject
  - inject_v1
- module: kumo.digest
  module: kumo.digest
  - sha1
  - sha256
  - sha384
  - sha512
  - sha512_256
- module: kumo.dkim
  module: kumo.dkim
- module: kumo.dns
  module: kumo.dns
- module: kumo.encode
  module: kumo.encode
- module: kumo.cidr
  module: kumo.cidr
  - make_map
- module: kumo.domain_map
  module: kumo.domain_map
  - new
- module: kumo.fs
  module: kumo.fs
  - glob
  - open
  - read_dir
  - uncached_glob
- module: kumo.http
  module: kumo.http
- module: kumo.kafka
  module: kumo.kafka
  - build_producer
- module: kumo.mpsc
  module: kumo.mpsc
  - define
- module: kumo.regex_set_map
  module: kumo.regex_set_map
  - new
- module: kumo.secrets
  module: kumo.secrets
  - load
- module: kumo.serde
  module: kumo.serde
- module: kumo.shaping
  module: kumo.shaping
  - load
- module: kumo.spf
  module: kumo.spf
  - check_host
- module: kumo.uuid
  module: kumo.uuid
  - new_v1
  - new_v4
  - new_v6
  - new_v7
  - parse
- module: redis
  module: redis
  - open
- module: regex
  module: regex
  - compile
  - escape
- module: sqlite
  module: sqlite
  - open
- module: string
  module: string
  - eval_template
  - psl_domain
  - psl_suffix
  - replace
  - replacen
  - rsplit
  - rsplitn
  - split
  - split_ascii_whitespace
  - split_whitespace
  - splitn
  - trim
  - trim_end
  - trim_start
- module: kumo.time
  module: kumo.time
  - sleep
  - start_timer
- module: tsa
  module: tsa
  - configure_tsa_db_path
  - start_http_listener
- object: address
  object: address
  - domain
  - email
  - user
- object: addressheader
  object: addressheader
  - domain
  - email
  - list
  - name
  - user
- object: authenticationresult
- object: connectionmeta
- object: keysource
- object: message
  object: message
- events
  events
- HTTP API Explorer
- HTTP API
  HTTP API
- Internal Rust API
  Internal Rust API
  - bounce_classify
  - cidr_map
  - config
  - data_loader
  - dns_resolver
  - domain_map
  - duration_serde
  - kumo_address
  - kumo_api_types
  - kumo_chrono_helper
  - kumo_dkim
  - kumo_dmarc
  - kumo_log_types
  - kumo_prometheus
  - kumo_server_common
  - kumo_server_lifecycle
  - kumo_server_memory
  - kumo_server_runtime
  - kumo_spf
  - kumo_template
  - lruttl
  - maildir
  - mailparsing
  - message
  - mod_amqp
  - mod_digest
  - mod_dns_resolver
  - mod_encode
  - mod_filesystem
  - mod_http
  - mod_kafka
  - mod_memoize
  - mod_mpsc
  - mod_redis
  - mod_regex
  - mod_serde
  - mod_sqlite
  - mod_string
  - mod_time
  - mod_uuid
  - mta_sts
  - regex_set_map
  - rfc5321
  - spool
  - throttle
  - timeq
  - uuid_helper
  - version_info
- Tags
FAQ
FAQ
Changelog
Changelog

Table of contents

Available Functions

Module `kumo.mpsc`

This module provides a Multi-Producer-Single-Consumer queue facility.

Available Functions

define

Copyright © 2023 Kumo Corp

Made with Material for MkDocs