task

Documentation

Index

• func NewBaseService() (svc2 interfaces.TaskBaseService, err error)
• type BaseService
  • func (svc *BaseService) GetQueue(nodeId primitive.ObjectID) (queue string)
  • func (svc *BaseService) Init() error
  • func (svc *BaseService) IsStopped() (res bool)
  • func (svc *BaseService) SaveTask(t interfaces.Task, status string) (err error)
  • func (svc *BaseService) Start()
  • func (svc *BaseService) Stop()
  • func (svc *BaseService) Wait()

Functions

func NewBaseService

func NewBaseService() (svc2 interfaces.TaskBaseService, err error)

Types

type BaseService

type BaseService struct {
	// dependencies
	interfaces.WithConfigPath
	// contains filtered or unexported fields
}

func (*BaseService) GetQueue

func (svc *BaseService) GetQueue(nodeId primitive.ObjectID) (queue string)

func (*BaseService) Init

func (svc *BaseService) Init() error

func (*BaseService) IsStopped

func (svc *BaseService) IsStopped() (res bool)

func (*BaseService) SaveTask

func (svc *BaseService) SaveTask(t interfaces.Task, status string) (err error)

SaveTask deprecated

func (*BaseService) Start

func (svc *BaseService) Start()

func (*BaseService) Stop

func (svc *BaseService) Stop()

func (*BaseService) Wait

func (svc *BaseService) Wait()