fanout

Documentation

Index

• type Emitter
  • func NewEmitter(emitters ...core.Emitter) *Emitter
  • func (e *Emitter) Emit(entry *entry.Entry)
  • func (e *Emitter) Init() error

Types

type Emitter

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

Emitter broadcasts log entries to multiple emitters

func NewEmitter

func NewEmitter(emitters ...core.Emitter) *Emitter

NewEmitter creates a new fanout emitter with the given emitters

func (*Emitter) Emit

func (e *Emitter) Emit(entry *entry.Entry)

Emit broadcasts the entry to all underlying emitters

func (*Emitter) Init

func (e *Emitter) Init() error

Init initializes all underlying emitters