@@ -0,0 +92,4 @@
+	}
+}
+
+func processMissedMessages(batch *[]*logEntry) {

@@ -0,0 +62,4 @@
+				batch = append(batch, entry)
+			}
+			batch = processMissedMessages(batch)
+			processBatch(batch)

@@ -0,0 +16,4 @@
+	encoder     zapcore.Encoder
+}
+
+func New(original zapcore.Core, call func(msg string, logTime time.Time) error, enabledCall func() bool) *LokiCore {

@@ -0,0 +7,4 @@
+
+// If the client is disabled, it does nothing.
+// If the entries channel is full, the message is discarded.
+func Send(msg string, timestamp time.Time) error {

@@ -0,0 +88,4 @@
+func processBatch(batch []*logEntry) []*logEntry {
+	if len(batch) > 0 {
+		sendLogs(batch)
+		batch = batch[:0]

@@ -0,0 +1,67 @@
+package loki

@@ -0,0 +7,4 @@
+	"time"
+)
+
+const LogEntriesChanSize = 5000

@@ -0,0 +8,4 @@
+)
+
+const LogEntriesChanSize = 5000
+const Path string = "/api/prom/push"

@@ -0,0 +5,4 @@
+	"time"
+)
+
+// If the client is disabled, it does nothing.

@@ -0,0 +43,4 @@
+	// E.g. localhost:3100/api/prom/push.
+	Endpoint string
+	Labels   map[string]string
+	//Maximum message buffering time.