retrypolicytest

package
v0.20.2 Latest Latest
Warning

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

Go to latest
Published: Apr 9, 2025 License: MPL-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RetryPolicyCustom

type RetryPolicyCustom struct{}

RetryPolicyCustom is a retry policy demonstrating trivial customization.

func (*RetryPolicyCustom) NextRetry

func (p *RetryPolicyCustom) NextRetry(job *rivertype.JobRow) time.Time

type RetryPolicyInvalid

type RetryPolicyInvalid struct{}

RetryPolicyInvalid is a retry policy that returns invalid timestamps.

func (*RetryPolicyInvalid) NextRetry

func (p *RetryPolicyInvalid) NextRetry(job *rivertype.JobRow) time.Time

type RetryPolicyNoJitter

type RetryPolicyNoJitter struct{}

RetryPolicyNoJitter is identical to default retry policy except that it leaves off the jitter to make checking against it more convenient.

func (*RetryPolicyNoJitter) NextRetry

func (p *RetryPolicyNoJitter) NextRetry(job *rivertype.JobRow) time.Time

Jump to

Keyboard shortcuts

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