manager

Documentation

Index

• type Manager
  • func NewManager(appConf config.AppConfig, daoManager *dao.Manager, ...) *Manager
  • func (m *Manager) AddTask(t *model.Task) error
  • func (m *Manager) DeleteTask(taskId string) error
  • func (m *Manager) GetAgentClient() (agentservice.Client, error)
  • func (m *Manager) GetAgentClientByServiceId(serviceId string) (agentservice.Client, error)
  • func (m *Manager) GetDispatcher() dispatcher.IDispatcher
  • func (m *Manager) GetRegistry() registry.IRegistry
  • func (m *Manager) StartUpdate()
  • func (m *Manager) SyncService()
  • func (m *Manager) UpdateAgentTasks()

Types

type Manager

type Manager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Manager that api manager

func NewManager

func NewManager(appConf config.AppConfig, daoManager *dao.Manager, dispatcher dispatcher.IDispatcher, registry registry.IRegistry, resolver discovery.Resolver) *Manager

func (*Manager) AddTask

func (m *Manager) AddTask(t *model.Task) error

func (*Manager) DeleteTask

func (m *Manager) DeleteTask(taskId string) error

func (*Manager) GetAgentClient

func (m *Manager) GetAgentClient() (agentservice.Client, error)

func (*Manager) GetAgentClientByServiceId

func (m *Manager) GetAgentClientByServiceId(serviceId string) (agentservice.Client, error)

func (*Manager) GetDispatcher

func (m *Manager) GetDispatcher() dispatcher.IDispatcher

func (*Manager) GetRegistry

func (m *Manager) GetRegistry() registry.IRegistry

func (*Manager) StartUpdate

func (m *Manager) StartUpdate()

func (*Manager) SyncService

func (m *Manager) SyncService()

SyncService sync service from registry

func (*Manager) UpdateAgentTasks

func (m *Manager) UpdateAgentTasks()