logzio

README

Logzio Golang API client

Sends logs to logz.io over HTTP. It is a low level lib that can to be integrated with other logging libs.

[![GoDoc][doc-img]][doc] [![Build Status][ci-img]][ci] [![Coverage Status][cov-img]][cov] [![Go Report][report-img]][report]

Prerequisites

go 1.x

Installation

$ go get -u github.com/logzio/logzio-go

Quick Start

package main

import (
  "fmt"
  "github.com/logzio/logzio-go"
  "os"
  "time"
)

func main() {
  l, err := logzio.New(
  		"fake-token",
  		SetDebug(os.Stderr),
  		SetUrl("http://localhost:12345"),
  		SetDrainDuration(time.Minute*10),
        SetSetTempDirectory("myQueue"),
        SetDrainDiskThreshold(99)
  	) // token is required
  if err != nil {
    panic(err)
  }
  msg := fmt.Sprintf("{ \"%s\": \"%s\"}", "message", time.Now().UnixNano())

  err = l.Send([]byte(msg))
  if err != nil {
     panic(err)
  }

  l.Stop() //logs are buffered on disk. Stop will drain the buffer
}

Usage

• Set url mode: logzio.New(token, SetUrl(ts.URL))

• Set drain duration (flush logs on disk): logzio.New(token, SetDrainDuration(time.Hour))

• Set debug mode: logzio.New(token, SetDebug(os.Stderr))

• Set queue dir: logzio.New(token, SetSetTempDirectory(os.Stderr))

• Set the sender to check if it crosses the maximum allowed disk usage: logzio.New(token, SetCheckDiskSpace(true))

• Set disk queue threshold, once the threshold is crossed the sender will not enqueue the received logs: logzio.New(token, SetDrainDiskThreshold(99))

Disk queue

Logzio go client uses goleveldb and goqueue as a persistent storage. Every 5 seconds logs are sent to logz.io (if any are available)

Tests

$ go test -v

See travis.yaml for running benchmark tests

Contributing

All PRs are welcome

Authors

• Douglas Chimento - [dougEfresh][me]
• Ido Halevi - idohalevi

License

This project is licensed under the Apache License - see the LICENSE file for details

Acknowledgments

• logzio-java-sender

Documentation

Index

• type LogzioSender
  • func New(token string, options ...SenderOptionFunc) (*LogzioSender, error)
  • func (l *LogzioSender) CloseIdleConnections()
  • func (l *LogzioSender) Drain()
  • func (l *LogzioSender) Send(payload []byte) error
  • func (l *LogzioSender) Stop()
  • func (l *LogzioSender) Sync() error
  • func (l *LogzioSender) Write(p []byte) (n int, err error)
• type Sender
• type SenderOptionFunc
  • func SetCheckDiskSpace(check bool) SenderOptionFunc
  • func SetDebug(debug io.Writer) SenderOptionFunc
  • func SetDrainDiskThreshold(th int) SenderOptionFunc
  • func SetDrainDuration(duration time.Duration) SenderOptionFunc
  • func SetTempDirectory(dir string) SenderOptionFunc
  • func SetUrl(url string) SenderOptionFunc

Types

type LogzioSender

type LogzioSender struct {
	// contains filtered or unexported fields
}

LogzioSender instance of the

func New

func New(token string, options ...SenderOptionFunc) (*LogzioSender, error)

New creates a new Logzio sender with a token and options

func (*LogzioSender) CloseIdleConnections

func (l *LogzioSender) CloseIdleConnections()

CloseIdleConnections to close all remaining open connections

func (*LogzioSender) Drain

func (l *LogzioSender) Drain()

Drain - Send remaining logs

func (*LogzioSender) Send

func (l *LogzioSender) Send(payload []byte) error

Send the payload to logz.io

func (*LogzioSender) Stop

func (l *LogzioSender) Stop()

Stop will close the LevelDB queue and do a final drain

func (*LogzioSender) Sync

func (l *LogzioSender) Sync() error

Sync drains the queue

func (*LogzioSender) Write

func (l *LogzioSender) Write(p []byte) (n int, err error)

type Sender

type Sender LogzioSender

Sender Alias to LogzioSender

type SenderOptionFunc

type SenderOptionFunc func(*LogzioSender) error

SenderOptionFunc options for logz

func SetCheckDiskSpace

func SetCheckDiskSpace(check bool) SenderOptionFunc

SetCheckDiskSpace to check if it crosses the maximum allowed disk usage

func SetDebug

func SetDebug(debug io.Writer) SenderOptionFunc

SetDebug mode and send logs to this writer

func SetDrainDiskThreshold

func SetDrainDiskThreshold(th int) SenderOptionFunc

SetDrainDiskThreshold to change the maximum used disk space

func SetDrainDuration

func SetDrainDuration(duration time.Duration) SenderOptionFunc

SetDrainDuration to change the interval between drains

func SetTempDirectory

func SetTempDirectory(dir string) SenderOptionFunc

SetTempDirectory Use this temporary dir

func SetUrl

func SetUrl(url string) SenderOptionFunc

SetUrl set the url which maybe different from the defaultUrl