summaryrefslogtreecommitdiff
path: root/plugins/http/plugin.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-19 18:10:39 +0300
committerGitHub <[email protected]>2021-01-19 18:10:39 +0300
commit0ff05b2732b4fd0783f959c94c54d7e39169f979 (patch)
treef50aa894ea4e5b402332f7f4a13b8c50ebb09126 /plugins/http/plugin.go
parent75ebbaac89ce8ebc3ab8de47b16e137844cfcd8a (diff)
parentd8e42927b63a0b102ce10d465a10d64bb6c02e22 (diff)
Merge pull request #487 from spiral/refactor/server_log_messagesv2.0.0-beta9
refactor(errors, logs): Uniform all errors operations, Update server log level of the server log messages
Diffstat (limited to 'plugins/http/plugin.go')
-rw-r--r--plugins/http/plugin.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/plugins/http/plugin.go b/plugins/http/plugin.go
index f35c321b..d9c1729e 100644
--- a/plugins/http/plugin.go
+++ b/plugins/http/plugin.go
@@ -71,7 +71,7 @@ type Plugin struct {
// Init must return configure svc and return true if svc hasStatus enabled. Must return error in case of
// misconfiguration. Services must not be used without proper configuration pushed first.
func (s *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Server) error {
- const op = errors.Op("http plugin init")
+ const op = errors.Op("http_plugin_init")
err := cfg.UnmarshalKey(PluginName, &s.cfg)
if err != nil {
return errors.E(op, err)
@@ -135,7 +135,7 @@ func (s *Plugin) Serve() chan error {
s.Lock()
defer s.Unlock()
- const op = errors.Op("serve http")
+ const op = errors.Op("http_plugin_serve")
errCh := make(chan error, 2)
var err error
@@ -298,7 +298,7 @@ func (s *Plugin) Name() string {
func (s *Plugin) Reset() error {
s.Lock()
defer s.Unlock()
- const op = errors.Op("http reset")
+ const op = errors.Op("http_plugin_reset")
s.log.Info("HTTP plugin got restart request. Restarting...")
s.pool.Destroy(context.Background())
s.pool = nil
@@ -387,7 +387,7 @@ func headerContainsUpgrade(r *http.Request, s *Plugin) bool {
// append RootCA to the https server TLS config
func (s *Plugin) appendRootCa() error {
- const op = errors.Op("append root CA")
+ const op = errors.Op("http_plugin_append_root_ca")
rootCAs, err := x509.SystemCertPool()
if err != nil {
return nil