diff --git a/.forgejo/workflows/ci.yaml b/.gitea/workflows/ci.yaml similarity index 85% rename from .forgejo/workflows/ci.yaml rename to .gitea/workflows/ci.yaml index 080700e..2efb4b7 100644 --- a/.forgejo/workflows/ci.yaml +++ b/.gitea/workflows/ci.yaml @@ -3,6 +3,7 @@ name: ci on: push: branches: [main] + tags: ["v*"] pull_request: concurrency: @@ -15,8 +16,9 @@ jobs: container: image: golang:1.25 env: - GOPRIVATE: forgejo.riotpiao.homelab.com + GOPRIVATE: forgejo.riotpiao.com GOFLAGS: -mod=readonly + GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} steps: - name: install node (required by JS-based actions) run: apt-get update && apt-get install -y --no-install-recommends nodejs ca-certificates git @@ -25,9 +27,7 @@ jobs: - name: configure git auth for private module fetch run: | - git config --global url."https://oauth2:${FORGEJO_PAT}@forgejo.riotpiao.homelab.com".insteadOf "https://forgejo.riotpiao.homelab.com" - env: - FORGEJO_PAT: ${{ secrets.FORGEJO_PAT }} + git config --global url."https://oauth2:${GITHUB_TOKEN}@forgejo.riotpiao.com".insteadOf "https://forgejo.riotpiao.com" - name: cache go modules + build cache uses: actions/cache@v4 diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml deleted file mode 100644 index d2b118c..0000000 --- a/.github/workflows/ci.yaml +++ /dev/null @@ -1,48 +0,0 @@ -name: build-push - -on: - push: - branches: [main] - tags: ["v*"] - -env: - REGISTRY: ghcr.io - IMAGE_NAME: ${{ github.repository_owner }}/kmsvc-management-service - -jobs: - build-push: - runs-on: ubuntu-latest - permissions: - contents: read - packages: write - steps: - - uses: actions/checkout@v4 - - - uses: docker/setup-qemu-action@v3 - - - uses: docker/setup-buildx-action@v3 - - - uses: docker/login-action@v3 - with: - registry: ${{ env.REGISTRY }} - username: ${{ github.actor }} - password: ${{ secrets.GITHUB_TOKEN }} - - - id: meta - uses: docker/metadata-action@v5 - with: - images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }} - tags: | - type=raw,value=latest,enable={{is_default_branch}} - type=semver,pattern={{version}} - type=sha - - - uses: docker/build-push-action@v6 - with: - context: . - platforms: linux/amd64,linux/arm64 - push: true - tags: ${{ steps.meta.outputs.tags }} - labels: ${{ steps.meta.outputs.labels }} - cache-from: type=gha - cache-to: type=gha,mode=max diff --git a/cmd/queue-operator/main.go b/cmd/queue-operator/main.go index 262af31..0795fe5 100644 --- a/cmd/queue-operator/main.go +++ b/cmd/queue-operator/main.go @@ -20,10 +20,10 @@ import ( "sigs.k8s.io/controller-runtime/pkg/log/zap" "sigs.k8s.io/controller-runtime/pkg/reconcile" - kmsvcv1 "github.com/rockliang/kafka-management-service/apis/kmsvc/v1" - "github.com/rockliang/kafka-management-service/internal/kafka" - "github.com/rockliang/kafka-management-service/internal/operator" - kmsvctemporal "github.com/rockliang/kafka-management-service/internal/temporal" + kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/operator" + kmsvctemporal "forgejo.riotpiao.com/rock/kmsvc-manage/internal/temporal" ) func main() { diff --git a/cmd/server/main.go b/cmd/server/main.go index 13f02c1..f604c92 100644 --- a/cmd/server/main.go +++ b/cmd/server/main.go @@ -16,17 +16,17 @@ import ( "syscall" "time" - kafkamgmtv1 "github.com/Riotpiaole/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" "github.com/grpc-ecosystem/grpc-gateway/v2/runtime" goredis "github.com/redis/go-redis/v9" "google.golang.org/grpc" - "github.com/rockliang/kafka-management-service/internal/api/handlers" - "github.com/rockliang/kafka-management-service/internal/config" - "github.com/rockliang/kafka-management-service/internal/core/queue" - "github.com/rockliang/kafka-management-service/internal/core/reaper" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/api/handlers" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/config" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/reaper" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // queueDiscoveryInterval is how often the server rescans Redis for newly diff --git a/go.mod b/go.mod index 29040c7..60eec29 100644 --- a/go.mod +++ b/go.mod @@ -1,9 +1,9 @@ -module github.com/rockliang/kafka-management-service +module forgejo.riotpiao.com/rock/kmsvc-manage go 1.26.0 require ( - github.com/Riotpiaole/kmsvc-proto v1.3.0 + forgejo.riotpiao.com/rock/kmsvc-proto v1.4.0 github.com/alicebob/miniredis/v2 v2.38.0 github.com/google/uuid v1.6.0 github.com/grpc-ecosystem/grpc-gateway/v2 v2.29.0 diff --git a/go.sum b/go.sum index e116f0c..5d45ff2 100644 --- a/go.sum +++ b/go.sum @@ -1,7 +1,7 @@ +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= 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/Riotpiaole/kmsvc-proto v1.3.0 h1:W+Nlbk5Rj9FmEctk9fPgDhR82xhkx9yRAw3EAnJ+UxY= -github.com/Riotpiaole/kmsvc-proto v1.3.0/go.mod h1:20/7jwP4wRxbNGq+qeFeZfTQs7Vtxaoqok6t+3Sc0U8= github.com/alicebob/miniredis/v2 v2.38.0 h1:nZAzCR+Lj+Vxk4ZXzm2NuKq2O33RXj1XxJ2e2uP9jiw= github.com/alicebob/miniredis/v2 v2.38.0/go.mod h1:TcL7YfarKPGDAthEtl5NBeHZfeUQj6OXMm/+iu5cLMM= github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM= diff --git a/internal/api/handlers/consumer_registry.go b/internal/api/handlers/consumer_registry.go index 5a0d341..418266e 100644 --- a/internal/api/handlers/consumer_registry.go +++ b/internal/api/handlers/consumer_registry.go @@ -5,8 +5,8 @@ import ( "fmt" "sync" - "github.com/rockliang/kafka-management-service/internal/core/queue" - "github.com/rockliang/kafka-management-service/internal/kafka" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" ) // ConsumerRegistry lazily creates and caches one Kafka consumer per queue, diff --git a/internal/api/handlers/queue_service.go b/internal/api/handlers/queue_service.go index c4ab0ed..c408223 100644 --- a/internal/api/handlers/queue_service.go +++ b/internal/api/handlers/queue_service.go @@ -11,13 +11,13 @@ import ( "strings" "time" - kafkamgmtv1 "github.com/Riotpiaole/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" goredis "github.com/redis/go-redis/v9" "google.golang.org/grpc/codes" "google.golang.org/grpc/status" "google.golang.org/protobuf/types/known/timestamppb" - "github.com/rockliang/kafka-management-service/internal/core/queue" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" ) // QueueService implements kafkamgmtv1.QueueServiceServer. diff --git a/internal/api/handlers/queue_service_test.go b/internal/api/handlers/queue_service_test.go index 2963021..7ad95c9 100644 --- a/internal/api/handlers/queue_service_test.go +++ b/internal/api/handlers/queue_service_test.go @@ -5,14 +5,14 @@ import ( "testing" "time" - kafkamgmtv1 "github.com/Riotpiaole/kmsvc-proto/gen/kafkamgmt/v1" + kafkamgmtv1 "forgejo.riotpiao.com/rock/kmsvc-proto/gen/kafkamgmt/v1" "github.com/alicebob/miniredis/v2" goredis "github.com/redis/go-redis/v9" "github.com/twmb/franz-go/pkg/kfake" - "github.com/rockliang/kafka-management-service/internal/core/queue" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // newTestKafka starts an in-memory, wire-protocol-compatible fake Kafka diff --git a/internal/core/queue/change_visibility.go b/internal/core/queue/change_visibility.go index 8ec318f..20e94d4 100644 --- a/internal/core/queue/change_visibility.go +++ b/internal/core/queue/change_visibility.go @@ -7,7 +7,7 @@ import ( goredis "github.com/redis/go-redis/v9" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) type ChangeVisibilityService struct { diff --git a/internal/core/queue/delete_message.go b/internal/core/queue/delete_message.go index f8efe39..cc33579 100644 --- a/internal/core/queue/delete_message.go +++ b/internal/core/queue/delete_message.go @@ -6,8 +6,8 @@ import ( goredis "github.com/redis/go-redis/v9" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // OffsetCommitter is the subset of kafka.Admin DeleteMessage needs to diff --git a/internal/core/queue/fifo.go b/internal/core/queue/fifo.go index 2d06a2d..e583a44 100644 --- a/internal/core/queue/fifo.go +++ b/internal/core/queue/fifo.go @@ -7,7 +7,7 @@ import ( goredis "github.com/redis/go-redis/v9" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // acquireFIFOSlot claims the per-group exclusivity gate (design.md §3) so diff --git a/internal/core/queue/queue_test.go b/internal/core/queue/queue_test.go index 1aa72c8..33d2446 100644 --- a/internal/core/queue/queue_test.go +++ b/internal/core/queue/queue_test.go @@ -9,8 +9,8 @@ import ( goredis "github.com/redis/go-redis/v9" "github.com/twmb/franz-go/pkg/kfake" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // newTestKafka starts an in-memory, wire-protocol-compatible fake Kafka diff --git a/internal/core/queue/receive_message.go b/internal/core/queue/receive_message.go index 2189690..4200317 100644 --- a/internal/core/queue/receive_message.go +++ b/internal/core/queue/receive_message.go @@ -9,8 +9,8 @@ import ( "github.com/google/uuid" goredis "github.com/redis/go-redis/v9" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) const defaultPollInterval = 200 * time.Millisecond // design.md §2b diff --git a/internal/core/queue/send_message.go b/internal/core/queue/send_message.go index 4398b52..74ec22d 100644 --- a/internal/core/queue/send_message.go +++ b/internal/core/queue/send_message.go @@ -8,8 +8,8 @@ import ( "github.com/google/uuid" goredis "github.com/redis/go-redis/v9" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // MaxMessageBodyBytes is the SQS-compatible size cap enforced at diff --git a/internal/core/queue/shard_router.go b/internal/core/queue/shard_router.go index 64c913f..1902c60 100644 --- a/internal/core/queue/shard_router.go +++ b/internal/core/queue/shard_router.go @@ -9,8 +9,8 @@ import ( goredis "github.com/redis/go-redis/v9" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // ShardRouter resolves a routing key to a shard by reading the cached shard diff --git a/internal/core/reaper/reaper.go b/internal/core/reaper/reaper.go index 3464cd8..2edbf13 100644 --- a/internal/core/reaper/reaper.go +++ b/internal/core/reaper/reaper.go @@ -10,8 +10,8 @@ import ( goredis "github.com/redis/go-redis/v9" - "github.com/rockliang/kafka-management-service/internal/core/queue" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) const ( diff --git a/internal/core/reaper/reaper_test.go b/internal/core/reaper/reaper_test.go index 066ae3b..3322e84 100644 --- a/internal/core/reaper/reaper_test.go +++ b/internal/core/reaper/reaper_test.go @@ -10,9 +10,9 @@ import ( goredis "github.com/redis/go-redis/v9" "github.com/twmb/franz-go/pkg/kfake" - "github.com/rockliang/kafka-management-service/internal/core/queue" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/core/queue" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) // newTestKafka mirrors internal/core/queue's test setup: an in-memory, diff --git a/internal/operator/admin.go b/internal/operator/admin.go index a31182d..e0e3fd1 100644 --- a/internal/operator/admin.go +++ b/internal/operator/admin.go @@ -3,7 +3,7 @@ package operator import ( "context" - "github.com/rockliang/kafka-management-service/internal/kafka" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" ) // TopicAdmin is the subset of internal/kafka.Admin the reconciler needs, diff --git a/internal/operator/fake_admin.go b/internal/operator/fake_admin.go index 9df6189..57834ab 100644 --- a/internal/operator/fake_admin.go +++ b/internal/operator/fake_admin.go @@ -4,7 +4,7 @@ import ( "context" "sync" - "github.com/rockliang/kafka-management-service/internal/kafka" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" ) // fakeAdmin is an in-memory TopicAdmin for reconciler tests — avoids needing diff --git a/internal/operator/queue_controller.go b/internal/operator/queue_controller.go index 2ca9729..3a0935e 100644 --- a/internal/operator/queue_controller.go +++ b/internal/operator/queue_controller.go @@ -18,9 +18,9 @@ import ( "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil" ctrllog "sigs.k8s.io/controller-runtime/pkg/log" - kmsvcv1 "github.com/rockliang/kafka-management-service/apis/kmsvc/v1" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) const finalizerName = "kmsvc.io/queue-operator" diff --git a/internal/operator/queue_controller_test.go b/internal/operator/queue_controller_test.go index a63d75b..5a1a648 100644 --- a/internal/operator/queue_controller_test.go +++ b/internal/operator/queue_controller_test.go @@ -15,9 +15,9 @@ import ( "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client/fake" - kmsvcv1 "github.com/rockliang/kafka-management-service/apis/kmsvc/v1" - "github.com/rockliang/kafka-management-service/internal/kafka" - kmsvcredis "github.com/rockliang/kafka-management-service/internal/redis" + kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" + kmsvcredis "forgejo.riotpiao.com/rock/kmsvc-manage/internal/redis" ) func newTestScheme(t *testing.T) *runtime.Scheme { diff --git a/internal/operator/shard_drain.go b/internal/operator/shard_drain.go index 4d3b7fa..62731fd 100644 --- a/internal/operator/shard_drain.go +++ b/internal/operator/shard_drain.go @@ -5,8 +5,8 @@ import ( "fmt" "time" - kmsvcv1 "github.com/rockliang/kafka-management-service/apis/kmsvc/v1" - "github.com/rockliang/kafka-management-service/internal/kafka" + kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" ) func secondsToDuration(s int32) time.Duration { diff --git a/internal/operator/shard_split.go b/internal/operator/shard_split.go index a2879f2..a7fe623 100644 --- a/internal/operator/shard_split.go +++ b/internal/operator/shard_split.go @@ -7,8 +7,8 @@ import ( metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - kmsvcv1 "github.com/rockliang/kafka-management-service/apis/kmsvc/v1" - "github.com/rockliang/kafka-management-service/internal/kafka" + kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" ) // reconcileSplits samples each Active shard's throughput and splits any shard diff --git a/internal/operator/temporal_worker_controller.go b/internal/operator/temporal_worker_controller.go index 2be95d0..2cb1cfa 100644 --- a/internal/operator/temporal_worker_controller.go +++ b/internal/operator/temporal_worker_controller.go @@ -12,7 +12,7 @@ import ( "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil" ctrllog "sigs.k8s.io/controller-runtime/pkg/log" - kmsvcv1 "github.com/rockliang/kafka-management-service/apis/kmsvc/v1" + kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" ) const temporalWorkerFinalizerName = "kmsvc.io/temporal-worker" diff --git a/internal/operator/temporal_worker_controller_test.go b/internal/operator/temporal_worker_controller_test.go index 1b8bc10..4015a61 100644 --- a/internal/operator/temporal_worker_controller_test.go +++ b/internal/operator/temporal_worker_controller_test.go @@ -12,7 +12,7 @@ import ( "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client/fake" - kmsvcv1 "github.com/rockliang/kafka-management-service/apis/kmsvc/v1" + kmsvcv1 "forgejo.riotpiao.com/rock/kmsvc-manage/apis/kmsvc/v1" ) func newTemporalWorkerTestScheme(t *testing.T) *runtime.Scheme { diff --git a/internal/redis/redis_test.go b/internal/redis/redis_test.go index b0ef9ff..ec10828 100644 --- a/internal/redis/redis_test.go +++ b/internal/redis/redis_test.go @@ -10,7 +10,7 @@ import ( "github.com/alicebob/miniredis/v2" goredis "github.com/redis/go-redis/v9" - "github.com/rockliang/kafka-management-service/internal/kafka" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" ) func newTestClient(t *testing.T) *goredis.Client { diff --git a/internal/redis/shardmap.go b/internal/redis/shardmap.go index 5903e51..08ce409 100644 --- a/internal/redis/shardmap.go +++ b/internal/redis/shardmap.go @@ -7,7 +7,7 @@ import ( "github.com/redis/go-redis/v9" - "github.com/rockliang/kafka-management-service/internal/kafka" + "forgejo.riotpiao.com/rock/kmsvc-manage/internal/kafka" ) // PutShardMap writes the active shard set for a queue (design.md §4's diff --git a/k8s/argocd/project.yaml b/k8s/argocd/project.yaml index 062b2d6..f2a2a27 100644 --- a/k8s/argocd/project.yaml +++ b/k8s/argocd/project.yaml @@ -2,11 +2,11 @@ apiVersion: argoproj.io/v1alpha1 kind: AppProject metadata: name: kmsvc - namespace: cicd + namespace: argocd spec: description: Kafka Management Service (design.md) -- Strimzi/Kafka, Redis, queue-operator, message-plane server sourceRepos: - - https://forgejo.riotpiao.homelab.com/rock/kafaka-management-service.git + - https://forgejo.riotpiao.com/rock/kmsvc-manage.git - https://strimzi.io/charts/ - https://charts.bitnami.com/bitnami destinations: diff --git a/k8s/argocd/root.yaml b/k8s/argocd/root.yaml index 240b1b0..923314a 100644 --- a/k8s/argocd/root.yaml +++ b/k8s/argocd/root.yaml @@ -2,11 +2,11 @@ apiVersion: argoproj.io/v1alpha1 kind: Application metadata: name: kmsvc-root - namespace: cicd + namespace: argocd spec: project: kmsvc source: - repoURL: https://forgejo.riotpiao.homelab.com/rock/kafaka-management-service.git + repoURL: https://forgejo.riotpiao.com/rock/kmsvc-manage.git targetRevision: main path: k8s/argocd/apps directory: