Documentation
¶
Overview ¶
Package deletemanager is a generated GoMock package.
Index ¶
- type DeleteManager
- type DeleteManagerImpl
- func (m *DeleteManagerImpl) AddDeleteWorkflowExecutionTask(ctx context.Context, nsID namespace.ID, we *commonpb.WorkflowExecution, ...) error
- func (m *DeleteManagerImpl) DeleteWorkflowExecution(ctx context.Context, nsID namespace.ID, we *commonpb.WorkflowExecution, ...) error
- func (m *DeleteManagerImpl) DeleteWorkflowExecutionByRetention(ctx context.Context, nsID namespace.ID, we *commonpb.WorkflowExecution, ...) error
- type MockDeleteManager
- func (m *MockDeleteManager) AddDeleteWorkflowExecutionTask(ctx context.Context, nsID namespace.ID, we *common.WorkflowExecution, ...) error
- func (m *MockDeleteManager) DeleteWorkflowExecution(ctx context.Context, nsID namespace.ID, we *common.WorkflowExecution, ...) error
- func (m *MockDeleteManager) DeleteWorkflowExecutionByRetention(ctx context.Context, nsID namespace.ID, we *common.WorkflowExecution, ...) error
- func (m *MockDeleteManager) EXPECT() *MockDeleteManagerMockRecorder
- type MockDeleteManagerMockRecorder
- func (mr *MockDeleteManagerMockRecorder) AddDeleteWorkflowExecutionTask(ctx, nsID, we, ms, workflowClosedVersion interface{}) *gomock.Call
- func (mr *MockDeleteManagerMockRecorder) DeleteWorkflowExecution(ctx, nsID, we, weCtx, ms, forceDeleteFromOpenVisibility, stage interface{}) *gomock.Call
- func (mr *MockDeleteManagerMockRecorder) DeleteWorkflowExecutionByRetention(ctx, nsID, we, weCtx, ms, stage interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeleteManager ¶
type DeleteManager interface {
AddDeleteWorkflowExecutionTask(
ctx context.Context,
nsID namespace.ID,
we *commonpb.WorkflowExecution,
ms workflow.MutableState,
workflowClosedVersion int64,
) error
DeleteWorkflowExecution(
ctx context.Context,
nsID namespace.ID,
we *commonpb.WorkflowExecution,
weCtx workflow.Context,
ms workflow.MutableState,
forceDeleteFromOpenVisibility bool,
stage *tasks.DeleteWorkflowExecutionStage,
) error
DeleteWorkflowExecutionByRetention(
ctx context.Context,
nsID namespace.ID,
we *commonpb.WorkflowExecution,
weCtx workflow.Context,
ms workflow.MutableState,
stage *tasks.DeleteWorkflowExecutionStage,
) error
}
type DeleteManagerImpl ¶
type DeleteManagerImpl struct {
// contains filtered or unexported fields
}
func NewDeleteManager ¶
func NewDeleteManager(
shardContext shard.Context,
cache wcache.Cache,
config *configs.Config,
timeSource clock.TimeSource,
visibilityManager manager.VisibilityManager,
) *DeleteManagerImpl
func (*DeleteManagerImpl) AddDeleteWorkflowExecutionTask ¶
func (m *DeleteManagerImpl) AddDeleteWorkflowExecutionTask(
ctx context.Context,
nsID namespace.ID,
we *commonpb.WorkflowExecution,
ms workflow.MutableState,
workflowClosedVersion int64,
) error
func (*DeleteManagerImpl) DeleteWorkflowExecution ¶
func (m *DeleteManagerImpl) DeleteWorkflowExecution(
ctx context.Context,
nsID namespace.ID,
we *commonpb.WorkflowExecution,
weCtx workflow.Context,
ms workflow.MutableState,
forceDeleteFromOpenVisibility bool,
stage *tasks.DeleteWorkflowExecutionStage,
) error
func (*DeleteManagerImpl) DeleteWorkflowExecutionByRetention ¶
func (m *DeleteManagerImpl) DeleteWorkflowExecutionByRetention(
ctx context.Context,
nsID namespace.ID,
we *commonpb.WorkflowExecution,
weCtx workflow.Context,
ms workflow.MutableState,
stage *tasks.DeleteWorkflowExecutionStage,
) error
type MockDeleteManager ¶
type MockDeleteManager struct {
// contains filtered or unexported fields
}
MockDeleteManager is a mock of DeleteManager interface.
func NewMockDeleteManager ¶
func NewMockDeleteManager(ctrl *gomock.Controller) *MockDeleteManager
NewMockDeleteManager creates a new mock instance.
func (*MockDeleteManager) AddDeleteWorkflowExecutionTask ¶
func (m *MockDeleteManager) AddDeleteWorkflowExecutionTask(ctx context.Context, nsID namespace.ID, we *common.WorkflowExecution, ms workflow.MutableState, workflowClosedVersion int64) error
AddDeleteWorkflowExecutionTask mocks base method.
func (*MockDeleteManager) DeleteWorkflowExecution ¶
func (m *MockDeleteManager) DeleteWorkflowExecution(ctx context.Context, nsID namespace.ID, we *common.WorkflowExecution, weCtx workflow.Context, ms workflow.MutableState, forceDeleteFromOpenVisibility bool, stage *tasks.DeleteWorkflowExecutionStage) error
DeleteWorkflowExecution mocks base method.
func (*MockDeleteManager) DeleteWorkflowExecutionByRetention ¶
func (m *MockDeleteManager) DeleteWorkflowExecutionByRetention(ctx context.Context, nsID namespace.ID, we *common.WorkflowExecution, weCtx workflow.Context, ms workflow.MutableState, stage *tasks.DeleteWorkflowExecutionStage) error
DeleteWorkflowExecutionByRetention mocks base method.
type MockDeleteManagerMockRecorder ¶
type MockDeleteManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockDeleteManagerMockRecorder is the mock recorder for MockDeleteManager.
func (*MockDeleteManagerMockRecorder) AddDeleteWorkflowExecutionTask ¶
func (mr *MockDeleteManagerMockRecorder) AddDeleteWorkflowExecutionTask(ctx, nsID, we, ms, workflowClosedVersion interface{}) *gomock.Call
AddDeleteWorkflowExecutionTask indicates an expected call of AddDeleteWorkflowExecutionTask.
func (*MockDeleteManagerMockRecorder) DeleteWorkflowExecution ¶
func (mr *MockDeleteManagerMockRecorder) DeleteWorkflowExecution(ctx, nsID, we, weCtx, ms, forceDeleteFromOpenVisibility, stage interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockDeleteManagerMockRecorder) DeleteWorkflowExecutionByRetention ¶
func (mr *MockDeleteManagerMockRecorder) DeleteWorkflowExecutionByRetention(ctx, nsID, we, weCtx, ms, stage interface{}) *gomock.Call
DeleteWorkflowExecutionByRetention indicates an expected call of DeleteWorkflowExecutionByRetention.
Source Files
Click to show internal directories.
Click to hide internal directories.