diff options
Diffstat (limited to 'plugins/broadcast/memory/driver.go')
-rw-r--r-- | plugins/broadcast/memory/driver.go | 42 |
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") +} |