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).
171 lines
6.9 KiB
Go
171 lines
6.9 KiB
Go
package tests
|
|
|
|
import (
|
|
"time"
|
|
|
|
enumspb "go.temporal.io/api/enums/v1"
|
|
namespacepb "go.temporal.io/api/namespace/v1"
|
|
persistencespb "github.com/hanzoai/tasks/api/persistence/v1"
|
|
"github.com/hanzoai/tasks/chasm"
|
|
"github.com/hanzoai/tasks/common/cluster"
|
|
"github.com/hanzoai/tasks/common/definition"
|
|
"github.com/hanzoai/tasks/common/dynamicconfig"
|
|
"github.com/hanzoai/tasks/common/namespace"
|
|
"github.com/hanzoai/tasks/common/persistence"
|
|
"github.com/hanzoai/tasks/common/primitives/timestamp"
|
|
"github.com/hanzoai/tasks/service/history/configs"
|
|
)
|
|
|
|
var (
|
|
Version = int64(1234)
|
|
|
|
NamespaceID = namespace.ID("deadbeef-0123-4567-890a-bcdef0123456")
|
|
Namespace = namespace.Name("mock namespace name")
|
|
ParentNamespaceID = namespace.ID("deadbeef-0123-4567-890a-bcdef0123457")
|
|
ParentNamespace = namespace.Name("mock parent namespace name")
|
|
TargetNamespaceID = namespace.ID("deadbeef-0123-4567-890a-bcdef0123458")
|
|
TargetNamespace = namespace.Name("mock target namespace name")
|
|
ChildNamespaceID = namespace.ID("deadbeef-0123-4567-890a-bcdef0123459")
|
|
ChildNamespace = namespace.Name("mock child namespace name")
|
|
StandbyNamespaceID = namespace.ID("deadbeef-0123-4567-890a-bcdef0123460")
|
|
StandbyNamespace = namespace.Name("mock standby namespace name")
|
|
StandbyWithVisibilityArchivalNamespaceID = namespace.ID("deadbeef-0123-4567-890a-bcdef0123461")
|
|
StandbyWithVisibilityArchivalNamespace = namespace.Name("mock standby with visibility archival namespace name")
|
|
MissedNamespaceID = namespace.ID("missed-namespace-id")
|
|
MissedNamespace = namespace.Name("missed-namespace-name")
|
|
WorkflowID = "mock-workflow-id"
|
|
RunID = "0d00698f-08e1-4d36-a3e2-3bf109f5d2d6"
|
|
WorkflowKey = definition.NewWorkflowKey(NamespaceID.String(), WorkflowID, RunID)
|
|
ArchetypeID = chasm.ArchetypeID(1234)
|
|
|
|
LocalNamespaceEntry = namespace.NewLocalNamespaceForTest(
|
|
&persistencespb.NamespaceInfo{Id: NamespaceID.String(), Name: Namespace.String()},
|
|
&persistencespb.NamespaceConfig{
|
|
Retention: timestamp.DurationFromDays(1),
|
|
BadBinaries: &namespacepb.BadBinaries{
|
|
Binaries: map[string]*namespacepb.BadBinaryInfo{
|
|
"lololol": nil},
|
|
},
|
|
},
|
|
cluster.TestCurrentClusterName,
|
|
)
|
|
|
|
GlobalNamespaceEntry = namespace.NewGlobalNamespaceForTest(
|
|
&persistencespb.NamespaceInfo{Id: NamespaceID.String(), Name: Namespace.String()},
|
|
&persistencespb.NamespaceConfig{
|
|
Retention: timestamp.DurationFromDays(1),
|
|
VisibilityArchivalState: enumspb.ARCHIVAL_STATE_ENABLED,
|
|
VisibilityArchivalUri: "test:///visibility/archival",
|
|
},
|
|
&persistencespb.NamespaceReplicationConfig{
|
|
ActiveClusterName: cluster.TestCurrentClusterName,
|
|
Clusters: []string{
|
|
cluster.TestCurrentClusterName,
|
|
cluster.TestAlternativeClusterName,
|
|
},
|
|
},
|
|
Version,
|
|
)
|
|
|
|
GlobalParentNamespaceEntry = namespace.NewGlobalNamespaceForTest(
|
|
&persistencespb.NamespaceInfo{Id: ParentNamespaceID.String(), Name: ParentNamespace.String()},
|
|
&persistencespb.NamespaceConfig{Retention: timestamp.DurationFromDays(1)},
|
|
&persistencespb.NamespaceReplicationConfig{
|
|
ActiveClusterName: cluster.TestCurrentClusterName,
|
|
Clusters: []string{
|
|
cluster.TestCurrentClusterName,
|
|
cluster.TestAlternativeClusterName,
|
|
},
|
|
},
|
|
Version,
|
|
)
|
|
|
|
GlobalTargetNamespaceEntry = namespace.NewGlobalNamespaceForTest(
|
|
&persistencespb.NamespaceInfo{Id: TargetNamespaceID.String(), Name: TargetNamespace.String()},
|
|
&persistencespb.NamespaceConfig{Retention: timestamp.DurationFromDays(1)},
|
|
&persistencespb.NamespaceReplicationConfig{
|
|
ActiveClusterName: cluster.TestCurrentClusterName,
|
|
Clusters: []string{
|
|
cluster.TestCurrentClusterName,
|
|
cluster.TestAlternativeClusterName,
|
|
},
|
|
},
|
|
Version,
|
|
)
|
|
|
|
GlobalStandbyNamespaceEntry = namespace.NewGlobalNamespaceForTest(
|
|
&persistencespb.NamespaceInfo{Id: StandbyNamespaceID.String(), Name: StandbyNamespace.String()},
|
|
&persistencespb.NamespaceConfig{Retention: timestamp.DurationFromDays(1)},
|
|
&persistencespb.NamespaceReplicationConfig{
|
|
ActiveClusterName: cluster.TestAlternativeClusterName,
|
|
Clusters: []string{
|
|
cluster.TestCurrentClusterName,
|
|
cluster.TestAlternativeClusterName,
|
|
},
|
|
},
|
|
Version,
|
|
)
|
|
|
|
GlobalStandbyWithVisibilityArchivalNamespaceEntry = namespace.NewGlobalNamespaceForTest(
|
|
&persistencespb.NamespaceInfo{
|
|
Id: StandbyWithVisibilityArchivalNamespaceID.String(),
|
|
Name: StandbyWithVisibilityArchivalNamespace.String(),
|
|
},
|
|
&persistencespb.NamespaceConfig{
|
|
Retention: timestamp.DurationFromDays(1),
|
|
VisibilityArchivalState: enumspb.ARCHIVAL_STATE_ENABLED,
|
|
VisibilityArchivalUri: "test:///visibility/archival",
|
|
},
|
|
&persistencespb.NamespaceReplicationConfig{
|
|
ActiveClusterName: cluster.TestAlternativeClusterName,
|
|
Clusters: []string{
|
|
cluster.TestCurrentClusterName,
|
|
cluster.TestAlternativeClusterName,
|
|
},
|
|
},
|
|
Version,
|
|
)
|
|
|
|
GlobalChildNamespaceEntry = namespace.NewGlobalNamespaceForTest(
|
|
&persistencespb.NamespaceInfo{Id: ChildNamespaceID.String(), Name: ChildNamespace.String()},
|
|
&persistencespb.NamespaceConfig{Retention: timestamp.DurationFromDays(1)},
|
|
&persistencespb.NamespaceReplicationConfig{
|
|
ActiveClusterName: cluster.TestCurrentClusterName,
|
|
Clusters: []string{
|
|
cluster.TestCurrentClusterName,
|
|
cluster.TestAlternativeClusterName,
|
|
},
|
|
},
|
|
Version,
|
|
)
|
|
|
|
CreateWorkflowExecutionResponse = &persistence.CreateWorkflowExecutionResponse{
|
|
NewMutableStateStats: persistence.MutableStateStatistics{
|
|
HistoryStatistics: &persistence.HistoryStatistics{},
|
|
},
|
|
}
|
|
|
|
GetWorkflowExecutionResponse = &persistence.GetWorkflowExecutionResponse{
|
|
MutableStateStats: persistence.MutableStateStatistics{},
|
|
}
|
|
|
|
UpdateWorkflowExecutionResponse = &persistence.UpdateWorkflowExecutionResponse{
|
|
UpdateMutableStateStats: persistence.MutableStateStatistics{
|
|
HistoryStatistics: &persistence.HistoryStatistics{},
|
|
},
|
|
NewMutableStateStats: nil,
|
|
}
|
|
)
|
|
|
|
func NewDynamicConfig() *configs.Config {
|
|
dc := dynamicconfig.NewNoopCollection()
|
|
config := configs.NewConfig(dc, 1)
|
|
config.EnableActivityEagerExecution = dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true)
|
|
config.NamespaceCacheRefreshInterval = dynamicconfig.GetDurationPropertyFn(time.Second)
|
|
config.ReplicationEnableUpdateWithNewTaskMerge = dynamicconfig.GetBoolPropertyFn(true)
|
|
config.EnableWorkflowIdReuseStartTimeValidation = dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true)
|
|
config.EnableTransitionHistory = dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true)
|
|
config.EnableChasm = dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false)
|
|
return config
|
|
}
|