Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrorMissingOrigin = errors.New("Event not emitted due to missing origin information")
View Source
var ErrorUnknownEventType = errors.New("Cannot create envelope for unknown event type")
Functions ¶
func NewUdpEmitter ¶
Types ¶
type ByteEmitter ¶
type EventEmitter ¶
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)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.