ndc

package
v1.22.3 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2023 License: MIT Imports: 41 Imported by: 0

Documentation

Overview

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Package ndc is a generated GoMock package.

Index

Constants

View Source 
const (
	EventsReapplicationResetWorkflowReason = "events-reapplication"
)

Variables

View Source 
var (
	// ErrInvalidNamespaceID is returned if namespace ID is invalid
	ErrInvalidNamespaceID = serviceerror.NewInvalidArgument("invalid namespace ID")
	// ErrInvalidExecution is returned if execution is invalid
	ErrInvalidExecution = serviceerror.NewInvalidArgument("invalid execution")
	// ErrInvalidRunID is returned if run ID is invalid
	ErrInvalidRunID = serviceerror.NewInvalidArgument("invalid run ID")
	// ErrEventIDMismatch is returned if event ID mis-matched
	ErrEventIDMismatch = serviceerror.NewInvalidArgument("event ID mismatch")
	// ErrEventVersionMismatch is returned if event version mis-matched
	ErrEventVersionMismatch = serviceerror.NewInvalidArgument("event version mismatch")
	// ErrNoNewRunHistory is returned if there is no new run history
	ErrNoNewRunHistory = serviceerror.NewInvalidArgument("no new run history events")
	// ErrLastEventIsNotContinueAsNew is returned if the last event is not continue as new
	ErrLastEventIsNotContinueAsNew = serviceerror.NewInvalidArgument("last event is not continue as new")
)

Functions

func IsTerminatedByResetter 

func IsTerminatedByResetter(event *historypb.HistoryEvent) bool

func NewResetter 

func NewResetter(
	shard shard.Context,
	transactionMgr transactionMgr,
	namespaceID namespace.ID,
	workflowID string,
	baseRunID string,
	newContext workflow.Context,
	newRunID string,
	logger log.Logger,
) *resetterImpl

func NewWorkflowResetter 

func NewWorkflowResetter(
	shard shard.Context,
	workflowCache wcache.Cache,
	logger log.Logger,
) *workflowResetterImpl

func WorkflowHappensAfter 

func WorkflowHappensAfter(
	thisLastWriteVersion int64,
	thisLastEventTaskID int64,
	thatLastWriteVersion int64,
	thatLastEventTaskID int64,
) bool

Types

type ActivityStateReplicator added in v1.22.0 

type ActivityStateReplicator interface {
	SyncActivityState(
		ctx context.Context,
		request *historyservice.SyncActivityRequest,
	) error
}

type ActivityStateReplicatorImpl added in v1.22.0 

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

func NewActivityStateReplicator added in v1.22.0 

func NewActivityStateReplicator(
	shard shard.Context,
	workflowCache wcache.Cache,
	logger log.Logger,
) *ActivityStateReplicatorImpl

func (*ActivityStateReplicatorImpl) SyncActivityState added in v1.22.0 

func (r *ActivityStateReplicatorImpl) SyncActivityState(
	ctx context.Context,
	request *historyservice.SyncActivityRequest,
) (retError error)

type BranchMgr 

type BranchMgr interface {
	// contains filtered or unexported methods
}

type BranchMgrImpl 

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

func NewBranchMgr 

func NewBranchMgr(
	shard shard.Context,
	context workflow.Context,
	mutableState workflow.MutableState,
	logger log.Logger,
) *BranchMgrImpl

type ConflictResolver 

type ConflictResolver interface {
	// contains filtered or unexported methods
}

type ConflictResolverImpl 

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

func NewConflictResolver 

func NewConflictResolver(
	shard shard.Context,
	context workflow.Context,
	mutableState workflow.MutableState,
	logger log.Logger,
) *ConflictResolverImpl

type EventBlobs added in v1.21.0 

type EventBlobs struct {
	CurrentRunEvents commonpb.DataBlob
	NewRunEvents     *commonpb.DataBlob
}

type EventsReapplier 

type EventsReapplier interface {
	ReapplyEvents(
		ctx context.Context,
		ms workflow.MutableState,
		historyEvents []*historypb.HistoryEvent,
		runID string,
	) ([]*historypb.HistoryEvent, error)
}

type EventsReapplierImpl 

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

func NewEventsReapplier 

func NewEventsReapplier(
	metricsHandler metrics.Handler,
	logger log.Logger,
) *EventsReapplierImpl

func (*EventsReapplierImpl) ReapplyEvents 

func (r *EventsReapplierImpl) ReapplyEvents(
	ctx context.Context,
	ms workflow.MutableState,
	historyEvents []*historypb.HistoryEvent,
	runID string,
) ([]*historypb.HistoryEvent, error)

type HistoryBlobsPaginationItem 

type HistoryBlobsPaginationItem struct {
	History       *historypb.History
	TransactionID int64
}

type HistoryReplicator 

type HistoryReplicator interface {
	ApplyEvents(
		ctx context.Context,
		request *historyservice.ReplicateEventsV2Request,
	) error
	// ApplyEventBlobs is the batch version of ApplyEvents
	// NOTE:
	//  1. all history events should have the same version
	//  2. all history events should share the same version history
	ApplyEventBlobs(
		ctx context.Context,
		workflowKey definition.WorkflowKey,
		baseExecutionInfo *workflowpb.BaseExecutionInfo,
		versionHistoryItems []*historyspb.VersionHistoryItem,
		events [][]*historypb.HistoryEvent,
		newEvents []*historypb.HistoryEvent,
	) error
}

type HistoryReplicatorImpl 

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

func NewHistoryReplicator 

func NewHistoryReplicator(
	shard shard.Context,
	workflowCache wcache.Cache,
	eventsReapplier EventsReapplier,
	eventSerializer serialization.Serializer,
	logger log.Logger,
) *HistoryReplicatorImpl

func (*HistoryReplicatorImpl) ApplyEventBlobs added in v1.21.0 

func (r *HistoryReplicatorImpl) ApplyEventBlobs(
	ctx context.Context,
	workflowKey definition.WorkflowKey,
	baseExecutionInfo *workflowpb.BaseExecutionInfo,
	versionHistoryItems []*historyspb.VersionHistoryItem,
	eventsSlice [][]*historypb.HistoryEvent,
	newEvents []*historypb.HistoryEvent,
) error

func (*HistoryReplicatorImpl) ApplyEvents 

func (r *HistoryReplicatorImpl) ApplyEvents(
	ctx context.Context,
	request *historyservice.ReplicateEventsV2Request,
) (retError error)

type MockActivityStateReplicator added in v1.22.0 

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

MockActivityStateReplicator is a mock of ActivityStateReplicator interface.

func NewMockActivityStateReplicator added in v1.22.0 

func NewMockActivityStateReplicator(ctrl *gomock.Controller) *MockActivityStateReplicator

NewMockActivityStateReplicator creates a new mock instance.

func (*MockActivityStateReplicator) EXPECT added in v1.22.0 

func (m *MockActivityStateReplicator) EXPECT() *MockActivityStateReplicatorMockRecorder

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

func (*MockActivityStateReplicator) SyncActivityState added in v1.22.0 

func (m *MockActivityStateReplicator) SyncActivityState(ctx context.Context, request *historyservice.SyncActivityRequest) error

SyncActivityState mocks base method.

type MockActivityStateReplicatorMockRecorder added in v1.22.0 

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

MockActivityStateReplicatorMockRecorder is the mock recorder for MockActivityStateReplicator.

func (*MockActivityStateReplicatorMockRecorder) SyncActivityState added in v1.22.0 

func (mr *MockActivityStateReplicatorMockRecorder) SyncActivityState(ctx, request interface{}) *gomock.Call

SyncActivityState indicates an expected call of SyncActivityState.

type MockBranchMgr 

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

MockBranchMgr is a mock of BranchMgr interface.

func NewMockBranchMgr 

func NewMockBranchMgr(ctrl *gomock.Controller) *MockBranchMgr

NewMockBranchMgr creates a new mock instance.

func (*MockBranchMgr) EXPECT 

func (m *MockBranchMgr) EXPECT() *MockBranchMgrMockRecorder

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

type MockBranchMgrMockRecorder 

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

MockBranchMgrMockRecorder is the mock recorder for MockBranchMgr.

type MockConflictResolver 

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

MockConflictResolver is a mock of ConflictResolver interface.

func NewMockConflictResolver 

func NewMockConflictResolver(ctrl *gomock.Controller) *MockConflictResolver

NewMockConflictResolver creates a new mock instance.

func (*MockConflictResolver) EXPECT 

func (m *MockConflictResolver) EXPECT() *MockConflictResolverMockRecorder

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

type MockConflictResolverMockRecorder 

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

MockConflictResolverMockRecorder is the mock recorder for MockConflictResolver.

type MockEventsReapplier 

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

MockEventsReapplier is a mock of EventsReapplier interface.

func NewMockEventsReapplier 

func NewMockEventsReapplier(ctrl *gomock.Controller) *MockEventsReapplier

NewMockEventsReapplier creates a new mock instance.

func (*MockEventsReapplier) EXPECT 

func (m *MockEventsReapplier) EXPECT() *MockEventsReapplierMockRecorder

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

func (*MockEventsReapplier) ReapplyEvents 

func (m *MockEventsReapplier) ReapplyEvents(ctx context.Context, ms workflow.MutableState, historyEvents []*history.HistoryEvent, runID string) ([]*history.HistoryEvent, error)

ReapplyEvents mocks base method.

type MockEventsReapplierMockRecorder 

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

MockEventsReapplierMockRecorder is the mock recorder for MockEventsReapplier.

func (*MockEventsReapplierMockRecorder) ReapplyEvents 

func (mr *MockEventsReapplierMockRecorder) ReapplyEvents(ctx, ms, historyEvents, runID interface{}) *gomock.Call

ReapplyEvents indicates an expected call of ReapplyEvents.

type MockStateRebuilder 

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

MockStateRebuilder is a mock of StateRebuilder interface.

func NewMockStateRebuilder 

func NewMockStateRebuilder(ctrl *gomock.Controller) *MockStateRebuilder

NewMockStateRebuilder creates a new mock instance.

func (*MockStateRebuilder) EXPECT 

func (m *MockStateRebuilder) EXPECT() *MockStateRebuilderMockRecorder

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

func (*MockStateRebuilder) Rebuild 

func (m *MockStateRebuilder) Rebuild(ctx context.Context, now time.Time, baseWorkflowIdentifier definition.WorkflowKey, baseBranchToken []byte, baseLastEventID int64, baseLastEventVersion *int64, targetWorkflowIdentifier definition.WorkflowKey, targetBranchToken []byte, requestID string) (workflow.MutableState, int64, error)

Rebuild mocks base method.

type MockStateRebuilderMockRecorder 

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

MockStateRebuilderMockRecorder is the mock recorder for MockStateRebuilder.

func (*MockStateRebuilderMockRecorder) Rebuild 

func (mr *MockStateRebuilderMockRecorder) Rebuild(ctx, now, baseWorkflowIdentifier, baseBranchToken, baseLastEventID, baseLastEventVersion, targetWorkflowIdentifier, targetBranchToken, requestID interface{}) *gomock.Call

Rebuild indicates an expected call of Rebuild.

type MockWorkflow 

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

MockWorkflow is a mock of Workflow interface.

func NewMockWorkflow 

func NewMockWorkflow(ctrl *gomock.Controller) *MockWorkflow

NewMockWorkflow creates a new mock instance.

func (*MockWorkflow) EXPECT 

func (m *MockWorkflow) EXPECT() *MockWorkflowMockRecorder

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

func (*MockWorkflow) FlushBufferedEvents 

func (m *MockWorkflow) FlushBufferedEvents() error

FlushBufferedEvents mocks base method.

func (*MockWorkflow) GetContext 

func (m *MockWorkflow) GetContext() workflow.Context

GetContext mocks base method.

func (*MockWorkflow) GetMutableState 

func (m *MockWorkflow) GetMutableState() workflow.MutableState

GetMutableState mocks base method.

func (*MockWorkflow) GetReleaseFn 

func (m *MockWorkflow) GetReleaseFn() cache.ReleaseCacheFunc

GetReleaseFn mocks base method.

func (*MockWorkflow) GetVectorClock 

func (m *MockWorkflow) GetVectorClock() (int64, int64, error)

GetVectorClock mocks base method.

func (*MockWorkflow) HappensAfter 

func (m *MockWorkflow) HappensAfter(that Workflow) (bool, error)

HappensAfter mocks base method.

func (*MockWorkflow) LastWriteByLocalCluster added in v1.21.0 

func (m *MockWorkflow) LastWriteByLocalCluster() (bool, error)

LastWriteByLocalCluster mocks base method.

func (*MockWorkflow) Revive 

func (m *MockWorkflow) Revive() error

Revive mocks base method.

func (*MockWorkflow) SuppressBy 

func (m *MockWorkflow) SuppressBy(incomingWorkflow Workflow) (workflow.TransactionPolicy, error)

SuppressBy mocks base method.

type MockWorkflowMockRecorder 

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

MockWorkflowMockRecorder is the mock recorder for MockWorkflow.

func (*MockWorkflowMockRecorder) FlushBufferedEvents 

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

FlushBufferedEvents indicates an expected call of FlushBufferedEvents.

func (*MockWorkflowMockRecorder) GetContext 

func (mr *MockWorkflowMockRecorder) GetContext() *gomock.Call

GetContext indicates an expected call of GetContext.

func (*MockWorkflowMockRecorder) GetMutableState 

func (mr *MockWorkflowMockRecorder) GetMutableState() *gomock.Call

GetMutableState indicates an expected call of GetMutableState.

func (*MockWorkflowMockRecorder) GetReleaseFn 

func (mr *MockWorkflowMockRecorder) GetReleaseFn() *gomock.Call

GetReleaseFn indicates an expected call of GetReleaseFn.

func (*MockWorkflowMockRecorder) GetVectorClock 

func (mr *MockWorkflowMockRecorder) GetVectorClock() *gomock.Call

GetVectorClock indicates an expected call of GetVectorClock.

func (*MockWorkflowMockRecorder) HappensAfter 

func (mr *MockWorkflowMockRecorder) HappensAfter(that interface{}) *gomock.Call

HappensAfter indicates an expected call of HappensAfter.

func (*MockWorkflowMockRecorder) LastWriteByLocalCluster added in v1.21.0 

func (mr *MockWorkflowMockRecorder) LastWriteByLocalCluster() *gomock.Call

LastWriteByLocalCluster indicates an expected call of LastWriteByLocalCluster.

func (*MockWorkflowMockRecorder) Revive 

func (mr *MockWorkflowMockRecorder) Revive() *gomock.Call

Revive indicates an expected call of Revive.

func (*MockWorkflowMockRecorder) SuppressBy 

func (mr *MockWorkflowMockRecorder) SuppressBy(incomingWorkflow interface{}) *gomock.Call

SuppressBy indicates an expected call of SuppressBy.

type MockWorkflowResetter 

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

MockWorkflowResetter is a mock of WorkflowResetter interface.

func NewMockWorkflowResetter 

func NewMockWorkflowResetter(ctrl *gomock.Controller) *MockWorkflowResetter

NewMockWorkflowResetter creates a new mock instance.

func (*MockWorkflowResetter) EXPECT 

func (m *MockWorkflowResetter) EXPECT() *MockWorkflowResetterMockRecorder

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

func (*MockWorkflowResetter) ResetWorkflow 

func (m *MockWorkflowResetter) ResetWorkflow(ctx context.Context, namespaceID namespace.ID, workflowID, baseRunID string, baseBranchToken []byte, baseRebuildLastEventID, baseRebuildLastEventVersion, baseNextEventID int64, resetRunID, resetRequestID string, currentWorkflow Workflow, resetReason string, additionalReapplyEvents []*v10.HistoryEvent, resetReapplyType v1.ResetReapplyType) error

ResetWorkflow mocks base method.

type MockWorkflowResetterMockRecorder 

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

MockWorkflowResetterMockRecorder is the mock recorder for MockWorkflowResetter.

func (*MockWorkflowResetterMockRecorder) ResetWorkflow 

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

ResetWorkflow indicates an expected call of ResetWorkflow.

type MockWorkflowStateReplicator added in v1.22.0 

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

MockWorkflowStateReplicator is a mock of WorkflowStateReplicator interface.

func NewMockWorkflowStateReplicator added in v1.22.0 

func NewMockWorkflowStateReplicator(ctrl *gomock.Controller) *MockWorkflowStateReplicator

NewMockWorkflowStateReplicator creates a new mock instance.

func (*MockWorkflowStateReplicator) EXPECT added in v1.22.0 

func (m *MockWorkflowStateReplicator) EXPECT() *MockWorkflowStateReplicatorMockRecorder

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

func (*MockWorkflowStateReplicator) SyncWorkflowState added in v1.22.0 

func (m *MockWorkflowStateReplicator) SyncWorkflowState(ctx context.Context, request *historyservice.ReplicateWorkflowStateRequest) error

SyncWorkflowState mocks base method.

type MockWorkflowStateReplicatorMockRecorder added in v1.22.0 

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

MockWorkflowStateReplicatorMockRecorder is the mock recorder for MockWorkflowStateReplicator.

func (*MockWorkflowStateReplicatorMockRecorder) SyncWorkflowState added in v1.22.0 

func (mr *MockWorkflowStateReplicatorMockRecorder) SyncWorkflowState(ctx, request interface{}) *gomock.Call

SyncWorkflowState indicates an expected call of SyncWorkflowState.

type MocktransactionMgr 

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

MocktransactionMgr is a mock of transactionMgr interface.

func NewMocktransactionMgr 

func NewMocktransactionMgr(ctrl *gomock.Controller) *MocktransactionMgr

NewMocktransactionMgr creates a new mock instance.

func (*MocktransactionMgr) EXPECT 

func (m *MocktransactionMgr) EXPECT() *MocktransactionMgrMockRecorder

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

type MocktransactionMgrForExistingWorkflow 

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

MocktransactionMgrForExistingWorkflow is a mock of transactionMgrForExistingWorkflow interface.

func NewMocktransactionMgrForExistingWorkflow 

func NewMocktransactionMgrForExistingWorkflow(ctrl *gomock.Controller) *MocktransactionMgrForExistingWorkflow

NewMocktransactionMgrForExistingWorkflow creates a new mock instance.

func (*MocktransactionMgrForExistingWorkflow) EXPECT 

func (m *MocktransactionMgrForExistingWorkflow) EXPECT() *MocktransactionMgrForExistingWorkflowMockRecorder

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

type MocktransactionMgrForExistingWorkflowMockRecorder 

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

MocktransactionMgrForExistingWorkflowMockRecorder is the mock recorder for MocktransactionMgrForExistingWorkflow.

type MocktransactionMgrForNewWorkflow 

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

MocktransactionMgrForNewWorkflow is a mock of transactionMgrForNewWorkflow interface.

func NewMocktransactionMgrForNewWorkflow 

func NewMocktransactionMgrForNewWorkflow(ctrl *gomock.Controller) *MocktransactionMgrForNewWorkflow

NewMocktransactionMgrForNewWorkflow creates a new mock instance.

func (*MocktransactionMgrForNewWorkflow) EXPECT 

func (m *MocktransactionMgrForNewWorkflow) EXPECT() *MocktransactionMgrForNewWorkflowMockRecorder

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

type MocktransactionMgrForNewWorkflowMockRecorder 

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

MocktransactionMgrForNewWorkflowMockRecorder is the mock recorder for MocktransactionMgrForNewWorkflow.

type MocktransactionMgrMockRecorder 

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

MocktransactionMgrMockRecorder is the mock recorder for MocktransactionMgr.

type StateRebuilder 

type StateRebuilder interface {
	Rebuild(
		ctx context.Context,
		now time.Time,
		baseWorkflowIdentifier definition.WorkflowKey,
		baseBranchToken []byte,
		baseLastEventID int64,
		baseLastEventVersion *int64,
		targetWorkflowIdentifier definition.WorkflowKey,
		targetBranchToken []byte,
		requestID string,
	) (workflow.MutableState, int64, error)
}

type StateRebuilderImpl 

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

func NewStateRebuilder 

func NewStateRebuilder(
	shard shard.Context,
	logger log.Logger,
) *StateRebuilderImpl

func (*StateRebuilderImpl) Rebuild 

func (r *StateRebuilderImpl) Rebuild(
	ctx context.Context,
	now time.Time,
	baseWorkflowIdentifier definition.WorkflowKey,
	baseBranchToken []byte,
	baseLastEventID int64,
	baseLastEventVersion *int64,
	targetWorkflowIdentifier definition.WorkflowKey,
	targetBranchToken []byte,
	requestID string,
) (workflow.MutableState, int64, error)

type Workflow 

type Workflow interface {
	GetContext() workflow.Context
	GetMutableState() workflow.MutableState
	GetReleaseFn() wcache.ReleaseCacheFunc
	GetVectorClock() (int64, int64, error)
	LastWriteByLocalCluster() (bool, error)

	HappensAfter(that Workflow) (bool, error)
	Revive() error
	SuppressBy(incomingWorkflow Workflow) (workflow.TransactionPolicy, error)
	FlushBufferedEvents() error
}

type WorkflowImpl 

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

func NewWorkflow 

func NewWorkflow(
	ctx context.Context,
	namespaceRegistry namespace.Registry,
	clusterMetadata cluster.Metadata,
	context workflow.Context,
	mutableState workflow.MutableState,
	releaseFn wcache.ReleaseCacheFunc,
) *WorkflowImpl

func (*WorkflowImpl) FlushBufferedEvents 

func (r *WorkflowImpl) FlushBufferedEvents() error

func (*WorkflowImpl) GetContext 

func (r *WorkflowImpl) GetContext() workflow.Context

func (*WorkflowImpl) GetMutableState 

func (r *WorkflowImpl) GetMutableState() workflow.MutableState

func (*WorkflowImpl) GetReleaseFn 

func (r *WorkflowImpl) GetReleaseFn() wcache.ReleaseCacheFunc

func (*WorkflowImpl) GetVectorClock 

func (r *WorkflowImpl) GetVectorClock() (int64, int64, error)

func (*WorkflowImpl) HappensAfter 

func (r *WorkflowImpl) HappensAfter(
	that Workflow,
) (bool, error)

func (*WorkflowImpl) LastWriteByLocalCluster added in v1.21.0 

func (r *WorkflowImpl) LastWriteByLocalCluster() (bool, error)

func (*WorkflowImpl) Revive 

func (r *WorkflowImpl) Revive() error

func (*WorkflowImpl) SuppressBy 

func (r *WorkflowImpl) SuppressBy(
	incomingWorkflow Workflow,
) (workflow.TransactionPolicy, error)

type WorkflowResetter 

type WorkflowResetter interface {
	ResetWorkflow(
		ctx context.Context,
		namespaceID namespace.ID,
		workflowID string,
		baseRunID string,
		baseBranchToken []byte,
		baseRebuildLastEventID int64,
		baseRebuildLastEventVersion int64,
		baseNextEventID int64,
		resetRunID string,
		resetRequestID string,
		currentWorkflow Workflow,
		resetReason string,
		additionalReapplyEvents []*historypb.HistoryEvent,
		resetReapplyType enumspb.ResetReapplyType,
	) error
}

type WorkflowStateReplicator added in v1.22.0 

type WorkflowStateReplicator interface {
	SyncWorkflowState(
		ctx context.Context,
		request *historyservice.ReplicateWorkflowStateRequest,
	) error
}

type WorkflowStateReplicatorImpl added in v1.22.0 

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

func NewWorkflowStateReplicator added in v1.22.0 

func NewWorkflowStateReplicator(
	shard shard.Context,
	workflowCache wcache.Cache,
	eventsReapplier EventsReapplier,
	eventSerializer serialization.Serializer,
	logger log.Logger,
) *WorkflowStateReplicatorImpl

func (*WorkflowStateReplicatorImpl) SyncWorkflowState added in v1.22.0 

func (r *WorkflowStateReplicatorImpl) SyncWorkflowState(
	ctx context.Context,
	request *historyservice.ReplicateWorkflowStateRequest,
) (retError error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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