thrift

package

v0.19.1 Latest Latest Go to latest Published: Mar 30, 2021 License: MIT Imports: 7 Imported by: 0

Details

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

Repository

github.com/uber/cadence

Links

Open Source Insights

Documentation ¶

Index ¶

func FromAccessDeniedError(t *types.AccessDeniedError) *shared.AccessDeniedError
func FromActivityLocalDispatchInfo(t *types.ActivityLocalDispatchInfo) *shared.ActivityLocalDispatchInfo
func FromActivityLocalDispatchInfoMap(t map[string]*types.ActivityLocalDispatchInfo) map[string]*shared.ActivityLocalDispatchInfo
func FromActivityTaskCancelRequestedEventAttributes(t *types.ActivityTaskCancelRequestedEventAttributes) *shared.ActivityTaskCancelRequestedEventAttributes
func FromActivityTaskCanceledEventAttributes(t *types.ActivityTaskCanceledEventAttributes) *shared.ActivityTaskCanceledEventAttributes
func FromActivityTaskCompletedEventAttributes(t *types.ActivityTaskCompletedEventAttributes) *shared.ActivityTaskCompletedEventAttributes
func FromActivityTaskFailedEventAttributes(t *types.ActivityTaskFailedEventAttributes) *shared.ActivityTaskFailedEventAttributes
func FromActivityTaskScheduledEventAttributes(t *types.ActivityTaskScheduledEventAttributes) *shared.ActivityTaskScheduledEventAttributes
func FromActivityTaskStartedEventAttributes(t *types.ActivityTaskStartedEventAttributes) *shared.ActivityTaskStartedEventAttributes
func FromActivityTaskTimedOutEventAttributes(t *types.ActivityTaskTimedOutEventAttributes) *shared.ActivityTaskTimedOutEventAttributes
func FromActivityType(t *types.ActivityType) *shared.ActivityType
func FromAddActivityTaskRequest(t *types.AddActivityTaskRequest) *matching.AddActivityTaskRequest
func FromAddDecisionTaskRequest(t *types.AddDecisionTaskRequest) *matching.AddDecisionTaskRequest
func FromAddSearchAttributeRequest(t *types.AddSearchAttributeRequest) *admin.AddSearchAttributeRequest
func FromAdminDescribeWorkflowExecutionRequest(t *types.AdminDescribeWorkflowExecutionRequest) *admin.DescribeWorkflowExecutionRequest
func FromAdminDescribeWorkflowExecutionResponse(t *types.AdminDescribeWorkflowExecutionResponse) *admin.DescribeWorkflowExecutionResponse
func FromArchivalStatus(t *types.ArchivalStatus) *shared.ArchivalStatus
func FromBadBinaries(t *types.BadBinaries) *shared.BadBinaries
func FromBadBinaryInfo(t *types.BadBinaryInfo) *shared.BadBinaryInfo
func FromBadBinaryInfoMap(t map[string]*types.BadBinaryInfo) map[string]*shared.BadBinaryInfo
func FromBadRequestError(t *types.BadRequestError) *shared.BadRequestError
func FromCancelExternalWorkflowExecutionFailedCause(t *types.CancelExternalWorkflowExecutionFailedCause) *shared.CancelExternalWorkflowExecutionFailedCause
func FromCancelOutstandingPollRequest(t *types.CancelOutstandingPollRequest) *matching.CancelOutstandingPollRequest
func FromCancelTimerDecisionAttributes(t *types.CancelTimerDecisionAttributes) *shared.CancelTimerDecisionAttributes
func FromCancelTimerFailedEventAttributes(t *types.CancelTimerFailedEventAttributes) *shared.CancelTimerFailedEventAttributes
func FromCancelWorkflowExecutionDecisionAttributes(t *types.CancelWorkflowExecutionDecisionAttributes) *shared.CancelWorkflowExecutionDecisionAttributes
func FromCancellationAlreadyRequestedError(t *types.CancellationAlreadyRequestedError) *shared.CancellationAlreadyRequestedError
func FromChildWorkflowExecutionCanceledEventAttributes(t *types.ChildWorkflowExecutionCanceledEventAttributes) *shared.ChildWorkflowExecutionCanceledEventAttributes
func FromChildWorkflowExecutionCompletedEventAttributes(t *types.ChildWorkflowExecutionCompletedEventAttributes) *shared.ChildWorkflowExecutionCompletedEventAttributes
func FromChildWorkflowExecutionFailedCause(t *types.ChildWorkflowExecutionFailedCause) *shared.ChildWorkflowExecutionFailedCause
func FromChildWorkflowExecutionFailedEventAttributes(t *types.ChildWorkflowExecutionFailedEventAttributes) *shared.ChildWorkflowExecutionFailedEventAttributes
func FromChildWorkflowExecutionStartedEventAttributes(t *types.ChildWorkflowExecutionStartedEventAttributes) *shared.ChildWorkflowExecutionStartedEventAttributes
func FromChildWorkflowExecutionTerminatedEventAttributes(t *types.ChildWorkflowExecutionTerminatedEventAttributes) *shared.ChildWorkflowExecutionTerminatedEventAttributes
func FromChildWorkflowExecutionTimedOutEventAttributes(t *types.ChildWorkflowExecutionTimedOutEventAttributes) *shared.ChildWorkflowExecutionTimedOutEventAttributes
func FromClientVersionNotSupportedError(t *types.ClientVersionNotSupportedError) *shared.ClientVersionNotSupportedError
func FromCloseShardRequest(t *types.CloseShardRequest) *shared.CloseShardRequest
func FromClusterInfo(t *types.ClusterInfo) *shared.ClusterInfo
func FromClusterReplicationConfiguration(t *types.ClusterReplicationConfiguration) *shared.ClusterReplicationConfiguration
func FromClusterReplicationConfigurationArray(t []*types.ClusterReplicationConfiguration) []*shared.ClusterReplicationConfiguration
func FromCompleteWorkflowExecutionDecisionAttributes(t *types.CompleteWorkflowExecutionDecisionAttributes) *shared.CompleteWorkflowExecutionDecisionAttributes
func FromContinueAsNewInitiator(t *types.ContinueAsNewInitiator) *shared.ContinueAsNewInitiator
func FromContinueAsNewWorkflowExecutionDecisionAttributes(t *types.ContinueAsNewWorkflowExecutionDecisionAttributes) *shared.ContinueAsNewWorkflowExecutionDecisionAttributes
func FromCountWorkflowExecutionsRequest(t *types.CountWorkflowExecutionsRequest) *shared.CountWorkflowExecutionsRequest
func FromCountWorkflowExecutionsResponse(t *types.CountWorkflowExecutionsResponse) *shared.CountWorkflowExecutionsResponse
func FromCurrentBranchChangedError(t *types.CurrentBranchChangedError) *shared.CurrentBranchChangedError
func FromDLQType(t *types.DLQType) *replicator.DLQType
func FromDataBlob(t *types.DataBlob) *shared.DataBlob
func FromDataBlobArray(t []*types.DataBlob) []*shared.DataBlob
func FromDecision(t *types.Decision) *shared.Decision
func FromDecisionArray(t []*types.Decision) []*shared.Decision
func FromDecisionTaskCompletedEventAttributes(t *types.DecisionTaskCompletedEventAttributes) *shared.DecisionTaskCompletedEventAttributes
func FromDecisionTaskFailedCause(t *types.DecisionTaskFailedCause) *shared.DecisionTaskFailedCause
func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttributes) *shared.DecisionTaskFailedEventAttributes
func FromDecisionTaskScheduledEventAttributes(t *types.DecisionTaskScheduledEventAttributes) *shared.DecisionTaskScheduledEventAttributes
func FromDecisionTaskStartedEventAttributes(t *types.DecisionTaskStartedEventAttributes) *shared.DecisionTaskStartedEventAttributes
func FromDecisionTaskTimedOutCause(t *types.DecisionTaskTimedOutCause) *shared.DecisionTaskTimedOutCause
func FromDecisionTaskTimedOutEventAttributes(t *types.DecisionTaskTimedOutEventAttributes) *shared.DecisionTaskTimedOutEventAttributes
func FromDecisionType(t *types.DecisionType) *shared.DecisionType
func FromDeprecateDomainRequest(t *types.DeprecateDomainRequest) *shared.DeprecateDomainRequest
func FromDescribeClusterResponse(t *types.DescribeClusterResponse) *admin.DescribeClusterResponse
func FromDescribeDomainRequest(t *types.DescribeDomainRequest) *shared.DescribeDomainRequest
func FromDescribeDomainResponse(t *types.DescribeDomainResponse) *shared.DescribeDomainResponse
func FromDescribeDomainResponseArray(t []*types.DescribeDomainResponse) []*shared.DescribeDomainResponse
func FromDescribeHistoryHostRequest(t *types.DescribeHistoryHostRequest) *shared.DescribeHistoryHostRequest
func FromDescribeHistoryHostResponse(t *types.DescribeHistoryHostResponse) *shared.DescribeHistoryHostResponse
func FromDescribeMutableStateRequest(t *types.DescribeMutableStateRequest) *history.DescribeMutableStateRequest
func FromDescribeMutableStateResponse(t *types.DescribeMutableStateResponse) *history.DescribeMutableStateResponse
func FromDescribeQueueRequest(t *types.DescribeQueueRequest) *shared.DescribeQueueRequest
func FromDescribeQueueResponse(t *types.DescribeQueueResponse) *shared.DescribeQueueResponse
func FromDescribeTaskListRequest(t *types.DescribeTaskListRequest) *shared.DescribeTaskListRequest
func FromDescribeTaskListResponse(t *types.DescribeTaskListResponse) *shared.DescribeTaskListResponse
func FromDescribeWorkflowExecutionRequest(t *types.DescribeWorkflowExecutionRequest) *shared.DescribeWorkflowExecutionRequest
func FromDescribeWorkflowExecutionResponse(t *types.DescribeWorkflowExecutionResponse) *shared.DescribeWorkflowExecutionResponse
func FromDomainAlreadyExistsError(t *types.DomainAlreadyExistsError) *shared.DomainAlreadyExistsError
func FromDomainCacheInfo(t *types.DomainCacheInfo) *shared.DomainCacheInfo
func FromDomainConfiguration(t *types.DomainConfiguration) *shared.DomainConfiguration
func FromDomainFilter(t *types.DomainFilter) *history.DomainFilter
func FromDomainInfo(t *types.DomainInfo) *shared.DomainInfo
func FromDomainNotActiveError(t *types.DomainNotActiveError) *shared.DomainNotActiveError
func FromDomainOperation(t *types.DomainOperation) *replicator.DomainOperation
func FromDomainReplicationConfiguration(t *types.DomainReplicationConfiguration) *shared.DomainReplicationConfiguration
func FromDomainStatus(t *types.DomainStatus) *shared.DomainStatus
func FromDomainTaskAttributes(t *types.DomainTaskAttributes) *replicator.DomainTaskAttributes
func FromEncodingType(t *types.EncodingType) *shared.EncodingType
func FromEntityNotExistsError(t *types.EntityNotExistsError) *shared.EntityNotExistsError
func FromError(err error) error
func FromEventAlreadyStartedError(t *types.EventAlreadyStartedError) *history.EventAlreadyStartedError
func FromEventType(t *types.EventType) *shared.EventType
func FromExternalWorkflowExecutionCancelRequestedEventAttributes(t *types.ExternalWorkflowExecutionCancelRequestedEventAttributes) *shared.ExternalWorkflowExecutionCancelRequestedEventAttributes
func FromExternalWorkflowExecutionSignaledEventAttributes(t *types.ExternalWorkflowExecutionSignaledEventAttributes) *shared.ExternalWorkflowExecutionSignaledEventAttributes
func FromFailWorkflowExecutionDecisionAttributes(t *types.FailWorkflowExecutionDecisionAttributes) *shared.FailWorkflowExecutionDecisionAttributes
func FromFailoverMarkerAttributes(t *types.FailoverMarkerAttributes) *replicator.FailoverMarkerAttributes
func FromFailoverMarkerAttributesArray(t []*types.FailoverMarkerAttributes) []*replicator.FailoverMarkerAttributes
func FromFailoverMarkerToken(t *types.FailoverMarkerToken) *history.FailoverMarkerToken
func FromFailoverMarkerTokenArray(t []*types.FailoverMarkerToken) []*history.FailoverMarkerToken
func FromFailoverMarkers(t *types.FailoverMarkers) *replicator.FailoverMarkers
func FromGetDLQReplicationMessagesRequest(t *types.GetDLQReplicationMessagesRequest) *replicator.GetDLQReplicationMessagesRequest
func FromGetDLQReplicationMessagesResponse(t *types.GetDLQReplicationMessagesResponse) *replicator.GetDLQReplicationMessagesResponse
func FromGetDomainReplicationMessagesRequest(t *types.GetDomainReplicationMessagesRequest) *replicator.GetDomainReplicationMessagesRequest
func FromGetDomainReplicationMessagesResponse(t *types.GetDomainReplicationMessagesResponse) *replicator.GetDomainReplicationMessagesResponse
func FromGetMutableStateRequest(t *types.GetMutableStateRequest) *history.GetMutableStateRequest
func FromGetMutableStateResponse(t *types.GetMutableStateResponse) *history.GetMutableStateResponse
func FromGetReplicationMessagesRequest(t *types.GetReplicationMessagesRequest) *replicator.GetReplicationMessagesRequest
func FromGetReplicationMessagesResponse(t *types.GetReplicationMessagesResponse) *replicator.GetReplicationMessagesResponse
func FromGetSearchAttributesResponse(t *types.GetSearchAttributesResponse) *shared.GetSearchAttributesResponse
func FromGetWorkflowExecutionHistoryRequest(t *types.GetWorkflowExecutionHistoryRequest) *shared.GetWorkflowExecutionHistoryRequest
func FromGetWorkflowExecutionHistoryResponse(t *types.GetWorkflowExecutionHistoryResponse) *shared.GetWorkflowExecutionHistoryResponse
func FromGetWorkflowExecutionRawHistoryV2Request(t *types.GetWorkflowExecutionRawHistoryV2Request) *admin.GetWorkflowExecutionRawHistoryV2Request
func FromGetWorkflowExecutionRawHistoryV2Response(t *types.GetWorkflowExecutionRawHistoryV2Response) *admin.GetWorkflowExecutionRawHistoryV2Response
func FromHeader(t *types.Header) *shared.Header
func FromHealthStatus(t *types.HealthStatus) *health.HealthStatus
func FromHistory(t *types.History) *shared.History
func FromHistoryArray(t []*types.History) []*shared.History
func FromHistoryBranch(t *types.HistoryBranch) *shared.HistoryBranch
func FromHistoryBranchRange(t *types.HistoryBranchRange) *shared.HistoryBranchRange
func FromHistoryBranchRangeArray(t []*types.HistoryBranchRange) []*shared.HistoryBranchRange
func FromHistoryDescribeWorkflowExecutionRequest(t *types.HistoryDescribeWorkflowExecutionRequest) *history.DescribeWorkflowExecutionRequest
func FromHistoryEvent(t *types.HistoryEvent) *shared.HistoryEvent
func FromHistoryEventArray(t []*types.HistoryEvent) []*shared.HistoryEvent
func FromHistoryEventFilterType(t *types.HistoryEventFilterType) *shared.HistoryEventFilterType
func FromHistoryQueryWorkflowRequest(t *types.HistoryQueryWorkflowRequest) *history.QueryWorkflowRequest
func FromHistoryQueryWorkflowResponse(t *types.HistoryQueryWorkflowResponse) *history.QueryWorkflowResponse
func FromHistoryReapplyEventsRequest(t *types.HistoryReapplyEventsRequest) *history.ReapplyEventsRequest
func FromHistoryRecordActivityTaskHeartbeatRequest(t *types.HistoryRecordActivityTaskHeartbeatRequest) *history.RecordActivityTaskHeartbeatRequest
func FromHistoryRefreshWorkflowTasksRequest(t *types.HistoryRefreshWorkflowTasksRequest) *history.RefreshWorkflowTasksRequest
func FromHistoryRequestCancelWorkflowExecutionRequest(t *types.HistoryRequestCancelWorkflowExecutionRequest) *history.RequestCancelWorkflowExecutionRequest
func FromHistoryResetStickyTaskListRequest(t *types.HistoryResetStickyTaskListRequest) *history.ResetStickyTaskListRequest
func FromHistoryResetStickyTaskListResponse(t *types.HistoryResetStickyTaskListResponse) *history.ResetStickyTaskListResponse
func FromHistoryResetWorkflowExecutionRequest(t *types.HistoryResetWorkflowExecutionRequest) *history.ResetWorkflowExecutionRequest
func FromHistoryRespondActivityTaskCanceledRequest(t *types.HistoryRespondActivityTaskCanceledRequest) *history.RespondActivityTaskCanceledRequest
func FromHistoryRespondActivityTaskCompletedRequest(t *types.HistoryRespondActivityTaskCompletedRequest) *history.RespondActivityTaskCompletedRequest
func FromHistoryRespondActivityTaskFailedRequest(t *types.HistoryRespondActivityTaskFailedRequest) *history.RespondActivityTaskFailedRequest
func FromHistoryRespondDecisionTaskCompletedRequest(t *types.HistoryRespondDecisionTaskCompletedRequest) *history.RespondDecisionTaskCompletedRequest
func FromHistoryRespondDecisionTaskCompletedResponse(t *types.HistoryRespondDecisionTaskCompletedResponse) *history.RespondDecisionTaskCompletedResponse
func FromHistoryRespondDecisionTaskFailedRequest(t *types.HistoryRespondDecisionTaskFailedRequest) *history.RespondDecisionTaskFailedRequest
func FromHistorySignalWithStartWorkflowExecutionRequest(t *types.HistorySignalWithStartWorkflowExecutionRequest) *history.SignalWithStartWorkflowExecutionRequest
func FromHistorySignalWorkflowExecutionRequest(t *types.HistorySignalWorkflowExecutionRequest) *history.SignalWorkflowExecutionRequest
func FromHistoryStartWorkflowExecutionRequest(t *types.HistoryStartWorkflowExecutionRequest) *history.StartWorkflowExecutionRequest
func FromHistoryTaskV2Attributes(t *types.HistoryTaskV2Attributes) *replicator.HistoryTaskV2Attributes
func FromHistoryTerminateWorkflowExecutionRequest(t *types.HistoryTerminateWorkflowExecutionRequest) *history.TerminateWorkflowExecutionRequest
func FromHostInfo(t *types.HostInfo) *admin.HostInfo
func FromHostInfoArray(t []*types.HostInfo) []*admin.HostInfo
func FromIndexedValueType(t types.IndexedValueType) shared.IndexedValueType
func FromIndexedValueTypeMap(t map[string]types.IndexedValueType) map[string]shared.IndexedValueType
func FromInternalDataInconsistencyError(t *types.InternalDataInconsistencyError) *shared.InternalDataInconsistencyError
func FromInternalServiceError(t *types.InternalServiceError) *shared.InternalServiceError
func FromLimitExceededError(t *types.LimitExceededError) *shared.LimitExceededError
func FromListArchivedWorkflowExecutionsRequest(t *types.ListArchivedWorkflowExecutionsRequest) *shared.ListArchivedWorkflowExecutionsRequest
func FromListArchivedWorkflowExecutionsResponse(t *types.ListArchivedWorkflowExecutionsResponse) *shared.ListArchivedWorkflowExecutionsResponse
func FromListClosedWorkflowExecutionsRequest(t *types.ListClosedWorkflowExecutionsRequest) *shared.ListClosedWorkflowExecutionsRequest
func FromListClosedWorkflowExecutionsResponse(t *types.ListClosedWorkflowExecutionsResponse) *shared.ListClosedWorkflowExecutionsResponse
func FromListDomainsRequest(t *types.ListDomainsRequest) *shared.ListDomainsRequest
func FromListDomainsResponse(t *types.ListDomainsResponse) *shared.ListDomainsResponse
func FromListOpenWorkflowExecutionsRequest(t *types.ListOpenWorkflowExecutionsRequest) *shared.ListOpenWorkflowExecutionsRequest
func FromListOpenWorkflowExecutionsResponse(t *types.ListOpenWorkflowExecutionsResponse) *shared.ListOpenWorkflowExecutionsResponse
func FromListTaskListPartitionsRequest(t *types.ListTaskListPartitionsRequest) *shared.ListTaskListPartitionsRequest
func FromListTaskListPartitionsResponse(t *types.ListTaskListPartitionsResponse) *shared.ListTaskListPartitionsResponse
func FromListWorkflowExecutionsRequest(t *types.ListWorkflowExecutionsRequest) *shared.ListWorkflowExecutionsRequest
func FromListWorkflowExecutionsResponse(t *types.ListWorkflowExecutionsResponse) *shared.ListWorkflowExecutionsResponse
func FromMarkerRecordedEventAttributes(t *types.MarkerRecordedEventAttributes) *shared.MarkerRecordedEventAttributes
func FromMatchingDescribeTaskListRequest(t *types.MatchingDescribeTaskListRequest) *matching.DescribeTaskListRequest
func FromMatchingListTaskListPartitionsRequest(t *types.MatchingListTaskListPartitionsRequest) *matching.ListTaskListPartitionsRequest
func FromMatchingPollForActivityTaskRequest(t *types.MatchingPollForActivityTaskRequest) *matching.PollForActivityTaskRequest
func FromMatchingPollForDecisionTaskRequest(t *types.MatchingPollForDecisionTaskRequest) *matching.PollForDecisionTaskRequest
func FromMatchingPollForDecisionTaskResponse(t *types.MatchingPollForDecisionTaskResponse) *matching.PollForDecisionTaskResponse
func FromMatchingQueryWorkflowRequest(t *types.MatchingQueryWorkflowRequest) *matching.QueryWorkflowRequest
func FromMatchingRespondQueryTaskCompletedRequest(t *types.MatchingRespondQueryTaskCompletedRequest) *matching.RespondQueryTaskCompletedRequest
func FromMembershipInfo(t *types.MembershipInfo) *admin.MembershipInfo
func FromMemo(t *types.Memo) *shared.Memo
func FromMergeDLQMessagesRequest(t *types.MergeDLQMessagesRequest) *replicator.MergeDLQMessagesRequest
func FromMergeDLQMessagesResponse(t *types.MergeDLQMessagesResponse) *replicator.MergeDLQMessagesResponse
func FromNotifyFailoverMarkersRequest(t *types.NotifyFailoverMarkersRequest) *history.NotifyFailoverMarkersRequest
func FromParentClosePolicy(t *types.ParentClosePolicy) *shared.ParentClosePolicy
func FromParentExecutionInfo(t *types.ParentExecutionInfo) *history.ParentExecutionInfo
func FromPendingActivityInfo(t *types.PendingActivityInfo) *shared.PendingActivityInfo
func FromPendingActivityInfoArray(t []*types.PendingActivityInfo) []*shared.PendingActivityInfo
func FromPendingActivityState(t *types.PendingActivityState) *shared.PendingActivityState
func FromPendingChildExecutionInfo(t *types.PendingChildExecutionInfo) *shared.PendingChildExecutionInfo
func FromPendingChildExecutionInfoArray(t []*types.PendingChildExecutionInfo) []*shared.PendingChildExecutionInfo
func FromPendingDecisionInfo(t *types.PendingDecisionInfo) *shared.PendingDecisionInfo
func FromPendingDecisionState(t *types.PendingDecisionState) *shared.PendingDecisionState
func FromPollForActivityTaskRequest(t *types.PollForActivityTaskRequest) *shared.PollForActivityTaskRequest
func FromPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *shared.PollForActivityTaskResponse
func FromPollForDecisionTaskRequest(t *types.PollForDecisionTaskRequest) *shared.PollForDecisionTaskRequest
func FromPollForDecisionTaskResponse(t *types.PollForDecisionTaskResponse) *shared.PollForDecisionTaskResponse
func FromPollMutableStateRequest(t *types.PollMutableStateRequest) *history.PollMutableStateRequest
func FromPollMutableStateResponse(t *types.PollMutableStateResponse) *history.PollMutableStateResponse
func FromPollerInfo(t *types.PollerInfo) *shared.PollerInfo
func FromPollerInfoArray(t []*types.PollerInfo) []*shared.PollerInfo
func FromProcessingQueueState(t *types.ProcessingQueueState) *history.ProcessingQueueState
func FromProcessingQueueStateArray(t []*types.ProcessingQueueState) []*history.ProcessingQueueState
func FromProcessingQueueStateArrayMap(t map[string][]*types.ProcessingQueueState) map[string][]*history.ProcessingQueueState
func FromProcessingQueueStates(t *types.ProcessingQueueStates) *history.ProcessingQueueStates
func FromPurgeDLQMessagesRequest(t *types.PurgeDLQMessagesRequest) *replicator.PurgeDLQMessagesRequest
func FromQueryConsistencyLevel(t *types.QueryConsistencyLevel) *shared.QueryConsistencyLevel
func FromQueryFailedError(t *types.QueryFailedError) *shared.QueryFailedError
func FromQueryRejectCondition(t *types.QueryRejectCondition) *shared.QueryRejectCondition
func FromQueryRejected(t *types.QueryRejected) *shared.QueryRejected
func FromQueryResultType(t *types.QueryResultType) *shared.QueryResultType
func FromQueryTaskCompletedType(t *types.QueryTaskCompletedType) *shared.QueryTaskCompletedType
func FromQueryWorkflowRequest(t *types.QueryWorkflowRequest) *shared.QueryWorkflowRequest
func FromQueryWorkflowResponse(t *types.QueryWorkflowResponse) *shared.QueryWorkflowResponse
func FromReadDLQMessagesRequest(t *types.ReadDLQMessagesRequest) *replicator.ReadDLQMessagesRequest
func FromReadDLQMessagesResponse(t *types.ReadDLQMessagesResponse) *replicator.ReadDLQMessagesResponse
func FromReapplyEventsRequest(t *types.ReapplyEventsRequest) *shared.ReapplyEventsRequest
func FromRecordActivityTaskHeartbeatByIDRequest(t *types.RecordActivityTaskHeartbeatByIDRequest) *shared.RecordActivityTaskHeartbeatByIDRequest
func FromRecordActivityTaskHeartbeatRequest(t *types.RecordActivityTaskHeartbeatRequest) *shared.RecordActivityTaskHeartbeatRequest
func FromRecordActivityTaskHeartbeatResponse(t *types.RecordActivityTaskHeartbeatResponse) *shared.RecordActivityTaskHeartbeatResponse
func FromRecordActivityTaskStartedRequest(t *types.RecordActivityTaskStartedRequest) *history.RecordActivityTaskStartedRequest
func FromRecordActivityTaskStartedResponse(t *types.RecordActivityTaskStartedResponse) *history.RecordActivityTaskStartedResponse
func FromRecordChildExecutionCompletedRequest(t *types.RecordChildExecutionCompletedRequest) *history.RecordChildExecutionCompletedRequest
func FromRecordDecisionTaskStartedRequest(t *types.RecordDecisionTaskStartedRequest) *history.RecordDecisionTaskStartedRequest
func FromRecordDecisionTaskStartedResponse(t *types.RecordDecisionTaskStartedResponse) *history.RecordDecisionTaskStartedResponse
func FromRecordMarkerDecisionAttributes(t *types.RecordMarkerDecisionAttributes) *shared.RecordMarkerDecisionAttributes
func FromRefreshWorkflowTasksRequest(t *types.RefreshWorkflowTasksRequest) *shared.RefreshWorkflowTasksRequest
func FromRegisterDomainRequest(t *types.RegisterDomainRequest) *shared.RegisterDomainRequest
func FromRemoteSyncMatchedError(t *types.RemoteSyncMatchedError) *shared.RemoteSyncMatchedError
func FromRemoveSignalMutableStateRequest(t *types.RemoveSignalMutableStateRequest) *history.RemoveSignalMutableStateRequest
func FromRemoveTaskRequest(t *types.RemoveTaskRequest) *shared.RemoveTaskRequest
func FromReplicateEventsV2Request(t *types.ReplicateEventsV2Request) *history.ReplicateEventsV2Request
func FromReplicationMessages(t *types.ReplicationMessages) *replicator.ReplicationMessages
func FromReplicationMessagesMap(t map[int32]*types.ReplicationMessages) map[int32]*replicator.ReplicationMessages
func FromReplicationTask(t *types.ReplicationTask) *replicator.ReplicationTask
func FromReplicationTaskArray(t []*types.ReplicationTask) []*replicator.ReplicationTask
func FromReplicationTaskInfo(t *types.ReplicationTaskInfo) *replicator.ReplicationTaskInfo
func FromReplicationTaskInfoArray(t []*types.ReplicationTaskInfo) []*replicator.ReplicationTaskInfo
func FromReplicationTaskType(t *types.ReplicationTaskType) *replicator.ReplicationTaskType
func FromReplicationToken(t *types.ReplicationToken) *replicator.ReplicationToken
func FromReplicationTokenArray(t []*types.ReplicationToken) []*replicator.ReplicationToken
func FromRequestCancelActivityTaskDecisionAttributes(t *types.RequestCancelActivityTaskDecisionAttributes) *shared.RequestCancelActivityTaskDecisionAttributes
func FromRequestCancelActivityTaskFailedEventAttributes(t *types.RequestCancelActivityTaskFailedEventAttributes) *shared.RequestCancelActivityTaskFailedEventAttributes
func FromRequestCancelExternalWorkflowExecutionDecisionAttributes(t *types.RequestCancelExternalWorkflowExecutionDecisionAttributes) *shared.RequestCancelExternalWorkflowExecutionDecisionAttributes
func FromRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *shared.RequestCancelExternalWorkflowExecutionFailedEventAttributes
func FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *shared.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
func FromRequestCancelWorkflowExecutionRequest(t *types.RequestCancelWorkflowExecutionRequest) *shared.RequestCancelWorkflowExecutionRequest
func FromResendReplicationTasksRequest(t *types.ResendReplicationTasksRequest) *admin.ResendReplicationTasksRequest
func FromResetPointInfo(t *types.ResetPointInfo) *shared.ResetPointInfo
func FromResetPointInfoArray(t []*types.ResetPointInfo) []*shared.ResetPointInfo
func FromResetPoints(t *types.ResetPoints) *shared.ResetPoints
func FromResetQueueRequest(t *types.ResetQueueRequest) *shared.ResetQueueRequest
func FromResetStickyTaskListRequest(t *types.ResetStickyTaskListRequest) *shared.ResetStickyTaskListRequest
func FromResetStickyTaskListResponse(t *types.ResetStickyTaskListResponse) *shared.ResetStickyTaskListResponse
func FromResetWorkflowExecutionRequest(t *types.ResetWorkflowExecutionRequest) *shared.ResetWorkflowExecutionRequest
func FromResetWorkflowExecutionResponse(t *types.ResetWorkflowExecutionResponse) *shared.ResetWorkflowExecutionResponse
func FromRespondActivityTaskCanceledByIDRequest(t *types.RespondActivityTaskCanceledByIDRequest) *shared.RespondActivityTaskCanceledByIDRequest
func FromRespondActivityTaskCanceledRequest(t *types.RespondActivityTaskCanceledRequest) *shared.RespondActivityTaskCanceledRequest
func FromRespondActivityTaskCompletedByIDRequest(t *types.RespondActivityTaskCompletedByIDRequest) *shared.RespondActivityTaskCompletedByIDRequest
func FromRespondActivityTaskCompletedRequest(t *types.RespondActivityTaskCompletedRequest) *shared.RespondActivityTaskCompletedRequest
func FromRespondActivityTaskFailedByIDRequest(t *types.RespondActivityTaskFailedByIDRequest) *shared.RespondActivityTaskFailedByIDRequest
func FromRespondActivityTaskFailedRequest(t *types.RespondActivityTaskFailedRequest) *shared.RespondActivityTaskFailedRequest
func FromRespondDecisionTaskCompletedRequest(t *types.RespondDecisionTaskCompletedRequest) *shared.RespondDecisionTaskCompletedRequest
func FromRespondDecisionTaskCompletedResponse(t *types.RespondDecisionTaskCompletedResponse) *shared.RespondDecisionTaskCompletedResponse
func FromRespondDecisionTaskFailedRequest(t *types.RespondDecisionTaskFailedRequest) *shared.RespondDecisionTaskFailedRequest
func FromRespondQueryTaskCompletedRequest(t *types.RespondQueryTaskCompletedRequest) *shared.RespondQueryTaskCompletedRequest
func FromRetryPolicy(t *types.RetryPolicy) *shared.RetryPolicy
func FromRetryTaskV2Error(t *types.RetryTaskV2Error) *shared.RetryTaskV2Error
func FromRingInfo(t *types.RingInfo) *admin.RingInfo
func FromRingInfoArray(t []*types.RingInfo) []*admin.RingInfo
func FromScheduleActivityTaskDecisionAttributes(t *types.ScheduleActivityTaskDecisionAttributes) *shared.ScheduleActivityTaskDecisionAttributes
func FromScheduleDecisionTaskRequest(t *types.ScheduleDecisionTaskRequest) *history.ScheduleDecisionTaskRequest
func FromSearchAttributes(t *types.SearchAttributes) *shared.SearchAttributes
func FromServiceBusyError(t *types.ServiceBusyError) *shared.ServiceBusyError
func FromShardOwnershipLostError(t *types.ShardOwnershipLostError) *history.ShardOwnershipLostError
func FromSignalExternalWorkflowExecutionDecisionAttributes(t *types.SignalExternalWorkflowExecutionDecisionAttributes) *shared.SignalExternalWorkflowExecutionDecisionAttributes
func FromSignalExternalWorkflowExecutionFailedCause(t *types.SignalExternalWorkflowExecutionFailedCause) *shared.SignalExternalWorkflowExecutionFailedCause
func FromSignalExternalWorkflowExecutionFailedEventAttributes(t *types.SignalExternalWorkflowExecutionFailedEventAttributes) *shared.SignalExternalWorkflowExecutionFailedEventAttributes
func FromSignalExternalWorkflowExecutionInitiatedEventAttributes(t *types.SignalExternalWorkflowExecutionInitiatedEventAttributes) *shared.SignalExternalWorkflowExecutionInitiatedEventAttributes
func FromSignalWithStartWorkflowExecutionRequest(t *types.SignalWithStartWorkflowExecutionRequest) *shared.SignalWithStartWorkflowExecutionRequest
func FromSignalWorkflowExecutionRequest(t *types.SignalWorkflowExecutionRequest) *shared.SignalWorkflowExecutionRequest
func FromStartChildWorkflowExecutionDecisionAttributes(t *types.StartChildWorkflowExecutionDecisionAttributes) *shared.StartChildWorkflowExecutionDecisionAttributes
func FromStartChildWorkflowExecutionFailedEventAttributes(t *types.StartChildWorkflowExecutionFailedEventAttributes) *shared.StartChildWorkflowExecutionFailedEventAttributes
func FromStartChildWorkflowExecutionInitiatedEventAttributes(t *types.StartChildWorkflowExecutionInitiatedEventAttributes) *shared.StartChildWorkflowExecutionInitiatedEventAttributes
func FromStartTimeFilter(t *types.StartTimeFilter) *shared.StartTimeFilter
func FromStartTimerDecisionAttributes(t *types.StartTimerDecisionAttributes) *shared.StartTimerDecisionAttributes
func FromStartWorkflowExecutionRequest(t *types.StartWorkflowExecutionRequest) *shared.StartWorkflowExecutionRequest
func FromStartWorkflowExecutionResponse(t *types.StartWorkflowExecutionResponse) *shared.StartWorkflowExecutionResponse
func FromStickyExecutionAttributes(t *types.StickyExecutionAttributes) *shared.StickyExecutionAttributes
func FromSupportedClientVersions(t *types.SupportedClientVersions) *shared.SupportedClientVersions
func FromSyncActivityRequest(t *types.SyncActivityRequest) *history.SyncActivityRequest
func FromSyncActivityTaskAttributes(t *types.SyncActivityTaskAttributes) *replicator.SyncActivityTaskAttributes
func FromSyncShardStatus(t *types.SyncShardStatus) *replicator.SyncShardStatus
func FromSyncShardStatusRequest(t *types.SyncShardStatusRequest) *history.SyncShardStatusRequest
func FromSyncShardStatusTaskAttributes(t *types.SyncShardStatusTaskAttributes) *replicator.SyncShardStatusTaskAttributes
func FromTaskIDBlock(t *types.TaskIDBlock) *shared.TaskIDBlock
func FromTaskList(t *types.TaskList) *shared.TaskList
func FromTaskListKind(t *types.TaskListKind) *shared.TaskListKind
func FromTaskListMetadata(t *types.TaskListMetadata) *shared.TaskListMetadata
func FromTaskListPartitionMetadata(t *types.TaskListPartitionMetadata) *shared.TaskListPartitionMetadata
func FromTaskListPartitionMetadataArray(t []*types.TaskListPartitionMetadata) []*shared.TaskListPartitionMetadata
func FromTaskListStatus(t *types.TaskListStatus) *shared.TaskListStatus
func FromTaskListType(t *types.TaskListType) *shared.TaskListType
func FromTaskSource(t *types.TaskSource) *matching.TaskSource
func FromTerminateWorkflowExecutionRequest(t *types.TerminateWorkflowExecutionRequest) *shared.TerminateWorkflowExecutionRequest
func FromTimeoutType(t *types.TimeoutType) *shared.TimeoutType
func FromTimerCanceledEventAttributes(t *types.TimerCanceledEventAttributes) *shared.TimerCanceledEventAttributes
func FromTimerFiredEventAttributes(t *types.TimerFiredEventAttributes) *shared.TimerFiredEventAttributes
func FromTimerStartedEventAttributes(t *types.TimerStartedEventAttributes) *shared.TimerStartedEventAttributes
func FromTransientDecisionInfo(t *types.TransientDecisionInfo) *shared.TransientDecisionInfo
func FromUpdateDomainInfo(t *types.UpdateDomainInfo) *shared.UpdateDomainInfo
func FromUpdateDomainRequest(t *types.UpdateDomainRequest) *shared.UpdateDomainRequest
func FromUpdateDomainResponse(t *types.UpdateDomainResponse) *shared.UpdateDomainResponse
func FromUpsertWorkflowSearchAttributesDecisionAttributes(t *types.UpsertWorkflowSearchAttributesDecisionAttributes) *shared.UpsertWorkflowSearchAttributesDecisionAttributes
func FromUpsertWorkflowSearchAttributesEventAttributes(t *types.UpsertWorkflowSearchAttributesEventAttributes) *shared.UpsertWorkflowSearchAttributesEventAttributes
func FromVersionHistories(t *types.VersionHistories) *shared.VersionHistories
func FromVersionHistory(t *types.VersionHistory) *shared.VersionHistory
func FromVersionHistoryArray(t []*types.VersionHistory) []*shared.VersionHistory
func FromVersionHistoryItem(t *types.VersionHistoryItem) *shared.VersionHistoryItem
func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*shared.VersionHistoryItem
func FromWorkerVersionInfo(t *types.WorkerVersionInfo) *shared.WorkerVersionInfo
func FromWorkflowExecution(t *types.WorkflowExecution) *shared.WorkflowExecution
func FromWorkflowExecutionAlreadyStartedError(t *types.WorkflowExecutionAlreadyStartedError) *shared.WorkflowExecutionAlreadyStartedError
func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecutionCancelRequestedEventAttributes) *shared.WorkflowExecutionCancelRequestedEventAttributes
func FromWorkflowExecutionCanceledEventAttributes(t *types.WorkflowExecutionCanceledEventAttributes) *shared.WorkflowExecutionCanceledEventAttributes
func FromWorkflowExecutionCloseStatus(t *types.WorkflowExecutionCloseStatus) *shared.WorkflowExecutionCloseStatus
func FromWorkflowExecutionCompletedEventAttributes(t *types.WorkflowExecutionCompletedEventAttributes) *shared.WorkflowExecutionCompletedEventAttributes
func FromWorkflowExecutionConfiguration(t *types.WorkflowExecutionConfiguration) *shared.WorkflowExecutionConfiguration
func FromWorkflowExecutionContinuedAsNewEventAttributes(t *types.WorkflowExecutionContinuedAsNewEventAttributes) *shared.WorkflowExecutionContinuedAsNewEventAttributes
func FromWorkflowExecutionFailedEventAttributes(t *types.WorkflowExecutionFailedEventAttributes) *shared.WorkflowExecutionFailedEventAttributes
func FromWorkflowExecutionFilter(t *types.WorkflowExecutionFilter) *shared.WorkflowExecutionFilter
func FromWorkflowExecutionInfo(t *types.WorkflowExecutionInfo) *shared.WorkflowExecutionInfo
func FromWorkflowExecutionInfoArray(t []*types.WorkflowExecutionInfo) []*shared.WorkflowExecutionInfo
func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSignaledEventAttributes) *shared.WorkflowExecutionSignaledEventAttributes
func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStartedEventAttributes) *shared.WorkflowExecutionStartedEventAttributes
func FromWorkflowExecutionTerminatedEventAttributes(t *types.WorkflowExecutionTerminatedEventAttributes) *shared.WorkflowExecutionTerminatedEventAttributes
func FromWorkflowExecutionTimedOutEventAttributes(t *types.WorkflowExecutionTimedOutEventAttributes) *shared.WorkflowExecutionTimedOutEventAttributes
func FromWorkflowIDReusePolicy(t *types.WorkflowIDReusePolicy) *shared.WorkflowIdReusePolicy
func FromWorkflowQuery(t *types.WorkflowQuery) *shared.WorkflowQuery
func FromWorkflowQueryMap(t map[string]*types.WorkflowQuery) map[string]*shared.WorkflowQuery
func FromWorkflowQueryResult(t *types.WorkflowQueryResult) *shared.WorkflowQueryResult
func FromWorkflowQueryResultMap(t map[string]*types.WorkflowQueryResult) map[string]*shared.WorkflowQueryResult
func FromWorkflowType(t *types.WorkflowType) *shared.WorkflowType
func FromWorkflowTypeFilter(t *types.WorkflowTypeFilter) *shared.WorkflowTypeFilter
func ToAccessDeniedError(t *shared.AccessDeniedError) *types.AccessDeniedError
func ToActivityLocalDispatchInfo(t *shared.ActivityLocalDispatchInfo) *types.ActivityLocalDispatchInfo
func ToActivityLocalDispatchInfoMap(t map[string]*shared.ActivityLocalDispatchInfo) map[string]*types.ActivityLocalDispatchInfo
func ToActivityTaskCancelRequestedEventAttributes(t *shared.ActivityTaskCancelRequestedEventAttributes) *types.ActivityTaskCancelRequestedEventAttributes
func ToActivityTaskCanceledEventAttributes(t *shared.ActivityTaskCanceledEventAttributes) *types.ActivityTaskCanceledEventAttributes
func ToActivityTaskCompletedEventAttributes(t *shared.ActivityTaskCompletedEventAttributes) *types.ActivityTaskCompletedEventAttributes
func ToActivityTaskFailedEventAttributes(t *shared.ActivityTaskFailedEventAttributes) *types.ActivityTaskFailedEventAttributes
func ToActivityTaskScheduledEventAttributes(t *shared.ActivityTaskScheduledEventAttributes) *types.ActivityTaskScheduledEventAttributes
func ToActivityTaskStartedEventAttributes(t *shared.ActivityTaskStartedEventAttributes) *types.ActivityTaskStartedEventAttributes
func ToActivityTaskTimedOutEventAttributes(t *shared.ActivityTaskTimedOutEventAttributes) *types.ActivityTaskTimedOutEventAttributes
func ToActivityType(t *shared.ActivityType) *types.ActivityType
func ToAddActivityTaskRequest(t *matching.AddActivityTaskRequest) *types.AddActivityTaskRequest
func ToAddDecisionTaskRequest(t *matching.AddDecisionTaskRequest) *types.AddDecisionTaskRequest
func ToAddSearchAttributeRequest(t *admin.AddSearchAttributeRequest) *types.AddSearchAttributeRequest
func ToAdminDescribeWorkflowExecutionRequest(t *admin.DescribeWorkflowExecutionRequest) *types.AdminDescribeWorkflowExecutionRequest
func ToAdminDescribeWorkflowExecutionResponse(t *admin.DescribeWorkflowExecutionResponse) *types.AdminDescribeWorkflowExecutionResponse
func ToArchivalStatus(t *shared.ArchivalStatus) *types.ArchivalStatus
func ToBadBinaries(t *shared.BadBinaries) *types.BadBinaries
func ToBadBinaryInfo(t *shared.BadBinaryInfo) *types.BadBinaryInfo
func ToBadBinaryInfoMap(t map[string]*shared.BadBinaryInfo) map[string]*types.BadBinaryInfo
func ToBadRequestError(t *shared.BadRequestError) *types.BadRequestError
func ToCancelExternalWorkflowExecutionFailedCause(t *shared.CancelExternalWorkflowExecutionFailedCause) *types.CancelExternalWorkflowExecutionFailedCause
func ToCancelOutstandingPollRequest(t *matching.CancelOutstandingPollRequest) *types.CancelOutstandingPollRequest
func ToCancelTimerDecisionAttributes(t *shared.CancelTimerDecisionAttributes) *types.CancelTimerDecisionAttributes
func ToCancelTimerFailedEventAttributes(t *shared.CancelTimerFailedEventAttributes) *types.CancelTimerFailedEventAttributes
func ToCancelWorkflowExecutionDecisionAttributes(t *shared.CancelWorkflowExecutionDecisionAttributes) *types.CancelWorkflowExecutionDecisionAttributes
func ToCancellationAlreadyRequestedError(t *shared.CancellationAlreadyRequestedError) *types.CancellationAlreadyRequestedError
func ToChildWorkflowExecutionCanceledEventAttributes(t *shared.ChildWorkflowExecutionCanceledEventAttributes) *types.ChildWorkflowExecutionCanceledEventAttributes
func ToChildWorkflowExecutionCompletedEventAttributes(t *shared.ChildWorkflowExecutionCompletedEventAttributes) *types.ChildWorkflowExecutionCompletedEventAttributes
func ToChildWorkflowExecutionFailedCause(t *shared.ChildWorkflowExecutionFailedCause) *types.ChildWorkflowExecutionFailedCause
func ToChildWorkflowExecutionFailedEventAttributes(t *shared.ChildWorkflowExecutionFailedEventAttributes) *types.ChildWorkflowExecutionFailedEventAttributes
func ToChildWorkflowExecutionStartedEventAttributes(t *shared.ChildWorkflowExecutionStartedEventAttributes) *types.ChildWorkflowExecutionStartedEventAttributes
func ToChildWorkflowExecutionTerminatedEventAttributes(t *shared.ChildWorkflowExecutionTerminatedEventAttributes) *types.ChildWorkflowExecutionTerminatedEventAttributes
func ToChildWorkflowExecutionTimedOutEventAttributes(t *shared.ChildWorkflowExecutionTimedOutEventAttributes) *types.ChildWorkflowExecutionTimedOutEventAttributes
func ToClientVersionNotSupportedError(t *shared.ClientVersionNotSupportedError) *types.ClientVersionNotSupportedError
func ToCloseShardRequest(t *shared.CloseShardRequest) *types.CloseShardRequest
func ToClusterInfo(t *shared.ClusterInfo) *types.ClusterInfo
func ToClusterReplicationConfiguration(t *shared.ClusterReplicationConfiguration) *types.ClusterReplicationConfiguration
func ToClusterReplicationConfigurationArray(t []*shared.ClusterReplicationConfiguration) []*types.ClusterReplicationConfiguration
func ToCompleteWorkflowExecutionDecisionAttributes(t *shared.CompleteWorkflowExecutionDecisionAttributes) *types.CompleteWorkflowExecutionDecisionAttributes
func ToContinueAsNewInitiator(t *shared.ContinueAsNewInitiator) *types.ContinueAsNewInitiator
func ToContinueAsNewWorkflowExecutionDecisionAttributes(t *shared.ContinueAsNewWorkflowExecutionDecisionAttributes) *types.ContinueAsNewWorkflowExecutionDecisionAttributes
func ToCountWorkflowExecutionsRequest(t *shared.CountWorkflowExecutionsRequest) *types.CountWorkflowExecutionsRequest
func ToCountWorkflowExecutionsResponse(t *shared.CountWorkflowExecutionsResponse) *types.CountWorkflowExecutionsResponse
func ToCurrentBranchChangedError(t *shared.CurrentBranchChangedError) *types.CurrentBranchChangedError
func ToDLQType(t *replicator.DLQType) *types.DLQType
func ToDataBlob(t *shared.DataBlob) *types.DataBlob
func ToDataBlobArray(t []*shared.DataBlob) []*types.DataBlob
func ToDecision(t *shared.Decision) *types.Decision
func ToDecisionArray(t []*shared.Decision) []*types.Decision
func ToDecisionTaskCompletedEventAttributes(t *shared.DecisionTaskCompletedEventAttributes) *types.DecisionTaskCompletedEventAttributes
func ToDecisionTaskFailedCause(t *shared.DecisionTaskFailedCause) *types.DecisionTaskFailedCause
func ToDecisionTaskFailedEventAttributes(t *shared.DecisionTaskFailedEventAttributes) *types.DecisionTaskFailedEventAttributes
func ToDecisionTaskScheduledEventAttributes(t *shared.DecisionTaskScheduledEventAttributes) *types.DecisionTaskScheduledEventAttributes
func ToDecisionTaskStartedEventAttributes(t *shared.DecisionTaskStartedEventAttributes) *types.DecisionTaskStartedEventAttributes
func ToDecisionTaskTimedOutCause(t *shared.DecisionTaskTimedOutCause) *types.DecisionTaskTimedOutCause
func ToDecisionTaskTimedOutEventAttributes(t *shared.DecisionTaskTimedOutEventAttributes) *types.DecisionTaskTimedOutEventAttributes
func ToDecisionType(t *shared.DecisionType) *types.DecisionType
func ToDeprecateDomainRequest(t *shared.DeprecateDomainRequest) *types.DeprecateDomainRequest
func ToDescribeClusterResponse(t *admin.DescribeClusterResponse) *types.DescribeClusterResponse
func ToDescribeDomainRequest(t *shared.DescribeDomainRequest) *types.DescribeDomainRequest
func ToDescribeDomainResponse(t *shared.DescribeDomainResponse) *types.DescribeDomainResponse
func ToDescribeDomainResponseArray(t []*shared.DescribeDomainResponse) []*types.DescribeDomainResponse
func ToDescribeHistoryHostRequest(t *shared.DescribeHistoryHostRequest) *types.DescribeHistoryHostRequest
func ToDescribeHistoryHostResponse(t *shared.DescribeHistoryHostResponse) *types.DescribeHistoryHostResponse
func ToDescribeMutableStateRequest(t *history.DescribeMutableStateRequest) *types.DescribeMutableStateRequest
func ToDescribeMutableStateResponse(t *history.DescribeMutableStateResponse) *types.DescribeMutableStateResponse
func ToDescribeQueueRequest(t *shared.DescribeQueueRequest) *types.DescribeQueueRequest
func ToDescribeQueueResponse(t *shared.DescribeQueueResponse) *types.DescribeQueueResponse
func ToDescribeTaskListRequest(t *shared.DescribeTaskListRequest) *types.DescribeTaskListRequest
func ToDescribeTaskListResponse(t *shared.DescribeTaskListResponse) *types.DescribeTaskListResponse
func ToDescribeWorkflowExecutionRequest(t *shared.DescribeWorkflowExecutionRequest) *types.DescribeWorkflowExecutionRequest
func ToDescribeWorkflowExecutionResponse(t *shared.DescribeWorkflowExecutionResponse) *types.DescribeWorkflowExecutionResponse
func ToDomainAlreadyExistsError(t *shared.DomainAlreadyExistsError) *types.DomainAlreadyExistsError
func ToDomainCacheInfo(t *shared.DomainCacheInfo) *types.DomainCacheInfo
func ToDomainConfiguration(t *shared.DomainConfiguration) *types.DomainConfiguration
func ToDomainFilter(t *history.DomainFilter) *types.DomainFilter
func ToDomainInfo(t *shared.DomainInfo) *types.DomainInfo
func ToDomainNotActiveError(t *shared.DomainNotActiveError) *types.DomainNotActiveError
func ToDomainOperation(t *replicator.DomainOperation) *types.DomainOperation
func ToDomainReplicationConfiguration(t *shared.DomainReplicationConfiguration) *types.DomainReplicationConfiguration
func ToDomainStatus(t *shared.DomainStatus) *types.DomainStatus
func ToDomainTaskAttributes(t *replicator.DomainTaskAttributes) *types.DomainTaskAttributes
func ToEncodingType(t *shared.EncodingType) *types.EncodingType
func ToEntityNotExistsError(t *shared.EntityNotExistsError) *types.EntityNotExistsError
func ToError(err error) error
func ToEventAlreadyStartedError(t *history.EventAlreadyStartedError) *types.EventAlreadyStartedError
func ToEventType(t *shared.EventType) *types.EventType
func ToExternalWorkflowExecutionCancelRequestedEventAttributes(t *shared.ExternalWorkflowExecutionCancelRequestedEventAttributes) *types.ExternalWorkflowExecutionCancelRequestedEventAttributes
func ToExternalWorkflowExecutionSignaledEventAttributes(t *shared.ExternalWorkflowExecutionSignaledEventAttributes) *types.ExternalWorkflowExecutionSignaledEventAttributes
func ToFailWorkflowExecutionDecisionAttributes(t *shared.FailWorkflowExecutionDecisionAttributes) *types.FailWorkflowExecutionDecisionAttributes
func ToFailoverMarkerAttributes(t *replicator.FailoverMarkerAttributes) *types.FailoverMarkerAttributes
func ToFailoverMarkerAttributesArray(t []*replicator.FailoverMarkerAttributes) []*types.FailoverMarkerAttributes
func ToFailoverMarkerToken(t *history.FailoverMarkerToken) *types.FailoverMarkerToken
func ToFailoverMarkerTokenArray(t []*history.FailoverMarkerToken) []*types.FailoverMarkerToken
func ToFailoverMarkers(t *replicator.FailoverMarkers) *types.FailoverMarkers
func ToGetDLQReplicationMessagesRequest(t *replicator.GetDLQReplicationMessagesRequest) *types.GetDLQReplicationMessagesRequest
func ToGetDLQReplicationMessagesResponse(t *replicator.GetDLQReplicationMessagesResponse) *types.GetDLQReplicationMessagesResponse
func ToGetDomainReplicationMessagesRequest(t *replicator.GetDomainReplicationMessagesRequest) *types.GetDomainReplicationMessagesRequest
func ToGetDomainReplicationMessagesResponse(t *replicator.GetDomainReplicationMessagesResponse) *types.GetDomainReplicationMessagesResponse
func ToGetMutableStateRequest(t *history.GetMutableStateRequest) *types.GetMutableStateRequest
func ToGetMutableStateResponse(t *history.GetMutableStateResponse) *types.GetMutableStateResponse
func ToGetReplicationMessagesRequest(t *replicator.GetReplicationMessagesRequest) *types.GetReplicationMessagesRequest
func ToGetReplicationMessagesResponse(t *replicator.GetReplicationMessagesResponse) *types.GetReplicationMessagesResponse
func ToGetSearchAttributesResponse(t *shared.GetSearchAttributesResponse) *types.GetSearchAttributesResponse
func ToGetWorkflowExecutionHistoryRequest(t *shared.GetWorkflowExecutionHistoryRequest) *types.GetWorkflowExecutionHistoryRequest
func ToGetWorkflowExecutionHistoryResponse(t *shared.GetWorkflowExecutionHistoryResponse) *types.GetWorkflowExecutionHistoryResponse
func ToGetWorkflowExecutionRawHistoryV2Request(t *admin.GetWorkflowExecutionRawHistoryV2Request) *types.GetWorkflowExecutionRawHistoryV2Request
func ToGetWorkflowExecutionRawHistoryV2Response(t *admin.GetWorkflowExecutionRawHistoryV2Response) *types.GetWorkflowExecutionRawHistoryV2Response
func ToHeader(t *shared.Header) *types.Header
func ToHealthStatus(t *health.HealthStatus) *types.HealthStatus
func ToHistory(t *shared.History) *types.History
func ToHistoryArray(t []*shared.History) []*types.History
func ToHistoryBranch(t *shared.HistoryBranch) *types.HistoryBranch
func ToHistoryBranchRange(t *shared.HistoryBranchRange) *types.HistoryBranchRange
func ToHistoryBranchRangeArray(t []*shared.HistoryBranchRange) []*types.HistoryBranchRange
func ToHistoryDescribeWorkflowExecutionRequest(t *history.DescribeWorkflowExecutionRequest) *types.HistoryDescribeWorkflowExecutionRequest
func ToHistoryEvent(t *shared.HistoryEvent) *types.HistoryEvent
func ToHistoryEventArray(t []*shared.HistoryEvent) []*types.HistoryEvent
func ToHistoryEventFilterType(t *shared.HistoryEventFilterType) *types.HistoryEventFilterType
func ToHistoryQueryWorkflowRequest(t *history.QueryWorkflowRequest) *types.HistoryQueryWorkflowRequest
func ToHistoryQueryWorkflowResponse(t *history.QueryWorkflowResponse) *types.HistoryQueryWorkflowResponse
func ToHistoryReapplyEventsRequest(t *history.ReapplyEventsRequest) *types.HistoryReapplyEventsRequest
func ToHistoryRecordActivityTaskHeartbeatRequest(t *history.RecordActivityTaskHeartbeatRequest) *types.HistoryRecordActivityTaskHeartbeatRequest
func ToHistoryRefreshWorkflowTasksRequest(t *history.RefreshWorkflowTasksRequest) *types.HistoryRefreshWorkflowTasksRequest
func ToHistoryRequestCancelWorkflowExecutionRequest(t *history.RequestCancelWorkflowExecutionRequest) *types.HistoryRequestCancelWorkflowExecutionRequest
func ToHistoryResetStickyTaskListRequest(t *history.ResetStickyTaskListRequest) *types.HistoryResetStickyTaskListRequest
func ToHistoryResetStickyTaskListResponse(t *history.ResetStickyTaskListResponse) *types.HistoryResetStickyTaskListResponse
func ToHistoryResetWorkflowExecutionRequest(t *history.ResetWorkflowExecutionRequest) *types.HistoryResetWorkflowExecutionRequest
func ToHistoryRespondActivityTaskCanceledRequest(t *history.RespondActivityTaskCanceledRequest) *types.HistoryRespondActivityTaskCanceledRequest
func ToHistoryRespondActivityTaskCompletedRequest(t *history.RespondActivityTaskCompletedRequest) *types.HistoryRespondActivityTaskCompletedRequest
func ToHistoryRespondActivityTaskFailedRequest(t *history.RespondActivityTaskFailedRequest) *types.HistoryRespondActivityTaskFailedRequest
func ToHistoryRespondDecisionTaskCompletedRequest(t *history.RespondDecisionTaskCompletedRequest) *types.HistoryRespondDecisionTaskCompletedRequest
func ToHistoryRespondDecisionTaskCompletedResponse(t *history.RespondDecisionTaskCompletedResponse) *types.HistoryRespondDecisionTaskCompletedResponse
func ToHistoryRespondDecisionTaskFailedRequest(t *history.RespondDecisionTaskFailedRequest) *types.HistoryRespondDecisionTaskFailedRequest
func ToHistorySignalWithStartWorkflowExecutionRequest(t *history.SignalWithStartWorkflowExecutionRequest) *types.HistorySignalWithStartWorkflowExecutionRequest
func ToHistorySignalWorkflowExecutionRequest(t *history.SignalWorkflowExecutionRequest) *types.HistorySignalWorkflowExecutionRequest
func ToHistoryStartWorkflowExecutionRequest(t *history.StartWorkflowExecutionRequest) *types.HistoryStartWorkflowExecutionRequest
func ToHistoryTaskV2Attributes(t *replicator.HistoryTaskV2Attributes) *types.HistoryTaskV2Attributes
func ToHistoryTerminateWorkflowExecutionRequest(t *history.TerminateWorkflowExecutionRequest) *types.HistoryTerminateWorkflowExecutionRequest
func ToHostInfo(t *admin.HostInfo) *types.HostInfo
func ToHostInfoArray(t []*admin.HostInfo) []*types.HostInfo
func ToIndexedValueType(t shared.IndexedValueType) types.IndexedValueType
func ToIndexedValueTypeMap(t map[string]shared.IndexedValueType) map[string]types.IndexedValueType
func ToInternalDataInconsistencyError(t *shared.InternalDataInconsistencyError) *types.InternalDataInconsistencyError
func ToInternalServiceError(t *shared.InternalServiceError) *types.InternalServiceError
func ToLimitExceededError(t *shared.LimitExceededError) *types.LimitExceededError
func ToListArchivedWorkflowExecutionsRequest(t *shared.ListArchivedWorkflowExecutionsRequest) *types.ListArchivedWorkflowExecutionsRequest
func ToListArchivedWorkflowExecutionsResponse(t *shared.ListArchivedWorkflowExecutionsResponse) *types.ListArchivedWorkflowExecutionsResponse
func ToListClosedWorkflowExecutionsRequest(t *shared.ListClosedWorkflowExecutionsRequest) *types.ListClosedWorkflowExecutionsRequest
func ToListClosedWorkflowExecutionsResponse(t *shared.ListClosedWorkflowExecutionsResponse) *types.ListClosedWorkflowExecutionsResponse
func ToListDomainsRequest(t *shared.ListDomainsRequest) *types.ListDomainsRequest
func ToListDomainsResponse(t *shared.ListDomainsResponse) *types.ListDomainsResponse
func ToListOpenWorkflowExecutionsRequest(t *shared.ListOpenWorkflowExecutionsRequest) *types.ListOpenWorkflowExecutionsRequest
func ToListOpenWorkflowExecutionsResponse(t *shared.ListOpenWorkflowExecutionsResponse) *types.ListOpenWorkflowExecutionsResponse
func ToListTaskListPartitionsRequest(t *shared.ListTaskListPartitionsRequest) *types.ListTaskListPartitionsRequest
func ToListTaskListPartitionsResponse(t *shared.ListTaskListPartitionsResponse) *types.ListTaskListPartitionsResponse
func ToListWorkflowExecutionsRequest(t *shared.ListWorkflowExecutionsRequest) *types.ListWorkflowExecutionsRequest
func ToListWorkflowExecutionsResponse(t *shared.ListWorkflowExecutionsResponse) *types.ListWorkflowExecutionsResponse
func ToMarkerRecordedEventAttributes(t *shared.MarkerRecordedEventAttributes) *types.MarkerRecordedEventAttributes
func ToMatchingDescribeTaskListRequest(t *matching.DescribeTaskListRequest) *types.MatchingDescribeTaskListRequest
func ToMatchingListTaskListPartitionsRequest(t *matching.ListTaskListPartitionsRequest) *types.MatchingListTaskListPartitionsRequest
func ToMatchingPollForActivityTaskRequest(t *matching.PollForActivityTaskRequest) *types.MatchingPollForActivityTaskRequest
func ToMatchingPollForDecisionTaskRequest(t *matching.PollForDecisionTaskRequest) *types.MatchingPollForDecisionTaskRequest
func ToMatchingPollForDecisionTaskResponse(t *matching.PollForDecisionTaskResponse) *types.MatchingPollForDecisionTaskResponse
func ToMatchingQueryWorkflowRequest(t *matching.QueryWorkflowRequest) *types.MatchingQueryWorkflowRequest
func ToMatchingRespondQueryTaskCompletedRequest(t *matching.RespondQueryTaskCompletedRequest) *types.MatchingRespondQueryTaskCompletedRequest
func ToMembershipInfo(t *admin.MembershipInfo) *types.MembershipInfo
func ToMemo(t *shared.Memo) *types.Memo
func ToMergeDLQMessagesRequest(t *replicator.MergeDLQMessagesRequest) *types.MergeDLQMessagesRequest
func ToMergeDLQMessagesResponse(t *replicator.MergeDLQMessagesResponse) *types.MergeDLQMessagesResponse
func ToNotifyFailoverMarkersRequest(t *history.NotifyFailoverMarkersRequest) *types.NotifyFailoverMarkersRequest
func ToParentClosePolicy(t *shared.ParentClosePolicy) *types.ParentClosePolicy
func ToParentExecutionInfo(t *history.ParentExecutionInfo) *types.ParentExecutionInfo
func ToPendingActivityInfo(t *shared.PendingActivityInfo) *types.PendingActivityInfo
func ToPendingActivityInfoArray(t []*shared.PendingActivityInfo) []*types.PendingActivityInfo
func ToPendingActivityState(t *shared.PendingActivityState) *types.PendingActivityState
func ToPendingChildExecutionInfo(t *shared.PendingChildExecutionInfo) *types.PendingChildExecutionInfo
func ToPendingChildExecutionInfoArray(t []*shared.PendingChildExecutionInfo) []*types.PendingChildExecutionInfo
func ToPendingDecisionInfo(t *shared.PendingDecisionInfo) *types.PendingDecisionInfo
func ToPendingDecisionState(t *shared.PendingDecisionState) *types.PendingDecisionState
func ToPollForActivityTaskRequest(t *shared.PollForActivityTaskRequest) *types.PollForActivityTaskRequest
func ToPollForActivityTaskResponse(t *shared.PollForActivityTaskResponse) *types.PollForActivityTaskResponse
func ToPollForDecisionTaskRequest(t *shared.PollForDecisionTaskRequest) *types.PollForDecisionTaskRequest
func ToPollForDecisionTaskResponse(t *shared.PollForDecisionTaskResponse) *types.PollForDecisionTaskResponse
func ToPollMutableStateRequest(t *history.PollMutableStateRequest) *types.PollMutableStateRequest
func ToPollMutableStateResponse(t *history.PollMutableStateResponse) *types.PollMutableStateResponse
func ToPollerInfo(t *shared.PollerInfo) *types.PollerInfo
func ToPollerInfoArray(t []*shared.PollerInfo) []*types.PollerInfo
func ToProcessingQueueState(t *history.ProcessingQueueState) *types.ProcessingQueueState
func ToProcessingQueueStateArray(t []*history.ProcessingQueueState) []*types.ProcessingQueueState
func ToProcessingQueueStateArrayMap(t map[string][]*history.ProcessingQueueState) map[string][]*types.ProcessingQueueState
func ToProcessingQueueStates(t *history.ProcessingQueueStates) *types.ProcessingQueueStates
func ToPurgeDLQMessagesRequest(t *replicator.PurgeDLQMessagesRequest) *types.PurgeDLQMessagesRequest
func ToQueryConsistencyLevel(t *shared.QueryConsistencyLevel) *types.QueryConsistencyLevel
func ToQueryFailedError(t *shared.QueryFailedError) *types.QueryFailedError
func ToQueryRejectCondition(t *shared.QueryRejectCondition) *types.QueryRejectCondition
func ToQueryRejected(t *shared.QueryRejected) *types.QueryRejected
func ToQueryResultType(t *shared.QueryResultType) *types.QueryResultType
func ToQueryTaskCompletedType(t *shared.QueryTaskCompletedType) *types.QueryTaskCompletedType
func ToQueryWorkflowRequest(t *shared.QueryWorkflowRequest) *types.QueryWorkflowRequest
func ToQueryWorkflowResponse(t *shared.QueryWorkflowResponse) *types.QueryWorkflowResponse
func ToReadDLQMessagesRequest(t *replicator.ReadDLQMessagesRequest) *types.ReadDLQMessagesRequest
func ToReadDLQMessagesResponse(t *replicator.ReadDLQMessagesResponse) *types.ReadDLQMessagesResponse
func ToReapplyEventsRequest(t *shared.ReapplyEventsRequest) *types.ReapplyEventsRequest
func ToRecordActivityTaskHeartbeatByIDRequest(t *shared.RecordActivityTaskHeartbeatByIDRequest) *types.RecordActivityTaskHeartbeatByIDRequest
func ToRecordActivityTaskHeartbeatRequest(t *shared.RecordActivityTaskHeartbeatRequest) *types.RecordActivityTaskHeartbeatRequest
func ToRecordActivityTaskHeartbeatResponse(t *shared.RecordActivityTaskHeartbeatResponse) *types.RecordActivityTaskHeartbeatResponse
func ToRecordActivityTaskStartedRequest(t *history.RecordActivityTaskStartedRequest) *types.RecordActivityTaskStartedRequest
func ToRecordActivityTaskStartedResponse(t *history.RecordActivityTaskStartedResponse) *types.RecordActivityTaskStartedResponse
func ToRecordChildExecutionCompletedRequest(t *history.RecordChildExecutionCompletedRequest) *types.RecordChildExecutionCompletedRequest
func ToRecordDecisionTaskStartedRequest(t *history.RecordDecisionTaskStartedRequest) *types.RecordDecisionTaskStartedRequest
func ToRecordDecisionTaskStartedResponse(t *history.RecordDecisionTaskStartedResponse) *types.RecordDecisionTaskStartedResponse
func ToRecordMarkerDecisionAttributes(t *shared.RecordMarkerDecisionAttributes) *types.RecordMarkerDecisionAttributes
func ToRefreshWorkflowTasksRequest(t *shared.RefreshWorkflowTasksRequest) *types.RefreshWorkflowTasksRequest
func ToRegisterDomainRequest(t *shared.RegisterDomainRequest) *types.RegisterDomainRequest
func ToRemoteSyncMatchedError(t *shared.RemoteSyncMatchedError) *types.RemoteSyncMatchedError
func ToRemoveSignalMutableStateRequest(t *history.RemoveSignalMutableStateRequest) *types.RemoveSignalMutableStateRequest
func ToRemoveTaskRequest(t *shared.RemoveTaskRequest) *types.RemoveTaskRequest
func ToReplicateEventsV2Request(t *history.ReplicateEventsV2Request) *types.ReplicateEventsV2Request
func ToReplicationMessages(t *replicator.ReplicationMessages) *types.ReplicationMessages
func ToReplicationMessagesMap(t map[int32]*replicator.ReplicationMessages) map[int32]*types.ReplicationMessages
func ToReplicationTask(t *replicator.ReplicationTask) *types.ReplicationTask
func ToReplicationTaskArray(t []*replicator.ReplicationTask) []*types.ReplicationTask
func ToReplicationTaskInfo(t *replicator.ReplicationTaskInfo) *types.ReplicationTaskInfo
func ToReplicationTaskInfoArray(t []*replicator.ReplicationTaskInfo) []*types.ReplicationTaskInfo
func ToReplicationTaskType(t *replicator.ReplicationTaskType) *types.ReplicationTaskType
func ToReplicationToken(t *replicator.ReplicationToken) *types.ReplicationToken
func ToReplicationTokenArray(t []*replicator.ReplicationToken) []*types.ReplicationToken
func ToRequestCancelActivityTaskDecisionAttributes(t *shared.RequestCancelActivityTaskDecisionAttributes) *types.RequestCancelActivityTaskDecisionAttributes
func ToRequestCancelActivityTaskFailedEventAttributes(t *shared.RequestCancelActivityTaskFailedEventAttributes) *types.RequestCancelActivityTaskFailedEventAttributes
func ToRequestCancelExternalWorkflowExecutionDecisionAttributes(t *shared.RequestCancelExternalWorkflowExecutionDecisionAttributes) *types.RequestCancelExternalWorkflowExecutionDecisionAttributes
func ToRequestCancelExternalWorkflowExecutionFailedEventAttributes(t *shared.RequestCancelExternalWorkflowExecutionFailedEventAttributes) *types.RequestCancelExternalWorkflowExecutionFailedEventAttributes
func ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes(t *shared.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) *types.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
func ToRequestCancelWorkflowExecutionRequest(t *shared.RequestCancelWorkflowExecutionRequest) *types.RequestCancelWorkflowExecutionRequest
func ToResendReplicationTasksRequest(t *admin.ResendReplicationTasksRequest) *types.ResendReplicationTasksRequest
func ToResetPointInfo(t *shared.ResetPointInfo) *types.ResetPointInfo
func ToResetPointInfoArray(t []*shared.ResetPointInfo) []*types.ResetPointInfo
func ToResetPoints(t *shared.ResetPoints) *types.ResetPoints
func ToResetQueueRequest(t *shared.ResetQueueRequest) *types.ResetQueueRequest
func ToResetStickyTaskListRequest(t *shared.ResetStickyTaskListRequest) *types.ResetStickyTaskListRequest
func ToResetStickyTaskListResponse(t *shared.ResetStickyTaskListResponse) *types.ResetStickyTaskListResponse
func ToResetWorkflowExecutionRequest(t *shared.ResetWorkflowExecutionRequest) *types.ResetWorkflowExecutionRequest
func ToResetWorkflowExecutionResponse(t *shared.ResetWorkflowExecutionResponse) *types.ResetWorkflowExecutionResponse
func ToRespondActivityTaskCanceledByIDRequest(t *shared.RespondActivityTaskCanceledByIDRequest) *types.RespondActivityTaskCanceledByIDRequest
func ToRespondActivityTaskCanceledRequest(t *shared.RespondActivityTaskCanceledRequest) *types.RespondActivityTaskCanceledRequest
func ToRespondActivityTaskCompletedByIDRequest(t *shared.RespondActivityTaskCompletedByIDRequest) *types.RespondActivityTaskCompletedByIDRequest
func ToRespondActivityTaskCompletedRequest(t *shared.RespondActivityTaskCompletedRequest) *types.RespondActivityTaskCompletedRequest
func ToRespondActivityTaskFailedByIDRequest(t *shared.RespondActivityTaskFailedByIDRequest) *types.RespondActivityTaskFailedByIDRequest
func ToRespondActivityTaskFailedRequest(t *shared.RespondActivityTaskFailedRequest) *types.RespondActivityTaskFailedRequest
func ToRespondDecisionTaskCompletedRequest(t *shared.RespondDecisionTaskCompletedRequest) *types.RespondDecisionTaskCompletedRequest
func ToRespondDecisionTaskCompletedResponse(t *shared.RespondDecisionTaskCompletedResponse) *types.RespondDecisionTaskCompletedResponse
func ToRespondDecisionTaskFailedRequest(t *shared.RespondDecisionTaskFailedRequest) *types.RespondDecisionTaskFailedRequest
func ToRespondQueryTaskCompletedRequest(t *shared.RespondQueryTaskCompletedRequest) *types.RespondQueryTaskCompletedRequest
func ToRetryPolicy(t *shared.RetryPolicy) *types.RetryPolicy
func ToRetryTaskV2Error(t *shared.RetryTaskV2Error) *types.RetryTaskV2Error
func ToRingInfo(t *admin.RingInfo) *types.RingInfo
func ToRingInfoArray(t []*admin.RingInfo) []*types.RingInfo
func ToScheduleActivityTaskDecisionAttributes(t *shared.ScheduleActivityTaskDecisionAttributes) *types.ScheduleActivityTaskDecisionAttributes
func ToScheduleDecisionTaskRequest(t *history.ScheduleDecisionTaskRequest) *types.ScheduleDecisionTaskRequest
func ToSearchAttributes(t *shared.SearchAttributes) *types.SearchAttributes
func ToServiceBusyError(t *shared.ServiceBusyError) *types.ServiceBusyError
func ToShardOwnershipLostError(t *history.ShardOwnershipLostError) *types.ShardOwnershipLostError
func ToSignalExternalWorkflowExecutionDecisionAttributes(t *shared.SignalExternalWorkflowExecutionDecisionAttributes) *types.SignalExternalWorkflowExecutionDecisionAttributes
func ToSignalExternalWorkflowExecutionFailedCause(t *shared.SignalExternalWorkflowExecutionFailedCause) *types.SignalExternalWorkflowExecutionFailedCause
func ToSignalExternalWorkflowExecutionFailedEventAttributes(t *shared.SignalExternalWorkflowExecutionFailedEventAttributes) *types.SignalExternalWorkflowExecutionFailedEventAttributes
func ToSignalExternalWorkflowExecutionInitiatedEventAttributes(t *shared.SignalExternalWorkflowExecutionInitiatedEventAttributes) *types.SignalExternalWorkflowExecutionInitiatedEventAttributes
func ToSignalWithStartWorkflowExecutionRequest(t *shared.SignalWithStartWorkflowExecutionRequest) *types.SignalWithStartWorkflowExecutionRequest
func ToSignalWorkflowExecutionRequest(t *shared.SignalWorkflowExecutionRequest) *types.SignalWorkflowExecutionRequest
func ToStartChildWorkflowExecutionDecisionAttributes(t *shared.StartChildWorkflowExecutionDecisionAttributes) *types.StartChildWorkflowExecutionDecisionAttributes
func ToStartChildWorkflowExecutionFailedEventAttributes(t *shared.StartChildWorkflowExecutionFailedEventAttributes) *types.StartChildWorkflowExecutionFailedEventAttributes
func ToStartChildWorkflowExecutionInitiatedEventAttributes(t *shared.StartChildWorkflowExecutionInitiatedEventAttributes) *types.StartChildWorkflowExecutionInitiatedEventAttributes
func ToStartTimeFilter(t *shared.StartTimeFilter) *types.StartTimeFilter
func ToStartTimerDecisionAttributes(t *shared.StartTimerDecisionAttributes) *types.StartTimerDecisionAttributes
func ToStartWorkflowExecutionRequest(t *shared.StartWorkflowExecutionRequest) *types.StartWorkflowExecutionRequest
func ToStartWorkflowExecutionResponse(t *shared.StartWorkflowExecutionResponse) *types.StartWorkflowExecutionResponse
func ToStickyExecutionAttributes(t *shared.StickyExecutionAttributes) *types.StickyExecutionAttributes
func ToSupportedClientVersions(t *shared.SupportedClientVersions) *types.SupportedClientVersions
func ToSyncActivityRequest(t *history.SyncActivityRequest) *types.SyncActivityRequest
func ToSyncActivityTaskAttributes(t *replicator.SyncActivityTaskAttributes) *types.SyncActivityTaskAttributes
func ToSyncShardStatus(t *replicator.SyncShardStatus) *types.SyncShardStatus
func ToSyncShardStatusRequest(t *history.SyncShardStatusRequest) *types.SyncShardStatusRequest
func ToSyncShardStatusTaskAttributes(t *replicator.SyncShardStatusTaskAttributes) *types.SyncShardStatusTaskAttributes
func ToTaskIDBlock(t *shared.TaskIDBlock) *types.TaskIDBlock
func ToTaskList(t *shared.TaskList) *types.TaskList
func ToTaskListKind(t *shared.TaskListKind) *types.TaskListKind
func ToTaskListMetadata(t *shared.TaskListMetadata) *types.TaskListMetadata
func ToTaskListPartitionMetadata(t *shared.TaskListPartitionMetadata) *types.TaskListPartitionMetadata
func ToTaskListPartitionMetadataArray(t []*shared.TaskListPartitionMetadata) []*types.TaskListPartitionMetadata
func ToTaskListStatus(t *shared.TaskListStatus) *types.TaskListStatus
func ToTaskListType(t *shared.TaskListType) *types.TaskListType
func ToTaskSource(t *matching.TaskSource) *types.TaskSource
func ToTerminateWorkflowExecutionRequest(t *shared.TerminateWorkflowExecutionRequest) *types.TerminateWorkflowExecutionRequest
func ToTimeoutType(t *shared.TimeoutType) *types.TimeoutType
func ToTimerCanceledEventAttributes(t *shared.TimerCanceledEventAttributes) *types.TimerCanceledEventAttributes
func ToTimerFiredEventAttributes(t *shared.TimerFiredEventAttributes) *types.TimerFiredEventAttributes
func ToTimerStartedEventAttributes(t *shared.TimerStartedEventAttributes) *types.TimerStartedEventAttributes
func ToTransientDecisionInfo(t *shared.TransientDecisionInfo) *types.TransientDecisionInfo
func ToUpdateDomainInfo(t *shared.UpdateDomainInfo) *types.UpdateDomainInfo
func ToUpdateDomainRequest(t *shared.UpdateDomainRequest) *types.UpdateDomainRequest
func ToUpdateDomainResponse(t *shared.UpdateDomainResponse) *types.UpdateDomainResponse
func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *shared.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes
func ToUpsertWorkflowSearchAttributesEventAttributes(t *shared.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes
func ToVersionHistories(t *shared.VersionHistories) *types.VersionHistories
func ToVersionHistory(t *shared.VersionHistory) *types.VersionHistory
func ToVersionHistoryArray(t []*shared.VersionHistory) []*types.VersionHistory
func ToVersionHistoryItem(t *shared.VersionHistoryItem) *types.VersionHistoryItem
func ToVersionHistoryItemArray(t []*shared.VersionHistoryItem) []*types.VersionHistoryItem
func ToWorkerVersionInfo(t *shared.WorkerVersionInfo) *types.WorkerVersionInfo
func ToWorkflowExecution(t *shared.WorkflowExecution) *types.WorkflowExecution
func ToWorkflowExecutionAlreadyStartedError(t *shared.WorkflowExecutionAlreadyStartedError) *types.WorkflowExecutionAlreadyStartedError
func ToWorkflowExecutionCancelRequestedEventAttributes(t *shared.WorkflowExecutionCancelRequestedEventAttributes) *types.WorkflowExecutionCancelRequestedEventAttributes
func ToWorkflowExecutionCanceledEventAttributes(t *shared.WorkflowExecutionCanceledEventAttributes) *types.WorkflowExecutionCanceledEventAttributes
func ToWorkflowExecutionCloseStatus(t *shared.WorkflowExecutionCloseStatus) *types.WorkflowExecutionCloseStatus
func ToWorkflowExecutionCompletedEventAttributes(t *shared.WorkflowExecutionCompletedEventAttributes) *types.WorkflowExecutionCompletedEventAttributes
func ToWorkflowExecutionConfiguration(t *shared.WorkflowExecutionConfiguration) *types.WorkflowExecutionConfiguration
func ToWorkflowExecutionContinuedAsNewEventAttributes(t *shared.WorkflowExecutionContinuedAsNewEventAttributes) *types.WorkflowExecutionContinuedAsNewEventAttributes
func ToWorkflowExecutionFailedEventAttributes(t *shared.WorkflowExecutionFailedEventAttributes) *types.WorkflowExecutionFailedEventAttributes
func ToWorkflowExecutionFilter(t *shared.WorkflowExecutionFilter) *types.WorkflowExecutionFilter
func ToWorkflowExecutionInfo(t *shared.WorkflowExecutionInfo) *types.WorkflowExecutionInfo
func ToWorkflowExecutionInfoArray(t []*shared.WorkflowExecutionInfo) []*types.WorkflowExecutionInfo
func ToWorkflowExecutionSignaledEventAttributes(t *shared.WorkflowExecutionSignaledEventAttributes) *types.WorkflowExecutionSignaledEventAttributes
func ToWorkflowExecutionStartedEventAttributes(t *shared.WorkflowExecutionStartedEventAttributes) *types.WorkflowExecutionStartedEventAttributes
func ToWorkflowExecutionTerminatedEventAttributes(t *shared.WorkflowExecutionTerminatedEventAttributes) *types.WorkflowExecutionTerminatedEventAttributes
func ToWorkflowExecutionTimedOutEventAttributes(t *shared.WorkflowExecutionTimedOutEventAttributes) *types.WorkflowExecutionTimedOutEventAttributes
func ToWorkflowIDReusePolicy(t *shared.WorkflowIdReusePolicy) *types.WorkflowIDReusePolicy
func ToWorkflowQuery(t *shared.WorkflowQuery) *types.WorkflowQuery
func ToWorkflowQueryMap(t map[string]*shared.WorkflowQuery) map[string]*types.WorkflowQuery
func ToWorkflowQueryResult(t *shared.WorkflowQueryResult) *types.WorkflowQueryResult
func ToWorkflowQueryResultMap(t map[string]*shared.WorkflowQueryResult) map[string]*types.WorkflowQueryResult
func ToWorkflowType(t *shared.WorkflowType) *types.WorkflowType
func ToWorkflowTypeFilter(t *shared.WorkflowTypeFilter) *types.WorkflowTypeFilter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FromAccessDeniedError ¶

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

FromAccessDeniedError converts internal AccessDeniedError type to thrift

func FromActivityLocalDispatchInfo ¶ added in v0.17.0

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

FromActivityLocalDispatchInfo converts internal ActivityLocalDispatchInfo type to thrift

func FromActivityLocalDispatchInfoMap ¶ added in v0.17.0

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

FromActivityLocalDispatchInfoMap converts internal ActivityLocalDispatchInfo type map to thrift

func FromActivityTaskCancelRequestedEventAttributes ¶

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

FromActivityTaskCancelRequestedEventAttributes converts internal ActivityTaskCancelRequestedEventAttributes type to thrift

func FromActivityTaskCanceledEventAttributes ¶

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

FromActivityTaskCanceledEventAttributes converts internal ActivityTaskCanceledEventAttributes type to thrift

func FromActivityTaskCompletedEventAttributes ¶

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

FromActivityTaskCompletedEventAttributes converts internal ActivityTaskCompletedEventAttributes type to thrift

func FromActivityTaskFailedEventAttributes ¶

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

FromActivityTaskFailedEventAttributes converts internal ActivityTaskFailedEventAttributes type to thrift

func FromActivityTaskScheduledEventAttributes ¶

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

FromActivityTaskScheduledEventAttributes converts internal ActivityTaskScheduledEventAttributes type to thrift

func FromActivityTaskStartedEventAttributes ¶

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

FromActivityTaskStartedEventAttributes converts internal ActivityTaskStartedEventAttributes type to thrift

func FromActivityTaskTimedOutEventAttributes ¶

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

FromActivityTaskTimedOutEventAttributes converts internal ActivityTaskTimedOutEventAttributes type to thrift

func FromActivityType ¶

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

FromActivityType converts internal ActivityType type to thrift

func FromAddActivityTaskRequest ¶ added in v0.17.0

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

FromAddActivityTaskRequest converts internal AddActivityTaskRequest type to thrift

func FromAddDecisionTaskRequest ¶ added in v0.17.0

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

FromAddDecisionTaskRequest converts internal AddDecisionTaskRequest type to thrift

func FromAddSearchAttributeRequest ¶ added in v0.17.0

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

FromAddSearchAttributeRequest converts internal AddSearchAttributeRequest type to thrift

func FromAdminDescribeWorkflowExecutionRequest ¶ added in v0.17.0

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

FromAdminDescribeWorkflowExecutionRequest converts internal DescribeWorkflowExecutionRequest type to thrift

func FromAdminDescribeWorkflowExecutionResponse ¶ added in v0.17.0

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

FromAdminDescribeWorkflowExecutionResponse converts internal DescribeWorkflowExecutionResponse type to thrift

func FromArchivalStatus ¶

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

FromArchivalStatus converts internal ArchivalStatus type to thrift

func FromBadBinaries ¶

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

FromBadBinaries converts internal BadBinaries type to thrift

func FromBadBinaryInfo ¶

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

FromBadBinaryInfo converts internal BadBinaryInfo type to thrift

func FromBadBinaryInfoMap ¶

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

FromBadBinaryInfoMap converts internal BadBinaryInfo type map to thrift

func FromBadRequestError ¶

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

FromBadRequestError converts internal BadRequestError type to thrift

func FromCancelExternalWorkflowExecutionFailedCause ¶

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

FromCancelExternalWorkflowExecutionFailedCause converts internal CancelExternalWorkflowExecutionFailedCause type to thrift

func FromCancelOutstandingPollRequest ¶ added in v0.17.0

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

FromCancelOutstandingPollRequest converts internal CancelOutstandingPollRequest type to thrift

func FromCancelTimerDecisionAttributes ¶

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

FromCancelTimerDecisionAttributes converts internal CancelTimerDecisionAttributes type to thrift

func FromCancelTimerFailedEventAttributes ¶

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

FromCancelTimerFailedEventAttributes converts internal CancelTimerFailedEventAttributes type to thrift

func FromCancelWorkflowExecutionDecisionAttributes ¶

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

FromCancelWorkflowExecutionDecisionAttributes converts internal CancelWorkflowExecutionDecisionAttributes type to thrift

func FromCancellationAlreadyRequestedError ¶

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

FromCancellationAlreadyRequestedError converts internal CancellationAlreadyRequestedError type to thrift

func FromChildWorkflowExecutionCanceledEventAttributes ¶

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

FromChildWorkflowExecutionCanceledEventAttributes converts internal ChildWorkflowExecutionCanceledEventAttributes type to thrift

func FromChildWorkflowExecutionCompletedEventAttributes ¶

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

FromChildWorkflowExecutionCompletedEventAttributes converts internal ChildWorkflowExecutionCompletedEventAttributes type to thrift

func FromChildWorkflowExecutionFailedCause ¶

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

FromChildWorkflowExecutionFailedCause converts internal ChildWorkflowExecutionFailedCause type to thrift

func FromChildWorkflowExecutionFailedEventAttributes ¶

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

FromChildWorkflowExecutionFailedEventAttributes converts internal ChildWorkflowExecutionFailedEventAttributes type to thrift

func FromChildWorkflowExecutionStartedEventAttributes ¶

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

FromChildWorkflowExecutionStartedEventAttributes converts internal ChildWorkflowExecutionStartedEventAttributes type to thrift

func FromChildWorkflowExecutionTerminatedEventAttributes ¶

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

FromChildWorkflowExecutionTerminatedEventAttributes converts internal ChildWorkflowExecutionTerminatedEventAttributes type to thrift

func FromChildWorkflowExecutionTimedOutEventAttributes ¶

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

FromChildWorkflowExecutionTimedOutEventAttributes converts internal ChildWorkflowExecutionTimedOutEventAttributes type to thrift

func FromClientVersionNotSupportedError ¶

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

FromClientVersionNotSupportedError converts internal ClientVersionNotSupportedError type to thrift

func FromCloseShardRequest ¶

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

FromCloseShardRequest converts internal CloseShardRequest type to thrift

func FromClusterInfo ¶

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

FromClusterInfo converts internal ClusterInfo type to thrift

func FromClusterReplicationConfiguration ¶

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

FromClusterReplicationConfiguration converts internal ClusterReplicationConfiguration type to thrift

func FromClusterReplicationConfigurationArray ¶

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

FromClusterReplicationConfigurationArray converts internal ClusterReplicationConfiguration type array to thrift

func FromCompleteWorkflowExecutionDecisionAttributes ¶

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

FromCompleteWorkflowExecutionDecisionAttributes converts internal CompleteWorkflowExecutionDecisionAttributes type to thrift

func FromContinueAsNewInitiator ¶

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

FromContinueAsNewInitiator converts internal ContinueAsNewInitiator type to thrift

func FromContinueAsNewWorkflowExecutionDecisionAttributes ¶

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

FromContinueAsNewWorkflowExecutionDecisionAttributes converts internal ContinueAsNewWorkflowExecutionDecisionAttributes type to thrift

func FromCountWorkflowExecutionsRequest ¶

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

FromCountWorkflowExecutionsRequest converts internal CountWorkflowExecutionsRequest type to thrift

func FromCountWorkflowExecutionsResponse ¶

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

FromCountWorkflowExecutionsResponse converts internal CountWorkflowExecutionsResponse type to thrift

func FromCurrentBranchChangedError ¶

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

FromCurrentBranchChangedError converts internal CurrentBranchChangedError type to thrift

func FromDLQType ¶ added in v0.17.0

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

FromDLQType converts internal DLQType type to thrift

func FromDataBlob ¶

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

FromDataBlob converts internal DataBlob type to thrift

func FromDataBlobArray ¶

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

FromDataBlobArray converts internal DataBlob type array to thrift

func FromDecision ¶

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

FromDecision converts internal Decision type to thrift

func FromDecisionArray ¶

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

FromDecisionArray converts internal Decision type array to thrift

func FromDecisionTaskCompletedEventAttributes ¶

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

FromDecisionTaskCompletedEventAttributes converts internal DecisionTaskCompletedEventAttributes type to thrift

func FromDecisionTaskFailedCause ¶

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

FromDecisionTaskFailedCause converts internal DecisionTaskFailedCause type to thrift

func FromDecisionTaskFailedEventAttributes ¶

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

FromDecisionTaskFailedEventAttributes converts internal DecisionTaskFailedEventAttributes type to thrift

func FromDecisionTaskScheduledEventAttributes ¶

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

FromDecisionTaskScheduledEventAttributes converts internal DecisionTaskScheduledEventAttributes type to thrift

func FromDecisionTaskStartedEventAttributes ¶

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

FromDecisionTaskStartedEventAttributes converts internal DecisionTaskStartedEventAttributes type to thrift

func FromDecisionTaskTimedOutCause ¶ added in v0.18.0

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

FromDecisionTaskTimedOutCause converts internal DecisionTaskTimedOutCause type to thrift

func FromDecisionTaskTimedOutEventAttributes ¶

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

FromDecisionTaskTimedOutEventAttributes converts internal DecisionTaskTimedOutEventAttributes type to thrift

func FromDecisionType ¶

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

FromDecisionType converts internal DecisionType type to thrift

func FromDeprecateDomainRequest ¶

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

FromDeprecateDomainRequest converts internal DeprecateDomainRequest type to thrift

func FromDescribeClusterResponse ¶ added in v0.17.0

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

FromDescribeClusterResponse converts internal DescribeClusterResponse type to thrift

func FromDescribeDomainRequest ¶

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

FromDescribeDomainRequest converts internal DescribeDomainRequest type to thrift

func FromDescribeDomainResponse ¶

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

FromDescribeDomainResponse converts internal DescribeDomainResponse type to thrift

func FromDescribeDomainResponseArray ¶

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

FromDescribeDomainResponseArray converts internal DescribeDomainResponse type array to thrift

func FromDescribeHistoryHostRequest ¶

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

FromDescribeHistoryHostRequest converts internal DescribeHistoryHostRequest type to thrift

func FromDescribeHistoryHostResponse ¶

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

FromDescribeHistoryHostResponse converts internal DescribeHistoryHostResponse type to thrift

func FromDescribeMutableStateRequest ¶ added in v0.17.0

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

FromDescribeMutableStateRequest converts internal DescribeMutableStateRequest type to thrift

func FromDescribeMutableStateResponse ¶ added in v0.17.0

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

FromDescribeMutableStateResponse converts internal DescribeMutableStateResponse type to thrift

func FromDescribeQueueRequest ¶

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

FromDescribeQueueRequest converts internal DescribeQueueRequest type to thrift

func FromDescribeQueueResponse ¶

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

FromDescribeQueueResponse converts internal DescribeQueueResponse type to thrift

func FromDescribeTaskListRequest ¶

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

FromDescribeTaskListRequest converts internal DescribeTaskListRequest type to thrift

func FromDescribeTaskListResponse ¶

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

FromDescribeTaskListResponse converts internal DescribeTaskListResponse type to thrift

func FromDescribeWorkflowExecutionRequest ¶

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

FromDescribeWorkflowExecutionRequest converts internal DescribeWorkflowExecutionRequest type to thrift

func FromDescribeWorkflowExecutionResponse ¶

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

FromDescribeWorkflowExecutionResponse converts internal DescribeWorkflowExecutionResponse type to thrift

func FromDomainAlreadyExistsError ¶

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

FromDomainAlreadyExistsError converts internal DomainAlreadyExistsError type to thrift

func FromDomainCacheInfo ¶

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

FromDomainCacheInfo converts internal DomainCacheInfo type to thrift

func FromDomainConfiguration ¶

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

FromDomainConfiguration converts internal DomainConfiguration type to thrift

func FromDomainFilter ¶ added in v0.17.0

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

FromDomainFilter converts internal DomainFilter type to thrift

func FromDomainInfo ¶

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

FromDomainInfo converts internal DomainInfo type to thrift

func FromDomainNotActiveError ¶

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

FromDomainNotActiveError converts internal DomainNotActiveError type to thrift

func FromDomainOperation ¶ added in v0.17.0

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

FromDomainOperation converts internal DomainOperation type to thrift

func FromDomainReplicationConfiguration ¶

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

FromDomainReplicationConfiguration converts internal DomainReplicationConfiguration type to thrift

func FromDomainStatus ¶

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

FromDomainStatus converts internal DomainStatus type to thrift

func FromDomainTaskAttributes ¶ added in v0.17.0

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

FromDomainTaskAttributes converts internal DomainTaskAttributes type to thrift

func FromEncodingType ¶

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

FromEncodingType converts internal EncodingType type to thrift

func FromEntityNotExistsError ¶

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

FromEntityNotExistsError converts internal EntityNotExistsError type to thrift

func FromError ¶

func FromError(err error) error

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

func FromEventAlreadyStartedError ¶ added in v0.17.0

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

FromEventAlreadyStartedError converts internal EventAlreadyStartedError type to thrift

func FromEventType ¶

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

FromEventType converts internal EventType type to thrift

func FromExternalWorkflowExecutionCancelRequestedEventAttributes ¶

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

FromExternalWorkflowExecutionCancelRequestedEventAttributes converts internal ExternalWorkflowExecutionCancelRequestedEventAttributes type to thrift

func FromExternalWorkflowExecutionSignaledEventAttributes ¶

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

FromExternalWorkflowExecutionSignaledEventAttributes converts internal ExternalWorkflowExecutionSignaledEventAttributes type to thrift

func FromFailWorkflowExecutionDecisionAttributes ¶

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

FromFailWorkflowExecutionDecisionAttributes converts internal FailWorkflowExecutionDecisionAttributes type to thrift

func FromFailoverMarkerAttributes ¶ added in v0.17.0

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

FromFailoverMarkerAttributes converts internal FailoverMarkerAttributes type to thrift

func FromFailoverMarkerAttributesArray ¶ added in v0.17.0

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

FromFailoverMarkerAttributesArray converts internal FailoverMarkerAttributes type array to thrift

func FromFailoverMarkerToken ¶ added in v0.17.0

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

FromFailoverMarkerToken converts internal FailoverMarkerToken type to thrift

func FromFailoverMarkerTokenArray ¶ added in v0.17.0

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

FromFailoverMarkerTokenArray converts internal FailoverMarkerToken type array to thrift

func FromFailoverMarkers ¶ added in v0.17.0

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

FromFailoverMarkers converts internal FailoverMarkers type to thrift

func FromGetDLQReplicationMessagesRequest ¶ added in v0.17.0

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

FromGetDLQReplicationMessagesRequest converts internal GetDLQReplicationMessagesRequest type to thrift

func FromGetDLQReplicationMessagesResponse ¶ added in v0.17.0

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

FromGetDLQReplicationMessagesResponse converts internal GetDLQReplicationMessagesResponse type to thrift

func FromGetDomainReplicationMessagesRequest ¶ added in v0.17.0

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

FromGetDomainReplicationMessagesRequest converts internal GetDomainReplicationMessagesRequest type to thrift

func FromGetDomainReplicationMessagesResponse ¶ added in v0.17.0

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

FromGetDomainReplicationMessagesResponse converts internal GetDomainReplicationMessagesResponse type to thrift

func FromGetMutableStateRequest ¶ added in v0.17.0

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

FromGetMutableStateRequest converts internal GetMutableStateRequest type to thrift

func FromGetMutableStateResponse ¶ added in v0.17.0

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

FromGetMutableStateResponse converts internal GetMutableStateResponse type to thrift

func FromGetReplicationMessagesRequest ¶ added in v0.17.0

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

FromGetReplicationMessagesRequest converts internal GetReplicationMessagesRequest type to thrift

func FromGetReplicationMessagesResponse ¶ added in v0.17.0

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

FromGetReplicationMessagesResponse converts internal GetReplicationMessagesResponse type to thrift

func FromGetSearchAttributesResponse ¶

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

FromGetSearchAttributesResponse converts internal GetSearchAttributesResponse type to thrift

func FromGetWorkflowExecutionHistoryRequest ¶

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

FromGetWorkflowExecutionHistoryRequest converts internal GetWorkflowExecutionHistoryRequest type to thrift

func FromGetWorkflowExecutionHistoryResponse ¶

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

FromGetWorkflowExecutionHistoryResponse converts internal GetWorkflowExecutionHistoryResponse type to thrift

func FromGetWorkflowExecutionRawHistoryV2Request ¶ added in v0.17.0

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

FromGetWorkflowExecutionRawHistoryV2Request converts internal GetWorkflowExecutionRawHistoryV2Request type to thrift

func FromGetWorkflowExecutionRawHistoryV2Response ¶ added in v0.17.0

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

FromGetWorkflowExecutionRawHistoryV2Response converts internal GetWorkflowExecutionRawHistoryV2Response type to thrift

func FromHeader ¶

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

FromHeader converts internal Header type to thrift

func FromHealthStatus ¶ added in v0.18.0

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

FromHealthStatus converts internal HealthStatus type to thrift

func FromHistory ¶

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

FromHistory converts internal History type to thrift

func FromHistoryArray ¶ added in v0.18.0

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

FromHistoryArray converts internal History array to thrift

func FromHistoryBranch ¶

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

FromHistoryBranch converts internal HistoryBranch type to thrift

func FromHistoryBranchRange ¶

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

FromHistoryBranchRange converts internal HistoryBranchRange type to thrift

func FromHistoryBranchRangeArray ¶

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

FromHistoryBranchRangeArray converts internal HistoryBranchRange type array to thrift

func FromHistoryDescribeWorkflowExecutionRequest ¶ added in v0.17.0

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

FromHistoryDescribeWorkflowExecutionRequest converts internal DescribeWorkflowExecutionRequest type to thrift

func FromHistoryEvent ¶

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

FromHistoryEvent converts internal HistoryEvent type to thrift

func FromHistoryEventArray ¶

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

FromHistoryEventArray converts internal HistoryEvent type array to thrift

func FromHistoryEventFilterType ¶

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

FromHistoryEventFilterType converts internal HistoryEventFilterType type to thrift

func FromHistoryQueryWorkflowRequest ¶ added in v0.17.0

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

FromHistoryQueryWorkflowRequest converts internal QueryWorkflowRequest type to thrift

func FromHistoryQueryWorkflowResponse ¶ added in v0.17.0

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

FromHistoryQueryWorkflowResponse converts internal QueryWorkflowResponse type to thrift

func FromHistoryReapplyEventsRequest ¶ added in v0.17.0

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

FromHistoryReapplyEventsRequest converts internal ReapplyEventsRequest type to thrift

func FromHistoryRecordActivityTaskHeartbeatRequest ¶ added in v0.17.0

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

FromHistoryRecordActivityTaskHeartbeatRequest converts internal RecordActivityTaskHeartbeatRequest type to thrift

func FromHistoryRefreshWorkflowTasksRequest ¶ added in v0.17.0

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

FromHistoryRefreshWorkflowTasksRequest converts internal RefreshWorkflowTasksRequest type to thrift

func FromHistoryRequestCancelWorkflowExecutionRequest ¶ added in v0.17.0

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

FromHistoryRequestCancelWorkflowExecutionRequest converts internal RequestCancelWorkflowExecutionRequest type to thrift

func FromHistoryResetStickyTaskListRequest ¶ added in v0.17.0

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

FromHistoryResetStickyTaskListRequest converts internal ResetStickyTaskListRequest type to thrift

func FromHistoryResetStickyTaskListResponse ¶ added in v0.17.0

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

FromHistoryResetStickyTaskListResponse converts internal ResetStickyTaskListResponse type to thrift

func FromHistoryResetWorkflowExecutionRequest ¶ added in v0.17.0

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

FromHistoryResetWorkflowExecutionRequest converts internal ResetWorkflowExecutionRequest type to thrift

func FromHistoryRespondActivityTaskCanceledRequest ¶ added in v0.17.0

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

FromHistoryRespondActivityTaskCanceledRequest converts internal RespondActivityTaskCanceledRequest type to thrift

func FromHistoryRespondActivityTaskCompletedRequest ¶ added in v0.17.0

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

FromHistoryRespondActivityTaskCompletedRequest converts internal RespondActivityTaskCompletedRequest type to thrift

func FromHistoryRespondActivityTaskFailedRequest ¶ added in v0.17.0

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

FromHistoryRespondActivityTaskFailedRequest converts internal RespondActivityTaskFailedRequest type to thrift

func FromHistoryRespondDecisionTaskCompletedRequest ¶ added in v0.17.0

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

FromHistoryRespondDecisionTaskCompletedRequest converts internal RespondDecisionTaskCompletedRequest type to thrift

func FromHistoryRespondDecisionTaskCompletedResponse ¶ added in v0.17.0

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

FromHistoryRespondDecisionTaskCompletedResponse converts internal RespondDecisionTaskCompletedResponse type to thrift

func FromHistoryRespondDecisionTaskFailedRequest ¶ added in v0.17.0

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

FromHistoryRespondDecisionTaskFailedRequest converts internal RespondDecisionTaskFailedRequest type to thrift

func FromHistorySignalWithStartWorkflowExecutionRequest ¶ added in v0.17.0

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

FromHistorySignalWithStartWorkflowExecutionRequest converts internal SignalWithStartWorkflowExecutionRequest type to thrift

func FromHistorySignalWorkflowExecutionRequest ¶ added in v0.17.0

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

FromHistorySignalWorkflowExecutionRequest converts internal SignalWorkflowExecutionRequest type to thrift

func FromHistoryStartWorkflowExecutionRequest ¶ added in v0.17.0

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

FromHistoryStartWorkflowExecutionRequest converts internal StartWorkflowExecutionRequest type to thrift

func FromHistoryTaskV2Attributes ¶ added in v0.17.0

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

FromHistoryTaskV2Attributes converts internal HistoryTaskV2Attributes type to thrift

func FromHistoryTerminateWorkflowExecutionRequest ¶ added in v0.17.0

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

FromHistoryTerminateWorkflowExecutionRequest converts internal TerminateWorkflowExecutionRequest type to thrift

func FromHostInfo ¶ added in v0.17.0

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

FromHostInfo converts internal HostInfo type to thrift

func FromHostInfoArray ¶ added in v0.17.0

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

FromHostInfoArray converts internal HostInfo type array to thrift

func FromIndexedValueType ¶

func FromIndexedValueType(t types.IndexedValueType) shared.IndexedValueType

FromIndexedValueType converts internal IndexedValueType type to thrift

func FromIndexedValueTypeMap ¶

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

FromIndexedValueTypeMap converts internal IndexedValueType type map to thrift

func FromInternalDataInconsistencyError ¶

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

FromInternalDataInconsistencyError converts internal InternalDataInconsistencyError type to thrift

func FromInternalServiceError ¶

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

FromInternalServiceError converts internal InternalServiceError type to thrift

func FromLimitExceededError ¶

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

FromLimitExceededError converts internal LimitExceededError type to thrift

func FromListArchivedWorkflowExecutionsRequest ¶

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

FromListArchivedWorkflowExecutionsRequest converts internal ListArchivedWorkflowExecutionsRequest type to thrift

func FromListArchivedWorkflowExecutionsResponse ¶

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

FromListArchivedWorkflowExecutionsResponse converts internal ListArchivedWorkflowExecutionsResponse type to thrift

func FromListClosedWorkflowExecutionsRequest ¶

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

FromListClosedWorkflowExecutionsRequest converts internal ListClosedWorkflowExecutionsRequest type to thrift

func FromListClosedWorkflowExecutionsResponse ¶

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

FromListClosedWorkflowExecutionsResponse converts internal ListClosedWorkflowExecutionsResponse type to thrift

func FromListDomainsRequest ¶

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

FromListDomainsRequest converts internal ListDomainsRequest type to thrift

func FromListDomainsResponse ¶

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

FromListDomainsResponse converts internal ListDomainsResponse type to thrift

func FromListOpenWorkflowExecutionsRequest ¶

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

FromListOpenWorkflowExecutionsRequest converts internal ListOpenWorkflowExecutionsRequest type to thrift

func FromListOpenWorkflowExecutionsResponse ¶

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

FromListOpenWorkflowExecutionsResponse converts internal ListOpenWorkflowExecutionsResponse type to thrift

func FromListTaskListPartitionsRequest ¶

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

FromListTaskListPartitionsRequest converts internal ListTaskListPartitionsRequest type to thrift

func FromListTaskListPartitionsResponse ¶

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

FromListTaskListPartitionsResponse converts internal ListTaskListPartitionsResponse type to thrift

func FromListWorkflowExecutionsRequest ¶

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

FromListWorkflowExecutionsRequest converts internal ListWorkflowExecutionsRequest type to thrift

func FromListWorkflowExecutionsResponse ¶

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

FromListWorkflowExecutionsResponse converts internal ListWorkflowExecutionsResponse type to thrift

func FromMarkerRecordedEventAttributes ¶

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

FromMarkerRecordedEventAttributes converts internal MarkerRecordedEventAttributes type to thrift

func FromMatchingDescribeTaskListRequest ¶ added in v0.17.0

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

FromMatchingDescribeTaskListRequest converts internal DescribeTaskListRequest type to thrift

func FromMatchingListTaskListPartitionsRequest ¶ added in v0.17.0

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

FromMatchingListTaskListPartitionsRequest converts internal ListTaskListPartitionsRequest type to thrift

func FromMatchingPollForActivityTaskRequest ¶ added in v0.17.0

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

FromMatchingPollForActivityTaskRequest converts internal PollForActivityTaskRequest type to thrift

func FromMatchingPollForDecisionTaskRequest ¶ added in v0.17.0

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

FromMatchingPollForDecisionTaskRequest converts internal PollForDecisionTaskRequest type to thrift

func FromMatchingPollForDecisionTaskResponse ¶ added in v0.17.0

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

FromMatchingPollForDecisionTaskResponse converts internal PollForDecisionTaskResponse type to thrift

func FromMatchingQueryWorkflowRequest ¶ added in v0.17.0

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

FromMatchingQueryWorkflowRequest converts internal QueryWorkflowRequest type to thrift

func FromMatchingRespondQueryTaskCompletedRequest ¶ added in v0.17.0

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

FromMatchingRespondQueryTaskCompletedRequest converts internal RespondQueryTaskCompletedRequest type to thrift

func FromMembershipInfo ¶ added in v0.17.0

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

FromMembershipInfo converts internal MembershipInfo type to thrift

func FromMemo ¶

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

FromMemo converts internal Memo type to thrift

func FromMergeDLQMessagesRequest ¶ added in v0.17.0

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

FromMergeDLQMessagesRequest converts internal MergeDLQMessagesRequest type to thrift

func FromMergeDLQMessagesResponse ¶ added in v0.17.0

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

FromMergeDLQMessagesResponse converts internal MergeDLQMessagesResponse type to thrift

func FromNotifyFailoverMarkersRequest ¶ added in v0.17.0

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

FromNotifyFailoverMarkersRequest converts internal NotifyFailoverMarkersRequest type to thrift

func FromParentClosePolicy ¶

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

FromParentClosePolicy converts internal ParentClosePolicy type to thrift

func FromParentExecutionInfo ¶ added in v0.17.0

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

FromParentExecutionInfo converts internal ParentExecutionInfo type to thrift

func FromPendingActivityInfo ¶

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

FromPendingActivityInfo converts internal PendingActivityInfo type to thrift

func FromPendingActivityInfoArray ¶

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

FromPendingActivityInfoArray converts internal PendingActivityInfo type array to thrift

func FromPendingActivityState ¶

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

FromPendingActivityState converts internal PendingActivityState type to thrift

func FromPendingChildExecutionInfo ¶

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

FromPendingChildExecutionInfo converts internal PendingChildExecutionInfo type to thrift

func FromPendingChildExecutionInfoArray ¶

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

FromPendingChildExecutionInfoArray converts internal PendingChildExecutionInfo type array to thrift

func FromPendingDecisionInfo ¶ added in v0.17.0

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

FromPendingDecisionInfo converts internal PendingDecisionInfo type to thrift

func FromPendingDecisionState ¶ added in v0.17.0

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

FromPendingDecisionState converts internal PendingDecisionState type to thrift

func FromPollForActivityTaskRequest ¶

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

FromPollForActivityTaskRequest converts internal PollForActivityTaskRequest type to thrift

func FromPollForActivityTaskResponse ¶

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

FromPollForActivityTaskResponse converts internal PollForActivityTaskResponse type to thrift

func FromPollForDecisionTaskRequest ¶

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

FromPollForDecisionTaskRequest converts internal PollForDecisionTaskRequest type to thrift

func FromPollForDecisionTaskResponse ¶

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

FromPollForDecisionTaskResponse converts internal PollForDecisionTaskResponse type to thrift

func FromPollMutableStateRequest ¶ added in v0.17.0

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

FromPollMutableStateRequest converts internal PollMutableStateRequest type to thrift

func FromPollMutableStateResponse ¶ added in v0.17.0

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

FromPollMutableStateResponse converts internal PollMutableStateResponse type to thrift

func FromPollerInfo ¶

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

FromPollerInfo converts internal PollerInfo type to thrift

func FromPollerInfoArray ¶

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

FromPollerInfoArray converts internal PollerInfo type array to thrift

func FromProcessingQueueState ¶ added in v0.17.0

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

FromProcessingQueueState converts internal ProcessingQueueState type to thrift

func FromProcessingQueueStateArray ¶ added in v0.17.0

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

FromProcessingQueueStateArray converts internal ProcessingQueueState type array to thrift

func FromProcessingQueueStateArrayMap ¶ added in v0.17.0

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

FromProcessingQueueStateArrayMap converts internal ProcessingQueueState array map to thrift

func FromProcessingQueueStates ¶ added in v0.17.0

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

FromProcessingQueueStates converts internal ProcessingQueueStates type to thrift

func FromPurgeDLQMessagesRequest ¶ added in v0.17.0

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

FromPurgeDLQMessagesRequest converts internal PurgeDLQMessagesRequest type to thrift

func FromQueryConsistencyLevel ¶

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

FromQueryConsistencyLevel converts internal QueryConsistencyLevel type to thrift

func FromQueryFailedError ¶

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

FromQueryFailedError converts internal QueryFailedError type to thrift

func FromQueryRejectCondition ¶

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

FromQueryRejectCondition converts internal QueryRejectCondition type to thrift

func FromQueryRejected ¶

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

FromQueryRejected converts internal QueryRejected type to thrift

func FromQueryResultType ¶

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

FromQueryResultType converts internal QueryResultType type to thrift

func FromQueryTaskCompletedType ¶

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

FromQueryTaskCompletedType converts internal QueryTaskCompletedType type to thrift

func FromQueryWorkflowRequest ¶

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

FromQueryWorkflowRequest converts internal QueryWorkflowRequest type to thrift

func FromQueryWorkflowResponse ¶

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

FromQueryWorkflowResponse converts internal QueryWorkflowResponse type to thrift

func FromReadDLQMessagesRequest ¶ added in v0.17.0

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

FromReadDLQMessagesRequest converts internal ReadDLQMessagesRequest type to thrift

func FromReadDLQMessagesResponse ¶ added in v0.17.0

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

FromReadDLQMessagesResponse converts internal ReadDLQMessagesResponse type to thrift

func FromReapplyEventsRequest ¶

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

FromReapplyEventsRequest converts internal ReapplyEventsRequest type to thrift

func FromRecordActivityTaskHeartbeatByIDRequest ¶

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

FromRecordActivityTaskHeartbeatByIDRequest converts internal RecordActivityTaskHeartbeatByIDRequest type to thrift

func FromRecordActivityTaskHeartbeatRequest ¶

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

FromRecordActivityTaskHeartbeatRequest converts internal RecordActivityTaskHeartbeatRequest type to thrift

func FromRecordActivityTaskHeartbeatResponse ¶

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

FromRecordActivityTaskHeartbeatResponse converts internal RecordActivityTaskHeartbeatResponse type to thrift

func FromRecordActivityTaskStartedRequest ¶ added in v0.17.0

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

FromRecordActivityTaskStartedRequest converts internal RecordActivityTaskStartedRequest type to thrift

func FromRecordActivityTaskStartedResponse ¶ added in v0.17.0

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

FromRecordActivityTaskStartedResponse converts internal RecordActivityTaskStartedResponse type to thrift

func FromRecordChildExecutionCompletedRequest ¶ added in v0.17.0

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

FromRecordChildExecutionCompletedRequest converts internal RecordChildExecutionCompletedRequest type to thrift

func FromRecordDecisionTaskStartedRequest ¶ added in v0.17.0

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

FromRecordDecisionTaskStartedRequest converts internal RecordDecisionTaskStartedRequest type to thrift

func FromRecordDecisionTaskStartedResponse ¶ added in v0.17.0

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

FromRecordDecisionTaskStartedResponse converts internal RecordDecisionTaskStartedResponse type to thrift

func FromRecordMarkerDecisionAttributes ¶

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

FromRecordMarkerDecisionAttributes converts internal RecordMarkerDecisionAttributes type to thrift

func FromRefreshWorkflowTasksRequest ¶

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

FromRefreshWorkflowTasksRequest converts internal RefreshWorkflowTasksRequest type to thrift

func FromRegisterDomainRequest ¶

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

FromRegisterDomainRequest converts internal RegisterDomainRequest type to thrift

func FromRemoteSyncMatchedError ¶

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

FromRemoteSyncMatchedError converts internal RemoteSyncMatchedError type to thrift

func FromRemoveSignalMutableStateRequest ¶ added in v0.17.0

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

FromRemoveSignalMutableStateRequest converts internal RemoveSignalMutableStateRequest type to thrift

func FromRemoveTaskRequest ¶

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

FromRemoveTaskRequest converts internal RemoveTaskRequest type to thrift

func FromReplicateEventsV2Request ¶ added in v0.17.0

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

FromReplicateEventsV2Request converts internal ReplicateEventsV2Request type to thrift

func FromReplicationMessages ¶ added in v0.17.0

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

FromReplicationMessages converts internal ReplicationMessages type to thrift

func FromReplicationMessagesMap ¶ added in v0.17.0

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

FromReplicationMessagesMap converts internal ReplicationMessages type map to thrift

func FromReplicationTask ¶ added in v0.17.0

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

FromReplicationTask converts internal ReplicationTask type to thrift

func FromReplicationTaskArray ¶ added in v0.17.0

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

FromReplicationTaskArray converts internal ReplicationTask type array to thrift

func FromReplicationTaskInfo ¶ added in v0.17.0

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

FromReplicationTaskInfo converts internal ReplicationTaskInfo type to thrift

func FromReplicationTaskInfoArray ¶ added in v0.17.0

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

FromReplicationTaskInfoArray converts internal ReplicationTaskInfo type array to thrift

func FromReplicationTaskType ¶ added in v0.17.0

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

FromReplicationTaskType converts internal ReplicationTaskType type to thrift

func FromReplicationToken ¶ added in v0.17.0

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

FromReplicationToken converts internal ReplicationToken type to thrift

func FromReplicationTokenArray ¶ added in v0.17.0

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

FromReplicationTokenArray converts internal ReplicationToken type array to thrift

func FromRequestCancelActivityTaskDecisionAttributes ¶

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

FromRequestCancelActivityTaskDecisionAttributes converts internal RequestCancelActivityTaskDecisionAttributes type to thrift

func FromRequestCancelActivityTaskFailedEventAttributes ¶

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

FromRequestCancelActivityTaskFailedEventAttributes converts internal RequestCancelActivityTaskFailedEventAttributes type to thrift

func FromRequestCancelExternalWorkflowExecutionDecisionAttributes ¶

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

FromRequestCancelExternalWorkflowExecutionDecisionAttributes converts internal RequestCancelExternalWorkflowExecutionDecisionAttributes type to thrift

func FromRequestCancelExternalWorkflowExecutionFailedEventAttributes ¶

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

FromRequestCancelExternalWorkflowExecutionFailedEventAttributes converts internal RequestCancelExternalWorkflowExecutionFailedEventAttributes type to thrift

func FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶

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

FromRequestCancelExternalWorkflowExecutionInitiatedEventAttributes converts internal RequestCancelExternalWorkflowExecutionInitiatedEventAttributes type to thrift

func FromRequestCancelWorkflowExecutionRequest ¶

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

FromRequestCancelWorkflowExecutionRequest converts internal RequestCancelWorkflowExecutionRequest type to thrift

func FromResendReplicationTasksRequest ¶ added in v0.17.0

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

FromResendReplicationTasksRequest converts internal ResendReplicationTasksRequest type to thrift

func FromResetPointInfo ¶

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

FromResetPointInfo converts internal ResetPointInfo type to thrift

func FromResetPointInfoArray ¶

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

FromResetPointInfoArray converts internal ResetPointInfo type array to thrift

func FromResetPoints ¶

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

FromResetPoints converts internal ResetPoints type to thrift

func FromResetQueueRequest ¶

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

FromResetQueueRequest converts internal ResetQueueRequest type to thrift

func FromResetStickyTaskListRequest ¶

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

FromResetStickyTaskListRequest converts internal ResetStickyTaskListRequest type to thrift

func FromResetStickyTaskListResponse ¶

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

FromResetStickyTaskListResponse converts internal ResetStickyTaskListResponse type to thrift

func FromResetWorkflowExecutionRequest ¶

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

FromResetWorkflowExecutionRequest converts internal ResetWorkflowExecutionRequest type to thrift

func FromResetWorkflowExecutionResponse ¶

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

FromResetWorkflowExecutionResponse converts internal ResetWorkflowExecutionResponse type to thrift

func FromRespondActivityTaskCanceledByIDRequest ¶

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

FromRespondActivityTaskCanceledByIDRequest converts internal RespondActivityTaskCanceledByIDRequest type to thrift

func FromRespondActivityTaskCanceledRequest ¶

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

FromRespondActivityTaskCanceledRequest converts internal RespondActivityTaskCanceledRequest type to thrift

func FromRespondActivityTaskCompletedByIDRequest ¶

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

FromRespondActivityTaskCompletedByIDRequest converts internal RespondActivityTaskCompletedByIDRequest type to thrift

func FromRespondActivityTaskCompletedRequest ¶

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

FromRespondActivityTaskCompletedRequest converts internal RespondActivityTaskCompletedRequest type to thrift

func FromRespondActivityTaskFailedByIDRequest ¶

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

FromRespondActivityTaskFailedByIDRequest converts internal RespondActivityTaskFailedByIDRequest type to thrift

func FromRespondActivityTaskFailedRequest ¶

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

FromRespondActivityTaskFailedRequest converts internal RespondActivityTaskFailedRequest type to thrift

func FromRespondDecisionTaskCompletedRequest ¶

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

FromRespondDecisionTaskCompletedRequest converts internal RespondDecisionTaskCompletedRequest type to thrift

func FromRespondDecisionTaskCompletedResponse ¶

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

FromRespondDecisionTaskCompletedResponse converts internal RespondDecisionTaskCompletedResponse type to thrift

func FromRespondDecisionTaskFailedRequest ¶

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

FromRespondDecisionTaskFailedRequest converts internal RespondDecisionTaskFailedRequest type to thrift

func FromRespondQueryTaskCompletedRequest ¶

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

FromRespondQueryTaskCompletedRequest converts internal RespondQueryTaskCompletedRequest type to thrift

func FromRetryPolicy ¶

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

FromRetryPolicy converts internal RetryPolicy type to thrift

func FromRetryTaskV2Error ¶

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

FromRetryTaskV2Error converts internal RetryTaskV2Error type to thrift

func FromRingInfo ¶ added in v0.17.0

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

FromRingInfo converts internal RingInfo type to thrift

func FromRingInfoArray ¶ added in v0.17.0

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

FromRingInfoArray converts internal RingInfo type array to thrift

func FromScheduleActivityTaskDecisionAttributes ¶

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

FromScheduleActivityTaskDecisionAttributes converts internal ScheduleActivityTaskDecisionAttributes type to thrift

func FromScheduleDecisionTaskRequest ¶ added in v0.17.0

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

FromScheduleDecisionTaskRequest converts internal ScheduleDecisionTaskRequest type to thrift

func FromSearchAttributes ¶

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

FromSearchAttributes converts internal SearchAttributes type to thrift

func FromServiceBusyError ¶

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

FromServiceBusyError converts internal ServiceBusyError type to thrift

func FromShardOwnershipLostError ¶ added in v0.17.0

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

FromShardOwnershipLostError converts internal ShardOwnershipLostError type to thrift

func FromSignalExternalWorkflowExecutionDecisionAttributes ¶

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

FromSignalExternalWorkflowExecutionDecisionAttributes converts internal SignalExternalWorkflowExecutionDecisionAttributes type to thrift

func FromSignalExternalWorkflowExecutionFailedCause ¶

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

FromSignalExternalWorkflowExecutionFailedCause converts internal SignalExternalWorkflowExecutionFailedCause type to thrift

func FromSignalExternalWorkflowExecutionFailedEventAttributes ¶

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

FromSignalExternalWorkflowExecutionFailedEventAttributes converts internal SignalExternalWorkflowExecutionFailedEventAttributes type to thrift

func FromSignalExternalWorkflowExecutionInitiatedEventAttributes ¶

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

FromSignalExternalWorkflowExecutionInitiatedEventAttributes converts internal SignalExternalWorkflowExecutionInitiatedEventAttributes type to thrift

func FromSignalWithStartWorkflowExecutionRequest ¶

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

FromSignalWithStartWorkflowExecutionRequest converts internal SignalWithStartWorkflowExecutionRequest type to thrift

func FromSignalWorkflowExecutionRequest ¶

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

FromSignalWorkflowExecutionRequest converts internal SignalWorkflowExecutionRequest type to thrift

func FromStartChildWorkflowExecutionDecisionAttributes ¶

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

FromStartChildWorkflowExecutionDecisionAttributes converts internal StartChildWorkflowExecutionDecisionAttributes type to thrift

func FromStartChildWorkflowExecutionFailedEventAttributes ¶

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

FromStartChildWorkflowExecutionFailedEventAttributes converts internal StartChildWorkflowExecutionFailedEventAttributes type to thrift

func FromStartChildWorkflowExecutionInitiatedEventAttributes ¶

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

FromStartChildWorkflowExecutionInitiatedEventAttributes converts internal StartChildWorkflowExecutionInitiatedEventAttributes type to thrift

func FromStartTimeFilter ¶

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

FromStartTimeFilter converts internal StartTimeFilter type to thrift

func FromStartTimerDecisionAttributes ¶

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

FromStartTimerDecisionAttributes converts internal StartTimerDecisionAttributes type to thrift

func FromStartWorkflowExecutionRequest ¶

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

FromStartWorkflowExecutionRequest converts internal StartWorkflowExecutionRequest type to thrift

func FromStartWorkflowExecutionResponse ¶

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

FromStartWorkflowExecutionResponse converts internal StartWorkflowExecutionResponse type to thrift

func FromStickyExecutionAttributes ¶

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

FromStickyExecutionAttributes converts internal StickyExecutionAttributes type to thrift

func FromSupportedClientVersions ¶

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

FromSupportedClientVersions converts internal SupportedClientVersions type to thrift

func FromSyncActivityRequest ¶ added in v0.17.0

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

FromSyncActivityRequest converts internal SyncActivityRequest type to thrift

func FromSyncActivityTaskAttributes ¶ added in v0.17.0

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

FromSyncActivityTaskAttributes converts internal SyncActivityTaskAttributes type to thrift

func FromSyncShardStatus ¶ added in v0.17.0

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

FromSyncShardStatus converts internal SyncShardStatus type to thrift

func FromSyncShardStatusRequest ¶ added in v0.17.0

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

FromSyncShardStatusRequest converts internal SyncShardStatusRequest type to thrift

func FromSyncShardStatusTaskAttributes ¶ added in v0.17.0

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

FromSyncShardStatusTaskAttributes converts internal SyncShardStatusTaskAttributes type to thrift

func FromTaskIDBlock ¶

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

FromTaskIDBlock converts internal TaskIDBlock type to thrift

func FromTaskList ¶

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

FromTaskList converts internal TaskList type to thrift

func FromTaskListKind ¶

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

FromTaskListKind converts internal TaskListKind type to thrift

func FromTaskListMetadata ¶

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

FromTaskListMetadata converts internal TaskListMetadata type to thrift

func FromTaskListPartitionMetadata ¶

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

FromTaskListPartitionMetadata converts internal TaskListPartitionMetadata type to thrift

func FromTaskListPartitionMetadataArray ¶

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

FromTaskListPartitionMetadataArray converts internal TaskListPartitionMetadata type array to thrift

func FromTaskListStatus ¶

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

FromTaskListStatus converts internal TaskListStatus type to thrift

func FromTaskListType ¶

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

FromTaskListType converts internal TaskListType type to thrift

func FromTaskSource ¶ added in v0.17.0

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

FromTaskSource converts internal TaskSource type to thrift

func FromTerminateWorkflowExecutionRequest ¶

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

FromTerminateWorkflowExecutionRequest converts internal TerminateWorkflowExecutionRequest type to thrift

func FromTimeoutType ¶

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

FromTimeoutType converts internal TimeoutType type to thrift

func FromTimerCanceledEventAttributes ¶

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

FromTimerCanceledEventAttributes converts internal TimerCanceledEventAttributes type to thrift

func FromTimerFiredEventAttributes ¶

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

FromTimerFiredEventAttributes converts internal TimerFiredEventAttributes type to thrift

func FromTimerStartedEventAttributes ¶

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

FromTimerStartedEventAttributes converts internal TimerStartedEventAttributes type to thrift

func FromTransientDecisionInfo ¶

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

FromTransientDecisionInfo converts internal TransientDecisionInfo type to thrift

func FromUpdateDomainInfo ¶

func FromUpdateDomainInfo(t *types.UpdateDomainInfo) *shared.UpdateDomainInfo

FromUpdateDomainInfo converts internal UpdateDomainInfo type to thrift

func FromUpdateDomainRequest ¶

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

FromUpdateDomainRequest converts internal UpdateDomainRequest type to thrift

func FromUpdateDomainResponse ¶

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

FromUpdateDomainResponse converts internal UpdateDomainResponse type to thrift

func FromUpsertWorkflowSearchAttributesDecisionAttributes ¶

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

FromUpsertWorkflowSearchAttributesDecisionAttributes converts internal UpsertWorkflowSearchAttributesDecisionAttributes type to thrift

func FromUpsertWorkflowSearchAttributesEventAttributes ¶

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

FromUpsertWorkflowSearchAttributesEventAttributes converts internal UpsertWorkflowSearchAttributesEventAttributes type to thrift

func FromVersionHistories ¶

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

FromVersionHistories converts internal VersionHistories type to thrift

func FromVersionHistory ¶

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

FromVersionHistory converts internal VersionHistory type to thrift

func FromVersionHistoryArray ¶

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

FromVersionHistoryArray converts internal VersionHistory type array to thrift

func FromVersionHistoryItem ¶

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

FromVersionHistoryItem converts internal VersionHistoryItem type to thrift

func FromVersionHistoryItemArray ¶

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

FromVersionHistoryItemArray converts internal VersionHistoryItem type array to thrift

func FromWorkerVersionInfo ¶

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

FromWorkerVersionInfo converts internal WorkerVersionInfo type to thrift

func FromWorkflowExecution ¶

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

FromWorkflowExecution converts internal WorkflowExecution type to thrift

func FromWorkflowExecutionAlreadyStartedError ¶

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

FromWorkflowExecutionAlreadyStartedError converts internal WorkflowExecutionAlreadyStartedError type to thrift

func FromWorkflowExecutionCancelRequestedEventAttributes ¶

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

FromWorkflowExecutionCancelRequestedEventAttributes converts internal WorkflowExecutionCancelRequestedEventAttributes type to thrift

func FromWorkflowExecutionCanceledEventAttributes ¶

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

FromWorkflowExecutionCanceledEventAttributes converts internal WorkflowExecutionCanceledEventAttributes type to thrift

func FromWorkflowExecutionCloseStatus ¶

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

FromWorkflowExecutionCloseStatus converts internal WorkflowExecutionCloseStatus type to thrift

func FromWorkflowExecutionCompletedEventAttributes ¶

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

FromWorkflowExecutionCompletedEventAttributes converts internal WorkflowExecutionCompletedEventAttributes type to thrift

func FromWorkflowExecutionConfiguration ¶

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

FromWorkflowExecutionConfiguration converts internal WorkflowExecutionConfiguration type to thrift

func FromWorkflowExecutionContinuedAsNewEventAttributes ¶

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

FromWorkflowExecutionContinuedAsNewEventAttributes converts internal WorkflowExecutionContinuedAsNewEventAttributes type to thrift

func FromWorkflowExecutionFailedEventAttributes ¶

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

FromWorkflowExecutionFailedEventAttributes converts internal WorkflowExecutionFailedEventAttributes type to thrift

func FromWorkflowExecutionFilter ¶

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

FromWorkflowExecutionFilter converts internal WorkflowExecutionFilter type to thrift

func FromWorkflowExecutionInfo ¶

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

FromWorkflowExecutionInfo converts internal WorkflowExecutionInfo type to thrift

func FromWorkflowExecutionInfoArray ¶

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

FromWorkflowExecutionInfoArray converts internal WorkflowExecutionInfo type array to thrift

func FromWorkflowExecutionSignaledEventAttributes ¶

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

FromWorkflowExecutionSignaledEventAttributes converts internal WorkflowExecutionSignaledEventAttributes type to thrift

func FromWorkflowExecutionStartedEventAttributes ¶

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

FromWorkflowExecutionStartedEventAttributes converts internal WorkflowExecutionStartedEventAttributes type to thrift

func FromWorkflowExecutionTerminatedEventAttributes ¶

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

FromWorkflowExecutionTerminatedEventAttributes converts internal WorkflowExecutionTerminatedEventAttributes type to thrift

func FromWorkflowExecutionTimedOutEventAttributes ¶

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

FromWorkflowExecutionTimedOutEventAttributes converts internal WorkflowExecutionTimedOutEventAttributes type to thrift

func FromWorkflowIDReusePolicy ¶

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

FromWorkflowIDReusePolicy converts internal WorkflowIDReusePolicy type to thrift

func FromWorkflowQuery ¶

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

FromWorkflowQuery converts internal WorkflowQuery type to thrift

func FromWorkflowQueryMap ¶

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

FromWorkflowQueryMap converts internal WorkflowQuery type map to thrift

func FromWorkflowQueryResult ¶

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

FromWorkflowQueryResult converts internal WorkflowQueryResult type to thrift

func FromWorkflowQueryResultMap ¶

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

FromWorkflowQueryResultMap converts internal WorkflowQueryResult type map to thrift

func FromWorkflowType ¶

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

FromWorkflowType converts internal WorkflowType type to thrift

func FromWorkflowTypeFilter ¶

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

FromWorkflowTypeFilter converts internal WorkflowTypeFilter type to thrift

func ToAccessDeniedError ¶

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

ToAccessDeniedError converts thrift AccessDeniedError type to internal

func ToActivityLocalDispatchInfo ¶ added in v0.17.0

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

ToActivityLocalDispatchInfo converts thrift ActivityLocalDispatchInfo type to internal

func ToActivityLocalDispatchInfoMap ¶ added in v0.17.0

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

ToActivityLocalDispatchInfoMap converts thrift ActivityLocalDispatchInfo type map to internal

func ToActivityTaskCancelRequestedEventAttributes ¶

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

ToActivityTaskCancelRequestedEventAttributes converts thrift ActivityTaskCancelRequestedEventAttributes type to internal

func ToActivityTaskCanceledEventAttributes ¶

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

ToActivityTaskCanceledEventAttributes converts thrift ActivityTaskCanceledEventAttributes type to internal

func ToActivityTaskCompletedEventAttributes ¶

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

ToActivityTaskCompletedEventAttributes converts thrift ActivityTaskCompletedEventAttributes type to internal

func ToActivityTaskFailedEventAttributes ¶

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

ToActivityTaskFailedEventAttributes converts thrift ActivityTaskFailedEventAttributes type to internal

func ToActivityTaskScheduledEventAttributes ¶

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

ToActivityTaskScheduledEventAttributes converts thrift ActivityTaskScheduledEventAttributes type to internal

func ToActivityTaskStartedEventAttributes ¶

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

ToActivityTaskStartedEventAttributes converts thrift ActivityTaskStartedEventAttributes type to internal

func ToActivityTaskTimedOutEventAttributes ¶

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

ToActivityTaskTimedOutEventAttributes converts thrift ActivityTaskTimedOutEventAttributes type to internal

func ToActivityType ¶

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

ToActivityType converts thrift ActivityType type to internal

func ToAddActivityTaskRequest ¶ added in v0.17.0

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

ToAddActivityTaskRequest converts thrift AddActivityTaskRequest type to internal

func ToAddDecisionTaskRequest ¶ added in v0.17.0

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

ToAddDecisionTaskRequest converts thrift AddDecisionTaskRequest type to internal

func ToAddSearchAttributeRequest ¶ added in v0.17.0

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

ToAddSearchAttributeRequest converts thrift AddSearchAttributeRequest type to internal

func ToAdminDescribeWorkflowExecutionRequest ¶ added in v0.17.0

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

ToAdminDescribeWorkflowExecutionRequest converts thrift DescribeWorkflowExecutionRequest type to internal

func ToAdminDescribeWorkflowExecutionResponse ¶ added in v0.17.0

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

ToAdminDescribeWorkflowExecutionResponse converts thrift DescribeWorkflowExecutionResponse type to internal

func ToArchivalStatus ¶

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

ToArchivalStatus converts thrift ArchivalStatus type to internal

func ToBadBinaries ¶

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

ToBadBinaries converts thrift BadBinaries type to internal

func ToBadBinaryInfo ¶

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

ToBadBinaryInfo converts thrift BadBinaryInfo type to internal

func ToBadBinaryInfoMap ¶

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

ToBadBinaryInfoMap converts thrift BadBinaryInfo type map to internal

func ToBadRequestError ¶

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

ToBadRequestError converts thrift BadRequestError type to internal

func ToCancelExternalWorkflowExecutionFailedCause ¶

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

ToCancelExternalWorkflowExecutionFailedCause converts thrift CancelExternalWorkflowExecutionFailedCause type to internal

func ToCancelOutstandingPollRequest ¶ added in v0.17.0

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

ToCancelOutstandingPollRequest converts thrift CancelOutstandingPollRequest type to internal

func ToCancelTimerDecisionAttributes ¶

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

ToCancelTimerDecisionAttributes converts thrift CancelTimerDecisionAttributes type to internal

func ToCancelTimerFailedEventAttributes ¶

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

ToCancelTimerFailedEventAttributes converts thrift CancelTimerFailedEventAttributes type to internal

func ToCancelWorkflowExecutionDecisionAttributes ¶

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

ToCancelWorkflowExecutionDecisionAttributes converts thrift CancelWorkflowExecutionDecisionAttributes type to internal

func ToCancellationAlreadyRequestedError ¶

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

ToCancellationAlreadyRequestedError converts thrift CancellationAlreadyRequestedError type to internal

func ToChildWorkflowExecutionCanceledEventAttributes ¶

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

ToChildWorkflowExecutionCanceledEventAttributes converts thrift ChildWorkflowExecutionCanceledEventAttributes type to internal

func ToChildWorkflowExecutionCompletedEventAttributes ¶

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

ToChildWorkflowExecutionCompletedEventAttributes converts thrift ChildWorkflowExecutionCompletedEventAttributes type to internal

func ToChildWorkflowExecutionFailedCause ¶

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

ToChildWorkflowExecutionFailedCause converts thrift ChildWorkflowExecutionFailedCause type to internal

func ToChildWorkflowExecutionFailedEventAttributes ¶

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

ToChildWorkflowExecutionFailedEventAttributes converts thrift ChildWorkflowExecutionFailedEventAttributes type to internal

func ToChildWorkflowExecutionStartedEventAttributes ¶

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

ToChildWorkflowExecutionStartedEventAttributes converts thrift ChildWorkflowExecutionStartedEventAttributes type to internal

func ToChildWorkflowExecutionTerminatedEventAttributes ¶

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

ToChildWorkflowExecutionTerminatedEventAttributes converts thrift ChildWorkflowExecutionTerminatedEventAttributes type to internal

func ToChildWorkflowExecutionTimedOutEventAttributes ¶

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

ToChildWorkflowExecutionTimedOutEventAttributes converts thrift ChildWorkflowExecutionTimedOutEventAttributes type to internal

func ToClientVersionNotSupportedError ¶

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

ToClientVersionNotSupportedError converts thrift ClientVersionNotSupportedError type to internal

func ToCloseShardRequest ¶

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

ToCloseShardRequest converts thrift CloseShardRequest type to internal

func ToClusterInfo ¶

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

ToClusterInfo converts thrift ClusterInfo type to internal

func ToClusterReplicationConfiguration ¶

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

ToClusterReplicationConfiguration converts thrift ClusterReplicationConfiguration type to internal

func ToClusterReplicationConfigurationArray ¶

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

ToClusterReplicationConfigurationArray converts thrift ClusterReplicationConfiguration type array to internal

func ToCompleteWorkflowExecutionDecisionAttributes ¶

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

ToCompleteWorkflowExecutionDecisionAttributes converts thrift CompleteWorkflowExecutionDecisionAttributes type to internal

func ToContinueAsNewInitiator ¶

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

ToContinueAsNewInitiator converts thrift ContinueAsNewInitiator type to internal

func ToContinueAsNewWorkflowExecutionDecisionAttributes ¶

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

ToContinueAsNewWorkflowExecutionDecisionAttributes converts thrift ContinueAsNewWorkflowExecutionDecisionAttributes type to internal

func ToCountWorkflowExecutionsRequest ¶

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

ToCountWorkflowExecutionsRequest converts thrift CountWorkflowExecutionsRequest type to internal

func ToCountWorkflowExecutionsResponse ¶

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

ToCountWorkflowExecutionsResponse converts thrift CountWorkflowExecutionsResponse type to internal

func ToCurrentBranchChangedError ¶

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

ToCurrentBranchChangedError converts thrift CurrentBranchChangedError type to internal

func ToDLQType ¶ added in v0.17.0

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

ToDLQType converts thrift DLQType type to internal

func ToDataBlob ¶

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

ToDataBlob converts thrift DataBlob type to internal

func ToDataBlobArray ¶

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

ToDataBlobArray converts thrift DataBlob type array to internal

func ToDecision ¶

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

ToDecision converts thrift Decision type to internal

func ToDecisionArray ¶

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

ToDecisionArray converts thrift Decision type array to internal

func ToDecisionTaskCompletedEventAttributes ¶

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

ToDecisionTaskCompletedEventAttributes converts thrift DecisionTaskCompletedEventAttributes type to internal

func ToDecisionTaskFailedCause ¶

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

ToDecisionTaskFailedCause converts thrift DecisionTaskFailedCause type to internal

func ToDecisionTaskFailedEventAttributes ¶

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

ToDecisionTaskFailedEventAttributes converts thrift DecisionTaskFailedEventAttributes type to internal

func ToDecisionTaskScheduledEventAttributes ¶

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

ToDecisionTaskScheduledEventAttributes converts thrift DecisionTaskScheduledEventAttributes type to internal

func ToDecisionTaskStartedEventAttributes ¶

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

ToDecisionTaskStartedEventAttributes converts thrift DecisionTaskStartedEventAttributes type to internal

func ToDecisionTaskTimedOutCause ¶ added in v0.18.0

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

ToDecisionTaskTimedOutCause converts thrift DecisionTaskTimedOutCause type to internal

func ToDecisionTaskTimedOutEventAttributes ¶

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

ToDecisionTaskTimedOutEventAttributes converts thrift DecisionTaskTimedOutEventAttributes type to internal

func ToDecisionType ¶

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

ToDecisionType converts thrift DecisionType type to internal

func ToDeprecateDomainRequest ¶

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

ToDeprecateDomainRequest converts thrift DeprecateDomainRequest type to internal

func ToDescribeClusterResponse ¶ added in v0.17.0

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

ToDescribeClusterResponse converts thrift DescribeClusterResponse type to internal

func ToDescribeDomainRequest ¶

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

ToDescribeDomainRequest converts thrift DescribeDomainRequest type to internal

func ToDescribeDomainResponse ¶

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

ToDescribeDomainResponse converts thrift DescribeDomainResponse type to internal

func ToDescribeDomainResponseArray ¶

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

ToDescribeDomainResponseArray converts thrift DescribeDomainResponse type array to internal

func ToDescribeHistoryHostRequest ¶

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

ToDescribeHistoryHostRequest converts thrift DescribeHistoryHostRequest type to internal

func ToDescribeHistoryHostResponse ¶

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

ToDescribeHistoryHostResponse converts thrift DescribeHistoryHostResponse type to internal

func ToDescribeMutableStateRequest ¶ added in v0.17.0

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

ToDescribeMutableStateRequest converts thrift DescribeMutableStateRequest type to internal

func ToDescribeMutableStateResponse ¶ added in v0.17.0

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

ToDescribeMutableStateResponse converts thrift DescribeMutableStateResponse type to internal

func ToDescribeQueueRequest ¶

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

ToDescribeQueueRequest converts thrift DescribeQueueRequest type to internal

func ToDescribeQueueResponse ¶

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

ToDescribeQueueResponse converts thrift DescribeQueueResponse type to internal

func ToDescribeTaskListRequest ¶

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

ToDescribeTaskListRequest converts thrift DescribeTaskListRequest type to internal

func ToDescribeTaskListResponse ¶

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

ToDescribeTaskListResponse converts thrift DescribeTaskListResponse type to internal

func ToDescribeWorkflowExecutionRequest ¶

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

ToDescribeWorkflowExecutionRequest converts thrift DescribeWorkflowExecutionRequest type to internal

func ToDescribeWorkflowExecutionResponse ¶

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

ToDescribeWorkflowExecutionResponse converts thrift DescribeWorkflowExecutionResponse type to internal

func ToDomainAlreadyExistsError ¶

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

ToDomainAlreadyExistsError converts thrift DomainAlreadyExistsError type to internal

func ToDomainCacheInfo ¶

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

ToDomainCacheInfo converts thrift DomainCacheInfo type to internal

func ToDomainConfiguration ¶

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

ToDomainConfiguration converts thrift DomainConfiguration type to internal

func ToDomainFilter ¶ added in v0.17.0

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

ToDomainFilter converts thrift DomainFilter type to internal

func ToDomainInfo ¶

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

ToDomainInfo converts thrift DomainInfo type to internal

func ToDomainNotActiveError ¶

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

ToDomainNotActiveError converts thrift DomainNotActiveError type to internal

func ToDomainOperation ¶ added in v0.17.0

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

ToDomainOperation converts thrift DomainOperation type to internal

func ToDomainReplicationConfiguration ¶

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

ToDomainReplicationConfiguration converts thrift DomainReplicationConfiguration type to internal

func ToDomainStatus ¶

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

ToDomainStatus converts thrift DomainStatus type to internal

func ToDomainTaskAttributes ¶ added in v0.17.0

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

ToDomainTaskAttributes converts thrift DomainTaskAttributes type to internal

func ToEncodingType ¶

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

ToEncodingType converts thrift EncodingType type to internal

func ToEntityNotExistsError ¶

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

ToEntityNotExistsError converts thrift EntityNotExistsError type to internal

func ToError ¶ added in v0.17.0

func ToError(err error) error

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

func ToEventAlreadyStartedError ¶ added in v0.17.0

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

ToEventAlreadyStartedError converts thrift EventAlreadyStartedError type to internal

func ToEventType ¶

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

ToEventType converts thrift EventType type to internal

func ToExternalWorkflowExecutionCancelRequestedEventAttributes ¶

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

ToExternalWorkflowExecutionCancelRequestedEventAttributes converts thrift ExternalWorkflowExecutionCancelRequestedEventAttributes type to internal

func ToExternalWorkflowExecutionSignaledEventAttributes ¶

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

ToExternalWorkflowExecutionSignaledEventAttributes converts thrift ExternalWorkflowExecutionSignaledEventAttributes type to internal

func ToFailWorkflowExecutionDecisionAttributes ¶

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

ToFailWorkflowExecutionDecisionAttributes converts thrift FailWorkflowExecutionDecisionAttributes type to internal

func ToFailoverMarkerAttributes ¶ added in v0.17.0

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

ToFailoverMarkerAttributes converts thrift FailoverMarkerAttributes type to internal

func ToFailoverMarkerAttributesArray ¶ added in v0.17.0

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

ToFailoverMarkerAttributesArray converts thrift FailoverMarkerAttributes type array to internal

func ToFailoverMarkerToken ¶ added in v0.17.0

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

ToFailoverMarkerToken converts thrift FailoverMarkerToken type to internal

func ToFailoverMarkerTokenArray ¶ added in v0.17.0

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

ToFailoverMarkerTokenArray converts thrift FailoverMarkerToken type array to internal

func ToFailoverMarkers ¶ added in v0.17.0

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

ToFailoverMarkers converts thrift FailoverMarkers type to internal

func ToGetDLQReplicationMessagesRequest ¶ added in v0.17.0

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

ToGetDLQReplicationMessagesRequest converts thrift GetDLQReplicationMessagesRequest type to internal

func ToGetDLQReplicationMessagesResponse ¶ added in v0.17.0

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

ToGetDLQReplicationMessagesResponse converts thrift GetDLQReplicationMessagesResponse type to internal

func ToGetDomainReplicationMessagesRequest ¶ added in v0.17.0

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

ToGetDomainReplicationMessagesRequest converts thrift GetDomainReplicationMessagesRequest type to internal

func ToGetDomainReplicationMessagesResponse ¶ added in v0.17.0

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

ToGetDomainReplicationMessagesResponse converts thrift GetDomainReplicationMessagesResponse type to internal

func ToGetMutableStateRequest ¶ added in v0.17.0

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

ToGetMutableStateRequest converts thrift GetMutableStateRequest type to internal

func ToGetMutableStateResponse ¶ added in v0.17.0

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

ToGetMutableStateResponse converts thrift GetMutableStateResponse type to internal

func ToGetReplicationMessagesRequest ¶ added in v0.17.0

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

ToGetReplicationMessagesRequest converts thrift GetReplicationMessagesRequest type to internal

func ToGetReplicationMessagesResponse ¶ added in v0.17.0

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

ToGetReplicationMessagesResponse converts thrift GetReplicationMessagesResponse type to internal

func ToGetSearchAttributesResponse ¶

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

ToGetSearchAttributesResponse converts thrift GetSearchAttributesResponse type to internal

func ToGetWorkflowExecutionHistoryRequest ¶

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

ToGetWorkflowExecutionHistoryRequest converts thrift GetWorkflowExecutionHistoryRequest type to internal

func ToGetWorkflowExecutionHistoryResponse ¶

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

ToGetWorkflowExecutionHistoryResponse converts thrift GetWorkflowExecutionHistoryResponse type to internal

func ToGetWorkflowExecutionRawHistoryV2Request ¶ added in v0.17.0

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

ToGetWorkflowExecutionRawHistoryV2Request converts thrift GetWorkflowExecutionRawHistoryV2Request type to internal

func ToGetWorkflowExecutionRawHistoryV2Response ¶ added in v0.17.0

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

ToGetWorkflowExecutionRawHistoryV2Response converts thrift GetWorkflowExecutionRawHistoryV2Response type to internal

func ToHeader ¶

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

ToHeader converts thrift Header type to internal

func ToHealthStatus ¶ added in v0.18.0

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

ToHealthStatus converts thrift HealthStatus type to internal

func ToHistory ¶

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

ToHistory converts thrift History type to internal

func ToHistoryArray ¶ added in v0.18.0

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

ToHistoryArray converts thrift History array to internal

func ToHistoryBranch ¶

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

ToHistoryBranch converts thrift HistoryBranch type to internal

func ToHistoryBranchRange ¶

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

ToHistoryBranchRange converts thrift HistoryBranchRange type to internal

func ToHistoryBranchRangeArray ¶

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

ToHistoryBranchRangeArray converts thrift HistoryBranchRange type array to internal

func ToHistoryDescribeWorkflowExecutionRequest ¶ added in v0.17.0

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

ToHistoryDescribeWorkflowExecutionRequest converts thrift DescribeWorkflowExecutionRequest type to internal

func ToHistoryEvent ¶

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

ToHistoryEvent converts thrift HistoryEvent type to internal

func ToHistoryEventArray ¶

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

ToHistoryEventArray converts thrift HistoryEvent type array to internal

func ToHistoryEventFilterType ¶

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

ToHistoryEventFilterType converts thrift HistoryEventFilterType type to internal

func ToHistoryQueryWorkflowRequest ¶ added in v0.17.0

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

ToHistoryQueryWorkflowRequest converts thrift QueryWorkflowRequest type to internal

func ToHistoryQueryWorkflowResponse ¶ added in v0.17.0

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

ToHistoryQueryWorkflowResponse converts thrift QueryWorkflowResponse type to internal

func ToHistoryReapplyEventsRequest ¶ added in v0.17.0

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

ToHistoryReapplyEventsRequest converts thrift ReapplyEventsRequest type to internal

func ToHistoryRecordActivityTaskHeartbeatRequest ¶ added in v0.17.0

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

ToHistoryRecordActivityTaskHeartbeatRequest converts thrift RecordActivityTaskHeartbeatRequest type to internal

func ToHistoryRefreshWorkflowTasksRequest ¶ added in v0.17.0

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

ToHistoryRefreshWorkflowTasksRequest converts thrift RefreshWorkflowTasksRequest type to internal

func ToHistoryRequestCancelWorkflowExecutionRequest ¶ added in v0.17.0

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

ToHistoryRequestCancelWorkflowExecutionRequest converts thrift RequestCancelWorkflowExecutionRequest type to internal

func ToHistoryResetStickyTaskListRequest ¶ added in v0.17.0

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

ToHistoryResetStickyTaskListRequest converts thrift ResetStickyTaskListRequest type to internal

func ToHistoryResetStickyTaskListResponse ¶ added in v0.17.0

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

ToHistoryResetStickyTaskListResponse converts thrift ResetStickyTaskListResponse type to internal

func ToHistoryResetWorkflowExecutionRequest ¶ added in v0.17.0

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

ToHistoryResetWorkflowExecutionRequest converts thrift ResetWorkflowExecutionRequest type to internal

func ToHistoryRespondActivityTaskCanceledRequest ¶ added in v0.17.0

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

ToHistoryRespondActivityTaskCanceledRequest converts thrift RespondActivityTaskCanceledRequest type to internal

func ToHistoryRespondActivityTaskCompletedRequest ¶ added in v0.17.0

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

ToHistoryRespondActivityTaskCompletedRequest converts thrift RespondActivityTaskCompletedRequest type to internal

func ToHistoryRespondActivityTaskFailedRequest ¶ added in v0.17.0

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

ToHistoryRespondActivityTaskFailedRequest converts thrift RespondActivityTaskFailedRequest type to internal

func ToHistoryRespondDecisionTaskCompletedRequest ¶ added in v0.17.0

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

ToHistoryRespondDecisionTaskCompletedRequest converts thrift RespondDecisionTaskCompletedRequest type to internal

func ToHistoryRespondDecisionTaskCompletedResponse ¶ added in v0.17.0

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

ToHistoryRespondDecisionTaskCompletedResponse converts thrift RespondDecisionTaskCompletedResponse type to internal

func ToHistoryRespondDecisionTaskFailedRequest ¶ added in v0.17.0

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

ToHistoryRespondDecisionTaskFailedRequest converts thrift RespondDecisionTaskFailedRequest type to internal

func ToHistorySignalWithStartWorkflowExecutionRequest ¶ added in v0.17.0

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

ToHistorySignalWithStartWorkflowExecutionRequest converts thrift SignalWithStartWorkflowExecutionRequest type to internal

func ToHistorySignalWorkflowExecutionRequest ¶ added in v0.17.0

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

ToHistorySignalWorkflowExecutionRequest converts thrift SignalWorkflowExecutionRequest type to internal

func ToHistoryStartWorkflowExecutionRequest ¶ added in v0.17.0

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

ToHistoryStartWorkflowExecutionRequest converts thrift StartWorkflowExecutionRequest type to internal

func ToHistoryTaskV2Attributes ¶ added in v0.17.0

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

ToHistoryTaskV2Attributes converts thrift HistoryTaskV2Attributes type to internal

func ToHistoryTerminateWorkflowExecutionRequest ¶ added in v0.17.0

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

ToHistoryTerminateWorkflowExecutionRequest converts thrift TerminateWorkflowExecutionRequest type to internal

func ToHostInfo ¶ added in v0.17.0

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

ToHostInfo converts thrift HostInfo type to internal

func ToHostInfoArray ¶ added in v0.17.0

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

ToHostInfoArray converts thrift HostInfo type array to internal

func ToIndexedValueType ¶

func ToIndexedValueType(t shared.IndexedValueType) types.IndexedValueType

ToIndexedValueType converts thrift IndexedValueType type to internal

func ToIndexedValueTypeMap ¶

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

ToIndexedValueTypeMap converts thrift IndexedValueType type map to internal

func ToInternalDataInconsistencyError ¶

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

ToInternalDataInconsistencyError converts thrift InternalDataInconsistencyError type to internal

func ToInternalServiceError ¶

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

ToInternalServiceError converts thrift InternalServiceError type to internal

func ToLimitExceededError ¶

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

ToLimitExceededError converts thrift LimitExceededError type to internal

func ToListArchivedWorkflowExecutionsRequest ¶

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

ToListArchivedWorkflowExecutionsRequest converts thrift ListArchivedWorkflowExecutionsRequest type to internal

func ToListArchivedWorkflowExecutionsResponse ¶

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

ToListArchivedWorkflowExecutionsResponse converts thrift ListArchivedWorkflowExecutionsResponse type to internal

func ToListClosedWorkflowExecutionsRequest ¶

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

ToListClosedWorkflowExecutionsRequest converts thrift ListClosedWorkflowExecutionsRequest type to internal

func ToListClosedWorkflowExecutionsResponse ¶

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

ToListClosedWorkflowExecutionsResponse converts thrift ListClosedWorkflowExecutionsResponse type to internal

func ToListDomainsRequest ¶

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

ToListDomainsRequest converts thrift ListDomainsRequest type to internal

func ToListDomainsResponse ¶

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

ToListDomainsResponse converts thrift ListDomainsResponse type to internal

func ToListOpenWorkflowExecutionsRequest ¶

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

ToListOpenWorkflowExecutionsRequest converts thrift ListOpenWorkflowExecutionsRequest type to internal

func ToListOpenWorkflowExecutionsResponse ¶

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

ToListOpenWorkflowExecutionsResponse converts thrift ListOpenWorkflowExecutionsResponse type to internal

func ToListTaskListPartitionsRequest ¶

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

ToListTaskListPartitionsRequest converts thrift ListTaskListPartitionsRequest type to internal

func ToListTaskListPartitionsResponse ¶

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

ToListTaskListPartitionsResponse converts thrift ListTaskListPartitionsResponse type to internal

func ToListWorkflowExecutionsRequest ¶

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

ToListWorkflowExecutionsRequest converts thrift ListWorkflowExecutionsRequest type to internal

func ToListWorkflowExecutionsResponse ¶

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

ToListWorkflowExecutionsResponse converts thrift ListWorkflowExecutionsResponse type to internal

func ToMarkerRecordedEventAttributes ¶

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

ToMarkerRecordedEventAttributes converts thrift MarkerRecordedEventAttributes type to internal

func ToMatchingDescribeTaskListRequest ¶ added in v0.17.0

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

ToMatchingDescribeTaskListRequest converts thrift DescribeTaskListRequest type to internal

func ToMatchingListTaskListPartitionsRequest ¶ added in v0.17.0

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

ToMatchingListTaskListPartitionsRequest converts thrift ListTaskListPartitionsRequest type to internal

func ToMatchingPollForActivityTaskRequest ¶ added in v0.17.0

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

ToMatchingPollForActivityTaskRequest converts thrift PollForActivityTaskRequest type to internal

func ToMatchingPollForDecisionTaskRequest ¶ added in v0.17.0

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

ToMatchingPollForDecisionTaskRequest converts thrift PollForDecisionTaskRequest type to internal

func ToMatchingPollForDecisionTaskResponse ¶ added in v0.17.0

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

ToMatchingPollForDecisionTaskResponse converts thrift PollForDecisionTaskResponse type to internal

func ToMatchingQueryWorkflowRequest ¶ added in v0.17.0

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

ToMatchingQueryWorkflowRequest converts thrift QueryWorkflowRequest type to internal

func ToMatchingRespondQueryTaskCompletedRequest ¶ added in v0.17.0

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

ToMatchingRespondQueryTaskCompletedRequest converts thrift RespondQueryTaskCompletedRequest type to internal

func ToMembershipInfo ¶ added in v0.17.0

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

ToMembershipInfo converts thrift MembershipInfo type to internal

func ToMemo ¶

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

ToMemo converts thrift Memo type to internal

func ToMergeDLQMessagesRequest ¶ added in v0.17.0

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

ToMergeDLQMessagesRequest converts thrift MergeDLQMessagesRequest type to internal

func ToMergeDLQMessagesResponse ¶ added in v0.17.0

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

ToMergeDLQMessagesResponse converts thrift MergeDLQMessagesResponse type to internal

func ToNotifyFailoverMarkersRequest ¶ added in v0.17.0

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

ToNotifyFailoverMarkersRequest converts thrift NotifyFailoverMarkersRequest type to internal

func ToParentClosePolicy ¶

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

ToParentClosePolicy converts thrift ParentClosePolicy type to internal

func ToParentExecutionInfo ¶ added in v0.17.0

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

ToParentExecutionInfo converts thrift ParentExecutionInfo type to internal

func ToPendingActivityInfo ¶

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

ToPendingActivityInfo converts thrift PendingActivityInfo type to internal

func ToPendingActivityInfoArray ¶

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

ToPendingActivityInfoArray converts thrift PendingActivityInfo type array to internal

func ToPendingActivityState ¶

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

ToPendingActivityState converts thrift PendingActivityState type to internal

func ToPendingChildExecutionInfo ¶

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

ToPendingChildExecutionInfo converts thrift PendingChildExecutionInfo type to internal

func ToPendingChildExecutionInfoArray ¶

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

ToPendingChildExecutionInfoArray converts thrift PendingChildExecutionInfo type array to internal

func ToPendingDecisionInfo ¶ added in v0.17.0

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

ToPendingDecisionInfo converts thrift PendingDecisionInfo type to internal

func ToPendingDecisionState ¶ added in v0.17.0

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

ToPendingDecisionState converts thrift PendingDecisionState type to internal

func ToPollForActivityTaskRequest ¶

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

ToPollForActivityTaskRequest converts thrift PollForActivityTaskRequest type to internal

func ToPollForActivityTaskResponse ¶

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

ToPollForActivityTaskResponse converts thrift PollForActivityTaskResponse type to internal

func ToPollForDecisionTaskRequest ¶

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

ToPollForDecisionTaskRequest converts thrift PollForDecisionTaskRequest type to internal

func ToPollForDecisionTaskResponse ¶

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

ToPollForDecisionTaskResponse converts thrift PollForDecisionTaskResponse type to internal

func ToPollMutableStateRequest ¶ added in v0.17.0

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

ToPollMutableStateRequest converts thrift PollMutableStateRequest type to internal

func ToPollMutableStateResponse ¶ added in v0.17.0

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

ToPollMutableStateResponse converts thrift PollMutableStateResponse type to internal

func ToPollerInfo ¶

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

ToPollerInfo converts thrift PollerInfo type to internal

func ToPollerInfoArray ¶

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

ToPollerInfoArray converts thrift PollerInfo type array to internal

func ToProcessingQueueState ¶ added in v0.17.0

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

ToProcessingQueueState converts thrift ProcessingQueueState type to internal

func ToProcessingQueueStateArray ¶ added in v0.17.0

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

ToProcessingQueueStateArray converts thrift ProcessingQueueState type array to internal

func ToProcessingQueueStateArrayMap ¶ added in v0.17.0

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

ToProcessingQueueStateArrayMap converts thrift ProcessingQueueState array map to internal

func ToProcessingQueueStates ¶ added in v0.17.0

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

ToProcessingQueueStates converts thrift ProcessingQueueStates type to internal

func ToPurgeDLQMessagesRequest ¶ added in v0.17.0

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

ToPurgeDLQMessagesRequest converts thrift PurgeDLQMessagesRequest type to internal

func ToQueryConsistencyLevel ¶

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

ToQueryConsistencyLevel converts thrift QueryConsistencyLevel type to internal

func ToQueryFailedError ¶

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

ToQueryFailedError converts thrift QueryFailedError type to internal

func ToQueryRejectCondition ¶

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

ToQueryRejectCondition converts thrift QueryRejectCondition type to internal

func ToQueryRejected ¶

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

ToQueryRejected converts thrift QueryRejected type to internal

func ToQueryResultType ¶

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

ToQueryResultType converts thrift QueryResultType type to internal

func ToQueryTaskCompletedType ¶

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

ToQueryTaskCompletedType converts thrift QueryTaskCompletedType type to internal

func ToQueryWorkflowRequest ¶

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

ToQueryWorkflowRequest converts thrift QueryWorkflowRequest type to internal

func ToQueryWorkflowResponse ¶

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

ToQueryWorkflowResponse converts thrift QueryWorkflowResponse type to internal

func ToReadDLQMessagesRequest ¶ added in v0.17.0

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

ToReadDLQMessagesRequest converts thrift ReadDLQMessagesRequest type to internal

func ToReadDLQMessagesResponse ¶ added in v0.17.0

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

ToReadDLQMessagesResponse converts thrift ReadDLQMessagesResponse type to internal

func ToReapplyEventsRequest ¶

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

ToReapplyEventsRequest converts thrift ReapplyEventsRequest type to internal

func ToRecordActivityTaskHeartbeatByIDRequest ¶

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

ToRecordActivityTaskHeartbeatByIDRequest converts thrift RecordActivityTaskHeartbeatByIDRequest type to internal

func ToRecordActivityTaskHeartbeatRequest ¶

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

ToRecordActivityTaskHeartbeatRequest converts thrift RecordActivityTaskHeartbeatRequest type to internal

func ToRecordActivityTaskHeartbeatResponse ¶

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

ToRecordActivityTaskHeartbeatResponse converts thrift RecordActivityTaskHeartbeatResponse type to internal

func ToRecordActivityTaskStartedRequest ¶ added in v0.17.0

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

ToRecordActivityTaskStartedRequest converts thrift RecordActivityTaskStartedRequest type to internal

func ToRecordActivityTaskStartedResponse ¶ added in v0.17.0

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

ToRecordActivityTaskStartedResponse converts thrift RecordActivityTaskStartedResponse type to internal

func ToRecordChildExecutionCompletedRequest ¶ added in v0.17.0

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

ToRecordChildExecutionCompletedRequest converts thrift RecordChildExecutionCompletedRequest type to internal

func ToRecordDecisionTaskStartedRequest ¶ added in v0.17.0

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

ToRecordDecisionTaskStartedRequest converts thrift RecordDecisionTaskStartedRequest type to internal

func ToRecordDecisionTaskStartedResponse ¶ added in v0.17.0

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

ToRecordDecisionTaskStartedResponse converts thrift RecordDecisionTaskStartedResponse type to internal

func ToRecordMarkerDecisionAttributes ¶

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

ToRecordMarkerDecisionAttributes converts thrift RecordMarkerDecisionAttributes type to internal

func ToRefreshWorkflowTasksRequest ¶

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

ToRefreshWorkflowTasksRequest converts thrift RefreshWorkflowTasksRequest type to internal

func ToRegisterDomainRequest ¶

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

ToRegisterDomainRequest converts thrift RegisterDomainRequest type to internal

func ToRemoteSyncMatchedError ¶

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

ToRemoteSyncMatchedError converts thrift RemoteSyncMatchedError type to internal

func ToRemoveSignalMutableStateRequest ¶ added in v0.17.0

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

ToRemoveSignalMutableStateRequest converts thrift RemoveSignalMutableStateRequest type to internal

func ToRemoveTaskRequest ¶

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

ToRemoveTaskRequest converts thrift RemoveTaskRequest type to internal

func ToReplicateEventsV2Request ¶ added in v0.17.0

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

ToReplicateEventsV2Request converts thrift ReplicateEventsV2Request type to internal

func ToReplicationMessages ¶ added in v0.17.0

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

ToReplicationMessages converts thrift ReplicationMessages type to internal

func ToReplicationMessagesMap ¶ added in v0.17.0

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

ToReplicationMessagesMap converts thrift ReplicationMessages type map to internal

func ToReplicationTask ¶ added in v0.17.0

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

ToReplicationTask converts thrift ReplicationTask type to internal

func ToReplicationTaskArray ¶ added in v0.17.0

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

ToReplicationTaskArray converts thrift ReplicationTask type array to internal

func ToReplicationTaskInfo ¶ added in v0.17.0

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

ToReplicationTaskInfo converts thrift ReplicationTaskInfo type to internal

func ToReplicationTaskInfoArray ¶ added in v0.17.0

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

ToReplicationTaskInfoArray converts thrift ReplicationTaskInfo type array to internal

func ToReplicationTaskType ¶ added in v0.17.0

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

ToReplicationTaskType converts thrift ReplicationTaskType type to internal

func ToReplicationToken ¶ added in v0.17.0

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

ToReplicationToken converts thrift ReplicationToken type to internal

func ToReplicationTokenArray ¶ added in v0.17.0

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

ToReplicationTokenArray converts thrift ReplicationToken type array to internal

func ToRequestCancelActivityTaskDecisionAttributes ¶

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

ToRequestCancelActivityTaskDecisionAttributes converts thrift RequestCancelActivityTaskDecisionAttributes type to internal

func ToRequestCancelActivityTaskFailedEventAttributes ¶

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

ToRequestCancelActivityTaskFailedEventAttributes converts thrift RequestCancelActivityTaskFailedEventAttributes type to internal

func ToRequestCancelExternalWorkflowExecutionDecisionAttributes ¶

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

ToRequestCancelExternalWorkflowExecutionDecisionAttributes converts thrift RequestCancelExternalWorkflowExecutionDecisionAttributes type to internal

func ToRequestCancelExternalWorkflowExecutionFailedEventAttributes ¶

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

ToRequestCancelExternalWorkflowExecutionFailedEventAttributes converts thrift RequestCancelExternalWorkflowExecutionFailedEventAttributes type to internal

func ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶

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

ToRequestCancelExternalWorkflowExecutionInitiatedEventAttributes converts thrift RequestCancelExternalWorkflowExecutionInitiatedEventAttributes type to internal

func ToRequestCancelWorkflowExecutionRequest ¶

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

ToRequestCancelWorkflowExecutionRequest converts thrift RequestCancelWorkflowExecutionRequest type to internal

func ToResendReplicationTasksRequest ¶ added in v0.17.0

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

ToResendReplicationTasksRequest converts thrift ResendReplicationTasksRequest type to internal

func ToResetPointInfo ¶

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

ToResetPointInfo converts thrift ResetPointInfo type to internal

func ToResetPointInfoArray ¶

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

ToResetPointInfoArray converts thrift ResetPointInfo type array to internal

func ToResetPoints ¶

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

ToResetPoints converts thrift ResetPoints type to internal

func ToResetQueueRequest ¶

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

ToResetQueueRequest converts thrift ResetQueueRequest type to internal

func ToResetStickyTaskListRequest ¶

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

ToResetStickyTaskListRequest converts thrift ResetStickyTaskListRequest type to internal

func ToResetStickyTaskListResponse ¶

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

ToResetStickyTaskListResponse converts thrift ResetStickyTaskListResponse type to internal

func ToResetWorkflowExecutionRequest ¶

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

ToResetWorkflowExecutionRequest converts thrift ResetWorkflowExecutionRequest type to internal

func ToResetWorkflowExecutionResponse ¶

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

ToResetWorkflowExecutionResponse converts thrift ResetWorkflowExecutionResponse type to internal

func ToRespondActivityTaskCanceledByIDRequest ¶

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

ToRespondActivityTaskCanceledByIDRequest converts thrift RespondActivityTaskCanceledByIDRequest type to internal

func ToRespondActivityTaskCanceledRequest ¶

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

ToRespondActivityTaskCanceledRequest converts thrift RespondActivityTaskCanceledRequest type to internal

func ToRespondActivityTaskCompletedByIDRequest ¶

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

ToRespondActivityTaskCompletedByIDRequest converts thrift RespondActivityTaskCompletedByIDRequest type to internal

func ToRespondActivityTaskCompletedRequest ¶

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

ToRespondActivityTaskCompletedRequest converts thrift RespondActivityTaskCompletedRequest type to internal

func ToRespondActivityTaskFailedByIDRequest ¶

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

ToRespondActivityTaskFailedByIDRequest converts thrift RespondActivityTaskFailedByIDRequest type to internal

func ToRespondActivityTaskFailedRequest ¶

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

ToRespondActivityTaskFailedRequest converts thrift RespondActivityTaskFailedRequest type to internal

func ToRespondDecisionTaskCompletedRequest ¶

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

ToRespondDecisionTaskCompletedRequest converts thrift RespondDecisionTaskCompletedRequest type to internal

func ToRespondDecisionTaskCompletedResponse ¶

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

ToRespondDecisionTaskCompletedResponse converts thrift RespondDecisionTaskCompletedResponse type to internal

func ToRespondDecisionTaskFailedRequest ¶

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

ToRespondDecisionTaskFailedRequest converts thrift RespondDecisionTaskFailedRequest type to internal

func ToRespondQueryTaskCompletedRequest ¶

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

ToRespondQueryTaskCompletedRequest converts thrift RespondQueryTaskCompletedRequest type to internal

func ToRetryPolicy ¶

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

ToRetryPolicy converts thrift RetryPolicy type to internal

func ToRetryTaskV2Error ¶

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

ToRetryTaskV2Error converts thrift RetryTaskV2Error type to internal

func ToRingInfo ¶ added in v0.17.0

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

ToRingInfo converts thrift RingInfo type to internal

func ToRingInfoArray ¶ added in v0.17.0

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

ToRingInfoArray converts thrift RingInfo type array to internal

func ToScheduleActivityTaskDecisionAttributes ¶

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

ToScheduleActivityTaskDecisionAttributes converts thrift ScheduleActivityTaskDecisionAttributes type to internal

func ToScheduleDecisionTaskRequest ¶ added in v0.17.0

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

ToScheduleDecisionTaskRequest converts thrift ScheduleDecisionTaskRequest type to internal

func ToSearchAttributes ¶

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

ToSearchAttributes converts thrift SearchAttributes type to internal

func ToServiceBusyError ¶

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

ToServiceBusyError converts thrift ServiceBusyError type to internal

func ToShardOwnershipLostError ¶ added in v0.17.0

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

ToShardOwnershipLostError converts thrift ShardOwnershipLostError type to internal

func ToSignalExternalWorkflowExecutionDecisionAttributes ¶

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

ToSignalExternalWorkflowExecutionDecisionAttributes converts thrift SignalExternalWorkflowExecutionDecisionAttributes type to internal

func ToSignalExternalWorkflowExecutionFailedCause ¶

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

ToSignalExternalWorkflowExecutionFailedCause converts thrift SignalExternalWorkflowExecutionFailedCause type to internal

func ToSignalExternalWorkflowExecutionFailedEventAttributes ¶

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

ToSignalExternalWorkflowExecutionFailedEventAttributes converts thrift SignalExternalWorkflowExecutionFailedEventAttributes type to internal

func ToSignalExternalWorkflowExecutionInitiatedEventAttributes ¶

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

ToSignalExternalWorkflowExecutionInitiatedEventAttributes converts thrift SignalExternalWorkflowExecutionInitiatedEventAttributes type to internal

func ToSignalWithStartWorkflowExecutionRequest ¶

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

ToSignalWithStartWorkflowExecutionRequest converts thrift SignalWithStartWorkflowExecutionRequest type to internal

func ToSignalWorkflowExecutionRequest ¶

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

ToSignalWorkflowExecutionRequest converts thrift SignalWorkflowExecutionRequest type to internal

func ToStartChildWorkflowExecutionDecisionAttributes ¶

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

ToStartChildWorkflowExecutionDecisionAttributes converts thrift StartChildWorkflowExecutionDecisionAttributes type to internal

func ToStartChildWorkflowExecutionFailedEventAttributes ¶

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

ToStartChildWorkflowExecutionFailedEventAttributes converts thrift StartChildWorkflowExecutionFailedEventAttributes type to internal

func ToStartChildWorkflowExecutionInitiatedEventAttributes ¶

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

ToStartChildWorkflowExecutionInitiatedEventAttributes converts thrift StartChildWorkflowExecutionInitiatedEventAttributes type to internal

func ToStartTimeFilter ¶

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

ToStartTimeFilter converts thrift StartTimeFilter type to internal

func ToStartTimerDecisionAttributes ¶

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

ToStartTimerDecisionAttributes converts thrift StartTimerDecisionAttributes type to internal

func ToStartWorkflowExecutionRequest ¶

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

ToStartWorkflowExecutionRequest converts thrift StartWorkflowExecutionRequest type to internal

func ToStartWorkflowExecutionResponse ¶

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

ToStartWorkflowExecutionResponse converts thrift StartWorkflowExecutionResponse type to internal

func ToStickyExecutionAttributes ¶

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

ToStickyExecutionAttributes converts thrift StickyExecutionAttributes type to internal

func ToSupportedClientVersions ¶

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

ToSupportedClientVersions converts thrift SupportedClientVersions type to internal

func ToSyncActivityRequest ¶ added in v0.17.0

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

ToSyncActivityRequest converts thrift SyncActivityRequest type to internal

func ToSyncActivityTaskAttributes ¶ added in v0.17.0

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

ToSyncActivityTaskAttributes converts thrift SyncActivityTaskAttributes type to internal

func ToSyncShardStatus ¶ added in v0.17.0

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

ToSyncShardStatus converts thrift SyncShardStatus type to internal

func ToSyncShardStatusRequest ¶ added in v0.17.0

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

ToSyncShardStatusRequest converts thrift SyncShardStatusRequest type to internal

func ToSyncShardStatusTaskAttributes ¶ added in v0.17.0

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

ToSyncShardStatusTaskAttributes converts thrift SyncShardStatusTaskAttributes type to internal

func ToTaskIDBlock ¶

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

ToTaskIDBlock converts thrift TaskIDBlock type to internal

func ToTaskList ¶

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

ToTaskList converts thrift TaskList type to internal

func ToTaskListKind ¶

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

ToTaskListKind converts thrift TaskListKind type to internal

func ToTaskListMetadata ¶

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

ToTaskListMetadata converts thrift TaskListMetadata type to internal

func ToTaskListPartitionMetadata ¶

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

ToTaskListPartitionMetadata converts thrift TaskListPartitionMetadata type to internal

func ToTaskListPartitionMetadataArray ¶

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

ToTaskListPartitionMetadataArray converts thrift TaskListPartitionMetadata type array to internal

func ToTaskListStatus ¶

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

ToTaskListStatus converts thrift TaskListStatus type to internal

func ToTaskListType ¶

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

ToTaskListType converts thrift TaskListType type to internal

func ToTaskSource ¶ added in v0.17.0

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

ToTaskSource converts thrift TaskSource type to internal

func ToTerminateWorkflowExecutionRequest ¶

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

ToTerminateWorkflowExecutionRequest converts thrift TerminateWorkflowExecutionRequest type to internal

func ToTimeoutType ¶

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

ToTimeoutType converts thrift TimeoutType type to internal

func ToTimerCanceledEventAttributes ¶

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

ToTimerCanceledEventAttributes converts thrift TimerCanceledEventAttributes type to internal

func ToTimerFiredEventAttributes ¶

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

ToTimerFiredEventAttributes converts thrift TimerFiredEventAttributes type to internal

func ToTimerStartedEventAttributes ¶

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

ToTimerStartedEventAttributes converts thrift TimerStartedEventAttributes type to internal

func ToTransientDecisionInfo ¶

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

ToTransientDecisionInfo converts thrift TransientDecisionInfo type to internal

func ToUpdateDomainInfo ¶

func ToUpdateDomainInfo(t *shared.UpdateDomainInfo) *types.UpdateDomainInfo

ToUpdateDomainInfo converts thrift UpdateDomainInfo type to internal

func ToUpdateDomainRequest ¶

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

ToUpdateDomainRequest converts thrift UpdateDomainRequest type to internal

func ToUpdateDomainResponse ¶

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

ToUpdateDomainResponse converts thrift UpdateDomainResponse type to internal

func ToUpsertWorkflowSearchAttributesDecisionAttributes ¶

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

ToUpsertWorkflowSearchAttributesDecisionAttributes converts thrift UpsertWorkflowSearchAttributesDecisionAttributes type to internal

func ToUpsertWorkflowSearchAttributesEventAttributes ¶

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

ToUpsertWorkflowSearchAttributesEventAttributes converts thrift UpsertWorkflowSearchAttributesEventAttributes type to internal

func ToVersionHistories ¶

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

ToVersionHistories converts thrift VersionHistories type to internal

func ToVersionHistory ¶

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

ToVersionHistory converts thrift VersionHistory type to internal

func ToVersionHistoryArray ¶

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

ToVersionHistoryArray converts thrift VersionHistory type array to internal

func ToVersionHistoryItem ¶

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

ToVersionHistoryItem converts thrift VersionHistoryItem type to internal

func ToVersionHistoryItemArray ¶

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

ToVersionHistoryItemArray converts thrift VersionHistoryItem type array to internal

func ToWorkerVersionInfo ¶

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

ToWorkerVersionInfo converts thrift WorkerVersionInfo type to internal

func ToWorkflowExecution ¶

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

ToWorkflowExecution converts thrift WorkflowExecution type to internal

func ToWorkflowExecutionAlreadyStartedError ¶

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

ToWorkflowExecutionAlreadyStartedError converts thrift WorkflowExecutionAlreadyStartedError type to internal

func ToWorkflowExecutionCancelRequestedEventAttributes ¶

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

ToWorkflowExecutionCancelRequestedEventAttributes converts thrift WorkflowExecutionCancelRequestedEventAttributes type to internal

func ToWorkflowExecutionCanceledEventAttributes ¶

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

ToWorkflowExecutionCanceledEventAttributes converts thrift WorkflowExecutionCanceledEventAttributes type to internal

func ToWorkflowExecutionCloseStatus ¶

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

ToWorkflowExecutionCloseStatus converts thrift WorkflowExecutionCloseStatus type to internal

func ToWorkflowExecutionCompletedEventAttributes ¶

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

ToWorkflowExecutionCompletedEventAttributes converts thrift WorkflowExecutionCompletedEventAttributes type to internal

func ToWorkflowExecutionConfiguration ¶

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

ToWorkflowExecutionConfiguration converts thrift WorkflowExecutionConfiguration type to internal

func ToWorkflowExecutionContinuedAsNewEventAttributes ¶

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

ToWorkflowExecutionContinuedAsNewEventAttributes converts thrift WorkflowExecutionContinuedAsNewEventAttributes type to internal

func ToWorkflowExecutionFailedEventAttributes ¶

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

ToWorkflowExecutionFailedEventAttributes converts thrift WorkflowExecutionFailedEventAttributes type to internal

func ToWorkflowExecutionFilter ¶

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

ToWorkflowExecutionFilter converts thrift WorkflowExecutionFilter type to internal

func ToWorkflowExecutionInfo ¶

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

ToWorkflowExecutionInfo converts thrift WorkflowExecutionInfo type to internal

func ToWorkflowExecutionInfoArray ¶

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

ToWorkflowExecutionInfoArray converts thrift WorkflowExecutionInfo type array to internal

func ToWorkflowExecutionSignaledEventAttributes ¶

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

ToWorkflowExecutionSignaledEventAttributes converts thrift WorkflowExecutionSignaledEventAttributes type to internal

func ToWorkflowExecutionStartedEventAttributes ¶

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

ToWorkflowExecutionStartedEventAttributes converts thrift WorkflowExecutionStartedEventAttributes type to internal

func ToWorkflowExecutionTerminatedEventAttributes ¶

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

ToWorkflowExecutionTerminatedEventAttributes converts thrift WorkflowExecutionTerminatedEventAttributes type to internal

func ToWorkflowExecutionTimedOutEventAttributes ¶

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

ToWorkflowExecutionTimedOutEventAttributes converts thrift WorkflowExecutionTimedOutEventAttributes type to internal

func ToWorkflowIDReusePolicy ¶

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

ToWorkflowIDReusePolicy converts thrift WorkflowIdReusePolicy type to internal

func ToWorkflowQuery ¶

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

ToWorkflowQuery converts thrift WorkflowQuery type to internal

func ToWorkflowQueryMap ¶

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

ToWorkflowQueryMap converts thrift WorkflowQuery type map to internal

func ToWorkflowQueryResult ¶

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

ToWorkflowQueryResult converts thrift WorkflowQueryResult type to internal

func ToWorkflowQueryResultMap ¶

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

ToWorkflowQueryResultMap converts thrift WorkflowQueryResult type map to internal

func ToWorkflowType ¶

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

ToWorkflowType converts thrift WorkflowType type to internal

func ToWorkflowTypeFilter ¶

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

ToWorkflowTypeFilter converts thrift WorkflowTypeFilter type to internal

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL