diff options
Diffstat (limited to 'plugins/memory/plugin.go')
-rw-r--r-- | plugins/memory/plugin.go | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/plugins/memory/plugin.go b/plugins/memory/plugin.go new file mode 100644 index 00000000..650f0b4b --- /dev/null +++ b/plugins/memory/plugin.go @@ -0,0 +1,25 @@ +package memory + +import ( + "github.com/spiral/roadrunner/v2/pkg/pubsub" + "github.com/spiral/roadrunner/v2/plugins/logger" +) + +const PluginName string = "memory" + +type Plugin struct { + log logger.Logger +} + +func (p *Plugin) Init(log logger.Logger) error { + p.log = log + return nil +} + +func (p *Plugin) PSProvide(key string) (pubsub.PubSub, error) { + return NewPubSubDriver(p.log, key) +} + +func (p *Plugin) Name() string { + return PluginName +} |