persistence

Mar 1, 2024

Changes in this version

+ const VisibilityOverridePrimary

+ const VisibilityOverrideSecondary

type DomainConfig

+ AsyncWorkflowConfig types.AsyncWorkflowConfiguration

type InternalDomainConfig

+ AsyncWorkflowsConfig *DataBlob

type InternalWorkflowMutableState

+ ChecksumData *DataBlob

type InternalWorkflowMutation

+ ChecksumData *DataBlob

type InternalWorkflowSnapshot

+ ChecksumData *DataBlob

type PayloadSerializer

+ DeserializeAsyncWorkflowsConfig func(data *DataBlob) (*types.AsyncWorkflowConfiguration, error)

+ DeserializeChecksum func(data *DataBlob) (checksum.Checksum, error)

+ SerializeAsyncWorkflowsConfig func(config *types.AsyncWorkflowConfiguration, encodingType common.EncodingType) (*DataBlob, error)

+ SerializeChecksum func(sum checksum.Checksum, encodingType common.EncodingType) (*DataBlob, error)

Jan 23, 2024

Changes in this version

+ const ContextKey

type AppendHistoryNodesRequest

+ func (r AppendHistoryNodesRequest) MetricTags() []metrics.Tag

type CompleteTaskRequest

+ func (r CompleteTaskRequest) MetricTags() []metrics.Tag

type CompleteTasksLessThanRequest

+ func (r CompleteTasksLessThanRequest) MetricTags() []metrics.Tag

type ConflictResolveWorkflowExecutionRequest

+ func (r ConflictResolveWorkflowExecutionRequest) GetDomainName() string

type CreateTasksRequest

+ func (r CreateTasksRequest) MetricTags() []metrics.Tag

type CreateWorkflowExecutionRequest

+ func (r *CreateWorkflowExecutionRequest) GetDomainName() string

+ func (r *CreateWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag

type DeleteCurrentWorkflowExecutionRequest

+ func (r DeleteCurrentWorkflowExecutionRequest) GetDomainName() string

+ func (r DeleteCurrentWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag

type DeleteHistoryBranchRequest

+ func (r DeleteHistoryBranchRequest) MetricTags() []metrics.Tag

type DeleteTaskListRequest

+ func (r DeleteTaskListRequest) MetricTags() []metrics.Tag

type DeleteWorkflowExecutionRequest

+ func (r DeleteWorkflowExecutionRequest) GetDomainName() string

+ func (r DeleteWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag

type ForkHistoryBranchRequest

+ func (r ForkHistoryBranchRequest) MetricTags() []metrics.Tag

type GetAllHistoryTreeBranchesResponse

+ func (r GetAllHistoryTreeBranchesResponse) Len() int

type GetCrossClusterTasksResponse

+ func (r *GetCrossClusterTasksResponse) Len() int

type GetCurrentExecutionRequest

+ func (r GetCurrentExecutionRequest) GetDomainName() string

+ func (r GetCurrentExecutionRequest) GetExtraLogTags() []tag.Tag

type GetHistoryTreeRequest

+ func (r GetHistoryTreeRequest) MetricTags() []metrics.Tag

type GetReplicationTasksResponse

+ func (r *GetReplicationTasksResponse) Len() int

type GetTasksRequest

+ func (r GetTasksRequest) MetricTags() []metrics.Tag

type GetTasksResponse

+ func (r *GetTasksResponse) Len() int

type GetTimerIndexTasksResponse

+ func (r *GetTimerIndexTasksResponse) Len() int

type GetTransferTasksResponse

+ func (r *GetTransferTasksResponse) Len() int

type GetWorkflowExecutionRequest

+ func (r GetWorkflowExecutionRequest) GetDomainName() string

+ func (r GetWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag

type InternalWorkflowExecutionInfo

+ IsCron bool

type IsWorkflowExecutionExistsRequest

+ func (r *IsWorkflowExecutionExistsRequest) GetDomainName() string

type LeaseTaskListRequest

+ func (r LeaseTaskListRequest) MetricTags() []metrics.Tag

type ListCurrentExecutionsResponse

+ func (r *ListCurrentExecutionsResponse) Len() int

type ListDomainsResponse

+ func (r *ListDomainsResponse) Len() int

+ type MockVisibilityManager struct

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

+ func (m *MockVisibilityManager) Close()

+ func (m *MockVisibilityManager) CountWorkflowExecutions(arg0 context.Context, arg1 *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) DeleteUninitializedWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error

+ func (m *MockVisibilityManager) DeleteWorkflowExecution(arg0 context.Context, arg1 *VisibilityDeleteWorkflowExecutionRequest) error

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

+ func (m *MockVisibilityManager) GetClosedWorkflowExecution(arg0 context.Context, arg1 *GetClosedWorkflowExecutionRequest) (*GetClosedWorkflowExecutionResponse, error)

+ func (m *MockVisibilityManager) GetName() string

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByStatus(arg0 context.Context, arg1 *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByType(arg0 context.Context, arg1 *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByType(arg0 context.Context, arg1 *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(arg0 context.Context, arg1 *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) ListWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) RecordWorkflowExecutionClosed(arg0 context.Context, arg1 *RecordWorkflowExecutionClosedRequest) error

+ func (m *MockVisibilityManager) RecordWorkflowExecutionStarted(arg0 context.Context, arg1 *RecordWorkflowExecutionStartedRequest) error

+ func (m *MockVisibilityManager) RecordWorkflowExecutionUninitialized(arg0 context.Context, arg1 *RecordWorkflowExecutionUninitializedRequest) error

+ func (m *MockVisibilityManager) ScanWorkflowExecutions(arg0 context.Context, arg1 *ListWorkflowExecutionsByQueryRequest) (*ListWorkflowExecutionsResponse, error)

+ func (m *MockVisibilityManager) UpsertWorkflowExecution(arg0 context.Context, arg1 *UpsertWorkflowExecutionRequest) error

+ type MockVisibilityManagerMockRecorder struct

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

+ func (mr *MockVisibilityManagerMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) DeleteUninitializedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) GetClosedWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

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

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionUninitialized(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockVisibilityManagerMockRecorder) UpsertWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

type PutReplicationTaskToDLQRequest

+ func (r *PutReplicationTaskToDLQRequest) MetricTags() []metrics.Tag

+ type QueueMessageList []*QueueMessage

+ func (r QueueMessageList) Len() int

type ReadHistoryBranchRequest

+ func (r ReadHistoryBranchRequest) MetricTags() []metrics.Tag

type ReadHistoryBranchResponse

+ func (r *ReadHistoryBranchResponse) Len() int

+ type ResponseComparatorContextKey string

type UpdateTaskListRequest

+ func (r UpdateTaskListRequest) MetricTags() []metrics.Tag

type UpdateWorkflowExecutionRequest

+ func (r *UpdateWorkflowExecutionRequest) GetDomainName() string

+ func (r *UpdateWorkflowExecutionRequest) GetExtraLogTags() []tag.Tag

Dec 6, 2023

Changes in this version

+ const Primary

+ const Secondary

+ var Operation = struct{ ... }

+ type GetTaskListSizeRequest struct

+ AckLevel int64

+ DomainID string

+ DomainName string

+ TaskListName string

+ TaskListType int

+ type GetTaskListSizeResponse struct

+ Size int64

type MockTaskManager

+ func (m *MockTaskManager) GetTaskListSize(ctx context.Context, request *GetTaskListSizeRequest) (*GetTaskListSizeResponse, error)

type MockTaskManagerMockRecorder

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

+ type OperationType string

type TaskManager

+ GetTaskListSize func(ctx context.Context, request *GetTaskListSizeRequest) (*GetTaskListSizeResponse, error)

type TaskStore

+ GetTaskListSize func(ctx context.Context, request *GetTaskListSizeRequest) (*GetTaskListSizeResponse, error)

Oct 19, 2023

Changes in this version

+ type MockRetryer struct

+ func NewMockRetryer(ctrl *gomock.Controller) *MockRetryer

+ func (m *MockRetryer) CompleteTimerTask(ctx context.Context, request *CompleteTimerTaskRequest) error

+ func (m *MockRetryer) DeleteCurrentWorkflowExecution(arg0 context.Context, arg1 *DeleteCurrentWorkflowExecutionRequest) error

+ func (m *MockRetryer) DeleteWorkflowExecution(arg0 context.Context, arg1 *DeleteWorkflowExecutionRequest) error

+ func (m *MockRetryer) EXPECT() *MockRetryerMockRecorder

+ func (m *MockRetryer) GetCurrentExecution(arg0 context.Context, arg1 *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)

+ func (m *MockRetryer) GetShardID() int

+ func (m *MockRetryer) GetTimerIndexTasks(arg0 context.Context, arg1 *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)

+ func (m *MockRetryer) GetWorkflowExecution(arg0 context.Context, arg1 *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)

+ func (m *MockRetryer) IsWorkflowExecutionExists(arg0 context.Context, arg1 *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)

+ func (m *MockRetryer) ListConcreteExecutions(arg0 context.Context, arg1 *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)

+ func (m *MockRetryer) ListCurrentExecutions(arg0 context.Context, arg1 *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)

+ func (m *MockRetryer) ReadHistoryBranch(arg0 context.Context, arg1 *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)

+ type MockRetryerMockRecorder struct

+ func (mr *MockRetryerMockRecorder) CompleteTimerTask(ctx, request interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) DeleteCurrentWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) GetCurrentExecution(arg0, arg1 interface{}) *gomock.Call

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

+ func (mr *MockRetryerMockRecorder) GetTimerIndexTasks(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) GetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) IsWorkflowExecutionExists(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) ListConcreteExecutions(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) ListCurrentExecutions(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRetryerMockRecorder) ReadHistoryBranch(arg0, arg1 interface{}) *gomock.Call

type VisibilityManager

+ func NewPinotVisibilityDualManager(dbVisibilityManager VisibilityManager, ...) VisibilityManager

+ func NewPinotVisibilityTripleManager(dbVisibilityManager VisibilityManager, ...) VisibilityManager

Aug 28, 2023

Changes in this version

type ConfigType

+ const GlobalIsolationGroupConfig

type DataBlob

+ func (d *DataBlob) GetData() []byte

type DomainConfig

+ IsolationGroups types.IsolationGroupConfiguration

type DynamicConfiguration

+ EnableShardIDMetrics dynamicconfig.BoolPropertyFn

+ PersistenceSampleLoggingRate dynamicconfig.IntPropertyFn

type InternalDomainConfig

+ IsolationGroups *DataBlob

type InternalTaskInfo

+ PartitionConfig map[string]string

type InternalWorkflowExecutionInfo

+ PartitionConfig map[string]string

type PayloadSerializer

+ DeserializeIsolationGroups func(data *DataBlob) (*types.IsolationGroupConfiguration, error)

+ SerializeIsolationGroups func(event *types.IsolationGroupConfiguration, encodingType common.EncodingType) (*DataBlob, error)

type TaskInfo

+ PartitionConfig map[string]string

type WorkflowExecutionInfo

+ PartitionConfig map[string]string

Mar 17, 2023

Changes in this version

type InternalRecordWorkflowExecutionClosedRequest

+ ShardID int16

+ UpdateTimestamp time.Time

type InternalRecordWorkflowExecutionStartedRequest

+ ShardID int16

+ UpdateTimestamp time.Time

type InternalRecordWorkflowExecutionUninitializedRequest

+ ShardID int64

+ UpdateTimestamp time.Time

type InternalUpsertWorkflowExecutionRequest

+ ShardID int64

+ UpdateTimestamp time.Time

type InternalVisibilityWorkflowExecutionInfo

+ ShardID int16

+ UpdateTime time.Time

type InternalWorkflowExecutionInfo

+ FirstExecutionRunID string

type RecordWorkflowExecutionClosedRequest

+ ShardID int16

+ UpdateTimestamp int64

type RecordWorkflowExecutionStartedRequest

+ ShardID int16

+ UpdateTimestamp int64

type RecordWorkflowExecutionUninitializedRequest

+ ShardID int64

+ UpdateTimestamp int64

type UpsertWorkflowExecutionRequest

+ ShardID int64

+ UpdateTimestamp int64

type VisibilityManager

+ DeleteUninitializedWorkflowExecution func(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error

type VisibilityStore

+ DeleteUninitializedWorkflowExecution func(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error

type WorkflowExecutionInfo

+ FirstExecutionRunID string

Oct 12, 2022

Changes in this version

+ var ErrVisibilityOperationNotSupported = &types.BadRequestError

type AppendHistoryNodesRequest

+ DomainName string

type AppendHistoryNodesResponse

+ DataBlob DataBlob

type CompleteTaskRequest

+ DomainName string

type CompleteTasksLessThanRequest

+ DomainName string

type ConflictResolveWorkflowExecutionRequest

+ DomainName string

type CreateTasksRequest

+ DomainName string

type CreateWorkflowExecutionRequest

+ DomainName string

+ type DBUnavailableError struct

+ Msg string

+ func (e *DBUnavailableError) Error() string

type DeleteCurrentWorkflowExecutionRequest

+ DomainName string

type DeleteHistoryBranchRequest

+ DomainName string

type DeleteTaskListRequest

+ DomainName string

type DeleteWorkflowExecutionRequest

+ DomainName string

+ type DynamicConfiguration struct

+ EnableCassandraAllConsistencyLevelDelete dynamicconfig.BoolPropertyFn

+ EnableSQLAsyncTransaction dynamicconfig.BoolPropertyFn

+ func NewDynamicConfiguration(dc *dynamicconfig.Collection) *DynamicConfiguration

type ForkHistoryBranchRequest

+ DomainName string

type GetCurrentExecutionRequest

+ DomainName string

type GetHistoryTreeRequest

+ DomainName string

type GetTasksRequest

+ DomainName string

type GetWorkflowExecutionRequest

+ DomainName string

+ type InternalRecordWorkflowExecutionUninitializedRequest struct

+ DomainUUID string

+ RunID string

+ WorkflowID string

+ WorkflowTypeName string

type IsWorkflowExecutionExistsRequest

+ DomainName string

type LeaseTaskListRequest

+ DomainName string

type PutReplicationTaskToDLQRequest

+ DomainName string

type ReadHistoryBranchRequest

+ DomainName string

+ type RecordWorkflowExecutionUninitializedRequest struct

+ Domain string

+ DomainUUID string

+ Execution types.WorkflowExecution

+ WorkflowTypeName string

type UpdateTaskListRequest

+ DomainName string

type UpdateWorkflowExecutionRequest

+ DomainName string

type VersionHistories

+ func (h *VersionHistories) FindFirstVersionHistoryByItem(item *VersionHistoryItem) (index int, history *VersionHistory, err error)

type VisibilityDeleteWorkflowExecutionRequest

+ Domain string

type VisibilityManager

+ RecordWorkflowExecutionUninitialized func(ctx context.Context, request *RecordWorkflowExecutionUninitializedRequest) error

type VisibilityStore

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

type WorkflowExecutionInfo

+ func (e *WorkflowExecutionInfo) IsRunning() bool

May 24, 2022

Changes in this version

+ const CrossClusterTaskTypeApplyParentClosePolicy

+ const CrossClusterTaskTypeRecordChildExeuctionCompleted

+ const TransferTaskTypeApplyParentClosePolicy

+ const TransferTaskTypeRecordChildExecutionCompleted

+ const TransferTaskTypeRecordWorkflowClosed

+ var ErrCorruptedHistory = &types.InternalDataInconsistencyError

+ type ApplyParentClosePolicyTask struct

+ TargetDomainIDs map[string]struct{}

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (u *ApplyParentClosePolicyTask) GetTaskID() int64

+ func (u *ApplyParentClosePolicyTask) GetType() int

+ func (u *ApplyParentClosePolicyTask) GetVersion() int64

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

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

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

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

type ChildExecutionInfo

+ DomainID string

+ DomainNameDEPRECATED string

+ type CrossClusterApplyParentClosePolicyTask struct

+ TargetCluster string

+ func (c *CrossClusterApplyParentClosePolicyTask) GetType() int

+ type CrossClusterRecordChildExecutionCompletedTask struct

+ TargetCluster string

+ func (c *CrossClusterRecordChildExecutionCompletedTask) GetType() int

type InternalChildExecutionInfo

+ DomainID string

+ DomainNameDEPRECATED string

type InternalRecordWorkflowExecutionClosedRequest

+ NumClusters int16

+ RetentionPeriod time.Duration

type InternalRecordWorkflowExecutionStartedRequest

+ NumClusters int16

type InternalUpsertWorkflowExecutionRequest

+ NumClusters int16

type InternalVisibilityWorkflowExecutionInfo

+ DomainID string

+ NumClusters int16

+ WorkflowType string

type InternalWorkflowExecutionInfo

+ ExpirationInterval time.Duration

+ type RecordChildExecutionCompletedTask struct

+ TargetDomainID string

+ TargetRunID string

+ TargetWorkflowID string

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (u *RecordChildExecutionCompletedTask) GetTaskID() int64

+ func (u *RecordChildExecutionCompletedTask) GetType() int

+ func (u *RecordChildExecutionCompletedTask) GetVersion() int64

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

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

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

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

+ type RecordWorkflowClosedTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (u *RecordWorkflowClosedTask) GetTaskID() int64

+ func (u *RecordWorkflowClosedTask) GetType() int

+ func (u *RecordWorkflowClosedTask) GetVersion() int64

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

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

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

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

type RecordWorkflowExecutionClosedRequest

+ NumClusters int16

type RecordWorkflowExecutionStartedRequest

+ NumClusters int16

type TransferTaskInfo

+ TargetDomainIDs map[string]struct{}

+ func (t *TransferTaskInfo) GetTargetDomainIDs() map[string]struct{}

type UpdateWorkflowMode

+ const UpdateWorkflowModeIgnoreCurrent

type UpsertWorkflowExecutionRequest

+ NumClusters int16

+ type VisibilityAdminDeletionKey string

Nov 18, 2021

Changes in this version

+ const CrossClusterTaskTypeRecordChildWorkflowExeuctionComplete

+ func HasMoreRowsToDelete(rowsDeleted, batchSize int) bool

+ func IsBackgroundTransientError(err error) bool

+ type CompleteTasksLessThanResponse struct

+ TasksCompleted int

+ type ConfigStore interface

+ FetchConfig func(ctx context.Context, configType ConfigType) (*InternalConfigStoreEntry, error)

+ UpdateConfig func(ctx context.Context, value *InternalConfigStoreEntry) error

+ type ConfigStoreManager interface

+ FetchDynamicConfig func(ctx context.Context) (*FetchDynamicConfigResponse, error)

+ UpdateDynamicConfig func(ctx context.Context, request *UpdateDynamicConfigRequest) error

+ func NewConfigStoreErrorInjectionPersistenceClient(persistence ConfigStoreManager, errorRate float64, logger log.Logger) ConfigStoreManager

+ func NewConfigStoreManagerImpl(persistence ConfigStore, logger log.Logger) ConfigStoreManager

+ func NewConfigStorePersistenceMetricsClient(persistence ConfigStoreManager, metricClient metrics.Client, logger log.Logger) ConfigStoreManager

+ func NewConfigStorePersistenceRateLimitedClient(persistence ConfigStoreManager, rateLimiter quotas.Limiter, logger log.Logger) ConfigStoreManager

+ type ConfigType int

+ const DynamicConfig

+ type CrossClusterRecordChildWorkflowExecutionCompleteTask struct

+ TargetCluster string

+ func (c *CrossClusterRecordChildWorkflowExecutionCompleteTask) GetType() int

+ type DomainStore interface

+ CreateDomain func(ctx context.Context, request *InternalCreateDomainRequest) (*CreateDomainResponse, error)

+ DeleteDomain func(ctx context.Context, request *DeleteDomainRequest) error

+ DeleteDomainByName func(ctx context.Context, request *DeleteDomainByNameRequest) error

+ GetDomain func(ctx context.Context, request *GetDomainRequest) (*InternalGetDomainResponse, error)

+ GetMetadata func(ctx context.Context) (*GetMetadataResponse, error)

+ GetName func() string

+ ListDomains func(ctx context.Context, request *ListDomainsRequest) (*InternalListDomainsResponse, error)

+ UpdateDomain func(ctx context.Context, request *InternalUpdateDomainRequest) error

+ type DynamicConfigSnapshot struct

+ Values *types.DynamicConfigBlob

+ Version int64

+ type FetchDynamicConfigResponse struct

+ Snapshot *DynamicConfigSnapshot

+ type InternalConfigStoreEntry struct

+ RowType int

+ Timestamp time.Time

+ Values *DataBlob

+ Version int64

+ 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 MockConfigStoreManager struct

+ func NewMockConfigStoreManager(ctrl *gomock.Controller) *MockConfigStoreManager

+ func (m *MockConfigStoreManager) Close()

+ func (m *MockConfigStoreManager) EXPECT() *MockConfigStoreManagerMockRecorder

+ func (m *MockConfigStoreManager) FetchDynamicConfig(ctx context.Context) (*FetchDynamicConfigResponse, error)

+ func (m *MockConfigStoreManager) UpdateDynamicConfig(ctx context.Context, request *UpdateDynamicConfigRequest) error

+ type MockConfigStoreManagerMockRecorder struct

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

+ func (mr *MockConfigStoreManagerMockRecorder) FetchDynamicConfig(ctx interface{}) *gomock.Call

+ func (mr *MockConfigStoreManagerMockRecorder) UpdateDynamicConfig(ctx, request interface{}) *gomock.Call

+ type MockDomainManager struct

+ func NewMockDomainManager(ctrl *gomock.Controller) *MockDomainManager

+ func (m *MockDomainManager) Close()

+ func (m *MockDomainManager) CreateDomain(ctx context.Context, request *CreateDomainRequest) (*CreateDomainResponse, error)

+ func (m *MockDomainManager) DeleteDomain(ctx context.Context, request *DeleteDomainRequest) error

+ func (m *MockDomainManager) DeleteDomainByName(ctx context.Context, request *DeleteDomainByNameRequest) error

+ func (m *MockDomainManager) EXPECT() *MockDomainManagerMockRecorder

+ func (m *MockDomainManager) GetDomain(ctx context.Context, request *GetDomainRequest) (*GetDomainResponse, error)

+ func (m *MockDomainManager) GetMetadata(ctx context.Context) (*GetMetadataResponse, error)

+ func (m *MockDomainManager) GetName() string

+ func (m *MockDomainManager) ListDomains(ctx context.Context, request *ListDomainsRequest) (*ListDomainsResponse, error)

+ func (m *MockDomainManager) UpdateDomain(ctx context.Context, request *UpdateDomainRequest) error

+ type MockDomainManagerMockRecorder struct

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

+ func (mr *MockDomainManagerMockRecorder) CreateDomain(ctx, request interface{}) *gomock.Call

+ func (mr *MockDomainManagerMockRecorder) DeleteDomain(ctx, request interface{}) *gomock.Call

+ func (mr *MockDomainManagerMockRecorder) DeleteDomainByName(ctx, request interface{}) *gomock.Call

+ func (mr *MockDomainManagerMockRecorder) GetDomain(ctx, request interface{}) *gomock.Call

+ func (mr *MockDomainManagerMockRecorder) GetMetadata(ctx interface{}) *gomock.Call

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

+ func (mr *MockDomainManagerMockRecorder) ListDomains(ctx, request interface{}) *gomock.Call

+ func (mr *MockDomainManagerMockRecorder) UpdateDomain(ctx, request interface{}) *gomock.Call

+ type MockExecutionManager struct

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

+ func (m *MockExecutionManager) Close()

+ func (m *MockExecutionManager) CompleteCrossClusterTask(ctx context.Context, request *CompleteCrossClusterTaskRequest) error

+ func (m *MockExecutionManager) CompleteReplicationTask(ctx context.Context, request *CompleteReplicationTaskRequest) error

+ func (m *MockExecutionManager) CompleteTimerTask(ctx context.Context, request *CompleteTimerTaskRequest) error

+ func (m *MockExecutionManager) CompleteTransferTask(ctx context.Context, request *CompleteTransferTaskRequest) error

+ func (m *MockExecutionManager) ConflictResolveWorkflowExecution(ctx context.Context, request *ConflictResolveWorkflowExecutionRequest) (*ConflictResolveWorkflowExecutionResponse, error)

+ func (m *MockExecutionManager) CreateFailoverMarkerTasks(ctx context.Context, request *CreateFailoverMarkersRequest) error

+ func (m *MockExecutionManager) CreateWorkflowExecution(ctx context.Context, request *CreateWorkflowExecutionRequest) (*CreateWorkflowExecutionResponse, error)

+ func (m *MockExecutionManager) DeleteCurrentWorkflowExecution(ctx context.Context, request *DeleteCurrentWorkflowExecutionRequest) error

+ func (m *MockExecutionManager) DeleteReplicationTaskFromDLQ(ctx context.Context, request *DeleteReplicationTaskFromDLQRequest) error

+ func (m *MockExecutionManager) DeleteWorkflowExecution(ctx context.Context, request *DeleteWorkflowExecutionRequest) error

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

+ func (m *MockExecutionManager) GetCrossClusterTasks(ctx context.Context, request *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)

+ func (m *MockExecutionManager) GetCurrentExecution(ctx context.Context, request *GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)

+ func (m *MockExecutionManager) GetName() string

+ func (m *MockExecutionManager) GetReplicationDLQSize(ctx context.Context, request *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error)

+ func (m *MockExecutionManager) GetReplicationTasks(ctx context.Context, request *GetReplicationTasksRequest) (*GetReplicationTasksResponse, error)

+ func (m *MockExecutionManager) GetReplicationTasksFromDLQ(ctx context.Context, request *GetReplicationTasksFromDLQRequest) (*GetReplicationTasksFromDLQResponse, error)

+ func (m *MockExecutionManager) GetShardID() int

+ func (m *MockExecutionManager) GetTimerIndexTasks(ctx context.Context, request *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)

+ func (m *MockExecutionManager) GetTransferTasks(ctx context.Context, request *GetTransferTasksRequest) (*GetTransferTasksResponse, error)

+ func (m *MockExecutionManager) GetWorkflowExecution(ctx context.Context, request *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)

+ func (m *MockExecutionManager) IsWorkflowExecutionExists(ctx context.Context, request *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)

+ func (m *MockExecutionManager) ListConcreteExecutions(ctx context.Context, request *ListConcreteExecutionsRequest) (*ListConcreteExecutionsResponse, error)

+ func (m *MockExecutionManager) ListCurrentExecutions(ctx context.Context, request *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)

+ func (m *MockExecutionManager) PutReplicationTaskToDLQ(ctx context.Context, request *PutReplicationTaskToDLQRequest) error

+ func (m *MockExecutionManager) RangeCompleteCrossClusterTask(ctx context.Context, request *RangeCompleteCrossClusterTaskRequest) (*RangeCompleteCrossClusterTaskResponse, error)

+ func (m *MockExecutionManager) RangeCompleteReplicationTask(ctx context.Context, request *RangeCompleteReplicationTaskRequest) (*RangeCompleteReplicationTaskResponse, error)

+ func (m *MockExecutionManager) RangeCompleteTimerTask(ctx context.Context, request *RangeCompleteTimerTaskRequest) (*RangeCompleteTimerTaskResponse, error)

+ func (m *MockExecutionManager) RangeCompleteTransferTask(ctx context.Context, request *RangeCompleteTransferTaskRequest) (*RangeCompleteTransferTaskResponse, error)

+ func (m *MockExecutionManager) RangeDeleteReplicationTaskFromDLQ(ctx context.Context, request *RangeDeleteReplicationTaskFromDLQRequest) (*RangeDeleteReplicationTaskFromDLQResponse, error)

+ func (m *MockExecutionManager) UpdateWorkflowExecution(ctx context.Context, 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 int) (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) Close() *gomock.Call

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockHistoryManager struct

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

+ func (m *MockHistoryManager) AppendHistoryNodes(ctx context.Context, request *AppendHistoryNodesRequest) (*AppendHistoryNodesResponse, error)

+ func (m *MockHistoryManager) Close()

+ func (m *MockHistoryManager) DeleteHistoryBranch(ctx context.Context, request *DeleteHistoryBranchRequest) error

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

+ func (m *MockHistoryManager) ForkHistoryBranch(ctx context.Context, request *ForkHistoryBranchRequest) (*ForkHistoryBranchResponse, error)

+ func (m *MockHistoryManager) GetAllHistoryTreeBranches(ctx context.Context, request *GetAllHistoryTreeBranchesRequest) (*GetAllHistoryTreeBranchesResponse, error)

+ func (m *MockHistoryManager) GetHistoryTree(ctx context.Context, request *GetHistoryTreeRequest) (*GetHistoryTreeResponse, error)

+ func (m *MockHistoryManager) GetName() string

+ func (m *MockHistoryManager) ReadHistoryBranch(ctx context.Context, request *ReadHistoryBranchRequest) (*ReadHistoryBranchResponse, error)

+ func (m *MockHistoryManager) ReadHistoryBranchByBatch(ctx context.Context, request *ReadHistoryBranchRequest) (*ReadHistoryBranchByBatchResponse, error)

+ func (m *MockHistoryManager) ReadRawHistoryBranch(ctx context.Context, request *ReadHistoryBranchRequest) (*ReadRawHistoryBranchResponse, error)

+ type MockHistoryManagerMockRecorder struct

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

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

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

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

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

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

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

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

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

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

+ type MockQueueManager struct

+ func NewMockQueueManager(ctrl *gomock.Controller) *MockQueueManager

+ func (m *MockQueueManager) Close()

+ func (m *MockQueueManager) DeleteMessageFromDLQ(ctx context.Context, messageID int64) error

+ func (m *MockQueueManager) DeleteMessagesBefore(ctx context.Context, messageID int64) error

+ func (m *MockQueueManager) EXPECT() *MockQueueManagerMockRecorder

+ func (m *MockQueueManager) EnqueueMessage(ctx context.Context, messagePayload []byte) error

+ func (m *MockQueueManager) EnqueueMessageToDLQ(ctx context.Context, messagePayload []byte) error

+ func (m *MockQueueManager) GetAckLevels(ctx context.Context) (map[string]int64, error)

+ func (m *MockQueueManager) GetDLQAckLevels(ctx context.Context) (map[string]int64, error)

+ func (m *MockQueueManager) GetDLQSize(ctx context.Context) (int64, error)

+ func (m *MockQueueManager) RangeDeleteMessagesFromDLQ(ctx context.Context, firstMessageID, lastMessageID int64) error

+ func (m *MockQueueManager) ReadMessages(ctx context.Context, lastMessageID int64, maxCount int) ([]*QueueMessage, error)

+ func (m *MockQueueManager) ReadMessagesFromDLQ(ctx context.Context, firstMessageID, lastMessageID int64, pageSize int, ...) ([]*QueueMessage, []byte, error)

+ func (m *MockQueueManager) UpdateAckLevel(ctx context.Context, messageID int64, clusterName string) error

+ func (m *MockQueueManager) UpdateDLQAckLevel(ctx context.Context, messageID int64, clusterName string) error

+ type MockQueueManagerMockRecorder struct

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

+ func (mr *MockQueueManagerMockRecorder) DeleteMessageFromDLQ(ctx, messageID interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) DeleteMessagesBefore(ctx, messageID interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) EnqueueMessage(ctx, messagePayload interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) EnqueueMessageToDLQ(ctx, messagePayload interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) GetAckLevels(ctx interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) GetDLQAckLevels(ctx interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) GetDLQSize(ctx interface{}) *gomock.Call

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

+ func (mr *MockQueueManagerMockRecorder) ReadMessages(ctx, lastMessageID, maxCount interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) ReadMessagesFromDLQ(ctx, firstMessageID, lastMessageID, pageSize, pageToken interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) UpdateAckLevel(ctx, messageID, clusterName interface{}) *gomock.Call

+ func (mr *MockQueueManagerMockRecorder) UpdateDLQAckLevel(ctx, messageID, clusterName interface{}) *gomock.Call

+ type MockShardManager struct

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

+ func (m *MockShardManager) Close()

+ func (m *MockShardManager) CreateShard(ctx context.Context, request *CreateShardRequest) error

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

+ func (m *MockShardManager) GetName() string

+ func (m *MockShardManager) GetShard(ctx context.Context, request *GetShardRequest) (*GetShardResponse, error)

+ func (m *MockShardManager) UpdateShard(ctx context.Context, request *UpdateShardRequest) error

+ type MockShardManagerMockRecorder struct

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

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

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

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

+ func (mr *MockShardManagerMockRecorder) UpdateShard(ctx, 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() int

+ 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(ctx context.Context, request *CompleteTaskRequest) error

+ func (m *MockTaskManager) CompleteTasksLessThan(ctx context.Context, request *CompleteTasksLessThanRequest) (*CompleteTasksLessThanResponse, error)

+ func (m *MockTaskManager) CreateTasks(ctx context.Context, request *CreateTasksRequest) (*CreateTasksResponse, error)

+ func (m *MockTaskManager) DeleteTaskList(ctx context.Context, request *DeleteTaskListRequest) error

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

+ func (m *MockTaskManager) GetName() string

+ func (m *MockTaskManager) GetOrphanTasks(ctx context.Context, request *GetOrphanTasksRequest) (*GetOrphanTasksResponse, error)

+ func (m *MockTaskManager) GetTasks(ctx context.Context, request *GetTasksRequest) (*GetTasksResponse, error)

+ func (m *MockTaskManager) LeaseTaskList(ctx context.Context, request *LeaseTaskListRequest) (*LeaseTaskListResponse, error)

+ func (m *MockTaskManager) ListTaskList(ctx context.Context, request *ListTaskListRequest) (*ListTaskListResponse, error)

+ func (m *MockTaskManager) UpdateTaskList(ctx context.Context, request *UpdateTaskListRequest) (*UpdateTaskListResponse, error)

+ type MockTaskManagerMockRecorder struct

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

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

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

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

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

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

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

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

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

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

+ func (mr *MockTaskManagerMockRecorder) UpdateTaskList(ctx, 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 PayloadSerializer

+ DeserializeDynamicConfigBlob func(data *DataBlob) (*types.DynamicConfigBlob, error)

+ SerializeDynamicConfigBlob func(blob *types.DynamicConfigBlob, encodingType common.EncodingType) (*DataBlob, error)

type RangeCompleteCrossClusterTaskRequest

+ PageSize int

+ type RangeCompleteCrossClusterTaskResponse struct

+ TasksCompleted int

type RangeCompleteReplicationTaskRequest

+ PageSize int

+ type RangeCompleteReplicationTaskResponse struct

+ TasksCompleted int

type RangeCompleteTimerTaskRequest

+ PageSize int

+ type RangeCompleteTimerTaskResponse struct

+ TasksCompleted int

type RangeCompleteTransferTaskRequest

+ PageSize int

+ type RangeCompleteTransferTaskResponse struct

+ TasksCompleted int

type RangeDeleteReplicationTaskFromDLQRequest

+ PageSize int

+ type RangeDeleteReplicationTaskFromDLQResponse struct

+ TasksCompleted int

+ type RecordWorkflowExecutionCompleteTask struct

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (u *RecordWorkflowExecutionCompleteTask) GetTaskID() int64

+ func (u *RecordWorkflowExecutionCompleteTask) GetType() int

+ func (u *RecordWorkflowExecutionCompleteTask) GetVersion() int64

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

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

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

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

+ type UpdateDynamicConfigRequest struct

+ Snapshot *DynamicConfigSnapshot

Aug 20, 2021

Changes in this version

+ const CrossClusterTaskDefaultTargetRunID

+ const CrossClusterTaskTypeCancelExecution

+ const CrossClusterTaskTypeSignalExecution

+ const CrossClusterTaskTypeStartChildExecution

+ type CompleteCrossClusterTaskRequest struct

+ TargetCluster string

+ TaskID int64

+ type CrossClusterCancelExecutionTask struct

+ TargetCluster string

+ func (c *CrossClusterCancelExecutionTask) GetType() int

+ type CrossClusterSignalExecutionTask struct

+ TargetCluster string

+ func (c *CrossClusterSignalExecutionTask) GetType() int

+ type CrossClusterStartChildExecutionTask struct

+ TargetCluster string

+ func (c *CrossClusterStartChildExecutionTask) GetType() int

+ type CrossClusterTaskInfo = TransferTaskInfo

type DataBlob

+ func (d *DataBlob) GetEncodingString() string

+ func (d *DataBlob) ToNilSafeDataBlob() *DataBlob

+ type DomainManager interface

+ CreateDomain func(ctx context.Context, request *CreateDomainRequest) (*CreateDomainResponse, error)

+ DeleteDomain func(ctx context.Context, request *DeleteDomainRequest) error

+ DeleteDomainByName func(ctx context.Context, request *DeleteDomainByNameRequest) error

+ GetDomain func(ctx context.Context, request *GetDomainRequest) (*GetDomainResponse, error)

+ GetMetadata func(ctx context.Context) (*GetMetadataResponse, error)

+ GetName func() string

+ ListDomains func(ctx context.Context, request *ListDomainsRequest) (*ListDomainsResponse, error)

+ UpdateDomain func(ctx context.Context, request *UpdateDomainRequest) error

+ func NewDomainManagerImpl(persistence MetadataStore, logger log.Logger) DomainManager

+ func NewDomainPersistenceErrorInjectionClient(persistence DomainManager, errorRate float64, logger log.Logger) DomainManager

+ func NewDomainPersistenceMetricsClient(persistence DomainManager, metricClient metrics.Client, logger log.Logger) DomainManager

+ func NewDomainPersistenceRateLimitedClient(persistence DomainManager, rateLimiter quotas.Limiter, logger log.Logger) DomainManager

type ExecutionManager

+ CompleteCrossClusterTask func(ctx context.Context, request *CompleteCrossClusterTaskRequest) error

+ GetCrossClusterTasks func(ctx context.Context, request *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)

+ RangeCompleteCrossClusterTask func(ctx context.Context, request *RangeCompleteCrossClusterTaskRequest) error

type ExecutionStore

+ CompleteCrossClusterTask func(ctx context.Context, request *CompleteCrossClusterTaskRequest) error

+ GetCrossClusterTasks func(ctx context.Context, request *GetCrossClusterTasksRequest) (*GetCrossClusterTasksResponse, error)

+ RangeCompleteCrossClusterTask func(ctx context.Context, request *RangeCompleteCrossClusterTaskRequest) error

+ type GetCrossClusterTasksRequest struct

+ BatchSize int

+ MaxReadLevel int64

+ NextPageToken []byte

+ ReadLevel int64

+ TargetCluster string

+ type GetCrossClusterTasksResponse struct

+ NextPageToken []byte

+ Tasks []*CrossClusterTaskInfo

type InternalRecordWorkflowExecutionClosedRequest

+ IsCron bool

type InternalRecordWorkflowExecutionStartedRequest

+ IsCron bool

type InternalShardInfo

+ CrossClusterProcessingQueueStates *DataBlob

type InternalUpsertWorkflowExecutionRequest

+ IsCron bool

type InternalVisibilityWorkflowExecutionInfo

+ IsCron bool

type InternalWorkflowMutation

+ CrossClusterTasks []Task

type InternalWorkflowSnapshot

+ CrossClusterTasks []Task

type MutableStateUpdateSessionStats

+ CrossClusterTaskCount int

+ type RangeCompleteCrossClusterTaskRequest struct

+ ExclusiveBeginTaskID int64

+ InclusiveEndTaskID int64

+ TargetCluster string

type RecordWorkflowExecutionClosedRequest

+ IsCron bool

type RecordWorkflowExecutionStartedRequest

+ IsCron bool

+ type SamplingConfig struct

+ VisibilityClosedMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityListMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityOpenMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

type ShardInfo

+ CrossClusterProcessingQueueStates *types.ProcessingQueueStates

+ func (s *ShardInfo) Copy() *ShardInfo

type UpsertWorkflowExecutionRequest

+ IsCron bool

type VisibilityManager

+ func NewVisibilityDualManager(dbVisibilityManager VisibilityManager, esVisibilityManager VisibilityManager, ...) VisibilityManager

type WorkflowExecutionInfo

+ IsCron bool

type WorkflowMutation

+ CrossClusterTasks []Task

type WorkflowSnapshot

+ CrossClusterTasks []Task

May 6, 2021

Changes in this version

+ func FromInternalWorkflowExecutionCloseStatus(closeStatus *types.WorkflowExecutionCloseStatus) int

+ type ConflictResolveWorkflowExecutionResponse struct

+ MutableStateUpdateSessionStats *MutableStateUpdateSessionStats

type CreateWorkflowExecutionResponse

+ MutableStateUpdateSessionStats *MutableStateUpdateSessionStats

+ type GetOrphanTasksRequest struct

+ Limit int

+ type GetOrphanTasksResponse struct

+ Tasks []*TaskKey

type MutableStateUpdateSessionStats

+ ReplicationTasksCount int

+ TimerTasksCount int

+ TransferTasksCount int

+ type TaskKey struct

+ DomainID string

+ TaskID int64

+ TaskListName string

+ TaskType int

type TaskManager

+ GetOrphanTasks func(ctx context.Context, request *GetOrphanTasksRequest) (*GetOrphanTasksResponse, error)

type TaskStore

+ GetOrphanTasks func(ctx context.Context, request *GetOrphanTasksRequest) (*GetOrphanTasksResponse, error)

Apr 16, 2021

Changes in this version

+ func IsTransientError(err error) bool

Jan 22, 2021

Changes in this version

+ func ToInternalWorkflowExecutionCloseStatus(closeStatus int) types.WorkflowExecutionCloseStatus

type DataBlob

+ func NewDataBlobFromInternal(blob *types.DataBlob) *DataBlob

+ func (d *DataBlob) ToInternal() *types.DataBlob

type Retryer

+ CompleteTimerTask func(ctx context.Context, request *CompleteTimerTaskRequest) error

+ GetTimerIndexTasks func(context.Context, *GetTimerIndexTasksRequest) (*GetTimerIndexTasksResponse, error)

type VersionHistories

+ func NewVersionHistoriesFromInternalType(input *types.VersionHistories) *VersionHistories

+ func (h *VersionHistories) ToInternalType() *types.VersionHistories

type VersionHistory

+ func NewVersionHistoryFromInternalType(input *types.VersionHistory) *VersionHistory

+ func (v *VersionHistory) ToInternalType() *types.VersionHistory

type VersionHistoryItem

+ func NewVersionHistoryItemFromInternalType(input *types.VersionHistoryItem) *VersionHistoryItem

+ func (item *VersionHistoryItem) ToInternalType() *types.VersionHistoryItem

Jan 13, 2021

Changes in this version

+ var ErrFakeInternalService = &workflow.InternalServiceError

+ var ErrFakeServiceBusy = &workflow.ServiceBusyError

+ var ErrFakeTimeout = &TimeoutError

+ var ErrFakeUnhandled = errors.New("fake unhandled error")

type ExecutionManager

+ func NewWorkflowExecutionPersistenceErrorInjectionClient(persistence ExecutionManager, errorRate float64, logger log.Logger) ExecutionManager

type HistoryManager

+ func NewHistoryPersistenceErrorInjectionClient(persistence HistoryManager, errorRate float64, logger log.Logger) HistoryManager

type InternalListWorkflowExecutionsRequest

+ EarliestTime time.Time

+ LatestTime time.Time

type InternalWorkflowMutation

+ DeleteChildExecutionInfos []int64

+ DeleteRequestCancelInfos []int64

+ DeleteSignalInfos []int64

+ DeleteSignalRequestedIDs []string

+ type ListWorkflowExecutionsByQueryRequest struct

+ Domain string

+ DomainUUID string

+ NextPageToken []byte

+ PageSize int

+ Query string

type ListWorkflowExecutionsRequest

+ EarliestTime int64

+ LatestTime int64

type MetadataManager

+ func NewMetadataPersistenceErrorInjectionClient(persistence MetadataManager, errorRate float64, logger log.Logger) MetadataManager

type Queue

+ GetDLQSize func(ctx context.Context) (int64, error)

type QueueManager

+ func NewQueuePersistenceErrorInjectionClient(persistence QueueManager, errorRate float64, logger log.Logger) QueueManager

+ GetDLQSize func(ctx context.Context) (int64, error)

type ShardManager

+ func NewShardPersistenceErrorInjectionClient(persistence ShardManager, errorRate float64, logger log.Logger) ShardManager

type TaskManager

+ func NewTaskPersistenceErrorInjectionClient(persistence TaskManager, errorRate float64, logger log.Logger) TaskManager

type VisibilityManager

+ func NewVisibilityPersistenceErrorInjectionClient(persistence VisibilityManager, errorRate float64, logger log.Logger) VisibilityManager

type WorkflowMutation

+ DeleteChildExecutionInfos []int64

+ DeleteRequestCancelInfos []int64

+ DeleteSignalInfos []int64

+ DeleteSignalRequestedIDs []string

Dec 4, 2020

Changes in this version

type CreateDomainRequest

+ LastUpdatedTime int64

type GetDomainResponse

+ LastUpdatedTime int64

type InternalCreateDomainRequest

+ LastUpdatedTime int64

+ type InternalCreateShardRequest struct

+ ShardInfo *InternalShardInfo

+ type InternalCreateTasksInfo struct

+ Data *InternalTaskInfo

+ Execution workflow.WorkflowExecution

+ TaskID int64

+ type InternalCreateTasksRequest struct

+ TaskListInfo *TaskListInfo

+ Tasks []*InternalCreateTasksInfo

+ type InternalGetClosedWorkflowExecutionRequest struct

+ Domain string

+ DomainUUID string

+ Execution workflow.WorkflowExecution

type InternalGetDomainResponse

+ LastUpdatedTime int64

+ type InternalGetHistoryTreeRequest struct

+ BranchToken []byte

+ ShardID *int

+ TreeID string

+ type InternalGetHistoryTreeResponse struct

+ Branches []*workflow.HistoryBranch

+ type InternalGetReplicationTasksFromDLQResponse = InternalGetReplicationTasksResponse

+ type InternalGetReplicationTasksResponse struct

+ NextPageToken []byte

+ Tasks []*InternalReplicationTaskInfo

+ type InternalGetShardRequest struct

+ ShardID int

+ type InternalGetShardResponse struct

+ ShardInfo *InternalShardInfo

+ type InternalGetTasksResponse struct

+ Tasks []*InternalTaskInfo

+ type InternalGetWorkflowExecutionRequest struct

+ DomainID string

+ Execution workflow.WorkflowExecution

+ type InternalListClosedWorkflowExecutionsByStatusRequest struct

+ Status workflow.WorkflowExecutionCloseStatus

+ type InternalListWorkflowExecutionsByTypeRequest struct

+ WorkflowTypeName string

+ type InternalListWorkflowExecutionsByWorkflowIDRequest struct

+ WorkflowID string

+ type InternalListWorkflowExecutionsRequest struct

+ Domain string

+ DomainUUID string

+ EarliestStartTime int64

+ LatestStartTime int64

+ NextPageToken []byte

+ PageSize int

+ type InternalPutReplicationTaskToDLQRequest struct

+ SourceClusterName string

+ TaskInfo *InternalReplicationTaskInfo

+ type InternalQueueMessage struct

+ ID int64

+ Payload []byte

+ QueueType QueueType

+ type InternalReplicationTaskInfo struct

+ BranchToken []byte

+ CreationTime int64

+ DomainID string

+ FirstEventID int64

+ NewRunBranchToken []byte

+ NextEventID int64

+ RunID string

+ ScheduledID int64

+ TaskID int64

+ TaskType int

+ Version int64

+ WorkflowID string

+ type InternalShardInfo struct

+ ClusterReplicationLevel map[string]int64

+ ClusterTimerAckLevel map[string]time.Time

+ ClusterTransferAckLevel map[string]int64

+ DomainNotificationVersion int64

+ Owner string

+ PendingFailoverMarkers *DataBlob

+ RangeID int64

+ ReplicationAckLevel int64

+ ReplicationDLQAckLevel map[string]int64

+ ShardID int

+ StolenSinceRenew int

+ TimerAckLevel time.Time

+ TimerFailoverLevels map[string]TimerFailoverLevel

+ TimerProcessingQueueStates *DataBlob

+ TransferAckLevel int64

+ TransferFailoverLevels map[string]TransferFailoverLevel

+ TransferProcessingQueueStates *DataBlob

+ UpdatedAt time.Time

+ type InternalTaskInfo struct

+ CreatedTime time.Time

+ DomainID string

+ Expiry time.Time

+ RunID string

+ ScheduleID int64

+ ScheduleToStartTimeout int32

+ TaskID int64

+ WorkflowID string

type InternalUpdateDomainRequest

+ LastUpdatedTime int64

+ type InternalUpdateShardRequest struct

+ PreviousRangeID int64

+ ShardInfo *InternalShardInfo

+ type InternalVisibilityWorkflowExecutionInfo struct

+ CloseTime time.Time

+ ExecutionTime time.Time

+ HistoryLength int64

+ Memo *DataBlob

+ RunID string

+ SearchAttributes map[string]interface{}

+ StartTime time.Time

+ Status *workflow.WorkflowExecutionCloseStatus

+ TaskList string

+ TypeName string

+ WorkflowID string

+ type QueueManager interface

+ DeleteMessageFromDLQ func(ctx context.Context, messageID int64) error

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

+ EnqueueMessage func(ctx context.Context, messagePayload []byte) error

+ EnqueueMessageToDLQ func(ctx context.Context, messagePayload []byte) (int64, error)

+ GetAckLevels func(ctx context.Context) (map[string]int64, error)

+ GetDLQAckLevels func(ctx context.Context) (map[string]int64, error)

+ RangeDeleteMessagesFromDLQ func(ctx context.Context, firstMessageID int64, lastMessageID int64) error

+ ReadMessages func(ctx context.Context, lastMessageID int64, maxCount int) ([]*QueueMessage, error)

+ ReadMessagesFromDLQ func(ctx context.Context, firstMessageID int64, lastMessageID int64, pageSize int, ...) ([]*QueueMessage, []byte, error)

+ UpdateAckLevel func(ctx context.Context, messageID int64, clusterName string) error

+ UpdateDLQAckLevel func(ctx context.Context, messageID int64, clusterName string) error

+ func NewQueueManager(persistence Queue) QueueManager

type ShardManager

+ func NewShardManager(persistence ShardStore) ShardManager

type ShardStore

+ CreateShard func(ctx context.Context, request *InternalCreateShardRequest) error

+ GetName func() string

+ GetShard func(ctx context.Context, request *InternalGetShardRequest) (*InternalGetShardResponse, error)

+ UpdateShard func(ctx context.Context, request *InternalUpdateShardRequest) error

type TaskManager

+ func NewTaskManager(persistence TaskStore) TaskManager

type TaskStore

+ CompleteTask func(ctx context.Context, request *CompleteTaskRequest) error

+ CompleteTasksLessThan func(ctx context.Context, request *CompleteTasksLessThanRequest) (int, error)

+ CreateTasks func(ctx context.Context, request *InternalCreateTasksRequest) (*CreateTasksResponse, error)

+ DeleteTaskList func(ctx context.Context, request *DeleteTaskListRequest) error

+ GetName func() string

+ GetTasks func(ctx context.Context, request *GetTasksRequest) (*InternalGetTasksResponse, error)

+ LeaseTaskList func(ctx context.Context, request *LeaseTaskListRequest) (*LeaseTaskListResponse, error)

+ ListTaskList func(ctx context.Context, request *ListTaskListRequest) (*ListTaskListResponse, error)

+ UpdateTaskList func(ctx context.Context, request *UpdateTaskListRequest) (*UpdateTaskListResponse, error)

type UpdateDomainRequest

+ LastUpdatedTime int64

Oct 8, 2020

Changes in this version

type PayloadSerializer

+ DeserializeProcessingQueueStates func(data *DataBlob) (*history.ProcessingQueueStates, error)

+ SerializeProcessingQueueStates func(states *history.ProcessingQueueStates, encodingType common.EncodingType) (*DataBlob, error)

+ type Retryer interface

+ DeleteCurrentWorkflowExecution func(request *DeleteCurrentWorkflowExecutionRequest) error

+ DeleteWorkflowExecution func(*DeleteWorkflowExecutionRequest) error

+ GetCurrentExecution func(*GetCurrentExecutionRequest) (*GetCurrentExecutionResponse, error)

+ GetShardID func() int

+ GetWorkflowExecution func(*GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)

+ IsWorkflowExecutionExists func(request *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)

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

+ ListCurrentExecutions func(request *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)

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

+ func NewPersistenceRetryer(execManager ExecutionManager, historyManager HistoryManager, ...) Retryer

type ShardInfo

+ TimerProcessingQueueStates *DataBlob

+ TransferProcessingQueueStates *DataBlob

Sep 14, 2020

Changes in this version

+ type CreateFailoverMarkersRequest struct

+ Markers []*FailoverMarkerTask

+ RangeID int64

+ type CurrentWorkflowExecution struct

+ CurrentRunID string

+ DomainID string

+ RunID string

+ State int

+ WorkflowID string

type ExecutionManager

+ CreateFailoverMarkerTasks func(request *CreateFailoverMarkersRequest) error

+ GetReplicationDLQSize func(request *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error)

+ IsWorkflowExecutionExists func(request *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)

+ ListCurrentExecutions func(request *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)

type ExecutionStore

+ CreateFailoverMarkerTasks func(request *CreateFailoverMarkersRequest) error

+ GetReplicationDLQSize func(request *GetReplicationDLQSizeRequest) (*GetReplicationDLQSizeResponse, error)

+ IsWorkflowExecutionExists func(request *IsWorkflowExecutionExistsRequest) (*IsWorkflowExecutionExistsResponse, error)

+ ListCurrentExecutions func(request *ListCurrentExecutionsRequest) (*ListCurrentExecutionsResponse, error)

type GetDomainResponse

+ PreviousFailoverVersion int64

+ type GetReplicationDLQSizeRequest struct

+ SourceClusterName string

+ type GetReplicationDLQSizeResponse struct

+ Size int64

type InternalGetDomainResponse

+ PreviousFailoverVersion int64

type InternalUpdateDomainRequest

+ PreviousFailoverVersion int64

+ type IsWorkflowExecutionExistsRequest struct

+ DomainID string

+ RunID string

+ WorkflowID string

+ type IsWorkflowExecutionExistsResponse struct

+ Exists bool

+ type ListCurrentExecutionsRequest struct

+ PageSize int

+ PageToken []byte

+ type ListCurrentExecutionsResponse struct

+ Executions []*CurrentWorkflowExecution

+ PageToken []byte

type PayloadSerializer

+ DeserializePendingFailoverMarkers func(data *DataBlob) ([]*replicator.FailoverMarkerAttributes, error)

+ SerializePendingFailoverMarkers func(markers []*replicator.FailoverMarkerAttributes, ...) (*DataBlob, error)

type ReplicationTaskInfo

+ CreationTime int64

type ShardInfo

+ PendingFailoverMarkers *DataBlob

type UpdateDomainRequest

+ PreviousFailoverVersion int64

Jul 7, 2020

Changes in this version

+ const ReplicationTaskTypeFailoverMarker

+ func PaginateHistory(historyV2Mgr HistoryManager, byBatch bool, branchToken []byte, ...) ([]*shared.HistoryEvent, []*shared.History, []byte, int, error)

type ExecutionManager

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

type ExecutionStore

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

+ type FailoverMarkerTask struct

+ DomainID string

+ SourceCluster string

+ TaskID int64

+ Version int64

+ VisibilityTimestamp time.Time

+ func (a *FailoverMarkerTask) GetTaskID() int64

+ func (a *FailoverMarkerTask) GetType() int

+ func (a *FailoverMarkerTask) GetVersion() int64

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

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

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

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

type GetDomainResponse

+ FailoverEndTime *int64

type InternalGetDomainResponse

+ FailoverEndTime *int64

+ type InternalListConcreteExecutionsEntity struct

+ ExecutionInfo *InternalWorkflowExecutionInfo

+ VersionHistories *DataBlob

+ type InternalListConcreteExecutionsResponse struct

+ Executions []*InternalListConcreteExecutionsEntity

+ NextPageToken []byte

type InternalRecordWorkflowExecutionClosedRequest

+ TaskList string

type InternalRecordWorkflowExecutionStartedRequest

+ TaskList string

type InternalUpdateDomainRequest

+ FailoverEndTime *int64

type InternalUpsertWorkflowExecutionRequest

+ TaskList string

+ type ListConcreteExecutionsEntity struct

+ ExecutionInfo *WorkflowExecutionInfo

+ VersionHistories *VersionHistories

+ type ListConcreteExecutionsRequest struct

+ PageSize int

+ PageToken []byte

+ type ListConcreteExecutionsResponse struct

+ Executions []*ListConcreteExecutionsEntity

+ PageToken []byte

type RecordWorkflowExecutionClosedRequest

+ TaskList string

type RecordWorkflowExecutionStartedRequest

+ TaskList string

type UpdateDomainRequest

+ FailoverEndTime *int64

type UpsertWorkflowExecutionRequest

+ TaskList string

type VisibilityWorkflowExecutionInfo

+ TaskList string

May 26, 2020

Changes in this version

type ActivityInfo

+ LastHeartbeatTimeoutVisibilityInSeconds int64

type ClusterReplicationConfig

+ func (config *ClusterReplicationConfig) GetCopy() *ClusterReplicationConfig

+ type DeleteReplicationTaskFromDLQRequest struct

+ SourceClusterName string

+ TaskID int64

type DomainReplicationQueue

+ DeleteMessageFromDLQ func(messageID int64) error

+ GetDLQAckLevel func() (int64, error)

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

+ PublishToDLQ func(message interface{}) error

+ RangeDeleteMessagesFromDLQ func(firstMessageID int64, lastMessageID int64) error

+ UpdateDLQAckLevel func(lastProcessedMessageID int64) error

type ExecutionManager

+ DeleteReplicationTaskFromDLQ func(request *DeleteReplicationTaskFromDLQRequest) error

+ RangeDeleteReplicationTaskFromDLQ func(request *RangeDeleteReplicationTaskFromDLQRequest) error

type ExecutionStore

+ DeleteReplicationTaskFromDLQ func(request *DeleteReplicationTaskFromDLQRequest) error

+ RangeDeleteReplicationTaskFromDLQ func(request *RangeDeleteReplicationTaskFromDLQRequest) error

type InternalActivityInfo

+ LastHeartbeatTimeoutVisibilityInSeconds int64

type InternalWorkflowMutableState

+ Checksum checksum.Checksum

type InternalWorkflowMutation

+ Checksum checksum.Checksum

type InternalWorkflowSnapshot

+ Checksum checksum.Checksum

+ type MockDomainReplicationQueue struct

+ func NewMockDomainReplicationQueue(ctrl *gomock.Controller) *MockDomainReplicationQueue

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

+ func (m *MockDomainReplicationQueue) EXPECT() *MockDomainReplicationQueueMockRecorder

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

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

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

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

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

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

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

+ func (m *MockDomainReplicationQueue) Start()

+ func (m *MockDomainReplicationQueue) Stop()

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

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

+ type MockDomainReplicationQueueMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

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

type Queue

+ DeleteMessageFromDLQ func(messageID int64) error

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

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

+ RangeDeleteMessagesFromDLQ func(firstMessageID int64, lastMessageID int64) error

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

+ UpdateDLQAckLevel func(messageID int64, clusterName string) error

type QueueMessage

+ QueueType QueueType

+ type QueueType int

+ const DomainReplicationQueueType

+ type RangeDeleteReplicationTaskFromDLQRequest struct

+ ExclusiveBeginTaskID int64

+ InclusiveEndTaskID int64

+ SourceClusterName string

type ShardInfo

+ ReplicationDLQAckLevel map[string]int64

type WorkflowMutableState

+ Checksum checksum.Checksum

type WorkflowMutation

+ Checksum checksum.Checksum

type WorkflowSnapshot

+ Checksum checksum.Checksum

Feb 15, 2020

Changes in this version

+ const WorkflowStateCorrupted

+ func IsNopUpsertWorkflowRequest(request *InternalUpsertWorkflowExecutionRequest) bool

type ExecutionManager

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

+ PutReplicationTaskToDLQ func(request *PutReplicationTaskToDLQRequest) error

+ RangeCompleteReplicationTask func(request *RangeCompleteReplicationTaskRequest) error

type ExecutionStore

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

+ PutReplicationTaskToDLQ func(request *PutReplicationTaskToDLQRequest) error

+ RangeCompleteReplicationTask func(request *RangeCompleteReplicationTaskRequest) error

+ type GetReplicationTasksFromDLQRequest struct

+ SourceClusterName string

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

+ type GetReplicationTasksFromDLQResponse = GetReplicationTasksResponse

type InternalWorkflowExecutionInfo

+ DecisionStartToCloseTimeout int32

+ type PutReplicationTaskToDLQRequest struct

+ SourceClusterName string

+ TaskInfo *ReplicationTaskInfo

+ type RangeCompleteReplicationTaskRequest struct

+ InclusiveEndTaskID int64

type TimerInfo

+ TaskStatus int64

type WorkflowExecutionInfo

+ DecisionStartToCloseTimeout int32

Nov 21, 2019

Changes in this version

+ const EventStoreVersion

Oct 18, 2019

Changes in this version

type DomainReplicationQueue

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

+ UpdateAckLevel func(lastProcessedMessageID int, clusterName string) error

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 Queue

+ DeleteMessagesBefore func(messageID int) error

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

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

+ UpdateAckLevel func(messageID int, clusterName string) error

type VersionHistories

+ CurrentVersionHistoryIndex int

+ Histories []*VersionHistory

type VersionHistory

+ BranchToken []byte

+ Items []*VersionHistoryItem

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

type VersionHistoryItem

+ EventID int64

+ Version int64

Oct 7, 2019

Changes in this version

+ const WorkflowStateVoid

+ const WorkflowStateZombie

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

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

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

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

+ func ValidateCreateWorkflowModeState(mode CreateWorkflowMode, newWorkflowSnapshot InternalWorkflowSnapshot) error

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

type ConflictResolveWorkflowExecutionRequest

+ CurrentWorkflowCAS *CurrentWorkflowCAS

+ Mode ConflictResolveWorkflowMode

+ NewWorkflowSnapshot *WorkflowSnapshot

+ type ConflictResolveWorkflowMode int

+ const ConflictResolveWorkflowModeBypassCurrent

+ const ConflictResolveWorkflowModeUpdateCurrent

type CreateWorkflowExecutionRequest

+ Mode CreateWorkflowMode

+ type CreateWorkflowMode int

+ const CreateWorkflowModeZombie

+ type CurrentWorkflowCAS struct

+ PrevLastWriteVersion int64

+ PrevRunID string

+ PrevState int

type DataBlob

+ func NewDataBlobFromThrift(blob *workflow.DataBlob) *DataBlob

+ func (d *DataBlob) ToThrift() *workflow.DataBlob

+ type DomainReplicationQueue interface

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

+ Publish func(message interface{}) error

+ func NewDomainReplicationQueue(queue Queue) DomainReplicationQueue

type InternalConflictResolveWorkflowExecutionRequest

+ CurrentWorkflowCAS *CurrentWorkflowCAS

+ Mode ConflictResolveWorkflowMode

+ NewWorkflowSnapshot *InternalWorkflowSnapshot

type InternalCreateWorkflowExecutionRequest

+ Mode CreateWorkflowMode

type InternalUpdateWorkflowExecutionRequest

+ Mode UpdateWorkflowMode

type InternalWorkflowMutableState

+ ActivityInfos map[int64]*InternalActivityInfo

+ VersionHistories *DataBlob

type InternalWorkflowMutation

+ LastWriteVersion int64

+ StartVersion int64

+ UpsertTimerInfos []*TimerInfo

+ VersionHistories *DataBlob

type InternalWorkflowSnapshot

+ LastWriteVersion int64

+ StartVersion int64

+ VersionHistories *DataBlob

type PayloadSerializer

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

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

+ type Queue interface

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

+ EnqueueMessage func(messagePayload []byte) 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 int

+ Payload []byte

type UpdateWorkflowExecutionRequest

+ Mode UpdateWorkflowMode

+ type UpdateWorkflowMode int

+ const UpdateWorkflowModeBypassCurrent

+ const UpdateWorkflowModeUpdateCurrent

type VersionHistories

+ func NewVersionHistoriesFromThrift(input *shared.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) ToThrift() *shared.VersionHistories

type VersionHistory

+ func NewVersionHistoryFromThrift(input *shared.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) 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) ToThrift() *shared.VersionHistory

type VersionHistoryItem

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

+ func NewVersionHistoryItemFromThrift(input *shared.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) ToThrift() *shared.VersionHistoryItem

type WorkflowExecutionInfo

+ func (e *WorkflowExecutionInfo) UpdateWorkflowStateCloseStatus(state int, closeStatus int) error

type WorkflowMutableState

+ VersionHistories *VersionHistories

type WorkflowMutation

+ UpsertTimerInfos []*TimerInfo

+ VersionHistories *VersionHistories

type WorkflowSnapshot

+ VersionHistories *VersionHistories

Sep 17, 2019

Changes in this version

+ func ToThriftWorkflowExecutionCloseStatus(closeStatus int) workflow.WorkflowExecutionCloseStatus

type ActivityInfo

+ LastFailureDetails []byte

type ChildExecutionInfo

+ ParentClosePolicy workflow.ParentClosePolicy

+ type DeleteTaskRequest struct

+ ShardID int

+ TaskID int64

+ Type int

type ExecutionManager

+ DeleteTask func(request *DeleteTaskRequest) error

type ExecutionStore

+ DeleteTask func(request *DeleteTaskRequest) error

+ type GetAllHistoryTreeBranchesRequest struct

+ NextPageToken []byte

+ PageSize int

+ type GetAllHistoryTreeBranchesResponse struct

+ Branches []HistoryBranchDetail

+ NextPageToken []byte

+ type HistoryBranchDetail struct

+ BranchID string

+ ForkTime time.Time

+ Info string

+ TreeID string

type HistoryV2Manager

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

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

type HistoryV2Store

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

type InternalActivityInfo

+ LastFailureDetails []byte

type InternalChildExecutionInfo

+ ParentClosePolicy workflow.ParentClosePolicy

type InternalReadHistoryBranchRequest

+ LastNodeID int64

+ LastTransactionID int64

type InternalReadHistoryBranchResponse

+ LastNodeID int64

+ LastTransactionID int64

+ type ReadRawHistoryBranchResponse struct

+ HistoryEventBlobs []*DataBlob

+ NextPageToken []byte

+ Size int

type ReplicationTaskInfo

+ func (t *ReplicationTaskInfo) GetDomainID() string

+ func (t *ReplicationTaskInfo) GetRunID() string

+ func (t *ReplicationTaskInfo) GetWorkflowID() string

type RequestCancelInfo

+ InitiatedEventBatchID int64

type ShardInfo

+ ClusterReplicationLevel map[string]int64

type SignalInfo

+ InitiatedEventBatchID int64

type TimerTaskInfo

+ func (t *TimerTaskInfo) GetDomainID() string

+ func (t *TimerTaskInfo) GetRunID() string

+ func (t *TimerTaskInfo) GetWorkflowID() string

type TransferTaskInfo

+ func (t *TransferTaskInfo) GetDomainID() string

+ func (t *TransferTaskInfo) GetRunID() string

+ func (t *TransferTaskInfo) GetWorkflowID() string

Aug 12, 2019

Changes in this version

type InternalWorkflowExecutionInfo

+ DecisionOriginalScheduledTimestamp int64

type WorkflowExecutionInfo

+ DecisionOriginalScheduledTimestamp int64

Jul 30, 2019

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

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

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

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

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 8, 2019

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

Changes in this version

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

Feb 12, 2019

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

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

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 24, 2018

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

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

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

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

Mar 12, 2018

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

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

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

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

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

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

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)