service

package
v0.0.0-...-cb472e6 Latest Latest
Warning

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

Go to latest
Published: Aug 27, 2021 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Service

type Service struct {
	*options.Config
	*backbone.Engine

	CacheDB *redis.Client
	DB      dal.RDB
	// contains filtered or unexported fields
}

func (*Service) CreateTask

func (s *Service) CreateTask(ctx *rest.Contexts)

func (*Service) DetailTask

func (s *Service) DetailTask(ctx *rest.Contexts)

func (*Service) Healthz

func (s *Service) Healthz(req *restful.Request, resp *restful.Response)

func (*Service) ListTask

func (s *Service) ListTask(ctx *rest.Contexts)

func (*Service) NewQueue

func (s *Service) NewQueue(taskMap map[string]TaskInfo) *TaskQueue

func (*Service) StatusToFailure

func (s *Service) StatusToFailure(ctx *rest.Contexts)

func (*Service) StatusToSuccess

func (s *Service) StatusToSuccess(ctx *rest.Contexts)

func (*Service) WebService

func (s *Service) WebService() *restful.Container

type TaskInfo

type TaskInfo struct {
	Name  string
	Addr  func() ([]string, error)
	Path  string
	Retry int64
}

type TaskQueue

type TaskQueue struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func (*TaskQueue) Start

func (tq *TaskQueue) Start()

func (*TaskQueue) Stop

func (tq *TaskQueue) Stop()

Jump to

Keyboard shortcuts

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