event

Documentation

Index

• type Event
• type EventHandler
• type EventHandlerFunc
  • func (f EventHandlerFunc) HandleEvent(db database.Database, e Event)
• type EventName
• type EventRegistry
  • func NewEventRegistry(db database.Database) EventRegistry

Types

type Event

type Event interface {
	Name() EventName
}

type EventHandler

type EventHandler interface {
	HandleEvent(database.Database, Event)
}

Implement same logic as in the net/http std lib

type EventHandlerFunc

type EventHandlerFunc func(database.Database, Event)

func (EventHandlerFunc) HandleEvent

func (f EventHandlerFunc) HandleEvent(db database.Database, e Event)

type EventName

type EventName string

EventName type

type EventRegistry

type EventRegistry interface {
	RegisterEventHandler(EventName, EventHandler)
	PushEvent(Event)
	Run(ctx context.Context)
}

EventRegistry is the central point for managing handlers for all kind of events

func NewEventRegistry

func NewEventRegistry(db database.Database) EventRegistry

NewEventRegistry returns an event registry where for each incoming event a list of handlers is called. We use a buffered channel for the worker go routines.