Function waitForViewIndexing

db/design_doc.go:679–711

Issues stale=false view queries to determine when view indexing is complete. Retries on timeout

(ctx context.Context, viewStore sgbucket.ViewStore, bucketName string, ddocName string, viewName string)

// Issues stale=false view queries to determine when view indexing is complete.  Retries on timeout
func waitForViewIndexing(ctx context.Context, viewStore sgbucket.ViewStore, bucketName string, ddocName string, viewName string) error {
	opts := map[string]interface{}{"stale": false, "key": fmt.Sprintf("view_%s_ready_check", viewName), "limit": 1}

	// Not using standard retry loop here, because we want to retry indefinitely on view timeout (since view indexing could potentially take hours), and
	// we don't need to sleep between attempts.  Using manual exponential backoff retry processing for non-timeout related errors, waits up to ~5 min
	errRetryCount := 0
	retrySleep := float64(100)
	maxRetry := 18
	for {
		results, err := viewStore.ViewQuery(ctx, ddocName, viewName, opts)
		if results != nil {
			_ = results.Close()
		}
		if err == nil {
			return nil
		}

		// Retry on timeout or undefined view errors , otherwise return the error
		if err == base.ErrViewTimeoutError {
			base.InfofCtx(ctx, base.KeyAll, "Timeout waiting for view %q to be ready for bucket %q - retrying...", viewName, base.UD(bucketName))
		} else {
			// For any other error, retry up to maxRetry, to wait for view initialization on the server
			errRetryCount++
			if errRetryCount > maxRetry {
				return err
			}
			base.WarnfCtx(ctx, "Error waiting for view %q to be ready for bucket %q - retrying...(%d/%d)", viewName, bucketName, errRetryCount, maxRetry)
			time.Sleep(time.Duration(retrySleep) * time.Millisecond)
			retrySleep *= float64(1.5)
		}
	}

}

func removeObsoleteDesignDocs(ctx context.Context, viewStore sgbucket.ViewStore, previewOnly bool, useViews bool) (removedDesignDocs []string, err error) {