Skip to content

Commit

Permalink
Renames durabletask-go repo to dapr
Browse files Browse the repository at this point in the history
Updates module github.com/microsoft/durabletask-go to
github.com/dapr/durabletask-go

Signed-off-by: joshvanl <[email protected]>
  • Loading branch information
JoshVanL committed Nov 26, 2024
1 parent 9314102 commit e44fe81
Show file tree
Hide file tree
Showing 40 changed files with 114 additions and 114 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
# Durable Task Framework for Go

[![Build](https://github.com/microsoft/durabletask-go/actions/workflows/pr-validation.yml/badge.svg)](https://github.com/microsoft/durabletask-go/actions/workflows/pr-validation.yml)
[![Build](https://github.com/dapr/durabletask-go/actions/workflows/pr-validation.yml/badge.svg)](https://github.com/dapr/durabletask-go/actions/workflows/pr-validation.yml)

The Durable Task Framework is a lightweight, embeddable engine for writing durable, fault-tolerant business logic (*orchestrations*) as ordinary code. The engine itself is written in Go and intended to be embedded into other Go-based processes. It exposes a gRPC endpoint to support writing durable flows in any language. There are currently SDKs that consume this gRPC endpoint for [.NET](https://github.com/microsoft/durabletask-dotnet) and [Java](https://github.com/microsoft/durabletask-java), with more to come. It's also possible to write orchestrations directly in Go and run them in the local process.

Expand Down Expand Up @@ -250,7 +250,7 @@ Note that each orchestration is represented as a single span with activities, ti
This repository contains submodules. Be sure to clone it with the option to include submodules. Otherwise you will not be able to generate the protobuf code.

```bash
git clone --recurse-submodules https://github.com/microsoft/durabletask-go
git clone --recurse-submodules https://github.com/dapr/durabletask-go
```

## Building the project
Expand Down
4 changes: 2 additions & 2 deletions api/orchestration.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@ import (
"fmt"
"time"

"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
"google.golang.org/protobuf/types/known/timestamppb"
"google.golang.org/protobuf/types/known/wrapperspb"
)
Expand Down
6 changes: 3 additions & 3 deletions backend/activity.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@ import (
"go.opentelemetry.io/otel/codes"
"go.opentelemetry.io/otel/trace"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
)

type activityProcessor struct {
Expand Down
6 changes: 3 additions & 3 deletions backend/backend.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@ import (
"errors"
"fmt"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
"google.golang.org/protobuf/proto"
)

Expand Down
6 changes: 3 additions & 3 deletions backend/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,9 @@ import (
"go.opentelemetry.io/otel/codes"
"go.opentelemetry.io/otel/trace"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
)

type TaskHubClient interface {
Expand Down
6 changes: 3 additions & 3 deletions backend/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,9 @@ import (
"google.golang.org/protobuf/types/known/timestamppb"
"google.golang.org/protobuf/types/known/wrapperspb"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
)

var emptyCompleteTaskResponse = &protos.CompleteTaskResponse{}
Expand Down
6 changes: 3 additions & 3 deletions backend/orchestration.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,9 @@ import (
"go.opentelemetry.io/otel/trace"
"google.golang.org/protobuf/types/known/wrapperspb"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
)

type OrchestratorExecutor interface {
Expand Down
6 changes: 3 additions & 3 deletions backend/runtimestate.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,9 @@ import (
"google.golang.org/protobuf/types/known/timestamppb"
"google.golang.org/protobuf/types/known/wrapperspb"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
)

var ErrDuplicateEvent = errors.New("duplicate event")
Expand Down
8 changes: 4 additions & 4 deletions backend/sqlite/sqlite.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,10 +11,10 @@ import (
"time"

"github.com/google/uuid"
"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
"google.golang.org/protobuf/proto"

_ "modernc.org/sqlite"
Expand Down
2 changes: 1 addition & 1 deletion backend/workitem.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"fmt"
"time"

"github.com/microsoft/durabletask-go/api"
"github.com/dapr/durabletask-go/api"
)

var ErrNoWorkItems = errors.New("no work items were found")
Expand Down
6 changes: 3 additions & 3 deletions client/client_grpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,9 @@ import (
"google.golang.org/grpc"
"google.golang.org/protobuf/types/known/wrapperspb"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/internal/protos"
)

// REVIEW: Can this be merged with backend/client.go somehow?
Expand Down
10 changes: 5 additions & 5 deletions client/worker_grpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@ import (
"time"

"github.com/cenkalti/backoff/v4"
"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/task"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
"google.golang.org/protobuf/types/known/emptypb"
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/microsoft/durabletask-go
module github.com/dapr/durabletask-go

go 1.19

Expand Down
2 changes: 1 addition & 1 deletion internal/helpers/history.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import (
"google.golang.org/protobuf/types/known/timestamppb"
"google.golang.org/protobuf/types/known/wrapperspb"

"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/internal/protos"
)

func NewExecutionStartedEvent(
Expand Down
2 changes: 1 addition & 1 deletion internal/helpers/tracing.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import (
"go.opentelemetry.io/otel/trace"
"google.golang.org/protobuf/types/known/wrapperspb"

"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/internal/protos"
)

var tracer = otel.Tracer("durabletask")
Expand Down
4 changes: 2 additions & 2 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@ import (

"google.golang.org/grpc"

"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
)

var (
Expand Down
2 changes: 1 addition & 1 deletion samples/azurefunctions/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"net/http"
"os"

"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/task"
)

// HelloCities is an orchestrator function that generates a "hello" message for several cities.
Expand Down
8 changes: 4 additions & 4 deletions samples/azurefunctions/middleware.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@ import (
"fmt"
"net/http"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/task"
"google.golang.org/protobuf/proto"
"google.golang.org/protobuf/types/known/wrapperspb"
)
Expand Down
6 changes: 3 additions & 3 deletions samples/distributedtracing/distributedtracing.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,9 @@ import (
"go.opentelemetry.io/otel/sdk/resource"
"go.opentelemetry.io/otel/sdk/trace"

"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/task"
)

func main() {
Expand Down
8 changes: 4 additions & 4 deletions samples/externalevents/externalevents.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@ import (
"log"
"time"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/task"
)

func main() {
Expand Down
6 changes: 3 additions & 3 deletions samples/parallel/parallel.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,9 @@ import (

"github.com/google/uuid"

"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/task"
)

func main() {
Expand Down
6 changes: 3 additions & 3 deletions samples/retries/retries.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,9 @@ import (
"math/rand"
"time"

"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/task"
)

func main() {
Expand Down
6 changes: 3 additions & 3 deletions samples/sequence/sequence.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@ import (
"fmt"
"log"

"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/task"
)

func main() {
Expand Down
2 changes: 1 addition & 1 deletion task/activity.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"math"
"time"

"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/internal/protos"
"google.golang.org/protobuf/types/known/wrapperspb"
)

Expand Down
8 changes: 4 additions & 4 deletions task/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@ import (
"encoding/json"
"fmt"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
"google.golang.org/protobuf/types/known/wrapperspb"
)

Expand Down
8 changes: 4 additions & 4 deletions task/orchestrator.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,10 +10,10 @@ import (

"google.golang.org/protobuf/types/known/wrapperspb"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
)

// Orchestrator is the functional interface for orchestrator functions.
Expand Down
2 changes: 1 addition & 1 deletion task/registry.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package task
import (
"fmt"

"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/helpers"
)

// TaskRegistry contains maps of names to corresponding orchestrator and activity functions.
Expand Down
2 changes: 1 addition & 1 deletion task/task.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"errors"
"fmt"

"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/internal/protos"
)

// ErrTaskBlocked is not an error, but rather a control flow signal indicating that an orchestrator
Expand Down
10 changes: 5 additions & 5 deletions tests/backend_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@ import (
"testing"
"time"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/microsoft/durabletask-go/internal/helpers"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/internal/helpers"
"github.com/dapr/durabletask-go/internal/protos"
"github.com/stretchr/testify/assert"
"google.golang.org/protobuf/types/known/timestamppb"
"google.golang.org/protobuf/types/known/wrapperspb"
Expand Down
12 changes: 6 additions & 6 deletions tests/grpc/grpc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,12 +10,12 @@ import (
"testing"
"time"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/backend"
"github.com/microsoft/durabletask-go/backend/sqlite"
"github.com/microsoft/durabletask-go/client"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/microsoft/durabletask-go/task"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/backend"
"github.com/dapr/durabletask-go/backend/sqlite"
"github.com/dapr/durabletask-go/client"
"github.com/dapr/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/task"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"google.golang.org/grpc"
Expand Down
4 changes: 2 additions & 2 deletions tests/metadata_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@ import (
"testing"
"time"

"github.com/microsoft/durabletask-go/api"
"github.com/microsoft/durabletask-go/internal/protos"
"github.com/dapr/durabletask-go/api"
"github.com/dapr/durabletask-go/internal/protos"
"github.com/stretchr/testify/assert"
"google.golang.org/protobuf/types/known/wrapperspb"
)
Expand Down
Loading

0 comments on commit e44fe81

Please sign in to comment.