Update vendor

37 files changed, 4559 insertions, 0 deletions

diff --git a/vendor/github.com/mattermost/logr/v2/.gitignore b/vendor/github.com/mattermost/logr/v2/.gitignore
new file mode 100644
index 00000000..bac5e1c1
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/.gitignore
@@ -0,0 +1,37 @@
+# Binaries for programs and plugins
+*.exe
+*.dll
+*.so
+*.dylib
+debug
+dynip
+
+# Test binary, build with `go test -c`
+*.test
+
+# Output of the go coverage tool, specifically when used with LiteIDE
+*.out
+
+# Output of profiler
+*.prof
+
+# Project-local glide cache, RE: https://github.com/Masterminds/glide/issues/736
+.glide/
+
+# IntelliJ config
+.idea
+
+# log files
+*.log
+
+# transient directories
+vendor
+output
+build
+app
+logs
+
+# test apps
+test/cmd/testapp1/testapp1
+test/cmd/simple/simple
+test/cmd/gelf/gelf
diff --git a/vendor/github.com/mattermost/logr/v2/.travis.yml b/vendor/github.com/mattermost/logr/v2/.travis.yml
new file mode 100644
index 00000000..e6c7caf1
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/.travis.yml
@@ -0,0 +1,4 @@
+language: go
+sudo: false
+go:
+  - 1.x
\ No newline at end of file
diff --git a/vendor/github.com/mattermost/logr/v2/LICENSE b/vendor/github.com/mattermost/logr/v2/LICENSE
new file mode 100644
index 00000000..3bea6788
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/LICENSE
@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2019 wiggin77
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
diff --git a/vendor/github.com/mattermost/logr/v2/README.md b/vendor/github.com/mattermost/logr/v2/README.md
new file mode 100644
index 00000000..9ee0f17c
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/README.md
@@ -0,0 +1,188 @@
+# logr
+
+[![GoDoc](https://godoc.org/github.com/mattermost/logr?status.svg)](http://godoc.org/github.com/mattermost/logr)
+[![Report Card](https://goreportcard.com/badge/github.com/mattermost/logr)](https://goreportcard.com/report/github.com/mattermost/logr)
+
+Logr is a fully asynchronous, contextual logger for Go.
+
+It is very much inspired by [Logrus](https://github.com/sirupsen/logrus) but addresses two issues:
+
+1. Logr is fully asynchronous, meaning that all formatting and writing is done in the background. Latency sensitive applications benefit from not waiting for logging to complete.
+
+2. Logr provides custom filters which provide more flexibility than Trace, Debug, Info... levels. If you need to temporarily increase verbosity of logging while tracking down a problem you can avoid the fire-hose that typically comes from Debug or Trace by using custom filters.
+
+## Concepts
+
+<!-- markdownlint-disable MD033 -->
+| entity | description |
+| ------ | ----------- |
+| Logr   | Engine instance typically instantiated once; used to configure logging.<br>```lgr,_ := logr.New()```|
+| Logger | Provides contextual logging via fields; lightweight, can be created once and accessed globally or create on demand.<br>```logger := lgr.NewLogger()```<br>```logger2 := logger.WithField("user", "Sam")```|
+| Target | A destination for log items such as console, file, database or just about anything that can be written to. Each target has its own filter/level and formatter, and any number of targets can be added to a Logr. Targets for file, syslog and any io.Writer are built-in and it is easy to create your own. You can also use any [Logrus hooks](https://github.com/sirupsen/logrus/wiki/Hooks) via a simple [adapter](https://github.com/wiggin77/logrus4logr).|
+| Filter | Determines which logging calls get written versus filtered out. Also determines which logging calls generate a stack trace.<br>```filter := &logr.StdFilter{Lvl: logr.Warn, Stacktrace: logr.Fatal}```|
+| Formatter | Formats the output. Logr includes built-in formatters for JSON and plain text with delimiters. It is easy to create your own formatters or you can also use any [Logrus formatters](https://github.com/sirupsen/logrus#formatters) via a simple [adapter](https://github.com/wiggin77/logrus4logr).<br>```formatter := &format.Plain{Delim: " \| "}```|
+
+## Usage
+
+```go
+// Create Logr instance.
+lgr,_ := logr.New()
+
+// Create a filter and formatter. Both can be shared by multiple
+// targets.
+filter := &logr.StdFilter{Lvl: logr.Warn, Stacktrace: logr.Error}
+formatter := &formatters.Plain{Delim: " | "}
+
+// WriterTarget outputs to any io.Writer
+t := targets.NewWriterTarget(filter, formatter, os.StdOut, 1000)
+lgr.AddTarget(t)
+
+// One or more Loggers can be created, shared, used concurrently,
+// or created on demand.
+logger := lgr.NewLogger().WithField("user", "Sarah")
+
+// Now we can log to the target(s).
+logger.Debug("login attempt")
+logger.Error("login failed")
+
+// Ensure targets are drained before application exit.
+lgr.Shutdown()
+```
+
+## Fields
+
+Fields allow for contextual logging, meaning information can be added to log statements without changing the statements themselves. Information can be shared across multiple logging statements thus allowing log analysis tools to group them.
+
+Fields are added via Loggers:
+
+```go
+lgr,_ := logr.New()
+// ... add targets ...
+logger := lgr.NewLogger().WithFields(logr.Fields{
+  "user": user,
+  "role": role})
+logger.Info("login attempt")
+// ... later ...
+logger.Info("login successful")
+```
+
+`Logger.WithFields` can be used to create additional Loggers that add more fields.
+
+Logr fields are inspired by and work the same as [Logrus fields](https://github.com/sirupsen/logrus#fields).
+
+## Filters
+
+Logr supports the traditional seven log levels via `logr.StdFilter`: Panic, Fatal, Error, Warning, Info, Debug, and Trace.
+
+```go
+// When added to a target, this filter will only allow
+// log statements with level severity Warn or higher.
+// It will also generate stack traces for Error or higher.
+filter := &logr.StdFilter{Lvl: logr.Warn, Stacktrace: logr.Error}
+```
+
+Logr also supports custom filters (logr.CustomFilter) which allow fine grained inclusion of log items without turning on the fire-hose.
+
+```go
+  // create custom levels; use IDs > 10.
+  LoginLevel := logr.Level{ID: 100, Name: "login ", Stacktrace: false}
+  LogoutLevel := logr.Level{ID: 101, Name: "logout", Stacktrace: false}
+
+  lgr,_ := logr.New()
+
+  // create a custom filter with custom levels.
+  filter := &logr.CustomFilter{}
+  filter.Add(LoginLevel, LogoutLevel)
+
+  formatter := &formatters.Plain{Delim: " | "}
+  tgr := targets.NewWriterTarget(filter, formatter, os.StdOut, 1000)
+  lgr.AddTarget(tgr)
+  logger := lgr.NewLogger().WithFields(logr.Fields{"user": "Bob", "role": "admin"})
+
+  logger.Log(LoginLevel, "this item will get logged")
+  logger.Debug("won't be logged since Debug wasn't added to custom filter")
+```
+
+Both filter types allow you to determine which levels require a stack trace to be output. Note that generating stack traces cannot happen fully asynchronously and thus add latency to the calling goroutine.
+
+## Targets
+
+There are built-in targets for outputting to syslog, file, or any `io.Writer`. More will be added.
+
+You can use any [Logrus hooks](https://github.com/sirupsen/logrus/wiki/Hooks) via a simple [adapter](https://github.com/wiggin77/logrus4logr).
+
+You can create your own target by implementing the [Target](./target.go) interface.
+
+Example target that outputs to `io.Writer`:
+
+```go
+type Writer struct {
+  out io.Writer
+}
+
+func NewWriterTarget(out io.Writer) *Writer {
+  w := &Writer{out: out}
+  return w
+}
+
+// Called once to initialize target.
+func (w *Writer) Init() error {
+  return nil
+}
+
+// Write will always be called by a single goroutine, so no locking needed.
+func (w *Writer) Write(p []byte, rec *logr.LogRec) (int, error) {
+  return w.out.Write(buf.Bytes())
+}
+
+// Called once to cleanup/free resources for target.
+func (w *Writer) Shutdown() error {
+  return nil
+}
+```
+
+## Formatters
+
+Logr has two built-in formatters, one for JSON and the other plain, delimited text.
+
+You can use any [Logrus formatters](https://github.com/sirupsen/logrus#formatters) via a simple [adapter](https://github.com/wiggin77/logrus4logr).
+
+You can create your own formatter by implementing the [Formatter](./formatter.go) interface:
+
+```go
+Format(rec *LogRec, stacktrace bool, buf *bytes.Buffer) (*bytes.Buffer, error)
+```
+
+## Handlers
+
+When creating the Logr instance, you can add several handlers that get called when exceptional events occur:
+
+### ```Logr.OnLoggerError(err error)```
+
+Called any time an internal logging error occurs. For example, this can happen when a target cannot connect to its data sink.
+
+It may be tempting to log this error, however there is a danger that logging this will simply generate another error and so on. If you must log it, use a target and custom level specifically for this event and ensure it cannot generate more errors.
+
+### ```Logr.OnQueueFull func(rec *LogRec, maxQueueSize int) bool```
+
+Called on an attempt to add a log record to a full Logr queue. This generally means the Logr maximum queue size is too small, or at least one target is very slow.  Logr maximum queue size can be changed before adding any targets via:
+
+```go
+lgr := logr.Logr{MaxQueueSize: 10000}
+```
+
+Returning true will drop the log record. False will block until the log record can be added, which creates a natural throttle at the expense of latency for the calling goroutine. The default is to block.
+
+### ```Logr.OnTargetQueueFull func(target Target, rec *LogRec, maxQueueSize int) bool```
+
+Called on an attempt to add a log record to a full target queue. This generally means your target's max queue size is too small, or the target is very slow to output.
+
+As with the Logr queue, returning true will drop the log record. False will block until the log record can be added, which creates a natural throttle at the expense of latency for the calling goroutine. The default is to block.
+
+### ```Logr.OnExit func(code int)  and  Logr.OnPanic func(err interface{})```
+
+OnExit and OnPanic are called when the Logger.FatalXXX and Logger.PanicXXX functions are called respectively.
+
+In both cases the default behavior is to shut down gracefully, draining all targets, and calling `os.Exit` or `panic` respectively.
+
+When adding your own handlers, be sure to call `Logr.Shutdown` before exiting the application to avoid losing log records.
diff --git a/vendor/github.com/mattermost/logr/v2/config/config.go b/vendor/github.com/mattermost/logr/v2/config/config.go
new file mode 100644
index 00000000..a93b7a25
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/config/config.go
@@ -0,0 +1,209 @@
+package config
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"os"
+	"strings"
+
+	"github.com/mattermost/logr/v2"
+	"github.com/mattermost/logr/v2/formatters"
+	"github.com/mattermost/logr/v2/targets"
+)
+
+type TargetCfg struct {
+	Type          string          `json:"type"` // one of "console", "file", "tcp", "syslog", "none".
+	Options       json.RawMessage `json:"options,omitempty"`
+	Format        string          `json:"format"` // one of "json", "plain", "gelf"
+	FormatOptions json.RawMessage `json:"format_options,omitempty"`
+	Levels        []logr.Level    `json:"levels"`
+	MaxQueueSize  int             `json:"maxqueuesize,omitempty"`
+}
+
+type ConsoleOptions struct {
+	Out string `json:"out"` // one of "stdout", "stderr"
+}
+
+type TargetFactory func(targetType string, options json.RawMessage) (logr.Target, error)
+type FormatterFactory func(format string, options json.RawMessage) (logr.Formatter, error)
+
+type Factories struct {
+	targetFactory    TargetFactory    // can be nil
+	formatterFactory FormatterFactory // can be nil
+}
+
+var removeAll = func(ti logr.TargetInfo) bool { return true }
+
+// ConfigureTargets replaces the current list of log targets with a new one based on a map
+// of name->TargetCfg. The map of TargetCfg's would typically be serialized from a JSON
+// source or can be programmatically created.
+//
+// An optional set of factories can be provided which will be called to create any target
+// types or formatters not built-in.
+//
+// To append log targets to an existing config, use `(*Logr).AddTarget` or
+// `(*Logr).AddTargetFromConfig` instead.
+func ConfigureTargets(lgr *logr.Logr, config map[string]TargetCfg, factories *Factories) error {
+	if err := lgr.RemoveTargets(context.Background(), removeAll); err != nil {
+		return fmt.Errorf("error removing existing log targets: %w", err)
+	}
+
+	if factories == nil {
+		factories = &Factories{nil, nil}
+	}
+
+	for name, tcfg := range config {
+		target, err := newTarget(tcfg.Type, tcfg.Options, factories.targetFactory)
+		if err != nil {
+			return fmt.Errorf("error creating log target %s: %w", name, err)
+		}
+
+		if target == nil {
+			continue
+		}
+
+		formatter, err := newFormatter(tcfg.Format, tcfg.FormatOptions, factories.formatterFactory)
+		if err != nil {
+			return fmt.Errorf("error creating formatter for log target %s: %w", name, err)
+		}
+
+		filter := newFilter(tcfg.Levels)
+		qSize := tcfg.MaxQueueSize
+		if qSize == 0 {
+			qSize = logr.DefaultMaxQueueSize
+		}
+
+		if err = lgr.AddTarget(target, name, filter, formatter, qSize); err != nil {
+			return fmt.Errorf("error adding log target %s: %w", name, err)
+		}
+	}
+	return nil
+}
+
+func newFilter(levels []logr.Level) logr.Filter {
+	filter := &logr.CustomFilter{}
+	for _, lvl := range levels {
+		filter.Add(lvl)
+	}
+	return filter
+}
+
+func newTarget(targetType string, options json.RawMessage, factory TargetFactory) (logr.Target, error) {
+	switch strings.ToLower(targetType) {
+	case "console":
+		c := ConsoleOptions{}
+		if len(options) != 0 {
+			if err := json.Unmarshal(options, &c); err != nil {
+				return nil, fmt.Errorf("error decoding console target options: %w", err)
+			}
+		}
+		var w io.Writer
+		switch c.Out {
+		case "stderr":
+			w = os.Stderr
+		case "stdout", "":
+			w = os.Stdout
+		default:
+			return nil, fmt.Errorf("invalid console target option '%s'", c.Out)
+		}
+		return targets.NewWriterTarget(w), nil
+	case "file":
+		fo := targets.FileOptions{}
+		if len(options) == 0 {
+			return nil, errors.New("missing file target options")
+		}
+		if err := json.Unmarshal(options, &fo); err != nil {
+			return nil, fmt.Errorf("error decoding file target options: %w", err)
+		}
+		if err := fo.CheckValid(); err != nil {
+			return nil, fmt.Errorf("invalid file target options: %w", err)
+		}
+		return targets.NewFileTarget(fo), nil
+	case "tcp":
+		to := targets.TcpOptions{}
+		if len(options) == 0 {
+			return nil, errors.New("missing TCP target options")
+		}
+		if err := json.Unmarshal(options, &to); err != nil {
+			return nil, fmt.Errorf("error decoding TCP target options: %w", err)
+		}
+		if err := to.CheckValid(); err != nil {
+			return nil, fmt.Errorf("invalid TCP target options: %w", err)
+		}
+		return targets.NewTcpTarget(&to), nil
+	case "syslog":
+		so := targets.SyslogOptions{}
+		if len(options) == 0 {
+			return nil, errors.New("missing SysLog target options")
+		}
+		if err := json.Unmarshal(options, &so); err != nil {
+			return nil, fmt.Errorf("error decoding Syslog target options: %w", err)
+		}
+		if err := so.CheckValid(); err != nil {
+			return nil, fmt.Errorf("invalid SysLog target options: %w", err)
+		}
+		return targets.NewSyslogTarget(&so)
+	case "none":
+		return nil, nil
+	default:
+		if factory != nil {
+			t, err := factory(targetType, options)
+			if err != nil || t == nil {
+				return nil, fmt.Errorf("error from target factory: %w", err)
+			}
+			return t, nil
+		}
+	}
+	return nil, fmt.Errorf("target type '%s' is unrecogized", targetType)
+}
+
+func newFormatter(format string, options json.RawMessage, factory FormatterFactory) (logr.Formatter, error) {
+	switch strings.ToLower(format) {
+	case "json":
+		j := formatters.JSON{}
+		if len(options) != 0 {
+			if err := json.Unmarshal(options, &j); err != nil {
+				return nil, fmt.Errorf("error decoding JSON formatter options: %w", err)
+			}
+			if err := j.CheckValid(); err != nil {
+				return nil, fmt.Errorf("invalid JSON formatter options: %w", err)
+			}
+		}
+		return &j, nil
+	case "plain":
+		p := formatters.Plain{}
+		if len(options) != 0 {
+			if err := json.Unmarshal(options, &p); err != nil {
+				return nil, fmt.Errorf("error decoding Plain formatter options: %w", err)
+			}
+			if err := p.CheckValid(); err != nil {
+				return nil, fmt.Errorf("invalid plain formatter options: %w", err)
+			}
+		}
+		return &p, nil
+	case "gelf":
+		g := formatters.Gelf{}
+		if len(options) != 0 {
+			if err := json.Unmarshal(options, &g); err != nil {
+				return nil, fmt.Errorf("error decoding Gelf formatter options: %w", err)
+			}
+			if err := g.CheckValid(); err != nil {
+				return nil, fmt.Errorf("invalid GELF formatter options: %w", err)
+			}
+		}
+		return &g, nil
+
+	default:
+		if factory != nil {
+			f, err := factory(format, options)
+			if err != nil || f == nil {
+				return nil, fmt.Errorf("error from formatter factory: %w", err)
+			}
+			return f, nil
+		}
+	}
+	return nil, fmt.Errorf("format '%s' is unrecogized", format)
+}
diff --git a/vendor/github.com/mattermost/logr/v2/config/sample-config.json b/vendor/github.com/mattermost/logr/v2/config/sample-config.json
new file mode 100644
index 00000000..540bafbb
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/config/sample-config.json
@@ -0,0 +1,90 @@
+{
+    "sample-console": {
+        "type": "console",
+        "options": {
+            "out": "stdout"
+        },
+        "format": "plain",
+        "format_options": {
+            "delim": " | "
+        },
+        "levels": [
+            {"id": 5, "name": "debug"},
+            {"id": 4, "name": "info"},
+            {"id": 3, "name": "warn"},
+            {"id": 2, "name": "error", "stacktrace": true},
+            {"id": 1, "name": "fatal", "stacktrace": true},
+            {"id": 0, "name": "panic", "stacktrace": true}
+        ],
+        "maxqueuesize": 1000
+    },
+    "sample-file": {
+        "type": "file",
+        "options": {
+            "filename": "test.log",
+            "max_size": 1000000,
+            "max_age": 1,
+            "max_backups": 10,
+            "compress": true
+        },
+        "format": "json",
+        "format_options": {
+        },
+        "levels": [
+            {"id": 5, "name": "debug"},
+            {"id": 4, "name": "info"},
+            {"id": 3, "name": "warn"},
+            {"id": 2, "name": "error", "stacktrace": true},
+            {"id": 1, "name": "fatal", "stacktrace": true},
+            {"id": 0, "name": "panic", "stacktrace": true}
+        ],
+        "maxqueuesize": 1000
+    },
+    "sample-tcp": {
+        "type": "tcp",
+        "options": {
+            "host": "localhost",
+            "port": 18066,
+            "tls": false,
+            "cert": "",
+            "insecure": false
+        },
+        "format": "gelf",
+        "format_options": {
+            "hostname": "server01"
+        },
+        "levels": [
+            {"id": 5, "name": "debug"},
+            {"id": 4, "name": "info"},
+            {"id": 3, "name": "warn"},
+            {"id": 2, "name": "error", "stacktrace": true},
+            {"id": 1, "name": "fatal", "stacktrace": true},
+            {"id": 0, "name": "panic", "stacktrace": true}
+        ],
+        "maxqueuesize": 1000
+    },
+    "sample-syslog": {
+        "type": "syslog",
+        "options": {
+            "host": "localhost",
+            "port": 18066,
+            "tls": false,
+            "cert": "",
+            "insecure": false,
+            "tag": "testapp"
+        },
+        "format": "plain",
+        "format_options": {
+            "delim": "  "
+        },
+        "levels": [
+            {"id": 5, "name": "debug"},
+            {"id": 4, "name": "info"},
+            {"id": 3, "name": "warn"},
+            {"id": 2, "name": "error", "stacktrace": true},
+            {"id": 1, "name": "fatal", "stacktrace": true},
+            {"id": 0, "name": "panic", "stacktrace": true}
+        ],
+        "maxqueuesize": 1000
+    }
+}
diff --git a/vendor/github.com/mattermost/logr/v2/const.go b/vendor/github.com/mattermost/logr/v2/const.go
new file mode 100644
index 00000000..29d92241
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/const.go
@@ -0,0 +1,34 @@
+package logr
+
+import "time"
+
+// Defaults.
+const (
+	// DefaultMaxQueueSize is the default maximum queue size for Logr instances.
+	DefaultMaxQueueSize = 1000
+
+	// DefaultMaxStackFrames is the default maximum max number of stack frames collected
+	// when generating stack traces for logging.
+	DefaultMaxStackFrames = 30
+
+	// MaxLevelID is the maximum value of a level ID. Some level cache implementations will
+	// allocate a cache of this size. Cannot exceed uint.
+	MaxLevelID = 65535
+
+	// DefaultEnqueueTimeout is the default amount of time a log record can take to be queued.
+	// This only applies to blocking enqueue which happen after `logr.OnQueueFull` is called
+	// and returns false.
+	DefaultEnqueueTimeout = time.Second * 30
+
+	// DefaultShutdownTimeout is the default amount of time `logr.Shutdown` can execute before
+	// timing out.
+	DefaultShutdownTimeout = time.Second * 30
+
+	// DefaultFlushTimeout is the default amount of time `logr.Flush` can execute before
+	// timing out.
+	DefaultFlushTimeout = time.Second * 30
+
+	// DefaultMaxPooledBuffer is the maximum size a pooled buffer can be.
+	// Buffers that grow beyond this size are garbage collected.
+	DefaultMaxPooledBuffer = 1024 * 1024
+)
diff --git a/vendor/github.com/mattermost/logr/v2/field.go b/vendor/github.com/mattermost/logr/v2/field.go
new file mode 100644
index 00000000..5725d0a1
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/field.go
@@ -0,0 +1,403 @@
+package logr
+
+import (
+	"errors"
+	"fmt"
+	"io"
+	"reflect"
+	"strconv"
+	"time"
+)
+
+var (
+	Comma   = []byte{','}
+	Equals  = []byte{'='}
+	Space   = []byte{' '}
+	Newline = []byte{'\n'}
+	Quote   = []byte{'"'}
+	Colon   = []byte{'"'}
+)
+
+// LogCloner is implemented by `Any` types that require a clone to be provided
+// to the logger because the original may mutate.
+type LogCloner interface {
+	LogClone() interface{}
+}
+
+// LogWriter is implemented by `Any` types that provide custom formatting for
+// log output. A string representation of the type should be written directly to
+// the `io.Writer`.
+type LogWriter interface {
+	LogWrite(w io.Writer) error
+}
+
+type FieldType uint8
+
+const (
+	UnknownType FieldType = iota
+	StringType
+	StringerType
+	StructType
+	ErrorType
+	BoolType
+	TimestampMillisType
+	TimeType
+	DurationType
+	Int64Type
+	Int32Type
+	IntType
+	Uint64Type
+	Uint32Type
+	UintType
+	Float64Type
+	Float32Type
+	BinaryType
+	ArrayType
+	MapType
+)
+
+type Field struct {
+	Key       string
+	Type      FieldType
+	Integer   int64
+	Float     float64
+	String    string
+	Interface interface{}
+}
+
+func quoteString(w io.Writer, s string, shouldQuote func(s string) bool) error {
+	b := shouldQuote(s)
+	if b {
+		if _, err := w.Write(Quote); err != nil {
+			return err
+		}
+	}
+
+	if _, err := w.Write([]byte(s)); err != nil {
+		return err
+	}
+
+	if b {
+		if _, err := w.Write(Quote); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+// ValueString converts a known type to a string using default formatting.
+// This is called lazily by a formatter.
+// Formatters can provide custom formatting or types passed via `Any` can implement
+// the `LogString` interface to generate output for logging.
+// If the optional shouldQuote callback is provided, then it will be called for any
+// string output that could potentially need to be quoted.
+func (f Field) ValueString(w io.Writer, shouldQuote func(s string) bool) error {
+	if shouldQuote == nil {
+		shouldQuote = func(s string) bool { return false }
+	}
+	var err error
+	switch f.Type {
+	case StringType:
+		err = quoteString(w, f.String, shouldQuote)
+
+	case StringerType:
+		s, ok := f.Interface.(fmt.Stringer)
+		if ok {
+			err = quoteString(w, s.String(), shouldQuote)
+		} else if f.Interface == nil {
+			err = quoteString(w, "", shouldQuote)
+		} else {
+			err = fmt.Errorf("invalid fmt.Stringer for key %s", f.Key)
+		}
+
+	case StructType:
+		s, ok := f.Interface.(LogWriter)
+		if ok {
+			err = s.LogWrite(w)
+			break
+		}
+		// structs that do not implement LogWriter fall back to reflection via Printf.
+		// TODO: create custom reflection-based encoder.
+		_, err = fmt.Fprintf(w, "%v", f.Interface)
+
+	case ErrorType:
+		// TODO: create custom error encoder.
+		err = quoteString(w, fmt.Sprintf("%v", f.Interface), shouldQuote)
+
+	case BoolType:
+		var b bool
+		if f.Integer != 0 {
+			b = true
+		}
+		_, err = io.WriteString(w, strconv.FormatBool(b))
+
+	case TimestampMillisType:
+		ts := time.Unix(f.Integer/1000, (f.Integer%1000)*int64(time.Millisecond))
+		err = quoteString(w, ts.UTC().Format(TimestampMillisFormat), shouldQuote)
+
+	case TimeType:
+		t, ok := f.Interface.(time.Time)
+		if !ok {
+			err = errors.New("invalid time")
+			break
+		}
+		err = quoteString(w, t.Format(DefTimestampFormat), shouldQuote)
+
+	case DurationType:
+		_, err = fmt.Fprintf(w, "%s", time.Duration(f.Integer))
+
+	case Int64Type, Int32Type, IntType:
+		_, err = io.WriteString(w, strconv.FormatInt(f.Integer, 10))
+
+	case Uint64Type, Uint32Type, UintType:
+		_, err = io.WriteString(w, strconv.FormatUint(uint64(f.Integer), 10))
+
+	case Float64Type, Float32Type:
+		size := 64
+		if f.Type == Float32Type {
+			size = 32
+		}
+		err = quoteString(w, strconv.FormatFloat(f.Float, 'f', -1, size), shouldQuote)
+
+	case BinaryType:
+		b, ok := f.Interface.([]byte)
+		if ok {
+			_, err = fmt.Fprintf(w, "[%X]", b)
+			break
+		}
+		_, err = fmt.Fprintf(w, "[%v]", f.Interface)
+
+	case ArrayType:
+		a := reflect.ValueOf(f.Interface)
+	arr:
+		for i := 0; i < a.Len(); i++ {
+			item := a.Index(i)
+			switch v := item.Interface().(type) {
+			case LogWriter:
+				if err = v.LogWrite(w); err != nil {
+					break arr
+				}
+			case fmt.Stringer:
+				if err = quoteString(w, v.String(), shouldQuote); err != nil {
+					break arr
+				}
+			default:
+				s := fmt.Sprintf("%v", v)
+				if err = quoteString(w, s, shouldQuote); err != nil {
+					break arr
+				}
+			}
+			if _, err = w.Write(Comma); err != nil {
+				break arr
+			}
+		}
+
+	case MapType:
+		a := reflect.ValueOf(f.Interface)
+		iter := a.MapRange()
+	it:
+		for iter.Next() {
+			if _, err = io.WriteString(w, iter.Key().String()); err != nil {
+				break it
+			}
+			if _, err = w.Write(Equals); err != nil {
+				break it
+			}
+			val := iter.Value().Interface()
+			switch v := val.(type) {
+			case LogWriter:
+				if err = v.LogWrite(w); err != nil {
+					break it
+				}
+			case fmt.Stringer:
+				if err = quoteString(w, v.String(), shouldQuote); err != nil {
+					break it
+				}
+			default:
+				s := fmt.Sprintf("%v", v)
+				if err = quoteString(w, s, shouldQuote); err != nil {
+					break it
+				}
+			}
+			if _, err = w.Write(Comma); err != nil {
+				break it
+			}
+		}
+
+	case UnknownType:
+		_, err = fmt.Fprintf(w, "%v", f.Interface)
+
+	default:
+		err = fmt.Errorf("invalid type %d", f.Type)
+	}
+	return err
+}
+
+func nilField(key string) Field {
+	return String(key, "")
+}
+
+func fieldForAny(key string, val interface{}) Field {
+	switch v := val.(type) {
+	case LogCloner:
+		if v == nil {
+			return nilField(key)
+		}
+		c := v.LogClone()
+		return Field{Key: key, Type: StructType, Interface: c}
+	case *LogCloner:
+		if v == nil {
+			return nilField(key)
+		}
+		c := (*v).LogClone()
+		return Field{Key: key, Type: StructType, Interface: c}
+	case LogWriter:
+		if v == nil {
+			return nilField(key)
+		}
+		return Field{Key: key, Type: StructType, Interface: v}
+	case *LogWriter:
+		if v == nil {
+			return nilField(key)
+		}
+		return Field{Key: key, Type: StructType, Interface: *v}
+	case bool:
+		return Bool(key, v)
+	case *bool:
+		if v == nil {
+			return nilField(key)
+		}
+		return Bool(key, *v)
+	case float64:
+		return Float64(key, v)
+	case *float64:
+		if v == nil {
+			return nilField(key)
+		}
+		return Float64(key, *v)
+	case float32:
+		return Float32(key, v)
+	case *float32:
+		if v == nil {
+			return nilField(key)
+		}
+		return Float32(key, *v)
+	case int:
+		return Int(key, v)
+	case *int:
+		if v == nil {
+			return nilField(key)
+		}
+		return Int(key, *v)
+	case int64:
+		return Int64(key, v)
+	case *int64:
+		if v == nil {
+			return nilField(key)
+		}
+		return Int64(key, *v)
+	case int32:
+		return Int32(key, v)
+	case *int32:
+		if v == nil {
+			return nilField(key)
+		}
+		return Int32(key, *v)
+	case int16:
+		return Int32(key, int32(v))
+	case *int16:
+		if v == nil {
+			return nilField(key)
+		}
+		return Int32(key, int32(*v))
+	case int8:
+		return Int32(key, int32(v))
+	case *int8:
+		if v == nil {
+			return nilField(key)
+		}
+		return Int32(key, int32(*v))
+	case string:
+		return String(key, v)
+	case *string:
+		if v == nil {
+			return nilField(key)
+		}
+		return String(key, *v)
+	case uint:
+		return Uint(key, v)
+	case *uint:
+		if v == nil {
+			return nilField(key)
+		}
+		return Uint(key, *v)
+	case uint64:
+		return Uint64(key, v)
+	case *uint64:
+		if v == nil {
+			return nilField(key)
+		}
+		return Uint64(key, *v)
+	case uint32:
+		return Uint32(key, v)
+	case *uint32:
+		if v == nil {
+			return nilField(key)
+		}
+		return Uint32(key, *v)
+	case uint16:
+		return Uint32(key, uint32(v))
+	case *uint16:
+		if v == nil {
+			return nilField(key)
+		}
+		return Uint32(key, uint32(*v))
+	case uint8:
+		return Uint32(key, uint32(v))
+	case *uint8:
+		if v == nil {
+			return nilField(key)
+		}
+		return Uint32(key, uint32(*v))
+	case []byte:
+		if v == nil {
+			return nilField(key)
+		}
+		return Field{Key: key, Type: BinaryType, Interface: v}
+	case time.Time:
+		return Time(key, v)
+	case *time.Time:
+		if v == nil {
+			return nilField(key)
+		}
+		return Time(key, *v)
+	case time.Duration:
+		return Duration(key, v)
+	case *time.Duration:
+		if v == nil {
+			return nilField(key)
+		}
+		return Duration(key, *v)
+	case error:
+		return NamedErr(key, v)
+	case fmt.Stringer:
+		if v == nil {
+			return nilField(key)
+		}
+		return Field{Key: key, Type: StringerType, Interface: v}
+	case *fmt.Stringer:
+		if v == nil {
+			return nilField(key)
+		}
+		return Field{Key: key, Type: StringerType, Interface: *v}
+	default:
+		return Field{Key: key, Type: UnknownType, Interface: val}
+	}
+}
+
+// FieldSorter provides sorting of an array of fields by key.
+type FieldSorter []Field
+
+func (fs FieldSorter) Len() int           { return len(fs) }
+func (fs FieldSorter) Less(i, j int) bool { return fs[i].Key < fs[j].Key }
+func (fs FieldSorter) Swap(i, j int)      { fs[i], fs[j] = fs[j], fs[i] }
diff --git a/vendor/github.com/mattermost/logr/v2/fieldapi.go b/vendor/github.com/mattermost/logr/v2/fieldapi.go
new file mode 100644
index 00000000..58b12280
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/fieldapi.go
@@ -0,0 +1,110 @@
+package logr
+
+import (
+	"fmt"
+	"time"
+)
+
+// Any picks the best supported field type based on type of val.
+// For best performance when passing a struct (or struct pointer),
+// implement `logr.LogWriter` on the struct, otherwise reflection
+// will be used to generate a string representation.
+func Any(key string, val interface{}) Field {
+	return fieldForAny(key, val)
+}
+
+// Int64 constructs a field containing a key and Int64 value.
+func Int64(key string, val int64) Field {
+	return Field{Key: key, Type: Int64Type, Integer: val}
+}
+
+// Int32 constructs a field containing a key and Int32 value.
+func Int32(key string, val int32) Field {
+	return Field{Key: key, Type: Int32Type, Integer: int64(val)}
+}
+
+// Int constructs a field containing a key and Int value.
+func Int(key string, val int) Field {
+	return Field{Key: key, Type: IntType, Integer: int64(val)}
+}
+
+// Uint64 constructs a field containing a key and Uint64 value.
+func Uint64(key string, val uint64) Field {
+	return Field{Key: key, Type: Uint64Type, Integer: int64(val)}
+}
+
+// Uint32 constructs a field containing a key and Uint32 value.
+func Uint32(key string, val uint32) Field {
+	return Field{Key: key, Type: Uint32Type, Integer: int64(val)}
+}
+
+// Uint constructs a field containing a key and Uint value.
+func Uint(key string, val uint) Field {
+	return Field{Key: key, Type: UintType, Integer: int64(val)}
+}
+
+// Float64 constructs a field containing a key and Float64 value.
+func Float64(key string, val float64) Field {
+	return Field{Key: key, Type: Float64Type, Float: val}
+}
+
+// Float32 constructs a field containing a key and Float32 value.
+func Float32(key string, val float32) Field {
+	return Field{Key: key, Type: Float32Type, Float: float64(val)}
+}
+
+// String constructs a field containing a key and String value.
+func String(key string, val string) Field {
+	return Field{Key: key, Type: StringType, String: val}
+}
+
+// Stringer constructs a field containing a key and a `fmt.Stringer` value.
+// The `String` method will be called in lazy fashion.
+func Stringer(key string, val fmt.Stringer) Field {
+	return Field{Key: key, Type: StringerType, Interface: val}
+}
+
+// Err constructs a field containing a default key ("error") and error value.
+func Err(err error) Field {
+	return NamedErr("error", err)
+}
+
+// NamedErr constructs a field containing a key and error value.
+func NamedErr(key string, err error) Field {
+	return Field{Key: key, Type: ErrorType, Interface: err}
+}
+
+// Bool constructs a field containing a key and bool value.
+func Bool(key string, val bool) Field {
+	var b int64
+	if val {
+		b = 1
+	}
+	return Field{Key: key, Type: BoolType, Integer: b}
+}
+
+// Time constructs a field containing a key and time.Time value.
+func Time(key string, val time.Time) Field {
+	return Field{Key: key, Type: TimeType, Interface: val}
+}
+
+// Duration constructs a field containing a key and time.Duration value.
+func Duration(key string, val time.Duration) Field {
+	return Field{Key: key, Type: DurationType, Integer: int64(val)}
+}
+
+// Millis constructs a field containing a key and timestamp value.
+// The timestamp is expected to be milliseconds since Jan 1, 1970 UTC.
+func Millis(key string, val int64) Field {
+	return Field{Key: key, Type: TimestampMillisType, Integer: val}
+}
+
+// Array constructs a field containing a key and array value.
+func Array(key string, val interface{}) Field {
+	return Field{Key: key, Type: ArrayType, Interface: val}
+}
+
+// Map constructs a field containing a key and map value.
+func Map(key string, val interface{}) Field {
+	return Field{Key: key, Type: MapType, Interface: val}
+}
diff --git a/vendor/github.com/mattermost/logr/v2/filter.go b/vendor/github.com/mattermost/logr/v2/filter.go
new file mode 100644
index 00000000..a52a7cf4
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/filter.go
@@ -0,0 +1,10 @@
+package logr
+
+// Filter allows targets to determine which Level(s) are active
+// for logging and which Level(s) require a stack trace to be output.
+// A default implementation using "panic, fatal..." is provided, and
+// a more flexible alternative implementation is also provided that
+// allows any number of custom levels.
+type Filter interface {
+	GetEnabledLevel(level Level) (Level, bool)
+}
diff --git a/vendor/github.com/mattermost/logr/v2/filtercustom.go b/vendor/github.com/mattermost/logr/v2/filtercustom.go
new file mode 100644
index 00000000..c20f2811
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/filtercustom.go
@@ -0,0 +1,47 @@
+package logr
+
+import (
+	"sync"
+)
+
+// CustomFilter allows targets to enable logging via a list of discrete levels.
+type CustomFilter struct {
+	mux    sync.RWMutex
+	levels map[LevelID]Level
+}
+
+// NewCustomFilter creates a filter supporting discrete log levels.
+func NewCustomFilter(levels ...Level) *CustomFilter {
+	filter := &CustomFilter{}
+	filter.Add(levels...)
+	return filter
+}
+
+// GetEnabledLevel returns the Level with the specified Level.ID and whether the level
+// is enabled for this filter.
+func (cf *CustomFilter) GetEnabledLevel(level Level) (Level, bool) {
+	cf.mux.RLock()
+	defer cf.mux.RUnlock()
+	levelEnabled, ok := cf.levels[level.ID]
+
+	if ok && levelEnabled.Name == "" {
+		levelEnabled.Name = level.Name
+	}
+
+	return levelEnabled, ok
+}
+
+// Add adds one or more levels to the list. Adding a level enables logging for
+// that level on any targets using this CustomFilter.
+func (cf *CustomFilter) Add(levels ...Level) {
+	cf.mux.Lock()
+	defer cf.mux.Unlock()
+
+	if cf.levels == nil {
+		cf.levels = make(map[LevelID]Level)
+	}
+
+	for _, s := range levels {
+		cf.levels[s.ID] = s
+	}
+}
diff --git a/vendor/github.com/mattermost/logr/v2/filterstd.go b/vendor/github.com/mattermost/logr/v2/filterstd.go
new file mode 100644
index 00000000..7f38a332
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/filterstd.go
@@ -0,0 +1,65 @@
+package logr
+
+// StdFilter allows targets to filter via classic log levels where any level
+// beyond a certain verbosity/severity is enabled.
+type StdFilter struct {
+	Lvl        Level
+	Stacktrace Level
+}
+
+// GetEnabledLevel returns the Level with the specified Level.ID and whether the level
+// is enabled for this filter.
+func (lt StdFilter) GetEnabledLevel(level Level) (Level, bool) {
+	enabled := level.ID <= lt.Lvl.ID
+	var levelEnabled Level
+
+	if enabled {
+		switch level.ID {
+		case Panic.ID:
+			levelEnabled = Panic
+		case Fatal.ID:
+			levelEnabled = Fatal
+		case Error.ID:
+			levelEnabled = Error
+		case Warn.ID:
+			levelEnabled = Warn
+		case Info.ID:
+			levelEnabled = Info
+		case Debug.ID:
+			levelEnabled = Debug
+		case Trace.ID:
+			levelEnabled = Trace
+		default:
+			levelEnabled = level
+		}
+	}
+	return levelEnabled, enabled
+}
+
+// IsEnabled returns true if the specified Level is at or above this verbosity. Also
+// determines if a stack trace is required.
+func (lt StdFilter) IsEnabled(level Level) bool {
+	return level.ID <= lt.Lvl.ID
+}
+
+// IsStacktraceEnabled returns true if the specified Level requires a stack trace.
+func (lt StdFilter) IsStacktraceEnabled(level Level) bool {
+	return level.ID <= lt.Stacktrace.ID
+}
+
+var (
+	// Panic is the highest level of severity.
+	Panic = Level{ID: 0, Name: "panic", Color: Red}
+	// Fatal designates a catastrophic error.
+	Fatal = Level{ID: 1, Name: "fatal", Color: Red}
+	// Error designates a serious but possibly recoverable error.
+	Error = Level{ID: 2, Name: "error", Color: Red}
+	// Warn designates non-critical error.
+	Warn = Level{ID: 3, Name: "warn", Color: Yellow}
+	// Info designates information regarding application events.
+	Info = Level{ID: 4, Name: "info", Color: Cyan}
+	// Debug designates verbose information typically used for debugging.
+	Debug = Level{ID: 5, Name: "debug", Color: NoColor}
+	// Trace designates the highest verbosity of log output.
+	Trace = Level{ID: 6, Name: "trace", Color: NoColor}
+)
diff --git a/vendor/github.com/mattermost/logr/v2/formatter.go b/vendor/github.com/mattermost/logr/v2/formatter.go
new file mode 100644
index 00000000..c8bb9b70
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/formatter.go
@@ -0,0 +1,184 @@
+package logr
+
+import (
+	"bytes"
+	"io"
+	"runtime"
+	"strconv"
+)
+
+// Formatter turns a LogRec into a formatted string.
+type Formatter interface {
+	// IsStacktraceNeeded returns true if this formatter requires a stacktrace to be
+	// generated for each LogRecord. Enabling features such as `Caller` field require
+	// a stacktrace.
+	IsStacktraceNeeded() bool
+
+	// Format converts a log record to bytes. If buf is not nil then it will be
+	// be filled with the formatted results, otherwise a new buffer will be allocated.
+	Format(rec *LogRec, level Level, buf *bytes.Buffer) (*bytes.Buffer, error)
+}
+
+const (
+	// DefTimestampFormat is the default time stamp format used by Plain formatter and others.
+	DefTimestampFormat = "2006-01-02 15:04:05.000 Z07:00"
+
+	// TimestampMillisFormat is the format for logging milliseconds UTC
+	TimestampMillisFormat = "Jan _2 15:04:05.000"
+)
+
+type Writer struct {
+	io.Writer
+}
+
+func (w Writer) Writes(elems ...[]byte) (int, error) {
+	var count int
+	for _, e := range elems {
+		if c, err := w.Write(e); err != nil {
+			return count + c, err
+		} else {
+			count += c
+		}
+	}
+	return count, nil
+}
+
+// DefaultFormatter is the default formatter, outputting only text with
+// no colors and a space delimiter. Use `format.Plain` instead.
+type DefaultFormatter struct {
+}
+
+// IsStacktraceNeeded always returns false for default formatter since the
+// `Caller` field is not supported.
+func (p *DefaultFormatter) IsStacktraceNeeded() bool {
+	return false
+}
+
+// Format converts a log record to bytes.
+func (p *DefaultFormatter) Format(rec *LogRec, level Level, buf *bytes.Buffer) (*bytes.Buffer, error) {
+	if buf == nil {
+		buf = &bytes.Buffer{}
+	}
+	timestampFmt := DefTimestampFormat
+
+	buf.WriteString(rec.Time().Format(timestampFmt))
+	buf.Write(Space)
+
+	buf.WriteString(level.Name)
+	buf.Write(Space)
+
+	buf.WriteString(rec.Msg())
+	buf.Write(Space)
+
+	fields := rec.Fields()
+	if len(fields) > 0 {
+		if err := WriteFields(buf, fields, Space, NoColor); err != nil {
+			return nil, err
+		}
+	}
+
+	if level.Stacktrace {
+		frames := rec.StackFrames()
+		if len(frames) > 0 {
+			buf.Write(Newline)
+			if err := WriteStacktrace(buf, rec.StackFrames()); err != nil {
+				return nil, err
+			}
+		}
+	}
+	buf.Write(Newline)
+
+	return buf, nil
+}
+
+// WriteFields writes zero or more name value pairs to the io.Writer.
+// The pairs output in key=value format with optional separator between fields.
+func WriteFields(w io.Writer, fields []Field, separator []byte, color Color) error {
+	ws := Writer{w}
+
+	sep := []byte{}
+	for _, field := range fields {
+		if err := writeField(ws, field, sep, color); err != nil {
+			return err
+		}
+		sep = separator
+	}
+	return nil
+}
+
+func writeField(ws Writer, field Field, sep []byte, color Color) error {
+	if len(sep) != 0 {
+		if _, err := ws.Write(sep); err != nil {
+			return err
+		}
+	}
+	if err := WriteWithColor(ws, field.Key, color); err != nil {
+		return err
+	}
+	if _, err := ws.Write(Equals); err != nil {
+		return err
+	}
+	return field.ValueString(ws, shouldQuote)
+}
+
+// shouldQuote returns true if val contains any characters that might be unsafe
+// when injecting log output into an aggregator, viewer or report.
+func shouldQuote(val string) bool {
+	for _, c := range val {
+		if !((c >= '0' && c <= '9') ||
+			(c >= 'a' && c <= 'z') ||
+			(c >= 'A' && c <= 'Z') ||
+			c == '-' || c == '.' || c == '_' || c == '/' || c == '@' || c == '^' || c == '+') {
+			return true
+		}
+	}
+	return false
+}
+
+// WriteStacktrace formats and outputs a stack trace to an io.Writer.
+func WriteStacktrace(w io.Writer, frames []runtime.Frame) error {
+	ws := Writer{w}
+	for _, frame := range frames {
+		if frame.Function != "" {
+			if _, err := ws.Writes(Space, Space, []byte(frame.Function), Newline); err != nil {
+				return err
+			}
+		}
+		if frame.File != "" {
+			s := strconv.FormatInt(int64(frame.Line), 10)
+			if _, err := ws.Writes([]byte{' ', ' ', ' ', ' ', ' ', ' '}, []byte(frame.File), Colon, []byte(s), Newline); err != nil {
+				return err
+			}
+		}
+	}
+	return nil
+}
+
+// WriteWithColor outputs a string with the specified ANSI color.
+func WriteWithColor(w io.Writer, s string, color Color) error {
+	var err error
+
+	writer := func(buf []byte) {
+		if err != nil {
+			return
+		}
+		_, err = w.Write(buf)
+	}
+
+	if color != NoColor {
+		writer(AnsiColorPrefix)
+		writer([]byte(strconv.FormatInt(int64(color), 10)))
+		writer(AnsiColorSuffix)
+	}
+
+	if err == nil {
+		_, err = io.WriteString(w, s)
+	}
+
+	if color != NoColor {
+		writer(AnsiColorPrefix)
+		writer([]byte(strconv.FormatInt(int64(NoColor), 10)))
+		writer(AnsiColorSuffix)
+	}
+	return err
+}
diff --git a/vendor/github.com/mattermost/logr/v2/formatters/gelf.go b/vendor/github.com/mattermost/logr/v2/formatters/gelf.go
new file mode 100644
index 00000000..9dece13c
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/formatters/gelf.go
@@ -0,0 +1,152 @@
+package formatters
+
+import (
+	"bytes"
+	"fmt"
+	"net"
+	"os"
+	"strings"
+
+	"github.com/francoispqt/gojay"
+	"github.com/mattermost/logr/v2"
+)
+
+const (
+	GelfVersion      = "1.1"
+	GelfVersionKey   = "version"
+	GelfHostKey      = "host"
+	GelfShortKey     = "short_message"
+	GelfFullKey      = "full_message"
+	GelfTimestampKey = "timestamp"
+	GelfLevelKey     = "level"
+)
+
+// Gelf formats log records as GELF rcords (https://docs.graylog.org/en/4.0/pages/gelf.html).
+type Gelf struct {
+	// Hostname allows a custom hostname, otherwise os.Hostname is used
+	Hostname string `json:"hostname"`
+
+	// EnableCaller enables output of the file and line number that emitted a log record.
+	EnableCaller bool `json:"enable_caller"`
+
+	// FieldSorter allows custom sorting for the context fields.
+	FieldSorter func(fields []logr.Field) []logr.Field `json:"-"`
+}
+
+func (g *Gelf) CheckValid() error {
+	return nil
+}
+
+// IsStacktraceNeeded returns true if a stacktrace is needed so we can output the `Caller` field.
+func (g *Gelf) IsStacktraceNeeded() bool {
+	return g.EnableCaller
+}
+
+// Format converts a log record to bytes in GELF format.
+func (g *Gelf) Format(rec *logr.LogRec, level logr.Level, buf *bytes.Buffer) (*bytes.Buffer, error) {
+	if buf == nil {
+		buf = &bytes.Buffer{}
+	}
+	enc := gojay.BorrowEncoder(buf)
+	defer func() {
+		enc.Release()
+	}()
+
+	gr := gelfRecord{
+		LogRec: rec,
+		Gelf:   g,
+		level:  level,
+		sorter: g.FieldSorter,
+	}
+
+	err := enc.EncodeObject(gr)
+	if err != nil {
+		return nil, err
+	}
+
+	buf.WriteByte(0)
+	return buf, nil
+}
+
+type gelfRecord struct {
+	*logr.LogRec
+	*Gelf
+	level  logr.Level
+	sorter func(fields []logr.Field) []logr.Field
+}
+
+// MarshalJSONObject encodes the LogRec as JSON.
+func (gr gelfRecord) MarshalJSONObject(enc *gojay.Encoder) {
+	enc.AddStringKey(GelfVersionKey, GelfVersion)
+	enc.AddStringKey(GelfHostKey, gr.getHostname())
+	enc.AddStringKey(GelfShortKey, gr.Msg())
+
+	if gr.level.Stacktrace {
+		frames := gr.StackFrames()
+		if len(frames) != 0 {
+			var sbuf strings.Builder
+			for _, frame := range frames {
+				fmt.Fprintf(&sbuf, "%s\n  %s:%d\n", frame.Function, frame.File, frame.Line)
+			}
+			enc.AddStringKey(GelfFullKey, sbuf.String())
+		}
+	}
+
+	secs := float64(gr.Time().UTC().Unix())
+	millis := float64(gr.Time().Nanosecond() / 1000000)
+	ts := secs + (millis / 1000)
+	enc.AddFloat64Key(GelfTimestampKey, ts)
+
+	enc.AddUint32Key(GelfLevelKey, uint32(gr.level.ID))
+
+	var fields []logr.Field
+	if gr.EnableCaller {
+		caller := logr.Field{
+			Key:    "_caller",
+			Type:   logr.StringType,
+			String: gr.LogRec.Caller(),
+		}
+		fields = append(fields, caller)
+	}
+
+	fields = append(fields, gr.Fields()...)
+	if gr.sorter != nil {
+		fields = gr.sorter(fields)
+	}
+
+	if len(fields) > 0 {
+		for _, field := range fields {
+			if !strings.HasPrefix("_", field.Key) {
+				field.Key = "_" + field.Key
+			}
+			if err := encodeField(enc, field); err != nil {
+				enc.AddStringKey(field.Key, fmt.Sprintf("<error encoding field: %v>", err))
+			}
+		}
+	}
+}
+
+// IsNil returns true if the gelf record pointer is nil.
+func (gr gelfRecord) IsNil() bool {
+	return gr.LogRec == nil
+}
+
+func (g *Gelf) getHostname() string {
+	if g.Hostname != "" {
+		return g.Hostname
+	}
+	h, err := os.Hostname()
+	if err == nil {
+		return h
+	}
+
+	// get the egress IP by fake dialing any address. UDP ensures no dial.
+	conn, err := net.Dial("udp", "8.8.8.8:80")
+	if err != nil {
+		return "unknown"
+	}
+	defer conn.Close()
+
+	local := conn.LocalAddr().(*net.UDPAddr)
+	return local.IP.String()
+}
diff --git a/vendor/github.com/mattermost/logr/v2/formatters/json.go b/vendor/github.com/mattermost/logr/v2/formatters/json.go
new file mode 100644
index 00000000..172b9612
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/formatters/json.go
@@ -0,0 +1,273 @@
+package formatters
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"runtime"
+	"strings"
+	"sync"
+
+	"github.com/francoispqt/gojay"
+	"github.com/mattermost/logr/v2"
+)
+
+// JSON formats log records as JSON.
+type JSON struct {
+	// DisableTimestamp disables output of timestamp field.
+	DisableTimestamp bool `json:"disable_timestamp"`
+	// DisableLevel disables output of level field.
+	DisableLevel bool `json:"disable_level"`
+	// DisableMsg disables output of msg field.
+	DisableMsg bool `json:"disable_msg"`
+	// DisableFields disables output of all fields.
+	DisableFields bool `json:"disable_fields"`
+	// DisableStacktrace disables output of stack trace.
+	DisableStacktrace bool `json:"disable_stacktrace"`
+	// EnableCaller enables output of the file and line number that emitted a log record.
+	EnableCaller bool `json:"enable_caller"`
+
+	// TimestampFormat is an optional format for timestamps. If empty
+	// then DefTimestampFormat is used.
+	TimestampFormat string `json:"timestamp_format"`
+
+	// KeyTimestamp overrides the timestamp field key name.
+	KeyTimestamp string `json:"key_timestamp"`
+
+	// KeyLevel overrides the level field key name.
+	KeyLevel string `json:"key_level"`
+
+	// KeyMsg overrides the msg field key name.
+	KeyMsg string `json:"key_msg"`
+
+	// KeyGroupFields when not empty will group all context fields
+	// under this key.
+	KeyGroupFields string `json:"key_group_fields"`
+
+	// KeyStacktrace overrides the stacktrace field key name.
+	KeyStacktrace string `json:"key_stacktrace"`
+
+	// KeyCaller overrides the caller field key name.
+	KeyCaller string `json:"key_caller"`
+
+	// FieldSorter allows custom sorting of the fields. If nil then
+	// no sorting is done.
+	FieldSorter func(fields []logr.Field) []logr.Field `json:"-"`
+
+	once sync.Once
+}
+
+func (j *JSON) CheckValid() error {
+	return nil
+}
+
+// IsStacktraceNeeded returns true if a stacktrace is needed so we can output the `Caller` field.
+func (j *JSON) IsStacktraceNeeded() bool {
+	return j.EnableCaller
+}
+
+// Format converts a log record to bytes in JSON format.
+func (j *JSON) Format(rec *logr.LogRec, level logr.Level, buf *bytes.Buffer) (*bytes.Buffer, error) {
+	j.once.Do(j.applyDefaultKeyNames)
+
+	if buf == nil {
+		buf = &bytes.Buffer{}
+	}
+	enc := gojay.BorrowEncoder(buf)
+	defer func() {
+		enc.Release()
+	}()
+
+	jlr := JSONLogRec{
+		LogRec: rec,
+		JSON:   j,
+		level:  level,
+		sorter: j.FieldSorter,
+	}
+
+	err := enc.EncodeObject(jlr)
+	if err != nil {
+		return nil, err
+	}
+	buf.WriteByte('\n')
+	return buf, nil
+}
+
+func (j *JSON) applyDefaultKeyNames() {
+	if j.KeyTimestamp == "" {
+		j.KeyTimestamp = "timestamp"
+	}
+	if j.KeyLevel == "" {
+		j.KeyLevel = "level"
+	}
+	if j.KeyMsg == "" {
+		j.KeyMsg = "msg"
+	}
+	if j.KeyStacktrace == "" {
+		j.KeyStacktrace = "stacktrace"
+	}
+	if j.KeyCaller == "" {
+		j.KeyCaller = "caller"
+	}
+}
+
+// JSONLogRec decorates a LogRec adding JSON encoding.
+type JSONLogRec struct {
+	*logr.LogRec
+	*JSON
+	level  logr.Level
+	sorter func(fields []logr.Field) []logr.Field
+}
+
+// MarshalJSONObject encodes the LogRec as JSON.
+func (jlr JSONLogRec) MarshalJSONObject(enc *gojay.Encoder) {
+	if !jlr.DisableTimestamp {
+		timestampFmt := jlr.TimestampFormat
+		if timestampFmt == "" {
+			timestampFmt = logr.DefTimestampFormat
+		}
+		time := jlr.Time()
+		enc.AddTimeKey(jlr.KeyTimestamp, &time, timestampFmt)
+	}
+	if !jlr.DisableLevel {
+		enc.AddStringKey(jlr.KeyLevel, jlr.level.Name)
+	}
+	if !jlr.DisableMsg {
+		enc.AddStringKey(jlr.KeyMsg, jlr.Msg())
+	}
+	if jlr.EnableCaller {
+		enc.AddStringKey(jlr.KeyCaller, jlr.Caller())
+	}
+	if !jlr.DisableFields {
+		fields := jlr.Fields()
+		if jlr.sorter != nil {
+			fields = jlr.sorter(fields)
+		}
+		if jlr.KeyGroupFields != "" {
+			enc.AddObjectKey(jlr.KeyGroupFields, FieldArray(fields))
+		} else {
+			if len(fields) > 0 {
+				for _, field := range fields {
+					field = jlr.prefixCollision(field)
+					if err := encodeField(enc, field); err != nil {
+						enc.AddStringKey(field.Key, "<error encoding field: "+err.Error()+">")
+					}
+				}
+			}
+		}
+	}
+	if jlr.level.Stacktrace && !jlr.DisableStacktrace {
+		frames := jlr.StackFrames()
+		if len(frames) > 0 {
+			enc.AddArrayKey(jlr.KeyStacktrace, stackFrames(frames))
+		}
+	}
+}
+
+// IsNil returns true if the LogRec pointer is nil.
+func (rec JSONLogRec) IsNil() bool {
+	return rec.LogRec == nil
+}
+
+func (rec JSONLogRec) prefixCollision(field logr.Field) logr.Field {
+	switch field.Key {
+	case rec.KeyTimestamp, rec.KeyLevel, rec.KeyMsg, rec.KeyStacktrace:
+		f := field
+		f.Key = "_" + field.Key
+		return rec.prefixCollision(f)
+	}
+	return field
+}
+
+type stackFrames []runtime.Frame
+
+// MarshalJSONArray encodes stackFrames slice as JSON.
+func (s stackFrames) MarshalJSONArray(enc *gojay.Encoder) {
+	for _, frame := range s {
+		enc.AddObject(stackFrame(frame))
+	}
+}
+
+// IsNil returns true if stackFrames is empty slice.
+func (s stackFrames) IsNil() bool {
+	return len(s) == 0
+}
+
+type stackFrame runtime.Frame
+
+// MarshalJSONArray encodes stackFrame as JSON.
+func (f stackFrame) MarshalJSONObject(enc *gojay.Encoder) {
+	enc.AddStringKey("Function", f.Function)
+	enc.AddStringKey("File", f.File)
+	enc.AddIntKey("Line", f.Line)
+}
+
+func (f stackFrame) IsNil() bool {
+	return false
+}
+
+type FieldArray []logr.Field
+
+// MarshalJSONObject encodes Fields map to JSON.
+func (fa FieldArray) MarshalJSONObject(enc *gojay.Encoder) {
+	for _, fld := range fa {
+		if err := encodeField(enc, fld); err != nil {
+			enc.AddStringKey(fld.Key, "<error encoding field: "+err.Error()+">")
+		}
+	}
+}
+
+// IsNil returns true if map is nil.
+func (fa FieldArray) IsNil() bool {
+	return fa == nil
+}
+
+func encodeField(enc *gojay.Encoder, field logr.Field) error {
+	// first check if the value has a marshaller already.
+	switch vt := field.Interface.(type) {
+	case gojay.MarshalerJSONObject:
+		enc.AddObjectKey(field.Key, vt)
+		return nil
+	case gojay.MarshalerJSONArray:
+		enc.AddArrayKey(field.Key, vt)
+		return nil
+	}
+
+	switch field.Type {
+	case logr.StringType:
+		enc.AddStringKey(field.Key, field.String)
+
+	case logr.BoolType:
+		var b bool
+		if field.Integer != 0 {
+			b = true
+		}
+		enc.AddBoolKey(field.Key, b)
+
+	case logr.StructType, logr.ArrayType, logr.MapType, logr.UnknownType:
+		b, err := json.Marshal(field.Interface)
+		if err != nil {
+			return err
+		}
+		embed := gojay.EmbeddedJSON(b)
+		enc.AddEmbeddedJSONKey(field.Key, &embed)
+
+	case logr.StringerType, logr.ErrorType, logr.TimestampMillisType, logr.TimeType, logr.DurationType, logr.BinaryType:
+		var buf strings.Builder
+		_ = field.ValueString(&buf, nil)
+		enc.AddStringKey(field.Key, buf.String())
+
+	case logr.Int64Type, logr.Int32Type, logr.IntType:
+		enc.AddInt64Key(field.Key, field.Integer)
+
+	case logr.Uint64Type, logr.Uint32Type, logr.UintType:
+		enc.AddUint64Key(field.Key, uint64(field.Integer))
+
+	case logr.Float64Type, logr.Float32Type:
+		enc.AddFloat64Key(field.Key, field.Float)
+
+	default:
+		return fmt.Errorf("invalid field type: %d", field.Type)
+	}
+	return nil
+}
diff --git a/vendor/github.com/mattermost/logr/v2/formatters/plain.go b/vendor/github.com/mattermost/logr/v2/formatters/plain.go
new file mode 100644
index 00000000..4d8af643
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/formatters/plain.go
@@ -0,0 +1,146 @@
+package formatters
+
+import (
+	"bytes"
+	"fmt"
+	"strings"
+
+	"github.com/mattermost/logr/v2"
+)
+
+// Plain is the simplest formatter, outputting only text with
+// no colors.
+type Plain struct {
+	// DisableTimestamp disables output of timestamp field.
+	DisableTimestamp bool `json:"disable_timestamp"`
+	// DisableLevel disables output of level field.
+	DisableLevel bool `json:"disable_level"`
+	// DisableMsg disables output of msg field.
+	DisableMsg bool `json:"disable_msg"`
+	// DisableFields disables output of all fields.
+	DisableFields bool `json:"disable_fields"`
+	// DisableStacktrace disables output of stack trace.
+	DisableStacktrace bool `json:"disable_stacktrace"`
+	// EnableCaller enables output of the file and line number that emitted a log record.
+	EnableCaller bool `json:"enable_caller"`
+
+	// Delim is an optional delimiter output between each log field.
+	// Defaults to a single space.
+	Delim string `json:"delim"`
+
+	// MinLevelLen sets the minimum level name length. If the level name is less
+	// than the minimum it will be padded with spaces.
+	MinLevelLen int `json:"min_level_len"`
+
+	// MinMessageLen sets the minimum msg length. If the msg text is less
+	// than the minimum it will be padded with spaces.
+	MinMessageLen int `json:"min_msg_len"`
+
+	// TimestampFormat is an optional format for timestamps. If empty
+	// then DefTimestampFormat is used.
+	TimestampFormat string `json:"timestamp_format"`
+
+	// LineEnd sets the end of line character(s). Defaults to '\n'.
+	LineEnd string `json:"line_end"`
+
+	// EnableColor sets whether output should include color.
+	EnableColor bool `json:"enable_color"`
+}
+
+func (p *Plain) CheckValid() error {
+	if p.MinMessageLen < 0 || p.MinMessageLen > 1024 {
+		return fmt.Errorf("min_msg_len is invalid(%d)", p.MinMessageLen)
+	}
+	return nil
+}
+
+// IsStacktraceNeeded returns true if a stacktrace is needed so we can output the `Caller` field.
+func (p *Plain) IsStacktraceNeeded() bool {
+	return p.EnableCaller
+}
+
+// Format converts a log record to bytes.
+func (p *Plain) Format(rec *logr.LogRec, level logr.Level, buf *bytes.Buffer) (*bytes.Buffer, error) {
+	delim := p.Delim
+	if delim == "" {
+		delim = " "
+	}
+	if buf == nil {
+		buf = &bytes.Buffer{}
+	}
+
+	timestampFmt := p.TimestampFormat
+	if timestampFmt == "" {
+		timestampFmt = logr.DefTimestampFormat
+	}
+
+	color := logr.NoColor
+	if p.EnableColor {
+		color = level.Color
+	}
+
+	if !p.DisableLevel {
+		_ = logr.WriteWithColor(buf, level.Name, color)
+		count := len(level.Name)
+		if p.MinLevelLen > count {
+			_, _ = buf.WriteString(strings.Repeat(" ", p.MinLevelLen-count))
+		}
+		buf.WriteString(delim)
+	}
+
+	if !p.DisableTimestamp {
+		var arr [128]byte
+		tbuf := rec.Time().AppendFormat(arr[:0], timestampFmt)
+		buf.WriteByte('[')
+		buf.Write(tbuf)
+		buf.WriteByte(']')
+		buf.WriteString(delim)
+	}
+
+	if !p.DisableMsg {
+		count, _ := buf.WriteString(rec.Msg())
+		if p.MinMessageLen > count {
+			_, _ = buf.WriteString(strings.Repeat(" ", p.MinMessageLen-count))
+		}
+		_, _ = buf.WriteString(delim)
+	}
+
+	var fields []logr.Field
+
+	if p.EnableCaller {
+		fld := logr.Field{
+			Key:    "caller",
+			Type:   logr.StringType,
+			String: rec.Caller(),
+		}
+		fields = append(fields, fld)
+	}
+
+	if !p.DisableFields {
+		fields = append(fields, rec.Fields()...)
+	}
+
+	if len(fields) > 0 {
+		if err := logr.WriteFields(buf, fields, logr.Space, color); err != nil {
+			return nil, err
+		}
+	}
+
+	if level.Stacktrace && !p.DisableStacktrace {
+		frames := rec.StackFrames()
+		if len(frames) > 0 {
+			buf.WriteString("\n")
+			if err := logr.WriteStacktrace(buf, rec.StackFrames()); err != nil {
+				return nil, err
+			}
+		}
+	}
+
+	if p.LineEnd == "" {
+		buf.WriteString("\n")
+	} else {
+		buf.WriteString(p.LineEnd)
+	}
+
+	return buf, nil
+}
diff --git a/vendor/github.com/mattermost/logr/v2/go.mod b/vendor/github.com/mattermost/logr/v2/go.mod
new file mode 100644
index 00000000..4cbe375e
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/go.mod
@@ -0,0 +1,11 @@
+module github.com/mattermost/logr/v2
+
+go 1.12
+
+require (
+	github.com/francoispqt/gojay v1.2.13
+	github.com/stretchr/testify v1.4.0
+	github.com/wiggin77/merror v1.0.2
+	github.com/wiggin77/srslog v1.0.1
+	gopkg.in/natefinch/lumberjack.v2 v2.0.0
+)
diff --git a/vendor/github.com/mattermost/logr/v2/go.sum b/vendor/github.com/mattermost/logr/v2/go.sum
new file mode 100644
index 00000000..ae504492
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/go.sum
@@ -0,0 +1,178 @@
+cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
+cloud.google.com/go v0.31.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
+cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
+cloud.google.com/go v0.37.0/go.mod h1:TS1dMSSfndXH133OKGwekG838Om/cQT0BUHV3HcBgoo=
+dmitri.shuralyov.com/app/changes v0.0.0-20180602232624-0a106ad413e3/go.mod h1:Yl+fi1br7+Rr3LqpNJf1/uxUdtRUV+Tnj0o93V2B9MU=
+dmitri.shuralyov.com/html/belt v0.0.0-20180602232347-f7d459c86be0/go.mod h1:JLBrvjyP0v+ecvNYvCpyZgu5/xkfAUhi6wJj28eUfSU=
+dmitri.shuralyov.com/service/change v0.0.0-20181023043359-a85b471d5412/go.mod h1:a1inKt/atXimZ4Mv927x+r7UpyzRUf4emIoiiSC2TN4=
+dmitri.shuralyov.com/state v0.0.0-20180228185332-28bcc343414c/go.mod h1:0PRwlb0D6DFvNNtx+9ybjezNCa8XF0xaYcETyp6rHWU=
+git.apache.org/thrift.git v0.0.0-20180902110319-2566ecd5d999/go.mod h1:fPE2ZNJGynbRyZ4dJvy6G277gSllfV2HJqblrnkyeyg=
+github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ=
+github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
+github.com/anmitsu/go-shlex v0.0.0-20161002113705-648efa622239/go.mod h1:2FmKhYUyUczH0OGQWaF5ceTx0UBShxjsH6f8oGKYe2c=
+github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
+github.com/bradfitz/go-smtpd v0.0.0-20170404230938-deb6d6237625/go.mod h1:HYsPBTaaSFSlLx/70C2HPIMNZpVV8+vt/A+FMnYP11g=
+github.com/buger/jsonparser v0.0.0-20181115193947-bf1c66bbce23/go.mod h1:bbYlZJ7hK1yFx9hf58LP0zeX7UjIGs20ufpu3evjr+s=
+github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
+github.com/coreos/go-systemd v0.0.0-20181012123002-c6f51f82210d/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
+github.com/flynn/go-shlex v0.0.0-20150515145356-3f9db97f8568/go.mod h1:xEzjJPgXI435gkrCt3MPfRiAkVrwSbHsst4LCFVfpJc=
+github.com/francoispqt/gojay v1.2.13 h1:d2m3sFjloqoIUQU3TsHBgj6qg/BVGlTBeHDUmyJnXKk=
+github.com/francoispqt/gojay v1.2.13/go.mod h1:ehT5mTG4ua4581f1++1WLG0vPdaA9HaiDsoyrBGkyDY=
+github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
+github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
+github.com/gliderlabs/ssh v0.1.1/go.mod h1:U7qILu1NlMHj9FlMhZLlkCdDnU1DBEAqr0aevW3Awn0=
+github.com/go-errors/errors v1.0.1/go.mod h1:f4zRHt4oKfwPJE5k8C9vpYG+aDHdBFUsgrm6/TyX73Q=
+github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
+github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
+github.com/golang/lint v0.0.0-20180702182130-06c8688daad7/go.mod h1:tluoj9z5200jBnyusfRPU2LqT6J+DAorxEvtC7LHB+E=
+github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
+github.com/golang/mock v1.2.0/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
+github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
+github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
+github.com/google/go-github v17.0.0+incompatible/go.mod h1:zLgOLi98H3fifZn+44m+umXrS52loVEgC2AApnigrVQ=
+github.com/google/go-querystring v1.0.0/go.mod h1:odCYkC5MyYFN7vkCjXpyrEuKhc/BUO6wN/zVPAxq5ck=
+github.com/google/martian v2.1.0+incompatible/go.mod h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs=
+github.com/google/pprof v0.0.0-20181206194817-3ea8567a2e57/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc=
+github.com/googleapis/gax-go v2.0.0+incompatible/go.mod h1:SFVmujtThgffbyetf+mdk2eWhX2bMyUtNHzFKcPA9HY=
+github.com/googleapis/gax-go/v2 v2.0.3/go.mod h1:LLvjysVCY1JZeum8Z6l8qUty8fiNwE08qbEPm1M08qg=
+github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=
+github.com/gregjones/httpcache v0.0.0-20180305231024-9cad4c3443a7/go.mod h1:FecbI9+v66THATjSRHfNgh1IVFe/9kFxbXtjV0ctIMA=
+github.com/grpc-ecosystem/grpc-gateway v1.5.0/go.mod h1:RSKVYQBd5MCa4OVpNdGskqpgL2+G+NZTnrVHpWWfpdw=
+github.com/jellevandenhooff/dkim v0.0.0-20150330215556-f50fe3d243e1/go.mod h1:E0B/fFc00Y+Rasa88328GlI/XbtyysCtTHZS8h7IrBU=
+github.com/json-iterator/go v1.1.6/go.mod h1:+SdeFBvtyEkXs7REEP0seUULqWtbJapLOCVDaaPEHmU=
+github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
+github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
+github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/pty v1.1.3/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/lunixbochs/vtclean v1.0.0/go.mod h1:pHhQNgMf3btfWnGBVipUOjRYhoOsdGqdm/+2c2E2WMI=
+github.com/mailru/easyjson v0.0.0-20190312143242-1de009706dbe/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc=
+github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
+github.com/microcosm-cc/bluemonday v1.0.1/go.mod h1:hsXNsILzKxV+sX77C5b8FSuKF00vh2OMYv+xgHpAMF4=
+github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
+github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
+github.com/neelance/astrewrite v0.0.0-20160511093645-99348263ae86/go.mod h1:kHJEU3ofeGjhHklVoIGuVj85JJwZ6kWPaJwCIxgnFmo=
+github.com/neelance/sourcemap v0.0.0-20151028013722-8c68805598ab/go.mod h1:Qr6/a/Q4r9LP1IltGz7tA7iOK1WonHEYhu1HRBA7ZiM=
+github.com/openzipkin/zipkin-go v0.1.1/go.mod h1:NtoC/o8u3JlF1lSlyPNswIbeQH9bJTmOf0Erfk+hxe8=
+github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/prometheus/client_golang v0.8.0/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
+github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
+github.com/prometheus/common v0.0.0-20180801064454-c7de2306084e/go.mod h1:daVV7qP5qjZbuso7PdcryaAu0sAZbrN9i7WWcTMWvro=
+github.com/prometheus/procfs v0.0.0-20180725123919-05ee40e3a273/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
+github.com/russross/blackfriday v1.5.2/go.mod h1:JO/DiYxRf+HjHt06OyowR9PTA263kcR/rfWxYHBV53g=
+github.com/sergi/go-diff v1.0.0/go.mod h1:0CfEIISq7TuYL3j771MWULgwwjU+GofnZX9QAmXWZgo=
+github.com/shurcooL/component v0.0.0-20170202220835-f88ec8f54cc4/go.mod h1:XhFIlyj5a1fBNx5aJTbKoIq0mNaPvOagO+HjB3EtxrY=
+github.com/shurcooL/events v0.0.0-20181021180414-410e4ca65f48/go.mod h1:5u70Mqkb5O5cxEA8nxTsgrgLehJeAw6Oc4Ab1c/P1HM=
+github.com/shurcooL/github_flavored_markdown v0.0.0-20181002035957-2122de532470/go.mod h1:2dOwnU2uBioM+SGy2aZoq1f/Sd1l9OkAeAUvjSyvgU0=
+github.com/shurcooL/go v0.0.0-20180423040247-9e1955d9fb6e/go.mod h1:TDJrrUr11Vxrven61rcy3hJMUqaf/CLWYhHNPmT14Lk=
+github.com/shurcooL/go-goon v0.0.0-20170922171312-37c2f522c041/go.mod h1:N5mDOmsrJOB+vfqUK+7DmDyjhSLIIBnXo9lvZJj3MWQ=
+github.com/shurcooL/gofontwoff v0.0.0-20180329035133-29b52fc0a18d/go.mod h1:05UtEgK5zq39gLST6uB0cf3NEHjETfB4Fgr3Gx5R9Vw=
+github.com/shurcooL/gopherjslib v0.0.0-20160914041154-feb6d3990c2c/go.mod h1:8d3azKNyqcHP1GaQE/c6dDgjkgSx2BZ4IoEi4F1reUI=
+github.com/shurcooL/highlight_diff v0.0.0-20170515013008-09bb4053de1b/go.mod h1:ZpfEhSmds4ytuByIcDnOLkTHGUI6KNqRNPDLHDk+mUU=
+github.com/shurcooL/highlight_go v0.0.0-20181028180052-98c3abbbae20/go.mod h1:UDKB5a1T23gOMUJrI+uSuH0VRDStOiUVSjBTRDVBVag=
+github.com/shurcooL/home v0.0.0-20181020052607-80b7ffcb30f9/go.mod h1:+rgNQw2P9ARFAs37qieuu7ohDNQ3gds9msbT2yn85sg=
+github.com/shurcooL/htmlg v0.0.0-20170918183704-d01228ac9e50/go.mod h1:zPn1wHpTIePGnXSHpsVPWEktKXHr6+SS6x/IKRb7cpw=
+github.com/shurcooL/httperror v0.0.0-20170206035902-86b7830d14cc/go.mod h1:aYMfkZ6DWSJPJ6c4Wwz3QtW22G7mf/PEgaB9k/ik5+Y=
+github.com/shurcooL/httpfs v0.0.0-20171119174359-809beceb2371/go.mod h1:ZY1cvUeJuFPAdZ/B6v7RHavJWZn2YPVFQ1OSXhCGOkg=
+github.com/shurcooL/httpgzip v0.0.0-20180522190206-b1c53ac65af9/go.mod h1:919LwcH0M7/W4fcZ0/jy0qGght1GIhqyS/EgWGH2j5Q=
+github.com/shurcooL/issues v0.0.0-20181008053335-6292fdc1e191/go.mod h1:e2qWDig5bLteJ4fwvDAc2NHzqFEthkqn7aOZAOpj+PQ=
+github.com/shurcooL/issuesapp v0.0.0-20180602232740-048589ce2241/go.mod h1:NPpHK2TI7iSaM0buivtFUc9offApnI0Alt/K8hcHy0I=
+github.com/shurcooL/notifications v0.0.0-20181007000457-627ab5aea122/go.mod h1:b5uSkrEVM1jQUspwbixRBhaIjIzL2xazXp6kntxYle0=
+github.com/shurcooL/octicon v0.0.0-20181028054416-fa4f57f9efb2/go.mod h1:eWdoE5JD4R5UVWDucdOPg1g2fqQRq78IQa9zlOV1vpQ=
+github.com/shurcooL/reactions v0.0.0-20181006231557-f2e0b4ca5b82/go.mod h1:TCR1lToEk4d2s07G3XGfz2QrgHXg4RJBvjrOozvoWfk=
+github.com/shurcooL/sanitized_anchor_name v0.0.0-20170918181015-86672fcb3f95/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=
+github.com/shurcooL/users v0.0.0-20180125191416-49c67e49c537/go.mod h1:QJTqeLYEDaXHZDBsXlPCDqdhQuJkuw4NOtaxYe3xii4=
+github.com/shurcooL/webdavfs v0.0.0-20170829043945-18c3829fa133/go.mod h1:hKmq5kWdCj2z2KEozexVbfEZIWiTjhE0+UjmZgPqehw=
+github.com/sourcegraph/annotate v0.0.0-20160123013949-f4cad6c6324d/go.mod h1:UdhH50NIW0fCiwBSr0co2m7BnFLdv4fQTgdqdJTHFeE=
+github.com/sourcegraph/syntaxhighlight v0.0.0-20170531221838-bd320f5d308e/go.mod h1:HuIsMU8RRBOtsCgI77wP899iHVBQpCmg4ErYMZB+2IA=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.2.2 h1:bSDNvY7ZPG5RlJ8otE/7V6gMiyenm9RtJ7IUVIAoJ1w=
+github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
+github.com/stretchr/testify v1.4.0 h1:2E4SXV/wtOkTonXsotYi4li6zVWxYlZuYNCXe9XRJyk=
+github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/tarm/serial v0.0.0-20180830185346-98f6abe2eb07/go.mod h1:kDXzergiv9cbyO7IOYJZWg1U88JhDg3PB6klq9Hg2pA=
+github.com/viant/assertly v0.4.8/go.mod h1:aGifi++jvCrUaklKEKT0BU95igDNaqkvz+49uaYMPRU=
+github.com/viant/toolbox v0.24.0/go.mod h1:OxMCG57V0PXuIP2HNQrtJf2CjqdmbrOx5EkMILuUhzM=
+github.com/wiggin77/merror v1.0.2 h1:V0nH9eFp64ASyaXC+pB5WpvBoCg7NUwvaCSKdzlcHqw=
+github.com/wiggin77/merror v1.0.2/go.mod h1:uQTcIU0Z6jRK4OwqganPYerzQxSFJ4GSHM3aurxxQpg=
+github.com/wiggin77/srslog v1.0.1 h1:gA2XjSMy3DrRdX9UqLuDtuVAAshb8bE1NhX1YK0Qe+8=
+github.com/wiggin77/srslog v1.0.1/go.mod h1:fehkyYDq1QfuYn60TDPu9YdY2bB85VUW2mvN1WynEls=
+go.opencensus.io v0.18.0/go.mod h1:vKdFvxhtzZ9onBp9VKHK8z/sRpBMnKAsufL7wlDrCOA=
+go4.org v0.0.0-20180809161055-417644f6feb5/go.mod h1:MkTOUMDaeVYJUOUsaDXIhWPZYa1yOyC1qaOBpL57BhE=
+golang.org/x/build v0.0.0-20190111050920-041ab4dc3f9d/go.mod h1:OWs+y06UdEOHN4y+MfF/py+xQ/tYqIWW03b70/CG9Rw=
+golang.org/x/crypto v0.0.0-20181030102418-4d3f4d9ffa16/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20190313024323-a1f597ede03a/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
+golang.org/x/lint v0.0.0-20180702182130-06c8688daad7/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
+golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
+golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
+golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20181029044818-c44066c5c816/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20181106065722-10aee1819953/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190313220215-9f648a60d977/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
+golang.org/x/oauth2 v0.0.0-20181017192945-9dcd33a902f4/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
+golang.org/x/oauth2 v0.0.0-20181203162652-d668ce993890/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
+golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
+golang.org/x/perf v0.0.0-20180704124530-6e6d33e29852/go.mod h1:JLpeXjPJfIyPr5TlbXLkXWLhP8nz10XfvxElABhCtcw=
+golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20181029174526-d69651ed3497/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190316082340-a2f829d7f35f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/time v0.0.0-20180412165947-fbb02b2291d2/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
+golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
+golang.org/x/tools v0.0.0-20180828015842-6cd1fcedba52/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20181030000716-a0a13e073c7b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
+google.golang.org/api v0.0.0-20180910000450-7ca32eb868bf/go.mod h1:4mhQ8q/RsB7i+udVvVy5NUi08OU8ZlA0gRVgrF7VFY0=
+google.golang.org/api v0.0.0-20181030000543-1d582fd0359e/go.mod h1:4mhQ8q/RsB7i+udVvVy5NUi08OU8ZlA0gRVgrF7VFY0=
+google.golang.org/api v0.1.0/go.mod h1:UGEZY7KEX120AnNLIHFMKIo4obdJhkp2tPbaPlQx13Y=
+google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
+google.golang.org/appengine v1.2.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/appengine v1.3.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
+google.golang.org/genproto v0.0.0-20180831171423-11092d34479b/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
+google.golang.org/genproto v0.0.0-20181029155118-b69ba1387ce2/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
+google.golang.org/genproto v0.0.0-20181202183823-bd91e49a0898/go.mod h1:7Ep/1NZk928CDR8SjdVbjWNpdIf6nzjE3BTgJDr2Atg=
+google.golang.org/genproto v0.0.0-20190306203927-b5d61aea6440/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
+google.golang.org/grpc v1.14.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw=
+google.golang.org/grpc v1.16.0/go.mod h1:0JHn/cJsOMiMfNA9+DeHDlAU7KAAB5GDlYFpa9MZMio=
+google.golang.org/grpc v1.17.0/go.mod h1:6QZJwpn2B+Zp71q/5VxRsJ6NXXVCE5NRUHRo+f3cWCs=
+google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw=
+gopkg.in/natefinch/lumberjack.v2 v2.0.0 h1:1Lc07Kr7qY4U2YPouBjpCLxpiyxIVoxqXgkXLknAOE8=
+gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k=
+gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.2.2 h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+grpc.go4.org v0.0.0-20170609214715-11d0a25b4919/go.mod h1:77eQGdRu53HpSqPFJFmuJdjuHRquDANNeA4x7B8WQ9o=
+honnef.co/go/tools v0.0.0-20180728063816-88497007e858/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+sourcegraph.com/sourcegraph/go-diff v0.5.0/go.mod h1:kuch7UrkMzY0X+p9CRK03kfuPQ2zzQcaEFbx8wA8rck=
+sourcegraph.com/sqs/pbtypes v0.0.0-20180604144634-d3ebe8f20ae4/go.mod h1:ketZ/q3QxT9HOBeFhu6RdvsftgpsbFHBF5Cas6cDKZ0=
diff --git a/vendor/github.com/mattermost/logr/v2/level.go b/vendor/github.com/mattermost/logr/v2/level.go
new file mode 100644
index 00000000..643d68e3
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/level.go
@@ -0,0 +1,34 @@
+package logr
+
+var AnsiColorPrefix = []byte("\u001b[")
+var AnsiColorSuffix = []byte("m")
+
+// Color for formatters that support color output.
+type Color uint8
+
+const (
+	NoColor Color = 0
+	Red     Color = 31
+	Green   Color = 32
+	Yellow  Color = 33
+	Blue    Color = 34
+	Magenta Color = 35
+	Cyan    Color = 36
+	White   Color = 37
+)
+
+// LevelID is the unique id of each level.
+type LevelID uint
+
+// Level provides a mechanism to enable/disable specific log lines.
+type Level struct {
+	ID         LevelID `json:"id"`
+	Name       string  `json:"name"`
+	Stacktrace bool    `json:"stacktrace,omitempty"`
+	Color      Color   `json:"color,omitempty"`
+}
+
+// String returns the name of this level.
+func (level Level) String() string {
+	return level.Name
+}
diff --git a/vendor/github.com/mattermost/logr/v2/levelcache.go b/vendor/github.com/mattermost/logr/v2/levelcache.go
new file mode 100644
index 00000000..2cefb61d
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/levelcache.go
@@ -0,0 +1,98 @@
+package logr
+
+import (
+	"fmt"
+	"sync"
+)
+
+// LevelStatus represents whether a level is enabled and
+// requires a stack trace.
+type LevelStatus struct {
+	Enabled    bool
+	Stacktrace bool
+	empty      bool
+}
+
+type levelCache interface {
+	setup()
+	get(id LevelID) (LevelStatus, bool)
+	put(id LevelID, status LevelStatus) error
+	clear()
+}
+
+// syncMapLevelCache uses sync.Map which may better handle large concurrency
+// scenarios.
+type syncMapLevelCache struct {
+	m sync.Map
+}
+
+func (c *syncMapLevelCache) setup() {
+	c.clear()
+}
+
+func (c *syncMapLevelCache) get(id LevelID) (LevelStatus, bool) {
+	if id > MaxLevelID {
+		return LevelStatus{}, false
+	}
+	s, _ := c.m.Load(id)
+	status := s.(LevelStatus)
+	return status, !status.empty
+}
+
+func (c *syncMapLevelCache) put(id LevelID, status LevelStatus) error {
+	if id > MaxLevelID {
+		return fmt.Errorf("level id cannot exceed MaxLevelID (%d)", MaxLevelID)
+	}
+	c.m.Store(id, status)
+	return nil
+}
+
+func (c *syncMapLevelCache) clear() {
+	var i LevelID
+	for i = 0; i < MaxLevelID; i++ {
+		c.m.Store(i, LevelStatus{empty: true})
+	}
+}
+
+// arrayLevelCache using array and a mutex.
+type arrayLevelCache struct {
+	arr [MaxLevelID + 1]LevelStatus
+	mux sync.RWMutex
+}
+
+func (c *arrayLevelCache) setup() {
+	c.clear()
+}
+
+//var dummy = LevelStatus{}
+
+func (c *arrayLevelCache) get(id LevelID) (LevelStatus, bool) {
+	if id > MaxLevelID {
+		return LevelStatus{}, false
+	}
+	c.mux.RLock()
+	status := c.arr[id]
+	ok := !status.empty
+	c.mux.RUnlock()
+	return status, ok
+}
+
+func (c *arrayLevelCache) put(id LevelID, status LevelStatus) error {
+	if id > MaxLevelID {
+		return fmt.Errorf("level id cannot exceed MaxLevelID (%d)", MaxLevelID)
+	}
+	c.mux.Lock()
+	defer c.mux.Unlock()
+
+	c.arr[id] = status
+	return nil
+}
+
+func (c *arrayLevelCache) clear() {
+	c.mux.Lock()
+	defer c.mux.Unlock()
+
+	for i := range c.arr {
+		c.arr[i] = LevelStatus{empty: true}
+	}
+}
diff --git a/vendor/github.com/mattermost/logr/v2/logger.go b/vendor/github.com/mattermost/logr/v2/logger.go
new file mode 100644
index 00000000..6ce9c9f0
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/logger.go
@@ -0,0 +1,99 @@
+package logr
+
+import "log"
+
+// Logger provides context for logging via fields.
+type Logger struct {
+	lgr    *Logr
+	fields []Field
+}
+
+// Logr returns the `Logr` instance that created this `Logger`.
+func (logger Logger) Logr() *Logr {
+	return logger.lgr
+}
+
+// With creates a new `Logger` with any existing fields plus the new ones.
+func (logger Logger) With(fields ...Field) Logger {
+	l := Logger{lgr: logger.lgr}
+	size := len(logger.fields) + len(fields)
+	if size > 0 {
+		l.fields = make([]Field, 0, size)
+		l.fields = append(l.fields, logger.fields...)
+		l.fields = append(l.fields, fields...)
+	}
+	return l
+}
+
+// StdLogger creates a standard logger backed by this `Logr.Logger` instance.
+// All log records are emitted with the specified log level.
+func (logger Logger) StdLogger(level Level) *log.Logger {
+	return NewStdLogger(level, logger)
+}
+
+// IsLevelEnabled determines if the specified level is enabled for at least
+// one log target.
+func (logger Logger) IsLevelEnabled(level Level) bool {
+	status := logger.Logr().IsLevelEnabled(level)
+	return status.Enabled
+}
+
+// Sugar creates a new `Logger` with a less structured API. Any fields are preserved.
+func (logger Logger) Sugar(fields ...Field) Sugar {
+	return Sugar{
+		logger: logger.With(fields...),
+	}
+}
+
+// Log checks that the level matches one or more targets, and
+// if so, generates a log record that is added to the Logr queue.
+// Arguments are handled in the manner of fmt.Print.
+func (logger Logger) Log(lvl Level, msg string, fields ...Field) {
+	status := logger.lgr.IsLevelEnabled(lvl)
+	if status.Enabled {
+		rec := NewLogRec(lvl, logger, msg, fields, status.Stacktrace)
+		logger.lgr.enqueue(rec)
+	}
+}
+
+// LogM calls `Log` multiple times, one for each level provided.
+func (logger Logger) LogM(levels []Level, msg string, fields ...Field) {
+	for _, lvl := range levels {
+		logger.Log(lvl, msg, fields...)
+	}
+}
+
+// Trace is a convenience method equivalent to `Log(TraceLevel, msg, fields...)`.
+func (logger Logger) Trace(msg string, fields ...Field) {
+	logger.Log(Trace, msg, fields...)
+}
+
+// Debug is a convenience method equivalent to `Log(DebugLevel, msg, fields...)`.
+func (logger Logger) Debug(msg string, fields ...Field) {
+	logger.Log(Debug, msg, fields...)
+}
+
+// Info is a convenience method equivalent to `Log(InfoLevel, msg, fields...)`.
+func (logger Logger) Info(msg string, fields ...Field) {
+	logger.Log(Info, msg, fields...)
+}
+
+// Warn is a convenience method equivalent to `Log(WarnLevel, msg, fields...)`.
+func (logger Logger) Warn(msg string, fields ...Field) {
+	logger.Log(Warn, msg, fields...)
+}
+
+// Error is a convenience method equivalent to `Log(ErrorLevel, msg, fields...)`.
+func (logger Logger) Error(msg string, fields ...Field) {
+	logger.Log(Error, msg, fields...)
+}
+
+// Fatal is a convenience method equivalent to `Log(FatalLevel, msg, fields...)`
+func (logger Logger) Fatal(msg string, fields ...Field) {
+	logger.Log(Fatal, msg, fields...)
+}
+
+// Panic is a convenience method equivalent to `Log(PanicLevel, msg, fields...)`
+func (logger Logger) Panic(msg string, fields ...Field) {
+	logger.Log(Panic, msg, fields...)
+}
diff --git a/vendor/github.com/mattermost/logr/v2/logr.go b/vendor/github.com/mattermost/logr/v2/logr.go
new file mode 100644
index 00000000..82b2a835
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/logr.go
@@ -0,0 +1,471 @@
+package logr
+
+import (
+	"bytes"
+	"context"
+	"errors"
+	"fmt"
+	"os"
+	"sync"
+	"sync/atomic"
+	"time"
+
+	"github.com/wiggin77/merror"
+)
+
+// Logr maintains a list of log targets and accepts incoming
+// log records.  Use `New` to create instances.
+type Logr struct {
+	tmux        sync.RWMutex // targetHosts mutex
+	targetHosts []*TargetHost
+
+	in         chan *LogRec
+	quit       chan struct{} // closed by Shutdown to exit read loop
+	done       chan struct{} // closed when read loop exited
+	lvlCache   levelCache
+	bufferPool sync.Pool
+	options    *options
+
+	metricsMux sync.RWMutex
+	metrics    *metrics
+
+	shutdown int32
+}
+
+// New creates a new Logr instance with one or more options specified.
+// Some options with invalid values can cause an error to be returned,
+// however `logr.New()` using just defaults never errors.
+func New(opts ...Option) (*Logr, error) {
+	options := &options{
+		maxQueueSize:    DefaultMaxQueueSize,
+		enqueueTimeout:  DefaultEnqueueTimeout,
+		shutdownTimeout: DefaultShutdownTimeout,
+		flushTimeout:    DefaultFlushTimeout,
+		maxPooledBuffer: DefaultMaxPooledBuffer,
+	}
+
+	lgr := &Logr{options: options}
+
+	// apply the options
+	for _, opt := range opts {
+		if err := opt(lgr); err != nil {
+			return nil, err
+		}
+	}
+	pkgName := GetLogrPackageName()
+	if pkgName != "" {
+		opt := StackFilter(pkgName, pkgName+"/targets", pkgName+"/formatters")
+		_ = opt(lgr)
+	}
+
+	lgr.in = make(chan *LogRec, lgr.options.maxQueueSize)
+	lgr.quit = make(chan struct{})
+	lgr.done = make(chan struct{})
+
+	if lgr.options.useSyncMapLevelCache {
+		lgr.lvlCache = &syncMapLevelCache{}
+	} else {
+		lgr.lvlCache = &arrayLevelCache{}
+	}
+	lgr.lvlCache.setup()
+
+	lgr.bufferPool = sync.Pool{
+		New: func() interface{} {
+			return new(bytes.Buffer)
+		},
+	}
+
+	lgr.initMetrics(lgr.options.metricsCollector, lgr.options.metricsUpdateFreqMillis)
+
+	go lgr.start()
+
+	return lgr, nil
+}
+
+// AddTarget adds a target to the logger which will receive
+// log records for outputting.
+func (lgr *Logr) AddTarget(target Target, name string, filter Filter, formatter Formatter, maxQueueSize int) error {
+	if lgr.IsShutdown() {
+		return fmt.Errorf("AddTarget called after Logr shut down")
+	}
+
+	lgr.metricsMux.RLock()
+	metrics := lgr.metrics
+	lgr.metricsMux.RUnlock()
+
+	hostOpts := targetHostOptions{
+		name:         name,
+		filter:       filter,
+		formatter:    formatter,
+		maxQueueSize: maxQueueSize,
+		metrics:      metrics,
+	}
+
+	host, err := newTargetHost(target, hostOpts)
+	if err != nil {
+		return err
+	}
+
+	lgr.tmux.Lock()
+	defer lgr.tmux.Unlock()
+
+	lgr.targetHosts = append(lgr.targetHosts, host)
+
+	lgr.ResetLevelCache()
+
+	return nil
+}
+
+// NewLogger creates a Logger using defaults. A `Logger` is light-weight
+// enough to create on-demand, but typically one or more Loggers are
+// created and re-used.
+func (lgr *Logr) NewLogger() Logger {
+	logger := Logger{lgr: lgr}
+	return logger
+}
+
+var levelStatusDisabled = LevelStatus{}
+
+// IsLevelEnabled returns true if at least one target has the specified
+// level enabled. The result is cached so that subsequent checks are fast.
+func (lgr *Logr) IsLevelEnabled(lvl Level) LevelStatus {
+	// No levels enabled after shutdown
+	if atomic.LoadInt32(&lgr.shutdown) != 0 {
+		return levelStatusDisabled
+	}
+
+	// Check cache.
+	status, ok := lgr.lvlCache.get(lvl.ID)
+	if ok {
+		return status
+	}
+
+	status = LevelStatus{}
+
+	// Cache miss; check each target.
+	lgr.tmux.RLock()
+	defer lgr.tmux.RUnlock()
+	for _, host := range lgr.targetHosts {
+		enabled, level := host.IsLevelEnabled(lvl)
+		if enabled {
+			status.Enabled = true
+			if level.Stacktrace || host.formatter.IsStacktraceNeeded() {
+				status.Stacktrace = true
+				break // if both level and stacktrace enabled then no sense checking more targets
+			}
+		}
+	}
+
+	// Cache and return the result.
+	if err := lgr.lvlCache.put(lvl.ID, status); err != nil {
+		lgr.ReportError(err)
+		return LevelStatus{}
+	}
+	return status
+}
+
+// HasTargets returns true only if at least one target exists within the lgr.
+func (lgr *Logr) HasTargets() bool {
+	lgr.tmux.RLock()
+	defer lgr.tmux.RUnlock()
+	return len(lgr.targetHosts) > 0
+}
+
+// TargetInfo provides name and type for a Target.
+type TargetInfo struct {
+	Name string
+	Type string
+}
+
+// TargetInfos enumerates all the targets added to this lgr.
+// The resulting slice represents a snapshot at time of calling.
+func (lgr *Logr) TargetInfos() []TargetInfo {
+	infos := make([]TargetInfo, 0)
+
+	lgr.tmux.RLock()
+	defer lgr.tmux.RUnlock()
+
+	for _, host := range lgr.targetHosts {
+		inf := TargetInfo{
+			Name: host.String(),
+			Type: fmt.Sprintf("%T", host.target),
+		}
+		infos = append(infos, inf)
+	}
+	return infos
+}
+
+// RemoveTargets safely removes one or more targets based on the filtering method.
+// f should return true to delete the target, false to keep it.
+// When removing a target, best effort is made to write any queued log records before
+// closing, with cxt determining how much time can be spent in total.
+// Note, keep the timeout short since this method blocks certain logging operations.
+func (lgr *Logr) RemoveTargets(cxt context.Context, f func(ti TargetInfo) bool) error {
+	errs := merror.New()
+	hosts := make([]*TargetHost, 0)
+
+	lgr.tmux.Lock()
+	defer lgr.tmux.Unlock()
+
+	for _, host := range lgr.targetHosts {
+		inf := TargetInfo{
+			Name: host.String(),
+			Type: fmt.Sprintf("%T", host.target),
+		}
+		if f(inf) {
+			if err := host.Shutdown(cxt); err != nil {
+				errs.Append(err)
+			}
+		} else {
+			hosts = append(hosts, host)
+		}
+	}
+
+	lgr.targetHosts = hosts
+	lgr.ResetLevelCache()
+
+	return errs.ErrorOrNil()
+}
+
+// ResetLevelCache resets the cached results of `IsLevelEnabled`. This is
+// called any time a Target is added or a target's level is changed.
+func (lgr *Logr) ResetLevelCache() {
+	lgr.lvlCache.clear()
+}
+
+// SetMetricsCollector sets (or resets) the metrics collector to be used for gathering
+// metrics for all targets. Only targets added after this call will use the collector.
+//
+// To ensure all targets use a collector, use the `SetMetricsCollector` option when
+// creating the Logr instead, or configure/reconfigure the Logr after calling this method.
+func (lgr *Logr) SetMetricsCollector(collector MetricsCollector, updateFreqMillis int64) {
+	lgr.initMetrics(collector, updateFreqMillis)
+}
+
+// enqueue adds a log record to the logr queue. If the queue is full then
+// this function either blocks or the log record is dropped, depending on
+// the result of calling `OnQueueFull`.
+func (lgr *Logr) enqueue(rec *LogRec) {
+	select {
+	case lgr.in <- rec:
+	default:
+		if lgr.options.onQueueFull != nil && lgr.options.onQueueFull(rec, cap(lgr.in)) {
+			return // drop the record
+		}
+		select {
+		case <-time.After(lgr.options.enqueueTimeout):
+			lgr.ReportError(fmt.Errorf("enqueue timed out for log rec [%v]", rec))
+		case lgr.in <- rec: // block until success or timeout
+		}
+	}
+}
+
+// Flush blocks while flushing the logr queue and all target queues, by
+// writing existing log records to valid targets.
+// Any attempts to add new log records will block until flush is complete.
+// `logr.FlushTimeout` determines how long flush can execute before
+// timing out. Use `IsTimeoutError` to determine if the returned error is
+// due to a timeout.
+func (lgr *Logr) Flush() error {
+	ctx, cancel := context.WithTimeout(context.Background(), lgr.options.flushTimeout)
+	defer cancel()
+	return lgr.FlushWithTimeout(ctx)
+}
+
+// Flush blocks while flushing the logr queue and all target queues, by
+// writing existing log records to valid targets.
+// Any attempts to add new log records will block until flush is complete.
+// Use `IsTimeoutError` to determine if the returned error is
+// due to a timeout.
+func (lgr *Logr) FlushWithTimeout(ctx context.Context) error {
+	if !lgr.HasTargets() {
+		return nil
+	}
+
+	if lgr.IsShutdown() {
+		return errors.New("Flush called on shut down Logr")
+	}
+
+	rec := newFlushLogRec(lgr.NewLogger())
+	lgr.enqueue(rec)
+
+	select {
+	case <-ctx.Done():
+		return newTimeoutError("logr queue flush timeout")
+	case <-rec.flush:
+	}
+	return nil
+}
+
+// IsShutdown returns true if this Logr instance has been shut down.
+// No further log records can be enqueued and no targets added after
+// shutdown.
+func (lgr *Logr) IsShutdown() bool {
+	return atomic.LoadInt32(&lgr.shutdown) != 0
+}
+
+// Shutdown cleanly stops the logging engine after making best efforts
+// to flush all targets. Call this function right before application
+// exit - logr cannot be restarted once shut down.
+// `logr.ShutdownTimeout` determines how long shutdown can execute before
+// timing out. Use `IsTimeoutError` to determine if the returned error is
+// due to a timeout.
+func (lgr *Logr) Shutdown() error {
+	ctx, cancel := context.WithTimeout(context.Background(), lgr.options.shutdownTimeout)
+	defer cancel()
+	return lgr.ShutdownWithTimeout(ctx)
+}
+
+// Shutdown cleanly stops the logging engine after making best efforts
+// to flush all targets. Call this function right before application
+// exit - logr cannot be restarted once shut down.
+// Use `IsTimeoutError` to determine if the returned error is due to a
+// timeout.
+func (lgr *Logr) ShutdownWithTimeout(ctx context.Context) error {
+	if err := lgr.FlushWithTimeout(ctx); err != nil {
+		return err
+	}
+
+	if atomic.SwapInt32(&lgr.shutdown, 1) != 0 {
+		return errors.New("Shutdown called again after shut down")
+	}
+
+	lgr.ResetLevelCache()
+	lgr.stopMetricsUpdater()
+
+	close(lgr.quit)
+
+	errs := merror.New()
+
+	// Wait for read loop to exit
+	select {
+	case <-ctx.Done():
+		errs.Append(newTimeoutError("logr queue shutdown timeout"))
+	case <-lgr.done:
+	}
+
+	// logr.in channel should now be drained to targets and no more log records
+	// can be added.
+	lgr.tmux.RLock()
+	defer lgr.tmux.RUnlock()
+	for _, host := range lgr.targetHosts {
+		err := host.Shutdown(ctx)
+		if err != nil {
+			errs.Append(err)
+		}
+	}
+	return errs.ErrorOrNil()
+}
+
+// ReportError is used to notify the host application of any internal logging errors.
+// If `OnLoggerError` is not nil, it is called with the error, otherwise the error is
+// output to `os.Stderr`.
+func (lgr *Logr) ReportError(err interface{}) {
+	lgr.incErrorCounter()
+
+	if lgr.options.onLoggerError == nil {
+		fmt.Fprintln(os.Stderr, err)
+		return
+	}
+	lgr.options.onLoggerError(fmt.Errorf("%v", err))
+}
+
+// BorrowBuffer borrows a buffer from the pool. Release the buffer to reduce garbage collection.
+func (lgr *Logr) BorrowBuffer() *bytes.Buffer {
+	if lgr.options.disableBufferPool {
+		return &bytes.Buffer{}
+	}
+	return lgr.bufferPool.Get().(*bytes.Buffer)
+}
+
+// ReleaseBuffer returns a buffer to the pool to reduce garbage collection. The buffer is only
+// retained if less than MaxPooledBuffer.
+func (lgr *Logr) ReleaseBuffer(buf *bytes.Buffer) {
+	if !lgr.options.disableBufferPool && buf.Cap() < lgr.options.maxPooledBuffer {
+		buf.Reset()
+		lgr.bufferPool.Put(buf)
+	}
+}
+
+// start selects on incoming log records until shutdown record is received.
+// Incoming log records are fanned out to all log targets.
+func (lgr *Logr) start() {
+	defer func() {
+		if r := recover(); r != nil {
+			lgr.ReportError(r)
+			go lgr.start()
+		} else {
+			close(lgr.done)
+		}
+	}()
+
+	for {
+		var rec *LogRec
+		select {
+		case rec = <-lgr.in:
+			if rec.flush != nil {
+				lgr.flush(rec.flush)
+			} else {
+				rec.prep()
+				lgr.fanout(rec)
+			}
+		case <-lgr.quit:
+			return
+		}
+	}
+}
+
+// fanout pushes a LogRec to all targets.
+func (lgr *Logr) fanout(rec *LogRec) {
+	var host *TargetHost
+	defer func() {
+		if r := recover(); r != nil {
+			lgr.ReportError(fmt.Errorf("fanout failed for target %s, %v", host.String(), r))
+		}
+	}()
+
+	var logged bool
+
+	lgr.tmux.RLock()
+	defer lgr.tmux.RUnlock()
+	for _, host = range lgr.targetHosts {
+		if enabled, _ := host.IsLevelEnabled(rec.Level()); enabled {
+			host.Log(rec)
+			logged = true
+		}
+	}
+
+	if logged {
+		lgr.incLoggedCounter()
+	}
+}
+
+// flush drains the queue and notifies when done.
+func (lgr *Logr) flush(done chan<- struct{}) {
+	// first drain the logr queue.
+loop:
+	for {
+		var rec *LogRec
+		select {
+		case rec = <-lgr.in:
+			if rec.flush == nil {
+				rec.prep()
+				lgr.fanout(rec)
+			}
+		default:
+			break loop
+		}
+	}
+
+	logger := lgr.NewLogger()
+
+	// drain all the targets; block until finished.
+	lgr.tmux.RLock()
+	defer lgr.tmux.RUnlock()
+	for _, host := range lgr.targetHosts {
+		rec := newFlushLogRec(logger)
+		host.Log(rec)
+		<-rec.flush
+	}
+	done <- struct{}{}
+}
diff --git a/vendor/github.com/mattermost/logr/v2/logrec.go b/vendor/github.com/mattermost/logr/v2/logrec.go
new file mode 100644
index 00000000..76d51b9e
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/logrec.go
@@ -0,0 +1,182 @@
+package logr
+
+import (
+	"fmt"
+	"path/filepath"
+	"runtime"
+	"strings"
+	"sync"
+	"time"
+)
+
+// LogRec collects raw, unformatted data to be logged.
+// TODO:  pool these?  how to reliably know when targets are done with them? Copy for each target?
+type LogRec struct {
+	mux  sync.RWMutex
+	time time.Time
+
+	level  Level
+	logger Logger
+
+	msg     string
+	newline bool
+	fields  []Field
+
+	stackPC    []uintptr
+	stackCount int
+
+	// flushes Logr and target queues when not nil.
+	flush chan struct{}
+
+	// remaining fields calculated by `prep`
+	frames    []runtime.Frame
+	fieldsAll []Field
+	caller    string
+}
+
+// NewLogRec creates a new LogRec with the current time and optional stack trace.
+func NewLogRec(lvl Level, logger Logger, msg string, fields []Field, incStacktrace bool) *LogRec {
+	rec := &LogRec{time: time.Now(), logger: logger, level: lvl, msg: msg, fields: fields}
+	if incStacktrace {
+		rec.stackPC = make([]uintptr, DefaultMaxStackFrames)
+		rec.stackCount = runtime.Callers(2, rec.stackPC)
+	}
+	return rec
+}
+
+// newFlushLogRec creates a LogRec that flushes the Logr queue and
+// any target queues that support flushing.
+func newFlushLogRec(logger Logger) *LogRec {
+	return &LogRec{logger: logger, flush: make(chan struct{})}
+}
+
+// prep resolves stack trace to frames.
+func (rec *LogRec) prep() {
+	rec.mux.Lock()
+	defer rec.mux.Unlock()
+
+	// include log rec fields and logger fields added via "With"
+	rec.fieldsAll = make([]Field, 0, len(rec.fields)+len(rec.logger.fields))
+	rec.fieldsAll = append(rec.fieldsAll, rec.logger.fields...)
+	rec.fieldsAll = append(rec.fieldsAll, rec.fields...)
+
+	filter := rec.logger.lgr.options.stackFilter
+
+	// resolve stack trace
+	if rec.stackCount > 0 {
+		rec.frames = make([]runtime.Frame, 0, rec.stackCount)
+		frames := runtime.CallersFrames(rec.stackPC[:rec.stackCount])
+		for {
+			frame, more := frames.Next()
+
+			// remove all package entries that are in filter.
+			pkg := ResolvePackageName(frame.Function)
+			if _, ok := filter[pkg]; !ok && pkg != "" {
+				rec.frames = append(rec.frames, frame)
+			}
+
+			if !more {
+				break
+			}
+		}
+	}
+
+	// calc caller if stack trace provided
+	if len(rec.frames) > 0 {
+		rec.caller = calcCaller(rec.frames)
+	}
+}
+
+// WithTime returns a shallow copy of the log record while replacing
+// the time. This can be used by targets and formatters to adjust
+// the time, or take ownership of the log record.
+func (rec *LogRec) WithTime(time time.Time) *LogRec {
+	rec.mux.RLock()
+	defer rec.mux.RUnlock()
+
+	return &LogRec{
+		time:       time,
+		level:      rec.level,
+		logger:     rec.logger,
+		msg:        rec.msg,
+		newline:    rec.newline,
+		fields:     rec.fields,
+		stackPC:    rec.stackPC,
+		stackCount: rec.stackCount,
+		frames:     rec.frames,
+	}
+}
+
+// Logger returns the `Logger` that created this `LogRec`.
+func (rec *LogRec) Logger() Logger {
+	return rec.logger
+}
+
+// Time returns this log record's time stamp.
+func (rec *LogRec) Time() time.Time {
+	// no locking needed as this field is not mutated.
+	return rec.time
+}
+
+// Level returns this log record's Level.
+func (rec *LogRec) Level() Level {
+	// no locking needed as this field is not mutated.
+	return rec.level
+}
+
+// Fields returns this log record's Fields.
+func (rec *LogRec) Fields() []Field {
+	// no locking needed as this field is not mutated.
+	return rec.fieldsAll
+}
+
+// Msg returns this log record's message text.
+func (rec *LogRec) Msg() string {
+	rec.mux.RLock()
+	defer rec.mux.RUnlock()
+	return rec.msg
+}
+
+// StackFrames returns this log record's stack frames or
+// nil if no stack trace was required.
+func (rec *LogRec) StackFrames() []runtime.Frame {
+	rec.mux.RLock()
+	defer rec.mux.RUnlock()
+	return rec.frames
+}
+
+// Caller returns this log record's caller info, meaning the file and line
+// number where this log record was emitted. Returns empty string if no
+// stack trace was provided.
+func (rec *LogRec) Caller() string {
+	rec.mux.RLock()
+	defer rec.mux.RUnlock()
+	return rec.caller
+}
+
+// String returns a string representation of this log record.
+func (rec *LogRec) String() string {
+	if rec.flush != nil {
+		return "[flusher]"
+	}
+
+	f := &DefaultFormatter{}
+	buf := rec.logger.lgr.BorrowBuffer()
+	defer rec.logger.lgr.ReleaseBuffer(buf)
+	buf, _ = f.Format(rec, rec.Level(), buf)
+	return strings.TrimSpace(buf.String())
+}
+
+func calcCaller(frames []runtime.Frame) string {
+	for _, frame := range frames {
+		if frame.File == "" {
+			continue
+		}
+
+		dir, file := filepath.Split(frame.File)
+		base := filepath.Base(dir)
+
+		return fmt.Sprintf("%s/%s:%d", base, file, frame.Line)
+	}
+	return ""
+}
diff --git a/vendor/github.com/mattermost/logr/v2/metrics.go b/vendor/github.com/mattermost/logr/v2/metrics.go
new file mode 100644
index 00000000..f4f4d67f
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/metrics.go
@@ -0,0 +1,140 @@
+package logr
+
+import "time"
+
+const (
+	DefMetricsUpdateFreqMillis = 15000 // 15 seconds
+)
+
+// Counter is a simple metrics sink that can only increment a value.
+// Implementations are external to Logr and provided via `MetricsCollector`.
+type Counter interface {
+	// Inc increments the counter by 1. Use Add to increment it by arbitrary non-negative values.
+	Inc()
+	// Add adds the given value to the counter. It panics if the value is < 0.
+	Add(float64)
+}
+
+// Gauge is a simple metrics sink that can receive values and increase or decrease.
+// Implementations are external to Logr and provided via `MetricsCollector`.
+type Gauge interface {
+	// Set sets the Gauge to an arbitrary value.
+	Set(float64)
+	// Add adds the given value to the Gauge. (The value can be negative, resulting in a decrease of the Gauge.)
+	Add(float64)
+	// Sub subtracts the given value from the Gauge. (The value can be negative, resulting in an increase of the Gauge.)
+	Sub(float64)
+}
+
+// MetricsCollector provides a way for users of this Logr package to have metrics pushed
+// in an efficient way to any backend, e.g. Prometheus.
+// For each target added to Logr, the supplied MetricsCollector will provide a Gauge
+// and Counters that will be called frequently as logging occurs.
+type MetricsCollector interface {
+	// QueueSizeGauge returns a Gauge that will be updated by the named target.
+	QueueSizeGauge(target string) (Gauge, error)
+	// LoggedCounter returns a Counter that will be incremented by the named target.
+	LoggedCounter(target string) (Counter, error)
+	// ErrorCounter returns a Counter that will be incremented by the named target.
+	ErrorCounter(target string) (Counter, error)
+	// DroppedCounter returns a Counter that will be incremented by the named target.
+	DroppedCounter(target string) (Counter, error)
+	// BlockedCounter returns a Counter that will be incremented by the named target.
+	BlockedCounter(target string) (Counter, error)
+}
+
+// TargetWithMetrics is a target that provides metrics.
+type TargetWithMetrics interface {
+	EnableMetrics(collector MetricsCollector, updateFreqMillis int64) error
+}
+
+type metrics struct {
+	collector        MetricsCollector
+	updateFreqMillis int64
+	queueSizeGauge   Gauge
+	loggedCounter    Counter
+	errorCounter     Counter
+	done             chan struct{}
+}
+
+// initMetrics initializes metrics collection.
+func (lgr *Logr) initMetrics(collector MetricsCollector, updatefreq int64) {
+	lgr.stopMetricsUpdater()
+
+	if collector == nil {
+		lgr.metricsMux.Lock()
+		lgr.metrics = nil
+		lgr.metricsMux.Unlock()
+		return
+	}
+
+	metrics := &metrics{
+		collector:        collector,
+		updateFreqMillis: updatefreq,
+		done:             make(chan struct{}),
+	}
+	metrics.queueSizeGauge, _ = collector.QueueSizeGauge("_logr")
+	metrics.loggedCounter, _ = collector.LoggedCounter("_logr")
+	metrics.errorCounter, _ = collector.ErrorCounter("_logr")
+
+	lgr.metricsMux.Lock()
+	lgr.metrics = metrics
+	lgr.metricsMux.Unlock()
+
+	go lgr.startMetricsUpdater()
+}
+
+func (lgr *Logr) setQueueSizeGauge(val float64) {
+	lgr.metricsMux.RLock()
+	defer lgr.metricsMux.RUnlock()
+
+	if lgr.metrics != nil {
+		lgr.metrics.queueSizeGauge.Set(val)
+	}
+}
+
+func (lgr *Logr) incLoggedCounter() {
+	lgr.metricsMux.RLock()
+	defer lgr.metricsMux.RUnlock()
+
+	if lgr.metrics != nil {
+		lgr.metrics.loggedCounter.Inc()
+	}
+}
+
+func (lgr *Logr) incErrorCounter() {
+	lgr.metricsMux.RLock()
+	defer lgr.metricsMux.RUnlock()
+
+	if lgr.metrics != nil {
+		lgr.metrics.errorCounter.Inc()
+	}
+}
+
+// startMetricsUpdater updates the metrics for any polled values every `metricsUpdateFreqSecs` seconds until
+// logr is closed.
+func (lgr *Logr) startMetricsUpdater() {
+	for {
+		lgr.metricsMux.RLock()
+		metrics := lgr.metrics
+		c := metrics.done
+		lgr.metricsMux.RUnlock()
+
+		select {
+		case <-c:
+			return
+		case <-time.After(time.Duration(metrics.updateFreqMillis) * time.Millisecond):
+			lgr.setQueueSizeGauge(float64(len(lgr.in)))
+		}
+	}
+}
+
+func (lgr *Logr) stopMetricsUpdater() {
+	lgr.metricsMux.Lock()
+	defer lgr.metricsMux.Unlock()
+
+	if lgr.metrics != nil && lgr.metrics.done != nil {
+		close(lgr.metrics.done)
+		lgr.metrics.done = nil
+	}
+}
diff --git a/vendor/github.com/mattermost/logr/v2/options.go b/vendor/github.com/mattermost/logr/v2/options.go
new file mode 100644
index 00000000..638f638a
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/options.go
@@ -0,0 +1,192 @@
+package logr
+
+import (
+	"errors"
+	"time"
+)
+
+type Option func(*Logr) error
+
+type options struct {
+	maxQueueSize            int
+	onLoggerError           func(error)
+	onQueueFull             func(rec *LogRec, maxQueueSize int) bool
+	onTargetQueueFull       func(target Target, rec *LogRec, maxQueueSize int) bool
+	onExit                  func(code int)
+	onPanic                 func(err interface{})
+	enqueueTimeout          time.Duration
+	shutdownTimeout         time.Duration
+	flushTimeout            time.Duration
+	useSyncMapLevelCache    bool
+	maxPooledBuffer         int
+	disableBufferPool       bool
+	metricsCollector        MetricsCollector
+	metricsUpdateFreqMillis int64
+	stackFilter             map[string]struct{}
+}
+
+// MaxQueueSize is the maximum number of log records that can be queued.
+// If exceeded, `OnQueueFull` is called which determines if the log
+// record will be dropped or block until add is successful.
+// Defaults to DefaultMaxQueueSize.
+func MaxQueueSize(size int) Option {
+	return func(l *Logr) error {
+		if size < 0 {
+			return errors.New("size cannot be less than zero")
+		}
+		l.options.maxQueueSize = size
+		return nil
+	}
+}
+
+// OnLoggerError, when not nil, is called any time an internal
+// logging error occurs. For example, this can happen when a
+// target cannot connect to its data sink.
+func OnLoggerError(f func(error)) Option {
+	return func(l *Logr) error {
+		l.options.onLoggerError = f
+		return nil
+	}
+}
+
+// OnQueueFull, when not nil, is called on an attempt to add
+// a log record to a full Logr queue.
+// `MaxQueueSize` can be used to modify the maximum queue size.
+// This function should return quickly, with a bool indicating whether
+// the log record should be dropped (true) or block until the log record
+// is successfully added (false). If nil then blocking (false) is assumed.
+func OnQueueFull(f func(rec *LogRec, maxQueueSize int) bool) Option {
+	return func(l *Logr) error {
+		l.options.onQueueFull = f
+		return nil
+	}
+}
+
+// OnTargetQueueFull, when not nil, is called on an attempt to add
+// a log record to a full target queue provided the target supports reporting
+// this condition.
+// This function should return quickly, with a bool indicating whether
+// the log record should be dropped (true) or block until the log record
+// is successfully added (false). If nil then blocking (false) is assumed.
+func OnTargetQueueFull(f func(target Target, rec *LogRec, maxQueueSize int) bool) Option {
+	return func(l *Logr) error {
+		l.options.onTargetQueueFull = f
+		return nil
+	}
+}
+
+// OnExit, when not nil, is called when a FatalXXX style log API is called.
+// When nil, then the default behavior is to cleanly shut down this Logr and
+// call `os.Exit(code)`.
+func OnExit(f func(code int)) Option {
+	return func(l *Logr) error {
+		l.options.onExit = f
+		return nil
+	}
+}
+
+// OnPanic, when not nil, is called when a PanicXXX style log API is called.
+// When nil, then the default behavior is to cleanly shut down this Logr and
+// call `panic(err)`.
+func OnPanic(f func(err interface{})) Option {
+	return func(l *Logr) error {
+		l.options.onPanic = f
+		return nil
+	}
+}
+
+// EnqueueTimeout is the amount of time a log record can take to be queued.
+// This only applies to blocking enqueue which happen after `logr.OnQueueFull`
+// is called and returns false.
+func EnqueueTimeout(dur time.Duration) Option {
+	return func(l *Logr) error {
+		l.options.enqueueTimeout = dur
+		return nil
+	}
+}
+
+// ShutdownTimeout is the amount of time `logr.Shutdown` can execute before
+// timing out. An alternative is to use `logr.ShutdownWithContext` and supply
+// a timeout.
+func ShutdownTimeout(dur time.Duration) Option {
+	return func(l *Logr) error {
+		l.options.shutdownTimeout = dur
+		return nil
+	}
+}
+
+// FlushTimeout is the amount of time `logr.Flush` can execute before
+// timing out. An alternative is to use `logr.FlushWithContext` and supply
+// a timeout.
+func FlushTimeout(dur time.Duration) Option {
+	return func(l *Logr) error {
+		l.options.flushTimeout = dur
+		return nil
+	}
+}
+
+// UseSyncMapLevelCache can be set to true when high concurrency (e.g. >32 cores)
+// is expected. This may improve performance with large numbers of cores - benchmark
+// for your use case.
+func UseSyncMapLevelCache(use bool) Option {
+	return func(l *Logr) error {
+		l.options.useSyncMapLevelCache = use
+		return nil
+	}
+}
+
+// MaxPooledBufferSize determines the maximum size of a buffer that can be
+// pooled. To reduce allocations, the buffers needed during formatting (etc)
+// are pooled. A very large log item will grow a buffer that could stay in
+// memory indefinitely. This setting lets you control how big a pooled buffer
+// can be - anything larger will be garbage collected after use.
+// Defaults to 1MB.
+func MaxPooledBufferSize(size int) Option {
+	return func(l *Logr) error {
+		l.options.maxPooledBuffer = size
+		return nil
+	}
+}
+
+// DisableBufferPool when true disables the buffer pool. See MaxPooledBuffer.
+func DisableBufferPool(disable bool) Option {
+	return func(l *Logr) error {
+		l.options.disableBufferPool = disable
+		return nil
+	}
+}
+
+// SetMetricsCollector enables metrics collection by supplying a MetricsCollector.
+// The MetricsCollector provides counters and gauges that are updated by log targets.
+// `updateFreqMillis` determines how often polled metrics are updated. Defaults to 15000 (15 seconds)
+// and must be at least 250 so we don't peg the CPU.
+func SetMetricsCollector(collector MetricsCollector, updateFreqMillis int64) Option {
+	return func(l *Logr) error {
+		if collector == nil {
+			return errors.New("collector cannot be nil")
+		}
+		if updateFreqMillis < 250 {
+			return errors.New("updateFreqMillis cannot be less than 250")
+		}
+		l.options.metricsCollector = collector
+		l.options.metricsUpdateFreqMillis = updateFreqMillis
+		return nil
+	}
+}
+
+// StackFilter provides a list of package names to exclude from the top of
+// stack traces.  The Logr packages are automatically filtered.
+func StackFilter(pkg ...string) Option {
+	return func(l *Logr) error {
+		if l.options.stackFilter == nil {
+			l.options.stackFilter = make(map[string]struct{})
+		}
+
+		for _, p := range pkg {
+			if p != "" {
+				l.options.stackFilter[p] = struct{}{}
+			}
+		}
+		return nil
+	}
+}
diff --git a/vendor/github.com/mattermost/logr/v2/pkg.go b/vendor/github.com/mattermost/logr/v2/pkg.go
new file mode 100644
index 00000000..873b2e95
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/pkg.go
@@ -0,0 +1,57 @@
+package logr
+
+import (
+	"runtime"
+	"strings"
+	"sync"
+)
+
+const (
+	maximumStackDepth int = 30
+)
+
+var (
+	logrPkg     string
+	pkgCalcOnce sync.Once
+)
+
+// GetPackageName returns the root package name of Logr.
+func GetLogrPackageName() string {
+	pkgCalcOnce.Do(func() {
+		logrPkg = GetPackageName("GetLogrPackageName")
+	})
+	return logrPkg
+}
+
+// GetPackageName returns the package name of the caller.
+// `callingFuncName` should be the name of the calling function and
+// should be unique enough not to collide with any runtime methods.
+func GetPackageName(callingFuncName string) string {
+	var pkgName string
+
+	pcs := make([]uintptr, maximumStackDepth)
+	_ = runtime.Callers(0, pcs)
+
+	for _, pc := range pcs {
+		funcName := runtime.FuncForPC(pc).Name()
+		if strings.Contains(funcName, callingFuncName) {
+			pkgName = ResolvePackageName(funcName)
+			break
+		}
+	}
+	return pkgName
+}
+
+// ResolvePackageName reduces a fully qualified function name to the package name
+func ResolvePackageName(f string) string {
+	for {
+		lastPeriod := strings.LastIndex(f, ".")
+		lastSlash := strings.LastIndex(f, "/")
+		if lastPeriod > lastSlash {
+			f = f[:lastPeriod]
+		} else {
+			break
+		}
+	}
+	return f
+}
diff --git a/vendor/github.com/mattermost/logr/v2/stdlogger.go b/vendor/github.com/mattermost/logr/v2/stdlogger.go
new file mode 100644
index 00000000..50171b3d
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/stdlogger.go
@@ -0,0 +1,56 @@
+package logr
+
+import (
+	"log"
+	"os"
+	"strings"
+)
+
+// NewStdLogger creates a standard logger backed by a Logr instance.
+// All log records are emitted with the specified log level.
+func NewStdLogger(level Level, logger Logger) *log.Logger {
+	adapter := newStdLogAdapter(logger, level)
+	return log.New(adapter, "", 0)
+}
+
+// RedirectStdLog redirects output from the standard library's package-global logger
+// to this logger at the specified level and with zero or more Field's. Since Logr already
+// handles caller annotations, timestamps, etc., it automatically disables the standard
+// library's annotations and prefixing.
+// A function is returned that restores the original prefix and flags and resets the standard
+// library's output to os.Stderr.
+func (lgr *Logr) RedirectStdLog(level Level, fields ...Field) func() {
+	flags := log.Flags()
+	prefix := log.Prefix()
+	log.SetFlags(0)
+	log.SetPrefix("")
+
+	logger := lgr.NewLogger().With(fields...)
+	adapter := newStdLogAdapter(logger, level)
+	log.SetOutput(adapter)
+
+	return func() {
+		log.SetFlags(flags)
+		log.SetPrefix(prefix)
+		log.SetOutput(os.Stderr)
+	}
+}
+
+type stdLogAdapter struct {
+	logger Logger
+	level  Level
+}
+
+func newStdLogAdapter(logger Logger, level Level) *stdLogAdapter {
+	return &stdLogAdapter{
+		logger: logger,
+		level:  level,
+	}
+}
+
+// Write implements io.Writer
+func (a *stdLogAdapter) Write(p []byte) (int, error) {
+	s := strings.TrimSpace(string(p))
+	a.logger.Log(a.level, s)
+	return len(p), nil
+}
diff --git a/vendor/github.com/mattermost/logr/v2/sugar.go b/vendor/github.com/mattermost/logr/v2/sugar.go
new file mode 100644
index 00000000..f4f300ee
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/sugar.go
@@ -0,0 +1,119 @@
+package logr
+
+import (
+	"fmt"
+)
+
+// Sugar provides a less structured API for logging.
+type Sugar struct {
+	logger Logger
+}
+
+func (s Sugar) sugarLog(lvl Level, msg string, args ...interface{}) {
+	if s.logger.IsLevelEnabled(lvl) {
+		fields := make([]Field, 0, len(args))
+		for _, arg := range args {
+			fields = append(fields, Any("", arg))
+		}
+		s.logger.Log(lvl, msg, fields...)
+	}
+}
+
+// Trace is a convenience method equivalent to `Log(TraceLevel, msg, args...)`.
+func (s Sugar) Trace(msg string, args ...interface{}) {
+	s.sugarLog(Trace, msg, args...)
+}
+
+// Debug is a convenience method equivalent to `Log(DebugLevel, msg, args...)`.
+func (s Sugar) Debug(msg string, args ...interface{}) {
+	s.sugarLog(Debug, msg, args...)
+}
+
+// Print ensures compatibility with std lib logger.
+func (s Sugar) Print(msg string, args ...interface{}) {
+	s.Info(msg, args...)
+}
+
+// Info is a convenience method equivalent to `Log(InfoLevel, msg, args...)`.
+func (s Sugar) Info(msg string, args ...interface{}) {
+	s.sugarLog(Info, msg, args...)
+}
+
+// Warn is a convenience method equivalent to `Log(WarnLevel, msg, args...)`.
+func (s Sugar) Warn(msg string, args ...interface{}) {
+	s.sugarLog(Warn, msg, args...)
+}
+
+// Error is a convenience method equivalent to `Log(ErrorLevel, msg, args...)`.
+func (s Sugar) Error(msg string, args ...interface{}) {
+	s.sugarLog(Error, msg, args...)
+}
+
+// Fatal is a convenience method equivalent to `Log(FatalLevel, msg, args...)`
+func (s Sugar) Fatal(msg string, args ...interface{}) {
+	s.sugarLog(Fatal, msg, args...)
+}
+
+// Panic is a convenience method equivalent to `Log(PanicLevel, msg, args...)`
+func (s Sugar) Panic(msg string, args ...interface{}) {
+	s.sugarLog(Panic, msg, args...)
+}
+
+//
+// Printf style
+//
+
+// Logf checks that the level matches one or more targets, and
+// if so, generates a log record that is added to the main
+// queue (channel). Arguments are handled in the manner of fmt.Printf.
+func (s Sugar) Logf(lvl Level, format string, args ...interface{}) {
+	if s.logger.IsLevelEnabled(lvl) {
+		var msg string
+		if format == "" {
+			msg = fmt.Sprint(args...)
+		} else {
+			msg = fmt.Sprintf(format, args...)
+		}
+		s.logger.Log(lvl, msg)
+	}
+}
+
+// Tracef is a convenience method equivalent to `Logf(TraceLevel, args...)`.
+func (s Sugar) Tracef(format string, args ...interface{}) {
+	s.Logf(Trace, format, args...)
+}
+
+// Debugf is a convenience method equivalent to `Logf(DebugLevel, args...)`.
+func (s Sugar) Debugf(format string, args ...interface{}) {
+	s.Logf(Debug, format, args...)
+}
+
+// Infof is a convenience method equivalent to `Logf(InfoLevel, args...)`.
+func (s Sugar) Infof(format string, args ...interface{}) {
+	s.Logf(Info, format, args...)
+}
+
+// Printf ensures compatibility with std lib logger.
+func (s Sugar) Printf(format string, args ...interface{}) {
+	s.Infof(format, args...)
+}
+
+// Warnf is a convenience method equivalent to `Logf(WarnLevel, args...)`.
+func (s Sugar) Warnf(format string, args ...interface{}) {
+	s.Logf(Warn, format, args...)
+}
+
+// Errorf is a convenience method equivalent to `Logf(ErrorLevel, args...)`.
+func (s Sugar) Errorf(format string, args ...interface{}) {
+	s.Logf(Error, format, args...)
+}
+
+// Fatalf is a convenience method equivalent to `Logf(FatalLevel, args...)`
+func (s Sugar) Fatalf(format string, args ...interface{}) {
+	s.Logf(Fatal, format, args...)
+}
+
+// Panicf is a convenience method equivalent to `Logf(PanicLevel, args...)`
+func (s Sugar) Panicf(format string, args ...interface{}) {
+	s.Logf(Panic, format, args...)
+}
diff --git a/vendor/github.com/mattermost/logr/v2/target.go b/vendor/github.com/mattermost/logr/v2/target.go
new file mode 100644
index 00000000..fa0a9320
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/target.go
@@ -0,0 +1,304 @@
+package logr
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"os"
+	"sync/atomic"
+	"time"
+)
+
+// Target represents a destination for log records such as file,
+// database, TCP socket, etc.
+type Target interface {
+	// Init is called once to initialize the target.
+	Init() error
+
+	// Write outputs to this target's destination.
+	Write(p []byte, rec *LogRec) (int, error)
+
+	// Shutdown is called once to free/close any resources.
+	// Target queue is already drained when this is called.
+	Shutdown() error
+}
+
+type targetMetrics struct {
+	queueSizeGauge Gauge
+	loggedCounter  Counter
+	errorCounter   Counter
+	droppedCounter Counter
+	blockedCounter Counter
+}
+
+type targetHostOptions struct {
+	name         string
+	filter       Filter
+	formatter    Formatter
+	maxQueueSize int
+	metrics      *metrics
+}
+
+// TargetHost hosts and manages the lifecycle of a target.
+// Incoming log records are queued and formatted before
+// being passed to the target.
+type TargetHost struct {
+	target Target
+	name   string
+
+	filter    Filter
+	formatter Formatter
+
+	in            chan *LogRec
+	quit          chan struct{} // closed by Shutdown to exit read loop
+	done          chan struct{} // closed when read loop exited
+	targetMetrics *targetMetrics
+
+	shutdown int32
+}
+
+func newTargetHost(target Target, options targetHostOptions) (*TargetHost, error) {
+	host := &TargetHost{
+		target:    target,
+		name:      options.name,
+		filter:    options.filter,
+		formatter: options.formatter,
+		in:        make(chan *LogRec, options.maxQueueSize),
+		quit:      make(chan struct{}),
+		done:      make(chan struct{}),
+	}
+
+	if host.name == "" {
+		host.name = fmt.Sprintf("%T", target)
+	}
+
+	if host.filter == nil {
+		host.filter = &StdFilter{Lvl: Fatal}
+	}
+	if host.formatter == nil {
+		host.formatter = &DefaultFormatter{}
+	}
+
+	err := host.initMetrics(options.metrics)
+	if err != nil {
+		return nil, err
+	}
+
+	err = target.Init()
+	if err != nil {
+		return nil, err
+	}
+
+	go host.start()
+
+	return host, nil
+}
+
+func (h *TargetHost) initMetrics(metrics *metrics) error {
+	if metrics == nil {
+		return nil
+	}
+
+	var err error
+	tmetrics := &targetMetrics{}
+
+	if tmetrics.queueSizeGauge, err = metrics.collector.QueueSizeGauge(h.name); err != nil {
+		return err
+	}
+	if tmetrics.loggedCounter, err = metrics.collector.LoggedCounter(h.name); err != nil {
+		return err
+	}
+	if tmetrics.errorCounter, err = metrics.collector.ErrorCounter(h.name); err != nil {
+		return err
+	}
+	if tmetrics.droppedCounter, err = metrics.collector.DroppedCounter(h.name); err != nil {
+		return err
+	}
+	if tmetrics.blockedCounter, err = metrics.collector.BlockedCounter(h.name); err != nil {
+		return err
+	}
+	h.targetMetrics = tmetrics
+
+	updateFreqMillis := metrics.updateFreqMillis
+	if updateFreqMillis == 0 {
+		updateFreqMillis = DefMetricsUpdateFreqMillis
+	}
+	if updateFreqMillis < 250 {
+		updateFreqMillis = 250 // don't peg the CPU
+	}
+
+	go h.startMetricsUpdater(updateFreqMillis)
+	return nil
+}
+
+// IsLevelEnabled returns true if this target should emit logs for the specified level.
+func (h *TargetHost) IsLevelEnabled(lvl Level) (enabled bool, level Level) {
+	level, enabled = h.filter.GetEnabledLevel(lvl)
+	return enabled, level
+}
+
+// Shutdown stops processing log records after making best
+// effort to flush queue.
+func (h *TargetHost) Shutdown(ctx context.Context) error {
+	if atomic.SwapInt32(&h.shutdown, 1) != 0 {
+		return errors.New("targetHost shutdown called more than once")
+	}
+
+	close(h.quit)
+
+	// No more records can be accepted; now wait for read loop to exit.
+	select {
+	case <-ctx.Done():
+	case <-h.done:
+	}
+
+	// b.in channel should now be drained.
+	return h.target.Shutdown()
+}
+
+// Log queues a log record to be output to this target's destination.
+func (h *TargetHost) Log(rec *LogRec) {
+	if atomic.LoadInt32(&h.shutdown) != 0 {
+		return
+	}
+
+	lgr := rec.Logger().Logr()
+	select {
+	case h.in <- rec:
+	default:
+		handler := lgr.options.onTargetQueueFull
+		if handler != nil && handler(h.target, rec, cap(h.in)) {
+			h.incDroppedCounter()
+			return // drop the record
+		}
+		h.incBlockedCounter()
+
+		select {
+		case <-time.After(lgr.options.enqueueTimeout):
+			lgr.ReportError(fmt.Errorf("target enqueue timeout for log rec [%v]", rec))
+		case h.in <- rec: // block until success or timeout
+		}
+	}
+}
+
+func (h *TargetHost) setQueueSizeGauge(val float64) {
+	if h.targetMetrics != nil {
+		h.targetMetrics.queueSizeGauge.Set(val)
+	}
+}
+
+func (h *TargetHost) incLoggedCounter() {
+	if h.targetMetrics != nil {
+		h.targetMetrics.loggedCounter.Inc()
+	}
+}
+
+func (h *TargetHost) incErrorCounter() {
+	if h.targetMetrics != nil {
+		h.targetMetrics.errorCounter.Inc()
+	}
+}
+
+func (h *TargetHost) incDroppedCounter() {
+	if h.targetMetrics != nil {
+		h.targetMetrics.droppedCounter.Inc()
+	}
+}
+
+func (h *TargetHost) incBlockedCounter() {
+	if h.targetMetrics != nil {
+		h.targetMetrics.blockedCounter.Inc()
+	}
+}
+
+// String returns a name for this target.
+func (h *TargetHost) String() string {
+	return h.name
+}
+
+// start accepts log records via In channel and writes to the
+// supplied target, until Done channel signaled.
+func (h *TargetHost) start() {
+	defer func() {
+		if r := recover(); r != nil {
+			fmt.Fprintln(os.Stderr, "TargetHost.start -- ", r)
+			go h.start()
+		} else {
+			close(h.done)
+		}
+	}()
+
+	for {
+		var rec *LogRec
+		select {
+		case rec = <-h.in:
+			if rec.flush != nil {
+				h.flush(rec.flush)
+			} else {
+				err := h.writeRec(rec)
+				if err != nil {
+					h.incErrorCounter()
+					rec.Logger().Logr().ReportError(err)
+				} else {
+					h.incLoggedCounter()
+				}
+			}
+		case <-h.quit:
+			return
+		}
+	}
+}
+
+func (h *TargetHost) writeRec(rec *LogRec) error {
+	level, enabled := h.filter.GetEnabledLevel(rec.Level())
+	if !enabled {
+		// how did we get here?
+		return fmt.Errorf("level %s not enabled for target %s", rec.Level().Name, h.name)
+	}
+
+	buf := rec.logger.lgr.BorrowBuffer()
+	defer rec.logger.lgr.ReleaseBuffer(buf)
+
+	buf, err := h.formatter.Format(rec, level, buf)
+	if err != nil {
+		return err
+	}
+
+	_, err = h.target.Write(buf.Bytes(), rec)
+	return err
+}
+
+// startMetricsUpdater updates the metrics for any polled values every `updateFreqMillis` seconds until
+// target is shut down.
+func (h *TargetHost) startMetricsUpdater(updateFreqMillis int64) {
+	for {
+		select {
+		case <-h.done:
+			return
+		case <-time.After(time.Duration(updateFreqMillis) * time.Millisecond):
+			h.setQueueSizeGauge(float64(len(h.in)))
+		}
+	}
+}
+
+// flush drains the queue and notifies when done.
+func (h *TargetHost) flush(done chan<- struct{}) {
+	for {
+		var rec *LogRec
+		var err error
+		select {
+		case rec = <-h.in:
+			// ignore any redundant flush records.
+			if rec.flush == nil {
+				err = h.writeRec(rec)
+				if err != nil {
+					h.incErrorCounter()
+					rec.Logger().Logr().ReportError(err)
+				}
+			}
+		default:
+			done <- struct{}{}
+			return
+		}
+	}
+}
diff --git a/vendor/github.com/mattermost/logr/v2/targets/file.go b/vendor/github.com/mattermost/logr/v2/targets/file.go
new file mode 100644
index 00000000..71133fac
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/targets/file.go
@@ -0,0 +1,78 @@
+package targets
+
+import (
+	"errors"
+	"io"
+
+	"github.com/mattermost/logr/v2"
+	"gopkg.in/natefinch/lumberjack.v2"
+)
+
+type FileOptions struct {
+	// Filename is the file to write logs to.  Backup log files will be retained
+	// in the same directory.  It uses <processname>-lumberjack.log in
+	// os.TempDir() if empty.
+	Filename string `json:"filename"`
+
+	// MaxSize is the maximum size in megabytes of the log file before it gets
+	// rotated. It defaults to 100 megabytes.
+	MaxSize int `json:"max_size"`
+
+	// MaxAge is the maximum number of days to retain old log files based on the
+	// timestamp encoded in their filename.  Note that a day is defined as 24
+	// hours and may not exactly correspond to calendar days due to daylight
+	// savings, leap seconds, etc. The default is not to remove old log files
+	// based on age.
+	MaxAge int `json:"max_age"`
+
+	// MaxBackups is the maximum number of old log files to retain.  The default
+	// is to retain all old log files (though MaxAge may still cause them to get
+	// deleted.)
+	MaxBackups int `json:"max_backups"`
+
+	// Compress determines if the rotated log files should be compressed
+	// using gzip. The default is not to perform compression.
+	Compress bool `json:"compress"`
+}
+
+func (fo FileOptions) CheckValid() error {
+	if fo.Filename == "" {
+		return errors.New("filename cannot be empty")
+	}
+	return nil
+}
+
+// File outputs log records to a file which can be log rotated based on size or age.
+// Uses `https://github.com/natefinch/lumberjack` for rotation.
+type File struct {
+	out io.WriteCloser
+}
+
+// NewFileTarget creates a target capable of outputting log records to a rotated file.
+func NewFileTarget(opts FileOptions) *File {
+	lumber := &lumberjack.Logger{
+		Filename:   opts.Filename,
+		MaxSize:    opts.MaxSize,
+		MaxBackups: opts.MaxBackups,
+		MaxAge:     opts.MaxAge,
+		Compress:   opts.Compress,
+	}
+	f := &File{out: lumber}
+	return f
+}
+
+// Init is called once to initialize the target.
+func (f *File) Init() error {
+	return nil
+}
+
+// Write outputs bytes to this file target.
+func (f *File) Write(p []byte, rec *logr.LogRec) (int, error) {
+	return f.out.Write(p)
+}
+
+// Shutdown is called once to free/close any resources.
+// Target queue is already drained when this is called.
+func (f *File) Shutdown() error {
+	return f.out.Close()
+}
diff --git a/vendor/github.com/mattermost/logr/v2/targets/syslog.go b/vendor/github.com/mattermost/logr/v2/targets/syslog.go
new file mode 100644
index 00000000..fc3fcc5f
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/targets/syslog.go
@@ -0,0 +1,112 @@
+// +build !windows,!nacl,!plan9
+
+package targets
+
+import (
+	"crypto/tls"
+	"errors"
+	"fmt"
+
+	"github.com/mattermost/logr/v2"
+	syslog "github.com/wiggin77/srslog"
+)
+
+// Syslog outputs log records to local or remote syslog.
+type Syslog struct {
+	params *SyslogOptions
+	writer *syslog.Writer
+}
+
+// SyslogOptions provides parameters for dialing a syslog daemon.
+type SyslogOptions struct {
+	IP       string `json:"ip,omitempty"` // deprecated
+	Host     string `json:"host"`
+	Port     int    `json:"port"`
+	TLS      bool   `json:"tls"`
+	Cert     string `json:"cert"`
+	Insecure bool   `json:"insecure"`
+	Tag      string `json:"tag"`
+}
+
+func (so SyslogOptions) CheckValid() error {
+	if so.Host == "" && so.IP == "" {
+		return errors.New("missing host")
+	}
+	if so.Port == 0 {
+		return errors.New("missing port")
+	}
+	return nil
+}
+
+// NewSyslogTarget creates a target capable of outputting log records to remote or local syslog, with or without TLS.
+func NewSyslogTarget(params *SyslogOptions) (*Syslog, error) {
+	if params == nil {
+		return nil, errors.New("params cannot be nil")
+	}
+
+	s := &Syslog{
+		params: params,
+	}
+	return s, nil
+}
+
+// Init is called once to initialize the target.
+func (s *Syslog) Init() error {
+	network := "tcp"
+	var config *tls.Config
+
+	if s.params.TLS {
+		network = "tcp+tls"
+		config = &tls.Config{InsecureSkipVerify: s.params.Insecure}
+		if s.params.Cert != "" {
+			pool, err := GetCertPool(s.params.Cert)
+			if err != nil {
+				return err
+			}
+			config.RootCAs = pool
+		}
+	}
+	raddr := fmt.Sprintf("%s:%d", s.params.IP, s.params.Port)
+	if raddr == ":0" {
+		// If no IP:port provided then connect to local syslog.
+		raddr = ""
+		network = ""
+	}
+
+	var err error
+	s.writer, err = syslog.DialWithTLSConfig(network, raddr, syslog.LOG_INFO, s.params.Tag, config)
+	return err
+}
+
+// Write outputs bytes to this file target.
+func (s *Syslog) Write(p []byte, rec *logr.LogRec) (int, error) {
+	txt := string(p)
+	n := len(txt)
+	var err error
+
+	switch rec.Level() {
+	case logr.Panic, logr.Fatal:
+		err = s.writer.Crit(txt)
+	case logr.Error:
+		err = s.writer.Err(txt)
+	case logr.Warn:
+		err = s.writer.Warning(txt)
+	case logr.Debug, logr.Trace:
+		err = s.writer.Debug(txt)
+	default:
+		// logr.Info plus all custom levels.
+		err = s.writer.Info(txt)
+	}
+
+	if err != nil {
+		n = 0
+		// syslog writer will try to reconnect.
+	}
+	return n, err
+}
+
+// Shutdown is called once to free/close any resources.
+// Target queue is already drained when this is called.
+func (s *Syslog) Shutdown() error {
+	return s.writer.Close()
+}
diff --git a/vendor/github.com/mattermost/logr/v2/targets/syslog_unsupported.go b/vendor/github.com/mattermost/logr/v2/targets/syslog_unsupported.go
new file mode 100644
index 00000000..e4086e96
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/targets/syslog_unsupported.go
@@ -0,0 +1,56 @@
+// +build windows nacl plan9
+
+package targets
+
+import (
+	"errors"
+
+	"github.com/mattermost/logr/v2"
+	syslog "github.com/wiggin77/srslog"
+)
+
+const (
+	unsupported = "Syslog target is not supported on this platform."
+)
+
+// Syslog outputs log records to local or remote syslog.
+type Syslog struct {
+	params *SyslogOptions
+	writer *syslog.Writer
+}
+
+// SyslogOptions provides parameters for dialing a syslog daemon.
+type SyslogOptions struct {
+	IP       string `json:"ip,omitempty"` // deprecated
+	Host     string `json:"host"`
+	Port     int    `json:"port"`
+	TLS      bool   `json:"tls"`
+	Cert     string `json:"cert"`
+	Insecure bool   `json:"insecure"`
+	Tag      string `json:"tag"`
+}
+
+func (so SyslogOptions) CheckValid() error {
+	return errors.New(unsupported)
+}
+
+// NewSyslogTarget creates a target capable of outputting log records to remote or local syslog, with or without TLS.
+func NewSyslogTarget(params *SyslogOptions) (*Syslog, error) {
+	return nil, errors.New(unsupported)
+}
+
+// Init is called once to initialize the target.
+func (s *Syslog) Init() error {
+	return errors.New(unsupported)
+}
+
+// Write outputs bytes to this file target.
+func (s *Syslog) Write(p []byte, rec *logr.LogRec) (int, error) {
+	return 0, errors.New(unsupported)
+}
+
+// Shutdown is called once to free/close any resources.
+// Target queue is already drained when this is called.
+func (s *Syslog) Shutdown() error {
+	return errors.New(unsupported)
+}
diff --git a/vendor/github.com/mattermost/logr/v2/targets/tcp.go b/vendor/github.com/mattermost/logr/v2/targets/tcp.go
new file mode 100644
index 00000000..ce73e034
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/targets/tcp.go
@@ -0,0 +1,251 @@
+// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
+// See LICENSE.txt for license information.
+
+package targets
+
+import (
+	"context"
+	"crypto/tls"
+	"errors"
+	"fmt"
+	"net"
+	"sync"
+	"time"
+
+	"github.com/mattermost/logr/v2"
+)
+
+const (
+	DialTimeoutSecs             = 30
+	WriteTimeoutSecs            = 30
+	RetryBackoffMillis    int64 = 100
+	MaxRetryBackoffMillis int64 = 30 * 1000 // 30 seconds
+)
+
+// Tcp outputs log records to raw socket server.
+type Tcp struct {
+	options *TcpOptions
+	addy    string
+
+	mutex    sync.Mutex
+	conn     net.Conn
+	monitor  chan struct{}
+	shutdown chan struct{}
+}
+
+// TcpOptions provides parameters for dialing a socket server.
+type TcpOptions struct {
+	IP       string `json:"ip,omitempty"` // deprecated
+	Host     string `json:"host"`
+	Port     int    `json:"port"`
+	TLS      bool   `json:"tls"`
+	Cert     string `json:"cert"`
+	Insecure bool   `json:"insecure"`
+}
+
+func (to TcpOptions) CheckValid() error {
+	if to.Host == "" && to.IP == "" {
+		return errors.New("missing host")
+	}
+	if to.Port == 0 {
+		return errors.New("missing port")
+	}
+	return nil
+}
+
+// NewTcpTarget creates a target capable of outputting log records to a raw socket, with or without TLS.
+func NewTcpTarget(options *TcpOptions) *Tcp {
+	tcp := &Tcp{
+		options:  options,
+		addy:     fmt.Sprintf("%s:%d", options.IP, options.Port),
+		monitor:  make(chan struct{}),
+		shutdown: make(chan struct{}),
+	}
+	return tcp
+}
+
+// Init is called once to initialize the target.
+func (tcp *Tcp) Init() error {
+	return nil
+}
+
+// getConn provides a net.Conn.  If a connection already exists, it is returned immediately,
+// otherwise this method blocks until a new connection is created, timeout or shutdown.
+func (tcp *Tcp) getConn(reporter func(err interface{})) (net.Conn, error) {
+	tcp.mutex.Lock()
+	defer tcp.mutex.Unlock()
+
+	if tcp.conn != nil {
+		return tcp.conn, nil
+	}
+
+	type result struct {
+		conn net.Conn
+		err  error
+	}
+
+	connChan := make(chan result)
+	ctx, cancel := context.WithTimeout(context.Background(), time.Second*DialTimeoutSecs)
+	defer cancel()
+
+	go func(ctx context.Context, ch chan result) {
+		conn, err := tcp.dial(ctx)
+		if err != nil {
+			reporter(fmt.Errorf("log target %s connection error: %w", tcp.String(), err))
+			return
+		}
+		tcp.conn = conn
+		tcp.monitor = make(chan struct{})
+		go monitor(tcp.conn, tcp.monitor)
+		ch <- result{conn: conn, err: err}
+	}(ctx, connChan)
+
+	select {
+	case <-tcp.shutdown:
+		return nil, errors.New("shutdown")
+	case res := <-connChan:
+		return res.conn, res.err
+	}
+}
+
+// dial connects to a TCP socket, and optionally performs a TLS handshake.
+// A non-nil context must be provided which can cancel the dial.
+func (tcp *Tcp) dial(ctx context.Context) (net.Conn, error) {
+	var dialer net.Dialer
+	dialer.Timeout = time.Second * DialTimeoutSecs
+	conn, err := dialer.DialContext(ctx, "tcp", fmt.Sprintf("%s:%d", tcp.options.IP, tcp.options.Port))
+	if err != nil {
+		return nil, err
+	}
+
+	if !tcp.options.TLS {
+		return conn, nil
+	}
+
+	tlsconfig := &tls.Config{
+		ServerName:         tcp.options.IP,
+		InsecureSkipVerify: tcp.options.Insecure,
+	}
+	if tcp.options.Cert != "" {
+		pool, err := GetCertPool(tcp.options.Cert)
+		if err != nil {
+			return nil, err
+		}
+		tlsconfig.RootCAs = pool
+	}
+
+	tlsConn := tls.Client(conn, tlsconfig)
+	if err := tlsConn.Handshake(); err != nil {
+		return nil, err
+	}
+	return tlsConn, nil
+}
+
+func (tcp *Tcp) close() error {
+	tcp.mutex.Lock()
+	defer tcp.mutex.Unlock()
+
+	var err error
+	if tcp.conn != nil {
+		close(tcp.monitor)
+		err = tcp.conn.Close()
+		tcp.conn = nil
+	}
+	return err
+}
+
+// Shutdown stops processing log records after making best effort to flush queue.
+func (tcp *Tcp) Shutdown() error {
+	err := tcp.close()
+	close(tcp.shutdown)
+	return err
+}
+
+// Write converts the log record to bytes, via the Formatter, and outputs to the socket.
+// Called by dedicated target goroutine and will block until success or shutdown.
+func (tcp *Tcp) Write(p []byte, rec *logr.LogRec) (int, error) {
+	try := 1
+	backoff := RetryBackoffMillis
+	for {
+		select {
+		case <-tcp.shutdown:
+			return 0, nil
+		default:
+		}
+
+		reporter := rec.Logger().Logr().ReportError
+
+		conn, err := tcp.getConn(reporter)
+		if err != nil {
+			reporter(fmt.Errorf("log target %s connection error: %w", tcp.String(), err))
+			backoff = tcp.sleep(backoff)
+			continue
+		}
+
+		err = conn.SetWriteDeadline(time.Now().Add(time.Second * WriteTimeoutSecs))
+		if err != nil {
+			reporter(fmt.Errorf("log target %s set write deadline error: %w", tcp.String(), err))
+		}
+
+		count, err := conn.Write(p)
+		if err == nil {
+			return count, nil
+		}
+
+		reporter(fmt.Errorf("log target %s write error: %w", tcp.String(), err))
+
+		_ = tcp.close()
+
+		backoff = tcp.sleep(backoff)
+		try++
+	}
+}
+
+// monitor continuously tries to read from the connection to detect socket close.
+// This is needed because TCP target uses a write only socket and Linux systems
+// take a long time to detect a loss of connectivity on a socket when only writing;
+// the writes simply fail without an error returned.
+func monitor(conn net.Conn, done <-chan struct{}) {
+	buf := make([]byte, 1)
+	for {
+		select {
+		case <-done:
+			return
+		case <-time.After(1 * time.Second):
+		}
+
+		err := conn.SetReadDeadline(time.Now().Add(time.Second * 30))
+		if err != nil {
+			continue
+		}
+
+		_, err = conn.Read(buf)
+
+		if errt, ok := err.(net.Error); ok && errt.Timeout() {
+			// read timeout is expected, keep looping.
+			continue
+		}
+
+		// Any other error closes the connection, forcing a reconnect.
+		conn.Close()
+		return
+	}
+}
+
+// String returns a string representation of this target.
+func (tcp *Tcp) String() string {
+	return fmt.Sprintf("TcpTarget[%s:%d]", tcp.options.IP, tcp.options.Port)
+}
+
+func (tcp *Tcp) sleep(backoff int64) int64 {
+	select {
+	case <-tcp.shutdown:
+	case <-time.After(time.Millisecond * time.Duration(backoff)):
+	}
+
+	nextBackoff := backoff + (backoff >> 1)
+	if nextBackoff > MaxRetryBackoffMillis {
+		nextBackoff = MaxRetryBackoffMillis
+	}
+	return nextBackoff
+}
diff --git a/vendor/github.com/mattermost/logr/v2/targets/test-tls-client-cert.pem b/vendor/github.com/mattermost/logr/v2/targets/test-tls-client-cert.pem
new file mode 100644
index 00000000..6ce8d042
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/targets/test-tls-client-cert.pem
@@ -0,0 +1,43 @@
+-----BEGIN CERTIFICATE-----
+MIIDjzCCAnegAwIBAgIRAPYfRSwdzKopBKxYxKqslJUwDQYJKoZIhvcNAQELBQAw
+JzElMCMGA1UEAwwcTWF0dGVybW9zdCwgSW5jLiBJbnRlcm5hbCBDQTAeFw0xOTAz
+MjIwMDE0MTVaFw0yMjAzMDYwMDE0MTVaMDsxOTA3BgNVBAMTME1hdHRlcm1vc3Qs
+IEluYy4gSW50ZXJuYWwgSW50ZXJtZWRpYXRlIEF1dGhvcml0eTCCASIwDQYJKoZI
+hvcNAQEBBQADggEPADCCAQoCggEBAMjliRdmvnNL4u/Jr/M2dPwQmTJXEBY/Vq9Q
+vAU52X3tRMCPxcaFz+x6ftuvdO2NdohXGAmtx9QU5LZcvFeTDpoVEBo9A+4jtLvD
+DZYaTNLpJmoSoJHaDbdWX+OAOqyDiWS741LuiMKWHhew9QOisat2ZINPxjmAd9wE
+xthTMgzsv7MUqnMer8U5OGQ0Qy7wAmNRc+2K3qPwkxe2RUvcte50DUFNgxEginsh
+vrkOXR383vUCZfu72qu8oggjiQpyTllu5je2Ap6JLjYLkEMiMqrYADuWor/ZHwa6
+WrFqVETxWfAV5u9Eh0wZM/KKYwRQuw9y+Nans77FmUl1tVWWNN8CAwEAAaOBoTCB
+njAMBgNVHRMEBTADAQH/MB0GA1UdDgQWBBQY4Uqswyr2hO/HetZt2RDxJdTIPjBi
+BgNVHSMEWzBZgBRFZXVg2Z5tNIsWeWjBLEy2yzKbMKErpCkwJzElMCMGA1UEAwwc
+TWF0dGVybW9zdCwgSW5jLiBJbnRlcm5hbCBDQYIUEifGUOM+bIFZo1tkjZB5YGBr
+0xEwCwYDVR0PBAQDAgEGMA0GCSqGSIb3DQEBCwUAA4IBAQAEdexL30Q0zBHmPAH8
+LhdK7dbzW1CmILbxRZlKAwRN+hKRXiMW3MHIkhNuoV9Aev602Q+ja4lWsRi/ktOL
+ni1FWx5gSScgdG8JGj47dOmoT3vXKX7+umiv4rQLPDl9/DKMuv204OYJq6VT+uNU
+6C6kL157jGJEO76H4fMZ8oYsD7Sq0zjiNKtuCYii0ngH3j3gB1jACLqRgveU7MdT
+pqOV2KfY31+h8VBtkUvljNztQ9xNY8Fjmt0SMf7E3FaUcaar3ZCr70G5aU3dKbe7
+47vGOBa5tCqw4YK0jgDKid3IJQul9a3J1mSsH8Wy3to9cAV4KGZBQLnzCX15a/+v
+3yVh
+-----END CERTIFICATE----- 
+-----BEGIN CERTIFICATE-----
+MIIDfjCCAmagAwIBAgIUEifGUOM+bIFZo1tkjZB5YGBr0xEwDQYJKoZIhvcNAQEL
+BQAwJzElMCMGA1UEAwwcTWF0dGVybW9zdCwgSW5jLiBJbnRlcm5hbCBDQTAeFw0x
+OTAzMjEyMTI4NDNaFw0yOTAzMTgyMTI4NDNaMCcxJTAjBgNVBAMMHE1hdHRlcm1v
+c3QsIEluYy4gSW50ZXJuYWwgQ0EwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEK
+AoIBAQDH0Xq5rMBGpKOVWTpb5MnaJIWFP/vOtvEk+7hVrfOfe1/5x0Kk3UgAHj85
+otaEZD1Lhn/JLkEqCiE/UXMJFwJDlNcO4CkdKBSpYX4bKAqy5q/X3QwioMSNpJG1
++YYrNGBH0sgKcKjyCaLhmqYLD0xZDVOmWIYBU9jUPyXw5U0tnsVrTqGMxVkm1xCY
+krCWN1ZoUrLvL0MCZc5qpxoPTopr9UO9cqSBSuy6BVWVuEWBZhpqHt+ul8VxhzzY
+q1k4l7r2qw+/wm1iJBedTeBVeWNag8JaVfLgu+/W7oJVlPO32Po7pnvHp8iJ3b4K
+zXyVHaTX4S6Em+6LV8855TYrShzlAgMBAAGjgaEwgZ4wHQYDVR0OBBYEFEVldWDZ
+nm00ixZ5aMEsTLbLMpswMGIGA1UdIwRbMFmAFEVldWDZnm00ixZ5aMEsTLbLMpsw
+oSukKTAnMSUwIwYDVQQDDBxNYXR0ZXJtb3N0LCBJbmMuIEludGVybmFsIENBghQS
+J8ZQ4z5sgVmjW2SNkHlgYGvTETAMBgNVHRMEBTADAQH/MAsGA1UdDwQEAwIBBjAN
+BgkqhkiG9w0BAQsFAAOCAQEAPiCWFmopyAkY2T3Zyo4yaRPhX1+VOTMKJtY6EUhq
+/GHz6kzEyvCUBf0N892cibGxekrEoItY9NqO6RQRfowg+Gn5kc13z4NyL2W8/eoT
+Xy0ZvfaQbU++fQ6pVtWtMblDMU9xiYd7/MDvJpO328l1Vhcdp8kEi+lCvpy0sCRc
+PxzPhbgCMAbZEGx+4TMQd4SZKzlRxW/2fflpReh6v1Dv0VDUSYQWwsUnaLpdKHfh
+a5k0vuySYcszE4YKlY0zakeFlJfp7fBp1xTwcdW8aTfw15EicPMwTc6xxA4JJUJx
+cddu817n1nayK5u6r9Qh1oIVkr0nC9YELMMy4dpPgJ88SA==
+-----END CERTIFICATE-----
diff --git a/vendor/github.com/mattermost/logr/v2/targets/utils.go b/vendor/github.com/mattermost/logr/v2/targets/utils.go
new file mode 100644
index 00000000..6e605af2
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/targets/utils.go
@@ -0,0 +1,33 @@
+package targets
+
+import (
+	"crypto/x509"
+	"encoding/base64"
+	"errors"
+	"io/ioutil"
+)
+
+// GetCertPool returns a x509.CertPool containing the cert(s)
+// from `cert`, which can be a path to a .pem or .crt file,
+// or a base64 encoded cert.
+func GetCertPool(cert string) (*x509.CertPool, error) {
+	if cert == "" {
+		return nil, errors.New("no cert provided")
+	}
+
+	// first treat as a file and try to read.
+	serverCert, err := ioutil.ReadFile(cert)
+	if err != nil {
+		// maybe it's a base64 encoded cert
+		serverCert, err = base64.StdEncoding.DecodeString(cert)
+		if err != nil {
+			return nil, errors.New("cert cannot be read")
+		}
+	}
+
+	pool := x509.NewCertPool()
+	if ok := pool.AppendCertsFromPEM(serverCert); ok {
+		return pool, nil
+	}
+	return nil, errors.New("cannot parse cert")
+}
diff --git a/vendor/github.com/mattermost/logr/v2/targets/writer.go b/vendor/github.com/mattermost/logr/v2/targets/writer.go
new file mode 100644
index 00000000..d9f64d76
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/targets/writer.go
@@ -0,0 +1,38 @@
+package targets
+
+import (
+	"io"
+	"io/ioutil"
+
+	"github.com/mattermost/logr/v2"
+)
+
+// Writer outputs log records to any `io.Writer`.
+type Writer struct {
+	out io.Writer
+}
+
+// NewWriterTarget creates a target capable of outputting log records to an io.Writer.
+func NewWriterTarget(out io.Writer) *Writer {
+	if out == nil {
+		out = ioutil.Discard
+	}
+	w := &Writer{out: out}
+	return w
+}
+
+// Init is called once to initialize the target.
+func (w *Writer) Init() error {
+	return nil
+}
+
+// Write outputs bytes to this file target.
+func (w *Writer) Write(p []byte, rec *logr.LogRec) (int, error) {
+	return w.out.Write(p)
+}
+
+// Shutdown is called once to free/close any resources.
+// Target queue is already drained when this is called.
+func (w *Writer) Shutdown() error {
+	return nil
+}
diff --git a/vendor/github.com/mattermost/logr/v2/timeout.go b/vendor/github.com/mattermost/logr/v2/timeout.go
new file mode 100644
index 00000000..37737bcf
--- /dev/null
+++ b/vendor/github.com/mattermost/logr/v2/timeout.go
@@ -0,0 +1,34 @@
+package logr
+
+import "github.com/wiggin77/merror"
+
+// timeoutError is returned from functions that can timeout.
+type timeoutError struct {
+	text string
+}
+
+// newTimeoutError returns a TimeoutError.
+func newTimeoutError(text string) timeoutError {
+	return timeoutError{text: text}
+}
+
+// IsTimeoutError returns true if err is a TimeoutError.
+func IsTimeoutError(err error) bool {
+	if _, ok := err.(timeoutError); ok {
+		return true
+	}
+	// if a multi-error, return true if any of the errors
+	// are TimeoutError
+	if merr, ok := err.(*merror.MError); ok {
+		for _, e := range merr.Errors() {
+			if IsTimeoutError(e) {
+				return true
+			}
+		}
+	}
+	return false
+}
+
+func (err timeoutError) Error() string {
+	return err.text
+}