non-retryable-rpc-error

go.temporal.io/server/chasm/tree.go 462 covered LOC · 154 ranges

Open complete file

301 logger log.Logger,

302 metricsHandler metrics.Handler,

303 > ) *Node { tree.go

304 > root := newTreeHelper(registry, timeSource, backend, pathEncoder, logger, metricsHandler)

305 >

306 > // If serializedNodes is empty, it means that this new tree.

307 > // Initialize empty serializedNode.

308 > root.initSerializedNode(fieldTypeComponent)

309 > // Default to Workflow archetype as empty tree is created for workflow as well.

310 > root.serializedNode.Metadata.GetComponentAttributes().TypeId = WorkflowArchetypeID

311 > // Although both value and serializedNode.Data are nil, they are considered NOT synced

312 > // because value has no type and serializedNode does.

313 > // deserialize method should set value when called.

314 > root.setValueState(valueStateNeedDeserialize)

315 > return root

316 > }

317

318 func newTreeHelper(

323 logger log.Logger,

324 metricsHandler metrics.Handler,

325 > ) *Node { tree.go

326 > base := &nodeBase{

327 > registry: registry,

328 > timeSource: timeSource,

329 > backend: backend,

330 > pathEncoder: pathEncoder,

331 > logger: logger,

332 > metricsHandler: metricsHandler,

333 >

334 > mutation: NodesMutation{

335 > UpdatedNodes: make(map[string]*persistencespb.ChasmNode),

336 > DeletedNodes: make(map[string]struct{}),

337 > },

338 > systemMutation: NodesMutation{

339 > UpdatedNodes: make(map[string]*persistencespb.ChasmNode),

340 > DeletedNodes: make(map[string]struct{}),

341 > },

342 > newTasks: make(map[any][]taskWithAttributes),

343 > immediatePureTasks: make(map[any][]taskWithAttributes),

344 > pendingRequestLinks: make(map[any]map[string][]*commonpb.Link),

345 > pendingUserMetadata: make(map[any]*sdkpb.UserMetadata),

346 > valueToNode: make(map[any]*Node),

347 > taskValueCache: make(map[*commonpb.DataBlob]reflect.Value),

348 > needsPointerResolution: false,

349 > }

350 >

351 > return newNode(base, nil, "")

352 > }

353

354 func newTreeInitSearchAttributesAndMemo(

387 func (n *Node) SetRootComponent(

388 rootComponent RootComponent,

389 > ) error { tree.go

390 > root := n.root()

391 > root.setValue(rootComponent)

392 > root.setValueState(valueStateNeedSyncStructure)

393 > if componentID, ok := n.registry.ComponentIDFor(rootComponent); ok {

394 > root.serializedNode.GetMetadata().GetComponentAttributes().TypeId = componentID

395 > }

396 > return root.syncSubComponents()

397 }

398

400 // If the node is a component or data node, the index from node value to node (valueToNode)

401 // is also updated.

402 > func (n *Node) setValue(value any) { tree.go

403 > if !n.isComponent() && !n.isData() {

404 n.value = value

405 return

406 }

407

408 > if n.value != nil { tree.go

409 delete(n.valueToNode, n.value)

410 }

411

412 > n.value = value tree.go

413 >

414 > if value != nil {

415 > n.valueToNode[value] = n

416 > }

417 }

418

419 > func (n *Node) setValueState(state valueState) { tree.go

420 > n.valueState = state

421 > if state >= valueStateNeedSerialize {

422 > n.markSubtreeDirty() tree.go

423 > }

424 }

425

429 // markSubtreeDirty marks this node and its entire lineage (ancestors and descendants)

430 // as dirty so that CloseTransaction knows to validate their tasks.

431 > func (n *Node) markSubtreeDirty() { tree.go

432 > // Propagate upward to ancestors.

433 > for cur := n; cur != nil && !cur.subtreeIsDirty; cur = cur.parent {

434 > cur.subtreeIsDirty = true

435 > }

436 // Propagate downward to descendants.

437 > for _, desc := range n.andAllChildren() { tree.go

438 > desc.subtreeIsDirty = true

439 > }

440 }

441

458 chasmContext Context,

459 ref ComponentRef,

460 > ) (Component, error) { tree.go

461 > // Archetype is already validated before this method is called.

462 > // (when the mutable state is loaded, in chasm engine implementation)

463 >

464 > node, ok := n.findNode(ref.componentPath)

465 > if !ok {

466 return nil, errComponentNotFound

467 }

468

469 > if ref.componentInitialVT != nil && transitionhistory.Compare( tree.go

470 > ref.componentInitialVT,

471 > node.serializedNode.Metadata.InitialVersionedTransition,

472 > ) != 0 {

473 return nil, errComponentNotFound

474 }

475

476 > validationContext := NewContext(chasmContext.goContext(), node) tree.go

477 > if err := node.prepareComponentValue(validationContext); err != nil {

478 return nil, err

479 }

480

481 > componentValue, ok := node.value.(Component) tree.go

482 > if !ok {

483 return nil, softassert.UnexpectedInternalErr(

484 n.logger,

487 }

488

489 > if err := node.validateAccess(validationContext, false); err != nil { tree.go

490 return nil, err

491 }

492

493 > if ref.validationFn != nil { tree.go

494 if err := ref.validationFn(node.root().backend, validationContext, componentValue, node.registry); err != nil {

495 return nil, err

498

499 // prepare component value again using incoming context to mark node as dirty if needed.

500 > if err := node.prepareComponentValue(chasmContext); err != nil { tree.go

501 return nil, err

502 }

503 > return componentValue, nil tree.go

504 }

505

517 // Note: engine mutations on paused components are still accepted (checkPaused=false),

518 // per the current requirement.

519 > func (n *Node) validateAccess(ctx Context, checkPaused bool) error { tree.go

520 > intent := operationIntentFromContext(ctx.goContext())

521 > if intent != OperationIntentProgress {

522 > // Read-only operations are always allowed. tree.go

523 > return nil

524 > }

525

526 // Detached nodes skip ancestor validation entirely.

598 func (n *Node) prepareComponentValue(

599 chasmContext Context,

600 > ) error { tree.go

601 > if n.valueState == valueStateNeedDeserialize {

602 metadata := n.serializedNode.Metadata

603 componentAttr := metadata.GetComponentAttributes()

624 // For now, we assume if a node is accessed with a MutableContext,

625 // its value will be mutated and no longer in sync with the serializedNode.

626 > _, componentCanBeMutated := chasmContext.(MutableContext) tree.go

627 > if componentCanBeMutated {

628 n.setValueState(valueStateNeedSyncStructure)

629 }

630

631 > return nil tree.go

632 }

633

680 }

681

682 > func (n *Node) isComponent() bool { tree.go

683 > return n.serializedNode.GetMetadata().GetComponentAttributes() != nil

684 > }

685

686 func (n *Node) isData() bool {

688 }

689

690 > func (n *Node) isMap() bool { tree.go

691 > return n.serializedNode.GetMetadata().GetCollectionAttributes() != nil

692 > }

693

694 func (n *Node) isDetached() bool {

707 }

708

709 > func (n *Node) fieldType() fieldType { tree.go

710 > if n.serializedNode.GetMetadata().GetComponentAttributes() != nil {

711 > return fieldTypeComponent tree.go

712 > }

713

714 if n.serializedNode.GetMetadata().GetDataAttributes() != nil {

729 }

730

731 > func (n *Node) valueFields() iter.Seq[fieldInfo] { tree.go

732 > return fieldsOf(reflect.ValueOf(n.value))

733 > }

734

735 > func assertStructPointer(t reflect.Type) error { tree.go

736 > if t == nil {

737 return nil

738 }

739

740 > if t.Kind() != reflect.Pointer || t.Elem().Kind() != reflect.Struct { tree.go

741 return serviceerror.NewInternalf("only pointer to struct is supported for tree node value: got %s", t.String())

742 }

743 > return nil tree.go

744 }

745

746 > func (n *Node) initSerializedNode(ft fieldType) { tree.go

747 > switch ft {

748 case fieldTypeData:

749 n.serializedNode = &persistencespb.ChasmNode{

758 },

759 }

760 > case fieldTypeComponent: tree.go

761 > n.serializedNode = &persistencespb.ChasmNode{

762 > Metadata: &persistencespb.ChasmNodeMetadata{

763 > InitialVersionedTransition: &persistencespb.VersionedTransition{

764 > TransitionCount: n.backend.NextTransitionCount(),

765 > NamespaceFailoverVersion: n.backend.GetCurrentVersion(),

766 > },

767 > Attributes: &persistencespb.ChasmNodeMetadata_ComponentAttributes{

768 > ComponentAttributes: &persistencespb.ChasmComponentAttributes{},

769 > },

770 > },

771 > }

772 case fieldTypePointer, fieldTypeDeferredPointer:

773 // A deferred pointer will be resolved to a regular pointer before persistence.

833 // serialize sets or updates serializedValue field of the node n with serialized value.

834 // It sets node's valueState to valueStateSynced and updates LastUpdateVersionedTransition.

835 > func (n *Node) serialize() error { tree.go

836 > switch n.serializedNode.GetMetadata().GetAttributes().(type) {

837 > case *persistencespb.ChasmNodeMetadata_ComponentAttributes: tree.go

838 > return n.serializeComponentNode()

839 case *persistencespb.ChasmNodeMetadata_DataAttributes:

840 return n.serializeDataNode()

852 // LastUpdateVersionedTransition, the skip-if-clean revert logic in

853 // closeTransactionSerializeNodes must be updated accordingly.

854 > func (n *Node) serializeComponentNode() error { tree.go

855 > for field := range n.valueFields() {

856 > if field.err != nil {

857 return field.err

858 }

859

860 > if field.kind != fieldKindData { tree.go

861 > continue tree.go

862 }

863

864 > var blob *commonpb.DataBlob tree.go

865 > if !field.val.IsNil() {

866 > var err error tree.go

867 > if blob, err = encodeChasmBlob(field.val.Interface().(proto.Message)); err != nil {

868 return err

869 }

870 }

871

872 > n.serializedNode.Data = blob tree.go

873 >

874 > if n.serializedNode.GetMetadata().GetLastUpdateVersionedTransition() == nil {

875 > rc, ok := n.registry.componentFor(n.value) tree.go

876 > if !ok {

877 return softassert.UnexpectedInternalErr(

878 n.logger,

881 }

882 // TypeId mismatch on a brand new node indicates node reassignment.

883 > existingTypeID := n.serializedNode.GetMetadata().GetComponentAttributes().GetTypeId() tree.go

884 > if existingTypeID != 0 && existingTypeID != rc.componentID {

885 return softassert.UnexpectedInternalErr(

886 n.logger,

889 )

890 }

891 > n.serializedNode.GetMetadata().GetComponentAttributes().TypeId = rc.componentID tree.go

892 }

893

894 > n.updateLastUpdateVersionedTransition() tree.go

895 > n.setValueState(valueStateSynced)

896

897 // continue to iterate over fields to validate that there is only one proto field in the component.

898 }

899 > return nil tree.go

900 }

901

915 //

916 // nolint:revive,cognitive-complexity

917 > func (n *Node) syncSubComponents() error { tree.go

918 > if n.valueState < valueStateNeedSyncStructure {

919 > for _, childNode := range n.children { tree.go

920 > err := childNode.syncSubComponents() tree.go

921 > if err != nil {

922 return err

923 }

924 }

925 > return nil tree.go

926 }

927

928 > childrenToKeep := make(map[string]struct{}) tree.go

929 > for field := range n.valueFields() {

930 > if field.err != nil {

931 return field.err

932 }

933

934 > switch field.kind { tree.go

935 case fieldKindUnspecified:

936 softassert.Fail(n.logger,

937 "field.kind can be unspecified only if err is not nil, and there is a check for it above")

938 > case fieldKindData: tree.go

939 // Nothing to sync.

940 > case fieldKindSubField: tree.go

941 > keepChild, updatedFieldV, err := n.syncSubField(field.val, field.name)

942 > if err != nil {

943 return err

944 }

945 > if updatedFieldV.IsValid() { tree.go

946 > field.val.Set(updatedFieldV) tree.go

947 > }

948 > if keepChild { tree.go

949 > childrenToKeep[field.name] = struct{}{} tree.go

950 > }

951 > case fieldKindParentPtr: tree.go

952 > internalField := field.val.FieldByName(parentPtrInternalFieldName)

953 > internal, ok := internalField.Interface().(parentPtrInternal)

954 > if !ok {

955 return softassert.UnexpectedInternalErr(

956 n.logger,

958 fmt.Errorf("node %s, actual type: %T", n.nodeName, internalField.Interface()))

959 }

960 > if internal.currentNode == nil || internal.currentNode != n { tree.go

961 > internal.currentNode = n tree.go

962 > internalField.Set(reflect.ValueOf(internal))

963 > }

964 case fieldKindSubMap:

965 // Validate map type before doing anything with it.

1020 }

1021

1022 > err := n.deleteChildren(childrenToKeep) tree.go

1023 > n.setValueState(valueStateNeedSerialize)

1024 >

1025 > return err

1026 }

1027

1135 updatedFieldV reflect.Value,

1136 err error,

1137 > ) { tree.go

1138 > internalV := fieldV.FieldByName(internalFieldName)

1139 > //nolint:revive // Internal field is guaranteed to be of type fieldInternal.

1140 > internal := internalV.Interface().(fieldInternal)

1141 > if internal.isEmpty() {

1142 // Internal is empty only when Field was explicitly set to NewEmptyField[T] which is a way to clear its value.

1143 // In this case, return keepNode=false and this node (and all it children) will be added to DeletedNodes map.

1145 }

1146

1147 > fieldValue := internal.value() tree.go

1148 > if internal.node == nil && fieldValue != nil {

1149 > fieldType := internal.fieldType() tree.go

1150 >

1151 > // Field is not empty but tree node is not set. It means this is a new field, and a node must be created.

1152 > childNode := newNode(n.nodeBase, n, fieldN)

1153 > childNode.initSerializedNode(fieldType)

1154 > childNode.setValueState(valueStateNeedSerialize)

1155 >

1156 > // set node value after validation

1157 > switch fieldType {

1158 > case fieldTypeComponent: tree.go

1159 > if err = assertStructPointer(reflect.TypeOf(fieldValue)); err != nil {

1160 return

1161 }

1162

1163 > childNode.setValueState(valueStateNeedSyncStructure) tree.go

1164 >

1165 > // Set detached flag from field option or component type registration.

1166 > componentAttr := childNode.serializedNode.GetMetadata().GetComponentAttributes()

1167 > componentAttr.Detached = internal.detached

1168 > if !componentAttr.Detached {

1169 > if rc, ok := n.registry.componentFor(fieldValue); ok {

1170 > componentAttr.Detached = rc.IsDetached()

1171 > }

1172 }

1173 case fieldTypeData:

1193 return

1194 }

1195 > childNode.setValue(fieldValue) tree.go

1196 >

1197 > n.children[fieldN] = childNode

1198 > internal.node = childNode

1199 >

1200 > updatedFieldV = reflect.New(fieldV.Type()).Elem()

1201 > updatedFieldV.FieldByName(internalFieldName).Set(reflect.ValueOf(internal))

1202 }

1203

1204 > if internal.fieldType() == fieldTypeComponent && internal.value() != nil { tree.go

1205 > err = internal.node.syncSubComponents() tree.go

1206 > if err != nil {

1207 return

1208 }

1209 }

1210

1211 > return true, updatedFieldV, nil tree.go

1212 }

1213

1214 func (n *Node) deleteChildren(

1215 childrenToKeep map[string]struct{},

1216 > ) error { tree.go

1217 > for childName, childNode := range n.children {

1218 > if _, childToKeep := childrenToKeep[childName]; !childToKeep { tree.go

1219 if err := childNode.delete(false); err != nil {

1220 return err

1222 }

1223 }

1224 > return nil tree.go

1225 }

1226

1277 }

1278

1279 > func (n *Node) updateLastUpdateVersionedTransition() { tree.go

1280 > if n.serializedNode.GetMetadata().GetLastUpdateVersionedTransition() == nil {

1281 > n.serializedNode.GetMetadata().LastUpdateVersionedTransition = &persistencespb.VersionedTransition{} tree.go

1282 > }

1283 > n.serializedNode.GetMetadata().GetLastUpdateVersionedTransition().TransitionCount = n.backend.NextTransitionCount() tree.go

1284 > n.serializedNode.GetMetadata().GetLastUpdateVersionedTransition().NamespaceFailoverVersion = n.backend.GetCurrentVersion()

1285 }

1286

1560 // reference a component that was never registered as a node are dropped and

1561 // logged at warn level to surface caller misuse.

1562 > func (n *Node) closeTransactionApplyPendingComponentMetadata() error { tree.go

1563 > if len(n.pendingRequestLinks) == 0 && len(n.pendingUserMetadata) == 0 {

1564 > return nil

1565 > }

1566 for _, node := range n.andAllChildren() {

1567 if !node.applyPendingComponentMetadata() {

1663 func (n *Node) Now(

1664 _ Component,

1665 > ) time.Time { tree.go

1666 > // TODO: Now() could be different for components after we support Pause for CHASM components.

1667 > return n.timeSource.Now()

1668 > }

1669

1670 // AddTask implements the CHASM MutableContext interface

1692 // CloseTransaction is used by MutableState to close the transaction and

1693 // track changes made in the current transaction.

1694 > func (n *Node) CloseTransaction() (NodesMutation, error) { tree.go

1695 > defer n.cleanupTransaction()

1696 >

1697 > if err := n.executeImmediatePureTasks(); err != nil {

1698 return NodesMutation{}, err

1699 }

1700

1701 > if err := n.syncSubComponents(); err != nil { tree.go

1702 return NodesMutation{}, err

1703 }

1704

1705 > if n.needsPointerResolution { tree.go

1706 if err := n.resolveDeferredPointers(); err != nil {

1707 return NodesMutation{}, err

1709 }

1710

1711 > nextVersionedTransition := &persistencespb.VersionedTransition{ tree.go

1712 > NamespaceFailoverVersion: n.backend.GetCurrentVersion(),

1713 > TransitionCount: n.backend.NextTransitionCount(),

1714 > }

1715 >

1716 > immutableContext := NewContext(context.TODO(), n)

1717 > rootLifecycleChanged, err := n.closeTransactionHandleRootLifecycleChange(immutableContext)

1718 > if err != nil {

1719 return NodesMutation{}, err

1720 }

1721

1722 > if n.subtreeIsDirty { tree.go

1723 > if err := n.closeTransactionForceUpdateVisibility(immutableContext, rootLifecycleChanged); err != nil { tree.go

1724 return NodesMutation{}, err

1725 }

1726 }

1727

1728 > if err := n.closeTransactionSerializeNodes(); err != nil { tree.go

1729 return NodesMutation{}, err

1730 }

1731

1732 > if err := n.closeTransactionUpdateComponentTasks(nextVersionedTransition); err != nil { tree.go

1733 return NodesMutation{}, err

1734 }

1735

1736 > if err := n.closeTransactionApplyPendingComponentMetadata(); err != nil { tree.go

1737 return NodesMutation{}, err

1738 }

1739

1740 // Both user & system data mutation need to be returned and persisted.

1741 > maps.Copy(n.mutation.UpdatedNodes, n.systemMutation.UpdatedNodes) tree.go

1742 > maps.Copy(n.mutation.DeletedNodes, n.systemMutation.DeletedNodes)

1743 >

1744 > return n.mutation, nil

1745 }

1746

1747 > func (n *Node) executeImmediatePureTasks() error { tree.go

1748 >

1749 > // We must sync structure before running any tasks here because,

1750 > // those tasks might be for a newly created component which doesn't even have a node yet.

1751 > // And we want to make sure we only run tasks for components that are still part of the tree.

1752 > syncStructure := true

1753 > var err error

1754 >

1755 > for len(n.immediatePureTasks) != 0 {

1756 // Create a map in case more immediate pure tasks get

1757 // added while existing ones are executed.

1786 }

1787

1788 > return nil tree.go

1789 }

1790

1791 func (n *Node) closeTransactionHandleRootLifecycleChange(

1792 immutableContext Context,

1793 > ) (bool, error) { tree.go

1794 > if n.backend.IsWorkflow() {

1795 // Workflow manages its lifecycle directly in mutable state.

1796 return false, nil

1797 }

1798

1799 > if n.valueState != valueStateNeedSerialize { tree.go

1800 return false, nil

1801 }

1802

1803 > if n.backend.GetExecutionState().State == enumsspb.WORKFLOW_EXECUTION_STATE_COMPLETED { tree.go

1804 // Already in completed state, no need to update lifecycle state.

1805 return false, nil

1806 }

1807

1808 > if n.terminated { tree.go

1809 return n.backend.UpdateWorkflowStateStatus(

1810 enumsspb.WORKFLOW_EXECUTION_STATE_COMPLETED,

1813 }

1814

1815 > rootComponent, err := n.Component(immutableContext, ComponentRef{}) tree.go

1816 > if err != nil {

1817 return false, err

1818 }

1819 > lifecycleState := rootComponent.LifecycleState(immutableContext) tree.go

1820 >

1821 > var newState enumsspb.WorkflowExecutionState

1822 > var newStatus enumspb.WorkflowExecutionStatus

1823 > switch lifecycleState {

1824 > case LifecycleStateRunning, LifecycleStatePaused:

1825 > // Paused is an OPEN state; the execution remains RUNNING from the persistence perspective.

1826 > newState = enumsspb.WORKFLOW_EXECUTION_STATE_RUNNING

1827 > newStatus = enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING

1828 case LifecycleStateCompleted:

1829 newState = enumsspb.WORKFLOW_EXECUTION_STATE_COMPLETED

1839 }

1840

1841 > return n.backend.UpdateWorkflowStateStatus(newState, newStatus) tree.go

1842 }

1843

1845 immutableContext Context,

1846 rootLifecycleChanged bool,

1847 > ) error { tree.go

1848 > if n.deleteAfterClose {

1849 return nil

1850 }

1851

1852 > if !rootLifecycleChanged && tree.go

1853 > n.backend.GetExecutionState().State == enumsspb.WORKFLOW_EXECUTION_STATE_COMPLETED {

1854 return nil

1855 }

1856

1857 > needUpdate := rootLifecycleChanged tree.go

1858 >

1859 > rootComponent, err := n.Component(immutableContext, ComponentRef{})

1860 > if err != nil {

1861 return err

1862 }

1863

1864 > saProvider, ok := rootComponent.(VisibilitySearchAttributesProvider) tree.go

1865 > if ok {

1866 saSlice := saProvider.SearchAttributes(immutableContext)

1867 newSA := searchAttributeKeyValuesToMap(saSlice)

1872 }

1873

1874 > memoProvider, ok := rootComponent.(VisibilityMemoProvider) tree.go

1875 > if ok {

1876 newMemo := memoProvider.Memo(immutableContext)

1877 if !proto.Equal(n.currentMemo, newMemo) {

1881 }

1882

1883 > if !needUpdate { tree.go

1884 > return nil tree.go

1885 > }

1886

1887 var visibilityNode *Node

1933 }

1934

1935 > func (n *Node) closeTransactionSerializeNodes() error { tree.go

1936 > for nodePath, node := range n.andAllChildren() {

1937 > if node.valueState > valueStateNeedSerialize {

1938 return serviceerror.NewInternalf("invalid valueState for serializing: %v", node.valueState)

1939 }

1940

1941 > if node.valueState < valueStateNeedSerialize { tree.go

1942 continue

1943 }

1944

1945 > encodedPath, err := node.getEncodedPath() tree.go

1946 > if err != nil {

1947 return err

1948 }

1952 // prevData captures the pre-serialize blob pointer; serialize() allocates a new

1953 // blob, leaving prevData pointing at the original for comparison.

1954 > prevVersionedTransition := common.CloneProto( tree.go

1955 > node.serializedNode.GetMetadata().GetLastUpdateVersionedTransition(),

1956 > )

1957 > skipIfClean := (node.isComponent() || node.isData() || node.isMap()) &&

1958 > prevVersionedTransition != nil &&

1959 > !node.hasNewTransactionSideEffects()

1960 > var prevData *commonpb.DataBlob

1961 > if skipIfClean {

1962 prevData = node.serializedNode.Data

1963 }

1964

1965 > if err := node.serialize(); err != nil { tree.go

1966 return err

1967 }

1968

1969 // Data bytes unchanged: revert the versioned transition bump and skip persistence.

1970 > if skipIfClean && bytes.Equal(prevData.GetData(), node.serializedNode.Data.GetData()) { tree.go

1971 node.serializedNode.GetMetadata().LastUpdateVersionedTransition = prevVersionedTransition

1972 continue

1973 }

1974

1975 > if componentAttr := node.serializedNode.GetMetadata().GetComponentAttributes(); componentAttr != nil && tree.go

1976 > componentAttr.TypeId == visibilityComponentTypeID &&

1977 > len(nodePath) != 1 {

1978 return softassert.UnexpectedInternalErr(

1979 n.logger,

1982 }

1983

1984 > n.mutation.UpdatedNodes[encodedPath] = node.serializedNode tree.go

1985 > // DeletedNodes map is populated when syncing tree structure. However, since we may sync tree structure

1986 > // multiple times in one transaction, if node at the same path was previously deleted, have structure synced,

1987 > // then get re-created, the same encoded path will exists in both UpdatedNodes and DeletedNodes maps.

1988 > //

1989 > // serializeNode only happens once at the end of a transaction, and here we know the node at this encoded path exists,

1990 > // remove it from the DeletedNodes map.

1991 > delete(n.mutation.DeletedNodes, encodedPath)

1992 }

1993

1994 > return nil tree.go

1995 }

1996

1997 func (n *Node) closeTransactionUpdateComponentTasks(

1998 nextVersionedTransition *persistencespb.VersionedTransition,

1999 > ) error { tree.go

2000 > taskOffset := int64(1)

2001 > taskValidationContext := NewContext(newContextWithOperationIntent(context.Background(), OperationIntentProgress), n)

2002 >

2003 > archetypeID := n.ArchetypeID()

2004 >

2005 > var firstPureTask *persistencespb.ChasmComponentAttributes_Task

2006 > var firstPureTaskNode *Node

2007 >

2008 > for nodePath, node := range n.andAllChildren() {

2009 > // no-op if node is not a component

2010 > componentAttr := node.serializedNode.Metadata.GetComponentAttributes()

2011 > if componentAttr == nil {

2012 continue

2013 }

2021 // markSubtreeDirty propagates to both ancestors and descendants at mutation time,

2022 // so we skip validation only for nodes with no dirty node anywhere in their lineage.

2023 > if node.subtreeIsDirty { tree.go

2024 > // Ensure this node's component value is hydrated before cleaning up tasks. tree.go

2025 > if err := node.prepareComponentValue(taskValidationContext); err != nil {

2026 return err

2027 }

2028

2029 > cleanedUp, err := node.closeTransactionCleanupInvalidTasks(taskValidationContext) tree.go

2030 > if err != nil {

2031 return err

2032 }

2033

2034 > if cleanedUp { tree.go

2035 // add the current node to UpdatedNodes map if it's not already there

2036 encodedPath, err := node.getEncodedPath()

2054 // This method is called after the closeTransactionSerializeNodes which sets valueState

2055 // to valueStateSynced.

2056 > if transitionhistory.Compare( tree.go

2057 > node.serializedNode.GetMetadata().LastUpdateVersionedTransition,

2058 > nextVersionedTransition,

2059 > ) == 0 && node.valueState != valueStateNeedDeserialize {

2060 > if err := node.closeTransactionHandleNewTasks( tree.go

2061 > nextVersionedTransition,

2062 > taskValidationContext,

2063 > &taskOffset,

2064 > ); err != nil {

2065 return err

2066 }

2067 }

2068

2069 > sideEffectTasks := componentAttr.GetSideEffectTasks() tree.go

2070 > for idx := len(sideEffectTasks) - 1; idx >= 0; idx-- {

2071 sideEffectTask := sideEffectTasks[idx]

2072 if sideEffectTask.PhysicalTaskStatus == physicalTaskStatusCreated {

2083 // Find the first pure task in the entire tree,

2084 // regardless if the pure task is newly added or existing.

2085 > pureTasks := componentAttr.GetPureTasks() tree.go

2086 > if len(pureTasks) == 0 {

2087 > continue tree.go

2088 }

2089

2101 // task, and that component get deleted by the second task.

2102

2103 > return n.closeTransactionGeneratePhysicalPureTask( tree.go

2104 > firstPureTask,

2105 > firstPureTaskNode,

2106 > archetypeID,

2107 > )

2108 }

2109

2164 func (n *Node) closeTransactionCleanupInvalidTasks(

2165 validateContext Context,

2166 > ) (bool, error) { tree.go

2167 > // Validate existing tasks and remove invalid ones.

2168 > var validationErr error

2169 > cleanedUp := false

2170 > deleteFunc := func(existingTask *persistencespb.ChasmComponentAttributes_Task) bool {

2171 existingTaskInstance, err := n.deserializeComponentTask(existingTask)

2172 if err != nil {

2196 }

2197

2198 > componentAttr := n.serializedNode.Metadata.GetComponentAttributes() tree.go

2199 > componentAttr.SideEffectTasks = slices.DeleteFunc(componentAttr.SideEffectTasks, deleteFunc)

2200 > if validationErr != nil {

2201 return false, validationErr

2202 }

2203 > componentAttr.PureTasks = slices.DeleteFunc(componentAttr.PureTasks, deleteFunc) tree.go

2204 > if validationErr != nil {

2205 return false, validationErr

2206 }

2207 > return cleanedUp, nil tree.go

2208 }

2209

2242 validateContext Context,

2243 taskOffset *int64,

2244 > ) error { tree.go

2245 > newTasks, ok := n.newTasks[n.value]

2246 > if !ok {

2247 > return nil tree.go

2248 > }

2249

2250 componentAttr := n.serializedNode.Metadata.GetComponentAttributes()

2346 firstTaskNode *Node,

2347 archetypeID ArchetypeID,

2348 > ) error { tree.go

2349 > if firstPureTask == nil {

2350 > n.backend.DeleteCHASMPureTasks(tasks.MaximumKey.FireTime) tree.go

2351 > return nil

2352 > }

2353

2354 firstPureTaskScheduledTime := firstPureTask.ScheduledTime.AsTime()

2445 // andAllChildren returns a sequence of all nodes in the tree starting from n, including n itself.

2446 // The sequence is depth-first, pre-order traversal.

2447 > func (n *Node) andAllChildren() iter.Seq2[[]string, *Node] { tree.go

2448 > return func(yield func([]string, *Node) bool) {

2449 > var walk func([]string, *Node) bool

2450 > walk = func(path []string, node *Node) bool {

2451 > if node == nil {

2452 return true

2453 }

2454 > if !yield(path, node) { tree.go

2455 return false

2456 }

2457 > for _, child := range node.children { tree.go

2458 > childPath := make([]string, len(path)+1) tree.go

2459 > copy(childPath, path)

2460 > childPath[len(path)] = child.nodeName

2461 > if !walk(childPath, child) {

2462 return false

2463 }

2464 }

2465 > return true tree.go

2466 }

2467 > walk(nil, n) tree.go

2468 }

2469 }

2470

2471 > func (n *Node) cleanupTransaction() { tree.go

2472 > n.mutation = NodesMutation{

2473 > UpdatedNodes: make(map[string]*persistencespb.ChasmNode),

2474 > DeletedNodes: make(map[string]struct{}),

2475 > }

2476 >

2477 > // System mutation are most likely to be empty, so we reuse existing ones if possible.

2478 > if len(n.systemMutation.UpdatedNodes) != 0 {

2479 n.systemMutation.UpdatedNodes = make(map[string]*persistencespb.ChasmNode)

2480 }

2481 > if len(n.systemMutation.DeletedNodes) != 0 { tree.go

2482 n.systemMutation.DeletedNodes = make(map[string]struct{})

2483 }

2484

2485 > n.newTasks = make(map[any][]taskWithAttributes) tree.go

2486 > if len(n.immediatePureTasks) != 0 {

2487 // n.immediatePureTasks should already be empty after executeImmediatePureTasks()

2488 // unless there's an error.

2490 }

2491

2492 > if len(n.pendingRequestLinks) != 0 { tree.go

2493 n.pendingRequestLinks = make(map[any]map[string][]*commonpb.Link)

2494 }

2495 > if len(n.pendingUserMetadata) != 0 { tree.go

2496 n.pendingUserMetadata = make(map[any]*sdkpb.UserMetadata)

2497 }

2498

2499 > n.needsPointerResolution = false tree.go

2500 >

2501 > // Reset per-node subtreeIsDirty on all nodes in the tree.

2502 > for _, node := range n.andAllChildren() {

2503 > node.subtreeIsDirty = false

2504 > }

2505 }

2506

2931 }

2932

2933 > func (n *Node) getEncodedPath() (string, error) { tree.go

2934 > if n.encodedPath != nil {

2935 return *n.encodedPath, nil

2936 }

2937 > encodePath, err := n.pathEncoder.Encode(n, n.path()) tree.go

2938 > if err == nil {

2939 > n.encodedPath = &encodePath

2940 > }

2941 > return encodePath, err

2942 }

2943

2944 > func (n *Node) path() []string { tree.go

2945 > if n.parent == nil {

2946 > return []string{}

2947 > }

2948

2949 > return append(n.parent.path(), n.nodeName) tree.go

2950 }

2951

2952 func (n *Node) findNode(

2953 path []string,

2954 > ) (*Node, bool) { tree.go

2955 > if len(path) == 0 {

2956 > return n, true

2957 > }

2958

2959 childName := path[0]

3115

3116 // ArchetypeID returns the framework's internal ID for the root component's fully qualified name.

3117 > func (n *Node) ArchetypeID() ArchetypeID { tree.go

3118 > // Root must be a component.

3119 > return n.root().serializedNode.Metadata.GetComponentAttributes().GetTypeId()

3120 > }

3121

3122 // Archetype returns the root component's fully qualified name.

3136 }

3137

3138 > func (n *Node) root() *Node { tree.go

3139 > if n.parent == nil {

3140 > return n

3141 > }

3142 return n.parent.root()

3143 }

3261 parent *Node,

3262 nodeName string,

3263 > ) *Node { tree.go

3264 > return &Node{

3265 > nodeBase: base,

3266 > parent: parent,

3267 > children: make(map[string]*Node),

3268 > nodeName: nodeName,

3269 > }

3270 > }

3271

3272 func compareSideEffectTasks(a, b *persistencespb.ChasmComponentAttributes_Task) int {

3868 // encodeChasmBlob encodes CHASM data and task payloads through the env-aware

3869 // serializer while preserving deterministic proto3 bytes for byte comparisons.

3870 > func encodeChasmBlob(m proto.Message) (*commonpb.DataBlob, error) { tree.go

3871 > return serialization.Encode(m, serialization.WithDeterministicProto3)

3872 > }

go.temporal.io/server/common/dynamicconfig/setting_gen.go 252 covered LOC · 54 ranges

Open complete file

26 type GlobalBoolConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[bool]

27

28 > func NewGlobalBoolSetting(key string, def bool, description string) GlobalBoolSetting { setting_gen.go

29 > return NewGlobalTypedSettingWithConverter[bool](key, convertBool, def, description)

30 > }

31

32 func NewGlobalBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) GlobalBoolConstrainedDefaultSetting {

43 type NamespaceBoolConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[bool]

44

45 > func NewNamespaceBoolSetting(key string, def bool, description string) NamespaceBoolSetting { setting_gen.go

46 > return NewNamespaceTypedSettingWithConverter[bool](key, convertBool, def, description)

47 > }

48

49 func NewNamespaceBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) NamespaceBoolConstrainedDefaultSetting {

60 type NamespaceIDBoolConstrainedDefaultSetting = NamespaceIDTypedConstrainedDefaultSetting[bool]

61

62 > func NewNamespaceIDBoolSetting(key string, def bool, description string) NamespaceIDBoolSetting { setting_gen.go

63 > return NewNamespaceIDTypedSettingWithConverter[bool](key, convertBool, def, description)

64 > }

65

66 func NewNamespaceIDBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) NamespaceIDBoolConstrainedDefaultSetting {

77 type TaskQueueBoolConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[bool]

78

79 > func NewTaskQueueBoolSetting(key string, def bool, description string) TaskQueueBoolSetting { setting_gen.go

80 > return NewTaskQueueTypedSettingWithConverter[bool](key, convertBool, def, description)

81 > }

82

83 func NewTaskQueueBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) TaskQueueBoolConstrainedDefaultSetting {

128 type DestinationBoolConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[bool]

129

130 > func NewDestinationBoolSetting(key string, def bool, description string) DestinationBoolSetting { setting_gen.go

131 > return NewDestinationTypedSettingWithConverter[bool](key, convertBool, def, description)

132 > }

133

134 func NewDestinationBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) DestinationBoolConstrainedDefaultSetting {

162 type GlobalIntConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[int]

163

164 > func NewGlobalIntSetting(key string, def int, description string) GlobalIntSetting { setting_gen.go

165 > return NewGlobalTypedSettingWithConverter[int](key, convertInt, def, description)

166 > }

167

168 func NewGlobalIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) GlobalIntConstrainedDefaultSetting {

179 type NamespaceIntConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[int]

180

181 > func NewNamespaceIntSetting(key string, def int, description string) NamespaceIntSetting { setting_gen.go

182 > return NewNamespaceTypedSettingWithConverter[int](key, convertInt, def, description)

183 > }

184

185 func NewNamespaceIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) NamespaceIntConstrainedDefaultSetting {

189 type IntPropertyFnWithNamespaceFilter = TypedPropertyFnWithNamespaceFilter[int]

190

191 > func GetIntPropertyFnFilteredByNamespace(value int) IntPropertyFnWithNamespaceFilter { setting_gen.go

192 > return GetTypedPropertyFnFilteredByNamespace(value)

193 > }

194

195 type NamespaceIDIntSetting = NamespaceIDTypedSetting[int]

213 type TaskQueueIntConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[int]

214

215 > func NewTaskQueueIntSetting(key string, def int, description string) TaskQueueIntSetting { setting_gen.go

216 > return NewTaskQueueTypedSettingWithConverter[int](key, convertInt, def, description)

217 > }

218

219 > func NewTaskQueueIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) TaskQueueIntConstrainedDefaultSetting { setting_gen.go

220 > return NewTaskQueueTypedSettingWithConstrainedDefault[int](key, convertInt, cdef, description)

221 > }

222

223 type IntPropertyFnWithTaskQueueFilter = TypedPropertyFnWithTaskQueueFilter[int]

230 type ShardIDIntConstrainedDefaultSetting = ShardIDTypedConstrainedDefaultSetting[int]

231

232 > func NewShardIDIntSetting(key string, def int, description string) ShardIDIntSetting { setting_gen.go

233 > return NewShardIDTypedSettingWithConverter[int](key, convertInt, def, description)

234 > }

235

236 func NewShardIDIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) ShardIDIntConstrainedDefaultSetting {

264 type DestinationIntConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[int]

265

266 > func NewDestinationIntSetting(key string, def int, description string) DestinationIntSetting { setting_gen.go

267 > return NewDestinationTypedSettingWithConverter[int](key, convertInt, def, description)

268 > }

269

270 func NewDestinationIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) DestinationIntConstrainedDefaultSetting {

298 type GlobalFloatConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[float64]

299

300 > func NewGlobalFloatSetting(key string, def float64, description string) GlobalFloatSetting { setting_gen.go

301 > return NewGlobalTypedSettingWithConverter[float64](key, convertFloat, def, description)

302 > }

303

304 func NewGlobalFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) GlobalFloatConstrainedDefaultSetting {

315 type NamespaceFloatConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[float64]

316

317 > func NewNamespaceFloatSetting(key string, def float64, description string) NamespaceFloatSetting { setting_gen.go

318 > return NewNamespaceTypedSettingWithConverter[float64](key, convertFloat, def, description)

319 > }

320

321 func NewNamespaceFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) NamespaceFloatConstrainedDefaultSetting {

349 type TaskQueueFloatConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[float64]

350

351 > func NewTaskQueueFloatSetting(key string, def float64, description string) TaskQueueFloatSetting { setting_gen.go

352 > return NewTaskQueueTypedSettingWithConverter[float64](key, convertFloat, def, description)

353 > }

354

355 func NewTaskQueueFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) TaskQueueFloatConstrainedDefaultSetting {

366 type ShardIDFloatConstrainedDefaultSetting = ShardIDTypedConstrainedDefaultSetting[float64]

367

368 > func NewShardIDFloatSetting(key string, def float64, description string) ShardIDFloatSetting { setting_gen.go

369 > return NewShardIDTypedSettingWithConverter[float64](key, convertFloat, def, description)

370 > }

371

372 func NewShardIDFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) ShardIDFloatConstrainedDefaultSetting {

400 type DestinationFloatConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[float64]

401

402 > func NewDestinationFloatSetting(key string, def float64, description string) DestinationFloatSetting { setting_gen.go

403 > return NewDestinationTypedSettingWithConverter[float64](key, convertFloat, def, description)

404 > }

405

406 func NewDestinationFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) DestinationFloatConstrainedDefaultSetting {

434 type GlobalStringConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[string]

435

436 > func NewGlobalStringSetting(key string, def string, description string) GlobalStringSetting { setting_gen.go

437 > return NewGlobalTypedSettingWithConverter[string](key, convertString, def, description)

438 > }

439

440 func NewGlobalStringSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[string], description string) GlobalStringConstrainedDefaultSetting {

570 type GlobalDurationConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[time.Duration]

571

572 > func NewGlobalDurationSetting(key string, def time.Duration, description string) GlobalDurationSetting { setting_gen.go

573 > return NewGlobalTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

574 > }

575

576 func NewGlobalDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) GlobalDurationConstrainedDefaultSetting {

587 type NamespaceDurationConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[time.Duration]

588

589 > func NewNamespaceDurationSetting(key string, def time.Duration, description string) NamespaceDurationSetting { setting_gen.go

590 > return NewNamespaceTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

591 > }

592

593 func NewNamespaceDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) NamespaceDurationConstrainedDefaultSetting {

604 type NamespaceIDDurationConstrainedDefaultSetting = NamespaceIDTypedConstrainedDefaultSetting[time.Duration]

605

606 > func NewNamespaceIDDurationSetting(key string, def time.Duration, description string) NamespaceIDDurationSetting { setting_gen.go

607 > return NewNamespaceIDTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

608 > }

609

610 func NewNamespaceIDDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) NamespaceIDDurationConstrainedDefaultSetting {

621 type TaskQueueDurationConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[time.Duration]

622

623 > func NewTaskQueueDurationSetting(key string, def time.Duration, description string) TaskQueueDurationSetting { setting_gen.go

624 > return NewTaskQueueTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

625 > }

626

627 > func NewTaskQueueDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) TaskQueueDurationConstrainedDefaultSetting { setting_gen.go

628 > return NewTaskQueueTypedSettingWithConstrainedDefault[time.Duration](key, convertDuration, cdef, description)

629 > }

630

631 type DurationPropertyFnWithTaskQueueFilter = TypedPropertyFnWithTaskQueueFilter[time.Duration]

638 type ShardIDDurationConstrainedDefaultSetting = ShardIDTypedConstrainedDefaultSetting[time.Duration]

639

640 > func NewShardIDDurationSetting(key string, def time.Duration, description string) ShardIDDurationSetting { setting_gen.go

641 > return NewShardIDTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

642 > }

643

644 func NewShardIDDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) ShardIDDurationConstrainedDefaultSetting {

655 type TaskTypeDurationConstrainedDefaultSetting = TaskTypeTypedConstrainedDefaultSetting[time.Duration]

656

657 > func NewTaskTypeDurationSetting(key string, def time.Duration, description string) TaskTypeDurationSetting { setting_gen.go

658 > return NewTaskTypeTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

659 > }

660

661 func NewTaskTypeDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) TaskTypeDurationConstrainedDefaultSetting {

672 type DestinationDurationConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[time.Duration]

673

674 > func NewDestinationDurationSetting(key string, def time.Duration, description string) DestinationDurationSetting { setting_gen.go

675 > return NewDestinationTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

676 > }

677

678 func NewDestinationDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) DestinationDurationConstrainedDefaultSetting {

682 type DurationPropertyFnWithDestinationFilter = TypedPropertyFnWithDestinationFilter[time.Duration]

683

684 > func GetDurationPropertyFnFilteredByDestination(value time.Duration) DurationPropertyFnWithDestinationFilter { setting_gen.go

685 > return GetTypedPropertyFnFilteredByDestination(value)

686 > }

687

688 type ChasmTaskTypeDurationSetting = ChasmTaskTypeTypedSetting[time.Duration]

689 type ChasmTaskTypeDurationConstrainedDefaultSetting = ChasmTaskTypeTypedConstrainedDefaultSetting[time.Duration]

690

691 > func NewChasmTaskTypeDurationSetting(key string, def time.Duration, description string) ChasmTaskTypeDurationSetting { setting_gen.go

692 > return NewChasmTaskTypeTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)

693 > }

694

695 func NewChasmTaskTypeDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) ChasmTaskTypeDurationConstrainedDefaultSetting {

723 type NamespaceMapConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[map[string]any]

724

725 > func NewNamespaceMapSetting(key string, def map[string]any, description string) NamespaceMapSetting { setting_gen.go

726 > return NewNamespaceTypedSettingWithConverter[map[string]any](key, convertMap, def, description)

727 > }

728

729 func NewNamespaceMapSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[map[string]any], description string) NamespaceMapConstrainedDefaultSetting {

845 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful

846 // when using non-empty maps or slices as defaults, the result may not be what you want.

847 > func NewGlobalTypedSetting[T any](key string, def T, description string) GlobalTypedSetting[T] { setting_gen.go

848 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.

849 > warnDefaultSharedStructure(key, def)

850 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.

851 > _ = deepCopyForMapstructure(def)

852 >

853 > s := GlobalTypedSetting[T]{

854 > key: MakeKey(key),

855 > def: def,

856 > convert: ConvertStructure[T](def),

857 > description: description,

858 > }

859 > register(s)

860 > return s

861 > }

862

863 // NewGlobalTypedSettingWithConverter creates a setting with a custom converter function.

864 > func NewGlobalTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) GlobalTypedSetting[T] { setting_gen.go

865 > s := GlobalTypedSetting[T]{

866 > key: MakeKey(key),

867 > def: def,

868 > convert: convert,

869 > description: description,

870 > }

871 > register(s)

872 > return s

873 > }

874

875 // NewGlobalTypedSettingWithConstrainedDefault creates a setting with a compound default value.

885 }

886

887 > func (s GlobalTypedSetting[T]) Key() Key { return s.key } setting_gen.go

888 func (s GlobalTypedSetting[T]) Precedence() Precedence { return PrecedenceGlobal }

889 func (s GlobalTypedSetting[T]) Validate(v any) error {

981 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful

982 // when using non-empty maps or slices as defaults, the result may not be what you want.

983 > func NewNamespaceTypedSetting[T any](key string, def T, description string) NamespaceTypedSetting[T] { setting_gen.go

984 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.

985 > warnDefaultSharedStructure(key, def)

986 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.

987 > _ = deepCopyForMapstructure(def)

988 >

989 > s := NamespaceTypedSetting[T]{

990 > key: MakeKey(key),

991 > def: def,

992 > convert: ConvertStructure[T](def),

993 > description: description,

994 > }

995 > register(s)

996 > return s

997 > }

998

999 // NewNamespaceTypedSettingWithConverter creates a setting with a custom converter function.

1000 > func NewNamespaceTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) NamespaceTypedSetting[T] { setting_gen.go

1001 > s := NamespaceTypedSetting[T]{

1002 > key: MakeKey(key),

1003 > def: def,

1004 > convert: convert,

1005 > description: description,

1006 > }

1007 > register(s)

1008 > return s

1009 > }

1010

1011 // NewNamespaceTypedSettingWithConstrainedDefault creates a setting with a compound default value.

1021 }

1022

1023 > func (s NamespaceTypedSetting[T]) Key() Key { return s.key } setting_gen.go

1024 func (s NamespaceTypedSetting[T]) Precedence() Precedence { return PrecedenceNamespace }

1025 func (s NamespaceTypedSetting[T]) Validate(v any) error {

1105 }

1106

1107 > func GetTypedPropertyFnFilteredByNamespace[T any](value T) TypedPropertyFnWithNamespaceFilter[T] { setting_gen.go

1108 > return func(namespace string) T {

1109 return value

1110 }

1134

1135 // NewNamespaceIDTypedSettingWithConverter creates a setting with a custom converter function.

1136 > func NewNamespaceIDTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) NamespaceIDTypedSetting[T] { setting_gen.go

1137 > s := NamespaceIDTypedSetting[T]{

1138 > key: MakeKey(key),

1139 > def: def,

1140 > convert: convert,

1141 > description: description,

1142 > }

1143 > register(s)

1144 > return s

1145 > }

1146

1147 // NewNamespaceIDTypedSettingWithConstrainedDefault creates a setting with a compound default value.

1157 }

1158

1159 > func (s NamespaceIDTypedSetting[T]) Key() Key { return s.key } setting_gen.go

1160 func (s NamespaceIDTypedSetting[T]) Precedence() Precedence { return PrecedenceNamespaceID }

1161 func (s NamespaceIDTypedSetting[T]) Validate(v any) error {

1253 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful

1254 // when using non-empty maps or slices as defaults, the result may not be what you want.

1255 > func NewTaskQueueTypedSetting[T any](key string, def T, description string) TaskQueueTypedSetting[T] { setting_gen.go

1256 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.

1257 > warnDefaultSharedStructure(key, def)

1258 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.

1259 > _ = deepCopyForMapstructure(def)

1260 >

1261 > s := TaskQueueTypedSetting[T]{

1262 > key: MakeKey(key),

1263 > def: def,

1264 > convert: ConvertStructure[T](def),

1265 > description: description,

1266 > }

1267 > register(s)

1268 > return s

1269 > }

1270

1271 // NewTaskQueueTypedSettingWithConverter creates a setting with a custom converter function.

1272 > func NewTaskQueueTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) TaskQueueTypedSetting[T] { setting_gen.go

1273 > s := TaskQueueTypedSetting[T]{

1274 > key: MakeKey(key),

1275 > def: def,

1276 > convert: convert,

1277 > description: description,

1278 > }

1279 > register(s)

1280 > return s

1281 > }

1282

1283 // NewTaskQueueTypedSettingWithConstrainedDefault creates a setting with a compound default value.

1284 > func NewTaskQueueTypedSettingWithConstrainedDefault[T any](key string, convert func(any) (T, error), cdef []TypedConstrainedValue[T], description string) TaskQueueTypedConstrainedDefaultSetting[T] { setting_gen.go

1285 > s := TaskQueueTypedConstrainedDefaultSetting[T]{

1286 > key: MakeKey(key),

1287 > cdef: cdef,

1288 > convert: convert,

1289 > description: description,

1290 > }

1291 > register(s)

1292 > return s

1293 > }

1294

1295 > func (s TaskQueueTypedSetting[T]) Key() Key { return s.key } setting_gen.go

1296 func (s TaskQueueTypedSetting[T]) Precedence() Precedence { return PrecedenceTaskQueue }

1297 func (s TaskQueueTypedSetting[T]) Validate(v any) error {

1300 }

1301

1302 > func (s TaskQueueTypedConstrainedDefaultSetting[T]) Key() Key { return s.key } setting_gen.go

1303 func (s TaskQueueTypedConstrainedDefaultSetting[T]) Precedence() Precedence { return PrecedenceTaskQueue }

1304 func (s TaskQueueTypedConstrainedDefaultSetting[T]) Validate(v any) error {

1430

1431 // NewShardIDTypedSettingWithConverter creates a setting with a custom converter function.

1432 > func NewShardIDTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) ShardIDTypedSetting[T] { setting_gen.go

1433 > s := ShardIDTypedSetting[T]{

1434 > key: MakeKey(key),

1435 > def: def,

1436 > convert: convert,

1437 > description: description,

1438 > }

1439 > register(s)

1440 > return s

1441 > }

1442

1443 // NewShardIDTypedSettingWithConstrainedDefault creates a setting with a compound default value.

1453 }

1454

1455 > func (s ShardIDTypedSetting[T]) Key() Key { return s.key } setting_gen.go

1456 func (s ShardIDTypedSetting[T]) Precedence() Precedence { return PrecedenceShardID }

1457 func (s ShardIDTypedSetting[T]) Validate(v any) error {

1566

1567 // NewTaskTypeTypedSettingWithConverter creates a setting with a custom converter function.

1568 > func NewTaskTypeTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) TaskTypeTypedSetting[T] { setting_gen.go

1569 > s := TaskTypeTypedSetting[T]{

1570 > key: MakeKey(key),

1571 > def: def,

1572 > convert: convert,

1573 > description: description,

1574 > }

1575 > register(s)

1576 > return s

1577 > }

1578

1579 // NewTaskTypeTypedSettingWithConstrainedDefault creates a setting with a compound default value.

1589 }

1590

1591 > func (s TaskTypeTypedSetting[T]) Key() Key { return s.key } setting_gen.go

1592 func (s TaskTypeTypedSetting[T]) Precedence() Precedence { return PrecedenceTaskType }

1593 func (s TaskTypeTypedSetting[T]) Validate(v any) error {

1685 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful

1686 // when using non-empty maps or slices as defaults, the result may not be what you want.

1687 > func NewDestinationTypedSetting[T any](key string, def T, description string) DestinationTypedSetting[T] { setting_gen.go

1688 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.

1689 > warnDefaultSharedStructure(key, def)

1690 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.

1691 > _ = deepCopyForMapstructure(def)

1692 >

1693 > s := DestinationTypedSetting[T]{

1694 > key: MakeKey(key),

1695 > def: def,

1696 > convert: ConvertStructure[T](def),

1697 > description: description,

1698 > }

1699 > register(s)

1700 > return s

1701 > }

1702

1703 // NewDestinationTypedSettingWithConverter creates a setting with a custom converter function.

1704 > func NewDestinationTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) DestinationTypedSetting[T] { setting_gen.go

1705 > s := DestinationTypedSetting[T]{

1706 > key: MakeKey(key),

1707 > def: def,

1708 > convert: convert,

1709 > description: description,

1710 > }

1711 > register(s)

1712 > return s

1713 > }

1714

1715 // NewDestinationTypedSettingWithConstrainedDefault creates a setting with a compound default value.

1725 }

1726

1727 > func (s DestinationTypedSetting[T]) Key() Key { return s.key } setting_gen.go

1728 func (s DestinationTypedSetting[T]) Precedence() Precedence { return PrecedenceDestination }

1729 func (s DestinationTypedSetting[T]) Validate(v any) error {

1829 }

1830

1831 > func GetTypedPropertyFnFilteredByDestination[T any](value T) TypedPropertyFnWithDestinationFilter[T] { setting_gen.go

1832 > return func(namespace string, destination string) T {

1833 > return value setting_gen.go

1834 > }

1835 }

1836

1858

1859 // NewChasmTaskTypeTypedSettingWithConverter creates a setting with a custom converter function.

1860 > func NewChasmTaskTypeTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) ChasmTaskTypeTypedSetting[T] { setting_gen.go

1861 > s := ChasmTaskTypeTypedSetting[T]{

1862 > key: MakeKey(key),

1863 > def: def,

1864 > convert: convert,

1865 > description: description,

1866 > }

1867 > register(s)

1868 > return s

1869 > }

1870

1871 // NewChasmTaskTypeTypedSettingWithConstrainedDefault creates a setting with a compound default value.

1881 }

1882

1883 > func (s ChasmTaskTypeTypedSetting[T]) Key() Key { return s.key } setting_gen.go

1884 func (s ChasmTaskTypeTypedSetting[T]) Precedence() Precedence { return PrecedenceChasmTaskType }

1885 func (s ChasmTaskTypeTypedSetting[T]) Validate(v any) error {

go.temporal.io/server/common/log/zap_logger.go 110 covered LOC · 28 ranges

Open complete file

58 // NewTestLogger returns a logger for tests

59 // Deprecated: Use testlogger.TestLogger instead.

60 > func NewTestLogger() *zapLogger { zap_logger.go

61 > format := os.Getenv(TestLogFormatEnvVar)

62 > if format == "" {

63 > format = "console"

64 > }

65

66 > logger := BuildZapLogger(Config{ zap_logger.go

67 > Level: os.Getenv(TestLogLevelEnvVar),

68 > Format: format,

69 > Development: true,

70 > })

71 >

72 > // Don't include stack traces for warnings during tests. Only include them for logs with level error and above.

73 > logger = logger.WithOptions(zap.AddStacktrace(zap.ErrorLevel))

74 >

75 > return NewZapLogger(logger)

76 }

77

82

83 // NewZapLogger returns a new zap based logger from zap.Logger

84 > func NewZapLogger(zl *zap.Logger) *zapLogger { zap_logger.go

85 > return &zapLogger{

86 > zl: zl,

87 > skip: skipForZapLogger,

88 > baseZl: zl,

89 > }

90 > }

91

92 // BuildZapLogger builds and returns a new zap.Logger for this logging configuration

93 > func BuildZapLogger(cfg Config) *zap.Logger { zap_logger.go

94 > return buildZapLogger(cfg, true)

95 > }

96

97 > func caller(skip int) string { zap_logger.go

98 > _, path, line, ok := runtime.Caller(skip)

99 > if !ok {

100 return ""

101 }

102 > return path + ":" + strconv.Itoa(line) zap_logger.go

103 }

104

105 > func (l *zapLogger) buildFieldsWithCallAt(tags []tag.Tag) []zap.Field { zap_logger.go

106 > fields := make([]zap.Field, len(tags)+1)

107 > l.fillFields(tags, fields)

108 > fields[len(fields)-1] = zap.String(tag.LoggingCallAtKey, caller(l.skip))

109 > return fields

110 > }

111

112 // fillFields fill fields parameter with fields read from tags. Optimized for performance.

113 > func (l *zapLogger) fillFields(tags []tag.Tag, fields []zap.Field) { zap_logger.go

114 > for i, t := range tags {

115 > if zt, ok := t.(tag.ZapTag); ok { zap_logger.go

116 > fields[i] = zt.Field()

117 > } else {

118 fields[i] = zap.Any(t.Key(), t.Value())

119 }

121 }

122

123 > func setDefaultMsg(msg string) string { zap_logger.go

124 > if msg == "" {

125 return defaultMsgForEmpty

126 }

127 > return msg zap_logger.go

128 }

129

136 }

137

138 > func (l *zapLogger) Info(msg string, tags ...tag.Tag) { zap_logger.go

139 > if l.zl.Core().Enabled(zap.InfoLevel) {

140 > msg = setDefaultMsg(msg)

141 > fields := l.buildFieldsWithCallAt(tags)

142 > l.zl.Info(msg, fields...)

143 > }

144 }

145

152 }

153

154 > func (l *zapLogger) Error(msg string, tags ...tag.Tag) { zap_logger.go

155 > if l.zl.Core().Enabled(zap.ErrorLevel) {

156 > msg = setDefaultMsg(msg)

157 > fields := l.buildFieldsWithCallAt(tags)

158 > l.zl.Error(msg, fields...)

159 > }

160 }

161

191 //

192 // by deduping "foo" against any existing "foo" tags *only in the former*

193 > func (l *zapLogger) With(tags ...tag.Tag) Logger { zap_logger.go

194 > cloneTags := mergeTags(l.tags, tags)

195 > if l.baseZl == nil {

196 l.baseZl = l.zl

197 }

198 > return l.cloneWithTags(cloneTags) zap_logger.go

199 }

200

201 > func (l *zapLogger) cloneWithTags(tags []tag.Tag) Logger { zap_logger.go

202 > fields := make([]zap.Field, len(tags))

203 > l.fillFields(tags, fields)

204 > zl := l.baseZl.With(fields...)

205 > return &zapLogger{

206 > zl: zl,

207 > skip: l.skip,

208 > baseZl: l.baseZl,

209 > tags: tags,

210 > }

211 > }

212

213 func (l *zapLogger) Skip(extraSkip int) Logger {

219 }

220

221 > func mergeTags(oldTags, newTags []tag.Tag) (outTags []tag.Tag) { zap_logger.go

222 > // Even if oldTags empty, we don't just return newTags because we need to de-dupe it.

223 > outTags = slices.Clone(oldTags)

224 > for _, t := range newTags {

225 > if i := slices.IndexFunc(outTags, func(ti tag.Tag) bool {

226 > return ti.Key() == t.Key() zap_logger.go

227 > }); i >= 0 {

228 outTags[i] = t

229 > } else { zap_logger.go

230 > outTags = append(outTags, t)

231 > }

232 }

233 > return outTags zap_logger.go

234 }

235

236 > func buildZapLogger(cfg Config, disableCaller bool) *zap.Logger { zap_logger.go

237 > encodeConfig := DefaultZapEncoderConfig

238 > if disableCaller {

239 > encodeConfig.CallerKey = zapcore.OmitKey

240 > encodeConfig.EncodeCaller = nil

241 > }

242

243 > outputPath := "stderr" zap_logger.go

244 > if len(cfg.OutputFile) > 0 {

245 outputPath = cfg.OutputFile

246 }

247 > if cfg.Stdout { zap_logger.go

248 outputPath = "stdout"

249 }

250 > encoding := "json" zap_logger.go

251 > if cfg.Format == "console" {

252 > encoding = "console" zap_logger.go

253 > }

254 > config := zap.Config{ zap_logger.go

255 > Level: zap.NewAtomicLevelAt(ParseZapLevel(cfg.Level)),

256 > Development: cfg.Development,

257 > Sampling: nil,

258 > Encoding: encoding,

259 > EncoderConfig: encodeConfig,

260 > OutputPaths: []string{outputPath},

261 > ErrorOutputPaths: []string{outputPath},

262 > DisableCaller: disableCaller,

263 > }

264 > logger, _ := config.Build()

265 > return logger

266 }

267

297 }

298

299 > func ParseZapLevel(level string) zapcore.Level { zap_logger.go

300 > switch strings.ToLower(level) {

301 case "debug":

302 return zap.DebugLevel

313 case "fatal":

314 return zap.FatalLevel

315 > default: zap_logger.go

316 > return zap.InfoLevel

317 }

318 }

go.temporal.io/server/chasm/registry.go 91 covered LOC · 41 ranges

Open complete file

51 }

52

53 > func NewRegistry(logger log.Logger) *Registry { registry.go

54 > return &Registry{

55 > libraries: make(map[string]Library),

56 > rcByFqn: make(map[string]*RegistrableComponent),

57 > rcByID: make(map[uint32]*RegistrableComponent),

58 > rcByGoType: make(map[reflect.Type]*RegistrableComponent),

59 > rtByFqn: make(map[string]*RegistrableTask),

60 > rtByID: make(map[uint32]*RegistrableTask),

61 > rtByGoType: make(map[reflect.Type]*RegistrableTask),

62 > rcContextValues: make(map[any]valueWithFqn),

63 > nexusServices: make(map[string]*nexus.Service),

64 > NexusEndpointProcessor: NewNexusEndpointProcessor(),

65 > logger: logger,

66 > }

67 > }

68

69 > func (r *Registry) Register(lib Library) error { registry.go

70 > if err := r.validateName(lib.Name()); err != nil {

71 return err

72 }

73 > if _, ok := r.libraries[lib.Name()]; ok { registry.go

74 return fmt.Errorf("library %s is already registered", lib.Name())

75 }

76 > r.libraries[lib.Name()] = lib registry.go

77 >

78 > for _, c := range lib.Components() {

79 > if err := r.registerComponent(lib, c); err != nil { registry.go

80 return err

81 }

82 }

83 > for _, t := range lib.Tasks() { registry.go

84 > if err := r.registerTask(lib, t); err != nil { registry.go

85 return err

86 }

87 }

88

89 > for _, svc := range lib.NexusServices() { registry.go

90 if err := r.registerNexusService(svc); err != nil {

91 return err

93 }

94

95 > for _, svc := range lib.NexusServiceProcessors() { registry.go

96 if err := r.NexusEndpointProcessor.RegisterServiceProcessor(svc); err != nil {

97 return err

99 }

100

101 > return nil registry.go

102 }

103

142 // This method should only be used by CHASM framework internal code,

143 // NOT CHASM library developers.

144 > func (r *Registry) ComponentIDFor(componentInstance any) (uint32, bool) { registry.go

145 > rc, ok := r.componentFor(componentInstance)

146 > if !ok {

147 return 0, false

148 }

149 > return rc.componentID, true registry.go

150 }

151

212 }

213

214 > func (r *Registry) componentFor(componentInstance any) (*RegistrableComponent, bool) { registry.go

215 > rc, ok := r.rcByGoType[reflect.TypeOf(componentInstance)]

216 > return rc, ok

217 > }

218

219 func (r *Registry) taskFor(taskInstance any) (*RegistrableTask, bool) {

235 lib namer,

236 rc *RegistrableComponent,

237 > ) error { registry.go

238 > if err := r.validate(rc); err != nil {

239 return err

240 }

241

242 > fqn, id, err := rc.registerToLibrary(lib) registry.go

243 > if err != nil {

244 return err

245 }

246

247 > if _, ok := r.rcByFqn[fqn]; ok { registry.go

248 return fmt.Errorf("component %s is already registered", fqn)

249 }

250

251 > if id == UnspecifiedArchetypeID { registry.go

252 return fmt.Errorf("component %s maps to a reserved archetype id %d, please use a different name", fqn, UnspecifiedArchetypeID)

253 }

254

255 > if existingComponent, ok := r.rcByID[id]; ok { registry.go

256 return fmt.Errorf("component ID %d collision between %s and %s", id, fqn, existingComponent.fqType())

257 }

258

259 > for key, value := range rc.contextValues { registry.go

260 if existingValue, ok := r.rcContextValues[key]; ok {

261 return fmt.Errorf("context value key %v registered by component %s conflicts with component %s", key, fqn, existingValue.fqn)

269 // rc.goType implements Component interface; therefore, it must be a struct.

270 // This check to protect against the interface itself being registered.

271 > if !(rc.goType.Kind() == reflect.Struct || registry.go

272 > (rc.goType.Kind() == reflect.Pointer && rc.goType.Elem().Kind() == reflect.Struct)) {

273 return fmt.Errorf("component type %s must be struct or pointer to struct", rc.goType.String())

274 }

275 > if _, ok := r.rcByGoType[rc.goType]; ok { registry.go

276 return fmt.Errorf("component type %s is already registered", rc.goType.String())

277 }

278 > r.warnUnmanagedFields(fqn, rc) registry.go

279 >

280 > r.rcByFqn[fqn] = rc

281 > r.rcByID[id] = rc

282 > r.rcByGoType[rc.goType] = rc

283 > return nil

284 }

285

286 > func (r *Registry) validate(rc *RegistrableComponent) error { registry.go

287 > if err := r.validateName(rc.componentType); err != nil {

288 return err

289 }

290 > return r.validateVisibilityBusinessIDAlias(rc) registry.go

291 }

292

294 lib namer,

295 rt *RegistrableTask,

296 > ) error { registry.go

297 > if err := r.validateName(rt.taskType); err != nil {

298 return err

299 }

300

301 > fqn, id, err := rt.registerToLibrary(lib) registry.go

302 > if err != nil {

303 return err

304 }

305

306 > if _, ok := r.rtByFqn[fqn]; ok { registry.go

307 return fmt.Errorf("task %s is already registered", fqn)

308 }

309

310 > if existingTask, ok := r.rtByID[id]; ok { registry.go

311 return fmt.Errorf("task type ID %d collision between %s and %s", id, fqn, existingTask.fqType())

312 }

313

314 > if !(rt.goType.Kind() == reflect.Struct || registry.go

315 > (rt.goType.Kind() == reflect.Pointer && rt.goType.Elem().Kind() == reflect.Struct)) {

316 return fmt.Errorf("task type %s must be struct or pointer to struct", rt.goType.String())

317 }

318 > if _, ok := r.rtByGoType[rt.goType]; ok { registry.go

319 return fmt.Errorf("task type %s is already registered", rt.goType.String())

320 }

321 > if !(rt.componentGoType.Kind() == reflect.Interface || registry.go

322 > (rt.componentGoType.Kind() == reflect.Struct ||

323 > (rt.componentGoType.Kind() == reflect.Pointer && rt.componentGoType.Elem().Kind() == reflect.Struct)) &&

324 > rt.componentGoType.AssignableTo(reflect.TypeFor[Component]())) {

325 return fmt.Errorf("component type %s must be and interface or struct that implements Component interface", rt.componentGoType.String())

326 }

327

328 > r.rtByFqn[fqn] = rt registry.go

329 > r.rtByID[id] = rt

330 > r.rtByGoType[rt.goType] = rt

331 > return nil

332 }

333

334 > func (r *Registry) validateName(n string) error { registry.go

335 > if n == "" {

336 return errors.New("name must not be empty")

337 }

338 > if !nameValidator.MatchString(n) { registry.go

339 return fmt.Errorf("name %s is invalid. name must follow golang identifier rules: %s", n, nameValidator.String())

340 }

341 > return nil registry.go

342 }

343

344 > func (r *Registry) validateVisibilityBusinessIDAlias(rc *RegistrableComponent) error { registry.go

345 > if !hasVisibilityField(rc.goType) {

346 > return nil registry.go

347 > }

348 // Archetypes that contain a Field[*Visibility] must specify WithBusinessIDAlias.

349 if !rc.hasBusinessIDAlias() {

353 }

354

355 > func (r *Registry) warnUnmanagedFields(fqn string, rc *RegistrableComponent) { registry.go

356 > var unmanagedFields []string

357 > for f := range unmanagedFieldsOf(rc.goType) {

358 > unmanagedFields = append(unmanagedFields, fmt.Sprintf("%s %s", f.name, f.typ)) registry.go

359 > }

360 > if len(unmanagedFields) > 0 { registry.go

361 > r.logger.Info(fmt.Sprintf( registry.go

362 > "Warning: CHASM component %s declares state fields that won't be managed by CHASM:\n\t%s",

363 > fqn,

364 > strings.Join(unmanagedFields, "\n\t")))

365 > }

366 }

367

go.temporal.io/server/api/persistence/v1/predicates.pb.go 82 covered LOC · 22 ranges

Open complete file

57 func (*Predicate) ProtoMessage() {}

58

59 > func (x *Predicate) ProtoReflect() protoreflect.Message { predicates.pb.go

60 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[0]

61 > if x != nil {

62 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

63 > if ms.LoadMessageInfo() == nil {

64 > ms.StoreMessageInfo(mi)

65 > }

66 > return ms

67 }

68 return mi.MessageOf(x)

261 func (*UniversalPredicateAttributes) ProtoMessage() {}

262

263 > func (x *UniversalPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

264 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[1]

265 > if x != nil {

266 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

267 if ms.LoadMessageInfo() == nil {

270 return ms

271 }

272 > return mi.MessageOf(x) predicates.pb.go

273 }

274

297 func (*EmptyPredicateAttributes) ProtoMessage() {}

298

299 > func (x *EmptyPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

300 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[2]

301 > if x != nil {

302 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

303 if ms.LoadMessageInfo() == nil {

306 return ms

307 }

308 > return mi.MessageOf(x) predicates.pb.go

309 }

310

334 func (*AndPredicateAttributes) ProtoMessage() {}

335

336 > func (x *AndPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

337 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[3]

338 > if x != nil {

339 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

340 if ms.LoadMessageInfo() == nil {

343 return ms

344 }

345 > return mi.MessageOf(x) predicates.pb.go

346 }

347

378 func (*OrPredicateAttributes) ProtoMessage() {}

379

380 > func (x *OrPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

381 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[4]

382 > if x != nil {

383 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

384 if ms.LoadMessageInfo() == nil {

387 return ms

388 }

389 > return mi.MessageOf(x) predicates.pb.go

390 }

391

422 func (*NotPredicateAttributes) ProtoMessage() {}

423

424 > func (x *NotPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

425 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[5]

426 > if x != nil {

427 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

428 if ms.LoadMessageInfo() == nil {

431 return ms

432 }

433 > return mi.MessageOf(x) predicates.pb.go

434 }

435

466 func (*NamespaceIdPredicateAttributes) ProtoMessage() {}

467

468 > func (x *NamespaceIdPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

469 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[6]

470 > if x != nil {

471 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

472 if ms.LoadMessageInfo() == nil {

475 return ms

476 }

477 > return mi.MessageOf(x) predicates.pb.go

478 }

479

510 func (*TaskTypePredicateAttributes) ProtoMessage() {}

511

512 > func (x *TaskTypePredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

513 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[7]

514 > if x != nil {

515 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

516 if ms.LoadMessageInfo() == nil {

519 return ms

520 }

521 > return mi.MessageOf(x) predicates.pb.go

522 }

523

554 func (*DestinationPredicateAttributes) ProtoMessage() {}

555

556 > func (x *DestinationPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

557 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[8]

558 > if x != nil {

559 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

560 if ms.LoadMessageInfo() == nil {

563 return ms

564 }

565 > return mi.MessageOf(x) predicates.pb.go

566 }

567

598 func (*OutboundTaskGroupPredicateAttributes) ProtoMessage() {}

599

600 > func (x *OutboundTaskGroupPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

601 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[9]

602 > if x != nil {

603 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

604 if ms.LoadMessageInfo() == nil {

607 return ms

608 }

609 > return mi.MessageOf(x) predicates.pb.go

610 }

611

642 func (*OutboundTaskPredicateAttributes) ProtoMessage() {}

643

644 > func (x *OutboundTaskPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go

645 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[10]

646 > if x != nil {

647 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

648 if ms.LoadMessageInfo() == nil {

651 return ms

652 }

653 > return mi.MessageOf(x) predicates.pb.go

654 }

655

828 }

829

830 > func init() { file_temporal_server_api_persistence_v1_predicates_proto_init() } predicates.pb.go

831 > func file_temporal_server_api_persistence_v1_predicates_proto_init() {

832 > if File_temporal_server_api_persistence_v1_predicates_proto != nil {

833 > return

834 > }

835 > file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[0].OneofWrappers = []any{

836 > (*Predicate_UniversalPredicateAttributes)(nil),

837 > (*Predicate_EmptyPredicateAttributes)(nil),

838 > (*Predicate_AndPredicateAttributes)(nil),

839 > (*Predicate_OrPredicateAttributes)(nil),

840 > (*Predicate_NotPredicateAttributes)(nil),

841 > (*Predicate_NamespaceIdPredicateAttributes)(nil),

842 > (*Predicate_TaskTypePredicateAttributes)(nil),

843 > (*Predicate_DestinationPredicateAttributes)(nil),

844 > (*Predicate_OutboundTaskGroupPredicateAttributes)(nil),

845 > (*Predicate_OutboundTaskPredicateAttributes)(nil),

846 > }

847 > type x struct{}

848 > out := protoimpl.TypeBuilder{

849 > File: protoimpl.DescBuilder{

850 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

851 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc), len(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc)),

852 > NumEnums: 0,

853 > NumMessages: 12,

854 > NumExtensions: 0,

855 > NumServices: 0,

856 > },

857 > GoTypes: file_temporal_server_api_persistence_v1_predicates_proto_goTypes,

858 > DependencyIndexes: file_temporal_server_api_persistence_v1_predicates_proto_depIdxs,

859 > MessageInfos: file_temporal_server_api_persistence_v1_predicates_proto_msgTypes,

860 > }.Build()

861 > File_temporal_server_api_persistence_v1_predicates_proto = out.File

862 > file_temporal_server_api_persistence_v1_predicates_proto_goTypes = nil

863 > file_temporal_server_api_persistence_v1_predicates_proto_depIdxs = nil

864 }

go.temporal.io/server/api/persistence/v1/chasm.pb.go 80 covered LOC · 14 ranges

Open complete file

67 }

68

69 > func (x *ChasmNode) GetMetadata() *ChasmNodeMetadata { chasm.pb.go

70 > if x != nil {

71 > return x.Metadata

72 > }

73 return nil

74 }

135 }

136

137 > func (x *ChasmNodeMetadata) GetLastUpdateVersionedTransition() *VersionedTransition { chasm.pb.go

138 > if x != nil {

139 > return x.LastUpdateVersionedTransition

140 > }

141 return nil

142 }

143

144 > func (x *ChasmNodeMetadata) GetAttributes() isChasmNodeMetadata_Attributes { chasm.pb.go

145 > if x != nil {

146 > return x.Attributes

147 > }

148 return nil

149 }

150

151 > func (x *ChasmNodeMetadata) GetComponentAttributes() *ChasmComponentAttributes { chasm.pb.go

152 > if x != nil {

153 > if x, ok := x.Attributes.(*ChasmNodeMetadata_ComponentAttributes); ok { chasm.pb.go

154 > return x.ComponentAttributes chasm.pb.go

155 > }

156 }

157 return nil

167 }

168

169 > func (x *ChasmNodeMetadata) GetCollectionAttributes() *ChasmCollectionAttributes { chasm.pb.go

170 > if x != nil {

171 > if x, ok := x.Attributes.(*ChasmNodeMetadata_CollectionAttributes); ok {

172 return x.CollectionAttributes

173 }

174 }

175 > return nil chasm.pb.go

176 }

177

267 }

268

269 > func (x *ChasmComponentAttributes) GetTypeId() uint32 { chasm.pb.go

270 > if x != nil {

271 > return x.TypeId

272 > }

273 return 0

274 }

275

276 > func (x *ChasmComponentAttributes) GetSideEffectTasks() []*ChasmComponentAttributes_Task { chasm.pb.go

277 > if x != nil {

278 > return x.SideEffectTasks

279 > }

280 return nil

281 }

282

283 > func (x *ChasmComponentAttributes) GetPureTasks() []*ChasmComponentAttributes_Task { chasm.pb.go

284 > if x != nil {

285 > return x.PureTasks

286 > }

287 return nil

288 }

660 }

661

662 > func (x *ChasmComponentRef) Reset() { chasm.pb.go

663 > *x = ChasmComponentRef{}

664 > mi := &file_temporal_server_api_persistence_v1_chasm_proto_msgTypes[9]

665 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

666 > ms.StoreMessageInfo(mi)

667 > }

668

669 func (x *ChasmComponentRef) String() string {

673 func (*ChasmComponentRef) ProtoMessage() {}

674

675 > func (x *ChasmComponentRef) ProtoReflect() protoreflect.Message { chasm.pb.go

676 > mi := &file_temporal_server_api_persistence_v1_chasm_proto_msgTypes[9]

677 > if x != nil {

678 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

679 > if ms.LoadMessageInfo() == nil {

680 > ms.StoreMessageInfo(mi)

681 > }

682 > return ms

683 }

684 return mi.MessageOf(x)

1180 }

1181

1182 > func init() { file_temporal_server_api_persistence_v1_chasm_proto_init() } chasm.pb.go

1183 > func file_temporal_server_api_persistence_v1_chasm_proto_init() {

1184 > if File_temporal_server_api_persistence_v1_chasm_proto != nil {

1185 > return

1186 > }

1187 > file_temporal_server_api_persistence_v1_hsm_proto_init()

1188 > file_temporal_server_api_persistence_v1_chasm_proto_msgTypes[1].OneofWrappers = []any{

1189 > (*ChasmNodeMetadata_ComponentAttributes)(nil),

1190 > (*ChasmNodeMetadata_DataAttributes)(nil),

1191 > (*ChasmNodeMetadata_CollectionAttributes)(nil),

1192 > (*ChasmNodeMetadata_PointerAttributes)(nil),

1193 > }

1194 > file_temporal_server_api_persistence_v1_chasm_proto_msgTypes[10].OneofWrappers = []any{

1195 > (*ChasmNexusCompletion_Success)(nil),

1196 > (*ChasmNexusCompletion_Failure)(nil),

1197 > }

1198 > type x struct{}

1199 > out := protoimpl.TypeBuilder{

1200 > File: protoimpl.DescBuilder{

1201 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

1202 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_chasm_proto_rawDesc), len(file_temporal_server_api_persistence_v1_chasm_proto_rawDesc)),

1203 > NumEnums: 0,

1204 > NumMessages: 15,

1205 > NumExtensions: 0,

1206 > NumServices: 0,

1207 > },

1208 > GoTypes: file_temporal_server_api_persistence_v1_chasm_proto_goTypes,

1209 > DependencyIndexes: file_temporal_server_api_persistence_v1_chasm_proto_depIdxs,

1210 > MessageInfos: file_temporal_server_api_persistence_v1_chasm_proto_msgTypes,

1211 > }.Build()

1212 > File_temporal_server_api_persistence_v1_chasm_proto = out.File

1213 > file_temporal_server_api_persistence_v1_chasm_proto_goTypes = nil

1214 > file_temporal_server_api_persistence_v1_chasm_proto_depIdxs = nil

1215 }

go.temporal.io/server/chasm/search_attribute.go 75 covered LOC · 12 ranges

Open complete file

136 }

137

138 > func newSearchAttributeFieldBool(index int) SearchAttributeFieldBool { search_attribute.go

139 > return SearchAttributeFieldBool{

140 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_BOOL, index),

141 > }

142 > }

143

144 // SearchAttributeFieldDateTime is a search attribute field for a datetime value.

147 }

148

149 > func newSearchAttributeFieldDateTime(index int) SearchAttributeFieldDateTime { search_attribute.go

150 > return SearchAttributeFieldDateTime{

151 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_DATETIME, index),

152 > }

153 > }

154

155 // SearchAttributeFieldInt is a search attribute field for an integer value.

158 }

159

160 > func newSearchAttributeFieldInt(index int) SearchAttributeFieldInt { search_attribute.go

161 > return SearchAttributeFieldInt{

162 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_INT, index),

163 > }

164 > }

165

166 // SearchAttributeFieldDouble is a search attribute field for a double value.

169 }

170

171 > func newSearchAttributeFieldDouble(index int) SearchAttributeFieldDouble { search_attribute.go

172 > return SearchAttributeFieldDouble{

173 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_DOUBLE, index),

174 > }

175 > }

176

177 // SearchAttributeFieldKeyword is a search attribute field for a keyword value.

180 }

181

182 > func newSearchAttributeFieldKeyword(index int) SearchAttributeFieldKeyword { search_attribute.go

183 > return SearchAttributeFieldKeyword{

184 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_KEYWORD, index),

185 > }

186 > }

187

188 > func newSearchAttributeFieldLowCardinalityKeyword(index int) SearchAttributeFieldKeyword { search_attribute.go

189 > return SearchAttributeFieldKeyword{

190 > field: fmt.Sprintf("%s%s%02d", sadefs.ReservedPrefix, "LowCardinalityKeyword", index),

191 > }

192 > }

193

194 // SearchAttributeFieldKeywordList is a search attribute field for a keyword list value.

197 }

198

199 > func newSearchAttributeFieldKeywordList(index int) SearchAttributeFieldKeywordList { search_attribute.go

200 > return SearchAttributeFieldKeywordList{

201 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_KEYWORD_LIST, index),

202 > }

203 > }

204

205 // SearchAttributeFieldText is a search attribute field for a text value.

214 }

215

216 > func resolveFieldName(valueType enumspb.IndexedValueType, index int) string { search_attribute.go

217 > // Columns are named like TemporalBool01, TemporalDatetime01, TemporalDouble01, TemporalInt01.

218 > return fmt.Sprintf("%s%s%02d", sadefs.ReservedPrefix, valueType.String(), index)

219 > }

220

221 func (s searchAttributeDefinition) definition() searchAttributeDefinition {

239 }

240

241 > func newSearchAttributeBoolByField(field string) SearchAttributeBool { search_attribute.go

242 > return SearchAttributeBool{

243 > searchAttributeDefinition: searchAttributeDefinition{

244 > alias: field,

245 > field: field,

246 > valueType: enumspb.INDEXED_VALUE_TYPE_BOOL,

247 > },

248 > }

249 > }

250

251 // Value sets the boolean value of the search attribute.

276 }

277

278 > func newSearchAttributeDateTimeByField(field string) SearchAttributeDateTime { search_attribute.go

279 > return SearchAttributeDateTime{

280 > searchAttributeDefinition: searchAttributeDefinition{

281 > alias: field,

282 > field: field,

283 > valueType: enumspb.INDEXED_VALUE_TYPE_DATETIME,

284 > },

285 > }

286 > }

287

288 // Value sets the date time value of the search attribute.

377 }

378

379 > func newSearchAttributeKeywordByField(field string) SearchAttributeKeyword { search_attribute.go

380 > return SearchAttributeKeyword{

381 > searchAttributeDefinition: searchAttributeDefinition{

382 > alias: field,

383 > field: field,

384 > valueType: enumspb.INDEXED_VALUE_TYPE_KEYWORD,

385 > },

386 > }

387 > }

388

389 // Value sets the string value of the search attribute.

414 }

415

416 > func newSearchAttributeKeywordListByField(field string) SearchAttributeKeywordList { search_attribute.go

417 > return SearchAttributeKeywordList{

418 > searchAttributeDefinition: searchAttributeDefinition{

419 > alias: field,

420 > field: field,

421 > valueType: enumspb.INDEXED_VALUE_TYPE_KEYWORD_LIST,

422 > },

423 > }

424 > }

425

426 // Value sets the string list value of the search attribute.

go.temporal.io/server/chasm/fields_iterator.go 67 covered LOC · 32 ranges

Open complete file

41 //

42 //nolint:revive // cognitive complexity 26 (> max enabled 25)

43 > func fieldsOf(valueV reflect.Value) iter.Seq[fieldInfo] { fields_iterator.go

44 > valueT := valueV.Type()

45 > dataFieldName := ""

46 > return func(yield func(fi fieldInfo) bool) {

47 > for i := 0; i < valueT.Elem().NumField(); i++ {

48 > fieldV := valueV.Elem().Field(i)

49 > fieldT := fieldV.Type()

50 > if fieldT == UnimplementedComponentT {

51 > continue fields_iterator.go

52 }

53

54 > fieldN := fieldName(valueT.Elem().Field(i)) fields_iterator.go

55 > var fieldErr error

56 > fieldK := fieldKindUnspecified

57 > if fieldT.AssignableTo(protoMessageT) {

58 > if dataFieldName != "" { fields_iterator.go

59 fieldErr = serviceerror.NewInternalf("%s.%s: only one data field %s (implements proto.Message) allowed in component", valueT, fieldN, dataFieldName)

60 }

61 > dataFieldName = fieldN fields_iterator.go

62 > fieldK = fieldKindData

63 > } else { fields_iterator.go

64 > prefix := genericTypePrefix(fieldT)

65 > if strings.HasPrefix(prefix, "*") {

66 switch prefix[1:] {

67 case chasmFieldTypePrefix,

73 continue

74 }

75 > } else { fields_iterator.go

76 > switch prefix {

77 > case chasmFieldTypePrefix: fields_iterator.go

78 > fieldK = fieldKindSubField

79 case chasmMapTypePrefix:

80 fieldK = fieldKindSubMap

81 case chasmMSPointerType:

82 fieldK = fieldKindMutableState

83 > case chasmParentPointerTypePrefix: fields_iterator.go

84 > fieldK = fieldKindParentPtr

85 > default: fields_iterator.go

86 > continue // Skip non-CHASM fields.

87 }

88 }

90 }

91

92 > if !yield(fieldInfo{val: fieldV, typ: fieldT, name: fieldN, kind: fieldK, err: fieldErr}) { fields_iterator.go

93 return

94 }

95 }

96 // If the data field is not found, generate one more fake field with only an error set.

97 > if dataFieldName == "" { fields_iterator.go

98 yield(fieldInfo{err: serviceerror.NewInternalf("%s: no data field (implements proto.Message) found", valueT)})

99 }

102

103 // unmanagedFieldsOf yields all non-CHASM managed fields of a struct.

104 > func unmanagedFieldsOf(valueT reflect.Type) iter.Seq[fieldInfo] { fields_iterator.go

105 > return func(yield func(fi fieldInfo) bool) {

106 > if valueT.Kind() == reflect.Pointer {

107 > valueT = valueT.Elem() fields_iterator.go

108 > }

109 > for field := range valueT.Fields() { fields_iterator.go

110 > fieldT := field.Type

111 > if fieldT == UnimplementedComponentT {

112 > continue fields_iterator.go

113 }

114

115 // Skip the data field, which is always CHASM-managed.

116 > if fieldT.AssignableTo(protoMessageT) { fields_iterator.go

117 > continue fields_iterator.go

118 }

119

120 > fieldN := fieldName(field) fields_iterator.go

121 > prefix := genericTypePrefix(fieldT)

122 > switch prefix {

123 case chasmFieldTypePrefix,

124 chasmMapTypePrefix,

125 chasmMSPointerType,

126 > chasmParentPointerTypePrefix: fields_iterator.go

127 > continue // Skip CHASM fields.

128 > default: fields_iterator.go

129 > if !yield(fieldInfo{typ: fieldT, name: fieldN}) {

130 return

131 }

135 }

136

137 > func genericTypePrefix(t reflect.Type) string { fields_iterator.go

138 > tn := t.String()

139 > if tn == chasmMSPointerType {

140 return chasmMSPointerType

141 }

142 > bracketPos := strings.Index(tn, "[") fields_iterator.go

143 > if bracketPos == -1 {

144 > return "" fields_iterator.go

145 > }

146 > return tn[:bracketPos+1] fields_iterator.go

147 }

148

149 > func fieldName(f reflect.StructField) string { fields_iterator.go

150 > if tagName := f.Tag.Get(fieldNameTag); tagName != "" {

151 return tagName

152 }

153 > return f.Name fields_iterator.go

154 }

155

161 // This is used at registration time to validate that archetypes using Visibility

162 // have configured a businessID alias.

163 > func hasVisibilityField(componentT reflect.Type) bool { fields_iterator.go

164 > if componentT.Kind() == reflect.Pointer {

165 > componentT = componentT.Elem() fields_iterator.go

166 > }

167 > if componentT.Kind() != reflect.Struct { fields_iterator.go

168 return false

169 }

170 > for field := range componentT.Fields() { fields_iterator.go

171 > fieldT := field.Type

172 > if fieldT == visibilityFieldT {

173 return true

174 }

175 }

176 > return false fields_iterator.go

177 }

go.temporal.io/server/chasm/lib/callback/invocable_internal.go 61 covered LOC · 20 ranges

Open complete file

27 // internalErr and a reference-id. An opaque error containing the reference-id is

28 // returned. Intended to be used to hide internal errors from end users.

29 > func logInternalError(logger log.Logger, internalMsg string, internalErr error) error { invocable_internal.go

30 > referenceID := uuid.NewString()

31 > logger.Error(internalMsg, tag.Error(internalErr), tag.String("reference-id", referenceID))

32 > return fmt.Errorf("internal error, reference-id: %v", referenceID)

33 > }

34

35 // invocableInternal is an invocable that delivers the Nexus operation completion data to History for cross-shard

42 }

43

44 > func (c invocableInternal) WrapError(result invocationResult, err error) error { invocable_internal.go

45 > // Return the invocation result error if present

46 > if resultErr := result.error(); resultErr != nil {

47 > return resultErr invocable_internal.go

48 > }

49

50 return err

57 task *callbackspb.InvocationTask,

58 taskAttr chasm.TaskAttributes,

59 > ) invocationResult { invocable_internal.go

60 > header := nexus.Header(c.callback.GetHeader())

61 > if header == nil {

62 header = nexus.Header{}

63 }

64

65 // Get back the component ref and (optional) request ID from the callback token in the header.

66 > encodedToken := header.Get(commonnexus.CallbackTokenHeader) invocable_internal.go

67 > if encodedToken == "" {

68 return invocationResultFail{logInternalError(h.logger, "callback missing token", nil)}

69 }

70

71 > decodedRef, requestID, err := chasm.UnpackNexusCallbackToken(encodedToken) invocable_internal.go

72 > if err != nil {

73 return invocationResultFail{logInternalError(h.logger, "failed to decode CHASM callback token", err)}

74 }

75

76 // Older tokens don't carry a request ID; fall back to the one on the callback state machine.

77 > if requestID == "" { invocable_internal.go

78 > requestID = c.requestID

79 > }

80

81 // Validate that the bytes are a valid ChasmComponentRef

82 > ref := &persistencespb.ChasmComponentRef{} invocable_internal.go

83 > if err := proto.Unmarshal(decodedRef, ref); err != nil {

84 return invocationResultFail{logInternalError(h.logger, "failed to unmarshal CHASM ComponentRef", err)}

85 }

86

87 > request, err := c.getHistoryRequest(decodedRef, requestID) invocable_internal.go

88 > if err != nil {

89 return invocationResultFail{logInternalError(h.logger, "failed to build history request", err)}

90 }

91

92 // RPC to History for cross-shard completion delivery.

93 > _, err = h.historyClient.CompleteNexusOperationChasm(ctx, request) invocable_internal.go

94 > if err != nil {

95 > msg := logInternalError(h.logger, "failed to complete Nexus operation", err) invocable_internal.go

96 > if isRetryableRPCResponse(err) {

97 return invocationResultRetry{err: msg}

98 }

99 > return invocationResultFail{msg} invocable_internal.go

100 }

101

103 }

104

105 > func isRetryableRPCResponse(err error) bool { invocable_internal.go

106 > var st *status.Status

107 > stGetter, ok := err.(interface{ Status() *status.Status })

108 > if ok {

109 st = stGetter.Status()

110 > } else { invocable_internal.go

111 > st, ok = status.FromError(err)

112 > if !ok {

113 // Not a gRPC induced error

114 return false

116 }

117 // nolint:exhaustive

118 > switch st.Code() { invocable_internal.go

119 case codes.Canceled,

120 codes.Unknown,

125 codes.Internal:

126 return true

127 > default: invocable_internal.go

128 > return false

129 }

130 }

133 refBytes []byte,

134 requestID string,

135 > ) (*historyservice.CompleteNexusOperationChasmRequest, error) { invocable_internal.go

136 > var req *historyservice.CompleteNexusOperationChasmRequest

137 >

138 > completion := &tokenspb.NexusOperationCompletion{

139 > ComponentRef: refBytes,

140 > RequestId: requestID,

141 > }

142 >

143 > if c.completion.Error == nil {

144 > var payload *commonpb.Payload invocable_internal.go

145 > if c.completion.Result != nil {

146 > var ok bool

147 > payload, ok = c.completion.Result.(*commonpb.Payload)

148 > if !ok {

149 return nil, fmt.Errorf("invalid result, expected a payload, got: %T", c.completion.Result)

150 }

151 }

152

153 > req = &historyservice.CompleteNexusOperationChasmRequest{ invocable_internal.go

154 > Outcome: &historyservice.CompleteNexusOperationChasmRequest_Success{

155 > Success: payload,

156 > },

157 > CloseTime: timestamppb.New(c.completion.CloseTime),

158 > Completion: completion,

159 > }

160 } else {

161 failure, err := nexusrpc.DefaultFailureConverter().ErrorToFailure(c.completion.Error)

181 }

182

183 > return req, nil invocable_internal.go

184 }

go.temporal.io/server/api/persistence/v1/executions.pb.go 60 covered LOC · 1 range

Open complete file

5706 }

5707

5708 > func init() { file_temporal_server_api_persistence_v1_executions_proto_init() } executions.pb.go

5709 > func file_temporal_server_api_persistence_v1_executions_proto_init() {

5710 > if File_temporal_server_api_persistence_v1_executions_proto != nil {

5711 > return

5712 > }

5713 > file_temporal_server_api_persistence_v1_chasm_proto_init()

5714 > file_temporal_server_api_persistence_v1_hsm_proto_init()

5715 > file_temporal_server_api_persistence_v1_queues_proto_init()

5716 > file_temporal_server_api_persistence_v1_update_proto_init()

5717 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[1].OneofWrappers = []any{

5718 > (*WorkflowExecutionInfo_LastWorkflowTaskFailureCause)(nil),

5719 > (*WorkflowExecutionInfo_LastWorkflowTaskTimedOutType)(nil),

5720 > }

5721 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[8].OneofWrappers = []any{

5722 > (*TransferTaskInfo_CloseExecutionTaskDetails_)(nil),

5723 > (*TransferTaskInfo_ChasmTaskInfo)(nil),

5724 > }

5725 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[10].OneofWrappers = []any{

5726 > (*VisibilityTaskInfo_ChasmTaskInfo)(nil),

5727 > }

5728 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[11].OneofWrappers = []any{

5729 > (*TimerTaskInfo_ChasmTaskInfo)(nil),

5730 > }

5731 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[13].OneofWrappers = []any{

5732 > (*OutboundTaskInfo_StateMachineInfo)(nil),

5733 > (*OutboundTaskInfo_ChasmTaskInfo)(nil),

5734 > (*OutboundTaskInfo_WorkerCommandsTask)(nil),

5735 > }

5736 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[17].OneofWrappers = []any{

5737 > (*ActivityInfo_UseWorkflowBuildIdInfo_)(nil),

5738 > (*ActivityInfo_LastIndependentlyAssignedBuildId)(nil),

5739 > }

5740 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[23].OneofWrappers = []any{

5741 > (*Callback_Nexus_)(nil),

5742 > (*Callback_Hsm)(nil),

5743 > }

5744 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[40].OneofWrappers = []any{

5745 > (*ActivityInfo_PauseInfo_Manual_)(nil),

5746 > (*ActivityInfo_PauseInfo_RuleId)(nil),

5747 > }

5748 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[46].OneofWrappers = []any{

5749 > (*CallbackInfo_Trigger_WorkflowClosed)(nil),

5750 > }

5751 > type x struct{}

5752 > out := protoimpl.TypeBuilder{

5753 > File: protoimpl.DescBuilder{

5754 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

5755 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_executions_proto_rawDesc), len(file_temporal_server_api_persistence_v1_executions_proto_rawDesc)),

5756 > NumEnums: 0,

5757 > NumMessages: 47,

5758 > NumExtensions: 0,

5759 > NumServices: 0,

5760 > },

5761 > GoTypes: file_temporal_server_api_persistence_v1_executions_proto_goTypes,

5762 > DependencyIndexes: file_temporal_server_api_persistence_v1_executions_proto_depIdxs,

5763 > MessageInfos: file_temporal_server_api_persistence_v1_executions_proto_msgTypes,

5764 > }.Build()

5765 > File_temporal_server_api_persistence_v1_executions_proto = out.File

5766 > file_temporal_server_api_persistence_v1_executions_proto_goTypes = nil

5767 > file_temporal_server_api_persistence_v1_executions_proto_depIdxs = nil

5768 }

go.temporal.io/server/chasm/engine.go 55 covered LOC · 14 ranges

Open complete file

339 input I,

340 opts ...TransitionOption,

341 > ) (O, []byte, error) { engine.go

342 > var output O

343 >

344 > ref, err := convertComponentRef(r)

345 > if err != nil {

346 return output, nil, err

347 }

348

349 > var options TransitionOptions engine.go

350 > for _, opt := range opts {

351 opt(&options)

352 }

353 > ref, err = ref.forConsistencyLevel(options.ConsistencyLevel) engine.go

354 > if err != nil {

355 return output, nil, err

356 }

357

358 > newSerializedRef, err := engineFromContext(ctx).UpdateComponent( engine.go

359 > ctx,

360 > ref,

361 > func(mutableContext MutableContext, c Component) (retErr error) {

362 > defer log.CapturePanic(mutableContext.Logger(), &retErr)

363 >

364 > var err error

365 > output, err = updateFn(

366 > c.(C),

367 > mutableContext,

368 > input,

369 > )

370 > return err

371 > },

372 opts...,

373 )

374

375 > if err != nil { engine.go

376 return output, nil, err

377 }

378 > return output, newSerializedRef, err engine.go

379 }

380

387 input I,

388 opts ...TransitionOption,

389 > ) (O, error) { engine.go

390 > var output O

391 >

392 > ref, err := convertComponentRef(r)

393 > if err != nil {

394 return output, err

395 }

396

397 > err = engineFromContext(ctx).ReadComponent( engine.go

398 > ctx,

399 > ref,

400 > func(chasmContext Context, c Component) (retErr error) {

401 > defer log.CapturePanic(chasmContext.Logger(), &retErr)

402 >

403 > var err error

404 > output, err = readFn(

405 > c.(C),

406 > chasmContext,

407 > input,

408 > )

409 > return err

410 > },

411 opts...,

412 )

413 > return output, err engine.go

414 }

415

477 func convertComponentRef[R []byte | ComponentRef](

478 r R,

479 > ) (ComponentRef, error) { engine.go

480 > if refToken, ok := any(r).([]byte); ok {

481 return DeserializeComponentRef(refToken)

482 }

483

484 //revive:disable-next-line:unchecked-type-assertion

485 > return any(r).(ComponentRef), nil engine.go

486 }

487

496 ctx context.Context,

497 engine Engine,

498 > ) context.Context { engine.go

499 > return context.WithValue(ctx, engineCtxKey, engine)

500 > }

501

502 func engineFromContext(

503 ctx context.Context,

504 > ) Engine { engine.go

505 > e, ok := ctx.Value(engineCtxKey).(Engine)

506 > if !ok {

507 return nil

508 }

509 > return e engine.go

510 }

go.temporal.io/server/chasm/lib/callback/gen/callbackpb/v1/message.pb.go 53 covered LOC · 10 ranges

Open complete file

145 func (*CallbackState) ProtoMessage() {}

146

147 > func (x *CallbackState) ProtoReflect() protoreflect.Message { message.pb.go

148 > mi := &file_temporal_server_chasm_lib_callback_proto_v1_message_proto_msgTypes[0]

149 > if x != nil {

150 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

151 > if ms.LoadMessageInfo() == nil {

152 > ms.StoreMessageInfo(mi)

153 > }

154 > return ms

155 }

156 return mi.MessageOf(x)

162 }

163

164 > func (x *CallbackState) GetCallback() *Callback { message.pb.go

165 > if x != nil {

166 > return x.Callback

167 > }

168 return nil

169 }

242 func (*Callback) ProtoMessage() {}

243

244 > func (x *Callback) ProtoReflect() protoreflect.Message { message.pb.go

245 > mi := &file_temporal_server_chasm_lib_callback_proto_v1_message_proto_msgTypes[1]

246 > if x != nil {

247 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

248 if ms.LoadMessageInfo() == nil {

251 return ms

252 }

253 > return mi.MessageOf(x) message.pb.go

254 }

255

266 }

267

268 > func (x *Callback) GetNexus() *Callback_Nexus { message.pb.go

269 > if x != nil {

270 > if x, ok := x.Variant.(*Callback_Nexus_); ok {

271 > return x.Nexus

272 > }

273 }

274 return nil

355 func (*Callback_Nexus) ProtoMessage() {}

356

357 > func (x *Callback_Nexus) ProtoReflect() protoreflect.Message { message.pb.go

358 > mi := &file_temporal_server_chasm_lib_callback_proto_v1_message_proto_msgTypes[3]

359 > if x != nil {

360 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

361 if ms.LoadMessageInfo() == nil {

364 return ms

365 }

366 > return mi.MessageOf(x) message.pb.go

367 }

368

379 }

380

381 > func (x *Callback_Nexus) GetHeader() map[string]string { message.pb.go

382 > if x != nil {

383 > return x.Header

384 > }

385 return nil

386 }

462 }

463

464 > func init() { file_temporal_server_chasm_lib_callback_proto_v1_message_proto_init() } message.pb.go

465 > func file_temporal_server_chasm_lib_callback_proto_v1_message_proto_init() {

466 > if File_temporal_server_chasm_lib_callback_proto_v1_message_proto != nil {

467 return

468 }

469 > file_temporal_server_chasm_lib_callback_proto_v1_message_proto_msgTypes[1].OneofWrappers = []any{ message.pb.go

470 > (*Callback_Nexus_)(nil),

471 > }

472 > type x struct{}

473 > out := protoimpl.TypeBuilder{

474 > File: protoimpl.DescBuilder{

475 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

476 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_callback_proto_v1_message_proto_rawDesc), len(file_temporal_server_chasm_lib_callback_proto_v1_message_proto_rawDesc)),

477 > NumEnums: 1,

478 > NumMessages: 5,

479 > NumExtensions: 0,

480 > NumServices: 0,

481 > },

482 > GoTypes: file_temporal_server_chasm_lib_callback_proto_v1_message_proto_goTypes,

483 > DependencyIndexes: file_temporal_server_chasm_lib_callback_proto_v1_message_proto_depIdxs,

484 > EnumInfos: file_temporal_server_chasm_lib_callback_proto_v1_message_proto_enumTypes,

485 > MessageInfos: file_temporal_server_chasm_lib_callback_proto_v1_message_proto_msgTypes,

486 > }.Build()

487 > File_temporal_server_chasm_lib_callback_proto_v1_message_proto = out.File

488 > file_temporal_server_chasm_lib_callback_proto_v1_message_proto_goTypes = nil

489 > file_temporal_server_chasm_lib_callback_proto_v1_message_proto_depIdxs = nil

490 }

go.temporal.io/server/chasm/registrable_task.go 53 covered LOC · 10 ranges

Open complete file

50 handler SideEffectTaskHandler[C, T],

51 opts ...RegistrableTaskOption,

52 > ) *RegistrableTask { registrable_task.go

53 > return newRegistrableTask(

54 > taskType,

55 > reflect.TypeFor[T](),

56 > reflect.TypeFor[C](),

57 > func(

58 > ctx Context,

59 > component any,

60 > taskInvocation TaskInvocation,

61 > taskData any,

62 > registry *Registry,

63 > ) (bool, error) {

64 return handler.Validate(

65 ctx,

90 handler PureTaskHandler[C, T],

91 opts ...RegistrableTaskOption,

92 > ) *RegistrableTask { registrable_task.go

93 > return newRegistrableTask(

94 > taskType,

95 > reflect.TypeFor[T](),

96 > reflect.TypeFor[C](),

97 > func(

98 > ctx Context,

99 > component any,

100 > taskInvocation TaskInvocation,

101 > taskData any,

102 > registry *Registry,

103 > ) (bool, error) {

104 return handler.Validate(

105 ctx,

139 sideEffectTaskDiscardFn sideEffectTaskDiscardFn,

140 opts ...RegistrableTaskOption,

141 > ) *RegistrableTask { registrable_task.go

142 > rt := &RegistrableTask{

143 > taskType: taskType,

144 > goType: goType,

145 > componentGoType: componentGoType,

146 > validateFn: validateFn,

147 > pureTaskExecuteFn: pureTaskExecuteFn,

148 > sideEffectTaskExecuteFn: sideEffectTaskExecuteFn,

149 > sideEffectTaskDiscardFn: sideEffectTaskDiscardFn,

150 > isPureTask: isPureTask,

151 > }

152 >

153 > for _, opt := range opts {

154 opt(rt)

155 }

156

157 > return rt registrable_task.go

158 }

159

160 func (rt *RegistrableTask) registerToLibrary(

161 library namer,

162 > ) (string, uint32, error) { registrable_task.go

163 > if rt.library != nil {

164 return "", 0, fmt.Errorf("task %s is already registered in library %s", rt.taskType, rt.library.Name())

165 }

166

167 > rt.library = library registrable_task.go

168 >

169 > fqn := rt.fqType()

170 > rt.taskTypeID = GenerateTypeID(fqn)

171 > // If outboundTaskGroup wasn't set on creation default it here,

172 > // since this is the first place we will have the fqn.

173 > if rt.outboundTaskGroup == "" {

174 > rt.outboundTaskGroup = fqn registrable_task.go

175 > }

176 > return fqn, rt.taskTypeID, nil registrable_task.go

177 }

178

190 // the library name and the task type. This is used to uniquely identify

191 // the task in the registry.

192 > func (rt *RegistrableTask) fqType() string { registrable_task.go

193 > if rt.library == nil {

194 // this should never happen because the task is only accessible from the library.

195 panic("task is not registered to a library")

196 }

197 > return FullyQualifiedName(rt.library.Name(), rt.taskType) registrable_task.go

198 }

199

go.temporal.io/server/api/persistence/v1/hsm.pb.go 48 covered LOC · 9 ranges

Open complete file

272 func (*StateMachineRef) ProtoMessage() {}

273

274 > func (x *StateMachineRef) ProtoReflect() protoreflect.Message { hsm.pb.go

275 > mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[3]

276 > if x != nil {

277 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

278 if ms.LoadMessageInfo() == nil {

281 return ms

282 }

283 > return mi.MessageOf(x) hsm.pb.go

284 }

285

478 func (*VersionedTransition) ProtoMessage() {}

479

480 > func (x *VersionedTransition) ProtoReflect() protoreflect.Message { hsm.pb.go

481 > mi := &file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[6]

482 > if x != nil {

483 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

484 if ms.LoadMessageInfo() == nil {

487 return ms

488 }

489 > return mi.MessageOf(x) hsm.pb.go

490 }

491

495 }

496

497 > func (x *VersionedTransition) GetNamespaceFailoverVersion() int64 { hsm.pb.go

498 > if x != nil {

499 > return x.NamespaceFailoverVersion hsm.pb.go

500 > }

501 return 0

502 }

503

504 > func (x *VersionedTransition) GetTransitionCount() int64 { hsm.pb.go

505 > if x != nil {

506 > return x.TransitionCount hsm.pb.go

507 > }

508 return 0

509 }

895 }

896

897 > func init() { file_temporal_server_api_persistence_v1_hsm_proto_init() } hsm.pb.go

898 > func file_temporal_server_api_persistence_v1_hsm_proto_init() {

899 > if File_temporal_server_api_persistence_v1_hsm_proto != nil {

900 > return

901 > }

902 > file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[8].OneofWrappers = []any{

903 > (*StateMachineTombstone_ActivityScheduledEventId)(nil),

904 > (*StateMachineTombstone_TimerId)(nil),

905 > (*StateMachineTombstone_ChildExecutionInitiatedEventId)(nil),

906 > (*StateMachineTombstone_RequestCancelInitiatedEventId)(nil),

907 > (*StateMachineTombstone_SignalExternalInitiatedEventId)(nil),

908 > (*StateMachineTombstone_UpdateId)(nil),

909 > (*StateMachineTombstone_StateMachinePath)(nil),

910 > (*StateMachineTombstone_ChasmNodePath)(nil),

911 > }

912 > type x struct{}

913 > out := protoimpl.TypeBuilder{

914 > File: protoimpl.DescBuilder{

915 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

916 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_hsm_proto_rawDesc), len(file_temporal_server_api_persistence_v1_hsm_proto_rawDesc)),

917 > NumEnums: 0,

918 > NumMessages: 12,

919 > NumExtensions: 0,

920 > NumServices: 0,

921 > },

922 > GoTypes: file_temporal_server_api_persistence_v1_hsm_proto_goTypes,

923 > DependencyIndexes: file_temporal_server_api_persistence_v1_hsm_proto_depIdxs,

924 > MessageInfos: file_temporal_server_api_persistence_v1_hsm_proto_msgTypes,

925 > }.Build()

926 > File_temporal_server_api_persistence_v1_hsm_proto = out.File

927 > file_temporal_server_api_persistence_v1_hsm_proto_goTypes = nil

928 > file_temporal_server_api_persistence_v1_hsm_proto_depIdxs = nil

929 }

go.temporal.io/server/api/historyservice/v1/request_response.pb.go 45 covered LOC · 1 range

Open complete file

11956 }

11957

11958 > func init() { file_temporal_server_api_historyservice_v1_request_response_proto_init() } request_response.pb.go

11959 > func file_temporal_server_api_historyservice_v1_request_response_proto_init() {

11960 > if File_temporal_server_api_historyservice_v1_request_response_proto != nil {

11961 > return

11962 > }

11963 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[107].OneofWrappers = []any{

11964 > (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState)(nil),

11965 > }

11966 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[108].OneofWrappers = []any{

11967 > (*StreamWorkflowReplicationMessagesResponse_Messages)(nil),

11968 > }

11969 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[134].OneofWrappers = []any{

11970 > (*CompleteNexusOperationChasmRequest_Success)(nil),

11971 > (*CompleteNexusOperationChasmRequest_Failure)(nil),

11972 > }

11973 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[136].OneofWrappers = []any{

11974 > (*CompleteNexusOperationRequest_Success)(nil),

11975 > (*CompleteNexusOperationRequest_Failure)(nil),

11976 > }

11977 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[162].OneofWrappers = []any{

11978 > (*ExecuteMultiOperationRequest_Operation_StartWorkflow)(nil),

11979 > (*ExecuteMultiOperationRequest_Operation_UpdateWorkflow)(nil),

11980 > }

11981 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[163].OneofWrappers = []any{

11982 > (*ExecuteMultiOperationResponse_Response_StartWorkflow)(nil),

11983 > (*ExecuteMultiOperationResponse_Response_UpdateWorkflow)(nil),

11984 > }

11985 > type x struct{}

11986 > out := protoimpl.TypeBuilder{

11987 > File: protoimpl.DescBuilder{

11988 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

11989 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_historyservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_historyservice_v1_request_response_proto_rawDesc)),

11990 > NumEnums: 0,

11991 > NumMessages: 171,

11992 > NumExtensions: 1,

11993 > NumServices: 0,

11994 > },

11995 > GoTypes: file_temporal_server_api_historyservice_v1_request_response_proto_goTypes,

11996 > DependencyIndexes: file_temporal_server_api_historyservice_v1_request_response_proto_depIdxs,

11997 > MessageInfos: file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes,

11998 > ExtensionInfos: file_temporal_server_api_historyservice_v1_request_response_proto_extTypes,

11999 > }.Build()

12000 > File_temporal_server_api_historyservice_v1_request_response_proto = out.File

12001 > file_temporal_server_api_historyservice_v1_request_response_proto_goTypes = nil

12002 > file_temporal_server_api_historyservice_v1_request_response_proto_depIdxs = nil

12003 }

go.temporal.io/server/api/matchingservice/v1/request_response.pb.go 43 covered LOC · 1 range

Open complete file

6833 }

6834

6835 > func init() { file_temporal_server_api_matchingservice_v1_request_response_proto_init() } request_response.pb.go

6836 > func file_temporal_server_api_matchingservice_v1_request_response_proto_init() {

6837 > if File_temporal_server_api_matchingservice_v1_request_response_proto != nil {

6838 > return

6839 > }

6840 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[27].OneofWrappers = []any{

6841 > (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_)(nil),

6842 > (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_)(nil),

6843 > (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId)(nil),

6844 > }

6845 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[29].OneofWrappers = []any{

6846 > (*GetWorkerVersioningRulesRequest_Request)(nil),

6847 > }

6848 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[31].OneofWrappers = []any{

6849 > (*UpdateWorkerVersioningRulesRequest_Request)(nil),

6850 > }

6851 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[37].OneofWrappers = []any{

6852 > (*SyncDeploymentUserDataRequest_UpdateVersionData)(nil),

6853 > (*SyncDeploymentUserDataRequest_ForgetVersion)(nil),

6854 > }

6855 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[56].OneofWrappers = []any{

6856 > (*DispatchNexusTaskResponse_HandlerError)(nil),

6857 > (*DispatchNexusTaskResponse_Response)(nil),

6858 > (*DispatchNexusTaskResponse_RequestTimeout)(nil),

6859 > (*DispatchNexusTaskResponse_Failure)(nil),

6860 > }

6861 > type x struct{}

6862 > out := protoimpl.TypeBuilder{

6863 > File: protoimpl.DescBuilder{

6864 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

6865 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_matchingservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_matchingservice_v1_request_response_proto_rawDesc)),

6866 > NumEnums: 0,

6867 > NumMessages: 97,

6868 > NumExtensions: 0,

6869 > NumServices: 0,

6870 > },

6871 > GoTypes: file_temporal_server_api_matchingservice_v1_request_response_proto_goTypes,

6872 > DependencyIndexes: file_temporal_server_api_matchingservice_v1_request_response_proto_depIdxs,

6873 > MessageInfos: file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes,

6874 > }.Build()

6875 > File_temporal_server_api_matchingservice_v1_request_response_proto = out.File

6876 > file_temporal_server_api_matchingservice_v1_request_response_proto_goTypes = nil

6877 > file_temporal_server_api_matchingservice_v1_request_response_proto_depIdxs = nil

6878 }

go.temporal.io/server/common/log/tag/tags.go 42 covered LOC · 13 ranges

Open complete file

35

36 // Error returns tag for Error

37 > func Error(err error) ZapTag { tags.go

38 > return ZapTag{

39 > // NOTE: zap already chosen "error" as key

40 > field: zap.Error(err),

41 > }

42 > }

43

44 // ServiceErrorType returns tag for ServiceErrorType

70

71 // WorkflowAction returns tag for WorkflowAction

72 > func workflowAction(action string) ZapTag { tags.go

73 > return NewStringTag("wf-action", action)

74 > }

75

76 // WorkflowListFilterType returns tag for WorkflowListFilterType

77 > func workflowListFilterType(listFilterType string) ZapTag { tags.go

78 > return NewStringTag("wf-list-filter-type", listFilterType)

79 > }

80

81 // general

108 // WorkflowID returns tag for WorkflowID

109 // TODO: Rename to BusinessID.

110 > func WorkflowID(workflowID string) ZapTag { tags.go

111 > return NewStringTag(WorkflowIDKey, workflowID)

112 > }

113

114 // WorkflowType returns tag for WorkflowType

124 // WorkflowRunID returns tag for WorkflowRunID

125 // TODO: Rename to RunID

126 > func WorkflowRunID(runID string) ZapTag { tags.go

127 > return NewStringTag(WorkflowRunIDKey, runID)

128 > }

129

130 // WorkflowNewRunID returns tag for WorkflowNewRunID

187 // WorkflowNamespaceID returns tag for WorkflowNamespaceID

188 // TODO: Rename to NamespaceID

189 > func WorkflowNamespaceID(namespaceID string) ZapTag { tags.go

190 > return NewStringTag("wf-namespace-id", namespaceID)

191 > }

192

193 // WorkflowNamespace returns tag for WorkflowNamespace

376

377 // Component returns tag for Component

378 > func component(component string) ZapTag { tags.go

379 > return NewStringTag("component", component)

380 > }

381

382 // Lifecycle returns tag for Lifecycle

383 > func lifecycle(lifecycle string) ZapTag { tags.go

384 > return NewStringTag("lifecycle", lifecycle)

385 > }

386

387 // StoreOperation returns tag for StoreOperation

388 > func storeOperation(storeOperation string) ZapTag { tags.go

389 > return NewStringTag("store-operation", storeOperation)

390 > }

391

392 // OperationResult returns tag for OperationResult

393 > func operationResult(operationResult string) ZapTag { tags.go

394 > return NewStringTag("operation-result", operationResult)

395 > }

396

397 // ErrorType returns tag for ErrorType

401

402 // errorType returns tag for ErrorType given a string

403 > func errorType(errorType string) ZapTag { tags.go

404 > return NewStringTag("error-type", errorType)

405 > }

406

407 // Shardupdate returns tag for Shardupdate

408 > func shardupdate(shardupdate string) ZapTag { tags.go

409 > return NewStringTag("shard-update", shardupdate)

410 > }

411

412 // scope returns a tag for scope

413 // Pre-defined scope tags are in values.go.

414 > func scope(scope string) ZapTag { tags.go

415 > return NewStringTag("scope", scope)

416 > }

417

418 // general

go.temporal.io/server/api/token/v1/message.pb.go 38 covered LOC · 6 ranges

Open complete file

597 }

598

599 > func (x *NexusOperationCompletion) Reset() { message.pb.go

600 > *x = NexusOperationCompletion{}

601 > mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[6]

602 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

603 > ms.StoreMessageInfo(mi)

604 > }

605

606 func (x *NexusOperationCompletion) String() string {

610 func (*NexusOperationCompletion) ProtoMessage() {}

611

612 > func (x *NexusOperationCompletion) ProtoReflect() protoreflect.Message { message.pb.go

613 > mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[6]

614 > if x != nil {

615 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) message.pb.go

616 > if ms.LoadMessageInfo() == nil {

617 > ms.StoreMessageInfo(mi)

618 > }

619 > return ms

620 }

621 return mi.MessageOf(x)

662 }

663

664 > func (x *NexusOperationCompletion) GetComponentRef() []byte { message.pb.go

665 > if x != nil {

666 > return x.ComponentRef

667 > }

668 return nil

669 }

785 }

786

787 > func init() { file_temporal_server_api_token_v1_message_proto_init() } message.pb.go

788 > func file_temporal_server_api_token_v1_message_proto_init() {

789 > if File_temporal_server_api_token_v1_message_proto != nil {

790 return

791 }

792 > type x struct{} message.pb.go

793 > out := protoimpl.TypeBuilder{

794 > File: protoimpl.DescBuilder{

795 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

796 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_token_v1_message_proto_rawDesc), len(file_temporal_server_api_token_v1_message_proto_rawDesc)),

797 > NumEnums: 0,

798 > NumMessages: 7,

799 > NumExtensions: 0,

800 > NumServices: 0,

801 > },

802 > GoTypes: file_temporal_server_api_token_v1_message_proto_goTypes,

803 > DependencyIndexes: file_temporal_server_api_token_v1_message_proto_depIdxs,

804 > MessageInfos: file_temporal_server_api_token_v1_message_proto_msgTypes,

805 > }.Build()

806 > File_temporal_server_api_token_v1_message_proto = out.File

807 > file_temporal_server_api_token_v1_message_proto_goTypes = nil

808 > file_temporal_server_api_token_v1_message_proto_depIdxs = nil

809 }

go.temporal.io/server/api/adminservice/v1/request_response.pb.go 36 covered LOC · 1 range

Open complete file

6623 }

6624

6625 > func init() { file_temporal_server_api_adminservice_v1_request_response_proto_init() } request_response.pb.go

6626 > func file_temporal_server_api_adminservice_v1_request_response_proto_init() {

6627 > if File_temporal_server_api_adminservice_v1_request_response_proto != nil {

6628 > return

6629 > }

6630 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[59].OneofWrappers = []any{

6631 > (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState)(nil),

6632 > }

6633 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[60].OneofWrappers = []any{

6634 > (*StreamWorkflowReplicationMessagesResponse_Messages)(nil),

6635 > }

6636 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[61].OneofWrappers = []any{

6637 > (*GetNamespaceRequest_Namespace)(nil),

6638 > (*GetNamespaceRequest_Id)(nil),

6639 > }

6640 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[90].OneofWrappers = []any{

6641 > (*StartAdminBatchOperationRequest_RefreshTasksOperation)(nil),

6642 > }

6643 > type x struct{}

6644 > out := protoimpl.TypeBuilder{

6645 > File: protoimpl.DescBuilder{

6646 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

6647 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_adminservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_adminservice_v1_request_response_proto_rawDesc)),

6648 > NumEnums: 1,

6649 > NumMessages: 105,

6650 > NumExtensions: 0,

6651 > NumServices: 0,

6652 > },

6653 > GoTypes: file_temporal_server_api_adminservice_v1_request_response_proto_goTypes,

6654 > DependencyIndexes: file_temporal_server_api_adminservice_v1_request_response_proto_depIdxs,

6655 > EnumInfos: file_temporal_server_api_adminservice_v1_request_response_proto_enumTypes,

6656 > MessageInfos: file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes,

6657 > }.Build()

6658 > File_temporal_server_api_adminservice_v1_request_response_proto = out.File

6659 > file_temporal_server_api_adminservice_v1_request_response_proto_goTypes = nil

6660 > file_temporal_server_api_adminservice_v1_request_response_proto_depIdxs = nil

6661 }

go.temporal.io/server/api/replication/v1/message.pb.go 36 covered LOC · 2 ranges

Open complete file

2441 }

2442

2443 > func init() { file_temporal_server_api_replication_v1_message_proto_init() } message.pb.go

2444 > func file_temporal_server_api_replication_v1_message_proto_init() {

2445 > if File_temporal_server_api_replication_v1_message_proto != nil {

2446 return

2447 }

2448 > file_temporal_server_api_replication_v1_message_proto_msgTypes[0].OneofWrappers = []any{ message.pb.go

2449 > (*ReplicationTask_NamespaceTaskAttributes)(nil),

2450 > (*ReplicationTask_SyncShardStatusTaskAttributes)(nil),

2451 > (*ReplicationTask_SyncActivityTaskAttributes)(nil),

2452 > (*ReplicationTask_HistoryTaskAttributes)(nil),

2453 > (*ReplicationTask_SyncWorkflowStateTaskAttributes)(nil),

2454 > (*ReplicationTask_TaskQueueUserDataAttributes)(nil),

2455 > (*ReplicationTask_SyncHsmAttributes)(nil),

2456 > (*ReplicationTask_BackfillHistoryTaskAttributes)(nil),

2457 > (*ReplicationTask_VerifyVersionedTransitionTaskAttributes)(nil),

2458 > (*ReplicationTask_SyncVersionedTransitionTaskAttributes)(nil),

2459 > }

2460 > file_temporal_server_api_replication_v1_message_proto_msgTypes[21].OneofWrappers = []any{

2461 > (*VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes)(nil),

2462 > (*VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes)(nil),

2463 > }

2464 > type x struct{}

2465 > out := protoimpl.TypeBuilder{

2466 > File: protoimpl.DescBuilder{

2467 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

2468 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_replication_v1_message_proto_rawDesc), len(file_temporal_server_api_replication_v1_message_proto_rawDesc)),

2469 > NumEnums: 0,

2470 > NumMessages: 23,

2471 > NumExtensions: 0,

2472 > NumServices: 0,

2473 > },

2474 > GoTypes: file_temporal_server_api_replication_v1_message_proto_goTypes,

2475 > DependencyIndexes: file_temporal_server_api_replication_v1_message_proto_depIdxs,

2476 > MessageInfos: file_temporal_server_api_replication_v1_message_proto_msgTypes,

2477 > }.Build()

2478 > File_temporal_server_api_replication_v1_message_proto = out.File

2479 > file_temporal_server_api_replication_v1_message_proto_goTypes = nil

2480 > file_temporal_server_api_replication_v1_message_proto_depIdxs = nil

2481 }

go.temporal.io/server/common/metrics/defs.go 35 covered LOC · 5 ranges

Open complete file

20 )

21

22 > func NewTimerDef(name string, opts ...Option) timerDefinition { defs.go

23 > // This line cannot be combined with others!

24 > // This ensures the stack trace has information of the caller.

25 > def := newMetricDefinition(name, opts...)

26 > globalRegistry.register(def)

27 > return timerDefinition{def}

28 > }

29

30 > func NewBytesHistogramDef(name string, opts ...Option) histogramDefinition { defs.go

31 > // This line cannot be combined with others!

32 > // This ensures the stack trace has information of the caller.

33 > def := newMetricDefinition(name, append(opts, WithUnit(Bytes))...)

34 > globalRegistry.register(def)

35 > return histogramDefinition{def}

36 > }

37

38 > func NewDimensionlessHistogramDef(name string, opts ...Option) histogramDefinition { defs.go

39 > // This line cannot be combined with others!

40 > // This ensures the stack trace has information of the caller.

41 > def := newMetricDefinition(name, append(opts, WithUnit(Dimensionless))...)

42 > globalRegistry.register(def)

43 > return histogramDefinition{def}

44 > }

45

46 > func NewCounterDef(name string, opts ...Option) counterDefinition { defs.go

47 > // This line cannot be combined with others!

48 > // This ensures the stack trace has information of the caller.

49 > def := newMetricDefinition(name, opts...)

50 > globalRegistry.register(def)

51 > return counterDefinition{def}

52 > }

53

54 > func NewGaugeDef(name string, opts ...Option) gaugeDefinition { defs.go

55 > // This line cannot be combined with others!

56 > // This ensures the stack trace has information of the caller.

57 > def := newMetricDefinition(name, opts...)

58 > globalRegistry.register(def)

59 > return gaugeDefinition{def}

60 > }

61

62 func (d histogramDefinition) With(handler Handler) HistogramIface {

go.temporal.io/server/common/backoff/retrypolicy.go 34 covered LOC · 6 ranges

Open complete file

80

81 // NewExponentialRetryPolicy returns an instance of ExponentialRetryPolicy using the provided initialInterval

82 > func NewExponentialRetryPolicy(initialInterval time.Duration) *ExponentialRetryPolicy { retrypolicy.go

83 > p := &ExponentialRetryPolicy{

84 > initialInterval: initialInterval,

85 > backoffCoefficient: defaultBackoffCoefficient,

86 > maximumInterval: defaultMaximumInterval,

87 > expirationInterval: defaultExpirationInterval,

88 > maximumAttempts: defaultMaximumAttempts,

89 > }

90 >

91 > return p

92 > }

93

94 // NewRetrier is used for creating a new instance of Retrier

121 // This does *not* cause the policy to stop retrying when the interval between retries reaches the supplied duration.

122 // That is what WithExpirationInterval does. Instead, this prevents the interval from exceeding maximumInterval.

123 > func (p *ExponentialRetryPolicy) WithMaximumInterval(maximumInterval time.Duration) *ExponentialRetryPolicy { retrypolicy.go

124 > p.maximumInterval = maximumInterval

125 > return p

126 > }

127

128 // WithExpirationInterval sets the absolute expiration interval for all retries

129 > func (p *ExponentialRetryPolicy) WithExpirationInterval(expirationInterval time.Duration) *ExponentialRetryPolicy { retrypolicy.go

130 > p.expirationInterval = expirationInterval

131 > return p

132 > }

133

134 // WithMaximumAttempts sets the maximum number of retry attempts

135 > func (p *ExponentialRetryPolicy) WithMaximumAttempts(maximumAttempts int) *ExponentialRetryPolicy { retrypolicy.go

136 > p.maximumAttempts = maximumAttempts

137 > return p

138 > }

139

140 // ComputeNextDelay returns the next delay interval. This is used by Retrier to delay calling the operation again

267 var _ RetryPolicy = (*ConstantDelayRetryPolicy)(nil)

268

269 > func NewConstantDelayRetryPolicy(delay time.Duration) *ConstantDelayRetryPolicy { retrypolicy.go

270 > return &ConstantDelayRetryPolicy{

271 > maximumAttempts: defaultMaximumAttempts,

272 > jitterPct: defaultJitterPct,

273 > delay: delay,

274 > }

275 > }

276

277 > func (p *ConstantDelayRetryPolicy) WithMaximumAttempts(maximumAttempts int) *ConstantDelayRetryPolicy { retrypolicy.go

278 > p.maximumAttempts = maximumAttempts

279 > return p

280 > }

281

282 func (p *ConstantDelayRetryPolicy) WithJitter(jitterPct float64) *ConstantDelayRetryPolicy {

go.temporal.io/server/chasm/engine_mock.go 33 covered LOC · 8 ranges

Open complete file

30

31 // NewMockEngine creates a new mock instance.

32 > func NewMockEngine(ctrl *gomock.Controller) *MockEngine { engine_mock.go

33 > mock := &MockEngine{ctrl: ctrl}

34 > mock.recorder = &MockEngineMockRecorder{mock}

35 > return mock

36 > }

37

38 // EXPECT returns an object that allows the caller to indicate expected use.

39 > func (m *MockEngine) EXPECT() *MockEngineMockRecorder { engine_mock.go

40 > return m.recorder

41 > }

42

43 // DeleteExecution mocks base method.

88

89 // ReadComponent mocks base method.

90 > func (m *MockEngine) ReadComponent(arg0 context.Context, arg1 ComponentRef, arg2 func(Context, Component) error, arg3 ...TransitionOption) error { engine_mock.go

91 > m.ctrl.T.Helper()

92 > varargs := []any{arg0, arg1, arg2}

93 > for _, a := range arg3 {

94 varargs = append(varargs, a)

95 }

96 > ret := m.ctrl.Call(m, "ReadComponent", varargs...) engine_mock.go

97 > ret0, _ := ret[0].(error)

98 > return ret0

99 }

100

101 // ReadComponent indicates an expected call of ReadComponent.

102 > func (mr *MockEngineMockRecorder) ReadComponent(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call { engine_mock.go

103 > mr.mock.ctrl.T.Helper()

104 > varargs := append([]any{arg0, arg1, arg2}, arg3...)

105 > return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ReadComponent", reflect.TypeOf((*MockEngine)(nil).ReadComponent), varargs...)

106 > }

107

108 // StartExecution mocks base method.

127

128 // UpdateComponent mocks base method.

129 > func (m *MockEngine) UpdateComponent(arg0 context.Context, arg1 ComponentRef, arg2 func(MutableContext, Component) error, arg3 ...TransitionOption) ([]byte, error) { engine_mock.go

130 > m.ctrl.T.Helper()

131 > varargs := []any{arg0, arg1, arg2}

132 > for _, a := range arg3 {

133 varargs = append(varargs, a)

134 }

135 > ret := m.ctrl.Call(m, "UpdateComponent", varargs...) engine_mock.go

136 > ret0, _ := ret[0].([]byte)

137 > ret1, _ := ret[1].(error)

138 > return ret0, ret1

139 }

140

141 // UpdateComponent indicates an expected call of UpdateComponent.

142 > func (mr *MockEngineMockRecorder) UpdateComponent(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call { engine_mock.go

143 > mr.mock.ctrl.T.Helper()

144 > varargs := append([]any{arg0, arg1, arg2}, arg3...)

145 > return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateComponent", reflect.TypeOf((*MockEngine)(nil).UpdateComponent), varargs...)

146 > }

147

148 // UpdateWithStartExecution mocks base method.

go.temporal.io/server/chasm/lib/callback/component.go 33 covered LOC · 9 ranges

Open complete file

62 }

63

64 > func (c *Callback) StateMachineState() callbackspb.CallbackStatus { component.go

65 > return c.Status

66 > }

67

68 > func (c *Callback) SetStateMachineState(status callbackspb.CallbackStatus) { component.go

69 > c.Status = status

70 > }

71

72 > func (c *Callback) recordAttempt(ts time.Time) { component.go

73 > c.Attempt++

74 > c.LastAttemptCompleteTime = timestamppb.New(ts)

75 > }

76

77 //nolint:revive // context.Context is an input parameter for chasm.ReadComponent, not a function parameter

79 ctx chasm.Context,

80 _ chasm.NoValue,

81 > ) (invocable, error) { component.go

82 > target := c.CompletionSource.Get(ctx)

83 >

84 > completion, err := target.GetNexusCompletion(ctx, c.RequestId)

85 > if err != nil {

86 return nil, err

87 }

88

89 > callback := c.GetCallback().GetNexus() component.go

90 > if callback == nil {

91 return nil, queueserrors.NewUnprocessableTaskError(

92 fmt.Sprintf("unprocessable callback variant: %v", callback),

94 }

95

96 > if callback.Url == chasm.NexusCompletionHandlerURL { component.go

97 > return invocableInternal{ component.go

98 > callback: callback,

99 > attempt: c.Attempt,

100 > completion: completion,

101 > requestID: c.RequestId,

102 > }, nil

103 > }

104 return invocableOutbound{

105 callback: callback,

119 ctx chasm.MutableContext,

120 input saveResultInput,

121 > ) (chasm.NoValue, error) { component.go

122 > switch r := input.result.(type) {

123 case invocationResultOK:

124 err := TransitionSucceeded.Apply(c, ctx, EventSucceeded{Time: ctx.Now(c)})

131 })

132 return nil, err

133 > case invocationResultFail: component.go

134 > err := TransitionFailed.Apply(c, ctx, EventFailed{

135 > Time: ctx.Now(c),

136 > Err: r.err,

137 > })

138 > return nil, err

139 default:

140 return nil, queueserrors.NewUnprocessableTaskError(

go.temporal.io/server/api/persistence/v1/update.pb.go 31 covered LOC · 1 range

Open complete file

422 }

423

424 > func init() { file_temporal_server_api_persistence_v1_update_proto_init() } update.pb.go

425 > func file_temporal_server_api_persistence_v1_update_proto_init() {

426 > if File_temporal_server_api_persistence_v1_update_proto != nil {

427 > return

428 > }

429 > file_temporal_server_api_persistence_v1_hsm_proto_init()

430 > file_temporal_server_api_persistence_v1_update_proto_msgTypes[0].OneofWrappers = []any{

431 > (*UpdateAdmissionInfo_HistoryPointer_)(nil),

432 > }

433 > file_temporal_server_api_persistence_v1_update_proto_msgTypes[3].OneofWrappers = []any{

434 > (*UpdateInfo_Acceptance)(nil),

435 > (*UpdateInfo_Completion)(nil),

436 > (*UpdateInfo_Admission)(nil),

437 > }

438 > type x struct{}

439 > out := protoimpl.TypeBuilder{

440 > File: protoimpl.DescBuilder{

441 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

442 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_update_proto_rawDesc), len(file_temporal_server_api_persistence_v1_update_proto_rawDesc)),

443 > NumEnums: 0,

444 > NumMessages: 5,

445 > NumExtensions: 0,

446 > NumServices: 0,

447 > },

448 > GoTypes: file_temporal_server_api_persistence_v1_update_proto_goTypes,

449 > DependencyIndexes: file_temporal_server_api_persistence_v1_update_proto_depIdxs,

450 > MessageInfos: file_temporal_server_api_persistence_v1_update_proto_msgTypes,

451 > }.Build()

452 > File_temporal_server_api_persistence_v1_update_proto = out.File

453 > file_temporal_server_api_persistence_v1_update_proto_goTypes = nil

454 > file_temporal_server_api_persistence_v1_update_proto_depIdxs = nil

455 }

go.temporal.io/server/chasm/node_backend_mock.go 31 covered LOC · 13 ranges

Open complete file

51 }

52

53 > func (m *MockNodeBackend) GetExecutionState() *persistencespb.WorkflowExecutionState { node_backend_mock.go

54 > if m.HandleGetExecutionState != nil {

55 return m.HandleGetExecutionState()

56 }

57 > return &persistencespb.WorkflowExecutionState{} node_backend_mock.go

58 }

59

72 }

73

74 > func (m *MockNodeBackend) GetCurrentVersion() int64 { node_backend_mock.go

75 > if m.HandleGetCurrentVersion != nil {

76 return m.HandleGetCurrentVersion()

77 }

78 > return 0 node_backend_mock.go

79 }

80

81 > func (m *MockNodeBackend) NextTransitionCount() int64 { node_backend_mock.go

82 > if m.HandleNextTransitionCount != nil {

83 return m.HandleNextTransitionCount()

84 }

85 > return 0 node_backend_mock.go

86 }

87

93 }

94

95 > func (m *MockNodeBackend) GetWorkflowKey() definition.WorkflowKey { node_backend_mock.go

96 > if m.HandleGetWorkflowKey != nil {

97 return m.HandleGetWorkflowKey()

98 }

99 > return definition.WorkflowKey{} node_backend_mock.go

100 }

101

112 }

113

114 > func (m *MockNodeBackend) DeleteCHASMPureTasks(maxScheduledTime time.Time) { node_backend_mock.go

115 > m.mu.Lock()

116 > defer m.mu.Unlock()

117 >

118 > m.DeletePureTaskCalls = append(m.DeletePureTaskCalls, maxScheduledTime)

119 > }

120

121 func (m *MockNodeBackend) LastDeletePureTaskCall() time.Time {

132 state enumsspb.WorkflowExecutionState,

133 status enumspb.WorkflowExecutionStatus,

134 > ) (bool, error) { node_backend_mock.go

135 > if m.HandleUpdateWorkflowStateStatus != nil {

136 ok, err := m.HandleUpdateWorkflowStateStatus(state, status)

137

146 }

147

148 > m.mu.Lock() node_backend_mock.go

149 > m.UpdateCalls = append(m.UpdateCalls, struct {

150 > State enumsspb.WorkflowExecutionState

151 > Status enumspb.WorkflowExecutionStatus

152 > }{State: state, Status: status})

153 > m.mu.Unlock()

154 >

155 > return false, nil

156 }

157

174 }

175

176 > func (m *MockNodeBackend) IsWorkflow() bool { node_backend_mock.go

177 > if m.HandleIsWorkflow != nil {

178 return m.HandleIsWorkflow()

179 }

180 > return false node_backend_mock.go

181 }

182

go.temporal.io/server/common/dynamicconfig/deepcopy.go 31 covered LOC · 6 ranges

Open complete file

9 // deepCopyForMapstructure does a simple deep copy of T. Fancy cases (anything other than plain old data)

10 // is not handled and will panic.

11 > func deepCopyForMapstructure[T any](t T) T { deepcopy.go

12 > // nolint:revive // this will be triggered from a static initializer before it can be triggered from production code

13 > return deepCopyValue(reflect.ValueOf(t)).Interface().(T)

14 > }

15

16 > func deepCopyValue(v reflect.Value) reflect.Value { deepcopy.go

17 > switch v.Kind() {

18 case reflect.Bool, reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64,

19 reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64,

20 > reflect.Uintptr, reflect.Float32, reflect.Float64, reflect.String: deepcopy.go

21 > nv := reflect.New(v.Type()).Elem()

22 > nv.Set(v)

23 > return nv

24 case reflect.Array:

25 nv := reflect.New(v.Type()).Elem()

42 }

43 return deepCopyValue(v.Elem()).Addr()

44 > case reflect.Slice: deepcopy.go

45 > if v.IsNil() {

46 > return v

47 > }

48 nv := reflect.MakeSlice(v.Type(), v.Len(), v.Len())

49 for i := range v.Len() {

51 }

52 return nv

53 > case reflect.Struct: deepcopy.go

54 > // Special case for time.Time: it has unexported fields so we can't copy it field by

55 > // field, but we can copy zero values (which is all we need for default values).

56 > if v.Type() == reflect.TypeFor[time.Time]() {

57 > if v.Interface().(time.Time).IsZero() {

58 > return reflect.ValueOf(time.Time{})

59 > }

60 // nolint:forbidigo // this will be triggered from a static initializer before it can be triggered from production code

61 panic(fmt.Sprintf("Can't deep copy non-zero time.Time: %v", v.Interface()))

62 }

63 > nv := reflect.New(v.Type()).Elem() deepcopy.go

64 > for i := range v.Type().NumField() {

65 > nv.Field(i).Set(deepCopyValue(v.Field(i)))

66 > }

67 > return nv

68 > case reflect.Interface, reflect.Func, reflect.Chan:

69 > // only nil values of any other reference types allowed!

70 > if v.IsNil() {

71 > return v

72 > }

73 fallthrough

74 default:

go.temporal.io/server/chasm/lib/callback/tasks.go 30 covered LOC · 4 ranges

Open complete file

47 func (invocationResultFail) mustImplementInvocationResult() {}

48

49 > func (r invocationResultFail) error() error { tasks.go

50 > return r.err

51 > }

52

53 // invocationResultRetry marks an invocation as failed with the intent to retry.

114 taskAttr chasm.TaskAttributes,

115 task *callbackspb.InvocationTask,

116 > ) error { tasks.go

117 > ns, err := h.namespaceRegistry.GetNamespaceByID(namespace.ID(ref.NamespaceID))

118 > if err != nil {

119 return fmt.Errorf("failed to get namespace by ID: %w", err)

120 }

121

122 > invokable, err := chasm.ReadComponent( tasks.go

123 > ctx,

124 > ref,

125 > (*Callback).loadInvocationArgs,

126 > nil,

127 > )

128 > if err != nil {

129 return err

130 }

131

132 > callCtx, cancel := context.WithTimeout( tasks.go

133 > ctx,

134 > h.config.RequestTimeout(ns.Name().String(), taskAttr.Destination),

135 > )

136 > defer cancel()

137 >

138 > result := invokable.Invoke(callCtx, ns, h, task, taskAttr)

139 > _, _, saveErr := chasm.UpdateComponent(

140 > ctx,

141 > ref,

142 > (*Callback).saveResult,

143 > saveResultInput{

144 > result: result,

145 > retryPolicy: h.config.RetryPolicy(),

146 > },

147 > )

148 > return invokable.WrapError(result, saveErr)

149 }

150

go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/execution_maps.go 30 covered LOC · 5 ranges

Open complete file

53 )

54

55 > func stringMap(a []string, f func(string) string) []string { execution_maps.go

56 > b := make([]string, len(a))

57 > for i, v := range a {

58 > b[i] = f(v)

59 > }

60 > return b

61 }

62

63 > func makeDeleteMapQry(tableName string) string { execution_maps.go

64 > return fmt.Sprintf(deleteMapQryTemplate, tableName)

65 > }

66

67 > func makeSetKeyInMapQry(tableName string, nonPrimaryKeyColumns []string, mapKeyName string) string { execution_maps.go

68 > return fmt.Sprintf(setKeyInMapQryTemplate,

69 > tableName,

70 > strings.Join(nonPrimaryKeyColumns, ","),

71 > strings.Join(stringMap(nonPrimaryKeyColumns, func(x string) string {

72 > return ":" + x

73 > }), ","),

74 > strings.Join(stringMap(nonPrimaryKeyColumns, func(x string) string {

75 > return x + "=VALUES(" + x + ")"

76 > }), ","),

77 mapKeyName)

78 }

79

80 > func makeDeleteKeyInMapQry(tableName string, mapKeyName string) string { execution_maps.go

81 > return fmt.Sprintf(deleteKeyInMapQryTemplate,

82 > tableName,

83 > mapKeyName)

84 > }

85

86 > func makeGetMapQryTemplate(tableName string, nonPrimaryKeyColumns []string, mapKeyName string) string { execution_maps.go

87 > return fmt.Sprintf(getMapQryTemplate,

88 > tableName,

89 > mapKeyName,

90 > strings.Join(nonPrimaryKeyColumns, ","))

91 > }

92

93 var (

go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/execution_maps.go 30 covered LOC · 6 ranges

Open complete file

86 )

87

88 > func stringMap(a []string, f func(string) string) []string { execution_maps.go

89 > b := make([]string, len(a))

90 > for i, v := range a {

91 > b[i] = f(v)

92 > }

93 > return b

94 }

95

96 > func makeDeleteMapQry(tableName string) string { execution_maps.go

97 > return fmt.Sprintf(deleteMapQueryTemplate, tableName)

98 > }

99

100 > func makeSetKeyInMapQry(tableName string, nonPrimaryKeyColumns []string, mapKeyName string) string { execution_maps.go

101 > return fmt.Sprintf(setKeyInMapQueryTemplate,

102 > tableName,

103 > strings.Join(nonPrimaryKeyColumns, ","),

104 > strings.Join(stringMap(nonPrimaryKeyColumns, func(x string) string {

105 > return ":" + x

106 > }), ","),

107 mapKeyName,

108 > strings.Join(stringMap(nonPrimaryKeyColumns, func(x string) string { execution_maps.go

109 > return "excluded." + x

110 > }), ","))

111 }

112

113 > func makeDeleteKeyInMapQry(tableName string, mapKeyName string) string { execution_maps.go

114 > return fmt.Sprintf(deleteKeyInMapQueryTemplate,

115 > tableName,

116 > mapKeyName)

117 > }

118

119 > func makeGetMapQryTemplate(tableName string, nonPrimaryKeyColumns []string, mapKeyName string) string { execution_maps.go

120 > return fmt.Sprintf(getMapQueryTemplate,

121 > tableName,

122 > mapKeyName,

123 > strings.Join(nonPrimaryKeyColumns, ","))

124 > }

125

126 var (

go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/execution_maps.go 30 covered LOC · 5 ranges

Open complete file

52 )

53

54 > func stringMap(a []string, f func(string) string) []string { execution_maps.go

55 > b := make([]string, len(a))

56 > for i, v := range a {

57 > b[i] = f(v)

58 > }

59 > return b

60 }

61

62 > func makeDeleteMapQry(tableName string) string { execution_maps.go

63 > return fmt.Sprintf(deleteMapQryTemplate, tableName)

64 > }

65

66 > func makeSetKeyInMapQry(tableName string, nonPrimaryKeyColumns []string, mapKeyName string) string { execution_maps.go

67 > return fmt.Sprintf(setKeyInMapQryTemplate,

68 > tableName,

69 > strings.Join(nonPrimaryKeyColumns, ","),

70 > strings.Join(stringMap(nonPrimaryKeyColumns, func(x string) string {

71 > return ":" + x

72 > }), ","),

73 > strings.Join(stringMap(nonPrimaryKeyColumns, func(x string) string {

74 > return x + "=" + x

75 > }), ","),

76 mapKeyName)

77 }

78

79 > func makeDeleteKeyInMapQry(tableName string, mapKeyName string) string { execution_maps.go

80 > return fmt.Sprintf(deleteKeyInMapQryTemplate,

81 > tableName,

82 > mapKeyName)

83 > }

84

85 > func makeGetMapQryTemplate(tableName string, nonPrimaryKeyColumns []string, mapKeyName string) string { execution_maps.go

86 > return fmt.Sprintf(getMapQryTemplate,

87 > tableName,

88 > mapKeyName,

89 > strings.Join(nonPrimaryKeyColumns, ","))

90 > }

91

92 var (

go.temporal.io/server/common/searchattribute/sadefs/constants.go 30 covered LOC · 9 ranges

Open complete file

261 }

262

263 > dbCustomSearchAttributeFieldNameRE = func() map[enumspb.IndexedValueType]*regexp.Regexp { constants.go

264 > res := map[enumspb.IndexedValueType]*regexp.Regexp{}

265 > for t := range defaultNumDBCustomSearchAttributes {

266 > res[t] = regexp.MustCompile(fmt.Sprintf(`^%s(0[1-9]|[1-9][0-9])$`, t.String()))

267 > }

268 > return res

269 }()

270 )

271

272 // System returns a clone of the system search attributes map.

273 > func System() map[string]enumspb.IndexedValueType { constants.go

274 > return maps.Clone(system)

275 > }

276

277 // Predefined returns a clone of the predefined search attributes map.

278 > func Predefined() map[string]enumspb.IndexedValueType { constants.go

279 > return maps.Clone(predefined)

280 > }

281

282 // PredefinedWhiteList returns a clone of the predefined whitelist search attributes map.

283 > func PredefinedWhiteList() map[string]enumspb.IndexedValueType { constants.go

284 > return maps.Clone(predefinedWhiteList)

285 > }

286

287 // Reserved returns a clone of the reserved field names map.

343 // GetSqlDbColName maps system and reserved search attributes to column names for SQL tables.

344 // If the input is not a system or reserved search attribute, then it returns the input.

345 > func GetSqlDbColName(name string) string { constants.go

346 > if fieldName, ok := sqlDbSystemNameToColName[name]; ok {

347 > return fieldName constants.go

348 > }

349 return name

350 }

352 func GetDBIndexSearchAttributes(

353 override map[enumspb.IndexedValueType]int,

354 > ) *persistencespb.IndexSearchAttributes { constants.go

355 > csa := map[string]enumspb.IndexedValueType{}

356 > for saType, defaultNumAttrs := range defaultNumDBCustomSearchAttributes {

357 > numAttrs := defaultNumAttrs

358 > if value, ok := override[saType]; ok {

359 numAttrs = value

360 }

361 > for i := range numAttrs { constants.go

362 > csa[fmt.Sprintf("%s%02d", saType.String(), i+1)] = saType

363 > }

364 }

365 > return &persistencespb.IndexSearchAttributes{ constants.go

366 > CustomSearchAttributes: csa,

367 > }

368 }

369

go.temporal.io/server/api/taskqueue/v1/message.pb.go 29 covered LOC · 2 ranges

Open complete file

1330 }

1331

1332 > func init() { file_temporal_server_api_taskqueue_v1_message_proto_init() } message.pb.go

1333 > func file_temporal_server_api_taskqueue_v1_message_proto_init() {

1334 > if File_temporal_server_api_taskqueue_v1_message_proto != nil {

1335 return

1336 }

1337 > file_temporal_server_api_taskqueue_v1_message_proto_msgTypes[0].OneofWrappers = []any{ message.pb.go

1338 > (*TaskVersionDirective_UseAssignmentRules)(nil),

1339 > (*TaskVersionDirective_AssignedBuildId)(nil),

1340 > }

1341 > file_temporal_server_api_taskqueue_v1_message_proto_msgTypes[5].OneofWrappers = []any{

1342 > (*TaskQueuePartition_NormalPartitionId)(nil),

1343 > (*TaskQueuePartition_StickyName)(nil),

1344 > (*TaskQueuePartition_WorkerCommands)(nil),

1345 > }

1346 > type x struct{}

1347 > out := protoimpl.TypeBuilder{

1348 > File: protoimpl.DescBuilder{

1349 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

1350 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_taskqueue_v1_message_proto_rawDesc), len(file_temporal_server_api_taskqueue_v1_message_proto_rawDesc)),

1351 > NumEnums: 0,

1352 > NumMessages: 16,

1353 > NumExtensions: 0,

1354 > NumServices: 0,

1355 > },

1356 > GoTypes: file_temporal_server_api_taskqueue_v1_message_proto_goTypes,

1357 > DependencyIndexes: file_temporal_server_api_taskqueue_v1_message_proto_depIdxs,

1358 > MessageInfos: file_temporal_server_api_taskqueue_v1_message_proto_msgTypes,

1359 > }.Build()

1360 > File_temporal_server_api_taskqueue_v1_message_proto = out.File

1361 > file_temporal_server_api_taskqueue_v1_message_proto_goTypes = nil

1362 > file_temporal_server_api_taskqueue_v1_message_proto_depIdxs = nil

1363 }

go.temporal.io/server/chasm/field_internal.go 29 covered LOC · 8 ranges

Open complete file

15 }

16

17 > func newFieldInternalWithValue(ft fieldType, v any) fieldInternal { field_internal.go

18 > return fieldInternal{

19 > ft: ft,

20 > v: v,

21 > }

22 > }

23

24 func newFieldInternalWithNode(node *Node) fieldInternal {

28 }

29

30 > func (fi fieldInternal) isEmpty() bool { field_internal.go

31 > return fi.v == nil && fi.node == nil

32 > }

33

34 > func (fi fieldInternal) value() any { field_internal.go

35 > // Deferred pointers are special-cased, since their serialized nodes are

36 > // initialized as regular persistable pointers.

37 > //

38 > // Deferred pointers may have a non-nil node after syncSubComponents, but before

39 > // resolution.

40 > if fi.node == nil || fi.ft == fieldTypeDeferredPointer {

41 > return fi.v field_internal.go

42 > }

43 > return fi.node.value field_internal.go

44 }

45

46 > func (fi fieldInternal) fieldType() fieldType { field_internal.go

47 > // Deferred pointers are special-cased, since their serialized nodes are

48 > // initialized as regular persistable pointers.

49 > //

50 > // Deferred pointers may have a non-nil node after syncSubComponents, but before

51 > // resolution.

52 > if fi.node == nil || fi.ft == fieldTypeDeferredPointer {

53 > return fi.ft field_internal.go

54 > }

55 > return fi.node.fieldType() field_internal.go

56 }

go.temporal.io/server/api/history/v1/message.pb.go 28 covered LOC · 6 ranges

Open complete file

92 func (*VersionHistoryItem) ProtoMessage() {}

93

94 > func (x *VersionHistoryItem) ProtoReflect() protoreflect.Message { message.pb.go

95 > mi := &file_temporal_server_api_history_v1_message_proto_msgTypes[1]

96 > if x != nil {

97 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

98 if ms.LoadMessageInfo() == nil {

101 return ms

102 }

103 > return mi.MessageOf(x) message.pb.go

104 }

105

198 func (*VersionHistories) ProtoMessage() {}

199

200 > func (x *VersionHistories) ProtoReflect() protoreflect.Message { message.pb.go

201 > mi := &file_temporal_server_api_history_v1_message_proto_msgTypes[3]

202 > if x != nil {

203 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

204 if ms.LoadMessageInfo() == nil {

207 return ms

208 }

209 > return mi.MessageOf(x) message.pb.go

210 }

211

498 }

499

500 > func init() { file_temporal_server_api_history_v1_message_proto_init() } message.pb.go

501 > func file_temporal_server_api_history_v1_message_proto_init() {

502 > if File_temporal_server_api_history_v1_message_proto != nil {

503 return

504 }

505 > type x struct{} message.pb.go

506 > out := protoimpl.TypeBuilder{

507 > File: protoimpl.DescBuilder{

508 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

509 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_history_v1_message_proto_rawDesc), len(file_temporal_server_api_history_v1_message_proto_rawDesc)),

510 > NumEnums: 0,

511 > NumMessages: 8,

512 > NumExtensions: 0,

513 > NumServices: 0,

514 > },

515 > GoTypes: file_temporal_server_api_history_v1_message_proto_goTypes,

516 > DependencyIndexes: file_temporal_server_api_history_v1_message_proto_depIdxs,

517 > MessageInfos: file_temporal_server_api_history_v1_message_proto_msgTypes,

518 > }.Build()

519 > File_temporal_server_api_history_v1_message_proto = out.File

520 > file_temporal_server_api_history_v1_message_proto_goTypes = nil

521 > file_temporal_server_api_history_v1_message_proto_depIdxs = nil

522 }

go.temporal.io/server/chasm/context.go 25 covered LOC · 4 ranges

Open complete file

133 ctx context.Context,

134 node *Node,

135 > ) Context { context.go

136 > return newContext(ctx, node)

137 > }

138

139 // newContext creates a new immutableCtx from an existing Context and root Node.

142 ctx context.Context,

143 node *Node,

144 > ) *immutableCtx { context.go

145 > root := node.root()

146 > workflowKey := node.backend.GetWorkflowKey()

147 > return &immutableCtx{

148 > ctx: ctx,

149 > now: root.Now(nil),

150 > root: root,

151 > executionKey: ExecutionKey{

152 > NamespaceID: workflowKey.NamespaceID,

153 > BusinessID: workflowKey.WorkflowID,

154 > RunID: workflowKey.RunID,

155 > },

156 > }

157 > }

158

159 func (c *immutableCtx) Ref(component Component) ([]byte, error) {

230 }

231

232 > func (c *immutableCtx) goContext() context.Context { context.go

233 > return c.ctx

234 > }

235

236 func (c *immutableCtx) RequestHeader(key string) string {

256 ctx context.Context,

257 node *Node,

258 > ) MutableContext { context.go

259 > return &mutableCtx{

260 > immutableCtx: newContext(ctx, node),

261 > }

262 > }

263

264 func (c *mutableCtx) AddTask(

go.temporal.io/server/chasm/registrable_component.go 25 covered LOC · 8 ranges

Open complete file

36 componentType string,

37 opts ...RegistrableComponentOption,

38 > ) *RegistrableComponent { registrable_component.go

39 > rc := &RegistrableComponent{

40 > componentType: componentType,

41 > goType: reflect.TypeFor[C](),

42 > }

43 > for _, opt := range opts {

44 > opt(rc) registrable_component.go

45 > }

46 > return rc registrable_component.go

47 }

48

65 // If a registrable component is not detached by default, a component definition

66 // can specify its child as detached via ComponentFieldDetached() option.

67 > func WithDetached() RegistrableComponentOption { registrable_component.go

68 > return func(rc *RegistrableComponent) {

69 > rc.detached = true

70 > }

71 }

72

73 // IsDetached returns true if the component type is registered as detached.

74 > func (rc *RegistrableComponent) IsDetached() bool { registrable_component.go

75 > return rc.detached

76 > }

77

78 // WithBusinessIDAlias allows specifying the business ID alias of the component.

184 func (rc *RegistrableComponent) registerToLibrary(

185 library namer,

186 > ) (string, uint32, error) { registrable_component.go

187 > if rc.library != nil {

188 return "", 0, fmt.Errorf("component %s is already registered in library %s", rc.componentType, rc.library.Name())

189 }

190

191 > rc.library = library registrable_component.go

192 > rc.fqn = FullyQualifiedName(rc.library.Name(), rc.componentType)

193 > rc.componentID = GenerateTypeID(rc.fqn)

194 > return rc.fqn, rc.componentID, nil

195 }

196

203 // The generated ID is used to uniquely identify components and tasks within the CHASM framework. The same FQN will

204 // always produce the same ID.

205 > func GenerateTypeID(fqn string) uint32 { registrable_component.go

206 > return farm.Fingerprint32([]byte(fqn))

207 > }

208

209 // hasBusinessIDAlias returns true if the component has a businessID alias configured

go.temporal.io/server/common/persistence/serialization/codec.go 25 covered LOC · 10 ranges

Open complete file

26 // encodingTypeFromEnv returns an EncodingType based on the environment variable `TEMPORAL_TEST_DATA_ENCODING`.

27 // It defaults to "ENCODING_TYPE_PROTO3" codec if the environment variable is not set.

28 > func encodingTypeFromEnv() enumspb.EncodingType { codec.go

29 > codecType := os.Getenv(SerializerDataEncodingEnvVar)

30 > switch strings.ToLower(codecType) {

31 > case "", "proto3": codec.go

32 > return enumspb.ENCODING_TYPE_PROTO3

33 case "json":

34 return enumspb.ENCODING_TYPE_JSON

51 // a reliable equality check for any well-formed proto message. For messages

52 // without map fields this is a no-op with no performance overhead.

53 > var WithDeterministicProto3 EncodeOption = func(opts *encodeOptions) { codec.go

54 > opts.deterministic = true

55 > }

56

57 // Encode encodes the given proto message. It respects the `TEMPORAL_TEST_DATA_ENCODING` environment variable;

58 // otherwise, it defaults to "ENCODING_TYPE_PROTO3".

59 > func Encode(m proto.Message, options ...EncodeOption) (*commonpb.DataBlob, error) { codec.go

60 > return encodeBlob(m, encodingTypeFromEnv(), options...)

61 > }

62

63 func encodeBlob(

65 encoding enumspb.EncodingType,

66 options ...EncodeOption,

67 > ) (*commonpb.DataBlob, error) { codec.go

68 > opts := encodeOptions{}

69 > for _, option := range options {

70 > option(&opts) codec.go

71 > }

72

73 > if m == nil { codec.go

74 return &commonpb.DataBlob{

75 Data: nil,

78 }

79

80 > switch encoding { codec.go

81 case enumspb.ENCODING_TYPE_JSON:

82 blob, err := codec.NewJSONPBEncoder().Encode(m)

88 EncodingType: enumspb.ENCODING_TYPE_JSON,

89 }, nil

90 > case enumspb.ENCODING_TYPE_PROTO3: codec.go

91 > data, err := proto.MarshalOptions{Deterministic: opts.deterministic}.Marshal(m)

92 > if err != nil {

93 return nil, NewSerializationError(enumspb.ENCODING_TYPE_PROTO3, err)

94 }

95 > return &commonpb.DataBlob{ codec.go

96 > EncodingType: enumspb.ENCODING_TYPE_PROTO3,

97 > Data: data,

98 > }, nil

99 default:

100 return nil, NewUnknownEncodingTypeError(encoding.String(), enumspb.ENCODING_TYPE_JSON, enumspb.ENCODING_TYPE_PROTO3)

go.temporal.io/server/common/routing/route.go 25 covered LOC · 8 ranges

Open complete file

36

37 // NewRoute returns a new [Route] instance with the given components.

38 > func NewRoute[T any](components ...Component[T]) Route[T] { route.go

39 > return Route[T]{components: components}

40 > }

41

42 // RouteBuilder is a builder for the [Route] interface.

46

47 // NewBuilder creates a new [RouteBuilder] instance, which can be used to define a new [Route] via a fluent API.

48 > func NewBuilder[T any]() *RouteBuilder[T] { route.go

49 > return &RouteBuilder[T]{}

50 > }

51

52 // With adds a series of [Component] instances to the [Route].

53 > func (r *RouteBuilder[T]) With(c ...Component[T]) *RouteBuilder[T] { route.go

54 > r.components = append(r.components, c...)

55 > return r

56 > }

57

58 // Constant adds a [Constant] component to the [Route].

59 > func (r *RouteBuilder[T]) Constant(values ...string) *RouteBuilder[T] { route.go

60 > return r.With(Constant[T](values...))

61 > }

62

63 // StringVariable adds a [StringVariable] component to the [Route].

64 > func (r *RouteBuilder[T]) StringVariable(name string, getter func(*T) *string) *RouteBuilder[T] { route.go

65 > return r.With(StringVariable[T](name, getter))

66 > }

67

68 // Build returns a read-only [Route].

69 > func (r *RouteBuilder[T]) Build() Route[T] { route.go

70 > return NewRoute[T](r.components...)

71 > }

72

73 // Representation returns the [github.com/gorilla/mux] compatible string representation of the route for usage in a

111 // Constant returns a [Component] that represents a series of constant HTTP path components in a Route.

112 // They will be joined via strings when used to construct a path or path representation.

113 > func Constant[T any](values ...string) constant[T] { route.go

114 > return values

115 > }

116

117 type constant[T any] []string

128

129 // StringVariable returns a [Component] that represents a string variable in a Route.

130 > func StringVariable[T any](name string, getter func(*T) *string) stringVariable[T] { route.go

131 > return stringVariable[T]{name, getter}

132 > }

133

134 type stringVariable[T any] struct {

go.temporal.io/server/api/clock/v1/message.pb.go 24 covered LOC · 4 ranges

Open complete file

45 func (*VectorClock) ProtoMessage() {}

46

47 > func (x *VectorClock) ProtoReflect() protoreflect.Message { message.pb.go

48 > mi := &file_temporal_server_api_clock_v1_message_proto_msgTypes[0]

49 > if x != nil {

50 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))

51 if ms.LoadMessageInfo() == nil {

54 return ms

55 }

56 > return mi.MessageOf(x) message.pb.go

57 }

58

193 }

194

195 > func init() { file_temporal_server_api_clock_v1_message_proto_init() } message.pb.go

196 > func file_temporal_server_api_clock_v1_message_proto_init() {

197 > if File_temporal_server_api_clock_v1_message_proto != nil {

198 return

199 }

200 > type x struct{} message.pb.go

201 > out := protoimpl.TypeBuilder{

202 > File: protoimpl.DescBuilder{

203 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

204 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_clock_v1_message_proto_rawDesc), len(file_temporal_server_api_clock_v1_message_proto_rawDesc)),

205 > NumEnums: 0,

206 > NumMessages: 2,

207 > NumExtensions: 0,

208 > NumServices: 0,

209 > },

210 > GoTypes: file_temporal_server_api_clock_v1_message_proto_goTypes,

211 > DependencyIndexes: file_temporal_server_api_clock_v1_message_proto_depIdxs,

212 > MessageInfos: file_temporal_server_api_clock_v1_message_proto_msgTypes,

213 > }.Build()

214 > File_temporal_server_api_clock_v1_message_proto = out.File

215 > file_temporal_server_api_clock_v1_message_proto_goTypes = nil

216 > file_temporal_server_api_clock_v1_message_proto_depIdxs = nil

217 }

go.temporal.io/server/api/persistence/v1/nexus.pb.go 24 covered LOC · 2 ranges

Open complete file

481 }

482

483 > func init() { file_temporal_server_api_persistence_v1_nexus_proto_init() } nexus.pb.go

484 > func file_temporal_server_api_persistence_v1_nexus_proto_init() {

485 > if File_temporal_server_api_persistence_v1_nexus_proto != nil {

486 return

487 }

488 > file_temporal_server_api_persistence_v1_nexus_proto_msgTypes[1].OneofWrappers = []any{ nexus.pb.go

489 > (*NexusEndpointTarget_Worker_)(nil),

490 > (*NexusEndpointTarget_External_)(nil),

491 > }

492 > type x struct{}

493 > out := protoimpl.TypeBuilder{

494 > File: protoimpl.DescBuilder{

495 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

496 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_nexus_proto_rawDesc), len(file_temporal_server_api_persistence_v1_nexus_proto_rawDesc)),

497 > NumEnums: 0,

498 > NumMessages: 6,

499 > NumExtensions: 0,

500 > NumServices: 0,

501 > },

502 > GoTypes: file_temporal_server_api_persistence_v1_nexus_proto_goTypes,

503 > DependencyIndexes: file_temporal_server_api_persistence_v1_nexus_proto_depIdxs,

504 > MessageInfos: file_temporal_server_api_persistence_v1_nexus_proto_msgTypes,

505 > }.Build()

506 > File_temporal_server_api_persistence_v1_nexus_proto = out.File

507 > file_temporal_server_api_persistence_v1_nexus_proto_goTypes = nil

508 > file_temporal_server_api_persistence_v1_nexus_proto_depIdxs = nil

509 }

go.temporal.io/server/api/persistence/v1/workflow_mutable_state.pb.go 24 covered LOC · 2 ranges

Open complete file

532 }

533

534 > func init() { file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_init() } workflow_mutable_state.pb.go

535 > func file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_init() {

536 > if File_temporal_server_api_persistence_v1_workflow_mutable_state_proto != nil {

537 return

538 }

539 > file_temporal_server_api_persistence_v1_chasm_proto_init() workflow_mutable_state.pb.go

540 > file_temporal_server_api_persistence_v1_executions_proto_init()

541 > file_temporal_server_api_persistence_v1_hsm_proto_init()

542 > file_temporal_server_api_persistence_v1_update_proto_init()

543 > type x struct{}

544 > out := protoimpl.TypeBuilder{

545 > File: protoimpl.DescBuilder{

546 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

547 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_rawDesc), len(file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_rawDesc)),

548 > NumEnums: 0,

549 > NumMessages: 16,

550 > NumExtensions: 0,

551 > NumServices: 0,

552 > },

553 > GoTypes: file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_goTypes,

554 > DependencyIndexes: file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_depIdxs,

555 > MessageInfos: file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_msgTypes,

556 > }.Build()

557 > File_temporal_server_api_persistence_v1_workflow_mutable_state_proto = out.File

558 > file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_goTypes = nil

559 > file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_depIdxs = nil

560 }

go.temporal.io/server/api/enums/v1/predicate.pb.go 23 covered LOC · 3 ranges

Open complete file

111 }

112

113 > func (PredicateType) Descriptor() protoreflect.EnumDescriptor { predicate.pb.go

114 > return file_temporal_server_api_enums_v1_predicate_proto_enumTypes[0].Descriptor()

115 > }

116

117 func (PredicateType) Type() protoreflect.EnumType {

170 }

171

172 > func init() { file_temporal_server_api_enums_v1_predicate_proto_init() } predicate.pb.go

173 > func file_temporal_server_api_enums_v1_predicate_proto_init() {

174 > if File_temporal_server_api_enums_v1_predicate_proto != nil {

175 return

176 }

177 > type x struct{} predicate.pb.go

178 > out := protoimpl.TypeBuilder{

179 > File: protoimpl.DescBuilder{

180 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

181 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_predicate_proto_rawDesc), len(file_temporal_server_api_enums_v1_predicate_proto_rawDesc)),

182 > NumEnums: 1,

183 > NumMessages: 0,

184 > NumExtensions: 0,

185 > NumServices: 0,

186 > },

187 > GoTypes: file_temporal_server_api_enums_v1_predicate_proto_goTypes,

188 > DependencyIndexes: file_temporal_server_api_enums_v1_predicate_proto_depIdxs,

189 > EnumInfos: file_temporal_server_api_enums_v1_predicate_proto_enumTypes,

190 > }.Build()

191 > File_temporal_server_api_enums_v1_predicate_proto = out.File

192 > file_temporal_server_api_enums_v1_predicate_proto_goTypes = nil

193 > file_temporal_server_api_enums_v1_predicate_proto_depIdxs = nil

194 }

go.temporal.io/server/api/enums/v1/task.pb.go 23 covered LOC · 3 ranges

Open complete file

303 }

304

305 > func (TaskType) Descriptor() protoreflect.EnumDescriptor { task.pb.go

306 > return file_temporal_server_api_enums_v1_task_proto_enumTypes[1].Descriptor()

307 > }

308

309 func (TaskType) Type() protoreflect.EnumType {

456 }

457

458 > func init() { file_temporal_server_api_enums_v1_task_proto_init() } task.pb.go

459 > func file_temporal_server_api_enums_v1_task_proto_init() {

460 > if File_temporal_server_api_enums_v1_task_proto != nil {

461 return

462 }

463 > type x struct{} task.pb.go

464 > out := protoimpl.TypeBuilder{

465 > File: protoimpl.DescBuilder{

466 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

467 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_task_proto_rawDesc), len(file_temporal_server_api_enums_v1_task_proto_rawDesc)),

468 > NumEnums: 3,

469 > NumMessages: 0,

470 > NumExtensions: 0,

471 > NumServices: 0,

472 > },

473 > GoTypes: file_temporal_server_api_enums_v1_task_proto_goTypes,

474 > DependencyIndexes: file_temporal_server_api_enums_v1_task_proto_depIdxs,

475 > EnumInfos: file_temporal_server_api_enums_v1_task_proto_enumTypes,

476 > }.Build()

477 > File_temporal_server_api_enums_v1_task_proto = out.File

478 > file_temporal_server_api_enums_v1_task_proto_goTypes = nil

479 > file_temporal_server_api_enums_v1_task_proto_depIdxs = nil

480 }

go.temporal.io/server/api/persistence/v1/queues.pb.go 23 covered LOC · 1 range

Open complete file

616 }

617

618 > func init() { file_temporal_server_api_persistence_v1_queues_proto_init() } queues.pb.go

619 > func file_temporal_server_api_persistence_v1_queues_proto_init() {

620 > if File_temporal_server_api_persistence_v1_queues_proto != nil {

621 > return

622 > }

623 > file_temporal_server_api_persistence_v1_predicates_proto_init()

624 > type x struct{}

625 > out := protoimpl.TypeBuilder{

626 > File: protoimpl.DescBuilder{

627 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

628 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_queues_proto_rawDesc), len(file_temporal_server_api_persistence_v1_queues_proto_rawDesc)),

629 > NumEnums: 0,

630 > NumMessages: 12,

631 > NumExtensions: 0,

632 > NumServices: 0,

633 > },

634 > GoTypes: file_temporal_server_api_persistence_v1_queues_proto_goTypes,

635 > DependencyIndexes: file_temporal_server_api_persistence_v1_queues_proto_depIdxs,

636 > MessageInfos: file_temporal_server_api_persistence_v1_queues_proto_msgTypes,

637 > }.Build()

638 > File_temporal_server_api_persistence_v1_queues_proto = out.File

639 > file_temporal_server_api_persistence_v1_queues_proto_goTypes = nil

640 > file_temporal_server_api_persistence_v1_queues_proto_depIdxs = nil

641 }

go.temporal.io/server/chasm/lib/callback/library.go 23 covered LOC · 3 ranges

Open complete file

31 }

32

33 > func (l *Library) Name() string { library.go

34 > return chasm.CallbackLibraryName

35 > }

36

37 > func (l *Library) Components() []*chasm.RegistrableComponent { library.go

38 > return []*chasm.RegistrableComponent{

39 > chasm.NewRegistrableComponent[*Callback](

40 > chasm.CallbackComponentName,

41 > chasm.WithDetached(),

42 > ),

43 > }

44 > }

45

46 > func (l *Library) Tasks() []*chasm.RegistrableTask { library.go

47 > return []*chasm.RegistrableTask{

48 > chasm.NewRegistrableSideEffectTask(

49 > "invoke",

50 > l.InvocationTaskHandler,

51 > ),

52 > chasm.NewRegistrablePureTask(

53 > "backoff",

54 > l.BackoffTaskHandler,

55 > ),

56 > }

57 > }

58

59 func (l *Library) RegisterServices(server *grpc.Server) {

go.temporal.io/server/common/clock/event_time_source.go 23 covered LOC · 5 ranges

Open complete file

39

40 // NewEventTimeSource returns a EventTimeSource with the current time set to Unix zero: 1970-01-01 00:00:00 +0000 UTC.

41 > func NewEventTimeSource() *EventTimeSource { event_time_source.go

42 > return &EventTimeSource{

43 > now: time.Unix(0, 0),

44 > }

45 > }

46

47 // Some clients depend on the fact that the runtime's timers do _not_ run synchronously.

55

56 // Now return the current time.

57 > func (ts *EventTimeSource) Now() time.Time { event_time_source.go

58 > ts.mu.RLock()

59 > defer ts.mu.RUnlock()

60 >

61 > return ts.now

62 > }

63

64 func (ts *EventTimeSource) Since(t time.Time) time.Duration {

106 // Update the fake current time. It returns the timeSource so that you can chain calls like this:

107 // timeSource := NewEventTimeSource().Update(time.Now())

108 > func (ts *EventTimeSource) Update(now time.Time) *EventTimeSource { event_time_source.go

109 > ts.mu.Lock()

110 > defer ts.mu.Unlock()

111 >

112 > ts.now = now

113 > ts.fireTimers()

114 > return ts

115 > }

116

117 // Advance the timer by the specified duration.

156

157 // fireTimers fires all timers that are ready.

158 > func (ts *EventTimeSource) fireTimers() { event_time_source.go

159 > n := 0

160 > for _, t := range ts.timers {

161 if t.deadline.After(ts.now) {

162 ts.timers[n] = t

172 }

173 }

174 > ts.timers = ts.timers[:n] event_time_source.go

175 }

176

go.temporal.io/server/api/common/v1/api_category.pb.go 22 covered LOC · 2 ranges

Open complete file

204 }

205

206 > func init() { file_temporal_server_api_common_v1_api_category_proto_init() } api_category.pb.go

207 > func file_temporal_server_api_common_v1_api_category_proto_init() {

208 > if File_temporal_server_api_common_v1_api_category_proto != nil {

209 return

210 }

211 > type x struct{} api_category.pb.go

212 > out := protoimpl.TypeBuilder{

213 > File: protoimpl.DescBuilder{

214 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

215 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_common_v1_api_category_proto_rawDesc), len(file_temporal_server_api_common_v1_api_category_proto_rawDesc)),

216 > NumEnums: 1,

217 > NumMessages: 1,

218 > NumExtensions: 1,

219 > NumServices: 0,

220 > },

221 > GoTypes: file_temporal_server_api_common_v1_api_category_proto_goTypes,

222 > DependencyIndexes: file_temporal_server_api_common_v1_api_category_proto_depIdxs,

223 > EnumInfos: file_temporal_server_api_common_v1_api_category_proto_enumTypes,

224 > MessageInfos: file_temporal_server_api_common_v1_api_category_proto_msgTypes,

225 > ExtensionInfos: file_temporal_server_api_common_v1_api_category_proto_extTypes,

226 > }.Build()

227 > File_temporal_server_api_common_v1_api_category_proto = out.File

228 > file_temporal_server_api_common_v1_api_category_proto_goTypes = nil

229 > file_temporal_server_api_common_v1_api_category_proto_depIdxs = nil

230 }

go.temporal.io/server/api/historyservicemock/v1/service_grpc.pb.mock.go 21 covered LOC · 5 ranges

Open complete file

33

34 // NewMockHistoryServiceClient creates a new mock instance.

35 > func NewMockHistoryServiceClient(ctrl *gomock.Controller) *MockHistoryServiceClient { service_grpc.pb.mock.go

36 > mock := &MockHistoryServiceClient{ctrl: ctrl}

37 > mock.recorder = &MockHistoryServiceClientMockRecorder{mock}

38 > return mock

39 > }

40

41 // EXPECT returns an object that allows the caller to indicate expected use.

42 > func (m *MockHistoryServiceClient) EXPECT() *MockHistoryServiceClientMockRecorder { service_grpc.pb.mock.go

43 > return m.recorder

44 > }

45

46 // AddTasks mocks base method.

125

126 // CompleteNexusOperationChasm mocks base method.

127 > func (m *MockHistoryServiceClient) CompleteNexusOperationChasm(ctx context.Context, in *historyservice.CompleteNexusOperationChasmRequest, opts ...grpc.CallOption) (*historyservice.CompleteNexusOperationChasmResponse, error) { service_grpc.pb.mock.go

128 > m.ctrl.T.Helper()

129 > varargs := []any{ctx, in}

130 > for _, a := range opts {

131 varargs = append(varargs, a)

132 }

133 > ret := m.ctrl.Call(m, "CompleteNexusOperationChasm", varargs...) service_grpc.pb.mock.go

134 > ret0, _ := ret[0].(*historyservice.CompleteNexusOperationChasmResponse)

135 > ret1, _ := ret[1].(error)

136 > return ret0, ret1

137 }

138

139 // CompleteNexusOperationChasm indicates an expected call of CompleteNexusOperationChasm.

140 > func (mr *MockHistoryServiceClientMockRecorder) CompleteNexusOperationChasm(ctx, in any, opts ...any) *gomock.Call { service_grpc.pb.mock.go

141 > mr.mock.ctrl.T.Helper()

142 > varargs := append([]any{ctx, in}, opts...)

143 > return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CompleteNexusOperationChasm", reflect.TypeOf((*MockHistoryServiceClient)(nil).CompleteNexusOperationChasm), varargs...)

144 > }

145

146 // DeepHealthCheck mocks base method.

go.temporal.io/server/api/persistence/v1/task_queues.pb.go 21 covered LOC · 2 ranges

Open complete file

899 }

900

901 > func init() { file_temporal_server_api_persistence_v1_task_queues_proto_init() } task_queues.pb.go

902 > func file_temporal_server_api_persistence_v1_task_queues_proto_init() {

903 > if File_temporal_server_api_persistence_v1_task_queues_proto != nil {

904 return

905 }

906 > type x struct{} task_queues.pb.go

907 > out := protoimpl.TypeBuilder{

908 > File: protoimpl.DescBuilder{

909 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

910 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_task_queues_proto_rawDesc), len(file_temporal_server_api_persistence_v1_task_queues_proto_rawDesc)),

911 > NumEnums: 1,

912 > NumMessages: 13,

913 > NumExtensions: 0,

914 > NumServices: 0,

915 > },

916 > GoTypes: file_temporal_server_api_persistence_v1_task_queues_proto_goTypes,

917 > DependencyIndexes: file_temporal_server_api_persistence_v1_task_queues_proto_depIdxs,

918 > EnumInfos: file_temporal_server_api_persistence_v1_task_queues_proto_enumTypes,

919 > MessageInfos: file_temporal_server_api_persistence_v1_task_queues_proto_msgTypes,

920 > }.Build()

921 > File_temporal_server_api_persistence_v1_task_queues_proto = out.File

922 > file_temporal_server_api_persistence_v1_task_queues_proto_goTypes = nil

923 > file_temporal_server_api_persistence_v1_task_queues_proto_depIdxs = nil

924 }

go.temporal.io/server/common/namespace/namespace.go 21 covered LOC · 6 ranges

Open complete file

81 resolver ReplicationResolver,

82 mutations ...Mutation,

83 > ) (*Namespace, error) { namespace.go

84 > if resolver == nil {

85 return nil, serviceerror.NewInvalidArgument("replicationResolver must be provided")

86 }

87 > ns := &Namespace{ namespace.go

88 > info: detail.Info,

89 > config: detail.Config,

90 > configVersion: detail.ConfigVersion,

91 > customSearchAttributesMapper: CustomSearchAttributesMapper{

92 > fieldToAlias: detail.Config.CustomSearchAttributeAliases,

93 > aliasToField: util.InverseMap(detail.Config.CustomSearchAttributeAliases),

94 > },

95 > replicationResolver: resolver,

96 > }

97 >

98 > for _, m := range mutations {

99 m.apply(ns)

100 }

101

102 > return ns, nil namespace.go

103 }

104

167

168 // Name observes this namespace's configured name.

169 > func (ns *Namespace) Name() Name { namespace.go

170 > if ns.info == nil {

171 return Name("")

172 }

173 > return Name(ns.info.Name) namespace.go

174 }

175

345 }

346

347 > func (n Name) String() string { namespace.go

348 > return string(n)

349 > }

350

351 func (n Name) IsEmpty() bool {

go.temporal.io/server/api/adminservice/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

273 }

274

275 > func init() { file_temporal_server_api_adminservice_v1_service_proto_init() } service.pb.go

276 > func file_temporal_server_api_adminservice_v1_service_proto_init() {

277 > if File_temporal_server_api_adminservice_v1_service_proto != nil {

278 return

279 }

280 > file_temporal_server_api_adminservice_v1_request_response_proto_init() service.pb.go

281 > type x struct{}

282 > out := protoimpl.TypeBuilder{

283 > File: protoimpl.DescBuilder{

284 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

285 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_adminservice_v1_service_proto_rawDesc), len(file_temporal_server_api_adminservice_v1_service_proto_rawDesc)),

286 > NumEnums: 0,

287 > NumMessages: 0,

288 > NumExtensions: 0,

289 > NumServices: 1,

290 > },

291 > GoTypes: file_temporal_server_api_adminservice_v1_service_proto_goTypes,

292 > DependencyIndexes: file_temporal_server_api_adminservice_v1_service_proto_depIdxs,

293 > }.Build()

294 > File_temporal_server_api_adminservice_v1_service_proto = out.File

295 > file_temporal_server_api_adminservice_v1_service_proto_goTypes = nil

296 > file_temporal_server_api_adminservice_v1_service_proto_depIdxs = nil

297 }

go.temporal.io/server/api/archiver/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

431 }

432

433 > func init() { file_temporal_server_api_archiver_v1_message_proto_init() } message.pb.go

434 > func file_temporal_server_api_archiver_v1_message_proto_init() {

435 > if File_temporal_server_api_archiver_v1_message_proto != nil {

436 return

437 }

438 > type x struct{} message.pb.go

439 > out := protoimpl.TypeBuilder{

440 > File: protoimpl.DescBuilder{

441 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

442 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_archiver_v1_message_proto_rawDesc), len(file_temporal_server_api_archiver_v1_message_proto_rawDesc)),

443 > NumEnums: 0,

444 > NumMessages: 4,

445 > NumExtensions: 0,

446 > NumServices: 0,

447 > },

448 > GoTypes: file_temporal_server_api_archiver_v1_message_proto_goTypes,

449 > DependencyIndexes: file_temporal_server_api_archiver_v1_message_proto_depIdxs,

450 > MessageInfos: file_temporal_server_api_archiver_v1_message_proto_msgTypes,

451 > }.Build()

452 > File_temporal_server_api_archiver_v1_message_proto = out.File

453 > file_temporal_server_api_archiver_v1_message_proto_goTypes = nil

454 > file_temporal_server_api_archiver_v1_message_proto_depIdxs = nil

455 }

go.temporal.io/server/api/chasm/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

206 }

207

208 > func init() { file_temporal_server_api_chasm_v1_message_proto_init() } message.pb.go

209 > func file_temporal_server_api_chasm_v1_message_proto_init() {

210 > if File_temporal_server_api_chasm_v1_message_proto != nil {

211 return

212 }

213 > type x struct{} message.pb.go

214 > out := protoimpl.TypeBuilder{

215 > File: protoimpl.DescBuilder{

216 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

217 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_chasm_v1_message_proto_rawDesc), len(file_temporal_server_api_chasm_v1_message_proto_rawDesc)),

218 > NumEnums: 0,

219 > NumMessages: 1,

220 > NumExtensions: 0,

221 > NumServices: 0,

222 > },

223 > GoTypes: file_temporal_server_api_chasm_v1_message_proto_goTypes,

224 > DependencyIndexes: file_temporal_server_api_chasm_v1_message_proto_depIdxs,

225 > MessageInfos: file_temporal_server_api_chasm_v1_message_proto_msgTypes,

226 > }.Build()

227 > File_temporal_server_api_chasm_v1_message_proto = out.File

228 > file_temporal_server_api_chasm_v1_message_proto_goTypes = nil

229 > file_temporal_server_api_chasm_v1_message_proto_depIdxs = nil

230 }

go.temporal.io/server/api/cluster/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

342 }

343

344 > func init() { file_temporal_server_api_cluster_v1_message_proto_init() } message.pb.go

345 > func file_temporal_server_api_cluster_v1_message_proto_init() {

346 > if File_temporal_server_api_cluster_v1_message_proto != nil {

347 return

348 }

349 > type x struct{} message.pb.go

350 > out := protoimpl.TypeBuilder{

351 > File: protoimpl.DescBuilder{

352 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

353 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_cluster_v1_message_proto_rawDesc), len(file_temporal_server_api_cluster_v1_message_proto_rawDesc)),

354 > NumEnums: 0,

355 > NumMessages: 4,

356 > NumExtensions: 0,

357 > NumServices: 0,

358 > },

359 > GoTypes: file_temporal_server_api_cluster_v1_message_proto_goTypes,

360 > DependencyIndexes: file_temporal_server_api_cluster_v1_message_proto_depIdxs,

361 > MessageInfos: file_temporal_server_api_cluster_v1_message_proto_msgTypes,

362 > }.Build()

363 > File_temporal_server_api_cluster_v1_message_proto = out.File

364 > file_temporal_server_api_cluster_v1_message_proto_goTypes = nil

365 > file_temporal_server_api_cluster_v1_message_proto_depIdxs = nil

366 }

go.temporal.io/server/api/common/v1/dlq.pb.go 20 covered LOC · 2 ranges

Open complete file

295 }

296

297 > func init() { file_temporal_server_api_common_v1_dlq_proto_init() } dlq.pb.go

298 > func file_temporal_server_api_common_v1_dlq_proto_init() {

299 > if File_temporal_server_api_common_v1_dlq_proto != nil {

300 return

301 }

302 > type x struct{} dlq.pb.go

303 > out := protoimpl.TypeBuilder{

304 > File: protoimpl.DescBuilder{

305 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

306 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_common_v1_dlq_proto_rawDesc), len(file_temporal_server_api_common_v1_dlq_proto_rawDesc)),

307 > NumEnums: 0,

308 > NumMessages: 4,

309 > NumExtensions: 0,

310 > NumServices: 0,

311 > },

312 > GoTypes: file_temporal_server_api_common_v1_dlq_proto_goTypes,

313 > DependencyIndexes: file_temporal_server_api_common_v1_dlq_proto_depIdxs,

314 > MessageInfos: file_temporal_server_api_common_v1_dlq_proto_msgTypes,

315 > }.Build()

316 > File_temporal_server_api_common_v1_dlq_proto = out.File

317 > file_temporal_server_api_common_v1_dlq_proto_goTypes = nil

318 > file_temporal_server_api_common_v1_dlq_proto_depIdxs = nil

319 }

go.temporal.io/server/api/contextpropagation/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

109 }

110

111 > func init() { file_temporal_server_api_contextpropagation_v1_message_proto_init() } message.pb.go

112 > func file_temporal_server_api_contextpropagation_v1_message_proto_init() {

113 > if File_temporal_server_api_contextpropagation_v1_message_proto != nil {

114 return

115 }

116 > type x struct{} message.pb.go

117 > out := protoimpl.TypeBuilder{

118 > File: protoimpl.DescBuilder{

119 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

120 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_contextpropagation_v1_message_proto_rawDesc), len(file_temporal_server_api_contextpropagation_v1_message_proto_rawDesc)),

121 > NumEnums: 0,

122 > NumMessages: 2,

123 > NumExtensions: 0,

124 > NumServices: 0,

125 > },

126 > GoTypes: file_temporal_server_api_contextpropagation_v1_message_proto_goTypes,

127 > DependencyIndexes: file_temporal_server_api_contextpropagation_v1_message_proto_depIdxs,

128 > MessageInfos: file_temporal_server_api_contextpropagation_v1_message_proto_msgTypes,

129 > }.Build()

130 > File_temporal_server_api_contextpropagation_v1_message_proto = out.File

131 > file_temporal_server_api_contextpropagation_v1_message_proto_goTypes = nil

132 > file_temporal_server_api_contextpropagation_v1_message_proto_depIdxs = nil

133 }

go.temporal.io/server/api/deployment/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

4626 }

4627

4628 > func init() { file_temporal_server_api_deployment_v1_message_proto_init() } message.pb.go

4629 > func file_temporal_server_api_deployment_v1_message_proto_init() {

4630 > if File_temporal_server_api_deployment_v1_message_proto != nil {

4631 return

4632 }

4633 > type x struct{} message.pb.go

4634 > out := protoimpl.TypeBuilder{

4635 > File: protoimpl.DescBuilder{

4636 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

4637 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_deployment_v1_message_proto_rawDesc), len(file_temporal_server_api_deployment_v1_message_proto_rawDesc)),

4638 > NumEnums: 0,

4639 > NumMessages: 75,

4640 > NumExtensions: 0,

4641 > NumServices: 0,

4642 > },

4643 > GoTypes: file_temporal_server_api_deployment_v1_message_proto_goTypes,

4644 > DependencyIndexes: file_temporal_server_api_deployment_v1_message_proto_depIdxs,

4645 > MessageInfos: file_temporal_server_api_deployment_v1_message_proto_msgTypes,

4646 > }.Build()

4647 > File_temporal_server_api_deployment_v1_message_proto = out.File

4648 > file_temporal_server_api_deployment_v1_message_proto_goTypes = nil

4649 > file_temporal_server_api_deployment_v1_message_proto_depIdxs = nil

4650 }

go.temporal.io/server/api/enums/v1/cluster.pb.go 20 covered LOC · 2 ranges

Open complete file

209 }

210

211 > func init() { file_temporal_server_api_enums_v1_cluster_proto_init() } cluster.pb.go

212 > func file_temporal_server_api_enums_v1_cluster_proto_init() {

213 > if File_temporal_server_api_enums_v1_cluster_proto != nil {

214 return

215 }

216 > type x struct{} cluster.pb.go

217 > out := protoimpl.TypeBuilder{

218 > File: protoimpl.DescBuilder{

219 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

220 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_cluster_proto_rawDesc), len(file_temporal_server_api_enums_v1_cluster_proto_rawDesc)),

221 > NumEnums: 2,

222 > NumMessages: 0,

223 > NumExtensions: 0,

224 > NumServices: 0,

225 > },

226 > GoTypes: file_temporal_server_api_enums_v1_cluster_proto_goTypes,

227 > DependencyIndexes: file_temporal_server_api_enums_v1_cluster_proto_depIdxs,

228 > EnumInfos: file_temporal_server_api_enums_v1_cluster_proto_enumTypes,

229 > }.Build()

230 > File_temporal_server_api_enums_v1_cluster_proto = out.File

231 > file_temporal_server_api_enums_v1_cluster_proto_goTypes = nil

232 > file_temporal_server_api_enums_v1_cluster_proto_depIdxs = nil

233 }

go.temporal.io/server/api/enums/v1/common.pb.go 20 covered LOC · 2 ranges

Open complete file

264 }

265

266 > func init() { file_temporal_server_api_enums_v1_common_proto_init() } common.pb.go

267 > func file_temporal_server_api_enums_v1_common_proto_init() {

268 > if File_temporal_server_api_enums_v1_common_proto != nil {

269 return

270 }

271 > type x struct{} common.pb.go

272 > out := protoimpl.TypeBuilder{

273 > File: protoimpl.DescBuilder{

274 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

275 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_common_proto_rawDesc), len(file_temporal_server_api_enums_v1_common_proto_rawDesc)),

276 > NumEnums: 3,

277 > NumMessages: 0,

278 > NumExtensions: 0,

279 > NumServices: 0,

280 > },

281 > GoTypes: file_temporal_server_api_enums_v1_common_proto_goTypes,

282 > DependencyIndexes: file_temporal_server_api_enums_v1_common_proto_depIdxs,

283 > EnumInfos: file_temporal_server_api_enums_v1_common_proto_enumTypes,

284 > }.Build()

285 > File_temporal_server_api_enums_v1_common_proto = out.File

286 > file_temporal_server_api_enums_v1_common_proto_goTypes = nil

287 > file_temporal_server_api_enums_v1_common_proto_depIdxs = nil

288 }

go.temporal.io/server/api/enums/v1/dlq.pb.go 20 covered LOC · 2 ranges

Open complete file

187 }

188

189 > func init() { file_temporal_server_api_enums_v1_dlq_proto_init() } dlq.pb.go

190 > func file_temporal_server_api_enums_v1_dlq_proto_init() {

191 > if File_temporal_server_api_enums_v1_dlq_proto != nil {

192 return

193 }

194 > type x struct{} dlq.pb.go

195 > out := protoimpl.TypeBuilder{

196 > File: protoimpl.DescBuilder{

197 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

198 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_dlq_proto_rawDesc), len(file_temporal_server_api_enums_v1_dlq_proto_rawDesc)),

199 > NumEnums: 2,

200 > NumMessages: 0,

201 > NumExtensions: 0,

202 > NumServices: 0,

203 > },

204 > GoTypes: file_temporal_server_api_enums_v1_dlq_proto_goTypes,

205 > DependencyIndexes: file_temporal_server_api_enums_v1_dlq_proto_depIdxs,

206 > EnumInfos: file_temporal_server_api_enums_v1_dlq_proto_enumTypes,

207 > }.Build()

208 > File_temporal_server_api_enums_v1_dlq_proto = out.File

209 > file_temporal_server_api_enums_v1_dlq_proto_goTypes = nil

210 > file_temporal_server_api_enums_v1_dlq_proto_depIdxs = nil

211 }

go.temporal.io/server/api/enums/v1/fairness_state.pb.go 20 covered LOC · 2 ranges

Open complete file

123 }

124

125 > func init() { file_temporal_server_api_enums_v1_fairness_state_proto_init() } fairness_state.pb.go

126 > func file_temporal_server_api_enums_v1_fairness_state_proto_init() {

127 > if File_temporal_server_api_enums_v1_fairness_state_proto != nil {

128 return

129 }

130 > type x struct{} fairness_state.pb.go

131 > out := protoimpl.TypeBuilder{

132 > File: protoimpl.DescBuilder{

133 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

134 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_fairness_state_proto_rawDesc), len(file_temporal_server_api_enums_v1_fairness_state_proto_rawDesc)),

135 > NumEnums: 1,

136 > NumMessages: 0,

137 > NumExtensions: 0,

138 > NumServices: 0,

139 > },

140 > GoTypes: file_temporal_server_api_enums_v1_fairness_state_proto_goTypes,

141 > DependencyIndexes: file_temporal_server_api_enums_v1_fairness_state_proto_depIdxs,

142 > EnumInfos: file_temporal_server_api_enums_v1_fairness_state_proto_enumTypes,

143 > }.Build()

144 > File_temporal_server_api_enums_v1_fairness_state_proto = out.File

145 > file_temporal_server_api_enums_v1_fairness_state_proto_goTypes = nil

146 > file_temporal_server_api_enums_v1_fairness_state_proto_depIdxs = nil

147 }

go.temporal.io/server/api/enums/v1/nexus.pb.go 20 covered LOC · 2 ranges

Open complete file

158 }

159

160 > func init() { file_temporal_server_api_enums_v1_nexus_proto_init() } nexus.pb.go

161 > func file_temporal_server_api_enums_v1_nexus_proto_init() {

162 > if File_temporal_server_api_enums_v1_nexus_proto != nil {

163 return

164 }

165 > type x struct{} nexus.pb.go

166 > out := protoimpl.TypeBuilder{

167 > File: protoimpl.DescBuilder{

168 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

169 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_nexus_proto_rawDesc), len(file_temporal_server_api_enums_v1_nexus_proto_rawDesc)),

170 > NumEnums: 1,

171 > NumMessages: 0,

172 > NumExtensions: 0,

173 > NumServices: 0,

174 > },

175 > GoTypes: file_temporal_server_api_enums_v1_nexus_proto_goTypes,

176 > DependencyIndexes: file_temporal_server_api_enums_v1_nexus_proto_depIdxs,

177 > EnumInfos: file_temporal_server_api_enums_v1_nexus_proto_enumTypes,

178 > }.Build()

179 > File_temporal_server_api_enums_v1_nexus_proto = out.File

180 > file_temporal_server_api_enums_v1_nexus_proto_goTypes = nil

181 > file_temporal_server_api_enums_v1_nexus_proto_depIdxs = nil

182 }

go.temporal.io/server/api/enums/v1/replication.pb.go 20 covered LOC · 2 ranges

Open complete file

314 }

315

316 > func init() { file_temporal_server_api_enums_v1_replication_proto_init() } replication.pb.go

317 > func file_temporal_server_api_enums_v1_replication_proto_init() {

318 > if File_temporal_server_api_enums_v1_replication_proto != nil {

319 return

320 }

321 > type x struct{} replication.pb.go

322 > out := protoimpl.TypeBuilder{

323 > File: protoimpl.DescBuilder{

324 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

325 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_replication_proto_rawDesc), len(file_temporal_server_api_enums_v1_replication_proto_rawDesc)),

326 > NumEnums: 3,

327 > NumMessages: 0,

328 > NumExtensions: 0,

329 > NumServices: 0,

330 > },

331 > GoTypes: file_temporal_server_api_enums_v1_replication_proto_goTypes,

332 > DependencyIndexes: file_temporal_server_api_enums_v1_replication_proto_depIdxs,

333 > EnumInfos: file_temporal_server_api_enums_v1_replication_proto_enumTypes,

334 > }.Build()

335 > File_temporal_server_api_enums_v1_replication_proto = out.File

336 > file_temporal_server_api_enums_v1_replication_proto_goTypes = nil

337 > file_temporal_server_api_enums_v1_replication_proto_depIdxs = nil

338 }

go.temporal.io/server/api/enums/v1/workflow.pb.go 20 covered LOC · 2 ranges

Open complete file

275 }

276

277 > func init() { file_temporal_server_api_enums_v1_workflow_proto_init() } workflow.pb.go

278 > func file_temporal_server_api_enums_v1_workflow_proto_init() {

279 > if File_temporal_server_api_enums_v1_workflow_proto != nil {

280 return

281 }

282 > type x struct{} workflow.pb.go

283 > out := protoimpl.TypeBuilder{

284 > File: protoimpl.DescBuilder{

285 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

286 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_workflow_proto_rawDesc), len(file_temporal_server_api_enums_v1_workflow_proto_rawDesc)),

287 > NumEnums: 3,

288 > NumMessages: 0,

289 > NumExtensions: 0,

290 > NumServices: 0,

291 > },

292 > GoTypes: file_temporal_server_api_enums_v1_workflow_proto_goTypes,

293 > DependencyIndexes: file_temporal_server_api_enums_v1_workflow_proto_depIdxs,

294 > EnumInfos: file_temporal_server_api_enums_v1_workflow_proto_enumTypes,

295 > }.Build()

296 > File_temporal_server_api_enums_v1_workflow_proto = out.File

297 > file_temporal_server_api_enums_v1_workflow_proto_goTypes = nil

298 > file_temporal_server_api_enums_v1_workflow_proto_depIdxs = nil

299 }

go.temporal.io/server/api/enums/v1/workflow_task_type.pb.go 20 covered LOC · 2 ranges

Open complete file

124 }

125

126 > func init() { file_temporal_server_api_enums_v1_workflow_task_type_proto_init() } workflow_task_type.pb.go

127 > func file_temporal_server_api_enums_v1_workflow_task_type_proto_init() {

128 > if File_temporal_server_api_enums_v1_workflow_task_type_proto != nil {

129 return

130 }

131 > type x struct{} workflow_task_type.pb.go

132 > out := protoimpl.TypeBuilder{

133 > File: protoimpl.DescBuilder{

134 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

135 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_workflow_task_type_proto_rawDesc), len(file_temporal_server_api_enums_v1_workflow_task_type_proto_rawDesc)),

136 > NumEnums: 1,

137 > NumMessages: 0,

138 > NumExtensions: 0,

139 > NumServices: 0,

140 > },

141 > GoTypes: file_temporal_server_api_enums_v1_workflow_task_type_proto_goTypes,

142 > DependencyIndexes: file_temporal_server_api_enums_v1_workflow_task_type_proto_depIdxs,

143 > EnumInfos: file_temporal_server_api_enums_v1_workflow_task_type_proto_enumTypes,

144 > }.Build()

145 > File_temporal_server_api_enums_v1_workflow_task_type_proto = out.File

146 > file_temporal_server_api_enums_v1_workflow_task_type_proto_goTypes = nil

147 > file_temporal_server_api_enums_v1_workflow_task_type_proto_depIdxs = nil

148 }

go.temporal.io/server/api/errordetails/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

625 }

626

627 > func init() { file_temporal_server_api_errordetails_v1_message_proto_init() } message.pb.go

628 > func file_temporal_server_api_errordetails_v1_message_proto_init() {

629 > if File_temporal_server_api_errordetails_v1_message_proto != nil {

630 return

631 }

632 > type x struct{} message.pb.go

633 > out := protoimpl.TypeBuilder{

634 > File: protoimpl.DescBuilder{

635 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

636 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_errordetails_v1_message_proto_rawDesc), len(file_temporal_server_api_errordetails_v1_message_proto_rawDesc)),

637 > NumEnums: 0,

638 > NumMessages: 10,

639 > NumExtensions: 0,

640 > NumServices: 0,

641 > },

642 > GoTypes: file_temporal_server_api_errordetails_v1_message_proto_goTypes,

643 > DependencyIndexes: file_temporal_server_api_errordetails_v1_message_proto_depIdxs,

644 > MessageInfos: file_temporal_server_api_errordetails_v1_message_proto_msgTypes,

645 > }.Build()

646 > File_temporal_server_api_errordetails_v1_message_proto = out.File

647 > file_temporal_server_api_errordetails_v1_message_proto_goTypes = nil

648 > file_temporal_server_api_errordetails_v1_message_proto_depIdxs = nil

649 }

go.temporal.io/server/api/health/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

300 }

301

302 > func init() { file_temporal_server_api_health_v1_message_proto_init() } message.pb.go

303 > func file_temporal_server_api_health_v1_message_proto_init() {

304 > if File_temporal_server_api_health_v1_message_proto != nil {

305 return

306 }

307 > type x struct{} message.pb.go

308 > out := protoimpl.TypeBuilder{

309 > File: protoimpl.DescBuilder{

310 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

311 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_health_v1_message_proto_rawDesc), len(file_temporal_server_api_health_v1_message_proto_rawDesc)),

312 > NumEnums: 0,

313 > NumMessages: 3,

314 > NumExtensions: 0,

315 > NumServices: 0,

316 > },

317 > GoTypes: file_temporal_server_api_health_v1_message_proto_goTypes,

318 > DependencyIndexes: file_temporal_server_api_health_v1_message_proto_depIdxs,

319 > MessageInfos: file_temporal_server_api_health_v1_message_proto_msgTypes,

320 > }.Build()

321 > File_temporal_server_api_health_v1_message_proto = out.File

322 > file_temporal_server_api_health_v1_message_proto_goTypes = nil

323 > file_temporal_server_api_health_v1_message_proto_depIdxs = nil

324 }

go.temporal.io/server/api/historyservice/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

428 }

429

430 > func init() { file_temporal_server_api_historyservice_v1_service_proto_init() } service.pb.go

431 > func file_temporal_server_api_historyservice_v1_service_proto_init() {

432 > if File_temporal_server_api_historyservice_v1_service_proto != nil {

433 return

434 }

435 > file_temporal_server_api_historyservice_v1_request_response_proto_init() service.pb.go

436 > type x struct{}

437 > out := protoimpl.TypeBuilder{

438 > File: protoimpl.DescBuilder{

439 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

440 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_historyservice_v1_service_proto_rawDesc), len(file_temporal_server_api_historyservice_v1_service_proto_rawDesc)),

441 > NumEnums: 0,

442 > NumMessages: 0,

443 > NumExtensions: 0,

444 > NumServices: 1,

445 > },

446 > GoTypes: file_temporal_server_api_historyservice_v1_service_proto_goTypes,

447 > DependencyIndexes: file_temporal_server_api_historyservice_v1_service_proto_depIdxs,

448 > }.Build()

449 > File_temporal_server_api_historyservice_v1_service_proto = out.File

450 > file_temporal_server_api_historyservice_v1_service_proto_goTypes = nil

451 > file_temporal_server_api_historyservice_v1_service_proto_depIdxs = nil

452 }

go.temporal.io/server/api/matchingservice/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

250 }

251

252 > func init() { file_temporal_server_api_matchingservice_v1_service_proto_init() } service.pb.go

253 > func file_temporal_server_api_matchingservice_v1_service_proto_init() {

254 > if File_temporal_server_api_matchingservice_v1_service_proto != nil {

255 return

256 }

257 > file_temporal_server_api_matchingservice_v1_request_response_proto_init() service.pb.go

258 > type x struct{}

259 > out := protoimpl.TypeBuilder{

260 > File: protoimpl.DescBuilder{

261 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

262 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_matchingservice_v1_service_proto_rawDesc), len(file_temporal_server_api_matchingservice_v1_service_proto_rawDesc)),

263 > NumEnums: 0,

264 > NumMessages: 0,

265 > NumExtensions: 0,

266 > NumServices: 1,

267 > },

268 > GoTypes: file_temporal_server_api_matchingservice_v1_service_proto_goTypes,

269 > DependencyIndexes: file_temporal_server_api_matchingservice_v1_service_proto_depIdxs,

270 > }.Build()

271 > File_temporal_server_api_matchingservice_v1_service_proto = out.File

272 > file_temporal_server_api_matchingservice_v1_service_proto_goTypes = nil

273 > file_temporal_server_api_matchingservice_v1_service_proto_depIdxs = nil

274 }

go.temporal.io/server/api/metrics/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

104 }

105

106 > func init() { file_temporal_server_api_metrics_v1_message_proto_init() } message.pb.go

107 > func file_temporal_server_api_metrics_v1_message_proto_init() {

108 > if File_temporal_server_api_metrics_v1_message_proto != nil {

109 return

110 }

111 > type x struct{} message.pb.go

112 > out := protoimpl.TypeBuilder{

113 > File: protoimpl.DescBuilder{

114 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

115 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_metrics_v1_message_proto_rawDesc), len(file_temporal_server_api_metrics_v1_message_proto_rawDesc)),

116 > NumEnums: 0,

117 > NumMessages: 2,

118 > NumExtensions: 0,

119 > NumServices: 0,

120 > },

121 > GoTypes: file_temporal_server_api_metrics_v1_message_proto_goTypes,

122 > DependencyIndexes: file_temporal_server_api_metrics_v1_message_proto_depIdxs,

123 > MessageInfos: file_temporal_server_api_metrics_v1_message_proto_msgTypes,

124 > }.Build()

125 > File_temporal_server_api_metrics_v1_message_proto = out.File

126 > file_temporal_server_api_metrics_v1_message_proto_goTypes = nil

127 > file_temporal_server_api_metrics_v1_message_proto_depIdxs = nil

128 }

go.temporal.io/server/api/namespace/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

114 }

115

116 > func init() { file_temporal_server_api_namespace_v1_message_proto_init() } message.pb.go

117 > func file_temporal_server_api_namespace_v1_message_proto_init() {

118 > if File_temporal_server_api_namespace_v1_message_proto != nil {

119 return

120 }

121 > type x struct{} message.pb.go

122 > out := protoimpl.TypeBuilder{

123 > File: protoimpl.DescBuilder{

124 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

125 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_namespace_v1_message_proto_rawDesc), len(file_temporal_server_api_namespace_v1_message_proto_rawDesc)),

126 > NumEnums: 0,

127 > NumMessages: 1,

128 > NumExtensions: 0,

129 > NumServices: 0,

130 > },

131 > GoTypes: file_temporal_server_api_namespace_v1_message_proto_goTypes,

132 > DependencyIndexes: file_temporal_server_api_namespace_v1_message_proto_depIdxs,

133 > MessageInfos: file_temporal_server_api_namespace_v1_message_proto_msgTypes,

134 > }.Build()

135 > File_temporal_server_api_namespace_v1_message_proto = out.File

136 > file_temporal_server_api_namespace_v1_message_proto_goTypes = nil

137 > file_temporal_server_api_namespace_v1_message_proto_depIdxs = nil

138 }

go.temporal.io/server/api/persistence/v1/chasm_visibility.pb.go 20 covered LOC · 2 ranges

Open complete file

146 }

147

148 > func init() { file_temporal_server_api_persistence_v1_chasm_visibility_proto_init() } chasm_visibility.pb.go

149 > func file_temporal_server_api_persistence_v1_chasm_visibility_proto_init() {

150 > if File_temporal_server_api_persistence_v1_chasm_visibility_proto != nil {

151 return

152 }

153 > type x struct{} chasm_visibility.pb.go

154 > out := protoimpl.TypeBuilder{

155 > File: protoimpl.DescBuilder{

156 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

157 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_chasm_visibility_proto_rawDesc), len(file_temporal_server_api_persistence_v1_chasm_visibility_proto_rawDesc)),

158 > NumEnums: 0,

159 > NumMessages: 2,

160 > NumExtensions: 0,

161 > NumServices: 0,

162 > },

163 > GoTypes: file_temporal_server_api_persistence_v1_chasm_visibility_proto_goTypes,

164 > DependencyIndexes: file_temporal_server_api_persistence_v1_chasm_visibility_proto_depIdxs,

165 > MessageInfos: file_temporal_server_api_persistence_v1_chasm_visibility_proto_msgTypes,

166 > }.Build()

167 > File_temporal_server_api_persistence_v1_chasm_visibility_proto = out.File

168 > file_temporal_server_api_persistence_v1_chasm_visibility_proto_goTypes = nil

169 > file_temporal_server_api_persistence_v1_chasm_visibility_proto_depIdxs = nil

170 }

go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go 20 covered LOC · 2 ranges

Open complete file

289 }

290

291 > func init() { file_temporal_server_api_persistence_v1_cluster_metadata_proto_init() } cluster_metadata.pb.go

292 > func file_temporal_server_api_persistence_v1_cluster_metadata_proto_init() {

293 > if File_temporal_server_api_persistence_v1_cluster_metadata_proto != nil {

294 return

295 }

296 > type x struct{} cluster_metadata.pb.go

297 > out := protoimpl.TypeBuilder{

298 > File: protoimpl.DescBuilder{

299 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

300 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_cluster_metadata_proto_rawDesc), len(file_temporal_server_api_persistence_v1_cluster_metadata_proto_rawDesc)),

301 > NumEnums: 0,

302 > NumMessages: 5,

303 > NumExtensions: 0,

304 > NumServices: 0,

305 > },

306 > GoTypes: file_temporal_server_api_persistence_v1_cluster_metadata_proto_goTypes,

307 > DependencyIndexes: file_temporal_server_api_persistence_v1_cluster_metadata_proto_depIdxs,

308 > MessageInfos: file_temporal_server_api_persistence_v1_cluster_metadata_proto_msgTypes,

309 > }.Build()

310 > File_temporal_server_api_persistence_v1_cluster_metadata_proto = out.File

311 > file_temporal_server_api_persistence_v1_cluster_metadata_proto_goTypes = nil

312 > file_temporal_server_api_persistence_v1_cluster_metadata_proto_depIdxs = nil

313 }

go.temporal.io/server/api/persistence/v1/history_tree.pb.go 20 covered LOC · 2 ranges

Open complete file

274 }

275

276 > func init() { file_temporal_server_api_persistence_v1_history_tree_proto_init() } history_tree.pb.go

277 > func file_temporal_server_api_persistence_v1_history_tree_proto_init() {

278 > if File_temporal_server_api_persistence_v1_history_tree_proto != nil {

279 return

280 }

281 > type x struct{} history_tree.pb.go

282 > out := protoimpl.TypeBuilder{

283 > File: protoimpl.DescBuilder{

284 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

285 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_history_tree_proto_rawDesc), len(file_temporal_server_api_persistence_v1_history_tree_proto_rawDesc)),

286 > NumEnums: 0,

287 > NumMessages: 3,

288 > NumExtensions: 0,

289 > NumServices: 0,

290 > },

291 > GoTypes: file_temporal_server_api_persistence_v1_history_tree_proto_goTypes,

292 > DependencyIndexes: file_temporal_server_api_persistence_v1_history_tree_proto_depIdxs,

293 > MessageInfos: file_temporal_server_api_persistence_v1_history_tree_proto_msgTypes,

294 > }.Build()

295 > File_temporal_server_api_persistence_v1_history_tree_proto = out.File

296 > file_temporal_server_api_persistence_v1_history_tree_proto_goTypes = nil

297 > file_temporal_server_api_persistence_v1_history_tree_proto_depIdxs = nil

298 }

go.temporal.io/server/api/persistence/v1/namespaces.pb.go 20 covered LOC · 2 ranges

Open complete file

536 }

537

538 > func init() { file_temporal_server_api_persistence_v1_namespaces_proto_init() } namespaces.pb.go

539 > func file_temporal_server_api_persistence_v1_namespaces_proto_init() {

540 > if File_temporal_server_api_persistence_v1_namespaces_proto != nil {

541 return

542 }

543 > type x struct{} namespaces.pb.go

544 > out := protoimpl.TypeBuilder{

545 > File: protoimpl.DescBuilder{

546 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

547 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_namespaces_proto_rawDesc), len(file_temporal_server_api_persistence_v1_namespaces_proto_rawDesc)),

548 > NumEnums: 0,

549 > NumMessages: 8,

550 > NumExtensions: 0,

551 > NumServices: 0,

552 > },

553 > GoTypes: file_temporal_server_api_persistence_v1_namespaces_proto_goTypes,

554 > DependencyIndexes: file_temporal_server_api_persistence_v1_namespaces_proto_depIdxs,

555 > MessageInfos: file_temporal_server_api_persistence_v1_namespaces_proto_msgTypes,

556 > }.Build()

557 > File_temporal_server_api_persistence_v1_namespaces_proto = out.File

558 > file_temporal_server_api_persistence_v1_namespaces_proto_goTypes = nil

559 > file_temporal_server_api_persistence_v1_namespaces_proto_depIdxs = nil

560 }

go.temporal.io/server/api/persistence/v1/queue_metadata.pb.go 20 covered LOC · 2 ranges

Open complete file

105 }

106

107 > func init() { file_temporal_server_api_persistence_v1_queue_metadata_proto_init() } queue_metadata.pb.go

108 > func file_temporal_server_api_persistence_v1_queue_metadata_proto_init() {

109 > if File_temporal_server_api_persistence_v1_queue_metadata_proto != nil {

110 return

111 }

112 > type x struct{} queue_metadata.pb.go

113 > out := protoimpl.TypeBuilder{

114 > File: protoimpl.DescBuilder{

115 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

116 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_queue_metadata_proto_rawDesc), len(file_temporal_server_api_persistence_v1_queue_metadata_proto_rawDesc)),

117 > NumEnums: 0,

118 > NumMessages: 2,

119 > NumExtensions: 0,

120 > NumServices: 0,

121 > },

122 > GoTypes: file_temporal_server_api_persistence_v1_queue_metadata_proto_goTypes,

123 > DependencyIndexes: file_temporal_server_api_persistence_v1_queue_metadata_proto_depIdxs,

124 > MessageInfos: file_temporal_server_api_persistence_v1_queue_metadata_proto_msgTypes,

125 > }.Build()

126 > File_temporal_server_api_persistence_v1_queue_metadata_proto = out.File

127 > file_temporal_server_api_persistence_v1_queue_metadata_proto_goTypes = nil

128 > file_temporal_server_api_persistence_v1_queue_metadata_proto_depIdxs = nil

129 }

go.temporal.io/server/api/persistence/v1/tasks.pb.go 20 covered LOC · 2 ranges

Open complete file

846 }

847

848 > func init() { file_temporal_server_api_persistence_v1_tasks_proto_init() } tasks.pb.go

849 > func file_temporal_server_api_persistence_v1_tasks_proto_init() {

850 > if File_temporal_server_api_persistence_v1_tasks_proto != nil {

851 return

852 }

853 > type x struct{} tasks.pb.go

854 > out := protoimpl.TypeBuilder{

855 > File: protoimpl.DescBuilder{

856 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

857 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc), len(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc)),

858 > NumEnums: 0,

859 > NumMessages: 8,

860 > NumExtensions: 0,

861 > NumServices: 0,

862 > },

863 > GoTypes: file_temporal_server_api_persistence_v1_tasks_proto_goTypes,

864 > DependencyIndexes: file_temporal_server_api_persistence_v1_tasks_proto_depIdxs,

865 > MessageInfos: file_temporal_server_api_persistence_v1_tasks_proto_msgTypes,

866 > }.Build()

867 > File_temporal_server_api_persistence_v1_tasks_proto = out.File

868 > file_temporal_server_api_persistence_v1_tasks_proto_goTypes = nil

869 > file_temporal_server_api_persistence_v1_tasks_proto_depIdxs = nil

870 }

go.temporal.io/server/api/visibilityservice/v1/request_response.pb.go 20 covered LOC · 2 ranges

Open complete file

402 }

403

404 > func init() { file_temporal_server_api_visibilityservice_v1_request_response_proto_init() } request_response.pb.go

405 > func file_temporal_server_api_visibilityservice_v1_request_response_proto_init() {

406 > if File_temporal_server_api_visibilityservice_v1_request_response_proto != nil {

407 return

408 }

409 > type x struct{} request_response.pb.go

410 > out := protoimpl.TypeBuilder{

411 > File: protoimpl.DescBuilder{

412 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

413 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_visibilityservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_visibilityservice_v1_request_response_proto_rawDesc)),

414 > NumEnums: 0,

415 > NumMessages: 5,

416 > NumExtensions: 0,

417 > NumServices: 0,

418 > },

419 > GoTypes: file_temporal_server_api_visibilityservice_v1_request_response_proto_goTypes,

420 > DependencyIndexes: file_temporal_server_api_visibilityservice_v1_request_response_proto_depIdxs,

421 > MessageInfos: file_temporal_server_api_visibilityservice_v1_request_response_proto_msgTypes,

422 > }.Build()

423 > File_temporal_server_api_visibilityservice_v1_request_response_proto = out.File

424 > file_temporal_server_api_visibilityservice_v1_request_response_proto_goTypes = nil

425 > file_temporal_server_api_visibilityservice_v1_request_response_proto_depIdxs = nil

426 }

go.temporal.io/server/api/workflow/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

278 }

279

280 > func init() { file_temporal_server_api_workflow_v1_message_proto_init() } message.pb.go

281 > func file_temporal_server_api_workflow_v1_message_proto_init() {

282 > if File_temporal_server_api_workflow_v1_message_proto != nil {

283 return

284 }

285 > type x struct{} message.pb.go

286 > out := protoimpl.TypeBuilder{

287 > File: protoimpl.DescBuilder{

288 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

289 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_workflow_v1_message_proto_rawDesc), len(file_temporal_server_api_workflow_v1_message_proto_rawDesc)),

290 > NumEnums: 0,

291 > NumMessages: 3,

292 > NumExtensions: 0,

293 > NumServices: 0,

294 > },

295 > GoTypes: file_temporal_server_api_workflow_v1_message_proto_goTypes,

296 > DependencyIndexes: file_temporal_server_api_workflow_v1_message_proto_depIdxs,

297 > MessageInfos: file_temporal_server_api_workflow_v1_message_proto_msgTypes,

298 > }.Build()

299 > File_temporal_server_api_workflow_v1_message_proto = out.File

300 > file_temporal_server_api_workflow_v1_message_proto_goTypes = nil

301 > file_temporal_server_api_workflow_v1_message_proto_depIdxs = nil

302 }

go.temporal.io/server/chasm/lib/callback/gen/callbackpb/v1/tasks.pb.go 20 covered LOC · 2 ranges

Open complete file

148 }

149

150 > func init() { file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_init() } tasks.pb.go

151 > func file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_init() {

152 > if File_temporal_server_chasm_lib_callback_proto_v1_tasks_proto != nil {

153 return

154 }

155 > type x struct{} tasks.pb.go

156 > out := protoimpl.TypeBuilder{

157 > File: protoimpl.DescBuilder{

158 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),

159 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_rawDesc), len(file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_rawDesc)),

160 > NumEnums: 0,

161 > NumMessages: 2,

162 > NumExtensions: 0,

163 > NumServices: 0,

164 > },

165 > GoTypes: file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_goTypes,

166 > DependencyIndexes: file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_depIdxs,

167 > MessageInfos: file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_msgTypes,

168 > }.Build()

169 > File_temporal_server_chasm_lib_callback_proto_v1_tasks_proto = out.File

170 > file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_goTypes = nil

171 > file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_depIdxs = nil

172 }

go.temporal.io/server/common/util/wildcard.go 20 covered LOC · 7 ranges

Open complete file

18 // WildCardStringToRegexps converts a given slices of string patterns to a slice of regular expressions matching

19 // wildcards (*) with any substring.

20 > func WildCardStringsToRegexp(patterns []string) (*regexp.Regexp, error) { wildcard.go

21 > var result strings.Builder

22 > result.WriteRune('^')

23 > for i, pattern := range patterns {

24 > result.WriteRune('(')

25 > first := true

26 > for literal := range strings.SplitSeq(pattern, "*") {

27 > if !first {

28 // Replace * with .*

29 result.WriteString(".*")

30 }

31 > result.WriteString(regexp.QuoteMeta(literal)) wildcard.go

32 > first = false

33 }

34 > result.WriteRune(')') wildcard.go

35 > if i < len(patterns)-1 {

36 > result.WriteRune('|') wildcard.go

37 > }

38 }

39 > result.WriteRune('$') wildcard.go

40 > return regexp.Compile(result.String())

41 }

42

43 // MustWildCardStringsToRegexp is like WildCardStringsToRegexp but panics on error.

44 > func MustWildCardStringsToRegexp(patterns []string) *regexp.Regexp { wildcard.go

45 > re, err := WildCardStringsToRegexp(patterns)

46 > if err != nil {

47 panic(err) //nolint:forbidigo // Must* functions conventionally panic on error.

48 }

49 > return re wildcard.go

50 }

go.temporal.io/server/chasm/statemachine.go 19 covered LOC · 6 ranges

Open complete file

34 // The apply function is called after verifying the transition is possible but before setting the destination state,

35 // so it can inspect the current (source) state.

36 > func NewTransition[S comparable, SM StateMachine[S], E any](src []S, dst S, apply func(SM, MutableContext, E) error) Transition[S, SM, E] { statemachine.go

37 > return Transition[S, SM, E]{

38 > Sources: src,

39 > Destination: dst,

40 > apply: apply,

41 > }

42 > }

43

44 // Possible returns a boolean indicating whether the transition is possible for the current state.

45 > func (t Transition[S, SM, E]) Possible(sm SM) bool { statemachine.go

46 > return slices.Contains(t.Sources, sm.StateMachineState())

47 > }

48

49 // Apply applies a transition event to the given state machine changing the state machine's state to the transition's

50 // Destination on success. The apply function is called before the state is changed, so it can inspect the current

51 // (source) state.

52 > func (t Transition[S, SM, E]) Apply(sm SM, ctx MutableContext, event E) (retErr error) { statemachine.go

53 > prevState := sm.StateMachineState()

54 >

55 > // Defer to always emit the transition telemetry event.

56 > if telemetry.DebugMode() {

57 defer func() {

58 attrs := []attribute.KeyValue{

68 }

69

70 > if !t.Possible(sm) { statemachine.go

71 return fmt.Errorf("%w from %v", ErrInvalidTransition, prevState)

72 }

73

74 > if err := t.apply(sm, ctx, event); err != nil { statemachine.go

75 return err

76 }

77 > sm.SetStateMachineState(t.Destination) statemachine.go

78 > return nil

79 }

go.temporal.io/server/common/log/tag/zap_tag.go 19 covered LOC · 5 ranges

Open complete file

26 }

27

28 > func (t ZapTag) Field() zap.Field { zap_tag.go

29 > return t.field

30 > }

31

32 > func (t ZapTag) Key() string { zap_tag.go

33 > return t.field.Key

34 > }

35

36 func (t ZapTag) Value() any {

44 }

45

46 > func NewStringTag(key string, value string) ZapTag { zap_tag.go

47 > return ZapTag{

48 > field: zap.String(key, value),

49 > }

50 > }

51

52 func NewStringsTag(key string, value []string) ZapTag {

118 }

119

120 > func NewBoolTag(key string, value bool) ZapTag { zap_tag.go

121 > return ZapTag{

122 > field: zap.Bool(key, value),

123 > }

124 > }

125

126 func NewErrorTag(key string, value error) ZapTag {

168 // Shorter helpers (aliases for the New* functions above)

169

170 > func String(key string, value string) ZapTag { zap_tag.go

171 > return NewStringTag(key, value)

172 > }

173

174 func Strings(key string, value []string) ZapTag {

go.temporal.io/server/common/namespace/registry_mock.go 19 covered LOC · 4 ranges

Open complete file

30

31 // NewMockRegistry creates a new mock instance.

32 > func NewMockRegistry(ctrl *gomock.Controller) *MockRegistry { registry_mock.go

33 > mock := &MockRegistry{ctrl: ctrl}

34 > mock.recorder = &MockRegistryMockRecorder{mock}

35 > return mock

36 > }

37

38 // EXPECT returns an object that allows the caller to indicate expected use.

39 > func (m *MockRegistry) EXPECT() *MockRegistryMockRecorder { registry_mock.go

40 > return m.recorder

41 > }

42

43 // GetAllNamespaces mocks base method.

86

87 // GetNamespaceByID mocks base method.

88 > func (m *MockRegistry) GetNamespaceByID(id ID) (*Namespace, error) { registry_mock.go

89 > m.ctrl.T.Helper()

90 > ret := m.ctrl.Call(m, "GetNamespaceByID", id)

91 > ret0, _ := ret[0].(*Namespace)

92 > ret1, _ := ret[1].(error)

93 > return ret0, ret1

94 > }

95

96 // GetNamespaceByID indicates an expected call of GetNamespaceByID.

97 > func (mr *MockRegistryMockRecorder) GetNamespaceByID(id any) *gomock.Call { registry_mock.go

98 > mr.mock.ctrl.T.Helper()

99 > return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetNamespaceByID", reflect.TypeOf((*MockRegistry)(nil).GetNamespaceByID), id)

100 > }

101

102 // GetNamespaceByIDWithOptions mocks base method.

go.temporal.io/server/common/dynamicconfig/collection.go 18 covered LOC · 3 ranges

Open complete file

676 // treat the fields independently), or the zero value of its type (if you want to treat the fields

677 // as a group and default unset fields to zero).

678 > func ConvertStructure[T any](def T) func(v any) (T, error) { collection.go

679 > return func(v any) (T, error) {

680 > // if we already have the right type, no conversion is necessary

681 > if typedV, ok := v.(T); ok {

682 return typedV, nil

683 }

685 // Deep-copy the default and decode over it. This allows using e.g. a struct with some

686 // default fields filled in and a config that only set some fields.

687 > out := deepCopyForMapstructure(def) collection.go

688 >

689 > dec, err := mapstructure.NewDecoder(&mapstructure.DecoderConfig{

690 > Result: &out,

691 > DecodeHook: mapstructure.ComposeDecodeHookFunc(

692 > mapstructureHookDuration,

693 > mapstructureHookTimestamp,

694 > mapstructureHookProtoEnum,

695 > mapstructureHookGeneric,

696 > ),

697 > })

698 > if err != nil {

699 return out, err

700 }

701 > err = dec.Decode(v) collection.go

702 > return out, err

703 }

704 }

go.temporal.io/server/chasm/context_mock.go 17 covered LOC · 6 ranges

Open complete file

83 }

84

85 > func (c *MockContext) Now(cmp Component) time.Time { context_mock.go

86 > if c.HandleNow != nil {

87 > return c.HandleNow(cmp) context_mock.go

88 > }

89 return time.Now()

90 }

101 }

102

103 > func (c *MockContext) ExecutionKey() ExecutionKey { context_mock.go

104 > if c.HandleExecutionKey != nil {

105 > return c.HandleExecutionKey() context_mock.go

106 > }

107 > return ExecutionKey{} context_mock.go

108 }

109

122 }

123

124 > func (c *MockContext) Logger() log.Logger { context_mock.go

125 > executionKey := c.ExecutionKey()

126 > return log.NewTestLogger().With(

127 > tag.WorkflowNamespaceID(executionKey.NamespaceID),

128 > tag.WorkflowID(executionKey.BusinessID),

129 > tag.WorkflowRunID(executionKey.RunID),

130 > )

131 > }

132

133 func (c *MockContext) MetricsHandler() metrics.Handler {

go.temporal.io/server/chasm/path_encoder.go 17 covered LOC · 8 ranges

Open complete file

48 node *Node,

49 path []string,

50 > ) (string, error) { path_encoder.go

51 > if path == nil {

52 path = node.path()

53 }

54

55 > if len(path) == 0 { path_encoder.go

56 > return "", nil

57 > }

58

59 > var b strings.Builder path_encoder.go

60 > lastIdx := len(path) - 1

61 > for i, nodeName := range path {

62 > if i > 0 {

63 if i == lastIdx &&

64 node.parent != nil &&

70 }

71

72 > if nodeName == "" { path_encoder.go

73 return "", serviceerror.NewInternalf("path contains empty node name: %v", path)

74 }

75

76 > for _, r := range nodeName { path_encoder.go

77 > if r == utf8.RuneError {

78 return "", serviceerror.NewInvalidArgumentf("node name contains invalid UTF-8 code point: %v", nodeName)

79 }

80

81 > if r == escapeChar || path_encoder.go

82 > r == nameSeparator ||

83 > r <= collectionSeparator {

84 _, _ = b.WriteRune(escapeChar)

85 }

86 > _, _ = b.WriteRune(r) path_encoder.go

87 }

88 }

89 > return b.String(), nil path_encoder.go

90 }

91

go.temporal.io/server/chasm/parent_pointer.go 16 covered LOC · 10 ranges

Open complete file

35 // Panics rather than returning an error, as errors are supposed to be handled by the framework as opposed to the

36 // application.

37 > func (p ParentPtr[T]) Get(chasmContext Context) T { parent_pointer.go

38 > vT, ok := p.TryGet(chasmContext)

39 > if !ok {

40 // nolint:forbidigo // Panic is intended here for framework error handling.

41 panic(serviceerror.NewInternal("expect parent component value but got nil"))

42 }

43 > return vT parent_pointer.go

44 }

45

48 // Panics rather than returning an error, as errors are supposed to be handled by the framework as opposed to the

49 // application.

50 > func (p ParentPtr[T]) TryGet(chasmContext Context) (T, bool) { parent_pointer.go

51 > var nilT T

52 > if p.Internal.currentNode == nil {

53 // ParentPtr not initialized

54 return nilT, false

55 }

56

57 > parent := p.Internal.currentNode.parent parent_pointer.go

58 > if parent == nil {

59 return nilT, false

60 }

61

62 > for parent.isMap() { parent_pointer.go

63 parent = parent.parent

64 if parent == nil {

73 }

74

75 > if !parent.isComponent() { parent_pointer.go

76 // nolint:forbidigo // Panic is intended here for framework error handling.

77 panic(softassert.UnexpectedInternalErr(

85 }

86

87 > if err := parent.prepareComponentValue(chasmContext); err != nil { parent_pointer.go

88 // nolint:forbidigo // Panic is intended here for framework error handling.

89 panic(err)

90 }

91

92 > if parent.value == nil { parent_pointer.go

93 return nilT, false

94 }

95

96 > vT, isT := parent.value.(T) parent_pointer.go

97 > if !isT {

98 // nolint:forbidigo // Panic is intended here for framework error handling.

99 panic(serviceerror.NewInternalf("parent component value doesn't implement %s", reflect.TypeFor[T]().Name()))

100 }

101 > return vT, true parent_pointer.go

102 }

go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_util_legacy.go 15 covered LOC · 3 ranges

Open complete file

68 }

69

70 > func newColName(name string) *colName { query_converter_util_legacy.go

71 > return &colName{Name: name}

72 > }

73

74 func newSAColName(

77 fieldName string,

78 valueType enumspb.IndexedValueType,

79 > ) *saColName { query_converter_util_legacy.go

80 > return &saColName{

81 > dbColName: newColName(dbColName),

82 > alias: alias,

83 > fieldName: fieldName,

84 > valueType: valueType,

85 > }

86 > }

87

88 func newFuncExpr(name string, exprs ...sqlparser.Expr) *sqlparser.FuncExpr {

105 }

106

107 > func getMaxDatetimeValue() time.Time { query_converter_util_legacy.go

108 > t, _ := time.Parse(time.RFC3339, "9999-12-31T23:59:59Z")

109 > return t

110 > }

111

112 // formatComparisonExprStringForError formats comparison expression after

go.temporal.io/server/common/build/build.go 14 covered LOC · 2 ranges

Open complete file

27 )

28

29 > func init() { build.go

30 > buildInfo, ok := debug.ReadBuildInfo()

31 > if !ok {

32 return

33 }

34

35 > InfoData.Available = true build.go

36 > InfoData.GoVersion = buildInfo.GoVersion

37 >

38 > for _, setting := range buildInfo.Settings {

39 > switch setting.Key {

40 > case "GOARCH":

41 > InfoData.GoArch = setting.Value

42 > case "GOOS":

43 > InfoData.GoOs = setting.Value

44 > case "CGO_ENABLED":

45 > InfoData.CgoEnabled = setting.Value == "1"

46 case "vcs.revision":

47 InfoData.GitRevision = setting.Value

go.temporal.io/server/common/dynamicconfig/gradual_change.go 14 covered LOC · 3 ranges

Open complete file

25 // StaticGradualChange returns a GradualChange whose Value always returns def and whose When

26 // always returns a time in the past.

27 > func StaticGradualChange[T any](def T) GradualChange[T] { gradual_change.go

28 > return GradualChange[T]{New: def}

29 > }

30

31 // Value returns the value for the given key at the given time.

56 // of type GradualChange into a GradualChange.

57 // nolint:revive // cognitive-complexity // this looks complicated but each case is fairly simple

58 > func ConvertGradualChange[T any](def T) func(v any) (GradualChange[T], error) { gradual_change.go

59 > changeConverter := ConvertStructure(StaticGradualChange(def))

60 >

61 > // Call this once so that if it's going to panic, it panics at static init time.

62 > _, _ = changeConverter(nil)

63 >

64 > switch reflect.TypeFor[T]() {

65 > case reflect.TypeFor[bool]():

66 > return func(v any) (GradualChange[T], error) {

67 if b, err := convertBool(v); err == nil {

68 var change GradualChange[T]

72 return changeConverter(v)

73 }

74 > case reflect.TypeFor[int](): gradual_change.go

75 > return func(v any) (GradualChange[T], error) {

76 if i, err := convertInt(v); err == nil {

77 var change GradualChange[T]

go.temporal.io/server/common/dynamicconfig/shared_structure.go 13 covered LOC · 5 ranges

Open complete file

17 )

18

19 > func warnDefaultSharedStructure(key string, def any) { shared_structure.go

20 > if path := hasSharedStructure(reflect.ValueOf(def), "root"); path != "" {

21 sharedStructureWarnings.Store(key, path)

22 }

42 }

43

44 > func hasSharedStructure(v reflect.Value, path string) string { shared_structure.go

45 > // nolint:exhaustive // deliberately not exhaustive

46 > switch v.Kind() {

47 > case reflect.Map, reflect.Slice, reflect.Pointer:

48 > if !v.IsNil() {

49 return path

50 }

51 > case reflect.Interface: shared_structure.go

52 > if !v.IsNil() {

53 return hasSharedStructure(v.Elem(), path)

54 }

55 > case reflect.Struct: shared_structure.go

56 > for i := range v.NumField() {

57 > if p := hasSharedStructure(v.Field(i), path+"."+v.Type().Field(i).Name); p != "" {

58 return p

59 }

66 }

67 }

68 > return "" shared_structure.go

69 }

go.temporal.io/server/chasm/lib/callback/statemachine.go 12 covered LOC · 1 range

Open complete file

93 []callbackspb.CallbackStatus{callbackspb.CALLBACK_STATUS_SCHEDULED},

94 callbackspb.CALLBACK_STATUS_FAILED,

95 > func(cb *Callback, ctx chasm.MutableContext, event EventFailed) error { statemachine.go

96 > cb.recordAttempt(event.Time)

97 > cb.LastAttemptFailure = &failurepb.Failure{

98 > Message: event.Err.Error(),

99 > FailureInfo: &failurepb.Failure_ApplicationFailureInfo{

100 > ApplicationFailureInfo: &failurepb.ApplicationFailureInfo{

101 > NonRetryable: true,

102 > },

103 > },

104 > }

105 > return nil

106 > },

107 )

108

go.temporal.io/server/chasm/library.go 12 covered LOC · 4 ranges

Open complete file

34 }

35

36 > func (UnimplementedLibrary) Tasks() []*RegistrableTask { library.go

37 > return nil

38 > }

39

40 // RegisterServices Registers the gRPC calls to the handlers of the library.

42 }

43

44 > func (UnimplementedLibrary) NexusServices() []*nexus.Service { library.go

45 > return nil

46 > }

47

48 > func (UnimplementedLibrary) NexusServiceProcessors() []*NexusServiceProcessor { library.go

49 > return nil

50 > }

51

52 func (UnimplementedLibrary) mustEmbedUnimplementedLibrary() {}

56 // tasks within the CHASM framework.

57 // The format of the returned FQN is: "libName.name"

58 > func FullyQualifiedName(libName, name string) string { library.go

59 > return libName + "." + name

60 > }

go.temporal.io/server/chasm/ref.go 12 covered LOC · 3 ranges

Open complete file

61 func NewComponentRef[C Component](

62 executionKey ExecutionKey,

63 > ) ComponentRef { ref.go

64 > return ComponentRef{

65 > ExecutionKey: executionKey,

66 > executionGoType: reflect.TypeFor[C](),

67 > }

68 > }

69

70 // NewComponentRefByArchetypeID creates a new ComponentRef with a known archetype ID.

84 // dropping the consistency tokens (and, at the weakest level, the run ID) that the level does not enforce.

85 // See [RefConsistencyLevel] for the ladder.

86 > func (r *ComponentRef) forConsistencyLevel(level RefConsistencyLevel) (ComponentRef, error) { ref.go

87 > ref := *r

88 > switch level {

89 > case RefConsistencyLevelExecutionLastUpdate: ref.go

90 > // Strongest (default): enforce the execution-level token; nothing relaxed.

91 > return ref, nil

92 case RefConsistencyLevelComponentCreation:

93 // Tolerate a stale execution transition without losing the staleness guarantee: run the

go.temporal.io/server/common/namespace/replication_resolver.go 12 covered LOC · 1 range

Open complete file

49 }

50

51 > func NewDefaultReplicationResolverFactory() ReplicationResolverFactory { replication_resolver.go

52 > return func(detail *persistencespb.NamespaceDetail) ReplicationResolver {

53 > // By convention, a namespace with non-zero failover version is a global namespace

54 > // This can be overridden by WithGlobalFlag mutation if needed

55 > isGlobal := detail.FailoverVersion != 0

56 > return &defaultReplicationResolver{

57 > replicationConfig: detail.ReplicationConfig,

58 > isGlobalNamespace: isGlobal,

59 > failoverVersion: detail.FailoverVersion,

60 > failoverNotificationVersion: detail.FailoverNotificationVersion,

61 > }

62 > }

63 }

64

go.temporal.io/server/common/persistence/visibility/store/elasticsearch/visibility_store.go 12 covered LOC · 3 ranges

Open complete file

101 }

102

103 > defaultSorter = func() []elastic.Sorter { visibility_store.go

104 > ret := make([]elastic.Sorter, 0, len(defaultSorterFields))

105 > for _, item := range defaultSorterFields {

106 > fs := elastic.NewFieldSort(item.name)

107 > if item.desc {

108 > fs.Desc()

109 > }

110 > if item.missing_first {

111 > fs.Missing("_first")

112 > } else {

113 fs.Missing("_last")

114 }

115 > ret = append(ret, fs) visibility_store.go

116 }

117 > return ret visibility_store.go

118 }()

119

go.temporal.io/server/common/metrics/defs_base.go 10 covered LOC · 1 range

Open complete file

10 }

11

12 > func newMetricDefinition(name string, opts ...Option) metricDefinition { defs_base.go

13 > d := metricDefinition{

14 > name: name,

15 > description: "",

16 > unit: "",

17 > }

18 > for _, opt := range opts {

19 > opt.apply(&d)

20 > }

21 > return d

22 }

23

go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/plugin.go 10 covered LOC · 1 range

Open complete file

36 var _ sqlplugin.Plugin = (*plugin)(nil)

37

38 > func init() { plugin.go

39 > sql.RegisterPlugin(PluginName, &plugin{

40 > driver: &driver.PQDriver{},

41 > queryConverter: &queryConverter{},

42 > })

43 > sql.RegisterPlugin(PluginNamePGX, &plugin{

44 > driver: &driver.PGXDriver{},

45 > queryConverter: &queryConverter{},

46 > })

47 > }

48

49 func (p *plugin) GetVisibilityQueryConverter() sqlplugin.VisibilityQueryConverter {

go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/visibility.go 10 covered LOC · 1 range

Open complete file

40 )

41

42 > func buildOnDuplicateKeyUpdate(fields ...string) string { visibility.go

43 > items := make([]string, len(fields))

44 > for i, field := range fields {

45 > items[i] = fmt.Sprintf("%s = excluded.%s", field, field)

46 > }

47 > return fmt.Sprintf(

48 > // The WHERE clause ensures that no update occurs if the version is behind the saved version.

49 > "ON CONFLICT (namespace_id, run_id) DO UPDATE SET %s WHERE executions_visibility.%s < EXCLUDED.%s",

50 > strings.Join(items, ", "), sqlplugin.VersionColumnName, sqlplugin.VersionColumnName,

51 > )

52 }

53

go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/visibility.go 10 covered LOC · 1 range

Open complete file

42 )

43

44 > func buildOnDuplicateKeyUpdate(fields ...string) string { visibility.go

45 > items := make([]string, len(fields))

46 > for i, field := range fields {

47 > items[i] = fmt.Sprintf("%s = excluded.%s", field, field)

48 > }

49 > return fmt.Sprintf(

50 > // The WHERE clause ensures that no update occurs if the version is behind the saved version.

51 > "ON CONFLICT (namespace_id, run_id) DO UPDATE SET %s WHERE executions_visibility.%s < EXCLUDED.%s",

52 > strings.Join(items, ", "), sqlplugin.VersionColumnName, sqlplugin.VersionColumnName,

53 > )

54 }

55

go.temporal.io/server/common/persistence/sql/sqlplugin/visibility.go 10 covered LOC · 2 ranges

Open complete file

219 }

220

221 > func getDbFields() []string { visibility.go

222 > t := reflect.TypeFor[VisibilityRow]()

223 > dbFields := make([]string, t.NumField())

224 > for i := 0; i < t.NumField(); i++ {

225 > f := t.Field(i)

226 > dbFields[i] = f.Tag.Get("db")

227 > if dbFields[i] == "" {

228 > dbFields[i] = strcase.ToSnake(f.Name)

229 > }

230 }

231 > return dbFields visibility.go

232 }

233

go.temporal.io/server/common/persistence/visibility/store/query/util.go 10 covered LOC · 2 ranges

Open complete file

70 }

71

72 > func NewUnsafeSQLString(val string) *UnsafeSQLString { util.go

73 > return &UnsafeSQLString{Val: val}

74 > }

75

76 func NewColName(name string) *ColumnName {

78 }

79

80 > func NewSAColumn(alias string, fieldName string, valueType enumspb.IndexedValueType) *SAColumn { util.go

81 > return &SAColumn{

82 > Alias: alias,

83 > FieldName: fieldName,

84 > ValueType: valueType,

85 > }

86 > }

87

88 func NamespaceDivisionSAColumn() *SAColumn {

go.temporal.io/server/common/persistence/sql/sqlplugin/util.go 9 covered LOC · 2 ranges

Open complete file

5 )

6

7 > func appendPrefix(prefix string, fields []string) []string { util.go

8 > out := make([]string, len(fields))

9 > for i, field := range fields {

10 > out[i] = prefix + field

11 > }

12 > return out

13 }

14

15 > func BuildNamedPlaceholder(fields ...string) string { util.go

16 > return strings.Join(appendPrefix(":", fields), ", ")

17 > }

go.temporal.io/server/common/testing/testhooks/test_impl.go 9 covered LOC · 2 ranges

Open complete file

89 var keyCounter atomic.Int64

90

91 > func newKey[T any, S any]() Key[T, S] { test_impl.go

92 > var zero S

93 > var s ScopeType

94 > switch any(zero).(type) {

95 > case namespace.ID, namespace.Name:

96 > s = ScopeNamespace

97 > case global:

98 > s = ScopeGlobal

99 default:

100 panic("testhooks: unknown scope type")

101 }

102 > return Key[T, S]{id: keyCounter.Add(1), scopeType: s} test_impl.go

103 }

go.temporal.io/server/chasm/component.go 8 covered LOC · 3 ranges

Open complete file

122 ctx context.Context,

123 intent OperationIntent,

124 > ) context.Context { component.go

125 > return context.WithValue(ctx, operationIntentCtxKey, intent)

126 > }

127

128 func operationIntentFromContext(

129 ctx context.Context,

130 > ) OperationIntent { component.go

131 > intent, ok := ctx.Value(operationIntentCtxKey).(OperationIntent)

132 > if !ok {

133 > return OperationIntentUnspecified component.go

134 > }

135 return intent

136 }

go.temporal.io/server/chasm/field.go 8 covered LOC · 2 ranges

Open complete file

39 c C,

40 options ...ComponentFieldOption,

41 > ) Field[C] { field.go

42 > opts := &componentFieldOptions{}

43 > for _, o := range options {

44 o(opts)

45 }

46 > internal := newFieldInternalWithValue(fieldTypeComponent, c) field.go

47 > internal.detached = opts.detached

48 > return Field[C]{

49 > Internal: internal,

50 > }

51 }

52

go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/visibility.go 8 covered LOC · 1 range

Open complete file

73 )

74

75 > func buildOnDuplicateKeyUpdate(fields ...string) string { visibility.go

76 > items := make([]string, len(fields))

77 > for i, field := range fields {

78 > // This line is to ensure that no update occurs (for any column) if the version is behind the saved version.

79 > items[i] = fmt.Sprintf("%v = IF(%v < VALUES(%v), VALUES(%v), %v)",

80 > field, sqlplugin.VersionColumnName, sqlplugin.VersionColumnName, field, field)

81 > }

82 > return fmt.Sprintf("ON DUPLICATE KEY UPDATE %s", strings.Join(items, ", "))

83 }

84

go.temporal.io/server/chasm/nexus_completion.go 7 covered LOC · 3 ranges

Open complete file

69 // the NexusOperationCompletion envelope, and (for backward compatibility) the legacy bare base64-encoded

70 // ChasmComponentRef, in which case the request ID is empty.

71 > func UnpackNexusCallbackToken(encoded string) (componentRef []byte, requestID string, err error) { nexus_completion.go

72 > raw, err := base64.RawURLEncoding.DecodeString(encoded)

73 > if err != nil {

74 return nil, "", err

75 }

76 > completion := &tokenspb.NexusOperationCompletion{} nexus_completion.go

77 > if proto.Unmarshal(raw, completion) == nil && len(completion.GetComponentRef()) > 0 &&

78 > proto.Unmarshal(completion.GetComponentRef(), &persistencespb.ChasmComponentRef{}) == nil {

79 return completion.GetComponentRef(), completion.GetRequestId(), nil

80 }

81 // Legacy format: the raw bytes are the ChasmComponentRef directly.

82 > return raw, "", nil nexus_completion.go

83 }

go.temporal.io/server/common/dynamicconfig/registry.go 7 covered LOC · 3 ranges

Open complete file

17 )

18

19 > func register(s GenericSetting) { registry.go

20 > if globalRegistry.queried.Load() {

21 panic("dynamicconfig.New*Setting must only be called from static initializers")

22 }

23 > if globalRegistry.settings == nil { registry.go

24 > globalRegistry.settings = make(map[Key]GenericSetting)

25 > }

26 > if globalRegistry.settings[s.Key()] != nil {

27 // nolint:forbidigo // only called during static initialization

28 panic(fmt.Sprintf("duplicate registration of dynamic config key: %q", s.Key().String()))

29 }

30 > globalRegistry.settings[s.Key()] = s registry.go

31 }

32

go.temporal.io/server/common/membership/grpc_resolver.go 7 covered LOC · 2 ranges

Open complete file

53 )

54

55 > func init() { grpc_resolver.go

56 > // This must be called in init to avoid race conditions.

57 > resolver.Register(&globalGrpcBuilder)

58 > }

59

60 // Most code should not use this, this is only exposed for code that has to recognize and use a

80 }

81

82 > func (m *grpcBuilder) Scheme() string { grpc_resolver.go

83 > return grpcResolverScheme

84 > }

85

86 func (m *grpcBuilder) getServiceResolver(u *url.URL) (ServiceResolver, error) {

go.temporal.io/server/common/util.go 7 covered LOC · 2 ranges

Open complete file

161

162 // CreatePersistenceClientRetryPolicy creates a retry policy for calls to persistence

163 > func CreatePersistenceClientRetryPolicy() backoff.RetryPolicy { util.go

164 > return backoff.NewExponentialRetryPolicy(persistenceClientRetryInitialInterval).

165 > WithMaximumAttempts(persistenceClientRetryMaxAttempts)

166 > }

167

168 // CreateFrontendClientRetryPolicy creates a retry policy for calls to frontend service

688

689 // CloneProto is a generic typed version of proto.Clone from proto.

690 > func CloneProto[T proto.Message](v T) T { util.go

691 > return proto.Clone(v).(T)

692 > }

693

694 func CloneProtoMap[K comparable, T proto.Message](src map[K]T) map[K]T {

go.temporal.io/server/common/metrics/option.go 6 covered LOC · 2 ranges

Open complete file

10 type WithDescription string

11

12 > func (h WithDescription) apply(m *metricDefinition) { option.go

13 > m.description = string(h)

14 > }

15

16 // WithUnit sets the unit of a metric. See NewBytesHistogramDef for an example.

17 type WithUnit MetricUnit

18

19 > func (h WithUnit) apply(m *metricDefinition) { option.go

20 > m.unit = MetricUnit(h)

21 > }

go.temporal.io/server/common/persistence/data_interfaces.go 6 covered LOC · 3 ranges

Open complete file

1408 // UnixMilliseconds returns t as a Unix time, the number of milliseconds elapsed since January 1, 1970 UTC.

1409 // It should be used for all CQL timestamp.

1410 > func UnixMilliseconds(t time.Time) int64 { data_interfaces.go

1411 > // Handling zero time separately because UnixNano is undefined for zero times.

1412 > if t.IsZero() {

1413 return 0

1414 }

1415

1416 > unixNano := t.UnixNano() data_interfaces.go

1417 > if unixNano < 0 {

1418 // Time is before January 1, 1970 UTC

1419 return 0

1420 }

1421 > return unixNano / int64(time.Millisecond) data_interfaces.go

1422 }

1423

go.temporal.io/server/common/persistence/nosql/nosqlplugin/cassandra/translator/fixed_address_translator.go 6 covered LOC · 2 ranges

Open complete file

15 )

16

17 > func init() { fixed_address_translator.go

18 > RegisterTranslator(fixedTranslatorName, NewFixedAddressTranslatorPlugin())

19 > }

20

21 type FixedAddressTranslatorPlugin struct {

22 }

23

24 > func NewFixedAddressTranslatorPlugin() TranslatorPlugin { fixed_address_translator.go

25 > return &FixedAddressTranslatorPlugin{}

26 > }

27

28 // GetTranslator What gocql driver does is that it will connect to the first node in the list in configuration

go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/plugin.go 6 covered LOC · 1 range

Open complete file

43 }

44

45 > func init() { plugin.go

46 > sql.RegisterPlugin(PluginName, &plugin{

47 > queryConverter: &queryConverter{},

48 > connPool: newConnPool(),

49 > })

50 > }

51

52 func (p *plugin) GetVisibilityQueryConverter() sqlplugin.VisibilityQueryConverter {

go.temporal.io/server/common/persistence/transitionhistory/transition_history.go 6 covered LOC · 5 ranges

Open complete file

51 func Compare(

52 a, b *persistencespb.VersionedTransition,

53 > ) int { transition_history.go

54 > if a.GetNamespaceFailoverVersion() < b.GetNamespaceFailoverVersion() {

55 return -1

56 }

57 > if a.GetNamespaceFailoverVersion() > b.GetNamespaceFailoverVersion() { transition_history.go

58 return 1

59 }

60

61 > if a.GetTransitionCount() < b.GetTransitionCount() { transition_history.go

62 return -1

63 }

64 > if a.GetTransitionCount() > b.GetTransitionCount() { transition_history.go

65 return 1

66 }

67

68 > return 0 transition_history.go

69 }

70

go.temporal.io/server/service/history/tasks/key.go 6 covered LOC · 1 range

Open complete file

35 }

36

37 > func NewKey(fireTime time.Time, taskID int64) Key { key.go

38 > return Key{

39 > FireTime: fireTime,

40 > TaskID: taskID,

41 > }

42 > }

43

44 func ValidateKey(key Key) error {

go.temporal.io/server/chasm/nexus_operation_processor.go 5 covered LOC · 1 range

Open complete file

165

166 // NewNexusEndpointProcessor creates a new NexusEndpointProcessor.

167 > func NewNexusEndpointProcessor() *NexusEndpointProcessor { nexus_operation_processor.go

168 > return &NexusEndpointProcessor{

169 > serviceProcessors: make(map[string]*NexusServiceProcessor),

170 > }

171 > }

172

173 // RegisterServiceProcessor adds a service-level processor to the endpoint keyed by its name.

go.temporal.io/server/common/metrics/registry.go 5 covered LOC · 1 range

Open complete file

43

44 // register adds a metric definition to the list of pending metric definitions. This method is thread-safe.

45 > func (c *registry) register(d metricDefinition) { registry.go

46 > c.Lock()

47 > defer c.Unlock()

48 > c.definitions = append(c.definitions, d)

49 > }

50

51 // buildCatalog builds a catalog from the list of pending metric definitions. It is safe to call this method multiple

go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/plugin.go 5 covered LOC · 1 range

Open complete file

24 var _ sqlplugin.Plugin = (*plugin)(nil)

25

26 > func init() { plugin.go

27 > sql.RegisterPlugin(PluginName, &plugin{

28 > queryConverter: &queryConverter{},

29 > })

30 > }

31

32 func (p *plugin) GetVisibilityQueryConverter() sqlplugin.VisibilityQueryConverter {

go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/conn_pool.go 5 covered LOC · 1 range

Open complete file

23 }

24

25 > func newConnPool() *connPool { conn_pool.go

26 > return &connPool{

27 > pool: make(map[string]entry),

28 > }

29 > }

30

31 // Allocate allocates the shared database in the pool or returns already exists instance with the same DSN. If instance

go.temporal.io/server/common/telemetry/config.go 5 covered LOC · 2 ranges

Open complete file

409 }

410

411 > func DebugMode() bool { config.go

412 > isDebug, err := strconv.ParseBool(os.Getenv(debugModeEnvVar))

413 > if err != nil {

414 > return false config.go

415 > }

416 return isDebug

417 }

go.temporal.io/server/common/persistence/sql/sqlplugin/mysql/typeconv.go 4 covered LOC · 2 ranges

Open complete file

33 }

34

35 > func getMinMySQLDateTime() time.Time { typeconv.go

36 > t, err := time.Parse(time.RFC3339, "1000-01-01T00:00:00Z")

37 > if err != nil {

38 return time.Unix(0, 0).UTC()

39 }

40 > return t.UTC() typeconv.go

41 }

go.temporal.io/server/common/persistence/sql/sqlplugin/postgresql/typeconv.go 4 covered LOC · 2 ranges

Open complete file

35 }

36

37 > func getMinPostgreSQLDateTime() time.Time { typeconv.go

38 > t, err := time.Parse(time.RFC3339, "1000-01-01T00:00:00Z")

39 > if err != nil {

40 return time.Unix(0, 0).UTC()

41 }

42 > return t.UTC() typeconv.go

43 }

go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/typeconv.go 4 covered LOC · 2 ranges

Open complete file

33 }

34

35 > func getMinSQLiteDateTime() time.Time { typeconv.go

36 > t, err := time.Parse(time.RFC3339, "1000-01-01T00:00:00Z")

37 > if err != nil {

38 return time.Unix(0, 0).UTC()

39 }

40 > return t.UTC() typeconv.go

41 }

go.temporal.io/server/common/util/util.go 4 covered LOC · 1 range

Open complete file

68

69 // InverseMap creates the inverse map, ie., for a key-value map, it builds the value-key map.

70 > func InverseMap[M ~map[K]V, K, V comparable](m M) map[V]K { util.go

71 > if m == nil {

72 > return nil

73 > }

74 invm := make(map[V]K, len(m))

75 for k, v := range m {

go.temporal.io/server/api/persistence/v1/chasm.go-helpers.pb.go 3 covered LOC · 1 range

Open complete file

340

341 // Marshal an object of type ChasmComponentRef to the protobuf v3 wire format

342 > func (val *ChasmComponentRef) Marshal() ([]byte, error) { chasm.go-helpers.pb.go

343 > return proto.Marshal(val)

344 > }

345

346 // Unmarshal an object of type ChasmComponentRef from the protobuf v3 wire format

go.temporal.io/server/api/persistence/v1/predicates.go-helpers.pb.go 3 covered LOC · 1 range

Open complete file

17

18 // Size returns the size of the object, in bytes, once serialized

19 > func (val *Predicate) Size() int { predicates.go-helpers.pb.go

20 > return proto.Size(val)

21 > }

22

23 // Equal returns whether two Predicate values are equivalent by recursively

go.temporal.io/server/common/dynamicconfig/key.go 3 covered LOC · 1 range

Open complete file

13 )

14

15 > func MakeKey(s string) Key { key.go

16 > return Key{handle: unique.Make(strings.ToLower(s))}

17 > }

18

19 func (k Key) String() string {

go.temporal.io/server/common/payload/payload.go 3 covered LOC · 1 range

Open complete file

30 }

31

32 > func Encode(value any) (*commonpb.Payload, error) { payload.go

33 > return defaultDataConverter.ToPayload(value)

34 > }

35

36 func Decode(p *commonpb.Payload, valuePtr any) error {

go.temporal.io/server/common/persistence/nosql/nosqlplugin/cassandra/translator/translator_plugin.go 3 covered LOC · 1 range

Open complete file

22 // RegisterPlugin adds an auth plugin to the plugin registry

23 // it is only safe to use from a package init function

24 > func RegisterTranslator(name string, plugin TranslatorPlugin) { translator_plugin.go

25 > translators[name] = plugin

26 > }

27

28 func LookupTranslator(name string) (TranslatorPlugin, error) {

go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go 3 covered LOC · 1 range

Open complete file

1182 baseAPI string,

1183 taskCategory tasks.Category,

1184 > ) string { persistence_rate_limited_clients.go

1185 > return baseAPI + taskCategory.Name()

1186 > }

go.temporal.io/server/common/persistence/sql/store.go 3 covered LOC · 2 ranges

Open complete file

19

20 // RegisterPlugin will register a SQL plugin

21 > func RegisterPlugin(pluginName string, plugin sqlplugin.Plugin) { store.go

22 > if _, ok := supportedPlugins[pluginName]; ok {

23 panic("plugin " + pluginName + " already registered")

24 }

25 > supportedPlugins[pluginName] = plugin store.go

26 }

27

go.temporal.io/server/common/tasks/priority.go 3 covered LOC · 1 range

Open complete file

77 func getPriority(

78 class, subClass Priority,

79 > ) Priority { priority.go

80 > return class | subClass

81 > }

go.temporal.io/server/service/history/tasks/category.go 3 covered LOC · 1 range

Open complete file

100 }

101

102 > func (c Category) Name() string { category.go

103 > return c.name

104 > }

105

106 func (c Category) Type() CategoryType {

go.temporal.io/server/common/log/panic.go 2 covered LOC · 1 range

Open complete file

13 // We have to use pointer is because in golang: "recover return nil if was not called directly by a deferred function."

14 // And we have to set the returned error otherwise our handler will return nil as error which is incorrect

15 > func CapturePanic(logger Logger, retError *error) { panic.go

16 > if panicObj := recover(); panicObj != nil {

17 err, ok := panicObj.(error)

18 if !ok {

go.temporal.io/server/common/persistence/client/fx.go 2 covered LOC · 1 range

Open complete file

224 }

225

226 > func managerProvider[T persistence.Closeable](newManagerFn func(Factory) (T, error)) func(Factory, fx.Lifecycle) (T, error) { fx.go

227 > return func(f Factory, lc fx.Lifecycle) (T, error) {

228 manager, err := newManagerFn(f) // passing receiver (Factory) as first argument.

229 if err != nil {

go.temporal.io/server/common/aggregate/noop_moving_window_average.go 1 covered LOC · 1 range

Open complete file

7 )

8

9 > func newNoopMovingWindowAverage() *noopMovingWindowAverage { return &noopMovingWindowAverage{} } noop_moving_window_average.go

10

11 func (a *noopMovingWindowAverage) Record(_ int64) {}

go.temporal.io/server/common/metrics/noop_impl.go 1 covered LOC · 1 range

Open complete file

15 )

16

17 > func newNoopMetricsHandler() *noopMetricsHandler { return &noopMetricsHandler{} } noop_impl.go

18

19 // WithTags creates a new MetricProvder with provided []Tag

go.temporal.io/server/common/persistence/noop_health_signal_aggregator.go 1 covered LOC · 1 range

Open complete file

11 )

12

13 > func newNoopSignalAggregator() *noopSignalAggregator { return &noopSignalAggregator{} } noop_health_signal_aggregator.go

14

15 func (a *noopSignalAggregator) Start() {}