Skip to content
log-10xPublic

About

Log10x pipeline modules

Resources

Security policy

Stars

0 stars

Watchers

0 watching

Forks

Latest commit

Β 

History

271 Commits

Folders and files

Repository files navigation

Log10x Modules

Core module definitions for the Log10x engine, the brain that powers log cost analysis, filtering, and optimization. Start with the MCP Server, it guides you through installing and configuring the apps below based on k8s discovery of your environment.

Full Documentation: doc.log10x.com

Architecture Overview

β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”
β”‚                            Log10x Engine                                  β”‚
β”‚                                                                           β”‚
β”‚  β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”  β”‚
β”‚  β”‚                          Applications                               β”‚  β”‚
β”‚  β”‚                                                                     β”‚  β”‚
β”‚  β”‚  β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”  β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”   β”‚  β”‚
β”‚  β”‚  β”‚     Runtime Apps        β”‚  β”‚        Setup / Tools            β”‚   β”‚  β”‚
β”‚  β”‚  β”‚                         β”‚  β”‚                                 β”‚   β”‚  β”‚
β”‚  β”‚  β”‚  β”œβ”€ Reporter (DaemonSet)β”‚  β”‚  β”œβ”€ Dev (local CLI)             β”‚   β”‚  β”‚
β”‚  β”‚  β”‚  β”œβ”€ Receiver (sidecar)  β”‚  β”‚  β”œβ”€ Compiler (symbol generation)β”‚   β”‚  β”‚
β”‚  β”‚  β”‚  β”‚  Filter + Compact    β”‚  β”‚  └─ MCP scaffold (validation)   β”‚   β”‚  β”‚
β”‚  β”‚  β”‚  └─ Retriever (S3 query)β”‚  β”‚                                 β”‚   β”‚  β”‚
β”‚  β”‚  β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜  β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜   β”‚  β”‚
β”‚  β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜  β”‚
β”‚                                                                           β”‚
β”‚  β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”  β”‚
β”‚  β”‚                           Pipelines                                 β”‚  β”‚
β”‚  β”‚                                                                     β”‚  β”‚
β”‚  β”‚  β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”  β”‚  β”‚
β”‚  β”‚  β”‚  COMPILE: Pull ──► Scan ──► Link ──► Push                     β”‚  β”‚  β”‚
β”‚  β”‚  β”‚           (GitHub, Docker, Helm) β†’ (AST, Bytecode) β†’ Symbols  β”‚  β”‚  β”‚
β”‚  β”‚  β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜  β”‚  β”‚
β”‚  β”‚                                                                     β”‚  β”‚
β”‚  β”‚  β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”  β”‚  β”‚
β”‚  β”‚  β”‚  RUN: Input ──► Transform ──► Aggregate ──► Output            β”‚  β”‚  β”‚
β”‚  β”‚  β”‚       (Forwarders, Analyzers) β†’ (Script) β†’ (Events, Metrics)  β”‚  β”‚  β”‚
β”‚  β”‚  β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜  β”‚  β”‚
β”‚  β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜  β”‚
β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜

Directory Structure

modules/
β”œβ”€β”€ apps/                           # Pre-built applications (flat topology)
β”‚   β”œβ”€β”€ compiler/                   # Symbol compilation app
β”‚   β”œβ”€β”€ dev/                        # Local preview CLI
β”‚   β”œβ”€β”€ mcp/                        # stdin/stdout scaffold used by the MCP server
β”‚   β”œβ”€β”€ reporter/                   # DaemonSet pre-SIEM cost insight
β”‚   β”œβ”€β”€ receiver/                  # Sidecar: Filter + Compact modes
β”‚   └── retriever/                   # S3 data lake indexing + on-demand query
β”‚
β”œβ”€β”€ pipelines/                      # Core pipeline definitions
β”‚   β”œβ”€β”€ compile/                    # Symbol compilation pipeline
β”‚   β”‚   └── modules/                # pull/, scanner/, link/
β”‚   β”œβ”€β”€ run/                        # Event processing pipeline
β”‚   β”‚   └── modules/                # input/, transform/, aggregate/, output/
β”‚   β”œβ”€β”€ doc/                        # Documentation generation pipeline
β”‚   └── shared/                     # Shared utilities
β”‚
└── lib/                            # Shared libraries
    └── script/                     # JavaScript libraries

Applications

In-Cluster Applications

Deployed alongside log forwarders (Fluentd, Fluent Bit, Filebeat, Logstash).

App Purpose Documentation Run Guide
Reporter Cost attribution metrics (DaemonSet, pre-SIEM, not in log path) Overview Run
Receiver Two modes: Filter (lossy, budget sampling, mute files) and Compact (lossless volume reduction via SIEM-side expand plugin, where the destination supports it) Overview Run
β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”
β”‚                    In-Cluster Deployment                         β”‚
β”‚                                                                  β”‚
β”‚   Reporter (DaemonSet) ─── tails pre-SIEM ────► Metrics          β”‚
β”‚                                                                  β”‚
β”‚   Application ──► Log Forwarder ──► Receiver ──► Analyzer       β”‚
β”‚   (logs)          (Fluentd,         (sidecar,     (Splunk,       β”‚
β”‚                    Filebeat)         Filter or     Elastic)      β”‚
β”‚                                      Compact)                    β”‚
β”‚                                                                  β”‚
β”‚   Metrics: ───────────────────────► Prometheus ────► Grafana    β”‚
β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜

Storage & Agent Applications

App Purpose Documentation Run Guide
Retriever S3 data lake indexing & queries Overview Run
MCP Agent control plane, reads Reporter metrics, commands Receiver/Retriever via GitOps Overview Run

For agentless SIEM-side cost analysis, use the log10x-mcp server's log10x_poc_from_siem_submit tool.

Setup & Developer Tools

App Purpose Documentation Run Guide
Dev Local CLI to preview savings on your logs Overview Run
Compile Generate symbol libraries from source code (optional, default library covers 150+ frameworks) Overview Test / Deploy

Pipelines

Compile Pipeline

Scans source code and generates symbol files for log template extraction.

β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”    β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”    β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”    β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”
β”‚  PULL    │───►│  SCAN    │───►│  LINK    │───►│  PUSH    β”‚
β”‚          β”‚    β”‚          β”‚    β”‚          β”‚    β”‚          β”‚
β”‚ GitHub   β”‚    β”‚ javaParserβ”‚   β”‚ Cross-refβ”‚    β”‚ S3       β”‚
β”‚ Docker   β”‚    β”‚ pythonAST β”‚   β”‚ analysis β”‚    β”‚ Local    β”‚
β”‚ Helm     β”‚    β”‚ ANTLR     β”‚   β”‚          β”‚    β”‚          β”‚
β”‚ Local    β”‚    β”‚ bytecode  β”‚   β”‚          β”‚    β”‚          β”‚
β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜    β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜    β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜    β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜

Documentation: Compile Pipeline

Module Type Examples Docs
Pull github, docker, helm, local Pull Modules
Scanner javaParser, pythonAST, scalameta, antlr, bytecode Scanner Modules

Run Pipeline

Processes log events in real-time for optimization, filtering, and reporting.

β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”    β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”    β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”    β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”
β”‚  INPUT   │───►│ TRANSFORM │───►│ AGGREGATE │───►│  OUTPUT  β”‚
β”‚          β”‚    β”‚           β”‚    β”‚           β”‚    β”‚          β”‚
β”‚ Forwarderβ”‚    β”‚ Script    β”‚    β”‚ Group by  β”‚    β”‚ Events   β”‚
β”‚ Analyzer β”‚    β”‚ Fields    β”‚    β”‚ template  β”‚    β”‚ Metrics  β”‚
β”‚ S3       β”‚    β”‚ Timestamp β”‚    β”‚ app       β”‚    β”‚ Stream   β”‚
β”‚ Stdin    β”‚    β”‚ Structure β”‚    β”‚ level     β”‚    β”‚          β”‚
β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜    β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜    β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜    β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜

Documentation: Run Pipeline

Module Type Examples Docs
Input/Forwarder fluentd, fluentbit, filebeat, logstash, otel Forwarders
Input/Analyzer splunk, elastic, datadog, cloudwatchLogs Analyzers
Transform script, fields, timestamp, structure Transform
Output/Event stdout, file, http, unix Event Output
Output/Metric prometheus, datadog, cloudwatch Metric Output

Configuration Reference

All configuration formats and specifications are documented at doc.log10x.com/config.

Topic Description Documentation
Module Configuration module.yaml structure and settings Module Config
App Configuration app.yaml structure and configFolders App Config
YAML Format YAML syntax and +include directives YAML Reference
JavaScript Scripting API and functions JavaScript
Symbol Files Symbol file format and usage Symbols
Folder Structure Configuration folder conventions Folders
Matching Rules Pattern matching syntax Match
CLI Options Command-line interface reference CLI

API Reference

Topic Description Documentation
Input API TenXObject structure and input handling Input API
Output API TenXSummary structure and output handling Output API
JavaScript API Scripting functions and objects JavaScript API
Compile API Compiler programmatic interface Compile API

Architecture

For detailed architecture documentation:

Topic Documentation
Engine Architecture Architecture Overview
Pipeline Architecture Pipeline Design
Module System Module Architecture
Launcher Options Launcher (sidecar, job, function)
GitOps Integration GitOps Workflows

Statistics

Category Count
Total Directories 180+
YAML Configuration Files 275+
Applications 10
Pipeline Types 4
Input Modules 15+
Output Modules 20+
Scanner Modules 12+
Supported Forwarders 5
Supported Analyzers 6

Quick Links

Resource URL
Documentation Hub doc.log10x.com
Getting Started doc.log10x.com/home
Installation doc.log10x.com/install
Applications doc.log10x.com/apps
Configuration doc.log10x.com/config
API Reference doc.log10x.com/api

License

This repository is licensed under the MIT License.

Log10x Product License Required

This repository contains module definitions for the Log10x engine. While these definitions are open source, running Log10x requires a commercial license.

What's Open Source What Requires License
Module YAML definitions Log10x engine/runtime
Documentation files Log10x apps (Reporter, Receiver, Retriever)
Schema definitions Executing pipelines

Get a Log10x License:

About

Log10x pipeline modules

Resources

Security policy

Stars

0 stars

Watchers

0 watching

Forks

Releases

Packages

Used by

Contributors

Languages