fakes

package

v0.0.0-...-c76ca94 Latest Latest Go to latest Published: Feb 2, 2017 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/emc-advanced-dev/layerx

Links

Open Source Insights

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 ¶

View Source

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"
)

View Source

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

View Source

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

	FAIL_ON_PURPOSE = "failonpurpose"
)

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

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