types

package
Version: v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2023 License: MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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

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

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)

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

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

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

MarshalText encodes CancelExternalWorkflowExecutionFailedCause to text.

func (CancelExternalWorkflowExecutionFailedCause) Ptr added in v0.17.0 

func (e CancelExternalWorkflowExecutionFailedCause) Ptr() *CancelExternalWorkflowExecutionFailedCause

Ptr is a helper function for getting pointer value

func (CancelExternalWorkflowExecutionFailedCause) String added in v0.18.0 

func (e CancelExternalWorkflowExecutionFailedCause) String() string

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 

func (err CancellationAlreadyRequestedError) Error() string

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 

func (e ChildWorkflowExecutionFailedCause) Ptr() *ChildWorkflowExecutionFailedCause

Ptr is a helper function for getting pointer value

func (ChildWorkflowExecutionFailedCause) String added in v0.18.0 

func (e ChildWorkflowExecutionFailedCause) String() string

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 

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

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 (err ClientVersionNotSupportedError) Error() string

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

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 

func (e ContinueAsNewInitiator) Ptr() *ContinueAsNewInitiator

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 

func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetInitiator() (o ContinueAsNewInitiator)

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 

func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetSearchAttributes() (o *SearchAttributes)

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
}

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

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

CrossClusterStartChildExecutionRequestAttributes is an internal type (TBD...)

func (*CrossClusterStartChildExecutionRequestAttributes) GetInitiatedEventAttributes added in v0.23.1 

func (v *CrossClusterStartChildExecutionRequestAttributes) GetInitiatedEventAttributes() (o *StartChildWorkflowExecutionInitiatedEventAttributes)

GetInitiatedEventAttributes is an internal getter (TBD...)

func (*CrossClusterStartChildExecutionRequestAttributes) GetRequestID added in v0.23.1 

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

GetRequestID is an internal getter (TBD...)

func (*CrossClusterStartChildExecutionRequestAttributes) GetTargetRunID added in v0.23.1 

func (v *CrossClusterStartChildExecutionRequestAttributes) GetTargetRunID() (o string)

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 

func (v *CrossClusterStartChildExecutionResponseAttributes) GetRunID() (o string)

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 

func (e CrossClusterTaskFailedCause) Ptr() *CrossClusterTaskFailedCause

Ptr is a helper function for getting pointer value

func (CrossClusterTaskFailedCause) String added in v0.23.1 

func (e CrossClusterTaskFailedCause) String() string

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 

func (e CrossClusterTaskType) Ptr() *CrossClusterTaskType

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

func (e DecisionTaskFailedCause) Ptr() *DecisionTaskFailedCause

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

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 

func (v *DecisionTaskFailedEventAttributes) GetCause() (o DecisionTaskFailedCause)

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

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 

func (e DecisionTaskTimedOutCause) Ptr() *DecisionTaskTimedOutCause

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

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

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

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

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

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

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

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

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

DomainConfiguration is an internal type (TBD...)

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

func (e DomainOperation) Ptr() *DomainOperation

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 

func (v *DomainReplicationConfiguration) GetClusters() (o []*ClusterReplicationConfiguration)

GetClusters is an internal getter (TBD...)

type DomainStatus 

type DomainStatus int32

DomainStatus is an internal type (TBD...) 

const (
	// DomainStatusRegistered is an option for DomainStatus
	DomainStatusRegistered DomainStatus = iota
	// DomainStatusDeprecated is an option for DomainStatus
	DomainStatusDeprecated
	// DomainStatusDeleted is an option for DomainStatus
	DomainStatusDeleted
)

func (DomainStatus) MarshalText added in v0.18.0 

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

MarshalText encodes DomainStatus to text.

func (DomainStatus) Ptr added in v0.17.0 

func (e DomainStatus) Ptr() *DomainStatus

Ptr is a helper function for getting pointer value

func (DomainStatus) String added in v0.18.0 

func (e DomainStatus) String() string

String returns a readable string representation of DomainStatus.

func (*DomainStatus) UnmarshalText added in v0.18.0 

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

UnmarshalText parses enum value from string representation

type DomainTaskAttributes added in v0.17.0 

type DomainTaskAttributes struct {
	DomainOperation         *DomainOperation                `json:"domainOperation,omitempty"`
	ID                      string                          `json:"id,omitempty"`
	Info                    *DomainInfo                     `json:"info,omitempty"`
	Config                  *DomainConfiguration            `json:"config,omitempty"`
	ReplicationConfig       *DomainReplicationConfiguration `json:"replicationConfig,omitempty"`
	ConfigVersion           int64                           `json:"configVersion,omitempty"`
	FailoverVersion         int64                           `json:"failoverVersion,omitempty"`
	PreviousFailoverVersion int64                           `json:"previousFailoverVersion,omitempty"`
}

DomainTaskAttributes is an internal type (TBD...)

func (*DomainTaskAttributes) GetConfigVersion added in v0.17.0 

func (v *DomainTaskAttributes) GetConfigVersion() (o int64)

GetConfigVersion is an internal getter (TBD...)

func (*DomainTaskAttributes) GetDomainOperation added in v0.17.0 

func (v *DomainTaskAttributes) GetDomainOperation() (o DomainOperation)

GetDomainOperation is an internal getter (TBD...)

func (*DomainTaskAttributes) GetFailoverVersion added in v0.17.0 

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

GetFailoverVersion is an internal getter (TBD...)

func (*DomainTaskAttributes) GetID added in v0.17.0 

func (v *DomainTaskAttributes) GetID() (o string)

GetID is an internal getter (TBD...)

func (*DomainTaskAttributes) GetInfo added in v0.17.0 

func (v *DomainTaskAttributes) GetInfo() (o *DomainInfo)

GetInfo is an internal getter (TBD...)

func (*DomainTaskAttributes) GetPreviousFailoverVersion added in v0.17.0 

func (v *DomainTaskAttributes) GetPreviousFailoverVersion() (o int64)

GetPreviousFailoverVersion is an internal getter (TBD...)

type DynamicConfigBlob added in v0.23.1 

type DynamicConfigBlob struct {
	SchemaVersion int64                 `json:"schemaVersion,omitempty"`
	Entries       []*DynamicConfigEntry `json:"entries,omitempty"`
}

type DynamicConfigEntry added in v0.23.1 

type DynamicConfigEntry struct {
	Name   string                `json:"name,omitempty"`
	Values []*DynamicConfigValue `json:"values,omitempty"`
}

type DynamicConfigFilter added in v0.23.1 

type DynamicConfigFilter struct {
	Name  string    `json:"name,omitempty"`
	Value *DataBlob `json:"value,omitempty"`
}

type DynamicConfigValue added in v0.23.1 

type DynamicConfigValue struct {
	Value   *DataBlob              `json:"value,omitempty"`
	Filters []*DynamicConfigFilter `json:"filters,omitempty"`
}

type EncodingType 

type EncodingType int32

EncodingType is an internal type (TBD...) 

const (
	// EncodingTypeThriftRW is an option for EncodingType
	EncodingTypeThriftRW EncodingType = iota
	// EncodingTypeJSON is an option for EncodingType
	EncodingTypeJSON
)

func (EncodingType) MarshalText added in v0.18.0 

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

MarshalText encodes EncodingType to text.

func (EncodingType) Ptr added in v0.17.0 

func (e EncodingType) Ptr() *EncodingType

Ptr is a helper function for getting pointer value

func (EncodingType) String added in v0.18.0 

func (e EncodingType) String() string

String returns a readable string representation of EncodingType.

func (*EncodingType) UnmarshalText added in v0.18.0 

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

UnmarshalText parses enum value from string representation

type EntityNotExistsError 

type EntityNotExistsError struct {
	Message        string `json:"message,required"`
	CurrentCluster string `json:"currentCluster,omitempty"`
	ActiveCluster  string `json:"activeCluster,omitempty"`
}

EntityNotExistsError is an internal type (TBD...)

func (EntityNotExistsError) Error 

func (err EntityNotExistsError) Error() string

type EventAlreadyStartedError added in v0.17.0 

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

EventAlreadyStartedError is an internal type (TBD...)

func (EventAlreadyStartedError) Error added in v0.17.0 

func (err EventAlreadyStartedError) Error() string

type EventType 

type EventType int32

EventType is an internal type (TBD...) 

const (
	// EventTypeWorkflowExecutionStarted is an option for EventType
	EventTypeWorkflowExecutionStarted EventType = iota
	// EventTypeWorkflowExecutionCompleted is an option for EventType
	EventTypeWorkflowExecutionCompleted
	// EventTypeWorkflowExecutionFailed is an option for EventType
	EventTypeWorkflowExecutionFailed
	// EventTypeWorkflowExecutionTimedOut is an option for EventType
	EventTypeWorkflowExecutionTimedOut
	// EventTypeDecisionTaskScheduled is an option for EventType
	EventTypeDecisionTaskScheduled
	// EventTypeDecisionTaskStarted is an option for EventType
	EventTypeDecisionTaskStarted
	// EventTypeDecisionTaskCompleted is an option for EventType
	EventTypeDecisionTaskCompleted
	// EventTypeDecisionTaskTimedOut is an option for EventType
	EventTypeDecisionTaskTimedOut
	// EventTypeDecisionTaskFailed is an option for EventType
	EventTypeDecisionTaskFailed
	// EventTypeActivityTaskScheduled is an option for EventType
	EventTypeActivityTaskScheduled
	// EventTypeActivityTaskStarted is an option for EventType
	EventTypeActivityTaskStarted
	// EventTypeActivityTaskCompleted is an option for EventType
	EventTypeActivityTaskCompleted
	// EventTypeActivityTaskFailed is an option for EventType
	EventTypeActivityTaskFailed
	// EventTypeActivityTaskTimedOut is an option for EventType
	EventTypeActivityTaskTimedOut
	// EventTypeActivityTaskCancelRequested is an option for EventType
	EventTypeActivityTaskCancelRequested
	// EventTypeRequestCancelActivityTaskFailed is an option for EventType
	EventTypeRequestCancelActivityTaskFailed
	// EventTypeActivityTaskCanceled is an option for EventType
	EventTypeActivityTaskCanceled
	// EventTypeTimerStarted is an option for EventType
	EventTypeTimerStarted
	// EventTypeTimerFired is an option for EventType
	EventTypeTimerFired
	// EventTypeCancelTimerFailed is an option for EventType
	EventTypeCancelTimerFailed
	// EventTypeTimerCanceled is an option for EventType
	EventTypeTimerCanceled
	// EventTypeWorkflowExecutionCancelRequested is an option for EventType
	EventTypeWorkflowExecutionCancelRequested
	// EventTypeWorkflowExecutionCanceled is an option for EventType
	EventTypeWorkflowExecutionCanceled
	// EventTypeRequestCancelExternalWorkflowExecutionInitiated is an option for EventType
	EventTypeRequestCancelExternalWorkflowExecutionInitiated
	// EventTypeRequestCancelExternalWorkflowExecutionFailed is an option for EventType
	EventTypeRequestCancelExternalWorkflowExecutionFailed
	// EventTypeExternalWorkflowExecutionCancelRequested is an option for EventType
	EventTypeExternalWorkflowExecutionCancelRequested
	// EventTypeMarkerRecorded is an option for EventType
	EventTypeMarkerRecorded
	// EventTypeWorkflowExecutionSignaled is an option for EventType
	EventTypeWorkflowExecutionSignaled
	// EventTypeWorkflowExecutionTerminated is an option for EventType
	EventTypeWorkflowExecutionTerminated
	// EventTypeWorkflowExecutionContinuedAsNew is an option for EventType
	EventTypeWorkflowExecutionContinuedAsNew
	// EventTypeStartChildWorkflowExecutionInitiated is an option for EventType
	EventTypeStartChildWorkflowExecutionInitiated
	// EventTypeStartChildWorkflowExecutionFailed is an option for EventType
	EventTypeStartChildWorkflowExecutionFailed
	// EventTypeChildWorkflowExecutionStarted is an option for EventType
	EventTypeChildWorkflowExecutionStarted
	// EventTypeChildWorkflowExecutionCompleted is an option for EventType
	EventTypeChildWorkflowExecutionCompleted
	// EventTypeChildWorkflowExecutionFailed is an option for EventType
	EventTypeChildWorkflowExecutionFailed
	// EventTypeChildWorkflowExecutionCanceled is an option for EventType
	EventTypeChildWorkflowExecutionCanceled
	// EventTypeChildWorkflowExecutionTimedOut is an option for EventType
	EventTypeChildWorkflowExecutionTimedOut
	// EventTypeChildWorkflowExecutionTerminated is an option for EventType
	EventTypeChildWorkflowExecutionTerminated
	// EventTypeSignalExternalWorkflowExecutionInitiated is an option for EventType
	EventTypeSignalExternalWorkflowExecutionInitiated
	// EventTypeSignalExternalWorkflowExecutionFailed is an option for EventType
	EventTypeSignalExternalWorkflowExecutionFailed
	// EventTypeExternalWorkflowExecutionSignaled is an option for EventType
	EventTypeExternalWorkflowExecutionSignaled
	// EventTypeUpsertWorkflowSearchAttributes is an option for EventType
	EventTypeUpsertWorkflowSearchAttributes
)

func EventTypeValues added in v0.18.0 

func EventTypeValues() []EventType

EventTypeValues returns all recognized values of EventType.

func (EventType) MarshalText added in v0.18.0 

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

MarshalText encodes EventType to text.

func (EventType) Ptr added in v0.17.0 

func (e EventType) Ptr() *EventType

Ptr is a helper function for getting pointer value

func (EventType) String added in v0.18.0 

func (e EventType) String() string

String returns a readable string representation of EventType.

func (*EventType) UnmarshalText added in v0.18.0 

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

UnmarshalText parses enum value from string representation

type ExternalWorkflowExecutionCancelRequestedEventAttributes 

type ExternalWorkflowExecutionCancelRequestedEventAttributes struct {
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	Domain            string             `json:"domain,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
}

ExternalWorkflowExecutionCancelRequestedEventAttributes is an internal type (TBD...)

func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) GetDomain added in v0.17.0 

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

GetDomain is an internal getter (TBD...)

func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) GetInitiatedEventID added in v0.17.0 

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

GetInitiatedEventID is an internal getter (TBD...)

type ExternalWorkflowExecutionSignaledEventAttributes 

type ExternalWorkflowExecutionSignaledEventAttributes struct {
	InitiatedEventID  int64              `json:"initiatedEventId,omitempty"`
	Domain            string             `json:"domain,omitempty"`
	WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
	Control           []byte             `json:"control,omitempty"`
}

ExternalWorkflowExecutionSignaledEventAttributes is an internal type (TBD...)

func (*ExternalWorkflowExecutionSignaledEventAttributes) GetDomain added in v0.17.0 

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

GetDomain is an internal getter (TBD...)

func (*ExternalWorkflowExecutionSignaledEventAttributes) GetInitiatedEventID added in v0.17.0 

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

GetInitiatedEventID is an internal getter (TBD...)

type FailWorkflowExecutionDecisionAttributes 

type FailWorkflowExecutionDecisionAttributes struct {
	Reason  *string `json:"reason,omitempty"`
	Details []byte  `json:"details,omitempty"`
}

FailWorkflowExecutionDecisionAttributes is an internal type (TBD...)

func (*FailWorkflowExecutionDecisionAttributes) GetReason added in v0.17.0 

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

GetReason is an internal getter (TBD...)

type FailoverInfo added in v0.24.0 

type FailoverInfo struct {
	FailoverVersion         int64   `json:"failoverVersion,omitempty"`
	FailoverStartTimestamp  int64   `json:"failoverStartTimestamp,omitempty"`
	FailoverExpireTimestamp int64   `json:"failoverExpireTimestamp,omitempty"`
	CompletedShardCount     int32   `json:"completedShardCount,omitempty"`
	PendingShards           []int32 `json:"pendingShards,omitempty"`
}

FailoverInfo is an internal type (TBD...)

func (*FailoverInfo) GetCompletedShardCount added in v0.24.0 

func (v *FailoverInfo) GetCompletedShardCount() (o int32)

GetCompletedShardCount is an internal getter (TBD...)

func (*FailoverInfo) GetFailoverExpireTimestamp added in v0.24.0 

func (v *FailoverInfo) GetFailoverExpireTimestamp() (o int64)

GetFailoverExpireTimestamp is an internal getter (TBD...)

func (*FailoverInfo) GetFailoverStartTimestamp added in v0.24.0 

func (v *FailoverInfo) GetFailoverStartTimestamp() (o int64)

GetFailoverStartTimestamp is an internal getter (TBD...)

func (*FailoverInfo) GetFailoverVersion added in v0.24.0 

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

GetFailoverVersion is an internal getter (TBD...)

func (*FailoverInfo) GetPendingShards added in v0.24.0 

func (v *FailoverInfo) GetPendingShards() (o []int32)

GetPendingShards is an internal getter (TBD...)

type FailoverMarkerAttributes added in v0.17.0 

type FailoverMarkerAttributes struct {
	DomainID        string `json:"domainID,omitempty"`
	FailoverVersion int64  `json:"failoverVersion,omitempty"`
	CreationTime    *int64 `json:"creationTime,omitempty"`
}

FailoverMarkerAttributes is an internal type (TBD...)

func (*FailoverMarkerAttributes) GetCreationTime added in v0.17.0 

func (v *FailoverMarkerAttributes) GetCreationTime() (o int64)

GetCreationTime is an internal getter (TBD...)

func (*FailoverMarkerAttributes) GetDomainID added in v0.17.0 

func (v *FailoverMarkerAttributes) GetDomainID() (o string)

GetDomainID is an internal getter (TBD...)

func (*FailoverMarkerAttributes) GetFailoverVersion added in v0.17.0 

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

GetFailoverVersion is an internal getter (TBD...)

type FailoverMarkerToken added in v0.17.0 

type FailoverMarkerToken struct {
	ShardIDs       []int32                   `json:"shardIDs,omitempty"`
	FailoverMarker *FailoverMarkerAttributes `json:"failoverMarker,omitempty"`
}

FailoverMarkerToken is an internal type (TBD...)

func (*FailoverMarkerToken) GetFailoverMarker added in v0.17.0 

func (v *FailoverMarkerToken) GetFailoverMarker() (o *FailoverMarkerAttributes)

GetFailoverMarker is an internal getter (TBD...)

func (*FailoverMarkerToken) GetShardIDs added in v0.17.0 

func (v *FailoverMarkerToken) GetShardIDs() (o []int32)

GetShardIDs is an internal getter (TBD...)

type FailoverMarkers added in v0.17.0 

type FailoverMarkers struct {
	FailoverMarkers []*FailoverMarkerAttributes `json:"failoverMarkers,omitempty"`
}

FailoverMarkers is an internal type (TBD...)

type FeatureNotEnabledError added in v0.22.0 

type FeatureNotEnabledError struct {
	FeatureFlag string `json:"featureFlag,required"`
}

FeatureNotEnabledError is an internal type (TBD...)

func (FeatureNotEnabledError) Error added in v0.22.0 

func (err FeatureNotEnabledError) Error() string

func (FeatureNotEnabledError) MarshalLogObject added in v0.25.0 

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

type GetCrossClusterTasksRequest added in v0.23.1 

type GetCrossClusterTasksRequest struct {
	ShardIDs      []int32 `json:"shardIDs,omitempty"`
	TargetCluster string  `json:"targetCluster,omitempty"`
}

GetCrossClusterTasksRequest is an internal type (TBD...)

func (*GetCrossClusterTasksRequest) GetShardIDs added in v0.23.1 

func (v *GetCrossClusterTasksRequest) GetShardIDs() (o []int32)

GetShardIDs is an internal getter (TBD...)

func (*GetCrossClusterTasksRequest) GetTargetCluster added in v0.23.1 

func (v *GetCrossClusterTasksRequest) GetTargetCluster() (o string)

GetTargetCluster is an internal getter (TBD...)

type GetCrossClusterTasksResponse added in v0.23.1 

type GetCrossClusterTasksResponse struct {
	TasksByShard       map[int32][]*CrossClusterTaskRequest `json:"tasksByShard,omitempty"`
	FailedCauseByShard map[int32]GetTaskFailedCause         `json:"failedCauseByShard,omitempty"`
}

GetCrossClusterTasksResponse is an internal type (TBD...)

func (*GetCrossClusterTasksResponse) GetTasksByShard added in v0.23.1 

func (v *GetCrossClusterTasksResponse) GetTasksByShard() (o map[int32][]*CrossClusterTaskRequest)

GetTasksByShard is an internal getter (TBD...)

type GetDLQReplicationMessagesRequest added in v0.17.0 

type GetDLQReplicationMessagesRequest struct {
	TaskInfos []*ReplicationTaskInfo `json:"taskInfos,omitempty"`
}

GetDLQReplicationMessagesRequest is an internal type (TBD...)

func (*GetDLQReplicationMessagesRequest) GetTaskInfos added in v0.17.0 

func (v *GetDLQReplicationMessagesRequest) GetTaskInfos() (o []*ReplicationTaskInfo)

GetTaskInfos is an internal getter (TBD...)

type GetDLQReplicationMessagesResponse added in v0.17.0 

type GetDLQReplicationMessagesResponse struct {
	ReplicationTasks []*ReplicationTask `json:"replicationTasks,omitempty"`
}

GetDLQReplicationMessagesResponse is an internal type (TBD...)

type GetDomainReplicationMessagesRequest added in v0.17.0 

type GetDomainReplicationMessagesRequest struct {
	LastRetrievedMessageID *int64 `json:"lastRetrievedMessageId,omitempty"`
	LastProcessedMessageID *int64 `json:"lastProcessedMessageId,omitempty"`
	ClusterName            string `json:"clusterName,omitempty"`
}

GetDomainReplicationMessagesRequest is an internal type (TBD...)

func (*GetDomainReplicationMessagesRequest) GetClusterName added in v0.17.0 

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

GetClusterName is an internal getter (TBD...)

func (*GetDomainReplicationMessagesRequest) GetLastProcessedMessageID added in v0.17.0 

func (v *GetDomainReplicationMessagesRequest) GetLastProcessedMessageID() (o int64)

GetLastProcessedMessageID is an internal getter (TBD...)

func (*GetDomainReplicationMessagesRequest) GetLastRetrievedMessageID added in v0.17.0 

func (v *GetDomainReplicationMessagesRequest) GetLastRetrievedMessageID() (o int64)

GetLastRetrievedMessageID is an internal getter (TBD...)

type GetDomainReplicationMessagesResponse added in v0.17.0 

type GetDomainReplicationMessagesResponse struct {
	Messages *ReplicationMessages `json:"messages,omitempty"`
}

GetDomainReplicationMessagesResponse is an internal type (TBD...)

type GetDynamicConfigRequest added in v0.23.1 

type GetDynamicConfigRequest struct {
	ConfigName string                 `json:"configName,omitempty"`
	Filters    []*DynamicConfigFilter `json:"filters,omitempty"`
}

type GetDynamicConfigResponse added in v0.23.1 

type GetDynamicConfigResponse struct {
	Value *DataBlob `json:"value,omitempty"`
}

type GetFailoverInfoRequest added in v0.24.0 

type GetFailoverInfoRequest struct {
	DomainID string `json:"domainID,omitempty"`
}

GetFailoverInfoRequest is an internal type (TBD...)

func (*GetFailoverInfoRequest) GetDomainID added in v0.24.0 

func (v *GetFailoverInfoRequest) GetDomainID() (o string)

GetDomainID is an internal getter (TBD...)

type GetFailoverInfoResponse added in v0.24.0 

type GetFailoverInfoResponse struct {
	CompletedShardCount int32   `json:"completedShardCount,omitempty"`
	PendingShards       []int32 `json:"pendingShards,omitempty"`
}

GetFailoverInfoResponse is an internal type (TBD...)

func (*GetFailoverInfoResponse) GetCompletedShardCount added in v0.24.0 

func (v *GetFailoverInfoResponse) GetCompletedShardCount() (o int32)

GetCompletedShardCount is an internal getter (TBD...)

func (*GetFailoverInfoResponse) GetPendingShards added in v0.24.0 

func (v *GetFailoverInfoResponse) GetPendingShards() (o []int32)

GetPendingShards is an internal getter (TBD...)

type GetMutableStateRequest added in v0.17.0 

type GetMutableStateRequest struct {
	DomainUUID          string             `json:"domainUUID,omitempty"`
	Execution           *WorkflowExecution `json:"execution,omitempty"`
	ExpectedNextEventID int64              `json:"expectedNextEventId,omitempty"`
	CurrentBranchToken  []byte             `json:"currentBranchToken,omitempty"`
}

GetMutableStateRequest is an internal type (TBD...)

func (*GetMutableStateRequest) GetDomainUUID added in v0.17.0 

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

GetDomainUUID is an internal getter (TBD...)

func (*GetMutableStateRequest) GetExpectedNextEventID added in v0.17.0 

func (v *GetMutableStateRequest) GetExpectedNextEventID() (o int64)

GetExpectedNextEventID is an internal getter (TBD...)

type GetMutableStateResponse added in v0.17.0 

type GetMutableStateResponse struct {
	Execution                            *WorkflowExecution `json:"execution,omitempty"`
	WorkflowType                         *WorkflowType      `json:"workflowType,omitempty"`
	NextEventID                          int64              `json:"NextEventId,omitempty"`
	PreviousStartedEventID               *int64             `json:"PreviousStartedEventId,omitempty"`
	LastFirstEventID                     int64              `json:"LastFirstEventId,omitempty"`
	TaskList                             *TaskList          `json:"taskList,omitempty"`
	StickyTaskList                       *TaskList          `json:"stickyTaskList,omitempty"`
	ClientLibraryVersion                 string             `json:"clientLibraryVersion,omitempty"`
	ClientFeatureVersion                 string             `json:"clientFeatureVersion,omitempty"`
	ClientImpl                           string             `json:"clientImpl,omitempty"`
	IsWorkflowRunning                    bool               `json:"isWorkflowRunning,omitempty"`
	StickyTaskListScheduleToStartTimeout *int32             `json:"stickyTaskListScheduleToStartTimeout,omitempty"`
	EventStoreVersion                    int32              `json:"eventStoreVersion,omitempty"`
	CurrentBranchToken                   []byte             `json:"currentBranchToken,omitempty"`
	WorkflowState                        *int32             `json:"workflowState,omitempty"`
	WorkflowCloseState                   *int32             `json:"workflowCloseState,omitempty"`
	VersionHistories                     *VersionHistories  `json:"versionHistories,omitempty"`
	IsStickyTaskListEnabled              bool               `json:"isStickyTaskListEnabled,omitempty"`
}

GetMutableStateResponse is an internal type (TBD...)

func (*GetMutableStateResponse) GetClientFeatureVersion added in v0.17.0 

func (v *GetMutableStateResponse) GetClientFeatureVersion() (o string)

GetClientFeatureVersion is an internal getter (TBD...)

func (*GetMutableStateResponse) GetClientImpl added in v0.17.0 

func (v *GetMutableStateResponse) GetClientImpl() (o string)

GetClientImpl is an internal getter (TBD...)

func (*GetMutableStateResponse) GetCurrentBranchToken added in v0.17.0