deleteuser

README

This is a more realistic example of usage for goodjob.

Let's imagine that we have three services that handle user data:

• Auth - handles authentication and authorization data of users
• Orders - handles some type of orders created by users
• Users - handles user profile data

The dummy code for those services' RPC clients is defiled in the dummyservice package.

Now, let's imagine that we want to safe-delete all user data.

We can do it in multiple fashions:

• call RPC methods to delete user data in each service and hope for the best, i.e. no errors would occur
• call RPC methods and retry operations that have failed for a reasonable amount of attempts
• call RPC methods and revert successful operations if one of the operations has failed.
• or we can do both, retry failed operations and revert unsuccessful ones if some retry threshold is reached.

Examples of all aforementioned approaches can be found here:

• simple safe-delete
• retry on failure
• revert on failure
• both retry and revert

Each of those packages contains:

• job definitions in the job.yaml files
• generated job boilerplate code in the job.gen.go files
• tests in the job_test.go files

Tasks for those jobs are in the tasks.go file.

Documentation

Index

• type SafeDeleteAuthDataTask
  • func (t SafeDeleteAuthDataTask) Exec(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)
  • func (t SafeDeleteAuthDataTask) GetID() goodjob.TaskID
  • func (t SafeDeleteAuthDataTask) GetJobID() goodjob.JobID
  • func (t SafeDeleteAuthDataTask) Revert(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)
• type SafeDeleteUserOrdersTask
  • func (t SafeDeleteUserOrdersTask) Exec(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)
  • func (t SafeDeleteUserOrdersTask) GetID() goodjob.TaskID
  • func (t SafeDeleteUserOrdersTask) GetJobID() goodjob.JobID
• type SafeDeleteUserTask
  • func (t SafeDeleteUserTask) Exec(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)
  • func (t SafeDeleteUserTask) GetID() goodjob.TaskID
  • func (t SafeDeleteUserTask) GetJobID() goodjob.JobID
  • func (t SafeDeleteUserTask) Revert(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)

Types

type SafeDeleteAuthDataTask

type SafeDeleteAuthDataTask struct {
	ID    goodjob.TaskID
	JobID goodjob.JobID
	Args  []*goodjob.TaskArg
}

func (SafeDeleteAuthDataTask) Exec

func (t SafeDeleteAuthDataTask) Exec(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)

func (SafeDeleteAuthDataTask) GetID

func (t SafeDeleteAuthDataTask) GetID() goodjob.TaskID

func (SafeDeleteAuthDataTask) GetJobID

func (t SafeDeleteAuthDataTask) GetJobID() goodjob.JobID

func (SafeDeleteAuthDataTask) Revert

func (t SafeDeleteAuthDataTask) Revert(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)

type SafeDeleteUserOrdersTask

type SafeDeleteUserOrdersTask struct {
	ID    goodjob.TaskID
	JobID goodjob.JobID
	Args  []*goodjob.TaskArg
}

func (SafeDeleteUserOrdersTask) Exec

func (t SafeDeleteUserOrdersTask) Exec(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)

func (SafeDeleteUserOrdersTask) GetID

func (t SafeDeleteUserOrdersTask) GetID() goodjob.TaskID

func (SafeDeleteUserOrdersTask) GetJobID

func (t SafeDeleteUserOrdersTask) GetJobID() goodjob.JobID

type SafeDeleteUserTask

type SafeDeleteUserTask struct {
	ID    goodjob.TaskID
	JobID goodjob.JobID
	Args  []*goodjob.TaskArg
}

func (SafeDeleteUserTask) Exec

func (t SafeDeleteUserTask) Exec(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)

func (SafeDeleteUserTask) GetID

func (t SafeDeleteUserTask) GetID() goodjob.TaskID

func (SafeDeleteUserTask) GetJobID

func (t SafeDeleteUserTask) GetJobID() goodjob.JobID

func (SafeDeleteUserTask) Revert

func (t SafeDeleteUserTask) Revert(args ...*goodjob.TaskArg) (result *goodjob.TaskResult)