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 FromPersistenceFeature(t *types.PersistenceFeature) *admin.PersistenceFeature
- func FromPersistenceFeatures(t []*types.PersistenceFeature) []*admin.PersistenceFeature
- func FromPersistenceInfo(t *types.PersistenceInfo) *admin.PersistenceInfo
- func FromPersistenceInfoMap(t map[string]*types.PersistenceInfo) map[string]*admin.PersistenceInfo
- func FromPersistenceSetting(t *types.PersistenceSetting) *admin.PersistenceSetting
- func FromPersistenceSettings(t []*types.PersistenceSetting) []*admin.PersistenceSetting
- func FromPollForActivityTaskRequest(t *types.PollForActivityTaskRequest) *shared.PollForActivityTaskRequest
- func FromPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *shared.PollForActivityTaskResponse
- func FromPollForDecisionTaskRequest(t *types.PollForDecisionTaskRequest) *shared.PollForDecisionTaskRequest
- func FromPollForDecisionTaskResponse(t *types.PollForDecisionTaskResponse) *shared.PollForDecisionTaskResponse
- func 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 FromUpdateDomainRequest(t *types.UpdateDomainRequest) *shared.UpdateDomainRequest
- func FromUpdateDomainResponse(t *types.UpdateDomainResponse) *shared.UpdateDomainResponse
- func FromUpsertWorkflowSearchAttributesDecisionAttributes(t *types.UpsertWorkflowSearchAttributesDecisionAttributes) *shared.UpsertWorkflowSearchAttributesDecisionAttributes
- func FromUpsertWorkflowSearchAttributesEventAttributes(t *types.UpsertWorkflowSearchAttributesEventAttributes) *shared.UpsertWorkflowSearchAttributesEventAttributes
- func FromVersionHistories(t *types.VersionHistories) *shared.VersionHistories
- func FromVersionHistory(t *types.VersionHistory) *shared.VersionHistory
- func FromVersionHistoryArray(t []*types.VersionHistory) []*shared.VersionHistory
- func FromVersionHistoryItem(t *types.VersionHistoryItem) *shared.VersionHistoryItem
- func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*shared.VersionHistoryItem
- func FromWorkerVersionInfo(t *types.WorkerVersionInfo) *shared.WorkerVersionInfo
- func FromWorkflowExecution(t *types.WorkflowExecution) *shared.WorkflowExecution
- func FromWorkflowExecutionAlreadyCompletedError(t *types.WorkflowExecutionAlreadyCompletedError) *shared.WorkflowExecutionAlreadyCompletedError
- func FromWorkflowExecutionAlreadyStartedError(t *types.WorkflowExecutionAlreadyStartedError) *shared.WorkflowExecutionAlreadyStartedError
- func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecutionCancelRequestedEventAttributes) *shared.WorkflowExecutionCancelRequestedEventAttributes
- func FromWorkflowExecutionCanceledEventAttributes(t *types.WorkflowExecutionCanceledEventAttributes) *shared.WorkflowExecutionCanceledEventAttributes
- func FromWorkflowExecutionCloseStatus(t *types.WorkflowExecutionCloseStatus) *shared.WorkflowExecutionCloseStatus
- func FromWorkflowExecutionCompletedEventAttributes(t *types.WorkflowExecutionCompletedEventAttributes) *shared.WorkflowExecutionCompletedEventAttributes
- func FromWorkflowExecutionConfiguration(t *types.WorkflowExecutionConfiguration) *shared.WorkflowExecutionConfiguration
- func FromWorkflowExecutionContinuedAsNewEventAttributes(t *types.WorkflowExecutionContinuedAsNewEventAttributes) *shared.WorkflowExecutionContinuedAsNewEventAttributes
- func FromWorkflowExecutionFailedEventAttributes(t *types.WorkflowExecutionFailedEventAttributes) *shared.WorkflowExecutionFailedEventAttributes
- func FromWorkflowExecutionFilter(t *types.WorkflowExecutionFilter) *shared.WorkflowExecutionFilter
- func FromWorkflowExecutionInfo(t *types.WorkflowExecutionInfo) *shared.WorkflowExecutionInfo
- func FromWorkflowExecutionInfoArray(t []*types.WorkflowExecutionInfo) []*shared.WorkflowExecutionInfo
- func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSignaledEventAttributes) *shared.WorkflowExecutionSignaledEventAttributes
- func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStartedEventAttributes) *shared.WorkflowExecutionStartedEventAttributes
- func FromWorkflowExecutionTerminatedEventAttributes(t *types.WorkflowExecutionTerminatedEventAttributes) *shared.WorkflowExecutionTerminatedEventAttributes
- func FromWorkflowExecutionTimedOutEventAttributes(t *types.WorkflowExecutionTimedOutEventAttributes) *shared.WorkflowExecutionTimedOutEventAttributes
- func FromWorkflowIDReusePolicy(t *types.WorkflowIDReusePolicy) *shared.WorkflowIdReusePolicy
- func FromWorkflowQuery(t *types.WorkflowQuery) *shared.WorkflowQuery
- func FromWorkflowQueryMap(t map[string]*types.WorkflowQuery) map[string]*shared.WorkflowQuery
- func FromWorkflowQueryResult(t *types.WorkflowQueryResult) *shared.WorkflowQueryResult
- func FromWorkflowQueryResultMap(t map[string]*types.WorkflowQueryResult) map[string]*shared.WorkflowQueryResult
- func FromWorkflowType(t *types.WorkflowType) *shared.WorkflowType
- func FromWorkflowTypeFilter(t *types.WorkflowTypeFilter) *shared.WorkflowTypeFilter
- func ToAccessDeniedError(t *shared.AccessDeniedError) *types.AccessDeniedError
- func ToActivityLocalDispatchInfo(t *shared.ActivityLocalDispatchInfo) *types.ActivityLocalDispatchInfo
- func ToActivityLocalDispatchInfoMap(t map[string]*shared.ActivityLocalDispatchInfo) map[string]*types.ActivityLocalDispatchInfo
- func ToActivityTaskCancelRequestedEventAttributes(t *shared.ActivityTaskCancelRequestedEventAttributes) *types.ActivityTaskCancelRequestedEventAttributes
- func ToActivityTaskCanceledEventAttributes(t *shared.ActivityTaskCanceledEventAttributes) *types.ActivityTaskCanceledEventAttributes
- func ToActivityTaskCompletedEventAttributes(t *shared.ActivityTaskCompletedEventAttributes) *types.ActivityTaskCompletedEventAttributes
- func 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 ToPersistenceFeature(t *admin.PersistenceFeature) *types.PersistenceFeature
- func ToPersistenceFeatures(t []*admin.PersistenceFeature) []*types.PersistenceFeature
- func ToPersistenceInfo(t *admin.PersistenceInfo) *types.PersistenceInfo
- func ToPersistenceInfoMap(t map[string]*admin.PersistenceInfo) map[string]*types.PersistenceInfo
- func ToPersistenceSetting(t *admin.PersistenceSetting) *types.PersistenceSetting
- func ToPersistenceSettings(t []*admin.PersistenceSetting) []*types.PersistenceSetting
- func ToPollForActivityTaskRequest(t *shared.PollForActivityTaskRequest) *types.PollForActivityTaskRequest
- func ToPollForActivityTaskResponse(t *shared.PollForActivityTaskResponse) *types.PollForActivityTaskResponse
- func ToPollForDecisionTaskRequest(t *shared.PollForDecisionTaskRequest) *types.PollForDecisionTaskRequest
- func ToPollForDecisionTaskResponse(t *shared.PollForDecisionTaskResponse) *types.PollForDecisionTaskResponse
- func 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 ToUpdateDomainRequest(t *shared.UpdateDomainRequest) *types.UpdateDomainRequest
- func ToUpdateDomainResponse(t *shared.UpdateDomainResponse) *types.UpdateDomainResponse
- func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *shared.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes
- func ToUpsertWorkflowSearchAttributesEventAttributes(t *shared.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes
- func ToVersionHistories(t *shared.VersionHistories) *types.VersionHistories
- func ToVersionHistory(t *shared.VersionHistory) *types.VersionHistory
- func ToVersionHistoryArray(t []*shared.VersionHistory) []*types.VersionHistory
- func ToVersionHistoryItem(t *shared.VersionHistoryItem) *types.VersionHistoryItem
- func ToVersionHistoryItemArray(t []*shared.VersionHistoryItem) []*types.VersionHistoryItem
- func ToWorkerVersionInfo(t *shared.WorkerVersionInfo) *types.WorkerVersionInfo
- func ToWorkflowExecution(t *shared.WorkflowExecution) *types.WorkflowExecution
- func ToWorkflowExecutionAlreadyCompletedError(t *shared.WorkflowExecutionAlreadyCompletedError) *types.WorkflowExecutionAlreadyCompletedError
- func ToWorkflowExecutionAlreadyStartedError(t *shared.WorkflowExecutionAlreadyStartedError) *types.WorkflowExecutionAlreadyStartedError
- func ToWorkflowExecutionCancelRequestedEventAttributes(t *shared.WorkflowExecutionCancelRequestedEventAttributes) *types.WorkflowExecutionCancelRequestedEventAttributes
- func ToWorkflowExecutionCanceledEventAttributes(t *shared.WorkflowExecutionCanceledEventAttributes) *types.WorkflowExecutionCanceledEventAttributes
- func ToWorkflowExecutionCloseStatus(t *shared.WorkflowExecutionCloseStatus) *types.WorkflowExecutionCloseStatus
- func ToWorkflowExecutionCompletedEventAttributes(t *shared.WorkflowExecutionCompletedEventAttributes) *types.WorkflowExecutionCompletedEventAttributes
- func ToWorkflowExecutionConfiguration(t *shared.WorkflowExecutionConfiguration) *types.WorkflowExecutionConfiguration
- func ToWorkflowExecutionContinuedAsNewEventAttributes(t *shared.WorkflowExecutionContinuedAsNewEventAttributes) *types.WorkflowExecutionContinuedAsNewEventAttributes
- func ToWorkflowExecutionFailedEventAttributes(t *shared.WorkflowExecutionFailedEventAttributes) *types.WorkflowExecutionFailedEventAttributes
- func ToWorkflowExecutionFilter(t *shared.WorkflowExecutionFilter) *types.WorkflowExecutionFilter
- func ToWorkflowExecutionInfo(t *shared.WorkflowExecutionInfo) *types.WorkflowExecutionInfo
- func ToWorkflowExecutionInfoArray(t []*shared.WorkflowExecutionInfo) []*types.WorkflowExecutionInfo
- func ToWorkflowExecutionSignaledEventAttributes(t *shared.WorkflowExecutionSignaledEventAttributes) *types.WorkflowExecutionSignaledEventAttributes
- func ToWorkflowExecutionStartedEventAttributes(t *shared.WorkflowExecutionStartedEventAttributes) *types.WorkflowExecutionStartedEventAttributes
- func ToWorkflowExecutionTerminatedEventAttributes(t *shared.WorkflowExecutionTerminatedEventAttributes) *types.WorkflowExecutionTerminatedEventAttributes
- func ToWorkflowExecutionTimedOutEventAttributes(t *shared.WorkflowExecutionTimedOutEventAttributes) *types.WorkflowExecutionTimedOutEventAttributes
- func ToWorkflowIDReusePolicy(t *shared.WorkflowIdReusePolicy) *types.WorkflowIDReusePolicy
- func ToWorkflowQuery(t *shared.WorkflowQuery) *types.WorkflowQuery
- func ToWorkflowQueryMap(t map[string]*shared.WorkflowQuery) map[string]*types.WorkflowQuery
- func ToWorkflowQueryResult(t *shared.WorkflowQueryResult) *types.WorkflowQueryResult
- func ToWorkflowQueryResultMap(t map[string]*shared.WorkflowQueryResult) map[string]*types.WorkflowQueryResult
- func ToWorkflowType(t *shared.WorkflowType) *types.WorkflowType
- func ToWorkflowTypeFilter(t *shared.WorkflowTypeFilter) *types.WorkflowTypeFilter
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 ¶
FromDataBlob converts internal DataBlob type to thrift
func FromDataBlobArray ¶
FromDataBlobArray converts internal DataBlob type array to thrift
func FromDecision ¶
FromDecision converts internal Decision type to thrift
func FromDecisionArray ¶
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 FromEventAlreadyStartedError ¶ added in v0.17.0
func FromEventAlreadyStartedError(t *types.EventAlreadyStartedError) *history.EventAlreadyStartedError
FromEventAlreadyStartedError converts internal EventAlreadyStartedError type to thrift
func FromEventType ¶
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 ¶
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 ¶
FromHistory converts internal History type to thrift
func FromHistoryArray ¶ added in v0.18.0
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
FromHostInfo converts internal HostInfo type to thrift
func FromHostInfoArray ¶ added in v0.17.0
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 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 FromPersistenceFeature ¶ added in v0.21.0
func FromPersistenceFeature(t *types.PersistenceFeature) *admin.PersistenceFeature
FromPersistenceFeature converts internal PersistenceFeature type to thrift
func FromPersistenceFeatures ¶ added in v0.21.0
func FromPersistenceFeatures(t []*types.PersistenceFeature) []*admin.PersistenceFeature
FromPersistenceFeatures converts internal []*types.PersistenceFeature type to thrift
func FromPersistenceInfo ¶ added in v0.21.0
func FromPersistenceInfo(t *types.PersistenceInfo) *admin.PersistenceInfo
FromPersistenceInfo converts internal PersistenceInfo type to thrift
func FromPersistenceInfoMap ¶ added in v0.21.0
func FromPersistenceInfoMap(t map[string]*types.PersistenceInfo) map[string]*admin.PersistenceInfo
FromPersistenceInfoMap converts internal map[string]*types.PersistenceInfo type to thrift
func FromPersistenceSetting ¶ added in v0.21.0
func FromPersistenceSetting(t *types.PersistenceSetting) *admin.PersistenceSetting
FromPersistenceSetting converts internal PersistenceSetting type to thrift
func FromPersistenceSettings ¶ added in v0.21.0
func FromPersistenceSettings(t []*types.PersistenceSetting) []*admin.PersistenceSetting
FromPersistenceSettings converts internal []*types.PersistenceSetting type to thrift
func FromPollForActivityTaskRequest ¶
func FromPollForActivityTaskRequest(t *types.PollForActivityTaskRequest) *shared.PollForActivityTaskRequest
FromPollForActivityTaskRequest converts internal PollForActivityTaskRequest type to thrift
func FromPollForActivityTaskResponse ¶
func FromPollForActivityTaskResponse(t *types.PollForActivityTaskResponse) *shared.PollForActivityTaskResponse
FromPollForActivityTaskResponse converts internal PollForActivityTaskResponse type to thrift
func FromPollForDecisionTaskRequest ¶
func FromPollForDecisionTaskRequest(t *types.PollForDecisionTaskRequest) *shared.PollForDecisionTaskRequest
FromPollForDecisionTaskRequest converts internal PollForDecisionTaskRequest type to thrift
func FromPollForDecisionTaskResponse ¶
func FromPollForDecisionTaskResponse(t *types.PollForDecisionTaskResponse) *shared.PollForDecisionTaskResponse
FromPollForDecisionTaskResponse converts internal PollForDecisionTaskResponse type to thrift
func 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
FromRingInfo converts internal RingInfo type to thrift
func FromRingInfoArray ¶ added in v0.17.0
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 ¶
FromTaskList converts internal TaskList type to thrift
func FromTaskListKind ¶
func FromTaskListKind(t *types.TaskListKind) *shared.TaskListKind
FromTaskListKind converts internal TaskListKind type to thrift
func FromTaskListMetadata ¶
func FromTaskListMetadata(t *types.TaskListMetadata) *shared.TaskListMetadata
FromTaskListMetadata converts internal TaskListMetadata type to thrift
func FromTaskListPartitionMetadata ¶
func FromTaskListPartitionMetadata(t *types.TaskListPartitionMetadata) *shared.TaskListPartitionMetadata
FromTaskListPartitionMetadata converts internal TaskListPartitionMetadata type to thrift
func FromTaskListPartitionMetadataArray ¶
func FromTaskListPartitionMetadataArray(t []*types.TaskListPartitionMetadata) []*shared.TaskListPartitionMetadata
FromTaskListPartitionMetadataArray converts internal TaskListPartitionMetadata type array to thrift
func FromTaskListStatus ¶
func FromTaskListStatus(t *types.TaskListStatus) *shared.TaskListStatus
FromTaskListStatus converts internal TaskListStatus type to thrift
func FromTaskListType ¶
func FromTaskListType(t *types.TaskListType) *shared.TaskListType
FromTaskListType converts internal TaskListType type to thrift
func FromTaskSource ¶ added in v0.17.0
func FromTaskSource(t *types.TaskSource) *matching.TaskSource
FromTaskSource converts internal TaskSource type to thrift
func FromTerminateWorkflowExecutionRequest ¶
func FromTerminateWorkflowExecutionRequest(t *types.TerminateWorkflowExecutionRequest) *shared.TerminateWorkflowExecutionRequest
FromTerminateWorkflowExecutionRequest converts internal TerminateWorkflowExecutionRequest type to thrift
func FromTimeoutType ¶
func FromTimeoutType(t *types.TimeoutType) *shared.TimeoutType
FromTimeoutType converts internal TimeoutType type to thrift
func FromTimerCanceledEventAttributes ¶
func FromTimerCanceledEventAttributes(t *types.TimerCanceledEventAttributes) *shared.TimerCanceledEventAttributes
FromTimerCanceledEventAttributes converts internal TimerCanceledEventAttributes type to thrift
func FromTimerFiredEventAttributes ¶
func FromTimerFiredEventAttributes(t *types.TimerFiredEventAttributes) *shared.TimerFiredEventAttributes
FromTimerFiredEventAttributes converts internal TimerFiredEventAttributes type to thrift
func FromTimerStartedEventAttributes ¶
func FromTimerStartedEventAttributes(t *types.TimerStartedEventAttributes) *shared.TimerStartedEventAttributes
FromTimerStartedEventAttributes converts internal TimerStartedEventAttributes type to thrift
func FromTransientDecisionInfo ¶
func FromTransientDecisionInfo(t *types.TransientDecisionInfo) *shared.TransientDecisionInfo
FromTransientDecisionInfo converts internal TransientDecisionInfo type to thrift
func FromUpdateDomainRequest ¶
func FromUpdateDomainRequest(t *types.UpdateDomainRequest) *shared.UpdateDomainRequest
FromUpdateDomainRequest converts internal UpdateDomainRequest type to thrift
func FromUpdateDomainResponse ¶
func FromUpdateDomainResponse(t *types.UpdateDomainResponse) *shared.UpdateDomainResponse
FromUpdateDomainResponse converts internal UpdateDomainResponse type to thrift
func FromUpsertWorkflowSearchAttributesDecisionAttributes ¶
func FromUpsertWorkflowSearchAttributesDecisionAttributes(t *types.UpsertWorkflowSearchAttributesDecisionAttributes) *shared.UpsertWorkflowSearchAttributesDecisionAttributes
FromUpsertWorkflowSearchAttributesDecisionAttributes converts internal UpsertWorkflowSearchAttributesDecisionAttributes type to thrift
func FromUpsertWorkflowSearchAttributesEventAttributes ¶
func FromUpsertWorkflowSearchAttributesEventAttributes(t *types.UpsertWorkflowSearchAttributesEventAttributes) *shared.UpsertWorkflowSearchAttributesEventAttributes
FromUpsertWorkflowSearchAttributesEventAttributes converts internal UpsertWorkflowSearchAttributesEventAttributes type to thrift
func FromVersionHistories ¶
func FromVersionHistories(t *types.VersionHistories) *shared.VersionHistories
FromVersionHistories converts internal VersionHistories type to thrift
func FromVersionHistory ¶
func FromVersionHistory(t *types.VersionHistory) *shared.VersionHistory
FromVersionHistory converts internal VersionHistory type to thrift
func FromVersionHistoryArray ¶
func FromVersionHistoryArray(t []*types.VersionHistory) []*shared.VersionHistory
FromVersionHistoryArray converts internal VersionHistory type array to thrift
func FromVersionHistoryItem ¶
func FromVersionHistoryItem(t *types.VersionHistoryItem) *shared.VersionHistoryItem
FromVersionHistoryItem converts internal VersionHistoryItem type to thrift
func FromVersionHistoryItemArray ¶
func FromVersionHistoryItemArray(t []*types.VersionHistoryItem) []*shared.VersionHistoryItem
FromVersionHistoryItemArray converts internal VersionHistoryItem type array to thrift
func FromWorkerVersionInfo ¶
func FromWorkerVersionInfo(t *types.WorkerVersionInfo) *shared.WorkerVersionInfo
FromWorkerVersionInfo converts internal WorkerVersionInfo type to thrift
func FromWorkflowExecution ¶
func FromWorkflowExecution(t *types.WorkflowExecution) *shared.WorkflowExecution
FromWorkflowExecution converts internal WorkflowExecution type to thrift
func FromWorkflowExecutionAlreadyCompletedError ¶ added in v0.21.0
func FromWorkflowExecutionAlreadyCompletedError(t *types.WorkflowExecutionAlreadyCompletedError) *shared.WorkflowExecutionAlreadyCompletedError
FromWorkflowExecutionAlreadyCompletedError converts internal WorkflowExecutionAlreadyCompletedError type to thrift
func FromWorkflowExecutionAlreadyStartedError ¶
func FromWorkflowExecutionAlreadyStartedError(t *types.WorkflowExecutionAlreadyStartedError) *shared.WorkflowExecutionAlreadyStartedError
FromWorkflowExecutionAlreadyStartedError converts internal WorkflowExecutionAlreadyStartedError type to thrift
func FromWorkflowExecutionCancelRequestedEventAttributes ¶
func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecutionCancelRequestedEventAttributes) *shared.WorkflowExecutionCancelRequestedEventAttributes
FromWorkflowExecutionCancelRequestedEventAttributes converts internal WorkflowExecutionCancelRequestedEventAttributes type to thrift
func FromWorkflowExecutionCanceledEventAttributes ¶
func FromWorkflowExecutionCanceledEventAttributes(t *types.WorkflowExecutionCanceledEventAttributes) *shared.WorkflowExecutionCanceledEventAttributes
FromWorkflowExecutionCanceledEventAttributes converts internal WorkflowExecutionCanceledEventAttributes type to thrift
func FromWorkflowExecutionCloseStatus ¶
func FromWorkflowExecutionCloseStatus(t *types.WorkflowExecutionCloseStatus) *shared.WorkflowExecutionCloseStatus
FromWorkflowExecutionCloseStatus converts internal WorkflowExecutionCloseStatus type to thrift
func FromWorkflowExecutionCompletedEventAttributes ¶
func FromWorkflowExecutionCompletedEventAttributes(t *types.WorkflowExecutionCompletedEventAttributes) *shared.WorkflowExecutionCompletedEventAttributes
FromWorkflowExecutionCompletedEventAttributes converts internal WorkflowExecutionCompletedEventAttributes type to thrift
func FromWorkflowExecutionConfiguration ¶
func FromWorkflowExecutionConfiguration(t *types.WorkflowExecutionConfiguration) *shared.WorkflowExecutionConfiguration
FromWorkflowExecutionConfiguration converts internal WorkflowExecutionConfiguration type to thrift
func FromWorkflowExecutionContinuedAsNewEventAttributes ¶
func FromWorkflowExecutionContinuedAsNewEventAttributes(t *types.WorkflowExecutionContinuedAsNewEventAttributes) *shared.WorkflowExecutionContinuedAsNewEventAttributes
FromWorkflowExecutionContinuedAsNewEventAttributes converts internal WorkflowExecutionContinuedAsNewEventAttributes type to thrift
func FromWorkflowExecutionFailedEventAttributes ¶
func FromWorkflowExecutionFailedEventAttributes(t *types.WorkflowExecutionFailedEventAttributes) *shared.WorkflowExecutionFailedEventAttributes
FromWorkflowExecutionFailedEventAttributes converts internal WorkflowExecutionFailedEventAttributes type to thrift
func FromWorkflowExecutionFilter ¶
func FromWorkflowExecutionFilter(t *types.WorkflowExecutionFilter) *shared.WorkflowExecutionFilter
FromWorkflowExecutionFilter converts internal WorkflowExecutionFilter type to thrift
func FromWorkflowExecutionInfo ¶
func FromWorkflowExecutionInfo(t *types.WorkflowExecutionInfo) *shared.WorkflowExecutionInfo
FromWorkflowExecutionInfo converts internal WorkflowExecutionInfo type to thrift
func FromWorkflowExecutionInfoArray ¶
func FromWorkflowExecutionInfoArray(t []*types.WorkflowExecutionInfo) []*shared.WorkflowExecutionInfo
FromWorkflowExecutionInfoArray converts internal WorkflowExecutionInfo type array to thrift
func FromWorkflowExecutionSignaledEventAttributes ¶
func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSignaledEventAttributes) *shared.WorkflowExecutionSignaledEventAttributes
FromWorkflowExecutionSignaledEventAttributes converts internal WorkflowExecutionSignaledEventAttributes type to thrift
func FromWorkflowExecutionStartedEventAttributes ¶
func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStartedEventAttributes) *shared.WorkflowExecutionStartedEventAttributes
FromWorkflowExecutionStartedEventAttributes converts internal WorkflowExecutionStartedEventAttributes type to thrift
func FromWorkflowExecutionTerminatedEventAttributes ¶
func FromWorkflowExecutionTerminatedEventAttributes(t *types.WorkflowExecutionTerminatedEventAttributes) *shared.WorkflowExecutionTerminatedEventAttributes
FromWorkflowExecutionTerminatedEventAttributes converts internal WorkflowExecutionTerminatedEventAttributes type to thrift
func FromWorkflowExecutionTimedOutEventAttributes ¶
func FromWorkflowExecutionTimedOutEventAttributes(t *types.WorkflowExecutionTimedOutEventAttributes) *shared.WorkflowExecutionTimedOutEventAttributes
FromWorkflowExecutionTimedOutEventAttributes converts internal WorkflowExecutionTimedOutEventAttributes type to thrift
func FromWorkflowIDReusePolicy ¶
func FromWorkflowIDReusePolicy(t *types.WorkflowIDReusePolicy) *shared.WorkflowIdReusePolicy
FromWorkflowIDReusePolicy converts internal WorkflowIDReusePolicy type to thrift
func FromWorkflowQuery ¶
func FromWorkflowQuery(t *types.WorkflowQuery) *shared.WorkflowQuery
FromWorkflowQuery converts internal WorkflowQuery type to thrift
func FromWorkflowQueryMap ¶
func FromWorkflowQueryMap(t map[string]*types.WorkflowQuery) map[string]*shared.WorkflowQuery
FromWorkflowQueryMap converts internal WorkflowQuery type map to thrift
func FromWorkflowQueryResult ¶
func FromWorkflowQueryResult(t *types.WorkflowQueryResult) *shared.WorkflowQueryResult
FromWorkflowQueryResult converts internal WorkflowQueryResult type to thrift
func FromWorkflowQueryResultMap ¶
func FromWorkflowQueryResultMap(t map[string]*types.WorkflowQueryResult) map[string]*shared.WorkflowQueryResult
FromWorkflowQueryResultMap converts internal WorkflowQueryResult type map to thrift
func FromWorkflowType ¶
func FromWorkflowType(t *types.WorkflowType) *shared.WorkflowType
FromWorkflowType converts internal WorkflowType type to thrift
func FromWorkflowTypeFilter ¶
func FromWorkflowTypeFilter(t *types.WorkflowTypeFilter) *shared.WorkflowTypeFilter
FromWorkflowTypeFilter converts internal WorkflowTypeFilter type to thrift
func ToAccessDeniedError ¶
func ToAccessDeniedError(t *shared.AccessDeniedError) *types.AccessDeniedError
ToAccessDeniedError converts thrift AccessDeniedError type to internal
func ToActivityLocalDispatchInfo ¶ added in v0.17.0
func ToActivityLocalDispatchInfo(t *shared.ActivityLocalDispatchInfo) *types.ActivityLocalDispatchInfo
ToActivityLocalDispatchInfo converts thrift ActivityLocalDispatchInfo type to internal
func ToActivityLocalDispatchInfoMap ¶ added in v0.17.0
func ToActivityLocalDispatchInfoMap(t map[string]*shared.ActivityLocalDispatchInfo) map[string]*types.ActivityLocalDispatchInfo
ToActivityLocalDispatchInfoMap converts thrift ActivityLocalDispatchInfo type map to internal
func ToActivityTaskCancelRequestedEventAttributes ¶
func ToActivityTaskCancelRequestedEventAttributes(t *shared.ActivityTaskCancelRequestedEventAttributes) *types.ActivityTaskCancelRequestedEventAttributes
ToActivityTaskCancelRequestedEventAttributes converts thrift ActivityTaskCancelRequestedEventAttributes type to internal
func ToActivityTaskCanceledEventAttributes ¶
func ToActivityTaskCanceledEventAttributes(t *shared.ActivityTaskCanceledEventAttributes) *types.ActivityTaskCanceledEventAttributes
ToActivityTaskCanceledEventAttributes converts thrift ActivityTaskCanceledEventAttributes type to internal
func ToActivityTaskCompletedEventAttributes ¶
func ToActivityTaskCompletedEventAttributes(t *shared.ActivityTaskCompletedEventAttributes) *types.ActivityTaskCompletedEventAttributes
ToActivityTaskCompletedEventAttributes converts thrift ActivityTaskCompletedEventAttributes type to internal
func 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 ¶
ToDataBlob converts thrift DataBlob type to internal
func ToDataBlobArray ¶
ToDataBlobArray converts thrift DataBlob type array to internal
func ToDecision ¶
ToDecision converts thrift Decision type to internal
func ToDecisionArray ¶
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
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 ¶
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 ToHealthStatus ¶ added in v0.18.0
func ToHealthStatus(t *health.HealthStatus) *types.HealthStatus
ToHealthStatus converts thrift HealthStatus type to internal
func ToHistoryArray ¶ added in v0.18.0
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
ToHostInfo converts thrift HostInfo type to internal
func ToHostInfoArray ¶ added in v0.17.0
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 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 ToPersistenceFeature ¶ added in v0.21.0
func ToPersistenceFeature(t *admin.PersistenceFeature) *types.PersistenceFeature
ToPersistenceFeature converts from thrift to internal PersistenceFeature type
func ToPersistenceFeatures ¶ added in v0.21.0
func ToPersistenceFeatures(t []*admin.PersistenceFeature) []*types.PersistenceFeature
ToPersistenceFeatures converts from thrift to internal []*types.PersistenceFeature type
func ToPersistenceInfo ¶ added in v0.21.0
func ToPersistenceInfo(t *admin.PersistenceInfo) *types.PersistenceInfo
ToPersistenceInfo converts thrift to internal PersistenceInfo type
func ToPersistenceInfoMap ¶ added in v0.21.0
func ToPersistenceInfoMap(t map[string]*admin.PersistenceInfo) map[string]*types.PersistenceInfo
ToPersistenceInfoMap converts thrift to internal map[string]*types.PersistenceInfo type
func ToPersistenceSetting ¶ added in v0.21.0
func ToPersistenceSetting(t *admin.PersistenceSetting) *types.PersistenceSetting
ToPersistenceSetting converts from thrift to internal PersistenceSetting type
func ToPersistenceSettings ¶ added in v0.21.0
func ToPersistenceSettings(t []*admin.PersistenceSetting) []*types.PersistenceSetting
ToPersistenceSettings converts thrift to internal []*types.PersistenceSetting type
func ToPollForActivityTaskRequest ¶
func ToPollForActivityTaskRequest(t *shared.PollForActivityTaskRequest) *types.PollForActivityTaskRequest
ToPollForActivityTaskRequest converts thrift PollForActivityTaskRequest type to internal
func ToPollForActivityTaskResponse ¶
func ToPollForActivityTaskResponse(t *shared.PollForActivityTaskResponse) *types.PollForActivityTaskResponse
ToPollForActivityTaskResponse converts thrift PollForActivityTaskResponse type to internal
func ToPollForDecisionTaskRequest ¶
func ToPollForDecisionTaskRequest(t *shared.PollForDecisionTaskRequest) *types.PollForDecisionTaskRequest
ToPollForDecisionTaskRequest converts thrift PollForDecisionTaskRequest type to internal
func ToPollForDecisionTaskResponse ¶
func ToPollForDecisionTaskResponse(t *shared.PollForDecisionTaskResponse) *types.PollForDecisionTaskResponse
ToPollForDecisionTaskResponse converts thrift PollForDecisionTaskResponse type to internal
func 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
ToRingInfo converts thrift RingInfo type to internal
func ToRingInfoArray ¶ added in v0.17.0
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 ¶
ToTaskList converts thrift TaskList type to internal
func ToTaskListKind ¶
func ToTaskListKind(t *shared.TaskListKind) *types.TaskListKind
ToTaskListKind converts thrift TaskListKind type to internal
func ToTaskListMetadata ¶
func ToTaskListMetadata(t *shared.TaskListMetadata) *types.TaskListMetadata
ToTaskListMetadata converts thrift TaskListMetadata type to internal
func ToTaskListPartitionMetadata ¶
func ToTaskListPartitionMetadata(t *shared.TaskListPartitionMetadata) *types.TaskListPartitionMetadata
ToTaskListPartitionMetadata converts thrift TaskListPartitionMetadata type to internal
func ToTaskListPartitionMetadataArray ¶
func ToTaskListPartitionMetadataArray(t []*shared.TaskListPartitionMetadata) []*types.TaskListPartitionMetadata
ToTaskListPartitionMetadataArray converts thrift TaskListPartitionMetadata type array to internal
func ToTaskListStatus ¶
func ToTaskListStatus(t *shared.TaskListStatus) *types.TaskListStatus
ToTaskListStatus converts thrift TaskListStatus type to internal
func ToTaskListType ¶
func ToTaskListType(t *shared.TaskListType) *types.TaskListType
ToTaskListType converts thrift TaskListType type to internal
func ToTaskSource ¶ added in v0.17.0
func ToTaskSource(t *matching.TaskSource) *types.TaskSource
ToTaskSource converts thrift TaskSource type to internal
func ToTerminateWorkflowExecutionRequest ¶
func ToTerminateWorkflowExecutionRequest(t *shared.TerminateWorkflowExecutionRequest) *types.TerminateWorkflowExecutionRequest
ToTerminateWorkflowExecutionRequest converts thrift TerminateWorkflowExecutionRequest type to internal
func ToTimeoutType ¶
func ToTimeoutType(t *shared.TimeoutType) *types.TimeoutType
ToTimeoutType converts thrift TimeoutType type to internal
func ToTimerCanceledEventAttributes ¶
func ToTimerCanceledEventAttributes(t *shared.TimerCanceledEventAttributes) *types.TimerCanceledEventAttributes
ToTimerCanceledEventAttributes converts thrift TimerCanceledEventAttributes type to internal
func ToTimerFiredEventAttributes ¶
func ToTimerFiredEventAttributes(t *shared.TimerFiredEventAttributes) *types.TimerFiredEventAttributes
ToTimerFiredEventAttributes converts thrift TimerFiredEventAttributes type to internal
func ToTimerStartedEventAttributes ¶
func ToTimerStartedEventAttributes(t *shared.TimerStartedEventAttributes) *types.TimerStartedEventAttributes
ToTimerStartedEventAttributes converts thrift TimerStartedEventAttributes type to internal
func ToTransientDecisionInfo ¶
func ToTransientDecisionInfo(t *shared.TransientDecisionInfo) *types.TransientDecisionInfo
ToTransientDecisionInfo converts thrift TransientDecisionInfo type to internal
func ToUpdateDomainRequest ¶
func ToUpdateDomainRequest(t *shared.UpdateDomainRequest) *types.UpdateDomainRequest
ToUpdateDomainRequest converts thrift UpdateDomainRequest type to internal
func ToUpdateDomainResponse ¶
func ToUpdateDomainResponse(t *shared.UpdateDomainResponse) *types.UpdateDomainResponse
ToUpdateDomainResponse converts thrift UpdateDomainResponse type to internal
func ToUpsertWorkflowSearchAttributesDecisionAttributes ¶
func ToUpsertWorkflowSearchAttributesDecisionAttributes(t *shared.UpsertWorkflowSearchAttributesDecisionAttributes) *types.UpsertWorkflowSearchAttributesDecisionAttributes
ToUpsertWorkflowSearchAttributesDecisionAttributes converts thrift UpsertWorkflowSearchAttributesDecisionAttributes type to internal
func ToUpsertWorkflowSearchAttributesEventAttributes ¶
func ToUpsertWorkflowSearchAttributesEventAttributes(t *shared.UpsertWorkflowSearchAttributesEventAttributes) *types.UpsertWorkflowSearchAttributesEventAttributes
ToUpsertWorkflowSearchAttributesEventAttributes converts thrift UpsertWorkflowSearchAttributesEventAttributes type to internal
func ToVersionHistories ¶
func ToVersionHistories(t *shared.VersionHistories) *types.VersionHistories
ToVersionHistories converts thrift VersionHistories type to internal
func ToVersionHistory ¶
func ToVersionHistory(t *shared.VersionHistory) *types.VersionHistory
ToVersionHistory converts thrift VersionHistory type to internal
func ToVersionHistoryArray ¶
func ToVersionHistoryArray(t []*shared.VersionHistory) []*types.VersionHistory
ToVersionHistoryArray converts thrift VersionHistory type array to internal
func ToVersionHistoryItem ¶
func ToVersionHistoryItem(t *shared.VersionHistoryItem) *types.VersionHistoryItem
ToVersionHistoryItem converts thrift VersionHistoryItem type to internal
func ToVersionHistoryItemArray ¶
func ToVersionHistoryItemArray(t []*shared.VersionHistoryItem) []*types.VersionHistoryItem
ToVersionHistoryItemArray converts thrift VersionHistoryItem type array to internal
func ToWorkerVersionInfo ¶
func ToWorkerVersionInfo(t *shared.WorkerVersionInfo) *types.WorkerVersionInfo
ToWorkerVersionInfo converts thrift WorkerVersionInfo type to internal
func ToWorkflowExecution ¶
func ToWorkflowExecution(t *shared.WorkflowExecution) *types.WorkflowExecution
ToWorkflowExecution converts thrift WorkflowExecution type to internal
func ToWorkflowExecutionAlreadyCompletedError ¶ added in v0.21.0
func ToWorkflowExecutionAlreadyCompletedError(t *shared.WorkflowExecutionAlreadyCompletedError) *types.WorkflowExecutionAlreadyCompletedError
ToWorkflowExecutionAlreadyCompletedError converts thrift WorkflowExecutionAlreadyCompletedError type to internal
func ToWorkflowExecutionAlreadyStartedError ¶
func ToWorkflowExecutionAlreadyStartedError(t *shared.WorkflowExecutionAlreadyStartedError) *types.WorkflowExecutionAlreadyStartedError
ToWorkflowExecutionAlreadyStartedError converts thrift WorkflowExecutionAlreadyStartedError type to internal
func ToWorkflowExecutionCancelRequestedEventAttributes ¶
func ToWorkflowExecutionCancelRequestedEventAttributes(t *shared.WorkflowExecutionCancelRequestedEventAttributes) *types.WorkflowExecutionCancelRequestedEventAttributes
ToWorkflowExecutionCancelRequestedEventAttributes converts thrift WorkflowExecutionCancelRequestedEventAttributes type to internal
func ToWorkflowExecutionCanceledEventAttributes ¶
func ToWorkflowExecutionCanceledEventAttributes(t *shared.WorkflowExecutionCanceledEventAttributes) *types.WorkflowExecutionCanceledEventAttributes
ToWorkflowExecutionCanceledEventAttributes converts thrift WorkflowExecutionCanceledEventAttributes type to internal
func ToWorkflowExecutionCloseStatus ¶
func ToWorkflowExecutionCloseStatus(t *shared.WorkflowExecutionCloseStatus) *types.WorkflowExecutionCloseStatus
ToWorkflowExecutionCloseStatus converts thrift WorkflowExecutionCloseStatus type to internal
func ToWorkflowExecutionCompletedEventAttributes ¶
func ToWorkflowExecutionCompletedEventAttributes(t *shared.WorkflowExecutionCompletedEventAttributes) *types.WorkflowExecutionCompletedEventAttributes
ToWorkflowExecutionCompletedEventAttributes converts thrift WorkflowExecutionCompletedEventAttributes type to internal
func ToWorkflowExecutionConfiguration ¶
func ToWorkflowExecutionConfiguration(t *shared.WorkflowExecutionConfiguration) *types.WorkflowExecutionConfiguration
ToWorkflowExecutionConfiguration converts thrift WorkflowExecutionConfiguration type to internal
func ToWorkflowExecutionContinuedAsNewEventAttributes ¶
func ToWorkflowExecutionContinuedAsNewEventAttributes(t *shared.WorkflowExecutionContinuedAsNewEventAttributes) *types.WorkflowExecutionContinuedAsNewEventAttributes
ToWorkflowExecutionContinuedAsNewEventAttributes converts thrift WorkflowExecutionContinuedAsNewEventAttributes type to internal
func ToWorkflowExecutionFailedEventAttributes ¶
func ToWorkflowExecutionFailedEventAttributes(t *shared.WorkflowExecutionFailedEventAttributes) *types.WorkflowExecutionFailedEventAttributes
ToWorkflowExecutionFailedEventAttributes converts thrift WorkflowExecutionFailedEventAttributes type to internal
func ToWorkflowExecutionFilter ¶
func ToWorkflowExecutionFilter(t *shared.WorkflowExecutionFilter) *types.WorkflowExecutionFilter
ToWorkflowExecutionFilter converts thrift WorkflowExecutionFilter type to internal
func ToWorkflowExecutionInfo ¶
func ToWorkflowExecutionInfo(t *shared.WorkflowExecutionInfo) *types.WorkflowExecutionInfo
ToWorkflowExecutionInfo converts thrift WorkflowExecutionInfo type to internal
func ToWorkflowExecutionInfoArray ¶
func ToWorkflowExecutionInfoArray(t []*shared.WorkflowExecutionInfo) []*types.WorkflowExecutionInfo
ToWorkflowExecutionInfoArray converts thrift WorkflowExecutionInfo type array to internal
func ToWorkflowExecutionSignaledEventAttributes ¶
func ToWorkflowExecutionSignaledEventAttributes(t *shared.WorkflowExecutionSignaledEventAttributes) *types.WorkflowExecutionSignaledEventAttributes
ToWorkflowExecutionSignaledEventAttributes converts thrift WorkflowExecutionSignaledEventAttributes type to internal
func ToWorkflowExecutionStartedEventAttributes ¶
func ToWorkflowExecutionStartedEventAttributes(t *shared.WorkflowExecutionStartedEventAttributes) *types.WorkflowExecutionStartedEventAttributes
ToWorkflowExecutionStartedEventAttributes converts thrift WorkflowExecutionStartedEventAttributes type to internal
func ToWorkflowExecutionTerminatedEventAttributes ¶
func ToWorkflowExecutionTerminatedEventAttributes(t *shared.WorkflowExecutionTerminatedEventAttributes) *types.WorkflowExecutionTerminatedEventAttributes
ToWorkflowExecutionTerminatedEventAttributes converts thrift WorkflowExecutionTerminatedEventAttributes type to internal
func ToWorkflowExecutionTimedOutEventAttributes ¶
func ToWorkflowExecutionTimedOutEventAttributes(t *shared.WorkflowExecutionTimedOutEventAttributes) *types.WorkflowExecutionTimedOutEventAttributes
ToWorkflowExecutionTimedOutEventAttributes converts thrift WorkflowExecutionTimedOutEventAttributes type to internal
func ToWorkflowIDReusePolicy ¶
func ToWorkflowIDReusePolicy(t *shared.WorkflowIdReusePolicy) *types.WorkflowIDReusePolicy
ToWorkflowIDReusePolicy converts thrift WorkflowIdReusePolicy type to internal
func ToWorkflowQuery ¶
func ToWorkflowQuery(t *shared.WorkflowQuery) *types.WorkflowQuery
ToWorkflowQuery converts thrift WorkflowQuery type to internal
func ToWorkflowQueryMap ¶
func ToWorkflowQueryMap(t map[string]*shared.WorkflowQuery) map[string]*types.WorkflowQuery
ToWorkflowQueryMap converts thrift WorkflowQuery type map to internal
func ToWorkflowQueryResult ¶
func ToWorkflowQueryResult(t *shared.WorkflowQueryResult) *types.WorkflowQueryResult
ToWorkflowQueryResult converts thrift WorkflowQueryResult type to internal
func ToWorkflowQueryResultMap ¶
func ToWorkflowQueryResultMap(t map[string]*shared.WorkflowQueryResult) map[string]*types.WorkflowQueryResult
ToWorkflowQueryResultMap converts thrift WorkflowQueryResult type map to internal
func ToWorkflowType ¶
func ToWorkflowType(t *shared.WorkflowType) *types.WorkflowType
ToWorkflowType converts thrift WorkflowType type to internal
func ToWorkflowTypeFilter ¶
func ToWorkflowTypeFilter(t *shared.WorkflowTypeFilter) *types.WorkflowTypeFilter
ToWorkflowTypeFilter converts thrift WorkflowTypeFilter type to internal
Types ¶
This section is empty.