task

package
v0.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 12, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL