Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
453 B · 22 lines
1234567891011121314151617181920212223package knotstream
import "tangled.org/core/knotmirror/models"
// subscription represents websocket connection with that hosttype subscription struct { hostname string
// embedded parallel job scheduler scheduler *ParallelScheduler}
func (s *subscription) LastSeq() int64 { return s.scheduler.LastSeq()}
func (s *subscription) HostCursor() models.HostCursor { return models.HostCursor{ Hostname: s.hostname, LastSeq: s.LastSeq(), }}