CountExecutions counts the executions of a CHASM archetype given an initial query. The generic parameter C is the CHASM component type used for execut

CreateMatchingClientRetryPolicy creates a retry policy for calls to matching service. When retryUnboundedOnSystemResourceExhausted returns true, syste

CreateReadTaskRetryPolicy creates a retry policy for loading background tasks

CreateSchemaVersionTables sets up the schema version tables

constructor callback must create empty object, add it to result slice, and return it.

DeleteFromCurrentExecutions deletes a single row that matches the filter criteria If a row exist, that row will be deleted and this method will return

DeleteFromReplicationDLQTasks deletes one row from replication_tasks_dlq table

DeleteFromReplicationTasks deletes a row from replication_tasks table

DeleteFromTimerTasks deletes one or more rows from timer_tasks table

DeleteFromTransferTasks deletes one rows from transfer_tasks table.

DeleteFromVisibilityTasks deletes one rows from visibility_tasks table.

DeleteHistoryNodes delete a node from history node table

DeletePendingRequestCancel deletes details about a RequestCancelInfo.

DeletePendingSignal deletes details about a SignalInfo

DeleteUserTimer deletes an user timer.

Dial creates a client connection to the given target with default options. The hostName syntax is defined in https://github.com/grpc/grpc/blob/master/

DropCassandraKeyspace drops the given keyspace, if it exists

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

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

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

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

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

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

EnqueueBufferedStarts adds new BufferedStarts to the invocation queue, immediately kicking off a processing task.

Equal returns whether two VersionHistory values are equivalent by recursively comparing the message's fields. For more information see the documentati

EqualTimes assertion that two times are equal within two millisecond precision

EstimateDistinctKeys returns an estimate of the number of distinct keys in the counter.

Fatal implements log.Logger.

ForServices indicates which supplied services (e.g. frontend, history, matching, worker) within the server to start

these 2 APIs should only be called when mutable state transaction is being closed

GenerateCRC32 generates an IEEE crc32 checksum on the serilized byte array of the given thrift object. The serialization proto used will be of type th

GenerateDeduplicationKey generates deduplication key

GenerateRequestIDRefLink builds a Link with a RequestIdReference. Use this for events that are buffered at signal time (e.g. SIGNALED), where the conc

TODO (rodrigozhou): deprecate with standard visibility code. GenerateSelectQuery generates the SELECT query based on the fields of VisibilitySelectFil

GetAllPollerInfo returns all pollers that polled from this taskqueue in last few minutes

GetByName returns an endpoint entry for the endpoint name for a caller from the given namespace ID. Note that the default implementation is global to

GetClientBean for testing

GetClusterMetadata for testing