persistence

Dec 23, 2024

Changes in this version

type XDCCacheValue

+ NextEventID int64

Sep 25, 2024

retracted

Changes in this version

+ var ErrPersistenceNamespaceShardLimitExceeded = &serviceerror.ResourceExhausted

+ var ErrPersistenceSystemLimitExceeded = &serviceerror.ResourceExhausted

Sep 6, 2024

Changes in this version

+ const ErrMsgFailedToParseCategoryID

+ var ErrInvalidQueueName = errors.New("invalid queue name, expected 4 fields")

+ var ErrNegativeListNexusEndpointsPageSize = &InvalidPersistenceRequestError

+ var ErrNexusEndpointVersionConflict = serviceerror.NewFailedPrecondition("nexus endpoint version mismatch")

+ func GetHistoryTaskQueueCategoryID(queueName string) (int, error)

+ type CreateOrUpdateNexusEndpointRequest struct

+ Entry *persistencespb.NexusEndpointEntry

+ LastKnownTableVersion int64

+ type CreateOrUpdateNexusEndpointResponse struct

+ Version int64

type CurrentWorkflowConditionFailedError

+ StartTime *time.Time

+ type DLQMetricsEmitter struct

+ func NewDLQMetricsEmitter(metricsHandler metrics.Handler, logger log.Logger, ...) *DLQMetricsEmitter

+ func (s *DLQMetricsEmitter) Start()

+ func (s *DLQMetricsEmitter) Stop()

+ type DataStoreFactory interface

+ Close func()

+ NewClusterMetadataStore func() (ClusterMetadataStore, error)

+ NewExecutionStore func() (ExecutionStore, error)

+ NewMetadataStore func() (MetadataStore, error)

+ NewNexusEndpointStore func() (NexusEndpointStore, error)

+ NewQueue func(queueType QueueType) (Queue, error)

+ NewQueueV2 func() (QueueV2, error)

+ NewShardStore func() (ShardStore, error)

+ NewTaskStore func() (TaskStore, error)

+ type DeleteNexusEndpointRequest struct

+ ID string

+ LastKnownTableVersion int64

type ForkHistoryBranchRequest

+ NewRunID string

+ type GetNexusEndpointRequest struct

+ ID string

type HistoryTaskQueueManagerImpl

+ func (m HistoryTaskQueueManagerImpl) Close()

+ type InternalCreateOrUpdateNexusEndpointRequest struct

+ Endpoint InternalNexusEndpoint

+ LastKnownTableVersion int64

type InternalForkHistoryBranchRequest

+ NewBranchToken []byte

+ type InternalListNexusEndpointsResponse struct

+ Endpoints []InternalNexusEndpoint

+ NextPageToken []byte

+ TableVersion int64

+ type InternalNexusEndpoint struct

+ Data *commonpb.DataBlob

+ ID string

+ Version int64

+ type ListNexusEndpointsRequest struct

+ LastKnownTableVersion int64

+ NextPageToken []byte

+ PageSize int

+ type ListNexusEndpointsResponse struct

+ Entries []*persistencespb.NexusEndpointEntry

+ NextPageToken []byte

+ TableVersion int64

type MockHistoryTaskQueueManager

+ func (m *MockHistoryTaskQueueManager) Close()

type MockHistoryTaskQueueManagerMockRecorder

+ func (mr *MockHistoryTaskQueueManagerMockRecorder) Close() *gomock.Call

type MockNamespaceReplicationQueue

+ func (m *MockNamespaceReplicationQueue) Close()

+ func (m *MockNamespaceReplicationQueue) DeleteMessagesBefore(ctx context.Context, exclusiveMessageID int64) error

type MockNamespaceReplicationQueueMockRecorder

+ func (mr *MockNamespaceReplicationQueueMockRecorder) Close() *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) DeleteMessagesBefore(ctx, exclusiveMessageID interface{}) *gomock.Call

+ type MockNexusEndpointManager struct

+ func NewMockNexusEndpointManager(ctrl *gomock.Controller) *MockNexusEndpointManager

+ func (m *MockNexusEndpointManager) Close()

+ func (m *MockNexusEndpointManager) CreateOrUpdateNexusEndpoint(ctx context.Context, request *CreateOrUpdateNexusEndpointRequest) (*CreateOrUpdateNexusEndpointResponse, error)

+ func (m *MockNexusEndpointManager) DeleteNexusEndpoint(ctx context.Context, request *DeleteNexusEndpointRequest) error

+ func (m *MockNexusEndpointManager) EXPECT() *MockNexusEndpointManagerMockRecorder

+ func (m *MockNexusEndpointManager) GetName() string

+ func (m *MockNexusEndpointManager) GetNexusEndpoint(ctx context.Context, request *GetNexusEndpointRequest) (*v1.NexusEndpointEntry, error)

+ func (m *MockNexusEndpointManager) ListNexusEndpoints(ctx context.Context, request *ListNexusEndpointsRequest) (*ListNexusEndpointsResponse, error)

+ type MockNexusEndpointManagerMockRecorder struct

+ func (mr *MockNexusEndpointManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockNexusEndpointManagerMockRecorder) CreateOrUpdateNexusEndpoint(ctx, request interface{}) *gomock.Call

+ func (mr *MockNexusEndpointManagerMockRecorder) DeleteNexusEndpoint(ctx, request interface{}) *gomock.Call

+ func (mr *MockNexusEndpointManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockNexusEndpointManagerMockRecorder) GetNexusEndpoint(ctx, request interface{}) *gomock.Call

+ func (mr *MockNexusEndpointManagerMockRecorder) ListNexusEndpoints(ctx, request interface{}) *gomock.Call

type NamespaceReplicationQueue

+ DeleteMessagesBefore func(ctx context.Context, exclusiveMessageID int64) error

+ type NexusEndpointManager interface

+ CreateOrUpdateNexusEndpoint func(ctx context.Context, request *CreateOrUpdateNexusEndpointRequest) (*CreateOrUpdateNexusEndpointResponse, error)

+ DeleteNexusEndpoint func(ctx context.Context, request *DeleteNexusEndpointRequest) error

+ GetName func() string

+ GetNexusEndpoint func(ctx context.Context, request *GetNexusEndpointRequest) (*persistencespb.NexusEndpointEntry, error)

+ ListNexusEndpoints func(ctx context.Context, request *ListNexusEndpointsRequest) (*ListNexusEndpointsResponse, error)

+ func NewNexusEndpointManager(persistence NexusEndpointStore, serializer serialization.Serializer, ...) NexusEndpointManager

+ func NewNexusEndpointPersistenceMetricsClient(persistence NexusEndpointManager, metricsHandler metrics.Handler, ...) NexusEndpointManager

+ func NewNexusEndpointPersistenceRateLimitedClient(persistence NexusEndpointManager, systemRateLimiter quotas.RequestRateLimiter, ...) NexusEndpointManager

+ func NewNexusEndpointPersistenceRetryableClient(persistence NexusEndpointManager, policy backoff.RetryPolicy, ...) NexusEndpointManager

+ type NexusEndpointStore interface

+ CreateOrUpdateNexusEndpoint func(ctx context.Context, request *InternalCreateOrUpdateNexusEndpointRequest) error

+ DeleteNexusEndpoint func(ctx context.Context, request *DeleteNexusEndpointRequest) error

+ GetName func() string

+ GetNexusEndpoint func(ctx context.Context, request *GetNexusEndpointRequest) (*InternalNexusEndpoint, error)

+ ListNexusEndpoints func(ctx context.Context, request *ListNexusEndpointsRequest) (*InternalListNexusEndpointsResponse, error)

type XDCCacheValue

+ EventBlobs []*commonpb.DataBlob

May 31, 2024

Changes in this version

+ var ErrNegativeListNexusIncomingServicesPageSize = &InvalidPersistenceRequestError

+ var ErrNexusIncomingServiceNotFound = &ConditionFailedError

+ var ErrNexusIncomingServiceVersionConflict = &ConditionFailedError

+ var ErrNexusTableVersionConflict = &ConditionFailedError

+ var ErrPersistenceNamespaceLimitExceeded = &serviceerror.ResourceExhausted

+ func GetHistoryTaskQueueName(categoryID int, sourceCluster string, targetCluster string) string

+ type CreateOrUpdateNexusIncomingServiceRequest struct

+ Entry *persistencespb.NexusIncomingServiceEntry

+ LastKnownTableVersion int64

+ type CreateOrUpdateNexusIncomingServiceResponse struct

+ Version int64

+ type DeleteNexusIncomingServiceRequest struct

+ LastKnownTableVersion int64

+ ServiceID string

type ExecutionStore

+ GetHistoryTreeContainingBranch func(ctx context.Context, request *InternalGetHistoryTreeContainingBranchRequest) (*InternalGetHistoryTreeContainingBranchResponse, error)

+ type GetNexusIncomingServiceRequest struct

+ ServiceID string

+ type InternalCreateOrUpdateNexusIncomingServiceRequest struct

+ LastKnownTableVersion int64

+ Service InternalNexusIncomingService

+ type InternalGetHistoryTreeContainingBranchRequest struct

+ BranchToken []byte

+ ShardID int32

+ type InternalGetHistoryTreeContainingBranchResponse struct

+ TreeInfos []*commonpb.DataBlob

+ type InternalListNexusIncomingServicesResponse struct

+ NextPageToken []byte

+ Services []InternalNexusIncomingService

+ TableVersion int64

+ type InternalNexusIncomingService struct

+ Data *commonpb.DataBlob

+ ServiceID string

+ Version int64

+ type ListNexusIncomingServicesRequest struct

+ LastKnownTableVersion int64

+ NextPageToken []byte

+ PageSize int

+ type ListNexusIncomingServicesResponse struct

+ Entries []*persistencespb.NexusIncomingServiceEntry

+ NextPageToken []byte

+ TableVersion int64

+ type MockNexusIncomingServiceManager struct

+ func NewMockNexusIncomingServiceManager(ctrl *gomock.Controller) *MockNexusIncomingServiceManager

+ func (m *MockNexusIncomingServiceManager) Close()

+ func (m *MockNexusIncomingServiceManager) CreateOrUpdateNexusIncomingService(ctx context.Context, request *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)

+ func (m *MockNexusIncomingServiceManager) DeleteNexusIncomingService(ctx context.Context, request *DeleteNexusIncomingServiceRequest) error

+ func (m *MockNexusIncomingServiceManager) EXPECT() *MockNexusIncomingServiceManagerMockRecorder

+ func (m *MockNexusIncomingServiceManager) GetName() string

+ func (m *MockNexusIncomingServiceManager) GetNexusIncomingService(ctx context.Context, request *GetNexusIncomingServiceRequest) (*v1.NexusIncomingServiceEntry, error)

+ func (m *MockNexusIncomingServiceManager) ListNexusIncomingServices(ctx context.Context, request *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, error)

+ type MockNexusIncomingServiceManagerMockRecorder struct

+ func (mr *MockNexusIncomingServiceManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockNexusIncomingServiceManagerMockRecorder) CreateOrUpdateNexusIncomingService(ctx, request interface{}) *gomock.Call

+ func (mr *MockNexusIncomingServiceManagerMockRecorder) DeleteNexusIncomingService(ctx, request interface{}) *gomock.Call

+ func (mr *MockNexusIncomingServiceManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockNexusIncomingServiceManagerMockRecorder) GetNexusIncomingService(ctx, request interface{}) *gomock.Call

+ func (mr *MockNexusIncomingServiceManagerMockRecorder) ListNexusIncomingServices(ctx, request interface{}) *gomock.Call

+ type NexusIncomingServiceManager interface

+ CreateOrUpdateNexusIncomingService func(ctx context.Context, request *CreateOrUpdateNexusIncomingServiceRequest) (*CreateOrUpdateNexusIncomingServiceResponse, error)

+ DeleteNexusIncomingService func(ctx context.Context, request *DeleteNexusIncomingServiceRequest) error

+ GetName func() string

+ GetNexusIncomingService func(ctx context.Context, request *GetNexusIncomingServiceRequest) (*persistencespb.NexusIncomingServiceEntry, error)

+ ListNexusIncomingServices func(ctx context.Context, request *ListNexusIncomingServicesRequest) (*ListNexusIncomingServicesResponse, error)

+ func NewNexusIncomingServiceManager(persistence NexusIncomingServiceStore, serializer serialization.Serializer, ...) NexusIncomingServiceManager

+ func NewNexusIncomingServicePersistenceMetricsClient(persistence NexusIncomingServiceManager, metricsHandler metrics.Handler, ...) NexusIncomingServiceManager

+ func NewNexusIncomingServicePersistenceRateLimitedClient(persistence NexusIncomingServiceManager, ...) NexusIncomingServiceManager

+ func NewNexusIncomingServicePersistenceRetryableClient(persistence NexusIncomingServiceManager, policy backoff.RetryPolicy, ...) NexusIncomingServiceManager

+ type NexusIncomingServiceStore interface

+ CreateOrUpdateNexusIncomingService func(ctx context.Context, ...) error

+ DeleteNexusIncomingService func(ctx context.Context, request *DeleteNexusIncomingServiceRequest) error

+ GetName func() string

+ GetNexusIncomingService func(ctx context.Context, request *GetNexusIncomingServiceRequest) (*InternalNexusIncomingService, error)

+ ListNexusIncomingServices func(ctx context.Context, request *ListNexusIncomingServicesRequest) (*InternalListNexusIncomingServicesResponse, error)

Mar 22, 2024

Changes in this version

+ const ErrMsgDeserializeHistoryTask

+ const ErrMsgDeserializeRawHistoryTask

+ const ErrMsgSerializeTaskToEnqueue

+ var ErrEnqueueTaskRequestTaskIsNil = errors.New("enqueue task request task is nil")

+ var ErrHistoryTaskBlobIsNil = errors.New("history task from queue has nil blob")

+ var ErrInvalidListQueuesNextPageToken = &InvalidPersistenceRequestError

+ var ErrInvalidQueueRangeDeleteMaxMessageID = &InvalidPersistenceRequestError

+ var ErrInvalidReadQueueMessagesNextPageToken = &InvalidPersistenceRequestError

+ var ErrNegativeListQueuesOffset = &InvalidPersistenceRequestError

+ var ErrNonPositiveListQueuesPageSize = &InvalidPersistenceRequestError

+ var ErrNonPositiveReadQueueMessagesPageSize = &InvalidPersistenceRequestError

+ var ErrQueueAlreadyExists = errors.New("queue already exists")

+ var ErrReadTasksNonPositivePageSize = errors.New("page size to read history tasks must be positive")

+ var ErrShardIDInvalid = errors.New("shard ID must be greater than 0")

+ func GetMinMessageIDToReadForQueueV2(queueType QueueV2Type, queueName string, nextPageToken []byte, ...) (int64, error)

+ func GetNextPageTokenForListQueues(queueNumber int64) []byte

+ func GetNextPageTokenForReadMessages(result []QueueV2Message) []byte

+ func GetOffsetForListQueues(nextPageToken []byte) (int64, error)

+ func GetPartitionForQueueV2(queueType QueueV2Type, queueName string, queue *persistencespb.Queue) (*persistencespb.QueuePartition, error)

+ func NewQueueNotFoundError(queueType QueueV2Type, queueName string) error

+ type CreateQueueRequest struct

+ QueueKey QueueKey

+ type CreateQueueResponse struct

+ type DeleteRange struct

+ MessagesToDelete int64

+ NewMinMessageID int64

+ func GetDeleteRange(request DeleteRequest) (DeleteRange, bool)

+ type DeleteRequest struct

+ ExistingMessageRange InclusiveMessageRange

+ LastIDToDeleteInclusive int64

+ type DeleteTasksRequest struct

+ InclusiveMaxMessageMetadata MessageMetadata

+ QueueKey QueueKey

+ type DeleteTasksResponse struct

+ MessagesDeleted int64

+ type EnqueueTaskRequest struct

+ QueueType QueueV2Type

+ SourceCluster string

+ SourceShardID int

+ TargetCluster string

+ Task tasks.Task

+ type EnqueueTaskResponse struct

+ Metadata MessageMetadata

type GetHistoryTreeResponse

+ BranchInfos []*persistencespb.HistoryBranch

type HistoryBranchDetail

+ BranchInfo *persistencespb.HistoryBranch

+ type HistoryTask struct

+ MessageMetadata MessageMetadata

+ Task tasks.Task

+ type HistoryTaskQueueManager interface

+ CreateQueue func(ctx context.Context, request *CreateQueueRequest) (*CreateQueueResponse, error)

+ DeleteTasks func(ctx context.Context, request *DeleteTasksRequest) (*DeleteTasksResponse, error)

+ EnqueueTask func(ctx context.Context, request *EnqueueTaskRequest) (*EnqueueTaskResponse, error)

+ ListQueues func(ctx context.Context, request *ListQueuesRequest) (*ListQueuesResponse, error)

+ ReadRawTasks func(ctx context.Context, request *ReadRawTasksRequest) (*ReadRawTasksResponse, error)

+ ReadTasks func(ctx context.Context, request *ReadTasksRequest) (*ReadTasksResponse, error)

+ type HistoryTaskQueueManagerImpl struct

+ func NewHistoryTaskQueueManager(queue QueueV2) *HistoryTaskQueueManagerImpl

+ func (m *HistoryTaskQueueManagerImpl) CreateQueue(ctx context.Context, request *CreateQueueRequest) (*CreateQueueResponse, error)

+ func (m *HistoryTaskQueueManagerImpl) DeleteTasks(ctx context.Context, request *DeleteTasksRequest) (*DeleteTasksResponse, error)

+ func (m *HistoryTaskQueueManagerImpl) EnqueueTask(ctx context.Context, request *EnqueueTaskRequest) (*EnqueueTaskResponse, error)

+ func (m *HistoryTaskQueueManagerImpl) ReadRawTasks(ctx context.Context, request *ReadRawTasksRequest) (*ReadRawTasksResponse, error)

+ func (m *HistoryTaskQueueManagerImpl) ReadTasks(ctx context.Context, request *ReadTasksRequest) (*ReadTasksResponse, error)

+ func (m HistoryTaskQueueManagerImpl) ListQueues(ctx context.Context, request *ListQueuesRequest) (*ListQueuesResponse, error)

+ type InclusiveMessageRange struct

+ MaxMessageID int64

+ MinMessageID int64

+ type InternalCreateQueueRequest struct

+ QueueName string

+ QueueType QueueV2Type

+ type InternalCreateQueueResponse struct

+ type InternalEnqueueMessageRequest struct

+ Blob *commonpb.DataBlob

+ QueueName string

+ QueueType QueueV2Type

+ type InternalEnqueueMessageResponse struct

+ Metadata MessageMetadata

type InternalForkHistoryBranchRequest

+ ForkBranchToken []byte

+ type InternalListQueuesRequest struct

+ NextPageToken []byte

+ PageSize int

+ QueueType QueueV2Type

+ type InternalListQueuesResponse struct

+ NextPageToken []byte

+ Queues []QueueInfo

+ type InternalRangeDeleteMessagesRequest struct

+ InclusiveMaxMessageMetadata MessageMetadata

+ QueueName string

+ QueueType QueueV2Type

+ type InternalRangeDeleteMessagesResponse struct

+ MessagesDeleted int64

+ type InternalReadMessagesRequest struct

+ NextPageToken []byte

+ PageSize int

+ QueueName string

+ QueueType QueueV2Type

+ type InternalReadMessagesResponse struct

+ Messages []QueueV2Message

+ NextPageToken []byte

+ type ListQueuesRequest struct

+ NextPageToken []byte

+ PageSize int

+ QueueType QueueV2Type

+ type ListQueuesResponse struct

+ NextPageToken []byte

+ Queues []QueueInfo

+ type MessageMetadata struct

+ ID int64

+ type MockHistoryTaskQueueManager struct

+ func NewMockHistoryTaskQueueManager(ctrl *gomock.Controller) *MockHistoryTaskQueueManager

+ func (m *MockHistoryTaskQueueManager) CreateQueue(ctx context.Context, request *CreateQueueRequest) (*CreateQueueResponse, error)

+ func (m *MockHistoryTaskQueueManager) DeleteTasks(ctx context.Context, request *DeleteTasksRequest) (*DeleteTasksResponse, error)

+ func (m *MockHistoryTaskQueueManager) EXPECT() *MockHistoryTaskQueueManagerMockRecorder

+ func (m *MockHistoryTaskQueueManager) EnqueueTask(ctx context.Context, request *EnqueueTaskRequest) (*EnqueueTaskResponse, error)

+ func (m *MockHistoryTaskQueueManager) ListQueues(ctx context.Context, request *ListQueuesRequest) (*ListQueuesResponse, error)

+ func (m *MockHistoryTaskQueueManager) ReadRawTasks(ctx context.Context, request *ReadRawTasksRequest) (*ReadRawTasksResponse, error)

+ func (m *MockHistoryTaskQueueManager) ReadTasks(ctx context.Context, request *ReadTasksRequest) (*ReadTasksResponse, error)

+ type MockHistoryTaskQueueManagerMockRecorder struct

+ func (mr *MockHistoryTaskQueueManagerMockRecorder) CreateQueue(ctx, request interface{}) *gomock.Call

+ func (mr *MockHistoryTaskQueueManagerMockRecorder) DeleteTasks(ctx, request interface{}) *gomock.Call

+ func (mr *MockHistoryTaskQueueManagerMockRecorder) EnqueueTask(ctx, request interface{}) *gomock.Call

+ func (mr *MockHistoryTaskQueueManagerMockRecorder) ListQueues(ctx, request interface{}) *gomock.Call

+ func (mr *MockHistoryTaskQueueManagerMockRecorder) ReadRawTasks(ctx, request interface{}) *gomock.Call

+ func (mr *MockHistoryTaskQueueManagerMockRecorder) ReadTasks(ctx, request interface{}) *gomock.Call

+ type QueueInfo struct

+ MessageCount int64

+ QueueName string

+ type QueueKey struct

+ Category tasks.Category

+ QueueType QueueV2Type

+ SourceCluster string

+ TargetCluster string

+ func (k QueueKey) GetQueueName() string

+ type QueueV2 interface

+ CreateQueue func(ctx context.Context, request *InternalCreateQueueRequest) (*InternalCreateQueueResponse, error)

+ EnqueueMessage func(ctx context.Context, request *InternalEnqueueMessageRequest) (*InternalEnqueueMessageResponse, error)

+ ListQueues func(ctx context.Context, request *InternalListQueuesRequest) (*InternalListQueuesResponse, error)

+ RangeDeleteMessages func(ctx context.Context, request *InternalRangeDeleteMessagesRequest) (*InternalRangeDeleteMessagesResponse, error)

+ ReadMessages func(ctx context.Context, request *InternalReadMessagesRequest) (*InternalReadMessagesResponse, error)

+ type QueueV2Message struct

+ Data *commonpb.DataBlob

+ MetaData MessageMetadata

+ type QueueV2Type int

+ const FirstQueueMessageID

+ const QueueTypeHistoryDLQ

+ const QueueTypeHistoryNormal

+ const QueueTypeUnspecified

+ type RawHistoryTask struct

+ MessageMetadata MessageMetadata

+ Payload *persistencespb.HistoryTask

+ type ReadRawTasksRequest = ReadTasksRequest

+ type ReadRawTasksResponse struct

+ NextPageToken []byte

+ Tasks []RawHistoryTask

+ type ReadTasksRequest struct

+ NextPageToken []byte

+ PageSize int

+ QueueKey QueueKey

+ type ReadTasksResponse struct

+ NextPageToken []byte

+ Tasks []HistoryTask

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

Changes in this version

+ func CopyBaseWorkflowInfo(baseWorkflowInfo *workflowspb.BaseExecutionInfo) *workflowspb.BaseExecutionInfo

+ func GetXDCCacheValue(executionInfo *persistencepb.WorkflowExecutionInfo, eventID int64, ...) ([]*historyspb.VersionHistoryItem, []byte, *workflowspb.BaseExecutionInfo, ...)

type HealthSignalAggregator

+ Start func()

+ Stop func()

type NamespaceReplicationQueue

+ Start func()

+ Stop func()

+ type XDCCache interface

+ Get func(key XDCCacheKey) (XDCCacheValue, bool)

+ Put func(key XDCCacheKey, value XDCCacheValue)

+ type XDCCacheImpl struct

+ func NewEventsBlobCache(maxBytes int, ttl time.Duration) *XDCCacheImpl

+ func (e *XDCCacheImpl) Get(key XDCCacheKey) (XDCCacheValue, bool)

+ func (e *XDCCacheImpl) Put(key XDCCacheKey, value XDCCacheValue)

+ type XDCCacheKey struct

+ MaxEventID int64

+ MinEventID int64

+ Version int64

+ WorkflowKey definition.WorkflowKey

+ func NewXDCCacheKey(workflowKey definition.WorkflowKey, minEventID int64, maxEventID int64, ...) XDCCacheKey

+ type XDCCacheValue struct

+ BaseWorkflowInfo *workflowspb.BaseExecutionInfo

+ EventBlob *commonpb.DataBlob

+ VersionHistoryItems []*historyspb.VersionHistoryItem

+ func NewXDCCacheValue(baseWorkflowInfo *workflowspb.BaseExecutionInfo, ...) XDCCacheValue

+ func (v XDCCacheValue) CacheSize() int

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

+ const CallerSegmentMissing

+ func NewHistoryBranch(treeID string, branchID *string, ...) ([]byte, error)

+ type CountTaskQueuesByBuildIdRequest struct

+ BuildID string

+ NamespaceID string

type ExecutionManager

+ GetHistoryBranchUtil func() HistoryBranchUtil

+ IsReplicationDLQEmpty func(ctx context.Context, request *GetReplicationTasksFromDLQRequest) (bool, error)

+ RegisterHistoryTaskReader func(ctx context.Context, request *RegisterHistoryTaskReaderRequest) error

+ UnregisterHistoryTaskReader func(ctx context.Context, request *UnregisterHistoryTaskReaderRequest)

+ UpdateHistoryTaskReaderProgress func(ctx context.Context, request *UpdateHistoryTaskReaderProgressRequest)

type ExecutionStore

+ GetHistoryBranchUtil func() HistoryBranchUtil

+ IsReplicationDLQEmpty func(ctx context.Context, request *GetReplicationTasksFromDLQRequest) (bool, error)

+ RegisterHistoryTaskReader func(ctx context.Context, request *RegisterHistoryTaskReaderRequest) error

+ UnregisterHistoryTaskReader func(ctx context.Context, request *UnregisterHistoryTaskReaderRequest)

+ UpdateHistoryTaskReaderProgress func(ctx context.Context, request *UpdateHistoryTaskReaderProgressRequest)

type ForkHistoryBranchRequest

+ NamespaceID string

type GetHistoryTasksRequest

+ ReaderID int64

+ type GetTaskQueueUserDataRequest struct

+ NamespaceID string

+ TaskQueue string

+ type GetTaskQueueUserDataResponse struct

+ UserData *persistencespb.VersionedTaskQueueUserData

+ type GetTaskQueuesByBuildIdRequest struct

+ BuildID string

+ NamespaceID string

+ type HealthSignalAggregator interface

+ AverageLatency func() float64

+ ErrorRatio func() float64

+ Record func(callerSegment int32, latency time.Duration, err error)

+ var NoopHealthSignalAggregator HealthSignalAggregator = newNoopSignalAggregator()

+ type HealthSignalAggregatorImpl struct

+ func NewHealthSignalAggregatorImpl(aggregationEnabled bool, windowSize time.Duration, maxBufferSize int, ...) *HealthSignalAggregatorImpl

+ func (s *HealthSignalAggregatorImpl) AverageLatency() float64

+ func (s *HealthSignalAggregatorImpl) ErrorRatio() float64

+ func (s *HealthSignalAggregatorImpl) Record(callerSegment int32, latency time.Duration, err error)

+ func (s *HealthSignalAggregatorImpl) Start()

+ func (s *HealthSignalAggregatorImpl) Stop()

+ type HistoryBranchUtil interface

+ NewHistoryBranch func(namespaceID string, treeID string, branchID *string, ...) ([]byte, error)

+ ParseHistoryBranchInfo func(branchToken []byte) (*persistencespb.HistoryBranch, error)

+ UpdateHistoryBranchInfo func(branchToken []byte, branchInfo *persistencespb.HistoryBranch) ([]byte, error)

+ type HistoryBranchUtilImpl struct

+ func (u *HistoryBranchUtilImpl) GetHistoryBranchUtil() HistoryBranchUtil

+ func (u *HistoryBranchUtilImpl) NewHistoryBranch(namespaceID string, treeID string, branchID *string, ...) ([]byte, error)

+ func (u *HistoryBranchUtilImpl) ParseHistoryBranchInfo(branchToken []byte) (*persistencespb.HistoryBranch, error)

+ func (u *HistoryBranchUtilImpl) UpdateHistoryBranchInfo(branchToken []byte, branchInfo *persistencespb.HistoryBranch) ([]byte, error)

+ type InternalGetTaskQueueUserDataResponse struct

+ UserData *commonpb.DataBlob

+ Version int64

+ type InternalListTaskQueueUserDataEntriesResponse struct

+ Entries []InternalTaskQueueUserDataEntry

+ NextPageToken []byte

+ type InternalTaskQueueUserDataEntry struct

+ Data *commonpb.DataBlob

+ TaskQueue string

+ Version int64

type InternalUpdateShardRequest

+ Owner string

+ type InternalUpdateTaskQueueUserDataRequest struct

+ BuildIdsAdded []string

+ BuildIdsRemoved []string

+ NamespaceID string

+ TaskQueue string

+ UserData *commonpb.DataBlob

+ Version int64

+ type ListTaskQueueUserDataEntriesRequest struct

+ NamespaceID string

+ NextPageToken []byte

+ PageSize int

+ type ListTaskQueueUserDataEntriesResponse struct

+ Entries []*TaskQueueUserDataEntry

+ NextPageToken []byte

type MockExecutionManager

+ func (m *MockExecutionManager) GetHistoryBranchUtil() HistoryBranchUtil

+ func (m *MockExecutionManager) IsReplicationDLQEmpty(ctx context.Context, request *GetReplicationTasksFromDLQRequest) (bool, error)

+ func (m *MockExecutionManager) RegisterHistoryTaskReader(ctx context.Context, request *RegisterHistoryTaskReaderRequest) error

+ func (m *MockExecutionManager) UnregisterHistoryTaskReader(ctx context.Context, request *UnregisterHistoryTaskReaderRequest)

+ func (m *MockExecutionManager) UpdateHistoryTaskReaderProgress(ctx context.Context, request *UpdateHistoryTaskReaderProgressRequest)

type MockExecutionManagerMockRecorder

+ func (mr *MockExecutionManagerMockRecorder) GetHistoryBranchUtil() *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) IsReplicationDLQEmpty(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RegisterHistoryTaskReader(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) UnregisterHistoryTaskReader(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) UpdateHistoryTaskReaderProgress(ctx, request interface{}) *gomock.Call

+ type MockHistoryBranchUtil struct

+ func NewMockHistoryBranchUtil(ctrl *gomock.Controller) *MockHistoryBranchUtil

+ func (m *MockHistoryBranchUtil) EXPECT() *MockHistoryBranchUtilMockRecorder

+ func (m *MockHistoryBranchUtil) NewHistoryBranch(namespaceID, treeID string, branchID *string, ...) ([]byte, error)

+ func (m *MockHistoryBranchUtil) ParseHistoryBranchInfo(branchToken []byte) (*persistence.HistoryBranch, error)

+ func (m *MockHistoryBranchUtil) UpdateHistoryBranchInfo(branchToken []byte, branchInfo *persistence.HistoryBranch) ([]byte, error)

+ type MockHistoryBranchUtilMockRecorder struct

+ func (mr *MockHistoryBranchUtilMockRecorder) NewHistoryBranch(...) *gomock.Call

+ func (mr *MockHistoryBranchUtilMockRecorder) ParseHistoryBranchInfo(branchToken interface{}) *gomock.Call

+ func (mr *MockHistoryBranchUtilMockRecorder) UpdateHistoryBranchInfo(branchToken, branchInfo interface{}) *gomock.Call

type MockTaskManager

+ func (m *MockTaskManager) CountTaskQueuesByBuildId(ctx context.Context, request *CountTaskQueuesByBuildIdRequest) (int, error)

+ func (m *MockTaskManager) GetTaskQueueUserData(ctx context.Context, request *GetTaskQueueUserDataRequest) (*GetTaskQueueUserDataResponse, error)

+ func (m *MockTaskManager) GetTaskQueuesByBuildId(ctx context.Context, request *GetTaskQueuesByBuildIdRequest) ([]string, error)

+ func (m *MockTaskManager) ListTaskQueueUserDataEntries(ctx context.Context, request *ListTaskQueueUserDataEntriesRequest) (*ListTaskQueueUserDataEntriesResponse, error)

+ func (m *MockTaskManager) UpdateTaskQueueUserData(ctx context.Context, request *UpdateTaskQueueUserDataRequest) error

type MockTaskManagerMockRecorder

+ func (mr *MockTaskManagerMockRecorder) CountTaskQueuesByBuildId(ctx, request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) GetTaskQueueUserData(ctx, request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) GetTaskQueuesByBuildId(ctx, request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) ListTaskQueueUserDataEntries(ctx, request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) UpdateTaskQueueUserData(ctx, request interface{}) *gomock.Call

type MutableStateStatistics

+ TotalUpdateCount int64

+ UpdateInfoCount int

+ type RegisterHistoryTaskReaderRequest struct

+ ReaderID int64

+ ShardID int32

+ ShardOwner string

+ TaskCategory tasks.Category

type TaskManager

+ CountTaskQueuesByBuildId func(ctx context.Context, request *CountTaskQueuesByBuildIdRequest) (int, error)

+ GetTaskQueueUserData func(ctx context.Context, request *GetTaskQueueUserDataRequest) (*GetTaskQueueUserDataResponse, error)

+ GetTaskQueuesByBuildId func(ctx context.Context, request *GetTaskQueuesByBuildIdRequest) ([]string, error)

+ ListTaskQueueUserDataEntries func(ctx context.Context, request *ListTaskQueueUserDataEntriesRequest) (*ListTaskQueueUserDataEntriesResponse, error)

+ UpdateTaskQueueUserData func(ctx context.Context, request *UpdateTaskQueueUserDataRequest) error

+ type TaskQueueUserDataEntry struct

+ TaskQueue string

+ UserData *persistencespb.VersionedTaskQueueUserData

type TaskStore

+ CountTaskQueuesByBuildId func(ctx context.Context, request *CountTaskQueuesByBuildIdRequest) (int, error)

+ GetTaskQueueUserData func(ctx context.Context, request *GetTaskQueueUserDataRequest) (*InternalGetTaskQueueUserDataResponse, error)

+ GetTaskQueuesByBuildId func(ctx context.Context, request *GetTaskQueuesByBuildIdRequest) ([]string, error)

+ ListTaskQueueUserDataEntries func(ctx context.Context, request *ListTaskQueueUserDataEntriesRequest) (*InternalListTaskQueueUserDataEntriesResponse, error)

+ UpdateTaskQueueUserData func(ctx context.Context, request *InternalUpdateTaskQueueUserDataRequest) error

+ type UnregisterHistoryTaskReaderRequest RegisterHistoryTaskReaderRequest

+ type UpdateHistoryTaskReaderProgressRequest struct

+ InclusiveMinPendingTaskKey tasks.Key

+ ReaderID int64

+ ShardID int32

+ ShardOwner string

+ TaskCategory tasks.Category

+ type UpdateTaskQueueUserDataRequest struct

+ BuildIdsAdded []string

+ BuildIdsRemoved []string

+ NamespaceID string

+ TaskQueue string

+ UserData *persistencespb.VersionedTaskQueueUserData

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

Changes in this version

type MutableStateStatistics

+ TotalActivityCount int64

+ TotalChildExecutionCount int64

+ TotalRequestCancelExternalCount int64

+ TotalSignalCount int64

+ TotalSignalExternalCount int64

+ TotalUserTimerCount int64

Feb 17, 2023 GO-2024-2689

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

Changes in this version

type ServiceType

+ const InternalFrontend

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

+ const ScheduledTaskMinPrecision

+ func ToHistoryTreeInfo(serializer serialization.Serializer, blob *commonpb.DataBlob) (*persistencespb.HistoryTreeInfo, error)

+ type AppendHistoryTimeoutError struct

+ Msg string

+ func (e *AppendHistoryTimeoutError) Error() string

type GetHistoryTreeResponse

+ BranchTokens [][]byte

type HistoryBranchDetail

+ BranchToken []byte

type NewHistoryBranchRequest

+ Ancestors []*persistencespb.HistoryBranchRange

+ ExecutionTimeout *time.Duration

+ RetentionDuration *time.Duration

+ RunTimeout *time.Duration

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 ConstructHistoryTaskAPI(baseAPI string, taskCategory tasks.Category) string

type NewHistoryBranchRequest

+ BranchID *string

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 IsConflictErr(err error) bool

+ func ParseHistoryBranchToken(branchToken []byte) (*persistencespb.HistoryBranch, error)

+ func UpdateHistoryBranchToken(branchToken []byte, branchInfo *persistencespb.HistoryBranch) ([]byte, error)

type ClusterMetadataManager

+ func NewClusterMetadataPersistenceRetryableClient(persistence ClusterMetadataManager, policy backoff.RetryPolicy, ...) ClusterMetadataManager

type ExecutionManager

+ func NewExecutionPersistenceRetryableClient(persistence ExecutionManager, policy backoff.RetryPolicy, ...) ExecutionManager

+ NewHistoryBranch func(ctx context.Context, request *NewHistoryBranchRequest) (*NewHistoryBranchResponse, error)

+ ParseHistoryBranchInfo func(ctx context.Context, request *ParseHistoryBranchInfoRequest) (*ParseHistoryBranchInfoResponse, error)

+ UpdateHistoryBranchInfo func(ctx context.Context, request *UpdateHistoryBranchInfoRequest) (*UpdateHistoryBranchInfoResponse, error)

type ExecutionStore

+ NewHistoryBranch func(ctx context.Context, request *NewHistoryBranchRequest) (*NewHistoryBranchResponse, error)

+ ParseHistoryBranchInfo func(ctx context.Context, request *ParseHistoryBranchInfoRequest) (*ParseHistoryBranchInfoResponse, error)

+ UpdateHistoryBranchInfo func(ctx context.Context, request *UpdateHistoryBranchInfoRequest) (*UpdateHistoryBranchInfoResponse, error)

type InternalAppendHistoryNodesRequest

+ BranchToken []byte

type InternalDeleteHistoryBranchRequest

+ BranchToken []byte

type InternalDeleteHistoryNodesRequest

+ BranchToken []byte

type InternalForkHistoryBranchRequest

+ BranchToken []byte

type InternalReadHistoryBranchRequest

+ BranchToken []byte

type MetadataManager

+ func NewMetadataPersistenceRetryableClient(persistence MetadataManager, policy backoff.RetryPolicy, ...) MetadataManager

type MockExecutionManager

+ func (m *MockExecutionManager) NewHistoryBranch(ctx context.Context, request *NewHistoryBranchRequest) (*NewHistoryBranchResponse, error)

+ func (m *MockExecutionManager) ParseHistoryBranchInfo(ctx context.Context, request *ParseHistoryBranchInfoRequest) (*ParseHistoryBranchInfoResponse, error)

+ func (m *MockExecutionManager) UpdateHistoryBranchInfo(ctx context.Context, request *UpdateHistoryBranchInfoRequest) (*UpdateHistoryBranchInfoResponse, error)

type MockExecutionManagerMockRecorder

+ func (mr *MockExecutionManagerMockRecorder) NewHistoryBranch(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ParseHistoryBranchInfo(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) UpdateHistoryBranchInfo(ctx, request interface{}) *gomock.Call

+ type NewHistoryBranchRequest struct

+ TreeID string

+ type NewHistoryBranchResponse struct

+ BranchToken []byte

+ type ParseHistoryBranchInfoRequest struct

+ BranchToken []byte

+ type ParseHistoryBranchInfoResponse struct

+ BranchInfo *persistencespb.HistoryBranch

type Queue

+ func NewQueuePersistenceRetryableClient(persistence Queue, policy backoff.RetryPolicy, isRetryable backoff.IsRetryable) Queue

type ShardManager

+ func NewShardPersistenceRetryableClient(persistence ShardManager, policy backoff.RetryPolicy, ...) ShardManager

type TaskManager

+ func NewTaskPersistenceRetryableClient(persistence TaskManager, policy backoff.RetryPolicy, ...) TaskManager

+ type UpdateHistoryBranchInfoRequest struct

+ BranchInfo *persistencespb.HistoryBranch

+ BranchToken []byte

+ type UpdateHistoryBranchInfoResponse struct

+ BranchToken []byte

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

Changes in this version

+ const RateLimitDefaultToken

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

+ type AppendRawHistoryNodesRequest struct

+ BranchToken []byte

+ History *commonpb.DataBlob

+ Info string

+ IsNewBranch bool

+ NodeID int64

+ PrevTransactionID int64

+ ShardID int32

+ TransactionID int64

+ type AssertShardOwnershipRequest struct

+ RangeID int64

+ ShardID int32

type CreateWorkflowMode

+ const CreateWorkflowModeBypassCurrent

+ const CreateWorkflowModeUpdateCurrent

type ExecutionManager

+ AppendRawHistoryNodes func(ctx context.Context, request *AppendRawHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

type MockExecutionManager

+ func (m *MockExecutionManager) AppendRawHistoryNodes(ctx context.Context, request *AppendRawHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

type MockExecutionManagerMockRecorder

+ func (mr *MockExecutionManagerMockRecorder) AppendRawHistoryNodes(ctx, request interface{}) *gomock.Call

type MockShardManager

+ func (m *MockShardManager) AssertShardOwnership(ctx context.Context, request *AssertShardOwnershipRequest) error

type MockShardManagerMockRecorder

+ func (mr *MockShardManagerMockRecorder) AssertShardOwnership(ctx, request interface{}) *gomock.Call

type MutableStateStatistics

+ TaskCountByCategory map[string]int

type ReadRawHistoryBranchResponse

+ NodeIDs []int64

type ShardManager

+ AssertShardOwnership func(ctx context.Context, request *AssertShardOwnershipRequest) error

type ShardStore

+ AssertShardOwnership func(ctx context.Context, request *AssertShardOwnershipRequest) error

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

May 5, 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

Apr 19, 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

Apr 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

Changes in this version

+ func ReadFullPageEventsReverse(ctx context.Context, executionMgr ExecutionManager, ...) ([]*historypb.HistoryEvent, int, []byte, error)

+ type AddHistoryTasksRequest struct

+ NamespaceID string

+ RangeID int64

+ RunID string

+ ShardID int32

+ Tasks map[tasks.Category][]tasks.Task

+ WorkflowID string

+ type CompleteHistoryTaskRequest struct

+ ShardID int32

+ TaskCategory tasks.Category

+ TaskKey tasks.Key

type CompleteTasksLessThanRequest

+ ExclusiveMaxTaskID int64

type ExecutionManager

+ AddHistoryTasks func(ctx context.Context, request *AddHistoryTasksRequest) error

+ CompleteHistoryTask func(ctx context.Context, request *CompleteHistoryTaskRequest) error

+ GetHistoryTask func(ctx context.Context, request *GetHistoryTaskRequest) (*GetHistoryTaskResponse, error)

+ GetHistoryTasks func(ctx context.Context, request *GetHistoryTasksRequest) (*GetHistoryTasksResponse, error)

+ RangeCompleteHistoryTasks func(ctx context.Context, request *RangeCompleteHistoryTasksRequest) error

+ ReadHistoryBranchReverse func(ctx context.Context, request *ReadHistoryBranchReverseRequest) (*ReadHistoryBranchReverseResponse, error)

+ SetWorkflowExecution func(ctx context.Context, request *SetWorkflowExecutionRequest) (*SetWorkflowExecutionResponse, error)

type ExecutionStore

+ AddHistoryTasks func(ctx context.Context, request *InternalAddHistoryTasksRequest) error

+ CompleteHistoryTask func(ctx context.Context, request *CompleteHistoryTaskRequest) error

+ GetHistoryTask func(ctx context.Context, request *GetHistoryTaskRequest) (*InternalGetHistoryTaskResponse, error)

+ GetHistoryTasks func(ctx context.Context, request *GetHistoryTasksRequest) (*InternalGetHistoryTasksResponse, error)

+ RangeCompleteHistoryTasks func(ctx context.Context, request *RangeCompleteHistoryTasksRequest) error

+ SetWorkflowExecution func(ctx context.Context, request *InternalSetWorkflowExecutionRequest) error

+ type FailoverLevel struct

+ CurrentLevel tasks.Key

+ MaxLevel tasks.Key

+ MinLevel tasks.Key

+ NamespaceIDs map[string]struct{}

+ StartTime time.Time

+ type GetHistoryTaskRequest struct

+ ShardID int32

+ TaskCategory tasks.Category

+ TaskKey tasks.Key

+ type GetHistoryTaskResponse struct

+ Task tasks.Task

+ type GetHistoryTasksRequest struct

+ BatchSize int

+ ExclusiveMaxTaskKey tasks.Key

+ InclusiveMinTaskKey tasks.Key

+ NextPageToken []byte

+ ShardID int32

+ TaskCategory tasks.Category

+ type GetHistoryTasksResponse struct

+ NextPageToken []byte

+ Tasks []tasks.Task

type GetTasksRequest

+ ExclusiveMaxTaskID int64

+ InclusiveMinTaskID int64

+ type InternalAddHistoryTasksRequest struct

+ NamespaceID string

+ RangeID int64

+ RunID string

+ ShardID int32

+ Tasks map[tasks.Category][]InternalHistoryTask

+ WorkflowID string

+ type InternalGetHistoryTaskResponse struct

+ Task commonpb.DataBlob

+ type InternalGetHistoryTasksResponse struct

+ NextPageToken []byte

+ Tasks []commonpb.DataBlob

+ type InternalHistoryTask struct

+ Blob commonpb.DataBlob

+ Key tasks.Key

+ type InternalListNamespacesRequest struct

+ NextPageToken []byte

+ PageSize int

type InternalReadHistoryBranchRequest

+ ReverseOrder bool

+ type InternalRenameNamespaceRequest struct

+ PreviousName string

+ type InternalSetWorkflowExecutionRequest struct

+ RangeID int64

+ SetWorkflowSnapshot InternalWorkflowSnapshot

+ ShardID int32

type InternalWorkflowMutation

+ Tasks map[tasks.Category][]InternalHistoryTask

type InternalWorkflowSnapshot

+ Tasks map[tasks.Category][]InternalHistoryTask

type ListNamespacesRequest

+ IncludeDeleted bool

type MetadataManager

+ RenameNamespace func(ctx context.Context, request *RenameNamespaceRequest) error

type MetadataStore

+ RenameNamespace func(ctx context.Context, request *InternalRenameNamespaceRequest) error

type MockExecutionManager

+ func (m *MockExecutionManager) AddHistoryTasks(ctx context.Context, request *AddHistoryTasksRequest) error

+ func (m *MockExecutionManager) CompleteHistoryTask(ctx context.Context, request *CompleteHistoryTaskRequest) error

+ func (m *MockExecutionManager) GetHistoryTask(ctx context.Context, request *GetHistoryTaskRequest) (*GetHistoryTaskResponse, error)

+ func (m *MockExecutionManager) GetHistoryTasks(ctx context.Context, request *GetHistoryTasksRequest) (*GetHistoryTasksResponse, error)

+ func (m *MockExecutionManager) RangeCompleteHistoryTasks(ctx context.Context, request *RangeCompleteHistoryTasksRequest) error

+ func (m *MockExecutionManager) ReadHistoryBranchReverse(ctx context.Context, request *ReadHistoryBranchReverseRequest) (*ReadHistoryBranchReverseResponse, error)

+ func (m *MockExecutionManager) SetWorkflowExecution(ctx context.Context, request *SetWorkflowExecutionRequest) (*SetWorkflowExecutionResponse, error)

type MockExecutionManagerMockRecorder

+ func (mr *MockExecutionManagerMockRecorder) AddHistoryTasks(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteHistoryTask(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetHistoryTask(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetHistoryTasks(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteHistoryTasks(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ReadHistoryBranchReverse(ctx, request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) SetWorkflowExecution(ctx, request interface{}) *gomock.Call

type MockMetadataManager

+ func (m *MockMetadataManager) RenameNamespace(ctx context.Context, request *RenameNamespaceRequest) error

type MockMetadataManagerMockRecorder

+ func (mr *MockMetadataManagerMockRecorder) RenameNamespace(ctx, request interface{}) *gomock.Call

+ type RangeCompleteHistoryTasksRequest struct

+ ExclusiveMaxTaskKey tasks.Key

+ InclusiveMinTaskKey tasks.Key

+ ShardID int32

+ TaskCategory tasks.Category

+ type ReadHistoryBranchReverseRequest struct

+ BranchToken []byte

+ LastFirstTransactionID int64

+ MaxEventID int64

+ NextPageToken []byte

+ PageSize int

+ ShardID int32

+ type ReadHistoryBranchReverseResponse struct

+ HistoryEvents []*historypb.HistoryEvent

+ NextPageToken []byte

+ Size int

+ type RenameNamespaceRequest struct

+ NewName string

+ PreviousName string

+ type SetWorkflowExecutionRequest struct

+ RangeID int64

+ SetWorkflowSnapshot WorkflowSnapshot

+ ShardID int32

+ type SetWorkflowExecutionResponse struct

type ShardInfoWithFailover

+ FailoverLevels map[tasks.Category]map[string]FailoverLevel

type WorkflowMutation

+ Tasks map[tasks.Category][]tasks.Task

type WorkflowSnapshot

+ Tasks map[tasks.Category][]tasks.Task

Mar 4, 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

Mar 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

type InternalWorkflowMutation

+ ExecutionInfoBlob *commonpb.DataBlob

Feb 9, 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

+ type CreateTaskQueueRequest struct

+ RangeID int64

+ TaskQueueInfo *persistencespb.TaskQueueInfo

+ type CreateTaskQueueResponse struct

+ type GetTaskQueueRequest struct

+ NamespaceID string

+ TaskQueue string

+ TaskType enumspb.TaskQueueType

+ type GetTaskQueueResponse struct

+ RangeID int64

+ TaskQueueInfo *persistencespb.TaskQueueInfo

type GetTasksRequest

+ MaxTaskIDInclusive int64

+ MinTaskIDExclusive int64

+ NextPageToken []byte

+ PageSize int

type GetTasksResponse

+ NextPageToken []byte

type InternalCreateTaskQueueRequest

+ ExpiryTime *time.Time

+ TaskQueueKind enumspb.TaskQueueKind

type InternalGetTasksResponse

+ NextPageToken []byte

type InternalUpdateTaskQueueRequest

+ PrevRangeID int64

type InternalWorkflowSnapshot

+ ExecutionInfoBlob *commonpb.DataBlob

type MockTaskManager

+ func (m *MockTaskManager) CreateTaskQueue(request *CreateTaskQueueRequest) (*CreateTaskQueueResponse, error)

+ func (m *MockTaskManager) GetTaskQueue(request *GetTaskQueueRequest) (*GetTaskQueueResponse, error)

type MockTaskManagerMockRecorder

+ func (mr *MockTaskManagerMockRecorder) CreateTaskQueue(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) GetTaskQueue(request interface{}) *gomock.Call

type ReadHistoryBranchByBatchResponse

+ TransactionIDs []int64

type TaskManager

+ CreateTaskQueue func(request *CreateTaskQueueRequest) (*CreateTaskQueueResponse, error)

+ GetTaskQueue func(request *GetTaskQueueRequest) (*GetTaskQueueResponse, error)

type TaskQueueKey

+ TaskQueueName string

+ TaskQueueType enumspb.TaskQueueType

type UpdateTaskQueueRequest

+ PrevRangeID int64

Mar 4, 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

Feb 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

Jan 21, 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

Jan 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

Jan 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

Dec 20, 2021 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 13, 2021 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

type ClusterMetadataManager

+ DeleteClusterMetadata func(request *DeleteClusterMetadataRequest) error

+ GetClusterMetadataV1 func() (*GetClusterMetadataResponse, error)

+ GetCurrentClusterMetadata func() (*GetClusterMetadataResponse, error)

+ ListClusterMetadata func(request *ListClusterMetadataRequest) (*ListClusterMetadataResponse, error)

type ClusterMetadataStore

+ DeleteClusterMetadata func(request *InternalDeleteClusterMetadataRequest) error

+ GetClusterMetadataV1 func() (*InternalGetClusterMetadataResponse, error)

+ ListClusterMetadata func(request *InternalListClusterMetadataRequest) (*InternalListClusterMetadataResponse, error)

+ SaveClusterMetadataV1 func(request *InternalSaveClusterMetadataRequest) (bool, error)

+ type CompleteTieredStorageTaskRequest struct

+ ShardID int32

+ TaskID int64

+ type DeleteClusterMetadataRequest struct

+ ClusterName string

type ExecutionManager

+ CompleteTieredStorageTask func(request *CompleteTieredStorageTaskRequest) error

+ GetTieredStorageTask func(request *GetTieredStorageTaskRequest) (*GetTieredStorageTaskResponse, error)

+ GetTieredStorageTasks func(request *GetTieredStorageTasksRequest) (*GetTieredStorageTasksResponse, error)

+ GetTimerTasks func(request *GetTimerTasksRequest) (*GetTimerTasksResponse, error)

+ RangeCompleteTieredStorageTask func(request *RangeCompleteTieredStorageTaskRequest) error

type ExecutionStore

+ CompleteTieredStorageTask func(request *CompleteTieredStorageTaskRequest) error

+ GetTieredStorageTask func(request *GetTieredStorageTaskRequest) (*InternalGetTieredStorageTaskResponse, error)

+ GetTieredStorageTasks func(request *GetTieredStorageTasksRequest) (*InternalGetTieredStorageTasksResponse, error)

+ GetTimerTasks func(request *GetTimerTasksRequest) (*InternalGetTimerTasksResponse, error)

+ RangeCompleteTieredStorageTask func(request *RangeCompleteTieredStorageTaskRequest) error

+ type GetClusterMetadataRequest struct

+ ClusterName string

+ type GetOrCreateShardRequest struct

+ InitialShardInfo *persistencespb.ShardInfo

+ LifecycleContext context.Context

+ ShardID int32

+ type GetOrCreateShardResponse struct

+ ShardInfo *persistencespb.ShardInfo

type GetReplicationTaskResponse

+ Task tasks.Task

+ type GetTieredStorageTaskRequest struct

+ ShardID int32

+ TaskID int64

+ type GetTieredStorageTaskResponse struct

+ Task tasks.Task

+ type GetTieredStorageTasksRequest struct

+ BatchSize int

+ MaxTaskID int64

+ MinTaskID int64

+ NextPageToken []byte

+ ShardID int32

+ type GetTieredStorageTasksResponse struct

+ NextPageToken []byte

+ Tasks []tasks.Task

type GetTimerTaskResponse

+ Task tasks.Task

+ type GetTimerTasksRequest struct

+ BatchSize int

+ MaxTimestamp time.Time

+ MinTimestamp time.Time

+ NextPageToken []byte

+ ShardID int32

+ type GetTimerTasksResponse struct

+ NextPageToken []byte

+ Tasks []tasks.Task

type GetTransferTaskResponse

+ Task tasks.Task

type GetVisibilityTaskResponse

+ Task tasks.Task

type GetWorkflowExecutionRequest

+ RunID string

+ WorkflowID string

+ type InternalDeleteClusterMetadataRequest struct

+ ClusterName string

+ type InternalGetClusterMetadataRequest struct

+ ClusterName string

+ type InternalGetOrCreateShardRequest struct

+ CreateShardInfo func() (rangeID int64, shardInfo *commonpb.DataBlob, err error)

+ LifecycleContext context.Context

+ ShardID int32

+ type InternalGetOrCreateShardResponse struct

+ ShardInfo *commonpb.DataBlob

+ type InternalGetReplicationTaskResponse struct

+ Task commonpb.DataBlob

+ type InternalGetReplicationTasksFromDLQResponse = InternalGetReplicationTasksResponse

+ type InternalGetReplicationTasksResponse struct

+ NextPageToken []byte

+ Tasks []commonpb.DataBlob

+ type InternalGetTieredStorageTaskResponse struct

+ Task commonpb.DataBlob

+ type InternalGetTieredStorageTasksResponse struct

+ NextPageToken []byte

+ Tasks []commonpb.DataBlob

+ type InternalGetTimerTaskResponse struct

+ Task commonpb.DataBlob

+ type InternalGetTimerTasksResponse struct

+ NextPageToken []byte

+ Tasks []commonpb.DataBlob

+ type InternalGetTransferTaskResponse struct

+ Task commonpb.DataBlob

+ type InternalGetTransferTasksResponse struct

+ NextPageToken []byte

+ Tasks []commonpb.DataBlob

+ type InternalGetVisibilityTaskResponse struct

+ Task commonpb.DataBlob

+ type InternalGetVisibilityTasksResponse struct

+ NextPageToken []byte

+ Tasks []commonpb.DataBlob

+ type InternalListClusterMetadataRequest struct

+ NextPageToken []byte

+ PageSize int

+ type InternalListClusterMetadataResponse struct

+ ClusterMetadata []*InternalGetClusterMetadataResponse

+ NextPageToken []byte

type InternalSaveClusterMetadataRequest

+ ClusterName string

type InternalUpdateNamespaceRequest

+ IsGlobal bool

+ type ListClusterMetadataRequest struct

+ NextPageToken []byte

+ PageSize int

+ type ListClusterMetadataResponse struct

+ ClusterMetadata []*GetClusterMetadataResponse

+ NextPageToken []byte

type MockClusterMetadataManager

+ func (m *MockClusterMetadataManager) DeleteClusterMetadata(request *DeleteClusterMetadataRequest) error

+ func (m *MockClusterMetadataManager) GetClusterMetadataV1() (*GetClusterMetadataResponse, error)

+ func (m *MockClusterMetadataManager) GetCurrentClusterMetadata() (*GetClusterMetadataResponse, error)

+ func (m *MockClusterMetadataManager) ListClusterMetadata(request *ListClusterMetadataRequest) (*ListClusterMetadataResponse, error)

type MockClusterMetadataManagerMockRecorder

+ func (mr *MockClusterMetadataManagerMockRecorder) DeleteClusterMetadata(request interface{}) *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetClusterMetadataV1() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetCurrentClusterMetadata() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) ListClusterMetadata(request interface{}) *gomock.Call

type MockExecutionManager

+ func (m *MockExecutionManager) CompleteTieredStorageTask(request *CompleteTieredStorageTaskRequest) error

+ func (m *MockExecutionManager) GetTieredStorageTask(request *GetTieredStorageTaskRequest) (*GetTieredStorageTaskResponse, error)

+ func (m *MockExecutionManager) GetTieredStorageTasks(request *GetTieredStorageTasksRequest) (*GetTieredStorageTasksResponse, error)

+ func (m *MockExecutionManager) GetTimerTasks(request *GetTimerTasksRequest) (*GetTimerTasksResponse, error)

+ func (m *MockExecutionManager) RangeCompleteTieredStorageTask(request *RangeCompleteTieredStorageTaskRequest) error

type MockExecutionManagerMockRecorder

+ func (mr *MockExecutionManagerMockRecorder) CompleteTieredStorageTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTieredStorageTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTieredStorageTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTimerTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteTieredStorageTask(request interface{}) *gomock.Call

type MockShardManager

+ func (m *MockShardManager) GetOrCreateShard(request *GetOrCreateShardRequest) (*GetOrCreateShardResponse, error)

type MockShardManagerMockRecorder

+ func (mr *MockShardManagerMockRecorder) GetOrCreateShard(request interface{}) *gomock.Call

+ type RangeCompleteTieredStorageTaskRequest struct

+ ExclusiveBeginTaskID int64

+ InclusiveEndTaskID int64

+ ShardID int32

type ShardManager

+ GetOrCreateShard func(request *GetOrCreateShardRequest) (*GetOrCreateShardResponse, error)

type ShardStore

+ GetOrCreateShard func(request *InternalGetOrCreateShardRequest) (*InternalGetOrCreateShardResponse, error)

type UpdateNamespaceRequest

+ IsGlobalNamespace bool

Feb 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

Jan 12, 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

Dec 20, 2021 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

Nov 4, 2021 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, 2021 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 LoadAndSplitQueryFromReaders(readers []io.Reader) ([]string, error)

type ConflictResolveWorkflowExecutionRequest

+ CurrentWorkflowEvents []*WorkflowEvents

+ NewWorkflowEvents []*WorkflowEvents

+ ResetWorkflowEvents []*WorkflowEvents

+ type ConflictResolveWorkflowExecutionResponse struct

+ CurrentMutableStateStats *MutableStateStatistics

+ NewMutableStateStats *MutableStateStatistics

+ ResetMutableStateStats MutableStateStatistics

type CreateWorkflowExecutionResponse

+ NewMutableStateStats MutableStateStatistics

+ type HistoryStatistics struct

+ CountDiff int

+ SizeDiff int

+ type InternalAddTasksRequest struct

+ NamespaceID string

+ RangeID int64

+ ReplicationTasks map[tasks.Key]commonpb.DataBlob

+ RunID string

+ ShardID int32

+ TimerTasks map[tasks.Key]commonpb.DataBlob

+ TransferTasks map[tasks.Key]commonpb.DataBlob

+ VisibilityTasks map[tasks.Key]commonpb.DataBlob

+ WorkflowID string

type InternalConflictResolveWorkflowExecutionRequest

+ CurrentWorkflowEventsNewEvents []*InternalAppendHistoryNodesRequest

+ NewWorkflowEventsNewEvents []*InternalAppendHistoryNodesRequest

+ ResetWorkflowEventsNewEvents []*InternalAppendHistoryNodesRequest

+ type MutableStateStatistics struct

+ ActivityInfoCount int

+ ActivityInfoSize int

+ BufferedEventsCount int

+ BufferedEventsSize int

+ ChildInfoCount int

+ ChildInfoSize int

+ ExecutionInfoSize int

+ ExecutionStateSize int

+ HistoryStatistics *HistoryStatistics

+ RequestCancelInfoCount int

+ RequestCancelInfoSize int

+ SignalInfoCount int

+ SignalInfoSize int

+ SignalRequestIDCount int

+ SignalRequestIDSize int

+ TimerInfoCount int

+ TimerInfoSize int

+ TotalSize int

type UpdateWorkflowExecutionResponse

+ NewMutableStateStats *MutableStateStatistics

+ UpdateMutableStateStats MutableStateStatistics

Oct 29, 2021 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 7, 2021 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 4, 2021 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, 2021 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 31, 2021 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 ReadFullPageEvents(executionMgr ExecutionManager, req *ReadHistoryBranchRequest) ([]*historypb.HistoryEvent, int, []byte, error)

+ func ReadFullPageEventsByBatch(executionMgr ExecutionManager, req *ReadHistoryBranchRequest) ([]*historypb.History, int, []byte, error)

type ActivityRetryTimerTask

+ func (r *ActivityRetryTimerTask) GetVisibilityTime() time.Time

+ func (r *ActivityRetryTimerTask) SetVisibilityTime(t time.Time)

type ActivityTask

+ func (a *ActivityTask) GetVisibilityTime() time.Time

+ func (a *ActivityTask) SetVisibilityTime(timestamp time.Time)

type ActivityTimeoutTask

+ func (a *ActivityTimeoutTask) GetVisibilityTime() time.Time

+ func (a *ActivityTimeoutTask) SetVisibilityTime(t time.Time)

type AddTasksRequest

+ ShardID int32

type CancelExecutionTask

+ func (u *CancelExecutionTask) GetVisibilityTime() time.Time

+ func (u *CancelExecutionTask) SetVisibilityTime(timestamp time.Time)

type CloseExecutionTask

+ func (a *CloseExecutionTask) GetVisibilityTime() time.Time

+ func (a *CloseExecutionTask) SetVisibilityTime(timestamp time.Time)

type CloseExecutionVisibilityTask

+ func (t *CloseExecutionVisibilityTask) GetVisibilityTime() time.Time

+ func (t *CloseExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type CompleteReplicationTaskRequest

+ ShardID int32

type CompleteTimerTaskRequest

+ ShardID int32

type CompleteTransferTaskRequest

+ ShardID int32

type CompleteVisibilityTaskRequest

+ ShardID int32

type ConflictResolveWorkflowExecutionRequest

+ ShardID int32

type CreateWorkflowExecutionRequest

+ NewWorkflowEvents []*WorkflowEvents

+ ShardID int32

type CreateWorkflowExecutionResponse

+ HistorySize int64

type CurrentWorkflowConditionFailedError

+ LastWriteVersion int64

+ RequestID string

+ RunID string

+ State enumsspb.WorkflowExecutionState

+ Status enumspb.WorkflowExecutionStatus

type DeleteCurrentWorkflowExecutionRequest

+ ShardID int32

type DeleteExecutionVisibilityTask

+ func (t *DeleteExecutionVisibilityTask) GetVisibilityTime() time.Time

+ func (t *DeleteExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type DeleteHistoryEventTask

+ func (a *DeleteHistoryEventTask) GetVisibilityTime() time.Time

+ func (a *DeleteHistoryEventTask) SetVisibilityTime(timestamp time.Time)

type DeleteReplicationTaskFromDLQRequest

+ ShardID int32

type DeleteWorkflowExecutionRequest

+ ShardID int32

type ExecutionManager

+ func NewExecutionPersistenceMetricsClient(persistence ExecutionManager, metricClient metrics.Client, logger log.Logger) ExecutionManager

+ func NewExecutionPersistenceRateLimitedClient(persistence ExecutionManager, rateLimiter quotas.RateLimiter, ...) ExecutionManager

+ AppendHistoryNodes func(request *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

+ DeleteHistoryBranch func(request *DeleteHistoryBranchRequest) error

+ ForkHistoryBranch func(request *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)

+ GetAllHistoryTreeBranches func(request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)

+ GetHistoryTree func(request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ ReadHistoryBranch func(request *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)

+ ReadHistoryBranchByBatch func(request *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)

+ ReadRawHistoryBranch func(request *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error)

+ TrimHistoryBranch func(request *TrimHistoryBranchRequest) (*TrimHistoryBranchResponse, error)

type ExecutionStore

+ AppendHistoryNodes func(request *InternalAppendHistoryNodesRequest) error

+ DeleteHistoryBranch func(request *InternalDeleteHistoryBranchRequest) error

+ DeleteHistoryNodes func(request *InternalDeleteHistoryNodesRequest) error

+ ForkHistoryBranch func(request *InternalForkHistoryBranchRequest) error

+ GetAllHistoryTreeBranches func(request *GetAllHistoryTreeBranchesRequest) (*InternalGetAllHistoryTreeBranchesResponse, error)

+ GetHistoryTree func(request *GetHistoryTreeRequest) (*InternalGetHistoryTreeResponse, error)

+ ReadHistoryBranch func(request *InternalReadHistoryBranchRequest) (*InternalReadHistoryBranchResponse, error)

type GetCurrentExecutionRequest

+ ShardID int32

type GetReplicationTasksFromDLQRequest

+ ShardID int32

type GetReplicationTasksRequest

+ ShardID int32

type GetTimerIndexTasksRequest

+ ShardID int32

type GetTransferTasksRequest

+ ShardID int32

type GetVisibilityTasksRequest

+ ShardID int32

type GetWorkflowExecutionRequest

+ ShardID int32

type HistoryReplicationTask

+ func (a *HistoryReplicationTask) GetVisibilityTime() time.Time

+ func (a *HistoryReplicationTask) SetVisibilityTime(timestamp time.Time)

type InternalConflictResolveWorkflowExecutionRequest

+ ShardID int32

type InternalCreateWorkflowExecutionRequest

+ NewWorkflowNewEvents []*InternalAppendHistoryNodesRequest

+ ShardID int32

+ type InternalCreateWorkflowExecutionResponse struct

type InternalUpdateWorkflowExecutionRequest

+ NewWorkflowNewEvents []*InternalAppendHistoryNodesRequest

+ ShardID int32

+ UpdateWorkflowNewEvents []*InternalAppendHistoryNodesRequest

type ListConcreteExecutionsRequest

+ ShardID int32

type MockExecutionManager

+ func (m *MockExecutionManager) AppendHistoryNodes(request *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

+ func (m *MockExecutionManager) DeleteHistoryBranch(request *DeleteHistoryBranchRequest) error

+ func (m *MockExecutionManager) ForkHistoryBranch(request *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)

+ func (m *MockExecutionManager) GetAllHistoryTreeBranches(request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)

+ func (m *MockExecutionManager) GetHistoryTree(request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ func (m *MockExecutionManager) ReadHistoryBranch(request *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)

+ func (m *MockExecutionManager) ReadHistoryBranchByBatch(request *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)

+ func (m *MockExecutionManager) ReadRawHistoryBranch(request *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error)

+ func (m *MockExecutionManager) TrimHistoryBranch(request *TrimHistoryBranchRequest) (*TrimHistoryBranchResponse, error)

type MockExecutionManagerMockRecorder

+ func (mr *MockExecutionManagerMockRecorder) AppendHistoryNodes(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) DeleteHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ForkHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetAllHistoryTreeBranches(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetHistoryTree(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ReadHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ReadHistoryBranchByBatch(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ReadRawHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) TrimHistoryBranch(request interface{}) *gomock.Call

type MockTask

+ func (m *MockTask) GetVisibilityTime() time.Time

+ func (m *MockTask) SetVisibilityTime(timestamp time.Time)

type MockTaskMockRecorder

+ func (mr *MockTaskMockRecorder) GetVisibilityTime() *gomock.Call

+ func (mr *MockTaskMockRecorder) SetVisibilityTime(timestamp interface{}) *gomock.Call

type MutableStateUpdateSessionStats

+ NewWorkflowHistorySizeDiff int64

+ UpdateWorkflowHistorySizeDiff int64

type PutReplicationTaskToDLQRequest

+ ShardID int32

type RangeCompleteReplicationTaskRequest

+ ShardID int32

type RangeCompleteTimerTaskRequest

+ ShardID int32

type RangeCompleteTransferTaskRequest

+ ShardID int32

type RangeCompleteVisibilityTaskRequest

+ ShardID int32

type RangeDeleteReplicationTaskFromDLQRequest

+ ShardID int32

type ResetWorkflowTask

+ func (a *ResetWorkflowTask) GetVisibilityTime() time.Time

+ func (a *ResetWorkflowTask) SetVisibilityTime(timestamp time.Time)

type SignalExecutionTask

+ func (u *SignalExecutionTask) GetVisibilityTime() time.Time

+ func (u *SignalExecutionTask) SetVisibilityTime(timestamp time.Time)

type StartChildExecutionTask

+ func (u *StartChildExecutionTask) GetVisibilityTime() time.Time

+ func (u *StartChildExecutionTask) SetVisibilityTime(timestamp time.Time)

type StartExecutionVisibilityTask

+ func (t *StartExecutionVisibilityTask) GetVisibilityTime() time.Time

+ func (t *StartExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type SyncActivityTask

+ func (a *SyncActivityTask) GetVisibilityTime() time.Time

+ func (a *SyncActivityTask) SetVisibilityTime(timestamp time.Time)

type Task

+ GetVisibilityTime func() time.Time

+ SetVisibilityTime func(timestamp time.Time)

type UpdateWorkflowExecutionRequest

+ NewWorkflowEvents []*WorkflowEvents

+ ShardID int32

+ UpdateWorkflowEvents []*WorkflowEvents

type UpsertExecutionVisibilityTask

+ func (t *UpsertExecutionVisibilityTask) GetVisibilityTime() time.Time

+ func (t *UpsertExecutionVisibilityTask) SetVisibilityTime(timestamp time.Time)

type UserTimerTask

+ func (u *UserTimerTask) GetVisibilityTime() time.Time

+ func (u *UserTimerTask) SetVisibilityTime(t time.Time)

type WorkflowBackoffTimerTask

+ func (r *WorkflowBackoffTimerTask) GetVisibilityTime() time.Time

+ func (r *WorkflowBackoffTimerTask) SetVisibilityTime(t time.Time)

+ type WorkflowConditionFailedError struct

+ DBRecordVersion int64

+ Msg string

+ NextEventID int64

+ func (e *WorkflowConditionFailedError) Error() string

type WorkflowTask

+ func (d *WorkflowTask) GetVisibilityTime() time.Time

+ func (d *WorkflowTask) SetVisibilityTime(timestamp time.Time)

type WorkflowTaskTimeoutTask

+ func (d *WorkflowTaskTimeoutTask) GetVisibilityTime() time.Time

+ func (d *WorkflowTaskTimeoutTask) SetVisibilityTime(t time.Time)

type WorkflowTimeoutTask

+ func (u *WorkflowTimeoutTask) GetVisibilityTime() time.Time

+ func (u *WorkflowTimeoutTask) SetVisibilityTime(t time.Time)

Aug 18, 2021 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 6, 2021 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 22, 2021 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 20, 2021 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 18, 2021 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 UnixMilliseconds(t time.Time) int64

type ExecutionManager

+ func NewExecutionManager(persistence ExecutionStore, logger log.Logger) ExecutionManager

type InternalAppendHistoryNodesRequest

+ TreeInfo *commonpb.DataBlob

+ type InternalCreateShardRequest struct

+ RangeID int64

+ ShardID int32

+ ShardInfo *commonpb.DataBlob

+ type InternalCreateTask struct

+ ExpiryTime *time.Time

+ Task *commonpb.DataBlob

+ TaskId int64

+ type InternalCreateTaskQueueRequest struct

+ NamespaceID string

+ RangeID int64

+ TaskQueue string

+ TaskQueueInfo *commonpb.DataBlob

+ TaskType enumspb.TaskQueueType

+ type InternalCreateTasksRequest struct

+ NamespaceID string

+ RangeID int64

+ TaskQueue string

+ TaskQueueInfo *commonpb.DataBlob

+ TaskType enumspb.TaskQueueType

+ Tasks []*InternalCreateTask

+ type InternalDeleteHistoryBranchRange struct

+ BeginNodeId int64

+ BranchId string

type InternalDeleteHistoryBranchRequest

+ BranchId string

+ BranchRanges []InternalDeleteHistoryBranchRange

+ TreeId string

+ type InternalExtendLeaseRequest struct

+ NamespaceID string

+ RangeID int64

+ TaskQueue string

+ TaskQueueInfo *commonpb.DataBlob

+ TaskType enumspb.TaskQueueType

type InternalForkHistoryBranchRequest

+ TreeInfo *commonpb.DataBlob

+ type InternalGetAllHistoryTreeBranchesResponse struct

+ Branches []InternalHistoryBranchDetail

+ NextPageToken []byte

+ type InternalGetCurrentExecutionResponse struct

+ ExecutionState *persistencespb.WorkflowExecutionState

+ LastWriteVersion int64

+ RunID string

+ type InternalGetHistoryTreeResponse struct

+ TreeInfos []*commonpb.DataBlob

+ type InternalGetShardRequest struct

+ ShardID int32

+ type InternalGetShardResponse struct

+ ShardInfo *commonpb.DataBlob

+ type InternalGetTaskQueueRequest struct

+ NamespaceID string

+ TaskQueue string

+ TaskType enumspb.TaskQueueType

+ type InternalGetTaskQueueResponse struct

+ RangeID int64

+ TaskQueueInfo *commonpb.DataBlob

+ type InternalGetTasksResponse struct

+ Tasks []*commonpb.DataBlob

+ type InternalHistoryBranchDetail struct

+ BranchID string

+ Data []byte

+ Encoding string

+ TreeID string

+ type InternalListTaskQueueItem struct

+ RangeID int64

+ TaskQueue *commonpb.DataBlob

+ type InternalListTaskQueueResponse struct

+ Items []*InternalListTaskQueueItem

+ NextPageToken []byte

+ type InternalQueueMetadata struct

+ Blob *commonpb.DataBlob

+ Version int64

type InternalRecordWorkflowExecutionClosedRequest

+ CloseTime time.Time

+ type InternalUpdateShardRequest struct

+ PreviousRangeID int64

+ RangeID int64

+ ShardID int32

+ ShardInfo *commonpb.DataBlob

+ type InternalUpdateTaskQueueRequest struct

+ ExpiryTime *time.Time

+ NamespaceID string

+ RangeID int64

+ TaskQueue string

+ TaskQueueInfo *commonpb.DataBlob

+ TaskQueueKind enumspb.TaskQueueKind

+ TaskType enumspb.TaskQueueType

type InternalVisibilityRequestBase

+ ExecutionTime time.Time

+ StartTime time.Time

+ StateTransitionCount int64

type InternalWorkflowMutation

+ ExecutionStateBlob *commonpb.DataBlob

+ NamespaceID string

+ RunID string

+ WorkflowID string

type InternalWorkflowSnapshot

+ ExecutionStateBlob *commonpb.DataBlob

+ NamespaceID string

+ RunID string

+ WorkflowID string

type Queue

+ Init func(blob *commonpb.DataBlob) error

type RecordWorkflowExecutionClosedRequest

+ CloseTime time.Time

type ShardManager

+ func NewShardManager(shardStore ShardStore) ShardManager

type ShardStore

+ CreateShard func(request *InternalCreateShardRequest) error

+ GetClusterName func() string

+ GetName func() string

+ GetShard func(request *InternalGetShardRequest) (*InternalGetShardResponse, error)

+ UpdateShard func(request *InternalUpdateShardRequest) error

type TaskManager

+ func NewTaskManager(store TaskStore) TaskManager

type TaskStore

+ CompleteTask func(request *CompleteTaskRequest) error

+ CompleteTasksLessThan func(request *CompleteTasksLessThanRequest) (int, error)

+ CreateTaskQueue func(request *InternalCreateTaskQueueRequest) error

+ CreateTasks func(request *InternalCreateTasksRequest) (*CreateTasksResponse, error)

+ DeleteTaskQueue func(request *DeleteTaskQueueRequest) error

+ ExtendLease func(request *InternalExtendLeaseRequest) error

+ GetName func() string

+ GetTaskQueue func(request *InternalGetTaskQueueRequest) (*InternalGetTaskQueueResponse, error)

+ GetTasks func(request *GetTasksRequest) (*InternalGetTasksResponse, error)

+ ListTaskQueue func(request *ListTaskQueueRequest) (*InternalListTaskQueueResponse, error)

+ UpdateTaskQueue func(request *InternalUpdateTaskQueueRequest) (*UpdateTaskQueueResponse, error)

type VisibilityRequestBase

+ ExecutionTime time.Time

+ StartTime time.Time

+ StateTransitionCount int64

type VisibilityWorkflowExecutionInfo

+ StateTransitionCount int64

Jun 24, 2021 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 23, 2021 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 18, 2021 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 8, 2021 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 7, 2021 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 2, 2021 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

+ type SearchAttributesManager struct

+ func NewSearchAttributesManager(timeSource clock.TimeSource, clusterMetadataManager ClusterMetadataManager) *SearchAttributesManager

+ func (m *SearchAttributesManager) GetSearchAttributes(indexName string, forceRefreshCache bool) (searchattribute.NameTypeMap, error)

+ func (m *SearchAttributesManager) SaveSearchAttributes(indexName string, ...) error

Jun 23, 2021 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

May 7, 2021 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

May 5, 2021 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

Apr 27, 2021 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

type AppendHistoryNodesRequest

+ PrevTransactionID int64

type GetReplicationTasksRequest

+ MaxTaskID int64

+ MinTaskID int64

type GetWorkflowExecutionResponse

+ DBRecordVersion int64

type HistoryManager

+ TrimHistoryBranch func(request *TrimHistoryBranchRequest) (*TrimHistoryBranchResponse, error)

type HistoryStore

+ DeleteHistoryNodes func(request *InternalDeleteHistoryNodesRequest) error

type InternalAppendHistoryNodesRequest

+ Node InternalHistoryNode

+ type InternalDeleteHistoryNodesRequest struct

+ BranchInfo *persistencespb.HistoryBranch

+ NodeID int64

+ ShardID int32

+ TransactionID int64

type InternalGetWorkflowExecutionResponse

+ DBRecordVersion int64

+ type InternalHistoryNode struct

+ Events *commonpb.DataBlob

+ NodeID int64

+ PrevTransactionID int64

+ TransactionID int64

type InternalReadHistoryBranchRequest

+ MetadataOnly bool

type InternalReadHistoryBranchResponse

+ Nodes []InternalHistoryNode

type InternalWorkflowMutableState

+ DBRecordVersion int64

type InternalWorkflowMutation

+ DBRecordVersion int64

type InternalWorkflowSnapshot

+ DBRecordVersion int64

type MockHistoryManager

+ func (m *MockHistoryManager) TrimHistoryBranch(request *TrimHistoryBranchRequest) (*TrimHistoryBranchResponse, error)

type MockHistoryManagerMockRecorder

+ func (mr *MockHistoryManagerMockRecorder) TrimHistoryBranch(request interface{}) *gomock.Call

+ type TrimHistoryBranchRequest struct

+ BranchToken []byte

+ NodeID int64

+ ShardID int32

+ TransactionID int64

+ type TrimHistoryBranchResponse struct

type WorkflowEvents

+ PrevTxnID int64

+ TxnID int64

type WorkflowMutation

+ DBRecordVersion int64

type WorkflowSnapshot

+ DBRecordVersion int64

Apr 15, 2021 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

Mar 29, 2021 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

Mar 23, 2021 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

Apr 15, 2021 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

Apr 7, 2021 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

Mar 23, 2021 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

Feb 16, 2021 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

Apr 15, 2021 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

type InternalRecordWorkflowExecutionClosedRequest

+ Retention *time.Duration

type RecordWorkflowExecutionClosedRequest

+ Retention *time.Duration

Apr 7, 2021 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

Mar 23, 2021 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

Feb 13, 2021 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

Jan 30, 2021 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

Jan 26, 2021 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

Jan 25, 2021 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

Jan 22, 2021 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

Apr 7, 2021 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

Mar 23, 2021 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 LoadAndSplitQuery(filePaths []string) ([]string, error)

+ type MockCloseable struct

+ func NewMockCloseable(ctrl *gomock.Controller) *MockCloseable

+ func (m *MockCloseable) Close()

+ func (m *MockCloseable) EXPECT() *MockCloseableMockRecorder

+ type MockCloseableMockRecorder struct

+ func (mr *MockCloseableMockRecorder) Close() *gomock.Call

+ type MockClusterMetadataManager struct

+ func NewMockClusterMetadataManager(ctrl *gomock.Controller) *MockClusterMetadataManager

+ func (m *MockClusterMetadataManager) Close()

+ func (m *MockClusterMetadataManager) EXPECT() *MockClusterMetadataManagerMockRecorder

+ func (m *MockClusterMetadataManager) GetClusterMembers(request *GetClusterMembersRequest) (*GetClusterMembersResponse, error)

+ func (m *MockClusterMetadataManager) GetClusterMetadata() (*GetClusterMetadataResponse, error)

+ func (m *MockClusterMetadataManager) GetName() string

+ func (m *MockClusterMetadataManager) PruneClusterMembership(request *PruneClusterMembershipRequest) error

+ func (m *MockClusterMetadataManager) SaveClusterMetadata(request *SaveClusterMetadataRequest) (bool, error)

+ func (m *MockClusterMetadataManager) UpsertClusterMembership(request *UpsertClusterMembershipRequest) error

+ type MockClusterMetadataManagerMockRecorder struct

+ func (mr *MockClusterMetadataManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetClusterMembers(request interface{}) *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetClusterMetadata() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) PruneClusterMembership(request interface{}) *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) SaveClusterMetadata(request interface{}) *gomock.Call

+ func (mr *MockClusterMetadataManagerMockRecorder) UpsertClusterMembership(request interface{}) *gomock.Call

+ type MockExecutionManager struct

+ func NewMockExecutionManager(ctrl *gomock.Controller) *MockExecutionManager

+ func (m *MockExecutionManager) AddTasks(request *AddTasksRequest) error

+ func (m *MockExecutionManager) Close()

+ func (m *MockExecutionManager) CompleteReplicationTask(request *CompleteReplicationTaskRequest) error

+ func (m *MockExecutionManager) CompleteTimerTask(request *CompleteTimerTaskRequest) error

+ func (m *MockExecutionManager) CompleteTransferTask(request *CompleteTransferTaskRequest) error

+ func (m *MockExecutionManager) CompleteVisibilityTask(request *CompleteVisibilityTaskRequest) error

+ func (m *MockExecutionManager) ConflictResolveWorkflowExecution(request *ConflictResolveWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) CreateWorkflowExecution(request *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)

+ func (m *MockExecutionManager) DeleteCurrentWorkflowExecution(request *DeleteCurrentWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) DeleteReplicationTaskFromDLQ(request *DeleteReplicationTaskFromDLQRequest) error

+ func (m *MockExecutionManager) DeleteWorkflowExecution(request *DeleteWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) EXPECT() *MockExecutionManagerMockRecorder

+ func (m *MockExecutionManager) GetCurrentExecution(request *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)

+ func (m *MockExecutionManager) GetName() string

+ func (m *MockExecutionManager) GetReplicationTask(request *GetReplicationTaskRequest) (*GetReplicationTaskResponse, error)

+ func (m *MockExecutionManager) GetReplicationTasks(request *GetReplicationTasksRequest) (*GetReplicationTasksResponse, error)

+ func (m *MockExecutionManager) GetReplicationTasksFromDLQ(request *GetReplicationTasksFromDLQRequest) (*GetReplicationTasksFromDLQResponse, error)

+ func (m *MockExecutionManager) GetShardID() int32

+ func (m *MockExecutionManager) GetTimerIndexTasks(request *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)

+ func (m *MockExecutionManager) GetTimerTask(request *GetTimerTaskRequest) (*GetTimerTaskResponse, error)

+ func (m *MockExecutionManager) GetTransferTask(request *GetTransferTaskRequest) (*GetTransferTaskResponse, error)

+ func (m *MockExecutionManager) GetTransferTasks(request *GetTransferTasksRequest) (*GetTransferTasksResponse, error)

+ func (m *MockExecutionManager) GetVisibilityTask(request *GetVisibilityTaskRequest) (*GetVisibilityTaskResponse, error)

+ func (m *MockExecutionManager) GetVisibilityTasks(request *GetVisibilityTasksRequest) (*GetVisibilityTasksResponse, error)

+ func (m *MockExecutionManager) GetWorkflowExecution(request *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)

+ func (m *MockExecutionManager) ListConcreteExecutions(request *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)

+ func (m *MockExecutionManager) PutReplicationTaskToDLQ(request *PutReplicationTaskToDLQRequest) error

+ func (m *MockExecutionManager) RangeCompleteReplicationTask(request *RangeCompleteReplicationTaskRequest) error

+ func (m *MockExecutionManager) RangeCompleteTimerTask(request *RangeCompleteTimerTaskRequest) error

+ func (m *MockExecutionManager) RangeCompleteTransferTask(request *RangeCompleteTransferTaskRequest) error

+ func (m *MockExecutionManager) RangeCompleteVisibilityTask(request *RangeCompleteVisibilityTaskRequest) error

+ func (m *MockExecutionManager) RangeDeleteReplicationTaskFromDLQ(request *RangeDeleteReplicationTaskFromDLQRequest) error

+ func (m *MockExecutionManager) UpdateWorkflowExecution(request *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error)

+ type MockExecutionManagerFactory struct

+ func NewMockExecutionManagerFactory(ctrl *gomock.Controller) *MockExecutionManagerFactory

+ func (m *MockExecutionManagerFactory) Close()

+ func (m *MockExecutionManagerFactory) EXPECT() *MockExecutionManagerFactoryMockRecorder

+ func (m *MockExecutionManagerFactory) NewExecutionManager(shardID int32) (ExecutionManager, error)

+ type MockExecutionManagerFactoryMockRecorder struct

+ func (mr *MockExecutionManagerFactoryMockRecorder) Close() *gomock.Call

+ func (mr *MockExecutionManagerFactoryMockRecorder) NewExecutionManager(shardID interface{}) *gomock.Call

+ type MockExecutionManagerMockRecorder struct

+ func (mr *MockExecutionManagerMockRecorder) AddTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteReplicationTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteTimerTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteTransferTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CompleteVisibilityTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ConflictResolveWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) CreateWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) DeleteCurrentWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) DeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) DeleteWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetCurrentExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetReplicationTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetReplicationTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetReplicationTasksFromDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetShardID() *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTimerIndexTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTimerTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTransferTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetTransferTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetVisibilityTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetVisibilityTasks(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) GetWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) ListConcreteExecutions(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteReplicationTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteTimerTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteTransferTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeCompleteVisibilityTask(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) RangeDeleteReplicationTaskFromDLQ(request interface{}) *gomock.Call

+ func (mr *MockExecutionManagerMockRecorder) UpdateWorkflowExecution(request interface{}) *gomock.Call

+ type MockHistoryManager struct

+ func NewMockHistoryManager(ctrl *gomock.Controller) *MockHistoryManager

+ func (m *MockHistoryManager) AppendHistoryNodes(request *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

+ func (m *MockHistoryManager) Close()

+ func (m *MockHistoryManager) DeleteHistoryBranch(request *DeleteHistoryBranchRequest) error

+ func (m *MockHistoryManager) EXPECT() *MockHistoryManagerMockRecorder

+ func (m *MockHistoryManager) ForkHistoryBranch(request *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)

+ func (m *MockHistoryManager) GetAllHistoryTreeBranches(request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)

+ func (m *MockHistoryManager) GetHistoryTree(request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ func (m *MockHistoryManager) GetName() string

+ func (m *MockHistoryManager) ReadHistoryBranch(request *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)

+ func (m *MockHistoryManager) ReadHistoryBranchByBatch(request *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)

+ func (m *MockHistoryManager) ReadRawHistoryBranch(request *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error)

+ type MockHistoryManagerMockRecorder struct

+ func (mr *MockHistoryManagerMockRecorder) AppendHistoryNodes(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) DeleteHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ForkHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) GetAllHistoryTreeBranches(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) GetHistoryTree(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ReadHistoryBranchByBatch(request interface{}) *gomock.Call

+ func (mr *MockHistoryManagerMockRecorder) ReadRawHistoryBranch(request interface{}) *gomock.Call

+ type MockMetadataManager struct

+ func NewMockMetadataManager(ctrl *gomock.Controller) *MockMetadataManager

+ func (m *MockMetadataManager) Close()

+ func (m *MockMetadataManager) CreateNamespace(request *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

+ func (m *MockMetadataManager) DeleteNamespace(request *DeleteNamespaceRequest) error

+ func (m *MockMetadataManager) DeleteNamespaceByName(request *DeleteNamespaceByNameRequest) error

+ func (m *MockMetadataManager) EXPECT() *MockMetadataManagerMockRecorder

+ func (m *MockMetadataManager) GetMetadata() (*GetMetadataResponse, error)

+ func (m *MockMetadataManager) GetName() string

+ func (m *MockMetadataManager) GetNamespace(request *GetNamespaceRequest) (*GetNamespaceResponse, error)

+ func (m *MockMetadataManager) InitializeSystemNamespaces(currentClusterName string) error

+ func (m *MockMetadataManager) ListNamespaces(request *ListNamespacesRequest) (*ListNamespacesResponse, error)

+ func (m *MockMetadataManager) UpdateNamespace(request *UpdateNamespaceRequest) error

+ type MockMetadataManagerMockRecorder struct

+ func (mr *MockMetadataManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) CreateNamespace(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) DeleteNamespace(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) DeleteNamespaceByName(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) GetMetadata() *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) GetNamespace(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) InitializeSystemNamespaces(currentClusterName interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) ListNamespaces(request interface{}) *gomock.Call

+ func (mr *MockMetadataManagerMockRecorder) UpdateNamespace(request interface{}) *gomock.Call

+ type MockShardManager struct

+ func NewMockShardManager(ctrl *gomock.Controller) *MockShardManager

+ func (m *MockShardManager) Close()

+ func (m *MockShardManager) CreateShard(request *CreateShardRequest) error

+ func (m *MockShardManager) EXPECT() *MockShardManagerMockRecorder

+ func (m *MockShardManager) GetName() string

+ func (m *MockShardManager) GetShard(request *GetShardRequest) (*GetShardResponse, error)

+ func (m *MockShardManager) UpdateShard(request *UpdateShardRequest) error

+ type MockShardManagerMockRecorder struct

+ func (mr *MockShardManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockShardManagerMockRecorder) CreateShard(request interface{}) *gomock.Call

+ func (mr *MockShardManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockShardManagerMockRecorder) GetShard(request interface{}) *gomock.Call

+ func (mr *MockShardManagerMockRecorder) UpdateShard(request interface{}) *gomock.Call

+ type MockTask struct

+ func NewMockTask(ctrl *gomock.Controller) *MockTask

+ func (m *MockTask) EXPECT() *MockTaskMockRecorder

+ func (m *MockTask) GetTaskID() int64

+ func (m *MockTask) GetType() v1.TaskType

+ func (m *MockTask) GetVersion() int64

+ func (m *MockTask) GetVisibilityTimestamp() time.Time

+ func (m *MockTask) SetTaskID(id int64)

+ func (m *MockTask) SetVersion(version int64)

+ func (m *MockTask) SetVisibilityTimestamp(timestamp time.Time)

+ type MockTaskManager struct

+ func NewMockTaskManager(ctrl *gomock.Controller) *MockTaskManager

+ func (m *MockTaskManager) Close()

+ func (m *MockTaskManager) CompleteTask(request *CompleteTaskRequest) error

+ func (m *MockTaskManager) CompleteTasksLessThan(request *CompleteTasksLessThanRequest) (int, error)

+ func (m *MockTaskManager) CreateTasks(request *CreateTasksRequest) (*CreateTasksResponse, error)

+ func (m *MockTaskManager) DeleteTaskQueue(request *DeleteTaskQueueRequest) error

+ func (m *MockTaskManager) EXPECT() *MockTaskManagerMockRecorder

+ func (m *MockTaskManager) GetName() string

+ func (m *MockTaskManager) GetTasks(request *GetTasksRequest) (*GetTasksResponse, error)

+ func (m *MockTaskManager) LeaseTaskQueue(request *LeaseTaskQueueRequest) (*LeaseTaskQueueResponse, error)

+ func (m *MockTaskManager) ListTaskQueue(request *ListTaskQueueRequest) (*ListTaskQueueResponse, error)

+ func (m *MockTaskManager) UpdateTaskQueue(request *UpdateTaskQueueRequest) (*UpdateTaskQueueResponse, error)

+ type MockTaskManagerMockRecorder struct

+ func (mr *MockTaskManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) CompleteTask(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) CompleteTasksLessThan(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) CreateTasks(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) DeleteTaskQueue(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) GetTasks(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) LeaseTaskQueue(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) ListTaskQueue(request interface{}) *gomock.Call

+ func (mr *MockTaskManagerMockRecorder) UpdateTaskQueue(request interface{}) *gomock.Call

+ type MockTaskMockRecorder struct

+ func (mr *MockTaskMockRecorder) GetTaskID() *gomock.Call

+ func (mr *MockTaskMockRecorder) GetType() *gomock.Call

+ func (mr *MockTaskMockRecorder) GetVersion() *gomock.Call

+ func (mr *MockTaskMockRecorder) GetVisibilityTimestamp() *gomock.Call

+ func (mr *MockTaskMockRecorder) SetTaskID(id interface{}) *gomock.Call

+ func (mr *MockTaskMockRecorder) SetVersion(version interface{}) *gomock.Call

+ func (mr *MockTaskMockRecorder) SetVisibilityTimestamp(timestamp interface{}) *gomock.Call

+ type MockVisibilityManager struct

+ func NewMockVisibilityManager(ctrl *gomock.Controller) *MockVisibilityManager

+ func (m *MockVisibilityManager) Close()

+ func (m *MockVisibilityManager) CountWorkflowExecutions(request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) DeleteWorkflowExecution(request *VisibilityDeleteWorkflowExecutionRequest) error

+ func (m *MockVisibilityManager) EXPECT() *MockVisibilityManagerMockRecorder

+ func (m *MockVisibilityManager) GetClosedWorkflowExecution(request *GetClosedWorkflowExecutionRequest) (*GetClosedWorkflowExecutionResponse, error)

+ func (m *MockVisibilityManager) GetName() string

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByStatus(request *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListOpenWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) RecordWorkflowExecutionClosed(request *RecordWorkflowExecutionClosedRequest) error

+ func (m *MockVisibilityManager) RecordWorkflowExecutionStarted(request *RecordWorkflowExecutionStartedRequest) error

+ func (m *MockVisibilityManager) ScanWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) UpsertWorkflowExecution(request *UpsertWorkflowExecutionRequest) error

+ type MockVisibilityManagerMockRecorder struct

+ func (mr *MockVisibilityManagerMockRecorder) Close() *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) CountWorkflowExecutions(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) DeleteWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) GetClosedWorkflowExecution(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) GetName() *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListWorkflowExecutions(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ScanWorkflowExecutions(request interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) UpsertWorkflowExecution(request interface{}) *gomock.Call

Feb 18, 2021 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

Feb 13, 2021 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

Jan 26, 2021 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

Jan 25, 2021 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

Jan 22, 2021 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 30, 2020 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 22, 2020 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

+ type AddTasksRequest struct

+ NamespaceID string

+ RangeID int64

+ ReplicationTasks []Task

+ RunID string

+ TimerTasks []Task

+ TransferTasks []Task

+ VisibilityTasks []Task

+ WorkflowID string

+ type CloseExecutionVisibilityTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (t *CloseExecutionVisibilityTask) GetTaskID() int64

+ func (t *CloseExecutionVisibilityTask) GetType() enumsspb.TaskType

+ func (t *CloseExecutionVisibilityTask) GetVersion() int64

+ func (t *CloseExecutionVisibilityTask) GetVisibilityTimestamp() time.Time

+ func (t *CloseExecutionVisibilityTask) SetTaskID(id int64)

+ func (t *CloseExecutionVisibilityTask) SetVersion(version int64)

+ func (t *CloseExecutionVisibilityTask) SetVisibilityTimestamp(timestamp time.Time)

+ type CompleteVisibilityTaskRequest struct

+ TaskID int64

+ type DeleteExecutionVisibilityTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (t *DeleteExecutionVisibilityTask) GetTaskID() int64

+ func (t *DeleteExecutionVisibilityTask) GetType() enumsspb.TaskType

+ func (t *DeleteExecutionVisibilityTask) GetVersion() int64

+ func (t *DeleteExecutionVisibilityTask) GetVisibilityTimestamp() time.Time

+ func (t *DeleteExecutionVisibilityTask) SetTaskID(id int64)

+ func (t *DeleteExecutionVisibilityTask) SetVersion(version int64)

+ func (t *DeleteExecutionVisibilityTask) SetVisibilityTimestamp(timestamp time.Time)

type ExecutionManager

+ AddTasks func(request *AddTasksRequest) error

+ CompleteVisibilityTask func(request *CompleteVisibilityTaskRequest) error

+ GetVisibilityTask func(request *GetVisibilityTaskRequest) (*GetVisibilityTaskResponse, error)

+ GetVisibilityTasks func(request *GetVisibilityTasksRequest) (*GetVisibilityTasksResponse, error)

+ RangeCompleteVisibilityTask func(request *RangeCompleteVisibilityTaskRequest) error

type ExecutionStore

+ AddTasks func(request *AddTasksRequest) error

+ CompleteVisibilityTask func(request *CompleteVisibilityTaskRequest) error

+ GetVisibilityTask func(request *GetVisibilityTaskRequest) (*GetVisibilityTaskResponse, error)

+ GetVisibilityTasks func(request *GetVisibilityTasksRequest) (*GetVisibilityTasksResponse, error)

+ RangeCompleteVisibilityTask func(request *RangeCompleteVisibilityTaskRequest) error

+ type GetVisibilityTaskRequest struct

+ ShardID int32

+ TaskID int64

+ type GetVisibilityTaskResponse struct

+ VisibilityTaskInfo *persistencespb.VisibilityTaskInfo

+ type GetVisibilityTasksRequest struct

+ BatchSize int

+ MaxReadLevel int64

+ NextPageToken []byte

+ ReadLevel int64

+ type GetVisibilityTasksResponse struct

+ NextPageToken []byte

+ Tasks []*persistencespb.VisibilityTaskInfo

+ type InternalVisibilityRequestBase struct

+ ExecutionTimestamp int64

+ Memo *commonpb.DataBlob

+ NamespaceID string

+ RunID string

+ SearchAttributes map[string]*commonpb.Payload

+ ShardID int32

+ StartTimestamp int64

+ Status enumspb.WorkflowExecutionStatus

+ TaskID int64

+ TaskQueue string

+ WorkflowID string

+ WorkflowTypeName string

type InternalWorkflowMutation

+ VisibilityTasks []Task

type InternalWorkflowSnapshot

+ VisibilityTasks []Task

+ type RangeCompleteVisibilityTaskRequest struct

+ ExclusiveBeginTaskID int64

+ InclusiveEndTaskID int64

+ type StartExecutionVisibilityTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (t *StartExecutionVisibilityTask) GetTaskID() int64

+ func (t *StartExecutionVisibilityTask) GetType() enumsspb.TaskType

+ func (t *StartExecutionVisibilityTask) GetVersion() int64

+ func (t *StartExecutionVisibilityTask) GetVisibilityTimestamp() time.Time

+ func (t *StartExecutionVisibilityTask) SetTaskID(id int64)

+ func (t *StartExecutionVisibilityTask) SetVersion(version int64)

+ func (t *StartExecutionVisibilityTask) SetVisibilityTimestamp(timestamp time.Time)

+ type UpsertExecutionVisibilityTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (t *UpsertExecutionVisibilityTask) GetTaskID() int64

+ func (t *UpsertExecutionVisibilityTask) GetType() enumsspb.TaskType

+ func (t *UpsertExecutionVisibilityTask) GetVersion() int64

+ func (t *UpsertExecutionVisibilityTask) GetVisibilityTimestamp() time.Time

+ func (t *UpsertExecutionVisibilityTask) SetTaskID(id int64)

+ func (t *UpsertExecutionVisibilityTask) SetVersion(version int64)

+ func (t *UpsertExecutionVisibilityTask) SetVisibilityTimestamp(timestamp time.Time)

type VisibilityManager

+ DeleteWorkflowExecutionV2 func(request *VisibilityDeleteWorkflowExecutionRequest) error

+ RecordWorkflowExecutionClosedV2 func(request *RecordWorkflowExecutionClosedRequest) error

+ RecordWorkflowExecutionStartedV2 func(request *RecordWorkflowExecutionStartedRequest) error

+ UpsertWorkflowExecutionV2 func(request *UpsertWorkflowExecutionRequest) error

+ type VisibilityRequestBase struct

+ Execution commonpb.WorkflowExecution

+ ExecutionTimestamp int64

+ Memo *commonpb.Memo

+ Namespace string

+ NamespaceID string

+ SearchAttributes map[string]*commonpb.Payload

+ ShardID int32

+ StartTimestamp int64

+ Status enumspb.WorkflowExecutionStatus

+ TaskID int64

+ TaskQueue string

+ WorkflowTypeName string

type VisibilityStore

+ DeleteWorkflowExecutionV2 func(request *VisibilityDeleteWorkflowExecutionRequest) error

+ RecordWorkflowExecutionClosedV2 func(request *InternalRecordWorkflowExecutionClosedRequest) error

+ RecordWorkflowExecutionStartedV2 func(request *InternalRecordWorkflowExecutionStartedRequest) error

+ UpsertWorkflowExecutionV2 func(request *InternalUpsertWorkflowExecutionRequest) error

type WorkflowMutation

+ VisibilityTasks []Task

type WorkflowSnapshot

+ VisibilityTasks []Task

Feb 18, 2021 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

Jan 25, 2021 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 30, 2020 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 10, 2020 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 9, 2020 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

+ const EmptyQueueMessageID

+ const MaxQueueMessageID

+ const MinQueueMessageID

type InternalWorkflowMutation

+ DeleteChildExecutionInfos []int64

+ DeleteRequestCancelInfos []int64

+ DeleteSignalInfos []int64

+ DeleteSignalRequestedIDs []string

type QueueMessage

+ Data []byte

+ Encoding string

type WorkflowMutation

+ DeleteChildExecutionInfos []int64

+ DeleteRequestCancelInfos []int64

+ DeleteSignalInfos []int64

+ DeleteSignalRequestedIDs []string

Feb 18, 2021 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

Nov 20, 2020 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

Nov 16, 2020 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

Nov 11, 2020 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

type InternalListConcreteExecutionsResponse

+ States []*InternalWorkflowMutableState

type InternalWorkflowMutableState

+ ExecutionState *persistencespb.WorkflowExecutionState

+ NextEventID int64

type InternalWorkflowMutation

+ ExecutionState *persistencespb.WorkflowExecutionState

+ NextEventID int64

type InternalWorkflowSnapshot

+ ExecutionState *persistencespb.WorkflowExecutionState

+ NextEventID int64

type ListConcreteExecutionsResponse

+ States []*persistencespb.WorkflowMutableState

type PayloadSerializer

+ DeserializeEvents func(data *commonpb.DataBlob) ([]*historypb.HistoryEvent, error)

+ SerializeEvents func(batch []*historypb.HistoryEvent, encodingType enumspb.EncodingType) (*commonpb.DataBlob, error)

type WorkflowMutation

+ ExecutionState *persistencespb.WorkflowExecutionState

+ NextEventID int64

type WorkflowSnapshot

+ ExecutionState *persistencespb.WorkflowExecutionState

+ NextEventID int64

Feb 18, 2021 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

Nov 20, 2020 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 27, 2020 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

Feb 18, 2021 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, 2020 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 14, 2020 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

type ClusterMetadataManager

+ GetClusterMetadata func() (*GetClusterMetadataResponse, error)

+ SaveClusterMetadata func(request *SaveClusterMetadataRequest) (bool, error)

type ClusterMetadataStore

+ GetClusterMetadata func() (*InternalGetClusterMetadataResponse, error)

+ SaveClusterMetadata func(request *InternalSaveClusterMetadataRequest) (bool, error)

+ type GetClusterMetadataResponse struct

+ Version int64

+ type InternalGetClusterMetadataResponse struct

+ ClusterMetadata *serialization.DataBlob

+ Version int64

+ type InternalSaveClusterMetadataRequest struct

+ ClusterMetadata *serialization.DataBlob

+ Version int64

type PayloadSerializer

+ DeserializeClusterMetadata func(data *serialization.DataBlob) (*persistenceblobs.ClusterMetadata, error)

+ SerializeClusterMetadata func(icm *persistenceblobs.ClusterMetadata, encodingType enumspb.EncodingType) (*serialization.DataBlob, error)

+ type SaveClusterMetadataRequest struct

+ Version int64

Feb 18, 2021 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 30, 2020 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 28, 2020 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 22, 2020 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

type InternalUpsertWorkflowExecutionRequest

+ Status enumspb.WorkflowExecutionStatus

type UpsertWorkflowExecutionRequest

+ Status enumspb.WorkflowExecutionStatus

Sep 17, 2020 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 ApplyWorkflowExecutionWritePolicies(info *persistenceblobs.WorkflowExecutionInfo, startVersion int64, ...)

+ func WorkflowExecutionToProto(executionInfo *WorkflowExecutionInfo, startVersion int64, ...) (*persistenceblobs.WorkflowExecutionInfo, ...)

type ReadHistoryBranchByBatchResponse

+ LastEventID int64

type WorkflowExecutionInfo

+ CancelRequestId string

+ CompletionEventBatchId int64

+ EventBranchToken []byte

+ ExecutionState *persistenceblobs.WorkflowExecutionState

+ ExecutionStats *persistenceblobs.ExecutionStats

+ FirstExecutionRunId string

+ InitiatedId int64

+ LastEventTaskId int64

+ LastFirstEventId int64

+ LastUpdatedTime *time.Time

+ NamespaceId string

+ NextEventId int64

+ ParentNamespaceId string

+ ParentRunId string

+ ParentWorkflowId string

+ RetryBackoffCoefficient float64

+ RetryInitialInterval *time.Duration

+ RetryMaximumAttempts int32

+ RetryMaximumInterval *time.Duration

+ RetryNonRetryableErrorTypes []string

+ StartTime *time.Time

+ WorkflowId string

+ WorkflowTaskRequestId string

+ WorkflowTaskScheduleId int64

+ WorkflowTaskStartedId int64

+ func WorkflowExecutionFromProto(info *persistenceblobs.WorkflowExecutionInfo, ...) *WorkflowExecutionInfo

+ func (e *WorkflowExecutionInfo) GetExecutionState() *persistenceblobs.WorkflowExecutionState

+ func (e *WorkflowExecutionInfo) GetRunId() string

Jul 31, 2020 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 GenerateVersionProto(r *persistenceblobs.ReplicationState) *persistenceblobs.ReplicationVersions

type InternalWorkflowExecutionInfo

+ DefaultWorkflowTaskTimeout int64

type WorkflowExecutionInfo

+ DefaultWorkflowTaskTimeout int64

Jul 15, 2020 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

+ const EventStoreVersion

+ var ErrIncompleteMembershipUpsert = errors.New("membership upserts require all fields")

+ var ErrInvalidMembershipExpiry = errors.New("membershipExpiry duration should be atleast 1 second")

+ func BuildHistoryGarbageCleanupInfo(namespaceID, workflowID, runID string) string

+ func InternalWorkflowExecutionInfoToProto(executionInfo *InternalWorkflowExecutionInfo, startVersion int64, ...) (*persistenceblobs.WorkflowExecutionInfo, ...)

+ func IsNopUpsertWorkflowRequest(request *InternalUpsertWorkflowExecutionRequest) bool

+ func NewDataBlobFromProto(blob *commonpb.DataBlob) *serialization.DataBlob

+ func NewHistoryBranchTokenByBranchID(treeID, branchID string) ([]byte, error)

+ func SplitHistoryGarbageCleanupInfo(info string) (namespaceID, workflowID, runID string, err error)

+ func ValidateConflictResolveWorkflowModeState(mode ConflictResolveWorkflowMode, ...) error

+ func ValidateCreateWorkflowModeState(mode CreateWorkflowMode, newWorkflowSnapshot InternalWorkflowSnapshot) error

+ func ValidateCreateWorkflowStateStatus(state enumsspb.WorkflowExecutionState, status enumspb.WorkflowExecutionStatus) error

+ func ValidateUpdateWorkflowModeState(mode UpdateWorkflowMode, currentWorkflowMutation InternalWorkflowMutation, ...) error

+ func ValidateUpdateWorkflowStateStatus(state enumsspb.WorkflowExecutionState, status enumspb.WorkflowExecutionStatus) error

type ActivityInfo

+ LastFailure *failurepb.Failure

+ LastHeartbeatTimeoutVisibilityInSeconds int64

+ NamespaceID string

+ NonRetryableErrorTypes []string

+ TaskQueue string

type ActivityTask

+ NamespaceID string

+ TaskQueue string

type CancelExecutionTask

+ TargetNamespaceID string

type ChildExecutionInfo

+ Namespace string

+ ParentClosePolicy enumspb.ParentClosePolicy

+ type ClusterMember struct

+ HostID uuid.UUID

+ LastHeartbeat time.Time

+ RPCAddress net.IP

+ RPCPort uint16

+ RecordExpiry time.Time

+ Role ServiceType

+ SessionStart time.Time

+ type ClusterMetadataManager interface

+ GetClusterMembers func(request *GetClusterMembersRequest) (*GetClusterMembersResponse, error)

+ GetImmutableClusterMetadata func() (*GetImmutableClusterMetadataResponse, error)

+ GetName func() string

+ InitializeImmutableClusterMetadata func(request *InitializeImmutableClusterMetadataRequest) (*InitializeImmutableClusterMetadataResponse, error)

+ PruneClusterMembership func(request *PruneClusterMembershipRequest) error

+ UpsertClusterMembership func(request *UpsertClusterMembershipRequest) error

+ func NewClusterMetadataManagerImpl(persistence ClusterMetadataStore, logger log.Logger) ClusterMetadataManager

+ func NewClusterMetadataPersistenceMetricsClient(persistence ClusterMetadataManager, metricClient metrics.Client, ...) ClusterMetadataManager

+ func NewClusterMetadataPersistenceRateLimitedClient(persistence ClusterMetadataManager, rateLimiter quotas.Limiter, ...) ClusterMetadataManager

+ type ClusterMetadataStore interface

+ GetClusterMembers func(request *GetClusterMembersRequest) (*GetClusterMembersResponse, error)

+ GetImmutableClusterMetadata func() (*InternalGetImmutableClusterMetadataResponse, error)

+ GetName func() string

+ InitializeImmutableClusterMetadata func(request *InternalInitializeImmutableClusterMetadataRequest) (*InternalInitializeImmutableClusterMetadataResponse, error)

+ PruneClusterMembership func(request *PruneClusterMembershipRequest) error

+ UpsertClusterMembership func(request *UpsertClusterMembershipRequest) error

type CompleteTaskRequest

+ TaskQueue *TaskQueueKey

type CompleteTasksLessThanRequest

+ NamespaceID string

+ TaskQueueName string

type ConflictResolveWorkflowExecutionRequest

+ CurrentWorkflowCAS *CurrentWorkflowCAS

+ Mode ConflictResolveWorkflowMode

+ NewWorkflowSnapshot *WorkflowSnapshot

+ type ConflictResolveWorkflowMode int

+ const ConflictResolveWorkflowModeBypassCurrent

+ const ConflictResolveWorkflowModeUpdateCurrent

type CountWorkflowExecutionsRequest

+ Namespace string

+ NamespaceID string

+ type CreateNamespaceRequest struct

+ IsGlobalNamespace bool

+ Namespace *persistenceblobs.NamespaceDetail

+ type CreateNamespaceResponse struct

+ ID string

type CreateTasksRequest

+ TaskQueueInfo *PersistedTaskQueueInfo

type CreateWorkflowExecutionRequest

+ Mode CreateWorkflowMode

+ type CreateWorkflowMode int

+ const CreateWorkflowModeZombie

+ type CurrentWorkflowCAS struct

+ PrevLastWriteVersion int64

+ PrevRunID string

+ PrevState enumsspb.WorkflowExecutionState

type DeleteCurrentWorkflowExecutionRequest

+ NamespaceID string

+ type DeleteNamespaceByNameRequest struct

+ Name string

+ type DeleteNamespaceRequest struct

+ ID string

+ type DeleteReplicationTaskFromDLQRequest struct

+ SourceClusterName string

+ TaskID int64

+ type DeleteTaskQueueRequest struct

+ RangeID int64

+ TaskQueue *TaskQueueKey

type DeleteWorkflowExecutionRequest

+ NamespaceID string

+ type DeserializationError struct

+ func NewDeserializationError(msg string) *DeserializationError

+ func (e *DeserializationError) Error() string

type ExecutionManager

+ DeleteReplicationTaskFromDLQ func(request *DeleteReplicationTaskFromDLQRequest) error

+ GetReplicationTask func(request *GetReplicationTaskRequest) (*GetReplicationTaskResponse, error)

+ GetReplicationTasksFromDLQ func(request *GetReplicationTasksFromDLQRequest) (*GetReplicationTasksFromDLQResponse, error)

+ GetTimerTask func(request *GetTimerTaskRequest) (*GetTimerTaskResponse, error)

+ GetTransferTask func(request *GetTransferTaskRequest) (*GetTransferTaskResponse, error)

+ ListConcreteExecutions func(request *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)

+ PutReplicationTaskToDLQ func(request *PutReplicationTaskToDLQRequest) error

+ RangeCompleteReplicationTask func(request *RangeCompleteReplicationTaskRequest) error

+ RangeDeleteReplicationTaskFromDLQ func(request *RangeDeleteReplicationTaskFromDLQRequest) error

type ExecutionStore

+ DeleteReplicationTaskFromDLQ func(request *DeleteReplicationTaskFromDLQRequest) error

+ GetReplicationTask func(request *GetReplicationTaskRequest) (*GetReplicationTaskResponse, error)

+ GetReplicationTasksFromDLQ func(request *GetReplicationTasksFromDLQRequest) (*GetReplicationTasksFromDLQResponse, error)

+ GetTimerTask func(request *GetTimerTaskRequest) (*GetTimerTaskResponse, error)

+ GetTransferTask func(request *GetTransferTaskRequest) (*GetTransferTaskResponse, error)

+ ListConcreteExecutions func(request *ListConcreteExecutionsRequest) (*InternalListConcreteExecutionsResponse, error)

+ PutReplicationTaskToDLQ func(request *PutReplicationTaskToDLQRequest) error

+ RangeCompleteReplicationTask func(request *RangeCompleteReplicationTaskRequest) error

+ RangeDeleteReplicationTaskFromDLQ func(request *RangeDeleteReplicationTaskFromDLQRequest) error

+ type GetAllHistoryTreeBranchesRequest struct

+ NextPageToken []byte

+ PageSize int

+ type GetAllHistoryTreeBranchesResponse struct

+ Branches []HistoryBranchDetail

+ NextPageToken []byte

type GetClosedWorkflowExecutionRequest

+ Namespace string

+ NamespaceID string

+ type GetClusterMembersRequest struct

+ HostIDEquals uuid.UUID

+ LastHeartbeatWithin time.Duration

+ NextPageToken []byte

+ PageSize int

+ RPCAddressEquals net.IP

+ RoleEquals ServiceType

+ SessionStartedAfter time.Time

+ type GetClusterMembersResponse struct

+ ActiveMembers []*ClusterMember

+ NextPageToken []byte

type GetCurrentExecutionRequest

+ NamespaceID string

type GetCurrentExecutionResponse

+ Status enumspb.WorkflowExecutionStatus

+ type GetImmutableClusterMetadataResponse struct

+ type GetNamespaceRequest struct

+ ID string

+ Name string

+ type GetNamespaceResponse struct

+ IsGlobalNamespace bool

+ Namespace *persistenceblobs.NamespaceDetail

+ NotificationVersion int64

+ type GetReplicationTaskRequest struct

+ ShardID int32

+ TaskID int64

+ type GetReplicationTaskResponse struct

+ ReplicationTaskInfo *persistenceblobs.ReplicationTaskInfo

+ type GetReplicationTasksFromDLQRequest struct

+ SourceClusterName string

+ func NewGetReplicationTasksFromDLQRequest(sourceClusterName string, readLevel int64, maxReadLevel int64, batchSize int, ...) *GetReplicationTasksFromDLQRequest

+ type GetReplicationTasksFromDLQResponse = GetReplicationTasksResponse

type GetTasksRequest

+ NamespaceID string

+ TaskQueue string

+ type GetTimerTaskRequest struct

+ ShardID int32

+ TaskID int64

+ VisibilityTimestamp time.Time

+ type GetTimerTaskResponse struct

+ TimerTaskInfo *persistenceblobs.TimerTaskInfo

+ type GetTransferTaskRequest struct

+ ShardID int32

+ TaskID int64

+ type GetTransferTaskResponse struct

+ TransferTaskInfo *persistenceblobs.TransferTaskInfo

type GetWorkflowExecutionRequest

+ NamespaceID string

+ type HistoryBranchDetail struct

+ BranchID string

+ ForkTime time.Time

+ Info string

+ TreeID string

type HistoryManager

+ AppendHistoryNodes func(request *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

+ DeleteHistoryBranch func(request *DeleteHistoryBranchRequest) error

+ ForkHistoryBranch func(request *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)

+ GetAllHistoryTreeBranches func(request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)

+ GetHistoryTree func(request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ ReadHistoryBranch func(request *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)

+ ReadHistoryBranchByBatch func(request *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)

+ ReadRawHistoryBranch func(request *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error)

type HistoryStore

+ AppendHistoryNodes func(request *InternalAppendHistoryNodesRequest) error

+ DeleteHistoryBranch func(request *InternalDeleteHistoryBranchRequest) error

+ ForkHistoryBranch func(request *InternalForkHistoryBranchRequest) (*InternalForkHistoryBranchResponse, error)

+ GetAllHistoryTreeBranches func(request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)

+ GetHistoryTree func(request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ ReadHistoryBranch func(request *InternalReadHistoryBranchRequest) (*InternalReadHistoryBranchResponse, error)

+ type InitializeImmutableClusterMetadataRequest struct

+ type InitializeImmutableClusterMetadataResponse struct

+ PersistedImmutableData persistenceblobs.ImmutableClusterMetadata

+ RequestApplied bool

type InternalActivityInfo

+ LastFailure *failurepb.Failure

+ LastHeartbeatTimeoutVisibilityInSeconds int64

+ LastHeartbeatUpdateTime time.Time

+ NamespaceID string

+ NonRetryableErrorTypes []string

+ TaskQueue string

+ func ProtoActivityInfoToInternalActivityInfo(decoded *persistenceblobs.ActivityInfo) *InternalActivityInfo

+ func (v *InternalActivityInfo) ToProto() *persistenceblobs.ActivityInfo

type InternalAppendHistoryEventsRequest

+ NamespaceID string

type InternalChildExecutionInfo

+ Namespace string

+ ParentClosePolicy enumspb.ParentClosePolicy

+ func ProtoChildExecutionInfoToInternal(rowInfo *persistenceblobs.ChildExecutionInfo) *InternalChildExecutionInfo

+ func (v *InternalChildExecutionInfo) ToProto() *persistenceblobs.ChildExecutionInfo

type InternalConflictResolveWorkflowExecutionRequest

+ CurrentWorkflowCAS *CurrentWorkflowCAS

+ Mode ConflictResolveWorkflowMode

+ NewWorkflowSnapshot *InternalWorkflowSnapshot

+ type InternalCreateNamespaceRequest struct

+ ID string

+ IsGlobal bool

+ Name string

+ Namespace *serialization.DataBlob

type InternalCreateWorkflowExecutionRequest

+ Mode CreateWorkflowMode

+ type InternalGetImmutableClusterMetadataResponse struct

+ ImmutableClusterMetadata *serialization.DataBlob

+ type InternalGetNamespaceResponse struct

+ IsGlobal bool

+ Namespace *serialization.DataBlob

+ NotificationVersion int64

+ type InternalInitializeImmutableClusterMetadataRequest struct

+ ImmutableClusterMetadata *serialization.DataBlob

+ type InternalInitializeImmutableClusterMetadataResponse struct

+ PersistedImmutableMetadata *serialization.DataBlob

+ RequestApplied bool

+ type InternalListConcreteExecutionsResponse struct

+ ExecutionInfos []*InternalWorkflowExecutionInfo

+ NextPageToken []byte

+ type InternalListNamespacesResponse struct

+ Namespaces []*InternalGetNamespaceResponse

+ NextPageToken []byte

type InternalReadHistoryBranchRequest

+ LastNodeID int64

+ LastTransactionID int64

type InternalReadHistoryBranchResponse

+ LastNodeID int64

+ LastTransactionID int64

type InternalRecordWorkflowExecutionClosedRequest

+ NamespaceID string

+ TaskQueue string

type InternalRecordWorkflowExecutionStartedRequest

+ NamespaceID string

+ RunTimeout int64

+ TaskQueue string

+ type InternalUpdateNamespaceRequest struct

+ Id string

+ Name string

+ Namespace *serialization.DataBlob

+ NotificationVersion int64

type InternalUpdateWorkflowExecutionRequest

+ Mode UpdateWorkflowMode

+ type InternalUpsertClusterMembershipRequest struct

+ RecordExpiry time.Time

type InternalUpsertWorkflowExecutionRequest

+ NamespaceID string

+ TaskQueue string

type InternalWorkflowExecutionInfo

+ CurrentWorkflowTaskTimeout int32

+ LastUpdateTimestamp time.Time

+ NamespaceID string

+ NonRetryableErrorTypes []string

+ ParentNamespaceID string

+ Status enumspb.WorkflowExecutionStatus

+ StickyTaskQueue string

+ TaskQueue string

+ WorkflowExecutionTimeout int32

+ WorkflowRunTimeout int32

+ WorkflowTaskAttempt int64

+ WorkflowTaskOriginalScheduledTimestamp int64

+ WorkflowTaskRequestID string

+ WorkflowTaskScheduleID int64

+ WorkflowTaskScheduledTimestamp int64

+ WorkflowTaskStartedID int64

+ WorkflowTaskStartedTimestamp int64

+ WorkflowTaskTimeout int32

+ WorkflowTaskVersion int64

+ func ProtoWorkflowExecutionToPartialInternalExecution(info *persistenceblobs.WorkflowExecutionInfo, ...) *InternalWorkflowExecutionInfo

type InternalWorkflowMutableState

+ ActivityInfos map[int64]*InternalActivityInfo

+ Checksum checksum.Checksum

+ VersionHistories *serialization.DataBlob

type InternalWorkflowMutation

+ Checksum checksum.Checksum

+ LastWriteVersion int64

+ StartVersion int64

+ UpsertTimerInfos []*persistenceblobs.TimerInfo

+ VersionHistories *serialization.DataBlob

type InternalWorkflowSnapshot

+ Checksum checksum.Checksum

+ LastWriteVersion int64

+ StartVersion int64

+ VersionHistories *serialization.DataBlob

+ type LeaseTaskQueueRequest struct

+ NamespaceID string

+ RangeID int64

+ TaskQueue string

+ TaskQueueKind enumspb.TaskQueueKind

+ TaskType enumspb.TaskQueueType

+ type LeaseTaskQueueResponse struct

+ TaskQueueInfo *PersistedTaskQueueInfo

+ type ListConcreteExecutionsRequest struct

+ PageSize int

+ PageToken []byte

+ type ListConcreteExecutionsResponse struct

+ ExecutionInfos []*WorkflowExecutionInfo

+ PageToken []byte

+ type ListNamespacesRequest struct

+ NextPageToken []byte

+ PageSize int

+ type ListNamespacesResponse struct

+ Namespaces []*GetNamespaceResponse

+ NextPageToken []byte

+ type ListTaskQueueRequest struct

+ PageSize int

+ PageToken []byte

+ type ListTaskQueueResponse struct

+ Items []*PersistedTaskQueueInfo

+ NextPageToken []byte

type ListWorkflowExecutionsRequest

+ Namespace string

+ NamespaceID string

type ListWorkflowExecutionsRequestV2

+ Namespace string

+ NamespaceID string

type MetadataManager

+ CreateNamespace func(request *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

+ DeleteNamespace func(request *DeleteNamespaceRequest) error

+ DeleteNamespaceByName func(request *DeleteNamespaceByNameRequest) error

+ GetNamespace func(request *GetNamespaceRequest) (*GetNamespaceResponse, error)

+ InitializeSystemNamespaces func(currentClusterName string) error

+ ListNamespaces func(request *ListNamespacesRequest) (*ListNamespacesResponse, error)

+ UpdateNamespace func(request *UpdateNamespaceRequest) error

type MetadataStore

+ CreateNamespace func(request *InternalCreateNamespaceRequest) (*CreateNamespaceResponse, error)

+ DeleteNamespace func(request *DeleteNamespaceRequest) error

+ DeleteNamespaceByName func(request *DeleteNamespaceByNameRequest) error

+ GetNamespace func(request *GetNamespaceRequest) (*InternalGetNamespaceResponse, error)

+ ListNamespaces func(request *ListNamespacesRequest) (*InternalListNamespacesResponse, error)

+ UpdateNamespace func(request *InternalUpdateNamespaceRequest) error

+ type MockNamespaceReplicationQueue struct

+ func NewMockNamespaceReplicationQueue(ctrl *gomock.Controller) *MockNamespaceReplicationQueue

+ func (m *MockNamespaceReplicationQueue) DeleteMessageFromDLQ(messageID int64) error

+ func (m *MockNamespaceReplicationQueue) EXPECT() *MockNamespaceReplicationQueueMockRecorder

+ func (m *MockNamespaceReplicationQueue) GetAckLevels() (map[string]int64, error)

+ func (m *MockNamespaceReplicationQueue) GetDLQAckLevel() (int64, error)

+ func (m *MockNamespaceReplicationQueue) GetMessagesFromDLQ(firstMessageID, lastMessageID int64, pageSize int, pageToken []byte) ([]*repication.ReplicationTask, []byte, error)

+ func (m *MockNamespaceReplicationQueue) GetReplicationMessages(lastMessageID int64, maxCount int) ([]*repication.ReplicationTask, int64, error)

+ func (m *MockNamespaceReplicationQueue) Publish(message interface{}) error

+ func (m *MockNamespaceReplicationQueue) PublishToDLQ(message interface{}) error

+ func (m *MockNamespaceReplicationQueue) RangeDeleteMessagesFromDLQ(firstMessageID, lastMessageID int64) error

+ func (m *MockNamespaceReplicationQueue) Start()

+ func (m *MockNamespaceReplicationQueue) Stop()

+ func (m *MockNamespaceReplicationQueue) UpdateAckLevel(lastProcessedMessageID int64, clusterName string) error

+ func (m *MockNamespaceReplicationQueue) UpdateDLQAckLevel(lastProcessedMessageID int64) error

+ type MockNamespaceReplicationQueueMockRecorder struct

+ func (mr *MockNamespaceReplicationQueueMockRecorder) DeleteMessageFromDLQ(messageID interface{}) *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) GetAckLevels() *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) GetDLQAckLevel() *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) GetMessagesFromDLQ(firstMessageID, lastMessageID, pageSize, pageToken interface{}) *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) GetReplicationMessages(lastMessageID, maxCount interface{}) *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) Publish(message interface{}) *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) PublishToDLQ(message interface{}) *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) RangeDeleteMessagesFromDLQ(firstMessageID, lastMessageID interface{}) *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) Start() *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) Stop() *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) UpdateAckLevel(lastProcessedMessageID, clusterName interface{}) *gomock.Call

+ func (mr *MockNamespaceReplicationQueueMockRecorder) UpdateDLQAckLevel(lastProcessedMessageID interface{}) *gomock.Call

+ type NamespaceReplicationQueue interface

+ DeleteMessageFromDLQ func(messageID int64) error

+ GetAckLevels func() (map[string]int64, error)

+ GetDLQAckLevel func() (int64, error)

+ GetMessagesFromDLQ func(firstMessageID int64, lastMessageID int64, pageSize int, pageToken []byte) ([]*replicationspb.ReplicationTask, []byte, error)

+ GetReplicationMessages func(lastMessageID int64, maxCount int) ([]*replicationspb.ReplicationTask, int64, error)

+ Publish func(message interface{}) error

+ PublishToDLQ func(message interface{}) error

+ RangeDeleteMessagesFromDLQ func(firstMessageID int64, lastMessageID int64) error

+ UpdateAckLevel func(lastProcessedMessageID int64, clusterName string) error

+ UpdateDLQAckLevel func(lastProcessedMessageID int64) error

+ func NewNamespaceReplicationQueue(queue Queue, clusterName string, metricsClient metrics.Client, ...) NamespaceReplicationQueue

type PayloadSerializer

+ DeserializeImmutableClusterMetadata func(data *serialization.DataBlob) (*persistenceblobs.ImmutableClusterMetadata, error)

+ DeserializeVersionHistories func(data *serialization.DataBlob) (*historyspb.VersionHistories, error)

+ SerializeImmutableClusterMetadata func(icm *persistenceblobs.ImmutableClusterMetadata, ...) (*serialization.DataBlob, error)

+ SerializeVersionHistories func(histories *historyspb.VersionHistories, encodingType common.EncodingType) (*serialization.DataBlob, error)

+ type PersistedTaskQueueInfo struct

+ Data *persistenceblobs.TaskQueueInfo

+ RangeID int64

+ type PruneClusterMembershipRequest struct

+ MaxRecordsPruned int

+ type PutReplicationTaskToDLQRequest struct

+ SourceClusterName string

+ TaskInfo *persistenceblobs.ReplicationTaskInfo

+ type Queue interface

+ DeleteMessageFromDLQ func(messageID int64) error

+ DeleteMessagesBefore func(messageID int64) error

+ EnqueueMessage func(messagePayload []byte) error

+ EnqueueMessageToDLQ func(messagePayload []byte) (int64, error)

+ GetAckLevels func() (map[string]int64, error)

+ GetDLQAckLevels func() (map[string]int64, error)

+ RangeDeleteMessagesFromDLQ func(firstMessageID int64, lastMessageID int64) error

+ ReadMessages func(lastMessageID int64, maxCount int) ([]*QueueMessage, error)

+ ReadMessagesFromDLQ func(firstMessageID int64, lastMessageID int64, pageSize int, pageToken []byte) ([]*QueueMessage, []byte, error)

+ UpdateAckLevel func(messageID int64, clusterName string) error

+ UpdateDLQAckLevel func(messageID int64, clusterName string) error

+ func NewQueuePersistenceMetricsClient(persistence Queue, metricClient metrics.Client, logger log.Logger) Queue

+ func NewQueuePersistenceRateLimitedClient(persistence Queue, rateLimiter quotas.Limiter, logger log.Logger) Queue

+ type QueueMessage struct

+ ID int64

+ Payload []byte

+ QueueType QueueType

+ type QueueType int

+ const NamespaceReplicationQueueType

+ type RangeCompleteReplicationTaskRequest struct

+ InclusiveEndTaskID int64

+ type RangeDeleteReplicationTaskFromDLQRequest struct

+ ExclusiveBeginTaskID int64

+ InclusiveEndTaskID int64

+ SourceClusterName string

+ type ReadRawHistoryBranchResponse struct

+ HistoryEventBlobs []*serialization.DataBlob

+ NextPageToken []byte

+ Size int

type RecordWorkflowExecutionClosedRequest

+ Namespace string

+ NamespaceID string

+ TaskQueue string

type RecordWorkflowExecutionStartedRequest

+ Namespace string

+ NamespaceID string

+ RunTimeout int64

+ TaskQueue string

type ReplicationState

+ func (r *ReplicationState) GenerateVersionProto() *persistenceblobs.ReplicationVersions

+ type ReplicationTaskInfoWrapper struct

+ func (d *ReplicationTaskInfoWrapper) GetVisibilityTime() *types.Timestamp

+ type SerializationError struct

+ func NewSerializationError(msg string) *SerializationError

+ func (e *SerializationError) Error() string

+ type ServiceType int

+ const All

+ const Frontend

+ const History

+ const Matching

+ const Worker

+ type ShardInfoWithFailover struct

+ TimerFailoverLevels map[string]TimerFailoverLevel

+ TransferFailoverLevels map[string]TransferFailoverLevel

type SignalExecutionTask

+ TargetNamespaceID string

type StartChildExecutionTask

+ TargetNamespaceID string

type TaskManager

+ DeleteTaskQueue func(request *DeleteTaskQueueRequest) error

+ LeaseTaskQueue func(request *LeaseTaskQueueRequest) (*LeaseTaskQueueResponse, error)

+ ListTaskQueue func(request *ListTaskQueueRequest) (*ListTaskQueueResponse, error)

+ UpdateTaskQueue func(request *UpdateTaskQueueRequest) (*UpdateTaskQueueResponse, error)

+ type TaskQueueKey struct

+ Name string

+ NamespaceID string

+ TaskType enumspb.TaskQueueType

type TimerFailoverLevel

+ NamespaceIDs map[string]struct{}

type TimerInfo

+ TaskStatus int64

type TransferFailoverLevel

+ NamespaceIDs map[string]struct{}

+ type UpdateNamespaceRequest struct

+ Namespace *persistenceblobs.NamespaceDetail

+ NotificationVersion int64

+ type UpdateTaskQueueRequest struct

+ RangeID int64

+ TaskQueueInfo *persistenceblobs.TaskQueueInfo

+ type UpdateTaskQueueResponse struct

type UpdateWorkflowExecutionRequest

+ Mode UpdateWorkflowMode

+ type UpdateWorkflowMode int

+ const UpdateWorkflowModeBypassCurrent

+ const UpdateWorkflowModeUpdateCurrent

+ type UpsertClusterMembershipRequest struct

+ HostID uuid.UUID

+ RPCAddress net.IP

+ RPCPort uint16

+ RecordExpiry time.Duration

+ Role ServiceType

+ SessionStart time.Time

type UpsertWorkflowExecutionRequest

+ Namespace string

+ NamespaceID string

+ TaskQueue string

type VersionHistories

+ CurrentVersionHistoryIndex int

+ Histories []*VersionHistory

+ func NewVersionHistoriesFromProto(input *historyspb.VersionHistories) *VersionHistories

+ func (h *VersionHistories) AddVersionHistory(v *VersionHistory) (bool, int, error)

+ func (h *VersionHistories) Duplicate() *VersionHistories

+ func (h *VersionHistories) FindFirstVersionHistoryIndexByItem(item *VersionHistoryItem) (int, error)

+ func (h *VersionHistories) FindLCAVersionHistoryIndexAndItem(incomingHistory *VersionHistory) (int, *VersionHistoryItem, error)

+ func (h *VersionHistories) GetCurrentVersionHistory() (*VersionHistory, error)

+ func (h *VersionHistories) GetCurrentVersionHistoryIndex() int

+ func (h *VersionHistories) GetVersionHistory(branchIndex int) (*VersionHistory, error)

+ func (h *VersionHistories) IsRebuilt() (bool, error)

+ func (h *VersionHistories) SetCurrentVersionHistoryIndex(index int) error

+ func (h *VersionHistories) ToProto() *historyspb.VersionHistories

type VersionHistory

+ BranchToken []byte

+ Items []*VersionHistoryItem

+ func NewVersionHistoryFromProto(input *historyspb.VersionHistory) *VersionHistory

+ func (v *VersionHistory) AddOrUpdateItem(item *VersionHistoryItem) error

+ func (v *VersionHistory) ContainsItem(item *VersionHistoryItem) bool

+ func (v *VersionHistory) Duplicate() *VersionHistory

+ func (v *VersionHistory) DuplicateUntilLCAItem(lcaItem *VersionHistoryItem) (*VersionHistory, error)

+ func (v *VersionHistory) Equals(input *VersionHistory) bool

+ func (v *VersionHistory) FindLCAItem(remote *VersionHistory) (*VersionHistoryItem, error)

+ func (v *VersionHistory) GetBranchToken() []byte

+ func (v *VersionHistory) GetEventVersion(eventID int64) (int64, error)

+ func (v *VersionHistory) GetFirstItem() (*VersionHistoryItem, error)

+ func (v *VersionHistory) GetLastItem() (*VersionHistoryItem, error)

+ func (v *VersionHistory) IsEmpty() bool

+ func (v *VersionHistory) IsLCAAppendable(item *VersionHistoryItem) bool

+ func (v *VersionHistory) SetBranchToken(inputToken []byte) error

+ func (v *VersionHistory) ToProto() *historyspb.VersionHistory

type VersionHistoryItem

+ EventID int64

+ Version int64

+ func NewVersionHistoryItem(inputEventID int64, inputVersion int64) *VersionHistoryItem

+ func NewVersionHistoryItemFromProto(input *historyspb.VersionHistoryItem) *VersionHistoryItem

+ func (item *VersionHistoryItem) Duplicate() *VersionHistoryItem

+ func (item *VersionHistoryItem) Equals(input *VersionHistoryItem) bool

+ func (item *VersionHistoryItem) GetEventID() int64

+ func (item *VersionHistoryItem) GetVersion() int64

+ func (item *VersionHistoryItem) ToProto() *historyspb.VersionHistoryItem

type VisibilityDeleteWorkflowExecutionRequest

+ NamespaceID string

type VisibilityWorkflowExecutionInfo

+ TaskQueue string

type WorkflowBackoffTimerTask

+ WorkflowBackoffType enumsspb.WorkflowBackoffType

type WorkflowEvents

+ NamespaceID string

type WorkflowExecutionAlreadyStartedError

+ Status enumspb.WorkflowExecutionStatus

type WorkflowExecutionInfo

+ CurrentWorkflowTaskTimeout int32

+ NamespaceID string

+ NonRetryableErrorTypes []string

+ ParentNamespaceID string

+ Status enumspb.WorkflowExecutionStatus

+ StickyTaskQueue string

+ TaskQueue string

+ WorkflowExecutionTimeout int32

+ WorkflowExpirationTime time.Time

+ WorkflowRunTimeout int32

+ WorkflowTaskAttempt int64

+ WorkflowTaskOriginalScheduledTimestamp int64

+ WorkflowTaskRequestID string

+ WorkflowTaskScheduleID int64

+ WorkflowTaskScheduledTimestamp int64

+ WorkflowTaskStartedID int64

+ WorkflowTaskStartedTimestamp int64

+ WorkflowTaskTimeout int32

+ WorkflowTaskVersion int64

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

type WorkflowMutableState

+ Checksum checksum.Checksum

+ VersionHistories *VersionHistories

type WorkflowMutation

+ Checksum checksum.Checksum

+ UpsertTimerInfos []*persistenceblobs.TimerInfo

+ VersionHistories *VersionHistories

type WorkflowSnapshot

+ Checksum checksum.Checksum

+ VersionHistories *VersionHistories

+ type WorkflowTask struct

+ NamespaceID string

+ RecordVisibility bool

+ ScheduleID int64

+ TaskID int64

+ TaskQueue string

+ Version int64

+ VisibilityTimestamp time.Time

+ func (d *WorkflowTask) GetTaskID() int64

+ func (d *WorkflowTask) GetType() enumsspb.TaskType

+ func (d *WorkflowTask) GetVersion() int64

+ func (d *WorkflowTask) GetVisibilityTimestamp() time.Time

+ func (d *WorkflowTask) SetTaskID(id int64)

+ func (d *WorkflowTask) SetVersion(version int64)

+ func (d *WorkflowTask) SetVisibilityTimestamp(timestamp time.Time)

+ type WorkflowTaskTimeoutTask struct

+ EventID int64

+ ScheduleAttempt int64

+ TaskID int64

+ TimeoutType enumspb.TimeoutType

+ Version int64

+ VisibilityTimestamp time.Time

+ func (d *WorkflowTaskTimeoutTask) GetTaskID() int64

+ func (d *WorkflowTaskTimeoutTask) GetType() enumsspb.TaskType

+ func (d *WorkflowTaskTimeoutTask) GetVersion() int64

+ func (d *WorkflowTaskTimeoutTask) GetVisibilityTimestamp() time.Time

+ func (d *WorkflowTaskTimeoutTask) SetTaskID(id int64)

+ func (d *WorkflowTaskTimeoutTask) SetVersion(version int64)

+ func (d *WorkflowTaskTimeoutTask) SetVisibilityTimestamp(t time.Time)

Aug 27, 2019 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 27, 2019 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 26, 2019 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 14, 2019 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 13, 2019 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 12, 2019 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 12, 2019 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

type InternalWorkflowExecutionInfo

+ DecisionOriginalScheduledTimestamp int64

type WorkflowExecutionInfo

+ DecisionOriginalScheduledTimestamp int64

Aug 8, 2019 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 8, 2019 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 6, 2019 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 30, 2019 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

+ type ConflictResolveWorkflowExecutionRequest struct

+ CurrentWorkflowMutation *WorkflowMutation

+ Encoding common.EncodingType

+ PrevLastWriteVersion int64

+ PrevRunID string

+ PrevState int

+ RangeID int64

+ ResetWorkflowSnapshot WorkflowSnapshot

type DomainConfig

+ HistoryArchivalStatus workflow.ArchivalStatus

+ HistoryArchivalURI string

+ VisibilityArchivalStatus workflow.ArchivalStatus

+ VisibilityArchivalURI string

type ExecutionManager

+ ConflictResolveWorkflowExecution func(request *ConflictResolveWorkflowExecutionRequest) error

+ type ExecutionStats struct

+ HistorySize int64

type ExecutionStore

+ ConflictResolveWorkflowExecution func(request *InternalConflictResolveWorkflowExecutionRequest) error

+ type InternalConflictResolveWorkflowExecutionRequest struct

+ CurrentWorkflowMutation *InternalWorkflowMutation

+ PrevLastWriteVersion int64

+ PrevRunID string

+ PrevState int

+ RangeID int64

+ ResetWorkflowSnapshot InternalWorkflowSnapshot

type InternalDomainConfig

+ HistoryArchivalStatus workflow.ArchivalStatus

+ HistoryArchivalURI string

+ VisibilityArchivalStatus workflow.ArchivalStatus

+ VisibilityArchivalURI string

type InternalWorkflowExecutionInfo

+ Memo map[string][]byte

+ type WorkflowEvents struct

+ BranchToken []byte

+ DomainID string

+ Events []*workflow.HistoryEvent

+ RunID string

+ WorkflowID string

type WorkflowExecutionInfo

+ Memo map[string][]byte

type WorkflowMutableState

+ ExecutionStats *ExecutionStats

type WorkflowMutation

+ ExecutionStats *ExecutionStats

type WorkflowSnapshot

+ ExecutionStats *ExecutionStats

Jul 26, 2019 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 24, 2019 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

+ const TransferTaskTypeUpsertWorkflowSearchAttributes

+ func ReadFullPageV2EventsByBatch(historyV2Mgr HistoryV2Manager, req *ReadHistoryBranchRequest) ([]*shared.History, int, []byte, error)

type ActivityInfo

+ LastFailureReason string

+ LastWorkerIdentity string

type CreateWorkflowExecutionRequest

+ NewWorkflowSnapshot WorkflowSnapshot

type InternalActivityInfo

+ LastFailureReason string

+ LastWorkerIdentity string

type InternalCreateWorkflowExecutionRequest

+ NewWorkflowSnapshot InternalWorkflowSnapshot

type InternalResetMutableStateRequest

+ CurrentWorkflowMutation *InternalWorkflowMutation

+ PrevLastWriteVersion int64

+ PrevState int

+ ResetWorkflowSnapshot InternalWorkflowSnapshot

type InternalResetWorkflowExecutionRequest

+ CurrentRunID string

+ CurrentRunNextEventID int64

+ CurrentWorkflowMutation *InternalWorkflowMutation

+ NewWorkflowSnapshot InternalWorkflowSnapshot

type InternalUpdateWorkflowExecutionRequest

+ NewWorkflowSnapshot *InternalWorkflowSnapshot

+ UpdateWorkflowMutation InternalWorkflowMutation

+ type InternalUpsertWorkflowExecutionRequest struct

+ DomainUUID string

+ ExecutionTimestamp int64

+ Memo *DataBlob

+ RunID string

+ SearchAttributes map[string][]byte

+ StartTimestamp int64

+ TaskID int64

+ WorkflowID string

+ WorkflowTimeout int64

+ WorkflowTypeName string

+ type InternalWorkflowMutation struct

+ ClearBufferedEvents bool

+ Condition int64

+ DeleteActivityInfos []int64

+ DeleteChildExecutionInfo *int64

+ DeleteRequestCancelInfo *int64

+ DeleteSignalInfo *int64

+ DeleteSignalRequestedID string

+ DeleteTimerInfos []string

+ ExecutionInfo *InternalWorkflowExecutionInfo

+ NewBufferedEvents *DataBlob

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

+ TimerTasks []Task

+ TransferTasks []Task

+ UpserTimerInfos []*TimerInfo

+ UpsertActivityInfos []*InternalActivityInfo

+ UpsertChildExecutionInfos []*InternalChildExecutionInfo

+ UpsertRequestCancelInfos []*RequestCancelInfo

+ UpsertSignalInfos []*SignalInfo

+ UpsertSignalRequestedIDs []string

+ type InternalWorkflowSnapshot struct

+ ActivityInfos []*InternalActivityInfo

+ ChildExecutionInfos []*InternalChildExecutionInfo

+ Condition int64

+ ExecutionInfo *InternalWorkflowExecutionInfo

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

+ RequestCancelInfos []*RequestCancelInfo

+ SignalInfos []*SignalInfo

+ SignalRequestedIDs []string

+ TimerInfos []*TimerInfo

+ TimerTasks []Task

+ TransferTasks []Task

type ResetMutableStateRequest

+ CurrentWorkflowMutation *WorkflowMutation

+ PrevLastWriteVersion int64

+ PrevState int

+ ResetWorkflowSnapshot WorkflowSnapshot

type ResetWorkflowExecutionRequest

+ CurrentRunID string

+ CurrentRunNextEventID int64

+ CurrentWorkflowMutation *WorkflowMutation

+ NewWorkflowSnapshot WorkflowSnapshot

type UpdateWorkflowExecutionRequest

+ NewWorkflowSnapshot *WorkflowSnapshot

+ UpdateWorkflowMutation WorkflowMutation

+ type UpsertWorkflowExecutionRequest struct

+ Domain string

+ DomainUUID string

+ Execution s.WorkflowExecution

+ ExecutionTimestamp int64

+ Memo *s.Memo

+ SearchAttributes map[string][]byte

+ StartTimestamp int64

+ TaskID int64

+ WorkflowTimeout int64

+ WorkflowTypeName string

+ type UpsertWorkflowSearchAttributesTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (u *UpsertWorkflowSearchAttributesTask) GetTaskID() int64

+ func (u *UpsertWorkflowSearchAttributesTask) GetType() int

+ func (u *UpsertWorkflowSearchAttributesTask) GetVersion() int64

+ func (u *UpsertWorkflowSearchAttributesTask) GetVisibilityTimestamp() time.Time

+ func (u *UpsertWorkflowSearchAttributesTask) SetTaskID(id int64)

+ func (u *UpsertWorkflowSearchAttributesTask) SetVersion(version int64)

+ func (u *UpsertWorkflowSearchAttributesTask) SetVisibilityTimestamp(timestamp time.Time)

type VisibilityManager

+ UpsertWorkflowExecution func(request *UpsertWorkflowExecutionRequest) error

type VisibilityStore

+ UpsertWorkflowExecution func(request *InternalUpsertWorkflowExecutionRequest) error

+ type WorkflowMutation struct

+ ClearBufferedEvents bool

+ Condition int64

+ DeleteActivityInfos []int64

+ DeleteChildExecutionInfo *int64

+ DeleteRequestCancelInfo *int64

+ DeleteSignalInfo *int64

+ DeleteSignalRequestedID string

+ DeleteTimerInfos []string

+ ExecutionInfo *WorkflowExecutionInfo

+ NewBufferedEvents []*workflow.HistoryEvent

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

+ TimerTasks []Task

+ TransferTasks []Task

+ UpserTimerInfos []*TimerInfo

+ UpsertActivityInfos []*ActivityInfo

+ UpsertChildExecutionInfos []*ChildExecutionInfo

+ UpsertRequestCancelInfos []*RequestCancelInfo

+ UpsertSignalInfos []*SignalInfo

+ UpsertSignalRequestedIDs []string

+ type WorkflowSnapshot struct

+ ActivityInfos []*ActivityInfo

+ ChildExecutionInfos []*ChildExecutionInfo

+ Condition int64

+ ExecutionInfo *WorkflowExecutionInfo

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

+ RequestCancelInfos []*RequestCancelInfo

+ SignalInfos []*SignalInfo

+ SignalRequestedIDs []string

+ TimerInfos []*TimerInfo

+ TimerTasks []Task

+ TransferTasks []Task

Jun 17, 2019 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 ValidateCreateWorkflowStateCloseStatus(state int, closeStatus int) error

+ func ValidateUpdateWorkflowStateCloseStatus(state int, closeStatus int) error

type CreateWorkflowExecutionRequest

+ CloseStatus int

+ SearchAttributes map[string][]byte

+ State int

type InternalCreateWorkflowExecutionRequest

+ CloseStatus int

+ SearchAttributes map[string][]byte

+ State int

type InternalRecordWorkflowExecutionClosedRequest

+ SearchAttributes map[string][]byte

type InternalRecordWorkflowExecutionStartedRequest

+ SearchAttributes map[string][]byte

type InternalWorkflowExecutionInfo

+ DecisionScheduledTimestamp int64

+ DecisionStartedTimestamp int64

+ SearchAttributes map[string][]byte

type RecordWorkflowExecutionClosedRequest

+ SearchAttributes map[string][]byte

type RecordWorkflowExecutionStartedRequest

+ SearchAttributes map[string][]byte

type TaskInfo

+ CreatedTime time.Time

+ type TransactionSizeLimitError struct

+ Msg string

+ func (e *TransactionSizeLimitError) Error() string

type VisibilityWorkflowExecutionInfo

+ SearchAttributes map[string]interface{}

type WorkflowExecutionInfo

+ DecisionScheduledTimestamp int64

+ DecisionStartedTimestamp int64

+ SearchAttributes map[string][]byte

May 14, 2019 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

+ const TransferTaskTypeResetWorkflow

+ type CountWorkflowExecutionsRequest struct

+ Domain string

+ DomainUUID string

+ Query string

+ type CountWorkflowExecutionsResponse struct

+ Count int64

+ type DeleteCurrentWorkflowExecutionRequest struct

+ DomainID string

+ RunID string

+ WorkflowID string

type ExecutionManager

+ DeleteCurrentWorkflowExecution func(request *DeleteCurrentWorkflowExecutionRequest) error

type ExecutionStore

+ DeleteCurrentWorkflowExecution func(request *DeleteCurrentWorkflowExecutionRequest) error

+ type InternalCreateDomainRequest struct

+ Config *InternalDomainConfig

+ ConfigVersion int64

+ FailoverVersion int64

+ Info *DomainInfo

+ IsGlobalDomain bool

+ ReplicationConfig *DomainReplicationConfig

+ type InternalDomainConfig struct

+ ArchivalBucket string

+ ArchivalStatus workflow.ArchivalStatus

+ BadBinaries *DataBlob

+ EmitMetric bool

+ Retention int32

+ type InternalGetDomainResponse struct

+ Config *InternalDomainConfig

+ ConfigVersion int64

+ FailoverNotificationVersion int64

+ FailoverVersion int64

+ Info *DomainInfo

+ IsGlobalDomain bool

+ NotificationVersion int64

+ ReplicationConfig *DomainReplicationConfig

+ TableVersion int

+ type InternalListDomainsResponse struct

+ Domains []*InternalGetDomainResponse

+ NextPageToken []byte

+ type InternalUpdateDomainRequest struct

+ Config *InternalDomainConfig

+ ConfigVersion int64

+ FailoverNotificationVersion int64

+ FailoverVersion int64

+ Info *DomainInfo

+ NotificationVersion int64

+ ReplicationConfig *DomainReplicationConfig

+ TableVersion int

type MetadataManager

+ func NewMetadataManagerImpl(persistence MetadataStore, logger log.Logger) MetadataManager

type MetadataStore

+ CreateDomain func(request *InternalCreateDomainRequest) (*CreateDomainResponse, error)

+ DeleteDomain func(request *DeleteDomainRequest) error

+ DeleteDomainByName func(request *DeleteDomainByNameRequest) error

+ GetDomain func(request *GetDomainRequest) (*InternalGetDomainResponse, error)

+ GetMetadata func() (*GetMetadataResponse, error)

+ GetName func() string

+ ListDomains func(request *ListDomainsRequest) (*InternalListDomainsResponse, error)

+ UpdateDomain func(request *InternalUpdateDomainRequest) error

+ type ResetWorkflowTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (a *ResetWorkflowTask) GetTaskID() int64

+ func (a *ResetWorkflowTask) GetType() int

+ func (a *ResetWorkflowTask) GetVersion() int64

+ func (a *ResetWorkflowTask) GetVisibilityTimestamp() time.Time

+ func (a *ResetWorkflowTask) SetTaskID(id int64)

+ func (a *ResetWorkflowTask) SetVersion(version int64)

+ func (a *ResetWorkflowTask) SetVisibilityTimestamp(timestamp time.Time)

+ type VersionHistories struct

+ func NewVersionHistories(histories []VersionHistory) VersionHistories

+ func (h *VersionHistories) AddHistory(item VersionHistoryItem, local VersionHistory, remote VersionHistory) error

+ func (h *VersionHistories) FindLowestCommonVersionHistory(history VersionHistory) (VersionHistoryItem, VersionHistory, error)

+ func (h *VersionHistories) GetHistories() []VersionHistory

+ type VersionHistory struct

+ func NewVersionHistory(items []VersionHistoryItem) VersionHistory

+ func (v *VersionHistory) FindLowestCommonVersionHistoryItem(remote VersionHistory) (VersionHistoryItem, error)

+ func (v *VersionHistory) IsAppendable(item VersionHistoryItem) bool

+ func (v *VersionHistory) Update(item VersionHistoryItem) error

+ type VersionHistoryItem struct

type VisibilityManager

+ CountWorkflowExecutions func(request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ ScanWorkflowExecutions func(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

type VisibilityStore

+ CountWorkflowExecutions func(request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ ScanWorkflowExecutions func(request *ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)

May 8, 2019 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

+ const TransferTaskTypeRecordWorkflowStarted

+ const VisibilityEncoding

+ func GetBeginNodeID(bi shared.HistoryBranch) int64

+ func IsTimeoutError(err error) bool

+ func NewOperationNotSupportErrorForVis() error

type AppendHistoryNodesRequest

+ ShardID *int

+ type CadenceDeserializationError struct

+ func NewCadenceDeserializationError(msg string) *CadenceDeserializationError

+ func (e *CadenceDeserializationError) Error() string

+ type CadenceSerializationError struct

+ func NewCadenceSerializationError(msg string) *CadenceSerializationError

+ func (e *CadenceSerializationError) Error() string

type CompleteForkBranchRequest

+ ShardID *int

type CreateWorkflowExecutionRequest

+ PreviousAutoResetPoints *workflow.ResetPoints

type DeleteHistoryBranchRequest

+ ShardID *int

type DomainConfig

+ BadBinaries workflow.BadBinaries

type ForkHistoryBranchRequest

+ ShardID *int

type GetCurrentExecutionResponse

+ LastWriteVersion int64

type GetHistoryTreeRequest

+ ShardID *int

type InternalAppendHistoryNodesRequest

+ ShardID int

type InternalCompleteForkBranchRequest

+ ShardID int

+ type InternalCreateWorkflowExecutionRequest struct

+ Attempt int32

+ BackoffCoefficient float64

+ BranchToken []byte

+ CreateWorkflowMode int

+ CronSchedule string

+ DecisionScheduleID int64

+ DecisionStartToCloseTimeout int32

+ DecisionStartedID int64

+ DecisionTimeoutValue int32

+ DecisionVersion int64

+ DomainID string

+ EventStoreVersion int32

+ Execution workflow.WorkflowExecution

+ ExecutionContext []byte

+ ExpirationSeconds int32

+ ExpirationTime time.Time

+ HasRetryPolicy bool

+ HistorySize int64

+ InitialInterval int32

+ InitiatedID int64

+ LastEventTaskID int64

+ LastProcessedEvent int64

+ MaximumAttempts int32

+ MaximumInterval int32

+ NextEventID int64

+ NonRetriableErrors []string

+ ParentDomainID string

+ ParentExecution *workflow.WorkflowExecution

+ PreviousAutoResetPoints *DataBlob

+ PreviousLastWriteVersion int64

+ PreviousRunID string

+ RangeID int64

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

+ RequestID string

+ SignalCount int32

+ TaskList string

+ TimerTasks []Task

+ TransferTasks []Task

+ WorkflowTimeout int32

+ WorkflowTypeName string

type InternalDeleteHistoryBranchRequest

+ ShardID int

type InternalForkHistoryBranchRequest

+ ShardID int

+ type InternalGetClosedWorkflowExecutionResponse struct

+ Execution *VisibilityWorkflowExecutionInfo

+ type InternalListWorkflowExecutionsResponse struct

+ Executions []*VisibilityWorkflowExecutionInfo

+ NextPageToken []byte

type InternalReadHistoryBranchRequest

+ ShardID int

+ type InternalRecordWorkflowExecutionClosedRequest struct

+ CloseTimestamp int64

+ DomainUUID string

+ ExecutionTimestamp int64

+ HistoryLength int64

+ Memo *DataBlob

+ RetentionSeconds int64

+ RunID string

+ StartTimestamp int64

+ Status workflow.WorkflowExecutionCloseStatus

+ TaskID int64

+ WorkflowID string

+ WorkflowTypeName string

+ type InternalRecordWorkflowExecutionStartedRequest struct

+ DomainUUID string

+ ExecutionTimestamp int64

+ Memo *DataBlob

+ RunID string

+ StartTimestamp int64

+ TaskID int64

+ WorkflowID string

+ WorkflowTimeout int64

+ WorkflowTypeName string

type InternalResetWorkflowExecutionRequest

+ CurrReplicationTasks []Task

type InternalWorkflowExecutionInfo

+ AutoResetPoints *DataBlob

+ type ListWorkflowExecutionsRequestV2 struct

+ Domain string

+ DomainUUID string

+ NextPageToken []byte

+ PageSize int

+ Query string

+ type PayloadSerializer interface

+ DeserializeBadBinaries func(data *DataBlob) (*workflow.BadBinaries, error)

+ DeserializeBatchEvents func(data *DataBlob) ([]*workflow.HistoryEvent, error)

+ DeserializeEvent func(data *DataBlob) (*workflow.HistoryEvent, error)

+ DeserializeResetPoints func(data *DataBlob) (*workflow.ResetPoints, error)

+ DeserializeVisibilityMemo func(data *DataBlob) (*workflow.Memo, error)

+ SerializeBadBinaries func(event *workflow.BadBinaries, encodingType common.EncodingType) (*DataBlob, error)

+ SerializeBatchEvents func(batch []*workflow.HistoryEvent, encodingType common.EncodingType) (*DataBlob, error)

+ SerializeEvent func(event *workflow.HistoryEvent, encodingType common.EncodingType) (*DataBlob, error)

+ SerializeResetPoints func(event *workflow.ResetPoints, encodingType common.EncodingType) (*DataBlob, error)

+ SerializeVisibilityMemo func(memo *workflow.Memo, encodingType common.EncodingType) (*DataBlob, error)

+ func NewPayloadSerializer() PayloadSerializer

type ReadHistoryBranchRequest

+ ShardID *int

type RecordWorkflowExecutionClosedRequest

+ ExecutionTimestamp int64

+ Memo *s.Memo

+ TaskID int64

type RecordWorkflowExecutionStartedRequest

+ ExecutionTimestamp int64

+ Memo *s.Memo

+ TaskID int64

+ type RecordWorkflowStartedTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (a *RecordWorkflowStartedTask) GetTaskID() int64

+ func (a *RecordWorkflowStartedTask) GetType() int

+ func (a *RecordWorkflowStartedTask) GetVersion() int64

+ func (a *RecordWorkflowStartedTask) GetVisibilityTimestamp() time.Time

+ func (a *RecordWorkflowStartedTask) SetTaskID(id int64)

+ func (a *RecordWorkflowStartedTask) SetVersion(version int64)

+ func (a *RecordWorkflowStartedTask) SetVisibilityTimestamp(timestamp time.Time)

type ResetWorkflowExecutionRequest

+ CurrReplicationTasks []Task

type TaskInfo

+ Expiry time.Time

+ type VisibilityDeleteWorkflowExecutionRequest struct

+ DomainID string

+ RunID string

+ TaskID int64

+ WorkflowID string

type VisibilityManager

+ func NewVisibilityManagerImpl(persistence VisibilityStore, logger log.Logger) VisibilityManager

+ DeleteWorkflowExecution func(request *VisibilityDeleteWorkflowExecutionRequest) error

+ ListWorkflowExecutions func(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

type VisibilityStore

+ DeleteWorkflowExecution func(request *VisibilityDeleteWorkflowExecutionRequest) error

+ GetClosedWorkflowExecution func(request *GetClosedWorkflowExecutionRequest) (*InternalGetClosedWorkflowExecutionResponse, error)

+ GetName func() string

+ ListClosedWorkflowExecutions func(request *ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutionsByStatus func(request *ListClosedWorkflowExecutionsByStatusRequest) (*InternalListWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutionsByType func(request *ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutionsByWorkflowID func(request *ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)

+ ListOpenWorkflowExecutions func(request *ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)

+ ListOpenWorkflowExecutionsByType func(request *ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)

+ ListOpenWorkflowExecutionsByWorkflowID func(request *ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)

+ ListWorkflowExecutions func(request *ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)

+ RecordWorkflowExecutionClosed func(request *InternalRecordWorkflowExecutionClosedRequest) error

+ RecordWorkflowExecutionStarted func(request *InternalRecordWorkflowExecutionStartedRequest) error

+ type VisibilityWorkflowExecutionInfo struct

+ CloseTime time.Time

+ ExecutionTime time.Time

+ HistoryLength int64

+ Memo *DataBlob

+ RunID string

+ StartTime time.Time

+ Status *workflow.WorkflowExecutionCloseStatus

+ TypeName string

+ WorkflowID string

type WorkflowExecutionInfo

+ AutoResetPoints *workflow.ResetPoints

Mar 12, 2019 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

Mar 8, 2019 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

+ const UnknownNumRowsAffected

+ type CompleteTasksLessThanRequest struct

+ DomainID string

+ Limit int

+ TaskID int64

+ TaskListName string

+ TaskType int

type CreateWorkflowExecutionRequest

+ LastEventTaskID int64

+ type DeleteTaskListRequest struct

+ DomainID string

+ RangeID int64

+ TaskListName string

+ TaskListType int

type InternalWorkflowExecutionInfo

+ LastEventTaskID int64

type LeaseTaskListRequest

+ RangeID int64

+ type ListTaskListRequest struct

+ PageSize int

+ PageToken []byte

+ type ListTaskListResponse struct

+ Items []TaskListInfo

+ NextPageToken []byte

type TaskListInfo

+ Expiry time.Time

+ LastUpdated time.Time

type TaskManager

+ CompleteTasksLessThan func(request *CompleteTasksLessThanRequest) (int, error)

+ DeleteTaskList func(request *DeleteTaskListRequest) error

+ ListTaskList func(request *ListTaskListRequest) (*ListTaskListResponse, error)

type WorkflowExecutionInfo

+ LastEventTaskID int64

Feb 19, 2019 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 ReadFullPageV2Events(historyV2Mgr HistoryV2Manager, req *ReadHistoryBranchRequest) ([]*shared.HistoryEvent, int, []byte, error)

Feb 12, 2019 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

+ const TaskTypeArchiveHistoryEvent

+ func DeleteWorkflowExecutionHistoryV2(historyV2Mgr HistoryV2Manager, branchToken []byte, logger bark.Logger) error

+ func NewHistoryBranchTokenFromAnother(branchID string, anotherToken []byte) ([]byte, error)

type ActivityInfo

+ ScheduledEventBatchID int64

type AppendHistoryNodesRequest

+ Info string

+ type ArchiveHistoryEventTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (a *ArchiveHistoryEventTask) GetTaskID() int64

+ func (a *ArchiveHistoryEventTask) GetType() int

+ func (a *ArchiveHistoryEventTask) GetVersion() int64

+ func (a *ArchiveHistoryEventTask) GetVisibilityTimestamp() time.Time

+ func (a *ArchiveHistoryEventTask) SetTaskID(id int64)

+ func (a *ArchiveHistoryEventTask) SetVersion(version int64)

+ func (a *ArchiveHistoryEventTask) SetVisibilityTimestamp(timestamp time.Time)

type ChildExecutionInfo

+ DomainName string

+ InitiatedEventBatchID int64

+ StartedRunID string

+ StartedWorkflowID string

+ WorkflowTypeName string

+ type CompleteForkBranchRequest struct

+ BranchToken []byte

+ Success bool

type DecisionTask

+ RecordVisibility bool

type ExecutionManager

+ ResetWorkflowExecution func(request *ResetWorkflowExecutionRequest) error

type ExecutionStore

+ ResetWorkflowExecution func(request *InternalResetWorkflowExecutionRequest) error

type ForkHistoryBranchRequest

+ Info string

+ type ForkingInProgressBranch struct

+ BranchID string

+ ForkTime time.Time

+ Info string

type GetClosedWorkflowExecutionRequest

+ Domain string

type GetHistoryTreeRequest

+ BranchToken []byte

type GetHistoryTreeResponse

+ ForkingInProgressBranches []ForkingInProgressBranch

type HistoryReplicationTask

+ ResetWorkflow bool

type HistoryV2Manager

+ CompleteForkBranch func(request *CompleteForkBranchRequest) error

type HistoryV2Store

+ CompleteForkBranch func(request *InternalCompleteForkBranchRequest) error

type InternalActivityInfo

+ ScheduledEventBatchID int64

type InternalAppendHistoryNodesRequest

+ Info string

type InternalChildExecutionInfo

+ DomainName string

+ InitiatedEventBatchID int64

+ StartedRunID string

+ StartedWorkflowID string

+ WorkflowTypeName string

+ type InternalCompleteForkBranchRequest struct

+ BranchInfo workflow.HistoryBranch

+ Success bool

type InternalForkHistoryBranchRequest

+ Info string

+ type InternalResetWorkflowExecutionRequest struct

+ BaseRunID string

+ BaseRunNextEventID int64

+ Condition int64

+ CurrExecutionInfo *InternalWorkflowExecutionInfo

+ CurrReplicationState *ReplicationState

+ CurrTimerTasks []Task

+ CurrTransferTasks []Task

+ InsertActivityInfos []*InternalActivityInfo

+ InsertChildExecutionInfos []*InternalChildExecutionInfo

+ InsertExecutionInfo *InternalWorkflowExecutionInfo

+ InsertReplicationState *ReplicationState

+ InsertReplicationTasks []Task

+ InsertRequestCancelInfos []*RequestCancelInfo

+ InsertSignalInfos []*SignalInfo

+ InsertSignalRequestedIDs []string

+ InsertTimerInfos []*TimerInfo

+ InsertTimerTasks []Task

+ InsertTransferTasks []Task

+ PrevRunState int

+ PrevRunVersion int64

+ RangeID int64

+ UpdateCurr bool

type InternalWorkflowExecutionInfo

+ CompletionEventBatchID int64

type ReplicationTaskInfo

+ ResetWorkflow bool

+ type ResetWorkflowExecutionRequest struct

+ BaseRunID string

+ BaseRunNextEventID int64

+ Condition int64

+ CurrExecutionInfo *WorkflowExecutionInfo

+ CurrReplicationState *ReplicationState

+ CurrTimerTasks []Task

+ CurrTransferTasks []Task

+ Encoding common.EncodingType

+ InsertActivityInfos []*ActivityInfo

+ InsertChildExecutionInfos []*ChildExecutionInfo

+ InsertExecutionInfo *WorkflowExecutionInfo

+ InsertReplicationState *ReplicationState

+ InsertReplicationTasks []Task

+ InsertRequestCancelInfos []*RequestCancelInfo

+ InsertSignalInfos []*SignalInfo

+ InsertSignalRequestedIDs []string

+ InsertTimerInfos []*TimerInfo

+ InsertTimerTasks []Task

+ InsertTransferTasks []Task

+ PrevRunState int

+ PrevRunVersion int64

+ RangeID int64

+ UpdateCurr bool

type TransferTaskInfo

+ RecordVisibility bool

type VisibilityManager

+ func NewElasticSearchVisibilityManager(esClient es.Client, index string, logger bark.Logger) VisibilityManager

+ func NewVisibilityManagerWrapper(visibilityManager, esVisibilityManager VisibilityManager, ...) VisibilityManager

type WorkflowExecutionInfo

+ CompletionEventBatchID int64

Jan 18, 2019 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

Jan 7, 2019 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

+ const EventStoreVersionV2

+ const TaskTypeWorkflowBackoffTimer

+ const WorkflowBackoffTimeoutTypeCron

+ const WorkflowBackoffTimeoutTypeRetry

+ var ErrPersistenceLimitExceededForList = &workflow.ServiceBusyError

+ func NewHistoryBranchToken(treeID string) ([]byte, error)

type ActivityInfo

+ LastHeartbeatTimeoutVisibility int64

+ type AppendHistoryNodesRequest struct

+ BranchToken []byte

+ Encoding common.EncodingType

+ Events []*workflow.HistoryEvent

+ IsNewBranch bool

+ TransactionID int64

+ type AppendHistoryNodesResponse struct

+ Size int

type BufferedReplicationTask

+ EventStoreVersion int32

+ NewRunEventStoreVersion int32

type CreateWorkflowExecutionRequest

+ BranchToken []byte

+ CronSchedule string

+ EventStoreVersion int32

+ ExpirationSeconds int32

+ SignalCount int32

+ type DeleteHistoryBranchRequest struct

+ BranchToken []byte

type DomainConfig

+ ArchivalBucket string

+ ArchivalStatus workflow.ArchivalStatus

type ExecutionManager

+ GetShardID func() int

type ExecutionStore

+ GetShardID func() int

+ type ForkHistoryBranchRequest struct

+ ForkBranchToken []byte

+ ForkNodeID int64

+ type ForkHistoryBranchResponse struct

+ NewBranchToken []byte

+ type GetHistoryTreeRequest struct

+ TreeID string

+ type GetHistoryTreeResponse struct

+ Branches []*workflow.HistoryBranch

+ type GetWorkflowExecutionHistoryByBatchResponse struct

+ History []*workflow.History

+ LastFirstEventID int64

+ NextPageToken []byte

+ Size int

type HistoryManager

+ GetWorkflowExecutionHistoryByBatch func(request *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryByBatchResponse, error)

type HistoryReplicationTask

+ BranchToken []byte

+ EventStoreVersion int32

+ NewRunBranchToken []byte

+ NewRunEventStoreVersion int32

+ type HistoryV2Manager interface

+ AppendHistoryNodes func(request *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

+ DeleteHistoryBranch func(request *DeleteHistoryBranchRequest) error

+ ForkHistoryBranch func(request *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)

+ GetHistoryTree func(request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ GetName func() string

+ ReadHistoryBranch func(request *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)

+ ReadHistoryBranchByBatch func(request *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)

+ func NewHistoryV2ManagerImpl(persistence HistoryV2Store, logger bark.Logger) HistoryV2Manager

+ func NewHistoryV2PersistenceMetricsClient(persistence HistoryV2Manager, metricClient metrics.Client, logger bark.Logger) HistoryV2Manager

+ func NewHistoryV2PersistenceRateLimitedClient(persistence HistoryV2Manager, rateLimiter common.TokenBucket, ...) HistoryV2Manager

+ type HistoryV2Store interface

+ AppendHistoryNodes func(request *InternalAppendHistoryNodesRequest) error

+ DeleteHistoryBranch func(request *InternalDeleteHistoryBranchRequest) error

+ ForkHistoryBranch func(request *InternalForkHistoryBranchRequest) (*InternalForkHistoryBranchResponse, error)

+ GetHistoryTree func(request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ GetName func() string

+ ReadHistoryBranch func(request *InternalReadHistoryBranchRequest) (*InternalReadHistoryBranchResponse, error)

type InternalActivityInfo

+ LastHeartbeatTimeoutVisibility int64

+ type InternalAppendHistoryNodesRequest struct

+ BranchInfo workflow.HistoryBranch

+ Events *DataBlob

+ IsNewBranch bool

+ NodeID int64

+ TransactionID int64

type InternalBufferedReplicationTask

+ EventStoreVersion int32

+ NewRunEventStoreVersion int32

+ type InternalDeleteHistoryBranchRequest struct

+ BranchInfo workflow.HistoryBranch

+ type InternalForkHistoryBranchRequest struct

+ ForkBranchInfo workflow.HistoryBranch

+ ForkNodeID int64

+ NewBranchID string

+ type InternalForkHistoryBranchResponse struct

+ NewBranchInfo workflow.HistoryBranch

+ type InternalReadHistoryBranchRequest struct

+ BranchID string

+ MaxNodeID int64

+ MinNodeID int64

+ NextPageToken []byte

+ PageSize int

+ TreeID string

+ type InternalReadHistoryBranchResponse struct

+ History []*DataBlob

+ NextPageToken []byte

type InternalWorkflowExecutionInfo

+ BranchToken []byte

+ CronSchedule string

+ EventStoreVersion int32

+ ExpirationSeconds int32

+ SignalCount int32

+ type InvalidPersistenceRequestError struct

+ Msg string

+ func (e *InvalidPersistenceRequestError) Error() string

type ListWorkflowExecutionsRequest

+ Domain string

+ type ReadHistoryBranchByBatchResponse struct

+ History []*workflow.History

+ LastFirstEventID int64

+ NextPageToken []byte

+ Size int

+ type ReadHistoryBranchRequest struct

+ BranchToken []byte

+ MaxEventID int64

+ MinEventID int64

+ NextPageToken []byte

+ PageSize int

+ type ReadHistoryBranchResponse struct

+ HistoryEvents []*workflow.HistoryEvent

+ LastFirstEventID int64

+ NextPageToken []byte

+ Size int

type ReplicationTaskInfo

+ BranchToken []byte

+ EventStoreVersion int32

+ NewRunBranchToken []byte

+ NewRunEventStoreVersion int32

type VisibilityManager

+ func NewVisibilitySamplingClient(persistence VisibilityManager, config *config.SamplingConfig, ...) VisibilityManager

+ type WorkflowBackoffTimerTask struct

+ EventID int64

+ TaskID int64

+ TimeoutType int

+ Version int64

+ VisibilityTimestamp time.Time

+ func (r *WorkflowBackoffTimerTask) GetTaskID() int64

+ func (r *WorkflowBackoffTimerTask) GetType() int

+ func (r *WorkflowBackoffTimerTask) GetVersion() int64

+ func (r *WorkflowBackoffTimerTask) GetVisibilityTimestamp() time.Time

+ func (r *WorkflowBackoffTimerTask) SetTaskID(id int64)

+ func (r *WorkflowBackoffTimerTask) SetVersion(version int64)

+ func (r *WorkflowBackoffTimerTask) SetVisibilityTimestamp(t time.Time)

type WorkflowExecutionInfo

+ BranchToken []byte

+ CronSchedule string

+ EventStoreVersion int32

+ ExpirationSeconds int32

+ SignalCount int32

+ func (e *WorkflowExecutionInfo) GetCurrentBranch() []byte

+ func (e *WorkflowExecutionInfo) IncreaseHistorySize(delta int64)

+ func (e *WorkflowExecutionInfo) IncreaseNextEventID()

+ func (e *WorkflowExecutionInfo) SetHistorySize(size int64)

+ func (e *WorkflowExecutionInfo) SetLastFirstEventID(id int64)

+ func (e *WorkflowExecutionInfo) SetNextEventID(id int64)

Oct 19, 2018 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

+ const CreateWorkflowModeBrandNew

+ const CreateWorkflowModeContinueAsNew

+ const CreateWorkflowModeWorkflowIDReuse

+ const InitialFailoverNotificationVersion

+ const ReplicationTaskTypeSyncActivity

+ const TaskTypeActivityRetryTimer

+ const TaskTypeWorkflowRetryTimer

+ const TransferTaskTransferTargetRunID

+ const TransferTaskTransferTargetWorkflowID

+ func DBTimestampToUnixNano(milliseconds int64) int64

+ func FromDataBlob(blob *DataBlob) ([]byte, string)

+ func SerializeClusterConfigs(replicationConfigs []*ClusterReplicationConfig) []map[string]interface

+ func UnixNanoToDBTimestamp(timestamp int64) int64

+ type ActivityRetryTimerTask struct

+ Attempt int32

+ EventID int64

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (r *ActivityRetryTimerTask) GetTaskID() int64

+ func (r *ActivityRetryTimerTask) GetType() int

+ func (r *ActivityRetryTimerTask) GetVersion() int64

+ func (r *ActivityRetryTimerTask) GetVisibilityTimestamp() time.Time

+ func (r *ActivityRetryTimerTask) SetTaskID(id int64)

+ func (r *ActivityRetryTimerTask) SetVersion(version int64)

+ func (r *ActivityRetryTimerTask) SetVisibilityTimestamp(t time.Time)

type AppendHistoryEventsRequest

+ Encoding common.EncodingType

+ EventBatchVersion int64

+ type AppendHistoryEventsResponse struct

+ Size int

type ClusterReplicationConfig

+ func DeserializeClusterConfigs(replicationConfigs []map[string]interface{}) []*ClusterReplicationConfig

type CreateWorkflowExecutionRequest

+ Attempt int32

+ BackoffCoefficient float64

+ CreateWorkflowMode int

+ ExpirationTime time.Time

+ HasRetryPolicy bool

+ HistorySize int64

+ InitialInterval int32

+ MaximumAttempts int32

+ MaximumInterval int32

+ NonRetriableErrors []string

+ PreviousLastWriteVersion int64

+ type CurrentWorkflowConditionFailedError struct

+ Msg string

+ func (e *CurrentWorkflowConditionFailedError) Error() string

+ type DataBlob struct

+ Data []byte

+ Encoding common.EncodingType

+ func NewDataBlob(data []byte, encodingType common.EncodingType) *DataBlob

+ func (d *DataBlob) GetEncoding() common.EncodingType

type ExecutionManager

+ func NewExecutionManagerImpl(persistence ExecutionStore, logger bark.Logger) ExecutionManager

+ GetName func() string

+ RangeCompleteTimerTask func(request *RangeCompleteTimerTaskRequest) error

+ RangeCompleteTransferTask func(request *RangeCompleteTransferTaskRequest) error

type ExecutionManagerFactory

+ NewExecutionManager func(shardID int) (ExecutionManager, error)

+ type ExecutionStore interface

+ CompleteReplicationTask func(request *CompleteReplicationTaskRequest) error

+ CompleteTimerTask func(request *CompleteTimerTaskRequest) error

+ CompleteTransferTask func(request *CompleteTransferTaskRequest) error

+ CreateWorkflowExecution func(request *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)

+ DeleteWorkflowExecution func(request *DeleteWorkflowExecutionRequest) error

+ GetCurrentExecution func(request *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)

+ GetName func() string

+ GetReplicationTasks func(request *GetReplicationTasksRequest) (*GetReplicationTasksResponse, error)

+ GetTimerIndexTasks func(request *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)

+ GetTransferTasks func(request *GetTransferTasksRequest) (*GetTransferTasksResponse, error)

+ GetWorkflowExecution func(request *GetWorkflowExecutionRequest) (*InternalGetWorkflowExecutionResponse, error)

+ RangeCompleteTimerTask func(request *RangeCompleteTimerTaskRequest) error

+ RangeCompleteTransferTask func(request *RangeCompleteTransferTaskRequest) error

+ ResetMutableState func(request *InternalResetMutableStateRequest) error

+ UpdateWorkflowExecution func(request *InternalUpdateWorkflowExecutionRequest) error

type GetWorkflowExecutionHistoryResponse

+ History *workflow.History

+ LastFirstEventID int64

+ Size int

type GetWorkflowExecutionResponse

+ MutableStateStats *MutableStateStats

type HistoryDeserializationError

+ func NewHistoryDeserializationError(msg string) *HistoryDeserializationError

type HistoryManager

+ func NewHistoryManagerImpl(persistence HistoryStore, logger bark.Logger) HistoryManager

+ GetName func() string

type HistorySerializationError

+ func NewHistorySerializationError(msg string) *HistorySerializationError

type HistorySerializer

+ func NewHistorySerializer() HistorySerializer

+ DeserializeBatchEvents func(data *DataBlob) ([]*workflow.HistoryEvent, error)

+ DeserializeEvent func(data *DataBlob) (*workflow.HistoryEvent, error)

+ SerializeBatchEvents func(batch []*workflow.HistoryEvent, encodingType common.EncodingType) (*DataBlob, error)

+ SerializeEvent func(event *workflow.HistoryEvent, encodingType common.EncodingType) (*DataBlob, error)

+ type HistoryStore interface

+ AppendHistoryEvents func(request *InternalAppendHistoryEventsRequest) error

+ DeleteWorkflowExecutionHistory func(request *DeleteWorkflowExecutionHistoryRequest) error

+ GetName func() string

+ GetWorkflowExecutionHistory func(request *InternalGetWorkflowExecutionHistoryRequest) (*InternalGetWorkflowExecutionHistoryResponse, error)

+ type InternalActivityInfo struct

+ ActivityID string

+ Attempt int32

+ BackoffCoefficient float64

+ CancelRequestID int64

+ CancelRequested bool

+ Details []byte

+ DomainID string

+ ExpirationTime time.Time

+ HasRetryPolicy bool

+ HeartbeatTimeout int32

+ InitialInterval int32

+ LastHeartBeatUpdatedTime time.Time

+ LastTimeoutVisibility int64

+ MaximumAttempts int32

+ MaximumInterval int32

+ NonRetriableErrors []string

+ RequestID string

+ ScheduleID int64

+ ScheduleToCloseTimeout int32

+ ScheduleToStartTimeout int32

+ ScheduledEvent *DataBlob

+ ScheduledTime time.Time

+ StartToCloseTimeout int32

+ StartedEvent *DataBlob

+ StartedID int64

+ StartedIdentity string

+ StartedTime time.Time

+ TaskList string

+ TimerTaskStatus int32

+ Version int64

+ type InternalAppendHistoryEventsRequest struct

+ DomainID string

+ EventBatchVersion int64

+ Events *DataBlob

+ Execution workflow.WorkflowExecution

+ FirstEventID int64

+ Overwrite bool

+ RangeID int64

+ TransactionID int64

+ type InternalBufferedReplicationTask struct

+ FirstEventID int64

+ History *DataBlob

+ NewRunHistory *DataBlob

+ NextEventID int64

+ Version int64

+ type InternalChildExecutionInfo struct

+ CreateRequestID string

+ InitiatedEvent DataBlob

+ InitiatedID int64

+ StartedEvent *DataBlob

+ StartedID int64

+ Version int64

+ type InternalGetWorkflowExecutionHistoryRequest struct

+ DomainID string

+ Execution workflow.WorkflowExecution

+ FirstEventID int64

+ LastEventBatchVersion int64

+ NextEventID int64

+ NextPageToken []byte

+ PageSize int

+ type InternalGetWorkflowExecutionHistoryResponse struct

+ History []*DataBlob

+ LastEventBatchVersion int64

+ NextPageToken []byte

+ type InternalGetWorkflowExecutionResponse struct

+ State *InternalWorkflowMutableState

+ type InternalResetMutableStateRequest struct

+ Condition int64

+ ExecutionInfo *InternalWorkflowExecutionInfo

+ InsertActivityInfos []*InternalActivityInfo

+ InsertChildExecutionInfos []*InternalChildExecutionInfo

+ InsertRequestCancelInfos []*RequestCancelInfo

+ InsertSignalInfos []*SignalInfo

+ InsertSignalRequestedIDs []string

+ InsertTimerInfos []*TimerInfo

+ PrevRunID string

+ RangeID int64

+ ReplicationState *ReplicationState

+ type InternalUpdateWorkflowExecutionRequest struct

+ ClearBufferedEvents bool

+ Condition int64

+ ContinueAsNew *CreateWorkflowExecutionRequest

+ DeleteActivityInfos []int64

+ DeleteBufferedReplicationTask *int64

+ DeleteChildExecutionInfo *int64

+ DeleteRequestCancelInfo *int64

+ DeleteSignalInfo *int64

+ DeleteSignalRequestedID string

+ DeleteTimerInfos []string

+ DeleteTimerTask Task

+ ExecutionInfo *InternalWorkflowExecutionInfo

+ FinishExecution bool

+ FinishedExecutionTTL int32

+ NewBufferedEvents *DataBlob

+ NewBufferedReplicationTask *InternalBufferedReplicationTask

+ RangeID int64

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

+ TimerTasks []Task

+ TransferTasks []Task

+ UpserTimerInfos []*TimerInfo

+ UpsertActivityInfos []*InternalActivityInfo

+ UpsertChildExecutionInfos []*InternalChildExecutionInfo

+ UpsertRequestCancelInfos []*RequestCancelInfo

+ UpsertSignalInfos []*SignalInfo

+ UpsertSignalRequestedIDs []string

+ type InternalWorkflowExecutionInfo struct

+ Attempt int32

+ BackoffCoefficient float64

+ CancelRequestID string

+ CancelRequested bool

+ ClientFeatureVersion string

+ ClientImpl string

+ ClientLibraryVersion string

+ CloseStatus int

+ CompletionEvent *DataBlob

+ CreateRequestID string

+ DecisionAttempt int64

+ DecisionRequestID string

+ DecisionScheduleID int64

+ DecisionStartedID int64

+ DecisionTimeout int32

+ DecisionTimeoutValue int32

+ DecisionTimestamp int64

+ DecisionVersion int64

+ DomainID string

+ ExecutionContext []byte

+ ExpirationTime time.Time

+ HasRetryPolicy bool

+ HistorySize int64

+ InitialInterval int32

+ InitiatedID int64

+ LastFirstEventID int64

+ LastProcessedEvent int64

+ LastUpdatedTimestamp time.Time

+ MaximumAttempts int32

+ MaximumInterval int32

+ NextEventID int64

+ NonRetriableErrors []string

+ ParentDomainID string

+ ParentRunID string

+ ParentWorkflowID string

+ RunID string

+ StartTimestamp time.Time

+ State int

+ StickyScheduleToStartTimeout int32

+ StickyTaskList string

+ TaskList string

+ WorkflowID string

+ WorkflowTimeout int32

+ WorkflowTypeName string

+ type InternalWorkflowMutableState struct

+ ActivitInfos map[int64]*InternalActivityInfo

+ BufferedEvents []*DataBlob

+ BufferedReplicationTasks map[int64]*InternalBufferedReplicationTask

+ ChildExecutionInfos map[int64]*InternalChildExecutionInfo

+ ExecutionInfo *InternalWorkflowExecutionInfo

+ ReplicationState *ReplicationState

+ RequestCancelInfos map[int64]*RequestCancelInfo

+ SignalInfos map[int64]*SignalInfo

+ SignalRequestedIDs map[string]struct{}

+ TimerInfos map[string]*TimerInfo

type MetadataManager

+ GetName func() string

+ type MetadataStore = MetadataManager

+ type MutableStateStats struct

+ ActivityInfoCount int

+ ActivityInfoSize int

+ BufferedEventsCount int

+ BufferedEventsSize int

+ BufferedReplicationTasksCount int

+ BufferedReplicationTasksSize int

+ ChildInfoCount int

+ ChildInfoSize int

+ ExecutionInfoSize int

+ MutableStateSize int

+ RequestCancelInfoCount int

+ SignalInfoCount int

+ SignalInfoSize int

+ TimerInfoCount int

+ TimerInfoSize int

+ type MutableStateUpdateSessionStats struct

+ ActivityInfoCount int

+ ActivityInfoSize int

+ BufferedEventsSize int

+ BufferedReplicationTasksSize int

+ ChildInfoCount int

+ ChildInfoSize int

+ DeleteActivityInfoCount int

+ DeleteChildInfoCount int

+ DeleteRequestCancelInfoCount int

+ DeleteSignalInfoCount int

+ DeleteTimerInfoCount int

+ ExecutionInfoSize int

+ MutableStateSize int

+ RequestCancelInfoCount int

+ SignalInfoCount int

+ SignalInfoSize int

+ TimerInfoCount int

+ TimerInfoSize int

+ type RangeCompleteTimerTaskRequest struct

+ ExclusiveEndTimestamp time.Time

+ InclusiveBeginTimestamp time.Time

+ type RangeCompleteTransferTaskRequest struct

+ ExclusiveBeginTaskID int64

+ InclusiveEndTaskID int64

type RecordWorkflowExecutionClosedRequest

+ Domain string

type RecordWorkflowExecutionStartedRequest

+ Domain string

type ReplicationTaskInfo

+ ScheduledID int64

type ResetMutableStateRequest

+ Encoding common.EncodingType

+ PrevRunID string

type ShardManager

+ GetName func() string

+ type ShardStore = ShardManager

+ type SyncActivityTask struct

+ ScheduledID int64

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (a *SyncActivityTask) GetTaskID() int64

+ func (a *SyncActivityTask) GetType() int

+ func (a *SyncActivityTask) GetVersion() int64

+ func (a *SyncActivityTask) GetVisibilityTimestamp() time.Time

+ func (a *SyncActivityTask) SetTaskID(id int64)

+ func (a *SyncActivityTask) SetVersion(version int64)

+ func (a *SyncActivityTask) SetVisibilityTimestamp(timestamp time.Time)

type TaskManager

+ GetName func() string

+ type TaskStore = TaskManager

type TimerFailoverLevel

+ StartTime time.Time

type TransferFailoverLevel

+ StartTime time.Time

type UpdateWorkflowExecutionRequest

+ Encoding common.EncodingType

+ type UpdateWorkflowExecutionResponse struct

+ MutableStateUpdateSessionStats *MutableStateUpdateSessionStats

type VisibilityManager

+ GetName func() string

+ type VisibilityStore = VisibilityManager

type WorkflowExecutionAlreadyStartedError

+ LastWriteVersion int64

type WorkflowExecutionInfo

+ Attempt int32

+ BackoffCoefficient float64

+ ExpirationTime time.Time

+ HasRetryPolicy bool

+ HistorySize int64

+ InitialInterval int32

+ MaximumAttempts int32

+ MaximumInterval int32

+ NonRetriableErrors []string

type WorkflowMutableState

+ ActivityInfos map[int64]*ActivityInfo

+ type WorkflowRetryTimerTask struct

+ EventID int64

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (r *WorkflowRetryTimerTask) GetTaskID() int64

+ func (r *WorkflowRetryTimerTask) GetType() int

+ func (r *WorkflowRetryTimerTask) GetVersion() int64

+ func (r *WorkflowRetryTimerTask) GetVisibilityTimestamp() time.Time

+ func (r *WorkflowRetryTimerTask) SetTaskID(id int64)

+ func (r *WorkflowRetryTimerTask) SetVersion(version int64)

+ func (r *WorkflowRetryTimerTask) SetVisibilityTimestamp(t time.Time)

Jul 26, 2018 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 24, 2018 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 ErrPersistenceLimitExceeded = &workflow.ServiceBusyError

type ActivityInfo

+ LastTimeoutVisibility int64

type ActivityTask

+ VisibilityTimestamp time.Time

+ func (a *ActivityTask) GetVisibilityTimestamp() time.Time

+ func (a *ActivityTask) SetVisibilityTimestamp(timestamp time.Time)

type CancelExecutionTask

+ VisibilityTimestamp time.Time

+ func (u *CancelExecutionTask) GetVisibilityTimestamp() time.Time

+ func (u *CancelExecutionTask) SetVisibilityTimestamp(timestamp time.Time)

type CloseExecutionTask

+ VisibilityTimestamp time.Time

+ func (a *CloseExecutionTask) GetVisibilityTimestamp() time.Time

+ func (a *CloseExecutionTask) SetVisibilityTimestamp(timestamp time.Time)

type DecisionTask

+ VisibilityTimestamp time.Time

+ func (d *DecisionTask) GetVisibilityTimestamp() time.Time

+ func (d *DecisionTask) SetVisibilityTimestamp(timestamp time.Time)

type DeleteHistoryEventTask

+ func (a *DeleteHistoryEventTask) GetVisibilityTimestamp() time.Time

+ func (a *DeleteHistoryEventTask) SetVisibilityTimestamp(timestamp time.Time)

type DomainInfo

+ Data map[string]string

type ExecutionManager

+ func NewWorkflowExecutionPersistenceMetricsClient(persistence ExecutionManager, metricClient metrics.Client, logger bark.Logger) ExecutionManager

+ func NewWorkflowExecutionPersistenceRateLimitedClient(persistence ExecutionManager, rateLimiter common.TokenBucket, ...) ExecutionManager

type HistoryManager

+ func NewHistoryPersistenceMetricsClient(persistence HistoryManager, metricClient metrics.Client, logger bark.Logger) HistoryManager

+ func NewHistoryPersistenceRateLimitedClient(persistence HistoryManager, rateLimiter common.TokenBucket, logger bark.Logger) HistoryManager

type HistoryReplicationTask

+ VisibilityTimestamp time.Time

+ func (a *HistoryReplicationTask) GetVisibilityTimestamp() time.Time

+ func (a *HistoryReplicationTask) SetVisibilityTimestamp(timestamp time.Time)

+ type ListDomainsRequest struct

+ NextPageToken []byte

+ PageSize int

+ type ListDomainsResponse struct

+ Domains []*GetDomainResponse

+ NextPageToken []byte

type MetadataManager

+ func NewMetadataPersistenceMetricsClient(persistence MetadataManager, metricClient metrics.Client, logger bark.Logger) MetadataManager

+ func NewMetadataPersistenceRateLimitedClient(persistence MetadataManager, rateLimiter common.TokenBucket, ...) MetadataManager

+ ListDomains func(request *ListDomainsRequest) (*ListDomainsResponse, error)

type ReplicationTaskInfo

+ func (t *ReplicationTaskInfo) GetVisibilityTimestamp() time.Time

type ShardInfo

+ TimerFailoverLevels map[string]TimerFailoverLevel

+ TransferFailoverLevels map[string]TransferFailoverLevel

type ShardManager

+ func NewShardPersistenceMetricsClient(persistence ShardManager, metricClient metrics.Client, logger bark.Logger) ShardManager

+ func NewShardPersistenceRateLimitedClient(persistence ShardManager, rateLimiter common.TokenBucket, logger bark.Logger) ShardManager

type SignalExecutionTask

+ VisibilityTimestamp time.Time

+ func (u *SignalExecutionTask) GetVisibilityTimestamp() time.Time

+ func (u *SignalExecutionTask) SetVisibilityTimestamp(timestamp time.Time)

type StartChildExecutionTask

+ VisibilityTimestamp time.Time

+ func (u *StartChildExecutionTask) GetVisibilityTimestamp() time.Time

+ func (u *StartChildExecutionTask) SetVisibilityTimestamp(timestamp time.Time)

type Task

+ GetVisibilityTimestamp func() time.Time

+ SetVisibilityTimestamp func(timestamp time.Time)

type TaskManager

+ func NewTaskPersistenceMetricsClient(persistence TaskManager, metricClient metrics.Client, logger bark.Logger) TaskManager

+ func NewTaskPersistenceRateLimitedClient(persistence TaskManager, rateLimiter common.TokenBucket, logger bark.Logger) TaskManager

type TestBase

+ func (s *TestBase) UpdateWorkflowExecutionForBufferEvents(updatedInfo *WorkflowExecutionInfo, rState *ReplicationState, condition int64, ...) error

+ type TimerFailoverLevel struct

+ CurrentLevel time.Time

+ DomainIDs []string

+ MaxLevel time.Time

+ MinLevel time.Time

type TimerTaskInfo

+ func (t *TimerTaskInfo) GetVisibilityTimestamp() time.Time

+ func (t *TimerTaskInfo) String() string

+ type TransferFailoverLevel struct

+ CurrentLevel int64

+ DomainIDs []string

+ MaxLevel int64

+ MinLevel int64

type TransferTaskInfo

+ VisibilityTimestamp time.Time

+ func (t *TransferTaskInfo) GetVisibilityTimestamp() time.Time

+ func (t *TransferTaskInfo) String() string

type VisibilityManager

+ func NewVisibilityPersistenceMetricsClient(persistence VisibilityManager, metricClient metrics.Client, logger bark.Logger) VisibilityManager

+ func NewVisibilityPersistenceRateLimitedClient(persistence VisibilityManager, rateLimiter common.TokenBucket, ...) VisibilityManager

type WorkflowExecutionAlreadyStartedError

+ StartVersion int64

Jun 9, 2018 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

+ const DomainTableVersionV1

+ const DomainTableVersionV2

type GetDomainResponse

+ FailoverNotificationVersion int64

+ NotificationVersion int64

+ TableVersion int

+ type GetMetadataResponse struct

+ NotificationVersion int64

type GetReplicationTasksRequest

+ NextPageToken []byte

type GetReplicationTasksResponse

+ NextPageToken []byte

type GetTimerIndexTasksRequest

+ NextPageToken []byte

type GetTransferTasksRequest

+ NextPageToken []byte

type GetTransferTasksResponse

+ NextPageToken []byte

+ type ListDomainRequest struct

+ NextPageToken []byte

+ PageSize int

+ type ListDomainResponse struct

+ Domains []*GetDomainResponse

+ NextPageToken []byte

type MetadataManager

+ func NewCassandraMetadataPersistenceV2(hosts string, port int, user, password, dc string, keyspace string, ...) (MetadataManager, error)

+ func NewMetadataManagerProxy(hosts string, port int, user, password, dc string, keyspace string, ...) (MetadataManager, error)

+ GetMetadata func() (*GetMetadataResponse, error)

+ ListDomain func(request *ListDomainRequest) (*ListDomainResponse, error)

type ShardInfo

+ DomainNotificationVersion int64

type TestBase

+ MetadataManagerV2 MetadataManager

+ MetadataProxy MetadataManager

type UpdateDomainRequest

+ FailoverNotificationVersion int64

+ NotificationVersion int64

+ TableVersion int

May 26, 2018 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

+ const TaskTypeRetryTimer

type ActivityInfo

+ Attempt int32

+ BackoffCoefficient float64

+ DomainID string

+ ExpirationTime time.Time

+ HasRetryPolicy bool

+ InitialInterval int32

+ MaximumAttempts int32

+ MaximumInterval int32

+ NonRetriableErrors []string

+ StartedIdentity string

+ TaskList string

+ Version int64

type ActivityTask

+ Version int64

+ func (a *ActivityTask) GetVersion() int64

+ func (a *ActivityTask) SetVersion(version int64)

type ActivityTimeoutTask

+ Attempt int64

+ Version int64

+ func (a *ActivityTimeoutTask) GetVersion() int64

+ func (a *ActivityTimeoutTask) SetVersion(version int64)

+ type BufferedReplicationTask struct

+ FirstEventID int64

+ History *SerializedHistoryEventBatch

+ NewRunHistory *SerializedHistoryEventBatch

+ NextEventID int64

+ Version int64

type CancelExecutionTask

+ Version int64

+ func (u *CancelExecutionTask) GetVersion() int64

+ func (u *CancelExecutionTask) SetVersion(version int64)

type ChildExecutionInfo

+ Version int64

type CloseExecutionTask

+ Version int64

+ func (a *CloseExecutionTask) GetVersion() int64

+ func (a *CloseExecutionTask) SetVersion(version int64)

type CreateWorkflowExecutionRequest

+ DecisionVersion int64

type DecisionTask

+ Version int64

+ func (d *DecisionTask) GetVersion() int64

+ func (d *DecisionTask) SetVersion(version int64)

type DecisionTimeoutTask

+ Version int64

+ func (d *DecisionTimeoutTask) GetVersion() int64

+ func (d *DecisionTimeoutTask) SetVersion(version int64)

type DeleteHistoryEventTask

+ Version int64

+ func (a *DeleteHistoryEventTask) GetVersion() int64

+ func (a *DeleteHistoryEventTask) SetVersion(version int64)

type ExecutionManager

+ ResetMutableState func(request *ResetMutableStateRequest) error

type HistoryReplicationTask

+ func (a *HistoryReplicationTask) GetVersion() int64

+ func (a *HistoryReplicationTask) SetVersion(version int64)

type ReplicationTaskInfo

+ func (t *ReplicationTaskInfo) GetVersion() int64

type RequestCancelInfo

+ Version int64

+ type ResetMutableStateRequest struct

+ Condition int64

+ ExecutionInfo *WorkflowExecutionInfo

+ InsertActivityInfos []*ActivityInfo

+ InsertChildExecutionInfos []*ChildExecutionInfo

+ InsertRequestCancelInfos []*RequestCancelInfo

+ InsertSignalInfos []*SignalInfo

+ InsertSignalRequestedIDs []string

+ InsertTimerInfos []*TimerInfo

+ RangeID int64

+ ReplicationState *ReplicationState

+ type RetryTimerTask struct

+ Attempt int32

+ EventID int64

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (r *RetryTimerTask) GetTaskID() int64

+ func (r *RetryTimerTask) GetType() int

+ func (r *RetryTimerTask) GetVersion() int64

+ func (r *RetryTimerTask) GetVisibilityTimestamp() time.Time

+ func (r *RetryTimerTask) SetTaskID(id int64)

+ func (r *RetryTimerTask) SetVersion(version int64)

+ func (r *RetryTimerTask) SetVisibilityTimestamp(t time.Time)

type SignalExecutionTask

+ Version int64

+ func (u *SignalExecutionTask) GetVersion() int64

+ func (u *SignalExecutionTask) SetVersion(version int64)

type SignalInfo

+ Version int64

type StartChildExecutionTask

+ Version int64

+ func (u *StartChildExecutionTask) GetVersion() int64

+ func (u *StartChildExecutionTask) SetVersion(version int64)

type Task

+ GetVersion func() int64

+ SetVersion func(version int64)

type TestBase

+ func (s *TestBase) ResetMutableState(info *WorkflowExecutionInfo, replicationState *ReplicationState, ...) error

+ func (s *TestBase) UpdateAllMutableState(updatedMutableState *WorkflowMutableState, condition int64) error

type TimerInfo

+ Version int64

type TimerTaskInfo

+ func (t *TimerTaskInfo) GetTaskID() int64

+ func (t *TimerTaskInfo) GetTaskType() int

+ func (t *TimerTaskInfo) GetVersion() int64

type TransferTaskInfo

+ Version int64

+ func (t *TransferTaskInfo) GetVersion() int64

type UpdateWorkflowExecutionRequest

+ DeleteBufferedReplicationTask *int64

+ NewBufferedReplicationTask *BufferedReplicationTask

type UserTimerTask

+ Version int64

+ func (u *UserTimerTask) GetVersion() int64

+ func (u *UserTimerTask) SetVersion(version int64)

type WorkflowExecutionInfo

+ DecisionVersion int64

type WorkflowMutableState

+ BufferedReplicationTasks map[int64]*BufferedReplicationTask

type WorkflowTimeoutTask

+ Version int64

+ func (u *WorkflowTimeoutTask) GetVersion() int64

+ func (u *WorkflowTimeoutTask) SetVersion(version int64)

Apr 16, 2018 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

+ const ReplicationTaskTypeHeartbeat

+ const ReplicationTaskTypeHistory

+ func SetSerializedHistoryDefaults(history *SerializedHistoryEventBatch)

+ type CompleteReplicationTaskRequest struct

+ TaskID int64

type CreateDomainRequest

+ ConfigVersion int64

type CreateWorkflowExecutionRequest

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

type ExecutionManager

+ CompleteReplicationTask func(request *CompleteReplicationTaskRequest) error

+ GetReplicationTasks func(request *GetReplicationTasksRequest) (*GetReplicationTasksResponse, error)

+ type GetReplicationTasksRequest struct

+ BatchSize int

+ MaxReadLevel int64

+ ReadLevel int64

+ type GetReplicationTasksResponse struct

+ Tasks []*ReplicationTaskInfo

type GetTimerIndexTasksResponse

+ NextPageToken []byte

+ type HistoryReplicationTask struct

+ FirstEventID int64

+ LastReplicationInfo map[string]*ReplicationInfo

+ NextEventID int64

+ TaskID int64

+ Version int64

+ func (a *HistoryReplicationTask) GetTaskID() int64

+ func (a *HistoryReplicationTask) GetType() int

+ func (a *HistoryReplicationTask) SetTaskID(id int64)

+ type ReplicationInfo struct

+ LastEventID int64

+ Version int64

+ type ReplicationState struct

+ CurrentVersion int64

+ LastReplicationInfo map[string]*ReplicationInfo

+ LastWriteEventID int64

+ LastWriteVersion int64

+ StartVersion int64

+ type ReplicationTaskInfo struct

+ DomainID string

+ FirstEventID int64

+ LastReplicationInfo map[string]*ReplicationInfo

+ NextEventID int64

+ RunID string

+ TaskID int64

+ TaskType int

+ Version int64

+ WorkflowID string

+ func (t *ReplicationTaskInfo) GetTaskID() int64

+ func (t *ReplicationTaskInfo) GetTaskType() int

type ShardInfo

+ ClusterTimerAckLevel map[string]time.Time

+ ClusterTransferAckLevel map[string]int64

+ ReplicationAckLevel int64

type TestBase

+ func (s *TestBase) ClearReplicationQueue()

+ func (s *TestBase) ClearTasks()

+ func (s *TestBase) CompleteReplicationTask(taskID int64) error

+ func (s *TestBase) CreateWorkflowExecutionWithReplication(domainID string, workflowExecution workflow.WorkflowExecution, ...) (*CreateWorkflowExecutionResponse, error)

+ func (s *TestBase) GetReplicationReadLevel() int64

+ func (s *TestBase) GetReplicationTasks(batchSize int) ([]*ReplicationTaskInfo, error)

+ func (s *TestBase) GetTransferReadLevel() int64

+ func (s *TestBase) UpdateWorkflowExecutionWithReplication(updatedInfo *WorkflowExecutionInfo, updatedReplicationState *ReplicationState, ...) error

+ func (s *TestBase) UpdateWorklowStateAndReplication(updatedInfo *WorkflowExecutionInfo, updatedReplicationState *ReplicationState, ...) error

type TimerTaskInfo

+ Version int64

type TransferTaskInfo

+ func (t *TransferTaskInfo) GetTaskID() int64

+ func (t *TransferTaskInfo) GetTaskType() int

type UpdateWorkflowExecutionRequest

+ DeleteActivityInfos []int64

+ ReplicationState *ReplicationState

+ ReplicationTasks []Task

type WorkflowMutableState

+ ReplicationState *ReplicationState

Apr 10, 2018 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

Mar 14, 2018 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

Mar 13, 2018 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

Mar 12, 2018 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 GetOrUseDefaultActiveCluster(currentClusterName string, activeClusterName string) string

type CancelExecutionTask

+ InitiatedID int64

+ TargetChildWorkflowOnly bool

+ type ClusterReplicationConfig struct

+ ClusterName string

+ func GetOrUseDefaultClusters(currentClusterName string, clusters []*ClusterReplicationConfig) []*ClusterReplicationConfig

type CreateDomainRequest

+ Config *DomainConfig

+ FailoverVersion int64

+ Info *DomainInfo

+ IsGlobalDomain bool

+ ReplicationConfig *DomainReplicationConfig

+ type DomainReplicationConfig struct

+ ActiveClusterName string

+ Clusters []*ClusterReplicationConfig

type GetDomainResponse

+ ConfigVersion int64

+ DBVersion int64

+ FailoverVersion int64

+ IsGlobalDomain bool

+ ReplicationConfig *DomainReplicationConfig

type SignalExecutionTask

+ TargetChildWorkflowOnly bool

type TestBase

+ ClusterMetadata cluster.Metadata

type TestBaseOptions

+ EnableGlobalDomain bool

+ IsMasterCluster bool

type TransferTaskInfo

+ TargetChildWorkflowOnly bool

type UpdateDomainRequest

+ ConfigVersion int64

+ DBVersion int64

+ FailoverVersion int64

+ ReplicationConfig *DomainReplicationConfig

Jan 30, 2018 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

+ const TaskListKindNormal

+ const TaskListKindSticky

+ const TransferTaskTypeSignalExecution

+ func GetTransferTaskTypeTransferTargetRunID() string

type LeaseTaskListRequest

+ TaskListKind int

+ type SignalExecutionTask struct

+ InitiatedID int64

+ TargetDomainID string

+ TargetRunID string

+ TargetWorkflowID string

+ TaskID int64

+ func (u *SignalExecutionTask) GetTaskID() int64

+ func (u *SignalExecutionTask) GetType() int

+ func (u *SignalExecutionTask) SetTaskID(id int64)

+ type SignalInfo struct

+ Control []byte

+ InitiatedID int64

+ Input []byte

+ SignalName string

+ SignalRequestID string

type TaskListInfo

+ Kind int

type TestBase

+ func (s *TestBase) DeleteSignalState(updatedInfo *WorkflowExecutionInfo, condition int64, deleteSignalInfo int64) error

+ func (s *TestBase) DeleteSignalsRequestedState(updatedInfo *WorkflowExecutionInfo, condition int64, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionForSignal(updatedInfo *WorkflowExecutionInfo, condition int64, transferTasks []Task, ...) error

+ func (s *TestBase) UpsertSignalInfoState(updatedInfo *WorkflowExecutionInfo, condition int64, ...) error

+ func (s *TestBase) UpsertSignalsRequestedState(updatedInfo *WorkflowExecutionInfo, condition int64, ...) error

type UpdateWorkflowExecutionRequest

+ DeleteSignalInfo *int64

+ DeleteSignalRequestedID string

+ UpsertSignalInfos []*SignalInfo

+ UpsertSignalRequestedIDs []string

type WorkflowMutableState

+ SignalInfos map[int64]*SignalInfo

+ SignalRequestedIDs map[string]struct{}

Jan 12, 2018 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

type CreateWorkflowExecutionRequest

+ ExecutionInfo *WorkflowExecutionInfo

+ PreviousRunID string

type GetCurrentExecutionResponse

+ CloseStatus int

+ StartRequestID string

+ State int

type TestBase

+ func (s *TestBase) GetCurrentWorkflowRunID(domainID, workflowID string) (string, error)

+ func (s *TestBase) UpdateWorkflowExecutionAndFinish(updatedInfo *WorkflowExecutionInfo, condition int64) error

type UpdateWorkflowExecutionRequest

+ FinishExecution bool

+ FinishedExecutionTTL int32

type VisibilityManager

+ func NewVisibilityPersistenceClient(persistence VisibilityManager, metricClient metrics.Client) VisibilityManager

+ type WorkflowExecutionAlreadyStartedError struct

+ CloseStatus int

+ Msg string

+ RunID string

+ StartRequestID string

+ State int

+ func (e *WorkflowExecutionAlreadyStartedError) Error() string

type WorkflowExecutionInfo

+ ClientFeatureVersion string

+ ClientImpl string

+ ClientLibraryVersion string

+ LastFirstEventID int64

Dec 12, 2017 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 5, 2017 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

+ const TransferTaskTypeCloseExecution

+ type CloseExecutionTask struct

+ TaskID int64

+ func (a *CloseExecutionTask) GetTaskID() int64

+ func (a *CloseExecutionTask) GetType() int

+ func (a *CloseExecutionTask) SetTaskID(id int64)

type CreateWorkflowExecutionRequest

+ WorkflowTimeout int32

type DecisionTimeoutTask

+ ScheduleAttempt int64

+ TimeoutType int

type DeleteWorkflowExecutionRequest

+ DomainID string

+ RunID string

+ WorkflowID string

type GetWorkflowExecutionHistoryRequest

+ FirstEventID int64

type RecordWorkflowExecutionStartedRequest

+ WorkflowTimeout int64

type TimerTaskInfo

+ ScheduleAttempt int64

type UpdateWorkflowExecutionRequest

+ ClearBufferedEvents bool

+ NewBufferedEvents *SerializedHistoryEventBatch

type WorkflowExecutionInfo

+ DecisionAttempt int64

+ DecisionTimestamp int64

+ StickyScheduleToStartTimeout int32

+ StickyTaskList string

+ WorkflowTimeout int32

type WorkflowMutableState

+ BufferedEvents []*SerializedHistoryEventBatch

Sep 29, 2017 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

type ExecutionManagerFactory

+ func NewCassandraPersistenceClientFactory(hosts string, port int, user, password, dc string, keyspace string, ...) (ExecutionManagerFactory, error)

type TestBase

+ func (s *TestBase) UpdateWorkflowExecutionForChildExecutionsInitiated(updatedInfo *WorkflowExecutionInfo, condition int64, transferTasks []Task, ...) error

Aug 15, 2017 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 7, 2017 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

type ActivityInfo

+ ScheduledTime time.Time

+ StartedTime time.Time

+ TimerTaskStatus int32

type CreateTasksRequest

+ TaskListInfo *TaskListInfo

type TestBase

+ TaskIDGenerator TransferTaskIDGenerator

type TestBaseOptions

+ ClusterPassword string

+ ClusterPort int

+ ClusterUser string

+ type TransferTaskIDGenerator interface

+ GetNextTransferTaskID func() (int64, error)

Jun 30, 2017 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

+ const DefaultEncodingType

+ const DomainStatusDeleted

+ const DomainStatusDeprecated

+ const DomainStatusRegistered

+ const TaskListTypeActivity

+ const TaskListTypeDecision

+ const TaskTypeActivityTimeout

+ const TaskTypeDecisionTimeout

+ const TaskTypeDeleteHistoryEvent

+ const TaskTypeUserTimer

+ const TaskTypeWorkflowTimeout

+ const TransferTaskTypeActivityTask

+ const TransferTaskTypeCancelExecution

+ const TransferTaskTypeDecisionTask

+ const TransferTaskTypeDeleteExecution

+ const TransferTaskTypeStartChildExecution

+ const WorkflowCloseStatusCanceled

+ const WorkflowCloseStatusCompleted

+ const WorkflowCloseStatusContinuedAsNew

+ const WorkflowCloseStatusFailed

+ const WorkflowCloseStatusNone

+ const WorkflowCloseStatusTerminated

+ const WorkflowCloseStatusTimedOut

+ const WorkflowStateCompleted

+ const WorkflowStateCreated

+ const WorkflowStateRunning

+ func GetDefaultHistoryVersion() int

+ func GetMaxSupportedHistoryVersion() int

+ func GetVisibilityTSFrom(task Task) time.Time

+ func NewHistoryVersionCompatibilityError(required int, supported int) error

+ func NewUnknownEncodingTypeError(encodingType common.EncodingType) error

+ func SetDefaultHistoryVersion(version int)

+ func SetMaxSupportedHistoryVersion(version int)

+ func SetVisibilityTSFrom(task Task, t time.Time)

+ type ActivityInfo struct

+ ActivityID string

+ CancelRequestID int64

+ CancelRequested bool

+ Details []byte

+ HeartbeatTimeout int32

+ LastHeartBeatUpdatedTime time.Time

+ RequestID string

+ ScheduleID int64

+ ScheduleToCloseTimeout int32

+ ScheduleToStartTimeout int32

+ ScheduledEvent []byte

+ StartToCloseTimeout int32

+ StartedEvent []byte

+ StartedID int64

+ type ActivityTask struct

+ DomainID string

+ ScheduleID int64

+ TaskID int64

+ TaskList string

+ func (a *ActivityTask) GetTaskID() int64

+ func (a *ActivityTask) GetType() int

+ func (a *ActivityTask) SetTaskID(id int64)

+ type ActivityTimeoutTask struct

+ EventID int64

+ TaskID int64

+ TimeoutType int

+ VisibilityTimestamp time.Time

+ func (a *ActivityTimeoutTask) GetTaskID() int64

+ func (a *ActivityTimeoutTask) GetType() int

+ func (a *ActivityTimeoutTask) GetVisibilityTimestamp() time.Time

+ func (a *ActivityTimeoutTask) SetTaskID(id int64)

+ func (a *ActivityTimeoutTask) SetVisibilityTimestamp(t time.Time)

+ type AppendHistoryEventsRequest struct

+ DomainID string

+ Events *SerializedHistoryEventBatch

+ Execution workflow.WorkflowExecution

+ FirstEventID int64

+ Overwrite bool

+ RangeID int64

+ TransactionID int64

+ type CancelExecutionTask struct

+ ScheduleID int64

+ TargetDomainID string

+ TargetRunID string

+ TargetWorkflowID string

+ TaskID int64

+ func (u *CancelExecutionTask) GetTaskID() int64

+ func (u *CancelExecutionTask) GetType() int

+ func (u *CancelExecutionTask) SetTaskID(id int64)

+ type CassandraTestCluster struct

+ type ChildExecutionInfo struct

+ CreateRequestID string

+ InitiatedEvent []byte

+ InitiatedID int64

+ StartedEvent []byte

+ StartedID int64

+ type Closeable interface

+ Close func()

+ type CompleteTaskRequest struct

+ TaskID int64

+ TaskList *TaskListInfo

+ type CompleteTimerTaskRequest struct

+ TaskID int64

+ VisibilityTimestamp time.Time

+ type CompleteTransferTaskRequest struct

+ TaskID int64

+ type ConditionFailedError struct

+ Msg string

+ func (e *ConditionFailedError) Error() string

+ type CreateDomainRequest struct

+ Description string

+ EmitMetric bool

+ Name string

+ OwnerEmail string

+ Retention int32

+ Status int

+ type CreateDomainResponse struct

+ ID string

+ type CreateShardRequest struct

+ ShardInfo *ShardInfo

+ type CreateTaskInfo struct

+ Data *TaskInfo

+ Execution workflow.WorkflowExecution

+ TaskID int64

+ type CreateTasksRequest struct

+ DomainID string

+ RangeID int64

+ TaskList string

+ TaskListType int

+ Tasks []*CreateTaskInfo

+ type CreateTasksResponse struct

+ type CreateWorkflowExecutionRequest struct

+ ContinueAsNew bool

+ DecisionScheduleID int64

+ DecisionStartToCloseTimeout int32

+ DecisionStartedID int64

+ DecisionTimeoutValue int32

+ DomainID string

+ Execution workflow.WorkflowExecution

+ ExecutionContext []byte

+ InitiatedID int64

+ LastProcessedEvent int64

+ NextEventID int64

+ ParentDomainID string

+ ParentExecution *workflow.WorkflowExecution

+ RangeID int64

+ RequestID string

+ TaskList string

+ TimerTasks []Task

+ TransferTasks []Task

+ WorkflowTypeName string

+ type CreateWorkflowExecutionResponse struct

+ TaskID string

+ type DecisionTask struct

+ DomainID string

+ ScheduleID int64

+ TaskID int64

+ TaskList string

+ func (d *DecisionTask) GetTaskID() int64

+ func (d *DecisionTask) GetType() int

+ func (d *DecisionTask) SetTaskID(id int64)

+ type DecisionTimeoutTask struct

+ EventID int64

+ TaskID int64

+ VisibilityTimestamp time.Time

+ func (d *DecisionTimeoutTask) GetTaskID() int64

+ func (d *DecisionTimeoutTask) GetType() int

+ func (d *DecisionTimeoutTask) GetVisibilityTimestamp() time.Time

+ func (d *DecisionTimeoutTask) SetTaskID(id int64)

+ func (d *DecisionTimeoutTask) SetVisibilityTimestamp(t time.Time)

+ type DeleteDomainByNameRequest struct

+ Name string

+ type DeleteDomainRequest struct

+ ID string

+ type DeleteExecutionTask struct

+ TaskID int64

+ func (a *DeleteExecutionTask) GetTaskID() int64

+ func (a *DeleteExecutionTask) GetType() int

+ func (a *DeleteExecutionTask) SetTaskID(id int64)

+ type DeleteHistoryEventTask struct

+ TaskID int64

+ VisibilityTimestamp time.Time

+ func (a *DeleteHistoryEventTask) GetTaskID() int64

+ func (a *DeleteHistoryEventTask) GetType() int

+ func (a *DeleteHistoryEventTask) SetTaskID(id int64)

+ type DeleteWorkflowExecutionHistoryRequest struct

+ DomainID string

+ Execution workflow.WorkflowExecution

+ type DeleteWorkflowExecutionRequest struct

+ ExecutionInfo *WorkflowExecutionInfo

+ type DomainConfig struct

+ EmitMetric bool

+ Retention int32

+ type DomainInfo struct

+ Description string

+ ID string

+ Name string

+ OwnerEmail string

+ Status int

+ type ExecutionManager interface

+ CompleteTimerTask func(request *CompleteTimerTaskRequest) error

+ CompleteTransferTask func(request *CompleteTransferTaskRequest) error

+ CreateWorkflowExecution func(request *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)

+ DeleteWorkflowExecution func(request *DeleteWorkflowExecutionRequest) error

+ GetCurrentExecution func(request *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)

+ GetTimerIndexTasks func(request *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)

+ GetTransferTasks func(request *GetTransferTasksRequest) (*GetTransferTasksResponse, error)

+ GetWorkflowExecution func(request *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)

+ UpdateWorkflowExecution func(request *UpdateWorkflowExecutionRequest) error

+ func NewCassandraWorkflowExecutionPersistence(hosts string, dc string, keyspace string, shardID int, logger bark.Logger) (ExecutionManager, error)

+ func NewWorkflowExecutionPersistenceClient(persistence ExecutionManager, metricClient metrics.Client) ExecutionManager

+ type ExecutionManagerFactory interface

+ CreateExecutionManager func(shardID int) (ExecutionManager, error)

+ type GetClosedWorkflowExecutionRequest struct

+ DomainUUID string

+ Execution s.WorkflowExecution

+ type GetClosedWorkflowExecutionResponse struct

+ Execution *s.WorkflowExecutionInfo

+ type GetCurrentExecutionRequest struct

+ DomainID string

+ WorkflowID string

+ type GetCurrentExecutionResponse struct

+ RunID string

+ type GetDomainRequest struct

+ ID string

+ Name string

+ type GetDomainResponse struct

+ Config *DomainConfig

+ Info *DomainInfo

+ type GetShardRequest struct

+ ShardID int

+ type GetShardResponse struct

+ ShardInfo *ShardInfo

+ type GetTasksRequest struct

+ BatchSize int

+ DomainID string

+ MaxReadLevel int64

+ RangeID int64

+ ReadLevel int64

+ TaskList string

+ TaskType int

+ type GetTasksResponse struct

+ Tasks []*TaskInfo

+ type GetTimerIndexTasksRequest struct

+ BatchSize int

+ MaxTimestamp time.Time

+ MinTimestamp time.Time

+ type GetTimerIndexTasksResponse struct

+ Timers []*TimerTaskInfo

+ type GetTransferTasksRequest struct

+ BatchSize int

+ MaxReadLevel int64

+ ReadLevel int64

+ type GetTransferTasksResponse struct

+ Tasks []*TransferTaskInfo

+ type GetWorkflowExecutionHistoryRequest struct

+ DomainID string

+ Execution workflow.WorkflowExecution

+ NextEventID int64

+ NextPageToken []byte

+ PageSize int

+ type GetWorkflowExecutionHistoryResponse struct

+ Events []SerializedHistoryEventBatch

+ NextPageToken []byte

+ type GetWorkflowExecutionRequest struct

+ DomainID string

+ Execution workflow.WorkflowExecution

+ type GetWorkflowExecutionResponse struct

+ State *WorkflowMutableState

+ type HistoryDeserializationError struct

+ func (e *HistoryDeserializationError) Error() string

+ type HistoryEventBatch struct

+ Events []*workflow.HistoryEvent

+ Version int

+ func NewHistoryEventBatch(version int, events []*workflow.HistoryEvent) *HistoryEventBatch

+ func (b *HistoryEventBatch) String() string

+ type HistoryManager interface

+ AppendHistoryEvents func(request *AppendHistoryEventsRequest) error

+ DeleteWorkflowExecutionHistory func(request *DeleteWorkflowExecutionHistoryRequest) error

+ GetWorkflowExecutionHistory func(request *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)

+ func NewCassandraHistoryPersistence(hosts string, dc string, keyspace string, logger bark.Logger) (HistoryManager, error)

+ func NewHistoryPersistenceClient(persistence HistoryManager, metricClient metrics.Client) HistoryManager

+ type HistorySerializationError struct

+ func (e *HistorySerializationError) Error() string

+ type HistorySerializer interface

+ Deserialize func(batch *SerializedHistoryEventBatch) (*HistoryEventBatch, error)

+ Serialize func(batch *HistoryEventBatch) (*SerializedHistoryEventBatch, error)

+ func NewJSONHistorySerializer() HistorySerializer

+ type HistorySerializerFactory interface

+ Get func(encodingType common.EncodingType) (HistorySerializer, error)

+ func NewHistorySerializerFactory() HistorySerializerFactory

+ type HistoryVersionCompatibilityError struct

+ func (e *HistoryVersionCompatibilityError) Error() string

+ type LeaseTaskListRequest struct

+ DomainID string

+ TaskList string

+ TaskType int

+ type LeaseTaskListResponse struct

+ TaskListInfo *TaskListInfo

+ type ListClosedWorkflowExecutionsByStatusRequest struct

+ Status s.WorkflowExecutionCloseStatus

+ type ListWorkflowExecutionsByTypeRequest struct

+ WorkflowTypeName string

+ type ListWorkflowExecutionsByWorkflowIDRequest struct

+ WorkflowID string

+ type ListWorkflowExecutionsRequest struct

+ DomainUUID string

+ EarliestStartTime int64

+ LatestStartTime int64

+ NextPageToken []byte

+ PageSize int

+ type ListWorkflowExecutionsResponse struct

+ Executions []*s.WorkflowExecutionInfo

+ NextPageToken []byte

+ type MetadataManager interface

+ CreateDomain func(request *CreateDomainRequest) (*CreateDomainResponse, error)

+ DeleteDomain func(request *DeleteDomainRequest) error

+ DeleteDomainByName func(request *DeleteDomainByNameRequest) error

+ GetDomain func(request *GetDomainRequest) (*GetDomainResponse, error)

+ UpdateDomain func(request *UpdateDomainRequest) error

+ func NewCassandraMetadataPersistence(hosts string, dc string, keyspace string, logger bark.Logger) (MetadataManager, error)

+ func NewMetadataPersistenceClient(persistence MetadataManager, metricClient metrics.Client) MetadataManager

+ type RecordWorkflowExecutionClosedRequest struct

+ CloseTimestamp int64

+ DomainUUID string

+ Execution s.WorkflowExecution

+ HistoryLength int64

+ RetentionSeconds int64

+ StartTimestamp int64

+ Status s.WorkflowExecutionCloseStatus

+ WorkflowTypeName string

+ type RecordWorkflowExecutionStartedRequest struct

+ DomainUUID string

+ Execution s.WorkflowExecution

+ StartTimestamp int64

+ WorkflowTypeName string

+ type RequestCancelInfo struct

+ CancelRequestID string

+ InitiatedID int64

+ type SerializedHistoryEventBatch struct

+ Data []byte

+ EncodingType common.EncodingType

+ Version int

+ func NewSerializedHistoryEventBatch(data []byte, encoding common.EncodingType, version int) *SerializedHistoryEventBatch

+ func (h *SerializedHistoryEventBatch) String() string

+ type ShardAlreadyExistError struct

+ Msg string

+ func (e *ShardAlreadyExistError) Error() string

+ type ShardInfo struct

+ Owner string

+ RangeID int64

+ ShardID int

+ StolenSinceRenew int

+ TimerAckLevel time.Time

+ TransferAckLevel int64

+ UpdatedAt time.Time

+ type ShardManager interface

+ CreateShard func(request *CreateShardRequest) error

+ GetShard func(request *GetShardRequest) (*GetShardResponse, error)

+ UpdateShard func(request *UpdateShardRequest) error

+ func NewCassandraShardPersistence(hosts string, dc string, keyspace string, logger bark.Logger) (ShardManager, error)

+ func NewShardPersistenceClient(persistence ShardManager, metricClient metrics.Client) ShardManager

+ type ShardOwnershipLostError struct

+ Msg string

+ ShardID int

+ func (e *ShardOwnershipLostError) Error() string

+ type StartChildExecutionTask struct

+ InitiatedID int64

+ TargetDomainID string

+ TargetWorkflowID string

+ TaskID int64

+ func (u *StartChildExecutionTask) GetTaskID() int64

+ func (u *StartChildExecutionTask) GetType() int

+ func (u *StartChildExecutionTask) SetTaskID(id int64)

+ type Task interface

+ GetTaskID func() int64

+ GetType func() int

+ SetTaskID func(id int64)

+ type TaskInfo struct

+ DomainID string

+ RunID string

+ ScheduleID int64

+ ScheduleToStartTimeout int32

+ TaskID int64

+ WorkflowID string

+ type TaskListInfo struct

+ AckLevel int64

+ DomainID string

+ Name string

+ RangeID int64

+ TaskType int

+ type TaskManager interface

+ CompleteTask func(request *CompleteTaskRequest) error

+ CreateTasks func(request *CreateTasksRequest) (*CreateTasksResponse, error)

+ GetTasks func(request *GetTasksRequest) (*GetTasksResponse, error)

+ LeaseTaskList func(request *LeaseTaskListRequest) (*LeaseTaskListResponse, error)

+ UpdateTaskList func(request *UpdateTaskListRequest) (*UpdateTaskListResponse, error)

+ func NewCassandraTaskPersistence(hosts string, dc string, keyspace string, logger bark.Logger) (TaskManager, error)

+ func NewTaskPersistenceClient(persistence TaskManager, metricClient metrics.Client) TaskManager

+ type TestBase struct

+ ExecutionMgrFactory ExecutionManagerFactory

+ HistoryMgr HistoryManager

+ MetadataManager MetadataManager

+ ShardContext *TestShardContext

+ ShardInfo *ShardInfo

+ ShardMgr ShardManager

+ TaskMgr TaskManager

+ VisibilityMgr VisibilityManager

+ WorkflowMgr ExecutionManager

+ func (s *TestBase) ClearTransferQueue()

+ func (s *TestBase) CompleteTask(domainID, taskList string, taskType int, taskID int64, ackLevel int64) error

+ func (s *TestBase) CompleteTimerTask(ts time.Time, taskID int64) error

+ func (s *TestBase) CompleteTransferTask(taskID int64) error

+ func (s *TestBase) ContinueAsNewExecution(updatedInfo *WorkflowExecutionInfo, condition int64, ...) error

+ func (s *TestBase) CreateActivityTasks(domainID string, workflowExecution workflow.WorkflowExecution, ...) ([]int64, error)

+ func (s *TestBase) CreateChildWorkflowExecution(domainID string, workflowExecution workflow.WorkflowExecution, ...) (string, error)

+ func (s *TestBase) CreateDecisionTask(domainID string, workflowExecution workflow.WorkflowExecution, taskList string, ...) (int64, error)

+ func (s *TestBase) CreateShard(shardID int, owner string, rangeID int64) error

+ func (s *TestBase) CreateWorkflowExecution(domainID string, workflowExecution workflow.WorkflowExecution, ...) (string, error)

+ func (s *TestBase) CreateWorkflowExecutionManyTasks(domainID string, workflowExecution workflow.WorkflowExecution, taskList string, ...) (string, error)

+ func (s *TestBase) DeleteCancelState(updatedInfo *WorkflowExecutionInfo, condition int64, deleteCancelInfo int64) error

+ func (s *TestBase) DeleteChildExecutionsState(updatedInfo *WorkflowExecutionInfo, condition int64, deleteChildInfo int64) error

+ func (s *TestBase) DeleteWorkflowExecution(info *WorkflowExecutionInfo) error

+ func (s *TestBase) GetCurrentWorkflow(domainID, workflowID string) (string, error)

+ func (s *TestBase) GetNextSequenceNumber() int64

+ func (s *TestBase) GetReadLevel() int64

+ func (s *TestBase) GetShard(shardID int) (*ShardInfo, error)

+ func (s *TestBase) GetTasks(domainID, taskList string, taskType int, batchSize int) (*GetTasksResponse, error)

+ func (s *TestBase) GetTimerIndexTasks() ([]*TimerTaskInfo, error)

+ func (s *TestBase) GetTransferTasks(batchSize int) ([]*TransferTaskInfo, error)

+ func (s *TestBase) GetWorkflowExecutionInfo(domainID string, workflowExecution workflow.WorkflowExecution) (*WorkflowMutableState, error)

+ func (s *TestBase) SetupWorkflowStore()

+ func (s *TestBase) SetupWorkflowStoreWithOptions(options TestBaseOptions)

+ func (s *TestBase) TearDownWorkflowStore()

+ func (s *TestBase) UpdateShard(updatedInfo *ShardInfo, previousRangeID int64) error

+ func (s *TestBase) UpdateWorkflowExecution(updatedInfo *WorkflowExecutionInfo, decisionScheduleIDs []int64, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionAndDelete(updatedInfo *WorkflowExecutionInfo, condition int64) error

+ func (s *TestBase) UpdateWorkflowExecutionForRequestCancel(updatedInfo *WorkflowExecutionInfo, condition int64, transferTasks []Task, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionWithRangeID(updatedInfo *WorkflowExecutionInfo, decisionScheduleIDs []int64, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionWithTransferTasks(updatedInfo *WorkflowExecutionInfo, condition int64, transferTasks []Task, ...) error

+ func (s *TestBase) UpsertChildExecutionsState(updatedInfo *WorkflowExecutionInfo, condition int64, ...) error

+ func (s *TestBase) UpsertRequestCancelState(updatedInfo *WorkflowExecutionInfo, condition int64, ...) error

+ type TestBaseOptions struct

+ ClusterHost string

+ Datacenter string

+ DropKeySpace bool

+ KeySpace string

+ SchemaDir string

+ type TestShardContext struct

+ func (s *TestShardContext) AppendHistoryEvents(request *AppendHistoryEventsRequest) error

+ func (s *TestShardContext) CreateWorkflowExecution(request *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)

+ func (s *TestShardContext) GetExecutionManager() ExecutionManager

+ func (s *TestShardContext) GetHistoryManager() HistoryManager

+ func (s *TestShardContext) GetLogger() bark.Logger

+ func (s *TestShardContext) GetMetricsClient() metrics.Client

+ func (s *TestShardContext) GetNextTransferTaskID() (int64, error)

+ func (s *TestShardContext) GetRangeID() int64

+ func (s *TestShardContext) GetTimeSource() common.TimeSource

+ func (s *TestShardContext) GetTimerAckLevel() time.Time

+ func (s *TestShardContext) GetTransferAckLevel() int64

+ func (s *TestShardContext) GetTransferMaxReadLevel() int64

+ func (s *TestShardContext) GetTransferSequenceNumber() int64

+ func (s *TestShardContext) Reset()

+ func (s *TestShardContext) UpdateTimerAckLevel(ackLevel time.Time) error

+ func (s *TestShardContext) UpdateTransferAckLevel(ackLevel int64) error

+ func (s *TestShardContext) UpdateWorkflowExecution(request *UpdateWorkflowExecutionRequest) error

+ type TimeoutError struct

+ Msg string

+ func (e *TimeoutError) Error() string

+ type TimerInfo struct

+ ExpiryTime time.Time

+ StartedID int64

+ TaskID int64

+ TimerID string

+ type TimerTaskInfo struct

+ DomainID string

+ EventID int64

+ RunID string

+ TaskID int64

+ TaskType int

+ TimeoutType int

+ VisibilityTimestamp time.Time

+ WorkflowID string

+ type TransferTaskInfo struct

+ DomainID string

+ RunID string

+ ScheduleID int64

+ TargetDomainID string

+ TargetRunID string

+ TargetWorkflowID string

+ TaskID int64

+ TaskList string

+ TaskType int

+ WorkflowID string

+ type UnknownEncodingTypeError struct

+ func (e *UnknownEncodingTypeError) Error() string

+ type UpdateDomainRequest struct

+ Config *DomainConfig

+ Info *DomainInfo

+ type UpdateShardRequest struct

+ PreviousRangeID int64

+ ShardInfo *ShardInfo

+ type UpdateTaskListRequest struct

+ TaskListInfo *TaskListInfo

+ type UpdateTaskListResponse struct

+ type UpdateWorkflowExecutionRequest struct

+ CloseExecution bool

+ Condition int64

+ ContinueAsNew *CreateWorkflowExecutionRequest

+ DeleteActivityInfo *int64

+ DeleteChildExecutionInfo *int64

+ DeleteRequestCancelInfo *int64

+ DeleteTimerInfos []string

+ DeleteTimerTask Task

+ ExecutionInfo *WorkflowExecutionInfo

+ RangeID int64

+ TimerTasks []Task

+ TransferTasks []Task

+ UpserTimerInfos []*TimerInfo

+ UpsertActivityInfos []*ActivityInfo

+ UpsertChildExecutionInfos []*ChildExecutionInfo

+ UpsertRequestCancelInfos []*RequestCancelInfo

+ type UserTimerTask struct

+ EventID int64

+ TaskID int64

+ VisibilityTimestamp time.Time

+ func (u *UserTimerTask) GetTaskID() int64

+ func (u *UserTimerTask) GetType() int

+ func (u *UserTimerTask) GetVisibilityTimestamp() time.Time

+ func (u *UserTimerTask) SetTaskID(id int64)

+ func (u *UserTimerTask) SetVisibilityTimestamp(t time.Time)

+ type VisibilityManager interface

+ GetClosedWorkflowExecution func(request *GetClosedWorkflowExecutionRequest) (*GetClosedWorkflowExecutionResponse, error)

+ ListClosedWorkflowExecutions func(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutionsByStatus func(request *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutionsByType func(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutionsByWorkflowID func(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

+ ListOpenWorkflowExecutions func(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ ListOpenWorkflowExecutionsByType func(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

+ ListOpenWorkflowExecutionsByWorkflowID func(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

+ RecordWorkflowExecutionClosed func(request *RecordWorkflowExecutionClosedRequest) error

+ RecordWorkflowExecutionStarted func(request *RecordWorkflowExecutionStartedRequest) error

+ func NewCassandraVisibilityPersistence(hosts string, dc string, keyspace string, logger bark.Logger) (VisibilityManager, error)

+ type WorkflowExecutionInfo struct

+ CancelRequestID string

+ CancelRequested bool

+ CloseStatus int

+ CompletionEvent []byte

+ CreateRequestID string

+ DecisionRequestID string

+ DecisionScheduleID int64

+ DecisionStartedID int64

+ DecisionTimeout int32

+ DecisionTimeoutValue int32

+ DomainID string

+ ExecutionContext []byte

+ InitiatedID int64

+ LastProcessedEvent int64

+ LastUpdatedTimestamp time.Time

+ NextEventID int64

+ ParentDomainID string

+ ParentRunID string

+ ParentWorkflowID string

+ RunID string

+ StartTimestamp time.Time

+ State int

+ TaskList string

+ WorkflowID string

+ WorkflowTypeName string

+ type WorkflowMutableState struct

+ ActivitInfos map[int64]*ActivityInfo

+ ChildExecutionInfos map[int64]*ChildExecutionInfo

+ ExecutionInfo *WorkflowExecutionInfo

+ RequestCancelInfos map[int64]*RequestCancelInfo

+ TimerInfos map[string]*TimerInfo

+ type WorkflowTimeoutTask struct

+ TaskID int64

+ VisibilityTimestamp time.Time

+ func (u *WorkflowTimeoutTask) GetTaskID() int64

+ func (u *WorkflowTimeoutTask) GetType() int

+ func (u *WorkflowTimeoutTask) GetVisibilityTimestamp() time.Time

+ func (u *WorkflowTimeoutTask) SetTaskID(id int64)

+ func (u *WorkflowTimeoutTask) SetVisibilityTimestamp(t time.Time)

Jun 7, 2017 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 6, 2017 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