Documentation ¶
Overview ¶
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Index ¶
- Variables
- type ActivityPropertiesModifiedExternallyEventAttributes
- func (*ActivityPropertiesModifiedExternallyEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityPropertiesModifiedExternallyEventAttributes) Equal(that interface{}) bool
- func (x *ActivityPropertiesModifiedExternallyEventAttributes) GetNewRetryPolicy() *v1.RetryPolicy
- func (x *ActivityPropertiesModifiedExternallyEventAttributes) GetScheduledEventId() int64
- func (val *ActivityPropertiesModifiedExternallyEventAttributes) Marshal() ([]byte, error)
- func (*ActivityPropertiesModifiedExternallyEventAttributes) ProtoMessage()
- func (x *ActivityPropertiesModifiedExternallyEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityPropertiesModifiedExternallyEventAttributes) Reset()
- func (val *ActivityPropertiesModifiedExternallyEventAttributes) Size() int
- func (x *ActivityPropertiesModifiedExternallyEventAttributes) String() string
- func (val *ActivityPropertiesModifiedExternallyEventAttributes) Unmarshal(buf []byte) error
- type ActivityTaskCancelRequestedEventAttributes
- func (*ActivityTaskCancelRequestedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityTaskCancelRequestedEventAttributes) Equal(that interface{}) bool
- func (x *ActivityTaskCancelRequestedEventAttributes) GetScheduledEventId() int64
- func (x *ActivityTaskCancelRequestedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *ActivityTaskCancelRequestedEventAttributes) Marshal() ([]byte, error)
- func (*ActivityTaskCancelRequestedEventAttributes) ProtoMessage()
- func (x *ActivityTaskCancelRequestedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityTaskCancelRequestedEventAttributes) Reset()
- func (val *ActivityTaskCancelRequestedEventAttributes) Size() int
- func (x *ActivityTaskCancelRequestedEventAttributes) String() string
- func (val *ActivityTaskCancelRequestedEventAttributes) Unmarshal(buf []byte) error
- type ActivityTaskCanceledEventAttributes
- func (*ActivityTaskCanceledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityTaskCanceledEventAttributes) Equal(that interface{}) bool
- func (x *ActivityTaskCanceledEventAttributes) GetDetails() *v1.Payloads
- func (x *ActivityTaskCanceledEventAttributes) GetIdentity() string
- func (x *ActivityTaskCanceledEventAttributes) GetLatestCancelRequestedEventId() int64
- func (x *ActivityTaskCanceledEventAttributes) GetScheduledEventId() int64
- func (x *ActivityTaskCanceledEventAttributes) GetStartedEventId() int64
- func (x *ActivityTaskCanceledEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
- func (val *ActivityTaskCanceledEventAttributes) Marshal() ([]byte, error)
- func (*ActivityTaskCanceledEventAttributes) ProtoMessage()
- func (x *ActivityTaskCanceledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityTaskCanceledEventAttributes) Reset()
- func (val *ActivityTaskCanceledEventAttributes) Size() int
- func (x *ActivityTaskCanceledEventAttributes) String() string
- func (val *ActivityTaskCanceledEventAttributes) Unmarshal(buf []byte) error
- type ActivityTaskCompletedEventAttributes
- func (*ActivityTaskCompletedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityTaskCompletedEventAttributes) Equal(that interface{}) bool
- func (x *ActivityTaskCompletedEventAttributes) GetIdentity() string
- func (x *ActivityTaskCompletedEventAttributes) GetResult() *v1.Payloads
- func (x *ActivityTaskCompletedEventAttributes) GetScheduledEventId() int64
- func (x *ActivityTaskCompletedEventAttributes) GetStartedEventId() int64
- func (x *ActivityTaskCompletedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
- func (val *ActivityTaskCompletedEventAttributes) Marshal() ([]byte, error)
- func (*ActivityTaskCompletedEventAttributes) ProtoMessage()
- func (x *ActivityTaskCompletedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityTaskCompletedEventAttributes) Reset()
- func (val *ActivityTaskCompletedEventAttributes) Size() int
- func (x *ActivityTaskCompletedEventAttributes) String() string
- func (val *ActivityTaskCompletedEventAttributes) Unmarshal(buf []byte) error
- type ActivityTaskFailedEventAttributes
- func (*ActivityTaskFailedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityTaskFailedEventAttributes) Equal(that interface{}) bool
- func (x *ActivityTaskFailedEventAttributes) GetFailure() *v13.Failure
- func (x *ActivityTaskFailedEventAttributes) GetIdentity() string
- func (x *ActivityTaskFailedEventAttributes) GetRetryState() v12.RetryState
- func (x *ActivityTaskFailedEventAttributes) GetScheduledEventId() int64
- func (x *ActivityTaskFailedEventAttributes) GetStartedEventId() int64
- func (x *ActivityTaskFailedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
- func (val *ActivityTaskFailedEventAttributes) Marshal() ([]byte, error)
- func (*ActivityTaskFailedEventAttributes) ProtoMessage()
- func (x *ActivityTaskFailedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityTaskFailedEventAttributes) Reset()
- func (val *ActivityTaskFailedEventAttributes) Size() int
- func (x *ActivityTaskFailedEventAttributes) String() string
- func (val *ActivityTaskFailedEventAttributes) Unmarshal(buf []byte) error
- type ActivityTaskScheduledEventAttributes
- func (*ActivityTaskScheduledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityTaskScheduledEventAttributes) Equal(that interface{}) bool
- func (x *ActivityTaskScheduledEventAttributes) GetActivityId() string
- func (x *ActivityTaskScheduledEventAttributes) GetActivityType() *v1.ActivityType
- func (x *ActivityTaskScheduledEventAttributes) GetHeader() *v1.Header
- func (x *ActivityTaskScheduledEventAttributes) GetHeartbeatTimeout() *durationpb.Duration
- func (x *ActivityTaskScheduledEventAttributes) GetInput() *v1.Payloads
- func (x *ActivityTaskScheduledEventAttributes) GetRetryPolicy() *v1.RetryPolicy
- func (x *ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeout() *durationpb.Duration
- func (x *ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeout() *durationpb.Duration
- func (x *ActivityTaskScheduledEventAttributes) GetStartToCloseTimeout() *durationpb.Duration
- func (x *ActivityTaskScheduledEventAttributes) GetTaskQueue() *v11.TaskQueue
- func (x *ActivityTaskScheduledEventAttributes) GetUseCompatibleVersion() bool
- func (x *ActivityTaskScheduledEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *ActivityTaskScheduledEventAttributes) Marshal() ([]byte, error)
- func (*ActivityTaskScheduledEventAttributes) ProtoMessage()
- func (x *ActivityTaskScheduledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityTaskScheduledEventAttributes) Reset()
- func (val *ActivityTaskScheduledEventAttributes) Size() int
- func (x *ActivityTaskScheduledEventAttributes) String() string
- func (val *ActivityTaskScheduledEventAttributes) Unmarshal(buf []byte) error
- type ActivityTaskStartedEventAttributes
- func (*ActivityTaskStartedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityTaskStartedEventAttributes) Equal(that interface{}) bool
- func (x *ActivityTaskStartedEventAttributes) GetAttempt() int32
- func (x *ActivityTaskStartedEventAttributes) GetIdentity() string
- func (x *ActivityTaskStartedEventAttributes) GetLastFailure() *v13.Failure
- func (x *ActivityTaskStartedEventAttributes) GetRequestId() string
- func (x *ActivityTaskStartedEventAttributes) GetScheduledEventId() int64
- func (val *ActivityTaskStartedEventAttributes) Marshal() ([]byte, error)
- func (*ActivityTaskStartedEventAttributes) ProtoMessage()
- func (x *ActivityTaskStartedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityTaskStartedEventAttributes) Reset()
- func (val *ActivityTaskStartedEventAttributes) Size() int
- func (x *ActivityTaskStartedEventAttributes) String() string
- func (val *ActivityTaskStartedEventAttributes) Unmarshal(buf []byte) error
- type ActivityTaskTimedOutEventAttributes
- func (*ActivityTaskTimedOutEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ActivityTaskTimedOutEventAttributes) Equal(that interface{}) bool
- func (x *ActivityTaskTimedOutEventAttributes) GetFailure() *v13.Failure
- func (x *ActivityTaskTimedOutEventAttributes) GetRetryState() v12.RetryState
- func (x *ActivityTaskTimedOutEventAttributes) GetScheduledEventId() int64
- func (x *ActivityTaskTimedOutEventAttributes) GetStartedEventId() int64
- func (val *ActivityTaskTimedOutEventAttributes) Marshal() ([]byte, error)
- func (*ActivityTaskTimedOutEventAttributes) ProtoMessage()
- func (x *ActivityTaskTimedOutEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ActivityTaskTimedOutEventAttributes) Reset()
- func (val *ActivityTaskTimedOutEventAttributes) Size() int
- func (x *ActivityTaskTimedOutEventAttributes) String() string
- func (val *ActivityTaskTimedOutEventAttributes) Unmarshal(buf []byte) error
- type ChildWorkflowExecutionCanceledEventAttributes
- func (*ChildWorkflowExecutionCanceledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ChildWorkflowExecutionCanceledEventAttributes) Equal(that interface{}) bool
- func (x *ChildWorkflowExecutionCanceledEventAttributes) GetDetails() *v1.Payloads
- func (x *ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventId() int64
- func (x *ChildWorkflowExecutionCanceledEventAttributes) GetNamespace() string
- func (x *ChildWorkflowExecutionCanceledEventAttributes) GetNamespaceId() string
- func (x *ChildWorkflowExecutionCanceledEventAttributes) GetStartedEventId() int64
- func (x *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *ChildWorkflowExecutionCanceledEventAttributes) Marshal() ([]byte, error)
- func (*ChildWorkflowExecutionCanceledEventAttributes) ProtoMessage()
- func (x *ChildWorkflowExecutionCanceledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowExecutionCanceledEventAttributes) Reset()
- func (val *ChildWorkflowExecutionCanceledEventAttributes) Size() int
- func (x *ChildWorkflowExecutionCanceledEventAttributes) String() string
- func (val *ChildWorkflowExecutionCanceledEventAttributes) Unmarshal(buf []byte) error
- type ChildWorkflowExecutionCompletedEventAttributes
- func (*ChildWorkflowExecutionCompletedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ChildWorkflowExecutionCompletedEventAttributes) Equal(that interface{}) bool
- func (x *ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventId() int64
- func (x *ChildWorkflowExecutionCompletedEventAttributes) GetNamespace() string
- func (x *ChildWorkflowExecutionCompletedEventAttributes) GetNamespaceId() string
- func (x *ChildWorkflowExecutionCompletedEventAttributes) GetResult() *v1.Payloads
- func (x *ChildWorkflowExecutionCompletedEventAttributes) GetStartedEventId() int64
- func (x *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *ChildWorkflowExecutionCompletedEventAttributes) Marshal() ([]byte, error)
- func (*ChildWorkflowExecutionCompletedEventAttributes) ProtoMessage()
- func (x *ChildWorkflowExecutionCompletedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowExecutionCompletedEventAttributes) Reset()
- func (val *ChildWorkflowExecutionCompletedEventAttributes) Size() int
- func (x *ChildWorkflowExecutionCompletedEventAttributes) String() string
- func (val *ChildWorkflowExecutionCompletedEventAttributes) Unmarshal(buf []byte) error
- type ChildWorkflowExecutionFailedEventAttributes
- func (*ChildWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ChildWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetFailure() *v13.Failure
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetNamespace() string
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetRetryState() v12.RetryState
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetStartedEventId() int64
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *ChildWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
- func (*ChildWorkflowExecutionFailedEventAttributes) ProtoMessage()
- func (x *ChildWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowExecutionFailedEventAttributes) Reset()
- func (val *ChildWorkflowExecutionFailedEventAttributes) Size() int
- func (x *ChildWorkflowExecutionFailedEventAttributes) String() string
- func (val *ChildWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
- type ChildWorkflowExecutionStartedEventAttributes
- func (*ChildWorkflowExecutionStartedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ChildWorkflowExecutionStartedEventAttributes) Equal(that interface{}) bool
- func (x *ChildWorkflowExecutionStartedEventAttributes) GetHeader() *v1.Header
- func (x *ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventId() int64
- func (x *ChildWorkflowExecutionStartedEventAttributes) GetNamespace() string
- func (x *ChildWorkflowExecutionStartedEventAttributes) GetNamespaceId() string
- func (x *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *ChildWorkflowExecutionStartedEventAttributes) Marshal() ([]byte, error)
- func (*ChildWorkflowExecutionStartedEventAttributes) ProtoMessage()
- func (x *ChildWorkflowExecutionStartedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowExecutionStartedEventAttributes) Reset()
- func (val *ChildWorkflowExecutionStartedEventAttributes) Size() int
- func (x *ChildWorkflowExecutionStartedEventAttributes) String() string
- func (val *ChildWorkflowExecutionStartedEventAttributes) Unmarshal(buf []byte) error
- type ChildWorkflowExecutionTerminatedEventAttributes
- func (*ChildWorkflowExecutionTerminatedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ChildWorkflowExecutionTerminatedEventAttributes) Equal(that interface{}) bool
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventId() int64
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetNamespace() string
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetNamespaceId() string
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetStartedEventId() int64
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *ChildWorkflowExecutionTerminatedEventAttributes) Marshal() ([]byte, error)
- func (*ChildWorkflowExecutionTerminatedEventAttributes) ProtoMessage()
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) Reset()
- func (val *ChildWorkflowExecutionTerminatedEventAttributes) Size() int
- func (x *ChildWorkflowExecutionTerminatedEventAttributes) String() string
- func (val *ChildWorkflowExecutionTerminatedEventAttributes) Unmarshal(buf []byte) error
- type ChildWorkflowExecutionTimedOutEventAttributes
- func (*ChildWorkflowExecutionTimedOutEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ChildWorkflowExecutionTimedOutEventAttributes) Equal(that interface{}) bool
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventId() int64
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetNamespace() string
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetNamespaceId() string
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetRetryState() v12.RetryState
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetStartedEventId() int64
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *ChildWorkflowExecutionTimedOutEventAttributes) Marshal() ([]byte, error)
- func (*ChildWorkflowExecutionTimedOutEventAttributes) ProtoMessage()
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) Reset()
- func (val *ChildWorkflowExecutionTimedOutEventAttributes) Size() int
- func (x *ChildWorkflowExecutionTimedOutEventAttributes) String() string
- func (val *ChildWorkflowExecutionTimedOutEventAttributes) Unmarshal(buf []byte) error
- type ExternalWorkflowExecutionCancelRequestedEventAttributes
- func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ExternalWorkflowExecutionCancelRequestedEventAttributes) Equal(that interface{}) bool
- func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetInitiatedEventId() int64
- func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetNamespace() string
- func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetNamespaceId() string
- func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (val *ExternalWorkflowExecutionCancelRequestedEventAttributes) Marshal() ([]byte, error)
- func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) ProtoMessage()
- func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) Reset()
- func (val *ExternalWorkflowExecutionCancelRequestedEventAttributes) Size() int
- func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) String() string
- func (val *ExternalWorkflowExecutionCancelRequestedEventAttributes) Unmarshal(buf []byte) error
- type ExternalWorkflowExecutionSignaledEventAttributes
- func (*ExternalWorkflowExecutionSignaledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *ExternalWorkflowExecutionSignaledEventAttributes) Equal(that interface{}) bool
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetControl() string
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetInitiatedEventId() int64
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetNamespace() string
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetNamespaceId() string
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (val *ExternalWorkflowExecutionSignaledEventAttributes) Marshal() ([]byte, error)
- func (*ExternalWorkflowExecutionSignaledEventAttributes) ProtoMessage()
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) Reset()
- func (val *ExternalWorkflowExecutionSignaledEventAttributes) Size() int
- func (x *ExternalWorkflowExecutionSignaledEventAttributes) String() string
- func (val *ExternalWorkflowExecutionSignaledEventAttributes) Unmarshal(buf []byte) error
- type History
- func (*History) Descriptor() ([]byte, []int)deprecated
- func (this *History) Equal(that interface{}) bool
- func (x *History) GetEvents() []*HistoryEvent
- func (val *History) Marshal() ([]byte, error)
- func (*History) ProtoMessage()
- func (x *History) ProtoReflect() protoreflect.Message
- func (x *History) Reset()
- func (val *History) Size() int
- func (x *History) String() string
- func (val *History) Unmarshal(buf []byte) error
- type HistoryEvent
- func (*HistoryEvent) Descriptor() ([]byte, []int)deprecated
- func (this *HistoryEvent) Equal(that interface{}) bool
- func (x *HistoryEvent) GetActivityPropertiesModifiedExternallyEventAttributes() *ActivityPropertiesModifiedExternallyEventAttributes
- func (x *HistoryEvent) GetActivityTaskCancelRequestedEventAttributes() *ActivityTaskCancelRequestedEventAttributes
- func (x *HistoryEvent) GetActivityTaskCanceledEventAttributes() *ActivityTaskCanceledEventAttributes
- func (x *HistoryEvent) GetActivityTaskCompletedEventAttributes() *ActivityTaskCompletedEventAttributes
- func (x *HistoryEvent) GetActivityTaskFailedEventAttributes() *ActivityTaskFailedEventAttributes
- func (x *HistoryEvent) GetActivityTaskScheduledEventAttributes() *ActivityTaskScheduledEventAttributes
- func (x *HistoryEvent) GetActivityTaskStartedEventAttributes() *ActivityTaskStartedEventAttributes
- func (x *HistoryEvent) GetActivityTaskTimedOutEventAttributes() *ActivityTaskTimedOutEventAttributes
- func (m *HistoryEvent) GetAttributes() isHistoryEvent_Attributes
- func (x *HistoryEvent) GetChildWorkflowExecutionCanceledEventAttributes() *ChildWorkflowExecutionCanceledEventAttributes
- func (x *HistoryEvent) GetChildWorkflowExecutionCompletedEventAttributes() *ChildWorkflowExecutionCompletedEventAttributes
- func (x *HistoryEvent) GetChildWorkflowExecutionFailedEventAttributes() *ChildWorkflowExecutionFailedEventAttributes
- func (x *HistoryEvent) GetChildWorkflowExecutionStartedEventAttributes() *ChildWorkflowExecutionStartedEventAttributes
- func (x *HistoryEvent) GetChildWorkflowExecutionTerminatedEventAttributes() *ChildWorkflowExecutionTerminatedEventAttributes
- func (x *HistoryEvent) GetChildWorkflowExecutionTimedOutEventAttributes() *ChildWorkflowExecutionTimedOutEventAttributes
- func (x *HistoryEvent) GetEventId() int64
- func (x *HistoryEvent) GetEventTime() *timestamppb.Timestamp
- func (x *HistoryEvent) GetEventType() v12.EventType
- func (x *HistoryEvent) GetExternalWorkflowExecutionCancelRequestedEventAttributes() *ExternalWorkflowExecutionCancelRequestedEventAttributes
- func (x *HistoryEvent) GetExternalWorkflowExecutionSignaledEventAttributes() *ExternalWorkflowExecutionSignaledEventAttributes
- func (x *HistoryEvent) GetMarkerRecordedEventAttributes() *MarkerRecordedEventAttributes
- func (x *HistoryEvent) GetRequestCancelExternalWorkflowExecutionFailedEventAttributes() *RequestCancelExternalWorkflowExecutionFailedEventAttributes
- func (x *HistoryEvent) GetRequestCancelExternalWorkflowExecutionInitiatedEventAttributes() *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
- func (x *HistoryEvent) GetSignalExternalWorkflowExecutionFailedEventAttributes() *SignalExternalWorkflowExecutionFailedEventAttributes
- func (x *HistoryEvent) GetSignalExternalWorkflowExecutionInitiatedEventAttributes() *SignalExternalWorkflowExecutionInitiatedEventAttributes
- func (x *HistoryEvent) GetStartChildWorkflowExecutionFailedEventAttributes() *StartChildWorkflowExecutionFailedEventAttributes
- func (x *HistoryEvent) GetStartChildWorkflowExecutionInitiatedEventAttributes() *StartChildWorkflowExecutionInitiatedEventAttributes
- func (x *HistoryEvent) GetTaskId() int64
- func (x *HistoryEvent) GetTimerCanceledEventAttributes() *TimerCanceledEventAttributes
- func (x *HistoryEvent) GetTimerFiredEventAttributes() *TimerFiredEventAttributes
- func (x *HistoryEvent) GetTimerStartedEventAttributes() *TimerStartedEventAttributes
- func (x *HistoryEvent) GetUpsertWorkflowSearchAttributesEventAttributes() *UpsertWorkflowSearchAttributesEventAttributes
- func (x *HistoryEvent) GetVersion() int64
- func (x *HistoryEvent) GetWorkerMayIgnore() bool
- func (x *HistoryEvent) GetWorkflowExecutionCancelRequestedEventAttributes() *WorkflowExecutionCancelRequestedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionCanceledEventAttributes() *WorkflowExecutionCanceledEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionCompletedEventAttributes() *WorkflowExecutionCompletedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionContinuedAsNewEventAttributes() *WorkflowExecutionContinuedAsNewEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionFailedEventAttributes() *WorkflowExecutionFailedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionSignaledEventAttributes() *WorkflowExecutionSignaledEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionStartedEventAttributes() *WorkflowExecutionStartedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionTerminatedEventAttributes() *WorkflowExecutionTerminatedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionTimedOutEventAttributes() *WorkflowExecutionTimedOutEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionUpdateAcceptedEventAttributes() *WorkflowExecutionUpdateAcceptedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionUpdateCompletedEventAttributes() *WorkflowExecutionUpdateCompletedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionUpdateRejectedEventAttributes() *WorkflowExecutionUpdateRejectedEventAttributes
- func (x *HistoryEvent) GetWorkflowExecutionUpdateRequestedEventAttributes() *WorkflowExecutionUpdateRequestedEventAttributes
- func (x *HistoryEvent) GetWorkflowPropertiesModifiedEventAttributes() *WorkflowPropertiesModifiedEventAttributes
- func (x *HistoryEvent) GetWorkflowPropertiesModifiedExternallyEventAttributes() *WorkflowPropertiesModifiedExternallyEventAttributes
- func (x *HistoryEvent) GetWorkflowTaskCompletedEventAttributes() *WorkflowTaskCompletedEventAttributes
- func (x *HistoryEvent) GetWorkflowTaskFailedEventAttributes() *WorkflowTaskFailedEventAttributes
- func (x *HistoryEvent) GetWorkflowTaskScheduledEventAttributes() *WorkflowTaskScheduledEventAttributes
- func (x *HistoryEvent) GetWorkflowTaskStartedEventAttributes() *WorkflowTaskStartedEventAttributes
- func (x *HistoryEvent) GetWorkflowTaskTimedOutEventAttributes() *WorkflowTaskTimedOutEventAttributes
- func (val *HistoryEvent) Marshal() ([]byte, error)
- func (*HistoryEvent) ProtoMessage()
- func (x *HistoryEvent) ProtoReflect() protoreflect.Message
- func (x *HistoryEvent) Reset()
- func (val *HistoryEvent) Size() int
- func (x *HistoryEvent) String() string
- func (val *HistoryEvent) Unmarshal(buf []byte) error
- type HistoryEvent_ActivityPropertiesModifiedExternallyEventAttributes
- type HistoryEvent_ActivityTaskCancelRequestedEventAttributes
- type HistoryEvent_ActivityTaskCanceledEventAttributes
- type HistoryEvent_ActivityTaskCompletedEventAttributes
- type HistoryEvent_ActivityTaskFailedEventAttributes
- type HistoryEvent_ActivityTaskScheduledEventAttributes
- type HistoryEvent_ActivityTaskStartedEventAttributes
- type HistoryEvent_ActivityTaskTimedOutEventAttributes
- type HistoryEvent_ChildWorkflowExecutionCanceledEventAttributes
- type HistoryEvent_ChildWorkflowExecutionCompletedEventAttributes
- type HistoryEvent_ChildWorkflowExecutionFailedEventAttributes
- type HistoryEvent_ChildWorkflowExecutionStartedEventAttributes
- type HistoryEvent_ChildWorkflowExecutionTerminatedEventAttributes
- type HistoryEvent_ChildWorkflowExecutionTimedOutEventAttributes
- type HistoryEvent_ExternalWorkflowExecutionCancelRequestedEventAttributes
- type HistoryEvent_ExternalWorkflowExecutionSignaledEventAttributes
- type HistoryEvent_MarkerRecordedEventAttributes
- type HistoryEvent_RequestCancelExternalWorkflowExecutionFailedEventAttributes
- type HistoryEvent_RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
- type HistoryEvent_SignalExternalWorkflowExecutionFailedEventAttributes
- type HistoryEvent_SignalExternalWorkflowExecutionInitiatedEventAttributes
- type HistoryEvent_StartChildWorkflowExecutionFailedEventAttributes
- type HistoryEvent_StartChildWorkflowExecutionInitiatedEventAttributes
- type HistoryEvent_TimerCanceledEventAttributes
- type HistoryEvent_TimerFiredEventAttributes
- type HistoryEvent_TimerStartedEventAttributes
- type HistoryEvent_UpsertWorkflowSearchAttributesEventAttributes
- type HistoryEvent_WorkflowExecutionCancelRequestedEventAttributes
- type HistoryEvent_WorkflowExecutionCanceledEventAttributes
- type HistoryEvent_WorkflowExecutionCompletedEventAttributes
- type HistoryEvent_WorkflowExecutionContinuedAsNewEventAttributes
- type HistoryEvent_WorkflowExecutionFailedEventAttributes
- type HistoryEvent_WorkflowExecutionSignaledEventAttributes
- type HistoryEvent_WorkflowExecutionStartedEventAttributes
- type HistoryEvent_WorkflowExecutionTerminatedEventAttributes
- type HistoryEvent_WorkflowExecutionTimedOutEventAttributes
- type HistoryEvent_WorkflowExecutionUpdateAcceptedEventAttributes
- type HistoryEvent_WorkflowExecutionUpdateCompletedEventAttributes
- type HistoryEvent_WorkflowExecutionUpdateRejectedEventAttributes
- type HistoryEvent_WorkflowExecutionUpdateRequestedEventAttributes
- type HistoryEvent_WorkflowPropertiesModifiedEventAttributes
- type HistoryEvent_WorkflowPropertiesModifiedExternallyEventAttributes
- type HistoryEvent_WorkflowTaskCompletedEventAttributes
- type HistoryEvent_WorkflowTaskFailedEventAttributes
- type HistoryEvent_WorkflowTaskScheduledEventAttributes
- type HistoryEvent_WorkflowTaskStartedEventAttributes
- type HistoryEvent_WorkflowTaskTimedOutEventAttributes
- type MarkerRecordedEventAttributes
- func (*MarkerRecordedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *MarkerRecordedEventAttributes) Equal(that interface{}) bool
- func (x *MarkerRecordedEventAttributes) GetDetails() map[string]*v1.Payloads
- func (x *MarkerRecordedEventAttributes) GetFailure() *v13.Failure
- func (x *MarkerRecordedEventAttributes) GetHeader() *v1.Header
- func (x *MarkerRecordedEventAttributes) GetMarkerName() string
- func (x *MarkerRecordedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *MarkerRecordedEventAttributes) Marshal() ([]byte, error)
- func (*MarkerRecordedEventAttributes) ProtoMessage()
- func (x *MarkerRecordedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *MarkerRecordedEventAttributes) Reset()
- func (val *MarkerRecordedEventAttributes) Size() int
- func (x *MarkerRecordedEventAttributes) String() string
- func (val *MarkerRecordedEventAttributes) Unmarshal(buf []byte) error
- type RequestCancelExternalWorkflowExecutionFailedEventAttributes
- func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetCause() v12.CancelExternalWorkflowExecutionFailedCause
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetControl() string
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetNamespace() string
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
- func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) ProtoMessage()
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Reset()
- func (val *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Size() int
- func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) String() string
- func (val *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
- type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
- func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Equal(that interface{}) bool
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() bool
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetControl() string
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetNamespace() string
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetNamespaceId() string
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetReason() string
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Marshal() ([]byte, error)
- func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) ProtoMessage()
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Reset()
- func (val *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Size() int
- func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) String() string
- func (val *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Unmarshal(buf []byte) error
- type SignalExternalWorkflowExecutionFailedEventAttributes
- func (*SignalExternalWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *SignalExternalWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetCause() v12.SignalExternalWorkflowExecutionFailedCause
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetControl() string
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetNamespace() string
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *SignalExternalWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
- func (*SignalExternalWorkflowExecutionFailedEventAttributes) ProtoMessage()
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) Reset()
- func (val *SignalExternalWorkflowExecutionFailedEventAttributes) Size() int
- func (x *SignalExternalWorkflowExecutionFailedEventAttributes) String() string
- func (val *SignalExternalWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
- type SignalExternalWorkflowExecutionInitiatedEventAttributes
- func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *SignalExternalWorkflowExecutionInitiatedEventAttributes) Equal(that interface{}) bool
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() bool
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetControl() string
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetHeader() *v1.Header
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetInput() *v1.Payloads
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetNamespace() string
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetNamespaceId() string
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetSignalName() string
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *SignalExternalWorkflowExecutionInitiatedEventAttributes) Marshal() ([]byte, error)
- func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) ProtoMessage()
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) Reset()
- func (val *SignalExternalWorkflowExecutionInitiatedEventAttributes) Size() int
- func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) String() string
- func (val *SignalExternalWorkflowExecutionInitiatedEventAttributes) Unmarshal(buf []byte) error
- type StartChildWorkflowExecutionFailedEventAttributes
- func (*StartChildWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *StartChildWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetCause() v12.StartChildWorkflowExecutionFailedCause
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetControl() string
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetNamespace() string
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowId() string
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (x *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *StartChildWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
- func (*StartChildWorkflowExecutionFailedEventAttributes) ProtoMessage()
- func (x *StartChildWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *StartChildWorkflowExecutionFailedEventAttributes) Reset()
- func (val *StartChildWorkflowExecutionFailedEventAttributes) Size() int
- func (x *StartChildWorkflowExecutionFailedEventAttributes) String() string
- func (val *StartChildWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
- type StartChildWorkflowExecutionInitiatedEventAttributes
- func (*StartChildWorkflowExecutionInitiatedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *StartChildWorkflowExecutionInitiatedEventAttributes) Equal(that interface{}) bool
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetControl() string
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetCronSchedule() string
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetHeader() *v1.Header
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetInput() *v1.Payloads
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetMemo() *v1.Memo
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetNamespace() string
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetNamespaceId() string
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetParentClosePolicy() v12.ParentClosePolicy
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetRetryPolicy() *v1.RetryPolicy
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetSearchAttributes() *v1.SearchAttributes
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetTaskQueue() *v11.TaskQueue
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetUseCompatibleVersion() bool
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecutionTimeout() *durationpb.Duration
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowId() string
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowIdReusePolicy() v12.WorkflowIdReusePolicy
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowRunTimeout() *durationpb.Duration
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskTimeout() *durationpb.Duration
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *StartChildWorkflowExecutionInitiatedEventAttributes) Marshal() ([]byte, error)
- func (*StartChildWorkflowExecutionInitiatedEventAttributes) ProtoMessage()
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) Reset()
- func (val *StartChildWorkflowExecutionInitiatedEventAttributes) Size() int
- func (x *StartChildWorkflowExecutionInitiatedEventAttributes) String() string
- func (val *StartChildWorkflowExecutionInitiatedEventAttributes) Unmarshal(buf []byte) error
- type TimerCanceledEventAttributes
- func (*TimerCanceledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *TimerCanceledEventAttributes) Equal(that interface{}) bool
- func (x *TimerCanceledEventAttributes) GetIdentity() string
- func (x *TimerCanceledEventAttributes) GetStartedEventId() int64
- func (x *TimerCanceledEventAttributes) GetTimerId() string
- func (x *TimerCanceledEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *TimerCanceledEventAttributes) Marshal() ([]byte, error)
- func (*TimerCanceledEventAttributes) ProtoMessage()
- func (x *TimerCanceledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *TimerCanceledEventAttributes) Reset()
- func (val *TimerCanceledEventAttributes) Size() int
- func (x *TimerCanceledEventAttributes) String() string
- func (val *TimerCanceledEventAttributes) Unmarshal(buf []byte) error
- type TimerFiredEventAttributes
- func (*TimerFiredEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *TimerFiredEventAttributes) Equal(that interface{}) bool
- func (x *TimerFiredEventAttributes) GetStartedEventId() int64
- func (x *TimerFiredEventAttributes) GetTimerId() string
- func (val *TimerFiredEventAttributes) Marshal() ([]byte, error)
- func (*TimerFiredEventAttributes) ProtoMessage()
- func (x *TimerFiredEventAttributes) ProtoReflect() protoreflect.Message
- func (x *TimerFiredEventAttributes) Reset()
- func (val *TimerFiredEventAttributes) Size() int
- func (x *TimerFiredEventAttributes) String() string
- func (val *TimerFiredEventAttributes) Unmarshal(buf []byte) error
- type TimerStartedEventAttributes
- func (*TimerStartedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *TimerStartedEventAttributes) Equal(that interface{}) bool
- func (x *TimerStartedEventAttributes) GetStartToFireTimeout() *durationpb.Duration
- func (x *TimerStartedEventAttributes) GetTimerId() string
- func (x *TimerStartedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *TimerStartedEventAttributes) Marshal() ([]byte, error)
- func (*TimerStartedEventAttributes) ProtoMessage()
- func (x *TimerStartedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *TimerStartedEventAttributes) Reset()
- func (val *TimerStartedEventAttributes) Size() int
- func (x *TimerStartedEventAttributes) String() string
- func (val *TimerStartedEventAttributes) Unmarshal(buf []byte) error
- type UpsertWorkflowSearchAttributesEventAttributes
- func (*UpsertWorkflowSearchAttributesEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *UpsertWorkflowSearchAttributesEventAttributes) Equal(that interface{}) bool
- func (x *UpsertWorkflowSearchAttributesEventAttributes) GetSearchAttributes() *v1.SearchAttributes
- func (x *UpsertWorkflowSearchAttributesEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *UpsertWorkflowSearchAttributesEventAttributes) Marshal() ([]byte, error)
- func (*UpsertWorkflowSearchAttributesEventAttributes) ProtoMessage()
- func (x *UpsertWorkflowSearchAttributesEventAttributes) ProtoReflect() protoreflect.Message
- func (x *UpsertWorkflowSearchAttributesEventAttributes) Reset()
- func (val *UpsertWorkflowSearchAttributesEventAttributes) Size() int
- func (x *UpsertWorkflowSearchAttributesEventAttributes) String() string
- func (val *UpsertWorkflowSearchAttributesEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionCancelRequestedEventAttributes
- func (*WorkflowExecutionCancelRequestedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionCancelRequestedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionCancelRequestedEventAttributes) GetCause() string
- func (x *WorkflowExecutionCancelRequestedEventAttributes) GetExternalInitiatedEventId() int64
- func (x *WorkflowExecutionCancelRequestedEventAttributes) GetExternalWorkflowExecution() *v1.WorkflowExecution
- func (x *WorkflowExecutionCancelRequestedEventAttributes) GetIdentity() string
- func (val *WorkflowExecutionCancelRequestedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionCancelRequestedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionCancelRequestedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionCancelRequestedEventAttributes) Reset()
- func (val *WorkflowExecutionCancelRequestedEventAttributes) Size() int
- func (x *WorkflowExecutionCancelRequestedEventAttributes) String() string
- func (val *WorkflowExecutionCancelRequestedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionCanceledEventAttributes
- func (*WorkflowExecutionCanceledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionCanceledEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionCanceledEventAttributes) GetDetails() *v1.Payloads
- func (x *WorkflowExecutionCanceledEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *WorkflowExecutionCanceledEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionCanceledEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionCanceledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionCanceledEventAttributes) Reset()
- func (val *WorkflowExecutionCanceledEventAttributes) Size() int
- func (x *WorkflowExecutionCanceledEventAttributes) String() string
- func (val *WorkflowExecutionCanceledEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionCompletedEventAttributes
- func (*WorkflowExecutionCompletedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionCompletedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionCompletedEventAttributes) GetNewExecutionRunId() string
- func (x *WorkflowExecutionCompletedEventAttributes) GetResult() *v1.Payloads
- func (x *WorkflowExecutionCompletedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *WorkflowExecutionCompletedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionCompletedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionCompletedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionCompletedEventAttributes) Reset()
- func (val *WorkflowExecutionCompletedEventAttributes) Size() int
- func (x *WorkflowExecutionCompletedEventAttributes) String() string
- func (val *WorkflowExecutionCompletedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionContinuedAsNewEventAttributes
- func (*WorkflowExecutionContinuedAsNewEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionContinuedAsNewEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetBackoffStartInterval() *durationpb.Duration
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetFailure() *v13.Failure
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetHeader() *v1.Header
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetInitiator() v12.ContinueAsNewInitiator
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetInput() *v1.Payloads
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetLastCompletionResult() *v1.Payloads
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetMemo() *v1.Memo
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetNewExecutionRunId() string
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetSearchAttributes() *v1.SearchAttributes
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetTaskQueue() *v11.TaskQueue
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetUseCompatibleVersion() bool
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowRunTimeout() *durationpb.Duration
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowTaskTimeout() *durationpb.Duration
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *WorkflowExecutionContinuedAsNewEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionContinuedAsNewEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) Reset()
- func (val *WorkflowExecutionContinuedAsNewEventAttributes) Size() int
- func (x *WorkflowExecutionContinuedAsNewEventAttributes) String() string
- func (val *WorkflowExecutionContinuedAsNewEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionFailedEventAttributes
- func (*WorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionFailedEventAttributes) GetFailure() *v13.Failure
- func (x *WorkflowExecutionFailedEventAttributes) GetNewExecutionRunId() string
- func (x *WorkflowExecutionFailedEventAttributes) GetRetryState() v12.RetryState
- func (x *WorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *WorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionFailedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionFailedEventAttributes) Reset()
- func (val *WorkflowExecutionFailedEventAttributes) Size() int
- func (x *WorkflowExecutionFailedEventAttributes) String() string
- func (val *WorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionSignaledEventAttributes
- func (*WorkflowExecutionSignaledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionSignaledEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionSignaledEventAttributes) GetExternalWorkflowExecution() *v1.WorkflowExecution
- func (x *WorkflowExecutionSignaledEventAttributes) GetHeader() *v1.Header
- func (x *WorkflowExecutionSignaledEventAttributes) GetIdentity() string
- func (x *WorkflowExecutionSignaledEventAttributes) GetInput() *v1.Payloads
- func (x *WorkflowExecutionSignaledEventAttributes) GetSignalName() string
- func (x *WorkflowExecutionSignaledEventAttributes) GetSkipGenerateWorkflowTask() bool
- func (val *WorkflowExecutionSignaledEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionSignaledEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionSignaledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionSignaledEventAttributes) Reset()
- func (val *WorkflowExecutionSignaledEventAttributes) Size() int
- func (x *WorkflowExecutionSignaledEventAttributes) String() string
- func (val *WorkflowExecutionSignaledEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionStartedEventAttributes
- func (*WorkflowExecutionStartedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionStartedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionStartedEventAttributes) GetAttempt() int32
- func (x *WorkflowExecutionStartedEventAttributes) GetCompletionCallbacks() []*v1.Callback
- func (x *WorkflowExecutionStartedEventAttributes) GetContinuedExecutionRunId() string
- func (x *WorkflowExecutionStartedEventAttributes) GetContinuedFailure() *v13.Failure
- func (x *WorkflowExecutionStartedEventAttributes) GetCronSchedule() string
- func (x *WorkflowExecutionStartedEventAttributes) GetFirstExecutionRunId() string
- func (x *WorkflowExecutionStartedEventAttributes) GetFirstWorkflowTaskBackoff() *durationpb.Duration
- func (x *WorkflowExecutionStartedEventAttributes) GetHeader() *v1.Header
- func (x *WorkflowExecutionStartedEventAttributes) GetIdentity() string
- func (x *WorkflowExecutionStartedEventAttributes) GetInitiator() v12.ContinueAsNewInitiator
- func (x *WorkflowExecutionStartedEventAttributes) GetInput() *v1.Payloads
- func (x *WorkflowExecutionStartedEventAttributes) GetLastCompletionResult() *v1.Payloads
- func (x *WorkflowExecutionStartedEventAttributes) GetMemo() *v1.Memo
- func (x *WorkflowExecutionStartedEventAttributes) GetOriginalExecutionRunId() string
- func (x *WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventId() int64
- func (x *WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventVersion() int64
- func (x *WorkflowExecutionStartedEventAttributes) GetParentWorkflowExecution() *v1.WorkflowExecution
- func (x *WorkflowExecutionStartedEventAttributes) GetParentWorkflowNamespace() string
- func (x *WorkflowExecutionStartedEventAttributes) GetParentWorkflowNamespaceId() string
- func (x *WorkflowExecutionStartedEventAttributes) GetPrevAutoResetPoints() *v14.ResetPoints
- func (x *WorkflowExecutionStartedEventAttributes) GetRetryPolicy() *v1.RetryPolicy
- func (x *WorkflowExecutionStartedEventAttributes) GetSearchAttributes() *v1.SearchAttributes
- func (x *WorkflowExecutionStartedEventAttributes) GetSourceVersionStamp() *v1.WorkerVersionStamp
- func (x *WorkflowExecutionStartedEventAttributes) GetTaskQueue() *v11.TaskQueue
- func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowExecutionExpirationTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowExecutionTimeout() *durationpb.Duration
- func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowId() string
- func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowRunTimeout() *durationpb.Duration
- func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowTaskTimeout() *durationpb.Duration
- func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowType() *v1.WorkflowType
- func (val *WorkflowExecutionStartedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionStartedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionStartedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionStartedEventAttributes) Reset()
- func (val *WorkflowExecutionStartedEventAttributes) Size() int
- func (x *WorkflowExecutionStartedEventAttributes) String() string
- func (val *WorkflowExecutionStartedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionTerminatedEventAttributes
- func (*WorkflowExecutionTerminatedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionTerminatedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionTerminatedEventAttributes) GetDetails() *v1.Payloads
- func (x *WorkflowExecutionTerminatedEventAttributes) GetIdentity() string
- func (x *WorkflowExecutionTerminatedEventAttributes) GetReason() string
- func (val *WorkflowExecutionTerminatedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionTerminatedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionTerminatedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionTerminatedEventAttributes) Reset()
- func (val *WorkflowExecutionTerminatedEventAttributes) Size() int
- func (x *WorkflowExecutionTerminatedEventAttributes) String() string
- func (val *WorkflowExecutionTerminatedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionTimedOutEventAttributes
- func (*WorkflowExecutionTimedOutEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionTimedOutEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionTimedOutEventAttributes) GetNewExecutionRunId() string
- func (x *WorkflowExecutionTimedOutEventAttributes) GetRetryState() v12.RetryState
- func (val *WorkflowExecutionTimedOutEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionTimedOutEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionTimedOutEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionTimedOutEventAttributes) Reset()
- func (val *WorkflowExecutionTimedOutEventAttributes) Size() int
- func (x *WorkflowExecutionTimedOutEventAttributes) String() string
- func (val *WorkflowExecutionTimedOutEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionUpdateAcceptedEventAttributes
- func (*WorkflowExecutionUpdateAcceptedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionUpdateAcceptedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequest() *v16.Request
- func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequestMessageId() string
- func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequestSequencingEventId() int64
- func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetProtocolInstanceId() string
- func (val *WorkflowExecutionUpdateAcceptedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionUpdateAcceptedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionUpdateAcceptedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionUpdateAcceptedEventAttributes) Reset()
- func (val *WorkflowExecutionUpdateAcceptedEventAttributes) Size() int
- func (x *WorkflowExecutionUpdateAcceptedEventAttributes) String() string
- func (val *WorkflowExecutionUpdateAcceptedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionUpdateCompletedEventAttributes
- func (*WorkflowExecutionUpdateCompletedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionUpdateCompletedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionUpdateCompletedEventAttributes) GetAcceptedEventId() int64
- func (x *WorkflowExecutionUpdateCompletedEventAttributes) GetMeta() *v16.Meta
- func (x *WorkflowExecutionUpdateCompletedEventAttributes) GetOutcome() *v16.Outcome
- func (val *WorkflowExecutionUpdateCompletedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionUpdateCompletedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionUpdateCompletedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionUpdateCompletedEventAttributes) Reset()
- func (val *WorkflowExecutionUpdateCompletedEventAttributes) Size() int
- func (x *WorkflowExecutionUpdateCompletedEventAttributes) String() string
- func (val *WorkflowExecutionUpdateCompletedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionUpdateRejectedEventAttributes
- func (*WorkflowExecutionUpdateRejectedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionUpdateRejectedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetFailure() *v13.Failure
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetProtocolInstanceId() string
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequest() *v16.Request
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequestMessageId() string
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequestSequencingEventId() int64
- func (val *WorkflowExecutionUpdateRejectedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionUpdateRejectedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) Reset()
- func (val *WorkflowExecutionUpdateRejectedEventAttributes) Size() int
- func (x *WorkflowExecutionUpdateRejectedEventAttributes) String() string
- func (val *WorkflowExecutionUpdateRejectedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowExecutionUpdateRequestedEventAttributes
- func (*WorkflowExecutionUpdateRequestedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionUpdateRequestedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowExecutionUpdateRequestedEventAttributes) GetOrigin() v12.UpdateRequestedEventOrigin
- func (x *WorkflowExecutionUpdateRequestedEventAttributes) GetRequest() *v16.Request
- func (val *WorkflowExecutionUpdateRequestedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowExecutionUpdateRequestedEventAttributes) ProtoMessage()
- func (x *WorkflowExecutionUpdateRequestedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionUpdateRequestedEventAttributes) Reset()
- func (val *WorkflowExecutionUpdateRequestedEventAttributes) Size() int
- func (x *WorkflowExecutionUpdateRequestedEventAttributes) String() string
- func (val *WorkflowExecutionUpdateRequestedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowPropertiesModifiedEventAttributes
- func (*WorkflowPropertiesModifiedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowPropertiesModifiedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowPropertiesModifiedEventAttributes) GetUpsertedMemo() *v1.Memo
- func (x *WorkflowPropertiesModifiedEventAttributes) GetWorkflowTaskCompletedEventId() int64
- func (val *WorkflowPropertiesModifiedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowPropertiesModifiedEventAttributes) ProtoMessage()
- func (x *WorkflowPropertiesModifiedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowPropertiesModifiedEventAttributes) Reset()
- func (val *WorkflowPropertiesModifiedEventAttributes) Size() int
- func (x *WorkflowPropertiesModifiedEventAttributes) String() string
- func (val *WorkflowPropertiesModifiedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowPropertiesModifiedExternallyEventAttributes
- func (*WorkflowPropertiesModifiedExternallyEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowPropertiesModifiedExternallyEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewTaskQueue() string
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowExecutionTimeout() *durationpb.Duration
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowRunTimeout() *durationpb.Duration
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowTaskTimeout() *durationpb.Duration
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetUpsertedMemo() *v1.Memo
- func (val *WorkflowPropertiesModifiedExternallyEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowPropertiesModifiedExternallyEventAttributes) ProtoMessage()
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) Reset()
- func (val *WorkflowPropertiesModifiedExternallyEventAttributes) Size() int
- func (x *WorkflowPropertiesModifiedExternallyEventAttributes) String() string
- func (val *WorkflowPropertiesModifiedExternallyEventAttributes) Unmarshal(buf []byte) error
- type WorkflowTaskCompletedEventAttributes
- func (*WorkflowTaskCompletedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowTaskCompletedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowTaskCompletedEventAttributes) GetBinaryChecksum() string
- func (x *WorkflowTaskCompletedEventAttributes) GetIdentity() string
- func (x *WorkflowTaskCompletedEventAttributes) GetMeteringMetadata() *v1.MeteringMetadata
- func (x *WorkflowTaskCompletedEventAttributes) GetScheduledEventId() int64
- func (x *WorkflowTaskCompletedEventAttributes) GetSdkMetadata() *v15.WorkflowTaskCompletedMetadata
- func (x *WorkflowTaskCompletedEventAttributes) GetStartedEventId() int64
- func (x *WorkflowTaskCompletedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
- func (val *WorkflowTaskCompletedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowTaskCompletedEventAttributes) ProtoMessage()
- func (x *WorkflowTaskCompletedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowTaskCompletedEventAttributes) Reset()
- func (val *WorkflowTaskCompletedEventAttributes) Size() int
- func (x *WorkflowTaskCompletedEventAttributes) String() string
- func (val *WorkflowTaskCompletedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowTaskFailedEventAttributes
- func (*WorkflowTaskFailedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowTaskFailedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowTaskFailedEventAttributes) GetBaseRunId() string
- func (x *WorkflowTaskFailedEventAttributes) GetBinaryChecksum() string
- func (x *WorkflowTaskFailedEventAttributes) GetCause() v12.WorkflowTaskFailedCause
- func (x *WorkflowTaskFailedEventAttributes) GetFailure() *v13.Failure
- func (x *WorkflowTaskFailedEventAttributes) GetForkEventVersion() int64
- func (x *WorkflowTaskFailedEventAttributes) GetIdentity() string
- func (x *WorkflowTaskFailedEventAttributes) GetNewRunId() string
- func (x *WorkflowTaskFailedEventAttributes) GetScheduledEventId() int64
- func (x *WorkflowTaskFailedEventAttributes) GetStartedEventId() int64
- func (x *WorkflowTaskFailedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
- func (val *WorkflowTaskFailedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowTaskFailedEventAttributes) ProtoMessage()
- func (x *WorkflowTaskFailedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowTaskFailedEventAttributes) Reset()
- func (val *WorkflowTaskFailedEventAttributes) Size() int
- func (x *WorkflowTaskFailedEventAttributes) String() string
- func (val *WorkflowTaskFailedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowTaskScheduledEventAttributes
- func (*WorkflowTaskScheduledEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowTaskScheduledEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowTaskScheduledEventAttributes) GetAttempt() int32
- func (x *WorkflowTaskScheduledEventAttributes) GetStartToCloseTimeout() *durationpb.Duration
- func (x *WorkflowTaskScheduledEventAttributes) GetTaskQueue() *v11.TaskQueue
- func (val *WorkflowTaskScheduledEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowTaskScheduledEventAttributes) ProtoMessage()
- func (x *WorkflowTaskScheduledEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowTaskScheduledEventAttributes) Reset()
- func (val *WorkflowTaskScheduledEventAttributes) Size() int
- func (x *WorkflowTaskScheduledEventAttributes) String() string
- func (val *WorkflowTaskScheduledEventAttributes) Unmarshal(buf []byte) error
- type WorkflowTaskStartedEventAttributes
- func (*WorkflowTaskStartedEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowTaskStartedEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowTaskStartedEventAttributes) GetHistorySizeBytes() int64
- func (x *WorkflowTaskStartedEventAttributes) GetIdentity() string
- func (x *WorkflowTaskStartedEventAttributes) GetRequestId() string
- func (x *WorkflowTaskStartedEventAttributes) GetScheduledEventId() int64
- func (x *WorkflowTaskStartedEventAttributes) GetSuggestContinueAsNew() bool
- func (val *WorkflowTaskStartedEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowTaskStartedEventAttributes) ProtoMessage()
- func (x *WorkflowTaskStartedEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowTaskStartedEventAttributes) Reset()
- func (val *WorkflowTaskStartedEventAttributes) Size() int
- func (x *WorkflowTaskStartedEventAttributes) String() string
- func (val *WorkflowTaskStartedEventAttributes) Unmarshal(buf []byte) error
- type WorkflowTaskTimedOutEventAttributes
- func (*WorkflowTaskTimedOutEventAttributes) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowTaskTimedOutEventAttributes) Equal(that interface{}) bool
- func (x *WorkflowTaskTimedOutEventAttributes) GetScheduledEventId() int64
- func (x *WorkflowTaskTimedOutEventAttributes) GetStartedEventId() int64
- func (x *WorkflowTaskTimedOutEventAttributes) GetTimeoutType() v12.TimeoutType
- func (val *WorkflowTaskTimedOutEventAttributes) Marshal() ([]byte, error)
- func (*WorkflowTaskTimedOutEventAttributes) ProtoMessage()
- func (x *WorkflowTaskTimedOutEventAttributes) ProtoReflect() protoreflect.Message
- func (x *WorkflowTaskTimedOutEventAttributes) Reset()
- func (val *WorkflowTaskTimedOutEventAttributes) Size() int
- func (x *WorkflowTaskTimedOutEventAttributes) String() string
- func (val *WorkflowTaskTimedOutEventAttributes) Unmarshal(buf []byte) error
Constants ¶
This section is empty.
Variables ¶
var File_temporal_api_history_v1_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ActivityPropertiesModifiedExternallyEventAttributes ¶ added in v1.11.0
type ActivityPropertiesModifiedExternallyEventAttributes struct { // The id of the `ACTIVITY_TASK_SCHEDULED` event this modification corresponds to. ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // If set, update the retry policy of the activity, replacing it with the specified one. // The number of attempts at the activity is preserved. NewRetryPolicy *v1.RetryPolicy `protobuf:"bytes,2,opt,name=new_retry_policy,json=newRetryPolicy,proto3" json:"new_retry_policy,omitempty"` // contains filtered or unexported fields }
func (*ActivityPropertiesModifiedExternallyEventAttributes) Descriptor
deprecated
added in
v1.11.0
func (*ActivityPropertiesModifiedExternallyEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityPropertiesModifiedExternallyEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityPropertiesModifiedExternallyEventAttributes) Equal ¶ added in v1.11.0
func (this *ActivityPropertiesModifiedExternallyEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityPropertiesModifiedExternallyEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityPropertiesModifiedExternallyEventAttributes) GetNewRetryPolicy ¶ added in v1.11.0
func (x *ActivityPropertiesModifiedExternallyEventAttributes) GetNewRetryPolicy() *v1.RetryPolicy
func (*ActivityPropertiesModifiedExternallyEventAttributes) GetScheduledEventId ¶ added in v1.11.0
func (x *ActivityPropertiesModifiedExternallyEventAttributes) GetScheduledEventId() int64
func (*ActivityPropertiesModifiedExternallyEventAttributes) Marshal ¶ added in v1.11.0
func (val *ActivityPropertiesModifiedExternallyEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityPropertiesModifiedExternallyEventAttributes to the protobuf v3 wire format
func (*ActivityPropertiesModifiedExternallyEventAttributes) ProtoMessage ¶ added in v1.11.0
func (*ActivityPropertiesModifiedExternallyEventAttributes) ProtoMessage()
func (*ActivityPropertiesModifiedExternallyEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityPropertiesModifiedExternallyEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityPropertiesModifiedExternallyEventAttributes) Reset ¶ added in v1.11.0
func (x *ActivityPropertiesModifiedExternallyEventAttributes) Reset()
func (*ActivityPropertiesModifiedExternallyEventAttributes) Size ¶ added in v1.11.0
func (val *ActivityPropertiesModifiedExternallyEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityPropertiesModifiedExternallyEventAttributes) String ¶ added in v1.11.0
func (x *ActivityPropertiesModifiedExternallyEventAttributes) String() string
func (*ActivityPropertiesModifiedExternallyEventAttributes) Unmarshal ¶ added in v1.11.0
func (val *ActivityPropertiesModifiedExternallyEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityPropertiesModifiedExternallyEventAttributes from the protobuf v3 wire format
type ActivityTaskCancelRequestedEventAttributes ¶
type ActivityTaskCancelRequestedEventAttributes struct { // The id of the `ACTIVITY_TASK_SCHEDULED` event this cancel request corresponds to ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ActivityTaskCancelRequestedEventAttributes) Descriptor
deprecated
func (*ActivityTaskCancelRequestedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityTaskCancelRequestedEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityTaskCancelRequestedEventAttributes) Equal ¶
func (this *ActivityTaskCancelRequestedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityTaskCancelRequestedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityTaskCancelRequestedEventAttributes) GetScheduledEventId ¶
func (x *ActivityTaskCancelRequestedEventAttributes) GetScheduledEventId() int64
func (*ActivityTaskCancelRequestedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *ActivityTaskCancelRequestedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*ActivityTaskCancelRequestedEventAttributes) Marshal ¶
func (val *ActivityTaskCancelRequestedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityTaskCancelRequestedEventAttributes to the protobuf v3 wire format
func (*ActivityTaskCancelRequestedEventAttributes) ProtoMessage ¶
func (*ActivityTaskCancelRequestedEventAttributes) ProtoMessage()
func (*ActivityTaskCancelRequestedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityTaskCancelRequestedEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityTaskCancelRequestedEventAttributes) Reset ¶
func (x *ActivityTaskCancelRequestedEventAttributes) Reset()
func (*ActivityTaskCancelRequestedEventAttributes) Size ¶
func (val *ActivityTaskCancelRequestedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityTaskCancelRequestedEventAttributes) String ¶
func (x *ActivityTaskCancelRequestedEventAttributes) String() string
func (*ActivityTaskCancelRequestedEventAttributes) Unmarshal ¶
func (val *ActivityTaskCancelRequestedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityTaskCancelRequestedEventAttributes from the protobuf v3 wire format
type ActivityTaskCanceledEventAttributes ¶
type ActivityTaskCanceledEventAttributes struct { // Additional information that the activity reported upon confirming cancellation Details *v1.Payloads `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"` // id of the most recent `ACTIVITY_TASK_CANCEL_REQUESTED` event which refers to the same // activity LatestCancelRequestedEventId int64 `` /* 152-byte string literal not displayed */ // The id of the `ACTIVITY_TASK_SCHEDULED` event this cancel confirmation corresponds to ScheduledEventId int64 `protobuf:"varint,3,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The id of the `ACTIVITY_TASK_STARTED` event this cancel confirmation corresponds to StartedEventId int64 `protobuf:"varint,4,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // id of the worker who canceled this activity Identity string `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"` // Version info of the worker who processed this workflow task. WorkerVersion *v1.WorkerVersionStamp `protobuf:"bytes,6,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,omitempty"` // contains filtered or unexported fields }
func (*ActivityTaskCanceledEventAttributes) Descriptor
deprecated
func (*ActivityTaskCanceledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityTaskCanceledEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityTaskCanceledEventAttributes) Equal ¶
func (this *ActivityTaskCanceledEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityTaskCanceledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityTaskCanceledEventAttributes) GetDetails ¶
func (x *ActivityTaskCanceledEventAttributes) GetDetails() *v1.Payloads
func (*ActivityTaskCanceledEventAttributes) GetIdentity ¶
func (x *ActivityTaskCanceledEventAttributes) GetIdentity() string
func (*ActivityTaskCanceledEventAttributes) GetLatestCancelRequestedEventId ¶
func (x *ActivityTaskCanceledEventAttributes) GetLatestCancelRequestedEventId() int64
func (*ActivityTaskCanceledEventAttributes) GetScheduledEventId ¶
func (x *ActivityTaskCanceledEventAttributes) GetScheduledEventId() int64
func (*ActivityTaskCanceledEventAttributes) GetStartedEventId ¶
func (x *ActivityTaskCanceledEventAttributes) GetStartedEventId() int64
func (*ActivityTaskCanceledEventAttributes) GetWorkerVersion ¶ added in v1.21.0
func (x *ActivityTaskCanceledEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
func (*ActivityTaskCanceledEventAttributes) Marshal ¶
func (val *ActivityTaskCanceledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityTaskCanceledEventAttributes to the protobuf v3 wire format
func (*ActivityTaskCanceledEventAttributes) ProtoMessage ¶
func (*ActivityTaskCanceledEventAttributes) ProtoMessage()
func (*ActivityTaskCanceledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityTaskCanceledEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityTaskCanceledEventAttributes) Reset ¶
func (x *ActivityTaskCanceledEventAttributes) Reset()
func (*ActivityTaskCanceledEventAttributes) Size ¶
func (val *ActivityTaskCanceledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityTaskCanceledEventAttributes) String ¶
func (x *ActivityTaskCanceledEventAttributes) String() string
func (*ActivityTaskCanceledEventAttributes) Unmarshal ¶
func (val *ActivityTaskCanceledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityTaskCanceledEventAttributes from the protobuf v3 wire format
type ActivityTaskCompletedEventAttributes ¶
type ActivityTaskCompletedEventAttributes struct { // Serialized results of the activity. IE: The return value of the activity function Result *v1.Payloads `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // The id of the `ACTIVITY_TASK_SCHEDULED` event this completion corresponds to ScheduledEventId int64 `protobuf:"varint,2,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The id of the `ACTIVITY_TASK_STARTED` event this completion corresponds to StartedEventId int64 `protobuf:"varint,3,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // id of the worker that completed this task Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"` // Version info of the worker who processed this workflow task. WorkerVersion *v1.WorkerVersionStamp `protobuf:"bytes,5,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,omitempty"` // contains filtered or unexported fields }
func (*ActivityTaskCompletedEventAttributes) Descriptor
deprecated
func (*ActivityTaskCompletedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityTaskCompletedEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityTaskCompletedEventAttributes) Equal ¶
func (this *ActivityTaskCompletedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityTaskCompletedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityTaskCompletedEventAttributes) GetIdentity ¶
func (x *ActivityTaskCompletedEventAttributes) GetIdentity() string
func (*ActivityTaskCompletedEventAttributes) GetResult ¶
func (x *ActivityTaskCompletedEventAttributes) GetResult() *v1.Payloads
func (*ActivityTaskCompletedEventAttributes) GetScheduledEventId ¶
func (x *ActivityTaskCompletedEventAttributes) GetScheduledEventId() int64
func (*ActivityTaskCompletedEventAttributes) GetStartedEventId ¶
func (x *ActivityTaskCompletedEventAttributes) GetStartedEventId() int64
func (*ActivityTaskCompletedEventAttributes) GetWorkerVersion ¶ added in v1.21.0
func (x *ActivityTaskCompletedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
func (*ActivityTaskCompletedEventAttributes) Marshal ¶
func (val *ActivityTaskCompletedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityTaskCompletedEventAttributes to the protobuf v3 wire format
func (*ActivityTaskCompletedEventAttributes) ProtoMessage ¶
func (*ActivityTaskCompletedEventAttributes) ProtoMessage()
func (*ActivityTaskCompletedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityTaskCompletedEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityTaskCompletedEventAttributes) Reset ¶
func (x *ActivityTaskCompletedEventAttributes) Reset()
func (*ActivityTaskCompletedEventAttributes) Size ¶
func (val *ActivityTaskCompletedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityTaskCompletedEventAttributes) String ¶
func (x *ActivityTaskCompletedEventAttributes) String() string
func (*ActivityTaskCompletedEventAttributes) Unmarshal ¶
func (val *ActivityTaskCompletedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityTaskCompletedEventAttributes from the protobuf v3 wire format
type ActivityTaskFailedEventAttributes ¶
type ActivityTaskFailedEventAttributes struct { // Failure details Failure *v13.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"` // The id of the `ACTIVITY_TASK_SCHEDULED` event this failure corresponds to ScheduledEventId int64 `protobuf:"varint,2,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The id of the `ACTIVITY_TASK_STARTED` event this failure corresponds to StartedEventId int64 `protobuf:"varint,3,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // id of the worker that failed this task Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"` RetryState v12.RetryState `` /* 130-byte string literal not displayed */ // Version info of the worker who processed this workflow task. WorkerVersion *v1.WorkerVersionStamp `protobuf:"bytes,6,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,omitempty"` // contains filtered or unexported fields }
func (*ActivityTaskFailedEventAttributes) Descriptor
deprecated
func (*ActivityTaskFailedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityTaskFailedEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityTaskFailedEventAttributes) Equal ¶
func (this *ActivityTaskFailedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityTaskFailedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityTaskFailedEventAttributes) GetFailure ¶
func (x *ActivityTaskFailedEventAttributes) GetFailure() *v13.Failure
func (*ActivityTaskFailedEventAttributes) GetIdentity ¶
func (x *ActivityTaskFailedEventAttributes) GetIdentity() string
func (*ActivityTaskFailedEventAttributes) GetRetryState ¶
func (x *ActivityTaskFailedEventAttributes) GetRetryState() v12.RetryState
func (*ActivityTaskFailedEventAttributes) GetScheduledEventId ¶
func (x *ActivityTaskFailedEventAttributes) GetScheduledEventId() int64
func (*ActivityTaskFailedEventAttributes) GetStartedEventId ¶
func (x *ActivityTaskFailedEventAttributes) GetStartedEventId() int64
func (*ActivityTaskFailedEventAttributes) GetWorkerVersion ¶ added in v1.21.0
func (x *ActivityTaskFailedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
func (*ActivityTaskFailedEventAttributes) Marshal ¶
func (val *ActivityTaskFailedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityTaskFailedEventAttributes to the protobuf v3 wire format
func (*ActivityTaskFailedEventAttributes) ProtoMessage ¶
func (*ActivityTaskFailedEventAttributes) ProtoMessage()
func (*ActivityTaskFailedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityTaskFailedEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityTaskFailedEventAttributes) Reset ¶
func (x *ActivityTaskFailedEventAttributes) Reset()
func (*ActivityTaskFailedEventAttributes) Size ¶
func (val *ActivityTaskFailedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityTaskFailedEventAttributes) String ¶
func (x *ActivityTaskFailedEventAttributes) String() string
func (*ActivityTaskFailedEventAttributes) Unmarshal ¶
func (val *ActivityTaskFailedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityTaskFailedEventAttributes from the protobuf v3 wire format
type ActivityTaskScheduledEventAttributes ¶
type ActivityTaskScheduledEventAttributes struct { // The worker/user assigned identifier for the activity ActivityId string `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"` ActivityType *v1.ActivityType `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"` TaskQueue *v11.TaskQueue `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` Header *v1.Header `protobuf:"bytes,5,opt,name=header,proto3" json:"header,omitempty"` Input *v1.Payloads `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"` // Indicates how long the caller is willing to wait for an activity completion. Limits how long // retries will be attempted. Either this or `start_to_close_timeout` must be specified. // // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: "to" is used to indicate interval. --) ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */ // Limits time an activity task can stay in a task queue before a worker picks it up. This // timeout is always non retryable, as all a retry would achieve is to put it back into the same // queue. Defaults to `schedule_to_close_timeout` or workflow execution timeout if not // specified. // // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: "to" is used to indicate interval. --) ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */ // Maximum time an activity is allowed to execute after being picked up by a worker. This // timeout is always retryable. Either this or `schedule_to_close_timeout` must be // specified. // // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: "to" is used to indicate interval. --) StartToCloseTimeout *durationpb.Duration `protobuf:"bytes,9,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"` // Maximum permitted time between successful worker heartbeats. HeartbeatTimeout *durationpb.Duration `protobuf:"bytes,10,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 153-byte string literal not displayed */ // Activities are assigned a default retry policy controlled by the service's dynamic // configuration. Retries will happen up to `schedule_to_close_timeout`. To disable retries set // retry_policy.maximum_attempts to 1. RetryPolicy *v1.RetryPolicy `protobuf:"bytes,12,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` // If this is set, the workflow executing this command wishes to start the activity using // a version compatible with the version that this workflow most recently ran on, if such // behavior is possible. UseCompatibleVersion bool `protobuf:"varint,13,opt,name=use_compatible_version,json=useCompatibleVersion,proto3" json:"use_compatible_version,omitempty"` // contains filtered or unexported fields }
func (*ActivityTaskScheduledEventAttributes) Descriptor
deprecated
func (*ActivityTaskScheduledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityTaskScheduledEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityTaskScheduledEventAttributes) Equal ¶
func (this *ActivityTaskScheduledEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityTaskScheduledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityTaskScheduledEventAttributes) GetActivityId ¶
func (x *ActivityTaskScheduledEventAttributes) GetActivityId() string
func (*ActivityTaskScheduledEventAttributes) GetActivityType ¶
func (x *ActivityTaskScheduledEventAttributes) GetActivityType() *v1.ActivityType
func (*ActivityTaskScheduledEventAttributes) GetHeader ¶
func (x *ActivityTaskScheduledEventAttributes) GetHeader() *v1.Header
func (*ActivityTaskScheduledEventAttributes) GetHeartbeatTimeout ¶ added in v0.28.0
func (x *ActivityTaskScheduledEventAttributes) GetHeartbeatTimeout() *durationpb.Duration
func (*ActivityTaskScheduledEventAttributes) GetInput ¶
func (x *ActivityTaskScheduledEventAttributes) GetInput() *v1.Payloads
func (*ActivityTaskScheduledEventAttributes) GetRetryPolicy ¶
func (x *ActivityTaskScheduledEventAttributes) GetRetryPolicy() *v1.RetryPolicy
func (*ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeout ¶ added in v0.28.0
func (x *ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeout() *durationpb.Duration
func (*ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeout ¶ added in v0.28.0
func (x *ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeout() *durationpb.Duration
func (*ActivityTaskScheduledEventAttributes) GetStartToCloseTimeout ¶ added in v0.28.0
func (x *ActivityTaskScheduledEventAttributes) GetStartToCloseTimeout() *durationpb.Duration
func (*ActivityTaskScheduledEventAttributes) GetTaskQueue ¶
func (x *ActivityTaskScheduledEventAttributes) GetTaskQueue() *v11.TaskQueue
func (*ActivityTaskScheduledEventAttributes) GetUseCompatibleVersion ¶ added in v1.21.0
func (x *ActivityTaskScheduledEventAttributes) GetUseCompatibleVersion() bool
func (*ActivityTaskScheduledEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *ActivityTaskScheduledEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*ActivityTaskScheduledEventAttributes) Marshal ¶
func (val *ActivityTaskScheduledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityTaskScheduledEventAttributes to the protobuf v3 wire format
func (*ActivityTaskScheduledEventAttributes) ProtoMessage ¶
func (*ActivityTaskScheduledEventAttributes) ProtoMessage()
func (*ActivityTaskScheduledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityTaskScheduledEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityTaskScheduledEventAttributes) Reset ¶
func (x *ActivityTaskScheduledEventAttributes) Reset()
func (*ActivityTaskScheduledEventAttributes) Size ¶
func (val *ActivityTaskScheduledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityTaskScheduledEventAttributes) String ¶
func (x *ActivityTaskScheduledEventAttributes) String() string
func (*ActivityTaskScheduledEventAttributes) Unmarshal ¶
func (val *ActivityTaskScheduledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityTaskScheduledEventAttributes from the protobuf v3 wire format
type ActivityTaskStartedEventAttributes ¶
type ActivityTaskStartedEventAttributes struct { // The id of the `ACTIVITY_TASK_SCHEDULED` event this task corresponds to ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // id of the worker that picked up this task Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"` // TODO ?? RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Starting at 1, the number of times this task has been attempted Attempt int32 `protobuf:"varint,4,opt,name=attempt,proto3" json:"attempt,omitempty"` // Will be set to the most recent failure details, if this task has previously failed and then // been retried. LastFailure *v13.Failure `protobuf:"bytes,5,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"` // contains filtered or unexported fields }
func (*ActivityTaskStartedEventAttributes) Descriptor
deprecated
func (*ActivityTaskStartedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityTaskStartedEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityTaskStartedEventAttributes) Equal ¶
func (this *ActivityTaskStartedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityTaskStartedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityTaskStartedEventAttributes) GetAttempt ¶
func (x *ActivityTaskStartedEventAttributes) GetAttempt() int32
func (*ActivityTaskStartedEventAttributes) GetIdentity ¶
func (x *ActivityTaskStartedEventAttributes) GetIdentity() string
func (*ActivityTaskStartedEventAttributes) GetLastFailure ¶
func (x *ActivityTaskStartedEventAttributes) GetLastFailure() *v13.Failure
func (*ActivityTaskStartedEventAttributes) GetRequestId ¶
func (x *ActivityTaskStartedEventAttributes) GetRequestId() string
func (*ActivityTaskStartedEventAttributes) GetScheduledEventId ¶
func (x *ActivityTaskStartedEventAttributes) GetScheduledEventId() int64
func (*ActivityTaskStartedEventAttributes) Marshal ¶
func (val *ActivityTaskStartedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityTaskStartedEventAttributes to the protobuf v3 wire format
func (*ActivityTaskStartedEventAttributes) ProtoMessage ¶
func (*ActivityTaskStartedEventAttributes) ProtoMessage()
func (*ActivityTaskStartedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityTaskStartedEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityTaskStartedEventAttributes) Reset ¶
func (x *ActivityTaskStartedEventAttributes) Reset()
func (*ActivityTaskStartedEventAttributes) Size ¶
func (val *ActivityTaskStartedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityTaskStartedEventAttributes) String ¶
func (x *ActivityTaskStartedEventAttributes) String() string
func (*ActivityTaskStartedEventAttributes) Unmarshal ¶
func (val *ActivityTaskStartedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityTaskStartedEventAttributes from the protobuf v3 wire format
type ActivityTaskTimedOutEventAttributes ¶
type ActivityTaskTimedOutEventAttributes struct { // If this activity had failed, was retried, and then timed out, that failure is stored as the // `cause` in here. Failure *v13.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"` // The id of the `ACTIVITY_TASK_SCHEDULED` event this timeout corresponds to ScheduledEventId int64 `protobuf:"varint,2,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The id of the `ACTIVITY_TASK_STARTED` event this timeout corresponds to StartedEventId int64 `protobuf:"varint,3,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` RetryState v12.RetryState `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ActivityTaskTimedOutEventAttributes) Descriptor
deprecated
func (*ActivityTaskTimedOutEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ActivityTaskTimedOutEventAttributes.ProtoReflect.Descriptor instead.
func (*ActivityTaskTimedOutEventAttributes) Equal ¶
func (this *ActivityTaskTimedOutEventAttributes) Equal(that interface{}) bool
Equal returns whether two ActivityTaskTimedOutEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ActivityTaskTimedOutEventAttributes) GetFailure ¶
func (x *ActivityTaskTimedOutEventAttributes) GetFailure() *v13.Failure
func (*ActivityTaskTimedOutEventAttributes) GetRetryState ¶
func (x *ActivityTaskTimedOutEventAttributes) GetRetryState() v12.RetryState
func (*ActivityTaskTimedOutEventAttributes) GetScheduledEventId ¶
func (x *ActivityTaskTimedOutEventAttributes) GetScheduledEventId() int64
func (*ActivityTaskTimedOutEventAttributes) GetStartedEventId ¶
func (x *ActivityTaskTimedOutEventAttributes) GetStartedEventId() int64
func (*ActivityTaskTimedOutEventAttributes) Marshal ¶
func (val *ActivityTaskTimedOutEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ActivityTaskTimedOutEventAttributes to the protobuf v3 wire format
func (*ActivityTaskTimedOutEventAttributes) ProtoMessage ¶
func (*ActivityTaskTimedOutEventAttributes) ProtoMessage()
func (*ActivityTaskTimedOutEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ActivityTaskTimedOutEventAttributes) ProtoReflect() protoreflect.Message
func (*ActivityTaskTimedOutEventAttributes) Reset ¶
func (x *ActivityTaskTimedOutEventAttributes) Reset()
func (*ActivityTaskTimedOutEventAttributes) Size ¶
func (val *ActivityTaskTimedOutEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ActivityTaskTimedOutEventAttributes) String ¶
func (x *ActivityTaskTimedOutEventAttributes) String() string
func (*ActivityTaskTimedOutEventAttributes) Unmarshal ¶
func (val *ActivityTaskTimedOutEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ActivityTaskTimedOutEventAttributes from the protobuf v3 wire format
type ChildWorkflowExecutionCanceledEventAttributes ¶
type ChildWorkflowExecutionCanceledEventAttributes struct { Details *v1.Payloads `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"` // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,7,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,4,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` // Id of the `START_CHILD_WORKFLOW_EXECUTION_INITIATED` event which this event corresponds to InitiatedEventId int64 `protobuf:"varint,5,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Id of the `CHILD_WORKFLOW_EXECUTION_STARTED` event which this event corresponds to StartedEventId int64 `protobuf:"varint,6,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // contains filtered or unexported fields }
func (*ChildWorkflowExecutionCanceledEventAttributes) Descriptor
deprecated
func (*ChildWorkflowExecutionCanceledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowExecutionCanceledEventAttributes.ProtoReflect.Descriptor instead.
func (*ChildWorkflowExecutionCanceledEventAttributes) Equal ¶
func (this *ChildWorkflowExecutionCanceledEventAttributes) Equal(that interface{}) bool
Equal returns whether two ChildWorkflowExecutionCanceledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ChildWorkflowExecutionCanceledEventAttributes) GetDetails ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) GetDetails() *v1.Payloads
func (*ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventId ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventId() int64
func (*ChildWorkflowExecutionCanceledEventAttributes) GetNamespace ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) GetNamespace() string
func (*ChildWorkflowExecutionCanceledEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ChildWorkflowExecutionCanceledEventAttributes) GetNamespaceId() string
func (*ChildWorkflowExecutionCanceledEventAttributes) GetStartedEventId ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) GetStartedEventId() int64
func (*ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowExecution ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowType ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*ChildWorkflowExecutionCanceledEventAttributes) Marshal ¶
func (val *ChildWorkflowExecutionCanceledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ChildWorkflowExecutionCanceledEventAttributes to the protobuf v3 wire format
func (*ChildWorkflowExecutionCanceledEventAttributes) ProtoMessage ¶
func (*ChildWorkflowExecutionCanceledEventAttributes) ProtoMessage()
func (*ChildWorkflowExecutionCanceledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ChildWorkflowExecutionCanceledEventAttributes) ProtoReflect() protoreflect.Message
func (*ChildWorkflowExecutionCanceledEventAttributes) Reset ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) Reset()
func (*ChildWorkflowExecutionCanceledEventAttributes) Size ¶
func (val *ChildWorkflowExecutionCanceledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ChildWorkflowExecutionCanceledEventAttributes) String ¶
func (x *ChildWorkflowExecutionCanceledEventAttributes) String() string
func (*ChildWorkflowExecutionCanceledEventAttributes) Unmarshal ¶
func (val *ChildWorkflowExecutionCanceledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ChildWorkflowExecutionCanceledEventAttributes from the protobuf v3 wire format
type ChildWorkflowExecutionCompletedEventAttributes ¶
type ChildWorkflowExecutionCompletedEventAttributes struct { Result *v1.Payloads `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,7,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,4,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` // Id of the `START_CHILD_WORKFLOW_EXECUTION_INITIATED` event which this event corresponds to InitiatedEventId int64 `protobuf:"varint,5,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Id of the `CHILD_WORKFLOW_EXECUTION_STARTED` event which this event corresponds to StartedEventId int64 `protobuf:"varint,6,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // contains filtered or unexported fields }
func (*ChildWorkflowExecutionCompletedEventAttributes) Descriptor
deprecated
func (*ChildWorkflowExecutionCompletedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowExecutionCompletedEventAttributes.ProtoReflect.Descriptor instead.
func (*ChildWorkflowExecutionCompletedEventAttributes) Equal ¶
func (this *ChildWorkflowExecutionCompletedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ChildWorkflowExecutionCompletedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventId ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventId() int64
func (*ChildWorkflowExecutionCompletedEventAttributes) GetNamespace ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) GetNamespace() string
func (*ChildWorkflowExecutionCompletedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ChildWorkflowExecutionCompletedEventAttributes) GetNamespaceId() string
func (*ChildWorkflowExecutionCompletedEventAttributes) GetResult ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) GetResult() *v1.Payloads
func (*ChildWorkflowExecutionCompletedEventAttributes) GetStartedEventId ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) GetStartedEventId() int64
func (*ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowExecution ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowType ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*ChildWorkflowExecutionCompletedEventAttributes) Marshal ¶
func (val *ChildWorkflowExecutionCompletedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ChildWorkflowExecutionCompletedEventAttributes to the protobuf v3 wire format
func (*ChildWorkflowExecutionCompletedEventAttributes) ProtoMessage ¶
func (*ChildWorkflowExecutionCompletedEventAttributes) ProtoMessage()
func (*ChildWorkflowExecutionCompletedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ChildWorkflowExecutionCompletedEventAttributes) ProtoReflect() protoreflect.Message
func (*ChildWorkflowExecutionCompletedEventAttributes) Reset ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) Reset()
func (*ChildWorkflowExecutionCompletedEventAttributes) Size ¶
func (val *ChildWorkflowExecutionCompletedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ChildWorkflowExecutionCompletedEventAttributes) String ¶
func (x *ChildWorkflowExecutionCompletedEventAttributes) String() string
func (*ChildWorkflowExecutionCompletedEventAttributes) Unmarshal ¶
func (val *ChildWorkflowExecutionCompletedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ChildWorkflowExecutionCompletedEventAttributes from the protobuf v3 wire format
type ChildWorkflowExecutionFailedEventAttributes ¶
type ChildWorkflowExecutionFailedEventAttributes struct { Failure *v13.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"` // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,8,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,4,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` // Id of the `START_CHILD_WORKFLOW_EXECUTION_INITIATED` event which this event corresponds to InitiatedEventId int64 `protobuf:"varint,5,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Id of the `CHILD_WORKFLOW_EXECUTION_STARTED` event which this event corresponds to StartedEventId int64 `protobuf:"varint,6,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` RetryState v12.RetryState `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ChildWorkflowExecutionFailedEventAttributes) Descriptor
deprecated
func (*ChildWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowExecutionFailedEventAttributes.ProtoReflect.Descriptor instead.
func (*ChildWorkflowExecutionFailedEventAttributes) Equal ¶
func (this *ChildWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ChildWorkflowExecutionFailedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ChildWorkflowExecutionFailedEventAttributes) GetFailure ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) GetFailure() *v13.Failure
func (*ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
func (*ChildWorkflowExecutionFailedEventAttributes) GetNamespace ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) GetNamespace() string
func (*ChildWorkflowExecutionFailedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ChildWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
func (*ChildWorkflowExecutionFailedEventAttributes) GetRetryState ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) GetRetryState() v12.RetryState
func (*ChildWorkflowExecutionFailedEventAttributes) GetStartedEventId ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) GetStartedEventId() int64
func (*ChildWorkflowExecutionFailedEventAttributes) GetWorkflowExecution ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ChildWorkflowExecutionFailedEventAttributes) GetWorkflowType ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*ChildWorkflowExecutionFailedEventAttributes) Marshal ¶
func (val *ChildWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ChildWorkflowExecutionFailedEventAttributes to the protobuf v3 wire format
func (*ChildWorkflowExecutionFailedEventAttributes) ProtoMessage ¶
func (*ChildWorkflowExecutionFailedEventAttributes) ProtoMessage()
func (*ChildWorkflowExecutionFailedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ChildWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
func (*ChildWorkflowExecutionFailedEventAttributes) Reset ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) Reset()
func (*ChildWorkflowExecutionFailedEventAttributes) Size ¶
func (val *ChildWorkflowExecutionFailedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ChildWorkflowExecutionFailedEventAttributes) String ¶
func (x *ChildWorkflowExecutionFailedEventAttributes) String() string
func (*ChildWorkflowExecutionFailedEventAttributes) Unmarshal ¶
func (val *ChildWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ChildWorkflowExecutionFailedEventAttributes from the protobuf v3 wire format
type ChildWorkflowExecutionStartedEventAttributes ¶
type ChildWorkflowExecutionStartedEventAttributes struct { // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,6,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Id of the `START_CHILD_WORKFLOW_EXECUTION_INITIATED` event which this event corresponds to InitiatedEventId int64 `protobuf:"varint,2,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,4,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` Header *v1.Header `protobuf:"bytes,5,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*ChildWorkflowExecutionStartedEventAttributes) Descriptor
deprecated
func (*ChildWorkflowExecutionStartedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowExecutionStartedEventAttributes.ProtoReflect.Descriptor instead.
func (*ChildWorkflowExecutionStartedEventAttributes) Equal ¶
func (this *ChildWorkflowExecutionStartedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ChildWorkflowExecutionStartedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ChildWorkflowExecutionStartedEventAttributes) GetHeader ¶
func (x *ChildWorkflowExecutionStartedEventAttributes) GetHeader() *v1.Header
func (*ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventId ¶
func (x *ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventId() int64
func (*ChildWorkflowExecutionStartedEventAttributes) GetNamespace ¶
func (x *ChildWorkflowExecutionStartedEventAttributes) GetNamespace() string
func (*ChildWorkflowExecutionStartedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ChildWorkflowExecutionStartedEventAttributes) GetNamespaceId() string
func (*ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution ¶
func (x *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ChildWorkflowExecutionStartedEventAttributes) GetWorkflowType ¶
func (x *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*ChildWorkflowExecutionStartedEventAttributes) Marshal ¶
func (val *ChildWorkflowExecutionStartedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ChildWorkflowExecutionStartedEventAttributes to the protobuf v3 wire format
func (*ChildWorkflowExecutionStartedEventAttributes) ProtoMessage ¶
func (*ChildWorkflowExecutionStartedEventAttributes) ProtoMessage()
func (*ChildWorkflowExecutionStartedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ChildWorkflowExecutionStartedEventAttributes) ProtoReflect() protoreflect.Message
func (*ChildWorkflowExecutionStartedEventAttributes) Reset ¶
func (x *ChildWorkflowExecutionStartedEventAttributes) Reset()
func (*ChildWorkflowExecutionStartedEventAttributes) Size ¶
func (val *ChildWorkflowExecutionStartedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ChildWorkflowExecutionStartedEventAttributes) String ¶
func (x *ChildWorkflowExecutionStartedEventAttributes) String() string
func (*ChildWorkflowExecutionStartedEventAttributes) Unmarshal ¶
func (val *ChildWorkflowExecutionStartedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ChildWorkflowExecutionStartedEventAttributes from the protobuf v3 wire format
type ChildWorkflowExecutionTerminatedEventAttributes ¶
type ChildWorkflowExecutionTerminatedEventAttributes struct { // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,6,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` // Id of the `START_CHILD_WORKFLOW_EXECUTION_INITIATED` event which this event corresponds to InitiatedEventId int64 `protobuf:"varint,4,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Id of the `CHILD_WORKFLOW_EXECUTION_STARTED` event which this event corresponds to StartedEventId int64 `protobuf:"varint,5,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // contains filtered or unexported fields }
func (*ChildWorkflowExecutionTerminatedEventAttributes) Descriptor
deprecated
func (*ChildWorkflowExecutionTerminatedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowExecutionTerminatedEventAttributes.ProtoReflect.Descriptor instead.
func (*ChildWorkflowExecutionTerminatedEventAttributes) Equal ¶
func (this *ChildWorkflowExecutionTerminatedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ChildWorkflowExecutionTerminatedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventId ¶
func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventId() int64
func (*ChildWorkflowExecutionTerminatedEventAttributes) GetNamespace ¶
func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetNamespace() string
func (*ChildWorkflowExecutionTerminatedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetNamespaceId() string
func (*ChildWorkflowExecutionTerminatedEventAttributes) GetStartedEventId ¶
func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetStartedEventId() int64
func (*ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowExecution ¶
func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowType ¶
func (x *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*ChildWorkflowExecutionTerminatedEventAttributes) Marshal ¶
func (val *ChildWorkflowExecutionTerminatedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ChildWorkflowExecutionTerminatedEventAttributes to the protobuf v3 wire format
func (*ChildWorkflowExecutionTerminatedEventAttributes) ProtoMessage ¶
func (*ChildWorkflowExecutionTerminatedEventAttributes) ProtoMessage()
func (*ChildWorkflowExecutionTerminatedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ChildWorkflowExecutionTerminatedEventAttributes) ProtoReflect() protoreflect.Message
func (*ChildWorkflowExecutionTerminatedEventAttributes) Reset ¶
func (x *ChildWorkflowExecutionTerminatedEventAttributes) Reset()
func (*ChildWorkflowExecutionTerminatedEventAttributes) Size ¶
func (val *ChildWorkflowExecutionTerminatedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ChildWorkflowExecutionTerminatedEventAttributes) String ¶
func (x *ChildWorkflowExecutionTerminatedEventAttributes) String() string
func (*ChildWorkflowExecutionTerminatedEventAttributes) Unmarshal ¶
func (val *ChildWorkflowExecutionTerminatedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ChildWorkflowExecutionTerminatedEventAttributes from the protobuf v3 wire format
type ChildWorkflowExecutionTimedOutEventAttributes ¶
type ChildWorkflowExecutionTimedOutEventAttributes struct { // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,7,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` // Id of the `START_CHILD_WORKFLOW_EXECUTION_INITIATED` event which this event corresponds to InitiatedEventId int64 `protobuf:"varint,4,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Id of the `CHILD_WORKFLOW_EXECUTION_STARTED` event which this event corresponds to StartedEventId int64 `protobuf:"varint,5,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` RetryState v12.RetryState `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ChildWorkflowExecutionTimedOutEventAttributes) Descriptor
deprecated
func (*ChildWorkflowExecutionTimedOutEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowExecutionTimedOutEventAttributes.ProtoReflect.Descriptor instead.
func (*ChildWorkflowExecutionTimedOutEventAttributes) Equal ¶
func (this *ChildWorkflowExecutionTimedOutEventAttributes) Equal(that interface{}) bool
Equal returns whether two ChildWorkflowExecutionTimedOutEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventId ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventId() int64
func (*ChildWorkflowExecutionTimedOutEventAttributes) GetNamespace ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetNamespace() string
func (*ChildWorkflowExecutionTimedOutEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetNamespaceId() string
func (*ChildWorkflowExecutionTimedOutEventAttributes) GetRetryState ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetRetryState() v12.RetryState
func (*ChildWorkflowExecutionTimedOutEventAttributes) GetStartedEventId ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetStartedEventId() int64
func (*ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowExecution ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowType ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*ChildWorkflowExecutionTimedOutEventAttributes) Marshal ¶
func (val *ChildWorkflowExecutionTimedOutEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ChildWorkflowExecutionTimedOutEventAttributes to the protobuf v3 wire format
func (*ChildWorkflowExecutionTimedOutEventAttributes) ProtoMessage ¶
func (*ChildWorkflowExecutionTimedOutEventAttributes) ProtoMessage()
func (*ChildWorkflowExecutionTimedOutEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ChildWorkflowExecutionTimedOutEventAttributes) ProtoReflect() protoreflect.Message
func (*ChildWorkflowExecutionTimedOutEventAttributes) Reset ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) Reset()
func (*ChildWorkflowExecutionTimedOutEventAttributes) Size ¶
func (val *ChildWorkflowExecutionTimedOutEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ChildWorkflowExecutionTimedOutEventAttributes) String ¶
func (x *ChildWorkflowExecutionTimedOutEventAttributes) String() string
func (*ChildWorkflowExecutionTimedOutEventAttributes) Unmarshal ¶
func (val *ChildWorkflowExecutionTimedOutEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ChildWorkflowExecutionTimedOutEventAttributes from the protobuf v3 wire format
type ExternalWorkflowExecutionCancelRequestedEventAttributes ¶
type ExternalWorkflowExecutionCancelRequestedEventAttributes struct { // id of the `REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED` event this event corresponds // to InitiatedEventId int64 `protobuf:"varint,1,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Namespace of the to-be-cancelled workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,4,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` // contains filtered or unexported fields }
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Descriptor
deprecated
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ExternalWorkflowExecutionCancelRequestedEventAttributes.ProtoReflect.Descriptor instead.
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Equal ¶
func (this *ExternalWorkflowExecutionCancelRequestedEventAttributes) Equal(that interface{}) bool
Equal returns whether two ExternalWorkflowExecutionCancelRequestedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) GetInitiatedEventId ¶
func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetInitiatedEventId() int64
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) GetNamespace ¶
func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetNamespace() string
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetNamespaceId() string
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) GetWorkflowExecution ¶
func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Marshal ¶
func (val *ExternalWorkflowExecutionCancelRequestedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ExternalWorkflowExecutionCancelRequestedEventAttributes to the protobuf v3 wire format
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) ProtoMessage ¶
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) ProtoMessage()
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) ProtoReflect() protoreflect.Message
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Reset ¶
func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) Reset()
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Size ¶
func (val *ExternalWorkflowExecutionCancelRequestedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) String ¶
func (x *ExternalWorkflowExecutionCancelRequestedEventAttributes) String() string
func (*ExternalWorkflowExecutionCancelRequestedEventAttributes) Unmarshal ¶
func (val *ExternalWorkflowExecutionCancelRequestedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ExternalWorkflowExecutionCancelRequestedEventAttributes from the protobuf v3 wire format
type ExternalWorkflowExecutionSignaledEventAttributes ¶
type ExternalWorkflowExecutionSignaledEventAttributes struct { // id of the `SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED` event this event corresponds to InitiatedEventId int64 `protobuf:"varint,1,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Namespace of the workflow which was signaled. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,5,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` // Deprecated Control string `protobuf:"bytes,4,opt,name=control,proto3" json:"control,omitempty"` // contains filtered or unexported fields }
func (*ExternalWorkflowExecutionSignaledEventAttributes) Descriptor
deprecated
func (*ExternalWorkflowExecutionSignaledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use ExternalWorkflowExecutionSignaledEventAttributes.ProtoReflect.Descriptor instead.
func (*ExternalWorkflowExecutionSignaledEventAttributes) Equal ¶
func (this *ExternalWorkflowExecutionSignaledEventAttributes) Equal(that interface{}) bool
Equal returns whether two ExternalWorkflowExecutionSignaledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ExternalWorkflowExecutionSignaledEventAttributes) GetControl ¶
func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetControl() string
func (*ExternalWorkflowExecutionSignaledEventAttributes) GetInitiatedEventId ¶
func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetInitiatedEventId() int64
func (*ExternalWorkflowExecutionSignaledEventAttributes) GetNamespace ¶
func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetNamespace() string
func (*ExternalWorkflowExecutionSignaledEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetNamespaceId() string
func (*ExternalWorkflowExecutionSignaledEventAttributes) GetWorkflowExecution ¶
func (x *ExternalWorkflowExecutionSignaledEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*ExternalWorkflowExecutionSignaledEventAttributes) Marshal ¶
func (val *ExternalWorkflowExecutionSignaledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type ExternalWorkflowExecutionSignaledEventAttributes to the protobuf v3 wire format
func (*ExternalWorkflowExecutionSignaledEventAttributes) ProtoMessage ¶
func (*ExternalWorkflowExecutionSignaledEventAttributes) ProtoMessage()
func (*ExternalWorkflowExecutionSignaledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *ExternalWorkflowExecutionSignaledEventAttributes) ProtoReflect() protoreflect.Message
func (*ExternalWorkflowExecutionSignaledEventAttributes) Reset ¶
func (x *ExternalWorkflowExecutionSignaledEventAttributes) Reset()
func (*ExternalWorkflowExecutionSignaledEventAttributes) Size ¶
func (val *ExternalWorkflowExecutionSignaledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ExternalWorkflowExecutionSignaledEventAttributes) String ¶
func (x *ExternalWorkflowExecutionSignaledEventAttributes) String() string
func (*ExternalWorkflowExecutionSignaledEventAttributes) Unmarshal ¶
func (val *ExternalWorkflowExecutionSignaledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type ExternalWorkflowExecutionSignaledEventAttributes from the protobuf v3 wire format
type History ¶
type History struct { Events []*HistoryEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*History) Descriptor
deprecated
func (*History) Equal ¶
Equal returns whether two History values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*History) GetEvents ¶
func (x *History) GetEvents() []*HistoryEvent
func (*History) ProtoMessage ¶
func (*History) ProtoMessage()
func (*History) ProtoReflect ¶ added in v1.26.1
func (x *History) ProtoReflect() protoreflect.Message
type HistoryEvent ¶
type HistoryEvent struct { // Monotonically increasing event number, starts at 1. EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` EventTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"` EventType v12.EventType `` /* 126-byte string literal not displayed */ // TODO: What is this? Appears unused by SDKs Version int64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` // TODO: What is this? Appears unused by SDKs TaskId int64 `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // Set to true when the SDK may ignore the event as it does not impact workflow state or // information in any way that the SDK need be concerned with. If an SDK encounters an event // type which it does not understand, it must error unless this is true. If it is true, it's // acceptable for the event type and/or attributes to be uninterpretable. WorkerMayIgnore bool `protobuf:"varint,300,opt,name=worker_may_ignore,json=workerMayIgnore,proto3" json:"worker_may_ignore,omitempty"` // The event details. The type must match that in `event_type`. // // Types that are assignable to Attributes: // // *HistoryEvent_WorkflowExecutionStartedEventAttributes // *HistoryEvent_WorkflowExecutionCompletedEventAttributes // *HistoryEvent_WorkflowExecutionFailedEventAttributes // *HistoryEvent_WorkflowExecutionTimedOutEventAttributes // *HistoryEvent_WorkflowTaskScheduledEventAttributes // *HistoryEvent_WorkflowTaskStartedEventAttributes // *HistoryEvent_WorkflowTaskCompletedEventAttributes // *HistoryEvent_WorkflowTaskTimedOutEventAttributes // *HistoryEvent_WorkflowTaskFailedEventAttributes // *HistoryEvent_ActivityTaskScheduledEventAttributes // *HistoryEvent_ActivityTaskStartedEventAttributes // *HistoryEvent_ActivityTaskCompletedEventAttributes // *HistoryEvent_ActivityTaskFailedEventAttributes // *HistoryEvent_ActivityTaskTimedOutEventAttributes // *HistoryEvent_TimerStartedEventAttributes // *HistoryEvent_TimerFiredEventAttributes // *HistoryEvent_ActivityTaskCancelRequestedEventAttributes // *HistoryEvent_ActivityTaskCanceledEventAttributes // *HistoryEvent_TimerCanceledEventAttributes // *HistoryEvent_MarkerRecordedEventAttributes // *HistoryEvent_WorkflowExecutionSignaledEventAttributes // *HistoryEvent_WorkflowExecutionTerminatedEventAttributes // *HistoryEvent_WorkflowExecutionCancelRequestedEventAttributes // *HistoryEvent_WorkflowExecutionCanceledEventAttributes // *HistoryEvent_RequestCancelExternalWorkflowExecutionInitiatedEventAttributes // *HistoryEvent_RequestCancelExternalWorkflowExecutionFailedEventAttributes // *HistoryEvent_ExternalWorkflowExecutionCancelRequestedEventAttributes // *HistoryEvent_WorkflowExecutionContinuedAsNewEventAttributes // *HistoryEvent_StartChildWorkflowExecutionInitiatedEventAttributes // *HistoryEvent_StartChildWorkflowExecutionFailedEventAttributes // *HistoryEvent_ChildWorkflowExecutionStartedEventAttributes // *HistoryEvent_ChildWorkflowExecutionCompletedEventAttributes // *HistoryEvent_ChildWorkflowExecutionFailedEventAttributes // *HistoryEvent_ChildWorkflowExecutionCanceledEventAttributes // *HistoryEvent_ChildWorkflowExecutionTimedOutEventAttributes // *HistoryEvent_ChildWorkflowExecutionTerminatedEventAttributes // *HistoryEvent_SignalExternalWorkflowExecutionInitiatedEventAttributes // *HistoryEvent_SignalExternalWorkflowExecutionFailedEventAttributes // *HistoryEvent_ExternalWorkflowExecutionSignaledEventAttributes // *HistoryEvent_UpsertWorkflowSearchAttributesEventAttributes // *HistoryEvent_WorkflowExecutionUpdateAcceptedEventAttributes // *HistoryEvent_WorkflowExecutionUpdateRejectedEventAttributes // *HistoryEvent_WorkflowExecutionUpdateCompletedEventAttributes // *HistoryEvent_WorkflowPropertiesModifiedExternallyEventAttributes // *HistoryEvent_ActivityPropertiesModifiedExternallyEventAttributes // *HistoryEvent_WorkflowPropertiesModifiedEventAttributes // *HistoryEvent_WorkflowExecutionUpdateRequestedEventAttributes Attributes isHistoryEvent_Attributes `protobuf_oneof:"attributes"` // contains filtered or unexported fields }
History events are the method by which Temporal SDKs advance (or recreate) workflow state. See the `EventType` enum for more info about what each event is for.
func (*HistoryEvent) Descriptor
deprecated
func (*HistoryEvent) Descriptor() ([]byte, []int)
Deprecated: Use HistoryEvent.ProtoReflect.Descriptor instead.
func (*HistoryEvent) Equal ¶
func (this *HistoryEvent) Equal(that interface{}) bool
Equal returns whether two HistoryEvent values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*HistoryEvent) GetActivityPropertiesModifiedExternallyEventAttributes ¶ added in v1.11.0
func (x *HistoryEvent) GetActivityPropertiesModifiedExternallyEventAttributes() *ActivityPropertiesModifiedExternallyEventAttributes
func (*HistoryEvent) GetActivityTaskCancelRequestedEventAttributes ¶
func (x *HistoryEvent) GetActivityTaskCancelRequestedEventAttributes() *ActivityTaskCancelRequestedEventAttributes
func (*HistoryEvent) GetActivityTaskCanceledEventAttributes ¶
func (x *HistoryEvent) GetActivityTaskCanceledEventAttributes() *ActivityTaskCanceledEventAttributes
func (*HistoryEvent) GetActivityTaskCompletedEventAttributes ¶
func (x *HistoryEvent) GetActivityTaskCompletedEventAttributes() *ActivityTaskCompletedEventAttributes
func (*HistoryEvent) GetActivityTaskFailedEventAttributes ¶
func (x *HistoryEvent) GetActivityTaskFailedEventAttributes() *ActivityTaskFailedEventAttributes
func (*HistoryEvent) GetActivityTaskScheduledEventAttributes ¶
func (x *HistoryEvent) GetActivityTaskScheduledEventAttributes() *ActivityTaskScheduledEventAttributes
func (*HistoryEvent) GetActivityTaskStartedEventAttributes ¶
func (x *HistoryEvent) GetActivityTaskStartedEventAttributes() *ActivityTaskStartedEventAttributes
func (*HistoryEvent) GetActivityTaskTimedOutEventAttributes ¶
func (x *HistoryEvent) GetActivityTaskTimedOutEventAttributes() *ActivityTaskTimedOutEventAttributes
func (*HistoryEvent) GetAttributes ¶
func (m *HistoryEvent) GetAttributes() isHistoryEvent_Attributes
func (*HistoryEvent) GetChildWorkflowExecutionCanceledEventAttributes ¶
func (x *HistoryEvent) GetChildWorkflowExecutionCanceledEventAttributes() *ChildWorkflowExecutionCanceledEventAttributes
func (*HistoryEvent) GetChildWorkflowExecutionCompletedEventAttributes ¶
func (x *HistoryEvent) GetChildWorkflowExecutionCompletedEventAttributes() *ChildWorkflowExecutionCompletedEventAttributes
func (*HistoryEvent) GetChildWorkflowExecutionFailedEventAttributes ¶
func (x *HistoryEvent) GetChildWorkflowExecutionFailedEventAttributes() *ChildWorkflowExecutionFailedEventAttributes
func (*HistoryEvent) GetChildWorkflowExecutionStartedEventAttributes ¶
func (x *HistoryEvent) GetChildWorkflowExecutionStartedEventAttributes() *ChildWorkflowExecutionStartedEventAttributes
func (*HistoryEvent) GetChildWorkflowExecutionTerminatedEventAttributes ¶
func (x *HistoryEvent) GetChildWorkflowExecutionTerminatedEventAttributes() *ChildWorkflowExecutionTerminatedEventAttributes
func (*HistoryEvent) GetChildWorkflowExecutionTimedOutEventAttributes ¶
func (x *HistoryEvent) GetChildWorkflowExecutionTimedOutEventAttributes() *ChildWorkflowExecutionTimedOutEventAttributes
func (*HistoryEvent) GetEventId ¶
func (x *HistoryEvent) GetEventId() int64
func (*HistoryEvent) GetEventTime ¶ added in v0.28.0
func (x *HistoryEvent) GetEventTime() *timestamppb.Timestamp
func (*HistoryEvent) GetEventType ¶
func (x *HistoryEvent) GetEventType() v12.EventType
func (*HistoryEvent) GetExternalWorkflowExecutionCancelRequestedEventAttributes ¶
func (x *HistoryEvent) GetExternalWorkflowExecutionCancelRequestedEventAttributes() *ExternalWorkflowExecutionCancelRequestedEventAttributes
func (*HistoryEvent) GetExternalWorkflowExecutionSignaledEventAttributes ¶
func (x *HistoryEvent) GetExternalWorkflowExecutionSignaledEventAttributes() *ExternalWorkflowExecutionSignaledEventAttributes
func (*HistoryEvent) GetMarkerRecordedEventAttributes ¶
func (x *HistoryEvent) GetMarkerRecordedEventAttributes() *MarkerRecordedEventAttributes
func (*HistoryEvent) GetRequestCancelExternalWorkflowExecutionFailedEventAttributes ¶
func (x *HistoryEvent) GetRequestCancelExternalWorkflowExecutionFailedEventAttributes() *RequestCancelExternalWorkflowExecutionFailedEventAttributes
func (*HistoryEvent) GetRequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶
func (x *HistoryEvent) GetRequestCancelExternalWorkflowExecutionInitiatedEventAttributes() *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
func (*HistoryEvent) GetSignalExternalWorkflowExecutionFailedEventAttributes ¶
func (x *HistoryEvent) GetSignalExternalWorkflowExecutionFailedEventAttributes() *SignalExternalWorkflowExecutionFailedEventAttributes
func (*HistoryEvent) GetSignalExternalWorkflowExecutionInitiatedEventAttributes ¶
func (x *HistoryEvent) GetSignalExternalWorkflowExecutionInitiatedEventAttributes() *SignalExternalWorkflowExecutionInitiatedEventAttributes
func (*HistoryEvent) GetStartChildWorkflowExecutionFailedEventAttributes ¶
func (x *HistoryEvent) GetStartChildWorkflowExecutionFailedEventAttributes() *StartChildWorkflowExecutionFailedEventAttributes
func (*HistoryEvent) GetStartChildWorkflowExecutionInitiatedEventAttributes ¶
func (x *HistoryEvent) GetStartChildWorkflowExecutionInitiatedEventAttributes() *StartChildWorkflowExecutionInitiatedEventAttributes
func (*HistoryEvent) GetTaskId ¶
func (x *HistoryEvent) GetTaskId() int64
func (*HistoryEvent) GetTimerCanceledEventAttributes ¶
func (x *HistoryEvent) GetTimerCanceledEventAttributes() *TimerCanceledEventAttributes
func (*HistoryEvent) GetTimerFiredEventAttributes ¶
func (x *HistoryEvent) GetTimerFiredEventAttributes() *TimerFiredEventAttributes
func (*HistoryEvent) GetTimerStartedEventAttributes ¶
func (x *HistoryEvent) GetTimerStartedEventAttributes() *TimerStartedEventAttributes
func (*HistoryEvent) GetUpsertWorkflowSearchAttributesEventAttributes ¶
func (x *HistoryEvent) GetUpsertWorkflowSearchAttributesEventAttributes() *UpsertWorkflowSearchAttributesEventAttributes
func (*HistoryEvent) GetVersion ¶
func (x *HistoryEvent) GetVersion() int64
func (*HistoryEvent) GetWorkerMayIgnore ¶ added in v1.11.0
func (x *HistoryEvent) GetWorkerMayIgnore() bool
func (*HistoryEvent) GetWorkflowExecutionCancelRequestedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionCancelRequestedEventAttributes() *WorkflowExecutionCancelRequestedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionCanceledEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionCanceledEventAttributes() *WorkflowExecutionCanceledEventAttributes
func (*HistoryEvent) GetWorkflowExecutionCompletedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionCompletedEventAttributes() *WorkflowExecutionCompletedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionContinuedAsNewEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionContinuedAsNewEventAttributes() *WorkflowExecutionContinuedAsNewEventAttributes
func (*HistoryEvent) GetWorkflowExecutionFailedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionFailedEventAttributes() *WorkflowExecutionFailedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionSignaledEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionSignaledEventAttributes() *WorkflowExecutionSignaledEventAttributes
func (*HistoryEvent) GetWorkflowExecutionStartedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionStartedEventAttributes() *WorkflowExecutionStartedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionTerminatedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionTerminatedEventAttributes() *WorkflowExecutionTerminatedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionTimedOutEventAttributes ¶
func (x *HistoryEvent) GetWorkflowExecutionTimedOutEventAttributes() *WorkflowExecutionTimedOutEventAttributes
func (*HistoryEvent) GetWorkflowExecutionUpdateAcceptedEventAttributes ¶ added in v1.16.0
func (x *HistoryEvent) GetWorkflowExecutionUpdateAcceptedEventAttributes() *WorkflowExecutionUpdateAcceptedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionUpdateCompletedEventAttributes ¶ added in v1.16.0
func (x *HistoryEvent) GetWorkflowExecutionUpdateCompletedEventAttributes() *WorkflowExecutionUpdateCompletedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionUpdateRejectedEventAttributes ¶ added in v1.16.0
func (x *HistoryEvent) GetWorkflowExecutionUpdateRejectedEventAttributes() *WorkflowExecutionUpdateRejectedEventAttributes
func (*HistoryEvent) GetWorkflowExecutionUpdateRequestedEventAttributes ¶ added in v1.27.0
func (x *HistoryEvent) GetWorkflowExecutionUpdateRequestedEventAttributes() *WorkflowExecutionUpdateRequestedEventAttributes
func (*HistoryEvent) GetWorkflowPropertiesModifiedEventAttributes ¶ added in v1.12.0
func (x *HistoryEvent) GetWorkflowPropertiesModifiedEventAttributes() *WorkflowPropertiesModifiedEventAttributes
func (*HistoryEvent) GetWorkflowPropertiesModifiedExternallyEventAttributes ¶ added in v1.11.0
func (x *HistoryEvent) GetWorkflowPropertiesModifiedExternallyEventAttributes() *WorkflowPropertiesModifiedExternallyEventAttributes
func (*HistoryEvent) GetWorkflowTaskCompletedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowTaskCompletedEventAttributes() *WorkflowTaskCompletedEventAttributes
func (*HistoryEvent) GetWorkflowTaskFailedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowTaskFailedEventAttributes() *WorkflowTaskFailedEventAttributes
func (*HistoryEvent) GetWorkflowTaskScheduledEventAttributes ¶
func (x *HistoryEvent) GetWorkflowTaskScheduledEventAttributes() *WorkflowTaskScheduledEventAttributes
func (*HistoryEvent) GetWorkflowTaskStartedEventAttributes ¶
func (x *HistoryEvent) GetWorkflowTaskStartedEventAttributes() *WorkflowTaskStartedEventAttributes
func (*HistoryEvent) GetWorkflowTaskTimedOutEventAttributes ¶
func (x *HistoryEvent) GetWorkflowTaskTimedOutEventAttributes() *WorkflowTaskTimedOutEventAttributes
func (*HistoryEvent) Marshal ¶
func (val *HistoryEvent) Marshal() ([]byte, error)
Marshal an object of type HistoryEvent to the protobuf v3 wire format
func (*HistoryEvent) ProtoMessage ¶
func (*HistoryEvent) ProtoMessage()
func (*HistoryEvent) ProtoReflect ¶ added in v1.26.1
func (x *HistoryEvent) ProtoReflect() protoreflect.Message
func (*HistoryEvent) Reset ¶
func (x *HistoryEvent) Reset()
func (*HistoryEvent) Size ¶
func (val *HistoryEvent) Size() int
Size returns the size of the object, in bytes, once serialized
func (*HistoryEvent) String ¶
func (x *HistoryEvent) String() string
func (*HistoryEvent) Unmarshal ¶
func (val *HistoryEvent) Unmarshal(buf []byte) error
Unmarshal an object of type HistoryEvent from the protobuf v3 wire format
type HistoryEvent_ActivityPropertiesModifiedExternallyEventAttributes ¶ added in v1.11.0
type HistoryEvent_ActivityPropertiesModifiedExternallyEventAttributes struct {
ActivityPropertiesModifiedExternallyEventAttributes *ActivityPropertiesModifiedExternallyEventAttributes `` /* 155-byte string literal not displayed */
}
type HistoryEvent_ActivityTaskCancelRequestedEventAttributes ¶
type HistoryEvent_ActivityTaskCancelRequestedEventAttributes struct {
ActivityTaskCancelRequestedEventAttributes *ActivityTaskCancelRequestedEventAttributes `` /* 137-byte string literal not displayed */
}
type HistoryEvent_ActivityTaskCanceledEventAttributes ¶
type HistoryEvent_ActivityTaskCanceledEventAttributes struct {
ActivityTaskCanceledEventAttributes *ActivityTaskCanceledEventAttributes `protobuf:"bytes,23,opt,name=activity_task_canceled_event_attributes,json=activityTaskCanceledEventAttributes,proto3,oneof"`
}
type HistoryEvent_ActivityTaskCompletedEventAttributes ¶
type HistoryEvent_ActivityTaskCompletedEventAttributes struct {
ActivityTaskCompletedEventAttributes *ActivityTaskCompletedEventAttributes `protobuf:"bytes,17,opt,name=activity_task_completed_event_attributes,json=activityTaskCompletedEventAttributes,proto3,oneof"`
}
type HistoryEvent_ActivityTaskFailedEventAttributes ¶
type HistoryEvent_ActivityTaskFailedEventAttributes struct {
ActivityTaskFailedEventAttributes *ActivityTaskFailedEventAttributes `protobuf:"bytes,18,opt,name=activity_task_failed_event_attributes,json=activityTaskFailedEventAttributes,proto3,oneof"`
}
type HistoryEvent_ActivityTaskScheduledEventAttributes ¶
type HistoryEvent_ActivityTaskScheduledEventAttributes struct {
ActivityTaskScheduledEventAttributes *ActivityTaskScheduledEventAttributes `protobuf:"bytes,15,opt,name=activity_task_scheduled_event_attributes,json=activityTaskScheduledEventAttributes,proto3,oneof"`
}
type HistoryEvent_ActivityTaskStartedEventAttributes ¶
type HistoryEvent_ActivityTaskStartedEventAttributes struct {
ActivityTaskStartedEventAttributes *ActivityTaskStartedEventAttributes `protobuf:"bytes,16,opt,name=activity_task_started_event_attributes,json=activityTaskStartedEventAttributes,proto3,oneof"`
}
type HistoryEvent_ActivityTaskTimedOutEventAttributes ¶
type HistoryEvent_ActivityTaskTimedOutEventAttributes struct {
ActivityTaskTimedOutEventAttributes *ActivityTaskTimedOutEventAttributes `protobuf:"bytes,19,opt,name=activity_task_timed_out_event_attributes,json=activityTaskTimedOutEventAttributes,proto3,oneof"`
}
type HistoryEvent_ChildWorkflowExecutionCanceledEventAttributes ¶
type HistoryEvent_ChildWorkflowExecutionCanceledEventAttributes struct {
ChildWorkflowExecutionCanceledEventAttributes *ChildWorkflowExecutionCanceledEventAttributes `` /* 143-byte string literal not displayed */
}
type HistoryEvent_ChildWorkflowExecutionCompletedEventAttributes ¶
type HistoryEvent_ChildWorkflowExecutionCompletedEventAttributes struct {
ChildWorkflowExecutionCompletedEventAttributes *ChildWorkflowExecutionCompletedEventAttributes `` /* 145-byte string literal not displayed */
}
type HistoryEvent_ChildWorkflowExecutionFailedEventAttributes ¶
type HistoryEvent_ChildWorkflowExecutionFailedEventAttributes struct {
ChildWorkflowExecutionFailedEventAttributes *ChildWorkflowExecutionFailedEventAttributes `` /* 139-byte string literal not displayed */
}
type HistoryEvent_ChildWorkflowExecutionStartedEventAttributes ¶
type HistoryEvent_ChildWorkflowExecutionStartedEventAttributes struct {
ChildWorkflowExecutionStartedEventAttributes *ChildWorkflowExecutionStartedEventAttributes `` /* 141-byte string literal not displayed */
}
type HistoryEvent_ChildWorkflowExecutionTerminatedEventAttributes ¶
type HistoryEvent_ChildWorkflowExecutionTerminatedEventAttributes struct {
ChildWorkflowExecutionTerminatedEventAttributes *ChildWorkflowExecutionTerminatedEventAttributes `` /* 147-byte string literal not displayed */
}
type HistoryEvent_ChildWorkflowExecutionTimedOutEventAttributes ¶
type HistoryEvent_ChildWorkflowExecutionTimedOutEventAttributes struct {
ChildWorkflowExecutionTimedOutEventAttributes *ChildWorkflowExecutionTimedOutEventAttributes `` /* 144-byte string literal not displayed */
}
type HistoryEvent_ExternalWorkflowExecutionCancelRequestedEventAttributes ¶
type HistoryEvent_ExternalWorkflowExecutionCancelRequestedEventAttributes struct {
ExternalWorkflowExecutionCancelRequestedEventAttributes *ExternalWorkflowExecutionCancelRequestedEventAttributes `` /* 164-byte string literal not displayed */
}
type HistoryEvent_ExternalWorkflowExecutionSignaledEventAttributes ¶
type HistoryEvent_ExternalWorkflowExecutionSignaledEventAttributes struct {
ExternalWorkflowExecutionSignaledEventAttributes *ExternalWorkflowExecutionSignaledEventAttributes `` /* 149-byte string literal not displayed */
}
type HistoryEvent_MarkerRecordedEventAttributes ¶
type HistoryEvent_MarkerRecordedEventAttributes struct {
MarkerRecordedEventAttributes *MarkerRecordedEventAttributes `protobuf:"bytes,25,opt,name=marker_recorded_event_attributes,json=markerRecordedEventAttributes,proto3,oneof"`
}
type HistoryEvent_RequestCancelExternalWorkflowExecutionFailedEventAttributes ¶
type HistoryEvent_RequestCancelExternalWorkflowExecutionFailedEventAttributes struct {
RequestCancelExternalWorkflowExecutionFailedEventAttributes *RequestCancelExternalWorkflowExecutionFailedEventAttributes `` /* 173-byte string literal not displayed */
}
type HistoryEvent_RequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶
type HistoryEvent_RequestCancelExternalWorkflowExecutionInitiatedEventAttributes struct {
RequestCancelExternalWorkflowExecutionInitiatedEventAttributes *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes `` /* 179-byte string literal not displayed */
}
type HistoryEvent_SignalExternalWorkflowExecutionFailedEventAttributes ¶
type HistoryEvent_SignalExternalWorkflowExecutionFailedEventAttributes struct {
SignalExternalWorkflowExecutionFailedEventAttributes *SignalExternalWorkflowExecutionFailedEventAttributes `` /* 158-byte string literal not displayed */
}
type HistoryEvent_SignalExternalWorkflowExecutionInitiatedEventAttributes ¶
type HistoryEvent_SignalExternalWorkflowExecutionInitiatedEventAttributes struct {
SignalExternalWorkflowExecutionInitiatedEventAttributes *SignalExternalWorkflowExecutionInitiatedEventAttributes `` /* 164-byte string literal not displayed */
}
type HistoryEvent_StartChildWorkflowExecutionFailedEventAttributes ¶
type HistoryEvent_StartChildWorkflowExecutionFailedEventAttributes struct {
StartChildWorkflowExecutionFailedEventAttributes *StartChildWorkflowExecutionFailedEventAttributes `` /* 150-byte string literal not displayed */
}
type HistoryEvent_StartChildWorkflowExecutionInitiatedEventAttributes ¶
type HistoryEvent_StartChildWorkflowExecutionInitiatedEventAttributes struct {
StartChildWorkflowExecutionInitiatedEventAttributes *StartChildWorkflowExecutionInitiatedEventAttributes `` /* 156-byte string literal not displayed */
}
type HistoryEvent_TimerCanceledEventAttributes ¶
type HistoryEvent_TimerCanceledEventAttributes struct {
TimerCanceledEventAttributes *TimerCanceledEventAttributes `protobuf:"bytes,24,opt,name=timer_canceled_event_attributes,json=timerCanceledEventAttributes,proto3,oneof"`
}
type HistoryEvent_TimerFiredEventAttributes ¶
type HistoryEvent_TimerFiredEventAttributes struct {
TimerFiredEventAttributes *TimerFiredEventAttributes `protobuf:"bytes,21,opt,name=timer_fired_event_attributes,json=timerFiredEventAttributes,proto3,oneof"`
}
type HistoryEvent_TimerStartedEventAttributes ¶
type HistoryEvent_TimerStartedEventAttributes struct {
TimerStartedEventAttributes *TimerStartedEventAttributes `protobuf:"bytes,20,opt,name=timer_started_event_attributes,json=timerStartedEventAttributes,proto3,oneof"`
}
type HistoryEvent_UpsertWorkflowSearchAttributesEventAttributes ¶
type HistoryEvent_UpsertWorkflowSearchAttributesEventAttributes struct {
UpsertWorkflowSearchAttributesEventAttributes *UpsertWorkflowSearchAttributesEventAttributes `` /* 143-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionCancelRequestedEventAttributes ¶
type HistoryEvent_WorkflowExecutionCancelRequestedEventAttributes struct {
WorkflowExecutionCancelRequestedEventAttributes *WorkflowExecutionCancelRequestedEventAttributes `` /* 147-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionCanceledEventAttributes ¶
type HistoryEvent_WorkflowExecutionCanceledEventAttributes struct {
WorkflowExecutionCanceledEventAttributes *WorkflowExecutionCanceledEventAttributes `` /* 132-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionCompletedEventAttributes ¶
type HistoryEvent_WorkflowExecutionCompletedEventAttributes struct {
WorkflowExecutionCompletedEventAttributes *WorkflowExecutionCompletedEventAttributes `` /* 133-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionContinuedAsNewEventAttributes ¶
type HistoryEvent_WorkflowExecutionContinuedAsNewEventAttributes struct {
WorkflowExecutionContinuedAsNewEventAttributes *WorkflowExecutionContinuedAsNewEventAttributes `` /* 146-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionFailedEventAttributes ¶
type HistoryEvent_WorkflowExecutionFailedEventAttributes struct {
WorkflowExecutionFailedEventAttributes *WorkflowExecutionFailedEventAttributes `` /* 127-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionSignaledEventAttributes ¶
type HistoryEvent_WorkflowExecutionSignaledEventAttributes struct {
WorkflowExecutionSignaledEventAttributes *WorkflowExecutionSignaledEventAttributes `` /* 132-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionStartedEventAttributes ¶
type HistoryEvent_WorkflowExecutionStartedEventAttributes struct {
WorkflowExecutionStartedEventAttributes *WorkflowExecutionStartedEventAttributes `` /* 129-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionTerminatedEventAttributes ¶
type HistoryEvent_WorkflowExecutionTerminatedEventAttributes struct {
WorkflowExecutionTerminatedEventAttributes *WorkflowExecutionTerminatedEventAttributes `` /* 136-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionTimedOutEventAttributes ¶
type HistoryEvent_WorkflowExecutionTimedOutEventAttributes struct {
WorkflowExecutionTimedOutEventAttributes *WorkflowExecutionTimedOutEventAttributes `` /* 132-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionUpdateAcceptedEventAttributes ¶ added in v1.16.0
type HistoryEvent_WorkflowExecutionUpdateAcceptedEventAttributes struct {
WorkflowExecutionUpdateAcceptedEventAttributes *WorkflowExecutionUpdateAcceptedEventAttributes `` /* 145-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionUpdateCompletedEventAttributes ¶ added in v1.16.0
type HistoryEvent_WorkflowExecutionUpdateCompletedEventAttributes struct {
WorkflowExecutionUpdateCompletedEventAttributes *WorkflowExecutionUpdateCompletedEventAttributes `` /* 147-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionUpdateRejectedEventAttributes ¶ added in v1.16.0
type HistoryEvent_WorkflowExecutionUpdateRejectedEventAttributes struct {
WorkflowExecutionUpdateRejectedEventAttributes *WorkflowExecutionUpdateRejectedEventAttributes `` /* 145-byte string literal not displayed */
}
type HistoryEvent_WorkflowExecutionUpdateRequestedEventAttributes ¶ added in v1.27.0
type HistoryEvent_WorkflowExecutionUpdateRequestedEventAttributes struct {
WorkflowExecutionUpdateRequestedEventAttributes *WorkflowExecutionUpdateRequestedEventAttributes `` /* 147-byte string literal not displayed */
}
type HistoryEvent_WorkflowPropertiesModifiedEventAttributes ¶ added in v1.12.0
type HistoryEvent_WorkflowPropertiesModifiedEventAttributes struct {
WorkflowPropertiesModifiedEventAttributes *WorkflowPropertiesModifiedEventAttributes `` /* 134-byte string literal not displayed */
}
type HistoryEvent_WorkflowPropertiesModifiedExternallyEventAttributes ¶ added in v1.11.0
type HistoryEvent_WorkflowPropertiesModifiedExternallyEventAttributes struct {
WorkflowPropertiesModifiedExternallyEventAttributes *WorkflowPropertiesModifiedExternallyEventAttributes `` /* 155-byte string literal not displayed */
}
type HistoryEvent_WorkflowTaskCompletedEventAttributes ¶
type HistoryEvent_WorkflowTaskCompletedEventAttributes struct {
WorkflowTaskCompletedEventAttributes *WorkflowTaskCompletedEventAttributes `protobuf:"bytes,12,opt,name=workflow_task_completed_event_attributes,json=workflowTaskCompletedEventAttributes,proto3,oneof"`
}
type HistoryEvent_WorkflowTaskFailedEventAttributes ¶
type HistoryEvent_WorkflowTaskFailedEventAttributes struct {
WorkflowTaskFailedEventAttributes *WorkflowTaskFailedEventAttributes `protobuf:"bytes,14,opt,name=workflow_task_failed_event_attributes,json=workflowTaskFailedEventAttributes,proto3,oneof"`
}
type HistoryEvent_WorkflowTaskScheduledEventAttributes ¶
type HistoryEvent_WorkflowTaskScheduledEventAttributes struct {
WorkflowTaskScheduledEventAttributes *WorkflowTaskScheduledEventAttributes `protobuf:"bytes,10,opt,name=workflow_task_scheduled_event_attributes,json=workflowTaskScheduledEventAttributes,proto3,oneof"`
}
type HistoryEvent_WorkflowTaskStartedEventAttributes ¶
type HistoryEvent_WorkflowTaskStartedEventAttributes struct {
WorkflowTaskStartedEventAttributes *WorkflowTaskStartedEventAttributes `protobuf:"bytes,11,opt,name=workflow_task_started_event_attributes,json=workflowTaskStartedEventAttributes,proto3,oneof"`
}
type HistoryEvent_WorkflowTaskTimedOutEventAttributes ¶
type HistoryEvent_WorkflowTaskTimedOutEventAttributes struct {
WorkflowTaskTimedOutEventAttributes *WorkflowTaskTimedOutEventAttributes `protobuf:"bytes,13,opt,name=workflow_task_timed_out_event_attributes,json=workflowTaskTimedOutEventAttributes,proto3,oneof"`
}
type MarkerRecordedEventAttributes ¶
type MarkerRecordedEventAttributes struct { // Workers use this to identify the "types" of various markers. Ex: Local activity, side effect. MarkerName string `protobuf:"bytes,1,opt,name=marker_name,json=markerName,proto3" json:"marker_name,omitempty"` // Serialized information recorded in the marker Details map[string]*v1.Payloads `` /* 155-byte string literal not displayed */ // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ Header *v1.Header `protobuf:"bytes,4,opt,name=header,proto3" json:"header,omitempty"` // Some uses of markers, like a local activity, could "fail". If they did that is recorded here. Failure *v13.Failure `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"` // contains filtered or unexported fields }
func (*MarkerRecordedEventAttributes) Descriptor
deprecated
func (*MarkerRecordedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use MarkerRecordedEventAttributes.ProtoReflect.Descriptor instead.
func (*MarkerRecordedEventAttributes) Equal ¶
func (this *MarkerRecordedEventAttributes) Equal(that interface{}) bool
Equal returns whether two MarkerRecordedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*MarkerRecordedEventAttributes) GetDetails ¶
func (x *MarkerRecordedEventAttributes) GetDetails() map[string]*v1.Payloads
func (*MarkerRecordedEventAttributes) GetFailure ¶
func (x *MarkerRecordedEventAttributes) GetFailure() *v13.Failure
func (*MarkerRecordedEventAttributes) GetHeader ¶
func (x *MarkerRecordedEventAttributes) GetHeader() *v1.Header
func (*MarkerRecordedEventAttributes) GetMarkerName ¶
func (x *MarkerRecordedEventAttributes) GetMarkerName() string
func (*MarkerRecordedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *MarkerRecordedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*MarkerRecordedEventAttributes) Marshal ¶
func (val *MarkerRecordedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type MarkerRecordedEventAttributes to the protobuf v3 wire format
func (*MarkerRecordedEventAttributes) ProtoMessage ¶
func (*MarkerRecordedEventAttributes) ProtoMessage()
func (*MarkerRecordedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *MarkerRecordedEventAttributes) ProtoReflect() protoreflect.Message
func (*MarkerRecordedEventAttributes) Reset ¶
func (x *MarkerRecordedEventAttributes) Reset()
func (*MarkerRecordedEventAttributes) Size ¶
func (val *MarkerRecordedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*MarkerRecordedEventAttributes) String ¶
func (x *MarkerRecordedEventAttributes) String() string
func (*MarkerRecordedEventAttributes) Unmarshal ¶
func (val *MarkerRecordedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type MarkerRecordedEventAttributes from the protobuf v3 wire format
type RequestCancelExternalWorkflowExecutionFailedEventAttributes ¶
type RequestCancelExternalWorkflowExecutionFailedEventAttributes struct { Cause v12.CancelExternalWorkflowExecutionFailedCause `` /* 134-byte string literal not displayed */ // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // Namespace of the workflow which failed to cancel. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,7,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,4,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` // id of the `REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED` event this failure // corresponds to InitiatedEventId int64 `protobuf:"varint,5,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Deprecated Control string `protobuf:"bytes,6,opt,name=control,proto3" json:"control,omitempty"` // contains filtered or unexported fields }
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Descriptor
deprecated
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use RequestCancelExternalWorkflowExecutionFailedEventAttributes.ProtoReflect.Descriptor instead.
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Equal ¶
func (this *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
Equal returns whether two RequestCancelExternalWorkflowExecutionFailedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetControl ¶
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetControl() string
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventId ¶
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetNamespace ¶
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetNamespace() string
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution ¶
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Marshal ¶
func (val *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type RequestCancelExternalWorkflowExecutionFailedEventAttributes to the protobuf v3 wire format
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) ProtoMessage ¶
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) ProtoMessage()
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Reset ¶
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Reset()
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Size ¶
func (val *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) String ¶
func (x *RequestCancelExternalWorkflowExecutionFailedEventAttributes) String() string
func (*RequestCancelExternalWorkflowExecutionFailedEventAttributes) Unmarshal ¶
func (val *RequestCancelExternalWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type RequestCancelExternalWorkflowExecutionFailedEventAttributes from the protobuf v3 wire format
type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes ¶
type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes struct { // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // The namespace the workflow to be cancelled lives in. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,7,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` // Deprecated Control string `protobuf:"bytes,4,opt,name=control,proto3" json:"control,omitempty"` // Workers are expected to set this to true if the workflow they are requesting to cancel is // a child of the workflow which issued the request ChildWorkflowOnly bool `protobuf:"varint,5,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"` // Reason for requesting the cancellation Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Descriptor
deprecated
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use RequestCancelExternalWorkflowExecutionInitiatedEventAttributes.ProtoReflect.Descriptor instead.
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Equal ¶
func (this *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Equal(that interface{}) bool
Equal returns whether two RequestCancelExternalWorkflowExecutionInitiatedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly ¶
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() bool
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetControl ¶
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetControl() string
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetNamespace ¶
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetNamespace() string
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetNamespaceId() string
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetReason ¶ added in v1.8.0
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetReason() string
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution ¶
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Marshal ¶
func (val *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes to the protobuf v3 wire format
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) ProtoMessage ¶
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) ProtoMessage()
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) ProtoReflect() protoreflect.Message
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Reset ¶
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Reset()
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Size ¶
func (val *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) String ¶
func (x *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) String() string
func (*RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Unmarshal ¶
func (val *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes from the protobuf v3 wire format
type SignalExternalWorkflowExecutionFailedEventAttributes ¶
type SignalExternalWorkflowExecutionFailedEventAttributes struct { Cause v12.SignalExternalWorkflowExecutionFailedCause `` /* 134-byte string literal not displayed */ // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // Namespace of the workflow which failed the signal. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,7,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,4,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` InitiatedEventId int64 `protobuf:"varint,5,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // Deprecated Control string `protobuf:"bytes,6,opt,name=control,proto3" json:"control,omitempty"` // contains filtered or unexported fields }
func (*SignalExternalWorkflowExecutionFailedEventAttributes) Descriptor
deprecated
func (*SignalExternalWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use SignalExternalWorkflowExecutionFailedEventAttributes.ProtoReflect.Descriptor instead.
func (*SignalExternalWorkflowExecutionFailedEventAttributes) Equal ¶
func (this *SignalExternalWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
Equal returns whether two SignalExternalWorkflowExecutionFailedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*SignalExternalWorkflowExecutionFailedEventAttributes) GetControl ¶
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetControl() string
func (*SignalExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventId ¶
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
func (*SignalExternalWorkflowExecutionFailedEventAttributes) GetNamespace ¶
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetNamespace() string
func (*SignalExternalWorkflowExecutionFailedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
func (*SignalExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution ¶
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*SignalExternalWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*SignalExternalWorkflowExecutionFailedEventAttributes) Marshal ¶
func (val *SignalExternalWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type SignalExternalWorkflowExecutionFailedEventAttributes to the protobuf v3 wire format
func (*SignalExternalWorkflowExecutionFailedEventAttributes) ProtoMessage ¶
func (*SignalExternalWorkflowExecutionFailedEventAttributes) ProtoMessage()
func (*SignalExternalWorkflowExecutionFailedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
func (*SignalExternalWorkflowExecutionFailedEventAttributes) Reset ¶
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) Reset()
func (*SignalExternalWorkflowExecutionFailedEventAttributes) Size ¶
func (val *SignalExternalWorkflowExecutionFailedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SignalExternalWorkflowExecutionFailedEventAttributes) String ¶
func (x *SignalExternalWorkflowExecutionFailedEventAttributes) String() string
func (*SignalExternalWorkflowExecutionFailedEventAttributes) Unmarshal ¶
func (val *SignalExternalWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type SignalExternalWorkflowExecutionFailedEventAttributes from the protobuf v3 wire format
type SignalExternalWorkflowExecutionInitiatedEventAttributes ¶
type SignalExternalWorkflowExecutionInitiatedEventAttributes struct { // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // Namespace of the to-be-signalled workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,9,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,3,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"` // name/type of the signal to fire in the external workflow SignalName string `protobuf:"bytes,4,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"` // Serialized arguments to provide to the signal handler Input *v1.Payloads `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"` // Deprecated Control string `protobuf:"bytes,6,opt,name=control,proto3" json:"control,omitempty"` // Workers are expected to set this to true if the workflow they are requesting to cancel is // a child of the workflow which issued the request ChildWorkflowOnly bool `protobuf:"varint,7,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"` Header *v1.Header `protobuf:"bytes,8,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Descriptor
deprecated
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use SignalExternalWorkflowExecutionInitiatedEventAttributes.ProtoReflect.Descriptor instead.
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Equal ¶
func (this *SignalExternalWorkflowExecutionInitiatedEventAttributes) Equal(that interface{}) bool
Equal returns whether two SignalExternalWorkflowExecutionInitiatedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() bool
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetControl ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetControl() string
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetHeader ¶ added in v1.7.0
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetHeader() *v1.Header
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetInput ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetInput() *v1.Payloads
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetNamespace ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetNamespace() string
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetNamespaceId() string
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetSignalName ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetSignalName() string
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Marshal ¶
func (val *SignalExternalWorkflowExecutionInitiatedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type SignalExternalWorkflowExecutionInitiatedEventAttributes to the protobuf v3 wire format
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) ProtoMessage ¶
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) ProtoMessage()
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) ProtoReflect() protoreflect.Message
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Reset ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) Reset()
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Size ¶
func (val *SignalExternalWorkflowExecutionInitiatedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) String ¶
func (x *SignalExternalWorkflowExecutionInitiatedEventAttributes) String() string
func (*SignalExternalWorkflowExecutionInitiatedEventAttributes) Unmarshal ¶
func (val *SignalExternalWorkflowExecutionInitiatedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type SignalExternalWorkflowExecutionInitiatedEventAttributes from the protobuf v3 wire format
type StartChildWorkflowExecutionFailedEventAttributes ¶
type StartChildWorkflowExecutionFailedEventAttributes struct { // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,8,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` Cause v12.StartChildWorkflowExecutionFailedCause `` /* 130-byte string literal not displayed */ // Deprecated Control string `protobuf:"bytes,5,opt,name=control,proto3" json:"control,omitempty"` // Id of the `START_CHILD_WORKFLOW_EXECUTION_INITIATED` event which this event corresponds to InitiatedEventId int64 `protobuf:"varint,6,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StartChildWorkflowExecutionFailedEventAttributes) Descriptor
deprecated
func (*StartChildWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use StartChildWorkflowExecutionFailedEventAttributes.ProtoReflect.Descriptor instead.
func (*StartChildWorkflowExecutionFailedEventAttributes) Equal ¶
func (this *StartChildWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
Equal returns whether two StartChildWorkflowExecutionFailedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*StartChildWorkflowExecutionFailedEventAttributes) GetCause ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetCause() v12.StartChildWorkflowExecutionFailedCause
func (*StartChildWorkflowExecutionFailedEventAttributes) GetControl ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetControl() string
func (*StartChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64
func (*StartChildWorkflowExecutionFailedEventAttributes) GetNamespace ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetNamespace() string
func (*StartChildWorkflowExecutionFailedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetNamespaceId() string
func (*StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowId ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowId() string
func (*StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowType ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*StartChildWorkflowExecutionFailedEventAttributes) Marshal ¶
func (val *StartChildWorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type StartChildWorkflowExecutionFailedEventAttributes to the protobuf v3 wire format
func (*StartChildWorkflowExecutionFailedEventAttributes) ProtoMessage ¶
func (*StartChildWorkflowExecutionFailedEventAttributes) ProtoMessage()
func (*StartChildWorkflowExecutionFailedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *StartChildWorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
func (*StartChildWorkflowExecutionFailedEventAttributes) Reset ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) Reset()
func (*StartChildWorkflowExecutionFailedEventAttributes) Size ¶
func (val *StartChildWorkflowExecutionFailedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*StartChildWorkflowExecutionFailedEventAttributes) String ¶
func (x *StartChildWorkflowExecutionFailedEventAttributes) String() string
func (*StartChildWorkflowExecutionFailedEventAttributes) Unmarshal ¶
func (val *StartChildWorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type StartChildWorkflowExecutionFailedEventAttributes from the protobuf v3 wire format
type StartChildWorkflowExecutionInitiatedEventAttributes ¶
type StartChildWorkflowExecutionInitiatedEventAttributes struct { // Namespace of the child workflow. // SDKs and UI tools should use `namespace` field but server must use `namespace_id` only. Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` NamespaceId string `protobuf:"bytes,18,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` TaskQueue *v11.TaskQueue `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` Input *v1.Payloads `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"` // Total workflow execution timeout including retries and continue as new. WorkflowExecutionTimeout *durationpb.Duration `` /* 135-byte string literal not displayed */ // Timeout of a single workflow run. WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"` // Timeout of a single workflow task. WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"` // Default: PARENT_CLOSE_POLICY_TERMINATE. ParentClosePolicy v12.ParentClosePolicy `` /* 160-byte string literal not displayed */ // Deprecated Control string `protobuf:"bytes,10,opt,name=control,proto3" json:"control,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 153-byte string literal not displayed */ // Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE. WorkflowIdReusePolicy v12.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */ RetryPolicy *v1.RetryPolicy `protobuf:"bytes,13,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` // If this child runs on a cron schedule, it will appear here CronSchedule string `protobuf:"bytes,14,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"` Header *v1.Header `protobuf:"bytes,15,opt,name=header,proto3" json:"header,omitempty"` Memo *v1.Memo `protobuf:"bytes,16,opt,name=memo,proto3" json:"memo,omitempty"` SearchAttributes *v1.SearchAttributes `protobuf:"bytes,17,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"` // If this is set, the workflow executing this command wishes to start the child workflow using // a version compatible with the version that this workflow most recently ran on, if such // behavior is possible. UseCompatibleVersion bool `protobuf:"varint,19,opt,name=use_compatible_version,json=useCompatibleVersion,proto3" json:"use_compatible_version,omitempty"` // contains filtered or unexported fields }
func (*StartChildWorkflowExecutionInitiatedEventAttributes) Descriptor
deprecated
func (*StartChildWorkflowExecutionInitiatedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use StartChildWorkflowExecutionInitiatedEventAttributes.ProtoReflect.Descriptor instead.
func (*StartChildWorkflowExecutionInitiatedEventAttributes) Equal ¶
func (this *StartChildWorkflowExecutionInitiatedEventAttributes) Equal(that interface{}) bool
Equal returns whether two StartChildWorkflowExecutionInitiatedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetControl ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetControl() string
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetCronSchedule ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetCronSchedule() string
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetHeader ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetHeader() *v1.Header
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetInput ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetInput() *v1.Payloads
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetMemo ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetMemo() *v1.Memo
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetNamespace ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetNamespace() string
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetNamespaceId ¶ added in v1.8.0
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetNamespaceId() string
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetParentClosePolicy ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetParentClosePolicy() v12.ParentClosePolicy
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetRetryPolicy ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetRetryPolicy() *v1.RetryPolicy
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetSearchAttributes ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetSearchAttributes() *v1.SearchAttributes
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetTaskQueue ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetTaskQueue() *v11.TaskQueue
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetUseCompatibleVersion ¶ added in v1.21.0
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetUseCompatibleVersion() bool
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecutionTimeout ¶ added in v0.28.0
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecutionTimeout() *durationpb.Duration
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowId ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowId() string
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowIdReusePolicy ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowIdReusePolicy() v12.WorkflowIdReusePolicy
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowRunTimeout ¶ added in v0.28.0
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowRunTimeout() *durationpb.Duration
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskTimeout ¶ added in v0.28.0
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowTaskTimeout() *durationpb.Duration
func (*StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowType ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*StartChildWorkflowExecutionInitiatedEventAttributes) Marshal ¶
func (val *StartChildWorkflowExecutionInitiatedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type StartChildWorkflowExecutionInitiatedEventAttributes to the protobuf v3 wire format
func (*StartChildWorkflowExecutionInitiatedEventAttributes) ProtoMessage ¶
func (*StartChildWorkflowExecutionInitiatedEventAttributes) ProtoMessage()
func (*StartChildWorkflowExecutionInitiatedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) ProtoReflect() protoreflect.Message
func (*StartChildWorkflowExecutionInitiatedEventAttributes) Reset ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) Reset()
func (*StartChildWorkflowExecutionInitiatedEventAttributes) Size ¶
func (val *StartChildWorkflowExecutionInitiatedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*StartChildWorkflowExecutionInitiatedEventAttributes) String ¶
func (x *StartChildWorkflowExecutionInitiatedEventAttributes) String() string
func (*StartChildWorkflowExecutionInitiatedEventAttributes) Unmarshal ¶
func (val *StartChildWorkflowExecutionInitiatedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type StartChildWorkflowExecutionInitiatedEventAttributes from the protobuf v3 wire format
type TimerCanceledEventAttributes ¶
type TimerCanceledEventAttributes struct { // Will match the `timer_id` from `TIMER_STARTED` event for this timer TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"` // The id of the `TIMER_STARTED` event itself StartedEventId int64 `protobuf:"varint,2,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // The id of the worker who requested this cancel Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"` // contains filtered or unexported fields }
func (*TimerCanceledEventAttributes) Descriptor
deprecated
func (*TimerCanceledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use TimerCanceledEventAttributes.ProtoReflect.Descriptor instead.
func (*TimerCanceledEventAttributes) Equal ¶
func (this *TimerCanceledEventAttributes) Equal(that interface{}) bool
Equal returns whether two TimerCanceledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*TimerCanceledEventAttributes) GetIdentity ¶
func (x *TimerCanceledEventAttributes) GetIdentity() string
func (*TimerCanceledEventAttributes) GetStartedEventId ¶
func (x *TimerCanceledEventAttributes) GetStartedEventId() int64
func (*TimerCanceledEventAttributes) GetTimerId ¶
func (x *TimerCanceledEventAttributes) GetTimerId() string
func (*TimerCanceledEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *TimerCanceledEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*TimerCanceledEventAttributes) Marshal ¶
func (val *TimerCanceledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type TimerCanceledEventAttributes to the protobuf v3 wire format
func (*TimerCanceledEventAttributes) ProtoMessage ¶
func (*TimerCanceledEventAttributes) ProtoMessage()
func (*TimerCanceledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *TimerCanceledEventAttributes) ProtoReflect() protoreflect.Message
func (*TimerCanceledEventAttributes) Reset ¶
func (x *TimerCanceledEventAttributes) Reset()
func (*TimerCanceledEventAttributes) Size ¶
func (val *TimerCanceledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*TimerCanceledEventAttributes) String ¶
func (x *TimerCanceledEventAttributes) String() string
func (*TimerCanceledEventAttributes) Unmarshal ¶
func (val *TimerCanceledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type TimerCanceledEventAttributes from the protobuf v3 wire format
type TimerFiredEventAttributes ¶
type TimerFiredEventAttributes struct { // Will match the `timer_id` from `TIMER_STARTED` event for this timer TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"` // The id of the `TIMER_STARTED` event itself StartedEventId int64 `protobuf:"varint,2,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // contains filtered or unexported fields }
func (*TimerFiredEventAttributes) Descriptor
deprecated
func (*TimerFiredEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use TimerFiredEventAttributes.ProtoReflect.Descriptor instead.
func (*TimerFiredEventAttributes) Equal ¶
func (this *TimerFiredEventAttributes) Equal(that interface{}) bool
Equal returns whether two TimerFiredEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*TimerFiredEventAttributes) GetStartedEventId ¶
func (x *TimerFiredEventAttributes) GetStartedEventId() int64
func (*TimerFiredEventAttributes) GetTimerId ¶
func (x *TimerFiredEventAttributes) GetTimerId() string
func (*TimerFiredEventAttributes) Marshal ¶
func (val *TimerFiredEventAttributes) Marshal() ([]byte, error)
Marshal an object of type TimerFiredEventAttributes to the protobuf v3 wire format
func (*TimerFiredEventAttributes) ProtoMessage ¶
func (*TimerFiredEventAttributes) ProtoMessage()
func (*TimerFiredEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *TimerFiredEventAttributes) ProtoReflect() protoreflect.Message
func (*TimerFiredEventAttributes) Reset ¶
func (x *TimerFiredEventAttributes) Reset()
func (*TimerFiredEventAttributes) Size ¶
func (val *TimerFiredEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*TimerFiredEventAttributes) String ¶
func (x *TimerFiredEventAttributes) String() string
func (*TimerFiredEventAttributes) Unmarshal ¶
func (val *TimerFiredEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type TimerFiredEventAttributes from the protobuf v3 wire format
type TimerStartedEventAttributes ¶
type TimerStartedEventAttributes struct { // The worker/user assigned id for this timer TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"` // How long until this timer fires // // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: "to" is used to indicate interval. --) StartToFireTimeout *durationpb.Duration `protobuf:"bytes,2,opt,name=start_to_fire_timeout,json=startToFireTimeout,proto3" json:"start_to_fire_timeout,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TimerStartedEventAttributes) Descriptor
deprecated
func (*TimerStartedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use TimerStartedEventAttributes.ProtoReflect.Descriptor instead.
func (*TimerStartedEventAttributes) Equal ¶
func (this *TimerStartedEventAttributes) Equal(that interface{}) bool
Equal returns whether two TimerStartedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*TimerStartedEventAttributes) GetStartToFireTimeout ¶ added in v0.28.0
func (x *TimerStartedEventAttributes) GetStartToFireTimeout() *durationpb.Duration
func (*TimerStartedEventAttributes) GetTimerId ¶
func (x *TimerStartedEventAttributes) GetTimerId() string
func (*TimerStartedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *TimerStartedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*TimerStartedEventAttributes) Marshal ¶
func (val *TimerStartedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type TimerStartedEventAttributes to the protobuf v3 wire format
func (*TimerStartedEventAttributes) ProtoMessage ¶
func (*TimerStartedEventAttributes) ProtoMessage()
func (*TimerStartedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *TimerStartedEventAttributes) ProtoReflect() protoreflect.Message
func (*TimerStartedEventAttributes) Reset ¶
func (x *TimerStartedEventAttributes) Reset()
func (*TimerStartedEventAttributes) Size ¶
func (val *TimerStartedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*TimerStartedEventAttributes) String ¶
func (x *TimerStartedEventAttributes) String() string
func (*TimerStartedEventAttributes) Unmarshal ¶
func (val *TimerStartedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type TimerStartedEventAttributes from the protobuf v3 wire format
type UpsertWorkflowSearchAttributesEventAttributes ¶
type UpsertWorkflowSearchAttributesEventAttributes struct { // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ SearchAttributes *v1.SearchAttributes `protobuf:"bytes,2,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"` // contains filtered or unexported fields }
func (*UpsertWorkflowSearchAttributesEventAttributes) Descriptor
deprecated
func (*UpsertWorkflowSearchAttributesEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use UpsertWorkflowSearchAttributesEventAttributes.ProtoReflect.Descriptor instead.
func (*UpsertWorkflowSearchAttributesEventAttributes) Equal ¶
func (this *UpsertWorkflowSearchAttributesEventAttributes) Equal(that interface{}) bool
Equal returns whether two UpsertWorkflowSearchAttributesEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*UpsertWorkflowSearchAttributesEventAttributes) GetSearchAttributes ¶
func (x *UpsertWorkflowSearchAttributesEventAttributes) GetSearchAttributes() *v1.SearchAttributes
func (*UpsertWorkflowSearchAttributesEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *UpsertWorkflowSearchAttributesEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*UpsertWorkflowSearchAttributesEventAttributes) Marshal ¶
func (val *UpsertWorkflowSearchAttributesEventAttributes) Marshal() ([]byte, error)
Marshal an object of type UpsertWorkflowSearchAttributesEventAttributes to the protobuf v3 wire format
func (*UpsertWorkflowSearchAttributesEventAttributes) ProtoMessage ¶
func (*UpsertWorkflowSearchAttributesEventAttributes) ProtoMessage()
func (*UpsertWorkflowSearchAttributesEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *UpsertWorkflowSearchAttributesEventAttributes) ProtoReflect() protoreflect.Message
func (*UpsertWorkflowSearchAttributesEventAttributes) Reset ¶
func (x *UpsertWorkflowSearchAttributesEventAttributes) Reset()
func (*UpsertWorkflowSearchAttributesEventAttributes) Size ¶
func (val *UpsertWorkflowSearchAttributesEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*UpsertWorkflowSearchAttributesEventAttributes) String ¶
func (x *UpsertWorkflowSearchAttributesEventAttributes) String() string
func (*UpsertWorkflowSearchAttributesEventAttributes) Unmarshal ¶
func (val *UpsertWorkflowSearchAttributesEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type UpsertWorkflowSearchAttributesEventAttributes from the protobuf v3 wire format
type WorkflowExecutionCancelRequestedEventAttributes ¶
type WorkflowExecutionCancelRequestedEventAttributes struct { // User provided reason for requesting cancellation // TODO: shall we create a new field with name "reason" and deprecate this one? Cause string `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"` // TODO: Is this the ID of the event in the workflow which initiated this cancel, if there was one? ExternalInitiatedEventId int64 `` /* 138-byte string literal not displayed */ ExternalWorkflowExecution *v1.WorkflowExecution `` /* 138-byte string literal not displayed */ // id of the worker or client who requested this cancel Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionCancelRequestedEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionCancelRequestedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionCancelRequestedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionCancelRequestedEventAttributes) Equal ¶
func (this *WorkflowExecutionCancelRequestedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionCancelRequestedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionCancelRequestedEventAttributes) GetCause ¶
func (x *WorkflowExecutionCancelRequestedEventAttributes) GetCause() string
func (*WorkflowExecutionCancelRequestedEventAttributes) GetExternalInitiatedEventId ¶
func (x *WorkflowExecutionCancelRequestedEventAttributes) GetExternalInitiatedEventId() int64
func (*WorkflowExecutionCancelRequestedEventAttributes) GetExternalWorkflowExecution ¶
func (x *WorkflowExecutionCancelRequestedEventAttributes) GetExternalWorkflowExecution() *v1.WorkflowExecution
func (*WorkflowExecutionCancelRequestedEventAttributes) GetIdentity ¶
func (x *WorkflowExecutionCancelRequestedEventAttributes) GetIdentity() string
func (*WorkflowExecutionCancelRequestedEventAttributes) Marshal ¶
func (val *WorkflowExecutionCancelRequestedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionCancelRequestedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionCancelRequestedEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionCancelRequestedEventAttributes) ProtoMessage()
func (*WorkflowExecutionCancelRequestedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionCancelRequestedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionCancelRequestedEventAttributes) Reset ¶
func (x *WorkflowExecutionCancelRequestedEventAttributes) Reset()
func (*WorkflowExecutionCancelRequestedEventAttributes) Size ¶
func (val *WorkflowExecutionCancelRequestedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionCancelRequestedEventAttributes) String ¶
func (x *WorkflowExecutionCancelRequestedEventAttributes) String() string
func (*WorkflowExecutionCancelRequestedEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionCancelRequestedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionCancelRequestedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionCanceledEventAttributes ¶
type WorkflowExecutionCanceledEventAttributes struct { // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ Details *v1.Payloads `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionCanceledEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionCanceledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionCanceledEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionCanceledEventAttributes) Equal ¶
func (this *WorkflowExecutionCanceledEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionCanceledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionCanceledEventAttributes) GetDetails ¶
func (x *WorkflowExecutionCanceledEventAttributes) GetDetails() *v1.Payloads
func (*WorkflowExecutionCanceledEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *WorkflowExecutionCanceledEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*WorkflowExecutionCanceledEventAttributes) Marshal ¶
func (val *WorkflowExecutionCanceledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionCanceledEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionCanceledEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionCanceledEventAttributes) ProtoMessage()
func (*WorkflowExecutionCanceledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionCanceledEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionCanceledEventAttributes) Reset ¶
func (x *WorkflowExecutionCanceledEventAttributes) Reset()
func (*WorkflowExecutionCanceledEventAttributes) Size ¶
func (val *WorkflowExecutionCanceledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionCanceledEventAttributes) String ¶
func (x *WorkflowExecutionCanceledEventAttributes) String() string
func (*WorkflowExecutionCanceledEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionCanceledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionCanceledEventAttributes from the protobuf v3 wire format
type WorkflowExecutionCompletedEventAttributes ¶
type WorkflowExecutionCompletedEventAttributes struct { // Serialized result of workflow completion (ie: The return value of the workflow function) Result *v1.Payloads `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // If another run is started by cron, this contains the new run id. NewExecutionRunId string `protobuf:"bytes,3,opt,name=new_execution_run_id,json=newExecutionRunId,proto3" json:"new_execution_run_id,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionCompletedEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionCompletedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionCompletedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionCompletedEventAttributes) Equal ¶
func (this *WorkflowExecutionCompletedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionCompletedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionCompletedEventAttributes) GetNewExecutionRunId ¶ added in v1.5.0
func (x *WorkflowExecutionCompletedEventAttributes) GetNewExecutionRunId() string
func (*WorkflowExecutionCompletedEventAttributes) GetResult ¶
func (x *WorkflowExecutionCompletedEventAttributes) GetResult() *v1.Payloads
func (*WorkflowExecutionCompletedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *WorkflowExecutionCompletedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*WorkflowExecutionCompletedEventAttributes) Marshal ¶
func (val *WorkflowExecutionCompletedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionCompletedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionCompletedEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionCompletedEventAttributes) ProtoMessage()
func (*WorkflowExecutionCompletedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionCompletedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionCompletedEventAttributes) Reset ¶
func (x *WorkflowExecutionCompletedEventAttributes) Reset()
func (*WorkflowExecutionCompletedEventAttributes) Size ¶
func (val *WorkflowExecutionCompletedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionCompletedEventAttributes) String ¶
func (x *WorkflowExecutionCompletedEventAttributes) String() string
func (*WorkflowExecutionCompletedEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionCompletedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionCompletedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionContinuedAsNewEventAttributes ¶
type WorkflowExecutionContinuedAsNewEventAttributes struct { // The run ID of the new workflow started by this continue-as-new NewExecutionRunId string `protobuf:"bytes,1,opt,name=new_execution_run_id,json=newExecutionRunId,proto3" json:"new_execution_run_id,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` TaskQueue *v11.TaskQueue `protobuf:"bytes,3,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` Input *v1.Payloads `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"` // Timeout of a single workflow run. WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"` // Timeout of a single workflow task. WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"` // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // TODO: How and is this used? BackoffStartInterval *durationpb.Duration `protobuf:"bytes,8,opt,name=backoff_start_interval,json=backoffStartInterval,proto3" json:"backoff_start_interval,omitempty"` Initiator v12.ContinueAsNewInitiator `protobuf:"varint,9,opt,name=initiator,proto3,enum=temporal.api.enums.v1.ContinueAsNewInitiator" json:"initiator,omitempty"` // TODO: David are these right? // Deprecated. If a workflow's retry policy would cause a new run to start when the current one // has failed, this field would be populated with that failure. Now (when supported by server // and sdk) the final event will be `WORKFLOW_EXECUTION_FAILED` with `new_execution_run_id` set. Failure *v13.Failure `protobuf:"bytes,10,opt,name=failure,proto3" json:"failure,omitempty"` // TODO: Is this the result of *this* workflow as it continued-as-new? LastCompletionResult *v1.Payloads `protobuf:"bytes,11,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"` Header *v1.Header `protobuf:"bytes,12,opt,name=header,proto3" json:"header,omitempty"` Memo *v1.Memo `protobuf:"bytes,13,opt,name=memo,proto3" json:"memo,omitempty"` SearchAttributes *v1.SearchAttributes `protobuf:"bytes,14,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"` // If this is set, the workflow executing this command wishes to continue as new using a version // compatible with the version that this workflow most recently ran on. UseCompatibleVersion bool `protobuf:"varint,15,opt,name=use_compatible_version,json=useCompatibleVersion,proto3" json:"use_compatible_version,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionContinuedAsNewEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionContinuedAsNewEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionContinuedAsNewEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionContinuedAsNewEventAttributes) Equal ¶
func (this *WorkflowExecutionContinuedAsNewEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionContinuedAsNewEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetBackoffStartInterval ¶ added in v0.28.0
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetBackoffStartInterval() *durationpb.Duration
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetFailure ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetFailure() *v13.Failure
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetHeader ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetHeader() *v1.Header
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetInitiator ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetInitiator() v12.ContinueAsNewInitiator
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetInput ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetInput() *v1.Payloads
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetLastCompletionResult ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetLastCompletionResult() *v1.Payloads
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetMemo ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetMemo() *v1.Memo
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetNewExecutionRunId ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetNewExecutionRunId() string
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetSearchAttributes ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetSearchAttributes() *v1.SearchAttributes
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetTaskQueue ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetTaskQueue() *v11.TaskQueue
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetUseCompatibleVersion ¶ added in v1.21.0
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetUseCompatibleVersion() bool
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowRunTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowRunTimeout() *durationpb.Duration
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowTaskTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowTaskTimeout() *durationpb.Duration
func (*WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowType ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*WorkflowExecutionContinuedAsNewEventAttributes) Marshal ¶
func (val *WorkflowExecutionContinuedAsNewEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionContinuedAsNewEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionContinuedAsNewEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionContinuedAsNewEventAttributes) ProtoMessage()
func (*WorkflowExecutionContinuedAsNewEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionContinuedAsNewEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionContinuedAsNewEventAttributes) Reset ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) Reset()
func (*WorkflowExecutionContinuedAsNewEventAttributes) Size ¶
func (val *WorkflowExecutionContinuedAsNewEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionContinuedAsNewEventAttributes) String ¶
func (x *WorkflowExecutionContinuedAsNewEventAttributes) String() string
func (*WorkflowExecutionContinuedAsNewEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionContinuedAsNewEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionContinuedAsNewEventAttributes from the protobuf v3 wire format
type WorkflowExecutionFailedEventAttributes ¶
type WorkflowExecutionFailedEventAttributes struct { // Serialized result of workflow failure (ex: An exception thrown, or error returned) Failure *v13.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"` RetryState v12.RetryState `` /* 130-byte string literal not displayed */ // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // If another run is started by cron or retry, this contains the new run id. NewExecutionRunId string `protobuf:"bytes,4,opt,name=new_execution_run_id,json=newExecutionRunId,proto3" json:"new_execution_run_id,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionFailedEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionFailedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionFailedEventAttributes) Equal ¶
func (this *WorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionFailedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionFailedEventAttributes) GetFailure ¶
func (x *WorkflowExecutionFailedEventAttributes) GetFailure() *v13.Failure
func (*WorkflowExecutionFailedEventAttributes) GetNewExecutionRunId ¶ added in v1.5.0
func (x *WorkflowExecutionFailedEventAttributes) GetNewExecutionRunId() string
func (*WorkflowExecutionFailedEventAttributes) GetRetryState ¶
func (x *WorkflowExecutionFailedEventAttributes) GetRetryState() v12.RetryState
func (*WorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId ¶
func (x *WorkflowExecutionFailedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*WorkflowExecutionFailedEventAttributes) Marshal ¶
func (val *WorkflowExecutionFailedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionFailedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionFailedEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionFailedEventAttributes) ProtoMessage()
func (*WorkflowExecutionFailedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionFailedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionFailedEventAttributes) Reset ¶
func (x *WorkflowExecutionFailedEventAttributes) Reset()
func (*WorkflowExecutionFailedEventAttributes) Size ¶
func (val *WorkflowExecutionFailedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionFailedEventAttributes) String ¶
func (x *WorkflowExecutionFailedEventAttributes) String() string
func (*WorkflowExecutionFailedEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionFailedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionFailedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionSignaledEventAttributes ¶
type WorkflowExecutionSignaledEventAttributes struct { // The name/type of the signal to fire SignalName string `protobuf:"bytes,1,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"` // Will be deserialized and provided as argument(s) to the signal handler Input *v1.Payloads `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"` // id of the worker/client who sent this signal Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"` // Headers that were passed by the sender of the signal and copied by temporal // server into the workflow task. Header *v1.Header `protobuf:"bytes,4,opt,name=header,proto3" json:"header,omitempty"` // Indicates the signal did not generate a new workflow task when received. SkipGenerateWorkflowTask bool `` /* 138-byte string literal not displayed */ // When signal origin is a workflow execution, this field is set. ExternalWorkflowExecution *v1.WorkflowExecution `` /* 138-byte string literal not displayed */ // contains filtered or unexported fields }
func (*WorkflowExecutionSignaledEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionSignaledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionSignaledEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionSignaledEventAttributes) Equal ¶
func (this *WorkflowExecutionSignaledEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionSignaledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionSignaledEventAttributes) GetExternalWorkflowExecution ¶ added in v1.27.0
func (x *WorkflowExecutionSignaledEventAttributes) GetExternalWorkflowExecution() *v1.WorkflowExecution
func (*WorkflowExecutionSignaledEventAttributes) GetHeader ¶ added in v1.6.0
func (x *WorkflowExecutionSignaledEventAttributes) GetHeader() *v1.Header
func (*WorkflowExecutionSignaledEventAttributes) GetIdentity ¶
func (x *WorkflowExecutionSignaledEventAttributes) GetIdentity() string
func (*WorkflowExecutionSignaledEventAttributes) GetInput ¶
func (x *WorkflowExecutionSignaledEventAttributes) GetInput() *v1.Payloads
func (*WorkflowExecutionSignaledEventAttributes) GetSignalName ¶
func (x *WorkflowExecutionSignaledEventAttributes) GetSignalName() string
func (*WorkflowExecutionSignaledEventAttributes) GetSkipGenerateWorkflowTask ¶ added in v1.21.0
func (x *WorkflowExecutionSignaledEventAttributes) GetSkipGenerateWorkflowTask() bool
func (*WorkflowExecutionSignaledEventAttributes) Marshal ¶
func (val *WorkflowExecutionSignaledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionSignaledEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionSignaledEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionSignaledEventAttributes) ProtoMessage()
func (*WorkflowExecutionSignaledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionSignaledEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionSignaledEventAttributes) Reset ¶
func (x *WorkflowExecutionSignaledEventAttributes) Reset()
func (*WorkflowExecutionSignaledEventAttributes) Size ¶
func (val *WorkflowExecutionSignaledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionSignaledEventAttributes) String ¶
func (x *WorkflowExecutionSignaledEventAttributes) String() string
func (*WorkflowExecutionSignaledEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionSignaledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionSignaledEventAttributes from the protobuf v3 wire format
type WorkflowExecutionStartedEventAttributes ¶
type WorkflowExecutionStartedEventAttributes struct { WorkflowType *v1.WorkflowType `protobuf:"bytes,1,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` // If this workflow is a child, the namespace our parent lives in. // SDKs and UI tools should use `parent_workflow_namespace` field but server must use `parent_workflow_namespace_id` only. ParentWorkflowNamespace string `` /* 132-byte string literal not displayed */ ParentWorkflowNamespaceId string `` /* 141-byte string literal not displayed */ // Contains information about parent workflow execution that initiated the child workflow these attributes belong to. // If the workflow these attributes belong to is not a child workflow of any other execution, this field will not be populated. ParentWorkflowExecution *v1.WorkflowExecution `` /* 132-byte string literal not displayed */ // EventID of the child execution initiated event in parent workflow ParentInitiatedEventId int64 `` /* 132-byte string literal not displayed */ TaskQueue *v11.TaskQueue `protobuf:"bytes,5,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` // SDK will deserialize this and provide it as arguments to the workflow function Input *v1.Payloads `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"` // Total workflow execution timeout including retries and continue as new. WorkflowExecutionTimeout *durationpb.Duration `` /* 135-byte string literal not displayed */ // Timeout of a single workflow run. WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"` // Timeout of a single workflow task. WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,9,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"` // Run id of the previous workflow which continued-as-new or retired or cron executed into this // workflow. ContinuedExecutionRunId string `` /* 135-byte string literal not displayed */ Initiator v12.ContinueAsNewInitiator `protobuf:"varint,11,opt,name=initiator,proto3,enum=temporal.api.enums.v1.ContinueAsNewInitiator" json:"initiator,omitempty"` ContinuedFailure *v13.Failure `protobuf:"bytes,12,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"` LastCompletionResult *v1.Payloads `protobuf:"bytes,13,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"` // This is the run id when the WorkflowExecutionStarted event was written. // A workflow reset changes the execution run_id, but preserves this field. OriginalExecutionRunId string `` /* 132-byte string literal not displayed */ // Identity of the client who requested this execution Identity string `protobuf:"bytes,15,opt,name=identity,proto3" json:"identity,omitempty"` // This is the very first runId along the chain of ContinueAsNew, Retry, Cron and Reset. // Used to identify a chain. FirstExecutionRunId string `protobuf:"bytes,16,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"` RetryPolicy *v1.RetryPolicy `protobuf:"bytes,17,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` // Starting at 1, the number of times we have tried to execute this workflow Attempt int32 `protobuf:"varint,18,opt,name=attempt,proto3" json:"attempt,omitempty"` // The absolute time at which the workflow will be timed out. // This is passed without change to the next run/retry of a workflow. WorkflowExecutionExpirationTime *timestamppb.Timestamp `` /* 159-byte string literal not displayed */ // If this workflow runs on a cron schedule, it will appear here CronSchedule string `protobuf:"bytes,20,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"` // For a cron workflow, this contains the amount of time between when this iteration of // the cron workflow was scheduled and when it should run next per its cron_schedule. FirstWorkflowTaskBackoff *durationpb.Duration `` /* 138-byte string literal not displayed */ Memo *v1.Memo `protobuf:"bytes,22,opt,name=memo,proto3" json:"memo,omitempty"` SearchAttributes *v1.SearchAttributes `protobuf:"bytes,23,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"` PrevAutoResetPoints *v14.ResetPoints `protobuf:"bytes,24,opt,name=prev_auto_reset_points,json=prevAutoResetPoints,proto3" json:"prev_auto_reset_points,omitempty"` Header *v1.Header `protobuf:"bytes,25,opt,name=header,proto3" json:"header,omitempty"` // Version of the child execution initiated event in parent workflow // It should be used together with parent_initiated_event_id to identify // a child initiated event for global namespace ParentInitiatedEventVersion int64 `` /* 148-byte string literal not displayed */ // This field is new in 1.21. WorkflowId string `protobuf:"bytes,28,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"` // If this workflow intends to use anything other than the current overall default version for // the queue, then we include it here. SourceVersionStamp *v1.WorkerVersionStamp `protobuf:"bytes,29,opt,name=source_version_stamp,json=sourceVersionStamp,proto3" json:"source_version_stamp,omitempty"` // Completion callbacks attached when this workflow was started. CompletionCallbacks []*v1.Callback `protobuf:"bytes,30,rep,name=completion_callbacks,json=completionCallbacks,proto3" json:"completion_callbacks,omitempty"` // contains filtered or unexported fields }
Always the first event in workflow history
func (*WorkflowExecutionStartedEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionStartedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionStartedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionStartedEventAttributes) Equal ¶
func (this *WorkflowExecutionStartedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionStartedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionStartedEventAttributes) GetAttempt ¶
func (x *WorkflowExecutionStartedEventAttributes) GetAttempt() int32
func (*WorkflowExecutionStartedEventAttributes) GetCompletionCallbacks ¶ added in v1.27.0
func (x *WorkflowExecutionStartedEventAttributes) GetCompletionCallbacks() []*v1.Callback
func (*WorkflowExecutionStartedEventAttributes) GetContinuedExecutionRunId ¶
func (x *WorkflowExecutionStartedEventAttributes) GetContinuedExecutionRunId() string
func (*WorkflowExecutionStartedEventAttributes) GetContinuedFailure ¶
func (x *WorkflowExecutionStartedEventAttributes) GetContinuedFailure() *v13.Failure
func (*WorkflowExecutionStartedEventAttributes) GetCronSchedule ¶
func (x *WorkflowExecutionStartedEventAttributes) GetCronSchedule() string
func (*WorkflowExecutionStartedEventAttributes) GetFirstExecutionRunId ¶
func (x *WorkflowExecutionStartedEventAttributes) GetFirstExecutionRunId() string
func (*WorkflowExecutionStartedEventAttributes) GetFirstWorkflowTaskBackoff ¶ added in v0.28.0
func (x *WorkflowExecutionStartedEventAttributes) GetFirstWorkflowTaskBackoff() *durationpb.Duration
func (*WorkflowExecutionStartedEventAttributes) GetHeader ¶
func (x *WorkflowExecutionStartedEventAttributes) GetHeader() *v1.Header
func (*WorkflowExecutionStartedEventAttributes) GetIdentity ¶
func (x *WorkflowExecutionStartedEventAttributes) GetIdentity() string
func (*WorkflowExecutionStartedEventAttributes) GetInitiator ¶
func (x *WorkflowExecutionStartedEventAttributes) GetInitiator() v12.ContinueAsNewInitiator
func (*WorkflowExecutionStartedEventAttributes) GetInput ¶
func (x *WorkflowExecutionStartedEventAttributes) GetInput() *v1.Payloads
func (*WorkflowExecutionStartedEventAttributes) GetLastCompletionResult ¶
func (x *WorkflowExecutionStartedEventAttributes) GetLastCompletionResult() *v1.Payloads
func (*WorkflowExecutionStartedEventAttributes) GetMemo ¶
func (x *WorkflowExecutionStartedEventAttributes) GetMemo() *v1.Memo
func (*WorkflowExecutionStartedEventAttributes) GetOriginalExecutionRunId ¶
func (x *WorkflowExecutionStartedEventAttributes) GetOriginalExecutionRunId() string
func (*WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventId ¶
func (x *WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventId() int64
func (*WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventVersion ¶ added in v1.8.0
func (x *WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventVersion() int64
func (*WorkflowExecutionStartedEventAttributes) GetParentWorkflowExecution ¶
func (x *WorkflowExecutionStartedEventAttributes) GetParentWorkflowExecution() *v1.WorkflowExecution
func (*WorkflowExecutionStartedEventAttributes) GetParentWorkflowNamespace ¶
func (x *WorkflowExecutionStartedEventAttributes) GetParentWorkflowNamespace() string
func (*WorkflowExecutionStartedEventAttributes) GetParentWorkflowNamespaceId ¶ added in v1.8.0
func (x *WorkflowExecutionStartedEventAttributes) GetParentWorkflowNamespaceId() string
func (*WorkflowExecutionStartedEventAttributes) GetPrevAutoResetPoints ¶
func (x *WorkflowExecutionStartedEventAttributes) GetPrevAutoResetPoints() *v14.ResetPoints
func (*WorkflowExecutionStartedEventAttributes) GetRetryPolicy ¶
func (x *WorkflowExecutionStartedEventAttributes) GetRetryPolicy() *v1.RetryPolicy
func (*WorkflowExecutionStartedEventAttributes) GetSearchAttributes ¶
func (x *WorkflowExecutionStartedEventAttributes) GetSearchAttributes() *v1.SearchAttributes
func (*WorkflowExecutionStartedEventAttributes) GetSourceVersionStamp ¶ added in v1.21.0
func (x *WorkflowExecutionStartedEventAttributes) GetSourceVersionStamp() *v1.WorkerVersionStamp
func (*WorkflowExecutionStartedEventAttributes) GetTaskQueue ¶
func (x *WorkflowExecutionStartedEventAttributes) GetTaskQueue() *v11.TaskQueue
func (*WorkflowExecutionStartedEventAttributes) GetWorkflowExecutionExpirationTime ¶ added in v0.28.0
func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowExecutionExpirationTime() *timestamppb.Timestamp
func (*WorkflowExecutionStartedEventAttributes) GetWorkflowExecutionTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowExecutionTimeout() *durationpb.Duration
func (*WorkflowExecutionStartedEventAttributes) GetWorkflowId ¶ added in v1.21.0
func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowId() string
func (*WorkflowExecutionStartedEventAttributes) GetWorkflowRunTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowRunTimeout() *durationpb.Duration
func (*WorkflowExecutionStartedEventAttributes) GetWorkflowTaskTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowTaskTimeout() *durationpb.Duration
func (*WorkflowExecutionStartedEventAttributes) GetWorkflowType ¶
func (x *WorkflowExecutionStartedEventAttributes) GetWorkflowType() *v1.WorkflowType
func (*WorkflowExecutionStartedEventAttributes) Marshal ¶
func (val *WorkflowExecutionStartedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionStartedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionStartedEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionStartedEventAttributes) ProtoMessage()
func (*WorkflowExecutionStartedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionStartedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionStartedEventAttributes) Reset ¶
func (x *WorkflowExecutionStartedEventAttributes) Reset()
func (*WorkflowExecutionStartedEventAttributes) Size ¶
func (val *WorkflowExecutionStartedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionStartedEventAttributes) String ¶
func (x *WorkflowExecutionStartedEventAttributes) String() string
func (*WorkflowExecutionStartedEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionStartedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionStartedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionTerminatedEventAttributes ¶
type WorkflowExecutionTerminatedEventAttributes struct { // User/client provided reason for termination Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` Details *v1.Payloads `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"` // id of the client who requested termination Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionTerminatedEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionTerminatedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionTerminatedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionTerminatedEventAttributes) Equal ¶
func (this *WorkflowExecutionTerminatedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionTerminatedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionTerminatedEventAttributes) GetDetails ¶
func (x *WorkflowExecutionTerminatedEventAttributes) GetDetails() *v1.Payloads
func (*WorkflowExecutionTerminatedEventAttributes) GetIdentity ¶
func (x *WorkflowExecutionTerminatedEventAttributes) GetIdentity() string
func (*WorkflowExecutionTerminatedEventAttributes) GetReason ¶
func (x *WorkflowExecutionTerminatedEventAttributes) GetReason() string
func (*WorkflowExecutionTerminatedEventAttributes) Marshal ¶
func (val *WorkflowExecutionTerminatedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionTerminatedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionTerminatedEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionTerminatedEventAttributes) ProtoMessage()
func (*WorkflowExecutionTerminatedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionTerminatedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionTerminatedEventAttributes) Reset ¶
func (x *WorkflowExecutionTerminatedEventAttributes) Reset()
func (*WorkflowExecutionTerminatedEventAttributes) Size ¶
func (val *WorkflowExecutionTerminatedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionTerminatedEventAttributes) String ¶
func (x *WorkflowExecutionTerminatedEventAttributes) String() string
func (*WorkflowExecutionTerminatedEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionTerminatedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionTerminatedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionTimedOutEventAttributes ¶
type WorkflowExecutionTimedOutEventAttributes struct { RetryState v12.RetryState `` /* 130-byte string literal not displayed */ // If another run is started by cron or retry, this contains the new run id. NewExecutionRunId string `protobuf:"bytes,2,opt,name=new_execution_run_id,json=newExecutionRunId,proto3" json:"new_execution_run_id,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionTimedOutEventAttributes) Descriptor
deprecated
func (*WorkflowExecutionTimedOutEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionTimedOutEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionTimedOutEventAttributes) Equal ¶
func (this *WorkflowExecutionTimedOutEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionTimedOutEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionTimedOutEventAttributes) GetNewExecutionRunId ¶ added in v1.5.0
func (x *WorkflowExecutionTimedOutEventAttributes) GetNewExecutionRunId() string
func (*WorkflowExecutionTimedOutEventAttributes) GetRetryState ¶
func (x *WorkflowExecutionTimedOutEventAttributes) GetRetryState() v12.RetryState
func (*WorkflowExecutionTimedOutEventAttributes) Marshal ¶
func (val *WorkflowExecutionTimedOutEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionTimedOutEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionTimedOutEventAttributes) ProtoMessage ¶
func (*WorkflowExecutionTimedOutEventAttributes) ProtoMessage()
func (*WorkflowExecutionTimedOutEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionTimedOutEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionTimedOutEventAttributes) Reset ¶
func (x *WorkflowExecutionTimedOutEventAttributes) Reset()
func (*WorkflowExecutionTimedOutEventAttributes) Size ¶
func (val *WorkflowExecutionTimedOutEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionTimedOutEventAttributes) String ¶
func (x *WorkflowExecutionTimedOutEventAttributes) String() string
func (*WorkflowExecutionTimedOutEventAttributes) Unmarshal ¶
func (val *WorkflowExecutionTimedOutEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionTimedOutEventAttributes from the protobuf v3 wire format
type WorkflowExecutionUpdateAcceptedEventAttributes ¶ added in v1.16.0
type WorkflowExecutionUpdateAcceptedEventAttributes struct { // The instance ID of the update protocol that generated this event. ProtocolInstanceId string `protobuf:"bytes,1,opt,name=protocol_instance_id,json=protocolInstanceId,proto3" json:"protocol_instance_id,omitempty"` // The message ID of the original request message that initiated this // update. Needed so that the worker can recreate and deliver that same // message as part of replay. AcceptedRequestMessageId string `` /* 137-byte string literal not displayed */ // The event ID used to sequence the original request message. AcceptedRequestSequencingEventId int64 `` /* 164-byte string literal not displayed */ // The message payload of the original request message that initiated this // update. AcceptedRequest *v16.Request `protobuf:"bytes,4,opt,name=accepted_request,json=acceptedRequest,proto3" json:"accepted_request,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionUpdateAcceptedEventAttributes) Descriptor
deprecated
added in
v1.16.0
func (*WorkflowExecutionUpdateAcceptedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionUpdateAcceptedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionUpdateAcceptedEventAttributes) Equal ¶ added in v1.16.0
func (this *WorkflowExecutionUpdateAcceptedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionUpdateAcceptedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequest ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequest() *v16.Request
func (*WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequestMessageId ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequestMessageId() string
func (*WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequestSequencingEventId ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetAcceptedRequestSequencingEventId() int64
func (*WorkflowExecutionUpdateAcceptedEventAttributes) GetProtocolInstanceId ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateAcceptedEventAttributes) GetProtocolInstanceId() string
func (*WorkflowExecutionUpdateAcceptedEventAttributes) Marshal ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateAcceptedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionUpdateAcceptedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionUpdateAcceptedEventAttributes) ProtoMessage ¶ added in v1.16.0
func (*WorkflowExecutionUpdateAcceptedEventAttributes) ProtoMessage()
func (*WorkflowExecutionUpdateAcceptedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionUpdateAcceptedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionUpdateAcceptedEventAttributes) Reset ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateAcceptedEventAttributes) Reset()
func (*WorkflowExecutionUpdateAcceptedEventAttributes) Size ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateAcceptedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionUpdateAcceptedEventAttributes) String ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateAcceptedEventAttributes) String() string
func (*WorkflowExecutionUpdateAcceptedEventAttributes) Unmarshal ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateAcceptedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionUpdateAcceptedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionUpdateCompletedEventAttributes ¶ added in v1.16.0
type WorkflowExecutionUpdateCompletedEventAttributes struct { // The metadata about this update. Meta *v16.Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` // The event ID indicating the acceptance of this update. AcceptedEventId int64 `protobuf:"varint,3,opt,name=accepted_event_id,json=acceptedEventId,proto3" json:"accepted_event_id,omitempty"` // The outcome of executing the workflow update function. Outcome *v16.Outcome `protobuf:"bytes,2,opt,name=outcome,proto3" json:"outcome,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionUpdateCompletedEventAttributes) Descriptor
deprecated
added in
v1.16.0
func (*WorkflowExecutionUpdateCompletedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionUpdateCompletedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionUpdateCompletedEventAttributes) Equal ¶ added in v1.16.0
func (this *WorkflowExecutionUpdateCompletedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionUpdateCompletedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionUpdateCompletedEventAttributes) GetAcceptedEventId ¶ added in v1.22.0
func (x *WorkflowExecutionUpdateCompletedEventAttributes) GetAcceptedEventId() int64
func (*WorkflowExecutionUpdateCompletedEventAttributes) GetMeta ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateCompletedEventAttributes) GetMeta() *v16.Meta
func (*WorkflowExecutionUpdateCompletedEventAttributes) GetOutcome ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateCompletedEventAttributes) GetOutcome() *v16.Outcome
func (*WorkflowExecutionUpdateCompletedEventAttributes) Marshal ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateCompletedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionUpdateCompletedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionUpdateCompletedEventAttributes) ProtoMessage ¶ added in v1.16.0
func (*WorkflowExecutionUpdateCompletedEventAttributes) ProtoMessage()
func (*WorkflowExecutionUpdateCompletedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionUpdateCompletedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionUpdateCompletedEventAttributes) Reset ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateCompletedEventAttributes) Reset()
func (*WorkflowExecutionUpdateCompletedEventAttributes) Size ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateCompletedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionUpdateCompletedEventAttributes) String ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateCompletedEventAttributes) String() string
func (*WorkflowExecutionUpdateCompletedEventAttributes) Unmarshal ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateCompletedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionUpdateCompletedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionUpdateRejectedEventAttributes ¶ added in v1.16.0
type WorkflowExecutionUpdateRejectedEventAttributes struct { // The instance ID of the update protocol that generated this event. ProtocolInstanceId string `protobuf:"bytes,1,opt,name=protocol_instance_id,json=protocolInstanceId,proto3" json:"protocol_instance_id,omitempty"` // The message ID of the original request message that initiated this // update. Needed so that the worker can recreate and deliver that same // message as part of replay. RejectedRequestMessageId string `` /* 137-byte string literal not displayed */ // The event ID used to sequence the original request message. RejectedRequestSequencingEventId int64 `` /* 164-byte string literal not displayed */ // The message payload of the original request message that initiated this // update. RejectedRequest *v16.Request `protobuf:"bytes,4,opt,name=rejected_request,json=rejectedRequest,proto3" json:"rejected_request,omitempty"` // The cause of rejection. Failure *v13.Failure `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionUpdateRejectedEventAttributes) Descriptor
deprecated
added in
v1.16.0
func (*WorkflowExecutionUpdateRejectedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionUpdateRejectedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionUpdateRejectedEventAttributes) Equal ¶ added in v1.16.0
func (this *WorkflowExecutionUpdateRejectedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionUpdateRejectedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionUpdateRejectedEventAttributes) GetFailure ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetFailure() *v13.Failure
func (*WorkflowExecutionUpdateRejectedEventAttributes) GetProtocolInstanceId ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetProtocolInstanceId() string
func (*WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequest ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequest() *v16.Request
func (*WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequestMessageId ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequestMessageId() string
func (*WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequestSequencingEventId ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateRejectedEventAttributes) GetRejectedRequestSequencingEventId() int64
func (*WorkflowExecutionUpdateRejectedEventAttributes) Marshal ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateRejectedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionUpdateRejectedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionUpdateRejectedEventAttributes) ProtoMessage ¶ added in v1.16.0
func (*WorkflowExecutionUpdateRejectedEventAttributes) ProtoMessage()
func (*WorkflowExecutionUpdateRejectedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionUpdateRejectedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionUpdateRejectedEventAttributes) Reset ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateRejectedEventAttributes) Reset()
func (*WorkflowExecutionUpdateRejectedEventAttributes) Size ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateRejectedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionUpdateRejectedEventAttributes) String ¶ added in v1.16.0
func (x *WorkflowExecutionUpdateRejectedEventAttributes) String() string
func (*WorkflowExecutionUpdateRejectedEventAttributes) Unmarshal ¶ added in v1.16.0
func (val *WorkflowExecutionUpdateRejectedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionUpdateRejectedEventAttributes from the protobuf v3 wire format
type WorkflowExecutionUpdateRequestedEventAttributes ¶ added in v1.27.0
type WorkflowExecutionUpdateRequestedEventAttributes struct { // The update request associated with this event. Request *v16.Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` // An explanation of why this event was written to history. Origin v12.UpdateRequestedEventOrigin `protobuf:"varint,2,opt,name=origin,proto3,enum=temporal.api.enums.v1.UpdateRequestedEventOrigin" json:"origin,omitempty"` // contains filtered or unexported fields }
func (*WorkflowExecutionUpdateRequestedEventAttributes) Descriptor
deprecated
added in
v1.27.0
func (*WorkflowExecutionUpdateRequestedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionUpdateRequestedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionUpdateRequestedEventAttributes) Equal ¶ added in v1.27.0
func (this *WorkflowExecutionUpdateRequestedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionUpdateRequestedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionUpdateRequestedEventAttributes) GetOrigin ¶ added in v1.27.0
func (x *WorkflowExecutionUpdateRequestedEventAttributes) GetOrigin() v12.UpdateRequestedEventOrigin
func (*WorkflowExecutionUpdateRequestedEventAttributes) GetRequest ¶ added in v1.27.0
func (x *WorkflowExecutionUpdateRequestedEventAttributes) GetRequest() *v16.Request
func (*WorkflowExecutionUpdateRequestedEventAttributes) Marshal ¶ added in v1.27.0
func (val *WorkflowExecutionUpdateRequestedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionUpdateRequestedEventAttributes to the protobuf v3 wire format
func (*WorkflowExecutionUpdateRequestedEventAttributes) ProtoMessage ¶ added in v1.27.0
func (*WorkflowExecutionUpdateRequestedEventAttributes) ProtoMessage()
func (*WorkflowExecutionUpdateRequestedEventAttributes) ProtoReflect ¶ added in v1.27.0
func (x *WorkflowExecutionUpdateRequestedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionUpdateRequestedEventAttributes) Reset ¶ added in v1.27.0
func (x *WorkflowExecutionUpdateRequestedEventAttributes) Reset()
func (*WorkflowExecutionUpdateRequestedEventAttributes) Size ¶ added in v1.27.0
func (val *WorkflowExecutionUpdateRequestedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionUpdateRequestedEventAttributes) String ¶ added in v1.27.0
func (x *WorkflowExecutionUpdateRequestedEventAttributes) String() string
func (*WorkflowExecutionUpdateRequestedEventAttributes) Unmarshal ¶ added in v1.27.0
func (val *WorkflowExecutionUpdateRequestedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionUpdateRequestedEventAttributes from the protobuf v3 wire format
type WorkflowPropertiesModifiedEventAttributes ¶ added in v1.12.0
type WorkflowPropertiesModifiedEventAttributes struct { // The `WORKFLOW_TASK_COMPLETED` event which this command was reported with WorkflowTaskCompletedEventId int64 `` /* 152-byte string literal not displayed */ // If set, update the workflow memo with the provided values. The values will be merged with // the existing memo. If the user wants to delete values, a default/empty Payload should be // used as the value for the key being deleted. UpsertedMemo *v1.Memo `protobuf:"bytes,2,opt,name=upserted_memo,json=upsertedMemo,proto3" json:"upserted_memo,omitempty"` // contains filtered or unexported fields }
func (*WorkflowPropertiesModifiedEventAttributes) Descriptor
deprecated
added in
v1.12.0
func (*WorkflowPropertiesModifiedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowPropertiesModifiedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowPropertiesModifiedEventAttributes) Equal ¶ added in v1.12.0
func (this *WorkflowPropertiesModifiedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowPropertiesModifiedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowPropertiesModifiedEventAttributes) GetUpsertedMemo ¶ added in v1.12.0
func (x *WorkflowPropertiesModifiedEventAttributes) GetUpsertedMemo() *v1.Memo
func (*WorkflowPropertiesModifiedEventAttributes) GetWorkflowTaskCompletedEventId ¶ added in v1.12.0
func (x *WorkflowPropertiesModifiedEventAttributes) GetWorkflowTaskCompletedEventId() int64
func (*WorkflowPropertiesModifiedEventAttributes) Marshal ¶ added in v1.12.0
func (val *WorkflowPropertiesModifiedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowPropertiesModifiedEventAttributes to the protobuf v3 wire format
func (*WorkflowPropertiesModifiedEventAttributes) ProtoMessage ¶ added in v1.12.0
func (*WorkflowPropertiesModifiedEventAttributes) ProtoMessage()
func (*WorkflowPropertiesModifiedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowPropertiesModifiedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowPropertiesModifiedEventAttributes) Reset ¶ added in v1.12.0
func (x *WorkflowPropertiesModifiedEventAttributes) Reset()
func (*WorkflowPropertiesModifiedEventAttributes) Size ¶ added in v1.12.0
func (val *WorkflowPropertiesModifiedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowPropertiesModifiedEventAttributes) String ¶ added in v1.12.0
func (x *WorkflowPropertiesModifiedEventAttributes) String() string
func (*WorkflowPropertiesModifiedEventAttributes) Unmarshal ¶ added in v1.12.0
func (val *WorkflowPropertiesModifiedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowPropertiesModifiedEventAttributes from the protobuf v3 wire format
type WorkflowPropertiesModifiedExternallyEventAttributes ¶ added in v1.11.0
type WorkflowPropertiesModifiedExternallyEventAttributes struct { // If set to a nonempty string, future workflow tasks for this workflow shall be dispatched on // the provided queue. NewTaskQueue string `protobuf:"bytes,1,opt,name=new_task_queue,json=newTaskQueue,proto3" json:"new_task_queue,omitempty"` // If set, update the workflow task timeout to this value. NewWorkflowTaskTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */ // If set, update the workflow run timeout to this value. May be set to 0 for no timeout. NewWorkflowRunTimeout *durationpb.Duration `` /* 128-byte string literal not displayed */ // If set, update the workflow execution timeout to this value. May be set to 0 for no timeout. NewWorkflowExecutionTimeout *durationpb.Duration `` /* 146-byte string literal not displayed */ // If set, update the workflow memo with the provided values. The values will be merged with // the existing memo. If the user wants to delete values, a default/empty Payload should be // used as the value for the key being deleted. UpsertedMemo *v1.Memo `protobuf:"bytes,5,opt,name=upserted_memo,json=upsertedMemo,proto3" json:"upserted_memo,omitempty"` // contains filtered or unexported fields }
func (*WorkflowPropertiesModifiedExternallyEventAttributes) Descriptor
deprecated
added in
v1.11.0
func (*WorkflowPropertiesModifiedExternallyEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowPropertiesModifiedExternallyEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowPropertiesModifiedExternallyEventAttributes) Equal ¶ added in v1.11.0
func (this *WorkflowPropertiesModifiedExternallyEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowPropertiesModifiedExternallyEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowPropertiesModifiedExternallyEventAttributes) GetNewTaskQueue ¶ added in v1.11.0
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewTaskQueue() string
func (*WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowExecutionTimeout ¶ added in v1.11.0
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowExecutionTimeout() *durationpb.Duration
func (*WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowRunTimeout ¶ added in v1.11.0
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowRunTimeout() *durationpb.Duration
func (*WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowTaskTimeout ¶ added in v1.11.0
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetNewWorkflowTaskTimeout() *durationpb.Duration
func (*WorkflowPropertiesModifiedExternallyEventAttributes) GetUpsertedMemo ¶ added in v1.11.0
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) GetUpsertedMemo() *v1.Memo
func (*WorkflowPropertiesModifiedExternallyEventAttributes) Marshal ¶ added in v1.11.0
func (val *WorkflowPropertiesModifiedExternallyEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowPropertiesModifiedExternallyEventAttributes to the protobuf v3 wire format
func (*WorkflowPropertiesModifiedExternallyEventAttributes) ProtoMessage ¶ added in v1.11.0
func (*WorkflowPropertiesModifiedExternallyEventAttributes) ProtoMessage()
func (*WorkflowPropertiesModifiedExternallyEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowPropertiesModifiedExternallyEventAttributes) Reset ¶ added in v1.11.0
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) Reset()
func (*WorkflowPropertiesModifiedExternallyEventAttributes) Size ¶ added in v1.11.0
func (val *WorkflowPropertiesModifiedExternallyEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowPropertiesModifiedExternallyEventAttributes) String ¶ added in v1.11.0
func (x *WorkflowPropertiesModifiedExternallyEventAttributes) String() string
func (*WorkflowPropertiesModifiedExternallyEventAttributes) Unmarshal ¶ added in v1.11.0
func (val *WorkflowPropertiesModifiedExternallyEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowPropertiesModifiedExternallyEventAttributes from the protobuf v3 wire format
type WorkflowTaskCompletedEventAttributes ¶
type WorkflowTaskCompletedEventAttributes struct { // The id of the `WORKFLOW_TASK_SCHEDULED` event this task corresponds to ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The id of the `WORKFLOW_TASK_STARTED` event this task corresponds to StartedEventId int64 `protobuf:"varint,2,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` // Identity of the worker who completed this task Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"` // Binary ID of the worker who completed this task BinaryChecksum string `protobuf:"bytes,4,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"` // Version info of the worker who processed this workflow task. If present, the `build_id` field // within is also used as `binary_checksum`, which may be omitted in that case (it may also be // populated to preserve compatibility). WorkerVersion *v1.WorkerVersionStamp `protobuf:"bytes,5,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,omitempty"` // Data the SDK wishes to record for itself, but server need not interpret, and does not // directly impact workflow state. SdkMetadata *v15.WorkflowTaskCompletedMetadata `protobuf:"bytes,6,opt,name=sdk_metadata,json=sdkMetadata,proto3" json:"sdk_metadata,omitempty"` // Local usage data sent during workflow task completion and recorded here for posterity MeteringMetadata *v1.MeteringMetadata `protobuf:"bytes,13,opt,name=metering_metadata,json=meteringMetadata,proto3" json:"metering_metadata,omitempty"` // contains filtered or unexported fields }
func (*WorkflowTaskCompletedEventAttributes) Descriptor
deprecated
func (*WorkflowTaskCompletedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTaskCompletedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowTaskCompletedEventAttributes) Equal ¶
func (this *WorkflowTaskCompletedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowTaskCompletedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowTaskCompletedEventAttributes) GetBinaryChecksum ¶
func (x *WorkflowTaskCompletedEventAttributes) GetBinaryChecksum() string
func (*WorkflowTaskCompletedEventAttributes) GetIdentity ¶
func (x *WorkflowTaskCompletedEventAttributes) GetIdentity() string
func (*WorkflowTaskCompletedEventAttributes) GetMeteringMetadata ¶ added in v1.18.1
func (x *WorkflowTaskCompletedEventAttributes) GetMeteringMetadata() *v1.MeteringMetadata
func (*WorkflowTaskCompletedEventAttributes) GetScheduledEventId ¶
func (x *WorkflowTaskCompletedEventAttributes) GetScheduledEventId() int64
func (*WorkflowTaskCompletedEventAttributes) GetSdkMetadata ¶ added in v1.17.0
func (x *WorkflowTaskCompletedEventAttributes) GetSdkMetadata() *v15.WorkflowTaskCompletedMetadata
func (*WorkflowTaskCompletedEventAttributes) GetStartedEventId ¶
func (x *WorkflowTaskCompletedEventAttributes) GetStartedEventId() int64
func (*WorkflowTaskCompletedEventAttributes) GetWorkerVersion ¶ added in v1.19.0
func (x *WorkflowTaskCompletedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
func (*WorkflowTaskCompletedEventAttributes) Marshal ¶
func (val *WorkflowTaskCompletedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowTaskCompletedEventAttributes to the protobuf v3 wire format
func (*WorkflowTaskCompletedEventAttributes) ProtoMessage ¶
func (*WorkflowTaskCompletedEventAttributes) ProtoMessage()
func (*WorkflowTaskCompletedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowTaskCompletedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowTaskCompletedEventAttributes) Reset ¶
func (x *WorkflowTaskCompletedEventAttributes) Reset()
func (*WorkflowTaskCompletedEventAttributes) Size ¶
func (val *WorkflowTaskCompletedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowTaskCompletedEventAttributes) String ¶
func (x *WorkflowTaskCompletedEventAttributes) String() string
func (*WorkflowTaskCompletedEventAttributes) Unmarshal ¶
func (val *WorkflowTaskCompletedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowTaskCompletedEventAttributes from the protobuf v3 wire format
type WorkflowTaskFailedEventAttributes ¶
type WorkflowTaskFailedEventAttributes struct { // The id of the `WORKFLOW_TASK_SCHEDULED` event this task corresponds to ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The id of the `WORKFLOW_TASK_STARTED` event this task corresponds to StartedEventId int64 `protobuf:"varint,2,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` Cause v12.WorkflowTaskFailedCause `protobuf:"varint,3,opt,name=cause,proto3,enum=temporal.api.enums.v1.WorkflowTaskFailedCause" json:"cause,omitempty"` // The failure details Failure *v13.Failure `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"` // If a worker explicitly failed this task, it's identity. TODO: What is this set to if server fails the task? Identity string `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"` // The original run id of the workflow. For reset workflow. BaseRunId string `protobuf:"bytes,6,opt,name=base_run_id,json=baseRunId,proto3" json:"base_run_id,omitempty"` // If the workflow is being reset, the new run id. NewRunId string `protobuf:"bytes,7,opt,name=new_run_id,json=newRunId,proto3" json:"new_run_id,omitempty"` // TODO: ? ForkEventVersion int64 `protobuf:"varint,8,opt,name=fork_event_version,json=forkEventVersion,proto3" json:"fork_event_version,omitempty"` // DEPRECATED since 1.21 - use `worker_version` instead. // If a worker explicitly failed this task, its binary id BinaryChecksum string `protobuf:"bytes,9,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"` // Version info of the worker who processed this workflow task. If present, the `build_id` field // within is also used as `binary_checksum`, which may be omitted in that case (it may also be // populated to preserve compatibility). WorkerVersion *v1.WorkerVersionStamp `protobuf:"bytes,10,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,omitempty"` // contains filtered or unexported fields }
func (*WorkflowTaskFailedEventAttributes) Descriptor
deprecated
func (*WorkflowTaskFailedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTaskFailedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowTaskFailedEventAttributes) Equal ¶
func (this *WorkflowTaskFailedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowTaskFailedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowTaskFailedEventAttributes) GetBaseRunId ¶
func (x *WorkflowTaskFailedEventAttributes) GetBaseRunId() string
func (*WorkflowTaskFailedEventAttributes) GetBinaryChecksum ¶
func (x *WorkflowTaskFailedEventAttributes) GetBinaryChecksum() string
func (*WorkflowTaskFailedEventAttributes) GetCause ¶
func (x *WorkflowTaskFailedEventAttributes) GetCause() v12.WorkflowTaskFailedCause
func (*WorkflowTaskFailedEventAttributes) GetFailure ¶
func (x *WorkflowTaskFailedEventAttributes) GetFailure() *v13.Failure
func (*WorkflowTaskFailedEventAttributes) GetForkEventVersion ¶
func (x *WorkflowTaskFailedEventAttributes) GetForkEventVersion() int64
func (*WorkflowTaskFailedEventAttributes) GetIdentity ¶
func (x *WorkflowTaskFailedEventAttributes) GetIdentity() string
func (*WorkflowTaskFailedEventAttributes) GetNewRunId ¶
func (x *WorkflowTaskFailedEventAttributes) GetNewRunId() string
func (*WorkflowTaskFailedEventAttributes) GetScheduledEventId ¶
func (x *WorkflowTaskFailedEventAttributes) GetScheduledEventId() int64
func (*WorkflowTaskFailedEventAttributes) GetStartedEventId ¶
func (x *WorkflowTaskFailedEventAttributes) GetStartedEventId() int64
func (*WorkflowTaskFailedEventAttributes) GetWorkerVersion ¶ added in v1.21.0
func (x *WorkflowTaskFailedEventAttributes) GetWorkerVersion() *v1.WorkerVersionStamp
func (*WorkflowTaskFailedEventAttributes) Marshal ¶
func (val *WorkflowTaskFailedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowTaskFailedEventAttributes to the protobuf v3 wire format
func (*WorkflowTaskFailedEventAttributes) ProtoMessage ¶
func (*WorkflowTaskFailedEventAttributes) ProtoMessage()
func (*WorkflowTaskFailedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowTaskFailedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowTaskFailedEventAttributes) Reset ¶
func (x *WorkflowTaskFailedEventAttributes) Reset()
func (*WorkflowTaskFailedEventAttributes) Size ¶
func (val *WorkflowTaskFailedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowTaskFailedEventAttributes) String ¶
func (x *WorkflowTaskFailedEventAttributes) String() string
func (*WorkflowTaskFailedEventAttributes) Unmarshal ¶
func (val *WorkflowTaskFailedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowTaskFailedEventAttributes from the protobuf v3 wire format
type WorkflowTaskScheduledEventAttributes ¶
type WorkflowTaskScheduledEventAttributes struct { // The task queue this workflow task was enqueued in, which could be a normal or sticky queue TaskQueue *v11.TaskQueue `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` // How long the worker has to process this task once receiving it before it times out // // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: "to" is used to indicate interval. --) StartToCloseTimeout *durationpb.Duration `protobuf:"bytes,2,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"` // Starting at 1, how many attempts there have been to complete this task Attempt int32 `protobuf:"varint,3,opt,name=attempt,proto3" json:"attempt,omitempty"` // contains filtered or unexported fields }
func (*WorkflowTaskScheduledEventAttributes) Descriptor
deprecated
func (*WorkflowTaskScheduledEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTaskScheduledEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowTaskScheduledEventAttributes) Equal ¶
func (this *WorkflowTaskScheduledEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowTaskScheduledEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowTaskScheduledEventAttributes) GetAttempt ¶
func (x *WorkflowTaskScheduledEventAttributes) GetAttempt() int32
func (*WorkflowTaskScheduledEventAttributes) GetStartToCloseTimeout ¶ added in v0.28.0
func (x *WorkflowTaskScheduledEventAttributes) GetStartToCloseTimeout() *durationpb.Duration
func (*WorkflowTaskScheduledEventAttributes) GetTaskQueue ¶
func (x *WorkflowTaskScheduledEventAttributes) GetTaskQueue() *v11.TaskQueue
func (*WorkflowTaskScheduledEventAttributes) Marshal ¶
func (val *WorkflowTaskScheduledEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowTaskScheduledEventAttributes to the protobuf v3 wire format
func (*WorkflowTaskScheduledEventAttributes) ProtoMessage ¶
func (*WorkflowTaskScheduledEventAttributes) ProtoMessage()
func (*WorkflowTaskScheduledEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowTaskScheduledEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowTaskScheduledEventAttributes) Reset ¶
func (x *WorkflowTaskScheduledEventAttributes) Reset()
func (*WorkflowTaskScheduledEventAttributes) Size ¶
func (val *WorkflowTaskScheduledEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowTaskScheduledEventAttributes) String ¶
func (x *WorkflowTaskScheduledEventAttributes) String() string
func (*WorkflowTaskScheduledEventAttributes) Unmarshal ¶
func (val *WorkflowTaskScheduledEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowTaskScheduledEventAttributes from the protobuf v3 wire format
type WorkflowTaskStartedEventAttributes ¶
type WorkflowTaskStartedEventAttributes struct { // The id of the `WORKFLOW_TASK_SCHEDULED` event this task corresponds to ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // Identity of the worker who picked up this task Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"` // TODO: ? Appears unused? RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // True if this workflow should continue-as-new soon because its history size (in // either event count or bytes) is getting large. SuggestContinueAsNew bool `` /* 126-byte string literal not displayed */ // Total history size in bytes, which the workflow might use to decide when to // continue-as-new regardless of the suggestion. Note that history event count is // just the event id of this event, so we don't include it explicitly here. HistorySizeBytes int64 `protobuf:"varint,5,opt,name=history_size_bytes,json=historySizeBytes,proto3" json:"history_size_bytes,omitempty"` // contains filtered or unexported fields }
func (*WorkflowTaskStartedEventAttributes) Descriptor
deprecated
func (*WorkflowTaskStartedEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTaskStartedEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowTaskStartedEventAttributes) Equal ¶
func (this *WorkflowTaskStartedEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowTaskStartedEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowTaskStartedEventAttributes) GetHistorySizeBytes ¶ added in v1.8.0
func (x *WorkflowTaskStartedEventAttributes) GetHistorySizeBytes() int64
func (*WorkflowTaskStartedEventAttributes) GetIdentity ¶
func (x *WorkflowTaskStartedEventAttributes) GetIdentity() string
func (*WorkflowTaskStartedEventAttributes) GetRequestId ¶
func (x *WorkflowTaskStartedEventAttributes) GetRequestId() string
func (*WorkflowTaskStartedEventAttributes) GetScheduledEventId ¶
func (x *WorkflowTaskStartedEventAttributes) GetScheduledEventId() int64
func (*WorkflowTaskStartedEventAttributes) GetSuggestContinueAsNew ¶ added in v1.8.0
func (x *WorkflowTaskStartedEventAttributes) GetSuggestContinueAsNew() bool
func (*WorkflowTaskStartedEventAttributes) Marshal ¶
func (val *WorkflowTaskStartedEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowTaskStartedEventAttributes to the protobuf v3 wire format
func (*WorkflowTaskStartedEventAttributes) ProtoMessage ¶
func (*WorkflowTaskStartedEventAttributes) ProtoMessage()
func (*WorkflowTaskStartedEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowTaskStartedEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowTaskStartedEventAttributes) Reset ¶
func (x *WorkflowTaskStartedEventAttributes) Reset()
func (*WorkflowTaskStartedEventAttributes) Size ¶
func (val *WorkflowTaskStartedEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowTaskStartedEventAttributes) String ¶
func (x *WorkflowTaskStartedEventAttributes) String() string
func (*WorkflowTaskStartedEventAttributes) Unmarshal ¶
func (val *WorkflowTaskStartedEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowTaskStartedEventAttributes from the protobuf v3 wire format
type WorkflowTaskTimedOutEventAttributes ¶
type WorkflowTaskTimedOutEventAttributes struct { // The id of the `WORKFLOW_TASK_SCHEDULED` event this task corresponds to ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` // The id of the `WORKFLOW_TASK_STARTED` event this task corresponds to StartedEventId int64 `protobuf:"varint,2,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"` TimeoutType v12.TimeoutType `` /* 134-byte string literal not displayed */ // contains filtered or unexported fields }
func (*WorkflowTaskTimedOutEventAttributes) Descriptor
deprecated
func (*WorkflowTaskTimedOutEventAttributes) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTaskTimedOutEventAttributes.ProtoReflect.Descriptor instead.
func (*WorkflowTaskTimedOutEventAttributes) Equal ¶
func (this *WorkflowTaskTimedOutEventAttributes) Equal(that interface{}) bool
Equal returns whether two WorkflowTaskTimedOutEventAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowTaskTimedOutEventAttributes) GetScheduledEventId ¶
func (x *WorkflowTaskTimedOutEventAttributes) GetScheduledEventId() int64
func (*WorkflowTaskTimedOutEventAttributes) GetStartedEventId ¶
func (x *WorkflowTaskTimedOutEventAttributes) GetStartedEventId() int64
func (*WorkflowTaskTimedOutEventAttributes) GetTimeoutType ¶
func (x *WorkflowTaskTimedOutEventAttributes) GetTimeoutType() v12.TimeoutType
func (*WorkflowTaskTimedOutEventAttributes) Marshal ¶
func (val *WorkflowTaskTimedOutEventAttributes) Marshal() ([]byte, error)
Marshal an object of type WorkflowTaskTimedOutEventAttributes to the protobuf v3 wire format
func (*WorkflowTaskTimedOutEventAttributes) ProtoMessage ¶
func (*WorkflowTaskTimedOutEventAttributes) ProtoMessage()
func (*WorkflowTaskTimedOutEventAttributes) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowTaskTimedOutEventAttributes) ProtoReflect() protoreflect.Message
func (*WorkflowTaskTimedOutEventAttributes) Reset ¶
func (x *WorkflowTaskTimedOutEventAttributes) Reset()
func (*WorkflowTaskTimedOutEventAttributes) Size ¶
func (val *WorkflowTaskTimedOutEventAttributes) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowTaskTimedOutEventAttributes) String ¶
func (x *WorkflowTaskTimedOutEventAttributes) String() string
func (*WorkflowTaskTimedOutEventAttributes) Unmarshal ¶
func (val *WorkflowTaskTimedOutEventAttributes) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowTaskTimedOutEventAttributes from the protobuf v3 wire format