emitter

Documentation

Index

• Variables
• func NewUdpEmitter(remoteAddr string) (*udpEmitter, error)
• func Wrap(e events.Event, origin string) (*events.Envelope, error)
• type ByteEmitter
• type EventEmitter
  • func NewEventEmitter(byteEmitter ByteEmitter, origin string) EventEmitter
• type InstrumentedEmitter
  • func NewInstrumentedEmitter(wrappedEmitter ByteEmitter) (InstrumentedEmitter, error)
• type RespondingByteEmitter
  • func NewHeartbeatResponder(byteEmitter ByteEmitter, origin string) (RespondingByteEmitter, error)

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(e 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
	Close()
}

func NewEventEmitter

func NewEventEmitter(byteEmitter ByteEmitter, origin string) EventEmitter

type InstrumentedEmitter

type InstrumentedEmitter interface {
	ByteEmitter
	GetHeartbeatEvent() events.Event
}

func NewInstrumentedEmitter

func NewInstrumentedEmitter(wrappedEmitter ByteEmitter) (InstrumentedEmitter, error)

type RespondingByteEmitter

type RespondingByteEmitter interface {
	ByteEmitter
	Respond(*control.ControlMessage)
}

func NewHeartbeatResponder

func NewHeartbeatResponder(byteEmitter ByteEmitter, origin string) (RespondingByteEmitter, error)