persistence

package

Go to main page

Versions in this module

v0

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