Merge branch 'v1.0'

api/proto/buf.gen.yaml

@@ -2,7 +2,7 @@ version: v1
 managed:
   enabled: true
   go_package_prefix:
-    default: github.com/proxima-one/streamdb-client-go/api/proto/gen/proto/go
+    default: github.com/proxima-one/streamdb-client-go/v2/api/proto/gen/proto/go
     except:
       - buf.build/googleapis/googleapis
 plugins:

cmd/dev/main.go

@@ -4,8 +4,8 @@ import (
 	"context"
 	"fmt"
 	"github.com/davecgh/go-spew/spew"
-	"github.com/proxima-one/streamdb-client-go/pkg/connection"
-	"github.com/proxima-one/streamdb-client-go/pkg/proximaclient"
+	"github.com/proxima-one/streamdb-client-go/v2/pkg/connection"
+	"github.com/proxima-one/streamdb-client-go/v2/pkg/proximaclient"
 	"time"
 )
 

go.mod

@@ -1,4 +1,4 @@
-module github.com/proxima-one/streamdb-client-go
+module github.com/proxima-one/streamdb-client-go/v2
 
 go 1.18
 

pkg/proximaclient/client_stream_db_consumer_client.go

@@ -4,8 +4,8 @@ import (
 	"context"
 	"crypto/tls"
 	"fmt"
-	streamConsumer "github.com/proxima-one/streamdb-client-go/api/proto/gen/proto/go/stream_consumer/v1alpha1"
-	"github.com/proxima-one/streamdb-client-go/internal"
+	streamConsumer "github.com/proxima-one/streamdb-client-go/v2/api/proto/gen/proto/go/stream_consumer/v1alpha1"
+	"github.com/proxima-one/streamdb-client-go/v2/internal"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials"
 	"google.golang.org/grpc/credentials/insecure"

pkg/proximaclient/client_stream_registy_client.go

@@ -4,7 +4,7 @@ import (
 	"encoding/json"
 	"fmt"
 	http "github.com/hashicorp/go-retryablehttp"
-	"github.com/proxima-one/streamdb-client-go/pkg/connection"
+	"github.com/proxima-one/streamdb-client-go/v2/pkg/connection"
 	"io"
 	"math"
 	"math/rand"

pkg/proximaclient/model_converters.go

@@ -1,8 +1,8 @@
 package proximaclient
 
 import (
-	pbModel "github.com/proxima-one/streamdb-client-go/api/proto/gen/proto/go/model/v1"
-	pbConsumerModel "github.com/proxima-one/streamdb-client-go/api/proto/gen/proto/go/stream_consumer/v1alpha1"
+	pbModel "github.com/proxima-one/streamdb-client-go/v2/api/proto/gen/proto/go/model/v1"
+	pbConsumerModel "github.com/proxima-one/streamdb-client-go/v2/api/proto/gen/proto/go/stream_consumer/v1alpha1"
 )
 
 func protoStateTransitionToStreamEvent(transition *pbModel.StateTransition) StreamEvent {

pkg/proximaclient/model_offset.go

@@ -2,7 +2,7 @@ package proximaclient
 
 import (
 	"fmt"
-	"github.com/proxima-one/streamdb-client-go/internal"
+	"github.com/proxima-one/streamdb-client-go/v2/internal"
 	"strings"
 )
 

pkg/proximaclient/model_timestamp.go

@@ -3,7 +3,7 @@ package proximaclient
 import (
 	"encoding/base64"
 	"fmt"
-	"github.com/proxima-one/streamdb-client-go/internal"
+	"github.com/proxima-one/streamdb-client-go/v2/internal"
 	"strconv"
 	"strings"
 	"time"