deletemanager

Documentation

Overview

Package deletemanager is a generated GoMock package.

Index

• type DeleteManager
• type DeleteManagerImpl
  • func NewDeleteManager(shardContext shard.Context, cache wcache.Cache, config *configs.Config, ...) *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 NewMockDeleteManager(ctrl *gomock.Controller) *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

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.

func (*MockDeleteManager) EXPECT

func (m *MockDeleteManager) EXPECT() *MockDeleteManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

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.