Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActivityCallWith ¶
type ActivityCallWith struct {
Name string `json:"name"`
Arguments []any `json:"arguments"`
Options *ActivityCallWithOptions `json:"options,omitempty"`
}
type ActivityCallWithOptions ¶
type ActivityCallWithOptions struct {
TaskQueue string `json:"taskQueue"`
ScheduleToCloseTimeout *model.Duration `json:"scheduleToCloseTimeout"`
ScheduleToStartTimeout *model.Duration `json:"scheduleToStartTimeout"`
StartToCloseTimeout *model.Duration `json:"startToCloseTimeout"`
HeartbeatTimeout *model.Duration `json:"heartbeatTimeout"`
WaitForCancellation *bool `json:"waitForCancellation"`
ActivityID string `json:"activityId"`
RetryPolicy *RetryPolicy `json:"retryPolicy"`
DisableEagerExecution *bool `json:"disableEagerExecution"`
Summary string `json:"summary"`
Priority *ActivityPriority `json:"priority"`
}
func (*ActivityCallWithOptions) ToTemporal ¶
func (a *ActivityCallWithOptions) ToTemporal(ctx workflow.Context) workflow.ActivityOptions
type ActivityPriority ¶
type ActivityPriority struct {
PriorityKey *int `json:"priorityKey"`
FairnessKey string `json:"fairnessKey"`
FairnessWeight *float32 `json:"fairnessWeight"`
}
func (*ActivityPriority) ToTemporal ¶
func (a *ActivityPriority) ToTemporal() temporal.Priority
type RetryPolicy ¶
type RetryPolicy struct {
InitialInterval *model.Duration `json:"initialInterval"`
BackoffCoefficient *float64 `json:"backoffCoefficient"`
MaximumInterval *model.Duration `json:"maximumInterval"`
MaximumAttempts *int32 `json:"maximumAttempts"`
NonRetryableErrorTypes []string `json:"nonRetryableErrorTypes"`
}
func (*RetryPolicy) ToTemporal ¶
func (r *RetryPolicy) ToTemporal() *temporal.RetryPolicy
Click to show internal directories.
Click to hide internal directories.