activity

package
v4.20.0 Latest Latest
Warning

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

Go to latest
Published: May 5, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_temporal_api_activity_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActivityOptions

type ActivityOptions struct {
	TaskQueue *v1.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"`
	RetryPolicy      *v11.RetryPolicy     `protobuf:"bytes,6,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityOptions) Descriptor deprecated

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

Deprecated: Use ActivityOptions.ProtoReflect.Descriptor instead.

func (*ActivityOptions) GetHeartbeatTimeout

func (x *ActivityOptions) GetHeartbeatTimeout() *durationpb.Duration

func (*ActivityOptions) GetRetryPolicy

func (x *ActivityOptions) GetRetryPolicy() *v11.RetryPolicy

func (*ActivityOptions) GetScheduleToCloseTimeout

func (x *ActivityOptions) GetScheduleToCloseTimeout() *durationpb.Duration

func (*ActivityOptions) GetScheduleToStartTimeout

func (x *ActivityOptions) GetScheduleToStartTimeout() *durationpb.Duration

func (*ActivityOptions) GetStartToCloseTimeout

func (x *ActivityOptions) GetStartToCloseTimeout() *durationpb.Duration

func (*ActivityOptions) GetTaskQueue

func (x *ActivityOptions) GetTaskQueue() *v1.TaskQueue

func (*ActivityOptions) ProtoMessage

func (*ActivityOptions) ProtoMessage()

func (*ActivityOptions) ProtoReflect

func (x *ActivityOptions) ProtoReflect() protoreflect.Message

func (*ActivityOptions) Reset

func (x *ActivityOptions) Reset()

func (*ActivityOptions) String

func (x *ActivityOptions) String() string

Jump to

Keyboard shortcuts

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