taskmanager

Documentation

Index

• Constants
• type Manager
  • func NewManager(paasEnv, clusterEnv string, checkInterval int, disc *discovery.Client, ...) (*Manager, error)
  • func (m *Manager) Run()
  • func (m *Manager) Stop()

Constants

const (
	// DEFAULT_CHECK_INTERVAL TODO
	DEFAULT_CHECK_INTERVAL = 60
)

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