Repository: Tochemey/goakt
Pull request #331 (2024-05-24 07:56:54)

fix: fix module path to match version

codecov[bot]: ## [Codecov](https://app.codecov.io/gh/Tochemey/goakt/pull/331?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Arsene) Report
All modified and coverable lines are covered by tests :white_check_mark:
> Project coverage is 87.02%. Comparing base [(`50e4930`)](https://app.codecov.io/gh/Tochemey/goakt/commit/50e4930e06110927687ccb304345eccf05daf4b9?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Arsene) to head [(`5cbeee7`)](https://app.codecov.io/gh/Tochemey/goakt/pull/331?dropdown=coverage&src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Arsene).


<details><summary>Additional details and impacted files</summary>


```diff
@@           Coverage Diff           @@
##             main     #331   +/-   ##
=======================================
  Coverage   87.02%   87.02%           
=======================================
  Files          32       32           
  Lines        2991     2991           
=======================================
  Hits         2603     2603           
  Misses        274      274           
  Partials      114      114           
```



</details>

[:umbrella: View full report in Codecov by Sentry](https://app.codecov.io/gh/Tochemey/goakt/pull/331?dropdown=coverage&src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Arsene).   
:loudspeaker: Have feedback on the report? [Share it here](https://about.codecov.io/codecov-pr-comment-feedback/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Arsene).


Patch:
diff --git a/README.md b/README.md
index 32833e0..e9af28c 100644
--- a/README.md
+++ b/README.md
@@ -201,7 +201,7 @@ You can schedule sending messages to actor that will be acted upon in the future
 #### Cron Expression Format
 
 | Field        | Required | Allowed Values  | Allowed Special Characters |
-| ------------ | -------- | --------------- | -------------------------- |
+|--------------|----------|-----------------|----------------------------|
 | Seconds      | yes      | 0-59            | , - * /                    |
 | Minutes      | yes      | 0-59            | , - * /                    |
 | Hours        | yes      | 0-23            | , - * /                    |
@@ -336,7 +336,7 @@ The API interface helps interact with a Go-Akt actor system as kind of client. T
 ## Installation
 
 ```bash
-go get github.com/tochemey/goakt
+go get github.com/tochemey/goakt/v2
 ```
 
 ## Clustering
diff --git a/actors/actor_system.go b/actors/actor_system.go
index b58e328..7c18687 100644
--- a/actors/actor_system.go
+++ b/actors/actor_system.go
@@ -49,17 +49,17 @@ import (
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/anypb"
 
-	"github.com/tochemey/goakt/discovery"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/hash"
-	"github.com/tochemey/goakt/internal/cluster"
-	"github.com/tochemey/goakt/internal/eventstream"
-	"github.com/tochemey/goakt/internal/internalpb"
-	"github.com/tochemey/goakt/internal/internalpb/internalpbconnect"
-	"github.com/tochemey/goakt/internal/metric"
-	"github.com/tochemey/goakt/internal/types"
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/telemetry"
+	"github.com/tochemey/goakt/v2/discovery"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/hash"
+	"github.com/tochemey/goakt/v2/internal/cluster"
+	"github.com/tochemey/goakt/v2/internal/eventstream"
+	"github.com/tochemey/goakt/v2/internal/internalpb"
+	"github.com/tochemey/goakt/v2/internal/internalpb/internalpbconnect"
+	"github.com/tochemey/goakt/v2/internal/metric"
+	"github.com/tochemey/goakt/v2/internal/types"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/telemetry"
 )
 
 // ActorSystem defines the contract of an actor system
diff --git a/actors/api.go b/actors/api.go
index 0efc760..910f003 100644
--- a/actors/api.go
+++ b/actors/api.go
@@ -34,10 +34,10 @@ import (
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/anypb"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/internal/http"
-	"github.com/tochemey/goakt/internal/internalpb"
-	"github.com/tochemey/goakt/internal/internalpb/internalpbconnect"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/internal/http"
+	"github.com/tochemey/goakt/v2/internal/internalpb"
+	"github.com/tochemey/goakt/v2/internal/internalpb/internalpbconnect"
 )
 
 // Ask sends a synchronous message to another actor and expect a response.
diff --git a/actors/behavior.go b/actors/behavior.go
index b67ac81..4a6e57c 100644
--- a/actors/behavior.go
+++ b/actors/behavior.go
@@ -25,7 +25,7 @@
 package actors
 
 import (
-	"github.com/tochemey/goakt/internal/stack"
+	"github.com/tochemey/goakt/v2/internal/stack"
 )
 
 // Behavior defines an actor behavior
diff --git a/actors/constants.go b/actors/constants.go
index d54c4e3..450c73b 100644
--- a/actors/constants.go
+++ b/actors/constants.go
@@ -27,7 +27,7 @@ package actors
 import (
 	"time"
 
-	"github.com/tochemey/goakt/goaktpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
 )
 
 // StrategyDirective represents the supervisor strategy directive
diff --git a/actors/context.go b/actors/context.go
index aee2b47..8c71eb0 100644
--- a/actors/context.go
+++ b/actors/context.go
@@ -33,7 +33,7 @@ import (
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/anypb"
 
-	"github.com/tochemey/goakt/goaktpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
 )
 
 // ReceiveContext is the context that is used by the actor to receive messages
diff --git a/actors/fn.go b/actors/fn.go
index 6908a15..1fb0fa5 100644
--- a/actors/fn.go
+++ b/actors/fn.go
@@ -29,7 +29,7 @@ import (
 
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/goaktpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
 )
 
 // ReceiveFunc is a message handling placeholder
diff --git a/actors/option.go b/actors/option.go
index 6b2036c..ff643bb 100644
--- a/actors/option.go
+++ b/actors/option.go
@@ -28,10 +28,10 @@ import (
 	"errors"
 	"time"
 
-	"github.com/tochemey/goakt/discovery"
-	"github.com/tochemey/goakt/hash"
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/telemetry"
+	"github.com/tochemey/goakt/v2/discovery"
+	"github.com/tochemey/goakt/v2/hash"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/telemetry"
 )
 
 var (
diff --git a/actors/path.go b/actors/path.go
index 7153a44..e50b6b4 100644
--- a/actors/path.go
+++ b/actors/path.go
@@ -29,7 +29,7 @@ import (
 
 	"github.com/google/uuid"
 
-	"github.com/tochemey/goakt/goaktpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
 )
 
 // Path is a unique path to an actor
diff --git a/actors/pid.go b/actors/pid.go
index 1e47473..219c466 100644
--- a/actors/pid.go
+++ b/actors/pid.go
@@ -45,16 +45,16 @@ import (
 	"google.golang.org/protobuf/types/known/anypb"
 	"google.golang.org/protobuf/types/known/timestamppb"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/internal/eventstream"
-	"github.com/tochemey/goakt/internal/http"
-	"github.com/tochemey/goakt/internal/internalpb"
-	"github.com/tochemey/goakt/internal/internalpb/internalpbconnect"
-	"github.com/tochemey/goakt/internal/metric"
-	"github.com/tochemey/goakt/internal/slices"
-	"github.com/tochemey/goakt/internal/types"
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/telemetry"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/internal/eventstream"
+	"github.com/tochemey/goakt/v2/internal/http"
+	"github.com/tochemey/goakt/v2/internal/internalpb"
+	"github.com/tochemey/goakt/v2/internal/internalpb/internalpbconnect"
+	"github.com/tochemey/goakt/v2/internal/metric"
+	"github.com/tochemey/goakt/v2/internal/slices"
+	"github.com/tochemey/goakt/v2/internal/types"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/telemetry"
 )
 
 // watcher is used to handle parent child relationship.
diff --git a/actors/pid_map.go b/actors/pid_map.go
index 60d51db..bffa32c 100644
--- a/actors/pid_map.go
+++ b/actors/pid_map.go
@@ -29,7 +29,7 @@ import (
 
 	"github.com/alphadose/haxmap"
 
-	"github.com/tochemey/goakt/internal/types"
+	"github.com/tochemey/goakt/v2/internal/types"
 )
 
 type prop struct {
diff --git a/actors/pid_option.go b/actors/pid_option.go
index 08fd880..cb917e7 100644
--- a/actors/pid_option.go
+++ b/actors/pid_option.go
@@ -27,9 +27,9 @@ package actors
 import (
 	"time"
 
-	"github.com/tochemey/goakt/internal/eventstream"
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/telemetry"
+	"github.com/tochemey/goakt/v2/internal/eventstream"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/telemetry"
 )
 
 // pidOption represents the pid
diff --git a/actors/reflection.go b/actors/reflection.go
index 54d7069..560a45e 100644
--- a/actors/reflection.go
+++ b/actors/reflection.go
@@ -27,7 +27,7 @@ package actors
 import (
 	"reflect"
 
-	"github.com/tochemey/goakt/internal/types"
+	"github.com/tochemey/goakt/v2/internal/types"
 )
 
 // reflection helps create an instance dynamically
diff --git a/actors/scheduler.go b/actors/scheduler.go
index e78f60c..cc94fff 100644
--- a/actors/scheduler.go
+++ b/actors/scheduler.go
@@ -39,9 +39,9 @@ import (
 	"go.uber.org/atomic"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/internal/cluster"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/internal/cluster"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 var errSkipJobScheduling = errors.New("skip job scheduling")
diff --git a/discovery/dnssd/config.go b/discovery/dnssd/config.go
index d64e833..e5d75ae 100644
--- a/discovery/dnssd/config.go
+++ b/discovery/dnssd/config.go
@@ -24,7 +24,7 @@
 
 package dnssd
 
-import "github.com/tochemey/goakt/internal/validation"
+import "github.com/tochemey/goakt/v2/internal/validation"
 
 // Config defines the discovery configuration
 type Config struct {
diff --git a/discovery/dnssd/discovery.go b/discovery/dnssd/discovery.go
index 8dab2f3..5263a2c 100644
--- a/discovery/dnssd/discovery.go
+++ b/discovery/dnssd/discovery.go
@@ -33,7 +33,7 @@ import (
 	"github.com/pkg/errors"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
 )
 
 const (
diff --git a/discovery/kubernetes/config.go b/discovery/kubernetes/config.go
index 4046c88..ebcdd64 100644
--- a/discovery/kubernetes/config.go
+++ b/discovery/kubernetes/config.go
@@ -25,7 +25,7 @@
 package kubernetes
 
 import (
-	"github.com/tochemey/goakt/internal/validation"
+	"github.com/tochemey/goakt/v2/internal/validation"
 )
 
 // Config defines the kubernetes discovery configuration
diff --git a/discovery/kubernetes/discovery.go b/discovery/kubernetes/discovery.go
index b0244e0..23aabce 100644
--- a/discovery/kubernetes/discovery.go
+++ b/discovery/kubernetes/discovery.go
@@ -40,7 +40,7 @@ import (
 	"k8s.io/client-go/rest"
 	"k8s.io/utils/strings/slices"
 
-	"github.com/tochemey/goakt/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
 )
 
 // Discovery represents the kubernetes discovery
diff --git a/discovery/mdns/config.go b/discovery/mdns/config.go
index d9211c4..5e3a51f 100644
--- a/discovery/mdns/config.go
+++ b/discovery/mdns/config.go
@@ -24,7 +24,7 @@
 
 package mdns
 
-import "github.com/tochemey/goakt/internal/validation"
+import "github.com/tochemey/goakt/v2/internal/validation"
 
 // Config represents the mDNS provider discoConfig
 type Config struct {
diff --git a/discovery/mdns/discovery.go b/discovery/mdns/discovery.go
index d0b050e..dede2b1 100644
--- a/discovery/mdns/discovery.go
+++ b/discovery/mdns/discovery.go
@@ -36,7 +36,7 @@ import (
 	"github.com/pkg/errors"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
 )
 
 // Discovery defines the mDNS discovery provider
diff --git a/discovery/nats/config.go b/discovery/nats/config.go
index ed43f1d..b9f607b 100644
--- a/discovery/nats/config.go
+++ b/discovery/nats/config.go
@@ -27,7 +27,7 @@ package nats
 import (
 	"time"
 
-	"github.com/tochemey/goakt/internal/validation"
+	"github.com/tochemey/goakt/v2/internal/validation"
 )
 
 // Config represents the nats provider discoConfig
diff --git a/discovery/nats/discovery.go b/discovery/nats/discovery.go
index 220f36f..2a2da11 100644
--- a/discovery/nats/discovery.go
+++ b/discovery/nats/discovery.go
@@ -35,9 +35,9 @@ import (
 	"github.com/nats-io/nats.go/encoders/protobuf"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/discovery"
-	internalpb "github.com/tochemey/goakt/internal/internalpb"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/discovery"
+	internalpb "github.com/tochemey/goakt/v2/internal/internalpb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 // Discovery represents the kubernetes discovery
diff --git a/discovery/nats/option.go b/discovery/nats/option.go
index 1dc5a00..384764e 100644
--- a/discovery/nats/option.go
+++ b/discovery/nats/option.go
@@ -24,7 +24,7 @@
 
 package nats
 
-import "github.com/tochemey/goakt/log"
+import "github.com/tochemey/goakt/v2/log"
 
 // Option is the interface that applies a configuration option.
 type Option interface {
diff --git a/examples/actor-cluster/dnssd/actors/actors.go b/examples/actor-cluster/dnssd/actors/actors.go
index 87e04fa..5b655e6 100644
--- a/examples/actor-cluster/dnssd/actors/actors.go
+++ b/examples/actor-cluster/dnssd/actors/actors.go
@@ -30,10 +30,10 @@ import (
 
 	"go.uber.org/atomic"
 
-	goakt "github.com/tochemey/goakt/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 type AccountEntity struct {
diff --git a/examples/actor-cluster/dnssd/cmd/run.go b/examples/actor-cluster/dnssd/cmd/run.go
index d1fbf79..4d79692 100644
--- a/examples/actor-cluster/dnssd/cmd/run.go
+++ b/examples/actor-cluster/dnssd/cmd/run.go
@@ -44,10 +44,10 @@ import (
 	sdktrace "go.opentelemetry.io/otel/sdk/trace"
 	semconv "go.opentelemetry.io/otel/semconv/v1.21.0"
 
-	goakt "github.com/tochemey/goakt/actors"
-	"github.com/tochemey/goakt/discovery/dnssd"
-	"github.com/tochemey/goakt/examples/actor-cluster/dnssd/service"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	"github.com/tochemey/goakt/v2/discovery/dnssd"
+	"github.com/tochemey/goakt/v2/examples/actor-cluster/dnssd/service"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 func initTracer(ctx context.Context, res *resource.Resource, traceURL string) {
diff --git a/examples/actor-cluster/dnssd/main.go b/examples/actor-cluster/dnssd/main.go
index ea1f2af..d3af99f 100644
--- a/examples/actor-cluster/dnssd/main.go
+++ b/examples/actor-cluster/dnssd/main.go
@@ -25,7 +25,7 @@
 package main
 
 import (
-	"github.com/tochemey/goakt/examples/actor-cluster/dnssd/cmd"
+	"github.com/tochemey/goakt/v2/examples/actor-cluster/dnssd/cmd"
 )
 
 func main() {
diff --git a/examples/actor-cluster/dnssd/service/service.go b/examples/actor-cluster/dnssd/service/service.go
index b4c4a7a..253eb99 100644
--- a/examples/actor-cluster/dnssd/service/service.go
+++ b/examples/actor-cluster/dnssd/service/service.go
@@ -37,11 +37,11 @@ import (
 	"golang.org/x/net/http2/h2c"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/actors"
-	kactors "github.com/tochemey/goakt/examples/actor-cluster/dnssd/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/examples/protos/samplepb/samplepbconnect"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/actors"
+	kactors "github.com/tochemey/goakt/v2/examples/actor-cluster/dnssd/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/examples/protos/samplepb/samplepbconnect"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 type AccountService struct {
diff --git a/examples/actor-cluster/k8s/actors/actors.go b/examples/actor-cluster/k8s/actors/actors.go
index 87e04fa..5b655e6 100644
--- a/examples/actor-cluster/k8s/actors/actors.go
+++ b/examples/actor-cluster/k8s/actors/actors.go
@@ -30,10 +30,10 @@ import (
 
 	"go.uber.org/atomic"
 
-	goakt "github.com/tochemey/goakt/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 type AccountEntity struct {
diff --git a/examples/actor-cluster/k8s/cmd/run.go b/examples/actor-cluster/k8s/cmd/run.go
index 18eb984..c99c219 100644
--- a/examples/actor-cluster/k8s/cmd/run.go
+++ b/examples/actor-cluster/k8s/cmd/run.go
@@ -34,10 +34,10 @@ import (
 	"github.com/caarlos0/env/v11"
 	"github.com/spf13/cobra"
 
-	goakt "github.com/tochemey/goakt/actors"
-	"github.com/tochemey/goakt/discovery/kubernetes"
-	"github.com/tochemey/goakt/examples/actor-cluster/k8s/service"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	"github.com/tochemey/goakt/v2/discovery/kubernetes"
+	"github.com/tochemey/goakt/v2/examples/actor-cluster/k8s/service"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 const (
diff --git a/examples/actor-cluster/k8s/main.go b/examples/actor-cluster/k8s/main.go
index 9412d5e..2b1e6d4 100644
--- a/examples/actor-cluster/k8s/main.go
+++ b/examples/actor-cluster/k8s/main.go
@@ -24,7 +24,7 @@
 
 package main
 
-import "github.com/tochemey/goakt/examples/actor-cluster/k8s/cmd"
+import "github.com/tochemey/goakt/v2/examples/actor-cluster/k8s/cmd"
 
 func main() {
 	cmd.Execute()
diff --git a/examples/actor-cluster/k8s/service/service.go b/examples/actor-cluster/k8s/service/service.go
index cae408d..72723ec 100644
--- a/examples/actor-cluster/k8s/service/service.go
+++ b/examples/actor-cluster/k8s/service/service.go
@@ -36,11 +36,11 @@ import (
 	"golang.org/x/net/http2/h2c"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/actors"
-	kactors "github.com/tochemey/goakt/examples/actor-cluster/k8s/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/examples/protos/samplepb/samplepbconnect"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/actors"
+	kactors "github.com/tochemey/goakt/v2/examples/actor-cluster/k8s/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/examples/protos/samplepb/samplepbconnect"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 type AccountService struct {
diff --git a/examples/actor-observability/main.go b/examples/actor-observability/main.go
index 8274fc9..51516ab 100644
--- a/examples/actor-observability/main.go
+++ b/examples/actor-observability/main.go
@@ -43,10 +43,10 @@ import (
 	semconv "go.opentelemetry.io/otel/semconv/v1.21.0"
 	"go.uber.org/atomic"
 
-	goakt "github.com/tochemey/goakt/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 var serviceName = semconv.ServiceNameKey.String("actor-observability")
diff --git a/examples/actor-receive/main.go b/examples/actor-receive/main.go
index c77d174..8c0b09e 100644
--- a/examples/actor-receive/main.go
+++ b/examples/actor-receive/main.go
@@ -34,9 +34,9 @@ import (
 
 	"go.uber.org/atomic"
 
-	goakt "github.com/tochemey/goakt/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 func main() {
diff --git a/examples/actor-to-actor/main.go b/examples/actor-to-actor/main.go
index cec0bb2..8559c63 100644
--- a/examples/actor-to-actor/main.go
+++ b/examples/actor-to-actor/main.go
@@ -34,9 +34,9 @@ import (
 
 	"go.uber.org/atomic"
 
-	goakt "github.com/tochemey/goakt/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 func main() {
diff --git a/examples/protos/samplepb/sample.pb.go b/examples/protos/samplepb/sample.pb.go
index ab1b5a2..fcc43bc 100644
--- a/examples/protos/samplepb/sample.pb.go
+++ b/examples/protos/samplepb/sample.pb.go
@@ -473,18 +473,18 @@ var file_sample_sample_proto_rawDesc = []byte{
 	0x52, 0x0e, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x42, 0x61, 0x6c, 0x61, 0x6e, 0x63, 0x65,
 	0x22, 0x2b, 0x0a, 0x0a, 0x47, 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1d,
 	0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
-	0x28, 0x09, 0x52, 0x09, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x42, 0x9a, 0x01,
+	0x28, 0x09, 0x52, 0x09, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x42, 0x9d, 0x01,
 	0x0a, 0x0c, 0x63, 0x6f, 0x6d, 0x2e, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x42, 0x0b,
 	0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01, 0x5a,
-	0x3b, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63, 0x68,
-	0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x65, 0x78, 0x61, 0x6d, 0x70,
-	0x6c, 0x65, 0x73, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2f, 0x73, 0x61, 0x6d, 0x70, 0x6c,
-	0x65, 0x70, 0x62, 0x3b, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x53,
-	0x58, 0x58, 0xaa, 0x02, 0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xca, 0x02, 0x08,
-	0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xe2, 0x02, 0x14, 0x53, 0x61, 0x6d, 0x70, 0x6c,
-	0x65, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea,
-	0x02, 0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
-	0x6f, 0x33,
+	0x3e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63, 0x68,
+	0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x76, 0x32, 0x2f, 0x65, 0x78,
+	0x61, 0x6d, 0x70, 0x6c, 0x65, 0x73, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2f, 0x73, 0x61,
+	0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x3b, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xa2,
+	0x02, 0x03, 0x53, 0x58, 0x58, 0xaa, 0x02, 0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62,
+	0xca, 0x02, 0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xe2, 0x02, 0x14, 0x53, 0x61,
+	0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61,
+	0x74, 0x61, 0xea, 0x02, 0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70,
+	0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
diff --git a/examples/protos/samplepb/samplepbconnect/service.connect.go b/examples/protos/samplepb/samplepbconnect/service.connect.go
index 3c5b1b3..e64b895 100644
--- a/examples/protos/samplepb/samplepbconnect/service.connect.go
+++ b/examples/protos/samplepb/samplepbconnect/service.connect.go
@@ -8,7 +8,7 @@ import (
 	connect "connectrpc.com/connect"
 	context "context"
 	errors "errors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
 	http "net/http"
 	strings "strings"
 )
diff --git a/examples/protos/samplepb/service.pb.go b/examples/protos/samplepb/service.pb.go
index 2823612..8612c87 100644
--- a/examples/protos/samplepb/service.pb.go
+++ b/examples/protos/samplepb/service.pb.go
@@ -351,17 +351,18 @@ var file_sample_service_proto_rawDesc = []byte{
 	0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x2e, 0x47, 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f,
 	0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x73, 0x61, 0x6d,
 	0x70, 0x6c, 0x65, 0x70, 0x62, 0x2e, 0x47, 0x65, 0x74, 0x41, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74,
-	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x9b, 0x01, 0x0a, 0x0c, 0x63, 0x6f, 0x6d,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x9e, 0x01, 0x0a, 0x0c, 0x63, 0x6f, 0x6d,
 	0x2e, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x42, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x69,
-	0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01, 0x5a, 0x3b, 0x67, 0x69, 0x74,
+	0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01, 0x5a, 0x3e, 0x67, 0x69, 0x74,
 	0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x79,
-	0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x65, 0x78, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x73, 0x2f,
-	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2f, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x3b,
-	0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x53, 0x58, 0x58, 0xaa, 0x02,
-	0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xca, 0x02, 0x08, 0x53, 0x61, 0x6d, 0x70,
-	0x6c, 0x65, 0x70, 0x62, 0xe2, 0x02, 0x14, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x5c,
-	0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x08, 0x53, 0x61,
-	0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x76, 0x32, 0x2f, 0x65, 0x78, 0x61, 0x6d, 0x70, 0x6c,
+	0x65, 0x73, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2f, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65,
+	0x70, 0x62, 0x3b, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x53, 0x58,
+	0x58, 0xaa, 0x02, 0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xca, 0x02, 0x08, 0x53,
+	0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0xe2, 0x02, 0x14, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65,
+	0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02,
+	0x08, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
+	0x33,
 }
 
 var (
diff --git a/examples/remoting/ping/main.go b/examples/remoting/ping/main.go
index 62a76dd..56c2092 100644
--- a/examples/remoting/ping/main.go
+++ b/examples/remoting/ping/main.go
@@ -33,10 +33,10 @@ import (
 
 	"go.uber.org/atomic"
 
-	goakt "github.com/tochemey/goakt/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 const (
diff --git a/examples/remoting/pong/main.go b/examples/remoting/pong/main.go
index dd6b6c3..3389211 100644
--- a/examples/remoting/pong/main.go
+++ b/examples/remoting/pong/main.go
@@ -32,10 +32,10 @@ import (
 
 	"go.uber.org/atomic"
 
-	goakt "github.com/tochemey/goakt/actors"
-	samplepb "github.com/tochemey/goakt/examples/protos/samplepb"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
+	goakt "github.com/tochemey/goakt/v2/actors"
+	samplepb "github.com/tochemey/goakt/v2/examples/protos/samplepb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 const (
diff --git a/go.mod b/go.mod
index a79ca79..f5336d6 100644
--- a/go.mod
+++ b/go.mod
@@ -1,4 +1,4 @@
-module github.com/tochemey/goakt
+module github.com/tochemey/goakt/v2
 
 go 1.21
 
@@ -7,14 +7,14 @@ require (
 	connectrpc.com/otelconnect v0.7.0
 	github.com/alphadose/haxmap v1.4.0
 	github.com/buraksezer/olric v0.5.6-0.20240510193155-81e12546eb39
-	github.com/caarlos0/env/v11 v11.0.0
+	github.com/caarlos0/env/v11 v11.0.1
 	github.com/deckarep/golang-set/v2 v2.6.0
 	github.com/flowchartsman/retry v1.2.0
 	github.com/google/go-cmp v0.6.0
 	github.com/google/uuid v1.6.0
 	github.com/grandcat/zeroconf v1.0.0
 	github.com/joho/godotenv v1.5.1
-	github.com/nats-io/nats-server/v2 v2.10.15
+	github.com/nats-io/nats-server/v2 v2.10.16
 	github.com/nats-io/nats.go v1.35.0
 	github.com/pkg/errors v0.9.1
 	github.com/prometheus/client_golang v1.19.1
@@ -24,14 +24,14 @@ require (
 	github.com/stretchr/testify v1.9.0
 	github.com/travisjeffery/go-dynaport v1.0.0
 	github.com/zeebo/xxh3 v1.0.2
-	go.opentelemetry.io/otel v1.26.0
-	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.26.0
-	go.opentelemetry.io/otel/exporters/prometheus v0.48.0
-	go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.26.0
-	go.opentelemetry.io/otel/metric v1.26.0
-	go.opentelemetry.io/otel/sdk v1.26.0
-	go.opentelemetry.io/otel/sdk/metric v1.26.0
-	go.opentelemetry.io/otel/trace v1.26.0
+	go.opentelemetry.io/otel v1.27.0
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.27.0
+	go.opentelemetry.io/otel/exporters/prometheus v0.49.0
+	go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.27.0
+	go.opentelemetry.io/otel/metric v1.27.0
+	go.opentelemetry.io/otel/sdk v1.27.0
+	go.opentelemetry.io/otel/sdk/metric v1.27.0
+	go.opentelemetry.io/otel/trace v1.27.0
 	go.uber.org/atomic v1.11.0
 	go.uber.org/goleak v1.3.0
 	go.uber.org/multierr v1.11.0
@@ -104,7 +104,7 @@ require (
 	github.com/tidwall/redcon v1.6.2 // indirect
 	github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
 	github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
-	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.26.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.27.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.2.0 // indirect
 	golang.org/x/crypto v0.23.0 // indirect
 	golang.org/x/exp v0.0.0-20240506185415-9bf2ced13842 // indirect
@@ -115,7 +115,7 @@ require (
 	golang.org/x/text v0.15.0 // indirect
 	golang.org/x/time v0.5.0 // indirect
 	golang.org/x/tools v0.21.0 // indirect
-	google.golang.org/genproto/googleapis/api v0.0.0-20240515191416-fc5f0ca64291 // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20240520151616-dc85e6b867a5 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20240515191416-fc5f0ca64291 // indirect
 	google.golang.org/grpc v1.64.0 // indirect
 	gopkg.in/inf.v0 v0.9.1 // indirect
diff --git a/go.sum b/go.sum
index 58f9faa..bff3815 100644
--- a/go.sum
+++ b/go.sum
@@ -36,8 +36,8 @@ github.com/buraksezer/consistent v0.10.0 h1:hqBgz1PvNLC5rkWcEBVAL9dFMBWz6I0VgUCW
 github.com/buraksezer/consistent v0.10.0/go.mod h1:6BrVajWq7wbKZlTOUPs/XVfR8c0maujuPowduSpZqmw=
 github.com/buraksezer/olric v0.5.6-0.20240510193155-81e12546eb39 h1:ZB2KxErCucUiYTz9gZlujrurj4WcOe+j4t1sB1okuGw=
 github.com/buraksezer/olric v0.5.6-0.20240510193155-81e12546eb39/go.mod h1:b1aCKANfqosRKIeYR5NPETD8/VnxcVdlbYGMZ97GPNA=
-github.com/caarlos0/env/v11 v11.0.0 h1:ZIlkOjuL3xoZS0kmUJlF74j2Qj8GMOq3CDLX/Viak8Q=
-github.com/caarlos0/env/v11 v11.0.0/go.mod h1:2RC3HQu8BQqtEK3V4iHPxj0jOdWdbPpWJ6pOueeU1xM=
+github.com/caarlos0/env/v11 v11.0.1 h1:A8dDt9Ub9ybqRSUF3fQc/TA/gTam2bKT4Pit+cwrsPs=
+github.com/caarlos0/env/v11 v11.0.1/go.mod h1:2RC3HQu8BQqtEK3V4iHPxj0jOdWdbPpWJ6pOueeU1xM=
 github.com/cenkalti/backoff v2.2.1+incompatible h1:tNowT99t7UNflLxfYYSlKYsBpXdEet03Pg2g16Swow4=
 github.com/cenkalti/backoff v2.2.1+incompatible/go.mod h1:90ReRw6GdpyfrHakVjL/QHaoyV4aDUVVkXQJJJ3NXXM=
 github.com/cenkalti/backoff/v4 v4.3.0 h1:MyRJ/UdXutAwSAT+s3wNd7MfTIcy71VQueUuFK343L8=
@@ -200,8 +200,8 @@ github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8m
 github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
 github.com/nats-io/jwt/v2 v2.5.7 h1:j5lH1fUXCnJnY8SsQeB/a/z9Azgu2bYIDvtPVNdxe2c=
 github.com/nats-io/jwt/v2 v2.5.7/go.mod h1:ZdWS1nZa6WMZfFwwgpEaqBV8EPGVgOTDHN/wTbz0Y5A=
-github.com/nats-io/nats-server/v2 v2.10.15 h1:O/l+ZT91ltMiiRJKjWLQJcGg7ypzjlb/bC5bFIRVw3M=
-github.com/nats-io/nats-server/v2 v2.10.15/go.mod h1:ul+pGt5I7e4U+nI09ZFDG4vqM+6Ce2Tou7UbVSnLiIw=
+github.com/nats-io/nats-server/v2 v2.10.16 h1:2jXaiydp5oB/nAx/Ytf9fdCi9QN6ItIc9eehX8kwVV0=
+github.com/nats-io/nats-server/v2 v2.10.16/go.mod h1:Pksi38H2+6xLe1vQx0/EA4bzetM0NqyIHcIbmgXSkIU=
 github.com/nats-io/nats.go v1.35.0 h1:XFNqNM7v5B+MQMKqVGAyHwYhyKb48jrenXNxIU20ULk=
 github.com/nats-io/nats.go v1.35.0/go.mod h1:Ubdu4Nh9exXdSz0RVWRFBbRfrbSxOYd26oF0wkWclB8=
 github.com/nats-io/nkeys v0.4.7 h1:RwNJbbIdYCoClSDNY7QVKZlyb/wfT6ugvFCiKy6vDvI=
@@ -246,8 +246,8 @@ github.com/redis/go-redis/v9 v9.5.1 h1:H1X4D3yHPaYrkL5X06Wh6xNVM/pX0Ft4RV0vMGvLB
 github.com/redis/go-redis/v9 v9.5.1/go.mod h1:hdY0cQFCN4fnSYT6TkisLufl/4W5UIXyv0b/CLO2V2M=
 github.com/reugn/go-quartz v0.12.0 h1:RsrklW++R5Swc7mCPYseXM06PTWN4N7/f1rsYkhHiww=
 github.com/reugn/go-quartz v0.12.0/go.mod h1:no4ktgYbAAuY0E1SchR8cTx1LF4jYIzdgaQhzRPSkpk=
-github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDNXVBh4M=
-github.com/rogpeppe/go-internal v1.11.0/go.mod h1:ddIwULY96R17DhadqLgMfk9H9tvdUzkipdSkR5nkCZA=
+github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU5NdKM8=
+github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4=
 github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
 github.com/ryanuber/columnize v2.1.2+incompatible/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
 github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529 h1:nn5Wsu0esKSJiIVhscUtVbo7ada43DJhG55ua/hjS5I=
@@ -298,24 +298,24 @@ github.com/zeebo/assert v1.3.0 h1:g7C04CbJuIDKNPFHmsk4hwZDO5O+kntRxzaUoNXj+IQ=
 github.com/zeebo/assert v1.3.0/go.mod h1:Pq9JiuJQpG8JLJdtkwrJESF0Foym2/D9XMU5ciN/wJ0=
 github.com/zeebo/xxh3 v1.0.2 h1:xZmwmqxHZA8AI603jOQ0tMqmBr9lPeFwGg6d+xy9DC0=
 github.com/zeebo/xxh3 v1.0.2/go.mod h1:5NWz9Sef7zIDm2JHfFlcQvNekmcEl9ekUZQQKCYaDcA=
-go.opentelemetry.io/otel v1.26.0 h1:LQwgL5s/1W7YiiRwxf03QGnWLb2HW4pLiAhaA5cZXBs=
-go.opentelemetry.io/otel v1.26.0/go.mod h1:UmLkJHUAidDval2EICqBMbnAd0/m2vmpf/dAM+fvFs4=
-go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.26.0 h1:1u/AyyOqAWzy+SkPxDpahCNZParHV8Vid1RnI2clyDE=
-go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.26.0/go.mod h1:z46paqbJ9l7c9fIPCXTqTGwhQZ5XoTIsfeFYWboizjs=
-go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.26.0 h1:Waw9Wfpo/IXzOI8bCB7DIk+0JZcqqsyn1JFnAc+iam8=
-go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.26.0/go.mod h1:wnJIG4fOqyynOnnQF/eQb4/16VlX2EJAHhHgqIqWfAo=
-go.opentelemetry.io/otel/exporters/prometheus v0.48.0 h1:sBQe3VNGUjY9IKWQC6z2lNqa5iGbDSxhs60ABwK4y0s=
-go.opentelemetry.io/otel/exporters/prometheus v0.48.0/go.mod h1:DtrbMzoZWwQHyrQmCfLam5DZbnmorsGbOtTbYHycU5o=
-go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.26.0 h1:0W5o9SzoR15ocYHEQfvfipzcNog1lBxOLfnex91Hk6s=
-go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.26.0/go.mod h1:zVZ8nz+VSggWmnh6tTsJqXQ7rU4xLwRtna1M4x5jq58=
-go.opentelemetry.io/otel/metric v1.26.0 h1:7S39CLuY5Jgg9CrnA9HHiEjGMF/X2VHvoXGgSllRz30=
-go.opentelemetry.io/otel/metric v1.26.0/go.mod h1:SY+rHOI4cEawI9a7N1A4nIg/nTQXe1ccCNWYOJUrpX4=
-go.opentelemetry.io/otel/sdk v1.26.0 h1:Y7bumHf5tAiDlRYFmGqetNcLaVUZmh4iYfmGxtmz7F8=
-go.opentelemetry.io/otel/sdk v1.26.0/go.mod h1:0p8MXpqLeJ0pzcszQQN4F0S5FVjBLgypeGSngLsmirs=
-go.opentelemetry.io/otel/sdk/metric v1.26.0 h1:cWSks5tfriHPdWFnl+qpX3P681aAYqlZHcAyHw5aU9Y=
-go.opentelemetry.io/otel/sdk/metric v1.26.0/go.mod h1:ClMFFknnThJCksebJwz7KIyEDHO+nTB6gK8obLy8RyE=
-go.opentelemetry.io/otel/trace v1.26.0 h1:1ieeAUb4y0TE26jUFrCIXKpTuVK7uJGN9/Z/2LP5sQA=
-go.opentelemetry.io/otel/trace v1.26.0/go.mod h1:4iDxvGDQuUkHve82hJJ8UqrwswHYsZuWCBllGV2U2y0=
+go.opentelemetry.io/otel v1.27.0 h1:9BZoF3yMK/O1AafMiQTVu0YDj5Ea4hPhxCs7sGva+cg=
+go.opentelemetry.io/otel v1.27.0/go.mod h1:DMpAK8fzYRzs+bi3rS5REupisuqTheUlSZJ1WnZaPAQ=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.27.0 h1:R9DE4kQ4k+YtfLI2ULwX82VtNQ2J8yZmA7ZIF/D+7Mc=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.27.0/go.mod h1:OQFyQVrDlbe+R7xrEyDr/2Wr67Ol0hRUgsfA+V5A95s=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.27.0 h1:qFffATk0X+HD+f1Z8lswGiOQYKHRlzfmdJm0wEaVrFA=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.27.0/go.mod h1:MOiCmryaYtc+V0Ei+Tx9o5S1ZjA7kzLucuVuyzBZloQ=
+go.opentelemetry.io/otel/exporters/prometheus v0.49.0 h1:Er5I1g/YhfYv9Affk9nJLfH/+qCCVVg1f2R9AbJfqDQ=
+go.opentelemetry.io/otel/exporters/prometheus v0.49.0/go.mod h1:KfQ1wpjf3zsHjzP149P4LyAwWRupc6c7t1ZJ9eXpKQM=
+go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.27.0 h1:/0YaXu3755A/cFbtXp+21lkXgI0QE5avTWA2HjU9/WE=
+go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.27.0/go.mod h1:m7SFxp0/7IxmJPLIY3JhOcU9CoFzDaCPL6xxQIxhA+o=
+go.opentelemetry.io/otel/metric v1.27.0 h1:hvj3vdEKyeCi4YaYfNjv2NUje8FqKqUY8IlF0FxV/ik=
+go.opentelemetry.io/otel/metric v1.27.0/go.mod h1:mVFgmRlhljgBiuk/MP/oKylr4hs85GZAylncepAX/ak=
+go.opentelemetry.io/otel/sdk v1.27.0 h1:mlk+/Y1gLPLn84U4tI8d3GNJmGT/eXe3ZuOXN9kTWmI=
+go.opentelemetry.io/otel/sdk v1.27.0/go.mod h1:Ha9vbLwJE6W86YstIywK2xFfPjbWlCuwPtMkKdz/Y4A=
+go.opentelemetry.io/otel/sdk/metric v1.27.0 h1:5uGNOlpXi+Hbo/DRoI31BSb1v+OGcpv2NemcCrOL8gI=
+go.opentelemetry.io/otel/sdk/metric v1.27.0/go.mod h1:we7jJVrYN2kh3mVBlswtPU22K0SA+769l93J6bsyvqw=
+go.opentelemetry.io/otel/trace v1.27.0 h1:IqYb813p7cmbHk0a5y6pD5JPakbVfftRXABGt5/Rscw=
+go.opentelemetry.io/otel/trace v1.27.0/go.mod h1:6RiD1hkAprV4/q+yd2ln1HG9GoPx39SuvvstaLBl+l4=
 go.opentelemetry.io/proto/otlp v1.2.0 h1:pVeZGk7nXDC9O2hncA6nHldxEjm6LByfA2aN8IOkz94=
 go.opentelemetry.io/proto/otlp v1.2.0/go.mod h1:gGpR8txAl5M03pDhMC79G6SdqNV26naRm/KDsgaHD8A=
 go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=
@@ -409,8 +409,8 @@ golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8T
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/genproto/googleapis/api v0.0.0-20240515191416-fc5f0ca64291 h1:4HZJ3Xv1cmrJ+0aFo304Zn79ur1HMxptAE7aCPNLSqc=
-google.golang.org/genproto/googleapis/api v0.0.0-20240515191416-fc5f0ca64291/go.mod h1:RGnPtTG7r4i8sPlNyDeikXF99hMM+hN6QMm4ooG9g2g=
+google.golang.org/genproto/googleapis/api v0.0.0-20240520151616-dc85e6b867a5 h1:P8OJ/WCl/Xo4E4zoe4/bifHpSmmKwARqyqE4nW6J2GQ=
+google.golang.org/genproto/googleapis/api v0.0.0-20240520151616-dc85e6b867a5/go.mod h1:RGnPtTG7r4i8sPlNyDeikXF99hMM+hN6QMm4ooG9g2g=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20240515191416-fc5f0ca64291 h1:AgADTJarZTBqgjiUzRgfaBchgYB3/WFTC80GPwsMcRI=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20240515191416-fc5f0ca64291/go.mod h1:EfXuqaE1J41VCDicxHzUDm+8rk+7ZdXzHV0IhO/I6s0=
 google.golang.org/grpc v1.64.0 h1:KH3VH9y/MgNQg1dE7b3XfVK0GsPSIzJwdF617gUSbvY=
diff --git a/goaktpb/goakt.pb.go b/goaktpb/goakt.pb.go
index abd6b24..72071fc 100644
--- a/goaktpb/goakt.pb.go
+++ b/goaktpb/goakt.pb.go
@@ -843,15 +843,15 @@ var file_goakt_goakt_proto_rawDesc = []byte{
 	0x65, 0x72, 0x6d, 0x69, 0x6e, 0x61, 0x74, 0x65, 0x64, 0x22, 0x0c, 0x0a, 0x0a, 0x50, 0x6f, 0x69,
 	0x73, 0x6f, 0x6e, 0x50, 0x69, 0x6c, 0x6c, 0x22, 0x0b, 0x0a, 0x09, 0x50, 0x6f, 0x73, 0x74, 0x53,
 	0x74, 0x61, 0x72, 0x74, 0x22, 0x0a, 0x0a, 0x08, 0x50, 0x72, 0x65, 0x53, 0x74, 0x61, 0x72, 0x74,
-	0x42, 0x82, 0x01, 0x0a, 0x0b, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62,
+	0x42, 0x85, 0x01, 0x0a, 0x0b, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62,
 	0x42, 0x0a, 0x47, 0x6f, 0x61, 0x6b, 0x74, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01,
-	0x5a, 0x29, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63,
-	0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x67, 0x6f, 0x61, 0x6b,
-	0x74, 0x70, 0x62, 0x3b, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x47, 0x58,
-	0x58, 0xaa, 0x02, 0x07, 0x47, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0xca, 0x02, 0x07, 0x47, 0x6f,
-	0x61, 0x6b, 0x74, 0x70, 0x62, 0xe2, 0x02, 0x13, 0x47, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0x5c,
-	0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x07, 0x47, 0x6f,
-	0x61, 0x6b, 0x74, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x5a, 0x2c, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63,
+	0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x76, 0x32, 0x2f, 0x67,
+	0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0x3b, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0xa2, 0x02,
+	0x03, 0x47, 0x58, 0x58, 0xaa, 0x02, 0x07, 0x47, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0xca, 0x02,
+	0x07, 0x47, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0xe2, 0x02, 0x13, 0x47, 0x6f, 0x61, 0x6b, 0x74,
+	0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02,
+	0x07, 0x47, 0x6f, 0x61, 0x6b, 0x74, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
diff --git a/internal/cluster/codec.go b/internal/cluster/codec.go
index c1cf613..ca7b959 100644
--- a/internal/cluster/codec.go
+++ b/internal/cluster/codec.go
@@ -27,7 +27,7 @@ package cluster
 import (
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/internal/internalpb"
+	"github.com/tochemey/goakt/v2/internal/internalpb"
 )
 
 // encode marshals a wire actor into a byte array
diff --git a/internal/cluster/discovery.go b/internal/cluster/discovery.go
index ac221de..960dac5 100644
--- a/internal/cluster/discovery.go
+++ b/internal/cluster/discovery.go
@@ -31,7 +31,7 @@ import (
 	"github.com/buraksezer/olric/pkg/service_discovery"
 	"github.com/pkg/errors"
 
-	"github.com/tochemey/goakt/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
 )
 
 // discoveryProvider wraps the Cluster engine discovery and implements
diff --git a/internal/cluster/engine.go b/internal/cluster/engine.go
index a6c14b4..e9e8069 100644
--- a/internal/cluster/engine.go
+++ b/internal/cluster/engine.go
@@ -39,12 +39,12 @@ import (
 	"google.golang.org/protobuf/types/known/anypb"
 	"google.golang.org/protobuf/types/known/timestamppb"
 
-	"github.com/tochemey/goakt/discovery"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/hash"
-	"github.com/tochemey/goakt/internal/internalpb"
-	"github.com/tochemey/goakt/internal/types"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/discovery"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/hash"
+	"github.com/tochemey/goakt/v2/internal/internalpb"
+	"github.com/tochemey/goakt/v2/internal/types"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 type EventType int
diff --git a/internal/cluster/hasher.go b/internal/cluster/hasher.go
index a25dc23..9041e52 100644
--- a/internal/cluster/hasher.go
+++ b/internal/cluster/hasher.go
@@ -27,7 +27,7 @@ package cluster
 import (
 	"github.com/buraksezer/olric/hasher"
 
-	"github.com/tochemey/goakt/hash"
+	"github.com/tochemey/goakt/v2/hash"
 )
 
 type hasherWrapper struct {
diff --git a/internal/cluster/logwriter.go b/internal/cluster/logwriter.go
index 2ccd411..15306f8 100644
--- a/internal/cluster/logwriter.go
+++ b/internal/cluster/logwriter.go
@@ -29,7 +29,7 @@ import (
 	"io"
 	"regexp"
 
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 // logWriter is a wrapper for the olric logging
diff --git a/internal/cluster/option.go b/internal/cluster/option.go
index f1f4fe0..de12d99 100644
--- a/internal/cluster/option.go
+++ b/internal/cluster/option.go
@@ -27,8 +27,8 @@ package cluster
 import (
 	"time"
 
-	"github.com/tochemey/goakt/hash"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/hash"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 // Option is the interface that applies a configuration option.
diff --git a/internal/eventstream/subscriber.go b/internal/eventstream/subscriber.go
index a4780ff..27258a2 100644
--- a/internal/eventstream/subscriber.go
+++ b/internal/eventstream/subscriber.go
@@ -29,7 +29,7 @@ import (
 
 	"github.com/google/uuid"
 
-	"github.com/tochemey/goakt/internal/queue"
+	"github.com/tochemey/goakt/v2/internal/queue"
 )
 
 // Subscriber defines the Subscriber Interface
diff --git a/internal/internalpb/internalpbconnect/remoting.connect.go b/internal/internalpb/internalpbconnect/remoting.connect.go
index 90dbc28..9af135a 100644
--- a/internal/internalpb/internalpbconnect/remoting.connect.go
+++ b/internal/internalpb/internalpbconnect/remoting.connect.go
@@ -8,7 +8,7 @@ import (
 	connect "connectrpc.com/connect"
 	context "context"
 	errors "errors"
-	internalpb "github.com/tochemey/goakt/internal/internalpb"
+	internalpb "github.com/tochemey/goakt/v2/internal/internalpb"
 	http "net/http"
 	strings "strings"
 )
diff --git a/internal/internalpb/nats.pb.go b/internal/internalpb/nats.pb.go
index cd18df9..85b212b 100644
--- a/internal/internalpb/nats.pb.go
+++ b/internal/internalpb/nats.pb.go
@@ -173,17 +173,17 @@ var file_internal_nats_proto_rawDesc = []byte{
 	0x41, 0x47, 0x45, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x52, 0x45, 0x51, 0x55, 0x45, 0x53, 0x54,
 	0x10, 0x02, 0x12, 0x1e, 0x0a, 0x1a, 0x4e, 0x41, 0x54, 0x53, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41,
 	0x47, 0x45, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x52, 0x45, 0x53, 0x50, 0x4f, 0x4e, 0x53, 0x45,
-	0x10, 0x03, 0x42, 0x9f, 0x01, 0x0a, 0x0e, 0x63, 0x6f, 0x6d, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72,
+	0x10, 0x03, 0x42, 0xa2, 0x01, 0x0a, 0x0e, 0x63, 0x6f, 0x6d, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72,
 	0x6e, 0x61, 0x6c, 0x70, 0x62, 0x42, 0x09, 0x4e, 0x61, 0x74, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f,
-	0x48, 0x02, 0x50, 0x01, 0x5a, 0x38, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d,
+	0x48, 0x02, 0x50, 0x01, 0x5a, 0x3b, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d,
 	0x2f, 0x74, 0x6f, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f,
-	0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61,
-	0x6c, 0x70, 0x62, 0x3b, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xa2, 0x02,
-	0x03, 0x49, 0x58, 0x58, 0xaa, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70,
-	0x62, 0xca, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xe2, 0x02,
-	0x16, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d,
-	0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e,
-	0x61, 0x6c, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x76, 0x32, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x69, 0x6e, 0x74, 0x65,
+	0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x3b, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70,
+	0x62, 0xa2, 0x02, 0x03, 0x49, 0x58, 0x58, 0xaa, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e,
+	0x61, 0x6c, 0x70, 0x62, 0xca, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70,
+	0x62, 0xe2, 0x02, 0x16, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x5c, 0x47,
+	0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x49, 0x6e, 0x74,
+	0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
diff --git a/internal/internalpb/remoting.pb.go b/internal/internalpb/remoting.pb.go
index c4908dc..b1a3c14 100644
--- a/internal/internalpb/remoting.pb.go
+++ b/internal/internalpb/remoting.pb.go
@@ -7,7 +7,7 @@
 package internalpb
 
 import (
-	goaktpb "github.com/tochemey/goakt/goaktpb"
+	goaktpb "github.com/tochemey/goakt/v2/goaktpb"
 	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	anypb "google.golang.org/protobuf/types/known/anypb"
@@ -809,18 +809,18 @@ var file_internal_remoting_proto_rawDesc = []byte{
 	0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x53, 0x70, 0x61,
 	0x77, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x69, 0x6e, 0x74, 0x65,
 	0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x53, 0x70, 0x61,
-	0x77, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0xa3, 0x01, 0x0a, 0x0e, 0x63,
+	0x77, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0xa6, 0x01, 0x0a, 0x0e, 0x63,
 	0x6f, 0x6d, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x42, 0x0d, 0x52,
 	0x65, 0x6d, 0x6f, 0x74, 0x69, 0x6e, 0x67, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01,
-	0x5a, 0x38, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63,
-	0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x69, 0x6e, 0x74, 0x65,
-	0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x3b,
-	0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x49, 0x58, 0x58,
-	0xaa, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xca, 0x02, 0x0a,
-	0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xe2, 0x02, 0x16, 0x49, 0x6e, 0x74,
-	0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64,
-	0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62,
-	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x5a, 0x3b, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63,
+	0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x76, 0x32, 0x2f, 0x69,
+	0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
+	0x70, 0x62, 0x3b, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xa2, 0x02, 0x03,
+	0x49, 0x58, 0x58, 0xaa, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62,
+	0xca, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xe2, 0x02, 0x16,
+	0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65,
+	0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61,
+	0x6c, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
diff --git a/internal/internalpb/wireactor.pb.go b/internal/internalpb/wireactor.pb.go
index 45fb91b..8254603 100644
--- a/internal/internalpb/wireactor.pb.go
+++ b/internal/internalpb/wireactor.pb.go
@@ -7,7 +7,7 @@
 package internalpb
 
 import (
-	goaktpb "github.com/tochemey/goakt/goaktpb"
+	goaktpb "github.com/tochemey/goakt/v2/goaktpb"
 	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
 	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
 	reflect "reflect"
@@ -114,18 +114,18 @@ var file_internal_wireactor_proto_rawDesc = []byte{
 	0x0a, 0x61, 0x63, 0x74, 0x6f, 0x72, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x03, 0x20, 0x01, 0x28,
 	0x09, 0x52, 0x09, 0x61, 0x63, 0x74, 0x6f, 0x72, 0x50, 0x61, 0x74, 0x68, 0x12, 0x1d, 0x0a, 0x0a,
 	0x61, 0x63, 0x74, 0x6f, 0x72, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09,
-	0x52, 0x09, 0x61, 0x63, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x42, 0xa4, 0x01, 0x0a, 0x0e,
+	0x52, 0x09, 0x61, 0x63, 0x74, 0x6f, 0x72, 0x54, 0x79, 0x70, 0x65, 0x42, 0xa7, 0x01, 0x0a, 0x0e,
 	0x63, 0x6f, 0x6d, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x42, 0x0e,
 	0x57, 0x69, 0x72, 0x65, 0x61, 0x63, 0x74, 0x6f, 0x72, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02,
-	0x50, 0x01, 0x5a, 0x38, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74,
-	0x6f, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x69, 0x6e,
-	0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70,
-	0x62, 0x3b, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x49,
-	0x58, 0x58, 0xaa, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xca,
-	0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xe2, 0x02, 0x16, 0x49,
-	0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74,
-	0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
-	0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x50, 0x01, 0x5a, 0x3b, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74,
+	0x6f, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x76, 0x32,
+	0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e,
+	0x61, 0x6c, 0x70, 0x62, 0x3b, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xa2,
+	0x02, 0x03, 0x49, 0x58, 0x58, 0xaa, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
+	0x70, 0x62, 0xca, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0xe2,
+	0x02, 0x16, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42,
+	0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x0a, 0x49, 0x6e, 0x74, 0x65, 0x72,
+	0x6e, 0x61, 0x6c, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
diff --git a/mocks/cluster/interface.go b/mocks/cluster/interface.go
index e1c2d38..267b0d1 100644
--- a/mocks/cluster/interface.go
+++ b/mocks/cluster/interface.go
@@ -5,8 +5,8 @@ package cluster
 import (
 	context "context"
 
-	internalcluster "github.com/tochemey/goakt/internal/cluster"
-	internalpb "github.com/tochemey/goakt/internal/internalpb"
+	internalcluster "github.com/tochemey/goakt/v2/internal/cluster"
+	internalpb "github.com/tochemey/goakt/v2/internal/internalpb"
 
 	mock "github.com/stretchr/testify/mock"
 )
diff --git a/mocks/cluster/option.go b/mocks/cluster/option.go
index 18b8e36..4ed9a53 100644
--- a/mocks/cluster/option.go
+++ b/mocks/cluster/option.go
@@ -4,7 +4,7 @@ package cluster
 
 import (
 	mock "github.com/stretchr/testify/mock"
-	internalcluster "github.com/tochemey/goakt/internal/cluster"
+	internalcluster "github.com/tochemey/goakt/v2/internal/cluster"
 )
 
 // Option is an autogenerated mock type for the Option type
diff --git a/mocks/cluster/option_func.go b/mocks/cluster/option_func.go
index a028f2b..718497d 100644
--- a/mocks/cluster/option_func.go
+++ b/mocks/cluster/option_func.go
@@ -4,7 +4,7 @@ package cluster
 
 import (
 	mock "github.com/stretchr/testify/mock"
-	internalcluster "github.com/tochemey/goakt/internal/cluster"
+	internalcluster "github.com/tochemey/goakt/v2/internal/cluster"
 )
 
 // OptionFunc is an autogenerated mock type for the OptionFunc type
diff --git a/mocks/discovery/nats/option.go b/mocks/discovery/nats/option.go
index c9dfd87..234d638 100644
--- a/mocks/discovery/nats/option.go
+++ b/mocks/discovery/nats/option.go
@@ -4,7 +4,7 @@ package nats
 
 import (
 	mock "github.com/stretchr/testify/mock"
-	discoverynats "github.com/tochemey/goakt/discovery/nats"
+	discoverynats "github.com/tochemey/goakt/v2/discovery/nats"
 )
 
 // Option is an autogenerated mock type for the Option type
diff --git a/mocks/discovery/nats/option_func.go b/mocks/discovery/nats/option_func.go
index 6325a7d..fa5bc42 100644
--- a/mocks/discovery/nats/option_func.go
+++ b/mocks/discovery/nats/option_func.go
@@ -4,7 +4,7 @@ package nats
 
 import (
 	mock "github.com/stretchr/testify/mock"
-	discoverynats "github.com/tochemey/goakt/discovery/nats"
+	discoverynats "github.com/tochemey/goakt/v2/discovery/nats"
 )
 
 // OptionFunc is an autogenerated mock type for the OptionFunc type
diff --git a/protos/goakt/goakt.proto b/protos/goakt/goakt.proto
index 7cd26b6..0841963 100644
--- a/protos/goakt/goakt.proto
+++ b/protos/goakt/goakt.proto
@@ -5,7 +5,7 @@ package goaktpb;
 import "google/protobuf/any.proto";
 import "google/protobuf/timestamp.proto";
 
-option go_package = "github.com/tochemey/goakt/goaktpb;goaktpb";
+option go_package = "github.com/tochemey/goakt/v2/goaktpb;goaktpb";
 
 // Address represents an actor address
 message Address {
diff --git a/protos/internal/nats.proto b/protos/internal/nats.proto
index afdb138..7b19543 100644
--- a/protos/internal/nats.proto
+++ b/protos/internal/nats.proto
@@ -2,7 +2,7 @@ syntax = "proto3";
 
 package internalpb;
 
-option go_package = "github.com/tochemey/goakt/internal/internalpb;internalpb";
+option go_package = "github.com/tochemey/goakt/v2/internal/internalpb;internalpb";
 
 // NatsMessageType defines the NATs message type
 enum NatsMessageType {
diff --git a/protos/internal/remoting.proto b/protos/internal/remoting.proto
index d4e161e..83f1036 100644
--- a/protos/internal/remoting.proto
+++ b/protos/internal/remoting.proto
@@ -5,7 +5,7 @@ package internalpb;
 import "goakt/goakt.proto";
 import "google/protobuf/any.proto";
 
-option go_package = "github.com/tochemey/goakt/internal/internalpb;internalpb";
+option go_package = "github.com/tochemey/goakt/v2/internal/internalpb;internalpb";
 
 // RemotingService defines the remoting service
 // With remoting one can:
diff --git a/protos/internal/wireactor.proto b/protos/internal/wireactor.proto
index 441ce99..6fe1192 100644
--- a/protos/internal/wireactor.proto
+++ b/protos/internal/wireactor.proto
@@ -4,7 +4,7 @@ package internalpb;
 
 import "goakt/goakt.proto";
 
-option go_package = "github.com/tochemey/goakt/internal/internalpb;internalpb";
+option go_package = "github.com/tochemey/goakt/v2/internal/internalpb;internalpb";
 
 // WireActor represents the actor information on the wire.
 message WireActor {
diff --git a/protos/sample/sample.proto b/protos/sample/sample.proto
index 0509922..7021022 100644
--- a/protos/sample/sample.proto
+++ b/protos/sample/sample.proto
@@ -2,7 +2,7 @@ syntax = "proto3";
 
 package samplepb;
 
-option go_package = "github.com/tochemey/goakt/examples/protos/samplepb;samplepb";
+option go_package = "github.com/tochemey/goakt/v2/examples/protos/samplepb;samplepb";
 
 message Ping {
   string id = 1;
diff --git a/protos/sample/service.proto b/protos/sample/service.proto
index 02db3a8..0be88fc 100644
--- a/protos/sample/service.proto
+++ b/protos/sample/service.proto
@@ -4,7 +4,7 @@ package samplepb;
 
 import "sample/sample.proto";
 
-option go_package = "github.com/tochemey/goakt/examples/protos/samplepb;samplepb";
+option go_package = "github.com/tochemey/goakt/v2/examples/protos/samplepb;samplepb";
 
 service AccountService {
   rpc CreateAccount(CreateAccountRequest) returns (CreateAccountResponse);


Test patch:
diff --git a/actors/actor_system_test.go b/actors/actor_system_test.go
index 30769e3..016f2f0 100644
--- a/actors/actor_system_test.go
+++ b/actors/actor_system_test.go
@@ -45,12 +45,12 @@ import (
 	"go.uber.org/atomic"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
-	clustermocks "github.com/tochemey/goakt/mocks/cluster"
-	testkit "github.com/tochemey/goakt/mocks/discovery"
-	"github.com/tochemey/goakt/telemetry"
-	testpb "github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
+	clustermocks "github.com/tochemey/goakt/v2/mocks/cluster"
+	testkit "github.com/tochemey/goakt/v2/mocks/discovery"
+	"github.com/tochemey/goakt/v2/telemetry"
+	testpb "github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 func TestActorSystem(t *testing.T) {
diff --git a/actors/actor_test.go b/actors/actor_test.go
index 1d1362a..98c7af1 100644
--- a/actors/actor_test.go
+++ b/actors/actor_test.go
@@ -38,11 +38,11 @@ import (
 	"go.uber.org/atomic"
 	"go.uber.org/goleak"
 
-	"github.com/tochemey/goakt/discovery"
-	"github.com/tochemey/goakt/discovery/nats"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
-	testspb "github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/discovery"
+	"github.com/tochemey/goakt/v2/discovery/nats"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
+	testspb "github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 func TestMain(m *testing.M) {
diff --git a/actors/api_test.go b/actors/api_test.go
index 3ad9dec..9719708 100644
--- a/actors/api_test.go
+++ b/actors/api_test.go
@@ -37,10 +37,10 @@ import (
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/anypb"
 
-	"github.com/tochemey/goakt/goaktpb"
-	internalpb "github.com/tochemey/goakt/internal/internalpb"
-	"github.com/tochemey/goakt/log"
-	testpb "github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	internalpb "github.com/tochemey/goakt/v2/internal/internalpb"
+	"github.com/tochemey/goakt/v2/log"
+	testpb "github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 func TestAsk(t *testing.T) {
diff --git a/actors/context_test.go b/actors/context_test.go
index 846da34..5fadfc9 100644
--- a/actors/context_test.go
+++ b/actors/context_test.go
@@ -37,10 +37,10 @@ import (
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/anypb"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/internal/eventstream"
-	"github.com/tochemey/goakt/log"
-	testpb "github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/internal/eventstream"
+	"github.com/tochemey/goakt/v2/log"
+	testpb "github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 func TestReceiveContext(t *testing.T) {
diff --git a/actors/option_test.go b/actors/option_test.go
index 109b8a7..3485bcf 100644
--- a/actors/option_test.go
+++ b/actors/option_test.go
@@ -31,9 +31,9 @@ import (
 	"github.com/stretchr/testify/assert"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/hash"
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/telemetry"
+	"github.com/tochemey/goakt/v2/hash"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/telemetry"
 )
 
 func TestOption(t *testing.T) {
diff --git a/actors/path_test.go b/actors/path_test.go
index 2719028..af8d3c0 100644
--- a/actors/path_test.go
+++ b/actors/path_test.go
@@ -32,7 +32,7 @@ import (
 	"github.com/stretchr/testify/assert"
 	"google.golang.org/protobuf/encoding/prototext"
 
-	"github.com/tochemey/goakt/goaktpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
 )
 
 func TestPath(t *testing.T) {
diff --git a/actors/pid_option_test.go b/actors/pid_option_test.go
index 5aae9c7..c7c43f8 100644
--- a/actors/pid_option_test.go
+++ b/actors/pid_option_test.go
@@ -31,8 +31,8 @@ import (
 	"github.com/stretchr/testify/assert"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/internal/eventstream"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/internal/eventstream"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 func TestPIDOptions(t *testing.T) {
diff --git a/actors/pid_test.go b/actors/pid_test.go
index 763659c..784070c 100644
--- a/actors/pid_test.go
+++ b/actors/pid_test.go
@@ -41,10 +41,10 @@ import (
 	"go.opentelemetry.io/otel/trace/noop"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/telemetry"
-	"github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/telemetry"
+	"github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 const (
diff --git a/actors/reflection_test.go b/actors/reflection_test.go
index 62251c9..f076703 100644
--- a/actors/reflection_test.go
+++ b/actors/reflection_test.go
@@ -29,8 +29,8 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/internal/types"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/internal/types"
 )
 
 func TestReflection(t *testing.T) {
diff --git a/actors/scheduler_test.go b/actors/scheduler_test.go
index 1275ee7..3d3e9b5 100644
--- a/actors/scheduler_test.go
+++ b/actors/scheduler_test.go
@@ -34,8 +34,8 @@ import (
 	"github.com/stretchr/testify/require"
 	"github.com/travisjeffery/go-dynaport"
 
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 func TestScheduler(t *testing.T) {
diff --git a/actors/stash_test.go b/actors/stash_test.go
index 462ef1c..a1c374c 100644
--- a/actors/stash_test.go
+++ b/actors/stash_test.go
@@ -32,8 +32,8 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"github.com/tochemey/goakt/log"
-	"github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/log"
+	"github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 func TestStash(t *testing.T) {
diff --git a/bench/bench_test.go b/bench/bench_test.go
index b2edf2b..8a8cf02 100644
--- a/bench/bench_test.go
+++ b/bench/bench_test.go
@@ -29,9 +29,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/tochemey/goakt/actors"
-	"github.com/tochemey/goakt/log"
-	testspb "github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/actors"
+	"github.com/tochemey/goakt/v2/log"
+	testspb "github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 const (
diff --git a/discovery/dnssd/discovery_test.go b/discovery/dnssd/discovery_test.go
index 6462ec3..6bd5f72 100644
--- a/discovery/dnssd/discovery_test.go
+++ b/discovery/dnssd/discovery_test.go
@@ -34,7 +34,7 @@ import (
 	"github.com/stretchr/testify/require"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
 )
 
 func TestDiscovery(t *testing.T) {
diff --git a/discovery/kubernetes/discovery_test.go b/discovery/kubernetes/discovery_test.go
index 53e37b4..1304cab 100644
--- a/discovery/kubernetes/discovery_test.go
+++ b/discovery/kubernetes/discovery_test.go
@@ -36,7 +36,7 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 	testclient "k8s.io/client-go/kubernetes/fake"
 
-	"github.com/tochemey/goakt/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
 )
 
 const (
diff --git a/discovery/mdns/discovery_test.go b/discovery/mdns/discovery_test.go
index 847470d..e449094 100644
--- a/discovery/mdns/discovery_test.go
+++ b/discovery/mdns/discovery_test.go
@@ -33,7 +33,7 @@ import (
 	"github.com/travisjeffery/go-dynaport"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
 )
 
 func TestDiscovery(t *testing.T) {
diff --git a/discovery/nats/discovery_test.go b/discovery/nats/discovery_test.go
index cb137d0..f03d0a7 100644
--- a/discovery/nats/discovery_test.go
+++ b/discovery/nats/discovery_test.go
@@ -34,8 +34,8 @@ import (
 	"github.com/travisjeffery/go-dynaport"
 	"go.uber.org/atomic"
 
-	"github.com/tochemey/goakt/discovery"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/discovery"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 func startNatsServer(t *testing.T) *natsserver.Server {
diff --git a/discovery/nats/option_test.go b/discovery/nats/option_test.go
index 4f7a9ca..1418c5b 100644
--- a/discovery/nats/option_test.go
+++ b/discovery/nats/option_test.go
@@ -29,7 +29,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 func TestOptions(t *testing.T) {
diff --git a/internal/cluster/codec_test.go b/internal/cluster/codec_test.go
index 7d6ec4e..a550c2e 100644
--- a/internal/cluster/codec_test.go
+++ b/internal/cluster/codec_test.go
@@ -32,8 +32,8 @@ import (
 	"github.com/stretchr/testify/require"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/internal/internalpb"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/internal/internalpb"
 )
 
 func TestCodec(t *testing.T) {
diff --git a/internal/cluster/discovery_test.go b/internal/cluster/discovery_test.go
index 26c0a71..58e8ecc 100644
--- a/internal/cluster/discovery_test.go
+++ b/internal/cluster/discovery_test.go
@@ -32,9 +32,9 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/travisjeffery/go-dynaport"
 
-	"github.com/tochemey/goakt/discovery"
-	"github.com/tochemey/goakt/log"
-	testkit "github.com/tochemey/goakt/mocks/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
+	"github.com/tochemey/goakt/v2/log"
+	testkit "github.com/tochemey/goakt/v2/mocks/discovery"
 )
 
 func TestDiscoveryProvider(t *testing.T) {
diff --git a/internal/cluster/engine_test.go b/internal/cluster/engine_test.go
index 578fa27..6d2925e 100644
--- a/internal/cluster/engine_test.go
+++ b/internal/cluster/engine_test.go
@@ -38,12 +38,12 @@ import (
 	"github.com/travisjeffery/go-dynaport"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/tochemey/goakt/discovery"
-	"github.com/tochemey/goakt/discovery/nats"
-	"github.com/tochemey/goakt/goaktpb"
-	"github.com/tochemey/goakt/internal/internalpb"
-	"github.com/tochemey/goakt/log"
-	testkit "github.com/tochemey/goakt/mocks/discovery"
+	"github.com/tochemey/goakt/v2/discovery"
+	"github.com/tochemey/goakt/v2/discovery/nats"
+	"github.com/tochemey/goakt/v2/goaktpb"
+	"github.com/tochemey/goakt/v2/internal/internalpb"
+	"github.com/tochemey/goakt/v2/log"
+	testkit "github.com/tochemey/goakt/v2/mocks/discovery"
 )
 
 func TestSingleNode(t *testing.T) {
diff --git a/internal/cluster/hasher_test.go b/internal/cluster/hasher_test.go
index 474eb8f..870d96d 100644
--- a/internal/cluster/hasher_test.go
+++ b/internal/cluster/hasher_test.go
@@ -29,7 +29,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	testkit "github.com/tochemey/goakt/mocks/hash"
+	testkit "github.com/tochemey/goakt/v2/mocks/hash"
 )
 
 func TestHasher(t *testing.T) {
diff --git a/internal/cluster/logwriter_test.go b/internal/cluster/logwriter_test.go
index c4990d2..d78bd2d 100644
--- a/internal/cluster/logwriter_test.go
+++ b/internal/cluster/logwriter_test.go
@@ -32,7 +32,7 @@ import (
 
 	"github.com/stretchr/testify/require"
 
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 func TestLogWriter(t *testing.T) {
diff --git a/internal/cluster/option_test.go b/internal/cluster/option_test.go
index cae1569..bcee5ab 100644
--- a/internal/cluster/option_test.go
+++ b/internal/cluster/option_test.go
@@ -30,8 +30,8 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	"github.com/tochemey/goakt/log"
-	testkit "github.com/tochemey/goakt/mocks/hash"
+	"github.com/tochemey/goakt/v2/log"
+	testkit "github.com/tochemey/goakt/v2/mocks/hash"
 )
 
 func TestOptions(t *testing.T) {
diff --git a/protos/test/test.proto b/protos/test/test.proto
index 1f2d76d..bcb9e1a 100644
--- a/protos/test/test.proto
+++ b/protos/test/test.proto
@@ -2,7 +2,7 @@ syntax = "proto3";
 
 package testpb;
 
-option go_package = "github.com/tochemey/goakt/test/data;testpb";
+option go_package = "github.com/tochemey/goakt/v2/test/data;testpb";
 
 message TestReply {}
 message TestPanic {}
diff --git a/test/data/testpb/test.pb.go b/test/data/testpb/test.pb.go
index 1b2b729..8e2289b 100644
--- a/test/data/testpb/test.pb.go
+++ b/test/data/testpb/test.pb.go
@@ -1075,16 +1075,16 @@ var file_test_test_proto_rawDesc = []byte{
 	0x6e, 0x73, 0x74, 0x61, 0x73, 0x68, 0x41, 0x6c, 0x6c, 0x22, 0x06, 0x0a, 0x04, 0x50, 0x69, 0x6e,
 	0x67, 0x22, 0x06, 0x0a, 0x04, 0x50, 0x6f, 0x6e, 0x67, 0x22, 0x22, 0x0a, 0x04, 0x57, 0x61, 0x69,
 	0x74, 0x12, 0x1a, 0x0a, 0x08, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20,
-	0x01, 0x28, 0x04, 0x52, 0x08, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x7d, 0x0a,
-	0x0a, 0x63, 0x6f, 0x6d, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x70, 0x62, 0x42, 0x09, 0x54, 0x65, 0x73,
-	0x74, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01, 0x5a, 0x2a, 0x67, 0x69, 0x74, 0x68,
-	0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x79, 0x2f,
-	0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x3b,
-	0x74, 0x65, 0x73, 0x74, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x54, 0x58, 0x58, 0xaa, 0x02, 0x06, 0x54,
-	0x65, 0x73, 0x74, 0x70, 0x62, 0xca, 0x02, 0x06, 0x54, 0x65, 0x73, 0x74, 0x70, 0x62, 0xe2, 0x02,
-	0x12, 0x54, 0x65, 0x73, 0x74, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64,
-	0x61, 0x74, 0x61, 0xea, 0x02, 0x06, 0x54, 0x65, 0x73, 0x74, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72,
-	0x6f, 0x74, 0x6f, 0x33,
+	0x01, 0x28, 0x04, 0x52, 0x08, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x80, 0x01,
+	0x0a, 0x0a, 0x63, 0x6f, 0x6d, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x70, 0x62, 0x42, 0x09, 0x54, 0x65,
+	0x73, 0x74, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x48, 0x02, 0x50, 0x01, 0x5a, 0x2d, 0x67, 0x69, 0x74,
+	0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x74, 0x6f, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x79,
+	0x2f, 0x67, 0x6f, 0x61, 0x6b, 0x74, 0x2f, 0x76, 0x32, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x2f, 0x64,
+	0x61, 0x74, 0x61, 0x3b, 0x74, 0x65, 0x73, 0x74, 0x70, 0x62, 0xa2, 0x02, 0x03, 0x54, 0x58, 0x58,
+	0xaa, 0x02, 0x06, 0x54, 0x65, 0x73, 0x74, 0x70, 0x62, 0xca, 0x02, 0x06, 0x54, 0x65, 0x73, 0x74,
+	0x70, 0x62, 0xe2, 0x02, 0x12, 0x54, 0x65, 0x73, 0x74, 0x70, 0x62, 0x5c, 0x47, 0x50, 0x42, 0x4d,
+	0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x06, 0x54, 0x65, 0x73, 0x74, 0x70, 0x62,
+	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
diff --git a/testkit/probe.go b/testkit/probe.go
index 58dbd2a..bc618e4 100644
--- a/testkit/probe.go
+++ b/testkit/probe.go
@@ -11,8 +11,8 @@ import (
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/reflect/protoreflect"
 
-	"github.com/tochemey/goakt/actors"
-	"github.com/tochemey/goakt/goaktpb"
+	"github.com/tochemey/goakt/v2/actors"
+	"github.com/tochemey/goakt/v2/goaktpb"
 )
 
 const (
diff --git a/testkit/probe_test.go b/testkit/probe_test.go
index c14bcfb..d710df7 100644
--- a/testkit/probe_test.go
+++ b/testkit/probe_test.go
@@ -9,8 +9,8 @@ import (
 	"github.com/stretchr/testify/require"
 	"google.golang.org/protobuf/encoding/prototext"
 
-	"github.com/tochemey/goakt/actors"
-	"github.com/tochemey/goakt/test/data/testpb"
+	"github.com/tochemey/goakt/v2/actors"
+	"github.com/tochemey/goakt/v2/test/data/testpb"
 )
 
 func TestTestProbe(t *testing.T) {
diff --git a/testkit/testkit.go b/testkit/testkit.go
index cc1e36b..4a98d20 100644
--- a/testkit/testkit.go
+++ b/testkit/testkit.go
@@ -5,8 +5,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/tochemey/goakt/actors"
-	"github.com/tochemey/goakt/log"
+	"github.com/tochemey/goakt/v2/actors"
+	"github.com/tochemey/goakt/v2/log"
 )
 
 // TestKit defines actor test kit