reset

Documentation

Overview

Package reset is a generated GoMock package.

Package reset is a generated GoMock package.

Index

• type MockWorkflowResetor
  • func NewMockWorkflowResetor(ctrl *gomock.Controller) *MockWorkflowResetor
  • func (m *MockWorkflowResetor) ApplyResetEvent(ctx context.Context, request *history.ReplicateEventsRequest, ...) error
  • func (m *MockWorkflowResetor) EXPECT() *MockWorkflowResetorMockRecorder
  • func (m *MockWorkflowResetor) ResetWorkflowExecution(ctx context.Context, resetRequest *shared.ResetWorkflowExecutionRequest, ...) (*shared.ResetWorkflowExecutionResponse, error)
• type MockWorkflowResetorMockRecorder
  • func (mr *MockWorkflowResetorMockRecorder) ApplyResetEvent(ctx, request, domainID, workflowID, currentRunID interface{}) *gomock.Call
  • func (mr *MockWorkflowResetorMockRecorder) ResetWorkflowExecution(ctx, resetRequest, baseContext, baseMutableState, currContext, ... interface{}) *gomock.Call
• 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 WorkflowResetor
• type WorkflowResetter
  • func NewWorkflowResetter(shard shard.Context, executionCache *execution.Cache, logger log.Logger) WorkflowResetter

Types

type MockWorkflowResetor

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

MockWorkflowResetor is a mock of WorkflowResetor interface

func NewMockWorkflowResetor

func NewMockWorkflowResetor(ctrl *gomock.Controller) *MockWorkflowResetor

NewMockWorkflowResetor creates a new mock instance

func (*MockWorkflowResetor) ApplyResetEvent

func (m *MockWorkflowResetor) ApplyResetEvent(ctx context.Context, request *history.ReplicateEventsRequest, domainID, workflowID, currentRunID string) error

ApplyResetEvent mocks base method

func (*MockWorkflowResetor) EXPECT

func (m *MockWorkflowResetor) EXPECT() *MockWorkflowResetorMockRecorder

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

func (*MockWorkflowResetor) ResetWorkflowExecution

func (m *MockWorkflowResetor) ResetWorkflowExecution(ctx context.Context, resetRequest *shared.ResetWorkflowExecutionRequest, baseContext execution.Context, baseMutableState execution.MutableState, currContext execution.Context, currMutableState execution.MutableState) (*shared.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method

type MockWorkflowResetorMockRecorder

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

MockWorkflowResetorMockRecorder is the mock recorder for MockWorkflowResetor

func (*MockWorkflowResetorMockRecorder) ApplyResetEvent

func (mr *MockWorkflowResetorMockRecorder) ApplyResetEvent(ctx, request, domainID, workflowID, currentRunID interface{}) *gomock.Call

ApplyResetEvent indicates an expected call of ApplyResetEvent

func (*MockWorkflowResetorMockRecorder) ResetWorkflowExecution

func (mr *MockWorkflowResetorMockRecorder) ResetWorkflowExecution(ctx, resetRequest, baseContext, baseMutableState, currContext, currMutableState interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution

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 []*shared.HistoryEvent) 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 interface{}) *gomock.Call

ResetWorkflow indicates an expected call of ResetWorkflow

type WorkflowResetor

type WorkflowResetor interface {
	ResetWorkflowExecution(
		ctx context.Context,
		resetRequest *workflow.ResetWorkflowExecutionRequest,
		baseContext execution.Context,
		baseMutableState execution.MutableState,
		currContext execution.Context,
		currMutableState execution.MutableState,
	) (response *workflow.ResetWorkflowExecutionResponse, retError error)

	ApplyResetEvent(
		ctx context.Context,
		request *h.ReplicateEventsRequest,
		domainID, workflowID, currentRunID string,
	) (retError error)
}

WorkflowResetor is deprecated: use WorkflowResetter instead when NDC is applies to all workflows

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 []*shared.HistoryEvent,
	) 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