testworker

package
v0.19.1174 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2026 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const ApprovalInnerSignalType signal.SignalType = "test-flow-approval-inner"
View Source 
const AutoRetrySignalType signal.SignalType = "test-flow-auto-retry"
View Source 
const CancelMarker = "cancel-callback-invoked"

CancelMarker is the value written to ResultDirective when Cancel() is invoked.

View Source 
const CancellableTestSignalType signal.SignalType = "test-flow-cancellable"
View Source 
const CountdownGroupSignalType signal.SignalType = "test-flow-countdown-group"
View Source 
const CountdownSignalType signal.SignalType = "test-flow-countdown"
View Source 
const FailSignalType signal.SignalType = "test-flow-fail"
View Source 
const ManualRetryGroupCountdownSignalType signal.SignalType = "test-flow-manual-retry-group-countdown"
View Source 
const ManualRetrySignalType signal.SignalType = "test-flow-manual-retry"
View Source 
const ManualRetryThenBlockSignalType signal.SignalType = "test-flow-manual-retry-then-block"
View Source 
const PlanApplyFailSignalType signal.SignalType = "test-flow-plan-apply-fail"
View Source 
const PolicyEvalApprovalSignalType signal.SignalType = "test-flow-policy-eval-approval"
View Source 
const RetryGroupSignalType signal.SignalType = "test-flow-retry-group"
View Source 
const SkipGroupApprovalSignalType signal.SignalType = "test-flow-skipgroup-approval"
View Source 
const SkippableFailSignalType signal.SignalType = "test-flow-skippable-fail"
View Source 
const SlowSignalType signal.SignalType = "test-flow-slow"
View Source 
const SuccessSignalType signal.SignalType = "test-flow-success"

Variables

This section is empty.

Functions

This section is empty.

Types

type ApprovalInnerSignal added in v0.19.1163 

type ApprovalInnerSignal struct{}

func (*ApprovalInnerSignal) Execute added in v0.19.1163 

func (s *ApprovalInnerSignal) Execute(workflow.Context) error

func (*ApprovalInnerSignal) SleepAfter added in v0.19.1163 

func (s *ApprovalInnerSignal) SleepAfter() time.Duration

func (*ApprovalInnerSignal) Type added in v0.19.1163 

func (s *ApprovalInnerSignal) Type() signal.SignalType

func (*ApprovalInnerSignal) Validate added in v0.19.1163 

func (s *ApprovalInnerSignal) Validate(workflow.Context) error

type AutoRetrySignal 

type AutoRetrySignal struct {
	FailUntilRetryIndex int `json:"fail_until_retry_index"`
}

func (*AutoRetrySignal) AutoRetry 

func (s *AutoRetrySignal) AutoRetry() bool

func (*AutoRetrySignal) Execute 

func (s *AutoRetrySignal) Execute(workflow.Context) error

func (*AutoRetrySignal) MaxRetries 

func (s *AutoRetrySignal) MaxRetries() int

func (*AutoRetrySignal) SleepAfter 

func (s *AutoRetrySignal) SleepAfter() time.Duration

func (*AutoRetrySignal) Type 

func (s *AutoRetrySignal) Type() signal.SignalType

func (*AutoRetrySignal) Validate 

func (s *AutoRetrySignal) Validate(workflow.Context) error

type CancellableTestSignal 

type CancellableTestSignal struct {
	StepID string `json:"step_id,omitempty"`
	FlowID string `json:"flow_id,omitempty"`
}

func (*CancellableTestSignal) Cancel 

func (s *CancellableTestSignal) Cancel(ctx workflow.Context) error

func (*CancellableTestSignal) Execute 

func (s *CancellableTestSignal) Execute(ctx workflow.Context) error

func (*CancellableTestSignal) SetStepContext 

func (s *CancellableTestSignal) SetStepContext(stepID, flowID string)

func (*CancellableTestSignal) SleepAfter 

func (s *CancellableTestSignal) SleepAfter() time.Duration

func (*CancellableTestSignal) Type 

func (s *CancellableTestSignal) Type() signal.SignalType

func (*CancellableTestSignal) Validate 

func (s *CancellableTestSignal) Validate(workflow.Context) error

type CountdownGroupSignal 

type CountdownGroupSignal struct {
	SucceedAtRetry int    `json:"succeed_at_retry"`
	StepID         string `json:"step_id,omitempty"`
	FlowID         string `json:"flow_id,omitempty"`
}

func (*CountdownGroupSignal) AutoRetry 

func (s *CountdownGroupSignal) AutoRetry() bool

func (*CountdownGroupSignal) Execute 

func (s *CountdownGroupSignal) Execute(ctx workflow.Context) error

func (*CountdownGroupSignal) MaxRetries 

func (s *CountdownGroupSignal) MaxRetries() int

func (*CountdownGroupSignal) RetryGroup 

func (s *CountdownGroupSignal) RetryGroup() bool

func (*CountdownGroupSignal) SetStepContext 

func (s *CountdownGroupSignal) SetStepContext(stepID, flowID string)

func (*CountdownGroupSignal) SleepAfter 

func (s *CountdownGroupSignal) SleepAfter() time.Duration

func (*CountdownGroupSignal) Type 

func (s *CountdownGroupSignal) Type() signal.SignalType

func (*CountdownGroupSignal) Validate 

func (s *CountdownGroupSignal) Validate(workflow.Context) error

type CountdownSignal 

type CountdownSignal struct {
	SucceedAtRetry int    `json:"succeed_at_retry"`
	StepID         string `json:"step_id,omitempty"`
	FlowID         string `json:"flow_id,omitempty"`
}

func (*CountdownSignal) AutoRetry 

func (s *CountdownSignal) AutoRetry() bool

func (*CountdownSignal) Execute 

func (s *CountdownSignal) Execute(ctx workflow.Context) error

func (*CountdownSignal) MaxRetries 

func (s *CountdownSignal) MaxRetries() int

func (*CountdownSignal) SetStepContext 

func (s *CountdownSignal) SetStepContext(stepID, flowID string)

func (*CountdownSignal) SleepAfter 

func (s *CountdownSignal) SleepAfter() time.Duration

func (*CountdownSignal) Type 

func (s *CountdownSignal) Type() signal.SignalType

func (*CountdownSignal) Validate 

func (s *CountdownSignal) Validate(workflow.Context) error

type FailSignal 

type FailSignal struct {
	Reason string `json:"reason"`
}

func (*FailSignal) Execute 

func (s *FailSignal) Execute(workflow.Context) error

func (*FailSignal) SleepAfter 

func (s *FailSignal) SleepAfter() time.Duration

func (*FailSignal) Type 

func (s *FailSignal) Type() signal.SignalType

func (*FailSignal) Validate 

func (s *FailSignal) Validate(workflow.Context) error

type ManualRetryGroupCountdownSignal 

type ManualRetryGroupCountdownSignal struct {
	StepID          string `json:"step_id,omitempty"`
	FlowID          string `json:"flow_id,omitempty"`
	GroupRetryCount int    `json:"-"`
}

func (*ManualRetryGroupCountdownSignal) AutoRetry 

func (s *ManualRetryGroupCountdownSignal) AutoRetry() bool

func (*ManualRetryGroupCountdownSignal) Execute 

func (s *ManualRetryGroupCountdownSignal) Execute(workflow.Context) error

func (*ManualRetryGroupCountdownSignal) MaxRetries 

func (s *ManualRetryGroupCountdownSignal) MaxRetries() int

func (*ManualRetryGroupCountdownSignal) RetryGroup 

func (s *ManualRetryGroupCountdownSignal) RetryGroup() bool

func (*ManualRetryGroupCountdownSignal) SetRetryCount 

func (s *ManualRetryGroupCountdownSignal) SetRetryCount(retryIndex, groupRetryIndex int)

func (*ManualRetryGroupCountdownSignal) SetStepContext 

func (s *ManualRetryGroupCountdownSignal) SetStepContext(stepID, flowID string)

func (*ManualRetryGroupCountdownSignal) SleepAfter 

func (s *ManualRetryGroupCountdownSignal) SleepAfter() time.Duration

func (*ManualRetryGroupCountdownSignal) Type 

func (s *ManualRetryGroupCountdownSignal) Type() signal.SignalType

func (*ManualRetryGroupCountdownSignal) Validate 

func (s *ManualRetryGroupCountdownSignal) Validate(workflow.Context) error

type ManualRetrySignal added in v0.19.1163 

type ManualRetrySignal struct {
	StepID string `json:"step_id,omitempty"`
	FlowID string `json:"flow_id,omitempty"`
}

func (*ManualRetrySignal) AutoRetry added in v0.19.1163 

func (s *ManualRetrySignal) AutoRetry() bool

func (*ManualRetrySignal) Execute added in v0.19.1163 

func (s *ManualRetrySignal) Execute(ctx workflow.Context) error

func (*ManualRetrySignal) MaxAutoRetries added in v0.19.1163 

func (s *ManualRetrySignal) MaxAutoRetries(workflow.Context) int

func (*ManualRetrySignal) MaxRetries added in v0.19.1163 

func (s *ManualRetrySignal) MaxRetries() int

func (*ManualRetrySignal) SetStepContext added in v0.19.1163 

func (s *ManualRetrySignal) SetStepContext(stepID, flowID string)

func (*ManualRetrySignal) SleepAfter added in v0.19.1163 

func (s *ManualRetrySignal) SleepAfter() time.Duration

func (*ManualRetrySignal) Type added in v0.19.1163 

func (s *ManualRetrySignal) Type() signal.SignalType

func (*ManualRetrySignal) Validate added in v0.19.1163 

func (s *ManualRetrySignal) Validate(workflow.Context) error

type ManualRetryThenBlockSignal added in v0.19.1163 

type ManualRetryThenBlockSignal struct {
	StepID string `json:"step_id,omitempty"`
	FlowID string `json:"flow_id,omitempty"`
}

func (*ManualRetryThenBlockSignal) AutoRetry added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) AutoRetry() bool

func (*ManualRetryThenBlockSignal) Cancel added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) Cancel(workflow.Context) error

func (*ManualRetryThenBlockSignal) Execute added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) Execute(ctx workflow.Context) error

func (*ManualRetryThenBlockSignal) MaxAutoRetries added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) MaxAutoRetries(workflow.Context) int

func (*ManualRetryThenBlockSignal) MaxRetries added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) MaxRetries() int

func (*ManualRetryThenBlockSignal) SetStepContext added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) SetStepContext(stepID, flowID string)

func (*ManualRetryThenBlockSignal) SleepAfter added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) SleepAfter() time.Duration

func (*ManualRetryThenBlockSignal) Type added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) Type() signal.SignalType

func (*ManualRetryThenBlockSignal) Validate added in v0.19.1163 

func (s *ManualRetryThenBlockSignal) Validate(workflow.Context) error

type PlanApplyFailSignal 

type PlanApplyFailSignal struct{}

func (*PlanApplyFailSignal) AutoRetry 

func (s *PlanApplyFailSignal) AutoRetry() bool

func (*PlanApplyFailSignal) Clone added in v0.19.945 

func (s *PlanApplyFailSignal) Clone(_ workflow.Context, originalStepName string) ([]signal.CloneStepDef, error)

func (*PlanApplyFailSignal) Execute 

func (s *PlanApplyFailSignal) Execute(workflow.Context) error

func (*PlanApplyFailSignal) MaxRetries 

func (s *PlanApplyFailSignal) MaxRetries() int

func (*PlanApplyFailSignal) RetryGroup 

func (s *PlanApplyFailSignal) RetryGroup() bool

func (*PlanApplyFailSignal) SleepAfter 

func (s *PlanApplyFailSignal) SleepAfter() time.Duration

func (*PlanApplyFailSignal) Type 

func (s *PlanApplyFailSignal) Type() signal.SignalType

func (*PlanApplyFailSignal) Validate 

func (s *PlanApplyFailSignal) Validate(workflow.Context) error

type PolicyEvalApprovalSignal added in v0.19.1163 

type PolicyEvalApprovalSignal struct{}

func (*PolicyEvalApprovalSignal) Execute added in v0.19.1163 

func (s *PolicyEvalApprovalSignal) Execute(workflow.Context) error

func (*PolicyEvalApprovalSignal) RequiresPolicyEvaluation added in v0.19.1163 

func (s *PolicyEvalApprovalSignal) RequiresPolicyEvaluation() bool

func (*PolicyEvalApprovalSignal) SleepAfter added in v0.19.1163 

func (s *PolicyEvalApprovalSignal) SleepAfter() time.Duration

func (*PolicyEvalApprovalSignal) Type added in v0.19.1163 

func (s *PolicyEvalApprovalSignal) Type() signal.SignalType

func (*PolicyEvalApprovalSignal) Validate added in v0.19.1163 

func (s *PolicyEvalApprovalSignal) Validate(workflow.Context) error

type RetryGroupSignal 

type RetryGroupSignal struct{}

func (*RetryGroupSignal) AutoRetry 

func (s *RetryGroupSignal) AutoRetry() bool

func (*RetryGroupSignal) Execute 

func (s *RetryGroupSignal) Execute(workflow.Context) error

func (*RetryGroupSignal) MaxRetries 

func (s *RetryGroupSignal) MaxRetries() int

func (*RetryGroupSignal) RetryGroup 

func (s *RetryGroupSignal) RetryGroup() bool

func (*RetryGroupSignal) SleepAfter 

func (s *RetryGroupSignal) SleepAfter() time.Duration

func (*RetryGroupSignal) Type 

func (s *RetryGroupSignal) Type() signal.SignalType

func (*RetryGroupSignal) Validate 

func (s *RetryGroupSignal) Validate(workflow.Context) error

type SkipGroupApprovalSignal added in v0.19.1163 

type SkipGroupApprovalSignal struct{}

func (*SkipGroupApprovalSignal) Execute added in v0.19.1163 

func (s *SkipGroupApprovalSignal) Execute(workflow.Context) error

func (*SkipGroupApprovalSignal) SkipGroup added in v0.19.1163 

func (s *SkipGroupApprovalSignal) SkipGroup() bool

func (*SkipGroupApprovalSignal) SleepAfter added in v0.19.1163 

func (s *SkipGroupApprovalSignal) SleepAfter() time.Duration

func (*SkipGroupApprovalSignal) Type added in v0.19.1163 

func (s *SkipGroupApprovalSignal) Type() signal.SignalType

func (*SkipGroupApprovalSignal) Validate added in v0.19.1163 

func (s *SkipGroupApprovalSignal) Validate(workflow.Context) error

type SkippableFailSignal added in v0.19.1163 

type SkippableFailSignal struct{}

func (*SkippableFailSignal) AutoRetry added in v0.19.1163 

func (s *SkippableFailSignal) AutoRetry() bool

func (*SkippableFailSignal) Execute added in v0.19.1163 

func (s *SkippableFailSignal) Execute(workflow.Context) error

func (*SkippableFailSignal) MaxRetries added in v0.19.1163 

func (s *SkippableFailSignal) MaxRetries() int

func (*SkippableFailSignal) SleepAfter added in v0.19.1163 

func (s *SkippableFailSignal) SleepAfter() time.Duration

func (*SkippableFailSignal) Type added in v0.19.1163 

func (s *SkippableFailSignal) Type() signal.SignalType

func (*SkippableFailSignal) Validate added in v0.19.1163 

func (s *SkippableFailSignal) Validate(workflow.Context) error

type SlowSignal 

type SlowSignal struct{}

func (*SlowSignal) Cancel 

func (s *SlowSignal) Cancel(workflow.Context) error

func (*SlowSignal) Execute 

func (s *SlowSignal) Execute(ctx workflow.Context) error

func (*SlowSignal) SleepAfter 

func (s *SlowSignal) SleepAfter() time.Duration

func (*SlowSignal) Type 

func (s *SlowSignal) Type() signal.SignalType

func (*SlowSignal) Validate 

func (s *SlowSignal) Validate(workflow.Context) error

type SuccessSignal 

type SuccessSignal struct{}

func (*SuccessSignal) Execute 

func (s *SuccessSignal) Execute(workflow.Context) error

func (*SuccessSignal) SleepAfter 

func (s *SuccessSignal) SleepAfter() time.Duration

func (*SuccessSignal) Type 

func (s *SuccessSignal) Type() signal.SignalType

func (*SuccessSignal) Validate 

func (s *SuccessSignal) Validate(workflow.Context) error

type Worker 

type Worker struct {
	worker.Worker
}

func New 

func New(params WorkerParams) (*Worker, error)

type WorkerParams 

type WorkerParams struct {
	fx.In

	V              *validator.Validate
	Cfg            *internal.Config
	Tclient        temporalclient.Client
	QueueWkflows   *queue.Workflows
	HandlerWkflows *handler.Workflows
	SharedActs     *workflows.Activities
	L              *zap.Logger
	Lc             fx.Lifecycle
	Interceptors   []interceptor.WorkerInterceptor `group:"interceptors"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.