1
2type PubSub interface {
3 GetSubs() iter.Seq[*Sub]
4 GetPubs() iter.Seq[*Pub]
5 GetChannels() iter.Seq[*Channel]
6 GetPipes() iter.Seq[*Pipe]
7 Pipe(pipeClient *PipeClient, pipes []*Pipe) error
8 Sub(sub *Sub, channels []*Channel) error
9 Pub(pub *Pub, channels []*Channel) error
10}
11
12type Cfg struct {
13 Logger *slog.Logger
14 PubSub PubSub
15}