history

package
Version: v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2023 License: MIT Imports: 18 Imported by: 49

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

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"`
}

func (*ActivityPropertiesModifiedExternallyEventAttributes) Descriptor added in v1.11.0 

func (*ActivityPropertiesModifiedExternallyEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityPropertiesModifiedExternallyEventAttributes) Equal added in v1.11.0 

func (this *ActivityPropertiesModifiedExternallyEventAttributes) Equal(that interface{}) bool

func (*ActivityPropertiesModifiedExternallyEventAttributes) GetNewRetryPolicy added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) GetNewRetryPolicy() *v1.RetryPolicy

func (*ActivityPropertiesModifiedExternallyEventAttributes) GetScheduledEventId added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) GetScheduledEventId() int64

func (*ActivityPropertiesModifiedExternallyEventAttributes) GoString added in v1.11.0 

func (this *ActivityPropertiesModifiedExternallyEventAttributes) GoString() string

func (*ActivityPropertiesModifiedExternallyEventAttributes) Marshal added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityPropertiesModifiedExternallyEventAttributes) MarshalTo added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityPropertiesModifiedExternallyEventAttributes) MarshalToSizedBuffer added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityPropertiesModifiedExternallyEventAttributes) ProtoMessage added in v1.11.0 

func (*ActivityPropertiesModifiedExternallyEventAttributes) ProtoMessage()

func (*ActivityPropertiesModifiedExternallyEventAttributes) Reset added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) Reset()

func (*ActivityPropertiesModifiedExternallyEventAttributes) Size added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) Size() (n int)

func (*ActivityPropertiesModifiedExternallyEventAttributes) String added in v1.11.0 

func (this *ActivityPropertiesModifiedExternallyEventAttributes) String() string

func (*ActivityPropertiesModifiedExternallyEventAttributes) Unmarshal added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityPropertiesModifiedExternallyEventAttributes) XXX_DiscardUnknown added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) XXX_DiscardUnknown()

func (*ActivityPropertiesModifiedExternallyEventAttributes) XXX_Marshal added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityPropertiesModifiedExternallyEventAttributes) XXX_Merge added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityPropertiesModifiedExternallyEventAttributes) XXX_Size added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) XXX_Size() int

func (*ActivityPropertiesModifiedExternallyEventAttributes) XXX_Unmarshal added in v1.11.0 

func (m *ActivityPropertiesModifiedExternallyEventAttributes) XXX_Unmarshal(b []byte) error

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 */
}

func (*ActivityTaskCancelRequestedEventAttributes) Descriptor 

func (*ActivityTaskCancelRequestedEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityTaskCancelRequestedEventAttributes) Equal 

func (this *ActivityTaskCancelRequestedEventAttributes) Equal(that interface{}) bool

func (*ActivityTaskCancelRequestedEventAttributes) GetScheduledEventId 

func (m *ActivityTaskCancelRequestedEventAttributes) GetScheduledEventId() int64

func (*ActivityTaskCancelRequestedEventAttributes) GetWorkflowTaskCompletedEventId 

func (m *ActivityTaskCancelRequestedEventAttributes) GetWorkflowTaskCompletedEventId() int64

func (*ActivityTaskCancelRequestedEventAttributes) GoString 

func (this *ActivityTaskCancelRequestedEventAttributes) GoString() string

func (*ActivityTaskCancelRequestedEventAttributes) Marshal 

func (m *ActivityTaskCancelRequestedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityTaskCancelRequestedEventAttributes) MarshalTo 

func (m *ActivityTaskCancelRequestedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityTaskCancelRequestedEventAttributes) MarshalToSizedBuffer 

func (m *ActivityTaskCancelRequestedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityTaskCancelRequestedEventAttributes) ProtoMessage 

func (*ActivityTaskCancelRequestedEventAttributes) ProtoMessage()

func (*ActivityTaskCancelRequestedEventAttributes) Reset 

func (m *ActivityTaskCancelRequestedEventAttributes) Reset()

func (*ActivityTaskCancelRequestedEventAttributes) Size 

func (m *ActivityTaskCancelRequestedEventAttributes) Size() (n int)

func (*ActivityTaskCancelRequestedEventAttributes) String 

func (this *ActivityTaskCancelRequestedEventAttributes) String() string

func (*ActivityTaskCancelRequestedEventAttributes) Unmarshal 

func (m *ActivityTaskCancelRequestedEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityTaskCancelRequestedEventAttributes) XXX_DiscardUnknown 

func (m *ActivityTaskCancelRequestedEventAttributes) XXX_DiscardUnknown()

func (*ActivityTaskCancelRequestedEventAttributes) XXX_Marshal 

func (m *ActivityTaskCancelRequestedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityTaskCancelRequestedEventAttributes) XXX_Merge 

func (m *ActivityTaskCancelRequestedEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityTaskCancelRequestedEventAttributes) XXX_Size 

func (m *ActivityTaskCancelRequestedEventAttributes) XXX_Size() int

func (*ActivityTaskCancelRequestedEventAttributes) XXX_Unmarshal 

func (m *ActivityTaskCancelRequestedEventAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ActivityTaskCanceledEventAttributes) Descriptor 

func (*ActivityTaskCanceledEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityTaskCanceledEventAttributes) Equal 

func (this *ActivityTaskCanceledEventAttributes) Equal(that interface{}) bool

func (*ActivityTaskCanceledEventAttributes) GetDetails 

func (m *ActivityTaskCanceledEventAttributes) GetDetails() *v1.Payloads

func (*ActivityTaskCanceledEventAttributes) GetIdentity 

func (m *ActivityTaskCanceledEventAttributes) GetIdentity() string

func (*ActivityTaskCanceledEventAttributes) GetLatestCancelRequestedEventId 

func (m *ActivityTaskCanceledEventAttributes) GetLatestCancelRequestedEventId() int64

func (*ActivityTaskCanceledEventAttributes) GetScheduledEventId 

func (m *ActivityTaskCanceledEventAttributes) GetScheduledEventId() int64

func (*ActivityTaskCanceledEventAttributes) GetStartedEventId 

func (m *ActivityTaskCanceledEventAttributes) GetStartedEventId() int64

func (*ActivityTaskCanceledEventAttributes) GoString 

func (this *ActivityTaskCanceledEventAttributes) GoString() string

func (*ActivityTaskCanceledEventAttributes) Marshal 

func (m *ActivityTaskCanceledEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityTaskCanceledEventAttributes) MarshalTo 

func (m *ActivityTaskCanceledEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityTaskCanceledEventAttributes) MarshalToSizedBuffer 

func (m *ActivityTaskCanceledEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityTaskCanceledEventAttributes) ProtoMessage 

func (*ActivityTaskCanceledEventAttributes) ProtoMessage()

func (*ActivityTaskCanceledEventAttributes) Reset 

func (m *ActivityTaskCanceledEventAttributes) Reset()

func (*ActivityTaskCanceledEventAttributes) Size 

func (m *ActivityTaskCanceledEventAttributes) Size() (n int)

func (*ActivityTaskCanceledEventAttributes) String 

func (this *ActivityTaskCanceledEventAttributes) String() string

func (*ActivityTaskCanceledEventAttributes) Unmarshal 

func (m *ActivityTaskCanceledEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityTaskCanceledEventAttributes) XXX_DiscardUnknown 

func (m *ActivityTaskCanceledEventAttributes) XXX_DiscardUnknown()

func (*ActivityTaskCanceledEventAttributes) XXX_Marshal 

func (m *ActivityTaskCanceledEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityTaskCanceledEventAttributes) XXX_Merge 

func (m *ActivityTaskCanceledEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityTaskCanceledEventAttributes) XXX_Size 

func (m *ActivityTaskCanceledEventAttributes) XXX_Size() int

func (*ActivityTaskCanceledEventAttributes) XXX_Unmarshal 

func (m *ActivityTaskCanceledEventAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ActivityTaskCompletedEventAttributes) Descriptor 

func (*ActivityTaskCompletedEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityTaskCompletedEventAttributes) Equal 

func (this *ActivityTaskCompletedEventAttributes) Equal(that interface{}) bool

func (*ActivityTaskCompletedEventAttributes) GetIdentity 

func (m *ActivityTaskCompletedEventAttributes) GetIdentity() string

func (*ActivityTaskCompletedEventAttributes) GetResult 

func (m *ActivityTaskCompletedEventAttributes) GetResult() *v1.Payloads

func (*ActivityTaskCompletedEventAttributes) GetScheduledEventId 

func (m *ActivityTaskCompletedEventAttributes) GetScheduledEventId() int64

func (*ActivityTaskCompletedEventAttributes) GetStartedEventId 

func (m *ActivityTaskCompletedEventAttributes) GetStartedEventId() int64

func (*ActivityTaskCompletedEventAttributes) GoString 

func (this *ActivityTaskCompletedEventAttributes) GoString() string

func (*ActivityTaskCompletedEventAttributes) Marshal 

func (m *ActivityTaskCompletedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityTaskCompletedEventAttributes) MarshalTo 

func (m *ActivityTaskCompletedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityTaskCompletedEventAttributes) MarshalToSizedBuffer 

func (m *ActivityTaskCompletedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityTaskCompletedEventAttributes) ProtoMessage 

func (*ActivityTaskCompletedEventAttributes) ProtoMessage()

func (*ActivityTaskCompletedEventAttributes) Reset 

func (m *ActivityTaskCompletedEventAttributes) Reset()

func (*ActivityTaskCompletedEventAttributes) Size 

func (m *ActivityTaskCompletedEventAttributes) Size() (n int)

func (*ActivityTaskCompletedEventAttributes) String 

func (this *ActivityTaskCompletedEventAttributes) String() string

func (*ActivityTaskCompletedEventAttributes) Unmarshal 

func (m *ActivityTaskCompletedEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityTaskCompletedEventAttributes) XXX_DiscardUnknown 

func (m *ActivityTaskCompletedEventAttributes) XXX_DiscardUnknown()

func (*ActivityTaskCompletedEventAttributes) XXX_Marshal 

func (m *ActivityTaskCompletedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityTaskCompletedEventAttributes) XXX_Merge 

func (m *ActivityTaskCompletedEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityTaskCompletedEventAttributes) XXX_Size 

func (m *ActivityTaskCompletedEventAttributes) XXX_Size() int

func (*ActivityTaskCompletedEventAttributes) XXX_Unmarshal 

func (m *ActivityTaskCompletedEventAttributes) XXX_Unmarshal(b []byte) error

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 */
}

func (*ActivityTaskFailedEventAttributes) Descriptor 

func (*ActivityTaskFailedEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityTaskFailedEventAttributes) Equal 

func (this *ActivityTaskFailedEventAttributes) Equal(that interface{}) bool

func (*ActivityTaskFailedEventAttributes) GetFailure 

func (m *ActivityTaskFailedEventAttributes) GetFailure() *v13.Failure

func (*ActivityTaskFailedEventAttributes) GetIdentity 

func (m *ActivityTaskFailedEventAttributes) GetIdentity() string

func (*ActivityTaskFailedEventAttributes) GetRetryState 

func (m *ActivityTaskFailedEventAttributes) GetRetryState() v12.RetryState

func (*ActivityTaskFailedEventAttributes) GetScheduledEventId 

func (m *ActivityTaskFailedEventAttributes) GetScheduledEventId() int64

func (*ActivityTaskFailedEventAttributes) GetStartedEventId 

func (m *ActivityTaskFailedEventAttributes) GetStartedEventId() int64

func (*ActivityTaskFailedEventAttributes) GoString 

func (this *ActivityTaskFailedEventAttributes) GoString() string

func (*ActivityTaskFailedEventAttributes) Marshal 

func (m *ActivityTaskFailedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityTaskFailedEventAttributes) MarshalTo 

func (m *ActivityTaskFailedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityTaskFailedEventAttributes) MarshalToSizedBuffer 

func (m *ActivityTaskFailedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityTaskFailedEventAttributes) ProtoMessage 

func (*ActivityTaskFailedEventAttributes) ProtoMessage()

func (*ActivityTaskFailedEventAttributes) Reset 

func (m *ActivityTaskFailedEventAttributes) Reset()

func (*ActivityTaskFailedEventAttributes) Size 

func (m *ActivityTaskFailedEventAttributes) Size() (n int)

func (*ActivityTaskFailedEventAttributes) String 

func (this *ActivityTaskFailedEventAttributes) String() string

func (*ActivityTaskFailedEventAttributes) Unmarshal 

func (m *ActivityTaskFailedEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityTaskFailedEventAttributes) XXX_DiscardUnknown 

func (m *ActivityTaskFailedEventAttributes) XXX_DiscardUnknown()

func (*ActivityTaskFailedEventAttributes) XXX_Marshal 

func (m *ActivityTaskFailedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityTaskFailedEventAttributes) XXX_Merge 

func (m *ActivityTaskFailedEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityTaskFailedEventAttributes) XXX_Size 

func (m *ActivityTaskFailedEventAttributes) XXX_Size() int

func (*ActivityTaskFailedEventAttributes) XXX_Unmarshal 

func (m *ActivityTaskFailedEventAttributes) XXX_Unmarshal(b []byte) error

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 *time.Duration `` /* 143-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 *time.Duration `` /* 143-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 *time.Duration `` /* 134-byte string literal not displayed */
	// Maximum permitted time between successful worker heartbeats.
	HeartbeatTimeout *time.Duration `protobuf:"bytes,10,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3,stdduration" 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"`
}

func (*ActivityTaskScheduledEventAttributes) Descriptor 

func (*ActivityTaskScheduledEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityTaskScheduledEventAttributes) Equal 

func (this *ActivityTaskScheduledEventAttributes) Equal(that interface{}) bool

func (*ActivityTaskScheduledEventAttributes) GetActivityId 

func (m *ActivityTaskScheduledEventAttributes) GetActivityId() string

func (*ActivityTaskScheduledEventAttributes) GetActivityType 

func (m *ActivityTaskScheduledEventAttributes) GetActivityType() *v1.ActivityType

func (*ActivityTaskScheduledEventAttributes) GetHeader 

func (m *ActivityTaskScheduledEventAttributes) GetHeader() *v1.Header

func (*ActivityTaskScheduledEventAttributes) GetHeartbeatTimeout added in v0.28.0 

func (m *ActivityTaskScheduledEventAttributes) GetHeartbeatTimeout() *time.Duration

func (*ActivityTaskScheduledEventAttributes) GetInput 

func (m *ActivityTaskScheduledEventAttributes) GetInput() *v1.Payloads

func (*ActivityTaskScheduledEventAttributes) GetRetryPolicy 

func (m *ActivityTaskScheduledEventAttributes) GetRetryPolicy() *v1.RetryPolicy

func (*ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeout added in v0.28.0 

func (m *ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeout() *time.Duration

func (*ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeout added in v0.28.0 

func (m *ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeout() *time.Duration

func (*ActivityTaskScheduledEventAttributes) GetStartToCloseTimeout added in v0.28.0 

func (m *ActivityTaskScheduledEventAttributes) GetStartToCloseTimeout() *time.Duration

func (*ActivityTaskScheduledEventAttributes) GetTaskQueue 

func (m *ActivityTaskScheduledEventAttributes) GetTaskQueue() *v11.TaskQueue

func (*ActivityTaskScheduledEventAttributes) GetWorkflowTaskCompletedEventId 

func (m *ActivityTaskScheduledEventAttributes) GetWorkflowTaskCompletedEventId() int64

func (*ActivityTaskScheduledEventAttributes) GoString 

func (this *ActivityTaskScheduledEventAttributes) GoString() string

func (*ActivityTaskScheduledEventAttributes) Marshal 

func (m *ActivityTaskScheduledEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityTaskScheduledEventAttributes) MarshalTo 

func (m *ActivityTaskScheduledEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityTaskScheduledEventAttributes) MarshalToSizedBuffer 

func (m *ActivityTaskScheduledEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityTaskScheduledEventAttributes) ProtoMessage 

func (*ActivityTaskScheduledEventAttributes) ProtoMessage()

func (*ActivityTaskScheduledEventAttributes) Reset 

func (m *ActivityTaskScheduledEventAttributes) Reset()

func (*ActivityTaskScheduledEventAttributes) Size 

func (m *ActivityTaskScheduledEventAttributes) Size() (n int)

func (*ActivityTaskScheduledEventAttributes) String 

func (this *ActivityTaskScheduledEventAttributes) String() string

func (*ActivityTaskScheduledEventAttributes) Unmarshal 

func (m *ActivityTaskScheduledEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityTaskScheduledEventAttributes) XXX_DiscardUnknown 

func (m *ActivityTaskScheduledEventAttributes) XXX_DiscardUnknown()

func (*ActivityTaskScheduledEventAttributes) XXX_Marshal 

func (m *ActivityTaskScheduledEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityTaskScheduledEventAttributes) XXX_Merge 

func (m *ActivityTaskScheduledEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityTaskScheduledEventAttributes) XXX_Size 

func (m *ActivityTaskScheduledEventAttributes) XXX_Size() int

func (*ActivityTaskScheduledEventAttributes) XXX_Unmarshal 

func (m *ActivityTaskScheduledEventAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ActivityTaskStartedEventAttributes) Descriptor 

func (*ActivityTaskStartedEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityTaskStartedEventAttributes) Equal 

func (this *ActivityTaskStartedEventAttributes) Equal(that interface{}) bool

func (*ActivityTaskStartedEventAttributes) GetAttempt 

func (m *ActivityTaskStartedEventAttributes) GetAttempt() int32

func (*ActivityTaskStartedEventAttributes) GetIdentity 

func (m *ActivityTaskStartedEventAttributes) GetIdentity() string

func (*ActivityTaskStartedEventAttributes) GetLastFailure 

func (m *ActivityTaskStartedEventAttributes) GetLastFailure() *v13.Failure

func (*ActivityTaskStartedEventAttributes) GetRequestId 

func (m *ActivityTaskStartedEventAttributes) GetRequestId() string

func (*ActivityTaskStartedEventAttributes) GetScheduledEventId 

func (m *ActivityTaskStartedEventAttributes) GetScheduledEventId() int64

func (*ActivityTaskStartedEventAttributes) GoString 

func (this *ActivityTaskStartedEventAttributes) GoString() string

func (*ActivityTaskStartedEventAttributes) Marshal 

func (m *ActivityTaskStartedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityTaskStartedEventAttributes) MarshalTo 

func (m *ActivityTaskStartedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityTaskStartedEventAttributes) MarshalToSizedBuffer 

func (m *ActivityTaskStartedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityTaskStartedEventAttributes) ProtoMessage 

func (*ActivityTaskStartedEventAttributes) ProtoMessage()

func (*ActivityTaskStartedEventAttributes) Reset 

func (m *ActivityTaskStartedEventAttributes) Reset()

func (*ActivityTaskStartedEventAttributes) Size 

func (m *ActivityTaskStartedEventAttributes) Size() (n int)

func (*ActivityTaskStartedEventAttributes) String 

func (this *ActivityTaskStartedEventAttributes) String() string

func (*ActivityTaskStartedEventAttributes) Unmarshal 

func (m *ActivityTaskStartedEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityTaskStartedEventAttributes) XXX_DiscardUnknown 

func (m *ActivityTaskStartedEventAttributes) XXX_DiscardUnknown()

func (*ActivityTaskStartedEventAttributes) XXX_Marshal 

func (m *ActivityTaskStartedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityTaskStartedEventAttributes) XXX_Merge 

func (m *ActivityTaskStartedEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityTaskStartedEventAttributes) XXX_Size 

func (m *ActivityTaskStartedEventAttributes) XXX_Size() int

func (*ActivityTaskStartedEventAttributes) XXX_Unmarshal 

func (m *ActivityTaskStartedEventAttributes) XXX_Unmarshal(b []byte) error

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 */
}

func (*ActivityTaskTimedOutEventAttributes) Descriptor 

func (*ActivityTaskTimedOutEventAttributes) Descriptor() ([]byte, []int)

func (*ActivityTaskTimedOutEventAttributes) Equal 

func (this *ActivityTaskTimedOutEventAttributes) Equal(that interface{}) bool

func (*ActivityTaskTimedOutEventAttributes) GetFailure 

func (m *ActivityTaskTimedOutEventAttributes) GetFailure() *v13.Failure

func (*ActivityTaskTimedOutEventAttributes) GetRetryState 

func (m *ActivityTaskTimedOutEventAttributes) GetRetryState() v12.RetryState

func (*ActivityTaskTimedOutEventAttributes) GetScheduledEventId 

func (m *ActivityTaskTimedOutEventAttributes) GetScheduledEventId() int64

func (*ActivityTaskTimedOutEventAttributes) GetStartedEventId 

func (m *ActivityTaskTimedOutEventAttributes) GetStartedEventId() int64

func (*ActivityTaskTimedOutEventAttributes) GoString 

func (this *ActivityTaskTimedOutEventAttributes) GoString() string

func (*ActivityTaskTimedOutEventAttributes) Marshal 

func (m *ActivityTaskTimedOutEventAttributes) Marshal() (dAtA []byte, err error)

func (*ActivityTaskTimedOutEventAttributes) MarshalTo 

func (m *ActivityTaskTimedOutEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ActivityTaskTimedOutEventAttributes) MarshalToSizedBuffer 

func (m *ActivityTaskTimedOutEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityTaskTimedOutEventAttributes) ProtoMessage 

func (*ActivityTaskTimedOutEventAttributes) ProtoMessage()

func (*ActivityTaskTimedOutEventAttributes) Reset 

func (m *ActivityTaskTimedOutEventAttributes) Reset()

func (*ActivityTaskTimedOutEventAttributes) Size 

func (m *ActivityTaskTimedOutEventAttributes) Size() (n int)

func (*ActivityTaskTimedOutEventAttributes) String 

func (this *ActivityTaskTimedOutEventAttributes) String() string

func (*ActivityTaskTimedOutEventAttributes) Unmarshal 

func (m *ActivityTaskTimedOutEventAttributes) Unmarshal(dAtA []byte) error

func (*ActivityTaskTimedOutEventAttributes) XXX_DiscardUnknown 

func (m *ActivityTaskTimedOutEventAttributes) XXX_DiscardUnknown()

func (*ActivityTaskTimedOutEventAttributes) XXX_Marshal 

func (m *ActivityTaskTimedOutEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityTaskTimedOutEventAttributes) XXX_Merge 

func (m *ActivityTaskTimedOutEventAttributes) XXX_Merge(src proto.Message)

func (*ActivityTaskTimedOutEventAttributes) XXX_Size 

func (m *ActivityTaskTimedOutEventAttributes) XXX_Size() int

func (*ActivityTaskTimedOutEventAttributes) XXX_Unmarshal 

func (m *ActivityTaskTimedOutEventAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ChildWorkflowExecutionCanceledEventAttributes) Descriptor 

func (*ChildWorkflowExecutionCanceledEventAttributes) Descriptor() ([]byte, []int)

func (*ChildWorkflowExecutionCanceledEventAttributes) Equal 

func (this *ChildWorkflowExecutionCanceledEventAttributes) Equal(that interface{}) bool

func (*ChildWorkflowExecutionCanceledEventAttributes) GetDetails 

func (m *ChildWorkflowExecutionCanceledEventAttributes) GetDetails() *v1.Payloads

func (*ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventId 

func (m *ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventId() int64

func (*ChildWorkflowExecutionCanceledEventAttributes) GetNamespace 

func (m *ChildWorkflowExecutionCanceledEventAttributes) GetNamespace() string

func (*ChildWorkflowExecutionCanceledEventAttributes) GetNamespaceId added in v1.8.0 

func (m *ChildWorkflowExecutionCanceledEventAttributes) GetNamespaceId() string

func (*ChildWorkflowExecutionCanceledEventAttributes) GetStartedEventId 

func (m *ChildWorkflowExecutionCanceledEventAttributes) GetStartedEventId() int64

func (*ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowExecution 

func (m *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowType 

func (m *ChildWorkflowExecutionCanceledEventAttributes) GetWorkflowType() *v1.WorkflowType

func (*ChildWorkflowExecutionCanceledEventAttributes) GoString 

func (this *ChildWorkflowExecutionCanceledEventAttributes) GoString() string

func (*ChildWorkflowExecutionCanceledEventAttributes) Marshal 

func (m *ChildWorkflowExecutionCanceledEventAttributes) Marshal() (dAtA []byte, err error)

func (*ChildWorkflowExecutionCanceledEventAttributes) MarshalTo 

func (m *ChildWorkflowExecutionCanceledEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionCanceledEventAttributes) MarshalToSizedBuffer 

func (m *ChildWorkflowExecutionCanceledEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionCanceledEventAttributes) ProtoMessage 

func (*ChildWorkflowExecutionCanceledEventAttributes) ProtoMessage()

func (*ChildWorkflowExecutionCanceledEventAttributes) Reset 

func (m *ChildWorkflowExecutionCanceledEventAttributes) Reset()

func (*ChildWorkflowExecutionCanceledEventAttributes) Size 

func (m *ChildWorkflowExecutionCanceledEventAttributes) Size() (n int)

func (*ChildWorkflowExecutionCanceledEventAttributes) String 

func (this *ChildWorkflowExecutionCanceledEventAttributes) String() string

func (*ChildWorkflowExecutionCanceledEventAttributes) Unmarshal 

func (m *ChildWorkflowExecutionCanceledEventAttributes) Unmarshal(dAtA []byte) error

func (*ChildWorkflowExecutionCanceledEventAttributes) XXX_DiscardUnknown 

func (m *ChildWorkflowExecutionCanceledEventAttributes) XXX_DiscardUnknown()

func (*ChildWorkflowExecutionCanceledEventAttributes) XXX_Marshal 

func (m *ChildWorkflowExecutionCanceledEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChildWorkflowExecutionCanceledEventAttributes) XXX_Merge 

func (m *ChildWorkflowExecutionCanceledEventAttributes) XXX_Merge(src proto.Message)

func (*ChildWorkflowExecutionCanceledEventAttributes) XXX_Size 

func (m *ChildWorkflowExecutionCanceledEventAttributes) XXX_Size() int

func (*ChildWorkflowExecutionCanceledEventAttributes) XXX_Unmarshal 

func (m *ChildWorkflowExecutionCanceledEventAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ChildWorkflowExecutionCompletedEventAttributes) Descriptor 

func (*ChildWorkflowExecutionCompletedEventAttributes) Descriptor() ([]byte, []int)

func (*ChildWorkflowExecutionCompletedEventAttributes) Equal 

func (this *ChildWorkflowExecutionCompletedEventAttributes) Equal(that interface{}) bool

func (*ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventId 

func (m *ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventId() int64

func (*ChildWorkflowExecutionCompletedEventAttributes) GetNamespace 

func (m *ChildWorkflowExecutionCompletedEventAttributes) GetNamespace() string

func (*ChildWorkflowExecutionCompletedEventAttributes) GetNamespaceId added in v1.8.0 

func (m *ChildWorkflowExecutionCompletedEventAttributes) GetNamespaceId() string

func (*ChildWorkflowExecutionCompletedEventAttributes) GetResult 

func (m *ChildWorkflowExecutionCompletedEventAttributes) GetResult() *v1.Payloads

func (*ChildWorkflowExecutionCompletedEventAttributes) GetStartedEventId 

func (m *ChildWorkflowExecutionCompletedEventAttributes) GetStartedEventId() int64

func (*ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowExecution 

func (m *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowType 

func (m *ChildWorkflowExecutionCompletedEventAttributes) GetWorkflowType() *v1.WorkflowType

func (*ChildWorkflowExecutionCompletedEventAttributes) GoString 

func (this *ChildWorkflowExecutionCompletedEventAttributes) GoString() string

func (*ChildWorkflowExecutionCompletedEventAttributes) Marshal 

func (m *ChildWorkflowExecutionCompletedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ChildWorkflowExecutionCompletedEventAttributes) MarshalTo 

func (m *ChildWorkflowExecutionCompletedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionCompletedEventAttributes) MarshalToSizedBuffer 

func (m *ChildWorkflowExecutionCompletedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionCompletedEventAttributes) ProtoMessage 

func (*ChildWorkflowExecutionCompletedEventAttributes) ProtoMessage()

func (*ChildWorkflowExecutionCompletedEventAttributes) Reset 

func (m *ChildWorkflowExecutionCompletedEventAttributes) Reset()

func (*ChildWorkflowExecutionCompletedEventAttributes) Size 

func (m *ChildWorkflowExecutionCompletedEventAttributes) Size() (n int)

func (*ChildWorkflowExecutionCompletedEventAttributes) String 

func (this *ChildWorkflowExecutionCompletedEventAttributes) String() string

func (*ChildWorkflowExecutionCompletedEventAttributes) Unmarshal 

func (m *ChildWorkflowExecutionCompletedEventAttributes) Unmarshal(dAtA []byte) error

func (*ChildWorkflowExecutionCompletedEventAttributes) XXX_DiscardUnknown 

func (m *ChildWorkflowExecutionCompletedEventAttributes) XXX_DiscardUnknown()

func (*ChildWorkflowExecutionCompletedEventAttributes) XXX_Marshal 

func (m *ChildWorkflowExecutionCompletedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChildWorkflowExecutionCompletedEventAttributes) XXX_Merge 

func (m *ChildWorkflowExecutionCompletedEventAttributes) XXX_Merge(src proto.Message)

func (*ChildWorkflowExecutionCompletedEventAttributes) XXX_Size 

func (m *ChildWorkflowExecutionCompletedEventAttributes) XXX_Size() int

func (*ChildWorkflowExecutionCompletedEventAttributes) XXX_Unmarshal 

func (m *ChildWorkflowExecutionCompletedEventAttributes) XXX_Unmarshal(b []byte) error

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 */
}

func (*ChildWorkflowExecutionFailedEventAttributes) Descriptor 

func (*ChildWorkflowExecutionFailedEventAttributes) Descriptor() ([]byte, []int)

func (*ChildWorkflowExecutionFailedEventAttributes) Equal 

func (this *ChildWorkflowExecutionFailedEventAttributes) Equal(that interface{}) bool

func (*ChildWorkflowExecutionFailedEventAttributes) GetFailure 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetFailure() *v13.Failure

func (*ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventId() int64

func (*ChildWorkflowExecutionFailedEventAttributes) GetNamespace 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetNamespace() string

func (*ChildWorkflowExecutionFailedEventAttributes) GetNamespaceId added in v1.8.0 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetNamespaceId() string

func (*ChildWorkflowExecutionFailedEventAttributes) GetRetryState 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetRetryState() v12.RetryState

func (*ChildWorkflowExecutionFailedEventAttributes) GetStartedEventId 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetStartedEventId() int64

func (*ChildWorkflowExecutionFailedEventAttributes) GetWorkflowExecution 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*ChildWorkflowExecutionFailedEventAttributes) GetWorkflowType 

func (m *ChildWorkflowExecutionFailedEventAttributes) GetWorkflowType() *v1.WorkflowType

func (*ChildWorkflowExecutionFailedEventAttributes) GoString 

func (this *ChildWorkflowExecutionFailedEventAttributes) GoString() string

func (*ChildWorkflowExecutionFailedEventAttributes) Marshal 

func (m *ChildWorkflowExecutionFailedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ChildWorkflowExecutionFailedEventAttributes) MarshalTo 

func (m *ChildWorkflowExecutionFailedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionFailedEventAttributes) MarshalToSizedBuffer 

func (m *ChildWorkflowExecutionFailedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionFailedEventAttributes) ProtoMessage 

func (*ChildWorkflowExecutionFailedEventAttributes) ProtoMessage()

func (*ChildWorkflowExecutionFailedEventAttributes) Reset 

func (m *ChildWorkflowExecutionFailedEventAttributes) Reset()

func (*ChildWorkflowExecutionFailedEventAttributes) Size 

func (m *ChildWorkflowExecutionFailedEventAttributes) Size() (n int)

func (*ChildWorkflowExecutionFailedEventAttributes) String 

func (this *ChildWorkflowExecutionFailedEventAttributes) String() string

func (*ChildWorkflowExecutionFailedEventAttributes) Unmarshal 

func (m *ChildWorkflowExecutionFailedEventAttributes) Unmarshal(dAtA []byte) error

func (*ChildWorkflowExecutionFailedEventAttributes) XXX_DiscardUnknown 

func (m *ChildWorkflowExecutionFailedEventAttributes) XXX_DiscardUnknown()

func (*ChildWorkflowExecutionFailedEventAttributes) XXX_Marshal 

func (m *ChildWorkflowExecutionFailedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChildWorkflowExecutionFailedEventAttributes) XXX_Merge 

func (m *ChildWorkflowExecutionFailedEventAttributes) XXX_Merge(src proto.Message)

func (*ChildWorkflowExecutionFailedEventAttributes) XXX_Size 

func (m *ChildWorkflowExecutionFailedEventAttributes) XXX_Size() int

func (*ChildWorkflowExecutionFailedEventAttributes) XXX_Unmarshal 

func (m *ChildWorkflowExecutionFailedEventAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ChildWorkflowExecutionStartedEventAttributes) Descriptor 

func (*ChildWorkflowExecutionStartedEventAttributes) Descriptor() ([]byte, []int)

func (*ChildWorkflowExecutionStartedEventAttributes) Equal 

func (this *ChildWorkflowExecutionStartedEventAttributes) Equal(that interface{}) bool

func (*ChildWorkflowExecutionStartedEventAttributes) GetHeader 

func (m *ChildWorkflowExecutionStartedEventAttributes) GetHeader() *v1.Header

func (*ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventId 

func (m *ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventId() int64

func (*ChildWorkflowExecutionStartedEventAttributes) GetNamespace 

func (m *ChildWorkflowExecutionStartedEventAttributes) GetNamespace() string

func (*ChildWorkflowExecutionStartedEventAttributes) GetNamespaceId added in v1.8.0 

func (m *ChildWorkflowExecutionStartedEventAttributes) GetNamespaceId() string

func (*ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution 

func (m *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*ChildWorkflowExecutionStartedEventAttributes) GetWorkflowType 

func (m *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowType() *v1.WorkflowType

func (*ChildWorkflowExecutionStartedEventAttributes) GoString 

func (this *ChildWorkflowExecutionStartedEventAttributes) GoString() string

func (*ChildWorkflowExecutionStartedEventAttributes) Marshal 

func (m *ChildWorkflowExecutionStartedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ChildWorkflowExecutionStartedEventAttributes) MarshalTo 

func (m *ChildWorkflowExecutionStartedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionStartedEventAttributes) MarshalToSizedBuffer 

func (m *ChildWorkflowExecutionStartedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionStartedEventAttributes) ProtoMessage 

func (*ChildWorkflowExecutionStartedEventAttributes) ProtoMessage()

func (*ChildWorkflowExecutionStartedEventAttributes) Reset 

func (m *ChildWorkflowExecutionStartedEventAttributes) Reset()

func (*ChildWorkflowExecutionStartedEventAttributes) Size 

func (m *ChildWorkflowExecutionStartedEventAttributes) Size() (n int)

func (*ChildWorkflowExecutionStartedEventAttributes) String 

func (this *ChildWorkflowExecutionStartedEventAttributes) String() string

func (*ChildWorkflowExecutionStartedEventAttributes) Unmarshal 

func (m *ChildWorkflowExecutionStartedEventAttributes) Unmarshal(dAtA []byte) error

func (*ChildWorkflowExecutionStartedEventAttributes) XXX_DiscardUnknown 

func (m *ChildWorkflowExecutionStartedEventAttributes) XXX_DiscardUnknown()

func (*ChildWorkflowExecutionStartedEventAttributes) XXX_Marshal 

func (m *ChildWorkflowExecutionStartedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChildWorkflowExecutionStartedEventAttributes) XXX_Merge 

func (m *ChildWorkflowExecutionStartedEventAttributes) XXX_Merge(src proto.Message)

func (*ChildWorkflowExecutionStartedEventAttributes) XXX_Size 

func (m *ChildWorkflowExecutionStartedEventAttributes) XXX_Size() int

func (*ChildWorkflowExecutionStartedEventAttributes) XXX_Unmarshal 

func (m *ChildWorkflowExecutionStartedEventAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ChildWorkflowExecutionTerminatedEventAttributes) Descriptor 

func (*ChildWorkflowExecutionTerminatedEventAttributes) Descriptor() ([]byte, []int)

func (*ChildWorkflowExecutionTerminatedEventAttributes) Equal 

func (this *ChildWorkflowExecutionTerminatedEventAttributes) Equal(that interface{}) bool

func (*ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventId 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventId() int64

func (*ChildWorkflowExecutionTerminatedEventAttributes) GetNamespace 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) GetNamespace() string

func (*ChildWorkflowExecutionTerminatedEventAttributes) GetNamespaceId added in v1.8.0 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) GetNamespaceId() string

func (*ChildWorkflowExecutionTerminatedEventAttributes) GetStartedEventId 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) GetStartedEventId() int64

func (*ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowExecution 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowType 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) GetWorkflowType() *v1.WorkflowType

func (*ChildWorkflowExecutionTerminatedEventAttributes) GoString 

func (this *ChildWorkflowExecutionTerminatedEventAttributes) GoString() string

func (*ChildWorkflowExecutionTerminatedEventAttributes) Marshal 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) Marshal() (dAtA []byte, err error)

func (*ChildWorkflowExecutionTerminatedEventAttributes) MarshalTo 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionTerminatedEventAttributes) MarshalToSizedBuffer 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionTerminatedEventAttributes) ProtoMessage 

func (*ChildWorkflowExecutionTerminatedEventAttributes) ProtoMessage()

func (*ChildWorkflowExecutionTerminatedEventAttributes) Reset 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) Reset()

func (*ChildWorkflowExecutionTerminatedEventAttributes) Size 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) Size() (n int)

func (*ChildWorkflowExecutionTerminatedEventAttributes) String 

func (this *ChildWorkflowExecutionTerminatedEventAttributes) String() string

func (*ChildWorkflowExecutionTerminatedEventAttributes) Unmarshal 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) Unmarshal(dAtA []byte) error

func (*ChildWorkflowExecutionTerminatedEventAttributes) XXX_DiscardUnknown 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) XXX_DiscardUnknown()

func (*ChildWorkflowExecutionTerminatedEventAttributes) XXX_Marshal 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChildWorkflowExecutionTerminatedEventAttributes) XXX_Merge 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) XXX_Merge(src proto.Message)

func (*ChildWorkflowExecutionTerminatedEventAttributes) XXX_Size 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) XXX_Size() int

func (*ChildWorkflowExecutionTerminatedEventAttributes) XXX_Unmarshal 

func (m *ChildWorkflowExecutionTerminatedEventAttributes) XXX_Unmarshal(b []byte) error

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 */
}

func (*ChildWorkflowExecutionTimedOutEventAttributes) Descriptor 

func (*ChildWorkflowExecutionTimedOutEventAttributes) Descriptor() ([]byte, []int)

func (*ChildWorkflowExecutionTimedOutEventAttributes) Equal 

func (this *ChildWorkflowExecutionTimedOutEventAttributes) Equal(that interface{}) bool

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventId 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventId() int64

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetNamespace 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) GetNamespace() string

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetNamespaceId added in v1.8.0 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) GetNamespaceId() string

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetRetryState 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) GetRetryState() v12.RetryState

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetStartedEventId 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) GetStartedEventId() int64

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowExecution 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowExecution() *v1.WorkflowExecution

func (*ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowType 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) GetWorkflowType() *v1.WorkflowType

func (*ChildWorkflowExecutionTimedOutEventAttributes) GoString 

func (this *ChildWorkflowExecutionTimedOutEventAttributes) GoString() string

func (*ChildWorkflowExecutionTimedOutEventAttributes) Marshal 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) Marshal() (dAtA []byte, err error)

func (*ChildWorkflowExecutionTimedOutEventAttributes) MarshalTo 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionTimedOutEventAttributes) MarshalToSizedBuffer 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChildWorkflowExecutionTimedOutEventAttributes) ProtoMessage 

func (*ChildWorkflowExecutionTimedOutEventAttributes) ProtoMessage()

func (*ChildWorkflowExecutionTimedOutEventAttributes) Reset 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) Reset()

func (*ChildWorkflowExecutionTimedOutEventAttributes) Size 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) Size() (n int)

func (*ChildWorkflowExecutionTimedOutEventAttributes) String 

func (this *ChildWorkflowExecutionTimedOutEventAttributes) String() string

func (*ChildWorkflowExecutionTimedOutEventAttributes) Unmarshal 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) Unmarshal(dAtA []byte) error

func (*ChildWorkflowExecutionTimedOutEventAttributes) XXX_DiscardUnknown 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) XXX_DiscardUnknown()

func (*ChildWorkflowExecutionTimedOutEventAttributes) XXX_Marshal 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChildWorkflowExecutionTimedOutEventAttributes) XXX_Merge 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) XXX_Merge(src proto.Message)

func (*ChildWorkflowExecutionTimedOutEventAttributes) XXX_Size 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) XXX_Size() int

func (*ChildWorkflowExecutionTimedOutEventAttributes) XXX_Unmarshal 

func (m *ChildWorkflowExecutionTimedOutEventAttributes) XXX_Unmarshal(b []byte)