NewQueryParser creates a new query parser for filestore

NewRPCFactory creates a new RPCFactory backed by a PipeListener.

NewReplicator create a new instance of namespace replicator

NewSearchAttributeDouble creates a new double search attribute given a predefined chasm field

NewSerializationError returns a SerializationError

NewServer returns a new instance of server that serves one or many services.

NewServerMetricsTrailerPropagatorInterceptor returns grpc server interceptor that injects metrics from context into gRPC trailer.

NewTaskExecutor creates a replication task executor The executor uses by 1) DLQ replication task handler 2) history replication task processor

NewTaskPersistenceRetryableClient creates a client to manage tasks

NewTaskQueueTypedSetting creates a setting that uses mapstructure to handle complex structured values. The value from dynamic config will be _merged_

NewTreeFromDB creates a new in-memory CHASM tree from a collection of flattened persistence CHASM nodes. This method should only be used when loading

Next generates the next clock timestamp given the current clock. HybridLogicalClock requires the previous clock to ensure that time doesn't move backw

NextAlignedTime returns the earliest time after `t` that is aligned to an integer multiple of `align` since the unix epoch.

NextTime returns the next time result, or an error if the schedule cannot be compiled.

Number returns tag for Number

NumberDeleted returns tag for NumberDeleted

NumberProcessed returns tag for NumberProcessed

ParseDLQMessages parses a JSONL file containing serialized [tdbg.DLQMessage] objects.

PersistenceTTL returns the TTL for the partition's persistence metadata. A zero value means no TTL (metadata persists indefinitely).

Poisoned reports whether the cluster's logger has recorded a failing log.

PopulateCallerInfo gets current caller info value from the context and updates any that are missing. Namespace name and method are passed as functions

Port returns tag for Port

Predicate constructs a prdicate from a slice of keys.

TODO(pri): old matcher cleanup

ProtoElementsMatch behaves like assert.ElementsMatch except in that it works for google/protobuf-generated structs

PublishUpdates calls all subscribed update functions with the changed keys.

TODO (alex): move this to some admin client (and join with IntegrationTestsClient)

task queue processor QueueReaderID returns tag for queue readerID

RangeDeleteFromReplicationDLQTasks deletes one or more rows from replication_tasks_dlq table ReplicationDLQTasksRangeFilter - {PageSize} will be ignor

DeleteFromReplicationTasks deletes multi rows from replication_tasks table ReplicationTasksRangeFilter - {PageSize} will be ignored

RangeDeleteFromTimerTasks deletes one or more rows from timer_tasks table TimerTasksRangeFilter - {TaskID, PageSize} will be ignored

RangeDeleteFromTransferTasks deletes one or more rows from transfer_tasks table. TransferTasksRangeFilter - {PageSize} will be ignored

RangeDeleteFromVisibilityTasks deletes one or more rows from visibility_tasks table. VisibilityTasksRangeFilter - {PageSize} will be ignored

RecordExecuteResult exposes recordExecuteResult so tests can pin the per-RequestId idempotency guard against concurrent ExecuteTasks.

RecycleToken immediately unblocks another process that is waiting for a token, if a waiter exists. A token should be recycled when the action being ra

ReencodeEventBlobsAsProto3 re-encodes event blobs as proto3 if the serializer uses a different encoding. In production (proto3 encoding), this returns

RelocatableAttributesFetcherProvider provides a new instance of a RelocatableAttributesFetcher. The manager.VisibilityManager parameter is used to fet

Remove deletes the given key from the map

ReplaceIntoChasmNodeMaps replaces one or more rows in the chasm_node_maps table.

ReplicationTaskTypeTag returns a new replication task type tag.

ResetContextTimeout creates new context with specified timeout and copies values from source Context.

For testing only; do not call from regular code!

RunDryrunTest tests a dryrun schema setup & update

RunNow deletes a batch of completed tasks if it's possible to do so This method attempts deletions without waiting for size/time threshold to be met

RunTool runs the temporal-cassandra-tool command line tool