diff options
author | Valery Piashchynski <[email protected]> | 2021-05-20 22:46:19 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-05-20 22:46:19 +0300 |
commit | d2e9d8320857f5768c54843a43ad16f59d6a3e8f (patch) | |
tree | f6f46e688b6005b2b0ea10c7238e925c0b58f25a /plugins/broadcast/redis/driver.go | |
parent | f85172106b4723b705aa75c3c310e8cebd050a8d (diff) |
- Update linters
- Implement base interfaces
- Implement BST search algo for the in-memory storage
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/broadcast/redis/driver.go')
-rw-r--r-- | plugins/broadcast/redis/driver.go | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/plugins/broadcast/redis/driver.go b/plugins/broadcast/redis/driver.go index 65a229e1..556d5f03 100644 --- a/plugins/broadcast/redis/driver.go +++ b/plugins/broadcast/redis/driver.go @@ -1 +1,29 @@ package redis + +import ( + "github.com/spiral/roadrunner/v2/plugins/broadcast" +) + +type Driver struct { +} + +func NewInMemoryDriver() broadcast.Storage { + b := &Driver{} + return b +} + +func (d *Driver) Store(uuid string, topics ...string) { + panic("implement me") +} + +func (d *Driver) StorePattern(uuid string, pattern string) { + panic("implement me") +} + +func (d *Driver) GetConnection(pattern string) []string { + panic("implement me") +} + +func (d *Driver) Construct(key string) (broadcast.Storage, error) { + panic("implement me") +} |