serialization

package
v1.3.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 24, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package serialization is a generated GoMock package.

Package serialization is a generated GoMock package.

Index

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
	TaskListKind             types.TaskListKind
	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) GetTaskListKind added in v1.3.5 

func (a *ActivityInfo) GetTaskListKind() (o types.TaskListKind)

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
	ActiveClustersConfig         []byte
	ActiveClustersConfigEncoding 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 

type HistoryBranchRange struct {
	BranchID    string
	BeginNodeID int64
	EndNodeID   int64
}

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 any) *gomock.Call

ActivityInfoFromBlob indicates an expected call of ActivityInfoFromBlob.

func (*MockParserMockRecorder) ActivityInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) ActivityInfoToBlob(arg0 any) *gomock.Call

ActivityInfoToBlob indicates an expected call of ActivityInfoToBlob.

func (*MockParserMockRecorder) ChildExecutionInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) ChildExecutionInfoFromBlob(arg0, arg1 any) *gomock.Call

ChildExecutionInfoFromBlob indicates an expected call of ChildExecutionInfoFromBlob.

func (*MockParserMockRecorder) ChildExecutionInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) ChildExecutionInfoToBlob(arg0 any) *gomock.Call

ChildExecutionInfoToBlob indicates an expected call of ChildExecutionInfoToBlob.

func (*MockParserMockRecorder) CrossClusterTaskInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) CrossClusterTaskInfoFromBlob(arg0, arg1 any) *gomock.Call

CrossClusterTaskInfoFromBlob indicates an expected call of CrossClusterTaskInfoFromBlob.

func (*MockParserMockRecorder) CrossClusterTaskInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) CrossClusterTaskInfoToBlob(arg0 any) *gomock.Call

CrossClusterTaskInfoToBlob indicates an expected call of CrossClusterTaskInfoToBlob.

func (*MockParserMockRecorder) DomainInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) DomainInfoFromBlob(arg0, arg1 any) *gomock.Call

DomainInfoFromBlob indicates an expected call of DomainInfoFromBlob.

func (*MockParserMockRecorder) DomainInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) DomainInfoToBlob(arg0 any) *gomock.Call

DomainInfoToBlob indicates an expected call of DomainInfoToBlob.

func (*MockParserMockRecorder) HistoryTreeInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) HistoryTreeInfoFromBlob(arg0, arg1 any) *gomock.Call

HistoryTreeInfoFromBlob indicates an expected call of HistoryTreeInfoFromBlob.

func (*MockParserMockRecorder) HistoryTreeInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) HistoryTreeInfoToBlob(arg0 any) *gomock.Call

HistoryTreeInfoToBlob indicates an expected call of HistoryTreeInfoToBlob.

func (*MockParserMockRecorder) ReplicationTaskInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) ReplicationTaskInfoFromBlob(arg0, arg1 any) *gomock.Call

ReplicationTaskInfoFromBlob indicates an expected call of ReplicationTaskInfoFromBlob.

func (*MockParserMockRecorder) ReplicationTaskInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) ReplicationTaskInfoToBlob(arg0 any) *gomock.Call

ReplicationTaskInfoToBlob indicates an expected call of ReplicationTaskInfoToBlob.

func (*MockParserMockRecorder) RequestCancelInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) RequestCancelInfoFromBlob(arg0, arg1 any) *gomock.Call

RequestCancelInfoFromBlob indicates an expected call of RequestCancelInfoFromBlob.

func (*MockParserMockRecorder) RequestCancelInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) RequestCancelInfoToBlob(arg0 any) *gomock.Call

RequestCancelInfoToBlob indicates an expected call of RequestCancelInfoToBlob.

func (*MockParserMockRecorder) ShardInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) ShardInfoFromBlob(arg0, arg1 any) *gomock.Call

ShardInfoFromBlob indicates an expected call of ShardInfoFromBlob.

func (*MockParserMockRecorder) ShardInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) ShardInfoToBlob(arg0 any) *gomock.Call

ShardInfoToBlob indicates an expected call of ShardInfoToBlob.

func (*MockParserMockRecorder) SignalInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) SignalInfoFromBlob(arg0, arg1 any) *gomock.Call

SignalInfoFromBlob indicates an expected call of SignalInfoFromBlob.

func (*MockParserMockRecorder) SignalInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) SignalInfoToBlob(arg0 any) *gomock.Call

SignalInfoToBlob indicates an expected call of SignalInfoToBlob.

func (*MockParserMockRecorder) TaskInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TaskInfoFromBlob(arg0, arg1 any) *gomock.Call

TaskInfoFromBlob indicates an expected call of TaskInfoFromBlob.

func (*MockParserMockRecorder) TaskInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TaskInfoToBlob(arg0 any) *gomock.Call

TaskInfoToBlob indicates an expected call of TaskInfoToBlob.

func (*MockParserMockRecorder) TaskListInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TaskListInfoFromBlob(arg0, arg1 any) *gomock.Call

TaskListInfoFromBlob indicates an expected call of TaskListInfoFromBlob.

func (*MockParserMockRecorder) TaskListInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TaskListInfoToBlob(arg0 any) *gomock.Call

TaskListInfoToBlob indicates an expected call of TaskListInfoToBlob.

func (*MockParserMockRecorder) TimerInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TimerInfoFromBlob(arg0, arg1 any) *gomock.Call

TimerInfoFromBlob indicates an expected call of TimerInfoFromBlob.

func (*MockParserMockRecorder) TimerInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TimerInfoToBlob(arg0 any) *gomock.Call

TimerInfoToBlob indicates an expected call of TimerInfoToBlob.

func (*MockParserMockRecorder) TimerTaskInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TimerTaskInfoFromBlob(arg0, arg1 any) *gomock.Call

TimerTaskInfoFromBlob indicates an expected call of TimerTaskInfoFromBlob.

func (*MockParserMockRecorder) TimerTaskInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TimerTaskInfoToBlob(arg0 any) *gomock.Call

TimerTaskInfoToBlob indicates an expected call of TimerTaskInfoToBlob.

func (*MockParserMockRecorder) TransferTaskInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TransferTaskInfoFromBlob(arg0, arg1 any) *gomock.Call

TransferTaskInfoFromBlob indicates an expected call of TransferTaskInfoFromBlob.

func (*MockParserMockRecorder) TransferTaskInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) TransferTaskInfoToBlob(arg0 any) *gomock.Call

TransferTaskInfoToBlob indicates an expected call of TransferTaskInfoToBlob.

func (*MockParserMockRecorder) WorkflowExecutionInfoFromBlob added in v1.2.7 

func (mr *MockParserMockRecorder) WorkflowExecutionInfoFromBlob(arg0, arg1 any) *gomock.Call

WorkflowExecutionInfoFromBlob indicates an expected call of WorkflowExecutionInfoFromBlob.

func (*MockParserMockRecorder) WorkflowExecutionInfoToBlob added in v1.2.7 

func (mr *MockParserMockRecorder) WorkflowExecutionInfoToBlob(arg0 any) *gomock.Call

WorkflowExecutionInfoToBlob indicates an expected call of WorkflowExecutionInfoToBlob.

type MockTaskSerializer added in v1.2.18 

type MockTaskSerializer struct {
	// contains filtered or unexported fields
}

MockTaskSerializer is a mock of TaskSerializer interface.

func NewMockTaskSerializer added in v1.2.18 

func NewMockTaskSerializer(ctrl *gomock.Controller) *MockTaskSerializer

NewMockTaskSerializer creates a new mock instance.

func (*MockTaskSerializer) DeserializeTask added in v1.2.18 

func (m *MockTaskSerializer) DeserializeTask(arg0 persistence.HistoryTaskCategory, arg1 *persistence.DataBlob) (persistence.Task, error)

DeserializeTask mocks base method.

func (*MockTaskSerializer) EXPECT added in v1.2.18 

func (m *MockTaskSerializer) EXPECT() *MockTaskSerializerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTaskSerializer) SerializeTask added in v1.2.18 

func (m *MockTaskSerializer) SerializeTask(arg0 persistence.HistoryTaskCategory, arg1 persistence.Task) (persistence.DataBlob, error)

SerializeTask mocks base method.

type MockTaskSerializerMockRecorder added in v1.2.18 

type MockTaskSerializerMockRecorder struct {
	// contains filtered or unexported fields
}

MockTaskSerializerMockRecorder is the mock recorder for MockTaskSerializer.

func (*MockTaskSerializerMockRecorder) DeserializeTask added in v1.2.18 

func (mr *MockTaskSerializerMockRecorder) DeserializeTask(arg0, arg1 any) *gomock.Call

DeserializeTask indicates an expected call of DeserializeTask.

func (*MockTaskSerializerMockRecorder) SerializeTask added in v1.2.18 

func (mr *MockTaskSerializerMockRecorder) SerializeTask(arg0, arg1 any) *gomock.Call

SerializeTask indicates an expected call of SerializeTask.

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.

func (*MockthriftRWType) FromWire added in v1.2.7 

func (m *MockthriftRWType) FromWire(w wire.Value) error

FromWire mocks base method.

func (*MockthriftRWType) ToWire added in v1.2.7 

func (m *MockthriftRWType) ToWire() (wire.Value, error)

ToWire 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 any) *gomock.Call

Decode indicates an expected call of Decode.

func (*MockthriftRWTypeMockRecorder) Encode added in v1.2.7 

func (mr *MockthriftRWTypeMockRecorder) Encode(arg0 any) *gomock.Call

Encode indicates an expected call of Encode.

func (*MockthriftRWTypeMockRecorder) FromWire added in v1.2.7 

func (mr *MockthriftRWTypeMockRecorder) FromWire(w any) *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(dc *persistence.DynamicConfiguration) (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 

type RequestCancelInfo struct {
	Version               int64
	InitiatedEventBatchID int64
	CancelRequestID       string
}

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
	QueueStates                               map[int32]*types.QueueState
}

ShardInfo blob in a serialization agnostic format

func (*ShardInfo) GetClusterReplicationLevel added in v0.18.0 

func (s *ShardInfo) GetClusterReplicationLevel() (o map[string]int64)

GetClusterReplicationLevel internal sql blob getter

func (*ShardInfo) GetClusterTimerAckLevel added in v0.18.0 

func (s *ShardInfo) GetClusterTimerAckLevel() (o map[string]time.Time)

GetClusterTimerAckLevel internal sql blob getter

func (*ShardInfo) GetClusterTransferAckLevel added in v0.18.0 

func (s *ShardInfo) GetClusterTransferAckLevel() (o map[string]int64)

GetClusterTransferAckLevel internal sql blob getter

func (*ShardInfo) GetDomainNotificationVersion added in v0.18.0 

func (s *ShardInfo) GetDomainNotificationVersion() (o int64)

GetDomainNotificationVersion internal sql blob getter

func (*ShardInfo) GetOwner added in v0.18.0 

func (s *ShardInfo) GetOwner() (o string)

GetOwner internal sql blob getter

func (*ShardInfo) GetPendingFailoverMarkers added in v0.18.0 

func (s *ShardInfo) GetPendingFailoverMarkers() (o []byte)

GetPendingFailoverMarkers internal sql blob getter

func (*ShardInfo) GetPendingFailoverMarkersEncoding added in v0.18.0 

func (s *ShardInfo) GetPendingFailoverMarkersEncoding() (o string)

GetPendingFailoverMarkersEncoding internal sql blob getter

func (*ShardInfo) GetQueueStates added in v1.3.1 

func (s *ShardInfo) GetQueueStates() (o map[int32]*types.QueueState)

GetQueueStates internal sql blob getter

func (*ShardInfo) GetReplicationAckLevel added in v0.18.0 

func (s *ShardInfo) GetReplicationAckLevel() (o int64)

GetReplicationAckLevel internal sql blob getter

func (*ShardInfo) GetReplicationDlqAckLevel added in v0.18.0 

func (s *ShardInfo) GetReplicationDlqAckLevel() (o map[string]int64)

GetReplicationDlqAckLevel internal sql blob getter

func (*ShardInfo) GetStolenSinceRenew added in v0.18.0 

func (s *ShardInfo) GetStolenSinceRenew() (o int32)

GetStolenSinceRenew internal sql blob getter

func (*ShardInfo) GetTimerAckLevel added in v0.18.0 

func (s *ShardInfo) GetTimerAckLevel() time.Time

GetTimerAckLevel internal sql blob getter

func (*ShardInfo) GetTimerProcessingQueueStates added in v0.18.0 

func (s *ShardInfo) GetTimerProcessingQueueStates() (o []byte)

GetTimerProcessingQueueStates internal sql blob getter

func (*ShardInfo) GetTimerProcessingQueueStatesEncoding added in v0.18.0 

func (s *ShardInfo) GetTimerProcessingQueueStatesEncoding() (o string)

GetTimerProcessingQueueStatesEncoding internal sql blob getter

func (*ShardInfo) GetTransferAckLevel added in v0.18.0 

func (s *ShardInfo) GetTransferAckLevel() (o int64)

GetTransferAckLevel internal sql blob getter

func (*ShardInfo) GetTransferProcessingQueueStates added in v0.18.0 

func (s *ShardInfo) GetTransferProcessingQueueStates() (o []byte)

GetTransferProcessingQueueStates internal sql blob getter

func (*ShardInfo) GetTransferProcessingQueueStatesEncoding added in v0.18.0 

func (s *ShardInfo) GetTransferProcessingQueueStatesEncoding() (o string)

GetTransferProcessingQueueStatesEncoding internal sql blob getter

func (*ShardInfo) GetUpdatedAt added in v0.18.0 

func (s *ShardInfo) GetUpdatedAt() time.Time

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 

func (t *TaskInfo) GetCreatedTimestamp() time.Time

GetCreatedTimestamp internal sql blob getter

func (*TaskInfo) GetExpiryTimestamp added in v0.18.0 

func (t *TaskInfo) GetExpiryTimestamp() time.Time

GetExpiryTimestamp internal sql blob getter

func (*TaskInfo) GetPartitionConfig added in v1.2.1 

func (t *TaskInfo) GetPartitionConfig() (o map[string]string)

GetPartitionConfig internal sql blob getter

func (*TaskInfo) GetRunID added in v0.18.0 

func (t *TaskInfo) GetRunID() (o []byte)

GetRunID internal sql blob getter

func (*TaskInfo) GetScheduleID added in v0.18.0 

func (t *TaskInfo) GetScheduleID() (o int64)

GetScheduleID internal sql blob getter

func (*TaskInfo) GetWorkflowID added in v0.18.0 

func (t *TaskInfo) GetWorkflowID() (o string)

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
	AdaptivePartitionConfig *TaskListPartitionConfig
}

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 TaskListPartition added in v1.2.17 

type TaskListPartition struct {
	IsolationGroups []string
}

type TaskListPartitionConfig added in v1.2.15 

type TaskListPartitionConfig struct {
	Version            int64
	NumReadPartitions  int32
	NumWritePartitions int32
	ReadPartitions     map[int32]*TaskListPartition
	WritePartitions    map[int32]*TaskListPartition
}

type TaskSerializer added in v1.2.18 

type TaskSerializer interface {
	SerializeTask(persistence.HistoryTaskCategory, persistence.Task) (persistence.DataBlob, error)
	DeserializeTask(persistence.HistoryTaskCategory, *persistence.DataBlob) (persistence.Task, error)
}

func NewTaskSerializer added in v1.2.18 

func NewTaskSerializer(parser Parser) TaskSerializer

type TimerInfo added in v0.18.0 

type TimerInfo struct {
	Version         int64
	StartedID       int64
	ExpiryTimestamp time.Time
	TaskID          int64
}

TimerInfo blob in a serialization agnostic format

func (*TimerInfo) GetExpiryTimestamp added in v0.18.0 

func (t *TimerInfo) GetExpiryTimestamp() (o time.Time)

GetExpiryTimestamp internal sql blob getter

func (*TimerInfo) GetStartedID added in v0.18.0 

func (t *TimerInfo) GetStartedID() (o int64)

GetStartedID internal sql blob getter

func (*TimerInfo) GetTaskID added in v0.18.0 

func (t *TimerInfo) GetTaskID() (o int64)

GetTaskID internal sql blob getter

func (*TimerInfo) GetVersion added in v0.18.0 

func (t *TimerInfo) GetVersion() (o int64)

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 MustParseUUID added in v0.18.0 

func MustParseUUID(s string) UUID

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 UUIDPtr added in v0.18.0 

func UUIDPtr(u UUID) *UUID

UUIDPtr simply returns a pointer for the given value type

func (*UUID) Scan added in v0.18.0 

func (u *UUID) Scan(src interface{}) error

Scan implements sql.Scanner interface to allow this type to be parsed transparently by database drivers

func (UUID) String added in v0.18.0 

func (u UUID) String() string

String returns the 36 byet hexstring representation of this uuid return empty string if this uuid is nil

func (UUID) Value added in v0.18.0 

func (u UUID) Value() (driver.Value, error)

Value implements sql.Valuer so that UUIDs can be written to databases transparently. This method returns a byte slice representation of uuid

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
	TaskListKind                         types.TaskListKind
	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
	CronOverlapPolicy                    types.CronOverlapPolicy
	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
	ActiveClusterSelectionPolicy         []byte
	ActiveClusterSelectionPolicyEncoding string
}

WorkflowExecutionInfo blob in a serialization agnostic format

func FromInternalWorkflowExecutionInfo added in v0.24.0 

func FromInternalWorkflowExecutionInfo(executionInfo *persistence.InternalWorkflowExecutionInfo) *WorkflowExecutionInfo

func (*WorkflowExecutionInfo) GetActiveClusterSelectionPolicyEncoding added in v1.3.2 

func (w *WorkflowExecutionInfo) GetActiveClusterSelectionPolicyEncoding() (o string)

GetActiveClusterSelectionPolicyEncoding internal sql blob getter

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) GetCronOverlapPolicy added in v1.3.2 

func (w *WorkflowExecutionInfo) GetCronOverlapPolicy() (o int32)

GetCronOverlapPolicy 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) GetTaskListKind added in v1.3.3 

func (w *WorkflowExecutionInfo) GetTaskListKind() (o types.TaskListKind)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.