(key interface{})
| 55 | } |
| 56 | |
| 57 | func (p *PubSubPipe) Subscribe(key interface{}) { |
| 58 | psKey, err := p.channel(key) |
| 59 | if err != nil { |
| 60 | p.Log.Error("invalid key passed to Subscribe", err) |
| 61 | return |
| 62 | } |
| 63 | |
| 64 | if err := p.PubSub.Subscribe(context.TODO(), psKey); err != nil { |
| 65 | p.Log.Error("pubsub subscribe failed", err) |
| 66 | } else { |
| 67 | p.Log.DebugMsg("subscribed to pubsub", "channel", psKey) |
| 68 | } |
| 69 | } |
| 70 | |
| 71 | func (p *PubSubPipe) Unsubscribe(key interface{}) { |
| 72 | psKey, err := p.channel(key) |