Update to version v2.2.0

LICENSE

@@ -199,4 +199,4 @@
    distributed under the License is distributed on an "AS IS" BASIS,
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
-   limitations under the License.
+   limitations under the License.

benchmarks/Dockerfile

@@ -35,7 +35,7 @@ RUN git clone https://github.com/wg/wrk.git && cd wrk && \
 
 # Install Benchmark's golang dependencies
 #########################################
-RUN go get -insecure git.itv.restr.im/itv-backend/reindexer && \
+RUN go get -insecure github.com/restream/reindexer && \
     go get github.com/tarantool/go-tarantool && \
     go get github.com/yunge/sphinx && \
     go get gopkg.in/mgo.v2 && \
@@ -50,7 +50,7 @@ RUN go get github.com/boltdb/bolt && \
     go get github.com/labstack/echo
 
 # Build Reindexer
-RUN make -C /go/src/git.itv.restr.im/itv-backend/reindexer/cpp_src -j8 EXTRA_CFLAGS=-DNDEBUG
+RUN make -C /go/src/github.com/restream/reindexer/cpp_src -j8 EXTRA_CFLAGS=-DNDEBUG
 
 # Install elastic search
 ########################

benchmarks/bench_queries_test.go

@@ -3,7 +3,7 @@ package main
 import (
 	"testing"
 
-	"git.itv.restr.im/itv-backend/reindexer/benchmarks/repo"
+	"github.com/restream/reindexer/benchmarks/repo"
 )
 
 func BenchmarkElasticGetByID(b *testing.B)            { repo.Get("elastic").QueryByID(b.N, false) }

benchmarks/bench_text_test.go

@@ -3,7 +3,7 @@ package main
 import (
 	"testing"
 
-	"git.itv.restr.im/itv-backend/reindexer/benchmarks/repo"
+	"github.com/restream/reindexer/benchmarks/repo"
 )
 
 func BenchmarkElasticFullText(b *testing.B) {

benchmarks/http.go

@@ -6,7 +6,7 @@ import (
 	"log"
 	"unicode/utf8"
 
-	"git.itv.restr.im/itv-backend/reindexer/benchmarks/repo"
+	"github.com/restream/reindexer/benchmarks/repo"
 
 	"github.com/buaazp/fasthttprouter"
 	"github.com/valyala/fasthttp"

benchmarks/http_echo.go

@@ -5,7 +5,7 @@ import (
 	"log"
 	"net/http"
 
-	"git.itv.restr.im/itv-backend/reindexer/benchmarks/repo"
+	"github.com/restream/reindexer/benchmarks/repo"
 
 	"github.com/labstack/echo"
 )

benchmarks/init_test.go

@@ -5,7 +5,7 @@ import (
 	"strings"
 	"testing"
 
-	"git.itv.restr.im/itv-backend/reindexer/benchmarks/repo"
+	"github.com/restream/reindexer/benchmarks/repo"
 )
 
 func TestMain(t *testing.T) {

benchmarks/main.go

@@ -3,7 +3,7 @@ package main
 import (
 	"flag"
 
-	"git.itv.restr.im/itv-backend/reindexer/benchmarks/repo"
+	"github.com/restream/reindexer/benchmarks/repo"
 )
 
 const itemsInDataSet = 100000

benchmarks/repo/reindex.go

@@ -4,9 +4,9 @@ import (
 	"log"
 	"math/rand"
 
-	"git.itv.restr.im/itv-backend/reindexer"
-	_ "git.itv.restr.im/itv-backend/reindexer/bindings/builtin"
-	_ "git.itv.restr.im/itv-backend/reindexer/bindings/cproto"
+	"github.com/restream/reindexer"
+	_ "github.com/restream/reindexer/bindings/builtin"
+	_ "github.com/restream/reindexer/bindings/cproto"
 )
 
 type ReindexRepo struct {

bindings.go

@@ -8,9 +8,9 @@ import (
 	"strings"
 	"time"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
-	"git.itv.restr.im/itv-backend/reindexer/bindings/builtinserver/config"
-	"git.itv.restr.im/itv-backend/reindexer/cjson"
+	"github.com/restream/reindexer/bindings"
+	"github.com/restream/reindexer/bindings/builtinserver/config"
+	"github.com/restream/reindexer/cjson"
 )
 
 const (

bindings/builtin/builtin.go

@@ -15,8 +15,8 @@ import (
 	"time"
 	"unsafe"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
-	"git.itv.restr.im/itv-backend/reindexer/cjson"
+	"github.com/restream/reindexer/bindings"
+	"github.com/restream/reindexer/cjson"
 )
 
 const defCgoLimit = 2000

bindings/builtinserver/builtinserver.go

@@ -12,9 +12,9 @@ import (
 	"time"
 	"unsafe"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
-	"git.itv.restr.im/itv-backend/reindexer/bindings/builtin"
-	"git.itv.restr.im/itv-backend/reindexer/bindings/builtinserver/config"
+	"github.com/restream/reindexer/bindings"
+	"github.com/restream/reindexer/bindings/builtin"
+	"github.com/restream/reindexer/bindings/builtinserver/config"
 )
 
 var defaultStartupTimeout time.Duration = time.Minute * 3

bindings/cproto/connection.go

@@ -12,8 +12,8 @@ import (
 	"sync/atomic"
 	"time"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
-	"git.itv.restr.im/itv-backend/reindexer/cjson"
+	"github.com/restream/reindexer/bindings"
+	"github.com/restream/reindexer/cjson"
 )
 
 type bufPtr struct {

bindings/cproto/cproto.go

@@ -11,8 +11,8 @@ import (
 	"sync/atomic"
 	"time"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
-	"git.itv.restr.im/itv-backend/reindexer/cjson"
+	"github.com/restream/reindexer/bindings"
+	"github.com/restream/reindexer/cjson"
 )
 
 const (

bindings/cproto/encdec.go

@@ -4,9 +4,9 @@ import (
 	"fmt"
 	"unsafe"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
+	"github.com/restream/reindexer/bindings"
 
-	"git.itv.restr.im/itv-backend/reindexer/cjson"
+	"github.com/restream/reindexer/cjson"
 )
 
 type rpcEncoder struct {

bindings/cproto/netbuf.go

@@ -6,7 +6,7 @@ import (
 	"sync"
 	"time"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
+	"github.com/restream/reindexer/bindings"
 )
 
 var bufPool sync.Pool

bindings/interface.go

@@ -5,7 +5,7 @@ import (
 	"net/url"
 	"time"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings/builtinserver/config"
+	"github.com/restream/reindexer/bindings/builtinserver/config"
 )
 
 type IndexDef struct {

cpp_src/client/namespace.cc

@@ -14,4 +14,4 @@ Item Namespace::NewItem() {
 }
 
 }  // namespace client
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/client/namespace.h

@@ -25,4 +25,4 @@ class Namespace {
 };
 
 }  // namespace client
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/cmake/modules/FindGperftools.cmake

@@ -49,4 +49,4 @@ mark_as_advanced(
   GPERFTOOLS_TCMALLOC_AND_PROFILER
   GPERFTOOLS_LIBRARIES
   GPERFTOOLS_INCLUDE_DIR)
-
+

cpp_src/cmake/modules/FindJemalloc.cmake

@@ -52,4 +52,4 @@ if ( UNIX )
   endif ( JEMALLOC_LIBRARY )
 
   mark_as_advanced( JEMALLOC_FOUND JEMALLOC_LIBRARY JEMALLOC_EXTRA_LIBRARIES JEMALLOC_INCLUDE_DIR )
-endif (UNIX)
+endif (UNIX)

cpp_src/cmake/modules/FindSnappy.cmake

@@ -78,4 +78,4 @@ endif ()
 mark_as_advanced(
   SNAPPY_LIBRARY
   SNAPPY_INCLUDE_DIR
-)
+)

cpp_src/cmd/reindexer_server/contrib/Dockerfile

@@ -9,7 +9,7 @@ RUN mkdir /src && \
     echo "noinst_PROGRAMS =" >> Makefile.am && \
     ./autogen.sh &&  ./configure && make -j8 && make install && \
     cd .. && \
-    git clone https://git.itv.restr.im/itv-backend/reindexer && \
+    git clone https://github.com/restream/reindexer && \
     cd reindexer && \
     git checkout develop && \
     ./dependencies.sh && \

cpp_src/cmd/reindexer_server/contrib/sysvinit.in

@@ -95,4 +95,4 @@ case "$1" in
     ;;
 esac
 
-exit 0
+exit 0

cpp_src/cmd/reindexer_server/test/mocks/users.json

@@ -23,4 +23,4 @@
             "*": "owner"
         }
     }
-}
+}

cpp_src/core/cjson/cjsonbuilder.h

@@ -99,4 +99,4 @@ class CJsonBuilder {
 	int count_ = 0;
 };
 
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/core/ft/numtotext.cc

@@ -140,4 +140,4 @@ vector<string>& NumToText::convert(string_view str, std::vector<std::string>& ou
 	}
 	return output;
 }
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/core/ft/numtotext.h

@@ -13,4 +13,4 @@ class NumToText {
 	static std::vector<std::string>& convert(string_view numStr, std::vector<std::string>& output);
 };
 
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/core/ft/stopwords/stop.h

@@ -3,4 +3,4 @@
 namespace reindexer {
 extern const char *stop_words_ru[];
 extern const char *stop_words_en[];
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/core/ft/typos.cc

@@ -37,4 +37,4 @@ void mktypos(typos_context *ctx, string_view word, int level, int maxTyposLen, s
 	mktyposInternal(ctx, ctx->utf16Word, level, maxTyposLen, callback);
 }
 
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/estl/chunk_buf.h

@@ -131,4 +131,4 @@ class chain_buf {
 	Mutex mtx_;
 };
 
-};  // namespace reindexer
+};  // namespace reindexer

cpp_src/estl/span.h

@@ -70,4 +70,4 @@ class span {
 
 inline static span<char> giftStr(string_view sv) { return span<char>(const_cast<char*>(sv.data()), sv.size()); }
 
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/estl/trivial_reverse_iterator.h

@@ -105,4 +105,4 @@ class trivial_reverse_iterator
 	inline bool EQ(Iterator lhs, Iterator rhs) const { return lhs == rhs; }
 };
 
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/gtests/bench/dict.txt

@@ -125720,4 +125720,4 @@
 ящик
 ящичек
 ящичник
-ящичный
+ящичный

cpp_src/replicator/walrecord.h

@@ -57,4 +57,4 @@ struct PackedWALRecord : public h_vector<uint8_t, 12> {
 	using h_vector<uint8_t, 12>::h_vector;
 	void Pack(const WALRecord &rec);
 };
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/replicator/walselecter.h

@@ -15,4 +15,4 @@ class WALSelecter {
 	Namespace *ns_;
 };
 
-};  // namespace reindexer
+};  // namespace reindexer

cpp_src/server/rpcupdatespusher.h

@@ -22,4 +22,4 @@ class RPCUpdatesPusher : public reindexer::IUpdatesObserver {
 };
 }  // namespace cproto
 }  // namespace net
-}  // namespace reindexer
+}  // namespace reindexer

cpp_src/vendor/atoi/atoi.h

@@ -216,4 +216,4 @@ inline typename std::enable_if<std::is_unsigned<T>::value, T>::type atoi(char co
 
 }  // namespace jsteemann
 
-#endif
+#endif

cpp_src/vendor/base64/base64.c

@@ -181,4 +181,4 @@ int Base64encode(char *encoded, const char *string, int len) {
 
 	*p++ = '\0';
 	return p - encoded;
-}
+}

dependencies.sh

@@ -212,4 +212,4 @@ if [ $? -eq 0 ]; then
     fi
 else
     error_msg "Unsupported OS type."
-fi
+fi

iterator.go

@@ -7,7 +7,7 @@ import (
 	"reflect"
 	"strings"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
+	"github.com/restream/reindexer/bindings"
 )
 
 // ExplainResults presents query plan

readme.md

@@ -121,13 +121,13 @@ import (
 	"fmt"
 	"math/rand"
 
-	"git.itv.restr.im/itv-backend/reindexer"
+	"github.com/restream/reindexer"
 	// choose how the Reindexer binds to the app (in this case "builtin," which means link Reindexer as a static library)
-	_ "git.itv.restr.im/itv-backend/reindexer/bindings/builtin"
+	_ "github.com/restream/reindexer/bindings/builtin"
 
 	// OR link Reindexer as static library with bundled server.
-	// _ "git.itv.restr.im/itv-backend/reindexer/bindings/builtinserver"
-	// "git.itv.restr.im/itv-backend/reindexer/bindings/builtinserver/config"
+	// _ "github.com/restream/reindexer/bindings/builtinserver"
+	// "github.com/restream/reindexer/bindings/builtinserver/config"
 
 )
 

reflect.go

@@ -8,7 +8,7 @@ import (
 	"strings"
 	"unsafe"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
+	"github.com/restream/reindexer/bindings"
 )
 
 const (

reindexer.go

@@ -3,10 +3,10 @@ package reindexer
 import (
 	"context"
 
-	"git.itv.restr.im/itv-backend/reindexer/bindings"
-	_ "git.itv.restr.im/itv-backend/reindexer/bindings/cproto"
-	"git.itv.restr.im/itv-backend/reindexer/dsl"
-	// _ "git.itv.restr.im/itv-backend/reindexer/bindings/builtinserver"
+	"github.com/restream/reindexer/bindings"
+	_ "github.com/restream/reindexer/bindings/cproto"
+	"github.com/restream/reindexer/dsl"
+	// _ "github.com/restream/reindexer/bindings/builtinserver"
 )
 
 // Condition types