diff --git a/auth_test.go b/auth_test.go index 5d3763c..544ef9a 100644 --- a/auth_test.go +++ b/auth_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1" ) func TestClientAttachesBearerToken(t *testing.T) { diff --git a/client.go b/client.go index b86819b..23aa5b8 100644 --- a/client.go +++ b/client.go @@ -5,7 +5,7 @@ import ( "fmt" "time" - kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1" "google.golang.org/grpc" "google.golang.org/grpc/credentials" "google.golang.org/grpc/credentials/insecure" diff --git a/examples/sendreceive/main.go b/examples/sendreceive/main.go index 80daf59..7bac9e8 100644 --- a/examples/sendreceive/main.go +++ b/examples/sendreceive/main.go @@ -8,7 +8,7 @@ import ( "log" "time" - kmsvc "forgejo.riotpiao.com/rock/kmsvc-sdk" + kmsvc "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-sdk" ) func main() { diff --git a/go.mod b/go.mod index 167dcca..00a0f6f 100644 --- a/go.mod +++ b/go.mod @@ -1,9 +1,9 @@ -module forgejo.riotpiao.com/rock/kmsvc-sdk +module forgejo.riotpiao.com/riotpiao-poimen/kmsvc-sdk go 1.26.0 require ( - forgejo.riotpiao.com/rock/kmsvc-proto v1.4.0 + forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto v1.4.0 google.golang.org/grpc v1.81.1 ) diff --git a/go.sum b/go.sum index 3bb31e4..e28e7d3 100644 --- a/go.sum +++ b/go.sum @@ -1,5 +1,5 @@ -forgejo.riotpiao.com/rock/kmsvc-proto v1.4.0 h1:4id+KXQhHndnlX6TC0XCYzq0MWhQWWJi09zQq4KPdR8= -forgejo.riotpiao.com/rock/kmsvc-proto v1.4.0/go.mod h1:Tvldxxalok/gCZPaUhPNLxJleRmaF0UIlLCa/MSrHg0= +forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto v1.4.0 h1:4id+KXQhHndnlX6TC0XCYzq0MWhQWWJi09zQq4KPdR8= +forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto v1.4.0/go.mod h1:Tvldxxalok/gCZPaUhPNLxJleRmaF0UIlLCa/MSrHg0= github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs= github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI= diff --git a/internal_test_fake_test.go b/internal_test_fake_test.go index 49026a5..2cae605 100644 --- a/internal_test_fake_test.go +++ b/internal_test_fake_test.go @@ -5,7 +5,7 @@ import ( "net" "testing" - kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" "google.golang.org/grpc/metadata" diff --git a/longpoll.go b/longpoll.go index 29e3f28..6456fad 100644 --- a/longpoll.go +++ b/longpoll.go @@ -4,7 +4,7 @@ import ( "context" "time" - kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1" ) // MaxReceiveMessages mirrors the server-side cap (design.md §2b). diff --git a/longpoll_test.go b/longpoll_test.go index 8f722c7..202ebb6 100644 --- a/longpoll_test.go +++ b/longpoll_test.go @@ -5,7 +5,7 @@ import ( "testing" "time" - kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1" ) func TestReceiveMessageMapsResponse(t *testing.T) { diff --git a/messages.go b/messages.go index 5463fd2..f191ab7 100644 --- a/messages.go +++ b/messages.go @@ -4,7 +4,7 @@ import ( "context" "fmt" - kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1" ) // MaxMessageBodyBytes matches SQS's message size cap (design.md §11.2). diff --git a/messages_test.go b/messages_test.go index e4ee500..e4fc6dc 100644 --- a/messages_test.go +++ b/messages_test.go @@ -6,7 +6,7 @@ import ( "errors" "testing" - kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1" "google.golang.org/grpc/codes" "google.golang.org/grpc/status" )