eventutil

Documentation

Index

• type Engine
  • func New(e *gin.Engine) *Engine
  • func (e *Engine) Capture(stream string, handler gin.HandlerFunc)
• type Listener

Types

type Engine

type Engine struct {
	Gin       *gin.Engine
	Listeners []Listener
}

Engine stores the Gin engine and the event listeners.

func New

func New(e *gin.Engine) *Engine

New creates the new event listener engine.

func (*Engine) Capture

func (e *Engine) Capture(stream string, handler gin.HandlerFunc)

Capture subscribes to a specified stream and capturing the incoming events.

type Listener

type Listener struct {
	Method  string
	Path    string
	Stream  string
	Handler gin.HandlerFunc
}

Listener listens and processes the specified incoming messages.