tugboat-logdb

README

tugboat-logdb

This is the default LogDB implementation for the Tugboat library.

How to use

package main

import (
	"github.com/coufalja/tugboat"
	"github.com/coufalja/tugboat/config"
	"github.com/coufalja/tugboat-transport/tcp"
	"github.com/coufalja/tugboat-logdb/pebble" // Import the pebble package
)

func main() {
	nhc := config.NodeHostConfig{
		NodeHostDir:    "/tmp",
		RTTMillisecond: 50,
		RaftAddress:    "localhost:8079",
	}

	// Configure the transport
	cfg := tcp.Config{
		MaxSnapshotSendBytesPerSecond: 5 * 1024 * 1024,
		MaxSnapshotRecvBytesPerSecond: 5 * 1024 * 1024,
		MutualTLS:                     false,
		RaftAddress:                   "localhost:8079", // The same RaftAddress must be passed both to transport and the NodeHost
	}
	// Configure LogDB
	lcfg := pebble.GetDefaultLogDBConfig()
	lcfg.KVLRUCacheSize = 2048
	_, _ = tugboat.NewNodeHost(nhc, tcp.Factory(cfg), pebble.Factory(lcfg))
}