mocks

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 30, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ExecutionManager

+ func (_m *ExecutionManager) AddTasks(request *persistence.AddTasksRequest) error

+ func (_m *ExecutionManager) CompleteVisibilityTask(request *persistence.CompleteVisibilityTaskRequest) error

+ func (_m *ExecutionManager) GetVisibilityTask(request *persistence.GetVisibilityTaskRequest) (*persistence.GetVisibilityTaskResponse, error)

+ func (_m *ExecutionManager) GetVisibilityTasks(request *persistence.GetVisibilityTasksRequest) (*persistence.GetVisibilityTasksResponse, error)

+ func (_m *ExecutionManager) RangeCompleteVisibilityTask(request *persistence.RangeCompleteVisibilityTaskRequest) error

type VisibilityManager

+ func (_m *VisibilityManager) DeleteWorkflowExecutionV2(request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

+ func (_m *VisibilityManager) RecordWorkflowExecutionClosedV2(request *persistence.RecordWorkflowExecutionClosedRequest) error

+ func (_m *VisibilityManager) RecordWorkflowExecutionStartedV2(request *persistence.RecordWorkflowExecutionStartedRequest) error

+ func (_m *VisibilityManager) UpsertWorkflowExecutionV2(request *persistence.UpsertWorkflowExecutionRequest) error

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 10, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 9, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 16, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 11, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 27, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 14, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type MockClusterMetadataManager

+ func (m *MockClusterMetadataManager) GetClusterMetadata() (*persistence.GetClusterMetadataResponse, error)

+ func (m *MockClusterMetadataManager) SaveClusterMetadata(request *persistence.SaveClusterMetadataRequest) (bool, error)

type MockClusterMetadataManagerMockRecorder

+ func (mr *MockClusterMetadataManagerMockRecorder) GetClusterMetadata() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) SaveClusterMetadata(request interface{}) *gomock.Call

+ type MockExecutionManager struct

+ func NewMockExecutionManager(ctrl *gomock.Controller) *MockExecutionManager

+ func (m *MockExecutionManager) Close()

+ func (m *MockExecutionManager) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error

+ func (m *MockExecutionManager) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error

+ func (m *MockExecutionManager) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error

+ func (m *MockExecutionManager) ConflictResolveWorkflowExecution(request *persistence.ConflictResolveWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) CreateWorkflowExecution(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

+ func (m *MockExecutionManager) DeleteCurrentWorkflowExecution(request *persistence.DeleteCurrentWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) DeleteReplicationTaskFromDLQ(request *persistence.DeleteReplicationTaskFromDLQRequest) error

+ func (m *MockExecutionManager) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) EXPECT() *MockExecutionManagerMockRecorder

+ func (m *MockExecutionManager) GetCurrentExecution(request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)

+ func (m *MockExecutionManager) GetName() string

+ func (m *MockExecutionManager) GetReplicationTask(request *persistence.GetReplicationTaskRequest) (*persistence.GetReplicationTaskResponse, error)

+ func (m *MockExecutionManager) GetReplicationTasks(request *persistence.GetReplicationTasksRequest) (*persistence.GetReplicationTasksResponse, error)

+ func (m *MockExecutionManager) GetReplicationTasksFromDLQ(request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.GetReplicationTasksFromDLQResponse, error)

+ func (m *MockExecutionManager) GetShardID() int

+ func (m *MockExecutionManager) GetTimerIndexTasks(request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)

+ func (m *MockExecutionManager) GetTimerTask(request *persistence.GetTimerTaskRequest) (*persistence.GetTimerTaskResponse, error)

+ func (m *MockExecutionManager) GetTransferTask(request *persistence.GetTransferTaskRequest) (*persistence.GetTransferTaskResponse, error)

+ func (m *MockExecutionManager) GetTransferTasks(request *persistence.GetTransferTasksRequest) (*persistence.GetTransferTasksResponse, error)

+ func (m *MockExecutionManager) GetWorkflowExecution(request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)

+ func (m *MockExecutionManager) ListConcreteExecutions(request *persistence.ListConcreteExecutionsRequest) (*persistence.ListConcreteExecutionsResponse, error)

+ func (m *MockExecutionManager) PutReplicationTaskToDLQ(request *persistence.PutReplicationTaskToDLQRequest) error

+ func (m *MockExecutionManager) RangeCompleteReplicationTask(request *persistence.RangeCompleteReplicationTaskRequest) error

+ func (m *MockExecutionManager) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error

+ func (m *MockExecutionManager) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error

+ func (m *MockExecutionManager) RangeDeleteReplicationTaskFromDLQ(request *persistence.RangeDeleteReplicationTaskFromDLQRequest) error

+ func (m *MockExecutionManager) ResetWorkflowExecution(request *persistence.ResetWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) UpdateWorkflowExecution(request *persistence.UpdateWorkflowExecutionRequest) (*persistence.UpdateWorkflowExecutionResponse, error)

+ type MockExecutionManagerFactory struct

+ func NewMockExecutionManagerFactory(ctrl *gomock.Controller) *MockExecutionManagerFactory

+ func (m *MockExecutionManagerFactory) Close()

+ func (m *MockExecutionManagerFactory) EXPECT() *MockExecutionManagerFactoryMockRecorder

+ func (m *MockExecutionManagerFactory) NewExecutionManager(shardID int) (persistence.ExecutionManager, error)

+ type MockExecutionManagerFactoryMockRecorder struct

+ func (mr *MockExecutionManagerFactoryMockRecorder) Close() *gomock.Call

+ func (mr *MockExecutionManagerFactoryMockRecorder) NewExecutionManager(shardID interface{}) *gomock.Call

+ type MockExecutionManagerMockRecorder struct

+ func (mr *MockExecutionManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteReplicationTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteTimerTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteTransferTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ConflictResolveWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CreateWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) DeleteCurrentWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) DeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) DeleteWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetCurrentExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetReplicationTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetReplicationTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetReplicationTasksFromDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetShardID() *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTimerIndexTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTimerTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTransferTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTransferTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ListConcreteExecutions(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteReplicationTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteTimerTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteTransferTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeDeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ResetWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) UpdateWorkflowExecution(request interface{}) *gomock.Call

+ type MockHistoryManager struct

+ func NewMockHistoryManager(ctrl *gomock.Controller) *MockHistoryManager

+ func (m *MockHistoryManager) AppendHistoryNodes(request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)

+ func (m *MockHistoryManager) Close()

+ func (m *MockHistoryManager) DeleteHistoryBranch(request *persistence.DeleteHistoryBranchRequest) error

+ func (m *MockHistoryManager) EXPECT() *MockHistoryManagerMockRecorder

+ func (m *MockHistoryManager) ForkHistoryBranch(request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)

+ func (m *MockHistoryManager) GetAllHistoryTreeBranches(request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.GetAllHistoryTreeBranchesResponse, error)

+ func (m *MockHistoryManager) GetHistoryTree(request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)

+ func (m *MockHistoryManager) GetName() string

+ func (m *MockHistoryManager) ReadHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

+ func (m *MockHistoryManager) ReadHistoryBranchByBatch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)

+ func (m *MockHistoryManager) ReadRawHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadRawHistoryBranchResponse, error)

+ type MockHistoryManagerMockRecorder struct

+ func (mr *MockHistoryManagerMockRecorder) AppendHistoryNodes(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) DeleteHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ForkHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) GetAllHistoryTreeBranches(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) GetHistoryTree(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranchByBatch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ReadRawHistoryBranch(request interface{}) *gomock.Call

+ type MockMetadataManager struct

+ func NewMockMetadataManager(ctrl *gomock.Controller) *MockMetadataManager

+ func (m *MockMetadataManager) Close()

+ func (m *MockMetadataManager) CreateNamespace(request *persistence.CreateNamespaceRequest) (*persistence.CreateNamespaceResponse, error)

+ func (m *MockMetadataManager) DeleteNamespace(request *persistence.DeleteNamespaceRequest) error

+ func (m *MockMetadataManager) DeleteNamespaceByName(request *persistence.DeleteNamespaceByNameRequest) error

+ func (m *MockMetadataManager) EXPECT() *MockMetadataManagerMockRecorder

+ func (m *MockMetadataManager) GetMetadata() (*persistence.GetMetadataResponse, error)

+ func (m *MockMetadataManager) GetName() string

+ func (m *MockMetadataManager) GetNamespace(request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)

+ func (m *MockMetadataManager) InitializeSystemNamespaces(currentClusterName string) error

+ func (m *MockMetadataManager) ListNamespaces(request *persistence.ListNamespacesRequest) (*persistence.ListNamespacesResponse, error)

+ func (m *MockMetadataManager) UpdateNamespace(request *persistence.UpdateNamespaceRequest) error

+ type MockMetadataManagerMockRecorder struct

+ func (mr *MockMetadataManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) CreateNamespace(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) DeleteNamespace(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) DeleteNamespaceByName(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) GetMetadata() *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) GetNamespace(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) InitializeSystemNamespaces(currentClusterName interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) ListNamespaces(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) UpdateNamespace(request interface{}) *gomock.Call

+ type MockShardManager struct

+ func NewMockShardManager(ctrl *gomock.Controller) *MockShardManager

+ func (m *MockShardManager) Close()

+ func (m *MockShardManager) CreateShard(request *persistence.CreateShardRequest) error

+ func (m *MockShardManager) EXPECT() *MockShardManagerMockRecorder

+ func (m *MockShardManager) GetName() string

+ func (m *MockShardManager) GetShard(request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

+ func (m *MockShardManager) UpdateShard(request *persistence.UpdateShardRequest) error

+ type MockShardManagerMockRecorder struct

+ func (mr *MockShardManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockShardManagerMockRecorder) CreateShard(request interface{}) *gomock.Call

+ func (mr *MockShardManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockShardManagerMockRecorder) GetShard(request interface{}) *gomock.Call

+ func (mr *MockShardManagerMockRecorder) UpdateShard(request interface{}) *gomock.Call

+ type MockTask struct

+ func NewMockTask(ctrl *gomock.Controller) *MockTask

+ func (m *MockTask) EXPECT() *MockTaskMockRecorder

+ func (m *MockTask) GetTaskID() int64

+ func (m *MockTask) GetType() enums.TaskType

+ func (m *MockTask) GetVersion() int64

+ func (m *MockTask) GetVisibilityTimestamp() time.Time

+ func (m *MockTask) SetTaskID(id int64)

+ func (m *MockTask) SetVersion(version int64)

+ func (m *MockTask) SetVisibilityTimestamp(timestamp time.Time)

+ type MockTaskManager struct

+ func NewMockTaskManager(ctrl *gomock.Controller) *MockTaskManager

+ func (m *MockTaskManager) Close()

+ func (m *MockTaskManager) CompleteTask(request *persistence.CompleteTaskRequest) error

+ func (m *MockTaskManager) CompleteTasksLessThan(request *persistence.CompleteTasksLessThanRequest) (int, error)

+ func (m *MockTaskManager) CreateTasks(request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)

+ func (m *MockTaskManager) DeleteTaskQueue(request *persistence.DeleteTaskQueueRequest) error

+ func (m *MockTaskManager) EXPECT() *MockTaskManagerMockRecorder

+ func (m *MockTaskManager) GetName() string

+ func (m *MockTaskManager) GetTasks(request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)

+ func (m *MockTaskManager) LeaseTaskQueue(request *persistence.LeaseTaskQueueRequest) (*persistence.LeaseTaskQueueResponse, error)

+ func (m *MockTaskManager) ListTaskQueue(request *persistence.ListTaskQueueRequest) (*persistence.ListTaskQueueResponse, error)

+ func (m *MockTaskManager) UpdateTaskQueue(request *persistence.UpdateTaskQueueRequest) (*persistence.UpdateTaskQueueResponse, error)

+ type MockTaskManagerMockRecorder struct

+ func (mr *MockTaskManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) CompleteTask(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) CompleteTasksLessThan(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) CreateTasks(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) DeleteTaskQueue(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) GetTasks(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) LeaseTaskQueue(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) ListTaskQueue(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) UpdateTaskQueue(request interface{}) *gomock.Call

+ type MockTaskMockRecorder struct

+ func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call

+ func (mr *MockTaskMockRecorder) GetType() *gomock.Call

+ func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call

+ func (mr *MockTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call

+ func (mr *MockTaskMockRecorder) SetTaskID(id interface{}) *gomock.Call

+ func (mr *MockTaskMockRecorder) SetVersion(version interface{}) *gomock.Call

+ func (mr *MockTaskMockRecorder) SetVisibilityTimestamp(timestamp interface{}) *gomock.Call

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 28, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 17, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 31, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 15, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ClusterMetadata

+ func (_m *ClusterMetadata) GetReplicationConsumerConfig() *config.ReplicationConsumerConfig

+ func (_m *ClusterMetadata) IsGlobalNamespaceEnabled() bool

type ExecutionManager

+ func (_m *ExecutionManager) DeleteReplicationTaskFromDLQ(request *persistence.DeleteReplicationTaskFromDLQRequest) error

+ func (_m *ExecutionManager) GetReplicationTask(request *persistence.GetReplicationTaskRequest) (*persistence.GetReplicationTaskResponse, error)

+ func (_m *ExecutionManager) GetReplicationTasksFromDLQ(request *persistence.GetReplicationTasksFromDLQRequest) (*persistence.GetReplicationTasksFromDLQResponse, error)

+ func (_m *ExecutionManager) GetTimerTask(request *persistence.GetTimerTaskRequest) (*persistence.GetTimerTaskResponse, error)

+ func (_m *ExecutionManager) GetTransferTask(request *persistence.GetTransferTaskRequest) (*persistence.GetTransferTaskResponse, error)

+ func (_m *ExecutionManager) ListConcreteExecutions(request *persistence.ListConcreteExecutionsRequest) (*persistence.ListConcreteExecutionsResponse, error)

+ func (_m *ExecutionManager) PutReplicationTaskToDLQ(request *persistence.PutReplicationTaskToDLQRequest) error

+ func (_m *ExecutionManager) RangeCompleteReplicationTask(request *persistence.RangeCompleteReplicationTaskRequest) error

+ func (_m *ExecutionManager) RangeDeleteReplicationTaskFromDLQ(request *persistence.RangeDeleteReplicationTaskFromDLQRequest) error

type HistoryV2Manager

+ func (_m *HistoryV2Manager) GetAllHistoryTreeBranches(request *persistence.GetAllHistoryTreeBranchesRequest) (*persistence.GetAllHistoryTreeBranchesResponse, error)

+ func (_m *HistoryV2Manager) ReadRawHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadRawHistoryBranchResponse, error)

type MetadataManager

+ func (_m *MetadataManager) CreateNamespace(request *persistence.CreateNamespaceRequest) (*persistence.CreateNamespaceResponse, error)

+ func (_m *MetadataManager) DeleteNamespace(request *persistence.DeleteNamespaceRequest) error

+ func (_m *MetadataManager) DeleteNamespaceByName(request *persistence.DeleteNamespaceByNameRequest) error

+ func (_m *MetadataManager) GetNamespace(request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)

+ func (_m *MetadataManager) InitializeSystemNamespaces(currentClusterName string) error

+ func (_m *MetadataManager) ListNamespaces(request *persistence.ListNamespacesRequest) (*persistence.ListNamespacesResponse, error)

+ func (_m *MetadataManager) UpdateNamespace(request *persistence.UpdateNamespaceRequest) error

+ type MockCloseable struct

+ func NewMockCloseable(ctrl *gomock.Controller) *MockCloseable

+ func (m *MockCloseable) Close()

+ func (m *MockCloseable) EXPECT() *MockCloseableMockRecorder

+ type MockCloseableMockRecorder struct

+ func (mr *MockCloseableMockRecorder) Close() *gomock.Call

+ type MockClusterMetadataManager struct

+ func NewMockClusterMetadataManager(ctrl *gomock.Controller) *MockClusterMetadataManager

+ func (m *MockClusterMetadataManager) Close()

+ func (m *MockClusterMetadataManager) EXPECT() *MockClusterMetadataManagerMockRecorder

+ func (m *MockClusterMetadataManager) GetClusterMembers(request *persistence.GetClusterMembersRequest) (*persistence.GetClusterMembersResponse, error)

+ func (m *MockClusterMetadataManager) GetImmutableClusterMetadata() (*persistence.GetImmutableClusterMetadataResponse, error)

+ func (m *MockClusterMetadataManager) GetName() string

+ func (m *MockClusterMetadataManager) InitializeImmutableClusterMetadata(request *persistence.InitializeImmutableClusterMetadataRequest) (*persistence.InitializeImmutableClusterMetadataResponse, error)

+ func (m *MockClusterMetadataManager) PruneClusterMembership(request *persistence.PruneClusterMembershipRequest) error

+ func (m *MockClusterMetadataManager) UpsertClusterMembership(request *persistence.UpsertClusterMembershipRequest) error

+ type MockClusterMetadataManagerMockRecorder struct

+ func (mr *MockClusterMetadataManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetClusterMembers(request interface{}) *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetImmutableClusterMetadata() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) InitializeImmutableClusterMetadata(request interface{}) *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) PruneClusterMembership(request interface{}) *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) UpsertClusterMembership(request interface{}) *gomock.Call

type TaskManager

+ func (_m *TaskManager) DeleteTaskQueue(request *persistence.DeleteTaskQueueRequest) error

+ func (_m *TaskManager) LeaseTaskQueue(request *persistence.LeaseTaskQueueRequest) (*persistence.LeaseTaskQueueResponse, error)

+ func (_m *TaskManager) ListTaskQueue(request *persistence.ListTaskQueueRequest) (*persistence.ListTaskQueueResponse, error)

+ func (_m *TaskManager) UpdateTaskQueue(request *persistence.UpdateTaskQueueRequest) (*persistence.UpdateTaskQueueResponse, error)

Aug 27, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 27, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 26, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 13, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 12, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 12, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 8, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 8, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 6, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 30, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ExecutionManager

+ func (_m *ExecutionManager) ConflictResolveWorkflowExecution(request *persistence.ConflictResolveWorkflowExecutionRequest) error

Jul 26, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 24, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type AdminClient

+ func (_m *AdminClient) AddSearchAttribute(ctx context.Context, Request *admin.AddSearchAttributeRequest, ...) error

type VisibilityManager

+ func (_m *VisibilityManager) UpsertWorkflowExecution(request *persistence.UpsertWorkflowExecutionRequest) error

Jun 17, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type FrontendClient

+ func (_m *FrontendClient) GetSearchAttributes(ctx context.Context, opts ...yarpc.CallOption) (*shared.GetSearchAttributesResponse, error)

May 14, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ClusterMetadata

+ func (_m *ClusterMetadata) GetAllClusterInfo() map[string]config.ClusterInformation

type ExecutionManager

+ func (_m *ExecutionManager) DeleteCurrentWorkflowExecution(request *persistence.DeleteCurrentWorkflowExecutionRequest) error

type FrontendClient

+ func (_m *FrontendClient) CountWorkflowExecutions(ctx context.Context, CountRequest *shared.CountWorkflowExecutionsRequest, ...) (*shared.CountWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) ScanWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest, ...) (*shared.ListWorkflowExecutionsResponse, error)

type VisibilityManager

+ func (_m *VisibilityManager) CountWorkflowExecutions(request *persistence.CountWorkflowExecutionsRequest) (*persistence.CountWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ScanWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

May 8, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type BlobstoreClient

+ func (_m *BlobstoreClient) BucketExists(ctx context.Context, bucket string) (bool, error)

+ func (_m *BlobstoreClient) GetRetryPolicy() backoff.RetryPolicy

+ func (_m *BlobstoreClient) GetTags(ctx context.Context, bucket string, key blob.Key) (map[string]string, error)

+ func (_m *BlobstoreClient) IsRetryableError(err error) bool

type FrontendClient

+ func (_m *FrontendClient) ListWorkflowExecutions(ctx context.Context, ListRequest *shared.ListWorkflowExecutionsRequest, ...) (*shared.ListWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) ResetWorkflowExecution(ctx context.Context, ResetRequest *shared.ResetWorkflowExecutionRequest, ...) (*shared.ResetWorkflowExecutionResponse, error)

type TaskManager

+ func (_m *TaskManager) CompleteTasksLessThan(request *persistence.CompleteTasksLessThanRequest) (int, error)

+ func (_m *TaskManager) DeleteTaskList(request *persistence.DeleteTaskListRequest) error

+ func (_m *TaskManager) ListTaskList(request *persistence.ListTaskListRequest) (*persistence.ListTaskListResponse, error)

type VisibilityManager

+ func (_m *VisibilityManager) DeleteWorkflowExecution(request *persistence.VisibilityDeleteWorkflowExecutionRequest) error

+ func (_m *VisibilityManager) ListWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequestV2) (*persistence.ListWorkflowExecutionsResponse, error)

Mar 12, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 8, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ClusterMetadata

+ func (_m *ClusterMetadata) ArchivalConfig() *cluster.ArchivalConfig

Feb 19, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 12, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type BlobstoreClient struct

+ func (_m *BlobstoreClient) BucketMetadata(ctx context.Context, bucket string) (*blobstore.BucketMetadataResponse, error)

+ func (_m *BlobstoreClient) Delete(ctx context.Context, bucket string, key blob.Key) (bool, error)

+ func (_m *BlobstoreClient) Download(ctx context.Context, bucket string, key blob.Key) (*blob.Blob, error)

+ func (_m *BlobstoreClient) Exists(ctx context.Context, bucket string, key blob.Key) (bool, error)

+ func (_m *BlobstoreClient) ListByPrefix(ctx context.Context, bucket string, prefix string) ([]blob.Key, error)

+ func (_m *BlobstoreClient) Upload(ctx context.Context, bucket string, key blob.Key, _a3 *blob.Blob) error

type ExecutionManager

+ func (_m *ExecutionManager) ResetWorkflowExecution(request *persistence.ResetWorkflowExecutionRequest) error

type HistoryClient

+ func (_m *HistoryClient) ResetWorkflowExecution(ctx context.Context, resetRequest *history.ResetWorkflowExecutionRequest, ...) (*shared.ResetWorkflowExecutionResponse, error)

type HistoryV2Manager

+ func (_m *HistoryV2Manager) CompleteForkBranch(request *persistence.CompleteForkBranchRequest) error

type MessagingClient

+ func (c *MessagingClient) NewConsumerWithClusterName(currentCluster, sourceCluster, consumerName string, concurrency int) (messaging.Consumer, error)

Jan 18, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 7, 2019 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type AdminClient struct

+ func (_m *AdminClient) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest, ...) (*shared.DescribeHistoryHostResponse, error)

+ func (_m *AdminClient) DescribeWorkflowExecution(ctx context.Context, request *admin.DescribeWorkflowExecutionRequest, ...) (*admin.DescribeWorkflowExecutionResponse, error)

+ func (_m *AdminClient) GetWorkflowExecutionRawHistory(ctx context.Context, request *admin.GetWorkflowExecutionRawHistoryRequest, ...) (*admin.GetWorkflowExecutionRawHistoryResponse, error)

+ type ArchivalClient struct

+ func (_m *ArchivalClient) Archive(_a0 *sysworkflow.ArchiveRequest) error

+ func (_m *ArchivalClient) Backfill(_a0 *sysworkflow.BackfillRequest) error

+ type Client struct

+ func (_m *Client) BucketMetadata(ctx context.Context, bucket string) (*blobstore.BucketMetadataResponse, error)

+ func (_m *Client) DownloadBlob(ctx context.Context, bucket string, path string) (*blobstore.Blob, error)

+ func (_m *Client) UploadBlob(ctx context.Context, bucket string, path string, blob *blobstore.Blob) error

type ClusterMetadata

+ func (_m *ClusterMetadata) GetAllClientAddress() map[string]config.Address

+ func (_m *ClusterMetadata) GetDefaultArchivalBucket() string

+ func (_m *ClusterMetadata) GetDeploymentGroup() string

+ func (_m *ClusterMetadata) IsArchivalEnabled() bool

type ExecutionManager

+ func (_m *ExecutionManager) GetShardID() int

+ type FrontendClient struct

+ func (_m *FrontendClient) DeprecateDomain(ctx context.Context, request *shared.DeprecateDomainRequest, ...) error

+ func (_m *FrontendClient) DescribeDomain(ctx context.Context, request *shared.DescribeDomainRequest, ...) (*shared.DescribeDomainResponse, error)

+ func (_m *FrontendClient) DescribeTaskList(ctx context.Context, request *shared.DescribeTaskListRequest, ...) (*shared.DescribeTaskListResponse, error)

+ func (_m *FrontendClient) DescribeWorkflowExecution(ctx context.Context, request *shared.DescribeWorkflowExecutionRequest, ...) (*shared.DescribeWorkflowExecutionResponse, error)

+ func (_m *FrontendClient) GetWorkflowExecutionHistory(ctx context.Context, request *shared.GetWorkflowExecutionHistoryRequest, ...) (*shared.GetWorkflowExecutionHistoryResponse, error)

+ func (_m *FrontendClient) ListClosedWorkflowExecutions(ctx context.Context, request *shared.ListClosedWorkflowExecutionsRequest, ...) (*shared.ListClosedWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) ListDomains(ctx context.Context, request *shared.ListDomainsRequest, ...) (*shared.ListDomainsResponse, error)

+ func (_m *FrontendClient) ListOpenWorkflowExecutions(ctx context.Context, request *shared.ListOpenWorkflowExecutionsRequest, ...) (*shared.ListOpenWorkflowExecutionsResponse, error)

+ func (_m *FrontendClient) PollForActivityTask(ctx context.Context, request *shared.PollForActivityTaskRequest, ...) (*shared.PollForActivityTaskResponse, error)

+ func (_m *FrontendClient) PollForDecisionTask(ctx context.Context, request *shared.PollForDecisionTaskRequest, ...) (*shared.PollForDecisionTaskResponse, error)

+ func (_m *FrontendClient) QueryWorkflow(ctx context.Context, request *shared.QueryWorkflowRequest, ...) (*shared.QueryWorkflowResponse, error)

+ func (_m *FrontendClient) RecordActivityTaskHeartbeat(ctx context.Context, request *shared.RecordActivityTaskHeartbeatRequest, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)

+ func (_m *FrontendClient) RecordActivityTaskHeartbeatByID(ctx context.Context, request *shared.RecordActivityTaskHeartbeatByIDRequest, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)

+ func (_m *FrontendClient) RegisterDomain(ctx context.Context, request *shared.RegisterDomainRequest, ...) error

+ func (_m *FrontendClient) RequestCancelWorkflowExecution(ctx context.Context, request *shared.RequestCancelWorkflowExecutionRequest, ...) error

+ func (_m *FrontendClient) ResetStickyTaskList(ctx context.Context, request *shared.ResetStickyTaskListRequest, ...) (*shared.ResetStickyTaskListResponse, error)

+ func (_m *FrontendClient) RespondActivityTaskCanceled(ctx context.Context, request *shared.RespondActivityTaskCanceledRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskCanceledByID(ctx context.Context, request *shared.RespondActivityTaskCanceledByIDRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskCompleted(ctx context.Context, request *shared.RespondActivityTaskCompletedRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskCompletedByID(ctx context.Context, request *shared.RespondActivityTaskCompletedByIDRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskFailed(ctx context.Context, request *shared.RespondActivityTaskFailedRequest, ...) error

+ func (_m *FrontendClient) RespondActivityTaskFailedByID(ctx context.Context, request *shared.RespondActivityTaskFailedByIDRequest, ...) error

+ func (_m *FrontendClient) RespondDecisionTaskCompleted(ctx context.Context, request *shared.RespondDecisionTaskCompletedRequest, ...) (*shared.RespondDecisionTaskCompletedResponse, error)

+ func (_m *FrontendClient) RespondDecisionTaskFailed(ctx context.Context, request *shared.RespondDecisionTaskFailedRequest, ...) error

+ func (_m *FrontendClient) RespondQueryTaskCompleted(ctx context.Context, request *shared.RespondQueryTaskCompletedRequest, ...) error

+ func (_m *FrontendClient) SignalWithStartWorkflowExecution(ctx context.Context, request *shared.SignalWithStartWorkflowExecutionRequest, ...) (*shared.StartWorkflowExecutionResponse, error)

+ func (_m *FrontendClient) SignalWorkflowExecution(ctx context.Context, request *shared.SignalWorkflowExecutionRequest, ...) error

+ func (_m *FrontendClient) StartWorkflowExecution(ctx context.Context, request *shared.StartWorkflowExecutionRequest, ...) (*shared.StartWorkflowExecutionResponse, error)

+ func (_m *FrontendClient) TerminateWorkflowExecution(ctx context.Context, request *shared.TerminateWorkflowExecutionRequest, ...) error

+ func (_m *FrontendClient) UpdateDomain(ctx context.Context, request *shared.UpdateDomainRequest, ...) (*shared.UpdateDomainResponse, error)

type HistoryClient

+ func (_m *HistoryClient) ReplicateRawEvents(ctx context.Context, request *history.ReplicateRawEventsRequest, ...) error

type HistoryManager

+ func (_m *HistoryManager) GetWorkflowExecutionHistoryByBatch(request *persistence.GetWorkflowExecutionHistoryRequest) (*persistence.GetWorkflowExecutionHistoryByBatchResponse, error)

+ type HistoryV2Manager struct

+ func (_m *HistoryV2Manager) AppendHistoryNodes(request *persistence.AppendHistoryNodesRequest) (*persistence.AppendHistoryNodesResponse, error)

+ func (_m *HistoryV2Manager) Close()

+ func (_m *HistoryV2Manager) DeleteHistoryBranch(request *persistence.DeleteHistoryBranchRequest) error

+ func (_m *HistoryV2Manager) ForkHistoryBranch(request *persistence.ForkHistoryBranchRequest) (*persistence.ForkHistoryBranchResponse, error)

+ func (_m *HistoryV2Manager) GetHistoryTree(request *persistence.GetHistoryTreeRequest) (*persistence.GetHistoryTreeResponse, error)

+ func (_m *HistoryV2Manager) GetName() string

+ func (_m *HistoryV2Manager) ReadHistoryBranch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchResponse, error)

+ func (_m *HistoryV2Manager) ReadHistoryBranchByBatch(request *persistence.ReadHistoryBranchRequest) (*persistence.ReadHistoryBranchByBatchResponse, error)

type MessagingClient

+ func (c *MessagingClient) NewProducerWithClusterName(sourceCluster string) (messaging.Producer, error)

Oct 19, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ExecutionManager

+ func (_m *ExecutionManager) GetName() string

+ func (_m *ExecutionManager) RangeCompleteTimerTask(request *persistence.RangeCompleteTimerTaskRequest) error

+ func (_m *ExecutionManager) RangeCompleteTransferTask(request *persistence.RangeCompleteTransferTaskRequest) error

type ExecutionManagerFactory

+ func (_m *ExecutionManagerFactory) NewExecutionManager(shardID int) (persistence.ExecutionManager, error)

type HistoryClient

+ func (_m *HistoryClient) SyncActivity(ctx context.Context, request *history.SyncActivityRequest, ...) error

type HistoryManager

+ func (_m *HistoryManager) GetName() string

type MetadataManager

+ func (_m *MetadataManager) GetName() string

type ShardManager

+ func (_m *ShardManager) GetName() string

type TaskManager

+ func (_m *TaskManager) GetName() string

type VisibilityManager

+ func (_m *VisibilityManager) GetName() string

Jul 26, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 24, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ClusterMetadata

+ func (_m *ClusterMetadata) IsVersionFromSameCluster(_a0 int64, _a1 int64) bool

type HistoryClient

+ func (_m *HistoryClient) SyncShardStatus(ctx context.Context, request *history.SyncShardStatusRequest, ...) error

type MetadataManager

+ func (_m *MetadataManager) ListDomains(request *persistence.ListDomainsRequest) (*persistence.ListDomainsResponse, error)

Jun 9, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryClient

+ func (_m *HistoryClient) DescribeHistoryHost(ctx context.Context, request *shared.DescribeHistoryHostRequest, ...) (*shared.DescribeHistoryHostResponse, error)

+ func (_m *HistoryClient) DescribeMutableState(ctx context.Context, request *history.DescribeMutableStateRequest, ...) (*history.DescribeMutableStateResponse, error)

type MetadataManager

+ func (_m *MetadataManager) GetMetadata() (*persistence.GetMetadataResponse, error)

+ func (_m *MetadataManager) ListDomain(request *persistence.ListDomainRequest) (*persistence.ListDomainResponse, error)

May 26, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ExecutionManager

+ func (_m *ExecutionManager) ResetMutableState(request *persistence.ResetMutableStateRequest) error

Apr 16, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ func NewMockMessagingClient(publisher messaging.Producer, consumer kafka.Consumer) messaging.Client

+ type ClusterMetadata struct

+ func (_m *ClusterMetadata) ClusterNameForFailoverVersion(failoverVersion int64) string

+ func (_m *ClusterMetadata) GetAllClusterFailoverVersions() map[string]int64

+ func (_m *ClusterMetadata) GetCurrentClusterName() string

+ func (_m *ClusterMetadata) GetMasterClusterName() string

+ func (_m *ClusterMetadata) GetNextFailoverVersion(_a0 int64) int64

+ func (_m *ClusterMetadata) IsGlobalDomainEnabled() bool

+ func (_m *ClusterMetadata) IsMasterCluster() bool

type ExecutionManager

+ func (_m *ExecutionManager) CompleteReplicationTask(request *persistence.CompleteReplicationTaskRequest) error

+ func (_m *ExecutionManager) GetReplicationTasks(request *persistence.GetReplicationTasksRequest) (*persistence.GetReplicationTasksResponse, error)

type HistoryClient

+ func (_m *HistoryClient) ReplicateEvents(ctx context.Context, request *history.ReplicateEventsRequest, ...) error

+ func (_m *HistoryClient) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*shared.StartWorkflowExecutionResponse, error)

+ type MessagingClient struct

+ func (c *MessagingClient) NewConsumer(topicName, consumerName string, concurrency int) (kafka.Consumer, error)

+ func (c *MessagingClient) NewProducer(topicName string) (messaging.Producer, error)

Apr 10, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 14, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 13, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 12, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryClient

+ func (_m *HistoryClient) ResetStickyTaskList(ctx context.Context, request *history.ResetStickyTaskListRequest, ...) (*history.ResetStickyTaskListResponse, error)

+ type KafkaProducer struct

+ func (_m *KafkaProducer) Close() error

+ func (_m *KafkaProducer) Publish(msg *replicator.ReplicationTask) error

+ func (_m *KafkaProducer) PublishBatch(msgs []*replicator.ReplicationTask) error

Jan 30, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryClient

+ func (_m *HistoryClient) RemoveSignalMutableState(ctx context.Context, removeRequest *history.RemoveSignalMutableStateRequest, ...) error

Jan 12, 2018 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryClient

+ func (_m *HistoryClient) GetMutableState(ctx context.Context, getRequest *history.GetMutableStateRequest, ...) (*history.GetMutableStateResponse, error)

type MatchingClient

+ func (_m *MatchingClient) DescribeTaskList(ctx context.Context, request *matching.DescribeTaskListRequest, ...) (*shared.DescribeTaskListResponse, error)

Dec 12, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 5, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type HistoryClient

+ func (_m *HistoryClient) DescribeWorkflowExecution(ctx context.Context, request *history.DescribeWorkflowExecutionRequest, ...) (*shared.DescribeWorkflowExecutionResponse, error)

+ func (_m *HistoryClient) RespondDecisionTaskFailed(ctx context.Context, failedRequest *history.RespondDecisionTaskFailedRequest, ...) error

Sep 29, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type ExecutionManagerFactory

+ func (_m *ExecutionManagerFactory) Close()

type MatchingClient

+ func (_m *MatchingClient) CancelOutstandingPoll(ctx context.Context, request *matching.CancelOutstandingPollRequest, ...) error

+ func (_m *MatchingClient) QueryWorkflow(ctx context.Context, queryRequest *matching.QueryWorkflowRequest, ...) (*shared.QueryWorkflowResponse, error)

+ func (_m *MatchingClient) RespondQueryTaskCompleted(ctx context.Context, request *matching.RespondQueryTaskCompletedRequest, ...) error

Aug 15, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 7, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 30, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type ExecutionManager struct

+ func (_m *ExecutionManager) Close()

+ func (_m *ExecutionManager) CompleteTimerTask(request *persistence.CompleteTimerTaskRequest) error

+ func (_m *ExecutionManager) CompleteTransferTask(request *persistence.CompleteTransferTaskRequest) error

+ func (_m *ExecutionManager) CreateWorkflowExecution(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

+ func (_m *ExecutionManager) DeleteWorkflowExecution(request *persistence.DeleteWorkflowExecutionRequest) error

+ func (_m *ExecutionManager) GetCurrentExecution(request *persistence.GetCurrentExecutionRequest) (*persistence.GetCurrentExecutionResponse, error)

+ func (_m *ExecutionManager) GetTimerIndexTasks(request *persistence.GetTimerIndexTasksRequest) (*persistence.GetTimerIndexTasksResponse, error)

+ func (_m *ExecutionManager) GetTransferTasks(request *persistence.GetTransferTasksRequest) (*persistence.GetTransferTasksResponse, error)

+ func (_m *ExecutionManager) GetWorkflowExecution(request *persistence.GetWorkflowExecutionRequest) (*persistence.GetWorkflowExecutionResponse, error)

+ func (_m *ExecutionManager) UpdateWorkflowExecution(request *persistence.UpdateWorkflowExecutionRequest) error

+ type ExecutionManagerFactory struct

+ func (_m *ExecutionManagerFactory) CreateExecutionManager(shardID int) (persistence.ExecutionManager, error)

+ type HistoryClient struct

+ func (_m *HistoryClient) GetWorkflowExecutionNextEventID(ctx thrift.Context, getRequest *history.GetWorkflowExecutionNextEventIDRequest) (*history.GetWorkflowExecutionNextEventIDResponse, error)

+ func (_m *HistoryClient) RecordActivityTaskHeartbeat(ctx thrift.Context, ...) (*shared.RecordActivityTaskHeartbeatResponse, error)

+ func (_m *HistoryClient) RecordActivityTaskStarted(ctx thrift.Context, addRequest *history.RecordActivityTaskStartedRequest) (*history.RecordActivityTaskStartedResponse, error)

+ func (_m *HistoryClient) RecordChildExecutionCompleted(ctx thrift.Context, request *history.RecordChildExecutionCompletedRequest) error

+ func (_m *HistoryClient) RecordDecisionTaskStarted(ctx thrift.Context, addRequest *history.RecordDecisionTaskStartedRequest) (*history.RecordDecisionTaskStartedResponse, error)

+ func (_m *HistoryClient) RequestCancelWorkflowExecution(ctx thrift.Context, request *history.RequestCancelWorkflowExecutionRequest) error

+ func (_m *HistoryClient) RespondActivityTaskCanceled(ctx thrift.Context, ...) error

+ func (_m *HistoryClient) RespondActivityTaskCompleted(ctx thrift.Context, ...) error

+ func (_m *HistoryClient) RespondActivityTaskFailed(ctx thrift.Context, failRequest *history.RespondActivityTaskFailedRequest) error

+ func (_m *HistoryClient) RespondDecisionTaskCompleted(ctx thrift.Context, ...) error

+ func (_m *HistoryClient) ScheduleDecisionTask(ctx thrift.Context, request *history.ScheduleDecisionTaskRequest) error

+ func (_m *HistoryClient) SignalWorkflowExecution(ctx thrift.Context, signalRequest *history.SignalWorkflowExecutionRequest) error

+ func (_m *HistoryClient) StartWorkflowExecution(ctx thrift.Context, startRequest *history.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

+ func (_m *HistoryClient) TerminateWorkflowExecution(ctx thrift.Context, ...) error

+ type HistoryManager struct

+ func (_m *HistoryManager) AppendHistoryEvents(request *persistence.AppendHistoryEventsRequest) error

+ func (_m *HistoryManager) Close()

+ func (_m *HistoryManager) DeleteWorkflowExecutionHistory(request *persistence.DeleteWorkflowExecutionHistoryRequest) error

+ func (_m *HistoryManager) GetWorkflowExecutionHistory(request *persistence.GetWorkflowExecutionHistoryRequest) (*persistence.GetWorkflowExecutionHistoryResponse, error)

+ type MatchingClient struct

+ func (_m *MatchingClient) AddActivityTask(ctx thrift.Context, addRequest *matching.AddActivityTaskRequest) error

+ func (_m *MatchingClient) AddDecisionTask(ctx thrift.Context, addRequest *matching.AddDecisionTaskRequest) error

+ func (_m *MatchingClient) PollForActivityTask(ctx thrift.Context, pollRequest *matching.PollForActivityTaskRequest) (*shared.PollForActivityTaskResponse, error)

+ func (_m *MatchingClient) PollForDecisionTask(ctx thrift.Context, pollRequest *matching.PollForDecisionTaskRequest) (*matching.PollForDecisionTaskResponse, error)

+ type MetadataManager struct

+ func (_m *MetadataManager) Close()

+ func (_m *MetadataManager) CreateDomain(request *persistence.CreateDomainRequest) (*persistence.CreateDomainResponse, error)

+ func (_m *MetadataManager) DeleteDomain(request *persistence.DeleteDomainRequest) error

+ func (_m *MetadataManager) DeleteDomainByName(request *persistence.DeleteDomainByNameRequest) error

+ func (_m *MetadataManager) GetDomain(request *persistence.GetDomainRequest) (*persistence.GetDomainResponse, error)

+ func (_m *MetadataManager) UpdateDomain(request *persistence.UpdateDomainRequest) error

+ type ServiceResolver struct

+ func (_m *ServiceResolver) AddListener(name string, notifyChannel chan<- *membership.ChangedEvent) error

+ func (_m *ServiceResolver) Lookup(key string) (*membership.HostInfo, error)

+ func (_m *ServiceResolver) RemoveListener(name string) error

+ type ShardManager struct

+ func (_m *ShardManager) Close()

+ func (_m *ShardManager) CreateShard(request *persistence.CreateShardRequest) error

+ func (_m *ShardManager) GetShard(request *persistence.GetShardRequest) (*persistence.GetShardResponse, error)

+ func (_m *ShardManager) UpdateShard(request *persistence.UpdateShardRequest) error

+ type TaskManager struct

+ func (_m *TaskManager) Close()

+ func (_m *TaskManager) CompleteTask(request *persistence.CompleteTaskRequest) error

+ func (_m *TaskManager) CreateTasks(request *persistence.CreateTasksRequest) (*persistence.CreateTasksResponse, error)

+ func (_m *TaskManager) GetTasks(request *persistence.GetTasksRequest) (*persistence.GetTasksResponse, error)

+ func (_m *TaskManager) LeaseTaskList(request *persistence.LeaseTaskListRequest) (*persistence.LeaseTaskListResponse, error)

+ func (_m *TaskManager) UpdateTaskList(request *persistence.UpdateTaskListRequest) (*persistence.UpdateTaskListResponse, error)

+ type VisibilityManager struct

+ func (_m *VisibilityManager) Close()

+ func (_m *VisibilityManager) GetClosedWorkflowExecution(request *persistence.GetClosedWorkflowExecutionRequest) (*persistence.GetClosedWorkflowExecutionResponse, error)

+ func (_m *VisibilityManager) ListClosedWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ListClosedWorkflowExecutionsByStatus(request *persistence.ListClosedWorkflowExecutionsByStatusRequest) (*persistence.ListWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ListClosedWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ListOpenWorkflowExecutions(request *persistence.ListWorkflowExecutionsRequest) (*persistence.ListWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ListOpenWorkflowExecutionsByType(request *persistence.ListWorkflowExecutionsByTypeRequest) (*persistence.ListWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(request *persistence.ListWorkflowExecutionsByWorkflowIDRequest) (*persistence.ListWorkflowExecutionsResponse, error)

+ func (_m *VisibilityManager) RecordWorkflowExecutionClosed(request *persistence.RecordWorkflowExecutionClosedRequest) error

+ func (_m *VisibilityManager) RecordWorkflowExecutionStarted(request *persistence.RecordWorkflowExecutionStartedRequest) error

Jun 7, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 6, 2017 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server