thrift

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: 8 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 *apiv1.ActivityType) *shared.ActivityType

func BadBinaries

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

func BadBinaryInfo

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

func BadBinaryInfoMap

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

func DataBlob

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

func DataBlobArray

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

func Decision

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

func DecisionArray

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

func DescribeDomainResponseArray

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

func DescribeDomainResponseDomain

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

func DomainStatus

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

func EncodingType

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

func Error

func Error(err error) error

func ExternalInitiatedId

func ExternalInitiatedId(t *apiv1.ExternalExecutionInfo) *int64

func FailureDetails

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

func FailureReason

func FailureReason(failure *apiv1.Failure) *string
func Header(t *apiv1.Header) *shared.Header

func History

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

func HistoryEvent

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

func HistoryEventArray

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

func Memo

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

func ParentDomainId

func ParentDomainId(pei *apiv1.ParentExecutionInfo) *string

func ParentDomainName

func ParentDomainName(pei *apiv1.ParentExecutionInfo) *string

func ParentInitiatedId

func ParentInitiatedId(pei *apiv1.ParentExecutionInfo) *int64

func ParentWorkflowExecution

func ParentWorkflowExecution(pei *apiv1.ParentExecutionInfo) *shared.WorkflowExecution

func Payload

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

func PayloadMap

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

func PendingActivityInfoArray

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

func PollerInfo

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

func PollerInfoArray

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

func QueryRejected

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

func ResetPointInfo

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

func ResetPointInfoArray

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

func ResetPoints

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

func RetryPolicy

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

func RunId

func RunId(t *apiv1.WorkflowExecution) *string

func TaskIdBlock

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

func TaskList

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

func TaskListKind

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

func TaskListStatus

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

func TaskListType

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

func TimeoutType

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

func WorkflowId

func WorkflowId(t *apiv1.WorkflowExecution) *string

func WorkflowQuery

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

func WorkflowQueryMap

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

func WorkflowType

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

Types

This section is empty.

Jump to

Keyboard shortcuts

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