X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/eadb94554a40517ebc367959e70bd41465a5ecdf..2094173f347a22f32e8da4590bb6594dad5d7ebd:/sdk/go/arvados/keep_service.go?ds=inline diff --git a/sdk/go/arvados/keep_service.go b/sdk/go/arvados/keep_service.go index 3af7479202..da1710374e 100644 --- a/sdk/go/arvados/keep_service.go +++ b/sdk/go/arvados/keep_service.go @@ -141,20 +141,20 @@ func (s *KeepService) Untrash(ctx context.Context, c *Client, blk string) error } // Index returns an unsorted list of blocks at the given mount point. -func (s *KeepService) IndexMount(c *Client, mountUUID string, prefix string) ([]KeepServiceIndexEntry, error) { - return s.index(c, s.url("mounts/"+mountUUID+"/blocks?prefix="+prefix)) +func (s *KeepService) IndexMount(ctx context.Context, c *Client, mountUUID string, prefix string) ([]KeepServiceIndexEntry, error) { + return s.index(ctx, c, s.url("mounts/"+mountUUID+"/blocks?prefix="+prefix)) } // Index returns an unsorted list of blocks that can be retrieved from // this server. -func (s *KeepService) Index(c *Client, prefix string) ([]KeepServiceIndexEntry, error) { - return s.index(c, s.url("index/"+prefix)) +func (s *KeepService) Index(ctx context.Context, c *Client, prefix string) ([]KeepServiceIndexEntry, error) { + return s.index(ctx, c, s.url("index/"+prefix)) } -func (s *KeepService) index(c *Client, url string) ([]KeepServiceIndexEntry, error) { - req, err := http.NewRequest("GET", url, nil) +func (s *KeepService) index(ctx context.Context, c *Client, url string) ([]KeepServiceIndexEntry, error) { + req, err := http.NewRequestWithContext(ctx, "GET", url, nil) if err != nil { - return nil, fmt.Errorf("NewRequest(%v): %v", url, err) + return nil, fmt.Errorf("NewRequestWithContext(%v): %v", url, err) } resp, err := c.Do(req) if err != nil {