- Notifications
You must be signed in to change notification settings - Fork1
Rebuf is a library that can be used as a WAL which can be used for logging and later replaying the data bytes during downstream service failure
License
NotificationsYou must be signed in to change notification settings
stym06/rebuf
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
rebuf is a Golang implementation of WAL (Write Ahead||After Logging) which can also be used to log data bytes during a downstream service issue which can later be replayed on-demand
- Create and replay log data on any filesystem.
- Lightweight and easy to use.
- Efficient storage and retrieval of log data.
- Clone the repository:
git clone https://github.com/stym06/rebuf.git - Navigate to the project directory:
cd rebuf - Install the necessary dependencies by running:
go mod download
func writeToStdout(data []byte) error {slog.Info(string(data))return nil}func main() {logger := slog.New(slog.NewTextHandler(os.Stdout, nil))//Init the RebufOptionsrebufOptions := &rebuf.RebufOptions{LogDir: "/Users/satyamraj/personal/rebuf/data",FsyncTime: 5 * time.Second,MaxLogSize: 50,MaxSegments: 5,Logger: logger,}//Init Rebufrebuf, err := rebuf.Init(rebufOptions)if err != nil {logger.Info("Error during Rebuf creation: " + err.Error())}defer rebuf.Close()// Write Bytesfor i := 0; i < 30; i++ {logger.Info("Writing data: ", "iter", i)go rebuf.Write([]byte("Hello world"))time.Sleep(300 * time.Millisecond)}//Replay and write to stdoutrebuf.Replay(writeToStdout)if err != nil {logger.Info(err.Error())}time.Sleep(30 * time.Second)}This project is licensed under the MIT License. See theLICENSE file for more information.
If you have any questions or concerns, please feel free to reach out to the author on GitHub:@stym06.