[CLN] Move go/coordinator to go/ since there's more stuff there (#…

…1769) ## Description of changes *Summarize the changes made by this PR.* - Improvements & Bug fixes - Move `go/coordinator` to `go/` since more than just the Coordinator lives there now. ## Test plan *How are these changes tested?* - [ ] Tests pass locally with `pytest` for python, `yarn test` for js ## Documentation Changes *Are all docstrings for user-facing APIs updated if required? Do we need to make documentation changes in the [docs repository](https://github.com/chroma-core/docs)?*
chroma-core · Feb 26, 2024 · 1c91ec0 · 1c91ec0
1 parent 3908b7b
commit 1c91ec0
Show file tree

Hide file tree

Showing 119 changed files with 20 additions and 20 deletions.
diff --git a/.github/workflows/chroma-cluster-test.yml b/.github/workflows/chroma-cluster-test.yml
@@ -65,4 +65,4 @@ jobs:
     - name: Start Tilt
       run: tilt ci
     - name: Test
-      run: bin/cluster-test.sh bash -c 'cd go/coordinator && go test -timeout 30s -run ^TestNodeWatcher$ github.com/chroma/chroma-coordinator/internal/memberlist_manager'
+      run: bin/cluster-test.sh bash -c 'cd go && go test -timeout 30s -run ^TestNodeWatcher$ github.com/chroma/chroma-coordinator/internal/memberlist_manager'
diff --git a/.github/workflows/chroma-coordinator-test.yaml b/.github/workflows/chroma-coordinator-test.yaml
@@ -34,7 +34,7 @@ jobs:
     - name: Checkout
       uses: actions/checkout@v3
     - name: Build and test
-      run: cd go/coordinator && make test
+      run: cd go && make test
       env:
         POSTGRES_HOST: localhost
         POSTGRES_PORT: 5432
diff --git a/.gitignore b/.gitignore
@@ -3,8 +3,8 @@
 
 **/__pycache__
 
-go/coordinator/bin/
-go/coordinator/**/testdata/
+go/bin/
+go/**/testdata/
 
 *.log
 

diff --git a/Tiltfile b/Tiltfile
@@ -2,12 +2,12 @@ update_settings(max_parallel_updates=6)
 
 docker_build('migration',
              context='.',
-             dockerfile='./go/coordinator/Dockerfile.migration'
+             dockerfile='./go/Dockerfile.migration'
 )
 
 docker_build('coordinator',
              context='.',
-             dockerfile='./go/coordinator/Dockerfile'
+             dockerfile='./go/Dockerfile'
 )
 
 docker_build('server',

diff --git a/bin/reset.sh b/bin/reset.sh
@@ -2,7 +2,7 @@
 
 eval $(minikube -p chroma-test docker-env)
 
-docker build -t chroma-coordinator:latest -f go/coordinator/Dockerfile .
+docker build -t chroma-coordinator:latest -f go/Dockerfile .
 
 kubectl delete deployment coordinator -n chroma
 

diff --git a/chromadb/ingest/impl/simple_policy.py b/chromadb/ingest/impl/simple_policy.py
@@ -54,7 +54,7 @@ def assign_collection(self, collection_id: UUID) -> str:
 
     @overrides
     def get_topics(self) -> Sequence[str]:
-        # Mirrors go/coordinator/internal/coordinator/assignment_policy.go
+        # Mirrors go/internal/coordinator/assignment_policy.go
         return [
             f"persistent://{self._tenant_id}/{self._topic_ns}/chroma_log_{i}"
             for i in range(16)

diff --git a/go/coordinator/Dockerfile → go/Dockerfile b/go/coordinator/Dockerfile → go/Dockerfile
@@ -2,12 +2,12 @@ FROM golang:1.20-alpine3.18 as build
 WORKDIR /src/chroma-coordinator
 RUN apk add --no-cache make git build-base bash
 
-ADD ./go/coordinator/go.mod ./go.mod
-ADD ./go/coordinator/go.sum ./go.sum
+ADD ./go/go.mod ./go.mod
+ADD ./go/go.sum ./go.sum
 ENV PATH=$PATH:/go/bin
 RUN go mod download
 
-ADD ./go/coordinator ./
+ADD ./go/ ./
 ENV GOCACHE=/root/.cache/go-build
 RUN --mount=type=cache,target="/root/.cache/go-build" make
 

diff --git a/go/Dockerfile.migration b/go/Dockerfile.migration
@@ -0,0 +1,4 @@
+FROM arigaio/atlas:latest
+workdir /app
+COPY ./go/migrations migrations
+COPY ./go/atlas.hcl atlas.hcl
diff --git a/go/coordinator/Makefile → go/Makefile b/go/coordinator/Makefile → go/Makefile
diff --git a/go/coordinator/atlas.hcl → go/atlas.hcl b/go/coordinator/atlas.hcl → go/atlas.hcl
diff --git a/go/coordinator/cmd/coordinator/cmd.go → go/cmd/coordinator/cmd.go b/go/coordinator/cmd/coordinator/cmd.go → go/cmd/coordinator/cmd.go
diff --git a/go/coordinator/cmd/coordinator/main.go → go/cmd/coordinator/main.go b/go/coordinator/cmd/coordinator/main.go → go/cmd/coordinator/main.go
diff --git a/go/coordinator/cmd/flag/flag.go → go/cmd/flag/flag.go b/go/coordinator/cmd/flag/flag.go → go/cmd/flag/flag.go
diff --git a/go/coordinator/cmd/logservice/cmd.go → go/cmd/logservice/cmd.go b/go/coordinator/cmd/logservice/cmd.go → go/cmd/logservice/cmd.go
diff --git a/go/coordinator/cmd/logservice/main.go → go/cmd/logservice/main.go b/go/coordinator/cmd/logservice/main.go → go/cmd/logservice/main.go
diff --git a/go/coordinator/Dockerfile.migration b/go/coordinator/Dockerfile.migration
diff --git a/go/coordinator/go.mod → go/go.mod b/go/coordinator/go.mod → go/go.mod
diff --git a/go/coordinator/go.sum → go/go.sum b/go/coordinator/go.sum → go/go.sum
diff --git a/go/coordinator/internal/common/component.go → go/internal/common/component.go b/go/coordinator/internal/common/component.go → go/internal/common/component.go
diff --git a/go/coordinator/internal/common/constants.go → go/internal/common/constants.go b/go/coordinator/internal/common/constants.go → go/internal/common/constants.go
diff --git a/go/coordinator/internal/common/errors.go → go/internal/common/errors.go b/go/coordinator/internal/common/errors.go → go/internal/common/errors.go
diff --git a/go/coordinator/internal/coordinator/apis.go → go/internal/coordinator/apis.go b/go/coordinator/internal/coordinator/apis.go → go/internal/coordinator/apis.go
diff --git a/...dinator/internal/coordinator/apis_test.go → go/internal/coordinator/apis_test.go b/...dinator/internal/coordinator/apis_test.go → go/internal/coordinator/apis_test.go
diff --git a/...internal/coordinator/assignment_policy.go → go/internal/coordinator/assignment_policy.go b/...internal/coordinator/assignment_policy.go → go/internal/coordinator/assignment_policy.go
diff --git a/...nator/internal/coordinator/coordinator.go → go/internal/coordinator/coordinator.go b/...nator/internal/coordinator/coordinator.go → go/internal/coordinator/coordinator.go
diff --git a/...al/coordinator/grpc/collection_service.go → ...al/coordinator/grpc/collection_service.go b/...al/coordinator/grpc/collection_service.go → ...al/coordinator/grpc/collection_service.go
diff --git a/...ordinator/grpc/collection_service_test.go → ...ordinator/grpc/collection_service_test.go b/...ordinator/grpc/collection_service_test.go → ...ordinator/grpc/collection_service_test.go
diff --git a/...l/coordinator/grpc/proto_model_convert.go → ...l/coordinator/grpc/proto_model_convert.go b/...l/coordinator/grpc/proto_model_convert.go → ...l/coordinator/grpc/proto_model_convert.go
diff --git a/...rdinator/grpc/proto_model_convert_test.go → ...rdinator/grpc/proto_model_convert_test.go b/...rdinator/grpc/proto_model_convert_test.go → ...rdinator/grpc/proto_model_convert_test.go
diff --git a/...ernal/coordinator/grpc/segment_service.go → ...ernal/coordinator/grpc/segment_service.go b/...ernal/coordinator/grpc/segment_service.go → ...ernal/coordinator/grpc/segment_service.go
diff --git a/...nator/internal/coordinator/grpc/server.go → go/internal/coordinator/grpc/server.go b/...nator/internal/coordinator/grpc/server.go → go/internal/coordinator/grpc/server.go
diff --git a/...ordinator/grpc/tenant_database_service.go → ...ordinator/grpc/tenant_database_service.go b/...ordinator/grpc/tenant_database_service.go → ...ordinator/grpc/tenant_database_service.go
diff --git a/go/coordinator/internal/coordinator/meta.go → go/internal/coordinator/meta.go b/go/coordinator/internal/coordinator/meta.go → go/internal/coordinator/meta.go
diff --git a/...dinator/internal/coordinator/meta_test.go → go/internal/coordinator/meta_test.go b/...dinator/internal/coordinator/meta_test.go → go/internal/coordinator/meta_test.go
diff --git a/go/coordinator/internal/grpcutils/config.go → go/internal/grpcutils/config.go b/go/coordinator/internal/grpcutils/config.go → go/internal/grpcutils/config.go
diff --git a/...dinator/internal/grpcutils/config_test.go → go/internal/grpcutils/config_test.go b/...dinator/internal/grpcutils/config_test.go → go/internal/grpcutils/config_test.go
diff --git a/...oordinator/internal/grpcutils/response.go → go/internal/grpcutils/response.go b/...oordinator/internal/grpcutils/response.go → go/internal/grpcutils/response.go
diff --git a/go/coordinator/internal/grpcutils/service.go → go/internal/grpcutils/service.go b/go/coordinator/internal/grpcutils/service.go → go/internal/grpcutils/service.go
diff --git a/go/coordinator/internal/logservice/apis.go → go/internal/logservice/apis.go b/go/coordinator/internal/logservice/apis.go → go/internal/logservice/apis.go
diff --git a/...nal/logservice/grpc/record_log_service.go → ...nal/logservice/grpc/record_log_service.go b/...nal/logservice/grpc/record_log_service.go → ...nal/logservice/grpc/record_log_service.go
diff --git a/...ogservice/grpc/record_log_service_test.go → ...ogservice/grpc/record_log_service_test.go b/...ogservice/grpc/record_log_service_test.go → ...ogservice/grpc/record_log_service_test.go
diff --git a/...inator/internal/logservice/grpc/server.go → go/internal/logservice/grpc/server.go b/...inator/internal/logservice/grpc/server.go → go/internal/logservice/grpc/server.go
diff --git a/...rdinator/internal/logservice/recordlog.go → go/internal/logservice/recordlog.go b/...rdinator/internal/logservice/recordlog.go → go/internal/logservice/recordlog.go
diff --git a/.../memberlist_manager/memberlist_manager.go → .../memberlist_manager/memberlist_manager.go b/.../memberlist_manager/memberlist_manager.go → .../memberlist_manager/memberlist_manager.go
diff --git a/...erlist_manager/memberlist_manager_test.go → ...erlist_manager/memberlist_manager_test.go b/...erlist_manager/memberlist_manager_test.go → ...erlist_manager/memberlist_manager_test.go
diff --git a/...al/memberlist_manager/memberlist_store.go → ...al/memberlist_manager/memberlist_store.go b/...al/memberlist_manager/memberlist_store.go → ...al/memberlist_manager/memberlist_store.go
diff --git a/...ternal/memberlist_manager/node_watcher.go → ...ternal/memberlist_manager/node_watcher.go b/...ternal/memberlist_manager/node_watcher.go → ...ternal/memberlist_manager/node_watcher.go
diff --git a/go/coordinator/internal/metastore/catalog.go → go/internal/metastore/catalog.go b/go/coordinator/internal/metastore/catalog.go → go/internal/metastore/catalog.go
diff --git a/...l/metastore/coordinator/memory_catalog.go → ...l/metastore/coordinator/memory_catalog.go b/...l/metastore/coordinator/memory_catalog.go → ...l/metastore/coordinator/memory_catalog.go
diff --git a/...astore/coordinator/memory_catalog_test.go → ...astore/coordinator/memory_catalog_test.go b/...astore/coordinator/memory_catalog_test.go → ...astore/coordinator/memory_catalog_test.go
diff --git a/...metastore/coordinator/model_db_convert.go → ...metastore/coordinator/model_db_convert.go b/...metastore/coordinator/model_db_convert.go → ...metastore/coordinator/model_db_convert.go
diff --git a/...tore/coordinator/model_db_convert_test.go → ...tore/coordinator/model_db_convert_test.go b/...tore/coordinator/model_db_convert_test.go → ...tore/coordinator/model_db_convert_test.go
diff --git a/...al/metastore/coordinator/table_catalog.go → ...al/metastore/coordinator/table_catalog.go b/...al/metastore/coordinator/table_catalog.go → ...al/metastore/coordinator/table_catalog.go
diff --git a/...tastore/coordinator/table_catalog_test.go → ...tastore/coordinator/table_catalog_test.go b/...tastore/coordinator/table_catalog_test.go → ...tastore/coordinator/table_catalog_test.go
diff --git a/...r/internal/metastore/db/dao/collection.go → go/internal/metastore/db/dao/collection.go b/...r/internal/metastore/db/dao/collection.go → go/internal/metastore/db/dao/collection.go
diff --git a/...l/metastore/db/dao/collection_metadata.go → ...l/metastore/db/dao/collection_metadata.go b/...l/metastore/db/dao/collection_metadata.go → ...l/metastore/db/dao/collection_metadata.go
diff --git a/...ernal/metastore/db/dao/collection_test.go → ...ernal/metastore/db/dao/collection_test.go b/...ernal/metastore/db/dao/collection_test.go → ...ernal/metastore/db/dao/collection_test.go
diff --git a/...nator/internal/metastore/db/dao/common.go → go/internal/metastore/db/dao/common.go b/...nator/internal/metastore/db/dao/common.go → go/internal/metastore/db/dao/common.go
diff --git a/...tor/internal/metastore/db/dao/database.go → go/internal/metastore/db/dao/database.go b/...tor/internal/metastore/db/dao/database.go → go/internal/metastore/db/dao/database.go
diff --git a/...internal/metastore/db/dao/notification.go → go/internal/metastore/db/dao/notification.go b/...internal/metastore/db/dao/notification.go → go/internal/metastore/db/dao/notification.go
diff --git a/...r/internal/metastore/db/dao/record_log.go → go/internal/metastore/db/dao/record_log.go b/...r/internal/metastore/db/dao/record_log.go → go/internal/metastore/db/dao/record_log.go
diff --git a/...ernal/metastore/db/dao/record_log_test.go → ...ernal/metastore/db/dao/record_log_test.go b/...ernal/metastore/db/dao/record_log_test.go → ...ernal/metastore/db/dao/record_log_test.go
diff --git a/...ator/internal/metastore/db/dao/segment.go → go/internal/metastore/db/dao/segment.go b/...ator/internal/metastore/db/dao/segment.go → go/internal/metastore/db/dao/segment.go
diff --git a/...rnal/metastore/db/dao/segment_metadata.go → ...rnal/metastore/db/dao/segment_metadata.go b/...rnal/metastore/db/dao/segment_metadata.go → ...rnal/metastore/db/dao/segment_metadata.go
diff --git a/...internal/metastore/db/dao/segment_test.go → go/internal/metastore/db/dao/segment_test.go b/...internal/metastore/db/dao/segment_test.go → go/internal/metastore/db/dao/segment_test.go
diff --git a/...nator/internal/metastore/db/dao/tenant.go → go/internal/metastore/db/dao/tenant.go b/...nator/internal/metastore/db/dao/tenant.go → go/internal/metastore/db/dao/tenant.go
diff --git a/...ator/internal/metastore/db/dbcore/core.go → go/internal/metastore/db/dbcore/core.go b/...ator/internal/metastore/db/dbcore/core.go → go/internal/metastore/db/dbcore/core.go
diff --git a/...ternal/metastore/db/dbmodel/collection.go → ...ternal/metastore/db/dbmodel/collection.go b/...ternal/metastore/db/dbmodel/collection.go → ...ternal/metastore/db/dbmodel/collection.go
diff --git a/...tastore/db/dbmodel/collection_metadata.go → ...tastore/db/dbmodel/collection_metadata.go b/...tastore/db/dbmodel/collection_metadata.go → ...tastore/db/dbmodel/collection_metadata.go
diff --git a/...r/internal/metastore/db/dbmodel/common.go → go/internal/metastore/db/dbmodel/common.go b/...r/internal/metastore/db/dbmodel/common.go → go/internal/metastore/db/dbmodel/common.go
diff --git a/...internal/metastore/db/dbmodel/database.go → go/internal/metastore/db/dbmodel/database.go b/...internal/metastore/db/dbmodel/database.go → go/internal/metastore/db/dbmodel/database.go
diff --git a/...tastore/db/dbmodel/mocks/ICollectionDb.go → ...tastore/db/dbmodel/mocks/ICollectionDb.go b/...tastore/db/dbmodel/mocks/ICollectionDb.go → ...tastore/db/dbmodel/mocks/ICollectionDb.go
diff --git a/...db/dbmodel/mocks/ICollectionMetadataDb.go → ...db/dbmodel/mocks/ICollectionMetadataDb.go b/...db/dbmodel/mocks/ICollectionMetadataDb.go → ...db/dbmodel/mocks/ICollectionMetadataDb.go
diff --git a/...metastore/db/dbmodel/mocks/IDatabaseDb.go → ...metastore/db/dbmodel/mocks/IDatabaseDb.go b/...metastore/db/dbmodel/mocks/IDatabaseDb.go → ...metastore/db/dbmodel/mocks/IDatabaseDb.go
diff --git a/...metastore/db/dbmodel/mocks/IMetaDomain.go → ...metastore/db/dbmodel/mocks/IMetaDomain.go b/...metastore/db/dbmodel/mocks/IMetaDomain.go → ...metastore/db/dbmodel/mocks/IMetaDomain.go
diff --git a/...store/db/dbmodel/mocks/INotificationDb.go → ...store/db/dbmodel/mocks/INotificationDb.go b/...store/db/dbmodel/mocks/INotificationDb.go → ...store/db/dbmodel/mocks/INotificationDb.go
diff --git a/.../metastore/db/dbmodel/mocks/ISegmentDb.go → .../metastore/db/dbmodel/mocks/ISegmentDb.go b/.../metastore/db/dbmodel/mocks/ISegmentDb.go → .../metastore/db/dbmodel/mocks/ISegmentDb.go
diff --git a/...re/db/dbmodel/mocks/ISegmentMetadataDb.go → ...re/db/dbmodel/mocks/ISegmentMetadataDb.go b/...re/db/dbmodel/mocks/ISegmentMetadataDb.go → ...re/db/dbmodel/mocks/ISegmentMetadataDb.go
diff --git a/...l/metastore/db/dbmodel/mocks/ITenantDb.go → ...l/metastore/db/dbmodel/mocks/ITenantDb.go b/...l/metastore/db/dbmodel/mocks/ITenantDb.go → ...l/metastore/db/dbmodel/mocks/ITenantDb.go
diff --git a/...etastore/db/dbmodel/mocks/ITransaction.go → ...etastore/db/dbmodel/mocks/ITransaction.go b/...etastore/db/dbmodel/mocks/ITransaction.go → ...etastore/db/dbmodel/mocks/ITransaction.go
diff --git a/...rnal/metastore/db/dbmodel/notification.go → ...rnal/metastore/db/dbmodel/notification.go b/...rnal/metastore/db/dbmodel/notification.go → ...rnal/metastore/db/dbmodel/notification.go
diff --git a/...ternal/metastore/db/dbmodel/record_log.go → ...ternal/metastore/db/dbmodel/record_log.go b/...ternal/metastore/db/dbmodel/record_log.go → ...ternal/metastore/db/dbmodel/record_log.go
diff --git a/.../internal/metastore/db/dbmodel/segment.go → go/internal/metastore/db/dbmodel/segment.go b/.../internal/metastore/db/dbmodel/segment.go → go/internal/metastore/db/dbmodel/segment.go
diff --git a/.../metastore/db/dbmodel/segment_metadata.go → .../metastore/db/dbmodel/segment_metadata.go b/.../metastore/db/dbmodel/segment_metadata.go → .../metastore/db/dbmodel/segment_metadata.go
diff --git a/...r/internal/metastore/db/dbmodel/tenant.go → go/internal/metastore/db/dbmodel/tenant.go b/...r/internal/metastore/db/dbmodel/tenant.go → go/internal/metastore/db/dbmodel/tenant.go
diff --git a/...nator/internal/metastore/mocks/Catalog.go → go/internal/metastore/mocks/Catalog.go b/...nator/internal/metastore/mocks/Catalog.go → go/internal/metastore/mocks/Catalog.go
diff --git a/go/coordinator/internal/model/collection.go → go/internal/model/collection.go b/go/coordinator/internal/model/collection.go → go/internal/model/collection.go
diff --git a/...tor/internal/model/collection_metadata.go → go/internal/model/collection_metadata.go b/...tor/internal/model/collection_metadata.go → go/internal/model/collection_metadata.go
diff --git a/go/coordinator/internal/model/database.go → go/internal/model/database.go b/go/coordinator/internal/model/database.go → go/internal/model/database.go
diff --git a/...oordinator/internal/model/notification.go → go/internal/model/notification.go b/...oordinator/internal/model/notification.go → go/internal/model/notification.go
diff --git a/go/coordinator/internal/model/segment.go → go/internal/model/segment.go b/go/coordinator/internal/model/segment.go → go/internal/model/segment.go
diff --git a/...inator/internal/model/segment_metadata.go → go/internal/model/segment_metadata.go b/...inator/internal/model/segment_metadata.go → go/internal/model/segment_metadata.go
diff --git a/go/coordinator/internal/model/tenant.go → go/internal/model/tenant.go b/go/coordinator/internal/model/tenant.go → go/internal/model/tenant.go
diff --git a/...tification/database_notification_store.go → ...tification/database_notification_store.go b/...tification/database_notification_store.go → ...tification/database_notification_store.go
diff --git a/...ation/database_notification_store_test.go → ...ation/database_notification_store_test.go b/...ation/database_notification_store_test.go → ...ation/database_notification_store_test.go
diff --git a/...notification/memory_notification_store.go → ...notification/memory_notification_store.go b/...notification/memory_notification_store.go → ...notification/memory_notification_store.go
diff --git a/...ication/memory_notification_store_test.go → ...ication/memory_notification_store_test.go b/...ication/memory_notification_store_test.go → ...ication/memory_notification_store_test.go
diff --git a/...al/notification/notification_processor.go → ...al/notification/notification_processor.go b/...al/notification/notification_processor.go → ...al/notification/notification_processor.go
diff --git a/...tification/notification_processor_test.go → ...tification/notification_processor_test.go b/...tification/notification_processor_test.go → ...tification/notification_processor_test.go
diff --git a/...ternal/notification/notification_store.go → ...ternal/notification/notification_store.go b/...ternal/notification/notification_store.go → ...ternal/notification/notification_store.go
diff --git a/...dinator/internal/notification/notifier.go → go/internal/notification/notifier.go b/...dinator/internal/notification/notifier.go → go/internal/notification/notifier.go
diff --git a/...internal/proto/coordinatorpb/chroma.pb.go → go/internal/proto/coordinatorpb/chroma.pb.go b/...internal/proto/coordinatorpb/chroma.pb.go → go/internal/proto/coordinatorpb/chroma.pb.go
diff --git a/...nal/proto/coordinatorpb/chroma_grpc.pb.go → ...nal/proto/coordinatorpb/chroma_grpc.pb.go b/...nal/proto/coordinatorpb/chroma_grpc.pb.go → ...nal/proto/coordinatorpb/chroma_grpc.pb.go
diff --git a/...nal/proto/coordinatorpb/coordinator.pb.go → ...nal/proto/coordinatorpb/coordinator.pb.go b/...nal/proto/coordinatorpb/coordinator.pb.go → ...nal/proto/coordinatorpb/coordinator.pb.go
diff --git a/...roto/coordinatorpb/coordinator_grpc.pb.go → ...roto/coordinatorpb/coordinator_grpc.pb.go b/...roto/coordinatorpb/coordinator_grpc.pb.go → ...roto/coordinatorpb/coordinator_grpc.pb.go
diff --git a/...ernal/proto/logservicepb/logservice.pb.go → ...ernal/proto/logservicepb/logservice.pb.go b/...ernal/proto/logservicepb/logservice.pb.go → ...ernal/proto/logservicepb/logservice.pb.go
diff --git a/.../proto/logservicepb/logservice_grpc.pb.go → .../proto/logservicepb/logservice_grpc.pb.go b/.../proto/logservicepb/logservice_grpc.pb.go → .../proto/logservicepb/logservice_grpc.pb.go
diff --git a/go/coordinator/internal/types/types.go → go/internal/types/types.go b/go/coordinator/internal/types/types.go → go/internal/types/types.go
diff --git a/go/coordinator/internal/utils/integration.go → go/internal/utils/integration.go b/go/coordinator/internal/utils/integration.go → go/internal/utils/integration.go
diff --git a/go/coordinator/internal/utils/kubernetes.go → go/internal/utils/kubernetes.go b/go/coordinator/internal/utils/kubernetes.go → go/internal/utils/kubernetes.go
diff --git a/go/coordinator/internal/utils/log.go → go/internal/utils/log.go b/go/coordinator/internal/utils/log.go → go/internal/utils/log.go
diff --git a/...oordinator/internal/utils/pulsar_admin.go → go/internal/utils/pulsar_admin.go b/...oordinator/internal/utils/pulsar_admin.go → go/internal/utils/pulsar_admin.go
diff --git a/...dinator/internal/utils/rendezvous_hash.go → go/internal/utils/rendezvous_hash.go b/...dinator/internal/utils/rendezvous_hash.go → go/internal/utils/rendezvous_hash.go
diff --git a/...or/internal/utils/rendezvous_hash_test.go → go/internal/utils/rendezvous_hash_test.go b/...or/internal/utils/rendezvous_hash_test.go → go/internal/utils/rendezvous_hash_test.go
diff --git a/go/coordinator/internal/utils/run.go → go/internal/utils/run.go b/go/coordinator/internal/utils/run.go → go/internal/utils/run.go
diff --git a/go/coordinator/internal/utils/signal.go → go/internal/utils/signal.go b/go/coordinator/internal/utils/signal.go → go/internal/utils/signal.go
diff --git a/go/coordinator/migrations/20240216211350.sql → go/migrations/20240216211350.sql b/go/coordinator/migrations/20240216211350.sql → go/migrations/20240216211350.sql
diff --git a/go/coordinator/migrations/atlas.sum → go/migrations/atlas.sum b/go/coordinator/migrations/atlas.sum → go/migrations/atlas.sum
diff --git a/idl/makefile b/idl/makefile
@@ -10,14 +10,14 @@ proto_python:
 proto_go:
 	@echo "Generating gRPC code for golang..."
 	@protoc \
-		--go_out=../go/coordinator/internal/proto/coordinatorpb \
+		--go_out=../go/internal/proto/coordinatorpb \
 		--go_opt paths=source_relative \
 		--plugin protoc-gen-go="${GOPATH}/bin/protoc-gen-go" \
-    	--go-grpc_out=../go/coordinator/internal/proto/coordinatorpb \
+    	--go-grpc_out=../go/internal/proto/coordinatorpb \
     	--go-grpc_opt paths=source_relative \
     	--plugin protoc-gen-go-grpc="${GOPATH}/bin/protoc-gen-go-grpc" \
 	    chromadb/proto/*.proto
-	@mv ../go/coordinator/internal/proto/coordinatorpb/chromadb/proto/logservice*.go ../go/coordinator/internal/proto/logservicepb/
-	@mv ../go/coordinator/internal/proto/coordinatorpb/chromadb/proto/*.go ../go/coordinator/internal/proto/coordinatorpb/
-	@rm -rf ../go/coordinator/internal/proto/coordinatorpb/chromadb
+	@mv ../go/internal/proto/coordinatorpb/chromadb/proto/logservice*.go ../go/internal/proto/logservicepb/
+	@mv ../go/internal/proto/coordinatorpb/chromadb/proto/*.go ../go/internal/proto/coordinatorpb/
+	@rm -rf ../go/internal/proto/coordinatorpb/chromadb
 	@echo "Done"