dzming.li
A vibe coded tangled fork which supports pijul.
1package knotstream
2
3import "tangled.org/core/knotmirror/models"
4
5// subscription represents websocket connection with that host
6type subscription struct {
7 hostname string
8
9 // embedded parallel job scheduler
10 scheduler *ParallelScheduler
11}
12
13func (s *subscription) LastSeq() int64 {
14 return s.scheduler.LastSeq()
15}
16
17func (s *subscription) HostCursor() models.HostCursor {
18 return models.HostCursor{
19 Hostname: s.hostname,
20 LastSeq: s.LastSeq(),
21 }
22}