Functions — github.com/codag-megalith/codag-drain

hub / github.com/codag-megalith/codag-drain / functions

Functions240 in github.com/codag-megalith/codag-drain

Capture the `<*>` slot raw strings for a line. Returns a vector of length `slot_count`; entries are None when the regex doesn't match. LibreLog comma

codag-drain/src/compress/profile.rs:183

↓ 1 callersFunctionchar_kind

(c: char)

codag-drain/src/compress/lex.rs:22

↓ 1 callersFunctionclip

(template: &str, max: usize)

codag-drain/src/compress.rs:184

↓ 1 callersMethodcluster_count

Number of live clusters.

drain3_rust/src/drain.rs:146

↓ 1 callersFunctionconstant_time_eq

(a: &[u8], b: &[u8])

examples/server/src/routes.rs:112

↓ 1 callersFunctiondelimited_tokens

(line: &str, masker: &LogMasker)

codag-drain/src/compress/grouper.rs:149

↓ 1 callersFunctiondistinct_samples

Build distinct first-seen samples (cap N) and a distinct count for a slot.

codag-drain/src/compress/profile.rs:199

↓ 1 callersFunctionenv_u64

(name: &str, default: u64)

examples/server/src/session.rs:59

↓ 1 callersMethodextra_delimiters

Return a reference to the extra delimiters used for tokenization.

drain3_rust/src/drain.rs:160

↓ 1 callersFunctionfmt_slot

(slot: &SlotSummary)

codag-drain/src/compress.rs:162

↓ 1 callersFunctiongenerate_logs

Generate realistic-looking log lines with variation.

drain3_rust/src/bench.rs:14

↓ 1 callersFunctiongeneric_delimiters

()

codag-drain/src/compress/grouper.rs:137

↓ 1 callersMethodget_clusters_ids_for_seq_len

Collect every cluster ID reachable under the subtree for a given token count.

drain3_rust/src/drain.rs:376

↓ 1 callersFunctiongroup_count_from_drain3

(contents: &[String])

codag-drain/tests/eval_loghub.rs:456

↓ 1 callersFunctionhas_static_anchor

True if the template has at least one *static anchor* - a non-placeholder, non-punctuation, non-whitespace char. A template that is all placeholders /

codag-drain/src/compress/template.rs:241

↓ 1 callersFunctionidf_table

(tokenized: &[Vec<LexToken>])

codag-drain/src/compress/grouper.rs:301

↓ 1 callersFunctionis_level_tok

(tok: &str)

codag-drain/src/input.rs:28

↓ 1 callersFunctionlines_of

(msgs: &[&str])

codag-drain/src/compress/profile.rs:219

↓ 1 callersMethodmasker

Return a reference to the configured masker, if any.

drain3_rust/src/drain.rs:170

↓ 1 callersMethodmatch_log

Read-only match against existing clusters (sim_th = 1.0, no mutations).

drain3_rust/src/drain.rs:105

↓ 1 callersMethodmerge

(cluster: &mut StatCluster, idx: usize, toks: &[LexToken])

codag-drain/src/compress/grouper.rs:396

↓ 1 callersFunctionparse_body

Parse a whole newline-delimited body into [`LogLine`]s, skipping blanks. In NDJSON mode, lines that fail to parse are skipped.

codag-drain/src/input.rs:116

↓ 1 callersFunctionparse_grouper

(s: Option<&str>)

examples/server/src/routes.rs:67

↓ 1 callersFunctionparse_prompt_log_list

Extract the Python-repr log list embedded in the LoRA prompt. This is a generic quoted-string scanner, not a log parser.

codag-drain/tests/eval_loghub.rs:118

↓ 1 callersFunctionregex_string_from_placeholder

Build the anchored regex *string* for a placeholder template, applying the LibreLog comma-strip. Returns `None` if it has no static anchor or fails to

codag-drain/src/compress/template.rs:251

↓ 1 callersMethodscore

( &self, cluster: &StatCluster, toks: &[LexToken], idf: &HashMap<String, f64>,

codag-drain/src/compress/grouper.rs:332

↓ 1 callersFunctiontemplate_groups

Build a template result from precomputed groups. Used by [`TemplateIndex`] and tests that need exact control over grouping.

codag-drain/src/compress.rs:296

↓ 1 callersMethodtemplates

(&self)

codag-drain/src/stream.rs:47

↓ 1 callersMethodtokenize

Tokenize content using the same logic as [`Drain::get_content_as_tokens`].

drain3_rust/src/pipeline.rs:75

↓ 1 callersMethodtouch

Mark a cluster as recently used (LRU promotion only).

drain3_rust/src/storage.rs:55

↓ 1 callersFunctiontrailing_alpha_unit

Trailing-alphabetic unit of a value (e.g. "ms" from "45ms", "MB" from "512MB"). Empty if the value does not end in letters or is purely alphabetic.

codag-drain/src/compress.rs:262

↓ 1 callersFunctionttl_sweeper

Background task: drop sessions idle longer than [`SESSION_TTL`].

examples/server/src/main.rs:19

↓ 1 callersFunctionuse_compact_lexing

(line: &str)

codag-drain/src/compress/grouper.rs:171

↓ 1 callersFunctionwhitespace_tokens

(line: &str)

codag-drain/src/compress/profile.rs:176

Methodadd_log_message

Preprocess and ingest a log message. Tokenization runs on the calling task; only the token vector is sent to the updater task for tree mutation.

drain3_rust/src/pipeline.rs:59

Functionadjacent_placeholder_collapse

()

codag-drain/src/compress/template.rs:311

Functionalpha_enum_values_are_slot_metadata

()

codag-drain/src/compress.rs:374

Functionanchored_regex_matches_members

()

codag-drain/src/compress/template.rs:327

Functionbench_scale

run with: cargo test --release bench_scale -- --nocapture --ignored

drain3_rust/src/bench.rs:112

Methodbuild

Build the profile. `groups` are emitted in ascending first-member-index order; `gid[i]` maps line `i` to its group index.

codag-drain/src/compress/profile.rs:78

Methodcollect_recursive

(node: &Node, ids: &mut Vec<usize>)

drain3_rust/src/drain.rs:377

Functioncompression_github_lora

()

codag-drain/tests/eval_loghub.rs:962

Functioncompression_loghub

()

codag-drain/tests/eval_loghub.rs:836

Functionconcurrency_overflow_returns_429

()

examples/server/tests/integration.rs:338

Methoddefault

()

codag-drain/src/compress.rs:74

Methoddefault

()

codag-drain/src/compress/grouper.rs:103

Methoddefault

()

drain3_rust/src/drain.rs:397

Methoddefault

()

drain3_rust/src/node.rs:23

Methoddefault

()

examples/server/src/session.rs:81

Functionderive_multi_ragged_falls_back_to_pair

()

codag-drain/src/compress/template.rs:366

Functionderive_multi_static_vs_vary

()

codag-drain/src/compress/template.rs:355

Functionderive_pair_static_vs_vary

()

codag-drain/src/compress/template.rs:317

Functionderive_template_preserves_punctuation

()

codag-drain/src/compress/lex.rs:169

Functiondeterministic_render

()

codag-drain/src/compress.rs:441

Functionempty_input

()

codag-drain/src/compress.rs:432

Functionempty_templates

()

codag-drain/src/stream.rs:84

Methodextend

(&mut self, lines: I)

codag-drain/src/stream.rs:33

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

drain3_rust/src/cluster.rs:26

Functionfmt_num

Format an f64 without trailing `.0` noise (`20.0` -> `20`, `0.8` -> `0.8`).

codag-drain/src/compress.rs:145

Methodfrom_env

()

examples/server/src/session.rs:36

Methodget_total_cluster_size

Sum of `size` across all live clusters.

drain3_rust/src/drain.rs:141

Functiongrouping_github_lora

()

codag-drain/tests/eval_loghub.rs:655

Functiongrouping_loghub

()

codag-drain/tests/eval_loghub.rs:473

Methodhas_numbers

(s: &str)

drain3_rust/src/drain.rs:182

Functionhealth

()

examples/server/src/routes.rs:209

Functionhealth_returns_ok

()

examples/server/tests/integration.rs:68

Functioningest

( State(state): State<AppState>, Path(id): Path<String>, Query(q): Query<TemplateQuery>, heade

examples/server/src/routes.rs:213

Functioningest_counts_accumulate_across_two_calls

()

examples/server/tests/integration.rs:236

Functioningest_ndjson_format

()

examples/server/tests/integration.rs:267

Functioningest_then_templates_text_parity

()

examples/server/tests/integration.rs:125

Functioninvalid_ndjson_returns_400

()

examples/server/tests/integration.rs:285

Functionis_useful_template

Port of `is_useful_template`, parameterized by `min_static_chars`. Counts static (non-placeholder, non-punctuation, non-space) chars.

codag-drain/src/compress/template.rs:272

Functionis_useful_template_threshold

()

codag-drain/src/compress/template.rs:345

Functionjson_serializes

()

codag-drain/src/compress.rs:455

Functionlcs_opcodes_equal_and_gap

()

codag-drain/src/compress/template.rs:293

Functionlen_and_is_empty

()

codag-drain/src/stream.rs:73

Functionlex_splits_compact_json

()

codag-drain/src/compress/lex.rs:148

Functionlex_splits_stack_frame_path

()

codag-drain/src/compress/lex.rs:158

Functionline_limit_returns_413

()

examples/server/tests/integration.rs:298

Functionmain

()

codag-drain/src/bin/codag-drain.rs:21

Functionmain

()

examples/server/src/main.rs:36

Functionmean

(vals: &[f64])

codag-drain/tests/eval_loghub.rs:316

Functionmedian_odd_and_even

()

codag-drain/src/compress/profile.rs:224

Functionmedian_over_all_values_not_distinct

()

codag-drain/src/compress/profile.rs:230

Functionmember_indices_ascending

()

codag-drain/src/compress/grouper.rs:463

Methodnew

(config: TemplaterConfig)

codag-drain/src/stream.rs:21

Methodnew

Construct a line with no level/timestamp.

codag-drain/src/compress.rs:40

Methodnew

Create a new concurrent drain pipeline. `drain` — a fully configured [`Drain`] instance (the updater takes ownership). `channel_capacity` — bounded M

drain3_rust/src/pipeline.rs:25

Methodnew

(pattern: &str, mask_with: &str)

drain3_rust/src/masking.rs:11

Methodnew

(tokens: Vec<String>, cluster_id: usize)

drain3_rust/src/cluster.rs:12

Methodnew

( depth: usize, sim_th: f64, max_children: usize, max_clusters: Option<usize>,

drain3_rust/src/drain.rs:26

Methodnew

()

drain3_rust/src/node.rs:14

Methodnew

(max_clusters: Option<usize>)

drain3_rust/src/storage.rs:19

Methodnew

()

examples/server/src/session.rs:75

Functionnumeric_detection_majority

()

codag-drain/src/compress/profile.rs:238

Functionnumeric_slot_summary_uses_all_values

()

codag-drain/src/compress.rs:398

Functionparse_body_skips_blanks_text

()

codag-drain/src/input.rs:177

Functionparse_json_line_full

()

codag-drain/src/input.rs:163

Functionparse_json_line_rejects_non_object

()

codag-drain/src/input.rs:171

Functionparse_line_extracts_iso_timestamp_and_level

()

codag-drain/src/input.rs:139

← previous next →101–200 of 240, ranked by callers