summaryrefslogtreecommitdiff
path: root/plugins/broadcast/memory/driver.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/broadcast/memory/driver.go')
-rw-r--r--plugins/broadcast/memory/driver.go42
1 files changed, 42 insertions, 0 deletions
diff --git a/plugins/broadcast/memory/driver.go b/plugins/broadcast/memory/driver.go
new file mode 100644
index 00000000..8a9374c9
--- /dev/null
+++ b/plugins/broadcast/memory/driver.go
@@ -0,0 +1,42 @@
+package memory
+
+import "github.com/spiral/roadrunner/v2/plugins/broadcast"
+
+type Driver struct {
+
+}
+
+func NewInMemoryDriver() broadcast.Broker {
+ b := &Driver{
+
+ }
+ return b
+}
+
+func (d *Driver) Serve() error {
+ panic("implement me")
+}
+
+func (d *Driver) Stop() {
+ panic("implement me")
+}
+
+func (d *Driver) Subscribe(upstream chan *broadcast.Message, topics ...string) error {
+ panic("implement me")
+}
+
+func (d *Driver) SubscribePattern(upstream chan *broadcast.Message, pattern string) error {
+ panic("implement me")
+}
+
+func (d *Driver) Unsubscribe(upstream chan *broadcast.Message, topics ...string) error {
+ panic("implement me")
+}
+
+func (d *Driver) UnsubscribePattern(upstream chan *broadcast.Message, pattern string) error {
+ panic("implement me")
+}
+
+func (d *Driver) Publish(messages ...*broadcast.Message) error {
+ panic("implement me")
+}