SQLog - Connecting the dots

SQLog is a Golang library that simplifies log management using slog. SQLog offers a lightweight and reliable solution for logging, making it perfect for developers seeking a cost-effective, high-performance way to monitor their applications.

Usage

Below is an example of using SQLog with the SQLite storage, with the interface exposed on port 8080. When you access http://localhost:8080?msg=test, any query parameter will be sent to the log.

You can view the generated logs at http://localhost:8080/logs/.

import (
	"log/slog"
	"net/http"
	"os"
	"strings"

	"github.com/nidorx/sqlog"

    // sqlite storage
	"github.com/nidorx/sqlog/sqlite"

    // sqlite driver
    _ "github.com/mattn/go-sqlite3"
)

func main() {
	storage, _ := sqlite.New(nil)
	logger, _ := sqlog.New(&sqlog.Config{
		Storage: storage,
	})

	// magic
	slog.SetDefault(slog.New(logger.Handler()))

	if true {
		// In the local environment, you can send the log to standard output.
		logger.Fanout(slog.NewTextHandler(os.Stdout, nil))
	}

	// SQLog ui/api handler
	logHttpHandler := logger.HttpHandler()

	// http handler (... nidorx/chain, gin-gonic/gin, gorilla/mux, julienschmidt/httprouter)
	httpHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if idx := strings.LastIndex(r.URL.Path, "/logs"); idx >= 0 {
			logHttpHandler.ServeHTTP(w, r)
		} else {
			args := []any{}
			msg := "I ❤️ SQLog"
			for k, v := range r.URL.Query() {
				if k == "msg" {
					msg = strings.Join(v, ",")
				} else {
					args = append(args, slog.Any(k, strings.Join(v, ",")))
				}
			}

			slog.Log(r.Context(), slog.LevelInfo, msg, args...)
			w.Write([]byte("🫶"))
		}
	})

	http.ListenAndServe(":8080", httpHandler)
}

Demo

You can view the current version of the SQLog demo at the links below:

The demo project captures all mouse movements and sends them to the server, which logs the received parameters.

• Log generator: https://sqlog-demo.onrender.com/

• SQLog UI : https://sqlog-demo.onrender.com/logs/

  IMPORTANT! I am using the free version of Render, so there is no guarantee of service stability or availability.

SQLog-demo.webm

The source code is in the demo directory.

How SQLog works?

SQLog is an efficient library for capturing and managing logs, designed with a focus on performance and low latency. The architecture of the solution consists of four main components: Handler, Ingester, Chunk, and Storage. Each of these components plays a crucial role in the ingestion, storage, and retrieval of logs.

1. Handler

   The Handler is an implementation of slog.Handler, allowing SQLog to be easily integrated as the standard logger in Go. It transforms logs coming from slog into JSON format using the default encoder slog.NewJSONHandler or a custom encoder, providing flexibility in log formatting.

2. Ingester

   The Ingester manages the ingestion of logs from the Handler in a non-blocking manner. It maintains an in-memory buffer that stores log entries in blocks called Chunks. When a Chunk reaches its maximum capacity, the Ingester starts using the next Chunk, marking the current one for writing to Storage. At regular intervals, the Ingester invokes the Flush method of the Storage to persist filled Chunks.

   Performance: One notable feature of the Ingester is its non-blocking implementation, which avoids using mutexes to ensure concurrency. Instead, it utilizes atomic operations from Go (sync/atomic), allowing multiple goroutines to write logs simultaneously without waiting on each other, resulting in superior performance and reduced latency.

3. Chunk

   The Chunk is a non-blocking structure that allows continuous writing of log entries. Each Chunk is a node in a linked list that has a reference to the next Chunk. The Ingester maintains references to two nodes: the current Chunk, which is still accepting new entries, and the flush Chunk, which contains completed entries that have not yet been persisted.

   Data Structure: This linked list approach not only simplifies the management of Chunks but also facilitates fast, non-blocking writing. By updating the internal references during the flush process, the Ingester ensures that logs are written efficiently with minimal performance impact.

4. Storage

   The Storage is responsible for the persistence of logs. SQLog's modular architecture allows for the implementation of different types of storage, such as disk files, databases, and external systems. Currently, there is a native implementation for SQLite (see more details) and another in development for in-memory persistence.

   Responsibilities:

   • Persistence: The Storage receives and stores Chunks from the Ingester.
   • Search: It also allows for the retrieval of records, which is used by the SQLog API for log visualization.

The combination of these layers makes SQLog a robust and efficient solution for log management, optimizing performance through a non-blocking architecture and the use of atomic operations. This results in fast, real-time log capture capable of handling high workloads without compromising efficiency.

Requirements

To use the builtin SQLite Storage implementation, you need to register the driver of your choice.

Examples:

• github.com/mattn/go-sqlite3
• modernc.org/sqlite

@TODO/IDEAS/ROADMAP

If you would like to contribute to this project, here are some tasks and ideas listed below. Feel free to suggest and implement new features in SQLog.

If you decide to work on a task, please leave a comment on the Issue so that others can collaborate.

• InMemory Storage
• Alerts - Enable the creation of alerts within SQLog. The solution should leverage the syntax of the language to evaluate logs at regular intervals and trigger alerts when specific conditions are met.
• Metrics (Count, AVG, Dashboards)
• NOT, REGEX (https://www.sqlite.org/lang_expr.html)

All kinds of contributions are welcome!

🐛 Found a bug?
Let me know by creating an issue.

References

• This project was inspired by Blacklite
• https://github.com/IGLOU-EU/go-wildcard
• The interface is inspired by Datadog

License

This code is distributed under the terms and conditions of the MIT license.