activity

type ActivityExecutionInfo struct {

	// 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 `` /* 134-byte string literal not displayed */
	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 `` /* 131-byte string literal not displayed */
	// Limits time an activity task can stay in a task queue before a worker picks it up. This
	// timeout is always non retryable, as all a retry would achieve is to put it back into the same
	// queue. Defaults to `schedule_to_close_timeout`.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// Maximum time 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.
	// DescribeActivityExecution does not set this field unless include_heartbeat_details was true in the request.
	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.
	// DescribeActivityExecution does not set this field unless include_last_failure was true in the request.
	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 `` /* 135-byte string literal not displayed */
	// 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 `` /* 135-byte string literal not displayed */
	// 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 `` /* 127-byte string literal not displayed */
	// 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"`
	// The name of the SDK of the worker that most recently picked up an attempt of this activity.
	// Overwritten on each new attempt. Empty if unknown.
	SdkName string `protobuf:"bytes,35,opt,name=sdk_name,json=sdkName,proto3" json:"sdk_name,omitempty"`
	// The version of the SDK of the worker that most recently picked up an attempt of this activity.
	// Overwritten on each new attempt. Empty if unknown.
	SdkVersion string `protobuf:"bytes,36,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"`
	// Time to wait before making the first activity task available for dispatch. This delay is not applied to retry attempts.
	StartDelay *durationpb.Duration `protobuf:"bytes,37,opt,name=start_delay,json=startDelay,proto3" json:"start_delay,omitempty"`
	// The time at which the first activity task is made available for dispatch, computed as
	// `schedule_time + start_delay`. Same as `schedule_time` if `start_delay` is not set.
	ExecutionTime *timestamppb.Timestamp `protobuf:"bytes,38,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	// contains filtered or unexported fields
}

type ActivityExecutionListInfo struct {

	// 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"`
	// contains filtered or unexported fields
}

type ActivityExecutionOutcome struct {

	// Types that are valid to be assigned to Value:
	//
	//	*ActivityExecutionOutcome_Result
	//	*ActivityExecutionOutcome_Failure
	Value isActivityExecutionOutcome_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

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

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

type ActivityOptions struct {
	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 `` /* 131-byte string literal not displayed */
	// Limits time an activity task can stay in a task queue before a worker picks it up. This
	// timeout is always non retryable, as all a retry would achieve is to put it back into the same
	// queue. Defaults to `schedule_to_close_timeout` or workflow execution timeout if not
	// specified.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// Maximum time an activity is allowed to execute after being picked up by a worker. This
	// timeout is always retryable. Either this or `schedule_to_close_timeout` must be
	// specified.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout *durationpb.Duration `protobuf:"bytes,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"`
	// Time to wait before making the first activity task available for dispatch. This delay is not applied to retry attempts.
	// When updated, the time is added to the original `schedule_time`, not to the current time.
	// If the resulting time is in the past, the task is made available for dispatch immediately.
	StartDelay *durationpb.Duration `protobuf:"bytes,8,opt,name=start_delay,json=startDelay,proto3" json:"start_delay,omitempty"`
	// contains filtered or unexported fields
}

type CallbackInfo struct {

	// 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"`
	// contains filtered or unexported fields
}

type CallbackInfo_ActivityClosed struct {
	// contains filtered or unexported fields
}

type CallbackInfo_Trigger struct {

	// Types that are valid to be assigned to Variant:
	//
	//	*CallbackInfo_Trigger_ActivityClosed
	Variant isCallbackInfo_Trigger_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

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