retry

type CheckFunc func(*task.Task) bool

type Options struct {
	bus.Options `toml:"bus"`

	// topic and channel to listen to
	// done tasks for retry review.
	DoneTopic        string `toml:"done_topic" commented:"true"`
	DoneChannel      string `toml:"done_channel" commented:"true"`
	RetriedTopic     string `toml:"retried_topic" commented:"true" comment:"all retries published to this topic (disable with \"-\" value)"`
	RetryFailedTopic string `toml:"retry_failed_topic" commented:"true" comment:"all failures (retried and failed) published to this topic"`

	// retry rules
	RetryRules []*RetryRule `toml:"rule" commented:"true"`
}

type RetryRule struct {
	TaskType string   `toml:"type"`
	Retries  int      `toml:"retry"`
	Wait     duration `toml:"wait"`  // duration to wait before creating and sending new task
	Topic    string   `toml:"topic"` // topic override (default is TaskType value)
}

type Retryer struct {
	sync.Mutex // mutex for updating the retryCache
	// contains filtered or unexported fields
}