proto

package

v1.2.7-prerelease4 Latest Latest Go to latest Published: Jan 30, 2024 License: MIT Imports: 15 Imported by: 0

Details

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

Repository

github.com/uber/cadence

Documentation ¶

Index ¶

Constants
func FromActivityLocalDispatchInfo(t *types.ActivityLocalDispatchInfo) *apiv1.ActivityLocalDispatchInfo
func FromActivityLocalDispatchInfoMap(t map[string]*types.ActivityLocalDispatchInfo) map[string]*apiv1.ActivityLocalDispatchInfo
func FromActivityTaskCancelRequestedEventAttributes(t *types.ActivityTaskCancelRequestedEventAttributes) *apiv1.ActivityTaskCancelRequestedEventAttributes
func FromActivityTaskCanceledEventAttributes(t *types.ActivityTaskCanceledEventAttributes) *apiv1.ActivityTaskCanceledEventAttributes
func FromActivityTaskCompletedEventAttributes(t *types.ActivityTaskCompletedEventAttributes) *apiv1.ActivityTaskCompletedEventAttributes
func FromActivityTaskDispatchInfo(t *types.ActivityTaskDispatchInfo) *matchingv1.ActivityTaskDispatchInfo
func FromActivityTaskFailedEventAttributes(t *types.ActivityTaskFailedEventAttributes) *apiv1.ActivityTaskFailedEventAttributes
func FromActivityTaskScheduledEventAttributes(t *types.ActivityTaskScheduledEventAttributes) *apiv1.ActivityTaskScheduledEventAttributes
func FromActivityTaskStartedEventAttributes(t *types.ActivityTaskStartedEventAttributes) *apiv1.ActivityTaskStartedEventAttributes
func FromActivityTaskTimedOutEventAttributes(t *types.ActivityTaskTimedOutEventAttributes) *apiv1.ActivityTaskTimedOutEventAttributes
func FromActivityType(t *types.ActivityType) *apiv1.ActivityType
func FromAdminAddSearchAttributeRequest(t *types.AddSearchAttributeRequest) *adminv1.AddSearchAttributeRequest
func FromAdminCloseShardRequest(t *types.CloseShardRequest) *adminv1.CloseShardRequest
func FromAdminCountDLQMessagesRequest(t *types.CountDLQMessagesRequest) *adminv1.CountDLQMessagesRequest
func FromAdminCountDLQMessagesResponse(t *types.CountDLQMessagesResponse) *adminv1.CountDLQMessagesResponse
func FromAdminDeleteWorkflowRequest(t *types.AdminDeleteWorkflowRequest) *adminv1.DeleteWorkflowRequest
func FromAdminDeleteWorkflowResponse(t *types.AdminDeleteWorkflowResponse) *adminv1.DeleteWorkflowResponse
func FromAdminDescribeClusterResponse(t *types.DescribeClusterResponse) *adminv1.DescribeClusterResponse
func FromAdminDescribeHistoryHostRequest(t *types.DescribeHistoryHostRequest) *adminv1.DescribeHistoryHostRequest
func FromAdminDescribeHistoryHostResponse(t *types.DescribeHistoryHostResponse) *adminv1.DescribeHistoryHostResponse
func FromAdminDescribeQueueRequest(t *types.DescribeQueueRequest) *adminv1.DescribeQueueRequest
func FromAdminDescribeQueueResponse(t *types.DescribeQueueResponse) *adminv1.DescribeQueueResponse
func FromAdminDescribeShardDistributionRequest(t *types.DescribeShardDistributionRequest) *adminv1.DescribeShardDistributionRequest
func FromAdminDescribeShardDistributionResponse(t *types.DescribeShardDistributionResponse) *adminv1.DescribeShardDistributionResponse
func FromAdminDescribeWorkflowExecutionRequest(t *types.AdminDescribeWorkflowExecutionRequest) *adminv1.DescribeWorkflowExecutionRequest
func FromAdminDescribeWorkflowExecutionResponse(t *types.AdminDescribeWorkflowExecutionResponse) *adminv1.DescribeWorkflowExecutionResponse
func FromAdminGetCrossClusterTasksRequest(t *types.GetCrossClusterTasksRequest) *adminv1.GetCrossClusterTasksRequest
func FromAdminGetCrossClusterTasksResponse(t *types.GetCrossClusterTasksResponse) *adminv1.GetCrossClusterTasksResponse
func FromAdminGetDLQReplicationMessagesRequest(t *types.GetDLQReplicationMessagesRequest) *adminv1.GetDLQReplicationMessagesRequest
func FromAdminGetDLQReplicationMessagesResponse(t *types.GetDLQReplicationMessagesResponse) *adminv1.GetDLQReplicationMessagesResponse
func FromAdminGetDomainAsyncWorkflowConfiguratonRequest(in *types.GetDomainAsyncWorkflowConfiguratonRequest) *adminv1.GetDomainAsyncWorkflowConfiguratonRequest
func FromAdminGetDomainAsyncWorkflowConfiguratonResponse(in *types.GetDomainAsyncWorkflowConfiguratonResponse) *adminv1.GetDomainAsyncWorkflowConfiguratonResponse
func FromAdminGetDomainIsolationGroupsRequest(t *types.GetDomainIsolationGroupsRequest) *adminv1.GetDomainIsolationGroupsRequest
func FromAdminGetDomainIsolationGroupsResponse(t *types.GetDomainIsolationGroupsResponse) *adminv1.GetDomainIsolationGroupsResponse
func FromAdminGetDomainReplicationMessagesRequest(t *types.GetDomainReplicationMessagesRequest) *adminv1.GetDomainReplicationMessagesRequest
func FromAdminGetDomainReplicationMessagesResponse(t *types.GetDomainReplicationMessagesResponse) *adminv1.GetDomainReplicationMessagesResponse
func FromAdminGetDynamicConfigRequest(t *types.GetDynamicConfigRequest) *adminv1.GetDynamicConfigRequest
func FromAdminGetDynamicConfigResponse(t *types.GetDynamicConfigResponse) *adminv1.GetDynamicConfigResponse
func FromAdminGetGlobalIsolationGroupsRequest(t *types.GetGlobalIsolationGroupsRequest) *adminv1.GetGlobalIsolationGroupsRequest
func FromAdminGetGlobalIsolationGroupsResponse(t *types.GetGlobalIsolationGroupsResponse) *adminv1.GetGlobalIsolationGroupsResponse
func FromAdminGetReplicationMessagesRequest(t *types.GetReplicationMessagesRequest) *adminv1.GetReplicationMessagesRequest
func FromAdminGetReplicationMessagesResponse(t *types.GetReplicationMessagesResponse) *adminv1.GetReplicationMessagesResponse
func FromAdminGetWorkflowExecutionRawHistoryV2Request(t *types.GetWorkflowExecutionRawHistoryV2Request) *adminv1.GetWorkflowExecutionRawHistoryV2Request
func FromAdminGetWorkflowExecutionRawHistoryV2Response(t *types.GetWorkflowExecutionRawHistoryV2Response) *adminv1.GetWorkflowExecutionRawHistoryV2Response
func FromAdminListDynamicConfigRequest(t *types.ListDynamicConfigRequest) *adminv1.ListDynamicConfigRequest
func FromAdminListDynamicConfigResponse(t *types.ListDynamicConfigResponse) *adminv1.ListDynamicConfigResponse
func FromAdminMaintainCorruptWorkflowRequest(t *types.AdminMaintainWorkflowRequest) *adminv1.MaintainCorruptWorkflowRequest
func FromAdminMaintainCorruptWorkflowResponse(t *types.AdminMaintainWorkflowResponse) *adminv1.MaintainCorruptWorkflowResponse
func FromAdminMergeDLQMessagesRequest(t *types.MergeDLQMessagesRequest) *adminv1.MergeDLQMessagesRequest
func FromAdminMergeDLQMessagesResponse(t *types.MergeDLQMessagesResponse) *adminv1.MergeDLQMessagesResponse
func FromAdminPurgeDLQMessagesRequest(t *types.PurgeDLQMessagesRequest) *adminv1.PurgeDLQMessagesRequest
func FromAdminReadDLQMessagesRequest(t *types.ReadDLQMessagesRequest) *adminv1.ReadDLQMessagesRequest
func FromAdminReadDLQMessagesResponse(t *types.ReadDLQMessagesResponse) *adminv1.ReadDLQMessagesResponse
func FromAdminReapplyEventsRequest(t *types.ReapplyEventsRequest) *adminv1.ReapplyEventsRequest
func FromAdminRefreshWorkflowTasksRequest(t *types.RefreshWorkflowTasksRequest) *adminv1.RefreshWorkflowTasksRequest
func FromAdminRemoveTaskRequest(t *types.RemoveTaskRequest) *adminv1.RemoveTaskRequest
func FromAdminResendReplicationTasksRequest(t *types.ResendReplicationTasksRequest) *adminv1.ResendReplicationTasksRequest
func FromAdminResetQueueRequest(t *types.ResetQueueRequest) *adminv1.ResetQueueRequest
func FromAdminRespondCrossClusterTasksCompletedRequest(t *types.RespondCrossClusterTasksCompletedRequest) *adminv1.RespondCrossClusterTasksCompletedRequest
func FromAdminRespondCrossClusterTasksCompletedResponse(t *types.RespondCrossClusterTasksCompletedResponse) *adminv1.RespondCrossClusterTasksCompletedResponse
func FromAdminRestoreDynamicConfigRequest(t *types.RestoreDynamicConfigRequest) *adminv1.RestoreDynamicConfigRequest
func FromAdminUpdateDomainAsyncWorkflowConfiguratonRequest(in *types.UpdateDomainAsyncWorkflowConfiguratonRequest) *adminv1.UpdateDomainAsyncWorkflowConfiguratonRequest
func FromAdminUpdateDomainAsyncWorkflowConfiguratonResponse(in *types.UpdateDomainAsyncWorkflowConfiguratonResponse) *adminv1.UpdateDomainAsyncWorkflowConfiguratonResponse
func FromAdminUpdateDomainIsolationGroupsRequest(t *types.UpdateDomainIsolationGroupsRequest) *adminv1.UpdateDomainIsolationGroupsRequest
func FromAdminUpdateDomainIsolationGroupsResponse(t *types.UpdateDomainIsolationGroupsResponse) *adminv1.UpdateDomainIsolationGroupsResponse
func FromAdminUpdateDynamicConfigRequest(t *types.UpdateDynamicConfigRequest) *adminv1.UpdateDynamicConfigRequest
func FromAdminUpdateGlobalIsolationGroupsRequest(t *types.UpdateGlobalIsolationGroupsRequest) *adminv1.UpdateGlobalIsolationGroupsRequest
func FromAdminUpdateGlobalIsolationGroupsResponse(t *types.UpdateGlobalIsolationGroupsResponse) *adminv1.UpdateGlobalIsolationGroupsResponse
func FromApplyParentClosePolicyAttributes(t *types.ApplyParentClosePolicyAttributes) *adminv1.ApplyParentClosePolicyAttributes
func FromApplyParentClosePolicyResult(t *types.ApplyParentClosePolicyResult) *adminv1.ApplyParentClosePolicyResult
func FromApplyParentClosePolicyStatus(t *types.ApplyParentClosePolicyStatus) *adminv1.ApplyParentClosePolicyStatus
func FromArchivalStatus(t *types.ArchivalStatus) apiv1.ArchivalStatus
func FromAsyncWorkflowKafkaQueueConfig(in *types.AsyncWorkflowKafkaQueueConfiguration) *apiv1.AsyncWorkflowConfiguration_KafkaConfig
func FromBadBinaries(t *types.BadBinaries) *apiv1.BadBinaries
func FromBadBinaryInfo(t *types.BadBinaryInfo) *apiv1.BadBinaryInfo
func FromBadBinaryInfoMap(t map[string]*types.BadBinaryInfo) map[string]*apiv1.BadBinaryInfo
func FromCancelExternalWorkflowExecutionFailedCause(t *types.CancelExternalWorkflowExecutionFailedCause) apiv1.CancelExternalWorkflowExecutionFailedCause
func FromCancelTimerDecisionAttributes(t *types.CancelTimerDecisionAttributes) *apiv1.CancelTimerDecisionAttributes
func FromCancelTimerFailedEventAttributes(t *types.CancelTimerFailedEventAttributes) *apiv1.CancelTimerFailedEventAttributes
func FromCancelWorkflowExecutionDecisionAttributes(t *types.CancelWorkflowExecutionDecisionAttributes) *apiv1.CancelWorkflowExecutionDecisionAttributes
func FromChildWorkflowExecutionCanceledEventAttributes(t *types.ChildWorkflowExecutionCanceledEventAttributes) *apiv1.ChildWorkflowExecutionCanceledEventAttributes
func FromChildWorkflowExecutionCompletedEventAttributes(t *types.ChildWorkflowExecutionCompletedEventAttributes) *apiv1.ChildWorkflowExecutionCompletedEventAttributes
func FromChildWorkflowExecutionFailedCause(t *types.ChildWorkflowExecutionFailedCause) apiv1.ChildWorkflowExecutionFailedCause
func FromChildWorkflowExecutionFailedEventAttributes(t *types.ChildWorkflowExecutionFailedEventAttributes) *apiv1.ChildWorkflowExecutionFailedEventAttributes
func FromChildWorkflowExecutionStartedEventAttributes(t *types.ChildWorkflowExecutionStartedEventAttributes) *apiv1.ChildWorkflowExecutionStartedEventAttributes
func FromChildWorkflowExecutionTerminatedEventAttributes(t *types.ChildWorkflowExecutionTerminatedEventAttributes) *apiv1.ChildWorkflowExecutionTerminatedEventAttributes
func FromChildWorkflowExecutionTimedOutEventAttributes(t *types.ChildWorkflowExecutionTimedOutEventAttributes) *apiv1.ChildWorkflowExecutionTimedOutEventAttributes
func FromClusterReplicationConfiguration(t *types.ClusterReplicationConfiguration) *apiv1.ClusterReplicationConfiguration
func FromClusterReplicationConfigurationArray(t []*types.ClusterReplicationConfiguration) []*apiv1.ClusterReplicationConfiguration
func FromCompleteWorkflowExecutionDecisionAttributes(t *types.CompleteWorkflowExecutionDecisionAttributes) *apiv1.CompleteWorkflowExecutionDecisionAttributes
func FromContinueAsNewInitiator(t *types.ContinueAsNewInitiator) apiv1.ContinueAsNewInitiator
func FromContinueAsNewWorkflowExecutionDecisionAttributes(t *types.ContinueAsNewWorkflowExecutionDecisionAttributes) *apiv1.ContinueAsNewWorkflowExecutionDecisionAttributes
func FromCountWorkflowExecutionsRequest(t *types.CountWorkflowExecutionsRequest) *apiv1.CountWorkflowExecutionsRequest
func FromCountWorkflowExecutionsResponse(t *types.CountWorkflowExecutionsResponse) *apiv1.CountWorkflowExecutionsResponse
func FromCrossClusterApplyParentClosePolicyRequestAttributes(t *types.CrossClusterApplyParentClosePolicyRequestAttributes) *adminv1.CrossClusterApplyParentClosePolicyRequestAttributes
func FromCrossClusterApplyParentClosePolicyResponseAttributes(t *types.CrossClusterApplyParentClosePolicyResponseAttributes) *adminv1.CrossClusterApplyParentClosePolicyResponseAttributes
func FromCrossClusterCancelExecutionRequestAttributes(t *types.CrossClusterCancelExecutionRequestAttributes) *adminv1.CrossClusterCancelExecutionRequestAttributes
func FromCrossClusterCancelExecutionResponseAttributes(t *types.CrossClusterCancelExecutionResponseAttributes) *adminv1.CrossClusterCancelExecutionResponseAttributes
func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes
func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes
func FromCrossClusterSignalExecutionRequestAttributes(t *types.CrossClusterSignalExecutionRequestAttributes) *adminv1.CrossClusterSignalExecutionRequestAttributes
func FromCrossClusterSignalExecutionResponseAttributes(t *types.CrossClusterSignalExecutionResponseAttributes) *adminv1.CrossClusterSignalExecutionResponseAttributes
func FromCrossClusterStartChildExecutionRequestAttributes(t *types.CrossClusterStartChildExecutionRequestAttributes) *adminv1.CrossClusterStartChildExecutionRequestAttributes
func FromCrossClusterStartChildExecutionResponseAttributes(t *types.CrossClusterStartChildExecutionResponseAttributes) *adminv1.CrossClusterStartChildExecutionResponseAttributes
func FromCrossClusterTaskFailedCause(t *types.CrossClusterTaskFailedCause) adminv1.CrossClusterTaskFailedCause
func FromCrossClusterTaskInfo(t *types.CrossClusterTaskInfo) *adminv1.CrossClusterTaskInfo
func FromCrossClusterTaskRequest(t *types.CrossClusterTaskRequest) *adminv1.CrossClusterTaskRequest
func FromCrossClusterTaskRequestArray(t []*types.CrossClusterTaskRequest) *adminv1.CrossClusterTaskRequests
func FromCrossClusterTaskRequestMap(t map[int32][]*types.CrossClusterTaskRequest) map[int32]*adminv1.CrossClusterTaskRequests
func FromCrossClusterTaskResponse(t *types.CrossClusterTaskResponse) *adminv1.CrossClusterTaskResponse
func FromCrossClusterTaskResponseArray(t []*types.CrossClusterTaskResponse) []*adminv1.CrossClusterTaskResponse
func FromCrossClusterTaskType(t *types.CrossClusterTaskType) adminv1.CrossClusterTaskType
func FromDLQType(t *types.DLQType) adminv1.DLQType
func FromDataBlob(t *types.DataBlob) *apiv1.DataBlob
func FromDataBlobArray(t []*types.DataBlob) []*apiv1.DataBlob
func FromDecision(d *types.Decision) *apiv1.Decision
func FromDecisionArray(t []*types.Decision) []*apiv1.Decision
func FromDecisionTaskCompletedEventAttributes(t *types.DecisionTaskCompletedEventAttributes) *apiv1.DecisionTaskCompletedEventAttributes
func FromDecisionTaskFailedCause(t *types.DecisionTaskFailedCause) apiv1.DecisionTaskFailedCause
func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttributes) *apiv1.DecisionTaskFailedEventAttributes
func FromDecisionTaskScheduledEventAttributes(t *types.DecisionTaskScheduledEventAttributes) *apiv1.DecisionTaskScheduledEventAttributes
func FromDecisionTaskStartedEventAttributes(t *types.DecisionTaskStartedEventAttributes) *apiv1.DecisionTaskStartedEventAttributes
func FromDecisionTaskTimedOutCause(t *types.DecisionTaskTimedOutCause) apiv1.DecisionTaskTimedOutCause
func FromDecisionTaskTimedOutEventAttributes(t *types.DecisionTaskTimedOutEventAttributes) *apiv1.DecisionTaskTimedOutEventAttributes
func FromDeprecateDomainRequest(t *types.DeprecateDomainRequest) *apiv1.DeprecateDomainRequest
func FromDescribeDomainRequest(t *types.DescribeDomainRequest) *apiv1.DescribeDomainRequest
func FromDescribeDomainResponse(t *types.DescribeDomainResponse) *apiv1.DescribeDomainResponse
func FromDescribeDomainResponseArray(t []*types.DescribeDomainResponse) []*apiv1.Domain
func FromDescribeDomainResponseDomain(t *types.DescribeDomainResponse) *apiv1.Domain
func FromDescribeTaskListRequest(t *types.DescribeTaskListRequest) *apiv1.DescribeTaskListRequest
func FromDescribeTaskListResponse(t *types.DescribeTaskListResponse) *apiv1.DescribeTaskListResponse
func FromDescribeTaskListResponseMap(t map[string]*types.DescribeTaskListResponse) map[string]*apiv1.DescribeTaskListResponse
func FromDescribeWorkflowExecutionRequest(t *types.DescribeWorkflowExecutionRequest) *apiv1.DescribeWorkflowExecutionRequest
func FromDescribeWorkflowExecutionResponse(t *types.DescribeWorkflowExecutionResponse) *apiv1.DescribeWorkflowExecutionResponse
func FromDomainAsyncWorkflowConfiguraton(in *types.AsyncWorkflowConfiguration) *apiv1.AsyncWorkflowConfiguration
func FromDomainCacheInfo(t *types.DomainCacheInfo) *adminv1.DomainCacheInfo
func FromDomainOperation(t *types.DomainOperation) adminv1.DomainOperation
func FromDomainStatus(t *types.DomainStatus) apiv1.DomainStatus
func FromDomainTaskAttributes(t *types.DomainTaskAttributes) *adminv1.DomainTaskAttributes
func FromDynamicConfigEntry(t *types.DynamicConfigEntry) *adminv1.DynamicConfigEntry
func FromDynamicConfigEntryArray(t []*types.DynamicConfigEntry) []*adminv1.DynamicConfigEntry
func FromDynamicConfigFilter(t *types.DynamicConfigFilter) *adminv1.DynamicConfigFilter
func FromDynamicConfigFilterArray(t []*types.DynamicConfigFilter) []*adminv1.DynamicConfigFilter
func FromDynamicConfigValue(t *types.DynamicConfigValue) *adminv1.DynamicConfigValue
func FromDynamicConfigValueArray(t []*types.DynamicConfigValue) []*adminv1.DynamicConfigValue
func FromEncodingType(t *types.EncodingType) apiv1.EncodingType
func FromError(err error) error
func FromEventFilterType(t *types.HistoryEventFilterType) apiv1.EventFilterType
func FromEventIDVersionPair(id, version *int64) *adminv1.VersionHistoryItem
func FromExternalExecutionInfoFields(we *types.WorkflowExecution, initiatedID *int64) *apiv1.ExternalExecutionInfo
func FromExternalWorkflowExecutionCancelRequestedEventAttributes(t *types.ExternalWorkflowExecutionCancelRequestedEventAttributes) *apiv1.ExternalWorkflowExecutionCancelRequestedEventAttributes
func FromExternalWorkflowExecutionSignaledEventAttributes(t *types.ExternalWorkflowExecutionSignaledEventAttributes) *apiv1.ExternalWorkflowExecutionSignaledEventAttributes
func FromFailWorkflowExecutionDecisionAttributes(t *types.FailWorkflowExecutionDecisionAttributes) *apiv1.FailWorkflowExecutionDecisionAttributes
func FromFailoverInfo(t *types.FailoverInfo) *apiv1.FailoverInfo
func FromFailoverMarkerAttributes(t *types.FailoverMarkerAttributes) *adminv1.FailoverMarkerAttributes
func FromFailoverMarkerToken(t *types.FailoverMarkerToken) *adminv1.FailoverMarkerToken
func FromFailoverMarkerTokenArray(t []*types.FailoverMarkerToken) []*adminv1.FailoverMarkerToken
func FromFailure(reason *string, details []byte) *apiv1.Failure
func FromGetClusterInfoResponse(t *types.ClusterInfo) *apiv1.GetClusterInfoResponse
func FromGetSearchAttributesResponse(t *types.GetSearchAttributesResponse) *apiv1.GetSearchAttributesResponse
func FromGetTaskFailedCause(t *types.GetTaskFailedCause) adminv1.GetTaskFailedCause
func FromGetTaskFailedCauseMap(t map[int32]types.GetTaskFailedCause) map[int32]adminv1.GetTaskFailedCause
func FromGetTaskListsByDomainRequest(t *types.GetTaskListsByDomainRequest) *apiv1.GetTaskListsByDomainRequest
func FromGetTaskListsByDomainResponse(t *types.GetTaskListsByDomainResponse) *apiv1.GetTaskListsByDomainResponse
func FromGetWorkflowExecutionHistoryRequest(t *types.GetWorkflowExecutionHistoryRequest) *apiv1.GetWorkflowExecutionHistoryRequest
func FromGetWorkflowExecutionHistoryResponse(t *types.GetWorkflowExecutionHistoryResponse) *apiv1.GetWorkflowExecutionHistoryResponse
func FromHeader(t *types.Header) *apiv1.Header
func FromHealthResponse(t *types.HealthStatus) *apiv1.HealthResponse
func FromHistory(t *types.History) *apiv1.History
func FromHistoryCloseShardRequest(t *types.CloseShardRequest) *historyv1.CloseShardRequest
func FromHistoryCountDLQMessagesRequest(t *types.CountDLQMessagesRequest) *historyv1.CountDLQMessagesRequest
func FromHistoryCountDLQMessagesResponse(t *types.HistoryCountDLQMessagesResponse) *historyv1.CountDLQMessagesResponse
func FromHistoryDLQCountEntryMap(t map[types.HistoryDLQCountKey]int64) []*adminv1.HistoryDLQCountEntry
func FromHistoryDescribeHistoryHostRequest(t *types.DescribeHistoryHostRequest) *historyv1.DescribeHistoryHostRequest
func FromHistoryDescribeHistoryHostResponse(t *types.DescribeHistoryHostResponse) *historyv1.DescribeHistoryHostResponse
func FromHistoryDescribeMutableStateRequest(t *types.DescribeMutableStateRequest) *historyv1.DescribeMutableStateRequest
func FromHistoryDescribeMutableStateResponse(t *types.DescribeMutableStateResponse) *historyv1.DescribeMutableStateResponse
func FromHistoryDescribeQueueRequest(t *types.DescribeQueueRequest) *historyv1.DescribeQueueRequest
func FromHistoryDescribeQueueResponse(t *types.DescribeQueueResponse) *historyv1.DescribeQueueResponse
func FromHistoryDescribeWorkflowExecutionRequest(t *types.HistoryDescribeWorkflowExecutionRequest) *historyv1.DescribeWorkflowExecutionRequest
func FromHistoryDescribeWorkflowExecutionResponse(t *types.DescribeWorkflowExecutionResponse) *historyv1.DescribeWorkflowExecutionResponse
func FromHistoryEvent(e *types.HistoryEvent) *apiv1.HistoryEvent
func FromHistoryEventArray(t []*types.HistoryEvent) []*apiv1.HistoryEvent
func FromHistoryGetCrossClusterTasksRequest(t *types.GetCrossClusterTasksRequest) *historyv1.GetCrossClusterTasksRequest
func FromHistoryGetCrossClusterTasksResponse(t *types.GetCrossClusterTasksResponse) *historyv1.GetCrossClusterTasksResponse
func FromHistoryGetDLQReplicationMessagesRequest(t *types.GetDLQReplicationMessagesRequest) *historyv1.GetDLQReplicationMessagesRequest
func FromHistoryGetDLQReplicationMessagesResponse(t *types.GetDLQReplicationMessagesResponse) *historyv1.GetDLQReplicationMessagesResponse
func FromHistoryGetFailoverInfoRequest(t *types.GetFailoverInfoRequest) *historyv1.GetFailoverInfoRequest
func FromHistoryGetFailoverInfoResponse(t *types.GetFailoverInfoResponse) *historyv1.GetFailoverInfoResponse
func FromHistoryGetMutableStateRequest(t *types.GetMutableStateRequest) *historyv1.GetMutableStateRequest
func FromHistoryGetMutableStateResponse(t *types.GetMutableStateResponse) *historyv1.GetMutableStateResponse
func FromHistoryGetReplicationMessagesRequest(t *types.GetReplicationMessagesRequest) *historyv1.GetReplicationMessagesRequest
func FromHistoryGetReplicationMessagesResponse(t *types.GetReplicationMessagesResponse) *historyv1.GetReplicationMessagesResponse
func FromHistoryMergeDLQMessagesRequest(t *types.MergeDLQMessagesRequest) *historyv1.MergeDLQMessagesRequest
func FromHistoryMergeDLQMessagesResponse(t *types.MergeDLQMessagesResponse) *historyv1.MergeDLQMessagesResponse
func FromHistoryNotifyFailoverMarkersRequest(t *types.NotifyFailoverMarkersRequest) *historyv1.NotifyFailoverMarkersRequest
func FromHistoryPollMutableStateRequest(t *types.PollMutableStateRequest) *historyv1.PollMutableStateRequest
func FromHistoryPollMutableStateResponse(t *types.PollMutableStateResponse) *historyv1.PollMutableStateResponse
func FromHistoryPurgeDLQMessagesRequest(t *types.PurgeDLQMessagesRequest) *historyv1.PurgeDLQMessagesRequest
func FromHistoryQueryWorkflowRequest(t *types.HistoryQueryWorkflowRequest) *historyv1.QueryWorkflowRequest
func FromHistoryQueryWorkflowResponse(t *types.HistoryQueryWorkflowResponse) *historyv1.QueryWorkflowResponse
func FromHistoryReadDLQMessagesRequest(t *types.ReadDLQMessagesRequest) *historyv1.ReadDLQMessagesRequest
func FromHistoryReadDLQMessagesResponse(t *types.ReadDLQMessagesResponse) *historyv1.ReadDLQMessagesResponse
func FromHistoryReapplyEventsRequest(t *types.HistoryReapplyEventsRequest) *historyv1.ReapplyEventsRequest
func FromHistoryRecordActivityTaskHeartbeatRequest(t *types.HistoryRecordActivityTaskHeartbeatRequest) *historyv1.RecordActivityTaskHeartbeatRequest
func FromHistoryRecordActivityTaskHeartbeatResponse(t *types.RecordActivityTaskHeartbeatResponse) *historyv1.RecordActivityTaskHeartbeatResponse
func FromHistoryRecordActivityTaskStartedRequest(t *types.RecordActivityTaskStartedRequest) *historyv1.RecordActivityTaskStartedRequest
func FromHistoryRecordActivityTaskStartedResponse(t *types.RecordActivityTaskStartedResponse) *historyv1.RecordActivityTaskStartedResponse
func FromHistoryRecordChildExecutionCompletedRequest(t *types.RecordChildExecutionCompletedRequest) *historyv1.RecordChildExecutionCompletedRequest
func FromHistoryRecordDecisionTaskStartedRequest(t *types.RecordDecisionTaskStartedRequest) *historyv1.RecordDecisionTaskStartedRequest
func FromHistoryRecordDecisionTaskStartedResponse(t *types.RecordDecisionTaskStartedResponse) *historyv1.RecordDecisionTaskStartedResponse
func FromHistoryRefreshWorkflowTasksRequest(t *types.HistoryRefreshWorkflowTasksRequest) *historyv1.RefreshWorkflowTasksRequest
func FromHistoryRemoveSignalMutableStateRequest(t *types.RemoveSignalMutableStateRequest) *historyv1.RemoveSignalMutableStateRequest
func FromHistoryRemoveTaskRequest(t *types.RemoveTaskRequest) *historyv1.RemoveTaskRequest
func FromHistoryReplicateEventsV2Request(t *types.ReplicateEventsV2Request) *historyv1.ReplicateEventsV2Request
func FromHistoryRequestCancelWorkflowExecutionRequest(t *types.HistoryRequestCancelWorkflowExecutionRequest) *historyv1.RequestCancelWorkflowExecutionRequest
func FromHistoryResetQueueRequest(t *types.ResetQueueRequest) *historyv1.ResetQueueRequest
func FromHistoryResetStickyTaskListRequest(t *types.HistoryResetStickyTaskListRequest) *historyv1.ResetStickyTaskListRequest
func FromHistoryResetStickyTaskListResponse(t *types.HistoryResetStickyTaskListResponse) *historyv1.ResetStickyTaskListResponse
func FromHistoryResetWorkflowExecutionRequest(t *types.HistoryResetWorkflowExecutionRequest) *historyv1.ResetWorkflowExecutionRequest
func FromHistoryResetWorkflowExecutionResponse(t *types.ResetWorkflowExecutionResponse) *historyv1.ResetWorkflowExecutionResponse
func FromHistoryRespondActivityTaskCanceledRequest(t *types.HistoryRespondActivityTaskCanceledRequest) *historyv1.RespondActivityTaskCanceledRequest
func FromHistoryRespondActivityTaskCompletedRequest(t *types.HistoryRespondActivityTaskCompletedRequest) *historyv1.RespondActivityTaskCompletedRequest
func FromHistoryRespondActivityTaskFailedRequest(t *types.HistoryRespondActivityTaskFailedRequest) *historyv1.RespondActivityTaskFailedRequest
func FromHistoryRespondCrossClusterTasksCompletedRequest(t *types.RespondCrossClusterTasksCompletedRequest) *historyv1.RespondCrossClusterTasksCompletedRequest
func FromHistoryRespondCrossClusterTasksCompletedResponse(t *types.RespondCrossClusterTasksCompletedResponse) *historyv1.RespondCrossClusterTasksCompletedResponse
func FromHistoryRespondDecisionTaskCompletedRequest(t *types.HistoryRespondDecisionTaskCompletedRequest) *historyv1.RespondDecisionTaskCompletedRequest
func FromHistoryRespondDecisionTaskCompletedResponse(t *types.HistoryRespondDecisionTaskCompletedResponse) *historyv1.RespondDecisionTaskCompletedResponse
func FromHistoryRespondDecisionTaskFailedRequest(t *types.HistoryRespondDecisionTaskFailedRequest) *historyv1.RespondDecisionTaskFailedRequest
func FromHistoryScheduleDecisionTaskRequest(t *types.ScheduleDecisionTaskRequest) *historyv1.ScheduleDecisionTaskRequest
func FromHistorySignalWithStartWorkflowExecutionRequest(t *types.HistorySignalWithStartWorkflowExecutionRequest) *historyv1.SignalWithStartWorkflowExecutionRequest
func FromHistorySignalWithStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *historyv1.SignalWithStartWorkflowExecutionResponse
func FromHistorySignalWorkflowExecutionRequest(t *types.HistorySignalWorkflowExecutionRequest) *historyv1.SignalWorkflowExecutionRequest
func FromHistoryStartWorkflowExecutionRequest(t *types.HistoryStartWorkflowExecutionRequest) *historyv1.StartWorkflowExecutionRequest
func FromHistoryStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *historyv1.StartWorkflowExecutionResponse
func FromHistorySyncActivityRequest(t *types.SyncActivityRequest) *historyv1.SyncActivityRequest
func FromHistorySyncShardStatusRequest(t *types.SyncShardStatusRequest) *historyv1.SyncShardStatusRequest
func FromHistoryTaskV2Attributes(t *types.HistoryTaskV2Attributes) *adminv1.HistoryTaskV2Attributes
func FromHistoryTerminateWorkflowExecutionRequest(t *types.HistoryTerminateWorkflowExecutionRequest) *historyv1.TerminateWorkflowExecutionRequest
func FromHostInfo(t *types.HostInfo) *adminv1.HostInfo
func FromHostInfoArray(t []*types.HostInfo) []*adminv1.HostInfo
func FromIndexedValueType(t types.IndexedValueType) apiv1.IndexedValueType
func FromIndexedValueTypeMap(t map[string]types.IndexedValueType) map[string]apiv1.IndexedValueType
func FromIsolationGroupConfig(in *types.IsolationGroupConfiguration) *apiv1.IsolationGroupConfiguration
func FromListArchivedWorkflowExecutionsRequest(t *types.ListArchivedWorkflowExecutionsRequest) *apiv1.ListArchivedWorkflowExecutionsRequest
func FromListArchivedWorkflowExecutionsResponse(t *types.ListArchivedWorkflowExecutionsResponse) *apiv1.ListArchivedWorkflowExecutionsResponse
func FromListClosedWorkflowExecutionsRequest(r *types.ListClosedWorkflowExecutionsRequest) *apiv1.ListClosedWorkflowExecutionsRequest
func FromListClosedWorkflowExecutionsResponse(t *types.ListClosedWorkflowExecutionsResponse) *apiv1.ListClosedWorkflowExecutionsResponse
func FromListDomainsRequest(t *types.ListDomainsRequest) *apiv1.ListDomainsRequest
func FromListDomainsResponse(t *types.ListDomainsResponse) *apiv1.ListDomainsResponse
func FromListOpenWorkflowExecutionsRequest(r *types.ListOpenWorkflowExecutionsRequest) *apiv1.ListOpenWorkflowExecutionsRequest
func FromListOpenWorkflowExecutionsResponse(t *types.ListOpenWorkflowExecutionsResponse) *apiv1.ListOpenWorkflowExecutionsResponse
func FromListTaskListPartitionsRequest(t *types.ListTaskListPartitionsRequest) *apiv1.ListTaskListPartitionsRequest
func FromListTaskListPartitionsResponse(t *types.ListTaskListPartitionsResponse) *apiv1.ListTaskListPartitionsResponse
func FromListWorkflowExecutionsRequest(t *types.ListWorkflowExecutionsRequest) *apiv1.ListWorkflowExecutionsRequest
func FromListWorkflowExecutionsResponse(t *types.ListWorkflowExecutionsResponse) *apiv1.ListWorkflowExecutionsResponse
func FromMarkerRecordedEventAttributes(t *types.MarkerRecordedEventAttributes) *apiv1.MarkerRecordedEventAttributes
func FromMatchingAddActivityTaskRequest(t *types.AddActivityTaskRequest) *matchingv1.AddActivityTaskRequest
func FromMatchingAddDecisionTaskRequest(t *types.AddDecisionTaskRequest) *matchingv1.AddDecisionTaskRequest
func FromMatchingCancelOutstandingPollRequest(t *types.CancelOutstandingPollRequest) *matchingv1.CancelOutstandingPollRequest
func FromMatchingDescribeTaskListRequest(t *types.MatchingDescribeTaskListRequest) *matchingv1.DescribeTaskListRequest
func FromMatchingDescribeTaskListResponse(t *types.DescribeTaskListResponse) *matchingv1.DescribeTaskListResponse
func FromMatchingDescribeTaskListResponseMap(t map[string]*types.DescribeTaskListResponse) map[string]*matchingv1.DescribeTaskListResponse
func FromMatchingGetTaskListsByDomainRequest(t *types.GetTaskListsByDomainRequest) *matchingv1.GetTaskListsByDomainRequest
func FromMatchingGetTaskListsByDomainResponse(t *types.GetTaskListsByDomainResponse) *matchingv1.GetTaskListsByDomainResponse
func FromMatchingListTaskListPartitionsRequest(t *types.MatchingListTaskListPartitionsRequest) *matchingv1.ListTaskListPartitionsRequest
func FromMatchingListTaskListPartitionsResponse(t *types.ListTaskListPartitionsResponse) *matchingv1.ListTaskListPartitionsResponse
func FromMatchingPollForActivityTaskRequest(t *types.MatchingPollForActivityTaskRequest) *matchingv1.PollForActivityTaskRequest
func FromMatchingPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *matchingv1.PollForActivityTaskResponse
func FromMatchingPollForDecisionTaskRequest(t *types.MatchingPollForDecisionTaskRequest) *matchingv1.PollForDecisionTaskRequest
func FromMatchingPollForDecisionTaskResponse(t *types.MatchingPollForDecisionTaskResponse) *matchingv1.PollForDecisionTaskResponse
func FromMatchingQueryWorkflowRequest(t *types.MatchingQueryWorkflowRequest) *matchingv1.QueryWorkflowRequest
func FromMatchingQueryWorkflowResponse(t *types.QueryWorkflowResponse) *matchingv1.QueryWorkflowResponse
func FromMatchingRespondQueryTaskCompletedRequest(t *types.MatchingRespondQueryTaskCompletedRequest) *matchingv1.RespondQueryTaskCompletedRequest
func FromMembershipInfo(t *types.MembershipInfo) *adminv1.MembershipInfo
func FromMemo(t *types.Memo) *apiv1.Memo
func FromParentClosePolicy(t *types.ParentClosePolicy) apiv1.ParentClosePolicy
func FromParentExecutionInfo(t *types.ParentExecutionInfo) *apiv1.ParentExecutionInfo
func FromParentExecutionInfoFields(domainID, domainName *string, we *types.WorkflowExecution, initiatedID *int64) *apiv1.ParentExecutionInfo
func FromPayload(data []byte) *apiv1.Payload
func FromPayloadMap(t map[string][]byte) map[string]*apiv1.Payload
func FromPendingActivityInfo(t *types.PendingActivityInfo) *apiv1.PendingActivityInfo
func FromPendingActivityInfoArray(t []*types.PendingActivityInfo) []*apiv1.PendingActivityInfo
func FromPendingActivityState(t *types.PendingActivityState) apiv1.PendingActivityState
func FromPendingChildExecutionInfo(t *types.PendingChildExecutionInfo) *apiv1.PendingChildExecutionInfo
func FromPendingChildExecutionInfoArray(t []*types.PendingChildExecutionInfo) []*apiv1.PendingChildExecutionInfo
func FromPendingDecisionInfo(t *types.PendingDecisionInfo) *apiv1.PendingDecisionInfo
func FromPendingDecisionState(t *types.PendingDecisionState) apiv1.PendingDecisionState
func FromPersistenceFeature(t *types.PersistenceFeature) *adminv1.PersistenceFeature
func FromPersistenceFeatures(t []*types.PersistenceFeature) []*adminv1.PersistenceFeature
func FromPersistenceInfo(t *types.PersistenceInfo) *adminv1.PersistenceInfo
func FromPersistenceInfoMap(t map[string]*types.PersistenceInfo) map[string]*adminv1.PersistenceInfo
func FromPersistenceSetting(t *types.PersistenceSetting) *adminv1.PersistenceSetting
func FromPersistenceSettings(t []*types.PersistenceSetting) []*adminv1.PersistenceSetting
func FromPollForActivityTaskRequest(t *types.PollForActivityTaskRequest) *apiv1.PollForActivityTaskRequest
func FromPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *apiv1.PollForActivityTaskResponse
func FromPollForDecisionTaskRequest(t *types.PollForDecisionTaskRequest) *apiv1.PollForDecisionTaskRequest
func FromPollForDecisionTaskResponse(t *types.PollForDecisionTaskResponse) *apiv1.PollForDecisionTaskResponse
func FromPollerInfo(t *types.PollerInfo) *apiv1.PollerInfo
func FromPollerInfoArray(t []*types.PollerInfo) []*apiv1.PollerInfo
func FromQueryConsistencyLevel(t *types.QueryConsistencyLevel) apiv1.QueryConsistencyLevel
func FromQueryRejectCondition(t *types.QueryRejectCondition) apiv1.QueryRejectCondition
func FromQueryRejected(t *types.QueryRejected) *apiv1.QueryRejected
func FromQueryResultType(t *types.QueryResultType) apiv1.QueryResultType
func FromQueryTaskCompletedType(t *types.QueryTaskCompletedType) apiv1.QueryResultType
func FromQueryWorkflowRequest(t *types.QueryWorkflowRequest) *apiv1.QueryWorkflowRequest
func FromQueryWorkflowResponse(t *types.QueryWorkflowResponse) *apiv1.QueryWorkflowResponse
func FromRecordActivityTaskHeartbeatByIDRequest(t *types.RecordActivityTaskHeartbeatByIDRequest) *apiv1.RecordActivityTaskHeartbeatByIDRequest
func FromRecordActivityTaskHeartbeatByIDResponse(t *types.RecordActivityTaskHeartbeatResponse) *apiv1.RecordActivityTaskHeartbeatByIDResponse
func FromRecordActivityTaskHeartbeatRequest(t *types.RecordActivityTaskHeartbeatRequest) *apiv1.RecordActivityTaskHeartbeatRequest
func FromRecordActivityTaskHeartbeatResponse(t *types.RecordActivityTaskHeartbeatResponse) *apiv1.RecordActivityTaskHeartbeatResponse
func FromRecordMarkerDecisionAttributes(t *types.RecordMarkerDecisionAttributes) *apiv1.RecordMarkerDecisionAttributes
func FromRefreshWorkflowTasksRequest(t *types.RefreshWorkflowTasksRequest) *apiv1.RefreshWorkflowTasksRequest
func FromRegisterDomainRequest(t *types.RegisterDomainRequest) *apiv1.RegisterDomainRequest
func FromReplicationMessages(t *types.ReplicationMessages) *adminv1.ReplicationMessages
func FromReplicationMessagesMap(t map[int32]*types.ReplicationMessages) map[int32]*adminv1.ReplicationMessages
func FromReplicationTask(t *types.ReplicationTask) *adminv1.ReplicationTask
func FromReplicationTaskArray(t []*types.ReplicationTask) []*adminv1.ReplicationTask
func FromReplicationTaskInfo(t *types.ReplicationTaskInfo) *adminv1.ReplicationTaskInfo
func FromReplicationTaskInfoArray(t []*types.ReplicationTaskInfo) []*adminv1.ReplicationTaskInfo
func FromReplicationTaskType(t *types.ReplicationTaskType) adminv1.ReplicationTaskType
func FromReplicationToken(t *types.ReplicationToken) *adminv1.ReplicationToken
func FromReplicationTokenArray(t []*types.ReplicationToken) []*adminv1.ReplicationToken
func FromRequestCancelActivityTaskDecisionAttributes(t *types.RequestCancelActivityTaskDecisionAttributes) *apiv1.RequestCancelActivityTaskDecisionAttributes
func FromRequestCancelActivityTaskFailedEventAttributes(t *types.RequestCancelActivityTaskFailedEventAttributes) *apiv1.RequestCancelActivityTaskFailedEventAttributes
func FromRequestCancelExternalWorkflowExecutionDecisionAttributes(t *types.RequestCancelExternalWorkflowExecutionDecisionAttributes) *apiv1.RequestCancelExternalWorkflowExecutionDecisionAttributes
func FromRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *apiv1.RequestCancelExternalWorkflowExecutionFailedEventAttributes
func FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *apiv1.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
func FromRequestCancelWorkflowExecutionRequest(t *types.RequestCancelWorkflowExecutionRequest) *apiv1.RequestCancelWorkflowExecutionRequest
func FromResetPointInfo(t *types.ResetPointInfo) *apiv1.ResetPointInfo
func FromResetPointInfoArray(t []*types.ResetPointInfo) []*apiv1.ResetPointInfo
func FromResetPoints(t *types.ResetPoints) *apiv1.ResetPoints
func FromResetStickyTaskListRequest(t *types.ResetStickyTaskListRequest) *apiv1.ResetStickyTaskListRequest
func FromResetStickyTaskListResponse(t *types.ResetStickyTaskListResponse) *apiv1.ResetStickyTaskListResponse
func FromResetWorkflowExecutionRequest(t *types.ResetWorkflowExecutionRequest) *apiv1.ResetWorkflowExecutionRequest
func FromResetWorkflowExecutionResponse(t *types.ResetWorkflowExecutionResponse) *apiv1.ResetWorkflowExecutionResponse
func FromRespondActivityTaskCanceledByIDRequest(t *types.RespondActivityTaskCanceledByIDRequest) *apiv1.RespondActivityTaskCanceledByIDRequest
func FromRespondActivityTaskCanceledRequest(t *types.RespondActivityTaskCanceledRequest) *apiv1.RespondActivityTaskCanceledRequest
func FromRespondActivityTaskCompletedByIDRequest(t *types.RespondActivityTaskCompletedByIDRequest) *apiv1.RespondActivityTaskCompletedByIDRequest
func FromRespondActivityTaskCompletedRequest(t *types.RespondActivityTaskCompletedRequest) *apiv1.RespondActivityTaskCompletedRequest
func FromRespondActivityTaskFailedByIDRequest(t *types.RespondActivityTaskFailedByIDRequest) *apiv1.RespondActivityTaskFailedByIDRequest
func FromRespondActivityTaskFailedRequest(t *types.RespondActivityTaskFailedRequest) *apiv1.RespondActivityTaskFailedRequest
func FromRespondDecisionTaskCompletedRequest(t *types.RespondDecisionTaskCompletedRequest) *apiv1.RespondDecisionTaskCompletedRequest
func FromRespondDecisionTaskCompletedResponse(t *types.RespondDecisionTaskCompletedResponse) *apiv1.RespondDecisionTaskCompletedResponse
func FromRespondDecisionTaskFailedRequest(t *types.RespondDecisionTaskFailedRequest) *apiv1.RespondDecisionTaskFailedRequest
func FromRespondQueryTaskCompletedRequest(t *types.RespondQueryTaskCompletedRequest) *apiv1.RespondQueryTaskCompletedRequest
func FromRestartWorkflowExecutionRequest(t *types.RestartWorkflowExecutionRequest) *apiv1.RestartWorkflowExecutionRequest
func FromRestartWorkflowExecutionResponse(t *types.RestartWorkflowExecutionResponse) *apiv1.RestartWorkflowExecutionResponse
func FromRetryPolicy(t *types.RetryPolicy) *apiv1.RetryPolicy
func FromRingInfo(t *types.RingInfo) *adminv1.RingInfo
func FromRingInfoArray(t []*types.RingInfo) []*adminv1.RingInfo
func FromScanWorkflowExecutionsRequest(t *types.ListWorkflowExecutionsRequest) *apiv1.ScanWorkflowExecutionsRequest
func FromScanWorkflowExecutionsResponse(t *types.ListWorkflowExecutionsResponse) *apiv1.ScanWorkflowExecutionsResponse
func FromScheduleActivityTaskDecisionAttributes(t *types.ScheduleActivityTaskDecisionAttributes) *apiv1.ScheduleActivityTaskDecisionAttributes
func FromSearchAttributes(t *types.SearchAttributes) *apiv1.SearchAttributes
func FromSignalExternalWorkflowExecutionDecisionAttributes(t *types.SignalExternalWorkflowExecutionDecisionAttributes) *apiv1.SignalExternalWorkflowExecutionDecisionAttributes
func FromSignalExternalWorkflowExecutionFailedCause(t *types.SignalExternalWorkflowExecutionFailedCause) apiv1.SignalExternalWorkflowExecutionFailedCause
func FromSignalExternalWorkflowExecutionFailedEventAttributes(t *types.SignalExternalWorkflowExecutionFailedEventAttributes) *apiv1.SignalExternalWorkflowExecutionFailedEventAttributes
func FromSignalExternalWorkflowExecutionInitiatedEventAttributes(t *types.SignalExternalWorkflowExecutionInitiatedEventAttributes) *apiv1.SignalExternalWorkflowExecutionInitiatedEventAttributes
func FromSignalWithStartWorkflowExecutionRequest(t *types.SignalWithStartWorkflowExecutionRequest) *apiv1.SignalWithStartWorkflowExecutionRequest
func FromSignalWithStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *apiv1.SignalWithStartWorkflowExecutionResponse
func FromSignalWorkflowExecutionRequest(t *types.SignalWorkflowExecutionRequest) *apiv1.SignalWorkflowExecutionRequest
func FromStartChildWorkflowExecutionDecisionAttributes(t *types.StartChildWorkflowExecutionDecisionAttributes) *apiv1.StartChildWorkflowExecutionDecisionAttributes
func FromStartChildWorkflowExecutionFailedEventAttributes(t *types.StartChildWorkflowExecutionFailedEventAttributes) *apiv1.StartChildWorkflowExecutionFailedEventAttributes
func FromStartChildWorkflowExecutionInitiatedEventAttributes(t *types.StartChildWorkflowExecutionInitiatedEventAttributes) *apiv1.StartChildWorkflowExecutionInitiatedEventAttributes
func FromStartTimeFilter(t *types.StartTimeFilter) *apiv1.StartTimeFilter
func FromStartTimerDecisionAttributes(t *types.StartTimerDecisionAttributes) *apiv1.StartTimerDecisionAttributes
func FromStartWorkflowExecutionAsyncRequest(t *types.StartWorkflowExecutionAsyncRequest) *apiv1.StartWorkflowExecutionAsyncRequest
func FromStartWorkflowExecutionAsyncResponse(t *types.StartWorkflowExecutionAsyncResponse) *apiv1.StartWorkflowExecutionAsyncResponse
func FromStartWorkflowExecutionRequest(t *types.StartWorkflowExecutionRequest) *apiv1.StartWorkflowExecutionRequest
func FromStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *apiv1.StartWorkflowExecutionResponse
func FromStatusFilter(t *types.WorkflowExecutionCloseStatus) *apiv1.StatusFilter
func FromStickyExecutionAttributes(t *types.StickyExecutionAttributes) *apiv1.StickyExecutionAttributes
func FromSupportedClientVersions(t *types.SupportedClientVersions) *apiv1.SupportedClientVersions
func FromSyncActivityTaskAttributes(t *types.SyncActivityTaskAttributes) *adminv1.SyncActivityTaskAttributes
func FromSyncShardStatus(t *types.SyncShardStatus) *adminv1.SyncShardStatus
func FromSyncShardStatusTaskAttributes(t *types.SyncShardStatusTaskAttributes) *adminv1.SyncShardStatusTaskAttributes
func FromTaskIDBlock(t *types.TaskIDBlock) *apiv1.TaskIDBlock
func FromTaskList(t *types.TaskList) *apiv1.TaskList
func FromTaskListKind(t *types.TaskListKind) apiv1.TaskListKind
func FromTaskListMetadata(t *types.TaskListMetadata) *apiv1.TaskListMetadata
func FromTaskListPartitionMetadata(t *types.TaskListPartitionMetadata) *apiv1.TaskListPartitionMetadata
func FromTaskListPartitionMetadataArray(t []*types.TaskListPartitionMetadata) []*apiv1.TaskListPartitionMetadata
func FromTaskListStatus(t *types.TaskListStatus) *apiv1.TaskListStatus
func FromTaskListType(t *types.TaskListType) apiv1.TaskListType
func FromTaskSource(t *types.TaskSource) sharedv1.TaskSource
func FromTaskType(t *int32) adminv1.TaskType
func FromTerminateWorkflowExecutionRequest(t *types.TerminateWorkflowExecutionRequest) *apiv1.TerminateWorkflowExecutionRequest
func FromTimeoutType(t *types.TimeoutType) apiv1.TimeoutType
func FromTimerCanceledEventAttributes(t *types.TimerCanceledEventAttributes) *apiv1.TimerCanceledEventAttributes
func FromTimerFiredEventAttributes(t *types.TimerFiredEventAttributes) *apiv1.TimerFiredEventAttributes
func FromTimerStartedEventAttributes(t *types.TimerStartedEventAttributes) *apiv1.TimerStartedEventAttributes
func FromTransientDecisionInfo(t *types.TransientDecisionInfo) *sharedv1.TransientDecisionInfo
func FromUpdateDomainRequest(t *types.UpdateDomainRequest) *apiv1.UpdateDomainRequest
func FromUpdateDomainResponse(t *types.UpdateDomainResponse) *apiv1.UpdateDomainResponse
func FromUpsertWorkflowSearchAttributesDecisionAttributes(t *types.UpsertWorkflowSearchAttributesDecisionAttributes) *apiv1.UpsertWorkflowSearchAttributesDecisionAttributes
func FromUpsertWorkflowSearchAttributesEventAttributes(t *types.UpsertWorkflowSearchAttributesEventAttributes) *apiv1.UpsertWorkflowSearchAttributesEventAttributes
func FromVersionHistories(t *types.VersionHistories) *sharedv1.VersionHistories
func FromVersionHistory(t *types.VersionHistory) *adminv1.VersionHistory
func FromVersionHistoryArray(t []*types.VersionHistory) []*adminv1.VersionHistory
func FromVersionHistoryItem(t *types.VersionHistoryItem) *adminv1.VersionHistoryItem
func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*adminv1.VersionHistoryItem
func FromWorkerVersionInfo(t *types.WorkerVersionInfo) *apiv1.WorkerVersionInfo
func FromWorkflowExecution(t *types.WorkflowExecution) *apiv1.WorkflowExecution
func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecutionCancelRequestedEventAttributes) *apiv1.WorkflowExecutionCancelRequestedEventAttributes
func FromWorkflowExecutionCanceledEventAttributes(t *types.WorkflowExecutionCanceledEventAttributes) *apiv1.WorkflowExecutionCanceledEventAttributes
func FromWorkflowExecutionCloseStatus(t *types.WorkflowExecutionCloseStatus) apiv1.WorkflowExecutionCloseStatus
func FromWorkflowExecutionCompletedEventAttributes(t *types.WorkflowExecutionCompletedEventAttributes) *apiv1.WorkflowExecutionCompletedEventAttributes
func FromWorkflowExecutionConfiguration(t *types.WorkflowExecutionConfiguration) *apiv1.WorkflowExecutionConfiguration
func FromWorkflowExecutionContinuedAsNewEventAttributes(t *types.WorkflowExecutionContinuedAsNewEventAttributes) *apiv1.WorkflowExecutionContinuedAsNewEventAttributes
func FromWorkflowExecutionFailedEventAttributes(t *types.WorkflowExecutionFailedEventAttributes) *apiv1.WorkflowExecutionFailedEventAttributes
func FromWorkflowExecutionFilter(t *types.WorkflowExecutionFilter) *apiv1.WorkflowExecutionFilter
func FromWorkflowExecutionInfo(t *types.WorkflowExecutionInfo) *apiv1.WorkflowExecutionInfo
func FromWorkflowExecutionInfoArray(t []*types.WorkflowExecutionInfo) []*apiv1.WorkflowExecutionInfo
func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSignaledEventAttributes) *apiv1.WorkflowExecutionSignaledEventAttributes
func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStartedEventAttributes) *apiv1.WorkflowExecutionStartedEventAttributes
func FromWorkflowExecutionTerminatedEventAttributes(t *types.WorkflowExecutionTerminatedEventAttributes) *apiv1.WorkflowExecutionTerminatedEventAttributes
func FromWorkflowExecutionTimedOutEventAttributes(t *types.WorkflowExecutionTimedOutEventAttributes) *apiv1.WorkflowExecutionTimedOutEventAttributes
func FromWorkflowIDReusePolicy(t *types.WorkflowIDReusePolicy) apiv1.WorkflowIdReusePolicy
func FromWorkflowQuery(t *types.WorkflowQuery) *apiv1.WorkflowQuery
func FromWorkflowQueryMap(t map[string]*types.WorkflowQuery) map[string]*apiv1.WorkflowQuery
func FromWorkflowQueryResult(t *types.WorkflowQueryResult) *apiv1.WorkflowQueryResult
func FromWorkflowQueryResultMap(t map[string]*types.WorkflowQueryResult) map[string]*apiv1.WorkflowQueryResult
func FromWorkflowRunPair(workflowID, runID string) *apiv1.WorkflowExecution
func FromWorkflowState(t *int32) sharedv1.WorkflowState
func FromWorkflowType(t *types.WorkflowType) *apiv1.WorkflowType
func FromWorkflowTypeFilter(t *types.WorkflowTypeFilter) *apiv1.WorkflowTypeFilter
func ToActivityLocalDispatchInfo(t *apiv1.ActivityLocalDispatchInfo) *types.ActivityLocalDispatchInfo
func ToActivityLocalDispatchInfoMap(t map[string]*apiv1.ActivityLocalDispatchInfo) map[string]*types.ActivityLocalDispatchInfo
func ToActivityTaskCancelRequestedEventAttributes(t *apiv1.ActivityTaskCancelRequestedEventAttributes) *types.ActivityTaskCancelRequestedEventAttributes
func ToActivityTaskCanceledEventAttributes(t *apiv1.ActivityTaskCanceledEventAttributes) *types.ActivityTaskCanceledEventAttributes
func ToActivityTaskCompletedEventAttributes(t *apiv1.ActivityTaskCompletedEventAttributes) *types.ActivityTaskCompletedEventAttributes
func ToActivityTaskDispatchInfo(t *matchingv1.ActivityTaskDispatchInfo) *types.ActivityTaskDispatchInfo
func ToActivityTaskFailedEventAttributes(t *apiv1.ActivityTaskFailedEventAttributes) *types.ActivityTaskFailedEventAttributes
func ToActivityTaskScheduledEventAttributes(t *apiv1.ActivityTaskScheduledEventAttributes) *types.ActivityTaskScheduledEventAttributes
func ToActivityTaskStartedEventAttributes(t *apiv1.ActivityTaskStartedEventAttributes) *types.ActivityTaskStartedEventAttributes
func ToActivityTaskTimedOutEventAttributes(t *apiv1.ActivityTaskTimedOutEventAttributes) *types.ActivityTaskTimedOutEventAttributes
func ToActivityType(t *apiv1.ActivityType) *types.ActivityType
func ToAdminAddSearchAttributeRequest(t *adminv1.AddSearchAttributeRequest) *types.AddSearchAttributeRequest
func ToAdminCloseShardRequest(t *adminv1.CloseShardRequest) *types.CloseShardRequest
func ToAdminCountDLQMessagesRequest(t *adminv1.CountDLQMessagesRequest) *types.CountDLQMessagesRequest
func ToAdminCountDLQMessagesResponse(t *adminv1.CountDLQMessagesResponse) *types.CountDLQMessagesResponse
func ToAdminDeleteWorkflowRequest(t *adminv1.DeleteWorkflowRequest) *types.AdminDeleteWorkflowRequest
func ToAdminDeleteWorkflowResponse(t *adminv1.DeleteWorkflowResponse) *types.AdminDeleteWorkflowResponse
func ToAdminDescribeClusterResponse(t *adminv1.DescribeClusterResponse) *types.DescribeClusterResponse
func ToAdminDescribeHistoryHostRequest(t *adminv1.DescribeHistoryHostRequest) *types.DescribeHistoryHostRequest
func ToAdminDescribeHistoryHostResponse(t *adminv1.DescribeHistoryHostResponse) *types.DescribeHistoryHostResponse
func ToAdminDescribeQueueRequest(t *adminv1.DescribeQueueRequest) *types.DescribeQueueRequest
func ToAdminDescribeQueueResponse(t *adminv1.DescribeQueueResponse) *types.DescribeQueueResponse
func ToAdminDescribeShardDistributionRequest(t *adminv1.DescribeShardDistributionRequest) *types.DescribeShardDistributionRequest
func ToAdminDescribeShardDistributionResponse(t *adminv1.DescribeShardDistributionResponse) *types.DescribeShardDistributionResponse
func ToAdminDescribeWorkflowExecutionRequest(t *adminv1.DescribeWorkflowExecutionRequest) *types.AdminDescribeWorkflowExecutionRequest
func ToAdminDescribeWorkflowExecutionResponse(t *adminv1.DescribeWorkflowExecutionResponse) *types.AdminDescribeWorkflowExecutionResponse
func ToAdminGetCrossClusterTasksRequest(t *adminv1.GetCrossClusterTasksRequest) *types.GetCrossClusterTasksRequest
func ToAdminGetCrossClusterTasksResponse(t *adminv1.GetCrossClusterTasksResponse) *types.GetCrossClusterTasksResponse
func ToAdminGetDLQReplicationMessagesRequest(t *adminv1.GetDLQReplicationMessagesRequest) *types.GetDLQReplicationMessagesRequest
func ToAdminGetDLQReplicationMessagesResponse(t *adminv1.GetDLQReplicationMessagesResponse) *types.GetDLQReplicationMessagesResponse
func ToAdminGetDomainAsyncWorkflowConfiguratonRequest(in *adminv1.GetDomainAsyncWorkflowConfiguratonRequest) *types.GetDomainAsyncWorkflowConfiguratonRequest
func ToAdminGetDomainAsyncWorkflowConfiguratonResponse(in *adminv1.GetDomainAsyncWorkflowConfiguratonResponse) *types.GetDomainAsyncWorkflowConfiguratonResponse
func ToAdminGetDomainIsolationGroupsRequest(t *adminv1.GetDomainIsolationGroupsRequest) *types.GetDomainIsolationGroupsRequest
func ToAdminGetDomainIsolationGroupsResponse(t *adminv1.GetDomainIsolationGroupsResponse) *types.GetDomainIsolationGroupsResponse
func ToAdminGetDomainReplicationMessagesRequest(t *adminv1.GetDomainReplicationMessagesRequest) *types.GetDomainReplicationMessagesRequest
func ToAdminGetDomainReplicationMessagesResponse(t *adminv1.GetDomainReplicationMessagesResponse) *types.GetDomainReplicationMessagesResponse
func ToAdminGetDynamicConfigRequest(t *adminv1.GetDynamicConfigRequest) *types.GetDynamicConfigRequest
func ToAdminGetDynamicConfigResponse(t *adminv1.GetDynamicConfigResponse) *types.GetDynamicConfigResponse
func ToAdminGetGlobalIsolationGroupsRequest(t *adminv1.GetGlobalIsolationGroupsRequest) *types.GetGlobalIsolationGroupsRequest
func ToAdminGetGlobalIsolationGroupsResponse(t *adminv1.GetGlobalIsolationGroupsResponse) *types.GetGlobalIsolationGroupsResponse
func ToAdminGetReplicationMessagesRequest(t *adminv1.GetReplicationMessagesRequest) *types.GetReplicationMessagesRequest
func ToAdminGetReplicationMessagesResponse(t *adminv1.GetReplicationMessagesResponse) *types.GetReplicationMessagesResponse
func ToAdminGetWorkflowExecutionRawHistoryV2Request(t *adminv1.GetWorkflowExecutionRawHistoryV2Request) *types.GetWorkflowExecutionRawHistoryV2Request
func ToAdminGetWorkflowExecutionRawHistoryV2Response(t *adminv1.GetWorkflowExecutionRawHistoryV2Response) *types.GetWorkflowExecutionRawHistoryV2Response
func ToAdminListDynamicConfigRequest(t *adminv1.ListDynamicConfigRequest) *types.ListDynamicConfigRequest
func ToAdminListDynamicConfigResponse(t *adminv1.ListDynamicConfigResponse) *types.ListDynamicConfigResponse
func ToAdminMaintainCorruptWorkflowRequest(t *adminv1.MaintainCorruptWorkflowRequest) *types.AdminMaintainWorkflowRequest
func ToAdminMaintainCorruptWorkflowResponse(t *adminv1.MaintainCorruptWorkflowResponse) *types.AdminMaintainWorkflowResponse
func ToAdminMergeDLQMessagesRequest(t *adminv1.MergeDLQMessagesRequest) *types.MergeDLQMessagesRequest
func ToAdminMergeDLQMessagesResponse(t *adminv1.MergeDLQMessagesResponse) *types.MergeDLQMessagesResponse
func ToAdminPurgeDLQMessagesRequest(t *adminv1.PurgeDLQMessagesRequest) *types.PurgeDLQMessagesRequest
func ToAdminReadDLQMessagesRequest(t *adminv1.ReadDLQMessagesRequest) *types.ReadDLQMessagesRequest
func ToAdminReadDLQMessagesResponse(t *adminv1.ReadDLQMessagesResponse) *types.ReadDLQMessagesResponse
func ToAdminReapplyEventsRequest(t *adminv1.ReapplyEventsRequest) *types.ReapplyEventsRequest
func ToAdminRefreshWorkflowTasksRequest(t *adminv1.RefreshWorkflowTasksRequest) *types.RefreshWorkflowTasksRequest
func ToAdminRemoveTaskRequest(t *adminv1.RemoveTaskRequest) *types.RemoveTaskRequest
func ToAdminResendReplicationTasksRequest(t *adminv1.ResendReplicationTasksRequest) *types.ResendReplicationTasksRequest
func ToAdminResetQueueRequest(t *adminv1.ResetQueueRequest) *types.ResetQueueRequest
func ToAdminRespondCrossClusterTasksCompletedRequest(t *adminv1.RespondCrossClusterTasksCompletedRequest) *types.RespondCrossClusterTasksCompletedRequest
func ToAdminRespondCrossClusterTasksCompletedResponse(t *adminv1.RespondCrossClusterTasksCompletedResponse) *types.RespondCrossClusterTasksCompletedResponse
func ToAdminRestoreDynamicConfigRequest(t *adminv1.RestoreDynamicConfigRequest) *types.RestoreDynamicConfigRequest
func ToAdminUpdateDomainAsyncWorkflowConfiguratonRequest(in *adminv1.UpdateDomainAsyncWorkflowConfiguratonRequest) *types.UpdateDomainAsyncWorkflowConfiguratonRequest
func ToAdminUpdateDomainAsyncWorkflowConfiguratonResponse(in *adminv1.UpdateDomainAsyncWorkflowConfiguratonResponse) *types.UpdateDomainAsyncWorkflowConfiguratonResponse
func ToAdminUpdateDomainIsolationGroupsRequest(t *adminv1.UpdateDomainIsolationGroupsRequest) *types.UpdateDomainIsolationGroupsRequest
func ToAdminUpdateDomainIsolationGroupsResponse(t *adminv1.UpdateDomainIsolationGroupsResponse) *types.UpdateDomainIsolationGroupsResponse
func ToAdminUpdateDynamicConfigRequest(t *adminv1.UpdateDynamicConfigRequest) *types.UpdateDynamicConfigRequest
func ToAdminUpdateGlobalIsolationGroupsRequest(t *adminv1.UpdateGlobalIsolationGroupsRequest) *types.UpdateGlobalIsolationGroupsRequest
func ToAdminUpdateGlobalIsolationGroupsResponse(t *adminv1.UpdateGlobalIsolationGroupsResponse) *types.UpdateGlobalIsolationGroupsResponse
func ToApplyParentClosePolicyAttributes(t *adminv1.ApplyParentClosePolicyAttributes) *types.ApplyParentClosePolicyAttributes
func ToApplyParentClosePolicyResult(t *adminv1.ApplyParentClosePolicyResult) *types.ApplyParentClosePolicyResult
func ToApplyParentClosePolicyStatus(t *adminv1.ApplyParentClosePolicyStatus) *types.ApplyParentClosePolicyStatus
func ToArchivalStatus(t apiv1.ArchivalStatus) *types.ArchivalStatus
func ToAsyncWorkflowKafkaQueueConfig(in *apiv1.AsyncWorkflowKafkaQueueConfiguration) *types.AsyncWorkflowKafkaQueueConfiguration
func ToBadBinaries(t *apiv1.BadBinaries) *types.BadBinaries
func ToBadBinaryInfo(t *apiv1.BadBinaryInfo) *types.BadBinaryInfo
func ToBadBinaryInfoMap(t map[string]*apiv1.BadBinaryInfo) map[string]*types.BadBinaryInfo
func ToCancelExternalWorkflowExecutionFailedCause(t apiv1.CancelExternalWorkflowExecutionFailedCause) *types.CancelExternalWorkflowExecutionFailedCause
func ToCancelTimerDecisionAttributes(t *apiv1.CancelTimerDecisionAttributes) *types.CancelTimerDecisionAttributes
func ToCancelTimerFailedEventAttributes(t *apiv1.CancelTimerFailedEventAttributes) *types.CancelTimerFailedEventAttributes
func ToCancelWorkflowExecutionDecisionAttributes(t *apiv1.CancelWorkflowExecutionDecisionAttributes) *types.CancelWorkflowExecutionDecisionAttributes
func ToChildWorkflowExecutionCanceledEventAttributes(t *apiv1.ChildWorkflowExecutionCanceledEventAttributes) *types.ChildWorkflowExecutionCanceledEventAttributes
func ToChildWorkflowExecutionCompletedEventAttributes(t *apiv1.ChildWorkflowExecutionCompletedEventAttributes) *types.ChildWorkflowExecutionCompletedEventAttributes
func ToChildWorkflowExecutionFailedCause(t apiv1.ChildWorkflowExecutionFailedCause) *types.ChildWorkflowExecutionFailedCause
func ToChildWorkflowExecutionFailedEventAttributes(t *apiv1.ChildWorkflowExecutionFailedEventAttributes) *types.ChildWorkflowExecutionFailedEventAttributes
func ToChildWorkflowExecutionStartedEventAttributes(t *apiv1.ChildWorkflowExecutionStartedEventAttributes) *types.ChildWorkflowExecutionStartedEventAttributes
func ToChildWorkflowExecutionTerminatedEventAttributes(t *apiv1.ChildWorkflowExecutionTerminatedEventAttributes) *types.ChildWorkflowExecutionTerminatedEventAttributes
func ToChildWorkflowExecutionTimedOutEventAttributes(t *apiv1.ChildWorkflowExecutionTimedOutEventAttributes) *types.ChildWorkflowExecutionTimedOutEventAttributes
func ToClusterReplicationConfiguration(t *apiv1.ClusterReplicationConfiguration) *types.ClusterReplicationConfiguration
func ToClusterReplicationConfigurationArray(t []*apiv1.ClusterReplicationConfiguration) []*types.ClusterReplicationConfiguration
func ToCompleteWorkflowExecutionDecisionAttributes(t *apiv1.CompleteWorkflowExecutionDecisionAttributes) *types.CompleteWorkflowExecutionDecisionAttributes
func ToContinueAsNewInitiator(t apiv1.ContinueAsNewInitiator) *types.ContinueAsNewInitiator
func ToContinueAsNewWorkflowExecutionDecisionAttributes(t *apiv1.ContinueAsNewWorkflowExecutionDecisionAttributes) *types.ContinueAsNewWorkflowExecutionDecisionAttributes
func ToCountWorkflowExecutionsRequest(t *apiv1.CountWorkflowExecutionsRequest) *types.CountWorkflowExecutionsRequest
func ToCountWorkflowExecutionsResponse(t *apiv1.CountWorkflowExecutionsResponse) *types.CountWorkflowExecutionsResponse
func ToCrossClusterApplyParentClosePolicyRequestAttributes(t *adminv1.CrossClusterApplyParentClosePolicyRequestAttributes) *types.CrossClusterApplyParentClosePolicyRequestAttributes
func ToCrossClusterApplyParentClosePolicyResponseAttributes(t *adminv1.CrossClusterApplyParentClosePolicyResponseAttributes) *types.CrossClusterApplyParentClosePolicyResponseAttributes
func ToCrossClusterCancelExecutionRequestAttributes(t *adminv1.CrossClusterCancelExecutionRequestAttributes) *types.CrossClusterCancelExecutionRequestAttributes
func ToCrossClusterCancelExecutionResponseAttributes(t *adminv1.CrossClusterCancelExecutionResponseAttributes) *types.CrossClusterCancelExecutionResponseAttributes
func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes
func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes
func ToCrossClusterSignalExecutionRequestAttributes(t *adminv1.CrossClusterSignalExecutionRequestAttributes) *types.CrossClusterSignalExecutionRequestAttributes
func ToCrossClusterSignalExecutionResponseAttributes(t *adminv1.CrossClusterSignalExecutionResponseAttributes) *types.CrossClusterSignalExecutionResponseAttributes
func ToCrossClusterStartChildExecutionRequestAttributes(t *adminv1.CrossClusterStartChildExecutionRequestAttributes) *types.CrossClusterStartChildExecutionRequestAttributes
func ToCrossClusterStartChildExecutionResponseAttributes(t *adminv1.CrossClusterStartChildExecutionResponseAttributes) *types.CrossClusterStartChildExecutionResponseAttributes
func ToCrossClusterTaskFailedCause(t adminv1.CrossClusterTaskFailedCause) *types.CrossClusterTaskFailedCause
func ToCrossClusterTaskInfo(t *adminv1.CrossClusterTaskInfo) *types.CrossClusterTaskInfo
func ToCrossClusterTaskRequest(t *adminv1.CrossClusterTaskRequest) *types.CrossClusterTaskRequest
func ToCrossClusterTaskRequestArray(t *adminv1.CrossClusterTaskRequests) []*types.CrossClusterTaskRequest
func ToCrossClusterTaskRequestMap(t map[int32]*adminv1.CrossClusterTaskRequests) map[int32][]*types.CrossClusterTaskRequest
func ToCrossClusterTaskResponse(t *adminv1.CrossClusterTaskResponse) *types.CrossClusterTaskResponse
func ToCrossClusterTaskResponseArray(t []*adminv1.CrossClusterTaskResponse) []*types.CrossClusterTaskResponse
func ToCrossClusterTaskType(t adminv1.CrossClusterTaskType) *types.CrossClusterTaskType
func ToDLQType(t adminv1.DLQType) *types.DLQType
func ToDataBlob(t *apiv1.DataBlob) *types.DataBlob
func ToDataBlobArray(t []*apiv1.DataBlob) []*types.DataBlob
func ToDecision(d *apiv1.Decision) *types.Decision
func ToDecisionArray(t []*apiv1.Decision) []*types.Decision
func ToDecisionTaskCompletedEventAttributes(t *apiv1.DecisionTaskCompletedEventAttributes) *types.DecisionTaskCompletedEventAttributes
func ToDecisionTaskFailedCause(t apiv1.DecisionTaskFailedCause) *types.DecisionTaskFailedCause
func ToDecisionTaskFailedEventAttributes(t *apiv1.DecisionTaskFailedEventAttributes) *types.DecisionTaskFailedEventAttributes
func ToDecisionTaskScheduledEventAttributes(t *apiv1.DecisionTaskScheduledEventAttributes) *types.DecisionTaskScheduledEventAttributes
func ToDecisionTaskStartedEventAttributes(t *apiv1.DecisionTaskStartedEventAttributes) *types.DecisionTaskStartedEventAttributes
func ToDecisionTaskTimedOutCause(t apiv1.DecisionTaskTimedOutCause) *types.DecisionTaskTimedOutCause
func ToDecisionTaskTimedOutEventAttributes(t *apiv1.DecisionTaskTimedOutEventAttributes) *types.DecisionTaskTimedOutEventAttributes
func ToDeprecateDomainRequest(t *apiv1.DeprecateDomainRequest) *types.DeprecateDomainRequest
func ToDescribeDomainRequest(t *apiv1.DescribeDomainRequest) *types.DescribeDomainRequest
func ToDescribeDomainResponse(t *apiv1.DescribeDomainResponse) *types.DescribeDomainResponse
func ToDescribeDomainResponseArray(t []*apiv1.Domain) []*types.DescribeDomainResponse
func ToDescribeDomainResponseDomain(t *apiv1.Domain) *types.DescribeDomainResponse
func ToDescribeTaskListRequest(t *apiv1.DescribeTaskListRequest) *types.DescribeTaskListRequest
func ToDescribeTaskListResponse(t *apiv1.DescribeTaskListResponse) *types.DescribeTaskListResponse
func ToDescribeTaskListResponseMap(t map[string]*apiv1.DescribeTaskListResponse) map[string]*types.DescribeTaskListResponse
func ToDescribeWorkflowExecutionRequest(t *apiv1.DescribeWorkflowExecutionRequest) *types.DescribeWorkflowExecutionRequest
func ToDescribeWorkflowExecutionResponse(t *apiv1.DescribeWorkflowExecutionResponse) *types.DescribeWorkflowExecutionResponse
func ToDomainAsyncWorkflowConfiguraton(in *apiv1.AsyncWorkflowConfiguration) *types.AsyncWorkflowConfiguration
func ToDomainCacheInfo(t *adminv1.DomainCacheInfo) *types.DomainCacheInfo
func ToDomainOperation(t adminv1.DomainOperation) *types.DomainOperation
func ToDomainStatus(t apiv1.DomainStatus) *types.DomainStatus
func ToDomainTaskAttributes(t *adminv1.DomainTaskAttributes) *types.DomainTaskAttributes
func ToDynamicConfigEntry(t *adminv1.DynamicConfigEntry) *types.DynamicConfigEntry
func ToDynamicConfigEntryArray(t []*adminv1.DynamicConfigEntry) []*types.DynamicConfigEntry
func ToDynamicConfigFilter(t *adminv1.DynamicConfigFilter) *types.DynamicConfigFilter
func ToDynamicConfigFilterArray(t []*adminv1.DynamicConfigFilter) []*types.DynamicConfigFilter
func ToDynamicConfigValue(t *adminv1.DynamicConfigValue) *types.DynamicConfigValue
func ToDynamicConfigValueArray(t []*adminv1.DynamicConfigValue) []*types.DynamicConfigValue
func ToEncodingType(t apiv1.EncodingType) *types.EncodingType
func ToError(err error) error
func ToEventFilterType(t apiv1.EventFilterType) *types.HistoryEventFilterType
func ToEventID(item *adminv1.VersionHistoryItem) *int64
func ToEventVersion(item *adminv1.VersionHistoryItem) *int64
func ToExternalInitiatedID(t *apiv1.ExternalExecutionInfo) *int64
func ToExternalWorkflowExecution(t *apiv1.ExternalExecutionInfo) *types.WorkflowExecution
func ToExternalWorkflowExecutionCancelRequestedEventAttributes(t *apiv1.ExternalWorkflowExecutionCancelRequestedEventAttributes) *types.ExternalWorkflowExecutionCancelRequestedEventAttributes
func ToExternalWorkflowExecutionSignaledEventAttributes(t *apiv1.ExternalWorkflowExecutionSignaledEventAttributes) *types.ExternalWorkflowExecutionSignaledEventAttributes
func ToFailWorkflowExecutionDecisionAttributes(t *apiv1.FailWorkflowExecutionDecisionAttributes) *types.FailWorkflowExecutionDecisionAttributes
func ToFailoverInfo(t *apiv1.FailoverInfo) *types.FailoverInfo
func ToFailoverMarkerAttributes(t *adminv1.FailoverMarkerAttributes) *types.FailoverMarkerAttributes
func ToFailoverMarkerToken(t *adminv1.FailoverMarkerToken) *types.FailoverMarkerToken
func ToFailoverMarkerTokenArray(t []*adminv1.FailoverMarkerToken) []*types.FailoverMarkerToken
func ToFailureDetails(failure *apiv1.Failure) []byte
func ToFailureReason(failure *apiv1.Failure) *string
func ToGetClusterInfoResponse(t *apiv1.GetClusterInfoResponse) *types.ClusterInfo
func ToGetSearchAttributesResponse(t *apiv1.GetSearchAttributesResponse) *types.GetSearchAttributesResponse
func ToGetTaskFailedCause(t adminv1.GetTaskFailedCause) *types.GetTaskFailedCause
func ToGetTaskFailedCauseMap(t map[int32]adminv1.GetTaskFailedCause) map[int32]types.GetTaskFailedCause
func ToGetTaskListsByDomainRequest(t *apiv1.GetTaskListsByDomainRequest) *types.GetTaskListsByDomainRequest
func ToGetTaskListsByDomainResponse(t *apiv1.GetTaskListsByDomainResponse) *types.GetTaskListsByDomainResponse
func ToGetWorkflowExecutionHistoryRequest(t *apiv1.GetWorkflowExecutionHistoryRequest) *types.GetWorkflowExecutionHistoryRequest
func ToGetWorkflowExecutionHistoryResponse(t *apiv1.GetWorkflowExecutionHistoryResponse) *types.GetWorkflowExecutionHistoryResponse
func ToHeader(t *apiv1.Header) *types.Header
func ToHealthResponse(t *apiv1.HealthResponse) *types.HealthStatus
func ToHistory(t *apiv1.History) *types.History
func ToHistoryCloseShardRequest(t *historyv1.CloseShardRequest) *types.CloseShardRequest
func ToHistoryCountDLQMessagesRequest(t *historyv1.CountDLQMessagesRequest) *types.CountDLQMessagesRequest
func ToHistoryCountDLQMessagesResponse(t *historyv1.CountDLQMessagesResponse) *types.HistoryCountDLQMessagesResponse
func ToHistoryDLQCountEntryMap(t []*adminv1.HistoryDLQCountEntry) map[types.HistoryDLQCountKey]int64
func ToHistoryDescribeHistoryHostRequest(t *historyv1.DescribeHistoryHostRequest) *types.DescribeHistoryHostRequest
func ToHistoryDescribeHistoryHostResponse(t *historyv1.DescribeHistoryHostResponse) *types.DescribeHistoryHostResponse
func ToHistoryDescribeMutableStateRequest(t *historyv1.DescribeMutableStateRequest) *types.DescribeMutableStateRequest
func ToHistoryDescribeMutableStateResponse(t *historyv1.DescribeMutableStateResponse) *types.DescribeMutableStateResponse
func ToHistoryDescribeQueueRequest(t *historyv1.DescribeQueueRequest) *types.DescribeQueueRequest
func ToHistoryDescribeQueueResponse(t *historyv1.DescribeQueueResponse) *types.DescribeQueueResponse
func ToHistoryDescribeWorkflowExecutionRequest(t *historyv1.DescribeWorkflowExecutionRequest) *types.HistoryDescribeWorkflowExecutionRequest
func ToHistoryDescribeWorkflowExecutionResponse(t *historyv1.DescribeWorkflowExecutionResponse) *types.DescribeWorkflowExecutionResponse
func ToHistoryEvent(e *apiv1.HistoryEvent) *types.HistoryEvent
func ToHistoryEventArray(t []*apiv1.HistoryEvent) []*types.HistoryEvent
func ToHistoryGetCrossClusterTasksRequest(t *historyv1.GetCrossClusterTasksRequest) *types.GetCrossClusterTasksRequest
func ToHistoryGetCrossClusterTasksResponse(t *historyv1.GetCrossClusterTasksResponse) *types.GetCrossClusterTasksResponse
func ToHistoryGetDLQReplicationMessagesRequest(t *historyv1.GetDLQReplicationMessagesRequest) *types.GetDLQReplicationMessagesRequest
func ToHistoryGetDLQReplicationMessagesResponse(t *historyv1.GetDLQReplicationMessagesResponse) *types.GetDLQReplicationMessagesResponse
func ToHistoryGetFailoverInfoRequest(t *historyv1.GetFailoverInfoRequest) *types.GetFailoverInfoRequest
func ToHistoryGetFailoverInfoResponse(t *historyv1.GetFailoverInfoResponse) *types.GetFailoverInfoResponse
func ToHistoryGetMutableStateRequest(t *historyv1.GetMutableStateRequest) *types.GetMutableStateRequest
func ToHistoryGetMutableStateResponse(t *historyv1.GetMutableStateResponse) *types.GetMutableStateResponse
func ToHistoryGetReplicationMessagesRequest(t *historyv1.GetReplicationMessagesRequest) *types.GetReplicationMessagesRequest
func ToHistoryGetReplicationMessagesResponse(t *historyv1.GetReplicationMessagesResponse) *types.GetReplicationMessagesResponse
func ToHistoryMergeDLQMessagesRequest(t *historyv1.MergeDLQMessagesRequest) *types.MergeDLQMessagesRequest
func ToHistoryMergeDLQMessagesResponse(t *historyv1.MergeDLQMessagesResponse) *types.MergeDLQMessagesResponse
func ToHistoryNotifyFailoverMarkersRequest(t *historyv1.NotifyFailoverMarkersRequest) *types.NotifyFailoverMarkersRequest
func ToHistoryPollMutableStateRequest(t *historyv1.PollMutableStateRequest) *types.PollMutableStateRequest
func ToHistoryPollMutableStateResponse(t *historyv1.PollMutableStateResponse) *types.PollMutableStateResponse
func ToHistoryPurgeDLQMessagesRequest(t *historyv1.PurgeDLQMessagesRequest) *types.PurgeDLQMessagesRequest
func ToHistoryQueryWorkflowRequest(t *historyv1.QueryWorkflowRequest) *types.HistoryQueryWorkflowRequest
func ToHistoryQueryWorkflowResponse(t *historyv1.QueryWorkflowResponse) *types.HistoryQueryWorkflowResponse
func ToHistoryReadDLQMessagesRequest(t *historyv1.ReadDLQMessagesRequest) *types.ReadDLQMessagesRequest
func ToHistoryReadDLQMessagesResponse(t *historyv1.ReadDLQMessagesResponse) *types.ReadDLQMessagesResponse
func ToHistoryReapplyEventsRequest(t *historyv1.ReapplyEventsRequest) *types.HistoryReapplyEventsRequest
func ToHistoryRecordActivityTaskHeartbeatRequest(t *historyv1.RecordActivityTaskHeartbeatRequest) *types.HistoryRecordActivityTaskHeartbeatRequest
func ToHistoryRecordActivityTaskHeartbeatResponse(t *historyv1.RecordActivityTaskHeartbeatResponse) *types.RecordActivityTaskHeartbeatResponse
func ToHistoryRecordActivityTaskStartedRequest(t *historyv1.RecordActivityTaskStartedRequest) *types.RecordActivityTaskStartedRequest
func ToHistoryRecordActivityTaskStartedResponse(t *historyv1.RecordActivityTaskStartedResponse) *types.RecordActivityTaskStartedResponse
func ToHistoryRecordChildExecutionCompletedRequest(t *historyv1.RecordChildExecutionCompletedRequest) *types.RecordChildExecutionCompletedRequest
func ToHistoryRecordDecisionTaskStartedRequest(t *historyv1.RecordDecisionTaskStartedRequest) *types.RecordDecisionTaskStartedRequest
func ToHistoryRecordDecisionTaskStartedResponse(t *historyv1.RecordDecisionTaskStartedResponse) *types.RecordDecisionTaskStartedResponse
func ToHistoryRefreshWorkflowTasksRequest(t *historyv1.RefreshWorkflowTasksRequest) *types.HistoryRefreshWorkflowTasksRequest
func ToHistoryRemoveSignalMutableStateRequest(t *historyv1.RemoveSignalMutableStateRequest) *types.RemoveSignalMutableStateRequest
func ToHistoryRemoveTaskRequest(t *historyv1.RemoveTaskRequest) *types.RemoveTaskRequest
func ToHistoryReplicateEventsV2Request(t *historyv1.ReplicateEventsV2Request) *types.ReplicateEventsV2Request
func ToHistoryRequestCancelWorkflowExecutionRequest(t *historyv1.RequestCancelWorkflowExecutionRequest) *types.HistoryRequestCancelWorkflowExecutionRequest
func ToHistoryResetQueueRequest(t *historyv1.ResetQueueRequest) *types.ResetQueueRequest
func ToHistoryResetStickyTaskListRequest(t *historyv1.ResetStickyTaskListRequest) *types.HistoryResetStickyTaskListRequest
func ToHistoryResetStickyTaskListResponse(t *historyv1.ResetStickyTaskListResponse) *types.HistoryResetStickyTaskListResponse
func ToHistoryResetWorkflowExecutionRequest(t *historyv1.ResetWorkflowExecutionRequest) *types.HistoryResetWorkflowExecutionRequest
func ToHistoryResetWorkflowExecutionResponse(t *historyv1.ResetWorkflowExecutionResponse) *types.ResetWorkflowExecutionResponse
func ToHistoryRespondActivityTaskCanceledRequest(t *historyv1.RespondActivityTaskCanceledRequest) *types.HistoryRespondActivityTaskCanceledRequest
func ToHistoryRespondActivityTaskCompletedRequest(t *historyv1.RespondActivityTaskCompletedRequest) *types.HistoryRespondActivityTaskCompletedRequest
func ToHistoryRespondActivityTaskFailedRequest(t *historyv1.RespondActivityTaskFailedRequest) *types.HistoryRespondActivityTaskFailedRequest
func ToHistoryRespondCrossClusterTasksCompletedRequest(t *historyv1.RespondCrossClusterTasksCompletedRequest) *types.RespondCrossClusterTasksCompletedRequest
func ToHistoryRespondCrossClusterTasksCompletedResponse(t *historyv1.RespondCrossClusterTasksCompletedResponse) *types.RespondCrossClusterTasksCompletedResponse
func ToHistoryRespondDecisionTaskCompletedRequest(t *historyv1.RespondDecisionTaskCompletedRequest) *types.HistoryRespondDecisionTaskCompletedRequest
func ToHistoryRespondDecisionTaskCompletedResponse(t *historyv1.RespondDecisionTaskCompletedResponse) *types.HistoryRespondDecisionTaskCompletedResponse
func ToHistoryRespondDecisionTaskFailedRequest(t *historyv1.RespondDecisionTaskFailedRequest) *types.HistoryRespondDecisionTaskFailedRequest
func ToHistoryScheduleDecisionTaskRequest(t *historyv1.ScheduleDecisionTaskRequest) *types.ScheduleDecisionTaskRequest
func ToHistorySignalWithStartWorkflowExecutionRequest(t *historyv1.SignalWithStartWorkflowExecutionRequest) *types.HistorySignalWithStartWorkflowExecutionRequest
func ToHistorySignalWithStartWorkflowExecutionResponse(t *historyv1.SignalWithStartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse
func ToHistorySignalWorkflowExecutionRequest(t *historyv1.SignalWorkflowExecutionRequest) *types.HistorySignalWorkflowExecutionRequest
func ToHistoryStartWorkflowExecutionRequest(t *historyv1.StartWorkflowExecutionRequest) *types.HistoryStartWorkflowExecutionRequest
func ToHistoryStartWorkflowExecutionResponse(t *historyv1.StartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse
func ToHistorySyncActivityRequest(t *historyv1.SyncActivityRequest) *types.SyncActivityRequest
func ToHistorySyncShardStatusRequest(t *historyv1.SyncShardStatusRequest) *types.SyncShardStatusRequest
func ToHistoryTaskV2Attributes(t *adminv1.HistoryTaskV2Attributes) *types.HistoryTaskV2Attributes
func ToHistoryTerminateWorkflowExecutionRequest(t *historyv1.TerminateWorkflowExecutionRequest) *types.HistoryTerminateWorkflowExecutionRequest
func ToHostInfo(t *adminv1.HostInfo) *types.HostInfo
func ToHostInfoArray(t []*adminv1.HostInfo) []*types.HostInfo
func ToIndexedValueType(t apiv1.IndexedValueType) types.IndexedValueType
func ToIndexedValueTypeMap(t map[string]apiv1.IndexedValueType) map[string]types.IndexedValueType
func ToIsolationGroupConfig(in *apiv1.IsolationGroupConfiguration) *types.IsolationGroupConfiguration
func ToListArchivedWorkflowExecutionsRequest(t *apiv1.ListArchivedWorkflowExecutionsRequest) *types.ListArchivedWorkflowExecutionsRequest
func ToListArchivedWorkflowExecutionsResponse(t *apiv1.ListArchivedWorkflowExecutionsResponse) *types.ListArchivedWorkflowExecutionsResponse
func ToListClosedWorkflowExecutionsRequest(r *apiv1.ListClosedWorkflowExecutionsRequest) *types.ListClosedWorkflowExecutionsRequest
func ToListClosedWorkflowExecutionsResponse(t *apiv1.ListClosedWorkflowExecutionsResponse) *types.ListClosedWorkflowExecutionsResponse
func ToListDomainsRequest(t *apiv1.ListDomainsRequest) *types.ListDomainsRequest
func ToListDomainsResponse(t *apiv1.ListDomainsResponse) *types.ListDomainsResponse
func ToListOpenWorkflowExecutionsRequest(r *apiv1.ListOpenWorkflowExecutionsRequest) *types.ListOpenWorkflowExecutionsRequest
func ToListOpenWorkflowExecutionsResponse(t *apiv1.ListOpenWorkflowExecutionsResponse) *types.ListOpenWorkflowExecutionsResponse
func ToListTaskListPartitionsRequest(t *apiv1.ListTaskListPartitionsRequest) *types.ListTaskListPartitionsRequest
func ToListTaskListPartitionsResponse(t *apiv1.ListTaskListPartitionsResponse) *types.ListTaskListPartitionsResponse
func ToListWorkflowExecutionsRequest(t *apiv1.ListWorkflowExecutionsRequest) *types.ListWorkflowExecutionsRequest
func ToListWorkflowExecutionsResponse(t *apiv1.ListWorkflowExecutionsResponse) *types.ListWorkflowExecutionsResponse
func ToMarkerRecordedEventAttributes(t *apiv1.MarkerRecordedEventAttributes) *types.MarkerRecordedEventAttributes
func ToMatchingAddActivityTaskRequest(t *matchingv1.AddActivityTaskRequest) *types.AddActivityTaskRequest
func ToMatchingAddDecisionTaskRequest(t *matchingv1.AddDecisionTaskRequest) *types.AddDecisionTaskRequest
func ToMatchingCancelOutstandingPollRequest(t *matchingv1.CancelOutstandingPollRequest) *types.CancelOutstandingPollRequest
func ToMatchingDescribeTaskListRequest(t *matchingv1.DescribeTaskListRequest) *types.MatchingDescribeTaskListRequest
func ToMatchingDescribeTaskListResponse(t *matchingv1.DescribeTaskListResponse) *types.DescribeTaskListResponse
func ToMatchingDescribeTaskListResponseMap(t map[string]*matchingv1.DescribeTaskListResponse) map[string]*types.DescribeTaskListResponse
func ToMatchingGetTaskListsByDomainRequest(t *matchingv1.GetTaskListsByDomainRequest) *types.GetTaskListsByDomainRequest
func ToMatchingGetTaskListsByDomainResponse(t *matchingv1.GetTaskListsByDomainResponse) *types.GetTaskListsByDomainResponse
func ToMatchingListTaskListPartitionsRequest(t *matchingv1.ListTaskListPartitionsRequest) *types.MatchingListTaskListPartitionsRequest
func ToMatchingListTaskListPartitionsResponse(t *matchingv1.ListTaskListPartitionsResponse) *types.ListTaskListPartitionsResponse
func ToMatchingPollForActivityTaskRequest(t *matchingv1.PollForActivityTaskRequest) *types.MatchingPollForActivityTaskRequest
func ToMatchingPollForActivityTaskResponse(t *matchingv1.PollForActivityTaskResponse) *types.PollForActivityTaskResponse
func ToMatchingPollForDecisionTaskRequest(t *matchingv1.PollForDecisionTaskRequest) *types.MatchingPollForDecisionTaskRequest
func ToMatchingPollForDecisionTaskResponse(t *matchingv1.PollForDecisionTaskResponse) *types.MatchingPollForDecisionTaskResponse
func ToMatchingQueryWorkflowRequest(t *matchingv1.QueryWorkflowRequest) *types.MatchingQueryWorkflowRequest
func ToMatchingQueryWorkflowResponse(t *matchingv1.QueryWorkflowResponse) *types.QueryWorkflowResponse
func ToMatchingRespondQueryTaskCompletedRequest(t *matchingv1.RespondQueryTaskCompletedRequest) *types.MatchingRespondQueryTaskCompletedRequest
func ToMembershipInfo(t *adminv1.MembershipInfo) *types.MembershipInfo
func ToMemo(t *apiv1.Memo) *types.Memo
func ToParentClosePolicy(t apiv1.ParentClosePolicy) *types.ParentClosePolicy
func ToParentDomainID(pei *apiv1.ParentExecutionInfo) *string
func ToParentDomainName(pei *apiv1.ParentExecutionInfo) *string
func ToParentExecutionInfo(t *apiv1.ParentExecutionInfo) *types.ParentExecutionInfo
func ToParentInitiatedID(pei *apiv1.ParentExecutionInfo) *int64
func ToParentWorkflowExecution(pei *apiv1.ParentExecutionInfo) *types.WorkflowExecution
func ToPayload(p *apiv1.Payload) []byte
func ToPayloadMap(t map[string]*apiv1.Payload) map[string][]byte
func ToPendingActivityInfo(t *apiv1.PendingActivityInfo) *types.PendingActivityInfo
func ToPendingActivityInfoArray(t []*apiv1.PendingActivityInfo) []*types.PendingActivityInfo
func ToPendingActivityState(t apiv1.PendingActivityState) *types.PendingActivityState
func ToPendingChildExecutionInfo(t *apiv1.PendingChildExecutionInfo) *types.PendingChildExecutionInfo
func ToPendingChildExecutionInfoArray(t []*apiv1.PendingChildExecutionInfo) []*types.PendingChildExecutionInfo
func ToPendingDecisionInfo(t *apiv1.PendingDecisionInfo) *types.PendingDecisionInfo
func ToPendingDecisionState(t apiv1.PendingDecisionState) *types.PendingDecisionState
func ToPersistenceFeature(t *adminv1.PersistenceFeature) *types.PersistenceFeature
func ToPersistenceFeatures(t []*adminv1.PersistenceFeature) []*types.PersistenceFeature
func ToPersistenceInfo(t *adminv1.PersistenceInfo) *types.PersistenceInfo
func ToPersistenceInfoMap(t map[string]*adminv1.PersistenceInfo) map[string]*types.PersistenceInfo
func ToPersistenceSetting(t *adminv1.PersistenceSetting) *types.PersistenceSetting
func ToPersistenceSettings(t []*adminv1.PersistenceSetting) []*types.PersistenceSetting
func ToPollForActivityTaskRequest(t *apiv1.PollForActivityTaskRequest) *types.PollForActivityTaskRequest
func ToPollForActivityTaskResponse(t *apiv1.PollForActivityTaskResponse) *types.PollForActivityTaskResponse
func ToPollForDecisionTaskRequest(t *apiv1.PollForDecisionTaskRequest) *types.PollForDecisionTaskRequest
func ToPollForDecisionTaskResponse(t *apiv1.PollForDecisionTaskResponse) *types.PollForDecisionTaskResponse
func ToPollerInfo(t *apiv1.PollerInfo) *types.PollerInfo
func ToPollerInfoArray(t []*apiv1.PollerInfo) []*types.PollerInfo
func ToQueryConsistencyLevel(t apiv1.QueryConsistencyLevel) *types.QueryConsistencyLevel
func ToQueryRejectCondition(t apiv1.QueryRejectCondition) *types.QueryRejectCondition
func ToQueryRejected(t *apiv1.QueryRejected) *types.QueryRejected
func ToQueryResultType(t apiv1.QueryResultType) *types.QueryResultType
func ToQueryTaskCompletedType(t apiv1.QueryResultType) *types.QueryTaskCompletedType
func ToQueryWorkflowRequest(t *apiv1.QueryWorkflowRequest) *types.QueryWorkflowRequest
func ToQueryWorkflowResponse(t *apiv1.QueryWorkflowResponse) *types.QueryWorkflowResponse
func ToRecordActivityTaskHeartbeatByIDRequest(t *apiv1.RecordActivityTaskHeartbeatByIDRequest) *types.RecordActivityTaskHeartbeatByIDRequest
func ToRecordActivityTaskHeartbeatByIDResponse(t *apiv1.RecordActivityTaskHeartbeatByIDResponse) *types.RecordActivityTaskHeartbeatResponse
func ToRecordActivityTaskHeartbeatRequest(t *apiv1.RecordActivityTaskHeartbeatRequest) *types.RecordActivityTaskHeartbeatRequest
func ToRecordActivityTaskHeartbeatResponse(t *apiv1.RecordActivityTaskHeartbeatResponse) *types.RecordActivityTaskHeartbeatResponse
func ToRecordMarkerDecisionAttributes(t *apiv1.RecordMarkerDecisionAttributes) *types.RecordMarkerDecisionAttributes
func ToRefreshWorkflowTasksRequest(t *apiv1.RefreshWorkflowTasksRequest) *types.RefreshWorkflowTasksRequest
func ToRegisterDomainRequest(t *apiv1.RegisterDomainRequest) *types.RegisterDomainRequest
func ToReplicationMessages(t *adminv1.ReplicationMessages) *types.ReplicationMessages
func ToReplicationMessagesMap(t map[int32]*adminv1.ReplicationMessages) map[int32]*types.ReplicationMessages
func ToReplicationTask(t *adminv1.ReplicationTask) *types.ReplicationTask
func ToReplicationTaskArray(t []*adminv1.ReplicationTask) []*types.ReplicationTask
func ToReplicationTaskInfo(t *adminv1.ReplicationTaskInfo) *types.ReplicationTaskInfo
func ToReplicationTaskInfoArray(t []*adminv1.ReplicationTaskInfo) []*types.ReplicationTaskInfo
func ToReplicationTaskType(t adminv1.ReplicationTaskType) *types.ReplicationTaskType
func ToReplicationToken(t *adminv1.ReplicationToken) *types.ReplicationToken
func ToReplicationTokenArray(t []*adminv1.ReplicationToken) []*types.ReplicationToken
func ToRequestCancelActivityTaskDecisionAttributes(t *apiv1.RequestCancelActivityTaskDecisionAttributes) *types.RequestCancelActivityTaskDecisionAttributes
func ToRequestCancelActivityTaskFailedEventAttributes(t *apiv1.RequestCancelActivityTaskFailedEventAttributes) *types.RequestCancelActivityTaskFailedEventAttributes
func ToRequestCancelExternalWorkflowExecutionDecisionAttributes(t *apiv1.RequestCancelExternalWorkflowExecutionDecisionAttributes) *types.RequestCancelExternalWorkflowExecutionDecisionAttributes
func ToRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *apiv1.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes
func ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *apiv1.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
func ToRequestCancelWorkflowExecutionRequest(t *apiv1.RequestCancelWorkflowExecutionRequest) *types.RequestCancelWorkflowExecutionRequest
func ToResetPointInfo(t *apiv1.ResetPointInfo) *types.ResetPointInfo
func ToResetPointInfoArray(t []*apiv1.ResetPointInfo) []*types.ResetPointInfo
func ToResetPoints(t *apiv1.ResetPoints) *types.ResetPoints
func ToResetStickyTaskListRequest(t *apiv1.ResetStickyTaskListRequest) *types.ResetStickyTaskListRequest
func ToResetStickyTaskListResponse(t *apiv1.ResetStickyTaskListResponse) *types.ResetStickyTaskListResponse
func ToResetWorkflowExecutionRequest(t *apiv1.ResetWorkflowExecutionRequest) *types.ResetWorkflowExecutionRequest
func ToResetWorkflowExecutionResponse(t *apiv1.ResetWorkflowExecutionResponse) *types.ResetWorkflowExecutionResponse
func ToRespondActivityTaskCanceledByIDRequest(t *apiv1.RespondActivityTaskCanceledByIDRequest) *types.RespondActivityTaskCanceledByIDRequest
func ToRespondActivityTaskCanceledRequest(t *apiv1.RespondActivityTaskCanceledRequest) *types.RespondActivityTaskCanceledRequest
func ToRespondActivityTaskCompletedByIDRequest(t *apiv1.RespondActivityTaskCompletedByIDRequest) *types.RespondActivityTaskCompletedByIDRequest
func ToRespondActivityTaskCompletedRequest(t *apiv1.RespondActivityTaskCompletedRequest) *types.RespondActivityTaskCompletedRequest
func ToRespondActivityTaskFailedByIDRequest(t *apiv1.RespondActivityTaskFailedByIDRequest) *types.RespondActivityTaskFailedByIDRequest
func ToRespondActivityTaskFailedRequest(t *apiv1.RespondActivityTaskFailedRequest) *types.RespondActivityTaskFailedRequest
func ToRespondDecisionTaskCompletedRequest(t *apiv1.RespondDecisionTaskCompletedRequest) *types.RespondDecisionTaskCompletedRequest
func ToRespondDecisionTaskCompletedResponse(t *apiv1.RespondDecisionTaskCompletedResponse) *types.RespondDecisionTaskCompletedResponse
func ToRespondDecisionTaskFailedRequest(t *apiv1.RespondDecisionTaskFailedRequest) *types.RespondDecisionTaskFailedRequest
func ToRespondQueryTaskCompletedRequest(t *apiv1.RespondQueryTaskCompletedRequest) *types.RespondQueryTaskCompletedRequest
func ToRestartWorkflowExecutionRequest(t *apiv1.RestartWorkflowExecutionRequest) *types.RestartWorkflowExecutionRequest
func ToRestartWorkflowExecutionResponse(t *apiv1.RestartWorkflowExecutionResponse) *types.RestartWorkflowExecutionResponse
func ToRetryPolicy(t *apiv1.RetryPolicy) *types.RetryPolicy
func ToRingInfo(t *adminv1.RingInfo) *types.RingInfo
func ToRingInfoArray(t []*adminv1.RingInfo) []*types.RingInfo
func ToRunID(t *apiv1.WorkflowExecution) string
func ToScanWorkflowExecutionsRequest(t *apiv1.ScanWorkflowExecutionsRequest) *types.ListWorkflowExecutionsRequest
func ToScanWorkflowExecutionsResponse(t *apiv1.ScanWorkflowExecutionsResponse) *types.ListWorkflowExecutionsResponse
func ToScheduleActivityTaskDecisionAttributes(t *apiv1.ScheduleActivityTaskDecisionAttributes) *types.ScheduleActivityTaskDecisionAttributes
func ToSearchAttributes(t *apiv1.SearchAttributes) *types.SearchAttributes
func ToSignalExternalWorkflowExecutionDecisionAttributes(t *apiv1.SignalExternalWorkflowExecutionDecisionAttributes) *types.SignalExternalWorkflowExecutionDecisionAttributes
func ToSignalExternalWorkflowExecutionFailedCause(t apiv1.SignalExternalWorkflowExecutionFailedCause) *types.SignalExternalWorkflowExecutionFailedCause
func ToSignalExternalWorkflowExecutionFailedEventAttributes(t *apiv1.SignalExternalWorkflowExecutionFailedEventAttributes) *types.SignalExternalWorkflowExecutionFailedEventAttributes
func ToSignalExternalWorkflowExecutionInitiatedEventAttributes(t *apiv1.SignalExternalWorkflowExecutionInitiatedEventAttributes) *types.SignalExternalWorkflowExecutionInitiatedEventAttributes
func ToSignalWithStartWorkflowExecutionRequest(t *apiv1.SignalWithStartWorkflowExecutionRequest) *types.SignalWithStartWorkflowExecutionRequest
func ToSignalWithStartWorkflowExecutionResponse(t *apiv1.SignalWithStartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse
func ToSignalWorkflowExecutionRequest(t *apiv1.SignalWorkflowExecutionRequest) *types.SignalWorkflowExecutionRequest
func ToStartChildWorkflowExecutionDecisionAttributes(t *apiv1.StartChildWorkflowExecutionDecisionAttributes) *types.StartChildWorkflowExecutionDecisionAttributes
func ToStartChildWorkflowExecutionFailedEventAttributes(t *apiv1.StartChildWorkflowExecutionFailedEventAttributes) *types.StartChildWorkflowExecutionFailedEventAttributes
func ToStartChildWorkflowExecutionInitiatedEventAttributes(t *apiv1.StartChildWorkflowExecutionInitiatedEventAttributes) *types.StartChildWorkflowExecutionInitiatedEventAttributes
func ToStartTimeFilter(t *apiv1.StartTimeFilter) *types.StartTimeFilter
func ToStartTimerDecisionAttributes(t *apiv1.StartTimerDecisionAttributes) *types.StartTimerDecisionAttributes
func ToStartWorkflowExecutionAsyncRequest(t *apiv1.StartWorkflowExecutionAsyncRequest) *types.StartWorkflowExecutionAsyncRequest
func ToStartWorkflowExecutionAsyncResponse(t *apiv1.StartWorkflowExecutionAsyncResponse) *types.StartWorkflowExecutionAsyncResponse
func ToStartWorkflowExecutionRequest(t *apiv1.StartWorkflowExecutionRequest) *types.StartWorkflowExecutionRequest
func ToStartWorkflowExecutionResponse(t *apiv1.StartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse
func ToStatusFilter(t *apiv1.StatusFilter) *types.WorkflowExecutionCloseStatus
func ToStickyExecutionAttributes(t *apiv1.StickyExecutionAttributes) *types.StickyExecutionAttributes
func ToSupportedClientVersions(t *apiv1.SupportedClientVersions) *types.SupportedClientVersions
func ToSyncActivityTaskAttributes(t *adminv1.SyncActivityTaskAttributes) *types.SyncActivityTaskAttributes
func ToSyncShardStatus(t *adminv1.SyncShardStatus) *types.SyncShardStatus
func ToSyncShardStatusTaskAttributes(t *adminv1.SyncShardStatusTaskAttributes) *types.SyncShardStatusTaskAttributes
func ToTaskIDBlock(t *apiv1.TaskIDBlock) *types.TaskIDBlock
func ToTaskList(t *apiv1.TaskList) *types.TaskList
func ToTaskListKind(t apiv1.TaskListKind) *types.TaskListKind
func ToTaskListMetadata(t *apiv1.TaskListMetadata) *types.TaskListMetadata
func ToTaskListPartitionMetadata(t *apiv1.TaskListPartitionMetadata) *types.TaskListPartitionMetadata
func ToTaskListPartitionMetadataArray(t []*apiv1.TaskListPartitionMetadata) []*types.TaskListPartitionMetadata
func ToTaskListStatus(t *apiv1.TaskListStatus) *types.TaskListStatus
func ToTaskListType(t apiv1.TaskListType) *types.TaskListType
func ToTaskSource(t sharedv1.TaskSource) *types.TaskSource
func ToTaskType(t adminv1.TaskType) *int32
func ToTerminateWorkflowExecutionRequest(t *apiv1.TerminateWorkflowExecutionRequest) *types.TerminateWorkflowExecutionRequest
func ToTimeoutType(t apiv1.TimeoutType) *types.TimeoutType
func ToTimerCanceledEventAttributes(t *apiv1.TimerCanceledEventAttributes) *types.TimerCanceledEventAttributes
func ToTimerFiredEventAttributes(t *apiv1.TimerFiredEventAttributes) *types.TimerFiredEventAttributes
func ToTimerStartedEventAttributes(t *apiv1.TimerStartedEventAttributes) *types.TimerStartedEventAttributes
func ToTransientDecisionInfo(t *sharedv1.TransientDecisionInfo) *types.TransientDecisionInfo
func ToUpdateDomainRequest(t *apiv1.UpdateDomainRequest) *types.UpdateDomainRequest
func ToUpdateDomainResponse(t *apiv1.UpdateDomainResponse) *types.UpdateDomainResponse
func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *apiv1.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes
func ToUpsertWorkflowSearchAttributesEventAttributes(t *apiv1.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes
func ToVersionHistories(t *sharedv1.VersionHistories) *types.VersionHistories
func ToVersionHistory(t *adminv1.VersionHistory) *types.VersionHistory
func ToVersionHistoryArray(t []*adminv1.VersionHistory) []*types.VersionHistory
func ToVersionHistoryItem(t *adminv1.VersionHistoryItem) *types.VersionHistoryItem
func ToVersionHistoryItemArray(t []*adminv1.VersionHistoryItem) []*types.VersionHistoryItem
func ToWorkerVersionInfo(t *apiv1.WorkerVersionInfo) *types.WorkerVersionInfo
func ToWorkflowExecution(t *apiv1.WorkflowExecution) *types.WorkflowExecution
func ToWorkflowExecutionCancelRequestedEventAttributes(t *apiv1.WorkflowExecutionCancelRequestedEventAttributes) *types.WorkflowExecutionCancelRequestedEventAttributes
func ToWorkflowExecutionCanceledEventAttributes(t *apiv1.WorkflowExecutionCanceledEventAttributes) *types.WorkflowExecutionCanceledEventAttributes
func ToWorkflowExecutionCloseStatus(t apiv1.WorkflowExecutionCloseStatus) *types.WorkflowExecutionCloseStatus
func ToWorkflowExecutionCompletedEventAttributes(t *apiv1.WorkflowExecutionCompletedEventAttributes) *types.WorkflowExecutionCompletedEventAttributes
func ToWorkflowExecutionConfiguration(t *apiv1.WorkflowExecutionConfiguration) *types.WorkflowExecutionConfiguration
func ToWorkflowExecutionContinuedAsNewEventAttributes(t *apiv1.WorkflowExecutionContinuedAsNewEventAttributes) *types.WorkflowExecutionContinuedAsNewEventAttributes
func ToWorkflowExecutionFailedEventAttributes(t *apiv1.WorkflowExecutionFailedEventAttributes) *types.WorkflowExecutionFailedEventAttributes
func ToWorkflowExecutionFilter(t *apiv1.WorkflowExecutionFilter) *types.WorkflowExecutionFilter
func ToWorkflowExecutionInfo(t *apiv1.WorkflowExecutionInfo) *types.WorkflowExecutionInfo
func ToWorkflowExecutionInfoArray(t []*apiv1.WorkflowExecutionInfo) []*types.WorkflowExecutionInfo
func ToWorkflowExecutionSignaledEventAttributes(t *apiv1.WorkflowExecutionSignaledEventAttributes) *types.WorkflowExecutionSignaledEventAttributes
func ToWorkflowExecutionStartedEventAttributes(t *apiv1.WorkflowExecutionStartedEventAttributes) *types.WorkflowExecutionStartedEventAttributes
func ToWorkflowExecutionTerminatedEventAttributes(t *apiv1.WorkflowExecutionTerminatedEventAttributes) *types.WorkflowExecutionTerminatedEventAttributes
func ToWorkflowExecutionTimedOutEventAttributes(t *apiv1.WorkflowExecutionTimedOutEventAttributes) *types.WorkflowExecutionTimedOutEventAttributes
func ToWorkflowID(t *apiv1.WorkflowExecution) string
func ToWorkflowIDReusePolicy(t apiv1.WorkflowIdReusePolicy) *types.WorkflowIDReusePolicy
func ToWorkflowQuery(t *apiv1.WorkflowQuery) *types.WorkflowQuery
func ToWorkflowQueryMap(t map[string]*apiv1.WorkflowQuery) map[string]*types.WorkflowQuery
func ToWorkflowQueryResult(t *apiv1.WorkflowQueryResult) *types.WorkflowQueryResult
func ToWorkflowQueryResultMap(t map[string]*apiv1.WorkflowQueryResult) map[string]*types.WorkflowQueryResult
func ToWorkflowState(t sharedv1.WorkflowState) *int32
func ToWorkflowType(t *apiv1.WorkflowType) *types.WorkflowType
func ToWorkflowTypeFilter(t *apiv1.WorkflowTypeFilter) *types.WorkflowTypeFilter

Constants ¶

View Source

const (
	DomainUpdateDescriptionField              = "description"
	DomainUpdateOwnerEmailField               = "owner_email"
	DomainUpdateDataField                     = "data"
	DomainUpdateRetentionPeriodField          = "workflow_execution_retention_period"
	DomainUpdateBadBinariesField              = "bad_binaries"
	DomainUpdateHistoryArchivalStatusField    = "history_archival_status"
	DomainUpdateHistoryArchivalURIField       = "history_archival_uri"
	DomainUpdateVisibilityArchivalStatusField = "visibility_archival_status"
	DomainUpdateVisibilityArchivalURIField    = "visibility_archival_uri"
	DomainUpdateActiveClusterNameField        = "active_cluster_name"
	DomainUpdateClustersField                 = "clusters"
	DomainUpdateDeleteBadBinaryField          = "delete_bad_binary"
	DomainUpdateFailoverTimeoutField          = "failover_timeout"
)

Variables ¶

This section is empty.

Functions ¶

func FromActivityLocalDispatchInfo ¶

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

func FromActivityLocalDispatchInfoMap ¶

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

func FromActivityTaskCancelRequestedEventAttributes ¶

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

func FromActivityTaskCanceledEventAttributes ¶

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

func FromActivityTaskCompletedEventAttributes ¶

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

func FromActivityTaskDispatchInfo ¶ added in v0.24.0

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

func FromActivityTaskFailedEventAttributes ¶

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

func FromActivityTaskScheduledEventAttributes ¶

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

func FromActivityTaskStartedEventAttributes ¶

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

func FromActivityTaskTimedOutEventAttributes ¶

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

func FromActivityType ¶

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

func FromAdminAddSearchAttributeRequest ¶

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

func FromAdminCloseShardRequest ¶

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

func FromAdminCountDLQMessagesRequest ¶ added in v0.25.0

func FromAdminCountDLQMessagesRequest(t *types.CountDLQMessagesRequest) *adminv1.CountDLQMessagesRequest

func FromAdminCountDLQMessagesResponse ¶ added in v0.25.0

func FromAdminCountDLQMessagesResponse(t *types.CountDLQMessagesResponse) *adminv1.CountDLQMessagesResponse

func FromAdminDeleteWorkflowRequest ¶ added in v0.24.0

func FromAdminDeleteWorkflowRequest(t *types.AdminDeleteWorkflowRequest) *adminv1.DeleteWorkflowRequest

FromAdminDeleteWorkflowRequest converts internal AdminDeleteWorkflowRequest type to proto

func FromAdminDeleteWorkflowResponse ¶ added in v0.24.0

func FromAdminDeleteWorkflowResponse(t *types.AdminDeleteWorkflowResponse) *adminv1.DeleteWorkflowResponse

FromAdminDeleteWorkflowResponse converts internal AdminDeleteWorkflowRequest type to proto

func FromAdminDescribeClusterResponse ¶

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

func FromAdminDescribeHistoryHostRequest ¶

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

func FromAdminDescribeHistoryHostResponse ¶

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

func FromAdminDescribeQueueRequest ¶

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

func FromAdminDescribeQueueResponse ¶

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

func FromAdminDescribeShardDistributionRequest ¶ added in v0.22.0

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

func FromAdminDescribeShardDistributionResponse ¶ added in v0.22.0

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

func FromAdminDescribeWorkflowExecutionRequest ¶

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

func FromAdminDescribeWorkflowExecutionResponse ¶

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

func FromAdminGetCrossClusterTasksRequest ¶ added in v0.23.1

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

FromAdminGetCrossClusterTasksRequest converts internal GetCrossClusterTasksRequest type to proto

func FromAdminGetCrossClusterTasksResponse ¶ added in v0.23.1

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

FromAdminGetCrossClusterTasksResponse converts internal GetCrossClusterTasksResponse type to proto

func FromAdminGetDLQReplicationMessagesRequest ¶

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

func FromAdminGetDLQReplicationMessagesResponse ¶

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

func FromAdminGetDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.8

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

func FromAdminGetDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.7

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

func FromAdminGetDomainIsolationGroupsRequest ¶ added in v1.2.7

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

func FromAdminGetDomainIsolationGroupsResponse ¶ added in v1.2.7

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

func FromAdminGetDomainReplicationMessagesRequest ¶

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

func FromAdminGetDomainReplicationMessagesResponse ¶

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

func FromAdminGetDynamicConfigRequest ¶ added in v1.2.7

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

FromAdminGetDynamicConfigRequest converts internal GetDynamicConfigRequest type to proto

func FromAdminGetDynamicConfigResponse ¶ added in v1.2.7

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

FromAdminGetDynamicConfigResponse converts internal GetDynamicConfigResponse type to proto

func FromAdminGetGlobalIsolationGroupsRequest ¶ added in v1.2.7

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

func FromAdminGetGlobalIsolationGroupsResponse ¶ added in v1.2.7

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

func FromAdminGetReplicationMessagesRequest ¶

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

func FromAdminGetReplicationMessagesResponse ¶

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

func FromAdminGetWorkflowExecutionRawHistoryV2Request ¶

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

func FromAdminGetWorkflowExecutionRawHistoryV2Response ¶

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

func FromAdminListDynamicConfigRequest ¶ added in v1.2.7

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

FromAdminListDynamicConfigRequest converts internal ListDynamicConfigRequest type to proto

func FromAdminListDynamicConfigResponse ¶ added in v1.2.7

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

FromAdminListDynamicConfigResponse converts internal ListDynamicConfigResponse type to proto

func FromAdminMaintainCorruptWorkflowRequest ¶ added in v1.2.7

func FromAdminMaintainCorruptWorkflowRequest(t *types.AdminMaintainWorkflowRequest) *adminv1.MaintainCorruptWorkflowRequest

FromAdminMaintainCorruptWorkflowRequest converts internal AdminMaintainWorkflowRequest type to proto

func FromAdminMaintainCorruptWorkflowResponse ¶ added in v1.2.7

func FromAdminMaintainCorruptWorkflowResponse(t *types.AdminMaintainWorkflowResponse) *adminv1.MaintainCorruptWorkflowResponse

FromAdminMaintainCorruptWorkflowResponse converts internal AdminMaintainWorkflowResponse type to proto

func FromAdminMergeDLQMessagesRequest ¶

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

func FromAdminMergeDLQMessagesResponse ¶

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

func FromAdminPurgeDLQMessagesRequest ¶

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

func FromAdminReadDLQMessagesRequest ¶

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

func FromAdminReadDLQMessagesResponse ¶

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

func FromAdminReapplyEventsRequest ¶

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

func FromAdminRefreshWorkflowTasksRequest ¶

func FromAdminRefreshWorkflowTasksRequest(t *types.RefreshWorkflowTasksRequest) *adminv1.RefreshWorkflowTasksRequest

func FromAdminRemoveTaskRequest ¶

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

func FromAdminResendReplicationTasksRequest ¶

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

func FromAdminResetQueueRequest ¶

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

func FromAdminRespondCrossClusterTasksCompletedRequest ¶ added in v0.24.0

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

FromAdminRespondCrossClusterTasksCompletedRequest converts internal RespondCrossClusterTasksCompletedRequest type to thrift

func FromAdminRespondCrossClusterTasksCompletedResponse ¶ added in v0.24.0

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

FromAdminRespondCrossClusterTasksCompletedResponse converts internal RespondCrossClusterTasksCompletedResponse type to thrift

func FromAdminRestoreDynamicConfigRequest ¶ added in v1.2.7

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

FromAdminRestoreDynamicConfigRequest converts internal RestoreDynamicConfigRequest type to proto

func FromAdminUpdateDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.8

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

func FromAdminUpdateDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.7

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

func FromAdminUpdateDomainIsolationGroupsRequest ¶ added in v1.2.7

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

func FromAdminUpdateDomainIsolationGroupsResponse ¶ added in v1.2.7

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

func FromAdminUpdateDynamicConfigRequest ¶ added in v1.2.7

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

FromAdminUpdateDynamicConfigRequest converts internal UpdateDynamicConfigRequest type to proto

func FromAdminUpdateGlobalIsolationGroupsRequest ¶ added in v1.2.7

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

func FromAdminUpdateGlobalIsolationGroupsResponse ¶ added in v1.2.7

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

func FromApplyParentClosePolicyAttributes ¶ added in v0.24.0

func FromApplyParentClosePolicyAttributes(t *types.ApplyParentClosePolicyAttributes) *adminv1.ApplyParentClosePolicyAttributes

FromApplyParentClosePolicyAttributes converts internal ApplyParentClosePolicyAttributes type to proto

func FromApplyParentClosePolicyResult ¶ added in v0.24.0

func FromApplyParentClosePolicyResult(t *types.ApplyParentClosePolicyResult) *adminv1.ApplyParentClosePolicyResult

FromApplyParentClosePolicyResult converts proto ApplyParentClosePolicyResult type to internal

func FromApplyParentClosePolicyStatus ¶ added in v0.24.0

func FromApplyParentClosePolicyStatus(t *types.ApplyParentClosePolicyStatus) *adminv1.ApplyParentClosePolicyStatus

FromApplyParentClosePolicyStatus converts internal ApplyParentClosePolicyStatus type to proto

func FromArchivalStatus ¶

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

func FromAsyncWorkflowKafkaQueueConfig ¶ added in v1.2.7

func FromAsyncWorkflowKafkaQueueConfig(in *types.AsyncWorkflowKafkaQueueConfiguration) *apiv1.AsyncWorkflowConfiguration_KafkaConfig

func FromBadBinaries ¶

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

func FromBadBinaryInfo ¶

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

func FromBadBinaryInfoMap ¶

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

func FromCancelExternalWorkflowExecutionFailedCause ¶

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

func FromCancelTimerDecisionAttributes ¶

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

func FromCancelTimerFailedEventAttributes ¶

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

func FromCancelWorkflowExecutionDecisionAttributes ¶

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

func FromChildWorkflowExecutionCanceledEventAttributes ¶

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

func FromChildWorkflowExecutionCompletedEventAttributes ¶

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

func FromChildWorkflowExecutionFailedCause ¶

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

func FromChildWorkflowExecutionFailedEventAttributes ¶

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

func FromChildWorkflowExecutionStartedEventAttributes ¶

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

func FromChildWorkflowExecutionTerminatedEventAttributes ¶

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

func FromChildWorkflowExecutionTimedOutEventAttributes ¶

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

func FromClusterReplicationConfiguration ¶

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

func FromClusterReplicationConfigurationArray ¶

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

func FromCompleteWorkflowExecutionDecisionAttributes ¶

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

func FromContinueAsNewInitiator ¶

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

func FromContinueAsNewWorkflowExecutionDecisionAttributes ¶

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

func FromCountWorkflowExecutionsRequest ¶

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

func FromCountWorkflowExecutionsResponse ¶

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

func FromCrossClusterApplyParentClosePolicyRequestAttributes ¶ added in v0.24.0

func FromCrossClusterApplyParentClosePolicyRequestAttributes(t *types.CrossClusterApplyParentClosePolicyRequestAttributes) *adminv1.CrossClusterApplyParentClosePolicyRequestAttributes

FromCrossClusterApplyParentClosePolicyRequestAttributes converts internal CrossClusterApplyParentClosePolicyRequestAttributes type to proto

func FromCrossClusterApplyParentClosePolicyResponseAttributes ¶ added in v0.24.0

func FromCrossClusterApplyParentClosePolicyResponseAttributes(t *types.CrossClusterApplyParentClosePolicyResponseAttributes) *adminv1.CrossClusterApplyParentClosePolicyResponseAttributes

FromCrossClusterApplyParentClosePolicyResponseAttributes converts internal CrossClusterApplyParentClosePolicyResponseAttributes type to proto

func FromCrossClusterCancelExecutionRequestAttributes ¶ added in v0.23.1

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

FromCrossClusterCancelExecutionRequestAttributes converts internal CrossClusterCancelExecutionRequestAttributes type to proto

func FromCrossClusterCancelExecutionResponseAttributes ¶ added in v0.23.1

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

FromCrossClusterCancelExecutionResponseAttributes converts internal CrossClusterCancelExecutionResponseAttributes type to proto

func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes ¶ added in v0.23.1

func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes

FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes converts internal CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes type to proto

func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes ¶ added in v0.23.1

func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes

FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes converts internal CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes type to proto

func FromCrossClusterSignalExecutionRequestAttributes ¶ added in v0.23.1

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

FromCrossClusterSignalExecutionRequestAttributes converts internal CrossClusterSignalExecutionRequestAttributes type to proto

func FromCrossClusterSignalExecutionResponseAttributes ¶ added in v0.23.1

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

FromCrossClusterSignalExecutionResponseAttributes converts internal CrossClusterSignalExecutionResponseAttributes type to proto

func FromCrossClusterStartChildExecutionRequestAttributes ¶ added in v0.23.1

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

FromCrossClusterStartChildExecutionRequestAttributes converts internal CrossClusterStartChildExecutionRequestAttributes type to proto

func FromCrossClusterStartChildExecutionResponseAttributes ¶ added in v0.23.1

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

FromCrossClusterStartChildExecutionResponseAttributes converts internal CrossClusterStartChildExecutionResponseAttributes type to proto

func FromCrossClusterTaskFailedCause ¶ added in v0.23.1

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

FromCrossClusterTaskFailedCause converts internal CrossClusterTaskFailedCause type to proto

func FromCrossClusterTaskInfo ¶ added in v0.23.1

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

FromCrossClusterTaskInfo converts internal CrossClusterTaskInfo type to proto

func FromCrossClusterTaskRequest ¶ added in v0.23.1

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

FromCrossClusterTaskRequest converts internal CrossClusterTaskRequest type to proto

func FromCrossClusterTaskRequestArray ¶ added in v0.23.1

func FromCrossClusterTaskRequestArray(t []*types.CrossClusterTaskRequest) *adminv1.CrossClusterTaskRequests

FromCrossClusterTaskRequestArray converts internal CrossClusterTaskRequest type array to proto

func FromCrossClusterTaskRequestMap ¶ added in v0.23.1

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

FromCrossClusterTaskRequestMap converts internal CrossClusterTaskRequest type map to proto

func FromCrossClusterTaskResponse ¶ added in v0.23.1

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

FromCrossClusterTaskResponse converts internal CrossClusterTaskResponse type to proto

func FromCrossClusterTaskResponseArray ¶ added in v0.23.1

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

FromCrossClusterTaskResponseArray converts internal CrossClusterTaskResponse type array to proto

func FromCrossClusterTaskType ¶ added in v0.23.1

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

FromCrossClusterTaskType converts internal CrossClusterTaskType type to proto

func FromDLQType ¶

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

func FromDataBlob ¶

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

func FromDataBlobArray ¶

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

func FromDecision ¶

func FromDecision(d *types.Decision) *apiv1.Decision

func FromDecisionArray ¶

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

func FromDecisionTaskCompletedEventAttributes ¶

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

func FromDecisionTaskFailedCause ¶

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

func FromDecisionTaskFailedEventAttributes ¶

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

func FromDecisionTaskScheduledEventAttributes ¶

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

func FromDecisionTaskStartedEventAttributes ¶

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

func FromDecisionTaskTimedOutCause ¶

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

func FromDecisionTaskTimedOutEventAttributes ¶

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

func FromDeprecateDomainRequest ¶

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

func FromDescribeDomainRequest ¶

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

func FromDescribeDomainResponse ¶

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

func FromDescribeDomainResponseArray ¶

func FromDescribeDomainResponseArray(t []*types.DescribeDomainResponse) []*apiv1.Domain

func FromDescribeDomainResponseDomain ¶

func FromDescribeDomainResponseDomain(t *types.DescribeDomainResponse) *apiv1.Domain

func FromDescribeTaskListRequest ¶

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

func FromDescribeTaskListResponse ¶

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

func FromDescribeTaskListResponseMap ¶ added in v0.24.0

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

func FromDescribeWorkflowExecutionRequest ¶

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

func FromDescribeWorkflowExecutionResponse ¶

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

func FromDomainAsyncWorkflowConfiguraton ¶ added in v1.2.7

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

func FromDomainCacheInfo ¶

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

func FromDomainOperation ¶

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

func FromDomainStatus ¶

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

func FromDomainTaskAttributes ¶

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

func FromDynamicConfigEntry ¶ added in v0.23.1

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

FromDynamicConfigEntry converts internal DynamicConfigEntry type to proto

func FromDynamicConfigEntryArray ¶ added in v0.23.1

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

FromDynamicConfigEntryArray converts internal DynamicConfigEntry array type to proto

func FromDynamicConfigFilter ¶ added in v0.23.1

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

FromDynamicConfigFilter converts internal DynamicConfigFilter type to proto

func FromDynamicConfigFilterArray ¶ added in v0.23.1

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

FromDynamicConfigFilterArray converts internal DynamicConfigFilter array type to proto

func FromDynamicConfigValue ¶ added in v0.23.1

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

FromDynamicConfigValue converts internal DynamicConfigValue type to proto

func FromDynamicConfigValueArray ¶ added in v0.23.1

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

FromDynamicConfigValueArray converts internal DynamicConfigValue array type to proto

func FromEncodingType ¶

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

func FromError ¶

func FromError(err error) error

func FromEventFilterType ¶

func FromEventFilterType(t *types.HistoryEventFilterType) apiv1.EventFilterType

func FromEventIDVersionPair ¶

func FromEventIDVersionPair(id, version *int64) *adminv1.VersionHistoryItem

func FromExternalExecutionInfoFields ¶

func FromExternalExecutionInfoFields(we *types.WorkflowExecution, initiatedID *int64) *apiv1.ExternalExecutionInfo

func FromExternalWorkflowExecutionCancelRequestedEventAttributes ¶

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

func FromExternalWorkflowExecutionSignaledEventAttributes ¶

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

func FromFailWorkflowExecutionDecisionAttributes ¶

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

func FromFailoverInfo ¶ added in v0.24.0

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

func FromFailoverMarkerAttributes ¶

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

func FromFailoverMarkerToken ¶

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

func FromFailoverMarkerTokenArray ¶

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

func FromFailure ¶

func FromFailure(reason *string, details []byte) *apiv1.Failure

func FromGetClusterInfoResponse ¶

func FromGetClusterInfoResponse(t *types.ClusterInfo) *apiv1.GetClusterInfoResponse

func FromGetSearchAttributesResponse ¶

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

func FromGetTaskFailedCause ¶ added in v0.23.1

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

FromGetTaskFailedCause converts internal GetTaskFailedCause type to proto

func FromGetTaskFailedCauseMap ¶ added in v0.23.1

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

FromGetTaskFailedCauseMap converts internal GetTaskFailedCause type map to proto

func FromGetTaskListsByDomainRequest ¶ added in v0.23.1

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

func FromGetTaskListsByDomainResponse ¶ added in v0.23.1

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

func FromGetWorkflowExecutionHistoryRequest ¶

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

func FromGetWorkflowExecutionHistoryResponse ¶

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

func FromHeader ¶

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

func FromHealthResponse ¶

func FromHealthResponse(t *types.HealthStatus) *apiv1.HealthResponse

func FromHistory ¶

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

func FromHistoryCloseShardRequest ¶

func FromHistoryCloseShardRequest(t *types.CloseShardRequest) *historyv1.CloseShardRequest

func FromHistoryCountDLQMessagesRequest ¶ added in v0.25.0

func FromHistoryCountDLQMessagesRequest(t *types.CountDLQMessagesRequest) *historyv1.CountDLQMessagesRequest

func FromHistoryCountDLQMessagesResponse ¶ added in v0.25.0

func FromHistoryCountDLQMessagesResponse(t *types.HistoryCountDLQMessagesResponse) *historyv1.CountDLQMessagesResponse

func FromHistoryDLQCountEntryMap ¶ added in v0.25.0

func FromHistoryDLQCountEntryMap(t map[types.HistoryDLQCountKey]int64) []*adminv1.HistoryDLQCountEntry

func FromHistoryDescribeHistoryHostRequest ¶

func FromHistoryDescribeHistoryHostRequest(t *types.DescribeHistoryHostRequest) *historyv1.DescribeHistoryHostRequest

func FromHistoryDescribeHistoryHostResponse ¶

func FromHistoryDescribeHistoryHostResponse(t *types.DescribeHistoryHostResponse) *historyv1.DescribeHistoryHostResponse

func FromHistoryDescribeMutableStateRequest ¶

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

func FromHistoryDescribeMutableStateResponse ¶

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

func FromHistoryDescribeQueueRequest ¶

func FromHistoryDescribeQueueRequest(t *types.DescribeQueueRequest) *historyv1.DescribeQueueRequest

func FromHistoryDescribeQueueResponse ¶

func FromHistoryDescribeQueueResponse(t *types.DescribeQueueResponse) *historyv1.DescribeQueueResponse

func FromHistoryDescribeWorkflowExecutionRequest ¶

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

func FromHistoryDescribeWorkflowExecutionResponse ¶

func FromHistoryDescribeWorkflowExecutionResponse(t *types.DescribeWorkflowExecutionResponse) *historyv1.DescribeWorkflowExecutionResponse

func FromHistoryEvent ¶

func FromHistoryEvent(e *types.HistoryEvent) *apiv1.HistoryEvent

func FromHistoryEventArray ¶

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

func FromHistoryGetCrossClusterTasksRequest ¶ added in v0.23.1

func FromHistoryGetCrossClusterTasksRequest(t *types.GetCrossClusterTasksRequest) *historyv1.GetCrossClusterTasksRequest

FromHistoryGetCrossClusterTasksRequest converts internal GetCrossClusterTasksRequest type to proto

func FromHistoryGetCrossClusterTasksResponse ¶ added in v0.23.1

func FromHistoryGetCrossClusterTasksResponse(t *types.GetCrossClusterTasksResponse) *historyv1.GetCrossClusterTasksResponse

FromHistoryGetCrossClusterTasksResponse converts internal GetCrossClusterTasksResponse type to proto

func FromHistoryGetDLQReplicationMessagesRequest ¶

func FromHistoryGetDLQReplicationMessagesRequest(t *types.GetDLQReplicationMessagesRequest) *historyv1.GetDLQReplicationMessagesRequest

func FromHistoryGetDLQReplicationMessagesResponse ¶

func FromHistoryGetDLQReplicationMessagesResponse(t *types.GetDLQReplicationMessagesResponse) *historyv1.GetDLQReplicationMessagesResponse

func FromHistoryGetFailoverInfoRequest ¶ added in v0.24.0

func FromHistoryGetFailoverInfoRequest(t *types.GetFailoverInfoRequest) *historyv1.GetFailoverInfoRequest

func FromHistoryGetFailoverInfoResponse ¶ added in v0.24.0

func FromHistoryGetFailoverInfoResponse(t *types.GetFailoverInfoResponse) *historyv1.GetFailoverInfoResponse

func FromHistoryGetMutableStateRequest ¶

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

func FromHistoryGetMutableStateResponse ¶

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

func FromHistoryGetReplicationMessagesRequest ¶

func FromHistoryGetReplicationMessagesRequest(t *types.GetReplicationMessagesRequest) *historyv1.GetReplicationMessagesRequest

func FromHistoryGetReplicationMessagesResponse ¶

func FromHistoryGetReplicationMessagesResponse(t *types.GetReplicationMessagesResponse) *historyv1.GetReplicationMessagesResponse

func FromHistoryMergeDLQMessagesRequest ¶

func FromHistoryMergeDLQMessagesRequest(t *types.MergeDLQMessagesRequest) *historyv1.MergeDLQMessagesRequest

func FromHistoryMergeDLQMessagesResponse ¶

func FromHistoryMergeDLQMessagesResponse(t *types.MergeDLQMessagesResponse) *historyv1.MergeDLQMessagesResponse

func FromHistoryNotifyFailoverMarkersRequest ¶

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

func FromHistoryPollMutableStateRequest ¶

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

func FromHistoryPollMutableStateResponse ¶

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

func FromHistoryPurgeDLQMessagesRequest ¶

func FromHistoryPurgeDLQMessagesRequest(t *types.PurgeDLQMessagesRequest) *historyv1.PurgeDLQMessagesRequest

func FromHistoryQueryWorkflowRequest ¶

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

func FromHistoryQueryWorkflowResponse ¶

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

func FromHistoryReadDLQMessagesRequest ¶

func FromHistoryReadDLQMessagesRequest(t *types.ReadDLQMessagesRequest) *historyv1.ReadDLQMessagesRequest

func FromHistoryReadDLQMessagesResponse ¶

func FromHistoryReadDLQMessagesResponse(t *types.ReadDLQMessagesResponse) *historyv1.ReadDLQMessagesResponse

func FromHistoryReapplyEventsRequest ¶

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

func FromHistoryRecordActivityTaskHeartbeatRequest ¶

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

func FromHistoryRecordActivityTaskHeartbeatResponse ¶

func FromHistoryRecordActivityTaskHeartbeatResponse(t *types.RecordActivityTaskHeartbeatResponse) *historyv1.RecordActivityTaskHeartbeatResponse

func FromHistoryRecordActivityTaskStartedRequest ¶

func FromHistoryRecordActivityTaskStartedRequest(t *types.RecordActivityTaskStartedRequest) *historyv1.RecordActivityTaskStartedRequest

func FromHistoryRecordActivityTaskStartedResponse ¶

func FromHistoryRecordActivityTaskStartedResponse(t *types.RecordActivityTaskStartedResponse) *historyv1.RecordActivityTaskStartedResponse

func FromHistoryRecordChildExecutionCompletedRequest ¶

func FromHistoryRecordChildExecutionCompletedRequest(t *types.RecordChildExecutionCompletedRequest) *historyv1.RecordChildExecutionCompletedRequest

func FromHistoryRecordDecisionTaskStartedRequest ¶

func FromHistoryRecordDecisionTaskStartedRequest(t *types.RecordDecisionTaskStartedRequest) *historyv1.RecordDecisionTaskStartedRequest

func FromHistoryRecordDecisionTaskStartedResponse ¶

func FromHistoryRecordDecisionTaskStartedResponse(t *types.RecordDecisionTaskStartedResponse) *historyv1.RecordDecisionTaskStartedResponse

func FromHistoryRefreshWorkflowTasksRequest ¶

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

func FromHistoryRemoveSignalMutableStateRequest ¶

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

func FromHistoryRemoveTaskRequest ¶

func FromHistoryRemoveTaskRequest(t *types.RemoveTaskRequest) *historyv1.RemoveTaskRequest

func FromHistoryReplicateEventsV2Request ¶

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

func FromHistoryRequestCancelWorkflowExecutionRequest ¶

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

func FromHistoryResetQueueRequest ¶

func FromHistoryResetQueueRequest(t *types.ResetQueueRequest) *historyv1.ResetQueueRequest

func FromHistoryResetStickyTaskListRequest ¶

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

func FromHistoryResetStickyTaskListResponse ¶ added in v1.2.7

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

func FromHistoryResetWorkflowExecutionRequest ¶

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

func FromHistoryResetWorkflowExecutionResponse ¶

func FromHistoryResetWorkflowExecutionResponse(t *types.ResetWorkflowExecutionResponse) *historyv1.ResetWorkflowExecutionResponse

func FromHistoryRespondActivityTaskCanceledRequest ¶

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

func FromHistoryRespondActivityTaskCompletedRequest ¶

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

func FromHistoryRespondActivityTaskFailedRequest ¶

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

func FromHistoryRespondCrossClusterTasksCompletedRequest ¶ added in v0.23.1

func FromHistoryRespondCrossClusterTasksCompletedRequest(t *types.RespondCrossClusterTasksCompletedRequest) *historyv1.RespondCrossClusterTasksCompletedRequest

FromHistoryRespondCrossClusterTasksCompletedRequest converts internal RespondCrossClusterTasksCompletedRequest type to thrift

func FromHistoryRespondCrossClusterTasksCompletedResponse ¶ added in v0.23.1

func FromHistoryRespondCrossClusterTasksCompletedResponse(t *types.RespondCrossClusterTasksCompletedResponse) *historyv1.RespondCrossClusterTasksCompletedResponse

FromHistoryRespondCrossClusterTasksCompletedResponse converts internal RespondCrossClusterTasksCompletedResponse type to thrift

func FromHistoryRespondDecisionTaskCompletedRequest ¶

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

func FromHistoryRespondDecisionTaskCompletedResponse ¶

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

func FromHistoryRespondDecisionTaskFailedRequest ¶

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

func FromHistoryScheduleDecisionTaskRequest ¶

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

func FromHistorySignalWithStartWorkflowExecutionRequest ¶

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

func FromHistorySignalWithStartWorkflowExecutionResponse ¶

func FromHistorySignalWithStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *historyv1.SignalWithStartWorkflowExecutionResponse

func FromHistorySignalWorkflowExecutionRequest ¶

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

func FromHistoryStartWorkflowExecutionRequest ¶

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

func FromHistoryStartWorkflowExecutionResponse ¶

func FromHistoryStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *historyv1.StartWorkflowExecutionResponse

func FromHistorySyncActivityRequest ¶

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

func FromHistorySyncShardStatusRequest ¶

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

func FromHistoryTaskV2Attributes ¶

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

func FromHistoryTerminateWorkflowExecutionRequest ¶

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

func FromHostInfo ¶

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

func FromHostInfoArray ¶

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

func FromIndexedValueType ¶

func FromIndexedValueType(t types.IndexedValueType) apiv1.IndexedValueType

func FromIndexedValueTypeMap ¶

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

func FromIsolationGroupConfig ¶ added in v1.2.1

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

func FromListArchivedWorkflowExecutionsRequest ¶

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

func FromListArchivedWorkflowExecutionsResponse ¶

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

func FromListClosedWorkflowExecutionsRequest ¶

func FromListClosedWorkflowExecutionsRequest(r *types.ListClosedWorkflowExecutionsRequest) *apiv1.ListClosedWorkflowExecutionsRequest

func FromListClosedWorkflowExecutionsResponse ¶

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

func FromListDomainsRequest ¶

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

func FromListDomainsResponse ¶

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

func FromListOpenWorkflowExecutionsRequest ¶

func FromListOpenWorkflowExecutionsRequest(r *types.ListOpenWorkflowExecutionsRequest) *apiv1.ListOpenWorkflowExecutionsRequest

func FromListOpenWorkflowExecutionsResponse ¶

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

func FromListTaskListPartitionsRequest ¶

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

func FromListTaskListPartitionsResponse ¶

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

func FromListWorkflowExecutionsRequest ¶

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

func FromListWorkflowExecutionsResponse ¶

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

func FromMarkerRecordedEventAttributes ¶

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

func FromMatchingAddActivityTaskRequest ¶

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

func FromMatchingAddDecisionTaskRequest ¶

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

func FromMatchingCancelOutstandingPollRequest ¶

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

func FromMatchingDescribeTaskListRequest ¶

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

func FromMatchingDescribeTaskListResponse ¶

func FromMatchingDescribeTaskListResponse(t *types.DescribeTaskListResponse) *matchingv1.DescribeTaskListResponse

func FromMatchingDescribeTaskListResponseMap ¶ added in v0.24.0

func FromMatchingDescribeTaskListResponseMap(t map[string]*types.DescribeTaskListResponse) map[string]*matchingv1.DescribeTaskListResponse

func FromMatchingGetTaskListsByDomainRequest ¶ added in v0.23.1

func FromMatchingGetTaskListsByDomainRequest(t *types.GetTaskListsByDomainRequest) *matchingv1.GetTaskListsByDomainRequest

func FromMatchingGetTaskListsByDomainResponse ¶ added in v0.23.1

func FromMatchingGetTaskListsByDomainResponse(t *types.GetTaskListsByDomainResponse) *matchingv1.GetTaskListsByDomainResponse

func FromMatchingListTaskListPartitionsRequest ¶

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

func FromMatchingListTaskListPartitionsResponse ¶

func FromMatchingListTaskListPartitionsResponse(t *types.ListTaskListPartitionsResponse) *matchingv1.ListTaskListPartitionsResponse

func FromMatchingPollForActivityTaskRequest ¶

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

func FromMatchingPollForActivityTaskResponse ¶

func FromMatchingPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *matchingv1.PollForActivityTaskResponse

func FromMatchingPollForDecisionTaskRequest ¶

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

func FromMatchingPollForDecisionTaskResponse ¶

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

func FromMatchingQueryWorkflowRequest ¶

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

func FromMatchingQueryWorkflowResponse ¶

func FromMatchingQueryWorkflowResponse(t *types.QueryWorkflowResponse) *matchingv1.QueryWorkflowResponse

func FromMatchingRespondQueryTaskCompletedRequest ¶

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

func FromMembershipInfo ¶

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

func FromMemo ¶

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

func FromParentClosePolicy ¶

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

func FromParentExecutionInfo ¶

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

func FromParentExecutionInfoFields ¶

func FromParentExecutionInfoFields(domainID, domainName *string, we *types.WorkflowExecution, initiatedID *int64) *apiv1.ParentExecutionInfo

func FromPayload ¶

func FromPayload(data []byte) *apiv1.Payload

func FromPayloadMap ¶

func FromPayloadMap(t map[string][]byte) map[string]*apiv1.Payload

func FromPendingActivityInfo ¶

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

func FromPendingActivityInfoArray ¶

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

func FromPendingActivityState ¶

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

func FromPendingChildExecutionInfo ¶

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

func FromPendingChildExecutionInfoArray ¶

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

func FromPendingDecisionInfo ¶

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

func FromPendingDecisionState ¶

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

func FromPersistenceFeature ¶ added in v0.21.0

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

func FromPersistenceFeatures ¶ added in v0.21.0

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

func FromPersistenceInfo ¶ added in v0.21.0

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

func FromPersistenceInfoMap ¶ added in v0.21.0

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

func FromPersistenceSetting ¶ added in v0.21.0

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

func FromPersistenceSettings ¶ added in v0.21.0

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

func FromPollForActivityTaskRequest ¶

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

func FromPollForActivityTaskResponse ¶

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

func FromPollForDecisionTaskRequest ¶

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

func FromPollForDecisionTaskResponse ¶

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

func FromPollerInfo ¶

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

func FromPollerInfoArray ¶

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

func FromQueryConsistencyLevel ¶

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

func FromQueryRejectCondition ¶

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

func FromQueryRejected ¶

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

func FromQueryResultType ¶

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

func FromQueryTaskCompletedType ¶

func FromQueryTaskCompletedType(t *types.QueryTaskCompletedType) apiv1.QueryResultType

func FromQueryWorkflowRequest ¶

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

func FromQueryWorkflowResponse ¶

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

func FromRecordActivityTaskHeartbeatByIDRequest ¶

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

func FromRecordActivityTaskHeartbeatByIDResponse ¶

func FromRecordActivityTaskHeartbeatByIDResponse(t *types.RecordActivityTaskHeartbeatResponse) *apiv1.RecordActivityTaskHeartbeatByIDResponse

func FromRecordActivityTaskHeartbeatRequest ¶

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

func FromRecordActivityTaskHeartbeatResponse ¶

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

func FromRecordMarkerDecisionAttributes ¶

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

func FromRefreshWorkflowTasksRequest ¶ added in v0.24.0

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

func FromRegisterDomainRequest ¶

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

func FromReplicationMessages ¶

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

func FromReplicationMessagesMap ¶

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

func FromReplicationTask ¶

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

func FromReplicationTaskArray ¶

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

func FromReplicationTaskInfo ¶

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

func FromReplicationTaskInfoArray ¶

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

func FromReplicationTaskType ¶

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

func FromReplicationToken ¶

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

func FromReplicationTokenArray ¶

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

func FromRequestCancelActivityTaskDecisionAttributes ¶

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

func FromRequestCancelActivityTaskFailedEventAttributes ¶

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

func FromRequestCancelExternalWorkflowExecutionDecisionAttributes ¶

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

func FromRequestCancelExternalWorkflowExecutionFailedEventAttributes ¶

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

func FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶

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

func FromRequestCancelWorkflowExecutionRequest ¶

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

func FromResetPointInfo ¶

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

func FromResetPointInfoArray ¶

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

func FromResetPoints ¶

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

func FromResetStickyTaskListRequest ¶

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

func FromResetStickyTaskListResponse ¶ added in v1.2.7

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

func FromResetWorkflowExecutionRequest ¶

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

func FromResetWorkflowExecutionResponse ¶

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

func FromRespondActivityTaskCanceledByIDRequest ¶

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

func FromRespondActivityTaskCanceledRequest ¶

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

func FromRespondActivityTaskCompletedByIDRequest ¶

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

func FromRespondActivityTaskCompletedRequest ¶

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

func FromRespondActivityTaskFailedByIDRequest ¶

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

func FromRespondActivityTaskFailedRequest ¶

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

func FromRespondDecisionTaskCompletedRequest ¶

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

func FromRespondDecisionTaskCompletedResponse ¶

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

func FromRespondDecisionTaskFailedRequest ¶

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

func FromRespondQueryTaskCompletedRequest ¶

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

func FromRestartWorkflowExecutionRequest ¶ added in v0.25.0

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

func FromRestartWorkflowExecutionResponse ¶ added in v0.25.0

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

func FromRetryPolicy ¶

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

func FromRingInfo ¶

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

func FromRingInfoArray ¶

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

func FromScanWorkflowExecutionsRequest ¶

func FromScanWorkflowExecutionsRequest(t *types.ListWorkflowExecutionsRequest) *apiv1.ScanWorkflowExecutionsRequest

func FromScanWorkflowExecutionsResponse ¶

func FromScanWorkflowExecutionsResponse(t *types.ListWorkflowExecutionsResponse) *apiv1.ScanWorkflowExecutionsResponse

func FromScheduleActivityTaskDecisionAttributes ¶

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

func FromSearchAttributes ¶

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

func FromSignalExternalWorkflowExecutionDecisionAttributes ¶

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

func FromSignalExternalWorkflowExecutionFailedCause ¶

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

func FromSignalExternalWorkflowExecutionFailedEventAttributes ¶

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

func FromSignalExternalWorkflowExecutionInitiatedEventAttributes ¶

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

func FromSignalWithStartWorkflowExecutionRequest ¶

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

func FromSignalWithStartWorkflowExecutionResponse ¶

func FromSignalWithStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *apiv1.SignalWithStartWorkflowExecutionResponse

func FromSignalWorkflowExecutionRequest ¶

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

func FromStartChildWorkflowExecutionDecisionAttributes ¶

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

func FromStartChildWorkflowExecutionFailedEventAttributes ¶

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

func FromStartChildWorkflowExecutionInitiatedEventAttributes ¶

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

func FromStartTimeFilter ¶

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

func FromStartTimerDecisionAttributes ¶

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

func FromStartWorkflowExecutionAsyncRequest ¶ added in v1.2.8

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

func FromStartWorkflowExecutionAsyncResponse ¶ added in v1.2.8

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

func FromStartWorkflowExecutionRequest ¶

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

func FromStartWorkflowExecutionResponse ¶

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

func FromStatusFilter ¶

func FromStatusFilter(t *types.WorkflowExecutionCloseStatus) *apiv1.StatusFilter

func FromStickyExecutionAttributes ¶

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

func FromSupportedClientVersions ¶

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

func FromSyncActivityTaskAttributes ¶

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

func FromSyncShardStatus ¶

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

func FromSyncShardStatusTaskAttributes ¶

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

func FromTaskIDBlock ¶

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

func FromTaskList ¶

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

func FromTaskListKind ¶

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

func FromTaskListMetadata ¶

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

func FromTaskListPartitionMetadata ¶

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

func FromTaskListPartitionMetadataArray ¶

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

func FromTaskListStatus ¶

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

func FromTaskListType ¶

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

func FromTaskSource ¶

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

func FromTaskType ¶

func FromTaskType(t *int32) adminv1.TaskType

func FromTerminateWorkflowExecutionRequest ¶

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

func FromTimeoutType ¶

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

func FromTimerCanceledEventAttributes ¶

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

func FromTimerFiredEventAttributes ¶

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

func FromTimerStartedEventAttributes ¶

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

func FromTransientDecisionInfo ¶

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

func FromUpdateDomainRequest ¶

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

func FromUpdateDomainResponse ¶

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

func FromUpsertWorkflowSearchAttributesDecisionAttributes ¶

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

func FromUpsertWorkflowSearchAttributesEventAttributes ¶

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

func FromVersionHistories ¶

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

func FromVersionHistory ¶

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

func FromVersionHistoryArray ¶

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

func FromVersionHistoryItem ¶

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

func FromVersionHistoryItemArray ¶

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

func FromWorkerVersionInfo ¶

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

func FromWorkflowExecution ¶

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

func FromWorkflowExecutionCancelRequestedEventAttributes ¶

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

func FromWorkflowExecutionCanceledEventAttributes ¶

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

func FromWorkflowExecutionCloseStatus ¶

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

func FromWorkflowExecutionCompletedEventAttributes ¶

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

func FromWorkflowExecutionConfiguration ¶

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

func FromWorkflowExecutionContinuedAsNewEventAttributes ¶

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

func FromWorkflowExecutionFailedEventAttributes ¶

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

func FromWorkflowExecutionFilter ¶

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

func FromWorkflowExecutionInfo ¶

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

func FromWorkflowExecutionInfoArray ¶

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

func FromWorkflowExecutionSignaledEventAttributes ¶

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

func FromWorkflowExecutionStartedEventAttributes ¶

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

func FromWorkflowExecutionTerminatedEventAttributes ¶

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

func FromWorkflowExecutionTimedOutEventAttributes ¶

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

func FromWorkflowIDReusePolicy ¶

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

func FromWorkflowQuery ¶

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

func FromWorkflowQueryMap ¶

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

func FromWorkflowQueryResult ¶

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

func FromWorkflowQueryResultMap ¶

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

func FromWorkflowRunPair ¶

func FromWorkflowRunPair(workflowID, runID string) *apiv1.WorkflowExecution

func FromWorkflowState ¶

func FromWorkflowState(t *int32) sharedv1.WorkflowState

func FromWorkflowType ¶

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

func FromWorkflowTypeFilter ¶

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

func ToActivityLocalDispatchInfo ¶

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

func ToActivityLocalDispatchInfoMap ¶

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

func ToActivityTaskCancelRequestedEventAttributes ¶

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

func ToActivityTaskCanceledEventAttributes ¶

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

func ToActivityTaskCompletedEventAttributes ¶

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

func ToActivityTaskDispatchInfo ¶ added in v0.24.0

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

func ToActivityTaskFailedEventAttributes ¶

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

func ToActivityTaskScheduledEventAttributes ¶

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

func ToActivityTaskStartedEventAttributes ¶

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

func ToActivityTaskTimedOutEventAttributes ¶

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

func ToActivityType ¶

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

func ToAdminAddSearchAttributeRequest ¶

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

func ToAdminCloseShardRequest ¶

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

func ToAdminCountDLQMessagesRequest ¶ added in v0.25.0

func ToAdminCountDLQMessagesRequest(t *adminv1.CountDLQMessagesRequest) *types.CountDLQMessagesRequest

func ToAdminCountDLQMessagesResponse ¶ added in v0.25.0

func ToAdminCountDLQMessagesResponse(t *adminv1.CountDLQMessagesResponse) *types.CountDLQMessagesResponse

func ToAdminDeleteWorkflowRequest ¶ added in v0.24.0

func ToAdminDeleteWorkflowRequest(t *adminv1.DeleteWorkflowRequest) *types.AdminDeleteWorkflowRequest

ToAdminDeleteWorkflowRequest converts proto AdminDeleteWorkflowRequest type to internal

func ToAdminDeleteWorkflowResponse ¶ added in v0.24.0

func ToAdminDeleteWorkflowResponse(t *adminv1.DeleteWorkflowResponse) *types.AdminDeleteWorkflowResponse

ToAdminDeleteWorkflowResponse converts proto AdminDeleteWorkflowResponse type to internal

func ToAdminDescribeClusterResponse ¶

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

func ToAdminDescribeHistoryHostRequest ¶

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

func ToAdminDescribeHistoryHostResponse ¶

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

func ToAdminDescribeQueueRequest ¶

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

func ToAdminDescribeQueueResponse ¶

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

func ToAdminDescribeShardDistributionRequest ¶ added in v0.22.0

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

func ToAdminDescribeShardDistributionResponse ¶ added in v0.22.0

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

func ToAdminDescribeWorkflowExecutionRequest ¶

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

func ToAdminDescribeWorkflowExecutionResponse ¶

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

func ToAdminGetCrossClusterTasksRequest ¶ added in v0.23.1

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

ToAdminGetCrossClusterTasksRequest converts proto GetCrossClusterTasksRequest type to internal

func ToAdminGetCrossClusterTasksResponse ¶ added in v0.23.1

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

ToAdminGetCrossClusterTasksResponse converts proto GetCrossClusterTasksResponse type to internal

func ToAdminGetDLQReplicationMessagesRequest ¶

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

func ToAdminGetDLQReplicationMessagesResponse ¶

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

func ToAdminGetDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.7

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

func ToAdminGetDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.8

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

func ToAdminGetDomainIsolationGroupsRequest ¶ added in v1.2.7

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

func ToAdminGetDomainIsolationGroupsResponse ¶ added in v1.2.7

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

func ToAdminGetDomainReplicationMessagesRequest ¶

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

func ToAdminGetDomainReplicationMessagesResponse ¶

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

func ToAdminGetDynamicConfigRequest ¶ added in v1.2.7

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

ToAdminGetDynamicConfigRequest converts proto GetDynamicConfigRequest type to internal

func ToAdminGetDynamicConfigResponse ¶ added in v1.2.7

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

ToAdminGetDynamicConfigResponse converts proto GetDynamicConfigResponse type to internal

func ToAdminGetGlobalIsolationGroupsRequest ¶ added in v1.2.7

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

func ToAdminGetGlobalIsolationGroupsResponse ¶ added in v1.2.7

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

func ToAdminGetReplicationMessagesRequest ¶

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

func ToAdminGetReplicationMessagesResponse ¶

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

func ToAdminGetWorkflowExecutionRawHistoryV2Request ¶

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

func ToAdminGetWorkflowExecutionRawHistoryV2Response ¶

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

func ToAdminListDynamicConfigRequest ¶ added in v1.2.7

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

ToAdminListDynamicConfigRequest converts proto ListDynamicConfigRequest type to internal

func ToAdminListDynamicConfigResponse ¶ added in v1.2.7

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

ToAdminListDynamicConfigResponse converts proto ListDynamicConfigResponse type to internal

func ToAdminMaintainCorruptWorkflowRequest ¶ added in v1.2.7

func ToAdminMaintainCorruptWorkflowRequest(t *adminv1.MaintainCorruptWorkflowRequest) *types.AdminMaintainWorkflowRequest

ToAdminMaintainCorruptWorkflowRequest converts proto AdminMaintainWorkflowRequest type to internal

func ToAdminMaintainCorruptWorkflowResponse ¶ added in v1.2.7

func ToAdminMaintainCorruptWorkflowResponse(t *adminv1.MaintainCorruptWorkflowResponse) *types.AdminMaintainWorkflowResponse

ToAdminMaintainCorruptWorkflowResponse converts proto AdminMaintainWorkflowResponse type to internal

func ToAdminMergeDLQMessagesRequest ¶

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

func ToAdminMergeDLQMessagesResponse ¶

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

func ToAdminPurgeDLQMessagesRequest ¶

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

func ToAdminReadDLQMessagesRequest ¶

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

func ToAdminReadDLQMessagesResponse ¶

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

func ToAdminReapplyEventsRequest ¶

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

func ToAdminRefreshWorkflowTasksRequest ¶

func ToAdminRefreshWorkflowTasksRequest(t *adminv1.RefreshWorkflowTasksRequest) *types.RefreshWorkflowTasksRequest

func ToAdminRemoveTaskRequest ¶

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

func ToAdminResendReplicationTasksRequest ¶

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

func ToAdminResetQueueRequest ¶

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

func ToAdminRespondCrossClusterTasksCompletedRequest ¶ added in v0.24.0

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

ToAdminRespondCrossClusterTasksCompletedRequest converts thrift RespondCrossClusterTasksCompletedRequest type to internal

func ToAdminRespondCrossClusterTasksCompletedResponse ¶ added in v0.24.0

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

ToAdminRespondCrossClusterTasksCompletedResponse converts thrift RespondCrossClusterTasksCompletedResponse type to internal

func ToAdminRestoreDynamicConfigRequest ¶ added in v1.2.7

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

ToAdminRestoreDynamicConfigRequest converts proto RestoreDynamicConfigRequest type to internal

func ToAdminUpdateDomainAsyncWorkflowConfiguratonRequest ¶ added in v1.2.7

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

func ToAdminUpdateDomainAsyncWorkflowConfiguratonResponse ¶ added in v1.2.8

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

func ToAdminUpdateDomainIsolationGroupsRequest ¶ added in v1.2.7

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

func ToAdminUpdateDomainIsolationGroupsResponse ¶ added in v1.2.7

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

func ToAdminUpdateDynamicConfigRequest ¶ added in v1.2.7

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

ToAdminUpdateDynamicConfigRequest converts proto UpdateDynamicConfigRequest type to internal

func ToAdminUpdateGlobalIsolationGroupsRequest ¶ added in v1.2.7

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

func ToAdminUpdateGlobalIsolationGroupsResponse ¶ added in v1.2.7

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

func ToApplyParentClosePolicyAttributes ¶ added in v0.24.0

func ToApplyParentClosePolicyAttributes(t *adminv1.ApplyParentClosePolicyAttributes) *types.ApplyParentClosePolicyAttributes

ToApplyParentClosePolicyAttributes converts proto ApplyParentClosePolicyAttributes type to internal

func ToApplyParentClosePolicyResult ¶ added in v0.24.0

func ToApplyParentClosePolicyResult(t *adminv1.ApplyParentClosePolicyResult) *types.ApplyParentClosePolicyResult

ToApplyParentClosePolicyResult converts proto ApplyParentClosePolicyResult type to internal

func ToApplyParentClosePolicyStatus ¶ added in v0.24.0

func ToApplyParentClosePolicyStatus(t *adminv1.ApplyParentClosePolicyStatus) *types.ApplyParentClosePolicyStatus

ToApplyParentClosePolicyStatus converts proto ApplyParentClosePolicyStatus type to internal

func ToArchivalStatus ¶

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

func ToAsyncWorkflowKafkaQueueConfig ¶ added in v1.2.7

func ToAsyncWorkflowKafkaQueueConfig(in *apiv1.AsyncWorkflowKafkaQueueConfiguration) *types.AsyncWorkflowKafkaQueueConfiguration

func ToBadBinaries ¶

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

func ToBadBinaryInfo ¶

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

func ToBadBinaryInfoMap ¶

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

func ToCancelExternalWorkflowExecutionFailedCause ¶

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

func ToCancelTimerDecisionAttributes ¶

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

func ToCancelTimerFailedEventAttributes ¶

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

func ToCancelWorkflowExecutionDecisionAttributes ¶

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

func ToChildWorkflowExecutionCanceledEventAttributes ¶

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

func ToChildWorkflowExecutionCompletedEventAttributes ¶

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

func ToChildWorkflowExecutionFailedCause ¶

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

func ToChildWorkflowExecutionFailedEventAttributes ¶

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

func ToChildWorkflowExecutionStartedEventAttributes ¶

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

func ToChildWorkflowExecutionTerminatedEventAttributes ¶

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

func ToChildWorkflowExecutionTimedOutEventAttributes ¶

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

func ToClusterReplicationConfiguration ¶

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

func ToClusterReplicationConfigurationArray ¶

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

func ToCompleteWorkflowExecutionDecisionAttributes ¶

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

func ToContinueAsNewInitiator ¶

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

func ToContinueAsNewWorkflowExecutionDecisionAttributes ¶

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

func ToCountWorkflowExecutionsRequest ¶

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

func ToCountWorkflowExecutionsResponse ¶

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

func ToCrossClusterApplyParentClosePolicyRequestAttributes ¶ added in v0.24.0

func ToCrossClusterApplyParentClosePolicyRequestAttributes(t *adminv1.CrossClusterApplyParentClosePolicyRequestAttributes) *types.CrossClusterApplyParentClosePolicyRequestAttributes

ToCrossClusterApplyParentClosePolicyRequestAttributes converts proto CrossClusterApplyParentClosePolicyRequestAttributes type to internal

func ToCrossClusterApplyParentClosePolicyResponseAttributes ¶ added in v0.24.0

func ToCrossClusterApplyParentClosePolicyResponseAttributes(t *adminv1.CrossClusterApplyParentClosePolicyResponseAttributes) *types.CrossClusterApplyParentClosePolicyResponseAttributes

ToCrossClusterApplyParentClosePolicyResponseAttributes converts proto CrossClusterApplyParentClosePolicyResponseAttributes type to internal

func ToCrossClusterCancelExecutionRequestAttributes ¶ added in v0.23.1

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

ToCrossClusterCancelExecutionRequestAttributes converts proto CrossClusterCancelExecutionRequestAttributes type to internal

func ToCrossClusterCancelExecutionResponseAttributes ¶ added in v0.23.1

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

ToCrossClusterCancelExecutionResponseAttributes converts proto CrossClusterCancelExecutionResponseAttributes type to internal

func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes ¶ added in v0.23.1

func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes

ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes converts proto CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes type to internal

func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes ¶ added in v0.23.1

func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *adminv1.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes

ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes converts proto CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes type to internal

func ToCrossClusterSignalExecutionRequestAttributes ¶ added in v0.23.1

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

ToCrossClusterSignalExecutionRequestAttributes converts proto CrossClusterSignalExecutionRequestAttributes type to internal

func ToCrossClusterSignalExecutionResponseAttributes ¶ added in v0.23.1

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

ToCrossClusterSignalExecutionResponseAttributes converts proto CrossClusterSignalExecutionResponseAttributes type to internal

func ToCrossClusterStartChildExecutionRequestAttributes ¶ added in v0.23.1

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

ToCrossClusterStartChildExecutionRequestAttributes converts proto CrossClusterStartChildExecutionRequestAttributes type to internal

func ToCrossClusterStartChildExecutionResponseAttributes ¶ added in v0.23.1

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

ToCrossClusterStartChildExecutionResponseAttributes converts proto CrossClusterStartChildExecutionResponseAttributes type to internal

func ToCrossClusterTaskFailedCause ¶ added in v0.23.1

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

ToCrossClusterTaskFailedCause converts proto CrossClusterTaskFailedCause type to internal

func ToCrossClusterTaskInfo ¶ added in v0.23.1

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

ToCrossClusterTaskInfo converts proto CrossClusterTaskInfo type to internal

func ToCrossClusterTaskRequest ¶ added in v0.23.1

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

ToCrossClusterTaskRequest converts proto CrossClusterTaskRequest type to internal

func ToCrossClusterTaskRequestArray ¶ added in v0.23.1

func ToCrossClusterTaskRequestArray(t *adminv1.CrossClusterTaskRequests) []*types.CrossClusterTaskRequest

ToCrossClusterTaskRequestArray converts proto CrossClusterTaskRequest type array to internal

func ToCrossClusterTaskRequestMap ¶ added in v0.23.1

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

ToCrossClusterTaskRequestMap converts proto CrossClusterTaskRequest type map to internal

func ToCrossClusterTaskResponse ¶ added in v0.23.1

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

ToCrossClusterTaskResponse converts proto CrossClusterTaskResponse type to internal

func ToCrossClusterTaskResponseArray ¶ added in v0.23.1

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

ToCrossClusterTaskResponseArray converts proto CrossClusterTaskResponse type array to internal

func ToCrossClusterTaskType ¶ added in v0.23.1

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

ToCrossClusterTaskType converts proto CrossClusterTaskType type to internal

func ToDLQType ¶

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

func ToDataBlob ¶

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

func ToDataBlobArray ¶

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

func ToDecision ¶

func ToDecision(d *apiv1.Decision) *types.Decision

func ToDecisionArray ¶

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

func ToDecisionTaskCompletedEventAttributes ¶

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

func ToDecisionTaskFailedCause ¶

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

func ToDecisionTaskFailedEventAttributes ¶

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

func ToDecisionTaskScheduledEventAttributes ¶

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

func ToDecisionTaskStartedEventAttributes ¶

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

func ToDecisionTaskTimedOutCause ¶

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

func ToDecisionTaskTimedOutEventAttributes ¶

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

func ToDeprecateDomainRequest ¶

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

func ToDescribeDomainRequest ¶

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

func ToDescribeDomainResponse ¶

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

func ToDescribeDomainResponseArray ¶

func ToDescribeDomainResponseArray(t []*apiv1.Domain) []*types.DescribeDomainResponse

func ToDescribeDomainResponseDomain ¶

func ToDescribeDomainResponseDomain(t *apiv1.Domain) *types.DescribeDomainResponse

func ToDescribeTaskListRequest ¶

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

func ToDescribeTaskListResponse ¶

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

func ToDescribeTaskListResponseMap ¶ added in v0.24.0

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

func ToDescribeWorkflowExecutionRequest ¶

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

func ToDescribeWorkflowExecutionResponse ¶

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

func ToDomainAsyncWorkflowConfiguraton ¶ added in v1.2.7

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

func ToDomainCacheInfo ¶

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

func ToDomainOperation ¶

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

func ToDomainStatus ¶

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

func ToDomainTaskAttributes ¶

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

func ToDynamicConfigEntry ¶ added in v0.23.1

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

ToDynamicConfigEntry converts proto DynamicConfigEntry type to internal

func ToDynamicConfigEntryArray ¶ added in v0.23.1

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

ToDynamicConfigEntryArray converts proto DynamicConfigEntry array type to internal

func ToDynamicConfigFilter ¶ added in v0.23.1

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

ToDynamicConfigFilter converts thrift DynamicConfigFilter type to internal

func ToDynamicConfigFilterArray ¶ added in v0.23.1

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

ToDynamicConfigFilterArray converts proto DynamicConfigFilter array type to internal

func ToDynamicConfigValue ¶ added in v0.23.1

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

ToDynamicConfigValue converts proto DynamicConfigValue type to internal

func ToDynamicConfigValueArray ¶ added in v0.23.1

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

ToDynamicConfigValueArray converts proto DynamicConfigValue array type to internal

func ToEncodingType ¶

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

func ToError ¶

func ToError(err error) error

func ToEventFilterType ¶

func ToEventFilterType(t apiv1.EventFilterType) *types.HistoryEventFilterType

func ToEventID ¶

func ToEventID(item *adminv1.VersionHistoryItem) *int64

func ToEventVersion ¶

func ToEventVersion(item *adminv1.VersionHistoryItem) *int64

func ToExternalInitiatedID ¶

func ToExternalInitiatedID(t *apiv1.ExternalExecutionInfo) *int64

func ToExternalWorkflowExecution ¶

func ToExternalWorkflowExecution(t *apiv1.ExternalExecutionInfo) *types.WorkflowExecution

func ToExternalWorkflowExecutionCancelRequestedEventAttributes ¶

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

func ToExternalWorkflowExecutionSignaledEventAttributes ¶

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

func ToFailWorkflowExecutionDecisionAttributes ¶

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

func ToFailoverInfo ¶ added in v0.24.0

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

func ToFailoverMarkerAttributes ¶

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

func ToFailoverMarkerToken ¶

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

func ToFailoverMarkerTokenArray ¶

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

func ToFailureDetails ¶

func ToFailureDetails(failure *apiv1.Failure) []byte

func ToFailureReason ¶

func ToFailureReason(failure *apiv1.Failure) *string

func ToGetClusterInfoResponse ¶

func ToGetClusterInfoResponse(t *apiv1.GetClusterInfoResponse) *types.ClusterInfo

func ToGetSearchAttributesResponse ¶

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

func ToGetTaskFailedCause ¶ added in v0.23.1

func ToGetTaskFailedCause(t adminv1.GetTaskFailedCause) *types.GetTaskFailedCause

ToGetTaskFailedCause converts proto GetTaskFailedCause type to internal

func ToGetTaskFailedCauseMap ¶ added in v0.23.1

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

ToGetTaskFailedCauseMap converts proto GetTaskFailedCause type map to internal

func ToGetTaskListsByDomainRequest ¶ added in v0.23.1

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

func ToGetTaskListsByDomainResponse ¶ added in v0.23.1

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

func ToGetWorkflowExecutionHistoryRequest ¶

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

func ToGetWorkflowExecutionHistoryResponse ¶

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

func ToHeader ¶

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

func ToHealthResponse ¶

func ToHealthResponse(t *apiv1.HealthResponse) *types.HealthStatus

func ToHistory ¶

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

func ToHistoryCloseShardRequest ¶

func ToHistoryCloseShardRequest(t *historyv1.CloseShardRequest) *types.CloseShardRequest

func ToHistoryCountDLQMessagesRequest ¶ added in v0.25.0

func ToHistoryCountDLQMessagesRequest(t *historyv1.CountDLQMessagesRequest) *types.CountDLQMessagesRequest

func ToHistoryCountDLQMessagesResponse ¶ added in v0.25.0

func ToHistoryCountDLQMessagesResponse(t *historyv1.CountDLQMessagesResponse) *types.HistoryCountDLQMessagesResponse

func ToHistoryDLQCountEntryMap ¶ added in v0.25.0

func ToHistoryDLQCountEntryMap(t []*adminv1.HistoryDLQCountEntry) map[types.HistoryDLQCountKey]int64

func ToHistoryDescribeHistoryHostRequest ¶

func ToHistoryDescribeHistoryHostRequest(t *historyv1.DescribeHistoryHostRequest) *types.DescribeHistoryHostRequest

func ToHistoryDescribeHistoryHostResponse ¶

func ToHistoryDescribeHistoryHostResponse(t *historyv1.DescribeHistoryHostResponse) *types.DescribeHistoryHostResponse

func ToHistoryDescribeMutableStateRequest ¶

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

func ToHistoryDescribeMutableStateResponse ¶

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

func ToHistoryDescribeQueueRequest ¶

func ToHistoryDescribeQueueRequest(t *historyv1.DescribeQueueRequest) *types.DescribeQueueRequest

func ToHistoryDescribeQueueResponse ¶

func ToHistoryDescribeQueueResponse(t *historyv1.DescribeQueueResponse) *types.DescribeQueueResponse

func ToHistoryDescribeWorkflowExecutionRequest ¶

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

func ToHistoryDescribeWorkflowExecutionResponse ¶

func ToHistoryDescribeWorkflowExecutionResponse(t *historyv1.DescribeWorkflowExecutionResponse) *types.DescribeWorkflowExecutionResponse

func ToHistoryEvent ¶

func ToHistoryEvent(e *apiv1.HistoryEvent) *types.HistoryEvent

func ToHistoryEventArray ¶

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

func ToHistoryGetCrossClusterTasksRequest ¶ added in v0.23.1

func ToHistoryGetCrossClusterTasksRequest(t *historyv1.GetCrossClusterTasksRequest) *types.GetCrossClusterTasksRequest

ToHistoryGetCrossClusterTasksRequest converts proto GetCrossClusterTasksRequest type to internal

func ToHistoryGetCrossClusterTasksResponse ¶ added in v0.23.1

func ToHistoryGetCrossClusterTasksResponse(t *historyv1.GetCrossClusterTasksResponse) *types.GetCrossClusterTasksResponse

ToHistoryGetCrossClusterTasksResponse converts proto GetCrossClusterTasksResponse type to internal

func ToHistoryGetDLQReplicationMessagesRequest ¶

func ToHistoryGetDLQReplicationMessagesRequest(t *historyv1.GetDLQReplicationMessagesRequest) *types.GetDLQReplicationMessagesRequest

func ToHistoryGetDLQReplicationMessagesResponse ¶

func ToHistoryGetDLQReplicationMessagesResponse(t *historyv1.GetDLQReplicationMessagesResponse) *types.GetDLQReplicationMessagesResponse

func ToHistoryGetFailoverInfoRequest ¶ added in v0.24.0

func ToHistoryGetFailoverInfoRequest(t *historyv1.GetFailoverInfoRequest) *types.GetFailoverInfoRequest

func ToHistoryGetFailoverInfoResponse ¶ added in v0.24.0

func ToHistoryGetFailoverInfoResponse(t *historyv1.GetFailoverInfoResponse) *types.GetFailoverInfoResponse

func ToHistoryGetMutableStateRequest ¶

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

func ToHistoryGetMutableStateResponse ¶

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

func ToHistoryGetReplicationMessagesRequest ¶

func ToHistoryGetReplicationMessagesRequest(t *historyv1.GetReplicationMessagesRequest) *types.GetReplicationMessagesRequest

func ToHistoryGetReplicationMessagesResponse ¶

func ToHistoryGetReplicationMessagesResponse(t *historyv1.GetReplicationMessagesResponse) *types.GetReplicationMessagesResponse

func ToHistoryMergeDLQMessagesRequest ¶

func ToHistoryMergeDLQMessagesRequest(t *historyv1.MergeDLQMessagesRequest) *types.MergeDLQMessagesRequest

func ToHistoryMergeDLQMessagesResponse ¶

func ToHistoryMergeDLQMessagesResponse(t *historyv1.MergeDLQMessagesResponse) *types.MergeDLQMessagesResponse

func ToHistoryNotifyFailoverMarkersRequest ¶

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

func ToHistoryPollMutableStateRequest ¶

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

func ToHistoryPollMutableStateResponse ¶

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

func ToHistoryPurgeDLQMessagesRequest ¶

func ToHistoryPurgeDLQMessagesRequest(t *historyv1.PurgeDLQMessagesRequest) *types.PurgeDLQMessagesRequest

func ToHistoryQueryWorkflowRequest ¶

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

func ToHistoryQueryWorkflowResponse ¶

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

func ToHistoryReadDLQMessagesRequest ¶

func ToHistoryReadDLQMessagesRequest(t *historyv1.ReadDLQMessagesRequest) *types.ReadDLQMessagesRequest

func ToHistoryReadDLQMessagesResponse ¶

func ToHistoryReadDLQMessagesResponse(t *historyv1.ReadDLQMessagesResponse) *types.ReadDLQMessagesResponse

func ToHistoryReapplyEventsRequest ¶

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

func ToHistoryRecordActivityTaskHeartbeatRequest ¶

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

func ToHistoryRecordActivityTaskHeartbeatResponse ¶

func ToHistoryRecordActivityTaskHeartbeatResponse(t *historyv1.RecordActivityTaskHeartbeatResponse) *types.RecordActivityTaskHeartbeatResponse

func ToHistoryRecordActivityTaskStartedRequest ¶

func ToHistoryRecordActivityTaskStartedRequest(t *historyv1.RecordActivityTaskStartedRequest) *types.RecordActivityTaskStartedRequest

func ToHistoryRecordActivityTaskStartedResponse ¶

func ToHistoryRecordActivityTaskStartedResponse(t *historyv1.RecordActivityTaskStartedResponse) *types.RecordActivityTaskStartedResponse

func ToHistoryRecordChildExecutionCompletedRequest ¶

func ToHistoryRecordChildExecutionCompletedRequest(t *historyv1.RecordChildExecutionCompletedRequest) *types.RecordChildExecutionCompletedRequest

func ToHistoryRecordDecisionTaskStartedRequest ¶

func ToHistoryRecordDecisionTaskStartedRequest(t *historyv1.RecordDecisionTaskStartedRequest) *types.RecordDecisionTaskStartedRequest

func ToHistoryRecordDecisionTaskStartedResponse ¶

func ToHistoryRecordDecisionTaskStartedResponse(t *historyv1.RecordDecisionTaskStartedResponse) *types.RecordDecisionTaskStartedResponse

func ToHistoryRefreshWorkflowTasksRequest ¶

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

func ToHistoryRemoveSignalMutableStateRequest ¶

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

func ToHistoryRemoveTaskRequest ¶

func ToHistoryRemoveTaskRequest(t *historyv1.RemoveTaskRequest) *types.RemoveTaskRequest

func ToHistoryReplicateEventsV2Request ¶

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

func ToHistoryRequestCancelWorkflowExecutionRequest ¶

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

func ToHistoryResetQueueRequest ¶

func ToHistoryResetQueueRequest(t *historyv1.ResetQueueRequest) *types.ResetQueueRequest

func ToHistoryResetStickyTaskListRequest ¶

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

func ToHistoryResetStickyTaskListResponse ¶ added in v1.2.7

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

func ToHistoryResetWorkflowExecutionRequest ¶

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

func ToHistoryResetWorkflowExecutionResponse ¶

func ToHistoryResetWorkflowExecutionResponse(t *historyv1.ResetWorkflowExecutionResponse) *types.ResetWorkflowExecutionResponse

func ToHistoryRespondActivityTaskCanceledRequest ¶

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

func ToHistoryRespondActivityTaskCompletedRequest ¶

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

func ToHistoryRespondActivityTaskFailedRequest ¶

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

func ToHistoryRespondCrossClusterTasksCompletedRequest ¶ added in v0.23.1

func ToHistoryRespondCrossClusterTasksCompletedRequest(t *historyv1.RespondCrossClusterTasksCompletedRequest) *types.RespondCrossClusterTasksCompletedRequest

ToHistoryRespondCrossClusterTasksCompletedRequest converts thrift RespondCrossClusterTasksCompletedRequest type to internal

func ToHistoryRespondCrossClusterTasksCompletedResponse ¶ added in v0.23.1

func ToHistoryRespondCrossClusterTasksCompletedResponse(t *historyv1.RespondCrossClusterTasksCompletedResponse) *types.RespondCrossClusterTasksCompletedResponse

ToHistoryRespondCrossClusterTasksCompletedResponse converts thrift RespondCrossClusterTasksCompletedResponse type to internal

func ToHistoryRespondDecisionTaskCompletedRequest ¶

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

func ToHistoryRespondDecisionTaskCompletedResponse ¶

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

func ToHistoryRespondDecisionTaskFailedRequest ¶

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

func ToHistoryScheduleDecisionTaskRequest ¶

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

func ToHistorySignalWithStartWorkflowExecutionRequest ¶

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

func ToHistorySignalWithStartWorkflowExecutionResponse ¶

func ToHistorySignalWithStartWorkflowExecutionResponse(t *historyv1.SignalWithStartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse

func ToHistorySignalWorkflowExecutionRequest ¶

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

func ToHistoryStartWorkflowExecutionRequest ¶

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

func ToHistoryStartWorkflowExecutionResponse ¶

func ToHistoryStartWorkflowExecutionResponse(t *historyv1.StartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse

func ToHistorySyncActivityRequest ¶

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

func ToHistorySyncShardStatusRequest ¶

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

func ToHistoryTaskV2Attributes ¶

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

func ToHistoryTerminateWorkflowExecutionRequest ¶

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

func ToHostInfo ¶

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

func ToHostInfoArray ¶

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

func ToIndexedValueType ¶

func ToIndexedValueType(t apiv1.IndexedValueType) types.IndexedValueType

func ToIndexedValueTypeMap ¶

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

func ToIsolationGroupConfig ¶ added in v1.2.1

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

func ToListArchivedWorkflowExecutionsRequest ¶

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

func ToListArchivedWorkflowExecutionsResponse ¶

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

func ToListClosedWorkflowExecutionsRequest ¶

func ToListClosedWorkflowExecutionsRequest(r *apiv1.ListClosedWorkflowExecutionsRequest) *types.ListClosedWorkflowExecutionsRequest

func ToListClosedWorkflowExecutionsResponse ¶

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

func ToListDomainsRequest ¶

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

func ToListDomainsResponse ¶

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

func ToListOpenWorkflowExecutionsRequest ¶

func ToListOpenWorkflowExecutionsRequest(r *apiv1.ListOpenWorkflowExecutionsRequest) *types.ListOpenWorkflowExecutionsRequest

func ToListOpenWorkflowExecutionsResponse ¶

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

func ToListTaskListPartitionsRequest ¶

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

func ToListTaskListPartitionsResponse ¶

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

func ToListWorkflowExecutionsRequest ¶

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

func ToListWorkflowExecutionsResponse ¶

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

func ToMarkerRecordedEventAttributes ¶

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

func ToMatchingAddActivityTaskRequest ¶

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

func ToMatchingAddDecisionTaskRequest ¶

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

func ToMatchingCancelOutstandingPollRequest ¶

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

func ToMatchingDescribeTaskListRequest ¶

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

func ToMatchingDescribeTaskListResponse ¶

func ToMatchingDescribeTaskListResponse(t *matchingv1.DescribeTaskListResponse) *types.DescribeTaskListResponse

func ToMatchingDescribeTaskListResponseMap ¶ added in v0.24.0

func ToMatchingDescribeTaskListResponseMap(t map[string]*matchingv1.DescribeTaskListResponse) map[string]*types.DescribeTaskListResponse

func ToMatchingGetTaskListsByDomainRequest ¶ added in v0.23.1

func ToMatchingGetTaskListsByDomainRequest(t *matchingv1.GetTaskListsByDomainRequest) *types.GetTaskListsByDomainRequest

func ToMatchingGetTaskListsByDomainResponse ¶ added in v0.23.1

func ToMatchingGetTaskListsByDomainResponse(t *matchingv1.GetTaskListsByDomainResponse) *types.GetTaskListsByDomainResponse

func ToMatchingListTaskListPartitionsRequest ¶

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

func ToMatchingListTaskListPartitionsResponse ¶

func ToMatchingListTaskListPartitionsResponse(t *matchingv1.ListTaskListPartitionsResponse) *types.ListTaskListPartitionsResponse

func ToMatchingPollForActivityTaskRequest ¶

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

func ToMatchingPollForActivityTaskResponse ¶

func ToMatchingPollForActivityTaskResponse(t *matchingv1.PollForActivityTaskResponse) *types.PollForActivityTaskResponse

func ToMatchingPollForDecisionTaskRequest ¶

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

func ToMatchingPollForDecisionTaskResponse ¶

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

func ToMatchingQueryWorkflowRequest ¶

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

func ToMatchingQueryWorkflowResponse ¶

func ToMatchingQueryWorkflowResponse(t *matchingv1.QueryWorkflowResponse) *types.QueryWorkflowResponse

func ToMatchingRespondQueryTaskCompletedRequest ¶

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

func ToMembershipInfo ¶

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

func ToMemo ¶

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

func ToParentClosePolicy ¶

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

func ToParentDomainID ¶

func ToParentDomainID(pei *apiv1.ParentExecutionInfo) *string

func ToParentDomainName ¶

func ToParentDomainName(pei *apiv1.ParentExecutionInfo) *string

func ToParentExecutionInfo ¶

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

func ToParentInitiatedID ¶

func ToParentInitiatedID(pei *apiv1.ParentExecutionInfo) *int64

func ToParentWorkflowExecution ¶

func ToParentWorkflowExecution(pei *apiv1.ParentExecutionInfo) *types.WorkflowExecution

func ToPayload ¶

func ToPayload(p *apiv1.Payload) []byte

func ToPayloadMap ¶

func ToPayloadMap(t map[string]*apiv1.Payload) map[string][]byte

func ToPendingActivityInfo ¶

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

func ToPendingActivityInfoArray ¶

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

func ToPendingActivityState ¶

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

func ToPendingChildExecutionInfo ¶

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

func ToPendingChildExecutionInfoArray ¶

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

func ToPendingDecisionInfo ¶

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

func ToPendingDecisionState ¶

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

func ToPersistenceFeature ¶ added in v0.21.0

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

func ToPersistenceFeatures ¶ added in v0.21.0

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

func ToPersistenceInfo ¶ added in v0.21.0

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

func ToPersistenceInfoMap ¶ added in v0.21.0

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

func ToPersistenceSetting ¶ added in v0.21.0

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

func ToPersistenceSettings ¶ added in v0.21.0

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

func ToPollForActivityTaskRequest ¶

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

func ToPollForActivityTaskResponse ¶

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

func ToPollForDecisionTaskRequest ¶

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

func ToPollForDecisionTaskResponse ¶

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

func ToPollerInfo ¶

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

func ToPollerInfoArray ¶

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

func ToQueryConsistencyLevel ¶

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

func ToQueryRejectCondition ¶

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

func ToQueryRejected ¶

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

func ToQueryResultType ¶

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

func ToQueryTaskCompletedType ¶

func ToQueryTaskCompletedType(t apiv1.QueryResultType) *types.QueryTaskCompletedType

func ToQueryWorkflowRequest ¶

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

func ToQueryWorkflowResponse ¶

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

func ToRecordActivityTaskHeartbeatByIDRequest ¶

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

func ToRecordActivityTaskHeartbeatByIDResponse ¶

func ToRecordActivityTaskHeartbeatByIDResponse(t *apiv1.RecordActivityTaskHeartbeatByIDResponse) *types.RecordActivityTaskHeartbeatResponse

func ToRecordActivityTaskHeartbeatRequest ¶

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

func ToRecordActivityTaskHeartbeatResponse ¶

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

func ToRecordMarkerDecisionAttributes ¶

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

func ToRefreshWorkflowTasksRequest ¶ added in v0.24.0

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

func ToRegisterDomainRequest ¶

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

func ToReplicationMessages ¶

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

func ToReplicationMessagesMap ¶

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

func ToReplicationTask ¶

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

func ToReplicationTaskArray ¶

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

func ToReplicationTaskInfo ¶

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

func ToReplicationTaskInfoArray ¶

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

func ToReplicationTaskType ¶

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

func ToReplicationToken ¶

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

func ToReplicationTokenArray ¶

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

func ToRequestCancelActivityTaskDecisionAttributes ¶

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

func ToRequestCancelActivityTaskFailedEventAttributes ¶

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

func ToRequestCancelExternalWorkflowExecutionDecisionAttributes ¶

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

func ToRequestCancelExternalWorkflowExecutionFailedEventAttributes ¶

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

func ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶

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

func ToRequestCancelWorkflowExecutionRequest ¶

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

func ToResetPointInfo ¶

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

func ToResetPointInfoArray ¶

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

func ToResetPoints ¶

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

func ToResetStickyTaskListRequest ¶

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

func ToResetStickyTaskListResponse ¶ added in v1.2.7

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

func ToResetWorkflowExecutionRequest ¶

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

func ToResetWorkflowExecutionResponse ¶

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

func ToRespondActivityTaskCanceledByIDRequest ¶

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

func ToRespondActivityTaskCanceledRequest ¶

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

func ToRespondActivityTaskCompletedByIDRequest ¶

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

func ToRespondActivityTaskCompletedRequest ¶

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

func ToRespondActivityTaskFailedByIDRequest ¶

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

func ToRespondActivityTaskFailedRequest ¶

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

func ToRespondDecisionTaskCompletedRequest ¶

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

func ToRespondDecisionTaskCompletedResponse ¶

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

func ToRespondDecisionTaskFailedRequest ¶

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

func ToRespondQueryTaskCompletedRequest ¶

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

func ToRestartWorkflowExecutionRequest ¶ added in v0.25.0

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

func ToRestartWorkflowExecutionResponse ¶ added in v1.2.7

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

func ToRetryPolicy ¶

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

func ToRingInfo ¶

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

func ToRingInfoArray ¶

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

func ToRunID ¶

func ToRunID(t *apiv1.WorkflowExecution) string

func ToScanWorkflowExecutionsRequest ¶

func ToScanWorkflowExecutionsRequest(t *apiv1.ScanWorkflowExecutionsRequest) *types.ListWorkflowExecutionsRequest

func ToScanWorkflowExecutionsResponse ¶

func ToScanWorkflowExecutionsResponse(t *apiv1.ScanWorkflowExecutionsResponse) *types.ListWorkflowExecutionsResponse

func ToScheduleActivityTaskDecisionAttributes ¶

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

func ToSearchAttributes ¶

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

func ToSignalExternalWorkflowExecutionDecisionAttributes ¶

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

func ToSignalExternalWorkflowExecutionFailedCause ¶

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

func ToSignalExternalWorkflowExecutionFailedEventAttributes ¶

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

func ToSignalExternalWorkflowExecutionInitiatedEventAttributes ¶

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

func ToSignalWithStartWorkflowExecutionRequest ¶

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

func ToSignalWithStartWorkflowExecutionResponse ¶

func ToSignalWithStartWorkflowExecutionResponse(t *apiv1.SignalWithStartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse

func ToSignalWorkflowExecutionRequest ¶

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

func ToStartChildWorkflowExecutionDecisionAttributes ¶

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

func ToStartChildWorkflowExecutionFailedEventAttributes ¶

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

func ToStartChildWorkflowExecutionInitiatedEventAttributes ¶

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

func ToStartTimeFilter ¶

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

func ToStartTimerDecisionAttributes ¶

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

func ToStartWorkflowExecutionAsyncRequest ¶ added in v1.2.8

func ToStartWorkflowExecutionAsyncRequest(t *apiv1.StartWorkflowExecutionAsyncRequest) *types.StartWorkflowExecutionAsyncRequest

func ToStartWorkflowExecutionAsyncResponse ¶ added in v1.2.8

func ToStartWorkflowExecutionAsyncResponse(t *apiv1.StartWorkflowExecutionAsyncResponse) *types.StartWorkflowExecutionAsyncResponse

func ToStartWorkflowExecutionRequest ¶

func ToStartWorkflowExecutionRequest(t *apiv1.StartWorkflowExecutionRequest) *types.StartWorkflowExecutionRequest

func ToStartWorkflowExecutionResponse ¶

func ToStartWorkflowExecutionResponse(t *apiv1.StartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse

func ToStatusFilter ¶

func ToStatusFilter(t *apiv1.StatusFilter) *types.WorkflowExecutionCloseStatus

func ToStickyExecutionAttributes ¶

func ToStickyExecutionAttributes(t *apiv1.StickyExecutionAttributes) *types.StickyExecutionAttributes

func ToSupportedClientVersions ¶

func ToSupportedClientVersions(t *apiv1.SupportedClientVersions) *types.SupportedClientVersions

func ToSyncActivityTaskAttributes ¶

func ToSyncActivityTaskAttributes(t *adminv1.SyncActivityTaskAttributes) *types.SyncActivityTaskAttributes

func ToSyncShardStatus ¶

func ToSyncShardStatus(t *adminv1.SyncShardStatus) *types.SyncShardStatus

func ToSyncShardStatusTaskAttributes ¶

func ToSyncShardStatusTaskAttributes(t *adminv1.SyncShardStatusTaskAttributes) *types.SyncShardStatusTaskAttributes

func ToTaskIDBlock ¶

func ToTaskIDBlock(t *apiv1.TaskIDBlock) *types.TaskIDBlock

func ToTaskList ¶

func ToTaskList(t *apiv1.TaskList) *types.TaskList

func ToTaskListKind ¶

func ToTaskListKind(t apiv1.TaskListKind) *types.TaskListKind

func ToTaskListMetadata ¶

func ToTaskListMetadata(t *apiv1.TaskListMetadata) *types.TaskListMetadata

func ToTaskListPartitionMetadata ¶

func ToTaskListPartitionMetadata(t *apiv1.TaskListPartitionMetadata) *types.TaskListPartitionMetadata

func ToTaskListPartitionMetadataArray ¶

func ToTaskListPartitionMetadataArray(t []*apiv1.TaskListPartitionMetadata) []*types.TaskListPartitionMetadata

func ToTaskListStatus ¶

func ToTaskListStatus(t *apiv1.TaskListStatus) *types.TaskListStatus

func ToTaskListType ¶

func ToTaskListType(t apiv1.TaskListType) *types.TaskListType

func ToTaskSource ¶

func ToTaskSource(t sharedv1.TaskSource) *types.TaskSource

func ToTaskType ¶

func ToTaskType(t adminv1.TaskType) *int32

func ToTerminateWorkflowExecutionRequest ¶

func ToTerminateWorkflowExecutionRequest(t *apiv1.TerminateWorkflowExecutionRequest) *types.TerminateWorkflowExecutionRequest

func ToTimeoutType ¶

func ToTimeoutType(t apiv1.TimeoutType) *types.TimeoutType

func ToTimerCanceledEventAttributes ¶

func ToTimerCanceledEventAttributes(t *apiv1.TimerCanceledEventAttributes) *types.TimerCanceledEventAttributes

func ToTimerFiredEventAttributes ¶

func ToTimerFiredEventAttributes(t *apiv1.TimerFiredEventAttributes) *types.TimerFiredEventAttributes

func ToTimerStartedEventAttributes ¶

func ToTimerStartedEventAttributes(t *apiv1.TimerStartedEventAttributes) *types.TimerStartedEventAttributes

func ToTransientDecisionInfo ¶

func ToTransientDecisionInfo(t *sharedv1.TransientDecisionInfo) *types.TransientDecisionInfo

func ToUpdateDomainRequest ¶

func ToUpdateDomainRequest(t *apiv1.UpdateDomainRequest) *types.UpdateDomainRequest

func ToUpdateDomainResponse ¶

func ToUpdateDomainResponse(t *apiv1.UpdateDomainResponse) *types.UpdateDomainResponse

func ToUpsertWorkflowSearchAttributesDecisionAttributes ¶

func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *apiv1.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes

func ToUpsertWorkflowSearchAttributesEventAttributes ¶

func ToUpsertWorkflowSearchAttributesEventAttributes(t *apiv1.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes

func ToVersionHistories ¶

func ToVersionHistories(t *sharedv1.VersionHistories) *types.VersionHistories

func ToVersionHistory ¶

func ToVersionHistory(t *adminv1.VersionHistory) *types.VersionHistory

func ToVersionHistoryArray ¶

func ToVersionHistoryArray(t []*adminv1.VersionHistory) []*types.VersionHistory

func ToVersionHistoryItem ¶

func ToVersionHistoryItem(t *adminv1.VersionHistoryItem) *types.VersionHistoryItem

func ToVersionHistoryItemArray ¶

func ToVersionHistoryItemArray(t []*adminv1.VersionHistoryItem) []*types.VersionHistoryItem

func ToWorkerVersionInfo ¶

func ToWorkerVersionInfo(t *apiv1.WorkerVersionInfo) *types.WorkerVersionInfo

func ToWorkflowExecution ¶

func ToWorkflowExecution(t *apiv1.WorkflowExecution) *types.WorkflowExecution

func ToWorkflowExecutionCancelRequestedEventAttributes ¶

func ToWorkflowExecutionCancelRequestedEventAttributes(t *apiv1.WorkflowExecutionCancelRequestedEventAttributes) *types.WorkflowExecutionCancelRequestedEventAttributes

func ToWorkflowExecutionCanceledEventAttributes ¶

func ToWorkflowExecutionCanceledEventAttributes(t *apiv1.WorkflowExecutionCanceledEventAttributes) *types.WorkflowExecutionCanceledEventAttributes

func ToWorkflowExecutionCloseStatus ¶

func ToWorkflowExecutionCloseStatus(t apiv1.WorkflowExecutionCloseStatus) *types.WorkflowExecutionCloseStatus

func ToWorkflowExecutionCompletedEventAttributes ¶

func ToWorkflowExecutionCompletedEventAttributes(t *apiv1.WorkflowExecutionCompletedEventAttributes) *types.WorkflowExecutionCompletedEventAttributes

func ToWorkflowExecutionConfiguration ¶

func ToWorkflowExecutionConfiguration(t *apiv1.WorkflowExecutionConfiguration) *types.WorkflowExecutionConfiguration

func ToWorkflowExecutionContinuedAsNewEventAttributes ¶

func ToWorkflowExecutionContinuedAsNewEventAttributes(t *apiv1.WorkflowExecutionContinuedAsNewEventAttributes) *types.WorkflowExecutionContinuedAsNewEventAttributes

func ToWorkflowExecutionFailedEventAttributes ¶

func ToWorkflowExecutionFailedEventAttributes(t *apiv1.WorkflowExecutionFailedEventAttributes) *types.WorkflowExecutionFailedEventAttributes

func ToWorkflowExecutionFilter ¶

func ToWorkflowExecutionFilter(t *apiv1.WorkflowExecutionFilter) *types.WorkflowExecutionFilter

func ToWorkflowExecutionInfo ¶

func ToWorkflowExecutionInfo(t *apiv1.WorkflowExecutionInfo) *types.WorkflowExecutionInfo

func ToWorkflowExecutionInfoArray ¶

func ToWorkflowExecutionInfoArray(t []*apiv1.WorkflowExecutionInfo) []*types.WorkflowExecutionInfo

func ToWorkflowExecutionSignaledEventAttributes ¶

func ToWorkflowExecutionSignaledEventAttributes(t *apiv1.WorkflowExecutionSignaledEventAttributes) *types.WorkflowExecutionSignaledEventAttributes

func ToWorkflowExecutionStartedEventAttributes ¶

func ToWorkflowExecutionStartedEventAttributes(t *apiv1.WorkflowExecutionStartedEventAttributes) *types.WorkflowExecutionStartedEventAttributes

func ToWorkflowExecutionTerminatedEventAttributes ¶

func ToWorkflowExecutionTerminatedEventAttributes(t *apiv1.WorkflowExecutionTerminatedEventAttributes) *types.WorkflowExecutionTerminatedEventAttributes

func ToWorkflowExecutionTimedOutEventAttributes ¶

func ToWorkflowExecutionTimedOutEventAttributes(t *apiv1.WorkflowExecutionTimedOutEventAttributes) *types.WorkflowExecutionTimedOutEventAttributes

func ToWorkflowID ¶

func ToWorkflowID(t *apiv1.WorkflowExecution) string

func ToWorkflowIDReusePolicy ¶

func ToWorkflowIDReusePolicy(t apiv1.WorkflowIdReusePolicy) *types.WorkflowIDReusePolicy

func ToWorkflowQuery ¶

func ToWorkflowQuery(t *apiv1.WorkflowQuery) *types.WorkflowQuery

func ToWorkflowQueryMap ¶

func ToWorkflowQueryMap(t map[string]*apiv1.WorkflowQuery) map[string]*types.WorkflowQuery

func ToWorkflowQueryResult ¶

func ToWorkflowQueryResult(t *apiv1.WorkflowQueryResult) *types.WorkflowQueryResult

func ToWorkflowQueryResultMap ¶

func ToWorkflowQueryResultMap(t map[string]*apiv1.WorkflowQueryResult) map[string]*types.WorkflowQueryResult

func ToWorkflowState ¶

func ToWorkflowState(t sharedv1.WorkflowState) *int32

func ToWorkflowType ¶

func ToWorkflowType(t *apiv1.WorkflowType) *types.WorkflowType

func ToWorkflowTypeFilter ¶

func ToWorkflowTypeFilter(t *apiv1.WorkflowTypeFilter) *types.WorkflowTypeFilter

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL