history

Aug 12, 2019

Changes in this version

type Config

+ DecisionHeartbeatTimeout dynamicconfig.DurationPropertyFnWithDomainFilter

Jul 30, 2019

Changes in this version

type Config

+ StickyTTL dynamicconfig.DurationPropertyFnWithDomainFilter

+ TimerProcessorHistoryArchivalSizeLimit dynamicconfig.IntPropertyFn

+ TimerProcessorHistoryArchivalTimeLimit dynamicconfig.DurationPropertyFn

type Engine

+ NotifyNewHistoryEvent func(event *historyEventNotification)

+ NotifyNewReplicationTasks func(tasks []persistence.Task)

+ NotifyNewTimerTasks func(tasks []persistence.Task)

+ NotifyNewTransferTasks func(tasks []persistence.Task)

type MockHistoryEngine

+ func (_m *MockHistoryEngine) NotifyNewHistoryEvent(event *historyEventNotification)

+ func (_m *MockHistoryEngine) NotifyNewReplicationTasks(tasks []persistence.Task)

+ func (_m *MockHistoryEngine) NotifyNewTimerTasks(tasks []persistence.Task)

+ func (_m *MockHistoryEngine) NotifyNewTransferTasks(tasks []persistence.Task)

type ShardContext

+ ConflictResolveWorkflowExecution func(request *persistence.ConflictResolveWorkflowExecutionRequest) error

+ GenerateTransferTaskID func() (int64, error)

+ GenerateTransferTaskIDs func(number int) ([]int64, error)

+ GetClusterMetadata func() cluster.Metadata

+ GetEngine func() Engine

+ SetEngine func(Engine)

type TestShardContext

+ func (s *TestShardContext) ConflictResolveWorkflowExecution(request *persistence.ConflictResolveWorkflowExecutionRequest) error

+ func (s *TestShardContext) GenerateTransferTaskID() (int64, error)

+ func (s *TestShardContext) GenerateTransferTaskIDs(number int) ([]int64, error)

+ func (s *TestShardContext) GetClusterMetadata() cluster.Metadata

+ func (s *TestShardContext) GetEngine() Engine

+ func (s *TestShardContext) SetEngine(engine Engine)

+ type WatcherSnapshot struct

+ CloseStatus int

+ type WorkflowWatcher interface

+ GetLatestSnapshot func() *WatcherSnapshot

+ Publish func(*WatcherSnapshot)

+ Subscribe func() (int64, <-chan struct{})

+ Unsubscribe func(int64)

+ func NewWorkflowWatcher() WorkflowWatcher

Jul 24, 2019

Changes in this version

+ var ErrRetryRaceCondition = &shared.RetryTaskError

+ var ErrUnreappliableEvent = &shared.BadRequestError

+ var ErrWorkflowFinished = &workflow.InternalServiceError

+ var ErrWorkflowMutationDecision = &shared.BadRequestError

+ var ErrWorkflowMutationSignal = &shared.BadRequestError

type Config

+ MaxDecisionStartToCloseSeconds dynamicconfig.IntPropertyFnWithDomainFilter

+ SearchAttributesNumberOfKeysLimit dynamicconfig.IntPropertyFnWithDomainFilter

+ SearchAttributesSizeOfValueLimit dynamicconfig.IntPropertyFnWithDomainFilter

+ SearchAttributesTotalSizeLimit dynamicconfig.IntPropertyFnWithDomainFilter

+ ValidSearchAttributes dynamicconfig.MapPropertyFn

Jun 17, 2019

Changes in this version

type Config

+ ArchiveRequestRPS dynamicconfig.IntPropertyFn

May 14, 2019

Changes in this version

+ const ErrMessageHistorySizeZero

+ var ErrEventIDMismatch = &shared.BadRequestError

+ var ErrEventVersionMismatch = &shared.BadRequestError

+ var ErrInvalidDomainID = &shared.BadRequestError

+ var ErrInvalidExecution = &shared.BadRequestError

+ var ErrInvalidRunID = &shared.BadRequestError

+ func FindAutoResetPoint(badBinaries *workflow.BadBinaries, autoResetPoints *workflow.ResetPoints) (reason string, pt *workflow.ResetPointInfo)

type Config

+ MaxAutoResetPoints dynamicconfig.IntPropertyFnWithDomainFilter

type Handler

+ func (h *Handler) RegisterHandler()

May 8, 2019

Changes in this version

type Config

+ ThrottledLogRPS dynamicconfig.IntPropertyFn

type ShardContext

+ GetThrottledLogger func() log.Logger

type TestShardContext

+ func (s *TestShardContext) GetThrottledLogger() log.Logger

Mar 8, 2019

Changes in this version

+ const ErrMessageNewRunHistorySizeZero

+ var ErrEventsAterWorkflowFinish = &shared.InternalServiceError

type Config

+ EmitShardDiffLog dynamicconfig.BoolPropertyFn

+ NumArchiveSystemWorkflows dynamicconfig.IntPropertyFn

type ShardContext

+ GetTransferTaskIDs func(number int) ([]int64, error)

type TestShardContext

+ func (s *TestShardContext) GetTransferTaskIDs(number int) ([]int64, error)

Feb 19, 2019

Changes in this version

type Config

+ EnableReadFromClosedExecutionV2 dynamicconfig.BoolPropertyFn

Feb 12, 2019

Changes in this version

type Config

+ EventsCacheInitialSize dynamicconfig.IntPropertyFn

+ EventsCacheMaxSize dynamicconfig.IntPropertyFn

+ EventsCacheTTL dynamicconfig.DurationPropertyFn

type Engine

+ ResetWorkflowExecution func(ctx context.Context, request *h.ResetWorkflowExecutionRequest) (*workflow.ResetWorkflowExecutionResponse, error)

type Handler

+ func (h *Handler) ResetWorkflowExecution(ctx context.Context, wrappedRequest *hist.ResetWorkflowExecutionRequest) (*gen.ResetWorkflowExecutionResponse, error)

+ type MockEventsCache struct

type MockHistoryEngine

+ func (_m *MockHistoryEngine) ResetWorkflowExecution(ctx context.Context, request *gohistory.ResetWorkflowExecutionRequest) (*shared.ResetWorkflowExecutionResponse, error)

type ShardContext

+ GetEventsCache func() eventsCache

+ ResetWorkflowExecution func(request *persistence.ResetWorkflowExecutionRequest) error

type TestShardContext

+ func (s *TestShardContext) GetEventsCache() eventsCache

+ func (s *TestShardContext) ResetWorkflowExecution(request *persistence.ResetWorkflowExecutionRequest) error

Jan 7, 2019

Changes in this version

+ var ErrCorruptedMutableStateDecision = &shared.BadRequestError

+ var ErrEmptyHistoryRawEventBatch = &shared.BadRequestError

+ var ErrRetryBufferEventsMsg = "retry on applying buffer events"

+ var ErrRetryEmptyEventsMsg = "retry on applying empty events"

+ var ErrRetryExistingWorkflowMsg = "workflow with same version is running"

+ var ErrRetrySyncActivityMsg = "retry on applying sync activity"

+ var ErrSignalsLimitExceeded = &workflow.LimitExceededError

+ var ErrUnknownEncodingType = &shared.BadRequestError

+ var ErrWorkflowNotFoundMsg = "retry on workflow not found"

+ func GenerateReplicationTask(targetClusters []string, task *persistence.ReplicationTaskInfo, ...) (*replicator.ReplicationTask, error)

+ func GetAllHistory(historyMgr persistence.HistoryManager, ...) (*shared.History, []*shared.History, error)

+ func PaginateHistory(historyMgr persistence.HistoryManager, ...) ([]*shared.HistoryEvent, []*shared.History, []byte, int, error)

type Config

+ BlobSizeLimitError dynamicconfig.IntPropertyFnWithDomainFilter

+ BlobSizeLimitWarn dynamicconfig.IntPropertyFnWithDomainFilter

+ EnableEventsV2 dynamicconfig.BoolPropertyFnWithDomainFilter

+ EnableHistoryRereplication dynamicconfig.BoolPropertyFn

+ EnableVisibilityToKafka dynamicconfig.BoolPropertyFn

+ HistoryCountLimitError dynamicconfig.IntPropertyFnWithDomainFilter

+ HistoryCountLimitWarn dynamicconfig.IntPropertyFnWithDomainFilter

+ HistorySizeLimitError dynamicconfig.IntPropertyFnWithDomainFilter

+ HistorySizeLimitWarn dynamicconfig.IntPropertyFnWithDomainFilter

+ MaxIDLengthLimit dynamicconfig.IntPropertyFn

+ MaximumSignalsPerExecution dynamicconfig.IntPropertyFnWithDomainFilter

+ NumSysWorkflows dynamicconfig.IntPropertyFn

+ func NewDynamicConfigForEventsV2Test() *Config

+ func NewDynamicConfigForTest() *Config

type Engine

+ ReplicateRawEvents func(ctx context.Context, request *h.ReplicateRawEventsRequest) error

type Handler

+ func (h *Handler) ReplicateRawEvents(ctx context.Context, replicateRequest *hist.ReplicateRawEventsRequest) error

type MockHistoryEngine

+ func (_m *MockHistoryEngine) ReplicateRawEvents(ctx context.Context, request *gohistory.ReplicateRawEventsRequest) error

type MockTimerQueueProcessor

+ func (_m *MockTimerQueueProcessor) LockTaskPrrocessing()

+ func (_m *MockTimerQueueProcessor) UnlockTaskPrrocessing()

type MockTransferQueueProcessor

+ func (_m *MockTransferQueueProcessor) LockTaskPrrocessing()

+ func (_m *MockTransferQueueProcessor) UnlockTaskPrrocessing()

type RemoteTimerGateImpl

+ func (timerGate *RemoteTimerGateImpl) Close()

type ShardContext

+ AppendHistoryV2Events func(request *persistence.AppendHistoryNodesRequest, domainID string) (int, error)

+ GetHistoryV2Manager func() persistence.HistoryV2Manager

type TestShardContext

+ func (s *TestShardContext) AppendHistoryV2Events(request *persistence.AppendHistoryNodesRequest, domainID string) (int, error)

+ func (s *TestShardContext) GetHistoryV2Manager() persistence.HistoryV2Manager

type TimerGate

+ Close func()

Oct 19, 2018

Changes in this version

+ var ErrImpossibleLocalRemoteMissingReplicationInfo = &shared.BadRequestError

+ var ErrImpossibleRemoteClaimSeenHigherVersion = &shared.BadRequestError

+ var ErrInternalFailure = &shared.BadRequestError

+ var ErrMoreThan2DC = &shared.BadRequestError

+ var ErrRetrySyncActivity = &shared.RetryTaskError

+ var ErrSignalOverSize = &workflow.BadRequestError

+ var ErrTaskDiscarded = errors.New("passive task pending for too long")

+ func NewVisibilitySamplingClient(persistence persistence.VisibilityManager, config *Config, ...) persistence.VisibilityManager

type Config

+ EnableSyncActivityHeartbeat dynamicconfig.BoolPropertyFn

+ EnableVisibilitySampling dynamicconfig.BoolPropertyFn

+ EventEncodingType dynamicconfig.StringPropertyFnWithDomainFilter

+ RPS dynamicconfig.IntPropertyFn

+ TimerProcessorMaxTimeShift dynamicconfig.DurationPropertyFn

+ VisibilityClosedMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityOpenMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

type Engine

+ SyncActivity func(ctx context.Context, request *h.SyncActivityRequest) error

type Handler

+ func (h *Handler) SyncActivity(ctx context.Context, syncActivityRequest *hist.SyncActivityRequest) error

type MockHistoryEngine

+ func (_m *MockHistoryEngine) SyncActivity(ctx context.Context, request *gohistory.SyncActivityRequest) error

+ type MockTimerProcessor struct

type ShardContext

+ GetTimerMaxReadLevel func(cluster string) time.Time

+ UpdateTimerMaxReadLevel func(cluster string) time.Time

type TestShardContext

+ func (s *TestShardContext) GetTimerMaxReadLevel(cluster string) time.Time

+ func (s *TestShardContext) UpdateTimerMaxReadLevel(cluster string) time.Time

Jul 26, 2018

Changes in this version

type Config

+ ReplicatorProcessorUpdateAckIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

+ TimerProcessorUpdateAckIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

+ TransferProcessorUpdateAckIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

type QueueProcessorOptions

+ UpdateAckIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

Jul 24, 2018

Changes in this version

+ var ErrCorruptedReplicationInfo = &shared.BadRequestError

+ var ErrMissingReplicationInfo = &shared.BadRequestError

+ var ErrRetryBufferEvents = &shared.RetryTaskError

+ var ErrRetryEntityNotExists = &shared.RetryTaskError

+ var ErrRetryExecutionAlreadyStarted = &shared.RetryTaskError

+ var ErrRetryExistingWorkflow = &shared.RetryTaskError

type Config

+ PersistenceMaxQPS dynamicconfig.FloatPropertyFn

+ ReplicatorProcessorMaxPollIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

+ ReplicatorProcessorStartDelay dynamicconfig.DurationPropertyFn

+ ShardSyncMinInterval dynamicconfig.DurationPropertyFn

+ StandbyClusterDelay dynamicconfig.DurationPropertyFn

+ TimerProcessorFailoverMaxPollRPS dynamicconfig.IntPropertyFn

+ TimerProcessorFailoverStartDelay dynamicconfig.DurationPropertyFn

+ TimerProcessorMaxPollIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

+ TimerProcessorMaxPollRPS dynamicconfig.IntPropertyFn

+ TimerProcessorStartDelay dynamicconfig.DurationPropertyFn

+ TransferProcessorFailoverMaxPollRPS dynamicconfig.IntPropertyFn

+ TransferProcessorFailoverStartDelay dynamicconfig.DurationPropertyFn

+ TransferProcessorMaxPollIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

+ TransferProcessorStartDelay dynamicconfig.DurationPropertyFn

type Engine

+ SyncShardStatus func(ctx context.Context, request *h.SyncShardStatusRequest) error

type Handler

+ func (h *Handler) SyncShardStatus(ctx context.Context, syncShardStatusRequest *hist.SyncShardStatusRequest) error

type MockHistoryEngine

+ func (_m *MockHistoryEngine) SyncShardStatus(ctx context.Context, request *gohistory.SyncShardStatusRequest) error

type QueueProcessorOptions

+ MaxPollIntervalJitterCoefficient dynamicconfig.FloatPropertyFn

+ StartDelay dynamicconfig.DurationPropertyFn

type ShardContext

+ DeleteTimerFailoverLevel func(failoverID string) error

+ DeleteTransferFailoverLevel func(failoverID string) error

+ GetAllTimerFailoverLevels func() map[string]persistence.TimerFailoverLevel

+ GetAllTransferFailoverLevels func() map[string]persistence.TransferFailoverLevel

+ UpdateTimerFailoverLevel func(failoverID string, level persistence.TimerFailoverLevel) error

+ UpdateTransferFailoverLevel func(failoverID string, level persistence.TransferFailoverLevel) error

type TestShardContext

+ func (s *TestShardContext) DeleteTimerFailoverLevel(failoverID string) error

+ func (s *TestShardContext) DeleteTransferFailoverLevel(failoverID string) error

+ func (s *TestShardContext) GetAllTimerFailoverLevels() map[string]persistence.TimerFailoverLevel

+ func (s *TestShardContext) GetAllTransferFailoverLevels() map[string]persistence.TransferFailoverLevel

+ func (s *TestShardContext) UpdateTimerFailoverLevel(failoverID string, level persistence.TimerFailoverLevel) error

+ func (s *TestShardContext) UpdateTransferFailoverLevel(failoverID string, level persistence.TransferFailoverLevel) error

Jun 9, 2018

Changes in this version

type Engine

+ DescribeMutableState func(ctx context.Context, request *h.DescribeMutableStateRequest) (*h.DescribeMutableStateResponse, error)

type Handler

+ func (h *Handler) DescribeHistoryHost(ctx context.Context, request *gen.DescribeHistoryHostRequest) (*gen.DescribeHistoryHostResponse, error)

+ func (h *Handler) DescribeMutableState(ctx context.Context, request *hist.DescribeMutableStateRequest) (*hist.DescribeMutableStateResponse, error)

type MockHistoryEngine

+ func (_m *MockHistoryEngine) DescribeMutableState(ctx context.Context, request *gohistory.DescribeMutableStateRequest) (*gohistory.DescribeMutableStateResponse, error)

type ShardContext

+ GetDomainNotificationVersion func() int64

+ UpdateDomainNotificationVersion func(domainNotificationVersion int64) error

type TestShardContext

+ func (s *TestShardContext) GetDomainNotificationVersion() int64

+ func (s *TestShardContext) UpdateDomainNotificationVersion(domainNotificationVersion int64) error

May 26, 2018

Changes in this version

+ var ErrBufferedEventsLimitExceeded = &workflow.LimitExceededError

+ var ErrTaskRetry = errors.New("passive task should retry due to condition in mutable state is not met")

type Config

+ MaximumBufferedEventsBatch int

+ ReplicatorProcessorUpdateShardTaskCount int

+ ShardUpdateMinInterval time.Duration

+ TimerProcessorCompleteTimerFailureRetryCount int

+ TimerProcessorCompleteTimerInterval time.Duration

+ TimerProcessorMaxPollInterval time.Duration

+ TimerProcessorStandbyTaskDelay time.Duration

+ TimerProcessorUpdateShardTaskCount int

+ TimerTaskMaxRetryCount int

+ TimerTaskWorkerCount int

+ TransferProcessorCompleteTransferFailureRetryCount int

+ TransferProcessorCompleteTransferInterval time.Duration

+ TransferProcessorStandbyTaskDelay time.Duration

+ TransferProcessorUpdateShardTaskCount int

+ type MockProcessor struct

+ type MockQueueAckMgr struct

+ type MockTimerQueueProcessor struct

+ func (_m *MockTimerQueueProcessor) FailoverDomain(domainID string, standbyClusterName string)

+ func (_m *MockTimerQueueProcessor) NotifyNewTimers(clusterName string, currentTime time.Time, timerTask []persistence.Task)

+ func (_m *MockTimerQueueProcessor) Start()

+ func (_m *MockTimerQueueProcessor) Stop()

+ type MockTransferQueueProcessor struct

+ func (_m *MockTransferQueueProcessor) FailoverDomain(domainID string, standbyClusterName string)

+ func (_m *MockTransferQueueProcessor) NotifyNewTask(clusterName string, currentTime time.Time, transferTask []persistence.Task)

+ func (_m *MockTransferQueueProcessor) Start()

+ func (_m *MockTransferQueueProcessor) Stop()

type QueueProcessorOptions

+ UpdateShardTaskCount int

type ShardContext

+ GetShardID func() int

+ GetTimerClusterAckLevel func(cluster string) time.Time

+ GetTransferClusterAckLevel func(cluster string) int64

+ ResetMutableState func(request *persistence.ResetMutableStateRequest) error

+ UpdateTimerClusterAckLevel func(cluster string, ackLevel time.Time) error

+ UpdateTransferClusterAckLevel func(cluster string, ackLevel int64) error

type TestShardContext

+ func (s *TestShardContext) GetShardID() int

+ func (s *TestShardContext) GetTimerClusterAckLevel(cluster string) time.Time

+ func (s *TestShardContext) GetTransferClusterAckLevel(cluster string) int64

+ func (s *TestShardContext) ResetMutableState(request *persistence.ResetMutableStateRequest) error

+ func (s *TestShardContext) UpdateTimerClusterAckLevel(cluster string, ackLevel time.Time) error

+ func (s *TestShardContext) UpdateTransferClusterAckLevel(cluster string, ackLevel int64) error

Apr 16, 2018

Changes in this version

type Config

+ ReplicatorProcessorForceUpdateInterval time.Duration

+ ReplicatorProcessorMaxPollInterval time.Duration

+ ReplicatorProcessorMaxPollRPS int

+ ReplicatorProcessorUpdateAckInterval time.Duration

+ ReplicatorTaskBatchSize int

+ ReplicatorTaskMaxRetryCount int

+ ReplicatorTaskWorkerCount int

+ TransferTaskMaxRetryCount int

type Engine

+ ReplicateEvents func(request *h.ReplicateEventsRequest) error

+ SignalWithStartWorkflowExecution func(request *h.SignalWithStartWorkflowExecutionRequest) (*workflow.StartWorkflowExecutionResponse, error)

type Handler

+ func (h *Handler) ReplicateEvents(ctx context.Context, replicateRequest *hist.ReplicateEventsRequest) error

+ func (h *Handler) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*gen.StartWorkflowExecutionResponse, error)

+ type LocalTimerGate interface

+ Close func()

+ func NewLocalTimerGate() LocalTimerGate

+ type LocalTimerGateImpl struct

+ func (timerGate *LocalTimerGateImpl) Close()

+ func (timerGate *LocalTimerGateImpl) FireAfter(now time.Time) bool

+ func (timerGate *LocalTimerGateImpl) FireChan() <-chan struct{}

+ func (timerGate *LocalTimerGateImpl) Update(nextTime time.Time) bool

type MockHistoryEngine

+ func (_m *MockHistoryEngine) ReplicateEvents(request *gohistory.ReplicateEventsRequest) error

+ func (_m *MockHistoryEngine) SignalWithStartWorkflowExecution(request *gohistory.SignalWithStartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

+ type MockTimerQueueAckMgr struct

+ type QueueProcessorOptions struct

+ BatchSize int

+ ForceUpdateInterval time.Duration

+ MaxPollInterval time.Duration

+ MaxPollRPS int

+ MaxRetryCount int

+ MetricScope int

+ UpdateAckInterval time.Duration

+ WorkerCount int

+ type RemoteTimerGate interface

+ SetCurrentTime func(nextTime time.Time) bool

+ func NewRemoteTimerGate() RemoteTimerGate

+ type RemoteTimerGateImpl struct

+ func (timerGate *RemoteTimerGateImpl) FireAfter(now time.Time) bool

+ func (timerGate *RemoteTimerGateImpl) FireChan() <-chan struct{}

+ func (timerGate *RemoteTimerGateImpl) SetCurrentTime(currentTime time.Time) bool

+ func (timerGate *RemoteTimerGateImpl) Update(nextTime time.Time) bool

type ShardContext

+ GetCurrentTime func(cluster string) time.Time

+ GetReplicatorAckLevel func() int64

+ GetService func() service.Service

+ SetCurrentTime func(cluster string, currentTime time.Time)

+ UpdateReplicatorAckLevel func(ackLevel int64) error

type TestBase

+ func (s *TestBase) SetupDomains()

+ func (s *TestBase) TeardownDomains()

type TestShardContext

+ func (s *TestShardContext) GetCurrentTime(cluster string) time.Time

+ func (s *TestShardContext) GetReplicatorAckLevel() int64

+ func (s *TestShardContext) GetService() service.Service

+ func (s *TestShardContext) SetCurrentTime(cluster string, currentTime time.Time)

+ func (s *TestShardContext) UpdateReplicatorAckLevel(ackLevel int64) error

+ type TimerGate interface

+ FireAfter func(now time.Time) bool

+ FireChan func() <-chan struct{}

+ Update func(nextTime time.Time) bool

+ type TimerSequenceID struct

+ TaskID int64

+ VisibilityTimestamp time.Time

+ func (s TimerSequenceID) String() string

Mar 12, 2018

Changes in this version

+ var ErrCancellationAlreadyRequested = &workflow.CancellationAlreadyRequestedError

+ var ErrWorkflowParent = &workflow.EntityNotExistsError

type Engine

+ ResetStickyTaskList func(resetRequest *h.ResetStickyTaskListRequest) (*h.ResetStickyTaskListResponse, error)

type Handler

+ func (h *Handler) ResetStickyTaskList(ctx context.Context, resetRequest *hist.ResetStickyTaskListRequest) (*hist.ResetStickyTaskListResponse, error)

type MockHistoryEngine

+ func (_m *MockHistoryEngine) ResetStickyTaskList(request *gohistory.ResetStickyTaskListRequest) (*gohistory.ResetStickyTaskListResponse, error)

Jan 30, 2018

Changes in this version

+ var ErrActivityTaskNotFound = &workflow.EntityNotExistsError

+ var ErrDeserializingToken = &workflow.BadRequestError

+ var ErrStaleState = errors.New("Cache mutable state could potentially be stale")

+ var ErrWorkflowCompleted = &workflow.EntityNotExistsError

type Engine

+ RemoveSignalMutableState func(request *h.RemoveSignalMutableStateRequest) error

type Handler

+ func (h *Handler) RemoveSignalMutableState(ctx context.Context, wrappedRequest *hist.RemoveSignalMutableStateRequest) error

type MockHistoryEngine

+ func (_m *MockHistoryEngine) RemoveSignalMutableState(request *gohistory.RemoveSignalMutableStateRequest) error

Jan 12, 2018

Changes in this version

+ var FailedWorkflowCloseState = map[int]bool

type Engine

+ GetMutableState func(ctx context.Context, request *h.GetMutableStateRequest) (*h.GetMutableStateResponse, error)

type Handler

+ func (h *Handler) GetMutableState(ctx context.Context, getRequest *hist.GetMutableStateRequest) (*hist.GetMutableStateResponse, error)

type MockHistoryEngine

+ func (_m *MockHistoryEngine) GetMutableState(ctx context.Context, request *gohistory.GetMutableStateRequest) (*gohistory.GetMutableStateResponse, error)

type ShardContext

+ GetDomainCache func() cache.DomainCache

type TestShardContext

+ func (s *TestShardContext) GetDomainCache() cache.DomainCache

Dec 5, 2017

Changes in this version

type Config

+ LongPollExpirationInterval time.Duration

+ func (config *Config) GetShardID(workflowID string) int

type Engine

+ DescribeWorkflowExecution func(request *h.DescribeWorkflowExecutionRequest) (*workflow.DescribeWorkflowExecutionResponse, error)

+ RespondDecisionTaskFailed func(request *h.RespondDecisionTaskFailedRequest) error

type Handler

+ func (h *Handler) DescribeWorkflowExecution(ctx context.Context, request *hist.DescribeWorkflowExecutionRequest) (*gen.DescribeWorkflowExecutionResponse, error)

+ func (h *Handler) RespondDecisionTaskFailed(ctx context.Context, wrappedRequest *hist.RespondDecisionTaskFailedRequest) error

type MockHistoryEngine

+ func (_m *MockHistoryEngine) DescribeWorkflowExecution(request *gohistory.DescribeWorkflowExecutionRequest) (*shared.DescribeWorkflowExecutionResponse, error)

+ func (_m *MockHistoryEngine) RespondDecisionTaskFailed(request *gohistory.RespondDecisionTaskFailedRequest) error

type ShardContext

+ NotifyNewHistoryEvent func(event *historyEventNotification) error

type TestShardContext

+ func (s *TestShardContext) NotifyNewHistoryEvent(event *historyEventNotification) error

Sep 29, 2017

Changes in this version

type Config

+ ExecutionMgrNumConns int

+ HistoryMgrNumConns int

+ TimerProcessorForceUpdateInterval time.Duration

+ TransferProcessorForceUpdateInterval time.Duration

Aug 15, 2017

Changes in this version

+ type Config struct

+ AcquireShardInterval time.Duration

+ DefaultScheduleToCloseActivityTimeoutInSecs int32

+ DefaultScheduleToStartActivityTimeoutInSecs int32

+ DefaultStartToCloseActivityTimeoutInSecs int32

+ HistoryCacheInitialSize int

+ HistoryCacheMaxSize int

+ HistoryCacheTTL time.Duration

+ NumberOfShards int

+ ProcessTimerTaskWorkerCount int

+ RangeSizeBits uint

+ TimerProcessorGetFailureRetryCount int

+ TimerProcessorUpdateAckInterval time.Duration

+ TimerProcessorUpdateFailureRetryCount int

+ TimerTaskBatchSize int

+ TransferProcessorMaxPollInterval time.Duration

+ TransferProcessorMaxPollRPS int

+ TransferProcessorUpdateAckInterval time.Duration

+ TransferTaskBatchSize int

+ TransferTaskWorkerCount int

+ func NewConfig(numberOfShards int) *Config

type ShardContext

+ GetConfig func() *Config

type TestShardContext

+ func (s *TestShardContext) GetConfig() *Config

Aug 7, 2017

Changes in this version

+ const TimerTaskStatusCreated

+ const TimerTaskStatusCreatedHeartbeat

+ const TimerTaskStatusCreatedScheduleToClose

+ const TimerTaskStatusCreatedScheduleToStart

+ const TimerTaskStatusCreatedStartToClose

+ const TimerTaskStatusNone

type Handler

+ func (h *Handler) Health(ctx thrift.Context) (*health.HealthStatus, error)

+ type TestBase struct

+ ShardContext *TestShardContext

+ func (s *TestBase) SetupWorkflowStore()

+ func (s *TestBase) SetupWorkflowStoreWithOptions(options persistence.TestBaseOptions)

+ type TestShardContext struct

+ func (s *TestShardContext) AppendHistoryEvents(request *persistence.AppendHistoryEventsRequest) error

+ func (s *TestShardContext) CreateWorkflowExecution(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

+ func (s *TestShardContext) GetExecutionManager() persistence.ExecutionManager

+ func (s *TestShardContext) GetHistoryManager() persistence.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 *persistence.UpdateWorkflowExecutionRequest) error

Jun 30, 2017

Changes in this version

+ const DefaultScheduleToCloseActivityTimeoutInSecs

+ const DefaultScheduleToStartActivityTimeoutInSecs

+ const DefaultStartToCloseActivityTimeoutInSecs

+ var ErrConflict = errors.New("Conditional update failed")

+ var ErrDuplicate = errors.New("Duplicate task, completing it")

+ var ErrMaxAttemptsExceeded = errors.New("Maximum attempts exceeded to update history")

+ var ErrTryLock = &workflow.InternalServiceError

+ func NewExecutionManagerFactory(config *config.Cassandra, logger bark.Logger, mClient metrics.Client) persistence.ExecutionManagerFactory

+ func NewService(params *service.BootstrapParams) common.Daemon

+ type Engine interface

+ GetWorkflowExecutionNextEventID func(request *h.GetWorkflowExecutionNextEventIDRequest) (*h.GetWorkflowExecutionNextEventIDResponse, error)

+ RecordActivityTaskHeartbeat func(request *h.RecordActivityTaskHeartbeatRequest) (*workflow.RecordActivityTaskHeartbeatResponse, error)

+ RecordActivityTaskStarted func(request *h.RecordActivityTaskStartedRequest) (*h.RecordActivityTaskStartedResponse, error)

+ RecordChildExecutionCompleted func(request *h.RecordChildExecutionCompletedRequest) error

+ RecordDecisionTaskStarted func(request *h.RecordDecisionTaskStartedRequest) (*h.RecordDecisionTaskStartedResponse, error)

+ RequestCancelWorkflowExecution func(request *h.RequestCancelWorkflowExecutionRequest) error

+ RespondActivityTaskCanceled func(request *h.RespondActivityTaskCanceledRequest) error

+ RespondActivityTaskCompleted func(request *h.RespondActivityTaskCompletedRequest) error

+ RespondActivityTaskFailed func(request *h.RespondActivityTaskFailedRequest) error

+ RespondDecisionTaskCompleted func(request *h.RespondDecisionTaskCompletedRequest) error

+ ScheduleDecisionTask func(request *h.ScheduleDecisionTaskRequest) error

+ SignalWorkflowExecution func(request *h.SignalWorkflowExecutionRequest) error

+ StartWorkflowExecution func(request *h.StartWorkflowExecutionRequest) (*workflow.StartWorkflowExecutionResponse, error)

+ TerminateWorkflowExecution func(request *h.TerminateWorkflowExecutionRequest) error

+ func NewEngineWithShardContext(shard ShardContext, metadataMgr persistence.MetadataManager, ...) Engine

+ type EngineFactory interface

+ CreateEngine func(context ShardContext) Engine

+ type Handler struct

+ func NewHandler(sVice service.Service, shardManager persistence.ShardManager, ...) (*Handler, []thrift.TChanServer)

+ func (h *Handler) CreateEngine(context ShardContext) Engine

+ func (h *Handler) GetWorkflowExecutionNextEventID(ctx thrift.Context, getRequest *hist.GetWorkflowExecutionNextEventIDRequest) (*hist.GetWorkflowExecutionNextEventIDResponse, error)

+ func (h *Handler) IsHealthy(ctx thrift.Context) (bool, error)

+ func (h *Handler) RecordActivityTaskHeartbeat(ctx thrift.Context, wrappedRequest *hist.RecordActivityTaskHeartbeatRequest) (*gen.RecordActivityTaskHeartbeatResponse, error)

+ func (h *Handler) RecordActivityTaskStarted(ctx thrift.Context, recordRequest *hist.RecordActivityTaskStartedRequest) (*hist.RecordActivityTaskStartedResponse, error)

+ func (h *Handler) RecordChildExecutionCompleted(ctx thrift.Context, request *hist.RecordChildExecutionCompletedRequest) error

+ func (h *Handler) RecordDecisionTaskStarted(ctx thrift.Context, recordRequest *hist.RecordDecisionTaskStartedRequest) (*hist.RecordDecisionTaskStartedResponse, error)

+ func (h *Handler) RequestCancelWorkflowExecution(ctx thrift.Context, request *hist.RequestCancelWorkflowExecutionRequest) error

+ func (h *Handler) RespondActivityTaskCanceled(ctx thrift.Context, wrappedRequest *hist.RespondActivityTaskCanceledRequest) error

+ func (h *Handler) RespondActivityTaskCompleted(ctx thrift.Context, wrappedRequest *hist.RespondActivityTaskCompletedRequest) error

+ func (h *Handler) RespondActivityTaskFailed(ctx thrift.Context, wrappedRequest *hist.RespondActivityTaskFailedRequest) error

+ func (h *Handler) RespondDecisionTaskCompleted(ctx thrift.Context, wrappedRequest *hist.RespondDecisionTaskCompletedRequest) error

+ func (h *Handler) ScheduleDecisionTask(ctx thrift.Context, request *hist.ScheduleDecisionTaskRequest) error

+ func (h *Handler) SignalWorkflowExecution(ctx thrift.Context, wrappedRequest *hist.SignalWorkflowExecutionRequest) error

+ func (h *Handler) Start(thriftService []thrift.TChanServer) error

+ func (h *Handler) StartWorkflowExecution(ctx thrift.Context, wrappedRequest *hist.StartWorkflowExecutionRequest) (*gen.StartWorkflowExecutionResponse, error)

+ func (h *Handler) Stop()

+ func (h *Handler) TerminateWorkflowExecution(ctx thrift.Context, wrappedRequest *hist.TerminateWorkflowExecutionRequest) error

+ type MockHistoryEngine struct

+ func (_m *MockHistoryEngine) GetWorkflowExecutionNextEventID(request *gohistory.GetWorkflowExecutionNextEventIDRequest) (*gohistory.GetWorkflowExecutionNextEventIDResponse, error)

+ func (_m *MockHistoryEngine) RecordActivityTaskHeartbeat(request *gohistory.RecordActivityTaskHeartbeatRequest) (*shared.RecordActivityTaskHeartbeatResponse, error)

+ func (_m *MockHistoryEngine) RecordActivityTaskStarted(request *gohistory.RecordActivityTaskStartedRequest) (*gohistory.RecordActivityTaskStartedResponse, error)

+ func (_m *MockHistoryEngine) RecordChildExecutionCompleted(request *gohistory.RecordChildExecutionCompletedRequest) error

+ func (_m *MockHistoryEngine) RecordDecisionTaskStarted(request *gohistory.RecordDecisionTaskStartedRequest) (*gohistory.RecordDecisionTaskStartedResponse, error)

+ func (_m *MockHistoryEngine) RequestCancelWorkflowExecution(request *gohistory.RequestCancelWorkflowExecutionRequest) error

+ func (_m *MockHistoryEngine) RespondActivityTaskCanceled(request *gohistory.RespondActivityTaskCanceledRequest) error

+ func (_m *MockHistoryEngine) RespondActivityTaskCompleted(request *gohistory.RespondActivityTaskCompletedRequest) error

+ func (_m *MockHistoryEngine) RespondActivityTaskFailed(request *gohistory.RespondActivityTaskFailedRequest) error

+ func (_m *MockHistoryEngine) RespondDecisionTaskCompleted(request *gohistory.RespondDecisionTaskCompletedRequest) error

+ func (_m *MockHistoryEngine) ScheduleDecisionTask(request *gohistory.ScheduleDecisionTaskRequest) error

+ func (_m *MockHistoryEngine) SignalWorkflowExecution(request *gohistory.SignalWorkflowExecutionRequest) error

+ func (_m *MockHistoryEngine) Start()

+ func (_m *MockHistoryEngine) StartWorkflowExecution(request *gohistory.StartWorkflowExecutionRequest) (*shared.StartWorkflowExecutionResponse, error)

+ func (_m *MockHistoryEngine) Stop()

+ func (_m *MockHistoryEngine) TerminateWorkflowExecution(request *gohistory.TerminateWorkflowExecutionRequest) error

+ type MockHistoryEngineFactory struct

+ func (_m *MockHistoryEngineFactory) CreateEngine(context ShardContext) Engine

+ type SequenceID struct

+ TaskID int64

+ VisibilityTimestamp time.Time

+ func (s SequenceID) String() string

+ type SequenceNumberGenerator interface

+ NextSeq func() int64

+ type Service struct

+ func (s *Service) Start()

+ func (s *Service) Stop()

+ type ShardContext interface

+ AppendHistoryEvents func(request *persistence.AppendHistoryEventsRequest) error

+ CreateWorkflowExecution func(request *persistence.CreateWorkflowExecutionRequest) (*persistence.CreateWorkflowExecutionResponse, error)

+ GetExecutionManager func() persistence.ExecutionManager

+ GetHistoryManager func() persistence.HistoryManager

+ GetLogger func() bark.Logger

+ GetMetricsClient func() metrics.Client

+ GetNextTransferTaskID func() (int64, error)

+ GetTimeSource func() common.TimeSource

+ GetTimerAckLevel func() time.Time

+ GetTransferAckLevel func() int64

+ GetTransferMaxReadLevel func() int64

+ GetTransferSequenceNumber func() int64

+ UpdateTimerAckLevel func(ackLevel time.Time) error

+ UpdateTransferAckLevel func(ackLevel int64) error

+ UpdateWorkflowExecution func(request *persistence.UpdateWorkflowExecutionRequest) error