emitter

Documentation

Index

• Variables
• func Wrap(event events.Event, origin string) (*events.Envelope, error)
• type ByteEmitter
• type EventEmitter
  • func NewEventEmitter(byteEmitter ByteEmitter, origin string) *EventEmitter
  • func (e *EventEmitter) Close()
  • func (e *EventEmitter) Emit(event events.Event) error
  • func (e *EventEmitter) EmitEnvelope(envelope *events.Envelope) error
  • func (e *EventEmitter) Origin() string
• type UDPEmitter
  • func NewUdpEmitter(remoteAddr string) (*UDPEmitter, error)
  • func (e *UDPEmitter) Address() net.Addr
  • func (e *UDPEmitter) Close()
  • func (e *UDPEmitter) Emit(data []byte) 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 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 struct {
	// contains filtered or unexported fields
}

func NewEventEmitter

func NewEventEmitter(byteEmitter ByteEmitter, origin string) *EventEmitter

func (*EventEmitter) Close

func (e *EventEmitter) Close()

func (*EventEmitter) Emit

func (e *EventEmitter) Emit(event events.Event) error

func (*EventEmitter) EmitEnvelope

func (e *EventEmitter) EmitEnvelope(envelope *events.Envelope) error

func (*EventEmitter) Origin

func (e *EventEmitter) Origin() string

type UDPEmitter

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

func NewUdpEmitter

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

func (*UDPEmitter) Address

func (e *UDPEmitter) Address() net.Addr

func (*UDPEmitter) Close

func (e *UDPEmitter) Close()

func (*UDPEmitter) Emit

func (e *UDPEmitter) Emit(data []byte) error