reset

Documentation

Overview

Package reset is a generated GoMock package.

Index

• type MockWorkflowResetter
  • func NewMockWorkflowResetter(ctrl *gomock.Controller) *MockWorkflowResetter
  • func (m *MockWorkflowResetter) EXPECT() *MockWorkflowResetterMockRecorder
  • func (m *MockWorkflowResetter) ResetWorkflow(ctx context.Context, domainID, workflowID, baseRunID string, ...) error
• type MockWorkflowResetterMockRecorder
  • func (mr *MockWorkflowResetterMockRecorder) ResetWorkflow(...) *gomock.Call
• type WorkflowResetter
  • func NewWorkflowResetter(shard shard.Context, executionCache *execution.Cache, logger log.Logger) WorkflowResetter

Types

type MockWorkflowResetter

type MockWorkflowResetter struct {
	// contains filtered or unexported fields
}

MockWorkflowResetter is a mock of WorkflowResetter interface

func NewMockWorkflowResetter

func NewMockWorkflowResetter(ctrl *gomock.Controller) *MockWorkflowResetter

NewMockWorkflowResetter creates a new mock instance

func (*MockWorkflowResetter) EXPECT

func (m *MockWorkflowResetter) EXPECT() *MockWorkflowResetterMockRecorder

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

func (*MockWorkflowResetter) ResetWorkflow

func (m *MockWorkflowResetter) ResetWorkflow(ctx context.Context, domainID, workflowID, baseRunID string, baseBranchToken []byte, baseRebuildLastEventID, baseRebuildLastEventVersion, baseNextEventID int64, resetRunID, resetRequestID string, currentWorkflow execution.Workflow, resetReason string, additionalReapplyEvents []*types.HistoryEvent, skipSignalReapply bool) error

ResetWorkflow mocks base method

type MockWorkflowResetterMockRecorder

type MockWorkflowResetterMockRecorder struct {
	// contains filtered or unexported fields
}

MockWorkflowResetterMockRecorder is the mock recorder for MockWorkflowResetter

func (*MockWorkflowResetterMockRecorder) ResetWorkflow

func (mr *MockWorkflowResetterMockRecorder) ResetWorkflow(ctx, domainID, workflowID, baseRunID, baseBranchToken, baseRebuildLastEventID, baseRebuildLastEventVersion, baseNextEventID, resetRunID, resetRequestID, currentWorkflow, resetReason, additionalReapplyEvents, skipSignalReapply interface{}) *gomock.Call

ResetWorkflow indicates an expected call of ResetWorkflow

type WorkflowResetter

type WorkflowResetter interface {
	ResetWorkflow(
		ctx ctx.Context,
		domainID string,
		workflowID string,
		baseRunID string,
		baseBranchToken []byte,
		baseRebuildLastEventID int64,
		baseRebuildLastEventVersion int64,
		baseNextEventID int64,
		resetRunID string,
		resetRequestID string,
		currentWorkflow execution.Workflow,
		resetReason string,
		additionalReapplyEvents []*types.HistoryEvent,
		skipSignalReapply bool,
	) error
}

WorkflowResetter is the new NDC compatible workflow reset component

func NewWorkflowResetter

func NewWorkflowResetter(
	shard shard.Context,
	executionCache *execution.Cache,
	logger log.Logger,
) WorkflowResetter

NewWorkflowResetter creates a workflow resetter