event

Documentation

Index

• type Broadcaster
• type Engine
  • func NewEventEngine() *Engine
  • func (e *Engine) BroadCast(evt interface{})
  • func (e *Engine) Start(ctx context.Context)
• type Event
• type EventError
  • func (e EventError) Error() string
• type Listener

Types

type Broadcaster

type Broadcaster interface {
	BroadCast(e interface{})
}

type Engine

type Engine struct {
	Register   chan Listener
	Unregister chan Listener
	// contains filtered or unexported fields
}

func NewEventEngine

func NewEventEngine() *Engine

func (*Engine) BroadCast

func (e *Engine) BroadCast(evt interface{})

func (*Engine) Start

func (e *Engine) Start(ctx context.Context)

Start event engine start function need goroutine

type Event

type Event interface {
}

type EventError

type EventError struct {
	Message string
}

func (EventError) Error

func (e EventError) Error() string

type Listener

type Listener interface {
	Listen(e interface{})
}