Affected by GO-2026-5578 and 1 other vulnerabilities

GO-2026-5578: Temporal does not enforce authentication and authorization for the streaming AdminService/StreamWorkflowReplicationMessages endpoint in go.temporal.io/server

GO-2026-5766: Temporal Server: attacker-controlled namespace could signal, delete, and reset workflows or activities in a victim namespace on the same cluster in go.temporal.io/server

tests

package

v1.29.4 Latest Latest Go to latest Published: Mar 4, 2026 License: MIT Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/temporalio/temporal

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewHistoryCurrentExecutionSuite(t *testing.T, store sqlplugin.HistoryExecution) *historyCurrentExecutionSuite
func NewHistoryExecutionActivitySuite(t *testing.T, store sqlplugin.HistoryExecutionActivity) *historyExecutionActivitySuite
func NewHistoryExecutionBufferSuite(t *testing.T, store sqlplugin.HistoryExecutionBuffer) *historyExecutionBufferSuite
func NewHistoryExecutionChasmSuite(t *testing.T, store sqlplugin.HistoryExecutionChasm) *historyExecutionChasmSuite
func NewHistoryExecutionChildWorkflowSuite(t *testing.T, store sqlplugin.HistoryExecutionChildWorkflow) *historyExecutionChildWorkflowSuite
func NewHistoryExecutionRequestCancelSuite(t *testing.T, store sqlplugin.HistoryExecutionRequestCancel) *historyExecutionRequestCancelSuite
func NewHistoryExecutionSignalRequestSuite(t *testing.T, store sqlplugin.HistoryExecutionSignalRequest) *historyExecutionSignalRequestSuite
func NewHistoryExecutionSignalSuite(t *testing.T, store sqlplugin.HistoryExecutionSignal) *historyExecutionSignalSuite
func NewHistoryExecutionSuite(t *testing.T, store sqlplugin.DB) *historyExecutionSuite
func NewHistoryExecutionTimerSuite(t *testing.T, store sqlplugin.HistoryExecutionTimer) *historyExecutionTimerSuite
func NewHistoryNodeSuite(t *testing.T, store sqlplugin.HistoryNode) *historyNodeSuite
func NewHistoryReplicationDLQTaskSuite(t *testing.T, store sqlplugin.HistoryReplicationDLQTask) *historyHistoryReplicationDLQTaskSuite
func NewHistoryReplicationTaskSuite(t *testing.T, store sqlplugin.HistoryReplicationTask) *historyHistoryReplicationTaskSuite
func NewHistoryShardSuite(t *testing.T, store sqlplugin.DB) *historyShardSuite
func NewHistoryTimerTaskSuite(t *testing.T, store sqlplugin.HistoryTimerTask) *historyHistoryTimerTaskSuite
func NewHistoryTransferTaskSuite(t *testing.T, store sqlplugin.HistoryTransferTask) *historyHistoryTransferTaskSuite
func NewHistoryTreeSuite(t *testing.T, store sqlplugin.HistoryTree) *historyTreeSuite
func NewHistoryVisibilityTaskSuite(t *testing.T, store sqlplugin.HistoryVisibilityTask) *historyHistoryVisibilityTaskSuite
func NewMatchingTaskQueueSuite(t *testing.T, store sqlplugin.MatchingTaskQueue, ...) *matchingTaskQueueSuite
func NewMatchingTaskSuite(t *testing.T, store sqlplugin.MatchingTask) *matchingTaskSuite
func NewMatchingTaskV2Suite(t *testing.T, store sqlplugin.MatchingTaskV2) *matchingTaskV2Suite
func NewNamespaceSuite(t *testing.T, store sqlplugin.DB) *namespaceSuite
func NewQueueMessageSuite(t *testing.T, store sqlplugin.QueueMessage) *queueMessageSuite
func NewQueueMetadataSuite(t *testing.T, store sqlplugin.QueueMetadata) *queueMetadataSuite
func NewVisibilitySuite(t *testing.T, store sqlplugin.Visibility) *visibilitySuite
func RunSQLQueueV2TestSuite(t *testing.T, baseDB sqlplugin.DB)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrGetLastMessageIdFailed = errors.New("getLastMessageId error")
	ErrTxBeginFailed          = errors.New("txBegin error")
	ErrInsertFailed           = errors.New("insert error")
	ErrTxRollbackFailed       = errors.New("txRollBack err")
	ErrTxCommitFailed         = errors.New("txCommit err")
	ErrRangeSelectFailed      = errors.New("rangeSelect err")
	ErrSelectMetadataFailed   = errors.New("selectFromMetadata err")
	ErrInsertMetadataFailed   = errors.New("insertMetadataFailed")
	ErrRangeDeleteFailed      = errors.New("rangeDeleteFailed")
	ErrUpdateMetadataFailed   = errors.New("updateMetadataFailed")
	ErrSelectQueueNames       = errors.New("selectQueueNamesFailed")
)

Functions ¶

func NewHistoryCurrentExecutionSuite ¶

func NewHistoryCurrentExecutionSuite(
	t *testing.T,
	store sqlplugin.HistoryExecution,
) *historyCurrentExecutionSuite

func NewHistoryExecutionActivitySuite ¶

func NewHistoryExecutionActivitySuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionActivity,
) *historyExecutionActivitySuite

func NewHistoryExecutionBufferSuite ¶

func NewHistoryExecutionBufferSuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionBuffer,
) *historyExecutionBufferSuite

func NewHistoryExecutionChasmSuite ¶ added in v1.28.0

func NewHistoryExecutionChasmSuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionChasm,
) *historyExecutionChasmSuite

func NewHistoryExecutionChildWorkflowSuite ¶

func NewHistoryExecutionChildWorkflowSuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionChildWorkflow,
) *historyExecutionChildWorkflowSuite

func NewHistoryExecutionRequestCancelSuite ¶

func NewHistoryExecutionRequestCancelSuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionRequestCancel,
) *historyExecutionRequestCancelSuite

func NewHistoryExecutionSignalRequestSuite ¶

func NewHistoryExecutionSignalRequestSuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionSignalRequest,
) *historyExecutionSignalRequestSuite

func NewHistoryExecutionSignalSuite ¶

func NewHistoryExecutionSignalSuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionSignal,
) *historyExecutionSignalSuite

func NewHistoryExecutionSuite ¶

func NewHistoryExecutionSuite(
	t *testing.T,
	store sqlplugin.DB,
) *historyExecutionSuite

func NewHistoryExecutionTimerSuite ¶

func NewHistoryExecutionTimerSuite(
	t *testing.T,
	store sqlplugin.HistoryExecutionTimer,
) *historyExecutionTimerSuite

func NewHistoryNodeSuite ¶

func NewHistoryNodeSuite(
	t *testing.T,
	store sqlplugin.HistoryNode,
) *historyNodeSuite

func NewHistoryReplicationDLQTaskSuite ¶

func NewHistoryReplicationDLQTaskSuite(
	t *testing.T,
	store sqlplugin.HistoryReplicationDLQTask,
) *historyHistoryReplicationDLQTaskSuite

func NewHistoryReplicationTaskSuite ¶

func NewHistoryReplicationTaskSuite(
	t *testing.T,
	store sqlplugin.HistoryReplicationTask,
) *historyHistoryReplicationTaskSuite

func NewHistoryShardSuite ¶

func NewHistoryShardSuite(
	t *testing.T,
	store sqlplugin.DB,
) *historyShardSuite

func NewHistoryTimerTaskSuite ¶

func NewHistoryTimerTaskSuite(
	t *testing.T,
	store sqlplugin.HistoryTimerTask,
) *historyHistoryTimerTaskSuite

func NewHistoryTransferTaskSuite ¶

func NewHistoryTransferTaskSuite(
	t *testing.T,
	store sqlplugin.HistoryTransferTask,
) *historyHistoryTransferTaskSuite

func NewHistoryTreeSuite ¶

func NewHistoryTreeSuite(
	t *testing.T,
	store sqlplugin.HistoryTree,
) *historyTreeSuite

func NewHistoryVisibilityTaskSuite ¶

func NewHistoryVisibilityTaskSuite(
	t *testing.T,
	store sqlplugin.HistoryVisibilityTask,
) *historyHistoryVisibilityTaskSuite

func NewMatchingTaskQueueSuite ¶

func NewMatchingTaskQueueSuite(
	t *testing.T,
	store sqlplugin.MatchingTaskQueue,
	version sqlplugin.MatchingTaskVersion,
) *matchingTaskQueueSuite

func NewMatchingTaskSuite ¶

func NewMatchingTaskSuite(
	t *testing.T,
	store sqlplugin.MatchingTask,
) *matchingTaskSuite

func NewMatchingTaskV2Suite ¶ added in v1.29.0

func NewMatchingTaskV2Suite(
	t *testing.T,
	store sqlplugin.MatchingTaskV2,
) *matchingTaskV2Suite

func NewNamespaceSuite ¶

func NewNamespaceSuite(
	t *testing.T,
	store sqlplugin.DB,
) *namespaceSuite

func NewQueueMessageSuite ¶

func NewQueueMessageSuite(
	t *testing.T,
	store sqlplugin.QueueMessage,
) *queueMessageSuite

func NewQueueMetadataSuite ¶

func NewQueueMetadataSuite(
	t *testing.T,
	store sqlplugin.QueueMetadata,
) *queueMetadataSuite

func NewVisibilitySuite ¶

func NewVisibilitySuite(
	t *testing.T,
	store sqlplugin.Visibility,
) *visibilitySuite

func RunSQLQueueV2TestSuite ¶ added in v1.23.0

func RunSQLQueueV2TestSuite(t *testing.T, baseDB sqlplugin.DB)

Types ¶