persistence

package

Go to main page

Versions in this module

v0

v0.8.6

Aug 27, 2019

v0.8.5

Aug 27, 2019

v0.8.4

Aug 26, 2019

v0.8.3

Aug 14, 2019

v0.8.2

Aug 13, 2019

v0.8.1

Aug 12, 2019

v0.8.0

Aug 12, 2019

Changes in this version

type InternalWorkflowExecutionInfo

+ DecisionOriginalScheduledTimestamp int64

type WorkflowExecutionInfo

+ DecisionOriginalScheduledTimestamp int64

v0.7.3

Aug 8, 2019

v0.7.2

Aug 8, 2019

v0.7.1

Aug 6, 2019

v0.7.0

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

v0.6.1

Jul 26, 2019

v0.6.0

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

v0.5.9

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

v0.5.8

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)

v0.5.7

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

v0.5.5

Mar 12, 2019

v0.5.4

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

v0.5.3

Feb 19, 2019

Changes in this version

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

v0.5.2

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

v0.5.1

Jan 18, 2019

v0.5.0

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)

v0.4.0

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)

v0.3.15

Jul 26, 2018

v0.3.14

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

v0.3.13

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

v0.3.12

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)

v0.3.11

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

v0.3.10

Apr 10, 2018

v0.3.9

Mar 14, 2018

v0.3.8

Mar 13, 2018

v0.3.7

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

v0.3.6

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

v0.3.5

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

v0.3.4

Dec 12, 2017

v0.3.3

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

v0.3.2

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

v0.3.1

Aug 15, 2017

v0.3.0

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)

v0.2.0

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)

v0.1.1-beta

Jun 7, 2017

v0.1.0-beta

Jun 6, 2017

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