pubsub_iface_v5.go

· erock's pastes · raw

expires: 2024-12-25

 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}