models

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

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

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

Jump to

Keyboard shortcuts

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