proto

package

v0.23.2 Latest Latest Go to latest Published: Dec 2, 2021 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

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

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

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

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/uber/cadence

Links

Open Source Insights

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 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 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 FromAdminGetDomainReplicationMessagesRequest(t *types.GetDomainReplicationMessagesRequest) *adminv1.GetDomainReplicationMessagesRequest
func FromAdminGetDomainReplicationMessagesResponse(t *types.GetDomainReplicationMessagesResponse) *adminv1.GetDomainReplicationMessagesResponse
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 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 FromArchivalStatus(t *types.ArchivalStatus) apiv1.ArchivalStatus
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 FromCrossClusterCancelExecutionRequestAttributes(t *types.CrossClusterCancelExecutionRequestAttributes) *sharedv1.CrossClusterCancelExecutionRequestAttributes
func FromCrossClusterCancelExecutionResponseAttributes(t *types.CrossClusterCancelExecutionResponseAttributes) *sharedv1.CrossClusterCancelExecutionResponseAttributes
func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *sharedv1.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes
func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *sharedv1.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes
func FromCrossClusterSignalExecutionRequestAttributes(t *types.CrossClusterSignalExecutionRequestAttributes) *sharedv1.CrossClusterSignalExecutionRequestAttributes
func FromCrossClusterSignalExecutionResponseAttributes(t *types.CrossClusterSignalExecutionResponseAttributes) *sharedv1.CrossClusterSignalExecutionResponseAttributes
func FromCrossClusterStartChildExecutionRequestAttributes(t *types.CrossClusterStartChildExecutionRequestAttributes) *sharedv1.CrossClusterStartChildExecutionRequestAttributes
func FromCrossClusterStartChildExecutionResponseAttributes(t *types.CrossClusterStartChildExecutionResponseAttributes) *sharedv1.CrossClusterStartChildExecutionResponseAttributes
func FromCrossClusterTaskFailedCause(t *types.CrossClusterTaskFailedCause) sharedv1.CrossClusterTaskFailedCause
func FromCrossClusterTaskInfo(t *types.CrossClusterTaskInfo) *sharedv1.CrossClusterTaskInfo
func FromCrossClusterTaskRequest(t *types.CrossClusterTaskRequest) *sharedv1.CrossClusterTaskRequest
func FromCrossClusterTaskRequestArray(t []*types.CrossClusterTaskRequest) *sharedv1.CrossClusterTaskRequests
func FromCrossClusterTaskRequestMap(t map[int32][]*types.CrossClusterTaskRequest) map[int32]*sharedv1.CrossClusterTaskRequests
func FromCrossClusterTaskResponse(t *types.CrossClusterTaskResponse) *sharedv1.CrossClusterTaskResponse
func FromCrossClusterTaskResponseArray(t []*types.CrossClusterTaskResponse) []*sharedv1.CrossClusterTaskResponse
func FromCrossClusterTaskType(t *types.CrossClusterTaskType) sharedv1.CrossClusterTaskType
func FromDLQType(t *types.DLQType) sharedv1.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 FromDescribeWorkflowExecutionRequest(t *types.DescribeWorkflowExecutionRequest) *apiv1.DescribeWorkflowExecutionRequest
func FromDescribeWorkflowExecutionResponse(t *types.DescribeWorkflowExecutionResponse) *apiv1.DescribeWorkflowExecutionResponse
func FromDomainCacheInfo(t *types.DomainCacheInfo) *sharedv1.DomainCacheInfo
func FromDomainOperation(t *types.DomainOperation) sharedv1.DomainOperation
func FromDomainStatus(t *types.DomainStatus) apiv1.DomainStatus
func FromDomainTaskAttributes(t *types.DomainTaskAttributes) *sharedv1.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) *sharedv1.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 FromFailoverMarkerAttributes(t *types.FailoverMarkerAttributes) *sharedv1.FailoverMarkerAttributes
func FromFailoverMarkerToken(t *types.FailoverMarkerToken) *sharedv1.FailoverMarkerToken
func FromFailoverMarkerTokenArray(t []*types.FailoverMarkerToken) []*sharedv1.FailoverMarkerToken
func FromFailure(reason *string, details []byte) *apiv1.Failure
func FromGetClusterInfoResponse(t *types.ClusterInfo) *apiv1.GetClusterInfoResponse
func FromGetDynamicConfigRequest(t *types.GetDynamicConfigRequest) *adminv1.GetDynamicConfigRequest
func FromGetDynamicConfigResponse(t *types.GetDynamicConfigResponse) *adminv1.GetDynamicConfigResponse
func FromGetSearchAttributesResponse(t *types.GetSearchAttributesResponse) *apiv1.GetSearchAttributesResponse
func FromGetTaskFailedCause(t *types.GetTaskFailedCause) sharedv1.GetTaskFailedCause
func FromGetTaskFailedCauseMap(t map[int32]types.GetTaskFailedCause) map[int32]sharedv1.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 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 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 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) *sharedv1.HistoryTaskV2Attributes
func FromHistoryTerminateWorkflowExecutionRequest(t *types.HistoryTerminateWorkflowExecutionRequest) *historyv1.TerminateWorkflowExecutionRequest
func FromHostInfo(t *types.HostInfo) *sharedv1.HostInfo
func FromHostInfoArray(t []*types.HostInfo) []*sharedv1.HostInfo
func FromIndexedValueType(t types.IndexedValueType) apiv1.IndexedValueType
func FromIndexedValueTypeMap(t map[string]types.IndexedValueType) map[string]apiv1.IndexedValueType
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 FromListDynamicConfigRequest(t *types.ListDynamicConfigRequest) *adminv1.ListDynamicConfigRequest
func FromListDynamicConfigResponse(t *types.ListDynamicConfigResponse) *adminv1.ListDynamicConfigResponse
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 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) *sharedv1.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) *sharedv1.PersistenceFeature
func FromPersistenceFeatures(t []*types.PersistenceFeature) []*sharedv1.PersistenceFeature
func FromPersistenceInfo(t *types.PersistenceInfo) *sharedv1.PersistenceInfo
func FromPersistenceInfoMap(t map[string]*types.PersistenceInfo) map[string]*sharedv1.PersistenceInfo
func FromPersistenceSetting(t *types.PersistenceSetting) *sharedv1.PersistenceSetting
func FromPersistenceSettings(t []*types.PersistenceSetting) []*sharedv1.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 FromRegisterDomainRequest(t *types.RegisterDomainRequest) *apiv1.RegisterDomainRequest
func FromReplicationMessages(t *types.ReplicationMessages) *sharedv1.ReplicationMessages
func FromReplicationMessagesMap(t map[int32]*types.ReplicationMessages) map[int32]*sharedv1.ReplicationMessages
func FromReplicationTask(t *types.ReplicationTask) *sharedv1.ReplicationTask
func FromReplicationTaskArray(t []*types.ReplicationTask) []*sharedv1.ReplicationTask
func FromReplicationTaskInfo(t *types.ReplicationTaskInfo) *sharedv1.ReplicationTaskInfo
func FromReplicationTaskInfoArray(t []*types.ReplicationTaskInfo) []*sharedv1.ReplicationTaskInfo
func FromReplicationTaskType(t *types.ReplicationTaskType) sharedv1.ReplicationTaskType
func FromReplicationToken(t *types.ReplicationToken) *sharedv1.ReplicationToken
func FromReplicationTokenArray(t []*types.ReplicationToken) []*sharedv1.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 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 FromRestoreDynamicConfigRequest(t *types.RestoreDynamicConfigRequest) *adminv1.RestoreDynamicConfigRequest
func FromRetryPolicy(t *types.RetryPolicy) *apiv1.RetryPolicy
func FromRingInfo(t *types.RingInfo) *sharedv1.RingInfo
func FromRingInfoArray(t []*types.RingInfo) []*sharedv1.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 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) *sharedv1.SyncActivityTaskAttributes
func FromSyncShardStatus(t *types.SyncShardStatus) *sharedv1.SyncShardStatus
func FromSyncShardStatusTaskAttributes(t *types.SyncShardStatusTaskAttributes) *sharedv1.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) sharedv1.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 FromUpdateDynamicConfigRequest(t *types.UpdateDynamicConfigRequest) *adminv1.UpdateDynamicConfigRequest
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) *sharedv1.VersionHistory
func FromVersionHistoryArray(t []*types.VersionHistory) []*sharedv1.VersionHistory
func FromVersionHistoryItem(t *types.VersionHistoryItem) *sharedv1.VersionHistoryItem
func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*sharedv1.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 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 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 ToAdminGetDomainReplicationMessagesRequest(t *adminv1.GetDomainReplicationMessagesRequest) *types.GetDomainReplicationMessagesRequest
func ToAdminGetDomainReplicationMessagesResponse(t *adminv1.GetDomainReplicationMessagesResponse) *types.GetDomainReplicationMessagesResponse
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 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 ToArchivalStatus(t apiv1.ArchivalStatus) *types.ArchivalStatus
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 ToCrossClusterCancelExecutionRequestAttributes(t *sharedv1.CrossClusterCancelExecutionRequestAttributes) *types.CrossClusterCancelExecutionRequestAttributes
func ToCrossClusterCancelExecutionResponseAttributes(t *sharedv1.CrossClusterCancelExecutionResponseAttributes) *types.CrossClusterCancelExecutionResponseAttributes
func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes(t *sharedv1.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes
func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes(t *sharedv1.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes) *types.CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes
func ToCrossClusterSignalExecutionRequestAttributes(t *sharedv1.CrossClusterSignalExecutionRequestAttributes) *types.CrossClusterSignalExecutionRequestAttributes
func ToCrossClusterSignalExecutionResponseAttributes(t *sharedv1.CrossClusterSignalExecutionResponseAttributes) *types.CrossClusterSignalExecutionResponseAttributes
func ToCrossClusterStartChildExecutionRequestAttributes(t *sharedv1.CrossClusterStartChildExecutionRequestAttributes) *types.CrossClusterStartChildExecutionRequestAttributes
func ToCrossClusterStartChildExecutionResponseAttributes(t *sharedv1.CrossClusterStartChildExecutionResponseAttributes) *types.CrossClusterStartChildExecutionResponseAttributes
func ToCrossClusterTaskFailedCause(t sharedv1.CrossClusterTaskFailedCause) *types.CrossClusterTaskFailedCause
func ToCrossClusterTaskInfo(t *sharedv1.CrossClusterTaskInfo) *types.CrossClusterTaskInfo
func ToCrossClusterTaskRequest(t *sharedv1.CrossClusterTaskRequest) *types.CrossClusterTaskRequest
func ToCrossClusterTaskRequestArray(t *sharedv1.CrossClusterTaskRequests) []*types.CrossClusterTaskRequest
func ToCrossClusterTaskRequestMap(t map[int32]*sharedv1.CrossClusterTaskRequests) map[int32][]*types.CrossClusterTaskRequest
func ToCrossClusterTaskResponse(t *sharedv1.CrossClusterTaskResponse) *types.CrossClusterTaskResponse
func ToCrossClusterTaskResponseArray(t []*sharedv1.CrossClusterTaskResponse) []*types.CrossClusterTaskResponse
func ToCrossClusterTaskType(t sharedv1.CrossClusterTaskType) *types.CrossClusterTaskType
func ToDLQType(t sharedv1.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 ToDescribeWorkflowExecutionRequest(t *apiv1.DescribeWorkflowExecutionRequest) *types.DescribeWorkflowExecutionRequest
func ToDescribeWorkflowExecutionResponse(t *apiv1.DescribeWorkflowExecutionResponse) *types.DescribeWorkflowExecutionResponse
func ToDomainCacheInfo(t *sharedv1.DomainCacheInfo) *types.DomainCacheInfo
func ToDomainOperation(t sharedv1.DomainOperation) *types.DomainOperation
func ToDomainStatus(t apiv1.DomainStatus) *types.DomainStatus
func ToDomainTaskAttributes(t *sharedv1.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 *sharedv1.VersionHistoryItem) *int64
func ToEventVersion(item *sharedv1.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 ToFailoverMarkerAttributes(t *sharedv1.FailoverMarkerAttributes) *types.FailoverMarkerAttributes
func ToFailoverMarkerToken(t *sharedv1.FailoverMarkerToken) *types.FailoverMarkerToken
func ToFailoverMarkerTokenArray(t []*sharedv1.FailoverMarkerToken) []*types.FailoverMarkerToken
func ToFailureDetails(failure *apiv1.Failure) []byte
func ToFailureReason(failure *apiv1.Failure) *string
func ToGetClusterInfoResponse(t *apiv1.GetClusterInfoResponse) *types.ClusterInfo
func ToGetDynamicConfigRequest(t *adminv1.GetDynamicConfigRequest) *types.GetDynamicConfigRequest
func ToGetDynamicConfigResponse(t *adminv1.GetDynamicConfigResponse) *types.GetDynamicConfigResponse
func ToGetSearchAttributesResponse(t *apiv1.GetSearchAttributesResponse) *types.GetSearchAttributesResponse
func ToGetTaskFailedCause(t sharedv1.GetTaskFailedCause) *types.GetTaskFailedCause
func ToGetTaskFailedCauseMap(t map[int32]sharedv1.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 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 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 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 *sharedv1.HistoryTaskV2Attributes) *types.HistoryTaskV2Attributes
func ToHistoryTerminateWorkflowExecutionRequest(t *historyv1.TerminateWorkflowExecutionRequest) *types.HistoryTerminateWorkflowExecutionRequest
func ToHostInfo(t *sharedv1.HostInfo) *types.HostInfo
func ToHostInfoArray(t []*sharedv1.HostInfo) []*types.HostInfo
func ToIndexedValueType(t apiv1.IndexedValueType) types.IndexedValueType
func ToIndexedValueTypeMap(t map[string]apiv1.IndexedValueType) map[string]types.IndexedValueType
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 ToListDynamicConfigRequest(t *adminv1.ListDynamicConfigRequest) *types.ListDynamicConfigRequest
func ToListDynamicConfigResponse(t *adminv1.ListDynamicConfigResponse) *types.ListDynamicConfigResponse
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 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 *sharedv1.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 *sharedv1.PersistenceFeature) *types.PersistenceFeature
func ToPersistenceFeatures(t []*sharedv1.PersistenceFeature) []*types.PersistenceFeature
func ToPersistenceInfo(t *sharedv1.PersistenceInfo) *types.PersistenceInfo
func ToPersistenceInfoMap(t map[string]*sharedv1.PersistenceInfo) map[string]*types.PersistenceInfo
func ToPersistenceSetting(t *sharedv1.PersistenceSetting) *types.PersistenceSetting
func ToPersistenceSettings(t []*sharedv1.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 ToRegisterDomainRequest(t *apiv1.RegisterDomainRequest) *types.RegisterDomainRequest
func ToReplicationMessages(t *sharedv1.ReplicationMessages) *types.ReplicationMessages
func ToReplicationMessagesMap(t map[int32]*sharedv1.ReplicationMessages) map[int32]*types.ReplicationMessages
func ToReplicationTask(t *sharedv1.ReplicationTask) *types.ReplicationTask
func ToReplicationTaskArray(t []*sharedv1.ReplicationTask) []*types.ReplicationTask
func ToReplicationTaskInfo(t *sharedv1.ReplicationTaskInfo) *types.ReplicationTaskInfo
func ToReplicationTaskInfoArray(t []*sharedv1.ReplicationTaskInfo) []*types.ReplicationTaskInfo
func ToReplicationTaskType(t sharedv1.ReplicationTaskType) *types.ReplicationTaskType
func ToReplicationToken(t *sharedv1.ReplicationToken) *types.ReplicationToken
func ToReplicationTokenArray(t []*sharedv1.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 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 ToRestoreDynamicConfigRequest(t *adminv1.RestoreDynamicConfigRequest) *types.RestoreDynamicConfigRequest
func ToRetryPolicy(t *apiv1.RetryPolicy) *types.RetryPolicy
func ToRingInfo(t *sharedv1.RingInfo) *types.RingInfo
func ToRingInfoArray(t []*sharedv1.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 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 *sharedv1.SyncActivityTaskAttributes) *types.SyncActivityTaskAttributes
func ToSyncShardStatus(t *sharedv1.SyncShardStatus) *types.SyncShardStatus
func ToSyncShardStatusTaskAttributes(t *sharedv1.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 sharedv1.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 ToUpdateDynamicConfigRequest(t *adminv1.UpdateDynamicConfigRequest) *types.UpdateDynamicConfigRequest
func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *apiv1.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes
func ToUpsertWorkflowSearchAttributesEventAttributes(t *apiv1.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes
func ToVersionHistories(t *sharedv1.VersionHistories) *types.VersionHistories
func ToVersionHistory(t *sharedv1.VersionHistory) *types.VersionHistory
func ToVersionHistoryArray(t []*sharedv1.VersionHistory) []*types.VersionHistory
func ToVersionHistoryItem(t *sharedv1.VersionHistoryItem) *types.VersionHistoryItem
func ToVersionHistoryItemArray(t []*sharedv1.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 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 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 FromAdminGetDomainReplicationMessagesRequest ¶

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

func FromAdminGetDomainReplicationMessagesResponse ¶

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

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

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

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 FromCrossClusterCancelExecutionRequestAttributes ¶ added in v0.23.1

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

FromCrossClusterCancelExecutionRequestAttributes converts internal CrossClusterCancelExecutionRequestAttributes type to proto

func FromCrossClusterCancelExecutionResponseAttributes ¶ added in v0.23.1

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

FromCrossClusterCancelExecutionResponseAttributes converts internal CrossClusterCancelExecutionResponseAttributes type to proto

func FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes ¶ added in v0.23.1

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

FromCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes converts internal CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes type to proto

func FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes ¶ added in v0.23.1

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

FromCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes converts internal CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes type to proto

func FromCrossClusterSignalExecutionRequestAttributes ¶ added in v0.23.1

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

FromCrossClusterSignalExecutionRequestAttributes converts internal CrossClusterSignalExecutionRequestAttributes type to proto

func FromCrossClusterSignalExecutionResponseAttributes ¶ added in v0.23.1

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

FromCrossClusterSignalExecutionResponseAttributes converts internal CrossClusterSignalExecutionResponseAttributes type to proto

func FromCrossClusterStartChildExecutionRequestAttributes ¶ added in v0.23.1

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

FromCrossClusterStartChildExecutionRequestAttributes converts internal CrossClusterStartChildExecutionRequestAttributes type to proto

func FromCrossClusterStartChildExecutionResponseAttributes ¶ added in v0.23.1

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

FromCrossClusterStartChildExecutionResponseAttributes converts internal CrossClusterStartChildExecutionResponseAttributes type to proto

func FromCrossClusterTaskFailedCause ¶ added in v0.23.1

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

FromCrossClusterTaskFailedCause converts internal CrossClusterTaskFailedCause type to proto

func FromCrossClusterTaskInfo ¶ added in v0.23.1

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

FromCrossClusterTaskInfo converts internal CrossClusterTaskInfo type to proto

func FromCrossClusterTaskRequest ¶ added in v0.23.1

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

FromCrossClusterTaskRequest converts internal CrossClusterTaskRequest type to proto

func FromCrossClusterTaskRequestArray ¶ added in v0.23.1

func FromCrossClusterTaskRequestArray(t []*types.CrossClusterTaskRequest) *sharedv1.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]*sharedv1.CrossClusterTaskRequests

FromCrossClusterTaskRequestMap converts internal CrossClusterTaskRequest type map to proto

func FromCrossClusterTaskResponse ¶ added in v0.23.1

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

FromCrossClusterTaskResponse converts internal CrossClusterTaskResponse type to proto

func FromCrossClusterTaskResponseArray ¶ added in v0.23.1

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

FromCrossClusterTaskResponseArray converts internal CrossClusterTaskResponse type array to proto

func FromCrossClusterTaskType ¶ added in v0.23.1

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

FromCrossClusterTaskType converts internal CrossClusterTaskType type to proto

func FromDLQType ¶

func FromDLQType(t *types.DLQType) sharedv1.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 FromDescribeWorkflowExecutionRequest ¶

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

func FromDescribeWorkflowExecutionResponse ¶

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

func FromDomainCacheInfo ¶

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

func FromDomainOperation ¶

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

func FromDomainStatus ¶

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

func FromDomainTaskAttributes ¶

func FromDomainTaskAttributes(t *types.DomainTaskAttributes) *sharedv1.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) *sharedv1.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 FromFailoverMarkerAttributes ¶

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

func FromFailoverMarkerToken ¶

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

func FromFailoverMarkerTokenArray ¶

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

func FromFailure ¶

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

func FromGetClusterInfoResponse ¶

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

func FromGetDynamicConfigRequest ¶ added in v0.23.1

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

FromGetDynamicConfigRequest converts internal GetDynamicConfigRequest type to proto

func FromGetDynamicConfigResponse ¶ added in v0.23.1

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

FromGetDynamicConfigResponse converts internal GetDynamicConfigResponse type to proto

func FromGetSearchAttributesResponse ¶

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

func FromGetTaskFailedCause ¶ added in v0.23.1

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

FromGetTaskFailedCause converts internal GetTaskFailedCause type to proto

func FromGetTaskFailedCauseMap ¶ added in v0.23.1

func FromGetTaskFailedCauseMap(t map[int32]types.GetTaskFailedCause) map[int32]sharedv1.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 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 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 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) *sharedv1.HistoryTaskV2Attributes

func FromHistoryTerminateWorkflowExecutionRequest ¶

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

func FromHostInfo ¶

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

func FromHostInfoArray ¶

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

func FromIndexedValueType ¶

func FromIndexedValueType(t types.IndexedValueType) apiv1.IndexedValueType

func FromIndexedValueTypeMap ¶

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

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 FromListDynamicConfigRequest ¶ added in v0.23.1

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

FromListDynamicConfigRequest converts internal ListDynamicConfigRequest type to proto

func FromListDynamicConfigResponse ¶ added in v0.23.1

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

FromListDynamicConfigResponse converts internal ListDynamicConfigResponse type to proto

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 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) *sharedv1.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) *sharedv1.PersistenceFeature

func FromPersistenceFeatures ¶ added in v0.21.0

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

func FromPersistenceInfo ¶ added in v0.21.0

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

func FromPersistenceInfoMap ¶ added in v0.21.0

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

func FromPersistenceSetting ¶ added in v0.21.0

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

func FromPersistenceSettings ¶ added in v0.21.0

func FromPersistenceSettings(t []*types.PersistenceSetting) []*sharedv1.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 FromRegisterDomainRequest ¶

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

func FromReplicationMessages ¶

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

func FromReplicationMessagesMap ¶

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

func FromReplicationTask ¶

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

func FromReplicationTaskArray ¶

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

func FromReplicationTaskInfo ¶

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

func FromReplicationTaskInfoArray ¶

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

func FromReplicationTaskType ¶

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

func FromReplicationToken ¶

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

func FromReplicationTokenArray ¶

func FromReplicationTokenArray(t []*types.ReplicationToken) []*sharedv1.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 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 FromRestoreDynamicConfigRequest ¶ added in v0.23.1

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

FromRestoreDynamicConfigRequest converts internal RestoreDynamicConfigRequest type to proto

func FromRetryPolicy ¶

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

func FromRingInfo ¶

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

func FromRingInfoArray ¶

func FromRingInfoArray(t []*types.RingInfo) []*sharedv1.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 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) *sharedv1.SyncActivityTaskAttributes

func FromSyncShardStatus ¶

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

func FromSyncShardStatusTaskAttributes ¶

func FromSyncShardStatusTaskAttributes(t *types.SyncShardStatusTaskAttributes) *sharedv1.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) sharedv1.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 FromUpdateDynamicConfigRequest ¶ added in v0.23.1

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

FromUpdateDynamicConfigRequest converts internal UpdateDynamicConfigRequest type to proto

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) *sharedv1.VersionHistory

func FromVersionHistoryArray ¶

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

func FromVersionHistoryItem ¶

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

func FromVersionHistoryItemArray ¶

func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*sharedv1.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 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 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 ToAdminGetDomainReplicationMessagesRequest ¶

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

func ToAdminGetDomainReplicationMessagesResponse ¶

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

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

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

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 ToCrossClusterCancelExecutionRequestAttributes ¶ added in v0.23.1

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

ToCrossClusterCancelExecutionRequestAttributes converts proto CrossClusterCancelExecutionRequestAttributes type to internal

func ToCrossClusterCancelExecutionResponseAttributes ¶ added in v0.23.1

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

ToCrossClusterCancelExecutionResponseAttributes converts proto CrossClusterCancelExecutionResponseAttributes type to internal

func ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes ¶ added in v0.23.1

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

ToCrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes converts proto CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes type to internal

func ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes ¶ added in v0.23.1

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

ToCrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes converts proto CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes type to internal

func ToCrossClusterSignalExecutionRequestAttributes ¶ added in v0.23.1

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

ToCrossClusterSignalExecutionRequestAttributes converts proto CrossClusterSignalExecutionRequestAttributes type to internal

func ToCrossClusterSignalExecutionResponseAttributes ¶ added in v0.23.1

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

ToCrossClusterSignalExecutionResponseAttributes converts proto CrossClusterSignalExecutionResponseAttributes type to internal

func ToCrossClusterStartChildExecutionRequestAttributes ¶ added in v0.23.1

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

ToCrossClusterStartChildExecutionRequestAttributes converts proto CrossClusterStartChildExecutionRequestAttributes type to internal

func ToCrossClusterStartChildExecutionResponseAttributes ¶ added in v0.23.1

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

ToCrossClusterStartChildExecutionResponseAttributes converts proto CrossClusterStartChildExecutionResponseAttributes type to internal

func ToCrossClusterTaskFailedCause ¶ added in v0.23.1

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

ToCrossClusterTaskFailedCause converts proto CrossClusterTaskFailedCause type to internal

func ToCrossClusterTaskInfo ¶ added in v0.23.1

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

ToCrossClusterTaskInfo converts proto CrossClusterTaskInfo type to internal

func ToCrossClusterTaskRequest ¶ added in v0.23.1

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

ToCrossClusterTaskRequest converts proto CrossClusterTaskRequest type to internal

func ToCrossClusterTaskRequestArray ¶ added in v0.23.1

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

ToCrossClusterTaskRequestArray converts proto CrossClusterTaskRequest type array to internal

func ToCrossClusterTaskRequestMap ¶ added in v0.23.1

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

ToCrossClusterTaskRequestMap converts proto CrossClusterTaskRequest type map to internal

func ToCrossClusterTaskResponse ¶ added in v0.23.1

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

ToCrossClusterTaskResponse converts proto CrossClusterTaskResponse type to internal

func ToCrossClusterTaskResponseArray ¶ added in v0.23.1

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

ToCrossClusterTaskResponseArray converts proto CrossClusterTaskResponse type array to internal

func ToCrossClusterTaskType ¶ added in v0.23.1

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

ToCrossClusterTaskType converts proto CrossClusterTaskType type to internal

func ToDLQType ¶

func ToDLQType(t sharedv1.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 ToDescribeWorkflowExecutionRequest ¶

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

func ToDescribeWorkflowExecutionResponse ¶

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

func ToDomainCacheInfo ¶

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

func ToDomainOperation ¶

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

func ToDomainStatus ¶

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

func ToDomainTaskAttributes ¶

func ToDomainTaskAttributes(t *sharedv1.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 *sharedv1.VersionHistoryItem) *int64

func ToEventVersion ¶

func ToEventVersion(item *sharedv1.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 ToFailoverMarkerAttributes ¶

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

func ToFailoverMarkerToken ¶

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

func ToFailoverMarkerTokenArray ¶

func ToFailoverMarkerTokenArray(t []*sharedv1.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 ToGetDynamicConfigRequest ¶ added in v0.23.1

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

ToGetDynamicConfigRequest converts proto GetDynamicConfigRequest type to internal

func ToGetDynamicConfigResponse ¶ added in v0.23.1

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

ToGetDynamicConfigResponse converts proto GetDynamicConfigResponse type to internal

func ToGetSearchAttributesResponse ¶

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

func ToGetTaskFailedCause ¶ added in v0.23.1

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

ToGetTaskFailedCause converts proto GetTaskFailedCause type to internal

func ToGetTaskFailedCauseMap ¶ added in v0.23.1

func ToGetTaskFailedCauseMap(t map[int32]sharedv1.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 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 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 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 *sharedv1.HistoryTaskV2Attributes) *types.HistoryTaskV2Attributes

func ToHistoryTerminateWorkflowExecutionRequest ¶

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

func ToHostInfo ¶

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

func ToHostInfoArray ¶

func ToHostInfoArray(t []*sharedv1.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 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 ToListDynamicConfigRequest ¶ added in v0.23.1

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

ToListDynamicConfigRequest converts proto ListDynamicConfigRequest type to internal

func ToListDynamicConfigResponse ¶ added in v0.23.1

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

ToListDynamicConfigResponse converts proto ListDynamicConfigResponse type to internal

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 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 *sharedv1.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 *sharedv1.PersistenceFeature) *types.PersistenceFeature

func ToPersistenceFeatures ¶ added in v0.21.0

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

func ToPersistenceInfo ¶ added in v0.21.0

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

func ToPersistenceInfoMap ¶ added in v0.21.0

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

func ToPersistenceSetting ¶ added in v0.21.0

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

func ToPersistenceSettings ¶ added in v0.21.0

func ToPersistenceSettings(t []*sharedv1.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 ToRegisterDomainRequest ¶

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

func ToReplicationMessages ¶

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

func ToReplicationMessagesMap ¶

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

func ToReplicationTask ¶

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

func ToReplicationTaskArray ¶

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

func ToReplicationTaskInfo ¶

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

func ToReplicationTaskInfoArray ¶

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

func ToReplicationTaskType ¶

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

func ToReplicationToken ¶

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

func ToReplicationTokenArray ¶

func ToReplicationTokenArray(t []*sharedv1.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 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 ToRestoreDynamicConfigRequest ¶ added in v0.23.1

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

ToRestoreDynamicConfigRequest converts proto RestoreDynamicConfigRequest type to internal

func ToRetryPolicy ¶

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

func ToRingInfo ¶

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

func ToRingInfoArray ¶

func ToRingInfoArray(t []*sharedv1.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 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 *sharedv1.SyncActivityTaskAttributes) *types.SyncActivityTaskAttributes

func ToSyncShardStatus ¶

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

func ToSyncShardStatusTaskAttributes ¶

func ToSyncShardStatusTaskAttributes(t *sharedv1.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 sharedv1.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 ToUpdateDynamicConfigRequest ¶ added in v0.23.1

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

ToUpdateDynamicConfigRequest converts proto UpdateDynamicConfigRequest type to internal

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 *sharedv1.VersionHistory) *types.VersionHistory

func ToVersionHistoryArray ¶

func ToVersionHistoryArray(t []*sharedv1.VersionHistory) []*types.VersionHistory

func ToVersionHistoryItem ¶

func ToVersionHistoryItem(t *sharedv1.VersionHistoryItem) *types.VersionHistoryItem

func ToVersionHistoryItemArray ¶

func ToVersionHistoryItemArray(t []*sharedv1.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