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