Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/emc-advanced-dev/layerx
/ functions
Functions
437 in github.com/emc-advanced-dev/layerx
⨍
Functions
437
◇
Types & classes
43
↓ 1 callers
Function
NewMesosApiServerWrapper
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager)
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:40
↓ 1 callers
Function
NewRpiApiServerWrapper
(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 callers
Function
NewTaskLauncher
(state *lxstate.State)
layerx-core/task_launcher/task_launcher.go:23
↓ 1 callers
Function
NewTpiApiServerWrapper
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager)
layerx-mesos-tpi/layerx_tpi_api/layerx_tpi_server_wrapper.go:28
↓ 1 callers
Function
PurgeState
()
layerx-core/task_launcher/task_launcher_test.go:21
↓ 1 callers
Function
PurgeState
()
layerx-core/tpi_messenger/tpi_messenger_test.go:20
↓ 1 callers
Function
PurgeState
()
layerx-core/main_loop/main_loop_test.go:22
↓ 1 callers
Method
RemoveResource
(resourceID string)
layerx-core/lxtypes/lxnode.go:89
↓ 1 callers
Function
SendKillTaskRequest
(rpiUrl string, taskId string)
layerx-core/rpi_messenger/rpi_messenger.go:47
↓ 1 callers
Function
SendLaunchTasksMessage
(rpiUrl string, tasksToLaunch []*lxtypes.Task, resourcesToUse []*lxtypes.Resource)
layerx-core/rpi_messenger/rpi_messenger.go:31
↓ 1 callers
Function
SendResourceCollectionRequest
(rpiUrl string)
layerx-core/rpi_messenger/rpi_messenger.go:18
↓ 1 callers
Function
SendStatusUpdate
(tpiUrl string, taskProvider *lxtypes.TaskProvider, status *mesosproto.TaskStatus)
layerx-core/tpi_messenger/tpi_messenger.go:38
↓ 1 callers
Function
SendTaskCollectionMessage
(tpiUrl string, taskProviders []*lxtypes.TaskProvider)
layerx-core/tpi_messenger/tpi_messenger.go:22
↓ 1 callers
Method
ToMasterInfo
()
layerx-mesos-tpi/mesos_master_api/mesos_data/mesos_state.go:149
↓ 1 callers
Method
ToResource
()
layerx-mesos-rpi/types/slave.go:68
↓ 1 callers
Function
UPIDFromString
Parse parses the UPID from the input string.
layerx-mesos-tpi/mesos_master_api/mesos_data/upid.go:18
↓ 1 callers
Function
accepted
()
layerx-core/web/dragula.js:334
↓ 1 callers
Function
addBehaviors
()
layerx-core/web/example/example.min.js:276
↓ 1 callers
Function
addNodeTaskBehaviors
()
layerx-core/web/example/example.min.js:348
↓ 1 callers
Function
assignTask
(state *lxstate.State, nodeId, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_assign_tasks.go:20
↓ 1 callers
Function
cancel
(revert)
layerx-core/web/dragula.js:275
↓ 1 callers
Function
clearRpisAndResources
(state *lxstate.State)
layerx-core/main.go:93
↓ 1 callers
Function
convertToPod
(task *lxtypes.Task, nodeName string)
layerx-k8s-rpi/kube/client.go:153
↓ 1 callers
Method
convertToServiceSpec
(task *lxtypes.Task, nodeName string)
layerx-swarm-rpi/swarm/client.go:150
↓ 1 callers
Function
convertToStatus
(service swarm.Service, task swarm.Task)
layerx-swarm-rpi/swarm/client.go:244
↓ 1 callers
Function
deploy_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:47
↓ 1 callers
Function
destroy_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:63
↓ 1 callers
Function
drag
(e)
layerx-core/web/dragula.js:350
↓ 1 callers
Function
end
()
layerx-core/web/dragula.js:215
↓ 1 callers
Function
fakeCollectResources
(layerXUrl string)
layerx-core/fakes/fake_rpi_server.go:116
↓ 1 callers
Function
fakeCollectTasks
(layerXUrl string, collectTasksMessage layerx_tpi_client.CollectTasksMessage)
layerx-core/fakes/fake_tpi_server.go:138
↓ 1 callers
Function
fakeKillTask
(layerXUrl string, taskId string)
layerx-core/fakes/fake_rpi_server.go:171
↓ 1 callers
Function
fakeLaunchTasks
(layerXUrl string, launchTaskMessage layerx_rpi_client.LaunchTasksMessage)
layerx-core/fakes/fake_rpi_server.go:143
↓ 1 callers
Function
fakeMesosResources
()
layerx-mesos-rpi/fakes/fake_objects.go:15
↓ 1 callers
Function
fakeMesosTask
(taskId string)
layerx-mesos-rpi/fakes/fake_objects.go:42
↓ 1 callers
Function
fakeUpdateTaskStatus
(updateTaskStatusMessage layerx_tpi_client.UpdateTaskStatusMessage)
layerx-core/fakes/fake_tpi_server.go:157
↓ 1 callers
Function
find
(el, type, fn)
layerx-core/web/example/example.min.js:556
↓ 1 callers
Function
gen_node_infos
(cluster_yml)
vagrant/lib/gen_node_infos.rb:4
↓ 1 callers
Function
getEventHost
(e)
layerx-core/web/dragula.js:577
↓ 1 callers
Function
getFirstTaskState
()
layerx-k8s-rpi/kube/client_test.go:120
↓ 1 callers
Function
getFirstTaskState
()
layerx-swarm-rpi/swarm/client_test.go:116
↓ 1 callers
Function
getOffset
(el)
layerx-core/web/dragula.js:525
↓ 1 callers
Function
getStatus
(pod v1.Pod)
layerx-k8s-rpi/kube/client.go:273
↓ 1 callers
Function
get_kubeconfig
conf
vagrant/lib/deploy_kubernetes.rb:5
↓ 1 callers
Function
get_swarm_config
conf
vagrant/lib/deploy_swarm.rb:6
↓ 1 callers
Function
inside
()
layerx-core/web/dragula.js:471
↓ 1 callers
Function
isCopy
(item, container)
layerx-core/web/dragula.js:484
↓ 1 callers
Function
isEditable
(el)
layerx-core/web/dragula.js:559
↓ 1 callers
Function
isTerminal
(status *mesosproto.TaskStatus)
layerx-core/lxserver/lx_core_helpers/handle_submit_status_update.go:67
↓ 1 callers
Function
mainLoop
()
example-brain/main.go:25
↓ 1 callers
Function
makeClassicEvent
()
layerx-core/web/example/example.min.js:510
↓ 1 callers
Function
makeCustomEvent
()
layerx-core/web/example/example.min.js:520
↓ 1 callers
Function
manually
()
layerx-core/web/dragula.js:568
↓ 1 callers
Function
migrateTask
(state *lxstate.State, nodeId, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_migrate_tasks.go:19
↓ 1 callers
Function
migrateTask
(nodeId, taskId)
layerx-core/web/example/example.min.js:192
↓ 1 callers
Function
moveTaskBetweenPools
(task *lxtypes.Task, sourceTaskPool, destinationTaskPool *lxstate.TaskPool)
layerx-core/lxserver/lx_core_helpers/handle_submit_status_update.go:55
↓ 1 callers
Function
newPhonyOffer
(frameworkId string, offerId string, slaveId string)
layerx-mesos-tpi/framework_manager/task_collection_offer.go:13
↓ 1 callers
Function
newPodKilledStatus
(task *lxtypes.Task)
layerx-k8s-rpi/main.go:172
↓ 1 callers
Function
newPodKilledStatus
(task *lxtypes.Task)
layerx-swarm-rpi/main.go:156
↓ 1 callers
Function
out
()
layerx-core/web/dragula.js:405
↓ 1 callers
Function
outside
()
layerx-core/web/dragula.js:457
↓ 1 callers
Function
over
()
layerx-core/web/dragula.js:404
↓ 1 callers
Function
overlaps
(prList1, prList2 []PortRange)
layerx-core/lxtypes/lxresource.go:65
↓ 1 callers
Function
pickNode
(nodes []*lxtypes.Node, task *lxtypes.Task)
example-brain/main.go:70
↓ 1 callers
Function
prepareFrameworkInfo
(layerxUrl, user string)
layerx-mesos-rpi/main.go:114
↓ 1 callers
Function
prepareStaticOptions
(options []martini.StaticOptions)
layerx-core/bindata/handler.go:96
↓ 1 callers
Method
processAcceptCall
(frameworkId string, accept *mesosscheduler.Call_Accept)
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:453
↓ 1 callers
Method
processMesosCall
(data []byte, upid *mesos_data.UPID)
layerx-mesos-tpi/mesos_master_api/master_api_server_wrapper.go:387
↓ 1 callers
Function
purgeState
()
layerx-core/main.go:19
↓ 1 callers
Function
refreshNodes
()
layerx-core/web/example/example.min.js:130
↓ 1 callers
Function
refreshPendingTasks
()
layerx-core/web/example/example.min.js:82
↓ 1 callers
Function
refreshStagingTasks
()
layerx-core/web/example/example.min.js:106
↓ 1 callers
Function
refreshTaskStatuses
()
layerx-core/web/example/example.min.js:39
↓ 1 callers
Function
reload_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:68
↓ 1 callers
Function
reload_kubernetes
conf
vagrant/lib/deploy_kubernetes.rb:52
↓ 1 callers
Function
remove
()
layerx-core/web/dragula.js:262
↓ 1 callers
Function
removeMirrorImage
()
layerx-core/web/dragula.js:432
↓ 1 callers
Function
renderMirrorImage
()
layerx-core/web/dragula.js:416
↓ 1 callers
Function
s
(o,u)
layerx-core/web/example/example.min.js:1
↓ 1 callers
Method
saveNode
(node *lxtypes.Node)
layerx-core/lxstate/node_pool.go:99
↓ 1 callers
Function
scheduleOnce
()
example-brain/main.go:34
↓ 1 callers
Function
sendFakeTaskOnOffer
(taskNo int, offer *mesosproto.Offer, masterUpid *mesos_data.UPID, port int)
layerx-mesos-tpi/fakes/fake_framework_server.go:111
↓ 1 callers
Function
setUp
()
layerx-k8s-rpi/kube/client_test.go:131
↓ 1 callers
Function
setUp
()
layerx-swarm-rpi/swarm/client_test.go:127
↓ 1 callers
Function
singleExeuction
(state *lxstate.State, taskLauncher *task_launcher.TaskLauncher, healthChecker *health_checker.HealthChecker)
layerx-core/main_loop/main_loop.go:30
↓ 1 callers
Function
statusUpdatesForever
(core *layerx_rpi_client.LayerXRpi, kubeClient *kube.Client)
layerx-k8s-rpi/main.go:110
↓ 1 callers
Function
statusUpdatesForever
(core *layerx_rpi_client.LayerXRpi, client *swarm.Client)
layerx-swarm-rpi/main.go:94
↓ 1 callers
Function
status_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:73
↓ 1 callers
Function
stop_docker_swarm
conf
vagrant/lib/deploy_swarm.rb:58
↓ 1 callers
Method
subtractRange
(pr2 PortRange)
layerx-core/lxtypes/lxresource.go:29
↓ 1 callers
Function
tearDown
()
layerx-k8s-rpi/kube/client_test.go:157
↓ 1 callers
Function
updatesForKilledTasks
(core *layerx_rpi_client.LayerXRpi, notKilledStatuses []*mesosproto.TaskStatus, ownedResources []*lxtypes.Reso
layerx-k8s-rpi/main.go:139
↓ 1 callers
Function
updatesForKilledTasks
(core *layerx_rpi_client.LayerXRpi, notKilledStatuses []*mesosproto.TaskStatus, ownedResources []*lxtypes.Reso
layerx-swarm-rpi/main.go:123
↓ 1 callers
Function
useNative
()
layerx-core/web/example/example.min.js:409
↓ 1 callers
Method
waitPodCreate
(name string)
layerx-k8s-rpi/kube/client.go:298
↓ 1 callers
Method
waitPodDelete
(name string)
layerx-k8s-rpi/kube/client.go:308
↓ 1 callers
Function
wrap
(el, type, fn)
layerx-core/web/example/example.min.js:536
↓ 1 callers
Function
wrapperFactory
(el, type, fn)
layerx-core/web/example/example.min.js:525
Function
AssignTasks
(state *lxstate.State, assignTasksMessage layerx_brain_client.BrainAssignTasksMessage)
layerx-core/lxserver/lx_core_helpers/handle_assign_tasks.go:10
Function
CollectResources
(core *layerx_rpi_client.LayerXRpi, masterAddr string)
layerx-mesos-rpi/layerx_rpi_api/rpi_api_helpers/handle_collect_resources.go:11
← previous
next →
201–300 of 437, ranked by callers