service

Documentation

Index

• type Service
  • func NewService(cpuCfg c.Config) *Service
  • func (s *Service) HandleWorker() error
  • func (s *Service) NewWorker()
  • func (s *Service) Register(name string, val interface{}) error
  • func (s *Service) Send(signature *tasks.Signature) (result *result.AsyncResult, e error)

Types

type Service

type Service struct {
	Name string
	Task int
	// contains filtered or unexported fields
}

Service ...

func NewService

func NewService(cpuCfg c.Config) *Service

NewService ...

func (*Service) HandleWorker

func (s *Service) HandleWorker() error

HandleWorker ...

func (*Service) NewWorker

func (s *Service) NewWorker()

NewWorker ...

func (*Service) Register

func (s *Service) Register(name string, val interface{}) error

AddTask ...

func (*Service) Send

func (s *Service) Send(signature *tasks.Signature) (result *result.AsyncResult, e error)

Send ...