ndc

package
v1.21.2 Latest Latest
Warning

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

Go to latest
Published: Jul 14, 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.

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 ActivityReplicator

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

type ActivityReplicatorImpl

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

func NewActivityReplicator

func NewActivityReplicator(
	shard shard.Context,
	workflowCache wcache.Cache,
	logger log.Logger,
) *ActivityReplicatorImpl

func (*ActivityReplicatorImpl) SyncActivity

func (r *ActivityReplicatorImpl) SyncActivity(
	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
	ApplyWorkflowState(
		ctx context.Context,
		request *historyservice.ReplicateWorkflowStateRequest,
	) error
}

type HistoryReplicatorImpl

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

func NewHistoryReplicator

func NewHistoryReplicator(
	shard shard.Context,
	workflowCache wcache.Cache,
	eventsReapplier EventsReapplier,
	logger log.Logger,
	eventSerializer serialization.Serializer,
) *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)

func (*HistoryReplicatorImpl) ApplyWorkflowState

func (r *HistoryReplicatorImpl) ApplyWorkflowState(
	ctx context.Context,
	request *historyservice.ReplicateWorkflowStateRequest,
) (retError error)

type MockActivityReplicator

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

MockActivityReplicator is a mock of ActivityReplicator interface.

func NewMockActivityReplicator

func NewMockActivityReplicator(ctrl *gomock.Controller) *MockActivityReplicator

NewMockActivityReplicator creates a new mock instance.

func (*MockActivityReplicator) EXPECT

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

func (*MockActivityReplicator) SyncActivity

SyncActivity mocks base method.

type MockActivityReplicatorMockRecorder

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

MockActivityReplicatorMockRecorder is the mock recorder for MockActivityReplicator.

func (*MockActivityReplicatorMockRecorder) SyncActivity

func (mr *MockActivityReplicatorMockRecorder) SyncActivity(ctx, request interface{}) *gomock.Call

SyncActivity indicates an expected call of SyncActivity.

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

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

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

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

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

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

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

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

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL