api

Sep 25, 2024

retracted

Changes in this version

+ type MockWorkflowConsistencyChecker struct

+ func NewMockWorkflowConsistencyChecker(ctrl *gomock.Controller) *MockWorkflowConsistencyChecker

+ func (m *MockWorkflowConsistencyChecker) EXPECT() *MockWorkflowConsistencyCheckerMockRecorder

+ func (m *MockWorkflowConsistencyChecker) GetCurrentRunID(ctx context.Context, namespaceID, workflowID string, ...) (string, error)

+ func (m *MockWorkflowConsistencyChecker) GetWorkflowCache() cache.Cache

+ func (m *MockWorkflowConsistencyChecker) GetWorkflowLease(ctx context.Context, reqClock *clock.VectorClock, ...) (WorkflowLease, error)

+ func (m *MockWorkflowConsistencyChecker) GetWorkflowLeaseWithConsistencyCheck(ctx context.Context, reqClock *clock.VectorClock, ...) (WorkflowLease, error)

+ type MockWorkflowConsistencyCheckerMockRecorder struct

+ func (mr *MockWorkflowConsistencyCheckerMockRecorder) GetCurrentRunID(ctx, namespaceID, workflowID, lockPriority any) *gomock.Call

+ func (mr *MockWorkflowConsistencyCheckerMockRecorder) GetWorkflowCache() *gomock.Call

+ func (mr *MockWorkflowConsistencyCheckerMockRecorder) GetWorkflowLease(ctx, reqClock, workflowKey, lockPriority any) *gomock.Call

+ func (mr *MockWorkflowConsistencyCheckerMockRecorder) GetWorkflowLeaseWithConsistencyCheck(ctx, reqClock, consistencyPredicate, workflowKey, lockPriority any) *gomock.Call

Sep 6, 2024

Changes in this version

+ func GetAndUpdateWorkflowWithConsistencyCheck(ctx context.Context, reqClock *clockspb.VectorClock, ...) (retError error)

type WorkflowConsistencyChecker

+ GetWorkflowLeaseWithConsistencyCheck func(ctx context.Context, reqClock *clockspb.VectorClock, ...) (WorkflowLease, error)

type WorkflowConsistencyCheckerImpl

+ func (c *WorkflowConsistencyCheckerImpl) GetWorkflowLeaseWithConsistencyCheck(ctx context.Context, reqClock *clockspb.VectorClock, ...) (WorkflowLease, error)

May 31, 2024

Changes in this version

+ var ErrUseCurrentExecution = errors.New("ErrUseCurrentExecution")

+ var UpdateWorkflowTerminate = &UpdateWorkflowAction

+ func GeneratePaginationTokenV2Request(request *historyservice.GetWorkflowExecutionRawHistoryV2Request, ...) *tokenspb.RawHistoryContinuation

+ func MigrateWorkflowIdReusePolicyForRunningWorkflow(wfIDReusePolicy *enumspb.WorkflowIdReusePolicy, ...)

+ func ValidatePaginationTokenV2Request(request *historyservice.GetWorkflowExecutionRawHistoryV2Request, ...) error

type UpdateWorkflowAction

+ AbortUpdates bool

type UpdateWorkflowActionFunc

+ func ResolveDuplicateWorkflowID(workflowID, newRunID, currentRunID string, ...) (UpdateWorkflowActionFunc, error)

+ type VersionedRunID struct

+ LastWriteVersion int64

+ RunID string

type WorkflowConsistencyChecker

+ GetWorkflowLease func(ctx context.Context, reqClock *clockspb.VectorClock, ...) (WorkflowLease, error)

type WorkflowConsistencyCheckerImpl

+ func (c *WorkflowConsistencyCheckerImpl) GetWorkflowLease(ctx context.Context, reqClock *clockspb.VectorClock, ...) (WorkflowLease, error)

+ type WorkflowLease interface

+ GetContext func() workflow.Context

+ GetMutableState func() workflow.MutableState

+ GetReleaseFn func() wcache.ReleaseCacheFunc

+ func NewWorkflowLease(context workflow.Context, releaseFn wcache.ReleaseCacheFunc, ...) WorkflowLease

Mar 22, 2024

Changes in this version

+ func DeserializeHistoryToken(bytes []byte) (*tokenspb.HistoryContinuation, error)

+ func DeserializeRawHistoryToken(bytes []byte) (*tokenspb.RawHistoryContinuation, error)

+ func GeneratePaginationToken(request *historyservice.GetWorkflowExecutionRawHistoryV2Request, ...) *tokenspb.RawHistoryContinuation

+ func GetHistory(ctx context.Context, shard shard.Context, namespaceID namespace.ID, ...) (*historypb.History, []byte, error)

+ func GetHistoryReverse(ctx context.Context, shard shard.Context, namespaceID namespace.ID, ...) (*historypb.History, []byte, int64, error)

+ func GetRawHistory(ctx context.Context, shard shard.Context, namespaceID namespace.ID, ...) ([]*commonpb.DataBlob, []byte, error)

+ func GetTaskCategory(categoryID int, registry tasks.TaskCategoryRegistry) (tasks.Category, error)

+ func ProcessOutgoingSearchAttributes(shard shard.Context, events []*historypb.HistoryEvent, ...) error

+ func SerializeHistoryToken(token *tokenspb.HistoryContinuation) ([]byte, error)

+ func SerializeRawHistoryToken(token *tokenspb.RawHistoryContinuation) ([]byte, error)

+ func TrimHistoryNode(ctx context.Context, shardContext shard.Context, ...)

+ func ValidatePaginationToken(request *historyservice.GetWorkflowExecutionRawHistoryV2Request, ...) error

Feb 29, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 2, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 12, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 7, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 30, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 22, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 3, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 6, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 5, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 21, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 8, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 24, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type WorkflowContext

+ GetUpdateRegistry func(context.Context) update.Registry

type WorkflowContextImpl

+ func (w *WorkflowContextImpl) GetUpdateRegistry(ctx context.Context) update.Registry

Jul 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 15, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 29, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 13, 2023 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 1, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ func GetMutableState(ctx context.Context, workflowKey definition.WorkflowKey, ...) (_ *historyservice.GetMutableStateResponse, retError error)

+ func GetOrPollMutableState(ctx context.Context, request *historyservice.GetMutableStateRequest, ...) (*historyservice.GetMutableStateResponse, error)

+ func IsHistoryEventOnCurrentBranch(mutableState workflow.MutableState, eventID int64, eventVersion int64) (bool, error)

+ func MutableStateToGetResponse(mutableState workflow.MutableState) (*historyservice.GetMutableStateResponse, error)

+ func ValidateReplicationConfig(clusterMetadata cluster.Metadata) error

type WorkflowConsistencyChecker

+ GetWorkflowCache func() workflow.Cache

type WorkflowConsistencyCheckerImpl

+ func (c *WorkflowConsistencyCheckerImpl) GetWorkflowCache() workflow.Cache

Nov 15, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 18, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ func GetActiveNamespace(shard shard.Context, namespaceUUID namespace.ID) (*namespace.Namespace, error)

+ func GetActivityScheduledEventID(activityID string, mutableState workflow.MutableState) (int64, error)

+ func GetAndUpdateWorkflowWithNew(ctx context.Context, reqClock *clockspb.VectorClock, ...) (retError error)

+ func OverrideStartWorkflowExecutionRequest(request *workflowservice.StartWorkflowExecutionRequest, metricsScope int, ...)

+ func SetActivityTaskRunID(ctx context.Context, token *tokenspb.Task, ...) error

+ func ValidateNamespaceUUID(namespaceUUID namespace.ID) error

+ func ValidateStartWorkflowExecutionRequest(ctx context.Context, request *workflowservice.StartWorkflowExecutionRequest, ...) error

Sep 14, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 30, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ func IsRetryableError(err error) bool

Aug 2, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ var UpdateWorkflowWithNewWorkflowTask = &UpdateWorkflowAction

+ var UpdateWorkflowWithoutWorkflowTask = &UpdateWorkflowAction

+ func BypassMutableStateConsistencyPredicate(mutableState workflow.MutableState) bool

+ func CreateMutableState(shard shard.Context, namespaceEntry *namespace.Namespace, runID string) (workflow.MutableState, error)

+ func FailMutableStateConsistencyPredicate(mutableState workflow.MutableState) bool

+ func GenerateFirstWorkflowTask(mutableState workflow.MutableState, ...) error

+ func NewWorkflowVersionCheck(shard shard.Context, prevLastWriteVersion int64, ...) error

+ func UpdateWorkflowWithNew(shard shard.Context, ctx context.Context, workflowContext WorkflowContext, ...) (retError error)

+ func ValidateSignal(ctx context.Context, shard shard.Context, mutableState workflow.MutableState, ...) error

+ func ValidateStart(ctx context.Context, shard shard.Context, namespaceEntry *namespace.Namespace, ...) error

+ type CreateWorkflowCASPredicate struct

+ LastWriteVersion int64

+ RunID string

+ type MutableStateConsistencyPredicate func(mutableState workflow.MutableState) bool

+ func HistoryEventConsistencyPredicate(eventID int64, eventVersion int64) MutableStateConsistencyPredicate

+ type UpdateWorkflowAction struct

+ CreateWorkflowTask bool

+ Noop bool

+ type UpdateWorkflowActionFunc func(WorkflowContext) (*UpdateWorkflowAction, error)

+ func ApplyWorkflowIDReusePolicy(prevStartRequestID, prevRunID string, ...) (UpdateWorkflowActionFunc, error)

+ type WorkflowConsistencyChecker interface

+ GetCurrentRunID func(ctx context.Context, namespaceID string, workflowID string) (string, error)

+ GetWorkflowContext func(ctx context.Context, reqClock *clockspb.VectorClock, ...) (WorkflowContext, error)

+ type WorkflowConsistencyCheckerImpl struct

+ func NewWorkflowConsistencyChecker(shardContext shard.Context, workflowCache workflow.Cache) *WorkflowConsistencyCheckerImpl

+ func (c *WorkflowConsistencyCheckerImpl) GetCurrentRunID(ctx context.Context, namespaceID string, workflowID string) (string, error)

+ func (c *WorkflowConsistencyCheckerImpl) GetWorkflowContext(ctx context.Context, reqClock *clockspb.VectorClock, ...) (WorkflowContext, error)

+ type WorkflowContext interface

+ GetContext func() workflow.Context

+ GetMutableState func() workflow.MutableState

+ GetNamespaceEntry func() *namespace.Namespace

+ GetNamespaceID func() namespace.ID

+ GetReleaseFn func() workflow.ReleaseCacheFunc

+ GetRunID func() string

+ GetWorkflowID func() string

+ GetWorkflowKey func() definition.WorkflowKey

+ ReloadMutableState func(context.Context) (workflow.MutableState, error)

+ func NewWorkflowWithSignal(shard shard.Context, namespaceEntry *namespace.Namespace, workflowID string, ...) (WorkflowContext, error)

+ type WorkflowContextImpl struct

+ func NewWorkflowContext(context workflow.Context, releaseFn workflow.ReleaseCacheFunc, ...) *WorkflowContextImpl

+ func (w *WorkflowContextImpl) GetContext() workflow.Context

+ func (w *WorkflowContextImpl) GetMutableState() workflow.MutableState

+ func (w *WorkflowContextImpl) GetNamespaceEntry() *namespace.Namespace

+ func (w *WorkflowContextImpl) GetNamespaceID() namespace.ID

+ func (w *WorkflowContextImpl) GetReleaseFn() workflow.ReleaseCacheFunc

+ func (w *WorkflowContextImpl) GetRunID() string

+ func (w *WorkflowContextImpl) GetWorkflowID() string

+ func (w *WorkflowContextImpl) GetWorkflowKey() definition.WorkflowKey

+ func (w *WorkflowContextImpl) ReloadMutableState(ctx context.Context) (workflow.MutableState, error)