MCPcopy Create free account

hub / github.com/adalkiran/distributed-inference / functions

Functions91 in github.com/adalkiran/distributed-inference

⨍ Functions 91◇ Types & classes 30
↓ 10 callersMethodstop
(closeConnection: Boolean)
ui/src/app.ts:157
↓ 5 callersMethodEnsureTenant
(id string, name string)
signaling/src/participant/tenantmanager.go:37
↓ 4 callersMethodupdateStatus
(connStatus: string)
ui/src/app.ts:215
↓ 3 callersMethodGetId
()
signaling/src/signaling/wsclient.go:85
↓ 2 callersFunctionNewTenant
(id string, name string)
signaling/src/participant/tenant.go:25
↓ 2 callersMethodRun
(waitGroup *sync.WaitGroup)
signaling/src/signaling/httpserver.go:46
↓ 2 callersMethodget_task_id
(self)
inference/src/tasks/base_inference_task.py:35
↓ 2 callersMethodprocess_images_messages
(self, messages, inventa: Inventa, session)
inference/src/tasks/yolox_inference_task.py:107
↓ 2 callersMethodresetCanvas
()
ui/src/app.ts:297
↓ 1 callersMethodAcceptSDPOfferAnswer
(participantId string, sdpOfferAnswer string)
signaling/src/orchestration/mediabridgemodule.go:59
↓ 1 callersMethodAcceptSDPOfferAnswer
(sdpOfferAnswer string)
mediabridge/src/endpoint/endpoint.go:187
↓ 1 callersMethodCreateParticipant
(tenantId string, wsClientId int)
signaling/src/participant/participantmanager.go:63
↓ 1 callersMethodDoSignaling
(endpointManager *EndpointManager)
mediabridge/src/endpoint/endpoint.go:61
↓ 1 callersMethodEndpointICEConnStateChange
(participantId string, newConnectionState string, oldConnectionState string)
signaling/src/orchestration/mediabridgemodule.go:72
↓ 1 callersMethodEnsureEndpoint
(participantId string)
mediabridge/src/endpoint/endpointmanager.go:132
↓ 1 callersMethodExecute
(hub *WsHub)
signaling/src/signaling/wscommands.go:35
↓ 1 callersMethodGetAllTenants
()
signaling/src/participant/tenantmanager.go:56
↓ 1 callersMethodGetParticipantByWsClientId
(wsClientId int)
signaling/src/participant/participantmanager.go:76
↓ 1 callersMethodInit
(inventaObj *inventa.Inventa)
signaling/src/orchestration/orchestrator.go:66
↓ 1 callersFunctionInitDatabase
(tenantManager *participant.TenantManager)
signaling/src/initdatabase.go:25
↓ 1 callersMethodInitFromDatabase
()
signaling/src/participant/tenantmanager.go:65
↓ 1 callersFunctionNewEndpoint
(participantId string)
mediabridge/src/endpoint/endpoint.go:53
↓ 1 callersFunctionNewMediaBridgeModule
(id string, inventaObj *inventa.Inventa)
signaling/src/orchestration/mediabridgemodule.go:38
↓ 1 callersFunctionNewParticipant
(tenant *Tenant, wsClientId int)
signaling/src/participant/participant.go:32
↓ 1 callersFunctionNewWsCommand
(messageData map[string]interface{}, wsClient *WsClient, fn WsCommandFn)
signaling/src/signaling/wscommands.go:27
↓ 1 callersFunctionNewWsMessageContainer
(type_ string, data interface{})
signaling/src/signaling/wshub.go:65
↓ 1 callersMethodPrepareParticipant
(participant *Participant)
signaling/src/participant/participantmanager.go:81
↓ 1 callersMethodRequestSDPOffer
(participantId string)
signaling/src/orchestration/mediabridgemodule.go:51
↓ 1 callersMethodRun
(waitGroup *sync.WaitGroup)
signaling/src/predictions/predictionslistener.go:53
↓ 1 callersMethodRun
(waitGroup *sync.WaitGroup)
mediabridge/src/endpoint/endpointmanager.go:50
↓ 1 callersMethodSaveTenant
(entity *Tenant)
signaling/src/participant/tenantmanager.go:47
↓ 1 callersMethodSelectMediaBridgeForParticipant
()
signaling/src/orchestration/orchestrator.go:51
↓ 1 callersMethodacceptOffer
(offerSdp: string)
ui/src/app.ts:190
↓ 1 callersMethodclose
()
ui/src/app.ts:293
↓ 1 callersMethodconnect
()
ui/src/app.ts:224
↓ 1 callersFunctionconnect_to_redis
()
inference/src/app.py:40
↓ 1 callersMethodcreateInterceptorRegistry
(me *webrtc.MediaEngine)
mediabridge/src/endpoint/endpointmanager.go:117
↓ 1 callersMethodcreateLocalPeerConnection
()
ui/src/app.ts:49
↓ 1 callersMethodcreateLocalTracks
()
ui/src/app.ts:122
↓ 1 callersMethodcreateMediaEngine
()
mediabridge/src/endpoint/endpointmanager.go:95
↓ 1 callersFunctioncreate_metrics_for_task
(task_id: string)
inference/src/app.py:33
↓ 1 callersMethodgetBackendWSURL
(relativePath: string)
ui/src/app.ts:27
↓ 1 callersMethodget_prediction
(self, img_bytes,session)
inference/src/tasks/yolox_inference_task.py:49
↓ 1 callersMethodget_task_name
(self)
inference/src/tasks/yolox_inference_task.py:46
↓ 1 callersMethodget_task_name
(self)
inference/src/tasks/base_inference_task.py:39
↓ 1 callersFunctioninitApp
()
ui/src/app.ts:351
↓ 1 callersFunctionmain
()
inference/src/app.py:67
↓ 1 callersFunctionnewWsHub
(wsCommandFnRegistry map[string]WsCommandFn)
signaling/src/signaling/wshub.go:72
↓ 1 callersFunctionprocessBroadcastMessage
(h *WsHub, broadcastMessage BroadcastMessage)
signaling/src/signaling/wshub.go:84
↓ 1 callersMethodprocessPredictionMessages
(messages []goredis.XMessage)
signaling/src/predictions/predictionslistener.go:76
↓ 1 callersMethodprocessPredictions
(predictionsData: any)
ui/src/app.ts:308
↓ 1 callersMethodprocessVP9Track
(track *webrtc.TrackRemote, endpointManager *EndpointManager)
mediabridge/src/endpoint/endpoint.go:203
↓ 1 callersFunctionrandStringRunes
(n int)
signaling/src/utils/generators.go:25
↓ 1 callersMethodreadPump
readPump pumps messages from the websocket connection to the hub. The application runs readPump in a per-connection goroutine. The application ensure
signaling/src/signaling/wsclient.go:94
↓ 1 callersMethodrun
(self)
inference/src/tasks/yolox_inference_task.py:128
↓ 1 callersMethodrun
(self)
inference/src/tasks/base_inference_task.py:43
↓ 1 callersMethodrun
* func writeContainerJSON(client *WsClient, messageType string, messageData interface{}) { client.conn.WriteJSON(WsMessageContainer{ Type: messageT
signaling/src/signaling/wshub.go:126
↓ 1 callersMethodsafeEncodeJpeg
(buffer *bytes.Buffer, img *vpx.Image)
mediabridge/src/endpoint/endpoint.go:194
↓ 1 callersMethodsendSdpToSignaling
(parsedSdp: sdpTransform.SessionDescription)
ui/src/app.ts:183
↓ 1 callersMethodserveWs
serveWs handles websocket requests from the peer.
signaling/src/signaling/httpserver.go:71
↓ 1 callersMethodset_metrics
(self, metrics: dict)
inference/src/tasks/base_inference_task.py:28
↓ 1 callersMethodstart
()
ui/src/app.ts:135
↓ 1 callersFunctiontry_register_to_orchestrator
(inventa: Inventa)
inference/src/app.py:49
↓ 1 callersMethodwritePump
writePump pumps messages from the hub to the websocket connection. A goroutine running writePump is started for each connection. The application ensu
signaling/src/signaling/wsclient.go:131
FunctionGenerateParticipantId
()
signaling/src/utils/generators.go:33
MethodGetTenant
(id string)
signaling/src/participant/tenantmanager.go:51
FunctionNewEndpointManager
(dockerHostIp string, udpPort int, inventaObj *inventa.Inventa)
mediabridge/src/endpoint/endpointmanager.go:39
FunctionNewHttpServer
(httpServerAddr string, wsCommandFnRegistry map[string]WsCommandFn)
signaling/src/signaling/httpserver.go:31
FunctionNewOrchestrator
()
signaling/src/orchestration/orchestrator.go:40
FunctionNewParticipantManager
(tenantManager *TenantManager, orchestrator *orchestration.Orchestrator, inventaObj *inventa.Inventa)
signaling/src/participant/participantmanager.go:49
FunctionNewPredictionListener
(participantManager *participant.ParticipantManager, inventaObj *inventa.Inventa, selfConsumerName string)
signaling/src/predictions/predictionslistener.go:44
FunctionNewTenantManager
(inventaObj *inventa.Inventa)
signaling/src/participant/tenantmanager.go:29
MethodRemoteAddrStr
()
signaling/src/signaling/wsclient.go:178
MethodRun
(waitGroup *sync.WaitGroup)
signaling/src/participant/participantmanager.go:95
MethodServiceRegisteringHandler
(serviceDescriptor inventa.ServiceDescriptor)
signaling/src/orchestration/orchestrator.go:76
MethodServiceUnregisteringHandler
(serviceDescriptor inventa.ServiceDescriptor, isZombie bool)
signaling/src/orchestration/orchestrator.go:93
MethodWsCommandJoin
(hub *signaling.WsHub, cmd *signaling.WsCommand)
signaling/src/participant/participantmanager.go:112
MethodWsCommandSdpOfferAnswer
(hub *signaling.WsHub, cmd *signaling.WsCommand)
signaling/src/participant/participantmanager.go:130
Method__init__
(self, inventa: Inventa, SelfDescriptor: ServiceDescriptor)
inference/src/tasks/yolox_inference_task.py:40
Method__init__
(self, inventa: Inventa, SelfDescriptor: ServiceDescriptor)
inference/src/tasks/base_inference_task.py:24
Methodautoclaim_stream
(self, self_consumer_name)
inference/src/tasks/yolox_inference_task.py:90
Methodconstructor
(videoElm: any)
ui/src/app.ts:44
Functionexception_handler
(loop, context)
inference/src/app.py:57
MethodgetBackendURL
(relativePath: string)
ui/src/app.ts:23
Methodget_task_id
(self)
inference/src/tasks/yolox_inference_task.py:43
Functionmain
()
signaling/src/main.go:43
Functionmain
()
mediabridge/src/main.go:43
MethodrpcCommandMbICEConnStateChange
(req *inventa.RPCCallRequest)
signaling/src/orchestration/orchestrator.go:117
FunctionrpcCommandSDPAcceptOfferAnswer
(req *inventa.RPCCallRequest)
mediabridge/src/main.go:117
FunctionrpcCommandSDPOfferReq
(req *inventa.RPCCallRequest)
mediabridge/src/main.go:103
MethodserveHome
(w http.ResponseWriter, r *http.Request)
signaling/src/signaling/httpserver.go:57