diff options
| author | Christopher Speller <crspeller@gmail.com> | 2018-06-21 13:10:40 -0700 |
|---|---|---|
| committer | Harrison Healey <harrisonmhealey@gmail.com> | 2018-06-21 16:10:40 -0400 |
| commit | 8526739066ccb00ccd24b74650a7d7b284442985 (patch) | |
| tree | 282512ae2ad95c98a9ca82de304a410b6b56685c /vendor/gopkg.in/olivere/elastic.v5/bulk.go | |
| parent | a59ccaa8b3844895dde3980e6224fef46ff4a1c8 (diff) | |
| download | chat-8526739066ccb00ccd24b74650a7d7b284442985.tar.gz chat-8526739066ccb00ccd24b74650a7d7b284442985.tar.bz2 chat-8526739066ccb00ccd24b74650a7d7b284442985.zip | |
MM-10934 Update server dependencies. (#8981)
* Changing throttled import path.
* Upgrading dependencies.
Diffstat (limited to 'vendor/gopkg.in/olivere/elastic.v5/bulk.go')
| -rw-r--r-- | vendor/gopkg.in/olivere/elastic.v5/bulk.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/vendor/gopkg.in/olivere/elastic.v5/bulk.go b/vendor/gopkg.in/olivere/elastic.v5/bulk.go index 452f5c394..7e2d3c53f 100644 --- a/vendor/gopkg.in/olivere/elastic.v5/bulk.go +++ b/vendor/gopkg.in/olivere/elastic.v5/bulk.go @@ -52,7 +52,8 @@ func NewBulkService(client *Client) *BulkService { return builder } -func (s *BulkService) reset() { +// Reset cleans up the request queue +func (s *BulkService) Reset() { s.requests = make([]BulkableRequest, 0) s.sizeInBytes = 0 s.sizeInBytesCursor = 0 @@ -262,7 +263,7 @@ func (s *BulkService) Do(ctx context.Context) (*BulkResponse, error) { } // Reset so the request can be reused - s.reset() + s.Reset() return ret, nil } |