Documentation
¶
Index ¶
- Variables
- type ActivityOptions
- func (*ActivityOptions) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityOptions) GetHeartbeatTimeout() *durationpb.Duration
- func (x *ActivityOptions) GetRetryPolicy() *v11.RetryPolicy
- func (x *ActivityOptions) GetScheduleToCloseTimeout() *durationpb.Duration
- func (x *ActivityOptions) GetScheduleToStartTimeout() *durationpb.Duration
- func (x *ActivityOptions) GetStartToCloseTimeout() *durationpb.Duration
- func (x *ActivityOptions) GetTaskQueue() *v1.TaskQueue
- func (*ActivityOptions) ProtoMessage()
- func (x *ActivityOptions) ProtoReflect() protoreflect.Message
- func (x *ActivityOptions) Reset()
- func (x *ActivityOptions) String() string
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
Click to show internal directories.
Click to hide internal directories.