1 files changed, 112 insertions, 0 deletions
diff --git a/vendor/gopkg.in/clog.v1/console.go b/vendor/gopkg.in/clog.v1/console.go
new file mode 100644
index 00000000..0f9b7333
--- /dev/null
+++ b/vendor/gopkg.in/clog.v1/console.go
@@ -0,0 +1,112 @@
+// Copyright 2017 Unknwon
+//
+// Licensed under the Apache License, Version 2.0 (the "License"): you may
+// not use this file except in compliance with the License. You may obtain
+// a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+// License for the specific language governing permissions and limitations
+// under the License.
+
+package clog
+
+import (
+	"log"
+
+	"github.com/fatih/color"
+)
+
+const CONSOLE MODE = "console"
+
+// Console color set for different levels.
+var consoleColors = []func(a ...interface{}) string{
+	color.New(color.FgBlue).SprintFunc(),   // Trace
+	color.New(color.FgGreen).SprintFunc(),  // Info
+	color.New(color.FgYellow).SprintFunc(), // Warn
+	color.New(color.FgRed).SprintFunc(),    // Error
+	color.New(color.FgHiRed).SprintFunc(),  // Fatal
+}
+
+type ConsoleConfig struct {
+	// Minimum level of messages to be processed.
+	Level LEVEL
+	// Buffer size defines how many messages can be queued before hangs.
+	BufferSize int64
+}
+
+type console struct {
+	*log.Logger
+	Adapter
+}
+
+func newConsole() Logger {
+	return &console{
+		Logger: log.New(color.Output, "", log.Ldate|log.Ltime),
+		Adapter: Adapter{
+			quitChan: make(chan struct{}),
+		},
+	}
+}
+
+func (c *console) Level() LEVEL { return c.level }
+
+func (c *console) Init(v interface{}) error {
+	cfg, ok := v.(ConsoleConfig)
+	if !ok {
+		return ErrConfigObject{"ConsoleConfig", v}
+	}
+
+	if !isValidLevel(cfg.Level) {
+		return ErrInvalidLevel{}
+	}
+	c.level = cfg.Level
+
+	c.msgChan = make(chan *Message, cfg.BufferSize)
+	return nil
+}
+
+func (c *console) ExchangeChans(errorChan chan<- error) chan *Message {
+	c.errorChan = errorChan
+	return c.msgChan
+}
+
+func (c *console) write(msg *Message) {
+	c.Logger.Print(consoleColors[msg.Level](msg.Body))
+}
+
+func (c *console) Start() {
+LOOP:
+	for {
+		select {
+		case msg := <-c.msgChan:
+			c.write(msg)
+		case <-c.quitChan:
+			break LOOP
+		}
+	}
+
+	for {
+		if len(c.msgChan) == 0 {
+			break
+		}
+
+		c.write(<-c.msgChan)
+	}
+	c.quitChan <- struct{}{} // Notify the cleanup is done.
+}
+
+func (c *console) Destroy() {
+	c.quitChan <- struct{}{}
+	<-c.quitChan
+
+	close(c.msgChan)
+	close(c.quitChan)
+}
+
+func init() {
+	Register(CONSOLE, newConsole)
+}