diff options
Diffstat (limited to 'plugins/broadcast/memory/driver.go')
-rw-r--r-- | plugins/broadcast/memory/driver.go | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/plugins/broadcast/memory/driver.go b/plugins/broadcast/memory/driver.go new file mode 100644 index 00000000..2eb45c8e --- /dev/null +++ b/plugins/broadcast/memory/driver.go @@ -0,0 +1,39 @@ +package memory + +import "github.com/spiral/roadrunner/v2/plugins/broadcast" + +type Driver struct { +} + +func NewInMemoryDriver() broadcast.Subscriber { + 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") +} |