worker

Documentation

Index

• Constants
• type IWorker
  • func GetWorker(workerType WorkerType) (IWorker, error)
• type JobWorker
  • func (w *JobWorker) Connect(projectID string) error
  • func (w JobWorker) Run()
• type MailWorker
  • func (w *MailWorker) Connect(projectID string) error
  • func (w MailWorker) Run()
• type WebWorker
  • func (w WebWorker) Run()
• type WorkerType

Constants

const WORKER_EMAIL = "email"

const WORKER_JOB = "job"

Types

type IWorker

type IWorker interface {
	Run()
}

func GetWorker

func GetWorker(workerType WorkerType) (IWorker, error)

type JobWorker

type JobWorker struct {
	ProjectID string
	// contains filtered or unexported fields
}

func (*JobWorker) Connect

func (w *JobWorker) Connect(projectID string) error

func (JobWorker) Run

func (w JobWorker) Run()

type MailWorker

type MailWorker struct {
	ProjectID string
	// contains filtered or unexported fields
}

func (*MailWorker) Connect

func (w *MailWorker) Connect(projectID string) error

func (MailWorker) Run

func (w MailWorker) Run()

type WebWorker

type WebWorker struct{}

func (WebWorker) Run

func (w WebWorker) Run()

type WorkerType

type WorkerType string