taskmanager

package
v0.21.3 Latest Latest
Warning

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

Go to latest
Published: Jun 9, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DEFAULT_CHECK_INTERVAL = 60
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

Manager task manager for discover task and dispatch task

func NewManager

func NewManager(paasEnv, clusterEnv string,
	checkInterval int,
	disc *discovery.Client, zk *zkclient.ZkClient, paasccClient paascc.ClientInterface) (*Manager, error)

NewManager create new task manager

func (*Manager) Run

func (m *Manager) Run()

Run run manager

func (*Manager) Stop

func (m *Manager) Stop()

Stop manager

Jump to

Keyboard shortcuts

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