fakes

Documentation

Index

• Constants
• func FakeLXDockerTask(taskId, taskName, slaveId, taskCommand string) *lxtypes.Task
• func FakeLXTask(taskId, taskName, slaveId, taskCommand string) *lxtypes.Task
• func FakeMesosDockerTask(taskId, taskName, slaveId, taskCommand string) *mesosproto.TaskInfo
• func FakeMesosTask(taskId, taskName, slaveId, taskCommand string) *mesosproto.TaskInfo
• func FakeNode(resourceId string, nodeId string) *lxtypes.Node
• func FakeOffer(offerId string, slaveId string) *mesosproto.Offer
• func FakeResources() []*mesosproto.Resource
• func FakeTaskProvider(tpid, source string) *lxtypes.TaskProvider
• func FakeTaskStatus(taskId string, fakeState mesosproto.TaskState) *mesosproto.TaskStatus
• func RunFakeRpiServer(layerxUrl string, port int, driverErrc chan error)
• func RunFakeTpiServer(layerxUrl string, port int, driverErrc chan error)
• type FakeCore
  • func NewFakeCore() *FakeCore
  • func (core *FakeCore) Start(fakeStatuses []*mesosproto.TaskStatus, port int)

Constants

const (
	//tpi
	RegisterTpi            = "/RegisterTpi"
	RegisterTaskProvider   = "/RegisterTaskProvider"
	DeregisterTaskProvider = "/DeregisterTaskProvider"
	GetTaskProviders       = "/GetTaskProviders"
	GetStatusUpdates       = "/GetStatusUpdates"
	GetStatusUpdate        = "/GetStatusUpdate"
	SubmitTask             = "/SubmitTask"
	KillTask               = "/KillTask"
	PurgeTask              = "/PurgeTask"
	//rpi
	RegisterRpi        = "/RegisterRpi"
	SubmitResource     = "/SubmitResource"
	RescindResource    = "/RescindResource"
	SubmitStatusUpdate = "/SubmitStatusUpdate"
	//brain
	GetNodes        = "/GetNodes"
	GetPendingTasks = "/GetPendingTasks"
	GetStagingTasks = "/GetStagingTasks"
	AssignTasks     = "/AssignTasks"
	MigrateTasks    = "/MigrateTasks"

	//for testing
	Purge = "/Purge"
)

const (
	COLLECT_RESOURCES = "/collect_resources"
	LAUNCH_TASKS      = "/launch_tasks"
	KILL_TASK         = "/kill_task"
)

const (
	COLLECT_TASKS              = "/collect_tasks"
	UPDATE_TASK_STATUS         = "/update_task_status"
	HEALTH_CHECK_TASK_PROVIDER = "/health_check_task_provider"

	FAIL_ON_PURPOSE = "failonpurpose"
)

Functions

func FakeLXDockerTask

func FakeLXDockerTask(taskId, taskName, slaveId, taskCommand string) *lxtypes.Task

func FakeLXTask

func FakeLXTask(taskId, taskName, slaveId, taskCommand string) *lxtypes.Task

func FakeMesosDockerTask

func FakeMesosDockerTask(taskId, taskName, slaveId, taskCommand string) *mesosproto.TaskInfo

func FakeMesosTask

func FakeMesosTask(taskId, taskName, slaveId, taskCommand string) *mesosproto.TaskInfo

func FakeNode

func FakeNode(resourceId string, nodeId string) *lxtypes.Node

func FakeOffer

func FakeOffer(offerId string, slaveId string) *mesosproto.Offer

func FakeResources

func FakeResources() []*mesosproto.Resource

func FakeTaskProvider

func FakeTaskProvider(tpid, source string) *lxtypes.TaskProvider

func FakeTaskStatus

func FakeTaskStatus(taskId string, fakeState mesosproto.TaskState) *mesosproto.TaskStatus

func RunFakeRpiServer

func RunFakeRpiServer(layerxUrl string, port int, driverErrc chan error)

func RunFakeTpiServer

func RunFakeTpiServer(layerxUrl string, port int, driverErrc chan error)

Types

type FakeCore

type FakeCore struct {
	TaskProviders map[string]*lxtypes.TaskProvider
	StatusUpdates map[string]*mesosproto.TaskStatus
	Tasks         map[string]*lxtypes.Task
	StagingTasks  map[string]*lxtypes.Task
	Nodes         map[string]*lxtypes.Node
}

func NewFakeCore

func NewFakeCore() *FakeCore

func (*FakeCore) Start

func (core *FakeCore) Start(fakeStatuses []*mesosproto.TaskStatus, port int)