Skip to content

Commit

Permalink
feauture: v4
Browse files Browse the repository at this point in the history 
Signed-off-by: Valery Piashchynski <[email protected]>
  • Loading branch information
@rustatian
rustatian committed Jan 10, 2023
1 parent f814710 commit e42ab46
Show file tree
Hide file tree
Showing 16 changed files with 87 additions and 52 deletions.
8 changes: 4 additions & 4 deletions aggregatedpool/activity.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@ import (
"sync/atomic"

"github.com/roadrunner-server/errors"
"github.com/roadrunner-server/sdk/v3/payload"
"github.com/roadrunner-server/sdk/v3/utils"
"github.com/temporalio/roadrunner-temporal/v2/common"
"github.com/temporalio/roadrunner-temporal/v2/internal"
"github.com/roadrunner-server/sdk/v4/payload"
"github.com/roadrunner-server/sdk/v4/utils"
"github.com/temporalio/roadrunner-temporal/v4/common"
"github.com/temporalio/roadrunner-temporal/v4/internal"
commonpb "go.temporal.io/api/common/v1"
tActivity "go.temporal.io/sdk/activity"
"go.temporal.io/sdk/temporal"
Expand Down
4 changes: 2 additions & 2 deletions aggregatedpool/handler.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@ import (
"time"

"github.com/roadrunner-server/errors"
"github.com/roadrunner-server/sdk/v3/payload"
"github.com/temporalio/roadrunner-temporal/v2/internal"
"github.com/roadrunner-server/sdk/v4/payload"
"github.com/temporalio/roadrunner-temporal/v4/internal"
commonpb "go.temporal.io/api/common/v1"
bindings "go.temporal.io/sdk/internalbindings"
"go.temporal.io/sdk/temporal"
Expand Down
2 changes: 1 addition & 1 deletion aggregatedpool/interceptor.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package aggregatedpool
import (
"context"

"github.com/temporalio/roadrunner-temporal/v2/common"
"github.com/temporalio/roadrunner-temporal/v4/common"
"go.temporal.io/sdk/interceptor"
)

Expand Down
6 changes: 3 additions & 3 deletions aggregatedpool/local_activity.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@ import (

"github.com/google/uuid"
"github.com/roadrunner-server/errors"
"github.com/roadrunner-server/sdk/v3/payload"
"github.com/temporalio/roadrunner-temporal/v2/common"
"github.com/temporalio/roadrunner-temporal/v2/internal"
"github.com/roadrunner-server/sdk/v4/payload"
"github.com/temporalio/roadrunner-temporal/v4/common"
"github.com/temporalio/roadrunner-temporal/v4/internal"
commonpb "go.temporal.io/api/common/v1"
tActivity "go.temporal.io/sdk/activity"
"go.temporal.io/sdk/temporal"
Expand Down
2 changes: 1 addition & 1 deletion aggregatedpool/workers.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"time"

"github.com/google/uuid"
"github.com/temporalio/roadrunner-temporal/v2/internal"
"github.com/temporalio/roadrunner-temporal/v4/internal"
tActivity "go.temporal.io/sdk/activity"
temporalClient "go.temporal.io/sdk/client"
"go.temporal.io/sdk/worker"
Expand Down
10 changes: 5 additions & 5 deletions aggregatedpool/workflow.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,11 +4,11 @@ import (
"sync/atomic"
"time"

"github.com/temporalio/roadrunner-temporal/v2/canceller"
"github.com/temporalio/roadrunner-temporal/v2/common"
"github.com/temporalio/roadrunner-temporal/v2/internal"
"github.com/temporalio/roadrunner-temporal/v2/queue"
"github.com/temporalio/roadrunner-temporal/v2/registry"
"github.com/temporalio/roadrunner-temporal/v4/canceller"
"github.com/temporalio/roadrunner-temporal/v4/common"
"github.com/temporalio/roadrunner-temporal/v4/internal"
"github.com/temporalio/roadrunner-temporal/v4/queue"
"github.com/temporalio/roadrunner-temporal/v4/registry"
commonpb "go.temporal.io/api/common/v1"
temporalClient "go.temporal.io/sdk/client"
bindings "go.temporal.io/sdk/internalbindings"
Expand Down
12 changes: 6 additions & 6 deletions common/interfaces.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,12 +4,12 @@ import (
"context"
"time"

"github.com/roadrunner-server/sdk/v3/payload"
"github.com/roadrunner-server/sdk/v3/pool"
staticPool "github.com/roadrunner-server/sdk/v3/pool/static_pool"
"github.com/roadrunner-server/sdk/v3/state/process"
"github.com/roadrunner-server/sdk/v3/worker"
"github.com/temporalio/roadrunner-temporal/v2/internal"
"github.com/roadrunner-server/sdk/v4/payload"
"github.com/roadrunner-server/sdk/v4/pool"
staticPool "github.com/roadrunner-server/sdk/v4/pool/static_pool"
"github.com/roadrunner-server/sdk/v4/state/process"
"github.com/roadrunner-server/sdk/v4/worker"
"github.com/temporalio/roadrunner-temporal/v4/internal"
"go.uber.org/zap"
)

Expand Down
2 changes: 1 addition & 1 deletion config.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"time"

"github.com/roadrunner-server/errors"
"github.com/roadrunner-server/sdk/v3/pool"
"github.com/roadrunner-server/sdk/v4/pool"
)

const (
Expand Down
9 changes: 4 additions & 5 deletions go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/temporalio/roadrunner-temporal/v2
module github.com/temporalio/roadrunner-temporal/v4

go 1.19

Expand All @@ -8,10 +8,10 @@ require (
github.com/golang/protobuf v1.5.2
github.com/google/uuid v1.3.0
github.com/roadrunner-server/errors v1.2.0
github.com/roadrunner-server/sdk/v3 v3.1.0
github.com/roadrunner-server/sdk/v4 v4.0.0
github.com/stretchr/testify v1.8.1
github.com/uber-go/tally/v4 v4.1.4
go.temporal.io/api v1.13.1-0.20221110200459-6a3cb21a3415
go.temporal.io/api v1.14.0
go.temporal.io/sdk v1.19.0
go.temporal.io/sdk/contrib/tally v0.2.0
go.temporal.io/server v1.19.0
Expand Down Expand Up @@ -49,14 +49,13 @@ require (
github.com/twmb/murmur3 v1.1.6 // indirect
github.com/yusufpapurcu/wmi v1.2.2 // indirect
go.uber.org/atomic v1.10.0 // indirect
go.uber.org/goleak v1.1.12 // indirect
go.uber.org/multierr v1.9.0 // indirect
golang.org/x/net v0.5.0 // indirect
golang.org/x/sync v0.1.0 // indirect
golang.org/x/sys v0.4.0 // indirect
golang.org/x/text v0.6.0 // indirect
golang.org/x/time v0.3.0 // indirect
google.golang.org/genproto v0.0.0-20230104163317-caabf589fcbf // indirect
google.golang.org/genproto v0.0.0-20230109162033-3c3c17ce83e6 // indirect
google.golang.org/grpc v1.51.0
gopkg.in/yaml.v3 v3.0.1 // indirect
)
Loading

0 comments on commit e42ab46

Please sign in to comment.