message.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// plugins:
// 	protoc-gen-go
// 	protoc
// source: temporal/api/activity/v1/message.proto

package activity

import (
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"

	v16 "go.temporal.io/api/callback/v1"
	v1 "go.temporal.io/api/common/v1"
	v14 "go.temporal.io/api/deployment/v1"
	v13 "go.temporal.io/api/enums/v1"
	v11 "go.temporal.io/api/failure/v1"
	v15 "go.temporal.io/api/sdk/v1"
	v12 "go.temporal.io/api/taskqueue/v1"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	durationpb "google.golang.org/protobuf/types/known/durationpb"
	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

// The outcome of a completed activity execution: either a successful result or a failure.
type ActivityExecutionOutcome struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Value:
	//
	//	*ActivityExecutionOutcome_Result
	//	*ActivityExecutionOutcome_Failure
	Value         isActivityExecutionOutcome_Value `protobuf_oneof:"value"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ActivityExecutionOutcome) Reset() {
	*x = ActivityExecutionOutcome{}
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ActivityExecutionOutcome) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ActivityExecutionOutcome) ProtoMessage() {}

func (x *ActivityExecutionOutcome) ProtoReflect() protoreflect.Message {
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ActivityExecutionOutcome.ProtoReflect.Descriptor instead.
func (*ActivityExecutionOutcome) Descriptor() ([]byte, []int) {
	return file_temporal_api_activity_v1_message_proto_rawDescGZIP(), []int{0}
}

func (x *ActivityExecutionOutcome) GetValue() isActivityExecutionOutcome_Value {
	if x != nil {
		return x.Value
	}
	return nil
}

func (x *ActivityExecutionOutcome) GetResult() *v1.Payloads {
	if x != nil {
		if x, ok := x.Value.(*ActivityExecutionOutcome_Result); ok {
			return x.Result
		}
	}
	return nil
}

func (x *ActivityExecutionOutcome) GetFailure() *v11.Failure {
	if x != nil {
		if x, ok := x.Value.(*ActivityExecutionOutcome_Failure); ok {
			return x.Failure
		}
	}
	return nil
}

type isActivityExecutionOutcome_Value interface {
	isActivityExecutionOutcome_Value()
}

type ActivityExecutionOutcome_Result struct {
	// The result if the activity completed successfully.
	Result *v1.Payloads `protobuf:"bytes,1,opt,name=result,proto3,oneof"`
}

type ActivityExecutionOutcome_Failure struct {
	// The failure if the activity completed unsuccessfully.
	Failure *v11.Failure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

func (*ActivityExecutionOutcome_Result) isActivityExecutionOutcome_Value() {}

func (*ActivityExecutionOutcome_Failure) isActivityExecutionOutcome_Value() {}

type ActivityOptions struct {
	state     protoimpl.MessageState `protogen:"open.v1"`
	TaskQueue *v12.TaskQueue         `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,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 `protobuf:"bytes,2,opt,name=schedule_to_close_timeout,json=scheduleToCloseTimeout,proto3" json:"schedule_to_close_timeout,omitempty"`
	// 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 `protobuf:"bytes,3,opt,name=schedule_to_start_timeout,json=scheduleToStartTimeout,proto3" json:"schedule_to_start_timeout,omitempty"`
	// 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,4,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,5,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"`
	// The retry policy for the activity. Will never exceed `schedule_to_close_timeout`.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,6,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Priority metadata. If this message is not present, or any fields are not
	// present, they inherit the values from the workflow.
	Priority      *v1.Priority `protobuf:"bytes,7,opt,name=priority,proto3" json:"priority,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ActivityOptions) Reset() {
	*x = ActivityOptions{}
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ActivityOptions) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ActivityOptions) ProtoMessage() {}

func (x *ActivityOptions) ProtoReflect() protoreflect.Message {
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ActivityOptions.ProtoReflect.Descriptor instead.
func (*ActivityOptions) Descriptor() ([]byte, []int) {
	return file_temporal_api_activity_v1_message_proto_rawDescGZIP(), []int{1}
}

func (x *ActivityOptions) GetTaskQueue() *v12.TaskQueue {
	if x != nil {
		return x.TaskQueue
	}
	return nil
}

func (x *ActivityOptions) GetScheduleToCloseTimeout() *durationpb.Duration {
	if x != nil {
		return x.ScheduleToCloseTimeout
	}
	return nil
}

func (x *ActivityOptions) GetScheduleToStartTimeout() *durationpb.Duration {
	if x != nil {
		return x.ScheduleToStartTimeout
	}
	return nil
}

func (x *ActivityOptions) GetStartToCloseTimeout() *durationpb.Duration {
	if x != nil {
		return x.StartToCloseTimeout
	}
	return nil
}

func (x *ActivityOptions) GetHeartbeatTimeout() *durationpb.Duration {
	if x != nil {
		return x.HeartbeatTimeout
	}
	return nil
}

func (x *ActivityOptions) GetRetryPolicy() *v1.RetryPolicy {
	if x != nil {
		return x.RetryPolicy
	}
	return nil
}

func (x *ActivityOptions) GetPriority() *v1.Priority {
	if x != nil {
		return x.Priority
	}
	return nil
}

// Information about a standalone activity.
type ActivityExecutionInfo struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Unique identifier of this activity within its namespace along with run ID (below).
	ActivityId string `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	RunId      string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// The type of the activity, a string that maps to a registered activity on a worker.
	ActivityType *v1.ActivityType `protobuf:"bytes,3,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	// A general status for this activity, indicates whether it is currently running or in one of the terminal statuses.
	Status v13.ActivityExecutionStatus `protobuf:"varint,4,opt,name=status,proto3,enum=temporal.api.enums.v1.ActivityExecutionStatus" json:"status,omitempty"`
	// More detailed breakdown of ACTIVITY_EXECUTION_STATUS_RUNNING.
	RunState  v13.PendingActivityState `protobuf:"varint,5,opt,name=run_state,json=runState,proto3,enum=temporal.api.enums.v1.PendingActivityState" json:"run_state,omitempty"`
	TaskQueue string                   `protobuf:"bytes,6,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Indicates how long the caller is willing to wait for an activity completion. Limits how long
	// retries will be attempted.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=schedule_to_close_timeout,json=scheduleToCloseTimeout,proto3" json:"schedule_to_close_timeout,omitempty"`
	// 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`.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=schedule_to_start_timeout,json=scheduleToStartTimeout,proto3" json:"schedule_to_start_timeout,omitempty"`
	// Maximum time a single activity attempt is allowed to execute after being picked up by a worker. This
	// timeout is always retryable.
	//
	// (-- 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 retry policy for the activity. Will never exceed `schedule_to_close_timeout`.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,11,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Details provided in the last recorded activity heartbeat.
	HeartbeatDetails *v1.Payloads `protobuf:"bytes,12,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	// Time the last heartbeat was recorded.
	LastHeartbeatTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
	// Time the last attempt was started.
	LastStartedTime *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=last_started_time,json=lastStartedTime,proto3" json:"last_started_time,omitempty"`
	// The attempt this activity is currently on. Incremented each time a new attempt is scheduled.
	Attempt int32 `protobuf:"varint,15,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// How long this activity has been running for, including all attempts and backoff between attempts.
	ExecutionDuration *durationpb.Duration `protobuf:"bytes,16,opt,name=execution_duration,json=executionDuration,proto3" json:"execution_duration,omitempty"`
	// Time the activity was originally scheduled via a StartActivityExecution request.
	ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"`
	// Scheduled time + schedule to close timeout.
	ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,18,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	// Time when the activity transitioned to a closed state.
	CloseTime *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	// Failure details from the last failed attempt.
	LastFailure        *v11.Failure `protobuf:"bytes,20,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity string       `protobuf:"bytes,21,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
	// Time from the last attempt failure to the next activity retry.
	// If the activity is currently running, this represents the next retry interval in case the attempt fails.
	// If activity is currently backing off between attempt, this represents the current retry interval.
	// If there is no next retry allowed, this field will be null.
	// This interval is typically calculated from the specified retry policy, but may be modified if an activity fails
	// with a retryable application failure specifying a retry delay.
	CurrentRetryInterval *durationpb.Duration `protobuf:"bytes,22,opt,name=current_retry_interval,json=currentRetryInterval,proto3" json:"current_retry_interval,omitempty"`
	// The time when the last activity attempt completed. If activity has not been completed yet, it will be null.
	LastAttemptCompleteTime *timestamppb.Timestamp `protobuf:"bytes,23,opt,name=last_attempt_complete_time,json=lastAttemptCompleteTime,proto3" json:"last_attempt_complete_time,omitempty"`
	// The time when the next activity attempt will be scheduled.
	// If activity is currently scheduled or started, this field will be null.
	NextAttemptScheduleTime *timestamppb.Timestamp `protobuf:"bytes,24,opt,name=next_attempt_schedule_time,json=nextAttemptScheduleTime,proto3" json:"next_attempt_schedule_time,omitempty"`
	// The Worker Deployment Version this activity was dispatched to most recently.
	// If nil, the activity has not yet been dispatched or was last dispatched to an unversioned worker.
	LastDeploymentVersion *v14.WorkerDeploymentVersion `protobuf:"bytes,25,opt,name=last_deployment_version,json=lastDeploymentVersion,proto3" json:"last_deployment_version,omitempty"`
	// Priority metadata.
	Priority *v1.Priority `protobuf:"bytes,26,opt,name=priority,proto3" json:"priority,omitempty"`
	// Incremented each time the activity's state is mutated in persistence.
	StateTransitionCount int64 `protobuf:"varint,27,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	// Updated once on scheduled and once on terminal status.
	StateSizeBytes   int64                `protobuf:"varint,28,opt,name=state_size_bytes,json=stateSizeBytes,proto3" json:"state_size_bytes,omitempty"`
	SearchAttributes *v1.SearchAttributes `protobuf:"bytes,29,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Header           *v1.Header           `protobuf:"bytes,30,opt,name=header,proto3" json:"header,omitempty"`
	// Metadata for use by user interfaces to display the fixed as-of-start summary and details of the activity.
	UserMetadata *v15.UserMetadata `protobuf:"bytes,31,opt,name=user_metadata,json=userMetadata,proto3" json:"user_metadata,omitempty"`
	// Set if activity cancelation was requested.
	CanceledReason string `protobuf:"bytes,32,opt,name=canceled_reason,json=canceledReason,proto3" json:"canceled_reason,omitempty"`
	// Links to related entities, such as the entity that started this activity.
	Links []*v1.Link `protobuf:"bytes,33,rep,name=links,proto3" json:"links,omitempty"`
	// Total number of heartbeats recorded across all attempts of this activity, including retries.
	TotalHeartbeatCount int64 `protobuf:"varint,34,opt,name=total_heartbeat_count,json=totalHeartbeatCount,proto3" json:"total_heartbeat_count,omitempty"`
	unknownFields       protoimpl.UnknownFields
	sizeCache           protoimpl.SizeCache
}

func (x *ActivityExecutionInfo) Reset() {
	*x = ActivityExecutionInfo{}
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ActivityExecutionInfo) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ActivityExecutionInfo) ProtoMessage() {}

func (x *ActivityExecutionInfo) ProtoReflect() protoreflect.Message {
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ActivityExecutionInfo.ProtoReflect.Descriptor instead.
func (*ActivityExecutionInfo) Descriptor() ([]byte, []int) {
	return file_temporal_api_activity_v1_message_proto_rawDescGZIP(), []int{2}
}

func (x *ActivityExecutionInfo) GetActivityId() string {
	if x != nil {
		return x.ActivityId
	}
	return ""
}

func (x *ActivityExecutionInfo) GetRunId() string {
	if x != nil {
		return x.RunId
	}
	return ""
}

func (x *ActivityExecutionInfo) GetActivityType() *v1.ActivityType {
	if x != nil {
		return x.ActivityType
	}
	return nil
}

func (x *ActivityExecutionInfo) GetStatus() v13.ActivityExecutionStatus {
	if x != nil {
		return x.Status
	}
	return v13.ActivityExecutionStatus(0)
}

func (x *ActivityExecutionInfo) GetRunState() v13.PendingActivityState {
	if x != nil {
		return x.RunState
	}
	return v13.PendingActivityState(0)
}

func (x *ActivityExecutionInfo) GetTaskQueue() string {
	if x != nil {
		return x.TaskQueue
	}
	return ""
}

func (x *ActivityExecutionInfo) GetScheduleToCloseTimeout() *durationpb.Duration {
	if x != nil {
		return x.ScheduleToCloseTimeout
	}
	return nil
}

func (x *ActivityExecutionInfo) GetScheduleToStartTimeout() *durationpb.Duration {
	if x != nil {
		return x.ScheduleToStartTimeout
	}
	return nil
}

func (x *ActivityExecutionInfo) GetStartToCloseTimeout() *durationpb.Duration {
	if x != nil {
		return x.StartToCloseTimeout
	}
	return nil
}

func (x *ActivityExecutionInfo) GetHeartbeatTimeout() *durationpb.Duration {
	if x != nil {
		return x.HeartbeatTimeout
	}
	return nil
}

func (x *ActivityExecutionInfo) GetRetryPolicy() *v1.RetryPolicy {
	if x != nil {
		return x.RetryPolicy
	}
	return nil
}

func (x *ActivityExecutionInfo) GetHeartbeatDetails() *v1.Payloads {
	if x != nil {
		return x.HeartbeatDetails
	}
	return nil
}

func (x *ActivityExecutionInfo) GetLastHeartbeatTime() *timestamppb.Timestamp {
	if x != nil {
		return x.LastHeartbeatTime
	}
	return nil
}

func (x *ActivityExecutionInfo) GetLastStartedTime() *timestamppb.Timestamp {
	if x != nil {
		return x.LastStartedTime
	}
	return nil
}

func (x *ActivityExecutionInfo) GetAttempt() int32 {
	if x != nil {
		return x.Attempt
	}
	return 0
}

func (x *ActivityExecutionInfo) GetExecutionDuration() *durationpb.Duration {
	if x != nil {
		return x.ExecutionDuration
	}
	return nil
}

func (x *ActivityExecutionInfo) GetScheduleTime() *timestamppb.Timestamp {
	if x != nil {
		return x.ScheduleTime
	}
	return nil
}

func (x *ActivityExecutionInfo) GetExpirationTime() *timestamppb.Timestamp {
	if x != nil {
		return x.ExpirationTime
	}
	return nil
}

func (x *ActivityExecutionInfo) GetCloseTime() *timestamppb.Timestamp {
	if x != nil {
		return x.CloseTime
	}
	return nil
}

func (x *ActivityExecutionInfo) GetLastFailure() *v11.Failure {
	if x != nil {
		return x.LastFailure
	}
	return nil
}

func (x *ActivityExecutionInfo) GetLastWorkerIdentity() string {
	if x != nil {
		return x.LastWorkerIdentity
	}
	return ""
}

func (x *ActivityExecutionInfo) GetCurrentRetryInterval() *durationpb.Duration {
	if x != nil {
		return x.CurrentRetryInterval
	}
	return nil
}

func (x *ActivityExecutionInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp {
	if x != nil {
		return x.LastAttemptCompleteTime
	}
	return nil
}

func (x *ActivityExecutionInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp {
	if x != nil {
		return x.NextAttemptScheduleTime
	}
	return nil
}

func (x *ActivityExecutionInfo) GetLastDeploymentVersion() *v14.WorkerDeploymentVersion {
	if x != nil {
		return x.LastDeploymentVersion
	}
	return nil
}

func (x *ActivityExecutionInfo) GetPriority() *v1.Priority {
	if x != nil {
		return x.Priority
	}
	return nil
}

func (x *ActivityExecutionInfo) GetStateTransitionCount() int64 {
	if x != nil {
		return x.StateTransitionCount
	}
	return 0
}

func (x *ActivityExecutionInfo) GetStateSizeBytes() int64 {
	if x != nil {
		return x.StateSizeBytes
	}
	return 0
}

func (x *ActivityExecutionInfo) GetSearchAttributes() *v1.SearchAttributes {
	if x != nil {
		return x.SearchAttributes
	}
	return nil
}

func (x *ActivityExecutionInfo) GetHeader() *v1.Header {
	if x != nil {
		return x.Header
	}
	return nil
}

func (x *ActivityExecutionInfo) GetUserMetadata() *v15.UserMetadata {
	if x != nil {
		return x.UserMetadata
	}
	return nil
}

func (x *ActivityExecutionInfo) GetCanceledReason() string {
	if x != nil {
		return x.CanceledReason
	}
	return ""
}

func (x *ActivityExecutionInfo) GetLinks() []*v1.Link {
	if x != nil {
		return x.Links
	}
	return nil
}

func (x *ActivityExecutionInfo) GetTotalHeartbeatCount() int64 {
	if x != nil {
		return x.TotalHeartbeatCount
	}
	return 0
}

// Limited activity information returned in the list response.
// When adding fields here, ensure that it is also present in ActivityExecutionInfo (note that it
// may already be present in ActivityExecutionInfo but not at the top-level).
type ActivityExecutionListInfo struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// A unique identifier of this activity within its namespace along with run ID (below).
	ActivityId string `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	// The run ID of the standalone activity.
	RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// The type of the activity, a string that maps to a registered activity on a worker.
	ActivityType *v1.ActivityType `protobuf:"bytes,3,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	// Time the activity was originally scheduled via a StartActivityExecution request.
	ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"`
	// If the activity is in a terminal status, this field represents the time the activity transitioned to that status.
	CloseTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	// Only scheduled and terminal statuses appear here. More detailed information in PendingActivityInfo but not
	// available in the list response.
	Status v13.ActivityExecutionStatus `protobuf:"varint,6,opt,name=status,proto3,enum=temporal.api.enums.v1.ActivityExecutionStatus" json:"status,omitempty"`
	// Search attributes from the start request.
	SearchAttributes *v1.SearchAttributes `protobuf:"bytes,7,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	// The task queue this activity was scheduled on when it was originally started, updated on activity options update.
	TaskQueue string `protobuf:"bytes,8,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Updated on terminal status.
	StateTransitionCount int64 `protobuf:"varint,9,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	// Updated once on scheduled and once on terminal status.
	StateSizeBytes int64 `protobuf:"varint,10,opt,name=state_size_bytes,json=stateSizeBytes,proto3" json:"state_size_bytes,omitempty"`
	// The difference between close time and scheduled time.
	// This field is only populated if the activity is closed.
	ExecutionDuration *durationpb.Duration `protobuf:"bytes,11,opt,name=execution_duration,json=executionDuration,proto3" json:"execution_duration,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

func (x *ActivityExecutionListInfo) Reset() {
	*x = ActivityExecutionListInfo{}
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ActivityExecutionListInfo) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ActivityExecutionListInfo) ProtoMessage() {}

func (x *ActivityExecutionListInfo) ProtoReflect() protoreflect.Message {
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ActivityExecutionListInfo.ProtoReflect.Descriptor instead.
func (*ActivityExecutionListInfo) Descriptor() ([]byte, []int) {
	return file_temporal_api_activity_v1_message_proto_rawDescGZIP(), []int{3}
}

func (x *ActivityExecutionListInfo) GetActivityId() string {
	if x != nil {
		return x.ActivityId
	}
	return ""
}

func (x *ActivityExecutionListInfo) GetRunId() string {
	if x != nil {
		return x.RunId
	}
	return ""
}

func (x *ActivityExecutionListInfo) GetActivityType() *v1.ActivityType {
	if x != nil {
		return x.ActivityType
	}
	return nil
}

func (x *ActivityExecutionListInfo) GetScheduleTime() *timestamppb.Timestamp {
	if x != nil {
		return x.ScheduleTime
	}
	return nil
}

func (x *ActivityExecutionListInfo) GetCloseTime() *timestamppb.Timestamp {
	if x != nil {
		return x.CloseTime
	}
	return nil
}

func (x *ActivityExecutionListInfo) GetStatus() v13.ActivityExecutionStatus {
	if x != nil {
		return x.Status
	}
	return v13.ActivityExecutionStatus(0)
}

func (x *ActivityExecutionListInfo) GetSearchAttributes() *v1.SearchAttributes {
	if x != nil {
		return x.SearchAttributes
	}
	return nil
}

func (x *ActivityExecutionListInfo) GetTaskQueue() string {
	if x != nil {
		return x.TaskQueue
	}
	return ""
}

func (x *ActivityExecutionListInfo) GetStateTransitionCount() int64 {
	if x != nil {
		return x.StateTransitionCount
	}
	return 0
}

func (x *ActivityExecutionListInfo) GetStateSizeBytes() int64 {
	if x != nil {
		return x.StateSizeBytes
	}
	return 0
}

func (x *ActivityExecutionListInfo) GetExecutionDuration() *durationpb.Duration {
	if x != nil {
		return x.ExecutionDuration
	}
	return nil
}

// CallbackInfo contains the state of an attached activity callback.
type CallbackInfo struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Trigger for this callback.
	Trigger *CallbackInfo_Trigger `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// Common callback info.
	Info          *v16.CallbackInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CallbackInfo) Reset() {
	*x = CallbackInfo{}
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CallbackInfo) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CallbackInfo) ProtoMessage() {}

func (x *CallbackInfo) ProtoReflect() protoreflect.Message {
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CallbackInfo.ProtoReflect.Descriptor instead.
func (*CallbackInfo) Descriptor() ([]byte, []int) {
	return file_temporal_api_activity_v1_message_proto_rawDescGZIP(), []int{4}
}

func (x *CallbackInfo) GetTrigger() *CallbackInfo_Trigger {
	if x != nil {
		return x.Trigger
	}
	return nil
}

func (x *CallbackInfo) GetInfo() *v16.CallbackInfo {
	if x != nil {
		return x.Info
	}
	return nil
}

// Trigger for when the activity is closed.
type CallbackInfo_ActivityClosed struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CallbackInfo_ActivityClosed) Reset() {
	*x = CallbackInfo_ActivityClosed{}
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CallbackInfo_ActivityClosed) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CallbackInfo_ActivityClosed) ProtoMessage() {}

func (x *CallbackInfo_ActivityClosed) ProtoReflect() protoreflect.Message {
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CallbackInfo_ActivityClosed.ProtoReflect.Descriptor instead.
func (*CallbackInfo_ActivityClosed) Descriptor() ([]byte, []int) {
	return file_temporal_api_activity_v1_message_proto_rawDescGZIP(), []int{4, 0}
}

type CallbackInfo_Trigger struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Variant:
	//
	//	*CallbackInfo_Trigger_ActivityClosed
	Variant       isCallbackInfo_Trigger_Variant `protobuf_oneof:"variant"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CallbackInfo_Trigger) Reset() {
	*x = CallbackInfo_Trigger{}
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CallbackInfo_Trigger) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CallbackInfo_Trigger) ProtoMessage() {}

func (x *CallbackInfo_Trigger) ProtoReflect() protoreflect.Message {
	mi := &file_temporal_api_activity_v1_message_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CallbackInfo_Trigger.ProtoReflect.Descriptor instead.
func (*CallbackInfo_Trigger) Descriptor() ([]byte, []int) {
	return file_temporal_api_activity_v1_message_proto_rawDescGZIP(), []int{4, 1}
}

func (x *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant {
	if x != nil {
		return x.Variant
	}
	return nil
}

func (x *CallbackInfo_Trigger) GetActivityClosed() *CallbackInfo_ActivityClosed {
	if x != nil {
		if x, ok := x.Variant.(*CallbackInfo_Trigger_ActivityClosed); ok {
			return x.ActivityClosed
		}
	}
	return nil
}

type isCallbackInfo_Trigger_Variant interface {
	isCallbackInfo_Trigger_Variant()
}

type CallbackInfo_Trigger_ActivityClosed struct {
	ActivityClosed *CallbackInfo_ActivityClosed `protobuf:"bytes,1,opt,name=activity_closed,json=activityClosed,proto3,oneof"`
}

func (*CallbackInfo_Trigger_ActivityClosed) isCallbackInfo_Trigger_Variant() {}

var File_temporal_api_activity_v1_message_proto protoreflect.FileDescriptor

const file_temporal_api_activity_v1_message_proto_rawDesc = "" +
	"\n" +
	"&temporal/api/activity/v1/message.proto\x12\x18temporal.api.activity.v1\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a$temporal/api/common/v1/message.proto\x1a(temporal/api/deployment/v1/message.proto\x1a$temporal/api/enums/v1/activity.proto\x1a&temporal/api/callback/v1/message.proto\x1a$temporal/api/enums/v1/workflow.proto\x1a%temporal/api/failure/v1/message.proto\x1a'temporal/api/taskqueue/v1/message.proto\x1a'temporal/api/sdk/v1/user_metadata.proto\"\x9d\x01\n" +
	"\x18ActivityExecutionOutcome\x12:\n" +
	"\x06result\x18\x01 \x01(\v2 .temporal.api.common.v1.PayloadsH\x00R\x06result\x12<\n" +
	"\afailure\x18\x02 \x01(\v2 .temporal.api.failure.v1.FailureH\x00R\afailureB\a\n" +
	"\x05value\"\xa0\x04\n" +
	"\x0fActivityOptions\x12C\n" +
	"\n" +
	"task_queue\x18\x01 \x01(\v2$.temporal.api.taskqueue.v1.TaskQueueR\ttaskQueue\x12T\n" +
	"\x19schedule_to_close_timeout\x18\x02 \x01(\v2\x19.google.protobuf.DurationR\x16scheduleToCloseTimeout\x12T\n" +
	"\x19schedule_to_start_timeout\x18\x03 \x01(\v2\x19.google.protobuf.DurationR\x16scheduleToStartTimeout\x12N\n" +
	"\x16start_to_close_timeout\x18\x04 \x01(\v2\x19.google.protobuf.DurationR\x13startToCloseTimeout\x12F\n" +
	"\x11heartbeat_timeout\x18\x05 \x01(\v2\x19.google.protobuf.DurationR\x10heartbeatTimeout\x12F\n" +
	"\fretry_policy\x18\x06 \x01(\v2#.temporal.api.common.v1.RetryPolicyR\vretryPolicy\x12<\n" +
	"\bpriority\x18\a \x01(\v2 .temporal.api.common.v1.PriorityR\bpriority\"\xcc\x11\n" +
	"\x15ActivityExecutionInfo\x12\x1f\n" +
	"\vactivity_id\x18\x01 \x01(\tR\n" +
	"activityId\x12\x15\n" +
	"\x06run_id\x18\x02 \x01(\tR\x05runId\x12I\n" +
	"\ractivity_type\x18\x03 \x01(\v2$.temporal.api.common.v1.ActivityTypeR\factivityType\x12F\n" +
	"\x06status\x18\x04 \x01(\x0e2..temporal.api.enums.v1.ActivityExecutionStatusR\x06status\x12H\n" +
	"\trun_state\x18\x05 \x01(\x0e2+.temporal.api.enums.v1.PendingActivityStateR\brunState\x12\x1d\n" +
	"\n" +
	"task_queue\x18\x06 \x01(\tR\ttaskQueue\x12T\n" +
	"\x19schedule_to_close_timeout\x18\a \x01(\v2\x19.google.protobuf.DurationR\x16scheduleToCloseTimeout\x12T\n" +
	"\x19schedule_to_start_timeout\x18\b \x01(\v2\x19.google.protobuf.DurationR\x16scheduleToStartTimeout\x12N\n" +
	"\x16start_to_close_timeout\x18\t \x01(\v2\x19.google.protobuf.DurationR\x13startToCloseTimeout\x12F\n" +
	"\x11heartbeat_timeout\x18\n" +
	" \x01(\v2\x19.google.protobuf.DurationR\x10heartbeatTimeout\x12F\n" +
	"\fretry_policy\x18\v \x01(\v2#.temporal.api.common.v1.RetryPolicyR\vretryPolicy\x12M\n" +
	"\x11heartbeat_details\x18\f \x01(\v2 .temporal.api.common.v1.PayloadsR\x10heartbeatDetails\x12J\n" +
	"\x13last_heartbeat_time\x18\r \x01(\v2\x1a.google.protobuf.TimestampR\x11lastHeartbeatTime\x12F\n" +
	"\x11last_started_time\x18\x0e \x01(\v2\x1a.google.protobuf.TimestampR\x0flastStartedTime\x12\x18\n" +
	"\aattempt\x18\x0f \x01(\x05R\aattempt\x12H\n" +
	"\x12execution_duration\x18\x10 \x01(\v2\x19.google.protobuf.DurationR\x11executionDuration\x12?\n" +
	"\rschedule_time\x18\x11 \x01(\v2\x1a.google.protobuf.TimestampR\fscheduleTime\x12C\n" +
	"\x0fexpiration_time\x18\x12 \x01(\v2\x1a.google.protobuf.TimestampR\x0eexpirationTime\x129\n" +
	"\n" +
	"close_time\x18\x13 \x01(\v2\x1a.google.protobuf.TimestampR\tcloseTime\x12C\n" +
	"\flast_failure\x18\x14 \x01(\v2 .temporal.api.failure.v1.FailureR\vlastFailure\x120\n" +
	"\x14last_worker_identity\x18\x15 \x01(\tR\x12lastWorkerIdentity\x12O\n" +
	"\x16current_retry_interval\x18\x16 \x01(\v2\x19.google.protobuf.DurationR\x14currentRetryInterval\x12W\n" +
	"\x1alast_attempt_complete_time\x18\x17 \x01(\v2\x1a.google.protobuf.TimestampR\x17lastAttemptCompleteTime\x12W\n" +
	"\x1anext_attempt_schedule_time\x18\x18 \x01(\v2\x1a.google.protobuf.TimestampR\x17nextAttemptScheduleTime\x12k\n" +
	"\x17last_deployment_version\x18\x19 \x01(\v23.temporal.api.deployment.v1.WorkerDeploymentVersionR\x15lastDeploymentVersion\x12<\n" +
	"\bpriority\x18\x1a \x01(\v2 .temporal.api.common.v1.PriorityR\bpriority\x124\n" +
	"\x16state_transition_count\x18\x1b \x01(\x03R\x14stateTransitionCount\x12(\n" +
	"\x10state_size_bytes\x18\x1c \x01(\x03R\x0estateSizeBytes\x12U\n" +
	"\x11search_attributes\x18\x1d \x01(\v2(.temporal.api.common.v1.SearchAttributesR\x10searchAttributes\x126\n" +
	"\x06header\x18\x1e \x01(\v2\x1e.temporal.api.common.v1.HeaderR\x06header\x12F\n" +
	"\ruser_metadata\x18\x1f \x01(\v2!.temporal.api.sdk.v1.UserMetadataR\fuserMetadata\x12'\n" +
	"\x0fcanceled_reason\x18  \x01(\tR\x0ecanceledReason\x122\n" +
	"\x05links\x18! \x03(\v2\x1c.temporal.api.common.v1.LinkR\x05links\x122\n" +
	"\x15total_heartbeat_count\x18\" \x01(\x03R\x13totalHeartbeatCount\"\x82\x05\n" +
	"\x19ActivityExecutionListInfo\x12\x1f\n" +
	"\vactivity_id\x18\x01 \x01(\tR\n" +
	"activityId\x12\x15\n" +
	"\x06run_id\x18\x02 \x01(\tR\x05runId\x12I\n" +
	"\ractivity_type\x18\x03 \x01(\v2$.temporal.api.common.v1.ActivityTypeR\factivityType\x12?\n" +
	"\rschedule_time\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\fscheduleTime\x129\n" +
	"\n" +
	"close_time\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\tcloseTime\x12F\n" +
	"\x06status\x18\x06 \x01(\x0e2..temporal.api.enums.v1.ActivityExecutionStatusR\x06status\x12U\n" +
	"\x11search_attributes\x18\a \x01(\v2(.temporal.api.common.v1.SearchAttributesR\x10searchAttributes\x12\x1d\n" +
	"\n" +
	"task_queue\x18\b \x01(\tR\ttaskQueue\x124\n" +
	"\x16state_transition_count\x18\t \x01(\x03R\x14stateTransitionCount\x12(\n" +
	"\x10state_size_bytes\x18\n" +
	" \x01(\x03R\x0estateSizeBytes\x12H\n" +
	"\x12execution_duration\x18\v \x01(\v2\x19.google.protobuf.DurationR\x11executionDuration\"\x9e\x02\n" +
	"\fCallbackInfo\x12H\n" +
	"\atrigger\x18\x01 \x01(\v2..temporal.api.activity.v1.CallbackInfo.TriggerR\atrigger\x12:\n" +
	"\x04info\x18\x02 \x01(\v2&.temporal.api.callback.v1.CallbackInfoR\x04info\x1a\x10\n" +
	"\x0eActivityClosed\x1av\n" +
	"\aTrigger\x12`\n" +
	"\x0factivity_closed\x18\x01 \x01(\v25.temporal.api.activity.v1.CallbackInfo.ActivityClosedH\x00R\x0eactivityClosedB\t\n" +
	"\avariantB\x93\x01\n" +
	"\x1bio.temporal.api.activity.v1B\fMessageProtoP\x01Z'go.temporal.io/api/activity/v1;activity\xaa\x02\x1aTemporalio.Api.Activity.V1\xea\x02\x1dTemporalio::Api::Activity::V1b\x06proto3"

var (
	file_temporal_api_activity_v1_message_proto_rawDescOnce sync.Once
	file_temporal_api_activity_v1_message_proto_rawDescData []byte
)

func file_temporal_api_activity_v1_message_proto_rawDescGZIP() []byte {
	file_temporal_api_activity_v1_message_proto_rawDescOnce.Do(func() {
		file_temporal_api_activity_v1_message_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_api_activity_v1_message_proto_rawDesc), len(file_temporal_api_activity_v1_message_proto_rawDesc)))
	})
	return file_temporal_api_activity_v1_message_proto_rawDescData
}

var file_temporal_api_activity_v1_message_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_temporal_api_activity_v1_message_proto_goTypes = []any{
	(*ActivityExecutionOutcome)(nil),    // 0: temporal.api.activity.v1.ActivityExecutionOutcome
	(*ActivityOptions)(nil),             // 1: temporal.api.activity.v1.ActivityOptions
	(*ActivityExecutionInfo)(nil),       // 2: temporal.api.activity.v1.ActivityExecutionInfo
	(*ActivityExecutionListInfo)(nil),   // 3: temporal.api.activity.v1.ActivityExecutionListInfo
	(*CallbackInfo)(nil),                // 4: temporal.api.activity.v1.CallbackInfo
	(*CallbackInfo_ActivityClosed)(nil), // 5: temporal.api.activity.v1.CallbackInfo.ActivityClosed
	(*CallbackInfo_Trigger)(nil),        // 6: temporal.api.activity.v1.CallbackInfo.Trigger
	(*v1.Payloads)(nil),                 // 7: temporal.api.common.v1.Payloads
	(*v11.Failure)(nil),                 // 8: temporal.api.failure.v1.Failure
	(*v12.TaskQueue)(nil),               // 9: temporal.api.taskqueue.v1.TaskQueue
	(*durationpb.Duration)(nil),         // 10: google.protobuf.Duration
	(*v1.RetryPolicy)(nil),              // 11: temporal.api.common.v1.RetryPolicy
	(*v1.Priority)(nil),                 // 12: temporal.api.common.v1.Priority
	(*v1.ActivityType)(nil),             // 13: temporal.api.common.v1.ActivityType
	(v13.ActivityExecutionStatus)(0),    // 14: temporal.api.enums.v1.ActivityExecutionStatus
	(v13.PendingActivityState)(0),       // 15: temporal.api.enums.v1.PendingActivityState
	(*timestamppb.Timestamp)(nil),       // 16: google.protobuf.Timestamp
	(*v14.WorkerDeploymentVersion)(nil), // 17: temporal.api.deployment.v1.WorkerDeploymentVersion
	(*v1.SearchAttributes)(nil),         // 18: temporal.api.common.v1.SearchAttributes
	(*v1.Header)(nil),                   // 19: temporal.api.common.v1.Header
	(*v15.UserMetadata)(nil),            // 20: temporal.api.sdk.v1.UserMetadata
	(*v1.Link)(nil),                     // 21: temporal.api.common.v1.Link
	(*v16.CallbackInfo)(nil),            // 22: temporal.api.callback.v1.CallbackInfo
}
var file_temporal_api_activity_v1_message_proto_depIdxs = []int32{
	7,  // 0: temporal.api.activity.v1.ActivityExecutionOutcome.result:type_name -> temporal.api.common.v1.Payloads
	8,  // 1: temporal.api.activity.v1.ActivityExecutionOutcome.failure:type_name -> temporal.api.failure.v1.Failure
	9,  // 2: temporal.api.activity.v1.ActivityOptions.task_queue:type_name -> temporal.api.taskqueue.v1.TaskQueue
	10, // 3: temporal.api.activity.v1.ActivityOptions.schedule_to_close_timeout:type_name -> google.protobuf.Duration
	10, // 4: temporal.api.activity.v1.ActivityOptions.schedule_to_start_timeout:type_name -> google.protobuf.Duration
	10, // 5: temporal.api.activity.v1.ActivityOptions.start_to_close_timeout:type_name -> google.protobuf.Duration
	10, // 6: temporal.api.activity.v1.ActivityOptions.heartbeat_timeout:type_name -> google.protobuf.Duration
	11, // 7: temporal.api.activity.v1.ActivityOptions.retry_policy:type_name -> temporal.api.common.v1.RetryPolicy
	12, // 8: temporal.api.activity.v1.ActivityOptions.priority:type_name -> temporal.api.common.v1.Priority
	13, // 9: temporal.api.activity.v1.ActivityExecutionInfo.activity_type:type_name -> temporal.api.common.v1.ActivityType
	14, // 10: temporal.api.activity.v1.ActivityExecutionInfo.status:type_name -> temporal.api.enums.v1.ActivityExecutionStatus
	15, // 11: temporal.api.activity.v1.ActivityExecutionInfo.run_state:type_name -> temporal.api.enums.v1.PendingActivityState
	10, // 12: temporal.api.activity.v1.ActivityExecutionInfo.schedule_to_close_timeout:type_name -> google.protobuf.Duration
	10, // 13: temporal.api.activity.v1.ActivityExecutionInfo.schedule_to_start_timeout:type_name -> google.protobuf.Duration
	10, // 14: temporal.api.activity.v1.ActivityExecutionInfo.start_to_close_timeout:type_name -> google.protobuf.Duration
	10, // 15: temporal.api.activity.v1.ActivityExecutionInfo.heartbeat_timeout:type_name -> google.protobuf.Duration
	11, // 16: temporal.api.activity.v1.ActivityExecutionInfo.retry_policy:type_name -> temporal.api.common.v1.RetryPolicy
	7,  // 17: temporal.api.activity.v1.ActivityExecutionInfo.heartbeat_details:type_name -> temporal.api.common.v1.Payloads
	16, // 18: temporal.api.activity.v1.ActivityExecutionInfo.last_heartbeat_time:type_name -> google.protobuf.Timestamp
	16, // 19: temporal.api.activity.v1.ActivityExecutionInfo.last_started_time:type_name -> google.protobuf.Timestamp
	10, // 20: temporal.api.activity.v1.ActivityExecutionInfo.execution_duration:type_name -> google.protobuf.Duration
	16, // 21: temporal.api.activity.v1.ActivityExecutionInfo.schedule_time:type_name -> google.protobuf.Timestamp
	16, // 22: temporal.api.activity.v1.ActivityExecutionInfo.expiration_time:type_name -> google.protobuf.Timestamp
	16, // 23: temporal.api.activity.v1.ActivityExecutionInfo.close_time:type_name -> google.protobuf.Timestamp
	8,  // 24: temporal.api.activity.v1.ActivityExecutionInfo.last_failure:type_name -> temporal.api.failure.v1.Failure
	10, // 25: temporal.api.activity.v1.ActivityExecutionInfo.current_retry_interval:type_name -> google.protobuf.Duration
	16, // 26: temporal.api.activity.v1.ActivityExecutionInfo.last_attempt_complete_time:type_name -> google.protobuf.Timestamp
	16, // 27: temporal.api.activity.v1.ActivityExecutionInfo.next_attempt_schedule_time:type_name -> google.protobuf.Timestamp
	17, // 28: temporal.api.activity.v1.ActivityExecutionInfo.last_deployment_version:type_name -> temporal.api.deployment.v1.WorkerDeploymentVersion
	12, // 29: temporal.api.activity.v1.ActivityExecutionInfo.priority:type_name -> temporal.api.common.v1.Priority
	18, // 30: temporal.api.activity.v1.ActivityExecutionInfo.search_attributes:type_name -> temporal.api.common.v1.SearchAttributes
	19, // 31: temporal.api.activity.v1.ActivityExecutionInfo.header:type_name -> temporal.api.common.v1.Header
	20, // 32: temporal.api.activity.v1.ActivityExecutionInfo.user_metadata:type_name -> temporal.api.sdk.v1.UserMetadata
	21, // 33: temporal.api.activity.v1.ActivityExecutionInfo.links:type_name -> temporal.api.common.v1.Link
	13, // 34: temporal.api.activity.v1.ActivityExecutionListInfo.activity_type:type_name -> temporal.api.common.v1.ActivityType
	16, // 35: temporal.api.activity.v1.ActivityExecutionListInfo.schedule_time:type_name -> google.protobuf.Timestamp
	16, // 36: temporal.api.activity.v1.ActivityExecutionListInfo.close_time:type_name -> google.protobuf.Timestamp
	14, // 37: temporal.api.activity.v1.ActivityExecutionListInfo.status:type_name -> temporal.api.enums.v1.ActivityExecutionStatus
	18, // 38: temporal.api.activity.v1.ActivityExecutionListInfo.search_attributes:type_name -> temporal.api.common.v1.SearchAttributes
	10, // 39: temporal.api.activity.v1.ActivityExecutionListInfo.execution_duration:type_name -> google.protobuf.Duration
	6,  // 40: temporal.api.activity.v1.CallbackInfo.trigger:type_name -> temporal.api.activity.v1.CallbackInfo.Trigger
	22, // 41: temporal.api.activity.v1.CallbackInfo.info:type_name -> temporal.api.callback.v1.CallbackInfo
	5,  // 42: temporal.api.activity.v1.CallbackInfo.Trigger.activity_closed:type_name -> temporal.api.activity.v1.CallbackInfo.ActivityClosed
	43, // [43:43] is the sub-list for method output_type
	43, // [43:43] is the sub-list for method input_type
	43, // [43:43] is the sub-list for extension type_name
	43, // [43:43] is the sub-list for extension extendee
	0,  // [0:43] is the sub-list for field type_name
}

func init() { file_temporal_api_activity_v1_message_proto_init() }
func file_temporal_api_activity_v1_message_proto_init() {
	if File_temporal_api_activity_v1_message_proto != nil {
		return
	}
	file_temporal_api_activity_v1_message_proto_msgTypes[0].OneofWrappers = []any{
		(*ActivityExecutionOutcome_Result)(nil),
		(*ActivityExecutionOutcome_Failure)(nil),
	}
	file_temporal_api_activity_v1_message_proto_msgTypes[6].OneofWrappers = []any{
		(*CallbackInfo_Trigger_ActivityClosed)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_api_activity_v1_message_proto_rawDesc), len(file_temporal_api_activity_v1_message_proto_rawDesc)),
			NumEnums:      0,
			NumMessages:   7,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_temporal_api_activity_v1_message_proto_goTypes,
		DependencyIndexes: file_temporal_api_activity_v1_message_proto_depIdxs,
		MessageInfos:      file_temporal_api_activity_v1_message_proto_msgTypes,
	}.Build()
	File_temporal_api_activity_v1_message_proto = out.File
	file_temporal_api_activity_v1_message_proto_goTypes = nil
	file_temporal_api_activity_v1_message_proto_depIdxs = nil
}