masterpool

Documentation

Index

• func InitTaskMasterPool(masterPool *TaskMasterPool)
• type TaskMasterPool
  • func GetTaskMasterPool() *TaskMasterPool
  • func NewTaskMasterPool(tasks *tasks.TaskMap) *TaskMasterPool
  • func (p *TaskMasterPool) Contains(jobInstanceId int64) bool
  • func (p *TaskMasterPool) Get(jobInstanceId int64) taskmaster.TaskMaster
  • func (p *TaskMasterPool) GetInstanceIds(specifiedAppGroupId int64) []int64
  • func (p *TaskMasterPool) Put(jobInstanceId int64, master taskmaster.TaskMaster)
  • func (p *TaskMasterPool) Remove(jobInstanceId int64)
  • func (p *TaskMasterPool) Tasks() *tasks.TaskMap

Functions

func InitTaskMasterPool

func InitTaskMasterPool(masterPool *TaskMasterPool)

Types

type TaskMasterPool

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

func GetTaskMasterPool

func GetTaskMasterPool() *TaskMasterPool

GetTaskMasterPool must be executed after InitTaskMasterPool, otherwise it returns nil

func NewTaskMasterPool

func NewTaskMasterPool(tasks *tasks.TaskMap) *TaskMasterPool

func (*TaskMasterPool) Contains

func (p *TaskMasterPool) Contains(jobInstanceId int64) bool

func (*TaskMasterPool) Get

func (p *TaskMasterPool) Get(jobInstanceId int64) taskmaster.TaskMaster

func (*TaskMasterPool) GetInstanceIds

func (p *TaskMasterPool) GetInstanceIds(specifiedAppGroupId int64) []int64

func (*TaskMasterPool) Put

func (p *TaskMasterPool) Put(jobInstanceId int64, master taskmaster.TaskMaster)

func (*TaskMasterPool) Remove

func (p *TaskMasterPool) Remove(jobInstanceId int64)

func (*TaskMasterPool) Tasks

func (p *TaskMasterPool) Tasks() *tasks.TaskMap