types

package

Go to main page

Versions in this module

v1

v1.2.15-prerelease05

Nov 27, 2024

v1.2.15-prerelease04

Nov 27, 2024

v1.2.15-prerelease02

Nov 15, 2024

v1.2.15-prerelease01

Oct 31, 2024

v1.2.14

Oct 18, 2024

Changes in this version

+ type AddActivityTaskResponse struct

+ PartitionConfig *TaskListPartitionConfig

+ type AddDecisionTaskResponse struct

+ PartitionConfig *TaskListPartitionConfig

+ type DiagnoseWorkflowExecutionRequest struct

+ Domain string

+ Identity string

+ WorkflowExecution *WorkflowExecution

+ func (v *DiagnoseWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *DiagnoseWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *DiagnoseWorkflowExecutionRequest) SerializeForLogging() (string, error)

+ type DiagnoseWorkflowExecutionResponse struct

+ DiagnosticWorkflowExecution *WorkflowExecution

+ Domain string

+ func (v *DiagnoseWorkflowExecutionResponse) GetDiagnosticWorkflowExecution() (o *WorkflowExecution)

+ func (v *DiagnoseWorkflowExecutionResponse) GetDomain() (o string)

+ type MatchingPollForActivityTaskResponse struct

+ ActivityID string

+ ActivityType *ActivityType

+ Attempt int32

+ BacklogCountHint int64

+ Header *Header

+ HeartbeatDetails []byte

+ HeartbeatTimeoutSeconds *int32

+ Input []byte

+ PartitionConfig *TaskListPartitionConfig

+ ScheduleToCloseTimeoutSeconds *int32

+ ScheduledTimestamp *int64

+ ScheduledTimestampOfThisAttempt *int64

+ StartToCloseTimeoutSeconds *int32

+ StartedTimestamp *int64

+ TaskToken []byte

+ WorkflowDomain string

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

type MatchingPollForDecisionTaskResponse

+ PartitionConfig *TaskListPartitionConfig

+ type TaskListPartitionConfig struct

+ NumReadPartitions int32

+ NumWritePartitions int32

+ Version int64

v1.2.14-prerelease14

Nov 12, 2024

v1.2.14-prerelease13

Nov 6, 2024

v1.2.14-prerelease12

Oct 31, 2024

v1.2.14-prerelease11

Oct 18, 2024

v1.2.14-prerelease10

Oct 16, 2024

v1.2.14-prerelease09

Oct 10, 2024

v1.2.14-prerelease08

Oct 8, 2024

v1.2.14-prerelease07

Oct 8, 2024

v1.2.14-prerelease06

Oct 7, 2024

v1.2.14-prerelease05

Oct 4, 2024

v1.2.14-prerelease04

Oct 2, 2024

v1.2.14-prerelease03

Sep 26, 2024

v1.2.14-prerelease02

Sep 25, 2024

v1.2.14-prerelease01

Sep 12, 2024

v1.2.13

Sep 4, 2024

Changes in this version

type DynamicConfigEntry

+ func (dce *DynamicConfigEntry) Copy() *DynamicConfigEntry

type DynamicConfigFilter

+ func (dcf *DynamicConfigFilter) Copy() *DynamicConfigFilter

type DynamicConfigValue

+ func (dcv *DynamicConfigValue) Copy() *DynamicConfigValue

v1.2.13-prerelease13

Sep 12, 2024

v1.2.13-prerelease12

Sep 6, 2024

v1.2.13-prerelease11

Sep 4, 2024

v1.2.13-prerelease10

Aug 29, 2024

v1.2.13-prerelease09

Aug 28, 2024

v1.2.13-prerelease08

Aug 27, 2024

v1.2.13-prerelease07

Aug 27, 2024

v1.2.13-prerelease06

Aug 26, 2024

v1.2.13-prerelease05

Aug 22, 2024

v1.2.13-prerelease04

Aug 16, 2024

v1.2.13-prerelease03

Aug 12, 2024

v1.2.13-prerelease02

Aug 9, 2024

v1.2.13-prerelease01

Aug 7, 2024

v1.2.12

Jul 26, 2024

Changes in this version

type SignalWithStartWorkflowExecutionRequest

+ FirstRunAtTimestamp *int64

type StartChildWorkflowExecutionInitiatedEventAttributes

+ FirstRunAtTimestamp *int64

type StartWorkflowExecutionRequest

+ FirstRunAtTimeStamp *int64

+ func (v *StartWorkflowExecutionRequest) GetFirstRunAtTimeStamp() (o int64)

v1.2.12-prerelease7

Jul 26, 2024

v1.2.12-prerelease6

Jul 25, 2024

v1.2.12-prerelease5

Jul 17, 2024

v1.2.12-prerelease4

Jul 17, 2024

v1.2.12-prerelease3

Jul 10, 2024

v1.2.12-prerelease2

Jun 28, 2024

v1.2.12-prerelease1

Jun 27, 2024

v1.2.11

Jun 21, 2024

Changes in this version

+ type ListAllWorkflowExecutionsRequest struct

+ Domain string

+ MaximumPageSize int32

+ NextPageToken []byte

+ PartialMatch bool

+ SortColumn string

+ SortOrder string

+ StartTimeFilter *StartTimeFilter

+ StatusFilter []WorkflowExecutionCloseStatus

+ WorkflowSearchValue string

+ func (v *ListAllWorkflowExecutionsRequest) GetDomain() (o string)

+ func (v *ListAllWorkflowExecutionsRequest) GetMaximumPageSize() (o int32)

+ func (v *ListAllWorkflowExecutionsRequest) SerializeForLogging() (string, error)

+ type ListAllWorkflowExecutionsResponse struct

+ Executions []*WorkflowExecutionInfo

+ NextPageToken []byte

+ func (v *ListAllWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo)

+ func (v *ListAllWorkflowExecutionsResponse) GetNextPageToken() (o []byte)

v1.2.11-prerelease9

Jun 27, 2024

v1.2.11-prerelease8

Jun 27, 2024

v1.2.11-prerelease7

Jun 21, 2024

v1.2.11-prerelease6

Jun 21, 2024

v1.2.11-prerelease5

Jun 13, 2024

v1.2.11-prerelease4

Jun 12, 2024

v1.2.11-prerelease3

Jun 11, 2024

v1.2.11-prerelease2

Jun 3, 2024

v1.2.11-prerelease10

Jun 28, 2024

v1.2.11-prerelease1

May 30, 2024

v1.2.10

May 17, 2024

Changes in this version

+ type Any struct

+ Value []byte

+ ValueType string

type CancelExternalWorkflowExecutionFailedCause

+ const CancelExternalWorkflowExecutionFailedCauseWorkflowAlreadyCompleted

+ type RatelimitUpdateRequest struct

+ Any *Any

+ type RatelimitUpdateResponse struct

+ Any *Any

type RecordChildExecutionCompletedRequest

+ StartedID int64

type SignalExternalWorkflowExecutionFailedCause

+ const SignalExternalWorkflowExecutionFailedCauseWorkflowAlreadyCompleted

v1.2.10-prerelease7

May 30, 2024

v1.2.10-prerelease6

May 17, 2024

v1.2.10-prerelease5

May 13, 2024

v1.2.10-prerelease4

May 1, 2024

v1.2.10-prerelease3

Apr 29, 2024

v1.2.10-prerelease2

Apr 25, 2024

v1.2.10-prerelease1

Apr 24, 2024

v1.2.9

Apr 12, 2024

Changes in this version

type DecisionTaskFailedEventAttributes

+ RequestID string

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

type DecisionTaskTimedOutEventAttributes

+ RequestID string

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

type ServiceBusyError

+ Reason string

type WorkflowExecutionCancelRequestedEventAttributes

+ RequestID string

type WorkflowExecutionSignaledEventAttributes

+ RequestID string

+ func (v *WorkflowExecutionSignaledEventAttributes) GetRequestID() (o string)

type WorkflowExecutionStartedEventAttributes

+ RequestID string

+ func (v *WorkflowExecutionStartedEventAttributes) GetRequestID() (o string)

v1.2.9-prerelease7

Apr 29, 2024

v1.2.9-prerelease6

Apr 25, 2024

v1.2.9-prerelease5

Apr 24, 2024

v1.2.9-prerelease4

Apr 12, 2024

v1.2.9-prerelease3

Apr 9, 2024

v1.2.9-prerelease2

Mar 27, 2024

v1.2.9-prerelease1

Mar 19, 2024

v1.2.8

Mar 1, 2024

Changes in this version

type AsyncWorkflowConfiguration

+ Enabled bool

+ QueueConfig *DataBlob

+ func (c AsyncWorkflowConfiguration) DeepCopy() AsyncWorkflowConfiguration

type DataBlob

+ func (v *DataBlob) DeepCopy() *DataBlob

type DomainConfiguration

+ AsyncWorkflowConfig *AsyncWorkflowConfiguration

+ func (v *DomainConfiguration) GetAsyncWorkflowConfiguration() AsyncWorkflowConfiguration

type IsolationGroupConfiguration

+ func (i IsolationGroupConfiguration) DeepCopy() IsolationGroupConfiguration

+ type SignalWithStartWorkflowExecutionAsyncRequest struct

+ type SignalWithStartWorkflowExecutionAsyncResponse struct

+ type StartWorkflowExecutionAsyncRequest struct

+ type StartWorkflowExecutionAsyncResponse struct

v1.2.8-prerelease9

Mar 19, 2024

v1.2.8-prerelease8

Mar 1, 2024

v1.2.8-prerelease7

Feb 26, 2024

v1.2.8-prerelease6

Feb 22, 2024

v1.2.8-prerelease5

Feb 15, 2024

v1.2.8-prerelease4

Feb 12, 2024

v1.2.8-prerelease3

Feb 8, 2024

v1.2.8-prerelease2

Feb 5, 2024

v1.2.8-prerelease1

Jan 30, 2024

v1.2.7

Jan 23, 2024

Changes in this version

+ const AsyncWorkflowQueueTypeInvalid

+ const AsyncWorkflowQueueTypeKafka

+ type AsyncWorkflowConfiguration struct

+ KafkaConfig *AsyncWorkflowKafkaQueueConfiguration

+ PredefinedQueueName string

+ QueueType AsyncWorkflowQueueType

+ type AsyncWorkflowKafkaQueueConfiguration struct

+ Brokers []string

+ ConsumerGroup string

+ DLQTopic string

+ Properties map[string]string

+ Topic string

+ type AsyncWorkflowQueueType int

type CountDLQMessagesRequest

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

+ type GetDomainAsyncWorkflowConfiguratonRequest struct

+ Domain string

+ func (v *GetDomainAsyncWorkflowConfiguratonRequest) SerializeForLogging() (string, error)

+ type GetDomainAsyncWorkflowConfiguratonResponse struct

+ Configuration *AsyncWorkflowConfiguration

type GetDomainIsolationGroupsRequest

+ func (v *GetDomainIsolationGroupsRequest) SerializeForLogging() (string, error)

type GetGlobalIsolationGroupsRequest

+ func (v *GetGlobalIsolationGroupsRequest) SerializeForLogging() (string, error)

type MatchingPollForActivityTaskRequest

+ func (v *MatchingPollForActivityTaskRequest) GetTaskList() (o *TaskList)

type MatchingPollForDecisionTaskRequest

+ func (v *MatchingPollForDecisionTaskRequest) GetTaskList() (o *TaskList)

type RespondCrossClusterTasksCompletedRequest

+ func (v *RespondCrossClusterTasksCompletedRequest) SerializeForLogging() (string, error)

+ type UpdateDomainAsyncWorkflowConfiguratonRequest struct

+ Configuration *AsyncWorkflowConfiguration

+ Domain string

+ func (v *UpdateDomainAsyncWorkflowConfiguratonRequest) SerializeForLogging() (string, error)

+ type UpdateDomainAsyncWorkflowConfiguratonResponse struct

type UpdateDomainIsolationGroupsRequest

+ func (v *UpdateDomainIsolationGroupsRequest) SerializeForLogging() (string, error)

type UpdateGlobalIsolationGroupsRequest

+ func (v *UpdateGlobalIsolationGroupsRequest) SerializeForLogging() (string, error)

v1.2.7-prerelease7

Feb 8, 2024

v1.2.7-prerelease6

Feb 5, 2024

v1.2.7-prerelease5

Jan 30, 2024

v1.2.7-prerelease4

Jan 30, 2024

v1.2.7-prerelease3

Jan 23, 2024

v1.2.7-prerelease2

Dec 11, 2023

v1.2.7-prerelease1

Dec 8, 2023

v1.2.6

Dec 6, 2023

v1.2.6-prerelease5

Dec 11, 2023

v1.2.6-prerelease4

Dec 8, 2023

v1.2.6-prerelease3

Dec 6, 2023

v1.2.6-prerelease2

Nov 15, 2023

v1.2.6-prerelease1

Nov 6, 2023

v1.2.5

Oct 19, 2023

v1.2.5-prerelease3

Oct 19, 2023

v1.2.5-prerelease2

Oct 18, 2023

v1.2.5-prerelease1

Oct 3, 2023

v1.2.4

Sep 27, 2023

v1.2.3

Sep 15, 2023

retracted

Changes in this version

type GetMutableStateResponse

+ HistorySize int64

type MatchingPollForDecisionTaskResponse

+ TotalHistoryBytes int64

+ func (v *MatchingPollForDecisionTaskResponse) GetTotalHistoryBytes() (o int64)

type PollForDecisionTaskResponse

+ TotalHistoryBytes int64

+ func (v *PollForDecisionTaskResponse) GetHistorySize() (o int64)

type RecordDecisionTaskStartedResponse

+ HistorySize int64

v1.2.2

Aug 30, 2023

v1.2.1

Aug 28, 2023

Changes in this version

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

type AddActivityTaskRequest

+ PartitionConfig map[string]string

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

type AddDecisionTaskRequest

+ PartitionConfig map[string]string

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

type AddSearchAttributeRequest

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

type AdminDeleteWorkflowRequest

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

type AdminDescribeWorkflowExecutionRequest

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

type CloseShardRequest

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

type CountWorkflowExecutionsRequest

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

type CrossClusterStartChildExecutionRequestAttributes

+ PartitionConfig map[string]string

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

type DeprecateDomainRequest

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

type DescribeDomainRequest

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

type DescribeHistoryHostRequest

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

type DescribeQueueRequest

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

type DescribeShardDistributionRequest

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

type DescribeTaskListRequest

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

type DescribeWorkflowExecutionRequest

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

type DomainConfiguration

+ IsolationGroups *IsolationGroupConfiguration

+ func (v *DomainConfiguration) GetIsolationGroupsConfiguration() IsolationGroupConfiguration

type GetCrossClusterTasksRequest

+ func (v *GetCrossClusterTasksRequest) SerializeForLogging() (string, error)

type GetDLQReplicationMessagesRequest

+ func (v *GetDLQReplicationMessagesRequest) SerializeForLogging() (string, error)

+ type GetDomainIsolationGroupsRequest struct

+ Domain string

+ type GetDomainIsolationGroupsResponse struct

+ IsolationGroups IsolationGroupConfiguration

type GetDomainReplicationMessagesRequest

+ func (v *GetDomainReplicationMessagesRequest) SerializeForLogging() (string, error)

type GetDynamicConfigRequest

+ func (v *GetDynamicConfigRequest) SerializeForLogging() (string, error)

+ type GetGlobalIsolationGroupsRequest struct

+ type GetGlobalIsolationGroupsResponse struct

+ IsolationGroups IsolationGroupConfiguration

type GetReplicationMessagesRequest

+ func (v *GetReplicationMessagesRequest) SerializeForLogging() (string, error)

type GetTaskListsByDomainRequest

+ func (v *GetTaskListsByDomainRequest) SerializeForLogging() (string, error)

type GetWorkflowExecutionHistoryRequest

+ func (v *GetWorkflowExecutionHistoryRequest) SerializeForLogging() (string, error)

type GetWorkflowExecutionRawHistoryV2Request

+ func (v *GetWorkflowExecutionRawHistoryV2Request) SerializeForLogging() (string, error)

type HistorySignalWithStartWorkflowExecutionRequest

+ PartitionConfig map[string]string

+ func (v *HistorySignalWithStartWorkflowExecutionRequest) GetPartitionConfig() (o map[string]string)

type HistoryStartWorkflowExecutionRequest

+ PartitionConfig map[string]string

+ func (v *HistoryStartWorkflowExecutionRequest) GetPartitionConfig() (o map[string]string)

+ type IsolationGroupConfiguration map[string]IsolationGroupPartition

+ func FromIsolationGroupPartitionList(in []IsolationGroupPartition) IsolationGroupConfiguration

+ func (i IsolationGroupConfiguration) ToPartitionList() []IsolationGroupPartition

+ type IsolationGroupPartition struct

+ Name string

+ State IsolationGroupState

+ type IsolationGroupState int

+ const IsolationGroupStateDrained

+ const IsolationGroupStateHealthy

+ const IsolationGroupStateInvalid

type ListArchivedWorkflowExecutionsRequest

+ func (v *ListArchivedWorkflowExecutionsRequest) SerializeForLogging() (string, error)

type ListClosedWorkflowExecutionsRequest

+ func (v *ListClosedWorkflowExecutionsRequest) SerializeForLogging() (string, error)

type ListDomainsRequest

+ func (v *ListDomainsRequest) SerializeForLogging() (string, error)

type ListDynamicConfigRequest

+ func (v *ListDynamicConfigRequest) SerializeForLogging() (string, error)

type ListOpenWorkflowExecutionsRequest

+ func (v *ListOpenWorkflowExecutionsRequest) SerializeForLogging() (string, error)

type ListTaskListPartitionsRequest

+ func (v *ListTaskListPartitionsRequest) SerializeForLogging() (string, error)

type ListWorkflowExecutionsRequest

+ func (v *ListWorkflowExecutionsRequest) SerializeForLogging() (string, error)

type MatchingPollForActivityTaskRequest

+ IsolationGroup string

+ func (v *MatchingPollForActivityTaskRequest) GetIsolationGroup() (o string)

type MatchingPollForDecisionTaskRequest

+ IsolationGroup string

+ func (v *MatchingPollForDecisionTaskRequest) GetIsolationGroup() (o string)

type MergeDLQMessagesRequest

+ func (v *MergeDLQMessagesRequest) SerializeForLogging() (string, error)

type PendingActivityInfo

+ StartedWorkerIdentity string

+ func (v *PendingActivityInfo) GetStartedWorkerIdentity() (o string)

type PollForActivityTaskRequest

+ func (v *PollForActivityTaskRequest) SerializeForLogging() (string, error)

type PollForDecisionTaskRequest

+ func (v *PollForDecisionTaskRequest) SerializeForLogging() (string, error)

type PurgeDLQMessagesRequest

+ func (v *PurgeDLQMessagesRequest) SerializeForLogging() (string, error)

type QueryWorkflowRequest

+ func (v *QueryWorkflowRequest) SerializeForLogging() (string, error)

type ReadDLQMessagesRequest

+ func (v *ReadDLQMessagesRequest) SerializeForLogging() (string, error)

type ReapplyEventsRequest

+ func (v *ReapplyEventsRequest) SerializeForLogging() (string, error)

type RecordActivityTaskHeartbeatRequest

+ func (v *RecordActivityTaskHeartbeatRequest) SerializeForLogging() (string, error)

type RefreshWorkflowTasksRequest

+ func (v *RefreshWorkflowTasksRequest) SerializeForLogging() (string, error)

type RegisterDomainRequest

+ func (v *RegisterDomainRequest) SerializeForLogging() (string, error)

type RemoveTaskRequest

+ func (v *RemoveTaskRequest) SerializeForLogging() (string, error)

type RequestCancelWorkflowExecutionRequest

+ func (v *RequestCancelWorkflowExecutionRequest) SerializeForLogging() (string, error)

type ResendReplicationTasksRequest

+ func (v *ResendReplicationTasksRequest) SerializeForLogging() (string, error)

type ResetQueueRequest

+ func (v *ResetQueueRequest) SerializeForLogging() (string, error)

type ResetStickyTaskListRequest

+ func (v *ResetStickyTaskListRequest) SerializeForLogging() (string, error)

type ResetWorkflowExecutionRequest

+ func (v *ResetWorkflowExecutionRequest) SerializeForLogging() (string, error)

type RestartWorkflowExecutionRequest

+ func (v *RestartWorkflowExecutionRequest) SerializeForLogging() (string, error)

type RestoreDynamicConfigRequest

+ func (v *RestoreDynamicConfigRequest) SerializeForLogging() (string, error)

type SignalWithStartWorkflowExecutionRequest

+ func (v *SignalWithStartWorkflowExecutionRequest) SerializeForLogging() (string, error)

type SignalWorkflowExecutionRequest

+ func (v *SignalWorkflowExecutionRequest) SerializeForLogging() (string, error)

type StartWorkflowExecutionRequest

+ func (v *StartWorkflowExecutionRequest) SerializeForLogging() (string, error)

type TerminateWorkflowExecutionRequest

+ func (v *TerminateWorkflowExecutionRequest) SerializeForLogging() (string, error)

+ type UpdateDomainIsolationGroupsRequest struct

+ Domain string

+ IsolationGroups IsolationGroupConfiguration

+ type UpdateDomainIsolationGroupsResponse struct

type UpdateDomainRequest

+ func (v *UpdateDomainRequest) SerializeForLogging() (string, error)

type UpdateDynamicConfigRequest

+ func (v *UpdateDynamicConfigRequest) SerializeForLogging() (string, error)

+ type UpdateGlobalIsolationGroupsRequest struct

+ IsolationGroups IsolationGroupConfiguration

+ type UpdateGlobalIsolationGroupsResponse struct

type WorkflowExecutionInfo

+ PartitionConfig map[string]string

+ func (v *WorkflowExecutionInfo) GetPartitionConfig() (o map[string]string)

type WorkflowExecutionStartedEventAttributes

+ PartitionConfig map[string]string

+ func (v *WorkflowExecutionStartedEventAttributes) GetPartitionConfig() (o map[string]string)

v1.0.0

Mar 17, 2023

Changes in this version

type RequestCancelWorkflowExecutionRequest

+ FirstExecutionRunID string

+ func (v *RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunID() (o string)

type TerminateWorkflowExecutionRequest

+ FirstExecutionRunID string

+ func (v *TerminateWorkflowExecutionRequest) GetFirstExecutionRunID() (o string)

type WorkflowExecutionInfo

+ UpdateTime *int64

+ func (v *WorkflowExecutionInfo) GetUpdateTime() (o int64)

v0

v0.25.0

Oct 12, 2022

Changes in this version

type ClientVersionNotSupportedError

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

type ContinueAsNewWorkflowExecutionDecisionAttributes

+ JitterStartSeconds *int32

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

+ type CountDLQMessagesRequest struct

+ ForceFetch bool

+ type CountDLQMessagesResponse struct

+ Domain int64

+ History map[HistoryDLQCountKey]int64

type CurrentBranchChangedError

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

type DomainNotActiveError

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

type FeatureNotEnabledError

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

+ type HistoryCountDLQMessagesResponse struct

+ Entries map[HistoryDLQCountKey]int64

+ type HistoryDLQCountKey struct

+ ShardID int32

+ SourceCluster string

type RequestCancelWorkflowExecutionRequest

+ Cause string

+ type RestartWorkflowExecutionRequest struct

+ Domain string

+ Identity string

+ WorkflowExecution *WorkflowExecution

+ func (v *RestartWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *RestartWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution)

+ type RestartWorkflowExecutionResponse struct

+ RunID string

+ func (v *RestartWorkflowExecutionResponse) GetRunID() (o string)

type RetryTaskV2Error

+ func (err RetryTaskV2Error) MarshalLogObject(enc zapcore.ObjectEncoder) error

type ShardOwnershipLostError

+ func (err ShardOwnershipLostError) MarshalLogObject(enc zapcore.ObjectEncoder) error

type SignalWithStartWorkflowExecutionRequest

+ JitterStartSeconds *int32

type StartChildWorkflowExecutionInitiatedEventAttributes

+ JitterStartSeconds *int32

type StartWorkflowExecutionRequest

+ JitterStartSeconds *int32

+ func (v *StartWorkflowExecutionRequest) GetJitterStartSeconds() (o int32)

+ type StickyWorkerUnavailableError struct

+ Message string

+ func (err StickyWorkerUnavailableError) Error() string

type WorkflowExecutionAlreadyStartedError

+ func (err WorkflowExecutionAlreadyStartedError) MarshalLogObject(enc zapcore.ObjectEncoder) error

type WorkflowExecutionContinuedAsNewEventAttributes

+ JitterStartSeconds *int32

type WorkflowExecutionStartedEventAttributes

+ FirstScheduleTime *time.Time

+ JitterStartSeconds *int32

+ func (v *WorkflowExecutionStartedEventAttributes) GetFirstScheduledTime() (o time.Time)

+ func (v *WorkflowExecutionStartedEventAttributes) GetJitterStartSeconds() (o int32)

v0.24.0

May 24, 2022

Changes in this version

+ type ActivityTaskDispatchInfo struct

+ Attempt *int64

+ HeartbeatDetails []byte

+ ScheduledEvent *HistoryEvent

+ ScheduledTimestampOfThisAttempt *int64

+ StartedTimestamp *int64

+ WorkflowDomain string

+ WorkflowType *WorkflowType

type AddActivityTaskRequest

+ ActivityTaskDispatchInfo *ActivityTaskDispatchInfo

+ type AdminDeleteWorkflowRequest struct

+ Domain string

+ Execution *WorkflowExecution

+ SkipErrors bool

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

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

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

+ type AdminDeleteWorkflowResponse struct

+ ExecutionsDeleted bool

+ HistoryDeleted bool

+ VisibilityDeleted bool

+ func (v *AdminDeleteWorkflowResponse) GetExecutionsDeleted() (o bool)

+ func (v *AdminDeleteWorkflowResponse) GetHistoryDeleted() (o bool)

+ func (v *AdminDeleteWorkflowResponse) GetVisibilityDeleted() (o bool)

+ type AdminMaintainWorkflowRequest = AdminDeleteWorkflowRequest

+ type AdminMaintainWorkflowResponse = AdminDeleteWorkflowResponse

+ type ApplyParentClosePolicyAttributes struct

+ ChildDomainID string

+ ChildRunID string

+ ChildWorkflowID string

+ ParentClosePolicy *ParentClosePolicy

+ func (v *ApplyParentClosePolicyAttributes) GetDomainID() (o string)

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

+ func (v *ApplyParentClosePolicyAttributes) GetRunID() (o string)

+ func (v *ApplyParentClosePolicyAttributes) GetWorkflowID() (o string)

+ type ApplyParentClosePolicyRequest struct

+ Child *ApplyParentClosePolicyAttributes

+ Status *ApplyParentClosePolicyStatus

+ func (v *ApplyParentClosePolicyRequest) GetChild() (o *ApplyParentClosePolicyAttributes)

+ func (v *ApplyParentClosePolicyRequest) GetStatus() (o *ApplyParentClosePolicyStatus)

+ type ApplyParentClosePolicyResult struct

+ Child *ApplyParentClosePolicyAttributes

+ FailedCause *CrossClusterTaskFailedCause

+ func (v *ApplyParentClosePolicyResult) GetChild() (o *ApplyParentClosePolicyAttributes)

+ func (v *ApplyParentClosePolicyResult) GetFailedCause() (o CrossClusterTaskFailedCause)

+ type ApplyParentClosePolicyStatus struct

+ Completed bool

+ FailedCause *CrossClusterTaskFailedCause

+ func (v *ApplyParentClosePolicyStatus) GetCompleted() (o bool)

+ func (v *ApplyParentClosePolicyStatus) GetFailedCause() (o CrossClusterTaskFailedCause)

+ type CrossClusterApplyParentClosePolicyRequestAttributes struct

+ Children []*ApplyParentClosePolicyRequest

+ func (v *CrossClusterApplyParentClosePolicyRequestAttributes) GetChildren() (o []*ApplyParentClosePolicyRequest)

+ type CrossClusterApplyParentClosePolicyResponseAttributes struct

+ ChildrenStatus []*ApplyParentClosePolicyResult

+ func (v *CrossClusterApplyParentClosePolicyResponseAttributes) GetChildrenStatus() (o []*ApplyParentClosePolicyResult)

type CrossClusterTaskRequest

+ ApplyParentClosePolicyAttributes *CrossClusterApplyParentClosePolicyRequestAttributes

+ func (v *CrossClusterTaskRequest) GetApplyParentClosePolicyAttributes() (o *CrossClusterApplyParentClosePolicyRequestAttributes)

type CrossClusterTaskResponse

+ ApplyParentClosePolicyAttributes *CrossClusterApplyParentClosePolicyResponseAttributes

+ TaskState int16

+ func (v *CrossClusterTaskResponse) GetApplyParenctClosePolicyAttributes() (o *CrossClusterApplyParentClosePolicyResponseAttributes)

+ func (v *CrossClusterTaskResponse) GetTaskState() (o int16)

type CrossClusterTaskType

+ const CrossClusterTaskTypeApplyParentPolicy

+ const CrossClusterTaskTypeRecordChildWorkflowExeuctionComplete

type DescribeDomainResponse

+ FailoverInfo *FailoverInfo

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

+ type FailoverInfo struct

+ CompletedShardCount int32

+ FailoverExpireTimestamp int64

+ FailoverStartTimestamp int64

+ FailoverVersion int64

+ PendingShards []int32

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

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

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

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

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

+ type GetFailoverInfoRequest struct

+ DomainID string

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

+ type GetFailoverInfoResponse struct

+ CompletedShardCount int32

+ PendingShards []int32

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

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

type GetTaskListsByDomainResponse

+ ActivityTaskListMap map[string]*DescribeTaskListResponse

+ DecisionTaskListMap map[string]*DescribeTaskListResponse

+ func (v *GetTaskListsByDomainResponse) GetActivityTaskListMap() (o map[string]*DescribeTaskListResponse)

+ func (v *GetTaskListsByDomainResponse) GetDecisionTaskListMap() (o map[string]*DescribeTaskListResponse)

type HistoryEvent

+ ID int64

type HistoryTerminateWorkflowExecutionRequest

+ ChildWorkflowOnly bool

+ ExternalWorkflowExecution *WorkflowExecution

+ func (v *HistoryTerminateWorkflowExecutionRequest) GetChildWorkflowOnly() (o bool)

+ func (v *HistoryTerminateWorkflowExecutionRequest) GetExternalWorkflowExecution() (o *WorkflowExecution)

type PendingChildExecutionInfo

+ Domain string

+ WorkflowTypeName string

+ func (v *PendingChildExecutionInfo) GetDomain() (o string)

+ func (v *PendingChildExecutionInfo) GetWorkflowTypeName() (o string)

v0.23.2

Dec 2, 2021

v0.23.1

Nov 18, 2021

Changes in this version

+ type CrossClusterCancelExecutionRequestAttributes struct

+ ChildWorkflowOnly bool

+ InitiatedEventID int64

+ RequestID string

+ TargetDomainID string

+ TargetRunID string

+ TargetWorkflowID string

+ func (v *CrossClusterCancelExecutionRequestAttributes) GetChildWorkflowOnly() (o bool)

+ func (v *CrossClusterCancelExecutionRequestAttributes) GetInitiatedEventID() (o int64)

+ func (v *CrossClusterCancelExecutionRequestAttributes) GetRequestID() (o string)

+ func (v *CrossClusterCancelExecutionRequestAttributes) GetTargetDomainID() (o string)

+ func (v *CrossClusterCancelExecutionRequestAttributes) GetTargetRunID() (o string)

+ func (v *CrossClusterCancelExecutionRequestAttributes) GetTargetWorkflowID() (o string)

+ type CrossClusterCancelExecutionResponseAttributes struct

+ type CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes struct

+ CompletionEvent *HistoryEvent

+ InitiatedEventID int64

+ TargetDomainID string

+ TargetRunID string

+ TargetWorkflowID string

+ func (v *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetInitiatedEventID() (o int64)

+ func (v *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetTargetDomainID() (o string)

+ func (v *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetTargetRunID() (o string)

+ func (v *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) GetTargetWorkflowID() (o string)

+ type CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes struct

+ type CrossClusterSignalExecutionRequestAttributes struct

+ ChildWorkflowOnly bool

+ Control []byte

+ InitiatedEventID int64

+ RequestID string

+ SignalInput []byte

+ SignalName string

+ TargetDomainID string

+ TargetRunID string

+ TargetWorkflowID string

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetChildWorkflowOnly() (o bool)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetControl() (o []byte)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetInitiatedEventID() (o int64)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetRequestID() (o string)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetSignalInput() (o []byte)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetSignalName() (o string)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetTargetDomainID() (o string)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetTargetRunID() (o string)

+ func (v *CrossClusterSignalExecutionRequestAttributes) GetTargetWorkflowID() (o string)

+ type CrossClusterSignalExecutionResponseAttributes struct

+ type CrossClusterStartChildExecutionRequestAttributes struct

+ InitiatedEventAttributes *StartChildWorkflowExecutionInitiatedEventAttributes

+ InitiatedEventID int64

+ RequestID string

+ TargetDomainID string

+ TargetRunID *string

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

+ func (v *CrossClusterStartChildExecutionRequestAttributes) GetInitiatedEventID() (o int64)

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

+ func (v *CrossClusterStartChildExecutionRequestAttributes) GetTargetDomainID() (o string)

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

+ type CrossClusterStartChildExecutionResponseAttributes struct

+ RunID string

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

+ type CrossClusterTaskFailedCause int32

+ const CrossClusterTaskFailedCauseDomainNotActive

+ const CrossClusterTaskFailedCauseDomainNotExists

+ const CrossClusterTaskFailedCauseUncategorized

+ const CrossClusterTaskFailedCauseWorkflowAlreadyCompleted

+ const CrossClusterTaskFailedCauseWorkflowAlreadyRunning

+ const CrossClusterTaskFailedCauseWorkflowNotExists

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

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

+ func (e CrossClusterTaskFailedCause) Ptr() *CrossClusterTaskFailedCause

+ func (e CrossClusterTaskFailedCause) String() string

+ type CrossClusterTaskInfo struct

+ DomainID string

+ RunID string

+ TaskID int64

+ TaskState int16

+ TaskType *CrossClusterTaskType

+ VisibilityTimestamp *int64

+ WorkflowID string

+ func (v *CrossClusterTaskInfo) GetDomainID() (o string)

+ func (v *CrossClusterTaskInfo) GetRunID() (o string)

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

+ func (v *CrossClusterTaskInfo) GetTaskState() (o int16)

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

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

+ func (v *CrossClusterTaskInfo) GetWorkflowID() (o string)

+ type CrossClusterTaskRequest struct

+ CancelExecutionAttributes *CrossClusterCancelExecutionRequestAttributes

+ RecordChildWorkflowExecutionCompleteAttributes *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes

+ SignalExecutionAttributes *CrossClusterSignalExecutionRequestAttributes

+ StartChildExecutionAttributes *CrossClusterStartChildExecutionRequestAttributes

+ TaskInfo *CrossClusterTaskInfo

+ func (v *CrossClusterTaskRequest) GetCancelExecutionAttributes() (o *CrossClusterCancelExecutionRequestAttributes)

+ func (v *CrossClusterTaskRequest) GetRecordChildWorkflowExecutionCompleteAttributes() (o *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes)

+ func (v *CrossClusterTaskRequest) GetSignalExecutionAttributes() (o *CrossClusterSignalExecutionRequestAttributes)

+ func (v *CrossClusterTaskRequest) GetStartChildExecutionAttributes() (o *CrossClusterStartChildExecutionRequestAttributes)

+ func (v *CrossClusterTaskRequest) GetTaskInfo() (o *CrossClusterTaskInfo)

+ type CrossClusterTaskResponse struct

+ CancelExecutionAttributes *CrossClusterCancelExecutionResponseAttributes

+ FailedCause *CrossClusterTaskFailedCause

+ RecordChildWorkflowExecutionCompleteAttributes *CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes

+ SignalExecutionAttributes *CrossClusterSignalExecutionResponseAttributes

+ StartChildExecutionAttributes *CrossClusterStartChildExecutionResponseAttributes

+ TaskID int64

+ TaskType *CrossClusterTaskType

+ func (v *CrossClusterTaskResponse) GetCancelExecutionAttributes() (o *CrossClusterCancelExecutionResponseAttributes)

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

+ func (v *CrossClusterTaskResponse) GetRecordChildWorkflowExecutionCompleteAttributes() (o *CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes)

+ func (v *CrossClusterTaskResponse) GetSignalExecutionAttributes() (o *CrossClusterSignalExecutionResponseAttributes)

+ func (v *CrossClusterTaskResponse) GetStartChildExecutionAttributes() (o *CrossClusterStartChildExecutionResponseAttributes)

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

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

+ type CrossClusterTaskType int32

+ const CrossClusterTaskTypeCancelExecution

+ const CrossClusterTaskTypeSignalExecution

+ const CrossClusterTaskTypeStartChildExecution

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

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

+ func (e CrossClusterTaskType) Ptr() *CrossClusterTaskType

+ func (e CrossClusterTaskType) String() string

+ type DynamicConfigBlob struct

+ Entries []*DynamicConfigEntry

+ SchemaVersion int64

+ func (v *DynamicConfigBlob) GetEntries() (o []*DynamicConfigEntry)

+ func (v *DynamicConfigBlob) GetSchemaVersion() (o int64)

+ type DynamicConfigEntry struct

+ Name string

+ Values []*DynamicConfigValue

+ func (v *DynamicConfigEntry) GetName() (o string)

+ func (v *DynamicConfigEntry) GetValues() (o []*DynamicConfigValue)

+ type DynamicConfigFilter struct

+ Name string

+ Value *DataBlob

+ func (v *DynamicConfigFilter) GetName() (o string)

+ func (v *DynamicConfigFilter) GetValue() (o *DataBlob)

+ type DynamicConfigValue struct

+ Filters []*DynamicConfigFilter

+ Value *DataBlob

+ func (v *DynamicConfigValue) GetFilters() (o []*DynamicConfigFilter)

+ func (v *DynamicConfigValue) GetValue() (o *DataBlob)

+ type GetCrossClusterTasksRequest struct

+ ShardIDs []int32

+ TargetCluster string

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

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

+ type GetCrossClusterTasksResponse struct

+ FailedCauseByShard map[int32]GetTaskFailedCause

+ TasksByShard map[int32][]*CrossClusterTaskRequest

+ func (v *GetCrossClusterTasksResponse) GetFailedCauseByShard() (o map[int32]GetTaskFailedCause)

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

+ type GetDynamicConfigRequest struct

+ ConfigName string

+ Filters []*DynamicConfigFilter

+ func (v *GetDynamicConfigRequest) GetConfigName() (o string)

+ func (v *GetDynamicConfigRequest) GetFilters() (o []*DynamicConfigFilter)

+ type GetDynamicConfigResponse struct

+ Value *DataBlob

+ func (v *GetDynamicConfigResponse) GetValue() (o *DataBlob)

+ type GetTaskFailedCause int32

+ const GetTaskFailedCauseServiceBusy

+ const GetTaskFailedCauseShardOwnershipLost

+ const GetTaskFailedCauseTimeout

+ const GetTaskFailedCauseUncategorized

+ func (e *GetTaskFailedCause) UnmarshalText(value []byte) error

+ func (e GetTaskFailedCause) MarshalText() ([]byte, error)

+ func (e GetTaskFailedCause) Ptr() *GetTaskFailedCause

+ func (e GetTaskFailedCause) String() string

+ type GetTaskListsByDomainRequest struct

+ Domain string

+ func (v *GetTaskListsByDomainRequest) GetDomain() (o string)

+ type GetTaskListsByDomainResponse struct

+ TaskListNames []string

+ func (v *GetTaskListsByDomainResponse) GetTaskListNames() (o []string)

+ type ListDynamicConfigRequest struct

+ ConfigName string

+ func (v *ListDynamicConfigRequest) GetConfigName() (o string)

+ type ListDynamicConfigResponse struct

+ Entries []*DynamicConfigEntry

+ func (v *ListDynamicConfigResponse) GetEntries() (o []*DynamicConfigEntry)

+ type MatchingGetTaskListsByDomainRequest struct

+ Domain string

+ func (v *MatchingGetTaskListsByDomainRequest) GetDomain() (o string)

type RemoveTaskRequest

+ ClusterName string

+ func (v *RemoveTaskRequest) GetClusterName() (o string)

+ type RespondCrossClusterTasksCompletedRequest struct

+ FetchNewTasks bool

+ ShardID int32

+ TargetCluster string

+ TaskResponses []*CrossClusterTaskResponse

+ func (v *RespondCrossClusterTasksCompletedRequest) GetFetchNewTasks() (o bool)

+ func (v *RespondCrossClusterTasksCompletedRequest) GetShardID() (o int32)

+ func (v *RespondCrossClusterTasksCompletedRequest) GetTargetCluster() (o string)

+ func (v *RespondCrossClusterTasksCompletedRequest) GetTaskResponses() (o []*CrossClusterTaskResponse)

+ type RespondCrossClusterTasksCompletedResponse struct

+ Tasks []*CrossClusterTaskRequest

+ func (v *RespondCrossClusterTasksCompletedResponse) GetTasks() (o []*CrossClusterTaskRequest)

+ type RestoreDynamicConfigRequest struct

+ ConfigName string

+ Filters []*DynamicConfigFilter

+ func (v *RestoreDynamicConfigRequest) GetConfigName() (o string)

+ func (v *RestoreDynamicConfigRequest) GetFilters() (o []*DynamicConfigFilter)

+ type UpdateDynamicConfigRequest struct

+ ConfigName string

+ ConfigValues []*DynamicConfigValue

+ func (v *UpdateDynamicConfigRequest) GetConfigName() (o string)

+ func (v *UpdateDynamicConfigRequest) GetConfigValues() (o []*DynamicConfigValue)

v0.22.4

Nov 11, 2021

v0.22.3

Oct 14, 2021

v0.22.2

Oct 8, 2021

v0.22.1

Oct 8, 2021

v0.22.0

Aug 20, 2021

Changes in this version

+ type DescribeShardDistributionRequest struct

+ PageID int32

+ PageSize int32

+ type DescribeShardDistributionResponse struct

+ NumberOfShards int32

+ Shards map[int32]string

+ func (v *DescribeShardDistributionResponse) GetNumberOfShards() (o int32)

+ func (v *DescribeShardDistributionResponse) GetShards() (o map[int32]string)

+ type FeatureNotEnabledError struct

+ FeatureFlag string

+ func (err FeatureNotEnabledError) Error() string

+ func (v *FeatureNotEnabledError) GetFeatureFlag() (o string)

type WorkflowExecutionInfo

+ IsCron bool

+ func (v *WorkflowExecutionInfo) GetIsCron() (o bool)

v0.21.3

Jun 17, 2021

v0.21.2

Jun 1, 2021

Changes in this version

type PollForDecisionTaskResponse

+ NextEventID int64

+ func (v *PollForDecisionTaskResponse) GetNextEventID() (o int64)

v0.21.0

May 6, 2021

Changes in this version

type DescribeClusterResponse

+ PersistenceInfo map[string]*PersistenceInfo

+ type PersistenceFeature struct

+ Enabled bool

+ Key string

+ type PersistenceInfo struct

+ Backend string

+ Features []*PersistenceFeature

+ Settings []*PersistenceSetting

+ type PersistenceSetting struct

+ Key string

+ Value string

type SignalWithStartWorkflowExecutionRequest

+ DelayStartSeconds *int32

+ func (v *SignalWithStartWorkflowExecutionRequest) GetDelayStartSeconds() (o int32)

type StartChildWorkflowExecutionInitiatedEventAttributes

+ DelayStartSeconds *int32

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetDelayStartSeconds() (o int32)

type StartWorkflowExecutionRequest

+ DelayStartSeconds *int32

+ func (v *StartWorkflowExecutionRequest) GetDelayStartSeconds() (o int32)

+ type WorkflowExecutionAlreadyCompletedError struct

+ Message string

+ func (err WorkflowExecutionAlreadyCompletedError) Error() string

+ func (v *WorkflowExecutionAlreadyCompletedError) GetMessage() (o string)

v0.20.0

Apr 16, 2021

Changes in this version

type UpdateDomainRequest

+ ActiveClusterName *string

+ BadBinaries *BadBinaries

+ Clusters []*ClusterReplicationConfiguration

+ Data map[string]string

+ Description *string

+ EmitMetric *bool

+ HistoryArchivalStatus *ArchivalStatus

+ HistoryArchivalURI *string

+ OwnerEmail *string

+ VisibilityArchivalStatus *ArchivalStatus

+ VisibilityArchivalURI *string

+ WorkflowExecutionRetentionPeriodInDays *int32

+ func (v *UpdateDomainRequest) GetHistoryArchivalURI() (o string)

+ func (v *UpdateDomainRequest) GetVisibilityArchivalURI() (o string)

type WorkflowExecutionInfo

+ ParentDomain *string

+ ParentInitiatedID *int64

type WorkflowExecutionStartedEventAttributes

+ ParentWorkflowDomainID *string

v0.19.2

Apr 16, 2021

v0.19.1

Mar 30, 2021

v0.19.0

Feb 8, 2021

v0.18.2

Mar 17, 2021

v0.18.1

Mar 1, 2021

v0.18.0

Jan 22, 2021

Changes in this version

type ArchivalStatus

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

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

+ func (e ArchivalStatus) String() string

type CancelExternalWorkflowExecutionFailedCause

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

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

+ func (e CancelExternalWorkflowExecutionFailedCause) String() string

type ChildWorkflowExecutionFailedCause

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

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

+ func (e ChildWorkflowExecutionFailedCause) String() string

type ContinueAsNewInitiator

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

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

+ func (e ContinueAsNewInitiator) String() string

type DLQType

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

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

+ func (e DLQType) String() string

type DecisionTaskFailedCause

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

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

+ func (e DecisionTaskFailedCause) String() string

+ type DecisionTaskTimedOutCause int32

+ const DecisionTaskTimedOutCauseReset

+ const DecisionTaskTimedOutCauseTimeout

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

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

+ func (e DecisionTaskTimedOutCause) Ptr() *DecisionTaskTimedOutCause

+ func (e DecisionTaskTimedOutCause) String() string

type DecisionTaskTimedOutEventAttributes

+ BaseRunID *string

+ Cause *DecisionTaskTimedOutCause

+ ForkEventVersion *int64

+ NewRunID *string

+ Reason *string

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

+ func (v *DecisionTaskTimedOutEventAttributes) GetCause() (o DecisionTaskTimedOutCause)

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

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

+ func (v *DecisionTaskTimedOutEventAttributes) GetReason() (o string)

type DecisionType

+ func DecisionTypeValues() []DecisionType

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

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

+ func (e DecisionType) String() string

type DomainOperation

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

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

+ func (e DomainOperation) String() string

type DomainStatus

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

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

+ func (e DomainStatus) String() string

type EncodingType

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

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

+ func (e EncodingType) String() string

type EventType

+ func EventTypeValues() []EventType

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

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

+ func (e EventType) String() string

+ type HealthStatus struct

+ Msg *string

+ Ok bool

+ func (v *HealthStatus) GetMsg() (o string)

+ func (v *HealthStatus) GetOk() (o bool)

type HistoryEventFilterType

+ func (e *HistoryEventFilterType) UnmarshalText(value []byte) error

+ func (e HistoryEventFilterType) MarshalText() ([]byte, error)

+ func (e HistoryEventFilterType) String() string

type IndexedValueType

+ func (e *IndexedValueType) UnmarshalText(value []byte) error

+ func (e IndexedValueType) MarshalText() ([]byte, error)

+ func (e IndexedValueType) String() string

+ type MetaHealthArgs struct

+ type MetaHealthResult struct

+ Success *HealthStatus

+ func (v *MetaHealthResult) GetSuccess() (o *HealthStatus)

type ParentClosePolicy

+ func (e *ParentClosePolicy) UnmarshalText(value []byte) error

+ func (e ParentClosePolicy) MarshalText() ([]byte, error)

+ func (e ParentClosePolicy) String() string

type PendingActivityState

+ func (e *PendingActivityState) UnmarshalText(value []byte) error

+ func (e PendingActivityState) MarshalText() ([]byte, error)

+ func (e PendingActivityState) String() string

type PendingDecisionState

+ func (e *PendingDecisionState) UnmarshalText(value []byte) error

+ func (e PendingDecisionState) MarshalText() ([]byte, error)

+ func (e PendingDecisionState) String() string

type QueryConsistencyLevel

+ func (e *QueryConsistencyLevel) UnmarshalText(value []byte) error

+ func (e QueryConsistencyLevel) MarshalText() ([]byte, error)

+ func (e QueryConsistencyLevel) String() string

type QueryRejectCondition

+ func (e *QueryRejectCondition) UnmarshalText(value []byte) error

+ func (e QueryRejectCondition) MarshalText() ([]byte, error)

+ func (e QueryRejectCondition) String() string

type QueryResultType

+ func (e *QueryResultType) UnmarshalText(value []byte) error

+ func (e QueryResultType) MarshalText() ([]byte, error)

+ func (e QueryResultType) String() string

type QueryTaskCompletedType

+ func (e *QueryTaskCompletedType) UnmarshalText(value []byte) error

+ func (e QueryTaskCompletedType) MarshalText() ([]byte, error)

+ func (e QueryTaskCompletedType) String() string

type ReadDLQMessagesResponse

+ ReplicationTasksInfo []*ReplicationTaskInfo

+ func (v *ReadDLQMessagesResponse) GetReplicationTasksInfo() (o []*ReplicationTaskInfo)

type ReplicationTaskType

+ func (e *ReplicationTaskType) UnmarshalText(value []byte) error

+ func (e ReplicationTaskType) MarshalText() ([]byte, error)

+ func (e ReplicationTaskType) String() string

type SignalExternalWorkflowExecutionFailedCause

+ func (e *SignalExternalWorkflowExecutionFailedCause) UnmarshalText(value []byte) error

+ func (e SignalExternalWorkflowExecutionFailedCause) MarshalText() ([]byte, error)

+ func (e SignalExternalWorkflowExecutionFailedCause) String() string

type TaskListKind

+ func (e *TaskListKind) UnmarshalText(value []byte) error

+ func (e TaskListKind) MarshalText() ([]byte, error)

+ func (e TaskListKind) String() string

type TaskListType

+ func (e *TaskListType) UnmarshalText(value []byte) error

+ func (e TaskListType) MarshalText() ([]byte, error)

+ func (e TaskListType) String() string

type TaskSource

+ func (e *TaskSource) UnmarshalText(value []byte) error

+ func (e TaskSource) MarshalText() ([]byte, error)

+ func (e TaskSource) String() string

type TimeoutType

+ func (e *TimeoutType) UnmarshalText(value []byte) error

+ func (e TimeoutType) MarshalText() ([]byte, error)

+ func (e TimeoutType) String() string

type WorkflowExecutionCloseStatus

+ func (e *WorkflowExecutionCloseStatus) UnmarshalText(value []byte) error

+ func (e WorkflowExecutionCloseStatus) MarshalText() ([]byte, error)

+ func (e WorkflowExecutionCloseStatus) String() string

type WorkflowIDReusePolicy

+ func (e *WorkflowIDReusePolicy) UnmarshalText(value []byte) error

+ func (e WorkflowIDReusePolicy) MarshalText() ([]byte, error)

+ func (e WorkflowIDReusePolicy) String() string

v0.17.0

Jan 13, 2021

Changes in this version

type AccessDeniedError

+ func (v *AccessDeniedError) GetMessage() (o string)

+ type ActivityLocalDispatchInfo struct

+ ActivityID *string

+ ScheduledTimestamp *int64

+ ScheduledTimestampOfThisAttempt *int64

+ StartedTimestamp *int64

+ TaskToken []byte

+ func (v *ActivityLocalDispatchInfo) GetActivityID() (o string)

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

+ func (v *ActivityLocalDispatchInfo) GetScheduledTimestampOfThisAttempt() (o int64)

+ func (v *ActivityLocalDispatchInfo) GetStartedTimestamp() (o int64)

+ func (v *ActivityLocalDispatchInfo) GetTaskToken() (o []byte)

type ActivityTaskCancelRequestedEventAttributes

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

+ func (v *ActivityTaskCancelRequestedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

type ActivityTaskCanceledEventAttributes

+ func (v *ActivityTaskCanceledEventAttributes) GetDetails() (o []byte)

+ func (v *ActivityTaskCanceledEventAttributes) GetIdentity() (o string)

+ func (v *ActivityTaskCanceledEventAttributes) GetLatestCancelRequestedEventID() (o int64)

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

+ func (v *ActivityTaskCanceledEventAttributes) GetStartedEventID() (o int64)

type ActivityTaskCompletedEventAttributes

+ func (v *ActivityTaskCompletedEventAttributes) GetIdentity() (o string)

+ func (v *ActivityTaskCompletedEventAttributes) GetResult() (o []byte)

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

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

type ActivityTaskFailedEventAttributes

+ func (v *ActivityTaskFailedEventAttributes) GetDetails() (o []byte)

+ func (v *ActivityTaskFailedEventAttributes) GetIdentity() (o string)

+ func (v *ActivityTaskFailedEventAttributes) GetReason() (o string)

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

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

type ActivityTaskScheduledEventAttributes

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

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

+ func (v *ActivityTaskScheduledEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

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

+ func (v *ActivityTaskScheduledEventAttributes) GetHeader() (o *Header)

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

+ func (v *ActivityTaskScheduledEventAttributes) GetInput() (o []byte)

+ func (v *ActivityTaskScheduledEventAttributes) GetRetryPolicy() (o *RetryPolicy)

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

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

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

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

type ActivityTaskStartedEventAttributes

+ func (v *ActivityTaskStartedEventAttributes) GetAttempt() (o int32)

+ func (v *ActivityTaskStartedEventAttributes) GetIdentity() (o string)

+ func (v *ActivityTaskStartedEventAttributes) GetLastFailureDetails() (o []byte)

+ func (v *ActivityTaskStartedEventAttributes) GetLastFailureReason() (o string)

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

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

type ActivityTaskTimedOutEventAttributes

+ func (v *ActivityTaskTimedOutEventAttributes) GetDetails() (o []byte)

+ func (v *ActivityTaskTimedOutEventAttributes) GetLastFailureDetails() (o []byte)

+ func (v *ActivityTaskTimedOutEventAttributes) GetLastFailureReason() (o string)

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

+ func (v *ActivityTaskTimedOutEventAttributes) GetStartedEventID() (o int64)

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

type ActivityType

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

+ type AddActivityTaskRequest struct

+ DomainUUID *string

+ Execution *WorkflowExecution

+ ForwardedFrom *string

+ ScheduleID *int64

+ ScheduleToStartTimeoutSeconds *int32

+ Source *TaskSource

+ SourceDomainUUID *string

+ TaskList *TaskList

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

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

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

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

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

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

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

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

+ type AddDecisionTaskRequest struct

+ DomainUUID *string

+ Execution *WorkflowExecution

+ ForwardedFrom *string

+ ScheduleID *int64

+ ScheduleToStartTimeoutSeconds *int32

+ Source *TaskSource

+ TaskList *TaskList

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

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

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

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

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

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

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

+ type AddSearchAttributeRequest struct

+ SearchAttribute map[string]IndexedValueType

+ SecurityToken *string

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

+ func (v *AddSearchAttributeRequest) GetSecurityToken() (o string)

+ type AdminDescribeWorkflowExecutionRequest struct

+ Domain *string

+ Execution *WorkflowExecution

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

+ func (v *AdminDescribeWorkflowExecutionRequest) GetExecution() (o *WorkflowExecution)

+ type AdminDescribeWorkflowExecutionResponse struct

+ HistoryAddr *string

+ MutableStateInCache *string

+ MutableStateInDatabase *string

+ ShardID *string

+ func (v *AdminDescribeWorkflowExecutionResponse) GetHistoryAddr() (o string)

+ func (v *AdminDescribeWorkflowExecutionResponse) GetMutableStateInCache() (o string)

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

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

+ type AdminServiceAddSearchAttributeArgs struct

+ Request *AddSearchAttributeRequest

+ func (v *AdminServiceAddSearchAttributeArgs) GetRequest() (o *AddSearchAttributeRequest)

+ type AdminServiceAddSearchAttributeResult struct

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ func (v *AdminServiceAddSearchAttributeResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceAddSearchAttributeResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceAddSearchAttributeResult) GetServiceBusyError() (o *ServiceBusyError)

+ type AdminServiceCloseShardArgs struct

+ Request *CloseShardRequest

+ func (v *AdminServiceCloseShardArgs) GetRequest() (o *CloseShardRequest)

+ type AdminServiceCloseShardResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ func (v *AdminServiceCloseShardResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *AdminServiceCloseShardResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceCloseShardResult) GetInternalServiceError() (o *InternalServiceError)

+ type AdminServiceDescribeClusterArgs struct

+ type AdminServiceDescribeClusterResult struct

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ Success *DescribeClusterResponse

+ func (v *AdminServiceDescribeClusterResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceDescribeClusterResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *AdminServiceDescribeClusterResult) GetSuccess() (o *DescribeClusterResponse)

+ type AdminServiceDescribeHistoryHostArgs struct

+ Request *DescribeHistoryHostRequest

+ func (v *AdminServiceDescribeHistoryHostArgs) GetRequest() (o *DescribeHistoryHostRequest)

+ type AdminServiceDescribeHistoryHostResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ Success *DescribeHistoryHostResponse

+ func (v *AdminServiceDescribeHistoryHostResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *AdminServiceDescribeHistoryHostResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceDescribeHistoryHostResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceDescribeHistoryHostResult) GetSuccess() (o *DescribeHistoryHostResponse)

+ type AdminServiceDescribeQueueArgs struct

+ Request *DescribeQueueRequest

+ func (v *AdminServiceDescribeQueueArgs) GetRequest() (o *DescribeQueueRequest)

+ type AdminServiceDescribeQueueResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ Success *DescribeQueueResponse

+ func (v *AdminServiceDescribeQueueResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *AdminServiceDescribeQueueResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceDescribeQueueResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceDescribeQueueResult) GetSuccess() (o *DescribeQueueResponse)

+ type AdminServiceDescribeWorkflowExecutionArgs struct

+ Request *AdminDescribeWorkflowExecutionRequest

+ func (v *AdminServiceDescribeWorkflowExecutionArgs) GetRequest() (o *AdminDescribeWorkflowExecutionRequest)

+ type AdminServiceDescribeWorkflowExecutionResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ Success *AdminDescribeWorkflowExecutionResponse

+ func (v *AdminServiceDescribeWorkflowExecutionResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *AdminServiceDescribeWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceDescribeWorkflowExecutionResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServiceDescribeWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceDescribeWorkflowExecutionResult) GetSuccess() (o *AdminDescribeWorkflowExecutionResponse)

+ type AdminServiceGetDLQReplicationMessagesArgs struct

+ Request *GetDLQReplicationMessagesRequest

+ func (v *AdminServiceGetDLQReplicationMessagesArgs) GetRequest() (o *GetDLQReplicationMessagesRequest)

+ type AdminServiceGetDLQReplicationMessagesResult struct

+ BadRequestError *BadRequestError

+ ServiceBusyError *ServiceBusyError

+ Success *GetDLQReplicationMessagesResponse

+ func (v *AdminServiceGetDLQReplicationMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceGetDLQReplicationMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *AdminServiceGetDLQReplicationMessagesResult) GetSuccess() (o *GetDLQReplicationMessagesResponse)

+ type AdminServiceGetDomainReplicationMessagesArgs struct

+ Request *GetDomainReplicationMessagesRequest

+ func (v *AdminServiceGetDomainReplicationMessagesArgs) GetRequest() (o *GetDomainReplicationMessagesRequest)

+ type AdminServiceGetDomainReplicationMessagesResult struct

+ BadRequestError *BadRequestError

+ ClientVersionNotSupportedError *ClientVersionNotSupportedError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ Success *GetDomainReplicationMessagesResponse

+ func (v *AdminServiceGetDomainReplicationMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceGetDomainReplicationMessagesResult) GetClientVersionNotSupportedError() (o *ClientVersionNotSupportedError)

+ func (v *AdminServiceGetDomainReplicationMessagesResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *AdminServiceGetDomainReplicationMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *AdminServiceGetDomainReplicationMessagesResult) GetSuccess() (o *GetDomainReplicationMessagesResponse)

+ type AdminServiceGetReplicationMessagesArgs struct

+ Request *GetReplicationMessagesRequest

+ func (v *AdminServiceGetReplicationMessagesArgs) GetRequest() (o *GetReplicationMessagesRequest)

+ type AdminServiceGetReplicationMessagesResult struct

+ BadRequestError *BadRequestError

+ ClientVersionNotSupportedError *ClientVersionNotSupportedError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ Success *GetReplicationMessagesResponse

+ func (v *AdminServiceGetReplicationMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceGetReplicationMessagesResult) GetClientVersionNotSupportedError() (o *ClientVersionNotSupportedError)

+ func (v *AdminServiceGetReplicationMessagesResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *AdminServiceGetReplicationMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *AdminServiceGetReplicationMessagesResult) GetSuccess() (o *GetReplicationMessagesResponse)

+ type AdminServiceGetWorkflowExecutionRawHistoryV2Args struct

+ GetRequest *GetWorkflowExecutionRawHistoryV2Request

+ func (v *AdminServiceGetWorkflowExecutionRawHistoryV2Args) GetGetRequest() (o *GetWorkflowExecutionRawHistoryV2Request)

+ type AdminServiceGetWorkflowExecutionRawHistoryV2Result struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ Success *GetWorkflowExecutionRawHistoryV2Response

+ func (v *AdminServiceGetWorkflowExecutionRawHistoryV2Result) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceGetWorkflowExecutionRawHistoryV2Result) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServiceGetWorkflowExecutionRawHistoryV2Result) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceGetWorkflowExecutionRawHistoryV2Result) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *AdminServiceGetWorkflowExecutionRawHistoryV2Result) GetSuccess() (o *GetWorkflowExecutionRawHistoryV2Response)

+ type AdminServiceMergeDLQMessagesArgs struct

+ Request *MergeDLQMessagesRequest

+ func (v *AdminServiceMergeDLQMessagesArgs) GetRequest() (o *MergeDLQMessagesRequest)

+ type AdminServiceMergeDLQMessagesResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ Success *MergeDLQMessagesResponse

+ func (v *AdminServiceMergeDLQMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceMergeDLQMessagesResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServiceMergeDLQMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceMergeDLQMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *AdminServiceMergeDLQMessagesResult) GetSuccess() (o *MergeDLQMessagesResponse)

+ type AdminServicePurgeDLQMessagesArgs struct

+ Request *PurgeDLQMessagesRequest

+ func (v *AdminServicePurgeDLQMessagesArgs) GetRequest() (o *PurgeDLQMessagesRequest)

+ type AdminServicePurgeDLQMessagesResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ func (v *AdminServicePurgeDLQMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServicePurgeDLQMessagesResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServicePurgeDLQMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServicePurgeDLQMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ type AdminServiceReadDLQMessagesArgs struct

+ Request *ReadDLQMessagesRequest

+ func (v *AdminServiceReadDLQMessagesArgs) GetRequest() (o *ReadDLQMessagesRequest)

+ type AdminServiceReadDLQMessagesResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ Success *ReadDLQMessagesResponse

+ func (v *AdminServiceReadDLQMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceReadDLQMessagesResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServiceReadDLQMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *AdminServiceReadDLQMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *AdminServiceReadDLQMessagesResult) GetSuccess() (o *ReadDLQMessagesResponse)

+ type AdminServiceReapplyEventsArgs struct

+ ReapplyEventsRequest *ReapplyEventsRequest

+ func (v *AdminServiceReapplyEventsArgs) GetReapplyEventsRequest() (o *ReapplyEventsRequest)

+ type AdminServiceReapplyEventsResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ func (v *AdminServiceReapplyEventsResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceReapplyEventsResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *AdminServiceReapplyEventsResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServiceReapplyEventsResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *AdminServiceReapplyEventsResult) GetServiceBusyError() (o *ServiceBusyError)

+ type AdminServiceRefreshWorkflowTasksArgs struct

+ Request *RefreshWorkflowTasksRequest

+ func (v *AdminServiceRefreshWorkflowTasksArgs) GetRequest() (o *RefreshWorkflowTasksRequest)

+ type AdminServiceRefreshWorkflowTasksResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ ServiceBusyError *ServiceBusyError

+ func (v *AdminServiceRefreshWorkflowTasksResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceRefreshWorkflowTasksResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *AdminServiceRefreshWorkflowTasksResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServiceRefreshWorkflowTasksResult) GetServiceBusyError() (o *ServiceBusyError)

+ type AdminServiceRemoveTaskArgs struct

+ Request *RemoveTaskRequest

+ func (v *AdminServiceRemoveTaskArgs) GetRequest() (o *RemoveTaskRequest)

+ type AdminServiceRemoveTaskResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ func (v *AdminServiceRemoveTaskResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *AdminServiceRemoveTaskResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceRemoveTaskResult) GetInternalServiceError() (o *InternalServiceError)

+ type AdminServiceResendReplicationTasksArgs struct

+ Request *ResendReplicationTasksRequest

+ func (v *AdminServiceResendReplicationTasksArgs) GetRequest() (o *ResendReplicationTasksRequest)

+ type AdminServiceResendReplicationTasksResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ ServiceBusyError *ServiceBusyError

+ func (v *AdminServiceResendReplicationTasksResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceResendReplicationTasksResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *AdminServiceResendReplicationTasksResult) GetServiceBusyError() (o *ServiceBusyError)

+ type AdminServiceResetQueueArgs struct

+ Request *ResetQueueRequest

+ func (v *AdminServiceResetQueueArgs) GetRequest() (o *ResetQueueRequest)

+ type AdminServiceResetQueueResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ func (v *AdminServiceResetQueueResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *AdminServiceResetQueueResult) GetBadRequestError() (o *BadRequestError)

+ func (v *AdminServiceResetQueueResult) GetInternalServiceError() (o *InternalServiceError)

type ArchivalStatus

+ func (e ArchivalStatus) Ptr() *ArchivalStatus

type BadBinaries

+ func (v *BadBinaries) GetBinaries() (o map[string]*BadBinaryInfo)

type BadBinaryInfo

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

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

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

type BadRequestError

+ func (v *BadRequestError) GetMessage() (o string)

type CancelExternalWorkflowExecutionFailedCause

+ func (e CancelExternalWorkflowExecutionFailedCause) Ptr() *CancelExternalWorkflowExecutionFailedCause

+ type CancelOutstandingPollRequest struct

+ DomainUUID *string

+ PollerID *string

+ TaskList *TaskList

+ TaskListType *int32

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

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

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

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

type CancelTimerDecisionAttributes

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

type CancelTimerFailedEventAttributes

+ func (v *CancelTimerFailedEventAttributes) GetCause() (o string)

+ func (v *CancelTimerFailedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *CancelTimerFailedEventAttributes) GetIdentity() (o string)

+ func (v *CancelTimerFailedEventAttributes) GetTimerID() (o string)

type CancelWorkflowExecutionDecisionAttributes

+ func (v *CancelWorkflowExecutionDecisionAttributes) GetDetails() (o []byte)

type CancellationAlreadyRequestedError

+ func (v *CancellationAlreadyRequestedError) GetMessage() (o string)

type ChildWorkflowExecutionCanceledEventAttributes

+ func (v *ChildWorkflowExecutionCanceledEventAttributes) GetDetails() (o []byte)

+ func (v *ChildWorkflowExecutionCanceledEventAttributes) GetDomain() (o string)

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

+ func (v *ChildWorkflowExecutionCanceledEventAttributes) GetStartedEventID() (o int64)

+ func (v *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowType() (o *WorkflowType)

type ChildWorkflowExecutionCompletedEventAttributes

+ func (v *ChildWorkflowExecutionCompletedEventAttributes) GetDomain() (o string)

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

+ func (v *ChildWorkflowExecutionCompletedEventAttributes) GetResult() (o []byte)

+ func (v *ChildWorkflowExecutionCompletedEventAttributes) GetStartedEventID() (o int64)

+ func (v *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowType() (o *WorkflowType)

type ChildWorkflowExecutionFailedCause

+ func (e ChildWorkflowExecutionFailedCause) Ptr() *ChildWorkflowExecutionFailedCause

type ChildWorkflowExecutionFailedEventAttributes

+ func (v *ChildWorkflowExecutionFailedEventAttributes) GetDetails() (o []byte)

+ func (v *ChildWorkflowExecutionFailedEventAttributes) GetDomain() (o string)

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

+ func (v *ChildWorkflowExecutionFailedEventAttributes) GetReason() (o string)

+ func (v *ChildWorkflowExecutionFailedEventAttributes) GetStartedEventID() (o int64)

+ func (v *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowType() (o *WorkflowType)

type ChildWorkflowExecutionStartedEventAttributes

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

+ func (v *ChildWorkflowExecutionStartedEventAttributes) GetHeader() (o *Header)

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

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

+ func (v *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowType() (o *WorkflowType)

type ChildWorkflowExecutionTerminatedEventAttributes

+ func (v *ChildWorkflowExecutionTerminatedEventAttributes) GetDomain() (o string)

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

+ func (v *ChildWorkflowExecutionTerminatedEventAttributes) GetStartedEventID() (o int64)

+ func (v *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowType() (o *WorkflowType)

type ChildWorkflowExecutionTimedOutEventAttributes

+ func (v *ChildWorkflowExecutionTimedOutEventAttributes) GetDomain() (o string)

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

+ func (v *ChildWorkflowExecutionTimedOutEventAttributes) GetStartedEventID() (o int64)

+ func (v *ChildWorkflowExecutionTimedOutEventAttributes) GetTimeoutType() (o TimeoutType)

+ func (v *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowType() (o *WorkflowType)

type ClientVersionNotSupportedError

+ func (v *ClientVersionNotSupportedError) GetClientImpl() (o string)

+ func (v *ClientVersionNotSupportedError) GetFeatureVersion() (o string)

+ func (v *ClientVersionNotSupportedError) GetSupportedVersions() (o string)

type CloseShardRequest

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

type ClusterInfo

+ func (v *ClusterInfo) GetSupportedClientVersions() (o *SupportedClientVersions)

type ClusterReplicationConfiguration

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

type CompleteWorkflowExecutionDecisionAttributes

+ func (v *CompleteWorkflowExecutionDecisionAttributes) GetResult() (o []byte)

type ContinueAsNewInitiator

+ func (e ContinueAsNewInitiator) Ptr() *ContinueAsNewInitiator

type ContinueAsNewWorkflowExecutionDecisionAttributes

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

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetCronSchedule() (o string)

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

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetFailureDetails() (o []byte)

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetFailureReason() (o string)

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetHeader() (o *Header)

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

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetInput() (o []byte)

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetLastCompletionResult() (o []byte)

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetMemo() (o *Memo)

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetRetryPolicy() (o *RetryPolicy)

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

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetTaskList() (o *TaskList)

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

+ func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetWorkflowType() (o *WorkflowType)

type CountWorkflowExecutionsRequest

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

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

type CountWorkflowExecutionsResponse

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

type CurrentBranchChangedError

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

+ func (v *CurrentBranchChangedError) GetMessage() (o string)

+ type DLQType int32

+ const DLQTypeDomain

+ const DLQTypeReplication

+ func (e DLQType) Ptr() *DLQType

type DataBlob

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

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

type Decision

+ func (v *Decision) GetCancelTimerDecisionAttributes() (o *CancelTimerDecisionAttributes)

+ func (v *Decision) GetCancelWorkflowExecutionDecisionAttributes() (o *CancelWorkflowExecutionDecisionAttributes)

+ func (v *Decision) GetCompleteWorkflowExecutionDecisionAttributes() (o *CompleteWorkflowExecutionDecisionAttributes)

+ func (v *Decision) GetContinueAsNewWorkflowExecutionDecisionAttributes() (o *ContinueAsNewWorkflowExecutionDecisionAttributes)

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

+ func (v *Decision) GetFailWorkflowExecutionDecisionAttributes() (o *FailWorkflowExecutionDecisionAttributes)

+ func (v *Decision) GetRecordMarkerDecisionAttributes() (o *RecordMarkerDecisionAttributes)

+ func (v *Decision) GetRequestCancelActivityTaskDecisionAttributes() (o *RequestCancelActivityTaskDecisionAttributes)

+ func (v *Decision) GetRequestCancelExternalWorkflowExecutionDecisionAttributes() (o *RequestCancelExternalWorkflowExecutionDecisionAttributes)

+ func (v *Decision) GetScheduleActivityTaskDecisionAttributes() (o *ScheduleActivityTaskDecisionAttributes)

+ func (v *Decision) GetSignalExternalWorkflowExecutionDecisionAttributes() (o *SignalExternalWorkflowExecutionDecisionAttributes)

+ func (v *Decision) GetStartChildWorkflowExecutionDecisionAttributes() (o *StartChildWorkflowExecutionDecisionAttributes)

+ func (v *Decision) GetStartTimerDecisionAttributes() (o *StartTimerDecisionAttributes)

+ func (v *Decision) GetUpsertWorkflowSearchAttributesDecisionAttributes() (o *UpsertWorkflowSearchAttributesDecisionAttributes)

type DecisionTaskCompletedEventAttributes

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

+ func (v *DecisionTaskCompletedEventAttributes) GetExecutionContext() (o []byte)

+ func (v *DecisionTaskCompletedEventAttributes) GetIdentity() (o string)

+ func (v *DecisionTaskCompletedEventAttributes) GetScheduledEventID() (o int64)

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

type DecisionTaskFailedCause

+ func (e DecisionTaskFailedCause) Ptr() *DecisionTaskFailedCause

type DecisionTaskFailedEventAttributes

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

+ func (v *DecisionTaskFailedEventAttributes) GetBinaryChecksum() (o string)

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

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

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

+ func (v *DecisionTaskFailedEventAttributes) GetIdentity() (o string)

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

+ func (v *DecisionTaskFailedEventAttributes) GetReason() (o string)

+ func (v *DecisionTaskFailedEventAttributes) GetScheduledEventID() (o int64)

+ func (v *DecisionTaskFailedEventAttributes) GetStartedEventID() (o int64)

type DecisionTaskScheduledEventAttributes

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

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

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

type DecisionTaskStartedEventAttributes

+ func (v *DecisionTaskStartedEventAttributes) GetIdentity() (o string)

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

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

type DecisionTaskTimedOutEventAttributes

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

+ func (v *DecisionTaskTimedOutEventAttributes) GetStartedEventID() (o int64)

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

type DecisionType

+ func (e DecisionType) Ptr() *DecisionType

type DeprecateDomainRequest

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

+ func (v *DeprecateDomainRequest) GetSecurityToken() (o string)

+ type DescribeClusterResponse struct

+ MembershipInfo *MembershipInfo

+ SupportedClientVersions *SupportedClientVersions

+ func (v *DescribeClusterResponse) GetMembershipInfo() (o *MembershipInfo)

+ func (v *DescribeClusterResponse) GetSupportedClientVersions() (o *SupportedClientVersions)

type DescribeDomainRequest

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

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

type DescribeDomainResponse

+ func (v *DescribeDomainResponse) GetConfiguration() (o *DomainConfiguration)

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

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

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

+ func (v *DescribeDomainResponse) GetReplicationConfiguration() (o *DomainReplicationConfiguration)

type DescribeHistoryHostRequest

+ func (v *DescribeHistoryHostRequest) GetExecutionForHost() (o *WorkflowExecution)

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

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

type DescribeHistoryHostResponse

+ func (v *DescribeHistoryHostResponse) GetAddress() (o string)

+ func (v *DescribeHistoryHostResponse) GetDomainCache() (o *DomainCacheInfo)

+ func (v *DescribeHistoryHostResponse) GetNumberOfShards() (o int32)

+ func (v *DescribeHistoryHostResponse) GetShardControllerStatus() (o string)

+ func (v *DescribeHistoryHostResponse) GetShardIDs() (o []int32)

+ type DescribeMutableStateRequest struct

+ DomainUUID *string

+ Execution *WorkflowExecution

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

+ func (v *DescribeMutableStateRequest) GetExecution() (o *WorkflowExecution)

+ type DescribeMutableStateResponse struct

+ MutableStateInCache *string

+ MutableStateInDatabase *string

+ func (v *DescribeMutableStateResponse) GetMutableStateInCache() (o string)

+ func (v *DescribeMutableStateResponse) GetMutableStateInDatabase() (o string)

type DescribeQueueRequest

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

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

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

type DescribeQueueResponse

+ func (v *DescribeQueueResponse) GetProcessingQueueStates() (o []string)

type DescribeTaskListRequest

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

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

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

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

type DescribeTaskListResponse

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

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

type DescribeWorkflowExecutionRequest

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

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

type DescribeWorkflowExecutionResponse

+ PendingDecision *PendingDecisionInfo

+ func (v *DescribeWorkflowExecutionResponse) GetExecutionConfiguration() (o *WorkflowExecutionConfiguration)

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

+ func (v *DescribeWorkflowExecutionResponse) GetPendingChildren() (o []*PendingChildExecutionInfo)

+ func (v *DescribeWorkflowExecutionResponse) GetPendingDecision() (o *PendingDecisionInfo)

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

type DomainAlreadyExistsError

+ func (v *DomainAlreadyExistsError) GetMessage() (o string)

type DomainCacheInfo

+ func (v *DomainCacheInfo) GetNumOfItemsInCacheByID() (o int64)

+ func (v *DomainCacheInfo) GetNumOfItemsInCacheByName() (o int64)

type DomainConfiguration

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

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

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

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

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

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

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

+ type DomainFilter struct

+ DomainIDs []string

+ ReverseMatch *bool

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

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

type DomainInfo

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

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

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

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

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

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

type DomainNotActiveError

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

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

+ func (v *DomainNotActiveError) GetDomainName() (o string)

+ func (v *DomainNotActiveError) GetMessage() (o string)

+ type DomainOperation int32

+ const DomainOperationCreate

+ const DomainOperationUpdate

+ func (e DomainOperation) Ptr() *DomainOperation

type DomainReplicationConfiguration

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

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

type DomainStatus

+ func (e DomainStatus) Ptr() *DomainStatus

+ type DomainTaskAttributes struct

+ Config *DomainConfiguration

+ ConfigVersion *int64

+ DomainOperation *DomainOperation

+ FailoverVersion *int64

+ ID *string

+ Info *DomainInfo

+ PreviousFailoverVersion *int64

+ ReplicationConfig *DomainReplicationConfiguration

+ func (v *DomainTaskAttributes) GetConfig() (o *DomainConfiguration)

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

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

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

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

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

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

+ func (v *DomainTaskAttributes) GetReplicationConfig() (o *DomainReplicationConfiguration)

type EncodingType

+ func (e EncodingType) Ptr() *EncodingType

type EntityNotExistsError

+ func (v *EntityNotExistsError) GetActiveCluster() (o string)

+ func (v *EntityNotExistsError) GetCurrentCluster() (o string)

+ func (v *EntityNotExistsError) GetMessage() (o string)

+ type EventAlreadyStartedError struct

+ Message string

+ func (err EventAlreadyStartedError) Error() string

+ func (v *EventAlreadyStartedError) GetMessage() (o string)

type EventType

+ func (e EventType) Ptr() *EventType

type ExternalWorkflowExecutionCancelRequestedEventAttributes

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

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

+ func (v *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

type ExternalWorkflowExecutionSignaledEventAttributes

+ func (v *ExternalWorkflowExecutionSignaledEventAttributes) GetControl() (o []byte)

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

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

+ func (v *ExternalWorkflowExecutionSignaledEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

type FailWorkflowExecutionDecisionAttributes

+ func (v *FailWorkflowExecutionDecisionAttributes) GetDetails() (o []byte)

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

+ type FailoverMarkerAttributes struct

+ CreationTime *int64

+ DomainID *string

+ FailoverVersion *int64

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

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

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

+ type FailoverMarkerToken struct

+ FailoverMarker *FailoverMarkerAttributes

+ ShardIDs []int32

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

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

+ type FailoverMarkers struct

+ FailoverMarkers []*FailoverMarkerAttributes

+ func (v *FailoverMarkers) GetFailoverMarkers() (o []*FailoverMarkerAttributes)

+ type GetDLQReplicationMessagesRequest struct

+ TaskInfos []*ReplicationTaskInfo

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

+ type GetDLQReplicationMessagesResponse struct

+ ReplicationTasks []*ReplicationTask

+ func (v *GetDLQReplicationMessagesResponse) GetReplicationTasks() (o []*ReplicationTask)

+ type GetDomainReplicationMessagesRequest struct

+ ClusterName *string

+ LastProcessedMessageID *int64

+ LastRetrievedMessageID *int64

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

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

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

+ type GetDomainReplicationMessagesResponse struct

+ Messages *ReplicationMessages

+ func (v *GetDomainReplicationMessagesResponse) GetMessages() (o *ReplicationMessages)

+ type GetMutableStateRequest struct

+ CurrentBranchToken []byte

+ DomainUUID *string

+ Execution *WorkflowExecution

+ ExpectedNextEventID *int64

+ func (v *GetMutableStateRequest) GetCurrentBranchToken() (o []byte)

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

+ func (v *GetMutableStateRequest) GetExecution() (o *WorkflowExecution)

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

+ type GetMutableStateResponse struct

+ ClientFeatureVersion *string

+ ClientImpl *string

+ ClientLibraryVersion *string

+ CurrentBranchToken []byte

+ EventStoreVersion *int32

+ Execution *WorkflowExecution

+ IsStickyTaskListEnabled *bool

+ IsWorkflowRunning *bool

+ LastFirstEventID *int64

+ NextEventID *int64

+ PreviousStartedEventID *int64

+ StickyTaskList *TaskList

+ StickyTaskListScheduleToStartTimeout *int32

+ TaskList *TaskList

+ VersionHistories *VersionHistories

+ WorkflowCloseState *int32

+ WorkflowState *int32

+ WorkflowType *WorkflowType

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

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

+ func (v *GetMutableStateResponse) GetClientLibraryVersion() (o string)

+ func (v *GetMutableStateResponse) GetCurrentBranchToken() (o []byte)

+ func (v *GetMutableStateResponse) GetEventStoreVersion() (o int32)

+ func (v *GetMutableStateResponse) GetExecution() (o *WorkflowExecution)

+ func (v *GetMutableStateResponse) GetIsStickyTaskListEnabled() (o bool)

+ func (v *GetMutableStateResponse) GetIsWorkflowRunning() (o bool)

+ func (v *GetMutableStateResponse) GetLastFirstEventID() (o int64)

+ func (v *GetMutableStateResponse) GetNextEventID() (o int64)

+ func (v *GetMutableStateResponse) GetPreviousStartedEventID() (o int64)

+ func (v *GetMutableStateResponse) GetStickyTaskList() (o *TaskList)

+ func (v *GetMutableStateResponse) GetStickyTaskListScheduleToStartTimeout() (o int32)

+ func (v *GetMutableStateResponse) GetTaskList() (o *TaskList)

+ func (v *GetMutableStateResponse) GetVersionHistories() (o *VersionHistories)

+ func (v *GetMutableStateResponse) GetWorkflowCloseState() (o int32)

+ func (v *GetMutableStateResponse) GetWorkflowState() (o int32)

+ func (v *GetMutableStateResponse) GetWorkflowType() (o *WorkflowType)

+ type GetReplicationMessagesRequest struct

+ ClusterName *string

+ Tokens []*ReplicationToken

+ func (v *GetReplicationMessagesRequest) GetClusterName() (o string)

+ func (v *GetReplicationMessagesRequest) GetTokens() (o []*ReplicationToken)

+ type GetReplicationMessagesResponse struct

+ MessagesByShard map[int32]*ReplicationMessages

+ func (v *GetReplicationMessagesResponse) GetMessagesByShard() (o map[int32]*ReplicationMessages)

type GetSearchAttributesResponse

+ func (v *GetSearchAttributesResponse) GetKeys() (o map[string]IndexedValueType)

type GetWorkflowExecutionHistoryRequest

+ func (v *GetWorkflowExecutionHistoryRequest) GetDomain() (o string)

+ func (v *GetWorkflowExecutionHistoryRequest) GetExecution() (o *WorkflowExecution)

+ func (v *GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType() (o HistoryEventFilterType)

+ func (v *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() (o int32)

+ func (v *GetWorkflowExecutionHistoryRequest) GetNextPageToken() (o []byte)

+ func (v *GetWorkflowExecutionHistoryRequest) GetSkipArchival() (o bool)

+ func (v *GetWorkflowExecutionHistoryRequest) GetWaitForNewEvent() (o bool)

type GetWorkflowExecutionHistoryResponse

+ func (v *GetWorkflowExecutionHistoryResponse) GetArchived() (o bool)

+ func (v *GetWorkflowExecutionHistoryResponse) GetHistory() (o *History)

+ func (v *GetWorkflowExecutionHistoryResponse) GetNextPageToken() (o []byte)

+ func (v *GetWorkflowExecutionHistoryResponse) GetRawHistory() (o []*DataBlob)

+ type GetWorkflowExecutionRawHistoryV2Request struct

+ Domain *string

+ EndEventID *int64

+ EndEventVersion *int64

+ Execution *WorkflowExecution

+ MaximumPageSize *int32

+ NextPageToken []byte

+ StartEventID *int64

+ StartEventVersion *int64

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetDomain() (o string)

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetEndEventID() (o int64)

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion() (o int64)

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetExecution() (o *WorkflowExecution)

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize() (o int32)

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetNextPageToken() (o []byte)

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetStartEventID() (o int64)

+ func (v *GetWorkflowExecutionRawHistoryV2Request) GetStartEventVersion() (o int64)

+ type GetWorkflowExecutionRawHistoryV2Response struct

+ HistoryBatches []*DataBlob

+ NextPageToken []byte

+ VersionHistory *VersionHistory

+ func (v *GetWorkflowExecutionRawHistoryV2Response) GetHistoryBatches() (o []*DataBlob)

+ func (v *GetWorkflowExecutionRawHistoryV2Response) GetNextPageToken() (o []byte)

+ func (v *GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory() (o *VersionHistory)

type Header

+ func (v *Header) GetFields() (o map[string][]byte)

type History

+ func (v *History) GetEvents() (o []*HistoryEvent)

type HistoryBranch

+ func (v *HistoryBranch) GetAncestors() (o []*HistoryBranchRange)

+ func (v *HistoryBranch) GetBranchID() (o string)

+ func (v *HistoryBranch) GetTreeID() (o string)

type HistoryBranchRange

+ func (v *HistoryBranchRange) GetBeginNodeID() (o int64)

+ func (v *HistoryBranchRange) GetBranchID() (o string)

+ func (v *HistoryBranchRange) GetEndNodeID() (o int64)

+ type HistoryDescribeWorkflowExecutionRequest struct

+ DomainUUID *string

+ Request *DescribeWorkflowExecutionRequest

+ func (v *HistoryDescribeWorkflowExecutionRequest) GetDomainUUID() (o string)

+ func (v *HistoryDescribeWorkflowExecutionRequest) GetRequest() (o *DescribeWorkflowExecutionRequest)

type HistoryEvent

+ func (v *HistoryEvent) GetActivityTaskCancelRequestedEventAttributes() (o *ActivityTaskCancelRequestedEventAttributes)

+ func (v *HistoryEvent) GetActivityTaskCanceledEventAttributes() (o *ActivityTaskCanceledEventAttributes)

+ func (v *HistoryEvent) GetActivityTaskCompletedEventAttributes() (o *ActivityTaskCompletedEventAttributes)

+ func (v *HistoryEvent) GetActivityTaskFailedEventAttributes() (o *ActivityTaskFailedEventAttributes)

+ func (v *HistoryEvent) GetActivityTaskScheduledEventAttributes() (o *ActivityTaskScheduledEventAttributes)

+ func (v *HistoryEvent) GetActivityTaskStartedEventAttributes() (o *ActivityTaskStartedEventAttributes)

+ func (v *HistoryEvent) GetActivityTaskTimedOutEventAttributes() (o *ActivityTaskTimedOutEventAttributes)

+ func (v *HistoryEvent) GetCancelTimerFailedEventAttributes() (o *CancelTimerFailedEventAttributes)

+ func (v *HistoryEvent) GetChildWorkflowExecutionCanceledEventAttributes() (o *ChildWorkflowExecutionCanceledEventAttributes)

+ func (v *HistoryEvent) GetChildWorkflowExecutionCompletedEventAttributes() (o *ChildWorkflowExecutionCompletedEventAttributes)

+ func (v *HistoryEvent) GetChildWorkflowExecutionFailedEventAttributes() (o *ChildWorkflowExecutionFailedEventAttributes)

+ func (v *HistoryEvent) GetChildWorkflowExecutionStartedEventAttributes() (o *ChildWorkflowExecutionStartedEventAttributes)

+ func (v *HistoryEvent) GetChildWorkflowExecutionTerminatedEventAttributes() (o *ChildWorkflowExecutionTerminatedEventAttributes)

+ func (v *HistoryEvent) GetChildWorkflowExecutionTimedOutEventAttributes() (o *ChildWorkflowExecutionTimedOutEventAttributes)

+ func (v *HistoryEvent) GetDecisionTaskCompletedEventAttributes() (o *DecisionTaskCompletedEventAttributes)

+ func (v *HistoryEvent) GetDecisionTaskFailedEventAttributes() (o *DecisionTaskFailedEventAttributes)

+ func (v *HistoryEvent) GetDecisionTaskScheduledEventAttributes() (o *DecisionTaskScheduledEventAttributes)

+ func (v *HistoryEvent) GetDecisionTaskStartedEventAttributes() (o *DecisionTaskStartedEventAttributes)

+ func (v *HistoryEvent) GetDecisionTaskTimedOutEventAttributes() (o *DecisionTaskTimedOutEventAttributes)

+ func (v *HistoryEvent) GetEventID() (o int64)

+ func (v *HistoryEvent) GetEventType() (o EventType)

+ func (v *HistoryEvent) GetExternalWorkflowExecutionCancelRequestedEventAttributes() (o *ExternalWorkflowExecutionCancelRequestedEventAttributes)

+ func (v *HistoryEvent) GetExternalWorkflowExecutionSignaledEventAttributes() (o *ExternalWorkflowExecutionSignaledEventAttributes)

+ func (v *HistoryEvent) GetMarkerRecordedEventAttributes() (o *MarkerRecordedEventAttributes)

+ func (v *HistoryEvent) GetRequestCancelActivityTaskFailedEventAttributes() (o *RequestCancelActivityTaskFailedEventAttributes)

+ func (v *HistoryEvent) GetRequestCancelExternalWorkflowExecutionFailedEventAttributes() (o *RequestCancelExternalWorkflowExecutionFailedEventAttributes)

+ func (v *HistoryEvent) GetRequestCancelExternalWorkflowExecutionInitiatedEventAttributes() (o *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes)

+ func (v *HistoryEvent) GetSignalExternalWorkflowExecutionFailedEventAttributes() (o *SignalExternalWorkflowExecutionFailedEventAttributes)

+ func (v *HistoryEvent) GetSignalExternalWorkflowExecutionInitiatedEventAttributes() (o *SignalExternalWorkflowExecutionInitiatedEventAttributes)

+ func (v *HistoryEvent) GetStartChildWorkflowExecutionFailedEventAttributes() (o *StartChildWorkflowExecutionFailedEventAttributes)

+ func (v *HistoryEvent) GetStartChildWorkflowExecutionInitiatedEventAttributes() (o *StartChildWorkflowExecutionInitiatedEventAttributes)

+ func (v *HistoryEvent) GetTaskID() (o int64)

+ func (v *HistoryEvent) GetTimerCanceledEventAttributes() (o *TimerCanceledEventAttributes)

+ func (v *HistoryEvent) GetTimerFiredEventAttributes() (o *TimerFiredEventAttributes)

+ func (v *HistoryEvent) GetTimerStartedEventAttributes() (o *TimerStartedEventAttributes)

+ func (v *HistoryEvent) GetTimestamp() (o int64)

+ func (v *HistoryEvent) GetUpsertWorkflowSearchAttributesEventAttributes() (o *UpsertWorkflowSearchAttributesEventAttributes)

+ func (v *HistoryEvent) GetVersion() (o int64)

+ func (v *HistoryEvent) GetWorkflowExecutionCancelRequestedEventAttributes() (o *WorkflowExecutionCancelRequestedEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionCanceledEventAttributes() (o *WorkflowExecutionCanceledEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionCompletedEventAttributes() (o *WorkflowExecutionCompletedEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionContinuedAsNewEventAttributes() (o *WorkflowExecutionContinuedAsNewEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionFailedEventAttributes() (o *WorkflowExecutionFailedEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionSignaledEventAttributes() (o *WorkflowExecutionSignaledEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionStartedEventAttributes() (o *WorkflowExecutionStartedEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionTerminatedEventAttributes() (o *WorkflowExecutionTerminatedEventAttributes)

+ func (v *HistoryEvent) GetWorkflowExecutionTimedOutEventAttributes() (o *WorkflowExecutionTimedOutEventAttributes)

type HistoryEventFilterType

+ func (e HistoryEventFilterType) Ptr() *HistoryEventFilterType

+ type HistoryQueryWorkflowRequest struct

+ DomainUUID *string

+ Request *QueryWorkflowRequest

+ func (v *HistoryQueryWorkflowRequest) GetDomainUUID() (o string)

+ func (v *HistoryQueryWorkflowRequest) GetRequest() (o *QueryWorkflowRequest)

+ type HistoryQueryWorkflowResponse struct

+ Response *QueryWorkflowResponse

+ func (v *HistoryQueryWorkflowResponse) GetResponse() (o *QueryWorkflowResponse)

+ type HistoryReapplyEventsRequest struct

+ DomainUUID *string

+ Request *ReapplyEventsRequest

+ func (v *HistoryReapplyEventsRequest) GetDomainUUID() (o string)

+ func (v *HistoryReapplyEventsRequest) GetRequest() (o *ReapplyEventsRequest)

+ type HistoryRecordActivityTaskHeartbeatRequest struct

+ DomainUUID *string

+ HeartbeatRequest *RecordActivityTaskHeartbeatRequest

+ func (v *HistoryRecordActivityTaskHeartbeatRequest) GetDomainUUID() (o string)

+ func (v *HistoryRecordActivityTaskHeartbeatRequest) GetHeartbeatRequest() (o *RecordActivityTaskHeartbeatRequest)

+ type HistoryRefreshWorkflowTasksRequest struct

+ DomainUIID *string

+ Request *RefreshWorkflowTasksRequest

+ func (v *HistoryRefreshWorkflowTasksRequest) GetDomainUIID() (o string)

+ func (v *HistoryRefreshWorkflowTasksRequest) GetRequest() (o *RefreshWorkflowTasksRequest)

+ type HistoryRequestCancelWorkflowExecutionRequest struct

+ CancelRequest *RequestCancelWorkflowExecutionRequest

+ ChildWorkflowOnly *bool

+ DomainUUID *string

+ ExternalInitiatedEventID *int64

+ ExternalWorkflowExecution *WorkflowExecution

+ func (v *HistoryRequestCancelWorkflowExecutionRequest) GetCancelRequest() (o *RequestCancelWorkflowExecutionRequest)

+ func (v *HistoryRequestCancelWorkflowExecutionRequest) GetChildWorkflowOnly() (o bool)

+ func (v *HistoryRequestCancelWorkflowExecutionRequest) GetDomainUUID() (o string)

+ func (v *HistoryRequestCancelWorkflowExecutionRequest) GetExternalInitiatedEventID() (o int64)

+ func (v *HistoryRequestCancelWorkflowExecutionRequest) GetExternalWorkflowExecution() (o *WorkflowExecution)

+ type HistoryResetStickyTaskListRequest struct

+ DomainUUID *string

+ Execution *WorkflowExecution

+ func (v *HistoryResetStickyTaskListRequest) GetDomainUUID() (o string)

+ func (v *HistoryResetStickyTaskListRequest) GetExecution() (o *WorkflowExecution)

+ type HistoryResetStickyTaskListResponse struct

+ type HistoryResetWorkflowExecutionRequest struct

+ DomainUUID *string

+ ResetRequest *ResetWorkflowExecutionRequest

+ func (v *HistoryResetWorkflowExecutionRequest) GetDomainUUID() (o string)

+ func (v *HistoryResetWorkflowExecutionRequest) GetResetRequest() (o *ResetWorkflowExecutionRequest)

+ type HistoryRespondActivityTaskCanceledRequest struct

+ CancelRequest *RespondActivityTaskCanceledRequest

+ DomainUUID *string

+ func (v *HistoryRespondActivityTaskCanceledRequest) GetCancelRequest() (o *RespondActivityTaskCanceledRequest)

+ func (v *HistoryRespondActivityTaskCanceledRequest) GetDomainUUID() (o string)

+ type HistoryRespondActivityTaskCompletedRequest struct

+ CompleteRequest *RespondActivityTaskCompletedRequest

+ DomainUUID *string

+ func (v *HistoryRespondActivityTaskCompletedRequest) GetCompleteRequest() (o *RespondActivityTaskCompletedRequest)

+ func (v *HistoryRespondActivityTaskCompletedRequest) GetDomainUUID() (o string)

+ type HistoryRespondActivityTaskFailedRequest struct

+ DomainUUID *string

+ FailedRequest *RespondActivityTaskFailedRequest

+ func (v *HistoryRespondActivityTaskFailedRequest) GetDomainUUID() (o string)

+ func (v *HistoryRespondActivityTaskFailedRequest) GetFailedRequest() (o *RespondActivityTaskFailedRequest)

+ type HistoryRespondDecisionTaskCompletedRequest struct

+ CompleteRequest *RespondDecisionTaskCompletedRequest

+ DomainUUID *string

+ func (v *HistoryRespondDecisionTaskCompletedRequest) GetCompleteRequest() (o *RespondDecisionTaskCompletedRequest)

+ func (v *HistoryRespondDecisionTaskCompletedRequest) GetDomainUUID() (o string)

+ type HistoryRespondDecisionTaskCompletedResponse struct

+ ActivitiesToDispatchLocally map[string]*ActivityLocalDispatchInfo

+ StartedResponse *RecordDecisionTaskStartedResponse

+ func (v *HistoryRespondDecisionTaskCompletedResponse) GetActivitiesToDispatchLocally() (o map[string]*ActivityLocalDispatchInfo)

+ func (v *HistoryRespondDecisionTaskCompletedResponse) GetStartedResponse() (o *RecordDecisionTaskStartedResponse)

+ type HistoryRespondDecisionTaskFailedRequest struct

+ DomainUUID *string

+ FailedRequest *RespondDecisionTaskFailedRequest

+ func (v *HistoryRespondDecisionTaskFailedRequest) GetDomainUUID() (o string)

+ func (v *HistoryRespondDecisionTaskFailedRequest) GetFailedRequest() (o *RespondDecisionTaskFailedRequest)

+ type HistoryServiceCloseShardArgs struct

+ Request *CloseShardRequest

+ func (v *HistoryServiceCloseShardArgs) GetRequest() (o *CloseShardRequest)

+ type HistoryServiceCloseShardResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ func (v *HistoryServiceCloseShardResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *HistoryServiceCloseShardResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceCloseShardResult) GetInternalServiceError() (o *InternalServiceError)

+ type HistoryServiceDescribeHistoryHostArgs struct

+ Request *DescribeHistoryHostRequest

+ func (v *HistoryServiceDescribeHistoryHostArgs) GetRequest() (o *DescribeHistoryHostRequest)

+ type HistoryServiceDescribeHistoryHostResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ Success *DescribeHistoryHostResponse

+ func (v *HistoryServiceDescribeHistoryHostResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *HistoryServiceDescribeHistoryHostResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceDescribeHistoryHostResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceDescribeHistoryHostResult) GetSuccess() (o *DescribeHistoryHostResponse)

+ type HistoryServiceDescribeMutableStateArgs struct

+ Request *DescribeMutableStateRequest

+ func (v *HistoryServiceDescribeMutableStateArgs) GetRequest() (o *DescribeMutableStateRequest)

+ type HistoryServiceDescribeMutableStateResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *DescribeMutableStateResponse

+ func (v *HistoryServiceDescribeMutableStateResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *HistoryServiceDescribeMutableStateResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceDescribeMutableStateResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceDescribeMutableStateResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceDescribeMutableStateResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceDescribeMutableStateResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceDescribeMutableStateResult) GetSuccess() (o *DescribeMutableStateResponse)

+ type HistoryServiceDescribeQueueArgs struct

+ Request *DescribeQueueRequest

+ func (v *HistoryServiceDescribeQueueArgs) GetRequest() (o *DescribeQueueRequest)

+ type HistoryServiceDescribeQueueResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ Success *DescribeQueueResponse

+ func (v *HistoryServiceDescribeQueueResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *HistoryServiceDescribeQueueResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceDescribeQueueResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceDescribeQueueResult) GetSuccess() (o *DescribeQueueResponse)

+ type HistoryServiceDescribeWorkflowExecutionArgs struct

+ DescribeRequest *HistoryDescribeWorkflowExecutionRequest

+ func (v *HistoryServiceDescribeWorkflowExecutionArgs) GetDescribeRequest() (o *HistoryDescribeWorkflowExecutionRequest)

+ type HistoryServiceDescribeWorkflowExecutionResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *DescribeWorkflowExecutionResponse

+ func (v *HistoryServiceDescribeWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceDescribeWorkflowExecutionResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceDescribeWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceDescribeWorkflowExecutionResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceDescribeWorkflowExecutionResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceDescribeWorkflowExecutionResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceDescribeWorkflowExecutionResult) GetSuccess() (o *DescribeWorkflowExecutionResponse)

+ type HistoryServiceGetDLQReplicationMessagesArgs struct

+ Request *GetDLQReplicationMessagesRequest

+ func (v *HistoryServiceGetDLQReplicationMessagesArgs) GetRequest() (o *GetDLQReplicationMessagesRequest)

+ type HistoryServiceGetDLQReplicationMessagesResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ Success *GetDLQReplicationMessagesResponse

+ func (v *HistoryServiceGetDLQReplicationMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceGetDLQReplicationMessagesResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceGetDLQReplicationMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceGetDLQReplicationMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceGetDLQReplicationMessagesResult) GetSuccess() (o *GetDLQReplicationMessagesResponse)

+ type HistoryServiceGetMutableStateArgs struct

+ GetRequest *GetMutableStateRequest

+ func (v *HistoryServiceGetMutableStateArgs) GetGetRequest() (o *GetMutableStateRequest)

+ type HistoryServiceGetMutableStateResult struct

+ BadRequestError *BadRequestError

+ CurrentBranchChangedError *CurrentBranchChangedError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *GetMutableStateResponse

+ func (v *HistoryServiceGetMutableStateResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceGetMutableStateResult) GetCurrentBranchChangedError() (o *CurrentBranchChangedError)

+ func (v *HistoryServiceGetMutableStateResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceGetMutableStateResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceGetMutableStateResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceGetMutableStateResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceGetMutableStateResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceGetMutableStateResult) GetSuccess() (o *GetMutableStateResponse)

+ type HistoryServiceGetReplicationMessagesArgs struct

+ Request *GetReplicationMessagesRequest

+ func (v *HistoryServiceGetReplicationMessagesArgs) GetRequest() (o *GetReplicationMessagesRequest)

+ type HistoryServiceGetReplicationMessagesResult struct

+ BadRequestError *BadRequestError

+ ClientVersionNotSupportedError *ClientVersionNotSupportedError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ Success *GetReplicationMessagesResponse

+ func (v *HistoryServiceGetReplicationMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceGetReplicationMessagesResult) GetClientVersionNotSupportedError() (o *ClientVersionNotSupportedError)

+ func (v *HistoryServiceGetReplicationMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceGetReplicationMessagesResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceGetReplicationMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceGetReplicationMessagesResult) GetSuccess() (o *GetReplicationMessagesResponse)

+ type HistoryServiceMergeDLQMessagesArgs struct

+ Request *MergeDLQMessagesRequest

+ func (v *HistoryServiceMergeDLQMessagesArgs) GetRequest() (o *MergeDLQMessagesRequest)

+ type HistoryServiceMergeDLQMessagesResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *MergeDLQMessagesResponse

+ func (v *HistoryServiceMergeDLQMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceMergeDLQMessagesResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceMergeDLQMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceMergeDLQMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceMergeDLQMessagesResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceMergeDLQMessagesResult) GetSuccess() (o *MergeDLQMessagesResponse)

+ type HistoryServiceNotifyFailoverMarkersArgs struct

+ Request *NotifyFailoverMarkersRequest

+ func (v *HistoryServiceNotifyFailoverMarkersArgs) GetRequest() (o *NotifyFailoverMarkersRequest)

+ type HistoryServiceNotifyFailoverMarkersResult struct

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ func (v *HistoryServiceNotifyFailoverMarkersResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceNotifyFailoverMarkersResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceNotifyFailoverMarkersResult) GetServiceBusyError() (o *ServiceBusyError)

+ type HistoryServicePollMutableStateArgs struct

+ PollRequest *PollMutableStateRequest

+ func (v *HistoryServicePollMutableStateArgs) GetPollRequest() (o *PollMutableStateRequest)

+ type HistoryServicePollMutableStateResult struct

+ BadRequestError *BadRequestError

+ CurrentBranchChangedError *CurrentBranchChangedError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *PollMutableStateResponse

+ func (v *HistoryServicePollMutableStateResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServicePollMutableStateResult) GetCurrentBranchChangedError() (o *CurrentBranchChangedError)

+ func (v *HistoryServicePollMutableStateResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServicePollMutableStateResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServicePollMutableStateResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServicePollMutableStateResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServicePollMutableStateResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServicePollMutableStateResult) GetSuccess() (o *PollMutableStateResponse)

+ type HistoryServicePurgeDLQMessagesArgs struct

+ Request *PurgeDLQMessagesRequest

+ func (v *HistoryServicePurgeDLQMessagesArgs) GetRequest() (o *PurgeDLQMessagesRequest)

+ type HistoryServicePurgeDLQMessagesResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServicePurgeDLQMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServicePurgeDLQMessagesResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServicePurgeDLQMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServicePurgeDLQMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServicePurgeDLQMessagesResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceQueryWorkflowArgs struct

+ QueryRequest *HistoryQueryWorkflowRequest

+ func (v *HistoryServiceQueryWorkflowArgs) GetQueryRequest() (o *HistoryQueryWorkflowRequest)

+ type HistoryServiceQueryWorkflowResult struct

+ BadRequestError *BadRequestError

+ ClientVersionNotSupportedError *ClientVersionNotSupportedError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ QueryFailedError *QueryFailedError

+ ServiceBusyError *ServiceBusyError

+ Success *HistoryQueryWorkflowResponse

+ func (v *HistoryServiceQueryWorkflowResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceQueryWorkflowResult) GetClientVersionNotSupportedError() (o *ClientVersionNotSupportedError)

+ func (v *HistoryServiceQueryWorkflowResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceQueryWorkflowResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceQueryWorkflowResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceQueryWorkflowResult) GetQueryFailedError() (o *QueryFailedError)

+ func (v *HistoryServiceQueryWorkflowResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceQueryWorkflowResult) GetSuccess() (o *HistoryQueryWorkflowResponse)

+ type HistoryServiceReadDLQMessagesArgs struct

+ Request *ReadDLQMessagesRequest

+ func (v *HistoryServiceReadDLQMessagesArgs) GetRequest() (o *ReadDLQMessagesRequest)

+ type HistoryServiceReadDLQMessagesResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *ReadDLQMessagesResponse

+ func (v *HistoryServiceReadDLQMessagesResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceReadDLQMessagesResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceReadDLQMessagesResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceReadDLQMessagesResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceReadDLQMessagesResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceReadDLQMessagesResult) GetSuccess() (o *ReadDLQMessagesResponse)

+ type HistoryServiceReapplyEventsArgs struct

+ ReapplyEventsRequest *HistoryReapplyEventsRequest

+ func (v *HistoryServiceReapplyEventsArgs) GetReapplyEventsRequest() (o *HistoryReapplyEventsRequest)

+ type HistoryServiceReapplyEventsResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceReapplyEventsResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceReapplyEventsResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceReapplyEventsResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceReapplyEventsResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceReapplyEventsResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceReapplyEventsResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceReapplyEventsResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRecordActivityTaskHeartbeatArgs struct

+ HeartbeatRequest *HistoryRecordActivityTaskHeartbeatRequest

+ func (v *HistoryServiceRecordActivityTaskHeartbeatArgs) GetHeartbeatRequest() (o *HistoryRecordActivityTaskHeartbeatRequest)

+ type HistoryServiceRecordActivityTaskHeartbeatResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *RecordActivityTaskHeartbeatResponse

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceRecordActivityTaskHeartbeatResult) GetSuccess() (o *RecordActivityTaskHeartbeatResponse)

+ type HistoryServiceRecordActivityTaskStartedArgs struct

+ AddRequest *RecordActivityTaskStartedRequest

+ func (v *HistoryServiceRecordActivityTaskStartedArgs) GetAddRequest() (o *RecordActivityTaskStartedRequest)

+ type HistoryServiceRecordActivityTaskStartedResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ EventAlreadyStartedError *EventAlreadyStartedError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *RecordActivityTaskStartedResponse

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetEventAlreadyStartedError() (o *EventAlreadyStartedError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceRecordActivityTaskStartedResult) GetSuccess() (o *RecordActivityTaskStartedResponse)

+ type HistoryServiceRecordChildExecutionCompletedArgs struct

+ CompletionRequest *RecordChildExecutionCompletedRequest

+ func (v *HistoryServiceRecordChildExecutionCompletedArgs) GetCompletionRequest() (o *RecordChildExecutionCompletedRequest)

+ type HistoryServiceRecordChildExecutionCompletedResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRecordChildExecutionCompletedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRecordChildExecutionCompletedResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRecordChildExecutionCompletedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRecordChildExecutionCompletedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRecordChildExecutionCompletedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRecordChildExecutionCompletedResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRecordChildExecutionCompletedResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRecordDecisionTaskStartedArgs struct

+ AddRequest *RecordDecisionTaskStartedRequest

+ func (v *HistoryServiceRecordDecisionTaskStartedArgs) GetAddRequest() (o *RecordDecisionTaskStartedRequest)

+ type HistoryServiceRecordDecisionTaskStartedResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ EventAlreadyStartedError *EventAlreadyStartedError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *RecordDecisionTaskStartedResponse

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetEventAlreadyStartedError() (o *EventAlreadyStartedError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceRecordDecisionTaskStartedResult) GetSuccess() (o *RecordDecisionTaskStartedResponse)

+ type HistoryServiceRefreshWorkflowTasksArgs struct

+ Request *HistoryRefreshWorkflowTasksRequest

+ func (v *HistoryServiceRefreshWorkflowTasksArgs) GetRequest() (o *HistoryRefreshWorkflowTasksRequest)

+ type HistoryServiceRefreshWorkflowTasksResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRefreshWorkflowTasksResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRefreshWorkflowTasksResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRefreshWorkflowTasksResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRefreshWorkflowTasksResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRefreshWorkflowTasksResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRefreshWorkflowTasksResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRemoveSignalMutableStateArgs struct

+ RemoveRequest *RemoveSignalMutableStateRequest

+ func (v *HistoryServiceRemoveSignalMutableStateArgs) GetRemoveRequest() (o *RemoveSignalMutableStateRequest)

+ type HistoryServiceRemoveSignalMutableStateResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRemoveSignalMutableStateResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRemoveSignalMutableStateResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRemoveSignalMutableStateResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRemoveSignalMutableStateResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRemoveSignalMutableStateResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRemoveSignalMutableStateResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRemoveSignalMutableStateResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRemoveTaskArgs struct

+ Request *RemoveTaskRequest

+ func (v *HistoryServiceRemoveTaskArgs) GetRequest() (o *RemoveTaskRequest)

+ type HistoryServiceRemoveTaskResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ func (v *HistoryServiceRemoveTaskResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *HistoryServiceRemoveTaskResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRemoveTaskResult) GetInternalServiceError() (o *InternalServiceError)

+ type HistoryServiceReplicateEventsV2Args struct

+ ReplicateV2Request *ReplicateEventsV2Request

+ func (v *HistoryServiceReplicateEventsV2Args) GetReplicateV2Request() (o *ReplicateEventsV2Request)

+ type HistoryServiceReplicateEventsV2Result struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ RetryTaskError *RetryTaskV2Error

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceReplicateEventsV2Result) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceReplicateEventsV2Result) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceReplicateEventsV2Result) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceReplicateEventsV2Result) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceReplicateEventsV2Result) GetRetryTaskError() (o *RetryTaskV2Error)

+ func (v *HistoryServiceReplicateEventsV2Result) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceReplicateEventsV2Result) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRequestCancelWorkflowExecutionArgs struct

+ CancelRequest *HistoryRequestCancelWorkflowExecutionRequest

+ func (v *HistoryServiceRequestCancelWorkflowExecutionArgs) GetCancelRequest() (o *HistoryRequestCancelWorkflowExecutionRequest)

+ type HistoryServiceRequestCancelWorkflowExecutionResult struct

+ BadRequestError *BadRequestError

+ CancellationAlreadyRequestedError *CancellationAlreadyRequestedError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetCancellationAlreadyRequestedError() (o *CancellationAlreadyRequestedError)

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRequestCancelWorkflowExecutionResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceResetQueueArgs struct

+ Request *ResetQueueRequest

+ func (v *HistoryServiceResetQueueArgs) GetRequest() (o *ResetQueueRequest)

+ type HistoryServiceResetQueueResult struct

+ AccessDeniedError *AccessDeniedError

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ func (v *HistoryServiceResetQueueResult) GetAccessDeniedError() (o *AccessDeniedError)

+ func (v *HistoryServiceResetQueueResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceResetQueueResult) GetInternalServiceError() (o *InternalServiceError)

+ type HistoryServiceResetStickyTaskListArgs struct

+ ResetRequest *HistoryResetStickyTaskListRequest

+ func (v *HistoryServiceResetStickyTaskListArgs) GetResetRequest() (o *HistoryResetStickyTaskListRequest)

+ type HistoryServiceResetStickyTaskListResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *HistoryResetStickyTaskListResponse

+ func (v *HistoryServiceResetStickyTaskListResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceResetStickyTaskListResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceResetStickyTaskListResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceResetStickyTaskListResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceResetStickyTaskListResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceResetStickyTaskListResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceResetStickyTaskListResult) GetSuccess() (o *HistoryResetStickyTaskListResponse)

+ type HistoryServiceResetWorkflowExecutionArgs struct

+ ResetRequest *HistoryResetWorkflowExecutionRequest

+ func (v *HistoryServiceResetWorkflowExecutionArgs) GetResetRequest() (o *HistoryResetWorkflowExecutionRequest)

+ type HistoryServiceResetWorkflowExecutionResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *ResetWorkflowExecutionResponse

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceResetWorkflowExecutionResult) GetSuccess() (o *ResetWorkflowExecutionResponse)

+ type HistoryServiceRespondActivityTaskCanceledArgs struct

+ CanceledRequest *HistoryRespondActivityTaskCanceledRequest

+ func (v *HistoryServiceRespondActivityTaskCanceledArgs) GetCanceledRequest() (o *HistoryRespondActivityTaskCanceledRequest)

+ type HistoryServiceRespondActivityTaskCanceledResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRespondActivityTaskCanceledResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRespondActivityTaskCanceledResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRespondActivityTaskCanceledResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRespondActivityTaskCanceledResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRespondActivityTaskCanceledResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRespondActivityTaskCanceledResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRespondActivityTaskCanceledResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRespondActivityTaskCompletedArgs struct

+ CompleteRequest *HistoryRespondActivityTaskCompletedRequest

+ func (v *HistoryServiceRespondActivityTaskCompletedArgs) GetCompleteRequest() (o *HistoryRespondActivityTaskCompletedRequest)

+ type HistoryServiceRespondActivityTaskCompletedResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRespondActivityTaskCompletedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRespondActivityTaskCompletedResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRespondActivityTaskCompletedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRespondActivityTaskCompletedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRespondActivityTaskCompletedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRespondActivityTaskCompletedResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRespondActivityTaskCompletedResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRespondActivityTaskFailedArgs struct

+ FailRequest *HistoryRespondActivityTaskFailedRequest

+ func (v *HistoryServiceRespondActivityTaskFailedArgs) GetFailRequest() (o *HistoryRespondActivityTaskFailedRequest)

+ type HistoryServiceRespondActivityTaskFailedResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRespondActivityTaskFailedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRespondActivityTaskFailedResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRespondActivityTaskFailedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRespondActivityTaskFailedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRespondActivityTaskFailedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRespondActivityTaskFailedResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRespondActivityTaskFailedResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceRespondDecisionTaskCompletedArgs struct

+ CompleteRequest *HistoryRespondDecisionTaskCompletedRequest

+ func (v *HistoryServiceRespondDecisionTaskCompletedArgs) GetCompleteRequest() (o *HistoryRespondDecisionTaskCompletedRequest)

+ type HistoryServiceRespondDecisionTaskCompletedResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *HistoryRespondDecisionTaskCompletedResponse

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceRespondDecisionTaskCompletedResult) GetSuccess() (o *HistoryRespondDecisionTaskCompletedResponse)

+ type HistoryServiceRespondDecisionTaskFailedArgs struct

+ FailedRequest *HistoryRespondDecisionTaskFailedRequest

+ func (v *HistoryServiceRespondDecisionTaskFailedArgs) GetFailedRequest() (o *HistoryRespondDecisionTaskFailedRequest)

+ type HistoryServiceRespondDecisionTaskFailedResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceRespondDecisionTaskFailedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceRespondDecisionTaskFailedResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceRespondDecisionTaskFailedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceRespondDecisionTaskFailedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceRespondDecisionTaskFailedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceRespondDecisionTaskFailedResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceRespondDecisionTaskFailedResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceScheduleDecisionTaskArgs struct

+ ScheduleRequest *ScheduleDecisionTaskRequest

+ func (v *HistoryServiceScheduleDecisionTaskArgs) GetScheduleRequest() (o *ScheduleDecisionTaskRequest)

+ type HistoryServiceScheduleDecisionTaskResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceScheduleDecisionTaskResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceScheduleDecisionTaskResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceScheduleDecisionTaskResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceScheduleDecisionTaskResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceScheduleDecisionTaskResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceScheduleDecisionTaskResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceScheduleDecisionTaskResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceSignalWithStartWorkflowExecutionArgs struct

+ SignalWithStartRequest *HistorySignalWithStartWorkflowExecutionRequest

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionArgs) GetSignalWithStartRequest() (o *HistorySignalWithStartWorkflowExecutionRequest)

+ type HistoryServiceSignalWithStartWorkflowExecutionResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *StartWorkflowExecutionResponse

+ WorkflowAlreadyStartedError *WorkflowExecutionAlreadyStartedError

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetSuccess() (o *StartWorkflowExecutionResponse)

+ func (v *HistoryServiceSignalWithStartWorkflowExecutionResult) GetWorkflowAlreadyStartedError() (o *WorkflowExecutionAlreadyStartedError)

+ type HistoryServiceSignalWorkflowExecutionArgs struct

+ SignalRequest *HistorySignalWorkflowExecutionRequest

+ func (v *HistoryServiceSignalWorkflowExecutionArgs) GetSignalRequest() (o *HistorySignalWorkflowExecutionRequest)

+ type HistoryServiceSignalWorkflowExecutionResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceSignalWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceSignalWorkflowExecutionResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceSignalWorkflowExecutionResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceSignalWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceSignalWorkflowExecutionResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceSignalWorkflowExecutionResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceSignalWorkflowExecutionResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceStartWorkflowExecutionArgs struct

+ StartRequest *HistoryStartWorkflowExecutionRequest

+ func (v *HistoryServiceStartWorkflowExecutionArgs) GetStartRequest() (o *HistoryStartWorkflowExecutionRequest)

+ type HistoryServiceStartWorkflowExecutionResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ SessionAlreadyExistError *WorkflowExecutionAlreadyStartedError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ Success *StartWorkflowExecutionResponse

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetSessionAlreadyExistError() (o *WorkflowExecutionAlreadyStartedError)

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ func (v *HistoryServiceStartWorkflowExecutionResult) GetSuccess() (o *StartWorkflowExecutionResponse)

+ type HistoryServiceSyncActivityArgs struct

+ SyncActivityRequest *SyncActivityRequest

+ func (v *HistoryServiceSyncActivityArgs) GetSyncActivityRequest() (o *SyncActivityRequest)

+ type HistoryServiceSyncActivityResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ RetryTaskV2Error *RetryTaskV2Error

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceSyncActivityResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceSyncActivityResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceSyncActivityResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceSyncActivityResult) GetRetryTaskV2Error() (o *RetryTaskV2Error)

+ func (v *HistoryServiceSyncActivityResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceSyncActivityResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceSyncShardStatusArgs struct

+ SyncShardStatusRequest *SyncShardStatusRequest

+ func (v *HistoryServiceSyncShardStatusArgs) GetSyncShardStatusRequest() (o *SyncShardStatusRequest)

+ type HistoryServiceSyncShardStatusResult struct

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceSyncShardStatusResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceSyncShardStatusResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceSyncShardStatusResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceSyncShardStatusResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceSyncShardStatusResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistoryServiceTerminateWorkflowExecutionArgs struct

+ TerminateRequest *HistoryTerminateWorkflowExecutionRequest

+ func (v *HistoryServiceTerminateWorkflowExecutionArgs) GetTerminateRequest() (o *HistoryTerminateWorkflowExecutionRequest)

+ type HistoryServiceTerminateWorkflowExecutionResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ ShardOwnershipLostError *ShardOwnershipLostError

+ func (v *HistoryServiceTerminateWorkflowExecutionResult) GetBadRequestError() (o *BadRequestError)

+ func (v *HistoryServiceTerminateWorkflowExecutionResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *HistoryServiceTerminateWorkflowExecutionResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *HistoryServiceTerminateWorkflowExecutionResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *HistoryServiceTerminateWorkflowExecutionResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *HistoryServiceTerminateWorkflowExecutionResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *HistoryServiceTerminateWorkflowExecutionResult) GetShardOwnershipLostError() (o *ShardOwnershipLostError)

+ type HistorySignalWithStartWorkflowExecutionRequest struct

+ DomainUUID *string

+ SignalWithStartRequest *SignalWithStartWorkflowExecutionRequest

+ func (v *HistorySignalWithStartWorkflowExecutionRequest) GetDomainUUID() (o string)

+ func (v *HistorySignalWithStartWorkflowExecutionRequest) GetSignalWithStartRequest() (o *SignalWithStartWorkflowExecutionRequest)

+ type HistorySignalWorkflowExecutionRequest struct

+ ChildWorkflowOnly *bool

+ DomainUUID *string

+ ExternalWorkflowExecution *WorkflowExecution

+ SignalRequest *SignalWorkflowExecutionRequest

+ func (v *HistorySignalWorkflowExecutionRequest) GetChildWorkflowOnly() (o bool)

+ func (v *HistorySignalWorkflowExecutionRequest) GetDomainUUID() (o string)

+ func (v *HistorySignalWorkflowExecutionRequest) GetExternalWorkflowExecution() (o *WorkflowExecution)

+ func (v *HistorySignalWorkflowExecutionRequest) GetSignalRequest() (o *SignalWorkflowExecutionRequest)

+ type HistoryStartWorkflowExecutionRequest struct

+ Attempt *int32

+ ContinueAsNewInitiator *ContinueAsNewInitiator

+ ContinuedFailureDetails []byte

+ ContinuedFailureReason *string

+ DomainUUID *string

+ ExpirationTimestamp *int64

+ FirstDecisionTaskBackoffSeconds *int32

+ LastCompletionResult []byte

+ ParentExecutionInfo *ParentExecutionInfo

+ StartRequest *StartWorkflowExecutionRequest

+ func (v *HistoryStartWorkflowExecutionRequest) GetAttempt() (o int32)

+ func (v *HistoryStartWorkflowExecutionRequest) GetContinueAsNewInitiator() (o *ContinueAsNewInitiator)

+ func (v *HistoryStartWorkflowExecutionRequest) GetContinuedFailureDetails() (o []byte)

+ func (v *HistoryStartWorkflowExecutionRequest) GetContinuedFailureReason() (o string)

+ func (v *HistoryStartWorkflowExecutionRequest) GetDomainUUID() (o string)

+ func (v *HistoryStartWorkflowExecutionRequest) GetExpirationTimestamp() (o int64)

+ func (v *HistoryStartWorkflowExecutionRequest) GetFirstDecisionTaskBackoffSeconds() (o int32)

+ func (v *HistoryStartWorkflowExecutionRequest) GetLastCompletionResult() (o []byte)

+ func (v *HistoryStartWorkflowExecutionRequest) GetParentExecutionInfo() (o *ParentExecutionInfo)

+ func (v *HistoryStartWorkflowExecutionRequest) GetStartRequest() (o *StartWorkflowExecutionRequest)

+ type HistoryTaskV2Attributes struct

+ DomainID *string

+ Events *DataBlob

+ NewRunEvents *DataBlob

+ RunID *string

+ TaskID *int64

+ VersionHistoryItems []*VersionHistoryItem

+ WorkflowID *string

+ func (v *HistoryTaskV2Attributes) GetDomainID() (o string)

+ func (v *HistoryTaskV2Attributes) GetEvents() (o *DataBlob)

+ func (v *HistoryTaskV2Attributes) GetNewRunEvents() (o *DataBlob)

+ func (v *HistoryTaskV2Attributes) GetRunID() (o string)

+ func (v *HistoryTaskV2Attributes) GetTaskID() (o int64)

+ func (v *HistoryTaskV2Attributes) GetVersionHistoryItems() (o []*VersionHistoryItem)

+ func (v *HistoryTaskV2Attributes) GetWorkflowID() (o string)

+ type HistoryTerminateWorkflowExecutionRequest struct

+ DomainUUID *string

+ TerminateRequest *TerminateWorkflowExecutionRequest

+ func (v *HistoryTerminateWorkflowExecutionRequest) GetDomainUUID() (o string)

+ func (v *HistoryTerminateWorkflowExecutionRequest) GetTerminateRequest() (o *TerminateWorkflowExecutionRequest)

+ type HostInfo struct

+ Identity *string

+ func (v *HostInfo) GetIdentity() (o string)

type IndexedValueType

+ func (e IndexedValueType) Ptr() *IndexedValueType

type InternalDataInconsistencyError

+ func (v *InternalDataInconsistencyError) GetMessage() (o string)

type InternalServiceError

+ func (v *InternalServiceError) GetMessage() (o string)

type LimitExceededError

+ func (v *LimitExceededError) GetMessage() (o string)

type ListArchivedWorkflowExecutionsRequest

+ func (v *ListArchivedWorkflowExecutionsRequest) GetDomain() (o string)

+ func (v *ListArchivedWorkflowExecutionsRequest) GetNextPageToken() (o []byte)

+ func (v *ListArchivedWorkflowExecutionsRequest) GetPageSize() (o int32)

+ func (v *ListArchivedWorkflowExecutionsRequest) GetQuery() (o string)

type ListArchivedWorkflowExecutionsResponse

+ func (v *ListArchivedWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo)

+ func (v *ListArchivedWorkflowExecutionsResponse) GetNextPageToken() (o []byte)

type ListClosedWorkflowExecutionsRequest

+ func (v *ListClosedWorkflowExecutionsRequest) GetDomain() (o string)

+ func (v *ListClosedWorkflowExecutionsRequest) GetExecutionFilter() (o *WorkflowExecutionFilter)

+ func (v *ListClosedWorkflowExecutionsRequest) GetMaximumPageSize() (o int32)

+ func (v *ListClosedWorkflowExecutionsRequest) GetNextPageToken() (o []byte)

+ func (v *ListClosedWorkflowExecutionsRequest) GetStartTimeFilter() (o *StartTimeFilter)

+ func (v *ListClosedWorkflowExecutionsRequest) GetStatusFilter() (o WorkflowExecutionCloseStatus)

+ func (v *ListClosedWorkflowExecutionsRequest) GetTypeFilter() (o *WorkflowTypeFilter)

type ListClosedWorkflowExecutionsResponse

+ func (v *ListClosedWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo)

+ func (v *ListClosedWorkflowExecutionsResponse) GetNextPageToken() (o []byte)

type ListDomainsRequest

+ func (v *ListDomainsRequest) GetNextPageToken() (o []byte)

+ func (v *ListDomainsRequest) GetPageSize() (o int32)

type ListDomainsResponse

+ func (v *ListDomainsResponse) GetDomains() (o []*DescribeDomainResponse)

+ func (v *ListDomainsResponse) GetNextPageToken() (o []byte)

type ListOpenWorkflowExecutionsRequest

+ func (v *ListOpenWorkflowExecutionsRequest) GetDomain() (o string)

+ func (v *ListOpenWorkflowExecutionsRequest) GetExecutionFilter() (o *WorkflowExecutionFilter)

+ func (v *ListOpenWorkflowExecutionsRequest) GetMaximumPageSize() (o int32)

+ func (v *ListOpenWorkflowExecutionsRequest) GetNextPageToken() (o []byte)

+ func (v *ListOpenWorkflowExecutionsRequest) GetStartTimeFilter() (o *StartTimeFilter)

+ func (v *ListOpenWorkflowExecutionsRequest) GetTypeFilter() (o *WorkflowTypeFilter)

type ListOpenWorkflowExecutionsResponse

+ func (v *ListOpenWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo)

+ func (v *ListOpenWorkflowExecutionsResponse) GetNextPageToken() (o []byte)

type ListTaskListPartitionsRequest

+ func (v *ListTaskListPartitionsRequest) GetDomain() (o string)

+ func (v *ListTaskListPartitionsRequest) GetTaskList() (o *TaskList)

type ListTaskListPartitionsResponse

+ func (v *ListTaskListPartitionsResponse) GetActivityTaskListPartitions() (o []*TaskListPartitionMetadata)

+ func (v *ListTaskListPartitionsResponse) GetDecisionTaskListPartitions() (o []*TaskListPartitionMetadata)

type ListWorkflowExecutionsRequest

+ func (v *ListWorkflowExecutionsRequest) GetDomain() (o string)

+ func (v *ListWorkflowExecutionsRequest) GetNextPageToken() (o []byte)

+ func (v *ListWorkflowExecutionsRequest) GetPageSize() (o int32)

+ func (v *ListWorkflowExecutionsRequest) GetQuery() (o string)

type ListWorkflowExecutionsResponse

+ func (v *ListWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo)

+ func (v *ListWorkflowExecutionsResponse) GetNextPageToken() (o []byte)

type MarkerRecordedEventAttributes

+ func (v *MarkerRecordedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *MarkerRecordedEventAttributes) GetDetails() (o []byte)

+ func (v *MarkerRecordedEventAttributes) GetHeader() (o *Header)

+ func (v *MarkerRecordedEventAttributes) GetMarkerName() (o string)

+ type MatchingDescribeTaskListRequest struct

+ DescRequest *DescribeTaskListRequest

+ DomainUUID *string

+ func (v *MatchingDescribeTaskListRequest) GetDescRequest() (o *DescribeTaskListRequest)

+ func (v *MatchingDescribeTaskListRequest) GetDomainUUID() (o string)

+ type MatchingListTaskListPartitionsRequest struct

+ Domain *string

+ TaskList *TaskList

+ func (v *MatchingListTaskListPartitionsRequest) GetDomain() (o string)

+ func (v *MatchingListTaskListPartitionsRequest) GetTaskList() (o *TaskList)

+ type MatchingPollForActivityTaskRequest struct

+ DomainUUID *string

+ ForwardedFrom *string

+ PollRequest *PollForActivityTaskRequest

+ PollerID *string

+ func (v *MatchingPollForActivityTaskRequest) GetDomainUUID() (o string)

+ func (v *MatchingPollForActivityTaskRequest) GetForwardedFrom() (o string)

+ func (v *MatchingPollForActivityTaskRequest) GetPollRequest() (o *PollForActivityTaskRequest)

+ func (v *MatchingPollForActivityTaskRequest) GetPollerID() (o string)

+ type MatchingPollForDecisionTaskRequest struct

+ DomainUUID *string

+ ForwardedFrom *string

+ PollRequest *PollForDecisionTaskRequest

+ PollerID *string

+ func (v *MatchingPollForDecisionTaskRequest) GetDomainUUID() (o string)

+ func (v *MatchingPollForDecisionTaskRequest) GetForwardedFrom() (o string)

+ func (v *MatchingPollForDecisionTaskRequest) GetPollRequest() (o *PollForDecisionTaskRequest)

+ func (v *MatchingPollForDecisionTaskRequest) GetPollerID() (o string)

+ type MatchingPollForDecisionTaskResponse struct

+ Attempt *int64

+ BacklogCountHint *int64

+ BranchToken []byte

+ DecisionInfo *TransientDecisionInfo

+ EventStoreVersion *int32

+ NextEventID *int64

+ PreviousStartedEventID *int64

+ Queries map[string]*WorkflowQuery

+ Query *WorkflowQuery

+ ScheduledTimestamp *int64

+ StartedEventID *int64

+ StartedTimestamp *int64

+ StickyExecutionEnabled *bool

+ TaskToken []byte

+ WorkflowExecution *WorkflowExecution

+ WorkflowExecutionTaskList *TaskList

+ WorkflowType *WorkflowType

+ func (v *MatchingPollForDecisionTaskResponse) GetAttempt() (o int64)

+ func (v *MatchingPollForDecisionTaskResponse) GetBacklogCountHint() (o int64)

+ func (v *MatchingPollForDecisionTaskResponse) GetBranchToken() (o []byte)

+ func (v *MatchingPollForDecisionTaskResponse) GetDecisionInfo() (o *TransientDecisionInfo)

+ func (v *MatchingPollForDecisionTaskResponse) GetEventStoreVersion() (o int32)

+ func (v *MatchingPollForDecisionTaskResponse) GetNextEventID() (o int64)

+ func (v *MatchingPollForDecisionTaskResponse) GetPreviousStartedEventID() (o int64)

+ func (v *MatchingPollForDecisionTaskResponse) GetQueries() (o map[string]*WorkflowQuery)

+ func (v *MatchingPollForDecisionTaskResponse) GetQuery() (o *WorkflowQuery)

+ func (v *MatchingPollForDecisionTaskResponse) GetScheduledTimestamp() (o int64)

+ func (v *MatchingPollForDecisionTaskResponse) GetStartedEventID() (o int64)

+ func (v *MatchingPollForDecisionTaskResponse) GetStartedTimestamp() (o int64)

+ func (v *MatchingPollForDecisionTaskResponse) GetStickyExecutionEnabled() (o bool)

+ func (v *MatchingPollForDecisionTaskResponse) GetTaskToken() (o []byte)

+ func (v *MatchingPollForDecisionTaskResponse) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *MatchingPollForDecisionTaskResponse) GetWorkflowExecutionTaskList() (o *TaskList)

+ func (v *MatchingPollForDecisionTaskResponse) GetWorkflowType() (o *WorkflowType)

+ type MatchingQueryWorkflowRequest struct

+ DomainUUID *string

+ ForwardedFrom *string

+ QueryRequest *QueryWorkflowRequest

+ TaskList *TaskList

+ func (v *MatchingQueryWorkflowRequest) GetDomainUUID() (o string)

+ func (v *MatchingQueryWorkflowRequest) GetForwardedFrom() (o string)

+ func (v *MatchingQueryWorkflowRequest) GetQueryRequest() (o *QueryWorkflowRequest)

+ func (v *MatchingQueryWorkflowRequest) GetTaskList() (o *TaskList)

+ type MatchingRespondQueryTaskCompletedRequest struct

+ CompletedRequest *RespondQueryTaskCompletedRequest

+ DomainUUID *string

+ TaskID *string

+ TaskList *TaskList

+ func (v *MatchingRespondQueryTaskCompletedRequest) GetCompletedRequest() (o *RespondQueryTaskCompletedRequest)

+ func (v *MatchingRespondQueryTaskCompletedRequest) GetDomainUUID() (o string)

+ func (v *MatchingRespondQueryTaskCompletedRequest) GetTaskID() (o string)

+ func (v *MatchingRespondQueryTaskCompletedRequest) GetTaskList() (o *TaskList)

+ type MatchingServiceAddActivityTaskArgs struct

+ AddRequest *AddActivityTaskRequest

+ func (v *MatchingServiceAddActivityTaskArgs) GetAddRequest() (o *AddActivityTaskRequest)

+ type MatchingServiceAddActivityTaskResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ RemoteSyncMatchedError *RemoteSyncMatchedError

+ ServiceBusyError *ServiceBusyError

+ func (v *MatchingServiceAddActivityTaskResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServiceAddActivityTaskResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *MatchingServiceAddActivityTaskResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServiceAddActivityTaskResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *MatchingServiceAddActivityTaskResult) GetRemoteSyncMatchedError() (o *RemoteSyncMatchedError)

+ func (v *MatchingServiceAddActivityTaskResult) GetServiceBusyError() (o *ServiceBusyError)

+ type MatchingServiceAddDecisionTaskArgs struct

+ AddRequest *AddDecisionTaskRequest

+ func (v *MatchingServiceAddDecisionTaskArgs) GetAddRequest() (o *AddDecisionTaskRequest)

+ type MatchingServiceAddDecisionTaskResult struct

+ BadRequestError *BadRequestError

+ DomainNotActiveError *DomainNotActiveError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ RemoteSyncMatchedError *RemoteSyncMatchedError

+ ServiceBusyError *ServiceBusyError

+ func (v *MatchingServiceAddDecisionTaskResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServiceAddDecisionTaskResult) GetDomainNotActiveError() (o *DomainNotActiveError)

+ func (v *MatchingServiceAddDecisionTaskResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServiceAddDecisionTaskResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *MatchingServiceAddDecisionTaskResult) GetRemoteSyncMatchedError() (o *RemoteSyncMatchedError)

+ func (v *MatchingServiceAddDecisionTaskResult) GetServiceBusyError() (o *ServiceBusyError)

+ type MatchingServiceCancelOutstandingPollArgs struct

+ Request *CancelOutstandingPollRequest

+ func (v *MatchingServiceCancelOutstandingPollArgs) GetRequest() (o *CancelOutstandingPollRequest)

+ type MatchingServiceCancelOutstandingPollResult struct

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ func (v *MatchingServiceCancelOutstandingPollResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServiceCancelOutstandingPollResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServiceCancelOutstandingPollResult) GetServiceBusyError() (o *ServiceBusyError)

+ type MatchingServiceDescribeTaskListArgs struct

+ Request *MatchingDescribeTaskListRequest

+ func (v *MatchingServiceDescribeTaskListArgs) GetRequest() (o *MatchingDescribeTaskListRequest)

+ type MatchingServiceDescribeTaskListResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ Success *DescribeTaskListResponse

+ func (v *MatchingServiceDescribeTaskListResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServiceDescribeTaskListResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *MatchingServiceDescribeTaskListResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServiceDescribeTaskListResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *MatchingServiceDescribeTaskListResult) GetSuccess() (o *DescribeTaskListResponse)

+ type MatchingServiceListTaskListPartitionsArgs struct

+ Request *MatchingListTaskListPartitionsRequest

+ func (v *MatchingServiceListTaskListPartitionsArgs) GetRequest() (o *MatchingListTaskListPartitionsRequest)

+ type MatchingServiceListTaskListPartitionsResult struct

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ ServiceBusyError *ServiceBusyError

+ Success *ListTaskListPartitionsResponse

+ func (v *MatchingServiceListTaskListPartitionsResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServiceListTaskListPartitionsResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServiceListTaskListPartitionsResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *MatchingServiceListTaskListPartitionsResult) GetSuccess() (o *ListTaskListPartitionsResponse)

+ type MatchingServicePollForActivityTaskArgs struct

+ PollRequest *MatchingPollForActivityTaskRequest

+ func (v *MatchingServicePollForActivityTaskArgs) GetPollRequest() (o *MatchingPollForActivityTaskRequest)

+ type MatchingServicePollForActivityTaskResult struct

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ Success *PollForActivityTaskResponse

+ func (v *MatchingServicePollForActivityTaskResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServicePollForActivityTaskResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServicePollForActivityTaskResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *MatchingServicePollForActivityTaskResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *MatchingServicePollForActivityTaskResult) GetSuccess() (o *PollForActivityTaskResponse)

+ type MatchingServicePollForDecisionTaskArgs struct

+ PollRequest *MatchingPollForDecisionTaskRequest

+ func (v *MatchingServicePollForDecisionTaskArgs) GetPollRequest() (o *MatchingPollForDecisionTaskRequest)

+ type MatchingServicePollForDecisionTaskResult struct

+ BadRequestError *BadRequestError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ Success *MatchingPollForDecisionTaskResponse

+ func (v *MatchingServicePollForDecisionTaskResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServicePollForDecisionTaskResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServicePollForDecisionTaskResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *MatchingServicePollForDecisionTaskResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *MatchingServicePollForDecisionTaskResult) GetSuccess() (o *MatchingPollForDecisionTaskResponse)

+ type MatchingServiceQueryWorkflowArgs struct

+ QueryRequest *MatchingQueryWorkflowRequest

+ func (v *MatchingServiceQueryWorkflowArgs) GetQueryRequest() (o *MatchingQueryWorkflowRequest)

+ type MatchingServiceQueryWorkflowResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ QueryFailedError *QueryFailedError

+ ServiceBusyError *ServiceBusyError

+ Success *QueryWorkflowResponse

+ func (v *MatchingServiceQueryWorkflowResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServiceQueryWorkflowResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *MatchingServiceQueryWorkflowResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServiceQueryWorkflowResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *MatchingServiceQueryWorkflowResult) GetQueryFailedError() (o *QueryFailedError)

+ func (v *MatchingServiceQueryWorkflowResult) GetServiceBusyError() (o *ServiceBusyError)

+ func (v *MatchingServiceQueryWorkflowResult) GetSuccess() (o *QueryWorkflowResponse)

+ type MatchingServiceRespondQueryTaskCompletedArgs struct

+ Request *MatchingRespondQueryTaskCompletedRequest

+ func (v *MatchingServiceRespondQueryTaskCompletedArgs) GetRequest() (o *MatchingRespondQueryTaskCompletedRequest)

+ type MatchingServiceRespondQueryTaskCompletedResult struct

+ BadRequestError *BadRequestError

+ EntityNotExistError *EntityNotExistsError

+ InternalServiceError *InternalServiceError

+ LimitExceededError *LimitExceededError

+ ServiceBusyError *ServiceBusyError

+ func (v *MatchingServiceRespondQueryTaskCompletedResult) GetBadRequestError() (o *BadRequestError)

+ func (v *MatchingServiceRespondQueryTaskCompletedResult) GetEntityNotExistError() (o *EntityNotExistsError)

+ func (v *MatchingServiceRespondQueryTaskCompletedResult) GetInternalServiceError() (o *InternalServiceError)

+ func (v *MatchingServiceRespondQueryTaskCompletedResult) GetLimitExceededError() (o *LimitExceededError)

+ func (v *MatchingServiceRespondQueryTaskCompletedResult) GetServiceBusyError() (o *ServiceBusyError)

+ type MembershipInfo struct

+ CurrentHost *HostInfo

+ ReachableMembers []string

+ Rings []*RingInfo

+ func (v *MembershipInfo) GetCurrentHost() (o *HostInfo)

+ func (v *MembershipInfo) GetReachableMembers() (o []string)

+ func (v *MembershipInfo) GetRings() (o []*RingInfo)

type Memo

+ func (v *Memo) GetFields() (o map[string][]byte)

+ type MergeDLQMessagesRequest struct

+ InclusiveEndMessageID *int64

+ MaximumPageSize *int32

+ NextPageToken []byte

+ ShardID *int32

+ SourceCluster *string

+ Type *DLQType

+ func (v *MergeDLQMessagesRequest) GetInclusiveEndMessageID() (o int64)

+ func (v *MergeDLQMessagesRequest) GetMaximumPageSize() (o int32)

+ func (v *MergeDLQMessagesRequest) GetNextPageToken() (o []byte)

+ func (v *MergeDLQMessagesRequest) GetShardID() (o int32)

+ func (v *MergeDLQMessagesRequest) GetSourceCluster() (o string)

+ func (v *MergeDLQMessagesRequest) GetType() (o DLQType)

+ type MergeDLQMessagesResponse struct

+ NextPageToken []byte

+ func (v *MergeDLQMessagesResponse) GetNextPageToken() (o []byte)

+ type NotifyFailoverMarkersRequest struct

+ FailoverMarkerTokens []*FailoverMarkerToken

+ func (v *NotifyFailoverMarkersRequest) GetFailoverMarkerTokens() (o []*FailoverMarkerToken)

type ParentClosePolicy

+ func (e ParentClosePolicy) Ptr() *ParentClosePolicy

+ type ParentExecutionInfo struct

+ Domain *string

+ DomainUUID *string

+ Execution *WorkflowExecution

+ InitiatedID *int64

+ func (v *ParentExecutionInfo) GetDomain() (o string)

+ func (v *ParentExecutionInfo) GetDomainUUID() (o string)

+ func (v *ParentExecutionInfo) GetExecution() (o *WorkflowExecution)

+ func (v *ParentExecutionInfo) GetInitiatedID() (o int64)

type PendingActivityInfo

+ func (v *PendingActivityInfo) GetActivityID() (o string)

+ func (v *PendingActivityInfo) GetActivityType() (o *ActivityType)

+ func (v *PendingActivityInfo) GetAttempt() (o int32)

+ func (v *PendingActivityInfo) GetExpirationTimestamp() (o int64)

+ func (v *PendingActivityInfo) GetHeartbeatDetails() (o []byte)

+ func (v *PendingActivityInfo) GetLastFailureDetails() (o []byte)

+ func (v *PendingActivityInfo) GetLastFailureReason() (o string)

+ func (v *PendingActivityInfo) GetLastHeartbeatTimestamp() (o int64)

+ func (v *PendingActivityInfo) GetLastStartedTimestamp() (o int64)

+ func (v *PendingActivityInfo) GetLastWorkerIdentity() (o string)

+ func (v *PendingActivityInfo) GetMaximumAttempts() (o int32)

+ func (v *PendingActivityInfo) GetScheduledTimestamp() (o int64)

+ func (v *PendingActivityInfo) GetState() (o PendingActivityState)

type PendingActivityState

+ func (e PendingActivityState) Ptr() *PendingActivityState

type PendingChildExecutionInfo

+ func (v *PendingChildExecutionInfo) GetInitiatedID() (o int64)

+ func (v *PendingChildExecutionInfo) GetParentClosePolicy() (o ParentClosePolicy)

+ func (v *PendingChildExecutionInfo) GetRunID() (o string)

+ func (v *PendingChildExecutionInfo) GetWorkflowID() (o string)

+ func (v *PendingChildExecutionInfo) GetWorkflowTypName() (o string)

+ type PendingDecisionInfo struct

+ Attempt *int64

+ OriginalScheduledTimestamp *int64

+ ScheduledTimestamp *int64

+ StartedTimestamp *int64

+ State *PendingDecisionState

+ func (v *PendingDecisionInfo) GetAttempt() (o int64)

+ func (v *PendingDecisionInfo) GetOriginalScheduledTimestamp() (o int64)

+ func (v *PendingDecisionInfo) GetScheduledTimestamp() (o int64)

+ func (v *PendingDecisionInfo) GetStartedTimestamp() (o int64)

+ func (v *PendingDecisionInfo) GetState() (o PendingDecisionState)

+ type PendingDecisionState int32

+ const PendingDecisionStateScheduled

+ const PendingDecisionStateStarted

+ func (e PendingDecisionState) Ptr() *PendingDecisionState

type PollForActivityTaskRequest

+ func (v *PollForActivityTaskRequest) GetDomain() (o string)

+ func (v *PollForActivityTaskRequest) GetIdentity() (o string)

+ func (v *PollForActivityTaskRequest) GetTaskList() (o *TaskList)

+ func (v *PollForActivityTaskRequest) GetTaskListMetadata() (o *TaskListMetadata)

type PollForActivityTaskResponse

+ func (v *PollForActivityTaskResponse) GetActivityID() (o string)

+ func (v *PollForActivityTaskResponse) GetActivityType() (o *ActivityType)

+ func (v *PollForActivityTaskResponse) GetAttempt() (o int32)

+ func (v *PollForActivityTaskResponse) GetHeader() (o *Header)

+ func (v *PollForActivityTaskResponse) GetHeartbeatDetails() (o []byte)

+ func (v *PollForActivityTaskResponse) GetHeartbeatTimeoutSeconds() (o int32)

+ func (v *PollForActivityTaskResponse) GetInput() (o []byte)

+ func (v *PollForActivityTaskResponse) GetScheduleToCloseTimeoutSeconds() (o int32)

+ func (v *PollForActivityTaskResponse) GetScheduledTimestamp() (o int64)

+ func (v *PollForActivityTaskResponse) GetScheduledTimestampOfThisAttempt() (o int64)

+ func (v *PollForActivityTaskResponse) GetStartToCloseTimeoutSeconds() (o int32)

+ func (v *PollForActivityTaskResponse) GetStartedTimestamp() (o int64)

+ func (v *PollForActivityTaskResponse) GetTaskToken() (o []byte)

+ func (v *PollForActivityTaskResponse) GetWorkflowDomain() (o string)

+ func (v *PollForActivityTaskResponse) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *PollForActivityTaskResponse) GetWorkflowType() (o *WorkflowType)

type PollForDecisionTaskRequest

+ func (v *PollForDecisionTaskRequest) GetBinaryChecksum() (o string)

+ func (v *PollForDecisionTaskRequest) GetDomain() (o string)

+ func (v *PollForDecisionTaskRequest) GetIdentity() (o string)

+ func (v *PollForDecisionTaskRequest) GetTaskList() (o *TaskList)

type PollForDecisionTaskResponse

+ func (v *PollForDecisionTaskResponse) GetAttempt() (o int64)

+ func (v *PollForDecisionTaskResponse) GetBacklogCountHint() (o int64)

+ func (v *PollForDecisionTaskResponse) GetHistory() (o *History)

+ func (v *PollForDecisionTaskResponse) GetNextPageToken() (o []byte)

+ func (v *PollForDecisionTaskResponse) GetPreviousStartedEventID() (o int64)

+ func (v *PollForDecisionTaskResponse) GetQueries() (o map[string]*WorkflowQuery)

+ func (v *PollForDecisionTaskResponse) GetQuery() (o *WorkflowQuery)

+ func (v *PollForDecisionTaskResponse) GetScheduledTimestamp() (o int64)

+ func (v *PollForDecisionTaskResponse) GetStartedEventID() (o int64)

+ func (v *PollForDecisionTaskResponse) GetStartedTimestamp() (o int64)

+ func (v *PollForDecisionTaskResponse) GetTaskToken() (o []byte)

+ func (v *PollForDecisionTaskResponse) GetWorkflowExecution() (o *WorkflowExecution)

+ func (v *PollForDecisionTaskResponse) GetWorkflowExecutionTaskList() (o *TaskList)

+ func (v *PollForDecisionTaskResponse) GetWorkflowType() (o *WorkflowType)

+ type PollMutableStateRequest struct

+ CurrentBranchToken []byte

+ DomainUUID *string

+ Execution *WorkflowExecution

+ ExpectedNextEventID *int64

+ func (v *PollMutableStateRequest) GetCurrentBranchToken() (o []byte)

+ func (v *PollMutableStateRequest) GetDomainUUID() (o string)

+ func (v *PollMutableStateRequest) GetExecution() (o *WorkflowExecution)

+ func (v *PollMutableStateRequest) GetExpectedNextEventID() (o int64)

+ type PollMutableStateResponse struct

+ ClientFeatureVersion *string

+ ClientImpl *string

+ ClientLibraryVersion *string

+ CurrentBranchToken []byte

+ Execution *WorkflowExecution

+ LastFirstEventID *int64

+ NextEventID *int64

+ PreviousStartedEventID *int64

+ StickyTaskList *TaskList

+ StickyTaskListScheduleToStartTimeout *int32

+ TaskList *TaskList

+ VersionHistories *VersionHistories

+ WorkflowCloseState *int32

+ WorkflowState *int32

+ WorkflowType *WorkflowType

+ func (v *PollMutableStateResponse) GetClientFeatureVersion() (o string)

+ func (v *PollMutableStateResponse) GetClientImpl() (o string)

+ func (v *PollMutableStateResponse) GetClientLibraryVersion() (o string)

+ func (v *PollMutableStateResponse) GetCurrentBranchToken() (o []byte)

+ func (v *PollMutableStateResponse) GetExecution() (o *WorkflowExecution)

+ func (v *PollMutableStateResponse) GetLastFirstEventID() (o int64)

+ func (v *PollMutableStateResponse) GetNextEventID() (o int64)

+ func (v *PollMutableStateResponse) GetPreviousStartedEventID() (o int64)

+ func (v *PollMutableStateResponse) GetStickyTaskList() (o *TaskList)

+ func (v *PollMutableStateResponse) GetStickyTaskListScheduleToStartTimeout() (o int32)

+ func (v *PollMutableStateResponse) GetTaskList() (o *TaskList)

+ func (v *PollMutableStateResponse) GetVersionHistories() (o *VersionHistories)

+ func (v *PollMutableStateResponse) GetWorkflowCloseState() (o int32)

+ func (v *PollMutableStateResponse) GetWorkflowState() (o int32)

+ func (v *PollMutableStateResponse) GetWorkflowType() (o *WorkflowType)

type PollerInfo

+ func (v *PollerInfo) GetIdentity() (o string)

+ func (v *PollerInfo) GetLastAccessTime() (o int64)

+ func (v *PollerInfo) GetRatePerSecond() (o float64)

+ type ProcessingQueueState struct

+ AckLevel *int64

+ DomainFilter *DomainFilter

+ Level *int32

+ MaxLevel *int64

+ func (v *ProcessingQueueState) GetAckLevel() (o int64)

+ func (v *ProcessingQueueState) GetDomainFilter() (o *DomainFilter)

+ func (v *ProcessingQueueState) GetLevel() (o int32)

+ func (v *ProcessingQueueState) GetMaxLevel() (o int64)

+ type ProcessingQueueStates struct

+ StatesByCluster map[string][]*ProcessingQueueState

+ func (v *ProcessingQueueStates) GetStatesByCluster() (o map[string][]*ProcessingQueueState)

+ type PurgeDLQMessagesRequest struct

+ InclusiveEndMessageID *int64

+ ShardID *int32

+ SourceCluster *string

+ Type *DLQType

+ func (v *PurgeDLQMessagesRequest) GetInclusiveEndMessageID() (o int64)

+ func (v *PurgeDLQMessagesRequest) GetShardID() (o int32)

+ func (v *PurgeDLQMessagesRequest) GetSourceCluster() (o string)

+ func (v *PurgeDLQMessagesRequest) GetType() (o DLQType)

type QueryConsistencyLevel

+ func (e QueryConsistencyLevel) Ptr() *QueryConsistencyLevel

type QueryFailedError

+ func (v *QueryFailedError) GetMessage() (o string)

type QueryRejectCondition

+ func (e QueryRejectCondition) Ptr() *QueryRejectCondition

type QueryRejected

+ func (v *QueryRejected) GetCloseStatus() (o WorkflowExecutionCloseStatus)

type QueryResultType

+ func (e QueryResultType) Ptr() *QueryResultType

type QueryTaskCompletedType

+ func (e QueryTaskCompletedType) Ptr() *QueryTaskCompletedType

type QueryWorkflowRequest

+ func (v *QueryWorkflowRequest) GetDomain() (o string)

+ func (v *QueryWorkflowRequest) GetExecution() (o *WorkflowExecution)

+ func (v *QueryWorkflowRequest) GetQuery() (o *WorkflowQuery)

+ func (v *QueryWorkflowRequest) GetQueryConsistencyLevel() (o QueryConsistencyLevel)

+ func (v *QueryWorkflowRequest) GetQueryRejectCondition() (o QueryRejectCondition)

type QueryWorkflowResponse

+ func (v *QueryWorkflowResponse) GetQueryRejected() (o *QueryRejected)

+ func (v *QueryWorkflowResponse) GetQueryResult() (o []byte)

+ type ReadDLQMessagesRequest struct

+ InclusiveEndMessageID *int64

+ MaximumPageSize *int32

+ NextPageToken []byte

+ ShardID *int32

+ SourceCluster *string

+ Type *DLQType

+ func (v *ReadDLQMessagesRequest) GetInclusiveEndMessageID() (o int64)

+ func (v *ReadDLQMessagesRequest) GetMaximumPageSize() (o int32)

+ func (v *ReadDLQMessagesRequest) GetNextPageToken() (o []byte)

+ func (v *ReadDLQMessagesRequest) GetShardID() (o int32)

+ func (v *ReadDLQMessagesRequest) GetSourceCluster() (o string)

+ func (v *ReadDLQMessagesRequest) GetType() (o DLQType)

+ type ReadDLQMessagesResponse struct

+ NextPageToken []byte

+ ReplicationTasks []*ReplicationTask

+ Type *DLQType

+ func (v *ReadDLQMessagesResponse) GetNextPageToken() (o []byte)

+ func (v *ReadDLQMessagesResponse) GetReplicationTasks() (o []*ReplicationTask)

+ func (v *ReadDLQMessagesResponse) GetType() (o DLQType)

type ReapplyEventsRequest

+ func (v *ReapplyEventsRequest) GetDomainName() (o string)

+ func (v *ReapplyEventsRequest) GetEvents() (o *DataBlob)

+ func (v *ReapplyEventsRequest) GetWorkflowExecution() (o *WorkflowExecution)

type RecordActivityTaskHeartbeatByIDRequest

+ func (v *RecordActivityTaskHeartbeatByIDRequest) GetActivityID() (o string)

+ func (v *RecordActivityTaskHeartbeatByIDRequest) GetDetails() (o []byte)

+ func (v *RecordActivityTaskHeartbeatByIDRequest) GetDomain() (o string)

+ func (v *RecordActivityTaskHeartbeatByIDRequest) GetIdentity() (o string)

+ func (v *RecordActivityTaskHeartbeatByIDRequest) GetRunID() (o string)

+ func (v *RecordActivityTaskHeartbeatByIDRequest) GetWorkflowID() (o string)

type RecordActivityTaskHeartbeatRequest

+ func (v *RecordActivityTaskHeartbeatRequest) GetDetails() (o []byte)

+ func (v *RecordActivityTaskHeartbeatRequest) GetIdentity() (o string)

+ func (v *RecordActivityTaskHeartbeatRequest) GetTaskToken() (o []byte)

type RecordActivityTaskHeartbeatResponse

+ func (v *RecordActivityTaskHeartbeatResponse) GetCancelRequested() (o bool)

+ type RecordActivityTaskStartedRequest struct

+ DomainUUID *string

+ PollRequest *PollForActivityTaskRequest

+ RequestID *string

+ ScheduleID *int64

+ TaskID *int64

+ WorkflowExecution *WorkflowExecution

+ func (v *RecordActivityTaskStartedRequest) GetDomainUUID() (o string)

+ func (v *RecordActivityTaskStartedRequest) GetPollRequest() (o *PollForActivityTaskRequest)

+ func (v *RecordActivityTaskStartedRequest) GetRequestID() (o string)

+ func (v *RecordActivityTaskStartedRequest) GetScheduleID() (o int64)

+ func (v *RecordActivityTaskStartedRequest) GetTaskID() (o int64)

+ func (v *RecordActivityTaskStartedRequest) GetWorkflowExecution() (o *WorkflowExecution)

+ type RecordActivityTaskStartedResponse struct

+ Attempt *int64

+ HeartbeatDetails []byte

+ ScheduledEvent *HistoryEvent

+ ScheduledTimestampOfThisAttempt *int64

+ StartedTimestamp *int64

+ WorkflowDomain *string

+ WorkflowType *WorkflowType

+ func (v *RecordActivityTaskStartedResponse) GetAttempt() (o int64)

+ func (v *RecordActivityTaskStartedResponse) GetHeartbeatDetails() (o []byte)

+ func (v *RecordActivityTaskStartedResponse) GetScheduledEvent() (o *HistoryEvent)

+ func (v *RecordActivityTaskStartedResponse) GetScheduledTimestampOfThisAttempt() (o int64)

+ func (v *RecordActivityTaskStartedResponse) GetStartedTimestamp() (o int64)

+ func (v *RecordActivityTaskStartedResponse) GetWorkflowDomain() (o string)

+ func (v *RecordActivityTaskStartedResponse) GetWorkflowType() (o *WorkflowType)

+ type RecordChildExecutionCompletedRequest struct

+ CompletedExecution *WorkflowExecution

+ CompletionEvent *HistoryEvent

+ DomainUUID *string

+ InitiatedID *int64

+ WorkflowExecution *WorkflowExecution

+ func (v *RecordChildExecutionCompletedRequest) GetCompletedExecution() (o *WorkflowExecution)

+ func (v *RecordChildExecutionCompletedRequest) GetCompletionEvent() (o *HistoryEvent)

+ func (v *RecordChildExecutionCompletedRequest) GetDomainUUID() (o string)

+ func (v *RecordChildExecutionCompletedRequest) GetInitiatedID() (o int64)

+ func (v *RecordChildExecutionCompletedRequest) GetWorkflowExecution() (o *WorkflowExecution)

+ type RecordDecisionTaskStartedRequest struct

+ DomainUUID *string

+ PollRequest *PollForDecisionTaskRequest

+ RequestID *string

+ ScheduleID *int64

+ TaskID *int64

+ WorkflowExecution *WorkflowExecution

+ func (v *RecordDecisionTaskStartedRequest) GetDomainUUID() (o string)

+ func (v *RecordDecisionTaskStartedRequest) GetPollRequest() (o *PollForDecisionTaskRequest)

+ func (v *RecordDecisionTaskStartedRequest) GetRequestID() (o string)

+ func (v *RecordDecisionTaskStartedRequest) GetScheduleID() (o int64)

+ func (v *RecordDecisionTaskStartedRequest) GetTaskID() (o int64)

+ func (v *RecordDecisionTaskStartedRequest) GetWorkflowExecution() (o *WorkflowExecution)

+ type RecordDecisionTaskStartedResponse struct

+ Attempt *int64

+ BranchToken []byte

+ DecisionInfo *TransientDecisionInfo

+ EventStoreVersion *int32

+ NextEventID *int64

+ PreviousStartedEventID *int64

+ Queries map[string]*WorkflowQuery

+ ScheduledEventID *int64

+ ScheduledTimestamp *int64

+ StartedEventID *int64

+ StartedTimestamp *int64

+ StickyExecutionEnabled *bool

+ WorkflowExecutionTaskList *TaskList

+ WorkflowType *WorkflowType

+ func (v *RecordDecisionTaskStartedResponse) GetAttempt() (o int64)

+ func (v *RecordDecisionTaskStartedResponse) GetBranchToken() (o []byte)

+ func (v *RecordDecisionTaskStartedResponse) GetDecisionInfo() (o *TransientDecisionInfo)

+ func (v *RecordDecisionTaskStartedResponse) GetEventStoreVersion() (o int32)

+ func (v *RecordDecisionTaskStartedResponse) GetNextEventID() (o int64)

+ func (v *RecordDecisionTaskStartedResponse) GetPreviousStartedEventID() (o int64)

+ func (v *RecordDecisionTaskStartedResponse) GetQueries() (o map[string]*WorkflowQuery)

+ func (v *RecordDecisionTaskStartedResponse) GetScheduledEventID() (o int64)

+ func (v *RecordDecisionTaskStartedResponse) GetScheduledTimestamp() (o int64)

+ func (v *RecordDecisionTaskStartedResponse) GetStartedEventID() (o int64)

+ func (v *RecordDecisionTaskStartedResponse) GetStartedTimestamp() (o int64)

+ func (v *RecordDecisionTaskStartedResponse) GetStickyExecutionEnabled() (o bool)

+ func (v *RecordDecisionTaskStartedResponse) GetWorkflowExecutionTaskList() (o *TaskList)

+ func (v *RecordDecisionTaskStartedResponse) GetWorkflowType() (o *WorkflowType)

type RecordMarkerDecisionAttributes

+ func (v *RecordMarkerDecisionAttributes) GetDetails() (o []byte)

+ func (v *RecordMarkerDecisionAttributes) GetHeader() (o *Header)

+ func (v *RecordMarkerDecisionAttributes) GetMarkerName() (o string)

type RefreshWorkflowTasksRequest

+ func (v *RefreshWorkflowTasksRequest) GetDomain() (o string)

+ func (v *RefreshWorkflowTasksRequest) GetExecution() (o *WorkflowExecution)

type RegisterDomainRequest

+ func (v *RegisterDomainRequest) GetActiveClusterName() (o string)

+ func (v *RegisterDomainRequest) GetClusters() (o []*ClusterReplicationConfiguration)

+ func (v *RegisterDomainRequest) GetData() (o map[string]string)

+ func (v *RegisterDomainRequest) GetDescription() (o string)

+ func (v *RegisterDomainRequest) GetEmitMetric() (o bool)

+ func (v *RegisterDomainRequest) GetHistoryArchivalStatus() (o ArchivalStatus)

+ func (v *RegisterDomainRequest) GetHistoryArchivalURI() (o string)

+ func (v *RegisterDomainRequest) GetIsGlobalDomain() (o bool)

+ func (v *RegisterDomainRequest) GetName() (o string)

+ func (v *RegisterDomainRequest) GetOwnerEmail() (o string)

+ func (v *RegisterDomainRequest) GetSecurityToken() (o string)

+ func (v *RegisterDomainRequest) GetVisibilityArchivalStatus() (o ArchivalStatus)

+ func (v *RegisterDomainRequest) GetVisibilityArchivalURI() (o string)

+ func (v *RegisterDomainRequest) GetWorkflowExecutionRetentionPeriodInDays() (o int32)

type RemoteSyncMatchedError

+ func (v *RemoteSyncMatchedError) GetMessage() (o string)

+ type RemoveSignalMutableStateRequest struct

+ DomainUUID *string

+ RequestID *string

+ WorkflowExecution *WorkflowExecution

+ func (v *RemoveSignalMutableStateRequest) GetDomainUUID() (o string)

+ func (v *RemoveSignalMutableStateRequest) GetRequestID() (o string)

+ func (v *RemoveSignalMutableStateRequest) GetWorkflowExecution() (o *WorkflowExecution)

type RemoveTaskRequest

+ func (v *RemoveTaskRequest) GetShardID() (o int32)

+ func (v *RemoveTaskRequest) GetTaskID() (o int64)

+ func (v *RemoveTaskRequest) GetType() (o int32)

+ func (v *RemoveTaskRequest) GetVisibilityTimestamp() (o int64)

+ type ReplicateEventsV2Request struct

+ DomainUUID *string

+ Events *DataBlob

+ NewRunEvents *DataBlob

+ VersionHistoryItems []*VersionHistoryItem

+ WorkflowExecution *WorkflowExecution

+ func (v *ReplicateEventsV2Request) GetDomainUUID() (o string)

+ func (v *ReplicateEventsV2Request) GetEvents() (o *DataBlob)

+ func (v *ReplicateEventsV2Request) GetNewRunEvents() (o *DataBlob)

+ func (v *ReplicateEventsV2Request) GetVersionHistoryItems() (o []*VersionHistoryItem)

+ func (v *ReplicateEventsV2Request) GetWorkflowExecution() (o *WorkflowExecution)

+ type ReplicationMessages struct

+ HasMore *bool

+ LastRetrievedMessageID *int64

+ ReplicationTasks []*ReplicationTask

+ SyncShardStatus *SyncShardStatus

+ func (v *ReplicationMessages) GetHasMore() (o bool)

+ func (v *ReplicationMessages) GetLastRetrievedMessageID() (o int64)

+ func (v *ReplicationMessages) GetReplicationTasks() (o []*ReplicationTask)

+ func (v *ReplicationMessages) GetSyncShardStatus() (o *SyncShardStatus)

+ type ReplicationTask struct

+ CreationTime *int64

+ DomainTaskAttributes *DomainTaskAttributes

+ FailoverMarkerAttributes *FailoverMarkerAttributes

+ HistoryTaskV2Attributes *HistoryTaskV2Attributes

+ SourceTaskID *int64

+ SyncActivityTaskAttributes *SyncActivityTaskAttributes

+ SyncShardStatusTaskAttributes *SyncShardStatusTaskAttributes

+ TaskType *ReplicationTaskType

+ func (v *ReplicationTask) GetCreationTime() (o int64)

+ func (v *ReplicationTask) GetDomainTaskAttributes() (o *DomainTaskAttributes)

+ func (v *ReplicationTask) GetFailoverMarkerAttributes() (o *FailoverMarkerAttributes)

+ func (v *ReplicationTask) GetHistoryTaskV2Attributes() (o *HistoryTaskV2Attributes)

+ func (v *ReplicationTask) GetSourceTaskID() (o int64)

+ func (v *ReplicationTask) GetSyncActivityTaskAttributes() (o *SyncActivityTaskAttributes)

+ func (v *ReplicationTask) GetSyncShardStatusTaskAttributes() (o *SyncShardStatusTaskAttributes)

+ func (v *ReplicationTask) GetTaskType() (o ReplicationTaskType)

+ type ReplicationTaskInfo struct

+ DomainID *string

+ FirstEventID *int64

+ NextEventID *int64

+ RunID *string

+ ScheduledID *int64

+ TaskID *int64

+ TaskType *int16

+ Version *int64

+ WorkflowID *string

+ func (v *ReplicationTaskInfo) GetDomainID() (o string)

+ func (v *ReplicationTaskInfo) GetFirstEventID() (o int64)

+ func (v *ReplicationTaskInfo) GetNextEventID() (o int64)

+ func (v *ReplicationTaskInfo) GetRunID() (o string)

+ func (v *ReplicationTaskInfo) GetScheduledID() (o int64)

+ func (v *ReplicationTaskInfo) GetTaskID() (o int64)

+ func (v *ReplicationTaskInfo) GetTaskType() (o int16)

+ func (v *ReplicationTaskInfo) GetVersion() (o int64)

+ func (v *ReplicationTaskInfo) GetWorkflowID() (o string)

+ type ReplicationTaskType int32

+ const ReplicationTaskTypeDomain

+ const ReplicationTaskTypeFailoverMarker

+ const ReplicationTaskTypeHistory

+ const ReplicationTaskTypeHistoryMetadata

+ const ReplicationTaskTypeHistoryV2

+ const ReplicationTaskTypeSyncActivity

+ const ReplicationTaskTypeSyncShardStatus

+ func (e ReplicationTaskType) Ptr() *ReplicationTaskType

+ type ReplicationToken struct

+ LastProcessedMessageID *int64

+ LastRetrievedMessageID *int64

+ ShardID *int32

+ func (v *ReplicationToken) GetLastProcessedMessageID() (o int64)

+ func (v *ReplicationToken) GetLastRetrievedMessageID() (o int64)

+ func (v *ReplicationToken) GetShardID() (o int32)

type RequestCancelActivityTaskDecisionAttributes

+ func (v *RequestCancelActivityTaskDecisionAttributes) GetActivityID() (o string)

type RequestCancelActivityTaskFailedEventAttributes

+ func (v *RequestCancelActivityTaskFailedEventAttributes) GetActivityID() (o string)

+ func (v *RequestCancelActivityTaskFailedEventAttributes) GetCause() (o string)

+ func (v *RequestCancelActivityTaskFailedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

type RequestCancelExternalWorkflowExecutionDecisionAttributes

+ func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetChildWorkflowOnly() (o bool)

+ func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetControl() (o []byte)

+ func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetDomain() (o string)

+ func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetRunID() (o string)

+ func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetWorkflowID() (o string)

type RequestCancelExternalWorkflowExecutionFailedEventAttributes

+ func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetCause() (o CancelExternalWorkflowExecutionFailedCause)

+ func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetControl() (o []byte)

+ func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetDomain() (o string)

+ func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64)

+ func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes

+ func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() (o bool)

+ func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetControl() (o []byte)

+ func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetDomain() (o string)

+ func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

type RequestCancelWorkflowExecutionRequest

+ func (v *RequestCancelWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *RequestCancelWorkflowExecutionRequest) GetIdentity() (o string)

+ func (v *RequestCancelWorkflowExecutionRequest) GetRequestID() (o string)

+ func (v *RequestCancelWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution)

+ type ResendReplicationTasksRequest struct

+ DomainID *string

+ EndEventID *int64

+ EndVersion *int64

+ RemoteCluster *string

+ RunID *string

+ StartEventID *int64

+ StartVersion *int64

+ WorkflowID *string

+ func (v *ResendReplicationTasksRequest) GetDomainID() (o string)

+ func (v *ResendReplicationTasksRequest) GetEndEventID() (o int64)

+ func (v *ResendReplicationTasksRequest) GetEndVersion() (o int64)

+ func (v *ResendReplicationTasksRequest) GetRemoteCluster() (o string)

+ func (v *ResendReplicationTasksRequest) GetRunID() (o string)

+ func (v *ResendReplicationTasksRequest) GetStartEventID() (o int64)

+ func (v *ResendReplicationTasksRequest) GetStartVersion() (o int64)

+ func (v *ResendReplicationTasksRequest) GetWorkflowID() (o string)

type ResetPointInfo

+ func (v *ResetPointInfo) GetBinaryChecksum() (o string)

+ func (v *ResetPointInfo) GetCreatedTimeNano() (o int64)

+ func (v *ResetPointInfo) GetExpiringTimeNano() (o int64)

+ func (v *ResetPointInfo) GetFirstDecisionCompletedID() (o int64)

+ func (v *ResetPointInfo) GetResettable() (o bool)

+ func (v *ResetPointInfo) GetRunID() (o string)

type ResetPoints

+ func (v *ResetPoints) GetPoints() (o []*ResetPointInfo)

type ResetQueueRequest

+ func (v *ResetQueueRequest) GetClusterName() (o string)

+ func (v *ResetQueueRequest) GetShardID() (o int32)

+ func (v *ResetQueueRequest) GetType() (o int32)

type ResetStickyTaskListRequest

+ func (v *ResetStickyTaskListRequest) GetDomain() (o string)

+ func (v *ResetStickyTaskListRequest) GetExecution() (o *WorkflowExecution)

type ResetWorkflowExecutionRequest

+ SkipSignalReapply *bool

+ func (v *ResetWorkflowExecutionRequest) GetDecisionFinishEventID() (o int64)

+ func (v *ResetWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *ResetWorkflowExecutionRequest) GetReason() (o string)

+ func (v *ResetWorkflowExecutionRequest) GetRequestID() (o string)

+ func (v *ResetWorkflowExecutionRequest) GetSkipSignalReapply() (o bool)

+ func (v *ResetWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution)

type ResetWorkflowExecutionResponse

+ func (v *ResetWorkflowExecutionResponse) GetRunID() (o string)

type RespondActivityTaskCanceledByIDRequest

+ func (v *RespondActivityTaskCanceledByIDRequest) GetActivityID() (o string)

+ func (v *RespondActivityTaskCanceledByIDRequest) GetDetails() (o []byte)

+ func (v *RespondActivityTaskCanceledByIDRequest) GetDomain() (o string)

+ func (v *RespondActivityTaskCanceledByIDRequest) GetIdentity() (o string)

+ func (v *RespondActivityTaskCanceledByIDRequest) GetRunID() (o string)

+ func (v *RespondActivityTaskCanceledByIDRequest) GetWorkflowID() (o string)

type RespondActivityTaskCanceledRequest

+ func (v *RespondActivityTaskCanceledRequest) GetDetails() (o []byte)

+ func (v *RespondActivityTaskCanceledRequest) GetIdentity() (o string)

+ func (v *RespondActivityTaskCanceledRequest) GetTaskToken() (o []byte)

type RespondActivityTaskCompletedByIDRequest

+ func (v *RespondActivityTaskCompletedByIDRequest) GetActivityID() (o string)

+ func (v *RespondActivityTaskCompletedByIDRequest) GetDomain() (o string)

+ func (v *RespondActivityTaskCompletedByIDRequest) GetIdentity() (o string)

+ func (v *RespondActivityTaskCompletedByIDRequest) GetResult() (o []byte)

+ func (v *RespondActivityTaskCompletedByIDRequest) GetRunID() (o string)

+ func (v *RespondActivityTaskCompletedByIDRequest) GetWorkflowID() (o string)

type RespondActivityTaskCompletedRequest

+ func (v *RespondActivityTaskCompletedRequest) GetIdentity() (o string)

+ func (v *RespondActivityTaskCompletedRequest) GetResult() (o []byte)

+ func (v *RespondActivityTaskCompletedRequest) GetTaskToken() (o []byte)

type RespondActivityTaskFailedByIDRequest

+ func (v *RespondActivityTaskFailedByIDRequest) GetActivityID() (o string)

+ func (v *RespondActivityTaskFailedByIDRequest) GetDetails() (o []byte)

+ func (v *RespondActivityTaskFailedByIDRequest) GetDomain() (o string)

+ func (v *RespondActivityTaskFailedByIDRequest) GetIdentity() (o string)

+ func (v *RespondActivityTaskFailedByIDRequest) GetReason() (o string)

+ func (v *RespondActivityTaskFailedByIDRequest) GetRunID() (o string)

+ func (v *RespondActivityTaskFailedByIDRequest) GetWorkflowID() (o string)

type RespondActivityTaskFailedRequest

+ func (v *RespondActivityTaskFailedRequest) GetDetails() (o []byte)

+ func (v *RespondActivityTaskFailedRequest) GetIdentity() (o string)

+ func (v *RespondActivityTaskFailedRequest) GetReason() (o string)

+ func (v *RespondActivityTaskFailedRequest) GetTaskToken() (o []byte)

type RespondDecisionTaskCompletedRequest

+ func (v *RespondDecisionTaskCompletedRequest) GetBinaryChecksum() (o string)

+ func (v *RespondDecisionTaskCompletedRequest) GetDecisions() (o []*Decision)

+ func (v *RespondDecisionTaskCompletedRequest) GetExecutionContext() (o []byte)

+ func (v *RespondDecisionTaskCompletedRequest) GetForceCreateNewDecisionTask() (o bool)

+ func (v *RespondDecisionTaskCompletedRequest) GetIdentity() (o string)

+ func (v *RespondDecisionTaskCompletedRequest) GetQueryResults() (o map[string]*WorkflowQueryResult)

+ func (v *RespondDecisionTaskCompletedRequest) GetReturnNewDecisionTask() (o bool)

+ func (v *RespondDecisionTaskCompletedRequest) GetStickyAttributes() (o *StickyExecutionAttributes)

+ func (v *RespondDecisionTaskCompletedRequest) GetTaskToken() (o []byte)

type RespondDecisionTaskCompletedResponse

+ ActivitiesToDispatchLocally map[string]*ActivityLocalDispatchInfo

+ func (v *RespondDecisionTaskCompletedResponse) GetActivitiesToDispatchLocally() (o map[string]*ActivityLocalDispatchInfo)

+ func (v *RespondDecisionTaskCompletedResponse) GetDecisionTask() (o *PollForDecisionTaskResponse)

type RespondDecisionTaskFailedRequest

+ func (v *RespondDecisionTaskFailedRequest) GetBinaryChecksum() (o string)

+ func (v *RespondDecisionTaskFailedRequest) GetCause() (o DecisionTaskFailedCause)

+ func (v *RespondDecisionTaskFailedRequest) GetDetails() (o []byte)

+ func (v *RespondDecisionTaskFailedRequest) GetIdentity() (o string)

+ func (v *RespondDecisionTaskFailedRequest) GetTaskToken() (o []byte)

type RespondQueryTaskCompletedRequest

+ func (v *RespondQueryTaskCompletedRequest) GetCompletedType() (o QueryTaskCompletedType)

+ func (v *RespondQueryTaskCompletedRequest) GetErrorMessage() (o string)

+ func (v *RespondQueryTaskCompletedRequest) GetQueryResult() (o []byte)

+ func (v *RespondQueryTaskCompletedRequest) GetTaskToken() (o []byte)

+ func (v *RespondQueryTaskCompletedRequest) GetWorkerVersionInfo() (o *WorkerVersionInfo)

type RetryPolicy

+ func (v *RetryPolicy) GetBackoffCoefficient() (o float64)

+ func (v *RetryPolicy) GetExpirationIntervalInSeconds() (o int32)

+ func (v *RetryPolicy) GetInitialIntervalInSeconds() (o int32)

+ func (v *RetryPolicy) GetMaximumAttempts() (o int32)

+ func (v *RetryPolicy) GetMaximumIntervalInSeconds() (o int32)

+ func (v *RetryPolicy) GetNonRetriableErrorReasons() (o []string)

type RetryTaskV2Error

+ func (v *RetryTaskV2Error) GetDomainID() (o string)

+ func (v *RetryTaskV2Error) GetEndEventID() (o int64)

+ func (v *RetryTaskV2Error) GetEndEventVersion() (o int64)

+ func (v *RetryTaskV2Error) GetMessage() (o string)

+ func (v *RetryTaskV2Error) GetRunID() (o string)

+ func (v *RetryTaskV2Error) GetStartEventID() (o int64)

+ func (v *RetryTaskV2Error) GetStartEventVersion() (o int64)

+ func (v *RetryTaskV2Error) GetWorkflowID() (o string)

+ type RingInfo struct

+ MemberCount *int32

+ Members []*HostInfo

+ Role *string

+ func (v *RingInfo) GetMemberCount() (o int32)

+ func (v *RingInfo) GetMembers() (o []*HostInfo)

+ func (v *RingInfo) GetRole() (o string)

type ScheduleActivityTaskDecisionAttributes

+ RequestLocalDispatch *bool

+ func (v *ScheduleActivityTaskDecisionAttributes) GetActivityID() (o string)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetActivityType() (o *ActivityType)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetDomain() (o string)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetHeader() (o *Header)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetHeartbeatTimeoutSeconds() (o int32)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetInput() (o []byte)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetRequestLocalDispatch() (o bool)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetRetryPolicy() (o *RetryPolicy)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetScheduleToCloseTimeoutSeconds() (o int32)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetScheduleToStartTimeoutSeconds() (o int32)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetStartToCloseTimeoutSeconds() (o int32)

+ func (v *ScheduleActivityTaskDecisionAttributes) GetTaskList() (o *TaskList)

+ type ScheduleDecisionTaskRequest struct

+ DomainUUID *string

+ IsFirstDecision *bool

+ WorkflowExecution *WorkflowExecution

+ func (v *ScheduleDecisionTaskRequest) GetDomainUUID() (o string)

+ func (v *ScheduleDecisionTaskRequest) GetIsFirstDecision() (o bool)

+ func (v *ScheduleDecisionTaskRequest) GetWorkflowExecution() (o *WorkflowExecution)

type SearchAttributes

+ func (v *SearchAttributes) GetIndexedFields() (o map[string][]byte)

type ServiceBusyError

+ func (v *ServiceBusyError) GetMessage() (o string)

+ type ShardOwnershipLostError struct

+ Message *string

+ Owner *string

+ func (err ShardOwnershipLostError) Error() string

+ func (v *ShardOwnershipLostError) GetMessage() (o string)

+ func (v *ShardOwnershipLostError) GetOwner() (o string)

type SignalExternalWorkflowExecutionDecisionAttributes

+ func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetChildWorkflowOnly() (o bool)

+ func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetControl() (o []byte)

+ func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetDomain() (o string)

+ func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetExecution() (o *WorkflowExecution)

+ func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetInput() (o []byte)

+ func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetSignalName() (o string)

type SignalExternalWorkflowExecutionFailedCause

+ func (e SignalExternalWorkflowExecutionFailedCause) Ptr() *SignalExternalWorkflowExecutionFailedCause

type SignalExternalWorkflowExecutionFailedEventAttributes

+ func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetCause() (o SignalExternalWorkflowExecutionFailedCause)

+ func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetControl() (o []byte)

+ func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetDomain() (o string)

+ func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64)

+ func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

type SignalExternalWorkflowExecutionInitiatedEventAttributes

+ func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() (o bool)

+ func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetControl() (o []byte)

+ func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetDomain() (o string)

+ func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetInput() (o []byte)

+ func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetSignalName() (o string)

+ func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution)

type SignalWithStartWorkflowExecutionRequest

+ func (v *SignalWithStartWorkflowExecutionRequest) GetControl() (o []byte)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() (o string)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds() (o int32)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetHeader() (o *Header)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetIdentity() (o string)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetInput() (o []byte)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetMemo() (o *Memo)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetRequestID() (o string)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetRetryPolicy() (o *RetryPolicy)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetSearchAttributes() (o *SearchAttributes)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetSignalInput() (o []byte)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetSignalName() (o string)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetTaskList() (o *TaskList)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds() (o int32)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetWorkflowID() (o string)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetWorkflowIDReusePolicy() (o WorkflowIDReusePolicy)

+ func (v *SignalWithStartWorkflowExecutionRequest) GetWorkflowType() (o *WorkflowType)

type SignalWorkflowExecutionRequest

+ func (v *SignalWorkflowExecutionRequest) GetControl() (o []byte)

+ func (v *SignalWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *SignalWorkflowExecutionRequest) GetIdentity() (o string)

+ func (v *SignalWorkflowExecutionRequest) GetInput() (o []byte)

+ func (v *SignalWorkflowExecutionRequest) GetRequestID() (o string)

+ func (v *SignalWorkflowExecutionRequest) GetSignalName() (o string)

+ func (v *SignalWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution)

type StartChildWorkflowExecutionDecisionAttributes

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetControl() (o []byte)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetCronSchedule() (o string)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetDomain() (o string)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetHeader() (o *Header)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetInput() (o []byte)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetMemo() (o *Memo)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetParentClosePolicy() (o ParentClosePolicy)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetRetryPolicy() (o *RetryPolicy)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetSearchAttributes() (o *SearchAttributes)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetTaskList() (o *TaskList)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetWorkflowID() (o string)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetWorkflowIDReusePolicy() (o WorkflowIDReusePolicy)

+ func (v *StartChildWorkflowExecutionDecisionAttributes) GetWorkflowType() (o *WorkflowType)

type StartChildWorkflowExecutionFailedEventAttributes

+ func (v *StartChildWorkflowExecutionFailedEventAttributes) GetCause() (o ChildWorkflowExecutionFailedCause)

+ func (v *StartChildWorkflowExecutionFailedEventAttributes) GetControl() (o []byte)

+ func (v *StartChildWorkflowExecutionFailedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *StartChildWorkflowExecutionFailedEventAttributes) GetDomain() (o string)

+ func (v *StartChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64)

+ func (v *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowID() (o string)

+ func (v *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowType() (o *WorkflowType)

type StartChildWorkflowExecutionInitiatedEventAttributes

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetControl() (o []byte)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetCronSchedule() (o string)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetDomain() (o string)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetHeader() (o *Header)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetInput() (o []byte)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetMemo() (o *Memo)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetParentClosePolicy() (o ParentClosePolicy)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetRetryPolicy() (o *RetryPolicy)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetSearchAttributes() (o *SearchAttributes)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetTaskList() (o *TaskList)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowID() (o string)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowIDReusePolicy() (o WorkflowIDReusePolicy)

+ func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowType() (o *WorkflowType)

type StartTimeFilter

+ func (v *StartTimeFilter) GetEarliestTime() (o int64)

+ func (v *StartTimeFilter) GetLatestTime() (o int64)

type StartTimerDecisionAttributes

+ func (v *StartTimerDecisionAttributes) GetStartToFireTimeoutSeconds() (o int64)

+ func (v *StartTimerDecisionAttributes) GetTimerID() (o string)

type StartWorkflowExecutionRequest

+ func (v *StartWorkflowExecutionRequest) GetCronSchedule() (o string)

+ func (v *StartWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *StartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds() (o int32)

+ func (v *StartWorkflowExecutionRequest) GetHeader() (o *Header)

+ func (v *StartWorkflowExecutionRequest) GetIdentity() (o string)

+ func (v *StartWorkflowExecutionRequest) GetInput() (o []byte)

+ func (v *StartWorkflowExecutionRequest) GetMemo() (o *Memo)

+ func (v *StartWorkflowExecutionRequest) GetRequestID() (o string)

+ func (v *StartWorkflowExecutionRequest) GetRetryPolicy() (o *RetryPolicy)

+ func (v *StartWorkflowExecutionRequest) GetSearchAttributes() (o *SearchAttributes)

+ func (v *StartWorkflowExecutionRequest) GetTaskList() (o *TaskList)

+ func (v *StartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds() (o int32)

+ func (v *StartWorkflowExecutionRequest) GetWorkflowID() (o string)

+ func (v *StartWorkflowExecutionRequest) GetWorkflowIDReusePolicy() (o WorkflowIDReusePolicy)

+ func (v *StartWorkflowExecutionRequest) GetWorkflowType() (o *WorkflowType)

type StartWorkflowExecutionResponse

+ func (v *StartWorkflowExecutionResponse) GetRunID() (o string)

type StickyExecutionAttributes

+ func (v *StickyExecutionAttributes) GetScheduleToStartTimeoutSeconds() (o int32)

+ func (v *StickyExecutionAttributes) GetWorkerTaskList() (o *TaskList)

type SupportedClientVersions

+ func (v *SupportedClientVersions) GetGoSdk() (o string)

+ func (v *SupportedClientVersions) GetJavaSdk() (o string)

+ type SyncActivityRequest struct

+ Attempt *int32

+ Details []byte

+ DomainID *string

+ LastFailureDetails []byte

+ LastFailureReason *string

+ LastHeartbeatTime *int64

+ LastWorkerIdentity *string

+ RunID *string

+ ScheduledID *int64

+ ScheduledTime *int64

+ StartedID *int64

+ StartedTime *int64

+ Version *int64

+ VersionHistory *VersionHistory

+ WorkflowID *string

+ func (v *SyncActivityRequest) GetAttempt() (o int32)

+ func (v *SyncActivityRequest) GetDetails() (o []byte)

+ func (v *SyncActivityRequest) GetDomainID() (o string)

+ func (v *SyncActivityRequest) GetLastFailureDetails() (o []byte)

+ func (v *SyncActivityRequest) GetLastFailureReason() (o string)

+ func (v *SyncActivityRequest) GetLastHeartbeatTime() (o int64)

+ func (v *SyncActivityRequest) GetLastWorkerIdentity() (o string)

+ func (v *SyncActivityRequest) GetRunID() (o string)

+ func (v *SyncActivityRequest) GetScheduledID() (o int64)

+ func (v *SyncActivityRequest) GetScheduledTime() (o int64)

+ func (v *SyncActivityRequest) GetStartedID() (o int64)

+ func (v *SyncActivityRequest) GetStartedTime() (o int64)

+ func (v *SyncActivityRequest) GetVersion() (o int64)

+ func (v *SyncActivityRequest) GetVersionHistory() (o *VersionHistory)

+ func (v *SyncActivityRequest) GetWorkflowID() (o string)

+ type SyncActivityTaskAttributes struct

+ Attempt *int32

+ Details []byte

+ DomainID *string

+ LastFailureDetails []byte

+ LastFailureReason *string

+ LastHeartbeatTime *int64

+ LastWorkerIdentity *string

+ RunID *string

+ ScheduledID *int64

+ ScheduledTime *int64

+ StartedID *int64

+ StartedTime *int64

+ Version *int64

+ VersionHistory *VersionHistory

+ WorkflowID *string

+ func (v *SyncActivityTaskAttributes) GetAttempt() (o int32)

+ func (v *SyncActivityTaskAttributes) GetDetails() (o []byte)

+ func (v *SyncActivityTaskAttributes) GetDomainID() (o string)

+ func (v *SyncActivityTaskAttributes) GetLastFailureDetails() (o []byte)

+ func (v *SyncActivityTaskAttributes) GetLastFailureReason() (o string)

+ func (v *SyncActivityTaskAttributes) GetLastHeartbeatTime() (o int64)

+ func (v *SyncActivityTaskAttributes) GetLastWorkerIdentity() (o string)

+ func (v *SyncActivityTaskAttributes) GetRunID() (o string)

+ func (v *SyncActivityTaskAttributes) GetScheduledID() (o int64)

+ func (v *SyncActivityTaskAttributes) GetScheduledTime() (o int64)

+ func (v *SyncActivityTaskAttributes) GetStartedID() (o int64)

+ func (v *SyncActivityTaskAttributes) GetStartedTime() (o int64)

+ func (v *SyncActivityTaskAttributes) GetVersion() (o int64)

+ func (v *SyncActivityTaskAttributes) GetVersionHistory() (o *VersionHistory)

+ func (v *SyncActivityTaskAttributes) GetWorkflowID() (o string)

+ type SyncShardStatus struct

+ Timestamp *int64

+ func (v *SyncShardStatus) GetTimestamp() (o int64)

+ type SyncShardStatusRequest struct

+ ShardID *int64

+ SourceCluster *string

+ Timestamp *int64

+ func (v *SyncShardStatusRequest) GetShardID() (o int64)

+ func (v *SyncShardStatusRequest) GetSourceCluster() (o string)

+ func (v *SyncShardStatusRequest) GetTimestamp() (o int64)

+ type SyncShardStatusTaskAttributes struct

+ ShardID *int64

+ SourceCluster *string

+ Timestamp *int64

+ func (v *SyncShardStatusTaskAttributes) GetShardID() (o int64)

+ func (v *SyncShardStatusTaskAttributes) GetSourceCluster() (o string)

+ func (v *SyncShardStatusTaskAttributes) GetTimestamp() (o int64)

type TaskIDBlock

+ func (v *TaskIDBlock) GetEndID() (o int64)

+ func (v *TaskIDBlock) GetStartID() (o int64)

type TaskList

+ func (v *TaskList) GetKind() (o TaskListKind)

+ func (v *TaskList) GetName() (o string)

type TaskListKind

+ func (e TaskListKind) Ptr() *TaskListKind

type TaskListMetadata

+ func (v *TaskListMetadata) GetMaxTasksPerSecond() (o float64)

type TaskListPartitionMetadata

+ func (v *TaskListPartitionMetadata) GetKey() (o string)

+ func (v *TaskListPartitionMetadata) GetOwnerHostName() (o string)

type TaskListStatus

+ func (v *TaskListStatus) GetAckLevel() (o int64)

+ func (v *TaskListStatus) GetBacklogCountHint() (o int64)

+ func (v *TaskListStatus) GetRatePerSecond() (o float64)

+ func (v *TaskListStatus) GetReadLevel() (o int64)

+ func (v *TaskListStatus) GetTaskIDBlock() (o *TaskIDBlock)

type TaskListType

+ func (e TaskListType) Ptr() *TaskListType

+ type TaskSource int32

+ const TaskSourceDbBacklog

+ const TaskSourceHistory

+ func (e TaskSource) Ptr() *TaskSource

type TerminateWorkflowExecutionRequest

+ func (v *TerminateWorkflowExecutionRequest) GetDetails() (o []byte)

+ func (v *TerminateWorkflowExecutionRequest) GetDomain() (o string)

+ func (v *TerminateWorkflowExecutionRequest) GetIdentity() (o string)

+ func (v *TerminateWorkflowExecutionRequest) GetReason() (o string)

+ func (v *TerminateWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution)

type TimeoutType

+ func (e TimeoutType) Ptr() *TimeoutType

type TimerCanceledEventAttributes

+ func (v *TimerCanceledEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *TimerCanceledEventAttributes) GetIdentity() (o string)

+ func (v *TimerCanceledEventAttributes) GetStartedEventID() (o int64)

+ func (v *TimerCanceledEventAttributes) GetTimerID() (o string)

type TimerFiredEventAttributes

+ func (v *TimerFiredEventAttributes) GetStartedEventID() (o int64)

+ func (v *TimerFiredEventAttributes) GetTimerID() (o string)

type TimerStartedEventAttributes

+ func (v *TimerStartedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *TimerStartedEventAttributes) GetStartToFireTimeoutSeconds() (o int64)

+ func (v *TimerStartedEventAttributes) GetTimerID() (o string)

type TransientDecisionInfo

+ func (v *TransientDecisionInfo) GetScheduledEvent() (o *HistoryEvent)

+ func (v *TransientDecisionInfo) GetStartedEvent() (o *HistoryEvent)

type UpdateDomainInfo

+ func (v *UpdateDomainInfo) GetData() (o map[string]string)

+ func (v *UpdateDomainInfo) GetDescription() (o string)

+ func (v *UpdateDomainInfo) GetOwnerEmail() (o string)

type UpdateDomainRequest

+ func (v *UpdateDomainRequest) GetConfiguration() (o *DomainConfiguration)

+ func (v *UpdateDomainRequest) GetDeleteBadBinary() (o string)

+ func (v *UpdateDomainRequest) GetFailoverTimeoutInSeconds() (o int32)

+ func (v *UpdateDomainRequest) GetName() (o string)

+ func (v *UpdateDomainRequest) GetReplicationConfiguration() (o *DomainReplicationConfiguration)

+ func (v *UpdateDomainRequest) GetSecurityToken() (o string)

+ func (v *UpdateDomainRequest) GetUpdatedInfo() (o *UpdateDomainInfo)

type UpdateDomainResponse

+ func (v *UpdateDomainResponse) GetConfiguration() (o *DomainConfiguration)

+ func (v *UpdateDomainResponse) GetDomainInfo() (o *DomainInfo)

+ func (v *UpdateDomainResponse) GetFailoverVersion() (o int64)

+ func (v *UpdateDomainResponse) GetIsGlobalDomain() (o bool)

+ func (v *UpdateDomainResponse) GetReplicationConfiguration() (o *DomainReplicationConfiguration)

type UpsertWorkflowSearchAttributesDecisionAttributes

+ func (v *UpsertWorkflowSearchAttributesDecisionAttributes) GetSearchAttributes() (o *SearchAttributes)

type UpsertWorkflowSearchAttributesEventAttributes

+ func (v *UpsertWorkflowSearchAttributesEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *UpsertWorkflowSearchAttributesEventAttributes) GetSearchAttributes() (o *SearchAttributes)

type VersionHistories

+ func (v *VersionHistories) GetCurrentVersionHistoryIndex() (o int32)

+ func (v *VersionHistories) GetHistories() (o []*VersionHistory)

type VersionHistory

+ func (v *VersionHistory) GetBranchToken() (o []byte)

+ func (v *VersionHistory) GetItems() (o []*VersionHistoryItem)

type VersionHistoryItem

+ func (v *VersionHistoryItem) GetEventID() (o int64)

+ func (v *VersionHistoryItem) GetVersion() (o int64)

type WorkerVersionInfo

+ func (v *WorkerVersionInfo) GetFeatureVersion() (o string)

+ func (v *WorkerVersionInfo) GetImpl() (o string)

type WorkflowExecution

+ func (v *WorkflowExecution) GetRunID() (o string)

+ func (v *WorkflowExecution) GetWorkflowID() (o string)

type WorkflowExecutionAlreadyStartedError

+ func (v *WorkflowExecutionAlreadyStartedError) GetMessage() (o string)

+ func (v *WorkflowExecutionAlreadyStartedError) GetRunID() (o string)

+ func (v *WorkflowExecutionAlreadyStartedError) GetStartRequestID() (o string)

type WorkflowExecutionCancelRequestedEventAttributes

+ func (v *WorkflowExecutionCancelRequestedEventAttributes) GetCause() (o string)

+ func (v *WorkflowExecutionCancelRequestedEventAttributes) GetExternalInitiatedEventID() (o int64)

+ func (v *WorkflowExecutionCancelRequestedEventAttributes) GetExternalWorkflowExecution() (o *WorkflowExecution)

+ func (v *WorkflowExecutionCancelRequestedEventAttributes) GetIdentity() (o string)

type WorkflowExecutionCanceledEventAttributes

+ func (v *WorkflowExecutionCanceledEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *WorkflowExecutionCanceledEventAttributes) GetDetails() (o []byte)

type WorkflowExecutionCloseStatus

+ func (e WorkflowExecutionCloseStatus) Ptr() *WorkflowExecutionCloseStatus

type WorkflowExecutionCompletedEventAttributes

+ func (v *WorkflowExecutionCompletedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *WorkflowExecutionCompletedEventAttributes) GetResult() (o []byte)

type WorkflowExecutionConfiguration

+ func (v *WorkflowExecutionConfiguration) GetExecutionStartToCloseTimeoutSeconds() (o int32)

+ func (v *WorkflowExecutionConfiguration) GetTaskList() (o *TaskList)

+ func (v *WorkflowExecutionConfiguration) GetTaskStartToCloseTimeoutSeconds() (o int32)

type WorkflowExecutionContinuedAsNewEventAttributes

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetBackoffStartIntervalInSeconds() (o int32)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetFailureDetails() (o []byte)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetFailureReason() (o string)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetHeader() (o *Header)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetInitiator() (o ContinueAsNewInitiator)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetInput() (o []byte)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetLastCompletionResult() (o []byte)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetMemo() (o *Memo)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetNewExecutionRunID() (o string)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetSearchAttributes() (o *SearchAttributes)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetTaskList() (o *TaskList)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32)

+ func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowType() (o *WorkflowType)

type WorkflowExecutionFailedEventAttributes

+ func (v *WorkflowExecutionFailedEventAttributes) GetDecisionTaskCompletedEventID() (o int64)

+ func (v *WorkflowExecutionFailedEventAttributes) GetDetails() (o []byte)

+ func (v *WorkflowExecutionFailedEventAttributes) GetReason() (o string)

type WorkflowExecutionFilter

+ func (v *WorkflowExecutionFilter) GetRunID() (o string)

+ func (v *WorkflowExecutionFilter) GetWorkflowID() (o string)

type WorkflowExecutionInfo

+ func (v *WorkflowExecutionInfo) GetAutoResetPoints() (o *ResetPoints)

+ func (v *WorkflowExecutionInfo) GetCloseStatus() (o WorkflowExecutionCloseStatus)

+ func (v *WorkflowExecutionInfo) GetCloseTime() (o int64)

+ func (v *WorkflowExecutionInfo) GetExecution() (o *WorkflowExecution)

+ func (v *WorkflowExecutionInfo) GetExecutionTime() (o int64)

+ func (v *WorkflowExecutionInfo) GetHistoryLength() (o int64)

+ func (v *WorkflowExecutionInfo) GetMemo() (o *Memo)

+ func (v *WorkflowExecutionInfo) GetParentDomainID() (o string)

+ func (v *WorkflowExecutionInfo) GetParentExecution() (o *WorkflowExecution)

+ func (v *WorkflowExecutionInfo) GetSearchAttributes() (o *SearchAttributes)

+ func (v *WorkflowExecutionInfo) GetStartTime() (o int64)

+ func (v *WorkflowExecutionInfo) GetTaskList() (o string)

+ func (v *WorkflowExecutionInfo) GetType() (o *WorkflowType)

type WorkflowExecutionSignaledEventAttributes

+ func (v *WorkflowExecutionSignaledEventAttributes) GetIdentity() (o string)

+ func (v *WorkflowExecutionSignaledEventAttributes) GetInput() (o []byte)

+ func (v *WorkflowExecutionSignaledEventAttributes) GetSignalName() (o string)

type WorkflowExecutionStartedEventAttributes

+ func (v *WorkflowExecutionStartedEventAttributes) GetAttempt() (o int32)

+ func (v *WorkflowExecutionStartedEventAttributes) GetContinuedExecutionRunID() (o string)

+ func (v *WorkflowExecutionStartedEventAttributes) GetContinuedFailureDetails() (o []byte)

+ func (v *WorkflowExecutionStartedEventAttributes) GetContinuedFailureReason() (o string)

+ func (v *WorkflowExecutionStartedEventAttributes) GetCronSchedule() (o string)

+ func (v *WorkflowExecutionStartedEventAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32)

+ func (v *WorkflowExecutionStartedEventAttributes) GetExpirationTimestamp() (o int64)

+ func (v *WorkflowExecutionStartedEventAttributes) GetFirstDecisionTaskBackoffSeconds() (o int32)

+ func (v *WorkflowExecutionStartedEventAttributes) GetFirstExecutionRunID() (o string)

+ func (v *WorkflowExecutionStartedEventAttributes) GetHeader() (o *Header)

+ func (v *WorkflowExecutionStartedEventAttributes) GetIdentity() (o string)

+ func (v *WorkflowExecutionStartedEventAttributes) GetInitiator() (o ContinueAsNewInitiator)

+ func (v *WorkflowExecutionStartedEventAttributes) GetInput() (o []byte)

+ func (v *WorkflowExecutionStartedEventAttributes) GetLastCompletionResult() (o []byte)

+ func (v *WorkflowExecutionStartedEventAttributes) GetMemo() (o *Memo)

+ func (v *WorkflowExecutionStartedEventAttributes) GetOriginalExecutionRunID() (o string)

+ func (v *WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventID() (o int64)

+ func (v *WorkflowExecutionStartedEventAttributes) GetParentWorkflowDomain() (o string)

+ func (v *WorkflowExecutionStartedEventAttributes) GetParentWorkflowExecution() (o *WorkflowExecution)

+ func (v *WorkflowExecutionStartedEventAttributes) GetPrevAutoResetPoints() (o *ResetPoints)

+ func (v *WorkflowExecutionStartedEventAttributes) GetRetryPolicy() (o *RetryPolicy)

+ func (v *WorkflowExecutionStartedEventAttributes) GetSearchAttributes() (o *SearchAttributes)

+ func (v *WorkflowExecutionStartedEventAttributes) GetTaskList() (o *TaskList)

+ func (v *WorkflowExecutionStartedEventAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32)

+ func (v *WorkflowExecutionStartedEventAttributes) GetWorkflowType() (o *WorkflowType)

type WorkflowExecutionTerminatedEventAttributes

+ func (v *WorkflowExecutionTerminatedEventAttributes) GetDetails() (o []byte)

+ func (v *WorkflowExecutionTerminatedEventAttributes) GetIdentity() (o string)

+ func (v *WorkflowExecutionTerminatedEventAttributes) GetReason() (o string)

type WorkflowExecutionTimedOutEventAttributes

+ func (v *WorkflowExecutionTimedOutEventAttributes) GetTimeoutType() (o TimeoutType)

type WorkflowIDReusePolicy

+ func (e WorkflowIDReusePolicy) Ptr() *WorkflowIDReusePolicy

type WorkflowQuery

+ func (v *WorkflowQuery) GetQueryArgs() (o []byte)

+ func (v *WorkflowQuery) GetQueryType() (o string)

type WorkflowQueryResult

+ func (v *WorkflowQueryResult) GetAnswer() (o []byte)

+ func (v *WorkflowQueryResult) GetErrorMessage() (o string)

+ func (v *WorkflowQueryResult) GetResultType() (o QueryResultType)

type WorkflowType

+ func (v *WorkflowType) GetName() (o string)

type WorkflowTypeFilter

+ func (v *WorkflowTypeFilter) GetName() (o string)

v0.16.1

Jan 21, 2021

v0.16.0

Dec 4, 2020

Changes in this version

+ type AccessDeniedError struct

+ Message string

+ func (err AccessDeniedError) Error() string

+ type ActivityTaskCancelRequestedEventAttributes struct

+ ActivityID *string

+ DecisionTaskCompletedEventID *int64

+ type ActivityTaskCanceledEventAttributes struct

+ Details []byte

+ Identity *string

+ LatestCancelRequestedEventID *int64

+ ScheduledEventID *int64

+ StartedEventID *int64

+ type ActivityTaskCompletedEventAttributes struct

+ Identity *string

+ Result []byte

+ ScheduledEventID *int64

+ StartedEventID *int64

+ type ActivityTaskFailedEventAttributes struct

+ Details []byte

+ Identity *string

+ Reason *string

+ ScheduledEventID *int64

+ StartedEventID *int64

+ type ActivityTaskScheduledEventAttributes struct

+ ActivityID *string

+ ActivityType *ActivityType

+ DecisionTaskCompletedEventID *int64

+ Domain *string

+ Header *Header

+ HeartbeatTimeoutSeconds *int32

+ Input []byte

+ RetryPolicy *RetryPolicy

+ ScheduleToCloseTimeoutSeconds *int32

+ ScheduleToStartTimeoutSeconds *int32

+ StartToCloseTimeoutSeconds *int32

+ TaskList *TaskList

+ type ActivityTaskStartedEventAttributes struct

+ Attempt *int32

+ Identity *string

+ LastFailureDetails []byte

+ LastFailureReason *string

+ RequestID *string

+ ScheduledEventID *int64

+ type ActivityTaskTimedOutEventAttributes struct

+ Details []byte

+ LastFailureDetails []byte

+ LastFailureReason *string

+ ScheduledEventID *int64

+ StartedEventID *int64

+ TimeoutType *TimeoutType

+ type ActivityType struct

+ Name *string

+ type ArchivalStatus int32

+ const ArchivalStatusDisabled

+ const ArchivalStatusEnabled

+ type BadBinaries struct

+ Binaries map[string]*BadBinaryInfo

+ type BadBinaryInfo struct

+ CreatedTimeNano *int64

+ Operator *string

+ Reason *string

+ type BadRequestError struct

+ Message string

+ func (err BadRequestError) Error() string

+ type CancelExternalWorkflowExecutionFailedCause int32

+ const CancelExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution

+ type CancelTimerDecisionAttributes struct

+ TimerID *string

+ type CancelTimerFailedEventAttributes struct

+ Cause *string

+ DecisionTaskCompletedEventID *int64

+ Identity *string

+ TimerID *string

+ type CancelWorkflowExecutionDecisionAttributes struct

+ Details []byte

+ type CancellationAlreadyRequestedError struct

+ Message string

+ func (err CancellationAlreadyRequestedError) Error() string

+ type ChildWorkflowExecutionCanceledEventAttributes struct

+ Details []byte

+ Domain *string

+ InitiatedEventID *int64

+ StartedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

+ type ChildWorkflowExecutionCompletedEventAttributes struct

+ Domain *string

+ InitiatedEventID *int64

+ Result []byte

+ StartedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

+ type ChildWorkflowExecutionFailedCause int32

+ const ChildWorkflowExecutionFailedCauseWorkflowAlreadyRunning

+ type ChildWorkflowExecutionFailedEventAttributes struct

+ Details []byte

+ Domain *string

+ InitiatedEventID *int64

+ Reason *string

+ StartedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

+ type ChildWorkflowExecutionStartedEventAttributes struct

+ Domain *string

+ Header *Header

+ InitiatedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

+ type ChildWorkflowExecutionTerminatedEventAttributes struct

+ Domain *string

+ InitiatedEventID *int64

+ StartedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

+ type ChildWorkflowExecutionTimedOutEventAttributes struct

+ Domain *string

+ InitiatedEventID *int64

+ StartedEventID *int64

+ TimeoutType *TimeoutType

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

+ type ClientVersionNotSupportedError struct

+ ClientImpl string

+ FeatureVersion string

+ SupportedVersions string

+ func (err ClientVersionNotSupportedError) Error() string

+ type CloseShardRequest struct

+ ShardID *int32

+ type ClusterInfo struct

+ SupportedClientVersions *SupportedClientVersions

+ type ClusterReplicationConfiguration struct

+ ClusterName *string

+ type CompleteWorkflowExecutionDecisionAttributes struct

+ Result []byte

+ type ContinueAsNewInitiator int32

+ const ContinueAsNewInitiatorCronSchedule

+ const ContinueAsNewInitiatorDecider

+ const ContinueAsNewInitiatorRetryPolicy

+ type ContinueAsNewWorkflowExecutionDecisionAttributes struct

+ BackoffStartIntervalInSeconds *int32

+ CronSchedule *string

+ ExecutionStartToCloseTimeoutSeconds *int32

+ FailureDetails []byte

+ FailureReason *string

+ Header *Header

+ Initiator *ContinueAsNewInitiator

+ Input []byte

+ LastCompletionResult []byte

+ Memo *Memo

+ RetryPolicy *RetryPolicy

+ SearchAttributes *SearchAttributes

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ WorkflowType *WorkflowType

+ type CountWorkflowExecutionsRequest struct

+ Domain *string

+ Query *string

+ type CountWorkflowExecutionsResponse struct

+ Count *int64

+ type CurrentBranchChangedError struct

+ CurrentBranchToken []byte

+ Message string

+ func (err CurrentBranchChangedError) Error() string

+ type DataBlob struct

+ Data []byte

+ EncodingType *EncodingType

+ type Decision struct

+ CancelTimerDecisionAttributes *CancelTimerDecisionAttributes

+ CancelWorkflowExecutionDecisionAttributes *CancelWorkflowExecutionDecisionAttributes

+ CompleteWorkflowExecutionDecisionAttributes *CompleteWorkflowExecutionDecisionAttributes

+ ContinueAsNewWorkflowExecutionDecisionAttributes *ContinueAsNewWorkflowExecutionDecisionAttributes

+ DecisionType *DecisionType

+ FailWorkflowExecutionDecisionAttributes *FailWorkflowExecutionDecisionAttributes

+ RecordMarkerDecisionAttributes *RecordMarkerDecisionAttributes

+ RequestCancelActivityTaskDecisionAttributes *RequestCancelActivityTaskDecisionAttributes

+ RequestCancelExternalWorkflowExecutionDecisionAttributes *RequestCancelExternalWorkflowExecutionDecisionAttributes

+ ScheduleActivityTaskDecisionAttributes *ScheduleActivityTaskDecisionAttributes

+ SignalExternalWorkflowExecutionDecisionAttributes *SignalExternalWorkflowExecutionDecisionAttributes

+ StartChildWorkflowExecutionDecisionAttributes *StartChildWorkflowExecutionDecisionAttributes

+ StartTimerDecisionAttributes *StartTimerDecisionAttributes

+ UpsertWorkflowSearchAttributesDecisionAttributes *UpsertWorkflowSearchAttributesDecisionAttributes

+ type DecisionTaskCompletedEventAttributes struct

+ BinaryChecksum *string

+ ExecutionContext []byte

+ Identity *string

+ ScheduledEventID *int64

+ StartedEventID *int64

+ type DecisionTaskFailedCause int32

+ const DecisionTaskFailedCauseBadBinary

+ const DecisionTaskFailedCauseBadCancelTimerAttributes

+ const DecisionTaskFailedCauseBadCancelWorkflowExecutionAttributes

+ const DecisionTaskFailedCauseBadCompleteWorkflowExecutionAttributes

+ const DecisionTaskFailedCauseBadContinueAsNewAttributes

+ const DecisionTaskFailedCauseBadFailWorkflowExecutionAttributes

+ const DecisionTaskFailedCauseBadRecordMarkerAttributes

+ const DecisionTaskFailedCauseBadRequestCancelActivityAttributes

+ const DecisionTaskFailedCauseBadRequestCancelExternalWorkflowExecutionAttributes

+ const DecisionTaskFailedCauseBadScheduleActivityAttributes

+ const DecisionTaskFailedCauseBadSearchAttributes

+ const DecisionTaskFailedCauseBadSignalInputSize

+ const DecisionTaskFailedCauseBadSignalWorkflowExecutionAttributes

+ const DecisionTaskFailedCauseBadStartChildExecutionAttributes

+ const DecisionTaskFailedCauseBadStartTimerAttributes

+ const DecisionTaskFailedCauseFailoverCloseDecision

+ const DecisionTaskFailedCauseForceCloseDecision

+ const DecisionTaskFailedCauseResetStickyTasklist

+ const DecisionTaskFailedCauseResetWorkflow

+ const DecisionTaskFailedCauseScheduleActivityDuplicateID

+ const DecisionTaskFailedCauseStartTimerDuplicateID

+ const DecisionTaskFailedCauseUnhandledDecision

+ const DecisionTaskFailedCauseWorkflowWorkerUnhandledFailure

+ type DecisionTaskFailedEventAttributes struct

+ BaseRunID *string

+ BinaryChecksum *string

+ Cause *DecisionTaskFailedCause

+ Details []byte

+ ForkEventVersion *int64

+ Identity *string

+ NewRunID *string

+ Reason *string

+ ScheduledEventID *int64

+ StartedEventID *int64

+ type DecisionTaskScheduledEventAttributes struct

+ Attempt *int64

+ StartToCloseTimeoutSeconds *int32

+ TaskList *TaskList

+ type DecisionTaskStartedEventAttributes struct

+ Identity *string

+ RequestID *string

+ ScheduledEventID *int64

+ type DecisionTaskTimedOutEventAttributes struct

+ ScheduledEventID *int64

+ StartedEventID *int64

+ TimeoutType *TimeoutType

+ type DecisionType int32

+ const DecisionTypeCancelTimer

+ const DecisionTypeCancelWorkflowExecution

+ const DecisionTypeCompleteWorkflowExecution

+ const DecisionTypeContinueAsNewWorkflowExecution

+ const DecisionTypeFailWorkflowExecution

+ const DecisionTypeRecordMarker

+ const DecisionTypeRequestCancelActivityTask

+ const DecisionTypeRequestCancelExternalWorkflowExecution

+ const DecisionTypeScheduleActivityTask

+ const DecisionTypeSignalExternalWorkflowExecution

+ const DecisionTypeStartChildWorkflowExecution

+ const DecisionTypeStartTimer

+ const DecisionTypeUpsertWorkflowSearchAttributes

+ type DeprecateDomainRequest struct

+ Name *string

+ SecurityToken *string

+ type DescribeDomainRequest struct

+ Name *string

+ UUID *string

+ type DescribeDomainResponse struct

+ Configuration *DomainConfiguration

+ DomainInfo *DomainInfo

+ FailoverVersion *int64

+ IsGlobalDomain *bool

+ ReplicationConfiguration *DomainReplicationConfiguration

+ type DescribeHistoryHostRequest struct

+ ExecutionForHost *WorkflowExecution

+ HostAddress *string

+ ShardIDForHost *int32

+ type DescribeHistoryHostResponse struct

+ Address *string

+ DomainCache *DomainCacheInfo

+ NumberOfShards *int32

+ ShardControllerStatus *string

+ ShardIDs []int32

+ type DescribeQueueRequest struct

+ ClusterName *string

+ ShardID *int32

+ Type *int32

+ type DescribeQueueResponse struct

+ ProcessingQueueStates []string

+ type DescribeTaskListRequest struct

+ Domain *string

+ IncludeTaskListStatus *bool

+ TaskList *TaskList

+ TaskListType *TaskListType

+ type DescribeTaskListResponse struct

+ Pollers []*PollerInfo

+ TaskListStatus *TaskListStatus

+ type DescribeWorkflowExecutionRequest struct

+ Domain *string

+ Execution *WorkflowExecution

+ type DescribeWorkflowExecutionResponse struct

+ ExecutionConfiguration *WorkflowExecutionConfiguration

+ PendingActivities []*PendingActivityInfo

+ PendingChildren []*PendingChildExecutionInfo

+ WorkflowExecutionInfo *WorkflowExecutionInfo

+ type DomainAlreadyExistsError struct

+ Message string

+ func (err DomainAlreadyExistsError) Error() string

+ type DomainCacheInfo struct

+ NumOfItemsInCacheByID *int64

+ NumOfItemsInCacheByName *int64

+ type DomainConfiguration struct

+ BadBinaries *BadBinaries

+ EmitMetric *bool

+ HistoryArchivalStatus *ArchivalStatus

+ HistoryArchivalURI *string

+ VisibilityArchivalStatus *ArchivalStatus

+ VisibilityArchivalURI *string

+ WorkflowExecutionRetentionPeriodInDays *int32

+ type DomainInfo struct

+ Data map[string]string

+ Description *string

+ Name *string

+ OwnerEmail *string

+ Status *DomainStatus

+ UUID *string

+ type DomainNotActiveError struct

+ ActiveCluster string

+ CurrentCluster string

+ DomainName string

+ Message string

+ func (err DomainNotActiveError) Error() string

+ type DomainReplicationConfiguration struct

+ ActiveClusterName *string

+ Clusters []*ClusterReplicationConfiguration

+ type DomainStatus int32

+ const DomainStatusDeleted

+ const DomainStatusDeprecated

+ const DomainStatusRegistered

+ type EncodingType int32

+ const EncodingTypeJSON

+ const EncodingTypeThriftRW

+ type EntityNotExistsError struct

+ ActiveCluster *string

+ CurrentCluster *string

+ Message string

+ func (err EntityNotExistsError) Error() string

+ type EventType int32

+ const EventTypeActivityTaskCancelRequested

+ const EventTypeActivityTaskCanceled

+ const EventTypeActivityTaskCompleted

+ const EventTypeActivityTaskFailed

+ const EventTypeActivityTaskScheduled

+ const EventTypeActivityTaskStarted

+ const EventTypeActivityTaskTimedOut

+ const EventTypeCancelTimerFailed

+ const EventTypeChildWorkflowExecutionCanceled

+ const EventTypeChildWorkflowExecutionCompleted

+ const EventTypeChildWorkflowExecutionFailed

+ const EventTypeChildWorkflowExecutionStarted

+ const EventTypeChildWorkflowExecutionTerminated

+ const EventTypeChildWorkflowExecutionTimedOut

+ const EventTypeDecisionTaskCompleted

+ const EventTypeDecisionTaskFailed

+ const EventTypeDecisionTaskScheduled

+ const EventTypeDecisionTaskStarted

+ const EventTypeDecisionTaskTimedOut

+ const EventTypeExternalWorkflowExecutionCancelRequested

+ const EventTypeExternalWorkflowExecutionSignaled

+ const EventTypeMarkerRecorded

+ const EventTypeRequestCancelActivityTaskFailed

+ const EventTypeRequestCancelExternalWorkflowExecutionFailed

+ const EventTypeRequestCancelExternalWorkflowExecutionInitiated

+ const EventTypeSignalExternalWorkflowExecutionFailed

+ const EventTypeSignalExternalWorkflowExecutionInitiated

+ const EventTypeStartChildWorkflowExecutionFailed

+ const EventTypeStartChildWorkflowExecutionInitiated

+ const EventTypeTimerCanceled

+ const EventTypeTimerFired

+ const EventTypeTimerStarted

+ const EventTypeUpsertWorkflowSearchAttributes

+ const EventTypeWorkflowExecutionCancelRequested

+ const EventTypeWorkflowExecutionCanceled

+ const EventTypeWorkflowExecutionCompleted

+ const EventTypeWorkflowExecutionContinuedAsNew

+ const EventTypeWorkflowExecutionFailed

+ const EventTypeWorkflowExecutionSignaled

+ const EventTypeWorkflowExecutionStarted

+ const EventTypeWorkflowExecutionTerminated

+ const EventTypeWorkflowExecutionTimedOut

+ type ExternalWorkflowExecutionCancelRequestedEventAttributes struct

+ Domain *string

+ InitiatedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ type ExternalWorkflowExecutionSignaledEventAttributes struct

+ Control []byte

+ Domain *string

+ InitiatedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ type FailWorkflowExecutionDecisionAttributes struct

+ Details []byte

+ Reason *string

+ type GetSearchAttributesResponse struct

+ Keys map[string]IndexedValueType

+ type GetWorkflowExecutionHistoryRequest struct

+ Domain *string

+ Execution *WorkflowExecution

+ HistoryEventFilterType *HistoryEventFilterType

+ MaximumPageSize *int32

+ NextPageToken []byte

+ SkipArchival *bool

+ WaitForNewEvent *bool

+ type GetWorkflowExecutionHistoryResponse struct

+ Archived *bool

+ History *History

+ NextPageToken []byte

+ RawHistory []*DataBlob

+ type Header struct

+ Fields map[string][]byte

+ type History struct

+ Events []*HistoryEvent

+ type HistoryBranch struct

+ Ancestors []*HistoryBranchRange

+ BranchID *string

+ TreeID *string

+ type HistoryBranchRange struct

+ BeginNodeID *int64

+ BranchID *string

+ EndNodeID *int64

+ type HistoryEvent struct

+ ActivityTaskCancelRequestedEventAttributes *ActivityTaskCancelRequestedEventAttributes

+ ActivityTaskCanceledEventAttributes *ActivityTaskCanceledEventAttributes

+ ActivityTaskCompletedEventAttributes *ActivityTaskCompletedEventAttributes

+ ActivityTaskFailedEventAttributes *ActivityTaskFailedEventAttributes

+ ActivityTaskScheduledEventAttributes *ActivityTaskScheduledEventAttributes

+ ActivityTaskStartedEventAttributes *ActivityTaskStartedEventAttributes

+ ActivityTaskTimedOutEventAttributes *ActivityTaskTimedOutEventAttributes

+ CancelTimerFailedEventAttributes *CancelTimerFailedEventAttributes

+ ChildWorkflowExecutionCanceledEventAttributes *ChildWorkflowExecutionCanceledEventAttributes

+ ChildWorkflowExecutionCompletedEventAttributes *ChildWorkflowExecutionCompletedEventAttributes

+ ChildWorkflowExecutionFailedEventAttributes *ChildWorkflowExecutionFailedEventAttributes

+ ChildWorkflowExecutionStartedEventAttributes *ChildWorkflowExecutionStartedEventAttributes

+ ChildWorkflowExecutionTerminatedEventAttributes *ChildWorkflowExecutionTerminatedEventAttributes

+ ChildWorkflowExecutionTimedOutEventAttributes *ChildWorkflowExecutionTimedOutEventAttributes

+ DecisionTaskCompletedEventAttributes *DecisionTaskCompletedEventAttributes

+ DecisionTaskFailedEventAttributes *DecisionTaskFailedEventAttributes

+ DecisionTaskScheduledEventAttributes *DecisionTaskScheduledEventAttributes

+ DecisionTaskStartedEventAttributes *DecisionTaskStartedEventAttributes

+ DecisionTaskTimedOutEventAttributes *DecisionTaskTimedOutEventAttributes

+ EventID *int64

+ EventType *EventType

+ ExternalWorkflowExecutionCancelRequestedEventAttributes *ExternalWorkflowExecutionCancelRequestedEventAttributes

+ ExternalWorkflowExecutionSignaledEventAttributes *ExternalWorkflowExecutionSignaledEventAttributes

+ MarkerRecordedEventAttributes *MarkerRecordedEventAttributes

+ RequestCancelActivityTaskFailedEventAttributes *RequestCancelActivityTaskFailedEventAttributes

+ RequestCancelExternalWorkflowExecutionFailedEventAttributes *RequestCancelExternalWorkflowExecutionFailedEventAttributes

+ RequestCancelExternalWorkflowExecutionInitiatedEventAttributes *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes

+ SignalExternalWorkflowExecutionFailedEventAttributes *SignalExternalWorkflowExecutionFailedEventAttributes

+ SignalExternalWorkflowExecutionInitiatedEventAttributes *SignalExternalWorkflowExecutionInitiatedEventAttributes

+ StartChildWorkflowExecutionFailedEventAttributes *StartChildWorkflowExecutionFailedEventAttributes

+ StartChildWorkflowExecutionInitiatedEventAttributes *StartChildWorkflowExecutionInitiatedEventAttributes

+ TaskID *int64

+ TimerCanceledEventAttributes *TimerCanceledEventAttributes

+ TimerFiredEventAttributes *TimerFiredEventAttributes

+ TimerStartedEventAttributes *TimerStartedEventAttributes

+ Timestamp *int64

+ UpsertWorkflowSearchAttributesEventAttributes *UpsertWorkflowSearchAttributesEventAttributes

+ Version *int64

+ WorkflowExecutionCancelRequestedEventAttributes *WorkflowExecutionCancelRequestedEventAttributes

+ WorkflowExecutionCanceledEventAttributes *WorkflowExecutionCanceledEventAttributes

+ WorkflowExecutionCompletedEventAttributes *WorkflowExecutionCompletedEventAttributes

+ WorkflowExecutionContinuedAsNewEventAttributes *WorkflowExecutionContinuedAsNewEventAttributes

+ WorkflowExecutionFailedEventAttributes *WorkflowExecutionFailedEventAttributes

+ WorkflowExecutionSignaledEventAttributes *WorkflowExecutionSignaledEventAttributes

+ WorkflowExecutionStartedEventAttributes *WorkflowExecutionStartedEventAttributes

+ WorkflowExecutionTerminatedEventAttributes *WorkflowExecutionTerminatedEventAttributes

+ WorkflowExecutionTimedOutEventAttributes *WorkflowExecutionTimedOutEventAttributes

+ type HistoryEventFilterType int32

+ const HistoryEventFilterTypeAllEvent

+ const HistoryEventFilterTypeCloseEvent

+ type IndexedValueType int32

+ const IndexedValueTypeBool

+ const IndexedValueTypeDatetime

+ const IndexedValueTypeDouble

+ const IndexedValueTypeInt

+ const IndexedValueTypeKeyword

+ const IndexedValueTypeString

+ type InternalDataInconsistencyError struct

+ Message string

+ func (err InternalDataInconsistencyError) Error() string

+ type InternalServiceError struct

+ Message string

+ func (err InternalServiceError) Error() string

+ type LimitExceededError struct

+ Message string

+ func (err LimitExceededError) Error() string

+ type ListArchivedWorkflowExecutionsRequest struct

+ Domain *string

+ NextPageToken []byte

+ PageSize *int32

+ Query *string

+ type ListArchivedWorkflowExecutionsResponse struct

+ Executions []*WorkflowExecutionInfo

+ NextPageToken []byte

+ type ListClosedWorkflowExecutionsRequest struct

+ Domain *string

+ ExecutionFilter *WorkflowExecutionFilter

+ MaximumPageSize *int32

+ NextPageToken []byte

+ StartTimeFilter *StartTimeFilter

+ StatusFilter *WorkflowExecutionCloseStatus

+ TypeFilter *WorkflowTypeFilter

+ type ListClosedWorkflowExecutionsResponse struct

+ Executions []*WorkflowExecutionInfo

+ NextPageToken []byte

+ type ListDomainsRequest struct

+ NextPageToken []byte

+ PageSize *int32

+ type ListDomainsResponse struct

+ Domains []*DescribeDomainResponse

+ NextPageToken []byte

+ type ListOpenWorkflowExecutionsRequest struct

+ Domain *string

+ ExecutionFilter *WorkflowExecutionFilter

+ MaximumPageSize *int32

+ NextPageToken []byte

+ StartTimeFilter *StartTimeFilter

+ TypeFilter *WorkflowTypeFilter

+ type ListOpenWorkflowExecutionsResponse struct

+ Executions []*WorkflowExecutionInfo

+ NextPageToken []byte

+ type ListTaskListPartitionsRequest struct

+ Domain *string

+ TaskList *TaskList

+ type ListTaskListPartitionsResponse struct

+ ActivityTaskListPartitions []*TaskListPartitionMetadata

+ DecisionTaskListPartitions []*TaskListPartitionMetadata

+ type ListWorkflowExecutionsRequest struct

+ Domain *string

+ NextPageToken []byte

+ PageSize *int32

+ Query *string

+ type ListWorkflowExecutionsResponse struct

+ Executions []*WorkflowExecutionInfo

+ NextPageToken []byte

+ type MarkerRecordedEventAttributes struct

+ DecisionTaskCompletedEventID *int64

+ Details []byte

+ Header *Header

+ MarkerName *string

+ type Memo struct

+ Fields map[string][]byte

+ type ParentClosePolicy int32

+ const ParentClosePolicyAbandon

+ const ParentClosePolicyRequestCancel

+ const ParentClosePolicyTerminate

+ type PendingActivityInfo struct

+ ActivityID *string

+ ActivityType *ActivityType

+ Attempt *int32

+ ExpirationTimestamp *int64

+ HeartbeatDetails []byte

+ LastFailureDetails []byte

+ LastFailureReason *string

+ LastHeartbeatTimestamp *int64

+ LastStartedTimestamp *int64

+ LastWorkerIdentity *string

+ MaximumAttempts *int32

+ ScheduledTimestamp *int64

+ State *PendingActivityState

+ type PendingActivityState int32

+ const PendingActivityStateCancelRequested

+ const PendingActivityStateScheduled

+ const PendingActivityStateStarted

+ type PendingChildExecutionInfo struct

+ InitiatedID *int64

+ ParentClosePolicy *ParentClosePolicy

+ RunID *string

+ WorkflowID *string

+ WorkflowTypName *string

+ type PollForActivityTaskRequest struct

+ Domain *string

+ Identity *string

+ TaskList *TaskList

+ TaskListMetadata *TaskListMetadata

+ type PollForActivityTaskResponse struct

+ ActivityID *string

+ ActivityType *ActivityType

+ Attempt *int32

+ Header *Header

+ HeartbeatDetails []byte

+ HeartbeatTimeoutSeconds *int32

+ Input []byte

+ ScheduleToCloseTimeoutSeconds *int32

+ ScheduledTimestamp *int64

+ ScheduledTimestampOfThisAttempt *int64

+ StartToCloseTimeoutSeconds *int32

+ StartedTimestamp *int64

+ TaskToken []byte

+ WorkflowDomain *string

+ WorkflowExecution *WorkflowExecution

+ WorkflowType *WorkflowType

+ type PollForDecisionTaskRequest struct

+ BinaryChecksum *string

+ Domain *string

+ Identity *string

+ TaskList *TaskList

+ type PollForDecisionTaskResponse struct

+ Attempt *int64

+ BacklogCountHint *int64

+ History *History

+ NextPageToken []byte

+ PreviousStartedEventID *int64

+ Queries map[string]*WorkflowQuery

+ Query *WorkflowQuery

+ ScheduledTimestamp *int64

+ StartedEventID *int64

+ StartedTimestamp *int64

+ TaskToken []byte

+ WorkflowExecution *WorkflowExecution

+ WorkflowExecutionTaskList *TaskList

+ WorkflowType *WorkflowType

+ type PollerInfo struct

+ Identity *string

+ LastAccessTime *int64

+ RatePerSecond *float64

+ type QueryConsistencyLevel int32

+ const QueryConsistencyLevelEventual

+ const QueryConsistencyLevelStrong

+ type QueryFailedError struct

+ Message string

+ func (err QueryFailedError) Error() string

+ type QueryRejectCondition int32

+ const QueryRejectConditionNotCompletedCleanly

+ const QueryRejectConditionNotOpen

+ type QueryRejected struct

+ CloseStatus *WorkflowExecutionCloseStatus

+ type QueryResultType int32

+ const QueryResultTypeAnswered

+ const QueryResultTypeFailed

+ type QueryTaskCompletedType int32

+ const QueryTaskCompletedTypeCompleted

+ const QueryTaskCompletedTypeFailed

+ type QueryWorkflowRequest struct

+ Domain *string

+ Execution *WorkflowExecution

+ Query *WorkflowQuery

+ QueryConsistencyLevel *QueryConsistencyLevel

+ QueryRejectCondition *QueryRejectCondition

+ type QueryWorkflowResponse struct

+ QueryRejected *QueryRejected

+ QueryResult []byte

+ type ReapplyEventsRequest struct

+ DomainName *string

+ Events *DataBlob

+ WorkflowExecution *WorkflowExecution

+ type RecordActivityTaskHeartbeatByIDRequest struct

+ ActivityID *string

+ Details []byte

+ Domain *string

+ Identity *string

+ RunID *string

+ WorkflowID *string

+ type RecordActivityTaskHeartbeatRequest struct

+ Details []byte

+ Identity *string

+ TaskToken []byte

+ type RecordActivityTaskHeartbeatResponse struct

+ CancelRequested *bool

+ type RecordMarkerDecisionAttributes struct

+ Details []byte

+ Header *Header

+ MarkerName *string

+ type RefreshWorkflowTasksRequest struct

+ Domain *string

+ Execution *WorkflowExecution

+ type RegisterDomainRequest struct

+ ActiveClusterName *string

+ Clusters []*ClusterReplicationConfiguration

+ Data map[string]string

+ Description *string

+ EmitMetric *bool

+ HistoryArchivalStatus *ArchivalStatus

+ HistoryArchivalURI *string

+ IsGlobalDomain *bool

+ Name *string

+ OwnerEmail *string

+ SecurityToken *string

+ VisibilityArchivalStatus *ArchivalStatus

+ VisibilityArchivalURI *string

+ WorkflowExecutionRetentionPeriodInDays *int32

+ type RemoteSyncMatchedError struct

+ Message string

+ func (err RemoteSyncMatchedError) Error() string

+ type RemoveTaskRequest struct

+ ShardID *int32

+ TaskID *int64

+ Type *int32

+ VisibilityTimestamp *int64

+ type RequestCancelActivityTaskDecisionAttributes struct

+ ActivityID *string

+ type RequestCancelActivityTaskFailedEventAttributes struct

+ ActivityID *string

+ Cause *string

+ DecisionTaskCompletedEventID *int64

+ type RequestCancelExternalWorkflowExecutionDecisionAttributes struct

+ ChildWorkflowOnly *bool

+ Control []byte

+ Domain *string

+ RunID *string

+ WorkflowID *string

+ type RequestCancelExternalWorkflowExecutionFailedEventAttributes struct

+ Cause *CancelExternalWorkflowExecutionFailedCause

+ Control []byte

+ DecisionTaskCompletedEventID *int64

+ Domain *string

+ InitiatedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes struct

+ ChildWorkflowOnly *bool

+ Control []byte

+ DecisionTaskCompletedEventID *int64

+ Domain *string

+ WorkflowExecution *WorkflowExecution

+ type RequestCancelWorkflowExecutionRequest struct

+ Domain *string

+ Identity *string

+ RequestID *string

+ WorkflowExecution *WorkflowExecution

+ type ResetPointInfo struct

+ BinaryChecksum *string

+ CreatedTimeNano *int64

+ ExpiringTimeNano *int64

+ FirstDecisionCompletedID *int64

+ Resettable *bool

+ RunID *string

+ type ResetPoints struct

+ Points []*ResetPointInfo

+ type ResetQueueRequest struct

+ ClusterName *string

+ ShardID *int32

+ Type *int32

+ type ResetStickyTaskListRequest struct

+ Domain *string

+ Execution *WorkflowExecution

+ type ResetStickyTaskListResponse struct

+ type ResetWorkflowExecutionRequest struct

+ DecisionFinishEventID *int64

+ Domain *string

+ Reason *string

+ RequestID *string

+ WorkflowExecution *WorkflowExecution

+ type ResetWorkflowExecutionResponse struct

+ RunID *string

+ type RespondActivityTaskCanceledByIDRequest struct

+ ActivityID *string

+ Details []byte

+ Domain *string

+ Identity *string

+ RunID *string

+ WorkflowID *string

+ type RespondActivityTaskCanceledRequest struct

+ Details []byte

+ Identity *string

+ TaskToken []byte

+ type RespondActivityTaskCompletedByIDRequest struct

+ ActivityID *string

+ Domain *string

+ Identity *string

+ Result []byte

+ RunID *string

+ WorkflowID *string

+ type RespondActivityTaskCompletedRequest struct

+ Identity *string

+ Result []byte

+ TaskToken []byte

+ type RespondActivityTaskFailedByIDRequest struct

+ ActivityID *string

+ Details []byte

+ Domain *string

+ Identity *string

+ Reason *string

+ RunID *string

+ WorkflowID *string

+ type RespondActivityTaskFailedRequest struct

+ Details []byte

+ Identity *string

+ Reason *string

+ TaskToken []byte

+ type RespondDecisionTaskCompletedRequest struct

+ BinaryChecksum *string

+ Decisions []*Decision

+ ExecutionContext []byte

+ ForceCreateNewDecisionTask *bool

+ Identity *string

+ QueryResults map[string]*WorkflowQueryResult

+ ReturnNewDecisionTask *bool

+ StickyAttributes *StickyExecutionAttributes

+ TaskToken []byte

+ type RespondDecisionTaskCompletedResponse struct

+ DecisionTask *PollForDecisionTaskResponse

+ type RespondDecisionTaskFailedRequest struct

+ BinaryChecksum *string

+ Cause *DecisionTaskFailedCause

+ Details []byte

+ Identity *string

+ TaskToken []byte

+ type RespondQueryTaskCompletedRequest struct

+ CompletedType *QueryTaskCompletedType

+ ErrorMessage *string

+ QueryResult []byte

+ TaskToken []byte

+ WorkerVersionInfo *WorkerVersionInfo

+ type RetryPolicy struct

+ BackoffCoefficient *float64

+ ExpirationIntervalInSeconds *int32

+ InitialIntervalInSeconds *int32

+ MaximumAttempts *int32

+ MaximumIntervalInSeconds *int32

+ NonRetriableErrorReasons []string

+ type RetryTaskV2Error struct

+ DomainID *string

+ EndEventID *int64

+ EndEventVersion *int64

+ Message string

+ RunID *string

+ StartEventID *int64

+ StartEventVersion *int64

+ WorkflowID *string

+ func (err RetryTaskV2Error) Error() string

+ type ScheduleActivityTaskDecisionAttributes struct

+ ActivityID *string

+ ActivityType *ActivityType

+ Domain *string

+ Header *Header

+ HeartbeatTimeoutSeconds *int32

+ Input []byte

+ RetryPolicy *RetryPolicy

+ ScheduleToCloseTimeoutSeconds *int32

+ ScheduleToStartTimeoutSeconds *int32

+ StartToCloseTimeoutSeconds *int32

+ TaskList *TaskList

+ type SearchAttributes struct

+ IndexedFields map[string][]byte

+ type ServiceBusyError struct

+ Message string

+ func (err ServiceBusyError) Error() string

+ type SignalExternalWorkflowExecutionDecisionAttributes struct

+ ChildWorkflowOnly *bool

+ Control []byte

+ Domain *string

+ Execution *WorkflowExecution

+ Input []byte

+ SignalName *string

+ type SignalExternalWorkflowExecutionFailedCause int32

+ const SignalExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution

+ type SignalExternalWorkflowExecutionFailedEventAttributes struct

+ Cause *SignalExternalWorkflowExecutionFailedCause

+ Control []byte

+ DecisionTaskCompletedEventID *int64

+ Domain *string

+ InitiatedEventID *int64

+ WorkflowExecution *WorkflowExecution

+ type SignalExternalWorkflowExecutionInitiatedEventAttributes struct

+ ChildWorkflowOnly *bool

+ Control []byte

+ DecisionTaskCompletedEventID *int64

+ Domain *string

+ Input []byte

+ SignalName *string

+ WorkflowExecution *WorkflowExecution

+ type SignalWithStartWorkflowExecutionRequest struct

+ Control []byte

+ CronSchedule *string

+ Domain *string

+ ExecutionStartToCloseTimeoutSeconds *int32

+ Header *Header

+ Identity *string

+ Input []byte

+ Memo *Memo

+ RequestID *string

+ RetryPolicy *RetryPolicy

+ SearchAttributes *SearchAttributes

+ SignalInput []byte

+ SignalName *string

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ WorkflowID *string

+ WorkflowIDReusePolicy *WorkflowIDReusePolicy

+ WorkflowType *WorkflowType

+ type SignalWorkflowExecutionRequest struct

+ Control []byte

+ Domain *string

+ Identity *string

+ Input []byte

+ RequestID *string

+ SignalName *string

+ WorkflowExecution *WorkflowExecution

+ type StartChildWorkflowExecutionDecisionAttributes struct

+ Control []byte

+ CronSchedule *string

+ Domain *string

+ ExecutionStartToCloseTimeoutSeconds *int32

+ Header *Header

+ Input []byte

+ Memo *Memo

+ ParentClosePolicy *ParentClosePolicy

+ RetryPolicy *RetryPolicy

+ SearchAttributes *SearchAttributes

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ WorkflowID *string

+ WorkflowIDReusePolicy *WorkflowIDReusePolicy

+ WorkflowType *WorkflowType

+ type StartChildWorkflowExecutionFailedEventAttributes struct

+ Cause *ChildWorkflowExecutionFailedCause

+ Control []byte

+ DecisionTaskCompletedEventID *int64

+ Domain *string

+ InitiatedEventID *int64

+ WorkflowID *string

+ WorkflowType *WorkflowType

+ type StartChildWorkflowExecutionInitiatedEventAttributes struct

+ Control []byte

+ CronSchedule *string

+ DecisionTaskCompletedEventID *int64

+ Domain *string

+ ExecutionStartToCloseTimeoutSeconds *int32

+ Header *Header

+ Input []byte

+ Memo *Memo

+ ParentClosePolicy *ParentClosePolicy

+ RetryPolicy *RetryPolicy

+ SearchAttributes *SearchAttributes

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ WorkflowID *string

+ WorkflowIDReusePolicy *WorkflowIDReusePolicy

+ WorkflowType *WorkflowType

+ type StartTimeFilter struct

+ EarliestTime *int64

+ LatestTime *int64

+ type StartTimerDecisionAttributes struct

+ StartToFireTimeoutSeconds *int64

+ TimerID *string

+ type StartWorkflowExecutionRequest struct

+ CronSchedule *string

+ Domain *string

+ ExecutionStartToCloseTimeoutSeconds *int32

+ Header *Header

+ Identity *string

+ Input []byte

+ Memo *Memo

+ RequestID *string

+ RetryPolicy *RetryPolicy

+ SearchAttributes *SearchAttributes

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ WorkflowID *string

+ WorkflowIDReusePolicy *WorkflowIDReusePolicy

+ WorkflowType *WorkflowType

+ type StartWorkflowExecutionResponse struct

+ RunID *string

+ type StickyExecutionAttributes struct

+ ScheduleToStartTimeoutSeconds *int32

+ WorkerTaskList *TaskList

+ type SupportedClientVersions struct

+ GoSdk *string

+ JavaSdk *string

+ type TaskIDBlock struct

+ EndID *int64

+ StartID *int64

+ type TaskList struct

+ Kind *TaskListKind

+ Name *string

+ type TaskListKind int32

+ const TaskListKindNormal

+ const TaskListKindSticky

+ type TaskListMetadata struct

+ MaxTasksPerSecond *float64

+ type TaskListPartitionMetadata struct

+ Key *string

+ OwnerHostName *string

+ type TaskListStatus struct

+ AckLevel *int64

+ BacklogCountHint *int64

+ RatePerSecond *float64

+ ReadLevel *int64

+ TaskIDBlock *TaskIDBlock

+ type TaskListType int32

+ const TaskListTypeActivity

+ const TaskListTypeDecision

+ type TerminateWorkflowExecutionRequest struct

+ Details []byte

+ Domain *string

+ Identity *string

+ Reason *string

+ WorkflowExecution *WorkflowExecution

+ type TimeoutType int32

+ const TimeoutTypeHeartbeat

+ const TimeoutTypeScheduleToClose

+ const TimeoutTypeScheduleToStart

+ const TimeoutTypeStartToClose

+ type TimerCanceledEventAttributes struct

+ DecisionTaskCompletedEventID *int64

+ Identity *string

+ StartedEventID *int64

+ TimerID *string

+ type TimerFiredEventAttributes struct

+ StartedEventID *int64

+ TimerID *string

+ type TimerStartedEventAttributes struct

+ DecisionTaskCompletedEventID *int64

+ StartToFireTimeoutSeconds *int64

+ TimerID *string

+ type TransientDecisionInfo struct

+ ScheduledEvent *HistoryEvent

+ StartedEvent *HistoryEvent

+ type UpdateDomainInfo struct

+ Data map[string]string

+ Description *string

+ OwnerEmail *string

+ type UpdateDomainRequest struct

+ Configuration *DomainConfiguration

+ DeleteBadBinary *string

+ FailoverTimeoutInSeconds *int32

+ Name *string

+ ReplicationConfiguration *DomainReplicationConfiguration

+ SecurityToken *string

+ UpdatedInfo *UpdateDomainInfo

+ type UpdateDomainResponse struct

+ Configuration *DomainConfiguration

+ DomainInfo *DomainInfo

+ FailoverVersion *int64

+ IsGlobalDomain *bool

+ ReplicationConfiguration *DomainReplicationConfiguration

+ type UpsertWorkflowSearchAttributesDecisionAttributes struct

+ SearchAttributes *SearchAttributes

+ type UpsertWorkflowSearchAttributesEventAttributes struct

+ DecisionTaskCompletedEventID *int64

+ SearchAttributes *SearchAttributes

+ type VersionHistories struct

+ CurrentVersionHistoryIndex *int32

+ Histories []*VersionHistory

+ type VersionHistory struct

+ BranchToken []byte

+ Items []*VersionHistoryItem

+ type VersionHistoryItem struct

+ EventID *int64

+ Version *int64

+ type WorkerVersionInfo struct

+ FeatureVersion *string

+ Impl *string

+ type WorkflowExecution struct

+ RunID *string

+ WorkflowID *string

+ type WorkflowExecutionAlreadyStartedError struct

+ Message *string

+ RunID *string

+ StartRequestID *string

+ func (err WorkflowExecutionAlreadyStartedError) Error() string

+ type WorkflowExecutionCancelRequestedEventAttributes struct

+ Cause *string

+ ExternalInitiatedEventID *int64

+ ExternalWorkflowExecution *WorkflowExecution

+ Identity *string

+ type WorkflowExecutionCanceledEventAttributes struct

+ DecisionTaskCompletedEventID *int64

+ Details []byte

+ type WorkflowExecutionCloseStatus int32

+ const WorkflowExecutionCloseStatusCanceled

+ const WorkflowExecutionCloseStatusCompleted

+ const WorkflowExecutionCloseStatusContinuedAsNew

+ const WorkflowExecutionCloseStatusFailed

+ const WorkflowExecutionCloseStatusTerminated

+ const WorkflowExecutionCloseStatusTimedOut

+ type WorkflowExecutionCompletedEventAttributes struct

+ DecisionTaskCompletedEventID *int64

+ Result []byte

+ type WorkflowExecutionConfiguration struct

+ ExecutionStartToCloseTimeoutSeconds *int32

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ type WorkflowExecutionContinuedAsNewEventAttributes struct

+ BackoffStartIntervalInSeconds *int32

+ DecisionTaskCompletedEventID *int64

+ ExecutionStartToCloseTimeoutSeconds *int32

+ FailureDetails []byte

+ FailureReason *string

+ Header *Header

+ Initiator *ContinueAsNewInitiator

+ Input []byte

+ LastCompletionResult []byte

+ Memo *Memo

+ NewExecutionRunID *string

+ SearchAttributes *SearchAttributes

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ WorkflowType *WorkflowType

+ type WorkflowExecutionFailedEventAttributes struct

+ DecisionTaskCompletedEventID *int64

+ Details []byte

+ Reason *string

+ type WorkflowExecutionFilter struct

+ RunID *string

+ WorkflowID *string

+ type WorkflowExecutionInfo struct

+ AutoResetPoints *ResetPoints

+ CloseStatus *WorkflowExecutionCloseStatus

+ CloseTime *int64

+ Execution *WorkflowExecution

+ ExecutionTime *int64

+ HistoryLength *int64

+ Memo *Memo

+ ParentDomainID *string

+ ParentExecution *WorkflowExecution

+ SearchAttributes *SearchAttributes

+ StartTime *int64

+ TaskList *string

+ Type *WorkflowType

+ type WorkflowExecutionSignaledEventAttributes struct

+ Identity *string

+ Input []byte

+ SignalName *string

+ type WorkflowExecutionStartedEventAttributes struct

+ Attempt *int32

+ ContinuedExecutionRunID *string

+ ContinuedFailureDetails []byte

+ ContinuedFailureReason *string

+ CronSchedule *string

+ ExecutionStartToCloseTimeoutSeconds *int32

+ ExpirationTimestamp *int64

+ FirstDecisionTaskBackoffSeconds *int32

+ FirstExecutionRunID *string

+ Header *Header

+ Identity *string

+ Initiator *ContinueAsNewInitiator

+ Input []byte

+ LastCompletionResult []byte

+ Memo *Memo

+ OriginalExecutionRunID *string

+ ParentInitiatedEventID *int64

+ ParentWorkflowDomain *string

+ ParentWorkflowExecution *WorkflowExecution

+ PrevAutoResetPoints *ResetPoints

+ RetryPolicy *RetryPolicy

+ SearchAttributes *SearchAttributes

+ TaskList *TaskList

+ TaskStartToCloseTimeoutSeconds *int32

+ WorkflowType *WorkflowType

+ type WorkflowExecutionTerminatedEventAttributes struct

+ Details []byte

+ Identity *string

+ Reason *string

+ type WorkflowExecutionTimedOutEventAttributes struct

+ TimeoutType *TimeoutType

+ type WorkflowIDReusePolicy int32

+ const WorkflowIDReusePolicyAllowDuplicate

+ const WorkflowIDReusePolicyAllowDuplicateFailedOnly

+ const WorkflowIDReusePolicyRejectDuplicate

+ const WorkflowIDReusePolicyTerminateIfRunning

+ type WorkflowQuery struct

+ QueryArgs []byte

+ QueryType *string

+ type WorkflowQueryResult struct

+ Answer []byte

+ ErrorMessage *string

+ ResultType *QueryResultType

+ type WorkflowType struct

+ Name *string

+ type WorkflowTypeFilter struct

+ Name *string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL