diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml index 7e2de15..f09042e 100644 --- a/.github/workflows/build.yml +++ b/.github/workflows/build.yml @@ -7,7 +7,7 @@ concurrency: cancel-in-progress: true env: - GOPRIVATE: github.com/stealthrocket/* + GOPRIVATE: github.com/dispatchrun/* GH_ACCESS_TOKEN: ${{ secrets.PRIVATE_ACCESS_TOKEN }} jobs: diff --git a/README.md b/README.md index f4aa291..e9b24e3 100644 --- a/README.md +++ b/README.md @@ -1,5 +1,5 @@ -[![build](https://github.com/stealthrocket/coroutine/actions/workflows/build.yml/badge.svg)](https://github.com/stealthrocket/coroutine/actions/workflows/build.yml) -[![Go Reference](https://pkg.go.dev/badge/github.com/stealthrocket/coroutine.svg)](https://pkg.go.dev/github.com/stealthrocket/coroutine) +[![build](https://github.com/dispatchrun/coroutine/actions/workflows/build.yml/badge.svg)](https://github.com/dispatchrun/coroutine/actions/workflows/build.yml) +[![Go Reference](https://pkg.go.dev/badge/github.com/dispatchrun/coroutine.svg)](https://pkg.go.dev/github.com/dispatchrun/coroutine) [![Apache 2 License](https://img.shields.io/badge/license-Apache%202-blue.svg)](LICENSE) [![Discord](https://img.shields.io/discord/1126309607166464131?label=Discord)](Discord) @@ -8,7 +8,7 @@ This project contains a durable coroutine compiler and runtime library for Go. > **Note** -> Read our announcement blog post: [Fairy tales of workflow orchestration](https://blog.stealthrocket.tech/fairy-tales-of-workflow-orchestration/). +> Read our announcement blog post: [Fairy tales of workflow orchestration](https://blog.dispatch.run/fairy-tales-of-workflow-orchestration/). ## Usage @@ -29,7 +29,7 @@ the caller: // main.go package main -import "github.com/stealthrocket/coroutine" +import "github.com/dispatchrun/coroutine" func main() { coro := coroutine.New[int, any](func() { @@ -82,7 +82,7 @@ Often times, the simplest construct to drive coroutine executions is to use the ```go package main -import "github.com/stealthrocket/coroutine" +import "github.com/dispatchrun/coroutine" func main() { coro := coroutine.New[int, any](func() { @@ -174,7 +174,7 @@ storage medium and later reloaded to restart computation where it was left off. To install the `coroc` compiler: ``` -go install github.com/stealthrocket/coroutine/compiler/cmd/coroc@latest +go install github.com/dispatchrun/coroutine/compiler/cmd/coroc@latest ``` Then to compile a package: @@ -233,7 +233,7 @@ import ( "log" "os" - "github.com/stealthrocket/coroutine" + "github.com/dispatchrun/coroutine" ) func work() { @@ -313,7 +313,7 @@ decide that some values need specific logic to be functional upon deserialization. See [the `coroutine/types` package][coro-types] for the tools to take control of serialization of the coroutine state. -[coro-types]: https://pkg.go.dev/github.com/stealthrocket/coroutine/types +[coro-types]: https://pkg.go.dev/github.com/dispatchrun/coroutine/types ### Scheduling @@ -354,5 +354,5 @@ Remember to be respectful and open minded! ## Community -- [Join us on Discord](https://stealthrocket.tech/discord) -- [Follow us on Twitter](https://twitter.com/_stealthrocket) +- [Join us on Discord](https://dispatch.run/discord) +- [Follow us on Twitter](https://twitter.com/_dispatchrun) diff --git a/buf.gen.yaml b/buf.gen.yaml index e65a40a..05ca7a5 100644 --- a/buf.gen.yaml +++ b/buf.gen.yaml @@ -2,7 +2,7 @@ version: v1 managed: enabled: true go_package_prefix: - default: github.com/stealthrocket/coroutine/gen/proto/go + default: github.com/dispatchrun/coroutine/gen/proto/go plugins: - plugin: buf.build/protocolbuffers/go:v1.31.0 diff --git a/compiler/cmd/coroc/main.go b/compiler/cmd/coroc/main.go index 129f5dd..8fc6e66 100644 --- a/compiler/cmd/coroc/main.go +++ b/compiler/cmd/coroc/main.go @@ -9,7 +9,7 @@ import ( "runtime/debug" "runtime/pprof" - "github.com/stealthrocket/coroutine/compiler" + "github.com/dispatchrun/coroutine/compiler" ) const usage = ` diff --git a/compiler/compile.go b/compiler/compile.go index 2e94145..a29bb9f 100644 --- a/compiler/compile.go +++ b/compiler/compile.go @@ -27,7 +27,7 @@ import ( "golang.org/x/tools/go/ssa/ssautil" ) -const coroutinePackage = "github.com/stealthrocket/coroutine" +const coroutinePackage = "github.com/dispatchrun/coroutine" // Compile compiles coroutines in a module. // diff --git a/compiler/coroutine_test.go b/compiler/coroutine_test.go index 0c2e0e3..491858f 100644 --- a/compiler/coroutine_test.go +++ b/compiler/coroutine_test.go @@ -4,9 +4,9 @@ import ( "slices" "testing" - "github.com/stealthrocket/coroutine" - . "github.com/stealthrocket/coroutine/compiler/testdata" - "github.com/stealthrocket/coroutine/types" + "github.com/dispatchrun/coroutine" + . "github.com/dispatchrun/coroutine/compiler/testdata" + "github.com/dispatchrun/coroutine/types" ) func init() { diff --git a/compiler/function.go b/compiler/function.go index 75ed118..2a3b25f 100644 --- a/compiler/function.go +++ b/compiler/function.go @@ -343,7 +343,7 @@ func (c *compiler) generateFunctypes(p *packages.Package, f *ast.File, colors ma } if len(init.List) > 0 { - astutil.AddNamedImport(nil, f, "_types", "github.com/stealthrocket/coroutine/types") + astutil.AddNamedImport(nil, f, "_types", "github.com/dispatchrun/coroutine/types") f.Decls = append(f.Decls, &ast.FuncDecl{ diff --git a/compiler/testdata/coroutine.go b/compiler/testdata/coroutine.go index 0555fb4..7d312a6 100644 --- a/compiler/testdata/coroutine.go +++ b/compiler/testdata/coroutine.go @@ -6,7 +6,7 @@ import ( "time" "unsafe" - "github.com/stealthrocket/coroutine" + "github.com/dispatchrun/coroutine" ) //go:generate coroc diff --git a/compiler/testdata/coroutine_durable.go b/compiler/testdata/coroutine_durable.go index a9ecb61..3fd4aa6 100644 --- a/compiler/testdata/coroutine_durable.go +++ b/compiler/testdata/coroutine_durable.go @@ -3,11 +3,11 @@ package testdata import ( - coroutine "github.com/stealthrocket/coroutine" + coroutine "github.com/dispatchrun/coroutine" time "time" unsafe "unsafe" ) -import _types "github.com/stealthrocket/coroutine/types" +import _types "github.com/dispatchrun/coroutine/types" func SomeFunctionThatShouldExistInTheCompiledFile() { } @@ -3393,7 +3393,7 @@ func IdentityGenericInt(n int) { IdentityGeneric[int](n) } //go:noinline func IdentityGenericClosure[T any](_fn0 T) { - _c := coroutine.LoadContext[int, any]() + _c := coroutine.LoadContext[T, any]() var _f0 *struct { IP int X0 T @@ -3682,7 +3682,7 @@ func RangeOverInt(_fn0 int) { } } func init() { - _types.RegisterFunc[func(_fn1 int) (_ func(int))]("github.com/stealthrocket/coroutine/compiler/testdata.(*Box).Closure") + _types.RegisterFunc[func(_fn1 int) (_ func(int))]("github.com/dispatchrun/coroutine/compiler/testdata.(*Box).Closure") _types.RegisterClosure[func(_fn0 int), struct { F uintptr X0 *struct { @@ -3690,9 +3690,9 @@ func init() { X0 *Box X1 int } - }]("github.com/stealthrocket/coroutine/compiler/testdata.(*Box).Closure.func1") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.(*Box).YieldAndInc") - _types.RegisterFunc[func(_fn1 int) (_ func(int))]("github.com/stealthrocket/coroutine/compiler/testdata.(*IdentityGenericStruct[go.shape.int]).Closure") + }]("github.com/dispatchrun/coroutine/compiler/testdata.(*Box).Closure.func1") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.(*Box).YieldAndInc") + _types.RegisterFunc[func(_fn1 int) (_ func(int))]("github.com/dispatchrun/coroutine/compiler/testdata.(*IdentityGenericStruct[go.shape.int]).Closure") _types.RegisterClosure[func(_fn0 int), struct { F uintptr X0 *struct { @@ -3701,25 +3701,25 @@ func init() { X1 int } D uintptr - }]("github.com/stealthrocket/coroutine/compiler/testdata.(*IdentityGenericStruct[go.shape.int]).Closure.func1") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.(*IdentityGenericStruct[go.shape.int]).Run") - _types.RegisterFunc[func(_fn1 int)]("github.com/stealthrocket/coroutine/compiler/testdata.(*MethodGeneratorState).MethodGenerator") - _types.RegisterFunc[func(n int)]("github.com/stealthrocket/coroutine/compiler/testdata.Double") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.EvenSquareGenerator") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.FizzBuzzIfGenerator") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.FizzBuzzSwitchGenerator") - _types.RegisterFunc[func(n int)]("github.com/stealthrocket/coroutine/compiler/testdata.Identity") - _types.RegisterFunc[func(n int)]("github.com/stealthrocket/coroutine/compiler/testdata.IdentityGenericClosureInt") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.IdentityGenericClosure[go.shape.int]") - _types.RegisterFunc[func(n int)]("github.com/stealthrocket/coroutine/compiler/testdata.IdentityGenericInt") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.IdentityGenericStructClosureInt") - _types.RegisterFunc[func(n int)]("github.com/stealthrocket/coroutine/compiler/testdata.IdentityGenericStructInt") - _types.RegisterFunc[func(n int)]("github.com/stealthrocket/coroutine/compiler/testdata.IdentityGeneric[go.shape.int]") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.IndirectClosure") - _types.RegisterFunc[func(_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.LoopBreakAndContinue") - _types.RegisterFunc[func(_fn0 int) (_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.NestedLoops") - _types.RegisterFunc[func(_fn0 int, _fn1 func(int))]("github.com/stealthrocket/coroutine/compiler/testdata.Range") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.Range10ClosureCapturingPointers") + }]("github.com/dispatchrun/coroutine/compiler/testdata.(*IdentityGenericStruct[go.shape.int]).Closure.func1") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.(*IdentityGenericStruct[go.shape.int]).Run") + _types.RegisterFunc[func(_fn1 int)]("github.com/dispatchrun/coroutine/compiler/testdata.(*MethodGeneratorState).MethodGenerator") + _types.RegisterFunc[func(n int)]("github.com/dispatchrun/coroutine/compiler/testdata.Double") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.EvenSquareGenerator") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.FizzBuzzIfGenerator") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.FizzBuzzSwitchGenerator") + _types.RegisterFunc[func(n int)]("github.com/dispatchrun/coroutine/compiler/testdata.Identity") + _types.RegisterFunc[func(n int)]("github.com/dispatchrun/coroutine/compiler/testdata.IdentityGenericClosureInt") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.IdentityGenericClosure[go.shape.int]") + _types.RegisterFunc[func(n int)]("github.com/dispatchrun/coroutine/compiler/testdata.IdentityGenericInt") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.IdentityGenericStructClosureInt") + _types.RegisterFunc[func(n int)]("github.com/dispatchrun/coroutine/compiler/testdata.IdentityGenericStructInt") + _types.RegisterFunc[func(n int)]("github.com/dispatchrun/coroutine/compiler/testdata.IdentityGeneric[go.shape.int]") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.IndirectClosure") + _types.RegisterFunc[func(_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.LoopBreakAndContinue") + _types.RegisterFunc[func(_fn0 int) (_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.NestedLoops") + _types.RegisterFunc[func(_fn0 int, _fn1 func(int))]("github.com/dispatchrun/coroutine/compiler/testdata.Range") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.Range10ClosureCapturingPointers") _types.RegisterClosure[func() (_ bool), struct { F uintptr X0 *struct { @@ -3732,8 +3732,8 @@ func init() { X5 bool X6 bool } - }]("github.com/stealthrocket/coroutine/compiler/testdata.Range10ClosureCapturingPointers.func2") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.Range10ClosureCapturingValues") + }]("github.com/dispatchrun/coroutine/compiler/testdata.Range10ClosureCapturingPointers.func2") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.Range10ClosureCapturingValues") _types.RegisterClosure[func() (_ bool), struct { F uintptr X0 *struct { @@ -3744,8 +3744,8 @@ func init() { X3 bool X4 bool } - }]("github.com/stealthrocket/coroutine/compiler/testdata.Range10ClosureCapturingValues.func2") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.Range10ClosureHeterogenousCapture") + }]("github.com/dispatchrun/coroutine/compiler/testdata.Range10ClosureCapturingValues.func2") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.Range10ClosureHeterogenousCapture") _types.RegisterClosure[func() int, struct { F uintptr X0 *struct { @@ -3765,7 +3765,7 @@ func init() { X12 bool X13 bool } - }]("github.com/stealthrocket/coroutine/compiler/testdata.Range10ClosureHeterogenousCapture.func2") + }]("github.com/dispatchrun/coroutine/compiler/testdata.Range10ClosureHeterogenousCapture.func2") _types.RegisterClosure[func() (_ bool), struct { F uintptr X0 *struct { @@ -3785,12 +3785,12 @@ func init() { X12 bool X13 bool } - }]("github.com/stealthrocket/coroutine/compiler/testdata.Range10ClosureHeterogenousCapture.func3") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.Range10Heterogenous") - _types.RegisterFunc[func(_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeArrayIndexValueGenerator") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeOverInt") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeOverMaps") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeReverseClosureCaptureByValue") + }]("github.com/dispatchrun/coroutine/compiler/testdata.Range10ClosureHeterogenousCapture.func3") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.Range10Heterogenous") + _types.RegisterFunc[func(_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeArrayIndexValueGenerator") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeOverInt") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeOverMaps") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeReverseClosureCaptureByValue") _types.RegisterClosure[func(), struct { F uintptr X0 *struct { @@ -3799,24 +3799,24 @@ func init() { X1 int X2 func() } - }]("github.com/stealthrocket/coroutine/compiler/testdata.RangeReverseClosureCaptureByValue.func2") - _types.RegisterFunc[func(_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeSliceIndexGenerator") - _types.RegisterFunc[func(n int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeTriple") - _types.RegisterFunc[func(i int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeTriple.func1") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeTripleFuncValue") - _types.RegisterFunc[func(i int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeTripleFuncValue.func2") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.RangeYieldAndDeferAssign") - _types.RegisterFunc[func() (_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.ReturnNamedValue") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.Select") - _types.RegisterFunc[func(_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.Shadowing") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.SomeFunctionThatShouldExistInTheCompiledFile") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.SquareGenerator") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.SquareGeneratorTwice") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.SquareGeneratorTwiceLoop") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.StructClosure") - _types.RegisterFunc[func(_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.TypeSwitchingGenerator") - _types.RegisterFunc[func(_fn0 int)]("github.com/stealthrocket/coroutine/compiler/testdata.VarArgs") - _types.RegisterFunc[func(_fn0 *int, _fn1, _fn2 int)]("github.com/stealthrocket/coroutine/compiler/testdata.YieldAndDeferAssign") + }]("github.com/dispatchrun/coroutine/compiler/testdata.RangeReverseClosureCaptureByValue.func2") + _types.RegisterFunc[func(_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeSliceIndexGenerator") + _types.RegisterFunc[func(n int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeTriple") + _types.RegisterFunc[func(i int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeTriple.func1") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeTripleFuncValue") + _types.RegisterFunc[func(i int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeTripleFuncValue.func2") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.RangeYieldAndDeferAssign") + _types.RegisterFunc[func() (_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.ReturnNamedValue") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.Select") + _types.RegisterFunc[func(_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.Shadowing") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.SomeFunctionThatShouldExistInTheCompiledFile") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.SquareGenerator") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.SquareGeneratorTwice") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.SquareGeneratorTwiceLoop") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.StructClosure") + _types.RegisterFunc[func(_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.TypeSwitchingGenerator") + _types.RegisterFunc[func(_fn0 int)]("github.com/dispatchrun/coroutine/compiler/testdata.VarArgs") + _types.RegisterFunc[func(_fn0 *int, _fn1, _fn2 int)]("github.com/dispatchrun/coroutine/compiler/testdata.YieldAndDeferAssign") _types.RegisterClosure[func(), struct { F uintptr X0 *struct { @@ -3826,8 +3826,8 @@ func init() { X2 int X3 []func() } - }]("github.com/stealthrocket/coroutine/compiler/testdata.YieldAndDeferAssign.func2") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.YieldingDurations") + }]("github.com/dispatchrun/coroutine/compiler/testdata.YieldAndDeferAssign.func2") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.YieldingDurations") _types.RegisterClosure[func(), struct { F uintptr X0 *struct { @@ -3837,11 +3837,11 @@ func init() { X2 func() X3 int } - }]("github.com/stealthrocket/coroutine/compiler/testdata.YieldingDurations.func2") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata.YieldingExpressionDesugaring") - _types.RegisterFunc[func(_fn0 int) (_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.a") - _types.RegisterFunc[func(_fn0 int) (_ int)]("github.com/stealthrocket/coroutine/compiler/testdata.b") - _types.RegisterFunc[func(_fn0 int) (_ func())]("github.com/stealthrocket/coroutine/compiler/testdata.buildClosure[go.shape.int]") + }]("github.com/dispatchrun/coroutine/compiler/testdata.YieldingDurations.func2") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata.YieldingExpressionDesugaring") + _types.RegisterFunc[func(_fn0 int) (_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.a") + _types.RegisterFunc[func(_fn0 int) (_ int)]("github.com/dispatchrun/coroutine/compiler/testdata.b") + _types.RegisterFunc[func(_fn0 int) (_ func())]("github.com/dispatchrun/coroutine/compiler/testdata.buildClosure[go.shape.int]") _types.RegisterClosure[func(), struct { F uintptr X0 *struct { @@ -3849,10 +3849,10 @@ func init() { X0 int } D uintptr - }]("github.com/stealthrocket/coroutine/compiler/testdata.buildClosure[go.shape.int].func1") + }]("github.com/dispatchrun/coroutine/compiler/testdata.buildClosure[go.shape.int].func1") _types.RegisterFunc[func(_fn0 interface { YieldAndInc() - }) (_ func())]("github.com/stealthrocket/coroutine/compiler/testdata.indirectClosure") + }) (_ func())]("github.com/dispatchrun/coroutine/compiler/testdata.indirectClosure") _types.RegisterClosure[func(), struct { F uintptr X0 *struct { @@ -3861,6 +3861,6 @@ func init() { YieldAndInc() } } - }]("github.com/stealthrocket/coroutine/compiler/testdata.indirectClosure.func2") - _types.RegisterFunc[func(_fn0 ...int)]("github.com/stealthrocket/coroutine/compiler/testdata.varArgs") + }]("github.com/dispatchrun/coroutine/compiler/testdata.indirectClosure.func2") + _types.RegisterFunc[func(_fn0 ...int)]("github.com/dispatchrun/coroutine/compiler/testdata.varArgs") } diff --git a/compiler/testdata/http/go.mod b/compiler/testdata/http/go.mod index 5c8c4c1..87304c2 100644 --- a/compiler/testdata/http/go.mod +++ b/compiler/testdata/http/go.mod @@ -1,7 +1,7 @@ -module github.com/stealthrocket/coroutine/compiler/testdata/http +module github.com/dispatchrun/coroutine/compiler/testdata/http go 1.21.0 -require github.com/stealthrocket/coroutine v0.0.0-20230906012022-7474cda88ddc +require github.com/dispatchrun/coroutine v0.0.0-20230906012022-7474cda88ddc -replace github.com/stealthrocket/coroutine => ../../../ +replace github.com/dispatchrun/coroutine => ../../../ diff --git a/compiler/testdata/http/main.go b/compiler/testdata/http/main.go index 8a714eb..05c5ee6 100644 --- a/compiler/testdata/http/main.go +++ b/compiler/testdata/http/main.go @@ -6,7 +6,7 @@ import ( "fmt" "net/http" - "github.com/stealthrocket/coroutine" + "github.com/dispatchrun/coroutine" ) type yieldingRoundTripper struct{} diff --git a/compiler/testdata/http/main_durable.go b/compiler/testdata/http/main_durable.go index 59f6adf..0e0a093 100644 --- a/compiler/testdata/http/main_durable.go +++ b/compiler/testdata/http/main_durable.go @@ -4,10 +4,10 @@ package main import ( http "net/http" - coroutine "github.com/stealthrocket/coroutine" + coroutine "github.com/dispatchrun/coroutine" fmt "fmt" ) -import _types "github.com/stealthrocket/coroutine/types" +import _types "github.com/dispatchrun/coroutine/types" type yieldingRoundTripper struct{} //go:noinline @@ -111,7 +111,7 @@ func main() { } } func init() { - _types.RegisterFunc[func(_fn0 *http.Request) (_ *http.Response, _ error)]("github.com/stealthrocket/coroutine/compiler/testdata/http.RoundTrip") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata/http.main") - _types.RegisterFunc[func()]("github.com/stealthrocket/coroutine/compiler/testdata/http.work") + _types.RegisterFunc[func(_fn0 *http.Request) (_ *http.Response, _ error)]("github.com/dispatchrun/coroutine/compiler/testdata/http.RoundTrip") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata/http.main") + _types.RegisterFunc[func()]("github.com/dispatchrun/coroutine/compiler/testdata/http.work") } diff --git a/coroutine_durable.go b/coroutine_durable.go index 7403f72..b71a590 100644 --- a/coroutine_durable.go +++ b/coroutine_durable.go @@ -7,7 +7,7 @@ import ( "runtime" "unsafe" - "github.com/stealthrocket/coroutine/types" + "github.com/dispatchrun/coroutine/types" ) // Durable is a constant which takes the values true or false depending on diff --git a/examples/scrape/go.mod b/examples/scrape/go.mod index 63985b5..bf19685 100644 --- a/examples/scrape/go.mod +++ b/examples/scrape/go.mod @@ -3,8 +3,8 @@ module scrape go 1.21.0 toolchain go1.22.2 -require github.com/stealthrocket/coroutine v0.0.0-00000000000000-000000000000 +require github.com/dispatchrun/coroutine v0.0.0-00000000000000-000000000000 require google.golang.org/protobuf v1.33.0 // indirect -replace github.com/stealthrocket/coroutine => ../../ +replace github.com/dispatchrun/coroutine => ../../ diff --git a/examples/scrape/main.go b/examples/scrape/main.go index 27f8225..32c3390 100644 --- a/examples/scrape/main.go +++ b/examples/scrape/main.go @@ -7,7 +7,7 @@ import ( "log" "os" - "github.com/stealthrocket/coroutine" + "github.com/dispatchrun/coroutine" ) func main() { diff --git a/examples/scrape/scraper.go b/examples/scrape/scraper.go index a6e4a3f..cca4d84 100644 --- a/examples/scrape/scraper.go +++ b/examples/scrape/scraper.go @@ -10,7 +10,7 @@ import ( "regexp" "strings" - "github.com/stealthrocket/coroutine" + "github.com/dispatchrun/coroutine" ) // Scraper recursively scrapes URLs. diff --git a/go.mod b/go.mod index e6de8bc..66e707c 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/stealthrocket/coroutine +module github.com/dispatchrun/coroutine go 1.22.0 diff --git a/types/func_test.go b/types/func_test.go index 54730a2..d4859ff 100644 --- a/types/func_test.go +++ b/types/func_test.go @@ -31,7 +31,7 @@ func TestFunctionAddress(t *testing.T) { } func TestFunctionLookup(t *testing.T) { - name := "github.com/stealthrocket/coroutine/types.TestFunctionLookup" + name := "github.com/dispatchrun/coroutine/types.TestFunctionLookup" sym1 := FuncByName(name) sym2 := FuncByAddr(FuncAddr(TestFunctionLookup)) @@ -45,7 +45,7 @@ func TestClosureAddress(t *testing.T) { p := *(*unsafe.Pointer)(unsafe.Pointer(&f)) c := (*closure)(p) - name := "github.com/stealthrocket/coroutine/types.op.func1" + name := "github.com/dispatchrun/coroutine/types.op.func1" addr1 := c.addr addr2 := FuncAddr(f) @@ -57,7 +57,7 @@ func TestClosureAddress(t *testing.T) { func TestClosureLookup(t *testing.T) { f := op(1, 2) - name := "github.com/stealthrocket/coroutine/types.op.func1" + name := "github.com/dispatchrun/coroutine/types.op.func1" sym1 := FuncByName(name) sym2 := FuncByAddr(FuncAddr(f)) @@ -67,7 +67,7 @@ func TestClosureLookup(t *testing.T) { } func TestRehydrateFunction(t *testing.T) { - f := FuncByName("github.com/stealthrocket/coroutine/types.op") + f := FuncByName("github.com/dispatchrun/coroutine/types.op") v := reflect.New(f.Type) p := v.UnsafePointer() @@ -88,7 +88,7 @@ func TestRehydrateFunction(t *testing.T) { } func TestRehydrateClosure(t *testing.T) { - f := FuncByName("github.com/stealthrocket/coroutine/types.op.func1") + f := FuncByName("github.com/dispatchrun/coroutine/types.op.func1") v := reflect.New(f.Closure) p := v.UnsafePointer() @@ -125,10 +125,10 @@ type opFunc1Closure struct { // This init function contains the work that would normally be done by the // compiler to generate the reflect data necessary to serialize functions. func init() { - op := FuncByName("github.com/stealthrocket/coroutine/types.op") + op := FuncByName("github.com/dispatchrun/coroutine/types.op") op.Type = reflect.TypeOf(func(int, int) (_ func() int) { return }) - fn := FuncByName("github.com/stealthrocket/coroutine/types.op.func1") + fn := FuncByName("github.com/dispatchrun/coroutine/types.op.func1") fn.Type = reflect.TypeOf(func() (_ int) { return }) fn.Closure = reflect.TypeOf(opFunc1Closure{}) } diff --git a/types/inspect.go b/types/inspect.go index 51b7c3a..b2c90a9 100644 --- a/types/inspect.go +++ b/types/inspect.go @@ -7,7 +7,7 @@ import ( "math" "reflect" - coroutinev1 "github.com/stealthrocket/coroutine/gen/proto/go/coroutine/v1" + coroutinev1 "github.com/dispatchrun/coroutine/gen/proto/go/coroutine/v1" ) // Inspect inspects serialized durable coroutine state. diff --git a/types/reflect.go b/types/reflect.go index 98b313a..6500092 100644 --- a/types/reflect.go +++ b/types/reflect.go @@ -7,7 +7,7 @@ import ( "reflect" "unsafe" - coroutinev1 "github.com/stealthrocket/coroutine/gen/proto/go/coroutine/v1" + coroutinev1 "github.com/dispatchrun/coroutine/gen/proto/go/coroutine/v1" ) func serializeType(s *Serializer, t reflect.Type) { diff --git a/types/serde.go b/types/serde.go index 516d690..31d4e97 100644 --- a/types/serde.go +++ b/types/serde.go @@ -13,7 +13,7 @@ import ( "runtime" "unsafe" - coroutinev1 "github.com/stealthrocket/coroutine/gen/proto/go/coroutine/v1" + coroutinev1 "github.com/dispatchrun/coroutine/gen/proto/go/coroutine/v1" ) // sID is the unique sID of a pointer or type in the serialized format. diff --git a/types/serde_test.go b/types/serde_test.go index 8252d10..e95ed90 100644 --- a/types/serde_test.go +++ b/types/serde_test.go @@ -15,7 +15,7 @@ import ( "time" "unsafe" - coroutinev1 "github.com/stealthrocket/coroutine/gen/proto/go/coroutine/v1" + coroutinev1 "github.com/dispatchrun/coroutine/gen/proto/go/coroutine/v1" ) func TestSerdeTime(t *testing.T) { @@ -98,7 +98,7 @@ func TestReflect(t *testing.T) { intpp := &intp type ctxKey1 struct{} - RegisterFunc[func(int) int]("github.com/stealthrocket/coroutine/types.identity") + RegisterFunc[func(int) int]("github.com/dispatchrun/coroutine/types.identity") var emptyMap map[string]struct{} @@ -250,7 +250,7 @@ func TestReflectUnsafePointer(t *testing.T) { } func TestReflectFunc(t *testing.T) { - RegisterFunc[func(int) int]("github.com/stealthrocket/coroutine/types.identity") + RegisterFunc[func(int) int]("github.com/dispatchrun/coroutine/types.identity") b, err := Serialize(reflect.ValueOf(identity)) if err != nil { @@ -278,7 +278,7 @@ func TestReflectClosure(t *testing.T) { RegisterClosure[func() int, struct { F uintptr X0 int - }]("github.com/stealthrocket/coroutine/types.TestReflectClosure.func1") + }]("github.com/dispatchrun/coroutine/types.TestReflectClosure.func1") t.Run("raw", func(t *testing.T) { b, err := Serialize(fn) diff --git a/types/types.go b/types/types.go index 92a0d17..b7628bc 100644 --- a/types/types.go +++ b/types/types.go @@ -5,7 +5,7 @@ import ( "reflect" "unsafe" - coroutinev1 "github.com/stealthrocket/coroutine/gen/proto/go/coroutine/v1" + coroutinev1 "github.com/dispatchrun/coroutine/gen/proto/go/coroutine/v1" ) type typeid = uint32