diff options
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/interface/broadcast/broadcast.go | 7 | ||||
| -rw-r--r-- | pkg/pubsub/interface.go | 5 |
2 files changed, 12 insertions, 0 deletions
diff --git a/pkg/interface/broadcast/broadcast.go b/pkg/interface/broadcast/broadcast.go new file mode 100644 index 00000000..c922c82e --- /dev/null +++ b/pkg/interface/broadcast/broadcast.go @@ -0,0 +1,7 @@ +package broadcast + +import "github.com/spiral/roadrunner/v2/pkg/pubsub" + +type Broadcaster interface { + GetDriver(key string) pubsub.SubReader +} diff --git a/pkg/pubsub/interface.go b/pkg/pubsub/interface.go index d021dbbe..30b544db 100644 --- a/pkg/pubsub/interface.go +++ b/pkg/pubsub/interface.go @@ -16,6 +16,11 @@ type PubSub interface { Reader } +type SubReader interface { + Subscriber + Reader +} + // Subscriber defines the ability to operate as message passing broker. // BETA interface type Subscriber interface { |