diff options
author | Martin Polden <mpolden@mpolden.no> | 2023-03-20 09:11:48 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2023-03-23 12:13:46 +0100 |
commit | 4c10f2c0bb8941756aa1f3e3f9ab97b024f1f735 (patch) | |
tree | 59d55dd4a52bdd1cbdad640fca270e265bfdf342 /client | |
parent | 4c1bf7ab4ebc5e56bdc438766c66b5f6e2a3c81c (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" |