retryable

Documentation

Index

• func NewRetryableDeleteUserDataJob(userID string, usersClient *dummyservices.UserServiceClient, ...) goodjob.RetryableJob
• type RetryableDeleteUserDataJob
  • func (j *RetryableDeleteUserDataJob) GetID() goodjob.JobID
  • func (j *RetryableDeleteUserDataJob) GetLastTask() goodjob.Task
  • func (j *RetryableDeleteUserDataJob) GetLastTaskPos() int
  • func (j *RetryableDeleteUserDataJob) GetLastTaskResult() *goodjob.TaskResult
  • func (j *RetryableDeleteUserDataJob) GetTaskArgs(taskID goodjob.TaskID) []*goodjob.TaskArg
  • func (j *RetryableDeleteUserDataJob) GetTasks() []goodjob.Task
  • func (j *RetryableDeleteUserDataJob) GetTasksToRetry() []goodjob.Task
  • func (j *RetryableDeleteUserDataJob) GetVisible() bool
  • func (j *RetryableDeleteUserDataJob) IncreaseRetryCount(taskID goodjob.TaskID)
  • func (j *RetryableDeleteUserDataJob) RetryThresholdReached(taskID goodjob.TaskID) bool
  • func (j *RetryableDeleteUserDataJob) SetLastTask(task goodjob.Task)
  • func (j *RetryableDeleteUserDataJob) SetLastTaskPos(pos int)
  • func (j *RetryableDeleteUserDataJob) SetLastTaskResult(result *goodjob.TaskResult)
  • func (j *RetryableDeleteUserDataJob) SetVisible(visible bool)

Functions

func NewRetryableDeleteUserDataJob

func NewRetryableDeleteUserDataJob(userID string, usersClient *dummyservices.UserServiceClient, authClient *dummyservices.AuthServiceClient, ordersClient *dummyservices.OrdersServiceClient, retryThreshold int) goodjob.RetryableJob

Types

type RetryableDeleteUserDataJob

type RetryableDeleteUserDataJob struct {
	LastTaskPos         int
	LastTaskResult      *goodjob.TaskResult
	ID                  goodjob.JobID
	JobArgs             []goodjob.JobArg
	Tasks               []goodjob.Task
	TaskArgs            map[goodjob.TaskID][]*goodjob.TaskArg
	Visible             bool
	LastTask            goodjob.Task
	RetryThreshold      int
	RetryThresholdCount map[goodjob.TaskID]int
}

func (*RetryableDeleteUserDataJob) GetID

func (j *RetryableDeleteUserDataJob) GetID() goodjob.JobID

func (*RetryableDeleteUserDataJob) GetLastTask

func (j *RetryableDeleteUserDataJob) GetLastTask() goodjob.Task

func (*RetryableDeleteUserDataJob) GetLastTaskPos

func (j *RetryableDeleteUserDataJob) GetLastTaskPos() int

func (*RetryableDeleteUserDataJob) GetLastTaskResult

func (j *RetryableDeleteUserDataJob) GetLastTaskResult() *goodjob.TaskResult

func (*RetryableDeleteUserDataJob) GetTaskArgs

func (j *RetryableDeleteUserDataJob) GetTaskArgs(taskID goodjob.TaskID) []*goodjob.TaskArg

func (*RetryableDeleteUserDataJob) GetTasks

func (j *RetryableDeleteUserDataJob) GetTasks() []goodjob.Task

func (*RetryableDeleteUserDataJob) GetTasksToRetry

func (j *RetryableDeleteUserDataJob) GetTasksToRetry() []goodjob.Task

func (*RetryableDeleteUserDataJob) GetVisible

func (j *RetryableDeleteUserDataJob) GetVisible() bool

func (*RetryableDeleteUserDataJob) IncreaseRetryCount

func (j *RetryableDeleteUserDataJob) IncreaseRetryCount(taskID goodjob.TaskID)

func (*RetryableDeleteUserDataJob) RetryThresholdReached

func (j *RetryableDeleteUserDataJob) RetryThresholdReached(taskID goodjob.TaskID) bool

func (*RetryableDeleteUserDataJob) SetLastTask

func (j *RetryableDeleteUserDataJob) SetLastTask(task goodjob.Task)

func (*RetryableDeleteUserDataJob) SetLastTaskPos

func (j *RetryableDeleteUserDataJob) SetLastTaskPos(pos int)

func (*RetryableDeleteUserDataJob) SetLastTaskResult

func (j *RetryableDeleteUserDataJob) SetLastTaskResult(result *goodjob.TaskResult)

func (*RetryableDeleteUserDataJob) SetVisible

func (j *RetryableDeleteUserDataJob) SetVisible(visible bool)