retryable_revertible

Documentation

Index

• func NewRetryableRevertibleDeleteUserDataJob(userID string, usersClient *dummyservices.UserServiceClient, ...) goodjob.RetryableRevertibleJob
• type RetryableRevertibleDeleteUserDataJob
  • func (j *RetryableRevertibleDeleteUserDataJob) GetID() goodjob.JobID
  • func (j *RetryableRevertibleDeleteUserDataJob) GetLastTask() goodjob.Task
  • func (j *RetryableRevertibleDeleteUserDataJob) GetLastTaskPos() int
  • func (j *RetryableRevertibleDeleteUserDataJob) GetLastTaskResult() *goodjob.TaskResult
  • func (j *RetryableRevertibleDeleteUserDataJob) GetRevertState() bool
  • func (j *RetryableRevertibleDeleteUserDataJob) GetTaskArgs(taskID goodjob.TaskID) []*goodjob.TaskArg
  • func (j *RetryableRevertibleDeleteUserDataJob) GetTasks() []goodjob.Task
  • func (j *RetryableRevertibleDeleteUserDataJob) GetTasksToRetry() []goodjob.Task
  • func (j *RetryableRevertibleDeleteUserDataJob) GetTasksToRevert() []goodjob.RevertibleTask
  • func (j *RetryableRevertibleDeleteUserDataJob) GetVisible() bool
  • func (j *RetryableRevertibleDeleteUserDataJob) IncreaseRetryCount(taskID goodjob.TaskID)
  • func (j *RetryableRevertibleDeleteUserDataJob) RetryThresholdReached(taskID goodjob.TaskID) bool
  • func (j *RetryableRevertibleDeleteUserDataJob) SetLastTask(task goodjob.Task)
  • func (j *RetryableRevertibleDeleteUserDataJob) SetLastTaskPos(pos int)
  • func (j *RetryableRevertibleDeleteUserDataJob) SetLastTaskResult(result *goodjob.TaskResult)
  • func (j *RetryableRevertibleDeleteUserDataJob) SetRevertState(revert bool)
  • func (j *RetryableRevertibleDeleteUserDataJob) SetVisible(visible bool)

Functions

func NewRetryableRevertibleDeleteUserDataJob

func NewRetryableRevertibleDeleteUserDataJob(userID string, usersClient *dummyservices.UserServiceClient, authClient *dummyservices.AuthServiceClient, ordersClient *dummyservices.OrdersServiceClient, forwardRetryThreshold int, backwardRetryThreshold int) goodjob.RetryableRevertibleJob

Types

type RetryableRevertibleDeleteUserDataJob

type RetryableRevertibleDeleteUserDataJob struct {
	Tasks                       []goodjob.Task
	TaskArgs                    map[goodjob.TaskID][]*goodjob.TaskArg
	Visible                     bool
	LastTask                    goodjob.Task
	LastTaskPos                 int
	LastTaskResult              *goodjob.TaskResult
	ID                          goodjob.JobID
	JobArgs                     []goodjob.JobArg
	RevertState                 bool
	ForwardRetryThreshold       int
	ForwardRetryThresholdCount  map[goodjob.TaskID]int
	BackwardRetryThreshold      int
	BackwardRetryThresholdCount map[goodjob.TaskID]int
}

func (*RetryableRevertibleDeleteUserDataJob) GetID

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

func (*RetryableRevertibleDeleteUserDataJob) GetLastTask

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

func (*RetryableRevertibleDeleteUserDataJob) GetLastTaskPos

func (j *RetryableRevertibleDeleteUserDataJob) GetLastTaskPos() int

func (*RetryableRevertibleDeleteUserDataJob) GetLastTaskResult

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

func (*RetryableRevertibleDeleteUserDataJob) GetRevertState

func (j *RetryableRevertibleDeleteUserDataJob) GetRevertState() bool

func (*RetryableRevertibleDeleteUserDataJob) GetTaskArgs

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

func (*RetryableRevertibleDeleteUserDataJob) GetTasks

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

func (*RetryableRevertibleDeleteUserDataJob) GetTasksToRetry

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

func (*RetryableRevertibleDeleteUserDataJob) GetTasksToRevert

func (j *RetryableRevertibleDeleteUserDataJob) GetTasksToRevert() []goodjob.RevertibleTask

func (*RetryableRevertibleDeleteUserDataJob) GetVisible

func (j *RetryableRevertibleDeleteUserDataJob) GetVisible() bool

func (*RetryableRevertibleDeleteUserDataJob) IncreaseRetryCount

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

func (*RetryableRevertibleDeleteUserDataJob) RetryThresholdReached

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

func (*RetryableRevertibleDeleteUserDataJob) SetLastTask

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

func (*RetryableRevertibleDeleteUserDataJob) SetLastTaskPos

func (j *RetryableRevertibleDeleteUserDataJob) SetLastTaskPos(pos int)

func (*RetryableRevertibleDeleteUserDataJob) SetLastTaskResult

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

func (*RetryableRevertibleDeleteUserDataJob) SetRevertState

func (j *RetryableRevertibleDeleteUserDataJob) SetRevertState(revert bool)

func (*RetryableRevertibleDeleteUserDataJob) SetVisible

func (j *RetryableRevertibleDeleteUserDataJob) SetVisible(visible bool)