MCPcopy Index your code
hub / github.com/dream-horizon-org/logwise

github.com/dream-horizon-org/logwise @v0.1.2

Chat with this repo
repository ↗ · DeepWiki ↗ · release v0.1.2 ↗ · + Follow
2,445 symbols 9,997 edges 333 files 270 documented · 11%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

LogWise

Open-source end-to-end logging system for high-volume log processing. Streams logs from Vector → Kafka → Spark → S3/Athena, with Grafana dashboards and automated orchestration.

📚 Documentation

Full documentation is available at: https://dream-horizon-org.github.io/logwise/

🚀 Quick Start

Docker Setup (Recommended)

  1. Complete S3 & Athena Setup (required first step):
  2. Follow the S3 & Athena Setup Guide

  3. Run the setup script: bash cd deploy ./setup.sh

  4. Access services:

  5. Grafana: http://localhost:3000 (admin/admin)
  6. Spark Master UI: http://localhost:18080
  7. Orchestrator: http://localhost:8080

For detailed instructions, see the Docker Setup Guide.

Quick Links

📁 Project Structure

logwise/
├── deploy/              # Docker deployment configuration
├── vector/              # Vector log collection config
├── spark/               # Spark streaming application
├── orchestrator/        # Spring Boot orchestrator service
└── docs/                # Documentation

✨ Features

  • High-throughput log processing with Kafka streaming
  • Real-time dashboards with Grafana integration
  • Scalable architecture with Spark stream processing
  • Cost-efficient storage using S3 and Athena
  • Production-ready with automated orchestration
  • Docker support for easy deployment

🤝 Contributing

We welcome contributions! Please see our Contributing Guide for details.

📄 License

This project is licensed under the LGPL-3 License. See the LICENSE file for details.

📧 Contact

For questions or support, please open an issue or contact the maintainers.

Extension points exported contracts — how you extend this code

KafkaClient (Interface)
Generic interface for Kafka operations across different Kafka implementations. This interface abstracts the differences [2 …
orchestrator/src/main/java/com/logwise/orchestrator/client/kafka/KafkaClient.java
VectorLogsOrBuilder (Interface)
(no doc) [3 implementers]
spark/src/main/java/com/logwise/spark/protobuf/VectorLogsOrBuilder.java
VMClient (Interface)
(no doc) [2 implementers]
orchestrator/src/main/java/com/logwise/orchestrator/client/VMClient.java
Stream (Interface)
(no doc) [2 implementers]
spark/src/main/java/com/logwise/spark/stream/Stream.java
AsgClient (Interface)
(no doc) [2 implementers]
orchestrator/src/main/java/com/logwise/orchestrator/client/AsgClient.java
FeignClient (Interface)
(no doc) [2 implementers]
spark/src/main/java/com/logwise/spark/clients/FeignClient.java
KubernetesClient (Interface)
(no doc) [2 implementers]
orchestrator/src/main/java/com/logwise/orchestrator/client/KubernetesClient.java
SparkJob (Interface)
(no doc)
spark/src/main/java/com/logwise/spark/jobs/SparkJob.java

Core symbols most depended-on inside this repo

any
called by 278
orchestrator/src/main/java/com/logwise/orchestrator/common/util/CollectionUtils.java
build
called by 241
spark/src/main/java/com/logwise/spark/protobuf/VectorLogs.java
error
called by 157
orchestrator/src/main/java/com/logwise/orchestrator/rest/io/RestResponse.java
getMessage
called by 152
spark/src/main/java/com/logwise/spark/protobuf/VectorLogsOrBuilder.java
getString
called by 136
orchestrator/src/main/java/com/logwise/orchestrator/rest/RestUtil.java
getTenantConfig
called by 90
orchestrator/src/main/java/com/logwise/orchestrator/util/ApplicationConfigUtil.java
map
called by 82
orchestrator/src/main/java/com/logwise/orchestrator/common/util/MapUtils.java
of
called by 80
orchestrator/src/main/java/com/logwise/orchestrator/rest/io/Error.java

Shape

Method 2,063
Class 356
Interface 17
Enum 9

Languages

Java100%

Modules by API surface

orchestrator/src/test/java/com/logwise/orchestrator/tests/unit/service/SparkServiceTest.java105 symbols
spark/src/main/java/com/logwise/spark/protobuf/VectorLogs.java64 symbols
spark/src/test/java/com/logwise/spark/jobs/impl/PushLogsToS3SparkJobTest.java41 symbols
orchestrator/src/test/java/com/logwise/orchestrator/tests/unit/rest/RestUtilTest.java39 symbols
orchestrator/src/test/java/com/logwise/orchestrator/tests/unit/CommonUtilTest.java38 symbols
spark/src/test/java/com/logwise/spark/listeners/SparkStageListenerTest.java37 symbols
orchestrator/src/test/java/com/logwise/orchestrator/tests/unit/UtilTest.java35 symbols
orchestrator/src/test/java/com/logwise/orchestrator/tests/unit/DtoTest.java28 symbols
orchestrator/src/test/java/com/logwise/orchestrator/tests/unit/rest/ParamConverterTest.java26 symbols
orchestrator/src/main/java/com/logwise/orchestrator/service/SparkService.java25 symbols
spark/src/test/java/com/logwise/spark/services/SparkScaleServiceTest.java24 symbols
orchestrator/src/test/java/com/logwise/orchestrator/tests/unit/util/JsonUtilsTest.java24 symbols

Datastores touched

(mysql)Database · 1 repos

For agents

$ claude mcp add logwise \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page