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).
98 lines
2.5 KiB
Go
98 lines
2.5 KiB
Go
package nsmanager
|
|
|
|
import (
|
|
enumspb "go.temporal.io/api/enums/v1"
|
|
"go.temporal.io/api/serviceerror"
|
|
persistencespb "github.com/hanzoai/tasks/api/persistence/v1"
|
|
"github.com/hanzoai/tasks/common/cluster"
|
|
)
|
|
|
|
type (
|
|
Validator struct {
|
|
clusterMetadata cluster.Metadata
|
|
}
|
|
)
|
|
|
|
// NewValidator create a new namespace attribute Validator
|
|
func NewValidator(
|
|
clusterMetadata cluster.Metadata,
|
|
) *Validator {
|
|
return &Validator{
|
|
clusterMetadata: clusterMetadata,
|
|
}
|
|
}
|
|
|
|
func (d *Validator) ValidateNamespaceConfig(config *persistencespb.NamespaceConfig) error {
|
|
if config.HistoryArchivalState == enumspb.ARCHIVAL_STATE_ENABLED && len(config.HistoryArchivalUri) == 0 {
|
|
return errInvalidArchivalConfig
|
|
}
|
|
if config.VisibilityArchivalState == enumspb.ARCHIVAL_STATE_ENABLED && len(config.VisibilityArchivalUri) == 0 {
|
|
return errInvalidArchivalConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (d *Validator) ValidateNamespaceReplicationConfigForLocalNamespace(
|
|
replicationConfig *persistencespb.NamespaceReplicationConfig,
|
|
) error {
|
|
activeCluster := replicationConfig.ActiveClusterName
|
|
clusters := replicationConfig.Clusters
|
|
|
|
if err := d.validateClusterName(activeCluster); err != nil {
|
|
return err
|
|
}
|
|
for _, clusterName := range clusters {
|
|
if err := d.validateClusterName(clusterName); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
if activeCluster != d.clusterMetadata.GetCurrentClusterName() {
|
|
return serviceerror.NewInvalidArgument("Invalid local namespace active cluster")
|
|
}
|
|
|
|
if len(clusters) != 1 || clusters[0] != activeCluster {
|
|
return serviceerror.NewInvalidArgument("Invalid local namespace clusters")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (d *Validator) ValidateNamespaceReplicationConfigForGlobalNamespace(
|
|
replicationConfig *persistencespb.NamespaceReplicationConfig,
|
|
) error {
|
|
activeCluster := replicationConfig.ActiveClusterName
|
|
clusters := replicationConfig.Clusters
|
|
|
|
if err := d.validateClusterName(activeCluster); err != nil {
|
|
return err
|
|
}
|
|
for _, clusterName := range clusters {
|
|
if err := d.validateClusterName(clusterName); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
activeClusterInClusters := false
|
|
for _, clusterName := range clusters {
|
|
if clusterName == activeCluster {
|
|
activeClusterInClusters = true
|
|
break
|
|
}
|
|
}
|
|
if !activeClusterInClusters {
|
|
return errActiveClusterNotInClusters
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (d *Validator) validateClusterName(
|
|
clusterName string,
|
|
) error {
|
|
if info, ok := d.clusterMetadata.GetAllClusterInfo()[clusterName]; !ok || !info.Enabled {
|
|
return serviceerror.NewInvalidArgumentf("Invalid cluster name: %v", clusterName)
|
|
}
|
|
return nil
|
|
}
|