pubsub_iface.diff

· erock's pastes · raw

expires: 2024-12-24

 1diff --git a/pubsub.go b/pubsub.go
 2index 2bc383e..2cb617a 100644
 3--- a/pubsub.go
 4+++ b/pubsub.go
 5@@ -213,15 +213,13 @@ func (pipe *Pipe) Cleanup() {
 6 }
 7 
 8 type PubSub interface {
 9-	GetSubs(channel string) []*Sub
10-	GetPubs(channel string) []*Pub
11-	GetChannels(channelPrefix string) []*Channel
12-	GetPipes(pipePrefix string) []*Pipe
13-	GetChannel(channel string) *Channel
14-	GetPipe(pipe string) *Pipe
15-	Pipe(pipe string, pipeClient *PipeClient) (error, error)
16-	Sub(channel string, sub *Sub) error
17-	Pub(channel string, pub *Pub) error
18+	GetSubs(channels []*Channel) []*Sub
19+	GetPubs(channels []*Channel) []*Pub
20+	GetChannels() []*Channel
21+	GetPipes() []*Pipe
22+	Pipe(pipes []*Pipe, pipeClient *PipeClient) (error, error)
23+	Sub(channels []*Channel, sub *Sub) error
24+	Pub(channel []*Channel, pub *Pub) error
25 }
26 
27 type Cfg struct {