MCPcopy Create free account

hub / github.com/KumoCorp/kumomta / functions

Functions3,617 in github.com/KumoCorp/kumomta

⨍ Functions 3,617◇ Types & classes 836
↓ 594 callersMethodto_string
(&self)
crates/kumo-dmarc/src/types/results.rs:160
↓ 544 callersMethodclone
(&self)
crates/kumo-prometheus/src/lib.rs:669
↓ 464 callersMethodpush
(&self, msg: Message)
crates/kumod/src/ready_queue.rs:183
↓ 387 callersMethodto_string
(&self)
crates/message/src/queue_name.rs:51
↓ 314 callersMethodinto
(self)
crates/mod-file-type/src/lib.rs:14
↓ 219 callersFunctionparse
(s: &str)
crates/kumo-spf/src/record.rs:653
↓ 210 callersMethodas_ref
(&self)
crates/kumo-jsonl/src/batch.rs:136
↓ 179 callersMethodclone
(&self)
crates/lruttl/src/lib.rs:505
↓ 175 callersMethodset
(&mut self, name: impl AsRef<[u8]>, value: impl AsRef<[u8]>)
crates/mailparsing/src/rfc5322_parser.rs:2216
↓ 166 callersMethodinto
(self)
crates/kumo-dmarc/src/types/results.rs:173
↓ 160 callersMethodset
(&self, v: usize)
crates/kumo-prometheus/src/counter.rs:82
↓ 155 callersMethodcollect
()
crates/kumo-server-memory/src/lib.rs:664
↓ 155 callersMethoditer
Iterate over all values in the map
crates/cidr-map/src/map.rs:508
↓ 153 callersMethodas_bytes
(&self)
crates/mailparsing/src/strings.rs:94
↓ 136 callersMethodclone
(&self)
crates/mailparsing/src/strings.rs:54
↓ 131 callersMethodlen
(&self)
crates/timeq/src/lib.rs:65
↓ 128 callersMethodpush
(&mut self, level: CheckLevel, msg: S)
crates/kumo-api-types/src/shaping.rs:508
↓ 120 callersMethodinto
(self)
crates/kumod/src/smtp_server.rs:178
↓ 116 callersMethodget
(&self, name: &Q)
crates/lruttl/src/lib.rs:696
↓ 110 callersMethoditer
Iterate over up to `take` messages in this queue. Not implemented for every queue strategy.
crates/kumod/src/queue/queue.rs:1739
↓ 104 callersMethodas_str
(&self)
crates/kumo-spf/src/lib.rs:59
↓ 100 callersMethodpath
(&self)
crates/maildir/src/lib.rs:204
↓ 99 callersMethodsend
(&self, client: &mut SmtpClient)
crates/integration-tests/src/kumod.rs:101
↓ 97 callersFunctiontag
Like nom::bytes::complete::tag, except that we print what the tag was expecting if there was an error. I feel like this should be the default behavior
crates/nom-utils/src/lib.rs:27
↓ 94 callersMethodinto_iter
(self)
crates/message/src/message.rs:237
↓ 90 callersMethodnext
(&mut self)
crates/kcli/src/top/mod.rs:224
↓ 88 callersMethodinc
(&self)
crates/kumod/src/queue/metrics.rs:236
↓ 88 callersMethodis_none
(&self)
crates/maildir/src/lib.rs:81
↓ 84 callersMethodsmtp_client
(&self)
crates/integration-tests/src/kumod.rs:254
↓ 82 callersFunctionspawn
Spawn a future as a task with a name. The task is spawned into the current tokio runtime.
crates/kumo-server-runtime/src/lib.rs:268
↓ 81 callersMethodis_empty
Returns true if the wheel is empty
crates/timeq/src/lib.rs:61
↓ 81 callersMethodis_empty
Whether the batch is empty.
crates/kumo-jsonl/src/batch.rs:102
↓ 80 callersMethodstop_both
(&mut self)
crates/integration-tests/src/kumod.rs:352
↓ 80 callersMethodwrite_response
( &mut self, status: u16, message: S, command: Option<String>, disconn
crates/kumod/src/smtp_server.rs:1152
↓ 78 callersMethodinsert
(&self, msg: Message)
crates/kumod/src/ready_queue.rs:826
↓ 77 callersMethodas_bytes
(&self)
crates/spool/src/spool_id.rs:65
↓ 76 callersMethodparse
(email: &str)
crates/mailparsing/src/rfc5322_parser.rs:1925
↓ 72 callersMethodget
()
crates/kumod/src/spool.rs:146
↓ 70 callersMethodborrow
Borrows the local copy of the config for read. The local copy will be updated from the upstream if necessary.
crates/kumo-server-common/src/config_handle.rs:57
↓ 69 callersMethodparse
Parse an envelope address from a string. Accepts either forward or reverse path syntax, with or without angle brackets. Returns anyhow::Result for ea
crates/rfc5321/src/parser.rs:493
↓ 67 callersMethodclone
(&self)
crates/kumo-server-lifecycle/src/lib.rs:58
↓ 67 callersMethodremove
Remove the named parameter
crates/mailparsing/src/rfc5322_parser.rs:2210
↓ 67 callersMethodwait_for_source_summary
(&self, mut func: F, timeout: Duration)
crates/integration-tests/src/kumod.rs:310
↓ 65 callersMethoddump_logs
(&self)
crates/integration-tests/src/kumod.rs:360
↓ 62 callersFunctionsleep
(_lua: Lua, seconds: f64)
crates/mod-time/src/lib.rs:93
↓ 59 callersMethodis_empty
(&self)
crates/kumod/src/queue/queue.rs:1755
↓ 58 callersMethodlen
The number of records in this batch.
crates/kumo-jsonl/src/batch.rs:97
↓ 54 callersMethodbuild
Build the multi-consumer tailer.
crates/kumo-jsonl/src/tailer.rs:134
↓ 51 callersMethodstore
( &self, id: SpoolId, data: Arc<Box<[u8]>>, force_sync: bool, deadline
crates/spool/src/rocks.rs:257
↓ 50 callersMethodvalue
(&self)
crates/kumo-prometheus/src/parser.rs:339
↓ 50 callersMethodwith_txt
(self, domain: &str, value: impl Into<String>)
crates/dns-resolver/src/resolver.rs:203
↓ 49 callersMethodto_str
(&self)
crates/mailparsing/src/strings.rs:102
↓ 46 callersMethodload
Load a checkpoint from the given path. Returns `Ok(None)` if the file does not exist.
crates/kumo-jsonl/src/checkpoint.rs:15
↓ 45 callersMethodenumerate
( &self, sender: Sender<SpoolEntry>, start_time: DateTime<Utc>, )
crates/spool/src/rocks.rs:379
↓ 43 callersMethodsend
(&self, value: CacheValue)
crates/mod-mpsc/src/lib.rs:19
↓ 42 callersMethodlen
(&self)
crates/kumod/src/ready_queue.rs:244
↓ 42 callersMethodtake
(mut self)
crates/kumod/src/delivery_metrics.rs:250
↓ 42 callersMethodwith_zone
(mut self, zone: &str)
crates/dns-resolver/src/resolver.rs:179
↓ 42 callersMethodwrite
(&mut self, bytes: &[u8])
crates/tsa-daemon/src/http_server.rs:483
↓ 41 callersMethodappend
Join other onto self, consuming self and producing a pointer that makes other relative to self
crates/mailparsing/src/mimepart.rs:1204
↓ 40 callersFunctionget
(set: &'a CidrMap<&str>, key: &str)
crates/cidr-map/src/map.rs:761
↓ 40 callersMethodinto
(self)
crates/kumod/src/http_server/inject_v1.rs:377
↓ 39 callersFunctionfrom_lua_value
Convert from a lua value to a deserializable type, with a slightly more helpful error message in case of failure. NOTE: the ", while processing" porti
crates/config/src/lib.rs:584
↓ 39 callersFunctionlog_disposition
(args: LogDisposition<'_>)
crates/kumod/src/logging/disposition.rs:34
↓ 39 callersMethodsplit
(re: &'r Regex, haystack: &'h str)
crates/mod-regex/src/lib.rs:111
↓ 38 callersMethodget
(&self, info: &ConnectionInfo)
crates/mod-amqp/src/amqprs_client.rs:29
↓ 38 callersMethodset_meta
(&mut self, name: N, value: V)
crates/kumod/src/smtp_server.rs:3317
↓ 38 callersMethodto_owned
(&'a self)
crates/mailparsing/src/header.rs:99
↓ 38 callersMethodwait_for_maildir_count
(&self, count: usize, timeout: Duration)
crates/integration-tests/src/kumod.rs:306
↓ 37 callersMethodget_or_create
Resolve an already-existing counter for the given key, creating a new one if it didn't already exist, or was previously pruned.
crates/kumo-prometheus/src/lib.rs:724
↓ 36 callersMethodencode
Re-encode the command as a single line of text ready to send on the wire, including the trailing `\r\n`. The returned `BString` can be fed back to [`
crates/rfc5321/src/parser.rs:1041
↓ 36 callersMethodfind
Tries to find the message with the given id in the maildir. This searches both the `new` and the `cur` folders.
crates/maildir/src/lib.rs:563
↓ 36 callersFunctiontag_no_case
(tag: &'static str)
crates/nom-utils/src/lib.rs:35
↓ 35 callersFunctionget_or_create_sub_module
Given a name path like `foo` or `foo.bar.baz`, sets up the module registry hierarchy to instantiate that path. Returns the leaf node of that path to a
crates/config/src/lib.rs:389
↓ 35 callersMethodid
(&self)
crates/maildir/src/lib.rs:109
↓ 35 callersMethodmin
(self, other: Self)
crates/kumo-server-memory/src/lib.rs:143
↓ 34 callersMethodlen
(&self)
crates/mailparsing/src/strings.rs:110
↓ 34 callersMethodstart
(self)
crates/integration-tests/src/kumod.rs:211
↓ 33 callersMethodcontains
(&self, message: &Message)
crates/message/src/timeq.rs:349
↓ 33 callersMethodget
Resolve an already-existing counter for the given key, or None if there either has never been such a value, or if it was pruned.
crates/kumo-prometheus/src/lib.rs:713
↓ 33 callersMethodheaders
Obtains a reference to the headers
crates/mailparsing/src/mimepart.rs:365
↓ 32 callersFunctionassert_encode
Parse a command from a string, encode it, and assert the encoded output equals `expected`. Then parse the encoded output and assert the result equals
crates/rfc5321/src/parser.rs:3011
↓ 32 callersMethodinsert
(&mut self, info: ConnectionInfo, pool: Arc<Pool<ConnectionManager>>)
crates/mod-amqp/src/amqprs_client.rs:33
↓ 32 callersMethodis_empty
(&self)
crates/mod-mpsc/src/lib.rs:99
↓ 32 callersMethodparse
(value: &str)
crates/dkim/src/header.rs:18
↓ 32 callersFunctionserialize_options
()
crates/config/src/lib.rs:874
↓ 31 callersMethodcollect_logs
(&self)
crates/integration-tests/src/kumod.rs:765
↓ 31 callersMethodelapsed
(&self)
crates/message/src/timeq.rs:456
↓ 31 callersFunctionload_config
()
crates/config/src/lib.rs:116
↓ 31 callersMethodtake
(&mut self)
crates/throttle/src/limit.rs:172
↓ 30 callersMethodip
Returns the ip representation of the address
crates/kumo-address/src/host.rs:44
↓ 30 callersMethodmax
(mut self, max: Option<u64>)
crates/kcli/src/top/sparkline.rs:79
↓ 30 callersMethodretain
Iterate the entire timeq and apply KEEPER to each item. If it returns true then the item will be retained in the timeq, otherwise, it will be unlinked
crates/message/src/timeq.rs:398
↓ 29 callersMethodinsert
(&mut self, pattern: &str, value: V)
crates/domain-map/src/lib.rs:79
↓ 28 callersMethodcontains
(&self, ip: IpAddr)
crates/cidr-map/src/map.rs:439
↓ 28 callersMethodget_queue_name
(&self)
crates/message/src/message.rs:932
↓ 28 callersFunctionnew_msg_body
(s: S)
crates/message/src/message.rs:2024
↓ 28 callersMethodto_string
(&self)
crates/mailparsing/src/header.rs:59
↓ 27 callersMethodadd
(mut self, reason: InsertReason)
crates/kumod/src/queue/insert_context.rs:21
↓ 27 callersMethodenv
(mut self, key: impl Into<String>, value: impl Into<String>)
crates/integration-tests/src/kumod.rs:201
next →1–100 of 3,617, ranked by callers