blender/flamenco
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Website: adjust documentation for the new event bus

Browse Source 
Needs more work though. At least now it doesn't point to non-existing
files any more.
This commit is contained in:
Sybren A. Stüvel 2024-02-05 09:27:06 +01:00
parent e7c4285ac6
commit 17c92e18c7
1 changed files with 6 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
web/project-website/content/development/socketio/_index.md
View File

@ -24,27 +24,16 @@ SocketIO messages have an *event name* and *room name*.
## Technical Details ## Technical Details
The following files & directories are relevant to the SocketIO broadcasting The following files & directories are relevant to the SocketIO/MQTT broadcasting
system on the Manager/backend side: system on the Manager/backend side:
`internal/manager/webupdates` `internal/manager/eventbus`
: package for the SocketIO broadcasting system : package for the event broadcasting system, including implementations for
SocketIO and MQTT.
`internal/manager/webupdates/sio_rooms.go`
: contains the list of predefined SocketIO *rooms* and *event types*. Note that
there are more rooms than listed in that file; there are dynamic room name
like `job-fa48930a-105c-4125-a7f7-0aa1651dcd57` that cannot be listed there as
constants.
`internal/manager/webupdates/job_updates.go`
: sending job-related updates.
`internal/manager/webupdates/worker_updates.go`
: sending worker-related updates.
`pkg/api/flamenco-openapi.yaml` `pkg/api/flamenco-openapi.yaml`
: the OpenAPI specification also includes the structures sent over SocketIO. : the OpenAPI specification also includes the structures sent over SocketIO and MQTT.
Search for `SocketIOJobUpdate`; the rest is defined in its vicinity. Search for `EventJobUpdate`; the rest is defined in its vicinity.
For a relatively simple example of a job update broadcast, see For a relatively simple example of a job update broadcast, see
`func (f *Flamenco) SetJobPriority(...)` in `internal/manager/api_impl/jobs.go`. `func (f *Flamenco) SetJobPriority(...)` in `internal/manager/api_impl/jobs.go`.