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
Function
CollectTasks
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager, collectTasksMessage la
layerx-mesos-tpi/layerx_tpi_api/tpi_api_helpers/collect_tasks_helper.go:10
Function
DeregisterTaskProvider
(state *lxstate.State, tpId string)
layerx-core/lxserver/lx_core_helpers/handle_deregister_task_provider.go:8
Function
DiffPortRanges
returns PRList1 minus intersections with PRList2
layerx-core/lxtypes/lxresource.go:75
Method
Disconnected
(scheduler.SchedulerDriver)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:65
Method
Equal
Equal returns true if two upid is equal
layerx-mesos-tpi/mesos_master_api/mesos_data/upid.go:41
Method
ExecutorLost
(driver scheduler.SchedulerDriver, exId *mesosproto.ExecutorID, slvId *mesosproto.SlaveID, i int)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:138
Function
FakeDeclineOffersCall
(frameworkId string, offerIds ...string)
layerx-mesos-tpi/fakes/fake_scheduler_calls.go:22
Function
FakeKillTaskCall
(frameworkId, taskId string)
layerx-mesos-tpi/fakes/fake_scheduler_calls.go:102
Function
FakeKillTaskMessage
(frameworkId string, taskId string)
layerx-mesos-tpi/fakes/fake_proto_objects.go:158
Function
FakeLXDockerTask
(taskId, taskName, slaveId, taskCommand string)
layerx-core/fakes/fake_lx_task.go:31
Function
FakeLaunchTasksCall
(frameworkId string, offerIds []string, taskInfos ...*mesosproto.TaskInfo)
layerx-mesos-tpi/fakes/fake_scheduler_calls.go:72
Function
FakeLaunchTasksMessage
(frameworkId string)
layerx-mesos-tpi/fakes/fake_proto_objects.go:57
Function
FakeNode
(resourceId string, nodeId string)
layerx-core/fakes/fake_lx_node.go:5
Function
FakeReconcileTasksCall
(frameworkId string, taskIds ...string)
layerx-mesos-tpi/fakes/fake_scheduler_calls.go:41
Function
FakeReconcileTasksMessage
(frameworkId string, statuses []*mesosproto.TaskStatus)
layerx-mesos-tpi/fakes/fake_proto_objects.go:81
Function
FakeRegisterFrameworkMessage
()
layerx-mesos-tpi/fakes/fake_proto_objects.go:38
Function
FakeReregisterFrameworkMessage
()
layerx-mesos-tpi/fakes/fake_proto_objects.go:44
Function
FakeReviveOffersCall
(frameworkId string)
layerx-mesos-tpi/fakes/fake_scheduler_calls.go:62
Function
FakeReviveOffersMessage
(frameworkId string)
layerx-mesos-tpi/fakes/fake_proto_objects.go:184
Function
FakeStatusUpdateAcknowledgementMessage
(frameworkId string, taskId string, slaveId string, uuid []byte)
layerx-mesos-tpi/fakes/fake_proto_objects.go:169
Function
FakeSubscribeCall
()
layerx-mesos-tpi/fakes/fake_scheduler_calls.go:9
Function
FakeTask
(taskId string)
layerx-mesos-rpi/fakes/fake_objects.go:11
Function
FakeTaskProvider
(tpid, source string)
layerx-core/fakes/fake_lx_task_provider.go:5
Function
FakeTaskStatus
(taskId string, fakeState mesosproto.TaskState)
layerx-mesos-tpi/fakes/fake_proto_objects.go:148
Function
FakeUnregisterFrameworkMessage
()
layerx-mesos-tpi/fakes/fake_proto_objects.go:51
Method
FrameworkMessage
(driver scheduler.SchedulerDriver, exId *mesosproto.ExecutorID, slvId *mesosproto.SlaveID, msg string)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:130
Method
GetDriver
()
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:45
Function
GetMesosState
(masterUpidString string)
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/get_mesos_state_helper.go:13
Function
GetNodes
(state *lxstate.State)
layerx-core/lxserver/lx_core_helpers/handle_get_nodes.go:9
Function
GetPendingTasks
(state *lxstate.State)
layerx-core/lxserver/lx_core_helpers/handle_get_pending_tasks.go:9
Function
GetStagingTasks
(state *lxstate.State)
layerx-core/lxserver/lx_core_helpers/handle_get_staging_tasks.go:9
Function
GetStatusUpdate
(state *lxstate.State, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_get_status_update.go:10
Function
GetStatusUpdates
(state *lxstate.State, tpId string)
layerx-core/lxserver/lx_core_helpers/handle_get_status_updates.go:9
Function
GetTaskProviders
(state *lxstate.State)
layerx-core/lxserver/lx_core_helpers/handle_get_task_providers.go:9
Method
GetTotalCpus
()
layerx-core/lxtypes/lxnode.go:105
Method
GetTotalDisk
()
layerx-core/lxtypes/lxnode.go:121
Method
GetTotalMem
()
layerx-core/lxtypes/lxnode.go:113
Method
GetTotalPorts
()
layerx-core/lxtypes/lxnode.go:129
Function
HandleKillTaskRequest
(tpi *layerx_tpi_client.LayerXTpi, frameworkId, taskId string)
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/kill_task_helper.go:9
Function
HandleLaunchTasksRequest
(tpi *layerx_tpi_client.LayerXTpi, frameworkId string, mesosTasks []*mesosproto.TaskInfo)
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/launch_tasks_helper.go:11
Function
HandleOfferRescinded
(core *layerx_rpi_client.LayerXRpi, driver scheduler.SchedulerDriver, id *mesosproto.OfferID)
layerx-mesos-rpi/mesos_framework_api/framework_api_handlers/handle_offer_rescinded.go:10
Function
HandleReconcileTasksRequest
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager, frameworkUpid *mesos_d
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/reconcile_tasks_helper.go:12
Function
HandleRegisterRequest
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager, frameworkUpid *mesos_d
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/register_request_helper.go:14
Function
HandleRemoveFramework
(tpi *layerx_tpi_client.LayerXTpi, frameworkId string)
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/remove_framework_helper.go:9
Function
HandleStatusUpdate
(lxRpi *layerx_rpi_client.LayerXRpi, status *mesosproto.TaskStatus)
layerx-mesos-rpi/mesos_framework_api/framework_api_handlers/handle_status_update.go:10
Function
HealthCheck
(tpi *layerx_tpi_client.LayerXTpi, frameworkManager framework_manager.FrameworkManager, healthCheckMessage lay
layerx-mesos-tpi/layerx_tpi_api/tpi_api_helpers/health_check_helper.go:10
Method
HealthCheckFramework
(frameworkId string, frameworkUpid *mesos_data.UPID)
layerx-mesos-tpi/framework_manager/framework_manager.go:123
Method
Initialize
()
layerx-core/lxstate/task_provider_pool.go:18
Method
Initialize
()
layerx-core/lxstate/node_pool.go:18
Method
Initialize
()
layerx-core/lxstate/status_pool.go:18
Function
KillTask
(driver scheduler.SchedulerDriver, taskId string)
layerx-mesos-rpi/layerx_rpi_api/rpi_api_helpers/handle_kill_task.go:11
Function
LaunchTasks
(driver scheduler.SchedulerDriver, taskQueue chan *lxtypes.Task, launchTasksMessage layerx_rpi_client.LaunchTa
layerx-mesos-rpi/layerx_rpi_api/rpi_api_helpers/handle_launch_tasks.go:10
Method
Len
()
layerx-core/lxtypes/lxresource.go:15
Method
Less
(i, j int)
layerx-core/lxtypes/lxresource.go:21
Function
LogReviveOffersMessage
(reviveOffers mesosproto.ReviveOffersMessage)
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/log_revive_offers_req.go:8
Function
LogStatusUpdateAck
(statusUpdateAck mesosproto.StatusUpdateAcknowledgementMessage)
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/log_status_update_ack_helper.go:8
Function
MigrateTasks
(state *lxstate.State, migrateTasksMessage layerx_brain_client.MigrateTaskMessage)
layerx-core/lxserver/lx_core_helpers/handle_migrate_tasks.go:9
Function
NewFakeCore
()
layerx-core/fakes/fake_lx_server.go:55
Function
NewRpiMesosScheduler
(lxRpi *layerx_rpi_client.LayerXRpi)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:27
Method
NotifyFrameworkRegistered
notify a framework that it has successfully registered with the tpi
layerx-mesos-tpi/framework_manager/framework_manager.go:36
Method
OfferRescinded
(driver scheduler.SchedulerDriver, id *mesosproto.OfferID)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:120
Function
ProcessMesosHttpRequest
(req *http.Request)
layerx-mesos-tpi/mesos_master_api/mesos_api_helpers/mesos_http_helpers.go:12
Function
PurgeTask
(state *lxstate.State, taskId string)
layerx-core/lxserver/lx_core_helpers/handle_purge_task.go:8
Function
RegisterRpi
(state *lxstate.State, rpiRegister layerx_rpi_client.RpiInfo)
layerx-core/lxserver/lx_core_helpers/handle_register_rpi.go:9
Function
RegisterTaskProvider
(state *lxstate.State, taskProvider *lxtypes.TaskProvider)
layerx-core/lxserver/lx_core_helpers/handle_register_task_provider.go:9
Function
RegisterTpi
(state *lxstate.State, tpiUrl string)
layerx-core/lxserver/lx_core_helpers/handle_register_tpi.go:8
Method
Registered
(driver scheduler.SchedulerDriver, frameworkId *mesosproto.FrameworkID, masterInfo *mesosproto.MasterInfo)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:52
Method
Reregistered
(driver scheduler.SchedulerDriver, masterInfo *mesosproto.MasterInfo)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:60
Function
RescindResource
(state *lxstate.State, resourceID string)
layerx-core/lxserver/lx_core_helpers/handle_rescind_resource.go:8
Method
ResourceOffers
(driver scheduler.SchedulerDriver, offers []*mesosproto.Offer)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:69
Function
RunFakeFrameworkServer
(frameworkid string, port int)
layerx-mesos-tpi/fakes/fake_framework_server.go:16
Function
RunFakeRpiServer
(layerxUrl string, port int, driverErrc chan error)
layerx-core/fakes/fake_rpi_server.go:25
Function
RunFakeTpiServer
(layerxUrl string, port int, driverErrc chan error)
layerx-core/fakes/fake_tpi_server.go:26
Method
SendStatusUpdate
send status update to framework
layerx-mesos-tpi/framework_manager/framework_manager.go:68
Method
SendTaskCollectionOffer
(frameworkId, phonyOfferId, phonySlaveId, phonySlavePid string, frameworkUpid *mesos_data.UPID)
layerx-mesos-tpi/framework_manager/framework_manager.go:102
Method
SlaveLost
(driver scheduler.SchedulerDriver, id *mesosproto.SlaveID)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:134
Function
Start
(port string, client *kube.Client, core *layerx_rpi_client.LayerXRpi)
layerx-k8s-rpi/server/server.go:21
Function
Start
(port string, client *swarm.Client, core *layerx_rpi_client.LayerXRpi)
layerx-swarm-rpi/server/server.go:21
Function
Static
Static returns a middleware handler that serves static files in the given directory.
layerx-core/bindata/handler.go:14
Method
StatusUpdate
(driver scheduler.SchedulerDriver, status *mesosproto.TaskStatus)
layerx-mesos-rpi/mesos_framework_api/rpi_mesos_scheduler.go:108
Function
SubmitResource
(state *lxstate.State, resource *lxtypes.Resource)
layerx-core/lxserver/lx_core_helpers/handle_submit_resource.go:10
Function
SubmitTask
(state *lxstate.State, tpId string, task *lxtypes.Task)
layerx-core/lxserver/lx_core_helpers/handle_submit_task.go:9
Method
Swap
(i, j int)
layerx-core/lxtypes/lxresource.go:18
Method
Teardown
()
layerx-k8s-rpi/kube/client.go:53
Function
TestFrameworkApiHandlers
(t *testing.T)
layerx-mesos-rpi/mesos_framework_api/framework_api_handlers/framework_api_handlers_suite_test.go:10
Function
TestFrameworkManager
(t *testing.T)
layerx-mesos-tpi/framework_manager/framework_manager_suite_test.go:10
Function
TestHealthChecker
(t *testing.T)
layerx-core/health_checker/health_checker_suite_test.go:10
Function
TestKube
(t *testing.T)
layerx-k8s-rpi/kube/kube_suite_test.go:10
Function
TestLayerxBrainClient
(t *testing.T)
layerx-core/layerx_brain_client/layerx_brain_client_suite_test.go:10
Function
TestLayerxRpiApi
(t *testing.T)
layerx-mesos-rpi/layerx_rpi_api/layerx_rpi_api_suite_test.go:10
Function
TestLayerxRpiClient
(t *testing.T)
layerx-core/layerx_rpi_client/layerx_rpi_client_suite_test.go:10
Function
TestLayerxTpi
(t *testing.T)
layerx-core/layerx_tpi_client/layerx_tpi_suite_test.go:10
Function
TestLayerxTpiApi
(t *testing.T)
layerx-mesos-tpi/layerx_tpi_api/layerx_tpi_api_suite_test.go:10
Function
TestLxCoreHelpers
(t *testing.T)
layerx-core/lxserver/lx_core_helpers/lx_core_helpers_suite_test.go:10
Function
TestLxserver
(t *testing.T)
layerx-core/lxserver/lxserver_suite_test.go:10
Function
TestLxtypes
(t *testing.T)
layerx-core/lxtypes/lxtypes_suite_test.go:10
Function
TestMainLoop
(t *testing.T)
layerx-core/main_loop/main_loop_suite_test.go:10
Function
TestMesosMasterApi
(t *testing.T)
layerx-mesos-tpi/mesos_master_api/mesos_master_api_suite_test.go:10
Function
TestRpiMessenger
(t *testing.T)
layerx-core/rpi_messenger/rpi_messenger_suite_test.go:10
Function
TestState
(t *testing.T)
layerx-core/lxstate/state_suite_test.go:10
← previous
next →
301–400 of 437, ranked by callers