MCPcopy Create free account

hub / github.com/emc-advanced-dev/layerx / functions

Functions437 in github.com/emc-advanced-dev/layerx

⨍ Functions 437◇ Types & classes 43
↓ 135 callersMethodInitializeState
(etcdUrl string)
layerx-core/lxstate/state.go:60
↓ 99 callersMethodString
String returns the string representation.
layerx-mesos-tpi/mesos_master_api/mesos_data/upid.go:36
↓ 78 callersMethodError
(driver scheduler.SchedulerDriver, err string)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:142
↓ 74 callersMethodString
()
layerx-core/lxtypes/lxnode.go:14
↓ 65 callersMethodAddTask
(task *lxtypes.Task)
layerx-core/lxstate/task_pool.go:26
↓ 52 callersFunctionNewState
()
layerx-core/lxstate/state.go:34
↓ 52 callersFunctionPurgeState
()
layerx-core/lxstate/state_test.go:13
↓ 36 callersMethodSubmitResource
call this method when submitting a new resource from the rpi
layerx-core/layerx_rpi_client/layerx_rpi.go:45
↓ 34 callersMethodRegisterTaskProvider
call this method when registering a new task provider to the tpi
layerx-core/layerx_tpi_client/layerx_tpi.go:45
↓ 31 callersMethodAddStatus
(status *mesosproto.TaskStatus)
layerx-core/lxstate/status_pool.go:26
↓ 29 callersMethodAddRpi
(rpi *layerx_rpi_client.RpiInfo)
layerx-core/lxstate/rpi_pool.go:26
↓ 29 callersMethodAddTask
(task *Task)
layerx-core/lxtypes/lxnode.go:61
↓ 26 callersMethodGetTasks
()
layerx-core/lxtypes/lxnode.go:73
↓ 24 callersMethodAddTaskProvider
(taskProvider *lxtypes.TaskProvider)
layerx-core/lxstate/task_provider_pool.go:26
↓ 24 callersFunctionPurgeState
()
layerx-core/lxserver/lxserver_test.go:21
↓ 22 callersMethodSubmitTask
call this method to submit a requested task to layer-x
layerx-core/layerx_tpi_client/layerx_tpi.go:147
↓ 21 callersMethodSetTpi
(tpiUrl string)
layerx-core/lxstate/state.go:76
↓ 20 callersMethodGetKey
()
layerx-core/lxstate/rpi_pool.go:14
↓ 19 callersMethodAddResource
(resource *Resource)
layerx-core/lxtypes/lxnode.go:27
↓ 18 callersMethodAddResource
(resource *lxtypes.Resource)
layerx-core/lxstate/resource_pool.go:34
↓ 18 callersMethodGetResources
()
layerx-core/lxtypes/lxnode.go:42
↓ 18 callersMethoddoOperation
(f func() ([]byte, int, error))
layerx-core/lxserver/lxserver.go:657
↓ 17 callersMethodAddNode
(node *lxtypes.Node)
layerx-core/lxstate/node_pool.go:26
↓ 17 callersMethodGetNode
(nodeId string)
layerx-core/lxstate/node_pool.go:39
↓ 17 callersMethodGetTask
(taskId string)
layerx-core/lxstate/task_pool.go:46
↓ 17 callersMethodGetTasks
()
layerx-core/lxstate/task_pool.go:76
↓ 16 callersFunction$
(id)
layerx-core/web/example/example.min.js:259
↓ 16 callersMethodGetKey
()
layerx-core/lxstate/node_pool.go:14
↓ 16 callersMethodGetNodeTaskPool
(nodeId string)
layerx-core/lxstate/node_pool.go:90
↓ 16 callersFunctionNewNode
(nodeId string)
layerx-core/lxtypes/lxnode.go:19
↓ 15 callersFunctionNewTaskFromMesos
(taskInfo *mesosproto.TaskInfo)
layerx-core/lxtypes/lxtask.go:158
↓ 14 callersFunctiongetParent
(el)
layerx-core/web/dragula.js:557
↓ 13 callersMethodGetTask
(taskId string)
layerx-core/lxtypes/lxnode.go:69
↓ 13 callersMethodGetTaskProviders
call this method to retrieve a list of registered task providers. e.g. before polling task providers for pending tasks
layerx-core/layerx_tpi_client/layerx_tpi.go:89
↓ 12 callersMethodGetNodes
()
layerx-core/lxstate/node_pool.go:51
↓ 11 callersMethodStart
(fakeStatuses []*mesosproto.TaskStatus, port int)
layerx-core/fakes/fake_lx_server.go:65
↓ 10 callersMethodqueueOperation
(f func() ([]byte, int, error))
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:374
↓ 9 callersMethodDeleteTask
(taskId string)
layerx-core/lxstate/task_pool.go:93
↓ 9 callersMethodGetStatus
(statusId string)
layerx-core/lxstate/status_pool.go:43
↓ 9 callersFunctionTempResourcePoolFunction
(rootKey, nodeId string)
layerx-core/lxstate/resource_pool.go:15
↓ 8 callersMethodGetTaskPoolContainingTask
(taskId string)
layerx-core/lxstate/state.go:215
↓ 8 callersFunctionNewResourceFromMesos
(offer *mesosproto.Offer)
layerx-core/lxtypes/lxresource.go:129
↓ 8 callersMethodWrapServer
()
layerx-core/lxserver/lxserver.go:61
↓ 8 callersFunctionfakeLXRpi
(name, url string)
layerx-core/lxstate/rpi_pool_test.go:13
↓ 8 callersFunctiongetCoord
(coord, e)
layerx-core/web/dragula.js:590
↓ 7 callersMethodAssignTasks
call this method to assign tasks to a node
layerx-core/layerx_brain_client/layerx_brain_client.go:106
↓ 7 callersMethodDeregisterTaskProvider
call this method when a non-failover task provider disconnects from the tpi
layerx-core/layerx_tpi_client/layerx_tpi.go:59
↓ 7 callersMethodGetKey
()
layerx-core/lxstate/task_pool.go:14
↓ 7 callersMethodGetKey
()
layerx-core/lxstate/resource_pool.go:22
↓ 7 callersMethodGetKey
()
layerx-core/lxstate/status_pool.go:14
↓ 7 callersMethodGetNodeResourcePool
(nodeId string)
layerx-core/lxstate/node_pool.go:80
↓ 7 callersMethodGetResource
(resourceId string)
layerx-core/lxtypes/lxnode.go:38
↓ 7 callersMethodGetStatusUpdate
call this method to retrieve a specific status for a specific task
layerx-core/layerx_tpi_client/layerx_tpi.go:128
↓ 7 callersMethodGetTaskProvider
(taskProviderId string)
layerx-core/lxstate/task_provider_pool.go:39
↓ 7 callersMethodGetTaskProviders
()
layerx-core/lxstate/task_provider_pool.go:52
↓ 7 callersMethodInitialize
()
layerx-core/lxstate/rpi_pool.go:18
↓ 7 callersMethodSubmitStatusUpdate
call this method when submitting a status update from the rpi
layerx-core/layerx_rpi_client/layerx_rpi.go:74
↓ 6 callersMethodFetchResources
()
layerx-k8s-rpi/kube/client.go:63
↓ 6 callersMethodFetchResources
()
layerx-swarm-rpi/swarm/client.go:46
↓ 6 callersMethodGetKey
()
layerx-core/lxstate/task_provider_pool.go:14
↓ 6 callersMethodGetPendingTasks
call this method to see unassigned tasks
layerx-core/layerx_brain_client/layerx_brain_client.go:26
↓ 6 callersMethodGetResource
(resourceId string)
layerx-core/lxstate/resource_pool.go:54
↓ 6 callersMethodGetRpi
(name string)
layerx-core/lxstate/rpi_pool.go:41
↓ 6 callersMethodGetStatuses
()
layerx-k8s-rpi/kube/client.go:139
↓ 6 callersMethodKillTask
(taskID string)
layerx-k8s-rpi/kube/client.go:128
↓ 6 callersMethodLaunchTasks
(launchTasksMessage layerx_rpi_client.LaunchTasksMessage)
layerx-k8s-rpi/kube/client.go:100
↓ 6 callersFunctionPurgeFakeServer
(fakeLxUrl string)
layerx-core/layerx_brain_client/layerx_brain_client_test.go:18
↓ 6 callersMethodRegisterRpi
call this method to register the RPI with layerx
layerx-core/layerx_rpi_client/layerx_rpi.go:27
↓ 6 callersFunctiongetEls
(classname)
layerx-core/web/example/example.min.js:263
↓ 6 callersFunctiongetResourceScalar
(resources []*mesosproto.Resource, name string)
layerx-core/lxtypes/lxtask.go:216
↓ 5 callersMethodDeleteResource
(resourceId string)
layerx-core/lxstate/resource_pool.go:101
↓ 5 callersMethodDeleteTaskProvider
(taskProviderId string)
layerx-core/lxstate/task_provider_pool.go:69
↓ 5 callersMethodFailDisconnectedTaskProviders
()
layerx-core/health_checker/task_provider_health_checker.go:23
↓ 5 callersMethodGetAllTasks
()
layerx-core/lxstate/state.go:92
↓ 5 callersMethodGetRpis
()
layerx-core/lxstate/rpi_pool.go:54
↓ 5 callersMethodGetStatusUpdates
()
layerx-core/lxstate/state.go:161
↓ 5 callersMethodGetTpiUrl
singluar (for now)
layerx-core/lxstate/state.go:258
↓ 5 callersMethodKillTask
call this method to submit a requested task to layer-x
layerx-core/layerx_tpi_client/layerx_tpi.go:161
↓ 5 callersMethodKillTask
(taskID string)
layerx-swarm-rpi/swarm/client.go:104
↓ 5 callersMethodSendStatusUpdate
(frameworkId string, frameworkUpid *mesos_data.UPID, status *mesosproto.TaskStatus)
layerx-mesos-tpi/framework_manager/framework_manager.go:20
↓ 5 callersFunctionnextEl
(el)
layerx-core/web/dragula.js:566
↓ 5 callersFunctiontouchy
(el, op, type, fn)
layerx-core/web/dragula.js:489
↓ 4 callersFunctionFakeFramework
()
layerx-mesos-tpi/fakes/fake_proto_objects.go:8
↓ 4 callersFunctionFakeOffer
(offerId string, slaveId string)
layerx-core/fakes/fake_mesos_offer.go:8
↓ 4 callersMethodGetFreeCpus
()
layerx-core/lxtypes/lxnode.go:143
↓ 4 callersMethodGetFreeDisk
()
layerx-core/lxtypes/lxnode.go:159
↓ 4 callersMethodGetFreeMem
()
layerx-core/lxtypes/lxnode.go:151
↓ 4 callersMethodGetNodes
call this method to see submitted nodes and their resources
layerx-core/layerx_brain_client/layerx_brain_client.go:67
↓ 4 callersMethodGetResources
()
layerx-core/lxstate/resource_pool.go:84
↓ 4 callersMethodGetStatuses
()
layerx-core/lxstate/status_pool.go:73
↓ 4 callersMethodGetStatuses
()
layerx-swarm-rpi/swarm/client.go:122
↓ 4 callersMethodGetTaskFromAnywhere
(taskId string)
layerx-core/lxstate/state.go:183
↓ 4 callersMethodLaunchTasks
(launchTasksMessage layerx_rpi_client.LaunchTasksMessage)
layerx-swarm-rpi/swarm/client.go:80
↓ 4 callersMethodModifyTask
(taskId string, modifiedTask *lxtypes.Task)
layerx-core/lxstate/task_pool.go:59
↓ 4 callersFunctionNewFrameworkManager
(masterUpid *mesos_data.UPID)
layerx-mesos-tpi/framework_manager/framework_manager.go:29
↓ 4 callersFunctionNewHealthChecker
(state *lxstate.State)
layerx-core/health_checker/task_provider_health_checker.go:17
↓ 4 callersFunctionPurgeState
()
layerx-core/health_checker/task_provider_health_checker_test.go:21
↓ 4 callersMethodPurgeTask
call this method to purge a requested task from layer-x
layerx-core/layerx_tpi_client/layerx_tpi.go:175
↓ 4 callersMethodRegisterTpi
call this method to register the TPI with layerx
layerx-core/layerx_tpi_client/layerx_tpi.go:30
↓ 4 callersMethodToMesos
()
layerx-core/lxtypes/lxtask.go:49
next →1–100 of 437, ranked by callers