Pubsub is a generic interface for broadcasting and receiving messages. Implementors should assume high-availability with the backing implementation.
| 45 | // Pubsub is a generic interface for broadcasting and receiving messages. |
| 46 | // Implementors should assume high-availability with the backing implementation. |
| 47 | type Pubsub interface { |
| 48 | Subscriber |
| 49 | Publisher |
| 50 | Close() error |
| 51 | } |
| 52 | |
| 53 | // msgOrErr either contains a message or an error |
| 54 | type msgOrErr struct { |
no outgoing calls
no test coverage detected