eventemitter

Documentation

Index

• func GenEventID() eventID
• type Event
  • func (e Event) String() string
• type EventEmitter
  • func NewEventEmitter(ctx context.Context, size int, logger logger.Logger) EventEmitter
• type EventEmitterImpl
  • func (m *EventEmitterImpl) AddEvent(eventID eventID, f eventFunc)
  • func (m *EventEmitterImpl) Close()
  • func (m *EventEmitterImpl) EmitEvent(eventID eventID, data interface{}) error
  • func (m *EventEmitterImpl) Remove(eventID eventID)
  • func (m *EventEmitterImpl) SyncEmitEvent(eventID eventID, data interface{}) error

Functions

func GenEventID

func GenEventID() eventID

Types

type Event

type Event struct {
	Signal eventID
	Data   interface{}
}

func (Event) String

func (e Event) String() string

type EventEmitter

type EventEmitter interface {
	AddEvent(eventID eventID, f eventFunc)
	EmitEvent(eventID eventID, data interface{}) error
}

func NewEventEmitter

func NewEventEmitter(ctx context.Context, size int, logger logger.Logger) EventEmitter

type EventEmitterImpl

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

func (*EventEmitterImpl) AddEvent

func (m *EventEmitterImpl) AddEvent(eventID eventID, f eventFunc)

func (*EventEmitterImpl) Close

func (m *EventEmitterImpl) Close()

func (*EventEmitterImpl) EmitEvent

func (m *EventEmitterImpl) EmitEvent(eventID eventID, data interface{}) error

func (*EventEmitterImpl) Remove

func (m *EventEmitterImpl) Remove(eventID eventID)

func (*EventEmitterImpl) SyncEmitEvent

func (m *EventEmitterImpl) SyncEmitEvent(eventID eventID, data interface{}) error