Documentation ¶
Index ¶
Constants ¶
View Source
const DefaultConcurrency = 256 * 1024
Variables ¶
View Source
var DefaultErrorHandler = func(err error, event EventCtx) { log.Println(err) }
Functions ¶
This section is empty.
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
func New ¶
func New(source EventSource, config ...Config) *App
func (*App) RegisterHandler ¶
func (app *App) RegisterHandler(eventName string, function HandlerFunction)
type Config ¶
type Config struct { AppName string ErrorHandler ErrorHandler Concurrency int }
type ErrorHandler ¶
type EventSource ¶
type HandlerFunction ¶
type HandlerFunction func(ctx EventCtx)
Click to show internal directories.
Click to hide internal directories.