event

Documentation

Index

• func Event(e *event.Event)
• func EventErrorPipeline(name string, msg string)
• func EventInfoPipeline(name string, msg string)
• func Init()
• type Recorder
  • func New() (*Recorder, error)
  • func (r Recorder) Event(e *event.Event)
  • func (r Recorder) Loop(ctx context.Context)

Functions

func Event

func Event(e *event.Event)

Event client call this function to record a event

func EventErrorPipeline

func EventErrorPipeline(name string, msg string)

EventErrorPipeline record a pipeline error event

func EventInfoPipeline

func EventInfoPipeline(name string, msg string)

EventInfoPipeline record a pipeline info event

func Init

func Init()

Init generate a recorder for global use

Types

type Recorder

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

Recorder record event. Aggregate events and delete old events regularly

var DefaultRecorder *Recorder

DefaultRecorder global default event recorder

func New

func New() (*Recorder, error)

New Returns a new Recorder

func (Recorder) Event

func (r Recorder) Event(e *event.Event)

Event pass event to income chan

func (Recorder) Loop

func (r Recorder) Loop(ctx context.Context)

Loop start event record loop