workflow

package
v1.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 17, 2022 License: MIT Imports: 59 Imported by: 2

Documentation

Overview

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Package workflow is a generated GoMock package.

Index

Constants

View Source 
const (
	HistoryBuilderStateMutable   HistoryBuilderState = 0
	HistoryBuilderStateImmutable                     = 1
	HistoryBuilderStateSealed                        = 2
)
View Source 
const (
	TimerTaskStatusNone = iota
	TimerTaskStatusCreated
)
View Source 
const (
	TimerTaskStatusCreatedStartToClose = 1 << iota
	TimerTaskStatusCreatedScheduleToStart
	TimerTaskStatusCreatedScheduleToClose
	TimerTaskStatusCreatedHeartbeat
)
View Source 
const (
	// ErrMessageHistorySizeZero indicate that history is empty
	ErrMessageHistorySizeZero = "encounter history size being zero"
)

Variables

View Source 
var (
	// ErrWorkflowFinished indicates trying to mutate mutable state after workflow finished
	ErrWorkflowFinished = serviceerror.NewInternal("invalid mutable state action: mutation after finish")
	// ErrMissingTimerInfo indicates missing timer info
	ErrMissingTimerInfo = serviceerror.NewInternal("unable to get timer info")
	// ErrMissingActivityInfo indicates missing activity info
	ErrMissingActivityInfo = serviceerror.NewInternal("unable to get activity info")
	// ErrMissingChildWorkflowInfo indicates missing child workflow info
	ErrMissingChildWorkflowInfo = serviceerror.NewInternal("unable to get child workflow info")
	// ErrMissingRequestCancelInfo indicates missing request cancel info
	ErrMissingRequestCancelInfo = serviceerror.NewInternal("unable to get request cancel info")
	// ErrMissingSignalInfo indicates missing signal external
	ErrMissingSignalInfo = serviceerror.NewInternal("unable to get signal info")
	// ErrMissingWorkflowStartEvent indicates missing workflow start event
	ErrMissingWorkflowStartEvent = serviceerror.NewInternal("unable to get workflow start event")
	// ErrMissingWorkflowCompletionEvent indicates missing workflow completion event
	ErrMissingWorkflowCompletionEvent = serviceerror.NewInternal("unable to get workflow completion event")
	// ErrMissingActivityScheduledEvent indicates missing workflow activity scheduled event
	ErrMissingActivityScheduledEvent = serviceerror.NewInternal("unable to get activity scheduled event")
	// ErrMissingChildWorkflowInitiatedEvent indicates missing child workflow initiated event
	ErrMissingChildWorkflowInitiatedEvent = serviceerror.NewInternal("unable to get child workflow initiated event")
	// ErrMissingSignalInitiatedEvent indicates missing workflow signal initiated event
	ErrMissingSignalInitiatedEvent = serviceerror.NewInternal("unable to get signal initiated event")
)
View Source 
var Module = fx.Options(
	fx.Provide(NewCacheFnProvider),
	fx.Populate(&taskGeneratorProvider),
)
View Source 
var (
	PersistenceOperationRetryPolicy = common.CreatePersistenceRetryPolicy()
)

Functions

func FindAutoResetPoint 

func FindAutoResetPoint(
	timeSource clock.TimeSource,
	verifyChecksum func(string) error,
	autoResetPoints *workflowpb.ResetPoints,
) (string, *workflowpb.ResetPointInfo)

FindAutoResetPoint returns the auto reset point

func NewTimerSequence 

func NewTimerSequence(
	mutableState MutableState,
) *timerSequenceImpl

func NotifyNewHistoryMutationEvent added in v1.12.0 

func NotifyNewHistoryMutationEvent(
	engine shard.Engine,
	workflowMutation *persistence.WorkflowMutation,
) error

func NotifyNewHistorySnapshotEvent added in v1.12.0 

func NotifyNewHistorySnapshotEvent(
	engine shard.Engine,
	workflowSnapshot *persistence.WorkflowSnapshot,
) error

func NotifyWorkflowMutationTasks added in v1.12.0 

func NotifyWorkflowMutationTasks(
	engine shard.Engine,
	workflowMutation *persistence.WorkflowMutation,
	clusterName string,
)

func NotifyWorkflowSnapshotTasks added in v1.12.0 

func NotifyWorkflowSnapshotTasks(
	engine shard.Engine,
	workflowSnapshot *persistence.WorkflowSnapshot,
	clusterName string,
)

func PersistWorkflowEvents added in v1.12.0 

func PersistWorkflowEvents(
	ctx context.Context,
	shard shard.Context,
	workflowEvents *persistence.WorkflowEvents,
) (int64, error)

func ScheduleWorkflowTask 

func ScheduleWorkflowTask(
	mutableState MutableState,
) error

func SetupNewWorkflowForRetryOrCron added in v1.13.0 

func SetupNewWorkflowForRetryOrCron(
	ctx context.Context,
	previousMutableState MutableState,
	newMutableState MutableState,
	newRunID string,
	startAttr *historypb.WorkflowExecutionStartedEventAttributes,
	lastCompletionResult *commonpb.Payloads,
	failure *failurepb.Failure,
	backoffInterval time.Duration,
	initiator enumspb.ContinueAsNewInitiator,
) error

func TerminateWorkflow 

func TerminateWorkflow(
	mutableState MutableState,
	eventBatchFirstEventID int64,
	terminateReason string,
	terminateDetails *commonpb.Payloads,
	terminateIdentity string,
	deleteAfterTerminate bool,
) error

func TestCloneToProto 

func TestCloneToProto(
	mutableState MutableState,
) *persistencespb.WorkflowMutableState

func TimeoutWorkflow 

func TimeoutWorkflow(
	mutableState MutableState,
	eventBatchFirstEventID int64,
	retryState enumspb.RetryState,
	continuedRunID string,
) error

Types

type Cache 

type Cache interface {
	GetOrCreateWorkflowExecution(
		ctx context.Context,
		namespaceID namespace.ID,
		execution commonpb.WorkflowExecution,
		caller CallerType,
	) (Context, ReleaseCacheFunc, error)
}

func NewCache 

func NewCache(shard shard.Context) Cache

type CacheImpl added in v1.13.0 

type CacheImpl struct {
	cache.Cache
	// contains filtered or unexported fields
}

func (*CacheImpl) GetOrCreateWorkflowExecution added in v1.13.0 

func (c *CacheImpl) GetOrCreateWorkflowExecution(
	ctx context.Context,
	namespaceID namespace.ID,
	execution commonpb.WorkflowExecution,
	caller CallerType,
) (Context, ReleaseCacheFunc, error)

type CallerType 

type CallerType int
const (
	CallerTypeAPI  CallerType = 0
	CallerTypeTask CallerType = 1
)

type Context 

type Context interface {
	GetNamespace() namespace.Name
	GetNamespaceID() namespace.ID
	GetWorkflowID() string
	GetRunID() string

	LoadWorkflowExecution(ctx context.Context) (MutableState, error)
	LoadExecutionStats(ctx context.Context) (*persistencespb.ExecutionStats, error)
	Clear()

	Lock(ctx context.Context, caller CallerType) error
	Unlock(caller CallerType)

	GetHistorySize() int64
	SetHistorySize(size int64)

	ReapplyEvents(
		eventBatches []*persistence.WorkflowEvents,
	) error

	PersistWorkflowEvents(
		ctx context.Context,
		workflowEvents *persistence.WorkflowEvents,
	) (int64, error)

	CreateWorkflowExecution(
		ctx context.Context,
		now time.Time,
		createMode persistence.CreateWorkflowMode,
		prevRunID string,
		prevLastWriteVersion int64,
		newMutableState MutableState,
		newWorkflow *persistence.WorkflowSnapshot,
		newWorkflowEvents []*persistence.WorkflowEvents,
	) error
	ConflictResolveWorkflowExecution(
		ctx context.Context,
		now time.Time,
		conflictResolveMode persistence.ConflictResolveWorkflowMode,
		resetMutableState MutableState,
		newContext Context,
		newMutableState MutableState,
		currentContext Context,
		currentMutableState MutableState,
		currentTransactionPolicy *TransactionPolicy,
	) error
	UpdateWorkflowExecutionAsActive(
		ctx context.Context,
		now time.Time,
	) error
	UpdateWorkflowExecutionWithNewAsActive(
		ctx context.Context,
		now time.Time,
		newContext Context,
		newMutableState MutableState,
	) error
	UpdateWorkflowExecutionAsPassive(
		ctx context.Context,
		now time.Time,
	) error
	UpdateWorkflowExecutionWithNewAsPassive(
		ctx context.Context,
		now time.Time,
		newContext Context,
		newMutableState MutableState,
	) error
	UpdateWorkflowExecutionWithNew(
		ctx context.Context,
		now time.Time,
		updateMode persistence.UpdateWorkflowMode,
		newContext Context,
		newMutableState MutableState,
		currentWorkflowTransactionPolicy TransactionPolicy,
		newWorkflowTransactionPolicy *TransactionPolicy,
	) error
	SetWorkflowExecution(
		ctx context.Context,
		now time.Time,
	) error
}

type ContextImpl 

type ContextImpl struct {
	MutableState MutableState
	// contains filtered or unexported fields
}

func NewContext 

func NewContext(
	shard shard.Context,
	workflowKey definition.WorkflowKey,
	logger log.Logger,
) *ContextImpl

func (*ContextImpl) Clear 

func (c *ContextImpl) Clear()

func (*ContextImpl) ConflictResolveWorkflowExecution 

func (c *ContextImpl) ConflictResolveWorkflowExecution(
	ctx context.Context,
	now time.Time,
	conflictResolveMode persistence.ConflictResolveWorkflowMode,
	resetMutableState MutableState,
	newContext Context,
	newMutableState MutableState,
	currentContext Context,
	currentMutableState MutableState,
	currentTransactionPolicy *TransactionPolicy,
) (retError error)

func (*ContextImpl) CreateWorkflowExecution 

func (c *ContextImpl) CreateWorkflowExecution(
	ctx context.Context,
	_ time.Time,
	createMode persistence.CreateWorkflowMode,
	prevRunID string,
	prevLastWriteVersion int64,
	newMutableState MutableState,
	newWorkflow *persistence.WorkflowSnapshot,
	newWorkflowEvents []*persistence.WorkflowEvents,
) (retError error)

func (*ContextImpl) GetHistorySize 

func (c *ContextImpl) GetHistorySize() int64

func (*ContextImpl) GetNamespace 

func (c *ContextImpl) GetNamespace() namespace.Name

func (*ContextImpl) GetNamespaceID 

func (c *ContextImpl) GetNamespaceID() namespace.ID

func (*ContextImpl) GetRunID added in v1.16.0 

func (c *ContextImpl) GetRunID() string

func (*ContextImpl) GetWorkflowID added in v1.16.0 

func (c *ContextImpl) GetWorkflowID() string

func (*ContextImpl) LoadExecutionStats 

func (c *ContextImpl) LoadExecutionStats(ctx context.Context) (*persistencespb.ExecutionStats, error)

func (*ContextImpl) LoadWorkflowExecution 

func (c *ContextImpl) LoadWorkflowExecution(ctx context.Context) (MutableState, error)

func (*ContextImpl) Lock 

func (c *ContextImpl) Lock(
	ctx context.Context,
	caller CallerType,
) error

func (*ContextImpl) PersistWorkflowEvents added in v1.12.0 

func (c *ContextImpl) PersistWorkflowEvents(
	ctx context.Context,
	workflowEvents *persistence.WorkflowEvents,
) (int64, error)

func (*ContextImpl) ReapplyEvents 

func (c *ContextImpl) ReapplyEvents(
	eventBatches []*persistence.WorkflowEvents,
) error

func (*ContextImpl) SetHistorySize 

func (c *ContextImpl) SetHistorySize(size int64)

func (*ContextImpl) SetWorkflowExecution added in v1.16.0 

func (c *ContextImpl) SetWorkflowExecution(ctx context.Context, now time.Time) (retError error)

func (*ContextImpl) Unlock 

func (c *ContextImpl) Unlock(
	caller CallerType,
)

func (*ContextImpl) UpdateWorkflowExecutionAsActive 

func (c *ContextImpl) UpdateWorkflowExecutionAsActive(
	ctx context.Context,
	now time.Time,
) error

func (*ContextImpl) UpdateWorkflowExecutionAsPassive 

func (c *ContextImpl) UpdateWorkflowExecutionAsPassive(
	ctx context.Context,
	now time.Time,
) error

func (*ContextImpl) UpdateWorkflowExecutionWithNew 

func (c *ContextImpl) UpdateWorkflowExecutionWithNew(
	ctx context.Context,
	now time.Time,
	updateMode persistence.UpdateWorkflowMode,
	newContext Context,
	newMutableState MutableState,
	currentWorkflowTransactionPolicy TransactionPolicy,
	newWorkflowTransactionPolicy *TransactionPolicy,
) (retError error)

func (*ContextImpl) UpdateWorkflowExecutionWithNewAsActive 

func (c *ContextImpl) UpdateWorkflowExecutionWithNewAsActive(
	ctx context.Context,
	now time.Time,
	newContext Context,
	newMutableState MutableState,
) error

func (*ContextImpl) UpdateWorkflowExecutionWithNewAsPassive 

func (c *ContextImpl) UpdateWorkflowExecutionWithNewAsPassive(
	ctx context.Context,
	now time.Time,
	newContext Context,
	newMutableState MutableState,
) error

type DeleteManager added in v1.15.0 

type DeleteManager interface {
	AddDeleteWorkflowExecutionTask(ctx context.Context, nsID namespace.ID, we commonpb.WorkflowExecution, ms MutableState, transferQueueAckLevel int64, visibilityQueueAckLevel int64) error
	DeleteWorkflowExecution(ctx context.Context, nsID namespace.ID, we commonpb.WorkflowExecution, weCtx Context, ms MutableState, sourceTaskVersion int64, forceDeleteFromOpenVisibility bool) error
	DeleteWorkflowExecutionByRetention(ctx context.Context, nsID namespace.ID, we commonpb.WorkflowExecution, weCtx Context, ms MutableState, sourceTaskVersion int64) error
}

type DeleteManagerImpl added in v1.15.0 

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

func NewDeleteManager added in v1.15.0 

func NewDeleteManager(
	shard shard.Context,
	cache Cache,
	config *configs.Config,
	archiverClient archiver.Client,
	timeSource clock.TimeSource,
) *DeleteManagerImpl

func (*DeleteManagerImpl) AddDeleteWorkflowExecutionTask added in v1.16.0 

func (m *DeleteManagerImpl) AddDeleteWorkflowExecutionTask(
	ctx context.Context,
	nsID namespace.ID,
	we commonpb.WorkflowExecution,
	ms MutableState,
	transferQueueAckLevel int64,
	visibilityQueueAckLevel int64,
) error

func (*DeleteManagerImpl) DeleteWorkflowExecution added in v1.15.0 

func (m *DeleteManagerImpl) DeleteWorkflowExecution(
	ctx context.Context,
	nsID namespace.ID,
	we commonpb.WorkflowExecution,
	weCtx Context,
	ms MutableState,
	sourceTaskVersion int64,
	forceDeleteFromOpenVisibility bool,
) error

func (*DeleteManagerImpl) DeleteWorkflowExecutionByRetention added in v1.15.0 

func (m *DeleteManagerImpl) DeleteWorkflowExecutionByRetention(
	ctx context.Context,
	nsID namespace.ID,
	we commonpb.WorkflowExecution,
	weCtx Context,
	ms MutableState,
	sourceTaskVersion int64,
) error

type HistoryBuilder 

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

TODO should the reorderFunc functionality be ported?

func NewImmutableHistoryBuilder 

func NewImmutableHistoryBuilder(
	history []*historypb.HistoryEvent,
) *HistoryBuilder

func NewMutableHistoryBuilder 

func NewMutableHistoryBuilder(
	timeSource clock.TimeSource,
	taskIDGenerator TaskIDGenerator,
	version int64,
	nextEventID int64,
	dbBufferBatch []*historypb.HistoryEvent,
) *HistoryBuilder

func (*HistoryBuilder) AddActivityTaskCancelRequestedEvent 

func (b *HistoryBuilder) AddActivityTaskCancelRequestedEvent(
	workflowTaskCompletedEventID int64,
	scheduledEventID int64,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddActivityTaskCanceledEvent 

func (b *HistoryBuilder) AddActivityTaskCanceledEvent(
	scheduledEventID int64,
	startedEventID int64,
	latestCancelRequestedEventID int64,
	details *commonpb.Payloads,
	identity string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddActivityTaskCompletedEvent 

func (b *HistoryBuilder) AddActivityTaskCompletedEvent(
	scheduledEventID int64,
	startedEventID int64,
	identity string,
	result *commonpb.Payloads,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddActivityTaskFailedEvent 

func (b *HistoryBuilder) AddActivityTaskFailedEvent(
	scheduledEventID int64,
	startedEventID int64,
	failure *failurepb.Failure,
	retryState enumspb.RetryState,
	identity string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddActivityTaskScheduledEvent 

func (b *HistoryBuilder) AddActivityTaskScheduledEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.ScheduleActivityTaskCommandAttributes,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddActivityTaskStartedEvent 

func (b *HistoryBuilder) AddActivityTaskStartedEvent(
	scheduledEventID int64,
	attempt int32,
	requestID string,
	identity string,
	lastFailure *failurepb.Failure,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddActivityTaskTimedOutEvent 

func (b *HistoryBuilder) AddActivityTaskTimedOutEvent(
	scheduledEventID,
	startedEventID int64,
	timeoutFailure *failurepb.Failure,
	retryState enumspb.RetryState,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddChildWorkflowExecutionCanceledEvent 

func (b *HistoryBuilder) AddChildWorkflowExecutionCanceledEvent(
	initiatedID int64,
	startedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	execution *commonpb.WorkflowExecution,
	workflowType *commonpb.WorkflowType,
	details *commonpb.Payloads,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddChildWorkflowExecutionCompletedEvent 

func (b *HistoryBuilder) AddChildWorkflowExecutionCompletedEvent(
	initiatedID int64,
	startedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	execution *commonpb.WorkflowExecution,
	workflowType *commonpb.WorkflowType,
	result *commonpb.Payloads,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddChildWorkflowExecutionFailedEvent 

func (b *HistoryBuilder) AddChildWorkflowExecutionFailedEvent(
	initiatedID int64,
	startedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	execution *commonpb.WorkflowExecution,
	workflowType *commonpb.WorkflowType,
	failure *failurepb.Failure,
	retryState enumspb.RetryState,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddChildWorkflowExecutionStartedEvent 

func (b *HistoryBuilder) AddChildWorkflowExecutionStartedEvent(
	initiatedID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	execution *commonpb.WorkflowExecution,
	workflowType *commonpb.WorkflowType,
	header *commonpb.Header,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddChildWorkflowExecutionTerminatedEvent 

func (b *HistoryBuilder) AddChildWorkflowExecutionTerminatedEvent(
	initiatedID int64,
	startedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	execution *commonpb.WorkflowExecution,
	workflowType *commonpb.WorkflowType,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddChildWorkflowExecutionTimedOutEvent 

func (b *HistoryBuilder) AddChildWorkflowExecutionTimedOutEvent(
	initiatedID int64,
	startedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	execution *commonpb.WorkflowExecution,
	workflowType *commonpb.WorkflowType,
	retryState enumspb.RetryState,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddCompletedWorkflowEvent 

func (b *HistoryBuilder) AddCompletedWorkflowEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.CompleteWorkflowExecutionCommandAttributes,
	newExecutionRunID string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddContinuedAsNewEvent 

func (b *HistoryBuilder) AddContinuedAsNewEvent(
	workflowTaskCompletedEventID int64,
	newRunID string,
	command *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddExternalWorkflowExecutionCancelRequested 

func (b *HistoryBuilder) AddExternalWorkflowExecutionCancelRequested(
	initiatedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddExternalWorkflowExecutionSignaled 

func (b *HistoryBuilder) AddExternalWorkflowExecutionSignaled(
	initiatedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
	control string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddFailWorkflowEvent 

func (b *HistoryBuilder) AddFailWorkflowEvent(
	workflowTaskCompletedEventID int64,
	retryState enumspb.RetryState,
	command *commandpb.FailWorkflowExecutionCommandAttributes,
	newExecutionRunID string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddMarkerRecordedEvent 

func (b *HistoryBuilder) AddMarkerRecordedEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.RecordMarkerCommandAttributes,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddRequestCancelExternalWorkflowExecutionFailedEvent 

func (b *HistoryBuilder) AddRequestCancelExternalWorkflowExecutionFailedEvent(
	workflowTaskCompletedEventID int64,
	initiatedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
	cause enumspb.CancelExternalWorkflowExecutionFailedCause,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (b *HistoryBuilder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes,
	targetNamespaceID namespace.ID,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddSignalExternalWorkflowExecutionFailedEvent 

func (b *HistoryBuilder) AddSignalExternalWorkflowExecutionFailedEvent(
	workflowTaskCompletedEventID int64,
	initiatedEventID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
	control string,
	cause enumspb.SignalExternalWorkflowExecutionFailedCause,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddSignalExternalWorkflowExecutionInitiatedEvent 

func (b *HistoryBuilder) AddSignalExternalWorkflowExecutionInitiatedEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.SignalExternalWorkflowExecutionCommandAttributes,
	targetNamespaceID namespace.ID,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddStartChildWorkflowExecutionFailedEvent 

func (b *HistoryBuilder) AddStartChildWorkflowExecutionFailedEvent(
	workflowTaskCompletedEventID int64,
	initiatedID int64,
	cause enumspb.StartChildWorkflowExecutionFailedCause,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	workflowType *commonpb.WorkflowType,
	control string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddStartChildWorkflowExecutionInitiatedEvent 

func (b *HistoryBuilder) AddStartChildWorkflowExecutionInitiatedEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.StartChildWorkflowExecutionCommandAttributes,
	targetNamespaceID namespace.ID,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddTimeoutWorkflowEvent 

func (b *HistoryBuilder) AddTimeoutWorkflowEvent(
	retryState enumspb.RetryState,
	newExecutionRunID string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddTimerCanceledEvent 

func (b *HistoryBuilder) AddTimerCanceledEvent(
	workflowTaskCompletedEventID int64,
	startedEventID int64,
	timerID string,
	identity string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddTimerFiredEvent 

func (b *HistoryBuilder) AddTimerFiredEvent(
	startedEventID int64,
	timerID string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddTimerStartedEvent 

func (b *HistoryBuilder) AddTimerStartedEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.StartTimerCommandAttributes,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddUpsertWorkflowSearchAttributesEvent 

func (b *HistoryBuilder) AddUpsertWorkflowSearchAttributesEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.UpsertWorkflowSearchAttributesCommandAttributes,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowExecutionCancelRequestedEvent 

func (b *HistoryBuilder) AddWorkflowExecutionCancelRequestedEvent(
	request *historyservice.RequestCancelWorkflowExecutionRequest,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowExecutionCanceledEvent 

func (b *HistoryBuilder) AddWorkflowExecutionCanceledEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.CancelWorkflowExecutionCommandAttributes,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowExecutionSignaledEvent 

func (b *HistoryBuilder) AddWorkflowExecutionSignaledEvent(
	signalName string,
	input *commonpb.Payloads,
	identity string,
	header *commonpb.Header,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowExecutionStartedEvent 

func (b *HistoryBuilder) AddWorkflowExecutionStartedEvent(
	startTime time.Time,
	request *historyservice.StartWorkflowExecutionRequest,
	resetPoints *workflowpb.ResetPoints,
	prevRunID string,
	firstRunID string,
	originalRunID string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowExecutionTerminatedEvent 

func (b *HistoryBuilder) AddWorkflowExecutionTerminatedEvent(
	reason string,
	details *commonpb.Payloads,
	identity string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowTaskCompletedEvent 

func (b *HistoryBuilder) AddWorkflowTaskCompletedEvent(
	scheduledEventID int64,
	startedEventID int64,
	identity string,
	checksum string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowTaskFailedEvent 

func (b *HistoryBuilder) AddWorkflowTaskFailedEvent(
	scheduledEventID int64,
	startedEventID int64,
	cause enumspb.WorkflowTaskFailedCause,
	failure *failurepb.Failure,
	identity string,
	baseRunID string,
	newRunID string,
	forkEventVersion int64,
	checksum string,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowTaskScheduledEvent 

func (b *HistoryBuilder) AddWorkflowTaskScheduledEvent(
	taskQueue *taskqueuepb.TaskQueue,
	startToCloseTimeout *time.Duration,
	attempt int32,
	now time.Time,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowTaskStartedEvent 

func (b *HistoryBuilder) AddWorkflowTaskStartedEvent(
	scheduledEventID int64,
	requestID string,
	identity string,
	now time.Time,
) *historypb.HistoryEvent

func (*HistoryBuilder) AddWorkflowTaskTimedOutEvent 

func (b *HistoryBuilder) AddWorkflowTaskTimedOutEvent(
	scheduledEventID int64,
	startedEventID int64,
	timeoutType enumspb.TimeoutType,
) *historypb.HistoryEvent

func (*HistoryBuilder) BufferEventSize 

func (b *HistoryBuilder) BufferEventSize() int

func (*HistoryBuilder) Finish 

func (b *HistoryBuilder) Finish(
	flushBufferEvent bool,
) (*HistoryMutation, error)

func (*HistoryBuilder) FlushAndCreateNewBatch 

func (b *HistoryBuilder) FlushAndCreateNewBatch()

func (*HistoryBuilder) FlushBufferToCurrentBatch 

func (b *HistoryBuilder) FlushBufferToCurrentBatch() map[int64]int64

func (*HistoryBuilder) GetAndRemoveTimerFireEvent 

func (b *HistoryBuilder) GetAndRemoveTimerFireEvent(
	timerID string,
) *historypb.HistoryEvent

func (*HistoryBuilder) HasActivityFinishEvent 

func (b *HistoryBuilder) HasActivityFinishEvent(
	scheduledEventID int64,
) bool

func (*HistoryBuilder) HasBufferEvents 

func (b *HistoryBuilder) HasBufferEvents() bool

func (*HistoryBuilder) NextEventID 

func (b *HistoryBuilder) NextEventID() int64

type HistoryBuilderState 

type HistoryBuilderState int

TODO should the reorderFunc functionality be ported?

type HistoryMutation 

type HistoryMutation struct {
	// events to be persist to events table
	DBEventsBatches [][]*historypb.HistoryEvent
	// events to be buffer in execution table
	DBBufferBatch []*historypb.HistoryEvent
	// whether to clear buffer events on DB
	DBClearBuffer bool
	// accumulated buffered events, equal to all buffer events from execution table
	MemBufferBatch []*historypb.HistoryEvent
	// scheduled to started event ID mapping for flushed buffered event
	ScheduledIDToStartedID map[int64]int64
}

TODO should the reorderFunc functionality be ported?

type MockCache added in v1.15.0 

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

MockCache is a mock of Cache interface.

func NewMockCache added in v1.15.0 

func NewMockCache(ctrl *gomock.Controller) *MockCache

NewMockCache creates a new mock instance.

func (*MockCache) EXPECT added in v1.15.0 

func (m *MockCache) EXPECT() *MockCacheMockRecorder

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

func (*MockCache) GetOrCreateWorkflowExecution added in v1.15.0 

func (m *MockCache) GetOrCreateWorkflowExecution(ctx context.Context, namespaceID namespace.ID, execution v1.WorkflowExecution, caller CallerType) (Context, ReleaseCacheFunc, error)

GetOrCreateWorkflowExecution mocks base method.

type MockCacheMockRecorder added in v1.15.0 

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

MockCacheMockRecorder is the mock recorder for MockCache.

func (*MockCacheMockRecorder) GetOrCreateWorkflowExecution added in v1.15.0 

func (mr *MockCacheMockRecorder) GetOrCreateWorkflowExecution(ctx, namespaceID, execution, caller interface{}) *gomock.Call

GetOrCreateWorkflowExecution indicates an expected call of GetOrCreateWorkflowExecution.

type MockContext 

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

MockContext is a mock of Context interface.

func NewMockContext 

func NewMockContext(ctrl *gomock.Controller) *MockContext

NewMockContext creates a new mock instance.

func (*MockContext) Clear 

func (m *MockContext) Clear()

Clear mocks base method.

func (*MockContext) ConflictResolveWorkflowExecution 

func (m *MockContext) ConflictResolveWorkflowExecution(ctx context.Context, now time.Time, conflictResolveMode persistence.ConflictResolveWorkflowMode, resetMutableState MutableState, newContext Context, newMutableState MutableState, currentContext Context, currentMutableState MutableState, currentTransactionPolicy *TransactionPolicy) error

ConflictResolveWorkflowExecution mocks base method.

func (*MockContext) CreateWorkflowExecution 

func (m *MockContext) CreateWorkflowExecution(ctx context.Context, now time.Time, createMode persistence.CreateWorkflowMode, prevRunID string, prevLastWriteVersion int64, newMutableState MutableState, newWorkflow *persistence.WorkflowSnapshot, newWorkflowEvents []*persistence.WorkflowEvents) error

CreateWorkflowExecution mocks base method.

func (*MockContext) EXPECT 

func (m *MockContext) EXPECT() *MockContextMockRecorder

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

func (*MockContext) GetHistorySize 

func (m *MockContext) GetHistorySize() int64

GetHistorySize mocks base method.

func (*MockContext) GetNamespace 

func (m *MockContext) GetNamespace() namespace.Name

GetNamespace mocks base method.

func (*MockContext) GetNamespaceID 

func (m *MockContext) GetNamespaceID() namespace.ID

GetNamespaceID mocks base method.

func (*MockContext) GetRunID added in v1.16.0 

func (m *MockContext) GetRunID() string

GetRunID mocks base method.

func (*MockContext) GetWorkflowID added in v1.16.0 

func (m *MockContext) GetWorkflowID() string

GetWorkflowID mocks base method.

func (*MockContext) LoadExecutionStats 

func (m *MockContext) LoadExecutionStats(ctx context.Context) (*v1.ExecutionStats, error)

LoadExecutionStats mocks base method.

func (*MockContext) LoadWorkflowExecution 

func (m *MockContext) LoadWorkflowExecution(ctx context.Context) (MutableState, error)

LoadWorkflowExecution mocks base method.

func (*MockContext) Lock 

func (m *MockContext) Lock(ctx context.Context, caller CallerType) error

Lock mocks base method.

func (*MockContext) PersistWorkflowEvents added in v1.12.0 

func (m *MockContext) PersistWorkflowEvents(ctx context.Context, workflowEvents *persistence.WorkflowEvents) (int64, error)

PersistWorkflowEvents mocks base method.

func (*MockContext) ReapplyEvents 

func (m *MockContext) ReapplyEvents(eventBatches []*persistence.WorkflowEvents) error

ReapplyEvents mocks base method.

func (*MockContext) SetHistorySize 

func (m *MockContext) SetHistorySize(size int64)

SetHistorySize mocks base method.

func (*MockContext) SetWorkflowExecution added in v1.16.0 

func (m *MockContext) SetWorkflowExecution(ctx context.Context, now time.Time) error

SetWorkflowExecution mocks base method.

func (*MockContext) Unlock 

func (m *MockContext) Unlock(caller CallerType)

Unlock mocks base method.

func (*MockContext) UpdateWorkflowExecutionAsActive 

func (m *MockContext) UpdateWorkflowExecutionAsActive(ctx context.Context, now time.Time) error

UpdateWorkflowExecutionAsActive mocks base method.

func (*MockContext) UpdateWorkflowExecutionAsPassive 

func (m *MockContext) UpdateWorkflowExecutionAsPassive(ctx context.Context, now time.Time) error

UpdateWorkflowExecutionAsPassive mocks base method.

func (*MockContext) UpdateWorkflowExecutionWithNew 

func (m *MockContext) UpdateWorkflowExecutionWithNew(ctx context.Context, now time.Time, updateMode persistence.UpdateWorkflowMode, newContext Context, newMutableState MutableState, currentWorkflowTransactionPolicy TransactionPolicy, newWorkflowTransactionPolicy *TransactionPolicy) error

UpdateWorkflowExecutionWithNew mocks base method.

func (*MockContext) UpdateWorkflowExecutionWithNewAsActive 

func (m *MockContext) UpdateWorkflowExecutionWithNewAsActive(ctx context.Context, now time.Time, newContext Context, newMutableState MutableState) error

UpdateWorkflowExecutionWithNewAsActive mocks base method.

func (*MockContext) UpdateWorkflowExecutionWithNewAsPassive 

func (m *MockContext) UpdateWorkflowExecutionWithNewAsPassive(ctx context.Context, now time.Time, newContext Context, newMutableState MutableState) error

UpdateWorkflowExecutionWithNewAsPassive mocks base method.

type MockContextMockRecorder 

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

MockContextMockRecorder is the mock recorder for MockContext.

func (*MockContextMockRecorder) Clear 

func (mr *MockContextMockRecorder) Clear() *gomock.Call

Clear indicates an expected call of Clear.

func (*MockContextMockRecorder) ConflictResolveWorkflowExecution 

func (mr *MockContextMockRecorder) ConflictResolveWorkflowExecution(ctx, now, conflictResolveMode, resetMutableState, newContext, newMutableState, currentContext, currentMutableState, currentTransactionPolicy interface{}) *gomock.Call

ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.

func (*MockContextMockRecorder) CreateWorkflowExecution 

func (mr *MockContextMockRecorder) CreateWorkflowExecution(ctx, now, createMode, prevRunID, prevLastWriteVersion, newMutableState, newWorkflow, newWorkflowEvents interface{}) *gomock.Call

CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.

func (*MockContextMockRecorder) GetHistorySize 

func (mr *MockContextMockRecorder) GetHistorySize() *gomock.Call

GetHistorySize indicates an expected call of GetHistorySize.

func (*MockContextMockRecorder) GetNamespace 

func (mr *MockContextMockRecorder) GetNamespace() *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockContextMockRecorder) GetNamespaceID 

func (mr *MockContextMockRecorder) GetNamespaceID() *gomock.Call

GetNamespaceID indicates an expected call of GetNamespaceID.

func (*MockContextMockRecorder) GetRunID added in v1.16.0 

func (mr *MockContextMockRecorder) GetRunID() *gomock.Call

GetRunID indicates an expected call of GetRunID.

func (*MockContextMockRecorder) GetWorkflowID added in v1.16.0 

func (mr *MockContextMockRecorder) GetWorkflowID() *gomock.Call

GetWorkflowID indicates an expected call of GetWorkflowID.

func (*MockContextMockRecorder) LoadExecutionStats 

func (mr *MockContextMockRecorder) LoadExecutionStats(ctx interface{}) *gomock.Call

LoadExecutionStats indicates an expected call of LoadExecutionStats.

func (*MockContextMockRecorder) LoadWorkflowExecution 

func (mr *MockContextMockRecorder) LoadWorkflowExecution(ctx interface{}) *gomock.Call

LoadWorkflowExecution indicates an expected call of LoadWorkflowExecution.

func (*MockContextMockRecorder) Lock 

func (mr *MockContextMockRecorder) Lock(ctx, caller interface{}) *gomock.Call

Lock indicates an expected call of Lock.

func (*MockContextMockRecorder) PersistWorkflowEvents added in v1.12.0 

func (mr *MockContextMockRecorder) PersistWorkflowEvents(ctx, workflowEvents interface{}) *gomock.Call

PersistWorkflowEvents indicates an expected call of PersistWorkflowEvents.

func (*MockContextMockRecorder) ReapplyEvents 

func (mr *MockContextMockRecorder) ReapplyEvents(eventBatches interface{}) *gomock.Call

ReapplyEvents indicates an expected call of ReapplyEvents.

func (*MockContextMockRecorder) SetHistorySize 

func (mr *MockContextMockRecorder) SetHistorySize(size interface{}) *gomock.Call

SetHistorySize indicates an expected call of SetHistorySize.

func (*MockContextMockRecorder) SetWorkflowExecution added in v1.16.0 

func (mr *MockContextMockRecorder) SetWorkflowExecution(ctx, now interface{}) *gomock.Call

SetWorkflowExecution indicates an expected call of SetWorkflowExecution.

func (*MockContextMockRecorder) Unlock 

func (mr *MockContextMockRecorder) Unlock(caller interface{}) *gomock.Call

Unlock indicates an expected call of Unlock.

func (*MockContextMockRecorder) UpdateWorkflowExecutionAsActive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionAsActive(ctx, now interface{}) *gomock.Call

UpdateWorkflowExecutionAsActive indicates an expected call of UpdateWorkflowExecutionAsActive.

func (*MockContextMockRecorder) UpdateWorkflowExecutionAsPassive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionAsPassive(ctx, now interface{}) *gomock.Call

UpdateWorkflowExecutionAsPassive indicates an expected call of UpdateWorkflowExecutionAsPassive.

func (*MockContextMockRecorder) UpdateWorkflowExecutionWithNew 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionWithNew(ctx, now, updateMode, newContext, newMutableState, currentWorkflowTransactionPolicy, newWorkflowTransactionPolicy interface{}) *gomock.Call

UpdateWorkflowExecutionWithNew indicates an expected call of UpdateWorkflowExecutionWithNew.

func (*MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsActive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsActive(ctx, now, newContext, newMutableState interface{}) *gomock.Call

UpdateWorkflowExecutionWithNewAsActive indicates an expected call of UpdateWorkflowExecutionWithNewAsActive.

func (*MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsPassive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsPassive(ctx, now, newContext, newMutableState interface{}) *gomock.Call

UpdateWorkflowExecutionWithNewAsPassive indicates an expected call of UpdateWorkflowExecutionWithNewAsPassive.

type MockDeleteManager added in v1.15.0 

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

MockDeleteManager is a mock of DeleteManager interface.

func NewMockDeleteManager added in v1.15.0 

func NewMockDeleteManager(ctrl *gomock.Controller) *MockDeleteManager

NewMockDeleteManager creates a new mock instance.

func (*MockDeleteManager) AddDeleteWorkflowExecutionTask added in v1.16.0 

func (m *MockDeleteManager) AddDeleteWorkflowExecutionTask(ctx context.Context, nsID namespace.ID, we v1.WorkflowExecution, ms MutableState, transferQueueAckLevel, visibilityQueueAckLevel int64) error

AddDeleteWorkflowExecutionTask mocks base method.

func (*MockDeleteManager) DeleteWorkflowExecution added in v1.15.0 

func (m *MockDeleteManager) DeleteWorkflowExecution(ctx context.Context, nsID namespace.ID, we v1.WorkflowExecution, weCtx Context, ms MutableState, sourceTaskVersion int64, forceDeleteFromOpenVisibility bool) error

DeleteWorkflowExecution mocks base method.

func (*MockDeleteManager) DeleteWorkflowExecutionByRetention added in v1.15.0 

func (m *MockDeleteManager) DeleteWorkflowExecutionByRetention(ctx context.Context, nsID namespace.ID, we v1.WorkflowExecution, weCtx Context, ms MutableState, sourceTaskVersion int64) error

DeleteWorkflowExecutionByRetention mocks base method.

func (*MockDeleteManager) EXPECT added in v1.15.0 

func (m *MockDeleteManager) EXPECT() *MockDeleteManagerMockRecorder

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

type MockDeleteManagerMockRecorder added in v1.15.0 

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

MockDeleteManagerMockRecorder is the mock recorder for MockDeleteManager.

func (*MockDeleteManagerMockRecorder) AddDeleteWorkflowExecutionTask added in v1.16.0 

func (mr *MockDeleteManagerMockRecorder) AddDeleteWorkflowExecutionTask(ctx, nsID, we, ms, transferQueueAckLevel, visibilityQueueAckLevel interface{}) *gomock.Call

AddDeleteWorkflowExecutionTask indicates an expected call of AddDeleteWorkflowExecutionTask.

func (*MockDeleteManagerMockRecorder) DeleteWorkflowExecution added in v1.15.0 

func (mr *MockDeleteManagerMockRecorder) DeleteWorkflowExecution(ctx, nsID, we, weCtx, ms, sourceTaskVersion, forceDeleteFromOpenVisibility interface{}) *gomock.Call

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockDeleteManagerMockRecorder) DeleteWorkflowExecutionByRetention added in v1.15.0 

func (mr *MockDeleteManagerMockRecorder) DeleteWorkflowExecutionByRetention(ctx, nsID, we, weCtx, ms, sourceTaskVersion interface{}) *gomock.Call

DeleteWorkflowExecutionByRetention indicates an expected call of DeleteWorkflowExecutionByRetention.

type MockMutableState 

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

MockMutableState is a mock of MutableState interface.

func NewMockMutableState 

func NewMockMutableState(ctrl *gomock.Controller) *MockMutableState

NewMockMutableState creates a new mock instance.

func (*MockMutableState) AddActivityTaskCancelRequestedEvent 

func (m *MockMutableState) AddActivityTaskCancelRequestedEvent(arg0, arg1 int64, arg2 string) (*v13.HistoryEvent, *v110.ActivityInfo, error)

AddActivityTaskCancelRequestedEvent mocks base method.

func (*MockMutableState) AddActivityTaskCanceledEvent 

func (m *MockMutableState) AddActivityTaskCanceledEvent(arg0, arg1, arg2 int64, arg3 *v10.Payloads, arg4 string) (*v13.HistoryEvent, error)

AddActivityTaskCanceledEvent mocks base method.

func (*MockMutableState) AddActivityTaskCompletedEvent 

func (m *MockMutableState) AddActivityTaskCompletedEvent(arg0, arg1 int64, arg2 *v16.RespondActivityTaskCompletedRequest) (*v13.HistoryEvent, error)

AddActivityTaskCompletedEvent mocks base method.

func (*MockMutableState) AddActivityTaskFailedEvent 

func (m *MockMutableState) AddActivityTaskFailedEvent(arg0, arg1 int64, arg2 *v12.Failure, arg3 v11.RetryState, arg4 string) (*v13.HistoryEvent, error)

AddActivityTaskFailedEvent mocks base method.

func (*MockMutableState) AddActivityTaskScheduledEvent 

func (m *MockMutableState) AddActivityTaskScheduledEvent(arg0 int64, arg1 *v1.ScheduleActivityTaskCommandAttributes, arg2 bool) (*v13.HistoryEvent, *v110.ActivityInfo, error)

AddActivityTaskScheduledEvent mocks base method.

func (*MockMutableState) AddActivityTaskStartedEvent 

func (m *MockMutableState) AddActivityTaskStartedEvent(arg0 *v110.ActivityInfo, arg1 int64, arg2, arg3 string) (*v13.HistoryEvent, error)

AddActivityTaskStartedEvent mocks base method.

func (*MockMutableState) AddActivityTaskTimedOutEvent 

func (m *MockMutableState) AddActivityTaskTimedOutEvent(arg0, arg1 int64, arg2 *v12.Failure, arg3 v11.RetryState) (*v13.HistoryEvent, error)

AddActivityTaskTimedOutEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionCanceledEvent 

func (m *MockMutableState) AddChildWorkflowExecutionCanceledEvent(arg0 int64, arg1 *v10.WorkflowExecution, arg2 *v13.WorkflowExecutionCanceledEventAttributes) (*v13.HistoryEvent, error)

AddChildWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionCompletedEvent 

func (m *MockMutableState) AddChildWorkflowExecutionCompletedEvent(arg0 int64, arg1 *v10.WorkflowExecution, arg2 *v13.WorkflowExecutionCompletedEventAttributes) (*v13.HistoryEvent, error)

AddChildWorkflowExecutionCompletedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionFailedEvent 

func (m *MockMutableState) AddChildWorkflowExecutionFailedEvent(arg0 int64, arg1 *v10.WorkflowExecution, arg2 *v13.WorkflowExecutionFailedEventAttributes) (*v13.HistoryEvent, error)

AddChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionStartedEvent 

func (m *MockMutableState) AddChildWorkflowExecutionStartedEvent(arg0 *v10.WorkflowExecution, arg1 *v10.WorkflowType, arg2 int64, arg3 *v10.Header, arg4 *v17.VectorClock) (*v13.HistoryEvent, error)

AddChildWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionTerminatedEvent 

func (m *MockMutableState) AddChildWorkflowExecutionTerminatedEvent(arg0 int64, arg1 *v10.WorkflowExecution, arg2 *v13.WorkflowExecutionTerminatedEventAttributes) (*v13.HistoryEvent, error)

AddChildWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionTimedOutEvent 

func (m *MockMutableState) AddChildWorkflowExecutionTimedOutEvent(arg0 int64, arg1 *v10.WorkflowExecution, arg2 *v13.WorkflowExecutionTimedOutEventAttributes) (*v13.HistoryEvent, error)

AddChildWorkflowExecutionTimedOutEvent mocks base method.

func (*MockMutableState) AddCompletedWorkflowEvent 

func (m *MockMutableState) AddCompletedWorkflowEvent(arg0 int64, arg1 *v1.CompleteWorkflowExecutionCommandAttributes, arg2 string) (*v13.HistoryEvent, error)

AddCompletedWorkflowEvent mocks base method.

func (*MockMutableState) AddContinueAsNewEvent 

func (m *MockMutableState) AddContinueAsNewEvent(arg0, arg1 int64, arg2 namespace.Name, arg3 *v1.ContinueAsNewWorkflowExecutionCommandAttributes) (*v13.HistoryEvent, MutableState, error)

AddContinueAsNewEvent mocks base method.

func (*MockMutableState) AddExternalWorkflowExecutionCancelRequested 

func (m *MockMutableState) AddExternalWorkflowExecutionCancelRequested(arg0 int64, arg1 namespace.Name, arg2 namespace.ID, arg3, arg4 string) (*v13.HistoryEvent, error)

AddExternalWorkflowExecutionCancelRequested mocks base method.

func (*MockMutableState) AddExternalWorkflowExecutionSignaled 

func (m *MockMutableState) AddExternalWorkflowExecutionSignaled(arg0 int64, arg1 namespace.Name, arg2 namespace.ID, arg3, arg4, arg5 string) (*v13.HistoryEvent, error)

AddExternalWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) AddFailWorkflowEvent 

func (m *MockMutableState) AddFailWorkflowEvent(arg0 int64, arg1 v11.RetryState, arg2 *v1.FailWorkflowExecutionCommandAttributes, arg3 string) (*v13.HistoryEvent, error)

AddFailWorkflowEvent mocks base method.

func (*MockMutableState) AddFirstWorkflowTaskScheduled 

func (m *MockMutableState) AddFirstWorkflowTaskScheduled(arg0 *v13.HistoryEvent) error

AddFirstWorkflowTaskScheduled mocks base method.

func (*MockMutableState) AddRecordMarkerEvent 

func (m *MockMutableState) AddRecordMarkerEvent(arg0 int64, arg1 *v1.RecordMarkerCommandAttributes) (*v13.HistoryEvent, error)

AddRecordMarkerEvent mocks base method.

func (*MockMutableState) AddRequestCancelExternalWorkflowExecutionFailedEvent 

func (m *MockMutableState) AddRequestCancelExternalWorkflowExecutionFailedEvent(arg0 int64, arg1 namespace.Name, arg2 namespace.ID, arg3, arg4 string, arg5 v11.CancelExternalWorkflowExecutionFailedCause) (*v13.HistoryEvent, error)

AddRequestCancelExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) AddRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 string, arg2 *v1.RequestCancelExternalWorkflowExecutionCommandAttributes, arg3 namespace.ID) (*v13.HistoryEvent, *v110.RequestCancelInfo, error)

AddRequestCancelExternalWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) AddSignalExternalWorkflowExecutionFailedEvent 

func (m *MockMutableState) AddSignalExternalWorkflowExecutionFailedEvent(arg0 int64, arg1 namespace.Name, arg2 namespace.ID, arg3, arg4, arg5 string, arg6 v11.SignalExternalWorkflowExecutionFailedCause) (*v13.HistoryEvent, error)

AddSignalExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddSignalExternalWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) AddSignalExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 string, arg2 *v1.SignalExternalWorkflowExecutionCommandAttributes, arg3 namespace.ID) (*v13.HistoryEvent, *v110.SignalInfo, error)

AddSignalExternalWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) AddSignalRequested 

func (m *MockMutableState) AddSignalRequested(requestID string)

AddSignalRequested mocks base method.

func (*MockMutableState) AddStartChildWorkflowExecutionFailedEvent 

func (m *MockMutableState) AddStartChildWorkflowExecutionFailedEvent(arg0 int64, arg1 v11.StartChildWorkflowExecutionFailedCause, arg2 *v13.StartChildWorkflowExecutionInitiatedEventAttributes) (*v13.HistoryEvent, error)

AddStartChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddStartChildWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) AddStartChildWorkflowExecutionInitiatedEvent(arg0 int64, arg1 string, arg2 *v1.StartChildWorkflowExecutionCommandAttributes, arg3 namespace.ID) (*v13.HistoryEvent, *v110.ChildExecutionInfo, error)

AddStartChildWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) AddTasks added in v1.16.0 

func (m *MockMutableState) AddTasks(tasks ...tasks.Task)

AddTasks mocks base method.

func (*MockMutableState) AddTimeoutWorkflowEvent 

func (m *MockMutableState) AddTimeoutWorkflowEvent(arg0 int64, arg1 v11.RetryState, arg2 string) (*v13.HistoryEvent, error)

AddTimeoutWorkflowEvent mocks base method.

func (*MockMutableState) AddTimerCanceledEvent 

func (m *MockMutableState) AddTimerCanceledEvent(arg0 int64, arg1 *v1.CancelTimerCommandAttributes, arg2 string) (*v13.HistoryEvent, error)

AddTimerCanceledEvent mocks base method.

func (*MockMutableState) AddTimerFiredEvent 

func (m *MockMutableState) AddTimerFiredEvent(arg0 string) (*v13.HistoryEvent, error)

AddTimerFiredEvent mocks base method.

func (*MockMutableState) AddTimerStartedEvent 

func (m *MockMutableState) AddTimerStartedEvent(arg0 int64, arg1 *v1.StartTimerCommandAttributes) (*v13.HistoryEvent, *v110.TimerInfo, error)

AddTimerStartedEvent mocks base method.

func (*MockMutableState) AddUpsertWorkflowSearchAttributesEvent 

func (m *MockMutableState) AddUpsertWorkflowSearchAttributesEvent(arg0 int64, arg1 *v1.UpsertWorkflowSearchAttributesCommandAttributes) (*v13.HistoryEvent, error)

AddUpsertWorkflowSearchAttributesEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionCancelRequestedEvent 

func (m *MockMutableState) AddWorkflowExecutionCancelRequestedEvent(arg0 *v19.RequestCancelWorkflowExecutionRequest) (*v13.HistoryEvent, error)

AddWorkflowExecutionCancelRequestedEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionCanceledEvent 

func (m *MockMutableState) AddWorkflowExecutionCanceledEvent(arg0 int64, arg1 *v1.CancelWorkflowExecutionCommandAttributes) (*v13.HistoryEvent, error)

AddWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionSignaled 

func (m *MockMutableState) AddWorkflowExecutionSignaled(signalName string, input *v10.Payloads, identity string, header *v10.Header) (*v13.HistoryEvent, error)

AddWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) AddWorkflowExecutionStartedEvent 

func (m *MockMutableState) AddWorkflowExecutionStartedEvent(arg0 v10.WorkflowExecution, arg1 *v19.StartWorkflowExecutionRequest) (*v13.HistoryEvent, error)

AddWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionStartedEventWithOptions added in v1.13.0 

func (m *MockMutableState) AddWorkflowExecutionStartedEventWithOptions(arg0 v10.WorkflowExecution, arg1 *v19.StartWorkflowExecutionRequest, arg2 *v15.ResetPoints, arg3, arg4 string) (*v13.HistoryEvent, error)

AddWorkflowExecutionStartedEventWithOptions mocks base method.

func (*MockMutableState) AddWorkflowExecutionTerminatedEvent 

func (m *MockMutableState) AddWorkflowExecutionTerminatedEvent(firstEventID int64, reason string, details *v10.Payloads, identity string, deleteAfterTerminate bool) (*v13.HistoryEvent, error)

AddWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskCompletedEvent 

func (m *MockMutableState) AddWorkflowTaskCompletedEvent(arg0, arg1 int64, arg2 *v16.RespondWorkflowTaskCompletedRequest, arg3 int) (*v13.HistoryEvent, error)

AddWorkflowTaskCompletedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskFailedEvent 

func (m *MockMutableState) AddWorkflowTaskFailedEvent(scheduledEventID, startedEventID int64, cause v11.WorkflowTaskFailedCause, failure *v12.Failure, identity, binChecksum, baseRunID, newRunID string, forkEventVersion int64) (*v13.HistoryEvent, error)

AddWorkflowTaskFailedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskScheduleToStartTimeoutEvent 

func (m *MockMutableState) AddWorkflowTaskScheduleToStartTimeoutEvent(arg0 int64) (*v13.HistoryEvent, error)

AddWorkflowTaskScheduleToStartTimeoutEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskScheduledEvent 

func (m *MockMutableState) AddWorkflowTaskScheduledEvent(bypassTaskGeneration bool) (*WorkflowTaskInfo, error)

AddWorkflowTaskScheduledEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskScheduledEventAsHeartbeat 

func (m *MockMutableState) AddWorkflowTaskScheduledEventAsHeartbeat(bypassTaskGeneration bool, originalScheduledTimestamp *time.Time) (*WorkflowTaskInfo, error)

AddWorkflowTaskScheduledEventAsHeartbeat mocks base method.

func (*MockMutableState) AddWorkflowTaskStartedEvent 

func (m *MockMutableState) AddWorkflowTaskStartedEvent(arg0 int64, arg1 string, arg2 *v14.TaskQueue, arg3 string) (*v13.HistoryEvent, *WorkflowTaskInfo, error)

AddWorkflowTaskStartedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskTimedOutEvent 

func (m *MockMutableState) AddWorkflowTaskTimedOutEvent(arg0, arg1 int64) (*v13.HistoryEvent, error)

AddWorkflowTaskTimedOutEvent mocks base method.

func (*MockMutableState) CheckResettable 

func (m *MockMutableState) CheckResettable() error

CheckResettable mocks base method.

func (*MockMutableState) ClearStickyness 

func (m *MockMutableState) ClearStickyness()

ClearStickyness mocks base method.

func (*MockMutableState) ClearTransientWorkflowTask added in v1.16.3 

func (m *MockMutableState) ClearTransientWorkflowTask() error

ClearTransientWorkflowTask mocks base method.

func (*MockMutableState) CloneToProto 

func (m *MockMutableState) CloneToProto() *v110.WorkflowMutableState

CloneToProto mocks base method.

func (*MockMutableState) CloseTransactionAsMutation 

func (m *MockMutableState) CloseTransactionAsMutation(now time.Time, transactionPolicy TransactionPolicy) (*persistence.WorkflowMutation, []*persistence.WorkflowEvents, error)

CloseTransactionAsMutation mocks base method.

func (*MockMutableState) CloseTransactionAsSnapshot 

func (m *MockMutableState) CloseTransactionAsSnapshot(now time.Time, transactionPolicy TransactionPolicy) (*persistence.WorkflowSnapshot, []*persistence.WorkflowEvents, error)

CloseTransactionAsSnapshot mocks base method.

func (*MockMutableState) CreateTransientWorkflowTaskEvents 

func (m *MockMutableState) CreateTransientWorkflowTaskEvents(workflowTask *WorkflowTaskInfo, identity string) (*v13.HistoryEvent, *v13.HistoryEvent)

CreateTransientWorkflowTaskEvents mocks base method.

func (*MockMutableState) DeleteSignalRequested 

func (m *MockMutableState) DeleteSignalRequested(requestID string)

DeleteSignalRequested mocks base method.

func (*MockMutableState) DeleteWorkflowTask 

func (m *MockMutableState) DeleteWorkflowTask()

DeleteWorkflowTask mocks base method.

func (*MockMutableState) EXPECT 

func (m *MockMutableState) EXPECT() *MockMutableStateMockRecorder

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

func (*MockMutableState) FlushBufferedEvents 

func (m *MockMutableState) FlushBufferedEvents()

FlushBufferedEvents mocks base method.

func (*MockMutableState) GenerateMigrationTasks added in v1.17.0 

func (m *MockMutableState) GenerateMigrationTasks(now time.Time) (tasks.Task, error)

GenerateMigrationTasks mocks base method.

func (*MockMutableState) GetActivityByActivityID 

func (m *MockMutableState) GetActivityByActivityID(arg0 string) (*v110.ActivityInfo, bool)

GetActivityByActivityID mocks base method.

func (*MockMutableState) GetActivityInfo 

func (m *MockMutableState) GetActivityInfo(arg0 int64) (*v110.ActivityInfo, bool)

GetActivityInfo mocks base method.

func (*MockMutableState) GetActivityInfoWithTimerHeartbeat 

func (m *MockMutableState) GetActivityInfoWithTimerHeartbeat(scheduledEventID int64) (*v110.ActivityInfo, time.Time, bool)

GetActivityInfoWithTimerHeartbeat mocks base method.

func (*MockMutableState) GetActivityScheduledEvent 

func (m *MockMutableState) GetActivityScheduledEvent(arg0 context.Context, arg1 int64) (*v13.HistoryEvent, error)

GetActivityScheduledEvent mocks base method.

func (*MockMutableState) GetChildExecutionInfo 

func (m *MockMutableState) GetChildExecutionInfo(arg0 int64) (*v110.ChildExecutionInfo, bool)

GetChildExecutionInfo mocks base method.

func (*MockMutableState) GetChildExecutionInitiatedEvent 

func (m *MockMutableState) GetChildExecutionInitiatedEvent(arg0 context.Context, arg1 int64) (*v13.HistoryEvent, error)

GetChildExecutionInitiatedEvent mocks base method.

func (*MockMutableState) GetCompletionEvent 

func (m *MockMutableState) GetCompletionEvent(arg0 context.Context) (*v13.HistoryEvent, error)

GetCompletionEvent mocks base method.

func (*MockMutableState) GetCronBackoffDuration 

func (m *MockMutableState) GetCronBackoffDuration() time.Duration

GetCronBackoffDuration mocks base method.

func (*MockMutableState) GetCurrentBranchToken 

func (m *MockMutableState) GetCurrentBranchToken() ([]byte, error)

GetCurrentBranchToken mocks base method.

func (*MockMutableState) GetCurrentVersion 

func (m *MockMutableState) GetCurrentVersion() int64

GetCurrentVersion mocks base method.

func (*MockMutableState) GetExecutionInfo 

func (m *MockMutableState) GetExecutionInfo() *v110.WorkflowExecutionInfo

GetExecutionInfo mocks base method.

func (*MockMutableState) GetExecutionState 

func (m *MockMutableState) GetExecutionState() *v110.WorkflowExecutionState

GetExecutionState mocks base method.

func (*MockMutableState) GetFirstRunID added in v1.13.0 

func (m *MockMutableState) GetFirstRunID() (string, error)

GetFirstRunID mocks base method.

func (*MockMutableState) GetInFlightWorkflowTask 

func (m *MockMutableState) GetInFlightWorkflowTask() (*WorkflowTaskInfo, bool)

GetInFlightWorkflowTask mocks base method.

func (*MockMutableState) GetLastFirstEventIDTxnID 

func (m *MockMutableState) GetLastFirstEventIDTxnID() (int64, int64)

GetLastFirstEventIDTxnID mocks base method.

func (*MockMutableState) GetLastWriteVersion 

func (m *MockMutableState) GetLastWriteVersion() (int64, error)

GetLastWriteVersion mocks base method.

func (*MockMutableState) GetNamespaceEntry 

func (m *MockMutableState) GetNamespaceEntry() *namespace.Namespace

GetNamespaceEntry mocks base method.

func (*MockMutableState) GetNextEventID 

func (m *MockMutableState) GetNextEventID() int64

GetNextEventID mocks base method.

func (*MockMutableState) GetPendingActivityInfos 

func (m *MockMutableState) GetPendingActivityInfos() map[int64]*v110.ActivityInfo

GetPendingActivityInfos mocks base method.

func (*MockMutableState) GetPendingChildExecutionInfos 

func (m *MockMutableState) GetPendingChildExecutionInfos() map[int64]*v110.ChildExecutionInfo

GetPendingChildExecutionInfos mocks base method.

func (*MockMutableState) GetPendingRequestCancelExternalInfos 

func (m *MockMutableState) GetPendingRequestCancelExternalInfos() map[int64]*v110.RequestCancelInfo

GetPendingRequestCancelExternalInfos mocks base method.

func (*MockMutableState) GetPendingSignalExternalInfos 

func (m *MockMutableState) GetPendingSignalExternalInfos() map[int64]*v110.SignalInfo

GetPendingSignalExternalInfos mocks base method.

func (*MockMutableState) GetPendingTimerInfos 

func (m *MockMutableState) GetPendingTimerInfos() map[string]*v110.TimerInfo

GetPendingTimerInfos mocks base method.

func (*MockMutableState) GetPendingWorkflowTask 

func (m *MockMutableState) GetPendingWorkflowTask() (*WorkflowTaskInfo, bool)

GetPendingWorkflowTask mocks base method.

func (*MockMutableState) GetPreviousStartedEventID 

func (m *MockMutableState) GetPreviousStartedEventID() int64

GetPreviousStartedEventID mocks base method.

func (*MockMutableState) GetQueryRegistry 

func (m *MockMutableState) GetQueryRegistry() QueryRegistry

GetQueryRegistry mocks base method.

func (*MockMutableState) GetRequestCancelInfo 

func (m *MockMutableState) GetRequestCancelInfo(arg0 int64) (*v110.RequestCancelInfo, bool)

GetRequestCancelInfo mocks base method.

func (*MockMutableState) GetRequesteCancelExternalInitiatedEvent added in v1.16.0 

func (m *MockMutableState) GetRequesteCancelExternalInitiatedEvent(arg0 context.Context, arg1 int64) (*v13.HistoryEvent, error)

GetRequesteCancelExternalInitiatedEvent mocks base method.

func (*MockMutableState) GetRetryBackoffDuration 

func (m *MockMutableState) GetRetryBackoffDuration(failure *v12.Failure) (time.Duration, v11.RetryState)

GetRetryBackoffDuration mocks base method.

func (*MockMutableState) GetSignalExternalInitiatedEvent added in v1.14.0 

func (m *MockMutableState) GetSignalExternalInitiatedEvent(arg0 context.Context, arg1 int64) (*v13.HistoryEvent, error)

GetSignalExternalInitiatedEvent mocks base method.

func (*MockMutableState) GetSignalInfo 

func (m *MockMutableState) GetSignalInfo(arg0 int64) (*v110.SignalInfo, bool)

GetSignalInfo mocks base method.

func (*MockMutableState) GetStartEvent 

func (m *MockMutableState) GetStartEvent(arg0 context.Context) (*v13.HistoryEvent, error)

GetStartEvent mocks base method.

func (*MockMutableState) GetStartVersion 

func (m *MockMutableState) GetStartVersion() (int64, error)

GetStartVersion mocks base method.

func (*MockMutableState) GetUpdateCondition 

func (m *MockMutableState) GetUpdateCondition() (int64, int64)

GetUpdateCondition mocks base method.

func (*MockMutableState) GetUserTimerInfo 

func (m *MockMutableState) GetUserTimerInfo(arg0 string) (*v110.TimerInfo, bool)

GetUserTimerInfo mocks base method.

func (*MockMutableState) GetUserTimerInfoByEventID 

func (m *MockMutableState) GetUserTimerInfoByEventID(arg0 int64) (*v110.TimerInfo, bool)

GetUserTimerInfoByEventID mocks base method.

func (*MockMutableState) GetWorkflowCloseTime added in v1.17.0 

func (m *MockMutableState) GetWorkflowCloseTime(ctx context.Context) (*time.Time, error)

GetWorkflowCloseTime mocks base method.

func (*MockMutableState) GetWorkflowKey added in v1.14.0 

func (m *MockMutableState) GetWorkflowKey() definition.WorkflowKey

GetWorkflowKey mocks base method.

func (*MockMutableState) GetWorkflowStateStatus 

func (m *MockMutableState) GetWorkflowStateStatus() (v18.WorkflowExecutionState, v11.WorkflowExecutionStatus)

GetWorkflowStateStatus mocks base method.

func (*MockMutableState) GetWorkflowTaskInfo 

func (m *MockMutableState) GetWorkflowTaskInfo(arg0 int64) (*WorkflowTaskInfo, bool)

GetWorkflowTaskInfo mocks base method.

func (*MockMutableState) GetWorkflowType 

func (m *MockMutableState) GetWorkflowType() *v10.WorkflowType

GetWorkflowType mocks base method.

func (*MockMutableState) HasBufferedEvents 

func (m *MockMutableState) HasBufferedEvents() bool

HasBufferedEvents mocks base method.

func (*MockMutableState) HasInFlightWorkflowTask 

func (m *MockMutableState) HasInFlightWorkflowTask() bool

HasInFlightWorkflowTask mocks base method.

func (*MockMutableState) HasParentExecution 

func (m *MockMutableState) HasParentExecution() bool

HasParentExecution mocks base method.

func (*MockMutableState) HasPendingWorkflowTask 

func (m *MockMutableState) HasPendingWorkflowTask() bool

HasPendingWorkflowTask mocks base method.

func (*MockMutableState) HasProcessedOrPendingWorkflowTask 

func (m *MockMutableState) HasProcessedOrPendingWorkflowTask() bool

HasProcessedOrPendingWorkflowTask mocks base method.

func (*MockMutableState) HasTransientWorkflowTask added in v1.16.3 

func (m *MockMutableState) HasTransientWorkflowTask() bool

HasTransientWorkflowTask mocks base method.

func (*MockMutableState) IsCancelRequested 

func (m *MockMutableState) IsCancelRequested() bool

IsCancelRequested mocks base method.

func (*MockMutableState) IsCurrentWorkflowGuaranteed 

func (m *MockMutableState) IsCurrentWorkflowGuaranteed() bool

IsCurrentWorkflowGuaranteed mocks base method.

func (*MockMutableState) IsResourceDuplicated 

func (m *MockMutableState) IsResourceDuplicated(resourceDedupKey definition.DeduplicationID) bool

IsResourceDuplicated mocks base method.

func (*MockMutableState) IsSignalRequested 

func (m *MockMutableState) IsSignalRequested(requestID string) bool

IsSignalRequested mocks base method.

func (*MockMutableState) IsStickyTaskQueueEnabled 

func (m *MockMutableState) IsStickyTaskQueueEnabled() bool

IsStickyTaskQueueEnabled mocks base method.

func (*MockMutableState) IsWorkflowExecutionRunning 

func (m *MockMutableState) IsWorkflowExecutionRunning() bool

IsWorkflowExecutionRunning mocks base method.

func (*MockMutableState) IsWorkflowPendingOnWorkflowTaskBackoff added in v1.16.3 

func (m *MockMutableState) IsWorkflowPendingOnWorkflowTaskBackoff() bool

IsWorkflowPendingOnWorkflowTaskBackoff mocks base method.

func (*MockMutableState) PopTasks added in v1.17.0 

func (m *MockMutableState) PopTasks() map[tasks.Category][]tasks.Task

PopTasks mocks base method.

func (*MockMutableState) ReplicateActivityInfo 

func (m *MockMutableState) ReplicateActivityInfo(arg0 *v19.SyncActivityRequest, arg1 bool) error

ReplicateActivityInfo mocks base method.

func (*MockMutableState) ReplicateActivityTaskCancelRequestedEvent 

func (m *MockMutableState) ReplicateActivityTaskCancelRequestedEvent(arg0 *v13.HistoryEvent) error

ReplicateActivityTaskCancelRequestedEvent mocks base method.

func (*MockMutableState) ReplicateActivityTaskCanceledEvent 

func (m *MockMutableState) ReplicateActivityTaskCanceledEvent(arg0 *v13.HistoryEvent) error

ReplicateActivityTaskCanceledEvent mocks base method.

func (*MockMutableState) ReplicateActivityTaskCompletedEvent 

func (m *MockMutableState) ReplicateActivityTaskCompletedEvent(arg0 *v13.HistoryEvent) error

ReplicateActivityTaskCompletedEvent mocks base method.

func (*MockMutableState) ReplicateActivityTaskFailedEvent 

func (m *MockMutableState) ReplicateActivityTaskFailedEvent(arg0 *v13.HistoryEvent) error

ReplicateActivityTaskFailedEvent mocks base method.

func (*MockMutableState) ReplicateActivityTaskScheduledEvent 

func (m *MockMutableState) ReplicateActivityTaskScheduledEvent(arg0 int64, arg1 *v13.HistoryEvent) (*v110.ActivityInfo, error)

ReplicateActivityTaskScheduledEvent mocks base method.

func (*MockMutableState) ReplicateActivityTaskStartedEvent 

func (m *MockMutableState) ReplicateActivityTaskStartedEvent(arg0 *v13.HistoryEvent) error

ReplicateActivityTaskStartedEvent mocks base method.

func (*MockMutableState) ReplicateActivityTaskTimedOutEvent 

func (m *MockMutableState) ReplicateActivityTaskTimedOutEvent(arg0 *v13.HistoryEvent) error

ReplicateActivityTaskTimedOutEvent mocks base method.

func (*MockMutableState) ReplicateChildWorkflowExecutionCanceledEvent 

func (m *MockMutableState) ReplicateChildWorkflowExecutionCanceledEvent(arg0 *v13.HistoryEvent) error

ReplicateChildWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) ReplicateChildWorkflowExecutionCompletedEvent 

func (m *MockMutableState) ReplicateChildWorkflowExecutionCompletedEvent(arg0 *v13.HistoryEvent) error

ReplicateChildWorkflowExecutionCompletedEvent mocks base method.

func (*MockMutableState) ReplicateChildWorkflowExecutionFailedEvent 

func (m *MockMutableState) ReplicateChildWorkflowExecutionFailedEvent(arg0 *v13.HistoryEvent) error

ReplicateChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ReplicateChildWorkflowExecutionStartedEvent 

func (m *MockMutableState) ReplicateChildWorkflowExecutionStartedEvent(arg0 *v13.HistoryEvent, arg1 *v17.VectorClock) error

ReplicateChildWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) ReplicateChildWorkflowExecutionTerminatedEvent 

func (m *MockMutableState) ReplicateChildWorkflowExecutionTerminatedEvent(arg0 *v13.HistoryEvent) error

ReplicateChildWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) ReplicateChildWorkflowExecutionTimedOutEvent 

func (m *MockMutableState) ReplicateChildWorkflowExecutionTimedOutEvent(arg0 *v13.HistoryEvent) error

ReplicateChildWorkflowExecutionTimedOutEvent mocks base method.

func (*MockMutableState) ReplicateExternalWorkflowExecutionCancelRequested 

func (m *MockMutableState) ReplicateExternalWorkflowExecutionCancelRequested(arg0 *v13.HistoryEvent) error

ReplicateExternalWorkflowExecutionCancelRequested mocks base method.

func (*MockMutableState) ReplicateExternalWorkflowExecutionSignaled 

func (m *MockMutableState) ReplicateExternalWorkflowExecutionSignaled(arg0 *v13.HistoryEvent) error

ReplicateExternalWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) ReplicateRequestCancelExternalWorkflowExecutionFailedEvent 

func (m *MockMutableState) ReplicateRequestCancelExternalWorkflowExecutionFailedEvent(arg0 *v13.HistoryEvent) error

ReplicateRequestCancelExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 *v13.HistoryEvent, arg2 string) (*v110.RequestCancelInfo, error)

ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) ReplicateSignalExternalWorkflowExecutionFailedEvent 

func (m *MockMutableState) ReplicateSignalExternalWorkflowExecutionFailedEvent(arg0 *v13.HistoryEvent) error

ReplicateSignalExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ReplicateSignalExternalWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) ReplicateSignalExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 *v13.HistoryEvent, arg2 string) (*v110.SignalInfo, error)

ReplicateSignalExternalWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) ReplicateStartChildWorkflowExecutionFailedEvent 

func (m *MockMutableState) ReplicateStartChildWorkflowExecutionFailedEvent(arg0 *v13.HistoryEvent) error

ReplicateStartChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ReplicateStartChildWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) ReplicateStartChildWorkflowExecutionInitiatedEvent(arg0 int64, arg1 *v13.HistoryEvent, arg2 string) (*v110.ChildExecutionInfo, error)

ReplicateStartChildWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) ReplicateTimerCanceledEvent 

func (m *MockMutableState) ReplicateTimerCanceledEvent(arg0 *v13.HistoryEvent) error

ReplicateTimerCanceledEvent mocks base method.

func (*MockMutableState) ReplicateTimerFiredEvent 

func (m *MockMutableState) ReplicateTimerFiredEvent(arg0 *v13.HistoryEvent) error

ReplicateTimerFiredEvent mocks base method.

func (*MockMutableState) ReplicateTimerStartedEvent 

func (m *MockMutableState) ReplicateTimerStartedEvent(arg0 *v13.HistoryEvent) (*v110.TimerInfo, error)

ReplicateTimerStartedEvent mocks base method.

func (*MockMutableState) ReplicateTransientWorkflowTaskScheduled 

func (m *MockMutableState) ReplicateTransientWorkflowTaskScheduled() (*WorkflowTaskInfo, error)

ReplicateTransientWorkflowTaskScheduled mocks base method.

func (*MockMutableState) ReplicateUpsertWorkflowSearchAttributesEvent 

func (m *MockMutableState) ReplicateUpsertWorkflowSearchAttributesEvent(arg0 *v13.HistoryEvent)

ReplicateUpsertWorkflowSearchAttributesEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionCancelRequestedEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionCancelRequestedEvent(arg0 *v13.HistoryEvent) error

ReplicateWorkflowExecutionCancelRequestedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionCanceledEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionCanceledEvent(arg0 int64, arg1 *v13.HistoryEvent) error

ReplicateWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionCompletedEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionCompletedEvent(arg0 int64, arg1 *v13.HistoryEvent) error

ReplicateWorkflowExecutionCompletedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionContinuedAsNewEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionContinuedAsNewEvent(arg0 int64, arg1 *v13.HistoryEvent) error

ReplicateWorkflowExecutionContinuedAsNewEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionFailedEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionFailedEvent(arg0 int64, arg1 *v13.HistoryEvent) error

ReplicateWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionSignaled 

func (m *MockMutableState) ReplicateWorkflowExecutionSignaled(arg0 *v13.HistoryEvent) error

ReplicateWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionStartedEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionStartedEvent(arg0 *v17.VectorClock, arg1 v10.WorkflowExecution, arg2 string, arg3 *v13.HistoryEvent) error

ReplicateWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionTerminatedEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionTerminatedEvent(arg0 int64, arg1 *v13.HistoryEvent) error

ReplicateWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowExecutionTimedoutEvent 

func (m *MockMutableState) ReplicateWorkflowExecutionTimedoutEvent(arg0 int64, arg1 *v13.HistoryEvent) error

ReplicateWorkflowExecutionTimedoutEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowTaskCompletedEvent 

func (m *MockMutableState) ReplicateWorkflowTaskCompletedEvent(arg0 *v13.HistoryEvent) error

ReplicateWorkflowTaskCompletedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowTaskFailedEvent 

func (m *MockMutableState) ReplicateWorkflowTaskFailedEvent() error

ReplicateWorkflowTaskFailedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowTaskScheduledEvent 

func (m *MockMutableState) ReplicateWorkflowTaskScheduledEvent(arg0, arg1 int64, arg2 *v14.TaskQueue, arg3 *time.Duration, arg4 int32, arg5, arg6 *time.Time) (*WorkflowTaskInfo, error)

ReplicateWorkflowTaskScheduledEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowTaskStartedEvent 

func (m *MockMutableState) ReplicateWorkflowTaskStartedEvent(arg0 *WorkflowTaskInfo, arg1, arg2, arg3 int64, arg4 string, arg5 time.Time) (*WorkflowTaskInfo, error)

ReplicateWorkflowTaskStartedEvent mocks base method.

func (*MockMutableState) ReplicateWorkflowTaskTimedOutEvent 

func (m *MockMutableState) ReplicateWorkflowTaskTimedOutEvent(arg0 v11.TimeoutType) error

ReplicateWorkflowTaskTimedOutEvent mocks base method.

func (*MockMutableState) RetryActivity 

func (m *MockMutableState) RetryActivity(ai *v110.ActivityInfo, failure *v12.Failure) (v11.RetryState, error)

RetryActivity mocks base method.

func (*MockMutableState) SetCurrentBranchToken 

func (m *MockMutableState) SetCurrentBranchToken(branchToken []byte) error

SetCurrentBranchToken mocks base method.

func (*MockMutableState) SetHistoryBuilder 

func (m *MockMutableState) SetHistoryBuilder(hBuilder *HistoryBuilder)

SetHistoryBuilder mocks base method.

func (*MockMutableState) SetHistoryTree 

func (m *MockMutableState) SetHistoryTree(treeID string) error

SetHistoryTree mocks base method.

func (*MockMutableState) SetUpdateCondition 

func (m *MockMutableState) SetUpdateCondition(arg0, arg1 int64)

SetUpdateCondition mocks base method.

func (*MockMutableState) StartTransaction 

func (m *MockMutableState) StartTransaction(entry *namespace.Namespace) (bool, error)

StartTransaction mocks base method.

func (*MockMutableState) UpdateActivity 

func (m *MockMutableState) UpdateActivity(arg0 *v110.ActivityInfo) error

UpdateActivity mocks base method.

func (*MockMutableState) UpdateActivityProgress 

func (m *MockMutableState) UpdateActivityProgress(ai *v110.ActivityInfo, request *v16.RecordActivityTaskHeartbeatRequest)

UpdateActivityProgress mocks base method.

func (*MockMutableState) UpdateActivityWithTimerHeartbeat 

func (m *MockMutableState) UpdateActivityWithTimerHeartbeat(arg0 *v110.ActivityInfo, arg1 time.Time) error

UpdateActivityWithTimerHeartbeat mocks base method.

func (*MockMutableState) UpdateCurrentVersion 

func (m *MockMutableState) UpdateCurrentVersion(version int64, forceUpdate bool) error

UpdateCurrentVersion mocks base method.

func (*MockMutableState) UpdateDuplicatedResource 

func (m *MockMutableState) UpdateDuplicatedResource(resourceDedupKey definition.DeduplicationID)

UpdateDuplicatedResource mocks base method.

func (*MockMutableState) UpdateUserTimer 

func (m *MockMutableState) UpdateUserTimer(arg0 *v110.TimerInfo) error

UpdateUserTimer mocks base method.

func (*MockMutableState) UpdateWorkflowStateStatus 

func (m *MockMutableState) UpdateWorkflowStateStatus(state v18.WorkflowExecutionState, status v11.WorkflowExecutionStatus) error

UpdateWorkflowStateStatus mocks base method.

type MockMutableStateMockRecorder 

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

MockMutableStateMockRecorder is the mock recorder for MockMutableState.

func (*MockMutableStateMockRecorder) AddActivityTaskCancelRequestedEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskCancelRequestedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddActivityTaskCancelRequestedEvent indicates an expected call of AddActivityTaskCancelRequestedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskCanceledEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskCanceledEvent(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

AddActivityTaskCanceledEvent indicates an expected call of AddActivityTaskCanceledEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskCompletedEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskCompletedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddActivityTaskCompletedEvent indicates an expected call of AddActivityTaskCompletedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskFailedEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskFailedEvent(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

AddActivityTaskFailedEvent indicates an expected call of AddActivityTaskFailedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskScheduledEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskScheduledEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddActivityTaskScheduledEvent indicates an expected call of AddActivityTaskScheduledEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskStartedEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskStartedEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddActivityTaskStartedEvent indicates an expected call of AddActivityTaskStartedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskTimedOutEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskTimedOutEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddActivityTaskTimedOutEvent indicates an expected call of AddActivityTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionCanceledEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionCanceledEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddChildWorkflowExecutionCanceledEvent indicates an expected call of AddChildWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionCompletedEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionCompletedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddChildWorkflowExecutionCompletedEvent indicates an expected call of AddChildWorkflowExecutionCompletedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionFailedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddChildWorkflowExecutionFailedEvent indicates an expected call of AddChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionStartedEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionStartedEvent(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

AddChildWorkflowExecutionStartedEvent indicates an expected call of AddChildWorkflowExecutionStartedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionTerminatedEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionTerminatedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddChildWorkflowExecutionTerminatedEvent indicates an expected call of AddChildWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionTimedOutEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionTimedOutEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddChildWorkflowExecutionTimedOutEvent indicates an expected call of AddChildWorkflowExecutionTimedOutEvent.

func (*MockMutableStateMockRecorder) AddCompletedWorkflowEvent 

func (mr *MockMutableStateMockRecorder) AddCompletedWorkflowEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddCompletedWorkflowEvent indicates an expected call of AddCompletedWorkflowEvent.

func (*MockMutableStateMockRecorder) AddContinueAsNewEvent 

func (mr *MockMutableStateMockRecorder) AddContinueAsNewEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddContinueAsNewEvent indicates an expected call of AddContinueAsNewEvent.

func (*MockMutableStateMockRecorder) AddExternalWorkflowExecutionCancelRequested 

func (mr *MockMutableStateMockRecorder) AddExternalWorkflowExecutionCancelRequested(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

AddExternalWorkflowExecutionCancelRequested indicates an expected call of AddExternalWorkflowExecutionCancelRequested.

func (*MockMutableStateMockRecorder) AddExternalWorkflowExecutionSignaled 

func (mr *MockMutableStateMockRecorder) AddExternalWorkflowExecutionSignaled(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

AddExternalWorkflowExecutionSignaled indicates an expected call of AddExternalWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) AddFailWorkflowEvent 

func (mr *MockMutableStateMockRecorder) AddFailWorkflowEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddFailWorkflowEvent indicates an expected call of AddFailWorkflowEvent.

func (*MockMutableStateMockRecorder) AddFirstWorkflowTaskScheduled 

func (mr *MockMutableStateMockRecorder) AddFirstWorkflowTaskScheduled(arg0 interface{}) *gomock.Call

AddFirstWorkflowTaskScheduled indicates an expected call of AddFirstWorkflowTaskScheduled.

func (*MockMutableStateMockRecorder) AddRecordMarkerEvent 

func (mr *MockMutableStateMockRecorder) AddRecordMarkerEvent(arg0, arg1 interface{}) *gomock.Call

AddRecordMarkerEvent indicates an expected call of AddRecordMarkerEvent.

func (*MockMutableStateMockRecorder) AddRequestCancelExternalWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) AddRequestCancelExternalWorkflowExecutionFailedEvent(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

AddRequestCancelExternalWorkflowExecutionFailedEvent indicates an expected call of AddRequestCancelExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddRequestCancelExternalWorkflowExecutionInitiatedEvent indicates an expected call of AddRequestCancelExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) AddSignalExternalWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) AddSignalExternalWorkflowExecutionFailedEvent(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

AddSignalExternalWorkflowExecutionFailedEvent indicates an expected call of AddSignalExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddSignalExternalWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) AddSignalExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddSignalExternalWorkflowExecutionInitiatedEvent indicates an expected call of AddSignalExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) AddSignalRequested 

func (mr *MockMutableStateMockRecorder) AddSignalRequested(requestID interface{}) *gomock.Call

AddSignalRequested indicates an expected call of AddSignalRequested.

func (*MockMutableStateMockRecorder) AddStartChildWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) AddStartChildWorkflowExecutionFailedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddStartChildWorkflowExecutionFailedEvent indicates an expected call of AddStartChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddStartChildWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) AddStartChildWorkflowExecutionInitiatedEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddStartChildWorkflowExecutionInitiatedEvent indicates an expected call of AddStartChildWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) AddTasks added in v1.16.0 

func (mr *MockMutableStateMockRecorder) AddTasks(tasks ...interface{}) *gomock.Call

AddTasks indicates an expected call of AddTasks.

func (*MockMutableStateMockRecorder) AddTimeoutWorkflowEvent 

func (mr *MockMutableStateMockRecorder) AddTimeoutWorkflowEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddTimeoutWorkflowEvent indicates an expected call of AddTimeoutWorkflowEvent.

func (*MockMutableStateMockRecorder) AddTimerCanceledEvent 

func (mr *MockMutableStateMockRecorder) AddTimerCanceledEvent(arg0, arg1, arg2 interface{}) *gomock.Call

AddTimerCanceledEvent indicates an expected call of AddTimerCanceledEvent.

func (*MockMutableStateMockRecorder) AddTimerFiredEvent 

func (mr *MockMutableStateMockRecorder) AddTimerFiredEvent(arg0 interface{}) *gomock.Call

AddTimerFiredEvent indicates an expected call of AddTimerFiredEvent.

func (*MockMutableStateMockRecorder) AddTimerStartedEvent 

func (mr *MockMutableStateMockRecorder) AddTimerStartedEvent(arg0, arg1 interface{}) *gomock.Call

AddTimerStartedEvent indicates an expected call of AddTimerStartedEvent.

func (*MockMutableStateMockRecorder) AddUpsertWorkflowSearchAttributesEvent 

func (mr *MockMutableStateMockRecorder) AddUpsertWorkflowSearchAttributesEvent(arg0, arg1 interface{}) *gomock.Call

AddUpsertWorkflowSearchAttributesEvent indicates an expected call of AddUpsertWorkflowSearchAttributesEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionCancelRequestedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionCancelRequestedEvent(arg0 interface{}) *gomock.Call

AddWorkflowExecutionCancelRequestedEvent indicates an expected call of AddWorkflowExecutionCancelRequestedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionCanceledEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionCanceledEvent(arg0, arg1 interface{}) *gomock.Call

AddWorkflowExecutionCanceledEvent indicates an expected call of AddWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionSignaled 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionSignaled(signalName, input, identity, header interface{}) *gomock.Call

AddWorkflowExecutionSignaled indicates an expected call of AddWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionStartedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionStartedEvent(arg0, arg1 interface{}) *gomock.Call

AddWorkflowExecutionStartedEvent indicates an expected call of AddWorkflowExecutionStartedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionStartedEventWithOptions added in v1.13.0 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionStartedEventWithOptions(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

AddWorkflowExecutionStartedEventWithOptions indicates an expected call of AddWorkflowExecutionStartedEventWithOptions.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionTerminatedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionTerminatedEvent(firstEventID, reason, details, identity, deleteAfterTerminate interface{}) *gomock.Call

AddWorkflowExecutionTerminatedEvent indicates an expected call of AddWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskCompletedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskCompletedEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddWorkflowTaskCompletedEvent indicates an expected call of AddWorkflowTaskCompletedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskFailedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskFailedEvent(scheduledEventID, startedEventID, cause, failure, identity, binChecksum, baseRunID, newRunID, forkEventVersion interface{}) *gomock.Call

AddWorkflowTaskFailedEvent indicates an expected call of AddWorkflowTaskFailedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskScheduleToStartTimeoutEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskScheduleToStartTimeoutEvent(arg0 interface{}) *gomock.Call

AddWorkflowTaskScheduleToStartTimeoutEvent indicates an expected call of AddWorkflowTaskScheduleToStartTimeoutEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskScheduledEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskScheduledEvent(bypassTaskGeneration interface{}) *gomock.Call

AddWorkflowTaskScheduledEvent indicates an expected call of AddWorkflowTaskScheduledEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskScheduledEventAsHeartbeat 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskScheduledEventAsHeartbeat(bypassTaskGeneration, originalScheduledTimestamp interface{}) *gomock.Call

AddWorkflowTaskScheduledEventAsHeartbeat indicates an expected call of AddWorkflowTaskScheduledEventAsHeartbeat.

func (*MockMutableStateMockRecorder) AddWorkflowTaskStartedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskStartedEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AddWorkflowTaskStartedEvent indicates an expected call of AddWorkflowTaskStartedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskTimedOutEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskTimedOutEvent(arg0, arg1 interface{}) *gomock.Call

AddWorkflowTaskTimedOutEvent indicates an expected call of AddWorkflowTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) CheckResettable 

func (mr *MockMutableStateMockRecorder) CheckResettable() *gomock.Call

CheckResettable indicates an expected call of CheckResettable.

func (*MockMutableStateMockRecorder) ClearStickyness 

func (mr *MockMutableStateMockRecorder) ClearStickyness() *gomock.Call

ClearStickyness indicates an expected call of ClearStickyness.

func (*MockMutableStateMockRecorder) ClearTransientWorkflowTask added in v1.16.3 

func (mr *MockMutableStateMockRecorder) ClearTransientWorkflowTask() *gomock.Call

ClearTransientWorkflowTask indicates an expected call of ClearTransientWorkflowTask.

func (*MockMutableStateMockRecorder) CloneToProto 

func (mr *MockMutableStateMockRecorder) CloneToProto() *gomock.Call

CloneToProto indicates an expected call of CloneToProto.

func (*MockMutableStateMockRecorder) CloseTransactionAsMutation 

func (mr *MockMutableStateMockRecorder) CloseTransactionAsMutation(now, transactionPolicy interface{}) *gomock.Call

CloseTransactionAsMutation indicates an expected call of CloseTransactionAsMutation.

func (*MockMutableStateMockRecorder) CloseTransactionAsSnapshot 

func (mr *MockMutableStateMockRecorder) CloseTransactionAsSnapshot(now, transactionPolicy interface{}) *gomock.Call

CloseTransactionAsSnapshot indicates an expected call of CloseTransactionAsSnapshot.

func (*MockMutableStateMockRecorder) CreateTransientWorkflowTaskEvents 

func (mr *MockMutableStateMockRecorder) CreateTransientWorkflowTaskEvents(workflowTask, identity interface{}) *gomock.Call

CreateTransientWorkflowTaskEvents indicates an expected call of CreateTransientWorkflowTaskEvents.

func (*MockMutableStateMockRecorder) DeleteSignalRequested 

func (mr *MockMutableStateMockRecorder) DeleteSignalRequested(requestID interface{}) *gomock.Call

DeleteSignalRequested indicates an expected call of DeleteSignalRequested.

func (*MockMutableStateMockRecorder) DeleteWorkflowTask 

func (mr *MockMutableStateMockRecorder) DeleteWorkflowTask() *gomock.Call

DeleteWorkflowTask indicates an expected call of DeleteWorkflowTask.

func (*MockMutableStateMockRecorder) FlushBufferedEvents 

func (mr *MockMutableStateMockRecorder) FlushBufferedEvents() *gomock.Call

FlushBufferedEvents indicates an expected call of FlushBufferedEvents.

func (*MockMutableStateMockRecorder) GenerateMigrationTasks added in v1.17.0 

func (mr *MockMutableStateMockRecorder) GenerateMigrationTasks(now interface{}) *gomock.Call

GenerateMigrationTasks indicates an expected call of GenerateMigrationTasks.

func (*MockMutableStateMockRecorder) GetActivityByActivityID 

func (mr *MockMutableStateMockRecorder) GetActivityByActivityID(arg0 interface{}) *gomock.Call

GetActivityByActivityID indicates an expected call of GetActivityByActivityID.

func (*MockMutableStateMockRecorder) GetActivityInfo 

func (mr *MockMutableStateMockRecorder) GetActivityInfo(arg0 interface{}) *gomock.Call

GetActivityInfo indicates an expected call of GetActivityInfo.

func (*MockMutableStateMockRecorder) GetActivityInfoWithTimerHeartbeat 

func (mr *MockMutableStateMockRecorder) GetActivityInfoWithTimerHeartbeat(scheduledEventID interface{}) *gomock.Call

GetActivityInfoWithTimerHeartbeat indicates an expected call of GetActivityInfoWithTimerHeartbeat.

func (*MockMutableStateMockRecorder) GetActivityScheduledEvent 

func (mr *MockMutableStateMockRecorder) GetActivityScheduledEvent(arg0, arg1 interface{}) *gomock.Call

GetActivityScheduledEvent indicates an expected call of GetActivityScheduledEvent.

func (*MockMutableStateMockRecorder) GetChildExecutionInfo 

func (mr *MockMutableStateMockRecorder) GetChildExecutionInfo(arg0 interface{}) *gomock.Call

GetChildExecutionInfo indicates an expected call of GetChildExecutionInfo.

func (*MockMutableStateMockRecorder) GetChildExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) GetChildExecutionInitiatedEvent(arg0, arg1 interface{}) *gomock.Call

GetChildExecutionInitiatedEvent indicates an expected call of GetChildExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) GetCompletionEvent 

func (mr *MockMutableStateMockRecorder) GetCompletionEvent(arg0 interface{}) *gomock.Call

GetCompletionEvent indicates an expected call of GetCompletionEvent.

func (*MockMutableStateMockRecorder) GetCronBackoffDuration 

func (mr *MockMutableStateMockRecorder) GetCronBackoffDuration() *gomock.Call

GetCronBackoffDuration indicates an expected call of GetCronBackoffDuration.

func (*MockMutableStateMockRecorder) GetCurrentBranchToken 

func (mr *MockMutableStateMockRecorder) GetCurrentBranchToken() *gomock.Call

GetCurrentBranchToken indicates an expected call of GetCurrentBranchToken.

func (*MockMutableStateMockRecorder) GetCurrentVersion 

func (mr *MockMutableStateMockRecorder) GetCurrentVersion() *gomock.Call

GetCurrentVersion indicates an expected call of GetCurrentVersion.

func (*MockMutableStateMockRecorder) GetExecutionInfo 

func (mr *MockMutableStateMockRecorder) GetExecutionInfo() *gomock.Call

GetExecutionInfo indicates an expected call of GetExecutionInfo.

func (*MockMutableStateMockRecorder) GetExecutionState 

func (mr *MockMutableStateMockRecorder) GetExecutionState() *gomock.Call

GetExecutionState indicates an expected call of GetExecutionState.

func (*MockMutableStateMockRecorder) GetFirstRunID added in v1.13.0 

func (mr *MockMutableStateMockRecorder) GetFirstRunID() *gomock.Call

GetFirstRunID indicates an expected call of GetFirstRunID.

func (*MockMutableStateMockRecorder) GetInFlightWorkflowTask 

func (mr *MockMutableStateMockRecorder) GetInFlightWorkflowTask() *gomock.Call

GetInFlightWorkflowTask indicates an expected call of GetInFlightWorkflowTask.

func (*MockMutableStateMockRecorder) GetLastFirstEventIDTxnID 

func (mr *MockMutableStateMockRecorder) GetLastFirstEventIDTxnID() *gomock.Call

GetLastFirstEventIDTxnID indicates an expected call of GetLastFirstEventIDTxnID.

func (*MockMutableStateMockRecorder) GetLastWriteVersion 

func (mr *MockMutableStateMockRecorder) GetLastWriteVersion() *gomock.Call

GetLastWriteVersion indicates an expected call of GetLastWriteVersion.

func (*MockMutableStateMockRecorder) GetNamespaceEntry 

func (mr *MockMutableStateMockRecorder) GetNamespaceEntry() *gomock.Call

GetNamespaceEntry indicates an expected call of GetNamespaceEntry.

func (*MockMutableStateMockRecorder) GetNextEventID 

func (mr *MockMutableStateMockRecorder) GetNextEventID() *gomock.Call

GetNextEventID indicates an expected call of GetNextEventID.

func (*MockMutableStateMockRecorder) GetPendingActivityInfos 

func (mr *MockMutableStateMockRecorder) GetPendingActivityInfos() *gomock.Call

GetPendingActivityInfos indicates an expected call of GetPendingActivityInfos.

func (*MockMutableStateMockRecorder) GetPendingChildExecutionInfos 

func (mr *MockMutableStateMockRecorder) GetPendingChildExecutionInfos() *gomock.Call

GetPendingChildExecutionInfos indicates an expected call of GetPendingChildExecutionInfos.

func (*MockMutableStateMockRecorder) GetPendingRequestCancelExternalInfos 

func (mr *MockMutableStateMockRecorder) GetPendingRequestCancelExternalInfos() *gomock.Call

GetPendingRequestCancelExternalInfos indicates an expected call of GetPendingRequestCancelExternalInfos.

func (*MockMutableStateMockRecorder) GetPendingSignalExternalInfos 

func (mr *MockMutableStateMockRecorder) GetPendingSignalExternalInfos() *gomock.Call

GetPendingSignalExternalInfos indicates an expected call of GetPendingSignalExternalInfos.

func (*MockMutableStateMockRecorder) GetPendingTimerInfos 

func (mr *MockMutableStateMockRecorder) GetPendingTimerInfos() *gomock.Call

GetPendingTimerInfos indicates an expected call of GetPendingTimerInfos.

func (*MockMutableStateMockRecorder) GetPendingWorkflowTask 

func (mr *MockMutableStateMockRecorder) GetPendingWorkflowTask() *gomock.Call

GetPendingWorkflowTask indicates an expected call of GetPendingWorkflowTask.

func (*MockMutableStateMockRecorder) GetPreviousStartedEventID 

func (mr *MockMutableStateMockRecorder) GetPreviousStartedEventID() *gomock.Call

GetPreviousStartedEventID indicates an expected call of GetPreviousStartedEventID.

func (*MockMutableStateMockRecorder) GetQueryRegistry 

func (mr *MockMutableStateMockRecorder) GetQueryRegistry() *gomock.Call

GetQueryRegistry indicates an expected call of GetQueryRegistry.

func (*MockMutableStateMockRecorder) GetRequestCancelInfo 

func (mr *MockMutableStateMockRecorder) GetRequestCancelInfo(arg0 interface{}) *gomock.Call

GetRequestCancelInfo indicates an expected call of GetRequestCancelInfo.

func (*MockMutableStateMockRecorder) GetRequesteCancelExternalInitiatedEvent added in v1.16.0 

func (mr *MockMutableStateMockRecorder) GetRequesteCancelExternalInitiatedEvent(arg0, arg1 interface{}) *gomock.Call

GetRequesteCancelExternalInitiatedEvent indicates an expected call of GetRequesteCancelExternalInitiatedEvent.

func (*MockMutableStateMockRecorder) GetRetryBackoffDuration 

func (mr *MockMutableStateMockRecorder) GetRetryBackoffDuration(failure interface{}) *gomock.Call

GetRetryBackoffDuration indicates an expected call of GetRetryBackoffDuration.

func (*MockMutableStateMockRecorder) GetSignalExternalInitiatedEvent added in v1.14.0 

func (mr *MockMutableStateMockRecorder) GetSignalExternalInitiatedEvent(arg0, arg1 interface{}) *gomock.Call

GetSignalExternalInitiatedEvent indicates an expected call of GetSignalExternalInitiatedEvent.

func (*MockMutableStateMockRecorder) GetSignalInfo 

func (mr *MockMutableStateMockRecorder) GetSignalInfo(arg0 interface{}) *gomock.Call

GetSignalInfo indicates an expected call of GetSignalInfo.

func (*MockMutableStateMockRecorder) GetStartEvent 

func (mr *MockMutableStateMockRecorder) GetStartEvent(arg0 interface{}) *gomock.Call

GetStartEvent indicates an expected call of GetStartEvent.

func (*MockMutableStateMockRecorder) GetStartVersion 

func (mr *MockMutableStateMockRecorder) GetStartVersion() *gomock.Call

GetStartVersion indicates an expected call of GetStartVersion.

func (*MockMutableStateMockRecorder) GetUpdateCondition 

func (mr *MockMutableStateMockRecorder) GetUpdateCondition() *gomock.Call

GetUpdateCondition indicates an expected call of GetUpdateCondition.

func (*MockMutableStateMockRecorder) GetUserTimerInfo 

func (mr *MockMutableStateMockRecorder) GetUserTimerInfo(arg0 interface{}) *gomock.Call

GetUserTimerInfo indicates an expected call of GetUserTimerInfo.

func (*MockMutableStateMockRecorder) GetUserTimerInfoByEventID 

func (mr *MockMutableStateMockRecorder) GetUserTimerInfoByEventID(arg0 interface{}) *gomock.Call

GetUserTimerInfoByEventID indicates an expected call of GetUserTimerInfoByEventID.

func (*MockMutableStateMockRecorder) GetWorkflowCloseTime added in v1.17.0 

func (mr *MockMutableStateMockRecorder) GetWorkflowCloseTime(ctx interface{}) *gomock.Call

GetWorkflowCloseTime indicates an expected call of GetWorkflowCloseTime.

func (*MockMutableStateMockRecorder) GetWorkflowKey added in v1.14.0 

func (mr *MockMutableStateMockRecorder) GetWorkflowKey() *gomock.Call

GetWorkflowKey indicates an expected call of GetWorkflowKey.

func (*MockMutableStateMockRecorder) GetWorkflowStateStatus 

func (mr *MockMutableStateMockRecorder) GetWorkflowStateStatus() *gomock.Call

GetWorkflowStateStatus indicates an expected call of GetWorkflowStateStatus.

func (*MockMutableStateMockRecorder) GetWorkflowTaskInfo 

func (mr *MockMutableStateMockRecorder) GetWorkflowTaskInfo(arg0 interface{}) *gomock.Call

GetWorkflowTaskInfo indicates an expected call of GetWorkflowTaskInfo.

func (*MockMutableStateMockRecorder) GetWorkflowType 

func (mr *MockMutableStateMockRecorder) GetWorkflowType() *gomock.Call

GetWorkflowType indicates an expected call of GetWorkflowType.

func (*MockMutableStateMockRecorder) HasBufferedEvents 

func (mr *MockMutableStateMockRecorder) HasBufferedEvents() *gomock.Call

HasBufferedEvents indicates an expected call of HasBufferedEvents.

func (*MockMutableStateMockRecorder) HasInFlightWorkflowTask 

func (mr *MockMutableStateMockRecorder) HasInFlightWorkflowTask() *gomock.Call

HasInFlightWorkflowTask indicates an expected call of HasInFlightWorkflowTask.

func (*MockMutableStateMockRecorder) HasParentExecution 

func (mr *MockMutableStateMockRecorder) HasParentExecution() *gomock.Call

HasParentExecution indicates an expected call of HasParentExecution.

func (*MockMutableStateMockRecorder) HasPendingWorkflowTask 

func (mr *MockMutableStateMockRecorder) HasPendingWorkflowTask() *gomock.Call

HasPendingWorkflowTask indicates an expected call of HasPendingWorkflowTask.

func (*MockMutableStateMockRecorder) HasProcessedOrPendingWorkflowTask 

func (mr *MockMutableStateMockRecorder) HasProcessedOrPendingWorkflowTask() *gomock.Call

HasProcessedOrPendingWorkflowTask indicates an expected call of HasProcessedOrPendingWorkflowTask.

func (*MockMutableStateMockRecorder) HasTransientWorkflowTask added in v1.16.3 

func (mr *MockMutableStateMockRecorder) HasTransientWorkflowTask() *gomock.Call

HasTransientWorkflowTask indicates an expected call of HasTransientWorkflowTask.

func (*MockMutableStateMockRecorder) IsCancelRequested 

func (mr *MockMutableStateMockRecorder) IsCancelRequested() *gomock.Call

IsCancelRequested indicates an expected call of IsCancelRequested.

func (*MockMutableStateMockRecorder) IsCurrentWorkflowGuaranteed 

func (mr *MockMutableStateMockRecorder) IsCurrentWorkflowGuaranteed() *gomock.Call

IsCurrentWorkflowGuaranteed indicates an expected call of IsCurrentWorkflowGuaranteed.

func (*MockMutableStateMockRecorder) IsResourceDuplicated 

func (mr *MockMutableStateMockRecorder) IsResourceDuplicated(resourceDedupKey interface{}) *gomock.Call

IsResourceDuplicated indicates an expected call of IsResourceDuplicated.

func (*MockMutableStateMockRecorder) IsSignalRequested 

func (mr *MockMutableStateMockRecorder) IsSignalRequested(requestID interface{}) *gomock.Call

IsSignalRequested indicates an expected call of IsSignalRequested.

func (*MockMutableStateMockRecorder) IsStickyTaskQueueEnabled 

func (mr *MockMutableStateMockRecorder) IsStickyTaskQueueEnabled() *gomock.Call

IsStickyTaskQueueEnabled indicates an expected call of IsStickyTaskQueueEnabled.

func (*MockMutableStateMockRecorder) IsWorkflowExecutionRunning 

func (mr *MockMutableStateMockRecorder) IsWorkflowExecutionRunning() *gomock.Call

IsWorkflowExecutionRunning indicates an expected call of IsWorkflowExecutionRunning.

func (*MockMutableStateMockRecorder) IsWorkflowPendingOnWorkflowTaskBackoff added in v1.16.3 

func (mr *MockMutableStateMockRecorder) IsWorkflowPendingOnWorkflowTaskBackoff() *gomock.Call

IsWorkflowPendingOnWorkflowTaskBackoff indicates an expected call of IsWorkflowPendingOnWorkflowTaskBackoff.

func (*MockMutableStateMockRecorder) PopTasks added in v1.17.0 

func (mr *MockMutableStateMockRecorder) PopTasks() *gomock.Call

PopTasks indicates an expected call of PopTasks.

func (*MockMutableStateMockRecorder) ReplicateActivityInfo 

func (mr *MockMutableStateMockRecorder) ReplicateActivityInfo(arg0, arg1 interface{}) *gomock.Call

ReplicateActivityInfo indicates an expected call of ReplicateActivityInfo.

func (*MockMutableStateMockRecorder) ReplicateActivityTaskCancelRequestedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateActivityTaskCancelRequestedEvent(arg0 interface{}) *gomock.Call

ReplicateActivityTaskCancelRequestedEvent indicates an expected call of ReplicateActivityTaskCancelRequestedEvent.

func (*MockMutableStateMockRecorder) ReplicateActivityTaskCanceledEvent 

func (mr *MockMutableStateMockRecorder) ReplicateActivityTaskCanceledEvent(arg0 interface{}) *gomock.Call

ReplicateActivityTaskCanceledEvent indicates an expected call of ReplicateActivityTaskCanceledEvent.

func (*MockMutableStateMockRecorder) ReplicateActivityTaskCompletedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateActivityTaskCompletedEvent(arg0 interface{}) *gomock.Call

ReplicateActivityTaskCompletedEvent indicates an expected call of ReplicateActivityTaskCompletedEvent.

func (*MockMutableStateMockRecorder) ReplicateActivityTaskFailedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateActivityTaskFailedEvent(arg0 interface{}) *gomock.Call

ReplicateActivityTaskFailedEvent indicates an expected call of ReplicateActivityTaskFailedEvent.

func (*MockMutableStateMockRecorder) ReplicateActivityTaskScheduledEvent 

func (mr *MockMutableStateMockRecorder) ReplicateActivityTaskScheduledEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateActivityTaskScheduledEvent indicates an expected call of ReplicateActivityTaskScheduledEvent.

func (*MockMutableStateMockRecorder) ReplicateActivityTaskStartedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateActivityTaskStartedEvent(arg0 interface{}) *gomock.Call

ReplicateActivityTaskStartedEvent indicates an expected call of ReplicateActivityTaskStartedEvent.

func (*MockMutableStateMockRecorder) ReplicateActivityTaskTimedOutEvent 

func (mr *MockMutableStateMockRecorder) ReplicateActivityTaskTimedOutEvent(arg0 interface{}) *gomock.Call

ReplicateActivityTaskTimedOutEvent indicates an expected call of ReplicateActivityTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionCanceledEvent 

func (mr *MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionCanceledEvent(arg0 interface{}) *gomock.Call

ReplicateChildWorkflowExecutionCanceledEvent indicates an expected call of ReplicateChildWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionCompletedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionCompletedEvent(arg0 interface{}) *gomock.Call

ReplicateChildWorkflowExecutionCompletedEvent indicates an expected call of ReplicateChildWorkflowExecutionCompletedEvent.

func (*MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionFailedEvent(arg0 interface{}) *gomock.Call

ReplicateChildWorkflowExecutionFailedEvent indicates an expected call of ReplicateChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionStartedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionStartedEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateChildWorkflowExecutionStartedEvent indicates an expected call of ReplicateChildWorkflowExecutionStartedEvent.

func (*MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionTerminatedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionTerminatedEvent(arg0 interface{}) *gomock.Call

ReplicateChildWorkflowExecutionTerminatedEvent indicates an expected call of ReplicateChildWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionTimedOutEvent 

func (mr *MockMutableStateMockRecorder) ReplicateChildWorkflowExecutionTimedOutEvent(arg0 interface{}) *gomock.Call

ReplicateChildWorkflowExecutionTimedOutEvent indicates an expected call of ReplicateChildWorkflowExecutionTimedOutEvent.

func (*MockMutableStateMockRecorder) ReplicateExternalWorkflowExecutionCancelRequested 

func (mr *MockMutableStateMockRecorder) ReplicateExternalWorkflowExecutionCancelRequested(arg0 interface{}) *gomock.Call

ReplicateExternalWorkflowExecutionCancelRequested indicates an expected call of ReplicateExternalWorkflowExecutionCancelRequested.

func (*MockMutableStateMockRecorder) ReplicateExternalWorkflowExecutionSignaled 

func (mr *MockMutableStateMockRecorder) ReplicateExternalWorkflowExecutionSignaled(arg0 interface{}) *gomock.Call

ReplicateExternalWorkflowExecutionSignaled indicates an expected call of ReplicateExternalWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) ReplicateRequestCancelExternalWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateRequestCancelExternalWorkflowExecutionFailedEvent(arg0 interface{}) *gomock.Call

ReplicateRequestCancelExternalWorkflowExecutionFailedEvent indicates an expected call of ReplicateRequestCancelExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent indicates an expected call of ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) ReplicateSignalExternalWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateSignalExternalWorkflowExecutionFailedEvent(arg0 interface{}) *gomock.Call

ReplicateSignalExternalWorkflowExecutionFailedEvent indicates an expected call of ReplicateSignalExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ReplicateSignalExternalWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateSignalExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

ReplicateSignalExternalWorkflowExecutionInitiatedEvent indicates an expected call of ReplicateSignalExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) ReplicateStartChildWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateStartChildWorkflowExecutionFailedEvent(arg0 interface{}) *gomock.Call

ReplicateStartChildWorkflowExecutionFailedEvent indicates an expected call of ReplicateStartChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ReplicateStartChildWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateStartChildWorkflowExecutionInitiatedEvent(arg0, arg1, arg2 interface{}) *gomock.Call

ReplicateStartChildWorkflowExecutionInitiatedEvent indicates an expected call of ReplicateStartChildWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) ReplicateTimerCanceledEvent 

func (mr *MockMutableStateMockRecorder) ReplicateTimerCanceledEvent(arg0 interface{}) *gomock.Call

ReplicateTimerCanceledEvent indicates an expected call of ReplicateTimerCanceledEvent.

func (*MockMutableStateMockRecorder) ReplicateTimerFiredEvent 

func (mr *MockMutableStateMockRecorder) ReplicateTimerFiredEvent(arg0 interface{}) *gomock.Call

ReplicateTimerFiredEvent indicates an expected call of ReplicateTimerFiredEvent.

func (*MockMutableStateMockRecorder) ReplicateTimerStartedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateTimerStartedEvent(arg0 interface{}) *gomock.Call

ReplicateTimerStartedEvent indicates an expected call of ReplicateTimerStartedEvent.

func (*MockMutableStateMockRecorder) ReplicateTransientWorkflowTaskScheduled 

func (mr *MockMutableStateMockRecorder) ReplicateTransientWorkflowTaskScheduled() *gomock.Call

ReplicateTransientWorkflowTaskScheduled indicates an expected call of ReplicateTransientWorkflowTaskScheduled.

func (*MockMutableStateMockRecorder) ReplicateUpsertWorkflowSearchAttributesEvent 

func (mr *MockMutableStateMockRecorder) ReplicateUpsertWorkflowSearchAttributesEvent(arg0 interface{}) *gomock.Call

ReplicateUpsertWorkflowSearchAttributesEvent indicates an expected call of ReplicateUpsertWorkflowSearchAttributesEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionCancelRequestedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionCancelRequestedEvent(arg0 interface{}) *gomock.Call

ReplicateWorkflowExecutionCancelRequestedEvent indicates an expected call of ReplicateWorkflowExecutionCancelRequestedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionCanceledEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionCanceledEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateWorkflowExecutionCanceledEvent indicates an expected call of ReplicateWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionCompletedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionCompletedEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateWorkflowExecutionCompletedEvent indicates an expected call of ReplicateWorkflowExecutionCompletedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionContinuedAsNewEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionContinuedAsNewEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateWorkflowExecutionContinuedAsNewEvent indicates an expected call of ReplicateWorkflowExecutionContinuedAsNewEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionFailedEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateWorkflowExecutionFailedEvent indicates an expected call of ReplicateWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionSignaled 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionSignaled(arg0 interface{}) *gomock.Call

ReplicateWorkflowExecutionSignaled indicates an expected call of ReplicateWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionStartedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionStartedEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

ReplicateWorkflowExecutionStartedEvent indicates an expected call of ReplicateWorkflowExecutionStartedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionTerminatedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionTerminatedEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateWorkflowExecutionTerminatedEvent indicates an expected call of ReplicateWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowExecutionTimedoutEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowExecutionTimedoutEvent(arg0, arg1 interface{}) *gomock.Call

ReplicateWorkflowExecutionTimedoutEvent indicates an expected call of ReplicateWorkflowExecutionTimedoutEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowTaskCompletedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowTaskCompletedEvent(arg0 interface{}) *gomock.Call

ReplicateWorkflowTaskCompletedEvent indicates an expected call of ReplicateWorkflowTaskCompletedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowTaskFailedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowTaskFailedEvent() *gomock.Call

ReplicateWorkflowTaskFailedEvent indicates an expected call of ReplicateWorkflowTaskFailedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowTaskScheduledEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowTaskScheduledEvent(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

ReplicateWorkflowTaskScheduledEvent indicates an expected call of ReplicateWorkflowTaskScheduledEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowTaskStartedEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowTaskStartedEvent(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

ReplicateWorkflowTaskStartedEvent indicates an expected call of ReplicateWorkflowTaskStartedEvent.

func (*MockMutableStateMockRecorder) ReplicateWorkflowTaskTimedOutEvent 

func (mr *MockMutableStateMockRecorder) ReplicateWorkflowTaskTimedOutEvent(arg0 interface{}) *gomock.Call

ReplicateWorkflowTaskTimedOutEvent indicates an expected call of ReplicateWorkflowTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) RetryActivity 

func (mr *MockMutableStateMockRecorder) RetryActivity(ai, failure interface{}) *gomock.Call

RetryActivity indicates an expected call of RetryActivity.

func (*MockMutableStateMockRecorder) SetCurrentBranchToken 

func (mr *MockMutableStateMockRecorder) SetCurrentBranchToken(branchToken interface{}) *gomock.Call

SetCurrentBranchToken indicates an expected call of SetCurrentBranchToken.

func (*MockMutableStateMockRecorder) SetHistoryBuilder 

func (mr *MockMutableStateMockRecorder) SetHistoryBuilder(hBuilder interface{}) *gomock.Call

SetHistoryBuilder indicates an expected call of SetHistoryBuilder.

func (*MockMutableStateMockRecorder) SetHistoryTree 

func (mr *MockMutableStateMockRecorder) SetHistoryTree(treeID interface{}) *gomock.Call

SetHistoryTree indicates an expected call of SetHistoryTree.

func (*MockMutableStateMockRecorder) SetUpdateCondition 

func (mr *MockMutableStateMockRecorder) SetUpdateCondition(arg0, arg1 interface{}) *gomock.Call

SetUpdateCondition indicates an expected call of SetUpdateCondition.

func (*MockMutableStateMockRecorder) StartTransaction 

func (mr *MockMutableStateMockRecorder) StartTransaction(entry interface{}) *gomock.Call

StartTransaction indicates an expected call of StartTransaction.

func (*MockMutableStateMockRecorder) UpdateActivity 

func (mr *MockMutableStateMockRecorder) UpdateActivity(arg0 interface{}) *gomock.Call

UpdateActivity indicates an expected call of UpdateActivity.

func (*MockMutableStateMockRecorder) UpdateActivityProgress 

func (mr *MockMutableStateMockRecorder) UpdateActivityProgress(ai, request interface{}) *gomock.Call

UpdateActivityProgress indicates an expected call of UpdateActivityProgress.

func (*MockMutableStateMockRecorder) UpdateActivityWithTimerHeartbeat 

func (mr *MockMutableStateMockRecorder) UpdateActivityWithTimerHeartbeat(arg0, arg1 interface{}) *gomock.Call

UpdateActivityWithTimerHeartbeat indicates an expected call of UpdateActivityWithTimerHeartbeat.

func (*MockMutableStateMockRecorder) UpdateCurrentVersion 

func (mr *MockMutableStateMockRecorder) UpdateCurrentVersion(version, forceUpdate interface{}) *gomock.Call

UpdateCurrentVersion indicates an expected call of UpdateCurrentVersion.

func (*MockMutableStateMockRecorder) UpdateDuplicatedResource 

func (mr *MockMutableStateMockRecorder) UpdateDuplicatedResource(resourceDedupKey interface{}) *gomock.Call

UpdateDuplicatedResource indicates an expected call of UpdateDuplicatedResource.

func (*MockMutableStateMockRecorder) UpdateUserTimer 

func (mr *MockMutableStateMockRecorder) UpdateUserTimer(arg0 interface{}) *gomock.Call

UpdateUserTimer indicates an expected call of UpdateUserTimer.

func (*MockMutableStateMockRecorder) UpdateWorkflowStateStatus 

func (mr *MockMutableStateMockRecorder) UpdateWorkflowStateStatus(state, status interface{}) *gomock.Call

UpdateWorkflowStateStatus indicates an expected call of UpdateWorkflowStateStatus.

type MockMutableStateRebuilder 

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

MockMutableStateRebuilder is a mock of MutableStateRebuilder interface.

func NewMockMutableStateRebuilder 

func NewMockMutableStateRebuilder(ctrl *gomock.Controller) *MockMutableStateRebuilder

NewMockMutableStateRebuilder creates a new mock instance.

func (*MockMutableStateRebuilder) ApplyEvents 

func (m *MockMutableStateRebuilder) ApplyEvents(namespaceID namespace.ID, requestID string, execution v1.WorkflowExecution, history, newRunHistory []*v10.HistoryEvent) (MutableState, error)

ApplyEvents mocks base method.

func (*MockMutableStateRebuilder) EXPECT 

func (m *MockMutableStateRebuilder) EXPECT() *MockMutableStateRebuilderMockRecorder

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

type MockMutableStateRebuilderMockRecorder 

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

MockMutableStateRebuilderMockRecorder is the mock recorder for MockMutableStateRebuilder.

func (*MockMutableStateRebuilderMockRecorder) ApplyEvents 

func (mr *MockMutableStateRebuilderMockRecorder) ApplyEvents(namespaceID, requestID, execution, history, newRunHistory interface{}) *gomock.Call

ApplyEvents indicates an expected call of ApplyEvents.

type MockTaskGenerator 

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

MockTaskGenerator is a mock of TaskGenerator interface.

func NewMockTaskGenerator 

func NewMockTaskGenerator(ctrl *gomock.Controller) *MockTaskGenerator

NewMockTaskGenerator creates a new mock instance.

func (*MockTaskGenerator) EXPECT 

func (m *MockTaskGenerator) EXPECT() *MockTaskGeneratorMockRecorder

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

func (*MockTaskGenerator) GenerateActivityRetryTasks 

func (m *MockTaskGenerator) GenerateActivityRetryTasks(activityScheduledEventID int64) error

GenerateActivityRetryTasks mocks base method.

func (*MockTaskGenerator) GenerateActivityTasks added in v1.16.0 

func (m *MockTaskGenerator) GenerateActivityTasks(now time.Time, event *history.HistoryEvent) error

GenerateActivityTasks mocks base method.

func (*MockTaskGenerator) GenerateActivityTimerTasks 

func (m *MockTaskGenerator) GenerateActivityTimerTasks(now time.Time) error

GenerateActivityTimerTasks mocks base method.

func (*MockTaskGenerator) GenerateChildWorkflowTasks 

func (m *MockTaskGenerator) GenerateChildWorkflowTasks(now time.Time, event *history.HistoryEvent) error

GenerateChildWorkflowTasks mocks base method.

func (*MockTaskGenerator) GenerateDelayedWorkflowTasks 

func (m *MockTaskGenerator) GenerateDelayedWorkflowTasks(now time.Time, startEvent *history.HistoryEvent) error

GenerateDelayedWorkflowTasks mocks base method.

func (*MockTaskGenerator) GenerateDeleteExecutionTask added in v1.15.0 

func (m *MockTaskGenerator) GenerateDeleteExecutionTask(now time.Time) (*tasks.DeleteExecutionTask, error)

GenerateDeleteExecutionTask mocks base method.

func (*MockTaskGenerator) GenerateHistoryReplicationTasks added in v1.14.0 

func (m *MockTaskGenerator) GenerateHistoryReplicationTasks(now time.Time, branchToken []byte, events []*history.HistoryEvent) error

GenerateHistoryReplicationTasks mocks base method.

func (*MockTaskGenerator) GenerateMigrationTasks added in v1.17.0 

func (m *MockTaskGenerator) GenerateMigrationTasks(now time.Time) (tasks.Task, error)

GenerateMigrationTasks mocks base method.

func (*MockTaskGenerator) GenerateRecordWorkflowStartedTasks 

func (m *MockTaskGenerator) GenerateRecordWorkflowStartedTasks(now time.Time, startEvent *history.HistoryEvent) error

GenerateRecordWorkflowStartedTasks mocks base method.

func (*MockTaskGenerator) GenerateRequestCancelExternalTasks 

func (m *MockTaskGenerator) GenerateRequestCancelExternalTasks(now time.Time, event *history.HistoryEvent) error

GenerateRequestCancelExternalTasks mocks base method.

func (*MockTaskGenerator) GenerateScheduleWorkflowTaskTasks 

func (m *MockTaskGenerator) GenerateScheduleWorkflowTaskTasks(now time.Time, workflowTaskScheduledEventID int64) error

GenerateScheduleWorkflowTaskTasks mocks base method.

func (*MockTaskGenerator) GenerateSignalExternalTasks 

func (m *MockTaskGenerator) GenerateSignalExternalTasks(now time.Time, event *history.HistoryEvent) error

GenerateSignalExternalTasks mocks base method.

func (*MockTaskGenerator) GenerateStartWorkflowTaskTasks 

func (m *MockTaskGenerator) GenerateStartWorkflowTaskTasks(now time.Time, workflowTaskScheduledEventID int64) error

GenerateStartWorkflowTaskTasks mocks base method.

func (*MockTaskGenerator) GenerateUserTimerTasks 

func (m *MockTaskGenerator) GenerateUserTimerTasks(now time.Time) error

GenerateUserTimerTasks mocks base method.

func (*MockTaskGenerator) GenerateWorkflowCloseTasks 

func (m *MockTaskGenerator) GenerateWorkflowCloseTasks(now time.Time, deleteAfterClose bool) error

GenerateWorkflowCloseTasks mocks base method.

func (*MockTaskGenerator) GenerateWorkflowResetTasks 

func (m *MockTaskGenerator) GenerateWorkflowResetTasks(now time.Time) error

GenerateWorkflowResetTasks mocks base method.

func (*MockTaskGenerator) GenerateWorkflowSearchAttrTasks 

func (m *MockTaskGenerator) GenerateWorkflowSearchAttrTasks(now time.Time) error

GenerateWorkflowSearchAttrTasks mocks base method.

func (*MockTaskGenerator) GenerateWorkflowStartTasks 

func (m *MockTaskGenerator) GenerateWorkflowStartTasks(now time.Time, startEvent *history.HistoryEvent) error

GenerateWorkflowStartTasks mocks base method.

type MockTaskGeneratorMockRecorder 

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

MockTaskGeneratorMockRecorder is the mock recorder for MockTaskGenerator.

func (*MockTaskGeneratorMockRecorder) GenerateActivityRetryTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateActivityRetryTasks(activityScheduledEventID interface{}) *gomock.Call

GenerateActivityRetryTasks indicates an expected call of GenerateActivityRetryTasks.

func (*MockTaskGeneratorMockRecorder) GenerateActivityTasks added in v1.16.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateActivityTasks(now, event interface{}) *gomock.Call

GenerateActivityTasks indicates an expected call of GenerateActivityTasks.

func (*MockTaskGeneratorMockRecorder) GenerateActivityTimerTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateActivityTimerTasks(now interface{}) *gomock.Call

GenerateActivityTimerTasks indicates an expected call of GenerateActivityTimerTasks.

func (*MockTaskGeneratorMockRecorder) GenerateChildWorkflowTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateChildWorkflowTasks(now, event interface{}) *gomock.Call

GenerateChildWorkflowTasks indicates an expected call of GenerateChildWorkflowTasks.

func (*MockTaskGeneratorMockRecorder) GenerateDelayedWorkflowTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateDelayedWorkflowTasks(now, startEvent interface{}) *gomock.Call

GenerateDelayedWorkflowTasks indicates an expected call of GenerateDelayedWorkflowTasks.

func (*MockTaskGeneratorMockRecorder) GenerateDeleteExecutionTask added in v1.15.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateDeleteExecutionTask(now interface{}) *gomock.Call

GenerateDeleteExecutionTask indicates an expected call of GenerateDeleteExecutionTask.

func (*MockTaskGeneratorMockRecorder) GenerateHistoryReplicationTasks added in v1.14.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateHistoryReplicationTasks(now, branchToken, events interface{}) *gomock.Call

GenerateHistoryReplicationTasks indicates an expected call of GenerateHistoryReplicationTasks.

func (*MockTaskGeneratorMockRecorder) GenerateMigrationTasks added in v1.17.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateMigrationTasks(now interface{}) *gomock.Call

GenerateMigrationTasks indicates an expected call of GenerateMigrationTasks.

func (*MockTaskGeneratorMockRecorder) GenerateRecordWorkflowStartedTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateRecordWorkflowStartedTasks(now, startEvent interface{}) *gomock.Call

GenerateRecordWorkflowStartedTasks indicates an expected call of GenerateRecordWorkflowStartedTasks.

func (*MockTaskGeneratorMockRecorder) GenerateRequestCancelExternalTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateRequestCancelExternalTasks(now, event interface{}) *gomock.Call

GenerateRequestCancelExternalTasks indicates an expected call of GenerateRequestCancelExternalTasks.

func (*MockTaskGeneratorMockRecorder) GenerateScheduleWorkflowTaskTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateScheduleWorkflowTaskTasks(now, workflowTaskScheduledEventID interface{}) *gomock.Call

GenerateScheduleWorkflowTaskTasks indicates an expected call of GenerateScheduleWorkflowTaskTasks.

func (*MockTaskGeneratorMockRecorder) GenerateSignalExternalTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateSignalExternalTasks(now, event interface{}) *gomock.Call

GenerateSignalExternalTasks indicates an expected call of GenerateSignalExternalTasks.

func (*MockTaskGeneratorMockRecorder) GenerateStartWorkflowTaskTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateStartWorkflowTaskTasks(now, workflowTaskScheduledEventID interface{}) *gomock.Call

GenerateStartWorkflowTaskTasks indicates an expected call of GenerateStartWorkflowTaskTasks.

func (*MockTaskGeneratorMockRecorder) GenerateUserTimerTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateUserTimerTasks(now interface{}) *gomock.Call

GenerateUserTimerTasks indicates an expected call of GenerateUserTimerTasks.

func (*MockTaskGeneratorMockRecorder) GenerateWorkflowCloseTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateWorkflowCloseTasks(now, deleteAfterClose interface{}) *gomock.Call

GenerateWorkflowCloseTasks indicates an expected call of GenerateWorkflowCloseTasks.

func (*MockTaskGeneratorMockRecorder) GenerateWorkflowResetTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateWorkflowResetTasks(now interface{}) *gomock.Call

GenerateWorkflowResetTasks indicates an expected call of GenerateWorkflowResetTasks.

func (*MockTaskGeneratorMockRecorder) GenerateWorkflowSearchAttrTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateWorkflowSearchAttrTasks(now interface{}) *gomock.Call

GenerateWorkflowSearchAttrTasks indicates an expected call of GenerateWorkflowSearchAttrTasks.

func (*MockTaskGeneratorMockRecorder) GenerateWorkflowStartTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateWorkflowStartTasks(now, startEvent interface{}) *gomock.Call

GenerateWorkflowStartTasks indicates an expected call of GenerateWorkflowStartTasks.

type MockTaskRefresher 

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

MockTaskRefresher is a mock of TaskRefresher interface.

func NewMockTaskRefresher 

func NewMockTaskRefresher(ctrl *gomock.Controller) *MockTaskRefresher

NewMockTaskRefresher creates a new mock instance.

func (*MockTaskRefresher) EXPECT 

func (m *MockTaskRefresher) EXPECT() *MockTaskRefresherMockRecorder

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

func (*MockTaskRefresher) RefreshTasks 

func (m *MockTaskRefresher) RefreshTasks(ctx context.Context, now time.Time, mutableState MutableState) error

RefreshTasks mocks base method.

type MockTaskRefresherMockRecorder 

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

MockTaskRefresherMockRecorder is the mock recorder for MockTaskRefresher.

func (*MockTaskRefresherMockRecorder) RefreshTasks 

func (mr *MockTaskRefresherMockRecorder) RefreshTasks(ctx, now, mutableState interface{}) *gomock.Call

RefreshTasks indicates an expected call of RefreshTasks.

type MockTimerSequence 

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

MockTimerSequence is a mock of TimerSequence interface.

func NewMockTimerSequence 

func NewMockTimerSequence(ctrl *gomock.Controller) *MockTimerSequence

NewMockTimerSequence creates a new mock instance.

func (*MockTimerSequence) CreateNextActivityTimer 

func (m *MockTimerSequence) CreateNextActivityTimer() (bool, error)

CreateNextActivityTimer mocks base method.

func (*MockTimerSequence) CreateNextUserTimer 

func (m *MockTimerSequence) CreateNextUserTimer() (bool, error)

CreateNextUserTimer mocks base method.

func (*MockTimerSequence) EXPECT 

func (m *MockTimerSequence) EXPECT() *MockTimerSequenceMockRecorder

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

func (*MockTimerSequence) IsExpired 

func (m *MockTimerSequence) IsExpired(referenceTime time.Time, timerSequenceID TimerSequenceID) bool

IsExpired mocks base method.

func (*MockTimerSequence) LoadAndSortActivityTimers 

func (m *MockTimerSequence) LoadAndSortActivityTimers() []TimerSequenceID

LoadAndSortActivityTimers mocks base method.

func (*MockTimerSequence) LoadAndSortUserTimers 

func (m *MockTimerSequence) LoadAndSortUserTimers() []TimerSequenceID

LoadAndSortUserTimers mocks base method.

type MockTimerSequenceMockRecorder 

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

MockTimerSequenceMockRecorder is the mock recorder for MockTimerSequence.

func (*MockTimerSequenceMockRecorder) CreateNextActivityTimer 

func (mr *MockTimerSequenceMockRecorder) CreateNextActivityTimer() *gomock.Call

CreateNextActivityTimer indicates an expected call of CreateNextActivityTimer.

func (*MockTimerSequenceMockRecorder) CreateNextUserTimer 

func (mr *MockTimerSequenceMockRecorder) CreateNextUserTimer() *gomock.Call

CreateNextUserTimer indicates an expected call of CreateNextUserTimer.

func (*MockTimerSequenceMockRecorder) IsExpired 

func (mr *MockTimerSequenceMockRecorder) IsExpired(referenceTime, timerSequenceID interface{}) *gomock.Call

IsExpired indicates an expected call of IsExpired.

func (*MockTimerSequenceMockRecorder) LoadAndSortActivityTimers 

func (mr *MockTimerSequenceMockRecorder) LoadAndSortActivityTimers() *gomock.Call

LoadAndSortActivityTimers indicates an expected call of LoadAndSortActivityTimers.

func (*MockTimerSequenceMockRecorder) LoadAndSortUserTimers 

func (mr *MockTimerSequenceMockRecorder) LoadAndSortUserTimers() *gomock.Call

LoadAndSortUserTimers indicates an expected call of LoadAndSortUserTimers.

type MockTransaction added in v1.12.0 

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

MockTransaction is a mock of Transaction interface.

func NewMockTransaction added in v1.12.0 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) ConflictResolveWorkflowExecution added in v1.12.0 

func (m *MockTransaction) ConflictResolveWorkflowExecution(ctx context.Context, conflictResolveMode persistence.ConflictResolveWorkflowMode, resetWorkflowSnapshot *persistence.WorkflowSnapshot, resetWorkflowEventsSeq []*persistence.WorkflowEvents, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents, currentWorkflowMutation *persistence.WorkflowMutation, currentWorkflowEventsSeq []*persistence.WorkflowEvents, clusterName string) (int64, int64, int64, error)

ConflictResolveWorkflowExecution mocks base method.

func (*MockTransaction) CreateWorkflowExecution added in v1.12.0 

func (m *MockTransaction) CreateWorkflowExecution(ctx context.Context, createMode persistence.CreateWorkflowMode, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents, clusterName string) (int64, error)

CreateWorkflowExecution mocks base method.

func (*MockTransaction) EXPECT added in v1.12.0 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

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

func (*MockTransaction) SetWorkflowExecution added in v1.16.0 

func (m *MockTransaction) SetWorkflowExecution(ctx context.Context, workflowSnapshot *persistence.WorkflowSnapshot, clusterName string) error

SetWorkflowExecution mocks base method.

func (*MockTransaction) UpdateWorkflowExecution added in v1.12.0 

func (m *MockTransaction) UpdateWorkflowExecution(ctx context.Context, updateMode persistence.UpdateWorkflowMode, currentWorkflowMutation *persistence.WorkflowMutation, currentWorkflowEventsSeq []*persistence.WorkflowEvents, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents, clusterName string) (int64, int64, error)

UpdateWorkflowExecution mocks base method.

type MockTransactionMockRecorder added in v1.12.0 

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

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) ConflictResolveWorkflowExecution added in v1.12.0 

func (mr *MockTransactionMockRecorder) ConflictResolveWorkflowExecution(ctx, conflictResolveMode, resetWorkflowSnapshot, resetWorkflowEventsSeq, newWorkflowSnapshot, newWorkflowEventsSeq, currentWorkflowMutation, currentWorkflowEventsSeq, clusterName interface{}) *gomock.Call

ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.

func (*MockTransactionMockRecorder) CreateWorkflowExecution added in v1.12.0 

func (mr *MockTransactionMockRecorder) CreateWorkflowExecution(ctx, createMode, newWorkflowSnapshot, newWorkflowEventsSeq, clusterName interface{}) *gomock.Call

CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.

func (*MockTransactionMockRecorder) SetWorkflowExecution added in v1.16.0 

func (mr *MockTransactionMockRecorder) SetWorkflowExecution(ctx, workflowSnapshot, clusterName interface{}) *gomock.Call

SetWorkflowExecution indicates an expected call of SetWorkflowExecution.

func (*MockTransactionMockRecorder) UpdateWorkflowExecution added in v1.12.0 

func (mr *MockTransactionMockRecorder) UpdateWorkflowExecution(ctx, updateMode, currentWorkflowMutation, currentWorkflowEventsSeq, newWorkflowSnapshot, newWorkflowEventsSeq, clusterName interface{}) *gomock.Call

UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.

type MutableState 

type MutableState interface {
	AddActivityTaskCancelRequestedEvent(int64, int64, string) (*historypb.HistoryEvent, *persistencespb.ActivityInfo, error)
	AddActivityTaskCanceledEvent(int64, int64, int64, *commonpb.Payloads, string) (*historypb.HistoryEvent, error)
	AddActivityTaskCompletedEvent(int64, int64, *workflowservice.RespondActivityTaskCompletedRequest) (*historypb.HistoryEvent, error)
	AddActivityTaskFailedEvent(int64, int64, *failurepb.Failure, enumspb.RetryState, string) (*historypb.HistoryEvent, error)
	AddActivityTaskScheduledEvent(int64, *commandpb.ScheduleActivityTaskCommandAttributes, bool) (*historypb.HistoryEvent, *persistencespb.ActivityInfo, error)
	AddActivityTaskStartedEvent(*persistencespb.ActivityInfo, int64, string, string) (*historypb.HistoryEvent, error)
	AddActivityTaskTimedOutEvent(int64, int64, *failurepb.Failure, enumspb.RetryState) (*historypb.HistoryEvent, error)
	AddChildWorkflowExecutionCanceledEvent(int64, *commonpb.WorkflowExecution, *historypb.WorkflowExecutionCanceledEventAttributes) (*historypb.HistoryEvent, error)
	AddChildWorkflowExecutionCompletedEvent(int64, *commonpb.WorkflowExecution, *historypb.WorkflowExecutionCompletedEventAttributes) (*historypb.HistoryEvent, error)
	AddChildWorkflowExecutionFailedEvent(int64, *commonpb.WorkflowExecution, *historypb.WorkflowExecutionFailedEventAttributes) (*historypb.HistoryEvent, error)
	AddChildWorkflowExecutionStartedEvent(*commonpb.WorkflowExecution, *commonpb.WorkflowType, int64, *commonpb.Header, *clockspb.VectorClock) (*historypb.HistoryEvent, error)
	AddChildWorkflowExecutionTerminatedEvent(int64, *commonpb.WorkflowExecution, *historypb.WorkflowExecutionTerminatedEventAttributes) (*historypb.HistoryEvent, error)
	AddChildWorkflowExecutionTimedOutEvent(int64, *commonpb.WorkflowExecution, *historypb.WorkflowExecutionTimedOutEventAttributes) (*historypb.HistoryEvent, error)
	AddCompletedWorkflowEvent(int64, *commandpb.CompleteWorkflowExecutionCommandAttributes, string) (*historypb.HistoryEvent, error)
	AddContinueAsNewEvent(int64, int64, namespace.Name, *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes) (*historypb.HistoryEvent, MutableState, error)
	AddWorkflowTaskCompletedEvent(int64, int64, *workflowservice.RespondWorkflowTaskCompletedRequest, int) (*historypb.HistoryEvent, error)
	AddWorkflowTaskFailedEvent(scheduledEventID int64, startedEventID int64, cause enumspb.WorkflowTaskFailedCause, failure *failurepb.Failure, identity, binChecksum, baseRunID, newRunID string, forkEventVersion int64) (*historypb.HistoryEvent, error)
	AddWorkflowTaskScheduleToStartTimeoutEvent(int64) (*historypb.HistoryEvent, error)
	AddFirstWorkflowTaskScheduled(*historypb.HistoryEvent) error
	AddWorkflowTaskScheduledEvent(bypassTaskGeneration bool) (*WorkflowTaskInfo, error)
	AddWorkflowTaskScheduledEventAsHeartbeat(bypassTaskGeneration bool, originalScheduledTimestamp *time.Time) (*WorkflowTaskInfo, error)
	AddWorkflowTaskStartedEvent(int64, string, *taskqueuepb.TaskQueue, string) (*historypb.HistoryEvent, *WorkflowTaskInfo, error)
	AddWorkflowTaskTimedOutEvent(int64, int64) (*historypb.HistoryEvent, error)
	AddExternalWorkflowExecutionCancelRequested(int64, namespace.Name, namespace.ID, string, string) (*historypb.HistoryEvent, error)
	AddExternalWorkflowExecutionSignaled(int64, namespace.Name, namespace.ID, string, string, string) (*historypb.HistoryEvent, error)
	AddFailWorkflowEvent(int64, enumspb.RetryState, *commandpb.FailWorkflowExecutionCommandAttributes, string) (*historypb.HistoryEvent, error)
	AddRecordMarkerEvent(int64, *commandpb.RecordMarkerCommandAttributes) (*historypb.HistoryEvent, error)
	AddRequestCancelExternalWorkflowExecutionFailedEvent(int64, namespace.Name, namespace.ID, string, string, enumspb.CancelExternalWorkflowExecutionFailedCause) (*historypb.HistoryEvent, error)
	AddRequestCancelExternalWorkflowExecutionInitiatedEvent(int64, string, *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes, namespace.ID) (*historypb.HistoryEvent, *persistencespb.RequestCancelInfo, error)
	AddSignalExternalWorkflowExecutionFailedEvent(int64, namespace.Name, namespace.ID, string, string, string, enumspb.SignalExternalWorkflowExecutionFailedCause) (*historypb.HistoryEvent, error)
	AddSignalExternalWorkflowExecutionInitiatedEvent(int64, string, *commandpb.SignalExternalWorkflowExecutionCommandAttributes, namespace.ID) (*historypb.HistoryEvent, *persistencespb.SignalInfo, error)
	AddSignalRequested(requestID string)
	AddStartChildWorkflowExecutionFailedEvent(int64, enumspb.StartChildWorkflowExecutionFailedCause, *historypb.StartChildWorkflowExecutionInitiatedEventAttributes) (*historypb.HistoryEvent, error)
	AddStartChildWorkflowExecutionInitiatedEvent(int64, string, *commandpb.StartChildWorkflowExecutionCommandAttributes, namespace.ID) (*historypb.HistoryEvent, *persistencespb.ChildExecutionInfo, error)
	AddTimeoutWorkflowEvent(int64, enumspb.RetryState, string) (*historypb.HistoryEvent, error)
	AddTimerCanceledEvent(int64, *commandpb.CancelTimerCommandAttributes, string) (*historypb.HistoryEvent, error)
	AddTimerFiredEvent(string) (*historypb.HistoryEvent, error)
	AddTimerStartedEvent(int64, *commandpb.StartTimerCommandAttributes) (*historypb.HistoryEvent, *persistencespb.TimerInfo, error)
	AddUpsertWorkflowSearchAttributesEvent(int64, *commandpb.UpsertWorkflowSearchAttributesCommandAttributes) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionCancelRequestedEvent(*historyservice.RequestCancelWorkflowExecutionRequest) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionCanceledEvent(int64, *commandpb.CancelWorkflowExecutionCommandAttributes) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionSignaled(signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionStartedEvent(commonpb.WorkflowExecution, *historyservice.StartWorkflowExecutionRequest) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionStartedEventWithOptions(commonpb.WorkflowExecution, *historyservice.StartWorkflowExecutionRequest, *workflowpb.ResetPoints, string, string) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionTerminatedEvent(firstEventID int64, reason string, details *commonpb.Payloads, identity string, deleteAfterTerminate bool) (*historypb.HistoryEvent, error)
	ClearStickyness()
	CheckResettable() error
	CloneToProto() *persistencespb.WorkflowMutableState
	RetryActivity(ai *persistencespb.ActivityInfo, failure *failurepb.Failure) (enumspb.RetryState, error)
	CreateTransientWorkflowTaskEvents(workflowTask *WorkflowTaskInfo, identity string) (*historypb.HistoryEvent, *historypb.HistoryEvent)
	DeleteWorkflowTask()
	DeleteSignalRequested(requestID string)
	FlushBufferedEvents()
	GetWorkflowKey() definition.WorkflowKey
	GetActivityByActivityID(string) (*persistencespb.ActivityInfo, bool)
	GetActivityInfo(int64) (*persistencespb.ActivityInfo, bool)
	GetActivityInfoWithTimerHeartbeat(scheduledEventID int64) (*persistencespb.ActivityInfo, time.Time, bool)
	GetActivityScheduledEvent(context.Context, int64) (*historypb.HistoryEvent, error)
	GetRequesteCancelExternalInitiatedEvent(context.Context, int64) (*historypb.HistoryEvent, error)
	GetChildExecutionInfo(int64) (*persistencespb.ChildExecutionInfo, bool)
	GetChildExecutionInitiatedEvent(context.Context, int64) (*historypb.HistoryEvent, error)
	GetCompletionEvent(context.Context) (*historypb.HistoryEvent, error)
	GetWorkflowCloseTime(ctx context.Context) (*time.Time, error)
	GetWorkflowTaskInfo(int64) (*WorkflowTaskInfo, bool)
	GetNamespaceEntry() *namespace.Namespace
	GetStartEvent(context.Context) (*historypb.HistoryEvent, error)
	GetSignalExternalInitiatedEvent(context.Context, int64) (*historypb.HistoryEvent, error)
	GetFirstRunID() (string, error)
	GetCurrentBranchToken() ([]byte, error)
	GetCurrentVersion() int64
	GetExecutionInfo() *persistencespb.WorkflowExecutionInfo
	GetExecutionState() *persistencespb.WorkflowExecutionState
	GetInFlightWorkflowTask() (*WorkflowTaskInfo, bool)
	GetPendingWorkflowTask() (*WorkflowTaskInfo, bool)
	GetLastFirstEventIDTxnID() (int64, int64)
	GetLastWriteVersion() (int64, error)
	GetNextEventID() int64
	GetPreviousStartedEventID() int64
	GetPendingActivityInfos() map[int64]*persistencespb.ActivityInfo
	GetPendingTimerInfos() map[string]*persistencespb.TimerInfo
	GetPendingChildExecutionInfos() map[int64]*persistencespb.ChildExecutionInfo
	GetPendingRequestCancelExternalInfos() map[int64]*persistencespb.RequestCancelInfo
	GetPendingSignalExternalInfos() map[int64]*persistencespb.SignalInfo
	GetRequestCancelInfo(int64) (*persistencespb.RequestCancelInfo, bool)
	GetRetryBackoffDuration(failure *failurepb.Failure) (time.Duration, enumspb.RetryState)
	GetCronBackoffDuration() time.Duration
	GetSignalInfo(int64) (*persistencespb.SignalInfo, bool)
	GetStartVersion() (int64, error)
	GetUserTimerInfoByEventID(int64) (*persistencespb.TimerInfo, bool)
	GetUserTimerInfo(string) (*persistencespb.TimerInfo, bool)
	GetWorkflowType() *commonpb.WorkflowType
	GetWorkflowStateStatus() (enumsspb.WorkflowExecutionState, enumspb.WorkflowExecutionStatus)
	GetQueryRegistry() QueryRegistry
	HasTransientWorkflowTask() bool
	ClearTransientWorkflowTask() error
	HasBufferedEvents() bool
	HasInFlightWorkflowTask() bool
	HasParentExecution() bool
	HasPendingWorkflowTask() bool
	HasProcessedOrPendingWorkflowTask() bool
	IsCancelRequested() bool
	IsCurrentWorkflowGuaranteed() bool
	IsSignalRequested(requestID string) bool
	IsStickyTaskQueueEnabled() bool
	IsWorkflowExecutionRunning() bool
	IsResourceDuplicated(resourceDedupKey definition.DeduplicationID) bool
	IsWorkflowPendingOnWorkflowTaskBackoff() bool
	UpdateDuplicatedResource(resourceDedupKey definition.DeduplicationID)
	ReplicateActivityInfo(*historyservice.SyncActivityRequest, bool) error
	ReplicateActivityTaskCancelRequestedEvent(*historypb.HistoryEvent) error
	ReplicateActivityTaskCanceledEvent(*historypb.HistoryEvent) error
	ReplicateActivityTaskCompletedEvent(*historypb.HistoryEvent) error
	ReplicateActivityTaskFailedEvent(*historypb.HistoryEvent) error
	ReplicateActivityTaskScheduledEvent(int64, *historypb.HistoryEvent) (*persistencespb.ActivityInfo, error)
	ReplicateActivityTaskStartedEvent(*historypb.HistoryEvent) error
	ReplicateActivityTaskTimedOutEvent(*historypb.HistoryEvent) error
	ReplicateChildWorkflowExecutionCanceledEvent(*historypb.HistoryEvent) error
	ReplicateChildWorkflowExecutionCompletedEvent(*historypb.HistoryEvent) error
	ReplicateChildWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ReplicateChildWorkflowExecutionStartedEvent(*historypb.HistoryEvent, *clockspb.VectorClock) error
	ReplicateChildWorkflowExecutionTerminatedEvent(*historypb.HistoryEvent) error
	ReplicateChildWorkflowExecutionTimedOutEvent(*historypb.HistoryEvent) error
	ReplicateWorkflowTaskCompletedEvent(*historypb.HistoryEvent) error
	ReplicateWorkflowTaskFailedEvent() error
	ReplicateWorkflowTaskScheduledEvent(int64, int64, *taskqueuepb.TaskQueue, *time.Duration, int32, *time.Time, *time.Time) (*WorkflowTaskInfo, error)
	ReplicateWorkflowTaskStartedEvent(*WorkflowTaskInfo, int64, int64, int64, string, time.Time) (*WorkflowTaskInfo, error)
	ReplicateWorkflowTaskTimedOutEvent(enumspb.TimeoutType) error
	ReplicateExternalWorkflowExecutionCancelRequested(*historypb.HistoryEvent) error
	ReplicateExternalWorkflowExecutionSignaled(*historypb.HistoryEvent) error
	ReplicateRequestCancelExternalWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent(int64, *historypb.HistoryEvent, string) (*persistencespb.RequestCancelInfo, error)
	ReplicateSignalExternalWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ReplicateSignalExternalWorkflowExecutionInitiatedEvent(int64, *historypb.HistoryEvent, string) (*persistencespb.SignalInfo, error)
	ReplicateStartChildWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ReplicateStartChildWorkflowExecutionInitiatedEvent(int64, *historypb.HistoryEvent, string) (*persistencespb.ChildExecutionInfo, error)
	ReplicateTimerCanceledEvent(*historypb.HistoryEvent) error
	ReplicateTimerFiredEvent(*historypb.HistoryEvent) error
	ReplicateTimerStartedEvent(*historypb.HistoryEvent) (*persistencespb.TimerInfo, error)
	ReplicateTransientWorkflowTaskScheduled() (*WorkflowTaskInfo, error)
	ReplicateUpsertWorkflowSearchAttributesEvent(*historypb.HistoryEvent)
	ReplicateWorkflowExecutionCancelRequestedEvent(*historypb.HistoryEvent) error
	ReplicateWorkflowExecutionCanceledEvent(int64, *historypb.HistoryEvent) error
	ReplicateWorkflowExecutionCompletedEvent(int64, *historypb.HistoryEvent) error
	ReplicateWorkflowExecutionContinuedAsNewEvent(int64, *historypb.HistoryEvent) error
	ReplicateWorkflowExecutionFailedEvent(int64, *historypb.HistoryEvent) error
	ReplicateWorkflowExecutionSignaled(*historypb.HistoryEvent) error
	ReplicateWorkflowExecutionStartedEvent(*clockspb.VectorClock, commonpb.WorkflowExecution, string, *historypb.HistoryEvent) error
	ReplicateWorkflowExecutionTerminatedEvent(int64, *historypb.HistoryEvent) error
	ReplicateWorkflowExecutionTimedoutEvent(int64, *historypb.HistoryEvent) error
	SetCurrentBranchToken(branchToken []byte) error
	SetHistoryBuilder(hBuilder *HistoryBuilder)
	SetHistoryTree(treeID string) error
	UpdateActivity(*persistencespb.ActivityInfo) error
	UpdateActivityWithTimerHeartbeat(*persistencespb.ActivityInfo, time.Time) error
	UpdateActivityProgress(ai *persistencespb.ActivityInfo, request *workflowservice.RecordActivityTaskHeartbeatRequest)
	UpdateUserTimer(*persistencespb.TimerInfo) error
	UpdateCurrentVersion(version int64, forceUpdate bool) error
	UpdateWorkflowStateStatus(state enumsspb.WorkflowExecutionState, status enumspb.WorkflowExecutionStatus) error

	AddTasks(tasks ...tasks.Task)
	PopTasks() map[tasks.Category][]tasks.Task
	SetUpdateCondition(int64, int64)
	GetUpdateCondition() (int64, int64)

	StartTransaction(entry *namespace.Namespace) (bool, error)
	CloseTransactionAsMutation(now time.Time, transactionPolicy TransactionPolicy) (*persistence.WorkflowMutation, []*persistence.WorkflowEvents, error)
	CloseTransactionAsSnapshot(now time.Time, transactionPolicy TransactionPolicy) (*persistence.WorkflowSnapshot, []*persistence.WorkflowEvents, error)
	GenerateMigrationTasks(now time.Time) (tasks.Task, error)
}

func RetryWorkflow 

func RetryWorkflow(
	mutableState MutableState,
	eventBatchFirstEventID int64,
	parentNamespace namespace.Name,
	continueAsNewAttributes *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes,
) (MutableState, error)

type MutableStateImpl 

type MutableStateImpl struct {
	InsertTasks map[tasks.Category][]tasks.Task

	QueryRegistry QueryRegistry
	// contains filtered or unexported fields
}

func NewMutableState 

func NewMutableState(
	shard shard.Context,
	eventsCache events.Cache,
	logger log.Logger,
	namespaceEntry *namespace.Namespace,
	startTime time.Time,
) *MutableStateImpl

func NewSanitizedMutableState added in v1.17.0 

func NewSanitizedMutableState(
	shard shard.Context,
	eventsCache events.Cache,
	logger log.Logger,
	namespaceEntry *namespace.Namespace,
	mutableStateRecord *persistencespb.WorkflowMutableState,
) (*MutableStateImpl, error)

func TestGlobalMutableState 

func TestGlobalMutableState(
	shard shard.Context,
	eventsCache events.Cache,
	logger log.Logger,
	version int64,
	runID string,
) *MutableStateImpl

func TestLocalMutableState 

func TestLocalMutableState(
	shard shard.Context,
	eventsCache events.Cache,
	ns *namespace.Namespace,
	logger log.Logger,
	runID string,
) *MutableStateImpl

func (*MutableStateImpl) AddActivityTaskCancelRequestedEvent 

func (e *MutableStateImpl) AddActivityTaskCancelRequestedEvent(
	workflowTaskCompletedEventID int64,
	scheduledEventID int64,
	_ string,
) (*historypb.HistoryEvent, *persistencespb.ActivityInfo, error)

func (*MutableStateImpl) AddActivityTaskCanceledEvent 

func (e *MutableStateImpl) AddActivityTaskCanceledEvent(
	scheduledEventID int64,
	startedEventID int64,
	latestCancelRequestedEventID int64,
	details *commonpb.Payloads,
	identity string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddActivityTaskCompletedEvent 

func (e *MutableStateImpl) AddActivityTaskCompletedEvent(
	scheduledEventID int64,
	startedEventID int64,
	request *workflowservice.RespondActivityTaskCompletedRequest,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddActivityTaskFailedEvent 

func (e *MutableStateImpl) AddActivityTaskFailedEvent(
	scheduledEventID int64,
	startedEventID int64,
	failure *failurepb.Failure,
	retryState enumspb.RetryState,
	identity string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddActivityTaskScheduledEvent 

func (e *MutableStateImpl) AddActivityTaskScheduledEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.ScheduleActivityTaskCommandAttributes,
	bypassTaskGeneration bool,
) (*historypb.HistoryEvent, *persistencespb.ActivityInfo, error)

func (*MutableStateImpl) AddActivityTaskStartedEvent 

func (e *MutableStateImpl) AddActivityTaskStartedEvent(
	ai *persistencespb.ActivityInfo,
	scheduledEventID int64,
	requestID string,
	identity string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddActivityTaskTimedOutEvent 

func (e *MutableStateImpl) AddActivityTaskTimedOutEvent(
	scheduledEventID int64,
	startedEventID int64,
	timeoutFailure *failurepb.Failure,
	retryState enumspb.RetryState,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddChildWorkflowExecutionCanceledEvent 

func (e *MutableStateImpl) AddChildWorkflowExecutionCanceledEvent(
	initiatedID int64,
	childExecution *commonpb.WorkflowExecution,
	attributes *historypb.WorkflowExecutionCanceledEventAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddChildWorkflowExecutionCompletedEvent 

func (e *MutableStateImpl) AddChildWorkflowExecutionCompletedEvent(
	initiatedID int64,
	childExecution *commonpb.WorkflowExecution,
	attributes *historypb.WorkflowExecutionCompletedEventAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddChildWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) AddChildWorkflowExecutionFailedEvent(
	initiatedID int64,
	childExecution *commonpb.WorkflowExecution,
	attributes *historypb.WorkflowExecutionFailedEventAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddChildWorkflowExecutionStartedEvent 

func (e *MutableStateImpl) AddChildWorkflowExecutionStartedEvent(
	execution *commonpb.WorkflowExecution,
	workflowType *commonpb.WorkflowType,
	initiatedID int64,
	header *commonpb.Header,
	clock *clockspb.VectorClock,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddChildWorkflowExecutionTerminatedEvent 

func (e *MutableStateImpl) AddChildWorkflowExecutionTerminatedEvent(
	initiatedID int64,
	childExecution *commonpb.WorkflowExecution,
	_ *historypb.WorkflowExecutionTerminatedEventAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddChildWorkflowExecutionTimedOutEvent 

func (e *MutableStateImpl) AddChildWorkflowExecutionTimedOutEvent(
	initiatedID int64,
	childExecution *commonpb.WorkflowExecution,
	attributes *historypb.WorkflowExecutionTimedOutEventAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddCompletedWorkflowEvent 

func (e *MutableStateImpl) AddCompletedWorkflowEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.CompleteWorkflowExecutionCommandAttributes,
	newExecutionRunID string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddContinueAsNewEvent 

func (e *MutableStateImpl) AddContinueAsNewEvent(
	firstEventID int64,
	workflowTaskCompletedEventID int64,
	parentNamespace namespace.Name,
	command *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes,
) (*historypb.HistoryEvent, MutableState, error)

func (*MutableStateImpl) AddExternalWorkflowExecutionCancelRequested 

func (e *MutableStateImpl) AddExternalWorkflowExecutionCancelRequested(
	initiatedID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddExternalWorkflowExecutionSignaled 

func (e *MutableStateImpl) AddExternalWorkflowExecutionSignaled(
	initiatedID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
	control string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddFailWorkflowEvent 

func (e *MutableStateImpl) AddFailWorkflowEvent(
	workflowTaskCompletedEventID int64,
	retryState enumspb.RetryState,
	command *commandpb.FailWorkflowExecutionCommandAttributes,
	newExecutionRunID string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddFirstWorkflowTaskScheduled 

func (e *MutableStateImpl) AddFirstWorkflowTaskScheduled(
	startEvent *historypb.HistoryEvent,
) error

func (*MutableStateImpl) AddRecordMarkerEvent 

func (e *MutableStateImpl) AddRecordMarkerEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.RecordMarkerCommandAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddRequestCancelExternalWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) AddRequestCancelExternalWorkflowExecutionFailedEvent(
	initiatedID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
	cause enumspb.CancelExternalWorkflowExecutionFailedCause,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (e *MutableStateImpl) AddRequestCancelExternalWorkflowExecutionInitiatedEvent(
	workflowTaskCompletedEventID int64,
	cancelRequestID string,
	command *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes,
	targetNamespaceID namespace.ID,
) (*historypb.HistoryEvent, *persistencespb.RequestCancelInfo, error)

func (*MutableStateImpl) AddSignalExternalWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) AddSignalExternalWorkflowExecutionFailedEvent(
	initiatedID int64,
	targetNamespace namespace.Name,
	targetNamespaceID namespace.ID,
	workflowID string,
	runID string,
	control string,
	cause enumspb.SignalExternalWorkflowExecutionFailedCause,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddSignalExternalWorkflowExecutionInitiatedEvent 

func (e *MutableStateImpl) AddSignalExternalWorkflowExecutionInitiatedEvent(
	workflowTaskCompletedEventID int64,
	signalRequestID string,
	command *commandpb.SignalExternalWorkflowExecutionCommandAttributes,
	targetNamespaceID namespace.ID,
) (*historypb.HistoryEvent, *persistencespb.SignalInfo, error)

func (*MutableStateImpl) AddSignalRequested 

func (e *MutableStateImpl) AddSignalRequested(
	requestID string,
)

func (*MutableStateImpl) AddStartChildWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) AddStartChildWorkflowExecutionFailedEvent(
	initiatedID int64,
	cause enumspb.StartChildWorkflowExecutionFailedCause,
	initiatedEventAttributes *historypb.StartChildWorkflowExecutionInitiatedEventAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddStartChildWorkflowExecutionInitiatedEvent 

func (e *MutableStateImpl) AddStartChildWorkflowExecutionInitiatedEvent(
	workflowTaskCompletedEventID int64,
	createRequestID string,
	command *commandpb.StartChildWorkflowExecutionCommandAttributes,
	targetNamespaceID namespace.ID,
) (*historypb.HistoryEvent, *persistencespb.ChildExecutionInfo, error)

func (*MutableStateImpl) AddTasks added in v1.16.0 

func (e *MutableStateImpl) AddTasks(
	tasks ...tasks.Task,
)

AddTasks append transfer tasks

func (*MutableStateImpl) AddTimeoutWorkflowEvent 

func (e *MutableStateImpl) AddTimeoutWorkflowEvent(
	firstEventID int64,
	retryState enumspb.RetryState,
	newExecutionRunID string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddTimerCanceledEvent 

func (e *MutableStateImpl) AddTimerCanceledEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.CancelTimerCommandAttributes,
	identity string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddTimerFiredEvent 

func (e *MutableStateImpl) AddTimerFiredEvent(
	timerID string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddTimerStartedEvent 

func (e *MutableStateImpl) AddTimerStartedEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.StartTimerCommandAttributes,
) (*historypb.HistoryEvent, *persistencespb.TimerInfo, error)

func (*MutableStateImpl) AddUpsertWorkflowSearchAttributesEvent 

func (e *MutableStateImpl) AddUpsertWorkflowSearchAttributesEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.UpsertWorkflowSearchAttributesCommandAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionCancelRequestedEvent 

func (e *MutableStateImpl) AddWorkflowExecutionCancelRequestedEvent(
	request *historyservice.RequestCancelWorkflowExecutionRequest,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionCanceledEvent 

func (e *MutableStateImpl) AddWorkflowExecutionCanceledEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.CancelWorkflowExecutionCommandAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionSignaled 

func (e *MutableStateImpl) AddWorkflowExecutionSignaled(
	signalName string,
	input *commonpb.Payloads,
	identity string,
	header *commonpb.Header,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionStartedEvent 

func (e *MutableStateImpl) AddWorkflowExecutionStartedEvent(
	execution commonpb.WorkflowExecution,
	startRequest *historyservice.StartWorkflowExecutionRequest,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionStartedEventWithOptions added in v1.13.0 

func (e *MutableStateImpl) AddWorkflowExecutionStartedEventWithOptions(
	execution commonpb.WorkflowExecution,
	startRequest *historyservice.StartWorkflowExecutionRequest,
	resetPoints *workflowpb.ResetPoints,
	prevRunID string,
	firstRunID string,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionTerminatedEvent 

func (e *MutableStateImpl) AddWorkflowExecutionTerminatedEvent(
	firstEventID int64,
	reason string,
	details *commonpb.Payloads,
	identity string,
	deleteAfterTerminate bool,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskCompletedEvent 

func (e *MutableStateImpl) AddWorkflowTaskCompletedEvent(
	scheduledEventID int64,
	startedEventID int64,
	request *workflowservice.RespondWorkflowTaskCompletedRequest,
	maxResetPoints int,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskFailedEvent 

func (e *MutableStateImpl) AddWorkflowTaskFailedEvent(
	scheduledEventID int64,
	startedEventID int64,
	cause enumspb.WorkflowTaskFailedCause,
	failure *failurepb.Failure,
	identity string,
	binChecksum string,
	baseRunID string,
	newRunID string,
	forkEventVersion int64,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskScheduleToStartTimeoutEvent 

func (e *MutableStateImpl) AddWorkflowTaskScheduleToStartTimeoutEvent(
	scheduledEventID int64,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskScheduledEvent 

func (e *MutableStateImpl) AddWorkflowTaskScheduledEvent(
	bypassTaskGeneration bool,
) (*WorkflowTaskInfo, error)

func (*MutableStateImpl) AddWorkflowTaskScheduledEventAsHeartbeat 

func (e *MutableStateImpl) AddWorkflowTaskScheduledEventAsHeartbeat(
	bypassTaskGeneration bool,
	originalScheduledTimestamp *time.Time,
) (*WorkflowTaskInfo, error)

AddWorkflowTaskScheduledEventAsHeartbeat is to record the first WorkflowTaskScheduledEvent during workflow task heartbeat.

func (*MutableStateImpl) AddWorkflowTaskStartedEvent 

func (e *MutableStateImpl) AddWorkflowTaskStartedEvent(
	scheduledEventID int64,
	requestID string,
	taskQueue *taskqueuepb.TaskQueue,
	identity string,
) (*historypb.HistoryEvent, *WorkflowTaskInfo, error)

func (*MutableStateImpl) AddWorkflowTaskTimedOutEvent 

func (e *MutableStateImpl) AddWorkflowTaskTimedOutEvent(
	scheduledEventID int64,
	startedEventID int64,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) CheckResettable 

func (e *MutableStateImpl) CheckResettable() error

CheckResettable check if workflow can be reset

func (*MutableStateImpl) ClearStickyness 

func (e *MutableStateImpl) ClearStickyness()

func (*MutableStateImpl) ClearTransientWorkflowTask added in v1.16.3 

func (e *MutableStateImpl) ClearTransientWorkflowTask() error

func (*MutableStateImpl) CloneToProto 

func (e *MutableStateImpl) CloneToProto() *persistencespb.WorkflowMutableState

func (*MutableStateImpl) CloseTransactionAsMutation 

func (e *MutableStateImpl) CloseTransactionAsMutation(
	now time.Time,
	transactionPolicy TransactionPolicy,
) (*persistence.WorkflowMutation, []*persistence.WorkflowEvents, error)

func (*MutableStateImpl) CloseTransactionAsSnapshot 

func (e *MutableStateImpl) CloseTransactionAsSnapshot(
	now time.Time,
	transactionPolicy TransactionPolicy,
) (*persistence.WorkflowSnapshot, []*persistence.WorkflowEvents, error)

func (*MutableStateImpl) CreateTransientWorkflowTaskEvents 

func (e *MutableStateImpl) CreateTransientWorkflowTaskEvents(
	workflowTask *WorkflowTaskInfo,
	identity string,
) (*historypb.HistoryEvent, *historypb.HistoryEvent)

func (*MutableStateImpl) DeleteActivity 

func (e *MutableStateImpl) DeleteActivity(
	scheduledEventID int64,
) error

DeleteActivity deletes details about an activity.

func (*MutableStateImpl) DeletePendingChildExecution 

func (e *MutableStateImpl) DeletePendingChildExecution(
	initiatedEventID int64,
) error

DeletePendingChildExecution deletes details about a ChildExecutionInfo.

func (*MutableStateImpl) DeletePendingRequestCancel 

func (e *MutableStateImpl) DeletePendingRequestCancel(
	initiatedEventID int64,
) error

DeletePendingRequestCancel deletes details about a RequestCancelInfo.

func (*MutableStateImpl) DeletePendingSignal 

func (e *MutableStateImpl) DeletePendingSignal(
	initiatedEventID int64,
) error

DeletePendingSignal deletes details about a SignalInfo

func (*MutableStateImpl) DeleteSignalRequested 

func (e *MutableStateImpl) DeleteSignalRequested(
	requestID string,
)

func (*MutableStateImpl) DeleteUserTimer 

func (e *MutableStateImpl) DeleteUserTimer(
	timerID string,
) error

DeleteUserTimer deletes an user timer.

func (*MutableStateImpl) DeleteWorkflowTask 

func (e *MutableStateImpl) DeleteWorkflowTask()

DeleteWorkflowTask deletes a workflow task.

func (*MutableStateImpl) FlushBufferedEvents 

func (e *MutableStateImpl) FlushBufferedEvents()

func (*MutableStateImpl) GenerateMigrationTasks added in v1.17.0 

func (e *MutableStateImpl) GenerateMigrationTasks(
	now time.Time,
) (tasks.Task, error)

func (*MutableStateImpl) GetActivityByActivityID 

func (e *MutableStateImpl) GetActivityByActivityID(
	activityID string,
) (*persistencespb.ActivityInfo, bool)

GetActivityByActivityID gives details about an activity that is currently in progress.

func (*MutableStateImpl) GetActivityInfo 

func (e *MutableStateImpl) GetActivityInfo(
	scheduledEventID int64,
) (*persistencespb.ActivityInfo, bool)

GetActivityInfo gives details about an activity that is currently in progress.

func (*MutableStateImpl) GetActivityInfoWithTimerHeartbeat 

func (e *MutableStateImpl) GetActivityInfoWithTimerHeartbeat(
	scheduledEventID int64,
) (*persistencespb.ActivityInfo, time.Time, bool)

GetActivityInfoWithTimerHeartbeat gives details about an activity that is currently in progress.

func (*MutableStateImpl) GetActivityScheduledEvent 

func (e *MutableStateImpl) GetActivityScheduledEvent(
	ctx context.Context,
	scheduledEventID int64,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) GetChildExecutionInfo 

func (e *MutableStateImpl) GetChildExecutionInfo(
	initiatedEventID int64,
) (*persistencespb.ChildExecutionInfo, bool)

GetChildExecutionInfo gives details about a child execution that is currently in progress.

func (*MutableStateImpl) GetChildExecutionInitiatedEvent 

func (e *MutableStateImpl) GetChildExecutionInitiatedEvent(
	ctx context.Context,
	initiatedEventID int64,
) (*historypb.HistoryEvent, error)

GetChildExecutionInitiatedEvent reads out the ChildExecutionInitiatedEvent from mutable state for in-progress child executions

func (*MutableStateImpl) GetCompletionEvent 

func (e *MutableStateImpl) GetCompletionEvent(
	ctx context.Context,
) (*historypb.HistoryEvent, error)

GetCompletionEvent retrieves the workflow completion event from mutable state

func (*MutableStateImpl) GetCronBackoffDuration 

func (e *MutableStateImpl) GetCronBackoffDuration() time.Duration

func (*MutableStateImpl) GetCurrentBranchToken 

func (e *MutableStateImpl) GetCurrentBranchToken() ([]byte, error)

func (*MutableStateImpl) GetCurrentVersion 

func (e *MutableStateImpl) GetCurrentVersion() int64

func (*MutableStateImpl) GetExecutionInfo 

func (e *MutableStateImpl) GetExecutionInfo() *persistencespb.WorkflowExecutionInfo

func (*MutableStateImpl) GetExecutionState 

func (e *MutableStateImpl) GetExecutionState() *persistencespb.WorkflowExecutionState

func (*MutableStateImpl) GetFirstRunID added in v1.13.0 

func (e *MutableStateImpl) GetFirstRunID() (string, error)

func (*MutableStateImpl) GetInFlightWorkflowTask 

func (e *MutableStateImpl) GetInFlightWorkflowTask() (*WorkflowTaskInfo, bool)

func (*MutableStateImpl) GetLastFirstEventIDTxnID 

func (e *MutableStateImpl) GetLastFirstEventIDTxnID() (int64, int64)

GetLastFirstEventIDTxnID returns last first event ID and corresponding transaction ID first event ID is the ID of a batch of events in a single history events record

func (*MutableStateImpl) GetLastWriteVersion 

func (e *MutableStateImpl) GetLastWriteVersion() (int64, error)

func (*MutableStateImpl) GetNamespaceEntry 

func (e *MutableStateImpl) GetNamespaceEntry() *namespace.Namespace

func (*MutableStateImpl) GetNextEventID 

func (e *MutableStateImpl) GetNextEventID() int64

GetNextEventID returns next event ID

func (*MutableStateImpl) GetPendingActivityInfos 

func (e *MutableStateImpl) GetPendingActivityInfos() map[int64]*persistencespb.ActivityInfo

func (*MutableStateImpl) GetPendingChildExecutionInfos 

func (e *MutableStateImpl) GetPendingChildExecutionInfos() map[int64]*persistencespb.ChildExecutionInfo

func (*MutableStateImpl) GetPendingRequestCancelExternalInfos 

func (e *MutableStateImpl) GetPendingRequestCancelExternalInfos() map[int64]*persistencespb.RequestCancelInfo

func (*MutableStateImpl) GetPendingSignalExternalInfos 

func (e *MutableStateImpl) GetPendingSignalExternalInfos() map[int64]*persistencespb.SignalInfo

func (*MutableStateImpl) GetPendingTimerInfos 

func (e *MutableStateImpl) GetPendingTimerInfos() map[string]*persistencespb.TimerInfo

func (*MutableStateImpl) GetPendingWorkflowTask 

func (e *MutableStateImpl) GetPendingWorkflowTask() (*WorkflowTaskInfo, bool)

func (*MutableStateImpl) GetPreviousStartedEventID 

func (e *MutableStateImpl) GetPreviousStartedEventID() int64

GetPreviousStartedEventID returns last started workflow task event ID

func (*MutableStateImpl) GetQueryRegistry 

func (e *MutableStateImpl) GetQueryRegistry() QueryRegistry

func (*MutableStateImpl) GetRequestCancelInfo 

func (e *MutableStateImpl) GetRequestCancelInfo(
	initiatedEventID int64,
) (*persistencespb.RequestCancelInfo, bool)

GetRequestCancelInfo gives details about a request cancellation that is currently in progress.

func (*MutableStateImpl) GetRequesteCancelExternalInitiatedEvent added in v1.16.0 

func (e *MutableStateImpl) GetRequesteCancelExternalInitiatedEvent(
	ctx context.Context,
	initiatedEventID int64,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) GetRetryBackoffDuration 

func (e *MutableStateImpl) GetRetryBackoffDuration(
	failure *failurepb.Failure,
) (time.Duration, enumspb.RetryState)

func (*MutableStateImpl) GetSignalExternalInitiatedEvent added in v1.14.0 

func (e *MutableStateImpl) GetSignalExternalInitiatedEvent(
	ctx context.Context,
	initiatedEventID int64,
) (*historypb.HistoryEvent, error)

GetSignalExternalInitiatedEvent get the details about signal external workflow

func (*MutableStateImpl) GetSignalInfo 

func (e *MutableStateImpl) GetSignalInfo(
	initiatedEventID int64,
) (*persistencespb.SignalInfo, bool)

GetSignalInfo get the details about a signal request that is currently in progress.

func (*MutableStateImpl) GetStartEvent 

func (e *MutableStateImpl) GetStartEvent(
	ctx context.Context,
) (*historypb.HistoryEvent, error)

GetStartEvent retrieves the workflow start event from mutable state

func (*MutableStateImpl) GetStartVersion 

func (e *MutableStateImpl) GetStartVersion() (int64, error)

func (*MutableStateImpl) GetUpdateCondition 

func (e *MutableStateImpl) GetUpdateCondition() (int64, int64)

func (*MutableStateImpl) GetUserTimerInfo 

func (e *MutableStateImpl) GetUserTimerInfo(
	timerID string,
) (*persistencespb.TimerInfo, bool)

GetUserTimerInfo gives details about a user timer.

func (*MutableStateImpl) GetUserTimerInfoByEventID 

func (e *MutableStateImpl) GetUserTimerInfoByEventID(
	startEventID int64,
) (*persistencespb.TimerInfo, bool)

GetUserTimerInfoByEventID gives details about a user timer.

func (*MutableStateImpl) GetWorkflowCloseTime added in v1.17.0 

func (e *MutableStateImpl) GetWorkflowCloseTime(ctx context.Context) (*time.Time, error)

GetWorkflowCloseTime returns workflow closed time, returns nil for open workflow

func (*MutableStateImpl) GetWorkflowKey added in v1.14.0 

func (e *MutableStateImpl) GetWorkflowKey() definition.WorkflowKey

func (*MutableStateImpl) GetWorkflowStateStatus 

func (e *MutableStateImpl) GetWorkflowStateStatus() (enumsspb.WorkflowExecutionState, enumspb.WorkflowExecutionStatus)

func (*MutableStateImpl) GetWorkflowTaskInfo 

func (e *MutableStateImpl) GetWorkflowTaskInfo(
	scheduledEventID int64,
) (*WorkflowTaskInfo, bool)

GetWorkflowTaskInfo returns details about the in-progress workflow task

func (*MutableStateImpl) GetWorkflowType 

func (e *MutableStateImpl) GetWorkflowType() *commonpb.WorkflowType

func (*MutableStateImpl) HasBufferedEvents 

func (e *MutableStateImpl) HasBufferedEvents() bool

func (*MutableStateImpl) HasInFlightWorkflowTask 

func (e *MutableStateImpl) HasInFlightWorkflowTask() bool

func (*MutableStateImpl) HasParentExecution 

func (e *MutableStateImpl) HasParentExecution() bool

func (*MutableStateImpl) HasPendingWorkflowTask 

func (e *MutableStateImpl) HasPendingWorkflowTask() bool

func (*MutableStateImpl) HasProcessedOrPendingWorkflowTask 

func (e *MutableStateImpl) HasProcessedOrPendingWorkflowTask() bool

func (*MutableStateImpl) HasTransientWorkflowTask added in v1.16.3 

func (e *MutableStateImpl) HasTransientWorkflowTask() bool

func (*MutableStateImpl) IsCancelRequested 

func (e *MutableStateImpl) IsCancelRequested() bool

func (*MutableStateImpl) IsCurrentWorkflowGuaranteed 

func (e *MutableStateImpl) IsCurrentWorkflowGuaranteed() bool

func (*MutableStateImpl) IsResourceDuplicated 

func (e *MutableStateImpl) IsResourceDuplicated(
	resourceDedupKey definition.DeduplicationID,
) bool

func (*MutableStateImpl) IsSignalRequested 

func (e *MutableStateImpl) IsSignalRequested(
	requestID string,
) bool

func (*MutableStateImpl) IsStickyTaskQueueEnabled 

func (e *MutableStateImpl) IsStickyTaskQueueEnabled() bool

func (*MutableStateImpl) IsWorkflowExecutionRunning 

func (e *MutableStateImpl) IsWorkflowExecutionRunning() bool

func (*MutableStateImpl) IsWorkflowPendingOnWorkflowTaskBackoff added in v1.16.3 

func (e *MutableStateImpl) IsWorkflowPendingOnWorkflowTaskBackoff() bool

func (*MutableStateImpl) PopTasks added in v1.17.0 

func (e *MutableStateImpl) PopTasks() map[tasks.Category][]tasks.Task

func (*MutableStateImpl) ReplicateActivityInfo 

func (e *MutableStateImpl) ReplicateActivityInfo(
	request *historyservice.SyncActivityRequest,
	resetActivityTimerTaskStatus bool,
) error

ReplicateActivityInfo replicate the necessary activity information

func (*MutableStateImpl) ReplicateActivityTaskCancelRequestedEvent 

func (e *MutableStateImpl) ReplicateActivityTaskCancelRequestedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateActivityTaskCanceledEvent 

func (e *MutableStateImpl) ReplicateActivityTaskCanceledEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateActivityTaskCompletedEvent 

func (e *MutableStateImpl) ReplicateActivityTaskCompletedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateActivityTaskFailedEvent 

func (e *MutableStateImpl) ReplicateActivityTaskFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateActivityTaskScheduledEvent 

func (e *MutableStateImpl) ReplicateActivityTaskScheduledEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) (*persistencespb.ActivityInfo, error)

func (*MutableStateImpl) ReplicateActivityTaskStartedEvent 

func (e *MutableStateImpl) ReplicateActivityTaskStartedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateActivityTaskTimedOutEvent 

func (e *MutableStateImpl) ReplicateActivityTaskTimedOutEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateChildWorkflowExecutionCanceledEvent 

func (e *MutableStateImpl) ReplicateChildWorkflowExecutionCanceledEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateChildWorkflowExecutionCompletedEvent 

func (e *MutableStateImpl) ReplicateChildWorkflowExecutionCompletedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateChildWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) ReplicateChildWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateChildWorkflowExecutionStartedEvent 

func (e *MutableStateImpl) ReplicateChildWorkflowExecutionStartedEvent(
	event *historypb.HistoryEvent,
	clock *clockspb.VectorClock,
) error

func (*MutableStateImpl) ReplicateChildWorkflowExecutionTerminatedEvent 

func (e *MutableStateImpl) ReplicateChildWorkflowExecutionTerminatedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateChildWorkflowExecutionTimedOutEvent 

func (e *MutableStateImpl) ReplicateChildWorkflowExecutionTimedOutEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateExternalWorkflowExecutionCancelRequested 

func (e *MutableStateImpl) ReplicateExternalWorkflowExecutionCancelRequested(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateExternalWorkflowExecutionSignaled 

func (e *MutableStateImpl) ReplicateExternalWorkflowExecutionSignaled(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateRequestCancelExternalWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) ReplicateRequestCancelExternalWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (e *MutableStateImpl) ReplicateRequestCancelExternalWorkflowExecutionInitiatedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
	cancelRequestID string,
) (*persistencespb.RequestCancelInfo, error)

func (*MutableStateImpl) ReplicateSignalExternalWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) ReplicateSignalExternalWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateSignalExternalWorkflowExecutionInitiatedEvent 

func (e *MutableStateImpl) ReplicateSignalExternalWorkflowExecutionInitiatedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
	signalRequestID string,
) (*persistencespb.SignalInfo, error)

func (*MutableStateImpl) ReplicateStartChildWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) ReplicateStartChildWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateStartChildWorkflowExecutionInitiatedEvent 

func (e *MutableStateImpl) ReplicateStartChildWorkflowExecutionInitiatedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
	createRequestID string,
) (*persistencespb.ChildExecutionInfo, error)

func (*MutableStateImpl) ReplicateTimerCanceledEvent 

func (e *MutableStateImpl) ReplicateTimerCanceledEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateTimerFiredEvent 

func (e *MutableStateImpl) ReplicateTimerFiredEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateTimerStartedEvent 

func (e *MutableStateImpl) ReplicateTimerStartedEvent(
	event *historypb.HistoryEvent,
) (*persistencespb.TimerInfo, error)

func (*MutableStateImpl) ReplicateTransientWorkflowTaskScheduled 

func (e *MutableStateImpl) ReplicateTransientWorkflowTaskScheduled() (*WorkflowTaskInfo, error)

func (*MutableStateImpl) ReplicateUpsertWorkflowSearchAttributesEvent 

func (e *MutableStateImpl) ReplicateUpsertWorkflowSearchAttributesEvent(
	event *historypb.HistoryEvent,
)

func (*MutableStateImpl) ReplicateWorkflowExecutionCancelRequestedEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionCancelRequestedEvent(
	_ *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionCanceledEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionCanceledEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionCompletedEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionCompletedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionContinuedAsNewEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionContinuedAsNewEvent(
	firstEventID int64,
	continueAsNewEvent *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionFailedEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionFailedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionSignaled 

func (e *MutableStateImpl) ReplicateWorkflowExecutionSignaled(
	_ *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionStartedEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionStartedEvent(
	parentClock *clockspb.VectorClock,
	execution commonpb.WorkflowExecution,
	requestID string,
	startEvent *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionTerminatedEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionTerminatedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowExecutionTimedoutEvent 

func (e *MutableStateImpl) ReplicateWorkflowExecutionTimedoutEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowTaskCompletedEvent 

func (e *MutableStateImpl) ReplicateWorkflowTaskCompletedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ReplicateWorkflowTaskFailedEvent 

func (e *MutableStateImpl) ReplicateWorkflowTaskFailedEvent() error

func (*MutableStateImpl) ReplicateWorkflowTaskScheduledEvent 

func (e *MutableStateImpl) ReplicateWorkflowTaskScheduledEvent(
	version int64,
	scheduledEventID int64,
	taskQueue *taskqueuepb.TaskQueue,
	startToCloseTimeout *time.Duration,
	attempt int32,
	scheduleTimestamp *time.Time,
	originalScheduledTimestamp *time.Time,
) (*WorkflowTaskInfo, error)

func (*MutableStateImpl) ReplicateWorkflowTaskStartedEvent 

func (e *MutableStateImpl) ReplicateWorkflowTaskStartedEvent(
	workflowTask *WorkflowTaskInfo,
	version int64,
	scheduledEventID int64,
	startedEventID int64,
	requestID string,
	timestamp time.Time,
) (*WorkflowTaskInfo, error)

func (*MutableStateImpl) ReplicateWorkflowTaskTimedOutEvent 

func (e *MutableStateImpl) ReplicateWorkflowTaskTimedOutEvent(
	timeoutType enumspb.TimeoutType,
) error

func (*MutableStateImpl) RetryActivity 

func (e *MutableStateImpl) RetryActivity(
	ai *persistencespb.ActivityInfo,
	failure *failurepb.Failure,
) (enumspb.RetryState, error)

func (*MutableStateImpl) SetCurrentBranchToken 

func (e *MutableStateImpl) SetCurrentBranchToken(
	branchToken []byte,
) error

func (*MutableStateImpl) SetHistoryBuilder 

func (e *MutableStateImpl) SetHistoryBuilder(hBuilder *HistoryBuilder)

func (*MutableStateImpl) SetHistoryTree 

func (e *MutableStateImpl) SetHistoryTree(
	treeID string,
) error

SetHistoryTree set treeID/historyBranches

func (*MutableStateImpl) SetUpdateCondition 

func (e *MutableStateImpl) SetUpdateCondition(
	nextEventIDInDB int64,
	dbRecordVersion int64,
)

func (*MutableStateImpl) StartTransaction 

func (e *MutableStateImpl) StartTransaction(
	namespaceEntry *namespace.Namespace,
) (bool, error)

func (*MutableStateImpl) UpdateActivity 

func (e *MutableStateImpl) UpdateActivity(
	ai *persistencespb.ActivityInfo,
) error

UpdateActivity updates an activity

func (*MutableStateImpl) UpdateActivityProgress 

func (e *MutableStateImpl) UpdateActivityProgress(
	ai *persistencespb.ActivityInfo,
	request *workflowservice.RecordActivityTaskHeartbeatRequest,
)

func (*MutableStateImpl) UpdateActivityWithTimerHeartbeat 

func (e *MutableStateImpl) UpdateActivityWithTimerHeartbeat(
	ai *persistencespb.ActivityInfo,
	timerTimeoutVisibility time.Time,
) error

UpdateActivityWithTimerHeartbeat updates an activity

func (*MutableStateImpl) UpdateCurrentVersion 

func (e *MutableStateImpl) UpdateCurrentVersion(
	version int64,
	forceUpdate bool,
) error

func (*MutableStateImpl) UpdateDuplicatedResource 

func (e *MutableStateImpl) UpdateDuplicatedResource(
	resourceDedupKey definition.DeduplicationID,
)

func (*MutableStateImpl) UpdateUserTimer 

func (e *MutableStateImpl) UpdateUserTimer(
	ti *persistencespb.TimerInfo,
) error

UpdateUserTimer updates the user timer in progress.

func (*MutableStateImpl) UpdateWorkflowStateStatus 

func (e *MutableStateImpl) UpdateWorkflowStateStatus(
	state enumsspb.WorkflowExecutionState,
	status enumspb.WorkflowExecutionStatus,
) error

type MutableStateRebuilder 

type MutableStateRebuilder interface {
	ApplyEvents(
		namespaceID namespace.ID,
		requestID string,
		execution commonpb.WorkflowExecution,
		history []*historypb.HistoryEvent,
		newRunHistory []*historypb.HistoryEvent,
	) (MutableState, error)
}

type MutableStateRebuilderImpl 

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

func NewMutableStateRebuilder 

func NewMutableStateRebuilder(
	shard shard.Context,
	logger log.Logger,
	mutableState MutableState,
) *MutableStateRebuilderImpl

func (*MutableStateRebuilderImpl) ApplyEvents 

func (b *MutableStateRebuilderImpl) ApplyEvents(
	namespaceID namespace.ID,
	requestID string,
	execution commonpb.WorkflowExecution,
	history []*historypb.HistoryEvent,
	newRunHistory []*historypb.HistoryEvent,
) (MutableState, error)

type NewCacheFn added in v1.13.0 

type NewCacheFn func(shard shard.Context) Cache

func NewCacheFnProvider added in v1.13.0 

func NewCacheFnProvider() NewCacheFn

NewCacheFnProvider provide a NewCacheFn that can be used to create new workflow cache.

type QueryRegistry 

type QueryRegistry interface {
	HasBufferedQuery() bool
	GetBufferedIDs() []string
	HasCompletedQuery() bool
	GetCompletedIDs() []string
	HasUnblockedQuery() bool
	GetUnblockedIDs() []string
	HasFailedQuery() bool
	GetFailedIDs() []string

	GetQueryTermCh(string) (<-chan struct{}, error)
	GetQueryInput(string) (*querypb.WorkflowQuery, error)
	GetTerminationState(string) (*QueryTerminationState, error)

	BufferQuery(queryInput *querypb.WorkflowQuery) (string, <-chan struct{})
	SetTerminationState(string, *QueryTerminationState) error
	RemoveQuery(id string)
	Clear()
}

func NewQueryRegistry 

func NewQueryRegistry() QueryRegistry

type QueryTerminationState 

type QueryTerminationState struct {
	QueryTerminationType QueryTerminationType
	QueryResult          *querypb.WorkflowQueryResult
	Failure              error
}

type QueryTerminationType 

type QueryTerminationType int
const (
	QueryTerminationTypeCompleted QueryTerminationType = iota
	QueryTerminationTypeUnblocked
	QueryTerminationTypeFailed
)

type ReleaseCacheFunc 

type ReleaseCacheFunc func(err error)
var NoopReleaseFn ReleaseCacheFunc = func(err error) {}

type TaskGenerator 

type TaskGenerator interface {
	GenerateWorkflowStartTasks(
		now time.Time,
		startEvent *historypb.HistoryEvent,
	) error
	GenerateWorkflowCloseTasks(
		now time.Time,
		deleteAfterClose bool,
	) error
	GenerateDeleteExecutionTask(
		now time.Time,
	) (*tasks.DeleteExecutionTask, error)
	GenerateRecordWorkflowStartedTasks(
		now time.Time,
		startEvent *historypb.HistoryEvent,
	) error
	GenerateDelayedWorkflowTasks(
		now time.Time,
		startEvent *historypb.HistoryEvent,
	) error
	GenerateScheduleWorkflowTaskTasks(
		now time.Time,
		workflowTaskScheduledEventID int64,
	) error
	GenerateStartWorkflowTaskTasks(
		now time.Time,
		workflowTaskScheduledEventID int64,
	) error
	GenerateActivityTasks(
		now time.Time,
		event *historypb.HistoryEvent,
	) error
	GenerateActivityRetryTasks(
		activityScheduledEventID int64,
	) error
	GenerateChildWorkflowTasks(
		now time.Time,
		event *historypb.HistoryEvent,
	) error
	GenerateRequestCancelExternalTasks(
		now time.Time,
		event *historypb.HistoryEvent,
	) error
	GenerateSignalExternalTasks(
		now time.Time,
		event *historypb.HistoryEvent,
	) error
	GenerateWorkflowSearchAttrTasks(
		now time.Time,
	) error
	GenerateWorkflowResetTasks(
		now time.Time,
	) error

	GenerateActivityTimerTasks(
		now time.Time,
	) error
	GenerateUserTimerTasks(
		now time.Time,
	) error

	GenerateHistoryReplicationTasks(
		now time.Time,
		branchToken []byte,
		events []*historypb.HistoryEvent,
	) error
	GenerateMigrationTasks(
		now time.Time,
	) (tasks.Task, error)
}

type TaskGeneratorImpl 

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

func NewTaskGenerator 

func NewTaskGenerator(
	namespaceRegistry namespace.Registry,
	mutableState MutableState,
) *TaskGeneratorImpl

func (*TaskGeneratorImpl) GenerateActivityRetryTasks 

func (r *TaskGeneratorImpl) GenerateActivityRetryTasks(
	activityScheduledEventID int64,
) error

func (*TaskGeneratorImpl) GenerateActivityTasks added in v1.16.0 

func (r *TaskGeneratorImpl) GenerateActivityTasks(
	now time.Time,
	event *historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateActivityTimerTasks 

func (r *TaskGeneratorImpl) GenerateActivityTimerTasks(
	now time.Time,
) error

func (*TaskGeneratorImpl) GenerateChildWorkflowTasks 

func (r *TaskGeneratorImpl) GenerateChildWorkflowTasks(
	now time.Time,
	event *historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateDelayedWorkflowTasks 

func (r *TaskGeneratorImpl) GenerateDelayedWorkflowTasks(
	now time.Time,
	startEvent *historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateDeleteExecutionTask added in v1.15.0 

func (r *TaskGeneratorImpl) GenerateDeleteExecutionTask(
	now time.Time,
) (*tasks.DeleteExecutionTask, error)

func (*TaskGeneratorImpl) GenerateHistoryReplicationTasks added in v1.14.0 

func (r *TaskGeneratorImpl) GenerateHistoryReplicationTasks(
	now time.Time,
	branchToken []byte,
	events []*historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateMigrationTasks added in v1.17.0 

func (r *TaskGeneratorImpl) GenerateMigrationTasks(
	now time.Time,
) (tasks.Task, error)

func (*TaskGeneratorImpl) GenerateRecordWorkflowStartedTasks 

func (r *TaskGeneratorImpl) GenerateRecordWorkflowStartedTasks(
	now time.Time,
	startEvent *historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateRequestCancelExternalTasks 

func (r *TaskGeneratorImpl) GenerateRequestCancelExternalTasks(
	now time.Time,
	event *historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateScheduleWorkflowTaskTasks 

func (r *TaskGeneratorImpl) GenerateScheduleWorkflowTaskTasks(
	now time.Time,
	workflowTaskScheduledEventID int64,
) error

func (*TaskGeneratorImpl) GenerateSignalExternalTasks 

func (r *TaskGeneratorImpl) GenerateSignalExternalTasks(
	now time.Time,
	event *historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateStartWorkflowTaskTasks 

func (r *TaskGeneratorImpl) GenerateStartWorkflowTaskTasks(
	_ time.Time,
	workflowTaskScheduledEventID int64,
) error

func (*TaskGeneratorImpl) GenerateUserTimerTasks 

func (r *TaskGeneratorImpl) GenerateUserTimerTasks(
	now time.Time,
) error

func (*TaskGeneratorImpl) GenerateWorkflowCloseTasks 

func (r *TaskGeneratorImpl) GenerateWorkflowCloseTasks(
	now time.Time,
	deleteAfterClose bool,
) error

func (*TaskGeneratorImpl) GenerateWorkflowResetTasks 

func (r *TaskGeneratorImpl) GenerateWorkflowResetTasks(
	now time.Time,
) error

func (*TaskGeneratorImpl) GenerateWorkflowSearchAttrTasks 

func (r *TaskGeneratorImpl) GenerateWorkflowSearchAttrTasks(
	now time.Time,
) error

func (*TaskGeneratorImpl) GenerateWorkflowStartTasks 

func (r *TaskGeneratorImpl) GenerateWorkflowStartTasks(
	_ time.Time,
	startEvent *historypb.HistoryEvent,
) error

type TaskGeneratorProvider added in v1.16.0 

type TaskGeneratorProvider interface {
	NewTaskGenerator(shard.Context, MutableState) TaskGenerator
}

func NewTaskGeneratorProvider added in v1.16.0 

func NewTaskGeneratorProvider() TaskGeneratorProvider

type TaskIDGenerator 

type TaskIDGenerator func(number int) ([]int64, error)

TODO should the reorderFunc functionality be ported?

type TaskRefresher 

type TaskRefresher interface {
	RefreshTasks(ctx context.Context, now time.Time, mutableState MutableState) error
}

type TaskRefresherImpl 

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

func NewTaskRefresher 

func NewTaskRefresher(
	shard shard.Context,
	config *configs.Config,
	namespaceRegistry namespace.Registry,
	eventsCache events.Cache,
	logger log.Logger,
) *TaskRefresherImpl

func (*TaskRefresherImpl) RefreshTasks 

func (r *TaskRefresherImpl) RefreshTasks(
	ctx context.Context,
	now time.Time,
	mutableState MutableState,
) error

type TimerSequence 

type TimerSequence interface {
	IsExpired(referenceTime time.Time, timerSequenceID TimerSequenceID) bool

	CreateNextUserTimer() (bool, error)
	CreateNextActivityTimer() (bool, error)

	LoadAndSortUserTimers() []TimerSequenceID
	LoadAndSortActivityTimers() []TimerSequenceID
}

type TimerSequenceID 

type TimerSequenceID struct {
	EventID      int64
	Timestamp    time.Time
	TimerType    enumspb.TimeoutType
	TimerCreated bool
	Attempt      int32
}

TimerSequenceID represent a in mem timer

type TimerSequenceIDs 

type TimerSequenceIDs []TimerSequenceID

func (TimerSequenceIDs) Len 

func (s TimerSequenceIDs) Len() int

Len implements sort.Interface

func (TimerSequenceIDs) Less 

func (s TimerSequenceIDs) Less(
	this int,
	that int,
) bool

Less implements sort.Interface

func (TimerSequenceIDs) Swap 

func (s TimerSequenceIDs) Swap(
	this int,
	that int,
)

Swap implements sort.Interface.

type Transaction added in v1.12.0 

type Transaction interface {
	CreateWorkflowExecution(
		ctx context.Context,
		createMode persistence.CreateWorkflowMode,
		newWorkflowSnapshot *persistence.WorkflowSnapshot,
		newWorkflowEventsSeq []*persistence.WorkflowEvents,
		clusterName string,
	) (int64, error)

	ConflictResolveWorkflowExecution(
		ctx context.Context,
		conflictResolveMode persistence.ConflictResolveWorkflowMode,
		resetWorkflowSnapshot *persistence.WorkflowSnapshot,
		resetWorkflowEventsSeq []*persistence.WorkflowEvents,
		newWorkflowSnapshot *persistence.WorkflowSnapshot,
		newWorkflowEventsSeq []*persistence.WorkflowEvents,
		currentWorkflowMutation *persistence.WorkflowMutation,
		currentWorkflowEventsSeq []*persistence.WorkflowEvents,
		clusterName string,
	) (int64, int64, int64, error)

	UpdateWorkflowExecution(
		ctx context.Context,
		updateMode persistence.UpdateWorkflowMode,
		currentWorkflowMutation *persistence.WorkflowMutation,
		currentWorkflowEventsSeq []*persistence.WorkflowEvents,
		newWorkflowSnapshot *persistence.WorkflowSnapshot,
		newWorkflowEventsSeq []*persistence.WorkflowEvents,
		clusterName string,
	) (int64, int64, error)

	SetWorkflowExecution(
		ctx context.Context,
		workflowSnapshot *persistence.WorkflowSnapshot,
		clusterName string,
	) error
}

type TransactionImpl added in v1.12.0 

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

func NewTransaction added in v1.12.0 

func NewTransaction(
	shard shard.Context,
) *TransactionImpl

func (*TransactionImpl) ConflictResolveWorkflowExecution added in v1.12.0 

func (t *TransactionImpl) ConflictResolveWorkflowExecution(
	ctx context.Context,
	conflictResolveMode persistence.ConflictResolveWorkflowMode,
	resetWorkflowSnapshot *persistence.WorkflowSnapshot,
	resetWorkflowEventsSeq []*persistence.WorkflowEvents,
	newWorkflowSnapshot *persistence.WorkflowSnapshot,
	newWorkflowEventsSeq []*persistence.WorkflowEvents,
	currentWorkflowMutation *persistence.WorkflowMutation,
	currentWorkflowEventsSeq []*persistence.WorkflowEvents,
	clusterName string,
) (int64, int64, int64, error)

func (*TransactionImpl) CreateWorkflowExecution added in v1.12.0 

func (t *TransactionImpl) CreateWorkflowExecution(
	ctx context.Context,
	createMode persistence.CreateWorkflowMode,
	newWorkflowSnapshot *persistence.WorkflowSnapshot,
	newWorkflowEventsSeq []*persistence.WorkflowEvents,
	clusterName string,
) (int64, error)

func (*TransactionImpl) SetWorkflowExecution added in v1.16.0 

func (t *TransactionImpl) SetWorkflowExecution(
	ctx context.Context,
	workflowSnapshot *persistence.WorkflowSnapshot,
	clusterName string,
) error

func (*TransactionImpl) UpdateWorkflowExecution added in v1.12.0 

func (t *TransactionImpl) UpdateWorkflowExecution(
	ctx context.Context,
	updateMode persistence.UpdateWorkflowMode,
	currentWorkflowMutation *persistence.WorkflowMutation,
	currentWorkflowEventsSeq []*persistence.WorkflowEvents,
	newWorkflowSnapshot *persistence.WorkflowSnapshot,
	newWorkflowEventsSeq []*persistence.WorkflowEvents,
	clusterName string,
) (int64, int64, error)

type TransactionPolicy 

type TransactionPolicy int
const (
	TransactionPolicyActive  TransactionPolicy = 0
	TransactionPolicyPassive TransactionPolicy = 1
)

func (TransactionPolicy) Ptr 

func (policy TransactionPolicy) Ptr() *TransactionPolicy

type WorkflowTaskInfo 

type WorkflowTaskInfo struct {
	Version             int64
	ScheduledEventID    int64
	StartedEventID      int64
	RequestID           string
	WorkflowTaskTimeout *time.Duration
	// This is only needed to communicate task queue used after AddWorkflowTaskScheduledEvent.
	TaskQueue *taskqueuepb.TaskQueue
	Attempt   int32
	// Scheduled and Started timestamps are useful for transient workflow task: when transient workflow task finally completes,
	// use these Timestamp to create scheduled/started events.
	// Also used for recording latency metrics
	ScheduledTime *time.Time
	StartedTime   *time.Time
	// OriginalScheduledTime is to record the first scheduled workflow task during workflow task heartbeat.
	// Client may to heartbeat workflow task by RespondWorkflowTaskComplete with ForceCreateNewWorkflowTask == true
	// In this case, OriginalScheduledTime won't change. Then when time.Now().UTC()-OriginalScheduledTime exceeds
	// some threshold, server can interrupt the heartbeat by enforcing to time out the workflow task.
	OriginalScheduledTime *time.Time
}

TODO: This should be part of persistence layer

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.