workflow

package
v1.26.2-122.0 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2024 License: MIT Imports: 82 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.

Index

Constants

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 (
	// EmptyVersionedTransition is the zero value for VersionedTransition.
	// It's not a valid versioned transition for a workflow, and should only
	// be used for representing the absence of a versioned transition.
	// EmptyVersionedTransition is also considered less than any non-empty versioned transition.
	EmptyVersionedTransition = &persistencespb.VersionedTransition{
		NamespaceFailoverVersion: common.EmptyVersion,
		TransitionCount:          0,
	}
)
View Source 
var ErrDuplicateRegistration = errors.New("duplicate registration")

ErrDuplicateRegistration is returned by a CommandHandlerRegistry when it detects duplicate registration.

View Source 
var Module = fx.Options(
	fx.Provide(func() TaskGeneratorProvider { return defaultTaskGeneratorProvider }),
	fx.Invoke(populateTaskGeneratorProvider),
	fx.Provide(RelocatableAttributesFetcherProvider),
	fx.Invoke(RegisterStateMachine),
)

Functions

func AddNextStateMachineTimerTask added in v1.25.0 

func AddNextStateMachineTimerTask(ms MutableState)

AddNextStateMachineTimerTask generates a state machine timer task if the first deadline doesn't have a task scheduled yet.

func CompareVersionedTransition added in v1.25.0 

func CompareVersionedTransition(
	a, b *persistencespb.VersionedTransition,
) int

CompareVersionedTransition compares two VersionedTransition structs. Returns -1 if a < b, 0 if a == b, 1 if a > b.

A VersionedTransition is considered less than another if its NamespaceFailoverVersion is less than the other's. Or if the NamespaceFailoverVersion is the same, then the TransitionCount is compared. Nil is considered the same as EmptyVersionedTransition, thus smaller than any non-empty versioned transition.

func CopyVersionedTransitions added in v1.26.0 

func CopyVersionedTransitions(
	transitions []*persistencespb.VersionedTransition,
) []*persistencespb.VersionedTransition

func ExponentialBackoffAlgorithm added in v1.24.0 

func ExponentialBackoffAlgorithm(initInterval *durationpb.Duration, backoffCoefficient float64, currentAttempt int32) time.Duration

func FindAutoResetPoint 

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

FindAutoResetPoint returns the auto reset point

func GetPerTaskQueueFamilyScope added in v1.25.0 

func GetPerTaskQueueFamilyScope(
	handler metrics.Handler,
	namespaceName namespace.Name,
	taskQueueFamily string,
	config *configs.Config,
	tags ...metrics.Tag,
) metrics.Handler

func MutableStateFailoverVersion added in v1.20.0 

func MutableStateFailoverVersion(
	mutableState MutableState,
) *int64

func NewMapEventCache added in v1.21.0 

func NewMapEventCache(
	t *testing.T,
	m map[events.EventKey]*historypb.HistoryEvent,
) events.Cache

NewMapEventCache is a functional event cache mock that wraps a simple Go map

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,
)

func NotifyWorkflowSnapshotTasks added in v1.12.0 

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

func PersistWorkflowEvents added in v1.12.0 

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

func RefreshTasksForWorkflowStart added in v1.25.0 

func RefreshTasksForWorkflowStart(
	ctx context.Context,
	mutableState MutableState,
	taskGenerator TaskGenerator,
	minVersionedTransition *persistencespb.VersionedTransition,
) error

func RegisterStateMachine added in v1.24.0 

func RegisterStateMachine(reg *hsm.Registry) error

func SanitizeMutableState added in v1.25.0 

func SanitizeMutableState(
	workflowMutableState *persistence.WorkflowMutableState,
) error

func SanitizeStateMachineNode added in v1.25.0 

func SanitizeStateMachineNode(
	node *persistence.StateMachineNode,
)

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,
	terminateReason string,
	terminateDetails *commonpb.Payloads,
	terminateIdentity string,
	deleteAfterTerminate bool,
	links []*commonpb.Link,
) error

TerminateWorkflow will write a WorkflowExecutionTerminated event with a fresh batch ID. Do not use for situations where the WorkflowExecutionTerminated event must fall within an existing event batch (for example, if you've already failed a workflow task via `failWorkflowTask` and have an event batch ID).

func TestCloneToProto 

func TestCloneToProto(
	mutableState MutableState,
) *persistencespb.WorkflowMutableState

func TimeoutWorkflow 

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

func TrackStateMachineTimer added in v1.25.0 

func TrackStateMachineTimer(ms MutableState, deadline time.Time, taskInfo *persistencespb.StateMachineTaskInfo)

TrackStateMachineTimer tracks a timer task in the mutable state's StateMachineTimers slice sorted and grouped by deadline.

func TransitionHistoryStalenessCheck added in v1.24.0 

func TransitionHistoryStalenessCheck(
	history []*persistencespb.VersionedTransition,
	refVersionedTransition *persistencespb.VersionedTransition,
) error

TransitionHistoryStalenessCheck verifies that ref namespace failover version and transition count is contained in the given transition history.

When a task or API request is being processed, the history is compared with the imprinted state reference to verify that the state is not stale or that the task/request itself is not stale. For example, if the state has a history of `[{v: 1, t: 3}, {v: 2, t: 5}]`, task A `{v: 2, t: 4}` **is not** referencing stale state because for version `2` transitions `4-5` are valid, while task B `{v: 2, t: 6}` **is** referencing stale state because the transition count is out of range for version `2`. Furthermore, task C `{v: 1, t: 4}` itself is stale because it is referencing an impossible state, likely due to post split-brain reconciliation. NOTE: This function should only be used when there is reloading logic on top of it, since the error returned is a terminal error.

func TrimStateMachineTimers added in v1.25.0 

func TrimStateMachineTimers(
	mutableState MutableState,
	minVersionedTransition *persistencespb.VersionedTransition,
) error

TrimStateMachineTimers returns of copy of trimmed the StateMachineTimers slice by removing any timer tasks that are associated with an HSM node that has been deleted or updated on or after the provided minVersionedTransition.

func UpdatedTransitionHistory added in v1.24.0 

func UpdatedTransitionHistory(
	history []*persistencespb.VersionedTransition,
	namespaceFailoverVersion int64,
) []*persistencespb.VersionedTransition

UpdatedTransitionHistory takes a slice of transition history and returns a new slice that includes the max state transition count for the given version. If the given version is the version of the last history item, that item will be replaced in the returned slice with an item containing the modified transition count. Does not modify the history slice in place.

Types

type BackoffCalculatorAlgorithmFunc added in v1.24.0 

type BackoffCalculatorAlgorithmFunc func(duration *durationpb.Duration, coefficient float64, currentAttempt int32) time.Duration

type CommandHandler added in v1.24.0 

type CommandHandler func(
	context.Context,
	MutableState,
	CommandValidator,
	int64,
	*commandpb.Command,
) error

CommandHandler is a function for handling a workflow command as part of processing a RespondWorkflowTaskCompleted worker request.

type CommandHandlerRegistry added in v1.24.0 

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

CommandHandlerRegistry maintains a mapping of command type to CommandHandler.

func NewCommandHandlerRegistry added in v1.24.0 

func NewCommandHandlerRegistry() *CommandHandlerRegistry

NewCommandHandlerRegistry creates a new CommandHandlerRegistry.

func (*CommandHandlerRegistry) Handler added in v1.24.0 

func (r *CommandHandlerRegistry) Handler(t enumspb.CommandType) (handler CommandHandler, ok bool)

Handler returns a CommandHandler for a given type and a boolean indicating whether it was found.

func (*CommandHandlerRegistry) Register added in v1.24.0 

func (r *CommandHandlerRegistry) Register(t enumspb.CommandType, handler CommandHandler) error

Register registers a CommandHandler for a given command type. Returns an ErrDuplicateRegistration if a handler for the given command is already registered. All registration is expected to happen in a single thread on process initialization.

type CommandValidator added in v1.24.0 

type CommandValidator interface {
	// IsValidPayloadSize validates that a payload size is within the configured limits.
	IsValidPayloadSize(size int) bool
}

CommandValidator is a helper for validating workflow commands.

type Context 

type Context interface {
	GetWorkflowKey() definition.WorkflowKey

	LoadMutableState(ctx context.Context, shardContext shard.Context) (MutableState, error)
	LoadExecutionStats(ctx context.Context, shardContext shard.Context) (*persistencespb.ExecutionStats, error)
	Clear()

	Lock(ctx context.Context, lockPriority locks.Priority) error
	Unlock()

	IsDirty() bool

	RefreshTasks(ctx context.Context, shardContext shard.Context) error

	ReapplyEvents(
		ctx context.Context,
		shardContext shard.Context,
		eventBatches []*persistence.WorkflowEvents,
	) error

	PersistWorkflowEvents(
		ctx context.Context,
		shardContext shard.Context,
		workflowEventsSlice ...*persistence.WorkflowEvents,
	) (int64, error)

	CreateWorkflowExecution(
		ctx context.Context,
		shardContext shard.Context,
		createMode persistence.CreateWorkflowMode,
		prevRunID string,
		prevLastWriteVersion int64,
		newMutableState MutableState,
		newWorkflow *persistence.WorkflowSnapshot,
		newWorkflowEvents []*persistence.WorkflowEvents,
	) error
	ConflictResolveWorkflowExecution(
		ctx context.Context,
		shardContext shard.Context,
		conflictResolveMode persistence.ConflictResolveWorkflowMode,
		resetMutableState MutableState,
		newContext Context,
		newMutableState MutableState,
		currentContext Context,
		currentMutableState MutableState,
		resetWorkflowTransactionPolicy TransactionPolicy,
		newWorkflowTransactionPolicy *TransactionPolicy,
		currentTransactionPolicy *TransactionPolicy,
	) error
	UpdateWorkflowExecutionAsActive(
		ctx context.Context,
		shardContext shard.Context,
	) error
	UpdateWorkflowExecutionWithNewAsActive(
		ctx context.Context,
		shardContext shard.Context,
		newContext Context,
		newMutableState MutableState,
	) error
	UpdateWorkflowExecutionAsPassive(
		ctx context.Context,
		shardContext shard.Context,
	) error
	UpdateWorkflowExecutionWithNewAsPassive(
		ctx context.Context,
		shardContext shard.Context,
		newContext Context,
		newMutableState MutableState,
	) error
	UpdateWorkflowExecutionWithNew(
		ctx context.Context,
		shardContext shard.Context,
		updateMode persistence.UpdateWorkflowMode,
		newContext Context,
		newMutableState MutableState,
		updateWorkflowTransactionPolicy TransactionPolicy,
		newWorkflowTransactionPolicy *TransactionPolicy,
	) error
	// SetWorkflowExecution is an alias to SubmitClosedWorkflowSnapshot with TransactionPolicyPassive.
	SetWorkflowExecution(
		ctx context.Context,
		shardContext shard.Context,
	) error
	// SubmitClosedWorkflowSnapshot closes the current mutable state transaction with the given
	// transactionPolicy and updates the workflow execution record in the DB. Does not check the "current"
	// run status for the execution.
	// Closes the transaction as snapshot, which errors out if there are any buffered events that need
	// flushing and generally does not expect new history events to be generated (expected for closed
	// workflows).
	// NOTE: in the future, we'd like to have the ability to close the transaction as mutation to avoid the
	// overhead of overwriting the entire DB record.
	SubmitClosedWorkflowSnapshot(
		ctx context.Context,
		shardContext shard.Context,
		transactionPolicy TransactionPolicy,
	) error
	// TODO (alex-update): move this from workflow context.
	UpdateRegistry(ctx context.Context, ms MutableState) update.Registry
}

type ContextImpl 

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

func NewContext 

func NewContext(
	config *configs.Config,
	workflowKey definition.WorkflowKey,
	logger log.Logger,
	throttledLogger log.ThrottledLogger,
	metricsHandler metrics.Handler,
) *ContextImpl

func (*ContextImpl) CacheSize added in v1.24.0 

func (c *ContextImpl) CacheSize() int

CacheSize estimates the in-memory size of the object for cache limits. For proto objects, it uses proto.Size() which returns the serialized size. Note: In-memory size will be slightly larger than the serialized size.

func (*ContextImpl) Clear 

func (c *ContextImpl) Clear()

func (*ContextImpl) ConflictResolveWorkflowExecution 

func (c *ContextImpl) ConflictResolveWorkflowExecution(
	ctx context.Context,
	shardContext shard.Context,
	conflictResolveMode persistence.ConflictResolveWorkflowMode,
	resetMutableState MutableState,
	newContext Context,
	newMutableState MutableState,
	currentContext Context,
	currentMutableState MutableState,
	resetWorkflowTransactionPolicy TransactionPolicy,
	newWorkflowTransactionPolicy *TransactionPolicy,
	currentTransactionPolicy *TransactionPolicy,
) (retError error)

func (*ContextImpl) CreateWorkflowExecution 

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

func (*ContextImpl) GetNamespace 

func (c *ContextImpl) GetNamespace(shardContext shard.Context) namespace.Name

func (*ContextImpl) GetWorkflowKey added in v1.19.0 

func (c *ContextImpl) GetWorkflowKey() definition.WorkflowKey

func (*ContextImpl) IsDirty added in v1.22.0 

func (c *ContextImpl) IsDirty() bool

func (*ContextImpl) LoadExecutionStats 

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

func (*ContextImpl) LoadMutableState added in v1.18.0 

func (c *ContextImpl) LoadMutableState(ctx context.Context, shardContext shard.Context) (MutableState, error)

func (*ContextImpl) Lock 

func (c *ContextImpl) Lock(
	ctx context.Context,
	lockPriority locks.Priority,
) error

func (*ContextImpl) PersistWorkflowEvents added in v1.12.0 

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

func (*ContextImpl) ReapplyEvents 

func (c *ContextImpl) ReapplyEvents(
	ctx context.Context,
	shardContext shard.Context,
	eventBatches []*persistence.WorkflowEvents,
) error

func (*ContextImpl) RefreshTasks added in v1.25.0 

func (c *ContextImpl) RefreshTasks(
	ctx context.Context,
	shardContext shard.Context,
) error

func (*ContextImpl) SetWorkflowExecution added in v1.16.0 

func (c *ContextImpl) SetWorkflowExecution(
	ctx context.Context,
	shardContext shard.Context,
) (retError error)

func (*ContextImpl) SubmitClosedWorkflowSnapshot added in v1.24.0 

func (c *ContextImpl) SubmitClosedWorkflowSnapshot(
	ctx context.Context,
	shardContext shard.Context,
	transactionPolicy TransactionPolicy,
) (retError error)

func (*ContextImpl) Unlock 

func (c *ContextImpl) Unlock()

func (*ContextImpl) UpdateRegistry added in v1.21.0 

func (c *ContextImpl) UpdateRegistry(ctx context.Context, fallbackMutableState MutableState) update.Registry

TODO: remove `fallbackMutableState` parameter again (added since it's not possible to initialize a new Context with a specific MutableState)

func (*ContextImpl) UpdateWorkflowExecutionAsActive 

func (c *ContextImpl) UpdateWorkflowExecutionAsActive(
	ctx context.Context,
	shardContext shard.Context,
) error

func (*ContextImpl) UpdateWorkflowExecutionAsPassive 

func (c *ContextImpl) UpdateWorkflowExecutionAsPassive(
	ctx context.Context,
	shardContext shard.Context,
) error

func (*ContextImpl) UpdateWorkflowExecutionWithNew 

func (c *ContextImpl) UpdateWorkflowExecutionWithNew(
	ctx context.Context,
	shardContext shard.Context,
	updateMode persistence.UpdateWorkflowMode,
	newContext Context,
	newMutableState MutableState,
	updateWorkflowTransactionPolicy TransactionPolicy,
	newWorkflowTransactionPolicy *TransactionPolicy,
) (retError error)

func (*ContextImpl) UpdateWorkflowExecutionWithNewAsActive 

func (c *ContextImpl) UpdateWorkflowExecutionWithNewAsActive(
	ctx context.Context,
	shardContext shard.Context,
	newContext Context,
	newMutableState MutableState,
) error

func (*ContextImpl) UpdateWorkflowExecutionWithNewAsPassive 

func (c *ContextImpl) UpdateWorkflowExecutionWithNewAsPassive(
	ctx context.Context,
	shardContext shard.Context,
	newContext Context,
	newMutableState MutableState,
) error

type FailWorkflowTaskError added in v1.24.0 

type FailWorkflowTaskError struct {
	// The cause to set on the WorkflowTaskFailed event.
	Cause             enumspb.WorkflowTaskFailedCause
	Message           string
	TerminateWorkflow bool
}

FailWorkflowTaskError is an error that can be returned from a CommandHandler to fail the current workflow task and optionally terminate the entire workflow.

func (FailWorkflowTaskError) Error added in v1.24.0 

func (e FailWorkflowTaskError) Error() string

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, shardContext shard.Context, conflictResolveMode persistence0.ConflictResolveWorkflowMode, resetMutableState MutableState, newContext Context, newMutableState MutableState, currentContext Context, currentMutableState MutableState, resetWorkflowTransactionPolicy TransactionPolicy, newWorkflowTransactionPolicy, currentTransactionPolicy *TransactionPolicy) error

ConflictResolveWorkflowExecution mocks base method.

func (*MockContext) CreateWorkflowExecution 

func (m *MockContext) CreateWorkflowExecution(ctx context.Context, shardContext shard.Context, createMode persistence0.CreateWorkflowMode, prevRunID string, prevLastWriteVersion int64, newMutableState MutableState, newWorkflow *persistence0.WorkflowSnapshot, newWorkflowEvents []*persistence0.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) GetWorkflowKey added in v1.19.0 

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

GetWorkflowKey mocks base method.

func (*MockContext) IsDirty added in v1.22.0 

func (m *MockContext) IsDirty() bool

IsDirty mocks base method.

func (*MockContext) LoadExecutionStats 

func (m *MockContext) LoadExecutionStats(ctx context.Context, shardContext shard.Context) (*persistence.ExecutionStats, error)

LoadExecutionStats mocks base method.

func (*MockContext) LoadMutableState added in v1.18.0 

func (m *MockContext) LoadMutableState(ctx context.Context, shardContext shard.Context) (MutableState, error)

LoadMutableState mocks base method.

func (*MockContext) Lock 

func (m *MockContext) Lock(ctx context.Context, lockPriority locks.Priority) error

Lock mocks base method.

func (*MockContext) PersistWorkflowEvents added in v1.12.0 

func (m *MockContext) PersistWorkflowEvents(ctx context.Context, shardContext shard.Context, workflowEventsSlice ...*persistence0.WorkflowEvents) (int64, error)

PersistWorkflowEvents mocks base method.

func (*MockContext) ReapplyEvents 

func (m *MockContext) ReapplyEvents(ctx context.Context, shardContext shard.Context, eventBatches []*persistence0.WorkflowEvents) error

ReapplyEvents mocks base method.

func (*MockContext) RefreshTasks added in v1.25.0 

func (m *MockContext) RefreshTasks(ctx context.Context, shardContext shard.Context) error

RefreshTasks mocks base method.

func (*MockContext) SetWorkflowExecution added in v1.16.0 

func (m *MockContext) SetWorkflowExecution(ctx context.Context, shardContext shard.Context) error

SetWorkflowExecution mocks base method.

func (*MockContext) SubmitClosedWorkflowSnapshot added in v1.24.0 

func (m *MockContext) SubmitClosedWorkflowSnapshot(ctx context.Context, shardContext shard.Context, transactionPolicy TransactionPolicy) error

SubmitClosedWorkflowSnapshot mocks base method.

func (*MockContext) Unlock 

func (m *MockContext) Unlock()

Unlock mocks base method.

func (*MockContext) UpdateRegistry added in v1.21.0 

func (m *MockContext) UpdateRegistry(ctx context.Context, ms MutableState) update.Registry

UpdateRegistry mocks base method.

func (*MockContext) UpdateWorkflowExecutionAsActive 

func (m *MockContext) UpdateWorkflowExecutionAsActive(ctx context.Context, shardContext shard.Context) error

UpdateWorkflowExecutionAsActive mocks base method.

func (*MockContext) UpdateWorkflowExecutionAsPassive 

func (m *MockContext) UpdateWorkflowExecutionAsPassive(ctx context.Context, shardContext shard.Context) error

UpdateWorkflowExecutionAsPassive mocks base method.

func (*MockContext) UpdateWorkflowExecutionWithNew 

func (m *MockContext) UpdateWorkflowExecutionWithNew(ctx context.Context, shardContext shard.Context, updateMode persistence0.UpdateWorkflowMode, newContext Context, newMutableState MutableState, updateWorkflowTransactionPolicy TransactionPolicy, newWorkflowTransactionPolicy *TransactionPolicy) error

UpdateWorkflowExecutionWithNew mocks base method.

func (*MockContext) UpdateWorkflowExecutionWithNewAsActive 

func (m *MockContext) UpdateWorkflowExecutionWithNewAsActive(ctx context.Context, shardContext shard.Context, newContext Context, newMutableState MutableState) error

UpdateWorkflowExecutionWithNewAsActive mocks base method.

func (*MockContext) UpdateWorkflowExecutionWithNewAsPassive 

func (m *MockContext) UpdateWorkflowExecutionWithNewAsPassive(ctx context.Context, shardContext shard.Context, 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, shardContext, conflictResolveMode, resetMutableState, newContext, newMutableState, currentContext, currentMutableState, resetWorkflowTransactionPolicy, newWorkflowTransactionPolicy, currentTransactionPolicy any) *gomock.Call

ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.

func (*MockContextMockRecorder) CreateWorkflowExecution 

func (mr *MockContextMockRecorder) CreateWorkflowExecution(ctx, shardContext, createMode, prevRunID, prevLastWriteVersion, newMutableState, newWorkflow, newWorkflowEvents any) *gomock.Call

CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.

func (*MockContextMockRecorder) GetWorkflowKey added in v1.19.0 

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

GetWorkflowKey indicates an expected call of GetWorkflowKey.

func (*MockContextMockRecorder) IsDirty added in v1.22.0 

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

IsDirty indicates an expected call of IsDirty.

func (*MockContextMockRecorder) LoadExecutionStats 

func (mr *MockContextMockRecorder) LoadExecutionStats(ctx, shardContext any) *gomock.Call

LoadExecutionStats indicates an expected call of LoadExecutionStats.

func (*MockContextMockRecorder) LoadMutableState added in v1.18.0 

func (mr *MockContextMockRecorder) LoadMutableState(ctx, shardContext any) *gomock.Call

LoadMutableState indicates an expected call of LoadMutableState.

func (*MockContextMockRecorder) Lock 

func (mr *MockContextMockRecorder) Lock(ctx, lockPriority any) *gomock.Call

Lock indicates an expected call of Lock.

func (*MockContextMockRecorder) PersistWorkflowEvents added in v1.12.0 

func (mr *MockContextMockRecorder) PersistWorkflowEvents(ctx, shardContext any, workflowEventsSlice ...any) *gomock.Call

PersistWorkflowEvents indicates an expected call of PersistWorkflowEvents.

func (*MockContextMockRecorder) ReapplyEvents 

func (mr *MockContextMockRecorder) ReapplyEvents(ctx, shardContext, eventBatches any) *gomock.Call

ReapplyEvents indicates an expected call of ReapplyEvents.

func (*MockContextMockRecorder) RefreshTasks added in v1.25.0 

func (mr *MockContextMockRecorder) RefreshTasks(ctx, shardContext any) *gomock.Call

RefreshTasks indicates an expected call of RefreshTasks.

func (*MockContextMockRecorder) SetWorkflowExecution added in v1.16.0 

func (mr *MockContextMockRecorder) SetWorkflowExecution(ctx, shardContext any) *gomock.Call

SetWorkflowExecution indicates an expected call of SetWorkflowExecution.

func (*MockContextMockRecorder) SubmitClosedWorkflowSnapshot added in v1.24.0 

func (mr *MockContextMockRecorder) SubmitClosedWorkflowSnapshot(ctx, shardContext, transactionPolicy any) *gomock.Call

SubmitClosedWorkflowSnapshot indicates an expected call of SubmitClosedWorkflowSnapshot.

func (*MockContextMockRecorder) Unlock 

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

Unlock indicates an expected call of Unlock.

func (*MockContextMockRecorder) UpdateRegistry added in v1.21.0 

func (mr *MockContextMockRecorder) UpdateRegistry(ctx, ms any) *gomock.Call

UpdateRegistry indicates an expected call of UpdateRegistry.

func (*MockContextMockRecorder) UpdateWorkflowExecutionAsActive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionAsActive(ctx, shardContext any) *gomock.Call

UpdateWorkflowExecutionAsActive indicates an expected call of UpdateWorkflowExecutionAsActive.

func (*MockContextMockRecorder) UpdateWorkflowExecutionAsPassive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionAsPassive(ctx, shardContext any) *gomock.Call

UpdateWorkflowExecutionAsPassive indicates an expected call of UpdateWorkflowExecutionAsPassive.

func (*MockContextMockRecorder) UpdateWorkflowExecutionWithNew 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionWithNew(ctx, shardContext, updateMode, newContext, newMutableState, updateWorkflowTransactionPolicy, newWorkflowTransactionPolicy any) *gomock.Call

UpdateWorkflowExecutionWithNew indicates an expected call of UpdateWorkflowExecutionWithNew.

func (*MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsActive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsActive(ctx, shardContext, newContext, newMutableState any) *gomock.Call

UpdateWorkflowExecutionWithNewAsActive indicates an expected call of UpdateWorkflowExecutionWithNewAsActive.

func (*MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsPassive 

func (mr *MockContextMockRecorder) UpdateWorkflowExecutionWithNewAsPassive(ctx, shardContext, newContext, newMutableState any) *gomock.Call

UpdateWorkflowExecutionWithNewAsPassive indicates an expected call of UpdateWorkflowExecutionWithNewAsPassive.

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) (*history.HistoryEvent, *persistence.ActivityInfo, error)

AddActivityTaskCancelRequestedEvent mocks base method.

func (*MockMutableState) AddActivityTaskCanceledEvent 

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

AddActivityTaskCanceledEvent mocks base method.

func (*MockMutableState) AddActivityTaskCompletedEvent 

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

AddActivityTaskCompletedEvent mocks base method.

func (*MockMutableState) AddActivityTaskFailedEvent 

func (m *MockMutableState) AddActivityTaskFailedEvent(arg0, arg1 int64, arg2 *failure.Failure, arg3 enums.RetryState, arg4 string, arg5 *common.WorkerVersionStamp) (*history.HistoryEvent, error)

AddActivityTaskFailedEvent mocks base method.

func (*MockMutableState) AddActivityTaskScheduledEvent 

func (m *MockMutableState) AddActivityTaskScheduledEvent(arg0 int64, arg1 *command.ScheduleActivityTaskCommandAttributes, arg2 bool) (*history.HistoryEvent, *persistence.ActivityInfo, error)

AddActivityTaskScheduledEvent mocks base method.

func (*MockMutableState) AddActivityTaskStartedEvent 

func (m *MockMutableState) AddActivityTaskStartedEvent(arg0 *persistence.ActivityInfo, arg1 int64, arg2, arg3 string, arg4 *common.WorkerVersionStamp, arg5 *taskqueue0.BuildIdRedirectInfo) (*history.HistoryEvent, error)

AddActivityTaskStartedEvent mocks base method.

func (*MockMutableState) AddActivityTaskTimedOutEvent 

func (m *MockMutableState) AddActivityTaskTimedOutEvent(arg0, arg1 int64, arg2 *failure.Failure, arg3 enums.RetryState) (*history.HistoryEvent, error)

AddActivityTaskTimedOutEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionCanceledEvent 

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

AddChildWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionCompletedEvent 

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

AddChildWorkflowExecutionCompletedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionFailedEvent 

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

AddChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionStartedEvent 

func (m *MockMutableState) AddChildWorkflowExecutionStartedEvent(arg0 *common.WorkflowExecution, arg1 *common.WorkflowType, arg2 int64, arg3 *common.Header, arg4 *clock.VectorClock) (*history.HistoryEvent, error)

AddChildWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionTerminatedEvent 

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

AddChildWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) AddChildWorkflowExecutionTimedOutEvent 

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

AddChildWorkflowExecutionTimedOutEvent mocks base method.

func (*MockMutableState) AddCompletedWorkflowEvent 

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

AddCompletedWorkflowEvent mocks base method.

func (*MockMutableState) AddContinueAsNewEvent 

func (m *MockMutableState) AddContinueAsNewEvent(arg0 context.Context, arg1, arg2 int64, arg3 namespace.Name, arg4 *command.ContinueAsNewWorkflowExecutionCommandAttributes) (*history.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) (*history.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) (*history.HistoryEvent, error)

AddExternalWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) AddFailWorkflowEvent 

func (m *MockMutableState) AddFailWorkflowEvent(arg0 int64, arg1 enums.RetryState, arg2 *command.FailWorkflowExecutionCommandAttributes, arg3 string) (*history.HistoryEvent, error)

AddFailWorkflowEvent mocks base method.

func (*MockMutableState) AddFirstWorkflowTaskScheduled 

func (m *MockMutableState) AddFirstWorkflowTaskScheduled(parentClock *clock.VectorClock, event *history.HistoryEvent, bypassTaskGeneration bool) (int64, error)

AddFirstWorkflowTaskScheduled mocks base method.

func (*MockMutableState) AddHistoryEvent added in v1.24.0 

func (m *MockMutableState) AddHistoryEvent(t enums.EventType, setAttributes func(*history.HistoryEvent)) *history.HistoryEvent

AddHistoryEvent mocks base method.

func (*MockMutableState) AddHistorySize added in v1.21.0 

func (m *MockMutableState) AddHistorySize(size int64)

AddHistorySize mocks base method.

func (*MockMutableState) AddRecordMarkerEvent 

func (m *MockMutableState) AddRecordMarkerEvent(arg0 int64, arg1 *command.RecordMarkerCommandAttributes) (*history.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 enums.CancelExternalWorkflowExecutionFailedCause) (*history.HistoryEvent, error)

AddRequestCancelExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) AddRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 string, arg2 *command.RequestCancelExternalWorkflowExecutionCommandAttributes, arg3 namespace.ID) (*history.HistoryEvent, *persistence.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 enums.SignalExternalWorkflowExecutionFailedCause) (*history.HistoryEvent, error)

AddSignalExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddSignalExternalWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) AddSignalExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 string, arg2 *command.SignalExternalWorkflowExecutionCommandAttributes, arg3 namespace.ID) (*history.HistoryEvent, *persistence.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 enums.StartChildWorkflowExecutionFailedCause, arg2 *history.StartChildWorkflowExecutionInitiatedEventAttributes) (*history.HistoryEvent, error)

AddStartChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) AddStartChildWorkflowExecutionInitiatedEvent 

func (m *MockMutableState) AddStartChildWorkflowExecutionInitiatedEvent(arg0 int64, arg1 string, arg2 *command.StartChildWorkflowExecutionCommandAttributes, arg3 namespace.ID) (*history.HistoryEvent, *persistence.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 enums.RetryState, arg2 string) (*history.HistoryEvent, error)

AddTimeoutWorkflowEvent mocks base method.

func (*MockMutableState) AddTimerCanceledEvent 

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

AddTimerCanceledEvent mocks base method.

func (*MockMutableState) AddTimerFiredEvent 

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

AddTimerFiredEvent mocks base method.

func (*MockMutableState) AddTimerStartedEvent 

func (m *MockMutableState) AddTimerStartedEvent(arg0 int64, arg1 *command.StartTimerCommandAttributes) (*history.HistoryEvent, *persistence.TimerInfo, error)

AddTimerStartedEvent mocks base method.

func (*MockMutableState) AddUpsertWorkflowSearchAttributesEvent 

func (m *MockMutableState) AddUpsertWorkflowSearchAttributesEvent(arg0 int64, arg1 *command.UpsertWorkflowSearchAttributesCommandAttributes) (*history.HistoryEvent, error)

AddUpsertWorkflowSearchAttributesEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionCancelRequestedEvent 

func (m *MockMutableState) AddWorkflowExecutionCancelRequestedEvent(arg0 *historyservice.RequestCancelWorkflowExecutionRequest) (*history.HistoryEvent, error)

AddWorkflowExecutionCancelRequestedEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionCanceledEvent 

func (m *MockMutableState) AddWorkflowExecutionCanceledEvent(arg0 int64, arg1 *command.CancelWorkflowExecutionCommandAttributes) (*history.HistoryEvent, error)

AddWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionSignaled 

func (m *MockMutableState) AddWorkflowExecutionSignaled(signalName string, input *common.Payloads, identity string, header *common.Header, skipGenerateWorkflowTask bool, links []*common.Link) (*history.HistoryEvent, error)

AddWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) AddWorkflowExecutionSignaledEvent added in v1.24.0 

func (m *MockMutableState) AddWorkflowExecutionSignaledEvent(signalName string, input *common.Payloads, identity string, header *common.Header, skipGenerateWorkflowTask bool, externalWorkflowExecution *common.WorkflowExecution, links []*common.Link) (*history.HistoryEvent, error)

AddWorkflowExecutionSignaledEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionStartedEvent 

func (m *MockMutableState) AddWorkflowExecutionStartedEvent(arg0 *common.WorkflowExecution, arg1 *historyservice.StartWorkflowExecutionRequest) (*history.HistoryEvent, error)

AddWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionStartedEventWithOptions added in v1.13.0 

func (m *MockMutableState) AddWorkflowExecutionStartedEventWithOptions(arg0 *common.WorkflowExecution, arg1 *historyservice.StartWorkflowExecutionRequest, arg2 *workflow.ResetPoints, arg3, arg4 string) (*history.HistoryEvent, error)

AddWorkflowExecutionStartedEventWithOptions mocks base method.

func (*MockMutableState) AddWorkflowExecutionTerminatedEvent 

func (m *MockMutableState) AddWorkflowExecutionTerminatedEvent(firstEventID int64, reason string, details *common.Payloads, identity string, deleteAfterTerminate bool, links []*common.Link) (*history.HistoryEvent, error)

AddWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionUpdateAcceptedEvent added in v1.20.0 

func (m *MockMutableState) AddWorkflowExecutionUpdateAcceptedEvent(protocolInstanceID, acceptedRequestMessageId string, acceptedRequestSequencingEventId int64, acceptedRequest *update.Request) (*history.HistoryEvent, error)

AddWorkflowExecutionUpdateAcceptedEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionUpdateAdmittedEvent added in v1.24.0 

func (m *MockMutableState) AddWorkflowExecutionUpdateAdmittedEvent(request *update.Request, origin enums.UpdateAdmittedEventOrigin) (*history.HistoryEvent, error)

AddWorkflowExecutionUpdateAdmittedEvent mocks base method.

func (*MockMutableState) AddWorkflowExecutionUpdateCompletedEvent added in v1.20.0 

func (m *MockMutableState) AddWorkflowExecutionUpdateCompletedEvent(acceptedEventID int64, updResp *update.Response) (*history.HistoryEvent, error)

AddWorkflowExecutionUpdateCompletedEvent mocks base method.

func (*MockMutableState) AddWorkflowPropertiesModifiedEvent added in v1.18.0 

func (m *MockMutableState) AddWorkflowPropertiesModifiedEvent(arg0 int64, arg1 *command.ModifyWorkflowPropertiesCommandAttributes) (*history.HistoryEvent, error)

AddWorkflowPropertiesModifiedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskCompletedEvent 

func (m *MockMutableState) AddWorkflowTaskCompletedEvent(arg0 *WorkflowTaskInfo, arg1 *workflowservice.RespondWorkflowTaskCompletedRequest, arg2 WorkflowTaskCompletionLimits) (*history.HistoryEvent, error)

AddWorkflowTaskCompletedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskFailedEvent 

func (m *MockMutableState) AddWorkflowTaskFailedEvent(workflowTask *WorkflowTaskInfo, cause enums.WorkflowTaskFailedCause, failure *failure.Failure, identity string, versioningStamp *common.WorkerVersionStamp, binChecksum, baseRunID, newRunID string, forkEventVersion int64) (*history.HistoryEvent, error)

AddWorkflowTaskFailedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskScheduleToStartTimeoutEvent 

func (m *MockMutableState) AddWorkflowTaskScheduleToStartTimeoutEvent(workflowTask *WorkflowTaskInfo) (*history.HistoryEvent, error)

AddWorkflowTaskScheduleToStartTimeoutEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskScheduledEvent 

func (m *MockMutableState) AddWorkflowTaskScheduledEvent(bypassTaskGeneration bool, workflowTaskType enums0.WorkflowTaskType) (*WorkflowTaskInfo, error)

AddWorkflowTaskScheduledEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskScheduledEventAsHeartbeat 

func (m *MockMutableState) AddWorkflowTaskScheduledEventAsHeartbeat(bypassTaskGeneration bool, originalScheduledTimestamp *timestamppb.Timestamp, workflowTaskType enums0.WorkflowTaskType) (*WorkflowTaskInfo, error)

AddWorkflowTaskScheduledEventAsHeartbeat mocks base method.

func (*MockMutableState) AddWorkflowTaskStartedEvent 

func (m *MockMutableState) AddWorkflowTaskStartedEvent(arg0 int64, arg1 string, arg2 *taskqueue.TaskQueue, arg3 string, arg4 *common.WorkerVersionStamp, arg5 *taskqueue0.BuildIdRedirectInfo, arg6 bool) (*history.HistoryEvent, *WorkflowTaskInfo, error)

AddWorkflowTaskStartedEvent mocks base method.

func (*MockMutableState) AddWorkflowTaskTimedOutEvent 

func (m *MockMutableState) AddWorkflowTaskTimedOutEvent(workflowTask *WorkflowTaskInfo) (*history.HistoryEvent, error)

AddWorkflowTaskTimedOutEvent mocks base method.

func (*MockMutableState) ApplyActivityTaskCancelRequestedEvent added in v1.24.0 

func (m *MockMutableState) ApplyActivityTaskCancelRequestedEvent(arg0 *history.HistoryEvent) error

ApplyActivityTaskCancelRequestedEvent mocks base method.

func (*MockMutableState) ApplyActivityTaskCanceledEvent added in v1.24.0 

func (m *MockMutableState) ApplyActivityTaskCanceledEvent(arg0 *history.HistoryEvent) error

ApplyActivityTaskCanceledEvent mocks base method.

func (*MockMutableState) ApplyActivityTaskCompletedEvent added in v1.24.0 

func (m *MockMutableState) ApplyActivityTaskCompletedEvent(arg0 *history.HistoryEvent) error

ApplyActivityTaskCompletedEvent mocks base method.

func (*MockMutableState) ApplyActivityTaskFailedEvent added in v1.24.0 

func (m *MockMutableState) ApplyActivityTaskFailedEvent(arg0 *history.HistoryEvent) error

ApplyActivityTaskFailedEvent mocks base method.

func (*MockMutableState) ApplyActivityTaskScheduledEvent added in v1.24.0 

func (m *MockMutableState) ApplyActivityTaskScheduledEvent(arg0 int64, arg1 *history.HistoryEvent) (*persistence.ActivityInfo, error)

ApplyActivityTaskScheduledEvent mocks base method.

func (*MockMutableState) ApplyActivityTaskStartedEvent added in v1.24.0 

func (m *MockMutableState) ApplyActivityTaskStartedEvent(arg0 *history.HistoryEvent) error

ApplyActivityTaskStartedEvent mocks base method.

func (*MockMutableState) ApplyActivityTaskTimedOutEvent added in v1.24.0 

func (m *MockMutableState) ApplyActivityTaskTimedOutEvent(arg0 *history.HistoryEvent) error

ApplyActivityTaskTimedOutEvent mocks base method.

func (*MockMutableState) ApplyBuildIdRedirect added in v1.24.0 

func (m *MockMutableState) ApplyBuildIdRedirect(startingTaskScheduledEventId int64, buildId string, redirectCounter int64) error

ApplyBuildIdRedirect mocks base method.

func (*MockMutableState) ApplyChildWorkflowExecutionCanceledEvent added in v1.24.0 

func (m *MockMutableState) ApplyChildWorkflowExecutionCanceledEvent(arg0 *history.HistoryEvent) error

ApplyChildWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) ApplyChildWorkflowExecutionCompletedEvent added in v1.24.0 

func (m *MockMutableState) ApplyChildWorkflowExecutionCompletedEvent(arg0 *history.HistoryEvent) error

ApplyChildWorkflowExecutionCompletedEvent mocks base method.

func (*MockMutableState) ApplyChildWorkflowExecutionFailedEvent added in v1.24.0 

func (m *MockMutableState) ApplyChildWorkflowExecutionFailedEvent(arg0 *history.HistoryEvent) error

ApplyChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ApplyChildWorkflowExecutionStartedEvent added in v1.24.0 

func (m *MockMutableState) ApplyChildWorkflowExecutionStartedEvent(arg0 *history.HistoryEvent, arg1 *clock.VectorClock) error

ApplyChildWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) ApplyChildWorkflowExecutionTerminatedEvent added in v1.24.0 

func (m *MockMutableState) ApplyChildWorkflowExecutionTerminatedEvent(arg0 *history.HistoryEvent) error

ApplyChildWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) ApplyChildWorkflowExecutionTimedOutEvent added in v1.24.0 

func (m *MockMutableState) ApplyChildWorkflowExecutionTimedOutEvent(arg0 *history.HistoryEvent) error

ApplyChildWorkflowExecutionTimedOutEvent mocks base method.

func (*MockMutableState) ApplyExternalWorkflowExecutionCancelRequested added in v1.24.0 

func (m *MockMutableState) ApplyExternalWorkflowExecutionCancelRequested(arg0 *history.HistoryEvent) error

ApplyExternalWorkflowExecutionCancelRequested mocks base method.

func (*MockMutableState) ApplyExternalWorkflowExecutionSignaled added in v1.24.0 

func (m *MockMutableState) ApplyExternalWorkflowExecutionSignaled(arg0 *history.HistoryEvent) error

ApplyExternalWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) ApplyRequestCancelExternalWorkflowExecutionFailedEvent added in v1.24.0 

func (m *MockMutableState) ApplyRequestCancelExternalWorkflowExecutionFailedEvent(arg0 *history.HistoryEvent) error

ApplyRequestCancelExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent added in v1.24.0 

func (m *MockMutableState) ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 *history.HistoryEvent, arg2 string) (*persistence.RequestCancelInfo, error)

ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) ApplySignalExternalWorkflowExecutionFailedEvent added in v1.24.0 

func (m *MockMutableState) ApplySignalExternalWorkflowExecutionFailedEvent(arg0 *history.HistoryEvent) error

ApplySignalExternalWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ApplySignalExternalWorkflowExecutionInitiatedEvent added in v1.24.0 

func (m *MockMutableState) ApplySignalExternalWorkflowExecutionInitiatedEvent(arg0 int64, arg1 *history.HistoryEvent, arg2 string) (*persistence.SignalInfo, error)

ApplySignalExternalWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) ApplyStartChildWorkflowExecutionFailedEvent added in v1.24.0 

func (m *MockMutableState) ApplyStartChildWorkflowExecutionFailedEvent(arg0 *history.HistoryEvent) error

ApplyStartChildWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ApplyStartChildWorkflowExecutionInitiatedEvent added in v1.24.0 

func (m *MockMutableState) ApplyStartChildWorkflowExecutionInitiatedEvent(arg0 int64, arg1 *history.HistoryEvent, arg2 string) (*persistence.ChildExecutionInfo, error)

ApplyStartChildWorkflowExecutionInitiatedEvent mocks base method.

func (*MockMutableState) ApplyTimerCanceledEvent added in v1.24.0 

func (m *MockMutableState) ApplyTimerCanceledEvent(arg0 *history.HistoryEvent) error

ApplyTimerCanceledEvent mocks base method.

func (*MockMutableState) ApplyTimerFiredEvent added in v1.24.0 

func (m *MockMutableState) ApplyTimerFiredEvent(arg0 *history.HistoryEvent) error

ApplyTimerFiredEvent mocks base method.

func (*MockMutableState) ApplyTimerStartedEvent added in v1.24.0 

func (m *MockMutableState) ApplyTimerStartedEvent(arg0 *history.HistoryEvent) (*persistence.TimerInfo, error)

ApplyTimerStartedEvent mocks base method.

func (*MockMutableState) ApplyTransientWorkflowTaskScheduled added in v1.24.0 

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

ApplyTransientWorkflowTaskScheduled mocks base method.

func (*MockMutableState) ApplyUpsertWorkflowSearchAttributesEvent added in v1.24.0 

func (m *MockMutableState) ApplyUpsertWorkflowSearchAttributesEvent(arg0 *history.HistoryEvent)

ApplyUpsertWorkflowSearchAttributesEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionCancelRequestedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionCancelRequestedEvent(arg0 *history.HistoryEvent) error

ApplyWorkflowExecutionCancelRequestedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionCanceledEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionCanceledEvent(arg0 int64, arg1 *history.HistoryEvent) error

ApplyWorkflowExecutionCanceledEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionCompletedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionCompletedEvent(arg0 int64, arg1 *history.HistoryEvent) error

ApplyWorkflowExecutionCompletedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionContinuedAsNewEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionContinuedAsNewEvent(arg0 int64, arg1 *history.HistoryEvent) error

ApplyWorkflowExecutionContinuedAsNewEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionFailedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionFailedEvent(arg0 int64, arg1 *history.HistoryEvent) error

ApplyWorkflowExecutionFailedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionSignaled added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionSignaled(arg0 *history.HistoryEvent) error

ApplyWorkflowExecutionSignaled mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionStartedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionStartedEvent(arg0 *clock.VectorClock, arg1 *common.WorkflowExecution, arg2 string, arg3 *history.HistoryEvent) error

ApplyWorkflowExecutionStartedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionTerminatedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionTerminatedEvent(arg0 int64, arg1 *history.HistoryEvent) error

ApplyWorkflowExecutionTerminatedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionTimedoutEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionTimedoutEvent(arg0 int64, arg1 *history.HistoryEvent) error

ApplyWorkflowExecutionTimedoutEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionUpdateAcceptedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionUpdateAcceptedEvent(arg0 *history.HistoryEvent) error

ApplyWorkflowExecutionUpdateAcceptedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionUpdateAdmittedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionUpdateAdmittedEvent(event *history.HistoryEvent, batchId int64) error

ApplyWorkflowExecutionUpdateAdmittedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowExecutionUpdateCompletedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowExecutionUpdateCompletedEvent(event *history.HistoryEvent, batchID int64) error

ApplyWorkflowExecutionUpdateCompletedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowPropertiesModifiedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowPropertiesModifiedEvent(arg0 *history.HistoryEvent)

ApplyWorkflowPropertiesModifiedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowTaskCompletedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowTaskCompletedEvent(arg0 *history.HistoryEvent) error

ApplyWorkflowTaskCompletedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowTaskFailedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowTaskFailedEvent() error

ApplyWorkflowTaskFailedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowTaskScheduledEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowTaskScheduledEvent(arg0, arg1 int64, arg2 *taskqueue.TaskQueue, arg3 *durationpb.Duration, arg4 int32, arg5, arg6 *timestamppb.Timestamp, arg7 enums0.WorkflowTaskType) (*WorkflowTaskInfo, error)

ApplyWorkflowTaskScheduledEvent mocks base method.

func (*MockMutableState) ApplyWorkflowTaskStartedEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowTaskStartedEvent(arg0 *WorkflowTaskInfo, arg1, arg2, arg3 int64, arg4 string, arg5 time.Time, arg6 bool, arg7 int64, arg8 *common.WorkerVersionStamp, arg9 int64) (*WorkflowTaskInfo, error)

ApplyWorkflowTaskStartedEvent mocks base method.

func (*MockMutableState) ApplyWorkflowTaskTimedOutEvent added in v1.24.0 

func (m *MockMutableState) ApplyWorkflowTaskTimedOutEvent(arg0 enums.TimeoutType) error

ApplyWorkflowTaskTimedOutEvent mocks base method.

func (*MockMutableState) CheckResettable 

func (m *MockMutableState) CheckResettable() error

CheckResettable mocks base method.

func (*MockMutableState) CheckSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (m *MockMutableState) CheckSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) bool

CheckSpeculativeWorkflowTaskTimeoutTask mocks base method.

func (*MockMutableState) ClearStickyTaskQueue added in v1.21.0 

func (m *MockMutableState) ClearStickyTaskQueue()

ClearStickyTaskQueue 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() *persistence.WorkflowMutableState

CloneToProto mocks base method.

func (*MockMutableState) CloseTransactionAsMutation 

func (m *MockMutableState) CloseTransactionAsMutation(transactionPolicy TransactionPolicy) (*persistence0.WorkflowMutation, []*persistence0.WorkflowEvents, error)

CloseTransactionAsMutation mocks base method.

func (*MockMutableState) CloseTransactionAsSnapshot 

func (m *MockMutableState) CloseTransactionAsSnapshot(transactionPolicy TransactionPolicy) (*persistence0.WorkflowSnapshot, []*persistence0.WorkflowEvents, error)

CloseTransactionAsSnapshot mocks base method.

func (*MockMutableState) ContinueAsNewMinBackoff added in v1.19.0 

func (m *MockMutableState) ContinueAsNewMinBackoff(backoffDuration *durationpb.Duration) *durationpb.Duration

ContinueAsNewMinBackoff mocks base method.

func (*MockMutableState) CurrentTaskQueue added in v1.21.0 

func (m *MockMutableState) CurrentTaskQueue() *taskqueue.TaskQueue

CurrentTaskQueue mocks base method.

func (*MockMutableState) DeleteSignalRequested 

func (m *MockMutableState) DeleteSignalRequested(requestID string)

DeleteSignalRequested 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() ([]tasks.Task, int64, error)

GenerateMigrationTasks mocks base method.

func (*MockMutableState) GetActivityByActivityID 

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

GetActivityByActivityID mocks base method.

func (*MockMutableState) GetActivityInfo 

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

GetActivityInfo mocks base method.

func (*MockMutableState) GetActivityInfoWithTimerHeartbeat 

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

GetActivityInfoWithTimerHeartbeat mocks base method.

func (*MockMutableState) GetActivityScheduledEvent 

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

GetActivityScheduledEvent mocks base method.

func (*MockMutableState) GetActivityType added in v1.22.0 

func (m *MockMutableState) GetActivityType(arg0 context.Context, arg1 *persistence.ActivityInfo) (*common.ActivityType, error)

GetActivityType mocks base method.

func (*MockMutableState) GetApproximatePersistedSize added in v1.21.0 

func (m *MockMutableState) GetApproximatePersistedSize() int

GetApproximatePersistedSize mocks base method.

func (*MockMutableState) GetAssignedBuildId added in v1.24.0 

func (m *MockMutableState) GetAssignedBuildId() string

GetAssignedBuildId mocks base method.

func (*MockMutableState) GetBaseWorkflowInfo added in v1.21.0 

func (m *MockMutableState) GetBaseWorkflowInfo() *workflow0.BaseExecutionInfo

GetBaseWorkflowInfo mocks base method.

func (*MockMutableState) GetChildExecutionInfo 

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

GetChildExecutionInfo mocks base method.

func (*MockMutableState) GetChildExecutionInitiatedEvent 

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

GetChildExecutionInitiatedEvent mocks base method.

func (*MockMutableState) GetCloseVersion added in v1.25.0 

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

GetCloseVersion mocks base method.

func (*MockMutableState) GetCompletionEvent 

func (m *MockMutableState) GetCompletionEvent(arg0 context.Context) (*history.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() *persistence.WorkflowExecutionInfo

GetExecutionInfo mocks base method.

func (*MockMutableState) GetExecutionState 

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

GetExecutionState mocks base method.

func (*MockMutableState) GetFirstRunID added in v1.13.0 

func (m *MockMutableState) GetFirstRunID(ctx context.Context) (string, error)

GetFirstRunID mocks base method.

func (*MockMutableState) GetHSMCompletionCallbackArg added in v1.25.0 

func (m *MockMutableState) GetHSMCompletionCallbackArg(ctx context.Context) (*persistence.HSMCompletionCallbackArg, error)

GetHSMCompletionCallbackArg mocks base method.

func (*MockMutableState) GetHistorySize added in v1.21.0 

func (m *MockMutableState) GetHistorySize() int64

GetHistorySize mocks base method.

func (*MockMutableState) GetInheritedBuildId added in v1.24.0 

func (m *MockMutableState) GetInheritedBuildId() string

GetInheritedBuildId mocks base method.

func (*MockMutableState) GetLastCompletedWorkflowTaskStartedEventId added in v1.25.0 

func (m *MockMutableState) GetLastCompletedWorkflowTaskStartedEventId() int64

GetLastCompletedWorkflowTaskStartedEventId mocks base method.

func (*MockMutableState) GetLastEventVersion added in v1.25.0 

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

GetLastEventVersion 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) GetMostRecentWorkerVersionStamp added in v1.24.0 

func (m *MockMutableState) GetMostRecentWorkerVersionStamp() *common.WorkerVersionStamp

GetMostRecentWorkerVersionStamp 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) GetNexusCompletion added in v1.24.0 

func (m *MockMutableState) GetNexusCompletion(ctx context.Context) (nexus.OperationCompletion, error)

GetNexusCompletion mocks base method.

func (*MockMutableState) GetPendingActivityInfos 

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

GetPendingActivityInfos mocks base method.

func (*MockMutableState) GetPendingChildExecutionInfos 

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

GetPendingChildExecutionInfos mocks base method.

func (*MockMutableState) GetPendingRequestCancelExternalInfos 

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

GetPendingRequestCancelExternalInfos mocks base method.

func (*MockMutableState) GetPendingSignalExternalInfos 

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

GetPendingSignalExternalInfos mocks base method.

func (*MockMutableState) GetPendingSignalRequestedIds added in v1.26.0 

func (m *MockMutableState) GetPendingSignalRequestedIds() []string

GetPendingSignalRequestedIds mocks base method.

func (*MockMutableState) GetPendingTimerInfos 

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

GetPendingTimerInfos mocks base method.

func (*MockMutableState) GetPendingWorkflowTask 

func (m *MockMutableState) GetPendingWorkflowTask() *WorkflowTaskInfo

GetPendingWorkflowTask mocks base method.

func (*MockMutableState) GetQueryRegistry 

func (m *MockMutableState) GetQueryRegistry() QueryRegistry

GetQueryRegistry mocks base method.

func (*MockMutableState) GetRequestCancelInfo 

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

GetRequestCancelInfo mocks base method.

func (*MockMutableState) GetRequesteCancelExternalInitiatedEvent added in v1.16.0 

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

GetRequesteCancelExternalInitiatedEvent mocks base method.

func (*MockMutableState) GetRetryBackoffDuration 

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

GetRetryBackoffDuration mocks base method.

func (*MockMutableState) GetSignalExternalInitiatedEvent added in v1.14.0 

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

GetSignalExternalInitiatedEvent mocks base method.

func (*MockMutableState) GetSignalInfo 

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

GetSignalInfo mocks base method.

func (*MockMutableState) GetStartEvent 

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

GetStartEvent mocks base method.

func (*MockMutableState) GetStartVersion 

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

GetStartVersion mocks base method.

func (*MockMutableState) GetStartedWorkflowTask added in v1.21.0 

func (m *MockMutableState) GetStartedWorkflowTask() *WorkflowTaskInfo

GetStartedWorkflowTask mocks base method.

func (*MockMutableState) GetTransientWorkflowTaskInfo added in v1.20.0 

func (m *MockMutableState) GetTransientWorkflowTaskInfo(workflowTask *WorkflowTaskInfo, identity string) *history0.TransientWorkflowTaskInfo

GetTransientWorkflowTaskInfo mocks base method.

func (*MockMutableState) GetUpdateCondition 

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

GetUpdateCondition mocks base method.

func (*MockMutableState) GetUpdateOutcome added in v1.21.0 

func (m *MockMutableState) GetUpdateOutcome(ctx context.Context, updateID string) (*update.Outcome, error)

GetUpdateOutcome mocks base method.

func (*MockMutableState) GetUserTimerInfo 

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

GetUserTimerInfo mocks base method.

func (*MockMutableState) GetUserTimerInfoByEventID 

func (m *MockMutableState) GetUserTimerInfoByEventID(arg0 int64) (*persistence.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) GetWorkflowExecutionDuration added in v1.24.0 

func (m *MockMutableState) GetWorkflowExecutionDuration(ctx context.Context) (time.Duration, error)

GetWorkflowExecutionDuration 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() (enums0.WorkflowExecutionState, enums.WorkflowExecutionStatus)

GetWorkflowStateStatus mocks base method.

func (*MockMutableState) GetWorkflowTaskByID added in v1.21.0 

func (m *MockMutableState) GetWorkflowTaskByID(scheduledEventID int64) *WorkflowTaskInfo

GetWorkflowTaskByID mocks base method.

func (*MockMutableState) GetWorkflowType 

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

GetWorkflowType mocks base method.

func (*MockMutableState) HSM added in v1.24.0 

func (m *MockMutableState) HSM() *hsm.Node

HSM mocks base method.

func (*MockMutableState) HadOrHasWorkflowTask added in v1.21.0 

func (m *MockMutableState) HadOrHasWorkflowTask() bool

HadOrHasWorkflowTask mocks base method.

func (*MockMutableState) HasAnyBufferedEvent added in v1.21.0 

func (m *MockMutableState) HasAnyBufferedEvent(filter historybuilder.BufferedEventFilter) bool

HasAnyBufferedEvent mocks base method.

func (*MockMutableState) HasBufferedEvents 

func (m *MockMutableState) HasBufferedEvents() bool

HasBufferedEvents mocks base method.

func (*MockMutableState) HasCompletedAnyWorkflowTask added in v1.25.0 

func (m *MockMutableState) HasCompletedAnyWorkflowTask() bool

HasCompletedAnyWorkflowTask 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) HasStartedWorkflowTask added in v1.21.0 

func (m *MockMutableState) HasStartedWorkflowTask() bool

HasStartedWorkflowTask 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) IsDirty added in v1.22.0 

func (m *MockMutableState) IsDirty() bool

IsDirty 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) IsStickyTaskQueueSet added in v1.21.0 

func (m *MockMutableState) IsStickyTaskQueueSet() bool

IsStickyTaskQueueSet mocks base method.

func (*MockMutableState) IsTransientWorkflowTask added in v1.20.0 

func (m *MockMutableState) IsTransientWorkflowTask() bool

IsTransientWorkflowTask mocks base method.

func (*MockMutableState) IsWorkflowCloseAttempted added in v1.21.0 

func (m *MockMutableState) IsWorkflowCloseAttempted() bool

IsWorkflowCloseAttempted 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) LoadHistoryEvent added in v1.24.0 

func (m *MockMutableState) LoadHistoryEvent(ctx context.Context, token []byte) (*history.HistoryEvent, error)

LoadHistoryEvent mocks base method.

func (*MockMutableState) NextTransitionCount added in v1.25.0 

func (m *MockMutableState) NextTransitionCount() int64

NextTransitionCount 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) RefreshExpirationTimeoutTask added in v1.25.0 

func (m *MockMutableState) RefreshExpirationTimeoutTask(ctx context.Context) error

RefreshExpirationTimeoutTask mocks base method.

func (*MockMutableState) RejectWorkflowExecutionUpdate added in v1.20.0 

func (m *MockMutableState) RejectWorkflowExecutionUpdate(protocolInstanceID string, updRejection *update.Rejection) error

RejectWorkflowExecutionUpdate mocks base method.

func (*MockMutableState) RemoveSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (m *MockMutableState) RemoveSpeculativeWorkflowTaskTimeoutTask()

RemoveSpeculativeWorkflowTaskTimeoutTask mocks base method.

func (*MockMutableState) RetryActivity 

func (m *MockMutableState) RetryActivity(ai *persistence.ActivityInfo, failure *failure.Failure) (enums.RetryState, error)

RetryActivity mocks base method.

func (*MockMutableState) SetBaseWorkflow added in v1.21.0 

func (m *MockMutableState) SetBaseWorkflow(baseRunID string, baseRunLowestCommonAncestorEventID, baseRunLowestCommonAncestorEventVersion int64)

SetBaseWorkflow 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.HistoryBuilder)

SetHistoryBuilder mocks base method.

func (*MockMutableState) SetHistoryTree 

func (m *MockMutableState) SetHistoryTree(executionTimeout, runTimeout *durationpb.Duration, treeID string) error

SetHistoryTree mocks base method.

func (*MockMutableState) SetSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (m *MockMutableState) SetSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error

SetSpeculativeWorkflowTaskTimeoutTask mocks base method.

func (*MockMutableState) SetStickyTaskQueue added in v1.21.0 

func (m *MockMutableState) SetStickyTaskQueue(name string, scheduleToStartTimeout *durationpb.Duration)

SetStickyTaskQueue 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) TaskQueueScheduleToStartTimeout added in v1.21.0 

func (m *MockMutableState) TaskQueueScheduleToStartTimeout(name string) (*taskqueue.TaskQueue, *durationpb.Duration)

TaskQueueScheduleToStartTimeout mocks base method.

func (*MockMutableState) UpdateActivity 

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

UpdateActivity mocks base method.

func (*MockMutableState) UpdateActivityInfo added in v1.24.0 

func (m *MockMutableState) UpdateActivityInfo(arg0 *historyservice.ActivitySyncInfo, arg1 bool) error

UpdateActivityInfo mocks base method.

func (*MockMutableState) UpdateActivityProgress 

func (m *MockMutableState) UpdateActivityProgress(ai *persistence.ActivityInfo, request *workflowservice.RecordActivityTaskHeartbeatRequest)

UpdateActivityProgress mocks base method.

func (*MockMutableState) UpdateActivityWithTimerHeartbeat 

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

UpdateActivityWithTimerHeartbeat mocks base method.

func (*MockMutableState) UpdateBuildIdAssignment added in v1.24.0 

func (m *MockMutableState) UpdateBuildIdAssignment(buildId string) error

UpdateBuildIdAssignment 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 *persistence.TimerInfo) error

UpdateUserTimer mocks base method.

func (*MockMutableState) UpdateWorkflowStateStatus 

func (m *MockMutableState) UpdateWorkflowStateStatus(state enums0.WorkflowExecutionState, status enums.WorkflowExecutionStatus) error

UpdateWorkflowStateStatus mocks base method.

func (*MockMutableState) VisitUpdates added in v1.21.0 

func (m *MockMutableState) VisitUpdates(visitor func(string, *persistence.UpdateInfo))

VisitUpdates 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 any) *gomock.Call

AddActivityTaskCancelRequestedEvent indicates an expected call of AddActivityTaskCancelRequestedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskCanceledEvent 

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

AddActivityTaskCanceledEvent indicates an expected call of AddActivityTaskCanceledEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskCompletedEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskCompletedEvent(arg0, arg1, arg2 any) *gomock.Call

AddActivityTaskCompletedEvent indicates an expected call of AddActivityTaskCompletedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskFailedEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskFailedEvent(arg0, arg1, arg2, arg3, arg4, arg5 any) *gomock.Call

AddActivityTaskFailedEvent indicates an expected call of AddActivityTaskFailedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskScheduledEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskScheduledEvent(arg0, arg1, arg2 any) *gomock.Call

AddActivityTaskScheduledEvent indicates an expected call of AddActivityTaskScheduledEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskStartedEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskStartedEvent(arg0, arg1, arg2, arg3, arg4, arg5 any) *gomock.Call

AddActivityTaskStartedEvent indicates an expected call of AddActivityTaskStartedEvent.

func (*MockMutableStateMockRecorder) AddActivityTaskTimedOutEvent 

func (mr *MockMutableStateMockRecorder) AddActivityTaskTimedOutEvent(arg0, arg1, arg2, arg3 any) *gomock.Call

AddActivityTaskTimedOutEvent indicates an expected call of AddActivityTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionCanceledEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionCanceledEvent(arg0, arg1, arg2 any) *gomock.Call

AddChildWorkflowExecutionCanceledEvent indicates an expected call of AddChildWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionCompletedEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionCompletedEvent(arg0, arg1, arg2 any) *gomock.Call

AddChildWorkflowExecutionCompletedEvent indicates an expected call of AddChildWorkflowExecutionCompletedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionFailedEvent(arg0, arg1, arg2 any) *gomock.Call

AddChildWorkflowExecutionFailedEvent indicates an expected call of AddChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionStartedEvent 

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

AddChildWorkflowExecutionStartedEvent indicates an expected call of AddChildWorkflowExecutionStartedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionTerminatedEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionTerminatedEvent(arg0, arg1, arg2 any) *gomock.Call

AddChildWorkflowExecutionTerminatedEvent indicates an expected call of AddChildWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) AddChildWorkflowExecutionTimedOutEvent 

func (mr *MockMutableStateMockRecorder) AddChildWorkflowExecutionTimedOutEvent(arg0, arg1, arg2 any) *gomock.Call

AddChildWorkflowExecutionTimedOutEvent indicates an expected call of AddChildWorkflowExecutionTimedOutEvent.

func (*MockMutableStateMockRecorder) AddCompletedWorkflowEvent 

func (mr *MockMutableStateMockRecorder) AddCompletedWorkflowEvent(arg0, arg1, arg2 any) *gomock.Call

AddCompletedWorkflowEvent indicates an expected call of AddCompletedWorkflowEvent.

func (*MockMutableStateMockRecorder) AddContinueAsNewEvent 

func (mr *MockMutableStateMockRecorder) AddContinueAsNewEvent(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

AddContinueAsNewEvent indicates an expected call of AddContinueAsNewEvent.

func (*MockMutableStateMockRecorder) AddExternalWorkflowExecutionCancelRequested 

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

AddExternalWorkflowExecutionCancelRequested indicates an expected call of AddExternalWorkflowExecutionCancelRequested.

func (*MockMutableStateMockRecorder) AddExternalWorkflowExecutionSignaled 

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

AddExternalWorkflowExecutionSignaled indicates an expected call of AddExternalWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) AddFailWorkflowEvent 

func (mr *MockMutableStateMockRecorder) AddFailWorkflowEvent(arg0, arg1, arg2, arg3 any) *gomock.Call

AddFailWorkflowEvent indicates an expected call of AddFailWorkflowEvent.

func (*MockMutableStateMockRecorder) AddFirstWorkflowTaskScheduled 

func (mr *MockMutableStateMockRecorder) AddFirstWorkflowTaskScheduled(parentClock, event, bypassTaskGeneration any) *gomock.Call

AddFirstWorkflowTaskScheduled indicates an expected call of AddFirstWorkflowTaskScheduled.

func (*MockMutableStateMockRecorder) AddHistoryEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) AddHistoryEvent(t, setAttributes any) *gomock.Call

AddHistoryEvent indicates an expected call of AddHistoryEvent.

func (*MockMutableStateMockRecorder) AddHistorySize added in v1.21.0 

func (mr *MockMutableStateMockRecorder) AddHistorySize(size any) *gomock.Call

AddHistorySize indicates an expected call of AddHistorySize.

func (*MockMutableStateMockRecorder) AddRecordMarkerEvent 

func (mr *MockMutableStateMockRecorder) AddRecordMarkerEvent(arg0, arg1 any) *gomock.Call

AddRecordMarkerEvent indicates an expected call of AddRecordMarkerEvent.

func (*MockMutableStateMockRecorder) AddRequestCancelExternalWorkflowExecutionFailedEvent 

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

AddRequestCancelExternalWorkflowExecutionFailedEvent indicates an expected call of AddRequestCancelExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) AddRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2, arg3 any) *gomock.Call

AddRequestCancelExternalWorkflowExecutionInitiatedEvent indicates an expected call of AddRequestCancelExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) AddSignalExternalWorkflowExecutionFailedEvent 

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

AddSignalExternalWorkflowExecutionFailedEvent indicates an expected call of AddSignalExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddSignalExternalWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) AddSignalExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2, arg3 any) *gomock.Call

AddSignalExternalWorkflowExecutionInitiatedEvent indicates an expected call of AddSignalExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) AddSignalRequested 

func (mr *MockMutableStateMockRecorder) AddSignalRequested(requestID any) *gomock.Call

AddSignalRequested indicates an expected call of AddSignalRequested.

func (*MockMutableStateMockRecorder) AddStartChildWorkflowExecutionFailedEvent 

func (mr *MockMutableStateMockRecorder) AddStartChildWorkflowExecutionFailedEvent(arg0, arg1, arg2 any) *gomock.Call

AddStartChildWorkflowExecutionFailedEvent indicates an expected call of AddStartChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) AddStartChildWorkflowExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) AddStartChildWorkflowExecutionInitiatedEvent(arg0, arg1, arg2, arg3 any) *gomock.Call

AddStartChildWorkflowExecutionInitiatedEvent indicates an expected call of AddStartChildWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) AddTasks added in v1.16.0 

func (mr *MockMutableStateMockRecorder) AddTasks(tasks ...any) *gomock.Call

AddTasks indicates an expected call of AddTasks.

func (*MockMutableStateMockRecorder) AddTimeoutWorkflowEvent 

func (mr *MockMutableStateMockRecorder) AddTimeoutWorkflowEvent(arg0, arg1, arg2 any) *gomock.Call

AddTimeoutWorkflowEvent indicates an expected call of AddTimeoutWorkflowEvent.

func (*MockMutableStateMockRecorder) AddTimerCanceledEvent 

func (mr *MockMutableStateMockRecorder) AddTimerCanceledEvent(arg0, arg1, arg2 any) *gomock.Call

AddTimerCanceledEvent indicates an expected call of AddTimerCanceledEvent.

func (*MockMutableStateMockRecorder) AddTimerFiredEvent 

func (mr *MockMutableStateMockRecorder) AddTimerFiredEvent(arg0 any) *gomock.Call

AddTimerFiredEvent indicates an expected call of AddTimerFiredEvent.

func (*MockMutableStateMockRecorder) AddTimerStartedEvent 

func (mr *MockMutableStateMockRecorder) AddTimerStartedEvent(arg0, arg1 any) *gomock.Call

AddTimerStartedEvent indicates an expected call of AddTimerStartedEvent.

func (*MockMutableStateMockRecorder) AddUpsertWorkflowSearchAttributesEvent 

func (mr *MockMutableStateMockRecorder) AddUpsertWorkflowSearchAttributesEvent(arg0, arg1 any) *gomock.Call

AddUpsertWorkflowSearchAttributesEvent indicates an expected call of AddUpsertWorkflowSearchAttributesEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionCancelRequestedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionCancelRequestedEvent(arg0 any) *gomock.Call

AddWorkflowExecutionCancelRequestedEvent indicates an expected call of AddWorkflowExecutionCancelRequestedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionCanceledEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionCanceledEvent(arg0, arg1 any) *gomock.Call

AddWorkflowExecutionCanceledEvent indicates an expected call of AddWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionSignaled 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionSignaled(signalName, input, identity, header, skipGenerateWorkflowTask, links any) *gomock.Call

AddWorkflowExecutionSignaled indicates an expected call of AddWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionSignaledEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionSignaledEvent(signalName, input, identity, header, skipGenerateWorkflowTask, externalWorkflowExecution, links any) *gomock.Call

AddWorkflowExecutionSignaledEvent indicates an expected call of AddWorkflowExecutionSignaledEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionStartedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionStartedEvent(arg0, arg1 any) *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 any) *gomock.Call

AddWorkflowExecutionStartedEventWithOptions indicates an expected call of AddWorkflowExecutionStartedEventWithOptions.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionTerminatedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionTerminatedEvent(firstEventID, reason, details, identity, deleteAfterTerminate, links any) *gomock.Call

AddWorkflowExecutionTerminatedEvent indicates an expected call of AddWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionUpdateAcceptedEvent added in v1.20.0 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionUpdateAcceptedEvent(protocolInstanceID, acceptedRequestMessageId, acceptedRequestSequencingEventId, acceptedRequest any) *gomock.Call

AddWorkflowExecutionUpdateAcceptedEvent indicates an expected call of AddWorkflowExecutionUpdateAcceptedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionUpdateAdmittedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionUpdateAdmittedEvent(request, origin any) *gomock.Call

AddWorkflowExecutionUpdateAdmittedEvent indicates an expected call of AddWorkflowExecutionUpdateAdmittedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowExecutionUpdateCompletedEvent added in v1.20.0 

func (mr *MockMutableStateMockRecorder) AddWorkflowExecutionUpdateCompletedEvent(acceptedEventID, updResp any) *gomock.Call

AddWorkflowExecutionUpdateCompletedEvent indicates an expected call of AddWorkflowExecutionUpdateCompletedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowPropertiesModifiedEvent added in v1.18.0 

func (mr *MockMutableStateMockRecorder) AddWorkflowPropertiesModifiedEvent(arg0, arg1 any) *gomock.Call

AddWorkflowPropertiesModifiedEvent indicates an expected call of AddWorkflowPropertiesModifiedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskCompletedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskCompletedEvent(arg0, arg1, arg2 any) *gomock.Call

AddWorkflowTaskCompletedEvent indicates an expected call of AddWorkflowTaskCompletedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskFailedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskFailedEvent(workflowTask, cause, failure, identity, versioningStamp, binChecksum, baseRunID, newRunID, forkEventVersion any) *gomock.Call

AddWorkflowTaskFailedEvent indicates an expected call of AddWorkflowTaskFailedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskScheduleToStartTimeoutEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskScheduleToStartTimeoutEvent(workflowTask any) *gomock.Call

AddWorkflowTaskScheduleToStartTimeoutEvent indicates an expected call of AddWorkflowTaskScheduleToStartTimeoutEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskScheduledEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskScheduledEvent(bypassTaskGeneration, workflowTaskType any) *gomock.Call

AddWorkflowTaskScheduledEvent indicates an expected call of AddWorkflowTaskScheduledEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskScheduledEventAsHeartbeat 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskScheduledEventAsHeartbeat(bypassTaskGeneration, originalScheduledTimestamp, workflowTaskType any) *gomock.Call

AddWorkflowTaskScheduledEventAsHeartbeat indicates an expected call of AddWorkflowTaskScheduledEventAsHeartbeat.

func (*MockMutableStateMockRecorder) AddWorkflowTaskStartedEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskStartedEvent(arg0, arg1, arg2, arg3, arg4, arg5, arg6 any) *gomock.Call

AddWorkflowTaskStartedEvent indicates an expected call of AddWorkflowTaskStartedEvent.

func (*MockMutableStateMockRecorder) AddWorkflowTaskTimedOutEvent 

func (mr *MockMutableStateMockRecorder) AddWorkflowTaskTimedOutEvent(workflowTask any) *gomock.Call

AddWorkflowTaskTimedOutEvent indicates an expected call of AddWorkflowTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) ApplyActivityTaskCancelRequestedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyActivityTaskCancelRequestedEvent(arg0 any) *gomock.Call

ApplyActivityTaskCancelRequestedEvent indicates an expected call of ApplyActivityTaskCancelRequestedEvent.

func (*MockMutableStateMockRecorder) ApplyActivityTaskCanceledEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyActivityTaskCanceledEvent(arg0 any) *gomock.Call

ApplyActivityTaskCanceledEvent indicates an expected call of ApplyActivityTaskCanceledEvent.

func (*MockMutableStateMockRecorder) ApplyActivityTaskCompletedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyActivityTaskCompletedEvent(arg0 any) *gomock.Call

ApplyActivityTaskCompletedEvent indicates an expected call of ApplyActivityTaskCompletedEvent.

func (*MockMutableStateMockRecorder) ApplyActivityTaskFailedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyActivityTaskFailedEvent(arg0 any) *gomock.Call

ApplyActivityTaskFailedEvent indicates an expected call of ApplyActivityTaskFailedEvent.

func (*MockMutableStateMockRecorder) ApplyActivityTaskScheduledEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyActivityTaskScheduledEvent(arg0, arg1 any) *gomock.Call

ApplyActivityTaskScheduledEvent indicates an expected call of ApplyActivityTaskScheduledEvent.

func (*MockMutableStateMockRecorder) ApplyActivityTaskStartedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyActivityTaskStartedEvent(arg0 any) *gomock.Call

ApplyActivityTaskStartedEvent indicates an expected call of ApplyActivityTaskStartedEvent.

func (*MockMutableStateMockRecorder) ApplyActivityTaskTimedOutEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyActivityTaskTimedOutEvent(arg0 any) *gomock.Call

ApplyActivityTaskTimedOutEvent indicates an expected call of ApplyActivityTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) ApplyBuildIdRedirect added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyBuildIdRedirect(startingTaskScheduledEventId, buildId, redirectCounter any) *gomock.Call

ApplyBuildIdRedirect indicates an expected call of ApplyBuildIdRedirect.

func (*MockMutableStateMockRecorder) ApplyChildWorkflowExecutionCanceledEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyChildWorkflowExecutionCanceledEvent(arg0 any) *gomock.Call

ApplyChildWorkflowExecutionCanceledEvent indicates an expected call of ApplyChildWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) ApplyChildWorkflowExecutionCompletedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyChildWorkflowExecutionCompletedEvent(arg0 any) *gomock.Call

ApplyChildWorkflowExecutionCompletedEvent indicates an expected call of ApplyChildWorkflowExecutionCompletedEvent.

func (*MockMutableStateMockRecorder) ApplyChildWorkflowExecutionFailedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyChildWorkflowExecutionFailedEvent(arg0 any) *gomock.Call

ApplyChildWorkflowExecutionFailedEvent indicates an expected call of ApplyChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ApplyChildWorkflowExecutionStartedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyChildWorkflowExecutionStartedEvent(arg0, arg1 any) *gomock.Call

ApplyChildWorkflowExecutionStartedEvent indicates an expected call of ApplyChildWorkflowExecutionStartedEvent.

func (*MockMutableStateMockRecorder) ApplyChildWorkflowExecutionTerminatedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyChildWorkflowExecutionTerminatedEvent(arg0 any) *gomock.Call

ApplyChildWorkflowExecutionTerminatedEvent indicates an expected call of ApplyChildWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) ApplyChildWorkflowExecutionTimedOutEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyChildWorkflowExecutionTimedOutEvent(arg0 any) *gomock.Call

ApplyChildWorkflowExecutionTimedOutEvent indicates an expected call of ApplyChildWorkflowExecutionTimedOutEvent.

func (*MockMutableStateMockRecorder) ApplyExternalWorkflowExecutionCancelRequested added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyExternalWorkflowExecutionCancelRequested(arg0 any) *gomock.Call

ApplyExternalWorkflowExecutionCancelRequested indicates an expected call of ApplyExternalWorkflowExecutionCancelRequested.

func (*MockMutableStateMockRecorder) ApplyExternalWorkflowExecutionSignaled added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyExternalWorkflowExecutionSignaled(arg0 any) *gomock.Call

ApplyExternalWorkflowExecutionSignaled indicates an expected call of ApplyExternalWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) ApplyRequestCancelExternalWorkflowExecutionFailedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyRequestCancelExternalWorkflowExecutionFailedEvent(arg0 any) *gomock.Call

ApplyRequestCancelExternalWorkflowExecutionFailedEvent indicates an expected call of ApplyRequestCancelExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2 any) *gomock.Call

ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent indicates an expected call of ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) ApplySignalExternalWorkflowExecutionFailedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplySignalExternalWorkflowExecutionFailedEvent(arg0 any) *gomock.Call

ApplySignalExternalWorkflowExecutionFailedEvent indicates an expected call of ApplySignalExternalWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ApplySignalExternalWorkflowExecutionInitiatedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplySignalExternalWorkflowExecutionInitiatedEvent(arg0, arg1, arg2 any) *gomock.Call

ApplySignalExternalWorkflowExecutionInitiatedEvent indicates an expected call of ApplySignalExternalWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) ApplyStartChildWorkflowExecutionFailedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyStartChildWorkflowExecutionFailedEvent(arg0 any) *gomock.Call

ApplyStartChildWorkflowExecutionFailedEvent indicates an expected call of ApplyStartChildWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ApplyStartChildWorkflowExecutionInitiatedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyStartChildWorkflowExecutionInitiatedEvent(arg0, arg1, arg2 any) *gomock.Call

ApplyStartChildWorkflowExecutionInitiatedEvent indicates an expected call of ApplyStartChildWorkflowExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) ApplyTimerCanceledEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyTimerCanceledEvent(arg0 any) *gomock.Call

ApplyTimerCanceledEvent indicates an expected call of ApplyTimerCanceledEvent.

func (*MockMutableStateMockRecorder) ApplyTimerFiredEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyTimerFiredEvent(arg0 any) *gomock.Call

ApplyTimerFiredEvent indicates an expected call of ApplyTimerFiredEvent.

func (*MockMutableStateMockRecorder) ApplyTimerStartedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyTimerStartedEvent(arg0 any) *gomock.Call

ApplyTimerStartedEvent indicates an expected call of ApplyTimerStartedEvent.

func (*MockMutableStateMockRecorder) ApplyTransientWorkflowTaskScheduled added in v1.24.0 

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

ApplyTransientWorkflowTaskScheduled indicates an expected call of ApplyTransientWorkflowTaskScheduled.

func (*MockMutableStateMockRecorder) ApplyUpsertWorkflowSearchAttributesEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyUpsertWorkflowSearchAttributesEvent(arg0 any) *gomock.Call

ApplyUpsertWorkflowSearchAttributesEvent indicates an expected call of ApplyUpsertWorkflowSearchAttributesEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionCancelRequestedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionCancelRequestedEvent(arg0 any) *gomock.Call

ApplyWorkflowExecutionCancelRequestedEvent indicates an expected call of ApplyWorkflowExecutionCancelRequestedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionCanceledEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionCanceledEvent(arg0, arg1 any) *gomock.Call

ApplyWorkflowExecutionCanceledEvent indicates an expected call of ApplyWorkflowExecutionCanceledEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionCompletedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionCompletedEvent(arg0, arg1 any) *gomock.Call

ApplyWorkflowExecutionCompletedEvent indicates an expected call of ApplyWorkflowExecutionCompletedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionContinuedAsNewEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionContinuedAsNewEvent(arg0, arg1 any) *gomock.Call

ApplyWorkflowExecutionContinuedAsNewEvent indicates an expected call of ApplyWorkflowExecutionContinuedAsNewEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionFailedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionFailedEvent(arg0, arg1 any) *gomock.Call

ApplyWorkflowExecutionFailedEvent indicates an expected call of ApplyWorkflowExecutionFailedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionSignaled added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionSignaled(arg0 any) *gomock.Call

ApplyWorkflowExecutionSignaled indicates an expected call of ApplyWorkflowExecutionSignaled.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionStartedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionStartedEvent(arg0, arg1, arg2, arg3 any) *gomock.Call

ApplyWorkflowExecutionStartedEvent indicates an expected call of ApplyWorkflowExecutionStartedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionTerminatedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionTerminatedEvent(arg0, arg1 any) *gomock.Call

ApplyWorkflowExecutionTerminatedEvent indicates an expected call of ApplyWorkflowExecutionTerminatedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionTimedoutEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionTimedoutEvent(arg0, arg1 any) *gomock.Call

ApplyWorkflowExecutionTimedoutEvent indicates an expected call of ApplyWorkflowExecutionTimedoutEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionUpdateAcceptedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionUpdateAcceptedEvent(arg0 any) *gomock.Call

ApplyWorkflowExecutionUpdateAcceptedEvent indicates an expected call of ApplyWorkflowExecutionUpdateAcceptedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionUpdateAdmittedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionUpdateAdmittedEvent(event, batchId any) *gomock.Call

ApplyWorkflowExecutionUpdateAdmittedEvent indicates an expected call of ApplyWorkflowExecutionUpdateAdmittedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowExecutionUpdateCompletedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowExecutionUpdateCompletedEvent(event, batchID any) *gomock.Call

ApplyWorkflowExecutionUpdateCompletedEvent indicates an expected call of ApplyWorkflowExecutionUpdateCompletedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowPropertiesModifiedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowPropertiesModifiedEvent(arg0 any) *gomock.Call

ApplyWorkflowPropertiesModifiedEvent indicates an expected call of ApplyWorkflowPropertiesModifiedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowTaskCompletedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowTaskCompletedEvent(arg0 any) *gomock.Call

ApplyWorkflowTaskCompletedEvent indicates an expected call of ApplyWorkflowTaskCompletedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowTaskFailedEvent added in v1.24.0 

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

ApplyWorkflowTaskFailedEvent indicates an expected call of ApplyWorkflowTaskFailedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowTaskScheduledEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowTaskScheduledEvent(arg0, arg1, arg2, arg3, arg4, arg5, arg6, arg7 any) *gomock.Call

ApplyWorkflowTaskScheduledEvent indicates an expected call of ApplyWorkflowTaskScheduledEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowTaskStartedEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowTaskStartedEvent(arg0, arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9 any) *gomock.Call

ApplyWorkflowTaskStartedEvent indicates an expected call of ApplyWorkflowTaskStartedEvent.

func (*MockMutableStateMockRecorder) ApplyWorkflowTaskTimedOutEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) ApplyWorkflowTaskTimedOutEvent(arg0 any) *gomock.Call

ApplyWorkflowTaskTimedOutEvent indicates an expected call of ApplyWorkflowTaskTimedOutEvent.

func (*MockMutableStateMockRecorder) CheckResettable 

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

CheckResettable indicates an expected call of CheckResettable.

func (*MockMutableStateMockRecorder) CheckSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (mr *MockMutableStateMockRecorder) CheckSpeculativeWorkflowTaskTimeoutTask(task any) *gomock.Call

CheckSpeculativeWorkflowTaskTimeoutTask indicates an expected call of CheckSpeculativeWorkflowTaskTimeoutTask.

func (*MockMutableStateMockRecorder) ClearStickyTaskQueue added in v1.21.0 

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

ClearStickyTaskQueue indicates an expected call of ClearStickyTaskQueue.

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(transactionPolicy any) *gomock.Call

CloseTransactionAsMutation indicates an expected call of CloseTransactionAsMutation.

func (*MockMutableStateMockRecorder) CloseTransactionAsSnapshot 

func (mr *MockMutableStateMockRecorder) CloseTransactionAsSnapshot(transactionPolicy any) *gomock.Call

CloseTransactionAsSnapshot indicates an expected call of CloseTransactionAsSnapshot.

func (*MockMutableStateMockRecorder) ContinueAsNewMinBackoff added in v1.19.0 

func (mr *MockMutableStateMockRecorder) ContinueAsNewMinBackoff(backoffDuration any) *gomock.Call

ContinueAsNewMinBackoff indicates an expected call of ContinueAsNewMinBackoff.

func (*MockMutableStateMockRecorder) CurrentTaskQueue added in v1.21.0 

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

CurrentTaskQueue indicates an expected call of CurrentTaskQueue.

func (*MockMutableStateMockRecorder) DeleteSignalRequested 

func (mr *MockMutableStateMockRecorder) DeleteSignalRequested(requestID any) *gomock.Call

DeleteSignalRequested indicates an expected call of DeleteSignalRequested.

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() *gomock.Call

GenerateMigrationTasks indicates an expected call of GenerateMigrationTasks.

func (*MockMutableStateMockRecorder) GetActivityByActivityID 

func (mr *MockMutableStateMockRecorder) GetActivityByActivityID(arg0 any) *gomock.Call

GetActivityByActivityID indicates an expected call of GetActivityByActivityID.

func (*MockMutableStateMockRecorder) GetActivityInfo 

func (mr *MockMutableStateMockRecorder) GetActivityInfo(arg0 any) *gomock.Call

GetActivityInfo indicates an expected call of GetActivityInfo.

func (*MockMutableStateMockRecorder) GetActivityInfoWithTimerHeartbeat 

func (mr *MockMutableStateMockRecorder) GetActivityInfoWithTimerHeartbeat(scheduledEventID any) *gomock.Call

GetActivityInfoWithTimerHeartbeat indicates an expected call of GetActivityInfoWithTimerHeartbeat.

func (*MockMutableStateMockRecorder) GetActivityScheduledEvent 

func (mr *MockMutableStateMockRecorder) GetActivityScheduledEvent(arg0, arg1 any) *gomock.Call

GetActivityScheduledEvent indicates an expected call of GetActivityScheduledEvent.

func (*MockMutableStateMockRecorder) GetActivityType added in v1.22.0 

func (mr *MockMutableStateMockRecorder) GetActivityType(arg0, arg1 any) *gomock.Call

GetActivityType indicates an expected call of GetActivityType.

func (*MockMutableStateMockRecorder) GetApproximatePersistedSize added in v1.21.0 

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

GetApproximatePersistedSize indicates an expected call of GetApproximatePersistedSize.

func (*MockMutableStateMockRecorder) GetAssignedBuildId added in v1.24.0 

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

GetAssignedBuildId indicates an expected call of GetAssignedBuildId.

func (*MockMutableStateMockRecorder) GetBaseWorkflowInfo added in v1.21.0 

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

GetBaseWorkflowInfo indicates an expected call of GetBaseWorkflowInfo.

func (*MockMutableStateMockRecorder) GetChildExecutionInfo 

func (mr *MockMutableStateMockRecorder) GetChildExecutionInfo(arg0 any) *gomock.Call

GetChildExecutionInfo indicates an expected call of GetChildExecutionInfo.

func (*MockMutableStateMockRecorder) GetChildExecutionInitiatedEvent 

func (mr *MockMutableStateMockRecorder) GetChildExecutionInitiatedEvent(arg0, arg1 any) *gomock.Call

GetChildExecutionInitiatedEvent indicates an expected call of GetChildExecutionInitiatedEvent.

func (*MockMutableStateMockRecorder) GetCloseVersion added in v1.25.0 

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

GetCloseVersion indicates an expected call of GetCloseVersion.

func (*MockMutableStateMockRecorder) GetCompletionEvent 

func (mr *MockMutableStateMockRecorder) GetCompletionEvent(arg0 any) *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(ctx any) *gomock.Call

GetFirstRunID indicates an expected call of GetFirstRunID.

func (*MockMutableStateMockRecorder) GetHSMCompletionCallbackArg added in v1.25.0 

func (mr *MockMutableStateMockRecorder) GetHSMCompletionCallbackArg(ctx any) *gomock.Call

GetHSMCompletionCallbackArg indicates an expected call of GetHSMCompletionCallbackArg.

func (*MockMutableStateMockRecorder) GetHistorySize added in v1.21.0 

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

GetHistorySize indicates an expected call of GetHistorySize.

func (*MockMutableStateMockRecorder) GetInheritedBuildId added in v1.24.0 

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

GetInheritedBuildId indicates an expected call of GetInheritedBuildId.

func (*MockMutableStateMockRecorder) GetLastCompletedWorkflowTaskStartedEventId added in v1.25.0 

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

GetLastCompletedWorkflowTaskStartedEventId indicates an expected call of GetLastCompletedWorkflowTaskStartedEventId.

func (*MockMutableStateMockRecorder) GetLastEventVersion added in v1.25.0 

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

GetLastEventVersion indicates an expected call of GetLastEventVersion.

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) GetMostRecentWorkerVersionStamp added in v1.24.0 

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

GetMostRecentWorkerVersionStamp indicates an expected call of GetMostRecentWorkerVersionStamp.

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) GetNexusCompletion added in v1.24.0 

func (mr *MockMutableStateMockRecorder) GetNexusCompletion(ctx any) *gomock.Call

GetNexusCompletion indicates an expected call of GetNexusCompletion.

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) GetPendingSignalRequestedIds added in v1.26.0 

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

GetPendingSignalRequestedIds indicates an expected call of GetPendingSignalRequestedIds.

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) GetQueryRegistry 

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

GetQueryRegistry indicates an expected call of GetQueryRegistry.

func (*MockMutableStateMockRecorder) GetRequestCancelInfo 

func (mr *MockMutableStateMockRecorder) GetRequestCancelInfo(arg0 any) *gomock.Call

GetRequestCancelInfo indicates an expected call of GetRequestCancelInfo.

func (*MockMutableStateMockRecorder) GetRequesteCancelExternalInitiatedEvent added in v1.16.0 

func (mr *MockMutableStateMockRecorder) GetRequesteCancelExternalInitiatedEvent(arg0, arg1 any) *gomock.Call

GetRequesteCancelExternalInitiatedEvent indicates an expected call of GetRequesteCancelExternalInitiatedEvent.

func (*MockMutableStateMockRecorder) GetRetryBackoffDuration 

func (mr *MockMutableStateMockRecorder) GetRetryBackoffDuration(failure any) *gomock.Call

GetRetryBackoffDuration indicates an expected call of GetRetryBackoffDuration.

func (*MockMutableStateMockRecorder) GetSignalExternalInitiatedEvent added in v1.14.0 

func (mr *MockMutableStateMockRecorder) GetSignalExternalInitiatedEvent(arg0, arg1 any) *gomock.Call

GetSignalExternalInitiatedEvent indicates an expected call of GetSignalExternalInitiatedEvent.

func (*MockMutableStateMockRecorder) GetSignalInfo 

func (mr *MockMutableStateMockRecorder) GetSignalInfo(arg0 any) *gomock.Call

GetSignalInfo indicates an expected call of GetSignalInfo.

func (*MockMutableStateMockRecorder) GetStartEvent 

func (mr *MockMutableStateMockRecorder) GetStartEvent(arg0 any) *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) GetStartedWorkflowTask added in v1.21.0 

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

GetStartedWorkflowTask indicates an expected call of GetStartedWorkflowTask.

func (*MockMutableStateMockRecorder) GetTransientWorkflowTaskInfo added in v1.20.0 

func (mr *MockMutableStateMockRecorder) GetTransientWorkflowTaskInfo(workflowTask, identity any) *gomock.Call

GetTransientWorkflowTaskInfo indicates an expected call of GetTransientWorkflowTaskInfo.

func (*MockMutableStateMockRecorder) GetUpdateCondition 

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

GetUpdateCondition indicates an expected call of GetUpdateCondition.

func (*MockMutableStateMockRecorder) GetUpdateOutcome added in v1.21.0 

func (mr *MockMutableStateMockRecorder) GetUpdateOutcome(ctx, updateID any) *gomock.Call

GetUpdateOutcome indicates an expected call of GetUpdateOutcome.

func (*MockMutableStateMockRecorder) GetUserTimerInfo 

func (mr *MockMutableStateMockRecorder) GetUserTimerInfo(arg0 any) *gomock.Call

GetUserTimerInfo indicates an expected call of GetUserTimerInfo.

func (*MockMutableStateMockRecorder) GetUserTimerInfoByEventID 

func (mr *MockMutableStateMockRecorder) GetUserTimerInfoByEventID(arg0 any) *gomock.Call

GetUserTimerInfoByEventID indicates an expected call of GetUserTimerInfoByEventID.

func (*MockMutableStateMockRecorder) GetWorkflowCloseTime added in v1.17.0 

func (mr *MockMutableStateMockRecorder) GetWorkflowCloseTime(ctx any) *gomock.Call

GetWorkflowCloseTime indicates an expected call of GetWorkflowCloseTime.

func (*MockMutableStateMockRecorder) GetWorkflowExecutionDuration added in v1.24.0 

func (mr *MockMutableStateMockRecorder) GetWorkflowExecutionDuration(ctx any) *gomock.Call

GetWorkflowExecutionDuration indicates an expected call of GetWorkflowExecutionDuration.

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) GetWorkflowTaskByID added in v1.21.0 

func (mr *MockMutableStateMockRecorder) GetWorkflowTaskByID(scheduledEventID any) *gomock.Call

GetWorkflowTaskByID indicates an expected call of GetWorkflowTaskByID.

func (*MockMutableStateMockRecorder) GetWorkflowType 

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

GetWorkflowType indicates an expected call of GetWorkflowType.

func (*MockMutableStateMockRecorder) HSM added in v1.24.0 

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

HSM indicates an expected call of HSM.

func (*MockMutableStateMockRecorder) HadOrHasWorkflowTask added in v1.21.0 

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

HadOrHasWorkflowTask indicates an expected call of HadOrHasWorkflowTask.

func (*MockMutableStateMockRecorder) HasAnyBufferedEvent added in v1.21.0 

func (mr *MockMutableStateMockRecorder) HasAnyBufferedEvent(filter any) *gomock.Call

HasAnyBufferedEvent indicates an expected call of HasAnyBufferedEvent.

func (*MockMutableStateMockRecorder) HasBufferedEvents 

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

HasBufferedEvents indicates an expected call of HasBufferedEvents.

func (*MockMutableStateMockRecorder) HasCompletedAnyWorkflowTask added in v1.25.0 

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

HasCompletedAnyWorkflowTask indicates an expected call of HasCompletedAnyWorkflowTask.

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) HasStartedWorkflowTask added in v1.21.0 

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

HasStartedWorkflowTask indicates an expected call of HasStartedWorkflowTask.

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) IsDirty added in v1.22.0 

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

IsDirty indicates an expected call of IsDirty.

func (*MockMutableStateMockRecorder) IsResourceDuplicated 

func (mr *MockMutableStateMockRecorder) IsResourceDuplicated(resourceDedupKey any) *gomock.Call

IsResourceDuplicated indicates an expected call of IsResourceDuplicated.

func (*MockMutableStateMockRecorder) IsSignalRequested 

func (mr *MockMutableStateMockRecorder) IsSignalRequested(requestID any) *gomock.Call

IsSignalRequested indicates an expected call of IsSignalRequested.

func (*MockMutableStateMockRecorder) IsStickyTaskQueueSet added in v1.21.0 

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

IsStickyTaskQueueSet indicates an expected call of IsStickyTaskQueueSet.

func (*MockMutableStateMockRecorder) IsTransientWorkflowTask added in v1.20.0 

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

IsTransientWorkflowTask indicates an expected call of IsTransientWorkflowTask.

func (*MockMutableStateMockRecorder) IsWorkflowCloseAttempted added in v1.21.0 

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

IsWorkflowCloseAttempted indicates an expected call of IsWorkflowCloseAttempted.

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) LoadHistoryEvent added in v1.24.0 

func (mr *MockMutableStateMockRecorder) LoadHistoryEvent(ctx, token any) *gomock.Call

LoadHistoryEvent indicates an expected call of LoadHistoryEvent.

func (*MockMutableStateMockRecorder) NextTransitionCount added in v1.25.0 

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

NextTransitionCount indicates an expected call of NextTransitionCount.

func (*MockMutableStateMockRecorder) PopTasks added in v1.17.0 

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

PopTasks indicates an expected call of PopTasks.

func (*MockMutableStateMockRecorder) RefreshExpirationTimeoutTask added in v1.25.0 

func (mr *MockMutableStateMockRecorder) RefreshExpirationTimeoutTask(ctx any) *gomock.Call

RefreshExpirationTimeoutTask indicates an expected call of RefreshExpirationTimeoutTask.

func (*MockMutableStateMockRecorder) RejectWorkflowExecutionUpdate added in v1.20.0 

func (mr *MockMutableStateMockRecorder) RejectWorkflowExecutionUpdate(protocolInstanceID, updRejection any) *gomock.Call

RejectWorkflowExecutionUpdate indicates an expected call of RejectWorkflowExecutionUpdate.

func (*MockMutableStateMockRecorder) RemoveSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

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

RemoveSpeculativeWorkflowTaskTimeoutTask indicates an expected call of RemoveSpeculativeWorkflowTaskTimeoutTask.

func (*MockMutableStateMockRecorder) RetryActivity 

func (mr *MockMutableStateMockRecorder) RetryActivity(ai, failure any) *gomock.Call

RetryActivity indicates an expected call of RetryActivity.

func (*MockMutableStateMockRecorder) SetBaseWorkflow added in v1.21.0 

func (mr *MockMutableStateMockRecorder) SetBaseWorkflow(baseRunID, baseRunLowestCommonAncestorEventID, baseRunLowestCommonAncestorEventVersion any) *gomock.Call

SetBaseWorkflow indicates an expected call of SetBaseWorkflow.

func (*MockMutableStateMockRecorder) SetCurrentBranchToken 

func (mr *MockMutableStateMockRecorder) SetCurrentBranchToken(branchToken any) *gomock.Call

SetCurrentBranchToken indicates an expected call of SetCurrentBranchToken.

func (*MockMutableStateMockRecorder) SetHistoryBuilder 

func (mr *MockMutableStateMockRecorder) SetHistoryBuilder(hBuilder any) *gomock.Call

SetHistoryBuilder indicates an expected call of SetHistoryBuilder.

func (*MockMutableStateMockRecorder) SetHistoryTree 

func (mr *MockMutableStateMockRecorder) SetHistoryTree(executionTimeout, runTimeout, treeID any) *gomock.Call

SetHistoryTree indicates an expected call of SetHistoryTree.

func (*MockMutableStateMockRecorder) SetSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (mr *MockMutableStateMockRecorder) SetSpeculativeWorkflowTaskTimeoutTask(task any) *gomock.Call

SetSpeculativeWorkflowTaskTimeoutTask indicates an expected call of SetSpeculativeWorkflowTaskTimeoutTask.

func (*MockMutableStateMockRecorder) SetStickyTaskQueue added in v1.21.0 

func (mr *MockMutableStateMockRecorder) SetStickyTaskQueue(name, scheduleToStartTimeout any) *gomock.Call

SetStickyTaskQueue indicates an expected call of SetStickyTaskQueue.

func (*MockMutableStateMockRecorder) SetUpdateCondition 

func (mr *MockMutableStateMockRecorder) SetUpdateCondition(arg0, arg1 any) *gomock.Call

SetUpdateCondition indicates an expected call of SetUpdateCondition.

func (*MockMutableStateMockRecorder) StartTransaction 

func (mr *MockMutableStateMockRecorder) StartTransaction(entry any) *gomock.Call

StartTransaction indicates an expected call of StartTransaction.

func (*MockMutableStateMockRecorder) TaskQueueScheduleToStartTimeout added in v1.21.0 

func (mr *MockMutableStateMockRecorder) TaskQueueScheduleToStartTimeout(name any) *gomock.Call

TaskQueueScheduleToStartTimeout indicates an expected call of TaskQueueScheduleToStartTimeout.

func (*MockMutableStateMockRecorder) UpdateActivity 

func (mr *MockMutableStateMockRecorder) UpdateActivity(arg0 any) *gomock.Call

UpdateActivity indicates an expected call of UpdateActivity.

func (*MockMutableStateMockRecorder) UpdateActivityInfo added in v1.24.0 

func (mr *MockMutableStateMockRecorder) UpdateActivityInfo(arg0, arg1 any) *gomock.Call

UpdateActivityInfo indicates an expected call of UpdateActivityInfo.

func (*MockMutableStateMockRecorder) UpdateActivityProgress 

func (mr *MockMutableStateMockRecorder) UpdateActivityProgress(ai, request any) *gomock.Call

UpdateActivityProgress indicates an expected call of UpdateActivityProgress.

func (*MockMutableStateMockRecorder) UpdateActivityWithTimerHeartbeat 

func (mr *MockMutableStateMockRecorder) UpdateActivityWithTimerHeartbeat(arg0, arg1 any) *gomock.Call

UpdateActivityWithTimerHeartbeat indicates an expected call of UpdateActivityWithTimerHeartbeat.

func (*MockMutableStateMockRecorder) UpdateBuildIdAssignment added in v1.24.0 

func (mr *MockMutableStateMockRecorder) UpdateBuildIdAssignment(buildId any) *gomock.Call

UpdateBuildIdAssignment indicates an expected call of UpdateBuildIdAssignment.

func (*MockMutableStateMockRecorder) UpdateCurrentVersion 

func (mr *MockMutableStateMockRecorder) UpdateCurrentVersion(version, forceUpdate any) *gomock.Call

UpdateCurrentVersion indicates an expected call of UpdateCurrentVersion.

func (*MockMutableStateMockRecorder) UpdateDuplicatedResource 

func (mr *MockMutableStateMockRecorder) UpdateDuplicatedResource(resourceDedupKey any) *gomock.Call

UpdateDuplicatedResource indicates an expected call of UpdateDuplicatedResource.

func (*MockMutableStateMockRecorder) UpdateUserTimer 

func (mr *MockMutableStateMockRecorder) UpdateUserTimer(arg0 any) *gomock.Call

UpdateUserTimer indicates an expected call of UpdateUserTimer.

func (*MockMutableStateMockRecorder) UpdateWorkflowStateStatus 

func (mr *MockMutableStateMockRecorder) UpdateWorkflowStateStatus(state, status any) *gomock.Call

UpdateWorkflowStateStatus indicates an expected call of UpdateWorkflowStateStatus.

func (*MockMutableStateMockRecorder) VisitUpdates added in v1.21.0 

func (mr *MockMutableStateMockRecorder) VisitUpdates(visitor any) *gomock.Call

VisitUpdates indicates an expected call of VisitUpdates.

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(ctx context.Context, namespaceID namespace.ID, requestID string, execution *common.WorkflowExecution, history [][]*history.HistoryEvent, newRunHistory []*history.HistoryEvent, newRunID string) (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(ctx, namespaceID, requestID, execution, history, newRunHistory, newRunID any) *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(activityInfo *persistence.ActivityInfo) error

GenerateActivityRetryTasks mocks base method.

func (*MockTaskGenerator) GenerateActivityTasks added in v1.16.0 

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

GenerateActivityTasks mocks base method.

func (*MockTaskGenerator) GenerateActivityTimerTasks 

func (m *MockTaskGenerator) GenerateActivityTimerTasks() error

GenerateActivityTimerTasks mocks base method.

func (*MockTaskGenerator) GenerateChildWorkflowTasks 

func (m *MockTaskGenerator) GenerateChildWorkflowTasks(event *history.HistoryEvent) error

GenerateChildWorkflowTasks mocks base method.

func (*MockTaskGenerator) GenerateDelayedWorkflowTasks 

func (m *MockTaskGenerator) GenerateDelayedWorkflowTasks(startEvent *history.HistoryEvent) error

GenerateDelayedWorkflowTasks mocks base method.

func (*MockTaskGenerator) GenerateDeleteExecutionTask added in v1.15.0 

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

GenerateDeleteExecutionTask mocks base method.

func (*MockTaskGenerator) GenerateDeleteHistoryEventTask added in v1.20.0 

func (m *MockTaskGenerator) GenerateDeleteHistoryEventTask(closeTime time.Time) error

GenerateDeleteHistoryEventTask mocks base method.

func (*MockTaskGenerator) GenerateDirtySubStateMachineTasks added in v1.24.0 

func (m *MockTaskGenerator) GenerateDirtySubStateMachineTasks(stateMachineRegistry *hsm.Registry) error

GenerateDirtySubStateMachineTasks mocks base method.

func (*MockTaskGenerator) GenerateHistoryReplicationTasks added in v1.14.0 

func (m *MockTaskGenerator) GenerateHistoryReplicationTasks(eventBatches [][]*history.HistoryEvent) error

GenerateHistoryReplicationTasks mocks base method.

func (*MockTaskGenerator) GenerateMigrationTasks added in v1.17.0 

func (m *MockTaskGenerator) GenerateMigrationTasks() ([]tasks.Task, int64, error)

GenerateMigrationTasks mocks base method.

func (*MockTaskGenerator) GenerateRecordWorkflowStartedTasks 

func (m *MockTaskGenerator) GenerateRecordWorkflowStartedTasks(startEvent *history.HistoryEvent) error

GenerateRecordWorkflowStartedTasks mocks base method.

func (*MockTaskGenerator) GenerateRequestCancelExternalTasks 

func (m *MockTaskGenerator) GenerateRequestCancelExternalTasks(event *history.HistoryEvent) error

GenerateRequestCancelExternalTasks mocks base method.

func (*MockTaskGenerator) GenerateScheduleSpeculativeWorkflowTaskTasks added in v1.23.0 

func (m *MockTaskGenerator) GenerateScheduleSpeculativeWorkflowTaskTasks(workflowTask *WorkflowTaskInfo) error

GenerateScheduleSpeculativeWorkflowTaskTasks mocks base method.

func (*MockTaskGenerator) GenerateScheduleWorkflowTaskTasks 

func (m *MockTaskGenerator) GenerateScheduleWorkflowTaskTasks(workflowTaskScheduledEventID int64) error

GenerateScheduleWorkflowTaskTasks mocks base method.

func (*MockTaskGenerator) GenerateSignalExternalTasks 

func (m *MockTaskGenerator) GenerateSignalExternalTasks(event *history.HistoryEvent) error

GenerateSignalExternalTasks mocks base method.

func (*MockTaskGenerator) GenerateStartWorkflowTaskTasks 

func (m *MockTaskGenerator) GenerateStartWorkflowTaskTasks(workflowTaskScheduledEventID int64) error

GenerateStartWorkflowTaskTasks mocks base method.

func (*MockTaskGenerator) GenerateUpsertVisibilityTask added in v1.18.0 

func (m *MockTaskGenerator) GenerateUpsertVisibilityTask() error

GenerateUpsertVisibilityTask mocks base method.

func (*MockTaskGenerator) GenerateUserTimerTasks 

func (m *MockTaskGenerator) GenerateUserTimerTasks() error

GenerateUserTimerTasks mocks base method.

func (*MockTaskGenerator) GenerateWorkflowCloseTasks 

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

GenerateWorkflowCloseTasks mocks base method.

func (*MockTaskGenerator) GenerateWorkflowResetTasks 

func (m *MockTaskGenerator) GenerateWorkflowResetTasks() error

GenerateWorkflowResetTasks mocks base method.

func (*MockTaskGenerator) GenerateWorkflowStartTasks 

func (m *MockTaskGenerator) GenerateWorkflowStartTasks(startEvent *history.HistoryEvent) (int32, 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(activityInfo any) *gomock.Call

GenerateActivityRetryTasks indicates an expected call of GenerateActivityRetryTasks.

func (*MockTaskGeneratorMockRecorder) GenerateActivityTasks added in v1.16.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateActivityTasks(activityScheduledEventID any) *gomock.Call

GenerateActivityTasks indicates an expected call of GenerateActivityTasks.

func (*MockTaskGeneratorMockRecorder) GenerateActivityTimerTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateActivityTimerTasks() *gomock.Call

GenerateActivityTimerTasks indicates an expected call of GenerateActivityTimerTasks.

func (*MockTaskGeneratorMockRecorder) GenerateChildWorkflowTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateChildWorkflowTasks(event any) *gomock.Call

GenerateChildWorkflowTasks indicates an expected call of GenerateChildWorkflowTasks.

func (*MockTaskGeneratorMockRecorder) GenerateDelayedWorkflowTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateDelayedWorkflowTasks(startEvent any) *gomock.Call

GenerateDelayedWorkflowTasks indicates an expected call of GenerateDelayedWorkflowTasks.

func (*MockTaskGeneratorMockRecorder) GenerateDeleteExecutionTask added in v1.15.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateDeleteExecutionTask() *gomock.Call

GenerateDeleteExecutionTask indicates an expected call of GenerateDeleteExecutionTask.

func (*MockTaskGeneratorMockRecorder) GenerateDeleteHistoryEventTask added in v1.20.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateDeleteHistoryEventTask(closeTime any) *gomock.Call

GenerateDeleteHistoryEventTask indicates an expected call of GenerateDeleteHistoryEventTask.

func (*MockTaskGeneratorMockRecorder) GenerateDirtySubStateMachineTasks added in v1.24.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateDirtySubStateMachineTasks(stateMachineRegistry any) *gomock.Call

GenerateDirtySubStateMachineTasks indicates an expected call of GenerateDirtySubStateMachineTasks.

func (*MockTaskGeneratorMockRecorder) GenerateHistoryReplicationTasks added in v1.14.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateHistoryReplicationTasks(eventBatches any) *gomock.Call

GenerateHistoryReplicationTasks indicates an expected call of GenerateHistoryReplicationTasks.

func (*MockTaskGeneratorMockRecorder) GenerateMigrationTasks added in v1.17.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateMigrationTasks() *gomock.Call

GenerateMigrationTasks indicates an expected call of GenerateMigrationTasks.

func (*MockTaskGeneratorMockRecorder) GenerateRecordWorkflowStartedTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateRecordWorkflowStartedTasks(startEvent any) *gomock.Call

GenerateRecordWorkflowStartedTasks indicates an expected call of GenerateRecordWorkflowStartedTasks.

func (*MockTaskGeneratorMockRecorder) GenerateRequestCancelExternalTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateRequestCancelExternalTasks(event any) *gomock.Call

GenerateRequestCancelExternalTasks indicates an expected call of GenerateRequestCancelExternalTasks.

func (*MockTaskGeneratorMockRecorder) GenerateScheduleSpeculativeWorkflowTaskTasks added in v1.23.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateScheduleSpeculativeWorkflowTaskTasks(workflowTask any) *gomock.Call

GenerateScheduleSpeculativeWorkflowTaskTasks indicates an expected call of GenerateScheduleSpeculativeWorkflowTaskTasks.

func (*MockTaskGeneratorMockRecorder) GenerateScheduleWorkflowTaskTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateScheduleWorkflowTaskTasks(workflowTaskScheduledEventID any) *gomock.Call

GenerateScheduleWorkflowTaskTasks indicates an expected call of GenerateScheduleWorkflowTaskTasks.

func (*MockTaskGeneratorMockRecorder) GenerateSignalExternalTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateSignalExternalTasks(event any) *gomock.Call

GenerateSignalExternalTasks indicates an expected call of GenerateSignalExternalTasks.

func (*MockTaskGeneratorMockRecorder) GenerateStartWorkflowTaskTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateStartWorkflowTaskTasks(workflowTaskScheduledEventID any) *gomock.Call

GenerateStartWorkflowTaskTasks indicates an expected call of GenerateStartWorkflowTaskTasks.

func (*MockTaskGeneratorMockRecorder) GenerateUpsertVisibilityTask added in v1.18.0 

func (mr *MockTaskGeneratorMockRecorder) GenerateUpsertVisibilityTask() *gomock.Call

GenerateUpsertVisibilityTask indicates an expected call of GenerateUpsertVisibilityTask.

func (*MockTaskGeneratorMockRecorder) GenerateUserTimerTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateUserTimerTasks() *gomock.Call

GenerateUserTimerTasks indicates an expected call of GenerateUserTimerTasks.

func (*MockTaskGeneratorMockRecorder) GenerateWorkflowCloseTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateWorkflowCloseTasks(closedTime, deleteAfterClose any) *gomock.Call

GenerateWorkflowCloseTasks indicates an expected call of GenerateWorkflowCloseTasks.

func (*MockTaskGeneratorMockRecorder) GenerateWorkflowResetTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateWorkflowResetTasks() *gomock.Call

GenerateWorkflowResetTasks indicates an expected call of GenerateWorkflowResetTasks.

func (*MockTaskGeneratorMockRecorder) GenerateWorkflowStartTasks 

func (mr *MockTaskGeneratorMockRecorder) GenerateWorkflowStartTasks(startEvent any) *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) PartialRefresh added in v1.25.0 

func (m *MockTaskRefresher) PartialRefresh(ctx context.Context, mutableState MutableState, minVersionedTransition *persistence.VersionedTransition) error

PartialRefresh mocks base method.

func (*MockTaskRefresher) Refresh added in v1.25.0 

func (m *MockTaskRefresher) Refresh(ctx context.Context, mutableState MutableState) error

Refresh mocks base method.

type MockTaskRefresherMockRecorder 

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

MockTaskRefresherMockRecorder is the mock recorder for MockTaskRefresher.

func (*MockTaskRefresherMockRecorder) PartialRefresh added in v1.25.0 

func (mr *MockTaskRefresherMockRecorder) PartialRefresh(ctx, mutableState, minVersionedTransition any) *gomock.Call

PartialRefresh indicates an expected call of PartialRefresh.

func (*MockTaskRefresherMockRecorder) Refresh added in v1.25.0 

func (mr *MockTaskRefresherMockRecorder) Refresh(ctx, mutableState any) *gomock.Call

Refresh indicates an expected call of Refresh.

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) 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) 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, resetWorkflowFailoverVersion int64, resetWorkflowSnapshot *persistence.WorkflowSnapshot, resetWorkflowEventsSeq []*persistence.WorkflowEvents, newWorkflowFailoverVersion *int64, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents, currentWorkflowFailoverVersion *int64, currentWorkflowMutation *persistence.WorkflowMutation, currentWorkflowEventsSeq []*persistence.WorkflowEvents) (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, newWorkflowFailoverVersion int64, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents) (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) error

SetWorkflowExecution mocks base method.

func (*MockTransaction) UpdateWorkflowExecution added in v1.12.0 

func (m *MockTransaction) UpdateWorkflowExecution(ctx context.Context, updateMode persistence.UpdateWorkflowMode, currentWorkflowFailoverVersion int64, currentWorkflowMutation *persistence.WorkflowMutation, currentWorkflowEventsSeq []*persistence.WorkflowEvents, newWorkflowFailoverVersion *int64, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents) (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, resetWorkflowFailoverVersion, resetWorkflowSnapshot, resetWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq any) *gomock.Call

ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.

func (*MockTransactionMockRecorder) CreateWorkflowExecution added in v1.12.0 

func (mr *MockTransactionMockRecorder) CreateWorkflowExecution(ctx, createMode, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq any) *gomock.Call

CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.

func (*MockTransactionMockRecorder) SetWorkflowExecution added in v1.16.0 

func (mr *MockTransactionMockRecorder) SetWorkflowExecution(ctx, workflowSnapshot any) *gomock.Call

SetWorkflowExecution indicates an expected call of SetWorkflowExecution.

func (*MockTransactionMockRecorder) UpdateWorkflowExecution added in v1.12.0 

func (mr *MockTransactionMockRecorder) UpdateWorkflowExecution(ctx, updateMode, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq any) *gomock.Call

UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.

type MutableState 

type MutableState interface {
	callbacks.CanGetNexusCompletion
	callbacks.CanGetHSMCompletionCallbackArg
	AddHistoryEvent(t enumspb.EventType, setAttributes func(*historypb.HistoryEvent)) *historypb.HistoryEvent
	LoadHistoryEvent(ctx context.Context, token []byte) (*historypb.HistoryEvent, error)

	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, *commonpb.WorkerVersionStamp) (*historypb.HistoryEvent, error)
	AddActivityTaskScheduledEvent(int64, *commandpb.ScheduleActivityTaskCommandAttributes, bool) (*historypb.HistoryEvent, *persistencespb.ActivityInfo, error)
	AddActivityTaskStartedEvent(*persistencespb.ActivityInfo, int64, string, string, *commonpb.WorkerVersionStamp, *taskqueuespb.BuildIdRedirectInfo) (*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(context.Context, int64, int64, namespace.Name, *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes) (*historypb.HistoryEvent, MutableState, error)
	AddWorkflowTaskCompletedEvent(*WorkflowTaskInfo, *workflowservice.RespondWorkflowTaskCompletedRequest, WorkflowTaskCompletionLimits) (*historypb.HistoryEvent, error)
	AddWorkflowTaskFailedEvent(workflowTask *WorkflowTaskInfo, cause enumspb.WorkflowTaskFailedCause, failure *failurepb.Failure, identity string, versioningStamp *commonpb.WorkerVersionStamp, binChecksum, baseRunID, newRunID string, forkEventVersion int64) (*historypb.HistoryEvent, error)
	AddWorkflowTaskScheduleToStartTimeoutEvent(workflowTask *WorkflowTaskInfo) (*historypb.HistoryEvent, error)
	AddFirstWorkflowTaskScheduled(parentClock *clockspb.VectorClock, event *historypb.HistoryEvent, bypassTaskGeneration bool) (int64, error)
	AddWorkflowTaskScheduledEvent(bypassTaskGeneration bool, workflowTaskType enumsspb.WorkflowTaskType) (*WorkflowTaskInfo, error)
	AddWorkflowTaskScheduledEventAsHeartbeat(bypassTaskGeneration bool, originalScheduledTimestamp *timestamppb.Timestamp, workflowTaskType enumsspb.WorkflowTaskType) (*WorkflowTaskInfo, error)
	AddWorkflowTaskStartedEvent(int64, string, *taskqueuepb.TaskQueue, string, *commonpb.WorkerVersionStamp, *taskqueuespb.BuildIdRedirectInfo, bool) (*historypb.HistoryEvent, *WorkflowTaskInfo, error)
	AddWorkflowTaskTimedOutEvent(workflowTask *WorkflowTaskInfo) (*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)
	AddWorkflowPropertiesModifiedEvent(int64, *commandpb.ModifyWorkflowPropertiesCommandAttributes) (*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,
		skipGenerateWorkflowTask bool,
		links []*commonpb.Link,
	) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionSignaledEvent(
		signalName string,
		input *commonpb.Payloads,
		identity string,
		header *commonpb.Header,
		skipGenerateWorkflowTask bool,
		externalWorkflowExecution *commonpb.WorkflowExecution,
		links []*commonpb.Link,
	) (*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, links []*commonpb.Link) (*historypb.HistoryEvent, error)

	AddWorkflowExecutionUpdateAcceptedEvent(protocolInstanceID string, acceptedRequestMessageId string, acceptedRequestSequencingEventId int64, acceptedRequest *updatepb.Request) (*historypb.HistoryEvent, error)
	AddWorkflowExecutionUpdateCompletedEvent(acceptedEventID int64, updResp *updatepb.Response) (*historypb.HistoryEvent, error)
	RejectWorkflowExecutionUpdate(protocolInstanceID string, updRejection *updatepb.Rejection) error
	AddWorkflowExecutionUpdateAdmittedEvent(request *updatepb.Request, origin enumspb.UpdateAdmittedEventOrigin) (*historypb.HistoryEvent, error)
	ApplyWorkflowExecutionUpdateAdmittedEvent(event *historypb.HistoryEvent, batchId int64) error
	VisitUpdates(visitor func(updID string, updInfo *persistencespb.UpdateInfo))
	GetUpdateOutcome(ctx context.Context, updateID string) (*updatepb.Outcome, error)

	CheckResettable() error
	CloneToProto() *persistencespb.WorkflowMutableState
	RetryActivity(ai *persistencespb.ActivityInfo, failure *failurepb.Failure) (enumspb.RetryState, error)
	GetTransientWorkflowTaskInfo(workflowTask *WorkflowTaskInfo, identity string) *historyspb.TransientWorkflowTaskInfo
	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)
	GetActivityType(context.Context, *persistencespb.ActivityInfo) (*commonpb.ActivityType, error)
	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)
	GetWorkflowExecutionDuration(ctx context.Context) (time.Duration, error)
	GetWorkflowTaskByID(scheduledEventID int64) *WorkflowTaskInfo
	GetNamespaceEntry() *namespace.Namespace
	GetStartEvent(context.Context) (*historypb.HistoryEvent, error)
	GetSignalExternalInitiatedEvent(context.Context, int64) (*historypb.HistoryEvent, error)
	GetFirstRunID(ctx context.Context) (string, error)
	GetCurrentBranchToken() ([]byte, error)
	GetCurrentVersion() int64
	GetStartVersion() (int64, error)
	GetCloseVersion() (int64, error)
	GetLastWriteVersion() (int64, error)
	GetLastEventVersion() (int64, error)
	GetExecutionInfo() *persistencespb.WorkflowExecutionInfo
	GetExecutionState() *persistencespb.WorkflowExecutionState
	GetStartedWorkflowTask() *WorkflowTaskInfo
	GetPendingWorkflowTask() *WorkflowTaskInfo
	GetLastFirstEventIDTxnID() (int64, int64)
	GetNextEventID() int64
	GetLastCompletedWorkflowTaskStartedEventId() 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
	GetPendingSignalRequestedIds() []string
	GetRequestCancelInfo(int64) (*persistencespb.RequestCancelInfo, bool)
	GetRetryBackoffDuration(failure *failurepb.Failure) (time.Duration, enumspb.RetryState)
	GetCronBackoffDuration() time.Duration
	GetSignalInfo(int64) (*persistencespb.SignalInfo, bool)
	GetUserTimerInfoByEventID(int64) (*persistencespb.TimerInfo, bool)
	GetUserTimerInfo(string) (*persistencespb.TimerInfo, bool)
	GetWorkflowType() *commonpb.WorkflowType
	GetWorkflowStateStatus() (enumsspb.WorkflowExecutionState, enumspb.WorkflowExecutionStatus)
	GetQueryRegistry() QueryRegistry
	GetBaseWorkflowInfo() *workflowspb.BaseExecutionInfo
	GetAssignedBuildId() string
	GetInheritedBuildId() string
	GetMostRecentWorkerVersionStamp() *commonpb.WorkerVersionStamp
	IsTransientWorkflowTask() bool
	ClearTransientWorkflowTask() error
	HasBufferedEvents() bool
	HasAnyBufferedEvent(filter historybuilder.BufferedEventFilter) bool
	HasStartedWorkflowTask() bool
	HasParentExecution() bool
	HasPendingWorkflowTask() bool
	HadOrHasWorkflowTask() bool
	IsCancelRequested() bool
	IsWorkflowCloseAttempted() bool
	IsCurrentWorkflowGuaranteed() bool
	IsSignalRequested(requestID string) bool
	GetApproximatePersistedSize() int

	CurrentTaskQueue() *taskqueuepb.TaskQueue
	SetStickyTaskQueue(name string, scheduleToStartTimeout *durationpb.Duration)
	ClearStickyTaskQueue()
	IsStickyTaskQueueSet() bool
	TaskQueueScheduleToStartTimeout(name string) (*taskqueuepb.TaskQueue, *durationpb.Duration)

	IsWorkflowExecutionRunning() bool
	IsResourceDuplicated(resourceDedupKey definition.DeduplicationID) bool
	IsWorkflowPendingOnWorkflowTaskBackoff() bool
	UpdateDuplicatedResource(resourceDedupKey definition.DeduplicationID)
	UpdateActivityInfo(*historyservice.ActivitySyncInfo, bool) error
	ApplyActivityTaskCancelRequestedEvent(*historypb.HistoryEvent) error
	ApplyActivityTaskCanceledEvent(*historypb.HistoryEvent) error
	ApplyActivityTaskCompletedEvent(*historypb.HistoryEvent) error
	ApplyActivityTaskFailedEvent(*historypb.HistoryEvent) error
	ApplyActivityTaskScheduledEvent(int64, *historypb.HistoryEvent) (*persistencespb.ActivityInfo, error)
	ApplyActivityTaskStartedEvent(*historypb.HistoryEvent) error
	ApplyActivityTaskTimedOutEvent(*historypb.HistoryEvent) error
	ApplyChildWorkflowExecutionCanceledEvent(*historypb.HistoryEvent) error
	ApplyChildWorkflowExecutionCompletedEvent(*historypb.HistoryEvent) error
	ApplyChildWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ApplyChildWorkflowExecutionStartedEvent(*historypb.HistoryEvent, *clockspb.VectorClock) error
	ApplyChildWorkflowExecutionTerminatedEvent(*historypb.HistoryEvent) error
	ApplyChildWorkflowExecutionTimedOutEvent(*historypb.HistoryEvent) error
	ApplyWorkflowTaskCompletedEvent(*historypb.HistoryEvent) error
	ApplyWorkflowTaskFailedEvent() error
	ApplyWorkflowTaskScheduledEvent(int64, int64, *taskqueuepb.TaskQueue, *durationpb.Duration, int32, *timestamppb.Timestamp, *timestamppb.Timestamp, enumsspb.WorkflowTaskType) (*WorkflowTaskInfo, error)
	ApplyWorkflowTaskStartedEvent(*WorkflowTaskInfo, int64, int64, int64, string, time.Time, bool, int64, *commonpb.WorkerVersionStamp, int64) (*WorkflowTaskInfo, error)
	ApplyWorkflowTaskTimedOutEvent(enumspb.TimeoutType) error
	ApplyExternalWorkflowExecutionCancelRequested(*historypb.HistoryEvent) error
	ApplyExternalWorkflowExecutionSignaled(*historypb.HistoryEvent) error
	ApplyRequestCancelExternalWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent(int64, *historypb.HistoryEvent, string) (*persistencespb.RequestCancelInfo, error)
	ApplySignalExternalWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ApplySignalExternalWorkflowExecutionInitiatedEvent(int64, *historypb.HistoryEvent, string) (*persistencespb.SignalInfo, error)
	ApplyStartChildWorkflowExecutionFailedEvent(*historypb.HistoryEvent) error
	ApplyStartChildWorkflowExecutionInitiatedEvent(int64, *historypb.HistoryEvent, string) (*persistencespb.ChildExecutionInfo, error)
	ApplyTimerCanceledEvent(*historypb.HistoryEvent) error
	ApplyTimerFiredEvent(*historypb.HistoryEvent) error
	ApplyTimerStartedEvent(*historypb.HistoryEvent) (*persistencespb.TimerInfo, error)
	ApplyTransientWorkflowTaskScheduled() (*WorkflowTaskInfo, error)
	ApplyWorkflowPropertiesModifiedEvent(*historypb.HistoryEvent)
	ApplyUpsertWorkflowSearchAttributesEvent(*historypb.HistoryEvent)
	ApplyWorkflowExecutionCancelRequestedEvent(*historypb.HistoryEvent) error
	ApplyWorkflowExecutionCanceledEvent(int64, *historypb.HistoryEvent) error
	ApplyWorkflowExecutionCompletedEvent(int64, *historypb.HistoryEvent) error
	ApplyWorkflowExecutionContinuedAsNewEvent(int64, *historypb.HistoryEvent) error
	ApplyWorkflowExecutionFailedEvent(int64, *historypb.HistoryEvent) error
	ApplyWorkflowExecutionSignaled(*historypb.HistoryEvent) error
	ApplyWorkflowExecutionStartedEvent(*clockspb.VectorClock, *commonpb.WorkflowExecution, string, *historypb.HistoryEvent) error
	ApplyWorkflowExecutionTerminatedEvent(int64, *historypb.HistoryEvent) error
	ApplyWorkflowExecutionTimedoutEvent(int64, *historypb.HistoryEvent) error
	ApplyWorkflowExecutionUpdateAcceptedEvent(*historypb.HistoryEvent) error
	ApplyWorkflowExecutionUpdateCompletedEvent(event *historypb.HistoryEvent, batchID int64) error
	SetCurrentBranchToken(branchToken []byte) error
	SetHistoryBuilder(hBuilder *historybuilder.HistoryBuilder)
	SetHistoryTree(executionTimeout *durationpb.Duration, runTimeout *durationpb.Duration, treeID string) error
	SetBaseWorkflow(
		baseRunID string,
		baseRunLowestCommonAncestorEventID int64,
		baseRunLowestCommonAncestorEventVersion int64,
	)
	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
	UpdateBuildIdAssignment(buildId string) error
	ApplyBuildIdRedirect(startingTaskScheduledEventId int64, buildId string, redirectCounter int64) error
	RefreshExpirationTimeoutTask(ctx context.Context) error

	GetHistorySize() int64
	AddHistorySize(size int64)

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

	SetSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) error
	CheckSpeculativeWorkflowTaskTimeoutTask(task *tasks.WorkflowTaskTimeoutTask) bool
	RemoveSpeculativeWorkflowTaskTimeoutTask()

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

	// ContinueAsNewMinBackoff calculate minimal backoff for next ContinueAsNew run.
	// Input backoffDuration is current backoff for next run.
	// If current backoff comply with minimal ContinueAsNew interval requirement, current backoff will be returned.
	// Current backoff could be nil which means it does not have a backoff.
	ContinueAsNewMinBackoff(backoffDuration *durationpb.Duration) *durationpb.Duration
	HasCompletedAnyWorkflowTask() bool

	HSM() *hsm.Node

	// NextTransitionCount returns the next state transition count from the state transition history.
	// If state transition history is empty (e.g. when disabled or fresh mutable state), returns 0.
	NextTransitionCount() int64
}

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,
	workflowID string,
	runID string,
	startTime time.Time,
) *MutableStateImpl

func NewMutableStateFromDB added in v1.23.0 

func NewMutableStateFromDB(
	shard shard.Context,
	eventsCache events.Cache,
	logger log.Logger,
	namespaceEntry *namespace.Namespace,
	dbRecord *persistencespb.WorkflowMutableState,
	dbRecordVersion int64,
) (*MutableStateImpl, error)

func NewMutableStateInChain added in v1.24.0 

func NewMutableStateInChain(
	shardContext shard.Context,
	eventsCache events.Cache,
	logger log.Logger,
	namespaceEntry *namespace.Namespace,
	workflowID string,
	runID string,
	startTime time.Time,
	currentMutableState MutableState,
) (*MutableStateImpl, error)

func NewSanitizedMutableState added in v1.17.0 

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

func TestGlobalMutableState 

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

func TestLocalMutableState 

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

func (*MutableStateImpl) AddActivityTaskCancelRequestedEvent 

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

func (*MutableStateImpl) AddActivityTaskCanceledEvent 

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

func (*MutableStateImpl) AddActivityTaskCompletedEvent 

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

func (*MutableStateImpl) AddActivityTaskFailedEvent 

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

func (*MutableStateImpl) AddActivityTaskScheduledEvent 

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

func (*MutableStateImpl) AddActivityTaskStartedEvent 

func (ms *MutableStateImpl) AddActivityTaskStartedEvent(
	ai *persistencespb.ActivityInfo,
	scheduledEventID int64,
	requestID string,
	identity string,
	versioningStamp *commonpb.WorkerVersionStamp,
	redirectInfo *taskqueue.BuildIdRedirectInfo,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddActivityTaskTimedOutEvent 

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

func (*MutableStateImpl) AddChildWorkflowExecutionCanceledEvent 

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

func (*MutableStateImpl) AddChildWorkflowExecutionCompletedEvent 

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

func (*MutableStateImpl) AddChildWorkflowExecutionFailedEvent 

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

func (*MutableStateImpl) AddChildWorkflowExecutionStartedEvent 

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

func (*MutableStateImpl) AddChildWorkflowExecutionTerminatedEvent 

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

func (*MutableStateImpl) AddChildWorkflowExecutionTimedOutEvent 

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

func (*MutableStateImpl) AddCompletedWorkflowEvent 

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

func (*MutableStateImpl) AddContinueAsNewEvent 

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

func (*MutableStateImpl) AddExternalWorkflowExecutionCancelRequested 

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

func (*MutableStateImpl) AddExternalWorkflowExecutionSignaled 

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

func (*MutableStateImpl) AddFailWorkflowEvent 

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

func (*MutableStateImpl) AddFirstWorkflowTaskScheduled 

func (ms *MutableStateImpl) AddFirstWorkflowTaskScheduled(
	parentClock *clockspb.VectorClock,
	startEvent *historypb.HistoryEvent,
	bypassTaskGeneration bool,
) (int64, error)

AddFirstWorkflowTaskScheduled adds the first workflow task scheduled event unless it should be delayed as indicated by the startEvent's FirstWorkflowTaskBackoff. Returns the workflow task's scheduled event ID if a task was scheduled, 0 otherwise.

func (*MutableStateImpl) AddHistoryEvent added in v1.24.0 

func (ms *MutableStateImpl) AddHistoryEvent(t enumspb.EventType, setAttributes func(*historypb.HistoryEvent)) *historypb.HistoryEvent

AddHistoryEvent adds any history event to this workflow execution. The provided setAttributes function should be used to set the attributes on the event.

func (*MutableStateImpl) AddHistorySize added in v1.21.0 

func (ms *MutableStateImpl) AddHistorySize(size int64)

func (*MutableStateImpl) AddRecordMarkerEvent 

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

func (*MutableStateImpl) AddRequestCancelExternalWorkflowExecutionFailedEvent 

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

func (*MutableStateImpl) AddRequestCancelExternalWorkflowExecutionInitiatedEvent 

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

func (*MutableStateImpl) AddSignalExternalWorkflowExecutionFailedEvent 

func (ms *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 (ms *MutableStateImpl) AddSignalExternalWorkflowExecutionInitiatedEvent(
	workflowTaskCompletedEventID int64,
	signalRequestID string,
	command *commandpb.SignalExternalWorkflowExecutionCommandAttributes,
	targetNamespaceID namespace.ID,
) (*historypb.HistoryEvent, *persistencespb.SignalInfo, error)

func (*MutableStateImpl) AddSignalRequested 

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

func (*MutableStateImpl) AddStartChildWorkflowExecutionFailedEvent 

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

func (*MutableStateImpl) AddStartChildWorkflowExecutionInitiatedEvent 

func (ms *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 (ms *MutableStateImpl) AddTasks(
	newTasks ...tasks.Task,
)

func (*MutableStateImpl) AddTimeoutWorkflowEvent 

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

func (*MutableStateImpl) AddTimerCanceledEvent 

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

func (*MutableStateImpl) AddTimerFiredEvent 

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

func (*MutableStateImpl) AddTimerStartedEvent 

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

func (*MutableStateImpl) AddUpsertWorkflowSearchAttributesEvent 

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

func (*MutableStateImpl) AddWorkflowExecutionCancelRequestedEvent 

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

func (*MutableStateImpl) AddWorkflowExecutionCanceledEvent 

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

func (*MutableStateImpl) AddWorkflowExecutionSignaled 

func (ms *MutableStateImpl) AddWorkflowExecutionSignaled(
	signalName string,
	input *commonpb.Payloads,
	identity string,
	header *commonpb.Header,
	skipGenerateWorkflowTask bool,
	links []*commonpb.Link,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionSignaledEvent added in v1.24.0 

func (ms *MutableStateImpl) AddWorkflowExecutionSignaledEvent(
	signalName string,
	input *commonpb.Payloads,
	identity string,
	header *commonpb.Header,
	skipGenerateWorkflowTask bool,
	externalWorkflowExecution *commonpb.WorkflowExecution,
	links []*commonpb.Link,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionStartedEvent 

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

func (*MutableStateImpl) AddWorkflowExecutionStartedEventWithOptions added in v1.13.0 

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

func (*MutableStateImpl) AddWorkflowExecutionTerminatedEvent 

func (ms *MutableStateImpl) AddWorkflowExecutionTerminatedEvent(
	firstEventID int64,
	reason string,
	details *commonpb.Payloads,
	identity string,
	deleteAfterTerminate bool,
	links []*commonpb.Link,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionUpdateAcceptedEvent added in v1.20.0 

func (ms *MutableStateImpl) AddWorkflowExecutionUpdateAcceptedEvent(
	protocolInstanceID string,
	acceptedRequestMessageId string,
	acceptedRequestSequencingEventId int64,
	acceptedRequest *updatepb.Request,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowExecutionUpdateAdmittedEvent added in v1.24.0 

func (ms *MutableStateImpl) AddWorkflowExecutionUpdateAdmittedEvent(request *updatepb.Request, origin enumspb.UpdateAdmittedEventOrigin) (*historypb.HistoryEvent, error)

AddWorkflowExecutionUpdateAdmittedEvent adds a WorkflowExecutionUpdateAdmittedEvent to in-memory history.

func (*MutableStateImpl) AddWorkflowExecutionUpdateCompletedEvent added in v1.20.0 

func (ms *MutableStateImpl) AddWorkflowExecutionUpdateCompletedEvent(
	acceptedEventID int64,
	updResp *updatepb.Response,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowPropertiesModifiedEvent added in v1.18.0 

func (ms *MutableStateImpl) AddWorkflowPropertiesModifiedEvent(
	workflowTaskCompletedEventID int64,
	command *commandpb.ModifyWorkflowPropertiesCommandAttributes,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskCompletedEvent 

func (ms *MutableStateImpl) AddWorkflowTaskCompletedEvent(
	workflowTask *WorkflowTaskInfo,
	request *workflowservice.RespondWorkflowTaskCompletedRequest,
	limits WorkflowTaskCompletionLimits,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskFailedEvent 

func (ms *MutableStateImpl) AddWorkflowTaskFailedEvent(
	workflowTask *WorkflowTaskInfo,
	cause enumspb.WorkflowTaskFailedCause,
	failure *failurepb.Failure,
	identity string,
	versioningStamp *commonpb.WorkerVersionStamp,
	binChecksum, baseRunID, newRunID string,
	forkEventVersion int64,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskScheduleToStartTimeoutEvent 

func (ms *MutableStateImpl) AddWorkflowTaskScheduleToStartTimeoutEvent(
	workflowTask *WorkflowTaskInfo,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) AddWorkflowTaskScheduledEvent 

func (ms *MutableStateImpl) AddWorkflowTaskScheduledEvent(
	bypassTaskGeneration bool,
	workflowTaskType enumsspb.WorkflowTaskType,
) (*WorkflowTaskInfo, error)

func (*MutableStateImpl) AddWorkflowTaskScheduledEventAsHeartbeat 

func (ms *MutableStateImpl) AddWorkflowTaskScheduledEventAsHeartbeat(
	bypassTaskGeneration bool,
	originalScheduledTimestamp *timestamppb.Timestamp,
	workflowTaskType enumsspb.WorkflowTaskType,
) (*WorkflowTaskInfo, error)

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

func (*MutableStateImpl) AddWorkflowTaskStartedEvent 

func (ms *MutableStateImpl) AddWorkflowTaskStartedEvent(
	scheduledEventID int64,
	requestID string,
	taskQueue *taskqueuepb.TaskQueue,
	identity string,
	versioningStamp *commonpb.WorkerVersionStamp,
	redirectInfo *taskqueue.BuildIdRedirectInfo,
	skipVersioningCheck bool,
) (*historypb.HistoryEvent, *WorkflowTaskInfo, error)

func (*MutableStateImpl) AddWorkflowTaskTimedOutEvent 

func (ms *MutableStateImpl) AddWorkflowTaskTimedOutEvent(
	workflowTask *WorkflowTaskInfo,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) ApplyActivityTaskCancelRequestedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyActivityTaskCancelRequestedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyActivityTaskCanceledEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyActivityTaskCanceledEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyActivityTaskCompletedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyActivityTaskCompletedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyActivityTaskFailedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyActivityTaskFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyActivityTaskScheduledEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyActivityTaskScheduledEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) (*persistencespb.ActivityInfo, error)

func (*MutableStateImpl) ApplyActivityTaskStartedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyActivityTaskStartedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyActivityTaskTimedOutEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyActivityTaskTimedOutEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyBuildIdRedirect added in v1.24.0 

func (ms *MutableStateImpl) ApplyBuildIdRedirect(
	startingTaskScheduledEventId int64,
	buildId string,
	redirectCounter int64,
) error

ApplyBuildIdRedirect applies possible redirect to mutable state based on versioning stamp of a starting task. If a redirect is applicable, assigned build ID of the wf will be updated and all scheduled but not started tasks will be rescheduled to be put on the matching queue of the right build ID.

func (*MutableStateImpl) ApplyChildWorkflowExecutionCanceledEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyChildWorkflowExecutionCanceledEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyChildWorkflowExecutionCompletedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyChildWorkflowExecutionCompletedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyChildWorkflowExecutionFailedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyChildWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyChildWorkflowExecutionStartedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyChildWorkflowExecutionStartedEvent(
	event *historypb.HistoryEvent,
	clock *clockspb.VectorClock,
) error

func (*MutableStateImpl) ApplyChildWorkflowExecutionTerminatedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyChildWorkflowExecutionTerminatedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyChildWorkflowExecutionTimedOutEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyChildWorkflowExecutionTimedOutEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyExternalWorkflowExecutionCancelRequested added in v1.24.0 

func (ms *MutableStateImpl) ApplyExternalWorkflowExecutionCancelRequested(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyExternalWorkflowExecutionSignaled added in v1.24.0 

func (ms *MutableStateImpl) ApplyExternalWorkflowExecutionSignaled(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyMutation added in v1.26.2 

func (ms *MutableStateImpl) ApplyMutation(
	mutation *persistencespb.WorkflowMutableStateMutation,
) error

func (*MutableStateImpl) ApplyRequestCancelExternalWorkflowExecutionFailedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyRequestCancelExternalWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent added in v1.24.0 

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

func (*MutableStateImpl) ApplySignalExternalWorkflowExecutionFailedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplySignalExternalWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplySignalExternalWorkflowExecutionInitiatedEvent added in v1.24.0 

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

func (*MutableStateImpl) ApplySnapshot added in v1.26.2 

func (ms *MutableStateImpl) ApplySnapshot(
	snapshot *persistencespb.WorkflowMutableState,
) error

func (*MutableStateImpl) ApplyStartChildWorkflowExecutionFailedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyStartChildWorkflowExecutionFailedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyStartChildWorkflowExecutionInitiatedEvent added in v1.24.0 

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

func (*MutableStateImpl) ApplyTimerCanceledEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyTimerCanceledEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyTimerFiredEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyTimerFiredEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyTimerStartedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyTimerStartedEvent(
	event *historypb.HistoryEvent,
) (*persistencespb.TimerInfo, error)

func (*MutableStateImpl) ApplyTransientWorkflowTaskScheduled added in v1.24.0 

func (ms *MutableStateImpl) ApplyTransientWorkflowTaskScheduled() (*WorkflowTaskInfo, error)

func (*MutableStateImpl) ApplyUpsertWorkflowSearchAttributesEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyUpsertWorkflowSearchAttributesEvent(
	event *historypb.HistoryEvent,
)

func (*MutableStateImpl) ApplyWorkflowExecutionCancelRequestedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionCancelRequestedEvent(
	_ *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionCanceledEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionCanceledEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionCompletedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionCompletedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionContinuedAsNewEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionContinuedAsNewEvent(
	firstEventID int64,
	continueAsNewEvent *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionFailedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionFailedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionSignaled added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionSignaled(
	_ *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionStartedEvent added in v1.24.0 

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

func (*MutableStateImpl) ApplyWorkflowExecutionTerminatedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionTerminatedEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionTimedoutEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionTimedoutEvent(
	firstEventID int64,
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionUpdateAcceptedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionUpdateAcceptedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowExecutionUpdateAdmittedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionUpdateAdmittedEvent(event *historypb.HistoryEvent, batchId int64) error

ApplyWorkflowExecutionUpdateAdmittedEvent applies a WorkflowExecutionUpdateAdmittedEvent to mutable state.

func (*MutableStateImpl) ApplyWorkflowExecutionUpdateCompletedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowExecutionUpdateCompletedEvent(
	event *historypb.HistoryEvent,
	batchID int64,
) error

func (*MutableStateImpl) ApplyWorkflowPropertiesModifiedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowPropertiesModifiedEvent(
	event *historypb.HistoryEvent,
)

func (*MutableStateImpl) ApplyWorkflowTaskCompletedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowTaskCompletedEvent(
	event *historypb.HistoryEvent,
) error

func (*MutableStateImpl) ApplyWorkflowTaskFailedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowTaskFailedEvent() error

func (*MutableStateImpl) ApplyWorkflowTaskScheduledEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowTaskScheduledEvent(
	version int64,
	scheduledEventID int64,
	taskQueue *taskqueuepb.TaskQueue,
	startToCloseTimeout *durationpb.Duration,
	attempt int32,
	scheduleTimestamp *timestamppb.Timestamp,
	originalScheduledTimestamp *timestamppb.Timestamp,
	workflowTaskType enumsspb.WorkflowTaskType,
) (*WorkflowTaskInfo, error)

func (*MutableStateImpl) ApplyWorkflowTaskStartedEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowTaskStartedEvent(
	workflowTask *WorkflowTaskInfo,
	version int64,
	scheduledEventID int64,
	startedEventID int64,
	requestID string,
	timestamp time.Time,
	suggestContinueAsNew bool,
	historySizeBytes int64,
	versioningStamp *commonpb.WorkerVersionStamp,
	redirectCounter int64,
) (*WorkflowTaskInfo, error)

func (*MutableStateImpl) ApplyWorkflowTaskTimedOutEvent added in v1.24.0 

func (ms *MutableStateImpl) ApplyWorkflowTaskTimedOutEvent(
	timeoutType enumspb.TimeoutType,
) error

func (*MutableStateImpl) BufferSizeAcceptable added in v1.20.3 

func (ms *MutableStateImpl) BufferSizeAcceptable() bool

func (*MutableStateImpl) CheckResettable 

func (ms *MutableStateImpl) CheckResettable() error

CheckResettable check if workflow can be reset

func (*MutableStateImpl) CheckSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (ms *MutableStateImpl) CheckSpeculativeWorkflowTaskTimeoutTask(
	task *tasks.WorkflowTaskTimeoutTask,
) bool

func (*MutableStateImpl) ClearStickyTaskQueue added in v1.21.0 

func (ms *MutableStateImpl) ClearStickyTaskQueue()

func (*MutableStateImpl) ClearTransientWorkflowTask added in v1.16.3 

func (ms *MutableStateImpl) ClearTransientWorkflowTask() error

func (*MutableStateImpl) CloneToProto 

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

func (*MutableStateImpl) CloseTransactionAsMutation 

func (ms *MutableStateImpl) CloseTransactionAsMutation(
	transactionPolicy TransactionPolicy,
) (*persistence.WorkflowMutation, []*persistence.WorkflowEvents, error)

func (*MutableStateImpl) CloseTransactionAsSnapshot 

func (ms *MutableStateImpl) CloseTransactionAsSnapshot(
	transactionPolicy TransactionPolicy,
) (*persistence.WorkflowSnapshot, []*persistence.WorkflowEvents, error)

func (*MutableStateImpl) ContinueAsNewMinBackoff added in v1.19.0 

func (ms *MutableStateImpl) ContinueAsNewMinBackoff(backoffDuration *durationpb.Duration) *durationpb.Duration

func (*MutableStateImpl) CurrentTaskQueue added in v1.21.0 

func (ms *MutableStateImpl) CurrentTaskQueue() *taskqueuepb.TaskQueue

func (*MutableStateImpl) DeleteActivity 

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

DeleteActivity deletes details about an activity.

func (*MutableStateImpl) DeletePendingChildExecution 

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

DeletePendingChildExecution deletes details about a ChildExecutionInfo.

func (*MutableStateImpl) DeletePendingRequestCancel 

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

DeletePendingRequestCancel deletes details about a RequestCancelInfo.

func (*MutableStateImpl) DeletePendingSignal 

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

DeletePendingSignal deletes details about a SignalInfo

func (*MutableStateImpl) DeleteSignalRequested 

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

func (*MutableStateImpl) DeleteUserTimer 

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

DeleteUserTimer deletes an user timer.

func (*MutableStateImpl) FlushBufferedEvents 

func (ms *MutableStateImpl) FlushBufferedEvents()

func (*MutableStateImpl) GenerateMigrationTasks added in v1.17.0 

func (ms *MutableStateImpl) GenerateMigrationTasks() ([]tasks.Task, int64, error)

func (*MutableStateImpl) GetActivityByActivityID 

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

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

func (*MutableStateImpl) GetActivityInfo 

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

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

func (*MutableStateImpl) GetActivityInfoWithTimerHeartbeat 

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

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

func (*MutableStateImpl) GetActivityScheduledEvent 

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

func (*MutableStateImpl) GetActivityType added in v1.22.0 

func (ms *MutableStateImpl) GetActivityType(
	ctx context.Context,
	ai *persistencespb.ActivityInfo,
) (*commonpb.ActivityType, error)

GetActivityType gets the ActivityType from ActivityInfo if set, or from the events history otherwise for backwards compatibility.

func (*MutableStateImpl) GetApproximatePersistedSize added in v1.21.0 

func (ms *MutableStateImpl) GetApproximatePersistedSize() int

GetApproximatePersistedSize returns approximate size of in-memory objects that will be written to persistence + size of buffered events in history builder if they will not be flushed

func (*MutableStateImpl) GetAssignedBuildId added in v1.24.0 

func (ms *MutableStateImpl) GetAssignedBuildId() string

func (*MutableStateImpl) GetBaseWorkflowInfo added in v1.21.0 

func (ms *MutableStateImpl) GetBaseWorkflowInfo() *workflowspb.BaseExecutionInfo

func (*MutableStateImpl) GetChildExecutionInfo 

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

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

func (*MutableStateImpl) GetChildExecutionInitiatedEvent 

func (ms *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) GetCloseVersion added in v1.25.0 

func (ms *MutableStateImpl) GetCloseVersion() (int64, error)

func (*MutableStateImpl) GetCompletionEvent 

func (ms *MutableStateImpl) GetCompletionEvent(
	ctx context.Context,
) (event *historypb.HistoryEvent, err error)

GetCompletionEvent retrieves the workflow completion event from mutable state

func (*MutableStateImpl) GetCronBackoffDuration 

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

func (*MutableStateImpl) GetCurrentBranchToken 

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

func (*MutableStateImpl) GetCurrentVersion 

func (ms *MutableStateImpl) GetCurrentVersion() int64

func (*MutableStateImpl) GetExecutionInfo 

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

func (*MutableStateImpl) GetExecutionState 

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

func (*MutableStateImpl) GetFirstRunID added in v1.13.0 

func (ms *MutableStateImpl) GetFirstRunID(
	ctx context.Context,
) (string, error)

func (*MutableStateImpl) GetHSMCompletionCallbackArg added in v1.25.0 

func (ms *MutableStateImpl) GetHSMCompletionCallbackArg(ctx context.Context) (*persistencespb.HSMCompletionCallbackArg, error)

GetHSMCallbackArg converts a workflow completion event into a [persistencepb.HSMCallbackArg].

func (*MutableStateImpl) GetHistorySize added in v1.21.0 

func (ms *MutableStateImpl) GetHistorySize() int64

func (*MutableStateImpl) GetInheritedBuildId added in v1.24.0 

func (ms *MutableStateImpl) GetInheritedBuildId() string

func (*MutableStateImpl) GetLastCompletedWorkflowTaskStartedEventId added in v1.25.0 

func (ms *MutableStateImpl) GetLastCompletedWorkflowTaskStartedEventId() int64

GetStartedEventIdForLastCompletedWorkflowTask returns last started workflow task event ID

func (*MutableStateImpl) GetLastEventVersion added in v1.25.0 

func (ms *MutableStateImpl) GetLastEventVersion() (int64, error)

func (*MutableStateImpl) GetLastFirstEventIDTxnID 

func (ms *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 (ms *MutableStateImpl) GetLastWriteVersion() (int64, error)

func (*MutableStateImpl) GetMostRecentWorkerVersionStamp added in v1.24.0 

func (ms *MutableStateImpl) GetMostRecentWorkerVersionStamp() *commonpb.WorkerVersionStamp

func (*MutableStateImpl) GetNamespaceEntry 

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

func (*MutableStateImpl) GetNextEventID 

func (ms *MutableStateImpl) GetNextEventID() int64

GetNextEventID returns next event ID

func (*MutableStateImpl) GetNexusCompletion added in v1.24.0 

func (ms *MutableStateImpl) GetNexusCompletion(ctx context.Context) (nexus.OperationCompletion, error)

GetNexusCompletion converts a workflow completion event into a nexus.OperationCompletion. Completions may be sent to arbitrary third parties, we intentionally do not include any termination reasons, and expose only failure messages.

func (*MutableStateImpl) GetPendingActivityInfos 

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

func (*MutableStateImpl) GetPendingChildExecutionInfos 

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

func (*MutableStateImpl) GetPendingRequestCancelExternalInfos 

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

func (*MutableStateImpl) GetPendingSignalExternalInfos 

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

func (*MutableStateImpl) GetPendingSignalRequestedIds added in v1.26.0 

func (ms *MutableStateImpl) GetPendingSignalRequestedIds() []string

func (*MutableStateImpl) GetPendingTimerInfos 

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

func (*MutableStateImpl) GetPendingWorkflowTask 

func (ms *MutableStateImpl) GetPendingWorkflowTask() *WorkflowTaskInfo

func (*MutableStateImpl) GetQueryRegistry 

func (ms *MutableStateImpl) GetQueryRegistry() QueryRegistry

func (*MutableStateImpl) GetRequestCancelInfo 

func (ms *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 (ms *MutableStateImpl) GetRequesteCancelExternalInitiatedEvent(
	ctx context.Context,
	initiatedEventID int64,
) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) GetRetryBackoffDuration 

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

func (*MutableStateImpl) GetSignalExternalInitiatedEvent added in v1.14.0 

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

GetSignalExternalInitiatedEvent get the details about signal external workflow

func (*MutableStateImpl) GetSignalInfo 

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

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

func (*MutableStateImpl) GetStartEvent 

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

GetStartEvent retrieves the workflow start event from mutable state

func (*MutableStateImpl) GetStartVersion 

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

func (*MutableStateImpl) GetStartedWorkflowTask added in v1.21.0 

func (ms *MutableStateImpl) GetStartedWorkflowTask() *WorkflowTaskInfo

func (*MutableStateImpl) GetTransientWorkflowTaskInfo added in v1.20.0 

func (ms *MutableStateImpl) GetTransientWorkflowTaskInfo(
	workflowTask *WorkflowTaskInfo,
	identity string,
) *historyspb.TransientWorkflowTaskInfo

TODO (alex-update): Transient needs to be renamed to "TransientOrSpeculative"

func (*MutableStateImpl) GetUpdateCondition 

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

func (*MutableStateImpl) GetUpdateOutcome added in v1.21.0 

func (ms *MutableStateImpl) GetUpdateOutcome(
	ctx context.Context,
	updateID string,
) (*updatepb.Outcome, error)

func (*MutableStateImpl) GetUserTimerInfo 

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

GetUserTimerInfo gives details about a user timer.

func (*MutableStateImpl) GetUserTimerInfoByEventID 

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

GetUserTimerInfoByEventID gives details about a user timer.

func (*MutableStateImpl) GetWorkflowCloseTime added in v1.17.0 

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

GetWorkflowCloseTime returns workflow closed time, returns a zero time for open workflow

func (*MutableStateImpl) GetWorkflowExecutionDuration added in v1.24.0 

func (ms *MutableStateImpl) GetWorkflowExecutionDuration(ctx context.Context) (time.Duration, error)

GetWorkflowExecutionDuration returns the workflow execution duration. Returns zero for open workflow.

func (*MutableStateImpl) GetWorkflowKey added in v1.14.0 

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

func (*MutableStateImpl) GetWorkflowStateStatus 

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

func (*MutableStateImpl) GetWorkflowTaskByID added in v1.21.0 

func (ms *MutableStateImpl) GetWorkflowTaskByID(scheduledEventID int64) *WorkflowTaskInfo

GetWorkflowTaskByID returns details about the current workflow task by scheduled event ID.

func (*MutableStateImpl) GetWorkflowType 

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

func (*MutableStateImpl) HSM added in v1.24.0 

func (ms *MutableStateImpl) HSM() *hsm.Node

func (*MutableStateImpl) HadOrHasWorkflowTask added in v1.21.0 

func (ms *MutableStateImpl) HadOrHasWorkflowTask() bool

func (*MutableStateImpl) HasAnyBufferedEvent added in v1.21.0 

func (ms *MutableStateImpl) HasAnyBufferedEvent(filter historybuilder.BufferedEventFilter) bool

HasAnyBufferedEvent returns true if there is at least one buffered event that matches the provided filter.

func (*MutableStateImpl) HasBufferedEvents 

func (ms *MutableStateImpl) HasBufferedEvents() bool

func (*MutableStateImpl) HasCompletedAnyWorkflowTask added in v1.25.0 

func (ms *MutableStateImpl) HasCompletedAnyWorkflowTask() bool

func (*MutableStateImpl) HasParentExecution 

func (ms *MutableStateImpl) HasParentExecution() bool

func (*MutableStateImpl) HasPendingWorkflowTask 

func (ms *MutableStateImpl) HasPendingWorkflowTask() bool

func (*MutableStateImpl) HasStartedWorkflowTask added in v1.21.0 

func (ms *MutableStateImpl) HasStartedWorkflowTask() bool

func (*MutableStateImpl) IsCancelRequested 

func (ms *MutableStateImpl) IsCancelRequested() bool

func (*MutableStateImpl) IsCurrentWorkflowGuaranteed 

func (ms *MutableStateImpl) IsCurrentWorkflowGuaranteed() bool

func (*MutableStateImpl) IsDirty added in v1.22.0 

func (ms *MutableStateImpl) IsDirty() bool

func (*MutableStateImpl) IsResourceDuplicated 

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

func (*MutableStateImpl) IsSignalRequested 

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

func (*MutableStateImpl) IsStickyTaskQueueSet added in v1.21.0 

func (ms *MutableStateImpl) IsStickyTaskQueueSet() bool

func (*MutableStateImpl) IsTransientWorkflowTask added in v1.20.0 

func (ms *MutableStateImpl) IsTransientWorkflowTask() bool

func (*MutableStateImpl) IsWorkflowCloseAttempted added in v1.21.0 

func (ms *MutableStateImpl) IsWorkflowCloseAttempted() bool

func (*MutableStateImpl) IsWorkflowExecutionRunning 

func (ms *MutableStateImpl) IsWorkflowExecutionRunning() bool

func (*MutableStateImpl) IsWorkflowPendingOnWorkflowTaskBackoff added in v1.16.3 

func (ms *MutableStateImpl) IsWorkflowPendingOnWorkflowTaskBackoff() bool

func (*MutableStateImpl) LoadHistoryEvent added in v1.24.0 

func (ms *MutableStateImpl) LoadHistoryEvent(ctx context.Context, token []byte) (*historypb.HistoryEvent, error)

func (*MutableStateImpl) NextTransitionCount added in v1.25.0 

func (ms *MutableStateImpl) NextTransitionCount() int64

NextTransitionCount implements hsm.NodeBackend.

func (*MutableStateImpl) PopTasks added in v1.17.0 

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

func (*MutableStateImpl) RefreshExpirationTimeoutTask added in v1.25.0 

func (ms *MutableStateImpl) RefreshExpirationTimeoutTask(ctx context.Context) error

func (*MutableStateImpl) RejectWorkflowExecutionUpdate added in v1.20.0 

func (ms *MutableStateImpl) RejectWorkflowExecutionUpdate(_ string, _ *updatepb.Rejection) error

func (*MutableStateImpl) RemoveSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (ms *MutableStateImpl) RemoveSpeculativeWorkflowTaskTimeoutTask()

func (*MutableStateImpl) RetryActivity 

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

func (*MutableStateImpl) SetBaseWorkflow added in v1.21.0 

func (ms *MutableStateImpl) SetBaseWorkflow(
	baseRunID string,
	baseRunLowestCommonAncestorEventID int64,
	baseRunLowestCommonAncestorEventVersion int64,
)

func (*MutableStateImpl) SetCurrentBranchToken 

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

func (*MutableStateImpl) SetHistoryBuilder 

func (ms *MutableStateImpl) SetHistoryBuilder(hBuilder *historybuilder.HistoryBuilder)

func (*MutableStateImpl) SetHistoryTree 

func (ms *MutableStateImpl) SetHistoryTree(
	executionTimeout *durationpb.Duration,
	runTimeout *durationpb.Duration,
	treeID string,
) error

SetHistoryTree set treeID/historyBranches

func (*MutableStateImpl) SetSpeculativeWorkflowTaskTimeoutTask added in v1.21.0 

func (ms *MutableStateImpl) SetSpeculativeWorkflowTaskTimeoutTask(
	task *tasks.WorkflowTaskTimeoutTask,
) error

func (*MutableStateImpl) SetStickyTaskQueue added in v1.21.0 

func (ms *MutableStateImpl) SetStickyTaskQueue(name string, scheduleToStartTimeout *durationpb.Duration)

func (*MutableStateImpl) SetUpdateCondition 

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

func (*MutableStateImpl) StartTransaction 

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

func (*MutableStateImpl) TaskQueueScheduleToStartTimeout added in v1.21.0 

func (ms *MutableStateImpl) TaskQueueScheduleToStartTimeout(tqName string) (*taskqueuepb.TaskQueue, *durationpb.Duration)

TaskQueueScheduleToStartTimeout returns TaskQueue struct and corresponding StartToClose timeout. Task queue kind (sticky or normal) is set based on comparison of normal task queue name in mutable state and provided name. ScheduleToStartTimeout is set based on queue kind and workflow task type.

func (*MutableStateImpl) UpdateActivity 

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

UpdateActivity updates an activity

func (*MutableStateImpl) UpdateActivityInfo added in v1.24.0 

func (ms *MutableStateImpl) UpdateActivityInfo(
	incomingActivityInfo *historyservice.ActivitySyncInfo,
	resetActivityTimerTaskStatus bool,
) error

UpdateActivityInfo applies the necessary activity information

func (*MutableStateImpl) UpdateActivityProgress 

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

func (*MutableStateImpl) UpdateActivityWithTimerHeartbeat 

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

UpdateActivityWithTimerHeartbeat updates an activity

func (*MutableStateImpl) UpdateBuildIdAssignment added in v1.24.0 

func (ms *MutableStateImpl) UpdateBuildIdAssignment(buildId string) error

UpdateBuildIdAssignment based on initial assignment or a redirect

func (*MutableStateImpl) UpdateCurrentVersion 

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

func (*MutableStateImpl) UpdateDuplicatedResource 

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

func (*MutableStateImpl) UpdateUserTimer 

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

UpdateUserTimer updates the user timer in progress.

func (*MutableStateImpl) UpdateWorkflowStateStatus 

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

func (*MutableStateImpl) VisitUpdates added in v1.21.0 

func (ms *MutableStateImpl) VisitUpdates(visitor func(updID string, updInfo *persistencespb.UpdateInfo))

VisitUpdates visits mutable state update entries, ordered by the ID of the history event pointed to by the mutable state entry. Thus, for example, updates entries in Admitted state will be visited in the order that their Admitted events were added to history.

type MutableStateRebuilder 

type MutableStateRebuilder interface {
	ApplyEvents(
		ctx context.Context,
		namespaceID namespace.ID,
		requestID string,
		execution *commonpb.WorkflowExecution,
		history [][]*historypb.HistoryEvent,
		newRunHistory []*historypb.HistoryEvent,
		newRunID string,
	) (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(
	ctx context.Context,
	namespaceID namespace.ID,
	requestID string,
	execution *commonpb.WorkflowExecution,
	history [][]*historypb.HistoryEvent,
	newRunHistory []*historypb.HistoryEvent,
	newRunID string,
) (MutableState, error)

type MutableStateWithEffects added in v1.21.0 

type MutableStateWithEffects struct {
	MutableState
	effect.Controller
}

func WithEffects added in v1.21.0 

func WithEffects(effects effect.Controller, ms MutableState) MutableStateWithEffects

func (MutableStateWithEffects) CanAddEvent added in v1.24.0 

func (mse MutableStateWithEffects) CanAddEvent() bool

type QueryCompletionState added in v1.17.3 

type QueryCompletionState struct {
	Type   QueryCompletionType
	Result *querypb.WorkflowQueryResult
	Err    error
}

type QueryCompletionType added in v1.17.3 

type QueryCompletionType int
const (
	QueryCompletionTypeSucceeded QueryCompletionType = iota
	QueryCompletionTypeUnblocked
	QueryCompletionTypeFailed
)

type QueryRegistry 

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

	GetQueryCompletionCh(string) (<-chan struct{}, error)
	GetQueryInput(string) (*querypb.WorkflowQuery, error)
	GetCompletionState(string) (*QueryCompletionState, error)

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

func NewQueryRegistry 

func NewQueryRegistry() QueryRegistry

type RelocatableAttributes added in v1.20.0 

type RelocatableAttributes struct {
	Memo             *commonpb.Memo
	SearchAttributes *commonpb.SearchAttributes
}

RelocatableAttributes contains workflow attributes that can be moved from the mutable state to the persistence backend.

type RelocatableAttributesFetcher added in v1.20.0 

type RelocatableAttributesFetcher interface {
	Fetch(
		ctx context.Context,
		mutableState MutableState,
	) (*RelocatableAttributes, error)
}

RelocatableAttributesFetcher is used to fetch the relocatable attributes from the mutable state. Relocatable attributes are attributes that can be moved from the mutable state to the persistence backend.

func RelocatableAttributesFetcherProvider added in v1.20.0 

func RelocatableAttributesFetcherProvider(
	visibilityManager manager.VisibilityManager,
) RelocatableAttributesFetcher

RelocatableAttributesFetcherProvider provides a new instance of a RelocatableAttributesFetcher. The manager.VisibilityManager parameter is used to fetch the relocatable attributes from the persistence backend iff we already moved them there out from the mutable state. The visibility manager is not used if the relocatable attributes are still in the mutable state. We detect that the fields have moved by checking if the CloseExecutionVisibilityTask for this workflow execution is marked as complete in the mutable state. Because the relocatable fields that we push to persistence are never updated thereafter, we may cache them on a per-workflow execution basis. Currently, there is no cache, but you may provide a manager.VisibilityManager that supports caching to this function safely. TODO: Add a cache around the visibility manager for the relocatable attributes.

type TaskGenerator 

type TaskGenerator interface {
	GenerateWorkflowStartTasks(
		startEvent *historypb.HistoryEvent,
	) (executionTimeoutTimerTaskStatus int32, err error)
	GenerateWorkflowCloseTasks(
		closedTime time.Time,
		deleteAfterClose bool,
	) error
	// GenerateDeleteHistoryEventTask adds a tasks.DeleteHistoryEventTask to the mutable state.
	// This task is used to delete the history events of the workflow execution after the retention period expires.
	GenerateDeleteHistoryEventTask(closeTime time.Time) error
	GenerateDeleteExecutionTask() (*tasks.DeleteExecutionTask, error)
	GenerateRecordWorkflowStartedTasks(
		startEvent *historypb.HistoryEvent,
	) error
	GenerateDelayedWorkflowTasks(
		startEvent *historypb.HistoryEvent,
	) error
	GenerateScheduleWorkflowTaskTasks(
		workflowTaskScheduledEventID int64,
	) error
	GenerateScheduleSpeculativeWorkflowTaskTasks(
		workflowTask *WorkflowTaskInfo,
	) error
	GenerateStartWorkflowTaskTasks(
		workflowTaskScheduledEventID int64,
	) error
	GenerateActivityTasks(
		activityScheduledEventID int64,
	) error
	GenerateActivityRetryTasks(activityInfo *persistencespb.ActivityInfo) error
	GenerateChildWorkflowTasks(
		event *historypb.HistoryEvent,
	) error
	GenerateRequestCancelExternalTasks(
		event *historypb.HistoryEvent,
	) error
	GenerateSignalExternalTasks(
		event *historypb.HistoryEvent,
	) error
	GenerateUpsertVisibilityTask() error
	GenerateWorkflowResetTasks() error

	// these 2 APIs should only be called when mutable state transaction is being closed
	GenerateActivityTimerTasks() error
	GenerateUserTimerTasks() error

	// replication tasks
	GenerateHistoryReplicationTasks(
		eventBatches [][]*historypb.HistoryEvent,
	) error
	GenerateMigrationTasks() ([]tasks.Task, int64, error)

	// Generate tasks for any updated state machines on mutable state.
	// Looks up machine definition in the provided registry.
	// Must be called **after** updating transition history for the current transition
	GenerateDirtySubStateMachineTasks(stateMachineRegistry *hsm.Registry) error
}

type TaskGeneratorImpl 

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

func NewTaskGenerator 

func NewTaskGenerator(
	namespaceRegistry namespace.Registry,
	mutableState MutableState,
	config *configs.Config,
	archivalMetadata archiver.ArchivalMetadata,
) *TaskGeneratorImpl

func (*TaskGeneratorImpl) GenerateActivityRetryTasks 

func (r *TaskGeneratorImpl) GenerateActivityRetryTasks(activityInfo *persistencespb.ActivityInfo) error

func (*TaskGeneratorImpl) GenerateActivityTasks added in v1.16.0 

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

func (*TaskGeneratorImpl) GenerateActivityTimerTasks 

func (r *TaskGeneratorImpl) GenerateActivityTimerTasks() error

func (*TaskGeneratorImpl) GenerateChildWorkflowTasks 

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

func (*TaskGeneratorImpl) GenerateDelayedWorkflowTasks 

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

func (*TaskGeneratorImpl) GenerateDeleteExecutionTask added in v1.15.0 

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

func (*TaskGeneratorImpl) GenerateDeleteHistoryEventTask added in v1.20.0 

func (r *TaskGeneratorImpl) GenerateDeleteHistoryEventTask(closeTime time.Time) error

GenerateDeleteHistoryEventTask adds a task to delete all history events for a workflow execution. This method only adds the task to the mutable state object in memory; it does not write the task to the database. You must call shard.Context#AddTasks to notify the history engine of this task.

func (*TaskGeneratorImpl) GenerateDirtySubStateMachineTasks added in v1.24.0 

func (r *TaskGeneratorImpl) GenerateDirtySubStateMachineTasks(
	stateMachineRegistry *hsm.Registry,
) error

func (*TaskGeneratorImpl) GenerateHistoryReplicationTasks added in v1.14.0 

func (r *TaskGeneratorImpl) GenerateHistoryReplicationTasks(
	eventBatches [][]*historypb.HistoryEvent,
) error

func (*TaskGeneratorImpl) GenerateMigrationTasks added in v1.17.0 

func (r *TaskGeneratorImpl) GenerateMigrationTasks() ([]tasks.Task, int64, error)

func (*TaskGeneratorImpl) GenerateRecordWorkflowStartedTasks 

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

func (*TaskGeneratorImpl) GenerateRequestCancelExternalTasks 

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

func (*TaskGeneratorImpl) GenerateScheduleSpeculativeWorkflowTaskTasks added in v1.23.0 

func (r *TaskGeneratorImpl) GenerateScheduleSpeculativeWorkflowTaskTasks(
	workflowTask *WorkflowTaskInfo,
) error

GenerateScheduleSpeculativeWorkflowTaskTasks is different from GenerateScheduleWorkflowTaskTasks (above):

  1. Always create ScheduleToStart timeout timer task (even for normal task queue).
  2. Don't create transfer task to push WT to matching.

func (*TaskGeneratorImpl) GenerateScheduleWorkflowTaskTasks 

func (r *TaskGeneratorImpl) GenerateScheduleWorkflowTaskTasks(
	workflowTaskScheduledEventID int64,
) error

func (*TaskGeneratorImpl) GenerateSignalExternalTasks 

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

func (*TaskGeneratorImpl) GenerateStartWorkflowTaskTasks 

func (r *TaskGeneratorImpl) GenerateStartWorkflowTaskTasks(
	workflowTaskScheduledEventID int64,
) error

func (*TaskGeneratorImpl) GenerateUpsertVisibilityTask added in v1.18.0 

func (r *TaskGeneratorImpl) GenerateUpsertVisibilityTask() error

func (*TaskGeneratorImpl) GenerateUserTimerTasks 

func (r *TaskGeneratorImpl) GenerateUserTimerTasks() error

func (*TaskGeneratorImpl) GenerateWorkflowCloseTasks 

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

func (*TaskGeneratorImpl) GenerateWorkflowResetTasks 

func (r *TaskGeneratorImpl) GenerateWorkflowResetTasks() error

func (*TaskGeneratorImpl) GenerateWorkflowStartTasks 

func (r *TaskGeneratorImpl) GenerateWorkflowStartTasks(
	startEvent *historypb.HistoryEvent,
) (int32, error)

type TaskGeneratorProvider added in v1.16.0 

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

func GetTaskGeneratorProvider added in v1.26.2 

func GetTaskGeneratorProvider() TaskGeneratorProvider

type TaskRefresher 

type TaskRefresher interface {
	// Refresh refreshes all tasks needed for the state machine to make progress or
	// those have side effects.
	Refresh(
		ctx context.Context,
		mutableState MutableState,
	) error
	// PartialRefresh refresh tasks for all sub state machines that have been updated
	// since the given minVersionedTransition (inclusive).
	// If a sub state machine's lastUpdateVersionedTransition is not available,
	// it will be treated the same as lastUpdateVersionedTransition equals to EmptyVersionedTransition.
	// The provided minVersionedTransition should NOT be nil, and if equals to EmptyVersionedTransition,
	// the behavior is equivalent to Refresh().
	PartialRefresh(
		ctx context.Context,
		mutableState MutableState,
		minVersionedTransition *persistencespb.VersionedTransition,
	) error
}

type TaskRefresherImpl 

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

func NewTaskRefresher 

func NewTaskRefresher(
	shard shard.Context,
) *TaskRefresherImpl

func (*TaskRefresherImpl) PartialRefresh added in v1.25.0 

func (r *TaskRefresherImpl) PartialRefresh(
	ctx context.Context,
	mutableState MutableState,
	minVersionedTransition *persistencespb.VersionedTransition,
) error

func (*TaskRefresherImpl) Refresh added in v1.25.0 

func (r *TaskRefresherImpl) Refresh(
	ctx context.Context,
	mutableState MutableState,
) error

type TimerSequence 

type TimerSequence interface {
	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,
		newWorkflowFailoverVersion int64,
		newWorkflowSnapshot *persistence.WorkflowSnapshot,
		newWorkflowEventsSeq []*persistence.WorkflowEvents,
	) (int64, error)

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

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

	SetWorkflowExecution(
		ctx context.Context,
		workflowSnapshot *persistence.WorkflowSnapshot,
	) 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,
	resetWorkflowFailoverVersion int64,
	resetWorkflowSnapshot *persistence.WorkflowSnapshot,
	resetWorkflowEventsSeq []*persistence.WorkflowEvents,
	newWorkflowFailoverVersion *int64,
	newWorkflowSnapshot *persistence.WorkflowSnapshot,
	newWorkflowEventsSeq []*persistence.WorkflowEvents,
	currentWorkflowFailoverVersion *int64,
	currentWorkflowMutation *persistence.WorkflowMutation,
	currentWorkflowEventsSeq []*persistence.WorkflowEvents,
) (int64, int64, int64, error)

func (*TransactionImpl) CreateWorkflowExecution added in v1.12.0 

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

func (*TransactionImpl) SetWorkflowExecution added in v1.16.0 

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

func (*TransactionImpl) UpdateWorkflowExecution added in v1.12.0 

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

type TransactionPolicy 

type TransactionPolicy int
const (
	TransactionPolicyActive  TransactionPolicy = 0
	TransactionPolicyPassive TransactionPolicy = 1
	// Mutable state is a top-level state machine in the state machines framework.
	StateMachineType = "workflow.MutableState"
)

func (TransactionPolicy) Ptr 

func (policy TransactionPolicy) Ptr() *TransactionPolicy

type WorkflowTaskCompletionLimits added in v1.21.0 

type WorkflowTaskCompletionLimits struct {
	MaxResetPoints              int
	MaxSearchAttributeValueSize int
}

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

	// Indicate type of the current workflow task (normal, transient, or speculative).
	Type enumsspb.WorkflowTaskType

	// These two fields are sent to workers in the WorkflowTaskStarted event. We need to save a
	// copy in mutable state to know the last values we sent (which might have been in a
	// transient event), otherwise a dynamic config change of the suggestion threshold could
	// cause the WorkflowTaskStarted event that the worker used to not match the event we saved
	// in history.
	SuggestContinueAsNew bool
	HistorySizeBytes     int64
	// BuildIdRedirectCounter tracks the started build ID redirect counter for transient/speculative WFT. This
	// info is to make sure the right redirect counter is used in the WFT started event created later
	// for a transient/speculative WFT.
	BuildIdRedirectCounter int64
	// BuildId tracks the started build ID for transient/speculative WFT. This info is used for two purposes:
	// - verify WFT completes by the same Build ID that started in the latest attempt
	// - when persisting transient/speculative WFT, the right Build ID is used in the WFT started event
	BuildId string
}

TODO: This should be part of persistence layer

Source Files

View all Source files

Directories

Path Synopsis
Package cache is a generated GoMock package.
 Package cache is a generated GoMock package.

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.