testworker

package
v0.19.905 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2026 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

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 PlanApplyFailSignalType signal.SignalType = "test-flow-plan-apply-fail"
View Source 
const RetryGroupSignalType signal.SignalType = "test-flow-retry-group"
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 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 PlanApplyFailSignal 

type PlanApplyFailSignal struct{}

func (*PlanApplyFailSignal) AutoRetry 

func (s *PlanApplyFailSignal) AutoRetry() bool

func (*PlanApplyFailSignal) CloneSteps 

func (s *PlanApplyFailSignal) CloneSteps(originalStepName string) []signal.CloneStepDef

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 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 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.