scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 02:44:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

use primary as source for FieldTranslate backup data (#2255)

Browse source 
* use primary as source for FieldTranslate backup data
This commit is contained in:
tgruben 2023-02-16 12:13:11 -06:00 • committed by GitHub
parent 41b8505d70
commit 6a9843b4a0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
internal_client.go
View file

@ -2259,9 +2259,17 @@ func (c *InternalClient) IndexTranslateDataReader(ctx context.Context, index str
func (c *InternalClient) FieldTranslateDataReader(ctx context.Context, index, field string) (io.ReadCloser, error) { func (c *InternalClient) FieldTranslateDataReader(ctx context.Context, index, field string) (io.ReadCloser, error) {
span, ctx := tracing.StartSpanFromContext(ctx, "InternalClient.FieldTranslateDataReader") span, ctx := tracing.StartSpanFromContext(ctx, "InternalClient.FieldTranslateDataReader")
defer span.Finish() defer span.Finish()
nodes, err := c.Nodes(ctx)
if err != nil {
return nil, err
}
primary := getPrimaryNode(nodes)
if primary == nil {
return nil, errors.New("no primary")
}
// Execute request against the host. // Execute request against the host.
u := fmt.Sprintf("%s%s/internal/translate/data?index=%s&field=%s", c.defaultURI, c.prefix(), url.QueryEscape(index), url.QueryEscape(field)) u := fmt.Sprintf("%s%s/internal/translate/data?index=%s&field=%s", primary.URI, c.prefix(), url.QueryEscape(index), url.QueryEscape(field))
// Build request. // Build request.
req, err := http.NewRequest("GET", u, nil) req, err := http.NewRequest("GET", u, nil)