From 298878c96d7e330cdff4e517667b3756644a59ca Mon Sep 17 00:00:00 2001 From: Sammy Kerata Oina <44265300+SammyOina@users.noreply.github.com> Date: Wed, 22 Nov 2023 15:15:19 +0300 Subject: [PATCH] NOISSUE - Rename module to cocos (#22) * add stringer Signed-off-by: SammyOina * rename module to cocos Signed-off-by: SammyOina * Fix fmt.Stringer implementation in computations.go The fmt.Stringer implementation for Datasets and Algorithms in computations.go was fixed to correctly use pointers. This commit addresses the issue where the String() method for Datasets and Algorithms in computations.go was not correctly implemented. The fix ensures that the String() method now correctly marshals the data to JSON and returns the string representation. The changes made in this commit will improve the functionality and accuracy of the String() method for Datasets and Algorithms. Signed-off-by: SammyOina --------- Signed-off-by: SammyOina --- agent/README.md | 4 +-- agent/api/grpc/client.go | 2 +- agent/api/grpc/endpoint.go | 2 +- agent/api/grpc/server.go | 2 +- agent/api/logging.go | 2 +- agent/api/metrics.go | 2 +- agent/computations.go | 52 +++++++++++++++++++++-------- agent/service.go | 2 +- agent/tracing/tracing.go | 14 ++------ cli/algorithms.go | 2 +- cli/attestation.go | 2 +- cli/datasets.go | 2 +- cli/openapi.yaml | 2 +- cli/result.go | 2 +- cli/run.go | 2 +- cli/sdk.go | 2 +- cmd/agent/main.go | 18 +++++----- cmd/cli/main.go | 10 +++--- cmd/manager/main.go | 30 ++++++++--------- go.mod | 2 +- internal/server/grpc/grpc.go | 2 +- internal/server/http/http.go | 2 +- manager/README.md | 4 +-- manager/api/grpc/client.go | 2 +- manager/api/grpc/endpoint.go | 2 +- manager/api/grpc/requests.go | 2 +- manager/api/grpc/server.go | 2 +- manager/api/http/endpoint.go | 2 +- manager/api/http/requests.go | 2 +- manager/api/http/transport.go | 2 +- manager/api/logging.go | 2 +- manager/api/metrics.go | 2 +- manager/qemu/qemu.go | 2 +- manager/service.go | 4 +-- manager/tracing/tracing.go | 2 +- pkg/clients/grpc/agent/agent.go | 6 ++-- pkg/clients/grpc/manager/manager.go | 6 ++-- pkg/sdk/agent.go | 2 +- 38 files changed, 111 insertions(+), 93 deletions(-) diff --git a/agent/README.md b/agent/README.md index abd0a3f3..76c1ab66 100644 --- a/agent/README.md +++ b/agent/README.md @@ -25,9 +25,9 @@ To start the service outside of the container, execute the following shell scrip ```bash # download the latest version of the service -go get github.com/ultravioletrs/cocos-ai +go get github.com/ultravioletrs/cocos -cd $GOPATH/src/github.com/ultravioletrs/cocos-ai +cd $GOPATH/src/github.com/ultravioletrs/cocos # compile the agent make agent diff --git a/agent/api/grpc/client.go b/agent/api/grpc/client.go index 4ca98029..e8058d08 100644 --- a/agent/api/grpc/client.go +++ b/agent/api/grpc/client.go @@ -9,7 +9,7 @@ import ( "github.com/go-kit/kit/endpoint" kitgrpc "github.com/go-kit/kit/transport/grpc" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" "google.golang.org/grpc" ) diff --git a/agent/api/grpc/endpoint.go b/agent/api/grpc/endpoint.go index 6e8de276..16bc1e23 100644 --- a/agent/api/grpc/endpoint.go +++ b/agent/api/grpc/endpoint.go @@ -7,7 +7,7 @@ import ( "encoding/json" "github.com/go-kit/kit/endpoint" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) func runEndpoint(svc agent.Service) endpoint.Endpoint { diff --git a/agent/api/grpc/server.go b/agent/api/grpc/server.go index d4ac398e..f3bbe038 100644 --- a/agent/api/grpc/server.go +++ b/agent/api/grpc/server.go @@ -6,7 +6,7 @@ import ( "context" "github.com/go-kit/kit/transport/grpc" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) type grpcServer struct { diff --git a/agent/api/logging.go b/agent/api/logging.go index 00f4d6ca..7b7e936e 100644 --- a/agent/api/logging.go +++ b/agent/api/logging.go @@ -12,7 +12,7 @@ import ( "time" "github.com/absmach/magistrala/logger" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) var _ agent.Service = (*loggingMiddleware)(nil) diff --git a/agent/api/metrics.go b/agent/api/metrics.go index cafcd9aa..90e141b8 100644 --- a/agent/api/metrics.go +++ b/agent/api/metrics.go @@ -11,7 +11,7 @@ import ( "time" "github.com/go-kit/kit/metrics" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) var _ agent.Service = (*metricsMiddleware)(nil) diff --git a/agent/computations.go b/agent/computations.go index a391b582..71fc40cc 100644 --- a/agent/computations.go +++ b/agent/computations.go @@ -5,24 +5,46 @@ package agent import ( "encoding/json" "errors" + "fmt" "reflect" "time" ) +var ( + _ fmt.Stringer = (*Datasets)(nil) + _ fmt.Stringer = (*Algorithms)(nil) +) + type Computation struct { - ID string `json:"id,omitempty"` - Name string `json:"name,omitempty"` - Description string `json:"description,omitempty"` - Status string `json:"status,omitempty"` - Owner string `json:"owner,omitempty"` - StartTime time.Time `json:"start_time,omitempty"` - EndTime time.Time `json:"end_time,omitempty"` - Datasets []Dataset `json:"datasets,omitempty"` - Algorithms []Algorithm `json:"algorithms,omitempty"` - ResultConsumers []string `json:"result_consumers,omitempty"` - Ttl int32 `json:"ttl,omitempty"` - Metadata Metadata `json:"metadata,omitempty"` - Timeout Duration `json:"timeout,omitempty"` + ID string `json:"id,omitempty"` + Name string `json:"name,omitempty"` + Description string `json:"description,omitempty"` + Status string `json:"status,omitempty"` + Owner string `json:"owner,omitempty"` + StartTime time.Time `json:"start_time,omitempty"` + EndTime time.Time `json:"end_time,omitempty"` + Datasets Datasets `json:"datasets,omitempty"` + Algorithms Algorithms `json:"algorithms,omitempty"` + ResultConsumers []string `json:"result_consumers,omitempty"` + Ttl int32 `json:"ttl,omitempty"` + Metadata Metadata `json:"metadata,omitempty"` + Timeout Duration `json:"timeout,omitempty"` +} + +func (d *Datasets) String() string { + dat, err := json.Marshal(d) + if err != nil { + return "" + } + return string(dat) +} + +func (a *Algorithms) String() string { + dat, err := json.Marshal(a) + if err != nil { + return "" + } + return string(dat) } type Duration struct { @@ -62,12 +84,16 @@ type Dataset struct { ID string `json:"id,omitempty"` } +type Datasets []Dataset + type Algorithm struct { Algorithm []byte `json:"-"` Provider string `json:"provider,omitempty"` ID string `json:"id,omitempty"` } +type Algorithms []Algorithm + func containsID(slice interface{}, id string) int { rangeOnMe := reflect.ValueOf(slice) for i := 0; i < rangeOnMe.Len(); i++ { diff --git a/agent/service.go b/agent/service.go index 8a1598bd..18601222 100644 --- a/agent/service.go +++ b/agent/service.go @@ -16,7 +16,7 @@ import ( "github.com/absmach/magistrala/logger" "github.com/absmach/magistrala/pkg/messaging" - "github.com/ultravioletrs/cocos-ai/pkg/socket" + "github.com/ultravioletrs/cocos/pkg/socket" ) var _ Service = (*agentService)(nil) diff --git a/agent/tracing/tracing.go b/agent/tracing/tracing.go index 8ea8e96c..c4be50fe 100644 --- a/agent/tracing/tracing.go +++ b/agent/tracing/tracing.go @@ -5,7 +5,7 @@ package tracing import ( "context" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" "go.opentelemetry.io/otel/attribute" "go.opentelemetry.io/otel/trace" ) @@ -23,14 +23,6 @@ func New(svc agent.Service, tracer trace.Tracer) agent.Service { } func (tm *tracingMiddleware) Run(ctx context.Context, cmp agent.Computation) (string, error) { - var datasetProviders, algorithmProviders []string - - for _, dataset := range cmp.Datasets { - datasetProviders = append(datasetProviders, dataset.Provider) - } - for _, algos := range cmp.Algorithms { - algorithmProviders = append(algorithmProviders, algos.Provider) - } ctx, span := tm.tracer.Start(ctx, "run", trace.WithAttributes( attribute.String("id", cmp.ID), attribute.String("name", cmp.Name), @@ -38,9 +30,9 @@ func (tm *tracingMiddleware) Run(ctx context.Context, cmp agent.Computation) (st attribute.String("status", cmp.Status), attribute.String("start_time", cmp.StartTime.String()), attribute.String("end_time", cmp.EndTime.String()), - attribute.StringSlice("dataset_providers", datasetProviders), - attribute.StringSlice("algorithm_providers", algorithmProviders), attribute.StringSlice("result_consumers", cmp.ResultConsumers), + attribute.Stringer("datasets", &cmp.Datasets), + attribute.Stringer("algorithms", &cmp.Algorithms), )) defer span.End() diff --git a/cli/algorithms.go b/cli/algorithms.go index 8e4d5f07..c67542ad 100644 --- a/cli/algorithms.go +++ b/cli/algorithms.go @@ -7,7 +7,7 @@ import ( "os" "github.com/spf13/cobra" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) func NewAlgorithmsCmd(sdk agent.Service) *cobra.Command { diff --git a/cli/attestation.go b/cli/attestation.go index 02e5c1f8..8485b924 100644 --- a/cli/attestation.go +++ b/cli/attestation.go @@ -7,7 +7,7 @@ import ( "os" "github.com/spf13/cobra" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) const attestationFilePath = "attestation.txt" diff --git a/cli/datasets.go b/cli/datasets.go index ffd6bd61..575b9a3e 100644 --- a/cli/datasets.go +++ b/cli/datasets.go @@ -7,7 +7,7 @@ import ( "os" "github.com/spf13/cobra" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) func NewDatasetsCmd(sdk agent.Service) *cobra.Command { diff --git a/cli/openapi.yaml b/cli/openapi.yaml index fe0c891a..b2e4abbe 100644 --- a/cli/openapi.yaml +++ b/cli/openapi.yaml @@ -3,7 +3,7 @@ info: title: Computation Service API version: 1.0.0 servers: - - url: https://api.example.com/v1 + - url: http://localhost:7002 paths: /run: post: diff --git a/cli/result.go b/cli/result.go index 166eb317..ea634f2d 100644 --- a/cli/result.go +++ b/cli/result.go @@ -7,7 +7,7 @@ import ( "os" "github.com/spf13/cobra" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) const resultFilePath = "result.bin" diff --git a/cli/run.go b/cli/run.go index feef723a..4eedad92 100644 --- a/cli/run.go +++ b/cli/run.go @@ -7,7 +7,7 @@ import ( "log" "github.com/spf13/cobra" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) func NewRunCmd(sdk agent.Service) *cobra.Command { diff --git a/cli/sdk.go b/cli/sdk.go index 98765809..7b2bc915 100644 --- a/cli/sdk.go +++ b/cli/sdk.go @@ -3,7 +3,7 @@ package cli import ( - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) func SetSDK(s agent.Service) { diff --git a/cmd/agent/main.go b/cmd/agent/main.go index 1e73266a..46aeff1b 100644 --- a/cmd/agent/main.go +++ b/cmd/agent/main.go @@ -12,15 +12,15 @@ import ( "github.com/absmach/magistrala/pkg/messaging" "github.com/absmach/magistrala/pkg/messaging/brokers" "github.com/absmach/magistrala/pkg/uuid" - "github.com/ultravioletrs/cocos-ai/agent" - "github.com/ultravioletrs/cocos-ai/agent/api" - agentgrpc "github.com/ultravioletrs/cocos-ai/agent/api/grpc" - "github.com/ultravioletrs/cocos-ai/agent/tracing" - "github.com/ultravioletrs/cocos-ai/internal" - "github.com/ultravioletrs/cocos-ai/internal/env" - jaegerclient "github.com/ultravioletrs/cocos-ai/internal/jaeger" - "github.com/ultravioletrs/cocos-ai/internal/server" - grpcserver "github.com/ultravioletrs/cocos-ai/internal/server/grpc" + "github.com/ultravioletrs/cocos/agent" + "github.com/ultravioletrs/cocos/agent/api" + agentgrpc "github.com/ultravioletrs/cocos/agent/api/grpc" + "github.com/ultravioletrs/cocos/agent/tracing" + "github.com/ultravioletrs/cocos/internal" + "github.com/ultravioletrs/cocos/internal/env" + jaegerclient "github.com/ultravioletrs/cocos/internal/jaeger" + "github.com/ultravioletrs/cocos/internal/server" + grpcserver "github.com/ultravioletrs/cocos/internal/server/grpc" "go.opentelemetry.io/otel/trace" "golang.org/x/sync/errgroup" "google.golang.org/grpc" diff --git a/cmd/cli/main.go b/cmd/cli/main.go index 11f565ef..7c6adb67 100644 --- a/cmd/cli/main.go +++ b/cmd/cli/main.go @@ -10,11 +10,11 @@ import ( "github.com/absmach/magistrala/logger" "github.com/spf13/cobra" "github.com/spf13/pflag" - "github.com/ultravioletrs/cocos-ai/cli" - "github.com/ultravioletrs/cocos-ai/internal/env" - "github.com/ultravioletrs/cocos-ai/pkg/clients/grpc" - "github.com/ultravioletrs/cocos-ai/pkg/clients/grpc/agent" - "github.com/ultravioletrs/cocos-ai/pkg/sdk" + "github.com/ultravioletrs/cocos/cli" + "github.com/ultravioletrs/cocos/internal/env" + "github.com/ultravioletrs/cocos/pkg/clients/grpc" + "github.com/ultravioletrs/cocos/pkg/clients/grpc/agent" + "github.com/ultravioletrs/cocos/pkg/sdk" ) const ( diff --git a/cmd/manager/main.go b/cmd/manager/main.go index ba70d7d5..ec8c5f23 100644 --- a/cmd/manager/main.go +++ b/cmd/manager/main.go @@ -13,21 +13,21 @@ import ( "github.com/absmach/magistrala/logger" "github.com/absmach/magistrala/pkg/messaging/brokers" "github.com/absmach/magistrala/pkg/uuid" - "github.com/ultravioletrs/cocos-ai/agent" - "github.com/ultravioletrs/cocos-ai/internal" - "github.com/ultravioletrs/cocos-ai/internal/env" - jaegerclient "github.com/ultravioletrs/cocos-ai/internal/jaeger" - "github.com/ultravioletrs/cocos-ai/internal/server" - grpcserver "github.com/ultravioletrs/cocos-ai/internal/server/grpc" - httpserver "github.com/ultravioletrs/cocos-ai/internal/server/http" - "github.com/ultravioletrs/cocos-ai/manager" - "github.com/ultravioletrs/cocos-ai/manager/api" - managergrpc "github.com/ultravioletrs/cocos-ai/manager/api/grpc" - httpapi "github.com/ultravioletrs/cocos-ai/manager/api/http" - "github.com/ultravioletrs/cocos-ai/manager/qemu" - "github.com/ultravioletrs/cocos-ai/manager/tracing" - pkggrpc "github.com/ultravioletrs/cocos-ai/pkg/clients/grpc" - agentgrpc "github.com/ultravioletrs/cocos-ai/pkg/clients/grpc/agent" + "github.com/ultravioletrs/cocos/agent" + "github.com/ultravioletrs/cocos/internal" + "github.com/ultravioletrs/cocos/internal/env" + jaegerclient "github.com/ultravioletrs/cocos/internal/jaeger" + "github.com/ultravioletrs/cocos/internal/server" + grpcserver "github.com/ultravioletrs/cocos/internal/server/grpc" + httpserver "github.com/ultravioletrs/cocos/internal/server/http" + "github.com/ultravioletrs/cocos/manager" + "github.com/ultravioletrs/cocos/manager/api" + managergrpc "github.com/ultravioletrs/cocos/manager/api/grpc" + httpapi "github.com/ultravioletrs/cocos/manager/api/http" + "github.com/ultravioletrs/cocos/manager/qemu" + "github.com/ultravioletrs/cocos/manager/tracing" + pkggrpc "github.com/ultravioletrs/cocos/pkg/clients/grpc" + agentgrpc "github.com/ultravioletrs/cocos/pkg/clients/grpc/agent" "go.opentelemetry.io/otel/trace" "golang.org/x/sync/errgroup" "google.golang.org/grpc" diff --git a/go.mod b/go.mod index 76ff24ce..7aa53d0b 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/ultravioletrs/cocos-ai +module github.com/ultravioletrs/cocos go 1.21.3 diff --git a/internal/server/grpc/grpc.go b/internal/server/grpc/grpc.go index 2488a6f6..0c41e163 100644 --- a/internal/server/grpc/grpc.go +++ b/internal/server/grpc/grpc.go @@ -9,7 +9,7 @@ import ( "time" "github.com/absmach/magistrala/logger" - "github.com/ultravioletrs/cocos-ai/internal/server" + "github.com/ultravioletrs/cocos/internal/server" "go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc" "google.golang.org/grpc" "google.golang.org/grpc/credentials" diff --git a/internal/server/http/http.go b/internal/server/http/http.go index d8e0806c..e8099aa7 100644 --- a/internal/server/http/http.go +++ b/internal/server/http/http.go @@ -9,7 +9,7 @@ import ( "time" "github.com/absmach/magistrala/logger" - "github.com/ultravioletrs/cocos-ai/internal/server" + "github.com/ultravioletrs/cocos/internal/server" ) const ( diff --git a/manager/README.md b/manager/README.md index 12e483db..7bfc7592 100644 --- a/manager/README.md +++ b/manager/README.md @@ -30,9 +30,9 @@ To start the service outside of the container, execute the following shell scrip ```bash # download the latest version of the service -go get github.com/ultravioletrs/cocos-ai +go get github.com/ultravioletrs/cocos -cd $GOPATH/src/github.com/ultravioletrs/cocos-ai +cd $GOPATH/src/github.com/ultravioletrs/cocos # compile the manager make manager diff --git a/manager/api/grpc/client.go b/manager/api/grpc/client.go index cde4f299..6b8adde8 100644 --- a/manager/api/grpc/client.go +++ b/manager/api/grpc/client.go @@ -9,7 +9,7 @@ import ( "github.com/go-kit/kit/endpoint" kitgrpc "github.com/go-kit/kit/transport/grpc" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" "google.golang.org/grpc" ) diff --git a/manager/api/grpc/endpoint.go b/manager/api/grpc/endpoint.go index 583af78c..e8253961 100644 --- a/manager/api/grpc/endpoint.go +++ b/manager/api/grpc/endpoint.go @@ -6,7 +6,7 @@ import ( "context" "github.com/go-kit/kit/endpoint" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" ) func runEndpoint(svc manager.Service) endpoint.Endpoint { diff --git a/manager/api/grpc/requests.go b/manager/api/grpc/requests.go index 94eece10..d5f8bb19 100644 --- a/manager/api/grpc/requests.go +++ b/manager/api/grpc/requests.go @@ -2,7 +2,7 @@ // SPDX-License-Identifier: Apache-2.0 package grpc -import "github.com/ultravioletrs/cocos-ai/manager" +import "github.com/ultravioletrs/cocos/manager" type runReq struct { Computation []byte `json:"computation,omitempty"` diff --git a/manager/api/grpc/server.go b/manager/api/grpc/server.go index 31208c0f..487914ec 100644 --- a/manager/api/grpc/server.go +++ b/manager/api/grpc/server.go @@ -6,7 +6,7 @@ import ( "context" "github.com/go-kit/kit/transport/grpc" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" ) type grpcServer struct { diff --git a/manager/api/http/endpoint.go b/manager/api/http/endpoint.go index 5417a3bb..c281f69a 100644 --- a/manager/api/http/endpoint.go +++ b/manager/api/http/endpoint.go @@ -6,7 +6,7 @@ import ( "context" "github.com/go-kit/kit/endpoint" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" ) func runEndpoint(svc manager.Service) endpoint.Endpoint { diff --git a/manager/api/http/requests.go b/manager/api/http/requests.go index fbb22c4a..0b0a1e1d 100644 --- a/manager/api/http/requests.go +++ b/manager/api/http/requests.go @@ -2,7 +2,7 @@ // SPDX-License-Identifier: Apache-2.0 package http -import "github.com/ultravioletrs/cocos-ai/manager" +import "github.com/ultravioletrs/cocos/manager" var _ apiReq = (*runReq)(nil) diff --git a/manager/api/http/transport.go b/manager/api/http/transport.go index 8c7d10e3..987dae64 100644 --- a/manager/api/http/transport.go +++ b/manager/api/http/transport.go @@ -14,7 +14,7 @@ import ( kithttp "github.com/go-kit/kit/transport/http" "github.com/go-zoo/bone" "github.com/prometheus/client_golang/prometheus/promhttp" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp" ) diff --git a/manager/api/logging.go b/manager/api/logging.go index 78445fe7..1d4ba4bd 100644 --- a/manager/api/logging.go +++ b/manager/api/logging.go @@ -12,7 +12,7 @@ import ( "time" log "github.com/absmach/magistrala/logger" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" ) var _ manager.Service = (*loggingMiddleware)(nil) diff --git a/manager/api/metrics.go b/manager/api/metrics.go index cd1225c5..dca400f9 100644 --- a/manager/api/metrics.go +++ b/manager/api/metrics.go @@ -11,7 +11,7 @@ import ( "time" "github.com/go-kit/kit/metrics" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" ) var _ manager.Service = (*metricsMiddleware)(nil) diff --git a/manager/qemu/qemu.go b/manager/qemu/qemu.go index 6d4cb9f0..e550107b 100644 --- a/manager/qemu/qemu.go +++ b/manager/qemu/qemu.go @@ -8,7 +8,7 @@ import ( "os/exec" "github.com/gofrs/uuid" - "github.com/ultravioletrs/cocos-ai/internal" + "github.com/ultravioletrs/cocos/internal" ) const ( diff --git a/manager/service.go b/manager/service.go index 74b4fb76..6da8e7c1 100644 --- a/manager/service.go +++ b/manager/service.go @@ -7,8 +7,8 @@ import ( "errors" "github.com/cenkalti/backoff/v4" - "github.com/ultravioletrs/cocos-ai/agent" - "github.com/ultravioletrs/cocos-ai/manager/qemu" + "github.com/ultravioletrs/cocos/agent" + "github.com/ultravioletrs/cocos/manager/qemu" ) var ( diff --git a/manager/tracing/tracing.go b/manager/tracing/tracing.go index 1e766eac..dfeea317 100644 --- a/manager/tracing/tracing.go +++ b/manager/tracing/tracing.go @@ -5,7 +5,7 @@ package tracing import ( "context" - "github.com/ultravioletrs/cocos-ai/manager" + "github.com/ultravioletrs/cocos/manager" "go.opentelemetry.io/otel/trace" ) diff --git a/pkg/clients/grpc/agent/agent.go b/pkg/clients/grpc/agent/agent.go index acca7782..5c1751b6 100644 --- a/pkg/clients/grpc/agent/agent.go +++ b/pkg/clients/grpc/agent/agent.go @@ -3,9 +3,9 @@ package agent import ( - "github.com/ultravioletrs/cocos-ai/agent" - agentapi "github.com/ultravioletrs/cocos-ai/agent/api/grpc" - "github.com/ultravioletrs/cocos-ai/pkg/clients/grpc" + "github.com/ultravioletrs/cocos/agent" + agentapi "github.com/ultravioletrs/cocos/agent/api/grpc" + "github.com/ultravioletrs/cocos/pkg/clients/grpc" ) // NewAgentClient creates new agent gRPC client instance. diff --git a/pkg/clients/grpc/manager/manager.go b/pkg/clients/grpc/manager/manager.go index 352faf4f..e5a34bd0 100644 --- a/pkg/clients/grpc/manager/manager.go +++ b/pkg/clients/grpc/manager/manager.go @@ -3,9 +3,9 @@ package manager import ( - "github.com/ultravioletrs/cocos-ai/manager" - managerapi "github.com/ultravioletrs/cocos-ai/manager/api/grpc" - "github.com/ultravioletrs/cocos-ai/pkg/clients/grpc" + "github.com/ultravioletrs/cocos/manager" + managerapi "github.com/ultravioletrs/cocos/manager/api/grpc" + "github.com/ultravioletrs/cocos/pkg/clients/grpc" ) // NewManagerClient creates new manager gRPC client instance. diff --git a/pkg/sdk/agent.go b/pkg/sdk/agent.go index c5bca7c5..f33f1f3b 100644 --- a/pkg/sdk/agent.go +++ b/pkg/sdk/agent.go @@ -7,7 +7,7 @@ import ( "encoding/json" "github.com/absmach/magistrala/logger" - "github.com/ultravioletrs/cocos-ai/agent" + "github.com/ultravioletrs/cocos/agent" ) var _ agent.Service = (*agentSDK)(nil)