LatestEventBatchID returns the first event ID of the batch currently being built, or common.EmptyEventID if the current batch is empty, e.g. after a F

Greater returns true if a is greater than b

Less implements sort.Interface

ListClosedWorkflow mocks base method.

ListExecutions implements the Engine interface for visibility queries.

ListTables returns a list of tables in this database

ListTables lists the table names in a Keyspace

ListTables returns a list of tables in this database

ListTables returns a list of tables in this database

ListTables returns a list of tables in this database

ListenerName returns tag for ListenerName

LoadFile parses and processes the given file contents into lr.Map (initialized if nil).

LoadSchema from PersistenceTestCluster interface

Main is the entry point for the testrunner tool. nolint:revive,deep-exit

MakePollerScalingDecision makes a decision on whether to scale pollers up or down based on the current state of the task queue and the task about to b

Marshal an object of type ChasmVisibilityData to the protobuf v3 wire format

Marshal an object of type ChasmVisibilityTaskData to the protobuf v3 wire format

Marshal an object of type ReadQueueMessagesNextPageToken to the protobuf v3 wire format

Marshal an object of type ListQueuesNextPageToken to the protobuf v3 wire format

Marshal an object of type GetWorkflowExecutionHistoryResponseWithRaw to the protobuf v3 wire format

MatchTasks returns all tasks in a category that match the given matcher function

MatchTasksForNamespace returns all tasks in a category for a specific namespace

MatchTasksForWorkflow returns all tasks in a category for a specific workflow If namespaceID is empty, it matches any namespace If runID is empty, it

MergeData performs a business specific merge of namespace data.

MustWildCardStringsToRegexp is like WildCardStringsToRegexp but panics on error.

Use test env-specific namespace here for test isolation.

NamespaceDLQHandlerProvider provides the default namespace DLQ message handler.

----------- Methods for every entity ------------ Add more as you need them following the pattern below. Replace "Entity" with the name of the entity,

New returns a new instance as daemon

NewCassandraConfig returns a new Cassandra config for test

NewCliApp instantiates a new instance of the CLI application

NewClient creates a new frontend service gRPC client

NewClient creates a new matching service gRPC client

NewClient creates a new admin service gRPC client

NewClient creates a new Client

NewClientCache creates a new client cache based on membership

NewClientStatsHandler creates a new gRPC stats handler that tracks each request with an encapsulating span using the provided TracerProvider and TextM

NewClientWithOptions returns a new Temporal client configured for making requests to the server. If no namespace option is set it will use a pre-regi

NewClientWithOptions is the same as NewClient but allows further customization. To set the client's namespace, use the corresponding field in client.

NewClusterMetadataManagerImpl returns new ClusterMetadataManager

NewClusterMetadataPersistenceMetricsClient creates a ClusterMetadataManager client to manage cluster metadata

NewClusterMetadataPersistenceRateLimitedClient creates a ClusterMetadataManager client to manage cluster metadata

NewClusterMetadataStore is used to create an instance of ClusterMetadataStore implementation

NewCollection creates a new [Collection].

NewCommandHandlerRegistry creates a new [CommandHandlerRegistry].

NewCompletionHandler returns a CompletionHandler. Wired via fx; see Module.