Update tikv client version and add one PC support

1 files changed, 38 insertions, 0 deletions

diff --git a/weed/filer/reader_pattern.go b/weed/filer/reader_pattern.go
new file mode 100644
index 000000000..b860bc577
--- /dev/null
+++ b/weed/filer/reader_pattern.go
@@ -0,0 +1,38 @@
+package filer
+
+type ReaderPattern struct {
+	isStreaming    bool
+	lastReadOffset int64
+}
+
+// For streaming read: only cache the first chunk
+// For random read: only fetch the requested range, instead of the whole chunk
+
+func NewReaderPattern() *ReaderPattern {
+	return &ReaderPattern{
+		isStreaming:    true,
+		lastReadOffset: -1,
+	}
+}
+
+func (rp *ReaderPattern) MonitorReadAt(offset int64, size int) {
+	isStreaming := true
+	if rp.lastReadOffset > offset {
+		isStreaming = false
+	}
+	if rp.lastReadOffset == -1 {
+		if offset != 0 {
+			isStreaming = false
+		}
+	}
+	rp.lastReadOffset = offset
+	rp.isStreaming = isStreaming
+}
+
+func (rp *ReaderPattern) IsStreamingMode() bool {
+	return rp.isStreaming
+}
+
+func (rp *ReaderPattern) IsRandomMode() bool {
+	return !rp.isStreaming
+}