thrift

package

v1.2.15-prerelease09 Latest Latest Go to latest Published: Dec 13, 2024 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/uber/cadence

Documentation ¶

Index ¶

Variables
func DecodeStructFromBytes(data []byte, target ThriftObject) error
func EncodeToBytes(obj ThriftObject) ([]byte, error)
func FromAccessDeniedError(t *types.AccessDeniedError) *shared.AccessDeniedError
func FromActivityLocalDispatchInfo(t *types.ActivityLocalDispatchInfo) *shared.ActivityLocalDispatchInfo
func FromActivityLocalDispatchInfoMap(t map[string]*types.ActivityLocalDispatchInfo) map[string]*shared.ActivityLocalDispatchInfo
func FromActivityTaskCancelRequestedEventAttributes(t *types.ActivityTaskCancelRequestedEventAttributes) *shared.ActivityTaskCancelRequestedEventAttributes
func FromActivityTaskCanceledEventAttributes(t *types.ActivityTaskCanceledEventAttributes) *shared.ActivityTaskCanceledEventAttributes
func FromActivityTaskCompletedEventAttributes(t *types.ActivityTaskCompletedEventAttributes) *shared.ActivityTaskCompletedEventAttributes
func FromActivityTaskDispatchInfo(t *types.ActivityTaskDispatchInfo) *matching.ActivityTaskDispatchInfo
func FromActivityTaskFailedEventAttributes(t *types.ActivityTaskFailedEventAttributes) *shared.ActivityTaskFailedEventAttributes
func FromActivityTaskScheduledEventAttributes(t *types.ActivityTaskScheduledEventAttributes) *shared.ActivityTaskScheduledEventAttributes
func FromActivityTaskStartedEventAttributes(t *types.ActivityTaskStartedEventAttributes) *shared.ActivityTaskStartedEventAttributes
func FromActivityTaskTimedOutEventAttributes(t *types.ActivityTaskTimedOutEventAttributes) *shared.ActivityTaskTimedOutEventAttributes
func FromActivityType(t *types.ActivityType) *shared.ActivityType
func FromAdminAddSearchAttributeRequest(t *types.AddSearchAttributeRequest) *admin.AddSearchAttributeRequest
func FromAdminCloseShardRequest(t *types.CloseShardRequest) *shared.CloseShardRequest
func FromAdminDeleteWorkflowRequest(t *types.AdminDeleteWorkflowRequest) *admin.AdminDeleteWorkflowRequest
func FromAdminDeleteWorkflowResponse(t *types.AdminDeleteWorkflowResponse) *admin.AdminDeleteWorkflowResponse
func FromAdminDescribeClusterResponse(t *types.DescribeClusterResponse) *admin.DescribeClusterResponse
func FromAdminDescribeHistoryHostRequest(t *types.DescribeHistoryHostRequest) *shared.DescribeHistoryHostRequest
func FromAdminDescribeHistoryHostResponse(t *types.DescribeHistoryHostResponse) *shared.DescribeHistoryHostResponse
func FromAdminDescribeQueueRequest(t *types.DescribeQueueRequest) *shared.DescribeQueueRequest
func FromAdminDescribeQueueResponse(t *types.DescribeQueueResponse) *shared.DescribeQueueResponse
func FromAdminDescribeShardDistributionRequest(t *types.DescribeShardDistributionRequest) *shared.DescribeShardDistributionRequest
func FromAdminDescribeShardDistributionResponse(t *types.DescribeShardDistributionResponse) *shared.DescribeShardDistributionResponse
func FromAdminDescribeWorkflowExecutionRequest(t *types.AdminDescribeWorkflowExecutionRequest) *admin.DescribeWorkflowExecutionRequest
func FromAdminDescribeWorkflowExecutionResponse(t *types.AdminDescribeWorkflowExecutionResponse) *admin.DescribeWorkflowExecutionResponse
func FromAdminGetCrossClusterTasksRequest(t *types.GetCrossClusterTasksRequest) *shared.GetCrossClusterTasksRequest
func FromAdminGetCrossClusterTasksResponse(t *types.GetCrossClusterTasksResponse) *shared.GetCrossClusterTasksResponse
func FromAdminGetDLQReplicationMessagesRequest(t *types.GetDLQReplicationMessagesRequest) *replicator.GetDLQReplicationMessagesRequest
func FromAdminGetDLQReplicationMessagesResponse(t *types.GetDLQReplicationMessagesResponse) *replicator.GetDLQReplicationMessagesResponse
func FromAdminGetDomainAsyncWorkflowConfiguratonRequest(in *types.GetDomainAsyncWorkflowConfiguratonRequest) *admin.GetDomainAsyncWorkflowConfiguratonRequest
func FromAdminGetDomainAsyncWorkflowConfiguratonResponse(in *types.GetDomainAsyncWorkflowConfiguratonResponse) *admin.GetDomainAsyncWorkflowConfiguratonResponse
func FromAdminGetDomainIsolationGroupsRequest(t *types.GetDomainIsolationGroupsRequest) *admin.GetDomainIsolationGroupsRequest
func FromAdminGetDomainIsolationGroupsResponse(t *types.GetDomainIsolationGroupsResponse) *admin.GetDomainIsolationGroupsResponse
func FromAdminGetDomainReplicationMessagesRequest(t *types.GetDomainReplicationMessagesRequest) *replicator.GetDomainReplicationMessagesRequest
func FromAdminGetDomainReplicationMessagesResponse(t *types.GetDomainReplicationMessagesResponse) *replicator.GetDomainReplicationMessagesResponse
func FromAdminGetDynamicConfigRequest(t *types.GetDynamicConfigRequest) *admin.GetDynamicConfigRequest
func FromAdminGetDynamicConfigResponse(t *types.GetDynamicConfigResponse) *admin.GetDynamicConfigResponse
func FromAdminGetGlobalIsolationGroupsRequest(t *types.GetGlobalIsolationGroupsRequest) *admin.GetGlobalIsolationGroupsRequest
func FromAdminGetGlobalIsolationGroupsResponse(t *types.GetGlobalIsolationGroupsResponse) *admin.GetGlobalIsolationGroupsResponse
func FromAdminGetReplicationMessagesRequest(t *types.GetReplicationMessagesRequest) *replicator.GetReplicationMessagesRequest
func FromAdminGetReplicationMessagesResponse(t *types.GetReplicationMessagesResponse) *replicator.GetReplicationMessagesResponse
func FromAdminGetWorkflowExecutionRawHistoryV2Request(t *types.GetWorkflowExecutionRawHistoryV2Request) *admin.GetWorkflowExecutionRawHistoryV2Request
func FromAdminGetWorkflowExecutionRawHistoryV2Response(t *types.GetWorkflowExecutionRawHistoryV2Response) *admin.GetWorkflowExecutionRawHistoryV2Response
func FromAdminListDynamicConfigRequest(t *types.ListDynamicConfigRequest) *admin.ListDynamicConfigRequest
func FromAdminListDynamicConfigResponse(t *types.ListDynamicConfigResponse) *admin.ListDynamicConfigResponse
func FromAdminMaintainCorruptWorkflowRequest(t *types.AdminMaintainWorkflowRequest) *admin.AdminMaintainWorkflowRequest
func FromAdminMaintainCorruptWorkflowResponse(t *types.AdminMaintainWorkflowResponse) *admin.AdminMaintainWorkflowResponse
func FromAdminMergeDLQMessagesRequest(t *types.MergeDLQMessagesRequest) *replicator.MergeDLQMessagesRequest
func FromAdminMergeDLQMessagesResponse(t *types.MergeDLQMessagesResponse) *replicator.MergeDLQMessagesResponse
func FromAdminPurgeDLQMessagesRequest(t *types.PurgeDLQMessagesRequest) *replicator.PurgeDLQMessagesRequest
func FromAdminReadDLQMessagesRequest(t *types.ReadDLQMessagesRequest) *replicator.ReadDLQMessagesRequest
func FromAdminReadDLQMessagesResponse(t *types.ReadDLQMessagesResponse) *replicator.ReadDLQMessagesResponse
func FromAdminReapplyEventsRequest(t *types.ReapplyEventsRequest) *shared.ReapplyEventsRequest
func FromAdminRemoveTaskRequest(t *types.RemoveTaskRequest) *shared.RemoveTaskRequest
func FromAdminResendReplicationTasksRequest(t *types.ResendReplicationTasksRequest) *admin.ResendReplicationTasksRequest
func FromAdminResetQueueRequest(t *types.ResetQueueRequest) *shared.ResetQueueRequest
func FromAdminRespondCrossClusterTasksCompletedRequest(t *types.RespondCrossClusterTasksCompletedRequest) *shared.RespondCrossClusterTasksCompletedRequest
func FromAdminRespondCrossClusterTasksCompletedResponse(t *types.RespondCrossClusterTasksCompletedResponse) *shared.RespondCrossClusterTasksCompletedResponse
func FromAdminRestoreDynamicConfigRequest(t *types.RestoreDynamicConfigRequest) *admin.RestoreDynamicConfigRequest
func FromAdminUpdateDomainAsyncWorkflowConfiguratonRequest(in *types.UpdateDomainAsyncWorkflowConfiguratonRequest) *admin.UpdateDomainAsyncWorkflowConfiguratonRequest
func FromAdminUpdateDomainAsyncWorkflowConfiguratonResponse(in *types.UpdateDomainAsyncWorkflowConfiguratonResponse) *admin.UpdateDomainAsyncWorkflowConfiguratonResponse
func FromAdminUpdateDomainIsolationGroupsRequest(t *types.UpdateDomainIsolationGroupsRequest) *admin.UpdateDomainIsolationGroupsRequest
func FromAdminUpdateDomainIsolationGroupsResponse(t *types.UpdateDomainIsolationGroupsResponse) *admin.UpdateDomainIsolationGroupsResponse
func FromAdminUpdateDynamicConfigRequest(t *types.UpdateDynamicConfigRequest) *admin.UpdateDynamicConfigRequest
func FromAdminUpdateGlobalIsolationGroupsRequest(t *types.UpdateGlobalIsolationGroupsRequest) *admin.UpdateGlobalIsolationGroupsRequest
func FromAdminUpdateGlobalIsolationGroupsResponse(t *types.UpdateGlobalIsolationGroupsResponse) *admin.UpdateGlobalIsolationGroupsResponse
func FromAny(t *types.Any) *shared.Any
func FromApplyParentClosePolicyAttributes(t *types.ApplyParentClosePolicyAttributes) *shared.ApplyParentClosePolicyAttributes
func FromApplyParentClosePolicyRequest(t *types.ApplyParentClosePolicyRequest) *shared.ApplyParentClosePolicyRequest
func FromApplyParentClosePolicyRequestArray(t []*types.ApplyParentClosePolicyRequest) []*shared.ApplyParentClosePolicyRequest
func FromApplyParentClosePolicyResult(t *types.ApplyParentClosePolicyResult) *shared.ApplyParentClosePolicyResult
func FromApplyParentClosePolicyResultArray(t []*types.ApplyParentClosePolicyResult) []*shared.ApplyParentClosePolicyResult
func FromApplyParentClosePolicyStatus(t *types.ApplyParentClosePolicyStatus) *shared.ApplyParentClosePolicyStatus
func FromArchivalStatus(t *types.ArchivalStatus) *shared.ArchivalStatus
func FromAutoConfigHint(t *types.AutoConfigHint) *shared.AutoConfigHint
func FromBadBinaries(t *types.BadBinaries) *shared.BadBinaries
func FromBadBinaryInfo(t *types.BadBinaryInfo) *shared.BadBinaryInfo
func FromBadBinaryInfoMap(t map[string]*types.BadBinaryInfo) map[string]*shared.BadBinaryInfo
func FromBadRequestError(t *types.BadRequestError) *shared.BadRequestError
func FromCancelExternalWorkflowExecutionFailedCause(t *types.CancelExternalWorkflowExecutionFailedCause) *shared.CancelExternalWorkflowExecutionFailedCause
func FromCancelTimerDecisionAttributes(t *types.CancelTimerDecisionAttributes) *shared.CancelTimerDecisionAttributes
func FromCancelTimerFailedEventAttributes(t *types.CancelTimerFailedEventAttributes) *shared.CancelTimerFailedEventAttributes
func FromCancelWorkflowExecutionDecisionAttributes(t *types.CancelWorkflowExecutionDecisionAttributes) *shared.CancelWorkflowExecutionDecisionAttributes
func FromCancellationAlreadyRequestedError(t *types.CancellationAlreadyRequestedError) *shared.CancellationAlreadyRequestedError
func FromChildWorkflowExecutionCanceledEventAttributes(t *types.ChildWorkflowExecutionCanceledEventAttributes) *shared.ChildWorkflowExecutionCanceledEventAttributes
func FromChildWorkflowExecutionCompletedEventAttributes(t *types.ChildWorkflowExecutionCompletedEventAttributes) *shared.ChildWorkflowExecutionCompletedEventAttributes
func FromChildWorkflowExecutionFailedCause(t *types.ChildWorkflowExecutionFailedCause) *shared.ChildWorkflowExecutionFailedCause
func FromChildWorkflowExecutionFailedEventAttributes(t *types.ChildWorkflowExecutionFailedEventAttributes) *shared.ChildWorkflowExecutionFailedEventAttributes
func FromChildWorkflowExecutionStartedEventAttributes(t *types.ChildWorkflowExecutionStartedEventAttributes) *shared.ChildWorkflowExecutionStartedEventAttributes
func FromChildWorkflowExecutionTerminatedEventAttributes(t *types.ChildWorkflowExecutionTerminatedEventAttributes) *shared.ChildWorkflowExecutionTerminatedEventAttributes
func FromChildWorkflowExecutionTimedOutEventAttributes(t *types.ChildWorkflowExecutionTimedOutEventAttributes) *shared.ChildWorkflowExecutionTimedOutEventAttributes
func FromClientVersionNotSupportedError(t *types.ClientVersionNotSupportedError) *shared.ClientVersionNotSupportedError
func FromClusterReplicationConfiguration(t *types.ClusterReplicationConfiguration) *shared.ClusterReplicationConfiguration
func FromClusterReplicationConfigurationArray(t []*types.ClusterReplicationConfiguration) []*shared.ClusterReplicationConfiguration
func FromCompleteWorkflowExecutionDecisionAttributes(t *types.CompleteWorkflowExecutionDecisionAttributes) *shared.CompleteWorkflowExecutionDecisionAttributes
func FromContinueAsNewInitiator(t *types.ContinueAsNewInitiator) *shared.ContinueAsNewInitiator
func FromContinueAsNewWorkflowExecutionDecisionAttributes(t *types.ContinueAsNewWorkflowExecutionDecisionAttributes) *shared.ContinueAsNewWorkflowExecutionDecisionAttributes
func FromCountWorkflowExecutionsRequest(t *types.CountWorkflowExecutionsRequest) *shared.CountWorkflowExecutionsRequest
func FromCountWorkflowExecutionsResponse(t *types.CountWorkflowExecutionsResponse) *shared.CountWorkflowExecutionsResponse
func FromCrossClusterApplyParentClosePolicyRequestAttributes(t *types.CrossClusterApplyParentClosePolicyRequestAttributes) *shared.CrossClusterApplyParentClosePolicyRequestAttributes
func FromCrossClusterApplyParentClosePolicyResponseAttributes(t *types.CrossClusterApplyParentClosePolicyResponseAttributes) *shared.CrossClusterApplyParentClosePolicyResponseAttributes
func FromCrossClusterCancelExecutionRequestAttributes(t *types.CrossClusterCancelExecutionRequestAttributes) *shared.CrossClusterCancelExecutionRequestAttributes
func FromCrossClusterCancelExecutionResponseAttributes(t *types.CrossClusterCancelExecutionResponseAttributes) *shared.CrossClusterCancelExecutionResponseAttributes
func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *shared.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes
func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *shared.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes
func FromCrossClusterSignalExecutionRequestAttributes(t *types.CrossClusterSignalExecutionRequestAttributes) *shared.CrossClusterSignalExecutionRequestAttributes
func FromCrossClusterSignalExecutionResponseAttributes(t *types.CrossClusterSignalExecutionResponseAttributes) *shared.CrossClusterSignalExecutionResponseAttributes
func FromCrossClusterStartChildExecutionRequestAttributes(t *types.CrossClusterStartChildExecutionRequestAttributes) *shared.CrossClusterStartChildExecutionRequestAttributes
func FromCrossClusterStartChildExecutionResponseAttributes(t *types.CrossClusterStartChildExecutionResponseAttributes) *shared.CrossClusterStartChildExecutionResponseAttributes
func FromCrossClusterTaskFailedCause(t *types.CrossClusterTaskFailedCause) *shared.CrossClusterTaskFailedCause
func FromCrossClusterTaskInfo(t *types.CrossClusterTaskInfo) *shared.CrossClusterTaskInfo
func FromCrossClusterTaskRequest(t *types.CrossClusterTaskRequest) *shared.CrossClusterTaskRequest
func FromCrossClusterTaskRequestArray(t []*types.CrossClusterTaskRequest) []*shared.CrossClusterTaskRequest
func FromCrossClusterTaskRequestMap(t map[int32][]*types.CrossClusterTaskRequest) map[int32][]*shared.CrossClusterTaskRequest
func FromCrossClusterTaskResponse(t *types.CrossClusterTaskResponse) *shared.CrossClusterTaskResponse
func FromCrossClusterTaskResponseArray(t []*types.CrossClusterTaskResponse) []*shared.CrossClusterTaskResponse
func FromCrossClusterTaskType(t *types.CrossClusterTaskType) *shared.CrossClusterTaskType
func FromCurrentBranchChangedError(t *types.CurrentBranchChangedError) *shared.CurrentBranchChangedError
func FromDLQType(t *types.DLQType) *replicator.DLQType
func FromDataBlob(t *types.DataBlob) *shared.DataBlob
func FromDataBlobArray(t []*types.DataBlob) []*shared.DataBlob
func FromDecision(t *types.Decision) *shared.Decision
func FromDecisionArray(t []*types.Decision) []*shared.Decision
func FromDecisionTaskCompletedEventAttributes(t *types.DecisionTaskCompletedEventAttributes) *shared.DecisionTaskCompletedEventAttributes
func FromDecisionTaskFailedCause(t *types.DecisionTaskFailedCause) *shared.DecisionTaskFailedCause
func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttributes) *shared.DecisionTaskFailedEventAttributes
func FromDecisionTaskScheduledEventAttributes(t *types.DecisionTaskScheduledEventAttributes) *shared.DecisionTaskScheduledEventAttributes
func FromDecisionTaskStartedEventAttributes(t *types.DecisionTaskStartedEventAttributes) *shared.DecisionTaskStartedEventAttributes
func FromDecisionTaskTimedOutCause(t *types.DecisionTaskTimedOutCause) *shared.DecisionTaskTimedOutCause
func FromDecisionTaskTimedOutEventAttributes(t *types.DecisionTaskTimedOutEventAttributes) *shared.DecisionTaskTimedOutEventAttributes
func FromDecisionType(t *types.DecisionType) *shared.DecisionType
func FromDeprecateDomainRequest(t *types.DeprecateDomainRequest) *shared.DeprecateDomainRequest
func FromDescribeDomainRequest(t *types.DescribeDomainRequest) *shared.DescribeDomainRequest
func FromDescribeDomainResponse(t *types.DescribeDomainResponse) *shared.DescribeDomainResponse
func FromDescribeDomainResponseArray(t []*types.DescribeDomainResponse) []*shared.DescribeDomainResponse
func FromDescribeTaskListRequest(t *types.DescribeTaskListRequest) *shared.DescribeTaskListRequest
func FromDescribeTaskListResponse(t *types.DescribeTaskListResponse) *shared.DescribeTaskListResponse
func FromDescribeTaskListResponseMap(t map[string]*types.DescribeTaskListResponse) map[string]*shared.DescribeTaskListResponse
func FromDescribeWorkflowExecutionRequest(t *types.DescribeWorkflowExecutionRequest) *shared.DescribeWorkflowExecutionRequest
func FromDescribeWorkflowExecutionResponse(t *types.DescribeWorkflowExecutionResponse) *shared.DescribeWorkflowExecutionResponse
func FromDiagnoseWorkflowExecutionRequest(t *types.DiagnoseWorkflowExecutionRequest) *shared.DiagnoseWorkflowExecutionRequest
func FromDiagnoseWorkflowExecutionResponse(t *types.DiagnoseWorkflowExecutionResponse) *shared.DiagnoseWorkflowExecutionResponse
func FromDomainAlreadyExistsError(t *types.DomainAlreadyExistsError) *shared.DomainAlreadyExistsError
func FromDomainAsyncWorkflowConfiguraton(in *types.AsyncWorkflowConfiguration) *shared.AsyncWorkflowConfiguration
func FromDomainCacheInfo(t *types.DomainCacheInfo) *shared.DomainCacheInfo
func FromDomainConfiguration(t *types.DomainConfiguration) *shared.DomainConfiguration
func FromDomainFilter(t *types.DomainFilter) *history.DomainFilter
func FromDomainInfo(t *types.DomainInfo) *shared.DomainInfo
func FromDomainNotActiveError(t *types.DomainNotActiveError) *shared.DomainNotActiveError
func FromDomainOperation(t *types.DomainOperation) *replicator.DomainOperation
func FromDomainReplicationConfiguration(t *types.DomainReplicationConfiguration) *shared.DomainReplicationConfiguration
func FromDomainStatus(t *types.DomainStatus) *shared.DomainStatus
func FromDomainTaskAttributes(t *types.DomainTaskAttributes) *replicator.DomainTaskAttributes
func FromDynamicConfigBlob(t *types.DynamicConfigBlob) *config.DynamicConfigBlob
func FromDynamicConfigEntry(t *types.DynamicConfigEntry) *config.DynamicConfigEntry
func FromDynamicConfigEntryArray(t []*types.DynamicConfigEntry) []*config.DynamicConfigEntry
func FromDynamicConfigFilter(t *types.DynamicConfigFilter) *config.DynamicConfigFilter
func FromDynamicConfigFilterArray(t []*types.DynamicConfigFilter) []*config.DynamicConfigFilter
func FromDynamicConfigValue(t *types.DynamicConfigValue) *config.DynamicConfigValue
func FromDynamicConfigValueArray(t []*types.DynamicConfigValue) []*config.DynamicConfigValue
func FromEncodingType(t *types.EncodingType) *shared.EncodingType
func FromEntityNotExistsError(t *types.EntityNotExistsError) *shared.EntityNotExistsError
func FromError(err error) error
func FromEventAlreadyStartedError(t *types.EventAlreadyStartedError) *history.EventAlreadyStartedError
func FromEventType(t *types.EventType) *shared.EventType
func FromExternalWorkflowExecutionCancelRequestedEventAttributes(t *types.ExternalWorkflowExecutionCancelRequestedEventAttributes) *shared.ExternalWorkflowExecutionCancelRequestedEventAttributes
func FromExternalWorkflowExecutionSignaledEventAttributes(t *types.ExternalWorkflowExecutionSignaledEventAttributes) *shared.ExternalWorkflowExecutionSignaledEventAttributes
func FromFailWorkflowExecutionDecisionAttributes(t *types.FailWorkflowExecutionDecisionAttributes) *shared.FailWorkflowExecutionDecisionAttributes
func FromFailoverInfo(t *types.FailoverInfo) *shared.FailoverInfo
func FromFailoverMarkerAttributes(t *types.FailoverMarkerAttributes) *replicator.FailoverMarkerAttributes
func FromFailoverMarkerAttributesArray(t []*types.FailoverMarkerAttributes) []*replicator.FailoverMarkerAttributes
func FromFailoverMarkerToken(t *types.FailoverMarkerToken) *history.FailoverMarkerToken
func FromFailoverMarkerTokenArray(t []*types.FailoverMarkerToken) []*history.FailoverMarkerToken
func FromFailoverMarkers(t *types.FailoverMarkers) *replicator.FailoverMarkers
func FromFeatureNotEnabledError(t *types.FeatureNotEnabledError) *shared.FeatureNotEnabledError
func FromGetClusterInfoResponse(t *types.ClusterInfo) *shared.ClusterInfo
func FromGetFailoverInfoRequest(t *types.GetFailoverInfoRequest) *history.GetFailoverInfoRequest
func FromGetFailoverInfoResponse(t *types.GetFailoverInfoResponse) *history.GetFailoverInfoResponse
func FromGetSearchAttributesResponse(t *types.GetSearchAttributesResponse) *shared.GetSearchAttributesResponse
func FromGetTaskFailedCause(t *types.GetTaskFailedCause) *shared.GetTaskFailedCause
func FromGetTaskFailedCauseMap(t map[int32]types.GetTaskFailedCause) map[int32]shared.GetTaskFailedCause
func FromGetTaskListsByDomainRequest(t *types.GetTaskListsByDomainRequest) *shared.GetTaskListsByDomainRequest
func FromGetTaskListsByDomainResponse(t *types.GetTaskListsByDomainResponse) *shared.GetTaskListsByDomainResponse
func FromGetWorkflowExecutionHistoryRequest(t *types.GetWorkflowExecutionHistoryRequest) *shared.GetWorkflowExecutionHistoryRequest
func FromGetWorkflowExecutionHistoryResponse(t *types.GetWorkflowExecutionHistoryResponse) *shared.GetWorkflowExecutionHistoryResponse
func FromHeader(t *types.Header) *shared.Header
func FromHealthStatus(t *types.HealthStatus) *health.HealthStatus
func FromHistory(t *types.History) *shared.History
func FromHistoryArray(t []*types.History) []*shared.History
func FromHistoryBranch(t *types.HistoryBranch) *shared.HistoryBranch
func FromHistoryBranchRange(t *types.HistoryBranchRange) *shared.HistoryBranchRange
func FromHistoryBranchRangeArray(t []*types.HistoryBranchRange) []*shared.HistoryBranchRange
func FromHistoryDescribeMutableStateRequest(t *types.DescribeMutableStateRequest) *history.DescribeMutableStateRequest
func FromHistoryDescribeMutableStateResponse(t *types.DescribeMutableStateResponse) *history.DescribeMutableStateResponse
func FromHistoryDescribeWorkflowExecutionRequest(t *types.HistoryDescribeWorkflowExecutionRequest) *history.DescribeWorkflowExecutionRequest
func FromHistoryEvent(t *types.HistoryEvent) *shared.HistoryEvent
func FromHistoryEventArray(t []*types.HistoryEvent) []*shared.HistoryEvent
func FromHistoryEventFilterType(t *types.HistoryEventFilterType) *shared.HistoryEventFilterType
func FromHistoryGetMutableStateRequest(t *types.GetMutableStateRequest) *history.GetMutableStateRequest
func FromHistoryGetMutableStateResponse(t *types.GetMutableStateResponse) *history.GetMutableStateResponse
func FromHistoryNotifyFailoverMarkersRequest(t *types.NotifyFailoverMarkersRequest) *history.NotifyFailoverMarkersRequest
func FromHistoryPollMutableStateRequest(t *types.PollMutableStateRequest) *history.PollMutableStateRequest
func FromHistoryPollMutableStateResponse(t *types.PollMutableStateResponse) *history.PollMutableStateResponse
func FromHistoryQueryWorkflowRequest(t *types.HistoryQueryWorkflowRequest) *history.QueryWorkflowRequest
func FromHistoryQueryWorkflowResponse(t *types.HistoryQueryWorkflowResponse) *history.QueryWorkflowResponse
func FromHistoryRatelimitUpdateRequest(t *types.RatelimitUpdateRequest) *history.RatelimitUpdateRequest
func FromHistoryRatelimitUpdateResponse(t *types.RatelimitUpdateResponse) *history.RatelimitUpdateResponse
func FromHistoryReapplyEventsRequest(t *types.HistoryReapplyEventsRequest) *history.ReapplyEventsRequest
func FromHistoryRecordActivityTaskHeartbeatRequest(t *types.HistoryRecordActivityTaskHeartbeatRequest) *history.RecordActivityTaskHeartbeatRequest
func FromHistoryRefreshWorkflowTasksRequest(t *types.HistoryRefreshWorkflowTasksRequest) *history.RefreshWorkflowTasksRequest
func FromHistoryRemoveSignalMutableStateRequest(t *types.RemoveSignalMutableStateRequest) *history.RemoveSignalMutableStateRequest
func FromHistoryReplicateEventsV2Request(t *types.ReplicateEventsV2Request) *history.ReplicateEventsV2Request
func FromHistoryRequestCancelWorkflowExecutionRequest(t *types.HistoryRequestCancelWorkflowExecutionRequest) *history.RequestCancelWorkflowExecutionRequest
func FromHistoryResetStickyTaskListRequest(t *types.HistoryResetStickyTaskListRequest) *history.ResetStickyTaskListRequest
func FromHistoryResetStickyTaskListResponse(t *types.HistoryResetStickyTaskListResponse) *history.ResetStickyTaskListResponse
func FromHistoryResetWorkflowExecutionRequest(t *types.HistoryResetWorkflowExecutionRequest) *history.ResetWorkflowExecutionRequest
func FromHistoryRespondActivityTaskCanceledRequest(t *types.HistoryRespondActivityTaskCanceledRequest) *history.RespondActivityTaskCanceledRequest
func FromHistoryRespondActivityTaskCompletedRequest(t *types.HistoryRespondActivityTaskCompletedRequest) *history.RespondActivityTaskCompletedRequest
func FromHistoryRespondActivityTaskFailedRequest(t *types.HistoryRespondActivityTaskFailedRequest) *history.RespondActivityTaskFailedRequest
func FromHistoryRespondDecisionTaskCompletedRequest(t *types.HistoryRespondDecisionTaskCompletedRequest) *history.RespondDecisionTaskCompletedRequest
func FromHistoryRespondDecisionTaskCompletedResponse(t *types.HistoryRespondDecisionTaskCompletedResponse) *history.RespondDecisionTaskCompletedResponse
func FromHistoryRespondDecisionTaskFailedRequest(t *types.HistoryRespondDecisionTaskFailedRequest) *history.RespondDecisionTaskFailedRequest
func FromHistoryScheduleDecisionTaskRequest(t *types.ScheduleDecisionTaskRequest) *history.ScheduleDecisionTaskRequest
func FromHistorySignalWithStartWorkflowExecutionRequest(t *types.HistorySignalWithStartWorkflowExecutionRequest) *history.SignalWithStartWorkflowExecutionRequest
func FromHistorySignalWorkflowExecutionRequest(t *types.HistorySignalWorkflowExecutionRequest) *history.SignalWorkflowExecutionRequest
func FromHistoryStartWorkflowExecutionRequest(t *types.HistoryStartWorkflowExecutionRequest) *history.StartWorkflowExecutionRequest
func FromHistorySyncActivityRequest(t *types.SyncActivityRequest) *history.SyncActivityRequest
func FromHistorySyncShardStatusRequest(t *types.SyncShardStatusRequest) *history.SyncShardStatusRequest
func FromHistoryTaskV2Attributes(t *types.HistoryTaskV2Attributes) *replicator.HistoryTaskV2Attributes
func FromHistoryTerminateWorkflowExecutionRequest(t *types.HistoryTerminateWorkflowExecutionRequest) *history.TerminateWorkflowExecutionRequest
func FromHostInfo(t *types.HostInfo) *admin.HostInfo
func FromHostInfoArray(t []*types.HostInfo) []*admin.HostInfo
func FromIndexedValueType(t types.IndexedValueType) shared.IndexedValueType
func FromIndexedValueTypeMap(t map[string]types.IndexedValueType) map[string]shared.IndexedValueType
func FromInternalDataInconsistencyError(t *types.InternalDataInconsistencyError) *shared.InternalDataInconsistencyError
func FromInternalServiceError(t *types.InternalServiceError) *shared.InternalServiceError
func FromIsolationGroupConfig(in *types.IsolationGroupConfiguration) *shared.IsolationGroupConfiguration
func FromLimitExceededError(t *types.LimitExceededError) *shared.LimitExceededError
func FromListArchivedWorkflowExecutionsRequest(t *types.ListArchivedWorkflowExecutionsRequest) *shared.ListArchivedWorkflowExecutionsRequest
func FromListArchivedWorkflowExecutionsResponse(t *types.ListArchivedWorkflowExecutionsResponse) *shared.ListArchivedWorkflowExecutionsResponse
func FromListClosedWorkflowExecutionsRequest(t *types.ListClosedWorkflowExecutionsRequest) *shared.ListClosedWorkflowExecutionsRequest
func FromListClosedWorkflowExecutionsResponse(t *types.ListClosedWorkflowExecutionsResponse) *shared.ListClosedWorkflowExecutionsResponse
func FromListDomainsRequest(t *types.ListDomainsRequest) *shared.ListDomainsRequest
func FromListDomainsResponse(t *types.ListDomainsResponse) *shared.ListDomainsResponse
func FromListOpenWorkflowExecutionsRequest(t *types.ListOpenWorkflowExecutionsRequest) *shared.ListOpenWorkflowExecutionsRequest
func FromListOpenWorkflowExecutionsResponse(t *types.ListOpenWorkflowExecutionsResponse) *shared.ListOpenWorkflowExecutionsResponse
func FromListTaskListPartitionsRequest(t *types.ListTaskListPartitionsRequest) *shared.ListTaskListPartitionsRequest
func FromListTaskListPartitionsResponse(t *types.ListTaskListPartitionsResponse) *shared.ListTaskListPartitionsResponse
func FromListWorkflowExecutionsRequest(t *types.ListWorkflowExecutionsRequest) *shared.ListWorkflowExecutionsRequest
func FromListWorkflowExecutionsResponse(t *types.ListWorkflowExecutionsResponse) *shared.ListWorkflowExecutionsResponse
func FromMarkerRecordedEventAttributes(t *types.MarkerRecordedEventAttributes) *shared.MarkerRecordedEventAttributes
func FromMatchingAddActivityTaskRequest(t *types.AddActivityTaskRequest) *matching.AddActivityTaskRequest
func FromMatchingAddDecisionTaskRequest(t *types.AddDecisionTaskRequest) *matching.AddDecisionTaskRequest
func FromMatchingCancelOutstandingPollRequest(t *types.CancelOutstandingPollRequest) *matching.CancelOutstandingPollRequest
func FromMatchingDescribeTaskListRequest(t *types.MatchingDescribeTaskListRequest) *matching.DescribeTaskListRequest
func FromMatchingListTaskListPartitionsRequest(t *types.MatchingListTaskListPartitionsRequest) *matching.ListTaskListPartitionsRequest
func FromMatchingPollForActivityTaskRequest(t *types.MatchingPollForActivityTaskRequest) *matching.PollForActivityTaskRequest
func FromMatchingPollForActivityTaskResponse(t *types.MatchingPollForActivityTaskResponse) *shared.PollForActivityTaskResponse
func FromMatchingPollForDecisionTaskRequest(t *types.MatchingPollForDecisionTaskRequest) *matching.PollForDecisionTaskRequest
func FromMatchingPollForDecisionTaskResponse(t *types.MatchingPollForDecisionTaskResponse) *matching.PollForDecisionTaskResponse
func FromMatchingQueryWorkflowRequest(t *types.MatchingQueryWorkflowRequest) *matching.QueryWorkflowRequest
func FromMatchingRespondQueryTaskCompletedRequest(t *types.MatchingRespondQueryTaskCompletedRequest) *matching.RespondQueryTaskCompletedRequest
func FromMembershipInfo(t *types.MembershipInfo) *admin.MembershipInfo
func FromMemo(t *types.Memo) *shared.Memo
func FromParentClosePolicy(t *types.ParentClosePolicy) *shared.ParentClosePolicy
func FromParentExecutionInfo(t *types.ParentExecutionInfo) *history.ParentExecutionInfo
func FromPendingActivityInfo(t *types.PendingActivityInfo) *shared.PendingActivityInfo
func FromPendingActivityInfoArray(t []*types.PendingActivityInfo) []*shared.PendingActivityInfo
func FromPendingActivityState(t *types.PendingActivityState) *shared.PendingActivityState
func FromPendingChildExecutionInfo(t *types.PendingChildExecutionInfo) *shared.PendingChildExecutionInfo
func FromPendingChildExecutionInfoArray(t []*types.PendingChildExecutionInfo) []*shared.PendingChildExecutionInfo
func FromPendingDecisionInfo(t *types.PendingDecisionInfo) *shared.PendingDecisionInfo
func FromPendingDecisionState(t *types.PendingDecisionState) *shared.PendingDecisionState
func FromPersistenceFeature(t *types.PersistenceFeature) *admin.PersistenceFeature
func FromPersistenceFeatures(t []*types.PersistenceFeature) []*admin.PersistenceFeature
func FromPersistenceInfo(t *types.PersistenceInfo) *admin.PersistenceInfo
func FromPersistenceInfoMap(t map[string]*types.PersistenceInfo) map[string]*admin.PersistenceInfo
func FromPersistenceSetting(t *types.PersistenceSetting) *admin.PersistenceSetting
func FromPersistenceSettings(t []*types.PersistenceSetting) []*admin.PersistenceSetting
func FromPollForActivityTaskRequest(t *types.PollForActivityTaskRequest) *shared.PollForActivityTaskRequest
func FromPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *shared.PollForActivityTaskResponse
func FromPollForDecisionTaskRequest(t *types.PollForDecisionTaskRequest) *shared.PollForDecisionTaskRequest
func FromPollForDecisionTaskResponse(t *types.PollForDecisionTaskResponse) *shared.PollForDecisionTaskResponse
func FromPollerInfo(t *types.PollerInfo) *shared.PollerInfo
func FromPollerInfoArray(t []*types.PollerInfo) []*shared.PollerInfo
func FromProcessingQueueState(t *types.ProcessingQueueState) *history.ProcessingQueueState
func FromProcessingQueueStateArray(t []*types.ProcessingQueueState) []*history.ProcessingQueueState
func FromProcessingQueueStateArrayMap(t map[string][]*types.ProcessingQueueState) map[string][]*history.ProcessingQueueState
func FromProcessingQueueStates(t *types.ProcessingQueueStates) *history.ProcessingQueueStates
func FromQueryConsistencyLevel(t *types.QueryConsistencyLevel) *shared.QueryConsistencyLevel
func FromQueryFailedError(t *types.QueryFailedError) *shared.QueryFailedError
func FromQueryRejectCondition(t *types.QueryRejectCondition) *shared.QueryRejectCondition
func FromQueryRejected(t *types.QueryRejected) *shared.QueryRejected
func FromQueryResultType(t *types.QueryResultType) *shared.QueryResultType
func FromQueryTaskCompletedType(t *types.QueryTaskCompletedType) *shared.QueryTaskCompletedType
func FromQueryWorkflowRequest(t *types.QueryWorkflowRequest) *shared.QueryWorkflowRequest
func FromQueryWorkflowResponse(t *types.QueryWorkflowResponse) *shared.QueryWorkflowResponse
func FromRecordActivityTaskHeartbeatByIDRequest(t *types.RecordActivityTaskHeartbeatByIDRequest) *shared.RecordActivityTaskHeartbeatByIDRequest
func FromRecordActivityTaskHeartbeatRequest(t *types.RecordActivityTaskHeartbeatRequest) *shared.RecordActivityTaskHeartbeatRequest
func FromRecordActivityTaskHeartbeatResponse(t *types.RecordActivityTaskHeartbeatResponse) *shared.RecordActivityTaskHeartbeatResponse
func FromRecordActivityTaskStartedRequest(t *types.RecordActivityTaskStartedRequest) *history.RecordActivityTaskStartedRequest
func FromRecordActivityTaskStartedResponse(t *types.RecordActivityTaskStartedResponse) *history.RecordActivityTaskStartedResponse
func FromRecordChildExecutionCompletedRequest(t *types.RecordChildExecutionCompletedRequest) *history.RecordChildExecutionCompletedRequest
func FromRecordDecisionTaskStartedRequest(t *types.RecordDecisionTaskStartedRequest) *history.RecordDecisionTaskStartedRequest
func FromRecordDecisionTaskStartedResponse(t *types.RecordDecisionTaskStartedResponse) *history.RecordDecisionTaskStartedResponse
func FromRecordMarkerDecisionAttributes(t *types.RecordMarkerDecisionAttributes) *shared.RecordMarkerDecisionAttributes
func FromRefreshWorkflowTasksRequest(t *types.RefreshWorkflowTasksRequest) *shared.RefreshWorkflowTasksRequest
func FromRegisterDomainRequest(t *types.RegisterDomainRequest) *shared.RegisterDomainRequest
func FromRemoteSyncMatchedError(t *types.RemoteSyncMatchedError) *shared.RemoteSyncMatchedError
func FromReplicationMessages(t *types.ReplicationMessages) *replicator.ReplicationMessages
func FromReplicationMessagesMap(t map[int32]*types.ReplicationMessages) map[int32]*replicator.ReplicationMessages
func FromReplicationTask(t *types.ReplicationTask) *replicator.ReplicationTask
func FromReplicationTaskArray(t []*types.ReplicationTask) []*replicator.ReplicationTask
func FromReplicationTaskInfo(t *types.ReplicationTaskInfo) *replicator.ReplicationTaskInfo
func FromReplicationTaskInfoArray(t []*types.ReplicationTaskInfo) []*replicator.ReplicationTaskInfo
func FromReplicationTaskType(t *types.ReplicationTaskType) *replicator.ReplicationTaskType
func FromReplicationToken(t *types.ReplicationToken) *replicator.ReplicationToken
func FromReplicationTokenArray(t []*types.ReplicationToken) []*replicator.ReplicationToken
func FromRequestCancelActivityTaskDecisionAttributes(t *types.RequestCancelActivityTaskDecisionAttributes) *shared.RequestCancelActivityTaskDecisionAttributes
func FromRequestCancelActivityTaskFailedEventAttributes(t *types.RequestCancelActivityTaskFailedEventAttributes) *shared.RequestCancelActivityTaskFailedEventAttributes
func FromRequestCancelExternalWorkflowExecutionDecisionAttributes(t *types.RequestCancelExternalWorkflowExecutionDecisionAttributes) *shared.RequestCancelExternalWorkflowExecutionDecisionAttributes
func FromRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *shared.RequestCancelExternalWorkflowExecutionFailedEventAttributes
func FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *shared.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
func FromRequestCancelWorkflowExecutionRequest(t *types.RequestCancelWorkflowExecutionRequest) *shared.RequestCancelWorkflowExecutionRequest
func FromResetPointInfo(t *types.ResetPointInfo) *shared.ResetPointInfo
func FromResetPointInfoArray(t []*types.ResetPointInfo) []*shared.ResetPointInfo
func FromResetPoints(t *types.ResetPoints) *shared.ResetPoints
func FromResetStickyTaskListRequest(t *types.ResetStickyTaskListRequest) *shared.ResetStickyTaskListRequest
func FromResetStickyTaskListResponse(t *types.ResetStickyTaskListResponse) *shared.ResetStickyTaskListResponse
func FromResetWorkflowExecutionRequest(t *types.ResetWorkflowExecutionRequest) *shared.ResetWorkflowExecutionRequest
func FromResetWorkflowExecutionResponse(t *types.ResetWorkflowExecutionResponse) *shared.ResetWorkflowExecutionResponse
func FromRespondActivityTaskCanceledByIDRequest(t *types.RespondActivityTaskCanceledByIDRequest) *shared.RespondActivityTaskCanceledByIDRequest
func FromRespondActivityTaskCanceledRequest(t *types.RespondActivityTaskCanceledRequest) *shared.RespondActivityTaskCanceledRequest
func FromRespondActivityTaskCompletedByIDRequest(t *types.RespondActivityTaskCompletedByIDRequest) *shared.RespondActivityTaskCompletedByIDRequest
func FromRespondActivityTaskCompletedRequest(t *types.RespondActivityTaskCompletedRequest) *shared.RespondActivityTaskCompletedRequest
func FromRespondActivityTaskFailedByIDRequest(t *types.RespondActivityTaskFailedByIDRequest) *shared.RespondActivityTaskFailedByIDRequest
func FromRespondActivityTaskFailedRequest(t *types.RespondActivityTaskFailedRequest) *shared.RespondActivityTaskFailedRequest
func FromRespondDecisionTaskCompletedRequest(t *types.RespondDecisionTaskCompletedRequest) *shared.RespondDecisionTaskCompletedRequest
func FromRespondDecisionTaskCompletedResponse(t *types.RespondDecisionTaskCompletedResponse) *shared.RespondDecisionTaskCompletedResponse
func FromRespondDecisionTaskFailedRequest(t *types.RespondDecisionTaskFailedRequest) *shared.RespondDecisionTaskFailedRequest
func FromRespondQueryTaskCompletedRequest(t *types.RespondQueryTaskCompletedRequest) *shared.RespondQueryTaskCompletedRequest
func FromRestartWorkflowExecutionRequest(t *types.RestartWorkflowExecutionRequest) *shared.RestartWorkflowExecutionRequest
func FromRestartWorkflowExecutionResponse(t *types.RestartWorkflowExecutionResponse) *shared.RestartWorkflowExecutionResponse
func FromRetryPolicy(t *types.RetryPolicy) *shared.RetryPolicy
func FromRetryTaskV2Error(t *types.RetryTaskV2Error) *shared.RetryTaskV2Error
func FromRingInfo(t *types.RingInfo) *admin.RingInfo
func FromRingInfoArray(t []*types.RingInfo) []*admin.RingInfo
func FromScheduleActivityTaskDecisionAttributes(t *types.ScheduleActivityTaskDecisionAttributes) *shared.ScheduleActivityTaskDecisionAttributes
func FromSearchAttributes(t *types.SearchAttributes) *shared.SearchAttributes
func FromServiceBusyError(t *types.ServiceBusyError) *shared.ServiceBusyError
func FromShardOwnershipLostError(t *types.ShardOwnershipLostError) *history.ShardOwnershipLostError
func FromSignalExternalWorkflowExecutionDecisionAttributes(t *types.SignalExternalWorkflowExecutionDecisionAttributes) *shared.SignalExternalWorkflowExecutionDecisionAttributes
func FromSignalExternalWorkflowExecutionFailedCause(t *types.SignalExternalWorkflowExecutionFailedCause) *shared.SignalExternalWorkflowExecutionFailedCause
func FromSignalExternalWorkflowExecutionFailedEventAttributes(t *types.SignalExternalWorkflowExecutionFailedEventAttributes) *shared.SignalExternalWorkflowExecutionFailedEventAttributes
func FromSignalExternalWorkflowExecutionInitiatedEventAttributes(t *types.SignalExternalWorkflowExecutionInitiatedEventAttributes) *shared.SignalExternalWorkflowExecutionInitiatedEventAttributes
func FromSignalWithStartWorkflowExecutionAsyncRequest(t *types.SignalWithStartWorkflowExecutionAsyncRequest) *shared.SignalWithStartWorkflowExecutionAsyncRequest
func FromSignalWithStartWorkflowExecutionAsyncResponse(t *types.SignalWithStartWorkflowExecutionAsyncResponse) *shared.SignalWithStartWorkflowExecutionAsyncResponse
func FromSignalWithStartWorkflowExecutionRequest(t *types.SignalWithStartWorkflowExecutionRequest) *shared.SignalWithStartWorkflowExecutionRequest
func FromSignalWorkflowExecutionRequest(t *types.SignalWorkflowExecutionRequest) *shared.SignalWorkflowExecutionRequest
func FromStartChildWorkflowExecutionDecisionAttributes(t *types.StartChildWorkflowExecutionDecisionAttributes) *shared.StartChildWorkflowExecutionDecisionAttributes
func FromStartChildWorkflowExecutionFailedEventAttributes(t *types.StartChildWorkflowExecutionFailedEventAttributes) *shared.StartChildWorkflowExecutionFailedEventAttributes
func FromStartChildWorkflowExecutionInitiatedEventAttributes(t *types.StartChildWorkflowExecutionInitiatedEventAttributes) *shared.StartChildWorkflowExecutionInitiatedEventAttributes
func FromStartTimeFilter(t *types.StartTimeFilter) *shared.StartTimeFilter
func FromStartTimerDecisionAttributes(t *types.StartTimerDecisionAttributes) *shared.StartTimerDecisionAttributes
func FromStartWorkflowExecutionAsyncRequest(t *types.StartWorkflowExecutionAsyncRequest) *shared.StartWorkflowExecutionAsyncRequest
func FromStartWorkflowExecutionAsyncResponse(t *types.StartWorkflowExecutionAsyncResponse) *shared.StartWorkflowExecutionAsyncResponse
func FromStartWorkflowExecutionRequest(t *types.StartWorkflowExecutionRequest) *shared.StartWorkflowExecutionRequest
func FromStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *shared.StartWorkflowExecutionResponse
func FromStickyExecutionAttributes(t *types.StickyExecutionAttributes) *shared.StickyExecutionAttributes
func FromStickyWorkerUnavailableError(t *types.StickyWorkerUnavailableError) *shared.StickyWorkerUnavailableError
func FromSupportedClientVersions(t *types.SupportedClientVersions) *shared.SupportedClientVersions
func FromSyncActivityTaskAttributes(t *types.SyncActivityTaskAttributes) *replicator.SyncActivityTaskAttributes
func FromSyncShardStatus(t *types.SyncShardStatus) *replicator.SyncShardStatus
func FromSyncShardStatusTaskAttributes(t *types.SyncShardStatusTaskAttributes) *replicator.SyncShardStatusTaskAttributes
func FromTaskIDBlock(t *types.TaskIDBlock) *shared.TaskIDBlock
func FromTaskList(t *types.TaskList) *shared.TaskList
func FromTaskListKind(t *types.TaskListKind) *shared.TaskListKind
func FromTaskListMetadata(t *types.TaskListMetadata) *shared.TaskListMetadata
func FromTaskListNotOwnedByHostError(t *cadence_errors.TaskListNotOwnedByHostError) *shared.TaskListNotOwnedByHostError
func FromTaskListPartitionMetadata(t *types.TaskListPartitionMetadata) *shared.TaskListPartitionMetadata
func FromTaskListPartitionMetadataArray(t []*types.TaskListPartitionMetadata) []*shared.TaskListPartitionMetadata
func FromTaskListStatus(t *types.TaskListStatus) *shared.TaskListStatus
func FromTaskListType(t *types.TaskListType) *shared.TaskListType
func FromTaskSource(t *types.TaskSource) *matching.TaskSource
func FromTerminateWorkflowExecutionRequest(t *types.TerminateWorkflowExecutionRequest) *shared.TerminateWorkflowExecutionRequest
func FromTimeoutType(t *types.TimeoutType) *shared.TimeoutType
func FromTimerCanceledEventAttributes(t *types.TimerCanceledEventAttributes) *shared.TimerCanceledEventAttributes
func FromTimerFiredEventAttributes(t *types.TimerFiredEventAttributes) *shared.TimerFiredEventAttributes
func FromTimerStartedEventAttributes(t *types.TimerStartedEventAttributes) *shared.TimerStartedEventAttributes
func FromTransientDecisionInfo(t *types.TransientDecisionInfo) *shared.TransientDecisionInfo
func FromUpdateDomainRequest(t *types.UpdateDomainRequest) *shared.UpdateDomainRequest
func FromUpdateDomainResponse(t *types.UpdateDomainResponse) *shared.UpdateDomainResponse
func FromUpsertWorkflowSearchAttributesDecisionAttributes(t *types.UpsertWorkflowSearchAttributesDecisionAttributes) *shared.UpsertWorkflowSearchAttributesDecisionAttributes
func FromUpsertWorkflowSearchAttributesEventAttributes(t *types.UpsertWorkflowSearchAttributesEventAttributes) *shared.UpsertWorkflowSearchAttributesEventAttributes
func FromVersionHistories(t *types.VersionHistories) *shared.VersionHistories
func FromVersionHistory(t *types.VersionHistory) *shared.VersionHistory
func FromVersionHistoryArray(t []*types.VersionHistory) []*shared.VersionHistory
func FromVersionHistoryItem(t *types.VersionHistoryItem) *shared.VersionHistoryItem
func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*shared.VersionHistoryItem
func FromWorkerVersionInfo(t *types.WorkerVersionInfo) *shared.WorkerVersionInfo
func FromWorkflowExecution(t *types.WorkflowExecution) *shared.WorkflowExecution
func FromWorkflowExecutionAlreadyCompletedError(t *types.WorkflowExecutionAlreadyCompletedError) *shared.WorkflowExecutionAlreadyCompletedError
func FromWorkflowExecutionAlreadyStartedError(t *types.WorkflowExecutionAlreadyStartedError) *shared.WorkflowExecutionAlreadyStartedError
func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecutionCancelRequestedEventAttributes) *shared.WorkflowExecutionCancelRequestedEventAttributes
func FromWorkflowExecutionCanceledEventAttributes(t *types.WorkflowExecutionCanceledEventAttributes) *shared.WorkflowExecutionCanceledEventAttributes
func FromWorkflowExecutionCloseStatus(t *types.WorkflowExecutionCloseStatus) *shared.WorkflowExecutionCloseStatus
func FromWorkflowExecutionCompletedEventAttributes(t *types.WorkflowExecutionCompletedEventAttributes) *shared.WorkflowExecutionCompletedEventAttributes
func FromWorkflowExecutionConfiguration(t *types.WorkflowExecutionConfiguration) *shared.WorkflowExecutionConfiguration
func FromWorkflowExecutionContinuedAsNewEventAttributes(t *types.WorkflowExecutionContinuedAsNewEventAttributes) *shared.WorkflowExecutionContinuedAsNewEventAttributes
func FromWorkflowExecutionFailedEventAttributes(t *types.WorkflowExecutionFailedEventAttributes) *shared.WorkflowExecutionFailedEventAttributes
func FromWorkflowExecutionFilter(t *types.WorkflowExecutionFilter) *shared.WorkflowExecutionFilter
func FromWorkflowExecutionInfo(t *types.WorkflowExecutionInfo) *shared.WorkflowExecutionInfo
func FromWorkflowExecutionInfoArray(t []*types.WorkflowExecutionInfo) []*shared.WorkflowExecutionInfo
func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSignaledEventAttributes) *shared.WorkflowExecutionSignaledEventAttributes
func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStartedEventAttributes) *shared.WorkflowExecutionStartedEventAttributes
func FromWorkflowExecutionTerminatedEventAttributes(t *types.WorkflowExecutionTerminatedEventAttributes) *shared.WorkflowExecutionTerminatedEventAttributes
func FromWorkflowExecutionTimedOutEventAttributes(t *types.WorkflowExecutionTimedOutEventAttributes) *shared.WorkflowExecutionTimedOutEventAttributes
func FromWorkflowIDReusePolicy(t *types.WorkflowIDReusePolicy) *shared.WorkflowIdReusePolicy
func FromWorkflowQuery(t *types.WorkflowQuery) *shared.WorkflowQuery
func FromWorkflowQueryMap(t map[string]*types.WorkflowQuery) map[string]*shared.WorkflowQuery
func FromWorkflowQueryResult(t *types.WorkflowQueryResult) *shared.WorkflowQueryResult
func FromWorkflowQueryResultMap(t map[string]*types.WorkflowQueryResult) map[string]*shared.WorkflowQueryResult
func FromWorkflowType(t *types.WorkflowType) *shared.WorkflowType
func FromWorkflowTypeFilter(t *types.WorkflowTypeFilter) *shared.WorkflowTypeFilter
func ToAccessDeniedError(t *shared.AccessDeniedError) *types.AccessDeniedError
func ToActivityLocalDispatchInfo(t *shared.ActivityLocalDispatchInfo) *types.ActivityLocalDispatchInfo
func ToActivityLocalDispatchInfoMap(t map[string]*shared.ActivityLocalDispatchInfo) map[string]*types.ActivityLocalDispatchInfo
func ToActivityTaskCancelRequestedEventAttributes(t *shared.ActivityTaskCancelRequestedEventAttributes) *types.ActivityTaskCancelRequestedEventAttributes
func ToActivityTaskCanceledEventAttributes(t *shared.ActivityTaskCanceledEventAttributes) *types.ActivityTaskCanceledEventAttributes
func ToActivityTaskCompletedEventAttributes(t *shared.ActivityTaskCompletedEventAttributes) *types.ActivityTaskCompletedEventAttributes
func ToActivityTaskDispatchInfo(t *matching.ActivityTaskDispatchInfo) *types.ActivityTaskDispatchInfo
func ToActivityTaskFailedEventAttributes(t *shared.ActivityTaskFailedEventAttributes) *types.ActivityTaskFailedEventAttributes
func ToActivityTaskScheduledEventAttributes(t *shared.ActivityTaskScheduledEventAttributes) *types.ActivityTaskScheduledEventAttributes
func ToActivityTaskStartedEventAttributes(t *shared.ActivityTaskStartedEventAttributes) *types.ActivityTaskStartedEventAttributes
func ToActivityTaskTimedOutEventAttributes(t *shared.ActivityTaskTimedOutEventAttributes) *types.ActivityTaskTimedOutEventAttributes
func ToActivityType(t *shared.ActivityType) *types.ActivityType
func ToAdminAddSearchAttributeRequest(t *admin.AddSearchAttributeRequest) *types.AddSearchAttributeRequest
func ToAdminCloseShardRequest(t *shared.CloseShardRequest) *types.CloseShardRequest
func ToAdminDeleteWorkflowRequest(t *admin.AdminDeleteWorkflowRequest) *types.AdminDeleteWorkflowRequest
func ToAdminDeleteWorkflowResponse(t *admin.AdminDeleteWorkflowResponse) *types.AdminDeleteWorkflowResponse
func ToAdminDescribeClusterResponse(t *admin.DescribeClusterResponse) *types.DescribeClusterResponse
func ToAdminDescribeHistoryHostRequest(t *shared.DescribeHistoryHostRequest) *types.DescribeHistoryHostRequest
func ToAdminDescribeHistoryHostResponse(t *shared.DescribeHistoryHostResponse) *types.DescribeHistoryHostResponse
func ToAdminDescribeQueueRequest(t *shared.DescribeQueueRequest) *types.DescribeQueueRequest
func ToAdminDescribeQueueResponse(t *shared.DescribeQueueResponse) *types.DescribeQueueResponse
func ToAdminDescribeShardDistributionRequest(t *shared.DescribeShardDistributionRequest) *types.DescribeShardDistributionRequest
func ToAdminDescribeShardDistributionResponse(t *shared.DescribeShardDistributionResponse) *types.DescribeShardDistributionResponse
func ToAdminDescribeWorkflowExecutionRequest(t *admin.DescribeWorkflowExecutionRequest) *types.AdminDescribeWorkflowExecutionRequest
func ToAdminDescribeWorkflowExecutionResponse(t *admin.DescribeWorkflowExecutionResponse) *types.AdminDescribeWorkflowExecutionResponse
func ToAdminGetCrossClusterTasksRequest(t *shared.GetCrossClusterTasksRequest) *types.GetCrossClusterTasksRequest
func ToAdminGetCrossClusterTasksResponse(t *shared.GetCrossClusterTasksResponse) *types.GetCrossClusterTasksResponse
func ToAdminGetDLQReplicationMessagesRequest(t *replicator.GetDLQReplicationMessagesRequest) *types.GetDLQReplicationMessagesRequest
func ToAdminGetDLQReplicationMessagesResponse(t *replicator.GetDLQReplicationMessagesResponse) *types.GetDLQReplicationMessagesResponse
func ToAdminGetDomainAsyncWorkflowConfiguratonRequest(in *admin.GetDomainAsyncWorkflowConfiguratonRequest) *types.GetDomainAsyncWorkflowConfiguratonRequest
func ToAdminGetDomainAsyncWorkflowConfiguratonResponse(in *admin.GetDomainAsyncWorkflowConfiguratonResponse) *types.GetDomainAsyncWorkflowConfiguratonResponse
func ToAdminGetDomainIsolationGroupsRequest(t *admin.GetDomainIsolationGroupsRequest) *types.GetDomainIsolationGroupsRequest
func ToAdminGetDomainIsolationGroupsResponse(t *admin.GetDomainIsolationGroupsResponse) *types.GetDomainIsolationGroupsResponse
func ToAdminGetDomainReplicationMessagesRequest(t *replicator.GetDomainReplicationMessagesRequest) *types.GetDomainReplicationMessagesRequest
func ToAdminGetDomainReplicationMessagesResponse(t *replicator.GetDomainReplicationMessagesResponse) *types.GetDomainReplicationMessagesResponse
func ToAdminGetDynamicConfigRequest(t *admin.GetDynamicConfigRequest) *types.GetDynamicConfigRequest
func ToAdminGetDynamicConfigResponse(t *admin.GetDynamicConfigResponse) *types.GetDynamicConfigResponse
func ToAdminGetGlobalIsolationGroupsRequest(t *admin.GetGlobalIsolationGroupsRequest) *types.GetGlobalIsolationGroupsRequest
func ToAdminGetGlobalIsolationGroupsResponse(t *admin.GetGlobalIsolationGroupsResponse) *types.GetGlobalIsolationGroupsResponse
func ToAdminGetReplicationMessagesRequest(t *replicator.GetReplicationMessagesRequest) *types.GetReplicationMessagesRequest
func ToAdminGetReplicationMessagesResponse(t *replicator.GetReplicationMessagesResponse) *types.GetReplicationMessagesResponse
func ToAdminGetWorkflowExecutionRawHistoryV2Request(t *admin.GetWorkflowExecutionRawHistoryV2Request) *types.GetWorkflowExecutionRawHistoryV2Request
func ToAdminGetWorkflowExecutionRawHistoryV2Response(t *admin.GetWorkflowExecutionRawHistoryV2Response) *types.GetWorkflowExecutionRawHistoryV2Response
func ToAdminListDynamicConfigRequest(t *admin.ListDynamicConfigRequest) *types.ListDynamicConfigRequest
func ToAdminListDynamicConfigResponse(t *admin.ListDynamicConfigResponse) *types.ListDynamicConfigResponse
func ToAdminMaintainCorruptWorkflowRequest(t *admin.AdminMaintainWorkflowRequest) *types.AdminMaintainWorkflowRequest
func ToAdminMaintainCorruptWorkflowResponse(t *admin.AdminMaintainWorkflowResponse) *types.AdminMaintainWorkflowResponse
func ToAdminMergeDLQMessagesRequest(t *replicator.MergeDLQMessagesRequest) *types.MergeDLQMessagesRequest
func ToAdminMergeDLQMessagesResponse(t *replicator.MergeDLQMessagesResponse) *types.MergeDLQMessagesResponse
func ToAdminPurgeDLQMessagesRequest(t *replicator.PurgeDLQMessagesRequest) *types.PurgeDLQMessagesRequest
func ToAdminReadDLQMessagesRequest(t *replicator.ReadDLQMessagesRequest) *types.ReadDLQMessagesRequest
func ToAdminReadDLQMessagesResponse(t *replicator.ReadDLQMessagesResponse) *types.ReadDLQMessagesResponse
func ToAdminReapplyEventsRequest(t *shared.ReapplyEventsRequest) *types.ReapplyEventsRequest
func ToAdminRemoveTaskRequest(t *shared.RemoveTaskRequest) *types.RemoveTaskRequest
func ToAdminResendReplicationTasksRequest(t *admin.ResendReplicationTasksRequest) *types.ResendReplicationTasksRequest
func ToAdminResetQueueRequest(t *shared.ResetQueueRequest) *types.ResetQueueRequest
func ToAdminRespondCrossClusterTasksCompletedRequest(t *shared.RespondCrossClusterTasksCompletedRequest) *types.RespondCrossClusterTasksCompletedRequest
func ToAdminRespondCrossClusterTasksCompletedResponse(t *shared.RespondCrossClusterTasksCompletedResponse) *types.RespondCrossClusterTasksCompletedResponse
func ToAdminRestoreDynamicConfigRequest(t *admin.RestoreDynamicConfigRequest) *types.RestoreDynamicConfigRequest
func ToAdminUpdateDomainAsyncWorkflowConfiguratonRequest(in *admin.UpdateDomainAsyncWorkflowConfiguratonRequest) *types.UpdateDomainAsyncWorkflowConfiguratonRequest
func ToAdminUpdateDomainAsyncWorkflowConfiguratonResponse(in *admin.UpdateDomainAsyncWorkflowConfiguratonResponse) *types.UpdateDomainAsyncWorkflowConfiguratonResponse
func ToAdminUpdateDomainIsolationGroupsRequest(t *admin.UpdateDomainIsolationGroupsRequest) *types.UpdateDomainIsolationGroupsRequest
func ToAdminUpdateDomainIsolationGroupsResponse(t *admin.UpdateDomainIsolationGroupsResponse) *types.UpdateDomainIsolationGroupsResponse
func ToAdminUpdateDynamicConfigRequest(t *admin.UpdateDynamicConfigRequest) *types.UpdateDynamicConfigRequest
func ToAdminUpdateGlobalIsolationGroupsRequest(t *admin.UpdateGlobalIsolationGroupsRequest) *types.UpdateGlobalIsolationGroupsRequest
func ToAdminUpdateGlobalIsolationGroupsResponse(t *admin.UpdateGlobalIsolationGroupsResponse) *types.UpdateGlobalIsolationGroupsResponse
func ToAny(t *shared.Any) *types.Any
func ToApplyParentClosePolicyAttributes(t *shared.ApplyParentClosePolicyAttributes) *types.ApplyParentClosePolicyAttributes
func ToApplyParentClosePolicyRequest(t *shared.ApplyParentClosePolicyRequest) *types.ApplyParentClosePolicyRequest
func ToApplyParentClosePolicyRequestArray(t []*shared.ApplyParentClosePolicyRequest) []*types.ApplyParentClosePolicyRequest
func ToApplyParentClosePolicyResult(t *shared.ApplyParentClosePolicyResult) *types.ApplyParentClosePolicyResult
func ToApplyParentClosePolicyResultArray(t []*shared.ApplyParentClosePolicyResult) []*types.ApplyParentClosePolicyResult
func ToApplyParentClosePolicyStatus(t *shared.ApplyParentClosePolicyStatus) *types.ApplyParentClosePolicyStatus
func ToArchivalStatus(t *shared.ArchivalStatus) *types.ArchivalStatus
func ToAutoConfigHint(t *shared.AutoConfigHint) *types.AutoConfigHint
func ToBadBinaries(t *shared.BadBinaries) *types.BadBinaries
func ToBadBinaryInfo(t *shared.BadBinaryInfo) *types.BadBinaryInfo
func ToBadBinaryInfoMap(t map[string]*shared.BadBinaryInfo) map[string]*types.BadBinaryInfo
func ToBadRequestError(t *shared.BadRequestError) *types.BadRequestError
func ToCancelExternalWorkflowExecutionFailedCause(t *shared.CancelExternalWorkflowExecutionFailedCause) *types.CancelExternalWorkflowExecutionFailedCause
func ToCancelTimerDecisionAttributes(t *shared.CancelTimerDecisionAttributes) *types.CancelTimerDecisionAttributes
func ToCancelTimerFailedEventAttributes(t *shared.CancelTimerFailedEventAttributes) *types.CancelTimerFailedEventAttributes
func ToCancelWorkflowExecutionDecisionAttributes(t *shared.CancelWorkflowExecutionDecisionAttributes) *types.CancelWorkflowExecutionDecisionAttributes
func ToCancellationAlreadyRequestedError(t *shared.CancellationAlreadyRequestedError) *types.CancellationAlreadyRequestedError
func ToChildWorkflowExecutionCanceledEventAttributes(t *shared.ChildWorkflowExecutionCanceledEventAttributes) *types.ChildWorkflowExecutionCanceledEventAttributes
func ToChildWorkflowExecutionCompletedEventAttributes(t *shared.ChildWorkflowExecutionCompletedEventAttributes) *types.ChildWorkflowExecutionCompletedEventAttributes
func ToChildWorkflowExecutionFailedCause(t *shared.ChildWorkflowExecutionFailedCause) *types.ChildWorkflowExecutionFailedCause
func ToChildWorkflowExecutionFailedEventAttributes(t *shared.ChildWorkflowExecutionFailedEventAttributes) *types.ChildWorkflowExecutionFailedEventAttributes
func ToChildWorkflowExecutionStartedEventAttributes(t *shared.ChildWorkflowExecutionStartedEventAttributes) *types.ChildWorkflowExecutionStartedEventAttributes
func ToChildWorkflowExecutionTerminatedEventAttributes(t *shared.ChildWorkflowExecutionTerminatedEventAttributes) *types.ChildWorkflowExecutionTerminatedEventAttributes
func ToChildWorkflowExecutionTimedOutEventAttributes(t *shared.ChildWorkflowExecutionTimedOutEventAttributes) *types.ChildWorkflowExecutionTimedOutEventAttributes
func ToClientVersionNotSupportedError(t *shared.ClientVersionNotSupportedError) *types.ClientVersionNotSupportedError
func ToClusterReplicationConfiguration(t *shared.ClusterReplicationConfiguration) *types.ClusterReplicationConfiguration
func ToClusterReplicationConfigurationArray(t []*shared.ClusterReplicationConfiguration) []*types.ClusterReplicationConfiguration
func ToCompleteWorkflowExecutionDecisionAttributes(t *shared.CompleteWorkflowExecutionDecisionAttributes) *types.CompleteWorkflowExecutionDecisionAttributes
func ToContinueAsNewInitiator(t *shared.ContinueAsNewInitiator) *types.ContinueAsNewInitiator
func ToContinueAsNewWorkflowExecutionDecisionAttributes(t *shared.ContinueAsNewWorkflowExecutionDecisionAttributes) *types.ContinueAsNewWorkflowExecutionDecisionAttributes
func ToCountWorkflowExecutionsRequest(t *shared.CountWorkflowExecutionsRequest) *types.CountWorkflowExecutionsRequest
func ToCountWorkflowExecutionsResponse(t *shared.CountWorkflowExecutionsResponse) *types.CountWorkflowExecutionsResponse
func ToCrossClusterApplyParentClosePolicyRequestAttributes(t *shared.CrossClusterApplyParentClosePolicyRequestAttributes) *types.CrossClusterApplyParentClosePolicyRequestAttributes
func ToCrossClusterApplyParentClosePolicyResponseAttributes(t *shared.CrossClusterApplyParentClosePolicyResponseAttributes) *types.CrossClusterApplyParentClosePolicyResponseAttributes
func ToCrossClusterCancelExecutionRequestAttributes(t *shared.CrossClusterCancelExecutionRequestAttributes) *types.CrossClusterCancelExecutionRequestAttributes
func ToCrossClusterCancelExecutionResponseAttributes(t *shared.CrossClusterCancelExecutionResponseAttributes) *types.CrossClusterCancelExecutionResponseAttributes
func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *shared.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes
func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *shared.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes
func ToCrossClusterSignalExecutionRequestAttributes(t *shared.CrossClusterSignalExecutionRequestAttributes) *types.CrossClusterSignalExecutionRequestAttributes
func ToCrossClusterSignalExecutionResponseAttributes(t *shared.CrossClusterSignalExecutionResponseAttributes) *types.CrossClusterSignalExecutionResponseAttributes
func ToCrossClusterStartChildExecutionRequestAttributes(t *shared.CrossClusterStartChildExecutionRequestAttributes) *types.CrossClusterStartChildExecutionRequestAttributes
func ToCrossClusterStartChildExecutionResponseAttributes(t *shared.CrossClusterStartChildExecutionResponseAttributes) *types.CrossClusterStartChildExecutionResponseAttributes
func ToCrossClusterTaskFailedCause(t *shared.CrossClusterTaskFailedCause) *types.CrossClusterTaskFailedCause
func ToCrossClusterTaskInfo(t *shared.CrossClusterTaskInfo) *types.CrossClusterTaskInfo
func ToCrossClusterTaskRequest(t *shared.CrossClusterTaskRequest) *types.CrossClusterTaskRequest
func ToCrossClusterTaskRequestArray(t []*shared.CrossClusterTaskRequest) []*types.CrossClusterTaskRequest
func ToCrossClusterTaskRequestMap(t map[int32][]*shared.CrossClusterTaskRequest) map[int32][]*types.CrossClusterTaskRequest
func ToCrossClusterTaskResponse(t *shared.CrossClusterTaskResponse) *types.CrossClusterTaskResponse
func ToCrossClusterTaskResponseArray(t []*shared.CrossClusterTaskResponse) []*types.CrossClusterTaskResponse
func ToCrossClusterTaskType(t *shared.CrossClusterTaskType) *types.CrossClusterTaskType
func ToCurrentBranchChangedError(t *shared.CurrentBranchChangedError) *types.CurrentBranchChangedError
func ToDLQType(t *replicator.DLQType) *types.DLQType
func ToDataBlob(t *shared.DataBlob) *types.DataBlob
func ToDataBlobArray(t []*shared.DataBlob) []*types.DataBlob
func ToDecision(t *shared.Decision) *types.Decision
func ToDecisionArray(t []*shared.Decision) []*types.Decision
func ToDecisionTaskCompletedEventAttributes(t *shared.DecisionTaskCompletedEventAttributes) *types.DecisionTaskCompletedEventAttributes
func ToDecisionTaskFailedCause(t *shared.DecisionTaskFailedCause) *types.DecisionTaskFailedCause
func ToDecisionTaskFailedEventAttributes(t *shared.DecisionTaskFailedEventAttributes) *types.DecisionTaskFailedEventAttributes
func ToDecisionTaskScheduledEventAttributes(t *shared.DecisionTaskScheduledEventAttributes) *types.DecisionTaskScheduledEventAttributes
func ToDecisionTaskStartedEventAttributes(t *shared.DecisionTaskStartedEventAttributes) *types.DecisionTaskStartedEventAttributes
func ToDecisionTaskTimedOutCause(t *shared.DecisionTaskTimedOutCause) *types.DecisionTaskTimedOutCause
func ToDecisionTaskTimedOutEventAttributes(t *shared.DecisionTaskTimedOutEventAttributes) *types.DecisionTaskTimedOutEventAttributes
func ToDecisionType(t *shared.DecisionType) *types.DecisionType
func ToDeprecateDomainRequest(t *shared.DeprecateDomainRequest) *types.DeprecateDomainRequest
func ToDescribeDomainRequest(t *shared.DescribeDomainRequest) *types.DescribeDomainRequest
func ToDescribeDomainResponse(t *shared.DescribeDomainResponse) *types.DescribeDomainResponse
func ToDescribeDomainResponseArray(t []*shared.DescribeDomainResponse) []*types.DescribeDomainResponse
func ToDescribeTaskListRequest(t *shared.DescribeTaskListRequest) *types.DescribeTaskListRequest
func ToDescribeTaskListResponse(t *shared.DescribeTaskListResponse) *types.DescribeTaskListResponse
func ToDescribeTaskListResponseMap(t map[string]*shared.DescribeTaskListResponse) map[string]*types.DescribeTaskListResponse
func ToDescribeWorkflowExecutionRequest(t *shared.DescribeWorkflowExecutionRequest) *types.DescribeWorkflowExecutionRequest
func ToDescribeWorkflowExecutionResponse(t *shared.DescribeWorkflowExecutionResponse) *types.DescribeWorkflowExecutionResponse
func ToDiagnoseWorkflowExecutionRequest(t *shared.DiagnoseWorkflowExecutionRequest) *types.DiagnoseWorkflowExecutionRequest
func ToDiagnoseWorkflowExecutionResponse(t *shared.DiagnoseWorkflowExecutionResponse) *types.DiagnoseWorkflowExecutionResponse
func ToDomainAlreadyExistsError(t *shared.DomainAlreadyExistsError) *types.DomainAlreadyExistsError
func ToDomainAsyncWorkflowConfiguraton(in *shared.AsyncWorkflowConfiguration) *types.AsyncWorkflowConfiguration
func ToDomainCacheInfo(t *shared.DomainCacheInfo) *types.DomainCacheInfo
func ToDomainConfiguration(t *shared.DomainConfiguration) *types.DomainConfiguration
func ToDomainFilter(t *history.DomainFilter) *types.DomainFilter
func ToDomainInfo(t *shared.DomainInfo) *types.DomainInfo
func ToDomainNotActiveError(t *shared.DomainNotActiveError) *types.DomainNotActiveError
func ToDomainOperation(t *replicator.DomainOperation) *types.DomainOperation
func ToDomainReplicationConfiguration(t *shared.DomainReplicationConfiguration) *types.DomainReplicationConfiguration
func ToDomainStatus(t *shared.DomainStatus) *types.DomainStatus
func ToDomainTaskAttributes(t *replicator.DomainTaskAttributes) *types.DomainTaskAttributes
func ToDynamicConfigBlob(t *config.DynamicConfigBlob) *types.DynamicConfigBlob
func ToDynamicConfigEntry(t *config.DynamicConfigEntry) *types.DynamicConfigEntry
func ToDynamicConfigEntryArray(t []*config.DynamicConfigEntry) []*types.DynamicConfigEntry
func ToDynamicConfigFilter(t *config.DynamicConfigFilter) *types.DynamicConfigFilter
func ToDynamicConfigFilterArray(t []*config.DynamicConfigFilter) []*types.DynamicConfigFilter
func ToDynamicConfigValue(t *config.DynamicConfigValue) *types.DynamicConfigValue
func ToDynamicConfigValueArray(t []*config.DynamicConfigValue) []*types.DynamicConfigValue
func ToEncodingType(t *shared.EncodingType) *types.EncodingType
func ToEntityNotExistsError(t *shared.EntityNotExistsError) *types.EntityNotExistsError
func ToError(err error) error
func ToEventAlreadyStartedError(t *history.EventAlreadyStartedError) *types.EventAlreadyStartedError
func ToEventType(t *shared.EventType) *types.EventType
func ToExternalWorkflowExecutionCancelRequestedEventAttributes(t *shared.ExternalWorkflowExecutionCancelRequestedEventAttributes) *types.ExternalWorkflowExecutionCancelRequestedEventAttributes
func ToExternalWorkflowExecutionSignaledEventAttributes(t *shared.ExternalWorkflowExecutionSignaledEventAttributes) *types.ExternalWorkflowExecutionSignaledEventAttributes
func ToFailWorkflowExecutionDecisionAttributes(t *shared.FailWorkflowExecutionDecisionAttributes) *types.FailWorkflowExecutionDecisionAttributes
func ToFailoverInfo(t *shared.FailoverInfo) *types.FailoverInfo
func ToFailoverMarkerAttributes(t *replicator.FailoverMarkerAttributes) *types.FailoverMarkerAttributes
func ToFailoverMarkerAttributesArray(t []*replicator.FailoverMarkerAttributes) []*types.FailoverMarkerAttributes
func ToFailoverMarkerToken(t *history.FailoverMarkerToken) *types.FailoverMarkerToken
func ToFailoverMarkerTokenArray(t []*history.FailoverMarkerToken) []*types.FailoverMarkerToken
func ToFailoverMarkers(t *replicator.FailoverMarkers) *types.FailoverMarkers
func ToFeatureNotEnabledError(t *shared.FeatureNotEnabledError) *types.FeatureNotEnabledError
func ToGetClusterInfoResponse(t *shared.ClusterInfo) *types.ClusterInfo
func ToGetCrossClusterTaskFailedCause(t *shared.GetTaskFailedCause) *types.GetTaskFailedCause
func ToGetFailoverInfoRequest(t *history.GetFailoverInfoRequest) *types.GetFailoverInfoRequest
func ToGetFailoverInfoResponse(t *history.GetFailoverInfoResponse) *types.GetFailoverInfoResponse
func ToGetSearchAttributesResponse(t *shared.GetSearchAttributesResponse) *types.GetSearchAttributesResponse
func ToGetTaskFailedCauseMap(t map[int32]shared.GetTaskFailedCause) map[int32]types.GetTaskFailedCause
func ToGetTaskListsByDomainRequest(t *shared.GetTaskListsByDomainRequest) *types.GetTaskListsByDomainRequest
func ToGetTaskListsByDomainResponse(t *shared.GetTaskListsByDomainResponse) *types.GetTaskListsByDomainResponse
func ToGetWorkflowExecutionHistoryRequest(t *shared.GetWorkflowExecutionHistoryRequest) *types.GetWorkflowExecutionHistoryRequest
func ToGetWorkflowExecutionHistoryResponse(t *shared.GetWorkflowExecutionHistoryResponse) *types.GetWorkflowExecutionHistoryResponse
func ToHeader(t *shared.Header) *types.Header
func ToHealthStatus(t *health.HealthStatus) *types.HealthStatus
func ToHistory(t *shared.History) *types.History
func ToHistoryArray(t []*shared.History) []*types.History
func ToHistoryBranch(t *shared.HistoryBranch) *types.HistoryBranch
func ToHistoryBranchRange(t *shared.HistoryBranchRange) *types.HistoryBranchRange
func ToHistoryBranchRangeArray(t []*shared.HistoryBranchRange) []*types.HistoryBranchRange
func ToHistoryDescribeMutableStateRequest(t *history.DescribeMutableStateRequest) *types.DescribeMutableStateRequest
func ToHistoryDescribeMutableStateResponse(t *history.DescribeMutableStateResponse) *types.DescribeMutableStateResponse
func ToHistoryDescribeWorkflowExecutionRequest(t *history.DescribeWorkflowExecutionRequest) *types.HistoryDescribeWorkflowExecutionRequest
func ToHistoryEvent(t *shared.HistoryEvent) *types.HistoryEvent
func ToHistoryEventArray(t []*shared.HistoryEvent) []*types.HistoryEvent
func ToHistoryEventFilterType(t *shared.HistoryEventFilterType) *types.HistoryEventFilterType
func ToHistoryGetMutableStateRequest(t *history.GetMutableStateRequest) *types.GetMutableStateRequest
func ToHistoryGetMutableStateResponse(t *history.GetMutableStateResponse) *types.GetMutableStateResponse
func ToHistoryNotifyFailoverMarkersRequest(t *history.NotifyFailoverMarkersRequest) *types.NotifyFailoverMarkersRequest
func ToHistoryPollMutableStateRequest(t *history.PollMutableStateRequest) *types.PollMutableStateRequest
func ToHistoryPollMutableStateResponse(t *history.PollMutableStateResponse) *types.PollMutableStateResponse
func ToHistoryQueryWorkflowRequest(t *history.QueryWorkflowRequest) *types.HistoryQueryWorkflowRequest
func ToHistoryQueryWorkflowResponse(t *history.QueryWorkflowResponse) *types.HistoryQueryWorkflowResponse
func ToHistoryRatelimitUpdateRequest(t *history.RatelimitUpdateRequest) *types.RatelimitUpdateRequest
func ToHistoryRatelimitUpdateResponse(t *history.RatelimitUpdateResponse) *types.RatelimitUpdateResponse
func ToHistoryReapplyEventsRequest(t *history.ReapplyEventsRequest) *types.HistoryReapplyEventsRequest
func ToHistoryRecordActivityTaskHeartbeatRequest(t *history.RecordActivityTaskHeartbeatRequest) *types.HistoryRecordActivityTaskHeartbeatRequest
func ToHistoryRefreshWorkflowTasksRequest(t *history.RefreshWorkflowTasksRequest) *types.HistoryRefreshWorkflowTasksRequest
func ToHistoryRemoveSignalMutableStateRequest(t *history.RemoveSignalMutableStateRequest) *types.RemoveSignalMutableStateRequest
func ToHistoryReplicateEventsV2Request(t *history.ReplicateEventsV2Request) *types.ReplicateEventsV2Request
func ToHistoryRequestCancelWorkflowExecutionRequest(t *history.RequestCancelWorkflowExecutionRequest) *types.HistoryRequestCancelWorkflowExecutionRequest
func ToHistoryResetStickyTaskListRequest(t *history.ResetStickyTaskListRequest) *types.HistoryResetStickyTaskListRequest
func ToHistoryResetStickyTaskListResponse(t *history.ResetStickyTaskListResponse) *types.HistoryResetStickyTaskListResponse
func ToHistoryResetWorkflowExecutionRequest(t *history.ResetWorkflowExecutionRequest) *types.HistoryResetWorkflowExecutionRequest
func ToHistoryRespondActivityTaskCanceledRequest(t *history.RespondActivityTaskCanceledRequest) *types.HistoryRespondActivityTaskCanceledRequest
func ToHistoryRespondActivityTaskCompletedRequest(t *history.RespondActivityTaskCompletedRequest) *types.HistoryRespondActivityTaskCompletedRequest
func ToHistoryRespondActivityTaskFailedRequest(t *history.RespondActivityTaskFailedRequest) *types.HistoryRespondActivityTaskFailedRequest
func ToHistoryRespondDecisionTaskCompletedRequest(t *history.RespondDecisionTaskCompletedRequest) *types.HistoryRespondDecisionTaskCompletedRequest
func ToHistoryRespondDecisionTaskCompletedResponse(t *history.RespondDecisionTaskCompletedResponse) *types.HistoryRespondDecisionTaskCompletedResponse
func ToHistoryRespondDecisionTaskFailedRequest(t *history.RespondDecisionTaskFailedRequest) *types.HistoryRespondDecisionTaskFailedRequest
func ToHistoryScheduleDecisionTaskRequest(t *history.ScheduleDecisionTaskRequest) *types.ScheduleDecisionTaskRequest
func ToHistorySignalWithStartWorkflowExecutionRequest(t *history.SignalWithStartWorkflowExecutionRequest) *types.HistorySignalWithStartWorkflowExecutionRequest
func ToHistorySignalWorkflowExecutionRequest(t *history.SignalWorkflowExecutionRequest) *types.HistorySignalWorkflowExecutionRequest
func ToHistoryStartWorkflowExecutionRequest(t *history.StartWorkflowExecutionRequest) *types.HistoryStartWorkflowExecutionRequest
func ToHistorySyncActivityRequest(t *history.SyncActivityRequest) *types.SyncActivityRequest
func ToHistorySyncShardStatusRequest(t *history.SyncShardStatusRequest) *types.SyncShardStatusRequest
func ToHistoryTaskV2Attributes(t *replicator.HistoryTaskV2Attributes) *types.HistoryTaskV2Attributes
func ToHistoryTerminateWorkflowExecutionRequest(t *history.TerminateWorkflowExecutionRequest) *types.HistoryTerminateWorkflowExecutionRequest
func ToHostInfo(t *admin.HostInfo) *types.HostInfo
func ToHostInfoArray(t []*admin.HostInfo) []*types.HostInfo
func ToIndexedValueType(t shared.IndexedValueType) types.IndexedValueType
func ToIndexedValueTypeMap(t map[string]shared.IndexedValueType) map[string]types.IndexedValueType
func ToInternalDataInconsistencyError(t *shared.InternalDataInconsistencyError) *types.InternalDataInconsistencyError
func ToInternalServiceError(t *shared.InternalServiceError) *types.InternalServiceError
func ToIsolationGroupConfig(in *shared.IsolationGroupConfiguration) *types.IsolationGroupConfiguration
func ToLimitExceededError(t *shared.LimitExceededError) *types.LimitExceededError
func ToListArchivedWorkflowExecutionsRequest(t *shared.ListArchivedWorkflowExecutionsRequest) *types.ListArchivedWorkflowExecutionsRequest
func ToListArchivedWorkflowExecutionsResponse(t *shared.ListArchivedWorkflowExecutionsResponse) *types.ListArchivedWorkflowExecutionsResponse
func ToListClosedWorkflowExecutionsRequest(t *shared.ListClosedWorkflowExecutionsRequest) *types.ListClosedWorkflowExecutionsRequest
func ToListClosedWorkflowExecutionsResponse(t *shared.ListClosedWorkflowExecutionsResponse) *types.ListClosedWorkflowExecutionsResponse
func ToListDomainsRequest(t *shared.ListDomainsRequest) *types.ListDomainsRequest
func ToListDomainsResponse(t *shared.ListDomainsResponse) *types.ListDomainsResponse
func ToListOpenWorkflowExecutionsRequest(t *shared.ListOpenWorkflowExecutionsRequest) *types.ListOpenWorkflowExecutionsRequest
func ToListOpenWorkflowExecutionsResponse(t *shared.ListOpenWorkflowExecutionsResponse) *types.ListOpenWorkflowExecutionsResponse
func ToListTaskListPartitionsRequest(t *shared.ListTaskListPartitionsRequest) *types.ListTaskListPartitionsRequest
func ToListTaskListPartitionsResponse(t *shared.ListTaskListPartitionsResponse) *types.ListTaskListPartitionsResponse
func ToListWorkflowExecutionsRequest(t *shared.ListWorkflowExecutionsRequest) *types.ListWorkflowExecutionsRequest
func ToListWorkflowExecutionsResponse(t *shared.ListWorkflowExecutionsResponse) *types.ListWorkflowExecutionsResponse
func ToMarkerRecordedEventAttributes(t *shared.MarkerRecordedEventAttributes) *types.MarkerRecordedEventAttributes
func ToMatchingAddActivityTaskRequest(t *matching.AddActivityTaskRequest) *types.AddActivityTaskRequest
func ToMatchingAddDecisionTaskRequest(t *matching.AddDecisionTaskRequest) *types.AddDecisionTaskRequest
func ToMatchingCancelOutstandingPollRequest(t *matching.CancelOutstandingPollRequest) *types.CancelOutstandingPollRequest
func ToMatchingDescribeTaskListRequest(t *matching.DescribeTaskListRequest) *types.MatchingDescribeTaskListRequest
func ToMatchingListTaskListPartitionsRequest(t *matching.ListTaskListPartitionsRequest) *types.MatchingListTaskListPartitionsRequest
func ToMatchingPollForActivityTaskRequest(t *matching.PollForActivityTaskRequest) *types.MatchingPollForActivityTaskRequest
func ToMatchingPollForActivityTaskResponse(t *shared.PollForActivityTaskResponse) *types.MatchingPollForActivityTaskResponse
func ToMatchingPollForDecisionTaskRequest(t *matching.PollForDecisionTaskRequest) *types.MatchingPollForDecisionTaskRequest
func ToMatchingPollForDecisionTaskResponse(t *matching.PollForDecisionTaskResponse) *types.MatchingPollForDecisionTaskResponse
func ToMatchingQueryWorkflowRequest(t *matching.QueryWorkflowRequest) *types.MatchingQueryWorkflowRequest
func ToMatchingRespondQueryTaskCompletedRequest(t *matching.RespondQueryTaskCompletedRequest) *types.MatchingRespondQueryTaskCompletedRequest
func ToMembershipInfo(t *admin.MembershipInfo) *types.MembershipInfo
func ToMemo(t *shared.Memo) *types.Memo
func ToParentClosePolicy(t *shared.ParentClosePolicy) *types.ParentClosePolicy
func ToParentExecutionInfo(t *history.ParentExecutionInfo) *types.ParentExecutionInfo
func ToPendingActivityInfo(t *shared.PendingActivityInfo) *types.PendingActivityInfo
func ToPendingActivityInfoArray(t []*shared.PendingActivityInfo) []*types.PendingActivityInfo
func ToPendingActivityState(t *shared.PendingActivityState) *types.PendingActivityState
func ToPendingChildExecutionInfo(t *shared.PendingChildExecutionInfo) *types.PendingChildExecutionInfo
func ToPendingChildExecutionInfoArray(t []*shared.PendingChildExecutionInfo) []*types.PendingChildExecutionInfo
func ToPendingDecisionInfo(t *shared.PendingDecisionInfo) *types.PendingDecisionInfo
func ToPendingDecisionState(t *shared.PendingDecisionState) *types.PendingDecisionState
func ToPersistenceFeature(t *admin.PersistenceFeature) *types.PersistenceFeature
func ToPersistenceFeatures(t []*admin.PersistenceFeature) []*types.PersistenceFeature
func ToPersistenceInfo(t *admin.PersistenceInfo) *types.PersistenceInfo
func ToPersistenceInfoMap(t map[string]*admin.PersistenceInfo) map[string]*types.PersistenceInfo
func ToPersistenceSetting(t *admin.PersistenceSetting) *types.PersistenceSetting
func ToPersistenceSettings(t []*admin.PersistenceSetting) []*types.PersistenceSetting
func ToPollForActivityTaskRequest(t *shared.PollForActivityTaskRequest) *types.PollForActivityTaskRequest
func ToPollForActivityTaskResponse(t *shared.PollForActivityTaskResponse) *types.PollForActivityTaskResponse
func ToPollForDecisionTaskRequest(t *shared.PollForDecisionTaskRequest) *types.PollForDecisionTaskRequest
func ToPollForDecisionTaskResponse(t *shared.PollForDecisionTaskResponse) *types.PollForDecisionTaskResponse
func ToPollerInfo(t *shared.PollerInfo) *types.PollerInfo
func ToPollerInfoArray(t []*shared.PollerInfo) []*types.PollerInfo
func ToProcessingQueueState(t *history.ProcessingQueueState) *types.ProcessingQueueState
func ToProcessingQueueStateArray(t []*history.ProcessingQueueState) []*types.ProcessingQueueState
func ToProcessingQueueStateArrayMap(t map[string][]*history.ProcessingQueueState) map[string][]*types.ProcessingQueueState
func ToProcessingQueueStates(t *history.ProcessingQueueStates) *types.ProcessingQueueStates
func ToQueryConsistencyLevel(t *shared.QueryConsistencyLevel) *types.QueryConsistencyLevel
func ToQueryFailedError(t *shared.QueryFailedError) *types.QueryFailedError
func ToQueryRejectCondition(t *shared.QueryRejectCondition) *types.QueryRejectCondition
func ToQueryRejected(t *shared.QueryRejected) *types.QueryRejected
func ToQueryResultType(t *shared.QueryResultType) *types.QueryResultType
func ToQueryTaskCompletedType(t *shared.QueryTaskCompletedType) *types.QueryTaskCompletedType
func ToQueryWorkflowRequest(t *shared.QueryWorkflowRequest) *types.QueryWorkflowRequest
func ToQueryWorkflowResponse(t *shared.QueryWorkflowResponse) *types.QueryWorkflowResponse
func ToRecordActivityTaskHeartbeatByIDRequest(t *shared.RecordActivityTaskHeartbeatByIDRequest) *types.RecordActivityTaskHeartbeatByIDRequest
func ToRecordActivityTaskHeartbeatRequest(t *shared.RecordActivityTaskHeartbeatRequest) *types.RecordActivityTaskHeartbeatRequest
func ToRecordActivityTaskHeartbeatResponse(t *shared.RecordActivityTaskHeartbeatResponse) *types.RecordActivityTaskHeartbeatResponse
func ToRecordActivityTaskStartedRequest(t *history.RecordActivityTaskStartedRequest) *types.RecordActivityTaskStartedRequest
func ToRecordActivityTaskStartedResponse(t *history.RecordActivityTaskStartedResponse) *types.RecordActivityTaskStartedResponse
func ToRecordChildExecutionCompletedRequest(t *history.RecordChildExecutionCompletedRequest) *types.RecordChildExecutionCompletedRequest
func ToRecordDecisionTaskStartedRequest(t *history.RecordDecisionTaskStartedRequest) *types.RecordDecisionTaskStartedRequest
func ToRecordDecisionTaskStartedResponse(t *history.RecordDecisionTaskStartedResponse) *types.RecordDecisionTaskStartedResponse
func ToRecordMarkerDecisionAttributes(t *shared.RecordMarkerDecisionAttributes) *types.RecordMarkerDecisionAttributes
func ToRefreshWorkflowTasksRequest(t *shared.RefreshWorkflowTasksRequest) *types.RefreshWorkflowTasksRequest
func ToRegisterDomainRequest(t *shared.RegisterDomainRequest) *types.RegisterDomainRequest
func ToRemoteSyncMatchedError(t *shared.RemoteSyncMatchedError) *types.RemoteSyncMatchedError
func ToReplicationMessages(t *replicator.ReplicationMessages) *types.ReplicationMessages
func ToReplicationMessagesMap(t map[int32]*replicator.ReplicationMessages) map[int32]*types.ReplicationMessages
func ToReplicationTask(t *replicator.ReplicationTask) *types.ReplicationTask
func ToReplicationTaskArray(t []*replicator.ReplicationTask) []*types.ReplicationTask
func ToReplicationTaskInfo(t *replicator.ReplicationTaskInfo) *types.ReplicationTaskInfo
func ToReplicationTaskInfoArray(t []*replicator.ReplicationTaskInfo) []*types.ReplicationTaskInfo
func ToReplicationTaskType(t *replicator.ReplicationTaskType) *types.ReplicationTaskType
func ToReplicationToken(t *replicator.ReplicationToken) *types.ReplicationToken
func ToReplicationTokenArray(t []*replicator.ReplicationToken) []*types.ReplicationToken
func ToRequestCancelActivityTaskDecisionAttributes(t *shared.RequestCancelActivityTaskDecisionAttributes) *types.RequestCancelActivityTaskDecisionAttributes
func ToRequestCancelActivityTaskFailedEventAttributes(t *shared.RequestCancelActivityTaskFailedEventAttributes) *types.RequestCancelActivityTaskFailedEventAttributes
func ToRequestCancelExternalWorkflowExecutionDecisionAttributes(t *shared.RequestCancelExternalWorkflowExecutionDecisionAttributes) *types.RequestCancelExternalWorkflowExecutionDecisionAttributes
func ToRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *shared.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes
func ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *shared.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
func ToRequestCancelWorkflowExecutionRequest(t *shared.RequestCancelWorkflowExecutionRequest) *types.RequestCancelWorkflowExecutionRequest
func ToResetPointInfo(t *shared.ResetPointInfo) *types.ResetPointInfo
func ToResetPointInfoArray(t []*shared.ResetPointInfo) []*types.ResetPointInfo
func ToResetPoints(t *shared.ResetPoints) *types.ResetPoints
func ToResetStickyTaskListRequest(t *shared.ResetStickyTaskListRequest) *types.ResetStickyTaskListRequest
func ToResetStickyTaskListResponse(t *shared.ResetStickyTaskListResponse) *types.ResetStickyTaskListResponse
func ToResetWorkflowExecutionRequest(t *shared.ResetWorkflowExecutionRequest) *types.ResetWorkflowExecutionRequest
func ToResetWorkflowExecutionResponse(t *shared.ResetWorkflowExecutionResponse) *types.ResetWorkflowExecutionResponse
func ToRespondActivityTaskCanceledByIDRequest(t *shared.RespondActivityTaskCanceledByIDRequest) *types.RespondActivityTaskCanceledByIDRequest
func ToRespondActivityTaskCanceledRequest(t *shared.RespondActivityTaskCanceledRequest) *types.RespondActivityTaskCanceledRequest
func ToRespondActivityTaskCompletedByIDRequest(t *shared.RespondActivityTaskCompletedByIDRequest) *types.RespondActivityTaskCompletedByIDRequest
func ToRespondActivityTaskCompletedRequest(t *shared.RespondActivityTaskCompletedRequest) *types.RespondActivityTaskCompletedRequest
func ToRespondActivityTaskFailedByIDRequest(t *shared.RespondActivityTaskFailedByIDRequest) *types.RespondActivityTaskFailedByIDRequest
func ToRespondActivityTaskFailedRequest(t *shared.RespondActivityTaskFailedRequest) *types.RespondActivityTaskFailedRequest
func ToRespondDecisionTaskCompletedRequest(t *shared.RespondDecisionTaskCompletedRequest) *types.RespondDecisionTaskCompletedRequest
func ToRespondDecisionTaskCompletedResponse(t *shared.RespondDecisionTaskCompletedResponse) *types.RespondDecisionTaskCompletedResponse
func ToRespondDecisionTaskFailedRequest(t *shared.RespondDecisionTaskFailedRequest) *types.RespondDecisionTaskFailedRequest
func ToRespondQueryTaskCompletedRequest(t *shared.RespondQueryTaskCompletedRequest) *types.RespondQueryTaskCompletedRequest
func ToRestartWorkflowExecutionRequest(t *shared.RestartWorkflowExecutionRequest) *types.RestartWorkflowExecutionRequest
func ToRestartWorkflowExecutionResponse(t *shared.RestartWorkflowExecutionResponse) *types.RestartWorkflowExecutionResponse
func ToRetryPolicy(t *shared.RetryPolicy) *types.RetryPolicy
func ToRetryTaskV2Error(t *shared.RetryTaskV2Error) *types.RetryTaskV2Error
func ToRingInfo(t *admin.RingInfo) *types.RingInfo
func ToRingInfoArray(t []*admin.RingInfo) []*types.RingInfo
func ToScheduleActivityTaskDecisionAttributes(t *shared.ScheduleActivityTaskDecisionAttributes) *types.ScheduleActivityTaskDecisionAttributes
func ToSearchAttributes(t *shared.SearchAttributes) *types.SearchAttributes
func ToServiceBusyError(t *shared.ServiceBusyError) *types.ServiceBusyError
func ToShardOwnershipLostError(t *history.ShardOwnershipLostError) *types.ShardOwnershipLostError
func ToSignalExternalWorkflowExecutionDecisionAttributes(t *shared.SignalExternalWorkflowExecutionDecisionAttributes) *types.SignalExternalWorkflowExecutionDecisionAttributes
func ToSignalExternalWorkflowExecutionFailedCause(t *shared.SignalExternalWorkflowExecutionFailedCause) *types.SignalExternalWorkflowExecutionFailedCause
func ToSignalExternalWorkflowExecutionFailedEventAttributes(t *shared.SignalExternalWorkflowExecutionFailedEventAttributes) *types.SignalExternalWorkflowExecutionFailedEventAttributes
func ToSignalExternalWorkflowExecutionInitiatedEventAttributes(t *shared.SignalExternalWorkflowExecutionInitiatedEventAttributes) *types.SignalExternalWorkflowExecutionInitiatedEventAttributes
func ToSignalWithStartWorkflowExecutionAsyncRequest(t *shared.SignalWithStartWorkflowExecutionAsyncRequest) *types.SignalWithStartWorkflowExecutionAsyncRequest
func ToSignalWithStartWorkflowExecutionAsyncResponse(t *shared.SignalWithStartWorkflowExecutionAsyncResponse) *types.SignalWithStartWorkflowExecutionAsyncResponse
func ToSignalWithStartWorkflowExecutionRequest(t *shared.SignalWithStartWorkflowExecutionRequest) *types.SignalWithStartWorkflowExecutionRequest
func ToSignalWorkflowExecutionRequest(t *shared.SignalWorkflowExecutionRequest) *types.SignalWorkflowExecutionRequest
func ToStartChildWorkflowExecutionDecisionAttributes(t *shared.StartChildWorkflowExecutionDecisionAttributes) *types.StartChildWorkflowExecutionDecisionAttributes
func ToStartChildWorkflowExecutionFailedEventAttributes(t *shared.StartChildWorkflowExecutionFailedEventAttributes) *types.StartChildWorkflowExecutionFailedEventAttributes
func ToStartChildWorkflowExecutionInitiatedEventAttributes(t *shared.StartChildWorkflowExecutionInitiatedEventAttributes) *types.StartChildWorkflowExecutionInitiatedEventAttributes
func ToStartTimeFilter(t *shared.StartTimeFilter) *types.StartTimeFilter
func ToStartTimerDecisionAttributes(t *shared.StartTimerDecisionAttributes) *types.StartTimerDecisionAttributes
func ToStartWorkflowExecutionAsyncRequest(t *shared.StartWorkflowExecutionAsyncRequest) *types.StartWorkflowExecutionAsyncRequest
func ToStartWorkflowExecutionAsyncResponse(t *shared.StartWorkflowExecutionAsyncResponse) *types.StartWorkflowExecutionAsyncResponse
func ToStartWorkflowExecutionRequest(t *shared.StartWorkflowExecutionRequest) *types.StartWorkflowExecutionRequest
func ToStartWorkflowExecutionResponse(t *shared.StartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse
func ToStickyExecutionAttributes(t *shared.StickyExecutionAttributes) *types.StickyExecutionAttributes
func ToStickyWorkerUnavailableError(t *shared.StickyWorkerUnavailableError) *types.StickyWorkerUnavailableError
func ToSupportedClientVersions(t *shared.SupportedClientVersions) *types.SupportedClientVersions
func ToSyncActivityTaskAttributes(t *replicator.SyncActivityTaskAttributes) *types.SyncActivityTaskAttributes
func ToSyncShardStatus(t *replicator.SyncShardStatus) *types.SyncShardStatus
func ToSyncShardStatusTaskAttributes(t *replicator.SyncShardStatusTaskAttributes) *types.SyncShardStatusTaskAttributes
func ToTaskIDBlock(t *shared.TaskIDBlock) *types.TaskIDBlock
func ToTaskList(t *shared.TaskList) *types.TaskList
func ToTaskListKind(t *shared.TaskListKind) *types.TaskListKind
func ToTaskListMetadata(t *shared.TaskListMetadata) *types.TaskListMetadata
func ToTaskListNotOwnedByHostError(t *shared.TaskListNotOwnedByHostError) *cadence_errors.TaskListNotOwnedByHostError
func ToTaskListPartitionMetadata(t *shared.TaskListPartitionMetadata) *types.TaskListPartitionMetadata
func ToTaskListPartitionMetadataArray(t []*shared.TaskListPartitionMetadata) []*types.TaskListPartitionMetadata
func ToTaskListStatus(t *shared.TaskListStatus) *types.TaskListStatus
func ToTaskListType(t *shared.TaskListType) *types.TaskListType
func ToTaskSource(t *matching.TaskSource) *types.TaskSource
func ToTerminateWorkflowExecutionRequest(t *shared.TerminateWorkflowExecutionRequest) *types.TerminateWorkflowExecutionRequest
func ToTimeoutType(t *shared.TimeoutType) *types.TimeoutType
func ToTimerCanceledEventAttributes(t *shared.TimerCanceledEventAttributes) *types.TimerCanceledEventAttributes
func ToTimerFiredEventAttributes(t *shared.TimerFiredEventAttributes) *types.TimerFiredEventAttributes
func ToTimerStartedEventAttributes(t *shared.TimerStartedEventAttributes) *types.TimerStartedEventAttributes
func ToTransientDecisionInfo(t *shared.TransientDecisionInfo) *types.TransientDecisionInfo
func ToUpdateDomainRequest(t *shared.UpdateDomainRequest) *types.UpdateDomainRequest
func ToUpdateDomainResponse(t *shared.UpdateDomainResponse) *types.UpdateDomainResponse
func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *shared.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes
func ToUpsertWorkflowSearchAttributesEventAttributes(t *shared.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes
func ToVersionHistories(t *shared.VersionHistories) *types.VersionHistories
func ToVersionHistory(t *shared.VersionHistory) *types.VersionHistory
func ToVersionHistoryArray(t []*shared.VersionHistory) []*types.VersionHistory
func ToVersionHistoryItem(t *shared.VersionHistoryItem) *types.VersionHistoryItem
func ToVersionHistoryItemArray(t []*shared.VersionHistoryItem) []*types.VersionHistoryItem
func ToWorkerVersionInfo(t *shared.WorkerVersionInfo) *types.WorkerVersionInfo
func ToWorkflowExecution(t *shared.WorkflowExecution) *types.WorkflowExecution
func ToWorkflowExecutionAlreadyCompletedError(t *shared.WorkflowExecutionAlreadyCompletedError) *types.WorkflowExecutionAlreadyCompletedError
func ToWorkflowExecutionAlreadyStartedError(t *shared.WorkflowExecutionAlreadyStartedError) *types.WorkflowExecutionAlreadyStartedError
func ToWorkflowExecutionCancelRequestedEventAttributes(t *shared.WorkflowExecutionCancelRequestedEventAttributes) *types.WorkflowExecutionCancelRequestedEventAttributes
func ToWorkflowExecutionCanceledEventAttributes(t *shared.WorkflowExecutionCanceledEventAttributes) *types.WorkflowExecutionCanceledEventAttributes
func ToWorkflowExecutionCloseStatus(t *shared.WorkflowExecutionCloseStatus) *types.WorkflowExecutionCloseStatus
func ToWorkflowExecutionCompletedEventAttributes(t *shared.WorkflowExecutionCompletedEventAttributes) *types.WorkflowExecutionCompletedEventAttributes
func ToWorkflowExecutionConfiguration(t *shared.WorkflowExecutionConfiguration) *types.WorkflowExecutionConfiguration
func ToWorkflowExecutionContinuedAsNewEventAttributes(t *shared.WorkflowExecutionContinuedAsNewEventAttributes) *types.WorkflowExecutionContinuedAsNewEventAttributes
func ToWorkflowExecutionFailedEventAttributes(t *shared.WorkflowExecutionFailedEventAttributes) *types.WorkflowExecutionFailedEventAttributes
func ToWorkflowExecutionFilter(t *shared.WorkflowExecutionFilter) *types.WorkflowExecutionFilter
func ToWorkflowExecutionInfo(t *shared.WorkflowExecutionInfo) *types.WorkflowExecutionInfo
func ToWorkflowExecutionInfoArray(t []*shared.WorkflowExecutionInfo) []*types.WorkflowExecutionInfo
func ToWorkflowExecutionSignaledEventAttributes(t *shared.WorkflowExecutionSignaledEventAttributes) *types.WorkflowExecutionSignaledEventAttributes
func ToWorkflowExecutionStartedEventAttributes(t *shared.WorkflowExecutionStartedEventAttributes) *types.WorkflowExecutionStartedEventAttributes
func ToWorkflowExecutionTerminatedEventAttributes(t *shared.WorkflowExecutionTerminatedEventAttributes) *types.WorkflowExecutionTerminatedEventAttributes
func ToWorkflowExecutionTimedOutEventAttributes(t *shared.WorkflowExecutionTimedOutEventAttributes) *types.WorkflowExecutionTimedOutEventAttributes
func ToWorkflowIDReusePolicy(t *shared.WorkflowIdReusePolicy) *types.WorkflowIDReusePolicy
func ToWorkflowQuery(t *shared.WorkflowQuery) *types.WorkflowQuery
func ToWorkflowQueryMap(t map[string]*shared.WorkflowQuery) map[string]*types.WorkflowQuery
func ToWorkflowQueryResult(t *shared.WorkflowQueryResult) *types.WorkflowQueryResult
func ToWorkflowQueryResultMap(t map[string]*shared.WorkflowQueryResult) map[string]*types.WorkflowQueryResult
func ToWorkflowType(t *shared.WorkflowType) *types.WorkflowType
func ToWorkflowTypeFilter(t *shared.WorkflowTypeFilter) *types.WorkflowTypeFilter
type ThriftObject

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	FromAdminRefreshWorkflowTasksRequest = FromRefreshWorkflowTasksRequest
	ToAdminRefreshWorkflowTasksRequest   = ToRefreshWorkflowTasksRequest
)

View Source

var (
	FromHistoryDescribeHistoryHostRequest                = FromAdminDescribeHistoryHostRequest
	ToHistoryDescribeHistoryHostRequest                  = ToAdminDescribeHistoryHostRequest
	FromHistoryDescribeHistoryHostResponse               = FromAdminDescribeHistoryHostResponse
	ToHistoryDescribeHistoryHostResponse                 = ToAdminDescribeHistoryHostResponse
	FromHistoryCloseShardRequest                         = FromAdminCloseShardRequest
	ToHistoryCloseShardRequest                           = ToAdminCloseShardRequest
	FromHistoryDescribeQueueRequest                      = FromAdminDescribeQueueRequest
	ToHistoryDescribeQueueRequest                        = ToAdminDescribeQueueRequest
	FromHistoryDescribeQueueResponse                     = FromAdminDescribeQueueResponse
	ToHistoryDescribeQueueResponse                       = ToAdminDescribeQueueResponse
	FromHistoryDescribeWorkflowExecutionResponse         = FromDescribeWorkflowExecutionResponse
	ToHistoryDescribeWorkflowExecutionResponse           = ToDescribeWorkflowExecutionResponse
	FromHistoryGetCrossClusterTasksRequest               = FromAdminGetCrossClusterTasksRequest
	ToHistoryGetCrossClusterTasksRequest                 = ToAdminGetCrossClusterTasksRequest
	FromHistoryGetCrossClusterTasksResponse              = FromAdminGetCrossClusterTasksResponse
	ToHistoryGetCrossClusterTasksResponse                = ToAdminGetCrossClusterTasksResponse
	FromHistoryGetDLQReplicationMessagesRequest          = FromAdminGetDLQReplicationMessagesRequest
	ToHistoryGetDLQReplicationMessagesRequest            = ToAdminGetDLQReplicationMessagesRequest
	FromHistoryGetDLQReplicationMessagesResponse         = FromAdminGetDLQReplicationMessagesResponse
	ToHistoryGetDLQReplicationMessagesResponse           = ToAdminGetDLQReplicationMessagesResponse
	FromHistoryGetFailoverInfoRequest                    = FromGetFailoverInfoRequest
	ToHistoryGetFailoverInfoRequest                      = ToGetFailoverInfoRequest
	FromHistoryGetFailoverInfoResponse                   = FromGetFailoverInfoResponse
	ToHistoryGetFailoverInfoResponse                     = ToGetFailoverInfoResponse
	FromHistoryGetReplicationMessagesRequest             = FromAdminGetReplicationMessagesRequest
	ToHistoryGetReplicationMessagesRequest               = ToAdminGetReplicationMessagesRequest
	FromHistoryGetReplicationMessagesResponse            = FromAdminGetReplicationMessagesResponse
	ToHistoryGetReplicationMessagesResponse              = ToAdminGetReplicationMessagesResponse
	FromHistoryMergeDLQMessagesRequest                   = FromAdminMergeDLQMessagesRequest
	ToHistoryMergeDLQMessagesRequest                     = ToAdminMergeDLQMessagesRequest
	FromHistoryMergeDLQMessagesResponse                  = FromAdminMergeDLQMessagesResponse
	ToHistoryMergeDLQMessagesResponse                    = ToAdminMergeDLQMessagesResponse
	FromHistoryPurgeDLQMessagesRequest                   = FromAdminPurgeDLQMessagesRequest
	ToHistoryPurgeDLQMessagesRequest                     = ToAdminPurgeDLQMessagesRequest
	FromHistoryReadDLQMessagesRequest                    = FromAdminReadDLQMessagesRequest
	ToHistoryReadDLQMessagesRequest                      = ToAdminReadDLQMessagesRequest
	FromHistoryReadDLQMessagesResponse                   = FromAdminReadDLQMessagesResponse
	ToHistoryReadDLQMessagesResponse                     = ToAdminReadDLQMessagesResponse
	FromHistoryRecordActivityTaskHeartbeatResponse       = FromRecordActivityTaskHeartbeatResponse
	ToHistoryRecordActivityTaskHeartbeatResponse         = ToRecordActivityTaskHeartbeatResponse
	FromHistoryRecordActivityTaskStartedRequest          = FromRecordActivityTaskStartedRequest
	ToHistoryRecordActivityTaskStartedRequest            = ToRecordActivityTaskStartedRequest
	FromHistoryRecordActivityTaskStartedResponse         = FromRecordActivityTaskStartedResponse
	ToHistoryRecordActivityTaskStartedResponse           = ToRecordActivityTaskStartedResponse
	FromHistoryRecordChildExecutionCompletedRequest      = FromRecordChildExecutionCompletedRequest
	ToHistoryRecordChildExecutionCompletedRequest        = ToRecordChildExecutionCompletedRequest
	FromHistoryRecordDecisionTaskStartedRequest          = FromRecordDecisionTaskStartedRequest
	ToHistoryRecordDecisionTaskStartedRequest            = ToRecordDecisionTaskStartedRequest
	FromHistoryRecordDecisionTaskStartedResponse         = FromRecordDecisionTaskStartedResponse
	ToHistoryRecordDecisionTaskStartedResponse           = ToRecordDecisionTaskStartedResponse
	FromHistoryRemoveTaskRequest                         = FromAdminRemoveTaskRequest
	ToHistoryRemoveTaskRequest                           = ToAdminRemoveTaskRequest
	FromHistoryResetQueueRequest                         = FromAdminResetQueueRequest
	ToHistoryResetQueueRequest                           = ToAdminResetQueueRequest
	FromHistoryResetWorkflowExecutionResponse            = FromResetWorkflowExecutionResponse
	ToHistoryResetWorkflowExecutionResponse              = ToResetWorkflowExecutionResponse
	FromHistoryRespondCrossClusterTasksCompletedRequest  = FromAdminRespondCrossClusterTasksCompletedRequest
	ToHistoryRespondCrossClusterTasksCompletedRequest    = ToAdminRespondCrossClusterTasksCompletedRequest
	FromHistoryRespondCrossClusterTasksCompletedResponse = FromAdminRespondCrossClusterTasksCompletedResponse
	ToHistoryRespondCrossClusterTasksCompletedResponse   = ToAdminRespondCrossClusterTasksCompletedResponse
	FromHistorySignalWithStartWorkflowExecutionResponse  = FromStartWorkflowExecutionResponse
	ToHistorySignalWithStartWorkflowExecutionResponse    = ToStartWorkflowExecutionResponse
	FromHistoryStartWorkflowExecutionResponse            = FromStartWorkflowExecutionResponse
	ToHistoryStartWorkflowExecutionResponse              = ToStartWorkflowExecutionResponse
)

View Source

var (
	FromMatchingDescribeTaskListResponse       = FromDescribeTaskListResponse
	ToMatchingDescribeTaskListResponse         = ToDescribeTaskListResponse
	FromMatchingGetTaskListsByDomainRequest    = FromGetTaskListsByDomainRequest
	ToMatchingGetTaskListsByDomainRequest      = ToGetTaskListsByDomainRequest
	FromMatchingGetTaskListsByDomainResponse   = FromGetTaskListsByDomainResponse
	ToMatchingGetTaskListsByDomainResponse     = ToGetTaskListsByDomainResponse
	FromMatchingListTaskListPartitionsResponse = FromListTaskListPartitionsResponse
	ToMatchingListTaskListPartitionsResponse   = ToListTaskListPartitionsResponse
	FromMatchingQueryWorkflowResponse          = FromQueryWorkflowResponse
	ToMatchingQueryWorkflowResponse            = ToQueryWorkflowResponse
)

View Source

var (
	FromScanWorkflowExecutionsRequest            = FromListWorkflowExecutionsRequest
	ToScanWorkflowExecutionsRequest              = ToListWorkflowExecutionsRequest
	FromRecordActivityTaskHeartbeatByIDResponse  = FromRecordActivityTaskHeartbeatResponse
	ToRecordActivityTaskHeartbeatByIDResponse    = ToRecordActivityTaskHeartbeatResponse
	FromScanWorkflowExecutionsResponse           = FromListWorkflowExecutionsResponse
	ToScanWorkflowExecutionsResponse             = ToListWorkflowExecutionsResponse
	FromSignalWithStartWorkflowExecutionResponse = FromStartWorkflowExecutionResponse
	ToSignalWithStartWorkflowExecutionResponse   = ToStartWorkflowExecutionResponse
)

Functions ¶

func DecodeStructFromBytes ¶ added in v1.2.12

func DecodeStructFromBytes(data []byte, target ThriftObject) error

func EncodeToBytes ¶ added in v1.2.12

func EncodeToBytes(obj ThriftObject) ([]byte, error)

func FromAccessDeniedError ¶

func FromAccessDeniedError(t *types.AccessDeniedError) *shared.AccessDeniedError

FromAccessDeniedError converts internal AccessDeniedError type to thrift

func FromActivityLocalDispatchInfo ¶ added in v0.17.0

func FromActivityLocalDispatchInfo(t *types.ActivityLocalDispatchInfo) *shared.ActivityLocalDispatchInfo

FromActivityLocalDispatchInfo converts internal ActivityLocalDispatchInfo type to thrift

func FromActivityLocalDispatchInfoMap ¶ added in v0.17.0

func FromActivityLocalDispatchInfoMap(t map[string]*types.ActivityLocalDispatchInfo) map[string]*shared.ActivityLocalDispatchInfo

FromActivityLocalDispatchInfoMap converts internal ActivityLocalDispatchInfo type map to thrift

func FromActivityTaskCancelRequestedEventAttributes ¶

func FromActivityTaskCancelRequestedEventAttributes(t *types.ActivityTaskCancelRequestedEventAttributes) *shared.ActivityTaskCancelRequestedEventAttributes

FromActivityTaskCancelRequestedEventAttributes converts internal ActivityTaskCancelRequestedEventAttributes type to thrift

func FromActivityTaskCanceledEventAttributes ¶

func FromActivityTaskCanceledEventAttributes(t *types.ActivityTaskCanceledEventAttributes) *shared.ActivityTaskCanceledEventAttributes

FromActivityTaskCanceledEventAttributes converts internal ActivityTaskCanceledEventAttributes type to thrift

func FromActivityTaskCompletedEventAttributes ¶

func FromActivityTaskCompletedEventAttributes(t *types.ActivityTaskCompletedEventAttributes) *shared.ActivityTaskCompletedEventAttributes

FromActivityTaskCompletedEventAttributes converts internal ActivityTaskCompletedEventAttributes type to thrift

func FromActivityTaskDispatchInfo ¶ added in v0.24.0

func FromActivityTaskDispatchInfo(t *types.ActivityTaskDispatchInfo) *matching.ActivityTaskDispatchInfo

func FromActivityTaskFailedEventAttributes ¶

func FromActivityTaskFailedEventAttributes(t *types.ActivityTaskFailedEventAttributes) *shared.ActivityTaskFailedEventAttributes

FromActivityTaskFailedEventAttributes converts internal ActivityTaskFailedEventAttributes type to thrift

func FromActivityTaskScheduledEventAttributes ¶

func FromActivityTaskScheduledEventAttributes(t *types.ActivityTaskScheduledEventAttributes) *shared.ActivityTaskScheduledEventAttributes

FromActivityTaskScheduledEventAttributes converts internal ActivityTaskScheduledEventAttributes type to thrift

func FromActivityTaskStartedEventAttributes ¶

func FromActivityTaskStartedEventAttributes(t *types.ActivityTaskStartedEventAttributes) *shared.ActivityTaskStartedEventAttributes

FromActivityTaskStartedEventAttributes converts internal ActivityTaskStartedEventAttributes type to thrift

func FromActivityTaskTimedOutEventAttributes ¶

func FromActivityTaskTimedOutEventAttributes(t *types.ActivityTaskTimedOutEventAttributes) *shared.ActivityTaskTimedOutEventAttributes

FromActivityTaskTimedOutEventAttributes converts internal ActivityTaskTimedOutEventAttributes type to thrift

func FromActivityType ¶

func FromActivityType(t *types.ActivityType) *shared.ActivityType

FromActivityType converts internal ActivityType type to thrift

func FromAdminAddSearchAttributeRequest ¶ added in v1.2.7

func FromAdminAddSearchAttributeRequest(t *types.AddSearchAttributeRequest) *admin.AddSearchAttributeRequest

FromAdminAddSearchAttributeRequest converts internal AddSearchAttributeRequest type to thrift

func FromAdminCloseShardRequest ¶ added in v1.2.7

func FromAdminCloseShardRequest(t *types.CloseShardRequest) *shared.CloseShardRequest

FromAdminCloseShardRequest converts internal CloseShardRequest type to thrift

func FromAdminDeleteWorkflowRequest ¶ added in v0.24.0

func FromAdminDeleteWorkflowRequest(t *types.AdminDeleteWorkflowRequest) *admin.AdminDeleteWorkflowRequest

FromAdminDeleteWorkflowRequest converts internal AdminDeleteWorkflowRequest type to thrift

func FromAdminDeleteWorkflowResponse ¶ added in v0.24.0

func FromAdminDeleteWorkflowResponse(t *types.AdminDeleteWorkflowResponse) *admin.AdminDeleteWorkflowResponse

FromAdminDeleteWorkflowResponse converts internal AdminDeleteWorkflowResponse type to thrift

func FromAdminDescribeClusterResponse ¶ added in v1.2.7

func FromAdminDescribeClusterResponse(t *types.DescribeClusterResponse) *admin.DescribeClusterResponse

FromAdminDescribeClusterResponse converts internal DescribeClusterResponse type to thrift

func FromAdminDescribeHistoryHostRequest ¶ added in v1.2.7

func FromAdminDescribeHistoryHostRequest(t *types.DescribeHistoryHostRequest) *shared.DescribeHistoryHostRequest

FromAdminDescribeHistoryHostRequest converts internal DescribeHistoryHostRequest type to thrift

func FromAdminDescribeHistoryHostResponse ¶ added in v1.2.7

func FromAdminDescribeHistoryHostResponse(t *types.DescribeHistoryHostResponse) *shared.DescribeHistoryHostResponse

FromAdminDescribeHistoryHostResponse converts internal DescribeHistoryHostResponse type to thrift

func FromAdminDescribeQueueRequest ¶ added in v1.2.7

func FromAdminDescribeQueueRequest(t *types.DescribeQueueRequest) *shared.DescribeQueueRequest

FromAdminDescribeQueueRequest converts internal DescribeQueueRequest type to thrift

func FromAdminDescribeQueueResponse ¶ added in v1.2.7

func FromAdminDescribeQueueResponse(t *types.DescribeQueueResponse) *shared.DescribeQueueResponse

FromAdminDescribeQueueResponse converts internal DescribeQueueResponse type to thrift

func FromAdminDescribeShardDistributionRequest ¶ added in v1.2.7

func FromAdminDescribeShardDistributionRequest(t *types.DescribeShardDistributionRequest) *shared.DescribeShardDistributionRequest

FromAdminDescribeShardDistributionRequest converts internal DescribeHistoryHostRequest type to thrift

func FromAdminDescribeShardDistributionResponse ¶ added in v1.2.7

func FromAdminDescribeShardDistributionResponse(t *types.DescribeShardDistributionResponse) *shared.DescribeShardDistributionResponse

FromAdminDescribeShardDistributionResponse converts internal DescribeHistoryHostResponse type to thrift

func FromAdminDescribeWorkflowExecutionRequest ¶ added in v0.17.0

func FromAdminDescribeWorkflowExecutionRequest(t *types.AdminDescribeWorkflowExecutionRequest) *admin.DescribeWorkflowExecutionRequest

FromAdminDescribeWorkflowExecutionRequest converts internal DescribeWorkflowExecutionRequest type to thrift

func FromAdminDescribeWorkflowExecutionResponse ¶ added in v0.17.0

func FromAdminDescribeWorkflowExecutionResponse(t *types.AdminDescribeWorkflowExecutionResponse) *admin.DescribeWorkflowExecutionResponse

FromAdminDescribeWorkflowExecutionResponse converts internal DescribeWorkflowExecutionResponse type to thrift

func FromAdminGetCrossClusterTasksRequest ¶ added in v1.2.7

func FromAdminGetCrossClusterTasksRequest(t *types.GetCrossClusterTasksRequest) *shared.GetCrossClusterTasksRequest

FromAdminGetCrossClusterTasksRequest converts internal GetCrossClusterTasksRequest type to thrift

func FromAdminGetCrossClusterTasksResponse ¶ added in v1.2.7

func FromAdminGetCrossClusterTasksResponse(t *types.GetCrossClusterTasksResponse) *shared.GetCrossClusterTasksResponse

FromAdminGetCrossClusterTasksResponse converts internal GetCrossClusterTasksResponse type to thrift

func FromAdminGetDLQReplicationMessagesRequest ¶ added in v1.2.7

func FromAdminGetDLQReplicationMessagesRequest(t *types.GetDLQReplicationMessagesRequest) *replicator.GetDLQReplicationMessagesRequest

FromAdminGetDLQReplicationMessagesRequest converts internal GetDLQReplicationMessagesRequest type to thrift

func FromAdminGetDLQReplicationMessagesResponse ¶ added in v1.2.7

func FromAdminGetDLQReplicationMessagesResponse(t *types.GetDLQReplicationMessagesResponse) *replicator.GetDLQReplicationMessagesResponse

FromAdminGetDLQReplicationMessagesResponse converts internal GetDLQReplicationMessagesResponse type to thrift

func FromAdminGetDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.8

func FromAdminGetDomainAsyncWorkflowConfiguratonRequest(in *types.GetDomainAsyncWorkflowConfiguratonRequest) *admin.GetDomainAsyncWorkflowConfiguratonRequest

func FromAdminGetDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.7

func FromAdminGetDomainAsyncWorkflowConfiguratonResponse(in *types.GetDomainAsyncWorkflowConfiguratonResponse) *admin.GetDomainAsyncWorkflowConfiguratonResponse

func FromAdminGetDomainIsolationGroupsRequest ¶ added in v1.2.7

func FromAdminGetDomainIsolationGroupsRequest(t *types.GetDomainIsolationGroupsRequest) *admin.GetDomainIsolationGroupsRequest

func FromAdminGetDomainIsolationGroupsResponse ¶ added in v1.2.7

func FromAdminGetDomainIsolationGroupsResponse(t *types.GetDomainIsolationGroupsResponse) *admin.GetDomainIsolationGroupsResponse

func FromAdminGetDomainReplicationMessagesRequest ¶ added in v1.2.7

func FromAdminGetDomainReplicationMessagesRequest(t *types.GetDomainReplicationMessagesRequest) *replicator.GetDomainReplicationMessagesRequest

FromAdminGetDomainReplicationMessagesRequest converts internal GetDomainReplicationMessagesRequest type to thrift

func FromAdminGetDomainReplicationMessagesResponse ¶ added in v1.2.7

func FromAdminGetDomainReplicationMessagesResponse(t *types.GetDomainReplicationMessagesResponse) *replicator.GetDomainReplicationMessagesResponse

FromAdminGetDomainReplicationMessagesResponse converts internal GetDomainReplicationMessagesResponse type to thrift

func FromAdminGetDynamicConfigRequest ¶ added in v1.2.7

func FromAdminGetDynamicConfigRequest(t *types.GetDynamicConfigRequest) *admin.GetDynamicConfigRequest

FromAdminGetDynamicConfigRequest converts internal GetDynamicConfigRequest type to thrift

func FromAdminGetDynamicConfigResponse ¶ added in v1.2.7

func FromAdminGetDynamicConfigResponse(t *types.GetDynamicConfigResponse) *admin.GetDynamicConfigResponse

FromAdminGetDynamicConfigResponse converts internal GetDynamicConfigResponse type to thrift

func FromAdminGetGlobalIsolationGroupsRequest ¶ added in v1.2.7

func FromAdminGetGlobalIsolationGroupsRequest(t *types.GetGlobalIsolationGroupsRequest) *admin.GetGlobalIsolationGroupsRequest

func FromAdminGetGlobalIsolationGroupsResponse ¶ added in v1.2.7

func FromAdminGetGlobalIsolationGroupsResponse(t *types.GetGlobalIsolationGroupsResponse) *admin.GetGlobalIsolationGroupsResponse

func FromAdminGetReplicationMessagesRequest ¶ added in v1.2.7

func FromAdminGetReplicationMessagesRequest(t *types.GetReplicationMessagesRequest) *replicator.GetReplicationMessagesRequest

FromAdminGetReplicationMessagesRequest converts internal GetReplicationMessagesRequest type to thrift

func FromAdminGetReplicationMessagesResponse ¶ added in v1.2.7

func FromAdminGetReplicationMessagesResponse(t *types.GetReplicationMessagesResponse) *replicator.GetReplicationMessagesResponse

FromAdminGetReplicationMessagesResponse converts internal GetReplicationMessagesResponse type to thrift

func FromAdminGetWorkflowExecutionRawHistoryV2Request ¶ added in v1.2.7

func FromAdminGetWorkflowExecutionRawHistoryV2Request(t *types.GetWorkflowExecutionRawHistoryV2Request) *admin.GetWorkflowExecutionRawHistoryV2Request

FromAdminGetWorkflowExecutionRawHistoryV2Request converts internal GetWorkflowExecutionRawHistoryV2Request type to thrift

func FromAdminGetWorkflowExecutionRawHistoryV2Response ¶ added in v1.2.7

func FromAdminGetWorkflowExecutionRawHistoryV2Response(t *types.GetWorkflowExecutionRawHistoryV2Response) *admin.GetWorkflowExecutionRawHistoryV2Response

FromAdminGetWorkflowExecutionRawHistoryV2Response converts internal GetWorkflowExecutionRawHistoryV2Response type to thrift

func FromAdminListDynamicConfigRequest ¶ added in v1.2.7

func FromAdminListDynamicConfigRequest(t *types.ListDynamicConfigRequest) *admin.ListDynamicConfigRequest

FromAdminListDynamicConfigRequest converts internal ListDynamicConfigRequest type to thrift

func FromAdminListDynamicConfigResponse ¶ added in v1.2.7

func FromAdminListDynamicConfigResponse(t *types.ListDynamicConfigResponse) *admin.ListDynamicConfigResponse

FromAdminListDynamicConfigResponse converts internal ListDynamicConfigResponse type to thrift

func FromAdminMaintainCorruptWorkflowRequest ¶ added in v1.2.7

func FromAdminMaintainCorruptWorkflowRequest(t *types.AdminMaintainWorkflowRequest) *admin.AdminMaintainWorkflowRequest

FromAdminMaintainCorruptWorkflowRequest converts internal AdminMaintainWorkflowRequest type to thrift

func FromAdminMaintainCorruptWorkflowResponse ¶ added in v1.2.7

func FromAdminMaintainCorruptWorkflowResponse(t *types.AdminMaintainWorkflowResponse) *admin.AdminMaintainWorkflowResponse

FromAdminMaintainCorruptWorkflowResponse converts internal AdminMaintainWorkflowResponse type to thrift

func FromAdminMergeDLQMessagesRequest ¶ added in v1.2.7

func FromAdminMergeDLQMessagesRequest(t *types.MergeDLQMessagesRequest) *replicator.MergeDLQMessagesRequest

FromAdminMergeDLQMessagesRequest converts internal MergeDLQMessagesRequest type to thrift

func FromAdminMergeDLQMessagesResponse ¶ added in v1.2.7

func FromAdminMergeDLQMessagesResponse(t *types.MergeDLQMessagesResponse) *replicator.MergeDLQMessagesResponse

FromAdminMergeDLQMessagesResponse converts internal MergeDLQMessagesResponse type to thrift

func FromAdminPurgeDLQMessagesRequest ¶ added in v1.2.7

func FromAdminPurgeDLQMessagesRequest(t *types.PurgeDLQMessagesRequest) *replicator.PurgeDLQMessagesRequest

FromAdminPurgeDLQMessagesRequest converts internal PurgeDLQMessagesRequest type to thrift

func FromAdminReadDLQMessagesRequest ¶ added in v1.2.7

func FromAdminReadDLQMessagesRequest(t *types.ReadDLQMessagesRequest) *replicator.ReadDLQMessagesRequest

FromAdminReadDLQMessagesRequest converts internal ReadDLQMessagesRequest type to thrift

func FromAdminReadDLQMessagesResponse ¶ added in v1.2.7

func FromAdminReadDLQMessagesResponse(t *types.ReadDLQMessagesResponse) *replicator.ReadDLQMessagesResponse

FromAdminReadDLQMessagesResponse converts internal ReadDLQMessagesResponse type to thrift

func FromAdminReapplyEventsRequest ¶ added in v1.2.7

func FromAdminReapplyEventsRequest(t *types.ReapplyEventsRequest) *shared.ReapplyEventsRequest

FromAdminReapplyEventsRequest converts internal ReapplyEventsRequest type to thrift

func FromAdminRemoveTaskRequest ¶ added in v1.2.7

func FromAdminRemoveTaskRequest(t *types.RemoveTaskRequest) *shared.RemoveTaskRequest

FromAdminRemoveTaskRequest converts internal RemoveTaskRequest type to thrift

func FromAdminResendReplicationTasksRequest ¶ added in v1.2.7

func FromAdminResendReplicationTasksRequest(t *types.ResendReplicationTasksRequest) *admin.ResendReplicationTasksRequest

FromAdminResendReplicationTasksRequest converts internal ResendReplicationTasksRequest type to thrift

func FromAdminResetQueueRequest ¶ added in v1.2.7

func FromAdminResetQueueRequest(t *types.ResetQueueRequest) *shared.ResetQueueRequest

FromAdminResetQueueRequest converts internal ResetQueueRequest type to thrift

func FromAdminRespondCrossClusterTasksCompletedRequest ¶ added in v1.2.7

func FromAdminRespondCrossClusterTasksCompletedRequest(t *types.RespondCrossClusterTasksCompletedRequest) *shared.RespondCrossClusterTasksCompletedRequest

FromAdminRespondCrossClusterTasksCompletedRequest converts internal RespondCrossClusterTasksCompletedRequest type to thrift

func FromAdminRespondCrossClusterTasksCompletedResponse ¶ added in v1.2.7

func FromAdminRespondCrossClusterTasksCompletedResponse(t *types.RespondCrossClusterTasksCompletedResponse) *shared.RespondCrossClusterTasksCompletedResponse

FromAdminRespondCrossClusterTasksCompletedResponse converts internal RespondCrossClusterTasksCompletedResponse type to thrift

func FromAdminRestoreDynamicConfigRequest ¶ added in v1.2.7

func FromAdminRestoreDynamicConfigRequest(t *types.RestoreDynamicConfigRequest) *admin.RestoreDynamicConfigRequest

FromAdminRestoreDynamicConfigRequest converts internal RestoreDynamicConfigRequest type to thrift

func FromAdminUpdateDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.8

func FromAdminUpdateDomainAsyncWorkflowConfiguratonRequest(in *types.UpdateDomainAsyncWorkflowConfiguratonRequest) *admin.UpdateDomainAsyncWorkflowConfiguratonRequest

func FromAdminUpdateDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.7

func FromAdminUpdateDomainAsyncWorkflowConfiguratonResponse(in *types.UpdateDomainAsyncWorkflowConfiguratonResponse) *admin.UpdateDomainAsyncWorkflowConfiguratonResponse

func FromAdminUpdateDomainIsolationGroupsRequest ¶ added in v1.2.7

func FromAdminUpdateDomainIsolationGroupsRequest(t *types.UpdateDomainIsolationGroupsRequest) *admin.UpdateDomainIsolationGroupsRequest

func FromAdminUpdateDomainIsolationGroupsResponse ¶ added in v1.2.7

func FromAdminUpdateDomainIsolationGroupsResponse(t *types.UpdateDomainIsolationGroupsResponse) *admin.UpdateDomainIsolationGroupsResponse

func FromAdminUpdateDynamicConfigRequest ¶ added in v1.2.7

func FromAdminUpdateDynamicConfigRequest(t *types.UpdateDynamicConfigRequest) *admin.UpdateDynamicConfigRequest

FromAdminUpdateDynamicConfigRequest converts internal UpdateDynamicConfigRequest type to thrift

func FromAdminUpdateGlobalIsolationGroupsRequest ¶ added in v1.2.7

func FromAdminUpdateGlobalIsolationGroupsRequest(t *types.UpdateGlobalIsolationGroupsRequest) *admin.UpdateGlobalIsolationGroupsRequest

func FromAdminUpdateGlobalIsolationGroupsResponse ¶ added in v1.2.7

func FromAdminUpdateGlobalIsolationGroupsResponse(t *types.UpdateGlobalIsolationGroupsResponse) *admin.UpdateGlobalIsolationGroupsResponse

func FromAny ¶ added in v1.2.10

func FromAny(t *types.Any) *shared.Any

FromAny converts internal Any type to thrift

func FromApplyParentClosePolicyAttributes ¶ added in v0.24.0

func FromApplyParentClosePolicyAttributes(
	t *types.ApplyParentClosePolicyAttributes,
) *shared.ApplyParentClosePolicyAttributes

FromApplyParentClosePolicyAttributes converts internal ApplyParentClosePolicyAttributes types to thrift

func FromApplyParentClosePolicyRequest ¶ added in v0.24.0

func FromApplyParentClosePolicyRequest(
	t *types.ApplyParentClosePolicyRequest,
) *shared.ApplyParentClosePolicyRequest

FromApplyParentClosePolicyRequest converts thrift ApplyParentClosePolicyRequest types to internal

func FromApplyParentClosePolicyRequestArray ¶ added in v0.24.0

func FromApplyParentClosePolicyRequestArray(
	t []*types.ApplyParentClosePolicyRequest,
) []*shared.ApplyParentClosePolicyRequest

FromApplyParentClosePolicyRequestArray converts thrift ApplyParentClosePolicyRequestArray types to internal

func FromApplyParentClosePolicyResult ¶ added in v0.24.0

func FromApplyParentClosePolicyResult(
	t *types.ApplyParentClosePolicyResult,
) *shared.ApplyParentClosePolicyResult

FromApplyParentClosePolicyResult converts thrift ApplyParentClosePolicyResult types to internal

func FromApplyParentClosePolicyResultArray ¶ added in v0.24.0

func FromApplyParentClosePolicyResultArray(
	t []*types.ApplyParentClosePolicyResult,
) []*shared.ApplyParentClosePolicyResult

FromApplyParentClosePolicyResultArray converts internal ApplyParentClosePolicyResultArray types to internal

func FromApplyParentClosePolicyStatus ¶ added in v0.24.0

func FromApplyParentClosePolicyStatus(
	t *types.ApplyParentClosePolicyStatus,
) *shared.ApplyParentClosePolicyStatus

FromApplyParentClosePolicyStatus converts thrift ApplyParentClosePolicyStatus types to internal

func FromArchivalStatus ¶

func FromArchivalStatus(t *types.ArchivalStatus) *shared.ArchivalStatus

FromArchivalStatus converts internal ArchivalStatus type to thrift

func FromAutoConfigHint ¶

func FromAutoConfigHint(t *types.AutoConfigHint) *shared.AutoConfigHint

FromWorkflowQuery converts internal WorkflowQuery type to thrift

func FromBadBinaries ¶

func FromBadBinaries(t *types.BadBinaries) *shared.BadBinaries

FromBadBinaries converts internal BadBinaries type to thrift

func FromBadBinaryInfo ¶

func FromBadBinaryInfo(t *types.BadBinaryInfo) *shared.BadBinaryInfo

FromBadBinaryInfo converts internal BadBinaryInfo type to thrift

func FromBadBinaryInfoMap ¶

func FromBadBinaryInfoMap(t map[string]*types.BadBinaryInfo) map[string]*shared.BadBinaryInfo

FromBadBinaryInfoMap converts internal BadBinaryInfo type map to thrift

func FromBadRequestError ¶

func FromBadRequestError(t *types.BadRequestError) *shared.BadRequestError

FromBadRequestError converts internal BadRequestError type to thrift

func FromCancelExternalWorkflowExecutionFailedCause ¶

func FromCancelExternalWorkflowExecutionFailedCause(t *types.CancelExternalWorkflowExecutionFailedCause) *shared.CancelExternalWorkflowExecutionFailedCause

FromCancelExternalWorkflowExecutionFailedCause converts internal CancelExternalWorkflowExecutionFailedCause type to thrift

func FromCancelTimerDecisionAttributes ¶

func FromCancelTimerDecisionAttributes(t *types.CancelTimerDecisionAttributes) *shared.CancelTimerDecisionAttributes

FromCancelTimerDecisionAttributes converts internal CancelTimerDecisionAttributes type to thrift

func FromCancelTimerFailedEventAttributes ¶

func FromCancelTimerFailedEventAttributes(t *types.CancelTimerFailedEventAttributes) *shared.CancelTimerFailedEventAttributes

FromCancelTimerFailedEventAttributes converts internal CancelTimerFailedEventAttributes type to thrift

func FromCancelWorkflowExecutionDecisionAttributes ¶

func FromCancelWorkflowExecutionDecisionAttributes(t *types.CancelWorkflowExecutionDecisionAttributes) *shared.CancelWorkflowExecutionDecisionAttributes

FromCancelWorkflowExecutionDecisionAttributes converts internal CancelWorkflowExecutionDecisionAttributes type to thrift

func FromCancellationAlreadyRequestedError ¶

func FromCancellationAlreadyRequestedError(t *types.CancellationAlreadyRequestedError) *shared.CancellationAlreadyRequestedError

FromCancellationAlreadyRequestedError converts internal CancellationAlreadyRequestedError type to thrift

func FromChildWorkflowExecutionCanceledEventAttributes ¶

func FromChildWorkflowExecutionCanceledEventAttributes(t *types.ChildWorkflowExecutionCanceledEventAttributes) *shared.ChildWorkflowExecutionCanceledEventAttributes

FromChildWorkflowExecutionCanceledEventAttributes converts internal ChildWorkflowExecutionCanceledEventAttributes type to thrift

func FromChildWorkflowExecutionCompletedEventAttributes ¶

func FromChildWorkflowExecutionCompletedEventAttributes(t *types.ChildWorkflowExecutionCompletedEventAttributes) *shared.ChildWorkflowExecutionCompletedEventAttributes

FromChildWorkflowExecutionCompletedEventAttributes converts internal ChildWorkflowExecutionCompletedEventAttributes type to thrift

func FromChildWorkflowExecutionFailedCause ¶

func FromChildWorkflowExecutionFailedCause(t *types.ChildWorkflowExecutionFailedCause) *shared.ChildWorkflowExecutionFailedCause

FromChildWorkflowExecutionFailedCause converts internal ChildWorkflowExecutionFailedCause type to thrift

func FromChildWorkflowExecutionFailedEventAttributes ¶

func FromChildWorkflowExecutionFailedEventAttributes(t *types.ChildWorkflowExecutionFailedEventAttributes) *shared.ChildWorkflowExecutionFailedEventAttributes

FromChildWorkflowExecutionFailedEventAttributes converts internal ChildWorkflowExecutionFailedEventAttributes type to thrift

func FromChildWorkflowExecutionStartedEventAttributes ¶

func FromChildWorkflowExecutionStartedEventAttributes(t *types.ChildWorkflowExecutionStartedEventAttributes) *shared.ChildWorkflowExecutionStartedEventAttributes

FromChildWorkflowExecutionStartedEventAttributes converts internal ChildWorkflowExecutionStartedEventAttributes type to thrift

func FromChildWorkflowExecutionTerminatedEventAttributes ¶

func FromChildWorkflowExecutionTerminatedEventAttributes(t *types.ChildWorkflowExecutionTerminatedEventAttributes) *shared.ChildWorkflowExecutionTerminatedEventAttributes

FromChildWorkflowExecutionTerminatedEventAttributes converts internal ChildWorkflowExecutionTerminatedEventAttributes type to thrift

func FromChildWorkflowExecutionTimedOutEventAttributes ¶

func FromChildWorkflowExecutionTimedOutEventAttributes(t *types.ChildWorkflowExecutionTimedOutEventAttributes) *shared.ChildWorkflowExecutionTimedOutEventAttributes

FromChildWorkflowExecutionTimedOutEventAttributes converts internal ChildWorkflowExecutionTimedOutEventAttributes type to thrift

func FromClientVersionNotSupportedError ¶

func FromClientVersionNotSupportedError(t *types.ClientVersionNotSupportedError) *shared.ClientVersionNotSupportedError

FromClientVersionNotSupportedError converts internal ClientVersionNotSupportedError type to thrift

func FromClusterReplicationConfiguration ¶

func FromClusterReplicationConfiguration(t *types.ClusterReplicationConfiguration) *shared.ClusterReplicationConfiguration

FromClusterReplicationConfiguration converts internal ClusterReplicationConfiguration type to thrift

func FromClusterReplicationConfigurationArray ¶

func FromClusterReplicationConfigurationArray(t []*types.ClusterReplicationConfiguration) []*shared.ClusterReplicationConfiguration

FromClusterReplicationConfigurationArray converts internal ClusterReplicationConfiguration type array to thrift

func FromCompleteWorkflowExecutionDecisionAttributes ¶

func FromCompleteWorkflowExecutionDecisionAttributes(t *types.CompleteWorkflowExecutionDecisionAttributes) *shared.CompleteWorkflowExecutionDecisionAttributes

FromCompleteWorkflowExecutionDecisionAttributes converts internal CompleteWorkflowExecutionDecisionAttributes type to thrift

func FromContinueAsNewInitiator ¶

func FromContinueAsNewInitiator(t *types.ContinueAsNewInitiator) *shared.ContinueAsNewInitiator

FromContinueAsNewInitiator converts internal ContinueAsNewInitiator type to thrift

func FromContinueAsNewWorkflowExecutionDecisionAttributes ¶

func FromContinueAsNewWorkflowExecutionDecisionAttributes(t *types.ContinueAsNewWorkflowExecutionDecisionAttributes) *shared.ContinueAsNewWorkflowExecutionDecisionAttributes

FromContinueAsNewWorkflowExecutionDecisionAttributes converts internal ContinueAsNewWorkflowExecutionDecisionAttributes type to thrift

func FromCountWorkflowExecutionsRequest ¶

func FromCountWorkflowExecutionsRequest(t *types.CountWorkflowExecutionsRequest) *shared.CountWorkflowExecutionsRequest

FromCountWorkflowExecutionsRequest converts internal CountWorkflowExecutionsRequest type to thrift

func FromCountWorkflowExecutionsResponse ¶

func FromCountWorkflowExecutionsResponse(t *types.CountWorkflowExecutionsResponse) *shared.CountWorkflowExecutionsResponse

FromCountWorkflowExecutionsResponse converts internal CountWorkflowExecutionsResponse type to thrift

func FromCrossClusterApplyParentClosePolicyRequestAttributes ¶ added in v0.24.0

func FromCrossClusterApplyParentClosePolicyRequestAttributes(
	t *types.CrossClusterApplyParentClosePolicyRequestAttributes,
) *shared.CrossClusterApplyParentClosePolicyRequestAttributes

FromCrossClusterApplyParentClosePolicyRequestAttributes converts internal CrossClusterApplyParentClosePolicyRequestAttributes types to thrift

func FromCrossClusterApplyParentClosePolicyResponseAttributes ¶ added in v0.24.0

func FromCrossClusterApplyParentClosePolicyResponseAttributes(
	t *types.CrossClusterApplyParentClosePolicyResponseAttributes,
) *shared.CrossClusterApplyParentClosePolicyResponseAttributes

FromCrossClusterApplyParentClosePolicyResponseAttributes converts internal CrossClusterApplyParentClosePolicyResponseAttributes type to thrift

func FromCrossClusterCancelExecutionRequestAttributes ¶ added in v0.23.1

func FromCrossClusterCancelExecutionRequestAttributes(t *types.CrossClusterCancelExecutionRequestAttributes) *shared.CrossClusterCancelExecutionRequestAttributes

FromCrossClusterCancelExecutionRequestAttributes converts internal CrossClusterCancelExecutionRequestAttributes type to thrift

func FromCrossClusterCancelExecutionResponseAttributes ¶ added in v0.23.1

func FromCrossClusterCancelExecutionResponseAttributes(t *types.CrossClusterCancelExecutionResponseAttributes) *shared.CrossClusterCancelExecutionResponseAttributes

FromCrossClusterCancelExecutionResponseAttributes converts internal CrossClusterCancelExecutionResponseAttributes type to thrift

func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes ¶ added in v0.24.0

func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(
	t *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes,
) *shared.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes

FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes converts internal CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes type to thrift

func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes ¶ added in v0.24.0

func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(
	t *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes,
) *shared.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes

FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes converts internal CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes type to thrift

func FromCrossClusterSignalExecutionRequestAttributes ¶ added in v0.23.1

func FromCrossClusterSignalExecutionRequestAttributes(t *types.CrossClusterSignalExecutionRequestAttributes) *shared.CrossClusterSignalExecutionRequestAttributes

FromCrossClusterSignalExecutionRequestAttributes converts internal CrossClusterSignalExecutionRequestAttributes type to thrift

func FromCrossClusterSignalExecutionResponseAttributes ¶ added in v0.23.1

func FromCrossClusterSignalExecutionResponseAttributes(t *types.CrossClusterSignalExecutionResponseAttributes) *shared.CrossClusterSignalExecutionResponseAttributes

FromCrossClusterSignalExecutionResponseAttributes converts internal CrossClusterSignalExecutionResponseAttributes type to thrift

func FromCrossClusterStartChildExecutionRequestAttributes ¶ added in v0.23.1

func FromCrossClusterStartChildExecutionRequestAttributes(t *types.CrossClusterStartChildExecutionRequestAttributes) *shared.CrossClusterStartChildExecutionRequestAttributes

FromCrossClusterStartChildExecutionRequestAttributes converts internal CrossClusterStartChildExecutionRequestAttributes type to thrift

func FromCrossClusterStartChildExecutionResponseAttributes ¶ added in v0.23.1

func FromCrossClusterStartChildExecutionResponseAttributes(t *types.CrossClusterStartChildExecutionResponseAttributes) *shared.CrossClusterStartChildExecutionResponseAttributes

FromCrossClusterStartChildExecutionResponseAttributes converts internal CrossClusterStartChildExecutionResponseAttributes type to thrift

func FromCrossClusterTaskFailedCause ¶ added in v0.23.1

func FromCrossClusterTaskFailedCause(t *types.CrossClusterTaskFailedCause) *shared.CrossClusterTaskFailedCause

FromCrossClusterTaskFailedCause converts internal CrossClusterTaskFailedCause type to thrift

func FromCrossClusterTaskInfo ¶ added in v0.23.1

func FromCrossClusterTaskInfo(t *types.CrossClusterTaskInfo) *shared.CrossClusterTaskInfo

FromCrossClusterTaskInfo converts internal CrossClusterTaskInfo type to thrift

func FromCrossClusterTaskRequest ¶ added in v0.23.1

func FromCrossClusterTaskRequest(t *types.CrossClusterTaskRequest) *shared.CrossClusterTaskRequest

FromCrossClusterTaskRequest converts internal CrossClusterTaskRequest type to thrift

func FromCrossClusterTaskRequestArray ¶ added in v0.23.1

func FromCrossClusterTaskRequestArray(t []*types.CrossClusterTaskRequest) []*shared.CrossClusterTaskRequest

FromCrossClusterTaskRequestArray converts internal CrossClusterTaskRequest type array to thrift

func FromCrossClusterTaskRequestMap ¶ added in v0.23.1

func FromCrossClusterTaskRequestMap(t map[int32][]*types.CrossClusterTaskRequest) map[int32][]*shared.CrossClusterTaskRequest

FromCrossClusterTaskRequestMap converts internal CrossClusterTaskRequest type map to thrift

func FromCrossClusterTaskResponse ¶ added in v0.23.1

func FromCrossClusterTaskResponse(t *types.CrossClusterTaskResponse) *shared.CrossClusterTaskResponse

FromCrossClusterTaskResponse converts internal CrossClusterTaskResponse type to thrift

func FromCrossClusterTaskResponseArray ¶ added in v0.23.1

func FromCrossClusterTaskResponseArray(t []*types.CrossClusterTaskResponse) []*shared.CrossClusterTaskResponse

FromCrossClusterTaskResponseArray converts internal CrossClusterTaskResponse type array to thrift

func FromCrossClusterTaskType ¶ added in v0.23.1

func FromCrossClusterTaskType(t *types.CrossClusterTaskType) *shared.CrossClusterTaskType

FromCrossClusterTaskType converts internal CrossClusterTaskType type to thrift

func FromCurrentBranchChangedError ¶

func FromCurrentBranchChangedError(t *types.CurrentBranchChangedError) *shared.CurrentBranchChangedError

FromCurrentBranchChangedError converts internal CurrentBranchChangedError type to thrift

func FromDLQType ¶ added in v0.17.0

func FromDLQType(t *types.DLQType) *replicator.DLQType

FromDLQType converts internal DLQType type to thrift

func FromDataBlob ¶

func FromDataBlob(t *types.DataBlob) *shared.DataBlob

FromDataBlob converts internal DataBlob type to thrift

func FromDataBlobArray ¶

func FromDataBlobArray(t []*types.DataBlob) []*shared.DataBlob

FromDataBlobArray converts internal DataBlob type array to thrift

func FromDecision ¶

func FromDecision(t *types.Decision) *shared.Decision

FromDecision converts internal Decision type to thrift

func FromDecisionArray ¶

func FromDecisionArray(t []*types.Decision) []*shared.Decision

FromDecisionArray converts internal Decision type array to thrift

func FromDecisionTaskCompletedEventAttributes ¶

func FromDecisionTaskCompletedEventAttributes(t *types.DecisionTaskCompletedEventAttributes) *shared.DecisionTaskCompletedEventAttributes

FromDecisionTaskCompletedEventAttributes converts internal DecisionTaskCompletedEventAttributes type to thrift

func FromDecisionTaskFailedCause ¶

func FromDecisionTaskFailedCause(t *types.DecisionTaskFailedCause) *shared.DecisionTaskFailedCause

FromDecisionTaskFailedCause converts internal DecisionTaskFailedCause type to thrift

func FromDecisionTaskFailedEventAttributes ¶

func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttributes) *shared.DecisionTaskFailedEventAttributes

FromDecisionTaskFailedEventAttributes converts internal DecisionTaskFailedEventAttributes type to thrift

func FromDecisionTaskScheduledEventAttributes ¶

func FromDecisionTaskScheduledEventAttributes(t *types.DecisionTaskScheduledEventAttributes) *shared.DecisionTaskScheduledEventAttributes

FromDecisionTaskScheduledEventAttributes converts internal DecisionTaskScheduledEventAttributes type to thrift

func FromDecisionTaskStartedEventAttributes ¶

func FromDecisionTaskStartedEventAttributes(t *types.DecisionTaskStartedEventAttributes) *shared.DecisionTaskStartedEventAttributes

FromDecisionTaskStartedEventAttributes converts internal DecisionTaskStartedEventAttributes type to thrift

func FromDecisionTaskTimedOutCause ¶ added in v0.18.0

func FromDecisionTaskTimedOutCause(t *types.DecisionTaskTimedOutCause) *shared.DecisionTaskTimedOutCause

FromDecisionTaskTimedOutCause converts internal DecisionTaskTimedOutCause type to thrift

func FromDecisionTaskTimedOutEventAttributes ¶

func FromDecisionTaskTimedOutEventAttributes(t *types.DecisionTaskTimedOutEventAttributes) *shared.DecisionTaskTimedOutEventAttributes

FromDecisionTaskTimedOutEventAttributes converts internal DecisionTaskTimedOutEventAttributes type to thrift

func FromDecisionType ¶

func FromDecisionType(t *types.DecisionType) *shared.DecisionType

FromDecisionType converts internal DecisionType type to thrift

func FromDeprecateDomainRequest ¶

func FromDeprecateDomainRequest(t *types.DeprecateDomainRequest) *shared.DeprecateDomainRequest

FromDeprecateDomainRequest converts internal DeprecateDomainRequest type to thrift

func FromDescribeDomainRequest ¶

func FromDescribeDomainRequest(t *types.DescribeDomainRequest) *shared.DescribeDomainRequest

FromDescribeDomainRequest converts internal DescribeDomainRequest type to thrift

func FromDescribeDomainResponse ¶

func FromDescribeDomainResponse(t *types.DescribeDomainResponse) *shared.DescribeDomainResponse

FromDescribeDomainResponse converts internal DescribeDomainResponse type to thrift

func FromDescribeDomainResponseArray ¶

func FromDescribeDomainResponseArray(t []*types.DescribeDomainResponse) []*shared.DescribeDomainResponse

FromDescribeDomainResponseArray converts internal DescribeDomainResponse type array to thrift

func FromDescribeTaskListRequest ¶

func FromDescribeTaskListRequest(t *types.DescribeTaskListRequest) *shared.DescribeTaskListRequest

FromDescribeTaskListRequest converts internal DescribeTaskListRequest type to thrift

func FromDescribeTaskListResponse ¶

func FromDescribeTaskListResponse(t *types.DescribeTaskListResponse) *shared.DescribeTaskListResponse

FromDescribeTaskListResponse converts internal DescribeTaskListResponse type to thrift

func FromDescribeTaskListResponseMap ¶ added in v0.24.0

func FromDescribeTaskListResponseMap(t map[string]*types.DescribeTaskListResponse) map[string]*shared.DescribeTaskListResponse

FromDescribeTaskListResponseMap converts internal DescribeTaskListResponse map type to thrift

func FromDescribeWorkflowExecutionRequest ¶

func FromDescribeWorkflowExecutionRequest(t *types.DescribeWorkflowExecutionRequest) *shared.DescribeWorkflowExecutionRequest

FromDescribeWorkflowExecutionRequest converts internal DescribeWorkflowExecutionRequest type to thrift

func FromDescribeWorkflowExecutionResponse ¶

func FromDescribeWorkflowExecutionResponse(t *types.DescribeWorkflowExecutionResponse) *shared.DescribeWorkflowExecutionResponse

FromDescribeWorkflowExecutionResponse converts internal DescribeWorkflowExecutionResponse type to thrift

func FromDiagnoseWorkflowExecutionRequest ¶ added in v1.2.14

func FromDiagnoseWorkflowExecutionRequest(t *types.DiagnoseWorkflowExecutionRequest) *shared.DiagnoseWorkflowExecutionRequest

FromDiagnoseWorkflowExecutionRequest converts internal DiagnoseWorkflowExecutionRequest type to thrift

func FromDiagnoseWorkflowExecutionResponse ¶ added in v1.2.14

func FromDiagnoseWorkflowExecutionResponse(t *types.DiagnoseWorkflowExecutionResponse) *shared.DiagnoseWorkflowExecutionResponse

FromDiagnoseWorkflowExecutionResponse converts internal DiagnoseWorkflowExecutionResponse type to thrift

func FromDomainAlreadyExistsError ¶

func FromDomainAlreadyExistsError(t *types.DomainAlreadyExistsError) *shared.DomainAlreadyExistsError

FromDomainAlreadyExistsError converts internal DomainAlreadyExistsError type to thrift

func FromDomainAsyncWorkflowConfiguraton ¶ added in v1.2.7

func FromDomainAsyncWorkflowConfiguraton(in *types.AsyncWorkflowConfiguration) *shared.AsyncWorkflowConfiguration

func FromDomainCacheInfo ¶

func FromDomainCacheInfo(t *types.DomainCacheInfo) *shared.DomainCacheInfo

FromDomainCacheInfo converts internal DomainCacheInfo type to thrift

func FromDomainConfiguration ¶

func FromDomainConfiguration(t *types.DomainConfiguration) *shared.DomainConfiguration

FromDomainConfiguration converts internal DomainConfiguration type to thrift

func FromDomainFilter ¶ added in v0.17.0

func FromDomainFilter(t *types.DomainFilter) *history.DomainFilter

FromDomainFilter converts internal DomainFilter type to thrift

func FromDomainInfo ¶

func FromDomainInfo(t *types.DomainInfo) *shared.DomainInfo

FromDomainInfo converts internal DomainInfo type to thrift

func FromDomainNotActiveError ¶

func FromDomainNotActiveError(t *types.DomainNotActiveError) *shared.DomainNotActiveError

FromDomainNotActiveError converts internal DomainNotActiveError type to thrift

func FromDomainOperation ¶ added in v0.17.0

func FromDomainOperation(t *types.DomainOperation) *replicator.DomainOperation

FromDomainOperation converts internal DomainOperation type to thrift

func FromDomainReplicationConfiguration ¶

func FromDomainReplicationConfiguration(t *types.DomainReplicationConfiguration) *shared.DomainReplicationConfiguration

FromDomainReplicationConfiguration converts internal DomainReplicationConfiguration type to thrift

func FromDomainStatus ¶

func FromDomainStatus(t *types.DomainStatus) *shared.DomainStatus

FromDomainStatus converts internal DomainStatus type to thrift

func FromDomainTaskAttributes ¶ added in v0.17.0

func FromDomainTaskAttributes(t *types.DomainTaskAttributes) *replicator.DomainTaskAttributes

FromDomainTaskAttributes converts internal DomainTaskAttributes type to thrift

func FromDynamicConfigBlob ¶ added in v0.23.1

func FromDynamicConfigBlob(t *types.DynamicConfigBlob) *config.DynamicConfigBlob

FromDynamicConfigBlob converts internal DynamicConfigBlob type to thrift

func FromDynamicConfigEntry ¶ added in v0.23.1

func FromDynamicConfigEntry(t *types.DynamicConfigEntry) *config.DynamicConfigEntry

FromDynamicConfigEntry converts internal DynamicConfigEntry type to thrift

func FromDynamicConfigEntryArray ¶ added in v0.23.1

func FromDynamicConfigEntryArray(t []*types.DynamicConfigEntry) []*config.DynamicConfigEntry

FromDynamicConfigEntryArray converts internal DynamicConfigEntry array type to thrift

func FromDynamicConfigFilter ¶ added in v0.23.1

func FromDynamicConfigFilter(t *types.DynamicConfigFilter) *config.DynamicConfigFilter

FromDynamicConfigFilter converts internal DynamicConfigFilter type to thrift

func FromDynamicConfigFilterArray ¶ added in v0.23.1

func FromDynamicConfigFilterArray(t []*types.DynamicConfigFilter) []*config.DynamicConfigFilter

FromDynamicConfigFilterArray converts internal DynamicConfigFilter array type to thrift

func FromDynamicConfigValue ¶ added in v0.23.1

func FromDynamicConfigValue(t *types.DynamicConfigValue) *config.DynamicConfigValue

FromDynamicConfigValue converts internal DynamicConfigValue type to thrift

func FromDynamicConfigValueArray ¶ added in v0.23.1

func FromDynamicConfigValueArray(t []*types.DynamicConfigValue) []*config.DynamicConfigValue

FromDynamicConfigValueArray converts internal DynamicConfigValue array type to thrift

func FromEncodingType ¶

func FromEncodingType(t *types.EncodingType) *shared.EncodingType

FromEncodingType converts internal EncodingType type to thrift

func FromEntityNotExistsError ¶

func FromEntityNotExistsError(t *types.EntityNotExistsError) *shared.EntityNotExistsError

FromEntityNotExistsError converts internal EntityNotExistsError type to thrift

func FromError ¶

func FromError(err error) error

FromError convert error to Thrift type if it comes as its internal equivalent

func FromEventAlreadyStartedError ¶ added in v0.17.0

func FromEventAlreadyStartedError(t *types.EventAlreadyStartedError) *history.EventAlreadyStartedError

FromEventAlreadyStartedError converts internal EventAlreadyStartedError type to thrift

func FromEventType ¶

func FromEventType(t *types.EventType) *shared.EventType

FromEventType converts internal EventType type to thrift

func FromExternalWorkflowExecutionCancelRequestedEventAttributes ¶

func FromExternalWorkflowExecutionCancelRequestedEventAttributes(t *types.ExternalWorkflowExecutionCancelRequestedEventAttributes) *shared.ExternalWorkflowExecutionCancelRequestedEventAttributes

FromExternalWorkflowExecutionCancelRequestedEventAttributes converts internal ExternalWorkflowExecutionCancelRequestedEventAttributes type to thrift

func FromExternalWorkflowExecutionSignaledEventAttributes ¶

func FromExternalWorkflowExecutionSignaledEventAttributes(t *types.ExternalWorkflowExecutionSignaledEventAttributes) *shared.ExternalWorkflowExecutionSignaledEventAttributes

FromExternalWorkflowExecutionSignaledEventAttributes converts internal ExternalWorkflowExecutionSignaledEventAttributes type to thrift

func FromFailWorkflowExecutionDecisionAttributes ¶

func FromFailWorkflowExecutionDecisionAttributes(t *types.FailWorkflowExecutionDecisionAttributes) *shared.FailWorkflowExecutionDecisionAttributes

FromFailWorkflowExecutionDecisionAttributes converts internal FailWorkflowExecutionDecisionAttributes type to thrift

func FromFailoverInfo ¶ added in v0.24.0

func FromFailoverInfo(t *types.FailoverInfo) *shared.FailoverInfo

FromFailoverInfo converts internal FailoverInfo type to thrift

func FromFailoverMarkerAttributes ¶ added in v0.17.0

func FromFailoverMarkerAttributes(t *types.FailoverMarkerAttributes) *replicator.FailoverMarkerAttributes

FromFailoverMarkerAttributes converts internal FailoverMarkerAttributes type to thrift

func FromFailoverMarkerAttributesArray ¶ added in v0.17.0

func FromFailoverMarkerAttributesArray(t []*types.FailoverMarkerAttributes) []*replicator.FailoverMarkerAttributes

FromFailoverMarkerAttributesArray converts internal FailoverMarkerAttributes type array to thrift

func FromFailoverMarkerToken ¶ added in v0.17.0

func FromFailoverMarkerToken(t *types.FailoverMarkerToken) *history.FailoverMarkerToken

FromFailoverMarkerToken converts internal FailoverMarkerToken type to thrift

func FromFailoverMarkerTokenArray ¶ added in v0.17.0

func FromFailoverMarkerTokenArray(t []*types.FailoverMarkerToken) []*history.FailoverMarkerToken

FromFailoverMarkerTokenArray converts internal FailoverMarkerToken type array to thrift

func FromFailoverMarkers ¶ added in v0.17.0

func FromFailoverMarkers(t *types.FailoverMarkers) *replicator.FailoverMarkers

FromFailoverMarkers converts internal FailoverMarkers type to thrift

func FromFeatureNotEnabledError ¶ added in v0.22.0

func FromFeatureNotEnabledError(t *types.FeatureNotEnabledError) *shared.FeatureNotEnabledError

FromFeatureNotEnabledError converts internal FeatureNotEnabledError type to thrift

func FromGetClusterInfoResponse ¶ added in v1.2.7

func FromGetClusterInfoResponse(t *types.ClusterInfo) *shared.ClusterInfo

FromGetClusterInfoResponse converts internal ClusterInfo type to thrift

func FromGetFailoverInfoRequest ¶ added in v0.24.0

func FromGetFailoverInfoRequest(t *types.GetFailoverInfoRequest) *history.GetFailoverInfoRequest

FromGetFailoverInfoRequest converts internal GetFailoverInfoRequest type to thrift

func FromGetFailoverInfoResponse ¶ added in v0.24.0

func FromGetFailoverInfoResponse(t *types.GetFailoverInfoResponse) *history.GetFailoverInfoResponse

FromGetFailoverInfoResponse converts internal GetFailoverInfoRequest type to thrift

func FromGetSearchAttributesResponse ¶

func FromGetSearchAttributesResponse(t *types.GetSearchAttributesResponse) *shared.GetSearchAttributesResponse

FromGetSearchAttributesResponse converts internal GetSearchAttributesResponse type to thrift

func FromGetTaskFailedCause ¶ added in v0.23.1

func FromGetTaskFailedCause(t *types.GetTaskFailedCause) *shared.GetTaskFailedCause

FromGetTaskFailedCause converts internal GetTaskFailedCause to thrift

func FromGetTaskFailedCauseMap ¶ added in v0.23.1

func FromGetTaskFailedCauseMap(t map[int32]types.GetTaskFailedCause) map[int32]shared.GetTaskFailedCause

FromGetTaskFailedCauseMap converts internal GetTaskFailedCause type map to thrift

func FromGetTaskListsByDomainRequest ¶ added in v0.23.1

func FromGetTaskListsByDomainRequest(t *types.GetTaskListsByDomainRequest) *shared.GetTaskListsByDomainRequest

FromGetTaskListsByDomainRequest converts internal GetTaskListsByDomainRequest type to thrift

func FromGetTaskListsByDomainResponse ¶ added in v0.23.1

func FromGetTaskListsByDomainResponse(t *types.GetTaskListsByDomainResponse) *shared.GetTaskListsByDomainResponse

FromGetTaskListsByDomainResponse converts internal GetTaskListsByDomainResponse type to thrift

func FromGetWorkflowExecutionHistoryRequest ¶

func FromGetWorkflowExecutionHistoryRequest(t *types.GetWorkflowExecutionHistoryRequest) *shared.GetWorkflowExecutionHistoryRequest

FromGetWorkflowExecutionHistoryRequest converts internal GetWorkflowExecutionHistoryRequest type to thrift

func FromGetWorkflowExecutionHistoryResponse ¶

func FromGetWorkflowExecutionHistoryResponse(t *types.GetWorkflowExecutionHistoryResponse) *shared.GetWorkflowExecutionHistoryResponse

FromGetWorkflowExecutionHistoryResponse converts internal GetWorkflowExecutionHistoryResponse type to thrift

func FromHeader ¶

func FromHeader(t *types.Header) *shared.Header

FromHeader converts internal Header type to thrift

func FromHealthStatus ¶ added in v0.18.0

func FromHealthStatus(t *types.HealthStatus) *health.HealthStatus

FromHealthStatus converts internal HealthStatus type to thrift

func FromHistory ¶

func FromHistory(t *types.History) *shared.History

FromHistory converts internal History type to thrift

func FromHistoryArray ¶ added in v0.18.0

func FromHistoryArray(t []*types.History) []*shared.History

FromHistoryArray converts internal History array to thrift

func FromHistoryBranch ¶

func FromHistoryBranch(t *types.HistoryBranch) *shared.HistoryBranch

FromHistoryBranch converts internal HistoryBranch type to thrift

func FromHistoryBranchRange ¶

func FromHistoryBranchRange(t *types.HistoryBranchRange) *shared.HistoryBranchRange

FromHistoryBranchRange converts internal HistoryBranchRange type to thrift

func FromHistoryBranchRangeArray ¶

func FromHistoryBranchRangeArray(t []*types.HistoryBranchRange) []*shared.HistoryBranchRange

FromHistoryBranchRangeArray converts internal HistoryBranchRange type array to thrift

func FromHistoryDescribeMutableStateRequest ¶ added in v1.2.7

func FromHistoryDescribeMutableStateRequest(t *types.DescribeMutableStateRequest) *history.DescribeMutableStateRequest

FromHistoryDescribeMutableStateRequest converts internal DescribeMutableStateRequest type to thrift

func FromHistoryDescribeMutableStateResponse ¶ added in v1.2.7

func FromHistoryDescribeMutableStateResponse(t *types.DescribeMutableStateResponse) *history.DescribeMutableStateResponse

FromHistoryDescribeMutableStateResponse converts internal DescribeMutableStateResponse type to thrift

func FromHistoryDescribeWorkflowExecutionRequest ¶ added in v0.17.0

func FromHistoryDescribeWorkflowExecutionRequest(t *types.HistoryDescribeWorkflowExecutionRequest) *history.DescribeWorkflowExecutionRequest

FromHistoryDescribeWorkflowExecutionRequest converts internal DescribeWorkflowExecutionRequest type to thrift

func FromHistoryEvent ¶

func FromHistoryEvent(t *types.HistoryEvent) *shared.HistoryEvent

FromHistoryEvent converts internal HistoryEvent type to thrift

func FromHistoryEventArray ¶

func FromHistoryEventArray(t []*types.HistoryEvent) []*shared.HistoryEvent

FromHistoryEventArray converts internal HistoryEvent type array to thrift

func FromHistoryEventFilterType ¶

func FromHistoryEventFilterType(t *types.HistoryEventFilterType) *shared.HistoryEventFilterType

FromHistoryEventFilterType converts internal HistoryEventFilterType type to thrift

func FromHistoryGetMutableStateRequest ¶ added in v1.2.7

func FromHistoryGetMutableStateRequest(t *types.GetMutableStateRequest) *history.GetMutableStateRequest

FromHistoryGetMutableStateRequest converts internal GetMutableStateRequest type to thrift

func FromHistoryGetMutableStateResponse ¶ added in v1.2.7

func FromHistoryGetMutableStateResponse(t *types.GetMutableStateResponse) *history.GetMutableStateResponse

FromHistoryGetMutableStateResponse converts internal GetMutableStateResponse type to thrift

func FromHistoryNotifyFailoverMarkersRequest ¶ added in v1.2.7

func FromHistoryNotifyFailoverMarkersRequest(t *types.NotifyFailoverMarkersRequest) *history.NotifyFailoverMarkersRequest

FromHistoryNotifyFailoverMarkersRequest converts internal NotifyFailoverMarkersRequest type to thrift

func FromHistoryPollMutableStateRequest ¶ added in v1.2.7

func FromHistoryPollMutableStateRequest(t *types.PollMutableStateRequest) *history.PollMutableStateRequest

FromHistoryPollMutableStateRequest converts internal PollMutableStateRequest type to thrift

func FromHistoryPollMutableStateResponse ¶ added in v1.2.7

func FromHistoryPollMutableStateResponse(t *types.PollMutableStateResponse) *history.PollMutableStateResponse

FromHistoryPollMutableStateResponse converts internal PollMutableStateResponse type to thrift

func FromHistoryQueryWorkflowRequest ¶ added in v0.17.0

func FromHistoryQueryWorkflowRequest(t *types.HistoryQueryWorkflowRequest) *history.QueryWorkflowRequest

FromHistoryQueryWorkflowRequest converts internal QueryWorkflowRequest type to thrift

func FromHistoryQueryWorkflowResponse ¶ added in v0.17.0

func FromHistoryQueryWorkflowResponse(t *types.HistoryQueryWorkflowResponse) *history.QueryWorkflowResponse

FromHistoryQueryWorkflowResponse converts internal QueryWorkflowResponse type to thrift

func FromHistoryRatelimitUpdateRequest ¶ added in v1.2.12

func FromHistoryRatelimitUpdateRequest(t *types.RatelimitUpdateRequest) *history.RatelimitUpdateRequest

func FromHistoryRatelimitUpdateResponse ¶ added in v1.2.10

func FromHistoryRatelimitUpdateResponse(t *types.RatelimitUpdateResponse) *history.RatelimitUpdateResponse

func FromHistoryReapplyEventsRequest ¶ added in v0.17.0

func FromHistoryReapplyEventsRequest(t *types.HistoryReapplyEventsRequest) *history.ReapplyEventsRequest

FromHistoryReapplyEventsRequest converts internal ReapplyEventsRequest type to thrift

func FromHistoryRecordActivityTaskHeartbeatRequest ¶ added in v0.17.0

func FromHistoryRecordActivityTaskHeartbeatRequest(t *types.HistoryRecordActivityTaskHeartbeatRequest) *history.RecordActivityTaskHeartbeatRequest

FromHistoryRecordActivityTaskHeartbeatRequest converts internal RecordActivityTaskHeartbeatRequest type to thrift

func FromHistoryRefreshWorkflowTasksRequest ¶ added in v0.17.0

func FromHistoryRefreshWorkflowTasksRequest(t *types.HistoryRefreshWorkflowTasksRequest) *history.RefreshWorkflowTasksRequest

FromHistoryRefreshWorkflowTasksRequest converts internal RefreshWorkflowTasksRequest type to thrift

func FromHistoryRemoveSignalMutableStateRequest ¶ added in v1.2.7

func FromHistoryRemoveSignalMutableStateRequest(t *types.RemoveSignalMutableStateRequest) *history.RemoveSignalMutableStateRequest

FromHistoryRemoveSignalMutableStateRequest converts internal RemoveSignalMutableStateRequest type to thrift

func FromHistoryReplicateEventsV2Request ¶ added in v1.2.7

func FromHistoryReplicateEventsV2Request(t *types.ReplicateEventsV2Request) *history.ReplicateEventsV2Request

FromHistoryReplicateEventsV2Request converts internal ReplicateEventsV2Request type to thrift

func FromHistoryRequestCancelWorkflowExecutionRequest ¶ added in v0.17.0

func FromHistoryRequestCancelWorkflowExecutionRequest(t *types.HistoryRequestCancelWorkflowExecutionRequest) *history.RequestCancelWorkflowExecutionRequest

FromHistoryRequestCancelWorkflowExecutionRequest converts internal RequestCancelWorkflowExecutionRequest type to thrift

func FromHistoryResetStickyTaskListRequest ¶ added in v0.17.0

func FromHistoryResetStickyTaskListRequest(t *types.HistoryResetStickyTaskListRequest) *history.ResetStickyTaskListRequest

FromHistoryResetStickyTaskListRequest converts internal ResetStickyTaskListRequest type to thrift

func FromHistoryResetStickyTaskListResponse ¶ added in v0.17.0

func FromHistoryResetStickyTaskListResponse(t *types.HistoryResetStickyTaskListResponse) *history.ResetStickyTaskListResponse

FromHistoryResetStickyTaskListResponse converts internal ResetStickyTaskListResponse type to thrift

func FromHistoryResetWorkflowExecutionRequest ¶ added in v0.17.0

func FromHistoryResetWorkflowExecutionRequest(t *types.HistoryResetWorkflowExecutionRequest) *history.ResetWorkflowExecutionRequest

FromHistoryResetWorkflowExecutionRequest converts internal ResetWorkflowExecutionRequest type to thrift

func FromHistoryRespondActivityTaskCanceledRequest ¶ added in v0.17.0

func FromHistoryRespondActivityTaskCanceledRequest(t *types.HistoryRespondActivityTaskCanceledRequest) *history.RespondActivityTaskCanceledRequest

FromHistoryRespondActivityTaskCanceledRequest converts internal RespondActivityTaskCanceledRequest type to thrift

func FromHistoryRespondActivityTaskCompletedRequest ¶ added in v0.17.0

func FromHistoryRespondActivityTaskCompletedRequest(t *types.HistoryRespondActivityTaskCompletedRequest) *history.RespondActivityTaskCompletedRequest

FromHistoryRespondActivityTaskCompletedRequest converts internal RespondActivityTaskCompletedRequest type to thrift

func FromHistoryRespondActivityTaskFailedRequest ¶ added in v0.17.0

func FromHistoryRespondActivityTaskFailedRequest(t *types.HistoryRespondActivityTaskFailedRequest) *history.RespondActivityTaskFailedRequest

FromHistoryRespondActivityTaskFailedRequest converts internal RespondActivityTaskFailedRequest type to thrift

func FromHistoryRespondDecisionTaskCompletedRequest ¶ added in v0.17.0

func FromHistoryRespondDecisionTaskCompletedRequest(t *types.HistoryRespondDecisionTaskCompletedRequest) *history.RespondDecisionTaskCompletedRequest

FromHistoryRespondDecisionTaskCompletedRequest converts internal RespondDecisionTaskCompletedRequest type to thrift

func FromHistoryRespondDecisionTaskCompletedResponse ¶ added in v0.17.0

func FromHistoryRespondDecisionTaskCompletedResponse(t *types.HistoryRespondDecisionTaskCompletedResponse) *history.RespondDecisionTaskCompletedResponse

FromHistoryRespondDecisionTaskCompletedResponse converts internal RespondDecisionTaskCompletedResponse type to thrift

func FromHistoryRespondDecisionTaskFailedRequest ¶ added in v0.17.0

func FromHistoryRespondDecisionTaskFailedRequest(t *types.HistoryRespondDecisionTaskFailedRequest) *history.RespondDecisionTaskFailedRequest

FromHistoryRespondDecisionTaskFailedRequest converts internal RespondDecisionTaskFailedRequest type to thrift

func FromHistoryScheduleDecisionTaskRequest ¶ added in v1.2.7

func FromHistoryScheduleDecisionTaskRequest(t *types.ScheduleDecisionTaskRequest) *history.ScheduleDecisionTaskRequest

FromHistoryScheduleDecisionTaskRequest converts internal ScheduleDecisionTaskRequest type to thrift

func FromHistorySignalWithStartWorkflowExecutionRequest ¶ added in v0.17.0

func FromHistorySignalWithStartWorkflowExecutionRequest(t *types.HistorySignalWithStartWorkflowExecutionRequest) *history.SignalWithStartWorkflowExecutionRequest

FromHistorySignalWithStartWorkflowExecutionRequest converts internal SignalWithStartWorkflowExecutionRequest type to thrift

func FromHistorySignalWorkflowExecutionRequest ¶ added in v0.17.0

func FromHistorySignalWorkflowExecutionRequest(t *types.HistorySignalWorkflowExecutionRequest) *history.SignalWorkflowExecutionRequest

FromHistorySignalWorkflowExecutionRequest converts internal SignalWorkflowExecutionRequest type to thrift

func FromHistoryStartWorkflowExecutionRequest ¶ added in v0.17.0

func FromHistoryStartWorkflowExecutionRequest(t *types.HistoryStartWorkflowExecutionRequest) *history.StartWorkflowExecutionRequest

FromHistoryStartWorkflowExecutionRequest converts internal StartWorkflowExecutionRequest type to thrift

func FromHistorySyncActivityRequest ¶ added in v1.2.7

func FromHistorySyncActivityRequest(t *types.SyncActivityRequest) *history.SyncActivityRequest

FromHistorySyncActivityRequest converts internal SyncActivityRequest type to thrift

func FromHistorySyncShardStatusRequest ¶ added in v1.2.7

func FromHistorySyncShardStatusRequest(t *types.SyncShardStatusRequest) *history.SyncShardStatusRequest

FromHistorySyncShardStatusRequest converts internal SyncShardStatusRequest type to thrift

func FromHistoryTaskV2Attributes ¶ added in v0.17.0

func FromHistoryTaskV2Attributes(t *types.HistoryTaskV2Attributes) *replicator.HistoryTaskV2Attributes

FromHistoryTaskV2Attributes converts internal HistoryTaskV2Attributes type to thrift

func FromHistoryTerminateWorkflowExecutionRequest ¶ added in v0.17.0

func FromHistoryTerminateWorkflowExecutionRequest(t *types.HistoryTerminateWorkflowExecutionRequest) *history.TerminateWorkflowExecutionRequest

FromHistoryTerminateWorkflowExecutionRequest converts internal TerminateWorkflowExecutionRequest type to thrift

func FromHostInfo ¶ added in v0.17.0

func FromHostInfo(t *types.HostInfo) *admin.HostInfo

FromHostInfo converts internal HostInfo type to thrift

func FromHostInfoArray ¶ added in v0.17.0

func FromHostInfoArray(t []*types.HostInfo) []*admin.HostInfo

FromHostInfoArray converts internal HostInfo type array to thrift

func FromIndexedValueType ¶

func FromIndexedValueType(t types.IndexedValueType) shared.IndexedValueType

FromIndexedValueType converts internal IndexedValueType type to thrift

func FromIndexedValueTypeMap ¶

func FromIndexedValueTypeMap(t map[string]types.IndexedValueType) map[string]shared.IndexedValueType

FromIndexedValueTypeMap converts internal IndexedValueType type map to thrift

func FromInternalDataInconsistencyError ¶

func FromInternalDataInconsistencyError(t *types.InternalDataInconsistencyError) *shared.InternalDataInconsistencyError

FromInternalDataInconsistencyError converts internal InternalDataInconsistencyError type to thrift

func FromInternalServiceError ¶

func FromInternalServiceError(t *types.InternalServiceError) *shared.InternalServiceError

FromInternalServiceError converts internal InternalServiceError type to thrift

func FromIsolationGroupConfig ¶ added in v1.2.1

func FromIsolationGroupConfig(in *types.IsolationGroupConfiguration) *shared.IsolationGroupConfiguration

func FromLimitExceededError ¶

func FromLimitExceededError(t *types.LimitExceededError) *shared.LimitExceededError

FromLimitExceededError converts internal LimitExceededError type to thrift

func FromListArchivedWorkflowExecutionsRequest ¶

func FromListArchivedWorkflowExecutionsRequest(t *types.ListArchivedWorkflowExecutionsRequest) *shared.ListArchivedWorkflowExecutionsRequest

FromListArchivedWorkflowExecutionsRequest converts internal ListArchivedWorkflowExecutionsRequest type to thrift

func FromListArchivedWorkflowExecutionsResponse ¶

func FromListArchivedWorkflowExecutionsResponse(t *types.ListArchivedWorkflowExecutionsResponse) *shared.ListArchivedWorkflowExecutionsResponse

FromListArchivedWorkflowExecutionsResponse converts internal ListArchivedWorkflowExecutionsResponse type to thrift

func FromListClosedWorkflowExecutionsRequest ¶

func FromListClosedWorkflowExecutionsRequest(t *types.ListClosedWorkflowExecutionsRequest) *shared.ListClosedWorkflowExecutionsRequest

FromListClosedWorkflowExecutionsRequest converts internal ListClosedWorkflowExecutionsRequest type to thrift

func FromListClosedWorkflowExecutionsResponse ¶

func FromListClosedWorkflowExecutionsResponse(t *types.ListClosedWorkflowExecutionsResponse) *shared.ListClosedWorkflowExecutionsResponse

FromListClosedWorkflowExecutionsResponse converts internal ListClosedWorkflowExecutionsResponse type to thrift

func FromListDomainsRequest ¶

func FromListDomainsRequest(t *types.ListDomainsRequest) *shared.ListDomainsRequest

FromListDomainsRequest converts internal ListDomainsRequest type to thrift

func FromListDomainsResponse ¶

func FromListDomainsResponse(t *types.ListDomainsResponse) *shared.ListDomainsResponse

FromListDomainsResponse converts internal ListDomainsResponse type to thrift

func FromListOpenWorkflowExecutionsRequest ¶

func FromListOpenWorkflowExecutionsRequest(t *types.ListOpenWorkflowExecutionsRequest) *shared.ListOpenWorkflowExecutionsRequest

FromListOpenWorkflowExecutionsRequest converts internal ListOpenWorkflowExecutionsRequest type to thrift

func FromListOpenWorkflowExecutionsResponse ¶

func FromListOpenWorkflowExecutionsResponse(t *types.ListOpenWorkflowExecutionsResponse) *shared.ListOpenWorkflowExecutionsResponse

FromListOpenWorkflowExecutionsResponse converts internal ListOpenWorkflowExecutionsResponse type to thrift

func FromListTaskListPartitionsRequest ¶

func FromListTaskListPartitionsRequest(t *types.ListTaskListPartitionsRequest) *shared.ListTaskListPartitionsRequest

FromListTaskListPartitionsRequest converts internal ListTaskListPartitionsRequest type to thrift

func FromListTaskListPartitionsResponse ¶

func FromListTaskListPartitionsResponse(t *types.ListTaskListPartitionsResponse) *shared.ListTaskListPartitionsResponse

FromListTaskListPartitionsResponse converts internal ListTaskListPartitionsResponse type to thrift

func FromListWorkflowExecutionsRequest ¶

func FromListWorkflowExecutionsRequest(t *types.ListWorkflowExecutionsRequest) *shared.ListWorkflowExecutionsRequest

FromListWorkflowExecutionsRequest converts internal ListWorkflowExecutionsRequest type to thrift

func FromListWorkflowExecutionsResponse ¶

func FromListWorkflowExecutionsResponse(t *types.ListWorkflowExecutionsResponse) *shared.ListWorkflowExecutionsResponse

FromListWorkflowExecutionsResponse converts internal ListWorkflowExecutionsResponse type to thrift

func FromMarkerRecordedEventAttributes ¶

func FromMarkerRecordedEventAttributes(t *types.MarkerRecordedEventAttributes) *shared.MarkerRecordedEventAttributes

FromMarkerRecordedEventAttributes converts internal MarkerRecordedEventAttributes type to thrift

func FromMatchingAddActivityTaskRequest ¶ added in v1.2.7

func FromMatchingAddActivityTaskRequest(t *types.AddActivityTaskRequest) *matching.AddActivityTaskRequest

FromMatchingAddActivityTaskRequest converts internal AddActivityTaskRequest type to thrift

func FromMatchingAddDecisionTaskRequest ¶ added in v1.2.7

func FromMatchingAddDecisionTaskRequest(t *types.AddDecisionTaskRequest) *matching.AddDecisionTaskRequest

FromMatchingAddDecisionTaskRequest converts internal AddDecisionTaskRequest type to thrift

func FromMatchingCancelOutstandingPollRequest ¶ added in v1.2.7

func FromMatchingCancelOutstandingPollRequest(t *types.CancelOutstandingPollRequest) *matching.CancelOutstandingPollRequest

FromMatchingCancelOutstandingPollRequest converts internal CancelOutstandingPollRequest type to thrift

func FromMatchingDescribeTaskListRequest ¶ added in v0.17.0

func FromMatchingDescribeTaskListRequest(t *types.MatchingDescribeTaskListRequest) *matching.DescribeTaskListRequest

FromMatchingDescribeTaskListRequest converts internal DescribeTaskListRequest type to thrift

func FromMatchingListTaskListPartitionsRequest ¶ added in v0.17.0

func FromMatchingListTaskListPartitionsRequest(t *types.MatchingListTaskListPartitionsRequest) *matching.ListTaskListPartitionsRequest

FromMatchingListTaskListPartitionsRequest converts internal ListTaskListPartitionsRequest type to thrift

func FromMatchingPollForActivityTaskRequest ¶ added in v0.17.0

func FromMatchingPollForActivityTaskRequest(t *types.MatchingPollForActivityTaskRequest) *matching.PollForActivityTaskRequest

FromMatchingPollForActivityTaskRequest converts internal PollForActivityTaskRequest type to thrift

func FromMatchingPollForActivityTaskResponse ¶ added in v1.2.7

func FromMatchingPollForActivityTaskResponse(t *types.MatchingPollForActivityTaskResponse) *shared.PollForActivityTaskResponse

func FromMatchingPollForDecisionTaskRequest ¶ added in v0.17.0

func FromMatchingPollForDecisionTaskRequest(t *types.MatchingPollForDecisionTaskRequest) *matching.PollForDecisionTaskRequest

FromMatchingPollForDecisionTaskRequest converts internal PollForDecisionTaskRequest type to thrift

func FromMatchingPollForDecisionTaskResponse ¶ added in v0.17.0

func FromMatchingPollForDecisionTaskResponse(t *types.MatchingPollForDecisionTaskResponse) *matching.PollForDecisionTaskResponse

FromMatchingPollForDecisionTaskResponse converts internal PollForDecisionTaskResponse type to thrift

func FromMatchingQueryWorkflowRequest ¶ added in v0.17.0

func FromMatchingQueryWorkflowRequest(t *types.MatchingQueryWorkflowRequest) *matching.QueryWorkflowRequest

FromMatchingQueryWorkflowRequest converts internal QueryWorkflowRequest type to thrift

func FromMatchingRespondQueryTaskCompletedRequest ¶ added in v0.17.0

func FromMatchingRespondQueryTaskCompletedRequest(t *types.MatchingRespondQueryTaskCompletedRequest) *matching.RespondQueryTaskCompletedRequest

FromMatchingRespondQueryTaskCompletedRequest converts internal RespondQueryTaskCompletedRequest type to thrift

func FromMembershipInfo ¶ added in v0.17.0

func FromMembershipInfo(t *types.MembershipInfo) *admin.MembershipInfo

FromMembershipInfo converts internal MembershipInfo type to thrift

func FromMemo ¶

func FromMemo(t *types.Memo) *shared.Memo

FromMemo converts internal Memo type to thrift

func FromParentClosePolicy ¶

func FromParentClosePolicy(t *types.ParentClosePolicy) *shared.ParentClosePolicy

FromParentClosePolicy converts internal ParentClosePolicy type to thrift

func FromParentExecutionInfo ¶ added in v0.17.0

func FromParentExecutionInfo(t *types.ParentExecutionInfo) *history.ParentExecutionInfo

FromHistoryParentExecutionInfo converts internal ParentExecutionInfo type to thrift

func FromPendingActivityInfo ¶

func FromPendingActivityInfo(t *types.PendingActivityInfo) *shared.PendingActivityInfo

FromPendingActivityInfo converts internal PendingActivityInfo type to thrift

func FromPendingActivityInfoArray ¶

func FromPendingActivityInfoArray(t []*types.PendingActivityInfo) []*shared.PendingActivityInfo

FromPendingActivityInfoArray converts internal PendingActivityInfo type array to thrift

func FromPendingActivityState ¶

func FromPendingActivityState(t *types.PendingActivityState) *shared.PendingActivityState

FromPendingActivityState converts internal PendingActivityState type to thrift

func FromPendingChildExecutionInfo ¶

func FromPendingChildExecutionInfo(t *types.PendingChildExecutionInfo) *shared.PendingChildExecutionInfo

FromPendingChildExecutionInfo converts internal PendingChildExecutionInfo type to thrift

func FromPendingChildExecutionInfoArray ¶

func FromPendingChildExecutionInfoArray(t []*types.PendingChildExecutionInfo) []*shared.PendingChildExecutionInfo

FromPendingChildExecutionInfoArray converts internal PendingChildExecutionInfo type array to thrift

func FromPendingDecisionInfo ¶ added in v0.17.0

func FromPendingDecisionInfo(t *types.PendingDecisionInfo) *shared.PendingDecisionInfo

FromPendingDecisionInfo converts internal PendingDecisionInfo type to thrift

func FromPendingDecisionState ¶ added in v0.17.0

func FromPendingDecisionState(t *types.PendingDecisionState) *shared.PendingDecisionState

FromPendingDecisionState converts internal PendingDecisionState type to thrift

func FromPersistenceFeature ¶ added in v0.21.0

func FromPersistenceFeature(t *types.PersistenceFeature) *admin.PersistenceFeature

FromPersistenceFeature converts internal PersistenceFeature type to thrift

func FromPersistenceFeatures ¶ added in v0.21.0

func FromPersistenceFeatures(t []*types.PersistenceFeature) []*admin.PersistenceFeature

FromPersistenceFeatures converts internal []*types.PersistenceFeature type to thrift

func FromPersistenceInfo ¶ added in v0.21.0

func FromPersistenceInfo(t *types.PersistenceInfo) *admin.PersistenceInfo

FromPersistenceInfo converts internal PersistenceInfo type to thrift

func FromPersistenceInfoMap ¶ added in v0.21.0

func FromPersistenceInfoMap(t map[string]*types.PersistenceInfo) map[string]*admin.PersistenceInfo

FromPersistenceInfoMap converts internal map[string]*types.PersistenceInfo type to thrift

func FromPersistenceSetting ¶ added in v0.21.0

func FromPersistenceSetting(t *types.PersistenceSetting) *admin.PersistenceSetting

FromPersistenceSetting converts internal PersistenceSetting type to thrift

func FromPersistenceSettings ¶ added in v0.21.0

func FromPersistenceSettings(t []*types.PersistenceSetting) []*admin.PersistenceSetting

FromPersistenceSettings converts internal []*types.PersistenceSetting type to thrift

func FromPollForActivityTaskRequest ¶

func FromPollForActivityTaskRequest(t *types.PollForActivityTaskRequest) *shared.PollForActivityTaskRequest

FromPollForActivityTaskRequest converts internal PollForActivityTaskRequest type to thrift

func FromPollForActivityTaskResponse ¶

func FromPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *shared.PollForActivityTaskResponse

FromPollForActivityTaskResponse converts internal PollForActivityTaskResponse type to thrift

func FromPollForDecisionTaskRequest ¶

func FromPollForDecisionTaskRequest(t *types.PollForDecisionTaskRequest) *shared.PollForDecisionTaskRequest

FromPollForDecisionTaskRequest converts internal PollForDecisionTaskRequest type to thrift

func FromPollForDecisionTaskResponse ¶

func FromPollForDecisionTaskResponse(t *types.PollForDecisionTaskResponse) *shared.PollForDecisionTaskResponse

FromPollForDecisionTaskResponse converts internal PollForDecisionTaskResponse type to thrift

func FromPollerInfo ¶

func FromPollerInfo(t *types.PollerInfo) *shared.PollerInfo

FromPollerInfo converts internal PollerInfo type to thrift

func FromPollerInfoArray ¶

func FromPollerInfoArray(t []*types.PollerInfo) []*shared.PollerInfo

FromPollerInfoArray converts internal PollerInfo type array to thrift

func FromProcessingQueueState ¶ added in v0.17.0

func FromProcessingQueueState(t *types.ProcessingQueueState) *history.ProcessingQueueState

FromProcessingQueueState converts internal ProcessingQueueState type to thrift

func FromProcessingQueueStateArray ¶ added in v0.17.0

func FromProcessingQueueStateArray(t []*types.ProcessingQueueState) []*history.ProcessingQueueState

FromProcessingQueueStateArray converts internal ProcessingQueueState type array to thrift

func FromProcessingQueueStateArrayMap ¶ added in v0.17.0

func FromProcessingQueueStateArrayMap(t map[string][]*types.ProcessingQueueState) map[string][]*history.ProcessingQueueState

FromProcessingQueueStateArrayMap converts internal ProcessingQueueState array map to thrift

func FromProcessingQueueStates ¶ added in v0.17.0

func FromProcessingQueueStates(t *types.ProcessingQueueStates) *history.ProcessingQueueStates

FromProcessingQueueStates converts internal ProcessingQueueStates type to thrift

func FromQueryConsistencyLevel ¶

func FromQueryConsistencyLevel(t *types.QueryConsistencyLevel) *shared.QueryConsistencyLevel

FromQueryConsistencyLevel converts internal QueryConsistencyLevel type to thrift

func FromQueryFailedError ¶

func FromQueryFailedError(t *types.QueryFailedError) *shared.QueryFailedError

FromQueryFailedError converts internal QueryFailedError type to thrift

func FromQueryRejectCondition ¶

func FromQueryRejectCondition(t *types.QueryRejectCondition) *shared.QueryRejectCondition

FromQueryRejectCondition converts internal QueryRejectCondition type to thrift

func FromQueryRejected ¶

func FromQueryRejected(t *types.QueryRejected) *shared.QueryRejected

FromQueryRejected converts internal QueryRejected type to thrift

func FromQueryResultType ¶

func FromQueryResultType(t *types.QueryResultType) *shared.QueryResultType

FromQueryResultType converts internal QueryResultType type to thrift

func FromQueryTaskCompletedType ¶

func FromQueryTaskCompletedType(t *types.QueryTaskCompletedType) *shared.QueryTaskCompletedType

FromQueryTaskCompletedType converts internal QueryTaskCompletedType type to thrift

func FromQueryWorkflowRequest ¶

func FromQueryWorkflowRequest(t *types.QueryWorkflowRequest) *shared.QueryWorkflowRequest

FromQueryWorkflowRequest converts internal QueryWorkflowRequest type to thrift

func FromQueryWorkflowResponse ¶

func FromQueryWorkflowResponse(t *types.QueryWorkflowResponse) *shared.QueryWorkflowResponse

FromQueryWorkflowResponse converts internal QueryWorkflowResponse type to thrift

func FromRecordActivityTaskHeartbeatByIDRequest ¶

func FromRecordActivityTaskHeartbeatByIDRequest(t *types.RecordActivityTaskHeartbeatByIDRequest) *shared.RecordActivityTaskHeartbeatByIDRequest

FromRecordActivityTaskHeartbeatByIDRequest converts internal RecordActivityTaskHeartbeatByIDRequest type to thrift

func FromRecordActivityTaskHeartbeatRequest ¶

func FromRecordActivityTaskHeartbeatRequest(t *types.RecordActivityTaskHeartbeatRequest) *shared.RecordActivityTaskHeartbeatRequest

FromRecordActivityTaskHeartbeatRequest converts internal RecordActivityTaskHeartbeatRequest type to thrift

func FromRecordActivityTaskHeartbeatResponse ¶

func FromRecordActivityTaskHeartbeatResponse(t *types.RecordActivityTaskHeartbeatResponse) *shared.RecordActivityTaskHeartbeatResponse

FromRecordActivityTaskHeartbeatResponse converts internal RecordActivityTaskHeartbeatResponse type to thrift

func FromRecordActivityTaskStartedRequest ¶ added in v0.17.0

func FromRecordActivityTaskStartedRequest(t *types.RecordActivityTaskStartedRequest) *history.RecordActivityTaskStartedRequest

FromRecordActivityTaskStartedRequest converts internal RecordActivityTaskStartedRequest type to thrift

func FromRecordActivityTaskStartedResponse ¶ added in v0.17.0

func FromRecordActivityTaskStartedResponse(t *types.RecordActivityTaskStartedResponse) *history.RecordActivityTaskStartedResponse

FromRecordActivityTaskStartedResponse converts internal RecordActivityTaskStartedResponse type to thrift

func FromRecordChildExecutionCompletedRequest ¶ added in v0.17.0

func FromRecordChildExecutionCompletedRequest(t *types.RecordChildExecutionCompletedRequest) *history.RecordChildExecutionCompletedRequest

FromRecordChildExecutionCompletedRequest converts internal RecordChildExecutionCompletedRequest type to thrift

func FromRecordDecisionTaskStartedRequest ¶ added in v0.17.0

func FromRecordDecisionTaskStartedRequest(t *types.RecordDecisionTaskStartedRequest) *history.RecordDecisionTaskStartedRequest

FromRecordDecisionTaskStartedRequest converts internal RecordDecisionTaskStartedRequest type to thrift

func FromRecordDecisionTaskStartedResponse ¶ added in v0.17.0

func FromRecordDecisionTaskStartedResponse(t *types.RecordDecisionTaskStartedResponse) *history.RecordDecisionTaskStartedResponse

FromRecordDecisionTaskStartedResponse converts internal RecordDecisionTaskStartedResponse type to thrift

func FromRecordMarkerDecisionAttributes ¶

func FromRecordMarkerDecisionAttributes(t *types.RecordMarkerDecisionAttributes) *shared.RecordMarkerDecisionAttributes

FromRecordMarkerDecisionAttributes converts internal RecordMarkerDecisionAttributes type to thrift

func FromRefreshWorkflowTasksRequest ¶

func FromRefreshWorkflowTasksRequest(t *types.RefreshWorkflowTasksRequest) *shared.RefreshWorkflowTasksRequest

FromRefreshWorkflowTasksRequest converts internal RefreshWorkflowTasksRequest type to thrift

func FromRegisterDomainRequest ¶

func FromRegisterDomainRequest(t *types.RegisterDomainRequest) *shared.RegisterDomainRequest

FromRegisterDomainRequest converts internal RegisterDomainRequest type to thrift

func FromRemoteSyncMatchedError ¶

func FromRemoteSyncMatchedError(t *types.RemoteSyncMatchedError) *shared.RemoteSyncMatchedError

FromRemoteSyncMatchedError converts internal RemoteSyncMatchedError type to thrift

func FromReplicationMessages ¶ added in v0.17.0

func FromReplicationMessages(t *types.ReplicationMessages) *replicator.ReplicationMessages

FromReplicationMessages converts internal ReplicationMessages type to thrift

func FromReplicationMessagesMap ¶ added in v0.17.0

func FromReplicationMessagesMap(t map[int32]*types.ReplicationMessages) map[int32]*replicator.ReplicationMessages

FromReplicationMessagesMap converts internal ReplicationMessages type map to thrift

func FromReplicationTask ¶ added in v0.17.0

func FromReplicationTask(t *types.ReplicationTask) *replicator.ReplicationTask

FromReplicationTask converts internal ReplicationTask type to thrift

func FromReplicationTaskArray ¶ added in v0.17.0

func FromReplicationTaskArray(t []*types.ReplicationTask) []*replicator.ReplicationTask

FromReplicationTaskArray converts internal ReplicationTask type array to thrift

func FromReplicationTaskInfo ¶ added in v0.17.0

func FromReplicationTaskInfo(t *types.ReplicationTaskInfo) *replicator.ReplicationTaskInfo

FromReplicationTaskInfo converts internal ReplicationTaskInfo type to thrift

func FromReplicationTaskInfoArray ¶ added in v0.17.0

func FromReplicationTaskInfoArray(t []*types.ReplicationTaskInfo) []*replicator.ReplicationTaskInfo

FromReplicationTaskInfoArray converts internal ReplicationTaskInfo type array to thrift

func FromReplicationTaskType ¶ added in v0.17.0

func FromReplicationTaskType(t *types.ReplicationTaskType) *replicator.ReplicationTaskType

FromReplicationTaskType converts internal ReplicationTaskType type to thrift

func FromReplicationToken ¶ added in v0.17.0

func FromReplicationToken(t *types.ReplicationToken) *replicator.ReplicationToken

FromReplicationToken converts internal ReplicationToken type to thrift

func FromReplicationTokenArray ¶ added in v0.17.0

func FromReplicationTokenArray(t []*types.ReplicationToken) []*replicator.ReplicationToken

FromReplicationTokenArray converts internal ReplicationToken type array to thrift

func FromRequestCancelActivityTaskDecisionAttributes ¶

func FromRequestCancelActivityTaskDecisionAttributes(t *types.RequestCancelActivityTaskDecisionAttributes) *shared.RequestCancelActivityTaskDecisionAttributes

FromRequestCancelActivityTaskDecisionAttributes converts internal RequestCancelActivityTaskDecisionAttributes type to thrift

func FromRequestCancelActivityTaskFailedEventAttributes ¶

func FromRequestCancelActivityTaskFailedEventAttributes(t *types.RequestCancelActivityTaskFailedEventAttributes) *shared.RequestCancelActivityTaskFailedEventAttributes

FromRequestCancelActivityTaskFailedEventAttributes converts internal RequestCancelActivityTaskFailedEventAttributes type to thrift

func FromRequestCancelExternalWorkflowExecutionDecisionAttributes ¶

func FromRequestCancelExternalWorkflowExecutionDecisionAttributes(t *types.RequestCancelExternalWorkflowExecutionDecisionAttributes) *shared.RequestCancelExternalWorkflowExecutionDecisionAttributes

FromRequestCancelExternalWorkflowExecutionDecisionAttributes converts internal RequestCancelExternalWorkflowExecutionDecisionAttributes type to thrift

func FromRequestCancelExternalWorkflowExecutionFailedEventAttributes ¶

func FromRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *shared.RequestCancelExternalWorkflowExecutionFailedEventAttributes

FromRequestCancelExternalWorkflowExecutionFailedEventAttributes converts internal RequestCancelExternalWorkflowExecutionFailedEventAttributes type to thrift

func FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶

func FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *shared.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes

FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes converts internal RequestCancelExternalWorkflowExecutionInitiatedEventAttributes type to thrift

func FromRequestCancelWorkflowExecutionRequest ¶

func FromRequestCancelWorkflowExecutionRequest(t *types.RequestCancelWorkflowExecutionRequest) *shared.RequestCancelWorkflowExecutionRequest

FromRequestCancelWorkflowExecutionRequest converts internal RequestCancelWorkflowExecutionRequest type to thrift

func FromResetPointInfo ¶

func FromResetPointInfo(t *types.ResetPointInfo) *shared.ResetPointInfo

FromResetPointInfo converts internal ResetPointInfo type to thrift

func FromResetPointInfoArray ¶

func FromResetPointInfoArray(t []*types.ResetPointInfo) []*shared.ResetPointInfo

FromResetPointInfoArray converts internal ResetPointInfo type array to thrift

func FromResetPoints ¶

func FromResetPoints(t *types.ResetPoints) *shared.ResetPoints

FromResetPoints converts internal ResetPoints type to thrift

func FromResetStickyTaskListRequest ¶

func FromResetStickyTaskListRequest(t *types.ResetStickyTaskListRequest) *shared.ResetStickyTaskListRequest

FromResetStickyTaskListRequest converts internal ResetStickyTaskListRequest type to thrift

func FromResetStickyTaskListResponse ¶

func FromResetStickyTaskListResponse(t *types.ResetStickyTaskListResponse) *shared.ResetStickyTaskListResponse

FromResetStickyTaskListResponse converts internal ResetStickyTaskListResponse type to thrift

func FromResetWorkflowExecutionRequest ¶

func FromResetWorkflowExecutionRequest(t *types.ResetWorkflowExecutionRequest) *shared.ResetWorkflowExecutionRequest

FromResetWorkflowExecutionRequest converts internal ResetWorkflowExecutionRequest type to thrift

func FromResetWorkflowExecutionResponse ¶

func FromResetWorkflowExecutionResponse(t *types.ResetWorkflowExecutionResponse) *shared.ResetWorkflowExecutionResponse

FromResetWorkflowExecutionResponse converts internal ResetWorkflowExecutionResponse type to thrift

func FromRespondActivityTaskCanceledByIDRequest ¶

func FromRespondActivityTaskCanceledByIDRequest(t *types.RespondActivityTaskCanceledByIDRequest) *shared.RespondActivityTaskCanceledByIDRequest

FromRespondActivityTaskCanceledByIDRequest converts internal RespondActivityTaskCanceledByIDRequest type to thrift

func FromRespondActivityTaskCanceledRequest ¶

func FromRespondActivityTaskCanceledRequest(t *types.RespondActivityTaskCanceledRequest) *shared.RespondActivityTaskCanceledRequest

FromRespondActivityTaskCanceledRequest converts internal RespondActivityTaskCanceledRequest type to thrift

func FromRespondActivityTaskCompletedByIDRequest ¶

func FromRespondActivityTaskCompletedByIDRequest(t *types.RespondActivityTaskCompletedByIDRequest) *shared.RespondActivityTaskCompletedByIDRequest

FromRespondActivityTaskCompletedByIDRequest converts internal RespondActivityTaskCompletedByIDRequest type to thrift

func FromRespondActivityTaskCompletedRequest ¶

func FromRespondActivityTaskCompletedRequest(t *types.RespondActivityTaskCompletedRequest) *shared.RespondActivityTaskCompletedRequest

FromRespondActivityTaskCompletedRequest converts internal RespondActivityTaskCompletedRequest type to thrift

func FromRespondActivityTaskFailedByIDRequest ¶

func FromRespondActivityTaskFailedByIDRequest(t *types.RespondActivityTaskFailedByIDRequest) *shared.RespondActivityTaskFailedByIDRequest

FromRespondActivityTaskFailedByIDRequest converts internal RespondActivityTaskFailedByIDRequest type to thrift

func FromRespondActivityTaskFailedRequest ¶

func FromRespondActivityTaskFailedRequest(t *types.RespondActivityTaskFailedRequest) *shared.RespondActivityTaskFailedRequest

FromRespondActivityTaskFailedRequest converts internal RespondActivityTaskFailedRequest type to thrift

func FromRespondDecisionTaskCompletedRequest ¶

func FromRespondDecisionTaskCompletedRequest(t *types.RespondDecisionTaskCompletedRequest) *shared.RespondDecisionTaskCompletedRequest

FromRespondDecisionTaskCompletedRequest converts internal RespondDecisionTaskCompletedRequest type to thrift

func FromRespondDecisionTaskCompletedResponse ¶

func FromRespondDecisionTaskCompletedResponse(t *types.RespondDecisionTaskCompletedResponse) *shared.RespondDecisionTaskCompletedResponse

FromRespondDecisionTaskCompletedResponse converts internal RespondDecisionTaskCompletedResponse type to thrift

func FromRespondDecisionTaskFailedRequest ¶

func FromRespondDecisionTaskFailedRequest(t *types.RespondDecisionTaskFailedRequest) *shared.RespondDecisionTaskFailedRequest

FromRespondDecisionTaskFailedRequest converts internal RespondDecisionTaskFailedRequest type to thrift

func FromRespondQueryTaskCompletedRequest ¶

func FromRespondQueryTaskCompletedRequest(t *types.RespondQueryTaskCompletedRequest) *shared.RespondQueryTaskCompletedRequest

FromRespondQueryTaskCompletedRequest converts internal RespondQueryTaskCompletedRequest type to thrift

func FromRestartWorkflowExecutionRequest ¶ added in v0.25.0

func FromRestartWorkflowExecutionRequest(t *types.RestartWorkflowExecutionRequest) *shared.RestartWorkflowExecutionRequest

FromRestartWorkflowExecutionRequest converts internal RestartWorkflowExecutionRequest type to thrift

func FromRestartWorkflowExecutionResponse ¶ added in v0.25.0

func FromRestartWorkflowExecutionResponse(t *types.RestartWorkflowExecutionResponse) *shared.RestartWorkflowExecutionResponse

FromRestartWorkflowExecutionResponse converts internal RestartWorkflowExecutionResponse type to thrift

func FromRetryPolicy ¶

func FromRetryPolicy(t *types.RetryPolicy) *shared.RetryPolicy

FromRetryPolicy converts internal RetryPolicy type to thrift

func FromRetryTaskV2Error ¶

func FromRetryTaskV2Error(t *types.RetryTaskV2Error) *shared.RetryTaskV2Error

FromRetryTaskV2Error converts internal RetryTaskV2Error type to thrift

func FromRingInfo ¶ added in v0.17.0

func FromRingInfo(t *types.RingInfo) *admin.RingInfo

FromRingInfo converts internal RingInfo type to thrift

func FromRingInfoArray ¶ added in v0.17.0

func FromRingInfoArray(t []*types.RingInfo) []*admin.RingInfo

FromRingInfoArray converts internal RingInfo type array to thrift

func FromScheduleActivityTaskDecisionAttributes ¶

func FromScheduleActivityTaskDecisionAttributes(t *types.ScheduleActivityTaskDecisionAttributes) *shared.ScheduleActivityTaskDecisionAttributes

FromScheduleActivityTaskDecisionAttributes converts internal ScheduleActivityTaskDecisionAttributes type to thrift

func FromSearchAttributes ¶

func FromSearchAttributes(t *types.SearchAttributes) *shared.SearchAttributes

FromSearchAttributes converts internal SearchAttributes type to thrift

func FromServiceBusyError ¶

func FromServiceBusyError(t *types.ServiceBusyError) *shared.ServiceBusyError

FromServiceBusyError converts internal ServiceBusyError type to thrift

func FromShardOwnershipLostError ¶ added in v0.17.0

func FromShardOwnershipLostError(t *types.ShardOwnershipLostError) *history.ShardOwnershipLostError

FromShardOwnershipLostError converts internal ShardOwnershipLostError type to thrift

func FromSignalExternalWorkflowExecutionDecisionAttributes ¶

func FromSignalExternalWorkflowExecutionDecisionAttributes(t *types.SignalExternalWorkflowExecutionDecisionAttributes) *shared.SignalExternalWorkflowExecutionDecisionAttributes

FromSignalExternalWorkflowExecutionDecisionAttributes converts internal SignalExternalWorkflowExecutionDecisionAttributes type to thrift

func FromSignalExternalWorkflowExecutionFailedCause ¶

func FromSignalExternalWorkflowExecutionFailedCause(t *types.SignalExternalWorkflowExecutionFailedCause) *shared.SignalExternalWorkflowExecutionFailedCause

FromSignalExternalWorkflowExecutionFailedCause converts internal SignalExternalWorkflowExecutionFailedCause type to thrift

func FromSignalExternalWorkflowExecutionFailedEventAttributes ¶

func FromSignalExternalWorkflowExecutionFailedEventAttributes(t *types.SignalExternalWorkflowExecutionFailedEventAttributes) *shared.SignalExternalWorkflowExecutionFailedEventAttributes

FromSignalExternalWorkflowExecutionFailedEventAttributes converts internal SignalExternalWorkflowExecutionFailedEventAttributes type to thrift

func FromSignalExternalWorkflowExecutionInitiatedEventAttributes ¶

func FromSignalExternalWorkflowExecutionInitiatedEventAttributes(t *types.SignalExternalWorkflowExecutionInitiatedEventAttributes) *shared.SignalExternalWorkflowExecutionInitiatedEventAttributes

FromSignalExternalWorkflowExecutionInitiatedEventAttributes converts internal SignalExternalWorkflowExecutionInitiatedEventAttributes type to thrift

func FromSignalWithStartWorkflowExecutionAsyncRequest ¶ added in v1.2.8

func FromSignalWithStartWorkflowExecutionAsyncRequest(t *types.SignalWithStartWorkflowExecutionAsyncRequest) *shared.SignalWithStartWorkflowExecutionAsyncRequest

func FromSignalWithStartWorkflowExecutionAsyncResponse ¶ added in v1.2.8

func FromSignalWithStartWorkflowExecutionAsyncResponse(t *types.SignalWithStartWorkflowExecutionAsyncResponse) *shared.SignalWithStartWorkflowExecutionAsyncResponse

func FromSignalWithStartWorkflowExecutionRequest ¶

func FromSignalWithStartWorkflowExecutionRequest(t *types.SignalWithStartWorkflowExecutionRequest) *shared.SignalWithStartWorkflowExecutionRequest

FromSignalWithStartWorkflowExecutionRequest converts internal SignalWithStartWorkflowExecutionRequest type to thrift

func FromSignalWorkflowExecutionRequest ¶

func FromSignalWorkflowExecutionRequest(t *types.SignalWorkflowExecutionRequest) *shared.SignalWorkflowExecutionRequest

FromSignalWorkflowExecutionRequest converts internal SignalWorkflowExecutionRequest type to thrift

func FromStartChildWorkflowExecutionDecisionAttributes ¶

func FromStartChildWorkflowExecutionDecisionAttributes(t *types.StartChildWorkflowExecutionDecisionAttributes) *shared.StartChildWorkflowExecutionDecisionAttributes

FromStartChildWorkflowExecutionDecisionAttributes converts internal StartChildWorkflowExecutionDecisionAttributes type to thrift

func FromStartChildWorkflowExecutionFailedEventAttributes ¶

func FromStartChildWorkflowExecutionFailedEventAttributes(t *types.StartChildWorkflowExecutionFailedEventAttributes) *shared.StartChildWorkflowExecutionFailedEventAttributes

FromStartChildWorkflowExecutionFailedEventAttributes converts internal StartChildWorkflowExecutionFailedEventAttributes type to thrift

func FromStartChildWorkflowExecutionInitiatedEventAttributes ¶

func FromStartChildWorkflowExecutionInitiatedEventAttributes(t *types.StartChildWorkflowExecutionInitiatedEventAttributes) *shared.StartChildWorkflowExecutionInitiatedEventAttributes

FromStartChildWorkflowExecutionInitiatedEventAttributes converts internal StartChildWorkflowExecutionInitiatedEventAttributes type to thrift

func FromStartTimeFilter ¶

func FromStartTimeFilter(t *types.StartTimeFilter) *shared.StartTimeFilter

FromStartTimeFilter converts internal StartTimeFilter type to thrift

func FromStartTimerDecisionAttributes ¶

func FromStartTimerDecisionAttributes(t *types.StartTimerDecisionAttributes) *shared.StartTimerDecisionAttributes

FromStartTimerDecisionAttributes converts internal StartTimerDecisionAttributes type to thrift

func FromStartWorkflowExecutionAsyncRequest ¶ added in v1.2.8

func FromStartWorkflowExecutionAsyncRequest(t *types.StartWorkflowExecutionAsyncRequest) *shared.StartWorkflowExecutionAsyncRequest

func FromStartWorkflowExecutionAsyncResponse ¶ added in v1.2.8

func FromStartWorkflowExecutionAsyncResponse(t *types.StartWorkflowExecutionAsyncResponse) *shared.StartWorkflowExecutionAsyncResponse

func FromStartWorkflowExecutionRequest ¶

func FromStartWorkflowExecutionRequest(t *types.StartWorkflowExecutionRequest) *shared.StartWorkflowExecutionRequest

FromStartWorkflowExecutionRequest converts internal StartWorkflowExecutionRequest type to thrift

func FromStartWorkflowExecutionResponse ¶

func FromStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *shared.StartWorkflowExecutionResponse

FromStartWorkflowExecutionResponse converts internal StartWorkflowExecutionResponse type to thrift

func FromStickyExecutionAttributes ¶

func FromStickyExecutionAttributes(t *types.StickyExecutionAttributes) *shared.StickyExecutionAttributes

FromStickyExecutionAttributes converts internal StickyExecutionAttributes type to thrift

func FromStickyWorkerUnavailableError ¶ added in v0.25.0

func FromStickyWorkerUnavailableError(t *types.StickyWorkerUnavailableError) *shared.StickyWorkerUnavailableError

FromStickyWorkerUnavailableError converts internal StickyWorkerUnavailableError type to thrift

func FromSupportedClientVersions ¶

func FromSupportedClientVersions(t *types.SupportedClientVersions) *shared.SupportedClientVersions

FromSupportedClientVersions converts internal SupportedClientVersions type to thrift

func FromSyncActivityTaskAttributes ¶ added in v0.17.0

func FromSyncActivityTaskAttributes(t *types.SyncActivityTaskAttributes) *replicator.SyncActivityTaskAttributes

FromSyncActivityTaskAttributes converts internal SyncActivityTaskAttributes type to thrift

func FromSyncShardStatus ¶ added in v0.17.0

func FromSyncShardStatus(t *types.SyncShardStatus) *replicator.SyncShardStatus

FromSyncShardStatus converts internal SyncShardStatus type to thrift

func FromSyncShardStatusTaskAttributes ¶ added in v0.17.0

func FromSyncShardStatusTaskAttributes(t *types.SyncShardStatusTaskAttributes) *replicator.SyncShardStatusTaskAttributes

FromSyncShardStatusTaskAttributes converts internal SyncShardStatusTaskAttributes type to thrift

func FromTaskIDBlock ¶

func FromTaskIDBlock(t *types.TaskIDBlock) *shared.TaskIDBlock

FromTaskIDBlock converts internal TaskIDBlock type to thrift

func FromTaskList ¶

func FromTaskList(t *types.TaskList) *shared.TaskList

FromTaskList converts internal TaskList type to thrift

func FromTaskListKind ¶

func FromTaskListKind(t *types.TaskListKind) *shared.TaskListKind

FromTaskListKind converts internal TaskListKind type to thrift

func FromTaskListMetadata ¶

func FromTaskListMetadata(t *types.TaskListMetadata) *shared.TaskListMetadata

FromTaskListMetadata converts internal TaskListMetadata type to thrift

func FromTaskListNotOwnedByHostError ¶ added in v1.2.13

func FromTaskListNotOwnedByHostError(t *cadence_errors.TaskListNotOwnedByHostError) *shared.TaskListNotOwnedByHostError

FromTaskListNotOwnedByHostError converts internal TaskListNotOwnedByHostError type to thrift

func FromTaskListPartitionMetadata ¶

func FromTaskListPartitionMetadata(t *types.TaskListPartitionMetadata) *shared.TaskListPartitionMetadata

FromTaskListPartitionMetadata converts internal TaskListPartitionMetadata type to thrift

func FromTaskListPartitionMetadataArray ¶

func FromTaskListPartitionMetadataArray(t []*types.TaskListPartitionMetadata) []*shared.TaskListPartitionMetadata

FromTaskListPartitionMetadataArray converts internal TaskListPartitionMetadata type array to thrift

func FromTaskListStatus ¶

func FromTaskListStatus(t *types.TaskListStatus) *shared.TaskListStatus

FromTaskListStatus converts internal TaskListStatus type to thrift

func FromTaskListType ¶

func FromTaskListType(t *types.TaskListType) *shared.TaskListType

FromTaskListType converts internal TaskListType type to thrift

func FromTaskSource ¶ added in v0.17.0

func FromTaskSource(t *types.TaskSource) *matching.TaskSource

FromTaskSource converts internal TaskSource type to thrift

func FromTerminateWorkflowExecutionRequest ¶

func FromTerminateWorkflowExecutionRequest(t *types.TerminateWorkflowExecutionRequest) *shared.TerminateWorkflowExecutionRequest

FromTerminateWorkflowExecutionRequest converts internal TerminateWorkflowExecutionRequest type to thrift

func FromTimeoutType ¶

func FromTimeoutType(t *types.TimeoutType) *shared.TimeoutType

FromTimeoutType converts internal TimeoutType type to thrift

func FromTimerCanceledEventAttributes ¶

func FromTimerCanceledEventAttributes(t *types.TimerCanceledEventAttributes) *shared.TimerCanceledEventAttributes

FromTimerCanceledEventAttributes converts internal TimerCanceledEventAttributes type to thrift

func FromTimerFiredEventAttributes ¶

func FromTimerFiredEventAttributes(t *types.TimerFiredEventAttributes) *shared.TimerFiredEventAttributes

FromTimerFiredEventAttributes converts internal TimerFiredEventAttributes type to thrift

func FromTimerStartedEventAttributes ¶

func FromTimerStartedEventAttributes(t *types.TimerStartedEventAttributes) *shared.TimerStartedEventAttributes

FromTimerStartedEventAttributes converts internal TimerStartedEventAttributes type to thrift

func FromTransientDecisionInfo ¶

func FromTransientDecisionInfo(t *types.TransientDecisionInfo) *shared.TransientDecisionInfo

FromTransientDecisionInfo converts internal TransientDecisionInfo type to thrift

func FromUpdateDomainRequest ¶

func FromUpdateDomainRequest(t *types.UpdateDomainRequest) *shared.UpdateDomainRequest

FromUpdateDomainRequest converts internal UpdateDomainRequest type to thrift

func FromUpdateDomainResponse ¶

func FromUpdateDomainResponse(t *types.UpdateDomainResponse) *shared.UpdateDomainResponse

FromUpdateDomainResponse converts internal UpdateDomainResponse type to thrift

func FromUpsertWorkflowSearchAttributesDecisionAttributes ¶

func FromUpsertWorkflowSearchAttributesDecisionAttributes(t *types.UpsertWorkflowSearchAttributesDecisionAttributes) *shared.UpsertWorkflowSearchAttributesDecisionAttributes

FromUpsertWorkflowSearchAttributesDecisionAttributes converts internal UpsertWorkflowSearchAttributesDecisionAttributes type to thrift

func FromUpsertWorkflowSearchAttributesEventAttributes ¶

func FromUpsertWorkflowSearchAttributesEventAttributes(t *types.UpsertWorkflowSearchAttributesEventAttributes) *shared.UpsertWorkflowSearchAttributesEventAttributes

FromUpsertWorkflowSearchAttributesEventAttributes converts internal UpsertWorkflowSearchAttributesEventAttributes type to thrift

func FromVersionHistories ¶

func FromVersionHistories(t *types.VersionHistories) *shared.VersionHistories

FromVersionHistories converts internal VersionHistories type to thrift

func FromVersionHistory ¶

func FromVersionHistory(t *types.VersionHistory) *shared.VersionHistory

FromVersionHistory converts internal VersionHistory type to thrift

func FromVersionHistoryArray ¶

func FromVersionHistoryArray(t []*types.VersionHistory) []*shared.VersionHistory

FromVersionHistoryArray converts internal VersionHistory type array to thrift

func FromVersionHistoryItem ¶

func FromVersionHistoryItem(t *types.VersionHistoryItem) *shared.VersionHistoryItem

FromVersionHistoryItem converts internal VersionHistoryItem type to thrift

func FromVersionHistoryItemArray ¶

func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*shared.VersionHistoryItem

FromVersionHistoryItemArray converts internal VersionHistoryItem type array to thrift

func FromWorkerVersionInfo ¶

func FromWorkerVersionInfo(t *types.WorkerVersionInfo) *shared.WorkerVersionInfo

FromWorkerVersionInfo converts internal WorkerVersionInfo type to thrift

func FromWorkflowExecution ¶

func FromWorkflowExecution(t *types.WorkflowExecution) *shared.WorkflowExecution

FromWorkflowExecution converts internal WorkflowExecution type to thrift

func FromWorkflowExecutionAlreadyCompletedError ¶ added in v0.21.0

func FromWorkflowExecutionAlreadyCompletedError(t *types.WorkflowExecutionAlreadyCompletedError) *shared.WorkflowExecutionAlreadyCompletedError

FromWorkflowExecutionAlreadyCompletedError converts internal WorkflowExecutionAlreadyCompletedError type to thrift

func FromWorkflowExecutionAlreadyStartedError ¶

func FromWorkflowExecutionAlreadyStartedError(t *types.WorkflowExecutionAlreadyStartedError) *shared.WorkflowExecutionAlreadyStartedError

FromWorkflowExecutionAlreadyStartedError converts internal WorkflowExecutionAlreadyStartedError type to thrift

func FromWorkflowExecutionCancelRequestedEventAttributes ¶

func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecutionCancelRequestedEventAttributes) *shared.WorkflowExecutionCancelRequestedEventAttributes

FromWorkflowExecutionCancelRequestedEventAttributes converts internal WorkflowExecutionCancelRequestedEventAttributes type to thrift

func FromWorkflowExecutionCanceledEventAttributes ¶

func FromWorkflowExecutionCanceledEventAttributes(t *types.WorkflowExecutionCanceledEventAttributes) *shared.WorkflowExecutionCanceledEventAttributes

FromWorkflowExecutionCanceledEventAttributes converts internal WorkflowExecutionCanceledEventAttributes type to thrift

func FromWorkflowExecutionCloseStatus ¶

func FromWorkflowExecutionCloseStatus(t *types.WorkflowExecutionCloseStatus) *shared.WorkflowExecutionCloseStatus

FromWorkflowExecutionCloseStatus converts internal WorkflowExecutionCloseStatus type to thrift

func FromWorkflowExecutionCompletedEventAttributes ¶

func FromWorkflowExecutionCompletedEventAttributes(t *types.WorkflowExecutionCompletedEventAttributes) *shared.WorkflowExecutionCompletedEventAttributes

FromWorkflowExecutionCompletedEventAttributes converts internal WorkflowExecutionCompletedEventAttributes type to thrift

func FromWorkflowExecutionConfiguration ¶

func FromWorkflowExecutionConfiguration(t *types.WorkflowExecutionConfiguration) *shared.WorkflowExecutionConfiguration

FromWorkflowExecutionConfiguration converts internal WorkflowExecutionConfiguration type to thrift

func FromWorkflowExecutionContinuedAsNewEventAttributes ¶

func FromWorkflowExecutionContinuedAsNewEventAttributes(t *types.WorkflowExecutionContinuedAsNewEventAttributes) *shared.WorkflowExecutionContinuedAsNewEventAttributes

FromWorkflowExecutionContinuedAsNewEventAttributes converts internal WorkflowExecutionContinuedAsNewEventAttributes type to thrift

func FromWorkflowExecutionFailedEventAttributes ¶

func FromWorkflowExecutionFailedEventAttributes(t *types.WorkflowExecutionFailedEventAttributes) *shared.WorkflowExecutionFailedEventAttributes

FromWorkflowExecutionFailedEventAttributes converts internal WorkflowExecutionFailedEventAttributes type to thrift

func FromWorkflowExecutionFilter ¶

func FromWorkflowExecutionFilter(t *types.WorkflowExecutionFilter) *shared.WorkflowExecutionFilter

FromWorkflowExecutionFilter converts internal WorkflowExecutionFilter type to thrift

func FromWorkflowExecutionInfo ¶

func FromWorkflowExecutionInfo(t *types.WorkflowExecutionInfo) *shared.WorkflowExecutionInfo

FromWorkflowExecutionInfo converts internal WorkflowExecutionInfo type to thrift

func FromWorkflowExecutionInfoArray ¶

func FromWorkflowExecutionInfoArray(t []*types.WorkflowExecutionInfo) []*shared.WorkflowExecutionInfo

FromWorkflowExecutionInfoArray converts internal WorkflowExecutionInfo type array to thrift

func FromWorkflowExecutionSignaledEventAttributes ¶

func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSignaledEventAttributes) *shared.WorkflowExecutionSignaledEventAttributes

FromWorkflowExecutionSignaledEventAttributes converts internal WorkflowExecutionSignaledEventAttributes type to thrift

func FromWorkflowExecutionStartedEventAttributes ¶

func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStartedEventAttributes) *shared.WorkflowExecutionStartedEventAttributes

FromWorkflowExecutionStartedEventAttributes converts internal WorkflowExecutionStartedEventAttributes type to thrift

func FromWorkflowExecutionTerminatedEventAttributes ¶

func FromWorkflowExecutionTerminatedEventAttributes(t *types.WorkflowExecutionTerminatedEventAttributes) *shared.WorkflowExecutionTerminatedEventAttributes

FromWorkflowExecutionTerminatedEventAttributes converts internal WorkflowExecutionTerminatedEventAttributes type to thrift

func FromWorkflowExecutionTimedOutEventAttributes ¶

func FromWorkflowExecutionTimedOutEventAttributes(t *types.WorkflowExecutionTimedOutEventAttributes) *shared.WorkflowExecutionTimedOutEventAttributes

FromWorkflowExecutionTimedOutEventAttributes converts internal WorkflowExecutionTimedOutEventAttributes type to thrift

func FromWorkflowIDReusePolicy ¶

func FromWorkflowIDReusePolicy(t *types.WorkflowIDReusePolicy) *shared.WorkflowIdReusePolicy

FromWorkflowIDReusePolicy converts internal WorkflowIDReusePolicy type to thrift

func FromWorkflowQuery ¶

func FromWorkflowQuery(t *types.WorkflowQuery) *shared.WorkflowQuery

FromWorkflowQuery converts internal WorkflowQuery type to thrift

func FromWorkflowQueryMap ¶

func FromWorkflowQueryMap(t map[string]*types.WorkflowQuery) map[string]*shared.WorkflowQuery

FromWorkflowQueryMap converts internal WorkflowQuery type map to thrift

func FromWorkflowQueryResult ¶

func FromWorkflowQueryResult(t *types.WorkflowQueryResult) *shared.WorkflowQueryResult

FromWorkflowQueryResult converts internal WorkflowQueryResult type to thrift

func FromWorkflowQueryResultMap ¶

func FromWorkflowQueryResultMap(t map[string]*types.WorkflowQueryResult) map[string]*shared.WorkflowQueryResult

FromWorkflowQueryResultMap converts internal WorkflowQueryResult type map to thrift

func FromWorkflowType ¶

func FromWorkflowType(t *types.WorkflowType) *shared.WorkflowType

FromWorkflowType converts internal WorkflowType type to thrift

func FromWorkflowTypeFilter ¶

func FromWorkflowTypeFilter(t *types.WorkflowTypeFilter) *shared.WorkflowTypeFilter

FromWorkflowTypeFilter converts internal WorkflowTypeFilter type to thrift

func ToAccessDeniedError ¶

func ToAccessDeniedError(t *shared.AccessDeniedError) *types.AccessDeniedError

ToAccessDeniedError converts thrift AccessDeniedError type to internal

func ToActivityLocalDispatchInfo ¶ added in v0.17.0

func ToActivityLocalDispatchInfo(t *shared.ActivityLocalDispatchInfo) *types.ActivityLocalDispatchInfo

ToActivityLocalDispatchInfo converts thrift ActivityLocalDispatchInfo type to internal

func ToActivityLocalDispatchInfoMap ¶ added in v0.17.0

func ToActivityLocalDispatchInfoMap(t map[string]*shared.ActivityLocalDispatchInfo) map[string]*types.ActivityLocalDispatchInfo

ToActivityLocalDispatchInfoMap converts thrift ActivityLocalDispatchInfo type map to internal

func ToActivityTaskCancelRequestedEventAttributes ¶

func ToActivityTaskCancelRequestedEventAttributes(t *shared.ActivityTaskCancelRequestedEventAttributes) *types.ActivityTaskCancelRequestedEventAttributes

ToActivityTaskCancelRequestedEventAttributes converts thrift ActivityTaskCancelRequestedEventAttributes type to internal

func ToActivityTaskCanceledEventAttributes ¶

func ToActivityTaskCanceledEventAttributes(t *shared.ActivityTaskCanceledEventAttributes) *types.ActivityTaskCanceledEventAttributes

ToActivityTaskCanceledEventAttributes converts thrift ActivityTaskCanceledEventAttributes type to internal

func ToActivityTaskCompletedEventAttributes ¶

func ToActivityTaskCompletedEventAttributes(t *shared.ActivityTaskCompletedEventAttributes) *types.ActivityTaskCompletedEventAttributes

ToActivityTaskCompletedEventAttributes converts thrift ActivityTaskCompletedEventAttributes type to internal

func ToActivityTaskDispatchInfo ¶ added in v0.24.0

func ToActivityTaskDispatchInfo(t *matching.ActivityTaskDispatchInfo) *types.ActivityTaskDispatchInfo

ToRecordActivityTaskStartedResponse converts thrift RecordActivityTaskStartedResponse type to internal

func ToActivityTaskFailedEventAttributes ¶

func ToActivityTaskFailedEventAttributes(t *shared.ActivityTaskFailedEventAttributes) *types.ActivityTaskFailedEventAttributes

ToActivityTaskFailedEventAttributes converts thrift ActivityTaskFailedEventAttributes type to internal

func ToActivityTaskScheduledEventAttributes ¶

func ToActivityTaskScheduledEventAttributes(t *shared.ActivityTaskScheduledEventAttributes) *types.ActivityTaskScheduledEventAttributes

ToActivityTaskScheduledEventAttributes converts thrift ActivityTaskScheduledEventAttributes type to internal

func ToActivityTaskStartedEventAttributes ¶

func ToActivityTaskStartedEventAttributes(t *shared.ActivityTaskStartedEventAttributes) *types.ActivityTaskStartedEventAttributes

ToActivityTaskStartedEventAttributes converts thrift ActivityTaskStartedEventAttributes type to internal

func ToActivityTaskTimedOutEventAttributes ¶

func ToActivityTaskTimedOutEventAttributes(t *shared.ActivityTaskTimedOutEventAttributes) *types.ActivityTaskTimedOutEventAttributes

ToActivityTaskTimedOutEventAttributes converts thrift ActivityTaskTimedOutEventAttributes type to internal

func ToActivityType ¶

func ToActivityType(t *shared.ActivityType) *types.ActivityType

ToActivityType converts thrift ActivityType type to internal

func ToAdminAddSearchAttributeRequest ¶ added in v1.2.7

func ToAdminAddSearchAttributeRequest(t *admin.AddSearchAttributeRequest) *types.AddSearchAttributeRequest

ToAdminAddSearchAttributeRequest converts thrift AddSearchAttributeRequest type to internal

func ToAdminCloseShardRequest ¶ added in v1.2.7

func ToAdminCloseShardRequest(t *shared.CloseShardRequest) *types.CloseShardRequest

ToAdminCloseShardRequest converts thrift CloseShardRequest type to internal

func ToAdminDeleteWorkflowRequest ¶ added in v0.24.0

func ToAdminDeleteWorkflowRequest(t *admin.AdminDeleteWorkflowRequest) *types.AdminDeleteWorkflowRequest

ToAdminDeleteWorkflowRequest converts thrift AdminDeleteWorkflowRequest type to internal

func ToAdminDeleteWorkflowResponse ¶ added in v0.24.0

func ToAdminDeleteWorkflowResponse(t *admin.AdminDeleteWorkflowResponse) *types.AdminDeleteWorkflowResponse

ToAdminDeleteWorkflowResponse converts thrift AdminDeleteWorkflowResponse type to internal

func ToAdminDescribeClusterResponse ¶ added in v1.2.7

func ToAdminDescribeClusterResponse(t *admin.DescribeClusterResponse) *types.DescribeClusterResponse

ToAdminDescribeClusterResponse converts thrift DescribeClusterResponse type to internal

func ToAdminDescribeHistoryHostRequest ¶ added in v1.2.7

func ToAdminDescribeHistoryHostRequest(t *shared.DescribeHistoryHostRequest) *types.DescribeHistoryHostRequest

ToAdminDescribeHistoryHostRequest converts thrift DescribeHistoryHostRequest type to internal

func ToAdminDescribeHistoryHostResponse ¶ added in v1.2.7

func ToAdminDescribeHistoryHostResponse(t *shared.DescribeHistoryHostResponse) *types.DescribeHistoryHostResponse

ToAdminDescribeHistoryHostResponse converts thrift DescribeHistoryHostResponse type to internal

func ToAdminDescribeQueueRequest ¶ added in v1.2.7

func ToAdminDescribeQueueRequest(t *shared.DescribeQueueRequest) *types.DescribeQueueRequest

ToAdminDescribeQueueRequest converts thrift DescribeQueueRequest type to internal

func ToAdminDescribeQueueResponse ¶ added in v1.2.7

func ToAdminDescribeQueueResponse(t *shared.DescribeQueueResponse) *types.DescribeQueueResponse

ToAdminDescribeQueueResponse converts thrift DescribeQueueResponse type to internal

func ToAdminDescribeShardDistributionRequest ¶ added in v1.2.7

func ToAdminDescribeShardDistributionRequest(t *shared.DescribeShardDistributionRequest) *types.DescribeShardDistributionRequest

ToAdminDescribeShardDistributionRequest converts thrift DescribeHistoryHostRequest type to internal

func ToAdminDescribeShardDistributionResponse ¶ added in v1.2.7

func ToAdminDescribeShardDistributionResponse(t *shared.DescribeShardDistributionResponse) *types.DescribeShardDistributionResponse

ToAdminDescribeShardDistributionResponse converts thrift DescribeHistoryHostResponse type to internal

func ToAdminDescribeWorkflowExecutionRequest ¶ added in v0.17.0

func ToAdminDescribeWorkflowExecutionRequest(t *admin.DescribeWorkflowExecutionRequest) *types.AdminDescribeWorkflowExecutionRequest

ToAdminDescribeWorkflowExecutionRequest converts thrift DescribeWorkflowExecutionRequest type to internal

func ToAdminDescribeWorkflowExecutionResponse ¶ added in v0.17.0

func ToAdminDescribeWorkflowExecutionResponse(t *admin.DescribeWorkflowExecutionResponse) *types.AdminDescribeWorkflowExecutionResponse

ToAdminDescribeWorkflowExecutionResponse converts thrift DescribeWorkflowExecutionResponse type to internal

func ToAdminGetCrossClusterTasksRequest ¶ added in v1.2.7

func ToAdminGetCrossClusterTasksRequest(t *shared.GetCrossClusterTasksRequest) *types.GetCrossClusterTasksRequest

ToAdminGetCrossClusterTasksRequest converts thrift GetCrossClusterTasksRequest type to internal

func ToAdminGetCrossClusterTasksResponse ¶ added in v1.2.7

func ToAdminGetCrossClusterTasksResponse(t *shared.GetCrossClusterTasksResponse) *types.GetCrossClusterTasksResponse

ToAdminGetCrossClusterTasksResponse converts thrift GetCrossClusterTasksResponse type to internal

func ToAdminGetDLQReplicationMessagesRequest ¶ added in v1.2.7

func ToAdminGetDLQReplicationMessagesRequest(t *replicator.GetDLQReplicationMessagesRequest) *types.GetDLQReplicationMessagesRequest

ToAdminGetDLQReplicationMessagesRequest converts thrift GetDLQReplicationMessagesRequest type to internal

func ToAdminGetDLQReplicationMessagesResponse ¶ added in v1.2.7

func ToAdminGetDLQReplicationMessagesResponse(t *replicator.GetDLQReplicationMessagesResponse) *types.GetDLQReplicationMessagesResponse

ToAdminGetDLQReplicationMessagesResponse converts thrift GetDLQReplicationMessagesResponse type to internal

func ToAdminGetDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.7

func ToAdminGetDomainAsyncWorkflowConfiguratonRequest(in *admin.GetDomainAsyncWorkflowConfiguratonRequest) *types.GetDomainAsyncWorkflowConfiguratonRequest

func ToAdminGetDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.8

func ToAdminGetDomainAsyncWorkflowConfiguratonResponse(in *admin.GetDomainAsyncWorkflowConfiguratonResponse) *types.GetDomainAsyncWorkflowConfiguratonResponse

func ToAdminGetDomainIsolationGroupsRequest ¶ added in v1.2.7

func ToAdminGetDomainIsolationGroupsRequest(t *admin.GetDomainIsolationGroupsRequest) *types.GetDomainIsolationGroupsRequest

func ToAdminGetDomainIsolationGroupsResponse ¶ added in v1.2.7

func ToAdminGetDomainIsolationGroupsResponse(t *admin.GetDomainIsolationGroupsResponse) *types.GetDomainIsolationGroupsResponse

func ToAdminGetDomainReplicationMessagesRequest ¶ added in v1.2.7

func ToAdminGetDomainReplicationMessagesRequest(t *replicator.GetDomainReplicationMessagesRequest) *types.GetDomainReplicationMessagesRequest

ToAdminGetDomainReplicationMessagesRequest converts thrift GetDomainReplicationMessagesRequest type to internal

func ToAdminGetDomainReplicationMessagesResponse ¶ added in v1.2.7

func ToAdminGetDomainReplicationMessagesResponse(t *replicator.GetDomainReplicationMessagesResponse) *types.GetDomainReplicationMessagesResponse

ToAdminGetDomainReplicationMessagesResponse converts thrift GetDomainReplicationMessagesResponse type to internal

func ToAdminGetDynamicConfigRequest ¶ added in v1.2.7

func ToAdminGetDynamicConfigRequest(t *admin.GetDynamicConfigRequest) *types.GetDynamicConfigRequest

ToAdminGetDynamicConfigRequest converts thrift GetDynamicConfigRequest type to internal

func ToAdminGetDynamicConfigResponse ¶ added in v1.2.7

func ToAdminGetDynamicConfigResponse(t *admin.GetDynamicConfigResponse) *types.GetDynamicConfigResponse

ToAdminGetDynamicConfigResponse converts thrift GetDynamicConfigResponse type to internal

func ToAdminGetGlobalIsolationGroupsRequest ¶ added in v1.2.7

func ToAdminGetGlobalIsolationGroupsRequest(t *admin.GetGlobalIsolationGroupsRequest) *types.GetGlobalIsolationGroupsRequest

func ToAdminGetGlobalIsolationGroupsResponse ¶ added in v1.2.7

func ToAdminGetGlobalIsolationGroupsResponse(t *admin.GetGlobalIsolationGroupsResponse) *types.GetGlobalIsolationGroupsResponse

func ToAdminGetReplicationMessagesRequest ¶ added in v1.2.7

func ToAdminGetReplicationMessagesRequest(t *replicator.GetReplicationMessagesRequest) *types.GetReplicationMessagesRequest

ToAdminGetReplicationMessagesRequest converts thrift GetReplicationMessagesRequest type to internal

func ToAdminGetReplicationMessagesResponse ¶ added in v1.2.7

func ToAdminGetReplicationMessagesResponse(t *replicator.GetReplicationMessagesResponse) *types.GetReplicationMessagesResponse

ToAdminGetReplicationMessagesResponse converts thrift GetReplicationMessagesResponse type to internal

func ToAdminGetWorkflowExecutionRawHistoryV2Request ¶ added in v1.2.7

func ToAdminGetWorkflowExecutionRawHistoryV2Request(t *admin.GetWorkflowExecutionRawHistoryV2Request) *types.GetWorkflowExecutionRawHistoryV2Request

ToAdminGetWorkflowExecutionRawHistoryV2Request converts thrift GetWorkflowExecutionRawHistoryV2Request type to internal

func ToAdminGetWorkflowExecutionRawHistoryV2Response ¶ added in v1.2.7

func ToAdminGetWorkflowExecutionRawHistoryV2Response(t *admin.GetWorkflowExecutionRawHistoryV2Response) *types.GetWorkflowExecutionRawHistoryV2Response

ToAdminGetWorkflowExecutionRawHistoryV2Response converts thrift GetWorkflowExecutionRawHistoryV2Response type to internal

func ToAdminListDynamicConfigRequest ¶ added in v1.2.7

func ToAdminListDynamicConfigRequest(t *admin.ListDynamicConfigRequest) *types.ListDynamicConfigRequest

ToAdminListDynamicConfigRequest converts thrift ListDynamicConfigRequest type to internal

func ToAdminListDynamicConfigResponse ¶ added in v1.2.7

func ToAdminListDynamicConfigResponse(t *admin.ListDynamicConfigResponse) *types.ListDynamicConfigResponse

ToAdminListDynamicConfigResponse converts thrift ListDynamicConfigResponse type to internal

func ToAdminMaintainCorruptWorkflowRequest ¶ added in v1.2.7

func ToAdminMaintainCorruptWorkflowRequest(t *admin.AdminMaintainWorkflowRequest) *types.AdminMaintainWorkflowRequest

ToAdminMaintainCorruptWorkflowRequest converts thrift AdminMaintainWorkflowRequest type to internal

func ToAdminMaintainCorruptWorkflowResponse ¶ added in v1.2.7

func ToAdminMaintainCorruptWorkflowResponse(t *admin.AdminMaintainWorkflowResponse) *types.AdminMaintainWorkflowResponse

ToAdminMaintainCorruptWorkflowResponse converts thrift AdminMaintainWorkflowResponse type to internal

func ToAdminMergeDLQMessagesRequest ¶ added in v1.2.7

func ToAdminMergeDLQMessagesRequest(t *replicator.MergeDLQMessagesRequest) *types.MergeDLQMessagesRequest

ToAdminMergeDLQMessagesRequest converts thrift MergeDLQMessagesRequest type to internal

func ToAdminMergeDLQMessagesResponse ¶ added in v1.2.7

func ToAdminMergeDLQMessagesResponse(t *replicator.MergeDLQMessagesResponse) *types.MergeDLQMessagesResponse

ToAdminMergeDLQMessagesResponse converts thrift MergeDLQMessagesResponse type to internal

func ToAdminPurgeDLQMessagesRequest ¶ added in v1.2.7

func ToAdminPurgeDLQMessagesRequest(t *replicator.PurgeDLQMessagesRequest) *types.PurgeDLQMessagesRequest

ToAdminPurgeDLQMessagesRequest converts thrift PurgeDLQMessagesRequest type to internal

func ToAdminReadDLQMessagesRequest ¶ added in v1.2.7

func ToAdminReadDLQMessagesRequest(t *replicator.ReadDLQMessagesRequest) *types.ReadDLQMessagesRequest

ToAdminReadDLQMessagesRequest converts thrift ReadDLQMessagesRequest type to internal

func ToAdminReadDLQMessagesResponse ¶ added in v1.2.7

func ToAdminReadDLQMessagesResponse(t *replicator.ReadDLQMessagesResponse) *types.ReadDLQMessagesResponse

ToAdminReadDLQMessagesResponse converts thrift ReadDLQMessagesResponse type to internal

func ToAdminReapplyEventsRequest ¶ added in v1.2.7

func ToAdminReapplyEventsRequest(t *shared.ReapplyEventsRequest) *types.ReapplyEventsRequest

ToAdminReapplyEventsRequest converts thrift ReapplyEventsRequest type to internal

func ToAdminRemoveTaskRequest ¶ added in v1.2.7

func ToAdminRemoveTaskRequest(t *shared.RemoveTaskRequest) *types.RemoveTaskRequest

ToAdminRemoveTaskRequest converts thrift RemoveTaskRequest type to internal

func ToAdminResendReplicationTasksRequest ¶ added in v1.2.7

func ToAdminResendReplicationTasksRequest(t *admin.ResendReplicationTasksRequest) *types.ResendReplicationTasksRequest

ToAdminResendReplicationTasksRequest converts thrift ResendReplicationTasksRequest type to internal

func ToAdminResetQueueRequest ¶ added in v1.2.7

func ToAdminResetQueueRequest(t *shared.ResetQueueRequest) *types.ResetQueueRequest

ToAdminResetQueueRequest converts thrift ResetQueueRequest type to internal

func ToAdminRespondCrossClusterTasksCompletedRequest ¶ added in v1.2.7

func ToAdminRespondCrossClusterTasksCompletedRequest(t *shared.RespondCrossClusterTasksCompletedRequest) *types.RespondCrossClusterTasksCompletedRequest

ToAdminRespondCrossClusterTasksCompletedRequest converts thrift RespondCrossClusterTasksCompletedRequest type to internal

func ToAdminRespondCrossClusterTasksCompletedResponse ¶ added in v1.2.7

func ToAdminRespondCrossClusterTasksCompletedResponse(t *shared.RespondCrossClusterTasksCompletedResponse) *types.RespondCrossClusterTasksCompletedResponse

ToAdminRespondCrossClusterTasksCompletedResponse converts thrift RespondCrossClusterTasksCompletedResponse type to internal

func ToAdminRestoreDynamicConfigRequest ¶ added in v1.2.7

func ToAdminRestoreDynamicConfigRequest(t *admin.RestoreDynamicConfigRequest) *types.RestoreDynamicConfigRequest

ToAdminRestoreDynamicConfigRequest converts thrift RestoreDynamicConfigRequest type to internal

func ToAdminUpdateDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.7

func ToAdminUpdateDomainAsyncWorkflowConfiguratonRequest(in *admin.UpdateDomainAsyncWorkflowConfiguratonRequest) *types.UpdateDomainAsyncWorkflowConfiguratonRequest

func ToAdminUpdateDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.8

func ToAdminUpdateDomainAsyncWorkflowConfiguratonResponse(in *admin.UpdateDomainAsyncWorkflowConfiguratonResponse) *types.UpdateDomainAsyncWorkflowConfiguratonResponse

func ToAdminUpdateDomainIsolationGroupsRequest ¶ added in v1.2.7

func ToAdminUpdateDomainIsolationGroupsRequest(t *admin.UpdateDomainIsolationGroupsRequest) *types.UpdateDomainIsolationGroupsRequest

func ToAdminUpdateDomainIsolationGroupsResponse ¶ added in v1.2.7

func ToAdminUpdateDomainIsolationGroupsResponse(t *admin.UpdateDomainIsolationGroupsResponse) *types.UpdateDomainIsolationGroupsResponse

func ToAdminUpdateDynamicConfigRequest ¶ added in v1.2.7

func ToAdminUpdateDynamicConfigRequest(t *admin.UpdateDynamicConfigRequest) *types.UpdateDynamicConfigRequest

ToAdminUpdateDynamicConfigRequest converts thrift UpdateDynamicConfigRequest type to internal

func ToAdminUpdateGlobalIsolationGroupsRequest ¶ added in v1.2.7

func ToAdminUpdateGlobalIsolationGroupsRequest(t *admin.UpdateGlobalIsolationGroupsRequest) *types.UpdateGlobalIsolationGroupsRequest

func ToAdminUpdateGlobalIsolationGroupsResponse ¶ added in v1.2.7

func ToAdminUpdateGlobalIsolationGroupsResponse(t *admin.UpdateGlobalIsolationGroupsResponse) *types.UpdateGlobalIsolationGroupsResponse

func ToAny ¶ added in v1.2.10

func ToAny(t *shared.Any) *types.Any

ToAny converts thrift Any type to internal

func ToApplyParentClosePolicyAttributes ¶ added in v0.24.0

func ToApplyParentClosePolicyAttributes(
	t *shared.ApplyParentClosePolicyAttributes,
) *types.ApplyParentClosePolicyAttributes

ToApplyParentClosePolicyAttributes converts thrift ApplyParentClosePolicyAttributes types to internal

func ToApplyParentClosePolicyRequest ¶ added in v0.24.0

func ToApplyParentClosePolicyRequest(
	t *shared.ApplyParentClosePolicyRequest,
) *types.ApplyParentClosePolicyRequest

ToApplyParentClosePolicyRequest converts thrift ApplyParentClosePolicyRequest types to internal

func ToApplyParentClosePolicyRequestArray ¶ added in v0.24.0

func ToApplyParentClosePolicyRequestArray(
	t []*shared.ApplyParentClosePolicyRequest,
) []*types.ApplyParentClosePolicyRequest

ToApplyParentClosePolicyRequestArray converts internal ApplyParentClosePolicyRequestArray types to thrift

func ToApplyParentClosePolicyResult ¶ added in v0.24.0

func ToApplyParentClosePolicyResult(
	t *shared.ApplyParentClosePolicyResult,
) *types.ApplyParentClosePolicyResult

ToApplyParentClosePolicyResult converts thrift ApplyParentClosePolicyResult types to internal

func ToApplyParentClosePolicyResultArray ¶ added in v0.24.0

func ToApplyParentClosePolicyResultArray(
	t []*shared.ApplyParentClosePolicyResult,
) []*types.ApplyParentClosePolicyResult

ToApplyParentClosePolicyResultArray converts internal ApplyParentClosePolicyResultArray types to thrift

func ToApplyParentClosePolicyStatus ¶ added in v0.24.0

func ToApplyParentClosePolicyStatus(
	t *shared.ApplyParentClosePolicyStatus,
) *types.ApplyParentClosePolicyStatus

ToApplyParentClosePolicyStatus converts thrift ApplyParentClosePolicyStatus types to internal

func ToArchivalStatus ¶

func ToArchivalStatus(t *shared.ArchivalStatus) *types.ArchivalStatus

ToArchivalStatus converts thrift ArchivalStatus type to internal

func ToAutoConfigHint ¶

func ToAutoConfigHint(t *shared.AutoConfigHint) *types.AutoConfigHint

ToWorkflowQuery converts thrift WorkflowQuery type to internal

func ToBadBinaries ¶

func ToBadBinaries(t *shared.BadBinaries) *types.BadBinaries

ToBadBinaries converts thrift BadBinaries type to internal

func ToBadBinaryInfo ¶

func ToBadBinaryInfo(t *shared.BadBinaryInfo) *types.BadBinaryInfo

ToBadBinaryInfo converts thrift BadBinaryInfo type to internal

func ToBadBinaryInfoMap ¶

func ToBadBinaryInfoMap(t map[string]*shared.BadBinaryInfo) map[string]*types.BadBinaryInfo

ToBadBinaryInfoMap converts thrift BadBinaryInfo type map to internal

func ToBadRequestError ¶

func ToBadRequestError(t *shared.BadRequestError) *types.BadRequestError

ToBadRequestError converts thrift BadRequestError type to internal

func ToCancelExternalWorkflowExecutionFailedCause ¶

func ToCancelExternalWorkflowExecutionFailedCause(t *shared.CancelExternalWorkflowExecutionFailedCause) *types.CancelExternalWorkflowExecutionFailedCause

ToCancelExternalWorkflowExecutionFailedCause converts thrift CancelExternalWorkflowExecutionFailedCause type to internal

func ToCancelTimerDecisionAttributes ¶

func ToCancelTimerDecisionAttributes(t *shared.CancelTimerDecisionAttributes) *types.CancelTimerDecisionAttributes

ToCancelTimerDecisionAttributes converts thrift CancelTimerDecisionAttributes type to internal

func ToCancelTimerFailedEventAttributes ¶

func ToCancelTimerFailedEventAttributes(t *shared.CancelTimerFailedEventAttributes) *types.CancelTimerFailedEventAttributes

ToCancelTimerFailedEventAttributes converts thrift CancelTimerFailedEventAttributes type to internal

func ToCancelWorkflowExecutionDecisionAttributes ¶

func ToCancelWorkflowExecutionDecisionAttributes(t *shared.CancelWorkflowExecutionDecisionAttributes) *types.CancelWorkflowExecutionDecisionAttributes

ToCancelWorkflowExecutionDecisionAttributes converts thrift CancelWorkflowExecutionDecisionAttributes type to internal

func ToCancellationAlreadyRequestedError ¶

func ToCancellationAlreadyRequestedError(t *shared.CancellationAlreadyRequestedError) *types.CancellationAlreadyRequestedError

ToCancellationAlreadyRequestedError converts thrift CancellationAlreadyRequestedError type to internal

func ToChildWorkflowExecutionCanceledEventAttributes ¶

func ToChildWorkflowExecutionCanceledEventAttributes(t *shared.ChildWorkflowExecutionCanceledEventAttributes) *types.ChildWorkflowExecutionCanceledEventAttributes

ToChildWorkflowExecutionCanceledEventAttributes converts thrift ChildWorkflowExecutionCanceledEventAttributes type to internal

func ToChildWorkflowExecutionCompletedEventAttributes ¶

func ToChildWorkflowExecutionCompletedEventAttributes(t *shared.ChildWorkflowExecutionCompletedEventAttributes) *types.ChildWorkflowExecutionCompletedEventAttributes

ToChildWorkflowExecutionCompletedEventAttributes converts thrift ChildWorkflowExecutionCompletedEventAttributes type to internal

func ToChildWorkflowExecutionFailedCause ¶

func ToChildWorkflowExecutionFailedCause(t *shared.ChildWorkflowExecutionFailedCause) *types.ChildWorkflowExecutionFailedCause

ToChildWorkflowExecutionFailedCause converts thrift ChildWorkflowExecutionFailedCause type to internal

func ToChildWorkflowExecutionFailedEventAttributes ¶

func ToChildWorkflowExecutionFailedEventAttributes(t *shared.ChildWorkflowExecutionFailedEventAttributes) *types.ChildWorkflowExecutionFailedEventAttributes

ToChildWorkflowExecutionFailedEventAttributes converts thrift ChildWorkflowExecutionFailedEventAttributes type to internal

func ToChildWorkflowExecutionStartedEventAttributes ¶

func ToChildWorkflowExecutionStartedEventAttributes(t *shared.ChildWorkflowExecutionStartedEventAttributes) *types.ChildWorkflowExecutionStartedEventAttributes

ToChildWorkflowExecutionStartedEventAttributes converts thrift ChildWorkflowExecutionStartedEventAttributes type to internal

func ToChildWorkflowExecutionTerminatedEventAttributes ¶

func ToChildWorkflowExecutionTerminatedEventAttributes(t *shared.ChildWorkflowExecutionTerminatedEventAttributes) *types.ChildWorkflowExecutionTerminatedEventAttributes

ToChildWorkflowExecutionTerminatedEventAttributes converts thrift ChildWorkflowExecutionTerminatedEventAttributes type to internal

func ToChildWorkflowExecutionTimedOutEventAttributes ¶

func ToChildWorkflowExecutionTimedOutEventAttributes(t *shared.ChildWorkflowExecutionTimedOutEventAttributes) *types.ChildWorkflowExecutionTimedOutEventAttributes

ToChildWorkflowExecutionTimedOutEventAttributes converts thrift ChildWorkflowExecutionTimedOutEventAttributes type to internal

func ToClientVersionNotSupportedError ¶

func ToClientVersionNotSupportedError(t *shared.ClientVersionNotSupportedError) *types.ClientVersionNotSupportedError

ToClientVersionNotSupportedError converts thrift ClientVersionNotSupportedError type to internal

func ToClusterReplicationConfiguration ¶

func ToClusterReplicationConfiguration(t *shared.ClusterReplicationConfiguration) *types.ClusterReplicationConfiguration

ToClusterReplicationConfiguration converts thrift ClusterReplicationConfiguration type to internal

func ToClusterReplicationConfigurationArray ¶

func ToClusterReplicationConfigurationArray(t []*shared.ClusterReplicationConfiguration) []*types.ClusterReplicationConfiguration

ToClusterReplicationConfigurationArray converts thrift ClusterReplicationConfiguration type array to internal

func ToCompleteWorkflowExecutionDecisionAttributes ¶

func ToCompleteWorkflowExecutionDecisionAttributes(t *shared.CompleteWorkflowExecutionDecisionAttributes) *types.CompleteWorkflowExecutionDecisionAttributes

ToCompleteWorkflowExecutionDecisionAttributes converts thrift CompleteWorkflowExecutionDecisionAttributes type to internal

func ToContinueAsNewInitiator ¶

func ToContinueAsNewInitiator(t *shared.ContinueAsNewInitiator) *types.ContinueAsNewInitiator

ToContinueAsNewInitiator converts thrift ContinueAsNewInitiator type to internal

func ToContinueAsNewWorkflowExecutionDecisionAttributes ¶

func ToContinueAsNewWorkflowExecutionDecisionAttributes(t *shared.ContinueAsNewWorkflowExecutionDecisionAttributes) *types.ContinueAsNewWorkflowExecutionDecisionAttributes

ToContinueAsNewWorkflowExecutionDecisionAttributes converts thrift ContinueAsNewWorkflowExecutionDecisionAttributes type to internal

func ToCountWorkflowExecutionsRequest ¶

func ToCountWorkflowExecutionsRequest(t *shared.CountWorkflowExecutionsRequest) *types.CountWorkflowExecutionsRequest

ToCountWorkflowExecutionsRequest converts thrift CountWorkflowExecutionsRequest type to internal

func ToCountWorkflowExecutionsResponse ¶

func ToCountWorkflowExecutionsResponse(t *shared.CountWorkflowExecutionsResponse) *types.CountWorkflowExecutionsResponse

ToCountWorkflowExecutionsResponse converts thrift CountWorkflowExecutionsResponse type to internal

func ToCrossClusterApplyParentClosePolicyRequestAttributes ¶ added in v0.24.0

func ToCrossClusterApplyParentClosePolicyRequestAttributes(
	t *shared.CrossClusterApplyParentClosePolicyRequestAttributes,
) *types.CrossClusterApplyParentClosePolicyRequestAttributes

ToCrossClusterApplyParentClosePolicyRequestAttributes converts thrift CrossClusterApplyParentClosePolicyRequestAttributes types to internal

func ToCrossClusterApplyParentClosePolicyResponseAttributes ¶ added in v0.24.0

func ToCrossClusterApplyParentClosePolicyResponseAttributes(
	t *shared.CrossClusterApplyParentClosePolicyResponseAttributes,
) *types.CrossClusterApplyParentClosePolicyResponseAttributes

ToCrossClusterApplyParentClosePolicyResponseAttributes converts thrift CrossClusterApplyParentClosePolicyResponseAttributes type to internal

func ToCrossClusterCancelExecutionRequestAttributes ¶ added in v0.23.1

func ToCrossClusterCancelExecutionRequestAttributes(t *shared.CrossClusterCancelExecutionRequestAttributes) *types.CrossClusterCancelExecutionRequestAttributes

ToCrossClusterCancelExecutionRequestAttributes converts thrift CrossClusterCancelExecutionRequestAttributes type to internal

func ToCrossClusterCancelExecutionResponseAttributes ¶ added in v0.23.1

func ToCrossClusterCancelExecutionResponseAttributes(t *shared.CrossClusterCancelExecutionResponseAttributes) *types.CrossClusterCancelExecutionResponseAttributes

ToCrossClusterCancelExecutionResponseAttributes converts thrift CrossClusterCancelExecutionResponseAttributes type to internal

func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes ¶ added in v0.24.0

func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(
	t *shared.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes,
) *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes

ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes converts thrift CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes type to internal

func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes ¶ added in v0.24.0

func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(
	t *shared.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes,
) *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes

ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes converts thrift CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes type to internal

func ToCrossClusterSignalExecutionRequestAttributes ¶ added in v0.23.1

func ToCrossClusterSignalExecutionRequestAttributes(t *shared.CrossClusterSignalExecutionRequestAttributes) *types.CrossClusterSignalExecutionRequestAttributes

ToCrossClusterSignalExecutionRequestAttributes converts thrift CrossClusterSignalExecutionRequestAttributes type to internal

func ToCrossClusterSignalExecutionResponseAttributes ¶ added in v0.23.1

func ToCrossClusterSignalExecutionResponseAttributes(t *shared.CrossClusterSignalExecutionResponseAttributes) *types.CrossClusterSignalExecutionResponseAttributes

ToCrossClusterSignalExecutionResponseAttributes converts thrift CrossClusterSignalExecutionResponseAttributes type to internal

func ToCrossClusterStartChildExecutionRequestAttributes ¶ added in v0.23.1

func ToCrossClusterStartChildExecutionRequestAttributes(t *shared.CrossClusterStartChildExecutionRequestAttributes) *types.CrossClusterStartChildExecutionRequestAttributes

ToCrossClusterStartChildExecutionRequestAttributes converts thrift CrossClusterStartChildExecutionRequestAttributes type to internal

func ToCrossClusterStartChildExecutionResponseAttributes ¶ added in v0.23.1

func ToCrossClusterStartChildExecutionResponseAttributes(t *shared.CrossClusterStartChildExecutionResponseAttributes) *types.CrossClusterStartChildExecutionResponseAttributes

ToCrossClusterStartChildExecutionResponseAttributes converts thrift CrossClusterStartChildExecutionResponseAttributes type to internal

func ToCrossClusterTaskFailedCause ¶ added in v0.23.1

func ToCrossClusterTaskFailedCause(t *shared.CrossClusterTaskFailedCause) *types.CrossClusterTaskFailedCause

ToCrossClusterTaskFailedCause converts thrift CrossClusterTaskFailedCause type to internal

func ToCrossClusterTaskInfo ¶ added in v0.23.1

func ToCrossClusterTaskInfo(t *shared.CrossClusterTaskInfo) *types.CrossClusterTaskInfo

ToCrossClusterTaskInfo converts thrift CrossClusterTaskInfo type to internal

func ToCrossClusterTaskRequest ¶ added in v0.23.1

func ToCrossClusterTaskRequest(t *shared.CrossClusterTaskRequest) *types.CrossClusterTaskRequest

ToCrossClusterTaskRequest converts thrift CrossClusterTaskRequest type to internal

func ToCrossClusterTaskRequestArray ¶ added in v0.23.1

func ToCrossClusterTaskRequestArray(t []*shared.CrossClusterTaskRequest) []*types.CrossClusterTaskRequest

ToCrossClusterTaskRequestArray converts thrift CrossClusterTaskRequest type array to internal

func ToCrossClusterTaskRequestMap ¶ added in v0.23.1

func ToCrossClusterTaskRequestMap(t map[int32][]*shared.CrossClusterTaskRequest) map[int32][]*types.CrossClusterTaskRequest

ToCrossClusterTaskRequestMap converts thrift CrossClusterTaskRequest type map to internal

func ToCrossClusterTaskResponse ¶ added in v0.23.1

func ToCrossClusterTaskResponse(t *shared.CrossClusterTaskResponse) *types.CrossClusterTaskResponse

ToCrossClusterTaskResponse converts thrift CrossClusterTaskResponse type to internal

func ToCrossClusterTaskResponseArray ¶ added in v0.23.1

func ToCrossClusterTaskResponseArray(t []*shared.CrossClusterTaskResponse) []*types.CrossClusterTaskResponse

ToCrossClusterTaskResponseArray converts thrift CrossClusterTaskResponse type array to internal

func ToCrossClusterTaskType ¶ added in v0.23.1

func ToCrossClusterTaskType(t *shared.CrossClusterTaskType) *types.CrossClusterTaskType

ToCrossClusterTaskType converts thrift CrossClusterTaskType type to internal

func ToCurrentBranchChangedError ¶

func ToCurrentBranchChangedError(t *shared.CurrentBranchChangedError) *types.CurrentBranchChangedError

ToCurrentBranchChangedError converts thrift CurrentBranchChangedError type to internal

func ToDLQType ¶ added in v0.17.0

func ToDLQType(t *replicator.DLQType) *types.DLQType

ToDLQType converts thrift DLQType type to internal

func ToDataBlob ¶

func ToDataBlob(t *shared.DataBlob) *types.DataBlob

ToDataBlob converts thrift DataBlob type to internal

func ToDataBlobArray ¶

func ToDataBlobArray(t []*shared.DataBlob) []*types.DataBlob

ToDataBlobArray converts thrift DataBlob type array to internal

func ToDecision ¶

func ToDecision(t *shared.Decision) *types.Decision

ToDecision converts thrift Decision type to internal

func ToDecisionArray ¶

func ToDecisionArray(t []*shared.Decision) []*types.Decision

ToDecisionArray converts thrift Decision type array to internal

func ToDecisionTaskCompletedEventAttributes ¶

func ToDecisionTaskCompletedEventAttributes(t *shared.DecisionTaskCompletedEventAttributes) *types.DecisionTaskCompletedEventAttributes

ToDecisionTaskCompletedEventAttributes converts thrift DecisionTaskCompletedEventAttributes type to internal

func ToDecisionTaskFailedCause ¶

func ToDecisionTaskFailedCause(t *shared.DecisionTaskFailedCause) *types.DecisionTaskFailedCause

ToDecisionTaskFailedCause converts thrift DecisionTaskFailedCause type to internal

func ToDecisionTaskFailedEventAttributes ¶

func ToDecisionTaskFailedEventAttributes(t *shared.DecisionTaskFailedEventAttributes) *types.DecisionTaskFailedEventAttributes

ToDecisionTaskFailedEventAttributes converts thrift DecisionTaskFailedEventAttributes type to internal

func ToDecisionTaskScheduledEventAttributes ¶

func ToDecisionTaskScheduledEventAttributes(t *shared.DecisionTaskScheduledEventAttributes) *types.DecisionTaskScheduledEventAttributes

ToDecisionTaskScheduledEventAttributes converts thrift DecisionTaskScheduledEventAttributes type to internal

func ToDecisionTaskStartedEventAttributes ¶

func ToDecisionTaskStartedEventAttributes(t *shared.DecisionTaskStartedEventAttributes) *types.DecisionTaskStartedEventAttributes

ToDecisionTaskStartedEventAttributes converts thrift DecisionTaskStartedEventAttributes type to internal

func ToDecisionTaskTimedOutCause ¶ added in v0.18.0

func ToDecisionTaskTimedOutCause(t *shared.DecisionTaskTimedOutCause) *types.DecisionTaskTimedOutCause

ToDecisionTaskTimedOutCause converts thrift DecisionTaskTimedOutCause type to internal

func ToDecisionTaskTimedOutEventAttributes ¶

func ToDecisionTaskTimedOutEventAttributes(t *shared.DecisionTaskTimedOutEventAttributes) *types.DecisionTaskTimedOutEventAttributes

ToDecisionTaskTimedOutEventAttributes converts thrift DecisionTaskTimedOutEventAttributes type to internal

func ToDecisionType ¶

func ToDecisionType(t *shared.DecisionType) *types.DecisionType

ToDecisionType converts thrift DecisionType type to internal

func ToDeprecateDomainRequest ¶

func ToDeprecateDomainRequest(t *shared.DeprecateDomainRequest) *types.DeprecateDomainRequest

ToDeprecateDomainRequest converts thrift DeprecateDomainRequest type to internal

func ToDescribeDomainRequest ¶

func ToDescribeDomainRequest(t *shared.DescribeDomainRequest) *types.DescribeDomainRequest

ToDescribeDomainRequest converts thrift DescribeDomainRequest type to internal

func ToDescribeDomainResponse ¶

func ToDescribeDomainResponse(t *shared.DescribeDomainResponse) *types.DescribeDomainResponse

ToDescribeDomainResponse converts thrift DescribeDomainResponse type to internal

func ToDescribeDomainResponseArray ¶

func ToDescribeDomainResponseArray(t []*shared.DescribeDomainResponse) []*types.DescribeDomainResponse

ToDescribeDomainResponseArray converts thrift DescribeDomainResponse type array to internal

func ToDescribeTaskListRequest ¶

func ToDescribeTaskListRequest(t *shared.DescribeTaskListRequest) *types.DescribeTaskListRequest

ToDescribeTaskListRequest converts thrift DescribeTaskListRequest type to internal

func ToDescribeTaskListResponse ¶

func ToDescribeTaskListResponse(t *shared.DescribeTaskListResponse) *types.DescribeTaskListResponse

ToDescribeTaskListResponse converts thrift DescribeTaskListResponse type to internal

func ToDescribeTaskListResponseMap ¶ added in v0.24.0

func ToDescribeTaskListResponseMap(t map[string]*shared.DescribeTaskListResponse) map[string]*types.DescribeTaskListResponse

ToDescribeTaskListResponseMap converts thrift DescribeTaskListResponse map type to internal

func ToDescribeWorkflowExecutionRequest ¶

func ToDescribeWorkflowExecutionRequest(t *shared.DescribeWorkflowExecutionRequest) *types.DescribeWorkflowExecutionRequest

ToDescribeWorkflowExecutionRequest converts thrift DescribeWorkflowExecutionRequest type to internal

func ToDescribeWorkflowExecutionResponse ¶

func ToDescribeWorkflowExecutionResponse(t *shared.DescribeWorkflowExecutionResponse) *types.DescribeWorkflowExecutionResponse

ToDescribeWorkflowExecutionResponse converts thrift DescribeWorkflowExecutionResponse type to internal

func ToDiagnoseWorkflowExecutionRequest ¶ added in v1.2.14

func ToDiagnoseWorkflowExecutionRequest(t *shared.DiagnoseWorkflowExecutionRequest) *types.DiagnoseWorkflowExecutionRequest

ToDiagnoseWorkflowExecutionRequest converts thrift DiagnoseWorkflowExecutionRequest type to internal

func ToDiagnoseWorkflowExecutionResponse ¶ added in v1.2.14

func ToDiagnoseWorkflowExecutionResponse(t *shared.DiagnoseWorkflowExecutionResponse) *types.DiagnoseWorkflowExecutionResponse

ToDiagnoseWorkflowExecutionResponse converts thrift DiagnoseeWorkflowExecutionResponse type to internal

func ToDomainAlreadyExistsError ¶

func ToDomainAlreadyExistsError(t *shared.DomainAlreadyExistsError) *types.DomainAlreadyExistsError

ToDomainAlreadyExistsError converts thrift DomainAlreadyExistsError type to internal

func ToDomainAsyncWorkflowConfiguraton ¶ added in v1.2.7

func ToDomainAsyncWorkflowConfiguraton(in *shared.AsyncWorkflowConfiguration) *types.AsyncWorkflowConfiguration

func ToDomainCacheInfo ¶

func ToDomainCacheInfo(t *shared.DomainCacheInfo) *types.DomainCacheInfo

ToDomainCacheInfo converts thrift DomainCacheInfo type to internal

func ToDomainConfiguration ¶

func ToDomainConfiguration(t *shared.DomainConfiguration) *types.DomainConfiguration

ToDomainConfiguration converts thrift DomainConfiguration type to internal

func ToDomainFilter ¶ added in v0.17.0

func ToDomainFilter(t *history.DomainFilter) *types.DomainFilter

ToDomainFilter converts thrift DomainFilter type to internal

func ToDomainInfo ¶

func ToDomainInfo(t *shared.DomainInfo) *types.DomainInfo

ToDomainInfo converts thrift DomainInfo type to internal

func ToDomainNotActiveError ¶

func ToDomainNotActiveError(t *shared.DomainNotActiveError) *types.DomainNotActiveError

ToDomainNotActiveError converts thrift DomainNotActiveError type to internal

func ToDomainOperation ¶ added in v0.17.0

func ToDomainOperation(t *replicator.DomainOperation) *types.DomainOperation

ToDomainOperation converts thrift DomainOperation type to internal

func ToDomainReplicationConfiguration ¶

func ToDomainReplicationConfiguration(t *shared.DomainReplicationConfiguration) *types.DomainReplicationConfiguration

ToDomainReplicationConfiguration converts thrift DomainReplicationConfiguration type to internal

func ToDomainStatus ¶

func ToDomainStatus(t *shared.DomainStatus) *types.DomainStatus

ToDomainStatus converts thrift DomainStatus type to internal

func ToDomainTaskAttributes ¶ added in v0.17.0

func ToDomainTaskAttributes(t *replicator.DomainTaskAttributes) *types.DomainTaskAttributes

ToDomainTaskAttributes converts thrift DomainTaskAttributes type to internal

func ToDynamicConfigBlob ¶ added in v0.23.1

func ToDynamicConfigBlob(t *config.DynamicConfigBlob) *types.DynamicConfigBlob

ToDynamicConfigBlob converts thrift DynamicConfigBlob type to internal

func ToDynamicConfigEntry ¶ added in v0.23.1

func ToDynamicConfigEntry(t *config.DynamicConfigEntry) *types.DynamicConfigEntry

ToDynamicConfigEntry converts thrift DynamicConfigEntry type to internal

func ToDynamicConfigEntryArray ¶ added in v0.23.1

func ToDynamicConfigEntryArray(t []*config.DynamicConfigEntry) []*types.DynamicConfigEntry

ToDynamicConfigEntryArray converts thrift DynamicConfigEntry array type to internal

func ToDynamicConfigFilter ¶ added in v0.23.1

func ToDynamicConfigFilter(t *config.DynamicConfigFilter) *types.DynamicConfigFilter

ToDynamicConfigFilter converts thrift DynamicConfigFilter type to internal

func ToDynamicConfigFilterArray ¶ added in v0.23.1

func ToDynamicConfigFilterArray(t []*config.DynamicConfigFilter) []*types.DynamicConfigFilter

ToDynamicConfigFilterArray converts thrift DynamicConfigFilter array type to internal

func ToDynamicConfigValue ¶ added in v0.23.1

func ToDynamicConfigValue(t *config.DynamicConfigValue) *types.DynamicConfigValue

ToDynamicConfigValue converts thrift DynamicConfigValue type to internal

func ToDynamicConfigValueArray ¶ added in v0.23.1

func ToDynamicConfigValueArray(t []*config.DynamicConfigValue) []*types.DynamicConfigValue

ToDynamicConfigValueArray converts thrift DynamicConfigValue array type to internal

func ToEncodingType ¶

func ToEncodingType(t *shared.EncodingType) *types.EncodingType

ToEncodingType converts thrift EncodingType type to internal

func ToEntityNotExistsError ¶

func ToEntityNotExistsError(t *shared.EntityNotExistsError) *types.EntityNotExistsError

ToEntityNotExistsError converts thrift EntityNotExistsError type to internal

func ToError ¶ added in v0.17.0

func ToError(err error) error

ToError convert error to internal type if it comes as its thrift equivalent

func ToEventAlreadyStartedError ¶ added in v0.17.0

func ToEventAlreadyStartedError(t *history.EventAlreadyStartedError) *types.EventAlreadyStartedError

ToEventAlreadyStartedError converts thrift EventAlreadyStartedError type to internal

func ToEventType ¶

func ToEventType(t *shared.EventType) *types.EventType

ToEventType converts thrift EventType type to internal

func ToExternalWorkflowExecutionCancelRequestedEventAttributes ¶

func ToExternalWorkflowExecutionCancelRequestedEventAttributes(t *shared.ExternalWorkflowExecutionCancelRequestedEventAttributes) *types.ExternalWorkflowExecutionCancelRequestedEventAttributes

ToExternalWorkflowExecutionCancelRequestedEventAttributes converts thrift ExternalWorkflowExecutionCancelRequestedEventAttributes type to internal

func ToExternalWorkflowExecutionSignaledEventAttributes ¶

func ToExternalWorkflowExecutionSignaledEventAttributes(t *shared.ExternalWorkflowExecutionSignaledEventAttributes) *types.ExternalWorkflowExecutionSignaledEventAttributes

ToExternalWorkflowExecutionSignaledEventAttributes converts thrift ExternalWorkflowExecutionSignaledEventAttributes type to internal

func ToFailWorkflowExecutionDecisionAttributes ¶

func ToFailWorkflowExecutionDecisionAttributes(t *shared.FailWorkflowExecutionDecisionAttributes) *types.FailWorkflowExecutionDecisionAttributes

ToFailWorkflowExecutionDecisionAttributes converts thrift FailWorkflowExecutionDecisionAttributes type to internal

func ToFailoverInfo ¶ added in v0.24.0

func ToFailoverInfo(t *shared.FailoverInfo) *types.FailoverInfo

ToFailoverInfo converts thrift FailoverInfo type to internal

func ToFailoverMarkerAttributes ¶ added in v0.17.0

func ToFailoverMarkerAttributes(t *replicator.FailoverMarkerAttributes) *types.FailoverMarkerAttributes

ToFailoverMarkerAttributes converts thrift FailoverMarkerAttributes type to internal

func ToFailoverMarkerAttributesArray ¶ added in v0.17.0

func ToFailoverMarkerAttributesArray(t []*replicator.FailoverMarkerAttributes) []*types.FailoverMarkerAttributes

ToFailoverMarkerAttributesArray converts thrift FailoverMarkerAttributes type array to internal

func ToFailoverMarkerToken ¶ added in v0.17.0

func ToFailoverMarkerToken(t *history.FailoverMarkerToken) *types.FailoverMarkerToken

ToFailoverMarkerToken converts thrift FailoverMarkerToken type to internal

func ToFailoverMarkerTokenArray ¶ added in v0.17.0

func ToFailoverMarkerTokenArray(t []*history.FailoverMarkerToken) []*types.FailoverMarkerToken

ToFailoverMarkerTokenArray converts thrift FailoverMarkerToken type array to internal

func ToFailoverMarkers ¶ added in v0.17.0

func ToFailoverMarkers(t *replicator.FailoverMarkers) *types.FailoverMarkers

ToFailoverMarkers converts thrift FailoverMarkers type to internal

func ToFeatureNotEnabledError ¶ added in v0.22.0

func ToFeatureNotEnabledError(t *shared.FeatureNotEnabledError) *types.FeatureNotEnabledError

ToFeatureNotEnabledError converts thrift FeatureNotEnabledError type to internal

func ToGetClusterInfoResponse ¶ added in v1.2.7

func ToGetClusterInfoResponse(t *shared.ClusterInfo) *types.ClusterInfo

ToGetClusterInfoResponse converts thrift ClusterInfo type to internal

func ToGetCrossClusterTaskFailedCause ¶ added in v0.23.1

func ToGetCrossClusterTaskFailedCause(t *shared.GetTaskFailedCause) *types.GetTaskFailedCause

ToGetCrossClusterTaskFailedCause converts thrift GetTaskFailedCause type to internal

func ToGetFailoverInfoRequest ¶ added in v0.24.0

func ToGetFailoverInfoRequest(t *history.GetFailoverInfoRequest) *types.GetFailoverInfoRequest

ToGetFailoverInfoRequest converts thrift GetFailoverInfoRequest type to internal

func ToGetFailoverInfoResponse ¶ added in v0.24.0

func ToGetFailoverInfoResponse(t *history.GetFailoverInfoResponse) *types.GetFailoverInfoResponse

ToGetFailoverInfoResponse converts thrift GetFailoverInfoResponse type to internal

func ToGetSearchAttributesResponse ¶

func ToGetSearchAttributesResponse(t *shared.GetSearchAttributesResponse) *types.GetSearchAttributesResponse

ToGetSearchAttributesResponse converts thrift GetSearchAttributesResponse type to internal

func ToGetTaskFailedCauseMap ¶ added in v0.23.1

func ToGetTaskFailedCauseMap(t map[int32]shared.GetTaskFailedCause) map[int32]types.GetTaskFailedCause

ToGetTaskFailedCauseMap converts thrift GetTaskFailedCause type map to internal

func ToGetTaskListsByDomainRequest ¶ added in v0.23.1

func ToGetTaskListsByDomainRequest(t *shared.GetTaskListsByDomainRequest) *types.GetTaskListsByDomainRequest

ToGetTaskListsByDomainRequest converts thrift GetTaskListsByDomainRequest type to internal

func ToGetTaskListsByDomainResponse ¶ added in v0.23.1

func ToGetTaskListsByDomainResponse(t *shared.GetTaskListsByDomainResponse) *types.GetTaskListsByDomainResponse

ToGetTaskListsByDomainResponse converts thrift GetTaskListsByDomainResponse type to internal

func ToGetWorkflowExecutionHistoryRequest ¶

func ToGetWorkflowExecutionHistoryRequest(t *shared.GetWorkflowExecutionHistoryRequest) *types.GetWorkflowExecutionHistoryRequest

ToGetWorkflowExecutionHistoryRequest converts thrift GetWorkflowExecutionHistoryRequest type to internal

func ToGetWorkflowExecutionHistoryResponse ¶

func ToGetWorkflowExecutionHistoryResponse(t *shared.GetWorkflowExecutionHistoryResponse) *types.GetWorkflowExecutionHistoryResponse

ToGetWorkflowExecutionHistoryResponse converts thrift GetWorkflowExecutionHistoryResponse type to internal

func ToHeader ¶

func ToHeader(t *shared.Header) *types.Header

ToHeader converts thrift Header type to internal

func ToHealthStatus ¶ added in v0.18.0

func ToHealthStatus(t *health.HealthStatus) *types.HealthStatus

ToHealthStatus converts thrift HealthStatus type to internal

func ToHistory ¶

func ToHistory(t *shared.History) *types.History

ToHistory converts thrift History type to internal

func ToHistoryArray ¶ added in v0.18.0

func ToHistoryArray(t []*shared.History) []*types.History

ToHistoryArray converts thrift History array to internal

func ToHistoryBranch ¶

func ToHistoryBranch(t *shared.HistoryBranch) *types.HistoryBranch

ToHistoryBranch converts thrift HistoryBranch type to internal

func ToHistoryBranchRange ¶

func ToHistoryBranchRange(t *shared.HistoryBranchRange) *types.HistoryBranchRange

ToHistoryBranchRange converts thrift HistoryBranchRange type to internal

func ToHistoryBranchRangeArray ¶

func ToHistoryBranchRangeArray(t []*shared.HistoryBranchRange) []*types.HistoryBranchRange

ToHistoryBranchRangeArray converts thrift HistoryBranchRange type array to internal

func ToHistoryDescribeMutableStateRequest ¶ added in v1.2.7

func ToHistoryDescribeMutableStateRequest(t *history.DescribeMutableStateRequest) *types.DescribeMutableStateRequest

ToHistoryDescribeMutableStateRequest converts thrift DescribeMutableStateRequest type to internal

func ToHistoryDescribeMutableStateResponse ¶ added in v1.2.7

func ToHistoryDescribeMutableStateResponse(t *history.DescribeMutableStateResponse) *types.DescribeMutableStateResponse

ToHistoryDescribeMutableStateResponse converts thrift DescribeMutableStateResponse type to internal

func ToHistoryDescribeWorkflowExecutionRequest ¶ added in v0.17.0

func ToHistoryDescribeWorkflowExecutionRequest(t *history.DescribeWorkflowExecutionRequest) *types.HistoryDescribeWorkflowExecutionRequest

ToHistoryDescribeWorkflowExecutionRequest converts thrift DescribeWorkflowExecutionRequest type to internal

func ToHistoryEvent ¶

func ToHistoryEvent(t *shared.HistoryEvent) *types.HistoryEvent

ToHistoryEvent converts thrift HistoryEvent type to internal

func ToHistoryEventArray ¶

func ToHistoryEventArray(t []*shared.HistoryEvent) []*types.HistoryEvent

ToHistoryEventArray converts thrift HistoryEvent type array to internal

func ToHistoryEventFilterType ¶

func ToHistoryEventFilterType(t *shared.HistoryEventFilterType) *types.HistoryEventFilterType

ToHistoryEventFilterType converts thrift HistoryEventFilterType type to internal

func ToHistoryGetMutableStateRequest ¶ added in v1.2.7

func ToHistoryGetMutableStateRequest(t *history.GetMutableStateRequest) *types.GetMutableStateRequest

ToHistoryGetMutableStateRequest converts thrift GetMutableStateRequest type to internal

func ToHistoryGetMutableStateResponse ¶ added in v1.2.7

func ToHistoryGetMutableStateResponse(t *history.GetMutableStateResponse) *types.GetMutableStateResponse

ToHistoryGetMutableStateResponse converts thrift GetMutableStateResponse type to internal

func ToHistoryNotifyFailoverMarkersRequest ¶ added in v1.2.7

func ToHistoryNotifyFailoverMarkersRequest(t *history.NotifyFailoverMarkersRequest) *types.NotifyFailoverMarkersRequest

ToHistoryNotifyFailoverMarkersRequest converts thrift NotifyFailoverMarkersRequest type to internal

func ToHistoryPollMutableStateRequest ¶ added in v1.2.7

func ToHistoryPollMutableStateRequest(t *history.PollMutableStateRequest) *types.PollMutableStateRequest

ToHistoryPollMutableStateRequest converts thrift PollMutableStateRequest type to internal

func ToHistoryPollMutableStateResponse ¶ added in v1.2.7

func ToHistoryPollMutableStateResponse(t *history.PollMutableStateResponse) *types.PollMutableStateResponse

ToHistoryPollMutableStateResponse converts thrift PollMutableStateResponse type to internal

func ToHistoryQueryWorkflowRequest ¶ added in v0.17.0

func ToHistoryQueryWorkflowRequest(t *history.QueryWorkflowRequest) *types.HistoryQueryWorkflowRequest

ToHistoryQueryWorkflowRequest converts thrift QueryWorkflowRequest type to internal

func ToHistoryQueryWorkflowResponse ¶ added in v0.17.0

func ToHistoryQueryWorkflowResponse(t *history.QueryWorkflowResponse) *types.HistoryQueryWorkflowResponse

ToHistoryQueryWorkflowResponse converts thrift QueryWorkflowResponse type to internal

func ToHistoryRatelimitUpdateRequest ¶ added in v1.2.10

func ToHistoryRatelimitUpdateRequest(t *history.RatelimitUpdateRequest) *types.RatelimitUpdateRequest

func ToHistoryRatelimitUpdateResponse ¶ added in v1.2.12

func ToHistoryRatelimitUpdateResponse(t *history.RatelimitUpdateResponse) *types.RatelimitUpdateResponse

func ToHistoryReapplyEventsRequest ¶ added in v0.17.0

func ToHistoryReapplyEventsRequest(t *history.ReapplyEventsRequest) *types.HistoryReapplyEventsRequest

ToHistoryReapplyEventsRequest converts thrift ReapplyEventsRequest type to internal

func ToHistoryRecordActivityTaskHeartbeatRequest ¶ added in v0.17.0

func ToHistoryRecordActivityTaskHeartbeatRequest(t *history.RecordActivityTaskHeartbeatRequest) *types.HistoryRecordActivityTaskHeartbeatRequest

ToHistoryRecordActivityTaskHeartbeatRequest converts thrift RecordActivityTaskHeartbeatRequest type to internal

func ToHistoryRefreshWorkflowTasksRequest ¶ added in v0.17.0

func ToHistoryRefreshWorkflowTasksRequest(t *history.RefreshWorkflowTasksRequest) *types.HistoryRefreshWorkflowTasksRequest

ToHistoryRefreshWorkflowTasksRequest converts thrift RefreshWorkflowTasksRequest type to internal

func ToHistoryRemoveSignalMutableStateRequest ¶ added in v1.2.7

func ToHistoryRemoveSignalMutableStateRequest(t *history.RemoveSignalMutableStateRequest) *types.RemoveSignalMutableStateRequest

ToHistoryRemoveSignalMutableStateRequest converts thrift RemoveSignalMutableStateRequest type to internal

func ToHistoryReplicateEventsV2Request ¶ added in v1.2.7

func ToHistoryReplicateEventsV2Request(t *history.ReplicateEventsV2Request) *types.ReplicateEventsV2Request

ToHistoryReplicateEventsV2Request converts thrift ReplicateEventsV2Request type to internal

func ToHistoryRequestCancelWorkflowExecutionRequest ¶ added in v0.17.0

func ToHistoryRequestCancelWorkflowExecutionRequest(t *history.RequestCancelWorkflowExecutionRequest) *types.HistoryRequestCancelWorkflowExecutionRequest

ToHistoryRequestCancelWorkflowExecutionRequest converts thrift RequestCancelWorkflowExecutionRequest type to internal

func ToHistoryResetStickyTaskListRequest ¶ added in v0.17.0

func ToHistoryResetStickyTaskListRequest(t *history.ResetStickyTaskListRequest) *types.HistoryResetStickyTaskListRequest

ToHistoryResetStickyTaskListRequest converts thrift ResetStickyTaskListRequest type to internal

func ToHistoryResetStickyTaskListResponse ¶ added in v0.17.0

func ToHistoryResetStickyTaskListResponse(t *history.ResetStickyTaskListResponse) *types.HistoryResetStickyTaskListResponse

ToHistoryResetStickyTaskListResponse converts thrift ResetStickyTaskListResponse type to internal

func ToHistoryResetWorkflowExecutionRequest ¶ added in v0.17.0

func ToHistoryResetWorkflowExecutionRequest(t *history.ResetWorkflowExecutionRequest) *types.HistoryResetWorkflowExecutionRequest

ToHistoryResetWorkflowExecutionRequest converts thrift ResetWorkflowExecutionRequest type to internal

func ToHistoryRespondActivityTaskCanceledRequest ¶ added in v0.17.0

func ToHistoryRespondActivityTaskCanceledRequest(t *history.RespondActivityTaskCanceledRequest) *types.HistoryRespondActivityTaskCanceledRequest

ToHistoryRespondActivityTaskCanceledRequest converts thrift RespondActivityTaskCanceledRequest type to internal

func ToHistoryRespondActivityTaskCompletedRequest ¶ added in v0.17.0

func ToHistoryRespondActivityTaskCompletedRequest(t *history.RespondActivityTaskCompletedRequest) *types.HistoryRespondActivityTaskCompletedRequest

ToHistoryRespondActivityTaskCompletedRequest converts thrift RespondActivityTaskCompletedRequest type to internal

func ToHistoryRespondActivityTaskFailedRequest ¶ added in v0.17.0

func ToHistoryRespondActivityTaskFailedRequest(t *history.RespondActivityTaskFailedRequest) *types.HistoryRespondActivityTaskFailedRequest

ToHistoryRespondActivityTaskFailedRequest converts thrift RespondActivityTaskFailedRequest type to internal

func ToHistoryRespondDecisionTaskCompletedRequest ¶ added in v0.17.0

func ToHistoryRespondDecisionTaskCompletedRequest(t *history.RespondDecisionTaskCompletedRequest) *types.HistoryRespondDecisionTaskCompletedRequest

ToHistoryRespondDecisionTaskCompletedRequest converts thrift RespondDecisionTaskCompletedRequest type to internal

func ToHistoryRespondDecisionTaskCompletedResponse ¶ added in v0.17.0

func ToHistoryRespondDecisionTaskCompletedResponse(t *history.RespondDecisionTaskCompletedResponse) *types.HistoryRespondDecisionTaskCompletedResponse

ToHistoryRespondDecisionTaskCompletedResponse converts thrift RespondDecisionTaskCompletedResponse type to internal

func ToHistoryRespondDecisionTaskFailedRequest ¶ added in v0.17.0

func ToHistoryRespondDecisionTaskFailedRequest(t *history.RespondDecisionTaskFailedRequest) *types.HistoryRespondDecisionTaskFailedRequest

ToHistoryRespondDecisionTaskFailedRequest converts thrift RespondDecisionTaskFailedRequest type to internal

func ToHistoryScheduleDecisionTaskRequest ¶ added in v1.2.7

func ToHistoryScheduleDecisionTaskRequest(t *history.ScheduleDecisionTaskRequest) *types.ScheduleDecisionTaskRequest

ToHistoryScheduleDecisionTaskRequest converts thrift ScheduleDecisionTaskRequest type to internal

func ToHistorySignalWithStartWorkflowExecutionRequest ¶ added in v0.17.0

func ToHistorySignalWithStartWorkflowExecutionRequest(t *history.SignalWithStartWorkflowExecutionRequest) *types.HistorySignalWithStartWorkflowExecutionRequest

ToHistorySignalWithStartWorkflowExecutionRequest converts thrift SignalWithStartWorkflowExecutionRequest type to internal

func ToHistorySignalWorkflowExecutionRequest ¶ added in v0.17.0

func ToHistorySignalWorkflowExecutionRequest(t *history.SignalWorkflowExecutionRequest) *types.HistorySignalWorkflowExecutionRequest

ToHistorySignalWorkflowExecutionRequest converts thrift SignalWorkflowExecutionRequest type to internal

func ToHistoryStartWorkflowExecutionRequest ¶ added in v0.17.0

func ToHistoryStartWorkflowExecutionRequest(t *history.StartWorkflowExecutionRequest) *types.HistoryStartWorkflowExecutionRequest

ToHistoryStartWorkflowExecutionRequest converts thrift StartWorkflowExecutionRequest type to internal

func ToHistorySyncActivityRequest ¶ added in v1.2.7

func ToHistorySyncActivityRequest(t *history.SyncActivityRequest) *types.SyncActivityRequest

ToHistorySyncActivityRequest converts thrift SyncActivityRequest type to internal

func ToHistorySyncShardStatusRequest ¶ added in v1.2.7

func ToHistorySyncShardStatusRequest(t *history.SyncShardStatusRequest) *types.SyncShardStatusRequest

ToHistorySyncShardStatusRequest converts thrift SyncShardStatusRequest type to internal

func ToHistoryTaskV2Attributes ¶ added in v0.17.0

func ToHistoryTaskV2Attributes(t *replicator.HistoryTaskV2Attributes) *types.HistoryTaskV2Attributes

ToHistoryTaskV2Attributes converts thrift HistoryTaskV2Attributes type to internal

func ToHistoryTerminateWorkflowExecutionRequest ¶ added in v0.17.0

func ToHistoryTerminateWorkflowExecutionRequest(t *history.TerminateWorkflowExecutionRequest) *types.HistoryTerminateWorkflowExecutionRequest

ToHistoryTerminateWorkflowExecutionRequest converts thrift TerminateWorkflowExecutionRequest type to internal

func ToHostInfo ¶ added in v0.17.0

func ToHostInfo(t *admin.HostInfo) *types.HostInfo

ToHostInfo converts thrift HostInfo type to internal

func ToHostInfoArray ¶ added in v0.17.0

func ToHostInfoArray(t []*admin.HostInfo) []*types.HostInfo

ToHostInfoArray converts thrift HostInfo type array to internal

func ToIndexedValueType ¶

func ToIndexedValueType(t shared.IndexedValueType) types.IndexedValueType

ToIndexedValueType converts thrift IndexedValueType type to internal

func ToIndexedValueTypeMap ¶

func ToIndexedValueTypeMap(t map[string]shared.IndexedValueType) map[string]types.IndexedValueType

ToIndexedValueTypeMap converts thrift IndexedValueType type map to internal

func ToInternalDataInconsistencyError ¶

func ToInternalDataInconsistencyError(t *shared.InternalDataInconsistencyError) *types.InternalDataInconsistencyError

ToInternalDataInconsistencyError converts thrift InternalDataInconsistencyError type to internal

func ToInternalServiceError ¶

func ToInternalServiceError(t *shared.InternalServiceError) *types.InternalServiceError

ToInternalServiceError converts thrift InternalServiceError type to internal

func ToIsolationGroupConfig ¶ added in v1.2.1

func ToIsolationGroupConfig(in *shared.IsolationGroupConfiguration) *types.IsolationGroupConfiguration

func ToLimitExceededError ¶

func ToLimitExceededError(t *shared.LimitExceededError) *types.LimitExceededError

ToLimitExceededError converts thrift LimitExceededError type to internal

func ToListArchivedWorkflowExecutionsRequest ¶

func ToListArchivedWorkflowExecutionsRequest(t *shared.ListArchivedWorkflowExecutionsRequest) *types.ListArchivedWorkflowExecutionsRequest

ToListArchivedWorkflowExecutionsRequest converts thrift ListArchivedWorkflowExecutionsRequest type to internal

func ToListArchivedWorkflowExecutionsResponse ¶

func ToListArchivedWorkflowExecutionsResponse(t *shared.ListArchivedWorkflowExecutionsResponse) *types.ListArchivedWorkflowExecutionsResponse

ToListArchivedWorkflowExecutionsResponse converts thrift ListArchivedWorkflowExecutionsResponse type to internal

func ToListClosedWorkflowExecutionsRequest ¶

func ToListClosedWorkflowExecutionsRequest(t *shared.ListClosedWorkflowExecutionsRequest) *types.ListClosedWorkflowExecutionsRequest

ToListClosedWorkflowExecutionsRequest converts thrift ListClosedWorkflowExecutionsRequest type to internal

func ToListClosedWorkflowExecutionsResponse ¶

func ToListClosedWorkflowExecutionsResponse(t *shared.ListClosedWorkflowExecutionsResponse) *types.ListClosedWorkflowExecutionsResponse

ToListClosedWorkflowExecutionsResponse converts thrift ListClosedWorkflowExecutionsResponse type to internal

func ToListDomainsRequest ¶

func ToListDomainsRequest(t *shared.ListDomainsRequest) *types.ListDomainsRequest

ToListDomainsRequest converts thrift ListDomainsRequest type to internal

func ToListDomainsResponse ¶

func ToListDomainsResponse(t *shared.ListDomainsResponse) *types.ListDomainsResponse

ToListDomainsResponse converts thrift ListDomainsResponse type to internal

func ToListOpenWorkflowExecutionsRequest ¶

func ToListOpenWorkflowExecutionsRequest(t *shared.ListOpenWorkflowExecutionsRequest) *types.ListOpenWorkflowExecutionsRequest

ToListOpenWorkflowExecutionsRequest converts thrift ListOpenWorkflowExecutionsRequest type to internal

func ToListOpenWorkflowExecutionsResponse ¶

func ToListOpenWorkflowExecutionsResponse(t *shared.ListOpenWorkflowExecutionsResponse) *types.ListOpenWorkflowExecutionsResponse

ToListOpenWorkflowExecutionsResponse converts thrift ListOpenWorkflowExecutionsResponse type to internal

func ToListTaskListPartitionsRequest ¶

func ToListTaskListPartitionsRequest(t *shared.ListTaskListPartitionsRequest) *types.ListTaskListPartitionsRequest

ToListTaskListPartitionsRequest converts thrift ListTaskListPartitionsRequest type to internal

func ToListTaskListPartitionsResponse ¶

func ToListTaskListPartitionsResponse(t *shared.ListTaskListPartitionsResponse) *types.ListTaskListPartitionsResponse

ToListTaskListPartitionsResponse converts thrift ListTaskListPartitionsResponse type to internal

func ToListWorkflowExecutionsRequest ¶

func ToListWorkflowExecutionsRequest(t *shared.ListWorkflowExecutionsRequest) *types.ListWorkflowExecutionsRequest

ToListWorkflowExecutionsRequest converts thrift ListWorkflowExecutionsRequest type to internal

func ToListWorkflowExecutionsResponse ¶

func ToListWorkflowExecutionsResponse(t *shared.ListWorkflowExecutionsResponse) *types.ListWorkflowExecutionsResponse

ToListWorkflowExecutionsResponse converts thrift ListWorkflowExecutionsResponse type to internal

func ToMarkerRecordedEventAttributes ¶

func ToMarkerRecordedEventAttributes(t *shared.MarkerRecordedEventAttributes) *types.MarkerRecordedEventAttributes

ToMarkerRecordedEventAttributes converts thrift MarkerRecordedEventAttributes type to internal

func ToMatchingAddActivityTaskRequest ¶ added in v1.2.7

func ToMatchingAddActivityTaskRequest(t *matching.AddActivityTaskRequest) *types.AddActivityTaskRequest

ToMatchingAddActivityTaskRequest converts thrift AddActivityTaskRequest type to internal

func ToMatchingAddDecisionTaskRequest ¶ added in v1.2.7

func ToMatchingAddDecisionTaskRequest(t *matching.AddDecisionTaskRequest) *types.AddDecisionTaskRequest

ToMatchingAddDecisionTaskRequest converts thrift AddDecisionTaskRequest type to internal

func ToMatchingCancelOutstandingPollRequest ¶ added in v1.2.7

func ToMatchingCancelOutstandingPollRequest(t *matching.CancelOutstandingPollRequest) *types.CancelOutstandingPollRequest

ToMatchingCancelOutstandingPollRequest converts thrift CancelOutstandingPollRequest type to internal

func ToMatchingDescribeTaskListRequest ¶ added in v0.17.0

func ToMatchingDescribeTaskListRequest(t *matching.DescribeTaskListRequest) *types.MatchingDescribeTaskListRequest

ToMatchingDescribeTaskListRequest converts thrift DescribeTaskListRequest type to internal

func ToMatchingListTaskListPartitionsRequest ¶ added in v0.17.0

func ToMatchingListTaskListPartitionsRequest(t *matching.ListTaskListPartitionsRequest) *types.MatchingListTaskListPartitionsRequest

ToMatchingListTaskListPartitionsRequest converts thrift ListTaskListPartitionsRequest type to internal

func ToMatchingPollForActivityTaskRequest ¶ added in v0.17.0

func ToMatchingPollForActivityTaskRequest(t *matching.PollForActivityTaskRequest) *types.MatchingPollForActivityTaskRequest

ToMatchingPollForActivityTaskRequest converts thrift PollForActivityTaskRequest type to internal

func ToMatchingPollForActivityTaskResponse ¶ added in v1.2.7

func ToMatchingPollForActivityTaskResponse(t *shared.PollForActivityTaskResponse) *types.MatchingPollForActivityTaskResponse

func ToMatchingPollForDecisionTaskRequest ¶ added in v0.17.0

func ToMatchingPollForDecisionTaskRequest(t *matching.PollForDecisionTaskRequest) *types.MatchingPollForDecisionTaskRequest

ToMatchingPollForDecisionTaskRequest converts thrift PollForDecisionTaskRequest type to internal

func ToMatchingPollForDecisionTaskResponse ¶ added in v0.17.0

func ToMatchingPollForDecisionTaskResponse(t *matching.PollForDecisionTaskResponse) *types.MatchingPollForDecisionTaskResponse

ToMatchingPollForDecisionTaskResponse converts thrift PollForDecisionTaskResponse type to internal

func ToMatchingQueryWorkflowRequest ¶ added in v0.17.0

func ToMatchingQueryWorkflowRequest(t *matching.QueryWorkflowRequest) *types.MatchingQueryWorkflowRequest

ToMatchingQueryWorkflowRequest converts thrift QueryWorkflowRequest type to internal

func ToMatchingRespondQueryTaskCompletedRequest ¶ added in v0.17.0

func ToMatchingRespondQueryTaskCompletedRequest(t *matching.RespondQueryTaskCompletedRequest) *types.MatchingRespondQueryTaskCompletedRequest

ToMatchingRespondQueryTaskCompletedRequest converts thrift RespondQueryTaskCompletedRequest type to internal

func ToMembershipInfo ¶ added in v0.17.0

func ToMembershipInfo(t *admin.MembershipInfo) *types.MembershipInfo

ToMembershipInfo converts thrift MembershipInfo type to internal

func ToMemo ¶

func ToMemo(t *shared.Memo) *types.Memo

ToMemo converts thrift Memo type to internal

func ToParentClosePolicy ¶

func ToParentClosePolicy(t *shared.ParentClosePolicy) *types.ParentClosePolicy

ToParentClosePolicy converts thrift ParentClosePolicy type to internal

func ToParentExecutionInfo ¶ added in v0.17.0

func ToParentExecutionInfo(t *history.ParentExecutionInfo) *types.ParentExecutionInfo

ToParentExecutionInfo converts thrift ParentExecutionInfo type to internal

func ToPendingActivityInfo ¶

func ToPendingActivityInfo(t *shared.PendingActivityInfo) *types.PendingActivityInfo

ToPendingActivityInfo converts thrift PendingActivityInfo type to internal

func ToPendingActivityInfoArray ¶

func ToPendingActivityInfoArray(t []*shared.PendingActivityInfo) []*types.PendingActivityInfo

ToPendingActivityInfoArray converts thrift PendingActivityInfo type array to internal

func ToPendingActivityState ¶

func ToPendingActivityState(t *shared.PendingActivityState) *types.PendingActivityState

ToPendingActivityState converts thrift PendingActivityState type to internal

func ToPendingChildExecutionInfo ¶

func ToPendingChildExecutionInfo(t *shared.PendingChildExecutionInfo) *types.PendingChildExecutionInfo

ToPendingChildExecutionInfo converts thrift PendingChildExecutionInfo type to internal

func ToPendingChildExecutionInfoArray ¶

func ToPendingChildExecutionInfoArray(t []*shared.PendingChildExecutionInfo) []*types.PendingChildExecutionInfo

ToPendingChildExecutionInfoArray converts thrift PendingChildExecutionInfo type array to internal

func ToPendingDecisionInfo ¶ added in v0.17.0

func ToPendingDecisionInfo(t *shared.PendingDecisionInfo) *types.PendingDecisionInfo

ToPendingDecisionInfo converts thrift PendingDecisionInfo type to internal

func ToPendingDecisionState ¶ added in v0.17.0

func ToPendingDecisionState(t *shared.PendingDecisionState) *types.PendingDecisionState

ToPendingDecisionState converts thrift PendingDecisionState type to internal

func ToPersistenceFeature ¶ added in v0.21.0

func ToPersistenceFeature(t *admin.PersistenceFeature) *types.PersistenceFeature

ToPersistenceFeature converts from thrift to internal PersistenceFeature type

func ToPersistenceFeatures ¶ added in v0.21.0

func ToPersistenceFeatures(t []*admin.PersistenceFeature) []*types.PersistenceFeature

ToPersistenceFeatures converts from thrift to internal []*types.PersistenceFeature type

func ToPersistenceInfo ¶ added in v0.21.0

func ToPersistenceInfo(t *admin.PersistenceInfo) *types.PersistenceInfo

ToPersistenceInfo converts thrift to internal PersistenceInfo type

func ToPersistenceInfoMap ¶ added in v0.21.0

func ToPersistenceInfoMap(t map[string]*admin.PersistenceInfo) map[string]*types.PersistenceInfo

ToPersistenceInfoMap converts thrift to internal map[string]*types.PersistenceInfo type

func ToPersistenceSetting ¶ added in v0.21.0

func ToPersistenceSetting(t *admin.PersistenceSetting) *types.PersistenceSetting

ToPersistenceSetting converts from thrift to internal PersistenceSetting type

func ToPersistenceSettings ¶ added in v0.21.0

func ToPersistenceSettings(t []*admin.PersistenceSetting) []*types.PersistenceSetting

ToPersistenceSettings converts thrift to internal []*types.PersistenceSetting type

func ToPollForActivityTaskRequest ¶

func ToPollForActivityTaskRequest(t *shared.PollForActivityTaskRequest) *types.PollForActivityTaskRequest

ToPollForActivityTaskRequest converts thrift PollForActivityTaskRequest type to internal

func ToPollForActivityTaskResponse ¶

func ToPollForActivityTaskResponse(t *shared.PollForActivityTaskResponse) *types.PollForActivityTaskResponse

ToPollForActivityTaskResponse converts thrift PollForActivityTaskResponse type to internal

func ToPollForDecisionTaskRequest ¶

func ToPollForDecisionTaskRequest(t *shared.PollForDecisionTaskRequest) *types.PollForDecisionTaskRequest

ToPollForDecisionTaskRequest converts thrift PollForDecisionTaskRequest type to internal

func ToPollForDecisionTaskResponse ¶

func ToPollForDecisionTaskResponse(t *shared.PollForDecisionTaskResponse) *types.PollForDecisionTaskResponse

ToPollForDecisionTaskResponse converts thrift PollForDecisionTaskResponse type to internal

func ToPollerInfo ¶

func ToPollerInfo(t *shared.PollerInfo) *types.PollerInfo

ToPollerInfo converts thrift PollerInfo type to internal

func ToPollerInfoArray ¶

func ToPollerInfoArray(t []*shared.PollerInfo) []*types.PollerInfo

ToPollerInfoArray converts thrift PollerInfo type array to internal

func ToProcessingQueueState ¶ added in v0.17.0

func ToProcessingQueueState(t *history.ProcessingQueueState) *types.ProcessingQueueState

ToProcessingQueueState converts thrift ProcessingQueueState type to internal

func ToProcessingQueueStateArray ¶ added in v0.17.0

func ToProcessingQueueStateArray(t []*history.ProcessingQueueState) []*types.ProcessingQueueState

ToProcessingQueueStateArray converts thrift ProcessingQueueState type array to internal

func ToProcessingQueueStateArrayMap ¶ added in v0.17.0

func ToProcessingQueueStateArrayMap(t map[string][]*history.ProcessingQueueState) map[string][]*types.ProcessingQueueState

ToProcessingQueueStateArrayMap converts thrift ProcessingQueueState array map to internal

func ToProcessingQueueStates ¶ added in v0.17.0

func ToProcessingQueueStates(t *history.ProcessingQueueStates) *types.ProcessingQueueStates

ToProcessingQueueStates converts thrift ProcessingQueueStates type to internal

func ToQueryConsistencyLevel ¶

func ToQueryConsistencyLevel(t *shared.QueryConsistencyLevel) *types.QueryConsistencyLevel

ToQueryConsistencyLevel converts thrift QueryConsistencyLevel type to internal

func ToQueryFailedError ¶

func ToQueryFailedError(t *shared.QueryFailedError) *types.QueryFailedError

ToQueryFailedError converts thrift QueryFailedError type to internal

func ToQueryRejectCondition ¶

func ToQueryRejectCondition(t *shared.QueryRejectCondition) *types.QueryRejectCondition

ToQueryRejectCondition converts thrift QueryRejectCondition type to internal

func ToQueryRejected ¶

func ToQueryRejected(t *shared.QueryRejected) *types.QueryRejected

ToQueryRejected converts thrift QueryRejected type to internal

func ToQueryResultType ¶

func ToQueryResultType(t *shared.QueryResultType) *types.QueryResultType

ToQueryResultType converts thrift QueryResultType type to internal

func ToQueryTaskCompletedType ¶

func ToQueryTaskCompletedType(t *shared.QueryTaskCompletedType) *types.QueryTaskCompletedType

ToQueryTaskCompletedType converts thrift QueryTaskCompletedType type to internal

func ToQueryWorkflowRequest ¶

func ToQueryWorkflowRequest(t *shared.QueryWorkflowRequest) *types.QueryWorkflowRequest

ToQueryWorkflowRequest converts thrift QueryWorkflowRequest type to internal

func ToQueryWorkflowResponse ¶

func ToQueryWorkflowResponse(t *shared.QueryWorkflowResponse) *types.QueryWorkflowResponse

ToQueryWorkflowResponse converts thrift QueryWorkflowResponse type to internal

func ToRecordActivityTaskHeartbeatByIDRequest ¶

func ToRecordActivityTaskHeartbeatByIDRequest(t *shared.RecordActivityTaskHeartbeatByIDRequest) *types.RecordActivityTaskHeartbeatByIDRequest

ToRecordActivityTaskHeartbeatByIDRequest converts thrift RecordActivityTaskHeartbeatByIDRequest type to internal

func ToRecordActivityTaskHeartbeatRequest ¶

func ToRecordActivityTaskHeartbeatRequest(t *shared.RecordActivityTaskHeartbeatRequest) *types.RecordActivityTaskHeartbeatRequest

ToRecordActivityTaskHeartbeatRequest converts thrift RecordActivityTaskHeartbeatRequest type to internal

func ToRecordActivityTaskHeartbeatResponse ¶

func ToRecordActivityTaskHeartbeatResponse(t *shared.RecordActivityTaskHeartbeatResponse) *types.RecordActivityTaskHeartbeatResponse

ToRecordActivityTaskHeartbeatResponse converts thrift RecordActivityTaskHeartbeatResponse type to internal

func ToRecordActivityTaskStartedRequest ¶ added in v0.17.0

func ToRecordActivityTaskStartedRequest(t *history.RecordActivityTaskStartedRequest) *types.RecordActivityTaskStartedRequest

ToRecordActivityTaskStartedRequest converts thrift RecordActivityTaskStartedRequest type to internal

func ToRecordActivityTaskStartedResponse ¶ added in v0.17.0

func ToRecordActivityTaskStartedResponse(t *history.RecordActivityTaskStartedResponse) *types.RecordActivityTaskStartedResponse

ToRecordActivityTaskStartedResponse converts thrift RecordActivityTaskStartedResponse type to internal

func ToRecordChildExecutionCompletedRequest ¶ added in v0.17.0

func ToRecordChildExecutionCompletedRequest(t *history.RecordChildExecutionCompletedRequest) *types.RecordChildExecutionCompletedRequest

ToRecordChildExecutionCompletedRequest converts thrift RecordChildExecutionCompletedRequest type to internal

func ToRecordDecisionTaskStartedRequest ¶ added in v0.17.0

func ToRecordDecisionTaskStartedRequest(t *history.RecordDecisionTaskStartedRequest) *types.RecordDecisionTaskStartedRequest

ToRecordDecisionTaskStartedRequest converts thrift RecordDecisionTaskStartedRequest type to internal

func ToRecordDecisionTaskStartedResponse ¶ added in v0.17.0

func ToRecordDecisionTaskStartedResponse(t *history.RecordDecisionTaskStartedResponse) *types.RecordDecisionTaskStartedResponse

ToRecordDecisionTaskStartedResponse converts thrift RecordDecisionTaskStartedResponse type to internal

func ToRecordMarkerDecisionAttributes ¶

func ToRecordMarkerDecisionAttributes(t *shared.RecordMarkerDecisionAttributes) *types.RecordMarkerDecisionAttributes

ToRecordMarkerDecisionAttributes converts thrift RecordMarkerDecisionAttributes type to internal

func ToRefreshWorkflowTasksRequest ¶

func ToRefreshWorkflowTasksRequest(t *shared.RefreshWorkflowTasksRequest) *types.RefreshWorkflowTasksRequest

ToRefreshWorkflowTasksRequest converts thrift RefreshWorkflowTasksRequest type to internal

func ToRegisterDomainRequest ¶

func ToRegisterDomainRequest(t *shared.RegisterDomainRequest) *types.RegisterDomainRequest

ToRegisterDomainRequest converts thrift RegisterDomainRequest type to internal

func ToRemoteSyncMatchedError ¶

func ToRemoteSyncMatchedError(t *shared.RemoteSyncMatchedError) *types.RemoteSyncMatchedError

ToRemoteSyncMatchedError converts thrift RemoteSyncMatchedError type to internal

func ToReplicationMessages ¶ added in v0.17.0

func ToReplicationMessages(t *replicator.ReplicationMessages) *types.ReplicationMessages

ToReplicationMessages converts thrift ReplicationMessages type to internal

func ToReplicationMessagesMap ¶ added in v0.17.0

func ToReplicationMessagesMap(t map[int32]*replicator.ReplicationMessages) map[int32]*types.ReplicationMessages

ToReplicationMessagesMap converts thrift ReplicationMessages type map to internal

func ToReplicationTask ¶ added in v0.17.0

func ToReplicationTask(t *replicator.ReplicationTask) *types.ReplicationTask

ToReplicationTask converts thrift ReplicationTask type to internal

func ToReplicationTaskArray ¶ added in v0.17.0

func ToReplicationTaskArray(t []*replicator.ReplicationTask) []*types.ReplicationTask

ToReplicationTaskArray converts thrift ReplicationTask type array to internal

func ToReplicationTaskInfo ¶ added in v0.17.0

func ToReplicationTaskInfo(t *replicator.ReplicationTaskInfo) *types.ReplicationTaskInfo

ToReplicationTaskInfo converts thrift ReplicationTaskInfo type to internal

func ToReplicationTaskInfoArray ¶ added in v0.17.0

func ToReplicationTaskInfoArray(t []*replicator.ReplicationTaskInfo) []*types.ReplicationTaskInfo

ToReplicationTaskInfoArray converts thrift ReplicationTaskInfo type array to internal

func ToReplicationTaskType ¶ added in v0.17.0

func ToReplicationTaskType(t *replicator.ReplicationTaskType) *types.ReplicationTaskType

ToReplicationTaskType converts thrift ReplicationTaskType type to internal

func ToReplicationToken ¶ added in v0.17.0

func ToReplicationToken(t *replicator.ReplicationToken) *types.ReplicationToken

ToReplicationToken converts thrift ReplicationToken type to internal

func ToReplicationTokenArray ¶ added in v0.17.0

func ToReplicationTokenArray(t []*replicator.ReplicationToken) []*types.ReplicationToken

ToReplicationTokenArray converts thrift ReplicationToken type array to internal

func ToRequestCancelActivityTaskDecisionAttributes ¶

func ToRequestCancelActivityTaskDecisionAttributes(t *shared.RequestCancelActivityTaskDecisionAttributes) *types.RequestCancelActivityTaskDecisionAttributes

ToRequestCancelActivityTaskDecisionAttributes converts thrift RequestCancelActivityTaskDecisionAttributes type to internal

func ToRequestCancelActivityTaskFailedEventAttributes ¶

func ToRequestCancelActivityTaskFailedEventAttributes(t *shared.RequestCancelActivityTaskFailedEventAttributes) *types.RequestCancelActivityTaskFailedEventAttributes

ToRequestCancelActivityTaskFailedEventAttributes converts thrift RequestCancelActivityTaskFailedEventAttributes type to internal

func ToRequestCancelExternalWorkflowExecutionDecisionAttributes ¶

func ToRequestCancelExternalWorkflowExecutionDecisionAttributes(t *shared.RequestCancelExternalWorkflowExecutionDecisionAttributes) *types.RequestCancelExternalWorkflowExecutionDecisionAttributes

ToRequestCancelExternalWorkflowExecutionDecisionAttributes converts thrift RequestCancelExternalWorkflowExecutionDecisionAttributes type to internal

func ToRequestCancelExternalWorkflowExecutionFailedEventAttributes ¶

func ToRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *shared.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes

ToRequestCancelExternalWorkflowExecutionFailedEventAttributes converts thrift RequestCancelExternalWorkflowExecutionFailedEventAttributes type to internal

func ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶

func ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *shared.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes

ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes converts thrift RequestCancelExternalWorkflowExecutionInitiatedEventAttributes type to internal

func ToRequestCancelWorkflowExecutionRequest ¶

func ToRequestCancelWorkflowExecutionRequest(t *shared.RequestCancelWorkflowExecutionRequest) *types.RequestCancelWorkflowExecutionRequest

ToRequestCancelWorkflowExecutionRequest converts thrift RequestCancelWorkflowExecutionRequest type to internal

func ToResetPointInfo ¶

func ToResetPointInfo(t *shared.ResetPointInfo) *types.ResetPointInfo

ToResetPointInfo converts thrift ResetPointInfo type to internal

func ToResetPointInfoArray ¶

func ToResetPointInfoArray(t []*shared.ResetPointInfo) []*types.ResetPointInfo

ToResetPointInfoArray converts thrift ResetPointInfo type array to internal

func ToResetPoints ¶

func ToResetPoints(t *shared.ResetPoints) *types.ResetPoints

ToResetPoints converts thrift ResetPoints type to internal

func ToResetStickyTaskListRequest ¶

func ToResetStickyTaskListRequest(t *shared.ResetStickyTaskListRequest) *types.ResetStickyTaskListRequest

ToResetStickyTaskListRequest converts thrift ResetStickyTaskListRequest type to internal

func ToResetStickyTaskListResponse ¶

func ToResetStickyTaskListResponse(t *shared.ResetStickyTaskListResponse) *types.ResetStickyTaskListResponse

ToResetStickyTaskListResponse converts thrift ResetStickyTaskListResponse type to internal

func ToResetWorkflowExecutionRequest ¶

func ToResetWorkflowExecutionRequest(t *shared.ResetWorkflowExecutionRequest) *types.ResetWorkflowExecutionRequest

ToResetWorkflowExecutionRequest converts thrift ResetWorkflowExecutionRequest type to internal

func ToResetWorkflowExecutionResponse ¶

func ToResetWorkflowExecutionResponse(t *shared.ResetWorkflowExecutionResponse) *types.ResetWorkflowExecutionResponse

ToResetWorkflowExecutionResponse converts thrift ResetWorkflowExecutionResponse type to internal

func ToRespondActivityTaskCanceledByIDRequest ¶

func ToRespondActivityTaskCanceledByIDRequest(t *shared.RespondActivityTaskCanceledByIDRequest) *types.RespondActivityTaskCanceledByIDRequest

ToRespondActivityTaskCanceledByIDRequest converts thrift RespondActivityTaskCanceledByIDRequest type to internal

func ToRespondActivityTaskCanceledRequest ¶

func ToRespondActivityTaskCanceledRequest(t *shared.RespondActivityTaskCanceledRequest) *types.RespondActivityTaskCanceledRequest

ToRespondActivityTaskCanceledRequest converts thrift RespondActivityTaskCanceledRequest type to internal

func ToRespondActivityTaskCompletedByIDRequest ¶

func ToRespondActivityTaskCompletedByIDRequest(t *shared.RespondActivityTaskCompletedByIDRequest) *types.RespondActivityTaskCompletedByIDRequest

ToRespondActivityTaskCompletedByIDRequest converts thrift RespondActivityTaskCompletedByIDRequest type to internal

func ToRespondActivityTaskCompletedRequest ¶

func ToRespondActivityTaskCompletedRequest(t *shared.RespondActivityTaskCompletedRequest) *types.RespondActivityTaskCompletedRequest

ToRespondActivityTaskCompletedRequest converts thrift RespondActivityTaskCompletedRequest type to internal

func ToRespondActivityTaskFailedByIDRequest ¶

func ToRespondActivityTaskFailedByIDRequest(t *shared.RespondActivityTaskFailedByIDRequest) *types.RespondActivityTaskFailedByIDRequest

ToRespondActivityTaskFailedByIDRequest converts thrift RespondActivityTaskFailedByIDRequest type to internal

func ToRespondActivityTaskFailedRequest ¶

func ToRespondActivityTaskFailedRequest(t *shared.RespondActivityTaskFailedRequest) *types.RespondActivityTaskFailedRequest

ToRespondActivityTaskFailedRequest converts thrift RespondActivityTaskFailedRequest type to internal

func ToRespondDecisionTaskCompletedRequest ¶

func ToRespondDecisionTaskCompletedRequest(t *shared.RespondDecisionTaskCompletedRequest) *types.RespondDecisionTaskCompletedRequest

ToRespondDecisionTaskCompletedRequest converts thrift RespondDecisionTaskCompletedRequest type to internal

func ToRespondDecisionTaskCompletedResponse ¶

func ToRespondDecisionTaskCompletedResponse(t *shared.RespondDecisionTaskCompletedResponse) *types.RespondDecisionTaskCompletedResponse

ToRespondDecisionTaskCompletedResponse converts thrift RespondDecisionTaskCompletedResponse type to internal

func ToRespondDecisionTaskFailedRequest ¶

func ToRespondDecisionTaskFailedRequest(t *shared.RespondDecisionTaskFailedRequest) *types.RespondDecisionTaskFailedRequest

ToRespondDecisionTaskFailedRequest converts thrift RespondDecisionTaskFailedRequest type to internal

func ToRespondQueryTaskCompletedRequest ¶

func ToRespondQueryTaskCompletedRequest(t *shared.RespondQueryTaskCompletedRequest) *types.RespondQueryTaskCompletedRequest

ToRespondQueryTaskCompletedRequest converts thrift RespondQueryTaskCompletedRequest type to internal

func ToRestartWorkflowExecutionRequest ¶ added in v0.25.0

func ToRestartWorkflowExecutionRequest(t *shared.RestartWorkflowExecutionRequest) *types.RestartWorkflowExecutionRequest

ToRestartWorkflowExecutionRequest converts thrift RestartWorkflowExecutionRequest type to internal

func ToRestartWorkflowExecutionResponse ¶ added in v0.25.0

func ToRestartWorkflowExecutionResponse(t *shared.RestartWorkflowExecutionResponse) *types.RestartWorkflowExecutionResponse

ToRestartWorkflowExecutionResponse converts thrift RestartWorkflowExecutionResponse type to internal

func ToRetryPolicy ¶

func ToRetryPolicy(t *shared.RetryPolicy) *types.RetryPolicy

ToRetryPolicy converts thrift RetryPolicy type to internal

func ToRetryTaskV2Error ¶

func ToRetryTaskV2Error(t *shared.RetryTaskV2Error) *types.RetryTaskV2Error

ToRetryTaskV2Error converts thrift RetryTaskV2Error type to internal

func ToRingInfo ¶ added in v0.17.0

func ToRingInfo(t *admin.RingInfo) *types.RingInfo

ToRingInfo converts thrift RingInfo type to internal

func ToRingInfoArray ¶ added in v0.17.0

func ToRingInfoArray(t []*admin.RingInfo) []*types.RingInfo

ToRingInfoArray converts thrift RingInfo type array to internal

func ToScheduleActivityTaskDecisionAttributes ¶

func ToScheduleActivityTaskDecisionAttributes(t *shared.ScheduleActivityTaskDecisionAttributes) *types.ScheduleActivityTaskDecisionAttributes

ToScheduleActivityTaskDecisionAttributes converts thrift ScheduleActivityTaskDecisionAttributes type to internal

func ToSearchAttributes ¶

func ToSearchAttributes(t *shared.SearchAttributes) *types.SearchAttributes

ToSearchAttributes converts thrift SearchAttributes type to internal

func ToServiceBusyError ¶

func ToServiceBusyError(t *shared.ServiceBusyError) *types.ServiceBusyError

ToServiceBusyError converts thrift ServiceBusyError type to internal

func ToShardOwnershipLostError ¶ added in v0.17.0

func ToShardOwnershipLostError(t *history.ShardOwnershipLostError) *types.ShardOwnershipLostError

ToShardOwnershipLostError converts thrift ShardOwnershipLostError type to internal

func ToSignalExternalWorkflowExecutionDecisionAttributes ¶

func ToSignalExternalWorkflowExecutionDecisionAttributes(t *shared.SignalExternalWorkflowExecutionDecisionAttributes) *types.SignalExternalWorkflowExecutionDecisionAttributes

ToSignalExternalWorkflowExecutionDecisionAttributes converts thrift SignalExternalWorkflowExecutionDecisionAttributes type to internal

func ToSignalExternalWorkflowExecutionFailedCause ¶

func ToSignalExternalWorkflowExecutionFailedCause(t *shared.SignalExternalWorkflowExecutionFailedCause) *types.SignalExternalWorkflowExecutionFailedCause

ToSignalExternalWorkflowExecutionFailedCause converts thrift SignalExternalWorkflowExecutionFailedCause type to internal

func ToSignalExternalWorkflowExecutionFailedEventAttributes ¶

func ToSignalExternalWorkflowExecutionFailedEventAttributes(t *shared.SignalExternalWorkflowExecutionFailedEventAttributes) *types.SignalExternalWorkflowExecutionFailedEventAttributes

ToSignalExternalWorkflowExecutionFailedEventAttributes converts thrift SignalExternalWorkflowExecutionFailedEventAttributes type to internal

func ToSignalExternalWorkflowExecutionInitiatedEventAttributes ¶

func ToSignalExternalWorkflowExecutionInitiatedEventAttributes(t *shared.SignalExternalWorkflowExecutionInitiatedEventAttributes) *types.SignalExternalWorkflowExecutionInitiatedEventAttributes

ToSignalExternalWorkflowExecutionInitiatedEventAttributes converts thrift SignalExternalWorkflowExecutionInitiatedEventAttributes type to internal

func ToSignalWithStartWorkflowExecutionAsyncRequest ¶ added in v1.2.8

func ToSignalWithStartWorkflowExecutionAsyncRequest(t *shared.SignalWithStartWorkflowExecutionAsyncRequest) *types.SignalWithStartWorkflowExecutionAsyncRequest

func ToSignalWithStartWorkflowExecutionAsyncResponse ¶ added in v1.2.8

func ToSignalWithStartWorkflowExecutionAsyncResponse(t *shared.SignalWithStartWorkflowExecutionAsyncResponse) *types.SignalWithStartWorkflowExecutionAsyncResponse

func ToSignalWithStartWorkflowExecutionRequest ¶

func ToSignalWithStartWorkflowExecutionRequest(t *shared.SignalWithStartWorkflowExecutionRequest) *types.SignalWithStartWorkflowExecutionRequest

ToSignalWithStartWorkflowExecutionRequest converts thrift SignalWithStartWorkflowExecutionRequest type to internal

func ToSignalWorkflowExecutionRequest ¶

func ToSignalWorkflowExecutionRequest(t *shared.SignalWorkflowExecutionRequest) *types.SignalWorkflowExecutionRequest

ToSignalWorkflowExecutionRequest converts thrift SignalWorkflowExecutionRequest type to internal

func ToStartChildWorkflowExecutionDecisionAttributes ¶

func ToStartChildWorkflowExecutionDecisionAttributes(t *shared.StartChildWorkflowExecutionDecisionAttributes) *types.StartChildWorkflowExecutionDecisionAttributes

ToStartChildWorkflowExecutionDecisionAttributes converts thrift StartChildWorkflowExecutionDecisionAttributes type to internal

func ToStartChildWorkflowExecutionFailedEventAttributes ¶

func ToStartChildWorkflowExecutionFailedEventAttributes(t *shared.StartChildWorkflowExecutionFailedEventAttributes) *types.StartChildWorkflowExecutionFailedEventAttributes

ToStartChildWorkflowExecutionFailedEventAttributes converts thrift StartChildWorkflowExecutionFailedEventAttributes type to internal

func ToStartChildWorkflowExecutionInitiatedEventAttributes ¶

func ToStartChildWorkflowExecutionInitiatedEventAttributes(t *shared.StartChildWorkflowExecutionInitiatedEventAttributes) *types.StartChildWorkflowExecutionInitiatedEventAttributes

ToStartChildWorkflowExecutionInitiatedEventAttributes converts thrift StartChildWorkflowExecutionInitiatedEventAttributes type to internal

func ToStartTimeFilter ¶

func ToStartTimeFilter(t *shared.StartTimeFilter) *types.StartTimeFilter

ToStartTimeFilter converts thrift StartTimeFilter type to internal

func ToStartTimerDecisionAttributes ¶

func ToStartTimerDecisionAttributes(t *shared.StartTimerDecisionAttributes) *types.StartTimerDecisionAttributes

ToStartTimerDecisionAttributes converts thrift StartTimerDecisionAttributes type to internal

func ToStartWorkflowExecutionAsyncRequest ¶ added in v1.2.8

func ToStartWorkflowExecutionAsyncRequest(t *shared.StartWorkflowExecutionAsyncRequest) *types.StartWorkflowExecutionAsyncRequest

func ToStartWorkflowExecutionAsyncResponse ¶ added in v1.2.8

func ToStartWorkflowExecutionAsyncResponse(t *shared.StartWorkflowExecutionAsyncResponse) *types.StartWorkflowExecutionAsyncResponse

func ToStartWorkflowExecutionRequest ¶

func ToStartWorkflowExecutionRequest(t *shared.StartWorkflowExecutionRequest) *types.StartWorkflowExecutionRequest

ToStartWorkflowExecutionRequest converts thrift StartWorkflowExecutionRequest type to internal

func ToStartWorkflowExecutionResponse ¶

func ToStartWorkflowExecutionResponse(t *shared.StartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse

ToStartWorkflowExecutionResponse converts thrift StartWorkflowExecutionResponse type to internal

func ToStickyExecutionAttributes ¶

func ToStickyExecutionAttributes(t *shared.StickyExecutionAttributes) *types.StickyExecutionAttributes

ToStickyExecutionAttributes converts thrift StickyExecutionAttributes type to internal

func ToStickyWorkerUnavailableError ¶ added in v0.25.0

func ToStickyWorkerUnavailableError(t *shared.StickyWorkerUnavailableError) *types.StickyWorkerUnavailableError

ToStickyWorkerUnavailableError converts thrift StickyWorkerUnavailableError type to internal

func ToSupportedClientVersions ¶

func ToSupportedClientVersions(t *shared.SupportedClientVersions) *types.SupportedClientVersions

ToSupportedClientVersions converts thrift SupportedClientVersions type to internal

func ToSyncActivityTaskAttributes ¶ added in v0.17.0

func ToSyncActivityTaskAttributes(t *replicator.SyncActivityTaskAttributes) *types.SyncActivityTaskAttributes

ToSyncActivityTaskAttributes converts thrift SyncActivityTaskAttributes type to internal

func ToSyncShardStatus ¶ added in v0.17.0

func ToSyncShardStatus(t *replicator.SyncShardStatus) *types.SyncShardStatus

ToSyncShardStatus converts thrift SyncShardStatus type to internal

func ToSyncShardStatusTaskAttributes ¶ added in v0.17.0

func ToSyncShardStatusTaskAttributes(t *replicator.SyncShardStatusTaskAttributes) *types.SyncShardStatusTaskAttributes

ToSyncShardStatusTaskAttributes converts thrift SyncShardStatusTaskAttributes type to internal

func ToTaskIDBlock ¶

func ToTaskIDBlock(t *shared.TaskIDBlock) *types.TaskIDBlock

ToTaskIDBlock converts thrift TaskIDBlock type to internal

func ToTaskList ¶

func ToTaskList(t *shared.TaskList) *types.TaskList

ToTaskList converts thrift TaskList type to internal

func ToTaskListKind ¶

func ToTaskListKind(t *shared.TaskListKind) *types.TaskListKind

ToTaskListKind converts thrift TaskListKind type to internal

func ToTaskListMetadata ¶

func ToTaskListMetadata(t *shared.TaskListMetadata) *types.TaskListMetadata

ToTaskListMetadata converts thrift TaskListMetadata type to internal

func ToTaskListNotOwnedByHostError ¶ added in v1.2.13

func ToTaskListNotOwnedByHostError(t *shared.TaskListNotOwnedByHostError) *cadence_errors.TaskListNotOwnedByHostError

ToTaskListNotOwnedByHostError converts thrift TaskListNotOwnedByHostError type to internal

func ToTaskListPartitionMetadata ¶

func ToTaskListPartitionMetadata(t *shared.TaskListPartitionMetadata) *types.TaskListPartitionMetadata

ToTaskListPartitionMetadata converts thrift TaskListPartitionMetadata type to internal

func ToTaskListPartitionMetadataArray ¶

func ToTaskListPartitionMetadataArray(t []*shared.TaskListPartitionMetadata) []*types.TaskListPartitionMetadata

ToTaskListPartitionMetadataArray converts thrift TaskListPartitionMetadata type array to internal

func ToTaskListStatus ¶

func ToTaskListStatus(t *shared.TaskListStatus) *types.TaskListStatus

ToTaskListStatus converts thrift TaskListStatus type to internal

func ToTaskListType ¶

func ToTaskListType(t *shared.TaskListType) *types.TaskListType

ToTaskListType converts thrift TaskListType type to internal

func ToTaskSource ¶ added in v0.17.0

func ToTaskSource(t *matching.TaskSource) *types.TaskSource

ToTaskSource converts thrift TaskSource type to internal

func ToTerminateWorkflowExecutionRequest ¶

func ToTerminateWorkflowExecutionRequest(t *shared.TerminateWorkflowExecutionRequest) *types.TerminateWorkflowExecutionRequest

ToTerminateWorkflowExecutionRequest converts thrift TerminateWorkflowExecutionRequest type to internal

func ToTimeoutType ¶

func ToTimeoutType(t *shared.TimeoutType) *types.TimeoutType

ToTimeoutType converts thrift TimeoutType type to internal

func ToTimerCanceledEventAttributes ¶

func ToTimerCanceledEventAttributes(t *shared.TimerCanceledEventAttributes) *types.TimerCanceledEventAttributes

ToTimerCanceledEventAttributes converts thrift TimerCanceledEventAttributes type to internal

func ToTimerFiredEventAttributes ¶

func ToTimerFiredEventAttributes(t *shared.TimerFiredEventAttributes) *types.TimerFiredEventAttributes

ToTimerFiredEventAttributes converts thrift TimerFiredEventAttributes type to internal

func ToTimerStartedEventAttributes ¶

func ToTimerStartedEventAttributes(t *shared.TimerStartedEventAttributes) *types.TimerStartedEventAttributes

ToTimerStartedEventAttributes converts thrift TimerStartedEventAttributes type to internal

func ToTransientDecisionInfo ¶

func ToTransientDecisionInfo(t *shared.TransientDecisionInfo) *types.TransientDecisionInfo

ToTransientDecisionInfo converts thrift TransientDecisionInfo type to internal

func ToUpdateDomainRequest ¶

func ToUpdateDomainRequest(t *shared.UpdateDomainRequest) *types.UpdateDomainRequest

ToUpdateDomainRequest converts thrift UpdateDomainRequest type to internal

func ToUpdateDomainResponse ¶

func ToUpdateDomainResponse(t *shared.UpdateDomainResponse) *types.UpdateDomainResponse

ToUpdateDomainResponse converts thrift UpdateDomainResponse type to internal

func ToUpsertWorkflowSearchAttributesDecisionAttributes ¶

func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *shared.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes

ToUpsertWorkflowSearchAttributesDecisionAttributes converts thrift UpsertWorkflowSearchAttributesDecisionAttributes type to internal

func ToUpsertWorkflowSearchAttributesEventAttributes ¶

func ToUpsertWorkflowSearchAttributesEventAttributes(t *shared.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes

ToUpsertWorkflowSearchAttributesEventAttributes converts thrift UpsertWorkflowSearchAttributesEventAttributes type to internal

func ToVersionHistories ¶

func ToVersionHistories(t *shared.VersionHistories) *types.VersionHistories

ToVersionHistories converts thrift VersionHistories type to internal

func ToVersionHistory ¶

func ToVersionHistory(t *shared.VersionHistory) *types.VersionHistory

ToVersionHistory converts thrift VersionHistory type to internal

func ToVersionHistoryArray ¶

func ToVersionHistoryArray(t []*shared.VersionHistory) []*types.VersionHistory

ToVersionHistoryArray converts thrift VersionHistory type array to internal

func ToVersionHistoryItem ¶

func ToVersionHistoryItem(t *shared.VersionHistoryItem) *types.VersionHistoryItem

ToVersionHistoryItem converts thrift VersionHistoryItem type to internal

func ToVersionHistoryItemArray ¶

func ToVersionHistoryItemArray(t []*shared.VersionHistoryItem) []*types.VersionHistoryItem

ToVersionHistoryItemArray converts thrift VersionHistoryItem type array to internal

func ToWorkerVersionInfo ¶

func ToWorkerVersionInfo(t *shared.WorkerVersionInfo) *types.WorkerVersionInfo

ToWorkerVersionInfo converts thrift WorkerVersionInfo type to internal

func ToWorkflowExecution ¶

func ToWorkflowExecution(t *shared.WorkflowExecution) *types.WorkflowExecution

ToWorkflowExecution converts thrift WorkflowExecution type to internal

func ToWorkflowExecutionAlreadyCompletedError ¶ added in v0.21.0

func ToWorkflowExecutionAlreadyCompletedError(t *shared.WorkflowExecutionAlreadyCompletedError) *types.WorkflowExecutionAlreadyCompletedError

ToWorkflowExecutionAlreadyCompletedError converts thrift WorkflowExecutionAlreadyCompletedError type to internal

func ToWorkflowExecutionAlreadyStartedError ¶

func ToWorkflowExecutionAlreadyStartedError(t *shared.WorkflowExecutionAlreadyStartedError) *types.WorkflowExecutionAlreadyStartedError

ToWorkflowExecutionAlreadyStartedError converts thrift WorkflowExecutionAlreadyStartedError type to internal

func ToWorkflowExecutionCancelRequestedEventAttributes ¶

func ToWorkflowExecutionCancelRequestedEventAttributes(t *shared.WorkflowExecutionCancelRequestedEventAttributes) *types.WorkflowExecutionCancelRequestedEventAttributes

ToWorkflowExecutionCancelRequestedEventAttributes converts thrift WorkflowExecutionCancelRequestedEventAttributes type to internal

func ToWorkflowExecutionCanceledEventAttributes ¶

func ToWorkflowExecutionCanceledEventAttributes(t *shared.WorkflowExecutionCanceledEventAttributes) *types.WorkflowExecutionCanceledEventAttributes

ToWorkflowExecutionCanceledEventAttributes converts thrift WorkflowExecutionCanceledEventAttributes type to internal

func ToWorkflowExecutionCloseStatus ¶

func ToWorkflowExecutionCloseStatus(t *shared.WorkflowExecutionCloseStatus) *types.WorkflowExecutionCloseStatus

ToWorkflowExecutionCloseStatus converts thrift WorkflowExecutionCloseStatus type to internal

func ToWorkflowExecutionCompletedEventAttributes ¶

func ToWorkflowExecutionCompletedEventAttributes(t *shared.WorkflowExecutionCompletedEventAttributes) *types.WorkflowExecutionCompletedEventAttributes

ToWorkflowExecutionCompletedEventAttributes converts thrift WorkflowExecutionCompletedEventAttributes type to internal

func ToWorkflowExecutionConfiguration ¶

func ToWorkflowExecutionConfiguration(t *shared.WorkflowExecutionConfiguration) *types.WorkflowExecutionConfiguration

ToWorkflowExecutionConfiguration converts thrift WorkflowExecutionConfiguration type to internal

func ToWorkflowExecutionContinuedAsNewEventAttributes ¶

func ToWorkflowExecutionContinuedAsNewEventAttributes(t *shared.WorkflowExecutionContinuedAsNewEventAttributes) *types.WorkflowExecutionContinuedAsNewEventAttributes

ToWorkflowExecutionContinuedAsNewEventAttributes converts thrift WorkflowExecutionContinuedAsNewEventAttributes type to internal

func ToWorkflowExecutionFailedEventAttributes ¶

func ToWorkflowExecutionFailedEventAttributes(t *shared.WorkflowExecutionFailedEventAttributes) *types.WorkflowExecutionFailedEventAttributes

ToWorkflowExecutionFailedEventAttributes converts thrift WorkflowExecutionFailedEventAttributes type to internal

func ToWorkflowExecutionFilter ¶

func ToWorkflowExecutionFilter(t *shared.WorkflowExecutionFilter) *types.WorkflowExecutionFilter

ToWorkflowExecutionFilter converts thrift WorkflowExecutionFilter type to internal

func ToWorkflowExecutionInfo ¶

func ToWorkflowExecutionInfo(t *shared.WorkflowExecutionInfo) *types.WorkflowExecutionInfo

ToWorkflowExecutionInfo converts thrift WorkflowExecutionInfo type to internal

func ToWorkflowExecutionInfoArray ¶

func ToWorkflowExecutionInfoArray(t []*shared.WorkflowExecutionInfo) []*types.WorkflowExecutionInfo

ToWorkflowExecutionInfoArray converts thrift WorkflowExecutionInfo type array to internal

func ToWorkflowExecutionSignaledEventAttributes ¶

func ToWorkflowExecutionSignaledEventAttributes(t *shared.WorkflowExecutionSignaledEventAttributes) *types.WorkflowExecutionSignaledEventAttributes

ToWorkflowExecutionSignaledEventAttributes converts thrift WorkflowExecutionSignaledEventAttributes type to internal

func ToWorkflowExecutionStartedEventAttributes ¶

func ToWorkflowExecutionStartedEventAttributes(t *shared.WorkflowExecutionStartedEventAttributes) *types.WorkflowExecutionStartedEventAttributes

ToWorkflowExecutionStartedEventAttributes converts thrift WorkflowExecutionStartedEventAttributes type to internal

func ToWorkflowExecutionTerminatedEventAttributes ¶

func ToWorkflowExecutionTerminatedEventAttributes(t *shared.WorkflowExecutionTerminatedEventAttributes) *types.WorkflowExecutionTerminatedEventAttributes

ToWorkflowExecutionTerminatedEventAttributes converts thrift WorkflowExecutionTerminatedEventAttributes type to internal

func ToWorkflowExecutionTimedOutEventAttributes ¶

func ToWorkflowExecutionTimedOutEventAttributes(t *shared.WorkflowExecutionTimedOutEventAttributes) *types.WorkflowExecutionTimedOutEventAttributes

ToWorkflowExecutionTimedOutEventAttributes converts thrift WorkflowExecutionTimedOutEventAttributes type to internal

func ToWorkflowIDReusePolicy ¶

func ToWorkflowIDReusePolicy(t *shared.WorkflowIdReusePolicy) *types.WorkflowIDReusePolicy

ToWorkflowIDReusePolicy converts thrift WorkflowIdReusePolicy type to internal

func ToWorkflowQuery ¶

func ToWorkflowQuery(t *shared.WorkflowQuery) *types.WorkflowQuery

ToWorkflowQuery converts thrift WorkflowQuery type to internal

func ToWorkflowQueryMap ¶

func ToWorkflowQueryMap(t map[string]*shared.WorkflowQuery) map[string]*types.WorkflowQuery

ToWorkflowQueryMap converts thrift WorkflowQuery type map to internal

func ToWorkflowQueryResult ¶

func ToWorkflowQueryResult(t *shared.WorkflowQueryResult) *types.WorkflowQueryResult

ToWorkflowQueryResult converts thrift WorkflowQueryResult type to internal

func ToWorkflowQueryResultMap ¶

func ToWorkflowQueryResultMap(t map[string]*shared.WorkflowQueryResult) map[string]*types.WorkflowQueryResult

ToWorkflowQueryResultMap converts thrift WorkflowQueryResult type map to internal

func ToWorkflowType ¶

func ToWorkflowType(t *shared.WorkflowType) *types.WorkflowType

ToWorkflowType converts thrift WorkflowType type to internal

func ToWorkflowTypeFilter ¶

func ToWorkflowTypeFilter(t *shared.WorkflowTypeFilter) *types.WorkflowTypeFilter

ToWorkflowTypeFilter converts thrift WorkflowTypeFilter type to internal

Types ¶

type ThriftObject ¶ added in v1.2.12

type ThriftObject interface {
	FromWire(w wire.Value) error
	ToWire() (wire.Value, error)
}

ThriftObject is satisfied by any thrift type, as they all have To/FromWire methods. go.uber.org/cadence has exactly this in an internal API, it's just copied here for simplicity.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL