proto

package
v1.2.9 Latest Latest
Warning

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

Go to latest
Published: Mar 1, 2024 License: MIT Imports: 7 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 ActivityType

func ActivityType(t *shared.ActivityType) *apiv1.ActivityType

func BadBinaries

func BadBinaries(t *shared.BadBinaries) *apiv1.BadBinaries

func BadBinaryInfo

func BadBinaryInfo(t *shared.BadBinaryInfo) *apiv1.BadBinaryInfo

func BadBinaryInfoMap

func BadBinaryInfoMap(t map[string]*shared.BadBinaryInfo) map[string]*apiv1.BadBinaryInfo

func DataBlob

func DataBlob(t *shared.DataBlob) *apiv1.DataBlob

func DataBlobArray

func DataBlobArray(t []*shared.DataBlob) []*apiv1.DataBlob

func Decision

func Decision(d *shared.Decision) *apiv1.Decision

func DecisionArray

func DecisionArray(t []*shared.Decision) []*apiv1.Decision

func DescribeDomainResponseArray

func DescribeDomainResponseArray(t []*shared.DescribeDomainResponse) []*apiv1.Domain

func DescribeDomainResponseDomain

func DescribeDomainResponseDomain(t *shared.DescribeDomainResponse) *apiv1.Domain

func DomainStatus

func DomainStatus(t *shared.DomainStatus) apiv1.DomainStatus

func EncodingType

func EncodingType(t *shared.EncodingType) apiv1.EncodingType

func Error

func Error(err error) error

func ExternalExecutionInfo

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

func Failure

func Failure(reason *string, details []byte) *apiv1.Failure
func Header(t *shared.Header) *apiv1.Header

func History

func History(t *shared.History) *apiv1.History

func HistoryEvent

func HistoryEvent(e *shared.HistoryEvent) *apiv1.HistoryEvent

func HistoryEventArray

func HistoryEventArray(t []*shared.HistoryEvent) []*apiv1.HistoryEvent

func Memo

func Memo(t *shared.Memo) *apiv1.Memo

func ParentExecutionInfo

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

func ParentExecutionInfo2

func ParentExecutionInfo2(domainID *string, we *shared.WorkflowExecution) *apiv1.ParentExecutionInfo

func Payload

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

func PayloadMap

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

func PendingActivityInfoArray

func PendingActivityInfoArray(t []*shared.PendingActivityInfo) []*apiv1.PendingActivityInfo

func PollerInfo

func PollerInfo(t *shared.PollerInfo) *apiv1.PollerInfo

func PollerInfoArray

func PollerInfoArray(t []*shared.PollerInfo) []*apiv1.PollerInfo

func QueryRejected

func QueryRejected(t *shared.QueryRejected) *apiv1.QueryRejected

func RefreshWorkflowTasksRequest added in v1.0.0

func ResetPointInfo

func ResetPointInfo(t *shared.ResetPointInfo) *apiv1.ResetPointInfo

func ResetPointInfoArray

func ResetPointInfoArray(t []*shared.ResetPointInfo) []*apiv1.ResetPointInfo

func ResetPoints

func ResetPoints(t *shared.ResetPoints) *apiv1.ResetPoints

func RetryPolicy

func RetryPolicy(t *shared.RetryPolicy) *apiv1.RetryPolicy

func TaskIdBlock

func TaskIdBlock(t *shared.TaskIDBlock) *apiv1.TaskIDBlock

func TaskList

func TaskList(t *shared.TaskList) *apiv1.TaskList

func TaskListKind

func TaskListKind(t *shared.TaskListKind) apiv1.TaskListKind

func TaskListStatus

func TaskListStatus(t *shared.TaskListStatus) *apiv1.TaskListStatus

func TaskListType

func TaskListType(t *shared.TaskListType) apiv1.TaskListType

func TimeoutType

func TimeoutType(t *shared.TimeoutType) apiv1.TimeoutType

func WorkflowQuery

func WorkflowQuery(t *shared.WorkflowQuery) *apiv1.WorkflowQuery

func WorkflowQueryMap

func WorkflowQueryMap(t map[string]*shared.WorkflowQuery) map[string]*apiv1.WorkflowQuery

func WorkflowRunPair

func WorkflowRunPair(workflowId, runId string) *apiv1.WorkflowExecution

func WorkflowType

func WorkflowType(t *shared.WorkflowType) *apiv1.WorkflowType

Types

This section is empty.

Jump to

Keyboard shortcuts

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