diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-14 20:29:10 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-14 20:29:10 +0300 |
| commit | 5a56dc33b9903e9d96e7c87067bd273ad2e68f8a (patch) | |
| tree | aa5e6020d18fd42ee29ac3cf62ad41d4f18795c4 /plugins/redis/plugin.go | |
| parent | 6860326fa5d8f37f6e954da07fd53b9261731227 (diff) | |
Update broadcast tests, add redis flusing. Initial impl of the job
drivers state.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/redis/plugin.go')
| -rw-r--r-- | plugins/redis/plugin.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/redis/plugin.go b/plugins/redis/plugin.go index 3c62a63f..961182a9 100644 --- a/plugins/redis/plugin.go +++ b/plugins/redis/plugin.go @@ -9,6 +9,8 @@ import ( "github.com/spiral/roadrunner/v2/common/pubsub" "github.com/spiral/roadrunner/v2/plugins/config" "github.com/spiral/roadrunner/v2/plugins/logger" + redis_kv "github.com/spiral/roadrunner/v2/plugins/redis/kv" + redis_pubsub "github.com/spiral/roadrunner/v2/plugins/redis/pubsub" ) const PluginName = "redis" @@ -62,7 +64,7 @@ func (p *Plugin) Available() {} // KVConstruct provides KV storage implementation over the redis plugin func (p *Plugin) KVConstruct(key string) (kv.Storage, error) { const op = errors.Op("redis_plugin_provide") - st, err := NewRedisDriver(p.log, key, p.cfgPlugin) + st, err := redis_kv.NewRedisDriver(p.log, key, p.cfgPlugin) if err != nil { return nil, errors.E(op, err) } @@ -71,5 +73,5 @@ func (p *Plugin) KVConstruct(key string) (kv.Storage, error) { } func (p *Plugin) PSConstruct(key string) (pubsub.PubSub, error) { - return NewPubSubDriver(p.log, key, p.cfgPlugin, p.stopCh) + return redis_pubsub.NewPubSubDriver(p.log, key, p.cfgPlugin, p.stopCh) } |