worker

Documentation

Index

• Constants
• Variables
• func InitProducer(producer event.TaskWorkerEventProducer)
• func InitWorkerDAO(db *mongox.Mongo, producer event.TaskWorkerEventProducer) dao.WorkerDAO
• type Execute
• type Handler
• type Module
  • func InitModule(q mq.MQ, db *mongox.Mongo, etcdClient *clientv3.Client) (*Module, error)
• type Service

Constants

const (
	RUNNING  = domain.RUNNING
	STOPPING = domain.STOPPING
	OFFLINE  = domain.OFFLINE
)

Variables

var ProviderSet = wire.NewSet(web.NewHandler, service.NewService, repository.NewWorkerRepository)

Functions

func InitProducer

func InitProducer(producer event.TaskWorkerEventProducer)

func InitWorkerDAO

func InitWorkerDAO(db *mongox.Mongo, producer event.TaskWorkerEventProducer) dao.WorkerDAO

Types

type Execute

type Execute = domain.Execute

type Handler

type Handler = web.Handler

type Module

type Module struct {
	Svc Service

	Hdl *Handler
	// contains filtered or unexported fields
}

func InitModule

func InitModule(q mq.MQ, db *mongox.Mongo, etcdClient *clientv3.Client) (*Module, error)

type Service

type Service = service.Service