MCPcopy Create free account

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

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

↓ 1 callersFunctionNewMesosApiServerWrapper
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager)
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:40
↓ 1 callersFunctionNewRpiApiServerWrapper
(rpi *layerx_rpi_client.LayerXRpi, masterAddr string, taskChan chan *lxtypes.Task, mesosSchedulerDriver schedu
layerx-mesos-rpi/layerx_rpi_api/layerx_rpi_server_wrapper.go:32
↓ 1 callersFunctionNewTaskLauncher
(state *lxstate.State)
layerx-core/task_launcher/task_launcher.go:23
↓ 1 callersFunctionNewTpiApiServerWrapper
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager)
layerx-mesos-tpi/layerx_tpi_api/layerx_tpi_server_wrapper.go:28
↓ 1 callersFunctionPurgeState
()
layerx-core/task_launcher/task_launcher_test.go:21
↓ 1 callersFunctionPurgeState
()
layerx-core/tpi_messenger/tpi_messenger_test.go:20
↓ 1 callersFunctionPurgeState
()
layerx-core/main_loop/main_loop_test.go:22
↓ 1 callersMethodRemoveResource
(resourceID string)
layerx-core/lxtypes/lxnode.go:89
↓ 1 callersFunctionSendKillTaskRequest
(rpiUrl string, taskId string)
layerx-core/rpi_messenger/rpi_messenger.go:47
↓ 1 callersFunctionSendLaunchTasksMessage
(rpiUrl string, tasksToLaunch []*lxtypes.Task, resourcesToUse []*lxtypes.Resource)
layerx-core/rpi_messenger/rpi_messenger.go:31
↓ 1 callersFunctionSendResourceCollectionRequest
(rpiUrl string)
layerx-core/rpi_messenger/rpi_messenger.go:18
↓ 1 callersFunctionSendStatusUpdate
(tpiUrl string, taskProvider *lxtypes.TaskProvider, status *mesosproto.TaskStatus)
layerx-core/tpi_messenger/tpi_messenger.go:38
↓ 1 callersFunctionSendTaskCollectionMessage
(tpiUrl string, taskProviders []*lxtypes.TaskProvider)
layerx-core/tpi_messenger/tpi_messenger.go:22
↓ 1 callersMethodToMasterInfo
()
layerx-mesos-tpi/mesos_master_api/mesos_data/mesos_state.go:149
↓ 1 callersMethodToResource
()
layerx-mesos-rpi/types/slave.go:68
↓ 1 callersFunctionUPIDFromString
Parse parses the UPID from the input string.
layerx-mesos-tpi/mesos_master_api/mesos_data/upid.go:18
↓ 1 callersFunctionaccepted
()
layerx-core/web/dragula.js:334
↓ 1 callersFunctionaddBehaviors
()
layerx-core/web/example/example.min.js:276
↓ 1 callersFunctionaddNodeTaskBehaviors
()
layerx-core/web/example/example.min.js:348
↓ 1 callersFunctionassignTask
(state *lxstate.State, nodeId, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_assign_tasks.go:20
↓ 1 callersFunctioncancel
(revert)
layerx-core/web/dragula.js:275
↓ 1 callersFunctionclearRpisAndResources
(state *lxstate.State)
layerx-core/main.go:93
↓ 1 callersFunctionconvertToPod
(task *lxtypes.Task, nodeName string)
layerx-k8s-rpi/kube/client.go:153
↓ 1 callersMethodconvertToServiceSpec
(task *lxtypes.Task, nodeName string)
layerx-swarm-rpi/swarm/client.go:150
↓ 1 callersFunctionconvertToStatus
(service swarm.Service, task swarm.Task)
layerx-swarm-rpi/swarm/client.go:244
↓ 1 callersFunctiondeploy_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:47
↓ 1 callersFunctiondestroy_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:63
↓ 1 callersFunctiondrag
(e)
layerx-core/web/dragula.js:350
↓ 1 callersFunctionend
()
layerx-core/web/dragula.js:215
↓ 1 callersFunctionfakeCollectResources
(layerXUrl string)
layerx-core/fakes/fake_rpi_server.go:116
↓ 1 callersFunctionfakeCollectTasks
(layerXUrl string, collectTasksMessage layerx_tpi_client.CollectTasksMessage)
layerx-core/fakes/fake_tpi_server.go:138
↓ 1 callersFunctionfakeKillTask
(layerXUrl string, taskId string)
layerx-core/fakes/fake_rpi_server.go:171
↓ 1 callersFunctionfakeLaunchTasks
(layerXUrl string, launchTaskMessage layerx_rpi_client.LaunchTasksMessage)
layerx-core/fakes/fake_rpi_server.go:143
↓ 1 callersFunctionfakeMesosResources
()
layerx-mesos-rpi/fakes/fake_objects.go:15
↓ 1 callersFunctionfakeMesosTask
(taskId string)
layerx-mesos-rpi/fakes/fake_objects.go:42
↓ 1 callersFunctionfakeUpdateTaskStatus
(updateTaskStatusMessage layerx_tpi_client.UpdateTaskStatusMessage)
layerx-core/fakes/fake_tpi_server.go:157
↓ 1 callersFunctionfind
(el, type, fn)
layerx-core/web/example/example.min.js:556
↓ 1 callersFunctiongen_node_infos
(cluster_yml)
vagrant/lib/gen_node_infos.rb:4
↓ 1 callersFunctiongetEventHost
(e)
layerx-core/web/dragula.js:577
↓ 1 callersFunctiongetFirstTaskState
()
layerx-k8s-rpi/kube/client_test.go:120
↓ 1 callersFunctiongetFirstTaskState
()
layerx-swarm-rpi/swarm/client_test.go:116
↓ 1 callersFunctiongetOffset
(el)
layerx-core/web/dragula.js:525
↓ 1 callersFunctiongetStatus
(pod v1.Pod)
layerx-k8s-rpi/kube/client.go:273
↓ 1 callersFunctionget_kubeconfig
conf
vagrant/lib/deploy_kubernetes.rb:5
↓ 1 callersFunctionget_swarm_config
conf
vagrant/lib/deploy_swarm.rb:6
↓ 1 callersFunctioninside
()
layerx-core/web/dragula.js:471
↓ 1 callersFunctionisCopy
(item, container)
layerx-core/web/dragula.js:484
↓ 1 callersFunctionisEditable
(el)
layerx-core/web/dragula.js:559
↓ 1 callersFunctionisTerminal
(status *mesosproto.TaskStatus)
layerx-core/lxserver/lx_core_helpers/handle_submit_status_update.go:67
↓ 1 callersFunctionmainLoop
()
example-brain/main.go:25
↓ 1 callersFunctionmakeClassicEvent
()
layerx-core/web/example/example.min.js:510
↓ 1 callersFunctionmakeCustomEvent
()
layerx-core/web/example/example.min.js:520
↓ 1 callersFunctionmanually
()
layerx-core/web/dragula.js:568
↓ 1 callersFunctionmigrateTask
(state *lxstate.State, nodeId, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_migrate_tasks.go:19
↓ 1 callersFunctionmigrateTask
(nodeId, taskId)
layerx-core/web/example/example.min.js:192
↓ 1 callersFunctionmoveTaskBetweenPools
(task *lxtypes.Task, sourceTaskPool, destinationTaskPool *lxstate.TaskPool)
layerx-core/lxserver/lx_core_helpers/handle_submit_status_update.go:55
↓ 1 callersFunctionnewPhonyOffer
(frameworkId string, offerId string, slaveId string)
layerx-mesos-tpi/framework_manager/task_collection_offer.go:13
↓ 1 callersFunctionnewPodKilledStatus
(task *lxtypes.Task)
layerx-k8s-rpi/main.go:172
↓ 1 callersFunctionnewPodKilledStatus
(task *lxtypes.Task)
layerx-swarm-rpi/main.go:156
↓ 1 callersFunctionout
()
layerx-core/web/dragula.js:405
↓ 1 callersFunctionoutside
()
layerx-core/web/dragula.js:457
↓ 1 callersFunctionover
()
layerx-core/web/dragula.js:404
↓ 1 callersFunctionoverlaps
(prList1, prList2 []PortRange)
layerx-core/lxtypes/lxresource.go:65
↓ 1 callersFunctionpickNode
(nodes []*lxtypes.Node, task *lxtypes.Task)
example-brain/main.go:70
↓ 1 callersFunctionprepareFrameworkInfo
(layerxUrl, user string)
layerx-mesos-rpi/main.go:114
↓ 1 callersFunctionprepareStaticOptions
(options []martini.StaticOptions)
layerx-core/bindata/handler.go:96
↓ 1 callersMethodprocessAcceptCall
(frameworkId string, accept *mesosscheduler.Call_Accept)
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:453
↓ 1 callersMethodprocessMesosCall
(data []byte, upid *mesos_data.UPID)
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:387
↓ 1 callersFunctionpurgeState
()
layerx-core/main.go:19
↓ 1 callersFunctionrefreshNodes
()
layerx-core/web/example/example.min.js:130
↓ 1 callersFunctionrefreshPendingTasks
()
layerx-core/web/example/example.min.js:82
↓ 1 callersFunctionrefreshStagingTasks
()
layerx-core/web/example/example.min.js:106
↓ 1 callersFunctionrefreshTaskStatuses
()
layerx-core/web/example/example.min.js:39
↓ 1 callersFunctionreload_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:68
↓ 1 callersFunctionreload_kubernetes
conf
vagrant/lib/deploy_kubernetes.rb:52
↓ 1 callersFunctionremove
()
layerx-core/web/dragula.js:262
↓ 1 callersFunctionremoveMirrorImage
()
layerx-core/web/dragula.js:432
↓ 1 callersFunctionrenderMirrorImage
()
layerx-core/web/dragula.js:416
↓ 1 callersFunctions
(o,u)
layerx-core/web/example/example.min.js:1
↓ 1 callersMethodsaveNode
(node *lxtypes.Node)
layerx-core/lxstate/node_pool.go:99
↓ 1 callersFunctionscheduleOnce
()
example-brain/main.go:34
↓ 1 callersFunctionsendFakeTaskOnOffer
(taskNo int, offer *mesosproto.Offer, masterUpid *mesos_data.UPID, port int)
layerx-mesos-tpi/fakes/fake_framework_server.go:111
↓ 1 callersFunctionsetUp
()
layerx-k8s-rpi/kube/client_test.go:131
↓ 1 callersFunctionsetUp
()
layerx-swarm-rpi/swarm/client_test.go:127
↓ 1 callersFunctionsingleExeuction
(state *lxstate.State, taskLauncher *task_launcher.TaskLauncher, healthChecker *health_checker.HealthChecker)
layerx-core/main_loop/main_loop.go:30
↓ 1 callersFunctionstatusUpdatesForever
(core *layerx_rpi_client.LayerXRpi, kubeClient *kube.Client)
layerx-k8s-rpi/main.go:110
↓ 1 callersFunctionstatusUpdatesForever
(core *layerx_rpi_client.LayerXRpi, client *swarm.Client)
layerx-swarm-rpi/main.go:94
↓ 1 callersFunctionstatus_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:73
↓ 1 callersFunctionstop_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:58
↓ 1 callersMethodsubtractRange
(pr2 PortRange)
layerx-core/lxtypes/lxresource.go:29
↓ 1 callersFunctiontearDown
()
layerx-k8s-rpi/kube/client_test.go:157
↓ 1 callersFunctionupdatesForKilledTasks
(core *layerx_rpi_client.LayerXRpi, notKilledStatuses []*mesosproto.TaskStatus, ownedResources []*lxtypes.Reso
layerx-k8s-rpi/main.go:139
↓ 1 callersFunctionupdatesForKilledTasks
(core *layerx_rpi_client.LayerXRpi, notKilledStatuses []*mesosproto.TaskStatus, ownedResources []*lxtypes.Reso
layerx-swarm-rpi/main.go:123
↓ 1 callersFunctionuseNative
()
layerx-core/web/example/example.min.js:409
↓ 1 callersMethodwaitPodCreate
(name string)
layerx-k8s-rpi/kube/client.go:298
↓ 1 callersMethodwaitPodDelete
(name string)
layerx-k8s-rpi/kube/client.go:308
↓ 1 callersFunctionwrap
(el, type, fn)
layerx-core/web/example/example.min.js:536
↓ 1 callersFunctionwrapperFactory
(el, type, fn)
layerx-core/web/example/example.min.js:525
FunctionAssignTasks
(state *lxstate.State, assignTasksMessage layerx_brain_client.BrainAssignTasksMessage)
layerx-core/lxserver/lx_core_helpers/handle_assign_tasks.go:10
FunctionCollectResources
(core *layerx_rpi_client.LayerXRpi, masterAddr string)
layerx-mesos-rpi/layerx_rpi_api/rpi_api_helpers/handle_collect_resources.go:11
← previousnext →201–300 of 437, ranked by callers