Function NewNamespaceConfig

schema/sqlite/setup.go:113–167

NewNamespaceConfig initializes a NamespaceConfig with the field values needed to pre-register the namespace via the CreateNamespaces function. Note: this function may receive breaking changes or be removed in the future.

(
	activeClusterName string,
	namespace string,
	global bool,
	customSearchAttributes map[string]enumspb.IndexedValueType,
)

//
// Note: this function may receive breaking changes or be removed in the future.
func NewNamespaceConfig(
	activeClusterName string,
	namespace string,
	global bool,
	customSearchAttributes map[string]enumspb.IndexedValueType,
) (*NamespaceConfig, error) {
	dbCustomSearchAttributes := sadefs.GetDBIndexSearchAttributes(nil).CustomSearchAttributes
	fieldToAliasMap := map[string]string{}
	for saName, saType := range customSearchAttributes {
		var targetFieldName string
		var cntUsed int
		for fieldName, fieldType := range dbCustomSearchAttributes {
			if fieldType != saType {
				continue
			}
			if _, ok := fieldToAliasMap[fieldName]; !ok {
				targetFieldName = fieldName
				break
			}
			cntUsed++
		}
		if targetFieldName == "" {
			return nil, fmt.Errorf(
				"cannot have more than %d search attributes of type %s",
				cntUsed,
				saType,
			)
		}
		fieldToAliasMap[targetFieldName] = saName
	}

	detail := persistencespb.NamespaceDetail{
		Info: &persistencespb.NamespaceInfo{
			Id:    primitives.NewUUID().String(),
			State: enumspb.NAMESPACE_STATE_REGISTERED,
			Name:  namespace,
		},
		Config: &persistencespb.NamespaceConfig{
			Retention:                    timestamp.DurationFromHours(24),
			HistoryArchivalState:         enumspb.ARCHIVAL_STATE_DISABLED,
			VisibilityArchivalState:      enumspb.ARCHIVAL_STATE_DISABLED,
			CustomSearchAttributeAliases: fieldToAliasMap,
		},
		ReplicationConfig: &persistencespb.NamespaceReplicationConfig{
			ActiveClusterName: activeClusterName,
			Clusters:          []string{activeClusterName},
		},
		FailoverVersion:             common.EmptyVersion,
		FailoverNotificationVersion: -1,
	}
	return &NamespaceConfig{
		Detail:   &detail,
		IsGlobal: global,
	}, nil
}

func createNamespaceIfNotExists(db sqlplugin.DB, namespace *NamespaceConfig) error {
	var (