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).
60 lines
1.3 KiB
Go
60 lines
1.3 KiB
Go
package tests
|
|
|
|
import (
|
|
"github.com/nexus-rpc/sdk-go/nexus"
|
|
"github.com/hanzoai/tasks/chasm"
|
|
)
|
|
|
|
type (
|
|
library struct {
|
|
chasm.UnimplementedLibrary
|
|
}
|
|
)
|
|
|
|
var Library = &library{}
|
|
|
|
func (l *library) Name() string {
|
|
return "tests"
|
|
}
|
|
|
|
func (l *library) NexusServices() []*nexus.Service {
|
|
return []*nexus.Service{NewTestServiceNexusService()}
|
|
}
|
|
|
|
func (l *library) NexusServiceProcessors() []*chasm.NexusServiceProcessor {
|
|
return []*chasm.NexusServiceProcessor{NewTestServiceNexusServiceProcessor()}
|
|
}
|
|
|
|
func (l *library) Components() []*chasm.RegistrableComponent {
|
|
return []*chasm.RegistrableComponent{
|
|
chasm.NewRegistrableComponent[*PayloadStore](
|
|
"payloadStore",
|
|
chasm.WithBusinessIDAlias("PayloadStoreId"),
|
|
chasm.WithSearchAttributes(
|
|
PayloadTotalCountSearchAttribute,
|
|
PayloadTotalSizeSearchAttribute,
|
|
ExecutionStatusSearchAttribute,
|
|
chasm.SearchAttributeTaskQueue,
|
|
),
|
|
chasm.WithContextValues(map[any]any{
|
|
componentCtxKey: componentCtxVal,
|
|
}),
|
|
),
|
|
}
|
|
}
|
|
|
|
func (l *library) Tasks() []*chasm.RegistrableTask {
|
|
return []*chasm.RegistrableTask{
|
|
chasm.NewRegistrablePureTask(
|
|
"payloadTTLPureTask",
|
|
&PayloadTTLPureTaskValidator{},
|
|
&PayloadTTLPureTaskExecutor{},
|
|
),
|
|
chasm.NewRegistrableSideEffectTask(
|
|
"payloadTTLSideEffectTask",
|
|
&PayloadTTLSideEffectTaskValidator{},
|
|
&PayloadTTLSideEffectTaskExecutor{},
|
|
),
|
|
}
|
|
}
|