emitter

Documentation

Index

• Variables
• func NewUdpEmitter(remoteAddr string) (*udpEmitter, error)
• func Wrap(event events.Event, origin string) (*events.Envelope, error)
• type ByteEmitter
• type EventEmitter
  • func NewEventEmitter(byteEmitter ByteEmitter, origin string) EventEmitter

Variables

var ErrorMissingOrigin = errors.New("Event not emitted due to missing origin information")

var ErrorUnknownEventType = errors.New("Cannot create envelope for unknown event type")

Functions

func NewUdpEmitter

func NewUdpEmitter(remoteAddr string) (*udpEmitter, error)

func Wrap

func Wrap(event events.Event, origin string) (*events.Envelope, error)

Types

type ByteEmitter

type ByteEmitter interface {
	Emit([]byte) error
	Close()
}

type EventEmitter

type EventEmitter interface {
	Emit(events.Event) error
	EmitEnvelope(*events.Envelope) error
	Close()
}

func NewEventEmitter

func NewEventEmitter(byteEmitter ByteEmitter, origin string) EventEmitter