serialization

package
v0.19.0 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2021 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
	DomainName             *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) GetDomainName added in v0.18.0 

func (c *ChildExecutionInfo) GetDomainName() (o string)

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

type DomainInfo struct {
	Name                        *string
	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
	PreviousFailoverVersion     *int64
	LastUpdatedTimestamp        *time.Time
}

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

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) 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
	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
	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) 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
	CompletionEvent                    []byte
	CompletionEventEncoding            *string
	TaskList                           *string
	WorkflowTypeName                   *string
	WorkflowTimeout                    *time.Duration
	DecisionTaskTimeout                *time.Duration
	ExecutionContext                   []byte
	State                              *int32
	CloseStatus                        *int32
	StartVersion                       *int64
	LastWriteEventID                   *int64
	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
}

WorkflowExecutionInfo blob in a serialization agnostic format

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