serialization

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

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

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

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
}

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) GetCrossClusterProcessingQueueStates added in v0.22.0 

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

GetCrossClusterProcessingQueueStates internal sql blob getter

func (*ShardInfo) GetCrossClusterProcessingQueueStatesEncoding added in v0.22.0 

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

GetCrossClusterProcessingQueueStatesEncoding 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) 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
}

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 

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

func MustParsePtrUUID(s *string) UUID

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 

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

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) 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

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.