From 4bca83bdd8544448732d996919da4d7c61a971dc Mon Sep 17 00:00:00 2001
From: Paul Buetow <paul@buetow.org>
Date: Sat, 30 Oct 2021 18:14:46 +0300
Subject: add support to read from stdin pipe in serverless mode, e.g. grep
 foo.log | dmap "select from ...."

---
 internal/datas/rbuffer.go | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'internal/datas/rbuffer.go')

diff --git a/internal/datas/rbuffer.go b/internal/datas/rbuffer.go
index df8f622..a705a43 100644
--- a/internal/datas/rbuffer.go
+++ b/internal/datas/rbuffer.go
@@ -2,6 +2,8 @@ package datas
 
 import "fmt"
 
+// TODO: Unused code file, delete it.
+
 // RBuffer is a simple circular string ring buffer data structure.
 type RBuffer struct {
 	Capacity int
-- 
cgit v1.2.3


From 6181a10443b5122e94c85a7c17f3603683d64cdf Mon Sep 17 00:00:00 2001
From: Paul Buetow <paul@buetow.org>
Date: Sat, 30 Oct 2021 18:17:53 +0300
Subject: remove unused rbuffer package

---
 internal/datas/rbuffer.go | 51 -----------------------------------------------
 1 file changed, 51 deletions(-)
 delete mode 100644 internal/datas/rbuffer.go

(limited to 'internal/datas/rbuffer.go')

diff --git a/internal/datas/rbuffer.go b/internal/datas/rbuffer.go
deleted file mode 100644
index a705a43..0000000
--- a/internal/datas/rbuffer.go
+++ /dev/null
@@ -1,51 +0,0 @@
-package datas
-
-import "fmt"
-
-// TODO: Unused code file, delete it.
-
-// RBuffer is a simple circular string ring buffer data structure.
-type RBuffer struct {
-	Capacity int
-	size     int
-	readPos  int
-	writePos int
-	data     []string
-}
-
-// NewRBuffer creates a new string ring buffer.
-func NewRBuffer(capacity int) (*RBuffer, error) {
-	if capacity < 1 {
-		return nil, fmt.Errorf("RBuffer capacity must not be less than 1")
-	}
-
-	r := RBuffer{
-		Capacity: capacity,
-		size:     capacity + 1,
-		data:     make([]string, capacity+1),
-	}
-
-	return &r, nil
-}
-
-// Add a value.
-func (r *RBuffer) Add(value string) {
-	r.data[r.writePos] = value
-	r.writePos = (r.writePos + 1) % r.size
-
-	if r.writePos == r.readPos {
-		r.readPos = (r.readPos + 1) % r.size
-	}
-}
-
-// Get a value.
-func (r *RBuffer) Get() (string, bool) {
-	if r.readPos == r.writePos {
-		// RBuffer is empty.
-		return "", false
-	}
-
-	value := r.data[r.readPos]
-	r.readPos = (r.readPos + 1) % r.size
-	return value, true
-}
-- 
cgit v1.2.3