diff options
Diffstat (limited to 'vendor/github.com/sirupsen')
27 files changed, 3119 insertions, 0 deletions
diff --git a/vendor/github.com/sirupsen/logrus/.gitignore b/vendor/github.com/sirupsen/logrus/.gitignore new file mode 100644 index 0000000..1fb13ab --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/.gitignore | |||
@@ -0,0 +1,4 @@ | |||
1 | logrus | ||
2 | vendor | ||
3 | |||
4 | .idea/ | ||
diff --git a/vendor/github.com/sirupsen/logrus/.golangci.yml b/vendor/github.com/sirupsen/logrus/.golangci.yml new file mode 100644 index 0000000..65dc285 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/.golangci.yml | |||
@@ -0,0 +1,40 @@ | |||
1 | run: | ||
2 | # do not run on test files yet | ||
3 | tests: false | ||
4 | |||
5 | # all available settings of specific linters | ||
6 | linters-settings: | ||
7 | errcheck: | ||
8 | # report about not checking of errors in type assetions: `a := b.(MyStruct)`; | ||
9 | # default is false: such cases aren't reported by default. | ||
10 | check-type-assertions: false | ||
11 | |||
12 | # report about assignment of errors to blank identifier: `num, _ := strconv.Atoi(numStr)`; | ||
13 | # default is false: such cases aren't reported by default. | ||
14 | check-blank: false | ||
15 | |||
16 | lll: | ||
17 | line-length: 100 | ||
18 | tab-width: 4 | ||
19 | |||
20 | prealloc: | ||
21 | simple: false | ||
22 | range-loops: false | ||
23 | for-loops: false | ||
24 | |||
25 | whitespace: | ||
26 | multi-if: false # Enforces newlines (or comments) after every multi-line if statement | ||
27 | multi-func: false # Enforces newlines (or comments) after every multi-line function signature | ||
28 | |||
29 | linters: | ||
30 | enable: | ||
31 | - megacheck | ||
32 | - govet | ||
33 | disable: | ||
34 | - maligned | ||
35 | - prealloc | ||
36 | disable-all: false | ||
37 | presets: | ||
38 | - bugs | ||
39 | - unused | ||
40 | fast: false | ||
diff --git a/vendor/github.com/sirupsen/logrus/.travis.yml b/vendor/github.com/sirupsen/logrus/.travis.yml new file mode 100644 index 0000000..c1dbd5a --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/.travis.yml | |||
@@ -0,0 +1,15 @@ | |||
1 | language: go | ||
2 | go_import_path: github.com/sirupsen/logrus | ||
3 | git: | ||
4 | depth: 1 | ||
5 | env: | ||
6 | - GO111MODULE=on | ||
7 | go: 1.15.x | ||
8 | os: linux | ||
9 | install: | ||
10 | - ./travis/install.sh | ||
11 | script: | ||
12 | - cd ci | ||
13 | - go run mage.go -v -w ../ crossBuild | ||
14 | - go run mage.go -v -w ../ lint | ||
15 | - go run mage.go -v -w ../ test | ||
diff --git a/vendor/github.com/sirupsen/logrus/CHANGELOG.md b/vendor/github.com/sirupsen/logrus/CHANGELOG.md new file mode 100644 index 0000000..7567f61 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/CHANGELOG.md | |||
@@ -0,0 +1,259 @@ | |||
1 | # 1.8.1 | ||
2 | Code quality: | ||
3 | * move magefile in its own subdir/submodule to remove magefile dependency on logrus consumer | ||
4 | * improve timestamp format documentation | ||
5 | |||
6 | Fixes: | ||
7 | * fix race condition on logger hooks | ||
8 | |||
9 | |||
10 | # 1.8.0 | ||
11 | |||
12 | Correct versioning number replacing v1.7.1. | ||
13 | |||
14 | # 1.7.1 | ||
15 | |||
16 | Beware this release has introduced a new public API and its semver is therefore incorrect. | ||
17 | |||
18 | Code quality: | ||
19 | * use go 1.15 in travis | ||
20 | * use magefile as task runner | ||
21 | |||
22 | Fixes: | ||
23 | * small fixes about new go 1.13 error formatting system | ||
24 | * Fix for long time race condiction with mutating data hooks | ||
25 | |||
26 | Features: | ||
27 | * build support for zos | ||
28 | |||
29 | # 1.7.0 | ||
30 | Fixes: | ||
31 | * the dependency toward a windows terminal library has been removed | ||
32 | |||
33 | Features: | ||
34 | * a new buffer pool management API has been added | ||
35 | * a set of `<LogLevel>Fn()` functions have been added | ||
36 | |||
37 | # 1.6.0 | ||
38 | Fixes: | ||
39 | * end of line cleanup | ||
40 | * revert the entry concurrency bug fix whic leads to deadlock under some circumstances | ||
41 | * update dependency on go-windows-terminal-sequences to fix a crash with go 1.14 | ||
42 | |||
43 | Features: | ||
44 | * add an option to the `TextFormatter` to completely disable fields quoting | ||
45 | |||
46 | # 1.5.0 | ||
47 | Code quality: | ||
48 | * add golangci linter run on travis | ||
49 | |||
50 | Fixes: | ||
51 | * add mutex for hooks concurrent access on `Entry` data | ||
52 | * caller function field for go1.14 | ||
53 | * fix build issue for gopherjs target | ||
54 | |||
55 | Feature: | ||
56 | * add an hooks/writer sub-package whose goal is to split output on different stream depending on the trace level | ||
57 | * add a `DisableHTMLEscape` option in the `JSONFormatter` | ||
58 | * add `ForceQuote` and `PadLevelText` options in the `TextFormatter` | ||
59 | |||
60 | # 1.4.2 | ||
61 | * Fixes build break for plan9, nacl, solaris | ||
62 | # 1.4.1 | ||
63 | This new release introduces: | ||
64 | * Enhance TextFormatter to not print caller information when they are empty (#944) | ||
65 | * Remove dependency on golang.org/x/crypto (#932, #943) | ||
66 | |||
67 | Fixes: | ||
68 | * Fix Entry.WithContext method to return a copy of the initial entry (#941) | ||
69 | |||
70 | # 1.4.0 | ||
71 | This new release introduces: | ||
72 | * Add `DeferExitHandler`, similar to `RegisterExitHandler` but prepending the handler to the list of handlers (semantically like `defer`) (#848). | ||
73 | * Add `CallerPrettyfier` to `JSONFormatter` and `TextFormatter` (#909, #911) | ||
74 | * Add `Entry.WithContext()` and `Entry.Context`, to set a context on entries to be used e.g. in hooks (#919). | ||
75 | |||
76 | Fixes: | ||
77 | * Fix wrong method calls `Logger.Print` and `Logger.Warningln` (#893). | ||
78 | * Update `Entry.Logf` to not do string formatting unless the log level is enabled (#903) | ||
79 | * Fix infinite recursion on unknown `Level.String()` (#907) | ||
80 | * Fix race condition in `getCaller` (#916). | ||
81 | |||
82 | |||
83 | # 1.3.0 | ||
84 | This new release introduces: | ||
85 | * Log, Logf, Logln functions for Logger and Entry that take a Level | ||
86 | |||
87 | Fixes: | ||
88 | * Building prometheus node_exporter on AIX (#840) | ||
89 | * Race condition in TextFormatter (#468) | ||
90 | * Travis CI import path (#868) | ||
91 | * Remove coloured output on Windows (#862) | ||
92 | * Pointer to func as field in JSONFormatter (#870) | ||
93 | * Properly marshal Levels (#873) | ||
94 | |||
95 | # 1.2.0 | ||
96 | This new release introduces: | ||
97 | * A new method `SetReportCaller` in the `Logger` to enable the file, line and calling function from which the trace has been issued | ||
98 | * A new trace level named `Trace` whose level is below `Debug` | ||
99 | * A configurable exit function to be called upon a Fatal trace | ||
100 | * The `Level` object now implements `encoding.TextUnmarshaler` interface | ||
101 | |||
102 | # 1.1.1 | ||
103 | This is a bug fix release. | ||
104 | * fix the build break on Solaris | ||
105 | * don't drop a whole trace in JSONFormatter when a field param is a function pointer which can not be serialized | ||
106 | |||
107 | # 1.1.0 | ||
108 | This new release introduces: | ||
109 | * several fixes: | ||
110 | * a fix for a race condition on entry formatting | ||
111 | * proper cleanup of previously used entries before putting them back in the pool | ||
112 | * the extra new line at the end of message in text formatter has been removed | ||
113 | * a new global public API to check if a level is activated: IsLevelEnabled | ||
114 | * the following methods have been added to the Logger object | ||
115 | * IsLevelEnabled | ||
116 | * SetFormatter | ||
117 | * SetOutput | ||
118 | * ReplaceHooks | ||
119 | * introduction of go module | ||
120 | * an indent configuration for the json formatter | ||
121 | * output colour support for windows | ||
122 | * the field sort function is now configurable for text formatter | ||
123 | * the CLICOLOR and CLICOLOR\_FORCE environment variable support in text formater | ||
124 | |||
125 | # 1.0.6 | ||
126 | |||
127 | This new release introduces: | ||
128 | * a new api WithTime which allows to easily force the time of the log entry | ||
129 | which is mostly useful for logger wrapper | ||
130 | * a fix reverting the immutability of the entry given as parameter to the hooks | ||
131 | a new configuration field of the json formatter in order to put all the fields | ||
132 | in a nested dictionnary | ||
133 | * a new SetOutput method in the Logger | ||
134 | * a new configuration of the textformatter to configure the name of the default keys | ||
135 | * a new configuration of the text formatter to disable the level truncation | ||
136 | |||
137 | # 1.0.5 | ||
138 | |||
139 | * Fix hooks race (#707) | ||
140 | * Fix panic deadlock (#695) | ||
141 | |||
142 | # 1.0.4 | ||
143 | |||
144 | * Fix race when adding hooks (#612) | ||
145 | * Fix terminal check in AppEngine (#635) | ||
146 | |||
147 | # 1.0.3 | ||
148 | |||
149 | * Replace example files with testable examples | ||
150 | |||
151 | # 1.0.2 | ||
152 | |||
153 | * bug: quote non-string values in text formatter (#583) | ||
154 | * Make (*Logger) SetLevel a public method | ||
155 | |||
156 | # 1.0.1 | ||
157 | |||
158 | * bug: fix escaping in text formatter (#575) | ||
159 | |||
160 | # 1.0.0 | ||
161 | |||
162 | * Officially changed name to lower-case | ||
163 | * bug: colors on Windows 10 (#541) | ||
164 | * bug: fix race in accessing level (#512) | ||
165 | |||
166 | # 0.11.5 | ||
167 | |||
168 | * feature: add writer and writerlevel to entry (#372) | ||
169 | |||
170 | # 0.11.4 | ||
171 | |||
172 | * bug: fix undefined variable on solaris (#493) | ||
173 | |||
174 | # 0.11.3 | ||
175 | |||
176 | * formatter: configure quoting of empty values (#484) | ||
177 | * formatter: configure quoting character (default is `"`) (#484) | ||
178 | * bug: fix not importing io correctly in non-linux environments (#481) | ||
179 | |||
180 | # 0.11.2 | ||
181 | |||
182 | * bug: fix windows terminal detection (#476) | ||
183 | |||
184 | # 0.11.1 | ||
185 | |||
186 | * bug: fix tty detection with custom out (#471) | ||
187 | |||
188 | # 0.11.0 | ||
189 | |||
190 | * performance: Use bufferpool to allocate (#370) | ||
191 | * terminal: terminal detection for app-engine (#343) | ||
192 | * feature: exit handler (#375) | ||
193 | |||
194 | # 0.10.0 | ||
195 | |||
196 | * feature: Add a test hook (#180) | ||
197 | * feature: `ParseLevel` is now case-insensitive (#326) | ||
198 | * feature: `FieldLogger` interface that generalizes `Logger` and `Entry` (#308) | ||
199 | * performance: avoid re-allocations on `WithFields` (#335) | ||
200 | |||
201 | # 0.9.0 | ||
202 | |||
203 | * logrus/text_formatter: don't emit empty msg | ||
204 | * logrus/hooks/airbrake: move out of main repository | ||
205 | * logrus/hooks/sentry: move out of main repository | ||
206 | * logrus/hooks/papertrail: move out of main repository | ||
207 | * logrus/hooks/bugsnag: move out of main repository | ||
208 | * logrus/core: run tests with `-race` | ||
209 | * logrus/core: detect TTY based on `stderr` | ||
210 | * logrus/core: support `WithError` on logger | ||
211 | * logrus/core: Solaris support | ||
212 | |||
213 | # 0.8.7 | ||
214 | |||
215 | * logrus/core: fix possible race (#216) | ||
216 | * logrus/doc: small typo fixes and doc improvements | ||
217 | |||
218 | |||
219 | # 0.8.6 | ||
220 | |||
221 | * hooks/raven: allow passing an initialized client | ||
222 | |||
223 | # 0.8.5 | ||
224 | |||
225 | * logrus/core: revert #208 | ||
226 | |||
227 | # 0.8.4 | ||
228 | |||
229 | * formatter/text: fix data race (#218) | ||
230 | |||
231 | # 0.8.3 | ||
232 | |||
233 | * logrus/core: fix entry log level (#208) | ||
234 | * logrus/core: improve performance of text formatter by 40% | ||
235 | * logrus/core: expose `LevelHooks` type | ||
236 | * logrus/core: add support for DragonflyBSD and NetBSD | ||
237 | * formatter/text: print structs more verbosely | ||
238 | |||
239 | # 0.8.2 | ||
240 | |||
241 | * logrus: fix more Fatal family functions | ||
242 | |||
243 | # 0.8.1 | ||
244 | |||
245 | * logrus: fix not exiting on `Fatalf` and `Fatalln` | ||
246 | |||
247 | # 0.8.0 | ||
248 | |||
249 | * logrus: defaults to stderr instead of stdout | ||
250 | * hooks/sentry: add special field for `*http.Request` | ||
251 | * formatter/text: ignore Windows for colors | ||
252 | |||
253 | # 0.7.3 | ||
254 | |||
255 | * formatter/\*: allow configuration of timestamp layout | ||
256 | |||
257 | # 0.7.2 | ||
258 | |||
259 | * formatter/text: Add configuration option for time format (#158) | ||
diff --git a/vendor/github.com/sirupsen/logrus/LICENSE b/vendor/github.com/sirupsen/logrus/LICENSE new file mode 100644 index 0000000..f090cb4 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/LICENSE | |||
@@ -0,0 +1,21 @@ | |||
1 | The MIT License (MIT) | ||
2 | |||
3 | Copyright (c) 2014 Simon Eskildsen | ||
4 | |||
5 | Permission is hereby granted, free of charge, to any person obtaining a copy | ||
6 | of this software and associated documentation files (the "Software"), to deal | ||
7 | in the Software without restriction, including without limitation the rights | ||
8 | to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
9 | copies of the Software, and to permit persons to whom the Software is | ||
10 | furnished to do so, subject to the following conditions: | ||
11 | |||
12 | The above copyright notice and this permission notice shall be included in | ||
13 | all copies or substantial portions of the Software. | ||
14 | |||
15 | THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
16 | IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
17 | FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
18 | AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
19 | LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
20 | OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN | ||
21 | THE SOFTWARE. | ||
diff --git a/vendor/github.com/sirupsen/logrus/README.md b/vendor/github.com/sirupsen/logrus/README.md new file mode 100644 index 0000000..d1d4a85 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/README.md | |||
@@ -0,0 +1,515 @@ | |||
1 | # Logrus <img src="http://i.imgur.com/hTeVwmJ.png" width="40" height="40" alt=":walrus:" class="emoji" title=":walrus:"/> [![Build Status](https://github.com/sirupsen/logrus/workflows/CI/badge.svg)](https://github.com/sirupsen/logrus/actions?query=workflow%3ACI) [![Build Status](https://travis-ci.org/sirupsen/logrus.svg?branch=master)](https://travis-ci.org/sirupsen/logrus) [![Go Reference](https://pkg.go.dev/badge/github.com/sirupsen/logrus.svg)](https://pkg.go.dev/github.com/sirupsen/logrus) | ||
2 | |||
3 | Logrus is a structured logger for Go (golang), completely API compatible with | ||
4 | the standard library logger. | ||
5 | |||
6 | **Logrus is in maintenance-mode.** We will not be introducing new features. It's | ||
7 | simply too hard to do in a way that won't break many people's projects, which is | ||
8 | the last thing you want from your Logging library (again...). | ||
9 | |||
10 | This does not mean Logrus is dead. Logrus will continue to be maintained for | ||
11 | security, (backwards compatible) bug fixes, and performance (where we are | ||
12 | limited by the interface). | ||
13 | |||
14 | I believe Logrus' biggest contribution is to have played a part in today's | ||
15 | widespread use of structured logging in Golang. There doesn't seem to be a | ||
16 | reason to do a major, breaking iteration into Logrus V2, since the fantastic Go | ||
17 | community has built those independently. Many fantastic alternatives have sprung | ||
18 | up. Logrus would look like those, had it been re-designed with what we know | ||
19 | about structured logging in Go today. Check out, for example, | ||
20 | [Zerolog][zerolog], [Zap][zap], and [Apex][apex]. | ||
21 | |||
22 | [zerolog]: https://github.com/rs/zerolog | ||
23 | [zap]: https://github.com/uber-go/zap | ||
24 | [apex]: https://github.com/apex/log | ||
25 | |||
26 | **Seeing weird case-sensitive problems?** It's in the past been possible to | ||
27 | import Logrus as both upper- and lower-case. Due to the Go package environment, | ||
28 | this caused issues in the community and we needed a standard. Some environments | ||
29 | experienced problems with the upper-case variant, so the lower-case was decided. | ||
30 | Everything using `logrus` will need to use the lower-case: | ||
31 | `github.com/sirupsen/logrus`. Any package that isn't, should be changed. | ||
32 | |||
33 | To fix Glide, see [these | ||
34 | comments](https://github.com/sirupsen/logrus/issues/553#issuecomment-306591437). | ||
35 | For an in-depth explanation of the casing issue, see [this | ||
36 | comment](https://github.com/sirupsen/logrus/issues/570#issuecomment-313933276). | ||
37 | |||
38 | Nicely color-coded in development (when a TTY is attached, otherwise just | ||
39 | plain text): | ||
40 | |||
41 | ![Colored](http://i.imgur.com/PY7qMwd.png) | ||
42 | |||
43 | With `log.SetFormatter(&log.JSONFormatter{})`, for easy parsing by logstash | ||
44 | or Splunk: | ||
45 | |||
46 | ```text | ||
47 | {"animal":"walrus","level":"info","msg":"A group of walrus emerges from the | ||
48 | ocean","size":10,"time":"2014-03-10 19:57:38.562264131 -0400 EDT"} | ||
49 | |||
50 | {"level":"warning","msg":"The group's number increased tremendously!", | ||
51 | "number":122,"omg":true,"time":"2014-03-10 19:57:38.562471297 -0400 EDT"} | ||
52 | |||
53 | {"animal":"walrus","level":"info","msg":"A giant walrus appears!", | ||
54 | "size":10,"time":"2014-03-10 19:57:38.562500591 -0400 EDT"} | ||
55 | |||
56 | {"animal":"walrus","level":"info","msg":"Tremendously sized cow enters the ocean.", | ||
57 | "size":9,"time":"2014-03-10 19:57:38.562527896 -0400 EDT"} | ||
58 | |||
59 | {"level":"fatal","msg":"The ice breaks!","number":100,"omg":true, | ||
60 | "time":"2014-03-10 19:57:38.562543128 -0400 EDT"} | ||
61 | ``` | ||
62 | |||
63 | With the default `log.SetFormatter(&log.TextFormatter{})` when a TTY is not | ||
64 | attached, the output is compatible with the | ||
65 | [logfmt](http://godoc.org/github.com/kr/logfmt) format: | ||
66 | |||
67 | ```text | ||
68 | time="2015-03-26T01:27:38-04:00" level=debug msg="Started observing beach" animal=walrus number=8 | ||
69 | time="2015-03-26T01:27:38-04:00" level=info msg="A group of walrus emerges from the ocean" animal=walrus size=10 | ||
70 | time="2015-03-26T01:27:38-04:00" level=warning msg="The group's number increased tremendously!" number=122 omg=true | ||
71 | time="2015-03-26T01:27:38-04:00" level=debug msg="Temperature changes" temperature=-4 | ||
72 | time="2015-03-26T01:27:38-04:00" level=panic msg="It's over 9000!" animal=orca size=9009 | ||
73 | time="2015-03-26T01:27:38-04:00" level=fatal msg="The ice breaks!" err=&{0x2082280c0 map[animal:orca size:9009] 2015-03-26 01:27:38.441574009 -0400 EDT panic It's over 9000!} number=100 omg=true | ||
74 | ``` | ||
75 | To ensure this behaviour even if a TTY is attached, set your formatter as follows: | ||
76 | |||
77 | ```go | ||
78 | log.SetFormatter(&log.TextFormatter{ | ||
79 | DisableColors: true, | ||
80 | FullTimestamp: true, | ||
81 | }) | ||
82 | ``` | ||
83 | |||
84 | #### Logging Method Name | ||
85 | |||
86 | If you wish to add the calling method as a field, instruct the logger via: | ||
87 | ```go | ||
88 | log.SetReportCaller(true) | ||
89 | ``` | ||
90 | This adds the caller as 'method' like so: | ||
91 | |||
92 | ```json | ||
93 | {"animal":"penguin","level":"fatal","method":"github.com/sirupsen/arcticcreatures.migrate","msg":"a penguin swims by", | ||
94 | "time":"2014-03-10 19:57:38.562543129 -0400 EDT"} | ||
95 | ``` | ||
96 | |||
97 | ```text | ||
98 | time="2015-03-26T01:27:38-04:00" level=fatal method=github.com/sirupsen/arcticcreatures.migrate msg="a penguin swims by" animal=penguin | ||
99 | ``` | ||
100 | Note that this does add measurable overhead - the cost will depend on the version of Go, but is | ||
101 | between 20 and 40% in recent tests with 1.6 and 1.7. You can validate this in your | ||
102 | environment via benchmarks: | ||
103 | ``` | ||
104 | go test -bench=.*CallerTracing | ||
105 | ``` | ||
106 | |||
107 | |||
108 | #### Case-sensitivity | ||
109 | |||
110 | The organization's name was changed to lower-case--and this will not be changed | ||
111 | back. If you are getting import conflicts due to case sensitivity, please use | ||
112 | the lower-case import: `github.com/sirupsen/logrus`. | ||
113 | |||
114 | #### Example | ||
115 | |||
116 | The simplest way to use Logrus is simply the package-level exported logger: | ||
117 | |||
118 | ```go | ||
119 | package main | ||
120 | |||
121 | import ( | ||
122 | log "github.com/sirupsen/logrus" | ||
123 | ) | ||
124 | |||
125 | func main() { | ||
126 | log.WithFields(log.Fields{ | ||
127 | "animal": "walrus", | ||
128 | }).Info("A walrus appears") | ||
129 | } | ||
130 | ``` | ||
131 | |||
132 | Note that it's completely api-compatible with the stdlib logger, so you can | ||
133 | replace your `log` imports everywhere with `log "github.com/sirupsen/logrus"` | ||
134 | and you'll now have the flexibility of Logrus. You can customize it all you | ||
135 | want: | ||
136 | |||
137 | ```go | ||
138 | package main | ||
139 | |||
140 | import ( | ||
141 | "os" | ||
142 | log "github.com/sirupsen/logrus" | ||
143 | ) | ||
144 | |||
145 | func init() { | ||
146 | // Log as JSON instead of the default ASCII formatter. | ||
147 | log.SetFormatter(&log.JSONFormatter{}) | ||
148 | |||
149 | // Output to stdout instead of the default stderr | ||
150 | // Can be any io.Writer, see below for File example | ||
151 | log.SetOutput(os.Stdout) | ||
152 | |||
153 | // Only log the warning severity or above. | ||
154 | log.SetLevel(log.WarnLevel) | ||
155 | } | ||
156 | |||
157 | func main() { | ||
158 | log.WithFields(log.Fields{ | ||
159 | "animal": "walrus", | ||
160 | "size": 10, | ||
161 | }).Info("A group of walrus emerges from the ocean") | ||
162 | |||
163 | log.WithFields(log.Fields{ | ||
164 | "omg": true, | ||
165 | "number": 122, | ||
166 | }).Warn("The group's number increased tremendously!") | ||
167 | |||
168 | log.WithFields(log.Fields{ | ||
169 | "omg": true, | ||
170 | "number": 100, | ||
171 | }).Fatal("The ice breaks!") | ||
172 | |||
173 | // A common pattern is to re-use fields between logging statements by re-using | ||
174 | // the logrus.Entry returned from WithFields() | ||
175 | contextLogger := log.WithFields(log.Fields{ | ||
176 | "common": "this is a common field", | ||
177 | "other": "I also should be logged always", | ||
178 | }) | ||
179 | |||
180 | contextLogger.Info("I'll be logged with common and other field") | ||
181 | contextLogger.Info("Me too") | ||
182 | } | ||
183 | ``` | ||
184 | |||
185 | For more advanced usage such as logging to multiple locations from the same | ||
186 | application, you can also create an instance of the `logrus` Logger: | ||
187 | |||
188 | ```go | ||
189 | package main | ||
190 | |||
191 | import ( | ||
192 | "os" | ||
193 | "github.com/sirupsen/logrus" | ||
194 | ) | ||
195 | |||
196 | // Create a new instance of the logger. You can have any number of instances. | ||
197 | var log = logrus.New() | ||
198 | |||
199 | func main() { | ||
200 | // The API for setting attributes is a little different than the package level | ||
201 | // exported logger. See Godoc. | ||
202 | log.Out = os.Stdout | ||
203 | |||
204 | // You could set this to any `io.Writer` such as a file | ||
205 | // file, err := os.OpenFile("logrus.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666) | ||
206 | // if err == nil { | ||
207 | // log.Out = file | ||
208 | // } else { | ||
209 | // log.Info("Failed to log to file, using default stderr") | ||
210 | // } | ||
211 | |||
212 | log.WithFields(logrus.Fields{ | ||
213 | "animal": "walrus", | ||
214 | "size": 10, | ||
215 | }).Info("A group of walrus emerges from the ocean") | ||
216 | } | ||
217 | ``` | ||
218 | |||
219 | #### Fields | ||
220 | |||
221 | Logrus encourages careful, structured logging through logging fields instead of | ||
222 | long, unparseable error messages. For example, instead of: `log.Fatalf("Failed | ||
223 | to send event %s to topic %s with key %d")`, you should log the much more | ||
224 | discoverable: | ||
225 | |||
226 | ```go | ||
227 | log.WithFields(log.Fields{ | ||
228 | "event": event, | ||
229 | "topic": topic, | ||
230 | "key": key, | ||
231 | }).Fatal("Failed to send event") | ||
232 | ``` | ||
233 | |||
234 | We've found this API forces you to think about logging in a way that produces | ||
235 | much more useful logging messages. We've been in countless situations where just | ||
236 | a single added field to a log statement that was already there would've saved us | ||
237 | hours. The `WithFields` call is optional. | ||
238 | |||
239 | In general, with Logrus using any of the `printf`-family functions should be | ||
240 | seen as a hint you should add a field, however, you can still use the | ||
241 | `printf`-family functions with Logrus. | ||
242 | |||
243 | #### Default Fields | ||
244 | |||
245 | Often it's helpful to have fields _always_ attached to log statements in an | ||
246 | application or parts of one. For example, you may want to always log the | ||
247 | `request_id` and `user_ip` in the context of a request. Instead of writing | ||
248 | `log.WithFields(log.Fields{"request_id": request_id, "user_ip": user_ip})` on | ||
249 | every line, you can create a `logrus.Entry` to pass around instead: | ||
250 | |||
251 | ```go | ||
252 | requestLogger := log.WithFields(log.Fields{"request_id": request_id, "user_ip": user_ip}) | ||
253 | requestLogger.Info("something happened on that request") # will log request_id and user_ip | ||
254 | requestLogger.Warn("something not great happened") | ||
255 | ``` | ||
256 | |||
257 | #### Hooks | ||
258 | |||
259 | You can add hooks for logging levels. For example to send errors to an exception | ||
260 | tracking service on `Error`, `Fatal` and `Panic`, info to StatsD or log to | ||
261 | multiple places simultaneously, e.g. syslog. | ||
262 | |||
263 | Logrus comes with [built-in hooks](hooks/). Add those, or your custom hook, in | ||
264 | `init`: | ||
265 | |||
266 | ```go | ||
267 | import ( | ||
268 | log "github.com/sirupsen/logrus" | ||
269 | "gopkg.in/gemnasium/logrus-airbrake-hook.v2" // the package is named "airbrake" | ||
270 | logrus_syslog "github.com/sirupsen/logrus/hooks/syslog" | ||
271 | "log/syslog" | ||
272 | ) | ||
273 | |||
274 | func init() { | ||
275 | |||
276 | // Use the Airbrake hook to report errors that have Error severity or above to | ||
277 | // an exception tracker. You can create custom hooks, see the Hooks section. | ||
278 | log.AddHook(airbrake.NewHook(123, "xyz", "production")) | ||
279 | |||
280 | hook, err := logrus_syslog.NewSyslogHook("udp", "localhost:514", syslog.LOG_INFO, "") | ||
281 | if err != nil { | ||
282 | log.Error("Unable to connect to local syslog daemon") | ||
283 | } else { | ||
284 | log.AddHook(hook) | ||
285 | } | ||
286 | } | ||
287 | ``` | ||
288 | Note: Syslog hook also support connecting to local syslog (Ex. "/dev/log" or "/var/run/syslog" or "/var/run/log"). For the detail, please check the [syslog hook README](hooks/syslog/README.md). | ||
289 | |||
290 | A list of currently known service hooks can be found in this wiki [page](https://github.com/sirupsen/logrus/wiki/Hooks) | ||
291 | |||
292 | |||
293 | #### Level logging | ||
294 | |||
295 | Logrus has seven logging levels: Trace, Debug, Info, Warning, Error, Fatal and Panic. | ||
296 | |||
297 | ```go | ||
298 | log.Trace("Something very low level.") | ||
299 | log.Debug("Useful debugging information.") | ||
300 | log.Info("Something noteworthy happened!") | ||
301 | log.Warn("You should probably take a look at this.") | ||
302 | log.Error("Something failed but I'm not quitting.") | ||
303 | // Calls os.Exit(1) after logging | ||
304 | log.Fatal("Bye.") | ||
305 | // Calls panic() after logging | ||
306 | log.Panic("I'm bailing.") | ||
307 | ``` | ||
308 | |||
309 | You can set the logging level on a `Logger`, then it will only log entries with | ||
310 | that severity or anything above it: | ||
311 | |||
312 | ```go | ||
313 | // Will log anything that is info or above (warn, error, fatal, panic). Default. | ||
314 | log.SetLevel(log.InfoLevel) | ||
315 | ``` | ||
316 | |||
317 | It may be useful to set `log.Level = logrus.DebugLevel` in a debug or verbose | ||
318 | environment if your application has that. | ||
319 | |||
320 | Note: If you want different log levels for global (`log.SetLevel(...)`) and syslog logging, please check the [syslog hook README](hooks/syslog/README.md#different-log-levels-for-local-and-remote-logging). | ||
321 | |||
322 | #### Entries | ||
323 | |||
324 | Besides the fields added with `WithField` or `WithFields` some fields are | ||
325 | automatically added to all logging events: | ||
326 | |||
327 | 1. `time`. The timestamp when the entry was created. | ||
328 | 2. `msg`. The logging message passed to `{Info,Warn,Error,Fatal,Panic}` after | ||
329 | the `AddFields` call. E.g. `Failed to send event.` | ||
330 | 3. `level`. The logging level. E.g. `info`. | ||
331 | |||
332 | #### Environments | ||
333 | |||
334 | Logrus has no notion of environment. | ||
335 | |||
336 | If you wish for hooks and formatters to only be used in specific environments, | ||
337 | you should handle that yourself. For example, if your application has a global | ||
338 | variable `Environment`, which is a string representation of the environment you | ||
339 | could do: | ||
340 | |||
341 | ```go | ||
342 | import ( | ||
343 | log "github.com/sirupsen/logrus" | ||
344 | ) | ||
345 | |||
346 | func init() { | ||
347 | // do something here to set environment depending on an environment variable | ||
348 | // or command-line flag | ||
349 | if Environment == "production" { | ||
350 | log.SetFormatter(&log.JSONFormatter{}) | ||
351 | } else { | ||
352 | // The TextFormatter is default, you don't actually have to do this. | ||
353 | log.SetFormatter(&log.TextFormatter{}) | ||
354 | } | ||
355 | } | ||
356 | ``` | ||
357 | |||
358 | This configuration is how `logrus` was intended to be used, but JSON in | ||
359 | production is mostly only useful if you do log aggregation with tools like | ||
360 | Splunk or Logstash. | ||
361 | |||
362 | #### Formatters | ||
363 | |||
364 | The built-in logging formatters are: | ||
365 | |||
366 | * `logrus.TextFormatter`. Logs the event in colors if stdout is a tty, otherwise | ||
367 | without colors. | ||
368 | * *Note:* to force colored output when there is no TTY, set the `ForceColors` | ||
369 | field to `true`. To force no colored output even if there is a TTY set the | ||
370 | `DisableColors` field to `true`. For Windows, see | ||
371 | [github.com/mattn/go-colorable](https://github.com/mattn/go-colorable). | ||
372 | * When colors are enabled, levels are truncated to 4 characters by default. To disable | ||
373 | truncation set the `DisableLevelTruncation` field to `true`. | ||
374 | * When outputting to a TTY, it's often helpful to visually scan down a column where all the levels are the same width. Setting the `PadLevelText` field to `true` enables this behavior, by adding padding to the level text. | ||
375 | * All options are listed in the [generated docs](https://godoc.org/github.com/sirupsen/logrus#TextFormatter). | ||
376 | * `logrus.JSONFormatter`. Logs fields as JSON. | ||
377 | * All options are listed in the [generated docs](https://godoc.org/github.com/sirupsen/logrus#JSONFormatter). | ||
378 | |||
379 | Third party logging formatters: | ||
380 | |||
381 | * [`FluentdFormatter`](https://github.com/joonix/log). Formats entries that can be parsed by Kubernetes and Google Container Engine. | ||
382 | * [`GELF`](https://github.com/fabienm/go-logrus-formatters). Formats entries so they comply to Graylog's [GELF 1.1 specification](http://docs.graylog.org/en/2.4/pages/gelf.html). | ||
383 | * [`logstash`](https://github.com/bshuster-repo/logrus-logstash-hook). Logs fields as [Logstash](http://logstash.net) Events. | ||
384 | * [`prefixed`](https://github.com/x-cray/logrus-prefixed-formatter). Displays log entry source along with alternative layout. | ||
385 | * [`zalgo`](https://github.com/aybabtme/logzalgo). Invoking the Power of Zalgo. | ||
386 | * [`nested-logrus-formatter`](https://github.com/antonfisher/nested-logrus-formatter). Converts logrus fields to a nested structure. | ||
387 | * [`powerful-logrus-formatter`](https://github.com/zput/zxcTool). get fileName, log's line number and the latest function's name when print log; Sava log to files. | ||
388 | * [`caption-json-formatter`](https://github.com/nolleh/caption_json_formatter). logrus's message json formatter with human-readable caption added. | ||
389 | |||
390 | You can define your formatter by implementing the `Formatter` interface, | ||
391 | requiring a `Format` method. `Format` takes an `*Entry`. `entry.Data` is a | ||
392 | `Fields` type (`map[string]interface{}`) with all your fields as well as the | ||
393 | default ones (see Entries section above): | ||
394 | |||
395 | ```go | ||
396 | type MyJSONFormatter struct { | ||
397 | } | ||
398 | |||
399 | log.SetFormatter(new(MyJSONFormatter)) | ||
400 | |||
401 | func (f *MyJSONFormatter) Format(entry *Entry) ([]byte, error) { | ||
402 | // Note this doesn't include Time, Level and Message which are available on | ||
403 | // the Entry. Consult `godoc` on information about those fields or read the | ||
404 | // source of the official loggers. | ||
405 | serialized, err := json.Marshal(entry.Data) | ||
406 | if err != nil { | ||
407 | return nil, fmt.Errorf("Failed to marshal fields to JSON, %w", err) | ||
408 | } | ||
409 | return append(serialized, '\n'), nil | ||
410 | } | ||
411 | ``` | ||
412 | |||
413 | #### Logger as an `io.Writer` | ||
414 | |||
415 | Logrus can be transformed into an `io.Writer`. That writer is the end of an `io.Pipe` and it is your responsibility to close it. | ||
416 | |||
417 | ```go | ||
418 | w := logger.Writer() | ||
419 | defer w.Close() | ||
420 | |||
421 | srv := http.Server{ | ||
422 | // create a stdlib log.Logger that writes to | ||
423 | // logrus.Logger. | ||
424 | ErrorLog: log.New(w, "", 0), | ||
425 | } | ||
426 | ``` | ||
427 | |||
428 | Each line written to that writer will be printed the usual way, using formatters | ||
429 | and hooks. The level for those entries is `info`. | ||
430 | |||
431 | This means that we can override the standard library logger easily: | ||
432 | |||
433 | ```go | ||
434 | logger := logrus.New() | ||
435 | logger.Formatter = &logrus.JSONFormatter{} | ||
436 | |||
437 | // Use logrus for standard log output | ||
438 | // Note that `log` here references stdlib's log | ||
439 | // Not logrus imported under the name `log`. | ||
440 | log.SetOutput(logger.Writer()) | ||
441 | ``` | ||
442 | |||
443 | #### Rotation | ||
444 | |||
445 | Log rotation is not provided with Logrus. Log rotation should be done by an | ||
446 | external program (like `logrotate(8)`) that can compress and delete old log | ||
447 | entries. It should not be a feature of the application-level logger. | ||
448 | |||
449 | #### Tools | ||
450 | |||
451 | | Tool | Description | | ||
452 | | ---- | ----------- | | ||
453 | |[Logrus Mate](https://github.com/gogap/logrus_mate)|Logrus mate is a tool for Logrus to manage loggers, you can initial logger's level, hook and formatter by config file, the logger will be generated with different configs in different environments.| | ||
454 | |[Logrus Viper Helper](https://github.com/heirko/go-contrib/tree/master/logrusHelper)|An Helper around Logrus to wrap with spf13/Viper to load configuration with fangs! And to simplify Logrus configuration use some behavior of [Logrus Mate](https://github.com/gogap/logrus_mate). [sample](https://github.com/heirko/iris-contrib/blob/master/middleware/logrus-logger/example) | | ||
455 | |||
456 | #### Testing | ||
457 | |||
458 | Logrus has a built in facility for asserting the presence of log messages. This is implemented through the `test` hook and provides: | ||
459 | |||
460 | * decorators for existing logger (`test.NewLocal` and `test.NewGlobal`) which basically just adds the `test` hook | ||
461 | * a test logger (`test.NewNullLogger`) that just records log messages (and does not output any): | ||
462 | |||
463 | ```go | ||
464 | import( | ||
465 | "github.com/sirupsen/logrus" | ||
466 | "github.com/sirupsen/logrus/hooks/test" | ||
467 | "github.com/stretchr/testify/assert" | ||
468 | "testing" | ||
469 | ) | ||
470 | |||
471 | func TestSomething(t*testing.T){ | ||
472 | logger, hook := test.NewNullLogger() | ||
473 | logger.Error("Helloerror") | ||
474 | |||
475 | assert.Equal(t, 1, len(hook.Entries)) | ||
476 | assert.Equal(t, logrus.ErrorLevel, hook.LastEntry().Level) | ||
477 | assert.Equal(t, "Helloerror", hook.LastEntry().Message) | ||
478 | |||
479 | hook.Reset() | ||
480 | assert.Nil(t, hook.LastEntry()) | ||
481 | } | ||
482 | ``` | ||
483 | |||
484 | #### Fatal handlers | ||
485 | |||
486 | Logrus can register one or more functions that will be called when any `fatal` | ||
487 | level message is logged. The registered handlers will be executed before | ||
488 | logrus performs an `os.Exit(1)`. This behavior may be helpful if callers need | ||
489 | to gracefully shutdown. Unlike a `panic("Something went wrong...")` call which can be intercepted with a deferred `recover` a call to `os.Exit(1)` can not be intercepted. | ||
490 | |||
491 | ``` | ||
492 | ... | ||
493 | handler := func() { | ||
494 | // gracefully shutdown something... | ||
495 | } | ||
496 | logrus.RegisterExitHandler(handler) | ||
497 | ... | ||
498 | ``` | ||
499 | |||
500 | #### Thread safety | ||
501 | |||
502 | By default, Logger is protected by a mutex for concurrent writes. The mutex is held when calling hooks and writing logs. | ||
503 | If you are sure such locking is not needed, you can call logger.SetNoLock() to disable the locking. | ||
504 | |||
505 | Situation when locking is not needed includes: | ||
506 | |||
507 | * You have no hooks registered, or hooks calling is already thread-safe. | ||
508 | |||
509 | * Writing to logger.Out is already thread-safe, for example: | ||
510 | |||
511 | 1) logger.Out is protected by locks. | ||
512 | |||
513 | 2) logger.Out is an os.File handler opened with `O_APPEND` flag, and every write is smaller than 4k. (This allows multi-thread/multi-process writing) | ||
514 | |||
515 | (Refer to http://www.notthewizard.com/2014/06/17/are-files-appends-really-atomic/) | ||
diff --git a/vendor/github.com/sirupsen/logrus/alt_exit.go b/vendor/github.com/sirupsen/logrus/alt_exit.go new file mode 100644 index 0000000..8fd189e --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/alt_exit.go | |||
@@ -0,0 +1,76 @@ | |||
1 | package logrus | ||
2 | |||
3 | // The following code was sourced and modified from the | ||
4 | // https://github.com/tebeka/atexit package governed by the following license: | ||
5 | // | ||
6 | // Copyright (c) 2012 Miki Tebeka <[email protected]>. | ||
7 | // | ||
8 | // Permission is hereby granted, free of charge, to any person obtaining a copy of | ||
9 | // this software and associated documentation files (the "Software"), to deal in | ||
10 | // the Software without restriction, including without limitation the rights to | ||
11 | // use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of | ||
12 | // the Software, and to permit persons to whom the Software is furnished to do so, | ||
13 | // subject to the following conditions: | ||
14 | // | ||
15 | // The above copyright notice and this permission notice shall be included in all | ||
16 | // copies or substantial portions of the Software. | ||
17 | // | ||
18 | // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
19 | // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS | ||
20 | // FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR | ||
21 | // COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER | ||
22 | // IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN | ||
23 | // CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. | ||
24 | |||
25 | import ( | ||
26 | "fmt" | ||
27 | "os" | ||
28 | ) | ||
29 | |||
30 | var handlers = []func(){} | ||
31 | |||
32 | func runHandler(handler func()) { | ||
33 | defer func() { | ||
34 | if err := recover(); err != nil { | ||
35 | fmt.Fprintln(os.Stderr, "Error: Logrus exit handler error:", err) | ||
36 | } | ||
37 | }() | ||
38 | |||
39 | handler() | ||
40 | } | ||
41 | |||
42 | func runHandlers() { | ||
43 | for _, handler := range handlers { | ||
44 | runHandler(handler) | ||
45 | } | ||
46 | } | ||
47 | |||
48 | // Exit runs all the Logrus atexit handlers and then terminates the program using os.Exit(code) | ||
49 | func Exit(code int) { | ||
50 | runHandlers() | ||
51 | os.Exit(code) | ||
52 | } | ||
53 | |||
54 | // RegisterExitHandler appends a Logrus Exit handler to the list of handlers, | ||
55 | // call logrus.Exit to invoke all handlers. The handlers will also be invoked when | ||
56 | // any Fatal log entry is made. | ||
57 | // | ||
58 | // This method is useful when a caller wishes to use logrus to log a fatal | ||
59 | // message but also needs to gracefully shutdown. An example usecase could be | ||
60 | // closing database connections, or sending a alert that the application is | ||
61 | // closing. | ||
62 | func RegisterExitHandler(handler func()) { | ||
63 | handlers = append(handlers, handler) | ||
64 | } | ||
65 | |||
66 | // DeferExitHandler prepends a Logrus Exit handler to the list of handlers, | ||
67 | // call logrus.Exit to invoke all handlers. The handlers will also be invoked when | ||
68 | // any Fatal log entry is made. | ||
69 | // | ||
70 | // This method is useful when a caller wishes to use logrus to log a fatal | ||
71 | // message but also needs to gracefully shutdown. An example usecase could be | ||
72 | // closing database connections, or sending a alert that the application is | ||
73 | // closing. | ||
74 | func DeferExitHandler(handler func()) { | ||
75 | handlers = append([]func(){handler}, handlers...) | ||
76 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/appveyor.yml b/vendor/github.com/sirupsen/logrus/appveyor.yml new file mode 100644 index 0000000..df9d65c --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/appveyor.yml | |||
@@ -0,0 +1,14 @@ | |||
1 | version: "{build}" | ||
2 | platform: x64 | ||
3 | clone_folder: c:\gopath\src\github.com\sirupsen\logrus | ||
4 | environment: | ||
5 | GOPATH: c:\gopath | ||
6 | branches: | ||
7 | only: | ||
8 | - master | ||
9 | install: | ||
10 | - set PATH=%GOPATH%\bin;c:\go\bin;%PATH% | ||
11 | - go version | ||
12 | build_script: | ||
13 | - go get -t | ||
14 | - go test | ||
diff --git a/vendor/github.com/sirupsen/logrus/buffer_pool.go b/vendor/github.com/sirupsen/logrus/buffer_pool.go new file mode 100644 index 0000000..c7787f7 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/buffer_pool.go | |||
@@ -0,0 +1,43 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "bytes" | ||
5 | "sync" | ||
6 | ) | ||
7 | |||
8 | var ( | ||
9 | bufferPool BufferPool | ||
10 | ) | ||
11 | |||
12 | type BufferPool interface { | ||
13 | Put(*bytes.Buffer) | ||
14 | Get() *bytes.Buffer | ||
15 | } | ||
16 | |||
17 | type defaultPool struct { | ||
18 | pool *sync.Pool | ||
19 | } | ||
20 | |||
21 | func (p *defaultPool) Put(buf *bytes.Buffer) { | ||
22 | p.pool.Put(buf) | ||
23 | } | ||
24 | |||
25 | func (p *defaultPool) Get() *bytes.Buffer { | ||
26 | return p.pool.Get().(*bytes.Buffer) | ||
27 | } | ||
28 | |||
29 | // SetBufferPool allows to replace the default logrus buffer pool | ||
30 | // to better meets the specific needs of an application. | ||
31 | func SetBufferPool(bp BufferPool) { | ||
32 | bufferPool = bp | ||
33 | } | ||
34 | |||
35 | func init() { | ||
36 | SetBufferPool(&defaultPool{ | ||
37 | pool: &sync.Pool{ | ||
38 | New: func() interface{} { | ||
39 | return new(bytes.Buffer) | ||
40 | }, | ||
41 | }, | ||
42 | }) | ||
43 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/doc.go b/vendor/github.com/sirupsen/logrus/doc.go new file mode 100644 index 0000000..da67aba --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/doc.go | |||
@@ -0,0 +1,26 @@ | |||
1 | /* | ||
2 | Package logrus is a structured logger for Go, completely API compatible with the standard library logger. | ||
3 | |||
4 | |||
5 | The simplest way to use Logrus is simply the package-level exported logger: | ||
6 | |||
7 | package main | ||
8 | |||
9 | import ( | ||
10 | log "github.com/sirupsen/logrus" | ||
11 | ) | ||
12 | |||
13 | func main() { | ||
14 | log.WithFields(log.Fields{ | ||
15 | "animal": "walrus", | ||
16 | "number": 1, | ||
17 | "size": 10, | ||
18 | }).Info("A walrus appears") | ||
19 | } | ||
20 | |||
21 | Output: | ||
22 | time="2015-09-07T08:48:33Z" level=info msg="A walrus appears" animal=walrus number=1 size=10 | ||
23 | |||
24 | For a full guide visit https://github.com/sirupsen/logrus | ||
25 | */ | ||
26 | package logrus | ||
diff --git a/vendor/github.com/sirupsen/logrus/entry.go b/vendor/github.com/sirupsen/logrus/entry.go new file mode 100644 index 0000000..71cdbbc --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/entry.go | |||
@@ -0,0 +1,442 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "bytes" | ||
5 | "context" | ||
6 | "fmt" | ||
7 | "os" | ||
8 | "reflect" | ||
9 | "runtime" | ||
10 | "strings" | ||
11 | "sync" | ||
12 | "time" | ||
13 | ) | ||
14 | |||
15 | var ( | ||
16 | |||
17 | // qualified package name, cached at first use | ||
18 | logrusPackage string | ||
19 | |||
20 | // Positions in the call stack when tracing to report the calling method | ||
21 | minimumCallerDepth int | ||
22 | |||
23 | // Used for caller information initialisation | ||
24 | callerInitOnce sync.Once | ||
25 | ) | ||
26 | |||
27 | const ( | ||
28 | maximumCallerDepth int = 25 | ||
29 | knownLogrusFrames int = 4 | ||
30 | ) | ||
31 | |||
32 | func init() { | ||
33 | // start at the bottom of the stack before the package-name cache is primed | ||
34 | minimumCallerDepth = 1 | ||
35 | } | ||
36 | |||
37 | // Defines the key when adding errors using WithError. | ||
38 | var ErrorKey = "error" | ||
39 | |||
40 | // An entry is the final or intermediate Logrus logging entry. It contains all | ||
41 | // the fields passed with WithField{,s}. It's finally logged when Trace, Debug, | ||
42 | // Info, Warn, Error, Fatal or Panic is called on it. These objects can be | ||
43 | // reused and passed around as much as you wish to avoid field duplication. | ||
44 | type Entry struct { | ||
45 | Logger *Logger | ||
46 | |||
47 | // Contains all the fields set by the user. | ||
48 | Data Fields | ||
49 | |||
50 | // Time at which the log entry was created | ||
51 | Time time.Time | ||
52 | |||
53 | // Level the log entry was logged at: Trace, Debug, Info, Warn, Error, Fatal or Panic | ||
54 | // This field will be set on entry firing and the value will be equal to the one in Logger struct field. | ||
55 | Level Level | ||
56 | |||
57 | // Calling method, with package name | ||
58 | Caller *runtime.Frame | ||
59 | |||
60 | // Message passed to Trace, Debug, Info, Warn, Error, Fatal or Panic | ||
61 | Message string | ||
62 | |||
63 | // When formatter is called in entry.log(), a Buffer may be set to entry | ||
64 | Buffer *bytes.Buffer | ||
65 | |||
66 | // Contains the context set by the user. Useful for hook processing etc. | ||
67 | Context context.Context | ||
68 | |||
69 | // err may contain a field formatting error | ||
70 | err string | ||
71 | } | ||
72 | |||
73 | func NewEntry(logger *Logger) *Entry { | ||
74 | return &Entry{ | ||
75 | Logger: logger, | ||
76 | // Default is three fields, plus one optional. Give a little extra room. | ||
77 | Data: make(Fields, 6), | ||
78 | } | ||
79 | } | ||
80 | |||
81 | func (entry *Entry) Dup() *Entry { | ||
82 | data := make(Fields, len(entry.Data)) | ||
83 | for k, v := range entry.Data { | ||
84 | data[k] = v | ||
85 | } | ||
86 | return &Entry{Logger: entry.Logger, Data: data, Time: entry.Time, Context: entry.Context, err: entry.err} | ||
87 | } | ||
88 | |||
89 | // Returns the bytes representation of this entry from the formatter. | ||
90 | func (entry *Entry) Bytes() ([]byte, error) { | ||
91 | return entry.Logger.Formatter.Format(entry) | ||
92 | } | ||
93 | |||
94 | // Returns the string representation from the reader and ultimately the | ||
95 | // formatter. | ||
96 | func (entry *Entry) String() (string, error) { | ||
97 | serialized, err := entry.Bytes() | ||
98 | if err != nil { | ||
99 | return "", err | ||
100 | } | ||
101 | str := string(serialized) | ||
102 | return str, nil | ||
103 | } | ||
104 | |||
105 | // Add an error as single field (using the key defined in ErrorKey) to the Entry. | ||
106 | func (entry *Entry) WithError(err error) *Entry { | ||
107 | return entry.WithField(ErrorKey, err) | ||
108 | } | ||
109 | |||
110 | // Add a context to the Entry. | ||
111 | func (entry *Entry) WithContext(ctx context.Context) *Entry { | ||
112 | dataCopy := make(Fields, len(entry.Data)) | ||
113 | for k, v := range entry.Data { | ||
114 | dataCopy[k] = v | ||
115 | } | ||
116 | return &Entry{Logger: entry.Logger, Data: dataCopy, Time: entry.Time, err: entry.err, Context: ctx} | ||
117 | } | ||
118 | |||
119 | // Add a single field to the Entry. | ||
120 | func (entry *Entry) WithField(key string, value interface{}) *Entry { | ||
121 | return entry.WithFields(Fields{key: value}) | ||
122 | } | ||
123 | |||
124 | // Add a map of fields to the Entry. | ||
125 | func (entry *Entry) WithFields(fields Fields) *Entry { | ||
126 | data := make(Fields, len(entry.Data)+len(fields)) | ||
127 | for k, v := range entry.Data { | ||
128 | data[k] = v | ||
129 | } | ||
130 | fieldErr := entry.err | ||
131 | for k, v := range fields { | ||
132 | isErrField := false | ||
133 | if t := reflect.TypeOf(v); t != nil { | ||
134 | switch { | ||
135 | case t.Kind() == reflect.Func, t.Kind() == reflect.Ptr && t.Elem().Kind() == reflect.Func: | ||
136 | isErrField = true | ||
137 | } | ||
138 | } | ||
139 | if isErrField { | ||
140 | tmp := fmt.Sprintf("can not add field %q", k) | ||
141 | if fieldErr != "" { | ||
142 | fieldErr = entry.err + ", " + tmp | ||
143 | } else { | ||
144 | fieldErr = tmp | ||
145 | } | ||
146 | } else { | ||
147 | data[k] = v | ||
148 | } | ||
149 | } | ||
150 | return &Entry{Logger: entry.Logger, Data: data, Time: entry.Time, err: fieldErr, Context: entry.Context} | ||
151 | } | ||
152 | |||
153 | // Overrides the time of the Entry. | ||
154 | func (entry *Entry) WithTime(t time.Time) *Entry { | ||
155 | dataCopy := make(Fields, len(entry.Data)) | ||
156 | for k, v := range entry.Data { | ||
157 | dataCopy[k] = v | ||
158 | } | ||
159 | return &Entry{Logger: entry.Logger, Data: dataCopy, Time: t, err: entry.err, Context: entry.Context} | ||
160 | } | ||
161 | |||
162 | // getPackageName reduces a fully qualified function name to the package name | ||
163 | // There really ought to be to be a better way... | ||
164 | func getPackageName(f string) string { | ||
165 | for { | ||
166 | lastPeriod := strings.LastIndex(f, ".") | ||
167 | lastSlash := strings.LastIndex(f, "/") | ||
168 | if lastPeriod > lastSlash { | ||
169 | f = f[:lastPeriod] | ||
170 | } else { | ||
171 | break | ||
172 | } | ||
173 | } | ||
174 | |||
175 | return f | ||
176 | } | ||
177 | |||
178 | // getCaller retrieves the name of the first non-logrus calling function | ||
179 | func getCaller() *runtime.Frame { | ||
180 | // cache this package's fully-qualified name | ||
181 | callerInitOnce.Do(func() { | ||
182 | pcs := make([]uintptr, maximumCallerDepth) | ||
183 | _ = runtime.Callers(0, pcs) | ||
184 | |||
185 | // dynamic get the package name and the minimum caller depth | ||
186 | for i := 0; i < maximumCallerDepth; i++ { | ||
187 | funcName := runtime.FuncForPC(pcs[i]).Name() | ||
188 | if strings.Contains(funcName, "getCaller") { | ||
189 | logrusPackage = getPackageName(funcName) | ||
190 | break | ||
191 | } | ||
192 | } | ||
193 | |||
194 | minimumCallerDepth = knownLogrusFrames | ||
195 | }) | ||
196 | |||
197 | // Restrict the lookback frames to avoid runaway lookups | ||
198 | pcs := make([]uintptr, maximumCallerDepth) | ||
199 | depth := runtime.Callers(minimumCallerDepth, pcs) | ||
200 | frames := runtime.CallersFrames(pcs[:depth]) | ||
201 | |||
202 | for f, again := frames.Next(); again; f, again = frames.Next() { | ||
203 | pkg := getPackageName(f.Function) | ||
204 | |||
205 | // If the caller isn't part of this package, we're done | ||
206 | if pkg != logrusPackage { | ||
207 | return &f //nolint:scopelint | ||
208 | } | ||
209 | } | ||
210 | |||
211 | // if we got here, we failed to find the caller's context | ||
212 | return nil | ||
213 | } | ||
214 | |||
215 | func (entry Entry) HasCaller() (has bool) { | ||
216 | return entry.Logger != nil && | ||
217 | entry.Logger.ReportCaller && | ||
218 | entry.Caller != nil | ||
219 | } | ||
220 | |||
221 | func (entry *Entry) log(level Level, msg string) { | ||
222 | var buffer *bytes.Buffer | ||
223 | |||
224 | newEntry := entry.Dup() | ||
225 | |||
226 | if newEntry.Time.IsZero() { | ||
227 | newEntry.Time = time.Now() | ||
228 | } | ||
229 | |||
230 | newEntry.Level = level | ||
231 | newEntry.Message = msg | ||
232 | |||
233 | newEntry.Logger.mu.Lock() | ||
234 | reportCaller := newEntry.Logger.ReportCaller | ||
235 | bufPool := newEntry.getBufferPool() | ||
236 | newEntry.Logger.mu.Unlock() | ||
237 | |||
238 | if reportCaller { | ||
239 | newEntry.Caller = getCaller() | ||
240 | } | ||
241 | |||
242 | newEntry.fireHooks() | ||
243 | buffer = bufPool.Get() | ||
244 | defer func() { | ||
245 | newEntry.Buffer = nil | ||
246 | buffer.Reset() | ||
247 | bufPool.Put(buffer) | ||
248 | }() | ||
249 | buffer.Reset() | ||
250 | newEntry.Buffer = buffer | ||
251 | |||
252 | newEntry.write() | ||
253 | |||
254 | newEntry.Buffer = nil | ||
255 | |||
256 | // To avoid Entry#log() returning a value that only would make sense for | ||
257 | // panic() to use in Entry#Panic(), we avoid the allocation by checking | ||
258 | // directly here. | ||
259 | if level <= PanicLevel { | ||
260 | panic(newEntry) | ||
261 | } | ||
262 | } | ||
263 | |||
264 | func (entry *Entry) getBufferPool() (pool BufferPool) { | ||
265 | if entry.Logger.BufferPool != nil { | ||
266 | return entry.Logger.BufferPool | ||
267 | } | ||
268 | return bufferPool | ||
269 | } | ||
270 | |||
271 | func (entry *Entry) fireHooks() { | ||
272 | var tmpHooks LevelHooks | ||
273 | entry.Logger.mu.Lock() | ||
274 | tmpHooks = make(LevelHooks, len(entry.Logger.Hooks)) | ||
275 | for k, v := range entry.Logger.Hooks { | ||
276 | tmpHooks[k] = v | ||
277 | } | ||
278 | entry.Logger.mu.Unlock() | ||
279 | |||
280 | err := tmpHooks.Fire(entry.Level, entry) | ||
281 | if err != nil { | ||
282 | fmt.Fprintf(os.Stderr, "Failed to fire hook: %v\n", err) | ||
283 | } | ||
284 | } | ||
285 | |||
286 | func (entry *Entry) write() { | ||
287 | entry.Logger.mu.Lock() | ||
288 | defer entry.Logger.mu.Unlock() | ||
289 | serialized, err := entry.Logger.Formatter.Format(entry) | ||
290 | if err != nil { | ||
291 | fmt.Fprintf(os.Stderr, "Failed to obtain reader, %v\n", err) | ||
292 | return | ||
293 | } | ||
294 | if _, err := entry.Logger.Out.Write(serialized); err != nil { | ||
295 | fmt.Fprintf(os.Stderr, "Failed to write to log, %v\n", err) | ||
296 | } | ||
297 | } | ||
298 | |||
299 | // Log will log a message at the level given as parameter. | ||
300 | // Warning: using Log at Panic or Fatal level will not respectively Panic nor Exit. | ||
301 | // For this behaviour Entry.Panic or Entry.Fatal should be used instead. | ||
302 | func (entry *Entry) Log(level Level, args ...interface{}) { | ||
303 | if entry.Logger.IsLevelEnabled(level) { | ||
304 | entry.log(level, fmt.Sprint(args...)) | ||
305 | } | ||
306 | } | ||
307 | |||
308 | func (entry *Entry) Trace(args ...interface{}) { | ||
309 | entry.Log(TraceLevel, args...) | ||
310 | } | ||
311 | |||
312 | func (entry *Entry) Debug(args ...interface{}) { | ||
313 | entry.Log(DebugLevel, args...) | ||
314 | } | ||
315 | |||
316 | func (entry *Entry) Print(args ...interface{}) { | ||
317 | entry.Info(args...) | ||
318 | } | ||
319 | |||
320 | func (entry *Entry) Info(args ...interface{}) { | ||
321 | entry.Log(InfoLevel, args...) | ||
322 | } | ||
323 | |||
324 | func (entry *Entry) Warn(args ...interface{}) { | ||
325 | entry.Log(WarnLevel, args...) | ||
326 | } | ||
327 | |||
328 | func (entry *Entry) Warning(args ...interface{}) { | ||
329 | entry.Warn(args...) | ||
330 | } | ||
331 | |||
332 | func (entry *Entry) Error(args ...interface{}) { | ||
333 | entry.Log(ErrorLevel, args...) | ||
334 | } | ||
335 | |||
336 | func (entry *Entry) Fatal(args ...interface{}) { | ||
337 | entry.Log(FatalLevel, args...) | ||
338 | entry.Logger.Exit(1) | ||
339 | } | ||
340 | |||
341 | func (entry *Entry) Panic(args ...interface{}) { | ||
342 | entry.Log(PanicLevel, args...) | ||
343 | } | ||
344 | |||
345 | // Entry Printf family functions | ||
346 | |||
347 | func (entry *Entry) Logf(level Level, format string, args ...interface{}) { | ||
348 | if entry.Logger.IsLevelEnabled(level) { | ||
349 | entry.Log(level, fmt.Sprintf(format, args...)) | ||
350 | } | ||
351 | } | ||
352 | |||
353 | func (entry *Entry) Tracef(format string, args ...interface{}) { | ||
354 | entry.Logf(TraceLevel, format, args...) | ||
355 | } | ||
356 | |||
357 | func (entry *Entry) Debugf(format string, args ...interface{}) { | ||
358 | entry.Logf(DebugLevel, format, args...) | ||
359 | } | ||
360 | |||
361 | func (entry *Entry) Infof(format string, args ...interface{}) { | ||
362 | entry.Logf(InfoLevel, format, args...) | ||
363 | } | ||
364 | |||
365 | func (entry *Entry) Printf(format string, args ...interface{}) { | ||
366 | entry.Infof(format, args...) | ||
367 | } | ||
368 | |||
369 | func (entry *Entry) Warnf(format string, args ...interface{}) { | ||
370 | entry.Logf(WarnLevel, format, args...) | ||
371 | } | ||
372 | |||
373 | func (entry *Entry) Warningf(format string, args ...interface{}) { | ||
374 | entry.Warnf(format, args...) | ||
375 | } | ||
376 | |||
377 | func (entry *Entry) Errorf(format string, args ...interface{}) { | ||
378 | entry.Logf(ErrorLevel, format, args...) | ||
379 | } | ||
380 | |||
381 | func (entry *Entry) Fatalf(format string, args ...interface{}) { | ||
382 | entry.Logf(FatalLevel, format, args...) | ||
383 | entry.Logger.Exit(1) | ||
384 | } | ||
385 | |||
386 | func (entry *Entry) Panicf(format string, args ...interface{}) { | ||
387 | entry.Logf(PanicLevel, format, args...) | ||
388 | } | ||
389 | |||
390 | // Entry Println family functions | ||
391 | |||
392 | func (entry *Entry) Logln(level Level, args ...interface{}) { | ||
393 | if entry.Logger.IsLevelEnabled(level) { | ||
394 | entry.Log(level, entry.sprintlnn(args...)) | ||
395 | } | ||
396 | } | ||
397 | |||
398 | func (entry *Entry) Traceln(args ...interface{}) { | ||
399 | entry.Logln(TraceLevel, args...) | ||
400 | } | ||
401 | |||
402 | func (entry *Entry) Debugln(args ...interface{}) { | ||
403 | entry.Logln(DebugLevel, args...) | ||
404 | } | ||
405 | |||
406 | func (entry *Entry) Infoln(args ...interface{}) { | ||
407 | entry.Logln(InfoLevel, args...) | ||
408 | } | ||
409 | |||
410 | func (entry *Entry) Println(args ...interface{}) { | ||
411 | entry.Infoln(args...) | ||
412 | } | ||
413 | |||
414 | func (entry *Entry) Warnln(args ...interface{}) { | ||
415 | entry.Logln(WarnLevel, args...) | ||
416 | } | ||
417 | |||
418 | func (entry *Entry) Warningln(args ...interface{}) { | ||
419 | entry.Warnln(args...) | ||
420 | } | ||
421 | |||
422 | func (entry *Entry) Errorln(args ...interface{}) { | ||
423 | entry.Logln(ErrorLevel, args...) | ||
424 | } | ||
425 | |||
426 | func (entry *Entry) Fatalln(args ...interface{}) { | ||
427 | entry.Logln(FatalLevel, args...) | ||
428 | entry.Logger.Exit(1) | ||
429 | } | ||
430 | |||
431 | func (entry *Entry) Panicln(args ...interface{}) { | ||
432 | entry.Logln(PanicLevel, args...) | ||
433 | } | ||
434 | |||
435 | // Sprintlnn => Sprint no newline. This is to get the behavior of how | ||
436 | // fmt.Sprintln where spaces are always added between operands, regardless of | ||
437 | // their type. Instead of vendoring the Sprintln implementation to spare a | ||
438 | // string allocation, we do the simplest thing. | ||
439 | func (entry *Entry) sprintlnn(args ...interface{}) string { | ||
440 | msg := fmt.Sprintln(args...) | ||
441 | return msg[:len(msg)-1] | ||
442 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/exported.go b/vendor/github.com/sirupsen/logrus/exported.go new file mode 100644 index 0000000..017c30c --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/exported.go | |||
@@ -0,0 +1,270 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "context" | ||
5 | "io" | ||
6 | "time" | ||
7 | ) | ||
8 | |||
9 | var ( | ||
10 | // std is the name of the standard logger in stdlib `log` | ||
11 | std = New() | ||
12 | ) | ||
13 | |||
14 | func StandardLogger() *Logger { | ||
15 | return std | ||
16 | } | ||
17 | |||
18 | // SetOutput sets the standard logger output. | ||
19 | func SetOutput(out io.Writer) { | ||
20 | std.SetOutput(out) | ||
21 | } | ||
22 | |||
23 | // SetFormatter sets the standard logger formatter. | ||
24 | func SetFormatter(formatter Formatter) { | ||
25 | std.SetFormatter(formatter) | ||
26 | } | ||
27 | |||
28 | // SetReportCaller sets whether the standard logger will include the calling | ||
29 | // method as a field. | ||
30 | func SetReportCaller(include bool) { | ||
31 | std.SetReportCaller(include) | ||
32 | } | ||
33 | |||
34 | // SetLevel sets the standard logger level. | ||
35 | func SetLevel(level Level) { | ||
36 | std.SetLevel(level) | ||
37 | } | ||
38 | |||
39 | // GetLevel returns the standard logger level. | ||
40 | func GetLevel() Level { | ||
41 | return std.GetLevel() | ||
42 | } | ||
43 | |||
44 | // IsLevelEnabled checks if the log level of the standard logger is greater than the level param | ||
45 | func IsLevelEnabled(level Level) bool { | ||
46 | return std.IsLevelEnabled(level) | ||
47 | } | ||
48 | |||
49 | // AddHook adds a hook to the standard logger hooks. | ||
50 | func AddHook(hook Hook) { | ||
51 | std.AddHook(hook) | ||
52 | } | ||
53 | |||
54 | // WithError creates an entry from the standard logger and adds an error to it, using the value defined in ErrorKey as key. | ||
55 | func WithError(err error) *Entry { | ||
56 | return std.WithField(ErrorKey, err) | ||
57 | } | ||
58 | |||
59 | // WithContext creates an entry from the standard logger and adds a context to it. | ||
60 | func WithContext(ctx context.Context) *Entry { | ||
61 | return std.WithContext(ctx) | ||
62 | } | ||
63 | |||
64 | // WithField creates an entry from the standard logger and adds a field to | ||
65 | // it. If you want multiple fields, use `WithFields`. | ||
66 | // | ||
67 | // Note that it doesn't log until you call Debug, Print, Info, Warn, Fatal | ||
68 | // or Panic on the Entry it returns. | ||
69 | func WithField(key string, value interface{}) *Entry { | ||
70 | return std.WithField(key, value) | ||
71 | } | ||
72 | |||
73 | // WithFields creates an entry from the standard logger and adds multiple | ||
74 | // fields to it. This is simply a helper for `WithField`, invoking it | ||
75 | // once for each field. | ||
76 | // | ||
77 | // Note that it doesn't log until you call Debug, Print, Info, Warn, Fatal | ||
78 | // or Panic on the Entry it returns. | ||
79 | func WithFields(fields Fields) *Entry { | ||
80 | return std.WithFields(fields) | ||
81 | } | ||
82 | |||
83 | // WithTime creates an entry from the standard logger and overrides the time of | ||
84 | // logs generated with it. | ||
85 | // | ||
86 | // Note that it doesn't log until you call Debug, Print, Info, Warn, Fatal | ||
87 | // or Panic on the Entry it returns. | ||
88 | func WithTime(t time.Time) *Entry { | ||
89 | return std.WithTime(t) | ||
90 | } | ||
91 | |||
92 | // Trace logs a message at level Trace on the standard logger. | ||
93 | func Trace(args ...interface{}) { | ||
94 | std.Trace(args...) | ||
95 | } | ||
96 | |||
97 | // Debug logs a message at level Debug on the standard logger. | ||
98 | func Debug(args ...interface{}) { | ||
99 | std.Debug(args...) | ||
100 | } | ||
101 | |||
102 | // Print logs a message at level Info on the standard logger. | ||
103 | func Print(args ...interface{}) { | ||
104 | std.Print(args...) | ||
105 | } | ||
106 | |||
107 | // Info logs a message at level Info on the standard logger. | ||
108 | func Info(args ...interface{}) { | ||
109 | std.Info(args...) | ||
110 | } | ||
111 | |||
112 | // Warn logs a message at level Warn on the standard logger. | ||
113 | func Warn(args ...interface{}) { | ||
114 | std.Warn(args...) | ||
115 | } | ||
116 | |||
117 | // Warning logs a message at level Warn on the standard logger. | ||
118 | func Warning(args ...interface{}) { | ||
119 | std.Warning(args...) | ||
120 | } | ||
121 | |||
122 | // Error logs a message at level Error on the standard logger. | ||
123 | func Error(args ...interface{}) { | ||
124 | std.Error(args...) | ||
125 | } | ||
126 | |||
127 | // Panic logs a message at level Panic on the standard logger. | ||
128 | func Panic(args ...interface{}) { | ||
129 | std.Panic(args...) | ||
130 | } | ||
131 | |||
132 | // Fatal logs a message at level Fatal on the standard logger then the process will exit with status set to 1. | ||
133 | func Fatal(args ...interface{}) { | ||
134 | std.Fatal(args...) | ||
135 | } | ||
136 | |||
137 | // TraceFn logs a message from a func at level Trace on the standard logger. | ||
138 | func TraceFn(fn LogFunction) { | ||
139 | std.TraceFn(fn) | ||
140 | } | ||
141 | |||
142 | // DebugFn logs a message from a func at level Debug on the standard logger. | ||
143 | func DebugFn(fn LogFunction) { | ||
144 | std.DebugFn(fn) | ||
145 | } | ||
146 | |||
147 | // PrintFn logs a message from a func at level Info on the standard logger. | ||
148 | func PrintFn(fn LogFunction) { | ||
149 | std.PrintFn(fn) | ||
150 | } | ||
151 | |||
152 | // InfoFn logs a message from a func at level Info on the standard logger. | ||
153 | func InfoFn(fn LogFunction) { | ||
154 | std.InfoFn(fn) | ||
155 | } | ||
156 | |||
157 | // WarnFn logs a message from a func at level Warn on the standard logger. | ||
158 | func WarnFn(fn LogFunction) { | ||
159 | std.WarnFn(fn) | ||
160 | } | ||
161 | |||
162 | // WarningFn logs a message from a func at level Warn on the standard logger. | ||
163 | func WarningFn(fn LogFunction) { | ||
164 | std.WarningFn(fn) | ||
165 | } | ||
166 | |||
167 | // ErrorFn logs a message from a func at level Error on the standard logger. | ||
168 | func ErrorFn(fn LogFunction) { | ||
169 | std.ErrorFn(fn) | ||
170 | } | ||
171 | |||
172 | // PanicFn logs a message from a func at level Panic on the standard logger. | ||
173 | func PanicFn(fn LogFunction) { | ||
174 | std.PanicFn(fn) | ||
175 | } | ||
176 | |||
177 | // FatalFn logs a message from a func at level Fatal on the standard logger then the process will exit with status set to 1. | ||
178 | func FatalFn(fn LogFunction) { | ||
179 | std.FatalFn(fn) | ||
180 | } | ||
181 | |||
182 | // Tracef logs a message at level Trace on the standard logger. | ||
183 | func Tracef(format string, args ...interface{}) { | ||
184 | std.Tracef(format, args...) | ||
185 | } | ||
186 | |||
187 | // Debugf logs a message at level Debug on the standard logger. | ||
188 | func Debugf(format string, args ...interface{}) { | ||
189 | std.Debugf(format, args...) | ||
190 | } | ||
191 | |||
192 | // Printf logs a message at level Info on the standard logger. | ||
193 | func Printf(format string, args ...interface{}) { | ||
194 | std.Printf(format, args...) | ||
195 | } | ||
196 | |||
197 | // Infof logs a message at level Info on the standard logger. | ||
198 | func Infof(format string, args ...interface{}) { | ||
199 | std.Infof(format, args...) | ||
200 | } | ||
201 | |||
202 | // Warnf logs a message at level Warn on the standard logger. | ||
203 | func Warnf(format string, args ...interface{}) { | ||
204 | std.Warnf(format, args...) | ||
205 | } | ||
206 | |||
207 | // Warningf logs a message at level Warn on the standard logger. | ||
208 | func Warningf(format string, args ...interface{}) { | ||
209 | std.Warningf(format, args...) | ||
210 | } | ||
211 | |||
212 | // Errorf logs a message at level Error on the standard logger. | ||
213 | func Errorf(format string, args ...interface{}) { | ||
214 | std.Errorf(format, args...) | ||
215 | } | ||
216 | |||
217 | // Panicf logs a message at level Panic on the standard logger. | ||
218 | func Panicf(format string, args ...interface{}) { | ||
219 | std.Panicf(format, args...) | ||
220 | } | ||
221 | |||
222 | // Fatalf logs a message at level Fatal on the standard logger then the process will exit with status set to 1. | ||
223 | func Fatalf(format string, args ...interface{}) { | ||
224 | std.Fatalf(format, args...) | ||
225 | } | ||
226 | |||
227 | // Traceln logs a message at level Trace on the standard logger. | ||
228 | func Traceln(args ...interface{}) { | ||
229 | std.Traceln(args...) | ||
230 | } | ||
231 | |||
232 | // Debugln logs a message at level Debug on the standard logger. | ||
233 | func Debugln(args ...interface{}) { | ||
234 | std.Debugln(args...) | ||
235 | } | ||
236 | |||
237 | // Println logs a message at level Info on the standard logger. | ||
238 | func Println(args ...interface{}) { | ||
239 | std.Println(args...) | ||
240 | } | ||
241 | |||
242 | // Infoln logs a message at level Info on the standard logger. | ||
243 | func Infoln(args ...interface{}) { | ||
244 | std.Infoln(args...) | ||
245 | } | ||
246 | |||
247 | // Warnln logs a message at level Warn on the standard logger. | ||
248 | func Warnln(args ...interface{}) { | ||
249 | std.Warnln(args...) | ||
250 | } | ||
251 | |||
252 | // Warningln logs a message at level Warn on the standard logger. | ||
253 | func Warningln(args ...interface{}) { | ||
254 | std.Warningln(args...) | ||
255 | } | ||
256 | |||
257 | // Errorln logs a message at level Error on the standard logger. | ||
258 | func Errorln(args ...interface{}) { | ||
259 | std.Errorln(args...) | ||
260 | } | ||
261 | |||
262 | // Panicln logs a message at level Panic on the standard logger. | ||
263 | func Panicln(args ...interface{}) { | ||
264 | std.Panicln(args...) | ||
265 | } | ||
266 | |||
267 | // Fatalln logs a message at level Fatal on the standard logger then the process will exit with status set to 1. | ||
268 | func Fatalln(args ...interface{}) { | ||
269 | std.Fatalln(args...) | ||
270 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/formatter.go b/vendor/github.com/sirupsen/logrus/formatter.go new file mode 100644 index 0000000..4088837 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/formatter.go | |||
@@ -0,0 +1,78 @@ | |||
1 | package logrus | ||
2 | |||
3 | import "time" | ||
4 | |||
5 | // Default key names for the default fields | ||
6 | const ( | ||
7 | defaultTimestampFormat = time.RFC3339 | ||
8 | FieldKeyMsg = "msg" | ||
9 | FieldKeyLevel = "level" | ||
10 | FieldKeyTime = "time" | ||
11 | FieldKeyLogrusError = "logrus_error" | ||
12 | FieldKeyFunc = "func" | ||
13 | FieldKeyFile = "file" | ||
14 | ) | ||
15 | |||
16 | // The Formatter interface is used to implement a custom Formatter. It takes an | ||
17 | // `Entry`. It exposes all the fields, including the default ones: | ||
18 | // | ||
19 | // * `entry.Data["msg"]`. The message passed from Info, Warn, Error .. | ||
20 | // * `entry.Data["time"]`. The timestamp. | ||
21 | // * `entry.Data["level"]. The level the entry was logged at. | ||
22 | // | ||
23 | // Any additional fields added with `WithField` or `WithFields` are also in | ||
24 | // `entry.Data`. Format is expected to return an array of bytes which are then | ||
25 | // logged to `logger.Out`. | ||
26 | type Formatter interface { | ||
27 | Format(*Entry) ([]byte, error) | ||
28 | } | ||
29 | |||
30 | // This is to not silently overwrite `time`, `msg`, `func` and `level` fields when | ||
31 | // dumping it. If this code wasn't there doing: | ||
32 | // | ||
33 | // logrus.WithField("level", 1).Info("hello") | ||
34 | // | ||
35 | // Would just silently drop the user provided level. Instead with this code | ||
36 | // it'll logged as: | ||
37 | // | ||
38 | // {"level": "info", "fields.level": 1, "msg": "hello", "time": "..."} | ||
39 | // | ||
40 | // It's not exported because it's still using Data in an opinionated way. It's to | ||
41 | // avoid code duplication between the two default formatters. | ||
42 | func prefixFieldClashes(data Fields, fieldMap FieldMap, reportCaller bool) { | ||
43 | timeKey := fieldMap.resolve(FieldKeyTime) | ||
44 | if t, ok := data[timeKey]; ok { | ||
45 | data["fields."+timeKey] = t | ||
46 | delete(data, timeKey) | ||
47 | } | ||
48 | |||
49 | msgKey := fieldMap.resolve(FieldKeyMsg) | ||
50 | if m, ok := data[msgKey]; ok { | ||
51 | data["fields."+msgKey] = m | ||
52 | delete(data, msgKey) | ||
53 | } | ||
54 | |||
55 | levelKey := fieldMap.resolve(FieldKeyLevel) | ||
56 | if l, ok := data[levelKey]; ok { | ||
57 | data["fields."+levelKey] = l | ||
58 | delete(data, levelKey) | ||
59 | } | ||
60 | |||
61 | logrusErrKey := fieldMap.resolve(FieldKeyLogrusError) | ||
62 | if l, ok := data[logrusErrKey]; ok { | ||
63 | data["fields."+logrusErrKey] = l | ||
64 | delete(data, logrusErrKey) | ||
65 | } | ||
66 | |||
67 | // If reportCaller is not set, 'func' will not conflict. | ||
68 | if reportCaller { | ||
69 | funcKey := fieldMap.resolve(FieldKeyFunc) | ||
70 | if l, ok := data[funcKey]; ok { | ||
71 | data["fields."+funcKey] = l | ||
72 | } | ||
73 | fileKey := fieldMap.resolve(FieldKeyFile) | ||
74 | if l, ok := data[fileKey]; ok { | ||
75 | data["fields."+fileKey] = l | ||
76 | } | ||
77 | } | ||
78 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/hooks.go b/vendor/github.com/sirupsen/logrus/hooks.go new file mode 100644 index 0000000..3f151cd --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/hooks.go | |||
@@ -0,0 +1,34 @@ | |||
1 | package logrus | ||
2 | |||
3 | // A hook to be fired when logging on the logging levels returned from | ||
4 | // `Levels()` on your implementation of the interface. Note that this is not | ||
5 | // fired in a goroutine or a channel with workers, you should handle such | ||
6 | // functionality yourself if your call is non-blocking and you don't wish for | ||
7 | // the logging calls for levels returned from `Levels()` to block. | ||
8 | type Hook interface { | ||
9 | Levels() []Level | ||
10 | Fire(*Entry) error | ||
11 | } | ||
12 | |||
13 | // Internal type for storing the hooks on a logger instance. | ||
14 | type LevelHooks map[Level][]Hook | ||
15 | |||
16 | // Add a hook to an instance of logger. This is called with | ||
17 | // `log.Hooks.Add(new(MyHook))` where `MyHook` implements the `Hook` interface. | ||
18 | func (hooks LevelHooks) Add(hook Hook) { | ||
19 | for _, level := range hook.Levels() { | ||
20 | hooks[level] = append(hooks[level], hook) | ||
21 | } | ||
22 | } | ||
23 | |||
24 | // Fire all the hooks for the passed level. Used by `entry.log` to fire | ||
25 | // appropriate hooks for a log entry. | ||
26 | func (hooks LevelHooks) Fire(level Level, entry *Entry) error { | ||
27 | for _, hook := range hooks[level] { | ||
28 | if err := hook.Fire(entry); err != nil { | ||
29 | return err | ||
30 | } | ||
31 | } | ||
32 | |||
33 | return nil | ||
34 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/json_formatter.go b/vendor/github.com/sirupsen/logrus/json_formatter.go new file mode 100644 index 0000000..c96dc56 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/json_formatter.go | |||
@@ -0,0 +1,128 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "bytes" | ||
5 | "encoding/json" | ||
6 | "fmt" | ||
7 | "runtime" | ||
8 | ) | ||
9 | |||
10 | type fieldKey string | ||
11 | |||
12 | // FieldMap allows customization of the key names for default fields. | ||
13 | type FieldMap map[fieldKey]string | ||
14 | |||
15 | func (f FieldMap) resolve(key fieldKey) string { | ||
16 | if k, ok := f[key]; ok { | ||
17 | return k | ||
18 | } | ||
19 | |||
20 | return string(key) | ||
21 | } | ||
22 | |||
23 | // JSONFormatter formats logs into parsable json | ||
24 | type JSONFormatter struct { | ||
25 | // TimestampFormat sets the format used for marshaling timestamps. | ||
26 | // The format to use is the same than for time.Format or time.Parse from the standard | ||
27 | // library. | ||
28 | // The standard Library already provides a set of predefined format. | ||
29 | TimestampFormat string | ||
30 | |||
31 | // DisableTimestamp allows disabling automatic timestamps in output | ||
32 | DisableTimestamp bool | ||
33 | |||
34 | // DisableHTMLEscape allows disabling html escaping in output | ||
35 | DisableHTMLEscape bool | ||
36 | |||
37 | // DataKey allows users to put all the log entry parameters into a nested dictionary at a given key. | ||
38 | DataKey string | ||
39 | |||
40 | // FieldMap allows users to customize the names of keys for default fields. | ||
41 | // As an example: | ||
42 | // formatter := &JSONFormatter{ | ||
43 | // FieldMap: FieldMap{ | ||
44 | // FieldKeyTime: "@timestamp", | ||
45 | // FieldKeyLevel: "@level", | ||
46 | // FieldKeyMsg: "@message", | ||
47 | // FieldKeyFunc: "@caller", | ||
48 | // }, | ||
49 | // } | ||
50 | FieldMap FieldMap | ||
51 | |||
52 | // CallerPrettyfier can be set by the user to modify the content | ||
53 | // of the function and file keys in the json data when ReportCaller is | ||
54 | // activated. If any of the returned value is the empty string the | ||
55 | // corresponding key will be removed from json fields. | ||
56 | CallerPrettyfier func(*runtime.Frame) (function string, file string) | ||
57 | |||
58 | // PrettyPrint will indent all json logs | ||
59 | PrettyPrint bool | ||
60 | } | ||
61 | |||
62 | // Format renders a single log entry | ||
63 | func (f *JSONFormatter) Format(entry *Entry) ([]byte, error) { | ||
64 | data := make(Fields, len(entry.Data)+4) | ||
65 | for k, v := range entry.Data { | ||
66 | switch v := v.(type) { | ||
67 | case error: | ||
68 | // Otherwise errors are ignored by `encoding/json` | ||
69 | // https://github.com/sirupsen/logrus/issues/137 | ||
70 | data[k] = v.Error() | ||
71 | default: | ||
72 | data[k] = v | ||
73 | } | ||
74 | } | ||
75 | |||
76 | if f.DataKey != "" { | ||
77 | newData := make(Fields, 4) | ||
78 | newData[f.DataKey] = data | ||
79 | data = newData | ||
80 | } | ||
81 | |||
82 | prefixFieldClashes(data, f.FieldMap, entry.HasCaller()) | ||
83 | |||
84 | timestampFormat := f.TimestampFormat | ||
85 | if timestampFormat == "" { | ||
86 | timestampFormat = defaultTimestampFormat | ||
87 | } | ||
88 | |||
89 | if entry.err != "" { | ||
90 | data[f.FieldMap.resolve(FieldKeyLogrusError)] = entry.err | ||
91 | } | ||
92 | if !f.DisableTimestamp { | ||
93 | data[f.FieldMap.resolve(FieldKeyTime)] = entry.Time.Format(timestampFormat) | ||
94 | } | ||
95 | data[f.FieldMap.resolve(FieldKeyMsg)] = entry.Message | ||
96 | data[f.FieldMap.resolve(FieldKeyLevel)] = entry.Level.String() | ||
97 | if entry.HasCaller() { | ||
98 | funcVal := entry.Caller.Function | ||
99 | fileVal := fmt.Sprintf("%s:%d", entry.Caller.File, entry.Caller.Line) | ||
100 | if f.CallerPrettyfier != nil { | ||
101 | funcVal, fileVal = f.CallerPrettyfier(entry.Caller) | ||
102 | } | ||
103 | if funcVal != "" { | ||
104 | data[f.FieldMap.resolve(FieldKeyFunc)] = funcVal | ||
105 | } | ||
106 | if fileVal != "" { | ||
107 | data[f.FieldMap.resolve(FieldKeyFile)] = fileVal | ||
108 | } | ||
109 | } | ||
110 | |||
111 | var b *bytes.Buffer | ||
112 | if entry.Buffer != nil { | ||
113 | b = entry.Buffer | ||
114 | } else { | ||
115 | b = &bytes.Buffer{} | ||
116 | } | ||
117 | |||
118 | encoder := json.NewEncoder(b) | ||
119 | encoder.SetEscapeHTML(!f.DisableHTMLEscape) | ||
120 | if f.PrettyPrint { | ||
121 | encoder.SetIndent("", " ") | ||
122 | } | ||
123 | if err := encoder.Encode(data); err != nil { | ||
124 | return nil, fmt.Errorf("failed to marshal fields to JSON, %w", err) | ||
125 | } | ||
126 | |||
127 | return b.Bytes(), nil | ||
128 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/logger.go b/vendor/github.com/sirupsen/logrus/logger.go new file mode 100644 index 0000000..5ff0aef --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/logger.go | |||
@@ -0,0 +1,417 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "context" | ||
5 | "io" | ||
6 | "os" | ||
7 | "sync" | ||
8 | "sync/atomic" | ||
9 | "time" | ||
10 | ) | ||
11 | |||
12 | // LogFunction For big messages, it can be more efficient to pass a function | ||
13 | // and only call it if the log level is actually enables rather than | ||
14 | // generating the log message and then checking if the level is enabled | ||
15 | type LogFunction func() []interface{} | ||
16 | |||
17 | type Logger struct { | ||
18 | // The logs are `io.Copy`'d to this in a mutex. It's common to set this to a | ||
19 | // file, or leave it default which is `os.Stderr`. You can also set this to | ||
20 | // something more adventurous, such as logging to Kafka. | ||
21 | Out io.Writer | ||
22 | // Hooks for the logger instance. These allow firing events based on logging | ||
23 | // levels and log entries. For example, to send errors to an error tracking | ||
24 | // service, log to StatsD or dump the core on fatal errors. | ||
25 | Hooks LevelHooks | ||
26 | // All log entries pass through the formatter before logged to Out. The | ||
27 | // included formatters are `TextFormatter` and `JSONFormatter` for which | ||
28 | // TextFormatter is the default. In development (when a TTY is attached) it | ||
29 | // logs with colors, but to a file it wouldn't. You can easily implement your | ||
30 | // own that implements the `Formatter` interface, see the `README` or included | ||
31 | // formatters for examples. | ||
32 | Formatter Formatter | ||
33 | |||
34 | // Flag for whether to log caller info (off by default) | ||
35 | ReportCaller bool | ||
36 | |||
37 | // The logging level the logger should log at. This is typically (and defaults | ||
38 | // to) `logrus.Info`, which allows Info(), Warn(), Error() and Fatal() to be | ||
39 | // logged. | ||
40 | Level Level | ||
41 | // Used to sync writing to the log. Locking is enabled by Default | ||
42 | mu MutexWrap | ||
43 | // Reusable empty entry | ||
44 | entryPool sync.Pool | ||
45 | // Function to exit the application, defaults to `os.Exit()` | ||
46 | ExitFunc exitFunc | ||
47 | // The buffer pool used to format the log. If it is nil, the default global | ||
48 | // buffer pool will be used. | ||
49 | BufferPool BufferPool | ||
50 | } | ||
51 | |||
52 | type exitFunc func(int) | ||
53 | |||
54 | type MutexWrap struct { | ||
55 | lock sync.Mutex | ||
56 | disabled bool | ||
57 | } | ||
58 | |||
59 | func (mw *MutexWrap) Lock() { | ||
60 | if !mw.disabled { | ||
61 | mw.lock.Lock() | ||
62 | } | ||
63 | } | ||
64 | |||
65 | func (mw *MutexWrap) Unlock() { | ||
66 | if !mw.disabled { | ||
67 | mw.lock.Unlock() | ||
68 | } | ||
69 | } | ||
70 | |||
71 | func (mw *MutexWrap) Disable() { | ||
72 | mw.disabled = true | ||
73 | } | ||
74 | |||
75 | // Creates a new logger. Configuration should be set by changing `Formatter`, | ||
76 | // `Out` and `Hooks` directly on the default logger instance. You can also just | ||
77 | // instantiate your own: | ||
78 | // | ||
79 | // var log = &logrus.Logger{ | ||
80 | // Out: os.Stderr, | ||
81 | // Formatter: new(logrus.TextFormatter), | ||
82 | // Hooks: make(logrus.LevelHooks), | ||
83 | // Level: logrus.DebugLevel, | ||
84 | // } | ||
85 | // | ||
86 | // It's recommended to make this a global instance called `log`. | ||
87 | func New() *Logger { | ||
88 | return &Logger{ | ||
89 | Out: os.Stderr, | ||
90 | Formatter: new(TextFormatter), | ||
91 | Hooks: make(LevelHooks), | ||
92 | Level: InfoLevel, | ||
93 | ExitFunc: os.Exit, | ||
94 | ReportCaller: false, | ||
95 | } | ||
96 | } | ||
97 | |||
98 | func (logger *Logger) newEntry() *Entry { | ||
99 | entry, ok := logger.entryPool.Get().(*Entry) | ||
100 | if ok { | ||
101 | return entry | ||
102 | } | ||
103 | return NewEntry(logger) | ||
104 | } | ||
105 | |||
106 | func (logger *Logger) releaseEntry(entry *Entry) { | ||
107 | entry.Data = map[string]interface{}{} | ||
108 | logger.entryPool.Put(entry) | ||
109 | } | ||
110 | |||
111 | // WithField allocates a new entry and adds a field to it. | ||
112 | // Debug, Print, Info, Warn, Error, Fatal or Panic must be then applied to | ||
113 | // this new returned entry. | ||
114 | // If you want multiple fields, use `WithFields`. | ||
115 | func (logger *Logger) WithField(key string, value interface{}) *Entry { | ||
116 | entry := logger.newEntry() | ||
117 | defer logger.releaseEntry(entry) | ||
118 | return entry.WithField(key, value) | ||
119 | } | ||
120 | |||
121 | // Adds a struct of fields to the log entry. All it does is call `WithField` for | ||
122 | // each `Field`. | ||
123 | func (logger *Logger) WithFields(fields Fields) *Entry { | ||
124 | entry := logger.newEntry() | ||
125 | defer logger.releaseEntry(entry) | ||
126 | return entry.WithFields(fields) | ||
127 | } | ||
128 | |||
129 | // Add an error as single field to the log entry. All it does is call | ||
130 | // `WithError` for the given `error`. | ||
131 | func (logger *Logger) WithError(err error) *Entry { | ||
132 | entry := logger.newEntry() | ||
133 | defer logger.releaseEntry(entry) | ||
134 | return entry.WithError(err) | ||
135 | } | ||
136 | |||
137 | // Add a context to the log entry. | ||
138 | func (logger *Logger) WithContext(ctx context.Context) *Entry { | ||
139 | entry := logger.newEntry() | ||
140 | defer logger.releaseEntry(entry) | ||
141 | return entry.WithContext(ctx) | ||
142 | } | ||
143 | |||
144 | // Overrides the time of the log entry. | ||
145 | func (logger *Logger) WithTime(t time.Time) *Entry { | ||
146 | entry := logger.newEntry() | ||
147 | defer logger.releaseEntry(entry) | ||
148 | return entry.WithTime(t) | ||
149 | } | ||
150 | |||
151 | func (logger *Logger) Logf(level Level, format string, args ...interface{}) { | ||
152 | if logger.IsLevelEnabled(level) { | ||
153 | entry := logger.newEntry() | ||
154 | entry.Logf(level, format, args...) | ||
155 | logger.releaseEntry(entry) | ||
156 | } | ||
157 | } | ||
158 | |||
159 | func (logger *Logger) Tracef(format string, args ...interface{}) { | ||
160 | logger.Logf(TraceLevel, format, args...) | ||
161 | } | ||
162 | |||
163 | func (logger *Logger) Debugf(format string, args ...interface{}) { | ||
164 | logger.Logf(DebugLevel, format, args...) | ||
165 | } | ||
166 | |||
167 | func (logger *Logger) Infof(format string, args ...interface{}) { | ||
168 | logger.Logf(InfoLevel, format, args...) | ||
169 | } | ||
170 | |||
171 | func (logger *Logger) Printf(format string, args ...interface{}) { | ||
172 | entry := logger.newEntry() | ||
173 | entry.Printf(format, args...) | ||
174 | logger.releaseEntry(entry) | ||
175 | } | ||
176 | |||
177 | func (logger *Logger) Warnf(format string, args ...interface{}) { | ||
178 | logger.Logf(WarnLevel, format, args...) | ||
179 | } | ||
180 | |||
181 | func (logger *Logger) Warningf(format string, args ...interface{}) { | ||
182 | logger.Warnf(format, args...) | ||
183 | } | ||
184 | |||
185 | func (logger *Logger) Errorf(format string, args ...interface{}) { | ||
186 | logger.Logf(ErrorLevel, format, args...) | ||
187 | } | ||
188 | |||
189 | func (logger *Logger) Fatalf(format string, args ...interface{}) { | ||
190 | logger.Logf(FatalLevel, format, args...) | ||
191 | logger.Exit(1) | ||
192 | } | ||
193 | |||
194 | func (logger *Logger) Panicf(format string, args ...interface{}) { | ||
195 | logger.Logf(PanicLevel, format, args...) | ||
196 | } | ||
197 | |||
198 | // Log will log a message at the level given as parameter. | ||
199 | // Warning: using Log at Panic or Fatal level will not respectively Panic nor Exit. | ||
200 | // For this behaviour Logger.Panic or Logger.Fatal should be used instead. | ||
201 | func (logger *Logger) Log(level Level, args ...interface{}) { | ||
202 | if logger.IsLevelEnabled(level) { | ||
203 | entry := logger.newEntry() | ||
204 | entry.Log(level, args...) | ||
205 | logger.releaseEntry(entry) | ||
206 | } | ||
207 | } | ||
208 | |||
209 | func (logger *Logger) LogFn(level Level, fn LogFunction) { | ||
210 | if logger.IsLevelEnabled(level) { | ||
211 | entry := logger.newEntry() | ||
212 | entry.Log(level, fn()...) | ||
213 | logger.releaseEntry(entry) | ||
214 | } | ||
215 | } | ||
216 | |||
217 | func (logger *Logger) Trace(args ...interface{}) { | ||
218 | logger.Log(TraceLevel, args...) | ||
219 | } | ||
220 | |||
221 | func (logger *Logger) Debug(args ...interface{}) { | ||
222 | logger.Log(DebugLevel, args...) | ||
223 | } | ||
224 | |||
225 | func (logger *Logger) Info(args ...interface{}) { | ||
226 | logger.Log(InfoLevel, args...) | ||
227 | } | ||
228 | |||
229 | func (logger *Logger) Print(args ...interface{}) { | ||
230 | entry := logger.newEntry() | ||
231 | entry.Print(args...) | ||
232 | logger.releaseEntry(entry) | ||
233 | } | ||
234 | |||
235 | func (logger *Logger) Warn(args ...interface{}) { | ||
236 | logger.Log(WarnLevel, args...) | ||
237 | } | ||
238 | |||
239 | func (logger *Logger) Warning(args ...interface{}) { | ||
240 | logger.Warn(args...) | ||
241 | } | ||
242 | |||
243 | func (logger *Logger) Error(args ...interface{}) { | ||
244 | logger.Log(ErrorLevel, args...) | ||
245 | } | ||
246 | |||
247 | func (logger *Logger) Fatal(args ...interface{}) { | ||
248 | logger.Log(FatalLevel, args...) | ||
249 | logger.Exit(1) | ||
250 | } | ||
251 | |||
252 | func (logger *Logger) Panic(args ...interface{}) { | ||
253 | logger.Log(PanicLevel, args...) | ||
254 | } | ||
255 | |||
256 | func (logger *Logger) TraceFn(fn LogFunction) { | ||
257 | logger.LogFn(TraceLevel, fn) | ||
258 | } | ||
259 | |||
260 | func (logger *Logger) DebugFn(fn LogFunction) { | ||
261 | logger.LogFn(DebugLevel, fn) | ||
262 | } | ||
263 | |||
264 | func (logger *Logger) InfoFn(fn LogFunction) { | ||
265 | logger.LogFn(InfoLevel, fn) | ||
266 | } | ||
267 | |||
268 | func (logger *Logger) PrintFn(fn LogFunction) { | ||
269 | entry := logger.newEntry() | ||
270 | entry.Print(fn()...) | ||
271 | logger.releaseEntry(entry) | ||
272 | } | ||
273 | |||
274 | func (logger *Logger) WarnFn(fn LogFunction) { | ||
275 | logger.LogFn(WarnLevel, fn) | ||
276 | } | ||
277 | |||
278 | func (logger *Logger) WarningFn(fn LogFunction) { | ||
279 | logger.WarnFn(fn) | ||
280 | } | ||
281 | |||
282 | func (logger *Logger) ErrorFn(fn LogFunction) { | ||
283 | logger.LogFn(ErrorLevel, fn) | ||
284 | } | ||
285 | |||
286 | func (logger *Logger) FatalFn(fn LogFunction) { | ||
287 | logger.LogFn(FatalLevel, fn) | ||
288 | logger.Exit(1) | ||
289 | } | ||
290 | |||
291 | func (logger *Logger) PanicFn(fn LogFunction) { | ||
292 | logger.LogFn(PanicLevel, fn) | ||
293 | } | ||
294 | |||
295 | func (logger *Logger) Logln(level Level, args ...interface{}) { | ||
296 | if logger.IsLevelEnabled(level) { | ||
297 | entry := logger.newEntry() | ||
298 | entry.Logln(level, args...) | ||
299 | logger.releaseEntry(entry) | ||
300 | } | ||
301 | } | ||
302 | |||
303 | func (logger *Logger) Traceln(args ...interface{}) { | ||
304 | logger.Logln(TraceLevel, args...) | ||
305 | } | ||
306 | |||
307 | func (logger *Logger) Debugln(args ...interface{}) { | ||
308 | logger.Logln(DebugLevel, args...) | ||
309 | } | ||
310 | |||
311 | func (logger *Logger) Infoln(args ...interface{}) { | ||
312 | logger.Logln(InfoLevel, args...) | ||
313 | } | ||
314 | |||
315 | func (logger *Logger) Println(args ...interface{}) { | ||
316 | entry := logger.newEntry() | ||
317 | entry.Println(args...) | ||
318 | logger.releaseEntry(entry) | ||
319 | } | ||
320 | |||
321 | func (logger *Logger) Warnln(args ...interface{}) { | ||
322 | logger.Logln(WarnLevel, args...) | ||
323 | } | ||
324 | |||
325 | func (logger *Logger) Warningln(args ...interface{}) { | ||
326 | logger.Warnln(args...) | ||
327 | } | ||
328 | |||
329 | func (logger *Logger) Errorln(args ...interface{}) { | ||
330 | logger.Logln(ErrorLevel, args...) | ||
331 | } | ||
332 | |||
333 | func (logger *Logger) Fatalln(args ...interface{}) { | ||
334 | logger.Logln(FatalLevel, args...) | ||
335 | logger.Exit(1) | ||
336 | } | ||
337 | |||
338 | func (logger *Logger) Panicln(args ...interface{}) { | ||
339 | logger.Logln(PanicLevel, args...) | ||
340 | } | ||
341 | |||
342 | func (logger *Logger) Exit(code int) { | ||
343 | runHandlers() | ||
344 | if logger.ExitFunc == nil { | ||
345 | logger.ExitFunc = os.Exit | ||
346 | } | ||
347 | logger.ExitFunc(code) | ||
348 | } | ||
349 | |||
350 | //When file is opened with appending mode, it's safe to | ||
351 | //write concurrently to a file (within 4k message on Linux). | ||
352 | //In these cases user can choose to disable the lock. | ||
353 | func (logger *Logger) SetNoLock() { | ||
354 | logger.mu.Disable() | ||
355 | } | ||
356 | |||
357 | func (logger *Logger) level() Level { | ||
358 | return Level(atomic.LoadUint32((*uint32)(&logger.Level))) | ||
359 | } | ||
360 | |||
361 | // SetLevel sets the logger level. | ||
362 | func (logger *Logger) SetLevel(level Level) { | ||
363 | atomic.StoreUint32((*uint32)(&logger.Level), uint32(level)) | ||
364 | } | ||
365 | |||
366 | // GetLevel returns the logger level. | ||
367 | func (logger *Logger) GetLevel() Level { | ||
368 | return logger.level() | ||
369 | } | ||
370 | |||
371 | // AddHook adds a hook to the logger hooks. | ||
372 | func (logger *Logger) AddHook(hook Hook) { | ||
373 | logger.mu.Lock() | ||
374 | defer logger.mu.Unlock() | ||
375 | logger.Hooks.Add(hook) | ||
376 | } | ||
377 | |||
378 | // IsLevelEnabled checks if the log level of the logger is greater than the level param | ||
379 | func (logger *Logger) IsLevelEnabled(level Level) bool { | ||
380 | return logger.level() >= level | ||
381 | } | ||
382 | |||
383 | // SetFormatter sets the logger formatter. | ||
384 | func (logger *Logger) SetFormatter(formatter Formatter) { | ||
385 | logger.mu.Lock() | ||
386 | defer logger.mu.Unlock() | ||
387 | logger.Formatter = formatter | ||
388 | } | ||
389 | |||
390 | // SetOutput sets the logger output. | ||
391 | func (logger *Logger) SetOutput(output io.Writer) { | ||
392 | logger.mu.Lock() | ||
393 | defer logger.mu.Unlock() | ||
394 | logger.Out = output | ||
395 | } | ||
396 | |||
397 | func (logger *Logger) SetReportCaller(reportCaller bool) { | ||
398 | logger.mu.Lock() | ||
399 | defer logger.mu.Unlock() | ||
400 | logger.ReportCaller = reportCaller | ||
401 | } | ||
402 | |||
403 | // ReplaceHooks replaces the logger hooks and returns the old ones | ||
404 | func (logger *Logger) ReplaceHooks(hooks LevelHooks) LevelHooks { | ||
405 | logger.mu.Lock() | ||
406 | oldHooks := logger.Hooks | ||
407 | logger.Hooks = hooks | ||
408 | logger.mu.Unlock() | ||
409 | return oldHooks | ||
410 | } | ||
411 | |||
412 | // SetBufferPool sets the logger buffer pool. | ||
413 | func (logger *Logger) SetBufferPool(pool BufferPool) { | ||
414 | logger.mu.Lock() | ||
415 | defer logger.mu.Unlock() | ||
416 | logger.BufferPool = pool | ||
417 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/logrus.go b/vendor/github.com/sirupsen/logrus/logrus.go new file mode 100644 index 0000000..2f16224 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/logrus.go | |||
@@ -0,0 +1,186 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "fmt" | ||
5 | "log" | ||
6 | "strings" | ||
7 | ) | ||
8 | |||
9 | // Fields type, used to pass to `WithFields`. | ||
10 | type Fields map[string]interface{} | ||
11 | |||
12 | // Level type | ||
13 | type Level uint32 | ||
14 | |||
15 | // Convert the Level to a string. E.g. PanicLevel becomes "panic". | ||
16 | func (level Level) String() string { | ||
17 | if b, err := level.MarshalText(); err == nil { | ||
18 | return string(b) | ||
19 | } else { | ||
20 | return "unknown" | ||
21 | } | ||
22 | } | ||
23 | |||
24 | // ParseLevel takes a string level and returns the Logrus log level constant. | ||
25 | func ParseLevel(lvl string) (Level, error) { | ||
26 | switch strings.ToLower(lvl) { | ||
27 | case "panic": | ||
28 | return PanicLevel, nil | ||
29 | case "fatal": | ||
30 | return FatalLevel, nil | ||
31 | case "error": | ||
32 | return ErrorLevel, nil | ||
33 | case "warn", "warning": | ||
34 | return WarnLevel, nil | ||
35 | case "info": | ||
36 | return InfoLevel, nil | ||
37 | case "debug": | ||
38 | return DebugLevel, nil | ||
39 | case "trace": | ||
40 | return TraceLevel, nil | ||
41 | } | ||
42 | |||
43 | var l Level | ||
44 | return l, fmt.Errorf("not a valid logrus Level: %q", lvl) | ||
45 | } | ||
46 | |||
47 | // UnmarshalText implements encoding.TextUnmarshaler. | ||
48 | func (level *Level) UnmarshalText(text []byte) error { | ||
49 | l, err := ParseLevel(string(text)) | ||
50 | if err != nil { | ||
51 | return err | ||
52 | } | ||
53 | |||
54 | *level = l | ||
55 | |||
56 | return nil | ||
57 | } | ||
58 | |||
59 | func (level Level) MarshalText() ([]byte, error) { | ||
60 | switch level { | ||
61 | case TraceLevel: | ||
62 | return []byte("trace"), nil | ||
63 | case DebugLevel: | ||
64 | return []byte("debug"), nil | ||
65 | case InfoLevel: | ||
66 | return []byte("info"), nil | ||
67 | case WarnLevel: | ||
68 | return []byte("warning"), nil | ||
69 | case ErrorLevel: | ||
70 | return []byte("error"), nil | ||
71 | case FatalLevel: | ||
72 | return []byte("fatal"), nil | ||
73 | case PanicLevel: | ||
74 | return []byte("panic"), nil | ||
75 | } | ||
76 | |||
77 | return nil, fmt.Errorf("not a valid logrus level %d", level) | ||
78 | } | ||
79 | |||
80 | // A constant exposing all logging levels | ||
81 | var AllLevels = []Level{ | ||
82 | PanicLevel, | ||
83 | FatalLevel, | ||
84 | ErrorLevel, | ||
85 | WarnLevel, | ||
86 | InfoLevel, | ||
87 | DebugLevel, | ||
88 | TraceLevel, | ||
89 | } | ||
90 | |||
91 | // These are the different logging levels. You can set the logging level to log | ||
92 | // on your instance of logger, obtained with `logrus.New()`. | ||
93 | const ( | ||
94 | // PanicLevel level, highest level of severity. Logs and then calls panic with the | ||
95 | // message passed to Debug, Info, ... | ||
96 | PanicLevel Level = iota | ||
97 | // FatalLevel level. Logs and then calls `logger.Exit(1)`. It will exit even if the | ||
98 | // logging level is set to Panic. | ||
99 | FatalLevel | ||
100 | // ErrorLevel level. Logs. Used for errors that should definitely be noted. | ||
101 | // Commonly used for hooks to send errors to an error tracking service. | ||
102 | ErrorLevel | ||
103 | // WarnLevel level. Non-critical entries that deserve eyes. | ||
104 | WarnLevel | ||
105 | // InfoLevel level. General operational entries about what's going on inside the | ||
106 | // application. | ||
107 | InfoLevel | ||
108 | // DebugLevel level. Usually only enabled when debugging. Very verbose logging. | ||
109 | DebugLevel | ||
110 | // TraceLevel level. Designates finer-grained informational events than the Debug. | ||
111 | TraceLevel | ||
112 | ) | ||
113 | |||
114 | // Won't compile if StdLogger can't be realized by a log.Logger | ||
115 | var ( | ||
116 | _ StdLogger = &log.Logger{} | ||
117 | _ StdLogger = &Entry{} | ||
118 | _ StdLogger = &Logger{} | ||
119 | ) | ||
120 | |||
121 | // StdLogger is what your logrus-enabled library should take, that way | ||
122 | // it'll accept a stdlib logger and a logrus logger. There's no standard | ||
123 | // interface, this is the closest we get, unfortunately. | ||
124 | type StdLogger interface { | ||
125 | Print(...interface{}) | ||
126 | Printf(string, ...interface{}) | ||
127 | Println(...interface{}) | ||
128 | |||
129 | Fatal(...interface{}) | ||
130 | Fatalf(string, ...interface{}) | ||
131 | Fatalln(...interface{}) | ||
132 | |||
133 | Panic(...interface{}) | ||
134 | Panicf(string, ...interface{}) | ||
135 | Panicln(...interface{}) | ||
136 | } | ||
137 | |||
138 | // The FieldLogger interface generalizes the Entry and Logger types | ||
139 | type FieldLogger interface { | ||
140 | WithField(key string, value interface{}) *Entry | ||
141 | WithFields(fields Fields) *Entry | ||
142 | WithError(err error) *Entry | ||
143 | |||
144 | Debugf(format string, args ...interface{}) | ||
145 | Infof(format string, args ...interface{}) | ||
146 | Printf(format string, args ...interface{}) | ||
147 | Warnf(format string, args ...interface{}) | ||
148 | Warningf(format string, args ...interface{}) | ||
149 | Errorf(format string, args ...interface{}) | ||
150 | Fatalf(format string, args ...interface{}) | ||
151 | Panicf(format string, args ...interface{}) | ||
152 | |||
153 | Debug(args ...interface{}) | ||
154 | Info(args ...interface{}) | ||
155 | Print(args ...interface{}) | ||
156 | Warn(args ...interface{}) | ||
157 | Warning(args ...interface{}) | ||
158 | Error(args ...interface{}) | ||
159 | Fatal(args ...interface{}) | ||
160 | Panic(args ...interface{}) | ||
161 | |||
162 | Debugln(args ...interface{}) | ||
163 | Infoln(args ...interface{}) | ||
164 | Println(args ...interface{}) | ||
165 | Warnln(args ...interface{}) | ||
166 | Warningln(args ...interface{}) | ||
167 | Errorln(args ...interface{}) | ||
168 | Fatalln(args ...interface{}) | ||
169 | Panicln(args ...interface{}) | ||
170 | |||
171 | // IsDebugEnabled() bool | ||
172 | // IsInfoEnabled() bool | ||
173 | // IsWarnEnabled() bool | ||
174 | // IsErrorEnabled() bool | ||
175 | // IsFatalEnabled() bool | ||
176 | // IsPanicEnabled() bool | ||
177 | } | ||
178 | |||
179 | // Ext1FieldLogger (the first extension to FieldLogger) is superfluous, it is | ||
180 | // here for consistancy. Do not use. Use Logger or Entry instead. | ||
181 | type Ext1FieldLogger interface { | ||
182 | FieldLogger | ||
183 | Tracef(format string, args ...interface{}) | ||
184 | Trace(args ...interface{}) | ||
185 | Traceln(args ...interface{}) | ||
186 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_appengine.go b/vendor/github.com/sirupsen/logrus/terminal_check_appengine.go new file mode 100644 index 0000000..2403de9 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_appengine.go | |||
@@ -0,0 +1,11 @@ | |||
1 | // +build appengine | ||
2 | |||
3 | package logrus | ||
4 | |||
5 | import ( | ||
6 | "io" | ||
7 | ) | ||
8 | |||
9 | func checkIfTerminal(w io.Writer) bool { | ||
10 | return true | ||
11 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_bsd.go b/vendor/github.com/sirupsen/logrus/terminal_check_bsd.go new file mode 100644 index 0000000..4997899 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_bsd.go | |||
@@ -0,0 +1,13 @@ | |||
1 | // +build darwin dragonfly freebsd netbsd openbsd | ||
2 | // +build !js | ||
3 | |||
4 | package logrus | ||
5 | |||
6 | import "golang.org/x/sys/unix" | ||
7 | |||
8 | const ioctlReadTermios = unix.TIOCGETA | ||
9 | |||
10 | func isTerminal(fd int) bool { | ||
11 | _, err := unix.IoctlGetTermios(fd, ioctlReadTermios) | ||
12 | return err == nil | ||
13 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_js.go b/vendor/github.com/sirupsen/logrus/terminal_check_js.go new file mode 100644 index 0000000..ebdae3e --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_js.go | |||
@@ -0,0 +1,7 @@ | |||
1 | // +build js | ||
2 | |||
3 | package logrus | ||
4 | |||
5 | func isTerminal(fd int) bool { | ||
6 | return false | ||
7 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_no_terminal.go b/vendor/github.com/sirupsen/logrus/terminal_check_no_terminal.go new file mode 100644 index 0000000..97af92c --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_no_terminal.go | |||
@@ -0,0 +1,11 @@ | |||
1 | // +build js nacl plan9 | ||
2 | |||
3 | package logrus | ||
4 | |||
5 | import ( | ||
6 | "io" | ||
7 | ) | ||
8 | |||
9 | func checkIfTerminal(w io.Writer) bool { | ||
10 | return false | ||
11 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_notappengine.go b/vendor/github.com/sirupsen/logrus/terminal_check_notappengine.go new file mode 100644 index 0000000..3293fb3 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_notappengine.go | |||
@@ -0,0 +1,17 @@ | |||
1 | // +build !appengine,!js,!windows,!nacl,!plan9 | ||
2 | |||
3 | package logrus | ||
4 | |||
5 | import ( | ||
6 | "io" | ||
7 | "os" | ||
8 | ) | ||
9 | |||
10 | func checkIfTerminal(w io.Writer) bool { | ||
11 | switch v := w.(type) { | ||
12 | case *os.File: | ||
13 | return isTerminal(int(v.Fd())) | ||
14 | default: | ||
15 | return false | ||
16 | } | ||
17 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_solaris.go b/vendor/github.com/sirupsen/logrus/terminal_check_solaris.go new file mode 100644 index 0000000..f6710b3 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_solaris.go | |||
@@ -0,0 +1,11 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "golang.org/x/sys/unix" | ||
5 | ) | ||
6 | |||
7 | // IsTerminal returns true if the given file descriptor is a terminal. | ||
8 | func isTerminal(fd int) bool { | ||
9 | _, err := unix.IoctlGetTermio(fd, unix.TCGETA) | ||
10 | return err == nil | ||
11 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_unix.go b/vendor/github.com/sirupsen/logrus/terminal_check_unix.go new file mode 100644 index 0000000..04748b8 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_unix.go | |||
@@ -0,0 +1,13 @@ | |||
1 | // +build linux aix zos | ||
2 | // +build !js | ||
3 | |||
4 | package logrus | ||
5 | |||
6 | import "golang.org/x/sys/unix" | ||
7 | |||
8 | const ioctlReadTermios = unix.TCGETS | ||
9 | |||
10 | func isTerminal(fd int) bool { | ||
11 | _, err := unix.IoctlGetTermios(fd, ioctlReadTermios) | ||
12 | return err == nil | ||
13 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/terminal_check_windows.go b/vendor/github.com/sirupsen/logrus/terminal_check_windows.go new file mode 100644 index 0000000..2879eb5 --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/terminal_check_windows.go | |||
@@ -0,0 +1,27 @@ | |||
1 | // +build !appengine,!js,windows | ||
2 | |||
3 | package logrus | ||
4 | |||
5 | import ( | ||
6 | "io" | ||
7 | "os" | ||
8 | |||
9 | "golang.org/x/sys/windows" | ||
10 | ) | ||
11 | |||
12 | func checkIfTerminal(w io.Writer) bool { | ||
13 | switch v := w.(type) { | ||
14 | case *os.File: | ||
15 | handle := windows.Handle(v.Fd()) | ||
16 | var mode uint32 | ||
17 | if err := windows.GetConsoleMode(handle, &mode); err != nil { | ||
18 | return false | ||
19 | } | ||
20 | mode |= windows.ENABLE_VIRTUAL_TERMINAL_PROCESSING | ||
21 | if err := windows.SetConsoleMode(handle, mode); err != nil { | ||
22 | return false | ||
23 | } | ||
24 | return true | ||
25 | } | ||
26 | return false | ||
27 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/text_formatter.go b/vendor/github.com/sirupsen/logrus/text_formatter.go new file mode 100644 index 0000000..be2c6ef --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/text_formatter.go | |||
@@ -0,0 +1,339 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "bytes" | ||
5 | "fmt" | ||
6 | "os" | ||
7 | "runtime" | ||
8 | "sort" | ||
9 | "strconv" | ||
10 | "strings" | ||
11 | "sync" | ||
12 | "time" | ||
13 | "unicode/utf8" | ||
14 | ) | ||
15 | |||
16 | const ( | ||
17 | red = 31 | ||
18 | yellow = 33 | ||
19 | blue = 36 | ||
20 | gray = 37 | ||
21 | ) | ||
22 | |||
23 | var baseTimestamp time.Time | ||
24 | |||
25 | func init() { | ||
26 | baseTimestamp = time.Now() | ||
27 | } | ||
28 | |||
29 | // TextFormatter formats logs into text | ||
30 | type TextFormatter struct { | ||
31 | // Set to true to bypass checking for a TTY before outputting colors. | ||
32 | ForceColors bool | ||
33 | |||
34 | // Force disabling colors. | ||
35 | DisableColors bool | ||
36 | |||
37 | // Force quoting of all values | ||
38 | ForceQuote bool | ||
39 | |||
40 | // DisableQuote disables quoting for all values. | ||
41 | // DisableQuote will have a lower priority than ForceQuote. | ||
42 | // If both of them are set to true, quote will be forced on all values. | ||
43 | DisableQuote bool | ||
44 | |||
45 | // Override coloring based on CLICOLOR and CLICOLOR_FORCE. - https://bixense.com/clicolors/ | ||
46 | EnvironmentOverrideColors bool | ||
47 | |||
48 | // Disable timestamp logging. useful when output is redirected to logging | ||
49 | // system that already adds timestamps. | ||
50 | DisableTimestamp bool | ||
51 | |||
52 | // Enable logging the full timestamp when a TTY is attached instead of just | ||
53 | // the time passed since beginning of execution. | ||
54 | FullTimestamp bool | ||
55 | |||
56 | // TimestampFormat to use for display when a full timestamp is printed. | ||
57 | // The format to use is the same than for time.Format or time.Parse from the standard | ||
58 | // library. | ||
59 | // The standard Library already provides a set of predefined format. | ||
60 | TimestampFormat string | ||
61 | |||
62 | // The fields are sorted by default for a consistent output. For applications | ||
63 | // that log extremely frequently and don't use the JSON formatter this may not | ||
64 | // be desired. | ||
65 | DisableSorting bool | ||
66 | |||
67 | // The keys sorting function, when uninitialized it uses sort.Strings. | ||
68 | SortingFunc func([]string) | ||
69 | |||
70 | // Disables the truncation of the level text to 4 characters. | ||
71 | DisableLevelTruncation bool | ||
72 | |||
73 | // PadLevelText Adds padding the level text so that all the levels output at the same length | ||
74 | // PadLevelText is a superset of the DisableLevelTruncation option | ||
75 | PadLevelText bool | ||
76 | |||
77 | // QuoteEmptyFields will wrap empty fields in quotes if true | ||
78 | QuoteEmptyFields bool | ||
79 | |||
80 | // Whether the logger's out is to a terminal | ||
81 | isTerminal bool | ||
82 | |||
83 | // FieldMap allows users to customize the names of keys for default fields. | ||
84 | // As an example: | ||
85 | // formatter := &TextFormatter{ | ||
86 | // FieldMap: FieldMap{ | ||
87 | // FieldKeyTime: "@timestamp", | ||
88 | // FieldKeyLevel: "@level", | ||
89 | // FieldKeyMsg: "@message"}} | ||
90 | FieldMap FieldMap | ||
91 | |||
92 | // CallerPrettyfier can be set by the user to modify the content | ||
93 | // of the function and file keys in the data when ReportCaller is | ||
94 | // activated. If any of the returned value is the empty string the | ||
95 | // corresponding key will be removed from fields. | ||
96 | CallerPrettyfier func(*runtime.Frame) (function string, file string) | ||
97 | |||
98 | terminalInitOnce sync.Once | ||
99 | |||
100 | // The max length of the level text, generated dynamically on init | ||
101 | levelTextMaxLength int | ||
102 | } | ||
103 | |||
104 | func (f *TextFormatter) init(entry *Entry) { | ||
105 | if entry.Logger != nil { | ||
106 | f.isTerminal = checkIfTerminal(entry.Logger.Out) | ||
107 | } | ||
108 | // Get the max length of the level text | ||
109 | for _, level := range AllLevels { | ||
110 | levelTextLength := utf8.RuneCount([]byte(level.String())) | ||
111 | if levelTextLength > f.levelTextMaxLength { | ||
112 | f.levelTextMaxLength = levelTextLength | ||
113 | } | ||
114 | } | ||
115 | } | ||
116 | |||
117 | func (f *TextFormatter) isColored() bool { | ||
118 | isColored := f.ForceColors || (f.isTerminal && (runtime.GOOS != "windows")) | ||
119 | |||
120 | if f.EnvironmentOverrideColors { | ||
121 | switch force, ok := os.LookupEnv("CLICOLOR_FORCE"); { | ||
122 | case ok && force != "0": | ||
123 | isColored = true | ||
124 | case ok && force == "0", os.Getenv("CLICOLOR") == "0": | ||
125 | isColored = false | ||
126 | } | ||
127 | } | ||
128 | |||
129 | return isColored && !f.DisableColors | ||
130 | } | ||
131 | |||
132 | // Format renders a single log entry | ||
133 | func (f *TextFormatter) Format(entry *Entry) ([]byte, error) { | ||
134 | data := make(Fields) | ||
135 | for k, v := range entry.Data { | ||
136 | data[k] = v | ||
137 | } | ||
138 | prefixFieldClashes(data, f.FieldMap, entry.HasCaller()) | ||
139 | keys := make([]string, 0, len(data)) | ||
140 | for k := range data { | ||
141 | keys = append(keys, k) | ||
142 | } | ||
143 | |||
144 | var funcVal, fileVal string | ||
145 | |||
146 | fixedKeys := make([]string, 0, 4+len(data)) | ||
147 | if !f.DisableTimestamp { | ||
148 | fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyTime)) | ||
149 | } | ||
150 | fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyLevel)) | ||
151 | if entry.Message != "" { | ||
152 | fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyMsg)) | ||
153 | } | ||
154 | if entry.err != "" { | ||
155 | fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyLogrusError)) | ||
156 | } | ||
157 | if entry.HasCaller() { | ||
158 | if f.CallerPrettyfier != nil { | ||
159 | funcVal, fileVal = f.CallerPrettyfier(entry.Caller) | ||
160 | } else { | ||
161 | funcVal = entry.Caller.Function | ||
162 | fileVal = fmt.Sprintf("%s:%d", entry.Caller.File, entry.Caller.Line) | ||
163 | } | ||
164 | |||
165 | if funcVal != "" { | ||
166 | fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyFunc)) | ||
167 | } | ||
168 | if fileVal != "" { | ||
169 | fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyFile)) | ||
170 | } | ||
171 | } | ||
172 | |||
173 | if !f.DisableSorting { | ||
174 | if f.SortingFunc == nil { | ||
175 | sort.Strings(keys) | ||
176 | fixedKeys = append(fixedKeys, keys...) | ||
177 | } else { | ||
178 | if !f.isColored() { | ||
179 | fixedKeys = append(fixedKeys, keys...) | ||
180 | f.SortingFunc(fixedKeys) | ||
181 | } else { | ||
182 | f.SortingFunc(keys) | ||
183 | } | ||
184 | } | ||
185 | } else { | ||
186 | fixedKeys = append(fixedKeys, keys...) | ||
187 | } | ||
188 | |||
189 | var b *bytes.Buffer | ||
190 | if entry.Buffer != nil { | ||
191 | b = entry.Buffer | ||
192 | } else { | ||
193 | b = &bytes.Buffer{} | ||
194 | } | ||
195 | |||
196 | f.terminalInitOnce.Do(func() { f.init(entry) }) | ||
197 | |||
198 | timestampFormat := f.TimestampFormat | ||
199 | if timestampFormat == "" { | ||
200 | timestampFormat = defaultTimestampFormat | ||
201 | } | ||
202 | if f.isColored() { | ||
203 | f.printColored(b, entry, keys, data, timestampFormat) | ||
204 | } else { | ||
205 | |||
206 | for _, key := range fixedKeys { | ||
207 | var value interface{} | ||
208 | switch { | ||
209 | case key == f.FieldMap.resolve(FieldKeyTime): | ||
210 | value = entry.Time.Format(timestampFormat) | ||
211 | case key == f.FieldMap.resolve(FieldKeyLevel): | ||
212 | value = entry.Level.String() | ||
213 | case key == f.FieldMap.resolve(FieldKeyMsg): | ||
214 | value = entry.Message | ||
215 | case key == f.FieldMap.resolve(FieldKeyLogrusError): | ||
216 | value = entry.err | ||
217 | case key == f.FieldMap.resolve(FieldKeyFunc) && entry.HasCaller(): | ||
218 | value = funcVal | ||
219 | case key == f.FieldMap.resolve(FieldKeyFile) && entry.HasCaller(): | ||
220 | value = fileVal | ||
221 | default: | ||
222 | value = data[key] | ||
223 | } | ||
224 | f.appendKeyValue(b, key, value) | ||
225 | } | ||
226 | } | ||
227 | |||
228 | b.WriteByte('\n') | ||
229 | return b.Bytes(), nil | ||
230 | } | ||
231 | |||
232 | func (f *TextFormatter) printColored(b *bytes.Buffer, entry *Entry, keys []string, data Fields, timestampFormat string) { | ||
233 | var levelColor int | ||
234 | switch entry.Level { | ||
235 | case DebugLevel, TraceLevel: | ||
236 | levelColor = gray | ||
237 | case WarnLevel: | ||
238 | levelColor = yellow | ||
239 | case ErrorLevel, FatalLevel, PanicLevel: | ||
240 | levelColor = red | ||
241 | case InfoLevel: | ||
242 | levelColor = blue | ||
243 | default: | ||
244 | levelColor = blue | ||
245 | } | ||
246 | |||
247 | levelText := strings.ToUpper(entry.Level.String()) | ||
248 | if !f.DisableLevelTruncation && !f.PadLevelText { | ||
249 | levelText = levelText[0:4] | ||
250 | } | ||
251 | if f.PadLevelText { | ||
252 | // Generates the format string used in the next line, for example "%-6s" or "%-7s". | ||
253 | // Based on the max level text length. | ||
254 | formatString := "%-" + strconv.Itoa(f.levelTextMaxLength) + "s" | ||
255 | // Formats the level text by appending spaces up to the max length, for example: | ||
256 | // - "INFO " | ||
257 | // - "WARNING" | ||
258 | levelText = fmt.Sprintf(formatString, levelText) | ||
259 | } | ||
260 | |||
261 | // Remove a single newline if it already exists in the message to keep | ||
262 | // the behavior of logrus text_formatter the same as the stdlib log package | ||
263 | entry.Message = strings.TrimSuffix(entry.Message, "\n") | ||
264 | |||
265 | caller := "" | ||
266 | if entry.HasCaller() { | ||
267 | funcVal := fmt.Sprintf("%s()", entry.Caller.Function) | ||
268 | fileVal := fmt.Sprintf("%s:%d", entry.Caller.File, entry.Caller.Line) | ||
269 | |||
270 | if f.CallerPrettyfier != nil { | ||
271 | funcVal, fileVal = f.CallerPrettyfier(entry.Caller) | ||
272 | } | ||
273 | |||
274 | if fileVal == "" { | ||
275 | caller = funcVal | ||
276 | } else if funcVal == "" { | ||
277 | caller = fileVal | ||
278 | } else { | ||
279 | caller = fileVal + " " + funcVal | ||
280 | } | ||
281 | } | ||
282 | |||
283 | switch { | ||
284 | case f.DisableTimestamp: | ||
285 | fmt.Fprintf(b, "\x1b[%dm%s\x1b[0m%s %-44s ", levelColor, levelText, caller, entry.Message) | ||
286 | case !f.FullTimestamp: | ||
287 | fmt.Fprintf(b, "\x1b[%dm%s\x1b[0m[%04d]%s %-44s ", levelColor, levelText, int(entry.Time.Sub(baseTimestamp)/time.Second), caller, entry.Message) | ||
288 | default: | ||
289 | fmt.Fprintf(b, "\x1b[%dm%s\x1b[0m[%s]%s %-44s ", levelColor, levelText, entry.Time.Format(timestampFormat), caller, entry.Message) | ||
290 | } | ||
291 | for _, k := range keys { | ||
292 | v := data[k] | ||
293 | fmt.Fprintf(b, " \x1b[%dm%s\x1b[0m=", levelColor, k) | ||
294 | f.appendValue(b, v) | ||
295 | } | ||
296 | } | ||
297 | |||
298 | func (f *TextFormatter) needsQuoting(text string) bool { | ||
299 | if f.ForceQuote { | ||
300 | return true | ||
301 | } | ||
302 | if f.QuoteEmptyFields && len(text) == 0 { | ||
303 | return true | ||
304 | } | ||
305 | if f.DisableQuote { | ||
306 | return false | ||
307 | } | ||
308 | for _, ch := range text { | ||
309 | if !((ch >= 'a' && ch <= 'z') || | ||
310 | (ch >= 'A' && ch <= 'Z') || | ||
311 | (ch >= '0' && ch <= '9') || | ||
312 | ch == '-' || ch == '.' || ch == '_' || ch == '/' || ch == '@' || ch == '^' || ch == '+') { | ||
313 | return true | ||
314 | } | ||
315 | } | ||
316 | return false | ||
317 | } | ||
318 | |||
319 | func (f *TextFormatter) appendKeyValue(b *bytes.Buffer, key string, value interface{}) { | ||
320 | if b.Len() > 0 { | ||
321 | b.WriteByte(' ') | ||
322 | } | ||
323 | b.WriteString(key) | ||
324 | b.WriteByte('=') | ||
325 | f.appendValue(b, value) | ||
326 | } | ||
327 | |||
328 | func (f *TextFormatter) appendValue(b *bytes.Buffer, value interface{}) { | ||
329 | stringVal, ok := value.(string) | ||
330 | if !ok { | ||
331 | stringVal = fmt.Sprint(value) | ||
332 | } | ||
333 | |||
334 | if !f.needsQuoting(stringVal) { | ||
335 | b.WriteString(stringVal) | ||
336 | } else { | ||
337 | b.WriteString(fmt.Sprintf("%q", stringVal)) | ||
338 | } | ||
339 | } | ||
diff --git a/vendor/github.com/sirupsen/logrus/writer.go b/vendor/github.com/sirupsen/logrus/writer.go new file mode 100644 index 0000000..074fd4b --- /dev/null +++ b/vendor/github.com/sirupsen/logrus/writer.go | |||
@@ -0,0 +1,102 @@ | |||
1 | package logrus | ||
2 | |||
3 | import ( | ||
4 | "bufio" | ||
5 | "io" | ||
6 | "runtime" | ||
7 | "strings" | ||
8 | ) | ||
9 | |||
10 | // Writer at INFO level. See WriterLevel for details. | ||
11 | func (logger *Logger) Writer() *io.PipeWriter { | ||
12 | return logger.WriterLevel(InfoLevel) | ||
13 | } | ||
14 | |||
15 | // WriterLevel returns an io.Writer that can be used to write arbitrary text to | ||
16 | // the logger at the given log level. Each line written to the writer will be | ||
17 | // printed in the usual way using formatters and hooks. The writer is part of an | ||
18 | // io.Pipe and it is the callers responsibility to close the writer when done. | ||
19 | // This can be used to override the standard library logger easily. | ||
20 | func (logger *Logger) WriterLevel(level Level) *io.PipeWriter { | ||
21 | return NewEntry(logger).WriterLevel(level) | ||
22 | } | ||
23 | |||
24 | // Writer returns an io.Writer that writes to the logger at the info log level | ||
25 | func (entry *Entry) Writer() *io.PipeWriter { | ||
26 | return entry.WriterLevel(InfoLevel) | ||
27 | } | ||
28 | |||
29 | // WriterLevel returns an io.Writer that writes to the logger at the given log level | ||
30 | func (entry *Entry) WriterLevel(level Level) *io.PipeWriter { | ||
31 | reader, writer := io.Pipe() | ||
32 | |||
33 | var printFunc func(args ...interface{}) | ||
34 | |||
35 | // Determine which log function to use based on the specified log level | ||
36 | switch level { | ||
37 | case TraceLevel: | ||
38 | printFunc = entry.Trace | ||
39 | case DebugLevel: | ||
40 | printFunc = entry.Debug | ||
41 | case InfoLevel: | ||
42 | printFunc = entry.Info | ||
43 | case WarnLevel: | ||
44 | printFunc = entry.Warn | ||
45 | case ErrorLevel: | ||
46 | printFunc = entry.Error | ||
47 | case FatalLevel: | ||
48 | printFunc = entry.Fatal | ||
49 | case PanicLevel: | ||
50 | printFunc = entry.Panic | ||
51 | default: | ||
52 | printFunc = entry.Print | ||
53 | } | ||
54 | |||
55 | // Start a new goroutine to scan the input and write it to the logger using the specified print function. | ||
56 | // It splits the input into chunks of up to 64KB to avoid buffer overflows. | ||
57 | go entry.writerScanner(reader, printFunc) | ||
58 | |||
59 | // Set a finalizer function to close the writer when it is garbage collected | ||
60 | runtime.SetFinalizer(writer, writerFinalizer) | ||
61 | |||
62 | return writer | ||
63 | } | ||
64 | |||
65 | // writerScanner scans the input from the reader and writes it to the logger | ||
66 | func (entry *Entry) writerScanner(reader *io.PipeReader, printFunc func(args ...interface{})) { | ||
67 | scanner := bufio.NewScanner(reader) | ||
68 | |||
69 | // Set the buffer size to the maximum token size to avoid buffer overflows | ||
70 | scanner.Buffer(make([]byte, bufio.MaxScanTokenSize), bufio.MaxScanTokenSize) | ||
71 | |||
72 | // Define a split function to split the input into chunks of up to 64KB | ||
73 | chunkSize := bufio.MaxScanTokenSize // 64KB | ||
74 | splitFunc := func(data []byte, atEOF bool) (int, []byte, error) { | ||
75 | if len(data) >= chunkSize { | ||
76 | return chunkSize, data[:chunkSize], nil | ||
77 | } | ||
78 | |||
79 | return bufio.ScanLines(data, atEOF) | ||
80 | } | ||
81 | |||
82 | // Use the custom split function to split the input | ||
83 | scanner.Split(splitFunc) | ||
84 | |||
85 | // Scan the input and write it to the logger using the specified print function | ||
86 | for scanner.Scan() { | ||
87 | printFunc(strings.TrimRight(scanner.Text(), "\r\n")) | ||
88 | } | ||
89 | |||
90 | // If there was an error while scanning the input, log an error | ||
91 | if err := scanner.Err(); err != nil { | ||
92 | entry.Errorf("Error while reading from Writer: %s", err) | ||
93 | } | ||
94 | |||
95 | // Close the reader when we are done | ||
96 | reader.Close() | ||
97 | } | ||
98 | |||
99 | // WriterFinalizer is a finalizer function that closes then given writer when it is garbage collected | ||
100 | func writerFinalizer(writer *io.PipeWriter) { | ||
101 | writer.Close() | ||
102 | } | ||