riotpiao-poimen/kmsvc-manage
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: update module path from rock/ to riotpiao-poimen/ org
ci / test (push) Failing after 34s
Details
build / Build and push image (push) Failing after 26s
Details

Browse Source
This commit is contained in:
rock
2026-09-07 22:44:50 -07:00
parent 53bcbcb33c
commit b09d0ee42b
26 changed files with 56 additions and 56 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/queue-operator/main.go
+4 -4
View File
@@ -20,10 +20,10 @@ import (
"sigs.k8s.io/controller-runtime/pkg/log/zap" "sigs.k8s.io/controller-runtime/pkg/log/zap"
"sigs.k8s.io/controller-runtime/pkg/reconcile" "sigs.k8s.io/controller-runtime/pkg/reconcile"
kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" kmsvcv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/apis/kmsvc/v1"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/operator" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/operator"
kmsvctemporal "forgejo.riotpiao.com/rock/kmsvc-manage/internal/temporal" kmsvctemporal "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/temporal"
) )
func main() { func main() {
cmd/server/main.go
+7 -7
View File
@@ -16,17 +16,17 @@ import (
"syscall" "syscall"
"time" "time"
kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1"
"github.com/grpc-ecosystem/grpc-gateway/v2/runtime" "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"google.golang.org/grpc" "google.golang.org/grpc"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/api/handlers" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/api/handlers"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/config" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/config"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/core/queue"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/reaper" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/core/reaper"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// queueDiscoveryInterval is how often the server rescans Redis for newly // queueDiscoveryInterval is how often the server rescans Redis for newly
go.mod
+2 -2
View File
@@ -1,9 +1,9 @@
module forgejo.riotpiao.com/rock/kmsvc-manage module forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage
go 1.26.0 go 1.26.0
require ( require (
forgejo.riotpiao.com/rock/kmsvc-proto v1.4.0 forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto v1.4.0
github.com/alicebob/miniredis/v2 v2.38.0 github.com/alicebob/miniredis/v2 v2.38.0
github.com/google/uuid v1.6.0 github.com/google/uuid v1.6.0
github.com/grpc-ecosystem/grpc-gateway/v2 v2.29.0 github.com/grpc-ecosystem/grpc-gateway/v2 v2.29.0
go.sum
+2 -2
View File
@@ -1,5 +1,5 @@
forgejo.riotpiao.com/rock/kmsvc-proto v1.4.0 h1:4id+KXQhHndnlX6TC0XCYzq0MWhQWWJi09zQq4KPdR8= forgejo.riotpiao.com/riotpiao-poimen/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/go.mod h1:Tvldxxalok/gCZPaUhPNLxJleRmaF0UIlLCa/MSrHg0=
github.com/Masterminds/semver/v3 v3.4.0 h1:Zog+i5UMtVoCU8oKka5P7i9q9HgrJeGzI9SA1Xbatp0= github.com/Masterminds/semver/v3 v3.4.0 h1:Zog+i5UMtVoCU8oKka5P7i9q9HgrJeGzI9SA1Xbatp0=
github.com/Masterminds/semver/v3 v3.4.0/go.mod h1:4V+yj/TJE1HU9XfppCwVMZq3I84lprf4nC11bSS5beM= github.com/Masterminds/semver/v3 v3.4.0/go.mod h1:4V+yj/TJE1HU9XfppCwVMZq3I84lprf4nC11bSS5beM=
github.com/alicebob/miniredis/v2 v2.38.0 h1:nZAzCR+Lj+Vxk4ZXzm2NuKq2O33RXj1XxJ2e2uP9jiw= github.com/alicebob/miniredis/v2 v2.38.0 h1:nZAzCR+Lj+Vxk4ZXzm2NuKq2O33RXj1XxJ2e2uP9jiw=
internal/api/handlers/consumer_registry.go
+2 -2
View File
@@ -5,8 +5,8 @@ import (
"fmt" "fmt"
"sync" "sync"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/core/queue"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
) )
// ConsumerRegistry lazily creates and caches one Kafka consumer per queue, // ConsumerRegistry lazily creates and caches one Kafka consumer per queue,
internal/api/handlers/queue_service.go
+2 -2
View File
@@ -11,13 +11,13 @@ import (
"strings" "strings"
"time" "time"
kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1"
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"google.golang.org/grpc/codes" "google.golang.org/grpc/codes"
"google.golang.org/grpc/status" "google.golang.org/grpc/status"
"google.golang.org/protobuf/types/known/timestamppb" "google.golang.org/protobuf/types/known/timestamppb"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/core/queue"
) )
// QueueService implements kafkamgmtv1.QueueServiceServer. // QueueService implements kafkamgmtv1.QueueServiceServer.
internal/api/handlers/queue_service_test.go
+4 -4
View File
@@ -5,14 +5,14 @@ import (
"testing" "testing"
"time" "time"
kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" kafkamgmtv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-proto/gen/kafkamgmt/v1"
"github.com/alicebob/miniredis/v2" "github.com/alicebob/miniredis/v2"
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"github.com/twmb/franz-go/pkg/kfake" "github.com/twmb/franz-go/pkg/kfake"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/core/queue"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// newTestKafka starts an in-memory, wire-protocol-compatible fake Kafka // newTestKafka starts an in-memory, wire-protocol-compatible fake Kafka
internal/core/queue/change_visibility.go
+1 -1
View File
@@ -7,7 +7,7 @@ import (
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
type ChangeVisibilityService struct { type ChangeVisibilityService struct {
internal/core/queue/delete_message.go
+2 -2
View File
@@ -6,8 +6,8 @@ import (
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// OffsetCommitter is the subset of kafka.Admin DeleteMessage needs to // OffsetCommitter is the subset of kafka.Admin DeleteMessage needs to
internal/core/queue/fifo.go
+1 -1
View File
@@ -7,7 +7,7 @@ import (
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// acquireFIFOSlot claims the per-group exclusivity gate (design.md §3) so // acquireFIFOSlot claims the per-group exclusivity gate (design.md §3) so
internal/core/queue/queue_test.go
+2 -2
View File
@@ -9,8 +9,8 @@ import (
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"github.com/twmb/franz-go/pkg/kfake" "github.com/twmb/franz-go/pkg/kfake"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// newTestKafka starts an in-memory, wire-protocol-compatible fake Kafka // newTestKafka starts an in-memory, wire-protocol-compatible fake Kafka
internal/core/queue/receive_message.go
+2 -2
View File
@@ -9,8 +9,8 @@ import (
"github.com/google/uuid" "github.com/google/uuid"
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
const defaultPollInterval = 200 * time.Millisecond // design.md §2b const defaultPollInterval = 200 * time.Millisecond // design.md §2b
internal/core/queue/send_message.go
+2 -2
View File
@@ -8,8 +8,8 @@ import (
"github.com/google/uuid" "github.com/google/uuid"
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// MaxMessageBodyBytes is the SQS-compatible size cap enforced at // MaxMessageBodyBytes is the SQS-compatible size cap enforced at
internal/core/queue/shard_router.go
+2 -2
View File
@@ -9,8 +9,8 @@ import (
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// ShardRouter resolves a routing key to a shard by reading the cached shard // ShardRouter resolves a routing key to a shard by reading the cached shard
internal/core/reaper/reaper.go
+2 -2
View File
@@ -10,8 +10,8 @@ import (
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/core/queue"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
const ( const (
internal/core/reaper/reaper_test.go
+3 -3
View File
@@ -10,9 +10,9 @@ import (
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"github.com/twmb/franz-go/pkg/kfake" "github.com/twmb/franz-go/pkg/kfake"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/core/queue"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
// newTestKafka mirrors internal/core/queue's test setup: an in-memory, // newTestKafka mirrors internal/core/queue's test setup: an in-memory,
internal/operator/admin.go
+1 -1
View File
@@ -3,7 +3,7 @@ package operator
import ( import (
"context" "context"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
) )
// TopicAdmin is the subset of internal/kafka.Admin the reconciler needs, // TopicAdmin is the subset of internal/kafka.Admin the reconciler needs,
internal/operator/fake_admin.go
+1 -1
View File
@@ -4,7 +4,7 @@ import (
"context" "context"
"sync" "sync"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
) )
// fakeAdmin is an in-memory TopicAdmin for reconciler tests — avoids needing // fakeAdmin is an in-memory TopicAdmin for reconciler tests — avoids needing
internal/operator/queue_controller.go
+3 -3
View File
@@ -18,9 +18,9 @@ import (
"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil" "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
ctrllog "sigs.k8s.io/controller-runtime/pkg/log" ctrllog "sigs.k8s.io/controller-runtime/pkg/log"
kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" kmsvcv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/apis/kmsvc/v1"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
const finalizerName = "kmsvc.io/queue-operator" const finalizerName = "kmsvc.io/queue-operator"
internal/operator/queue_controller_test.go
+3 -3
View File
@@ -15,9 +15,9 @@ import (
"sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/client/fake" "sigs.k8s.io/controller-runtime/pkg/client/fake"
kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" kmsvcv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/apis/kmsvc/v1"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" kmsvcredis "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/redis"
) )
func newTestScheme(t *testing.T) *runtime.Scheme { func newTestScheme(t *testing.T) *runtime.Scheme {
internal/operator/shard_drain.go
+2 -2
View File
@@ -5,8 +5,8 @@ import (
"fmt" "fmt"
"time" "time"
kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" kmsvcv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/apis/kmsvc/v1"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
) )
func secondsToDuration(s int32) time.Duration { func secondsToDuration(s int32) time.Duration {
internal/operator/shard_split.go
+2 -2
View File
@@ -7,8 +7,8 @@ import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" kmsvcv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/apis/kmsvc/v1"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
) )
// reconcileSplits samples each Active shard's throughput and splits any shard // reconcileSplits samples each Active shard's throughput and splits any shard
internal/operator/temporal_worker_controller.go
+1 -1
View File
@@ -12,7 +12,7 @@ import (
"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil" "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
ctrllog "sigs.k8s.io/controller-runtime/pkg/log" ctrllog "sigs.k8s.io/controller-runtime/pkg/log"
kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" kmsvcv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/apis/kmsvc/v1"
) )
const temporalWorkerFinalizerName = "kmsvc.io/temporal-worker" const temporalWorkerFinalizerName = "kmsvc.io/temporal-worker"
internal/operator/temporal_worker_controller_test.go
+1 -1
View File
@@ -12,7 +12,7 @@ import (
"sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/client/fake" "sigs.k8s.io/controller-runtime/pkg/client/fake"
kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" kmsvcv1 "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/apis/kmsvc/v1"
) )
func newTemporalWorkerTestScheme(t *testing.T) *runtime.Scheme { func newTemporalWorkerTestScheme(t *testing.T) *runtime.Scheme {
internal/redis/redis_test.go
+1 -1
View File
@@ -10,7 +10,7 @@ import (
"github.com/alicebob/miniredis/v2" "github.com/alicebob/miniredis/v2"
goredis "github.com/redis/go-redis/v9" goredis "github.com/redis/go-redis/v9"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
) )
func newTestClient(t *testing.T) *goredis.Client { func newTestClient(t *testing.T) *goredis.Client {
internal/redis/shardmap.go
+1 -1
View File
@@ -7,7 +7,7 @@ import (
"github.com/redis/go-redis/v9" "github.com/redis/go-redis/v9"
"forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" "forgejo.riotpiao.com/riotpiao-poimen/kmsvc-manage/internal/kafka"
) )
// PutShardMap writes the active shard set for a queue (design.md §4's // PutShardMap writes the active shard set for a queue (design.md §4's