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
↓ 4 callersFunctiongenerateTaskStatus
(taskId string, taskState mesosproto.TaskState, message string)
layerx-core/lxserver/lx_core_helpers/handle_get_status_update.go:28
↓ 4 callersFunctionstartRefresh
()
layerx-core/web/example/example.min.js:30
↓ 3 callersMethodDeleteRpi
(name string)
layerx-core/lxstate/rpi_pool.go:71
↓ 3 callersFunctionFakeMesosTask
(taskId string)
layerx-mesos-tpi/fakes/fake_proto_objects.go:90
↓ 3 callersMethodGetRpiUrls
plural
layerx-core/lxstate/state.go:273
↓ 3 callersMethodGetStagingTasks
call this method to see unassigned tasks
layerx-core/layerx_brain_client/layerx_brain_client.go:46
↓ 3 callersMethodGetTpi
()
layerx-core/lxstate/state.go:84
↓ 3 callersMethodInit
()
layerx-k8s-rpi/kube/client.go:37
↓ 3 callersMethodMigrateTasks
call this method to migrate running tasks from one node to another
layerx-core/layerx_brain_client/layerx_brain_client.go:123
↓ 3 callersMethodModifyResource
(resourceId string, modifiedResource *lxtypes.Resource)
layerx-core/lxstate/resource_pool.go:67
↓ 3 callersMethodModifyStatus
(statusId string, modifiedStatus *mesosproto.TaskStatus)
layerx-core/lxstate/status_pool.go:56
↓ 3 callersFunctionPollWait
(waitFunc func() bool)
layerx-k8s-rpi/kube/client.go:318
↓ 3 callersMethodRemoveTask
(taskId string)
layerx-core/lxtypes/lxnode.go:97
↓ 3 callersMethodSendTaskCollectionOffer
(frameworkId, phonyOfferId, phonySlaveId, phonySlavePid string, frameworkUpid *mesos_data.UPID)
layerx-mesos-tpi/framework_manager/framework_manager.go:21
↓ 3 callersMethodWrapWithMesos
(m *martini.ClassicMartini, masterUpidString string, driverErrc chan error)
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:47
↓ 3 callersFunctioncleanup
()
layerx-core/web/dragula.js:297
↓ 3 callersFunctioncontains
(a, obj)
layerx-core/web/example/example.min.js:267
↓ 3 callersFunctioncontainsString
(strArray []string, target string)
layerx-core/lxstate/state.go:290
↓ 3 callersFunctioneventualMovements
(remove)
layerx-core/web/dragula.js:72
↓ 3 callersFunctiongetResourceScalar
(resources []*mesosproto.Resource, name string)
layerx-core/lxtypes/lxresource_test.go:41
↓ 3 callersFunctionhandle
(res http.ResponseWriter, action func() (interface{}, int, error))
layerx-k8s-rpi/server/server.go:78
↓ 3 callersFunctionhandle
(res http.ResponseWriter, action func() (interface{}, int, error))
layerx-swarm-rpi/server/server.go:78
↓ 3 callersFunctionin_path?
(cmd)
vagrant/lib/helpers.rb:11
↓ 3 callersFunctionisContainer
(el)
layerx-core/web/dragula.js:62
↓ 3 callersFunctionisInitialPlacement
(target, s)
layerx-core/web/dragula.js:315
↓ 3 callersMethodqueueOperation
(f func() ([]byte, int, error))
layerx-mesos-tpi/layerx_tpi_api/layerx_tpi_server_wrapper.go:152
↓ 3 callersMethodqueueOperation
(f func() ([]byte, int, error))
layerx-mesos-rpi/layerx_rpi_api/layerx_rpi_server_wrapper.go:127
↓ 3 callersMethodsendMessage
(destination *mesos_data.UPID, message proto.Message, path string)
layerx-mesos-tpi/framework_manager/framework_manager.go:138
↓ 2 callersMethodDeleteNode
(nodeId string)
layerx-core/lxstate/node_pool.go:68
↓ 2 callersMethodDeleteStatus
(statusId string)
layerx-core/lxstate/status_pool.go:90
↓ 2 callersMethodExpireTimedOutTaskProviders
()
layerx-core/health_checker/task_provider_health_checker.go:55
↓ 2 callersMethodGetDriver
()
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:15
↓ 2 callersMethodGetRpiName
()
layerx-core/lxtypes/lxnode.go:50
↓ 2 callersMethodGetStatusUpdatesForTaskProvider
(tpId string)
layerx-core/lxstate/state.go:129
↓ 2 callersMethodGetTaskProvider
call this method to retrieve a specific task provider for the id
layerx-core/layerx_tpi_client/layerx_tpi.go:73
↓ 2 callersFunctionHealthCheck
(tpiUrl string, taskProvider *lxtypes.TaskProvider)
layerx-core/tpi_messenger/tpi_messenger.go:54
↓ 2 callersMethodLaunchStagedTasks
()
layerx-core/task_launcher/task_launcher.go:30
↓ 2 callersMethodModifyTask
(task *Task)
layerx-core/lxtypes/lxnode.go:81
↓ 2 callersMethodNotifyFrameworkRegistered
(frameworkName, frameworkId string, frameworkUpid *mesos_data.UPID)
layerx-mesos-tpi/framework_manager/framework_manager.go:19
↓ 2 callersFunctionProcessStatusUpdate
(state *lxstate.State, tpiUrl string, status *mesosproto.TaskStatus)
layerx-core/lxserver/lx_core_helpers/handle_submit_status_update.go:12
↓ 2 callersFunctionPurgeState
()
layerx-core/lxserver/lx_core_helpers/handle_submit_status_update_test.go:20
↓ 2 callersFunctionPurgeState
()
layerx-core/rpi_messenger/rpi_messenger_test.go:19
↓ 2 callersMethodRescindResource
call this method if a resource has been rescinded or is no longer valid / available
layerx-core/layerx_rpi_client/layerx_rpi.go:60
↓ 2 callersMethodWrapWithRpi
(m *martini.ClassicMartini, driverErrc chan error)
layerx-mesos-rpi/layerx_rpi_api/layerx_rpi_server_wrapper.go:41
↓ 2 callersMethodWrapWithTpi
(m *martini.ClassicMartini, masterUpidString string, driverErrc chan error)
layerx-mesos-tpi/layerx_tpi_api/layerx_tpi_server_wrapper.go:35
↓ 2 callersFunctionaddResourceToNode
(resourcePool *lxstate.ResourcePool, resource *lxtypes.Resource)
layerx-core/lxserver/lx_core_helpers/handle_submit_resource.go:29
↓ 2 callersFunctionassignTask
(nodeId, taskId)
layerx-core/web/example/example.min.js:180
↓ 2 callersFunctioncanStart
(item)
layerx-core/web/dragula.js:154
↓ 2 callersFunctiondeploy_kubernetes
conf
vagrant/lib/deploy_kubernetes.rb:36
↓ 2 callersMethoddestroyFailedTaskProvider
(taskProvider *lxtypes.TaskProvider)
layerx-core/health_checker/task_provider_health_checker.go:73
↓ 2 callersFunctiondragula
(initialContainers, options)
layerx-core/web/dragula.js:10
↓ 2 callersFunctiondrop
(item, target)
layerx-core/web/dragula.js:249
↓ 2 callersFunctionevents
(remove)
layerx-core/web/dragula.js:66
↓ 2 callersFunctionfakeMesosResources
()
layerx-core/fakes/fake_lx_task.go:60
↓ 2 callersFunctionfindDropTarget
(elementBehindCursor, clientX, clientY)
layerx-core/web/dragula.js:327
↓ 2 callersFunctiongetElementBehindPoint
(point, x, y)
layerx-core/web/dragula.js:543
↓ 2 callersFunctiongetImmediateChild
(dropTarget, target)
layerx-core/web/dragula.js:441
↓ 2 callersFunctiongetRectHeight
(rect)
layerx-core/web/dragula.js:556
↓ 2 callersFunctiongetRectWidth
(rect)
layerx-core/web/dragula.js:555
↓ 2 callersFunctiongetReference
(dropTarget, target, x, y)
layerx-core/web/dragula.js:452
↓ 2 callersFunctiongetScroll
(scrollProp, offsetProp)
layerx-core/web/dragula.js:533
↓ 2 callersFunctionisInput
(el)
layerx-core/web/dragula.js:558
↓ 2 callersMethodloadNode
(nodeId string)
layerx-core/lxstate/node_pool.go:129
↓ 2 callersFunctionlookupClass
(className)
layerx-core/web/classes.js:7
↓ 2 callersFunctionmoved
(type)
layerx-core/web/dragula.js:403
↓ 2 callersFunctionmovements
(remove)
layerx-core/web/dragula.js:77
↓ 2 callersMethodoverlaps
(pr2 PortRange)
layerx-core/lxtypes/lxresource.go:52
↓ 2 callersMethodoverlapsAny
(prList []PortRange)
layerx-core/lxtypes/lxresource.go:56
↓ 2 callersFunctionparsePortsString
(portString string)
layerx-mesos-rpi/types/slave.go:88
↓ 2 callersFunctionrelease
(e)
layerx-core/web/dragula.js:229
↓ 2 callersFunctionresolve
(after)
layerx-core/web/dragula.js:479
↓ 2 callersFunctionrespond
(res http.ResponseWriter, message interface{})
layerx-k8s-rpi/server/server.go:96
↓ 2 callersFunctionrespond
(res http.ResponseWriter, message interface{})
layerx-swarm-rpi/server/server.go:96
↓ 2 callersFunctionsendTaskKilledStatus
(state *lxstate.State, taskState mesosproto.TaskState, tpiUrl, taskProviderId, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_kill_task.go:66
↓ 2 callersFunctionsortRanges
(prlist []PortRange)
layerx-core/lxtypes/lxresource.go:25
↓ 2 callersFunctionstart
(context)
layerx-core/web/dragula.js:197
↓ 2 callersFunctionungrab
()
layerx-core/web/dragula.js:223
↓ 2 callersFunctionunwrap
(el, type, fn)
layerx-core/web/example/example.min.js:547
↓ 2 callersFunctionwhichMouseButton
(e)
layerx-core/web/dragula.js:515
↓ 1 callersFunctionFakeLXTask
(taskId, taskName, slaveId, taskCommand string)
layerx-core/fakes/fake_lx_task.go:9
↓ 1 callersFunctionFakeMesosDockerTask
(taskId, taskName, slaveId, taskCommand string)
layerx-core/fakes/fake_lx_task.go:36
↓ 1 callersFunctionFakeMesosTask
(taskId, taskName, slaveId, taskCommand string)
layerx-core/fakes/fake_lx_task.go:14
↓ 1 callersFunctionFakeResources
()
layerx-core/fakes/fake_mesos_offer.go:24
↓ 1 callersFunctionFakeResources
()
layerx-mesos-tpi/fakes/fake_proto_objects.go:108
↓ 1 callersFunctionFakeTaskStatus
(taskId string, fakeState mesosproto.TaskState)
layerx-core/fakes/fake_mesos_status.go:8
↓ 1 callersMethodFlushResources
()
layerx-core/lxtypes/lxnode.go:57
↓ 1 callersMethodGetFreePorts
()
layerx-core/lxtypes/lxnode.go:167
↓ 1 callersMethodGetNodes
call this method to see submitted nodes and their resources + tasks call this to see tasks that the specific RPI should care about. useful for knowing
layerx-core/layerx_rpi_client/layerx_rpi.go:92
↓ 1 callersMethodGetResourcePoolContainingResource
(resourceID string)
layerx-core/lxstate/state.go:196
↓ 1 callersMethodGetStatusUpdates
call this method to retrieve a list of the most recent status updates for tasks from the specified task provider
layerx-core/layerx_tpi_client/layerx_tpi.go:109
↓ 1 callersMethodGetStatusUpdates
call this method to see most recent status updates for all tasks
layerx-core/layerx_brain_client/layerx_brain_client.go:87
↓ 1 callersFunctionHandleResourceOffers
(lxRpi *layerx_rpi_client.LayerXRpi, offers []*mesosproto.Offer)
layerx-mesos-rpi/mesos_framework_api/framework_api_handlers/handle_resource_offers.go:10
↓ 1 callersMethodHealthCheckFramework
(frameworkId string, frameworkUpid *mesos_data.UPID)
layerx-mesos-tpi/framework_manager/framework_manager.go:22
↓ 1 callersMethodInitialize
()
layerx-core/lxstate/task_pool.go:18
↓ 1 callersMethodInitialize
()
layerx-core/lxstate/resource_pool.go:26
↓ 1 callersFunctionKillTask
(state *lxstate.State, tpiUrl, taskProviderId, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_kill_task.go:12
↓ 1 callersFunctionMainLoop
run as goroutine
layerx-core/main_loop/main_loop.go:20
↓ 1 callersFunctionNewClient
(kubeClient *kubernetes.Clientset)
layerx-k8s-rpi/kube/client.go:31
↓ 1 callersFunctionNewClient
(rpiName string)
layerx-swarm-rpi/swarm/client.go:28
↓ 1 callersFunctionNewLayerXCoreServerWrapper
(state *lxstate.State, m *martini.ClassicMartini, driverErrc chan error)
layerx-core/lxserver/lxserver.go:53
← previousnext →101–200 of 437, ranked by callers