thrift

package

v1.2.13-prerelease04 Latest Latest Go to latest Published: Aug 16, 2024 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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 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 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 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 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 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 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 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 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
	FromMatchingPollForActivityTaskResponse    = FromPollForActivityTaskResponse
	ToMatchingPollForActivityTaskResponse      = ToPollForActivityTaskResponse
	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 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 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 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 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 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 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 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 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