mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
36 lines
1.4 KiB
Go
36 lines
1.4 KiB
Go
package nexus
|
|
|
|
import "github.com/hanzoai/tasks/common/routing"
|
|
|
|
type NamespaceAndTaskQueue struct {
|
|
Namespace string
|
|
TaskQueue string
|
|
}
|
|
|
|
var RouteDispatchNexusTaskByNamespaceAndTaskQueue = routing.NewBuilder[NamespaceAndTaskQueue]().
|
|
Constant("namespaces").
|
|
StringVariable("namespace", func(params *NamespaceAndTaskQueue) *string { return ¶ms.Namespace }).
|
|
Constant("task-queues").
|
|
StringVariable("task_queue", func(params *NamespaceAndTaskQueue) *string { return ¶ms.TaskQueue }).
|
|
Constant("nexus-services").
|
|
Build()
|
|
|
|
var RouteDispatchNexusTaskByEndpoint = routing.NewBuilder[string]().
|
|
Constant("nexus", "endpoints").
|
|
StringVariable("endpoint", func(endpoint *string) *string { return endpoint }).
|
|
Constant("services").
|
|
Build()
|
|
|
|
// RouteCompletionCallback is an HTTP route for completing a Nexus operation via callback.
|
|
var RouteCompletionCallback = routing.NewBuilder[string]().
|
|
Constant("namespaces").
|
|
StringVariable("namespace", func(namespace *string) *string { return namespace }).
|
|
Constant("nexus", "callback").
|
|
Build()
|
|
|
|
// PathCompletionCallbackNoIdentifier is an HTTP route for completing a Nexus operation via callback.
|
|
// Unlike RouteCompletionCallback it does not require any identifying information to be provided in the
|
|
// URL path. Instead the handler for this path is expected to look up identifying information through
|
|
// via the callback token in the headers.
|
|
var PathCompletionCallbackNoIdentifier = "/nexus/callback"
|