types

package
v1.2.9 Latest Latest
Warning

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

Go to latest
Published: Apr 12, 2024 License: MIT Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SerializeRequest added in v1.2.1

func SerializeRequest(request interface{}) (string, error)

SerializeRequest Serialize an arbitrary request for logging pass in a pointer as a parameter to save space

Types

type AccessDeniedError

type AccessDeniedError struct {
	Message string `json:"message,required"`
}

AccessDeniedError is an internal type (TBD...)

func (AccessDeniedError) Error

func (err AccessDeniedError) Error() string

type ActivityLocalDispatchInfo added in v0.17.0

type ActivityLocalDispatchInfo struct {
	ActivityID                      string `json:"activityId,omitempty"`
	ScheduledTimestamp              *int64 `json:"scheduledTimestamp,omitempty"`
	StartedTimestamp                *int64 `json:"startedTimestamp,omitempty"`
	ScheduledTimestampOfThisAttempt *int64 `json:"scheduledTimestampOfThisAttempt,omitempty"`
	TaskToken                       []byte `json:"taskToken,omitempty"`
}

ActivityLocalDispatchInfo is an internal type (TBD...)

func (*ActivityLocalDispatchInfo) GetScheduledTimestamp added in v0.17.0

func (v *ActivityLocalDispatchInfo) GetScheduledTimestamp() (o int64)

GetScheduledTimestamp is an internal getter (TBD...)

type ActivityTaskCancelRequestedEventAttributes

type ActivityTaskCancelRequestedEventAttributes struct {
	ActivityID                   string `json:"activityId,omitempty"`
	DecisionTaskCompletedEventID int64  `json:"decisionTaskCompletedEventId,omitempty"`
}

ActivityTaskCancelRequestedEventAttributes is an internal type (TBD...)

func (*ActivityTaskCancelRequestedEventAttributes) GetActivityID added in v0.17.0

func (v *ActivityTaskCancelRequestedEventAttributes) GetActivityID() (o string)

GetActivityID is an internal getter (TBD...)

type ActivityTaskCanceledEventAttributes

type ActivityTaskCanceledEventAttributes struct {
	Details                      []byte `json:"details,omitempty"`
	LatestCancelRequestedEventID int64  `json:"latestCancelRequestedEventId,omitempty"`
	ScheduledEventID             int64  `json:"scheduledEventId,omitempty"`
	StartedEventID               int64  `json:"startedEventId,omitempty"`
	Identity                     string `json:"identity,omitempty"`
}

ActivityTaskCanceledEventAttributes is an internal type (TBD...)

func (*ActivityTaskCanceledEventAttributes) GetScheduledEventID added in v0.17.0

func (v *ActivityTaskCanceledEventAttributes) GetScheduledEventID() (o int64)

GetScheduledEventID is an internal getter (TBD...)

type ActivityTaskCompletedEventAttributes

type ActivityTaskCompletedEventAttributes struct {
	Result           []byte `json:"result,omitempty"`
	ScheduledEventID int64  `json:"scheduledEventId,omitempty"`
	StartedEventID   int64  `json:"startedEventId,omitempty"`
	Identity         string `json:"identity,omitempty"`
}

ActivityTaskCompletedEventAttributes is an internal type (TBD...)

func (*ActivityTaskCompletedEventAttributes) GetScheduledEventID added in v0.17.0

func (v *ActivityTaskCompletedEventAttributes) GetScheduledEventID() (o int64)

GetScheduledEventID is an internal getter (TBD...)

func (*ActivityTaskCompletedEventAttributes) GetStartedEventID added in v0.17.0

func (v *ActivityTaskCompletedEventAttributes) GetStartedEventID() (o int64)

GetStartedEventID is an internal getter (TBD...)

type ActivityTaskDispatchInfo added in v0.24.0

type ActivityTaskDispatchInfo struct {
	ScheduledEvent                  *HistoryEvent `json:"scheduledEvent,omitempty"`
	StartedTimestamp                *int64        `json:"startedTimestamp,omitempty"`
	Attempt                         *int64        `json:"attempt,omitempty"`
	ScheduledTimestampOfThisAttempt *int64        `json:"scheduledTimestampOfThisAttempt,omitempty"`
	HeartbeatDetails                []byte        `json:"heartbeatDetails,omitempty"`
	WorkflowType                    *WorkflowType `json:"workflowType,omitempty"`
	WorkflowDomain                  string        `json:"workflowDomain,omitempty"`
}

ActivityTaskDispatchInfo is an internal type (TBD...)

type ActivityTaskFailedEventAttributes

type ActivityTaskFailedEventAttributes struct {
	Reason           *string `json:"reason,omitempty"`
	Details          []byte  `json:"details,omitempty"`
	ScheduledEventID int64   `json:"scheduledEventId,omitempty"`
	StartedEventID   int64   `json:"startedEventId,omitempty"`
	Identity         string  `json:"identity,omitempty"`
}

ActivityTaskFailedEventAttributes is an internal type (TBD...)

func (*ActivityTaskFailedEventAttributes) GetScheduledEventID added in v0.17.0

func (v *ActivityTaskFailedEventAttributes) GetScheduledEventID() (o int64)

GetScheduledEventID is an internal getter (TBD...)

func (*ActivityTaskFailedEventAttributes) GetStartedEventID added in v0.17.0

func (v *ActivityTaskFailedEventAttributes) GetStartedEventID() (o int64)

GetStartedEventID is an internal getter (TBD...)

type ActivityTaskScheduledEventAttributes

type ActivityTaskScheduledEventAttributes struct {
	ActivityID                    string        `json:"activityId,omitempty"`
	ActivityType                  *ActivityType `json:"activityType,omitempty"`
	Domain                        *string       `json:"domain,omitempty"`
	TaskList                      *TaskList     `json:"taskList,omitempty"`
	Input                         []byte        `json:"input,omitempty"`
	ScheduleToCloseTimeoutSeconds *int32        `json:"scheduleToCloseTimeoutSeconds,omitempty"`
	ScheduleToStartTimeoutSeconds *int32        `json:"scheduleToStartTimeoutSeconds,omitempty"`
	StartToCloseTimeoutSeconds    *int32        `json:"startToCloseTimeoutSeconds,omitempty"`
	HeartbeatTimeoutSeconds       *int32        `json:"heartbeatTimeoutSeconds,omitempty"`
	DecisionTaskCompletedEventID  int64         `json:"decisionTaskCompletedEventId,omitempty"`
	RetryPolicy                   *RetryPolicy  `json:"retryPolicy,omitempty"`
	Header                        *Header       `json:"header,omitempty"`
}

ActivityTaskScheduledEventAttributes is an internal type (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetActivityID added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetActivityID() (o string)

GetActivityID is an internal getter (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetActivityType added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetActivityType() (o *ActivityType)

GetActivityType is an internal getter (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetDomain added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetDomain() (o string)

GetDomain is an internal getter (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetHeartbeatTimeoutSeconds added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetHeartbeatTimeoutSeconds() (o int32)

GetHeartbeatTimeoutSeconds is an internal getter (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeoutSeconds added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeoutSeconds() (o int32)

GetScheduleToCloseTimeoutSeconds is an internal getter (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeoutSeconds added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeoutSeconds() (o int32)

GetScheduleToStartTimeoutSeconds is an internal getter (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetStartToCloseTimeoutSeconds added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetStartToCloseTimeoutSeconds() (o int32)

GetStartToCloseTimeoutSeconds is an internal getter (TBD...)

func (*ActivityTaskScheduledEventAttributes) GetTaskList added in v0.17.0

func (v *ActivityTaskScheduledEventAttributes) GetTaskList() (o *TaskList)

GetTaskList is an internal getter (TBD...)

type ActivityTaskStartedEventAttributes

type ActivityTaskStartedEventAttributes struct {
	ScheduledEventID   int64   `json:"scheduledEventId,omitempty"`
	Identity           string  `json:"identity,omitempty"`
	RequestID          string  `json:"requestId,omitempty"`
	Attempt            int32   `json:"attempt,omitempty"`
	LastFailureReason  *string `json:"lastFailureReason,omitempty"`
	LastFailureDetails []byte  `json:"lastFailureDetails,omitempty"`
}

ActivityTaskStartedEventAttributes is an internal type (TBD...)

func (*ActivityTaskStartedEventAttributes) GetRequestID added in v0.17.0

func (v *ActivityTaskStartedEventAttributes) GetRequestID() (o string)

GetRequestID is an internal getter (TBD...)

func (*ActivityTaskStartedEventAttributes) GetScheduledEventID added in v0.17.0

func (v *ActivityTaskStartedEventAttributes) GetScheduledEventID() (o int64)

GetScheduledEventID is an internal getter (TBD...)

type ActivityTaskTimedOutEventAttributes

type ActivityTaskTimedOutEventAttributes struct {
	Details            []byte       `json:"details,omitempty"`
	ScheduledEventID   int64        `json:"scheduledEventId,omitempty"`
	StartedEventID     int64        `json:"startedEventId,omitempty"`
	TimeoutType        *TimeoutType `json:"timeoutType,omitempty"`
	LastFailureReason  *string      `json:"lastFailureReason,omitempty"`
	LastFailureDetails []byte       `json:"lastFailureDetails,omitempty"`
}

ActivityTaskTimedOutEventAttributes is an internal type (TBD...)

func (*ActivityTaskTimedOutEventAttributes) GetScheduledEventID added in v0.17.0

func (v *ActivityTaskTimedOutEventAttributes) GetScheduledEventID() (o int64)

GetScheduledEventID is an internal getter (TBD...)

func (*ActivityTaskTimedOutEventAttributes) GetTimeoutType added in v0.17.0

func (v *ActivityTaskTimedOutEventAttributes) GetTimeoutType() (o TimeoutType)

GetTimeoutType is an internal getter (TBD...)

type ActivityType

type ActivityType struct {
	Name string `json:"name,omitempty"`
}

ActivityType is an internal type (TBD...)

func (*ActivityType) GetName added in v0.17.0

func (v *ActivityType) GetName() (o string)

GetName is an internal getter (TBD...)

type AddActivityTaskRequest added in v0.17.0

type AddActivityTaskRequest struct {
	DomainUUID                    string                    `json:"domainUUID,omitempty"`
	Execution                     *WorkflowExecution        `json:"execution,omitempty"`
	SourceDomainUUID              string                    `json:"sourceDomainUUID,omitempty"`
	TaskList                      *TaskList                 `json:"taskList,omitempty"`
	ScheduleID                    int64                     `json:"scheduleId,omitempty"`
	ScheduleToStartTimeoutSeconds *int32                    `json:"scheduleToStartTimeoutSeconds,omitempty"`
	Source                        *TaskSource               `json:"source,omitempty"`
	ForwardedFrom                 string                    `json:"forwardedFrom,omitempty"`
	ActivityTaskDispatchInfo      *ActivityTaskDispatchInfo `json:"activityTaskDispatchInfo,omitempty"`
	PartitionConfig               map[string]string
}

AddActivityTaskRequest is an internal type (TBD...)

func (*AddActivityTaskRequest) GetDomainUUID added in v0.17.0

func (v *AddActivityTaskRequest) GetDomainUUID() (o string)

GetDomainUUID is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetExecution added in v0.17.0

func (v *AddActivityTaskRequest) GetExecution() (o *WorkflowExecution)

GetExecution is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetForwardedFrom added in v0.17.0

func (v *AddActivityTaskRequest) GetForwardedFrom() (o string)

GetForwardedFrom is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetPartitionConfig added in v1.2.1

func (v *AddActivityTaskRequest) GetPartitionConfig() (o map[string]string)

GetPartitionConfig is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetScheduleID added in v0.17.0

func (v *AddActivityTaskRequest) GetScheduleID() (o int64)

GetScheduleID is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetScheduleToStartTimeoutSeconds added in v0.17.0

func (v *AddActivityTaskRequest) GetScheduleToStartTimeoutSeconds() (o int32)

GetScheduleToStartTimeoutSeconds is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetSource added in v0.17.0

func (v *AddActivityTaskRequest) GetSource() (o TaskSource)

GetSource is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetSourceDomainUUID added in v0.17.0

func (v *AddActivityTaskRequest) GetSourceDomainUUID() (o string)

GetSourceDomainUUID is an internal getter (TBD...)

func (*AddActivityTaskRequest) GetTaskList added in v0.17.0

func (v *AddActivityTaskRequest) GetTaskList() (o *TaskList)

GetTaskList is an internal getter (TBD...)

type AddDecisionTaskRequest added in v0.17.0

type AddDecisionTaskRequest struct {
	DomainUUID                    string             `json:"domainUUID,omitempty"`
	Execution                     *WorkflowExecution `json:"execution,omitempty"`
	TaskList                      *TaskList          `json:"taskList,omitempty"`
	ScheduleID                    int64              `json:"scheduleId,omitempty"`
	ScheduleToStartTimeoutSeconds *int32             `json:"scheduleToStartTimeoutSeconds,omitempty"`
	Source                        *TaskSource        `json:"source,omitempty"`
	ForwardedFrom                 string             `json:"forwardedFrom,omitempty"`
	PartitionConfig               map[string]string
}

AddDecisionTaskRequest is an internal type (TBD...)

func (*AddDecisionTaskRequest) GetDomainUUID added in v0.17.0

func (v *AddDecisionTaskRequest) GetDomainUUID() (o string)

GetDomainUUID is an internal getter (TBD...)

func (*AddDecisionTaskRequest) GetExecution added in v0.17.0

func (v *AddDecisionTaskRequest) GetExecution() (o *WorkflowExecution)

GetExecution is an internal getter (TBD...)

func (*AddDecisionTaskRequest) GetForwardedFrom added in v0.17.0

func (v *AddDecisionTaskRequest) GetForwardedFrom() (o string)

GetForwardedFrom is an internal getter (TBD...)

func (*AddDecisionTaskRequest) GetPartitionConfig added in v1.2.1

func (v *AddDecisionTaskRequest) GetPartitionConfig() (o map[string]string)

GetPartitionConfig is an internal getter (TBD...)

func (*AddDecisionTaskRequest) GetScheduleID added in v0.17.0

func (v *AddDecisionTaskRequest) GetScheduleID() (o int64)

GetScheduleID is an internal getter (TBD...)

func (*AddDecisionTaskRequest) GetScheduleToStartTimeoutSeconds added in v0.17.0

func (v *AddDecisionTaskRequest) GetScheduleToStartTimeoutSeconds() (o int32)

GetScheduleToStartTimeoutSeconds is an internal getter (TBD...)

func (*AddDecisionTaskRequest) GetSource added in v0.17.0

func (v *AddDecisionTaskRequest) GetSource() (o TaskSource)

GetSource is an internal getter (TBD...)

func (*AddDecisionTaskRequest) GetTaskList added in v0.17.0

func (v *AddDecisionTaskRequest) GetTaskList() (o *TaskList)

GetTaskList is an internal getter (TBD...)

type AddSearchAttributeRequest added in v0.17.0

type AddSearchAttributeRequest struct {
	SearchAttribute map[string]IndexedValueType `json:"searchAttribute,omitempty"`
	SecurityToken   string                      `json:"securityToken,omitempty"`
}

AddSearchAttributeRequest is an internal type (TBD...)

func (*AddSearchAttributeRequest) GetSearchAttribute added in v0.17.0

func (v *AddSearchAttributeRequest) GetSearchAttribute() (o map[string]IndexedValueType)

GetSearchAttribute is an internal getter (TBD...)

func (*AddSearchAttributeRequest) SerializeForLogging added in v1.2.1

func (v *AddSearchAttributeRequest) SerializeForLogging() (string, error)

type AdminDeleteWorkflowRequest added in v0.24.0

type AdminDeleteWorkflowRequest struct {
	Domain     string             `json:"domain,omitempty"`
	Execution  *WorkflowExecution `json:"execution,omitempty"`
	SkipErrors bool               `json:"skipErrors,omitempty"`
}

AdminDeleteWorkflowRequest is an internal type (TBD...)

func (*AdminDeleteWorkflowRequest) GetDomain added in v0.24.0

func (v *AdminDeleteWorkflowRequest) GetDomain() (o string)

func (*AdminDeleteWorkflowRequest) GetExecution added in v0.24.0

func (v *AdminDeleteWorkflowRequest) GetExecution() (o *WorkflowExecution)

GetExecution is an internal getter (TBD...)

func (*AdminDeleteWorkflowRequest) GetSkipErrors added in v0.24.0

func (v *AdminDeleteWorkflowRequest) GetSkipErrors() (o bool)

func (*AdminDeleteWorkflowRequest) SerializeForLogging added in v1.2.1

func (v *AdminDeleteWorkflowRequest) SerializeForLogging() (string, error)

type AdminDeleteWorkflowResponse added in v0.24.0

type AdminDeleteWorkflowResponse struct {
	HistoryDeleted    bool `json:"historyDeleted,omitempty"`
	ExecutionsDeleted bool `json:"executionsDeleted,omitempty"`
	VisibilityDeleted bool `json:"visibilityDeleted,omitempty"`
}

type AdminDescribeWorkflowExecutionRequest added in v0.17.0

type AdminDescribeWorkflowExecutionRequest struct {
	Domain    string             `json:"domain,omitempty"`
	Execution *WorkflowExecution `json:"execution,omitempty"`
}

AdminDescribeWorkflowExecutionRequest is an internal type (TBD...)

func (*AdminDescribeWorkflowExecutionRequest) GetDomain added in v0.17.0

func (v *AdminDescribeWorkflowExecutionRequest) GetDomain() (o string)

GetDomain is an internal getter (TBD...)

func (*AdminDescribeWorkflowExecutionRequest) SerializeForLogging added in v1.2.1

func (v *AdminDescribeWorkflowExecutionRequest) SerializeForLogging() (string, error)

type AdminDescribeWorkflowExecutionResponse added in v0.17.0

type AdminDescribeWorkflowExecutionResponse struct {
	ShardID                string `json:"shardId,omitempty"`
	HistoryAddr            string `json:"historyAddr,omitempty"`
	MutableStateInCache    string `json:"mutableStateInCache,omitempty"`
	MutableStateInDatabase string `json:"mutableStateInDatabase,omitempty"`
}

AdminDescribeWorkflowExecutionResponse is an internal type (TBD...)

func (*AdminDescribeWorkflowExecutionResponse) GetMutableStateInDatabase added in v0.17.0

func (v *AdminDescribeWorkflowExecutionResponse) GetMutableStateInDatabase() (o string)

GetMutableStateInDatabase is an internal getter (TBD...)

func (*AdminDescribeWorkflowExecutionResponse) GetShardID added in v0.17.0

func (v *AdminDescribeWorkflowExecutionResponse) GetShardID() (o string)

GetShardID is an internal getter (TBD...)

type AdminMaintainWorkflowRequest added in v0.24.0

type AdminMaintainWorkflowRequest = AdminDeleteWorkflowRequest

type AdminMaintainWorkflowResponse added in v0.24.0

type AdminMaintainWorkflowResponse = AdminDeleteWorkflowResponse

type ApplyParentClosePolicyAttributes added in v0.24.0

type ApplyParentClosePolicyAttributes struct {
	ChildDomainID     string             `json:"ChildDomainID,omitempty"`
	ChildWorkflowID   string             `json:"ChildWorkflowID,omitempty"`
	ChildRunID        string             `json:"ChildRunID,omitempty"`
	ParentClosePolicy *ParentClosePolicy `json:"parentClosePolicy,omitempty"`
}

func (*ApplyParentClosePolicyAttributes) GetParentClosePolicy added in v0.24.0

func (v *ApplyParentClosePolicyAttributes) GetParentClosePolicy() (o *ParentClosePolicy)

GetParentClosePolicy is an internal getter (TBD...)

type ApplyParentClosePolicyRequest added in v0.24.0

type ApplyParentClosePolicyRequest struct {
	Child  *ApplyParentClosePolicyAttributes `json:"child,omitempty"`
	Status *ApplyParentClosePolicyStatus     `json:"status,omitempty"`
}

type ApplyParentClosePolicyResult added in v0.24.0

type ApplyParentClosePolicyResult struct {
	Child       *ApplyParentClosePolicyAttributes `json:"child,omitempty"`
	FailedCause *CrossClusterTaskFailedCause      `json:"failedCause,omitempty"`
}

type ApplyParentClosePolicyStatus added in v0.24.0

type ApplyParentClosePolicyStatus struct {
	Completed   bool                         `json:"completed,omitempty"`
	FailedCause *CrossClusterTaskFailedCause `json:"failedCause,omitempty"`
}

type ArchivalStatus

type ArchivalStatus int32

ArchivalStatus is an internal type (TBD...)

const (
	// ArchivalStatusDisabled is an option for ArchivalStatus
	ArchivalStatusDisabled ArchivalStatus = iota
	// ArchivalStatusEnabled is an option for ArchivalStatus
	ArchivalStatusEnabled
)

func (ArchivalStatus) MarshalText added in v0.18.0

func (e ArchivalStatus) MarshalText() ([]byte, error)

MarshalText encodes ArchivalStatus to text.

func (ArchivalStatus) Ptr added in v0.17.0

func (e ArchivalStatus) Ptr() *ArchivalStatus

Ptr is a helper function for getting pointer value

func (ArchivalStatus) String added in v0.18.0

func (e ArchivalStatus) String() string

String returns a readable string representation of ArchivalStatus.

func (*ArchivalStatus) UnmarshalText added in v0.18.0

func (e *ArchivalStatus) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type AsyncWorkflowConfiguration added in v1.2.7

type AsyncWorkflowConfiguration struct {
	Enabled             bool
	PredefinedQueueName string
	QueueType           string
	QueueConfig         *DataBlob
}

func (AsyncWorkflowConfiguration) DeepCopy added in v1.2.8

type BadBinaries

type BadBinaries struct {
	Binaries map[string]*BadBinaryInfo `json:"binaries,omitempty"`
}

BadBinaries is an internal type (TBD...)

type BadBinaryInfo

type BadBinaryInfo struct {
	Reason          string `json:"reason,omitempty"`
	Operator        string `json:"operator,omitempty"`
	CreatedTimeNano *int64 `json:"createdTimeNano,omitempty"`
}

BadBinaryInfo is an internal type (TBD...)

func (*BadBinaryInfo) GetCreatedTimeNano added in v0.17.0

func (v *BadBinaryInfo) GetCreatedTimeNano() (o int64)

GetCreatedTimeNano is an internal getter (TBD...)

func (*BadBinaryInfo) GetOperator added in v0.17.0

func (v *BadBinaryInfo) GetOperator() (o string)

GetOperator is an internal getter (TBD...)

func (*BadBinaryInfo) GetReason added in v0.17.0

func (v *BadBinaryInfo) GetReason() (o string)

GetReason is an internal getter (TBD...)

type BadRequestError

type BadRequestError struct {
	Message string `json:"message,required"`
}

BadRequestError is an internal type (TBD...)

func (BadRequestError) Error

func (err BadRequestError) Error() string

type CancelExternalWorkflowExecutionFailedCause

type CancelExternalWorkflowExecutionFailedCause int32

CancelExternalWorkflowExecutionFailedCause is an internal type (TBD...)

const (
	// CancelExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution is an option for CancelExternalWorkflowExecutionFailedCause
	CancelExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution CancelExternalWorkflowExecutionFailedCause = iota
)

func (CancelExternalWorkflowExecutionFailedCause) MarshalText added in v0.18.0

MarshalText encodes CancelExternalWorkflowExecutionFailedCause to text.

func (CancelExternalWorkflowExecutionFailedCause) Ptr added in v0.17.0

Ptr is a helper function for getting pointer value

func (CancelExternalWorkflowExecutionFailedCause) String added in v0.18.0

String returns a readable string representation of CancelExternalWorkflowExecutionFailedCause.

func (*CancelExternalWorkflowExecutionFailedCause) UnmarshalText added in v0.18.0

func (e *CancelExternalWorkflowExecutionFailedCause) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type CancelOutstandingPollRequest added in v0.17.0

type CancelOutstandingPollRequest struct {
	DomainUUID   string    `json:"domainUUID,omitempty"`
	TaskListType *int32    `json:"taskListType,omitempty"`
	TaskList     *TaskList `json:"taskList,omitempty"`
	PollerID     string    `json:"pollerID,omitempty"`
}

CancelOutstandingPollRequest is an internal type (TBD...)

func (*CancelOutstandingPollRequest) GetDomainUUID added in v0.17.0

func (v *CancelOutstandingPollRequest) GetDomainUUID() (o string)

GetDomainUUID is an internal getter (TBD...)

func (*CancelOutstandingPollRequest) GetPollerID added in v0.17.0

func (v *CancelOutstandingPollRequest) GetPollerID() (o string)

GetPollerID is an internal getter (TBD...)

func (*CancelOutstandingPollRequest) GetTaskList added in v0.17.0

func (v *CancelOutstandingPollRequest) GetTaskList() (o *TaskList)

GetTaskList is an internal getter (TBD...)

func (*CancelOutstandingPollRequest) GetTaskListType added in v0.17.0

func (v *CancelOutstandingPollRequest) GetTaskListType() (o int32)

GetTaskListType is an internal getter (TBD...)

type CancelTimerDecisionAttributes

type CancelTimerDecisionAttributes struct {
	TimerID string `json:"timerId,omitempty"`
}

CancelTimerDecisionAttributes is an internal type (TBD...)

func (*CancelTimerDecisionAttributes) GetTimerID added in v0.17.0

func (v *CancelTimerDecisionAttributes) GetTimerID() (o string)

GetTimerID is an internal getter (TBD...)

type CancelTimerFailedEventAttributes

type CancelTimerFailedEventAttributes struct {
	TimerID                      string `json:"timerId,omitempty"`
	Cause                        string `json:"cause,omitempty"`
	DecisionTaskCompletedEventID int64  `json:"decisionTaskCompletedEventId,omitempty"`
	Identity                     string `json:"identity,omitempty"`
}

CancelTimerFailedEventAttributes is an internal type (TBD...)

type CancelWorkflowExecutionDecisionAttributes

type CancelWorkflowExecutionDecisionAttributes struct {
	Details []byte `json:"details,omitempty"`
}

CancelWorkflowExecutionDecisionAttributes is an internal type (TBD...)

type CancellationAlreadyRequestedError

type CancellationAlreadyRequestedError struct {
	Message string `json:"message,required"`
}

CancellationAlreadyRequestedError is an internal type (TBD...)

func (CancellationAlreadyRequestedError) Error

type ChildWorkflowExecutionCanceledEventAttributes

type ChildWorkflowExecutionCanceledEventAttributes struct {
	Details           []byte             `json:"details,omitempty"`
	Domain            string             `json:"domain,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
	WorkflowType      *WorkflowType      `json:"workflowType,omitempty"`
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	StartedEventID    int64              `json:"startedEventId,omitempty"`
}

ChildWorkflowExecutionCanceledEventAttributes is an internal type (TBD...)

func (*ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventID added in v0.17.0

func (v *ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventID() (o int64)

GetInitiatedEventID is an internal getter (TBD...)

type ChildWorkflowExecutionCompletedEventAttributes

type ChildWorkflowExecutionCompletedEventAttributes struct {
	Result            []byte             `json:"result,omitempty"`
	Domain            string             `json:"domain,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
	WorkflowType      *WorkflowType      `json:"workflowType,omitempty"`
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	StartedEventID    int64              `json:"startedEventId,omitempty"`
}

ChildWorkflowExecutionCompletedEventAttributes is an internal type (TBD...)

func (*ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventID added in v0.17.0

func (v *ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventID() (o int64)

GetInitiatedEventID is an internal getter (TBD...)

type ChildWorkflowExecutionFailedCause

type ChildWorkflowExecutionFailedCause int32

ChildWorkflowExecutionFailedCause is an internal type (TBD...)

const (
	// ChildWorkflowExecutionFailedCauseWorkflowAlreadyRunning is an option for ChildWorkflowExecutionFailedCause
	ChildWorkflowExecutionFailedCauseWorkflowAlreadyRunning ChildWorkflowExecutionFailedCause = iota
)

func (ChildWorkflowExecutionFailedCause) MarshalText added in v0.18.0

func (e ChildWorkflowExecutionFailedCause) MarshalText() ([]byte, error)

MarshalText encodes ChildWorkflowExecutionFailedCause to text.

func (ChildWorkflowExecutionFailedCause) Ptr added in v0.17.0

Ptr is a helper function for getting pointer value

func (ChildWorkflowExecutionFailedCause) String added in v0.18.0

String returns a readable string representation of ChildWorkflowExecutionFailedCause.

func (*ChildWorkflowExecutionFailedCause) UnmarshalText added in v0.18.0

func (e *ChildWorkflowExecutionFailedCause) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type ChildWorkflowExecutionFailedEventAttributes

type ChildWorkflowExecutionFailedEventAttributes struct {
	Reason            *string            `json:"reason,omitempty"`
	Details           []byte             `json:"details,omitempty"`
	Domain            string             `json:"domain,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
	WorkflowType      *WorkflowType      `json:"workflowType,omitempty"`
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	StartedEventID    int64              `json:"startedEventId,omitempty"`
}

ChildWorkflowExecutionFailedEventAttributes is an internal type (TBD...)

func (*ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventID added in v0.17.0

func (v *ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64)

GetInitiatedEventID is an internal getter (TBD...)

type ChildWorkflowExecutionStartedEventAttributes

type ChildWorkflowExecutionStartedEventAttributes struct {
	Domain            string             `json:"domain,omitempty"`
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
	WorkflowType      *WorkflowType      `json:"workflowType,omitempty"`
	Header            *Header            `json:"header,omitempty"`
}

ChildWorkflowExecutionStartedEventAttributes is an internal type (TBD...)

func (*ChildWorkflowExecutionStartedEventAttributes) GetDomain added in v0.17.0

GetDomain is an internal getter (TBD...)

func (*ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventID added in v0.17.0

func (v *ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventID() (o int64)

GetInitiatedEventID is an internal getter (TBD...)

func (*ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution added in v0.17.0

func (v *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

GetWorkflowExecution is an internal getter (TBD...)

type ChildWorkflowExecutionTerminatedEventAttributes

type ChildWorkflowExecutionTerminatedEventAttributes struct {
	Domain            string             `json:"domain,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
	WorkflowType      *WorkflowType      `json:"workflowType,omitempty"`
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	StartedEventID    int64              `json:"startedEventId,omitempty"`
}

ChildWorkflowExecutionTerminatedEventAttributes is an internal type (TBD...)

func (*ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventID added in v0.17.0

func (v *ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventID() (o int64)

GetInitiatedEventID is an internal getter (TBD...)

type ChildWorkflowExecutionTimedOutEventAttributes

type ChildWorkflowExecutionTimedOutEventAttributes struct {
	TimeoutType       *TimeoutType       `json:"timeoutType,omitempty"`
	Domain            string             `json:"domain,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
	WorkflowType      *WorkflowType      `json:"workflowType,omitempty"`
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	StartedEventID    int64              `json:"startedEventId,omitempty"`
}

ChildWorkflowExecutionTimedOutEventAttributes is an internal type (TBD...)

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventID added in v0.17.0

func (v *ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventID() (o int64)

GetInitiatedEventID is an internal getter (TBD...)

type ClientVersionNotSupportedError

type ClientVersionNotSupportedError struct {
	FeatureVersion    string `json:"featureVersion,required"`
	ClientImpl        string `json:"clientImpl,required"`
	SupportedVersions string `json:"supportedVersions,required"`
}

ClientVersionNotSupportedError is an internal type (TBD...)

func (ClientVersionNotSupportedError) Error

func (ClientVersionNotSupportedError) MarshalLogObject added in v0.25.0

func (err ClientVersionNotSupportedError) MarshalLogObject(enc zapcore.ObjectEncoder) error

type CloseShardRequest

type CloseShardRequest struct {
	ShardID int32 `json:"shardID,omitempty"`
}

CloseShardRequest is an internal type (TBD...)

func (*CloseShardRequest) GetShardID added in v0.17.0

func (v *CloseShardRequest) GetShardID() (o int32)

GetShardID is an internal getter (TBD...)

func (*CloseShardRequest) SerializeForLogging added in v1.2.1

func (v *CloseShardRequest) SerializeForLogging() (string, error)

type ClusterInfo

type ClusterInfo struct {
	SupportedClientVersions *SupportedClientVersions `json:"supportedClientVersions,omitempty"`
}

ClusterInfo is an internal type (TBD...)

type ClusterReplicationConfiguration

type ClusterReplicationConfiguration struct {
	ClusterName string `json:"clusterName,omitempty"`
}

ClusterReplicationConfiguration is an internal type (TBD...)

func (*ClusterReplicationConfiguration) GetClusterName added in v0.17.0

func (v *ClusterReplicationConfiguration) GetClusterName() (o string)

GetClusterName is an internal getter (TBD...)

type CompleteWorkflowExecutionDecisionAttributes

type CompleteWorkflowExecutionDecisionAttributes struct {
	Result []byte `json:"result,omitempty"`
}

CompleteWorkflowExecutionDecisionAttributes is an internal type (TBD...)

type ContinueAsNewInitiator

type ContinueAsNewInitiator int32

ContinueAsNewInitiator is an internal type (TBD...)

const (
	// ContinueAsNewInitiatorDecider is an option for ContinueAsNewInitiator
	ContinueAsNewInitiatorDecider ContinueAsNewInitiator = iota
	// ContinueAsNewInitiatorRetryPolicy is an option for ContinueAsNewInitiator
	ContinueAsNewInitiatorRetryPolicy
	// ContinueAsNewInitiatorCronSchedule is an option for ContinueAsNewInitiator
	ContinueAsNewInitiatorCronSchedule
)

func (ContinueAsNewInitiator) MarshalText added in v0.18.0

func (e ContinueAsNewInitiator) MarshalText() ([]byte, error)

MarshalText encodes ContinueAsNewInitiator to text.

func (ContinueAsNewInitiator) Ptr added in v0.17.0

Ptr is a helper function for getting pointer value

func (ContinueAsNewInitiator) String added in v0.18.0

func (e ContinueAsNewInitiator) String() string

String returns a readable string representation of ContinueAsNewInitiator.

func (*ContinueAsNewInitiator) UnmarshalText added in v0.18.0

func (e *ContinueAsNewInitiator) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type ContinueAsNewWorkflowExecutionDecisionAttributes

type ContinueAsNewWorkflowExecutionDecisionAttributes struct {
	WorkflowType                        *WorkflowType           `json:"workflowType,omitempty"`
	TaskList                            *TaskList               `json:"taskList,omitempty"`
	Input                               []byte                  `json:"input,omitempty"`
	ExecutionStartToCloseTimeoutSeconds *int32                  `json:"executionStartToCloseTimeoutSeconds,omitempty"`
	TaskStartToCloseTimeoutSeconds      *int32                  `json:"taskStartToCloseTimeoutSeconds,omitempty"`
	BackoffStartIntervalInSeconds       *int32                  `json:"backoffStartIntervalInSeconds,omitempty"`
	RetryPolicy                         *RetryPolicy            `json:"retryPolicy,omitempty"`
	Initiator                           *ContinueAsNewInitiator `json:"initiator,omitempty"`
	FailureReason                       *string                 `json:"failureReason,omitempty"`
	FailureDetails                      []byte                  `json:"failureDetails,omitempty"`
	LastCompletionResult                []byte                  `json:"lastCompletionResult,omitempty"`
	CronSchedule                        string                  `json:"cronSchedule,omitempty"`
	Header                              *Header                 `json:"header,omitempty"`
	Memo                                *Memo                   `json:"memo,omitempty"`
	SearchAttributes                    *SearchAttributes       `json:"searchAttributes,omitempty"`
	JitterStartSeconds                  *int32                  `json:"jitterStartSeconds,omitempty"`
}

ContinueAsNewWorkflowExecutionDecisionAttributes is an internal type (TBD...)

func (*ContinueAsNewWorkflowExecutionDecisionAttributes) GetBackoffStartIntervalInSeconds added in v0.17.0

func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetBackoffStartIntervalInSeconds() (o int32)

GetBackoffStartIntervalInSeconds is an internal getter (TBD...)

func (*ContinueAsNewWorkflowExecutionDecisionAttributes) GetExecutionStartToCloseTimeoutSeconds added in v0.17.0

func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32)

GetExecutionStartToCloseTimeoutSeconds is an internal getter (TBD...)

func (*ContinueAsNewWorkflowExecutionDecisionAttributes) GetInitiator added in v0.17.0

GetInitiator is an internal getter (TBD...)

func (*ContinueAsNewWorkflowExecutionDecisionAttributes) GetJitterStartSeconds added in v0.25.0

func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetJitterStartSeconds() (o int32)

GetJitterStartSeconds is an internal getter (TBD...)

func (*ContinueAsNewWorkflowExecutionDecisionAttributes) GetSearchAttributes added in v0.17.0

GetSearchAttributes is an internal getter (TBD...)

func (*ContinueAsNewWorkflowExecutionDecisionAttributes) GetTaskStartToCloseTimeoutSeconds added in v0.17.0

func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32)

GetTaskStartToCloseTimeoutSeconds is an internal getter (TBD...)

type CountDLQMessagesRequest added in v0.25.0

type CountDLQMessagesRequest struct {
	// ForceFetch will force fetching current values from DB
	// instead of using cached values used for emitting metrics.
	ForceFetch bool
}

func (*CountDLQMessagesRequest) SerializeForLogging added in v1.2.7

func (v *CountDLQMessagesRequest) SerializeForLogging() (string, error)

type CountDLQMessagesResponse added in v0.25.0

type CountDLQMessagesResponse struct {
	History map[HistoryDLQCountKey]int64
	Domain  int64
}

type CountWorkflowExecutionsRequest

type CountWorkflowExecutionsRequest struct {
	Domain string `json:"domain,omitempty"`
	Query  string `json:"query,omitempty"`
}

CountWorkflowExecutionsRequest is an internal type (TBD...)

func (*CountWorkflowExecutionsRequest) GetDomain added in v0.17.0

func (v *CountWorkflowExecutionsRequest) GetDomain() (o string)

GetDomain is an internal getter (TBD...)

func (*CountWorkflowExecutionsRequest) GetQuery added in v0.17.0

func (v *CountWorkflowExecutionsRequest) GetQuery() (o string)

GetQuery is an internal getter (TBD...)

func (*CountWorkflowExecutionsRequest) SerializeForLogging added in v1.2.1

func (v *CountWorkflowExecutionsRequest) SerializeForLogging() (string, error)

type CountWorkflowExecutionsResponse

type CountWorkflowExecutionsResponse struct {
	Count int64 `json:"count,omitempty"`
}

CountWorkflowExecutionsResponse is an internal type (TBD...)

func (*CountWorkflowExecutionsResponse) GetCount added in v0.17.0

func (v *CountWorkflowExecutionsResponse) GetCount() (o int64)

GetCount is an internal getter (TBD...)

type CrossClusterApplyParentClosePolicyRequestAttributes added in v0.24.0

type CrossClusterApplyParentClosePolicyRequestAttributes struct {
	Children []*ApplyParentClosePolicyRequest `json:"children,omitempty"`
}

type CrossClusterApplyParentClosePolicyResponseAttributes added in v0.24.0

type CrossClusterApplyParentClosePolicyResponseAttributes struct {
	ChildrenStatus []*ApplyParentClosePolicyResult `json:"childrenStatus,omitempty"`
}

CrossClusterApplyParentClosePolicyResponseAttributes is an internal type (TBD...)

type CrossClusterCancelExecutionRequestAttributes added in v0.23.1

type CrossClusterCancelExecutionRequestAttributes struct {
	TargetDomainID    string `json:"targetDomainID,omitempty"`
	TargetWorkflowID  string `json:"targetWorkflowID,omitempty"`
	TargetRunID       string `json:"targetRunID,omitempty"`
	RequestID         string `json:"requestID,omitempty"`
	InitiatedEventID  int64  `json:"initiatedEventID,omitempty"`
	ChildWorkflowOnly bool   `json:"childWorkflowOnly,omitempty"`
}

CrossClusterCancelExecutionRequestAttributes is an internal type (TBD...)

type CrossClusterCancelExecutionResponseAttributes added in v0.23.1

type CrossClusterCancelExecutionResponseAttributes struct {
}

CrossClusterCancelExecutionResponseAttributes is an internal type (TBD...)

type CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes added in v0.23.1

type CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes struct {
	TargetDomainID   string        `json:"targetDomainID,omitempty"`
	TargetWorkflowID string        `json:"targetWorkflowID,omitempty"`
	TargetRunID      string        `json:"targetRunID,omitempty"`
	InitiatedEventID int64         `json:"initiatedEventID,omitempty"`
	CompletionEvent  *HistoryEvent `json:"completionEvent,omitempty"`
}

type CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes added in v0.23.1

type CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes struct {
}

CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes is an internal type (TBD...)

type CrossClusterSignalExecutionRequestAttributes added in v0.23.1

type CrossClusterSignalExecutionRequestAttributes struct {
	TargetDomainID    string `json:"targetDomainID,omitempty"`
	TargetWorkflowID  string `json:"targetWorkflowID,omitempty"`
	TargetRunID       string `json:"targetRunID,omitempty"`
	RequestID         string `json:"requestID,omitempty"`
	InitiatedEventID  int64  `json:"initiatedEventID,omitempty"`
	ChildWorkflowOnly bool   `json:"childWorkflowOnly,omitempty"`
	SignalName        string `json:"signalName,omitempty"`
	SignalInput       []byte `json:"signalInput,omitempty"`
	Control           []byte `json:"control,omitempty"`
}

CrossClusterSignalExecutionRequestAttributes is an internal type (TBD...)

type CrossClusterSignalExecutionResponseAttributes added in v0.23.1

type CrossClusterSignalExecutionResponseAttributes struct {
}

CrossClusterSignalExecutionResponseAttributes is an internal type (TBD...)

type CrossClusterStartChildExecutionRequestAttributes added in v0.23.1

type CrossClusterStartChildExecutionRequestAttributes struct {
	TargetDomainID           string                                               `json:"targetDomainID,omitempty"`
	RequestID                string                                               `json:"requestID,omitempty"`
	InitiatedEventID         int64                                                `json:"initiatedEventID,omitempty"`
	InitiatedEventAttributes *StartChildWorkflowExecutionInitiatedEventAttributes `json:"initiatedEventAttributes,omitempty"`
	TargetRunID              *string                                              `json:"targetRunID,omitempty"`
	PartitionConfig          map[string]string
}

CrossClusterStartChildExecutionRequestAttributes is an internal type (TBD...)

func (*CrossClusterStartChildExecutionRequestAttributes) GetInitiatedEventAttributes added in v0.23.1

GetInitiatedEventAttributes is an internal getter (TBD...)

func (*CrossClusterStartChildExecutionRequestAttributes) GetPartitionConfig added in v1.2.1

func (v *CrossClusterStartChildExecutionRequestAttributes) GetPartitionConfig() (o map[string]string)

GetTargetRunID is an internal getter (TBD...)

func (*CrossClusterStartChildExecutionRequestAttributes) GetRequestID added in v0.23.1

GetRequestID is an internal getter (TBD...)

func (*CrossClusterStartChildExecutionRequestAttributes) GetTargetRunID added in v0.23.1

GetTargetRunID is an internal getter (TBD...)

type CrossClusterStartChildExecutionResponseAttributes added in v0.23.1

type CrossClusterStartChildExecutionResponseAttributes struct {
	RunID string `json:"runID,omitempty"`
}

CrossClusterStartChildExecutionResponseAttributes is an internal type (TBD...)

func (*CrossClusterStartChildExecutionResponseAttributes) GetRunID added in v0.23.1

GetRunID is an internal getter (TBD...)

type CrossClusterTaskFailedCause added in v0.23.1

type CrossClusterTaskFailedCause int32

CrossClusterTaskFailedCause is an internal type (TBD...)

const (
	// CrossClusterTaskFailedCauseDomainNotActive is an option for CrossClusterTaskFailedCause
	CrossClusterTaskFailedCauseDomainNotActive CrossClusterTaskFailedCause = iota
	// CrossClusterTaskFailedCauseDomainNotExists is an option for CrossClusterTaskFailedCause
	CrossClusterTaskFailedCauseDomainNotExists
	// CrossClusterTaskFailedCauseWorkflowAlreadyRunning is an option for CrossClusterTaskFailedCause
	CrossClusterTaskFailedCauseWorkflowAlreadyRunning
	// CrossClusterTaskFailedCauseWorkflowNotExists is an option for CrossClusterTaskFailedCause
	CrossClusterTaskFailedCauseWorkflowNotExists
	// CrossClusterTaskFailedCauseWorkflowAlreadyCompleted is an option for CrossClusterTaskFailedCause
	CrossClusterTaskFailedCauseWorkflowAlreadyCompleted
	// CrossClusterTaskFailedCauseUncategorized is an option for CrossClusterTaskFailedCause
	CrossClusterTaskFailedCauseUncategorized
)

func (CrossClusterTaskFailedCause) MarshalText added in v0.23.1

func (e CrossClusterTaskFailedCause) MarshalText() ([]byte, error)

MarshalText encodes CrossClusterTaskFailedCause to text.

func (CrossClusterTaskFailedCause) Ptr added in v0.23.1

Ptr is a helper function for getting pointer value

func (CrossClusterTaskFailedCause) String added in v0.23.1

String returns a readable string representation of CrossClusterTaskFailedCause.

func (*CrossClusterTaskFailedCause) UnmarshalText added in v0.23.1

func (e *CrossClusterTaskFailedCause) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type CrossClusterTaskInfo added in v0.23.1

type CrossClusterTaskInfo struct {
	DomainID            string                `json:"domainID,omitempty"`
	WorkflowID          string                `json:"workflowID,omitempty"`
	RunID               string                `json:"runID,omitempty"`
	TaskType            *CrossClusterTaskType `json:"taskType,omitempty"`
	TaskState           int16                 `json:"taskState,omitempty"`
	TaskID              int64                 `json:"taskID,omitempty"`
	VisibilityTimestamp *int64                `json:"visibilityTimestamp,omitempty"`
}

CrossClusterTaskInfo is an internal type (TBD...)

func (*CrossClusterTaskInfo) GetTaskID added in v0.23.1

func (v *CrossClusterTaskInfo) GetTaskID() (o int64)

GetTaskID is an internal getter (TBD...)

func (*CrossClusterTaskInfo) GetTaskType added in v0.23.1

func (v *CrossClusterTaskInfo) GetTaskType() (o CrossClusterTaskType)

GetTaskType is an internal getter (TBD...)

func (*CrossClusterTaskInfo) GetVisibilityTimestamp added in v0.23.1

func (v *CrossClusterTaskInfo) GetVisibilityTimestamp() (o int64)

GetVisibilityTimestamp is an internal getter (TBD...)

type CrossClusterTaskRequest added in v0.23.1

type CrossClusterTaskRequest struct {
	TaskInfo                                       *CrossClusterTaskInfo                                              `json:"taskInfo,omitempty"`
	StartChildExecutionAttributes                  *CrossClusterStartChildExecutionRequestAttributes                  `json:"startChildExecutionAttributes,omitempty"`
	CancelExecutionAttributes                      *CrossClusterCancelExecutionRequestAttributes                      `json:"cancelExecutionAttributes,omitempty"`
	SignalExecutionAttributes                      *CrossClusterSignalExecutionRequestAttributes                      `json:"signalExecutionAttributes,omitempty"`
	RecordChildWorkflowExecutionCompleteAttributes *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes `json:"RecordChildWorkflowExecutionCompleteAttributes,omitempty"`
	ApplyParentClosePolicyAttributes               *CrossClusterApplyParentClosePolicyRequestAttributes               `json:"ApplyParentClosePolicyAttributes,omitempty"`
}

CrossClusterTaskRequest is an internal type (TBD...)

type CrossClusterTaskResponse added in v0.23.1

type CrossClusterTaskResponse struct {
	TaskID                                         int64                                                               `json:"taskID,omitempty"`
	TaskType                                       *CrossClusterTaskType                                               `json:"taskType,omitempty"`
	TaskState                                      int16                                                               `json:"taskState,omitempty"`
	FailedCause                                    *CrossClusterTaskFailedCause                                        `json:"failedCause,omitempty"`
	StartChildExecutionAttributes                  *CrossClusterStartChildExecutionResponseAttributes                  `json:"startChildExecutionAttributes,omitempty"`
	CancelExecutionAttributes                      *CrossClusterCancelExecutionResponseAttributes                      `json:"cancelExecutionAttributes,omitempty"`
	SignalExecutionAttributes                      *CrossClusterSignalExecutionResponseAttributes                      `json:"signalExecutionAttributes,omitempty"`
	RecordChildWorkflowExecutionCompleteAttributes *CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes `json:"RecordChildWorkflowExecutionCompleteAttributes,omitempty"`
	ApplyParentClosePolicyAttributes               *CrossClusterApplyParentClosePolicyResponseAttributes               `json:"ApplyParentClosePolicyAttributes,omitempty"`
}

CrossClusterTaskResponse is an internal type (TBD...)

func (*CrossClusterTaskResponse) GetFailedCause added in v0.23.1

func (v *CrossClusterTaskResponse) GetFailedCause() (o CrossClusterTaskFailedCause)

GetFailedCause is an internal getter (TBD...)

func (*CrossClusterTaskResponse) GetTaskID added in v0.23.1

func (v *CrossClusterTaskResponse) GetTaskID() (o int64)

GetTaskID is an internal getter (TBD...)

func (*CrossClusterTaskResponse) GetTaskType added in v0.23.1

func (v *CrossClusterTaskResponse) GetTaskType() (o CrossClusterTaskType)

GetTaskType is an internal getter (TBD...)

type CrossClusterTaskType added in v0.23.1

type CrossClusterTaskType int32

CrossClusterTaskType is an internal type (TBD...)

const (
	// CrossClusterTaskTypeStartChildExecution is an option for CrossClusterTaskType
	CrossClusterTaskTypeStartChildExecution CrossClusterTaskType = iota
	// CrossClusterTaskTypeCancelExecution is an option for CrossClusterTaskType
	CrossClusterTaskTypeCancelExecution
	// CrossClusterTaskTypeSignalExecution is an option for CrossClusterTaskType
	CrossClusterTaskTypeSignalExecution
	// CrossClusterTaskTypeRecordChildWorkflowExeuctionComplete is an option for CrossClusterTaskType
	CrossClusterTaskTypeRecordChildWorkflowExeuctionComplete
	// CrossClusterTaskTypeApplyParentPolicy is an option for CrossClusterTaskType
	CrossClusterTaskTypeApplyParentPolicy
)

func (CrossClusterTaskType) MarshalText added in v0.23.1

func (e CrossClusterTaskType) MarshalText() ([]byte, error)

MarshalText encodes CrossClusterTaskType to text.

func (CrossClusterTaskType) Ptr added in v0.23.1

Ptr is a helper function for getting pointer value

func (CrossClusterTaskType) String added in v0.23.1

func (e CrossClusterTaskType) String() string

String returns a readable string representation of CrossClusterTaskType.

func (*CrossClusterTaskType) UnmarshalText added in v0.23.1

func (e *CrossClusterTaskType) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type CurrentBranchChangedError

type CurrentBranchChangedError struct {
	Message            string `json:"message,required"`
	CurrentBranchToken []byte `json:"currentBranchToken,required"`
}

CurrentBranchChangedError is an internal type (TBD...)

func (CurrentBranchChangedError) Error

func (err CurrentBranchChangedError) Error() string

func (*CurrentBranchChangedError) GetCurrentBranchToken added in v0.17.0

func (v *CurrentBranchChangedError) GetCurrentBranchToken() (o []byte)

GetCurrentBranchToken is an internal getter (TBD...)

func (CurrentBranchChangedError) MarshalLogObject added in v0.25.0

func (err CurrentBranchChangedError) MarshalLogObject(enc zapcore.ObjectEncoder) error

type DLQType added in v0.17.0

type DLQType int32

DLQType is an internal type (TBD...)

const (
	// DLQTypeReplication is an option for DLQType
	DLQTypeReplication DLQType = iota
	// DLQTypeDomain is an option for DLQType
	DLQTypeDomain
)

func (DLQType) MarshalText added in v0.18.0

func (e DLQType) MarshalText() ([]byte, error)

MarshalText encodes DLQType to text.

func (DLQType) Ptr added in v0.17.0

func (e DLQType) Ptr() *DLQType

Ptr is a helper function for getting pointer value

func (DLQType) String added in v0.18.0

func (e DLQType) String() string

String returns a readable string representation of DLQType.

func (*DLQType) UnmarshalText added in v0.18.0

func (e *DLQType) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type DataBlob

type DataBlob struct {
	EncodingType *EncodingType `json:"EncodingType,omitempty"`
	Data         []byte        `json:"Data,omitempty"`
}

DataBlob is an internal type (TBD...)

func (*DataBlob) DeepCopy added in v1.2.8

func (v *DataBlob) DeepCopy() *DataBlob

func (*DataBlob) GetData added in v0.17.0

func (v *DataBlob) GetData() (o []byte)

GetData is an internal getter (TBD...)

func (*DataBlob) GetEncodingType added in v0.17.0

func (v *DataBlob) GetEncodingType() (o EncodingType)

GetEncodingType is an internal getter (TBD...)

type Decision

type Decision struct {
	DecisionType                                             *DecisionType                                             `json:"decisionType,omitempty"`
	ScheduleActivityTaskDecisionAttributes                   *ScheduleActivityTaskDecisionAttributes                   `json:"scheduleActivityTaskDecisionAttributes,omitempty"`
	StartTimerDecisionAttributes                             *StartTimerDecisionAttributes                             `json:"startTimerDecisionAttributes,omitempty"`
	CompleteWorkflowExecutionDecisionAttributes              *CompleteWorkflowExecutionDecisionAttributes              `json:"completeWorkflowExecutionDecisionAttributes,omitempty"`
	FailWorkflowExecutionDecisionAttributes                  *FailWorkflowExecutionDecisionAttributes                  `json:"failWorkflowExecutionDecisionAttributes,omitempty"`
	RequestCancelActivityTaskDecisionAttributes              *RequestCancelActivityTaskDecisionAttributes              `json:"requestCancelActivityTaskDecisionAttributes,omitempty"`
	CancelTimerDecisionAttributes                            *CancelTimerDecisionAttributes                            `json:"cancelTimerDecisionAttributes,omitempty"`
	CancelWorkflowExecutionDecisionAttributes                *CancelWorkflowExecutionDecisionAttributes                `json:"cancelWorkflowExecutionDecisionAttributes,omitempty"`
	RequestCancelExternalWorkflowExecutionDecisionAttributes *RequestCancelExternalWorkflowExecutionDecisionAttributes `json:"requestCancelExternalWorkflowExecutionDecisionAttributes,omitempty"`
	RecordMarkerDecisionAttributes                           *RecordMarkerDecisionAttributes                           `json:"recordMarkerDecisionAttributes,omitempty"`
	ContinueAsNewWorkflowExecutionDecisionAttributes         *ContinueAsNewWorkflowExecutionDecisionAttributes         `json:"continueAsNewWorkflowExecutionDecisionAttributes,omitempty"`
	StartChildWorkflowExecutionDecisionAttributes            *StartChildWorkflowExecutionDecisionAttributes            `json:"startChildWorkflowExecutionDecisionAttributes,omitempty"`
	SignalExternalWorkflowExecutionDecisionAttributes        *SignalExternalWorkflowExecutionDecisionAttributes        `json:"signalExternalWorkflowExecutionDecisionAttributes,omitempty"`
	UpsertWorkflowSearchAttributesDecisionAttributes         *UpsertWorkflowSearchAttributesDecisionAttributes         `json:"upsertWorkflowSearchAttributesDecisionAttributes,omitempty"`
}

Decision is an internal type (TBD...)

func (*Decision) GetDecisionType added in v0.17.0

func (v *Decision) GetDecisionType() (o DecisionType)

GetDecisionType is an internal getter (TBD...)

type DecisionTaskCompletedEventAttributes

type DecisionTaskCompletedEventAttributes struct {
	ExecutionContext []byte `json:"executionContext,omitempty"`
	ScheduledEventID int64  `json:"scheduledEventId,omitempty"`
	StartedEventID   int64  `json:"startedEventId,omitempty"`
	Identity         string `json:"identity,omitempty"`
	BinaryChecksum   string `json:"binaryChecksum,omitempty"`
}

DecisionTaskCompletedEventAttributes is an internal type (TBD...)

func (*DecisionTaskCompletedEventAttributes) GetBinaryChecksum added in v0.17.0

func (v *DecisionTaskCompletedEventAttributes) GetBinaryChecksum() (o string)

GetBinaryChecksum is an internal getter (TBD...)

func (*DecisionTaskCompletedEventAttributes) GetStartedEventID added in v0.17.0

func (v *DecisionTaskCompletedEventAttributes) GetStartedEventID() (o int64)

GetStartedEventID is an internal getter (TBD...)

type DecisionTaskFailedCause

type DecisionTaskFailedCause int32

DecisionTaskFailedCause is an internal type (TBD...)

const (
	// DecisionTaskFailedCauseUnhandledDecision is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseUnhandledDecision DecisionTaskFailedCause = iota
	// DecisionTaskFailedCauseBadScheduleActivityAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadScheduleActivityAttributes
	// DecisionTaskFailedCauseBadRequestCancelActivityAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadRequestCancelActivityAttributes
	// DecisionTaskFailedCauseBadStartTimerAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadStartTimerAttributes
	// DecisionTaskFailedCauseBadCancelTimerAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadCancelTimerAttributes
	// DecisionTaskFailedCauseBadRecordMarkerAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadRecordMarkerAttributes
	// DecisionTaskFailedCauseBadCompleteWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadCompleteWorkflowExecutionAttributes
	// DecisionTaskFailedCauseBadFailWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadFailWorkflowExecutionAttributes
	// DecisionTaskFailedCauseBadCancelWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadCancelWorkflowExecutionAttributes
	// DecisionTaskFailedCauseBadRequestCancelExternalWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadRequestCancelExternalWorkflowExecutionAttributes
	// DecisionTaskFailedCauseBadContinueAsNewAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadContinueAsNewAttributes
	// DecisionTaskFailedCauseStartTimerDuplicateID is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseStartTimerDuplicateID
	// DecisionTaskFailedCauseResetStickyTasklist is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseResetStickyTasklist
	// DecisionTaskFailedCauseWorkflowWorkerUnhandledFailure is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseWorkflowWorkerUnhandledFailure
	// DecisionTaskFailedCauseBadSignalWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadSignalWorkflowExecutionAttributes
	// DecisionTaskFailedCauseBadStartChildExecutionAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadStartChildExecutionAttributes
	// DecisionTaskFailedCauseForceCloseDecision is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseForceCloseDecision
	// DecisionTaskFailedCauseFailoverCloseDecision is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseFailoverCloseDecision
	// DecisionTaskFailedCauseBadSignalInputSize is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadSignalInputSize
	// DecisionTaskFailedCauseResetWorkflow is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseResetWorkflow
	// DecisionTaskFailedCauseBadBinary is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadBinary
	// DecisionTaskFailedCauseScheduleActivityDuplicateID is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseScheduleActivityDuplicateID
	// DecisionTaskFailedCauseBadSearchAttributes is an option for DecisionTaskFailedCause
	DecisionTaskFailedCauseBadSearchAttributes
)

func (DecisionTaskFailedCause) MarshalText added in v0.18.0

func (e DecisionTaskFailedCause) MarshalText() ([]byte, error)

MarshalText encodes DecisionTaskFailedCause to text.

func (DecisionTaskFailedCause) Ptr added in v0.17.0

Ptr is a helper function for getting pointer value

func (DecisionTaskFailedCause) String added in v0.18.0

func (e DecisionTaskFailedCause) String() string

String returns a readable string representation of DecisionTaskFailedCause.

func (*DecisionTaskFailedCause) UnmarshalText added in v0.18.0

func (e *DecisionTaskFailedCause) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type DecisionTaskFailedEventAttributes

type DecisionTaskFailedEventAttributes struct {
	ScheduledEventID int64                    `json:"scheduledEventId,omitempty"`
	StartedEventID   int64                    `json:"startedEventId,omitempty"`
	Cause            *DecisionTaskFailedCause `json:"cause,omitempty"`
	Details          []byte                   `json:"details,omitempty"`
	Identity         string                   `json:"identity,omitempty"`
	Reason           *string                  `json:"reason,omitempty"`
	BaseRunID        string                   `json:"baseRunId,omitempty"`
	NewRunID         string                   `json:"newRunId,omitempty"`
	ForkEventVersion int64                    `json:"forkEventVersion,omitempty"`
	BinaryChecksum   string                   `json:"binaryChecksum,omitempty"`
	RequestID        string                   `json:"requestId,omitempty"`
}

DecisionTaskFailedEventAttributes is an internal type (TBD...)

func (*DecisionTaskFailedEventAttributes) GetBaseRunID added in v0.17.0

func (v *DecisionTaskFailedEventAttributes) GetBaseRunID() (o string)

GetBaseRunID is an internal getter (TBD...)

func (*DecisionTaskFailedEventAttributes) GetCause added in v0.17.0

GetCause is an internal getter (TBD...)

func (*DecisionTaskFailedEventAttributes) GetDetails added in v0.17.0

func (v *DecisionTaskFailedEventAttributes) GetDetails() (o []byte)

GetDetails is an internal getter (TBD...)

func (*DecisionTaskFailedEventAttributes) GetForkEventVersion added in v0.17.0

func (v *DecisionTaskFailedEventAttributes) GetForkEventVersion() (o int64)

GetForkEventVersion is an internal getter (TBD...)

func (*DecisionTaskFailedEventAttributes) GetNewRunID added in v0.17.0

func (v *DecisionTaskFailedEventAttributes) GetNewRunID() (o string)

GetNewRunID is an internal getter (TBD...)

func (*DecisionTaskFailedEventAttributes) GetRequestID added in v1.2.9

func (v *DecisionTaskFailedEventAttributes) GetRequestID() (o string)

GetRequestID is an internal getter (TBD...)

type DecisionTaskScheduledEventAttributes

type DecisionTaskScheduledEventAttributes struct {
	TaskList                   *TaskList `json:"taskList,omitempty"`
	StartToCloseTimeoutSeconds *int32    `json:"startToCloseTimeoutSeconds,omitempty"`
	Attempt                    int64     `json:"attempt,omitempty"`
}

DecisionTaskScheduledEventAttributes is an internal type (TBD...)

func (*DecisionTaskScheduledEventAttributes) GetAttempt added in v0.17.0

func (v *DecisionTaskScheduledEventAttributes) GetAttempt() (o int64)

GetAttempt is an internal getter (TBD...)

func (*DecisionTaskScheduledEventAttributes) GetStartToCloseTimeoutSeconds added in v0.17.0

func (v *DecisionTaskScheduledEventAttributes) GetStartToCloseTimeoutSeconds() (o int32)

GetStartToCloseTimeoutSeconds is an internal getter (TBD...)

func (*DecisionTaskScheduledEventAttributes) GetTaskList added in v0.17.0

func (v *DecisionTaskScheduledEventAttributes) GetTaskList() (o *TaskList)

GetTaskList is an internal getter (TBD...)

type DecisionTaskStartedEventAttributes

type DecisionTaskStartedEventAttributes struct {
	ScheduledEventID int64  `json:"scheduledEventId,omitempty"`
	Identity         string `json:"identity,omitempty"`
	RequestID        string `json:"requestId,omitempty"`
}

DecisionTaskStartedEventAttributes is an internal type (TBD...)

func (*DecisionTaskStartedEventAttributes) GetRequestID added in v0.17.0

func (v *DecisionTaskStartedEventAttributes) GetRequestID() (o string)

GetRequestID is an internal getter (TBD...)

func (*DecisionTaskStartedEventAttributes) GetScheduledEventID added in v0.17.0

func (v *DecisionTaskStartedEventAttributes) GetScheduledEventID() (o int64)

GetScheduledEventID is an internal getter (TBD...)

type DecisionTaskTimedOutCause added in v0.18.0

type DecisionTaskTimedOutCause int32

DecisionTaskTimedOutCause is an internal type (TBD...)

const (
	// DecisionTaskTimedOutCauseTimeout is an option for DecisionTaskTimedOutCause
	DecisionTaskTimedOutCauseTimeout DecisionTaskTimedOutCause = iota
	// DecisionTaskTimedOutCauseReset is an option for DecisionTaskTimedOutCause
	DecisionTaskTimedOutCauseReset
)

func (DecisionTaskTimedOutCause) MarshalText added in v0.18.0

func (e DecisionTaskTimedOutCause) MarshalText() ([]byte, error)

MarshalText encodes DecisionTaskFailedCause to text.

func (DecisionTaskTimedOutCause) Ptr added in v0.18.0

Ptr is a helper function for getting pointer value

func (DecisionTaskTimedOutCause) String added in v0.18.0

func (e DecisionTaskTimedOutCause) String() string

String returns a readable string representation of DecisionTaskTimedOutCause.

func (*DecisionTaskTimedOutCause) UnmarshalText added in v0.18.0

func (e *DecisionTaskTimedOutCause) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type DecisionTaskTimedOutEventAttributes

type DecisionTaskTimedOutEventAttributes struct {
	ScheduledEventID int64                      `json:"scheduledEventId,omitempty"`
	StartedEventID   int64                      `json:"startedEventId,omitempty"`
	TimeoutType      *TimeoutType               `json:"timeoutType,omitempty"`
	BaseRunID        string                     `json:"baseRunId,omitempty"`
	NewRunID         string                     `json:"newRunId,omitempty"`
	ForkEventVersion int64                      `json:"forkEventVersion,omitempty"`
	Reason           string                     `json:"reason,omitempty"`
	Cause            *DecisionTaskTimedOutCause `json:"cause,omitempty"`
	RequestID        string                     `json:"requestId,omitempty"`
}

DecisionTaskTimedOutEventAttributes is an internal type (TBD...)

func (*DecisionTaskTimedOutEventAttributes) GetBaseRunID added in v0.18.0

func (v *DecisionTaskTimedOutEventAttributes) GetBaseRunID() (o string)

GetBaseRunID is an internal getter (TBD...)

func (*DecisionTaskTimedOutEventAttributes) GetCause added in v0.18.0

GetCause is an internal getter (TBD...)

func (*DecisionTaskTimedOutEventAttributes) GetForkEventVersion added in v0.18.0

func (v *DecisionTaskTimedOutEventAttributes) GetForkEventVersion() (o int64)

GetForkEventVersion is an internal getter (TBD...)

func (*DecisionTaskTimedOutEventAttributes) GetNewRunID added in v0.18.0

func (v *DecisionTaskTimedOutEventAttributes) GetNewRunID() (o string)

GetNewRunID is an internal getter (TBD...)

func (*DecisionTaskTimedOutEventAttributes) GetRequestID added in v1.2.9

func (v *DecisionTaskTimedOutEventAttributes) GetRequestID() (o string)

GetRequestID is an internal getter (TBD...)

func (*DecisionTaskTimedOutEventAttributes) GetScheduledEventID added in v0.17.0

func (v *DecisionTaskTimedOutEventAttributes) GetScheduledEventID() (o int64)

GetScheduledEventID is an internal getter (TBD...)

func (*DecisionTaskTimedOutEventAttributes) GetTimeoutType added in v0.17.0

func (v *DecisionTaskTimedOutEventAttributes) GetTimeoutType() (o TimeoutType)

GetTimeoutType is an internal getter (TBD...)

type DecisionType

type DecisionType int32

DecisionType is an internal type (TBD...)

const (
	// DecisionTypeScheduleActivityTask is an option for DecisionType
	DecisionTypeScheduleActivityTask DecisionType = iota
	// DecisionTypeRequestCancelActivityTask is an option for DecisionType
	DecisionTypeRequestCancelActivityTask
	// DecisionTypeStartTimer is an option for DecisionType
	DecisionTypeStartTimer
	// DecisionTypeCompleteWorkflowExecution is an option for DecisionType
	DecisionTypeCompleteWorkflowExecution
	// DecisionTypeFailWorkflowExecution is an option for DecisionType
	DecisionTypeFailWorkflowExecution
	// DecisionTypeCancelTimer is an option for DecisionType
	DecisionTypeCancelTimer
	// DecisionTypeCancelWorkflowExecution is an option for DecisionType
	DecisionTypeCancelWorkflowExecution
	// DecisionTypeRequestCancelExternalWorkflowExecution is an option for DecisionType
	DecisionTypeRequestCancelExternalWorkflowExecution
	// DecisionTypeRecordMarker is an option for DecisionType
	DecisionTypeRecordMarker
	// DecisionTypeContinueAsNewWorkflowExecution is an option for DecisionType
	DecisionTypeContinueAsNewWorkflowExecution
	// DecisionTypeStartChildWorkflowExecution is an option for DecisionType
	DecisionTypeStartChildWorkflowExecution
	// DecisionTypeSignalExternalWorkflowExecution is an option for DecisionType
	DecisionTypeSignalExternalWorkflowExecution
	// DecisionTypeUpsertWorkflowSearchAttributes is an option for DecisionType
	DecisionTypeUpsertWorkflowSearchAttributes
)

func DecisionTypeValues added in v0.18.0

func DecisionTypeValues() []DecisionType

DecisionTypeValues returns all recognized values of DecisionType.

func (DecisionType) MarshalText added in v0.18.0

func (e DecisionType) MarshalText() ([]byte, error)

MarshalText encodes DecisionType to text.

func (DecisionType) Ptr added in v0.17.0

func (e DecisionType) Ptr() *DecisionType

Ptr is a helper function for getting pointer value

func (DecisionType) String added in v0.18.0

func (e DecisionType) String() string

String returns a readable string representation of DecisionType.

func (*DecisionType) UnmarshalText added in v0.18.0

func (e *DecisionType) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type DeprecateDomainRequest

type DeprecateDomainRequest struct {
	Name          string `json:"name,omitempty"`
	SecurityToken string `json:"securityToken,omitempty"`
}

DeprecateDomainRequest is an internal type (TBD...)

func (*DeprecateDomainRequest) GetName added in v0.17.0

func (v *DeprecateDomainRequest) GetName() (o string)

GetName is an internal getter (TBD...)

func (*DeprecateDomainRequest) SerializeForLogging added in v1.2.1

func (v *DeprecateDomainRequest) SerializeForLogging() (string, error)

type DescribeClusterResponse added in v0.17.0

type DescribeClusterResponse struct {
	SupportedClientVersions *SupportedClientVersions    `json:"supportedClientVersions,omitempty"`
	MembershipInfo          *MembershipInfo             `json:"membershipInfo,omitempty"`
	PersistenceInfo         map[string]*PersistenceInfo `json:"persistenceInfo,omitempty"`
}

DescribeClusterResponse is an internal type (TBD...)

type DescribeDomainRequest

type DescribeDomainRequest struct {
	Name *string `json:"name,omitempty"`
	UUID *string `json:"uuid,omitempty"`
}

DescribeDomainRequest is an internal type (TBD...)

func (*DescribeDomainRequest) GetName added in v0.17.0

func (v *DescribeDomainRequest) GetName() (o string)

GetName is an internal getter (TBD...)

func (*DescribeDomainRequest) GetUUID added in v0.17.0

func (v *DescribeDomainRequest) GetUUID() (o string)

GetUUID is an internal getter (TBD...)

func (*DescribeDomainRequest) SerializeForLogging added in v1.2.1

func (v *DescribeDomainRequest) SerializeForLogging() (string, error)

type DescribeDomainResponse

type DescribeDomainResponse struct {
	DomainInfo               *DomainInfo                     `json:"domainInfo,omitempty"`
	Configuration            *DomainConfiguration            `json:"configuration,omitempty"`
	ReplicationConfiguration *DomainReplicationConfiguration `json:"replicationConfiguration,omitempty"`
	FailoverVersion          int64                           `json:"failoverVersion,omitempty"`
	IsGlobalDomain           bool                            `json:"isGlobalDomain,omitempty"`
	FailoverInfo             *FailoverInfo                   `json:"failoverInfo,omitempty"`
}

DescribeDomainResponse is an internal type (TBD...)

func (*DescribeDomainResponse) GetDomainInfo added in v0.17.0

func (v *DescribeDomainResponse) GetDomainInfo() (o *DomainInfo)

GetDomainInfo is an internal getter (TBD...)

func (*DescribeDomainResponse) GetFailoverInfo added in v0.24.0

func (v *DescribeDomainResponse) GetFailoverInfo() (o *FailoverInfo)

GetFailoverInfo is an internal getter (TBD...)

func (*DescribeDomainResponse) GetFailoverVersion added in v0.17.0

func (v *DescribeDomainResponse) GetFailoverVersion() (o int64)

GetFailoverVersion is an internal getter (TBD...)

func (*DescribeDomainResponse) GetIsGlobalDomain added in v0.17.0

func (v *DescribeDomainResponse) GetIsGlobalDomain() (o bool)

GetIsGlobalDomain is an internal getter (TBD...)

type DescribeHistoryHostRequest

type DescribeHistoryHostRequest struct {
	HostAddress      *string            `json:"hostAddress,omitempty"`
	ShardIDForHost   *int32             `json:"shardIdForHost,omitempty"`
	ExecutionForHost *WorkflowExecution `json:"executionForHost,omitempty"`
}

DescribeHistoryHostRequest is an internal type (TBD...)

func (*DescribeHistoryHostRequest) GetHostAddress added in v0.17.0

func (v *DescribeHistoryHostRequest) GetHostAddress() (o string)

GetHostAddress is an internal getter (TBD...)

func (*DescribeHistoryHostRequest) GetShardIDForHost added in v0.17.0

func (v *DescribeHistoryHostRequest) GetShardIDForHost() (o int32)

GetShardIDForHost is an internal getter (TBD...)

func (*DescribeHistoryHostRequest) SerializeForLogging added in v1.2.1

func (v *DescribeHistoryHostRequest) SerializeForLogging() (string, error)

type DescribeHistoryHostResponse

type DescribeHistoryHostResponse struct {
	NumberOfShards        int32            `json:"numberOfShards,omitempty"`
	ShardIDs              []int32          `json:"shardIDs,omitempty"`
	DomainCache           *DomainCacheInfo `json:"domainCache,omitempty"`
	ShardControllerStatus string           `json:"shardControllerStatus,omitempty"`
	Address               string           `json:"address,omitempty"`
}

DescribeHistoryHostResponse is an internal type (TBD...)

type DescribeMutableStateRequest added in v0.17.0

type DescribeMutableStateRequest struct {
	DomainUUID string             `json:"domainUUID,omitempty"`
	Execution  *WorkflowExecution `json:"execution,omitempty"`
}

DescribeMutableStateRequest is an internal type (TBD...)

func (*DescribeMutableStateRequest) GetDomainUUID added in v0.17.0

func (v *DescribeMutableStateRequest) GetDomainUUID() (o string)

GetDomainUUID is an internal getter (TBD...)

type DescribeMutableStateResponse added in v0.17.0

type DescribeMutableStateResponse struct {
	MutableStateInCache    string `json:"mutableStateInCache,omitempty"`
	MutableStateInDatabase string `json:"mutableStateInDatabase,omitempty"`
}

DescribeMutableStateResponse is an internal type (TBD...)

type DescribeQueueRequest

type DescribeQueueRequest struct {
	ShardID     int32  `json:"shardID,omitempty"`
	ClusterName string `json:"clusterName,omitempty"`
	Type        *int32 `json:"type,omitempty"`
}

DescribeQueueRequest is an internal type (TBD...)

func (*DescribeQueueRequest) GetClusterName added in v0.17.0

func (v *DescribeQueueRequest) GetClusterName() (o string)

GetClusterName is an internal getter (TBD...)

func (*DescribeQueueRequest) GetShardID added in v0.17.0

func (v *DescribeQueueRequest) GetShardID() (o int32)

GetShardID is an internal getter (TBD...)

func (*DescribeQueueRequest) GetType added in v0.17.0

func (v *DescribeQueueRequest) GetType() (o int32)

GetType is an internal getter (TBD...)

func (*DescribeQueueRequest) SerializeForLogging added in v1.2.1

func (v *DescribeQueueRequest) SerializeForLogging() (string, error)

type DescribeQueueResponse

type DescribeQueueResponse struct {
	ProcessingQueueStates []string `json:"processingQueueStates,omitempty"`
}

DescribeQueueResponse is an internal type (TBD...)

type DescribeShardDistributionRequest added in v0.22.0

type DescribeShardDistributionRequest struct {
	PageSize int32 `json:"pageSize,omitempty"`
	PageID   int32 `json:"pageID,omitempty"`
}

DescribeShardDistributionRequest is an internal type (TBD...)

func (*DescribeShardDistributionRequest) SerializeForLogging added in v1.2.1

func (v *DescribeShardDistributionRequest) SerializeForLogging() (string, error)

type DescribeShardDistributionResponse added in v0.22.0

type DescribeShardDistributionResponse struct {
	NumberOfShards int32            `json:"numberOfShards,omitempty"`
	Shards         map[int32]string `json:"shardIDs,omitempty"`
}

DescribeShardDistributionResponse is an internal type (TBD...)

type DescribeTaskListRequest

type DescribeTaskListRequest struct {
	Domain                string        `json:"domain,omitempty"`
	TaskList              *TaskList     `json:"taskList,omitempty"`
	TaskListType          *TaskListType `json:"taskListType,omitempty"`
	IncludeTaskListStatus bool          `json:"includeTaskListStatus,omitempty"`
}

DescribeTaskListRequest is an internal type (TBD...)

func (*DescribeTaskListRequest) GetDomain added in v0.17.0

func (v *DescribeTaskListRequest) GetDomain() (o string)

GetDomain is an internal getter (TBD...)

func (*DescribeTaskListRequest) GetIncludeTaskListStatus added in v0.17.0

func (v *DescribeTaskListRequest) GetIncludeTaskListStatus() (o bool)

GetIncludeTaskListStatus is an internal getter (TBD...)

func (*DescribeTaskListRequest) GetTaskList added in v0.17.0

func (v *DescribeTaskListRequest) GetTaskList() (o *TaskList)

GetTaskList is an internal getter (TBD...)

func (*DescribeTaskListRequest) GetTaskListType added in v0.17.0

func (v *DescribeTaskListRequest) GetTaskListType() (o TaskListType)

GetTaskListType is an internal getter (TBD...)

func (*DescribeTaskListRequest) SerializeForLogging added in v1.2.1

func (v *DescribeTaskListRequest) SerializeForLogging() (string, error)

type DescribeTaskListResponse

type DescribeTaskListResponse struct {
	Pollers        []*PollerInfo   `json:"pollers,omitempty"`
	TaskListStatus *TaskListStatus `json:"taskListStatus,omitempty"`
}

DescribeTaskListResponse is an internal type (TBD...)

func (*DescribeTaskListResponse) GetPollers added in v0.17.0

func (v *DescribeTaskListResponse) GetPollers() (o []*PollerInfo)

GetPollers is an internal getter (TBD...)

func (*DescribeTaskListResponse) GetTaskListStatus added in v0.17.0

func (v *DescribeTaskListResponse) GetTaskListStatus() (o *TaskListStatus)

GetTaskListStatus is an internal getter (TBD...)

type DescribeWorkflowExecutionRequest

type DescribeWorkflowExecutionRequest struct {
	Domain    string             `json:"domain,omitempty"`
	Execution *WorkflowExecution `json:"execution,omitempty"`
}

DescribeWorkflowExecutionRequest is an internal type (TBD...)

func (*DescribeWorkflowExecutionRequest) GetDomain added in v0.17.0

func (v *DescribeWorkflowExecutionRequest) GetDomain() (o string)

GetDomain is an internal getter (TBD...)

func (*DescribeWorkflowExecutionRequest) GetExecution added in v0.17.0

func (v *DescribeWorkflowExecutionRequest) GetExecution() (o *WorkflowExecution)

GetExecution is an internal getter (TBD...)

func (*DescribeWorkflowExecutionRequest) SerializeForLogging added in v1.2.1

func (v *DescribeWorkflowExecutionRequest) SerializeForLogging() (string, error)

type DescribeWorkflowExecutionResponse

type DescribeWorkflowExecutionResponse struct {
	ExecutionConfiguration *WorkflowExecutionConfiguration `json:"executionConfiguration,omitempty"`
	WorkflowExecutionInfo  *WorkflowExecutionInfo          `json:"workflowExecutionInfo,omitempty"`
	PendingActivities      []*PendingActivityInfo          `json:"pendingActivities,omitempty"`
	PendingChildren        []*PendingChildExecutionInfo    `json:"pendingChildren,omitempty"`
	PendingDecision        *PendingDecisionInfo            `json:"pendingDecision,omitempty"`
}

DescribeWorkflowExecutionResponse is an internal type (TBD...)

func (*DescribeWorkflowExecutionResponse) GetPendingActivities added in v0.17.0

func (v *DescribeWorkflowExecutionResponse) GetPendingActivities() (o []*PendingActivityInfo)

GetPendingActivities is an internal getter (TBD...)

func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo added in v0.17.0

func (v *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() (o *WorkflowExecutionInfo)

GetWorkflowExecutionInfo is an internal getter (TBD...)

type DomainAlreadyExistsError

type DomainAlreadyExistsError struct {
	Message string `json:"message,required"`
}

DomainAlreadyExistsError is an internal type (TBD...)

func (DomainAlreadyExistsError) Error

func (err DomainAlreadyExistsError) Error() string

type DomainCacheInfo

type DomainCacheInfo struct {
	NumOfItemsInCacheByID   int64 `json:"numOfItemsInCacheByID,omitempty"`
	NumOfItemsInCacheByName int64 `json:"numOfItemsInCacheByName,omitempty"`
}

DomainCacheInfo is an internal type (TBD...)

type DomainConfiguration

type DomainConfiguration struct {
	WorkflowExecutionRetentionPeriodInDays int32                        `json:"workflowExecutionRetentionPeriodInDays,omitempty"`
	EmitMetric                             bool                         `json:"emitMetric,omitempty"`
	BadBinaries                            *BadBinaries                 `json:"badBinaries,omitempty"`
	HistoryArchivalStatus                  *ArchivalStatus              `json:"historyArchivalStatus,omitempty"`
	HistoryArchivalURI                     string                       `json:"historyArchivalURI,omitempty"`
	VisibilityArchivalStatus               *ArchivalStatus              `json:"visibilityArchivalStatus,omitempty"`
	VisibilityArchivalURI                  string                       `json:"visibilityArchivalURI,omitempty"`
	IsolationGroups                        *IsolationGroupConfiguration `json:"isolationGroupConfiguration,omitempty"`
	AsyncWorkflowConfig                    *AsyncWorkflowConfiguration  `json:"asyncWorkflowConfiguration,omitempty"`
}

DomainConfiguration is an internal type (TBD...)

func (*DomainConfiguration) GetAsyncWorkflowConfiguration added in v1.2.8

func (v *DomainConfiguration) GetAsyncWorkflowConfiguration() AsyncWorkflowConfiguration

func (*DomainConfiguration) GetBadBinaries added in v0.17.0

func (v *DomainConfiguration) GetBadBinaries() (o *BadBinaries)

GetBadBinaries is an internal getter (TBD...)

func (*DomainConfiguration) GetEmitMetric added in v0.17.0

func (v *DomainConfiguration) GetEmitMetric() (o bool)

GetEmitMetric is an internal getter (TBD...)

func (*DomainConfiguration) GetHistoryArchivalStatus added in v0.17.0

func (v *DomainConfiguration) GetHistoryArchivalStatus() (o ArchivalStatus)

GetHistoryArchivalStatus is an internal getter (TBD...)

func (*DomainConfiguration) GetHistoryArchivalURI added in v0.17.0

func (v *DomainConfiguration) GetHistoryArchivalURI() (o string)

GetHistoryArchivalURI is an internal getter (TBD...)

func (*DomainConfiguration) GetIsolationGroupsConfiguration added in v1.2.1

func (v *DomainConfiguration) GetIsolationGroupsConfiguration() IsolationGroupConfiguration

GetIsolationGroupsConfiguration is an internal getter (TBD...)

func (*DomainConfiguration) GetVisibilityArchivalStatus added in v0.17.0

func (v *DomainConfiguration) GetVisibilityArchivalStatus() (o ArchivalStatus)

GetVisibilityArchivalStatus is an internal getter (TBD...)

func (*DomainConfiguration) GetVisibilityArchivalURI added in v0.17.0

func (v *DomainConfiguration) GetVisibilityArchivalURI() (o string)

GetVisibilityArchivalURI is an internal getter (TBD...)

func (*DomainConfiguration) GetWorkflowExecutionRetentionPeriodInDays added in v0.17.0

func (v *DomainConfiguration) GetWorkflowExecutionRetentionPeriodInDays() (o int32)

GetWorkflowExecutionRetentionPeriodInDays is an internal getter (TBD...)

type DomainFilter added in v0.17.0

type DomainFilter struct {
	DomainIDs    []string `json:"domainIDs,omitempty"`
	ReverseMatch bool     `json:"reverseMatch,omitempty"`
}

DomainFilter is an internal type (TBD...)

func (*DomainFilter) GetDomainIDs added in v0.17.0

func (v *DomainFilter) GetDomainIDs() (o []string)

GetDomainIDs is an internal getter (TBD...)

func (*DomainFilter) GetReverseMatch added in v0.17.0

func (v *DomainFilter) GetReverseMatch() (o bool)

GetReverseMatch is an internal getter (TBD...)

type DomainInfo

type DomainInfo struct {
	Name        string            `json:"name,omitempty"`
	Status      *DomainStatus     `json:"status,omitempty"`
	Description string            `json:"description,omitempty"`
	OwnerEmail  string            `json:"ownerEmail,omitempty"`
	Data        map[string]string `json:"data,omitempty"`
	UUID        string            `json:"uuid,omitempty"`
}

DomainInfo is an internal type (TBD...)

func (*DomainInfo) GetData added in v0.17.0

func (v *DomainInfo) GetData() (o map[string]string)

GetData is an internal getter (TBD...)

func (*DomainInfo) GetDescription added in v0.17.0

func (v *DomainInfo) GetDescription() (o string)

GetDescription is an internal getter (TBD...)

func (*DomainInfo) GetName added in v0.17.0

func (v *DomainInfo) GetName() (o string)

GetName is an internal getter (TBD...)

func (*DomainInfo) GetOwnerEmail added in v0.17.0

func (v *DomainInfo) GetOwnerEmail() (o string)

GetOwnerEmail is an internal getter (TBD...)

func (*DomainInfo) GetStatus added in v0.17.0

func (v *DomainInfo) GetStatus() (o DomainStatus)

GetStatus is an internal getter (TBD...)

func (*DomainInfo) GetUUID added in v0.17.0

func (v *DomainInfo) GetUUID() (o string)

GetUUID is an internal getter (TBD...)

type DomainNotActiveError

type DomainNotActiveError struct {
	Message        string `json:"message,required"`
	DomainName     string `json:"domainName,required"`
	CurrentCluster string `json:"currentCluster,required"`
	ActiveCluster  string `json:"activeCluster,required"`
}

DomainNotActiveError is an internal type (TBD...)

func (DomainNotActiveError) Error

func (err DomainNotActiveError) Error() string

func (*DomainNotActiveError) GetActiveCluster added in v0.17.0

func (v *DomainNotActiveError) GetActiveCluster() (o string)

GetActiveCluster is an internal getter (TBD...)

func (*DomainNotActiveError) GetCurrentCluster added in v0.17.0

func (v *DomainNotActiveError) GetCurrentCluster() (o string)

GetCurrentCluster is an internal getter (TBD...)

func (DomainNotActiveError) MarshalLogObject added in v0.25.0

func (err DomainNotActiveError) MarshalLogObject(enc zapcore.ObjectEncoder) error

type DomainOperation added in v0.17.0

type DomainOperation int32

DomainOperation is an internal type (TBD...)

const (
	// DomainOperationCreate is an option for DomainOperation
	DomainOperationCreate DomainOperation = iota
	// DomainOperationUpdate is an option for DomainOperation
	DomainOperationUpdate
)

func (DomainOperation) MarshalText added in v0.18.0

func (e DomainOperation) MarshalText() ([]byte, error)

MarshalText encodes DomainOperation to text.

func (DomainOperation) Ptr added in v0.17.0

Ptr is a helper function for getting pointer value

func (DomainOperation) String added in v0.18.0

func (e DomainOperation) String() string

String returns a readable string representation of DomainOperation.

func (*DomainOperation) UnmarshalText added in v0.18.0

func (e *DomainOperation) UnmarshalText(value []byte) error

UnmarshalText parses enum value from string representation

type DomainReplicationConfiguration

type DomainReplicationConfiguration struct {
	ActiveClusterName string                             `json:"activeClusterName,omitempty"`
	Clusters          []*ClusterReplicationConfiguration `json:"clusters,omitempty"`
}

DomainReplicationConfiguration is an internal type (TBD...)

func (*DomainReplicationConfiguration) GetActiveClusterName added in v0.17.0

func (v *DomainReplicationConfiguration) GetActiveClusterName() (o string)

GetActiveClusterName is an internal getter (TBD...)

func (*DomainReplicationConfiguration) GetClusters added in v0.17.0 <