onRejectionMsg expects the Update state to be stateSent (or stateAdmitted) and returns an error otherwise. On commit of buffered effects, the state ma

onResponseMsg expects the Update to be in either stateProvisionallyAccepted or stateAccepted and returns an error if it finds otherwise. On commit of

packNexusCallbackToken encodes a CHASM component ref and request ID into a callback token.

logic borrowed from tls.X509KeyPair()

Elasticsearch aggregation groups are returned as a nested object. This function flattens the response into rows. nolint:revive // cognitive complexit

parseFullyQualifiedTestName extracts names like "pkg/path.TestName" from a line.

parseHosts returns parses a list of hosts separated by comma

parseJUnitFile reads and parses a single JUnit XML file

parsePlainTestName extracts a leading "TestName(" form.

parseRequestTimeoutHeader checks if the Request-Timeout HTTP header is set and returns the parsed duration if so. Returns (0, true) if unset. Returns

parseTimeDuration parses the given time duration in either short or long convention and returns the time.Duration Valid values (long notation/short no

parseTimeRange parses a given time duration string (in format X<time-duration>) and returns parsed timestamp given that duration in the past from curr

pendingNexusOperationCount returns the number of pending Nexus operations in the workflow.

performPostResetOperations performs the optional post reset operations on the reset workflow.

persistPendingCallbacks writes one WorkflowExecutionOptionsUpdatedEvent per buffered AttachCallbacks callback, skipping any whose requestID is already

caller to ensure that lock is obtained before call this function

pollNexusTaskQueueResponse returns the poll response for a nexus task that is ready for dispatching. This method should only be called when isStarted(

pollWorkflowTasksConcurrently polls tasks using numWorkers concurrently

postValidate update tracked task info

preValidate track a task and return if validation should be done

predicateSatisfied is a helper function for PollComponent. It returns (ref, err) where ref is non-nil iff there's no error and predicate evaluates to

prepareNewWorkflow creates a new workflow context, and closes its mutable state transaction as snapshot. It returns the creationContext which can late

process is a callback function that gets invoked from within the executor.Run() method