jobsv1

Documentation

Index

• func NewManager(config jobs.Config, repo jobs.Repository) jobs.Manager
• func NewRepository(repo storage.Repository) jobs.Repository
• type BaseTask
  • func (b *BaseTask) ParseJobID(taskTypeName string, kwargs map[string]interface{}) error
  • func (b *BaseTask) UpdateJob(accountID identity.DID, taskTypeName string, err error) error
  • func (b *BaseTask) UpdateJobWithValue(accountID identity.DID, taskTypeName string, err error, txValue *jobs.JobValue) error
• type Bootstrapper
  • func (b Bootstrapper) Bootstrap(ctx map[string]interface{}) error

Functions

func NewManager

func NewManager(config jobs.Config, repo jobs.Repository) jobs.Manager

NewManager returns a JobManager implementation.

func NewRepository

func NewRepository(repo storage.Repository) jobs.Repository

NewRepository registers the the Job model and returns the an implementation of the Repository.

Types

type BaseTask

type BaseTask struct {
	JobID jobs.JobID

	// state
	JobManager jobs.Manager
}

BaseTask holds the required details and helper functions for tasks to update jobs. should be embedded into the task

func (*BaseTask) ParseJobID

func (b *BaseTask) ParseJobID(taskTypeName string, kwargs map[string]interface{}) error

ParseJobID parses JobID.

func (*BaseTask) UpdateJob

func (b *BaseTask) UpdateJob(accountID identity.DID, taskTypeName string, err error) error

UpdateJob add a new log and updates the status of the job based on the error.

func (*BaseTask) UpdateJobWithValue

func (b *BaseTask) UpdateJobWithValue(accountID identity.DID, taskTypeName string, err error, txValue *jobs.JobValue) error

UpdateJobWithValue add a new log and updates the status of the transaction based on the error and adds a value to the tx

type Bootstrapper

type Bootstrapper struct{}

Bootstrapper implements bootstrap.Bootstrapper.

func (Bootstrapper) Bootstrap

func (b Bootstrapper) Bootstrap(ctx map[string]interface{}) error

Bootstrap adds transaction.Repository into context.