NewHistoryEventEdge initials a new edge between two HistoryEventVertexes

String returns the 36 byte hexstring representation of this uuid return empty string if this uuid is nil

EXPECT returns an object that allows the caller to indicate expected use.

re. Data v.s. Component. Components have behavior and has a lifecycle. while Data doesn't and must be attached to a component. You can define a compo

NewRegistry creates a new [Registry].

RetryPolicy returns the retry policy for task processing

TaskID returns tag for TaskID

CreateQueue creates a new queue. An error will be returned if the queue already exists. In addition, an error will be returned if you attempt to opera

EXPECT returns an object that allows the caller to indicate expected use.

GetNamespace helper method

ReserveN returns a Reservation that indicates how long the caller must wait before event happen.

TryGet returns the value of the field and a boolean indicating if the value was found, deserializing if necessary. Panics rather than returning an err

Version returns a pointer to the physical queue version key. Caller must not manipulate the returned value.

TODO (Shivam): Clean up this function once sync entity workflows have been removed.

Execute process this task

GetFailoverVersionIncrement return the Failover version increment value

IsEmpty indicate if the queue is empty

NewRoot creates a new root [Node]. Children may be provided from persistence to rehydrate the tree. Returns [ErrNotRegistered] if the key's type is no

NewSerializer creates a new instance of Serializer

Options returns the TestOptions to configure matching behavior.

Unmarshal an object of type Task from the protobuf v3 wire format

waitForAssignmentRulePropagation waits for all partitions of tq to have the given assignment rule in their versioning data

EXPECT returns an object that allows the caller to indicate expected use.

Expect instructs the logger to track matching log calls, as specified by the level, msg, and tag arguments. For error-level logs, depending on the Mod

Len return the size of the queue

NewNamespaceForTest returns an entry with test data

Stop prevents the Timer from firing. It returns true if the call stops the timer, false if the timer has already expired or been stopped.

upsertHeartbeats inserts or refreshes a WorkerHeartbeat under the given namespace. Returns the count of added and removed entries separately. Workers

GetLastVersionHistoryItem return the last VersionHistoryItem.

That performs a soft assertion by logging an error if the given condition is false. It is meant to indicate a condition is always expected to be true.

WithMaximumInterval sets the maximum interval for each retry. This does *not* cause the policy to stop retrying when the interval between retries reac

========== System tags defined here: ========== Tags with pre-define values Component returns tag for Component

Dial returns a [TaskClient] given a cluster name. You don't need to close this client. Note that some implementations will cache clients.

WithExpirationInterval sets the absolute expiration interval for all retries

Append an issue to the set.

Bytes returns the raw bytes of the deserialized TaskPayload. This will return nil if the payload has not been deserialized yet.

EXPECT returns an object that allows the caller to indicate expected use.