summaryrefslogtreecommitdiffstats
path: root/client
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2023-03-20 09:11:48 +0100
committerMartin Polden <mpolden@mpolden.no>2023-03-23 12:13:46 +0100
commit4c10f2c0bb8941756aa1f3e3f9ab97b024f1f735 (patch)
tree59d55dd4a52bdd1cbdad640fca270e265bfdf342 /client
parent4c1bf7ab4ebc5e56bdc438766c66b5f6e2a3c81c (diff)
Rename feed -> document
Diffstat (limited to 'client')
-rw-r--r--client/go/internal/vespa/document/document.go (renamed from client/go/internal/vespa/feed/document.go)8
-rw-r--r--client/go/internal/vespa/document/document_test.go (renamed from client/go/internal/vespa/feed/document_test.go)4
-rw-r--r--client/go/internal/vespa/document/feeder.go (renamed from client/go/internal/vespa/feed/feed.go)4
-rw-r--r--client/go/internal/vespa/document/http.go (renamed from client/go/internal/vespa/feed/http.go)2
-rw-r--r--client/go/internal/vespa/document/http_test.go (renamed from client/go/internal/vespa/feed/http_test.go)2
5 files changed, 10 insertions, 10 deletions
diff --git a/client/go/internal/vespa/feed/document.go b/client/go/internal/vespa/document/document.go
index 72898529013..b327011be4b 100644
--- a/client/go/internal/vespa/feed/document.go
+++ b/client/go/internal/vespa/document/document.go
@@ -1,4 +1,4 @@
-package feed
+package document
import (
"bufio"
@@ -162,7 +162,7 @@ func parseDocument(d *Document) error {
} else {
return fmt.Errorf("invalid document: missing operation: %v", d)
}
- docId, err := ParseDocumentId(id)
+ docId, err := ParseId(id)
if err != nil {
return err
}
@@ -240,8 +240,8 @@ func parseError(value string) error {
return fmt.Errorf("invalid document: expected id:<namespace>:<document-type>:[n=<number>|g=<group>]:<user-specific>, got %q", value)
}
-// ParseDocumentId parses a serialized document ID string.
-func ParseDocumentId(serialized string) (DocumentId, error) {
+// ParseId parses a serialized document ID string.
+func ParseId(serialized string) (DocumentId, error) {
parts := strings.SplitN(serialized, ":", 4)
if len(parts) < 4 || parts[0] != "id" {
return DocumentId{}, parseError(serialized)
diff --git a/client/go/internal/vespa/feed/document_test.go b/client/go/internal/vespa/document/document_test.go
index e409c55c90d..03df7b62045 100644
--- a/client/go/internal/vespa/feed/document_test.go
+++ b/client/go/internal/vespa/document/document_test.go
@@ -1,4 +1,4 @@
-package feed
+package document
import (
"bytes"
@@ -78,7 +78,7 @@ func TestParseDocumentId(t *testing.T) {
{"id:ns:type::", DocumentId{}, true},
}
for i, tt := range tests {
- parsed, err := ParseDocumentId(tt.in)
+ parsed, err := ParseId(tt.in)
if err == nil && tt.fail {
t.Errorf("#%d: expected error for ParseDocumentId(%q), but got none", i, tt.in)
}
diff --git a/client/go/internal/vespa/feed/feed.go b/client/go/internal/vespa/document/feeder.go
index ac2dcc4e049..6a0249ab9b9 100644
--- a/client/go/internal/vespa/feed/feed.go
+++ b/client/go/internal/vespa/document/feeder.go
@@ -1,4 +1,4 @@
-package feed
+package document
import (
"time"
@@ -90,7 +90,7 @@ func (s *Stats) Add(other Stats) {
s.BytesRecv += other.BytesRecv
}
-// Feeder is the interface for code that can feed documents.
+// Feeder is the interface for a consumer of documents.
type Feeder interface {
Send(Document) Result
Stats() Stats
diff --git a/client/go/internal/vespa/feed/http.go b/client/go/internal/vespa/document/http.go
index 87630924a3a..1d0248c35f9 100644
--- a/client/go/internal/vespa/feed/http.go
+++ b/client/go/internal/vespa/document/http.go
@@ -1,4 +1,4 @@
-package feed
+package document
import (
"bytes"
diff --git a/client/go/internal/vespa/feed/http_test.go b/client/go/internal/vespa/document/http_test.go
index 42a350b9279..2bc7feb21ff 100644
--- a/client/go/internal/vespa/feed/http_test.go
+++ b/client/go/internal/vespa/document/http_test.go
@@ -1,4 +1,4 @@
-package feed
+package document
import (
"bytes"