Categorygithub.com/adirelle/bilies-go
modulepackage
0.0.0-20160912075331-616b2ab523b2
Repository: https://github.com/adirelle/bilies-go.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
30
Dependents
0
Files
1.3k SLOC

# README

bilies-go

Bulk Insert Logs Into ElasticSearch - in Go

Build Status GoDoc

bilibes-go is designed to bulk-insert log entry into ElasticSearch.

It waits for JSON-encoded log entries on standard input, one per line, stores them in a disk-based queue, then send batchs using the bulk API of ElasticSearch.

Installation

go get github.com/Adirelle/bilies-go

Documentation

Documentation is available on Godoc.

License

See the LICENSE file.

# Functions

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
BackoffDelay calculates a backoff delay, given a number of consecutive failures.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
LineReader reads lines from input on demand.
No description provided by the author
MetricDumper dumps the metrics when receiving SIGUSR1 and on exit (in debug mode).
NewAsyncWriter creates a new asynchronous writter for the specified writer.
NewBackendURLPool creates a new backend pool for the given hosts.
No description provided by the author
NewReopenableWriter creates a writer that reopen on SIGHUP signal.
No description provided by the author
No description provided by the author
No description provided by the author
RecordParser requests Line from LineReader, converts them to InputRecords, and send them to the RecordQueuer.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
StartLogging setups logging and starts the asynchronous logger.
SetupPidFile creates the PID file and writes the current PID into it.
Shutdown initiates a shutdown and waits for all goroutines to finish.
SignalHandler initiates a shutdown when SIGINT or SIGTERM is received.
Start starts f as a goroutine, and registers it in the starting and ending groups.
No description provided by the author
No description provided by the author

# Structs

AsyncWriter is an empty struct that implements io.Writer.
BackendURL is a string containing the URL of a backend.
BackendURLPool manages a collection of backend URLs.
BaseMetricFormatter is a formatter with an unit.
No description provided by the author
IndexedBuffer is a bytes.Buffer that also holds an index and a map to identify records.
No description provided by the author
ReopenableWriter is a file writer that reopen its file on SIGHUP.
ScaledMetricFormatter is a formatter with an unit and scale prefixes.
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author
No description provided by the author
Formatter for metric values.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author