summaryrefslogtreecommitdiff
path: root/plugins
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-18 18:10:41 +0300
committerValery Piashchynski <[email protected]>2021-01-18 18:10:41 +0300
commit4c32ad8cf5c2f70086ded5d11460be598b4c8117 (patch)
treebeea14fd1e690d77c83b43b7c75376dd74cd6ebc /plugins
parent77be5a1d2db3ca6ce1408f254391c66e0c5367e8 (diff)
Fix incorrectly set environment variables in the server plugin
Diffstat (limited to 'plugins')
-rw-r--r--plugins/http/plugin.go11
-rw-r--r--plugins/logger/plugin.go1
-rw-r--r--plugins/server/plugin.go8
3 files changed, 10 insertions, 10 deletions
diff --git a/plugins/http/plugin.go b/plugins/http/plugin.go
index 70e91cbe..222bf852 100644
--- a/plugins/http/plugin.go
+++ b/plugins/http/plugin.go
@@ -33,8 +33,8 @@ const (
// PluginName declares plugin name.
PluginName = "http"
- // EventInitSSL thrown at moment of https initialization. SSL server passed as context.
- EventInitSSL = 750
+ // RR_HTTP env variable key (internal) if the HTTP presents
+ RR_HTTP = "RR_HTTP" //nolint:golint,stylecheck
)
// Middleware interface
@@ -89,6 +89,13 @@ func (s *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Se
return errors.E(op, errors.Disabled)
}
+ // init if nil
+ if s.cfg.Env == nil {
+ s.cfg.Env = make(map[string]string)
+ }
+
+ s.cfg.Env[RR_HTTP] = "true"
+
s.pool, err = server.NewWorkerPool(context.Background(), poolImpl.Config{
Debug: s.cfg.Pool.Debug,
NumWorkers: s.cfg.Pool.NumWorkers,
diff --git a/plugins/logger/plugin.go b/plugins/logger/plugin.go
index 01bf5cc0..250127b0 100644
--- a/plugins/logger/plugin.go
+++ b/plugins/logger/plugin.go
@@ -64,6 +64,5 @@ func (z *ZapLogger) ServiceLogger(n endure.Named) (Logger, error) {
func (z *ZapLogger) Provides() []interface{} {
return []interface{}{
z.ServiceLogger,
- z.DefaultLogger,
}
}
diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go
index 8c39b783..721cbd0f 100644
--- a/plugins/server/plugin.go
+++ b/plugins/server/plugin.go
@@ -27,9 +27,7 @@ const PluginName = "server"
// RR_RELAY env variable key (internal)
const RR_RELAY = "RR_RELAY" //nolint:golint,stylecheck
// RR_RPC env variable key (internal) if the RPC presents
-const RR_RPC = "" //nolint:golint,stylecheck
-// RR_HTTP env variable key (internal) if the HTTP presents
-const RR_HTTP = "false" //nolint:golint,stylecheck
+const RR_RPC = "RR_RPC" //nolint:golint,stylecheck
// Plugin manages worker
type Plugin struct {
@@ -189,10 +187,6 @@ func (server *Plugin) setEnv(e Env) []string {
env = append(env, fmt.Sprintf("%s=%s", strings.ToUpper(k), v))
}
- // set internal env variables
- if server.cfg.HTTP != nil {
- env = append(env, fmt.Sprintf("%s=%s", RR_HTTP, "true"))
- }
if server.cfg.RPC != nil && server.cfg.RPC.Listen != "" {
env = append(env, fmt.Sprintf("%s=%s", RR_RPC, server.cfg.RPC.Listen))
}