event

README

Event

Usage

package main

import (
	"fmt"
	"time"

	"github.com/go-kratos-ecosystem/components/v2/event"
	"github.com/go-kratos-ecosystem/components/v2/feature"
)

type testListener struct {
	feature.AsyncFeature  // async feature
}

func (l *testListener) Listen() []event.Event {
	return []event.Event{
		"test",
		"test2",
	}
}

func (l *testListener) Handle(e event.Event, data interface{}) {
	if s, ok := data.(string); ok {
		fmt.Println("event:", e, "data:", s)
	} else {
		panic("invalid data")
	}
}

type test2Listener struct{}

func (l *test2Listener) Listen() []event.Event {
	return []event.Event{
		"test",
	}
}

func (l *test2Listener) Handle(event event.Event, data interface{}) {
	fmt.Println("event:", event, "data:", data)
}

func main() {
	d := event.NewDispatcher(event.WithRecovery(func(err interface{}, listener event.Listener, event event.Event, data interface{}) { //nolint:lll
		fmt.Println("err:", err, "listener:", listener, "event:", event, "data:", data)
	}))

	d.AddListener(new(testListener), new(test2Listener))

	d.Dispatch("test", "test data")
	d.Dispatch("test2", "test2 data")
	d.Dispatch("test3", "test3 data")

	time.Sleep(time.Second)
}

Output:

event: test data: test data
event: test2 data: test2 data
event: test data: test data

Links

• https://github.com/asaskevich/EventBus

Documentation

Index

• type Dispatcher
  • func NewDispatcher(opts ...Option) *Dispatcher
  • func (d *Dispatcher) AddListener(listener ...Listener)
  • func (d *Dispatcher) Dispatch(event Event, data interface{})
• type Event
• type Listener
• type Option
  • func WithRecovery(handler RecoveryHandler) Option
• type RecoveryHandler

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(opts ...Option) *Dispatcher

func (*Dispatcher) AddListener

func (d *Dispatcher) AddListener(listener ...Listener)

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(event Event, data interface{})

type Event

type Event string

type Listener

type Listener interface {
	Listen() []Event
	Handle(event Event, data interface{})
}

type Option

type Option func(*Dispatcher)

func WithRecovery

func WithRecovery(handler RecoveryHandler) Option

type RecoveryHandler

type RecoveryHandler func(err interface{}, listener Listener, event Event, data interface{})

var DefaultRecovery RecoveryHandler = func(err interface{}, listener Listener, event Event, data interface{}) {
	log.Errorf("[Event] handler panic listener: %v, event: %s, data: %v, err: %v", listener, event, data, err)
}