Documentation ¶
Overview ¶
Package serialization is a generated GoMock package.
Index ¶
- func ToInternalWorkflowExecutionInfo(info *WorkflowExecutionInfo) *persistence.InternalWorkflowExecutionInfo
- type ActivityInfo
- func (a *ActivityInfo) GetActivityID() (o string)
- func (a *ActivityInfo) GetAttempt() (o int32)
- func (a *ActivityInfo) GetCancelRequestID() (o int64)
- func (a *ActivityInfo) GetCancelRequested() (o bool)
- func (a *ActivityInfo) GetHasRetryPolicy() (o bool)
- func (a *ActivityInfo) GetHeartbeatTimeout() time.Duration
- func (a *ActivityInfo) GetRequestID() (o string)
- func (a *ActivityInfo) GetRetryBackoffCoefficient() (o float64)
- func (a *ActivityInfo) GetRetryExpirationTimestamp() time.Time
- func (a *ActivityInfo) GetRetryInitialInterval() time.Duration
- func (a *ActivityInfo) GetRetryLastFailureDetails() (o []byte)
- func (a *ActivityInfo) GetRetryLastFailureReason() (o string)
- func (a *ActivityInfo) GetRetryLastWorkerIdentity() (o string)
- func (a *ActivityInfo) GetRetryMaximumAttempts() (o int32)
- func (a *ActivityInfo) GetRetryMaximumInterval() time.Duration
- func (a *ActivityInfo) GetRetryNonRetryableErrors() (o []string)
- func (a *ActivityInfo) GetScheduleToCloseTimeout() time.Duration
- func (a *ActivityInfo) GetScheduleToStartTimeout() time.Duration
- func (a *ActivityInfo) GetScheduledEvent() (o []byte)
- func (a *ActivityInfo) GetScheduledEventBatchID() (o int64)
- func (a *ActivityInfo) GetScheduledEventEncoding() (o string)
- func (a *ActivityInfo) GetScheduledTimestamp() time.Time
- func (a *ActivityInfo) GetStartToCloseTimeout() time.Duration
- func (a *ActivityInfo) GetStartedEvent() (o []byte)
- func (a *ActivityInfo) GetStartedEventEncoding() (o string)
- func (a *ActivityInfo) GetStartedID() (o int64)
- func (a *ActivityInfo) GetStartedIdentity() (o string)
- func (a *ActivityInfo) GetStartedTimestamp() time.Time
- func (a *ActivityInfo) GetTaskList() (o string)
- func (a *ActivityInfo) GetTimerTaskStatus() (o int32)
- func (a *ActivityInfo) GetVersion() (o int64)
- type ChildExecutionInfo
- func (c *ChildExecutionInfo) GetCreateRequestID() (o string)
- func (c *ChildExecutionInfo) GetDomainID() (o string)
- func (c *ChildExecutionInfo) GetDomainNameDEPRECATED() (o string)
- func (c *ChildExecutionInfo) GetInitiatedEvent() (o []byte)
- func (c *ChildExecutionInfo) GetInitiatedEventBatchID() (o int64)
- func (c *ChildExecutionInfo) GetInitiatedEventEncoding() (o string)
- func (c *ChildExecutionInfo) GetParentClosePolicy() (o int32)
- func (c *ChildExecutionInfo) GetStartedEvent() (o []byte)
- func (c *ChildExecutionInfo) GetStartedEventEncoding() (o string)
- func (c *ChildExecutionInfo) GetStartedID() (o int64)
- func (c *ChildExecutionInfo) GetStartedRunID() (o []byte)
- func (c *ChildExecutionInfo) GetStartedWorkflowID() (o string)
- func (c *ChildExecutionInfo) GetVersion() (o int64)
- func (c *ChildExecutionInfo) GetWorkflowTypeName() (o string)
- type CrossClusterTaskInfo
- type DomainInfo
- func (d *DomainInfo) GetActiveClusterName() (o string)
- func (d *DomainInfo) GetArchivalBucket() (o string)
- func (d *DomainInfo) GetArchivalStatus() (o int16)
- func (d *DomainInfo) GetBadBinaries() (o []byte)
- func (d *DomainInfo) GetBadBinariesEncoding() (o string)
- func (d *DomainInfo) GetClusters() (o []string)
- func (d *DomainInfo) GetConfigVersion() (o int64)
- func (d *DomainInfo) GetData() (o map[string]string)
- func (d *DomainInfo) GetDescription() (o string)
- func (d *DomainInfo) GetEmitMetric() (o bool)
- func (d *DomainInfo) GetFailoverEndTimestamp() time.Time
- func (d *DomainInfo) GetFailoverNotificationVersion() (o int64)
- func (d *DomainInfo) GetFailoverVersion() (o int64)
- func (d *DomainInfo) GetHistoryArchivalStatus() (o int16)
- func (d *DomainInfo) GetHistoryArchivalURI() (o string)
- func (d *DomainInfo) GetLastUpdatedTimestamp() time.Time
- func (d *DomainInfo) GetName() (o string)
- func (d *DomainInfo) GetNotificationVersion() (o int64)
- func (d *DomainInfo) GetOwner() (o string)
- func (d *DomainInfo) GetPreviousFailoverVersion() (o int64)
- func (d *DomainInfo) GetRetention() time.Duration
- func (d *DomainInfo) GetStatus() (o int32)
- func (d *DomainInfo) GetVisibilityArchivalStatus() (o int16)
- func (d *DomainInfo) GetVisibilityArchivalURI() (o string)
- type HistoryBranchRange
- type HistoryTreeInfo
- type MockParser
- func (m *MockParser) ActivityInfoFromBlob(arg0 []byte, arg1 string) (*ActivityInfo, error)
- func (m *MockParser) ActivityInfoToBlob(arg0 *ActivityInfo) (persistence.DataBlob, error)
- func (m *MockParser) ChildExecutionInfoFromBlob(arg0 []byte, arg1 string) (*ChildExecutionInfo, error)
- func (m *MockParser) ChildExecutionInfoToBlob(arg0 *ChildExecutionInfo) (persistence.DataBlob, error)
- func (m *MockParser) CrossClusterTaskInfoFromBlob(arg0 []byte, arg1 string) (*CrossClusterTaskInfo, error)
- func (m *MockParser) CrossClusterTaskInfoToBlob(arg0 *CrossClusterTaskInfo) (persistence.DataBlob, error)
- func (m *MockParser) DomainInfoFromBlob(arg0 []byte, arg1 string) (*DomainInfo, error)
- func (m *MockParser) DomainInfoToBlob(arg0 *DomainInfo) (persistence.DataBlob, error)
- func (m *MockParser) EXPECT() *MockParserMockRecorder
- func (m *MockParser) HistoryTreeInfoFromBlob(arg0 []byte, arg1 string) (*HistoryTreeInfo, error)
- func (m *MockParser) HistoryTreeInfoToBlob(arg0 *HistoryTreeInfo) (persistence.DataBlob, error)
- func (m *MockParser) ReplicationTaskInfoFromBlob(arg0 []byte, arg1 string) (*ReplicationTaskInfo, error)
- func (m *MockParser) ReplicationTaskInfoToBlob(arg0 *ReplicationTaskInfo) (persistence.DataBlob, error)
- func (m *MockParser) RequestCancelInfoFromBlob(arg0 []byte, arg1 string) (*RequestCancelInfo, error)
- func (m *MockParser) RequestCancelInfoToBlob(arg0 *RequestCancelInfo) (persistence.DataBlob, error)
- func (m *MockParser) ShardInfoFromBlob(arg0 []byte, arg1 string) (*ShardInfo, error)
- func (m *MockParser) ShardInfoToBlob(arg0 *ShardInfo) (persistence.DataBlob, error)
- func (m *MockParser) SignalInfoFromBlob(arg0 []byte, arg1 string) (*SignalInfo, error)
- func (m *MockParser) SignalInfoToBlob(arg0 *SignalInfo) (persistence.DataBlob, error)
- func (m *MockParser) TaskInfoFromBlob(arg0 []byte, arg1 string) (*TaskInfo, error)
- func (m *MockParser) TaskInfoToBlob(arg0 *TaskInfo) (persistence.DataBlob, error)
- func (m *MockParser) TaskListInfoFromBlob(arg0 []byte, arg1 string) (*TaskListInfo, error)
- func (m *MockParser) TaskListInfoToBlob(arg0 *TaskListInfo) (persistence.DataBlob, error)
- func (m *MockParser) TimerInfoFromBlob(arg0 []byte, arg1 string) (*TimerInfo, error)
- func (m *MockParser) TimerInfoToBlob(arg0 *TimerInfo) (persistence.DataBlob, error)
- func (m *MockParser) TimerTaskInfoFromBlob(arg0 []byte, arg1 string) (*TimerTaskInfo, error)
- func (m *MockParser) TimerTaskInfoToBlob(arg0 *TimerTaskInfo) (persistence.DataBlob, error)
- func (m *MockParser) TransferTaskInfoFromBlob(arg0 []byte, arg1 string) (*TransferTaskInfo, error)
- func (m *MockParser) TransferTaskInfoToBlob(arg0 *TransferTaskInfo) (persistence.DataBlob, error)
- func (m *MockParser) WorkflowExecutionInfoFromBlob(arg0 []byte, arg1 string) (*WorkflowExecutionInfo, error)
- func (m *MockParser) WorkflowExecutionInfoToBlob(arg0 *WorkflowExecutionInfo) (persistence.DataBlob, error)
- type MockParserMockRecorder
- func (mr *MockParserMockRecorder) ActivityInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) ActivityInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) ChildExecutionInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) ChildExecutionInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) CrossClusterTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) CrossClusterTaskInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) DomainInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) DomainInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) HistoryTreeInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) HistoryTreeInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) ReplicationTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) ReplicationTaskInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) RequestCancelInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) RequestCancelInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) ShardInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) ShardInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) SignalInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) SignalInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TaskInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TaskListInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TaskListInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TimerInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TimerInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TimerTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TimerTaskInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TransferTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) TransferTaskInfoToBlob(arg0 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) WorkflowExecutionInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockParserMockRecorder) WorkflowExecutionInfoToBlob(arg0 interface{}) *gomock.Call
- type Mockdecoder
- type MockdecoderMockRecorder
- type Mockencoder
- type MockencoderMockRecorder
- type MockthriftRWType
- type MockthriftRWTypeMockRecorder
- type Parser
- type ReplicationTaskInfo
- func (t *ReplicationTaskInfo) GetBranchToken() (o []byte)
- func (t *ReplicationTaskInfo) GetCreationTimestamp() time.Time
- func (t *ReplicationTaskInfo) GetDomainID() (o []byte)
- func (t *ReplicationTaskInfo) GetEventStoreVersion() (o int32)
- func (t *ReplicationTaskInfo) GetFirstEventID() (o int64)
- func (t *ReplicationTaskInfo) GetNewRunBranchToken() (o []byte)
- func (t *ReplicationTaskInfo) GetNewRunEventStoreVersion() (o int32)
- func (t *ReplicationTaskInfo) GetNextEventID() (o int64)
- func (t *ReplicationTaskInfo) GetRunID() (o []byte)
- func (t *ReplicationTaskInfo) GetScheduledID() (o int64)
- func (t *ReplicationTaskInfo) GetTaskType() (o int16)
- func (t *ReplicationTaskInfo) GetVersion() (o int64)
- func (t *ReplicationTaskInfo) GetWorkflowID() (o string)
- type RequestCancelInfo
- type ShardInfo
- func (s *ShardInfo) GetClusterReplicationLevel() (o map[string]int64)
- func (s *ShardInfo) GetClusterTimerAckLevel() (o map[string]time.Time)
- func (s *ShardInfo) GetClusterTransferAckLevel() (o map[string]int64)
- func (s *ShardInfo) GetDomainNotificationVersion() (o int64)
- func (s *ShardInfo) GetOwner() (o string)
- func (s *ShardInfo) GetPendingFailoverMarkers() (o []byte)
- func (s *ShardInfo) GetPendingFailoverMarkersEncoding() (o string)
- func (s *ShardInfo) GetReplicationAckLevel() (o int64)
- func (s *ShardInfo) GetReplicationDlqAckLevel() (o map[string]int64)
- func (s *ShardInfo) GetStolenSinceRenew() (o int32)
- func (s *ShardInfo) GetTimerAckLevel() time.Time
- func (s *ShardInfo) GetTimerProcessingQueueStates() (o []byte)
- func (s *ShardInfo) GetTimerProcessingQueueStatesEncoding() (o string)
- func (s *ShardInfo) GetTransferAckLevel() (o int64)
- func (s *ShardInfo) GetTransferProcessingQueueStates() (o []byte)
- func (s *ShardInfo) GetTransferProcessingQueueStatesEncoding() (o string)
- func (s *ShardInfo) GetUpdatedAt() time.Time
- type SignalInfo
- type TaskInfo
- type TaskListInfo
- type TimerInfo
- type TimerTaskInfo
- func (t *TimerTaskInfo) GetDomainID() (o []byte)
- func (t *TimerTaskInfo) GetEventID() (o int64)
- func (t *TimerTaskInfo) GetRunID() (o []byte)
- func (t *TimerTaskInfo) GetScheduleAttempt() (o int64)
- func (t *TimerTaskInfo) GetTaskType() (o int16)
- func (t *TimerTaskInfo) GetTimeoutType() (o int16)
- func (t *TimerTaskInfo) GetVersion() (o int64)
- func (t *TimerTaskInfo) GetWorkflowID() (o string)
- type TransferTaskInfo
- func (t *TransferTaskInfo) GetDomainID() (o []byte)
- func (t *TransferTaskInfo) GetRunID() (o []byte)
- func (t *TransferTaskInfo) GetScheduleID() (o int64)
- func (t *TransferTaskInfo) GetTargetChildWorkflowOnly() (o bool)
- func (t *TransferTaskInfo) GetTargetDomainID() (o []byte)
- func (t *TransferTaskInfo) GetTargetDomainIDs() (o map[string]struct{})
- func (t *TransferTaskInfo) GetTargetRunID() (o []byte)
- func (t *TransferTaskInfo) GetTargetWorkflowID() (o string)
- func (t *TransferTaskInfo) GetTaskList() (o string)
- func (t *TransferTaskInfo) GetTaskType() (o int16)
- func (t *TransferTaskInfo) GetVersion() (o int64)
- func (t *TransferTaskInfo) GetVisibilityTimestamp() time.Time
- func (t *TransferTaskInfo) GetWorkflowID() (o string)
- type UUID
- type WorkflowExecutionInfo
- func (w *WorkflowExecutionInfo) GetAutoResetPoints() (o []byte)
- func (w *WorkflowExecutionInfo) GetAutoResetPointsEncoding() (o string)
- func (w *WorkflowExecutionInfo) GetCancelRequestID() (o string)
- func (w *WorkflowExecutionInfo) GetCancelRequested() (o bool)
- func (w *WorkflowExecutionInfo) GetChecksum() (o []byte)
- func (w *WorkflowExecutionInfo) GetChecksumEncoding() (o string)
- func (w *WorkflowExecutionInfo) GetClientFeatureVersion() (o string)
- func (w *WorkflowExecutionInfo) GetClientImpl() (o string)
- func (w *WorkflowExecutionInfo) GetClientLibraryVersion() (o string)
- func (w *WorkflowExecutionInfo) GetCloseStatus() (o int32)
- func (w *WorkflowExecutionInfo) GetCompletionEvent() (o []byte)
- func (w *WorkflowExecutionInfo) GetCompletionEventBatchID() (o int64)
- func (w *WorkflowExecutionInfo) GetCompletionEventEncoding() (o string)
- func (w *WorkflowExecutionInfo) GetCreateRequestID() (o string)
- func (w *WorkflowExecutionInfo) GetCronSchedule() (o string)
- func (w *WorkflowExecutionInfo) GetDecisionAttempt() (o int64)
- func (w *WorkflowExecutionInfo) GetDecisionOriginalScheduledTimestamp() time.Time
- func (w *WorkflowExecutionInfo) GetDecisionRequestID() (o string)
- func (w *WorkflowExecutionInfo) GetDecisionScheduleID() (o int64)
- func (w *WorkflowExecutionInfo) GetDecisionScheduledTimestamp() time.Time
- func (w *WorkflowExecutionInfo) GetDecisionStartedID() (o int64)
- func (w *WorkflowExecutionInfo) GetDecisionStartedTimestamp() time.Time
- func (w *WorkflowExecutionInfo) GetDecisionTaskTimeout() time.Duration
- func (w *WorkflowExecutionInfo) GetDecisionTimeout() time.Duration
- func (w *WorkflowExecutionInfo) GetDecisionVersion() (o int64)
- func (w *WorkflowExecutionInfo) GetEventBranchToken() (o []byte)
- func (w *WorkflowExecutionInfo) GetEventStoreVersion() (o int32)
- func (w *WorkflowExecutionInfo) GetExecutionContext() (o []byte)
- func (w *WorkflowExecutionInfo) GetFirstExecutionRunID() (o []byte)
- func (w *WorkflowExecutionInfo) GetHasRetryPolicy() (o bool)
- func (w *WorkflowExecutionInfo) GetHistorySize() (o int64)
- func (w *WorkflowExecutionInfo) GetInitiatedID() (o int64)
- func (w *WorkflowExecutionInfo) GetIsCron() (o bool)
- func (w *WorkflowExecutionInfo) GetLastEventTaskID() (o int64)
- func (w *WorkflowExecutionInfo) GetLastFirstEventID() (o int64)
- func (w *WorkflowExecutionInfo) GetLastProcessedEvent() (o int64)
- func (w *WorkflowExecutionInfo) GetLastUpdatedTimestamp() time.Time
- func (w *WorkflowExecutionInfo) GetLastWriteEventID() (o int64)
- func (w *WorkflowExecutionInfo) GetMemo() (o map[string][]byte)
- func (w *WorkflowExecutionInfo) GetParentDomainID() (o []byte)
- func (w *WorkflowExecutionInfo) GetParentRunID() (o []byte)
- func (w *WorkflowExecutionInfo) GetParentWorkflowID() (o string)
- func (w *WorkflowExecutionInfo) GetPartitionConfig() (o map[string]string)
- func (w *WorkflowExecutionInfo) GetRetryAttempt() (o int64)
- func (w *WorkflowExecutionInfo) GetRetryBackoffCoefficient() (o float64)
- func (w *WorkflowExecutionInfo) GetRetryExpiration() time.Duration
- func (w *WorkflowExecutionInfo) GetRetryExpirationTimestamp() time.Time
- func (w *WorkflowExecutionInfo) GetRetryInitialInterval() time.Duration
- func (w *WorkflowExecutionInfo) GetRetryMaximumAttempts() (o int32)
- func (w *WorkflowExecutionInfo) GetRetryMaximumInterval() time.Duration
- func (w *WorkflowExecutionInfo) GetRetryNonRetryableErrors() (o []string)
- func (w *WorkflowExecutionInfo) GetSearchAttributes() (o map[string][]byte)
- func (w *WorkflowExecutionInfo) GetSignalCount() (o int64)
- func (w *WorkflowExecutionInfo) GetStartTimestamp() time.Time
- func (w *WorkflowExecutionInfo) GetStartVersion() (o int64)
- func (w *WorkflowExecutionInfo) GetState() (o int32)
- func (w *WorkflowExecutionInfo) GetStickyScheduleToStartTimeout() time.Duration
- func (w *WorkflowExecutionInfo) GetStickyTaskList() (o string)
- func (w *WorkflowExecutionInfo) GetTaskList() (o string)
- func (w *WorkflowExecutionInfo) GetVersionHistories() (o []byte)
- func (w *WorkflowExecutionInfo) GetVersionHistoriesEncoding() (o string)
- func (w *WorkflowExecutionInfo) GetWorkflowTimeout() time.Duration
- func (w *WorkflowExecutionInfo) GetWorkflowTypeName() (o string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToInternalWorkflowExecutionInfo ¶ added in v0.24.0
func ToInternalWorkflowExecutionInfo(info *WorkflowExecutionInfo) *persistence.InternalWorkflowExecutionInfo
Types ¶
type ActivityInfo ¶ added in v0.18.0
type ActivityInfo struct { Version int64 ScheduledEventBatchID int64 ScheduledEvent []byte ScheduledEventEncoding string ScheduledTimestamp time.Time StartedID int64 StartedEvent []byte StartedEventEncoding string StartedTimestamp time.Time ActivityID string RequestID string ScheduleToStartTimeout time.Duration ScheduleToCloseTimeout time.Duration StartToCloseTimeout time.Duration HeartbeatTimeout time.Duration CancelRequested bool CancelRequestID int64 TimerTaskStatus int32 Attempt int32 TaskList string StartedIdentity string HasRetryPolicy bool RetryInitialInterval time.Duration RetryMaximumInterval time.Duration RetryMaximumAttempts int32 RetryExpirationTimestamp time.Time RetryBackoffCoefficient float64 RetryNonRetryableErrors []string RetryLastFailureReason string RetryLastWorkerIdentity string RetryLastFailureDetails []byte }
ActivityInfo blob in a serialization agnostic format
func (*ActivityInfo) GetActivityID ¶ added in v0.18.0
func (a *ActivityInfo) GetActivityID() (o string)
GetActivityID internal sql blob getter
func (*ActivityInfo) GetAttempt ¶ added in v0.18.0
func (a *ActivityInfo) GetAttempt() (o int32)
GetAttempt internal sql blob getter
func (*ActivityInfo) GetCancelRequestID ¶ added in v0.18.0
func (a *ActivityInfo) GetCancelRequestID() (o int64)
GetCancelRequestID internal sql blob getter
func (*ActivityInfo) GetCancelRequested ¶ added in v0.18.0
func (a *ActivityInfo) GetCancelRequested() (o bool)
GetCancelRequested internal sql blob getter
func (*ActivityInfo) GetHasRetryPolicy ¶ added in v0.18.0
func (a *ActivityInfo) GetHasRetryPolicy() (o bool)
GetHasRetryPolicy internal sql blob getter
func (*ActivityInfo) GetHeartbeatTimeout ¶ added in v0.18.0
func (a *ActivityInfo) GetHeartbeatTimeout() time.Duration
GetHeartbeatTimeout internal sql blob getter
func (*ActivityInfo) GetRequestID ¶ added in v0.18.0
func (a *ActivityInfo) GetRequestID() (o string)
GetRequestID internal sql blob getter
func (*ActivityInfo) GetRetryBackoffCoefficient ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryBackoffCoefficient() (o float64)
GetRetryBackoffCoefficient internal sql blob getter
func (*ActivityInfo) GetRetryExpirationTimestamp ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryExpirationTimestamp() time.Time
GetRetryExpirationTimestamp internal sql blob getter
func (*ActivityInfo) GetRetryInitialInterval ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryInitialInterval() time.Duration
GetRetryInitialInterval internal sql blob getter
func (*ActivityInfo) GetRetryLastFailureDetails ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryLastFailureDetails() (o []byte)
GetRetryLastFailureDetails internal sql blob getter
func (*ActivityInfo) GetRetryLastFailureReason ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryLastFailureReason() (o string)
GetRetryLastFailureReason internal sql blob getter
func (*ActivityInfo) GetRetryLastWorkerIdentity ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryLastWorkerIdentity() (o string)
GetRetryLastWorkerIdentity internal sql blob getter
func (*ActivityInfo) GetRetryMaximumAttempts ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryMaximumAttempts() (o int32)
GetRetryMaximumAttempts internal sql blob getter
func (*ActivityInfo) GetRetryMaximumInterval ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryMaximumInterval() time.Duration
GetRetryMaximumInterval internal sql blob getter
func (*ActivityInfo) GetRetryNonRetryableErrors ¶ added in v0.18.0
func (a *ActivityInfo) GetRetryNonRetryableErrors() (o []string)
GetRetryNonRetryableErrors internal sql blob getter
func (*ActivityInfo) GetScheduleToCloseTimeout ¶ added in v0.18.0
func (a *ActivityInfo) GetScheduleToCloseTimeout() time.Duration
GetScheduleToCloseTimeout internal sql blob getter
func (*ActivityInfo) GetScheduleToStartTimeout ¶ added in v0.18.0
func (a *ActivityInfo) GetScheduleToStartTimeout() time.Duration
GetScheduleToStartTimeout internal sql blob getter
func (*ActivityInfo) GetScheduledEvent ¶ added in v0.18.0
func (a *ActivityInfo) GetScheduledEvent() (o []byte)
GetScheduledEvent internal sql blob getter
func (*ActivityInfo) GetScheduledEventBatchID ¶ added in v0.18.0
func (a *ActivityInfo) GetScheduledEventBatchID() (o int64)
GetScheduledEventBatchID internal sql blob getter
func (*ActivityInfo) GetScheduledEventEncoding ¶ added in v0.18.0
func (a *ActivityInfo) GetScheduledEventEncoding() (o string)
GetScheduledEventEncoding internal sql blob getter
func (*ActivityInfo) GetScheduledTimestamp ¶ added in v0.18.0
func (a *ActivityInfo) GetScheduledTimestamp() time.Time
GetScheduledTimestamp internal sql blob getter
func (*ActivityInfo) GetStartToCloseTimeout ¶ added in v0.18.0
func (a *ActivityInfo) GetStartToCloseTimeout() time.Duration
GetStartToCloseTimeout internal sql blob getter
func (*ActivityInfo) GetStartedEvent ¶ added in v0.18.0
func (a *ActivityInfo) GetStartedEvent() (o []byte)
GetStartedEvent internal sql blob getter
func (*ActivityInfo) GetStartedEventEncoding ¶ added in v0.18.0
func (a *ActivityInfo) GetStartedEventEncoding() (o string)
GetStartedEventEncoding internal sql blob getter
func (*ActivityInfo) GetStartedID ¶ added in v0.18.0
func (a *ActivityInfo) GetStartedID() (o int64)
GetStartedID internal sql blob getter
func (*ActivityInfo) GetStartedIdentity ¶ added in v0.18.0
func (a *ActivityInfo) GetStartedIdentity() (o string)
GetStartedIdentity internal sql blob getter
func (*ActivityInfo) GetStartedTimestamp ¶ added in v0.18.0
func (a *ActivityInfo) GetStartedTimestamp() time.Time
GetStartedTimestamp internal sql blob getter
func (*ActivityInfo) GetTaskList ¶ added in v0.18.0
func (a *ActivityInfo) GetTaskList() (o string)
GetTaskList internal sql blob getter
func (*ActivityInfo) GetTimerTaskStatus ¶ added in v0.18.0
func (a *ActivityInfo) GetTimerTaskStatus() (o int32)
GetTimerTaskStatus internal sql blob getter
func (*ActivityInfo) GetVersion ¶ added in v0.18.0
func (a *ActivityInfo) GetVersion() (o int64)
GetVersion internal sql blob getter
type ChildExecutionInfo ¶ added in v0.18.0
type ChildExecutionInfo struct { Version int64 InitiatedEventBatchID int64 StartedID int64 InitiatedEvent []byte InitiatedEventEncoding string StartedWorkflowID string StartedRunID UUID StartedEvent []byte StartedEventEncoding string CreateRequestID string DomainID string DomainNameDEPRECATED string WorkflowTypeName string ParentClosePolicy int32 }
ChildExecutionInfo blob in a serialization agnostic format
func (*ChildExecutionInfo) GetCreateRequestID ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetCreateRequestID() (o string)
GetCreateRequestID internal sql blob getter
func (*ChildExecutionInfo) GetDomainID ¶ added in v0.24.0
func (c *ChildExecutionInfo) GetDomainID() (o string)
GetDomainID internal sql blob getter
func (*ChildExecutionInfo) GetDomainNameDEPRECATED ¶ added in v0.24.0
func (c *ChildExecutionInfo) GetDomainNameDEPRECATED() (o string)
GetDomainNameDEPRECATED internal sql blob getter
func (*ChildExecutionInfo) GetInitiatedEvent ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetInitiatedEvent() (o []byte)
GetInitiatedEvent internal sql blob getter
func (*ChildExecutionInfo) GetInitiatedEventBatchID ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetInitiatedEventBatchID() (o int64)
GetInitiatedEventBatchID internal sql blob getter
func (*ChildExecutionInfo) GetInitiatedEventEncoding ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetInitiatedEventEncoding() (o string)
GetInitiatedEventEncoding internal sql blob getter
func (*ChildExecutionInfo) GetParentClosePolicy ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetParentClosePolicy() (o int32)
GetParentClosePolicy internal sql blob getter
func (*ChildExecutionInfo) GetStartedEvent ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetStartedEvent() (o []byte)
GetStartedEvent internal sql blob getter
func (*ChildExecutionInfo) GetStartedEventEncoding ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetStartedEventEncoding() (o string)
GetStartedEventEncoding internal sql blob getter
func (*ChildExecutionInfo) GetStartedID ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetStartedID() (o int64)
GetStartedID internal sql blob getter
func (*ChildExecutionInfo) GetStartedRunID ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetStartedRunID() (o []byte)
GetStartedRunID internal sql blob getter
func (*ChildExecutionInfo) GetStartedWorkflowID ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetStartedWorkflowID() (o string)
GetStartedWorkflowID internal sql blob getter
func (*ChildExecutionInfo) GetVersion ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetVersion() (o int64)
GetVersion internal sql blob getter
func (*ChildExecutionInfo) GetWorkflowTypeName ¶ added in v0.18.0
func (c *ChildExecutionInfo) GetWorkflowTypeName() (o string)
GetWorkflowTypeName internal sql blob getter
type CrossClusterTaskInfo ¶ added in v0.22.0
type CrossClusterTaskInfo = TransferTaskInfo
CrossClusterTaskInfo blob in a serialization agnostic format Cross cluster tasks are exactly like transfer tasks so instead of creating another struct and duplicating the same logic everywhere. We reuse TransferTaskInfo
type DomainInfo ¶ added in v0.18.0
type DomainInfo struct { Name string // TODO: This field seems not to be required. We already store domain name in another column. Description string Owner string Status int32 Retention time.Duration EmitMetric bool ArchivalBucket string ArchivalStatus int16 ConfigVersion int64 NotificationVersion int64 FailoverNotificationVersion int64 FailoverVersion int64 ActiveClusterName string Clusters []string Data map[string]string BadBinaries []byte BadBinariesEncoding string HistoryArchivalStatus int16 HistoryArchivalURI string VisibilityArchivalStatus int16 VisibilityArchivalURI string FailoverEndTimestamp *time.Time // TODO: There is logic checking if it's nil, should revisit this PreviousFailoverVersion int64 LastUpdatedTimestamp time.Time IsolationGroups []byte IsolationGroupsEncoding string AsyncWorkflowConfig []byte AsyncWorkflowConfigEncoding string }
DomainInfo blob in a serialization agnostic format
func (*DomainInfo) GetActiveClusterName ¶ added in v0.18.0
func (d *DomainInfo) GetActiveClusterName() (o string)
GetActiveClusterName internal sql blob getter
func (*DomainInfo) GetArchivalBucket ¶ added in v0.18.0
func (d *DomainInfo) GetArchivalBucket() (o string)
GetArchivalBucket internal sql blob getter
func (*DomainInfo) GetArchivalStatus ¶ added in v0.18.0
func (d *DomainInfo) GetArchivalStatus() (o int16)
GetArchivalStatus internal sql blob getter
func (*DomainInfo) GetBadBinaries ¶ added in v0.18.0
func (d *DomainInfo) GetBadBinaries() (o []byte)
GetBadBinaries internal sql blob getter
func (*DomainInfo) GetBadBinariesEncoding ¶ added in v0.18.0
func (d *DomainInfo) GetBadBinariesEncoding() (o string)
GetBadBinariesEncoding internal sql blob getter
func (*DomainInfo) GetClusters ¶ added in v0.18.0
func (d *DomainInfo) GetClusters() (o []string)
GetClusters internal sql blob getter
func (*DomainInfo) GetConfigVersion ¶ added in v0.18.0
func (d *DomainInfo) GetConfigVersion() (o int64)
GetConfigVersion internal sql blob getter
func (*DomainInfo) GetData ¶ added in v0.18.0
func (d *DomainInfo) GetData() (o map[string]string)
GetData internal sql blob getter
func (*DomainInfo) GetDescription ¶ added in v0.18.0
func (d *DomainInfo) GetDescription() (o string)
GetDescription internal sql blob getter
func (*DomainInfo) GetEmitMetric ¶ added in v0.18.0
func (d *DomainInfo) GetEmitMetric() (o bool)
GetEmitMetric internal sql blob getter
func (*DomainInfo) GetFailoverEndTimestamp ¶ added in v0.18.0
func (d *DomainInfo) GetFailoverEndTimestamp() time.Time
GetFailoverEndTimestamp internal sql blob getter
func (*DomainInfo) GetFailoverNotificationVersion ¶ added in v0.18.0
func (d *DomainInfo) GetFailoverNotificationVersion() (o int64)
GetFailoverNotificationVersion internal sql blob getter
func (*DomainInfo) GetFailoverVersion ¶ added in v0.18.0
func (d *DomainInfo) GetFailoverVersion() (o int64)
GetFailoverVersion internal sql blob getter
func (*DomainInfo) GetHistoryArchivalStatus ¶ added in v0.18.0
func (d *DomainInfo) GetHistoryArchivalStatus() (o int16)
GetHistoryArchivalStatus internal sql blob getter
func (*DomainInfo) GetHistoryArchivalURI ¶ added in v0.18.0
func (d *DomainInfo) GetHistoryArchivalURI() (o string)
GetHistoryArchivalURI internal sql blob getter
func (*DomainInfo) GetLastUpdatedTimestamp ¶ added in v0.18.0
func (d *DomainInfo) GetLastUpdatedTimestamp() time.Time
GetLastUpdatedTimestamp internal sql blob getter
func (*DomainInfo) GetName ¶ added in v0.18.0
func (d *DomainInfo) GetName() (o string)
GetName internal sql blob getter
func (*DomainInfo) GetNotificationVersion ¶ added in v0.18.0
func (d *DomainInfo) GetNotificationVersion() (o int64)
GetNotificationVersion internal sql blob getter
func (*DomainInfo) GetOwner ¶ added in v0.18.0
func (d *DomainInfo) GetOwner() (o string)
GetOwner internal sql blob getter
func (*DomainInfo) GetPreviousFailoverVersion ¶ added in v0.18.0
func (d *DomainInfo) GetPreviousFailoverVersion() (o int64)
GetPreviousFailoverVersion internal sql blob getter
func (*DomainInfo) GetRetention ¶ added in v0.18.0
func (d *DomainInfo) GetRetention() time.Duration
GetRetention internal sql blob getter
func (*DomainInfo) GetStatus ¶ added in v0.18.0
func (d *DomainInfo) GetStatus() (o int32)
GetStatus internal sql blob getter
func (*DomainInfo) GetVisibilityArchivalStatus ¶ added in v0.18.0
func (d *DomainInfo) GetVisibilityArchivalStatus() (o int16)
GetVisibilityArchivalStatus internal sql blob getter
func (*DomainInfo) GetVisibilityArchivalURI ¶ added in v0.18.0
func (d *DomainInfo) GetVisibilityArchivalURI() (o string)
GetVisibilityArchivalURI internal sql blob getter
type HistoryBranchRange ¶ added in v0.18.0
HistoryBranchRange blob in a serialization agnostic format
type HistoryTreeInfo ¶ added in v0.18.0
type HistoryTreeInfo struct { CreatedTimestamp time.Time Ancestors []*types.HistoryBranchRange Info string }
HistoryTreeInfo blob in a serialization agnostic format
func (*HistoryTreeInfo) GetAncestors ¶ added in v0.18.0
func (h *HistoryTreeInfo) GetAncestors() (o []*types.HistoryBranchRange)
GetAncestors internal sql blob getter
func (*HistoryTreeInfo) GetCreatedTimestamp ¶ added in v0.18.0
func (h *HistoryTreeInfo) GetCreatedTimestamp() time.Time
GetCreatedTimestamp internal sql blob getter
func (*HistoryTreeInfo) GetInfo ¶ added in v0.18.0
func (h *HistoryTreeInfo) GetInfo() (o string)
GetInfo internal sql blob getter
type MockParser ¶ added in v1.2.7
type MockParser struct {
// contains filtered or unexported fields
}
MockParser is a mock of Parser interface.
func NewMockParser ¶ added in v1.2.7
func NewMockParser(ctrl *gomock.Controller) *MockParser
NewMockParser creates a new mock instance.
func (*MockParser) ActivityInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) ActivityInfoFromBlob(arg0 []byte, arg1 string) (*ActivityInfo, error)
ActivityInfoFromBlob mocks base method.
func (*MockParser) ActivityInfoToBlob ¶ added in v1.2.7
func (m *MockParser) ActivityInfoToBlob(arg0 *ActivityInfo) (persistence.DataBlob, error)
ActivityInfoToBlob mocks base method.
func (*MockParser) ChildExecutionInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) ChildExecutionInfoFromBlob(arg0 []byte, arg1 string) (*ChildExecutionInfo, error)
ChildExecutionInfoFromBlob mocks base method.
func (*MockParser) ChildExecutionInfoToBlob ¶ added in v1.2.7
func (m *MockParser) ChildExecutionInfoToBlob(arg0 *ChildExecutionInfo) (persistence.DataBlob, error)
ChildExecutionInfoToBlob mocks base method.
func (*MockParser) CrossClusterTaskInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) CrossClusterTaskInfoFromBlob(arg0 []byte, arg1 string) (*CrossClusterTaskInfo, error)
CrossClusterTaskInfoFromBlob mocks base method.
func (*MockParser) CrossClusterTaskInfoToBlob ¶ added in v1.2.7
func (m *MockParser) CrossClusterTaskInfoToBlob(arg0 *CrossClusterTaskInfo) (persistence.DataBlob, error)
CrossClusterTaskInfoToBlob mocks base method.
func (*MockParser) DomainInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) DomainInfoFromBlob(arg0 []byte, arg1 string) (*DomainInfo, error)
DomainInfoFromBlob mocks base method.
func (*MockParser) DomainInfoToBlob ¶ added in v1.2.7
func (m *MockParser) DomainInfoToBlob(arg0 *DomainInfo) (persistence.DataBlob, error)
DomainInfoToBlob mocks base method.
func (*MockParser) EXPECT ¶ added in v1.2.7
func (m *MockParser) EXPECT() *MockParserMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockParser) HistoryTreeInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) HistoryTreeInfoFromBlob(arg0 []byte, arg1 string) (*HistoryTreeInfo, error)
HistoryTreeInfoFromBlob mocks base method.
func (*MockParser) HistoryTreeInfoToBlob ¶ added in v1.2.7
func (m *MockParser) HistoryTreeInfoToBlob(arg0 *HistoryTreeInfo) (persistence.DataBlob, error)
HistoryTreeInfoToBlob mocks base method.
func (*MockParser) ReplicationTaskInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) ReplicationTaskInfoFromBlob(arg0 []byte, arg1 string) (*ReplicationTaskInfo, error)
ReplicationTaskInfoFromBlob mocks base method.
func (*MockParser) ReplicationTaskInfoToBlob ¶ added in v1.2.7
func (m *MockParser) ReplicationTaskInfoToBlob(arg0 *ReplicationTaskInfo) (persistence.DataBlob, error)
ReplicationTaskInfoToBlob mocks base method.
func (*MockParser) RequestCancelInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) RequestCancelInfoFromBlob(arg0 []byte, arg1 string) (*RequestCancelInfo, error)
RequestCancelInfoFromBlob mocks base method.
func (*MockParser) RequestCancelInfoToBlob ¶ added in v1.2.7
func (m *MockParser) RequestCancelInfoToBlob(arg0 *RequestCancelInfo) (persistence.DataBlob, error)
RequestCancelInfoToBlob mocks base method.
func (*MockParser) ShardInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) ShardInfoFromBlob(arg0 []byte, arg1 string) (*ShardInfo, error)
ShardInfoFromBlob mocks base method.
func (*MockParser) ShardInfoToBlob ¶ added in v1.2.7
func (m *MockParser) ShardInfoToBlob(arg0 *ShardInfo) (persistence.DataBlob, error)
ShardInfoToBlob mocks base method.
func (*MockParser) SignalInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) SignalInfoFromBlob(arg0 []byte, arg1 string) (*SignalInfo, error)
SignalInfoFromBlob mocks base method.
func (*MockParser) SignalInfoToBlob ¶ added in v1.2.7
func (m *MockParser) SignalInfoToBlob(arg0 *SignalInfo) (persistence.DataBlob, error)
SignalInfoToBlob mocks base method.
func (*MockParser) TaskInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) TaskInfoFromBlob(arg0 []byte, arg1 string) (*TaskInfo, error)
TaskInfoFromBlob mocks base method.
func (*MockParser) TaskInfoToBlob ¶ added in v1.2.7
func (m *MockParser) TaskInfoToBlob(arg0 *TaskInfo) (persistence.DataBlob, error)
TaskInfoToBlob mocks base method.
func (*MockParser) TaskListInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) TaskListInfoFromBlob(arg0 []byte, arg1 string) (*TaskListInfo, error)
TaskListInfoFromBlob mocks base method.
func (*MockParser) TaskListInfoToBlob ¶ added in v1.2.7
func (m *MockParser) TaskListInfoToBlob(arg0 *TaskListInfo) (persistence.DataBlob, error)
TaskListInfoToBlob mocks base method.
func (*MockParser) TimerInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) TimerInfoFromBlob(arg0 []byte, arg1 string) (*TimerInfo, error)
TimerInfoFromBlob mocks base method.
func (*MockParser) TimerInfoToBlob ¶ added in v1.2.7
func (m *MockParser) TimerInfoToBlob(arg0 *TimerInfo) (persistence.DataBlob, error)
TimerInfoToBlob mocks base method.
func (*MockParser) TimerTaskInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) TimerTaskInfoFromBlob(arg0 []byte, arg1 string) (*TimerTaskInfo, error)
TimerTaskInfoFromBlob mocks base method.
func (*MockParser) TimerTaskInfoToBlob ¶ added in v1.2.7
func (m *MockParser) TimerTaskInfoToBlob(arg0 *TimerTaskInfo) (persistence.DataBlob, error)
TimerTaskInfoToBlob mocks base method.
func (*MockParser) TransferTaskInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) TransferTaskInfoFromBlob(arg0 []byte, arg1 string) (*TransferTaskInfo, error)
TransferTaskInfoFromBlob mocks base method.
func (*MockParser) TransferTaskInfoToBlob ¶ added in v1.2.7
func (m *MockParser) TransferTaskInfoToBlob(arg0 *TransferTaskInfo) (persistence.DataBlob, error)
TransferTaskInfoToBlob mocks base method.
func (*MockParser) WorkflowExecutionInfoFromBlob ¶ added in v1.2.7
func (m *MockParser) WorkflowExecutionInfoFromBlob(arg0 []byte, arg1 string) (*WorkflowExecutionInfo, error)
WorkflowExecutionInfoFromBlob mocks base method.
func (*MockParser) WorkflowExecutionInfoToBlob ¶ added in v1.2.7
func (m *MockParser) WorkflowExecutionInfoToBlob(arg0 *WorkflowExecutionInfo) (persistence.DataBlob, error)
WorkflowExecutionInfoToBlob mocks base method.
type MockParserMockRecorder ¶ added in v1.2.7
type MockParserMockRecorder struct {
// contains filtered or unexported fields
}
MockParserMockRecorder is the mock recorder for MockParser.
func (*MockParserMockRecorder) ActivityInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ActivityInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
ActivityInfoFromBlob indicates an expected call of ActivityInfoFromBlob.
func (*MockParserMockRecorder) ActivityInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ActivityInfoToBlob(arg0 interface{}) *gomock.Call
ActivityInfoToBlob indicates an expected call of ActivityInfoToBlob.
func (*MockParserMockRecorder) ChildExecutionInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ChildExecutionInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
ChildExecutionInfoFromBlob indicates an expected call of ChildExecutionInfoFromBlob.
func (*MockParserMockRecorder) ChildExecutionInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ChildExecutionInfoToBlob(arg0 interface{}) *gomock.Call
ChildExecutionInfoToBlob indicates an expected call of ChildExecutionInfoToBlob.
func (*MockParserMockRecorder) CrossClusterTaskInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) CrossClusterTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
CrossClusterTaskInfoFromBlob indicates an expected call of CrossClusterTaskInfoFromBlob.
func (*MockParserMockRecorder) CrossClusterTaskInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) CrossClusterTaskInfoToBlob(arg0 interface{}) *gomock.Call
CrossClusterTaskInfoToBlob indicates an expected call of CrossClusterTaskInfoToBlob.
func (*MockParserMockRecorder) DomainInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) DomainInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
DomainInfoFromBlob indicates an expected call of DomainInfoFromBlob.
func (*MockParserMockRecorder) DomainInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) DomainInfoToBlob(arg0 interface{}) *gomock.Call
DomainInfoToBlob indicates an expected call of DomainInfoToBlob.
func (*MockParserMockRecorder) HistoryTreeInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) HistoryTreeInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
HistoryTreeInfoFromBlob indicates an expected call of HistoryTreeInfoFromBlob.
func (*MockParserMockRecorder) HistoryTreeInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) HistoryTreeInfoToBlob(arg0 interface{}) *gomock.Call
HistoryTreeInfoToBlob indicates an expected call of HistoryTreeInfoToBlob.
func (*MockParserMockRecorder) ReplicationTaskInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ReplicationTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
ReplicationTaskInfoFromBlob indicates an expected call of ReplicationTaskInfoFromBlob.
func (*MockParserMockRecorder) ReplicationTaskInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ReplicationTaskInfoToBlob(arg0 interface{}) *gomock.Call
ReplicationTaskInfoToBlob indicates an expected call of ReplicationTaskInfoToBlob.
func (*MockParserMockRecorder) RequestCancelInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) RequestCancelInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
RequestCancelInfoFromBlob indicates an expected call of RequestCancelInfoFromBlob.
func (*MockParserMockRecorder) RequestCancelInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) RequestCancelInfoToBlob(arg0 interface{}) *gomock.Call
RequestCancelInfoToBlob indicates an expected call of RequestCancelInfoToBlob.
func (*MockParserMockRecorder) ShardInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ShardInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
ShardInfoFromBlob indicates an expected call of ShardInfoFromBlob.
func (*MockParserMockRecorder) ShardInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) ShardInfoToBlob(arg0 interface{}) *gomock.Call
ShardInfoToBlob indicates an expected call of ShardInfoToBlob.
func (*MockParserMockRecorder) SignalInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) SignalInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
SignalInfoFromBlob indicates an expected call of SignalInfoFromBlob.
func (*MockParserMockRecorder) SignalInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) SignalInfoToBlob(arg0 interface{}) *gomock.Call
SignalInfoToBlob indicates an expected call of SignalInfoToBlob.
func (*MockParserMockRecorder) TaskInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
TaskInfoFromBlob indicates an expected call of TaskInfoFromBlob.
func (*MockParserMockRecorder) TaskInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TaskInfoToBlob(arg0 interface{}) *gomock.Call
TaskInfoToBlob indicates an expected call of TaskInfoToBlob.
func (*MockParserMockRecorder) TaskListInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TaskListInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
TaskListInfoFromBlob indicates an expected call of TaskListInfoFromBlob.
func (*MockParserMockRecorder) TaskListInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TaskListInfoToBlob(arg0 interface{}) *gomock.Call
TaskListInfoToBlob indicates an expected call of TaskListInfoToBlob.
func (*MockParserMockRecorder) TimerInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TimerInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
TimerInfoFromBlob indicates an expected call of TimerInfoFromBlob.
func (*MockParserMockRecorder) TimerInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TimerInfoToBlob(arg0 interface{}) *gomock.Call
TimerInfoToBlob indicates an expected call of TimerInfoToBlob.
func (*MockParserMockRecorder) TimerTaskInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TimerTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
TimerTaskInfoFromBlob indicates an expected call of TimerTaskInfoFromBlob.
func (*MockParserMockRecorder) TimerTaskInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TimerTaskInfoToBlob(arg0 interface{}) *gomock.Call
TimerTaskInfoToBlob indicates an expected call of TimerTaskInfoToBlob.
func (*MockParserMockRecorder) TransferTaskInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TransferTaskInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
TransferTaskInfoFromBlob indicates an expected call of TransferTaskInfoFromBlob.
func (*MockParserMockRecorder) TransferTaskInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) TransferTaskInfoToBlob(arg0 interface{}) *gomock.Call
TransferTaskInfoToBlob indicates an expected call of TransferTaskInfoToBlob.
func (*MockParserMockRecorder) WorkflowExecutionInfoFromBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) WorkflowExecutionInfoFromBlob(arg0, arg1 interface{}) *gomock.Call
WorkflowExecutionInfoFromBlob indicates an expected call of WorkflowExecutionInfoFromBlob.
func (*MockParserMockRecorder) WorkflowExecutionInfoToBlob ¶ added in v1.2.7
func (mr *MockParserMockRecorder) WorkflowExecutionInfoToBlob(arg0 interface{}) *gomock.Call
WorkflowExecutionInfoToBlob indicates an expected call of WorkflowExecutionInfoToBlob.
type Mockdecoder ¶ added in v1.2.7
type Mockdecoder struct {
// contains filtered or unexported fields
}
Mockdecoder is a mock of decoder interface.
func NewMockdecoder ¶ added in v1.2.7
func NewMockdecoder(ctrl *gomock.Controller) *Mockdecoder
NewMockdecoder creates a new mock instance.
func (*Mockdecoder) EXPECT ¶ added in v1.2.7
func (m *Mockdecoder) EXPECT() *MockdecoderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockdecoderMockRecorder ¶ added in v1.2.7
type MockdecoderMockRecorder struct {
// contains filtered or unexported fields
}
MockdecoderMockRecorder is the mock recorder for Mockdecoder.
type Mockencoder ¶ added in v1.2.7
type Mockencoder struct {
// contains filtered or unexported fields
}
Mockencoder is a mock of encoder interface.
func NewMockencoder ¶ added in v1.2.7
func NewMockencoder(ctrl *gomock.Controller) *Mockencoder
NewMockencoder creates a new mock instance.
func (*Mockencoder) EXPECT ¶ added in v1.2.7
func (m *Mockencoder) EXPECT() *MockencoderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockencoderMockRecorder ¶ added in v1.2.7
type MockencoderMockRecorder struct {
// contains filtered or unexported fields
}
MockencoderMockRecorder is the mock recorder for Mockencoder.
type MockthriftRWType ¶ added in v1.2.7
type MockthriftRWType struct {
// contains filtered or unexported fields
}
MockthriftRWType is a mock of thriftRWType interface.
func NewMockthriftRWType ¶ added in v1.2.7
func NewMockthriftRWType(ctrl *gomock.Controller) *MockthriftRWType
NewMockthriftRWType creates a new mock instance.
func (*MockthriftRWType) Decode ¶ added in v1.2.7
func (m *MockthriftRWType) Decode(arg0 stream.Reader) error
Decode mocks base method.
func (*MockthriftRWType) EXPECT ¶ added in v1.2.7
func (m *MockthriftRWType) EXPECT() *MockthriftRWTypeMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockthriftRWType) Encode ¶ added in v1.2.7
func (m *MockthriftRWType) Encode(arg0 stream.Writer) error
Encode mocks base method.
type MockthriftRWTypeMockRecorder ¶ added in v1.2.7
type MockthriftRWTypeMockRecorder struct {
// contains filtered or unexported fields
}
MockthriftRWTypeMockRecorder is the mock recorder for MockthriftRWType.
func (*MockthriftRWTypeMockRecorder) Decode ¶ added in v1.2.7
func (mr *MockthriftRWTypeMockRecorder) Decode(arg0 interface{}) *gomock.Call
Decode indicates an expected call of Decode.
func (*MockthriftRWTypeMockRecorder) Encode ¶ added in v1.2.7
func (mr *MockthriftRWTypeMockRecorder) Encode(arg0 interface{}) *gomock.Call
Encode indicates an expected call of Encode.
func (*MockthriftRWTypeMockRecorder) FromWire ¶ added in v1.2.7
func (mr *MockthriftRWTypeMockRecorder) FromWire(w interface{}) *gomock.Call
FromWire indicates an expected call of FromWire.
func (*MockthriftRWTypeMockRecorder) ToWire ¶ added in v1.2.7
func (mr *MockthriftRWTypeMockRecorder) ToWire() *gomock.Call
ToWire indicates an expected call of ToWire.
type Parser ¶
type Parser interface { ShardInfoToBlob(*ShardInfo) (persistence.DataBlob, error) DomainInfoToBlob(*DomainInfo) (persistence.DataBlob, error) HistoryTreeInfoToBlob(*HistoryTreeInfo) (persistence.DataBlob, error) WorkflowExecutionInfoToBlob(*WorkflowExecutionInfo) (persistence.DataBlob, error) ActivityInfoToBlob(*ActivityInfo) (persistence.DataBlob, error) ChildExecutionInfoToBlob(*ChildExecutionInfo) (persistence.DataBlob, error) SignalInfoToBlob(*SignalInfo) (persistence.DataBlob, error) RequestCancelInfoToBlob(*RequestCancelInfo) (persistence.DataBlob, error) TimerInfoToBlob(*TimerInfo) (persistence.DataBlob, error) TaskInfoToBlob(*TaskInfo) (persistence.DataBlob, error) TaskListInfoToBlob(*TaskListInfo) (persistence.DataBlob, error) TransferTaskInfoToBlob(*TransferTaskInfo) (persistence.DataBlob, error) CrossClusterTaskInfoToBlob(*CrossClusterTaskInfo) (persistence.DataBlob, error) TimerTaskInfoToBlob(*TimerTaskInfo) (persistence.DataBlob, error) ReplicationTaskInfoToBlob(*ReplicationTaskInfo) (persistence.DataBlob, error) ShardInfoFromBlob([]byte, string) (*ShardInfo, error) DomainInfoFromBlob([]byte, string) (*DomainInfo, error) HistoryTreeInfoFromBlob([]byte, string) (*HistoryTreeInfo, error) WorkflowExecutionInfoFromBlob([]byte, string) (*WorkflowExecutionInfo, error) ActivityInfoFromBlob([]byte, string) (*ActivityInfo, error) ChildExecutionInfoFromBlob([]byte, string) (*ChildExecutionInfo, error) SignalInfoFromBlob([]byte, string) (*SignalInfo, error) RequestCancelInfoFromBlob([]byte, string) (*RequestCancelInfo, error) TimerInfoFromBlob([]byte, string) (*TimerInfo, error) TaskInfoFromBlob([]byte, string) (*TaskInfo, error) TaskListInfoFromBlob([]byte, string) (*TaskListInfo, error) TransferTaskInfoFromBlob([]byte, string) (*TransferTaskInfo, error) CrossClusterTaskInfoFromBlob([]byte, string) (*CrossClusterTaskInfo, error) TimerTaskInfoFromBlob([]byte, string) (*TimerTaskInfo, error) ReplicationTaskInfoFromBlob([]byte, string) (*ReplicationTaskInfo, error) }
Parser is used to do serialization and deserialization. A parser is backed by a a single encoder which encodes into one format and a collection of decoders. Parser selects the appropriate decoder for the provided blob.
func NewParser ¶
func NewParser(encodingType common.EncodingType, decodingTypes ...common.EncodingType) (Parser, error)
NewParser constructs a new parser using encoder as specified by encodingType and using decoders specified by decodingTypes
type ReplicationTaskInfo ¶ added in v0.18.0
type ReplicationTaskInfo struct { DomainID UUID WorkflowID string RunID UUID TaskType int16 Version int64 FirstEventID int64 NextEventID int64 ScheduledID int64 EventStoreVersion int32 NewRunEventStoreVersion int32 BranchToken []byte NewRunBranchToken []byte CreationTimestamp time.Time }
ReplicationTaskInfo blob in a serialization agnostic format
func (*ReplicationTaskInfo) GetBranchToken ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetBranchToken() (o []byte)
GetBranchToken internal sql blob getter
func (*ReplicationTaskInfo) GetCreationTimestamp ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetCreationTimestamp() time.Time
GetCreationTimestamp internal sql blob getter
func (*ReplicationTaskInfo) GetDomainID ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetDomainID() (o []byte)
GetDomainID internal sql blob getter
func (*ReplicationTaskInfo) GetEventStoreVersion ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetEventStoreVersion() (o int32)
GetEventStoreVersion internal sql blob getter
func (*ReplicationTaskInfo) GetFirstEventID ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetFirstEventID() (o int64)
GetFirstEventID internal sql blob getter
func (*ReplicationTaskInfo) GetNewRunBranchToken ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetNewRunBranchToken() (o []byte)
GetNewRunBranchToken internal sql blob getter
func (*ReplicationTaskInfo) GetNewRunEventStoreVersion ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetNewRunEventStoreVersion() (o int32)
GetNewRunEventStoreVersion internal sql blob getter
func (*ReplicationTaskInfo) GetNextEventID ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetNextEventID() (o int64)
GetNextEventID internal sql blob getter
func (*ReplicationTaskInfo) GetRunID ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetRunID() (o []byte)
GetRunID internal sql blob getter
func (*ReplicationTaskInfo) GetScheduledID ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetScheduledID() (o int64)
GetScheduledID internal sql blob getter
func (*ReplicationTaskInfo) GetTaskType ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetTaskType() (o int16)
GetTaskType internal sql blob getter
func (*ReplicationTaskInfo) GetVersion ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetVersion() (o int64)
GetVersion internal sql blob getter
func (*ReplicationTaskInfo) GetWorkflowID ¶ added in v0.18.0
func (t *ReplicationTaskInfo) GetWorkflowID() (o string)
GetWorkflowID internal sql blob getter
type RequestCancelInfo ¶ added in v0.18.0
RequestCancelInfo blob in a serialization agnostic format
func (*RequestCancelInfo) GetCancelRequestID ¶ added in v0.18.0
func (r *RequestCancelInfo) GetCancelRequestID() (o string)
GetCancelRequestID internal sql blob getter
func (*RequestCancelInfo) GetInitiatedEventBatchID ¶ added in v0.18.0
func (r *RequestCancelInfo) GetInitiatedEventBatchID() (o int64)
GetInitiatedEventBatchID internal sql blob getter
func (*RequestCancelInfo) GetVersion ¶ added in v0.18.0
func (r *RequestCancelInfo) GetVersion() (o int64)
GetVersion internal sql blob getter
type ShardInfo ¶ added in v0.18.0
type ShardInfo struct { StolenSinceRenew int32 UpdatedAt time.Time ReplicationAckLevel int64 TransferAckLevel int64 TimerAckLevel time.Time DomainNotificationVersion int64 ClusterTransferAckLevel map[string]int64 ClusterTimerAckLevel map[string]time.Time Owner string ClusterReplicationLevel map[string]int64 PendingFailoverMarkers []byte PendingFailoverMarkersEncoding string ReplicationDlqAckLevel map[string]int64 TransferProcessingQueueStates []byte TransferProcessingQueueStatesEncoding string CrossClusterProcessingQueueStates []byte CrossClusterProcessingQueueStatesEncoding string TimerProcessingQueueStates []byte TimerProcessingQueueStatesEncoding string }
ShardInfo blob in a serialization agnostic format
func (*ShardInfo) GetClusterReplicationLevel ¶ added in v0.18.0
GetClusterReplicationLevel internal sql blob getter
func (*ShardInfo) GetClusterTimerAckLevel ¶ added in v0.18.0
GetClusterTimerAckLevel internal sql blob getter
func (*ShardInfo) GetClusterTransferAckLevel ¶ added in v0.18.0
GetClusterTransferAckLevel internal sql blob getter
func (*ShardInfo) GetDomainNotificationVersion ¶ added in v0.18.0
GetDomainNotificationVersion internal sql blob getter
func (*ShardInfo) GetPendingFailoverMarkers ¶ added in v0.18.0
GetPendingFailoverMarkers internal sql blob getter
func (*ShardInfo) GetPendingFailoverMarkersEncoding ¶ added in v0.18.0
GetPendingFailoverMarkersEncoding internal sql blob getter
func (*ShardInfo) GetReplicationAckLevel ¶ added in v0.18.0
GetReplicationAckLevel internal sql blob getter
func (*ShardInfo) GetReplicationDlqAckLevel ¶ added in v0.18.0
GetReplicationDlqAckLevel internal sql blob getter
func (*ShardInfo) GetStolenSinceRenew ¶ added in v0.18.0
GetStolenSinceRenew internal sql blob getter
func (*ShardInfo) GetTimerAckLevel ¶ added in v0.18.0
GetTimerAckLevel internal sql blob getter
func (*ShardInfo) GetTimerProcessingQueueStates ¶ added in v0.18.0
GetTimerProcessingQueueStates internal sql blob getter
func (*ShardInfo) GetTimerProcessingQueueStatesEncoding ¶ added in v0.18.0
GetTimerProcessingQueueStatesEncoding internal sql blob getter
func (*ShardInfo) GetTransferAckLevel ¶ added in v0.18.0
GetTransferAckLevel internal sql blob getter
func (*ShardInfo) GetTransferProcessingQueueStates ¶ added in v0.18.0
GetTransferProcessingQueueStates internal sql blob getter
func (*ShardInfo) GetTransferProcessingQueueStatesEncoding ¶ added in v0.18.0
GetTransferProcessingQueueStatesEncoding internal sql blob getter
func (*ShardInfo) GetUpdatedAt ¶ added in v0.18.0
GetUpdatedAt internal sql blob getter
type SignalInfo ¶ added in v0.18.0
type SignalInfo struct { Version int64 InitiatedEventBatchID int64 RequestID string Name string Input []byte Control []byte }
SignalInfo blob in a serialization agnostic format
func (*SignalInfo) GetControl ¶ added in v0.18.0
func (s *SignalInfo) GetControl() (o []byte)
GetControl internal sql blob getter
func (*SignalInfo) GetInitiatedEventBatchID ¶ added in v0.18.0
func (s *SignalInfo) GetInitiatedEventBatchID() (o int64)
GetInitiatedEventBatchID internal sql blob getter
func (*SignalInfo) GetInput ¶ added in v0.18.0
func (s *SignalInfo) GetInput() (o []byte)
GetInput internal sql blob getter
func (*SignalInfo) GetName ¶ added in v0.18.0
func (s *SignalInfo) GetName() (o string)
GetName internal sql blob getter
func (*SignalInfo) GetRequestID ¶ added in v0.18.0
func (s *SignalInfo) GetRequestID() (o string)
GetRequestID internal sql blob getter
func (*SignalInfo) GetVersion ¶ added in v0.18.0
func (s *SignalInfo) GetVersion() (o int64)
GetVersion internal sql blob getter
type TaskInfo ¶ added in v0.18.0
type TaskInfo struct { WorkflowID string RunID UUID ScheduleID int64 ExpiryTimestamp time.Time CreatedTimestamp time.Time PartitionConfig map[string]string }
TaskInfo blob in a serialization agnostic format
func (*TaskInfo) GetCreatedTimestamp ¶ added in v0.18.0
GetCreatedTimestamp internal sql blob getter
func (*TaskInfo) GetExpiryTimestamp ¶ added in v0.18.0
GetExpiryTimestamp internal sql blob getter
func (*TaskInfo) GetPartitionConfig ¶ added in v1.2.1
GetPartitionConfig internal sql blob getter
func (*TaskInfo) GetScheduleID ¶ added in v0.18.0
GetScheduleID internal sql blob getter
func (*TaskInfo) GetWorkflowID ¶ added in v0.18.0
GetWorkflowID internal sql blob getter
type TaskListInfo ¶ added in v0.18.0
type TaskListInfo struct { Kind int16 AckLevel int64 ExpiryTimestamp time.Time LastUpdated time.Time }
TaskListInfo blob in a serialization agnostic format
func (*TaskListInfo) GetAckLevel ¶ added in v0.18.0
func (t *TaskListInfo) GetAckLevel() (o int64)
GetAckLevel internal sql blob getter
func (*TaskListInfo) GetExpiryTimestamp ¶ added in v0.18.0
func (t *TaskListInfo) GetExpiryTimestamp() time.Time
GetExpiryTimestamp internal sql blob getter
func (*TaskListInfo) GetKind ¶ added in v0.18.0
func (t *TaskListInfo) GetKind() (o int16)
GetKind internal sql blob getter
func (*TaskListInfo) GetLastUpdated ¶ added in v0.18.0
func (t *TaskListInfo) GetLastUpdated() time.Time
GetLastUpdated internal sql blob getter
type TimerInfo ¶ added in v0.18.0
TimerInfo blob in a serialization agnostic format
func (*TimerInfo) GetExpiryTimestamp ¶ added in v0.18.0
GetExpiryTimestamp internal sql blob getter
func (*TimerInfo) GetStartedID ¶ added in v0.18.0
GetStartedID internal sql blob getter
func (*TimerInfo) GetVersion ¶ added in v0.18.0
GetVersion internal sql blob getter
type TimerTaskInfo ¶ added in v0.18.0
type TimerTaskInfo struct { DomainID UUID WorkflowID string RunID UUID TaskType int16 TimeoutType *int16 // TODO: The default value for TimeoutType doesn't make sense. No equivalent value for nil. Version int64 ScheduleAttempt int64 EventID int64 }
TimerTaskInfo blob in a serialization agnostic format
func (*TimerTaskInfo) GetDomainID ¶ added in v0.18.0
func (t *TimerTaskInfo) GetDomainID() (o []byte)
GetDomainID internal sql blob getter
func (*TimerTaskInfo) GetEventID ¶ added in v0.18.0
func (t *TimerTaskInfo) GetEventID() (o int64)
GetEventID internal sql blob getter
func (*TimerTaskInfo) GetRunID ¶ added in v0.18.0
func (t *TimerTaskInfo) GetRunID() (o []byte)
GetRunID internal sql blob getter
func (*TimerTaskInfo) GetScheduleAttempt ¶ added in v0.18.0
func (t *TimerTaskInfo) GetScheduleAttempt() (o int64)
GetScheduleAttempt internal sql blob getter
func (*TimerTaskInfo) GetTaskType ¶ added in v0.18.0
func (t *TimerTaskInfo) GetTaskType() (o int16)
GetTaskType internal sql blob getter
func (*TimerTaskInfo) GetTimeoutType ¶ added in v0.18.0
func (t *TimerTaskInfo) GetTimeoutType() (o int16)
GetTimeoutType internal sql blob getter
func (*TimerTaskInfo) GetVersion ¶ added in v0.18.0
func (t *TimerTaskInfo) GetVersion() (o int64)
GetVersion internal sql blob getter
func (*TimerTaskInfo) GetWorkflowID ¶ added in v0.18.0
func (t *TimerTaskInfo) GetWorkflowID() (o string)
GetWorkflowID internal sql blob getter
type TransferTaskInfo ¶ added in v0.18.0
type TransferTaskInfo struct { DomainID UUID WorkflowID string RunID UUID TaskType int16 TargetDomainID UUID TargetDomainIDs []UUID TargetWorkflowID string TargetRunID UUID TaskList string TargetChildWorkflowOnly bool ScheduleID int64 Version int64 VisibilityTimestamp time.Time }
TransferTaskInfo blob in a serialization agnostic format
func (*TransferTaskInfo) GetDomainID ¶ added in v0.18.0
func (t *TransferTaskInfo) GetDomainID() (o []byte)
GetDomainID internal sql blob getter
func (*TransferTaskInfo) GetRunID ¶ added in v0.18.0
func (t *TransferTaskInfo) GetRunID() (o []byte)
GetRunID internal sql blob getter
func (*TransferTaskInfo) GetScheduleID ¶ added in v0.18.0
func (t *TransferTaskInfo) GetScheduleID() (o int64)
GetScheduleID internal sql blob getter
func (*TransferTaskInfo) GetTargetChildWorkflowOnly ¶ added in v0.18.0
func (t *TransferTaskInfo) GetTargetChildWorkflowOnly() (o bool)
GetTargetChildWorkflowOnly internal sql blob getter
func (*TransferTaskInfo) GetTargetDomainID ¶ added in v0.18.0
func (t *TransferTaskInfo) GetTargetDomainID() (o []byte)
GetTargetDomainID internal sql blob getter
func (*TransferTaskInfo) GetTargetDomainIDs ¶ added in v0.24.0
func (t *TransferTaskInfo) GetTargetDomainIDs() (o map[string]struct{})
GetTargetDomainIDs internal sql blob getter
func (*TransferTaskInfo) GetTargetRunID ¶ added in v0.18.0
func (t *TransferTaskInfo) GetTargetRunID() (o []byte)
GetTargetRunID internal sql blob getter
func (*TransferTaskInfo) GetTargetWorkflowID ¶ added in v0.18.0
func (t *TransferTaskInfo) GetTargetWorkflowID() (o string)
GetTargetWorkflowID internal sql blob getter
func (*TransferTaskInfo) GetTaskList ¶ added in v0.18.0
func (t *TransferTaskInfo) GetTaskList() (o string)
GetTaskList internal sql blob getter
func (*TransferTaskInfo) GetTaskType ¶ added in v0.18.0
func (t *TransferTaskInfo) GetTaskType() (o int16)
GetTaskType internal sql blob getter
func (*TransferTaskInfo) GetVersion ¶ added in v0.18.0
func (t *TransferTaskInfo) GetVersion() (o int64)
GetVersion internal sql blob getter
func (*TransferTaskInfo) GetVisibilityTimestamp ¶ added in v0.18.0
func (t *TransferTaskInfo) GetVisibilityTimestamp() time.Time
GetVisibilityTimestamp internal sql blob getter
func (*TransferTaskInfo) GetWorkflowID ¶ added in v0.18.0
func (t *TransferTaskInfo) GetWorkflowID() (o string)
GetWorkflowID internal sql blob getter
type UUID ¶ added in v0.18.0
type UUID []byte
UUID represents a 16-byte universally unique identifier this type is a wrapper around google/uuid with the following differences
- type is a byte slice instead of [16]byte
- db serialization converts uuid to bytes as opposed to string
func MustParsePtrUUID ¶ added in v0.18.0
MustParsePtrUUID returns a UUID parsed from the given string representation returns nil if the input is empty string panics if the given input is malformed
func MustParseUUID ¶ added in v0.18.0
MustParseUUID returns a UUID parsed from the given string representation returns nil if the input is empty string panics if the given input is malformed
func (*UUID) Scan ¶ added in v0.18.0
Scan implements sql.Scanner interface to allow this type to be parsed transparently by database drivers
type WorkflowExecutionInfo ¶ added in v0.18.0
type WorkflowExecutionInfo struct { ParentDomainID UUID ParentWorkflowID string ParentRunID UUID InitiatedID int64 CompletionEventBatchID *int64 // TODO: This is not updated because of backward compatibility issue. Should revisit it later. CompletionEvent []byte CompletionEventEncoding string TaskList string IsCron bool WorkflowTypeName string WorkflowTimeout time.Duration DecisionTaskTimeout time.Duration ExecutionContext []byte State int32 CloseStatus int32 StartVersion int64 LastWriteEventID *int64 // TODO: We have logic checking if LastWriteEventID != nil. The field seems to be deprecated. Should revisit it later. LastEventTaskID int64 LastFirstEventID int64 LastProcessedEvent int64 StartTimestamp time.Time LastUpdatedTimestamp time.Time DecisionVersion int64 DecisionScheduleID int64 DecisionStartedID int64 DecisionTimeout time.Duration DecisionAttempt int64 DecisionStartedTimestamp time.Time DecisionScheduledTimestamp time.Time CancelRequested bool DecisionOriginalScheduledTimestamp time.Time CreateRequestID string DecisionRequestID string CancelRequestID string StickyTaskList string StickyScheduleToStartTimeout time.Duration RetryAttempt int64 RetryInitialInterval time.Duration RetryMaximumInterval time.Duration RetryMaximumAttempts int32 RetryExpiration time.Duration RetryBackoffCoefficient float64 RetryExpirationTimestamp time.Time RetryNonRetryableErrors []string HasRetryPolicy bool CronSchedule string EventStoreVersion int32 EventBranchToken []byte SignalCount int64 HistorySize int64 ClientLibraryVersion string ClientFeatureVersion string ClientImpl string AutoResetPoints []byte AutoResetPointsEncoding string SearchAttributes map[string][]byte Memo map[string][]byte VersionHistories []byte VersionHistoriesEncoding string FirstExecutionRunID UUID PartitionConfig map[string]string Checksum []byte ChecksumEncoding string }
WorkflowExecutionInfo blob in a serialization agnostic format
func FromInternalWorkflowExecutionInfo ¶ added in v0.24.0
func FromInternalWorkflowExecutionInfo(executionInfo *persistence.InternalWorkflowExecutionInfo) *WorkflowExecutionInfo
func (*WorkflowExecutionInfo) GetAutoResetPoints ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetAutoResetPoints() (o []byte)
GetAutoResetPoints internal sql blob getter
func (*WorkflowExecutionInfo) GetAutoResetPointsEncoding ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetAutoResetPointsEncoding() (o string)
GetAutoResetPointsEncoding internal sql blob getter
func (*WorkflowExecutionInfo) GetCancelRequestID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCancelRequestID() (o string)
GetCancelRequestID internal sql blob getter
func (*WorkflowExecutionInfo) GetCancelRequested ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCancelRequested() (o bool)
GetCancelRequested internal sql blob getter
func (*WorkflowExecutionInfo) GetChecksum ¶ added in v1.2.8
func (w *WorkflowExecutionInfo) GetChecksum() (o []byte)
GetCheckSum internal sql blob getter
func (*WorkflowExecutionInfo) GetChecksumEncoding ¶ added in v1.2.8
func (w *WorkflowExecutionInfo) GetChecksumEncoding() (o string)
GetCheckSumEncoding internal sql blob getter
func (*WorkflowExecutionInfo) GetClientFeatureVersion ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetClientFeatureVersion() (o string)
GetClientFeatureVersion internal sql blob getter
func (*WorkflowExecutionInfo) GetClientImpl ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetClientImpl() (o string)
GetClientImpl internal sql blob getter
func (*WorkflowExecutionInfo) GetClientLibraryVersion ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetClientLibraryVersion() (o string)
GetClientLibraryVersion internal sql blob getter
func (*WorkflowExecutionInfo) GetCloseStatus ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCloseStatus() (o int32)
GetCloseStatus internal sql blob getter
func (*WorkflowExecutionInfo) GetCompletionEvent ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCompletionEvent() (o []byte)
GetCompletionEvent internal sql blob getter
func (*WorkflowExecutionInfo) GetCompletionEventBatchID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCompletionEventBatchID() (o int64)
GetCompletionEventBatchID internal sql blob getter
func (*WorkflowExecutionInfo) GetCompletionEventEncoding ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCompletionEventEncoding() (o string)
GetCompletionEventEncoding internal sql blob getter
func (*WorkflowExecutionInfo) GetCreateRequestID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCreateRequestID() (o string)
GetCreateRequestID internal sql blob getter
func (*WorkflowExecutionInfo) GetCronSchedule ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetCronSchedule() (o string)
GetCronSchedule internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionAttempt ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionAttempt() (o int64)
GetDecisionAttempt internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionOriginalScheduledTimestamp ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionOriginalScheduledTimestamp() time.Time
GetDecisionOriginalScheduledTimestamp internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionRequestID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionRequestID() (o string)
GetDecisionRequestID internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionScheduleID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionScheduleID() (o int64)
GetDecisionScheduleID internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionScheduledTimestamp ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionScheduledTimestamp() time.Time
GetDecisionScheduledTimestamp internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionStartedID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionStartedID() (o int64)
GetDecisionStartedID internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionStartedTimestamp ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionStartedTimestamp() time.Time
GetDecisionStartedTimestamp internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionTaskTimeout ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionTaskTimeout() time.Duration
GetDecisionTaskTimeout internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionTimeout ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionTimeout() time.Duration
GetDecisionTimeout internal sql blob getter
func (*WorkflowExecutionInfo) GetDecisionVersion ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetDecisionVersion() (o int64)
GetDecisionVersion internal sql blob getter
func (*WorkflowExecutionInfo) GetEventBranchToken ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetEventBranchToken() (o []byte)
GetEventBranchToken internal sql blob getter
func (*WorkflowExecutionInfo) GetEventStoreVersion ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetEventStoreVersion() (o int32)
GetEventStoreVersion internal sql blob getter
func (*WorkflowExecutionInfo) GetExecutionContext ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetExecutionContext() (o []byte)
GetExecutionContext internal sql blob getter
func (*WorkflowExecutionInfo) GetFirstExecutionRunID ¶ added in v1.0.0
func (w *WorkflowExecutionInfo) GetFirstExecutionRunID() (o []byte)
GetFirstExecutionRunID internal sql blob getter
func (*WorkflowExecutionInfo) GetHasRetryPolicy ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetHasRetryPolicy() (o bool)
GetHasRetryPolicy internal sql blob getter
func (*WorkflowExecutionInfo) GetHistorySize ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetHistorySize() (o int64)
GetHistorySize internal sql blob getter
func (*WorkflowExecutionInfo) GetInitiatedID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetInitiatedID() (o int64)
GetInitiatedID internal sql blob getter
func (*WorkflowExecutionInfo) GetIsCron ¶ added in v0.22.0
func (w *WorkflowExecutionInfo) GetIsCron() (o bool)
GetIsCron internal sql blob getter
func (*WorkflowExecutionInfo) GetLastEventTaskID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetLastEventTaskID() (o int64)
GetLastEventTaskID internal sql blob getter
func (*WorkflowExecutionInfo) GetLastFirstEventID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetLastFirstEventID() (o int64)
GetLastFirstEventID internal sql blob getter
func (*WorkflowExecutionInfo) GetLastProcessedEvent ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetLastProcessedEvent() (o int64)
GetLastProcessedEvent internal sql blob getter
func (*WorkflowExecutionInfo) GetLastUpdatedTimestamp ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetLastUpdatedTimestamp() time.Time
GetLastUpdatedTimestamp internal sql blob getter
func (*WorkflowExecutionInfo) GetLastWriteEventID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetLastWriteEventID() (o int64)
GetLastWriteEventID internal sql blob getter
func (*WorkflowExecutionInfo) GetMemo ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetMemo() (o map[string][]byte)
GetMemo internal sql blob getter
func (*WorkflowExecutionInfo) GetParentDomainID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetParentDomainID() (o []byte)
GetParentDomainID internal sql blob getter
func (*WorkflowExecutionInfo) GetParentRunID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetParentRunID() (o []byte)
GetParentRunID internal sql blob getter
func (*WorkflowExecutionInfo) GetParentWorkflowID ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetParentWorkflowID() (o string)
GetParentWorkflowID internal sql blob getter
func (*WorkflowExecutionInfo) GetPartitionConfig ¶ added in v1.2.1
func (w *WorkflowExecutionInfo) GetPartitionConfig() (o map[string]string)
GetPartitionConfig internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryAttempt ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryAttempt() (o int64)
GetRetryAttempt internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryBackoffCoefficient ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryBackoffCoefficient() (o float64)
GetRetryBackoffCoefficient internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryExpiration ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryExpiration() time.Duration
GetRetryExpiration internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryExpirationTimestamp ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryExpirationTimestamp() time.Time
GetRetryExpirationTimestamp internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryInitialInterval ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryInitialInterval() time.Duration
GetRetryInitialInterval internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryMaximumAttempts ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryMaximumAttempts() (o int32)
GetRetryMaximumAttempts internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryMaximumInterval ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryMaximumInterval() time.Duration
GetRetryMaximumInterval internal sql blob getter
func (*WorkflowExecutionInfo) GetRetryNonRetryableErrors ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetRetryNonRetryableErrors() (o []string)
GetRetryNonRetryableErrors internal sql blob getter
func (*WorkflowExecutionInfo) GetSearchAttributes ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetSearchAttributes() (o map[string][]byte)
GetSearchAttributes internal sql blob getter
func (*WorkflowExecutionInfo) GetSignalCount ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetSignalCount() (o int64)
GetSignalCount internal sql blob getter
func (*WorkflowExecutionInfo) GetStartTimestamp ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetStartTimestamp() time.Time
GetStartTimestamp internal sql blob getter
func (*WorkflowExecutionInfo) GetStartVersion ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetStartVersion() (o int64)
GetStartVersion internal sql blob getter
func (*WorkflowExecutionInfo) GetState ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetState() (o int32)
GetState internal sql blob getter
func (*WorkflowExecutionInfo) GetStickyScheduleToStartTimeout ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetStickyScheduleToStartTimeout() time.Duration
GetStickyScheduleToStartTimeout internal sql blob getter
func (*WorkflowExecutionInfo) GetStickyTaskList ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetStickyTaskList() (o string)
GetStickyTaskList internal sql blob getter
func (*WorkflowExecutionInfo) GetTaskList ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetTaskList() (o string)
GetTaskList internal sql blob getter
func (*WorkflowExecutionInfo) GetVersionHistories ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetVersionHistories() (o []byte)
GetVersionHistories internal sql blob getter
func (*WorkflowExecutionInfo) GetVersionHistoriesEncoding ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetVersionHistoriesEncoding() (o string)
GetVersionHistoriesEncoding internal sql blob getter
func (*WorkflowExecutionInfo) GetWorkflowTimeout ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetWorkflowTimeout() time.Duration
GetWorkflowTimeout internal sql blob getter
func (*WorkflowExecutionInfo) GetWorkflowTypeName ¶ added in v0.18.0
func (w *WorkflowExecutionInfo) GetWorkflowTypeName() (o string)
GetWorkflowTypeName internal sql blob getter