proto

package
v0.21.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 17, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func FromActivityType

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

func FromArchivalStatus

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

func FromBadBinaries

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

func FromBadBinaryInfo

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

func FromBadBinaryInfoMap

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

func FromDLQType

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

func FromDataBlob

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

func FromDataBlobArray

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

func FromDecision

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

func FromDecisionArray

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

func FromDescribeDomainResponseArray

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

func FromDescribeDomainResponseDomain

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

func FromDomainStatus

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

func FromEncodingType

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

func FromError

func FromError(err error) error

func FromEventIDVersionPair

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

func FromExternalExecutionInfoFields

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

func FromFailoverMarkerTokenArray

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

func FromFailure

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

func FromGetClusterInfoResponse

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

func FromHeader

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

func FromHealthResponse

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

func FromHistory

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

func FromHistoryEvent

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

func FromHistoryEventArray

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

func FromHostInfo

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

func FromHostInfoArray

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

func FromIndexedValueTypeMap

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

func FromMembershipInfo

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

func FromMemo

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

func FromParentExecutionInfoFields

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

func FromPayload

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

func FromPayloadMap

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

func FromPendingActivityInfoArray

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

func FromPersistenceFeature added in v0.21.0

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

func FromPersistenceFeatures added in v0.21.0

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

func FromPersistenceInfo added in v0.21.0

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

func FromPersistenceInfoMap added in v0.21.0

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

func FromPersistenceSetting added in v0.21.0

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

func FromPersistenceSettings added in v0.21.0

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

func FromPollerInfo

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

func FromPollerInfoArray

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

func FromQueryRejected

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

func FromQueryResultType

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

func FromReplicationTaskArray

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

func FromReplicationTaskInfoArray

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

func FromReplicationTokenArray

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

func FromResetPointInfo

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

func FromResetPointInfoArray

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

func FromResetPoints

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

func FromRetryPolicy

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

func FromRingInfo

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

func FromRingInfoArray

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

func FromSearchAttributes

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

func FromStartTimeFilter

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

func FromTaskIDBlock

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

func FromTaskList

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

func FromTaskListKind

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

func FromTaskListMetadata

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

func FromTaskListStatus

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

func FromTaskListType

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

func FromTaskSource

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

func FromTaskType

func FromTaskType(t *int32) sharedv1.TaskType

func FromTimeoutType

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

func FromVersionHistory

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

func FromVersionHistoryArray

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

func FromVersionHistoryItemArray

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

func FromWorkflowExecutionInfoArray

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

func FromWorkflowQuery

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

func FromWorkflowQueryMap

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

func FromWorkflowQueryResultMap

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

func FromWorkflowRunPair

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

func FromWorkflowState

func FromWorkflowState(t *int32) sharedv1.WorkflowState

func FromWorkflowType

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

func ToActivityType

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

func ToArchivalStatus

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

func ToBadBinaries

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

func ToBadBinaryInfo

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

func ToBadBinaryInfoMap

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

func ToDLQType

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

func ToDataBlob

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

func ToDataBlobArray

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

func ToDecision

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

func ToDecisionArray

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

func ToDescribeDomainResponseArray

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

func ToDescribeDomainResponseDomain

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

func ToDomainStatus

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

func ToEncodingType

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

func ToError

func ToError(err error) error

func ToEventID

func ToEventID(item *sharedv1.VersionHistoryItem) *int64

func ToEventVersion

func ToEventVersion(item *sharedv1.VersionHistoryItem) *int64

func ToExternalInitiatedID

func ToExternalInitiatedID(t *apiv1.ExternalExecutionInfo) *int64

func ToFailoverMarkerTokenArray

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

func ToFailureDetails

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

func ToFailureReason

func ToFailureReason(failure *apiv1.Failure) *string

func ToGetClusterInfoResponse

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

func ToHeader

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

func ToHealthResponse

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

func ToHistory

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

func ToHistoryEvent

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

func ToHistoryEventArray

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

func ToHostInfo

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

func ToHostInfoArray

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

func ToIndexedValueTypeMap

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

func ToMemo

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

func ToParentDomainID

func ToParentDomainID(pei *apiv1.ParentExecutionInfo) *string

func ToParentDomainName

func ToParentDomainName(pei *apiv1.ParentExecutionInfo) *string

func ToParentInitiatedID

func ToParentInitiatedID(pei *apiv1.ParentExecutionInfo) *int64

func ToParentWorkflowExecution

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

func ToPayload

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

func ToPayloadMap

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

func ToPendingActivityInfoArray

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

func ToPersistenceFeature added in v0.21.0

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

func ToPersistenceFeatures added in v0.21.0

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

func ToPersistenceInfo added in v0.21.0

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

func ToPersistenceInfoMap added in v0.21.0

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

func ToPersistenceSetting added in v0.21.0

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

func ToPersistenceSettings added in v0.21.0

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

func ToPollerInfo

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

func ToPollerInfoArray

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

func ToQueryRejected

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

func ToReplicationTaskArray

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

func ToReplicationTaskInfoArray

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

func ToReplicationTokenArray

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

func ToResetPointInfo

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

func ToResetPointInfoArray

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

func ToResetPoints

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

func ToRetryPolicy

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

func ToRingInfo

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

func ToRingInfoArray

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

func ToRunID

func ToRunID(t *apiv1.WorkflowExecution) string

func ToStartTimeFilter

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

func ToTaskIDBlock

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

func ToTaskList

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

func ToTaskListKind

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

func ToTaskListStatus

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

func ToTaskListType

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

func ToTaskSource

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

func ToTaskType

func ToTaskType(t sharedv1.TaskType) *int32

func ToTimeoutType

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

func ToVersionHistoryArray

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

func ToVersionHistoryItemArray

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

func ToWorkflowExecutionInfoArray

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

func ToWorkflowID

func ToWorkflowID(t *apiv1.WorkflowExecution) string

func ToWorkflowQuery

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

func ToWorkflowQueryMap

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

func ToWorkflowState

func ToWorkflowState(t sharedv1.WorkflowState) *int32

func ToWorkflowType

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

Types

This section is empty.

Jump to

Keyboard shortcuts

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