metrics

package
v0.0.0-...-df570b3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 12, 2018 License: MIT Imports: 6 Imported by: 23

Documentation

Overview

Package metrics defines a basic structure foundation for handling logs without much hassle, allow more different entries to be created. Inspired by https://medium.com/@tjholowaychuk/apex-log-e8d9627f4a9a.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrBatchEmitterClosed = errors.New("batcher already closed")
)

errors.

View Source
var NilPair = (*Pair)(nil)

NilPair defines a nil starting pair.

Functions

func Apply

func Apply(en *Entry, mods ...func(*Entry))

Apply runs all giving func(*Entry) functions provided on the provided Entry.

func Error

func Error(err error) func(*Entry)

Error returns a entry where the message is the provided error.Error() value and the error is added as a key-value within the Entry fields.

func Errorf

func Errorf(message string, m ...interface{}) func(*Entry)

Errorf returns a entry where the message is the provided error.Error() value produced from the message and its provided values and the error is added as a key-value within the Entry fields.

func Info

func Info(message string, m ...interface{}) func(*Entry)

Info returns an Entry with the level set to Info.

func Message

func Message(message string, m ...interface{}) func(*Entry)

Message returns a new Entry with the provided Level and message used.

func Partial

func Partial(mods ...func(*Entry)) func(*Entry)

Partial returns a new func(*Entry) which will always apply provided func(*Entry) to all provided Entry.

func RedAlert

func RedAlert(err error, message string, m ...interface{}) func(*Entry)

RedAlert returns an Entry with the level set to RedAlertLvl.

func Tags

func Tags(ts ...string) func(*Entry)

Tags returns an Entry with the tags value set to ts.

func Type

func Type(t string) func(*Entry)

Type returns an Entry with the type value set to t.

func With

func With(key string, value interface{}) func(*Entry)

With returns a Entry set to the LogLevel of the previous and adds the giving key-value pair to the entry.

func WithFields

func WithFields(f Field) func(*Entry)

WithFields adds all field key-value pair into associated Entry returning the Entry.

func WithFilter

func WithFilter(filter interface{}) func(*Entry)

WithFilter returns a Entry and set the Filter to the provided value.

func WithID

func WithID(id string) func(*Entry)

WithID returns a Entry and set the ID to the provided value.

func WithMessage

func WithMessage(level Level, message string, m ...interface{}) func(*Entry)

WithMessage returns a new Entry with the provided Level and message used.

func WithTimelapse

func WithTimelapse(message string, f Field) func(*Entry)

WithTimelapse returns a Timelapse with associated field and message.

func WithTrace

func WithTrace(t Trace) func(*Entry)

WithTrace returns itself after setting the giving trace value has the method trace for the giving Entry.

func YellowAlert

func YellowAlert(err error, message string, m ...interface{}) func(*Entry)

YellowAlert returns an Entry with the level set to YellowAlertLvl.

Types

type Collector

type Collector interface {
	Collect(string) Entry
}

Collector defines an interface which exposes a single method to collect internal data which is then returned as an Entry.

func Collect

func Collect(fn EntryEmitter) Collector

Collect returns a Collector which executes provided function when called by Metric to run.

type CommitFunction

type CommitFunction func([]Entry) error

CommitFunction defines a function type which is used to process a batch of Entry.

type ConditionalProcessors

type ConditionalProcessors interface {
	Processors
	Can(Entry) bool
}

ConditionalProcessors defines a Processor which first validate it's ability to process a giving Entry.

func Case

func Case(fn FilterFn, procs ...Processors) ConditionalProcessors

Case returns a Processor object with the provided Augmenters and Metrics implemement objects for receiving metric Entries, where entries are filtered out based on a provided function.

type DoFn

type DoFn func(Entry) error

DoFn defines a function type which takes a giving Entry.

type Entry

type Entry struct {
	ID        string      `json:"id"`
	Function  string      `json:"function"`
	File      string      `json:"file"`
	Type      string      `json:"type"`
	Line      int         `json:"line"`
	Level     Level       `json:"level"`
	Field     Field       `json:"fields"`
	Time      time.Time   `json:"time"`
	Message   string      `json:"message"`
	Filter    interface{} `json:"filter"`
	Tags      []string    `json:"tags"`
	Trace     Trace       `json:"trace"`
	Timelapse []Timelapse `json:"timelapse"`
}

Entry represent a giving record of data at a giving period of time.

type EntryEmitter

type EntryEmitter func(string) Entry

EntryEmitter defines a type which returns a entry when runned.

type Field

type Field map[string]interface{}

Field represents a giving map of values associated with a giving field value.

func (Field) Get

func (p Field) Get(key string) (value interface{}, found bool)

Get collects the value of a key if it exists.

func (Field) GetBool

func (p Field) GetBool(key string) (bool, bool)

GetBool collects the string value of a key if it exists.

func (Field) GetFloat32

func (p Field) GetFloat32(key string) (float32, bool)

GetFloat32 collects the string value of a key if it exists.

func (Field) GetFloat64

func (p Field) GetFloat64(key string) (float64, bool)

GetFloat64 collects the string value of a key if it exists.

func (Field) GetInt

func (p Field) GetInt(key string) (int, bool)

GetInt collects the string value of a key if it exists.

func (Field) GetInt16

func (p Field) GetInt16(key string) (int16, bool)

GetInt16 collects the string value of a key if it exists.

func (Field) GetInt32

func (p Field) GetInt32(key string) (int32, bool)

GetInt32 collects the string value of a key if it exists.

func (Field) GetInt64

func (p Field) GetInt64(key string) (int64, bool)

GetInt64 collects the string value of a key if it exists.

func (Field) GetInt8

func (p Field) GetInt8(key string) (int8, bool)

GetInt8 collects the string value of a key if it exists.

func (Field) GetString

func (p Field) GetString(key string) (string, bool)

GetString collects the string value of a key if it exists.

type FilterFn

type FilterFn func(Entry) bool

FilterFn defines a function type which takes a giving Entry returning a bool to indicate filtering state.

type Level

type Level int

Level defines a int type which represent the a giving level of entry for a giving entry.

const (
	RedAlertLvl    Level = iota // Immediately notify everyone by mail level, because this is bad
	YellowAlertLvl              // Immediately notify everyone but we can wait to tomorrow
	ErrorLvl                    // Error occured with some code due to normal opperation or odd behaviour (not critical)
	InfoLvl                     // Information for view about code operation (replaces Debug, Notice, Trace).
)

level constants

func GetLevel

func GetLevel(lvl string) Level

GetLevel returns Level value for the giving string. It returns -1 if it does not know the level string.

func (Level) String

func (l Level) String() string

String returns the string version of the Level.

type MetricConsumer

type MetricConsumer interface {
	Processors
	Run(<-chan struct{})
}

MetricConsumer exposes a interface which allows the consumption of Entries into a underline system, which can be started through it's run method.

func BatchConsumer

func BatchConsumer(maxSize int, maxwait time.Duration, fn CommitFunction) MetricConsumer

BatchConsumer returns a new instance of a batchConsumer.

type Metrics

type Metrics interface {
	Send(Entry) error
	Emit(...func(*Entry)) error
	CollectMetrics(string) error
}

Metrics defines an interface with a single method for receiving new Entry objects.

func New

func New(vals ...interface{}) Metrics

New returns a Metrics object with the provided Augmenters and Metrics implemement objects for receiving metric Entries.

type Pair

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

Pair defines a struct for storing a linked pair of key and values.

func Append

func Append(p *Pair, key string, value interface{}) *Pair

Append returns a new Pair with the giving key and with the provded Pair set as it's previous link.

func NewPair

func NewPair(key string, value interface{}) *Pair

NewPair returns a a key-value pair chain for setting fields.

func (*Pair) Append

func (p *Pair) Append(key string, val interface{}) *Pair

Append returns a new pair with the giving key and value and its previous set to this pair.

func (*Pair) Fields

func (p *Pair) Fields() Field

Fields returns all internal pair data as a map.

func (*Pair) Get

func (p *Pair) Get(key string) (value interface{}, found bool)

Get collects the value of a key if it exists.

func (*Pair) GetBool

func (p *Pair) GetBool(key string) (bool, bool)

GetBool collects the string value of a key if it exists.

func (*Pair) GetFloat32

func (p *Pair) GetFloat32(key string) (float32, bool)

GetFloat32 collects the string value of a key if it exists.

func (*Pair) GetFloat64

func (p *Pair) GetFloat64(key string) (float64, bool)

GetFloat64 collects the string value of a key if it exists.

func (*Pair) GetInt

func (p *Pair) GetInt(key string) (int, bool)

GetInt collects the string value of a key if it exists.

func (*Pair) GetInt16

func (p *Pair) GetInt16(key string) (int16, bool)

GetInt16 collects the string value of a key if it exists.

func (*Pair) GetInt32

func (p *Pair) GetInt32(key string) (int32, bool)

GetInt32 collects the string value of a key if it exists.

func (*Pair) GetInt64

func (p *Pair) GetInt64(key string) (int64, bool)

GetInt64 collects the string value of a key if it exists.

func (*Pair) GetInt8

func (p *Pair) GetInt8(key string) (int8, bool)

GetInt8 collects the string value of a key if it exists.

func (*Pair) GetString

func (p *Pair) GetString(key string) (string, bool)

GetString collects the string value of a key if it exists.

func (*Pair) Root

func (p *Pair) Root() *Pair

Root returns the root Pair in the chain which links all pairs together.

type Processors

type Processors interface {
	Handle(Entry) error
}

Processors implements a single method to process a Entry.

func DoWith

func DoWith(do DoFn) Processors

DoWith returns a Metrics object where all entries are applied to the provided function.

func FilterLevel

func FilterLevel(l Level, procs ...Processors) Processors

FilterLevel will return a metrics where all Entry will be filtered by their Entry.Level if the level giving is greater or equal to the provided, then it will be received by the metrics subscribers.

func Switch

func Switch(conditions ...ConditionalProcessors) Processors

Switch returns a new instance of a SwitchMaster.

type Timelapse

type Timelapse struct {
	Message string    `json:"message"`
	Time    time.Time `json:"time"`
	Field   Field     `json:"fields"`
}

Timelapse defines a message attached with a giving time value.

type Trace

type Trace struct {
	File       string    `json:"file"`
	Package    string    `json:"Package"`
	Function   string    `json:"function"`
	LineNumber int       `json:"line_number"`
	Stack      []byte    `json:"stack"`
	Comments   []string  `json:"comments"`
	Time       time.Time `json:"end_time"`
}

Trace defines a structure which contains the stack, start and endtime on a given from a trace call to trace a given call with stack details and execution time.

func NewTrace

func NewTrace(comments ...string) Trace

NewTrace returns a Trace object which is used to track the execution and stack details of a given trace call.

func NewTraceWithCallDepth

func NewTraceWithCallDepth(depth int, comments ...string) Trace

NewTraceWithCallDepth returns a Trace object which is used to track the execution and stack details of a given trace call.

func (Trace) String

func (t Trace) String() string

String returns the giving trace timestamp for the execution time.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL